From f81e9a5b2b22b3b9e05cdeafb091bca707fa27aa Mon Sep 17 00:00:00 2001
From: Junjie <xjj@123>
Date: 星期二, 29 四月 2025 16:20:58 +0800
Subject: [PATCH] #

---
 src/main/java/com/zy/asrs/controller/OpenController.java |  122 +++++++++++++++++++++++++++++-----------
 1 files changed, 89 insertions(+), 33 deletions(-)

diff --git a/src/main/java/com/zy/asrs/controller/OpenController.java b/src/main/java/com/zy/asrs/controller/OpenController.java
index e7aff90..1708c2e 100644
--- a/src/main/java/com/zy/asrs/controller/OpenController.java
+++ b/src/main/java/com/zy/asrs/controller/OpenController.java
@@ -68,6 +68,8 @@
     private CommonService commonService;
     @Autowired
     private NotifyUtils notifyUtils;
+    @Autowired
+    private BasDevpService basDevpService;
 
     private static final boolean auth = true;
 
@@ -138,7 +140,7 @@
                     .eq("loc_no", locNo)
                     .eq("barcode", param.getBarcode()));
             if(Cools.isEmpty(locMast)){
-                result = R.error("璇ュ簱浣嶄笉婊¤冻鍑哄簱鏉′欢" + param.getTargetPoint());
+                result = R.error("璇ュ簱浣嶄笉婊¤冻鍑哄簱鏉′欢" + locMast.getLocNo());
                 return result;
             }
 
@@ -273,40 +275,65 @@
                                @RequestBody TaskCancelParam param,
                                HttpServletRequest request) {
         auth(appkey, param, request);
-        if (Cools.isEmpty(param)) {
-            return R.error("鍙傛暟涓虹┖锛�");
-        } else if (Cools.isEmpty(param.getTaskNo())) {
-            return R.error("宸ヤ綔鍙蜂负绌猴紒");
-        } else if (Cools.isEmpty(param.getIoType())) {
-            return R.error("鎿嶄綔绫诲瀷涓虹┖锛�");
-        } else if (Cools.isEmpty(param.getBarcode())) {
-            return R.error("鎵樼洏鐮佷笉鑳戒负绌猴紒");
-        }
+        R result = null;
+        try {
+            if (Cools.isEmpty(param)) {
+                return R.error("鍙傛暟涓虹┖锛�");
+            } else if (Cools.isEmpty(param.getTaskNo())) {
+                return R.error("宸ヤ綔鍙蜂负绌猴紒");
+            } else if (Cools.isEmpty(param.getIoType())) {
+                return R.error("鎿嶄綔绫诲瀷涓虹┖锛�");
+            } else if (Cools.isEmpty(param.getBarcode())) {
+                return R.error("鎵樼洏鐮佷笉鑳戒负绌猴紒");
+            }
 
-        TaskWrk taskWrk = taskWrkService.selectOne(new EntityWrapper<TaskWrk>()
-                .eq("task_no", param.getTaskNo())
-                .eq("io_type", param.getIoType())
-                .eq("barcode", param.getBarcode()));
-        if (Cools.isEmpty(taskWrk)){
-            return R.error("鏈煡鍒板綋鍓嶄换鍔�---" + param);
+            TaskWrk taskWrk = taskWrkService.selectOne(new EntityWrapper<TaskWrk>()
+                    .eq("task_no", param.getTaskNo())
+                    .eq("io_type", param.getIoType())
+                    .eq("barcode", param.getBarcode()));
+            if (Cools.isEmpty(taskWrk)){
+                result =  R.error("鏈煡鍒板綋鍓嶄换鍔�---" + param);
+                return result;
+            }
+            boolean sign = false;
+            switch (param.getTaskStatus()) {
+                case 1://姝e父鍙栨秷
+                    if (taskWrk.getStatus() > 1) {
+                        if (taskWrk.getIoType() == 1 && taskWrk.getWrkSts() <= 2) {//鍏ュ簱
+                            break;
+                        }
+
+                        result = R.error("浠诲姟宸插紑濮嬫墽琛�");
+                        return result;
+                    }
+                    break;
+                case 2://姝e父瀹屾垚
+                    if (taskWrk.getStatus() > 1) {
+                        result = R.error("浠诲姟宸插紑濮嬫墽琛�");
+                        return result;
+                    }
+                    sign = true;
+                    break;
+                default:
+                    result = R.error("鏈煡鎿嶄綔");
+                    return result;
+            }
+            result = taskWrkOperate(taskWrk, sign);
+            return result;
+        } catch (Exception e) {
+            e.printStackTrace();
+            result = R.error(e.getMessage());
+            return R.error(e.getMessage());
+        }finally {
+            apiLogService.save("wms浠诲姟涓嬪彂鎺ュ彛"
+                    ,request.getRemoteAddr()+request.getRequestURI()
+                    ,""
+                    ,request.getRemoteAddr()
+                    ,JSON.toJSONString(param)
+                    ,JSON.toJSONString(result)
+                    ,true
+            );
         }
-        boolean sign =false;
-        switch (param.getTaskStatus()) {
-            case 1://姝e父鍙栨秷
-                if (taskWrk.getStatus() > 1) {
-                    return R.error("浠诲姟宸插紑濮嬫墽琛�");
-                }
-                break;
-            case 2://姝e父瀹屾垚
-                if (taskWrk.getStatus() > 1) {
-                    return R.error("浠诲姟宸插紑濮嬫墽琛�");
-                }
-                sign = true;
-                break;
-            default:
-                return R.error("鏈煡鎿嶄綔");
-        }
-        return taskWrkOperate(taskWrk, sign);
     }
 
     //浠诲姟鎿嶄綔
@@ -344,6 +371,35 @@
         return R.ok(crnStatusParams);
     }
 
+    //杈撻�佺珯鐐圭姸鎬佹煡璇㈡帴鍙�
+    @GetMapping("/stationStatus")
+    @Transactional
+    public R stationStatus() {
+        List<StationStatusParam> data = new ArrayList<>();
+        List<BasDevp> list = basDevpService.selectList(new EntityWrapper<BasDevp>()
+                .in("dev_no", 102, 104, 106, 108, 203, 206, 209, 212));
+        for (BasDevp basDevp : list) {
+            String taskNo = "";
+            String barcode = "";
+            if (basDevp.getWrkNo() > 0) {
+                TaskWrk taskWrk = taskWrkService.selectByWrkNo(basDevp.getWrkNo());
+                if (taskWrk != null) {
+                    taskNo = taskWrk.getTaskNo();
+                    barcode = taskWrk.getBarcode();
+                }
+            }
+
+            StationStatusParam param = new StationStatusParam();
+            param.setStaNo(basDevp.getDevNo());
+            param.setTaskNo(taskNo);
+            param.setLoading(basDevp.getLoading());
+            param.setBarcode(barcode);
+
+            data.add(param);
+        }
+        return R.ok(data);
+    }
+
     //妯℃嫙杈撻�佺嚎鍏ュ簱
     @PostMapping("/simulationDevpIn")
     @Transactional

--
Gitblit v1.9.1