package com.gkhy.safePlatform.safeCheck.Schedules;
|
|
|
import com.gkhy.safePlatform.safeCheck.entity.SafeCheckWork;
|
import com.gkhy.safePlatform.safeCheck.enums.WorkStatusEnum;
|
import com.gkhy.safePlatform.safeCheck.mq.msg.SafeCheckCreateTaskMsg;
|
import com.gkhy.safePlatform.safeCheck.service.SafeCheckTaskUnitSchedulesService;
|
import com.gkhy.safePlatform.safeCheck.service.impl.SafeCheckTaskUnitSchedulesServicelmpl;
|
import com.gkhy.safePlatform.safeCheck.util.ConsolePrintIfEnvIsDevUtil;
|
import org.apache.log4j.LogManager;
|
import org.apache.log4j.Logger;
|
import org.apache.rocketmq.client.producer.SendResult;
|
import org.apache.rocketmq.client.producer.SendStatus;
|
import org.apache.rocketmq.spring.core.RocketMQTemplate;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.beans.factory.annotation.Value;
|
import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
|
import org.springframework.scheduling.annotation.EnableScheduling;
|
import org.springframework.scheduling.annotation.Scheduled;
|
import org.springframework.stereotype.Component;
|
import org.springframework.transaction.annotation.Transactional;
|
|
import javax.annotation.PostConstruct;
|
import java.text.SimpleDateFormat;
|
import java.util.Date;
|
import java.util.List;
|
|
|
@Component
|
@ConditionalOnProperty(prefix = "safeCheckScheduling", name = "enabled", havingValue = "true")
|
public class SafeCheckScheduleWork {
|
|
private Logger logger = LogManager.getLogger(SafeCheckWork.class);
|
|
|
@Autowired
|
private SafeCheckTaskUnitSchedulesService taskUnitSchedulesService;
|
|
@Autowired
|
private RocketMQTemplate rocketMQTemplate;
|
|
@Value("${rocketmq.topic.safeCheckCreateTaskTopic}")
|
private String safeCheckCreateTaskTopic;
|
|
|
public SafeCheckScheduleWork() {
|
}
|
|
|
@Scheduled(cron = "0 0/5 * * * ?") //每隔5分钟执行一次
|
@PostConstruct
|
public void createNewWorkTask() throws Exception {
|
ConsolePrintIfEnvIsDevUtil.consolePrintIfEnvIsDev("【智能巡检】【定时生成巡检任务】[定时查询正常任务-->启动中.......]"+new Date());
|
// System.out.println("【智能巡检】[定时生成巡检任务][定时任务启动中.......]"+new Date());
|
logger.info("【智能巡检】[定时生成巡检任务]");
|
List<SafeCheckWork> worksList = taskUnitSchedulesService.findActiveWorkListByTime();
|
if(worksList != null && worksList.size()>0){
|
ConsolePrintIfEnvIsDevUtil.consolePrintIfEnvIsDev(new Date() +" 【智能巡检】[定时生成巡检任务单元][创建巡检任务] 数量 : "+worksList.size());
|
// System.out.println(new Date() +" 【智能巡检】[定时生成巡检任务单元][创建巡检任务] 数量 : "+worksList.size());
|
logger.info(" 【智能巡检】[定时生成巡检任务单元][创建巡检任务] 数量 : "+ worksList.size());
|
worksList.forEach(work -> {
|
//1、mq发送生成task消息
|
SafeCheckCreateTaskMsg createTaskMsg = new SafeCheckCreateTaskMsg();
|
createTaskMsg.setWorkId(work.getId());
|
//在获取到调度信息后的一分钟内创建任务
|
// createTaskMsg.setCreateTaskTime(new Date(work.getNextNoticeTime().getTime()-60*1000));
|
createTaskMsg.setCreateTaskTime(new Date((new Date()).getTime()+60*1000));
|
SendResult sendResult = rocketMQTemplate.syncSend(safeCheckCreateTaskTopic, createTaskMsg);
|
// System.out.println(new Date() +" 【智能巡检】[定时生成巡检任务单元][发送消息,在获取到调度信息后的一分钟内创建任务] : "+work.getId());
|
logger.info(new Date() +" 【智能巡检】[定时生成巡检任务单元][发送消息,在获取到调度信息后的一分钟内创建任务] : "+work.getId());
|
ConsolePrintIfEnvIsDevUtil.consolePrintIfEnvIsDev(new Date() +" 【智能巡检】[定时生成巡检任务单元][发送消息,在获取到调度信息后的一分钟内创建任务] : "+work.getId());
|
if(sendResult.getSendStatus() == SendStatus.SEND_OK){
|
//2、修改调度状态
|
work.setWorkStatus(WorkStatusEnum.WORK_STATUS_DISPATCHING.getStatus());
|
taskUnitSchedulesService.updateWorkStatusById(work);
|
}
|
});
|
}
|
}
|
|
/**
|
* 重置错误的任务调度信息 调度表中如果通知时间在当前时间之前，对调度时间进行重置
|
* @throws Exception
|
*/
|
@Scheduled(cron = "0 0/4 * * * ?") //每隔5分钟执行一次
|
public void resetWorkErrorSchedule() throws Exception {
|
ConsolePrintIfEnvIsDevUtil.consolePrintIfEnvIsDev("【智能巡检】【定时生成巡检任务】[定时排查异常任务-->启动中.......]"+new Date());
|
// System.out.println("【智能巡检】[定时生成巡检任务]【定时排查异常任务】启动中.......]"+new Date());
|
logger.info("[调度异常任务处理]");
|
List<SafeCheckWork> worksList = taskUnitSchedulesService.findFaildScheduleList();
|
if(worksList != null && worksList.size()>0){
|
ConsolePrintIfEnvIsDevUtil.consolePrintIfEnvIsDev(new Date()+" [调度异常任务处理][重置调度时间] 数量 : "+worksList.size());
|
// System.out.println(new Date()+" [调度异常任务处理][重置调度时间] 数量 : "+worksList.size());
|
logger.info(" [调度异常任务处理][重置调度时间] 数量 : "+worksList.size());
|
worksList.forEach(schedule -> {
|
Date nextNoticeTime = schedule.getNextNoticeTime();
|
ConsolePrintIfEnvIsDevUtil.consolePrintIfEnvIsDev(new Date() +" 【智能巡检】[定时检查异常巡检任务单元][在当前时间十分钟后发送进行消息通知] : "+schedule.getId());
|
logger.info(new Date() +" 【智能巡检】[定时检查异常巡检任务单元][在当前时间十分钟后发送进行消息通知] : "+schedule.getId());
|
// System.out.println(new Date() +" 【智能巡检】[定时检查异常巡检任务单元][在当前时间十分钟后发送进行消息通知] : "+schedule.getId());
|
Date newNoticeTime = new Date((new Date()).getTime() + (10 * 60 * 1000));
|
SimpleDateFormat formatter = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
|
logger.info(" [调度异常任务处理][重置任务调度时间] WORKID : "+ schedule.getId()+" 旧的通知时间:"+ formatter.format(nextNoticeTime)+" 新的通知时间:"+formatter.format(newNoticeTime));
|
ConsolePrintIfEnvIsDevUtil.consolePrintIfEnvIsDev(
|
"[调度异常任务处理][重置任务调度时间] WORKID : "+ schedule.getId()+" 旧的通知时间:"+ formatter.format(nextNoticeTime)+" 新的通知时间:"+formatter.format(newNoticeTime));
|
// System.out.println(" [调度异常任务处理][重置任务调度时间] WORKID : "+ schedule.getId()+" 旧的通知时间:"+ formatter.format(nextNoticeTime)+" 新的通知时间:"+formatter.format(newNoticeTime));
|
if(schedule !=null && schedule.getId()>0){
|
taskUnitSchedulesService.resetScheduleTime(schedule.getId(),newNoticeTime);
|
}
|
});
|
}
|
}
|
}
|
