yhlxj/netflix-service/src/main/java/com/cyksj/service/mange/impl/CmsOrderDonServiceImpl.java

package com.cyksj.service.mange.impl;

import cn.hutool.core.collection.CollUtil;
import cn.hutool.core.date.DateField;
import cn.hutool.core.date.DateTime;
import cn.hutool.core.date.DateUtil;
import cn.hutool.core.lang.Assert;
import cn.hutool.core.util.ObjectUtil;
import cn.hutool.core.util.StrUtil;
import com.alipay.api.AlipayClient;
import com.alipay.api.domain.AlipayTradeRefundModel;
import com.alipay.api.request.AlipayTradeRefundRequest;
import com.alipay.api.response.AlipayTradeRefundResponse;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.cyksj.common.constant.Constant;
import com.cyksj.common.exception.BusinessRuntimeException;
import com.cyksj.common.task.GlobalThreadPoolTaskExecutor;
import com.cyksj.common.util.Codec;
import com.cyksj.common.util.Jsons;
import com.cyksj.common.util.StringUtil;
import com.cyksj.common.util.Xmls;
import com.cyksj.config.WeChatConfig;
import com.cyksj.config.zfb.AliPayClientFactory;
import com.cyksj.dto.RedisKey;
import com.cyksj.mapper.*;
import com.cyksj.mapper.channel.ShopConfigMapper;
import com.cyksj.mapper.channel.UserPayEquipmentAvailableBenefitsMapper;
import com.cyksj.mapper.channel.UserPayEquipmentReceiveBenefitsRecordMapper;
import com.cyksj.mapper.manage.cms.CmsUserMapper;
import com.cyksj.mapper.manage.distribute.DistributeWaitingSendPointsMapper;
import com.cyksj.mapper.manage.distribute.UserDistributeBusinessOrderDonRecordMapper;
import com.cyksj.mapper.manage.distribute.UserDistributeMapper;
import com.cyksj.mapper.manage.distribute.equipment.EquipmentUserDistributeTransportBenefitsMapper;
import com.cyksj.mapper.manage.distribute.sub.UserDistributeSubMapper;
import com.cyksj.mapper.manage.distribute.sub.UserDistributeSubRewardsMapper;
import com.cyksj.mapper.manage.distribute.sub.UserDistributeSubWaitingMapper;
import com.cyksj.mapper.manage.sys.WorkOrderMapper;
import com.cyksj.mapper.mirrorshop.UserMirrorShopDistributeWaitingSendPointsMapper;
import com.cyksj.mapper.mirrorshop.UserMirrorShopMapper;
import com.cyksj.mapper.shop.YhShopUserDistributeBusinessOrderDonRecordMapper;
import com.cyksj.mapper.stock.GoodsSkuStockRelateMapper;
import com.cyksj.model.entity.*;
import com.cyksj.model.excel.ExcelOrderDonInfo;
import com.cyksj.model.manage.request.ReqSetLogisticsPost;
import com.cyksj.model.manage.views.GroupsRelationView;
import com.cyksj.model.request.ChangeRelationReq;
import com.cyksj.model.request.ClickOutReq;
import com.cyksj.model.request.OrderBalanceRefundReq;
import com.cyksj.model.request.OrderRefundReq;
import com.cyksj.redis.RedisService;
import com.cyksj.service.coin.UserGalaxyCoinService;
import com.cyksj.service.coupon.CouponFontService;
import com.cyksj.service.distribute.equipment.EquipmentDistributeService;
import com.cyksj.service.giftcard.GiftCardOrderUseRecordService;
import com.cyksj.service.mange.CmsOrderDonService;
import com.cyksj.service.mange.MirrorUserCleatService;
import com.cyksj.service.mange.stock.GoodsDonStockService;
import com.cyksj.service.market.MarketFrontService;
import com.cyksj.service.order.OrderCommonService;
import com.cyksj.service.order.OrderRefundService;
import com.cyksj.service.order.UserRealOrderBenefitsService;
import com.cyksj.service.relation.GroupRelationClearService;
import com.cyksj.service.relation.GroupRelationFrontService;
import com.cyksj.service.relation.GroupsRelationExpiryRecordService;
import com.cyksj.service.relation.GroupsRelationNetflixService;
import com.cyksj.service.shop.YhShopDistributeService;
import com.cyksj.service.user.UserBenefitsService;
import com.cyksj.service.user.UserBindRelationService;
import com.cyksj.service.wechat.WeChatService;
import com.ejlchina.searcher.BeanSearcher;
import com.ejlchina.searcher.util.MapUtils;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.springframework.dao.DuplicateKeyException;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import java.math.BigDecimal;
import java.math.RoundingMode;
import java.util.Date;
import java.util.List;
import java.util.Map;
import java.util.Optional;
import java.util.concurrent.atomic.AtomicInteger;
import java.util.stream.Collectors;

/**
 * @author chan
 * @date 2021/10/25 下午10:14
 */
@Service
@Slf4j
@RequiredArgsConstructor
public class CmsOrderDonServiceImpl extends ServiceImpl<OrderDonMapper,OrderDon> implements CmsOrderDonService {

    private final OrderDonTransportMapper transportMapper;

    private final OrderDonWaybillMapper orderDonWaybillMapper;

    private final GoodsSkuStockRelateMapper skuStockRelateMapper;

    private final GoodsDonStockService goodsDonStockService;

    private final GoodsDonSkuMapper goodsDonSkuMapper;

    private final UserRealOrderBenefitsService userRealOrderBenefitsService;

    private final UserRelationKickOutRecordMapper kickOutRecordMapper;

    private final CmsUserMapper cmsUserMapper;

    private final OrderCommonService orderCommonService;

    private final GoodsDonMapper goodsDonMapper;

    private final RedisService redisService;

    private final UserBenefitsService userBenefitsService;

    private final DistributeWaitingSendPointsMapper distributeWaitingSendPointsMapper;

    private final RefundOrderDonMapper refundOrderDonMapper;

    private final UserDistributeMapper userDistributeMapper;

    private final OrderDonMapper orderDonMapper;

    private final MarketFrontService marketFrontService;

    private final EquipmentDistributeService equipmentDistributeService;

    private final CouponFontService couponFontService;

    private final WeChatService weChatService;

    private final WeChatConfig weChatConfig;

    private final ShopConfigMapper shopConfigMapper;

    private final GroupRelationClearService relationClearService;

    private final GroupsRelationMapper relationMapper;

    private final GroupsMapper groupsMapper;

    private final GoodsDonSkuMapper skuMapper;

    private final UserDistributeBusinessOrderDonRecordMapper businessOrderDonRecordMapper;

    private final WorkOrderMapper workOrderMapper;

    private final OrderRefundService orderRefundService;

    private final OrderDiscountPlusPurchaseSkuRelationMapper orderDiscountPlusPurchaseSkuRelationMapper;

    private final EquipmentUserDistributeTransportBenefitsMapper transportBenefitsMapper;

    private final BeanSearcher beanSearcher;

    private final UserPayEquipmentReceiveBenefitsRecordMapper receiveBenefitsRecordMapper;

    private final GroupsRelationExpiryRecordService groupsRelationExpiryRecordService;

    private final GiftCardOrderUseRecordService giftCardOrderUseRecordService;

    private final GiftCardUserRecordMapper giftCardUserRecordMapper;

    private final YhShopDistributeService yhShopDistributeService;

    private final YhShopUserDistributeBusinessOrderDonRecordMapper yhShopBusinessOrderDonRecordMapper;

    private final UserPayEquipmentAvailableBenefitsMapper availableBenefitsMapper;

    private final GroupRelationFrontService groupRelationFrontService;

    private final UserMapper userMapper;

    private final ChatgptUserMapper chatgptUserMapper;

    private final UserDistributeSubMapper userDistributeSubMapper;

    private final UserDistributeSubWaitingMapper subWaitingMapper;

    private final UserDistributeSubRewardsMapper userDistributeSubRewardsMapper;

    private final UpgradeOrderDonMapper upgradeOrderDonMapper;

    private final UpgradePackageMapper upgradePackageMapper;

    private final MidjourneyUserMapper midjourneyUserMapper;

    private final GroupsRelationMapper groupsRelationMapper;

    private final UserBindRelationService userBindRelationService;

    private final GroupsRelationNetflixService groupsRelationNetflixService;

    private final AccountMapper accountMapper;

    private final MirrorUserCleatService mirrorUserCleatService;

    private final OrderDonRenewRecordMapper orderDonRenewRecordMapper;

    private final OrderDonUpgradeRenewRecordMapper orderDonUpgradeRenewRecordMapper;

    private final LumaUserMapper lumaUserMapper;

    private final UserBenefitsOrderRecordMapper userBenefitsOrderRecordMapper;

    private final UserBenefitsComboRelationRecordMapper userBenefitsComboRelationRecordMapper;

    private final UserMirrorShopMapper userMirrorShopMapper;

    private final UserMirrorShopDistributeWaitingSendPointsMapper userMirrorShopDistributeWaitingSendPointsMapper;

    private final ClaudeUserMapper claudeUserMapper;

    private final UserTicketClearedRecordMapper userTicketClearedRecordMapper;

    private final NetflixUserAccountSubmitRecoverRecordMapper netflixUserAccountSubmitRecoverRecordMapper;

    private final NetflixUserChangeOtherTicketRecordMapper netflixUserChangeOtherTicketRecordMapper;

    private final OrderDonGalaxyCoinRecordMapper orderDonGalaxyCoinRecordMapper;

    private final UserGalaxyCoinService userGalaxyCoinService;

    private static final GlobalThreadPoolTaskExecutor TASK_POOL = GlobalThreadPoolTaskExecutor.getInstance();

    @Override
    public List<ExcelOrderDonInfo> exportOrderInfo(Long promotionId, String start, String end) {
        return this.getBaseMapper().exportOrderInfo(promotionId,start,end);
    }

    @Override
    public OrderDonTransport getTransport(Long orderId) {
        return transportMapper.selectOne(Wrappers.lambdaQuery(OrderDonTransport.class).eq(OrderDonTransport::getOrderId, orderId));
    }

    @Transactional(rollbackFor = Throwable.class)
    @Override
    public OrderDonWaybill setWaybill(ReqSetLogisticsPost reqSetLogisticsPost) {
        OrderDonWaybill orderDonWaybill = Optional.ofNullable(orderDonWaybillMapper.selectOne(Wrappers.lambdaQuery(OrderDonWaybill.class).eq(OrderDonWaybill::getOrderId, reqSetLogisticsPost.getOrderId()))).orElse(new OrderDonWaybill());
        orderDonWaybill.setCodeCn(reqSetLogisticsPost.getCodeCn());
        orderDonWaybill.setTrackingNumber(reqSetLogisticsPost.getTrackingNumber());
        orderDonWaybill.setOrderId(reqSetLogisticsPost.getOrderId());
        orderDonWaybill.setRemark(reqSetLogisticsPost.getRemark());
        OrderDon orderDon = getById(orderDonWaybill.getOrderId());
        Integer type = Optional.ofNullable(reqSetLogisticsPost.getType()).orElse(0);
        //实物发货
        if (type == 0 || type == 1) {
            if (orderDonWaybill.getId() == null) {
                try {
                    orderDonWaybillMapper.insert(orderDonWaybill);
                } catch (DuplicateKeyException e) {
                    return orderDonWaybill;
                }
                orderDon.setStatus(OrderDon.Status.transport);
                updateById(orderDon);
                //库存扣减逻辑
                List<GoodsSkuStockRelate> relateList = skuStockRelateMapper.selectList(Wrappers.lambdaQuery(GoodsSkuStockRelate.class).eq(GoodsSkuStockRelate::getSkuId, orderDon.getSkuId()));
                if (!relateList.isEmpty()) {
                    relateList.forEach((relate) -> {
                        goodsDonStockService.upStockRelate(relate.getStockId(), orderDon.getId(), "transport");
                    });
                }
            } else {
                if (orderDon.getStatus() == OrderDon.Status.hasPayment) {
                    orderDon.setStatus(OrderDon.Status.transport);
                    updateById(orderDon);
                }
                orderDonWaybillMapper.updateById(orderDonWaybill);
            }

            //实物分销订单是否存在
            DistributeWaitingSendPoints waitingSendPoints = distributeWaitingSendPointsMapper.selectOne(Wrappers.lambdaQuery(DistributeWaitingSendPoints.class)
                    .eq(DistributeWaitingSendPoints::getOrderId, orderDon.getId())
                    .eq(DistributeWaitingSendPoints::getIsDelivery, false)
                    .last("limit 1"));
            if (waitingSendPoints != null) {
                //实物分销订单发货后再 进行提成结算期
                waitingSendPoints.setIsDelivery(true);
                distributeWaitingSendPointsMapper.updateById(waitingSendPoints);
            }
            //分销有礼 分销实物是否有发货后用户权益
            EquipmentUserDistributeTransportBenefits transportBenefits = transportBenefitsMapper.selectOne(Wrappers.lambdaQuery(EquipmentUserDistributeTransportBenefits.class)
                    .eq(EquipmentUserDistributeTransportBenefits::getOrderId, orderDon.getId())
                    .eq(EquipmentUserDistributeTransportBenefits::getStatus, EquipmentUserDistributeTransportBenefits.Status.hasPayment).last("limit 1"));
            if (transportBenefits != null) {
                if (transportBenefits.getBalance().compareTo(BigDecimal.ZERO) > 0) {
                    //7天后余额到账
                    transportBenefitsMapper.update(null, Wrappers.lambdaUpdate(EquipmentUserDistributeTransportBenefits.class)
                            .set(EquipmentUserDistributeTransportBenefits::getStatus, EquipmentUserDistributeTransportBenefits.Status.transport)
                            .set(EquipmentUserDistributeTransportBenefits::getSendTime, DateUtil.offsetDay(DateTime.now(), 7))
                            .eq(EquipmentUserDistributeTransportBenefits::getOrderId, orderDon.getId())
                            .eq(EquipmentUserDistributeTransportBenefits::getStatus, EquipmentUserDistributeTransportBenefits.Status.hasPayment));
                }
            }
        }

        //权益发货
        if (type == 0 || type == 2) {
            GoodsDonSku sku = goodsDonSkuMapper.selectById(orderDon.getSkuId());
            if (sku != null && sku.getIsBenefits()) {
                //是否实物权益已发放
                Integer count = receiveBenefitsRecordMapper.selectCount(Wrappers.lambdaQuery(UserPayEquipmentReceiveBenefitsRecord.class)
                        .eq(UserPayEquipmentReceiveBenefitsRecord::getRealOrderId, orderDon.getId()));
                if (count == 0) {
                    count = availableBenefitsMapper.selectCount(Wrappers.lambdaQuery(UserPayEquipmentAvailableBenefits.class)
                            .eq(UserPayEquipmentAvailableBenefits::getRealOrderId, orderDon.getId()));
                }
                if (count == 0) {
                    //实物权益未发
                    String benefitsKey = RedisService.key.REAL_GOODS_BENEFITS_KEY.getNameFormat(orderDon.getId());
                    if (redisService.setNx(benefitsKey, orderDon.getId(), RedisService.key.REAL_GOODS_BENEFITS_KEY.getTimeout())) {
                        //发放实物购买权益
                        if (StrUtil.isNotEmpty(sku.getBenefitsList())) {
                            try {
                                List<GoodsDonSku> goodsDonSkus = Jsons.parseList(sku.getBenefitsList(), GoodsDonSku.class);
                                //自购实物 获取权益
                                userRealOrderBenefitsService.getPayRealGoodsBenefits(orderDon.getUserId(), orderDon.getId(), orderDon.getYhsId(), goodsDonSkus);
                                //清除多余的车票
                                clearExtraRelation(orderDon);
                            } catch (Exception e) {
                                redisService.del(benefitsKey);
                            }
                        }
                    }
                }
            }
        }
        return orderDonWaybill;
    }

    @Override
    public void kickOutRelationId(long adminId, ClickOutReq req) {
        Long orderId = req.getOrderId();
        OrderDon orderDon = getById(orderId);
        if (orderDon != null && !orderDon.getIsKickOut()) {
            try {
                UserRelationKickOutRecord kickOutRecord = new UserRelationKickOutRecord();
                kickOutRecord.setUserId(orderDon.getUserId());
                kickOutRecord.setRelationId(orderDon.getRelationId());
                kickOutRecord.setGoodsId(orderDon.getGoodsId());
                kickOutRecord.setSkuId(orderDon.getSkuId());


                kickOutRecord.setReason(req.getReason());
                kickOutRecord.setImg(req.getImg());
                kickOutRecord.setRemark(req.getRemark());
                kickOutRecord.setOrderId(orderDon.getId());
                kickOutRecord.setOrderNo(orderDon.getOrderNo());
                Optional.ofNullable(cmsUserMapper.selectById(adminId)).ifPresent(cmsUser -> kickOutRecord.setOperator(cmsUser.getNickname()));
                kickOutRecordMapper.insert(kickOutRecord);

                orderDon.setIsKickOut(true);
                updateById(orderDon);
                GoodsDon goodsDon = goodsDonMapper.selectById(orderDon.getGoodsId());
                GoodsDonSku goodsDonSku = goodsDonSkuMapper.selectById(orderDon.getSkuId());
                //清除车票
                orderCommonService.clearUnrealGoodsDetail(orderDon, goodsDon.getType(), goodsDonSku);
            } catch (DuplicateKeyException e) {

            }
        }
    }

    @Override
    @Transactional(rollbackFor = Throwable.class)
    public void unifiedRefund(OrderRefundReq refundReq) throws Exception {
        OrderDon orderDon = orderDonMapper.selectById(refundReq.getOrderId());
        GoodsDonSku sku = null;
        if (orderDon.getSkuId() != null) {
            sku = goodsDonSkuMapper.selectById(orderDon.getSkuId());
        }
        GoodsDon goodsDon = goodsDonMapper.selectById(orderDon.getGoodsId());
        if (StrUtil.isEmpty(refundReq.getRefundType())) {
            refundReq.setRefundType("money");
        }
        String refundType = refundReq.getRefundType();
        //校验订单是否符合退款
        checkOrderRefund(orderDon, goodsDon, sku, refundReq);
        //空订单关闭
        if (orderDon.getMoney().compareTo(BigDecimal.ZERO) == 0 && orderDon.getBalance().compareTo(BigDecimal.ZERO) == 0
                && orderDon.getRelationId() == 0) {
            orderDon.setStatus(OrderDon.Status.refund);
            orderDonMapper.updateById(orderDon);
            if (goodsDon.getType() == 2) {
                //扣除用户自身实物权益
                userRealOrderBenefitsService.deductUserRealGoodsBenefits(orderDon.getId());
            }
            return;
        }
        //调用第三方接口退款
        String outNo = StrUtil.EMPTY;
        if (refundReq.getRefundMoney() != null && refundReq.getRefundMoney().compareTo(BigDecimal.ZERO) > 0) {
            outNo = orderRefundService.centerRefund(refundReq, orderDon);
        }
        orderDon.setRefundDesc(refundReq.getRefundDesc());
        //记录退款信息
        commonRefund(orderDon, refundReq.getRefundMoney(), refundReq.getOperator(), goodsDon, sku, outNo, refundType, refundReq.getIsOnly(), refundReq.getRefundBalance(), refundReq.getChatImg(), refundReq.getDeductBalance(), refundReq.getDpRelationIds());
        //修改订单状态
        orderDon.setStatus(OrderDon.Status.refund);
        orderDonMapper.updateById(orderDon);
        //续费升级订单
        if (orderDon.getOrderType() == 2 && sku.getIsMirror()) {
            mirrorUserCleatService.handleRenewUpgradeOrders(orderDon, sku);
        }
        //提交过工单的订单
        //将用户异常订单关闭
        workOrderMapper.update(null, Wrappers.lambdaUpdate(WorkOrder.class)
                .set(WorkOrder::getStatus, WorkOrder.Status.close)
                .eq(WorkOrder::getStatus, WorkOrder.Status.waiting)
                .eq(WorkOrder::getUserId, orderDon.getUserId())
                .eq(WorkOrder::getRelationId, orderDon.getRelationId()));

        //将GPT规格的车队 下次可停车时间置空
        groupRelationFrontService.setGroupsTripsParkingTimeEmpty(sku, orderDon.getRelationId());
    }

    @Override
    @Transactional(rollbackFor = Throwable.class)
    public void unifiedUpgradeRefund(OrderRefundReq refundReq) throws Exception {
        UpgradeOrderDon orderDon = upgradeOrderDonMapper.selectById(refundReq.getOrderId());
        UpgradePackage upgradePackage = upgradePackageMapper.selectById(orderDon.getPackageId());
        if (StrUtil.isEmpty(refundReq.getRefundType())) {
            refundReq.setRefundType("money");
        }
        String refundType = refundReq.getRefundType();
        //校验订单是否符合退款
        checkUpgradeOrderRefund(orderDon, refundReq);
        //空订单关闭
        if (orderDon.getMoney().compareTo(BigDecimal.ZERO) == 0 && orderDon.getBalance().compareTo(BigDecimal.ZERO) == 0) {
            orderDon.setStatus(UpgradeOrderDon.Status.refund);
            upgradeOrderDonMapper.updateById(orderDon);
            return;
        }
        Long userId = orderDon.getUserId();
        List<Long> userIdList = null;
        //检验gpt套餐
        if (upgradePackage.getGoodsId() == 18) {
            userIdList = userBindRelationService.getRelationUserIdList(userId, null);
            //是否有更高级的套餐
            UpgradeOrderDon more = upgradeOrderDonMapper.selectOne(Wrappers.lambdaQuery(UpgradeOrderDon.class)
                    .in(UpgradeOrderDon::getUserId, userIdList)
                    .eq(UpgradeOrderDon::getRelationId, orderDon.getRelationId())
                    .gt(UpgradeOrderDon::getNum, orderDon.getNum())
                    .eq(UpgradeOrderDon::getStatus, UpgradeOrderDon.Status.complete)
                    .last("limit 1"));
            if (more != null) {
                throw BusinessRuntimeException.getInstance("请先退掉其更高级套餐");
            }
        }

        //调用第三方接口退款
        String outNo = orderRefundService.centerUpgradeRefund(refundReq, orderDon);
        orderDon.setRefundDesc(refundReq.getRefundDesc());
        //记录退款信息
        commonUpgradeRefund(orderDon, refundReq.getRefundMoney(), refundReq.getOperator(), upgradePackage, outNo, refundType, refundReq.getIsOnly(), refundReq.getRefundBalance(), refundReq.getChatImg());
        //修改订单状态
        orderDon.setStatus(UpgradeOrderDon.Status.refund);
        upgradeOrderDonMapper.updateById(orderDon);
        //扣除套餐次数
        if (upgradePackage.getGoodsId() == 26) {
            MidjourneyUser midjourneyUser = midjourneyUserMapper.selectOne(Wrappers.lambdaQuery(MidjourneyUser.class).eq(MidjourneyUser::getRelationId, orderDon.getRelationId()));
            if (midjourneyUser != null) {
                int update = midjourneyUserMapper.update(null, Wrappers.lambdaUpdate(MidjourneyUser.class)
                        .set(MidjourneyUser::getMjUpgradeNum, midjourneyUser.getMjUpgradeNum() < upgradePackage.getNum() ? 0 : midjourneyUser.getMjUpgradeNum() - upgradePackage.getNum())
                        .eq(MidjourneyUser::getId, midjourneyUser.getId()));
                if (update == 0) {
                    log.info("midjourneyUser 套餐包增值失败 id:{},orderId:{}", midjourneyUser.getId(), orderDon.getId());
                }
                Long decr = redisService.decr(RedisService.key.MIDJOURNEY_UPGRADE_LIMIT.getName() + midjourneyUser.getId(), upgradePackage.getNum().longValue());
                if (decr < 0) {
                    redisService.set(RedisService.key.MIDJOURNEY_UPGRADE_LIMIT.getName() + midjourneyUser.getId(), 0L);
                }
            }
        }

        //扣除gpt套餐升级
        if (upgradePackage.getGoodsId() == 18) {
            ChatgptUser chatgptUser = chatgptUserMapper.selectOne(Wrappers.lambdaQuery(ChatgptUser.class).eq(ChatgptUser::getRelationId, orderDon.getRelationId()));
            if (chatgptUser != null) {
                GroupsRelation relation = groupsRelationMapper.selectById(chatgptUser.getRelationId());
                GroupsTrips groupsTrips = groupsMapper.selectById(relation.getGroupsId());
                GoodsDonSku sku = skuMapper.selectById(groupsTrips.getSkuId());

                //原先sku的套餐
                Long gptLimitTime = sku.getGptLimitTime();
                Integer gptLimitNum = sku.getGptLimitNum();

                //次等套餐的规格
                UpgradeOrderDon secondUpgrade = upgradeOrderDonMapper.selectOne(Wrappers.lambdaQuery(UpgradeOrderDon.class)
                        .in(UpgradeOrderDon::getUserId, userIdList)
                        .eq(UpgradeOrderDon::getRelationId, orderDon.getRelationId())
                        .lt(UpgradeOrderDon::getNum, orderDon.getNum())
                        .eq(UpgradeOrderDon::getStatus, UpgradeOrderDon.Status.complete)
                        .last("limit 1"));
                Long renewSkuId = chatgptUser.getRenewSkuId();

                //续费升级
                GoodsDonSku renewSku = null;
                if (renewSkuId != null) {
                    renewSku = goodsDonSkuMapper.selectById(renewSkuId);
                    gptLimitTime = renewSku.getGptLimitTime();
                    gptLimitNum = renewSku.getGptLimitNum();
                }

                if (secondUpgrade != null) {
                    gptLimitTime = secondUpgrade.getTime();
                    gptLimitNum = secondUpgrade.getNum();

                    if (renewSku != null) {
                        //低级套餐
                        GoodsDonSku secondSkuUpGrade = goodsDonSkuMapper.selectById(secondUpgrade.getSkuId());
                        //续费升级套餐更高
                        if (renewSku.getMonths() >= secondSkuUpGrade.getMonths() && renewSku.getGptLimitNum() >= secondSkuUpGrade.getGptLimitNum() && renewSku.getGptLimitTime() <= secondSkuUpGrade.getGptLimitTime()) {
                            gptLimitTime = renewSku.getGptLimitTime();
                            gptLimitNum = renewSku.getGptLimitNum();
                        }
                    }
                }
                Long packageId = 0l;
                //降级套餐
                if (secondUpgrade != null) {
                    packageId = secondUpgrade.getPackageId();
                }
                int update = chatgptUserMapper.update(null, Wrappers.lambdaUpdate(ChatgptUser.class)
                        .set(ChatgptUser::getLimitTime, gptLimitTime)
                        .set(ChatgptUser::getLimitNum, gptLimitNum)
                        .set(ChatgptUser::getPackageId, packageId)
                        //无次等套餐 不需要清除套餐时间
                        .set(secondUpgrade == null, ChatgptUser::getClearPackageTime, null)
                        .eq(ChatgptUser::getId, chatgptUser.getId()));
                if (update == 0) {
                    log.info("chatgptUser 升级套餐包增值失败 id:{},orderId:{}", chatgptUser.getId(), orderDon.getId());
                }
            }
        }

        //扣除luma套餐次数
        if (upgradePackage.getGoodsId() == Constant.LUMA_GOODS_ID) {
            LumaUser lumaUser = lumaUserMapper.selectOne(Wrappers.lambdaQuery(LumaUser.class).eq(LumaUser::getRelationId, orderDon.getRelationId()));
            if (lumaUser != null) {
                int update = lumaUserMapper.update(null, Wrappers.lambdaUpdate(LumaUser.class)
                        .set(LumaUser::getNum, lumaUser.getNum() < upgradePackage.getNum() ? 0 : lumaUser.getNum() - upgradePackage.getNum())
                        .eq(LumaUser::getId, lumaUser.getId()));
                if (update == 0) {
                    log.info("lumaUser 套餐包增值失败 id:{},orderId:{}", lumaUser.getId(), orderDon.getId());
                }
                Long decr = redisService.decr(RedisService.key.LUMA_NUM_LIMIT.getName() + lumaUser.getId(), upgradePackage.getNum().longValue());
                if (decr < 0) {
                    redisService.set(RedisService.key.LUMA_NUM_LIMIT.getName() + lumaUser.getId(), 0L);
                }
            }
        }
    }

    /**
     * 退款后 处理关联
     */
    public void commonUpgradeRefund(UpgradeOrderDon orderDon, BigDecimal refundMoney, String operator, UpgradePackage upgradePackage, String outNo, String refundType, Boolean isOnly, BigDecimal refundBalance, String chatImg) {
        TASK_POOL.execute(() -> {
            orderRefundService.refundUpgradeRecord(orderDon, refundMoney,upgradePackage, operator, outNo, refundType, chatImg);
            //退等比例
            if (isOnly != null && isOnly) {
                userBenefitsService.addUserBalance(orderDon.getUserId(), refundBalance, UserBalanceSourceRecord.Source.refund, 0L, orderDon.getId(),  upgradePackage.getName()+ UserBalanceSourceRecord.Source.refund.getDesc(), true);
                BigDecimal orderDonRefundBalance = Optional.ofNullable(orderDon.getRefundBalance()).orElse(BigDecimal.ZERO);
                orderDon.setRefundBalance(orderDonRefundBalance.add(refundBalance));
            }

            //若存在余额支付，退还余额
            if (isOnly == null && orderDon.getBalance().compareTo(BigDecimal.ZERO) > 0) {
                userBenefitsService.addUserBalance(orderDon.getUserId(), orderDon.getBalance(), UserBalanceSourceRecord.Source.refund, 0L, orderDon.getId(), upgradePackage.getName() + UserBalanceSourceRecord.Source.refund.getDesc(), true);
            }

            if (UpgradeOrderDon.Type.BALANCE.getType().equals(refundType)) {
                if (isOnly == null && orderDon.getMoney().compareTo(BigDecimal.ZERO) > 0) {
                    userBenefitsService.addUserBalance(orderDon.getUserId(), orderDon.getRefundBalance(), UserBalanceSourceRecord.Source.refund, 0L, orderDon.getId(), upgradePackage.getName() + UserBalanceSourceRecord.Source.refund.getDesc(), true);
                }
            }
        });
    }
    /**
     * 校验订单是否符合退款操作
     */
    private void checkUpgradeOrderRefund(UpgradeOrderDon orderDon, OrderRefundReq refundReq) {
        if (orderDon == null) {
            throw BusinessRuntimeException.getInstance("订单不存在");
        }
        BigDecimal orderDonRefundMoney = Optional.ofNullable(orderDon.getRefundMoney()).orElse(BigDecimal.ZERO);
        BigDecimal orderDonRefundBalance = Optional.ofNullable(orderDon.getRefundBalance()).orElse(BigDecimal.ZERO);
        String refundType = refundReq.getRefundType();
        if (orderDon.getType() == UpgradeOrderDon.Type.BALANCE && !UpgradeOrderDon.Type.BALANCE.getType().equals(refundType)) {
            throw BusinessRuntimeException.getInstance("余额支付的订单不支持金额退款");
        }
        if (UpgradeOrderDon.Status.refund == orderDon.getStatus()) {
            throw BusinessRuntimeException.getInstance("该订单已退款");
        }
        if (UpgradeOrderDon.Status.noPayment == orderDon.getStatus() || UpgradeOrderDon.Status.close == orderDon.getStatus()) {
            throw BusinessRuntimeException.getInstance("订单{0}状态不支持退款", orderDon.getStatus());
        }

        BigDecimal refundMoney = refundReq.getRefundMoney();
        BigDecimal money = orderDon.getMoney();
        //余额退款
        if (UpgradeOrderDon.Type.BALANCE.getType().equals(refundType)) {
            BigDecimal balance = orderDon.getBalance();
            refundMoney = orderDonRefundBalance.add(refundMoney);
            if (UpgradeOrderDon.Type.BALANCE == orderDon.getType() && refundMoney.compareTo(balance) > 0) {
                throw BusinessRuntimeException.getInstance("退款余额大于订单支付余额");
            }
            if (UpgradeOrderDon.Type.BALANCE != orderDon.getType() && refundMoney.compareTo(money) > 0) {
                throw BusinessRuntimeException.getInstance("退款余额大于订单支付金额");
            }
            orderDon.setRefundBalance(refundMoney);
            orderDon.setRefundMoney(BigDecimal.ZERO);
        } else {
            //退金额
            refundMoney = orderDonRefundMoney.add(refundMoney);
            if (refundMoney.compareTo(money) > 0) {
                throw BusinessRuntimeException.getInstance("退款金额大于订单支付金额");
            }
            orderDon.setRefundMoney(refundMoney);
        }
        if (!redisService.setNx(String.format("%s", refundReq.getOrderId()), refundReq.getOrderId(), 10l)) {
            throw BusinessRuntimeException.getInstance("请勿重复点击,正在退款中..");
        }

    }
    public String wxRefund(OrderRefundReq refundReq, OrderDon orderDon) throws Exception {
        if (orderDon.getMoney().compareTo(BigDecimal.ZERO) <=0){
            return StrUtil.EMPTY;
        }
        long time = System.currentTimeMillis();
        //退款订单号
        String outRefundNo = Codec.DoDigest.custom()
                .setAlgorithm(Codec.DoDigest.Algorithm.MD5)
                .setStringData(time + String.valueOf(orderDon.getId()))
                .toHexString();
        weChatService.refundWxOrder(weChatConfig.getAppid(),
                Optional.ofNullable(orderDon.getShopId()).orElse(ShopConfig.WX_DEFAULT_APP_ID),
                orderDon.getTransactionId(),
                outRefundNo,
                orderDon.getMoney(),
                refundReq.getRefundMoney(),
                weChatConfig.getNotifyDomain() + "manage/order/wx/refund/notify");
        //记录退款信息
        return outRefundNo;
    }

    @Override
    public void wxRefundNotify(Map<String, String> map) throws Exception {
        // 对退款数据 解密
        String md5Key = Codec.DoDigest.custom().setAlgorithm(Codec.DoDigest.Algorithm.MD5).setStringData(shopConfigMapper.getByAppId(map.get("mch_id")).getSecret()).toHexString();
        String reqInfoXml = Codec.DoCipher.custom().setAlgorithm(Codec.DoCipher.Trans.AES_ECB_PKCS7Padding).setBase64Data(map.get("req_info")).setStringKey(md5Key).ofDecrypt().toText();
        log.info("=== 退款数据解密: \n {}", reqInfoXml);
        Map<String, String> reqInfoMap = Xmls.toMap(reqInfoXml);
        // 退款失败
        if (StrUtil.equals("CHANGE", reqInfoMap.get("refund_status"))) {
            throw BusinessRuntimeException.getInstance("退款异常.");
        } else if (StrUtil.equals("REFUNDCLOSE", reqInfoMap.get("refund_status"))) {
            throw BusinessRuntimeException.getInstance("退款关闭.");
        }
        /* 此处处理业务逻辑 */
        String outRefundNo = reqInfoMap.get("out_refund_no");
        String transactionId = reqInfoMap.get("transaction_id");
        String refundFee = reqInfoMap.get("refund_fee");
        OrderDon orderDon = orderDonMapper.selectOne(Wrappers.lambdaQuery(OrderDon.class).eq(OrderDon::getTransactionId, transactionId).last("limit 1"));
        if (orderDon == null) {
            log.error("退款回调,transactionId:{}订单不存在", transactionId);
            return;
        }
        log.info("微信退款: 退款单号[{}] 退款成功.", outRefundNo);
    }

    @Override
    @Transactional(rollbackFor = Throwable.class)
    public void changeRelation(ChangeRelationReq req) throws Exception {
        Long relationId = req.getRelationId();
        Long groupId = req.getGroupsId();
        UserTicketClearedRecord.Source source = req.getSource();
        if (source == null) source = UserTicketClearedRecord.Source.change_ticket;
        GroupsRelation relation = relationMapper.selectById(relationId);
        Long yhsId = relation.getYhsId();
        Assert.notNull(relation, "车票已不存在");
        if (relation.getRechargeStatus() != null) {
            throw BusinessRuntimeException.getInstance("代充账号车票无法更换车票");
        }
        String key = RedisService.key.NETFLIX_CHANGE_TICKET_KEY.getName() + relationId;
        if (!redisService.setNx(key, relationId, RedisService.key.NETFLIX_CHANGE_TICKET_KEY.getTimeout())) {
            throw BusinessRuntimeException.getInstance("正在更换车票中..");
        }
        Long userId = relation.getUserId();
        log.info("用户userId:{}更换车票relationId:{}", userId, relationId);
        OrderDon orderDon = orderDonMapper.selectOne(Wrappers.lambdaQuery(OrderDon.class)
                .eq(OrderDon::getUserId, userId)
                .eq(OrderDon::getRelationId, relationId)
                .notIn(OrderDon::getStatus, Constant.noOrderAllStatus)
                .orderByDesc(OrderDon::getId)
                .last("limit 1"));
        OrderDiscountPlusPurchaseSkuRelation plusPurchaseSkuRelation = null;
        List<Long> plus_relationList = null;
        if (orderDon == null) {
            List<OrderDiscountPlusPurchaseSkuRelation> plusPurchaseSkuRelations = orderDiscountPlusPurchaseSkuRelationMapper.selectPlusRelationByIdAndUserId(relation.getId(), relation.getUserId());
            for (OrderDiscountPlusPurchaseSkuRelation data : plusPurchaseSkuRelations) {
                String relationIds = data.getRelationIds();
                if (StrUtil.isEmpty(relationIds)) {
                    return;
                }
                List<Long> relationList = Jsons.parseList(relationIds, Long.class);
                if (relationList.contains(relationId)) {
                    plusPurchaseSkuRelation = data;
                    break;
                }
            }
            if (plusPurchaseSkuRelation != null) {
                String relationIds = plusPurchaseSkuRelation.getRelationIds();
                if (StrUtil.isNotEmpty(relationIds)) {
                    plus_relationList = Jsons.parseList(relationIds, Long.class);
                    if (plus_relationList.contains(relationId)) {
                        orderDon = new OrderDon();
                        GroupsRelationView groupsRelationView = beanSearcher.searchFirst(GroupsRelationView.class, MapUtils.builder().field(GroupsRelationView::getId, relationId).build());
                        Assert.notNull(groupsRelationView, "车票已不存在");
                        orderDon.setUserId(groupsRelationView.getUserId());
                        orderDon.setSkuId(groupsRelationView.getSkuId());
                        orderDon.setGoodsId(groupsRelationView.getGoodsId());
                        orderDon.setStatus(OrderDon.Status.complete);
                        orderDon.setOrderType(1);
                    }
                }
            }
        }
        Assert.notNull(orderDon, "订单不存在");
        if (orderDon.getStatus() == OrderDon.Status.refund) {
            throw BusinessRuntimeException.getInstance("订单已退款");
        }

        //获取新车队
        LambdaQueryWrapper<GroupsTrips> queryWrapper = Wrappers.lambdaQuery(GroupsTrips.class)
                .eq(GroupsTrips::getSkuId, orderDon.getSkuId())
                .eq(GroupsTrips::getId, groupId)
                .ne(GroupsTrips::getId, relation.getGroupsId())
                .ne(GroupsTrips::getStatus, GroupsTrips.Status.down)
                .last("limit 1");
        GroupsTrips groups = groupsMapper.selectOne(queryWrapper);
        if (groups == null) throw BusinessRuntimeException.getInstance("车队不存在或已下架");
        if (!Constant.AI_goodsIds.contains(orderDon.getGoodsId()) && groups.getAvailableNum() <= 0) {
            throw BusinessRuntimeException.getInstance("该新车位人员已满");
        }
        Integer relationNum = groups.getNum();
        //获取新车队车位
        GroupsRelation newRelation;
        Boolean isOutside = req.getIsOutside();
        if (Constant.AI_goodsIds.contains(orderDon.getGoodsId()) && ((isOutside != null && isOutside) || groups.getAvailableNum() == 0) && groups.getNum() > 1) {
            //Ai车队 额外增加车位 并不让上车
            newRelation = getChatGPTOutsideRelation(orderDon.getUserId(), groupId, relationNum, 1);
        } else {
            newRelation = getRelationThisTrips(orderDon.getUserId(), groupId, 1);
        }

        newRelation.setUserId(userId);
        newRelation.setStartTime(relation.getStartTime());
        newRelation.setExpiryTime(relation.getExpiryTime());
        newRelation.setYhsId(yhsId);
        newRelation.setCmt(relation.getCmt());
        newRelation.setCustomerService(relation.getCustomerService());
        if (newRelation.getStatus() != GroupsRelation.Status.outside) {
            newRelation.setStatus(GroupsRelation.Status.validity);
        }

        //清除原先车票
        relation.setNewRelationId(newRelation.getId());
        relationClearService.clearTicket(relation, source);
        
        //兜底处理 多余车票
        clearOtherChangeTicket(userId, relationId, newRelation, orderDon.getSkuId());

        //奈飞车票
        if (orderDon.getGoodsId() == 1) {
            User user = userMapper.selectById(newRelation.getUserId());
            GroupsTrips groupsTrips = groupsMapper.selectById(newRelation.getGroupsId());
            Account account = accountMapper.selectById(groupsTrips.getAccountId());
            AtomicInteger start = new AtomicInteger(1);
            groupsRelationNetflixService.timingSetNetflix(newRelation.getNum(), user.getNickname(), account.getAccount(), account.getPassword(), newRelation.getExpiryTime(), start);
        }

        if (plusPurchaseSkuRelation != null && plus_relationList != null) {
            plus_relationList.remove(relationId);
            plus_relationList.add(newRelation.getId());
            plusPurchaseSkuRelation.setRelationIds(plus_relationList.toString());
            orderDiscountPlusPurchaseSkuRelationMapper.updateById(plusPurchaseSkuRelation);
        }

        if (source != null && source == UserTicketClearedRecord.Source.abnormal) {
            //将用户异常订单关闭
            workOrderMapper.update(null, Wrappers.lambdaUpdate(WorkOrder.class)
                    .set(WorkOrder::getStatus, WorkOrder.Status.close)
                    .eq(WorkOrder::getStatus, WorkOrder.Status.waiting)
                    .eq(WorkOrder::getUserId, userId)
                    .eq(WorkOrder::getRelationId, relationId));
        }

        if (orderDon.getMoney() != null && orderDon.getMoney().compareTo(BigDecimal.ZERO) == 0) {
            //是否是实物权益车票
            UserPayEquipmentReceiveBenefitsRecord receiveBenefitsRecord = receiveBenefitsRecordMapper.selectOne(Wrappers.lambdaQuery(UserPayEquipmentReceiveBenefitsRecord.class)
                    .eq(UserPayEquipmentReceiveBenefitsRecord::getTicketOrderId, orderDon.getId())
                    .eq(UserPayEquipmentReceiveBenefitsRecord::getRelationId, relationId).last("limit 1"));
            if (receiveBenefitsRecord != null) {
                receiveBenefitsRecord.setRelationId(newRelation.getId());
                receiveBenefitsRecordMapper.updateById(receiveBenefitsRecord);
            }
        }

        if ((newRelation.getStartTime() == null || newRelation.getExpiryTime() == null)) {
            List<OrderDon> orderDonList = orderDonMapper.selectList(Wrappers.lambdaQuery(OrderDon.class).eq(OrderDon::getUserId, userId).eq(OrderDon::getRelationId, relationId).eq(OrderDon::getStatus, OrderDon.Status.hasPayment));
            if (orderDonList.isEmpty()) {
                orderDonList = orderDonMapper.selectList(Wrappers.lambdaQuery(OrderDon.class)
                        .eq(OrderDon::getUserId, userId)
                        .eq(OrderDon::getRelationId, relationId)
                        .eq(OrderDon::getStatus, OrderDon.Status.complete)
                        .orderByDesc(OrderDon::getId)
                        .last("limit 1"));
            }
            if (groups.getStatus() == GroupsTrips.Status.waiting) {
                orderDonList.forEach(hasPaymentOrder -> {
                    hasPaymentOrder.setRelationId(newRelation.getId());
                    orderDonMapper.updateById(hasPaymentOrder);
                });
                relationMapper.updateById(newRelation);
                return;
            }
            orderDonList.forEach((hasPaymentOrder) -> {
                //如果续费增加时间，如果首次则设置当前时间为初始时间
                Date expiryTime = Optional.ofNullable(newRelation.getExpiryTime()).orElse(new Date());
                GoodsDonSku donSku = skuMapper.selectById(hasPaymentOrder.getSkuId());
                Date newDate;
                if (donSku.getDays() != null && donSku.getDays() > 0) {
                    newDate = DateUtil.offsetDay(expiryTime, donSku.getDays() * hasPaymentOrder.getNum());
                } else {
                    newDate = DateUtil.offset(expiryTime, DateField.MONTH, donSku.getMonths() * hasPaymentOrder.getNum());
                }
                newRelation.setExpiryTime(newDate);
                newRelation.setStartTime(newRelation.getStartTime() == null ? new Date() : null);
                relationMapper.updateById(newRelation);

                hasPaymentOrder.setStatus(OrderDon.Status.complete);
                hasPaymentOrder.setRelationId(newRelation.getId());
                orderDonMapper.updateById(hasPaymentOrder);
            });
            return;
        }

        List<OrderDon> orderDonList = orderDonMapper.selectList(Wrappers.lambdaQuery(OrderDon.class).eq(OrderDon::getUserId, userId).eq(OrderDon::getRelationId, relationId).eq(OrderDon::getStatus, OrderDon.Status.complete));
        orderDonList.forEach(completeOrder->{
            completeOrder.setRelationId(newRelation.getId());
            orderDonMapper.updateById(completeOrder);
        });
        log.info("userId:{}更换车票,原座位号relationId:{}======>新座位号newRelationId:{}", newRelation.getUserId(), relationId, newRelation.getId());
        relationMapper.updateById(newRelation);

        //更换车票 调整GPT相关规格新车队 上车数
        GoodsDonSku sku = goodsDonSkuMapper.selectById(groups.getSkuId());
        groupRelationFrontService.adjustGroupsParkingTime(newRelation.getId(), sku);

        //关闭正在恢复的车票
        if (orderDon.getGoodsId() == Constant.NETFLIX_GID) {
            List<Long> userIdList = userBindRelationService.getRelationUserIdList(orderDon.getUserId(), null);
            NetflixUserAccountSubmitRecoverRecord recoverRecord = netflixUserAccountSubmitRecoverRecordMapper.selectOne(Wrappers.lambdaQuery(NetflixUserAccountSubmitRecoverRecord.class)
                    .eq(NetflixUserAccountSubmitRecoverRecord::getRelationId, orderDon.getRelationId())
                    .in(NetflixUserAccountSubmitRecoverRecord::getUserId, userIdList)
                    .eq(NetflixUserAccountSubmitRecoverRecord::getStatus, 0)
                    .last("limit 1"));
            if (recoverRecord != null) {
                recoverRecord.setStatus(3);
                netflixUserAccountSubmitRecoverRecordMapper.updateById(recoverRecord);
            }
        }
    }

    public String zfbRefund(OrderRefundReq refundReq, OrderDon orderDon) throws Exception {
        if (orderDon.getMoney().compareTo(BigDecimal.ZERO) <=0){
            return StrUtil.EMPTY;
        }
        AlipayTradeRefundResponse response;
        //支付宝退款
        AlipayClient alipayClient = AliPayClientFactory.getAlipayClient(Optional.ofNullable(orderDon.getShopId()).orElse(ShopConfig.ZFB_DEFAULT_APP_ID));
        AlipayTradeRefundRequest request = new AlipayTradeRefundRequest();
        AlipayTradeRefundModel model = new AlipayTradeRefundModel();
        //支付宝交易号
        model.setTradeNo(orderDon.getTransactionId());
        model.setRefundAmount(refundReq.getRefundMoney().divide(BigDecimal.valueOf(100), 2, RoundingMode.HALF_EVEN).toString());
        model.setQueryOptions(List.of("gmt_refund_pay"));
        long time = System.currentTimeMillis();
        //退款订单号
        String outRefundNo = Codec.DoDigest.custom()
                .setAlgorithm(Codec.DoDigest.Algorithm.MD5)
                .setStringData(time + String.valueOf(orderDon.getId()))
                .toHexString();
        //退款请求号
        model.setOutRequestNo(outRefundNo);
        request.setBizModel(model);
        String shopId = orderDon.getShopId();
        ShopConfig shopConfig = shopConfigMapper.selectOne(Wrappers.lambdaQuery(ShopConfig.class).eq(ShopConfig::getAppId, orderDon.getShopId()));
        if (shopId != null && shopConfig != null && shopConfig.getIsCert()) {
            response = alipayClient.certificateExecute(request);
        } else {
            response = alipayClient.execute(request);
        }
        if (!response.isSuccess()) throw BusinessRuntimeException.getInstance("退款失败,e:{0}", response.getSubMsg());
//			AliPayRefundRep aliPayRefundRep = Jsons.parseObject(response.getBody(), AliPayRefundRep.class);
//			AliPayRefundRep.AlipayTradeRefundResponse res = aliPayRefundRep.getResponse();
//			orderDon.setRefundMoney(res.getRefundFee().multiply(BigDecimal.valueOf(100)));
        return outRefundNo;
    }

    /**
     * 校验订单是否符合退款操作
     */
    private void checkOrderRefund(OrderDon orderDon, GoodsDon goodsDon, GoodsDonSku sku, OrderRefundReq refundReq) {
        if (orderDon == null) {
            throw BusinessRuntimeException.getInstance("订单不存在");
        }
        BigDecimal orderDonRefundMoney = Optional.ofNullable(orderDon.getRefundMoney()).orElse(BigDecimal.ZERO);
        BigDecimal orderDonRefundBalance = Optional.ofNullable(orderDon.getRefundBalance()).orElse(BigDecimal.ZERO);
        String refundType = refundReq.getRefundType();
        if (orderDon.getType() == OrderDon.Type.BALANCE && !OrderDon.Type.BALANCE.getType().equals(refundType)) {
            throw BusinessRuntimeException.getInstance("余额支付的订单不支持金额退款");
        }
        if (OrderDon.Status.refund == orderDon.getStatus()) {
            throw BusinessRuntimeException.getInstance("该订单已退款");
        }
        if (OrderDon.Status.noPayment == orderDon.getStatus() || OrderDon.Status.close == orderDon.getStatus()) {
            throw BusinessRuntimeException.getInstance("订单{0}状态不支持退款", orderDon.getStatus());
        }
        if (goodsDon.getId() == Constant.NETFLIX_GID) {
            Integer selectCount = netflixUserChangeOtherTicketRecordMapper.selectCount(Wrappers.lambdaQuery(NetflixUserChangeOtherTicketRecord.class)
                    .eq(NetflixUserChangeOtherTicketRecord::getOrderId, orderDon.getId()));
            if (selectCount > 0) {
                throw BusinessRuntimeException.getInstance("该奈飞车票已替换其他车票，无法退款");
            }
        }
        if (goodsDon.getType() == 1 && sku != null) {
            //虚拟原订单是否已过期
            Integer months = sku.getMonths();
            Integer days = sku.getDays();
            Integer num = orderDon.getNum();
            DateTime now = DateTime.now();
            DateTime endTime;
            if (days != null && days > 0) {
                endTime = DateUtil.offsetDay(orderDon.getCreatedTime(), days * num);
            } else {
                endTime = DateUtil.offsetMonth(orderDon.getCreatedTime(), months * num);
            }
            if (now.isAfter(endTime)) {
                throw BusinessRuntimeException.getInstance("该订单车票已过期");
            }
            if (orderDon.getOrderType() == 1) {
                //是否有其他付款订单是否过期
                OrderDon otherOrder = orderDonMapper.selectOne(Wrappers.lambdaQuery(OrderDon.class)
                        .eq(OrderDon::getRelationId, orderDon.getRelationId())
                        .eq(OrderDon::getUserId, orderDon.getUserId())
                        .ne(OrderDon::getId, orderDon.getId())
                        .notIn(OrderDon::getStatus, Constant.noOrderAllStatus)
                        .eq(OrderDon::getOrderType, 2)
                        .orderByDesc(OrderDon::getId)
                        .last("limit 1"));
                if (otherOrder != null) {
                    throw BusinessRuntimeException.getInstance("该笔订单存在续费订单，请先退掉续费订单");
                }
            }
        }
        BigDecimal refundMoney = refundReq.getRefundMoney();
        BigDecimal money = orderDon.getMoney();
        //余额退款
        if (OrderDon.Type.BALANCE.getType().equals(refundType)) {
            BigDecimal balance = orderDon.getBalance();
            refundMoney = orderDonRefundBalance.add(refundMoney);
            if (OrderDon.Type.BALANCE == orderDon.getType() && refundMoney.compareTo(balance) > 0) {
                throw BusinessRuntimeException.getInstance("退款余额大于订单支付余额");
            }
            if (OrderDon.Type.BALANCE != orderDon.getType() && refundMoney.compareTo(money) > 0) {
                throw BusinessRuntimeException.getInstance("退款余额大于订单支付金额");
            }
            orderDon.setRefundBalance(refundMoney);
            orderDon.setRefundMoney(BigDecimal.ZERO);
        } else {
            //退金额
            refundMoney = orderDonRefundMoney.add(refundMoney);
            if (refundMoney.compareTo(money) > 0) {
                throw BusinessRuntimeException.getInstance("退款金额大于订单支付金额");
            }
            orderDon.setRefundMoney(refundMoney);
        }
        //礼品卡是否已使用
        GiftCardUserRecord giftCardUserRecord = null;
        if (goodsDon.getSpecialType() != null && goodsDon.getSpecialType() == GoodsDon.SpecialType.giftCard) {
            Integer count = giftCardUserRecordMapper.selectCount(Wrappers.lambdaQuery(GiftCardUserRecord.class)
                    .eq(GiftCardUserRecord::getIsUsed, 1)
                    .eq(GiftCardUserRecord::getOrderId, orderDon.getId()));
            if (count > 0) {
                throw BusinessRuntimeException.getInstance("该礼品卡已使用无法退款");
            }
        }
        if (!redisService.setNx(String.format("%s", refundReq.getOrderId()), refundReq.getOrderId(), 10l)) {
            throw BusinessRuntimeException.getInstance("请勿重复点击,正在退款中..");
        }
        //礼品卡购买状态
        if (giftCardUserRecord != null) {
            giftCardUserRecord.setIsPay(false);
            giftCardUserRecordMapper.updateById(giftCardUserRecord);
        }
        //校验续费升级规格
        checkMirrorRenewSku(orderDon);
    }

    /**
     * 退款后 处理关联
     */
    public void commonRefund(OrderDon orderDon, BigDecimal refundMoney, String operator, GoodsDon goodsDon, GoodsDonSku sku, String outNo, String refundType, Boolean isOnly, BigDecimal refundBalance, String chatImg, BigDecimal deductBalance, List<Long> dpRelationIds) {
        orderRefundService.refundRecord(orderDon, refundMoney, operator, goodsDon, sku, outNo, refundType, chatImg);
        //退款一次
        goodsDonStockService.upStockRelate(null, orderDon.getId(), "refund");
        try {
            if (!orderDon.getIsDp()) {
                //虚物订单退款,清出车队,车票变为已过期
                orderCommonService.clearUnrealGoodsDetail(orderDon, goodsDon.getType(), sku);
            }
        } catch (Exception e) {
            log.error("清除车票错误:{}", StringUtil.getErrorText(e));
        }
        //若存在优惠券使用,退还优惠券
        if (orderDon.getCouponUserId() != 0) {
            couponFontService.updateOrderDonCouponStatus(orderDon);
        }
        //退等比例
        if (isOnly != null && isOnly) {
            userBenefitsService.addUserBalance(orderDon.getUserId(), refundBalance, UserBalanceSourceRecord.Source.refund, orderDon.getYhsId(), orderDon.getId(), goodsDon.getTitle() + UserBalanceSourceRecord.Source.refund.getDesc(), true);
            BigDecimal orderDonRefundBalance = Optional.ofNullable(orderDon.getRefundBalance()).orElse(BigDecimal.ZERO);
            orderDon.setRefundBalance(orderDonRefundBalance.add(refundBalance));
        }

        //若存在余额支付，退还余额
        if (isOnly == null && orderDon.getBalance().compareTo(BigDecimal.ZERO) > 0) {
            BigDecimal addBalance = orderDon.getBalance();
            //需额外扣除余额
            if (deductBalance != null && deductBalance.compareTo(BigDecimal.ZERO) > 0) {
                addBalance = addBalance.subtract(deductBalance);
            }
            userBenefitsService.addUserBalance(orderDon.getUserId(), addBalance, UserBalanceSourceRecord.Source.refund, orderDon.getYhsId(), orderDon.getId(), goodsDon.getTitle() + UserBalanceSourceRecord.Source.refund.getDesc(), true);
        }
        //是否全额退款
        if (refundMoney.compareTo(orderDon.getMoney()) == 0) {
            //是否使用银河币支付
            OrderDonGalaxyCoinRecord orderDonGalaxyCoinRecord = orderDonGalaxyCoinRecordMapper.selectOne(Wrappers.lambdaQuery(OrderDonGalaxyCoinRecord.class)
                    .eq(OrderDonGalaxyCoinRecord::getOrderId, orderDon.getId())
                    .last("limit 1"));
            if (orderDonGalaxyCoinRecord != null) {
                //有效时，返还银河币 并记录
                userGalaxyCoinService.recordOrderRefundGalaxyCoinIfValid(orderDon.getId(), orderDonGalaxyCoinRecord.getUserId(), orderDonGalaxyCoinRecord.getGalaxyCoin());
                //扣除 该笔订单产生的返现银河币
                if (orderDon.getMoney().compareTo(BigDecimal.ZERO) > 0) {
                    userGalaxyCoinService.subOrderGenerateGalaxyCoin(orderDon.getId());
                }
            }
        }

        try {
            marketFrontService.subSpecificChanceNum(orderDon.getUserId(), orderDon.getId(), orderDon.getGoodsId(), orderDon.getUpdateTime());
            if (goodsDon.getType() == 2 && !orderDon.getIsDistribute()) {
                equipmentDistributeService.subDistributeBenefitsChance(orderDon.getUserId(), orderDon.getId());
                //扣除用户自身实物权益
                userRealOrderBenefitsService.deductUserRealGoodsBenefits(orderDon.getId());
            }
        } catch (Exception e) {
            log.error("wx减少抽奖机会错误,orderId:{},error:{}", orderDon.getId(), e);
        }
        if (OrderDon.Type.BALANCE.getType().equals(refundType)) {
            if (isOnly == null && orderDon.getMoney().compareTo(BigDecimal.ZERO) > 0) {
                userBenefitsService.addUserBalance(orderDon.getUserId(), orderDon.getRefundBalance(), UserBalanceSourceRecord.Source.refund, orderDon.getYhsId(), orderDon.getId(), goodsDon.getTitle() + UserBalanceSourceRecord.Source.refund.getDesc(), true);
            }
        } else {
            //余额退款不需要扣除积分
            //分销提成积分扣除
            deductDsPoints(orderDon);
            //店铺 分销提成金额扣除
            yhShopDistributeService.deductDsMoney(orderDon);
            //镜像店铺 分销提成金额扣除
            deductUserMirrorShopMoney(orderDon);
        }

        if (orderDon.getIsFixedDistribute()) {
            //商务提成 因订单退款去掉
            UserDistributeBusinessOrderDonRecord record = businessOrderDonRecordMapper.selectOne(Wrappers.lambdaQuery(UserDistributeBusinessOrderDonRecord.class)
                    .eq(UserDistributeBusinessOrderDonRecord::getOrderId, orderDon.getId())
                    .eq(UserDistributeBusinessOrderDonRecord::getStatus, UserDistributeBusinessOrderDonRecord.Status.success)
                    .last("limit 1"));
            if (record != null) {
                record.setStatus(UserDistributeBusinessOrderDonRecord.Status.refund);
                businessOrderDonRecordMapper.updateById(record);
            }
        }

        //店铺商务提成
        if (orderDon.getYhsId() != null && orderDon.getYhsId() > 0) {
            YhShopUserDistributeBusinessOrderDonRecord shop_record = yhShopBusinessOrderDonRecordMapper.selectOne(Wrappers.lambdaQuery(YhShopUserDistributeBusinessOrderDonRecord.class)
                    .eq(YhShopUserDistributeBusinessOrderDonRecord::getOrderId, orderDon.getId())
                    .eq(YhShopUserDistributeBusinessOrderDonRecord::getStatus, YhShopUserDistributeBusinessOrderDonRecord.Status.success)
                    .last("limit 1"));
            if (shop_record != null) {
                shop_record.setStatus(YhShopUserDistributeBusinessOrderDonRecord.Status.refund);
                yhShopBusinessOrderDonRecordMapper.updateById(shop_record);
            }
        }
        //是否是优惠加购关联订单
        if (orderDon.getIsDp()) {
            OrderDiscountPlusPurchaseSkuRelation discountPlusPurchaseSkuRelation = orderDiscountPlusPurchaseSkuRelationMapper.selectOne(Wrappers.lambdaQuery(OrderDiscountPlusPurchaseSkuRelation.class)
                    .eq(OrderDiscountPlusPurchaseSkuRelation::getOrderId, orderDon.getId()).last("limit 1"));
            if (discountPlusPurchaseSkuRelation != null) {
                //选择清除加购车票
                if (CollUtil.isNotEmpty(dpRelationIds)) {
                    try {
                        List<GroupsRelation> groupsRelations = relationMapper.selectList(Wrappers.lambdaQuery(GroupsRelation.class)
                                .eq(GroupsRelation::getUserId, orderDon.getUserId())
                                .in(GroupsRelation::getId, dpRelationIds));
                        log.info("优惠加购订单orderId:{}退款,清除相关车票relation_ids:{}", orderDon.getId(), dpRelationIds);
                        groupsRelations.forEach(relation -> relationClearService.clearTicket(relation, UserTicketClearedRecord.Source.dp));
                    } catch (Exception e) {
                    }
                }
                String plusOrderIds = discountPlusPurchaseSkuRelation.getPlusOrderIds();
                if (StrUtil.isNotBlank(plusOrderIds)) {
                    try {
                        log.info("关闭优惠加购orderId:{}关联实物订单", orderDon.getId());
                        List<Long> plusOrderIdList = Jsons.parseList(plusOrderIds, Long.class);
                        List<OrderDon> relate_orderDons = orderDonMapper.selectList(Wrappers.lambdaQuery(OrderDon.class)
                                .in(OrderDon::getId, plusOrderIdList)
                                .notIn(OrderDon::getStatus, Constant.noOrderStatus));
                        relate_orderDons.forEach(relate_o -> {
                            //扣除用户自身实物权益
                            userRealOrderBenefitsService.deductUserRealGoodsBenefits(relate_o.getId());
                        });
                        orderDonMapper.update(null, Wrappers.lambdaUpdate(OrderDon.class)
                                .set(OrderDon::getStatus, OrderDon.Status.refund)
                                .in(OrderDon::getId, plusOrderIdList)
                                .ne(OrderDon::getStatus, OrderDon.Status.refund));
                    } catch (Exception e) {
                    }
                }
            }
        }

        //同步车票退款 重购记录
        TASK_POOL.execute(() -> {
            GroupsRelationExpiryRecord groupsRelationExpiryRecord = groupsRelationExpiryRecordService.getOne(Wrappers.lambdaQuery(GroupsRelationExpiryRecord.class)
                    .in(GroupsRelationExpiryRecord::getReBuyOrderId, orderDon.getId())
                    .eq(GroupsRelationExpiryRecord::getRelationId, orderDon.getRelationId()).last("limit 1"));
            if (groupsRelationExpiryRecord == null) {
                log.info("订单orderId:{}退款,同步是否有重购记录不是直接续费车票", orderDon.getId());
                List<GroupsRelationExpiryRecord> groupsRelationExpiryRecords = groupsRelationExpiryRecordService.list(Wrappers.lambdaQuery(GroupsRelationExpiryRecord.class)
                        .in(GroupsRelationExpiryRecord::getReBuyOrderId, orderDon.getId()));
                log.info("订单orderId:{}退款,重购记录不是直接续费车票大小:{}", groupsRelationExpiryRecords.size());
                if (CollUtil.isNotEmpty(groupsRelationExpiryRecords)) {
                    groupsRelationExpiryRecords.forEach(data -> {
                        data.setIsReBuy(false);
                    });
                    groupsRelationExpiryRecordService.saveOrUpdateBatch(groupsRelationExpiryRecords);
                }
            }
            if (groupsRelationExpiryRecord != null) {
                groupsRelationExpiryRecord.setIsReBuy(false);
                groupsRelationExpiryRecordService.saveOrUpdate(groupsRelationExpiryRecord);
            }
        });

        //是否是礼品卡 现金支付订单
        BigDecimal gcCash = orderDon.getGcCash();
        if (gcCash != null && gcCash.compareTo(BigDecimal.ZERO) > 0) {
            giftCardOrderUseRecordService.returnGiftCardCash(orderDon.getId());
        }
        //清除礼品卡
        if (goodsDon.getSpecialType() != null && goodsDon.getSpecialType() == GoodsDon.SpecialType.giftCard) {
            giftCardUserRecordMapper.update(null, Wrappers.lambdaUpdate(GiftCardUserRecord.class)
                    .set(GiftCardUserRecord::getIsPay, 0)
                    .eq(GiftCardUserRecord::getOrderId, orderDon.getId()));
        }
        //是否是分销订单
        //处理下级渠道分销提成
        handleSubRewards(orderDon);

        //是否是用户套餐优惠权益订单
        if (orderDon.getGoodsId() == 15) {
            UserBenefitsComboRelationRecord userBenefitsComboRelationRecord = userBenefitsComboRelationRecordMapper.selectOne(Wrappers.lambdaQuery(UserBenefitsComboRelationRecord.class)
                    .eq(UserBenefitsComboRelationRecord::getOrderId, orderDon.getId()).last("limit 1"));
            if (userBenefitsComboRelationRecord != null) {
                try {
                    String relationIds = userBenefitsComboRelationRecord.getRelationIds();
                    List<Long> relationIdList = Jsons.parseList(relationIds, Long.class);
                    //清空车票或减少车票时间
                    relationIdList.forEach(relationId -> {
                        orderCommonService.clearUserTicketTime(relationId);
                    });
                } catch (Exception e) {

                }
            }
        }
        //HBO GO退款，车队上架
        setUpIfEmpty(orderDon.getGoodsId(), orderDon.getRelationId());

        if (orderDon.getGoodsId() == Constant.NETFLIX_GID) {
            List<Long> userIdList = userBindRelationService.getRelationUserIdList(orderDon.getUserId(), null);
            NetflixUserAccountSubmitRecoverRecord recoverRecord = netflixUserAccountSubmitRecoverRecordMapper.selectOne(Wrappers.lambdaQuery(NetflixUserAccountSubmitRecoverRecord.class)
                    .eq(NetflixUserAccountSubmitRecoverRecord::getRelationId, orderDon.getRelationId())
                    .in(NetflixUserAccountSubmitRecoverRecord::getUserId, userIdList)
                    .eq(NetflixUserAccountSubmitRecoverRecord::getStatus, 0)
                    .last("limit 1"));
            if (recoverRecord != null) {
                recoverRecord.setStatus(3);
                netflixUserAccountSubmitRecoverRecordMapper.updateById(recoverRecord);
            }
        }
    }

    //处理下级渠道分销提成
    public void handleSubRewards(OrderDon orderDon) {
        //是否是分销订单
        //处理下级渠道分销提成
        if (orderDon.getIsDistribute()) {
            UserDistributeSub subRelate = userDistributeSubMapper.getSubRelate(orderDon.getUserId());
            if (subRelate != null) {
                List<UserDistributeSubWaiting> subWaitings = subWaitingMapper.selectList(Wrappers.lambdaQuery(UserDistributeSubWaiting.class)
                        .eq(UserDistributeSubWaiting::getSubUserId, subRelate.getSubUserId())
                        .eq(UserDistributeSubWaiting::getSendStatus, UserDistributeSubWaiting.Status.waiting));
                if (CollUtil.isNotEmpty(subWaitings)) {
                    List<UserDistributeSubRewards> userDistributeSubRewards = userDistributeSubRewardsMapper.selectList(null);
                    Map<Integer, List<UserDistributeSubRewards>> rewardLevelMap = userDistributeSubRewards.stream().collect(Collectors.groupingBy(UserDistributeSubRewards::getLevel));
                    subWaitings.forEach(wait -> {
                        List<UserDistributeSubRewards> thisLevelList = rewardLevelMap.get(wait.getLevel());
                        if (thisLevelList == null) {
                            return;
                        }
                        UserDistributeSubRewards thisLevel = thisLevelList.get(0);
                        Integer months = thisLevel.getMonths();
                        BigDecimal subOrderMoney = Optional.ofNullable(orderDonMapper.selectSubChannelOrderMoney(wait.getSubUserId(), subRelate.getCreatedTime(), DateUtil.offsetMonth(subRelate.getCreatedTime(), months))).orElse(BigDecimal.ZERO);
                        if (subOrderMoney.compareTo(thisLevel.getTargetAmount()) < 0) {
                            subWaitingMapper.update(null, Wrappers.lambdaUpdate(UserDistributeSubWaiting.class)
                                    .set(UserDistributeSubWaiting::getSendStatus, UserDistributeSubWaiting.Status.close)
                                    .eq(UserDistributeSubWaiting::getSendStatus, UserDistributeSubWaiting.Status.waiting)
                                    .eq(UserDistributeSubWaiting::getId, wait.getId()));
                        }
                    });
                }
            }
        }
    }

    /**
     * 退款 分销提成积分扣除
     */
    public void deductDsPoints(OrderDon orderDon) {
        if (orderDon.getIsDistribute()) {
            DistributeWaitingSendPoints distributeWaitingSendPoints = distributeWaitingSendPointsMapper.selectOne(Wrappers.lambdaQuery(DistributeWaitingSendPoints.class).eq(DistributeWaitingSendPoints::getOrderId, orderDon.getId()).eq(DistributeWaitingSendPoints::getIsVip,Boolean.FALSE).last("limit 1"));
            if (distributeWaitingSendPoints != null) {
                BigDecimal money = orderDon.getMoney();
                BigDecimal refundMoney = orderDon.getRefundMoney();
                //已发送 发送中 部分 全额退款
                DistributeWaitingSendPoints.Status sendStatus = distributeWaitingSendPoints.getSendStatus();
                BigDecimal points = distributeWaitingSendPoints.getPoints();
                if (sendStatus == DistributeWaitingSendPoints.Status.waiting) {
                    //实物设备退款就清0
                    if (refundMoney.compareTo(money) == 0 || orderDon.getGoodsId() == 15) {
                        //待发送状态 全额退款
                        distributeWaitingSendPoints.setSendStatus(DistributeWaitingSendPoints.Status.close);
                        distributeWaitingSendPoints.setRefundPoints(points);
                        distributeWaitingSendPoints.setPoints(BigDecimal.ZERO);
                        distributeWaitingSendPointsMapper.updateById(distributeWaitingSendPoints);
                        return;
                    }
                    Integer thisGoodsRate = distributeWaitingSendPoints.getRate();
                    if (thisGoodsRate == null || thisGoodsRate == 0) {
                        thisGoodsRate = Optional.ofNullable(userDistributeMapper.getDistributeGoodsRateByUidAndGid(orderDon.getUserId(), orderDon.getGoodsId())).orElse(0);
                    }
                    if (thisGoodsRate > 0) {
                        BigDecimal refundRate = refundMoney.divide(money, 2, RoundingMode.DOWN);
                        //退掉比例的提成
                        BigDecimal needSubPoints = points.multiply(refundRate);
                        distributeWaitingSendPoints.setRefundPoints(needSubPoints);
                        //剩余积分
                        BigDecimal remainPoints = points.subtract(needSubPoints);
                        distributeWaitingSendPoints.setPoints(remainPoints);
                        //原先获取积分也扣除
                        if (distributeWaitingSendPoints.getOriPoints().compareTo(BigDecimal.ZERO) > 0) {
                            BigDecimal oriNeedSubPoints = distributeWaitingSendPoints.getOriPoints().multiply(refundRate);
                            distributeWaitingSendPoints.setOriPoints(distributeWaitingSendPoints.getOriPoints().subtract(oriNeedSubPoints));
                        }
                        distributeWaitingSendPointsMapper.updateById(distributeWaitingSendPoints);
                    }
                } else if (sendStatus == DistributeWaitingSendPoints.Status.success) {
                    //已发送的提成 部分退款 全额退款 需要扣除用户积分
                    //扣除固定推广者积分
                    //实物设备退款就清0
                    if (refundMoney.compareTo(money) == 0 || orderDon.getGoodsId() == 15) {
                        userBenefitsService.deductDistributePoints(orderDon.getId(), distributeWaitingSendPoints.getSharedId(), points);
                        distributeWaitingSendPoints.setRefundPoints(points);
                        distributeWaitingSendPoints.setPoints(BigDecimal.ZERO);
                        distributeWaitingSendPoints.setSendStatus(DistributeWaitingSendPoints.Status.close);
                        distributeWaitingSendPointsMapper.updateById(distributeWaitingSendPoints);
                        return;
                    }
                    Integer thisGoodsRate = distributeWaitingSendPoints.getRate();
                    if (thisGoodsRate == null || thisGoodsRate == 0) {
                        thisGoodsRate = Optional.ofNullable(userDistributeMapper.getDistributeGoodsRateByUidAndGid(orderDon.getUserId(), orderDon.getGoodsId())).orElse(0);
                    }
                    if (thisGoodsRate > 0) {
                        BigDecimal refundRate = refundMoney.divide(money, 2, RoundingMode.DOWN);
                        //退掉比例的提成
                        BigDecimal needSubPoints = points.multiply(refundRate);
                        userBenefitsService.deductDistributePoints(orderDon.getId(), distributeWaitingSendPoints.getSharedId(), needSubPoints);
                        //部分退款
                        distributeWaitingSendPoints.setRefundPoints(needSubPoints);
                        distributeWaitingSendPoints.setPoints(points.subtract(needSubPoints));
                        //原先获取积分也扣除
                        if (distributeWaitingSendPoints.getOriPoints().compareTo(BigDecimal.ZERO) > 0) {
                            BigDecimal oriNeedSubPoints = distributeWaitingSendPoints.getOriPoints().multiply(refundRate);
                            distributeWaitingSendPoints.setOriPoints(distributeWaitingSendPoints.getOriPoints().subtract(oriNeedSubPoints));
                        }
                        distributeWaitingSendPointsMapper.updateById(distributeWaitingSendPoints);
                    }

                }
            }
        }
    }

    @Override
    public void refundPriceDiffer(OrderRefundReq orderRefundReq) throws Exception {
        Long orderId = orderRefundReq.getOrderId();
        OrderDon orderDon = orderDonMapper.selectById(orderId);
        if (orderDon == null) {
            throw BusinessRuntimeException.getInstance("订单不存在");
        }
        if (orderDon.getMoney().compareTo(BigDecimal.ZERO) == 0) {
            throw BusinessRuntimeException.getInstance("该订单是0元订单,无法补差价");
        }
        if (Constant.noOrderAllStatus.contains(orderDon.getStatus().name())) {
            throw BusinessRuntimeException.getInstance("订单不是已支付状态");
        }
        //默认补差价余额
        String refundType = Optional.ofNullable(orderRefundReq.getRefundType()).orElse("balance");
        BigDecimal refundMoney = orderRefundReq.getRefundMoney();
        BigDecimal orderRefundMoney = Optional.ofNullable(orderDon.getRefundMoney()).orElse(BigDecimal.ZERO);
        BigDecimal orderDonRefundBalance = Optional.ofNullable(orderDon.getRefundBalance()).orElse(BigDecimal.ZERO);
        if (refundMoney.add(orderRefundMoney).add(orderDonRefundBalance).compareTo(orderDon.getRealMoney()) >= 0) {
            throw BusinessRuntimeException.getInstance("补差价已达到该订单付款金额");
        }
        GoodsDon goodsDon = goodsDonMapper.selectById(orderDon.getGoodsId());
        GoodsDonSku sku = null;
        if (orderDon.getSkuId() != null) {
            sku = skuMapper.selectById(orderDon.getSkuId());
        }
        orderDon.setRefundDesc("补差价");
        String outNo = StrUtil.EMPTY;
        if ("money".equals(refundType)) {
            if (refundMoney == null || refundMoney.compareTo(BigDecimal.ZERO) <= 0) {
                throw BusinessRuntimeException.getInstance("请输入正确的差价金额");
            }
            if (refundMoney.compareTo(orderDon.getMoney()) >= 0) {
                throw BusinessRuntimeException.getInstance("补差价金额应不大于订单金额");
            }
            //退款
            orderRefundReq.setIsDiffer(true);
            outNo = orderRefundService.centerRefund(orderRefundReq, orderDon);
            orderDon.setRefundMoney(orderRefundMoney.add(refundMoney));
            orderDonMapper.updateById(orderDon);

            //补差价金额 扣除对应分销提成金额
            orderDon.setRefundMoney(refundMoney);
            deductDsPoints(orderDon);
            //店铺分销提成金额扣除
            yhShopDistributeService.deductDsMoney(orderDon);

        } else {
            BigDecimal refundBalance = refundMoney;
            if (refundBalance == null || refundBalance.compareTo(BigDecimal.ZERO) <= 0 || refundBalance.compareTo(orderDon.getMoney()) > 0) {
                throw BusinessRuntimeException.getInstance("请输入正确的差价金额");
            }
            userBenefitsService.addUserBalance(orderDon.getUserId(), refundBalance, UserBalanceSourceRecord.Source.price_differ, orderDon.getYhsId(), orderDon.getId(), goodsDon.getTitle() + UserBalanceSourceRecord.Source.price_differ.getDesc(), true);
            orderDon.setRefundBalance(orderDonRefundBalance.add(refundBalance));
            orderDonMapper.updateById(orderDon);
        }

        orderRefundService.refundRecord(orderDon, refundMoney, orderRefundReq.getOperator(), goodsDon, sku, outNo, refundType, null);
    }

    @Override
    @Transactional(rollbackFor = Throwable.class)
    public void clearBalanceToRefundMoney(OrderBalanceRefundReq refundReq) throws Exception {
        Long refundOrderId = refundReq.getRefundOrderId();
        BigDecimal refundMoney = refundReq.getRefundMoney();
        RefundOrderDon refundOrderDon = refundOrderDonMapper.selectById(refundOrderId);
        if (!"balance".equals(refundOrderDon.getRefundMethod())) {
            throw BusinessRuntimeException.getInstance("该记录不是余额退款类型");
        }
        Long orderId = refundOrderDon.getOrderId();
        OrderDon orderDon = orderDonMapper.selectById(orderId);
        if (orderDon.getMoney().compareTo(BigDecimal.ZERO) == 0) {
            throw BusinessRuntimeException.getInstance("该记录对应的订单无实际支付金额");
        }
        if (refundOrderDon.getIsClearBalance()) {
            throw BusinessRuntimeException.getInstance("该笔退款余额记录已退款");
        }
        BigDecimal refundFee = refundOrderDon.getRefundFee();
        //默认退全部余额
        if (refundMoney != null) {
            refundFee = refundMoney;
        }
        BigDecimal money = orderDon.getMoney();
        //若退款余额 大于退款金额 将退款余额至为 退款金额
        if (refundFee.compareTo(money) > 0) {
            refundFee = money;
        }
        User user = userMapper.selectById(orderDon.getUserId());
        if (user.getBalance().compareTo(refundFee) < 0) {
            throw BusinessRuntimeException.getInstance("用户余额不足，无法扣除对应退款余额");
        }
        int update = userMapper.update(null, Wrappers.lambdaUpdate(User.class)
                .set(User::getBalance, user.getBalance().subtract(refundFee))
                .eq(User::getId, user.getId())
                .eq(User::getBalance, user.getBalance()));
        if (update == 0) {
            throw BusinessRuntimeException.getInstance("扣除用户退款余额失败,请重试...");
        }
        OrderRefundReq orderRefundReq = new OrderRefundReq();
        orderRefundReq.setOrderId(orderId);
        orderRefundReq.setRefundMoney(refundFee);
        orderRefundReq.setRefundType("money");

        String outNo = orderRefundService.centerRefund(orderRefundReq, orderDon);

        orderDon.setRefundBalance(orderDon.getRefundBalance().subtract(refundFee));
        BigDecimal orderRefundMoney = Optional.ofNullable(orderDon.getRefundMoney()).orElse(BigDecimal.ZERO);
        orderDon.setRefundMoney(orderRefundMoney.add(refundFee));
        orderDonMapper.updateById(orderDon);

        refundOrderDon.setOutRefundNo(outNo);
        refundOrderDon.setIsClearBalance(true);
        refundOrderDonMapper.updateById(refundOrderDon);
    }

    /**
     * 寻找该车队空余车位
     */
    public GroupsRelation getRelationThisTrips(Long userId, Long groupsId, Integer retryNum) {
        //寻找快满编车队进行占座
        GroupsRelation relation = relationMapper.selectRandomOneRelationByGroupsId(groupsId);
        if (relation == null) {
            throw BusinessRuntimeException.getInstance("该车队人员已满,请选择另一车队");
        }
        Long relationId = relation.getId();
        if (!redisService.setNx(RedisKey.GROUPS_RELATION_NUM_KEY + relationId, userId, 60 * 5L)) {
            if (retryNum == 7) throw BusinessRuntimeException.getInstance("该车队人员已满,请选择另一车队");
            retryNum++;
            return getRelationThisTrips(userId, groupsId, retryNum);
        }
        int count = groupsMapper.decrAvailableNum(relation.getGroupsId());
        if (count == 0) {
            log.error("车位异常 groupId:{}", groupsId);
            groupsMapper.updateAvailableNum(groupsId);
            throw new BusinessRuntimeException("车位异常");
        }
        return relation;
    }

    private GroupsRelation getChatGPTOutsideRelation(Long userId, Long groupsId, Integer relationNum, Integer retryNum) {
        //寻找快满编车队额外座位
        GroupsRelation relation = relationMapper.selectOutsideRelationByGroupsId(groupsId, relationNum);
        if (relation == null) {
            relation = new GroupsRelation();
            relation.setStatus(GroupsRelation.Status.outside);
            relation.setUserId(userId);
            relation.setGroupsId(groupsId);
            GroupsRelation maxNumRelation = relationMapper.selectOne(Wrappers.lambdaQuery(GroupsRelation.class).eq(GroupsRelation::getGroupsId, groupsId).orderByDesc(GroupsRelation::getNum).last("limit 1"));
            relation.setNum(maxNumRelation.getNum() + 1);
            relationMapper.insert(relation);
            return relation;
        }
        Long relationId = relation.getId();
        if (!redisService.setNx(RedisKey.GROUPS_RELATION_NUM_KEY + relationId, userId, 60 * 5L)) {
            if (retryNum == 7) throw BusinessRuntimeException.getInstance("该车队人员已满,请选择另一车队");
            retryNum++;
            return getChatGPTOutsideRelation(userId, groupsId, relationNum, retryNum);
        }
        return relation;
    }

    private void checkMirrorRenewSku(OrderDon orderDon) {
        Long skuId = orderDon.getSkuId();
        Long orderId = orderDon.getId();
        OrderDonRenewRecord orderDonRenewRecord = orderDonRenewRecordMapper.selectOne(Wrappers.lambdaQuery(OrderDonRenewRecord.class)
                .eq(OrderDonRenewRecord::getOrderId, orderId)
                .last("limit 1"));
        if (orderDonRenewRecord != null) {
            //gpt
            if (orderDon.getGoodsId() == 18) {
                ChatgptUser chatgptUser = chatgptUserMapper.selectOne(Wrappers.lambdaQuery(ChatgptUser.class)
                        .eq(ChatgptUser::getRelationId, orderDon.getRelationId())
                        .last("limit 1"));
                Long presentRenewSkuId = chatgptUser.getRenewSkuId();
                if (presentRenewSkuId != null) {
                    //存在不同升级套餐
                    GoodsDonSku presentRenewSku = skuMapper.selectById(presentRenewSkuId);
                    if (!ObjectUtil.equal(presentRenewSkuId, skuId)) {
                        throw BusinessRuntimeException.getInstance("请先退掉用户目前续费升级的{0}规格", presentRenewSku.getSpecVal());
                    }
                }
            }
            //claude pro
            if (orderDon.getGoodsId() == 75) {
                ClaudeUser claudeUser = claudeUserMapper.selectOne(Wrappers.lambdaQuery(ClaudeUser.class)
                        .eq(ClaudeUser::getRelationId, orderDon.getRelationId())
                        .last("limit 1"));
                Long presentRenewSkuId = claudeUser.getRenewSkuId();
                if (presentRenewSkuId != null) {
                    //存在不同升级套餐
                    GoodsDonSku presentRenewSku = skuMapper.selectById(presentRenewSkuId);
                    if (!ObjectUtil.equal(presentRenewSkuId, skuId)) {
                        throw BusinessRuntimeException.getInstance("请先退掉用户目前续费升级的{0}规格", presentRenewSku.getSpecVal());
                    }
                }
            }
        }
    }

    private void clearExtraRelation(OrderDon orderDon) {
        List<UserPayEquipmentReceiveBenefitsRecord> userPayEquipmentReceiveBenefitsRecords = receiveBenefitsRecordMapper.selectList(Wrappers.lambdaQuery(UserPayEquipmentReceiveBenefitsRecord.class)
                .eq(UserPayEquipmentReceiveBenefitsRecord::getRealOrderId, orderDon.getId()));
        userPayEquipmentReceiveBenefitsRecords.forEach(record -> {
            Long skuId = record.getSkuId();
            List<GroupsRelation> relations = relationMapper.selectExtraRelation(orderDon.getUserId(), skuId, record.getRelationId());
            relations.forEach(relation -> {
                //不是优惠加购
                Integer count = orderDiscountPlusPurchaseSkuRelationMapper.selectCount(Wrappers.lambdaQuery(OrderDiscountPlusPurchaseSkuRelation.class)
                        .eq(OrderDiscountPlusPurchaseSkuRelation::getUserId, relation.getUserId())
                        .apply("JSON_CONTAINS(relation_ids,'" + relation.getId() + "')"));
                if (count == 0) {
                    log.info("非优惠加购订单，直接清除userId:{}车票：{}", relation.getUserId(), relation.getId());
                    relationClearService.clearTicket(relation, UserTicketClearedRecord.Source.manual);
                }
            });
        });
    }

    /**
     * 扣除用户镜像店铺提成
     */
    private void deductUserMirrorShopMoney(OrderDon orderDon) {
        UserMirrorShopDistributeWaitingSendPoints distributeWaitingSendPoints = userMirrorShopDistributeWaitingSendPointsMapper.selectOne(Wrappers.lambdaQuery(UserMirrorShopDistributeWaitingSendPoints.class)
                .eq(UserMirrorShopDistributeWaitingSendPoints::getOrderId, orderDon.getId())
                .last("limit 1"));
        if (distributeWaitingSendPoints != null) {
            BigDecimal money = orderDon.getMoney();
            BigDecimal refundMoney = orderDon.getRefundMoney();
            //已发送 发送中 部分 全额退款
            UserMirrorShopDistributeWaitingSendPoints.Status sendStatus = distributeWaitingSendPoints.getSendStatus();
            BigDecimal take_money = distributeWaitingSendPoints.getMoney();
            if (sendStatus == UserMirrorShopDistributeWaitingSendPoints.Status.waiting) {
                if (refundMoney.compareTo(money) == 0) {
                    //待发送状态 全额退款
                    distributeWaitingSendPoints.setSendStatus(UserMirrorShopDistributeWaitingSendPoints.Status.close);
                    distributeWaitingSendPoints.setRefundMoney(take_money);
                    distributeWaitingSendPoints.setMoney(BigDecimal.ZERO);
                    userMirrorShopDistributeWaitingSendPointsMapper.updateById(distributeWaitingSendPoints);
                    return;
                }
                Integer rate = distributeWaitingSendPoints.getRate();
                if (rate > 0) {
                    BigDecimal needDeductMoney = refundMoney.multiply(BigDecimal.valueOf(rate).divide(BigDecimal.valueOf(100)));
                    distributeWaitingSendPoints.setRefundMoney(needDeductMoney);
                    //剩余积分
                    distributeWaitingSendPoints.setMoney(take_money.subtract(needDeductMoney));
                    userMirrorShopDistributeWaitingSendPointsMapper.updateById(distributeWaitingSendPoints);
                }
            } else if (sendStatus == UserMirrorShopDistributeWaitingSendPoints.Status.success) {
                //已发送的提成 部分退款 全额退款 需要扣除用户积分
                //扣除固定推广者积分
                if (refundMoney.compareTo(money) == 0) {
                    //扣除店铺主 已有的提成金额
                    userBenefitsService.deductUserMirrorShopTakeMoney(orderDon.getId(), distributeWaitingSendPoints.getShopUserId(), take_money);
                    distributeWaitingSendPoints.setRefundMoney(take_money);
                    distributeWaitingSendPoints.setMoney(BigDecimal.ZERO);
                    distributeWaitingSendPoints.setSendStatus(UserMirrorShopDistributeWaitingSendPoints.Status.close);
                    userMirrorShopDistributeWaitingSendPointsMapper.updateById(distributeWaitingSendPoints);
                    return;
                }
                Integer rate = distributeWaitingSendPoints.getRate();
                if (rate > 0) {
                    BigDecimal needDeductMoney = refundMoney.multiply(BigDecimal.valueOf(rate).divide(BigDecimal.valueOf(100)));
                    //扣除店铺主 已有的提成金额
                    userBenefitsService.deductUserMirrorShopTakeMoney(orderDon.getId(), distributeWaitingSendPoints.getShopUserId(), needDeductMoney);
                    //部分退款
                    distributeWaitingSendPoints.setRefundMoney(needDeductMoney);
                    distributeWaitingSendPoints.setMoney(take_money.subtract(needDeductMoney));
                    userMirrorShopDistributeWaitingSendPointsMapper.updateById(distributeWaitingSendPoints);
                }

            }
        }
    }

    /**
     * 清除多余车票
     */
    private void clearOtherChangeTicket(Long userId, Long relationId, GroupsRelation newRelation, Long skuId) {
        UserTicketClearedRecord userTicketClearedRecord = userTicketClearedRecordMapper.selectOne(Wrappers.lambdaQuery(UserTicketClearedRecord.class)
                .eq(UserTicketClearedRecord::getUserId, userId)
                .eq(UserTicketClearedRecord::getRelationId, relationId)
                .eq(UserTicketClearedRecord::getSource, UserTicketClearedRecord.Source.change_ticket)
                .orderByDesc(UserTicketClearedRecord::getId)
                .last("limit 1"));
        if (userTicketClearedRecord != null) {
            Long newRelationId = userTicketClearedRecord.getNewRelationId();
            List<GroupsRelation> others = relationMapper.selectList(Wrappers.lambdaQuery(GroupsRelation.class)
                    .ne(GroupsRelation::getId, newRelationId)
                    .eq(GroupsRelation::getUserId, userId)
                    .eq(GroupsRelation::getStartTime, newRelation.getStartTime())
                    .eq(GroupsRelation::getExpiryTime, newRelation.getExpiryTime()));
            others.forEach(r -> {
                Long groupsId = r.getGroupsId();
                GroupsTrips groupsTrips = groupsMapper.selectById(groupsId);
                //排除 非同规格车票
                if (!skuId.equals(groupsTrips.getSkuId())) {
                    return;
                }
                Long rid = r.getId();
                Integer selectCount = orderDonMapper.selectCount(Wrappers.lambdaQuery(OrderDon.class)
                        .eq(OrderDon::getUserId, userId)
                        .eq(OrderDon::getRelationId, rid)
                        .notIn(OrderDon::getStatus, Constant.noOrderAllStatus));
                if (selectCount == 0) {
                    //不是优惠加购
                    Integer count = orderDiscountPlusPurchaseSkuRelationMapper.selectCount(Wrappers.lambdaQuery(OrderDiscountPlusPurchaseSkuRelation.class)
                            .eq(OrderDiscountPlusPurchaseSkuRelation::getUserId, userId)
                            .apply("JSON_CONTAINS(relation_ids,'" + rid + "')"));
                    if (count == 0) {
                        log.info("清除用户:{}多余车票", userId);
                        relationClearService.clearTicket(r, UserTicketClearedRecord.Source.manual);
                    }
                }
            });
        }
    }

    /**
     * 车队退款 自动上架
     */
	private void setUpIfEmpty(Long goodsId, Long relationId) {
		if (goodsId == Constant.HBO_GO_GOODS_ID) {
			GroupsRelation relation = relationMapper.selectById(relationId);
			if (relation == null) {
				return;
			}
			GroupsTrips groupsTrips = groupsMapper.selectById(relation.getGroupsId());
			if (groupsTrips == null) {
				return;
			}
			if (groupsTrips.getStatus() == GroupsTrips.Status.down) {
				log.info("HBO GO车队:{}存在退款，自动上架", groupsTrips.getId());
				groupsMapper.update(null, Wrappers.lambdaUpdate(GroupsTrips.class)
						.set(GroupsTrips::getStatus, GroupsTrips.Status.validity)
						.eq(GroupsTrips::getId, groupsTrips.getId()));
			}
		}
	}
}