From c3324e194441e601d474601bd0f7ac62c120c486 Mon Sep 17 00:00:00 2001 From: futian.liu <liufutianyoo@163.com> Date: 星期一, 13 十一月 2023 16:17:28 +0800 Subject: [PATCH] 出库fix --- consum-base/src/main/java/com/consum/base/service/LWhFormOutputServiceImpl.java | 80 +++++++++++++++++++++++++--------------- 1 files changed, 50 insertions(+), 30 deletions(-) diff --git a/consum-base/src/main/java/com/consum/base/service/LWhFormOutputServiceImpl.java b/consum-base/src/main/java/com/consum/base/service/LWhFormOutputServiceImpl.java index 7be440f..dd97fbc 100644 --- a/consum-base/src/main/java/com/consum/base/service/LWhFormOutputServiceImpl.java +++ b/consum-base/src/main/java/com/consum/base/service/LWhFormOutputServiceImpl.java @@ -3,24 +3,27 @@ import com.consum.base.core.CodeGeneratorEnum; import com.consum.base.core.CodeGeneratorService; import com.consum.base.core.param.BaseWarehouseParam1; +import com.consum.base.core.utils.IdUtil; +import com.consum.base.pojo.LWFormsOutputGoodsModelParam; +import com.consum.base.pojo.LWFormsOutputGoodsParam; +import com.consum.base.pojo.LWhFormOutputInsertParam; import com.consum.base.pojo.LWhFormOutputParam; -import com.consum.base.pojo.LWhProcureModelParams; -import com.consum.base.util.IdUtil; -import com.consum.model.po.*; +import com.consum.model.po.BaseGoodsModels; +import com.consum.model.po.BaseWarehouse; +import com.consum.model.po.FinSysTenantUser; +import com.consum.model.po.LWhFormOutput; +import com.consum.model.po.LWhProcureModel; import com.iplatform.model.po.S_user_core; import com.walker.db.page.GenericPager; -import com.walker.infrastructure.utils.DateUtils; import com.walker.infrastructure.utils.StringUtils; import com.walker.jdbc.service.BaseServiceImpl; +import java.util.ArrayList; +import java.util.HashMap; +import java.util.List; import lombok.extern.slf4j.Slf4j; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import org.springframework.transaction.interceptor.TransactionAspectSupport; -import org.springframework.util.CollectionUtils; - -import java.util.ArrayList; -import java.util.HashMap; -import java.util.List; /** * @Description 鍑哄簱鍗� @@ -41,9 +44,10 @@ private LWhProcureModelService lWhProcureModelService; @Autowired private LWhFormOutputCoreService lWhFormOutputCoreService; + @Autowired + private BaseGoodsModelsServiceImpl baseGoodsModelsService; private static String QUERY_FORM_OUTPUT_LIST = "SELECT * FROM l_wh_form_output WHERE 1 = 1"; - // /** // * @Description 鏂板鍑哄簱鍗� @@ -146,7 +150,7 @@ * @Author 鍗㈠簡闃� * @Date 2023/10/27 */ - public int add(LWhFormOutputParam param, S_user_core currentUser, FinSysTenantUser sysInfo) { + public int add(LWhFormOutputInsertParam param, S_user_core currentUser, FinSysTenantUser sysInfo) { //1.鏂板鍑哄簱鍗曡褰� LWhFormOutput lWhFormOutput = new LWhFormOutput(); //鍑哄叆搴搃d @@ -168,8 +172,7 @@ lWhFormOutput.setAgencyName(sysInfo.getTenantName()); lWhFormOutput.setOperatorId(sysInfo.getId()); lWhFormOutput.setOperatorName(sysInfo.getUserName()); - long dateTimeNumber = DateUtils.getDateTimeNumber(System.currentTimeMillis()); - lWhFormOutput.setDealTime(dateTimeNumber); + lWhFormOutput.setDealTime(param.getDealTime()); lWhFormOutput.setStates(1); int flag1 = this.insert(lWhFormOutput); if (flag1 == 0) { @@ -177,20 +180,27 @@ return 0; } //2.鏂板鐗╁搧鍨嬪彿璁板綍 - List<LWhProcureModelParams> models = param.getModels(); + List<LWFormsOutputGoodsParam> goodsList = param.getGoods(); List<LWhProcureModel> modelList = new ArrayList<>(); - for (LWhProcureModelParams model : models) { - LWhProcureModel lWhProcureModel = new LWhProcureModel(); - lWhProcureModel.setId(IdUtil.generateId()); - lWhProcureModel.setBusinessType(3); - lWhProcureModel.setBusinessId(lWhFormOutputId); - lWhProcureModel.setBaseGoodsModelsId(model.getBaseGoodsModelsId()); - //lWhProcureModel.se - lWhProcureModel.setCounts(model.getCounts()); - //鏍规嵁鐗╁搧鍨嬪彿鏌ヨ鐗╁搧搴撳瓨 - int goodsNum = this.lWhGoodsService.queryGoodsModelNum(0,warehouseId, model.getBaseGoodsModelsId(), (short) 1, null); - lWhProcureModel.setWorehouseCount(goodsNum); - modelList.add(lWhProcureModel); + for (LWFormsOutputGoodsParam goods : goodsList) { + List<LWFormsOutputGoodsModelParam> models = goods.getModels(); + for (LWFormsOutputGoodsModelParam model : models) { + LWhProcureModel lWhProcureModel = new LWhProcureModel(); + lWhProcureModel.setId(IdUtil.generateId()); + lWhProcureModel.setBusinessType(3); + lWhProcureModel.setBusinessId(lWhFormOutputId); + lWhProcureModel.setBaseGoodsModelsId(model.getBaseGoodsModelsId()); + //鏍规嵁鍨嬪彿id鏌ヨ鍨嬪彿 + BaseGoodsModels baseGoodsModels = this.baseGoodsModelsService.get(new BaseGoodsModels(model.getBaseGoodsModelsId())); + if (baseGoodsModels != null) { + lWhProcureModel.setBaseGoodsModelsName(baseGoodsModels.getModelName()); + } + lWhProcureModel.setCounts(model.getCounts()); + //鏍规嵁鐗╁搧鍨嬪彿鏌ヨ鐗╁搧搴撳瓨 + int goodsNum = this.lWhGoodsService.queryGoodsModelNum(0, warehouseId, model.getBaseGoodsModelsId(), (short) 1, null); + lWhProcureModel.setWorehouseCount(goodsNum); + modelList.add(lWhProcureModel); + } } int flag2 = this.lWhProcureModelService.insert(modelList); if (flag2 != modelList.size()) { @@ -198,11 +208,20 @@ TransactionAspectSupport.currentTransactionStatus().setRollbackOnly(); return 0; } + + //3.鏍规嵁鍑哄簱鍗曞嚭搴� + Long lWarehouseFlowId = this.lWhFormOutputCoreService.outFormByTransId(lWhFormOutputId, currentUser, param.getDealTime()); + if (lWarehouseFlowId == null) { + log.error("鏍规嵁鍑哄簱鍗曞嚭搴撳け璐�"); + TransactionAspectSupport.currentTransactionStatus().setRollbackOnly(); + return 0; + } + return 1; } /** - * @Description 鍒楄〃鏌ヨ + * @Description 鍒楄〃鏌ヨ * @Author 鍗㈠簡闃� * @Date 2023/10/30 */ @@ -216,13 +235,14 @@ } //鐗╁搧鍚嶇О if (!StringUtils.isEmpty(param.getGoodsTemplateName())) { - sql.append(" AND id IN (SELECT BUSINESS_ID FROM L_WH_PROCURE_MODEL procureModel LEFT JOIN BASE_GOODS_MODELS baseModel ON procureModel.BASE_GOODS_MODELS_ID=baseModel.ID LEFT JOIN BASE_GOODS_TEMPLATE baseTemp ON baseModel.GOODS_TEMPLATES_ID=baseTemp.id WHERE procureModel.BUSINESS_TYPE=1 AND baseTemp.GOODS_NAME LIKE :goodsTemplateName)"); + sql.append( + " AND id IN (SELECT BUSINESS_ID FROM L_WH_PROCURE_MODEL procureModel LEFT JOIN BASE_GOODS_MODELS baseModel ON procureModel.BASE_GOODS_MODELS_ID=baseModel.ID LEFT JOIN BASE_GOODS_TEMPLATE baseTemp ON baseModel.GOODS_TEMPLATES_ID=baseTemp.id WHERE procureModel.BUSINESS_TYPE=1 AND baseTemp.GOODS_NAME LIKE :goodsTemplateName)"); paramts.put("goodsTemplateName", StringUtils.CHAR_PERCENT + param.getGoodsTemplateName() + StringUtils.CHAR_PERCENT); } //鏈烘瀯 - if (param.getAgencyId() != null){ + if (param.getAgencyId() != null) { sql.append(" and AGENCY_ID like :agencyId "); - paramts.put("agencyId", param.getAgencyId() + StringUtils.CHAR_PERCENT); + paramts.put("agencyId", param.getAgencyId() + StringUtils.CHAR_PERCENT); } //鍒涘缓浜� if (!StringUtils.isEmpty(param.getOperatorName())) { -- Gitblit v1.9.1