From 116ab17ceb0c77aef99fa10b8a88fc055bb839f0 Mon Sep 17 00:00:00 2001
From: Junjie <xjj@123>
Date: 星期一, 23 六月 2025 19:35:53 +0800
Subject: [PATCH] #

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

diff --git a/src/main/java/com/zy/asrs/controller/OpenController.java b/src/main/java/com/zy/asrs/controller/OpenController.java
index 2a3e840..8bb5a66 100644
--- a/src/main/java/com/zy/asrs/controller/OpenController.java
+++ b/src/main/java/com/zy/asrs/controller/OpenController.java
@@ -57,6 +57,17 @@
         add("ea1f0459efc02a79f046f982767939ae");
     }};
 
+    private void auth(String appkey, Object obj, HttpServletRequest request) {
+        log.info("{}鎺ュ彛琚闂紱appkey:{}锛涜姹傛暟鎹細{}", request.getServletPath(), appkey, JSON.toJSONString(obj));
+        request.setAttribute("cache", obj);
+        if (Cools.isEmpty(appkey)) {
+            throw new CoolException("璁よ瘉澶辫触锛岃纭appkey鏃犺锛�");
+        }
+        if (!APP_KEY_LIST.contains(appkey)) {
+            throw new CoolException("璁よ瘉澶辫触锛岃纭appkey鏃犺锛�");
+        }
+    }
+
     //鍒涘缓浠诲姟
     @PostMapping("/taskCreate")
     @Transactional
@@ -81,26 +92,26 @@
                     return R.error("鏉$爜[barcode]涓嶈兘涓虹┖");
                 }
                 String locNo=null;
-                if(param.getIoType()==1){
-                    locNo=param.getTargetPoint();
-                }else{
-                    locNo=param.getStartPoint();
+                if (param.getIoType() == 1) {
+                    locNo = param.getTargetPoint();
+                } else {
+                    locNo = param.getStartPoint();
                 }
-                try{
+                try {
                     LocMast locMast = locMastService.selectOne(new EntityWrapper<LocMast>()
-                            .eq("loc_no", locNo).ne("loc_sts","X"));
-                    if (Cools.isEmpty(locMast)){
-                        log.error("搴撲綅鍙蜂笉瀛樺湪"+locNo);
-                        return R.error("搴撲綅鍙蜂笉瀛樺湪"+locNo).add("搴撲綅鍙蜂笉瀛樺湪"+locNo);
+                            .eq("loc_no", locNo).ne("loc_sts", "X"));
+                    if (Cools.isEmpty(locMast)) {
+                        log.error("搴撲綅鍙蜂笉瀛樺湪" + locNo);
+                        return R.error("搴撲綅鍙蜂笉瀛樺湪" + locNo).add("搴撲綅鍙蜂笉瀛樺湪" + locNo);
                     }
-                }catch (Exception e){
-                    log.error("搴撲綅鍙锋娴嬬▼搴忓紓甯�==銆嬪紓甯镐俊鎭�"+e);
-                    return R.error("搴撲綅鍙锋娴嬬▼搴忓紓甯�").add("搴撲綅鍙锋娴嬬▼搴忓紓甯�==銆嬪紓甯镐俊鎭�"+e);
+                } catch (Exception e) {
+                    log.error("搴撲綅鍙锋娴嬬▼搴忓紓甯�==銆嬪紓甯镐俊鎭�" + e);
+                    return R.error("搴撲綅鍙锋娴嬬▼搴忓紓甯�").add("搴撲綅鍙锋娴嬬▼搴忓紓甯�==銆嬪紓甯镐俊鎭�" + e);
                 }
-                LocMast locMast=locMastService.selectOne(new EntityWrapper<LocMast>()
-                        .eq("loc_sts","F")
-                        .eq("loc_no",locNo)
-                        .eq("barcode",param.getBarcode()));
+                LocMast locMast = locMastService.selectOne(new EntityWrapper<LocMast>()
+                        .eq("loc_sts", "F")
+                        .eq("loc_no", locNo)
+                        .eq("barcode", param.getBarcode()));
                 if(Cools.isEmpty(locMast)){
                     return R.error("璇ュ簱浣嶄笉婊¤冻鍑哄簱鏉′欢"+param.getTargetPoint());
                 }
@@ -108,12 +119,41 @@
                     locNoList.add(locMast.getLocNo());
                     paramList.add(param);
                 }else {
-                    return R.error("璇ュ簱浣嶄笉鑳藉悓鏃朵笅鍙戜袱绗斾换鍔�"+locMast.getLocNo());
+                    return R.error("璇ュ簱浣嶄笉鑳藉悓鏃朵笅鍙戜袱绗斾换鍔�" + locMast.getLocNo());
                 }
             }
             for (TaskCreateParam param : paramList){
                 openService.taskCreate(param);
             }
+        }catch (Exception e){
+            log.error("浠诲姟涓嬪彂寮傚父"+e);
+            return R.error();
+        }
+        return R.ok();
+    }
+
+    //鍒涘缓鍏ュ簱浠诲姟
+    @PostMapping("/taskCreateIn")
+    @Transactional
+    public R taskCreateIn(@RequestHeader String appkey,
+                        @RequestBody TaskCreateInParam param,
+                        HttpServletRequest request) {
+        auth(appkey, param, request);
+        try{
+            if (Cools.isEmpty(param)) {
+                return R.parse(BaseRes.PARAM);
+            }
+            if (Cools.isEmpty(param.getTaskNo())) {
+                return R.error("浠诲姟鍙穂taskNo]涓嶈兘涓虹┖");
+            }
+            if (Cools.isEmpty(param.getIoType())) {
+                return R.error("浠诲姟绫诲瀷[ioType]涓嶈兘涓虹┖");
+            }
+            if (Cools.isEmpty(param.getBarcode())) {
+                return R.error("鏉$爜[barcode]涓嶈兘涓虹┖");
+            }
+
+            openService.taskCreateIn(param);
         }catch (Exception e){
             log.error("浠诲姟涓嬪彂寮傚父"+e);
             return R.error();
@@ -149,17 +189,6 @@
         return R.ok().add(commandInfos);
     }
 
-    private void auth(String appkey, Object obj, HttpServletRequest request) {
-        log.info("{}鎺ュ彛琚闂紱appkey:{}锛涜姹傛暟鎹細{}", request.getServletPath(), appkey, JSON.toJSONString(obj));
-        request.setAttribute("cache", obj);
-        if (Cools.isEmpty(appkey)) {
-            throw new CoolException("璁よ瘉澶辫触锛岃纭appkey鏃犺锛�");
-        }
-        if (!APP_KEY_LIST.contains(appkey)) {
-            throw new CoolException("璁よ瘉澶辫触锛岃纭appkey鏃犺锛�");
-        }
-    }
-
     //浠诲姟涓嬪彂鎺ュ彛
     @PostMapping("/outboundTaskSend")
     @Transactional
@@ -182,7 +211,7 @@
                 map.put("Msg","浠诲姟绫诲瀷涓虹┖锛�");
                 return map;
             }
-            String fusion = Utils.Fusion(param.getOriginalRowNo(), param.getOriginalFloorNo(), param.getOriginalColumnNo());
+            String fusion = Utils.getLocNo(param.getOriginalRowNo(), param.getOriginalFloorNo(), param.getOriginalColumnNo());
             param.setStartPoint(fusion);
             LocMast locMast = locMastService.selectByLocNo(param.getStartPoint());
             if(Cools.isEmpty(locMast)){
@@ -209,7 +238,7 @@
                     return r;
                 }
             }else if (param.getStereoscopicTaskType() == 3){
-                String fusion1 = Utils.Fusion(param.getGoalRowNo(), param.getGoalFloorNo(), param.getGoalColumnNo());
+                String fusion1 = Utils.getLocNo(param.getGoalRowNo(), param.getGoalFloorNo(), param.getGoalColumnNo());
                 param.setTerminalNo(fusion1);
                 //绉诲簱浠诲姟鍒涘缓
                 r = openService.taskCreate(new TaskCreateParam(param,locMast.getCrnNo()));

--
Gitblit v1.9.1