From 4a06fe15a333805d0f8678fde6274b9c20d13602 Mon Sep 17 00:00:00 2001
From: LSH
Date: 星期四, 12 十月 2023 16:35:25 +0800
Subject: [PATCH] #

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

diff --git a/src/main/java/com/zy/asrs/controller/OpenController.java b/src/main/java/com/zy/asrs/controller/OpenController.java
index 18c87c4..1576d6c 100644
--- a/src/main/java/com/zy/asrs/controller/OpenController.java
+++ b/src/main/java/com/zy/asrs/controller/OpenController.java
@@ -16,6 +16,7 @@
 import com.zy.common.web.BaseController;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.transaction.annotation.Transactional;
 import org.springframework.web.bind.annotation.*;
 
 import javax.servlet.http.HttpServletRequest;
@@ -146,28 +147,31 @@
 
     //浠诲姟涓嬪彂鎺ュ彛
     @PostMapping("/outboundTaskSend")
+    @Transactional
     public R outboundTaskSend(@RequestHeader String appkey,
-                              @RequestBody WMSAndAGVInterfaceParam param,
+                              @RequestBody List<WMSAndAGVInterfaceParam> params,
                               HttpServletRequest request) {
-        try {
-            if (Cools.isEmpty(param)){
-                return R.error("鍙傛暟涓虹┖锛�");
-            } else if (Cools.isEmpty(param.getTaskNo())){
-                return R.error("浠诲姟鍙蜂负绌猴紒");
-            } else if (Cools.isEmpty(param.getTaskType())){
-                return R.error("浠诲姟绫诲瀷涓虹┖锛�");
-            } else if (Cools.isEmpty(param.getWarehouseId())){
-                return R.error("浠撳簱鏍囪瘑涓虹┖锛�");
-            }
-            if (Cools.isEmpty(param.getTaskPriority())){
-                param.setTaskPriority(1);
-            }
-            if (Cools.isEmpty(param.getContainerCode())){
-                return R.error("瀹瑰櫒缂栫爜(鎵樼洏鐮�)涓虹┖锛�");
-            }
-            if (Cools.isEmpty(param.getEmptyContainer())){
-                return R.error("鏄惁绌烘墭鐩樹俊鍙蜂负绌猴紒");
-            }
+        List<WMSAndAGVInterfaceParam> params1 =new ArrayList<>();
+        for (WMSAndAGVInterfaceParam param:params){
+            try {
+                if (Cools.isEmpty(param)){
+                    return R.error("鍙傛暟涓虹┖锛�");
+                } else if (Cools.isEmpty(param.getTaskNo())){
+                    return R.error("浠诲姟鍙蜂负绌猴紒");
+                } else if (Cools.isEmpty(param.getTaskType())){
+                    return R.error("浠诲姟绫诲瀷涓虹┖锛�");
+                } else if (Cools.isEmpty(param.getWarehouseId())){
+                    return R.error("浠撳簱鏍囪瘑涓虹┖锛�");
+                }
+                if (Cools.isEmpty(param.getTaskPriority())){
+                    param.setTaskPriority(1);
+                }
+                if (Cools.isEmpty(param.getContainerCode())){
+                    return R.error("瀹瑰櫒缂栫爜(鎵樼洏鐮�)涓虹┖锛�");
+                }
+                if (Cools.isEmpty(param.getEmptyContainer())){
+                    return R.error("鏄惁绌烘墭鐩樹俊鍙蜂负绌猴紒");
+                }
 //        if (Cools.isEmpty(param.getTaskTunnel())){
 //            return R.error("浠诲姟宸烽亾涓虹┖锛�");
 //        }
@@ -177,17 +181,20 @@
 //        if (Cools.isEmpty(param.getTaskSerialNo())){
 //            return R.error("浠诲姟鎵ц椤哄簭涓虹┖锛�");
 //        }
-            if (Cools.isEmpty(param.getTargetWharf())){
-                return R.error("鐩爣鐮佸ご鍖哄煙涓虹┖锛�");//G寮�澶�=7杞﹂棿锛孒寮�澶�=8灞傦紝J寮�澶�=9杞﹂棿
+                if (Cools.isEmpty(param.getTargetWharf())){
+                    return R.error("鐩爣鐮佸ご鍖哄煙涓虹┖锛�");//G寮�澶�=7杞﹂棿锛孒寮�澶�=8灞傦紝J寮�澶�=9杞﹂棿
+                }
+
+                openService.taskCreate(new taskCreateParam(param));
+
+                params1.add(param);
+//                return R.ok(param);
+            }catch (Exception e){
+                String errorMsg = Cools.isEmpty(e.getLocalizedMessage()) ? "" : e.getLocalizedMessage();
+                return R.error("鐢熸垚浠诲姟澶辫触锛岃鑱旂郴绠$悊鍛�!"+ errorMsg);
             }
-
-            openService.taskCreate(new taskCreateParam(param));
-
-            return R.ok(param);
-        }catch (Exception e){
-            String errorMsg = Cools.isEmpty(e.getLocalizedMessage()) ? "" : e.getLocalizedMessage();
-            return R.ok("鐢熸垚浠诲姟澶辫触锛岃鑱旂郴绠$悊鍛�!"+ errorMsg);
         }
+        return R.ok(params1);
     }
 
     //浠诲姟鍙栨秷鎺ュ彛

--
Gitblit v1.9.1