From f78f7a18a7fc91bea907c5238b788deb1e082364 Mon Sep 17 00:00:00 2001
From: LSH
Date: 星期三, 03 四月 2024 09:19:53 +0800
Subject: [PATCH] #

---
 src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java |   72 +++++++++++++++++++++++++++++++-----
 1 files changed, 62 insertions(+), 10 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 184421c..1c2fce9 100644
--- a/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java
+++ b/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java
@@ -2318,6 +2318,7 @@
                         param.setIoType(10);
                         param.setSourceStaNo(122);
                         param.setLocType1((short)1);
+                        param.setRgvNo(rgvProtocol.getRgvNo());
                         String response = new HttpHandler.Builder()
                                 .setUri(wmsUrl)
                                 .setPath("/rpc/pakin/empty/loc/v1")
@@ -3696,6 +3697,18 @@
                         if (!basDevp.getAutoing().equals("Y") || basDevp.getLoading().equals("Y") || basDevp.getWrkNo()!=0){
                             continue;
                         }
+                        List<Integer> STA_WORK_CU1 = new ArrayList<Integer>() {{
+                            add(101);add(102);add(104);add(105);add(107);add(108);add(118);add(119);add(122);
+                        }};
+                        List<Integer> STA_WORK_CU2 = new ArrayList<Integer>() {{
+                            add(110);add(111);add(113);add(114);add(116);add(117);add(120);add(121);add(122);add(123);
+                        }};
+                        if (basRgv.getRgvNo()==1 && !STA_WORK_CU1.contains(wrkMastSta.getStaStart())){
+                            continue;
+                        }else if (basRgv.getRgvNo()==2 && !STA_WORK_CU2.contains(wrkMastSta.getStaStart())){
+                            continue;
+                        }
+
                         if (basDevp.getDevNo()>=118 && basDevp.getDevNo()<=123){
                             if (!basDevp.getEmptyMk().equals("Y")){
                                 continue;
@@ -3935,8 +3948,19 @@
                             if (!basDevp.getAutoing().equals("Y") || !basDevp.getLoading().equals("Y")){
                                 continue;
                             }
+                            List<Integer> STA_WORK_CU1 = new ArrayList<Integer>() {{
+                                add(101);add(102);add(104);add(105);add(107);add(108);add(118);add(119);add(122);
+                            }};
+                            List<Integer> STA_WORK_CU2 = new ArrayList<Integer>() {{
+                                add(110);add(111);add(113);add(114);add(116);add(117);add(120);add(121);add(122);add(123);
+                            }};
+                            if (basRgv.getRgvNo()==1 && !STA_WORK_CU1.contains(wrkMastSta.getStaStart())){
+                                continue;
+                            }else if (basRgv.getRgvNo()==2 && !STA_WORK_CU2.contains(wrkMastSta.getStaStart())){
+                                continue;
+                            }
                             if (basDevp.getDevNo()>=118 && basDevp.getDevNo()<=123){
-                                if (basDevp.getEmptyMk().equals("Y")){
+                                if (!basDevp.getEmptyMk().equals("Y")){
                                     continue;
                                 }
                             }
@@ -4064,6 +4088,7 @@
             if (integer==0){
                 return;
             }
+            boolean signRgv = true;
             for (RgvSlave rgvSlave:slaveProperties.getRgv()) {
                 RgvThread rgvThread = (RgvThread) SlaveConnection.get(SlaveType.Rgv, rgvSlave.getId());
                 RgvProtocol rgvProtocol = rgvThread.getRgvProtocol();
@@ -4077,25 +4102,52 @@
                 }
 
                 // 鍙湁褰揜GV绌洪棽銆佽嚜鍔�,宸ヤ綅涓�鏃犵墿//rgv鍙敤
-                if (rgvProtocol.getStatusType() == RgvStatusType.IDLE
+                if (!(rgvProtocol.getStatusType() == RgvStatusType.IDLE
                         && rgvProtocol.getModeType() == RgvModeType.AUTO
                         && rgvProtocol.getLoaded1()==0  //鐜板満淇敼锛氬彔鐩樻満锛屼笉婊¢兘绠楁棤鐗╋紝鎬庝箞鍒ゆ柇闇�瑕佽窡鐢垫帶瀵规帴
                         && rgvProtocol.getTaskNo1()==0
                         && rgvProtocol.getTaskNo2()==0
                         && rgvProtocol.getStatusType1() == RgvStatusType.IDLE
                         && rgvProtocol.getStatusType2() == RgvStatusType.IDLE
-                ) {
-                    BasRgvMap basRgvMap = basRgvMapMapper.selectById(rgvProtocol.getRgvNo());
-                    if (rgvProtocol.getRgvPosI().equals(basRgvMap.getStartRoute())){
+                )) {
+                    signRgv = false;
+                    break;
+                }
+            }
+            if (signRgv){
+                for (RgvSlave rgvSlave:slaveProperties.getRgv()) {
+                    RgvThread rgvThread = (RgvThread) SlaveConnection.get(SlaveType.Rgv, rgvSlave.getId());
+                    RgvProtocol rgvProtocol = rgvThread.getRgvProtocol();
+                    if (rgvProtocol == null) {
                         continue;
                     }
-                    if (rgvProtocol.getRgvNo()==1 && (rgvProtocol.getRgvPosI().equals(101) || rgvProtocol.getRgvPosI().equals(102) )){
-                        continue;
-                    } else if (rgvProtocol.getRgvNo()==2 && (rgvProtocol.getRgvPosI().equals(116) || rgvProtocol.getRgvPosI().equals(117) ) ){
+                    BasRgv basRgv = basRgvService.selectById(rgvSlave.getId());
+                    if (basRgv == null) {
+                        log.error("{}鍙稲GV灏氭湭鍦ㄦ暟鎹簱杩涜缁存姢锛�", rgvSlave.getId());
                         continue;
                     }
-                    rgvAvoidanceXY(rgvProtocol.getRgvNo());
-                    rgvMapUpdate(basRgvMap,basRgvMap.getStartRoute(),basRgvMap.getStartRoute());
+
+                    // 鍙湁褰揜GV绌洪棽銆佽嚜鍔�,宸ヤ綅涓�鏃犵墿//rgv鍙敤
+                    if (rgvProtocol.getStatusType() == RgvStatusType.IDLE
+                            && rgvProtocol.getModeType() == RgvModeType.AUTO
+                            && rgvProtocol.getLoaded1()==0  //鐜板満淇敼锛氬彔鐩樻満锛屼笉婊¢兘绠楁棤鐗╋紝鎬庝箞鍒ゆ柇闇�瑕佽窡鐢垫帶瀵规帴
+                            && rgvProtocol.getTaskNo1()==0
+                            && rgvProtocol.getTaskNo2()==0
+                            && rgvProtocol.getStatusType1() == RgvStatusType.IDLE
+                            && rgvProtocol.getStatusType2() == RgvStatusType.IDLE
+                    ) {
+                        BasRgvMap basRgvMap = basRgvMapMapper.selectById(rgvProtocol.getRgvNo());
+                        if (rgvProtocol.getRgvPosI().equals(basRgvMap.getStartRoute())){
+                            continue;
+                        }
+                        if (rgvProtocol.getRgvNo()==1 && (rgvProtocol.getRgvPosI().equals(101) || rgvProtocol.getRgvPosI().equals(102) )){
+                            continue;
+                        } else if (rgvProtocol.getRgvNo()==2 && (rgvProtocol.getRgvPosI().equals(116) || rgvProtocol.getRgvPosI().equals(117) ) ){
+                            continue;
+                        }
+                        rgvAvoidanceXY(rgvProtocol.getRgvNo());
+                        rgvMapUpdate(basRgvMap,basRgvMap.getStartRoute(),basRgvMap.getStartRoute());
+                    }
                 }
             }
         }catch (Exception e){

--
Gitblit v1.9.1