From 7fc948e6ddc958a2c7379b8eb3b240f77350ce4b Mon Sep 17 00:00:00 2001
From: cy <1664593601@qq.com>
Date: 星期六, 09 十二月 2023 11:02:42 +0800
Subject: [PATCH] feat: 报废后台账不对；出库后预警
---
consum-base/src/main/java/com/consum/base/service/impl/LWhFormTransferServiceImpl.java | 95 +++++++++++++++++++++++++----------------------
1 files changed, 50 insertions(+), 45 deletions(-)
diff --git a/consum-base/src/main/java/com/consum/base/service/impl/LWhFormTransferServiceImpl.java b/consum-base/src/main/java/com/consum/base/service/impl/LWhFormTransferServiceImpl.java
index 8bd2708..c333fa9 100644
--- a/consum-base/src/main/java/com/consum/base/service/impl/LWhFormTransferServiceImpl.java
+++ b/consum-base/src/main/java/com/consum/base/service/impl/LWhFormTransferServiceImpl.java
@@ -5,7 +5,6 @@
import java.util.List;
import java.util.Map;
import java.util.Objects;
-import java.util.Optional;
import java.util.stream.Collectors;
import org.apache.commons.compress.utils.Lists;
@@ -18,6 +17,7 @@
import com.consum.base.core.CodeGeneratorEnum;
import com.consum.base.core.CodeGeneratorService;
import com.consum.base.core.type.CategoryType;
+import com.consum.base.core.type.TransferBusinessType;
import com.consum.base.core.utils.CurrencyUtil;
import com.consum.base.core.utils.IdUtil;
import com.consum.base.core.utils.MapUtils;
@@ -99,23 +99,20 @@
lWhFormTransfer.setId(lWhFormTransferId);
Integer businessType = param.getTransferBusinessType();
- // 鍗曟嵁绫诲瀷銆�0浠撳簱璋冩嫧锛�1閮ㄩ棬鍒嗗彂锛�2閮ㄩ棬鐗╁搧鍥為��
- // TODO 鏋氫妇瀛楀吀
+ // 鍗曟嵁绫诲瀷銆�0浠撳簱璋冩嫧锛�1閮ㄩ棬鍒嗗彂
lWhFormTransfer.setBusinessType(businessType);
CodeGeneratorEnum codeGeneratorEnum = null;
- if (businessType == 0) {
+ if (businessType == TransferBusinessType.STOCK_TRANSFER.getValue()) {
codeGeneratorEnum = CodeGeneratorEnum.Transfer;
- } else if (businessType == 1) {
+ } else if (businessType == TransferBusinessType.DEPARTMENT_PROCURE.getValue()) {
codeGeneratorEnum = CodeGeneratorEnum.Distribute;
- } else if (businessType == 2) {
- codeGeneratorEnum = CodeGeneratorEnum.GOBACK;
}
lWhFormTransfer.setBusinessFormCode(codeGeneratorService.createBusinessFormCode(codeGeneratorEnum));
Long warehouseId = param.getInWarehouseId();
// 璋冩嫧绫诲瀷鍗曟嵁
- if (businessType == 0) {
+ if (businessType == TransferBusinessType.STOCK_TRANSFER.getValue()) {
// 鍏ュ簱浠撳簱涓哄綋鍓嶇敤鎴风殑榛樿浠撳簱
String tenantId = sysInfo.getTenantId();
String tenantName = sysInfo.getTenantName();
@@ -130,42 +127,40 @@
lWhFormTransfer.setInAgencyName(tenantName);
}
// 褰撲笟鍔＄被鍨嬩负閮ㄩ棬鍒嗗彂鏃� 娣诲姞閮ㄩ棬鍒嗗彂璁板綍鍜屼娇鐢ㄤ汉
- if (businessType == 1) {
+ if (businessType == TransferBusinessType.DEPARTMENT_PROCURE.getValue()) {
// 閮ㄩ棬鍒嗗彂绫诲瀷 鍑哄簱浠撳簱绫诲瀷0鏈烘瀯1閮ㄩ棬
// 浠庡綋鍓嶇櫥褰曞簱绠′汉浠庡簱涓嚭搴擄紝鍏ュ埌鎵�閫夐儴闂ㄧ殑涓�
// 鏌ヨ搴撶鍛樹俊鎭拰鐩稿叧浠撳簱
- Long id = sysInfo.getId();
+ Long sysUserId = sysInfo.getSysUserId();
BaseWarehouseManager manager = new BaseWarehouseManager();
- manager.setManagerId(id);
+ manager.setManagerId(sysUserId);
List<BaseWarehouseManager> managerList = baseWarehouseManagerService.select(manager);
if (CollectionUtils.isEmpty(managerList)) {
log.error("璇ョ敤鎴蜂笉鏄簱绠″憳");
throw new Exception("璇ョ敤鎴蜂笉鏄簱绠″憳");
}
- Optional<BaseWarehouseManager> first = managerList.stream().findFirst();
- if (first.isPresent()) {
- BaseWarehouseManager baseWarehouseManager = first.get();
- Long baseWarehouseId = baseWarehouseManager.getBaseWarehouseId();
- BaseWarehouse baseWarehouse = new BaseWarehouse();
- baseWarehouse.setId(baseWarehouseId);
- BaseWarehouse warehouse = baseWarehouseService.get(baseWarehouse);
+ BaseWarehouseManager baseWarehouseManager = managerList.stream().findFirst().orElse(null);
+ Long baseWarehouseId = baseWarehouseManager.getBaseWarehouseId();
+ BaseWarehouse baseWarehouse = new BaseWarehouse();
+ baseWarehouse.setId(baseWarehouseId);
+ BaseWarehouse warehouse = baseWarehouseService.get(baseWarehouse);
- lWhFormTransfer.setInWarehouseType(1);
- lWhFormTransfer.setInWarehouseId(param.getDepartmentId());
- lWhFormTransfer.setInWarehouseName(param.getDepartmentName());
- lWhFormTransfer.setInOperatorName(param.getOperatorName());
- lWhFormTransfer.setInTime(param.getCreateTime());
+ lWhFormTransfer.setInWarehouseType(1);
+ lWhFormTransfer.setInWarehouseId(param.getDepartmentId());
+ lWhFormTransfer.setInWarehouseName(param.getDepartmentName());
+ lWhFormTransfer.setInOperatorName(param.getOperatorName());
+ lWhFormTransfer.setInTime(param.getCreateTime());
- lWhFormTransfer.setOutWarehouseType(0);
- lWhFormTransfer.setOutWarehouseId(warehouse.getId());
- lWhFormTransfer.setOutWarehouseName(warehouse.getWarehouseName());
+ lWhFormTransfer.setOutWarehouseType(0);
+ lWhFormTransfer.setOutWarehouseId(warehouse.getId());
+ lWhFormTransfer.setOutWarehouseName(warehouse.getWarehouseName());
- lWhFormTransfer.setOutOperatorId(sysInfo.getId());
- lWhFormTransfer.setOutOperatorName(sysInfo.getUserName());
- lWhFormTransfer.setOutputTime(param.getCreateTime());
- lWhFormTransfer.setTel(param.getTel());
- }
+ lWhFormTransfer.setOutOperatorId(sysInfo.getId());
+ lWhFormTransfer.setOutOperatorName(sysInfo.getUserName());
+ lWhFormTransfer.setOutputTime(param.getCreateTime());
+ lWhFormTransfer.setTel(param.getTel());
+
}
// 鏍规嵁鏈烘瀯id鏌ヨ璋冩嫧鏈烘瀯
@@ -190,6 +185,23 @@
// 2.鏂板鐗╁搧鍨嬪彿璁板綍
List<LWhFormTransferGoodsInfoParam> transferGoods = param.getTransferGoods();
List<LWhProcureModel> modelList = new ArrayList<>();
+
+ // 鍒ゆ柇娣诲姞涓�娆′娇鐢ㄤ汉璁板綍
+ List<LWhFormTransferGoodsInfoParam> recordType = transferGoods.stream()
+ .filter(
+ item -> businessType == TransferBusinessType.DEPARTMENT_PROCURE.getValue() && item.getModels().stream()
+ .anyMatch(model -> baseGoodsModelsService.queryGoodsModelInfo(model.getBaseGoodsModelsId()).stream()
+ .findFirst().orElse(null).get("type").equals(CategoryType.TYPE_A.getValue())))
+ .collect(Collectors.toList());
+ LWhProcureModelUserRecord lWhProcureModelUserRecord = new LWhProcureModelUserRecord();
+ if (!CollectionUtils.isEmpty(recordType)) {
+ lWhProcureModelUserRecord.setId(IdUtil.generateId());
+ lWhProcureModelUserRecord.setTransBusinessId(lWhFormTransferId);
+ lWhProcureModelUserRecord.setOperatorId(sysInfo.getId());
+ lWhProcureModelUserRecord.setOperatorName(sysInfo.getUserName());
+ lWhProcureModelUserRecord.setDealTime(DateUtils.getDateTimeNumber(System.currentTimeMillis()));
+ lWhProcureModelUserRecordService.insert(lWhProcureModelUserRecord);
+ }
for (LWhFormTransferGoodsInfoParam transferGoodsInfo : transferGoods) {
for (LWhTransferModelParam model : transferGoodsInfo.getModels()) {
LWhProcureModel lWhProcureModel = new LWhProcureModel();
@@ -197,13 +209,13 @@
// 璋冩嫧涓氬姟绫诲瀷杞崲鍒扮墿鍝佺被鍨�
// 鐗╁搧绫诲瀷 1 閲囪喘2 璋冩嫧 3鍑哄簱4閮ㄩ棬鍒嗗彂
Long baseGoodsModelsId = model.getBaseGoodsModelsId();
- if (businessType == 0) {
+ if (businessType == TransferBusinessType.STOCK_TRANSFER.getValue()) {
lWhProcureModel.setBusinessType(2);
// 鏍规嵁鐗╁搧鍨嬪彿鏌ヨ鐗╁搧搴撳瓨
int goodsNum = lWhGoodsService.queryGoodsModelNum(0, warehouseId, baseGoodsModelsId, 1, null);
lWhProcureModel.setWorehouseCount(goodsNum);
}
- if (businessType == 1) {
+ if (businessType == TransferBusinessType.DEPARTMENT_PROCURE.getValue()) {
lWhProcureModel.setBusinessType(4);
}
lWhProcureModel.setCounts(model.getCounts());
@@ -223,16 +235,8 @@
// 3.褰撲笟鍔＄被鍨嬩负閮ㄩ棬鍒嗗彂鏃� 娣诲姞閮ㄩ棬鍒嗗彂璁板綍鍜屼娇鐢ㄤ汉
// 鍗曟嵁绫诲瀷 1 閲囪喘2 璋冩嫧 3鍑哄簱4閮ㄩ棬鍒嗗彂
// 閮ㄩ棬鍒嗗彂绫诲瀷
- if (businessType == 1 && CategoryType.TYPE_A.getValue().equals(baseModelMap.get("type"))) {
- // TODO 閲嶅淇濆瓨
- LWhProcureModelUserRecord lWhProcureModelUserRecord = new LWhProcureModelUserRecord();
- lWhProcureModelUserRecord.setId(IdUtil.generateId());
- lWhProcureModelUserRecord.setTransBusinessId(lWhFormTransferId);
- lWhProcureModelUserRecord.setOperatorId(sysInfo.getId());
- lWhProcureModelUserRecord.setOperatorName(sysInfo.getUserName());
- lWhProcureModelUserRecord.setDealTime(DateUtils.getDateTimeNumber(System.currentTimeMillis()));
- lWhProcureModelUserRecordService.insert(lWhProcureModelUserRecord);
-
+ if (businessType == TransferBusinessType.DEPARTMENT_PROCURE.getValue()
+ && CategoryType.TYPE_A.getValue().equals(baseModelMap.get("type"))) {
List<LWhProcureModelUser> procureModelUserList = Lists.newArrayList();
for (LWhProcureModelUserParam lWhProcureModelUserParam : model.getProcureModelUserList()) {
LWhProcureModelUser lWhProcureModelUser = new LWhProcureModelUser();
@@ -385,7 +389,8 @@
// 閮ㄩ棬鍒嗗彂闇�瑕佹煡璇娇鐢ㄤ俊鎭�
Integer businessType = result.getBusinessType();
String type = goodsTemplateInfoVO.getType();
- if (businessType == 1 && CategoryType.TYPE_A.getValue().equals(type)) {
+ if (businessType == TransferBusinessType.DEPARTMENT_PROCURE.getValue()
+ && CategoryType.TYPE_A.getValue().equals(type)) {
Long procureModelId = goodsModelVO.getId();
LWhProcureModelUser lWhProcureModelUser = new LWhProcureModelUser();
@@ -593,7 +598,7 @@
+ " ft.OUT_OPERATOR_NAME,\n" + " ft.OUTPUT_TIME\n" + "FROM l_wh_form_transfer ft\n"
+ " LEFT JOIN l_wh_procure_model pm ON ft.ID = pm.BUSINESS_ID\n"
+ " LEFT JOIN base_goods_models bgm ON bgm.id = pm.BASE_GOODS_MODELS_ID\n"
- + " LEFT JOIN base_goods_template bgt ON bgt.id = bgm.GOODS_TEMPLATES_ID where 1=1 ");
+ + " LEFT JOIN base_goods_template bgt ON bgt.id = bgm.GOODS_TEMPLATES_ID where ft.BUSINESS_TYPE =0 ");
if (StringUtils.isNotEmpty(param.getBusinessFormCode())) {
sql.append("AND ft.BUSINESS_FORM_CODE = :businessFormCode ");
params.put("businessFormCode", param.getBusinessFormCode());
--
Gitblit v1.9.1