支付宝订阅ChatGPT服务的技术实现与避坑指南

3次阅读

没有评论

共计 3382 个字符，预计需要花费 9 分钟才能阅读完成。

在直接对接支付宝订阅和 ChatGPT API 时，开发者通常会遇到以下典型问题：

支付回调延迟：由于网络问题或支付宝系统繁忙，支付成功的回调可能延迟到达，导致用户订阅状态更新不及时。
订阅状态同步困难：支付宝的订阅状态与 ChatGPT 服务的配额管理需要保持一致，但在高并发场景下容易出现状态不一致的情况。
订单幂等性处理：支付宝的回调可能会重复触发，如果没有正确处理幂等性，会导致重复开通服务或扣费问题。

针对上述问题，我们对比了两种常见的解决方案：

轮询方案：
优点：实现简单，不需要额外的 Webhook 服务。
缺点：实时性差，频繁轮询会增加服务器负担，且无法保证及时捕获支付状态变化。
Webhook 方案：
优点：实时性好，支付宝主动推送支付状态变化，减少服务器负担。
缺点：需要额外开发 Webhook 接收服务，且需要处理签名验证和回调失败等问题。

显然，Webhook 方案更适合高并发和实时性要求较高的场景。

在支付宝开放平台配置订阅接口时，需要注意以下几点：

回调地址：确保回调地址是公网可访问的 HTTPS 地址，且路径正确。
密钥配置：正确配置应用公钥和支付宝公钥，用于签名验证。
订阅协议：明确订阅周期、价格和续费规则，并在用户支付时清晰展示。

以下是一个简单的 Spring Boot Webhook 接收服务的代码示例：

@RestController
@RequestMapping("/api/webhook")
public class AlipayWebhookController {@PostMapping("/alipay")
    public String handleAlipayCallback(@RequestBody String body, HttpServletRequest request) {
        // 1. 验证签名
        if (!verifySignature(request, body)) {return "failure";}

        // 2. 解析回调数据
        JSONObject json = JSON.parseObject(body);
        String tradeStatus = json.getString("trade_status");
        String outTradeNo = json.getString("out_trade_no");

        // 3. 处理订单状态
        handleOrderStatus(outTradeNo, tradeStatus);

        return "success";
    }

    private boolean verifySignature(HttpServletRequest request, String body) {
        // 实现支付宝签名验证逻辑
        // 示例代码省略具体实现
        return true;
    }

    private void handleOrderStatus(String outTradeNo, String tradeStatus) {
        // 实现订单状态处理逻辑
        // 示例代码省略具体实现
    }
}

为了管理订阅状态，我们设计了一个简单的状态机，包含以下状态：

PENDING：等待支付
PAID：支付成功，待开通服务
ACTIVE：服务已开通
EXPIRED：服务已过期
CANCELLED：已取消

状态转换图如下：

stateDiagram
    [*] --> PENDING
    PENDING --> PAID: 支付成功
    PAID --> ACTIVE: 开通服务
    ACTIVE --> EXPIRED: 过期
    ACTIVE --> CANCELLED: 取消
    EXPIRED --> [*]
    CANCELLED --> [*]

在用户支付成功后，我们需要调用 ChatGPT API 为用户开通相应的服务配额。以下是一个简单的实现示例：

public void activateChatGPTService(String userId, String planId) {
    // 1. 根据 planId 获取对应的配额
    ChatGPTQuota quota = getQuotaByPlanId(planId);

    // 2. 调用 ChatGPT API 开通服务
    ChatGPTApiClient client = new ChatGPTApiClient();
    client.updateUserQuota(userId, quota);

    // 3. 更新本地订阅状态
    subscriptionService.updateStatus(userId, SubscriptionStatus.ACTIVE);
}

以下是支付宝回调验签的核心代码：

private boolean verifySignature(HttpServletRequest request, String body) {
    try {Map<String, String> params = new HashMap<>();
        for (String key : request.getParameterMap().keySet()) {params.put(key, request.getParameter(key));
        }

        // 1. 获取支付宝公钥
        String alipayPublicKey = getAlipayPublicKey();

        // 2. 验证签名
        return AlipaySignature.rsaCheckV1(params, alipayPublicKey, "UTF-8", "RSA2");
    } catch (Exception e) {log.error("验签失败", e);
        return false;
    }
}

为了防止重复处理回调，我们需要实现幂等性处理：

@Transactional
public void handleOrderStatus(String outTradeNo, String tradeStatus) {
    // 1. 查询订单是否存在
    Order order = orderRepository.findByOutTradeNo(outTradeNo);
    if (order == null) {throw new RuntimeException("订单不存在");
    }

    // 2. 检查订单状态是否已处理
    if (order.getStatus().equals(tradeStatus)) {return; // 已处理，直接返回}

    // 3. 更新订单状态
    order.setStatus(tradeStatus);
    orderRepository.save(order);

    // 4. 根据状态触发后续操作
    if ("TRADE_SUCCESS".equals(tradeStatus)) {activateChatGPTService(order.getUserId(), order.getPlanId());
    }
}

API 地址不同 ：沙箱环境的 API 地址通常以openapi.alipaydev.com 结尾，而生产环境是openapi.alipay.com。
数据隔离：沙箱环境的数据与生产环境完全隔离，测试时需要使用沙箱账号。
证书差异：沙箱环境和生产环境的支付宝公钥不同，需要分别配置。

支付宝会在回调失败后重试，但开发者也需要在服务端实现重试机制：