parent
1065c305d2
commit
9b5af12c3a
|
@ -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);
|
||||
|
|
Loading…
Reference in New Issue