From 3f69b4dfc585c4dfbc3c07a6acf5cdd838033636 Mon Sep 17 00:00:00 2001
From: liuguocan <527956374@qq.com>
Date: 星期二, 28 十一月 2023 14:45:49 +0800
Subject: [PATCH] Merge remote-tracking branch 'origin/master'

---
 consum-base/src/main/java/com/consum/base/service/LWhFormTransferCoreService.java |   34 ++++++++++++++++++++--------------
 1 files changed, 20 insertions(+), 14 deletions(-)

diff --git a/consum-base/src/main/java/com/consum/base/service/LWhFormTransferCoreService.java b/consum-base/src/main/java/com/consum/base/service/LWhFormTransferCoreService.java
index 7c0bff1..c5573dc 100644
--- a/consum-base/src/main/java/com/consum/base/service/LWhFormTransferCoreService.java
+++ b/consum-base/src/main/java/com/consum/base/service/LWhFormTransferCoreService.java
@@ -1,27 +1,26 @@
 package com.consum.base.service;
 
+import cn.hutool.core.convert.Convert;
 import com.consum.base.core.WhBusinessEnum;
+import com.consum.base.core.service.LWhWarningCoreServiceImpl;
 import com.consum.base.core.utils.LockManage;
-import com.consum.model.po.LGoodsUserRecord;
-import com.consum.model.po.LWarehouseFlow;
-import com.consum.model.po.LWhFormTransfer;
-import com.consum.model.po.LWhGoodsRecord;
-import com.consum.model.po.LWhGoodsRecordDetails;
-import com.consum.model.po.LWhProcureModelUser;
+import com.consum.model.po.*;
 import com.iplatform.model.po.S_user_core;
 import com.walker.infrastructure.utils.CollectionUtils;
 import com.walker.infrastructure.utils.DateUtils;
 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 org.springframework.transaction.interceptor.TransactionAspectSupport;
+
+import javax.annotation.Resource;
 import java.util.ArrayList;
 import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
 import java.util.stream.Collectors;
-import javax.annotation.Resource;
-import lombok.extern.slf4j.Slf4j;
-import org.springframework.stereotype.Service;
-import org.springframework.transaction.annotation.Transactional;
-import org.springframework.transaction.interceptor.TransactionAspectSupport;
 
 /**
  * @ClassName LWhFormTransferCoreService
@@ -31,7 +30,7 @@
  **/
 @Service
 @Slf4j
-@Transactional(rollbackFor = Exception.class)
+@Transactional(rollbackFor = Exception.class, propagation = Propagation.REQUIRED)
 public class LWhFormTransferCoreService {
 
     @Resource
@@ -52,7 +51,8 @@
     private LWhGoodsRecordDetailsService lWhGoodsRecordDetailsService;
     @Resource
     private LGoodsUserRecordServiceImpl lGoodsUserRecordService;
-
+    @Resource
+    private LWhWarningCoreServiceImpl lWhWarningCoreService;
 
     /**
      * 鎵ц璋冩嫧鍑哄簱鎿嶄綔
@@ -103,6 +103,7 @@
         lWhFormTransfer.setOutputTime(dealTime);
         lWhFormTransfer.setOutWarehouseFlowId(lWarehouseFlowId);
         lWhFormTransferService.update(lWhFormTransfer);
+
         log.info("璋冩嫧鍗曪細{} 鍑哄簱瀹屾垚", whFormTransferId);
         return;
 
@@ -163,12 +164,14 @@
         inwarehouseFlow.setDealTime(dealTime);
         lWarehouseFlowService.insert(inwarehouseFlow);
 
+        ArrayList<Long> allChangModelList = new ArrayList<>();
         LWhGoodsRecord lWhGoodsRecord = new LWhGoodsRecord();
         lWhGoodsRecord.setWarehouseFlowId(outWarehouseFlowId);
         List<LWhGoodsRecord> whGoodsRecordList = lWhGoodsRecordService.select(lWhGoodsRecord);
         for (LWhGoodsRecord whGoodsRecord : whGoodsRecordList) {
             Long oldRecordId = whGoodsRecord.getId();
             Long baseGoodsModelsId = whGoodsRecord.getBaseGoodsModelsId();
+            allChangModelList.add(baseGoodsModelsId);
             whGoodsRecord.setId(NumberGenerator.getLongSequenceNumber());
             whGoodsRecord.setWarehouseType(inWarehouseType);
             whGoodsRecord.setWarehouseId(inWarehouseId);
@@ -180,7 +183,7 @@
                 List<Long> outGoodsIds = getGoodsidByFlowId(outWarehouseFlowId, oldRecordId);
                 // 搴撳瓨鐗╁搧璇︽儏锛圠_WH_GOODS锛変腑 鐘舵�佽缃负1
                 lWhGoodsService.modGoodsTransfering(outGoodsIds, inWarehouseType, inWarehouseId, inWarehouseName, goodsStatus);
-                if (businessType == 1){
+                if (businessType == 1) {
                     // 1閮ㄩ棬鍒嗗彂 姝ゆ椂瑕佸線 鐗╁搧浣跨敤璁板綍銆怢_GOODS_USER_RECORD銆戞坊鍔犳暟鎹�
                     //鏌ヨ閮ㄩ棬鍒嗗彂浣跨敤浜�
                     LWhProcureModelUser lWhProcureModelUser = new LWhProcureModelUser();
@@ -257,6 +260,9 @@
         lWhFormTransfer.setInOperatorName(nickName);
         lWhFormTransfer.setInTime(dealTime);
         lWhFormTransferService.update(lWhFormTransfer);
+
+        //褰撳簱瀛樺彉鍔ㄦ椂璋冪敤璇ユ柟娉�
+        lWhWarningCoreService.updateKuCun(Convert.toShort(inWarehouseType, (short) 0), inWarehouseId, allChangModelList, null, dealTime);
         log.info("璋冩嫧鍗曪細{} 鍏ュ簱瀹屾垚", whFormTransferId);
         return;
     }

--
Gitblit v1.9.1