Nodejs 中的 Stripe 订阅集成 [终极指南]-js教程-PHP中文网

nodejs 中的 stripe 订阅集成 [终极指南]

让 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 订阅控制器的片段：

git-log-tracker

Git post-commit 钩子 + SQLite 提交索引工具。自动将每次提交的元数据（哈希值、作者、分支、仓库、主题）记录到本地 SQLite 数据库中，随后提供一个命令行接口（CLI），支持查询、列表展示、统计、删除和更新记录。触发场景：管理 Git 钩子、跨仓库查询提交历史、定位某次提交所属的仓库、查看提交统计信息、将提交记录写入本地索引。当用户提及“提交日志记录”、“提交索引”、“跨仓库查找提交”、“Git 钩子管理”，或希望以结构化方式查询其提交历史时（即使未明确指出该工具），请使

下载

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! };