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


@@ -10,8 +10,10 @@


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.project.system.domain.SysDept;


@@ -67,6 +69,9 @@


    private ProcurementRecordMapper procurementRecordStorageMapper;




    @Autowired


    private CustomStorageMapper customStorageMapper;




    @Autowired


    private QualityInspectMapper qualityStatisticsMapper;




    @Autowired


@@ -95,53 +100,56 @@


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


            return homeBusinessDto;


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


        }


        // 合计合同金额


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


            return homeBusinessDto;


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


        }




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


@@ -149,7 +157,7 @@


                .map(ProcurementRecordOut::getInboundNum)


                .filter(Objects::nonNull)


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


        BigDecimal stock = stockAmount.subtract(outboundAmount);


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


        // 获取当天入库数量


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


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


@@ -159,9 +167,6 @@


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


@@ -374,29 +379,31 @@


        }


        // 应收


        List<SalesLedger> salesLedgers = salesLedgerMapper.selectList(new LambdaQueryWrapper<SalesLedger>()


                .ge(SalesLedger::getEntryDate, startDate)


                .lt(SalesLedger::getEntryDate, endDate)


//                .ge(SalesLedger::getEntryDate, startDate)


//                .lt(SalesLedger::getEntryDate, endDate)


        );


        BigDecimal receivableMoney = salesLedgers.stream().map(SalesLedger::getContractAmount).reduce(BigDecimal.ZERO, BigDecimal::add);


        // 应付


        List<PurchaseLedger> procurementRecords = purchaseLedgerMapper.selectList(new LambdaQueryWrapper<PurchaseLedger>()


                .ge(PurchaseLedger::getEntryDate, startDate)


                .lt(PurchaseLedger::getEntryDate, endDate)


//                .ge(PurchaseLedger::getEntryDate, startDate)


//                .lt(PurchaseLedger::getEntryDate, endDate)


        );


        BigDecimal payableMoney = procurementRecords.stream().map(PurchaseLedger::getContractAmount).reduce(BigDecimal.ZERO, BigDecimal::add);


        // 预收


        List<ReceiptPayment> receiptPayments = receiptPaymentMapper.selectList(new LambdaQueryWrapper<ReceiptPayment>()


                .ge(ReceiptPayment::getReceiptPaymentDate, startDate)


                .lt(ReceiptPayment::getReceiptPaymentDate, endDate));


//                .ge(ReceiptPayment::getReceiptPaymentDate, startDate)


//                .lt(ReceiptPayment::getReceiptPaymentDate, endDate)


        );


        BigDecimal advanceMoney = receiptPayments.stream().map(ReceiptPayment::getReceiptPaymentAmount).reduce(BigDecimal.ZERO, BigDecimal::add);


        // 预付


        List<PaymentRegistration> paymentRegistrations = paymentRegistrationMapper.selectList(new LambdaQueryWrapper<PaymentRegistration>()


                .ge(PaymentRegistration::getPaymentDate, startDate)


                .lt(PaymentRegistration::getPaymentDate, endDate));


//                .ge(PaymentRegistration::getPaymentDate, startDate)


//                .lt(PaymentRegistration::getPaymentDate, endDate)


        );


        BigDecimal prepayMoney = paymentRegistrations.stream().map(PaymentRegistration::getCurrentPaymentAmount).reduce(BigDecimal.ZERO, BigDecimal::add);


        StatisticsReceivablePayableDto statisticsReceivablePayableDto = new StatisticsReceivablePayableDto();


        statisticsReceivablePayableDto.setPayableMoney(payableMoney);


        statisticsReceivablePayableDto.setReceivableMoney(receivableMoney);


        statisticsReceivablePayableDto.setPayableMoney(payableMoney.subtract(prepayMoney));


        statisticsReceivablePayableDto.setReceivableMoney(receivableMoney.subtract(advanceMoney));


        statisticsReceivablePayableDto.setAdvanceMoney(advanceMoney);


        statisticsReceivablePayableDto.setPrepayMoney(prepayMoney);