wujianwei
1 天以前 d14994e10797ce5bc0d29668d358f7c5274dcc5b
service/src/main/java/com/ruoyi/cwgl/service/impl/ReceivableBillManagementServiceImpl.java
@@ -1,18 +1,17 @@
package com.ruoyi.cwgl.service.impl;
import java.math.BigDecimal;
import java.util.Date;
import java.util.List;
import com.ruoyi.common.utils.DateUtils;
import javax.annotation.Resource;
import com.ruoyi.cwgl.domain.ReceivableBillCustomerSummary;
import com.ruoyi.cwgl.domain.*;
import com.ruoyi.cwgl.domain.vo.ReceivableBillAgingAnalysisVo;
import com.ruoyi.cwgl.mapper.ReceivableFeeManagementMapper;
import com.ruoyi.cwgl.domain.vo.ReceivableBillAccountAnalysisVo;
import com.ruoyi.cwgl.mapper.*;
import com.ruoyi.cwgl.service.IAgingLogService;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.stereotype.Service;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.Async;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -22,13 +21,7 @@
import com.ruoyi.common.enums.DataSourceType;
import com.ruoyi.common.core.service.BaseService;
import com.ruoyi.cwgl.mapper.ReceivableBillManagementMapper;
import com.ruoyi.cwgl.domain.ReceivableBillManagement;
import com.ruoyi.cwgl.domain.ReceivableFeeManagement;
import com.ruoyi.cwgl.domain.ReceivableBillManagementLog;
import com.ruoyi.cwgl.service.IReceivableBillManagementLogService;
import com.ruoyi.cwgl.service.IReceivableBillManagementService;
import com.ruoyi.cwgl.service.IReceivableFeeManagementService;
import com.ruoyi.common.core.text.Convert;
import com.ruoyi.common.exception.ServiceException;
import com.ruoyi.common.utils.SecurityUtils;
@@ -50,7 +43,11 @@
    private ReceivableFeeManagementMapper receivableFeeManagementMapper;
    
    @Resource
    private IReceivableBillManagementLogService receivableBillManagementLogService;
    private ReceivableBillManagementLogMapper receivableBillManagementLogMapper;
    @Resource
    private AgingLogMapper agingLogMapper;
    @Resource
    private AccountLogMapper accountLogMapper;
    /**
@@ -108,6 +105,41 @@
            PageUtils.startPage(pageNum, Constants.EXPORT_PATE_SIZE);
            return selectReceivableBillManagementList(receivableBillManagement);
        });
    }   /**
     * 查询应收账单管理列表 异步 导出
     *
     * @param receivableBillManagement 应收账单管理
     * @param exportKey 导出功能的唯一标识
     * @return 应收账单管理集合
     */
    @DataSource(DataSourceType.SLAVE)
    @Async
    @Override
    public void customerSummaryExport(ReceivableBillManagement receivableBillManagement,String exportKey) {
        super.export2(ReceivableBillCustomerSummary.class,exportKey,"应收账款分析管理",(pageNum)->{
            PageUtils.startPage(pageNum, Constants.EXPORT_PATE_SIZE);
            return selectReceivableBillCustomerSummaryList(receivableBillManagement);
        });
    }  @DataSource(DataSourceType.SLAVE)
    @Async
    @Override
    public void agingAnalysisExport(ReceivableBillManagement receivableBillManagement,String exportKey) {
        super.export2(ReceivableBillAgingAnalysisVo.class,exportKey,"应收账款分析管理",(pageNum)->{
            PageUtils.startPage(pageNum, Constants.EXPORT_PATE_SIZE);
            return selectReceivableBillAgingAnalysisList(receivableBillManagement);
        });
    }
    @Async
    @Override
    public void accountAnalysisExport(ReceivableBillManagement receivableBillManagement,String exportKey) {
        super.export2(ReceivableBillAccountAnalysisVo.class,exportKey,"应收账款分析管理",(pageNum)->{
            PageUtils.startPage(pageNum, Constants.EXPORT_PATE_SIZE);
            return selectReceivableBillAccountAnalysisList(receivableBillManagement);
        });
    }
@@ -156,9 +188,44 @@
            log.setCreateBy(SecurityUtils.getUsername());
            log.setCreateTime(DateUtils.getNowDate());
            log.setOperation("修改应收账单,账单编号:" + receivableBillManagement.getSystemNo());
            receivableBillManagementLogService.insertReceivableBillManagementLog(log);
            receivableBillManagementLogMapper.insertReceivableBillManagementLog(log);
        }
        
        return result;
    } @Override
    public int aging(ReceivableBillManagement receivableBillManagement)
    {
        receivableBillManagement.setUpdateTime(DateUtils.getNowDate());
        int result = receivableBillManagementMapper.updateReceivableBillManagement(receivableBillManagement);
        // 记录操作日志
        if (result > 0) {
            AgingLog log = new AgingLog();
            log.setHeadId(receivableBillManagement.getId());
            log.setCreateBy(SecurityUtils.getUsername());
            log.setCreateTime(DateUtils.getNowDate());
            log.setOperation("编辑账龄分析信息");
            agingLogMapper.insertAgingLog(log);
        }
        return result;
    }
    @Override
    public int account(ReceivableBillManagement receivableBillManagement)
    {
        receivableBillManagement.setUpdateTime(DateUtils.getNowDate());
        int result = receivableBillManagementMapper.updateReceivableBillManagement(receivableBillManagement);
        // 记录操作日志
        if (result > 0) {
            AccountLog log = new AccountLog();
            log.setHeadId(receivableBillManagement.getId());
            log.setCreateBy(SecurityUtils.getUsername());
            log.setCreateTime(DateUtils.getNowDate());
            log.setOperation("编辑账款分析信息");
            accountLogMapper.insertAccountLog(log);
        }
        return result;
    }
@@ -242,9 +309,9 @@
            String billSystemNo = billManagement.getSystemNo();
            if (billSystemNo != null && !billSystemNo.trim().isEmpty()) {
                // 查询关联该账单的应收费用记录
                ReceivableFeeManagement queryFee = new ReceivableFeeManagement();
                queryFee.setRelatedBillNo(billSystemNo);
                List<ReceivableFeeManagement> feeList = receivableFeeManagementMapper.selectReceivableFeeManagementList(queryFee);
//                ReceivableFeeManagement queryFee = new ReceivableFeeManagement();
//                queryFee.setRelatedBillNo(billSystemNo);
//                List<ReceivableFeeManagement> feeList = receivableFeeManagementMapper.selectReceivableFeeManagementList(queryFee);
                
                // 清除关联账单编号并将状态改为0(待生成账单)
                receivableFeeManagementMapper.updateReceivableFeeManagementByRelatedBillNo(billSystemNo);
@@ -253,10 +320,15 @@
            // 记录作废操作日志
            ReceivableBillManagementLog log = new ReceivableBillManagementLog();
            log.setBillId(id);
            log.setCreateBy(SecurityUtils.getUsername());
            try {
                log.setCreateBy(SecurityUtils.getUsername());
            } catch (Exception e) {
                // 远程调用时没有登录信息,使用api作为创建人
                log.setCreateBy("api");
            }
            log.setCreateTime(DateUtils.getNowDate());
            log.setOperation("作废应收账单,账单编号:" + billManagement.getSystemNo());
            receivableBillManagementLogService.insertReceivableBillManagementLog(log);
            receivableBillManagementLogMapper.insertReceivableBillManagementLog(log);
        }
        
        return result;
@@ -303,4 +375,32 @@
        
        return result;
    }
    /**
     * 批量更新应收账单账龄分析数据
     * 直接在数据库层面计算账龄分段,避免查询大量数据到应用层
     *
     * @return 更新的记录数
     */
    @Override
    public int batchUpdateAgingAnalysisData()
    {
        return receivableBillManagementMapper.batchUpdateAgingAnalysisData();
    }
    /**
     * 查询应收账单账款分析列表
     *
     * @param receivableBillManagement 查询条件
     * @return 应收账单账款分析列表
     */
    @DataSource(DataSourceType.SLAVE)
    @Override
    public List<ReceivableBillAccountAnalysisVo> selectReceivableBillAccountAnalysisList(ReceivableBillManagement receivableBillManagement)
    {
        // 直接查询数据库中的账款分析数据
        List<ReceivableBillAccountAnalysisVo> result = receivableBillManagementMapper.selectReceivableBillAccountAnalysisList(receivableBillManagement);
        return result;
    }
}