From a5e0d72c0a71f795e56690879a560ce715fa6313 Mon Sep 17 00:00:00 2001
From: zwl <1051256694@qq.com>
Date: 星期五, 20 三月 2026 08:54:01 +0800
Subject: [PATCH] 入库口强制入库确认后还会退回一次，才可入库修复
---
src/main/java/com/zy/core/utils/WmsOperateUtils.java | 33 +++++++++++++++++++++++++++++----
1 files changed, 29 insertions(+), 4 deletions(-)
diff --git a/src/main/java/com/zy/core/utils/WmsOperateUtils.java b/src/main/java/com/zy/core/utils/WmsOperateUtils.java
index 67e1df5..e28f5ce 100644
--- a/src/main/java/com/zy/core/utils/WmsOperateUtils.java
+++ b/src/main/java/com/zy/core/utils/WmsOperateUtils.java
@@ -33,6 +33,7 @@
import java.util.Date;
import java.util.HashMap;
import java.util.List;
+import java.util.UUID;
import java.util.concurrent.TimeUnit;
@Component
@@ -147,6 +148,7 @@
*/
public void applyInTaskAsync(String barcode, Integer sourceStaNo, Integer locType1,Double weight) {
String requestKey = RedisKeyType.ASYNC_WMS_IN_TASK_REQUEST.key + barcode + "_" + sourceStaNo;
+ String requestVersionKey = RedisKeyType.ASYNC_WMS_IN_TASK_REQUEST_VERSION.key + barcode + "_" + sourceStaNo;
String responseKey = RedisKeyType.ASYNC_WMS_IN_TASK_RESPONSE.key + barcode + "_" + sourceStaNo;
// 妫�鏌ユ槸鍚﹀凡鏈夎姹傚湪杩涜涓�
@@ -155,13 +157,21 @@
return; // 宸叉湁璇锋眰鍦ㄨ繘琛屼腑锛岃烦杩�
}
- // 鏍囪璇锋眰杩涜涓紝璁剧疆60绉掕秴鏃�
- redisUtil.set(requestKey, "processing", 60);
+ String requestId = UUID.randomUUID().toString();
+ // 鏍囪璇锋眰杩涜涓紝璁板綍褰撳墠鏈�鏂拌姹傜増鏈紝鏃ц姹傛櫄鍒版椂涓嶅厑璁歌鐩栨柊缁撴灉
+ redisUtil.set(requestKey, requestId, 120);
+ redisUtil.set(requestVersionKey, requestId, 600);
+ redisUtil.del(responseKey);
// 鎻愪氦寮傛浠诲姟
new Thread(() -> {
try {
String response = applyInTask(barcode, sourceStaNo, locType1,weight);
+ Object latestRequestVersion = redisUtil.get(requestVersionKey);
+ if (latestRequestVersion == null || !requestId.equals(latestRequestVersion.toString())) {
+ News.info("蹇界暐杩囨湡寮傛WMS鍏ュ簱鍝嶅簲锛宐arcode={}锛宻tationId={}锛宺equestId={}", barcode, sourceStaNo, requestId);
+ return;
+ }
if (response != null) {
// 瀛樺偍鍝嶅簲缁撴灉锛岃缃�60绉掕秴鏃�
redisUtil.set(responseKey, response, 60);
@@ -173,10 +183,16 @@
}
} catch (Exception e) {
News.error("寮傛WMS鍏ュ簱璇锋眰寮傚父锛宐arcode={}锛宻tationId={}锛宔rror={},weight={}", barcode, sourceStaNo, e.getMessage(),weight);
- redisUtil.set(responseKey, "ERROR:" + e.getMessage(), 10);
+ Object latestRequestVersion = redisUtil.get(requestVersionKey);
+ if (latestRequestVersion != null && requestId.equals(latestRequestVersion.toString())) {
+ redisUtil.set(responseKey, "ERROR:" + e.getMessage(), 10);
+ }
} finally {
// 娓呴櫎璇锋眰杩涜涓爣璁�
- redisUtil.del(requestKey);
+ Object currentRequest = redisUtil.get(requestKey);
+ if (currentRequest != null && requestId.equals(currentRequest.toString())) {
+ redisUtil.del(requestKey);
+ }
}
}).start();
}
@@ -211,6 +227,15 @@
return redisUtil.get(requestKey) != null;
}
+ public void clearAsyncInTaskCache(String barcode, Integer stationId) {
+ String cacheSuffix = barcode + "_" + stationId;
+ redisUtil.del(
+ RedisKeyType.ASYNC_WMS_IN_TASK_REQUEST.key + cacheSuffix,
+ RedisKeyType.ASYNC_WMS_IN_TASK_REQUEST_VERSION.key + cacheSuffix,
+ RedisKeyType.ASYNC_WMS_IN_TASK_RESPONSE.key + cacheSuffix
+ );
+ }
+
// 鐢宠浠诲姟閲嶆柊鍒嗛厤搴撲綅
public synchronized String applyReassignTaskLocNo(Integer taskNo, Integer stationId) {
String wmsUrl = null;
--
Gitblit v1.9.1