联讯物业系统后台
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
xiaogang
2024-01-13 be1b426b7d765a546f4a26b60e80aa49a57079b9 
 service-store/src/main/java/com/java110/store/bmo/allocation/impl/AllocationBMOImpl.java


@@ -4,22 +4,24 @@


import com.java110.dto.purchase.AllocationStorehouseDto;


import com.java110.dto.resource.ResourceStoreDto;


import com.java110.dto.resource.ResourceStoreTimesDto;


import com.java110.intf.common.IAllocationStorehouseUserInnerServiceSMO;


import com.java110.dto.store.StorehouseDto;


import com.java110.intf.store.*;


import com.java110.po.purchase.ResourceStorePo;


import com.java110.po.resource.ResourceStoreTimesPo;


import com.java110.store.bmo.allocation.IAllocationBMO;


import com.java110.utils.util.Assert;


import com.java110.utils.util.BeanConvertUtil;


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


import org.springframework.stereotype.Service;




import java.math.BigDecimal;


import java.util.List;




@Service


public class AllocationBMOImpl implements IAllocationBMO {




    @Autowired


    private IAllocationStorehouseApplyInnerServiceSMO allocationStorehouseApplyInnerServiceSMOImpl;


    private IStorehouseInnerServiceSMO storehouseInnerServiceSMOImpl;




    @Autowired


    private IResourceStoreTimesV1InnerServiceSMO resourceStoreTimesV1InnerServiceSMOImpl;


@@ -28,34 +30,26 @@


    private IResourceStoreInnerServiceSMO resourceStoreInnerServiceSMOImpl;




    @Autowired


    private IAllocationStorehouseUserInnerServiceSMO allocationStorehouseUserInnerServiceSMOImpl;




    @Autowired


    private IUserStorehouseInnerServiceSMO userStorehouseInnerServiceSMOImpl;




    @Autowired


    private IAllocationStorehouseApplyV1InnerServiceSMO allocationStorehouseApplyV1InnerServiceSMOImpl;




    @Autowired


    private IAllocationStorehouseV1InnerServiceSMO allocationStorehouseV1InnerServiceSMOImpl;




    @Autowired


    private IResourceStoreV1InnerServiceSMO resourceStoreV1InnerServiceSMOImpl;




    @Override


    public void doToAllocationStorehouse(AllocationStorehouseDto tmpAllocationStorehouseDto, int allocationStock) {


    public void doToAllocationStorehouse(AllocationStorehouseDto tmpAllocationStorehouseDto, double allocationStock) {


        //查询z 仓库


        StorehouseDto storehouseDto = new StorehouseDto();


        storehouseDto.setShId(tmpAllocationStorehouseDto.getShIdz());


        List<StorehouseDto> targetStorehouseDtos = storehouseInnerServiceSMOImpl.queryStorehouses(storehouseDto);


        Assert.listOnlyOne(targetStorehouseDtos, "目标仓库不存在");




        // todo -------------------------------------------------原仓库中做扣除 (start)-----------------------------------------------------//


        // todo 原仓库中扣除 数量


        ResourceStoreDto resourceStoreDto = new ResourceStoreDto();


        resourceStoreDto.setResCode(tmpAllocationStorehouseDto.getResCode());


        resourceStoreDto.setResId(tmpAllocationStorehouseDto.getResId());


        resourceStoreDto.setShId(tmpAllocationStorehouseDto.getShIda());


        List<ResourceStoreDto> resourceStoreDtoAs = resourceStoreInnerServiceSMOImpl.queryResourceStores(resourceStoreDto);


        //todo 这种场景不存在


        if (resourceStoreDtoAs == null || resourceStoreDtoAs.size() < 1) {


            return;


        }




        ResourceStoreTimesDto resourceStoreTimesDto = new ResourceStoreTimesDto();


        resourceStoreTimesDto.setTimesId(tmpAllocationStorehouseDto.getTimesId());


        resourceStoreTimesDto.setShId(tmpAllocationStorehouseDto.getShIda());


@@ -64,9 +58,7 @@


        if (resourceStoreTimesDtoAs == null || resourceStoreTimesDtoAs.size() < 1) {


            return;


        }




        int stockA = Integer.parseInt(resourceStoreDtoAs.get(0).getStock());




        double stockA = Double.parseDouble(resourceStoreDtoAs.get(0).getStock());


        //todo 库存不够时，只能调拨 库存，这种场景应该执行不到 前文做了校验


        if (stockA < allocationStock) {


            allocationStock = stockA;


@@ -76,14 +68,11 @@


        resourceStorePo.setStoreId(resourceStoreDtoAs.get(0).getStoreId());


        resourceStorePo.setStock(allocationStock * -1 + "");// 这里去扣出


        resourceStoreInnerServiceSMOImpl.updateResourceStore(resourceStorePo);




        stockA = Integer.parseInt(resourceStoreTimesDtoAs.get(0).getStock());




        stockA = Double.parseDouble(resourceStoreTimesDtoAs.get(0).getStock());


        //todo 库存不够时，只能调拨 库存，这种场景应该执行不到 前文做了校验


        if (stockA < allocationStock) {


            allocationStock = stockA;


        }




        ResourceStoreTimesPo resourceStoreTimesPo = new ResourceStoreTimesPo();


        resourceStoreTimesPo.setPrice(resourceStoreTimesDtoAs.get(0).getPrice());


        resourceStoreTimesPo.setShId(resourceStoreTimesDtoAs.get(0).getShId());


@@ -96,7 +85,7 @@


        // todo -------------------------------------------------目标仓库中做增加 (start)-----------------------------------------------------//


        //todo 查询目标仓库中 库存


        resourceStoreDto = new ResourceStoreDto();


        resourceStoreDto.setResCode(tmpAllocationStorehouseDto.getResCode());


        resourceStoreDto.setResCode(resourceStoreDtoAs.get(0).getResCode());


        resourceStoreDto.setShId(tmpAllocationStorehouseDto.getShIdz());


        List<ResourceStoreDto> resourceStoreDtoZs = resourceStoreInnerServiceSMOImpl.queryResourceStores(resourceStoreDto);


        //todo 这种场景不存在


@@ -106,35 +95,35 @@


            tmpResourceStorePo.setResId(GenerateCodeFactory.getGeneratorId("11"));


            tmpResourceStorePo.setStock(allocationStock + "");


            tmpResourceStorePo.setShId(tmpAllocationStorehouseDto.getShIdz());


            tmpResourceStorePo.setCommunityId(targetStorehouseDtos.get(0).getCommunityId());


            BigDecimal miniUnitStock = new BigDecimal(resourceStoreDtoAs.get(0).getMiniUnitStock()); //获取最小计量单位数量


            BigDecimal stock = new BigDecimal(tmpResourceStorePo.getStock()); //获取物品库存


            BigDecimal miniStock = miniUnitStock.multiply(stock); //计算最小计量单位总数


            tmpResourceStorePo.setMiniStock(String.valueOf(miniStock));


            resourceStoreV1InnerServiceSMOImpl.saveResourceStore(tmpResourceStorePo);




            // todo 添加 times


            ResourceStoreTimesPo tmpResourceStoreTimesPo = BeanConvertUtil.covertBean(resourceStoreTimesDtoAs.get(0), ResourceStoreTimesPo.class);


            tmpResourceStoreTimesPo.setTimesId(GenerateCodeFactory.getGeneratorId("11"));


            tmpResourceStoreTimesPo.setStock(allocationStock + "");


            tmpResourceStoreTimesPo.setShId(tmpAllocationStorehouseDto.getShIdz());




            tmpResourceStoreTimesPo.setCommunityId(targetStorehouseDtos.get(0).getCommunityId());


            resourceStoreTimesV1InnerServiceSMOImpl.saveResourceStoreTimes(tmpResourceStoreTimesPo);


            return;


        }




        resourceStorePo = new ResourceStorePo();


        resourceStorePo.setResId(resourceStoreDtoZs.get(0).getResId());


        resourceStorePo.setStoreId(resourceStoreDtoZs.get(0).getStoreId());


        resourceStorePo.setStock(allocationStock + "");// 这里去扣出


        resourceStorePo.setStock(allocationStock + "");// 这里去添加到目标仓库


        resourceStoreInnerServiceSMOImpl.updateResourceStore(resourceStorePo);






        resourceStoreTimesPo = new ResourceStoreTimesPo();


        resourceStoreTimesPo.setPrice(resourceStoreTimesDtoAs.get(0).getPrice());


        resourceStoreTimesPo.setShId(resourceStoreDtoZs.get(0).getShId());


        resourceStoreTimesPo.setResCode(resourceStoreTimesDtoAs.get(0).getResCode());


        resourceStoreTimesPo.setStoreId(resourceStoreTimesDtoAs.get(0).getStoreId());


        resourceStoreTimesPo.setStock(allocationStock + "");// 这里去增加


        resourceStoreTimesPo.setCommunityId(resourceStoreDtoZs.get(0).getCommunityId());


        resourceStoreTimesPo.setApplyOrderId(tmpAllocationStorehouseDto.getApplyId());


        resourceStoreTimesV1InnerServiceSMOImpl.saveOrUpdateResourceStoreTimes(resourceStoreTimesPo);


        // todo -------------------------------------------------目标仓库中做增加 (end)-----------------------------------------------------//






    }


}