日志存储优化

yun-zuoyi
wei.peng 6 years ago
parent 38d5bc10da
commit b61b59ff76

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

Loading…
Cancel
Save