定价模式总结

// 用量计费追踪服务——记录每次 API 调用 class MeteringService { constructor(redis, stripe) { this.redis = redis; this.stripe = stripe; } // 记录用量 async recordUsage(orgId, { inputTokens, outputTokens, model }) { const month = new Date().toISOString().slice(0, 7); const key = `usage:${orgId}:${month}`; // Redis INBY 精确计数 const pipeline = this.redis.pipeline(); pipeline.hincrby(key, `input_${model}`, inputTokens); pipeline.hincrby(key, `output_${model}`, outputTokens); pipeline.hincrby(key, 'total_calls', 1); pipeline.expire(key, 90 * 24 * 3600); // 90天过期 await pipeline.exec(); // 检查是否接近上限 → 发送预警 const usage = await this.getMonthlyUsage(orgId); const limit = await this.getLimit(orgId); if (usage.totalCost >= limit * 0.8) { await this.sendUsageAlert(orgId, usage, limit); } } // 同步到 Stripe（每5分钟批量上报） async syncToStripe(orgId) { const usage = await this.getMonthlyUsage(orgId); await this.stripe.subscriptionItems.createUsageRecord( subscriptionItemId, { quantity: Math.round(usage.totalCost * 100), // 美分 timestamp: 'now', action: 'set', // 绝对值设置，避免重复计数 } ); } }

// 计费策略模式——让定价模式可插拔 class BillingEngine { constructor(strategy) { this.strategy = strategy; } async calculateMonthlyBill(org) { return this.strategy.calculate(org); } } // Tiered 模式 class TieredPricing { calculate(org) { const tierPrices = { free: 0, pro: 20, enterprise: 100 }; return { base: tierPrices[org.tier] * org.seats, overage: 0, total: tierPrices[org.tier] * org.seats, }; } } // Usage-based 模式 class UsagePricing { calculate(org) { const base = 0; const tokenCost = org.usage.inputTokens * 0.0000025 // $2.5/M + org.usage.outputTokens * 0.00001; // $10/M return { base, overage: tokenCost, total: tokenCost }; } } // Hybrid 模式 = Tiered + Usage class HybridPricing { constructor(baseTier, usageModel) { this.base = new TieredPricing(baseTier); this.usage = new UsagePricing(usageModel); } calculate(org) { const baseBill = this.base.calculate(org); const usageBill = this.usage.calculate(org); return { base: baseBill.total, overage: usageBill.overage, total: baseBill.total + usageBill.overage, breakdown: { seat: baseBill.total, usage: usageBill.overage }, }; } } // 使用：根据产品配置切换定价模式 const engine = org.tier === 'enterprise' ? new BillingEngine(new HybridPricing()) : new BillingEngine(new TieredPricing()); const bill = await engine.calculateMonthlyBill(org);