From 3884e330379c96e7576ada6b7a988a84e8757886 Mon Sep 17 00:00:00 2001
From: futian.liu <liufutianyoo@163.com>
Date: 星期一, 18 十二月 2023 16:12:50 +0800
Subject: [PATCH] 修改查询库存的仓库参数

---
 consum-base/src/main/java/com/consum/base/core/service/LWhWarningCoreServiceImpl.java |   48 ++++++++++++++++++++++++++----------------------
 1 files changed, 26 insertions(+), 22 deletions(-)

diff --git a/consum-base/src/main/java/com/consum/base/core/service/LWhWarningCoreServiceImpl.java b/consum-base/src/main/java/com/consum/base/core/service/LWhWarningCoreServiceImpl.java
index a9e5089..c7e6333 100644
--- a/consum-base/src/main/java/com/consum/base/core/service/LWhWarningCoreServiceImpl.java
+++ b/consum-base/src/main/java/com/consum/base/core/service/LWhWarningCoreServiceImpl.java
@@ -1,6 +1,17 @@
 package com.consum.base.core.service;
 
-import cn.hutool.core.convert.Convert;
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Map;
+import java.util.stream.Collectors;
+
+import javax.annotation.Resource;
+
+import org.apache.commons.collections4.CollectionUtils;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Propagation;
+import org.springframework.transaction.annotation.Transactional;
+
 import com.consum.base.core.utils.IdUtil;
 import com.consum.base.service.BaseGoodsModelsService;
 import com.consum.base.service.BaseWarehouseService;
@@ -8,16 +19,8 @@
 import com.consum.model.po.BaseWarehouse;
 import com.consum.model.po.FinSysTenantUser;
 import com.consum.model.po.WhWarning;
-import java.util.ArrayList;
-import java.util.List;
-import java.util.Map;
-import java.util.stream.Collectors;
-import javax.annotation.Resource;
-import org.apache.commons.collections4.CollectionUtils;
-import org.springframework.stereotype.Service;
-import org.springframework.transaction.annotation.Propagation;
-import org.springframework.transaction.annotation.Transactional;
 
+import cn.hutool.core.convert.Convert;
 
 /**
  * @ClassName LWhWarningCoreServiceImpl
@@ -44,22 +47,21 @@
      * @param warehouseId
      * @param baseModelIdList
      */
-    public void updateKuCun(Short warehouseType, Long warehouseId, List<Long> baseModelIdList, FinSysTenantUser sysInfo, Long dealTime) {
+    public void updateKuCun(Short warehouseType, Long warehouseId, List<Long> baseModelIdList, FinSysTenantUser sysInfo,
+        Long dealTime) {
         if (baseModelIdList == null) {
             baseModelIdList = new ArrayList<>();
         }
         sysInfo = sysInfo == null ? new FinSysTenantUser() : sysInfo;
         // 鑾峰彇鍒拌揪鍒伴槇鍊肩殑鐗╁搧
-        List<Map<String, Object>> kuCunNotifyList = lWhWarningService.checkKuCun(warehouseType, warehouseId, baseModelIdList);
-        //
-//        log.info("娌℃湁杈惧埌闃堝�肩殑鐗╁搧");
+        List<Map<String, Object>> kuCunNotifyList =
+            lWhWarningService.checkKuCun(warehouseType, warehouseId, baseModelIdList);
+        // log.info("娌℃湁杈惧埌闃堝�肩殑鐗╁搧");
         if (CollectionUtils.isEmpty(kuCunNotifyList)) {
             kuCunNormalModel(warehouseType, warehouseId, baseModelIdList);
             return;
         }
-        List<Long> allChangModelList = baseModelIdList.stream()
-            .distinct()
-            .collect(Collectors.toList());
+        List<Long> allChangModelList = baseModelIdList.stream().distinct().collect(Collectors.toList());
         baseModelIdList = allChangModelList;
 
         // 灏嗘暟鎹彃鍏ュ簱瀛橀璀︺�怶H_WARNING銆�
@@ -87,7 +89,7 @@
             whWarning.setBaseGoodsTemplateId(Convert.toLong(modelInfo.get("goodsId")));
             whWarning.setBaseGoodsTemplateName(Convert.toStr(modelInfo.get("goodsName")));
             whWarning.setBaseGoodsModelsId(baseGoodsModelsId);
-            whWarning.setBaseGoodsModelsName((String) modelInfo.get("modelName"));
+            whWarning.setBaseGoodsModelsName((String)modelInfo.get("modelName"));
             whWarning.setGoodsType(2);
             whWarning.setWarningType(warningType);
             whWarning.setUpperLimit(upperLimit);
@@ -103,16 +105,17 @@
             warningList.add(whWarning);
         }
 
-        //淇敼浠ュ墠鐨勯璀︾姸鎬�
+        // 淇敼浠ュ墠鐨勯璀︾姸鎬�
         baseModelIdList.removeAll(kuCunNotifyModelIdList);
         kuCunNormalModel(warehouseType, warehouseId, baseModelIdList);
 
-        //鎵归噺鎻掑叆棰勮
+        // 鎵归噺鎻掑叆棰勮
         lWhWarningService.insertBatch(warningList);
 
     }
 
-    private String KU_CUN_NORMAL_MODEL = "update WH_WARNING set STATES=2 where WAREHOUSE_TYPE=? and BASE_WAREHOUSE_ID=?";
+    private String KU_CUN_NORMAL_MODEL =
+        "update WH_WARNING set STATES=2 where WAREHOUSE_TYPE=? and BASE_WAREHOUSE_ID=?";
 
     /**
      * @param warehouseType
@@ -130,7 +133,8 @@
 
         StringBuilder sql = new StringBuilder(KU_CUN_NORMAL_MODEL);
         if (!org.springframework.util.CollectionUtils.isEmpty(normalBaseModelIdList)) {
-            sql.append(" and BASE_GOODS_MODELS_ID in(").append(org.apache.commons.lang3.StringUtils.join(normalBaseModelIdList, ",")).append(")");
+            sql.append(" and BASE_GOODS_MODELS_ID in(")
+                .append(org.apache.commons.lang3.StringUtils.join(normalBaseModelIdList, ",")).append(")");
         }
         return lWhWarningService.update(sql.toString(), params.toArray());
     }

--
Gitblit v1.9.1