yhlxj/netflix-service/src/main/java/com/cyksj/server/recharge/impl/GptProxyRechargeServiceImpl.java

package com.cyksj.server.recharge.impl;

import cn.hutool.core.date.DateTime;
import cn.hutool.core.date.DateUtil;
import cn.hutool.core.util.StrUtil;
import cn.hutool.http.HttpRequest;
import cn.hutool.http.HttpResponse;
import cn.hutool.json.JSONObject;
import cn.hutool.json.JSONUtil;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.cyksj.common.constant.Constant;
import com.cyksj.common.exception.BusinessRuntimeException;
import com.cyksj.common.task.GlobalThreadPoolTaskExecutor;
import com.cyksj.common.util.Jsons;
import com.cyksj.mapper.*;
import com.cyksj.model.dto.GptCardTokenDto;
import com.cyksj.model.entity.*;
import com.cyksj.model.request.GroupsRelationRechargeReq;
import com.cyksj.redis.RedisService;
import com.cyksj.server.recharge.GptProxyRechargeService;
import com.cyksj.server.recharge.dto.CardKeyValidationResult;
import com.cyksj.server.recharge.dto.TaskResult;
import com.cyksj.server.recharge.dto.TaskSubmitResult;
import com.cyksj.server.recharge.dto.TokenParseResult;
import com.cyksj.service.chatgpt.GptUserRechargeRecordService;
import com.cyksj.service.order.MultiQuantityOrderService;
import com.cyksj.service.recharge.*;
import com.cyksj.service.user.UserBindRelationService;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import java.util.Date;
import java.util.List;
import java.util.Optional;

/**
 * @author chan
 * @date 2025/7/30 18:55
 */
@Slf4j
@Service
@RequiredArgsConstructor
public class GptProxyRechargeServiceImpl implements GptProxyRechargeService {

    private final GptRechargeCardKeyMapper gptRechargeCardKeyMapper;

    private final GroupsRelationMapper relationMapper;

    private final UserBindRelationService userBindRelationService;

    private final GroupsMapper groupsMapper;

    private final GoodsDonSkuMapper skuMapper;

    private final OrderDonMapper orderDonMapper;

    private final MultiQuantityOrderService multiQuantityOrderService;

	private final GptUserRechargeRecordService gptUserRechargeRecordService;

	private final RedisService redisService;

	private final GptRechargeCardKeyChannelService gptRechargeCardKeyChannelService;

	private final AfDianRechargeService afDianRechargeService;

	private final ChongAfDianRechargeService chongAfDianRechargeService;

    private final YearAfDianRechargeService yearAfDianRechargeService;

    private final GoAfDianRechargeService goAfDianRechargeService;

    private final HiBoyRechargeService hiBoyRechargeService;

    private final PlusAfDianRechargeService plusAfDianRechargeService;

    private final SancRechargeService sancRechargeService;

    private final CdkRechargeService cdkRechargeService;

    private final GuofenzaixianRechargeService guofenzaixianRechargeService;

    private final RedeemCloudRechargeService redeemCloudRechargeService;

    private final GptUserRechargeNumRecordMapper gptUserRechargeNumRecordMapper;

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

	private HttpRequest createBaseRequest(String url) {
        return HttpRequest.get(url)
                .header("accept", "application/json, text/plain, */*")
                .header("accept-language", "zh-CN,zh;q=0.9,en;q=0.8")
                .header("origin", "https://www.ow520.com")
                .header("referer", "https://www.ow520.com/")
                .header("user-agent", "Mozilla/5.0 (Macintosh; Intel Mac OS X 10_15_7) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/138.0.0.0 Safari/537.36");
    }

    public CardKeyValidationResult validateCardKey(String cardKey) {
        log.info("开始验证卡密: {}", cardKey);
        try {
	        String BASE_URL = gptRechargeCardKeyChannelService.getCardKeyDomain(cardKey);
	        HttpResponse response = createBaseRequest(BASE_URL + "/card-keys/" + cardKey)
			        .execute();
            String body = response.body();
            log.info("卡密验证响应: {}", body);
            
            JSONObject jsonResponse = JSONUtil.parseObj(body);
            CardKeyValidationResult result = new CardKeyValidationResult(
                jsonResponse.getBool("available")
            );
            //{"available":false,"error":"卡密已被使用"}
            log.info("卡密验证结果: {}", result);
            return result;
        } catch (Exception e) {
            log.error("验证卡密失败: {}", e.getMessage(), e);
            throw new RuntimeException("验证卡密失败: " + e.getMessage(), e);
        }
    }

    public TokenParseResult parseToken(String accessToken) {
        log.info("开始验证凭证: {}", accessToken.substring(0, Math.min(20, accessToken.length())) + "...");
        try {
	        String BASE_URL = gptRechargeCardKeyChannelService.getCardKeyDomain(null);
	        String url = BASE_URL + "/parse-token";
            JSONObject requestBody = new JSONObject();
            requestBody.put("access_token", accessToken);
            
            HttpResponse response = HttpRequest.post(url)
                    .header("accept", "application/json, text/plain, */*")
                    .header("accept-language", "zh-CN,zh;q=0.9,en;q=0.8")
                    .header("content-type", "application/json")
                    .header("origin", "https://www.ow520.com")
                    .header("referer", "https://www.ow520.com/")
                    .header("user-agent", "Mozilla/5.0 (Macintosh; Intel Mac OS X 10_15_7) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/138.0.0.0 Safari/537.36")
                    .body(requestBody.toString())
                    .execute();
            String body = response.body();
            log.info("凭证验证响应: {}", body);
            
            JSONObject jsonResponse = JSONUtil.parseObj(body);
            TokenParseResult result = new TokenParseResult(
                jsonResponse.getStr("message"),
                jsonResponse.getBool("success")
            );
            log.info("凭证验证结果: {}", result);
            return result;
        } catch (Exception e) {
            log.error("验证凭证失败: {}", e.getMessage(), e);
            throw new RuntimeException("验证凭证失败: " + e.getMessage(), e);
        }
    }

    public TaskSubmitResult submitTask(String cardKey, String accessToken, String idp) {
        log.info("开始提交任务 - 卡密: {}, idp: {}", cardKey, idp);
        try {
	        String BASE_URL = gptRechargeCardKeyChannelService.getCardKeyDomain(cardKey);
	        String url = BASE_URL + "/tasks";
            JSONObject requestBody = new JSONObject();
            requestBody.put("card_key", cardKey);
            requestBody.put("access_token", accessToken);
            requestBody.put("idp", idp);
            
            HttpResponse response = HttpRequest.post(url)
		            .setConnectionTimeout(60000)
		            .header("accept", "application/json, text/plain, */*")
                    .header("accept-language", "zh-CN,zh;q=0.9,en;q=0.8")
                    .header("content-type", "application/json")
                    .header("origin", "https://www.ow520.com")
                    .header("referer", "https://www.ow520.com/")
                    .header("user-agent", "Mozilla/5.0 (Macintosh; Intel Mac OS X 10_15_7) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/138.0.0.0 Safari/537.36")
                    .body(requestBody.toString())
                    .execute();
            String body = response.body();
            log.info("任务提交响应: {}", body);
            
            JSONObject jsonResponse = JSONUtil.parseObj(body);
            TaskSubmitResult result = new TaskSubmitResult(
                jsonResponse.getStr("task_id"),
                jsonResponse.getBool("success")
            );
            log.info("任务提交结果: {}", result);
            return result;
        } catch (Exception e) {
            log.error("提交任务失败: {}", e.getMessage(), e);
            throw new RuntimeException("提交任务失败: " + e.getMessage(), e);
        }
    }

    public TaskResult getTaskResult(String taskId) {
        //特殊处理year活动代充 走通流程
        if (StrUtil.isNotBlank(taskId) && taskId.contains("yhrgzc:")) {
            GroupsRelation relation = relationMapper.selectOne(Wrappers.lambdaQuery(GroupsRelation.class)
                    .eq(GroupsRelation::getGptTaskId, taskId)
                    .last("limit 1"));
            if (relation == null) {
                return null;
            }
            TaskResult taskResult = new TaskResult();
            taskResult.setStatus("recharging");
            if (relation.getRechargeStatus() == GroupsRelation.RechargeStatus.complete) {
                taskResult.setStatus("completed");
            }
            if (relation.getRechargeStatus() == GroupsRelation.RechargeStatus.recharge_error) {
                taskResult.setStatus("failed");
            }
            return taskResult;
        }
        log.info("开始查询任务结果: {}", taskId);
        try {
	        GroupsRelation relation = relationMapper.selectOne(Wrappers.lambdaQuery(GroupsRelation.class)
			        .eq(GroupsRelation::getGptTaskId, taskId)
			        .last("limit 1"));
	        if (relation == null) {
		        return null;
	        }
	        String cardKey = relation.getCardKey();
	        GptRechargeCardKey gptRechargeCardKey = gptRechargeCardKeyMapper.selectOne(Wrappers.lambdaQuery(GptRechargeCardKey.class).eq(GptRechargeCardKey::getCardKey, cardKey).last("limit 1"));
	        if (gptRechargeCardKey.getChannelId() == Constant.AF_DIAN_CHANNEL_ID) {
		        return afDianRechargeService.getTaskResult(relation);
	        }
			if (gptRechargeCardKey.getChannelId()==Constant.CHONG_AF_DIAN_CHANNEL_ID){
				return chongAfDianRechargeService.getTaskResult(relation);
			}
            if (gptRechargeCardKey.getChannelId() == Constant.SC_CHANNEL_ID) {
                return sancRechargeService.getTaskResult(relation);
            }
            if (Constant.REDEEM_CLOUD_CHANNEL_ID.equals(gptRechargeCardKey.getChannelId())) {
                return redeemCloudRechargeService.getTaskResult(relation);
            }
	        String BASE_URL = gptRechargeCardKeyChannelService.getCardKeyDomain(cardKey);
	        String url = BASE_URL + "/tasks/" + taskId;
            HttpResponse response = createBaseRequest(url)
                    .execute();
            String body = response.body();
            log.info("任务查询响应: {}", body);

            JSONObject jsonResponse = JSONUtil.parseObj(body);
            TaskResult result = new TaskResult(
                jsonResponse.getStr("status"),
                jsonResponse.getStr("result"),
                jsonResponse.getStr("error")
            );
            log.info("任务查询结果: {}", result);
	        String status = result.getStatus();
	        String resultResult = Optional.ofNullable(result.getError()).orElse(result.getResult());
			//更新代充状态
			resetGroupsRelationRechargeStatus(relation, status, resultResult);
	        return result;
        } catch (Exception e) {
            log.error("获取任务结果失败: {}", e.getMessage(), e);
            throw new RuntimeException("获取任务结果失败: " + e.getMessage(), e);
        }
    }

    private String getAccessTokenFromRechargePayload(String saveTokenJson) {
        try {
            JSONObject jsonObject = JSONUtil.parseObj(saveTokenJson);
            String accessToken = jsonObject.getStr("accessToken");
            if (StrUtil.isNotBlank(accessToken)) {
                try {
                    JSONObject sessionObject = JSONUtil.parseObj(accessToken);
                    String sessionAccessToken = sessionObject.getStr("accessToken");
                    if (StrUtil.isNotBlank(sessionAccessToken)) {
                        return sessionAccessToken;
                    }
                } catch (Exception ignored) {
                }
                return accessToken;
            }
            String payload = jsonObject.getStr("payload");
            if (StrUtil.isNotBlank(payload)) {
                GptCardTokenDto gptCardTokenDto = Jsons.parseObject(payload, GptCardTokenDto.class);
                if (gptCardTokenDto != null && StrUtil.isNotBlank(gptCardTokenDto.getAccessToken())) {
                    return gptCardTokenDto.getAccessToken();
                }
            }
        } catch (Exception e) {
            return saveTokenJson;
        }
        return saveTokenJson;
    }

	@Override
	@Transactional(rollbackFor = Throwable.class)
	public String confirmRecharge(GroupsRelationRechargeReq req) {
		Long relationId = req.getRelationId();
		Long userId = req.getUserId();
		List<Long> userIdList = userBindRelationService.getRelationUserIdList(userId, null);
		GroupsRelation relation = relationMapper.selectOne(Wrappers.lambdaQuery(GroupsRelation.class)
				.in(GroupsRelation::getUserId, userIdList)
				.eq(GroupsRelation::getId, relationId)
				.eq(GroupsRelation::getStatus, GroupsRelation.Status.validity));
		if (relation == null) {
			throw BusinessRuntimeException.getInstance("车票不存在");
		}
        if (relation.getRechargeStatus() != null && relation.getRechargeStatus() == GroupsRelation.RechargeStatus.recharge_error) {
            throw BusinessRuntimeException.getInstance("充值失败，清联系客服");
        }
		String userAccount = relation.getAccount();
		GroupsTrips groupsTrips = groupsMapper.selectById(relation.getGroupsId());
		GoodsDonSku sku = skuMapper.selectById(groupsTrips.getSkuId());
//		//GPT 代充
//		if (sku.getGoodsId() != Constant.GPT_RECHARGE_GOODS_ID) {
//			throw BusinessRuntimeException.getInstance("车票类型错误");
//		}
		Integer rechargeNum = relation.getRechargeNum();
		Integer rechargeRemainNum = relation.getRechargeRemainNum();
		if (rechargeRemainNum == null || rechargeRemainNum <= 0) {
			throw BusinessRuntimeException.getInstance("剩余可代充次数为0");
		}
        //近一个小时成功
        Integer successHour = gptUserRechargeNumRecordMapper.selectCount(Wrappers.lambdaQuery(GptUserRechargeNumRecord.class)
                .eq(GptUserRechargeNumRecord::getRelationId, relationId)
                .in(GptUserRechargeNumRecord::getUserId, userIdList)
                .gt(GptUserRechargeNumRecord::getCreatedTime, DateUtil.offsetHour(DateTime.now(), -1)));
        if (successHour > 0) {
            throw BusinessRuntimeException.getInstance("近一个小时只可充值一次");
        }

        if (relation.getRechargeStatus() == GroupsRelation.RechargeStatus.recharging) {
			throw BusinessRuntimeException.getInstance("确认充值中");
		}
		if (relation.getRechargeStatus() == GroupsRelation.RechargeStatus.recharge_error) {
			throw BusinessRuntimeException.getInstance("充值失败，请联系客服开通");
		}
		String key = RedisService.key.GPT_RECHARGE_KEY.getName() + relationId;
		boolean b = redisService.setNx(key, relationId, RedisService.key.GPT_RECHARGE_KEY.getTimeout());
		if (!b) {
			throw BusinessRuntimeException.getInstance("确认充值中");
		}
        Integer subRechargeNum = 1;
        Integer specificChannel = null;
        //活动gpt代充类型
        if (sku.getRechargeType() == 2) {
            specificChannel = 8;
            subRechargeNum = 12;
        }
        //指定了代充渠道 直接用这个渠道 其他不能用
        if (sku.getRechargeChannelId() != null) {
            specificChannel = sku.getRechargeChannelId();
        }
		try {
			int updateRemainNum = relationMapper.update(null, Wrappers.lambdaUpdate(GroupsRelation.class)
					.set(GroupsRelation::getRechargeRemainNum, rechargeRemainNum - subRechargeNum)
					.eq(GroupsRelation::getId, relationId)
					.eq(GroupsRelation::getUserId, relation.getUserId())
					.eq(GroupsRelation::getRechargeRemainNum, rechargeRemainNum));
			if (updateRemainNum == 0) {
				throw BusinessRuntimeException.getInstance("代充异常，请重试");
			}
			OrderDon orderDon = multiQuantityOrderService.findOrderByRelationId(relationId);
			if (orderDon != null && !userIdList.contains(orderDon.getUserId())) {
				orderDon = null;
			}
			if (orderDon == null) {
				orderDon = orderDonMapper.selectOne(Wrappers.lambdaQuery(OrderDon.class)
						.in(OrderDon::getUserId, userIdList)
						.eq(OrderDon::getRelationId, relationId)
						.notIn(OrderDon::getStatus, Constant.noOrderAllStatus)
						.orderByDesc(OrderDon::getId)
						.last("limit 1"));
			}
			if (orderDon == null) {
				throw BusinessRuntimeException.getInstance("代充订单不存在或已退款");
			}
			//入库token json
			String saveTokenJson = req.getAccessToken();
			String accessToken = getAccessTokenFromRechargePayload(saveTokenJson);
			//验证用户token是否正确
			TokenParseResult tokenParseResult = parseToken(accessToken);
			if (!tokenParseResult.getSuccess()) {
				throw BusinessRuntimeException.getInstance("您输入的凭证有误，请重新输入");
			}
			String rechargeAccount = tokenParseResult.getMessage();
			//月付校验前后账号是否一致
			if (sku.getMonths() == 1 && !StrUtil.equals(rechargeAccount, userAccount)) {
				throw BusinessRuntimeException.getInstance("请填入绑定账号的token");
			}
			//记录代充账号 token
			relation.setGptToken(saveTokenJson);
			relation.setAccount(rechargeAccount);
			//获取GPT代充key
			//代充卡密类型
			Integer gptRechargeCardKeyType = 0;
			//若是季、年付 且首月代充
			if (sku.getMonths() > 1 && rechargeNum == rechargeRemainNum) {
				gptRechargeCardKeyType = 1;
			}
			GptRechargeCardKey gptRechargeCardKey = gptRechargeCardKeyMapper.selectOne(Wrappers.lambdaQuery(GptRechargeCardKey.class)
					.eq(GptRechargeCardKey::getType, gptRechargeCardKeyType)
					.eq(GptRechargeCardKey::getStatus, Boolean.FALSE)
                    .eq(specificChannel != null, GptRechargeCardKey::getChannelId, specificChannel)
                    .notIn(specificChannel == null, GptRechargeCardKey::getChannelId, List.of(Constant.YEAR_AF_DIAN_CHANNEL_ID, Constant.HIBOY_PRO_ONE_CHANNEL_ID, Constant.HIBOY_PRO_TWO_CHANNEL_ID))
                    .last("order by channel_id desc, rand() limit 1"));
			//季、年付卡密不存在 从月付代充卡密中获取
			if (gptRechargeCardKey == null && gptRechargeCardKeyType == 1) {
                gptRechargeCardKey = gptRechargeCardKeyMapper.selectOne(Wrappers.lambdaQuery(GptRechargeCardKey.class)
                        .eq(GptRechargeCardKey::getType, 0)
                        .eq(GptRechargeCardKey::getStatus, Boolean.FALSE)
                        .eq(specificChannel != null, GptRechargeCardKey::getChannelId, specificChannel)
                        .notIn(specificChannel == null, GptRechargeCardKey::getChannelId, List.of(Constant.YEAR_AF_DIAN_CHANNEL_ID, Constant.HIBOY_PRO_ONE_CHANNEL_ID, Constant.HIBOY_PRO_TWO_CHANNEL_ID))
                        .last("order by channel_id desc, rand() limit 1"));
			}
			if (gptRechargeCardKey == null) {
				setRechargeRelationStatusAutoError(relation);
				throw BusinessRuntimeException.getInstance("充值失败，请联系客服开通");
			}
			int update = gptRechargeCardKeyMapper.update(null, Wrappers.lambdaUpdate(GptRechargeCardKey.class)
					.set(GptRechargeCardKey::getStatus, Boolean.TRUE)
					.set(GptRechargeCardKey::getOrderId, orderDon.getId())
					.set(GptRechargeCardKey::getUpdateTime, DateTime.now())
					.set(GptRechargeCardKey::getOrderNo, orderDon.getOrderNo())
					.eq(GptRechargeCardKey::getId, gptRechargeCardKey.getId())
					.eq(GptRechargeCardKey::getStatus, Boolean.FALSE));
			if (update == 0) {
				setRechargeRelationStatusAutoError(relation);
				throw BusinessRuntimeException.getInstance("充值失败，请联系客服开通");
			}
			String gptCardKey = gptRechargeCardKey.getCardKey();

			Long channelId = gptRechargeCardKey.getChannelId();
			//AF dian
			if (channelId == Constant.AF_DIAN_CHANNEL_ID) {
				return afDianRechargeService.confirmRecharge(relation, gptCardKey, null);
			}
			//chong.afdian
			if (channelId == Constant.CHONG_AF_DIAN_CHANNEL_ID) {
				return chongAfDianRechargeService.confirmRecharge(relation, gptCardKey, null);
			}
            //year.afdian
			if (channelId == Constant.YEAR_AF_DIAN_CHANNEL_ID) {
				return yearAfDianRechargeService.confirmRecharge(relation, gptCardKey, null);
			}
            //go.afdian
            if (channelId == Constant.GO_AF_DIAN_CHANNEL_ID) {
                return goAfDianRechargeService.confirmRecharge(relation, gptCardKey, null);
            }
            //hiboy
            if (channelId == Constant.HIBOY_CHANNEL_ID || channelId == Constant.HIBOY_PRO_ONE_CHANNEL_ID || channelId == Constant.HIBOY_PRO_TWO_CHANNEL_ID) {
                return hiBoyRechargeService.confirmRecharge(relation, gptCardKey, null);
            }
            //plus.afdian
            if (channelId == Constant.PLUS_AFDIAN_CHANNEL_ID) {
                return plusAfDianRechargeService.confirmRecharge(relation, gptCardKey, null);
            }
            //三川
            if (channelId == Constant.SC_CHANNEL_ID) {
                return sancRechargeService.confirmRecharge(relation, gptCardKey, null);
            }
            //cdk
            if (channelId == Constant.CDK_CHANNEL_ID) {
                return cdkRechargeService.confirmRecharge(relation, gptCardKey, null);
            }
            //guofenzai
            if (channelId == Constant.GUOFENZAIXIAN_CHANNEL_ID) {
                return guofenzaixianRechargeService.confirmRecharge(relation, gptCardKey, null);
            }
            //redeemcloud
            if (Constant.REDEEM_CLOUD_CHANNEL_ID.equals(channelId)) {
                return redeemCloudRechargeService.confirmRecharge(relation, gptCardKey, null);
            }
			//校验卡密是否可用
			CardKeyValidationResult cardKeyValidationResult = validateCardKey(gptCardKey);
			if (!cardKeyValidationResult.getAvailable()) {
				setRechargeRelationStatusAutoError(relation);
				throw BusinessRuntimeException.getInstance("充值失败，请联系客服开通");
			}
			//提交任务
			TaskSubmitResult result = submitTask(gptCardKey, accessToken, "auth0");
			if (!result.getSuccess()) {
				setRechargeRelationStatusAutoError(relation);
				throw BusinessRuntimeException.getInstance("充值失败，请联系客服开通");
			}
			String taskId = result.getTaskId();
			relationMapper.update(null, Wrappers.lambdaUpdate(GroupsRelation.class)
					//记录代充账号
					.set(GroupsRelation::getAccount, rechargeAccount)
					.set(GroupsRelation::getRechargeStatus, GroupsRelation.RechargeStatus.recharging)
					.set(GroupsRelation::getCardKey, gptCardKey)
					.set(GroupsRelation::getGptToken, saveTokenJson)
					.set(GroupsRelation::getGptTaskId, taskId)
					.set(GroupsRelation::getOperator, null)
					.eq(GroupsRelation::getId, relationId));
			return taskId;
		} finally {
			if (redisService.hasKey(key)) {
				redisService.del(key);
			}
		}
	}

	/**
	 * 设置代充自动充值异常
	 */
	public void setRechargeRelationStatusAutoError(GroupsRelation relation) {
		TASK_EXECUTOR.execute(()->{
			relationMapper.update(null, Wrappers.lambdaUpdate(GroupsRelation.class)
					.set(GroupsRelation::getAccount, relation.getAccount())
					.set(GroupsRelation::getGptToken, relation.getGptToken())
					.set(GroupsRelation::getRechargeStatus, GroupsRelation.RechargeStatus.recharge_error)
					.eq(GroupsRelation::getId, relation.getId()));
		});
	}

	/**
	 * 更新代充状态
	 */
	private void resetGroupsRelationRechargeStatus(GroupsRelation relation, String status, String result) {
		if ("completed".equals(status) || "failed".equals(status) || "unknown".equals(status)) {
			String taskId = relation.getGptTaskId();
			if (relation != null && relation.getRechargeStatus() == GroupsRelation.RechargeStatus.recharging) {
				Integer rechargeRemainNum = relation.getRechargeRemainNum();
				GroupsRelation.RechargeStatus rechargeStatus = "completed".equals(status) ? GroupsRelation.RechargeStatus.complete : GroupsRelation.RechargeStatus.recharge_error;
				String cardKey = relation.getCardKey();
				GptRechargeCardKey gptRechargeCardKey = gptRechargeCardKeyMapper.selectOne(Wrappers.lambdaQuery(GptRechargeCardKey.class)
						.eq(GptRechargeCardKey::getCardKey, cardKey)
						.last("limit 1"));
				if (rechargeStatus == GroupsRelation.RechargeStatus.recharge_error) {
					if (gptRechargeCardKey != null) {
						gptRechargeCardKeyMapper.update(null, Wrappers.lambdaUpdate(GptRechargeCardKey.class)
								.set(GptRechargeCardKey::getStatus, Boolean.FALSE)
								.set(GptRechargeCardKey::getOrderId, null)
								.set(GptRechargeCardKey::getOrderNo, null)
								.eq(GptRechargeCardKey::getId, gptRechargeCardKey.getId())
								.eq(GptRechargeCardKey::getStatus, Boolean.TRUE));
					}
				}
				if (rechargeStatus == GroupsRelation.RechargeStatus.recharge_error) {
					if (!redisService.setNx(RedisService.key.GPT_RECHARGE_RECOVER_KEY.getName() + taskId, taskId, RedisService.key.GPT_RECHARGE_RECOVER_KEY.getTimeout())) {
						return;
					}
				}
				Date startTime = relation.getStartTime();
				DateTime expiryTime = null;
				if (rechargeStatus == GroupsRelation.RechargeStatus.complete && startTime == null) {
					GroupsTrips groupsTrips = groupsMapper.selectById(relation.getGroupsId());
					if (groupsTrips != null) {
						startTime = DateTime.now();
						GoodsDonSku sku = skuMapper.selectById(groupsTrips.getSkuId());
						if (sku.getDays() != null && sku.getDays() > 0) {
							expiryTime = DateUtil.offsetDay(startTime, sku.getDays());
						} else {
							expiryTime = DateUtil.offsetMonth(startTime, sku.getMonths());
						}
					}
				}
				String rechargeErrorInfo = null;
				if (rechargeStatus == GroupsRelation.RechargeStatus.recharge_error) {
					rechargeErrorInfo = result;
				}
				relationMapper.update(null, Wrappers.lambdaUpdate(GroupsRelation.class)
						.set(rechargeStatus == GroupsRelation.RechargeStatus.recharge_error, GroupsRelation::getRechargeRemainNum, rechargeRemainNum + 1)
						.set(GroupsRelation::getRechargeStatus, rechargeStatus)
						.set(expiryTime != null, GroupsRelation::getStartTime, startTime)
						.set(expiryTime != null, GroupsRelation::getExpiryTime, expiryTime)
						.set(StrUtil.isNotEmpty(rechargeErrorInfo), GroupsRelation::getRechargeErrorInfo, rechargeErrorInfo)
						.eq(GroupsRelation::getId, relation.getId())
						.le(GroupsRelation::getRechargeRemainNum, relation.getRechargeNum())
						.eq(GroupsRelation::getRechargeStatus, GroupsRelation.RechargeStatus.recharging));
				//记录代充记录
				if (rechargeStatus == GroupsRelation.RechargeStatus.complete) {
					String remark = "自动代充";
					if (StrUtil.isNotBlank(relation.getOperator())) {
						remark = "后台自动代充";
					}
					gptUserRechargeRecordService.recordGptUserRechargeNum(relation.getCardKey(), relation.getUserId(), relation.getId(), relation.getAccount(), -1, relation.getOperator(), remark);
					//修改对应订单状态
					if (gptRechargeCardKey != null) {
						Long orderId = gptRechargeCardKey.getOrderId();
						OrderDon orderDon = orderDonMapper.selectById(orderId);
						if (orderDon != null && orderDon.getStatus() == OrderDon.Status.hasPayment) {
							orderDon.setStatus(OrderDon.Status.complete);
							orderDonMapper.updateById(orderDon);
						}
					}
				}
			}
		}
	}
}