From 1cb18ad19e48be2b944b005db1b950a667725fc6 Mon Sep 17 00:00:00 2001
From: Junjie <fallin.jie@qq.com>
Date: 星期三, 06 五月 2026 16:33:27 +0800
Subject: [PATCH] #log
---
src/main/java/com/zy/common/utils/NavigateUtils.java | 110 ++++++++++++++++++++++++++++++++++++++++++++-----------
1 files changed, 88 insertions(+), 22 deletions(-)
diff --git a/src/main/java/com/zy/common/utils/NavigateUtils.java b/src/main/java/com/zy/common/utils/NavigateUtils.java
index 2dbe19c..72229ba 100644
--- a/src/main/java/com/zy/common/utils/NavigateUtils.java
+++ b/src/main/java/com/zy/common/utils/NavigateUtils.java
@@ -27,6 +27,7 @@
import com.zy.asrs.service.StationCycleCapacityService;
import com.zy.asrs.service.StationPathPolicyService;
import com.zy.core.News;
+import lombok.extern.slf4j.Slf4j;
import org.springframework.scheduling.annotation.Scheduled;
import com.zy.core.model.StationObjModel;
import com.zy.core.model.command.StationCommand;
@@ -53,6 +54,7 @@
import java.util.LinkedHashMap;
@Component
+@Slf4j
public class NavigateUtils {
private static final long STATION_PATH_SLOW_LOG_THRESHOLD_MS = 500L;
@@ -111,29 +113,59 @@
Integer endStationId,
Integer currentTaskNo,
Double pathLenFactor) {
- StationPathResolvedPolicy resolvedPolicy = resolveStationPathPolicy(startStationId, endStationId);
- StationPathRuntimeSnapshot runtimeSnapshot = loadStationPathRuntimeSnapshot(currentTaskNo);
- StationPathSearchContext context = buildStationPathSearchContext(
- startStationId,
- endStationId,
- resolvedPolicy,
- StationPathCalcMode.REROUTE,
- runtimeSnapshot
- );
- if (context.allList.isEmpty()) {
- return new ArrayList<>();
- }
+ long totalStartNs = System.nanoTime();
+ log.info("绔欑偣璺緞鍊欓�夎绠楀叆鍙ｏ紝startStationId={}锛宔ndStationId={}锛宼askNo={}锛宲athLenFactor={}",
+ startStationId, endStationId, currentTaskNo, pathLenFactor);
+ try {
+ StationPathResolvedPolicy resolvedPolicy = resolveStationPathPolicy(startStationId, endStationId);
+ log.info("绔欑偣璺緞鍊欓�夌瓥鐣ヨВ鏋愬畬鎴愶紝startStationId={}锛宔ndStationId={}锛宼askNo={}锛宮atchedRule={}锛宺uleCode={}锛宲rofileCode={}锛宑ostMs={}",
+ startStationId,
+ endStationId,
+ currentTaskNo,
+ resolvedPolicy != null && resolvedPolicy.matchedRule(),
+ resolvedPolicy == null || resolvedPolicy.getRuleEntity() == null ? null : resolvedPolicy.getRuleEntity().getRuleCode(),
+ resolvedPolicy == null ? null : resolvedPolicy.getDefaultProfileCode(),
+ elapsedMillis(totalStartNs));
+ StationPathRuntimeSnapshot runtimeSnapshot = loadStationPathRuntimeSnapshot(currentTaskNo);
+ StationPathSearchContext context = buildStationPathSearchContext(
+ startStationId,
+ endStationId,
+ resolvedPolicy,
+ StationPathCalcMode.REROUTE,
+ runtimeSnapshot
+ );
+ if (context.allList.isEmpty()) {
+ log.warn("绔欑偣璺緞鍊欓�夎绠楃粨鏉燂紝鍘熷洜=empty_search_context锛宻tartStationId={}锛宔ndStationId={}锛宼askNo={}锛宼otalCostMs={}",
+ startStationId, endStationId, currentTaskNo, elapsedMillis(totalStartNs));
+ return new ArrayList<>();
+ }
- List<List<NavigateNode>> orderedPathList = orderStationPathCandidates(
- context.allList,
- context.resolvedPolicy,
- currentTaskNo,
- pathLenFactor,
- startStationId,
- endStationId,
- runtimeSnapshot
- );
- return normalizeCandidatePaths(orderedPathList);
+ long orderStartNs = System.nanoTime();
+ List<List<NavigateNode>> orderedPathList = orderStationPathCandidates(
+ context.allList,
+ context.resolvedPolicy,
+ currentTaskNo,
+ pathLenFactor,
+ startStationId,
+ endStationId,
+ runtimeSnapshot
+ );
+ List<List<NavigateNode>> normalizedPathList = normalizeCandidatePaths(orderedPathList);
+ log.info("绔欑偣璺緞鍊欓�夎绠楃粨鏉燂紝startStationId={}锛宔ndStationId={}锛宼askNo={}锛宺awCandidateCount={}锛宱rderedPathCount={}锛宯ormalizedPathCount={}锛宱rderCostMs={}锛宼otalCostMs={}",
+ startStationId,
+ endStationId,
+ currentTaskNo,
+ context.allList.size(),
+ orderedPathList == null ? null : orderedPathList.size(),
+ normalizedPathList.size(),
+ elapsedMillis(orderStartNs),
+ elapsedMillis(totalStartNs));
+ return normalizedPathList;
+ } catch (Exception e) {
+ log.error("绔欑偣璺緞鍊欓�夎绠楀紓甯革紝startStationId={}锛宔ndStationId={}锛宼askNo={}锛宲athLenFactor={}锛宑ostMs={}",
+ startStationId, endStationId, currentTaskNo, pathLenFactor, elapsedMillis(totalStartNs), e);
+ throw e;
+ }
}
public Map<Integer, Set<Integer>> loadUndirectedStationGraphSnapshot() {
@@ -2685,6 +2717,8 @@
}
Integer lev = startStation.getStationLev();
stepCostMap.put("loadStartStation", elapsedMillis(stepStartNs));
+ log.info("绔欑偣璺緞鎼滅储涓婁笅鏂囧姞杞借捣鐐瑰畬鎴愶紝startStationId={}锛宔ndStationId={}锛宮ode={}锛宭ev={}锛宑ostMs={}",
+ startStationId, endStationId, calcMode, lev, stepCostMap.get("loadStartStation"));
stepStartNs = System.nanoTime();
NavigateSolution navigateSolution = new NavigateSolution();
@@ -2701,6 +2735,16 @@
throw new CoolException("鏈壘鍒拌 缁堢偣 瀵瑰簲鐨勮妭鐐�");
}
stepCostMap.put("loadStationMapAndNode", elapsedMillis(stepStartNs));
+ log.info("绔欑偣璺緞鎼滅储涓婁笅鏂囧姞杞藉湴鍥惧畬鎴愶紝startStationId={}锛宔ndStationId={}锛宮ode={}锛宮apRows={}锛宻tartNode=({},{})锛宔ndNode=({},{})锛宑ostMs={}",
+ startStationId,
+ endStationId,
+ calcMode,
+ stationMap.size(),
+ startNode.getX(),
+ startNode.getY(),
+ endNode.getX(),
+ endNode.getY(),
+ stepCostMap.get("loadStationMapAndNode"));
stepStartNs = System.nanoTime();
StationPathProfileConfig profileConfig = resolvedPolicy.getProfileConfig() == null
@@ -2717,6 +2761,14 @@
int calcMaxPaths = safeInt(profileConfig.getCalcMaxPaths(), 500);
int calcMaxCost = safeInt(profileConfig.getCalcMaxCost(), 300);
List<Integer> guideStationSequence = buildGuideStationSequence(startStationId, endStationId, resolvedPolicy.getRuleConfig());
+ log.info("绔欑偣璺緞鍊欓�夋灇涓惧紑濮嬶紝startStationId={}锛宔ndStationId={}锛宮ode={}锛宑alcMaxDepth={}锛宑alcMaxPaths={}锛宑alcMaxCost={}锛実uideStationSequence={}",
+ startStationId,
+ endStationId,
+ calcMode,
+ calcMaxDepth,
+ calcMaxPaths,
+ calcMaxCost,
+ JSON.toJSONString(guideStationSequence));
stepStartNs = System.nanoTime();
List<List<NavigateNode>> allList = navigateSolution.allSimplePaths(
stationMap,
@@ -2729,6 +2781,12 @@
);
stepCostMap.put("allSimplePaths", elapsedMillis(stepStartNs));
rawCandidateCount = allList.size();
+ log.info("绔欑偣璺緞鍊欓�夋灇涓惧畬鎴愶紝startStationId={}锛宔ndStationId={}锛宮ode={}锛宺awCandidateCount={}锛宑ostMs={}",
+ startStationId,
+ endStationId,
+ calcMode,
+ rawCandidateCount,
+ stepCostMap.get("allSimplePaths"));
if (allList.isEmpty()) {
logStationPathSearchContextSlow(startStationId, endStationId, calcMode, lev, rawCandidateCount, filteredCandidateCount, stepCostMap, totalStartNs);
return StationPathSearchContext.empty(resolvedPolicy);
@@ -2738,6 +2796,14 @@
allList = filterNonAutoStationPaths(allList, statusMap);
stepCostMap.put("filterNonAutoStation", elapsedMillis(stepStartNs));
filteredCandidateCount = allList.size();
+ log.info("绔欑偣璺緞鍊欓�夎嚜鍔ㄧ姸鎬佽繃婊ゅ畬鎴愶紝startStationId={}锛宔ndStationId={}锛宮ode={}锛宺awCandidateCount={}锛宖ilteredCandidateCount={}锛宻tatusCount={}锛宑ostMs={}",
+ startStationId,
+ endStationId,
+ calcMode,
+ rawCandidateCount,
+ filteredCandidateCount,
+ statusMap.size(),
+ stepCostMap.get("filterNonAutoStation"));
if (allList.isEmpty()) {
News.info("[WCS Debug] 绔欑偣璺緞鍊欓�夊叏閮ㄨ杩囨护锛屽瓨鍦ㄩ潪鑷姩绔欑偣,startStationId={},endStationId={}", startStationId, endStationId);
logStationPathSearchContextSlow(startStationId, endStationId, calcMode, lev, rawCandidateCount, filteredCandidateCount, stepCostMap, totalStartNs);
--
Gitblit v1.9.1