From 31692354e8191b583250c213152bfd0068ffe0fc Mon Sep 17 00:00:00 2001 From: futian.liu <liufutianyoo@163.com> Date: 星期一, 13 十一月 2023 10:43:05 +0800 Subject: [PATCH] 整理代码 --- consum-base/src/main/java/com/consum/base/service/LWhFormOutputServiceImpl.java | 56 +++++++++++++++++++++++++++++++++++--------------------- 1 files changed, 35 insertions(+), 21 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..d52b1d7 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,20 +3,17 @@ import com.consum.base.core.CodeGeneratorEnum; import com.consum.base.core.CodeGeneratorService; import com.consum.base.core.param.BaseWarehouseParam1; -import com.consum.base.pojo.LWhFormOutputParam; -import com.consum.base.pojo.LWhProcureModelParams; -import com.consum.base.util.IdUtil; +import com.consum.base.pojo.*; +import com.consum.base.core.utils.IdUtil; import com.consum.model.po.*; 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 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; @@ -41,6 +38,8 @@ 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"; @@ -146,7 +145,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 +167,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 +175,27 @@ return 0; } //2.鏂板鐗╁搧鍨嬪彿璁板綍 - List<LWhProcureModelParams> models = param.getModels(); + List<LWhFormOutputGoodsParams> 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 (LWhFormOutputGoodsParams goods : goodsList) { + List<LWhProcureModelParams> models = goods.getModels(); + for (LWhProcureModelParams 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,6 +203,15 @@ 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; } -- Gitblit v1.9.1