From 794ed17c6f37a6deacb6ef37349dceb03eae3395 Mon Sep 17 00:00:00 2001
From: lsh <lsh@163.com>
Date: 星期五, 06 六月 2025 08:40:35 +0800
Subject: [PATCH] *

---
 src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java |   18 ++++++++++++++++++
 1 files changed, 18 insertions(+), 0 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 b4256dd..c41153e 100644
--- a/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java
+++ b/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java
@@ -263,6 +263,8 @@
     //鑾峰彇灏忚溅鍙栨斁浠诲姟鍒楄〃澶辫触
     public synchronized List<List<List<WrkMast>>> getWrkMastListAll(List<List<Integer>> siteListAll ,BasDevpPosition[] basDevpPositionsListUN) {
         List<List<List<WrkMast>>> wrkMastListAll = new ArrayList<>();
+        List<Integer> sourceStaNoList = new ArrayList<>();
+
         for (List<Integer> siteList : siteListAll){
             List<List<WrkMast>> wrkMastLists = new ArrayList<>();
             try {
@@ -273,9 +275,19 @@
                     for (WrkMast wrkMast : wrkMastList) {
                         if (!Cools.isEmpty(wrkMast)) {
                             if (siteList.contains(wrkMast.getSourceStaNo())){
+                                if (!sourceStaNoList.contains(wrkMast.getSourceStaNo())){
+                                    List<WrkMast> wrkMastListS = wrkMastService.selectList(new EntityWrapper<WrkMast>().eq("source_sta_no", wrkMast.getSourceStaNo()).eq("wrk_sts", 1L).orderBy("modi_time", true));
+                                    if (wrkMastListS.isEmpty()){
+                                        continue;
+                                    }
+                                } else {
+                                    continue;
+                                }
                                 if (SortTheExecutionOfTheCarUtil.devpNoSortbj(basDevpPositionsListUN, wrkMast.getSourceStaNo(), wrkMast.getStaNo())) {
+                                    sourceStaNoList.add(wrkMast.getSourceStaNo());
                                     wrkMastlistA.add(wrkMast);
                                 } else {
+                                    sourceStaNoList.add(wrkMast.getSourceStaNo());
                                     wrkMastlistB.add(wrkMast);
                                 }
                             }
@@ -493,6 +505,9 @@
                                 if (basDevpPosition.getPlcPosition()-rgvProtocol.getRgvPos()>taskRunPerimeter){
                                     if (!rgvNoM.contains(rgvProtocol.getRgvNo())){
                                         rgvNoM.add(rgvProtocol.getRgvNo());
+                                        if (wrkMastRunCount == 0){
+                                            devperimeter = basDevpPosition.getPlcPosition()-taskRunPerimeter+1000;
+                                        }
                                         wrkMastRunCount++;
                                         break;
                                     }
@@ -502,6 +517,9 @@
                                 if (rgvProtocol.getRgvPos()+ perimeter -basDevpPosition.getPlcPosition()>taskRunPerimeter){
                                     if (!rgvNoM.contains(rgvProtocol.getRgvNo())){
                                         rgvNoM.add(rgvProtocol.getRgvNo());
+                                        if (wrkMastRunCount == 0){
+                                            devperimeter = basDevpPosition.getPlcPosition()-taskRunPerimeter+1000;
+                                        }
                                         wrkMastRunCount++;
                                         break;
                                     }

--
Gitblit v1.9.1