低值易耗品管理系统
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
futian.liu
2023-12-15 b268fd73f060108b8214ed1afcbbf03480435f3a 
 consum-base/src/main/java/com/consum/base/service/LWarehouseFlowCoreService.java


@@ -1,5 +1,7 @@


package com.consum.base.service;




import java.util.ArrayList;


import java.util.Arrays;


import java.util.List;


import java.util.Map;


import java.util.stream.Collectors;


@@ -50,12 +52,14 @@




    @PostConstruct


    public void init() {


        this.simpleJdbcCall = new SimpleJdbcCall(jdbcTemplate).withCatalogName(dataBaseName).withProcedureName("InsertL_WH_GOODS");


        this.simpleJdbcCall =


            new SimpleJdbcCall(jdbcTemplate).withCatalogName(dataBaseName).withProcedureName("InsertL_WH_GOODS");


    }




    @Autowired


    public LWarehouseFlowCoreService(JdbcTemplate jdbcTemplate, LWarehouseFlowService lWarehouseFlowService, LWhGoodsService lWhGoodsService,


                                     BaseGoodsTemplateService baseGoodsTemplateService, LWhGoodsRecordService lWhGoodsRecordServiceImpl) {


    public LWarehouseFlowCoreService(JdbcTemplate jdbcTemplate, LWarehouseFlowService lWarehouseFlowService,


        LWhGoodsService lWhGoodsService, BaseGoodsTemplateService baseGoodsTemplateService,


        LWhGoodsRecordService lWhGoodsRecordServiceImpl) {


        this.jdbcTemplate = jdbcTemplate;


        this.lWarehouseFlowService = lWarehouseFlowService;


        this.baseGoodsTemplateService = baseGoodsTemplateService;


@@ -70,7 +74,8 @@


     * @param warehouseFlow


     * @return


     */


    public int buyInsertWareFlow(List<LWhProcureModel> goodsModelNumList, LWhFormProcure lWhFormProcure, LWarehouseFlow warehouseFlow) {


    public int buyInsertWareFlow(List<LWhProcureModel> goodsModelNumList, LWhFormProcure lWhFormProcure,


        LWarehouseFlow warehouseFlow) {


        if (CollectionUtils.isEmpty(goodsModelNumList)) {


            log.error("没有要入库的物品");


            return 0;


@@ -85,9 +90,9 @@


        Long dealTime = warehouseFlow.getDealTime();


        BaseWarehouse baseWarehouses = lWarehouseFlowService.get(new BaseWarehouse(warehouseId));


        String warehouseName = baseWarehouses.getWarehouseName();


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


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


        short buyType = lWhFormProcure.getBuyType().shortValue();


        //采购时间


        // 采购时间


        Long procureTime2 = lWhFormProcure.getProcureTime();


        Long procureTime = procureTime2 == null ? dealTime : procureTime2;


        // 插入流水总表


@@ -96,27 +101,26 @@


            return 0;


        }




        //统计各型号数量


        Map<Long, Integer> countsSumByBaseGoodsModelsId = goodsModelNumList.stream()


                .collect(Collectors.groupingBy(LWhProcureModel::getBaseGoodsModelsId,


                        Collectors.summingInt(LWhProcureModel::getCounts)));


        // 统计各型号数量


        Map<Long, Integer> countsSumByBaseGoodsModelsId = goodsModelNumList.stream().collect(Collectors


            .groupingBy(LWhProcureModel::getBaseGoodsModelsId, Collectors.summingInt(LWhProcureModel::getCounts)));


        Map<Long, List<LWhProcureModel>> sameModelList = goodsModelNumList.stream()


                // 按型号分


                .collect(Collectors.groupingBy(LWhProcureModel::getBaseGoodsModelsId));


            // 按型号分


            .collect(Collectors.groupingBy(LWhProcureModel::getBaseGoodsModelsId));


        countsSumByBaseGoodsModelsId.forEach((baseGoodsModelsId, modelCount) -> {


            //查询型号信息


            // 查询型号信息


            Map<String, Object> tempGoodsInfo = baseGoodsTemplateService.queryGoodsInfoByModelId(baseGoodsModelsId);


            //价值类型


            String classificationObj = (String) tempGoodsInfo.get("classification");


            // 价值类型


            String classificationObj = (String)tempGoodsInfo.get("classification");


            Short classificationT = 3;


            if (classificationObj != null) {


                classificationT = (short) ((classificationObj).charAt(0) - 64);


                classificationT = (short)((classificationObj).charAt(0) - 64);


            }


            short classification = classificationT;


            Long tempGoodsId = (Long) tempGoodsInfo.get("goodsid");


            String goodsName = (String) tempGoodsInfo.get("goodsname");


            String modelName = (String) tempGoodsInfo.get("modelname");


            String goodsUnit = (String) tempGoodsInfo.get("unit");


            Long tempGoodsId = (Long)tempGoodsInfo.get("goodsid");


            String goodsName = (String)tempGoodsInfo.get("goodsname");


            String modelName = (String)tempGoodsInfo.get("modelname");


            String goodsUnit = (String)tempGoodsInfo.get("unit");




            // 插入 各规格物品的进出库记录 L_WH_GOODS_RECORD


            long whGoodsRecordId = IdUtil.generateId();


@@ -130,34 +134,35 @@


            whGoodsRecord.setBaseGoodsModelsId(baseGoodsModelsId);


            whGoodsRecord.setBaseGoodsModelsName(modelName);


            whGoodsRecord.setDealTime(dealTime);


            //本次调整类型 1=调增；2=调减


            // 本次调整类型 1=调增；2=调减


            whGoodsRecord.setThisType(1);




            //通过LockManage获得锁


            // 通过LockManage获得锁


            Object warehouseModelLockObj = LockManage.acquireLock(warehouseType, warehouseId, baseGoodsModelsId);


            synchronized (warehouseModelLockObj) {


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


                int goodsModelNum = lWhGoodsService.queryGoodsModelNum(warehouseType, warehouseId, baseGoodsModelsId, 1, null);


                List<Long> warehouseIds = new ArrayList<>(Arrays.asList(warehouseId));


                int goodsModelNum =


                    lWhGoodsService.queryGoodsModelNum(warehouseType, warehouseIds, baseGoodsModelsId, 1, null);


                whGoodsRecord.setInitialCount(goodsModelNum);


                whGoodsRecord.setThisCount(modelCount);


                whGoodsRecord.setEndCount(goodsModelNum + modelCount);




                long totalPrice = 0;


                //将同型号的物品插入 库存物品详情


                // 将同型号的物品插入 库存物品详情


                List<LWhProcureModel> lWhProcureModels = sameModelList.get(baseGoodsModelsId);


                for (LWhProcureModel item : lWhProcureModels) {


                    //供应商


                    // 供应商


                    String supplier = item.getSupplier();


                    //价格


                    // 价格


                    Long price = item.getPrice();


                    //物品个数


                    // 物品个数


                    Integer counts = item.getCounts();


                    totalPrice = totalPrice + counts * price;


                    sameGoodsInsertMore(warehouseFlowId, warehouseType, warehouseId, whGoodsRecordId, (short) 1, warehouseName,


                            classification, tempGoodsId, goodsName, baseGoodsModelsId, modelName,


                            supplier, buyType, goodsUnit, price, procureTime, 1, dealTime, counts);


                }


                ;


                    sameGoodsInsertMore(warehouseFlowId, warehouseType, warehouseId, whGoodsRecordId, (short)1,


                        warehouseName, classification, tempGoodsId, goodsName, baseGoodsModelsId, modelName, supplier,


                        buyType, goodsUnit, price, procureTime, 1, dealTime, counts);


                } ;


                whGoodsRecord.setTotalPrice(totalPrice);


            }


            lWhGoodsRecordServiceImpl.insert(whGoodsRecord);


@@ -166,51 +171,39 @@


        return 1;


    }






    /**


     * 同样规格的物品 插入多次， 同时将主键记录在 进出库流水明细【L_WH_GOODS_RECORD_DETAILS】, 更新 物品仓库保管记录【L_GOODS_WH_RECORD】


     *


     * @param pWarehouseId         仓库id


     * @param pWarehouseName       仓库名称


     * @param pCostType            物品价值类型


     * @param pWarehouseId 仓库id


     * @param pWarehouseName 仓库名称


     * @param pCostType 物品价值类型


     * @param pBaseGoodsTemplateId 物品模板ID


     * @param pGoodsTemplateName   物品模板名称


     * @param pBaseGoodsModelsId   物品型号ID


     * @param pGoodsTemplateName 物品模板名称


     * @param pBaseGoodsModelsId 物品型号ID


     * @param pBaseGoodsModelsName 物品型号名称


     * @param pUnit                物品单位


     * @param pSupplier            物品供应商


     * @param pBuyType             物品购买类型


     * @param pPrice               物品价格


     * @param pProcureDate         采购日期


     * @param pStates              状态


     * @param pTimes               插入条数


     * @param pUnit 物品单位


     * @param pSupplier 物品供应商


     * @param pBuyType 物品购买类型


     * @param pPrice 物品价格


     * @param pProcureDate 采购日期


     * @param pStates 状态


     * @param pTimes 插入条数


     */


    public void sameGoodsInsertMore(long pWarehouseFlowId, Integer warehouseType, long pWarehouseId, long pWhGoodsRecordId, short pRecordType,


                                    String pWarehouseName, short pCostType,


                                    long pBaseGoodsTemplateId, String pGoodsTemplateName, long pBaseGoodsModelsId,


                                    String pBaseGoodsModelsName, String pSupplier, short pBuyType,


                                    String pUnit, long pPrice, long pProcureDate,


                                    int pStates, long pDealTime, int pTimes) {


        SqlParameterSource in = new MapSqlParameterSource()


                .addValue("p_WAREHOUSE_FLOW_ID", pWarehouseFlowId)


                .addValue("p_WAREHOUSE_TYPE", warehouseType)


                .addValue("p_WAREHOUSE_ID", pWarehouseId)


                .addValue("p_WH_GOODS_RECORD_ID", pWhGoodsRecordId)


                .addValue("p_RECORD_TYPE", pRecordType)


                .addValue("p_WAREHOUSE_NAME", pWarehouseName)


                .addValue("p_COST_TYPE", pCostType)


                .addValue("p_BASE_GOODS_TEMPLATE_ID", pBaseGoodsTemplateId)


                .addValue("p_GOODS_TEMPLATE_NAME", pGoodsTemplateName)


                .addValue("p_BASE_GOODS_MODELS_ID", pBaseGoodsModelsId)


                .addValue("p_BASE_GOODS_MODELS_NAME", pBaseGoodsModelsName)


                .addValue("p_SUPPLIER", pSupplier)


                .addValue("p_BUY_TYPE", pBuyType)


                .addValue("p_UNIT", pUnit)


                .addValue("p_PRICE", pPrice)


                .addValue("p_PROCURE_DATE", pProcureDate)


                .addValue("p_STATES", pStates)


                .addValue("p_DEAL_TIME", pDealTime)


                .addValue("p_times", pTimes);


    public void sameGoodsInsertMore(long pWarehouseFlowId, Integer warehouseType, long pWarehouseId,


        long pWhGoodsRecordId, short pRecordType, String pWarehouseName, short pCostType, long pBaseGoodsTemplateId,


        String pGoodsTemplateName, long pBaseGoodsModelsId, String pBaseGoodsModelsName, String pSupplier,


        short pBuyType, String pUnit, long pPrice, long pProcureDate, int pStates, long pDealTime, int pTimes) {


        SqlParameterSource in = new MapSqlParameterSource().addValue("p_WAREHOUSE_FLOW_ID", pWarehouseFlowId)


            .addValue("p_WAREHOUSE_TYPE", warehouseType).addValue("p_WAREHOUSE_ID", pWarehouseId)


            .addValue("p_WH_GOODS_RECORD_ID", pWhGoodsRecordId).addValue("p_RECORD_TYPE", pRecordType)


            .addValue("p_WAREHOUSE_NAME", pWarehouseName).addValue("p_COST_TYPE", pCostType)


            .addValue("p_BASE_GOODS_TEMPLATE_ID", pBaseGoodsTemplateId)


            .addValue("p_GOODS_TEMPLATE_NAME", pGoodsTemplateName)


            .addValue("p_BASE_GOODS_MODELS_ID", pBaseGoodsModelsId)


            .addValue("p_BASE_GOODS_MODELS_NAME", pBaseGoodsModelsName).addValue("p_SUPPLIER", pSupplier)


            .addValue("p_BUY_TYPE", pBuyType).addValue("p_UNIT", pUnit).addValue("p_PRICE", pPrice)


            .addValue("p_PROCURE_DATE", pProcureDate).addValue("p_STATES", pStates).addValue("p_DEAL_TIME", pDealTime)


            .addValue("p_times", pTimes);


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


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


    }