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

package com.example.demo.serviceImpl.cash;

import com.example.demo.Util.JWTUtil;
import com.example.demo.Util.LanguageTranslationUtil;
import com.example.demo.config.RabbitMQConfig;
import com.example.demo.domain.DTO.PerformanceDTO;
import com.example.demo.domain.entity.*;
import com.example.demo.domain.vo.cash.*;
import com.example.demo.domain.vo.coin.GoldUser;
import com.example.demo.domain.vo.coin.Messages;
import com.example.demo.domain.vo.coin.Result;
import com.example.demo.mapper.cash.CashCollectionMapper;
import com.example.demo.mapper.coin.MarketMapper;
import com.example.demo.mapper.coin.UserMapper;
import com.example.demo.service.cash.CashCollectionService;
import com.github.pagehelper.PageHelper;
import com.github.pagehelper.PageInfo;
import jakarta.servlet.http.HttpServletRequest;
import lombok.extern.slf4j.Slf4j;
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.util.CollectionUtils;
import org.springframework.web.bind.annotation.RequestHeader;
import org.springframework.web.context.request.RequestContextHolder;
import org.springframework.web.context.request.ServletRequestAttributes;

import java.math.BigDecimal;
import java.time.LocalDateTime;
import java.time.ZoneOffset;
import java.util.Arrays;
import java.util.List;
import java.util.Objects;
import java.util.UUID;
import java.util.stream.Collectors;

/**
 * @program: gold-java
 * @ClassName cashCollectionServiceImpl
 * @description: 处理收款相关业务逻辑
 * @author: Ethan
 * @create: 2025−09-26 11:23
 * @Version 1.0
 **/
@Service
@Slf4j
public class CashCollectionServiceImpl implements CashCollectionService {

    @Autowired
    private CashCollectionMapper cashCollectionMapper;
    @Autowired
    private UserMapper userMapper;
    @Autowired
    private MarketMapper marketMapper;
    @Autowired
    private RabbitTemplate rabbitTemplate;
    @Autowired
    private LanguageTranslationUtil languageTranslationUtil;

    //新增收款订单
    @Override
    public String add(CashCollection cashCollection,@RequestHeader(defaultValue = "zh_CN") String lang) {
        if (cashCollection.getJwcode() == null) {
            throw new IllegalArgumentException("精网号不能为空");
        }
        if (cashCollection.getJwcode() < 10000000 || cashCollection.getJwcode() > 99999999) {
            throw new IllegalArgumentException("精网号必须为8位");
        }
        if (cashCollection.getName() == null || cashCollection.getName().isEmpty()){
            throw new IllegalArgumentException("客户姓名不能为空");
        }
        if (cashCollection.getActivity() == null || cashCollection.getActivity().isEmpty()) {
            throw new IllegalArgumentException("活动不能为空");
        }
        if (cashCollection.getGoodsName() == null|| cashCollection.getGoodsName().isEmpty()) {
            throw new IllegalArgumentException("产品名称不能为空");
        }
        if (cashCollection.getGoodsName().equals("金币充值")) {
            if (cashCollection.getPermanentGold() == 0 && cashCollection.getFreeGold() == 0) {
                throw new IllegalArgumentException("金币数量不能为空");
            }
            if (cashCollection.getWalletId() == null || cashCollection.getWalletId() < 0 || cashCollection.getWalletId() > 10) {
                throw new IllegalArgumentException("钱包ID不能为空");
            }
        }
        if (!cashCollection.getGoodsName().equals("金币充值")) {
            if (cashCollection.getGoodNum() == 0) {
                throw new IllegalArgumentException("产品数量不能为空");
            }
            if (cashCollection.getNumUnit() == null|| cashCollection.getNumUnit().isEmpty()) {
                throw new IllegalArgumentException("数量单位不能为空");
            }
        }
        if (cashCollection.getPaymentCurrency() == null || cashCollection.getPaymentCurrency().isEmpty()) {
            throw new IllegalArgumentException("支付币种不能为空");
        }
        if (cashCollection.getPaymentAmount() == null || cashCollection.getPaymentAmount().compareTo(BigDecimal.ZERO) == 0) {
            throw new IllegalArgumentException("支付金额不能为空");
        }
        if (cashCollection.getPayType() == null|| cashCollection.getPayType().isEmpty()) {
            throw new IllegalArgumentException("支付方式不能为空");
        }
        if (cashCollection.getReceivedMarket() == null||cashCollection.getReceivedMarket().isEmpty()) {
            throw new IllegalArgumentException("到账地区不能为空");
        }
        if (cashCollection.getPayTime() == null) {
            throw new IllegalArgumentException("付款时间不能为空");
        }
        //生成订单号后半部分
        String orderNumber = UUID.randomUUID().toString().replaceAll("-", "");
        CashRecord cashRecord = new CashRecord();
        //构建订单信息
        cashRecord.setOrderCode("XJ_" + orderNumber);   //订单号
        cashRecord.setJwcode(cashCollection.getJwcode());   //精网号
        cashRecord.setName(cashCollection.getName());   //客户姓名
        cashRecord.setActivity(cashCollection.getActivity());   // 活动
        cashRecord.setGoodsName(cashCollection.getGoodsName()); //商品名称
        cashRecord.setGoodNum(cashCollection.getGoodNum());    //商品数量
        cashRecord.setNumUnit(cashCollection.getNumUnit());     //数量单位
        cashRecord.setPermanentGold(cashCollection.getPermanentGold()); //永久金币
        cashRecord.setFreeGold(cashCollection.getFreeGold());   //免费金币
        cashRecord.setWalletId(cashCollection.getWalletId());   // 钱包 ID
        cashRecord.setPaymentCurrency(cashCollection.getPaymentCurrency()); //付款币种
        cashRecord.setPaymentAmount(cashCollection.getPaymentAmount());     //付款金额
        cashRecord.setReceivedMarket(cashCollection.getReceivedMarket());   //到账地区
        cashRecord.setPayType(cashCollection.getPayType());     //支付方式
        cashRecord.setPayTime(cashCollection.getPayTime());     //付款时间
        cashRecord.setVoucher(cashCollection.getVoucher());     //转账凭证
        cashRecord.setRemark(cashCollection.getRemark());       //备注
        cashRecord.setStatus(0);    //订单状态：付款线下财务待审核
        cashRecord.setSubmitterId(cashCollection.getSubmitterId()); //提交人 ID
        cashRecord.setSubmitterMarket(cashCollection.getSubmitterMarket());
        cashRecord.setOrderType(1);     //订单类型：1-收款
        cashRecord.setMarket(cashCollection.getMarket());
        //地区，根据jwcode插入
        //cashRecord.setMarket(cashCollectionMapper.getMarketByJwcode(cashRecord.getJwcode()));
        //插入新收款订单
        cashCollectionMapper.add(cashRecord);
        // 发送收款创建消息
        Messages message = new Messages();
        message.setJwcode(cashRecord.getJwcode());
        message.setName(cashRecord.getName());
        message.setStatus(cashRecord.getStatus());
        message.setDesc("的现金收款申请待审核，前往审核");
        message.setTitle("现金管理--收款处理");
        message.setType(0);
        message.setTypeId(cashRecord.getId());
        message.setMarket(Integer.valueOf(cashRecord.getMarket()));
        String marketName = marketMapper.getMarketNameById(String.valueOf(message.getMarket()));
        message.setMarketName(marketName);
        message.setQueryId(67);
        rabbitTemplate.convertAndSend(RabbitMQConfig.CASH_COLLECTION_EXCHANGE, "cash.collection.save", message);
        return "添加成功";
    }

    @Override
    public String addFreeCoin(CashCollection cashCollection,@RequestHeader(defaultValue = "zh_CN") String lang) {
        if (cashCollection.getJwcode() == null) {
            throw new IllegalArgumentException("精网号不能为空");
        }
        if (cashCollection.getJwcode() < 10000000 || cashCollection.getJwcode() > 99999999) {
            throw new IllegalArgumentException("精网号必须为8位");
        }
        if (cashCollection.getName() == null || cashCollection.getName().isEmpty()){
            throw new IllegalArgumentException("客户姓名不能为空");
        }
        if (cashCollection.getActivity() == null || cashCollection.getActivity().isEmpty()) {
            throw new IllegalArgumentException("活动不能为空");
        }
        if (cashCollection.getFreeGold() == 0) {
            throw new IllegalArgumentException("免费金币数量不能为空");
        }
        //生成订单号后半部分
        String orderNumber = UUID.randomUUID().toString().replaceAll("-", "");
        CashRecord cashRecord = new CashRecord();
        //构建订单信息
        cashRecord.setOrderCode("XJ_" + orderNumber);   //订单号
        cashRecord.setJwcode(cashCollection.getJwcode());   //精网号
        cashRecord.setName(cashCollection.getName());   //客户姓名
        cashRecord.setActivity(cashCollection.getActivity());   // 活动
        cashRecord.setGoodsName("免费金币赠送"); //商品名称
        cashRecord.setFreeGold(cashCollection.getFreeGold());   //免费金币
        cashRecord.setRemark(cashCollection.getRemark());       //备注
        cashRecord.setStatus(0);    //订单状态：付款线下财务待审核
        cashRecord.setSubmitterId(cashCollection.getSubmitterId()); //提交人ID
        cashRecord.setSubmitterMarket(cashCollection.getSubmitterMarket());
        cashRecord.setOrderType(1);     //订单类型：1-收款
        cashRecord.setMarket(cashCollection.getMarket());
        //地区，根据jwcode插入
        //cashRecord.setMarket(cashCollectionMapper.getMarketByJwcode(cashRecord.getJwcode()));
        //插入新收款订单
        cashCollectionMapper.add(cashRecord);
        // 发送收款创建消息
        Messages message = new Messages();
        message.setJwcode(cashRecord.getJwcode());
        message.setName(cashRecord.getName());
        message.setStatus(cashRecord.getStatus());
        message.setDesc("的现金收款申请待审核，请前往审核");
        message.setTitle("现金收款--现金收款");
        message.setType(1);
        message.setTypeId(cashRecord.getId());
        message.setMarket(Integer.valueOf(cashRecord.getMarket()));
        String marketName = marketMapper.getMarketNameById(String.valueOf(message.getMarket()));
        message.setMarketName(marketName);
        message.setQueryId(67);
        rabbitTemplate.convertAndSend(RabbitMQConfig.CASH_COLLECTION_EXCHANGE, "cash.collection.save", message);
        return "添加成功";
    }

    //撤回未审核的订单
    @Override
    public String cancel(String orderCode) {
        // 查询订单是否存在
        CashRecord cashRecord = cashCollectionMapper.selectByOrderCode(orderCode);
        if (cashRecord == null) {
            throw new IllegalArgumentException("订单不存在");
        }
        if (cashRecord.getStatus() != 0) {
            throw new IllegalArgumentException("订单状态不符合条件");
        }

        // 更新订单状态为撤回状态（5）
        int rows = cashCollectionMapper.updateStatus(orderCode, 5);

        // 更新与该订单关联的消息记录的 flag 字段为 1
        try {
            // 根据订单ID查找关联的消息记录
            Messages message = new Messages();
            message.setTypeId(cashRecord.getId()); // 订单ID作为消息的 typeId
            message.setType(0); // 消息类型为收款

            // 更新消息的 flag 字段为 1
            int messageRows = cashCollectionMapper.updateMessageFlagByTypeIdAndType(
                    message.getTypeId(), message.getType(), 1);

            if (messageRows <= 0) {
                log.warn("未找到与订单 {} 关联的消息记录", orderCode);
            }
        } catch (Exception e) {
            log.error("更新消息状态失败，订单号：{}", orderCode, e);
            // 可选择抛出异常或记录日志后继续执行
        }
        return rows > 0 ? "撤回成功" : "撤回失败";
    }

    //编辑并重新提交收款订单
    @Override
    public String reSubmit(CashRecord cashRecord,@RequestHeader(defaultValue = "zh_CN") String lang) {
        if (cashRecord.getJwcode() == null) {
            throw new IllegalArgumentException("精网号不能为空");
        }
        if (cashRecord.getJwcode() < 10000000 || cashRecord.getJwcode() > 99999999) {
            throw new IllegalArgumentException("精网号必须为8位");
        }
        if (cashRecord.getName() == null) {
            throw new IllegalArgumentException("客户姓名不能为空");
        }
        if (cashRecord.getActivity() == null) {
            throw new IllegalArgumentException("活动不能为空");
        }
        if (cashRecord.getGoodsName() == null) {
            throw new IllegalArgumentException("商品名不能为空");
        }
        if (cashRecord.getGoodsName().equals("金币充值")) {
            if (cashRecord.getPermanentGold() == 0 && cashRecord.getFreeGold() == 0) {
                throw new IllegalArgumentException("金币数量不能为空");
            }if (cashRecord.getPermanentGold() == 0){
                throw new IllegalArgumentException("永久金币数量不能为空");
            }
            if (cashRecord.getWalletId() == null) {
                throw new IllegalArgumentException("钱包ID不能为空");
            }
        }
        if (!cashRecord.getGoodsName().equals("金币充值")) {
            if (cashRecord.getGoodNum() == 0) {
                throw new IllegalArgumentException("产品数量不能为空");
            }
            if (cashRecord.getNumUnit() == null) {
                throw new IllegalArgumentException("数量单位不能为空");
            }
        }
        if (cashRecord.getPaymentCurrency() == null) {
            throw new IllegalArgumentException("支付币种不能为空");
        }
        if (cashRecord.getPaymentAmount() == null || cashRecord.getPaymentAmount().compareTo(BigDecimal.ZERO) == 0) {
            throw new IllegalArgumentException("支付金额不能为空");
        }
        if (cashRecord.getPayType() == null) {
            throw new IllegalArgumentException("支付方式不能为空");
        }
        if (cashRecord.getReceivedMarket() == null) {
            throw new IllegalArgumentException("到账地区不能为空");
        }
        if (cashRecord.getPayTime() == null) {
            throw new IllegalArgumentException("付款时间不能为空");
        }

        CashRecord status = cashCollectionMapper.selectByOrderCode(cashRecord.getOrderCode());
        if (!status.getStatus().equals(5)) {
            throw new IllegalArgumentException("只允许编辑已撤回订单");
        }
        //地区，根据jwcode插入（弃用，插入前调用接口获取地区和姓名，之后前端传入）
        //cashRecord.setMarket(cashCollectionMapper.getMarketByJwcode(cashRecord.getJwcode()));
        int rows = cashCollectionMapper.updateByOrderCode(cashRecord);
        if (rows > 0) {
            // 发送收款创建消息
            Messages message = new Messages();
            message.setJwcode(cashRecord.getJwcode());
            message.setName(cashRecord.getName());
            message.setStatus(cashRecord.getStatus());
            message.setDesc("的现金收款申请待审核，前往审核");
            message.setTitle("现金管理--收款处理");
            message.setType(0);
            message.setTypeId(cashRecord.getId());
            message.setMarket(Integer.valueOf(cashRecord.getMarket()));
            String marketName = marketMapper.getMarketNameById(String.valueOf(message.getMarket()));
            message.setMarketName(marketName);
            message.setQueryId(67);
            rabbitTemplate.convertAndSend(RabbitMQConfig.CASH_COLLECTION_EXCHANGE, "cash.collection.save", message);
        }
        return rows > 0 ? "重新提交成功" : "重新提交失败";
    }

    //多条件查询收款订单列表
    @Override
    public PageInfo<CashCollection> selectCollection(Integer pageNum, Integer pageSize, CashCollection cashCollection) {
     /*   //将操作人的地区列表改为id
        List<String> markets = marketMapper.getMarketIds(cashCollection.getMarkets());
        if (markets.contains("9") || markets.contains("9999")) {
            markets = null;
        }*/
        //  cashCollection.setReceivedMarket(marketMapper.getMarketId(cashCollection.getReceivedMarket()));
        if (cashCollection.getCashRoleId() == 2) {
            //角色是总部时，若不特地传状态，传1346，sql处理为（1，3，4，6）筛选，
            if (cashCollection.getStatus() == null) {
                cashCollection.setStatus(1346);
            }
            cashCollection.setSubmitterId(null);
            cashCollection.setReceivedMarket(null);
            cashCollection.setSubmitterMarket(null);
        }
        if (cashCollection.getCashRoleId() == 1) {
            //角色是地方财务，提交人置空不设筛选条件,仅按收款地区、提交人地区筛选（）

            if (cashCollection.getStatus() == null) {
                cashCollection.setStatus(123460);
            }
            //状态为待审核和已驳回时按照提交人地区筛选
            if (cashCollection.getStatus() == 0 || cashCollection.getStatus() == 2) {
                cashCollection.setReceivedMarket(null);
            }
            //状态为已通过和Link通过时，满足收款地区或提交人地区即可
          /*  if (cashCollection.getStatus() == 13) {
                cashCollection.setSubmitterId(null);
            }*/
            //状态为13 或46，已通过或已完成和已退款，满足收款地区或提交人地区即可，
            cashCollection.setSubmitterId(null);


        }
        if (cashCollection.getCashRoleId() == 0) {
            //角色是地方财务，提交人置空不设筛选条件---仅当角色是0 地方客服时，按提交人筛选
            if (cashCollection.getStatus() == null) {
                cashCollection.setStatus(1234560);
            }
            cashCollection.setSubmitterId(cashCollection.getSubmitterId());
            cashCollection.setReceivedMarket(null);
        }
       // cashCollection.setMarkets(markets);
        PageHelper.startPage(pageNum, pageSize);     //必须要直接跟mapper
        List<CashCollection> cashCollections = cashCollectionMapper.selectCollection1(pageNum, pageSize, cashCollection);
        return new PageInfo<>(cashCollections);
    }

    //补全手续费等内容
    @Override
    @Transactional(rollbackFor = Exception.class)
    public String complete(CashRecord cashRecord) {


        if (!Objects.equals(cashRecord.getPaymentCurrency(), cashRecord.getReceivedCurrency())
                && ("Stripe".equals(cashRecord.getPayType()) || "Paypal".equals(cashRecord.getPayType()))) {
            return "支付币种与收款币种不一致";
        }

        int rows = cashCollectionMapper.complete(cashRecord);
        String goodsName = cashCollectionMapper.selectGoodsNameByCode(cashRecord.getOrderCode());
        if (goodsName != null && goodsName.equals("金币充值")) {
            cashRecord.setOrderCode(cashRecord.getOrderCode().replace("XJ_", "XJCZ_"));
            //修改金币订单
            cashCollectionMapper.updateGoldOrder(cashRecord);
        }
        return rows > 0 ? "编辑成功" : "编辑失败";
    }

    //根据精网号查询姓名和地区
    @Override
    public Result getNameAndMarket(Integer jwcode,@RequestHeader(defaultValue = "zh_CN") String lang) {
        try {
            HttpServletRequest request = ((ServletRequestAttributes) RequestContextHolder.getRequestAttributes()).getRequest();
            String token = request.getHeader("token");
            Admin admin = (Admin) JWTUtil.getUserDetailsList(String.valueOf(token), Admin.class);

            if (admin != null) {
                List<String> list = Arrays.asList(admin.getMarkets().split(","));
                List<String> markets = marketMapper.getMarketIds(list);

                // 检查用户是否存在
                int userCount = cashCollectionMapper.checkUserExists(jwcode);
                if (userCount == 0) {
                    String message = languageTranslationUtil.translate("精网号有误！请检查", lang);
                    return Result.error(message);
                }

                if (markets.contains("9") || markets.contains("9999")) {
                    // 有特殊权限，可访问所有用户
                    User user = new User();
                    user.setMarket(cashCollectionMapper.getMarketByJwcode(jwcode));
                    user.setName(cashCollectionMapper.getNameByJwcode(jwcode));
                    user.setMarketName(cashCollectionMapper.getMarketNameByJwcode(jwcode));
                    return Result.success(user);
                } else {
                    // 检查用户所在市场是否在管理员权限范围内
                    String userMarket = cashCollectionMapper.getMarketByJwcode(jwcode);

                    if (userMarket != null && markets.contains(userMarket)) {
                        // 有权限访问，返回用户信息
                        User user = new User();
                        user.setMarket(userMarket);
                        user.setName(cashCollectionMapper.getNameByJwcode(jwcode));
                        user.setMarketName(cashCollectionMapper.getMarketNameByJwcode(jwcode));
                        return Result.success(user);
                    } else {
                        // 无权限，返回用户所属地区
                        String userMarketName = cashCollectionMapper.getMarketNameByJwcode(jwcode);
                        String translatedMarketName = languageTranslationUtil.translate(userMarketName, lang);
                        String message = languageTranslationUtil.translate("无权限访问", lang);
                        return Result.errorWithData(message, java.util.Map.of("market", translatedMarketName));
                    }
                }
            } else {
                // admin 为 null，即权限验证失败
                String userMarketName = cashCollectionMapper.getMarketNameByJwcode(jwcode);
                String translatedMarketName = languageTranslationUtil.translate(userMarketName, lang);
                String message = languageTranslationUtil.translate("无权限访问", lang);
                return Result.errorWithData(message, java.util.Map.of("market", translatedMarketName));
            }
        } catch (Exception e) {
            e.printStackTrace();
            String errorMessage = languageTranslationUtil.translate("精网号有误！请检查", lang);
            return Result.error(errorMessage);
        }
    }

    //获取收款活动列表
    @Override
    public List<RechargeActivity> getActivityList() {
        LocalDateTime now = LocalDateTime.now();
        return cashCollectionMapper.getActivityList(now);
    }

    //同步g_order订单到cash_record表
    @Override
    public Object syncToCashRecord() {
        int total = 0;
        while (true) {
            List<GOrder> gOrders = cashCollectionMapper.getUnSync(50);
            if (CollectionUtils.isEmpty(gOrders)) {
                break;
            }
            try {
                // 每批独立事务
                processBatch(gOrders);
                total += gOrders.size();
                log.info("✅ 同步完成一批，数量: {}, 累计: {}", gOrders.size(), total);
            } catch (Exception e) {

                    List<Integer> failedIds = gOrders.stream().map(GOrder::getId).collect(Collectors.toList());
                    log.error("失败订单ID: {}", failedIds);
                    // 可存入 error_log 表，供人工处理



                   
                // 这里选择继续下一批（容忍部分失败）
            }

            if (gOrders.size() < 50) {
                break; // 最后一批
            }
        }
        return "同步完毕，成功处理 " + total + " 条";
    }
    @Override
    @Transactional(rollbackFor = Exception.class)
    public void processBatch(List<GOrder> gOrders) {
        for (GOrder gOrder : gOrders) {
            CashRecord cashRecord = new CashRecord();
            //构建基础信息
            cashRecord.setOrderType(1);
            cashRecord.setJwcode(gOrder.getJwcode());
            String name=cashCollectionMapper.getNameByJwcode(gOrder.getJwcode());
            if (name!=null){
                cashRecord.setName(name);
            }else cashRecord.setName("未知");

            cashRecord.setMarket(cashCollectionMapper.getMarketByJwcode(gOrder.getJwcode()));
            if (gOrder.getType().equals("gold")){   //充金豆
                cashRecord.setActivity("99");
                cashRecord.setGoodsName("Link充值金豆");
                cashRecord.setRemark("Link充值金豆");
                cashRecord.setNumUnit("个");
                cashRecord.setPermanentGold(0);
                cashRecord.setGoodNum(gOrder.getCount());

            }
            if (gOrder.getType().equals("gold_coin")){//充金币
                cashRecord.setActivity("98");
                cashRecord.setGoodsName("Link充值金币");
                cashRecord.setRemark("Link充值金币");
                cashRecord.setPermanentGold(gOrder.getCount()*100);
                cashRecord.setGoodNum(0);

            }
            cashRecord.setOrderCode(gOrder.getOrderNo());
            if (gOrder != null) {
                switch (gOrder.getPayStyle()) {
                    case 3:
                        cashRecord.setPayType("IOS内购");
                        cashRecord.setBankCode(gOrder.getIosTransactionId());
                        cashRecord.setReceivedMarket("4");
                        cashRecord.setPayload("IOS");
                        break;
                    case 5:
                        cashRecord.setPayType("Stripe");
                        cashRecord.setReceivedMarket("13");
                        cashRecord.setPayload("Stripe");
                        break;
                    case 6:
                        cashRecord.setPayType("PaymentAsia");
                        cashRecord.setReceivedMarket("13");
                        cashRecord.setPayload("PaymentAsia");
                        break;
                    case 7:
                        cashRecord.setPayType("Ipay88");
                        cashRecord.setReceivedMarket("5");
                        cashRecord.setPayload("Ipay88");
                        break;
                    case 9:
                        cashRecord.setPayType("FirstData");
                        cashRecord.setReceivedMarket("4");
                        cashRecord.setBankCode(gOrder.getFirstdataIpgTransactionId());
                        cashRecord.setPayload("FirstData");
                        break;
                    case 10:
                        cashRecord.setPayType("PaySolutions");
                        cashRecord.setReceivedMarket("24018");
                        cashRecord.setPayload("PaySolutions");
                        break;
                    case 15:
                        cashRecord.setPayType("Stripe2");
                        cashRecord.setReceivedMarket("4");
                        cashRecord.setPayload("Stripe2");
                    default:
                        break;
                }
            }
            cashRecord.setFreeGold(0);
            cashRecord.setPaymentCurrency("");
            cashRecord.setPaymentAmount(BigDecimal.valueOf(0));
            //转换时间戳，加上时区偏移
            cashRecord.setPayTime(LocalDateTime.ofEpochSecond(gOrder.getSuccessTime(), 0, ZoneOffset.of("+08:00")));
            cashRecord.setAuditTime(LocalDateTime.ofEpochSecond(gOrder.getSuccessTime(), 0, ZoneOffset.of("+08:00")));
            cashRecord.setStatus(3);
            cashRecord.setSubmitterId(99999);
            //存入现金库
            cashCollectionMapper.add(cashRecord);
            cashCollectionMapper.markSynced(gOrder.getId());
        }
    }

    @Override
    public CashCollection selectById(CashCollection cashCollection) {

        return cashCollectionMapper.selectById(cashCollection.getId());
    }
    //根据goldcoin订单号查询收款订单
    @Override
    public CashCollection selectByGoldCoinOrderCode(String orderNo) {
        return cashCollectionMapper.selectByGoldCoinOrderCode(orderNo);
    }

    //多条件查询收款订单列表
    @Override
    public PageInfo<PerformanceVO> performanceSelect(Integer pageNum, Integer pageSize, PerformanceDTO performanceDTO) {
        PageHelper.startPage(pageNum, pageSize);     //必须要直接跟mapper
        List<PerformanceVO> performanceVOs = cashCollectionMapper.performanceSelect(performanceDTO);
        return new PageInfo<>(performanceVOs);
    }

    // 根据精网号和钱包 ID 查询用户钱包明细列表（分页）
    @Override
    public PageInfo<UserWalletRecordVO> selectWalletRecordsByJwcodeAndWalletId(
            Integer pageNum, Integer pageSize, Integer jwcode, Integer walletId) {
        PageHelper.startPage(pageNum, pageSize);
        List<UserWalletRecordVO> records = cashCollectionMapper.selectWalletRecordsByJwcodeAndWalletId(jwcode, walletId);
        return new PageInfo<>(records);
    }

    // 根据精网号和地区查询用户的所有钱包 ID 和金币数量（包含用户名和地区）（分页）
    @Override
    public PageInfo<UserWalletVO> selectUserWallets(Integer jwcode, String market, Integer pageNum, Integer pageSize) {
        PageHelper.startPage(pageNum, pageSize);
        List<UserWalletVO> wallets = cashCollectionMapper.selectUserWallets(jwcode, market);
        return new PageInfo<>(wallets);
    }
}