4 changed files with 150 additions and 1 deletions
@ -0,0 +1,134 @@ |
|||||||
|
package com.hnac.hzims.operational.maintenance.scheduled; |
||||||
|
|
||||||
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; |
||||||
|
import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper; |
||||||
|
import com.baomidou.mybatisplus.core.toolkit.Wrappers; |
||||||
|
import com.hnac.hzims.equipment.feign.IEmInfoClient; |
||||||
|
import com.hnac.hzims.operational.duty.entity.ImsDutyMainEntity; |
||||||
|
import com.hnac.hzims.operational.maintenance.entity.OperMaintenanceLibraryEntity; |
||||||
|
import com.hnac.hzims.operational.maintenance.entity.OperMaintenancePlanEntity; |
||||||
|
import com.hnac.hzims.operational.maintenance.entity.OperMaintenanceTaskEntity; |
||||||
|
import com.hnac.hzims.operational.maintenance.mapper.OperMaintenanceLibraryMapper; |
||||||
|
import com.hnac.hzims.operational.maintenance.service.IOperMaintenancePlanService; |
||||||
|
import com.hnac.hzims.operational.maintenance.service.IOperMaintenanceTaskService; |
||||||
|
import com.hnac.hzinfo.inspect.plan.entity.PlanEntity; |
||||||
|
import com.xxl.job.core.biz.model.ReturnT; |
||||||
|
import com.xxl.job.core.handler.annotation.XxlJob; |
||||||
|
import com.xxl.job.core.log.XxlJobLogger; |
||||||
|
import lombok.AllArgsConstructor; |
||||||
|
import lombok.extern.slf4j.Slf4j; |
||||||
|
import org.apache.commons.lang.StringUtils; |
||||||
|
import org.springblade.core.log.logger.BladeLogger; |
||||||
|
import org.springblade.core.tool.utils.*; |
||||||
|
import org.springblade.flow.core.feign.IFlowClient; |
||||||
|
import org.springblade.system.user.feign.IUserClient; |
||||||
|
import org.springframework.beans.factory.annotation.Autowired; |
||||||
|
import org.springframework.stereotype.Component; |
||||||
|
|
||||||
|
import java.time.Instant; |
||||||
|
import java.time.LocalDateTime; |
||||||
|
import java.time.ZoneId; |
||||||
|
import java.time.format.DateTimeFormatter; |
||||||
|
import java.util.*; |
||||||
|
import java.util.stream.Collectors; |
||||||
|
|
||||||
|
import static com.hnac.hzims.operational.maintenance.constants.ScheduledConstant.TASK_VALUE_MAINTENANCE_TASK_CREATE; |
||||||
|
import static org.springblade.core.tool.utils.DateUtil.PATTERN_DATE; |
||||||
|
|
||||||
|
/** |
||||||
|
* 日常维护任务生成 |
||||||
|
*/ |
||||||
|
@Component |
||||||
|
@Slf4j |
||||||
|
@AllArgsConstructor |
||||||
|
public class MaintenanceTaskSchedule { |
||||||
|
|
||||||
|
private final BladeLogger logger; |
||||||
|
private final IOperMaintenancePlanService planService; |
||||||
|
private final IOperMaintenanceTaskService taskService; |
||||||
|
private final IFlowClient flowClient; |
||||||
|
|
||||||
|
@XxlJob(TASK_VALUE_MAINTENANCE_TASK_CREATE) |
||||||
|
public ReturnT<String> execute(String param) throws Exception { |
||||||
|
Date startDate = StringUtil.isNotBlank(param) ? DateUtil.parse(param, DateUtil.PATTERN_DATE) : DateUtil.parse(DateUtil.formatDate(DateUtil.now()), DateUtil.PATTERN_DATE); |
||||||
|
Date endDate = DateUtil.parse(DateUtil.formatDate(DateUtil.plusDays(startDate, 1)), DateUtil.PATTERN_DATE); |
||||||
|
LambdaQueryWrapper<OperMaintenancePlanEntity> planQW = Wrappers.<OperMaintenancePlanEntity>lambdaQuery().isNull(OperMaintenancePlanEntity::getCreateTaskTime) |
||||||
|
.gt(OperMaintenancePlanEntity::getDisposeTime, startDate).le(OperMaintenancePlanEntity::getDisposeTime, endDate); |
||||||
|
List<OperMaintenancePlanEntity> planList = planService.list(planQW); |
||||||
|
XxlJobLogger.log("日常维护任务生成开始！计划ID为:"+planList.stream().map(OperMaintenancePlanEntity::getId).map(String::valueOf).collect(Collectors.joining(","))); |
||||||
|
//分页插入日常维护计划
|
||||||
|
planList.forEach(this::generateTaskByPlan); |
||||||
|
XxlJobLogger.log("日常维护任务生成完成！"); |
||||||
|
return new ReturnT<>("SUCCESS"); |
||||||
|
} |
||||||
|
|
||||||
|
/** |
||||||
|
* 根据日常维护计划生成日常维护任务 |
||||||
|
* @param plan 日常维护计划 |
||||||
|
*/ |
||||||
|
private void generateTaskByPlan(OperMaintenancePlanEntity plan) { |
||||||
|
try { |
||||||
|
OperMaintenanceTaskEntity taskEntity = BeanUtil.copy(plan,OperMaintenanceTaskEntity.class); |
||||||
|
taskEntity.setPlanId(plan.getId()); |
||||||
|
taskEntity.setDisposer(Optional.ofNullable(plan.getDisposer()).map(String::valueOf).orElse(null)); |
||||||
|
LocalDateTime disposeTime = taskEntity.getDisposeTime().toInstant() |
||||||
|
.atZone(ZoneId.systemDefault()).toLocalDateTime(); |
||||||
|
taskEntity.setPlanEndTime(disposeTime.plusHours(taskEntity.getHours())); |
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
if(StringUtil.isNotBlank(plan.getEmCode())){ |
||||||
|
List<String> emCodeList = Arrays.asList(plan.getEmCode().split(",")); |
||||||
|
for(String emCode : emCodeList){ |
||||||
|
taskEntity.setEmCode(emCode); |
||||||
|
this.createTask(taskEntity); |
||||||
|
} |
||||||
|
} |
||||||
|
else { |
||||||
|
this.createTask(taskEntity); |
||||||
|
} |
||||||
|
} |
||||||
|
catch(Exception e) { |
||||||
|
logger.error("MaintenanceTaskSchedule:generateTaskByPlan",e.getLocalizedMessage()); |
||||||
|
XxlJobLogger.log(plan.getId()+"计划创建任务失败"); |
||||||
|
// 查询到日常维护计划所创建的任务
|
||||||
|
List<OperMaintenanceTaskEntity> maintenanceTasks = taskService.list(Wrappers.<OperMaintenanceTaskEntity>lambdaQuery().eq(OperMaintenanceTaskEntity::getPlanId, plan.getId())); |
||||||
|
for (OperMaintenanceTaskEntity maintenanceTask : maintenanceTasks) { |
||||||
|
if(Func.isNotEmpty(maintenanceTask.getProcessInstanceId())) { |
||||||
|
flowClient.delProcessInstanceById(maintenanceTask.getProcessInstanceId(),"错误流程"); |
||||||
|
taskService.removeById(maintenanceTask.getId()); |
||||||
|
} |
||||||
|
} |
||||||
|
} |
||||||
|
} |
||||||
|
|
||||||
|
/** |
||||||
|
* 创建日常维护任务以及生成工作流 |
||||||
|
* @param task 日常维护任务 |
||||||
|
*/ |
||||||
|
private void createTask(OperMaintenanceTaskEntity task) { |
||||||
|
task.setId(null); |
||||||
|
task.setCreateTime(new Date()); |
||||||
|
task.setUpdateTime(new Date()); |
||||||
|
task.setTaskCode(UUID.randomUUID().toString()); |
||||||
|
// if (ObjectUtil.isNotEmpty(task.getMaintenanceModel()) && finalPlanEntity.getMaintenanceModel() == 2) {
|
||||||
|
// //查询值班信息
|
||||||
|
// LambdaQueryWrapper<ImsDutyMainEntity> entityLambdaQueryWrapper = new LambdaQueryWrapper<>();
|
||||||
|
// entityLambdaQueryWrapper.eq(ImsDutyMainEntity::getDutyDate, DateTimeFormatter.ofPattern(PATTERN_DATE).format(disposeTime));
|
||||||
|
// entityLambdaQueryWrapper.eq(ImsDutyMainEntity::getClassId, finalPlanEntity.getImsDutyClassId());
|
||||||
|
// ImsDutyMainEntity entity = mainService.getOne(entityLambdaQueryWrapper);
|
||||||
|
// if (ObjectUtil.isNotEmpty(entity) && StringUtils.isNotEmpty(entity.getDutyPersonIds())) {
|
||||||
|
// String userId = entity.getDutyPersonIds();
|
||||||
|
// taskEntity.setDisposer(userId.replaceAll("\\^", ","));
|
||||||
|
// } else {
|
||||||
|
// log.info("计划ID为：{}未查询到排班记录", finalPlanEntity.getId());
|
||||||
|
// LambdaUpdateWrapper<OperMaintenancePlanEntity> planQueryWrapper = Wrappers.<OperMaintenancePlanEntity>lambdaUpdate()
|
||||||
|
// .set(OperMaintenancePlanEntity::getCreateTaskTime, new Date())
|
||||||
|
// .eq(OperMaintenancePlanEntity::getId, finalPlanEntity.getId());
|
||||||
|
// maintenancePlanService.update(planQueryWrapper);
|
||||||
|
// return;
|
||||||
|
// }
|
||||||
|
// }
|
||||||
|
} |
||||||
|
|
||||||
|
} |
||||||
Loading…
Reference in new issue