cl
7 天以前 9dfb6faea4613b0a58dc43022e5e5997d81edda4
rsf-server/src/main/java/com/vincent/rsf/server/manager/schedules/CloudWmsNotifySchedule.java
@@ -48,11 +48,12 @@
            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
@@ -63,9 +64,9 @@
                }
                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;
                    }
                }