如何通过Stripe验证月度收费及高级用户状态并优化支付系统？

我正在开发一个Web应用，其中设有仅高级用户可访问的区域。目前我通过自定义代码处理支付逻辑并记录用户的高级状态，但维护起来很麻烦，想请教更好的实现方式：

我的当前支付处理代码如下：

var time = req.params.time; 
console.log(time); 
if (time === '1') { 
  var amount = 1499; 
  var days = 30; 
} else if (time === '3') { 
  amount = 999 * 3; 
  days = 90; 
} else res.render('payment/error', {title: 'Error', user: req.user}); 

//^^^^ error/security handling ^^^^// 
console.log(req.user.username); 
stripe.charges.create({ 
  amount: amount, 
  currency: "cad", 
  source: req.body.stripeToken, 
  description: "Charge for DigitLead website evaluation tool", 
  receipt_email: req.user.username, 
}).then(ch => { 
  console.log(ch); 
  Account.findById(req.user._id).then(u => { 
    var date = new Date().getTime(); 
    console.log(date); 
    u.lastPaid = date; 
    date += (days * 24 * 60 * 60 * 1000); 
    console.log(date); 
    u.premiumEnds = date; 
    console.log(u); 
    u.save(); 
    res.render('payment/summary', { 
      title: 'Payment Summary', 
      user: req.user, 
      date: u.premiumEnds, 
    }) 
  }); 
}).catch(e => console.log(e)); 

我不满意这个实现，因为未来修改支付规则时维护成本太高。想请教：

1. 是否可以通过Stripe API来管理用户的高级状态，而不用完全依赖自定义代码？
2. 针对现有代码和模型，还有哪些优化建议？

我的当前用户模型（需要修改）：

var mongoose = require('mongoose'); 
var plm = require('passport-local-mongoose'); 
var accountSchema = new mongoose.Schema({ 
  accType: String, 
  websites: [], 
  keys: [], 
  creditCardNo: Number, 
  alexaCalls: Number, 
  stripeId: String, 
  lastPaid: Date, 
  premiumEnds: Date, 
}); 
accountSchema.plugin(plm); 
module.exports = mongoose.model('Account', accountSchema); 

一、用Stripe Subscriptions替代一次性Charge管理高级状态 #

完全可以用Stripe的订阅（Subscriptions）API来简化高级用户状态的管理，这会比你现在的一次性Charge方案更健壮、易维护：

• 核心优势：订阅会自动跟踪用户的付费周期、续费状态、过期时间，不用你手动计算premiumEnds这类字段。Stripe会在用户续费成功/失败、订阅过期时发送Webhook通知，你只需要根据这些通知更新数据库中的用户状态即可。
• 快速实现步骤：
  1. 在Stripe后台创建产品（比如"高级会员"）和对应的价格计划（月付$14.99、季付$29.97）。
  2. 前端用Stripe Elements收集支付信息，创建订阅会话（而非直接创建Charge）。
  3. 后端监听Stripe的Webhook事件：customer.subscription.created（订阅创建成功）、customer.subscription.updated（订阅状态变更）、customer.subscription.deleted（订阅取消），根据事件内容更新数据库中用户的accType或isPremium字段。
  4. 检查用户高级状态时，优先查询本地数据库的状态（可缓存Stripe返回的订阅到期时间），必要时再调用Stripe API校验（适合对状态准确性要求极高的场景）。

二、现有代码的可维护性优化 #

如果暂时不想切换到订阅方案，可以先优化现有代码的结构：

• 提取支付规则配置：把不同时长的金额和天数抽成配置对象，后续修改规则只需调整配置，不用动核心逻辑：

  const paymentPlans = {
    '1': { amount: 1499, days: 30 },
    '3': { amount: 999 * 3, days: 90 }
  };
  const plan = paymentPlans[time];
  if (!plan) {
    return res.render('payment/error', {title: 'Error', user: req.user});
  }
  const { amount, days } = plan;
  

• 增强错误处理：当前的catch仅打印错误，应该把错误信息反馈给用户，提升体验：

  }).catch(e => {
    console.error(e);
    res.render('payment/error', {title: 'Payment Failed', user: req.user, error: e.message});
  });
  

• 用async/await简化Promise嵌套：替代多层.then()，让代码逻辑更清晰：

  try {
    const ch = await stripe.charges.create({ /* 支付参数 */ });
    const u = await Account.findById(req.user._id);
    const now = new Date();
    u.lastPaid = now;
    u.premiumEnds = new Date(now.getTime() + days * 24 * 60 * 60 * 1000);
    await u.save();
    res.render('payment/summary', { /* 渲染参数 */ });
  } catch (e) {
    console.error(e);
    res.render('payment/error', { /* 错误页面参数 */ });
  }
  

三、用户模型的安全性与结构优化 #

• 移除敏感字段：绝对不要存储creditCardNo！Stripe已经帮你处理支付信息，你只需要保存用户的Stripe Customer ID（stripeId）即可，存储信用卡号会带来合规（PCI DSS）和安全风险。
• 简化状态字段：添加isPremium布尔字段，或者把accType设为枚举值（free/premium），配合premiumEnds使用，检查状态时更直观：

  var accountSchema = new mongoose.Schema({ 
    accType: { type: String, enum: ['free', 'premium'], default: 'free' },
    websites: [{ type: mongoose.Schema.Types.ObjectId, ref: 'Website' }], // 建议用MongoDB引用替代空数组
    keys: [{ type: String }],
    alexaCalls: { type: Number, default: 0 },
    stripeId: String,
    lastPaid: Date,
    premiumEnds: Date,
  });
  

• 添加索引：对premiumEnds和accType字段添加索引，提升高级用户查询的效率。

四、封装高级状态检查中间件 #

把检查用户是否为高级用户的逻辑封装成Express中间件，在需要保护的路由中直接使用，避免重复代码：

function requirePremium(req, res, next) {
  const user = req.user;
  if (!user) {
    return res.redirect('/login');
  }
  // 自定义方案的检查逻辑
  if (user.accType !== 'premium' || new Date() > user.premiumEnds) {
    return res.redirect('/upgrade');
  }
  // 订阅方案的检查逻辑（示例）
  // if (!user.isPremium) return res.redirect('/upgrade');
  next();
}

// 使用中间件保护路由
app.get('/premium-dashboard', requirePremium, (req, res) => {
  res.render('premium/dashboard');
});

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