package com.by4cloud.platformx.device.service.impl; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.by4cloud.platformx.admin.api.entity.SysUser; import com.by4cloud.platformx.device.dto.InspectionTaskQueryDTO; import com.by4cloud.platformx.device.entity.InspectionTask; import com.by4cloud.platformx.device.entity.InspectionTaskItem; import com.by4cloud.platformx.device.mapper.InspectionTaskItemMapper; import com.by4cloud.platformx.device.mapper.InspectionTaskMapper; import com.by4cloud.platformx.device.service.InspectionTaskService; import lombok.AllArgsConstructor; import org.springframework.stereotype.Service; import java.util.List; /** * 巡检任务 * * @author syt * @date 2025-04-22 09:15:32 */ @Service @AllArgsConstructor public class InspectionTaskServiceImpl extends ServiceImpl implements InspectionTaskService { private final InspectionTaskItemMapper itemMapper; @Override public IPage pageNew(Page page, InspectionTaskQueryDTO queryDTO) { return baseMapper.page(page,queryDTO); } @Override public InspectionTask getByIdNew(Long id) { InspectionTask task = baseMapper.selectById(id); QueryWrapper queryWrapper = new QueryWrapper<>(); queryWrapper.eq("task_id",id); List taskItemList = itemMapper.selectList(queryWrapper); task.setItemList(taskItemList); return task; } @Override public boolean updateByIdNew(InspectionTask inspectionTask) { inspectionTask.getItemList().stream().forEach(item->{ itemMapper.updateById(item); }); inspectionTask.setTaskStatus(2); baseMapper.updateById(inspectionTask); return true; } @Override public boolean taskStartById(Long id) { InspectionTask task = baseMapper.selectById(id); task.setTaskStatus(1); baseMapper.updateById(task); return true; } }