产品供销存-后端
blame | 历史 | 补丁 | 提交 | 提交对比 | 忽略空白
maven
2025-12-12 17132f3dd27f5bd97a081bbd9e08a37e9e8f25af 
 src/main/java/com/ruoyi/home/service/impl/HomeServiceImpl.java


@@ -1,6 +1,9 @@


package com.ruoyi.home.service.impl;




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


import com.baomidou.mybatisplus.core.toolkit.Wrappers;


import com.ruoyi.account.pojo.AccountExpense;


import com.ruoyi.account.pojo.AccountIncome;


import com.ruoyi.approve.mapper.ApproveProcessMapper;


import com.ruoyi.approve.pojo.ApproveProcess;


import com.ruoyi.common.utils.SecurityUtils;


@@ -10,12 +13,12 @@


import com.ruoyi.home.service.HomeService;


import com.ruoyi.lavorissue.mapper.LavorIssueMapper;


import com.ruoyi.lavorissue.pojo.LaborIssue;


import com.ruoyi.procurementrecord.mapper.CustomStorageMapper;


import com.ruoyi.procurementrecord.mapper.ProcurementRecordMapper;


import com.ruoyi.procurementrecord.mapper.ProcurementRecordOutMapper;


import com.ruoyi.procurementrecord.pojo.CustomStorage;


import com.ruoyi.procurementrecord.pojo.ProcurementRecordOut;


import com.ruoyi.procurementrecord.pojo.ProcurementRecordStorage;


import com.ruoyi.production.mapper.SalesLedgerWorkMapper;


import com.ruoyi.production.pojo.SalesLedgerWork;


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


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


import com.ruoyi.purchase.mapper.PaymentRegistrationMapper;


@@ -40,6 +43,7 @@


import java.text.ParseException;


import java.text.SimpleDateFormat;


import java.time.*;


import java.time.format.DateTimeFormatter;


import java.time.temporal.TemporalAdjusters;


import java.util.*;


import java.util.concurrent.atomic.AtomicInteger;


@@ -69,9 +73,6 @@


    private ProcurementRecordMapper procurementRecordStorageMapper;




    @Autowired


    private CustomStorageMapper customStorageMapper;




    @Autowired


    private QualityInspectMapper qualityStatisticsMapper;




    @Autowired


@@ -89,6 +90,9 @@


    @Autowired


    private SysDeptMapper sysDeptMapper;




    @Autowired


    private SalesLedgerWorkMapper salesLedgerWorkMapper;;




    @Override


    public HomeBusinessDto business() {


        // 构建结果


@@ -100,56 +104,53 @@


        salesLedgerLambdaQueryWrapper.ge(SalesLedger::getEntryDate, currentMonth.atDay(1).atStartOfDay())  // 大于等于本月第一天


                .lt(SalesLedger::getEntryDate, currentMonth.plusMonths(1).atDay(1).atStartOfDay()); // 小于下月第一天


        List<SalesLedger> salesLedgers = salesLedgerMapper.selectList(salesLedgerLambdaQueryWrapper);


        if(!CollectionUtils.isEmpty(salesLedgers)){


            // 合计合同金额


            BigDecimal contractAmount = salesLedgers.stream().map(SalesLedger::getContractAmount)


                    .filter(Objects::nonNull)


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


            LambdaQueryWrapper<SalesLedgerProduct> salesLedgerProductMapperLambdaQueryWrapper = new LambdaQueryWrapper<SalesLedgerProduct>();


            salesLedgerProductMapperLambdaQueryWrapper.eq(SalesLedgerProduct::getType, 1)


                    .in(SalesLedgerProduct::getSalesLedgerId, salesLedgers.stream().map(SalesLedger::getId).collect(Collectors.toList()));


            List<SalesLedgerProduct> salesLedgerProducts = salesLedgerProductMapper.selectList(salesLedgerProductMapperLambdaQueryWrapper);


            // 未开票金额


            BigDecimal noInvoiceAmountTotal = salesLedgerProducts.stream().map(SalesLedgerProduct::getNoInvoiceAmount)


                    .filter(Objects::nonNull)


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


            homeBusinessDto.setMonthSaleMoney(contractAmount.setScale(2, RoundingMode.HALF_UP).toString());


            homeBusinessDto.setMonthSaleHaveMoney(noInvoiceAmountTotal.setScale(2, RoundingMode.HALF_UP).toString());


        if(CollectionUtils.isEmpty(salesLedgers)){


            return homeBusinessDto;


        }


        // 合计合同金额


        BigDecimal contractAmount = salesLedgers.stream().map(SalesLedger::getContractAmount)


                .filter(Objects::nonNull)


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


        LambdaQueryWrapper<SalesLedgerProduct> salesLedgerProductMapperLambdaQueryWrapper = new LambdaQueryWrapper<SalesLedgerProduct>();


        salesLedgerProductMapperLambdaQueryWrapper.eq(SalesLedgerProduct::getType, 1)


                .in(SalesLedgerProduct::getSalesLedgerId, salesLedgers.stream().map(SalesLedger::getId).collect(Collectors.toList()));


        List<SalesLedgerProduct> salesLedgerProducts = salesLedgerProductMapper.selectList(salesLedgerProductMapperLambdaQueryWrapper);


        // 未开票金额


        BigDecimal noInvoiceAmountTotal = salesLedgerProducts.stream().map(SalesLedgerProduct::getNoInvoiceAmount)


                .filter(Objects::nonNull)


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


        homeBusinessDto.setMonthSaleMoney(contractAmount.setScale(2, RoundingMode.HALF_UP).toString());


        homeBusinessDto.setMonthSaleHaveMoney(noInvoiceAmountTotal.setScale(2, RoundingMode.HALF_UP).toString());


        // 创建LambdaQueryWrapper


        LambdaQueryWrapper<PurchaseLedger> queryWrapper = new LambdaQueryWrapper<>();


        queryWrapper.ge(PurchaseLedger::getEntryDate, currentMonth.atDay(1).atStartOfDay())  // 大于等于本月第一天


                .lt(PurchaseLedger::getEntryDate, currentMonth.plusMonths(1).atDay(1).atStartOfDay()); // 小于下月第一天




        // 执行查询并计算总和


        List<PurchaseLedger> purchaseLedgers = purchaseLedgerMapper.selectList(queryWrapper);


        if(!CollectionUtils.isEmpty(purchaseLedgers)){


            LambdaQueryWrapper<SalesLedgerProduct> salesLedgerProductMapperLambdaQueryWrapperCopy = new LambdaQueryWrapper<SalesLedgerProduct>();


            salesLedgerProductMapperLambdaQueryWrapperCopy.eq(SalesLedgerProduct::getType, 2)


                    .in(SalesLedgerProduct::getSalesLedgerId, purchaseLedgers.stream().map(PurchaseLedger::getId).collect(Collectors.toList()));


            List<SalesLedgerProduct> salesLedgerProductsCopy = salesLedgerProductMapper.selectList(salesLedgerProductMapperLambdaQueryWrapperCopy);


            // 合计合同金额


            BigDecimal receiveAmount = purchaseLedgers.stream()


                    .map(PurchaseLedger::getContractAmount)


                    .filter(Objects::nonNull)


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


            // 未开票金额


            BigDecimal unReceiptPaymentAmount = salesLedgerProductsCopy.stream()


                    .map(SalesLedgerProduct::getNoInvoiceAmount)


                    .filter(Objects::nonNull)


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


            homeBusinessDto.setMonthPurchaseMoney(receiveAmount.setScale(2, RoundingMode.HALF_UP).toString());


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


        if(CollectionUtils.isEmpty(purchaseLedgers)){


            return homeBusinessDto;


        }




        LambdaQueryWrapper<SalesLedgerProduct> salesLedgerProductMapperLambdaQueryWrapperCopy = new LambdaQueryWrapper<SalesLedgerProduct>();


        salesLedgerProductMapperLambdaQueryWrapper.eq(SalesLedgerProduct::getType, 2)


                .in(SalesLedgerProduct::getSalesLedgerId, purchaseLedgers.stream().map(PurchaseLedger::getId).collect(Collectors.toList()));


        List<SalesLedgerProduct> salesLedgerProductsCopy = salesLedgerProductMapper.selectList(salesLedgerProductMapperLambdaQueryWrapperCopy);


        // 合计合同金额


        BigDecimal receiveAmount = purchaseLedgers.stream()


                .map(PurchaseLedger::getContractAmount)


                .filter(Objects::nonNull)


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


        // 未开票金额


        BigDecimal unReceiptPaymentAmount = salesLedgerProductsCopy.stream()


                .map(SalesLedgerProduct::getNoInvoiceAmount)


                .filter(Objects::nonNull)


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




        // 统计库存


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


@@ -157,7 +158,7 @@


                .map(ProcurementRecordOut::getInboundNum)


                .filter(Objects::nonNull)


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


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


        BigDecimal stock = stockAmount.subtract(outboundAmount);


        // 获取当天入库数量


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


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


@@ -167,6 +168,9 @@


                .map(ProcurementRecordStorage::getInboundNum)


                .filter(Objects::nonNull)


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




        homeBusinessDto.setMonthPurchaseMoney(receiveAmount.setScale(2, RoundingMode.HALF_UP).toString());


        homeBusinessDto.setMonthPurchaseHaveMoney(unReceiptPaymentAmount.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;


@@ -266,50 +270,83 @@




    @Override


    public QualityStatisticsDto qualityStatistics() {


        // 获取一周数据


        // 获取当前时间


        // 获取近四个月数据（往前推三个月，共4个完整月份）


        LocalDate today = LocalDate.now();


        // 获取本周周一


        LocalDate startOfWeek = today.with(DayOfWeek.MONDAY);


        // 获取本周周日


        LocalDate endOfWeek = today.with(DayOfWeek.SUNDAY);


        LambdaQueryWrapper<QualityInspect> qualityInspectLambdaQueryWrapper = new LambdaQueryWrapper<>();


        qualityInspectLambdaQueryWrapper.ge(QualityInspect::getCheckTime, startOfWeek)


                .gt(QualityInspect::getCheckTime, endOfWeek);


        List<QualityInspect> qualityInspects = qualityStatisticsMapper.selectList(qualityInspectLambdaQueryWrapper);


        // 定义日期格式化器（用于显示“年月”格式）


        DateTimeFormatter monthFormatter = DateTimeFormatter.ofPattern("yyyy-MM");




        QualityStatisticsDto qualityStatisticsDto = new QualityStatisticsDto();


        qualityStatisticsDto.setSupplierNum(qualityInspects.stream().filter(item -> item.getInspectType().equals(0)).map(QualityInspect::getQuantity).reduce(BigDecimal.ZERO, BigDecimal::add));


        qualityStatisticsDto.setProcessNum(qualityInspects.stream().filter(item -> item.getInspectType().equals(1)).map(QualityInspect::getQuantity).reduce(BigDecimal.ZERO, BigDecimal::add));


        qualityStatisticsDto.setFactoryNum(qualityInspects.stream().filter(item -> item.getInspectType().equals(2)).map(QualityInspect::getQuantity).reduce(BigDecimal.ZERO, BigDecimal::add));


        List<QualityStatisticsItem> qualityStatisticsItems = new ArrayList<>();


        for (int j = 1; j < 8; j++) {


            LocalDate endTime = startOfWeek.plusDays(j);


            LocalDate startTime = endTime.minusDays(1);


            QualityStatisticsItem qualityStatisticsItem = new QualityStatisticsItem();


            qualityStatisticsItem.setDate(startTime.toString());


            qualityStatisticsItem.setSupplierNum(qualityInspects.stream()


                    .filter(item -> item.getInspectType().equals(0) && "不合格".equals(item.getCheckResult())


                            && (startTime.isEqual(item.getCheckTime().toInstant().atZone(ZoneId.systemDefault()).toLocalDate()) || startTime.isAfter(item.getCheckTime().toInstant().atZone(ZoneId.systemDefault()).toLocalDate()))


                            && endTime.isBefore(item.getCheckTime().toInstant().atZone(ZoneId.systemDefault()).toLocalDate()))




        BigDecimal supplierNum = new BigDecimal(0);


        BigDecimal factoryNum = new BigDecimal(0);


        BigDecimal processNum = new BigDecimal(0);


        // 循环4次，分别统计近4个月的数据（当前月、前1个月、前2个月、前3个月）


        for (int i = 3; i >= 0; i--) {


            // 计算当前循环对应的月份（i=0：当前月，i=1：前1个月，以此类推）


            LocalDate currentMonth = today.minusMonths(i);


            // 当月的开始日期（每月1号）


            LocalDate monthStart = currentMonth.withDayOfMonth(1);


            // 当月的结束日期（每月最后一天）


            LocalDate monthEnd = currentMonth.withDayOfMonth(currentMonth.lengthOfMonth());




            // 构建当月的查询条件（如果想一次性查全4个月数据再内存筛选，可优化为先查全再循环筛选）


            LambdaQueryWrapper<QualityInspect> queryWrapper = new LambdaQueryWrapper<>();


            queryWrapper.ge(QualityInspect::getCheckTime, monthStart)


                    .le(QualityInspect::getCheckTime, monthEnd); // 筛选当月数据


            List<QualityInspect> monthInspects = qualityStatisticsMapper.selectList(queryWrapper);


            BigDecimal reduce = monthInspects.stream()


                    .filter(inspect -> inspect.getInspectType().equals(0))


                    .map(QualityInspect::getQuantity)


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


            );


            qualityStatisticsItem.setFactoryNum(qualityInspects.stream()


                    .filter(item -> item.getInspectType().equals(1) && "不合格".equals(item.getCheckResult())


                            && (startTime.isEqual(item.getCheckTime().toInstant().atZone(ZoneId.systemDefault()).toLocalDate()) || startTime.isAfter(item.getCheckTime().toInstant().atZone(ZoneId.systemDefault()).toLocalDate()))


                            && endTime.isBefore(item.getCheckTime().toInstant().atZone(ZoneId.systemDefault()).toLocalDate()))


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


            supplierNum = supplierNum.add(reduce);


            BigDecimal reduce1 = monthInspects.stream()


                    .filter(inspect -> inspect.getInspectType().equals(1))


                    .map(QualityInspect::getQuantity)


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


            );


            qualityStatisticsItem.setProcessNum(qualityInspects.stream()


                    .filter(item -> item.getInspectType().equals(2) && "不合格".equals(item.getCheckResult())


                            && (startTime.isEqual(item.getCheckTime().toInstant().atZone(ZoneId.systemDefault()).toLocalDate()) || startTime.isAfter(item.getCheckTime().toInstant().atZone(ZoneId.systemDefault()).toLocalDate()))


                            && endTime.isBefore(item.getCheckTime().toInstant().atZone(ZoneId.systemDefault()).toLocalDate()))


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


            processNum= processNum.add(reduce1);


            BigDecimal reduce2 = monthInspects.stream()


                    .filter(inspect -> inspect.getInspectType().equals(2))


                    .map(QualityInspect::getQuantity)


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


            qualityStatisticsItems.add(qualityStatisticsItem);


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


            factoryNum = factoryNum.add(reduce2);




            // 构建当月统计项


            QualityStatisticsItem item = new QualityStatisticsItem();


            item.setDate(monthStart.format(monthFormatter)); // 日期显示为“年月”（如 2025-10）




            // 1. 供应商检验（类型0）- 合格数量


            BigDecimal supplierQualified = monthInspects.stream()


                    .filter(inspect -> inspect.getInspectType().equals(0)


                            && "合格".equals(inspect.getCheckResult()))


                    .map(QualityInspect::getQuantity)


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


            item.setSupplierNum(supplierQualified);




            // 2. 工序检验（类型1）- 合格数量


            BigDecimal processQualified = monthInspects.stream()


                    .filter(inspect -> inspect.getInspectType().equals(1)


                            && "合格".equals(inspect.getCheckResult()))


                    .map(QualityInspect::getQuantity)


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


            item.setProcessNum(processQualified);




            // 3. 工厂检验（类型2）- 合格数量


            BigDecimal factoryQualified = monthInspects.stream()


                    .filter(inspect -> inspect.getInspectType().equals(2)


                            && "合格".equals(inspect.getCheckResult()))


                    .map(QualityInspect::getQuantity)


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


            item.setFactoryNum(factoryQualified);




            qualityStatisticsItems.add(item);


        }


        // 统计近4个月总数据（所有月份汇总）


        qualityStatisticsDto.setProcessNum(processNum);


        qualityStatisticsDto.setSupplierNum(supplierNum);


        qualityStatisticsDto.setFactoryNum(factoryNum);


        qualityStatisticsDto.setItem(qualityStatisticsItems);




        return qualityStatisticsDto;


    }




@@ -409,4 +446,218 @@




        return statisticsReceivablePayableDto;


    }




    @Override


    public QualityProductQualifiedRateDto qualityProductQualifiedRate() {


        QualityProductQualifiedRateDto qualityProductQualifiedRateDto = new QualityProductQualifiedRateDto();


        List<QualityInspect> qualityInspects = qualityStatisticsMapper.selectList(null);


        if(!CollectionUtils.isEmpty(qualityInspects)){


            // 原材料合格率


            long rawwMaterialCount = qualityInspects.stream().filter(qualityInspect -> qualityInspect.getInspectType() == 0).count();


            long count = qualityInspects.stream().filter(qualityInspect -> "合格".equals(qualityInspect.getCheckResult()) && qualityInspect.getInspectType() == 0).count();


            if(count > 0){


                qualityProductQualifiedRateDto.setRawMaterialQualifiedRate(new BigDecimal(rawwMaterialCount)


                        .divide(new BigDecimal( count), 4, RoundingMode.HALF_UP)


                        .multiply(BigDecimal.valueOf(100.0)));


            }


            // 过程合格率


            long processCount = qualityInspects.stream().filter(qualityInspect -> qualityInspect.getInspectType() == 1).count();


            long countOne = qualityInspects.stream().filter(qualityInspect -> "合格".equals(qualityInspect.getCheckResult()) && qualityInspect.getInspectType() == 1).count();


            if(countOne > 0){


                qualityProductQualifiedRateDto.setProcessQualifiedRate(new BigDecimal(processCount)


                        .divide(new BigDecimal( countOne), 4, RoundingMode.HALF_UP)


                        .multiply(BigDecimal.valueOf(100.0)));


            }


            // 出厂合格率


            long factoryCount = qualityInspects.stream().filter(qualityInspect -> qualityInspect.getInspectType() == 2).count();


            long countTwo = qualityInspects.stream().filter(qualityInspect -> "合格".equals(qualityInspect.getCheckResult()) && qualityInspect.getInspectType() == 2).count();


            if(countTwo > 0){


                qualityProductQualifiedRateDto.setFactoryQualifiedRate(new BigDecimal(factoryCount)


                        .divide(new BigDecimal( countTwo), 4, RoundingMode.HALF_UP)


                        .multiply(BigDecimal.valueOf(100.0)));


            }


        }


        // 库存周转率统计当月出库（使用）的物料总数量÷平均的库存物料总数量×100%。）


        // 获取当前月


        LocalDate today = LocalDate.now();


        LocalDate startDate = today.with(TemporalAdjusters.firstDayOfMonth());


        LocalDate endDate = today.with(TemporalAdjusters.lastDayOfMonth());


        // 获取当前月出库（使用）的物料总数量


        List<ProcurementRecordOut> procurementRecordOuts = procurementRecordOutMapper.selectList(new LambdaQueryWrapper<ProcurementRecordOut>()


                .ge(ProcurementRecordOut::getCreateTime, startDate)


                .lt(ProcurementRecordOut::getCreateTime, endDate));


        // 获取当前月入库的物料总数量


        List<ProcurementRecordStorage> procurementRecordStorages = procurementRecordStorageMapper.selectList(new LambdaQueryWrapper<ProcurementRecordStorage>()


                .ge(ProcurementRecordStorage::getCreateTime, startDate)


                .lt(ProcurementRecordStorage::getCreateTime, endDate));


        BigDecimal reduce = procurementRecordOuts.stream()


                .map(ProcurementRecordOut::getInboundNum)


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


        BigDecimal reduceOne = procurementRecordStorages.stream()


                .map(ProcurementRecordStorage::getInboundNum)


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


        if(reduce.compareTo(BigDecimal.ZERO) > 0){


            qualityProductQualifiedRateDto.setInventoryTurnoverRate(reduceOne.divide(reduce, 4, RoundingMode.HALF_UP)


                    .multiply(BigDecimal.valueOf(100.0)));


        }




        return qualityProductQualifiedRateDto;


    }




    @Override


    public QualityStatisticsDto inventoryStatistics() {


        // 获取近四个月数据（往前推三个月，共4个完整月份）


        LocalDate today = LocalDate.now();


        // 定义日期格式化器（用于显示“年月”格式）


        DateTimeFormatter monthFormatter = DateTimeFormatter.ofPattern("yyyy-MM");




        QualityStatisticsDto qualityStatisticsDto = new QualityStatisticsDto();


        List<QualityStatisticsItem> qualityStatisticsItems = new ArrayList<>();




        BigDecimal supplierNum = new BigDecimal(0); //入库数量


        BigDecimal factoryNum = new BigDecimal(0); //出库数量


        // 循环4次，分别统计近4个月的数据（当前月、前1个月、前2个月、前3个月）


        for (int i = 3; i >= 0; i--) {


            // 计算当前循环对应的月份（i=0：当前月，i=1：前1个月，以此类推）


            LocalDate currentMonth = today.minusMonths(i);


            // 当月的开始日期（每月1号）


            LocalDate monthStart = currentMonth.withDayOfMonth(1);


            // 当月的结束日期（每月最后一天）


            LocalDate monthEnd = currentMonth.withDayOfMonth(currentMonth.lengthOfMonth());




            // 入库数量


            // 构建当月的查询条件（如果想一次性查全4个月数据再内存筛选，可优化为先查全再循环筛选）


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


            queryWrapper.ge(ProcurementRecordStorage::getCreateTime, monthStart)


                    .le(ProcurementRecordStorage::getCreateTime, monthEnd); // 筛选当月数据


            List<ProcurementRecordStorage> monthInspects = procurementRecordStorageMapper.selectList(queryWrapper);


            // 出库数量


            LambdaQueryWrapper<ProcurementRecordOut> queryWrapper1 = new LambdaQueryWrapper<>();


            queryWrapper1.ge(ProcurementRecordOut::getCreateTime, monthStart)


                    .le(ProcurementRecordOut::getCreateTime, monthEnd);


            List<ProcurementRecordOut> monthInspects1 = procurementRecordOutMapper.selectList(queryWrapper1);


            BigDecimal reduce = monthInspects.stream()


                    .map(ProcurementRecordStorage::getInboundNum)


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


            supplierNum = supplierNum.add(reduce);


            BigDecimal reduce1 = monthInspects1.stream()


                    .map(ProcurementRecordOut::getInboundNum)


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


            factoryNum= factoryNum.add(reduce1);




            // 构建当月统计项


            QualityStatisticsItem item = new QualityStatisticsItem();


            item.setDate(monthStart.format(monthFormatter)); // 日期显示为“年月”（如 2025-10）




            // 1. 供应商检验（类型0）- 合格数量


            BigDecimal supplierQualified = monthInspects.stream()


                    .map(ProcurementRecordStorage::getInboundNum)


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


            item.setSupplierNum(supplierQualified);




            // 3. 工厂检验（类型2）- 合格数量


            BigDecimal factoryQualified = monthInspects1.stream()


                    .map(ProcurementRecordOut::getInboundNum)


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


            item.setFactoryNum(factoryQualified);




            qualityStatisticsItems.add(item);


        }


        // 统计近4个月总数据（所有月份汇总）


        qualityStatisticsDto.setSupplierNum(supplierNum);


        qualityStatisticsDto.setFactoryNum(factoryNum);


        qualityStatisticsDto.setItem(qualityStatisticsItems);




        return qualityStatisticsDto;


    }




    @Override


    public Map<String, List<String>> productionStatistics() {


        // 获取最近四个月（当前月 + 前3个月）的时间范围


        LocalDate today = LocalDate.now();


        DateTimeFormatter monthFormatter = DateTimeFormatter.ofPattern("yyyy-MM"); // 年月格式化器


        Map<String, List<String>> result = new HashMap<>();


        List<String> months = new ArrayList<>(); // 存储年月（如 2025-12、2025-11）


        List<String> totalIncomeList = new ArrayList<>(); // 每月总收入


        List<String> totalExpenseList = new ArrayList<>(); // 每月总支出


        List<String> netIncomeList = new ArrayList<>(); // 每月净收入（收入-支出）




        // 步骤1：计算近4个月的年月列表（当前月、前1月、前2月、前3月）


        List<String> targetMonths = new ArrayList<>();


        for (int i = 0; i < 4; i++) {


            LocalDate currentMonth = today.minusMonths(i);


            String monthStr = currentMonth.format(monthFormatter);


            targetMonths.add(monthStr);


        }


        // 反转列表，确保顺序为「前3月 → 当前月」（可选，按需求调整顺序）


        Collections.reverse(targetMonths);




        // 步骤2：一次性查询近4个月所有收入数据，按“年月”分组汇总


        LocalDate fourMonthsAgo = today.minusMonths(3).withDayOfMonth(1); // 近4个月起始日（前3月1号）


        LocalDate currentMonthEnd = today.withDayOfMonth(today.lengthOfMonth()); // 当前月结束日


        ZoneId zoneId = ZoneId.of("Asia/Shanghai");


        // 查询近4个月所有收入


        List<SalesLedgerWork> allIncomes = salesLedgerWorkMapper.selectList(


                Wrappers.<SalesLedgerWork>lambdaQuery()


                        .ge(SalesLedgerWork::getSchedulingDate, fourMonthsAgo.toString()) // 大于等于起始日


                        .le(SalesLedgerWork::getSchedulingDate, currentMonthEnd.toString()) // 小于等于结束日


        );




        // 待生产


        Map<String, BigDecimal> monthlyIncomeMap = allIncomes.stream()


                .filter(income -> income.getSchedulingNum() != null && income.getStatus().equals(1)) // 过滤空金额


                .collect(Collectors.groupingBy(


                        income -> {


                            // 将输入时间（字符串）转换为LocalDate，再格式化为年月


                            return income.getSchedulingDate().format(monthFormatter);


                        },


                        Collectors.reducing(BigDecimal.ZERO, SalesLedgerWork::getSchedulingNum, BigDecimal::add)


                ));




        // 生产中


        Map<String, BigDecimal> monthlyExpenseMap = allIncomes.stream()


                .filter(income -> income.getSchedulingNum() != null && income.getStatus().equals(2)) // 过滤空金额


                .collect(Collectors.groupingBy(


                        income -> {


                            // 将输入时间（字符串）转换为LocalDate，再格式化为年月


                            return income.getSchedulingDate().format(monthFormatter);


                        },


                        Collectors.reducing(BigDecimal.ZERO, SalesLedgerWork::getSchedulingNum, BigDecimal::add)


                ));




        // 已报工


        Map<String, BigDecimal> successIncomeMap = allIncomes.stream()


                .filter(income -> income.getSchedulingNum() != null && income.getStatus().equals(3)) // 过滤空金额


                .collect(Collectors.groupingBy(


                        income -> {


                            // 将输入时间（字符串）转换为LocalDate，再格式化为年月


                            return income.getSchedulingDate().format(monthFormatter);


                        },


                        Collectors.reducing(BigDecimal.ZERO, SalesLedgerWork::getSchedulingNum, BigDecimal::add)


                ));




        // 步骤4：循环4个目标月份，填充统计数据（无数据时默认为0）


        for (String month : targetMonths) {


            // 待生产


            BigDecimal totalIncome = monthlyIncomeMap.getOrDefault(month, BigDecimal.ZERO);


            // 生产中


            BigDecimal totalExpense = monthlyExpenseMap.getOrDefault(month, BigDecimal.ZERO);


            // 已报工


            BigDecimal netIncome =  successIncomeMap.getOrDefault(month, BigDecimal.ZERO);




            // 填充列表


            months.add(month);


            totalIncomeList.add(totalIncome.toString());


            totalExpenseList.add(totalExpense.toString());


            netIncomeList.add(netIncome.toString());


        }




        // 组装结果


        result.put("days", months); // 年月（如 ["2025-09", "2025-10", "2025-11", "2025-12"]）


        result.put("totalIncome", totalIncomeList); // 待生产


        result.put("totalExpense", totalExpenseList); // 生产中


        result.put("netIncome", netIncomeList); // 已报工




        return result;


    }


}