diff --git a/cctp-atu/atu-engine/atu-script-engine/src/main/java/net/northking/cctp/se/exec/DefaultExecThread.java b/cctp-atu/atu-engine/atu-script-engine/src/main/java/net/northking/cctp/se/exec/DefaultExecThread.java index 85d55c7..b73e54a 100644 --- a/cctp-atu/atu-engine/atu-script-engine/src/main/java/net/northking/cctp/se/exec/DefaultExecThread.java +++ b/cctp-atu/atu-engine/atu-script-engine/src/main/java/net/northking/cctp/se/exec/DefaultExecThread.java @@ -920,7 +920,7 @@ public class DefaultExecThread implements AtuExecThread{ } try { if (task.getRetryStrategy() != null && AtuExecConstant.TASK_RETRY_STRATEGY_PACKAGE.equals(task.getRetryStrategy())) { // - count = task.getCurrentRetryNum(); + count = task.getCurrentRetryNum(); // TODO: -3 } if(null==executeResult){ if (!this.thread.isInterrupted()) { @@ -994,6 +994,7 @@ public class DefaultExecThread implements AtuExecThread{ } String resultMsg = ""; if(0!=executeResult.getResultStatus()){ + // TODO: 这里的错误信息 resultMsg = "自动重试次数:"+count+";"+executeResult.getResultMsg(); } if (!this.thread.isInterrupted()) { diff --git a/cctp-atu/atu-execute-plan/src/main/java/net/northking/cctp/executePlan/api/service/AtuPlanTaskApiServiceImpl.java b/cctp-atu/atu-execute-plan/src/main/java/net/northking/cctp/executePlan/api/service/AtuPlanTaskApiServiceImpl.java index 75c1ca8..0403be4 100644 --- a/cctp-atu/atu-execute-plan/src/main/java/net/northking/cctp/executePlan/api/service/AtuPlanTaskApiServiceImpl.java +++ b/cctp-atu/atu-execute-plan/src/main/java/net/northking/cctp/executePlan/api/service/AtuPlanTaskApiServiceImpl.java @@ -1288,6 +1288,7 @@ public class AtuPlanTaskApiServiceImpl extends AbstractExcelService Object o = redisTemplate.opsForHash().get(RedisConstant.PLAN_BATCH_RETRY_COUNT, atuTaskExecDto.getBatchId()); if (null != o) { int count = Integer.parseInt(o.toString()); + // TODO: 如何是-3 atuTaskExecDto.setCurrentRetryNum(atuTaskExecDto.getFailRetryNum() - count); } amqpAdmin.declareQueue(new Queue(queueName));