From cbb00d4729243e4949b3c921fc2f94cb03ca8aaa Mon Sep 17 00:00:00 2001
From: Junjie <fallin.jie@qq.com>
Date: 星期五, 27 三月 2026 18:47:43 +0800
Subject: [PATCH] #

---
 src/main/java/com/zy/asrs/task/WrkAnalysisStationArrivalScanner.java |    8 ++++----
 1 files changed, 4 insertions(+), 4 deletions(-)

diff --git a/src/main/java/com/zy/asrs/task/WrkAnalysisStationArrivalScanner.java b/src/main/java/com/zy/asrs/task/WrkAnalysisStationArrivalScanner.java
index 9740c55..cf33ff0 100644
--- a/src/main/java/com/zy/asrs/task/WrkAnalysisStationArrivalScanner.java
+++ b/src/main/java/com/zy/asrs/task/WrkAnalysisStationArrivalScanner.java
@@ -66,10 +66,10 @@
             }
             Map<Integer, StationProtocol> statusMap = stationThread.getStatusMap();
             StationProtocol stationProtocol = statusMap == null ? null : statusMap.get(basStation.getStationId());
-            if (stationProtocol == null) {
-                continue;
-            }
-            if (!wrkMast.getWrkNo().equals(stationProtocol.getTaskNo()) || !stationProtocol.isLoading()) {
+            boolean arrived = stationProtocol != null
+                    && wrkMast.getWrkNo().equals(stationProtocol.getTaskNo())
+                    && stationProtocol.isLoading();
+            if (!arrived && !stationThread.hasRecentArrival(basStation.getStationId(), wrkMast.getWrkNo())) {
                 continue;
             }
             boolean updated = wrkAnalysisService.completeInboundStationRun(wrkMast, new Date());

--
Gitblit v1.9.1