低值易耗品管理系统
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
cy
2023-11-14 8e6c3af833dd3cbc6a8a5cbf95943b199231d96a 
 consum-base/src/main/java/com/consum/base/service/LWhFormOutputCoreService.java


@@ -4,18 +4,13 @@


import com.consum.base.core.CodeGeneratorService;


import com.consum.base.core.WhBusinessEnum;


import com.consum.base.core.param.BaseWarehouseParam1;


import com.consum.base.core.util.LockManage;


import com.consum.base.core.utils.LockManage;


import com.consum.model.po.*;


import com.iplatform.model.po.S_user_core;


import com.walker.infrastructure.utils.CollectionUtils;


import com.walker.infrastructure.utils.NumberGenerator;


import lombok.extern.slf4j.Slf4j;


import org.apache.commons.lang3.StringUtils;


import org.springframework.beans.factory.annotation.Autowired;


import org.springframework.jdbc.core.JdbcTemplate;


import org.springframework.jdbc.core.namedparam.MapSqlParameterSource;


import org.springframework.jdbc.core.namedparam.SqlParameterSource;


import org.springframework.jdbc.core.simple.SimpleJdbcCall;


import org.springframework.stereotype.Service;


import org.springframework.transaction.annotation.Transactional;


import org.springframework.transaction.interceptor.TransactionAspectSupport;


@@ -25,43 +20,41 @@




/**


 * @ClassName WhFormOutputCoreService


 * @Author cy


 * @Date 2023/10/26


 * @Description


 * @Version 1.0


 **/


@Slf4j


@Service


@Transactional(rollbackFor = Exception.class)


public class LWhFormOutputCoreService {


    private final JdbcTemplate jdbcTemplate;


    private SimpleJdbcCall simpleJdbcCall;




    private BaseGoodsTemplateServiceImpl baseGoodsTemplateService;


    private LWhGoodsService lWhGoodsService;


    private CodeGeneratorService codeGeneratorService;


    private LWhProcureModelService lWhProcureModelService;


    private LWhFormTransferService lWhFormTransferService;


    private LWhFormOutputService lWhFormOutputService;


    private LWarehouseFlowService lWarehouseFlowService;


    private LWhGoodsRecordDetailsService lWhGoodsRecordDetailsService;


    private LWhGoodsRecordService lWhGoodsRecordService;




    @Autowired


    public LWhFormOutputCoreService(BaseGoodsTemplateServiceImpl baseGoodsTemplateService,


                                    LWhGoodsService lWhGoodsService,


                                    CodeGeneratorService codeGeneratorService,


                                    LWhProcureModelService lWhProcureModelService,


                                    LWhFormTransferService lWhFormTransferService,


                                    LWhFormOutputService lWhFormOutputService,


                                    LWarehouseFlowService lWarehouseFlowService,


                                    JdbcTemplate jdbcTemplate


    ) {


                                    LWhGoodsRecordDetailsService lWhGoodsRecordDetailsService,


                                    LWhGoodsRecordService lWhGoodsRecordService) {


        this.baseGoodsTemplateService = baseGoodsTemplateService;


        this.lWhGoodsService = lWhGoodsService;


        this.codeGeneratorService = codeGeneratorService;


        this.lWhProcureModelService = lWhProcureModelService;


        this.lWhFormTransferService = lWhFormTransferService;


        this.lWhFormOutputService = lWhFormOutputService;


        this.lWarehouseFlowService = lWarehouseFlowService;


        this.jdbcTemplate = jdbcTemplate;


        this.simpleJdbcCall = new SimpleJdbcCall(jdbcTemplate).withProcedureName("insert_WH_GOODS_RECORD_DETAILS");


        this.lWhGoodsRecordDetailsService = lWhGoodsRecordDetailsService;


        this.lWhGoodsRecordService = lWhGoodsRecordService;


    }






@@ -77,7 +70,7 @@


            return null;


        }


        LWhFormTransfer lWhFormTransfer = new LWhFormTransfer(whFormTransferId);


        lWhFormTransfer = lWhFormTransferService.get(lWhFormTransfer);


        lWhFormTransfer = lWhFormOutputService.get(lWhFormTransfer);


        if (lWhFormTransfer == null || lWhFormTransfer.getStates() != 0) {


            log.error("调拨失败！请检查调拨单状态");


            return null;


@@ -119,7 +112,7 @@


        whFormOutput.setId(outWarehouseFormId);


        // 此时并没有出库


        whFormOutput.setWarehouseFlowId(null);


        whFormOutput.setBusinessFormCode(codeGeneratorService.createCodeByPrefix(CodeGeneratorEnum.OutPut_Warehouse.getValue(), 4));


        whFormOutput.setBusinessFormCode(codeGeneratorService.createBusinessFormCode(CodeGeneratorEnum.OutPut_Warehouse));


        //进出库流水总表 入库单ID


        whFormOutput.setInWarehouseFlowId(null);


//        调拨单ID(调拨时需要)


@@ -169,8 +162,12 @@


            return null;


        }


        // 要出物品的仓库id


        Integer outWarehouseType = lWhFormOutput.getOutWarehouseType();


        Long outWarehouseId = lWhFormOutput.getWarehouseId();


        String warehouseName = lWhFormOutput.getWarehouseName();


        Integer inWarehouseType = lWhFormOutput.getInWarehouseType();


        Long inWarehouseId = lWhFormOutput.getInWarehouseId();


        String inWarehouseName = lWhFormOutput.getInWarehouseName();




        Long userId = currentUser.getId();


        String nickName = currentUser.getNick_name();


@@ -184,7 +181,7 @@


        short queryModelStatusT = 1;


        //采购方式（1：集采；2=自采）


        Short buyTypeT = null;


        Short modGoodsTransferingStatusT = null;


        Integer modGoodsTransferingStatusT = null;


        String outputCode = lWhFormOutput.getOutputCode();


        if ((BaseWarehouseParam1.In_OutPutTypeEnum.Transfer_Output.getValue() + "").equals(outputCode)) {


            //调拨出库


@@ -203,11 +200,7 @@


        }


        short queryModelStatus = queryModelStatusT;


        Short buyType = buyTypeT;


        Short modGoodsTransferingStatus = modGoodsTransferingStatusT;




        // 接收方仓库信息


        Long inWarehouseId = lWhFormOutput.getInWarehouseId();


        String inWarehouseName = lWhFormOutput.getInWarehouseName();


        Integer modGoodsTransferingStatus = modGoodsTransferingStatusT;




        goodsModelNumList.forEach(itemModelInfo -> {


            // 需要调拨的物品的某个型号


@@ -245,10 +238,11 @@


            whGoodsRecord.setThisCount(counts);




            //通过LockManage获得锁


            Object warehouseModelLockObj = LockManage.acquireLock(outWarehouseId, baseGoodsModelsId);


            Object warehouseModelLockObj = LockManage.acquireLock(outWarehouseType, outWarehouseId, baseGoodsModelsId);


            List<Long> outGoodsId = null;


            synchronized (warehouseModelLockObj) {


                // 获得锁后查询该型号的期初数量


                int goodsModelNum = lWhGoodsService.queryGoodsModelNum(outWarehouseId, baseGoodsModelsId, queryModelStatus, buyType);


                int goodsModelNum = lWhGoodsService.queryGoodsModelNum(outWarehouseType, outWarehouseId, baseGoodsModelsId, queryModelStatus, buyType);


                if (goodsModelNum < counts) {


                    log.error("出库失败！型号{} 的数量不足，需要调拨{}个，仓库中现存{}个", baseGoodsModelsId, counts, goodsModelNum);


                    // 手动回滚


@@ -259,11 +253,18 @@


                whGoodsRecord.setEndCount(goodsModelNum - counts);




                //出库时候，按 先入库的先出库，同时入库的，按价格高的先出库


                List<Long> outGoodsId = lWhGoodsService.queryOutGoodsId(outWarehouseId, baseGoodsModelsId, queryModelStatus, buyType, goodsModelNum);


                lWhGoodsService.modGoodsTransfering(outGoodsId, inWarehouseId, inWarehouseName, modGoodsTransferingStatus);


                outGoodsId = lWhGoodsService.queryOutGoodsId(outWarehouseType, outWarehouseId, baseGoodsModelsId, queryModelStatus, buyType,


                        counts);


                lWhGoodsService.modGoodsTransfering(outGoodsId, inWarehouseType, inWarehouseId, inWarehouseName, modGoodsTransferingStatus);


                // 批量插入 进出库流水明细[L_WH_GOODS_RECORD_DETAILS]


                sameGoodsInsertMore(outGoodsId, whGoodsRecordId, (short) 0);


                lWhGoodsRecordDetailsService.sameGoodsInsertMore(outGoodsId, whGoodsRecordId, (short) 0);


            }


            long totalAmount = lWhGoodsService.queryGoodsPriceById(outGoodsId);


            LWhProcureModel lWhProcureModel = new LWhProcureModel(itemModelInfo.getId());


            whGoodsRecord.setTotalPrice(totalAmount);


            lWhGoodsRecordService.insert(whGoodsRecord);


            lWhProcureModel.setTotalAmount(totalAmount);


            lWhProcureModelService.update(lWhProcureModel);


        });


        LWarehouseFlow warehouseFlow = new LWarehouseFlow();


        warehouseFlow.setId(lWarehouseFlowId);


@@ -281,16 +282,14 @@


        if (flowInsertFlag == 0) {


            return null;


        }


        // 向出库单 插入 进出库流水总表ID


        lWhFormOutput = new LWhFormOutput(outWarehouseFormId);


        lWhFormOutput.setStates(2);


        lWhFormOutput.setWarehouseFlowId(lWarehouseFlowId);


        lWhFormOutputService.update(lWhFormOutput);




        return lWarehouseFlowId;


    }




    public void sameGoodsInsertMore(List<Long> outGoodsId, long whGoodsRecordId, short thisType) {


        SqlParameterSource in = new MapSqlParameterSource()


                .addValue("WHGOODSIDList", StringUtils.join(outGoodsId))


                .addValue("WH_GOODS_RECORD_ID", whGoodsRecordId)


                .addValue("THIS_TYPE", thisType);




        Map<String, Object> out = simpleJdbcCall.execute(in);


        System.out.println("Procedure result: " + out);


    }


}