如何在Stripe中识别完成支付的登录用户并更新数据库状态

要识别完成付款的登录用户，核心是在创建Checkout会话时将用户ID附加到会话的元数据中，之后在Webhook事件中提取该ID并关联到数据库操作。以下是具体修改步骤：

1. 修改Checkout会话创建代码，添加用户元数据 #

在创建Stripe Checkout会话时，通过metadata字段传入当前登录用户的ID（假设后端已通过认证中间件获取到用户ID，比如req.user.id）：

app.post("/checkout-session", async (req, res) => {
  try {
    // 确保已获取当前登录用户的ID（根据你的认证方式调整，比如JWT、session）
    const userId = req.user.id; 

    const session = await stripe.checkout.sessions.create({
      payment_method_types: ["card"],
      mode: "payment",
      line_items: req.body.items.map((item) => {
        const storeItem = storeItems.get(item.id);
        return {
          price_data: {
            currency: "usd",
            product_data: {
              name: storeItem.name,
            },
            unit_amount: storeItem.priceInCents,
          },
          quantity: item.quantity,
        };
      }),
      // 添加metadata，存储用户ID
      metadata: {
        user_id: userId
      },
      success_url: `${process.env.CLIENT_URL}/success`,
      cancel_url: `${process.env.CLIENT_URL}/failure`,
    });
    res.json({ url: session.url });
  } catch (e) {
    res.status(500).json({ error: e.message });
  }
});

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

在checkout.session.completed事件中，从会话对象的metadata里取出用户ID，执行数据库更新操作：

app.post("/webhook", express.raw({ type: "application/json" }), async (req, res) => {
  let event;
  if (process.env.STRIPE_WEBHOOK_SECRET) {
    const signature = req.headers["stripe-signature"];
    try {
      event = stripe.webhooks.constructEvent(
        req.body,
        signature,
        process.env.STRIPE_WEBHOOK_SECRET
      );
    } catch (err) {
      console.log(`⚠️  Webhook签名验证失败:`, err.message);
      return res.sendStatus(400);
    }
  } else {
    event = JSON.parse(req.body);
  }

  // 处理事件
  switch (event.type) {
    case "checkout.session.completed":
      const checkoutSession = event.data.object;
      console.log("Checkout会话已完成:", checkoutSession);
      
      // 提取metadata中的用户ID
      const userId = checkoutSession.metadata.user_id;
      if (!userId) {
        console.log("未找到用户ID元数据");
        return res.sendStatus(200);
      }

      // 执行数据库更新操作（示例代码，根据你的数据库类型调整）
      try {
        // 比如更新用户的付款状态为已完成
        await db.query(
          "UPDATE users SET payment_status = 'completed' WHERE id = $1",
          [userId]
        );
        console.log(`用户 ${userId} 的付款状态已更新`);
      } catch (dbErr) {
        console.log("更新数据库失败:", dbErr.message);
      }
      break;
    // 其他事件处理保持不变
    case "payment_intent.succeeded":
      const paymentIntent = event.data.object;
      console.log(`PaymentIntent ${paymentIntent.id} 支付成功，金额: ${paymentIntent.amount}`);
      break;
    case "payment_intent.payment_failed":
      const failedPaymentIntent = event.data.object;
      console.log(`PaymentIntent ${failedPaymentIntent.id} 支付失败: ${failedPaymentIntent.last_payment_error?.message}`);
      break;
    default:
      console.log(`未处理的事件类型: ${event.type}`);
  }

  res.sendStatus(200);
});

关键注意事项 #

• 认证验证：确保/checkout-session接口只有已登录用户能访问，避免恶意请求伪造用户ID。
• 元数据限制：Stripe元数据最多支持50个键值对，单个键值不超过500字符，不要存储敏感信息（如密码）。
• Webhook可靠性：Stripe会重试失败的Webhook请求，确保你的数据库操作是幂等的（比如通过会话ID判断是否已处理过该付款）。

内容的提问来源于stack exchange，提问作者vikram sah