yineng.huang
/
hz
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

场景-3的TODO，发生错误的大致位置

hz_1122
darkmanlee 2025-01-06 19:51:30 +08:00
parent 795a83a563
commit ef393d13fe
2 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
cctp-atu/atu-engine/atu-script-engine/src/main/java/net/northking/cctp/se/exec/DefaultExecThread.java
View File

@ -920,7 +920,7 @@ public class DefaultExecThread implements AtuExecThread{
} }
try { try {
if (task.getRetryStrategy() != null && AtuExecConstant.TASK_RETRY_STRATEGY_PACKAGE.equals(task.getRetryStrategy())) { // if (task.getRetryStrategy() != null && AtuExecConstant.TASK_RETRY_STRATEGY_PACKAGE.equals(task.getRetryStrategy())) { //
count = task.getCurrentRetryNum(); count = task.getCurrentRetryNum(); // TODO: -3
} }
if(null==executeResult){ if(null==executeResult){
if (!this.thread.isInterrupted()) { if (!this.thread.isInterrupted()) {
@ -994,6 +994,7 @@ public class DefaultExecThread implements AtuExecThread{
} }
String resultMsg = ""; String resultMsg = "";
if(0!=executeResult.getResultStatus()){ if(0!=executeResult.getResultStatus()){
// TODO: 这里的错误信息
resultMsg = "自动重试次数："+count+";"+executeResult.getResultMsg(); resultMsg = "自动重试次数："+count+";"+executeResult.getResultMsg();
} }
if (!this.thread.isInterrupted()) { if (!this.thread.isInterrupted()) {

1
cctp-atu/atu-execute-plan/src/main/java/net/northking/cctp/executePlan/api/service/AtuPlanTaskApiServiceImpl.java
View File

@ -1288,6 +1288,7 @@ public class AtuPlanTaskApiServiceImpl extends AbstractExcelService<AtuPlanTask>
Object o = redisTemplate.opsForHash().get(RedisConstant.PLAN_BATCH_RETRY_COUNT, atuTaskExecDto.getBatchId()); Object o = redisTemplate.opsForHash().get(RedisConstant.PLAN_BATCH_RETRY_COUNT, atuTaskExecDto.getBatchId());
if (null != o) { if (null != o) {
int count = Integer.parseInt(o.toString()); int count = Integer.parseInt(o.toString());
// TODO: 如何是-3
atuTaskExecDto.setCurrentRetryNum(atuTaskExecDto.getFailRetryNum() - count); atuTaskExecDto.setCurrentRetryNum(atuTaskExecDto.getFailRetryNum() - count);
} }
amqpAdmin.declareQueue(new Queue(queueName)); amqpAdmin.declareQueue(new Queue(queueName));