From a3c70ef5ed3c18209b37ba01a8ab3eb0eea0d7cb Mon Sep 17 00:00:00 2001
From: zjj <3272660260@qq.com>
Date: 星期二, 12 十二月 2023 16:49:52 +0800
Subject: [PATCH] #

---
 src/main/java/com/zy/asrs/service/impl/OpenServiceImpl.java |   29 ++++++++++++++++++-----------
 1 files changed, 18 insertions(+), 11 deletions(-)

diff --git a/src/main/java/com/zy/asrs/service/impl/OpenServiceImpl.java b/src/main/java/com/zy/asrs/service/impl/OpenServiceImpl.java
index 529e10a..d8a80b1 100644
--- a/src/main/java/com/zy/asrs/service/impl/OpenServiceImpl.java
+++ b/src/main/java/com/zy/asrs/service/impl/OpenServiceImpl.java
@@ -53,7 +53,8 @@
     @Value("${wms.url}")
     private String wmsUrl;
     public ArrayList<String> wharfCode1 = new ArrayList<String>(){{
-        add("J-1101"); add("J-1103"); add("J-1105"); add("J-1107"); add("J-1109"); add("J-1111");
+        add("J-1101"); add("J-1103"); add("J-1105"); add("J-1107"); add("J-1109"); add("J-1111");add("H-1101");
+        add("G-1101");
     }};
 
 
@@ -200,14 +201,22 @@
                 staProtocol = staProtocol.clone();
             }
             Short workNo = staProtocol.getWorkNo();
-            for (DevpSlave.Sta inSta : devp.getInSta()) {
-                if (inSta.getBackSta().equals(staDesc.getStnNo())){
-                    if (wharfCode1.contains(param.getWharfCode())){
-                        if (!staProtocol.isLoading() && !staProtocol.isCar()){
-                            //AGV鍑哄簱瀹屾垚浠ュ悗
-                        }
+            if (wharfCode1.contains(param.getWharfCode())){
+                if (!staProtocol.isLoading() && !staProtocol.isCar() && staProtocol.getWorkNo() >0){
+                    //AGV鍑哄簱瀹屾垚浠ュ悗
+                    staProtocol.setWorkNo((short) 0);
+                    staProtocol.setStaNo((short)0);
+                    boolean result = MessageQueue.offer(SlaveType.Devp, devp.getId(), new Task(3, staProtocol));
+                    if (result) {
 
-                    }else {
+                    } else {
+                        throw new RuntimeException("agv杩斿洖瀹屾垚鍚庯紝鍛戒护涓嬪彂澶辫触");
+                    }
+                }
+            }else {
+                for (DevpSlave.Sta inSta : devp.getInSta()) {
+                    if (inSta.getBackSta().equals(staDesc.getStnNo())){
+
                         if (staProtocol.isLoading() && !staProtocol.isCar() && workNo == 0){
                             //AGV鍏ュ簱瀹屾垚浠ュ悗
                             staProtocol.setWorkNo((short) 9999);
@@ -219,12 +228,10 @@
                                 throw new RuntimeException("agv杩斿洖瀹屾垚鍚庯紝鍛戒护涓嬪彂澶辫触");
                             }
                         }
+
                     }
                 }
             }
-
-
-
         }
 
     }

--
Gitblit v1.9.1