gold-java/src/main/java/com/example/demo/serviceImpl/cash/CashRefundServiceImpl.java

package com.example.demo.serviceImpl.cash;

import com.example.demo.Util.LanguageTranslationUtil;
import com.example.demo.Util.SimpleIdGenerator;
import com.example.demo.domain.entity.*;
import com.example.demo.Util.BusinessException;
import com.example.demo.Util.GoldTistV2;
import com.example.demo.config.RabbitMQConfig;
import com.example.demo.domain.vo.bean.Region;
import com.example.demo.domain.vo.cash.*;
import com.example.demo.domain.vo.coin.Messages;
import com.example.demo.domain.vo.coin.Result;
import com.example.demo.exception.SystemException;
import com.example.demo.mapper.cash.CashCollectionMapper;
import com.example.demo.mapper.cash.CashRefundMapper;
import com.example.demo.mapper.coin.*;
import com.example.demo.service.Wallet.WalletService;
import com.example.demo.service.cash.RefundService;
import com.example.demo.service.coin.TranslationService;
import com.github.pagehelper.PageHelper;
import com.github.pagehelper.PageInfo;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.collections4.CollectionUtils;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.web.bind.annotation.RequestHeader;
import com.example.demo.domain.DTO.Currency;

import java.math.BigDecimal;
import java.math.RoundingMode;
import java.time.LocalDate;
import java.util.*;
import java.util.function.Function;
import java.util.stream.Collectors;

import static org.apache.commons.lang3.StringUtils.substring;

/**
 * @program: GOLD
 * @ClassName CashRefundServiceImpl
 * @description:
 * @author: huangqizhen
 * @create: 2025−09-28 15:02
 * @Version 1.0
 **/
@Service
@Slf4j
public class CashRefundServiceImpl implements RefundService {

    @Autowired
    private CashRefundMapper cashRefundMapper;
    @Autowired
    private RefundMapper refundMapper;
    @Autowired
    private AuditMapper auditMapper;
    @Autowired
    private MarketMapper marketMapper;
    @Autowired
    private RabbitTemplate rabbitTemplate;
    @Autowired
    private OperationLogMapper operationLogMapper;
    @Autowired
    private CashCollectionMapper cashCollectionMapper;
    @Autowired
    private LanguageTranslationUtil languageTranslationUtil;
    @Autowired
    private WalletService walletService;
    @Autowired
    private TranslationService translationService;
    @Autowired
    private WalletMapper walletMapper;
    @Autowired
    private UserMapper userMapper;

    @Override
    public PageInfo<CashRecordDTO> select(Integer pageNum, Integer pageSize, CashRecordDTO cashRecordDTO) {
        PageHelper.startPage(pageNum, pageSize);     //必须要直接跟mapper
        List<CashRecordDTO> list = cashRefundMapper.select(cashRecordDTO);

        if (list.isEmpty()) {
            return new PageInfo<>(list);
        }

        // 批量收集ID
        Set<Integer> relatedIds = new HashSet<>();
        Set<Integer> marketIds = new HashSet<>();
        Set<Integer> submitterIds = new HashSet<>();
        Set<Integer> auditIds = new HashSet<>();
        Set<Integer> executorIds = new HashSet<>();

        list.forEach(item -> {
            if (item.getRelatedId() != null) relatedIds.add(item.getRelatedId());
            if (item.getMarket() != null) marketIds.add(item.getMarket());
            if (item.getSubmitterId() != null) submitterIds.add(item.getSubmitterId());
            if (item.getAuditId() != null) auditIds.add(item.getAuditId());
            if (item.getExecutor() != null) executorIds.add(item.getExecutor());
        });

        // 批量查询
        Map<Integer, CashCollection> cashCollectionMap = cashCollectionMapper.selectBatchIds(relatedIds)
                .stream().collect(Collectors.toMap(CashCollection::getId, Function.identity()));

        Map<Integer, String> marketNameMap = marketMapper.getMarketByIds(marketIds)
                .stream().collect(Collectors.toMap(Market::getId, Market::getName));

        Map<Integer, String> submitterNameMap = auditMapper.getNamesByIds(submitterIds)
                .stream().collect(Collectors.toMap(Admin::getId, Admin::getAdminName));

        Map<Integer, LhlAudit> auditMap = cashRefundMapper.getAuditBatch(auditIds)
                .stream().collect(Collectors.toMap(LhlAudit::getId, Function.identity()));
        Map<String, String> executorNameMap = auditMapper.getNamesByJwcodes(executorIds)
                .stream().collect(Collectors.toMap(Admin::getAccount, Admin::getAdminName));

        // 处理数据
        list.forEach(item -> {
            CashCollection cashCollection = cashCollectionMap.get(item.getRelatedId());
            if (cashCollection != null) {
                processCashCollection(item, cashCollection);
            }


            String marketName = marketNameMap.get(item.getMarket());
            String submitter = submitterNameMap.get(item.getSubmitterId());
            LhlAudit lhlAudit = auditMap.get(item.getAuditId());
            String executorName = executorNameMap.get(String.valueOf(item.getExecutor()));

            item.setMarketName(marketName != null ? marketName : "");
            item.setSubmitter(submitter != null ? submitter : "");
            item.setExecutorName(executorName != null ? executorName : "");

            if (lhlAudit != null) {
                item.setAreaServise(lhlAudit.getAreaServise());
                item.setAreaFinance(lhlAudit.getAreaFinance());
                item.setAreaCharge(lhlAudit.getAreaCharge());
                item.setHeadFinance(lhlAudit.getHeadFinance());
            }
        });

        return new PageInfo<>(list);
    }

    private void processCashCollection(CashRecordDTO item, CashCollection cashCollection) {
        // 设置默认值
        Integer freeGold = cashCollection.getFreeGold() != null ? cashCollection.getFreeGold() : 0;
        Integer permanentGold = cashCollection.getPermanentGold() != null ? cashCollection.getPermanentGold() : 0;

        BigDecimal free = new BigDecimal(freeGold).divide(new BigDecimal(100), 2, RoundingMode.HALF_UP);
        BigDecimal permanent = new BigDecimal(permanentGold).divide(new BigDecimal(100), 2, RoundingMode.HALF_UP);


        item.setGold(permanent);
        item.setFree(free);
        item.setActivity(cashCollection.getActivity());
        item.setPaymentCurrency(cashCollection.getPaymentCurrency());
        if (cashCollection.getPaymentCurrency() != null) {
            item.setPaymentAmount(cashCollection.getPaymentAmount().divide(new BigDecimal(100), 2, RoundingMode.HALF_UP));
        } else item.setPaymentAmount(cashCollection.getPaymentAmount());
        item.setReceivedCurrency(cashCollection.getReceivedCurrency());
        if (cashCollection.getReceivedCurrency() != null) {
            item.setReceivedAmount(cashCollection.getReceivedAmount().divide(new BigDecimal(100), 2, RoundingMode.HALF_UP));
        } else item.setReceivedAmount(cashCollection.getReceivedAmount());
        item.setPayType(cashCollection.getPayType());
        item.setPayTime(cashCollection.getPayTime());
        item.setPayBankCode(cashCollection.getBankCode());
        item.setPaySubmitter(cashCollection.getSubmitterName());
        item.setAudit(cashCollection.getAuditName());
        item.setReceivedTime(cashCollection.getReceivedTime());
        item.setPayVoucher(cashCollection.getVoucher());
        item.setPayRemark(cashCollection.getRemark());
        item.setHandlingCharge(cashCollection.getHandlingCharge().divide(new BigDecimal(100), 2, RoundingMode.HALF_UP));

        // 处理金币金额
        if (item.getPermanentGold() != null) {
            item.setPermanentGold(item.getPermanentGold().divide(new BigDecimal(100), 2, RoundingMode.HALF_UP));
        }
        if (item.getFreeGold() != null) {
            item.setFreeGold(item.getFreeGold().divide(new BigDecimal(100), 2, RoundingMode.HALF_UP));
        }
    }

    @Override
    public int add(CashRecordRefund cashRecordRefund, @RequestHeader(defaultValue = "zh_CN") String lang) throws Exception {
        try {
            if (cashRecordRefund.getJwcode() == null) {
                throw new Exception("未输入精网号");
            }
            if (cashRecordRefund.getRefundModel() == null) {
                throw new Exception("请填充退款类型");
            }
            if (cashRecordRefund.getRefundReason() == null) {
                throw new Exception("请填写退款理由");
            }
            if (cashRecordRefund.getHandlingCharge() == null) {
                throw new Exception("请先填写手续费");
            }
            if (cashRecordRefund.getMarket() == null || cashRecordRefund.getMarket().trim().isEmpty()) {
                throw new Exception("请选择所属地区");
            }
            if(cashRecordRefund.getWalletId() != null) {
                Integer wallet = cashRecordRefund.getWalletId();
                UserRegionWallet userRegionWallet = walletMapper.selectWallet(cashRecordRefund.getJwcode(), wallet);
                User user = userMapper.selectUserByJwcode(cashRecordRefund.getJwcode());
                if (user.getCurrentFreeJune().add(user.getCurrentFreeDecember()).compareTo(BigDecimal.valueOf(cashRecordRefund.getPartRefundFree())) < 0) {
                    String errorMsg = languageTranslationUtil.translate("用户钱包余额不足", lang);
                    throw new BusinessException(errorMsg);
                }
                if (userRegionWallet == null) {
                    //初始化钱包
                    walletMapper.insert(new UserRegionWallet(null, cashRecordRefund.getJwcode(), wallet, BigDecimal.ZERO, new Date(), new Date()));
                    log.warn("用户钱包不存在，已初始化钱包");
                }
                if (userRegionWallet.getCurrentPermanentGold().compareTo(BigDecimal.valueOf(cashRecordRefund.getPartRefundGold())) < 0) {
                    throw new BusinessException("用户钱包金币不足");
                }
            }
            CashRecordDone cashRecordDonetwo = new CashRecordDone();
            cashRecordDonetwo.setAreaServise(cashRecordRefund.getAreaServise());
            cashRefundMapper.addAudit(cashRecordDonetwo);
            cashRecordRefund.setAuditId(cashRecordDonetwo.getId());

            cashRecordRefund.setStatus(10);
            //生成订单号后半部分
            String orderNumber = cashRecordRefund.getOrderCode();
            //构建订单信息
            cashRecordRefund.setOrderCode("TK" + orderNumber);   //订单号

            // 查询市场 ID，增加空值检查和多语言支持
            String marketName = cashRecordRefund.getMarket();
            String marketId = marketMapper.getMarketId(marketName);

            // 如果直接查询失败，尝试将英文名称转换为中文后再次查询
            if (marketId == null || marketId.trim().isEmpty()) {
                String chineseMarketName = translationService.findChineseSimplifiedByTranslation(marketName, "en");
                if (chineseMarketName != null && !chineseMarketName.equals(marketName)) {
                    marketId = marketMapper.getMarketId(chineseMarketName);
                }
            }

            if (marketId == null || marketId.trim().isEmpty()) {
                throw new Exception("无效的所属地区：" + cashRecordRefund.getMarket());
            }
            cashRecordRefund.setMarket(String.valueOf(Integer.valueOf(marketId)));

            cashRefundMapper.insert(cashRecordRefund);
            CashRecordDone cashRecordDone1 = new CashRecordDone();
            cashRecordDone1.setId(cashRecordRefund.getOriginalOrderId());
            cashRecordDone1.setStatus(6);
            if (cashRecordDone1.getId() != null || cashRecordDone1.getOrderCode() != null) {
                cashRefundMapper.updateStatus(cashRecordDone1);
            } else {
                return Result.error("提交失败").getCode();
            }

            // 发送退款创建消息
            Messages message = new Messages();
            message.setJwcode(cashRecordRefund.getJwcode());
            message.setName(cashRecordRefund.getName());
            message.setStatus(cashRecordRefund.getStatus());
            message.setDesc("的客服退款申请待审核，前往处理");
            message.setTitle("现金退款--新增退款");
            message.setType(0);
            message.setTypeId(cashRecordRefund.getId());
            message.setMarket(Integer.valueOf(cashRecordRefund.getMarket()));
            String marketName2 = marketMapper.getMarketNameById(String.valueOf(message.getMarket()));
            message.setMarketName(marketName2);
            message.setQueryId(103);
            rabbitTemplate.convertAndSend(RabbitMQConfig.CASH_REFUND_EXCHANGE, "cash.refund.save", message);

            return Result.success("提交成功").getCode();
        } catch (Exception e) {
            log.error("add error", e);
            throw e;
        }
    }

    @Override
    public int update(CashRecordDone cashRecordDone) throws Exception {
        if (cashRecordDone.getJwcode() == null) {
            throw new RuntimeException("未输入精网号");
        }
        if (cashRecordDone.getPaymentAmount() == null) {
            throw new RuntimeException("未输入付款金额");
        }
        if (cashRecordDone.getPaymentCurrency() == null) {
            throw new RuntimeException("未输入付款币种");
        }
        if (cashRecordDone.getRefundModel() == null) {
            throw new RuntimeException("请填写退款类型");
        }
        if (cashRecordDone.getRefundReason() == null) {
            throw new RuntimeException("请填写退款理由");
        }
        if (cashRecordDone.getNewRefundGold() == null) {
            cashRecordDone.setNewRefundGold(BigDecimal.valueOf(0));
        }
        if (cashRecordDone.getNewRefundFree() == null) {
            cashRecordDone.setNewRefundFree(BigDecimal.valueOf(0));
        }

        int result = cashRefundMapper.update(cashRecordDone);
        CashRecordDTO cashRecordDTO = cashRefundMapper.selectById(cashRecordDone.getId());
        if (result > 0) {
            // 发送审核消息
            Messages message = new Messages();
            message.setJwcode(cashRecordDTO.getJwcode());
            message.setName(cashRecordDTO.getName());
            message.setStatus(cashRecordDTO.getStatus());
            message.setDesc("的退款申请待审核，前往处理");
            message.setTitle("现金管理--退款审批");
            message.setType(1);
            message.setTypeId(cashRecordDTO.getId());
            message.setMarket(cashRecordDTO.getMarket());
            String marketName = marketMapper.getMarketNameById(String.valueOf(message.getMarket()));
            message.setMarketName(marketName);
            message.setQueryId(103);
            rabbitTemplate.convertAndSend(RabbitMQConfig.CASH_REFUND_EXCHANGE, "cash.refund.save", message);
        }
        return (result > 0 ? Result.success("提交成功") : Result.error("提交失败")).getCode();
    }

    @Override
    public int withdraw(CashRecordDone cashRecordDone) {
        // 撤回订单
        int result = cashRefundMapper.withdraw(cashRecordDone.getId());

        if (result > 0) {
            // 更新与该订单关联的消息记录的flag字段为1
            cashRefundMapper.updateMessageFlagByOrderId(cashRecordDone.getId());
        }

        return result;
    }

    @Override
    public int review(CashRecordDone cashRecordDone, @RequestHeader(defaultValue = "zh_CN") String lang) throws Exception {
        if (cashRecordDone.getStatus() == 12 || cashRecordDone.getStatus() == 22) {
            if (cashRecordDone.getOrderCode() == null) {
                throw new RuntimeException("未输入订单号");
            }
            CashRecordDone cashRecordDone1 = new CashRecordDone();
            cashRecordDone1.setId(cashRecordDone.getRelatedId());
            cashRecordDone1.setOrderCode(cashRecordDone.getOrderCode().substring(2));
            cashRecordDone1.setStatus(4);
            if (cashRecordDone1.getId() != null || cashRecordDone1.getOrderCode() != null) {
                cashRefundMapper.updateStatus(cashRecordDone1);
            }
        }
        cashRefundMapper.updateAudit(cashRecordDone);
        int result = cashRefundMapper.review(cashRecordDone);
        CashRecordDTO cashRecordDTO = cashRefundMapper.selectById(cashRecordDone.getId());
        if (result > 0) {
            // 发送审核消息
            Messages message = new Messages();
            message.setJwcode(cashRecordDTO.getJwcode());
            message.setName(cashRecordDTO.getName());
            message.setStatus(cashRecordDTO.getStatus());
            if (cashRecordDTO.getStatus()==20) {
                message.setDesc("的现金退款申请待审批，前往处理");
                message.setTitle("现金管理--退款审批(负责人)");
                message.setQueryId(107);
            } else if (cashRecordDTO.getStatus()==30) {
                message.setDesc("的现金退款申请待审核，前往处理");
                message.setTitle("现金管理--退款审批(总部财务)");
                message.setQueryId(111);
            } else {
                message.setDesc("的现金退款申请已被驳回，前往查看详情");
                message.setTitle("现金管理--退款提交");
                message.setQueryId(99);
            }
            message.setType(1);
            message.setTypeId(cashRecordDTO.getId());
            message.setMarket(cashRecordDTO.getMarket());
            String marketName = marketMapper.getMarketNameById(String.valueOf(message.getMarket()));
            message.setMarketName(marketName);

            rabbitTemplate.convertAndSend(RabbitMQConfig.CASH_REFUND_EXCHANGE, "cash.refund.save", message);

        }

        return (result > 0 ? Result.success("提交成功") : Result.error("提交失败")).getCode();
    }

    @Override
    public int executor(CashRecordDone cashRecordDone) throws Exception {
        if (cashRecordDone.getRefundVoucher() == null) {
            throw new RuntimeException("未输入退款凭证");
        }
        if (cashRecordDone.getRefundTime() == null) {
            throw new RuntimeException("未输入退款时间");
        }
        if (cashRecordDone.getRefundRemark() == null) {
            throw new RuntimeException("未输入退款备注");
        }
        if (cashRecordDone.getRefundChannels() == null) {
            throw new RuntimeException("未输入退款途径");
        }
        if (cashRecordDone.getRefundCurrency() == null) {
            throw new RuntimeException("未输入退款币种");
        }
        if (cashRecordDone.getRefundAmount() == null) {
            throw new RuntimeException("未输入退款金额");
        }
        int result = cashRefundMapper.executor(cashRecordDone);
        return (result > 0 ? Result.success("提交成功") : Result.error("提交失败")).getCode();
    }

    @Override
    public int updateStatus(CashRecordDone cashRecordDone) {
        return cashRefundMapper.updateStatus(cashRecordDone);
    }

    @Transactional(rollbackFor = Exception.class)
    @Override
    public int finalreview(CashRecordDone cashRecordDone, @RequestHeader(defaultValue = "zh_CN") String lang) {
        if (cashRecordDone.getPermanentGold() == null) {
            cashRecordDone.setPermanentGold(0);
        }
        if (cashRecordDone.getFreeGold() == null) {
            cashRecordDone.setFreeGold(0);
        }
        if (cashRecordDone.getStatus() == 32) {
            CashRecordDone cashRecordDone1 = new CashRecordDone();
            cashRecordDone1.setOrderCode(cashRecordDone.getOrderCode().substring(2));
            cashRecordDone1.setStatus(4);
            if (cashRecordDone1.getId() != null || cashRecordDone1.getOrderCode() != null) {
                cashRefundMapper.updateStatus(cashRecordDone1);
            }
        }
        if (cashRecordDone.getGoodsName() != null && cashRecordDone.getStatus() == 40 &&
                (cashRecordDone.getGoodsName().equals(languageTranslationUtil.translate("金币充值", lang)) ||
                        cashRecordDone.getGoodsName().contains(languageTranslationUtil.translate("金币充值", lang)))) {
            UserGoldRecord userGoldRecord = new UserGoldRecord();
            userGoldRecord.setOrderCode(cashRecordDone.getOrderCode());
            String orderCode = cashRecordDone.getOrderCode();
            if (orderCode != null && orderCode.length() > 4 && orderCode.startsWith("TKXJ")) {
                orderCode = "XJCZ" + orderCode.substring(4);
            }
            userGoldRecord.setType((byte) 2);
            userGoldRecord.setIsRefund((byte) 1);
            userGoldRecord.setRefundType("金币退款");
            if (cashRecordDone.getRefundModel() == 1) {
                userGoldRecord.setRefundModel(Byte.valueOf("1"));
            } else if (cashRecordDone.getRefundModel() == 0) {
                userGoldRecord.setRefundModel(Byte.valueOf("0"));
            }


            userGoldRecord.setJwcode(cashRecordDone.getJwcode());
            userGoldRecord.setSumGold(cashRecordDone.getPermanentGold() + cashRecordDone.getFreeGold());
            userGoldRecord.setPermanentGold(cashRecordDone.getPermanentGold());
            int currentMonth = LocalDate.now().getMonthValue();
            if (currentMonth >= 1 && currentMonth <= 6) {
                // 1-6月：设置12月额度，6月保持默认值
                userGoldRecord.setFreeJune(0);
                userGoldRecord.setFreeDecember(cashRecordDone.getFreeGold());
            } else {
                // 7-12月：设置6月额度，12月保持默认值
                userGoldRecord.setFreeJune(cashRecordDone.getFreeGold());
                userGoldRecord.setFreeDecember(0);
            }
            userGoldRecord.setGoodsName("金币充值");
            userGoldRecord.setPayPlatform("金币系统");
            userGoldRecord.setRemark(cashRecordDone.getRemark());
            userGoldRecord.setAdminId(cashRecordDone.getAdminId());
            userGoldRecord.setAuditStatus(1);
            userGoldRecord.setTaskGold(0);
            userGoldRecord.setCreateTime(new Date());
            userGoldRecord.setUpdateTime(new Date());
            String auditName = auditMapper.getName(cashRecordDone.getAuditId());
            refundMapper.add(userGoldRecord);
            cashRefundMapper.updategold(orderCode);
            User user = new User();
            user.setJwcode(userGoldRecord.getJwcode());
            user.setCurrentPermanentGold(BigDecimal.valueOf(-userGoldRecord.getPermanentGold())); //当前永久金币
            user.setCurrentFreeJune(BigDecimal.valueOf(-userGoldRecord.getFreeJune())); //当前六月免费金币
            user.setCurrentFreeDecember(BigDecimal.valueOf(-userGoldRecord.getFreeDecember())); //当前十二月免费金币
            User usergold = userMapper.selectUserByJwcode(userGoldRecord.getJwcode());
            if(usergold.getCurrentFreeJune().add(user.getCurrentFreeJune()).compareTo(BigDecimal.ZERO)<0){
                throw new RuntimeException("当前六月免费金币不足");
            }
            if (usergold.getCurrentFreeDecember().add(user.getCurrentFreeDecember()).compareTo(BigDecimal.ZERO)<0){
                throw new RuntimeException("当前十二月免费金币不足");
            }
            auditMapper.updateUserGold(user);

// 钱包更新 - 按原始充值流水 wallet_id 优先级顺序原路退回（1-10，越小优先级越高）
            String orderCodeA = "XJ" + orderCode.substring(4);

// 1. 查询原始充值流水（type=0 充值，status=0 正常）
            List<UserWalletRecord> originalRecords = walletService.selectUserWalletRecord(userGoldRecord.getJwcode(), orderCodeA);
            if (!CollectionUtils.isEmpty(originalRecords)) {
                // 过滤充值记录并按 wallet_id 升序排序
                originalRecords = originalRecords.stream()
                        .filter(r -> r.getType() == 0 && r.getStatus() == 0)
                        .sorted(Comparator.comparing(UserWalletRecord::getWalletId))
                        .collect(Collectors.toList());

                // 2. 本次退款总金额（取绝对值）
                BigDecimal totalRefundAmount = BigDecimal.valueOf(userGoldRecord.getPermanentGold()).abs();

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

                    // 🔥【新增】预校验：检查用户余额是否足够退款
                    BigDecimal userTotalBalance = getUserTotalBalance(userGoldRecord.getJwcode(), originalRecords);
                    if (userTotalBalance.compareTo(totalRefundAmount) < 0) {
                        // 🔥 余额不足，直接报错返回（根据项目规范选择抛异常或返回错误码）
                        String errorMsg = String.format("退款失败：用户余额不足 | jwcode=%s, 待退金额=%s, 当前余额=%s",
                                userGoldRecord.getJwcode(), totalRefundAmount, userTotalBalance);
                        log.error(errorMsg);
                        throw new BusinessException("WALLET_REFUND_INSUFFICIENT"+ errorMsg);
                        // 或者：return Result.fail("WALLET_REFUND_INSUFFICIENT", "余额不足，无法退款");
                    }

                    BigDecimal remainingRefund = totalRefundAmount;

                    // 3. 按原始流水顺序退回（支持多钱包）
                    for (UserWalletRecord record : originalRecords) {
                        if (remainingRefund.compareTo(BigDecimal.ZERO) <= 0) {
                            break;
                        }

                        Integer walletId = record.getWalletId();
                        BigDecimal originalAmount = BigDecimal.valueOf(record.getAmount()).abs();
                        if (originalAmount.compareTo(BigDecimal.ZERO) <= 0) {
                            continue;
                        }

                        // 4. 计算本次退回金额
                        BigDecimal refundAmount = originalAmount.min(remainingRefund);
                        if (refundAmount.compareTo(BigDecimal.ZERO) <= 0) {
                            continue;
                        }

                        // 5. 插入退款流水（amount 存负数，表示扣减）
                        UserWalletRecord refundRecord = new UserWalletRecord();
                        refundRecord.setType(2);  // 充值退款类型
                        refundRecord.setTransactionCurrency("金币"); // 交易币种
                        refundRecord.setJwcode(userGoldRecord.getJwcode());
                        refundRecord.setWalletId(walletId);
                        refundRecord.setAmount(refundAmount.negate().intValue());  // 🔥 负数扣款
                        refundRecord.setOrderCode("TK" + orderCodeA);
                        if (cashRecordDone.getRefundModel()==1) {
                            refundRecord.setDescription("部分退款");
                        }
                        else if (cashRecordDone.getRefundModel()==0) {
                            refundRecord.setDescription("全部退款");
                        }
                        refundRecord.setStatus(0);
                        walletService.addUserWalletRecord(refundRecord);

                        // 6. 查询并更新钱包余额
                        UserRegionWallet currentWallet = walletMapper.selectWallet(userGoldRecord.getJwcode(), walletId);
                        if (currentWallet == null) {
                            log.error("钱包记录不存在，无法退款 | jwcode={}, walletId={}", userGoldRecord.getJwcode(), walletId);
                            continue;
                        }

                        // 7. 扣减余额
                        BigDecimal newBalance = currentWallet.getCurrentPermanentGold().subtract(refundAmount);
                        // 🔥 兜底：理论上预校验已通过，这里不会再出现负数，但保留防御式编程
                        if (newBalance.compareTo(BigDecimal.ZERO) < 0) {
                            log.warn("退款后余额为负，强制置零 | jwcode={}, walletId={}", userGoldRecord.getJwcode(), walletId);
                            newBalance = BigDecimal.ZERO;
                        }
                        currentWallet.setCurrentPermanentGold(newBalance);
                        walletMapper.updateWallet(currentWallet);

                        // 8. 更新原流水状态
                        walletService.updateUserWalletRecord(record.getId());

                        // 9. 扣减剩余待退金额
                        remainingRefund = remainingRefund.subtract(refundAmount);
                    }
                }
            }

            GoldTistV2.addCoinNew(userGoldRecord.getJwcode().toString(), 58, //退款免费+永久金币-充值
                    (double) (userGoldRecord.getFreeDecember() + userGoldRecord.getFreeJune() + userGoldRecord.getPermanentGold()) / 100, SimpleIdGenerator.generateId(),
                    userGoldRecord.getRemark(), (double) userGoldRecord.getPermanentGold() / 100, auditName, "退款金币充值");
        }

        cashRefundMapper.updateAudit(cashRecordDone);
        int result = cashRefundMapper.review(cashRecordDone);
        CashRecordDTO cashRecordDTO = cashRefundMapper.selectById(cashRecordDone.getId());
        if (result > 0) {
            // 发送审核消息
            Messages message = new Messages();
            message.setJwcode(cashRecordDTO.getJwcode());
            message.setName(cashRecordDTO.getName());
            message.setStatus(cashRecordDTO.getStatus());
            message.setDesc(cashRecordDTO.getStatus() != 32 ? "的退款记录需填写执行明细，前往查看处理" : "的现金退款申请已被驳回，前往查看详情");
            message.setTitle(cashRecordDTO.getStatus() != 32 ? "现金管理--执行明细填写":"现金管理--退款提交");
            message.setType(1);
            message.setTypeId(cashRecordDTO.getId());
            message.setMarket(cashRecordDTO.getMarket());
            String marketName = marketMapper.getMarketNameById(String.valueOf(message.getMarket()));
            message.setMarketName(marketName);
            message.setQueryId(cashRecordDTO.getStatus() != 32 ? 115:99);
            if (cashRecordDTO.getStatus() != 32) {
                log.info("Setting executor to: {}", cashRecordDTO.getExecutor());
                message.setExecutor(cashRecordDTO.getExecutor());
                log.info("Executor after setting: {}", message.getExecutor());
            }
            rabbitTemplate.convertAndSend(RabbitMQConfig.CASH_REFUND_EXCHANGE, "cash.refund.save", message);
        }
        return (result > 0 ? Result.success("提交成功") : Result.error("提交失败")).getCode();
    }

    @Override
    public PageInfo<CashRecordDTO> financeSelect(Integer pageNum, Integer pageSize, CashRecordDTO cashRecordDTO) {
        PageHelper.startPage(pageNum, pageSize);     //必须要直接跟mapper
//        System.out.println(goldDetail.getMarkets());
        List<CashRecordDTO> list = cashRefundMapper.financeSelect(cashRecordDTO);
        if (list.isEmpty()) {
            return new PageInfo<>(list);
        }

        // 批量收集ID
        Set<Integer> relatedIds = new HashSet<>();
        Set<Integer> marketIds = new HashSet<>();
        Set<Integer> submitterIds = new HashSet<>();
        Set<Integer> auditIds = new HashSet<>();
        Set<Integer> executorIds = new HashSet<>();

        list.forEach(item -> {
            if (item.getRelatedId() != null) relatedIds.add(item.getRelatedId());
            if (item.getMarket() != null) marketIds.add(item.getMarket());
            if (item.getSubmitterId() != null) submitterIds.add(item.getSubmitterId());
            if (item.getAuditId() != null) auditIds.add(item.getAuditId());
            if (item.getExecutor() != null) executorIds.add(item.getExecutor());
        });

        // 批量查询
        Map<Integer, CashCollection> cashCollectionMap = cashCollectionMapper.selectBatchIds(relatedIds)
                .stream().collect(Collectors.toMap(CashCollection::getId, Function.identity()));

        Map<Integer, String> marketNameMap = marketMapper.getMarketByIds(marketIds)
                .stream().collect(Collectors.toMap(Market::getId, Market::getName));

        Map<Integer, String> submitterNameMap = auditMapper.getNamesByIds(submitterIds)
                .stream().collect(Collectors.toMap(Admin::getId, Admin::getAdminName));

        Map<Integer, LhlAudit> auditMap = cashRefundMapper.getAuditBatch(auditIds)
                .stream().collect(Collectors.toMap(LhlAudit::getId, Function.identity()));
        Map<String, String> executorNameMap = auditMapper.getNamesByJwcodes(executorIds)
                .stream().collect(Collectors.toMap(Admin::getAccount, Admin::getAdminName));

        // 处理数据
        list.forEach(item -> {
            CashCollection cashCollection = cashCollectionMap.get(item.getRelatedId());
            if (cashCollection != null) {
                processCashCollection(item, cashCollection);
            }


            String marketName = marketNameMap.get(item.getMarket());
            String submitter = submitterNameMap.get(item.getSubmitterId());
            LhlAudit lhlAudit = auditMap.get(item.getAuditId());
            String executorName = executorNameMap.get(String.valueOf(item.getExecutor()));

            item.setMarketName(marketName != null ? marketName : "");
            item.setSubmitter(submitter != null ? submitter : "");
            item.setExecutorName(executorName != null ? executorName : "");

            if (lhlAudit != null) {
                item.setAreaServise(lhlAudit.getAreaServise());
                item.setAreaFinance(lhlAudit.getAreaFinance());
                item.setAreaCharge(lhlAudit.getAreaCharge());
                item.setHeadFinance(lhlAudit.getHeadFinance());
            }
        });

        return new PageInfo<>(list);
    }

    @Override
    public PageInfo<CashRecordDTO> financeSelect2(Integer pageNum, Integer pageSize, CashRecordDTO cashRecordDTO) {
        PageHelper.startPage(pageNum, pageSize);     //必须要直接跟mapper
//        System.out.println(goldDetail.getMarkets());
        List<CashRecordDTO> list = cashRefundMapper.financeSelect(cashRecordDTO);
        if (list.isEmpty()) {
            return new PageInfo<>(list);
        }

        // 批量收集ID
        Set<Integer> relatedIds = new HashSet<>();
        Set<Integer> marketIds = new HashSet<>();
        Set<Integer> submitterIds = new HashSet<>();
        Set<Integer> auditIds = new HashSet<>();
        Set<Integer> executorIds = new HashSet<>();

        list.forEach(item -> {
            if (item.getRelatedId() != null) relatedIds.add(item.getRelatedId());
            if (item.getMarket() != null) marketIds.add(item.getMarket());
            if (item.getSubmitterId() != null) submitterIds.add(item.getSubmitterId());
            if (item.getAuditId() != null) auditIds.add(item.getAuditId());
            if (item.getExecutor() != null) executorIds.add(item.getExecutor());
        });

        // 批量查询
        Map<Integer, CashCollection> cashCollectionMap = cashCollectionMapper.selectBatchIds(relatedIds)
                .stream().collect(Collectors.toMap(CashCollection::getId, Function.identity()));

        Map<Integer, String> marketNameMap = marketMapper.getMarketByIds(marketIds)
                .stream().collect(Collectors.toMap(Market::getId, Market::getName));

        Map<Integer, String> submitterNameMap = auditMapper.getNamesByIds(submitterIds)
                .stream().collect(Collectors.toMap(Admin::getId, Admin::getAdminName));

        Map<Integer, LhlAudit> auditMap = cashRefundMapper.getAuditBatch(auditIds)
                .stream().collect(Collectors.toMap(LhlAudit::getId, Function.identity()));
        Map<String, String> executorNameMap = auditMapper.getNamesByJwcodes(executorIds)
                .stream().collect(Collectors.toMap(Admin::getAccount, Admin::getAdminName));

        // 处理数据
        list.forEach(item -> {
            CashCollection cashCollection = cashCollectionMap.get(item.getRelatedId());
            if (cashCollection != null) {
                processCashCollection(item, cashCollection);
            }


            String marketName = marketNameMap.get(item.getMarket());
            String submitter = submitterNameMap.get(item.getSubmitterId());
            LhlAudit lhlAudit = auditMap.get(item.getAuditId());
            String executorName = executorNameMap.get(String.valueOf(item.getExecutor()));

            item.setMarketName(marketName != null ? marketName : "");
            item.setSubmitter(submitter != null ? submitter : "");
            item.setExecutorName(executorName != null ? executorName : "");

            if (lhlAudit != null) {
                item.setAreaServise(lhlAudit.getAreaServise());
                item.setAreaFinance(lhlAudit.getAreaFinance());
                item.setAreaCharge(lhlAudit.getAreaCharge());
                item.setHeadFinance(lhlAudit.getHeadFinance());
            }
        });

        return new PageInfo<>(list);
    }

    @Override
    public PageInfo<CashRecordDTO> exSelect(Integer pageNum, Integer pageSize, CashRecordDTO cashRecordDTO) {
        PageHelper.startPage(pageNum, pageSize);     //必须要直接跟mapper
//        System.out.println(goldDetail.getMarkets());
        List<CashRecordDTO> list = cashRefundMapper.exSelect(cashRecordDTO);
        System.out.println(list);
        if (list.isEmpty()) {
            return new PageInfo<>(list);
        }

        // 批量收集ID
        Set<Integer> relatedIds = new HashSet<>();
        Set<Integer> marketIds = new HashSet<>();
        Set<Integer> submitterIds = new HashSet<>();
        Set<Integer> auditIds = new HashSet<>();
        Set<Integer> executorIds = new HashSet<>();

        list.forEach(item -> {
            if (item.getRelatedId() != null) relatedIds.add(item.getRelatedId());
            if (item.getMarket() != null) marketIds.add(item.getMarket());
            if (item.getSubmitterId() != null) submitterIds.add(item.getSubmitterId());
            if (item.getAuditId() != null) auditIds.add(item.getAuditId());
            if (item.getExecutor() != null) executorIds.add(item.getExecutor());
        });

        // 批量查询
        Map<Integer, CashCollection> cashCollectionMap = cashCollectionMapper.selectBatchIds(relatedIds)
                .stream().collect(Collectors.toMap(CashCollection::getId, Function.identity()));

        Map<Integer, String> marketNameMap = marketMapper.getMarketByIds(marketIds)
                .stream().collect(Collectors.toMap(Market::getId, Market::getName));

        Map<Integer, String> submitterNameMap = auditMapper.getNamesByIds(submitterIds)
                .stream().collect(Collectors.toMap(Admin::getId, Admin::getAdminName));

        Map<Integer, LhlAudit> auditMap = cashRefundMapper.getAuditBatch(auditIds)
                .stream().collect(Collectors.toMap(LhlAudit::getId, Function.identity()));
        Map<String, String> executorNameMap = auditMapper.getNamesByJwcodes(executorIds)
                .stream().collect(Collectors.toMap(Admin::getAccount, Admin::getAdminName));

        // 处理数据
        list.forEach(item -> {
            CashCollection cashCollection = cashCollectionMap.get(item.getRelatedId());
            if (cashCollection != null) {
                processCashCollection(item, cashCollection);
            }


            String marketName = marketNameMap.get(item.getMarket());
            String submitter = submitterNameMap.get(item.getSubmitterId());
            LhlAudit lhlAudit = auditMap.get(item.getAuditId());
            String executorName = executorNameMap.get(String.valueOf(item.getExecutor()));

            item.setMarketName(marketName != null ? marketName : "");
            item.setSubmitter(submitter != null ? submitter : "");
            item.setExecutorName(executorName != null ? executorName : "");

            if (lhlAudit != null) {
                item.setAreaServise(lhlAudit.getAreaServise());
                item.setAreaFinance(lhlAudit.getAreaFinance());
                item.setAreaCharge(lhlAudit.getAreaCharge());
                item.setHeadFinance(lhlAudit.getHeadFinance());
            }
        });

        return new PageInfo<>(list);
    }

    @Override
    @Transactional(rollbackFor = Exception.class)
    public void addOnline(CashRecordRefund cashRecordRefund,String  lang) {
        try {
            if (cashRecordRefund.getJwcode() == null) {
                throw new BusinessException("未输入精网号");
            }
            if (cashRecordRefund.getRefundModel() == null) {
                throw new BusinessException("请填充退款类型");
            }
            if (cashRecordRefund.getRefundReason() == null) {
                throw new BusinessException("请填写退款理由");
            }
            if (cashRecordRefund.getMarket() == null || cashRecordRefund.getMarket().trim().isEmpty()) {
                throw new BusinessException("请选择所属地区");
            }

            String payType = cashRecordRefund.getPayType();
            Integer wallet = null;
            if (payType == null || payType.trim().isEmpty()) {
                throw new SystemException("未传输支付方式");
            }
            if (payType.equals("Stripe")||payType.equals("PaymentAsia"))
            {
                wallet = 2;
            }
            if (payType.equals("FirstData")||payType.equals("Grabpay")||payType.equals("Nets")||payType.equals("PayPal")||payType.equals("IOS"))
            {
                wallet = 5;
            }
            if (payType.equals("Stripe2"))
            {
                wallet = 3;
            }
            if (payType.equals("iPay88")||payType.equals("Ipay88"))
            {
                wallet = 4;
            }
            if (payType.equals("E-Transfer"))
            {
                wallet = 6;
            }
            if (payType.equals("paysolution"))
            {
                wallet = 8;
            }
            UserRegionWallet userRegionWallet = walletMapper.selectWallet(cashRecordRefund.getJwcode(), wallet);
            User user = userMapper.selectUserByJwcode(cashRecordRefund.getJwcode());
            if (user.getCurrentFreeJune().add(user.getCurrentFreeDecember()).compareTo(BigDecimal.valueOf(cashRecordRefund.getPartRefundFree()))<0){
                String errorMsg = languageTranslationUtil.translate("用户钱包余额不足", lang);
                throw new BusinessException(errorMsg);
            }
            if (userRegionWallet == null) {
                //初始化钱包
                walletMapper.insert(new UserRegionWallet(null, cashRecordRefund.getJwcode(), wallet, BigDecimal.ZERO, new Date(), new Date()));
                log.warn("用户钱包不存在，已初始化钱包");
            }
            if (userRegionWallet.getCurrentPermanentGold().compareTo(BigDecimal.valueOf(cashRecordRefund.getPartRefundGold())) < 0) {
                throw new BusinessException("用户钱包金币不足");
            }
            CashRecordDone cashRecordDonetwo = new CashRecordDone();
            cashRecordDonetwo.setAreaServise(cashRecordRefund.getAreaServise());
            cashRefundMapper.addAudit(cashRecordDonetwo);
            cashRecordRefund.setAuditId(cashRecordDonetwo.getId());

            cashRecordRefund.setStatus(20);
            //生成订单号后半部分
            String orderNumber = cashRecordRefund.getOrderCode();
            //构建订单信息
            cashRecordRefund.setOrderCode("TK" + orderNumber);   //订单号

            // 查询市场 ID，增加空值检查
            String marketName = cashRecordRefund.getMarket();

            // 如果传入的是英文名称，需要转换为中文名称再查询
            String marketId = marketMapper.getMarketId(marketName);
            if (marketId == null || marketId.trim().isEmpty()) {
                // 尝试将英文名称转换为中文后再次查询
                String chineseMarketName = translationService.findChineseSimplifiedByTranslation(marketName, "en");
                if (chineseMarketName != null && !chineseMarketName.equals(marketName)) {
                    marketId = marketMapper.getMarketId(chineseMarketName);
                }
            }

            if (marketId == null || marketId.trim().isEmpty()) {
                throw new BusinessException("无效的所属地区：" + cashRecordRefund.getMarket());
            }
            cashRecordRefund.setMarket(String.valueOf(Integer.valueOf(marketId)));

            cashRefundMapper.insert(cashRecordRefund);

            CashRecordDone cashRecordDone1 = new CashRecordDone();
            cashRecordDone1.setId(cashRecordRefund.getOriginalOrderId());
            cashRecordDone1.setStatus(6);
            if (cashRecordDone1.getId() != null || cashRecordDone1.getOrderCode() != null) {
                cashRefundMapper.updateStatus(cashRecordDone1);
            } else {
                throw new SystemException("提交失败");
            }
        } catch (BusinessException | SystemException e) {
            throw e;
        } catch (Exception e) {
            log.error("addOnline error", e);
            throw new SystemException("提交失败：" + e.getMessage());
        }
    }

    @Override
    public PageInfo<FundsDTO> funds(Integer pageNum, Integer pageSize, FundsDTO fundsDTO) {
// 1. 分页查询主数据
        PageHelper.startPage(pageNum, pageSize);
        if (fundsDTO.getStatuses() == null || fundsDTO.getStatuses().isEmpty()) {
            fundsDTO.setStatuses(Arrays.asList(4, 6));
        }
        List<FundsDTO> list = cashRefundMapper.selectfunds(fundsDTO);

        // 4. 收集所有需要转换的 regionId 和 currencyId
        Set<Integer> regionIds = new HashSet<>();
        Set<Integer> currencyIds = new HashSet<>();
        Set<Integer> reCurrencyIds = new HashSet<>();
        for (FundsDTO dto : list) {
            if (dto.getMarket() != null) {
                regionIds.add(dto.getMarket());
            }
            if (dto.getPaymentCurrency() != null) {
                currencyIds.add(dto.getPaymentCurrency());
            }
            if (dto.getReceivedCurrency() != null) {
                reCurrencyIds.add(dto.getReceivedCurrency());
            }
        }

        // 5. 批量查询地区字典
        Map<Integer, String> regionMap = new HashMap<>();
        if (!regionIds.isEmpty()) {
            List<Region> regions = refundMapper.selectByIds(new ArrayList<>(regionIds));
            for (Region region : regions) {
                regionMap.put(region.getId(), region.getName());
            }
        }

        // 6. 批量查询币种字典
        Map<Integer, String> currencyMap = new HashMap<>();
        if (!currencyIds.isEmpty()) {
            List<Currency> currencies = refundMapper.selectByCIds(new ArrayList<>(currencyIds));
            for (Currency currency : currencies) {
                currencyMap.put(currency.getId(), currency.getName()); // 或 getCode()，按需调整
            }
        }
        Map<Integer, String> reCurrencyMap = new HashMap<>();
        if (!reCurrencyIds.isEmpty()) {
            List<Currency> reCurrencies = refundMapper.selectByCIds(new ArrayList<>(reCurrencyIds));
            for (Currency reCurrency : reCurrencies) {
                reCurrencyMap.put(reCurrency.getId(), reCurrency.getName()); // 或 getCode()，按需调整
            }
        }

        // 7. 回填地区名称和币种名称到 DTO
        for (FundsDTO dto : list) {
            dto.setMarketName(regionMap.get(dto.getMarket()));
            dto.setPaymentCurrencyName(currencyMap.get(dto.getPaymentCurrency()));
            dto.setReceivedCurrencyName(reCurrencyMap.get(dto.getReceivedCurrency()));
        }

        // 8. 返回分页结果
        return new PageInfo<>(list);
    }



    /**
     * 计算用户指定钱包列表的总可用余额
     * @param jwcode 用户标识
     * @param records 原始充值流水列表（用于提取 wallet_id 列表）
     * @return 总余额（BigDecimal）
     */
    private BigDecimal getUserTotalBalance(Integer jwcode, List<UserWalletRecord> records) {
        // 提取涉及到的 wallet_id 列表（去重）
        List<Integer> walletIds = records.stream()
                .map(UserWalletRecord::getWalletId)
                .distinct()
                .collect(Collectors.toList());

        if (CollectionUtils.isEmpty(walletIds)) {
            return BigDecimal.ZERO;
        }

        // 批量查询钱包当前余额（避免 N+1 查询）
        List<UserRegionWallet> wallets = walletMapper.selectWalletsByJwcodeAndIds(jwcode, walletIds);

        // 汇总余额
        return wallets.stream()
                .map(UserRegionWallet::getCurrentPermanentGold)
                .filter(Objects::nonNull)
                .reduce(BigDecimal.ZERO, BigDecimal::add);
    }

}