产品供销存-后端
blame | 历史 | 补丁 | 提交 | 提交对比 | 忽略空白
yaowanxin
9 小时以前 8e2390f4708613052cb50d944ed5c8de039a16b1 
 src/main/java/com/ruoyi/home/service/impl/HomeServiceImpl.java


@@ -1,8 +1,12 @@


package com.ruoyi.home.service.impl;




import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;


import com.baomidou.mybatisplus.core.metadata.IPage;


import com.baomidou.mybatisplus.extension.plugins.pagination.Page;


import com.ruoyi.approve.mapper.ApproveProcessMapper;


import com.ruoyi.approve.pojo.ApproveProcess;


import com.ruoyi.basic.mapper.ProductModelMapper;


import com.ruoyi.basic.pojo.ProductModel;


import com.ruoyi.collaborativeApproval.mapper.NoticeMapper;


import com.ruoyi.collaborativeApproval.pojo.Notice;


import com.ruoyi.common.utils.SecurityUtils;


@@ -22,6 +26,15 @@


import com.ruoyi.procurementrecord.pojo.CustomStorage;


import com.ruoyi.procurementrecord.pojo.ProcurementRecordOut;


import com.ruoyi.procurementrecord.pojo.ProcurementRecordStorage;


import com.ruoyi.procurementrecord.utils.StockUtils;


import com.ruoyi.production.dto.ProductOrderDto;


import com.ruoyi.production.dto.ProductWorkOrderDto;


import com.ruoyi.production.dto.ProductionProductMainDto;


import com.ruoyi.production.mapper.ProductOrderMapper;


import com.ruoyi.production.mapper.ProductWorkOrderMapper;


import com.ruoyi.production.mapper.ProductionProductMainMapper;


import com.ruoyi.production.pojo.ProductOrder;


import com.ruoyi.production.pojo.ProductWorkOrder;


import com.ruoyi.project.system.domain.SysDept;


import com.ruoyi.project.system.mapper.SysDeptMapper;


import com.ruoyi.purchase.mapper.PaymentRegistrationMapper;


@@ -98,7 +111,16 @@




    @Autowired


    private NoticeMapper noticeMapper;




    @Autowired


    private ProductOrderMapper productOrderMapper;


    @Autowired


    private ProductionProductMainMapper productionProductMainMapper;


    @Autowired


    private ProductWorkOrderMapper productWorkOrderMapper;


    @Autowired


    private ProductModelMapper productModelMapper;


    @Autowired


    private StockUtils stockUtils;


    @Override


    public HomeBusinessDto business() {


        // 构建结果


@@ -151,23 +173,35 @@


            homeBusinessDto.setMonthPurchaseHaveMoney(unReceiptPaymentAmount.setScale(2, RoundingMode.HALF_UP).toString());


        }


        // 统计库存


        List<ProcurementRecordStorage> procurementRecordStorages = procurementRecordStorageMapper.selectList(null);


        BigDecimal stockAmount = procurementRecordStorages.stream()


                .map(ProcurementRecordStorage::getInboundNum)


                .filter(Objects::nonNull)


                .reduce(BigDecimal.ZERO, BigDecimal::add);


        // 自定义库存


        List<CustomStorage> customStorages = customStorageMapper.selectList(null);


        BigDecimal customStockAmount = customStorages.stream()


                .map(CustomStorage::getInboundNum)


                .filter(Objects::nonNull)


                .reduce(BigDecimal.ZERO, BigDecimal::add);


        List<ProcurementRecordOut> procurementRecordOuts = procurementRecordOutMapper.selectList(null);


        BigDecimal outboundAmount = procurementRecordOuts.stream()


                .map(ProcurementRecordOut::getInboundNum)


                .filter(Objects::nonNull)


                .reduce(BigDecimal.ZERO, BigDecimal::add);


        BigDecimal stock = stockAmount.add(customStockAmount).subtract(outboundAmount);


//        List<ProcurementRecordStorage> procurementRecordStorages = procurementRecordStorageMapper.selectList(null);


//        BigDecimal stockAmount = procurementRecordStorages.stream()


//                .map(ProcurementRecordStorage::getInboundNum)


//                .filter(Objects::nonNull)


//                .reduce(BigDecimal.ZERO, BigDecimal::add);


//        // 自定义库存


//        List<CustomStorage> customStorages = customStorageMapper.selectList(null);


//        BigDecimal customStockAmount = customStorages.stream()


//                .map(CustomStorage::getInboundNum)


//                .filter(Objects::nonNull)


//                .reduce(BigDecimal.ZERO, BigDecimal::add);


//        List<ProcurementRecordOut> procurementRecordOuts = procurementRecordOutMapper.selectList(null);


//        BigDecimal outboundAmount = procurementRecordOuts.stream()


//                .map(ProcurementRecordOut::getInboundNum)


//                .filter(Objects::nonNull)


//                .reduce(BigDecimal.ZERO, BigDecimal::add);


//        BigDecimal stock = stockAmount.add(customStockAmount).subtract(outboundAmount);


        IPage<ProductModel> productModelIPage = productModelMapper.listPageProductModel(new Page<>(1, -1), new ProductModel());


        if(!CollectionUtils.isEmpty(productModelIPage.getRecords())){


            //获取规格id


            List<Long> modelIds = productModelIPage.getRecords().stream().map(ProductModel::getId).collect(Collectors.toList());


            BigDecimal stockQuantityTotal = modelIds.stream()


                    .map(stockUtils::getStockQuantity)


                    .map(map -> map.get("stockQuantity"))


                    .filter(Objects::nonNull)


                    .reduce(BigDecimal.ZERO, BigDecimal::add);


            homeBusinessDto.setInventoryNum(stockQuantityTotal.setScale(2, RoundingMode.HALF_UP).toString());


        }




        // 获取当天入库数量


        LambdaQueryWrapper<ProcurementRecordStorage> procurementRecordStorageLambdaQueryWrapper = new LambdaQueryWrapper<>();


        procurementRecordStorageLambdaQueryWrapper.ge(ProcurementRecordStorage::getCreateTime, now)  // 大于等于当天


@@ -177,7 +211,7 @@


                .map(ProcurementRecordStorage::getInboundNum)


                .filter(Objects::nonNull)


                .reduce(BigDecimal.ZERO, BigDecimal::add);


        homeBusinessDto.setInventoryNum(stock.setScale(2, RoundingMode.HALF_UP).toString());


//        homeBusinessDto.setInventoryNum(stock.setScale(2, RoundingMode.HALF_UP).toString());


        homeBusinessDto.setTodayInventoryNum(stockAmount1.setScale(2, RoundingMode.HALF_UP).toString());


        return homeBusinessDto;


    }


@@ -490,4 +524,41 @@


                .eq(Notice::getStatus, 1) // 1表示发布状态


                .ge(Notice::getExpirationDate, new Date())); // 过期时间大于等于当前日期


    }




    @Override


    public ProductionProgressDto productionProgress() {


        ProductionProgressDto productionProgressDto = new ProductionProgressDto();


        List<ProductOrder> productOrderList = productOrderMapper.selectList(new LambdaQueryWrapper<ProductOrder>());


        List<ProductOrderDto> productOrderDtoList = new ArrayList<>();


        productOrderList.forEach(productOrder -> {


            ProductOrderDto productOrderDto = productOrderMapper.productMainByOrderId(productOrder);


//            if (productOrderDto != null && productOrderDto.getPlanQuantity() != null && productOrderDto.getQuantity() != null) {


//                productOrderDto.setCompletionStatus((productOrderDto.getPlanQuantity().subtract(productOrderDto.getQuantity())).divide(productOrderDto.getPlanQuantity(), 2, RoundingMode.HALF_UP));


//            }


            productOrderDtoList.add(productOrderDto);


        });


        productionProgressDto.setCompletedOrderDetails(productOrderDtoList);


        // 1. 查询所有生产订单（可根据需求添加过滤条件，如排除已删除、已取消的订单）


        IPage<ProductOrderDto> productOrderDtoIPage = productOrderMapper.pageProductOrder(new Page<>(1, -1), new ProductOrderDto());




        // 2. 初始化汇总数据


        int totalCount = productOrderDtoIPage.getRecords().size();


        int completedCount = (int) productOrderDtoIPage.getRecords().stream().map(productOrderDto -> productOrderMapper.productMainByOrderId(productOrderDto)).filter(productOrderDto1 -> productOrderDto1.getQuantity() != null && productOrderDto1.getQuantity().compareTo(BigDecimal.ZERO) == 0).count();




        // 6. 赋值汇总数据


        productionProgressDto.setTotalOrderCount(totalCount);


        productionProgressDto.setCompletedOrderCount(completedCount);


        productionProgressDto.setUncompletedOrderCount(totalCount - completedCount);


        productionProgressDto.setCompletedProgressCount(BigDecimal.valueOf(completedCount).divide(BigDecimal.valueOf(totalCount), 2, RoundingMode.HALF_UP));


        return productionProgressDto;


    }


    @Override


    public Map<Integer, List<ProductWorkOrderDto>> workInProcessTurnover() {


        List<ProductWorkOrderDto> productWorkOrderDtoList = productWorkOrderMapper.selectProductWorkOrderDtoList();


       //根据状态区分工单的各个状态


        Map<Integer, List<ProductWorkOrderDto>> productWorkOrderDtoMap = productWorkOrderDtoList.stream().collect(Collectors.groupingBy(ProductWorkOrderDto::getStatus));




        return productWorkOrderDtoMap;




    }


}