提交 1e7eea13 authored 作者: xueli.xue's avatar xueli.xue

任务执行回调,SUCCESS状态才会触发子任务fix

上级 cbeaf5a4
...@@ -44,7 +44,7 @@ public class XxlJobLogCallbackServerHandler extends AbstractHandler { ...@@ -44,7 +44,7 @@ public class XxlJobLogCallbackServerHandler extends AbstractHandler {
// trigger success, to trigger child job, and avoid repeat trigger child job // trigger success, to trigger child job, and avoid repeat trigger child job
String childTriggerMsg = null; String childTriggerMsg = null;
if (!ResponseModel.SUCCESS.equals(log.getHandleStatus())) { if (ResponseModel.SUCCESS.equals(requestModel.getStatus()) && !ResponseModel.SUCCESS.equals(log.getHandleStatus())) {
XxlJobInfo xxlJobInfo = DynamicSchedulerUtil.xxlJobInfoDao.load(log.getJobGroup(), log.getJobName()); XxlJobInfo xxlJobInfo = DynamicSchedulerUtil.xxlJobInfoDao.load(log.getJobGroup(), log.getJobName());
if (xxlJobInfo!=null && StringUtils.isNotBlank(xxlJobInfo.getChildJobKey())) { if (xxlJobInfo!=null && StringUtils.isNotBlank(xxlJobInfo.getChildJobKey())) {
childTriggerMsg = "<hr>"; childTriggerMsg = "<hr>";
......
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论