如何将用户ID传递给Stripe，实现支付成功后关联用户更新

核心思路是在创建Stripe支付会话时，将用户ID存入会话的**元数据（metadata）**中，这样支付成功后触发的Webhook就能从事件对象里提取到该用户ID，进而完成数据库更新。以下是具体实现步骤：

1. 生成支付会话时注入用户ID #

后端在创建Stripe Checkout Session的接口里，加入metadata字段并传入当前用户的ID。前端调用这个接口时，需要传递已登录用户的ID（确保用户身份已通过认证，比如JWT校验）。

Express(TypeScript)后端代码示例： #

import Stripe from 'stripe';
import { Request, Response } from 'express';

const stripe = new Stripe(process.env.STRIPE_SECRET_KEY!, {
  apiVersion: '2024-06-20',
});

// 创建支付会话接口
app.post('/api/checkout/session', async (req: Request, res: Response) => {
  // 从请求体获取用户ID（前端需传递，后端要先校验用户合法性）
  const { userId } = req.body;
  
  const session = await stripe.checkout.sessions.create({
    payment_method_types: ['card'],
    line_items: [
      {
        price: 'price_xxxxxx', // 替换为你的Stripe价格ID
        quantity: 1,
      },
    ],
    mode: 'payment',
    success_url: 'https://your-app.com/payment-success',
    cancel_url: 'https://your-app.com/payment-cancel',
    // 存入用户ID到元数据
    metadata: {
      user_id: userId,
    },
  });

  res.json({ checkoutUrl: session.url });
});

Angular前端代码示例： #

// 组件内调用支付会话接口
async initiatePayment() {
  // 从认证服务获取当前登录用户ID（确保已完成登录校验）
  const userId = this.authService.getAuthenticatedUserId();
  
  try {
    const response = await this.http.post<{ checkoutUrl: string }>(
      '/api/checkout/session',
      { userId }
    ).toPromise();
    
    // 跳转至Stripe支付页面
    window.location.href = response!.checkoutUrl;
  } catch (err) {
    console.error('生成支付会话失败:', err);
  }
}

2. Webhook中提取用户ID并更新数据库 #

当Stripe触发checkout.session.completed事件（支付成功的核心事件）时，从事件对象的会话数据里取出metadata.user_id，然后执行数据库更新逻辑。务必先验证Stripe签名，防止恶意请求。

Webhook处理代码示例： #

app.post(
  '/api/stripe/webhook',
  express.raw({ type: 'application/json' }),
  async (req: Request, res: Response) => {
    const sig = req.headers['stripe-signature'];
    let event: Stripe.Event;

    try {
      // 验证Webhook签名，确保请求来自Stripe
      event = stripe.webhooks.constructEvent(
        req.body,
        sig!,
        process.env.STRIPE_WEBHOOK_SECRET!
      );
    } catch (err) {
      console.error('Webhook签名验证失败:', err);
      return res.status(400).send(`Webhook Error: ${(err as Error).message}`);
    }

    // 处理支付成功事件
    if (event.type === 'checkout.session.completed') {
      const session = event.data.object as Stripe.Checkout.Session;
      const userId = session.metadata?.user_id;

      if (userId) {
        // 更新数据库，标记用户为付费会员
        await UserModel.updateOne(
          { _id: userId },
          { 
            isPaidMember: true,
            membershipActivatedAt: new Date()
          }
        );
        console.log(`用户 ${userId} 已标记为付费会员`);
      } else {
        console.error('Webhook事件中未找到用户ID');
      }
    }

    res.json({ received: true });
  }
);

3. 关键注意事项 #

• 签名验证不可省略：Stripe会对每个Webhook请求签名，后端必须验证签名，避免伪造请求篡改用户会员状态。
• 用户ID合法性校验：后端接收前端传递的userId时，要校验该用户是否真实存在、是否为当前登录用户（比如通过JWT解析后的用户ID比对），防止恶意用户篡改userId。
• 备选方案：如果你的应用使用Stripe Customer对象关联用户，可以将userId存入Customer的metadata中，后续从事件关联的Customer对象里获取，但直接存在Checkout Session的metadata更直接高效。

内容的提问来源于stack exchange，提问作者Garrett James