产品供销存-后端
blame | 历史 | 补丁 | 提交 | 提交对比 | 忽略空白
liyong
2 天以前 4635770544e2d57416ad88a8983ee293919f5fec 
 src/main/java/com/ruoyi/account/service/impl/AccountingServiceImpl.java


@@ -3,27 +3,47 @@


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


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


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


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


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


import com.ruoyi.account.bean.dto.AccountReportDto;


import com.ruoyi.account.bean.dto.DeviceTypeDetail;


import com.ruoyi.account.bean.dto.DeviceTypeDistributionVO;


import com.ruoyi.account.mapper.BorrowInfoMapper;


import com.ruoyi.account.pojo.BorrowInfo;


import com.ruoyi.account.bean.dto.purchase.PurchaseInboundDto;


import com.ruoyi.account.bean.dto.purchase.PurchaseReturnDto;


import com.ruoyi.account.bean.dto.sales.SalesOutboundDto;


import com.ruoyi.account.bean.dto.sales.SalesReturnDto;


import com.ruoyi.account.bean.vo.AccountReportVo;


import com.ruoyi.account.bean.vo.purchase.PurchaseInboundVo;


import com.ruoyi.account.bean.vo.purchase.PurchaseReturnVo;


import com.ruoyi.account.bean.vo.sales.SalesOutboundVo;


import com.ruoyi.account.bean.vo.sales.SalesReturnVo;


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


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


import com.ruoyi.account.pojo.purchase.AccountPurchasePayment;


import com.ruoyi.account.pojo.sales.AccountSalesCollection;


import com.ruoyi.account.service.AccountingService;


import com.ruoyi.device.mapper.DeviceLedgerMapper;


import com.ruoyi.device.pojo.DeviceLedger;


import com.ruoyi.framework.web.domain.AjaxResult;


import com.ruoyi.procurementrecord.mapper.CustomStorageMapper;


import com.ruoyi.procurementrecord.mapper.ProcurementRecordMapper;


import com.ruoyi.procurementrecord.mapper.ProcurementRecordOutMapper;


import com.ruoyi.procurementrecord.mapper.ReturnManagementMapper;


import com.ruoyi.procurementrecord.pojo.CustomStorage;


import com.ruoyi.procurementrecord.pojo.ProcurementRecordOut;


import com.ruoyi.procurementrecord.pojo.ProcurementRecordStorage;


import com.ruoyi.purchase.mapper.PurchaseReturnOrdersMapper;


import com.ruoyi.stock.mapper.StockInRecordMapper;


import com.ruoyi.stock.mapper.StockOutRecordMapper;


import lombok.RequiredArgsConstructor;


import lombok.extern.slf4j.Slf4j;


import org.springframework.stereotype.Service;




import java.math.BigDecimal;


import java.time.LocalDate;


import java.time.LocalDateTime;


import java.time.Year;


import java.time.format.DateTimeFormatter;


import java.time.temporal.ChronoUnit;


import java.util.*;


import java.util.stream.Collectors;


@@ -35,14 +55,21 @@


@Service


@Slf4j


@RequiredArgsConstructor


public class AccountingServiceImpl {


public class AccountingServiceImpl implements AccountingService {




    private final DeviceLedgerMapper deviceLedgerMapper;


    private final BorrowInfoMapper borrowInfoMapper;


    private final CustomStorageMapper customStorageMapper;


    private final ProcurementRecordMapper procurementRecordMapper;


    private final ProcurementRecordOutMapper procurementRecordOutMapper;


    private final AccountSalesCollectionMapper accountSalesCollectionMapper;


    private final AccountPurchasePaymentMapper accountPurchasePaymentMapper;


    private final StockOutRecordMapper stockOutRecordMapper;


    private final ReturnManagementMapper returnManagementMapper;


    private final StockInRecordMapper stockInRecordMapper;


    private final PurchaseReturnOrdersMapper purchaseReturnOrdersMapper;






    @Override


    public AjaxResult total(Integer year) {


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


        map.put("deprAmount",0); // 折旧金额


@@ -75,17 +102,8 @@


            map.put("netValue",reduce.subtract(total));


        }


        // 负债


        LambdaQueryWrapper<BorrowInfo> borrowInfoLambdaQueryWrapper = new LambdaQueryWrapper<>();


        borrowInfoLambdaQueryWrapper.like(BorrowInfo::getCreateTime,year)


                .eq(BorrowInfo::getStatus,1);


        List<BorrowInfo> borrowInfos = borrowInfoMapper.selectList(borrowInfoLambdaQueryWrapper);


        if(CollectionUtils.isNotEmpty(borrowInfos)){


            BigDecimal reduce = borrowInfos.stream()


                    .map(BorrowInfo::getBorrowAmount)


                    .filter(Objects::nonNull)


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


            map.put("debt",reduce);


        }


        map.put("debt",BigDecimal.ZERO);




        // 库存资产


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


        procurementRecordStorageLambdaQueryWrapper.like(ProcurementRecordStorage::getCreateTime,year);


@@ -245,6 +263,7 @@


        return totalDepreciation.setScale(2, BigDecimal.ROUND_HALF_UP);


    }




    @Override


    public AjaxResult deviceTypeDistribution(Integer year) {


        // 2. 组装返回VO


       DeviceTypeDistributionVO vo = new DeviceTypeDistributionVO();


@@ -268,6 +287,7 @@


        return AjaxResult.success(vo);


    }




    @Override


    public AjaxResult calculateDepreciation(Page page, Integer year) {


        LambdaQueryWrapper<DeviceLedger> deviceLedgerLambdaQueryWrapper = new LambdaQueryWrapper<>();


        deviceLedgerLambdaQueryWrapper.like(DeviceLedger::getCreateTime,year)


@@ -279,4 +299,159 @@


        }


        return AjaxResult.success(deviceLedgerIPage);


    }




    @Override


    public AccountReportVo getAccountStatementDetailsByMonth(AccountReportDto accountReportDto) {


        AccountReportVo accountReportVo = new AccountReportVo();


        LocalDate start = accountReportDto.getEntryDateStart();


        LocalDate end = accountReportDto.getEntryDateEnd();


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




        // ========== 1. 顶部卡片数据 ==========


        // 1.1 总营收 = 收款单总金额


        List<AccountSalesCollection> accountSalesCollections = accountSalesCollectionMapper.selectList(


                Wrappers.<AccountSalesCollection>lambdaQuery()


                        .between(AccountSalesCollection::getCollectionDate, start, end)


        );


        BigDecimal totalIncome = Optional.of(


                accountSalesCollections.stream()


                        .map(AccountSalesCollection::getCollectionAmount)


                        .filter(Objects::nonNull)


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


        ).orElse(BigDecimal.ZERO);


        accountReportVo.setTotalIncome(totalIncome);


        // 1.2 总支出 = 付款单总金额


        List<AccountPurchasePayment> accountPurchasePayments = accountPurchasePaymentMapper.selectList(


                Wrappers.<AccountPurchasePayment>lambdaQuery()


                        .between(AccountPurchasePayment::getPaymentDate, start, end)


        );


        BigDecimal totalExpense = Optional.of(


                accountPurchasePayments.stream()


                        .map(AccountPurchasePayment::getPaymentAmount)


                        .filter(Objects::nonNull)


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


        ).orElse(BigDecimal.ZERO);


        accountReportVo.setTotalExpense(totalExpense);


        // 1.3 应收账款 = 销售出库金额合计 - 销售退货金额合计


        SalesOutboundDto salesOutboundDto = new SalesOutboundDto();


        salesOutboundDto.setStartDate(accountReportDto.getEntryDateStart());


        salesOutboundDto.setEndDate(accountReportDto.getEntryDateEnd());


        List<SalesOutboundVo> salesOutboundVos = stockOutRecordMapper.listPageAccountSales(new Page(1, -1), salesOutboundDto).getRecords();


        BigDecimal salesOutAmount = Optional.of(


                salesOutboundVos.stream()


                        .map(SalesOutboundVo::getOutboundAmount)


                        .filter(Objects::nonNull)


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


        ).orElse(BigDecimal.ZERO);


        SalesReturnDto salesReturnDto = new SalesReturnDto();


        salesReturnDto.setStartDate(accountReportDto.getEntryDateStart());


        salesReturnDto.setEndDate(accountReportDto.getEntryDateEnd());


        List<SalesReturnVo> salesReturnVos = returnManagementMapper.listPageAccountSalesReturn(new Page(1, -1), salesReturnDto).getRecords();


        BigDecimal salesReturnAmount = Optional.of(


                salesReturnVos.stream()


                        .map(SalesReturnVo::getRefundAmount)


                        .filter(Objects::nonNull)


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


        ).orElse(BigDecimal.ZERO);


        accountReportVo.setAccountsReceivable(salesOutAmount.subtract(salesReturnAmount));


        // 1.4 应付账款 = 采购入库金额合计 - 采购退货金额合计


        PurchaseInboundDto purchaseInboundDto = new PurchaseInboundDto();


        purchaseInboundDto.setStartDate(accountReportDto.getEntryDateStart());


        purchaseInboundDto.setEndDate(accountReportDto.getEntryDateEnd());


        List<PurchaseInboundVo> purchaseInboundVos = stockInRecordMapper.listPageAccountPurchase(new Page(1, -1), purchaseInboundDto).getRecords();


        BigDecimal purchaseInAmount = Optional.of(


                purchaseInboundVos.stream()


                        .map(PurchaseInboundVo::getInboundAmount)


                        .filter(Objects::nonNull)


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


        ).orElse(BigDecimal.ZERO);


        PurchaseReturnDto purchaseReturnDto = new PurchaseReturnDto();


        purchaseReturnDto.setStartDate(accountReportDto.getEntryDateStart());


        purchaseReturnDto.setEndDate(accountReportDto.getEntryDateEnd());


        List<PurchaseReturnVo> purchaseReturnVos = purchaseReturnOrdersMapper.listPageAccountPurchaseReturn(new Page(1, -1), purchaseReturnDto).getRecords();


        BigDecimal purchaseReturnAmount = Optional.of(


                purchaseReturnVos.stream()


                        .map(PurchaseReturnVo::getTotalAmount)


                        .filter(Objects::nonNull)


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


        ).orElse(BigDecimal.ZERO);


        accountReportVo.setAccountsPayable(purchaseInAmount.subtract(purchaseReturnAmount));


        // 1.5 净利润 = 总营收 - 总支出


        BigDecimal netProfit = totalIncome.subtract(totalExpense);


        accountReportVo.setNetRevenue(netProfit);




        // ========== 2. 折线图：月度营收/支出/净利润趋势 ==========


        Map<String, BigDecimal> monthIncomeMap = new HashMap<>();


        Map<String, BigDecimal> monthExpenseMap = new HashMap<>();


        // 月度营收


        accountSalesCollections.forEach(item -> {


            String month = item.getCollectionDate().format(monthFormatter);


            monthIncomeMap.put(month, monthIncomeMap.getOrDefault(month, BigDecimal.ZERO)


                    .add(Optional.ofNullable(item.getCollectionAmount()).orElse(BigDecimal.ZERO)));


        });


        // 月度支出


        accountPurchasePayments.forEach(item -> {


            String month = item.getPaymentDate().format(monthFormatter);


            monthExpenseMap.put(month, monthExpenseMap.getOrDefault(month, BigDecimal.ZERO)


                    .add(Optional.ofNullable(item.getPaymentAmount()).orElse(BigDecimal.ZERO)));


        });


        // 生成连续月份列表


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


        LocalDate current = start.withDayOfMonth(1);


        while (!current.isAfter(end.withDayOfMonth(1))) {


            monthList.add(current.format(monthFormatter));


            current = current.plusMonths(1);


        }


        // 组装趋势数据


        List<AccountReportVo.MonthlyTrendVO> trendList = new ArrayList<>();


        for (String month : monthList) {


            BigDecimal income = monthIncomeMap.getOrDefault(month, BigDecimal.ZERO);


            BigDecimal expense = monthExpenseMap.getOrDefault(month, BigDecimal.ZERO);


            AccountReportVo.MonthlyTrendVO trend = new AccountReportVo.MonthlyTrendVO();


            trend.setMonth(month);


            trend.setIncome(income);


            trend.setExpense(expense);


            trend.setProfit(income.subtract(expense));


            trendList.add(trend);


        }


        accountReportVo.setMonthlyTrendList(trendList);




        // ========== 3. 柱状图：月度应收/应付数据 ==========


        Map<String, BigDecimal> monthReceivableMap = new HashMap<>();


        Map<String, BigDecimal> monthPayableMap = new HashMap<>();


        // 月度应收（销售出库-退货）


        salesOutboundVos.forEach(item -> {


            String month = item.getShippingDate().format(monthFormatter);


            monthReceivableMap.put(month, monthReceivableMap.getOrDefault(month, BigDecimal.ZERO)


                    .add(Optional.ofNullable(item.getOutboundAmount()).orElse(BigDecimal.ZERO)));


        });


        salesReturnVos.forEach(item -> {


            String month = item.getMakeTime().format(monthFormatter);


            monthReceivableMap.put(month, monthReceivableMap.getOrDefault(month, BigDecimal.ZERO)


                    .subtract(Optional.ofNullable(item.getRefundAmount()).orElse(BigDecimal.ZERO)));


        });




        // 月度应付（采购入库-退货）


        purchaseInboundVos.forEach(item -> {


            String month = item.getInboundDate().format(monthFormatter);


            monthPayableMap.put(month, monthPayableMap.getOrDefault(month, BigDecimal.ZERO)


                    .add(Optional.ofNullable(item.getInboundAmount()).orElse(BigDecimal.ZERO)));


        });


        purchaseReturnVos.forEach(item -> {


            String month = item.getPreparedAt().format(monthFormatter);


            monthPayableMap.put(month, monthPayableMap.getOrDefault(month, BigDecimal.ZERO)


                    .subtract(Optional.ofNullable(item.getTotalAmount()).orElse(BigDecimal.ZERO)));


        });


        // 组装应收应付数据


        List<AccountReportVo.ReceivablePayableVO> rpList = new ArrayList<>();


        for (String month : monthList) {


            AccountReportVo.ReceivablePayableVO rp = new AccountReportVo.ReceivablePayableVO();


            rp.setMonth(month);


            rp.setReceivable(monthReceivableMap.getOrDefault(month, BigDecimal.ZERO));


            rp.setPayable(monthPayableMap.getOrDefault(month, BigDecimal.ZERO));


            rpList.add(rp);


        }


        accountReportVo.setReceivablePayableList(rpList);


        return accountReportVo;


    }


}