From 05aa23e4bce89c2028985e0c98b6ef82e91fc506 Mon Sep 17 00:00:00 2001
From: zjj <zjj123456>
Date: 星期五, 29 三月 2024 08:30:55 +0800
Subject: [PATCH] #

---
 src/main/java/com/zy/asrs/service/impl/OpenServiceImpl.java |   19 +++++++++++++------
 1 files changed, 13 insertions(+), 6 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 2b344d8..ab6f514 100644
--- a/src/main/java/com/zy/asrs/service/impl/OpenServiceImpl.java
+++ b/src/main/java/com/zy/asrs/service/impl/OpenServiceImpl.java
@@ -213,13 +213,13 @@
     }
 
     @Override
-    public void getAgvTaskOver(TaskOverParam param) {
+    public R getAgvTaskOver(TaskOverParam param) {
         // 鏍规嵁杈撻�佺嚎plc閬嶅巻
         for (DevpSlave devp : slaveProperties.getDevp()) {
             StaDesc staDesc = staDescService.selectOne(new EntityWrapper<StaDesc>()
                     .eq("stn_desc", param.getWharfCode()));
             if (Cools.isEmpty(staDesc)){
-                throw new RuntimeException("鏈煡璇㈠埌绔欑偣淇℃伅");
+                throw new CoolException("鏈煡璇㈠埌绔欑偣淇℃伅");
             }
             // 鑾峰彇鍏ュ簱绔欎俊鎭�
             DevpThread devpThread = (DevpThread) SlaveConnection.get(SlaveType.Devp, devp.getId());
@@ -237,10 +237,13 @@
                     staProtocol.setStaNo((short)0);
                     boolean result = MessageQueue.offer(SlaveType.Devp, devp.getId(), new Task(3, staProtocol));
                     if (result) {
-
+                        return R.ok("鍙栬揣瀹屾垚");
                     } else {
-                        throw new RuntimeException("agv杩斿洖瀹屾垚鍚庯紝鍛戒护涓嬪彂澶辫触");
+                        throw new CoolException("agv杩斿洖瀹屾垚鍚庯紝鍛戒护涓嬪彂澶辫触");
                     }
+                }else {
+                    return R.error("鍙栬揣绔欑偣鐘舵�佹湁璇�,鏈夌墿淇″彿锛�"+staProtocol.isLoading()
+                            +",杞﹁締淇″彿锛�"+staProtocol.isCar()+",宸ヤ綔鍙凤細"+staProtocol.getWorkNo());
                 }
             }else {
                 for (DevpSlave.Sta inSta : devp.getInSta()) {
@@ -252,16 +255,20 @@
                             staProtocol.setStaNo(inSta.getStaNo().shortValue());
                             boolean result = MessageQueue.offer(SlaveType.Devp, devp.getId(), new Task(3, staProtocol));
                             if (result) {
-
+                                return R.ok("鏀捐揣瀹屾垚");
                             } else {
-                                throw new RuntimeException("agv杩斿洖瀹屾垚鍚庯紝鍛戒护涓嬪彂澶辫触");
+                                throw new CoolException("agv杩斿洖瀹屾垚鍚庯紝鍛戒护涓嬪彂澶辫触");
                             }
+                        }else {
+                            return R.error("鏀捐揣绔欑偣鐘舵�佹湁璇�,鏈夌墿淇″彿锛�"+staProtocol.isLoading()
+                                    +",杞﹁締淇″彿锛�"+staProtocol.isCar()+",宸ヤ綔鍙凤細"+staProtocol.getWorkNo());
                         }
 
                     }
                 }
             }
         }
+        return R.ok();
 
     }
 

--
Gitblit v1.9.1