From cb2f02d60aac235f2f9e5ef777e0141fb697c264 Mon Sep 17 00:00:00 2001
From: cl <1442464845@qq.com>
Date: 星期五, 01 五月 2026 15:18:11 +0800
Subject: [PATCH] 多加入参数和修改规则
---
rsf-server/src/main/java/com/vincent/rsf/server/manager/service/impl/CloudWmsNotifyLogServiceImpl.java | 8 ++++----
1 files changed, 4 insertions(+), 4 deletions(-)
diff --git a/rsf-server/src/main/java/com/vincent/rsf/server/manager/service/impl/CloudWmsNotifyLogServiceImpl.java b/rsf-server/src/main/java/com/vincent/rsf/server/manager/service/impl/CloudWmsNotifyLogServiceImpl.java
index c9726d0..a8d03ee 100644
--- a/rsf-server/src/main/java/com/vincent/rsf/server/manager/service/impl/CloudWmsNotifyLogServiceImpl.java
+++ b/rsf-server/src/main/java/com/vincent/rsf/server/manager/service/impl/CloudWmsNotifyLogServiceImpl.java
@@ -36,7 +36,7 @@
/** 鍗曟潯寰呭姙銆屾鍦ㄤ笂鎶ャ�峈edis 鍗犱綅绉掓暟锛圫ET NX EX锛� */
private static final int CLOUD_WMS_NOTIFY_SENDING_REDIS_TTL_SECONDS = 120;
/** sending=1 浣� Redis 鏃犲崰浣嶏細update_time 鏃╀簬姝ゆ椂闀匡紙鍒嗛挓锛夊垯琛ュ伩娓呴浂 */
- private static final int STALE_SENDING_RECOVER_AFTER_MINUTES = 6;
+ private static final int STALE_SENDING_RECOVER_AFTER_MINUTES = 2;
@Autowired
private ConfigService configService;
@@ -73,12 +73,12 @@
@Override
public List<CloudWmsNotifyLog> listPending(int limit, int maxRetry) {
LambdaQueryWrapper<CloudWmsNotifyLog> wrapper = new LambdaQueryWrapper<CloudWmsNotifyLog>()
- // 浠呮煡璇㈡暟鎹簱閰嶇疆鐘舵�侊細寰呴�氱煡 + 澶辫触锛堝彲閲嶈瘯锛�
+ // 浠呮煡璇㈡暟鎹簱閰嶇疆鐘舵��
.in(CloudWmsNotifyLog::getNotifyStatus, getNotifyStatusPending(), getNotifyStatusFail())
.apply("(send_hold IS NULL OR send_hold = 0)")
- // 浠呮煡璇㈠彲閲嶈瘯鏁版嵁锛氭棤闄愰噸璇曘�佹湭閰嶇疆涓婇檺銆佹垨鏈揪鍒颁笂闄�
+ // 浠呮煡璇㈠彲閲嶈瘯鏁版嵁
.apply("(max_retry_count IS NULL OR max_retry_count = -1 OR retry_count < max_retry_count)")
- // 浠呮煡璇㈠凡鍒伴噸璇曟椂闂寸殑鏁版嵁锛岄伩鍏嶅墠 50 鏉℃湭鍒伴棿闅斿鑷村悗缁褰曢暱鏈熼ゥ楗�
+ // 浠呮煡璇㈠凡鍒伴噸璇曟椂闂寸殑鏁版嵁
.apply("(last_notify_time IS NULL OR retry_interval_seconds IS NULL OR retry_interval_seconds <= 0 OR TIMESTAMPDIFF(SECOND, last_notify_time, NOW()) >= retry_interval_seconds)")
//缂洪噸璇曞弬鏁扮殑涓嶈繘鍏ュ緟鍙戦�佸垪琛�
.isNotNull(CloudWmsNotifyLog::getMaxRetryCount)
--
Gitblit v1.9.1