From 41aeff86351d1dd94fe2408175f96475f227c1b9 Mon Sep 17 00:00:00 2001
From: Junjie <fallin.jie@qq.com>
Date: 星期四, 02 四月 2026 17:15:27 +0800
Subject: [PATCH] #执行优化

---
 src/main/java/com/zy/core/utils/StationOperateProcessUtils.java |  370 +++++++++++++++++++++++++++++++++++++++++++++++++++-
 1 files changed, 357 insertions(+), 13 deletions(-)

diff --git a/src/main/java/com/zy/core/utils/StationOperateProcessUtils.java b/src/main/java/com/zy/core/utils/StationOperateProcessUtils.java
index 85dc30d..247d6ee 100644
--- a/src/main/java/com/zy/core/utils/StationOperateProcessUtils.java
+++ b/src/main/java/com/zy/core/utils/StationOperateProcessUtils.java
@@ -1,14 +1,21 @@
 package com.zy.core.utils;
 
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.zy.asrs.entity.BasCrnp;
+import com.zy.asrs.entity.BasDevp;
 import com.zy.asrs.entity.WrkMast;
-import com.zy.asrs.service.WrkMastService;
+import com.zy.asrs.service.*;
+import com.zy.core.News;
+import com.zy.core.cache.SlaveConnection;
+import com.zy.core.enums.SlaveType;
 import com.zy.core.enums.WrkIoType;
 import com.zy.core.enums.WrkStsType;
-import com.zy.core.utils.station.StationDispatchLoadSupport;
-import com.zy.core.utils.station.StationOutboundDispatchProcessor;
-import com.zy.core.utils.station.StationRegularDispatchProcessor;
-import com.zy.core.utils.station.StationRerouteProcessor;
+import com.zy.core.model.StationObjModel;
+import com.zy.core.model.protocol.StationProtocol;
+import com.zy.core.task.MainProcessLane;
+import com.zy.core.task.MainProcessTaskSubmitter;
+import com.zy.core.thread.StationThread;
+import com.zy.core.utils.station.*;
 import com.zy.core.utils.station.model.RerouteCommandPlan;
 import com.zy.core.utils.station.model.RerouteContext;
 import com.zy.core.utils.station.model.RerouteDecision;
@@ -16,12 +23,20 @@
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
 
+import java.util.Date;
 import java.util.List;
+import java.util.Map;
 
 @Component
 public class StationOperateProcessUtils {
     @Autowired
     private WrkMastService wrkMastService;
+    @Autowired
+    private BasDevpService basDevpService;
+    @Autowired
+    private BasStationService basStationService;
+    @Autowired
+    private WrkAnalysisService wrkAnalysisService;
     @Autowired
     private StationRegularDispatchProcessor stationRegularDispatchProcessor;
     @Autowired
@@ -30,10 +45,21 @@
     private StationOutboundDispatchProcessor stationOutboundDispatchProcessor;
     @Autowired
     private StationRerouteProcessor stationRerouteProcessor;
+    @Autowired
+    private MainProcessTaskSubmitter mainProcessTaskSubmitter;
+    @Autowired
+    private StationOutboundDecisionSupport stationOutboundDecisionSupport;
+    @Autowired
+    private BasCrnpService basCrnpService;
 
     //鎵ц杈撻�佺珯鐐瑰叆搴撲换鍔�
     public synchronized void stationInExecute() {
         stationRegularDispatchProcessor.stationInExecute();
+    }
+
+    // 鎵ц鍗曚釜绔欑偣鐨勫叆搴撲换鍔′笅鍙�
+    public void stationInExecute(BasDevp basDevp, StationObjModel stationObjModel) {
+        stationRegularDispatchProcessor.stationInExecute(basDevp, stationObjModel);
     }
 
     //鎵ц鍫嗗灈鏈鸿緭閫佺珯鐐瑰嚭搴撲换鍔�
@@ -41,37 +67,84 @@
         stationOutboundDispatchProcessor.crnStationOutExecute();
     }
 
+    // 鎵ц鍗曚釜鍑哄簱浠诲姟瀵瑰簲鐨勮緭閫佺珯鐐逛笅鍙�
+    public void crnStationOutExecute(WrkMast wrkMast) {
+        stationOutboundDispatchProcessor.crnStationOutExecute(wrkMast);
+    }
+
     //鎵ц鍙屽伐浣嶅爢鍨涙満杈撻�佺珯鐐瑰嚭搴撲换鍔�
     public synchronized void dualCrnStationOutExecute() {
         stationOutboundDispatchProcessor.dualCrnStationOutExecute();
     }
 
-    //妫�娴嬭緭閫佺珯鐐瑰嚭搴撲换鍔℃墽琛屽畬鎴�
-    public synchronized void stationOutExecuteFinish() {
-        stationRegularDispatchProcessor.stationOutExecuteFinish();
+    // 妫�娴嬪崟涓嚭搴撲换鍔℃槸鍚﹀埌杈剧洰鏍囩珯鍙�
+    public void stationOutExecuteFinish(StationObjModel stationObjModel) {
+        stationRegularDispatchProcessor.stationOutExecuteFinish(stationObjModel);
+    }
+
+    // 妫�娴嬪崟涓叆搴撲换鍔℃槸鍚﹀埌杈剧洰鏍囩珯鍙�
+    public void scanInboundStationArrival(StationObjModel stationObjModel) {
+        if (stationObjModel == null) {
+            return;
+        }
+        StationThread stationThread = (StationThread) SlaveConnection.get(SlaveType.Devp, stationObjModel.getDeviceNo());
+        if (stationThread == null) {
+            return;
+        }
+        Map<Integer, StationProtocol> statusMap = stationThread.getStatusMap();
+        StationProtocol stationProtocol = statusMap == null ? null : statusMap.get(stationObjModel.getStationId());
+        if (stationProtocol == null) {
+            return;
+        }
+        if (stationProtocol.getTaskNo() <= 0) {
+            return;
+        }
+        WrkMast wrkMast = wrkMastService.selectByWorkNo(stationProtocol.getTaskNo());
+        if (wrkMast == null) {
+            return;
+        }
+        boolean updated = wrkAnalysisService.completeInboundStationRun(wrkMast, new Date());
+        if (updated) {
+            News.info("鍏ュ簱绔欑偣鍒拌揪鎵弿鍛戒腑锛屽伐浣滃彿={}锛岀洰鏍囩珯={}", wrkMast.getWrkNo(), wrkMast.getStaNo());
+        }
     }
 
     // 妫�娴嬩换鍔¤浆瀹屾垚
-    public synchronized void checkTaskToComplete() {
+    public void checkTaskToComplete() {
         stationRegularDispatchProcessor.checkTaskToComplete();
     }
 
+    // 妫�娴嬪崟涓嚭搴撲换鍔℃槸鍚﹀彲浠ヨ浆瀹屾垚
+    public void checkTaskToComplete(WrkMast wrkMast) {
+        stationRegularDispatchProcessor.checkTaskToComplete(wrkMast);
+    }
+
     //妫�娴嬭緭閫佺珯鐐规槸鍚﹁繍琛屽牭濉�
-    public synchronized void checkStationRunBlock() {
+    public void checkStationRunBlock() {
         stationRerouteProcessor.checkStationRunBlock();
     }
 
+    // 妫�娴嬪崟涓珯鐐规槸鍚﹁繍琛屽牭濉�
+    public void checkStationRunBlock(BasDevp basDevp, Integer stationId) {
+        stationRerouteProcessor.checkStationRunBlock(basDevp, stationId);
+    }
+
     //妫�娴嬭緭閫佺珯鐐逛换鍔″仠鐣欒秴鏃跺悗閲嶆柊璁$畻璺緞
-    public synchronized void checkStationIdleRecover() {
+    public void checkStationIdleRecover() {
         stationRerouteProcessor.checkStationIdleRecover();
     }
 
+    // 妫�娴嬪崟涓珯鐐逛换鍔″仠鐣欒秴鏃跺悗鐨勬仮澶嶅鐞�
+    public void checkStationIdleRecover(BasDevp basDevp, Integer stationId) {
+        stationRerouteProcessor.checkStationIdleRecover(basDevp, stationId);
+    }
+
     //鑾峰彇杈撻�佺嚎浠诲姟鏁伴噺
-    public synchronized int getCurrentStationTaskCount() {
+    public int getCurrentStationTaskCount() {
         return stationDispatchLoadSupport.countCurrentStationTask();
     }
 
-    public synchronized int getCurrentOutboundTaskCountByTargetStation(Integer stationId) {
+    public int getCurrentOutboundTaskCountByTargetStation(Integer stationId) {
         if (stationId == null) {
             return 0;
         }
@@ -89,11 +162,282 @@
         stationRerouteProcessor.checkStationOutOrder();
     }
 
+    // 妫�娴嬪崟涓珯鐐圭殑鍑哄簱鎺掑簭
+    public void checkStationOutOrder(BasDevp basDevp, StationObjModel stationObjModel) {
+        stationRerouteProcessor.checkStationOutOrder(basDevp, stationObjModel);
+    }
+
     // 鐩戞帶缁曞湀绔欑偣
     public synchronized void watchCircleStation() {
         stationRerouteProcessor.watchCircleStation();
     }
 
+    // 鐩戞帶鍗曚釜缁曞湀绔欑偣
+    public void watchCircleStation(BasDevp basDevp, Integer stationId) {
+        stationRerouteProcessor.watchCircleStation(basDevp, stationId);
+    }
+
+    public void submitStationInTasks(long minIntervalMs) {
+        submitStationInTasks(MainProcessLane.STATION_IN, minIntervalMs);
+    }
+
+    public void submitStationInTasks(MainProcessLane lane, long minIntervalMs) {
+        List<BasDevp> basDevps = basDevpService.list(new QueryWrapper<>());
+        for (BasDevp basDevp : basDevps) {
+            StationThread stationThread = (StationThread) SlaveConnection.get(SlaveType.Devp, basDevp.getDevpNo());
+            if (stationThread == null) {
+                continue;
+            }
+            Map<Integer, StationProtocol> stationMap = stationThread.getStatusMap();
+            if (stationMap == null || stationMap.isEmpty()) {
+                continue;
+            }
+            for (StationObjModel stationObjModel : basDevp.getBarcodeStationList$()) {
+                Integer stationId = stationObjModel == null ? null : stationObjModel.getStationId();
+                if (stationId == null || !stationMap.containsKey(stationId)) {
+                    continue;
+                }
+                StationProtocol stationProtocol = stationMap.get(stationId);
+                if (stationProtocol == null
+                        || !stationProtocol.isAutoing()
+                        || !stationProtocol.isLoading()
+                        || stationProtocol.getTaskNo() <= 0) {
+                    continue;
+                }
+                mainProcessTaskSubmitter.submitKeyedSerialTask(
+                        lane,
+                        stationId,
+                        "stationInExecute",
+                        minIntervalMs,
+                        () -> stationInExecute(basDevp, stationObjModel)
+                );
+            }
+        }
+    }
+
+    public void submitCrnStationOutTasks(long minIntervalMs) {
+        submitCrnStationOutTasks(MainProcessLane.STATION_OUT, minIntervalMs);
+    }
+
+    public void submitCrnStationOutTasks(MainProcessLane lane, long minIntervalMs) {
+        List<WrkMast> wrkMasts = wrkMastService.list(new QueryWrapper<WrkMast>()
+                .eq("wrk_sts", WrkStsType.OUTBOUND_RUN_COMPLETE.sts)
+                .isNotNull("crn_no"));
+        for (WrkMast wrkMast : wrkMasts) {
+            Integer laneKey = wrkMast == null ? null : wrkMast.getSourceStaNo();
+            if (laneKey == null) {
+                laneKey = wrkMast == null ? null : wrkMast.getWrkNo();
+            }
+            mainProcessTaskSubmitter.submitKeyedSerialTask(
+                    lane,
+                    laneKey,
+                    "crnStationOutExecute",
+                    minIntervalMs,
+                    () -> crnStationOutExecute(wrkMast)
+            );
+        }
+    }
+
+    public void submitStationOutExecuteFinishTasks(long minIntervalMs) {
+        submitStationOutExecuteFinishTasks(MainProcessLane.STATION_OUT_FINISH, minIntervalMs);
+    }
+
+    public void submitStationOutExecuteFinishTasks(MainProcessLane lane, long minIntervalMs) {
+        List<BasDevp> basDevps = basDevpService.list(new QueryWrapper<>());
+        for (BasDevp basDevp : basDevps) {
+            for (StationObjModel stationObjModel : basDevp.getOutStationList$()) {
+                mainProcessTaskSubmitter.submitKeyedSerialTask(
+                        lane,
+                        stationObjModel.getStationId(),
+                        "stationOutExecuteFinish",
+                        minIntervalMs,
+                        () -> stationOutExecuteFinish(stationObjModel)
+                );
+            }
+        }
+    }
+
+    public void submitInboundStationArrivalTasks(long minIntervalMs) {
+        submitInboundStationArrivalTasks(MainProcessLane.STATION_IN_ARRIVAL, minIntervalMs);
+    }
+
+    public void submitInboundStationArrivalTasks(MainProcessLane lane, long minIntervalMs) {
+        List<BasCrnp> basCrnps = basCrnpService.list(new QueryWrapper<>());
+        for (BasCrnp basCrnp : basCrnps) {
+            Integer crnNo = basCrnp == null ? null : basCrnp.getCrnNo();
+            if (crnNo == null) {
+                continue;
+            }
+
+            for (StationObjModel stationObjModel : basCrnp.getInStationList$()) {
+                mainProcessTaskSubmitter.submitKeyedSerialTask(
+                        lane,
+                        stationObjModel.getStationId(),
+                        "scanInboundStationArrival",
+                        minIntervalMs,
+                        () -> scanInboundStationArrival(stationObjModel)
+                );
+            }
+        }
+    }
+
+    public void submitCheckTaskToCompleteTasks(long minIntervalMs) {
+        submitCheckTaskToCompleteTasks(MainProcessLane.STATION_COMPLETE, minIntervalMs);
+    }
+
+    public void submitCheckTaskToCompleteTasks(MainProcessLane lane, long minIntervalMs) {
+        List<WrkMast> wrkMasts = wrkMastService.list(new QueryWrapper<WrkMast>()
+                .eq("wrk_sts", WrkStsType.STATION_RUN_COMPLETE.sts)
+                .isNotNull("sta_no"));
+        for (WrkMast wrkMast : wrkMasts) {
+            mainProcessTaskSubmitter.submitKeyedSerialTask(
+                    lane,
+                    wrkMast.getStaNo(),
+                    "checkTaskToComplete",
+                    minIntervalMs,
+                    () -> checkTaskToComplete(wrkMast)
+            );
+        }
+    }
+
+    public void submitCheckStationOutOrderTasks(long minIntervalMs) {
+        submitCheckStationOutOrderTasks(MainProcessLane.STATION_OUT_ORDER, minIntervalMs);
+    }
+
+    public void submitCheckStationOutOrderTasks(MainProcessLane lane, long minIntervalMs) {
+        List<BasDevp> basDevps = basDevpService.list(new QueryWrapper<>());
+        for (BasDevp basDevp : basDevps) {
+            StationThread stationThread = (StationThread) SlaveConnection.get(SlaveType.Devp, basDevp.getDevpNo());
+            if (stationThread == null) {
+                continue;
+            }
+
+            for (StationObjModel stationObjModel : basDevp.getOutOrderList$()) {
+                Integer stationId = stationObjModel == null ? null : stationObjModel.getStationId();
+                if (stationId == null) {
+                    continue;
+                }
+                Map<Integer, StationProtocol> statusMap = stationThread.getStatusMap();
+                StationProtocol stationProtocol = statusMap.get(stationId);
+                if (stationProtocol == null
+                        || !stationProtocol.isAutoing()
+                        || !stationProtocol.isLoading()
+                        || stationProtocol.getTaskNo() <= 0
+                        || stationProtocol.isRunBlock()
+                        || !stationProtocol.getStationId().equals(stationProtocol.getTargetStaNo())) {
+                    continue;
+                }
+                mainProcessTaskSubmitter.submitKeyedSerialTask(
+                        lane,
+                        stationId,
+                        "checkStationOutOrder",
+                        minIntervalMs,
+                        () -> checkStationOutOrder(basDevp, stationObjModel)
+                );
+            }
+        }
+    }
+
+    public void submitWatchCircleStationTasks(long minIntervalMs) {
+        submitWatchCircleStationTasks(MainProcessLane.STATION_WATCH_CIRCLE, minIntervalMs);
+    }
+
+    public void submitWatchCircleStationTasks(MainProcessLane lane, long minIntervalMs) {
+        List<BasDevp> basDevps = basDevpService.list(new QueryWrapper<>());
+        for (BasDevp basDevp : basDevps) {
+            StationThread stationThread = (StationThread) SlaveConnection.get(SlaveType.Devp, basDevp.getDevpNo());
+            if (stationThread == null) {
+                continue;
+            }
+            for (StationProtocol stationProtocol : stationThread.getStatus()) {
+                Integer stationId = stationProtocol == null ? null : stationProtocol.getStationId();
+                if (stationId == null) {
+                    continue;
+                }
+                if (!stationProtocol.isAutoing()
+                        || !stationProtocol.isLoading()
+                        || stationProtocol.getTaskNo() <= 0
+                        || !stationOutboundDecisionSupport.isWatchingCircleArrival(stationProtocol.getTaskNo(), stationProtocol.getStationId())) {
+                    continue;
+                }
+
+                mainProcessTaskSubmitter.submitKeyedSerialTask(
+                        lane,
+                        stationId,
+                        "watchCircleStation",
+                        minIntervalMs,
+                        () -> watchCircleStation(basDevp, stationId)
+                );
+            }
+        }
+    }
+
+    public void submitCheckStationRunBlockTasks(long minIntervalMs) {
+        submitCheckStationRunBlockTasks(MainProcessLane.STATION_RUN_BLOCK, minIntervalMs);
+    }
+
+    public void submitCheckStationRunBlockTasks(MainProcessLane lane, long minIntervalMs) {
+        List<BasDevp> basDevps = basDevpService.list(new QueryWrapper<>());
+        for (BasDevp basDevp : basDevps) {
+            StationThread stationThread = (StationThread) SlaveConnection.get(SlaveType.Devp, basDevp.getDevpNo());
+            if (stationThread == null) {
+                continue;
+            }
+            for (StationProtocol stationProtocol : stationThread.getStatus()) {
+                Integer stationId = stationProtocol == null ? null : stationProtocol.getStationId();
+                if (stationId == null) {
+                    continue;
+                }
+                if (!stationProtocol.isAutoing()
+                        || !stationProtocol.isLoading()
+                        || stationProtocol.getTaskNo() <= 0
+                        || !stationProtocol.isRunBlock()) {
+                    continue;
+                }
+                mainProcessTaskSubmitter.submitKeyedSerialTask(
+                        lane,
+                        stationId,
+                        "checkStationRunBlock",
+                        minIntervalMs,
+                        () -> checkStationRunBlock(basDevp, stationId)
+                );
+            }
+        }
+    }
+
+    public void submitCheckStationIdleRecoverTasks(long minIntervalMs) {
+        submitCheckStationIdleRecoverTasks(MainProcessLane.STATION_IDLE_RECOVER, minIntervalMs);
+    }
+
+    public void submitCheckStationIdleRecoverTasks(MainProcessLane lane, long minIntervalMs) {
+        List<BasDevp> basDevps = basDevpService.list(new QueryWrapper<>());
+        for (BasDevp basDevp : basDevps) {
+            StationThread stationThread = (StationThread) SlaveConnection.get(SlaveType.Devp, basDevp.getDevpNo());
+            if (stationThread == null) {
+                continue;
+            }
+            for (StationProtocol stationProtocol : stationThread.getStatus()) {
+                Integer stationId = stationProtocol == null ? null : stationProtocol.getStationId();
+                if (stationId == null) {
+                    continue;
+                }
+                if (!stationProtocol.isAutoing()
+                        || !stationProtocol.isLoading()
+                        || stationProtocol.getTaskNo() <= 0
+                        || stationProtocol.isRunBlock()) {
+                    continue;
+                }
+                mainProcessTaskSubmitter.submitKeyedSerialTask(
+                        lane,
+                        stationId,
+                        "checkStationIdleRecover",
+                        minIntervalMs,
+                        () -> checkStationIdleRecover(basDevp, stationId)
+                );
+            }
+        }
+    }
+
     RerouteCommandPlan buildRerouteCommandPlan(RerouteContext context,
                                                RerouteDecision decision) {
         return stationRerouteProcessor.buildRerouteCommandPlan(context, decision);

--
Gitblit v1.9.1