From eb8577aac0f1f7d783ecd067e7eef05e53e7fd10 Mon Sep 17 00:00:00 2001 From: luqingyang <lqy5492@163.com> Date: 星期五, 27 十月 2023 17:24:26 +0800 Subject: [PATCH] Merge remote-tracking branch 'origin/master' --- consum-base/src/main/java/com/consum/base/service/LWhFormOutputServiceImpl.java | 204 +++++++++++++++++++++++++++++++++++++++++++++++++++ 1 files changed, 204 insertions(+), 0 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 new file mode 100644 index 0000000..5ac7972 --- /dev/null +++ b/consum-base/src/main/java/com/consum/base/service/LWhFormOutputServiceImpl.java @@ -0,0 +1,204 @@ +package com.consum.base.service; + +import com.consum.base.Constants; +import com.consum.base.core.param.BaseWarehouseParam1; +import com.consum.base.pojo.LWhFormOutputParam; +import com.consum.base.util.IdUtil; +import com.consum.model.po.*; +import com.iplatform.model.po.S_user_core; +import com.walker.infrastructure.utils.DateUtils; +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.List; + +/** + * @Description 鍑哄簱鍗� + * @Author 鍗㈠簡闃� + * @Date 2023/10/27 + */ +@Slf4j +@Service +public class LWhFormOutputServiceImpl extends BaseServiceImpl { + + @Autowired + private BaseWarehouseServiceImpl baseWarehouseService; + @Autowired + private LWhGoodsService lWhGoodsService; + @Autowired + private LWhProcureModelService lWhProcureModelService; + @Autowired + private LWhFormOutputCoreService lWhFormOutputCoreService; + +// /** +// * @Description 鏂板鍑哄簱鍗� +// * @Author 鍗㈠簡闃� +// * @Date 2023/10/27 +// */ +// public int add(LWhFormOutputParam param, S_user_core currentUser, FinSysTenantUser sysInfo) { +// //1.鏂板鍑哄簱鍗曡褰� +// LWhFormOutput lWhFormOutput = new LWhFormOutput(); +// //鍑哄叆搴搃d +// long lWhFormOutputId = IdUtil.generateId(); +// lWhFormOutput.setId(lWhFormOutputId); +// Long warehouseId = param.getWarehouseId(); +// lWhFormOutput.setWarehouseId(warehouseId); +// //鏍规嵁浠撳簱id鏌ヨ浠撳簱 +// BaseWarehouse warehouse = this.baseWarehouseService.getById(warehouseId); +// if (warehouse == null) { +// log.error("浠撳簱id涓嶅瓨鍦�"); +// return 0; +// } +// lWhFormOutput.setWarehouseName(warehouse.getWarehouseName()); +// lWhFormOutput.setOutputCode(BaseWarehouseParam1.In_OutPutTypeEnum.Fragmentary_Output.getValue()+""); +// lWhFormOutput.setOutputName("闆舵槦鍑哄簱"); +// lWhFormOutput.setAgencyId(Long.valueOf(sysInfo.getTenantId())); +// lWhFormOutput.setAgencyName(sysInfo.getTenantName()); +// lWhFormOutput.setOperatorId(sysInfo.getId()); +// lWhFormOutput.setOperatorName(sysInfo.getUserName()); +// long dateTimeNumber = DateUtils.getDateTimeNumber(System.currentTimeMillis()); +// lWhFormOutput.setDealTime(dateTimeNumber); +// lWhFormOutput.setStates(1); +// int flag1 = this.insert(lWhFormOutput); +// +// //2.鏍规嵁鍑哄簱鍗曞嚭搴� +// Long lWarehouseFlowId = this.lWhFormOutputCoreService.outFormByTransId(lWhFormOutput.getId(), currentUser, dateTimeNumber); +// //3.鍚戝嚭搴撳崟 鎻掑叆 杩涘嚭搴撴祦姘存�昏〃ID +// int flag3 = 0; +// if (flag1 > 0) { +// LWhFormOutput lWhFormOutput1 = new LWhFormOutput(lWhFormOutputId); +// lWhFormOutput1.setWarehouseFlowId(lWarehouseFlowId); +// flag3 = this.update(lWhFormOutput1); +// } +// +// //4.鏂板l_wh_goods_record璁板綍 +// List<LWhGoodsRecord> recordList = param.getList(); +// if (CollectionUtils.isEmpty(recordList)) { +// log.error("瑙勬牸鍨嬪彿涓虹┖"); +// return 0; +// } +// int flag5 = 0; +// int number = -1; //鍑哄簱鍚庯紝鐗╁搧鍓╀綑鏁伴噺 +// for (LWhGoodsRecord record : recordList) { +// //鐗╁搧id鍜岀墿鍝佸悕绉� +// record.setBaseGoodsTemplateId(param.getBaseGoodsTemplateId()); +// record.setGoodsTemplateName(param.getGoodsTemplateName()); +// +// record.setId(IdUtil.generateId()); +// record.setWarehouseId(warehouseId); +// //鏍规嵁鐗╁搧鍨嬪彿鏌ヨ鐗╁搧搴撳瓨 +// int goodsNum = this.lWhGoodsService.queryGoodsModelNum(warehouseId, record.getBaseGoodsModelsId(), (short) 1, null); +// record.setInitialCount(goodsNum); +// record.setThisType(2); +// +// //鍒ゆ柇鍑哄簱鏁伴噺鏄惁灏忎簬搴撳瓨 +// number = goodsNum - record.getThisCount(); +// if (number < 0) { +// log.error("搴撳瓨涓嶈冻"); +// break; +// } +// record.setEndCount(number); +// record.setDealTime(dateTimeNumber); +// record.setWarehouseFlowId(lWarehouseFlowId); +// +// //5.鏂板L_WH_PROCURE_MODEL璁板綍 +// LWhProcureModel lWhProcureModel = new LWhProcureModel(); +// lWhProcureModel.setId(IdUtil.generateId()); +// lWhProcureModel.setBusinessType(3); +// lWhProcureModel.setBaseGoodsModelsId(record.getBaseGoodsModelsId()); +// lWhProcureModel.setCounts(record.getThisCount()); +// lWhProcureModel.setWorehouseCount(goodsNum); +// int res = this.lWhProcureModelService.insert(lWhProcureModel); +// flag5 += res; +// } +// //濡傛灉鍑哄簱鍚庯紝鍓╀綑搴撳瓨澶т簬0锛屾柊澧瀕_wh_goods_record璁板綍 +// int flag4 = 0; +// if (number >= 0){ +// flag4 = this.lWhGoodsService.insert(recordList); +// } +// +// //濡傛灉鏈変竴鏉¤褰曟柊澧炲け璐ワ紝鍒欏洖婊� +// if (flag1 == 0 || flag3 == 0 || flag4 != recordList.size() || flag5 != recordList.size() || number < 0) { +// TransactionAspectSupport.currentTransactionStatus().setRollbackOnly(); +// return 0; +// } +// +// return 1; +// } + + /** + * @Description 鏂板鍑哄簱鍗� + * @Author 鍗㈠簡闃� + * @Date 2023/10/27 + */ + public int add(LWhFormOutputParam param, S_user_core currentUser, FinSysTenantUser sysInfo) { + //1.鏂板鍑哄簱鍗曡褰� + LWhFormOutput lWhFormOutput = new LWhFormOutput(); + //鍑哄叆搴搃d + long lWhFormOutputId = IdUtil.generateId(); + lWhFormOutput.setId(lWhFormOutputId); + Long warehouseId = param.getWarehouseId(); + lWhFormOutput.setWarehouseId(warehouseId); + //鏍规嵁浠撳簱id鏌ヨ浠撳簱 + BaseWarehouse warehouse = this.baseWarehouseService.getById(warehouseId); + if (warehouse == null) { + log.error("浠撳簱id涓嶅瓨鍦�"); + return 0; + } + lWhFormOutput.setWarehouseName(warehouse.getWarehouseName()); + lWhFormOutput.setOutputCode(BaseWarehouseParam1.In_OutPutTypeEnum.Fragmentary_Output.getValue() + ""); + lWhFormOutput.setOutputName("闆舵槦鍑哄簱"); + lWhFormOutput.setAgencyId(Long.valueOf(sysInfo.getTenantId())); + lWhFormOutput.setAgencyName(sysInfo.getTenantName()); + lWhFormOutput.setOperatorId(sysInfo.getId()); + lWhFormOutput.setOperatorName(sysInfo.getUserName()); + long dateTimeNumber = DateUtils.getDateTimeNumber(System.currentTimeMillis()); + lWhFormOutput.setDealTime(dateTimeNumber); + lWhFormOutput.setStates(1); + int flag1 = this.insert(lWhFormOutput); + + //4.鏂板l_wh_goods_record璁板綍 + List<LWhGoodsRecord> recordList = param.getList(); + if (CollectionUtils.isEmpty(recordList)) { + log.error("瑙勬牸鍨嬪彿涓虹┖"); + return 0; + } + int flag5 = 0; + for (LWhGoodsRecord record : recordList) { + //鏍规嵁鐗╁搧鍨嬪彿鏌ヨ鐗╁搧搴撳瓨 + int goodsNum = this.lWhGoodsService.queryGoodsModelNum(warehouseId, record.getBaseGoodsModelsId(), (short) 1, null); + + //5.鏂板L_WH_PROCURE_MODEL璁板綍 + LWhProcureModel lWhProcureModel = new LWhProcureModel(); + lWhProcureModel.setId(IdUtil.generateId()); + lWhProcureModel.setBusinessType(3); + lWhProcureModel.setBaseGoodsModelsId(record.getBaseGoodsModelsId()); + lWhProcureModel.setCounts(record.getThisCount()); + lWhProcureModel.setWorehouseCount(goodsNum); + int res = this.lWhProcureModelService.insert(lWhProcureModel); + flag5 += res; + } + + //2.鏍规嵁鍑哄簱鍗曞嚭搴� + Long lWarehouseFlowId = this.lWhFormOutputCoreService.outFormByTransId(lWhFormOutput.getId(), currentUser, dateTimeNumber); + //3.鍚戝嚭搴撳崟 鎻掑叆 杩涘嚭搴撴祦姘存�昏〃ID + int flag3 = 0; + if (flag1 > 0) { + LWhFormOutput lWhFormOutput1 = new LWhFormOutput(lWhFormOutputId); + lWhFormOutput1.setWarehouseFlowId(lWarehouseFlowId); + flag3 = this.update(lWhFormOutput1); + } + + //濡傛灉鏈変竴鏉¤褰曟柊澧炲け璐ワ紝鍒欏洖婊� + if (flag1 == 0 || flag3 == 0 || flag5 != recordList.size()) { + TransactionAspectSupport.currentTransactionStatus().setRollbackOnly(); + return 0; + } + + return 1; + } +} -- Gitblit v1.9.1