From d65679fefe52fc2bf2435825c65aec3a329e3b9e Mon Sep 17 00:00:00 2001
From: Junjie <fallin.jie@qq.com>
Date: 星期二, 22 四月 2025 14:40:21 +0800
Subject: [PATCH] #

---
 src/main/java/com/zy/asrs/controller/OpenController.java |   85 ++++++++++++++++++++++++++++--------------
 1 files changed, 57 insertions(+), 28 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..13cef9e 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();
@@ -147,17 +187,6 @@
 
         List<CommandInfo> commandInfos = commandInfoService.selectByTaskNo(taskNo);
         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鏃犺锛�");
-        }
     }
 
     //浠诲姟涓嬪彂鎺ュ彛

--
Gitblit v1.9.1