From 9b8ff50b66361c4b56074b7586b2d5951ecf2091 Mon Sep 17 00:00:00 2001
From: Junjie <fallin.jie@qq.com>
Date: 星期四, 02 四月 2026 15:02:14 +0800
Subject: [PATCH] #优化运行速度

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

diff --git a/src/main/java/com/zy/core/utils/StationOperateProcessUtils.java b/src/main/java/com/zy/core/utils/StationOperateProcessUtils.java
index 138a68a..0a9a7a3 100644
--- a/src/main/java/com/zy/core/utils/StationOperateProcessUtils.java
+++ b/src/main/java/com/zy/core/utils/StationOperateProcessUtils.java
@@ -1,8 +1,10 @@
 package com.zy.core.utils;
 
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.zy.asrs.entity.BasDevp;
 import com.zy.asrs.entity.BasStation;
 import com.zy.asrs.entity.WrkMast;
+import com.zy.asrs.service.BasDevpService;
 import com.zy.asrs.service.BasStationService;
 import com.zy.asrs.service.WrkAnalysisService;
 import com.zy.asrs.service.WrkMastService;
@@ -11,7 +13,10 @@
 import com.zy.core.enums.SlaveType;
 import com.zy.core.enums.WrkIoType;
 import com.zy.core.enums.WrkStsType;
+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.StationDispatchLoadSupport;
 import com.zy.core.utils.station.StationOutboundDispatchProcessor;
@@ -33,6 +38,8 @@
     @Autowired
     private WrkMastService wrkMastService;
     @Autowired
+    private BasDevpService basDevpService;
+    @Autowired
     private BasStationService basStationService;
     @Autowired
     private WrkAnalysisService wrkAnalysisService;
@@ -44,15 +51,27 @@
     private StationOutboundDispatchProcessor stationOutboundDispatchProcessor;
     @Autowired
     private StationRerouteProcessor stationRerouteProcessor;
+    @Autowired
+    private MainProcessTaskSubmitter mainProcessTaskSubmitter;
 
     //鎵ц杈撻�佺珯鐐瑰叆搴撲换鍔�
     public synchronized void stationInExecute() {
         stationRegularDispatchProcessor.stationInExecute();
     }
 
+    // 鎵ц鍗曚釜绔欑偣鐨勫叆搴撲换鍔′笅鍙�
+    public void stationInExecute(BasDevp basDevp, StationObjModel stationObjModel) {
+        stationRegularDispatchProcessor.stationInExecute(basDevp, stationObjModel);
+    }
+
     //鎵ц鍫嗗灈鏈鸿緭閫佺珯鐐瑰嚭搴撲换鍔�
     public synchronized void crnStationOutExecute() {
         stationOutboundDispatchProcessor.crnStationOutExecute();
+    }
+
+    // 鎵ц鍗曚釜鍑哄簱浠诲姟瀵瑰簲鐨勮緭閫佺珯鐐逛笅鍙�
+    public void crnStationOutExecute(WrkMast wrkMast) {
+        stationOutboundDispatchProcessor.crnStationOutExecute(wrkMast);
     }
 
     //鎵ц鍙屽伐浣嶅爢鍨涙満杈撻�佺珯鐐瑰嚭搴撲换鍔�
@@ -63,6 +82,11 @@
     //妫�娴嬭緭閫佺珯鐐瑰嚭搴撲换鍔℃墽琛屽畬鎴�
     public synchronized void stationOutExecuteFinish() {
         stationRegularDispatchProcessor.stationOutExecuteFinish();
+    }
+
+    // 妫�娴嬪崟涓嚭搴撲换鍔℃槸鍚﹀埌杈剧洰鏍囩珯鍙�
+    public void stationOutExecuteFinish(WrkMast wrkMast) {
+        stationRegularDispatchProcessor.stationOutExecuteFinish(wrkMast);
     }
 
     // 妫�娴嬪叆搴撲换鍔℃槸鍚﹀埌杈剧珯鍙板苟杞负绔欏彴杩愯瀹屾垚
@@ -100,9 +124,43 @@
         }
     }
 
+    // 妫�娴嬪崟涓叆搴撲换鍔℃槸鍚﹀埌杈剧洰鏍囩珯鍙�
+    public void scanInboundStationArrival(WrkMast wrkMast) {
+        if (wrkMast == null || wrkMast.getWrkNo() == null || wrkMast.getStaNo() == null) {
+            return;
+        }
+        BasStation basStation = basStationService.getOne(new QueryWrapper<BasStation>()
+                .eq("station_id", wrkMast.getStaNo())
+                .last("limit 1"));
+        if (basStation == null || basStation.getDeviceNo() == null) {
+            return;
+        }
+        StationThread stationThread = (StationThread) SlaveConnection.get(SlaveType.Devp, basStation.getDeviceNo());
+        if (stationThread == null) {
+            return;
+        }
+        Map<Integer, StationProtocol> statusMap = stationThread.getStatusMap();
+        StationProtocol stationProtocol = statusMap == null ? null : statusMap.get(basStation.getStationId());
+        boolean arrived = stationProtocol != null
+                && wrkMast.getWrkNo().equals(stationProtocol.getTaskNo())
+                && stationProtocol.isLoading();
+        if (!arrived && !stationThread.hasRecentArrival(basStation.getStationId(), wrkMast.getWrkNo())) {
+            return;
+        }
+        boolean updated = wrkAnalysisService.completeInboundStationRun(wrkMast, new Date());
+        if (updated) {
+            News.info("鍏ュ簱绔欑偣鍒拌揪鎵弿鍛戒腑锛屽伐浣滃彿={}锛岀洰鏍囩珯={}", wrkMast.getWrkNo(), wrkMast.getStaNo());
+        }
+    }
+
     // 妫�娴嬩换鍔¤浆瀹屾垚
     public synchronized void checkTaskToComplete() {
         stationRegularDispatchProcessor.checkTaskToComplete();
+    }
+
+    // 妫�娴嬪崟涓嚭搴撲换鍔℃槸鍚﹀彲浠ヨ浆瀹屾垚
+    public void checkTaskToComplete(WrkMast wrkMast) {
+        stationRegularDispatchProcessor.checkTaskToComplete(wrkMast);
     }
 
     //妫�娴嬭緭閫佺珯鐐规槸鍚﹁繍琛屽牭濉�
@@ -110,9 +168,19 @@
         stationRerouteProcessor.checkStationRunBlock();
     }
 
+    // 妫�娴嬪崟涓珯鐐规槸鍚﹁繍琛屽牭濉�
+    public void checkStationRunBlock(BasDevp basDevp, Integer stationId) {
+        stationRerouteProcessor.checkStationRunBlock(basDevp, stationId);
+    }
+
     //妫�娴嬭緭閫佺珯鐐逛换鍔″仠鐣欒秴鏃跺悗閲嶆柊璁$畻璺緞
     public synchronized void checkStationIdleRecover() {
         stationRerouteProcessor.checkStationIdleRecover();
+    }
+
+    // 妫�娴嬪崟涓珯鐐逛换鍔″仠鐣欒秴鏃跺悗鐨勬仮澶嶅鐞�
+    public void checkStationIdleRecover(BasDevp basDevp, Integer stationId) {
+        stationRerouteProcessor.checkStationIdleRecover(basDevp, stationId);
     }
 
     //鑾峰彇杈撻�佺嚎浠诲姟鏁伴噺
@@ -138,11 +206,244 @@
         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<WrkMast> wrkMasts = wrkMastService.list(new QueryWrapper<WrkMast>()
+                .eq("wrk_sts", WrkStsType.STATION_RUN.sts)
+                .isNotNull("sta_no"));
+        for (WrkMast wrkMast : wrkMasts) {
+            mainProcessTaskSubmitter.submitKeyedSerialTask(
+                    lane,
+                    wrkMast.getStaNo(),
+                    "stationOutExecuteFinish",
+                    minIntervalMs,
+                    () -> stationOutExecuteFinish(wrkMast)
+            );
+        }
+    }
+
+    public void submitInboundStationArrivalTasks(long minIntervalMs) {
+        submitInboundStationArrivalTasks(MainProcessLane.STATION_IN_ARRIVAL, minIntervalMs);
+    }
+
+    public void submitInboundStationArrivalTasks(MainProcessLane lane, long minIntervalMs) {
+        List<WrkMast> wrkMasts = wrkMastService.list(new QueryWrapper<WrkMast>()
+                .eq("io_type", 1)
+                .eq("wrk_sts", WrkStsType.INBOUND_STATION_RUN.sts)
+                .isNotNull("sta_no"));
+        for (WrkMast wrkMast : wrkMasts) {
+            mainProcessTaskSubmitter.submitKeyedSerialTask(
+                    lane,
+                    wrkMast.getStaNo(),
+                    "scanInboundStationArrival",
+                    minIntervalMs,
+                    () -> scanInboundStationArrival(wrkMast)
+            );
+        }
+    }
+
+    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) {
+            for (StationObjModel stationObjModel : basDevp.getOutOrderList$()) {
+                Integer stationId = stationObjModel == null ? null : stationObjModel.getStationId();
+                if (stationId == null) {
+                    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;
+                }
+                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;
+                }
+                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;
+                }
+                mainProcessTaskSubmitter.submitKeyedSerialTask(
+                        lane,
+                        stationId,
+                        "checkStationIdleRecover",
+                        minIntervalMs,
+                        () -> checkStationIdleRecover(basDevp, stationId)
+                );
+            }
+        }
+    }
+
     RerouteCommandPlan buildRerouteCommandPlan(RerouteContext context,
                                                RerouteDecision decision) {
         return stationRerouteProcessor.buildRerouteCommandPlan(context, decision);

--
Gitblit v1.9.1