From 870a9499eb65de0031ef8e8f70607e5dfb64b806 Mon Sep 17 00:00:00 2001
From: cy <1664593601@qq.com>
Date: 星期四, 30 十一月 2023 09:30:18 +0800
Subject: [PATCH] Merge remote-tracking branch 'origin/master'

---
 consum-base/src/main/java/com/consum/base/service/LWhFormProcureCoreService.java |   23 ++++++++++++++++++++---
 1 files changed, 20 insertions(+), 3 deletions(-)

diff --git a/consum-base/src/main/java/com/consum/base/service/LWhFormProcureCoreService.java b/consum-base/src/main/java/com/consum/base/service/LWhFormProcureCoreService.java
index adb9a3e..c06992e 100644
--- a/consum-base/src/main/java/com/consum/base/service/LWhFormProcureCoreService.java
+++ b/consum-base/src/main/java/com/consum/base/service/LWhFormProcureCoreService.java
@@ -1,6 +1,7 @@
 package com.consum.base.service;
 
 import com.consum.base.core.WhBusinessEnum;
+import com.consum.base.core.service.LWhWarningCoreServiceImpl;
 import com.consum.model.po.LWarehouseFlow;
 import com.consum.model.po.LWhFormProcure;
 import com.consum.model.po.LWhProcureModel;
@@ -9,26 +10,31 @@
 import com.walker.infrastructure.utils.NumberGenerator;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Propagation;
 import org.springframework.transaction.annotation.Transactional;
 
 import javax.annotation.Resource;
 import java.util.List;
+import java.util.stream.Collectors;
 
 /**
  * @ClassName LWhFormProcureCoreService
-
  * @Date 2023/10/26
  * @Description
  * @Version 1.0
  **/
 @Service
 @Slf4j
+@Transactional(propagation= Propagation.REQUIRED)
 public class LWhFormProcureCoreService {
     @Resource
     private LWhProcureModelService lWhProcureModelService;
 
     @Resource
     private LWhFormProcureService lWhFormProcureService;
+
+    @Resource
+    private LWhWarningCoreServiceImpl lWhWarningCoreService;
 
     @Resource
     private LWarehouseFlowCoreService lWarehouseFlowService;
@@ -56,11 +62,12 @@
 
         List<LWhProcureModel> goodsModelNum = lWhProcureModelService.getModelByForm(WhBusinessEnum.CAIGOU, whFormProcureId);
         // 娴佹按璁板綍鎬昏〃ID
+        Long warehouseId = lWhFormProcure.getWarehouseId();
         long lWarehouseFlowId = NumberGenerator.getLongSequenceNumberNano();
         LWarehouseFlow warehouseFlow = new LWarehouseFlow();
         warehouseFlow.setId(lWarehouseFlowId);
         warehouseFlow.setWarehouseType(0);
-        warehouseFlow.setWarehouseId(lWhFormProcure.getWarehouseId());
+        warehouseFlow.setWarehouseId(warehouseId);
         warehouseFlow.setWarehouseName(lWhFormProcure.getWarehouseName());
         warehouseFlow.setThisType(1);
         warehouseFlow.setBusinessType(WhBusinessEnum.CAIGOU.getValue() + 0);
@@ -79,8 +86,18 @@
             whFormProcure.setIncomeTime(dealTime);
             lWhFormProcureService.update(whFormProcure);
         }
+
+
+        // 鎻愬彇baseGoodsModelsId骞舵斁鍏ユ柊鐨凩ist涓�
+        List<Long> allChangModelList = goodsModelNum.stream()
+                .map(LWhProcureModel::getBaseGoodsModelsId)
+                .distinct()
+                .collect(Collectors.toList());
+        //褰撳簱瀛樺彉鍔ㄦ椂璋冪敤璇ユ柟娉�
+        lWhWarningCoreService.updateKuCun((short) 0, warehouseId, allChangModelList, null, dealTime);
+
         log.info("鍏ュ簱鍗曪細{} 鍏ュ簱瀹屾垚", whFormProcureId);
         return null;
-
     }
+
 }

--
Gitblit v1.9.1