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