From bc48a855d98e360042a7e2fff5594a91a82578c6 Mon Sep 17 00:00:00 2001
From: taisheng <taisheng@qq.com>
Date: 星期四, 24 七月 2025 16:16:33 +0800
Subject: [PATCH] #

---
 src/main/java/com/zy/asrs/controller/TaskWrkController.java |   80 +++++++++++++++++++--------------------
 1 files changed, 39 insertions(+), 41 deletions(-)

diff --git a/src/main/java/com/zy/asrs/controller/TaskWrkController.java b/src/main/java/com/zy/asrs/controller/TaskWrkController.java
index b891f3b..7753f55 100644
--- a/src/main/java/com/zy/asrs/controller/TaskWrkController.java
+++ b/src/main/java/com/zy/asrs/controller/TaskWrkController.java
@@ -291,33 +291,34 @@
             taskWrk.setModiUser(9999L);//鎿嶄綔鍛�
         }
         String response="";
-        try{
-            HashMap<String, Object> headParam = new HashMap<>();
-            headParam.put("TaskNo",taskWrk.getTaskNo());
-            headParam.put("Result",0);
-//            headParam.put("reportTime",new Date());
+//        try{
+//            HashMap<String, Object> headParam = new HashMap<>();
+//            headParam.put("TaskNo",taskWrk.getTaskNo());
+//            headParam.put("Result",0);
+////            headParam.put("reportTime",new Date());
+//
+//            log.info("wcs鎵嬪姩鍙栨秷浠诲姟涓婃姤wm={}", taskWrk);
+//            response = new HttpHandler.Builder()
+//                    // .setHeaders(headParam)
+//                    .setUri(wmsUrl)
+//                    .setPath(TaskExecCallback)
+//                    .setJson(JSON.toJSONString(headParam))
+//                    .build()
+//                    .doPost();
+//            JSONObject jsonObject = JSON.parseObject(response);
+//            apiLogService.save("wcs鎵嬪姩鍙栨秷浠诲姟涓婃姤wms"
+//                    ,wmsUrl+TaskExecCallback
+//                    ,null
+//                    ,"127.0.0.1"
+//                    ,JSON.toJSONString(headParam)
+//                    ,response
+//                    ,true
+//            );
+//        }catch (Exception e){
+//            log.error("wcs鎵嬪姩鍙栨秷浠诲姟涓婃姤wms澶辫触={},杩斿洖鍊�={}", taskWrk,response);
+////            throw new CoolException(e);
+//        }
 
-            log.info("wcs鎵嬪姩鍙栨秷浠诲姟涓婃姤wm={}", taskWrk);
-            response = new HttpHandler.Builder()
-                    // .setHeaders(headParam)
-                    .setUri(wmsUrl)
-                    .setPath(TaskExecCallback)
-                    .setJson(JSON.toJSONString(headParam))
-                    .build()
-                    .doPost();
-            JSONObject jsonObject = JSON.parseObject(response);
-            apiLogService.save("wcs鎵嬪姩鍙栨秷浠诲姟涓婃姤wms"
-                    ,wmsUrl+TaskExecCallback
-                    ,null
-                    ,"127.0.0.1"
-                    ,JSON.toJSONString(headParam)
-                    ,response
-                    ,true
-            );
-        }catch (Exception e){
-            log.error("wcs鎵嬪姩鍙栨秷浠诲姟涓婃姤wms澶辫触={},杩斿洖鍊�={}", taskWrk,response);
-//            throw new CoolException(e);
-        }
         taskWrk.setCompleteTime(now);//瀹岀粨鏃堕棿
         taskWrkService.updateById(taskWrk);
         return R.ok();
@@ -360,21 +361,18 @@
             return R.error("娌℃湁鎵惧埌璇ヤ换鍔�={"+notifyDto+"}");
         }
         Date now = new Date();
-        if(notifyDto.getMsgType().equals("task_complete")&&taskWrk.getIoType()==3){
-            taskWrk.setWrkSts(9);//鏇存柊鏁版嵁瀹屾垚锛岀洿鎺ヨ浆鍘嗗彶妗�
-
-            //鏇存柊婧愬簱浣嶇姸鎬佷负绌哄簱浣�
-            LocMast locMast = locMastService.selectByLocNo(taskWrk.getStartPoint());
-            locMast.setLocSts("O");
-            locMastService.updateById(locMast);
-
-            //鏇存柊鐩爣搴撶姸鎬佷负鍦ㄥ簱
-            LocMast locMast2 = locMastService.selectByLocNo(taskWrk.getTargetPoint());
-            locMast2.setLocSts("F");
-            locMastService.updateById(locMast2);
-            taskWrk.setModiTime(now);//鎿嶄綔鏃堕棿
-            taskWrk.setModiUser(9998L);//鎿嶄綔鍛�
-            taskWrkService.updateById(taskWrk);
+        if (notifyDto.getMsgType().equals("task_complete")) {
+            if (taskWrk.getIoType() == 1 || taskWrk.getIoType() == 3) {
+                taskWrk.setWrkSts(8);//鏇存柊鏁版嵁
+                taskWrk.setModiTime(now);//鎿嶄綔鏃堕棿
+                taskWrk.setModiUser(9998L);//鎿嶄綔鍛�
+                taskWrkService.updateById(taskWrk);
+            } else if (taskWrk.getIoType() == 2) {
+                taskWrk.setWrkSts(18);//鏇存柊鏁版嵁
+                taskWrk.setModiTime(now);//鎿嶄綔鏃堕棿
+                taskWrk.setModiUser(9998L);//鎿嶄綔鍛�
+                taskWrkService.updateById(taskWrk);
+            }
         }
         return R.ok();
     }

--
Gitblit v1.9.1