diff --git a/cctp-atu/atu-execute-plan/src/main/java/net/northking/cctp/executePlan/job/PlanBatchTaskDataUpdateJob.java b/cctp-atu/atu-execute-plan/src/main/java/net/northking/cctp/executePlan/job/PlanBatchTaskDataUpdateJob.java index 9a34b1d..7ad2850 100644 --- a/cctp-atu/atu-execute-plan/src/main/java/net/northking/cctp/executePlan/job/PlanBatchTaskDataUpdateJob.java +++ b/cctp-atu/atu-execute-plan/src/main/java/net/northking/cctp/executePlan/job/PlanBatchTaskDataUpdateJob.java @@ -150,7 +150,9 @@ public class PlanBatchTaskDataUpdateJob { if (ObjectUtil.isNotNull(runningStatusObj)) { runningTotal = Integer.parseInt(runningStatusObj.toString()); } - + // TODO: 判断有没有负数、总数是否相等 + // 失败的数据 + // 脚本超时的 if (waitTotal != 0 || runningTotal != 0) { // 该批次还未完成 return; @@ -189,7 +191,7 @@ public class PlanBatchTaskDataUpdateJob { if (ObjectUtil.isNotNull(cancelStatusObj)) { cancelTotal = Integer.parseInt(cancelStatusObj.toString()); } - + // TODO: 统计库表数据进行更新,而不是通过缓存 // 更新批次表 AtuPlanBatch planBatch = new AtuPlanBatch(); planBatch.setId(batchId);