From 680c4484aebd032289a7a5ab1bad5c6c357ffee9 Mon Sep 17 00:00:00 2001
From: skyouc <creaycat@gmail.com>
Date: 星期四, 25 十二月 2025 09:52:29 +0800
Subject: [PATCH] no message

---
 src/main/java/com/zy/api/service/impl/KopenApiServiceImpl.java |  119 +++++++++++++++++++++++++++++++----------------------------
 1 files changed, 62 insertions(+), 57 deletions(-)

diff --git a/src/main/java/com/zy/api/service/impl/KopenApiServiceImpl.java b/src/main/java/com/zy/api/service/impl/KopenApiServiceImpl.java
index 38d8f8d..c401f48 100644
--- a/src/main/java/com/zy/api/service/impl/KopenApiServiceImpl.java
+++ b/src/main/java/com/zy/api/service/impl/KopenApiServiceImpl.java
@@ -69,17 +69,20 @@
     /**
      * 鎺ユ敹涓嬪彂璁㈠崟淇℃伅
      *
-     * @param params
+     * @param orderParams
      * @return com.core.common.R
      * @author Ryan
      * @date 2025/11/24 14:49
      */
     @Override
-    public XSR receiveOrders(PubOrderParams params) {
-        if (params.getType().equals(OrderWkType.getTypeVal(params.getType()))) {
-            return XSR.error("褰撳墠绫诲瀷涓嶆槸涓婃灦娲惧伐鍗曪紒锛�");
-        }
-        addOrUpdateOrders(params, "add");
+    public XSR receiveOrders(List<PubOrderParams> orderParams) {
+        orderParams.forEach(params -> {
+            if (params.getType().equals(OrderWkType.getTypeVal(params.getType()))) {
+                throw new CoolException("褰撳墠绫诲瀷涓嶆槸涓婃灦娲惧伐鍗曪紒锛�");
+            }
+            addOrUpdateOrders(params, "add");
+        });
+
         return XSR.ok("鍗曟嵁涓嬪彂鎴愬姛锛侊紒");
     }
 
@@ -91,7 +94,7 @@
      */
     @Override
     @Transactional(rollbackFor = Exception.class)
-    public XSR getInDispatchResult(ReportOrderParam params) {
+    public XSR getInDispatchResult(List<ReportOrderParam> params) {
         if (Objects.isNull(params)) {
             return XSR.error("鍙傛暟涓嶈兘涓虹┖锛侊紒");
         }
@@ -124,29 +127,31 @@
     /**
      * 澶囪揣鎸囩ず娲惧伐鍗曚笅鍙�
      *
-     * @param params
+     * @param pubOrderParams
      * @return com.core.common.R
      * @author Ryan
      * @date 2025/11/24 15:21
      */
     @Override
     @Transactional(rollbackFor = Exception.class)
-    public XSR sendOutDispatch(PubOrderParams params) {
-        if (Objects.isNull(params)) {
+    public XSR sendOutDispatch(List<PubOrderParams> pubOrderParams) {
+        if (Objects.isNull(pubOrderParams) || pubOrderParams.isEmpty()) {
             return XSR.error("鍙傛暟涓嶈兘涓虹┖锛侊紒");
         }
-        // 鏍¢獙鍙傛暟
-        if (Objects.isNull(params.getDispatch_no())) {
-            return XSR.error("娲惧伐鍗曠紪鍙蜂笉鑳戒负绌猴紒锛�");
-        }
-        if (Objects.isNull(params.getKopen_id())) {
-            return XSR.error("娴佹按鍙蜂笉鑳戒负绌猴紒锛�");
-        }
-        if (Objects.isNull(params.getCompany_id())) {
-            return XSR.error("鍏徃ID涓嶈兘涓虹┖锛侊紒");
-        }
+        pubOrderParams.forEach(params -> {
+            // 鏍¢獙鍙傛暟
+            if (Objects.isNull(params.getDispatch_no())) {
+                throw new CoolException("娲惧伐鍗曠紪鍙蜂笉鑳戒负绌猴紒锛�");
+            }
+            if (Objects.isNull(params.getKopen_id())) {
+                throw new CoolException("娴佹按鍙蜂笉鑳戒负绌猴紒锛�");
+            }
+            if (Objects.isNull(params.getCompany_id())) {
+                throw new CoolException("鍏徃ID涓嶈兘涓虹┖锛侊紒");
+            }
 
-        addOrUpdateOrders(params, "add");
+            addOrUpdateOrders(params, "add");
+        });
 
         return XSR.ok("澶囪揣鎸囩ず娲惧伐鍗曚笅鍙戞垚鍔燂紒锛�");
     }
@@ -272,7 +277,7 @@
         OrderParams orderParams = JSONObject.parseObject(JSONObject.toJSONString(params), OrderParams.class);
         // Order order = orderService.selectOne(new
         // EntityWrapper<Order>().eq("order_no", orderParams.getDispatch_no()));
-        Order order = new Order();
+        Order order = null;
         if (OrderType.ORDER_IN.type.equals(OrderWkType.getTypeVal(params.getType()))) {
             // 鍏ュ簱
             order = orderService.selectOne(new EntityWrapper<Order>().eq("order_no",
@@ -291,7 +296,6 @@
             }
         }
         // 鍑哄簱
-
         if (type.equals("add") && !Objects.isNull(order)) {
             throw new CoolException("鍗曟嵁宸插瓨鍦�, 涓嶅彲閲嶅娣诲姞锛侊紒");
         }
@@ -354,6 +358,7 @@
         newOrder.setUuid(generateUUID(params));
         // 娴佹按鍙凤紙鍞竴锛�
         newOrder.setDefNumber(params.getKopen_id());
+        newOrder.setTargetLocation(params.getTarget_location());
         // 绠卞彿
         newOrder.setItemName(params.getPm_tktid());
         newOrder.setSettle(OrderSettle.ORDER_SETTLE_HOLDING.type);
@@ -415,50 +420,50 @@
     /**
      * 澶囪揣鍗曚笅鍙�
      *
-     * @param params
+     * @param stockUpParams
      * @return com.core.common.R
      * @author Ryan
      * @date 2025/11/24 15:40
      */
     @Override
-    public XSR getOutDetails(StockUpOrderParams params) {
-        if (Objects.isNull(params)) {
+    public XSR getOutDetails(List<StockUpOrderParams> stockUpParams) {
+        if (Objects.isNull(stockUpParams)) {
             return XSR.error("鍙傛暟涓嶈兘涓虹┖锛侊紒");
         }
-        // 鏍¢獙鍙傛暟
-        if (Objects.isNull(params.getDispatch_no())) {
-            return XSR.error("娲惧伐鍗曠紪鍙蜂笉鑳戒负绌猴紒锛�");
-        }
-        if (Objects.isNull(params.getKopen_id())) {
-            return XSR.error("娴佹按鍙蜂笉鑳戒负绌猴紒锛�");
-        }
-        if (Objects.isNull(params.getCompany_id())) {
-            return XSR.error("鍏徃ID涓嶈兘涓虹┖锛侊紒");
-        }
-        if (Objects.isNull(params.getDetails()) || params.getDetails().isEmpty()) {
-            return XSR.error("璁㈠崟鏄庣粏涓嶈兘涓虹┖锛侊紒");
-        }
-
-        List<OrderItemsParam> items = new ArrayList<>();
-        if (params.getDetails() != null) {
-            for (OutOrderParams detail : params.getDetails()) {
-                if (detail.getPartList() != null) {
-                    items.addAll(detail.getPartList());
+        stockUpParams.forEach(params -> {
+            if (Objects.isNull(params.getDispatch_no())) {
+                throw new CoolException("娲惧伐鍗曠紪鍙蜂笉鑳戒负绌猴紒锛�");
+            }
+            if (Objects.isNull(params.getKopen_id())) {
+                throw new CoolException("娴佹按鍙蜂笉鑳戒负绌猴紒锛�");
+            }
+            if (Objects.isNull(params.getCompany_id())) {
+                throw new CoolException("鍏徃ID涓嶈兘涓虹┖锛侊紒");
+            }
+            if (Objects.isNull(params.getDetails()) || params.getDetails().isEmpty()) {
+                throw new CoolException("璁㈠崟鏄庣粏涓嶈兘涓虹┖锛侊紒");
+            }
+            List<OrderItemsParam> items = new ArrayList<>();
+            if (params.getDetails() != null) {
+                for (OutOrderParams detail : params.getDetails()) {
+                    if (detail.getPartList() != null) {
+                        items.addAll(detail.getPartList());
+                    }
                 }
             }
-        }
 
-        params.getDetails().forEach(item -> {
-            PubOrderParams pubOrderParams = new PubOrderParams();
-            BeanUtils.copyProperties(params, pubOrderParams);
-            pubOrderParams.setType(item.getType())
-                    .setPick_no(item.getPick_no())
-                    .setCus_address(item.getCus_address())
-                    .setOrder_no(item.getOrder_no())
-                    .setUpdate_time(params.getUpdate_time())
-                    .setCus_id(item.getCus_id());
-            pubOrderParams.setDetails(item.getPartList());
-            addOrUpdateOrders(pubOrderParams, "add");
+            params.getDetails().forEach(item -> {
+                PubOrderParams pubOrderParams = new PubOrderParams();
+                BeanUtils.copyProperties(params, pubOrderParams);
+                pubOrderParams.setType(item.getType())
+                        .setPick_no(item.getPick_no())
+                        .setCus_address(item.getCus_address())
+                        .setOrder_no(item.getOrder_no())
+                        .setUpdate_time(params.getUpdate_time())
+                        .setCus_id(item.getCus_id());
+                pubOrderParams.setDetails(item.getPartList());
+                addOrUpdateOrders(pubOrderParams, "add");
+            });
         });
 
         return XSR.ok("澶囪揣鍗曚笅鍙戞垚鍔燂紒锛�");

--
Gitblit v1.9.1