Nodejs 中的 Stripe 订阅集成 [终极指南]

admin数码21/11/2024 23:00:3300

Nodejs 中的 Stripe 订阅集成 [终极指南]-第1张图片-海印网

让 stripe 订阅与后端服务配合使用可能会很棘手，并且常常会导致开发人员所谓的可怕的“大脑分裂”——同步管理 stripe 的逻辑和您自己的后端数据。

在 vratix，我们在构建开源 stripe 订阅 api 模块时正面解决了这个问题。以下是我们如何在 node.js 中处理 stripe 订阅计费，以保持事情简单、可扩展且对开发人员友好。

核心原则：让 stripe 成为真理之源

关键是将尽可能多的逻辑转移到stripe，同时保持数据库最小化。我们只存储：

客户 id
订阅id
计划

这样，我们就可以避免：

过于复杂的后端逻辑
用于同步仪表板更改的容易出错的 webhook 实现
数据冗余

通过这种方法，您仍然拥有功能齐全的订阅计费系统，同时依赖 stripe 作为唯一的事实来源。

我们实施的特点

在本指南结束时，您将拥有一个基于订阅的应用程序，支持：

用户订阅计划
结帐会议
订阅追加销售
可用计划列表

技术堆栈

postgresql
node.js express.js
打字稿

第1步：数据库设计

我们首先设计一个干净、最小的数据库表：

create table user_subscriptions (  
    "id" serial primary key,  
    "plan" varchar not null,  
    "user_id" integer not null references users(id) on delete cascade,  
    "customer_id" varchar,  
    "subscription_id" varchar not null,  
    "is_owner" boolean not null default true,  
    "created_at" timestamp not null default now(),  
    unique (user_id, subscription_id)  
);

登录后复制

要点：

user_id：引用您的内部用户表
plan：跟踪订阅计划
subscription_id：stripe 订阅 id
is_owner：标记主要订阅持有者

第 2 步：控制器

我们使用工厂函数来保持业务逻辑模块化和可测试。以下是我们的 stripe 订阅控制器的片段：

async getsubscriptions() {  
  const stripeprices = await stripe.prices.list({  
    active: true,  
    type: "recurring",  
    expand: ["data.product"],  
  });  

  return stripeprices.data.map((price) => {  
    const product = price.product as stripe.product;  
    return {  
      plan: price.lookup_key || product.name.tolowercase().replaceall(" ", "_"),  
      name: product.name,  
      priceid: price.id,  
      interval: price.recurring!.interval,  
      price: { currency: price.currency, amount: price.unit_amount },  
    };  
  });  
}

登录后复制

主要亮点：

自定义订阅密钥：源自产品名称或用于清理计划检查的lookup_key（user.plan === 'pro_plan'）。
stripe-first 方法：我们直接从 stripe 获取订阅数据，避免了“脑裂”。

第 3 步：简化 stripe 结账

我们的 createcheckout 函数设置订阅结账会话：

const checkout = await stripe.checkout.sessions.create({  
  line_items: [  
    {  
      price: priceid,  
      adjustable_quantity: { enabled: true },  
      quantity: seats || 1,  
    },  
  ],  
  mode: "subscription",  
  subscription_data: { metadata: { userid } },  
  success_url: checkout_success_url,  
  cancel_url: checkout_cancel_url,  
});  

return { url: checkout.url! };

登录后复制