From 7a326ec05e656413e7d78eb40cb974cc72f08e62 Mon Sep 17 00:00:00 2001
From: zyx <zyx123456>
Date: 星期日, 07 四月 2024 15:05:26 +0800
Subject: [PATCH] 导入重复单据后,修改单据状态

---
 src/main/java/com/zy/asrs/controller/AgvOpenController.java |  155 +++++++++------------------------------------------
 1 files changed, 28 insertions(+), 127 deletions(-)

diff --git a/src/main/java/com/zy/asrs/controller/AgvOpenController.java b/src/main/java/com/zy/asrs/controller/AgvOpenController.java
index b7ef1bb..89fb7e1 100644
--- a/src/main/java/com/zy/asrs/controller/AgvOpenController.java
+++ b/src/main/java/com/zy/asrs/controller/AgvOpenController.java
@@ -60,7 +60,7 @@
 
         apiLogService.save(
                 "ESS浠诲姟鍥炶皟",
-                "/tzskwms/agv/task/event/status",
+                "/phyzwms/agv/task/event/status",
                 null,
                 null,
                 JSON.toJSONString(JSONObject.toJSONString(param)),
@@ -78,16 +78,16 @@
         }
         AgvWrkMast agvWrkMast = agvWrkMastService.selectOne(new EntityWrapper<AgvWrkMast>().eq("wrk_no", wrkNo));
         if(Cools.isEmpty(agvWrkMast)){
-            agvWrkMast = agvWrkMastService.selectOne(new EntityWrapper<AgvWrkMast>().eq("barcode",param.getContainerCode()));
+            agvWrkMast = agvWrkMastService.selectOne(new EntityWrapper<AgvWrkMast>().eq("barcode",param.getPodCode()));
             if (Cools.isEmpty(agvWrkMast)){
                 return R.error("浠诲姟缂栧彿閿欒");
             }
         }
 
-        AgvTask agvTask = AgvTask.valueOf(param.getEventType());
+        AgvTask agvTask = AgvTask.valueOf(param.getMethod());
         Class<AgvTask> clz = AgvTask.class;
         try {
-            Method method = clz.getDeclaredMethod(param.getStatus(), AgvWrkMast.class, AgvTaskCallBackParam.class);
+            Method method = clz.getDeclaredMethod("success", AgvWrkMast.class, AgvTaskCallBackParam.class);
             method.invoke(agvTask,agvWrkMast,param);
         } catch (NoSuchMethodException e) {
             return R.error("浠诲姟鐘舵�乻tatus鍙傛暟鏈夎");
@@ -112,182 +112,83 @@
 enum AgvTask{
 
     /**
-     * 涓婃姤浠诲姟鐘舵��
+     * 涓婃姤浠诲姟瀹屾垚
      */
-    task{
+    end{
         @Transactional
         public void success(AgvWrkMast agvWrkMast, AgvTaskCallBackParam param) {
             //淇敼AGV宸ヤ綔妗g殑宸ヤ綔鐘舵�佷负205.宸ヤ綔瀹屾垚
             agvWrkMast.setWrkSts(205L);
-            agvWrkMast.setLocNo(param.getLocationCode());
-            agvWrkMastService.updateById(agvWrkMast);
-            //agvWrkMastService.updateWrkStsByWrkNo(agvWrkMast.getWrkNo(),205);
 
             //鍑哄簱浠诲姟 101.鍑哄簱 || 103.鎷f枡鍑哄簱 || 107.鐩樼偣鍑哄簱
             if(agvWrkMast.getIoType() == 101 || agvWrkMast.getIoType() == 103 || agvWrkMast.getIoType() == 107){
                 //淇敼鍑哄簱绔欑偣鐘舵��
-                agvBasDevpService.updateLocStsAndBarcodeByDevNo(agvWrkMast.getLocNo(),"F",agvWrkMast.getBarcode());
+                agvBasDevpService.updateLocStsAndBarcodeByDevNo(agvWrkMast.getLocNo(),"F",agvWrkMast.getBarcode(),agvWrkMast.getWhsType().shortValue());
             }
             //鍑哄簱浠诲姟 110.绌烘澘鍑哄簱
             if(agvWrkMast.getIoType() == 110){
-                agvBasDevpService.updateLocStsAndBarcodeByDevNo(agvWrkMast.getLocNo(),"F",agvWrkMast.getBarcode());
+                agvBasDevpService.updateLocStsAndBarcodeByDevNo(agvWrkMast.getLocNo(),"F",agvWrkMast.getBarcode(),agvWrkMast.getWhsType().shortValue());
+                agvWrkMast.setWrkSts(206L);
             }
-        }
-
-        public void fail(AgvWrkMast agvWrkMast, AgvTaskCallBackParam param) {
-
-        }
-
-        public void cancel(AgvWrkMast agvWrkMast, AgvTaskCallBackParam param) {
-
-        }
-
-        public void suspend(AgvWrkMast agvWrkMast, AgvTaskCallBackParam param) {
-
+            agvWrkMastService.updateById(agvWrkMast);
         }
     },
     /**
-     * 涓婃姤浠诲姟鍒嗛厤缁欐満鍣ㄤ汉
+     * 浠诲姟寮�濮�
      */
-    task_allocated{
+    start{
         @Transactional
         public void success(AgvWrkMast agvWrkMast, AgvTaskCallBackParam param) {
-
-        }
-
-        public void fail(AgvWrkMast agvWrkMast, AgvTaskCallBackParam param) {
-
-        }
-
-        public void cancel(AgvWrkMast agvWrkMast, AgvTaskCallBackParam param) {
-
-        }
-
-        public void suspend(AgvWrkMast agvWrkMast, AgvTaskCallBackParam param) {
-
+            //淇敼AGV宸ヤ綔妗g殑宸ヤ綔鐘舵�佷负203.浠诲姟寮�濮�
+            agvWrkMast.setWrkSts(203L);
+            agvWrkMastService.updateById(agvWrkMast);
         }
     },
     /**
-     * 涓婃姤鍙栫鐘舵��
+     * 璧板嚭鍌ㄤ綅鐘舵��
      */
-    tote_load{
+    outbin{
         @Transactional
         public void success(AgvWrkMast agvWrkMast, AgvTaskCallBackParam param) {
 
             //鍏ュ簱浠诲姟 || 鎷f枡鍏ュ簱浠诲姟 ||鐩樼偣鍐嶅叆搴� ||绌烘澘鍏ュ簱
             if(agvWrkMast.getIoType() == 1 || agvWrkMast.getIoType() == 53 || agvWrkMast.getIoType() == 57 || agvWrkMast.getIoType() == 10){
                 //淇敼婧愮珯鐐圭姸鎬佷负O.绌猴紝浠ュ強瑙g粦鎵樼洏鏉$爜
-                agvBasDevpService.updateLocStsAndBarcodeByDevNo(agvWrkMast.getSourceLocNo(),"O","");
+                agvBasDevpService.updateLocStsAndBarcodeByDevNo(agvWrkMast.getSourceLocNo(),"O","",null);
             }
 
             //淇敼AGV宸ヤ綔妗g殑宸ヤ綔鐘舵�佷负203.RCS鏀捐揣涓�
-            agvWrkMastService.updateWrkStsByWrkNo(agvWrkMast.getWrkNo(),203);
-
-
+            agvWrkMastService.updateWrkStsByWrkNo(agvWrkMast.getWrkNo(),204);
 
         }
 
-        public void fail(AgvWrkMast agvWrkMast, AgvTaskCallBackParam param) {
-
-        }
-
-        public void cancel(AgvWrkMast agvWrkMast, AgvTaskCallBackParam param) {
-
-        }
-
-        public void suspend(AgvWrkMast agvWrkMast, AgvTaskCallBackParam param) {
-
-        }
     },
     /**
      * 涓婃姤鏀剧鐘舵��
      */
-    tote_unload{
+    cancel{
         @Transactional
         public void success(AgvWrkMast agvWrkMast, AgvTaskCallBackParam param) {
-            //淇敼宸ヤ綔妗g姸鎬佷负204.鏀捐揣瀹屾垚
-            agvWrkMast.setWrkSts(204L);
-            //agvWrkMast.setLocNo(param.getLocationCode());
-            agvWrkMastService.updateById(agvWrkMast);
-            //agvWrkMastService.updateWrkStsByWrkNo(agvWrkMast.getWrkNo(),204);
+
 
         }
 
-        public void fail(AgvWrkMast agvWrkMast, AgvTaskCallBackParam param) {
-
-        }
-
-        public void cancel(AgvWrkMast agvWrkMast, AgvTaskCallBackParam param) {
-
-        }
-
-        public void suspend(AgvWrkMast agvWrkMast, AgvTaskCallBackParam param) {
-
-        }
     },
-    robot_reach{
+    apply{
         @Transactional
         public void success(AgvWrkMast agvWrkMast, AgvTaskCallBackParam param) {
-
-        }
-
-        public void fail(AgvWrkMast agvWrkMast, AgvTaskCallBackParam param) {
-
-        }
-
-        public void cancel(AgvWrkMast agvWrkMast, AgvTaskCallBackParam param) {
-
-        }
-
-        public void suspend(AgvWrkMast agvWrkMast, AgvTaskCallBackParam param) {
-
-        }
-    },
-    weight{
-        @Transactional
-        public void success(AgvWrkMast agvWrkMast, AgvTaskCallBackParam param) {
-
-        }
-
-        public void fail(AgvWrkMast agvWrkMast, AgvTaskCallBackParam param) {
-
-        }
-
-        public void cancel(AgvWrkMast agvWrkMast, AgvTaskCallBackParam param) {
-
-        }
-
-        public void suspend(AgvWrkMast agvWrkMast, AgvTaskCallBackParam param) {
-
-        }
-    },
-    rfid{
-        @Transactional
-        public void success(AgvWrkMast agvWrkMast, AgvTaskCallBackParam param) {
-
-        }
-
-        public void fail(AgvWrkMast agvWrkMast, AgvTaskCallBackParam param) {
-
-        }
-
-        public void cancel(AgvWrkMast agvWrkMast, AgvTaskCallBackParam param) {
-
-        }
-
-        public void suspend(AgvWrkMast agvWrkMast, AgvTaskCallBackParam param) {
 
         }
     };
 
     //浠诲姟鐘舵�佷负鎴愬姛
     public abstract void success(AgvWrkMast agvWrkMast, AgvTaskCallBackParam param);
-    //浠诲姟鐘舵�佷负澶辫触
-    public abstract void fail(AgvWrkMast agvWrkMast, AgvTaskCallBackParam param);
-    //浠诲姟鐘舵�佷负鍙栨秷
-    public abstract void cancel(AgvWrkMast agvWrkMast, AgvTaskCallBackParam param);
-    //浠诲姟鐘舵�佷负鎸傝捣
-    public abstract void suspend(AgvWrkMast agvWrkMast, AgvTaskCallBackParam param);
+//    //浠诲姟鐘舵�佷负澶辫触
+//    public abstract void fail(AgvWrkMast agvWrkMast, AgvTaskCallBackParam param);
+//    //浠诲姟鐘舵�佷负鍙栨秷
+//    public abstract void cancel(AgvWrkMast agvWrkMast, AgvTaskCallBackParam param);
+//    //浠诲姟鐘舵�佷负鎸傝捣
+//    public abstract void suspend(AgvWrkMast agvWrkMast, AgvTaskCallBackParam param);
 
     @Setter
     AgvBasDevpService agvBasDevpService;

--
Gitblit v1.9.1