From ac1b67e3e56ce4c2d9406d66c4287f84882783be Mon Sep 17 00:00:00 2001
From: Tankaikai <tankaikai@aliyun.com>
Date: Thu, 10 Apr 2025 17:15:47 +0800
Subject: [PATCH] =?UTF-8?q?=E5=87=BA=E5=85=A5=E5=BA=93bug?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../product/service/impl/ConsStockFlowServiceImpl.java   | 9 ++++++---
 1 file changed, 6 insertions(+), 3 deletions(-)

diff --git a/cash-service/product-service/src/main/java/com/czg/service/product/service/impl/ConsStockFlowServiceImpl.java b/cash-service/product-service/src/main/java/com/czg/service/product/service/impl/ConsStockFlowServiceImpl.java
index 935a9d171..c75f2c7c8 100644
--- a/cash-service/product-service/src/main/java/com/czg/service/product/service/impl/ConsStockFlowServiceImpl.java
+++ b/cash-service/product-service/src/main/java/com/czg/service/product/service/impl/ConsStockFlowServiceImpl.java
@@ -5,7 +5,6 @@ import cn.hutool.core.bean.copier.CopyOptions;
 import cn.hutool.core.collection.CollUtil;
 import cn.hutool.core.thread.ThreadUtil;
 import cn.hutool.core.util.NumberUtil;
-import cn.hutool.core.util.ObjUtil;
 import cn.hutool.core.util.StrUtil;
 import com.alibaba.fastjson2.JSON;
 import com.czg.exception.CzgException;
@@ -98,7 +97,9 @@ public class ConsStockFlowServiceImpl extends ServiceImpl<ConsStockFlowMapper, C
             updateStockList.add(consInfo);
         }
         super.saveBatch(insertList);
-        updateStockList.parallelStream().forEach(consInfoMapper::update);
+        for (ConsInfo consInfo : updateStockList) {
+            consInfoMapper.update(consInfo);
+        }
     }
 
     @Override
@@ -131,7 +132,9 @@ public class ConsStockFlowServiceImpl extends ServiceImpl<ConsStockFlowMapper, C
             updateStockList.add(consInfo);
         }
         super.saveBatch(insertList);
-        updateStockList.parallelStream().forEach(consInfoMapper::update);
+        for (ConsInfo consInfo : updateStockList) {
+            consInfoMapper.update(consInfo);
+        }
     }
 
     @Override