From cbdf37567d53de40dfd51eba57aad3cf7095f4fe Mon Sep 17 00:00:00 2001
From: zjj <3272660260@qq.com>
Date: 星期二, 29 四月 2025 10:49:59 +0800
Subject: [PATCH] #

---
 rsf-server/src/main/java/com/vincent/rsf/server/manager/service/impl/OutStockServiceImpl.java |   15 +++++++++++++--
 1 files changed, 13 insertions(+), 2 deletions(-)

diff --git a/rsf-server/src/main/java/com/vincent/rsf/server/manager/service/impl/OutStockServiceImpl.java b/rsf-server/src/main/java/com/vincent/rsf/server/manager/service/impl/OutStockServiceImpl.java
index 17ea75b..ddc4991 100644
--- a/rsf-server/src/main/java/com/vincent/rsf/server/manager/service/impl/OutStockServiceImpl.java
+++ b/rsf-server/src/main/java/com/vincent/rsf/server/manager/service/impl/OutStockServiceImpl.java
@@ -12,7 +12,7 @@
 import com.vincent.rsf.server.manager.enums.WaveExceStatus;
 import com.vincent.rsf.server.manager.mapper.AsnOrderMapper;
 import com.vincent.rsf.server.manager.service.*;
-import com.vincent.rsf.server.manager.utils.GroupMergeUtil;
+import com.vincent.rsf.server.manager.utils.OptimalAlgorithmUtil;
 import com.vincent.rsf.server.system.constant.SerialRuleCode;
 import com.vincent.rsf.server.system.utils.SerialRuleUtils;
 import org.apache.commons.lang3.StringUtils;
@@ -290,7 +290,18 @@
             throw new CoolException("涓诲崟淇敼澶辫触锛侊紒");
         }
 
+        for (int i = 0; i < orderItems.size(); i++) {
+            orderItems.get(i).setWorkQty(orderItems.get(i).getAnfme());
+        }
+
+        if (!asnOrderItemService.saveOrUpdateBatch(orderItems)) {
+            throw new CoolException("鍑哄簱鍗曟墽琛屾暟閲忎慨鏀瑰け璐ワ紒锛�");
+        }
+
+        double sum2 = orderItems.stream().mapToDouble(AsnOrderItem::getWorkQty).sum();
         if (!this.update(new LambdaUpdateWrapper<AsnOrder>()
+                .set(AsnOrder::getWaveId, wave.getId())
+                        .set(AsnOrder::getWorkQty, sum2)
                 .set(AsnOrder::getExceStatus, AsnExceStatus.OUT_STOCK_STATUS_TASK_WAVE.val)
                 .in(AsnOrder::getId, ids))) {
             throw new CoolException("鎵ц鐘舵�佷慨鏀逛慨鏀瑰け璐ワ紒锛�");
@@ -321,7 +332,7 @@
                     .setWaveCode(wave.getCode());
             items.add(item);
         });
-        List<WaveItem> waveItems = GroupMergeUtil.groupAndMerge(items,
+        List<WaveItem> waveItems = OptimalAlgorithmUtil.groupAndMerge(items,
                 (p1, p2) -> new WaveItem(
                         p1.getWaveId(),
                         p1.getWaveCode(),

--
Gitblit v1.9.1