From 749667c292417691b80e9bb47842bf03c6576ea2 Mon Sep 17 00:00:00 2001
From: Junjie <fallin.jie@qq.com>
Date: 星期三, 01 四月 2026 16:43:01 +0800
Subject: [PATCH] #入库任务优化
---
src/main/java/com/zy/core/utils/WmsOperateUtils.java | 117 +++++++++++++++++++++++++++++++++++++++++++++-------------
1 files changed, 90 insertions(+), 27 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..358a9e0 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;
@@ -67,7 +68,12 @@
}
public String applyInTask(InTaskApplyRequest request) {
+ long startMs = System.currentTimeMillis();
+ Map<String, Long> stepCostMap = new LinkedHashMap<>();
+
+ long redisGetStartNs = System.nanoTime();
Object systemConfigMapObj = redisUtil.get(RedisKeyType.SYSTEM_CONFIG_MAP.key);
+ addStepCost(stepCostMap, "redisUtil.get", elapsedMsFromNano(redisGetStartNs));
if (systemConfigMapObj == null) {
News.error("绯荤粺Config缂撳瓨澶辨晥");
return null;
@@ -90,8 +96,10 @@
String response = null;
int result = 0;
try {
+ long stationQueryStartNs = System.nanoTime();
BasStation basStation = basStationService
.getOne(new QueryWrapper<BasStation>().eq("station_id", request.getSourceStaNo()));
+ addStepCost(stepCostMap, "basStationService.getOne", elapsedMsFromNano(stationQueryStartNs));
if (basStation == null) {
News.error("绔欑偣{}涓嶅瓨鍦�", request.getSourceStaNo());
return null;
@@ -105,35 +113,41 @@
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()));
+ long getRowStartNs = System.nanoTime();
+ requestParam.put("row", Utils.getInTaskEnableRowWithCache(request.getSourceStaNo()));
+ addStepCost(stepCostMap, "Utils.getInTaskEnableRowWithCache", elapsedMsFromNano(getRowStartNs));
if (request.getExtraParams() != null && !request.getExtraParams().isEmpty()) {
requestParam.putAll(request.getExtraParams());
}
+ long httpPostStartNs = System.nanoTime();
response = new HttpHandler.Builder()
.setUri(wmsUrl)
.setPath(wmsSystemInUrl)
.setJson(JSON.toJSONString(requestParam))
- .setTimeout(30, TimeUnit.SECONDS)
+ .setTimeout(APPLY_IN_TASK_TIMEOUT_SECONDS, TimeUnit.SECONDS)
.build()
.doPost();
+ addStepCost(stepCostMap, "HttpHandler.doPost", elapsedMsFromNano(httpPostStartNs));
if (!Cools.isEmpty(response)) {
+ long parseResponseStartNs = System.nanoTime();
JSONObject jsonObject = JSON.parseObject(response);
+ addStepCost(stepCostMap, "JSON.parseObject", elapsedMsFromNano(parseResponseStartNs));
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);
@@ -141,7 +155,15 @@
httpRequestLog.setResponse(response);
httpRequestLog.setCreateTime(new Date());
httpRequestLog.setResult(result);
- httpRequestLogService.save(httpRequestLog);
+ long saveRequestLogStartNs = System.nanoTime();
+ try {
+ httpRequestLogService.save(httpRequestLog);
+ } finally {
+ addStepCost(stepCostMap, "httpRequestLogService.save", elapsedMsFromNano(saveRequestLogStartNs));
+ News.info("WMS鍏ュ簱鐢宠鑰楁椂缁熻锛歶rl锛歿}锛沚arcode锛歿}锛泂ourceStaNo锛歿}锛泂tepCosts锛歿}锛泂lowestStep锛歿}锛泃otalCost={}ms",
+ wmsUrl + wmsSystemInUrl, request.getBarcode(), request.getSourceStaNo(),
+ formatStepCosts(stepCostMap), getSlowestStep(stepCostMap), elapsedMs(startMs));
+ }
}
return response;
}
@@ -180,6 +202,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 +227,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 +314,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 +331,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 +360,35 @@
return response;
}
+ private long elapsedMs(long startMs) {
+ return System.currentTimeMillis() - startMs;
+ }
+
+ private long elapsedMsFromNano(long startNs) {
+ return TimeUnit.NANOSECONDS.toMillis(System.nanoTime() - startNs);
+ }
+
+ private void addStepCost(Map<String, Long> stepCostMap, String stepName, long costMs) {
+ stepCostMap.put(stepName, costMs);
+ }
+
+ private String formatStepCosts(Map<String, Long> stepCostMap) {
+ return JSON.toJSONString(stepCostMap);
+ }
+
+ private String getSlowestStep(Map<String, Long> stepCostMap) {
+ String slowestStepName = "-";
+ long maxCostMs = -1L;
+ for (Map.Entry<String, Long> entry : stepCostMap.entrySet()) {
+ if (entry.getValue() != null && entry.getValue() > maxCostMs) {
+ slowestStepName = entry.getKey();
+ maxCostMs = entry.getValue();
+ }
+ }
+ if (maxCostMs < 0) {
+ return "-";
+ }
+ return slowestStepName + "=" + maxCostMs + "ms";
+ }
+
}
--
Gitblit v1.9.1