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


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


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


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


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


import com.ruoyi.account.mapper.AccountIncomeMapper;


import com.ruoyi.account.pojo.AccountExpense;


import com.ruoyi.home.mapper.HomeMapper;


import com.ruoyi.account.mapper.AccountExpenseMapper;


import com.ruoyi.account.mapper.purchase.AccountPurchasePaymentMapper;


import com.ruoyi.account.mapper.sales.AccountSalesCollectionMapper;


import com.ruoyi.approve.mapper.ApproveProcessMapper;


import com.ruoyi.approve.pojo.ApproveProcess;


import com.ruoyi.basic.mapper.CustomerMapper;


@@ -25,33 +23,27 @@


import com.ruoyi.dto.MapDto;


import com.ruoyi.framework.security.LoginUser;


import com.ruoyi.home.dto.*;


import com.ruoyi.home.mapper.HomeMapper;


import com.ruoyi.home.service.HomeService;


import com.ruoyi.production.mapper.ProductionOperationTaskMapper;


import com.ruoyi.production.mapper.ProductionAccountMapper;


import com.ruoyi.production.mapper.ProductionOrderMapper;


import com.ruoyi.production.mapper.ProductionProductInputMapper;


import com.ruoyi.production.mapper.ProductionProductOutputMapper;


import com.ruoyi.production.bean.dto.ProductionProductOutputDto;


import com.ruoyi.production.mapper.*;


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


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


import com.ruoyi.purchase.mapper.PaymentRegistrationMapper;


import com.ruoyi.purchase.mapper.PurchaseLedgerMapper;


import com.ruoyi.purchase.pojo.PaymentRegistration;


import com.ruoyi.purchase.pojo.PurchaseLedger;


import com.ruoyi.quality.mapper.QualityInspectMapper;


import com.ruoyi.quality.mapper.QualityUnqualifiedMapper;


import com.ruoyi.quality.pojo.QualityInspect;


import com.ruoyi.quality.pojo.QualityUnqualified;


import com.ruoyi.sales.mapper.ReceiptPaymentMapper;


import com.ruoyi.sales.mapper.SalesLedgerMapper;


import com.ruoyi.sales.mapper.SalesLedgerProductMapper;


import com.ruoyi.sales.pojo.ReceiptPayment;


import com.ruoyi.sales.pojo.SalesLedger;


import com.ruoyi.sales.pojo.SalesLedgerProduct;


import com.ruoyi.staff.mapper.StaffOnJobMapper;


import com.ruoyi.staff.pojo.StaffOnJob;


import com.ruoyi.stock.mapper.StockInventoryMapper;


import lombok.RequiredArgsConstructor;


import lombok.extern.slf4j.Slf4j;


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


import org.springframework.stereotype.Service;


import org.springframework.util.CollectionUtils;




@@ -71,73 +63,51 @@


 */


@Service


@Slf4j


@RequiredArgsConstructor


public class HomeServiceImpl implements HomeService {




    @Autowired


    private SalesLedgerMapper salesLedgerMapper;


    private final SalesLedgerMapper salesLedgerMapper;




    @Autowired


    private PurchaseLedgerMapper purchaseLedgerMapper;


    private final PurchaseLedgerMapper purchaseLedgerMapper;




    @Autowired


    private SalesLedgerProductMapper salesLedgerProductMapper;


    private final SalesLedgerProductMapper salesLedgerProductMapper;




    @Autowired


    private StockInventoryMapper stockInventoryMapper;


    private final StockInventoryMapper stockInventoryMapper;




    @Autowired


    private QualityInspectMapper qualityStatisticsMapper;


    private final QualityInspectMapper qualityStatisticsMapper;




    @Autowired


    private ApproveProcessMapper approveProcessMapper;


    private final ApproveProcessMapper approveProcessMapper;




    @Autowired


    private ReceiptPaymentMapper receiptPaymentMapper;


    private final SysDeptMapper sysDeptMapper;




    @Autowired


    private PaymentRegistrationMapper paymentRegistrationMapper;


    private final NoticeMapper noticeMapper;




    @Autowired


    private SysDeptMapper sysDeptMapper;


    private final ProductionOrderMapper productionOrderMapper;




    @Autowired


    private NoticeMapper noticeMapper;


    private final ProductMapper productMapper;




    @Autowired


    private ProductionOrderMapper productionOrderMapper;


    private final StaffOnJobMapper staffOnJobMapper;




    @Autowired


    private ProductMapper productMapper;


    private final CustomerMapper customerMapper;




    @Autowired


    private StaffOnJobMapper staffOnJobMapper;


    private final SupplierManageMapper supplierManageMapper;




    @Autowired


    private CustomerMapper customerMapper;


    private final HomeMapper homeMapper;




    @Autowired


    private SupplierManageMapper supplierManageMapper;


    private final ProductionProductOutputMapper productionProductOutputMapper;




    @Autowired


    private HomeMapper homeMapper;


    private final QualityInspectMapper qualityInspectMapper;




    @Autowired


    private ProductionProductOutputMapper productionProductOutputMapper;


    private final QualityUnqualifiedMapper qualityUnqualifiedMapper;




    @Autowired


    private QualityInspectMapper qualityInspectMapper;


    private final ProductionOperationTaskMapper productionOperationTaskMapper;




    @Autowired


    private QualityUnqualifiedMapper qualityUnqualifiedMapper;


    private final AccountPurchasePaymentMapper accountPurchasePaymentMapper;


    private final AccountSalesCollectionMapper accountSalesCollectionMapper;




    @Autowired


    private ProductionOperationTaskMapper productionOperationTaskMapper;


    


    @Autowired


    private AccountExpenseMapper accountExpenseMapper;


    private final ProductionAccountMapper productionAccountMapper;




    @Autowired


    private AccountIncomeMapper accountIncomeMapper;


    private final ProductionProductInputMapper productionProductInputMapper;




    @Override


    public HomeBusinessDto business() {


@@ -161,12 +131,8 @@


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


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


        }


        // 创建LambdaQueryWrapper


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


@@ -189,14 +155,8 @@


                    .filter(Objects::nonNull)


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




            //  待付款总金额


            BigDecimal unReceiptPaymentAmount = salesLedgerProductsCopy.stream()


                    .map(SalesLedgerProduct::getPendingTicketsTotal)


                    .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.setMonthPurchaseHaveMoney(BigDecimal.ZERO.setScale(2, RoundingMode.HALF_UP).toString());


        }


        // 统计库存


        BigDecimal stockQuantityTotal = stockInventoryMapper.selectTotal();


@@ -434,6 +394,7 @@


     */


    @Override


    public StatisticsReceivablePayableDto statisticsReceivablePayable(Integer type) {


        StatisticsReceivablePayableDto statisticsReceivablePayableDto = new StatisticsReceivablePayableDto();


        LocalDate today = LocalDate.now();


        LocalDate startDate = null;


        LocalDate endDate = null;


@@ -460,48 +421,14 @@


                break;


        }


        // 应收


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


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


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


        );


        // BigDecimal receivableMoney =


        // salesLedgers.stream().map(SalesLedger::getContractAmount).reduce(BigDecimal.ZERO,


        // BigDecimal::add);


        BigDecimal receivableMoney = sumAmount(salesLedgers, SalesLedger::getContractAmount);




        // 应付


        List<PurchaseLedger> procurementRecords = purchaseLedgerMapper


                .selectList(new LambdaQueryWrapper<PurchaseLedger>()


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


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


                );


        // BigDecimal payableMoney =


        // procurementRecords.stream().map(PurchaseLedger::getContractAmount).reduce(BigDecimal.ZERO,


        // BigDecimal::add);


        BigDecimal payableMoney = sumAmount(procurementRecords, PurchaseLedger::getContractAmount);




        // 预收


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


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


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


        );


        // BigDecimal advanceMoney =


        // receiptPayments.stream().map(ReceiptPayment::getReceiptPaymentAmount).reduce(BigDecimal.ZERO,


        // BigDecimal::add);


        BigDecimal advanceMoney = sumAmount(receiptPayments, ReceiptPayment::getReceiptPaymentAmount);




        // 预付


        List<PaymentRegistration> paymentRegistrations = paymentRegistrationMapper


                .selectList(new LambdaQueryWrapper<PaymentRegistration>()


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


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


                );


        // BigDecimal prepayMoney =


        // paymentRegistrations.stream().map(PaymentRegistration::getCurrentPaymentAmount).reduce(BigDecimal.ZERO,


        // BigDecimal::add);


        BigDecimal prepayMoney = sumAmount(paymentRegistrations, PaymentRegistration::getCurrentPaymentAmount);


        StatisticsReceivablePayableDto statisticsReceivablePayableDto = new StatisticsReceivablePayableDto();


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


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


        statisticsReceivablePayableDto.setAdvanceMoney(advanceMoney);


        statisticsReceivablePayableDto.setPrepayMoney(prepayMoney);








        return statisticsReceivablePayableDto;


    }


@@ -514,7 +441,7 @@


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


    }




    @Autowired




    private DeviceRepairMapper deviceRepairMapper;




    @Override


@@ -1184,13 +1111,9 @@


        String endStr = endDate.format(DateTimeFormatter.ofPattern("yyyy-MM-dd"));




        // 2. 查询数据


        List<IncomeExpenseAnalysisDto> incomeList = accountIncomeMapper.selectIncomeStats(startStr, endStr, dateFormat);


        List<IncomeExpenseAnalysisDto> incomeList = accountSalesCollectionMapper.selectIncomeStats(startStr, endStr, dateFormat);


        List<IncomeExpenseAnalysisDto> expenseList = accountPurchasePaymentMapper.selectPayment(startStr, endStr, dateFormat);




        // List<IncomeExpenseAnalysisDto> purchaseList =


        // purchaseLedgerMapper.selectPurchaseStats(startStr, endStr, dateFormat);




        List<IncomeExpenseAnalysisDto> expenseList = accountExpenseMapper.selectAccountExpenseStats(startStr, endStr,


                dateFormat);




        // 3. 转 Map（自动合并）


        Map<String, BigDecimal> incomeMap = incomeList.stream()


@@ -1199,11 +1122,7 @@


                        IncomeExpenseAnalysisDto::getAmount,


                        BigDecimal::add));




        // Map<String, BigDecimal> purchaseMap = purchaseList.stream()


        // .collect(Collectors.toMap(


        // IncomeExpenseAnalysisDto::getDateStr,


        // IncomeExpenseAnalysisDto::getAmount,


        // BigDecimal::add));






        Map<String, BigDecimal> expenseMap = expenseList.stream()


                .collect(Collectors.toMap(


@@ -1217,18 +1136,12 @@


        for (String dateStr : xAxis) {


            Map<String, Object> item = new HashMap<>();


            item.put("date", dateStr);




            // 收入


            BigDecimal income = incomeMap.getOrDefault(dateStr, BigDecimal.ZERO);


            item.put("income", income.setScale(2, RoundingMode.HALF_UP));




            // 支出 = 采购 + 财务支出


            // BigDecimal purchase = purchaseMap.getOrDefault(dateStr, BigDecimal.ZERO);


            // 支出


            BigDecimal expense = expenseMap.getOrDefault(dateStr, BigDecimal.ZERO);


            // BigDecimal totalExpense = purchase.add(expense);


            BigDecimal totalExpense = expense;




            item.put("expense", totalExpense.setScale(2, RoundingMode.HALF_UP));


            item.put("expense", expense.setScale(2, RoundingMode.HALF_UP));




            result.add(item);


        }


@@ -1255,8 +1168,8 @@


        String startStr = startDate.format(DateTimeFormatter.ofPattern("yyyy-MM-dd"));


        String endStr = endDate.format(DateTimeFormatter.ofPattern("yyyy-MM-dd"));




        List<IncomeExpenseAnalysisDto> incomeList = accountIncomeMapper.selectIncomeStats(startStr, endStr, dateFormat);


        List<IncomeExpenseAnalysisDto> expenseList = accountExpenseMapper.selectAccountExpenseStats(startStr, endStr, dateFormat);


        List<IncomeExpenseAnalysisDto> incomeList = accountSalesCollectionMapper.selectIncomeStats(startStr, endStr, dateFormat);


        List<IncomeExpenseAnalysisDto> expenseList = accountPurchasePaymentMapper.selectPayment(startStr, endStr, dateFormat);




        Map<String, BigDecimal> incomeMap = incomeList.stream().collect(Collectors


                .toMap(IncomeExpenseAnalysisDto::getDateStr, IncomeExpenseAnalysisDto::getAmount, BigDecimal::add));


@@ -1292,11 +1205,6 @@


            rawMaterialDto.setName("原材料");


            rawMaterialDto.setValue(rawMaterialAmount != null ? rawMaterialAmount.toString() : "0");


            result.add(rawMaterialDto);




            List<MapDto> expenseList = accountExpenseMapper.selectExpenseComposition(null, null);


            if (expenseList != null) {


                result.addAll(expenseList);


            }


        }




        BigDecimal total = BigDecimal.ZERO;


@@ -1347,34 +1255,6 @@


            return dto;


        }




        BigDecimal collected = products.stream()


                .map(SalesLedgerProduct::getInvoiceTotal)


                .filter(Objects::nonNull)


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


        dto.setMonthlyIncome(collected);




        BigDecimal overdue = products.stream()


                .map(SalesLedgerProduct::getPendingInvoiceTotal)


                .filter(Objects::nonNull)


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


        dto.setOverdueNum(overdue);




        BigDecimal total = collected.add(overdue);




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


            String collectionRate = collected.divide(total, 4, RoundingMode.HALF_UP)


                    .multiply(new BigDecimal("100"))


                    .setScale(2, RoundingMode.HALF_UP)


                    .toString();


            dto.setCollectionRate(collectionRate);




            String overdueRate = overdue.divide(total, 4, RoundingMode.HALF_UP)


                    .multiply(new BigDecimal("100"))


                    .setScale(2, RoundingMode.HALF_UP)


                    .toString();


            dto.setOverdueRate(overdueRate);


        }




        return dto;


    }




@@ -1406,38 +1286,14 @@


                if (p.getTaxInclusiveTotalPrice() != null) {


                    rawMaterialCost = rawMaterialCost.add(p.getTaxInclusiveTotalPrice());


                }




                if (p.getTicketsTotal() != null) {


                    paidAmount = paidAmount.add(p.getTicketsTotal());


                }




                if (p.getPendingTicketsTotal() != null) {


                    pendingAmount = pendingAmount.add(p.getPendingTicketsTotal());


                }


            }


        }




        // 其他费用


        LambdaQueryWrapper<AccountExpense> expenseWrapper = new LambdaQueryWrapper<>();


        expenseWrapper.ge(AccountExpense::getExpenseDate,


                java.sql.Date.valueOf(currentMonth.atDay(1)));


        expenseWrapper.le(AccountExpense::getExpenseDate,


                java.sql.Date.valueOf(currentMonth.atEndOfMonth()));




        List<AccountExpense> expenses = accountExpenseMapper.selectList(expenseWrapper);




        BigDecimal otherExpense = BigDecimal.ZERO;


        if (!CollectionUtils.isEmpty(expenses)) {


            for (AccountExpense e : expenses) {


                if (e.getExpenseMoney() != null) {


                    otherExpense = otherExpense.add(e.getExpenseMoney());


                }


            }


        }




        // 月度总支出


        // BigDecimal monthlyExpenditure = rawMaterialCost.add(otherExpense);


        BigDecimal monthlyExpenditure = otherExpense;


        BigDecimal monthlyExpenditure = BigDecimal.ZERO;


        dto.setMonthlyExpenditure(monthlyExpenditure);




        // 已付款 ÷（已付款 + 待付款）


@@ -1460,13 +1316,6 @@


        List<SalesLedgerProduct> salesProducts = salesLedgerProductMapper.selectList(salesWrapper);




        BigDecimal revenue = BigDecimal.ZERO;


        if (!CollectionUtils.isEmpty(salesProducts)) {


            for (SalesLedgerProduct s : salesProducts) {


                if (s.getInvoiceAmount() != null) {


                    revenue = revenue.add(s.getInvoiceAmount());


                }


            }


        }




        // 毛利润 & 利润率


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


@@ -1488,9 +1337,6 @@




        return dto;


    }




    @Autowired


    private ProductionProductInputMapper productionProductInputMapper;




    @Override


    public List<InputOutputAnalysisDto> inputOutputAnalysis(Integer type) {


@@ -1522,7 +1368,8 @@


        String endStr = endDate.atStartOfDay()


                .format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"));




        List<Map<String, Object>> inputList = productionProductInputMapper.selectInputStats(startStr, endStr);


//        List<Map<String, Object>> inputList = productionProductInputMapper.selectInputStats(startStr, endStr);


        List<Map<String, Object>> inputList = null;


        List<Map<String, Object>> outputList = productionProductOutputMapper.selectDailyOutputStats(startStr, endStr);




        Map<String, InputOutputAnalysisDto> dateMap = new HashMap<>();


@@ -1655,7 +1502,7 @@




        List<ProductionTaskStatisticsDto> startList = productionOperationTaskMapper.selectTaskStartStats(startStr, endStr);




        List<com.ruoyi.production.dto.ProductionProductOutputDto> outputList = productionProductOutputMapper


        List<ProductionProductOutputDto> outputList = productionProductOutputMapper


                .selectOutputStats(startStr, endStr);




        Map<String, WorkOrderEfficiencyDto> dateMap = new HashMap<>();


@@ -1675,7 +1522,7 @@




        // 完工数量和良品率


        if (!CollectionUtils.isEmpty(outputList)) {


            for (com.ruoyi.production.dto.ProductionProductOutputDto item : outputList) {


            for (ProductionProductOutputDto item : outputList) {


                if (item.getCreateTime() != null) {


                    String date = item.getCreateTime().toLocalDate().toString();


                    WorkOrderEfficiencyDto dto = dateMap.getOrDefault(date, new WorkOrderEfficiencyDto());


@@ -1748,8 +1595,6 @@


                .collect(Collectors.toList());


    }




    @Autowired


    private ProductionAccountMapper salesLedgerProductionAccountingMapper;




    @Override


    public List<ProductionAccountingDto> productionAccountingAnalysis(Integer type) {


@@ -1778,7 +1623,7 @@




        String endStr = endDate.plusDays(1).atStartOfDay().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"));




        List<Map<String, Object>> wagesList = salesLedgerProductionAccountingMapper.selectDailyWagesStats(startStr,


        List<Map<String, Object>> wagesList = productionAccountMapper.selectDailyWagesStats(startStr,


                endStr);




        if (CollectionUtils.isEmpty(wagesList)) {