From dcdfc93b50febf61301832d91dfcddcfa1ca5403 Mon Sep 17 00:00:00 2001
From: 1 <1@123>
Date: 星期三, 14 五月 2025 14:06:36 +0800
Subject: [PATCH] #

---
 src/main/java/com/zy/asrs/controller/TaskWrkController.java |  139 +++++++++++++++++++++++++++-------------------
 1 files changed, 81 insertions(+), 58 deletions(-)

diff --git a/src/main/java/com/zy/asrs/controller/TaskWrkController.java b/src/main/java/com/zy/asrs/controller/TaskWrkController.java
index 7a58fad..ec82562 100644
--- a/src/main/java/com/zy/asrs/controller/TaskWrkController.java
+++ b/src/main/java/com/zy/asrs/controller/TaskWrkController.java
@@ -23,6 +23,7 @@
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.web.bind.annotation.*;
 
+import java.time.LocalDateTime;
 import java.util.*;
 
 @RestController
@@ -260,41 +261,44 @@
 
         }
         String response="";
-        try{
-            HashMap<String, Object> headParam = new HashMap<>();
-            headParam.put("taskNo",taskWrk.getTaskNo());
-            headParam.put("status",taskWrk.getStatus());
-            headParam.put("ioType",taskWrk.getIoTypeWms());
-            headParam.put("barcode",taskWrk.getBarcode());
-//            headParam.put("reportTime",new Date());
-            log.info("wcs鎵嬪姩瀹屾垚浠诲姟涓婃姤wms={}", taskWrk);
-            response = new HttpHandler.Builder()
-                    // .setHeaders(headParam)
-                    .setUri(wmsUrl)
-                    .setPath(taskStatusFeedbackPath)
-                    .setJson(JSON.toJSONString(headParam))
-                    .build()
-                    .doPost();
 
-            JSONObject jsonObject = JSON.parseObject(response);
-            apiLogService.save("wcs鎵嬪姩瀹屾垚浠诲姟涓婃姤wms"
-                    ,wmsUrl+taskStatusFeedbackPath
-                    ,null
-                    ,"127.0.0.1"
-                    ,JSON.toJSONString(headParam)
-                    ,response
-                    ,true
-            );
-        }catch (Exception e){
-            log.error("wcs鎵嬪姩瀹屾垚浠诲姟涓婃姤wms澶眥},杩斿洖鍊�={}", taskWrk,response);
-//            throw new CoolException(e);
-        }
         Date now = new Date();
         locMast.setModiTime(now);
-        locMastService.updateById(locMast);
         taskWrk.setStatus(7);//鎵嬪姩瀹屾垚浠诲姟
         taskWrk.setModiTime(now);
         taskWrk.setCompleteTime(now);
+//        try{
+//            HashMap<String, Object> headParam = new HashMap<>();
+//            headParam.put("taskNo",taskWrk.getTaskNo());
+//            headParam.put("taskStatus",taskWrk.getStatusWms());
+//            headParam.put("ioType",taskWrk.getIoTypeWms());
+//            headParam.put("barCode",taskWrk.getBarcode());
+//            headParam.put("reportTime", LocalDateTime.now());
+//            headParam.put("weight",taskWrk.getScWeight().doubleValue());
+//
+//            log.info("wcs鎵嬪姩瀹屾垚浠诲姟涓婃姤wms={}", taskWrk);
+//            response = new HttpHandler.Builder()
+//                    // .setHeaders(headParam)
+//                    .setUri(wmsUrl)
+//                    .setPath(taskStatusFeedbackPath)
+//                    .setJson(JSON.toJSONString(headParam))
+//                    .build()
+//                    .doPost();
+//
+//            JSONObject jsonObject = JSON.parseObject(response);
+//            apiLogService.save("wcs鎵嬪姩瀹屾垚浠诲姟涓婃姤wms"
+//                    ,wmsUrl+taskStatusFeedbackPath
+//                    ,null
+//                    ,"127.0.0.1"
+//                    ,JSON.toJSONString(headParam)
+//                    ,response
+//                    ,true
+//            );
+//        }catch (Exception e){
+//            log.error("wcs鎵嬪姩瀹屾垚浠诲姟涓婃姤wms澶眥},杩斿洖鍊�={}", taskWrk,response);
+////            throw new CoolException(e);
+//        }
+        locMastService.updateById(locMast);
         taskWrkService.updateById(taskWrk);
         return R.ok();
     }
@@ -319,35 +323,37 @@
             taskWrk.setModiUser(1111L);//鎿嶄綔鍛�
         }
         String response="";
-        try{
-            HashMap<String, Object> headParam = new HashMap<>();
-            headParam.put("taskNo",taskWrk.getTaskNo());
-            headParam.put("status",taskWrk.getStatus());
-            headParam.put("ioType",taskWrk.getIoTypeWms());
-            headParam.put("barcode",taskWrk.getBarcode());
-//            headParam.put("reportTime",new Date());
-
-            log.info("wcs鎵嬪姩鍙栨秷浠诲姟涓婃姤wm={}", taskWrk);
-            response = new HttpHandler.Builder()
-                    // .setHeaders(headParam)
-                    .setUri(wmsUrl)
-                    .setPath(taskStatusFeedbackPath)
-                    .setJson(JSON.toJSONString(headParam))
-                    .build()
-                    .doPost();
-            JSONObject jsonObject = JSON.parseObject(response);
-            apiLogService.save("wcs鎵嬪姩鍙栨秷浠诲姟涓婃姤wms"
-                    ,wmsUrl+taskStatusFeedbackPath
-                    ,null
-                    ,"127.0.0.1"
-                    ,JSON.toJSONString(headParam)
-                    ,response
-                    ,true
-            );
-        }catch (Exception e){
-            log.error("wcs鎵嬪姩鍙栨秷浠诲姟涓婃姤wms澶辫触={},杩斿洖鍊�={}", taskWrk,response);
-//            throw new CoolException(e);
-        }
+//        try{
+//            HashMap<String, Object> headParam = new HashMap<>();
+//            headParam.put("taskNo",taskWrk.getTaskNo());
+//            headParam.put("taskStatus",taskWrk.getStatusWms());
+//            headParam.put("ioType",taskWrk.getIoTypeWms());
+//            headParam.put("barCode",taskWrk.getBarcode());
+//            headParam.put("reportTime", LocalDateTime.now());
+//            headParam.put("weight",taskWrk.getScWeight().doubleValue());
+//
+//
+//            log.info("wcs鎵嬪姩鍙栨秷浠诲姟涓婃姤wm={}", taskWrk);
+//            response = new HttpHandler.Builder()
+//                    // .setHeaders(headParam)
+//                    .setUri(wmsUrl)
+//                    .setPath(taskStatusFeedbackPath)
+//                    .setJson(JSON.toJSONString(headParam))
+//                    .build()
+//                    .doPost();
+//            JSONObject jsonObject = JSON.parseObject(response);
+//            apiLogService.save("wcs鎵嬪姩鍙栨秷浠诲姟涓婃姤wms"
+//                    ,wmsUrl+taskStatusFeedbackPath
+//                    ,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();
@@ -377,6 +383,7 @@
             return R.ok();
         } else if (!Cools.isEmpty(taskWrk) && taskWrk.getWrkSts()==3) {
             taskWrk.setWrkSts(2);
+            taskWrk.setStatus(TaskStatusType.RECEIVE.id);//娲惧彂鐘舵��
             taskWrkService.updateById(taskWrk);
             if(!taskWrkService.updateById(taskWrk)){
                 return R.error("鏇存柊浠诲姟鐘舵�佸け璐�");
@@ -387,6 +394,22 @@
         }
 
     }
+    @PostMapping(value = "/taskWrk/assign/auth")
+    @ManagerAuth(memo = "杈撻�佺嚎涓嬪彂瀹屾垚")
+    public R returnAssign(@RequestParam String taskNo) {
+        TaskWrk taskWrk = taskWrkService.selectByTaskNo(taskNo);
+        if (!Cools.isEmpty(taskWrk) && taskWrk.getWrkSts()==1){
+            taskWrk.setStatus(TaskStatusType.RECEIVE.id);//娲惧彂鐘舵��
+            taskWrk.setWrkSts(2);
+            if(!taskWrkService.updateById(taskWrk)){
+                return R.error("鏇存柊浠诲姟鐘舵�佸け璐�");
+            }
+            return R.ok();
+        }else{
+            return R.error("浠诲姟鐘舵�佷笉瀵规棤娉曡烦杞�");
+        }
+
+    }
 
 
 }

--
Gitblit v1.9.1