From 1654b0a8c149f86d38f3202cb88c655ad0a25384 Mon Sep 17 00:00:00 2001
From: Junjie <fallin.jie@qq.com>
Date: 星期三, 01 四月 2026 10:33:25 +0800
Subject: [PATCH] #出库任务路径计算增加cache
---
src/main/java/com/zy/core/utils/WmsOperateUtils.java | 66 ++++++++++++++++++++------------
1 files changed, 41 insertions(+), 25 deletions(-)
diff --git a/src/main/java/com/zy/core/utils/WmsOperateUtils.java b/src/main/java/com/zy/core/utils/WmsOperateUtils.java
index 4b81b92..45eedcd 100644
--- a/src/main/java/com/zy/core/utils/WmsOperateUtils.java
+++ b/src/main/java/com/zy/core/utils/WmsOperateUtils.java
@@ -39,6 +39,7 @@
@Component
public class WmsOperateUtils {
+ private static final int APPLY_IN_TASK_TIMEOUT_SECONDS = 5;
@Autowired
private ConfigService configService;
@@ -89,6 +90,7 @@
Map<String, Object> requestParam = new LinkedHashMap<>();
String response = null;
int result = 0;
+ long startMs = System.currentTimeMillis();
try {
BasStation basStation = basStationService
.getOne(new QueryWrapper<BasStation>().eq("station_id", request.getSourceStaNo()));
@@ -114,26 +116,26 @@
.setUri(wmsUrl)
.setPath(wmsSystemInUrl)
.setJson(JSON.toJSONString(requestParam))
- .setTimeout(30, TimeUnit.SECONDS)
+ .setTimeout(APPLY_IN_TASK_TIMEOUT_SECONDS, TimeUnit.SECONDS)
.build()
.doPost();
if (!Cools.isEmpty(response)) {
JSONObject jsonObject = JSON.parseObject(response);
if (jsonObject.getInteger("code") == 200) {
result = 1;
- News.info("璇锋眰WMS鍏ュ簱鎺ュ彛鎴愬姛锛侊紒锛乽rl锛歿}锛況equest锛歿}锛況esponse锛歿}", wmsUrl + wmsSystemInUrl,
- JSON.toJSONString(requestParam), response);
+ News.info("璇锋眰WMS鍏ュ簱鎺ュ彛鎴愬姛锛侊紒锛乽rl锛歿}锛況equest锛歿}锛況esponse锛歿}锛沜ost={}ms",
+ wmsUrl + wmsSystemInUrl, JSON.toJSONString(requestParam), response, elapsedMs(startMs));
} else {
- News.info("璇锋眰WMS鍏ュ簱鎺ュ彛澶辫触锛屾帴鍙ｈ繑鍥濩ode寮傚父锛侊紒锛乽rl锛歿}锛況equest锛歿}锛況esponse锛歿}", wmsUrl + wmsSystemInUrl,
- JSON.toJSONString(requestParam), response);
+ News.info("璇锋眰WMS鍏ュ簱鎺ュ彛澶辫触锛屾帴鍙ｈ繑鍥濩ode寮傚父锛侊紒锛乽rl锛歿}锛況equest锛歿}锛況esponse锛歿}锛沜ost={}ms",
+ wmsUrl + wmsSystemInUrl, JSON.toJSONString(requestParam), response, elapsedMs(startMs));
}
} else {
- News.info("璇锋眰WMS鍏ュ簱鎺ュ彛澶辫触锛屾帴鍙ｆ湭鍝嶅簲锛侊紒锛乽rl锛歿}锛況equest锛歿}锛況esponse锛歿}", wmsUrl + wmsSystemInUrl,
- JSON.toJSONString(requestParam), response);
+ News.info("璇锋眰WMS鍏ュ簱鎺ュ彛澶辫触锛屾帴鍙ｆ湭鍝嶅簲锛侊紒锛乽rl锛歿}锛況equest锛歿}锛況esponse锛歿}锛沜ost={}ms",
+ wmsUrl + wmsSystemInUrl, JSON.toJSONString(requestParam), response, elapsedMs(startMs));
}
} catch (Exception e) {
- News.error("璇锋眰WMS鍏ュ簱鎺ュ彛寮傚父锛侊紒锛乽rl锛歿}锛況equest锛歿}锛況esponse锛歿}", wmsUrl + wmsSystemInUrl,
- JSON.toJSONString(requestParam), response, e);
+ News.error("璇锋眰WMS鍏ュ簱鎺ュ彛寮傚父锛侊紒锛乽rl锛歿}锛況equest锛歿}锛況esponse锛歿}锛沜ost={}ms", wmsUrl + wmsSystemInUrl,
+ JSON.toJSONString(requestParam), response, elapsedMs(startMs), e);
} finally {
HttpRequestLog httpRequestLog = new HttpRequestLog();
httpRequestLog.setName(wmsUrl + wmsSystemInUrl);
@@ -180,6 +182,7 @@
HashMap<String, Object> requestParam = new HashMap<>();
String response = null;
int result = 0;
+ long startMs = System.currentTimeMillis();
try {
List<Integer> excludeCrnList = new ArrayList<>();
List<Integer> excludeDualCrnList = new ArrayList<>();
@@ -204,19 +207,23 @@
JSONObject jsonObject = JSON.parseObject(response);
if (jsonObject.getInteger("code") == 200) {
result = 1;
- News.info("璇锋眰鐢宠浠诲姟閲嶆柊鍒嗛厤鍏ュ簱鎺ュ彛鎴愬姛锛侊紒锛乽rl锛歿}锛況equest锛歿}锛況esponse锛歿}", wmsUrl + wmsSystemReassignInTaskUrl,
- JSON.toJSONString(requestParam), response);
+ News.info("璇锋眰鐢宠浠诲姟閲嶆柊鍒嗛厤鍏ュ簱鎺ュ彛鎴愬姛锛侊紒锛乽rl锛歿}锛況equest锛歿}锛況esponse锛歿}锛沜ost={}ms",
+ wmsUrl + wmsSystemReassignInTaskUrl, JSON.toJSONString(requestParam), response,
+ elapsedMs(startMs));
} else {
- News.info("璇锋眰鐢宠浠诲姟閲嶆柊鍒嗛厤鍏ュ簱鎺ュ彛澶辫触锛屾帴鍙ｈ繑鍥濩ode寮傚父锛侊紒锛乽rl锛歿}锛況equest锛歿}锛況esponse锛歿}",
- wmsUrl + wmsSystemReassignInTaskUrl, JSON.toJSONString(requestParam), response);
+ News.info("璇锋眰鐢宠浠诲姟閲嶆柊鍒嗛厤鍏ュ簱鎺ュ彛澶辫触锛屾帴鍙ｈ繑鍥濩ode寮傚父锛侊紒锛乽rl锛歿}锛況equest锛歿}锛況esponse锛歿}锛沜ost={}ms",
+ wmsUrl + wmsSystemReassignInTaskUrl, JSON.toJSONString(requestParam), response,
+ elapsedMs(startMs));
}
} else {
- News.info("璇锋眰鐢宠浠诲姟閲嶆柊鍒嗛厤鍏ュ簱鎺ュ彛澶辫触锛屾帴鍙ｆ湭鍝嶅簲锛侊紒锛乽rl锛歿}锛況equest锛歿}锛況esponse锛歿}", wmsUrl + wmsSystemReassignInTaskUrl,
- JSON.toJSONString(requestParam), response);
+ News.info("璇锋眰鐢宠浠诲姟閲嶆柊鍒嗛厤鍏ュ簱鎺ュ彛澶辫触锛屾帴鍙ｆ湭鍝嶅簲锛侊紒锛乽rl锛歿}锛況equest锛歿}锛況esponse锛歿}锛沜ost={}ms",
+ wmsUrl + wmsSystemReassignInTaskUrl, JSON.toJSONString(requestParam), response,
+ elapsedMs(startMs));
}
} catch (Exception e) {
- News.error("璇锋眰鐢宠浠诲姟閲嶆柊鍒嗛厤鍏ュ簱鎺ュ彛寮傚父锛侊紒锛乽rl锛歿}锛況equest锛歿}锛� response锛歿}", wmsUrl + wmsSystemReassignInTaskUrl,
- JSON.toJSONString(requestParam), response, e);
+ News.error("璇锋眰鐢宠浠诲姟閲嶆柊鍒嗛厤鍏ュ簱鎺ュ彛寮傚父锛侊紒锛乽rl锛歿}锛況equest锛歿}锛� response锛歿}锛沜ost={}ms",
+ wmsUrl + wmsSystemReassignInTaskUrl, JSON.toJSONString(requestParam), response,
+ elapsedMs(startMs), e);
} finally {
HttpRequestLog httpRequestLog = new HttpRequestLog();
httpRequestLog.setName(wmsUrl + wmsSystemReassignInTaskUrl);
@@ -287,6 +294,7 @@
HashMap<String, Object> requestParam = new HashMap<>();
String response = null;
int result = 0;
+ long startMs = System.currentTimeMillis();
try {
requestParam.put("locNo", locNo);
requestParam.put("row", crnRows);
@@ -303,19 +311,23 @@
JSONObject jsonObject = JSON.parseObject(response);
if (jsonObject.getInteger("code") == 200) {
result = 1;
- News.info("璇锋眰WMS鐢宠鏇存崲搴撲綅鎺ュ彛鎴愬姛锛侊紒锛乽rl锛歿}锛況equest锛歿}锛況esponse锛歿}", wmsUrl + wmsSystemChangeLocNoUrl,
- JSON.toJSONString(requestParam), response);
+ News.info("璇锋眰WMS鐢宠鏇存崲搴撲綅鎺ュ彛鎴愬姛锛侊紒锛乽rl锛歿}锛況equest锛歿}锛況esponse锛歿}锛沜ost={}ms",
+ wmsUrl + wmsSystemChangeLocNoUrl, JSON.toJSONString(requestParam), response,
+ elapsedMs(startMs));
} else {
- News.info("璇锋眰WMS鐢宠鏇存崲搴撲綅鎺ュ彛澶辫触锛屾帴鍙ｈ繑鍥濩ode寮傚父锛侊紒锛乽rl锛歿}锛況equest锛歿}锛況esponse锛歿}",
- wmsUrl + wmsSystemChangeLocNoUrl, JSON.toJSONString(requestParam), response);
+ News.info("璇锋眰WMS鐢宠鏇存崲搴撲綅鎺ュ彛澶辫触锛屾帴鍙ｈ繑鍥濩ode寮傚父锛侊紒锛乽rl锛歿}锛況equest锛歿}锛況esponse锛歿}锛沜ost={}ms",
+ wmsUrl + wmsSystemChangeLocNoUrl, JSON.toJSONString(requestParam), response,
+ elapsedMs(startMs));
}
} else {
- News.info("璇锋眰WMS鐢宠鏇存崲搴撲綅鎺ュ彛澶辫触锛屾帴鍙ｆ湭鍝嶅簲锛侊紒锛乽rl锛歿}锛況equest锛歿}锛況esponse锛歿}", wmsUrl + wmsSystemChangeLocNoUrl,
- JSON.toJSONString(requestParam), response);
+ News.info("璇锋眰WMS鐢宠鏇存崲搴撲綅鎺ュ彛澶辫触锛屾帴鍙ｆ湭鍝嶅簲锛侊紒锛乽rl锛歿}锛況equest锛歿}锛況esponse锛歿}锛沜ost={}ms",
+ wmsUrl + wmsSystemChangeLocNoUrl, JSON.toJSONString(requestParam), response,
+ elapsedMs(startMs));
}
} catch (Exception e) {
- News.error("璇锋眰WMS鐢宠鏇存崲搴撲綅鎺ュ彛寮傚父锛侊紒锛乽rl锛歿}锛況equest锛歿}锛況esponse锛歿}", wmsUrl + wmsSystemChangeLocNoUrl,
- JSON.toJSONString(requestParam), response, e);
+ News.error("璇锋眰WMS鐢宠鏇存崲搴撲綅鎺ュ彛寮傚父锛侊紒锛乽rl锛歿}锛況equest锛歿}锛況esponse锛歿}锛沜ost={}ms",
+ wmsUrl + wmsSystemChangeLocNoUrl, JSON.toJSONString(requestParam), response,
+ elapsedMs(startMs), e);
} finally {
HttpRequestLog httpRequestLog = new HttpRequestLog();
httpRequestLog.setName(wmsUrl + wmsSystemChangeLocNoUrl);
@@ -328,4 +340,8 @@
return response;
}
+ private long elapsedMs(long startMs) {
+ return System.currentTimeMillis() - startMs;
+ }
+
}
--
Gitblit v1.9.1