From c828579bf44bf5b2ded4c04b16670be71cc76514 Mon Sep 17 00:00:00 2001
From: skyouc <958836976@qq.com>
Date: 星期六, 18 四月 2026 10:56:31 +0800
Subject: [PATCH] no message
---
src/main/java/com/zy/core/utils/CrnOperateProcessUtils.java | 26 +++++++++++++++++---------
1 files changed, 17 insertions(+), 9 deletions(-)
diff --git a/src/main/java/com/zy/core/utils/CrnOperateProcessUtils.java b/src/main/java/com/zy/core/utils/CrnOperateProcessUtils.java
index 5c813e1..d58d707 100644
--- a/src/main/java/com/zy/core/utils/CrnOperateProcessUtils.java
+++ b/src/main/java/com/zy/core/utils/CrnOperateProcessUtils.java
@@ -134,11 +134,11 @@
return;
}
- //鎵ц绉诲姩浠诲姟
- boolean executed = executeCrnMoveTask(crnThread, crnProtocol);
- if (executed) {
- return;
- }
+// //鎵ц绉诲姩浠诲姟
+// boolean executed = executeCrnMoveTask(crnThread, crnProtocol);
+// if (executed) {
+// return;
+// }
String lastIo = resolveCrnLastIo(crnProtocol);
@@ -387,9 +387,9 @@
return false;
}
- if (!allowBatchOutboundExecute(wrkMast, true)) {
- return false;
- }
+// if (!allowBatchOutboundExecute(wrkMast, true)) {
+// return false;
+// }
for (StationObjModel stationObjModel : outStationList) {
StationThread stationThread = (StationThread) SlaveConnection.get(SlaveType.Devp, stationObjModel.getDeviceNo());
@@ -398,7 +398,15 @@
}
Map<Integer, StationProtocol> stationProtocolMap = stationThread.getStatusMap();
- StationProtocol stationProtocol = stationProtocolMap.get(stationObjModel.getStationId());
+
+ //鑾峰彇褰撳墠浠诲姟鍫嗗灈鏈轰换鍔＄珯鍙�
+ Integer staNo = wrkMast.getSourceStaNo();
+ Integer stationId = stationObjModel.getStationId();
+ StationProtocol stationProtocol = stationProtocolMap.get(staNo);
+
+ if (!staNo.equals(stationId)) {
+ continue;
+ }
if (stationProtocol == null) {
continue;
}
--
Gitblit v1.9.1