Stripe订阅服务重复创建Customer问题解决方案咨询

问题根源 #

直接使用Stripe预构建的支付链接（buy.stripe.com）时，即便预填用户邮箱，Stripe也不会自动关联到已存在的Customer对象。只有在通过API创建Checkout Session时明确指定customer参数，Stripe才会复用原有Customer，否则每次支付都会生成新的Customer实例，导致后续订阅事件无法正确关联到系统内的用户。

解决方案步骤 #

1. 创建生成Checkout Session的API端点 #

在Next.js项目中新增API路由，用于动态生成关联用户的Stripe Checkout Session：

// pages/api/create-checkout-session.ts
import { NextApiRequest, NextApiResponse } from 'next';
import Stripe from 'stripe';
import mongooseConnect from '@/lib/mongooseConnect';
import User from '@/models/User';

const stripe = new Stripe(process.env.STRIPE_SK as string);

export default async function handler(req: NextApiRequest, res: NextApiResponse) {
  if (req.method !== 'POST') {
    return res.status(405).json({ error: 'Method not allowed' });
  }

  await mongooseConnect();
  const { email } = req.body;

  // 查询系统内的用户，获取已关联的Stripe Customer ID
  const user = await User.findOne({ email });
  let customerId: string | undefined;
  if (user?.stripeCustomerId) {
    customerId = user.stripeCustomerId;
  }

  try {
    const session = await stripe.checkout.sessions.create({
      // 若已有Customer则指定，否则Stripe会自动创建并关联
      customer: customerId,
      customer_email: !customerId ? email : undefined, // 仅当无Customer时传入邮箱
      line_items: [
        {
          price: '你的产品Price ID', // 替换为Stripe后台的Price ID
          quantity: 1,
        },
      ],
      mode: 'subscription',
      success_url: `${process.env.NEXT_PUBLIC_BASE_URL}/success?session_id={CHECKOUT_SESSION_ID}`,
      cancel_url: `${process.env.NEXT_PUBLIC_BASE_URL}/cancel`,
    });

    res.status(200).json({ url: session.url });
  } catch (err: any) {
    res.status(500).json({ error: err.message });
  }
}

2. 修改前端支付按钮逻辑 #

替换原有的静态支付链接，改为调用上述API获取动态Session URL后跳转：

// 前端组件代码
import { useSession } from 'next-auth/react';

export default function PayButton() {
  const { data: session } = useSession();

  const handlePay = async () => {
    if (!session?.user?.email) return;

    try {
      const response = await fetch('/api/create-checkout-session', {
        method: 'POST',
        headers: { 'Content-Type': 'application/json' },
        body: JSON.stringify({ email: session.user.email }),
      });

      const { url } = await response.json();
      window.location.href = url;
    } catch (err) {
      console.error('Failed to create checkout session:', err);
    }
  };

  return (
    <button
      className="bg-red-600 text-white py-2 px-4 rounded inline-block"
      onClick={handlePay}
    >
      Pay Now
    </button>
  );
}

3. 优化Webhook逻辑（可选） #

确保checkout.session.completed事件中，用户的stripeCustomerId能正确更新（如果是首次支付自动创建的Customer）：

在原webhook.ts的checkout.session.completed分支中，补充如下逻辑：

// 原有的user查询逻辑之后
if (!user.stripeCustomerId && session.customer) {
  user.stripeCustomerId = session.customer as string;
  await user.save();
}

原理说明 #

通过API创建Checkout Session时指定customer参数，Stripe会复用该Customer对象创建订阅，而非生成新的Customer。这样后续的customer.subscription.deleted等事件就能通过subscription.customer正确关联到系统内的用户，避免权限回收等逻辑异常。

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