From 522aaae547187ed4abc737ead587f646ed0147e2 Mon Sep 17 00:00:00 2001
From: Junjie <fallin.jie@qq.com>
Date: 星期四, 26 三月 2026 09:52:29 +0800
Subject: [PATCH] #
---
src/main/java/com/zy/core/move/StationMoveCoordinator.java | 4 ++++
1 files changed, 4 insertions(+), 0 deletions(-)
diff --git a/src/main/java/com/zy/core/move/StationMoveCoordinator.java b/src/main/java/com/zy/core/move/StationMoveCoordinator.java
index 1adc417..84eb0c6 100644
--- a/src/main/java/com/zy/core/move/StationMoveCoordinator.java
+++ b/src/main/java/com/zy/core/move/StationMoveCoordinator.java
@@ -87,14 +87,17 @@
}
String candidateSignature = buildPathSignature(candidateCommand);
+ // 鍚� task銆佸悓褰撳墠浣嶇疆銆佸悓璺緞绛惧悕鐨勫懡浠よ涓洪噸澶嶆淳鍙戯紝鐩存帴鍘嬪埗銆�
if (!isBlank(candidateSignature) && Objects.equals(candidateSignature, session.getPathSignature())) {
return true;
}
+ // 鍒拌揪涓嬩竴鍐崇瓥绔欏悗鍏佽閲嶆柊鍐崇瓥锛屼笉缁х画鍙楁棫 session 鐨勪腑闂磋矾寰勪繚鎶ゃ��
if (Objects.equals(currentStationId, session.getNextDecisionStationId())) {
return false;
}
+ // 杩樺鍦ㄦ棫璺嚎瑕嗙洊鑼冨洿鍐呮椂锛屽叾浠栬Е鍙戞簮涓嶅簲鍐嶆彃鍏ヤ竴鏉℃柊鍛戒护銆�
return session.containsStation(currentStationId);
}
@@ -117,6 +120,7 @@
&& Objects.equals(current.getNextDecisionStationId(), command.getTargetStaNo())
&& Objects.equals(current.getPathSignature(), pathSignature);
+ // 鍚屼竴瑙﹀彂绔欍�佸悓涓�鐩爣銆佸悓涓�璺緞绛惧悕鏃跺鐢ㄥ綋鍓� session锛屽彧鍒锋柊涓嬪彂鏃堕棿锛屼笉鏂板紑 routeVersion銆�
StationMoveSession session = reuseCurrent ? current : new StationMoveSession();
if (!reuseCurrent) {
session.setRouteVersion(current == null || current.getRouteVersion() == null
--
Gitblit v1.9.1