|
|
@ -12,6 +12,7 @@ import com.hnac.hzims.operational.maintenance.mapper.OperMaintenanceTaskMapper; |
|
|
|
import com.hnac.hzims.operational.maintenance.service.IOperMaintenanceMonitorService; |
|
|
|
import com.hnac.hzims.operational.maintenance.service.IOperMaintenanceMonitorService; |
|
|
|
import com.hnac.hzims.operational.maintenance.vo.OperMaintenancePlanVO; |
|
|
|
import com.hnac.hzims.operational.maintenance.vo.OperMaintenancePlanVO; |
|
|
|
import com.hnac.hzims.operational.maintenance.wrapper.OperMaintenancePlanWrapper; |
|
|
|
import com.hnac.hzims.operational.maintenance.wrapper.OperMaintenancePlanWrapper; |
|
|
|
|
|
|
|
import org.apache.commons.lang3.StringUtils; |
|
|
|
import org.springblade.core.tool.api.R; |
|
|
|
import org.springblade.core.tool.api.R; |
|
|
|
import org.springblade.core.tool.utils.*; |
|
|
|
import org.springblade.core.tool.utils.*; |
|
|
|
import org.springblade.system.user.cache.UserCache; |
|
|
|
import org.springblade.system.user.cache.UserCache; |
|
|
@ -32,61 +33,61 @@ import java.util.stream.Collectors; |
|
|
|
**/ |
|
|
|
**/ |
|
|
|
@Service |
|
|
|
@Service |
|
|
|
public class OperMaintenanceMonitorServiceImpl implements IOperMaintenanceMonitorService { |
|
|
|
public class OperMaintenanceMonitorServiceImpl implements IOperMaintenanceMonitorService { |
|
|
|
@Autowired |
|
|
|
@Autowired |
|
|
|
private OperMaintenanceParameterMapper parameterMapper; |
|
|
|
private OperMaintenanceParameterMapper parameterMapper; |
|
|
|
@Autowired |
|
|
|
@Autowired |
|
|
|
private OperMaintenanceTaskMapper taskMapper; |
|
|
|
private OperMaintenanceTaskMapper taskMapper; |
|
|
|
@Autowired |
|
|
|
@Autowired |
|
|
|
private OperMaintenancePlanMapper planMapper; |
|
|
|
private OperMaintenancePlanMapper planMapper; |
|
|
|
@Autowired |
|
|
|
@Autowired |
|
|
|
private IImsDutyClassService imsDutyClassService; |
|
|
|
private IImsDutyClassService imsDutyClassService; |
|
|
|
|
|
|
|
|
|
|
|
@Override |
|
|
|
@Override |
|
|
|
public R<Map<String, List<OperMaintenancePlanVO>>> reportMonth(OperMaintenanceMonitorReportMonthDTO req) { |
|
|
|
public R<Map<String, List<OperMaintenancePlanVO>>> reportMonth(OperMaintenanceMonitorReportMonthDTO req) { |
|
|
|
List<OperMaintenancePlanEntity> planEntities = planMapper.selectList(new LambdaQueryWrapper<OperMaintenancePlanEntity>() {{ |
|
|
|
List<OperMaintenancePlanEntity> planEntities = planMapper.selectList(new LambdaQueryWrapper<OperMaintenancePlanEntity>() {{ |
|
|
|
LocalDate startDate = LocalDate.of(req.getYear(), req.getMonth(),1); |
|
|
|
LocalDate startDate = LocalDate.of(req.getYear(), req.getMonth(), 1); |
|
|
|
// Date startTime = DateUtil.parse(DateUtil.format(DateUtil.now(), "yyyy-MM") + "-01", DateUtil.PATTERN_DATE);
|
|
|
|
// Date startTime = DateUtil.parse(DateUtil.format(DateUtil.now(), "yyyy-MM") + "-01", DateUtil.PATTERN_DATE);
|
|
|
|
eq(OperMaintenancePlanEntity::getIsDeleted, 0L); |
|
|
|
eq(OperMaintenancePlanEntity::getIsDeleted, 0L); |
|
|
|
ge(OperMaintenancePlanEntity::getDisposeTime, startDate); |
|
|
|
ge(OperMaintenancePlanEntity::getDisposeTime, startDate); |
|
|
|
lt(OperMaintenancePlanEntity::getDisposeTime, startDate.with(TemporalAdjusters.lastDayOfMonth())); |
|
|
|
lt(OperMaintenancePlanEntity::getDisposeTime, startDate.with(TemporalAdjusters.lastDayOfMonth())) |
|
|
|
}}); |
|
|
|
.eq(StringUtils.isNoneBlank(req.getStationCode()), OperMaintenancePlanEntity::getStationCode, req.getStationCode()); |
|
|
|
|
|
|
|
}}); |
|
|
|
|
|
|
|
|
|
|
|
//获取列表班次ID集合
|
|
|
|
//获取列表班次ID集合
|
|
|
|
List<Long> classIdList = planEntities.stream().filter(planEntity -> ObjectUtil.isNotEmpty(planEntity.getImsDutyClassId())) |
|
|
|
List<Long> classIdList = planEntities.stream().filter(planEntity -> ObjectUtil.isNotEmpty(planEntity.getImsDutyClassId())) |
|
|
|
.map(OperMaintenancePlanEntity::getImsDutyClassId).collect(Collectors.toList()); |
|
|
|
.map(OperMaintenancePlanEntity::getImsDutyClassId).collect(Collectors.toList()); |
|
|
|
IImsDutyClassService imsDutyClassService = SpringUtil.getBean(IImsDutyClassService.class); |
|
|
|
IImsDutyClassService imsDutyClassService = SpringUtil.getBean(IImsDutyClassService.class); |
|
|
|
Map<Long,List<ImsDutyClassEntity>> classMap = null; |
|
|
|
Map<Long, List<ImsDutyClassEntity>> classMap = null; |
|
|
|
if(CollectionUtil.isNotEmpty(classIdList)) { |
|
|
|
if (CollectionUtil.isNotEmpty(classIdList)) { |
|
|
|
List<ImsDutyClassEntity> classEntityList = imsDutyClassService.list(new LambdaQueryWrapper<ImsDutyClassEntity>(){{ |
|
|
|
List<ImsDutyClassEntity> classEntityList = imsDutyClassService.list(new LambdaQueryWrapper<ImsDutyClassEntity>() {{ |
|
|
|
in(ImsDutyClassEntity::getId,classIdList); |
|
|
|
in(ImsDutyClassEntity::getId, classIdList); |
|
|
|
}}); |
|
|
|
}}); |
|
|
|
if(CollectionUtil.isNotEmpty(classEntityList)) { |
|
|
|
if (CollectionUtil.isNotEmpty(classEntityList)) { |
|
|
|
classMap = classEntityList.stream().collect(Collectors.groupingBy(ImsDutyClassEntity::getId)); |
|
|
|
classMap = classEntityList.stream().collect(Collectors.groupingBy(ImsDutyClassEntity::getId)); |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
//完善班次与执行人
|
|
|
|
//完善班次与执行人
|
|
|
|
List<OperMaintenancePlanVO> operMaintenancePlanVOS = new ArrayList<>(); |
|
|
|
List<OperMaintenancePlanVO> operMaintenancePlanVOS = new ArrayList<>(); |
|
|
|
Map<Long, List<ImsDutyClassEntity>> finalClassMap = classMap; |
|
|
|
Map<Long, List<ImsDutyClassEntity>> finalClassMap = classMap; |
|
|
|
planEntities.forEach(planEntity -> { |
|
|
|
planEntities.forEach(planEntity -> { |
|
|
|
OperMaintenancePlanVO planVO = BeanUtil.copy(planEntity,OperMaintenancePlanVO.class); |
|
|
|
OperMaintenancePlanVO planVO = BeanUtil.copy(planEntity, OperMaintenancePlanVO.class); |
|
|
|
if(ObjectUtil.isNotEmpty(planEntity.getImsDutyClassId())) { |
|
|
|
if (ObjectUtil.isNotEmpty(planEntity.getImsDutyClassId())) { |
|
|
|
//类型为班次时 获取班次名称
|
|
|
|
//类型为班次时 获取班次名称
|
|
|
|
planVO.setDutyClassName(finalClassMap.get(planEntity.getImsDutyClassId()).get(0).getClassName()); |
|
|
|
planVO.setDutyClassName(finalClassMap.get(planEntity.getImsDutyClassId()).get(0).getClassName()); |
|
|
|
} |
|
|
|
} else if (ObjectUtil.isNotEmpty(planEntity.getDisposer())) { |
|
|
|
else if(ObjectUtil.isNotEmpty(planEntity.getDisposer())) { |
|
|
|
//类型为人员类型时 获取执行人名称
|
|
|
|
//类型为人员类型时 获取执行人名称
|
|
|
|
planVO.setDisposerName(Optional.ofNullable(UserCache.getUser(planEntity.getDisposer())).map(User::getName).orElse(null)); |
|
|
|
planVO.setDisposerName(Optional.ofNullable(UserCache.getUser(planEntity.getDisposer())).map(User::getName).orElse(null)); |
|
|
|
} |
|
|
|
} |
|
|
|
//当月是否生成任务 默认是false
|
|
|
|
//当月是否生成任务 默认是false
|
|
|
|
LocalDateTime createTaskTime = com.hnac.hzims.common.utils.DateUtil.DateToLocalDateTime(planEntity.getCreateTaskTime()); |
|
|
|
LocalDateTime createTaskTime = com.hnac.hzims.common.utils.DateUtil.DateToLocalDateTime(planEntity.getCreateTaskTime()); |
|
|
|
if (ObjectUtil.isNotEmpty(createTaskTime) && com.hnac.hzims.common.utils.DateUtil.judgeSameDay(createTaskTime, LocalDate.now())) { |
|
|
|
if(ObjectUtil.isNotEmpty(createTaskTime) && com.hnac.hzims.common.utils.DateUtil.judgeSameDay(createTaskTime, LocalDate.now())) { |
|
|
|
planVO.setGenerateSign(true); |
|
|
|
planVO.setGenerateSign(true); |
|
|
|
} |
|
|
|
} |
|
|
|
operMaintenancePlanVOS.add(planVO); |
|
|
|
operMaintenancePlanVOS.add(planVO); |
|
|
|
}); |
|
|
|
}); |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
Map<String, List<OperMaintenancePlanVO>> data = operMaintenancePlanVOS.stream().collect(Collectors.groupingBy(o -> DateUtil.formatDate(o.getDisposeTime()))); |
|
|
|
Map<String, List<OperMaintenancePlanVO>> data = operMaintenancePlanVOS.stream().collect(Collectors.groupingBy(o -> DateUtil.formatDate(o.getDisposeTime()))); |
|
|
|
return R.data(new TreeMap<>(data)); |
|
|
|
return R.data(new TreeMap<>(data)); |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|