From d7621e3cbf301453fe87ee584f34333378a5afb3 Mon Sep 17 00:00:00 2001
From: L <L@123>
Date: 星期日, 21 九月 2025 21:02:50 +0800
Subject: [PATCH] *

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

diff --git a/src/main/java/com/zy/asrs/controller/OpenController.java b/src/main/java/com/zy/asrs/controller/OpenController.java
index 8b0604a..1c26f05 100644
--- a/src/main/java/com/zy/asrs/controller/OpenController.java
+++ b/src/main/java/com/zy/asrs/controller/OpenController.java
@@ -26,6 +26,8 @@
 public class OpenController extends BaseController {
 
     private static final boolean auth = true;
+    private static final String  sign_arm_order = "|s|LABEL_";
+    private static final String  sign_arm_sku = "|sku|LABEL_";
     public static final ArrayList<String> APP_KEY_LIST = new ArrayList<String>() {{
         add("ea1f0459efc02a79f046f982767939ae");
     }};
@@ -216,4 +218,145 @@
         System.out.println(JSON.toJSONString(param1));
     }
 
+
+    /**
+     * 鍒嗘嫞绾夸笂鎶ユ帴鏀�
+     */
+    @PostMapping("/arm/task/v1")
+    public synchronized R TaskArmReport(@RequestHeader(required = false) String appkey,
+                                           @RequestBody TaskArmReportParam param,
+                                           HttpServletRequest request) {
+        auth(appkey, param, request);
+        if (Cools.isEmpty(param)) {
+            return R.parse(BaseRes.PARAM);
+        }
+        if (Cools.isEmpty(param.getOrderNo())) {
+            return R.error("鍗曟嵁缂栧彿[orderNo]涓嶈兘涓虹┖");
+        }
+        if (Cools.isEmpty(param.getSku())) {
+            return R.error("瀹汉鍨嬪彿[sku]涓嶈兘涓虹┖");
+        }
+        if (Cools.isEmpty(param.getPo())) {
+            return R.error("瀹汉PO[po]涓嶈兘涓虹┖");
+        }
+        if (Cools.isEmpty(param.getUpc())) {
+            return R.error("UPC[upc]涓嶈兘涓虹┖");
+        }
+        if (Cools.isEmpty(param.getSupplier())) {
+            return R.error("璐ф簮[supplier]涓嶈兘涓虹┖");
+        }
+        if (Cools.isEmpty(param.getStaNo())) {
+            return R.error("鍒嗘嫞鐐逛綅[staNo]涓嶈兘涓虹┖");
+        }
+        openService.taskArmReport(param);
+        return R.ok();
+    }
+
+
+    /**
+     * 鍗曠爜瀹屾垚
+     */
+    @PostMapping("/arm/task/cycle_result")
+    public synchronized R TaskArmCycleResult(@RequestHeader(required = false) String appkey,
+                                        @RequestBody TaskArmCycleResultParam param,
+                                        HttpServletRequest request) {
+        auth(appkey, param, request);
+        if (Cools.isEmpty(param)) {
+            return R.parse(BaseRes.PARAM);
+        }
+        if (Cools.isEmpty(param.getArm_no())) {
+            return R.error("鏈烘鑷傜紪鍙穂Arm_no]涓嶈兘涓虹┖");
+        }
+        if (Cools.isEmpty(param.getOrder_id())) {
+            return R.error("鍗曟嵁缂栧彿[order_id]涓嶈兘涓虹┖");
+        }
+        if (Cools.isEmpty(param.getPick_num())) {
+            return R.error("瀹汉鍨嬪彿[pick_num]涓嶈兘涓虹┖");
+        }
+        try{
+            param.OrderIdTwo(sign_arm_order,sign_arm_sku);
+        } catch (Exception e){
+            return R.error("鍗曟嵁缂栧彿[order_id]浠� "+sign_arm_sku+" 涓� "+sign_arm_order+" 浣滀负鎷嗗垎鏍囪鎷嗗垎澶辫触锛侊紒锛�");
+        }
+
+        openService.taskArmCycleResult(param);
+        return R.ok();
+    }
+
+
+    /**
+     * 鎵樼洏瀹屾垚
+     */
+    @PostMapping("/arm/task/workspace_status")
+    public synchronized R TaskArmWorkspaceStatus(@RequestHeader(required = false) String appkey,
+                                             @RequestBody TaskArmWorkspaceStatusParam param,
+                                             HttpServletRequest request) {
+        auth(appkey, param, request);
+        if (Cools.isEmpty(param)) {
+            return R.parse(BaseRes.PARAM);
+        }
+        if (Cools.isEmpty(param.getArm_no())) {
+            return R.error("鏈烘鑷傜紪鍙穂Arm_no]涓嶈兘涓虹┖");
+        }
+        if (Cools.isEmpty(param.getId())) {
+            return R.error("鍗曟嵁缂栧彿[order_id]涓嶈兘涓虹┖");
+        }
+        if (Cools.isEmpty(param.getType())) {
+            return R.error("瀹汉鍨嬪彿[pick_num]涓嶈兘涓虹┖");
+        }
+        if (Cools.isEmpty(param.getStatus())) {
+            return R.error("瀹汉鍨嬪彿[pick_num]涓嶈兘涓虹┖");
+        }
+
+        openService.taskArmWorkspaceStatus(param);
+        return R.ok();
+    }
+
+
+    /**
+     * 寮傚父涓婃姤
+     */
+    @PostMapping("/armAbnormalOperation")
+    public synchronized R ArmAbnormalOperation(@RequestHeader(required = false) String appkey,
+                                                 @RequestBody TaskArmErrorParam param,
+                                                 HttpServletRequest request) {
+        auth(appkey, param, request);
+        if (Cools.isEmpty(param.getArm_no())) {
+            return R.error("鏈烘鑷傜紪鍙穂Arm_no]涓嶈兘涓虹┖");
+        }
+        if (Cools.isEmpty(param)) {
+            return R.parse(BaseRes.PARAM);
+        }
+
+        return R.ok().add(param);
+    }
+
+
+    /**
+     * 璁㈠崟瀹屾垚涓婃姤
+     */
+    @PostMapping("/arm/task/order_result")
+    public synchronized R TaskArmWorkOrderStatus(@RequestHeader(required = false) String appkey,
+                                                 @RequestBody OrderArmEndParam param,
+                                                 HttpServletRequest request) {
+        auth(appkey, param, request);
+        if (Cools.isEmpty(param)) {
+            return R.parse(BaseRes.PARAM);
+        }
+        if (Cools.isEmpty(param.getArm_no())) {
+            return R.error("鏈烘鑷傜紪鍙穂Arm_no]涓嶈兘涓虹┖");
+        }
+        if (Cools.isEmpty(param.getOrder_id())) {
+            return R.error("鍗曟嵁缂栧彿[order_id]涓嶈兘涓虹┖");
+        }
+        try{
+            param.OrderIdTwo(sign_arm_order,sign_arm_sku);
+        } catch (Exception e){
+            return R.error("鍗曟嵁缂栧彿[order_id]浠� "+sign_arm_sku+" 涓� "+sign_arm_order+" 浣滀负鎷嗗垎鏍囪鎷嗗垎澶辫触锛侊紒锛�");
+        }
+
+        openService.taskArmWorkOrderStatus(param);
+        return R.ok();
+    }
+
 }

--
Gitblit v1.9.1