From 9dfb6faea4613b0a58dc43022e5e5997d81edda4 Mon Sep 17 00:00:00 2001
From: cl <1442464845@qq.com>
Date: 星期四, 30 四月 2026 18:02:07 +0800
Subject: [PATCH] #上报 全量
---
rsf-server/src/main/java/com/vincent/rsf/server/manager/schedules/CloudWmsNotifySchedule.java | 7 ++++---
1 files changed, 4 insertions(+), 3 deletions(-)
diff --git a/rsf-server/src/main/java/com/vincent/rsf/server/manager/schedules/CloudWmsNotifySchedule.java b/rsf-server/src/main/java/com/vincent/rsf/server/manager/schedules/CloudWmsNotifySchedule.java
index 2d54b55..d5b3c13 100644
--- a/rsf-server/src/main/java/com/vincent/rsf/server/manager/schedules/CloudWmsNotifySchedule.java
+++ b/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={}锛宐izRef={}锛宮axRetry={}锛宨ntervalSeconds={}",
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={}锛宐izRef={}锛宔lapsed={}s锛宨nterval={}s",
-// logRecord.getId(), logRecord.getBizRef(), elapsed, intervalSeconds);
+// logRecord.getId(), logRecord.getBizRef(), elapsed, effectiveIntervalSeconds);
continue;
}
}
--
Gitblit v1.9.1