|
|
@ -12,6 +12,7 @@ import cn.estsh.i3plus.pojo.base.enumutil.ImppEnumUtil;
|
|
|
|
import cn.estsh.i3plus.pojo.platform.bean.SysMessage;
|
|
|
|
import cn.estsh.i3plus.pojo.platform.bean.SysMessage;
|
|
|
|
import cn.estsh.i3plus.pojo.platform.bean.SysTaskPlan;
|
|
|
|
import cn.estsh.i3plus.pojo.platform.bean.SysTaskPlan;
|
|
|
|
import cn.estsh.i3plus.pojo.platform.platbean.SysLogTaskTime;
|
|
|
|
import cn.estsh.i3plus.pojo.platform.platbean.SysLogTaskTime;
|
|
|
|
|
|
|
|
import cn.estsh.impp.framework.boot.util.ImppLog;
|
|
|
|
import com.alibaba.fastjson.JSON;
|
|
|
|
import com.alibaba.fastjson.JSON;
|
|
|
|
import com.rabbitmq.client.Channel;
|
|
|
|
import com.rabbitmq.client.Channel;
|
|
|
|
import org.slf4j.Logger;
|
|
|
|
import org.slf4j.Logger;
|
|
|
@ -48,6 +49,9 @@ public class ScheduleQueueReceiver {
|
|
|
|
@Autowired
|
|
|
|
@Autowired
|
|
|
|
private RabbitTemplate rabbitTemplate;
|
|
|
|
private RabbitTemplate rabbitTemplate;
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
@Autowired
|
|
|
|
|
|
|
|
private ImppLog imppLog;
|
|
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
/**
|
|
|
|
* 定时任务通道处理
|
|
|
|
* 定时任务通道处理
|
|
|
|
*
|
|
|
|
*
|
|
|
@ -76,7 +80,7 @@ public class ScheduleQueueReceiver {
|
|
|
|
logTaskTime.setTaskCycleNameRdd(taskPlan.getTaskCycleNameRdd());
|
|
|
|
logTaskTime.setTaskCycleNameRdd(taskPlan.getTaskCycleNameRdd());
|
|
|
|
logTaskTime.setTaskCycleExpsRdd(taskPlan.getTaskCycleExpsRdd());
|
|
|
|
logTaskTime.setTaskCycleExpsRdd(taskPlan.getTaskCycleExpsRdd());
|
|
|
|
ConvertBean.serviceModelInitialize(logTaskTime, "system");
|
|
|
|
ConvertBean.serviceModelInitialize(logTaskTime, "system");
|
|
|
|
sysTaskPlanService.logInsertSysLogTaskTime(logTaskTime);
|
|
|
|
imppLog.insertSysLogTaskTime(logTaskTime);
|
|
|
|
|
|
|
|
|
|
|
|
// 定时任务失败通知
|
|
|
|
// 定时任务失败通知
|
|
|
|
if (CommonEnumUtil.TRUE_OR_FALSE.FALSE.getValue() == logTaskTime.getTaskStatus()
|
|
|
|
if (CommonEnumUtil.TRUE_OR_FALSE.FALSE.getValue() == logTaskTime.getTaskStatus()
|
|
|
|