Stripe结账成功后无法获取Customer ID存入用户数据库的技术求助

问题根源 #

当你调用stripe.checkout.sessions.create但未指定customer参数时，Stripe不会在会话创建阶段生成Customer ID。只有当客户完成结账支付后，Stripe才会自动创建对应的Customer对象，所以你在会话创建后直接读取session.customer会得到undefined。

方案1：提前关联已有用户到Stripe Customer（推荐） #

如果你的系统中用户已经存在账号，可以提前为用户创建（或关联）Stripe Customer，在创建结账会话时直接指定这个Customer ID。这样会话创建后就能立即拿到Customer ID，同时支付完成后会自动关联到该Customer。

修改后的代码示例：

router.post("/create-checkout-session", ensureAuthenticated, async (req, res) => { 
  const { priceId } = req.body; 
  try {
    // 检查当前用户是否已关联Stripe Customer ID
    let customerId = req.user.stripeCustomerId; // 假设你的用户模型存储了这个字段
    if (!customerId) {
      // 为用户创建新的Stripe Customer
      const customer = await stripe.customers.create({
        email: req.user.email, // 使用你的用户邮箱
        // 可选：添加用户姓名等其他信息
        // name: req.user.fullName
      });
      customerId = customer.id;
      // 把新的Customer ID保存到你的用户数据库
      await User.findByIdAndUpdate(req.user._id, { stripeCustomerId: customerId });
    }

    const session = await stripe.checkout.sessions.create({ 
      mode: "subscription", 
      payment_method_types: ["card"], 
      customer: customerId, // 这里指定已有的Customer ID
      line_items: [ 
        { 
          price: priceId, 
          quantity: 1, 
        }, 
      ], 
      success_url: 'http://localhost:3000/fr/premiereconnexion?session_id={CHECKOUT_SESSION_ID}', 
      cancel_url: 'https://localhost:3000/fr/erreursouscription', 
    }); 
    // 现在session.customer会返回有效的Customer ID
    res.send({ sessionId: session.id, customerID: session.customer }); 
  } catch (e) { 
    res.status(400); 
    return res.send({ error: { message: e.message, } }); 
  } 
});

方案2：通过Stripe Webhook获取支付完成后的Customer ID #

如果用户尚未在你的系统创建账号，或者你希望让Stripe自动创建Customer，那么需要通过Stripe Webhook监听checkout.session.completed事件——这个事件会在客户成功完成支付后触发，此时你可以从事件数据中提取Customer ID并写入数据库。

步骤1：修改结账会话创建代码，添加用户标识

在创建会话时加入client_reference_id，传递你的系统用户ID，方便后续关联：

router.post("/create-checkout-session", ensureAuthenticated, async (req, res) => { 
  const { priceId } = req.body; 
  try { 
    const session = await stripe.checkout.sessions.create({ 
      mode: "subscription", 
      payment_method_types: ["card"], 
      client_reference_id: req.user._id.toString(), // 传递你的系统用户ID
      line_items: [ 
        { 
          price: priceId, 
          quantity: 1, 
        }, 
      ], 
      success_url: 'http://localhost:3000/fr/premiereconnexion?session_id={CHECKOUT_SESSION_ID}', 
      cancel_url: 'https://localhost:3000/fr/erreursouscription', 
    }); 
    res.send({ sessionId: session.id }); 
  } catch (e) { 
    res.status(400); 
    return res.send({ error: { message: e.message, } }); 
  } 
});

步骤2：设置Webhook处理路由

创建一个Webhook端点，监听checkout.session.completed事件并写入Customer ID：

// 注意：使用express.raw解析Stripe的Webhook请求体
router.post('/stripe-webhook', express.raw({type: 'application/json'}), async (req, res) => {
  const sig = req.headers['stripe-signature'];
  const webhookSecret = process.env.STRIPE_WEBHOOK_SECRET; // 你的Stripe Webhook密钥

  let event;

  try {
    // 验证Webhook事件的合法性
    event = stripe.webhooks.constructEvent(req.body, sig, webhookSecret);
  } catch (err) {
    return res.status(400).send(`Webhook Error: ${err.message}`);
  }

  // 处理支付完成事件
  if (event.type === 'checkout.session.completed') {
    const session = event.data.object;
    const customerId = session.customer; // 拿到有效的Customer ID
    const userId = session.client_reference_id; // 拿到之前传递的系统用户ID

    // 将Customer ID写入你的用户数据库
    await User.findByIdAndUpdate(userId, { stripeCustomerId: customerId });
  }

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

关键提醒 #

• 不要依赖会话创建时的session.customer字段，除非你提前指定了customer参数。
• 使用Webhook时，务必在Stripe Dashboard中配置正确的Webhook端点和密钥，并验证事件签名，避免恶意请求。

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