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.FundFlowLog;
|
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.IFundFlowLogService;
|
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;
|
|
@Resource
|
private IFundFlowLogService fundFlowLogService;
|
|
|
/**
|
* 查询账单认领明细
|
*
|
* @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)
|
{
|
if (ids == null || ids.length == 0) {
|
throw new RuntimeException("删除的认领明细ID不能为空");
|
}
|
|
// 由于删除只会有一条记录，取第一条进行处理
|
Integer id = ids[0];
|
FundFlowClaimDetail claimDetail = fundFlowClaimDetailMapper.selectFundFlowClaimDetailById(id);
|
if (claimDetail == null) {
|
throw new RuntimeException("未找到要删除的认领明细记录，ID: " + id);
|
}
|
|
Integer fundFlowId = claimDetail.getFundFlowId();
|
BigDecimal deleteAmount = claimDetail.getClaimAmount();
|
|
// 查询资金流水信息
|
FundFlow fundFlow = fundFlowMapper.selectFundFlowById(fundFlowId);
|
if (fundFlow == null) {
|
throw new RuntimeException("资金流水不存在，ID: " + fundFlowId);
|
}
|
|
// 更新资金流水的已认领金额
|
BigDecimal newClaimedAmount = fundFlow.getClaimedAmount().subtract(deleteAmount);
|
if (newClaimedAmount.compareTo(BigDecimal.ZERO) < 0) {
|
newClaimedAmount = BigDecimal.ZERO;
|
}
|
|
// 根据新的认领金额设置状态
|
String newStatus =fundFlow.getStatus();
|
if (newClaimedAmount.compareTo(BigDecimal.ZERO) == 0) {
|
// 已认领金额为0，状态改为1（未认领）
|
newStatus = "1";
|
} else if (newClaimedAmount.compareTo(fundFlow.getTransactionAmount()) < 0) {
|
// 已认领金额小于交易金额，状态改为2（部分认领）
|
newStatus = "2";
|
}
|
|
// 更新资金流水状态和已认领金额
|
fundFlow.setStatus(newStatus);
|
fundFlow.setClaimedAmount(newClaimedAmount);
|
fundFlow.setUpdateTime(DateUtils.getNowDate());
|
int updateResult = fundFlowMapper.updateFundFlow(fundFlow);
|
if (updateResult <= 0) {
|
throw new RuntimeException("更新资金流水状态失败，ID: " + fundFlowId);
|
}
|
|
// 删除结算明细并更新账单状态
|
deleteSettlementDetailsAndUpdateBillStatus(claimDetail,fundFlow);
|
|
int result = fundFlowClaimDetailMapper.deleteFundFlowClaimDetailByIds(ids);
|
|
// 记录操作日志
|
if (result > 0) {
|
FundFlowLog log = new FundFlowLog();
|
log.setFlowId(fundFlowId);
|
log.setOperation("删除账单认领明细，账单编号：" + claimDetail.getBillNo() + "，认领金额：" + deleteAmount + "，资金流水号：" + fundFlow.getBankFlowNo());
|
fundFlowLogService.insertFundFlowLog(log);
|
}
|
|
return result;
|
}
|
|
/**
|
* 删除账单认领明细信息
|
*
|
* @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);
|
|
// 记录操作日志
|
FundFlowLog log = new FundFlowLog();
|
log.setFlowId(fundFlowId);
|
log.setOperation("新增账单认领明细，账单编号：" + claimDetail.getBillNo() + "，认领金额：" + claimAmount + "，资金流水号：" + fundFlow.getBankFlowNo());
|
fundFlowLogService.insertFundFlowLog(log);
|
}
|
|
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);
|
// 这里可以选择抛出异常或记录日志，但不中断整个认领流程
|
}
|
}
|
|
/**
|
* 删除结算明细并更新账单状态
|
*/
|
private void deleteSettlementDetailsAndUpdateBillStatus(FundFlowClaimDetail claimDetail, FundFlow fundFlow) {
|
String billNo = claimDetail.getBillNo();
|
Integer claimDetailId = claimDetail.getId();
|
|
try {
|
|
|
// 根据收支标识借贷标志判断是应收账单还是应付账单
|
if (fundFlow.getIncomeExpenseFlag().equals(0)) {
|
// 应收账单
|
deleteReceivableSettlementDetail(claimDetailId);
|
} else {
|
// 应付账单
|
deletePayableSettlementDetail(claimDetailId);
|
}
|
|
logger.info("成功删除结算明细，认领明细ID：{}", claimDetailId);
|
} catch (Exception e) {
|
logger.error("删除结算明细失败，认领明细ID：{}", claimDetailId, e);
|
// 这里可以选择抛出异常或记录日志，但不中断整个删除流程
|
}
|
}
|
|
/**
|
* 删除应收账单结算明细
|
*/
|
private void deleteReceivableSettlementDetail(Integer claimDetailId) {
|
try {
|
// 根据认领明细ID查询应收账单结算明细
|
ReceivableBillSettlementDetail receivableQuery = new ReceivableBillSettlementDetail();
|
receivableQuery.setClaimDetailId(claimDetailId);
|
List<ReceivableBillSettlementDetail> receivableDetails = receivableBillSettlementDetailService.selectReceivableBillSettlementDetailList(receivableQuery);
|
|
if (!receivableDetails.isEmpty()) {
|
Integer[] receivableIds = receivableDetails.stream()
|
.map(ReceivableBillSettlementDetail::getId)
|
.toArray(Integer[]::new);
|
receivableBillSettlementDetailService.deleteReceivableBillSettlementDetailByIds(receivableIds);
|
logger.info("成功删除应收账单结算明细，认领明细ID：{}", claimDetailId);
|
}
|
} catch (Exception e) {
|
logger.error("删除应收账单结算明细失败，认领明细ID：{}", claimDetailId, e);
|
throw e;
|
}
|
}
|
|
/**
|
* 删除应付账单结算明细
|
*/
|
private void deletePayableSettlementDetail(Integer claimDetailId) {
|
try {
|
// 根据认领明细ID查询应付账单结算明细
|
PayableBillSettlementDetail payableQuery = new PayableBillSettlementDetail();
|
payableQuery.setClaimDetailId(claimDetailId);
|
List<PayableBillSettlementDetail> payableDetails = payableBillSettlementDetailService.selectPayableBillSettlementDetailList(payableQuery);
|
|
if (!payableDetails.isEmpty()) {
|
Integer[] payableIds = payableDetails.stream()
|
.map(PayableBillSettlementDetail::getId)
|
.toArray(Integer[]::new);
|
payableBillSettlementDetailService.deletePayableBillSettlementDetailByIds(payableIds);
|
logger.info("成功删除应付账单结算明细，认领明细ID：{}", claimDetailId);
|
}
|
} catch (Exception e) {
|
logger.error("删除应付账单结算明细失败，认领明细ID：{}", claimDetailId, e);
|
throw e;
|
}
|
}
|
|
}
|
