From 23b4e7942a8524ed1e89d93c55a470f0dc263d5a Mon Sep 17 00:00:00 2001
From: lsh <lsh@163.com>
Date: 星期五, 06 六月 2025 13:54:01 +0800
Subject: [PATCH] *

---
 src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java |   24 +++++++++++++++++++-----
 1 files changed, 19 insertions(+), 5 deletions(-)

diff --git a/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java b/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java
index 27e2d7b..9841de2 100644
--- a/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java
+++ b/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java
@@ -234,7 +234,7 @@
                 return;
             }
             long differenceInSeconds = TimeCalculatorUtils.differenceInMilliseconds(wrkMasts.get(0).getModiTime(), new Date());
-            if (differenceInSeconds <= 100) {
+            if (differenceInSeconds <= 1000) {
                 return;
             }
 
@@ -270,6 +270,8 @@
             try {
                 List<WrkMast> wrkMastlistA = new ArrayList<>();
                 List<WrkMast> wrkMastlistB = new ArrayList<>();
+                List<WrkMast> wrkMastlistC = new ArrayList<>();
+                List<WrkMast> wrkMastlistD = new ArrayList<>();
                 for (BasDevpPosition basDevpPosition : basDevpPositionsListUN) {
                     List<WrkMast> wrkMastList = wrkMastService.selectList(new EntityWrapper<WrkMast>().eq("sta_no", basDevpPosition.getDevNo()).eq("wrk_sts", 1L).orderBy("modi_time", true));
                     for (WrkMast wrkMast : wrkMastList) {
@@ -283,12 +285,22 @@
                                 } else {
                                     continue;
                                 }
+                                long differenceInSeconds = TimeCalculatorUtils.differenceInMilliseconds(wrkMast.getModiTime(), new Date());
+
                                 if (SortTheExecutionOfTheCarUtil.devpNoSortbj(basDevpPositionsListUN, wrkMast.getSourceStaNo(), wrkMast.getStaNo())) {
                                     sourceStaNoList.add(wrkMast.getSourceStaNo());
-                                    wrkMastlistA.add(wrkMast);
+                                    if (differenceInSeconds>600000){
+                                        wrkMastlistA.add(wrkMast);
+                                    } else {
+                                        wrkMastlistC.add(wrkMast);
+                                    }
                                 } else {
                                     sourceStaNoList.add(wrkMast.getSourceStaNo());
-                                    wrkMastlistB.add(wrkMast);
+                                    if (differenceInSeconds>600000){
+                                        wrkMastlistB.add(wrkMast);
+                                    } else {
+                                        wrkMastlistD.add(wrkMast);
+                                    }
                                 }
                             }
                         }
@@ -296,6 +308,8 @@
                 }
                 wrkMastLists.add(wrkMastlistA);
                 wrkMastLists.add(wrkMastlistB);
+                wrkMastLists.add(wrkMastlistC);
+                wrkMastLists.add(wrkMastlistD);
 //                return wrkMastLists;
                 wrkMastListAll.add(wrkMastLists);
             } catch (Exception e) {
@@ -602,7 +616,7 @@
                         && rgvProtocol.getStatusType() == RgvStatusType.IDLE
                         && rgvProtocol.getTaskNo1() == 0
                         && rgvProtocol.getAlarm() == 0) {
-                    if (!MessageQueue.offer(SlaveType.Rgv, rgvProtocol.getRgvNo(), new Task(4,devperimeter))) {
+                    if (!MessageQueue.offer(SlaveType.Rgv, rgvProtocol.getRgvNo(), new Task(5,devperimeter))) {
                         log.error("RGV婕父鍚姩鍛戒护涓嬪彂澶辫触锛孯GV鍙�={}锛屼换鍔℃暟鎹�={}", rgvNo, "婕父鎸囦护");
                         break;
                     }
@@ -661,7 +675,7 @@
                                     wrkMastService.updateById(wrkMast);
                                     continue;
                                 }else {
-                                    log.error("宸ヤ綔鍙�"+wrkMast.getWrkNo()+"浠诲姟瀹屾垚淇℃伅涓婁紶澶勭悊澶辫触");
+                                    log.error("宸ヤ綔鍙�"+wrkMast.getWrkNo()+"浠诲姟瀹屾垚淇℃伅涓婁紶澶勭悊澶辫触1");
                                 }
                             } else {
                                 //娴嬭瘯鐢�

--
Gitblit v1.9.1