From 2bcfd4d2cd5e88ad9e5484bbd8b4834336b9c12c Mon Sep 17 00:00:00 2001
From: Junjie <xjj@123>
Date: 星期二, 29 四月 2025 12:38:50 +0800
Subject: [PATCH] #

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

diff --git a/src/main/java/com/zy/asrs/controller/OpenController.java b/src/main/java/com/zy/asrs/controller/OpenController.java
index 36b3858..1751e90 100644
--- a/src/main/java/com/zy/asrs/controller/OpenController.java
+++ b/src/main/java/com/zy/asrs/controller/OpenController.java
@@ -92,64 +92,71 @@
     @PostMapping("/taskCreate")
     @Transactional
     public R taskCreate(@RequestHeader String appkey,
-                          @RequestBody List<TaskCreateParam> param1,
+                          @RequestBody TaskCreateParam param,
                           HttpServletRequest request) {
-        auth(appkey, param1, request);
+        auth(appkey, param, request);
+
+        R result = null;
         try{
-            List<TaskCreateParam> paramList = new ArrayList<>();
-            List<String> locNoList = new ArrayList<>();
-            for (TaskCreateParam param : param1) {
-                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]涓嶈兘涓虹┖");
-                }
-                String locNo=null;
-                if (param.getIoType() == 1) {
-                    locNo = param.getTargetPoint();
-                } else {
-                    locNo = param.getStartPoint();
-                }
-                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);
-                    }
-                } catch (Exception e) {
-                    log.error("搴撲綅鍙锋娴嬬▼搴忓紓甯�==銆嬪紓甯镐俊鎭�" + e);
-                    return R.error("搴撲綅鍙锋娴嬬▼搴忓紓甯�").add("搴撲綅鍙锋娴嬬▼搴忓紓甯�==銆嬪紓甯镐俊鎭�" + e);
-                }
+            if (Cools.isEmpty(param)) {
+                result = R.parse(BaseRes.PARAM);
+                return result;
+            }
+            if (Cools.isEmpty(param.getTaskNo())) {
+                result = R.error("浠诲姟鍙穂taskNo]涓嶈兘涓虹┖");
+                return result;
+            }
+            if (Cools.isEmpty(param.getIoType())) {
+                result = R.error("浠诲姟绫诲瀷[ioType]涓嶈兘涓虹┖");
+                return result;
+            }
+            if (Cools.isEmpty(param.getBarcode())) {
+                result = R.error("鏉$爜[barcode]涓嶈兘涓虹┖");
+                return result;
+            }
+            String locNo=null;
+            if (param.getIoType() == 1) {
+                locNo = param.getTargetPoint();
+            } else {
+                locNo = param.getStartPoint();
+            }
+            try {
                 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());
+                        .eq("loc_no", locNo).ne("loc_sts", "X"));
+                if (Cools.isEmpty(locMast)) {
+                    log.error("搴撲綅鍙蜂笉瀛樺湪" + locNo);
+                    result = R.error("搴撲綅鍙蜂笉瀛樺湪" + locNo).add("搴撲綅鍙蜂笉瀛樺湪" + locNo);
+                    return result;
                 }
-                if (!locNoList.contains(locMast.getLocNo())){
-                    locNoList.add(locMast.getLocNo());
-                    paramList.add(param);
-                }else {
-                    return R.error("璇ュ簱浣嶄笉鑳藉悓鏃朵笅鍙戜袱绗斾换鍔�" + locMast.getLocNo());
-                }
+            } catch (Exception e) {
+                log.error("搴撲綅鍙锋娴嬬▼搴忓紓甯�==銆嬪紓甯镐俊鎭�" + e);
+                result = R.error("搴撲綅鍙锋娴嬬▼搴忓紓甯�").add("搴撲綅鍙锋娴嬬▼搴忓紓甯�==銆嬪紓甯镐俊鎭�" + e);
+                return result;
             }
-            for (TaskCreateParam param : paramList){
-                openService.taskCreate(param);
+            LocMast locMast = locMastService.selectOne(new EntityWrapper<LocMast>()
+                    .eq("loc_sts", "F")
+                    .eq("loc_no", locNo)
+                    .eq("barcode", param.getBarcode()));
+            if(Cools.isEmpty(locMast)){
+                result = R.error("璇ュ簱浣嶄笉婊¤冻鍑哄簱鏉′欢" + locMast.getLocNo());
+                return result;
             }
+
+            result = openService.taskCreate(param);
+            return result;
         }catch (Exception e){
-            log.error("浠诲姟涓嬪彂寮傚父"+e);
+            log.error("浠诲姟涓嬪彂寮傚父" + e);
             return R.error();
+        }finally {
+            apiLogService.save("wms浠诲姟涓嬪彂鎺ュ彛"
+                    ,request.getRemoteAddr()+request.getRequestURI()
+                    ,""
+                    ,request.getRemoteAddr()
+                    ,JSON.toJSONString(param)
+                    ,JSON.toJSONString(result)
+                    ,true
+            );
         }
-        return R.ok();
     }
 
     //鍒涘缓鍏ュ簱浠诲姟
@@ -379,7 +386,7 @@
 
             JSONObject result = jsonObject.getJSONObject("data");
             Integer resultWrkNo = result.getInteger("wrkNo");
-            Integer resultStaNo = result.getInteger("staNo");
+            Integer resultStaNo = result.getInteger("stnNo");
             String resultLocNo = result.getString("locNo");
 
             // 鍒涙柊涓�涓叆搴撳伐浣滄。
@@ -459,7 +466,6 @@
         }
         log.info("鍏ュ簱璇锋眰鍙傛暟=" + JSON.toJSONString(barcode));
         log.info("鍏ュ簱璇锋眰杩斿洖鍙傛暟=" + JSON.toJSONString(response));
-        return R.error();
+        return R.ok();
     }
-
 }

--
Gitblit v1.9.1