From 9b5af12c3aa92719105e171ccca2aa24e6b4664f Mon Sep 17 00:00:00 2001
From: "jieying.li" <jieying.li@northking.net>
Date: Mon, 2 Dec 2024 19:20:00 +0800
Subject: [PATCH] =?UTF-8?q?fix=EF=BC=9A=E6=89=A7=E8=A1=8C=E8=AE=A1?=
 =?UTF-8?q?=E5=88=92=201.=E7=BB=9F=E8=AE=A1=E9=9C=80=E8=A6=81=E4=BF=AE?=
 =?UTF-8?q?=E6=94=B9=E7=9A=84=E5=9C=B0=E6=96=B9=EF=BC=8Ctodo?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../cctp/executePlan/job/PlanBatchTaskDataUpdateJob.java    | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)

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);