Stripe 迁移工具

import com.stripe.Stripe;
import com.stripe.StripeClient;
import com.waffo.stripe.WaffoStripe;                             // ← 新增
import com.waffo.stripe.config.WaffoConfig;                      // ← 新增

// ← 新增：Waffo 凭据。环境变量名与 waffo-java 约定一致时，一行 fromEnv() 即可
com.waffo.types.config.WaffoConfig waffoJavaConfig =
        com.waffo.types.config.WaffoConfig.fromEnv();

// ← 新增：路由配置
WaffoConfig routing = WaffoConfig.builder()
        .waffoConfig(waffoJavaConfig)
        .notifyUrl("https://your-app.example/webhooks/waffo")
        .build();

Stripe.apiKey = System.getenv("STRIPE_SECRET_KEY");              // ← 改这里：密钥改用全局设置
StripeClient client = WaffoStripe.client(routing);                // ← 改这里：换掉构造方式

import com.stripe.StripeClient;

StripeClient client = new StripeClient(System.getenv("STRIPE_SECRET_KEY"));

SessionCreateParams params = SessionCreateParams.builder()
        .setMode(SessionCreateParams.Mode.SUBSCRIPTION)
        .setSuccessUrl("https://your-app.example/subscription/success")
        .setCancelUrl("https://your-app.example/subscription/cancel")
        .addLineItem(SessionCreateParams.LineItem.builder()
                .setPrice("price_123")
                .setQuantity(1L)
                .build())
        .putMetadata("source", "waffo")                          // ← 新增：这一行决定走 Waffo
        .build();

RequestOptions options = RequestOptions.builder()                // ← 新增：幂等键，调用前先持久化
        .setIdempotencyKey(persistedSubscriptionRequest)
        .build();

Session session = client.checkout().sessions()
        .create(params, options);                                // ← 改这里：多传一个 options
saveSubscriptionMapping(orderId, session.getSubscription());     // ← 新增：保存 wsub_ 与业务订单的关系
redirect(session.getUrl());                                      // 不变：仍然从 getUrl() 取跳转地址

SessionCreateParams params = SessionCreateParams.builder()
        .setMode(SessionCreateParams.Mode.SUBSCRIPTION)
        .setSuccessUrl("https://your-app.example/subscription/success")
        .setCancelUrl("https://your-app.example/subscription/cancel")
        .addLineItem(SessionCreateParams.LineItem.builder()
                .setPrice("price_123")
                .setQuantity(1L)
                .build())
        .build();

Session session = client.checkout().sessions().create(params);
redirect(session.getUrl());

// Stripe 原端点保持不动，下面新增 Waffo 的 HTTP 路由
@PostMapping(value = "/webhooks/waffo", produces = MediaType.APPLICATION_JSON_VALUE)
public ResponseEntity<String> onWaffo(@RequestBody String body,
                                      @RequestHeader("X-SIGNATURE") String signature) throws StripeException {

    WaffoStripeWebhookResult result = webhooks.handle(body, signature);   // SDK 完成验签、翻译和确认响应生成

    if (result.getPaymentNotification() != null) {
        subscriptionPaymentHandler.handle(                                // 订阅扣款单独记账
                result.getPaymentNotification().getResult());
    }

    Event event = result.getEvent();
    if (event != null) {
        existingStripeWebhookDispatcher.dispatch(event);                  // 不变：复用原有分发逻辑
    }

    return ResponseEntity.ok()                                            // 将 SDK 结果映射为 Spring HTTP 响应
            .contentType(MediaType.APPLICATION_JSON)
            .body(result.getResponseBody());
}

import com.stripe.net.Webhook;

// 只有 Stripe 一个端点
@PostMapping("/webhooks/stripe")
public ResponseEntity<String> onStripe(@RequestBody String body,
                                       @RequestHeader("Stripe-Signature") String signature) {
    try {
        Event event = Webhook.constructEvent(body, signature, endpointSecret);
        existingStripeWebhookDispatcher.dispatch(event);
        return ResponseEntity.ok("ok");    // Stripe 只看状态码，响应体写什么都行
    } catch (SignatureVerificationException e) {
        return ResponseEntity.badRequest().build();
    }
}