From 1822fb1b8dc476bdb3270d0dd0cd79cbbc02ae2c Mon Sep 17 00:00:00 2001 From: 石广澎 <shiguangpeng@163.com> Date: 星期二, 12 十二月 2023 16:58:25 +0800 Subject: [PATCH] feat: 物品规格管理页面 --- consum-base/src/main/java/com/consum/base/service/impl/LWhFormTransferServiceImpl.java | 133 ++++++++++++++++++++++++++----------------- 1 files changed, 80 insertions(+), 53 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..0d2a6c6 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 @@ -1,11 +1,12 @@ package com.consum.base.service.impl; +import static com.walker.db.Sorts.DESC; + import java.util.ArrayList; import java.util.HashMap; 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 +19,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; @@ -35,7 +37,7 @@ import com.consum.base.pojo.response.LWHFromTransferExtendVO; import com.consum.base.service.BaseWarehouseManagerService; import com.consum.base.service.BaseWarehouseService; -import com.consum.base.service.FinSysTenantServiceImpl; +import com.consum.base.service.FinSysTenantService; import com.consum.base.service.LWhFormTransferService; import com.consum.base.service.LWhGoodsService; import com.consum.base.service.LWhProcureModelService; @@ -67,7 +69,7 @@ @Autowired private CodeGeneratorService codeGeneratorService; @Autowired - private FinSysTenantServiceImpl finSysTenantService; + private FinSysTenantService finSysTenantService; @Autowired private LWhGoodsService lWhGoodsService; @Autowired @@ -99,23 +101,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 +129,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 +187,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 +211,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 +237,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(); @@ -289,6 +295,11 @@ paramts.put("goodsTemplateName", StringUtils.CHAR_PERCENT + param.getGoodsTemplateName() + StringUtils.CHAR_PERCENT); } + // 鐗╁搧id + if (param.getGoodsTemplateId() != null) { + sql.append("AND bgt.id = :goodsTemplateId "); + paramts.put("goodsTemplateId", param.getGoodsTemplateId()); + } // 璋冩嫧鏈烘瀯 if (param.getOutAgencyId() != null) { sql.append(" and OUT_AGENCY_ID = :OUT_AGENCY_ID "); @@ -328,9 +339,9 @@ paramts.put("inTimeEnd", param.getEndTime() * 1000000 + 240000); } // 鍒嗗彂閮ㄩ棬 - if (param.getInWarehouseId() != null) { + if (param.getDepartmentId() != null) { sql.append("and ft.IN_WAREHOUSE_ID = :inWarehouseId "); - paramts.put("inWarehouseId", param.getInWarehouseId()); + paramts.put("inWarehouseId", param.getDepartmentId()); } sql.append(" ORDER BY ft.CREATE_TIME DESC"); @@ -385,11 +396,18 @@ // 閮ㄩ棬鍒嗗彂闇�瑕佹煡璇娇鐢ㄤ俊鎭� 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(); + LWhProcureModelUserRecord lWhProcureModelUserRecord = new LWhProcureModelUserRecord(); + lWhProcureModelUserRecord.setTransBusinessId(id); + List<LWhProcureModelUserRecord> select = lWhProcureModelUserRecordService + .select(lWhProcureModelUserRecord, DESC().setField("DEAL_TIME")); + LWhProcureModelUserRecord record = select.stream().findFirst().orElse(null); LWhProcureModelUser lWhProcureModelUser = new LWhProcureModelUser(); lWhProcureModelUser.setWhProcureModelId(procureModelId); + lWhProcureModelUser.setProcureModelUserRecordId(record.getId()); List<LWhProcureModelUser> procureModelUserList = this.lWhProcureModelUserService.select(lWhProcureModelUser); @@ -546,6 +564,11 @@ paramts.put("goodsName", StringUtils.CHAR_PERCENT + transferQry.getGoodsTemplateName() + StringUtils.CHAR_PERCENT); } + // 鐗╁搧id + if (transferQry.getGoodsTemplateId() != null) { + sql.append("AND bgt.id =:goodsTemplateId "); + paramts.put("goodsTemplateId", transferQry.getGoodsTemplateId()); + } // 瑙勬牸鍨嬪彿 if (transferQry.getBaseGoodsModelsId() != null) { sql.append("AND bgm.id =:goodsModelId "); @@ -553,13 +576,13 @@ } // 璋冩嫧鏈烘瀯 if (transferQry.getOutAgencyId() != null) { - sql.append("AND OUT_AGENCY_ID = :OUT_AGENCY_ID "); - paramts.put("OUT_AGENCY_ID", transferQry.getOutAgencyId()); + sql.append("AND OUT_AGENCY_ID like :OUT_AGENCY_ID "); + paramts.put("OUT_AGENCY_ID", transferQry.getOutAgencyId() + StringUtils.CHAR_PERCENT); } // 鍒嗗彂閮ㄩ棬 - if (transferQry.getInWarehouseId() != null) { + if (transferQry.getDepartmentId() != null) { sql.append("and ft.IN_WAREHOUSE_ID = :inWarehouseId "); - paramts.put("inWarehouseId", transferQry.getInWarehouseId()); + paramts.put("inWarehouseId", transferQry.getDepartmentId()); } // 鍒涘缓浜� if (StringUtils.isNotEmpty(transferQry.getOperatorName())) { @@ -593,7 +616,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()); @@ -602,6 +625,10 @@ sql.append("AND bgt.GOODS_NAME like :goodsName "); params.put("goodsName", StringUtils.CHAR_PERCENT + param.getGoodsTemplateName() + StringUtils.CHAR_PERCENT); } + if (param.getGoodsTemplateId() != null) { + sql.append("AND bgt.id = :goodsTemplateId "); + params.put("goodsTemplateId", param.getGoodsTemplateId()); + } if (param.getBaseGoodsModelsId() != null) { sql.append("AND bgm.id = :goodsModelId "); params.put("goodsModelId", param.getBaseGoodsModelsId()); -- Gitblit v1.9.1