From 1817a79605b464735014a00e762e715788229a4b Mon Sep 17 00:00:00 2001
From: Junjie <fallin.jie@qq.com>
Date: 星期三, 01 四月 2026 11:41:14 +0800
Subject: [PATCH] #入库获取Row优化
---
src/main/java/com/zy/core/utils/WmsOperateUtils.java | 65 ++++++++++++++++++++------------
1 files changed, 40 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 0c33c6d..2edc720 100644
--- a/src/main/java/com/zy/core/utils/WmsOperateUtils.java
+++ b/src/main/java/com/zy/core/utils/WmsOperateUtils.java
@@ -90,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()));
@@ -106,7 +107,7 @@
requestParam.put("barcode", request.getBarcode());
requestParam.put("sourceStaNo", stationNo);
requestParam.put("locType1", request.getLocType1() == null ? 1 : request.getLocType1());
- requestParam.put("row", Utils.getInTaskEnableRow(request.getSourceStaNo()));
+ requestParam.put("row", Utils.getInTaskEnableRowWithCache(request.getSourceStaNo()));
if (request.getExtraParams() != null && !request.getExtraParams().isEmpty()) {
requestParam.putAll(request.getExtraParams());
}
@@ -122,19 +123,19 @@
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);
@@ -181,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<>();
@@ -205,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);
@@ -288,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);
@@ -304,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);
@@ -329,4 +340,8 @@
return response;
}
+ private long elapsedMs(long startMs) {
+ return System.currentTimeMillis() - startMs;
+ }
+
}
--
Gitblit v1.9.1