Browse Source

debug 重试到10

master
PoffyZhang 1 year ago
parent
commit
40eba2fd07
2 changed files with 2 additions and 2 deletions
  1. +1
    -1
      pmapi/src/main/java/com/ningdatech/pmapi/staging/service/impl/NdWorkNoticeStagingServiceImpl.java
  2. +1
    -1
      pmapi/src/main/java/com/ningdatech/pmapi/staging/service/impl/ProjectStagingServiceImpl.java

+ 1
- 1
pmapi/src/main/java/com/ningdatech/pmapi/staging/service/impl/NdWorkNoticeStagingServiceImpl.java View File

@@ -48,7 +48,7 @@ public class NdWorkNoticeStagingServiceImpl extends ServiceImpl<NdWorkNoticeStag
log.info("没有对应重试间隔时间 添加重试信息失败"); log.info("没有对应重试间隔时间 添加重试信息失败");
return Boolean.FALSE; return Boolean.FALSE;
} }
Integer addSeconds = workNoticeFlowMapUtil.intervalTimeMap.get(retryTimes);
Integer addSeconds = workNoticeFlowMapUtil.intervalTimeMap.get(workNoticeStaging.getRetryTimes());
Boolean dead = Boolean.FALSE; Boolean dead = Boolean.FALSE;
//超过重试最大次数 dead置为 true //超过重试最大次数 dead置为 true
if (retryTimes.compareTo(StagingContant.Retry.MAX_RETRY_TIMES) > 0) { if (retryTimes.compareTo(StagingContant.Retry.MAX_RETRY_TIMES) > 0) {


+ 1
- 1
pmapi/src/main/java/com/ningdatech/pmapi/staging/service/impl/ProjectStagingServiceImpl.java View File

@@ -65,7 +65,7 @@ public class ProjectStagingServiceImpl extends ServiceImpl<ProjectStagingMapper,
log.info("没有对应重试间隔时间 添加重试信息失败"); log.info("没有对应重试间隔时间 添加重试信息失败");
return Boolean.FALSE; return Boolean.FALSE;
} }
Integer addSeconds = projectStatusFlowUtil.intervalTimeMap.get(retryTimes);
Integer addSeconds = projectStatusFlowUtil.intervalTimeMap.get(projectStaging.getRetryTimes());
Boolean dead = Boolean.FALSE; Boolean dead = Boolean.FALSE;
//超过重试最大次数 dead置为 true //超过重试最大次数 dead置为 true
if(retryTimes.compareTo(StagingContant.Retry.MAX_RETRY_TIMES) > 0){ if(retryTimes.compareTo(StagingContant.Retry.MAX_RETRY_TIMES) > 0){


Loading…
Cancel
Save