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(); // //出入库id // 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 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,新增l_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(); //出入库id 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 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; } }