package org.dromara.analy.service.impl; import org.dromara.common.core.utils.MapstructUtils; import org.dromara.common.core.utils.StringUtils; import org.dromara.common.mybatis.core.page.TableDataInfo; import org.dromara.common.mybatis.core.page.PageQuery; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.toolkit.Wrappers; import lombok.RequiredArgsConstructor; import lombok.extern.slf4j.Slf4j; import org.springframework.stereotype.Service; import org.dromara.analy.domain.bo.HoisterTimeDataBo; import org.dromara.analy.domain.vo.HoisterTimeDataVo; import org.dromara.analy.domain.HoisterTimeData; import org.dromara.analy.mapper.HoisterTimeDataMapper; import org.dromara.analy.service.IHoisterTimeDataService; import java.util.Date; import java.util.List; import java.util.Map; import java.util.Collection; /** * 提升机分析Service业务层处理 * * @author zhuguifei * @date 2026-02-02 */ @Slf4j @RequiredArgsConstructor @Service public class HoisterTimeDataServiceImpl implements IHoisterTimeDataService { private final HoisterTimeDataMapper baseMapper; /** * 查询提升机分析 * * @param time 主键 * @return 提升机分析 */ @Override public HoisterTimeDataVo queryById(Date time){ return baseMapper.selectVoById(time); } /** * 分页查询提升机分析列表 * * @param bo 查询条件 * @param pageQuery 分页参数 * @return 提升机分析分页列表 */ @Override public TableDataInfo queryPageList(HoisterTimeDataBo bo, PageQuery pageQuery) { LambdaQueryWrapper lqw = buildQueryWrapper(bo); Page result = baseMapper.selectVoPage(pageQuery.build(), lqw); return TableDataInfo.build(result); } /** * 查询符合条件的提升机分析列表 * * @param bo 查询条件 * @return 提升机分析列表 */ @Override public List queryList(HoisterTimeDataBo bo) { LambdaQueryWrapper lqw = buildQueryWrapper(bo); return baseMapper.selectVoList(lqw); } private LambdaQueryWrapper buildQueryWrapper(HoisterTimeDataBo bo) { Map params = bo.getParams(); LambdaQueryWrapper lqw = Wrappers.lambdaQuery(); lqw.eq(bo.getTime() != null, HoisterTimeData::getTime, bo.getTime()); lqw.eq(StringUtils.isNotBlank(bo.getKey()), HoisterTimeData::getKey, bo.getKey()); lqw.eq(bo.getOnline() != null, HoisterTimeData::getOnline, bo.getOnline()); lqw.eq(bo.getShift() != null, HoisterTimeData::getShift, bo.getShift()); lqw.eq(bo.getEquNo() != null, HoisterTimeData::getEquNo, bo.getEquNo()); lqw.between(params.get("beginTime") != null && params.get("endTime") != null, HoisterTimeData::getTime, params.get("beginTime"), params.get("endTime")); return lqw; } /** * 新增提升机分析 * * @param bo 提升机分析 * @return 是否新增成功 */ @Override public Boolean insertByBo(HoisterTimeDataBo bo) { HoisterTimeData add = MapstructUtils.convert(bo, HoisterTimeData.class); validEntityBeforeSave(add); boolean flag = baseMapper.insert(add) > 0; if (flag) { bo.setTime(add.getTime()); } return flag; } /** * 修改提升机分析 * * @param bo 提升机分析 * @return 是否修改成功 */ @Override public Boolean updateByBo(HoisterTimeDataBo bo) { HoisterTimeData update = MapstructUtils.convert(bo, HoisterTimeData.class); validEntityBeforeSave(update); return baseMapper.updateById(update) > 0; } /** * 保存前的数据校验 */ private void validEntityBeforeSave(HoisterTimeData entity){ //TODO 做一些数据校验,如唯一约束 } /** * 校验并批量删除提升机分析信息 * * @param ids 待删除的主键集合 * @param isValid 是否进行有效性校验 * @return 是否删除成功 */ @Override public Boolean deleteWithValidByIds(Collection ids, Boolean isValid) { if(isValid){ //TODO 做一些业务上的校验,判断是否需要校验 } return baseMapper.deleteByIds(ids) > 0; } }