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


@@ -1,23 +1,22 @@


package com.consum.base.service;




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


import com.consum.model.po.BaseWarehouse;


import com.consum.model.po.LWarehouseFlow;


import com.consum.model.po.LWhFormProcure;


import com.consum.model.po.LWhGoodsRecord;


import com.consum.model.po.LWhProcureModel;


import com.consum.model.po.*;


import com.walker.infrastructure.utils.CollectionUtils;


import com.walker.infrastructure.utils.NumberGenerator;


import java.util.List;


import java.util.Map;


import java.util.stream.Collectors;


import lombok.extern.slf4j.Slf4j;


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


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


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 javax.annotation.PostConstruct;


import java.util.List;


import java.util.Map;


import java.util.stream.Collectors;




/**


 * @ClassName LWarehouseFlowService


@@ -36,15 +35,22 @@


    private LWhGoodsRecordService lWhGoodsRecordService;


    private BaseGoodsTemplateServiceImpl baseGoodsTemplateService;




    @Value("${spring.datasource.dataBaseName}")


    private String dataBaseName;




    @PostConstruct


    public void init() {


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


    }




    @Autowired


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


        BaseGoodsTemplateServiceImpl baseGoodsTemplateService, LWhGoodsRecordService lWhGoodsRecordService) {


                                     BaseGoodsTemplateServiceImpl baseGoodsTemplateService, LWhGoodsRecordService lWhGoodsRecordService) {


        this.jdbcTemplate = jdbcTemplate;


        this.lWarehouseFlowService = lWarehouseFlowService;


        this.baseGoodsTemplateService = baseGoodsTemplateService;


        this.lWhGoodsService = lWhGoodsService;


        this.lWhGoodsRecordService = lWhGoodsRecordService;


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


    }




    /**


@@ -82,11 +88,11 @@




        //统计各型号数量


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


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


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


                .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);


@@ -136,11 +142,12 @@


                    Long price = item.getPrice();


                    //物品个数


                    Integer counts = item.getCounts();


                    totalPrice = totalPrice + counts*price;


                    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);


                };


                            classification, tempGoodsId, goodsName, baseGoodsModelsId, modelName,


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


                }


                ;


                whGoodsRecord.setTotalPrice(totalPrice);


            }


            lWhGoodsRecordService.insert(whGoodsRecord);


@@ -169,31 +176,31 @@


     * @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) {


                                    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);


                .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);


    }