package com.ruoyi.cwgl.service.impl;
|
|
import java.util.List;
|
|
import com.ruoyi.common.utils.DateUtils;
|
import javax.annotation.Resource;
|
|
import lombok.NonNull;
|
import org.springframework.transaction.annotation.Transactional;
|
import org.springframework.stereotype.Service;
|
import org.springframework.scheduling.annotation.Async;
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
import com.ruoyi.common.utils.PageUtils;
|
import com.ruoyi.common.constant.Constants;
|
import com.ruoyi.common.annotation.DataSource;
|
import com.ruoyi.common.enums.DataSourceType;
|
import com.ruoyi.common.core.service.BaseService;
|
|
import com.ruoyi.cwgl.mapper.FundFlowClaimDetailMapper;
|
import com.ruoyi.cwgl.mapper.FundFlowMapper;
|
import com.ruoyi.cwgl.domain.FundFlowClaimDetail;
|
import com.ruoyi.cwgl.domain.FundFlow;
|
import com.ruoyi.cwgl.domain.ReceivableBillSettlementDetail;
|
import com.ruoyi.cwgl.domain.PayableBillSettlementDetail;
|
import com.ruoyi.cwgl.domain.ReceivableBillManagement;
|
import com.ruoyi.cwgl.domain.PayableBillManagement;
|
import com.ruoyi.cwgl.service.IFundFlowClaimDetailService;
|
import com.ruoyi.cwgl.service.IReceivableBillSettlementDetailService;
|
import com.ruoyi.cwgl.service.IPayableBillSettlementDetailService;
|
import com.ruoyi.cwgl.service.IReceivableBillManagementService;
|
import com.ruoyi.cwgl.service.IPayableBillManagementService;
|
import com.ruoyi.common.core.text.Convert;
|
import com.ruoyi.common.utils.SecurityUtils;
|
import java.math.BigDecimal;
|
|
/**
|
* 账单认领明细Service业务层处理
|
*
|
* @author ruoyi
|
* @date 2026-01-12
|
*/
|
@Service
|
@Transactional(rollbackFor = Exception.class)
|
public class FundFlowClaimDetailServiceImpl extends BaseService<FundFlowClaimDetailMapper, FundFlowClaimDetail> implements IFundFlowClaimDetailService
|
{
|
protected final Logger logger = LoggerFactory.getLogger(getClass());
|
@Resource
|
private FundFlowClaimDetailMapper fundFlowClaimDetailMapper;
|
|
@Resource
|
private FundFlowMapper fundFlowMapper;
|
|
@Resource
|
private IReceivableBillSettlementDetailService receivableBillSettlementDetailService;
|
|
@Resource
|
private IPayableBillSettlementDetailService payableBillSettlementDetailService;
|
|
@Resource
|
private IReceivableBillManagementService receivableBillManagementService;
|
|
@Resource
|
private IPayableBillManagementService payableBillManagementService;
|
|
|
/**
|
* 查询账单认领明细
|
*
|
* @param id 账单认领明细ID
|
* @return 账单认领明细
|
*/
|
@DataSource(DataSourceType.SLAVE)
|
@Override
|
public FundFlowClaimDetail selectFundFlowClaimDetailById(Integer id)
|
{
|
return fundFlowClaimDetailMapper.selectFundFlowClaimDetailById(id);
|
}
|
|
/**
|
* 查询账单认领明细 记录数
|
*
|
* @param fundFlowClaimDetail 账单认领明细
|
* @return 账单认领明细集合
|
*/
|
@DataSource(DataSourceType.SLAVE)
|
@Override
|
public int selectFundFlowClaimDetailCount(FundFlowClaimDetail fundFlowClaimDetail)
|
{
|
return fundFlowClaimDetailMapper.selectFundFlowClaimDetailCount(fundFlowClaimDetail);
|
}
|
|
/**
|
* 查询账单认领明细列表
|
*
|
* @param fundFlowClaimDetail 账单认领明细
|
* @return 账单认领明细
|
*/
|
@DataSource(DataSourceType.SLAVE)
|
@Override
|
public List<FundFlowClaimDetail> selectFundFlowClaimDetailList(FundFlowClaimDetail fundFlowClaimDetail)
|
{
|
return fundFlowClaimDetailMapper.selectFundFlowClaimDetailList(fundFlowClaimDetail);
|
}
|
|
/**
|
* 查询账单认领明细列表 异步 导出
|
*
|
* @param fundFlowClaimDetail 账单认领明细
|
* @param exportKey 导出功能的唯一标识
|
* @return 账单认领明细集合
|
*/
|
@DataSource(DataSourceType.SLAVE)
|
@Async
|
@Override
|
public void export(FundFlowClaimDetail fundFlowClaimDetail,String exportKey) {
|
|
super.export(FundFlowClaimDetail.class,exportKey,"fundFlowClaimDetailData",(pageNum)->{
|
PageUtils.startPage(pageNum, Constants.EXPORT_PATE_SIZE);
|
return selectFundFlowClaimDetailList(fundFlowClaimDetail);
|
});
|
}
|
|
|
/**
|
* 新增账单认领明细
|
*
|
* @param fundFlowClaimDetail 账单认领明细
|
* @return 结果
|
*/
|
@Override
|
public int insertFundFlowClaimDetail(FundFlowClaimDetail fundFlowClaimDetail)
|
{
|
fundFlowClaimDetail.setCreateTime(DateUtils.getNowDate());
|
return fundFlowClaimDetailMapper.insertFundFlowClaimDetail(fundFlowClaimDetail);
|
}
|
|
/**
|
* 新增账单认领明细[批量]
|
*
|
* @param fundFlowClaimDetails 账单认领明细
|
* @return 结果
|
*/
|
@Override
|
public int insertFundFlowClaimDetailBatch(List<FundFlowClaimDetail> fundFlowClaimDetails)
|
{
|
int rows = fundFlowClaimDetailMapper.insertFundFlowClaimDetailBatch(fundFlowClaimDetails);
|
return rows;
|
}
|
|
/**
|
* 修改账单认领明细
|
*
|
* @param fundFlowClaimDetail 账单认领明细
|
* @return 结果
|
*/
|
@Override
|
public int updateFundFlowClaimDetail(FundFlowClaimDetail fundFlowClaimDetail)
|
{
|
fundFlowClaimDetail.setUpdateTime(DateUtils.getNowDate());
|
return fundFlowClaimDetailMapper.updateFundFlowClaimDetail(fundFlowClaimDetail);
|
}
|
|
/**
|
* 修改账单认领明细[批量]
|
*
|
* @param fundFlowClaimDetails 账单认领明细
|
* @return 结果
|
*/
|
@Override
|
public int updateFundFlowClaimDetailBatch(List<FundFlowClaimDetail> fundFlowClaimDetails){
|
return fundFlowClaimDetailMapper.updateFundFlowClaimDetailBatch(fundFlowClaimDetails);
|
}
|
|
/**
|
* 删除账单认领明细对象
|
*
|
* @param ids 需要删除的数据ID
|
* @return 结果
|
*/
|
@Override
|
public int deleteFundFlowClaimDetailByIds(String ids)
|
{
|
|
return deleteFundFlowClaimDetailByIds(Convert.toIntArray(ids));
|
}
|
|
/**
|
* 删除账单认领明细对象
|
*
|
*
|
* @param ids 需要删除的数据ID
|
* @return 结果
|
*/
|
@Override
|
public int deleteFundFlowClaimDetailByIds(Integer[] ids)
|
{
|
|
|
return fundFlowClaimDetailMapper.deleteFundFlowClaimDetailByIds(ids);
|
}
|
|
/**
|
* 删除账单认领明细信息
|
*
|
* @param id 账单认领明细ID
|
* @return 结果
|
*/
|
@Override
|
public int deleteFundFlowClaimDetailById(Integer id)
|
{
|
|
return fundFlowClaimDetailMapper.deleteFundFlowClaimDetailById(id);
|
}
|
|
/**
|
* 账单认领
|
*
|
* @param fundFlowId 资金流水ID
|
* @param claimDetails 账单认领明细列表
|
* @return 结果
|
*/
|
@Override
|
public int claimBill(Integer fundFlowId, FundFlowClaimDetail claimDetail)
|
{
|
if (fundFlowId == null) {
|
throw new RuntimeException("资金流水ID不能为空");
|
}
|
|
if (claimDetail == null ) {
|
throw new RuntimeException("认领明细列表不能为空");
|
}
|
|
//金额
|
BigDecimal claimAmount = claimDetail.getClaimAmount();
|
if (claimAmount == null || claimAmount.compareTo(BigDecimal.ZERO) <= 0) {
|
throw new RuntimeException("认领金额必须大于0");
|
|
}
|
|
// 查询资金流水信息
|
FundFlow fundFlow = fundFlowMapper.selectFundFlowById(fundFlowId);
|
|
// 根据总认领金额与交易金额的比较设置状态
|
String newStatus = getString(fundFlowId, claimDetail, fundFlow);
|
|
// 更新资金流水状态和已认领金额
|
fundFlow.setStatus(newStatus);
|
fundFlow.setClaimedAmount(fundFlow.getClaimedAmount().add(claimAmount)); // 设置已认领金额
|
fundFlow.setUpdateTime(DateUtils.getNowDate());
|
int updateResult = fundFlowMapper.updateFundFlow(fundFlow);
|
if (updateResult <= 0) {
|
throw new RuntimeException("更新资金流水状态失败，ID: " + fundFlowId);
|
}
|
|
|
|
|
// 设置资金流水ID
|
claimDetail.setFundFlowId(fundFlowId);
|
// 设置认领日期
|
claimDetail.setClaimDate(DateUtils.getNowDate());
|
// 设置创建时间
|
claimDetail.setCreateTime(DateUtils.getNowDate());
|
|
|
int insertResult = fundFlowClaimDetailMapper.insertFundFlowClaimDetail(claimDetail);
|
|
// 新增：创建结算明细并更新账单状态
|
if (insertResult > 0) {
|
|
|
createSettlementDetailsAndUpdateBillStatus(claimDetail, fundFlow);
|
}
|
|
return insertResult;
|
}
|
|
/**
|
* 根据资金流水ID、认领详情列表和资金流水对象获取状态字符串
|
* @param fundFlowId 资金流水ID，用于标识特定的资金流水记录
|
* @param claimDetail 认领详情列表，包含所有认领金额信息
|
* @param fundFlow 资金流水对象，包含交易金额等关键信息
|
* @return 返回处理后的状态字符串
|
* @throws RuntimeException 当资金流水对象为null时抛出异常
|
*/
|
private static @NonNull String getString(Integer fundFlowId, FundFlowClaimDetail claimDetail, FundFlow fundFlow) {
|
// 检查资金流水对象是否为空，如果为空则抛出异常
|
if (fundFlow == null) {
|
throw new RuntimeException("资金流水不存在，ID: " + fundFlowId);
|
}
|
|
// 计算总认领金额
|
BigDecimal totalClaimAmount = claimDetail.getClaimAmount();
|
|
|
// 验证总认领金额不能超过交易金额
|
return getString(fundFlow, totalClaimAmount);
|
|
}
|
|
private static @NonNull String getString(FundFlow fundFlow, BigDecimal totalClaimAmount) {
|
BigDecimal transactionAmount = fundFlow.getTransactionAmount();
|
if (totalClaimAmount.compareTo(transactionAmount) > 0) {
|
throw new RuntimeException("总认领金额不能超过交易金额。交易金额: " + transactionAmount + ", 总认领金额: " + totalClaimAmount);
|
}
|
|
// 根据总认领金额与交易金额的比较设置状态
|
String newStatus;
|
if (totalClaimAmount.compareTo(transactionAmount) < 0) {
|
// 总认领金额小于交易金额，状态改为2（部分认领）
|
newStatus = "2";
|
} else {
|
// 总认领金额等于交易金额，状态改为3（完全认领）
|
newStatus = "3";
|
}
|
return newStatus;
|
}
|
|
/**
|
* 创建结算明细并更新账单状态
|
*/
|
private void createSettlementDetailsAndUpdateBillStatus(FundFlowClaimDetail claimDetail, FundFlow fundFlow) {
|
|
String billNo = claimDetail.getBillNo();
|
BigDecimal claimAmount = claimDetail.getClaimAmount();
|
Integer claimDetailId = claimDetail.getId();
|
|
// 根据关联企业类型判断是应收账单还是应付账单
|
if (fundFlow.getIncomeExpenseFlag().equals(0)) {
|
// 应收账单
|
createReceivableSettlementDetail(billNo, claimAmount, fundFlow, claimDetailId);
|
} else {
|
// 应付账单
|
createPayableSettlementDetail(billNo, claimAmount, fundFlow, claimDetailId);
|
|
}
|
}
|
|
/**
|
* 创建应收账单结算明细
|
*/
|
private void createReceivableSettlementDetail(String billNo, BigDecimal claimAmount, FundFlow fundFlow, Integer claimDetailId) {
|
try {
|
// 根据账单编号查询应收账单
|
ReceivableBillManagement bill = receivableBillManagementService.selectReceivableBillManagementBySystemNo(billNo);
|
if (bill != null) {
|
// 创建结算明细
|
ReceivableBillSettlementDetail settlementDetail = new ReceivableBillSettlementDetail();
|
settlementDetail.setBillId(bill.getId());
|
settlementDetail.setClaimDetailId(claimDetailId); // 设置认领明细ID
|
settlementDetail.setReceiptAmount(claimAmount);
|
settlementDetail.setReceiptDate(fundFlow.getTransactionDate());
|
settlementDetail.setSettlementMethod("银行转账"); // 根据实际情况设置
|
settlementDetail.setCreateBy(SecurityUtils.getUsername());
|
settlementDetail.setCreateTime(DateUtils.getNowDate());
|
|
// 插入结算明细（会自动更新账单状态）
|
receivableBillSettlementDetailService.insertReceivableBillSettlementDetail(settlementDetail);
|
|
logger.info("成功创建应收账单结算明细，账单编号：{}，金额：{}，认领明细ID：{}", billNo, claimAmount, claimDetailId);
|
} else {
|
logger.warn("未找到对应的应收账单，账单编号：{}", billNo);
|
}
|
} catch (Exception e) {
|
logger.error("创建应收账单结算明细失败，账单编号：{}", billNo, e);
|
// 这里可以选择抛出异常或记录日志，但不中断整个认领流程
|
}
|
}
|
|
/**
|
* 创建应付账单结算明细
|
*/
|
private void createPayableSettlementDetail(String billNo, BigDecimal claimAmount, FundFlow fundFlow, Integer claimDetailId) {
|
try {
|
// 根据账单编号查询应付账单
|
PayableBillManagement bill = payableBillManagementService.selectPayableBillManagementBySystemNo(billNo);
|
if (bill != null) {
|
// 创建结算明细
|
PayableBillSettlementDetail settlementDetail = new PayableBillSettlementDetail();
|
settlementDetail.setBillId(bill.getId());
|
settlementDetail.setClaimDetailId(claimDetailId); // 设置认领明细ID
|
settlementDetail.setPaymentAmount(claimAmount);
|
settlementDetail.setPaymentDate(fundFlow.getTransactionDate());
|
settlementDetail.setSettlementMethod("银行转账"); // 根据实际情况设置
|
settlementDetail.setCreateBy(SecurityUtils.getUsername());
|
settlementDetail.setCreateTime(DateUtils.getNowDate());
|
|
// 插入结算明细（会自动更新账单状态）
|
payableBillSettlementDetailService.insertPayableBillSettlementDetail(settlementDetail);
|
|
logger.info("成功创建应付账单结算明细，账单编号：{}，金额：{}，认领明细ID：{}", billNo, claimAmount, claimDetailId);
|
} else {
|
logger.warn("未找到对应的应付账单，账单编号：{}", billNo);
|
}
|
} catch (Exception e) {
|
logger.error("创建应付账单结算明细失败，账单编号：{}", billNo, e);
|
// 这里可以选择抛出异常或记录日志，但不中断整个认领流程
|
}
|
}
|
|
|
}
|
