| | |
| | | try { |
| | | Integer maxRetry = logRecord.getMaxRetryCount(); |
| | | Integer intervalSeconds = logRecord.getRetryIntervalSeconds(); |
| | | if (maxRetry == null || intervalSeconds == null || intervalSeconds <= 0) { |
| | | if (maxRetry == null || intervalSeconds == null) { |
| | | log.warn("云仓上报待办跳过:重试参数缺失,id={},bizRef={},maxRetry={},intervalSeconds={}", |
| | | logRecord.getId(), logRecord.getBizRef(), maxRetry, intervalSeconds); |
| | | continue; |
| | | } |
| | | int effectiveIntervalSeconds = Math.max(0, intervalSeconds); |
| | | // if (logRecord.getRetryCount() != null && logRecord.getRetryCount() >= maxRetry) { |
| | | if (!isInfiniteRetry(maxRetry) |
| | | && logRecord.getRetryCount() != null |
| | |
| | | } |
| | | if (logRecord.getLastNotifyTime() != null) { |
| | | long elapsed = (nowMs - logRecord.getLastNotifyTime().getTime()) / 1000; |
| | | if (elapsed < intervalSeconds) { |
| | | if (elapsed < effectiveIntervalSeconds) { |
| | | // log.info("云仓上报待办跳过:未到重试间隔,id={},bizRef={},elapsed={}s,interval={}s", |
| | | // logRecord.getId(), logRecord.getBizRef(), elapsed, intervalSeconds); |
| | | // logRecord.getId(), logRecord.getBizRef(), elapsed, effectiveIntervalSeconds); |
| | | continue; |
| | | } |
| | | } |