|
|
|
@ -54,15 +54,16 @@ public class JobFailMonitorHelper { |
|
|
|
|
if (ReturnT.SUCCESS_CODE == log.getTriggerCode() && log.getHandleCode() == 0) { |
|
|
|
|
JobFailMonitorHelper.monitor(jobLogId); |
|
|
|
|
logger.info(">>>>>>>>>>> job monitor, job running, JobLogId:{}", jobLogId); |
|
|
|
|
} |
|
|
|
|
if (ReturnT.SUCCESS_CODE == log.getTriggerCode() && ReturnT.SUCCESS_CODE == log.getHandleCode()) { |
|
|
|
|
} else if (ReturnT.SUCCESS_CODE == log.getTriggerCode() && ReturnT.SUCCESS_CODE == log.getHandleCode()) { |
|
|
|
|
// job success, pass
|
|
|
|
|
logger.info(">>>>>>>>>>> job monitor, job success, JobLogId:{}", jobLogId); |
|
|
|
|
} |
|
|
|
|
if (ReturnT.FAIL_CODE == log.getTriggerCode() || ReturnT.FAIL_CODE == log.getHandleCode()) { |
|
|
|
|
} else if (ReturnT.FAIL_CODE == log.getTriggerCode() || ReturnT.FAIL_CODE == log.getHandleCode()) { |
|
|
|
|
// job fail,
|
|
|
|
|
failAlarm(log); |
|
|
|
|
logger.info(">>>>>>>>>>> job monitor, job fail, JobLogId:{}", jobLogId); |
|
|
|
|
} else { |
|
|
|
|
JobFailMonitorHelper.monitor(jobLogId); |
|
|
|
|
logger.info(">>>>>>>>>>> job monitor, job unknown, JobLogId:{}", jobLogId); |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|