From 3f30983db5b3cd2b25cb215579501a2ef134883c Mon Sep 17 00:00:00 2001
From: zyx <zyx123456>
Date: 星期五, 04 八月 2023 17:00:11 +0800
Subject: [PATCH] agv 订单出库功能完善

---
 src/main/java/com/zy/asrs/controller/AgvOpenController.java |   99 +++++++++++++++++++++++++++++--------------------
 1 files changed, 58 insertions(+), 41 deletions(-)

diff --git a/src/main/java/com/zy/asrs/controller/AgvOpenController.java b/src/main/java/com/zy/asrs/controller/AgvOpenController.java
index d922dfe..9ad92d1 100644
--- a/src/main/java/com/zy/asrs/controller/AgvOpenController.java
+++ b/src/main/java/com/zy/asrs/controller/AgvOpenController.java
@@ -70,8 +70,8 @@
         AgvTask agvTask = AgvTask.valueOf(param.getEventType());
         Class<AgvTask> clz = AgvTask.class;
         try {
-            Method method = clz.getDeclaredMethod(param.getStatus(),AgvTaskCallBackParam.class);
-            method.invoke(agvTask,param);
+            Method method = clz.getDeclaredMethod(param.getStatus(), AgvWrkMast.class, AgvTaskCallBackParam.class);
+            method.invoke(agvTask,agvWrkMast,param);
         } catch (NoSuchMethodException e) {
             return R.error("浠诲姟鐘舵�乻tatus鍙傛暟鏈夎");
         } catch (InvocationTargetException e) {
@@ -103,20 +103,26 @@
      */
     task{
         @Transactional
-        public void success(AgvTaskCallBackParam param) {
+        public void success(AgvWrkMast agvWrkMast, AgvTaskCallBackParam param) {
             //淇敼AGV宸ヤ綔妗g殑宸ヤ綔鐘舵�佷负205.宸ヤ綔瀹屾垚
-            agvWrkMastService.updateWrkStsByWrkNo(Integer.valueOf(param.getTaskCode()),205);
+            agvWrkMastService.updateWrkStsByWrkNo(agvWrkMast.getWrkNo(),205);
+
+            //鍑哄簱浠诲姟 101.鍑哄簱 || 103.鎷f枡鍑哄簱
+            if(agvWrkMast.getIoType() == 101 || agvWrkMast.getIoType() == 103){
+                //淇敼鍑哄簱绔欑偣鐘舵��
+                agvBasDevpService.updateLocStsAndBarcodeByDevNo(agvWrkMast.getLocNo(),"F",agvWrkMast.getBarcode());
+            }
         }
 
-        public void fail(AgvTaskCallBackParam param) {
+        public void fail(AgvWrkMast agvWrkMast, AgvTaskCallBackParam param) {
 
         }
 
-        public void cancel(AgvTaskCallBackParam param) {
+        public void cancel(AgvWrkMast agvWrkMast, AgvTaskCallBackParam param) {
 
         }
 
-        public void suspend(AgvTaskCallBackParam param) {
+        public void suspend(AgvWrkMast agvWrkMast, AgvTaskCallBackParam param) {
 
         }
     },
@@ -125,19 +131,19 @@
      */
     task_allocated{
         @Transactional
-        public void success(AgvTaskCallBackParam param) {
+        public void success(AgvWrkMast agvWrkMast, AgvTaskCallBackParam param) {
 
         }
 
-        public void fail(AgvTaskCallBackParam param) {
+        public void fail(AgvWrkMast agvWrkMast, AgvTaskCallBackParam param) {
 
         }
 
-        public void cancel(AgvTaskCallBackParam param) {
+        public void cancel(AgvWrkMast agvWrkMast, AgvTaskCallBackParam param) {
 
         }
 
-        public void suspend(AgvTaskCallBackParam param) {
+        public void suspend(AgvWrkMast agvWrkMast, AgvTaskCallBackParam param) {
 
         }
     },
@@ -146,25 +152,36 @@
      */
     tote_load{
         @Transactional
-        public void success(AgvTaskCallBackParam param) {
-            //淇敼婧愮珯鐐圭姸鎬佷负O.绌猴紝浠ュ強瑙g粦鎵樼洏鏉$爜
-            agvBasDevpService.updateLocStsAndBarcodeByDevNo(param.getStationCode(),"O","");
+        public void success(AgvWrkMast agvWrkMast, AgvTaskCallBackParam param) {
+
+            //鍏ュ簱浠诲姟 || 鎷f枡鍏ュ簱浠诲姟
+            if(agvWrkMast.getIoType() == 1 || agvWrkMast.getIoType() == 53){
+                //淇敼婧愮珯鐐圭姸鎬佷负O.绌猴紝浠ュ強瑙g粦鎵樼洏鏉$爜
+                agvBasDevpService.updateLocStsAndBarcodeByDevNo(agvWrkMast.getSourceLocNo(),"O","");
+            }
+
+            //鍑哄簱浠诲姟 101.鍑哄簱 || 103.鎷f枡鍑哄簱
+            if(agvWrkMast.getIoType() == 101 || agvWrkMast.getIoType() == 103){
+                //淇敼婧愬簱浣嶇姸鎬�
+
+            }
+
             //淇敼AGV宸ヤ綔妗g殑宸ヤ綔鐘舵�佷负203.RCS鏀捐揣涓�
-            agvWrkMastService.updateWrkStsByWrkNo(Integer.valueOf(param.getTaskCode()),203);
-            //淇敼AGV鍏ュ簱閫氱煡妗g姸鎬�
-            //agvWaitPakinService.updateIoStatus(Integer.valueOf(param.getTaskCode()),"Y");
+            agvWrkMastService.updateWrkStsByWrkNo(agvWrkMast.getWrkNo(),203);
+
+
 
         }
 
-        public void fail(AgvTaskCallBackParam param) {
+        public void fail(AgvWrkMast agvWrkMast, AgvTaskCallBackParam param) {
 
         }
 
-        public void cancel(AgvTaskCallBackParam param) {
+        public void cancel(AgvWrkMast agvWrkMast, AgvTaskCallBackParam param) {
 
         }
 
-        public void suspend(AgvTaskCallBackParam param) {
+        public void suspend(AgvWrkMast agvWrkMast, AgvTaskCallBackParam param) {
 
         }
     },
@@ -173,86 +190,86 @@
      */
     tote_unload{
         @Transactional
-        public void success(AgvTaskCallBackParam param) {
+        public void success(AgvWrkMast agvWrkMast, AgvTaskCallBackParam param) {
             //淇敼宸ヤ綔妗g姸鎬佷负204.鏀捐揣瀹屾垚
-            agvWrkMastService.updateWrkStsByWrkNo(Integer.valueOf(param.getTaskCode()),204);
+            agvWrkMastService.updateWrkStsByWrkNo(agvWrkMast.getWrkNo(),204);
         }
 
-        public void fail(AgvTaskCallBackParam param) {
+        public void fail(AgvWrkMast agvWrkMast, AgvTaskCallBackParam param) {
 
         }
 
-        public void cancel(AgvTaskCallBackParam param) {
+        public void cancel(AgvWrkMast agvWrkMast, AgvTaskCallBackParam param) {
 
         }
 
-        public void suspend(AgvTaskCallBackParam param) {
+        public void suspend(AgvWrkMast agvWrkMast, AgvTaskCallBackParam param) {
 
         }
     },
     robot_reach{
         @Transactional
-        public void success(AgvTaskCallBackParam param) {
+        public void success(AgvWrkMast agvWrkMast, AgvTaskCallBackParam param) {
 
         }
 
-        public void fail(AgvTaskCallBackParam param) {
+        public void fail(AgvWrkMast agvWrkMast, AgvTaskCallBackParam param) {
 
         }
 
-        public void cancel(AgvTaskCallBackParam param) {
+        public void cancel(AgvWrkMast agvWrkMast, AgvTaskCallBackParam param) {
 
         }
 
-        public void suspend(AgvTaskCallBackParam param) {
+        public void suspend(AgvWrkMast agvWrkMast, AgvTaskCallBackParam param) {
 
         }
     },
     weight{
         @Transactional
-        public void success(AgvTaskCallBackParam param) {
+        public void success(AgvWrkMast agvWrkMast, AgvTaskCallBackParam param) {
 
         }
 
-        public void fail(AgvTaskCallBackParam param) {
+        public void fail(AgvWrkMast agvWrkMast, AgvTaskCallBackParam param) {
 
         }
 
-        public void cancel(AgvTaskCallBackParam param) {
+        public void cancel(AgvWrkMast agvWrkMast, AgvTaskCallBackParam param) {
 
         }
 
-        public void suspend(AgvTaskCallBackParam param) {
+        public void suspend(AgvWrkMast agvWrkMast, AgvTaskCallBackParam param) {
 
         }
     },
     rfid{
         @Transactional
-        public void success(AgvTaskCallBackParam param) {
+        public void success(AgvWrkMast agvWrkMast, AgvTaskCallBackParam param) {
 
         }
 
-        public void fail(AgvTaskCallBackParam param) {
+        public void fail(AgvWrkMast agvWrkMast, AgvTaskCallBackParam param) {
 
         }
 
-        public void cancel(AgvTaskCallBackParam param) {
+        public void cancel(AgvWrkMast agvWrkMast, AgvTaskCallBackParam param) {
 
         }
 
-        public void suspend(AgvTaskCallBackParam param) {
+        public void suspend(AgvWrkMast agvWrkMast, AgvTaskCallBackParam param) {
 
         }
     };
 
     //浠诲姟鐘舵�佷负鎴愬姛
-    public abstract void success(AgvTaskCallBackParam param);
+    public abstract void success(AgvWrkMast agvWrkMast, AgvTaskCallBackParam param);
     //浠诲姟鐘舵�佷负澶辫触
-    public abstract void fail(AgvTaskCallBackParam param);
+    public abstract void fail(AgvWrkMast agvWrkMast, AgvTaskCallBackParam param);
     //浠诲姟鐘舵�佷负鍙栨秷
-    public abstract void cancel(AgvTaskCallBackParam param);
+    public abstract void cancel(AgvWrkMast agvWrkMast, AgvTaskCallBackParam param);
     //浠诲姟鐘舵�佷负鎸傝捣
-    public abstract void suspend(AgvTaskCallBackParam param);
+    public abstract void suspend(AgvWrkMast agvWrkMast, AgvTaskCallBackParam param);
 
     @Setter
     AgvBasDevpService agvBasDevpService;

--
Gitblit v1.9.1