7.5 变现方式与收入优化

做出产品 → 等流量 → 流量够大了再考虑赚钱

验证需求 → 设计变现模式 → 开发产品 → 获取流量 → 优化转化

主要: 订阅制 (Freemium)
辅助: AdSense (免费用户)
补充: 联盟营销 (推荐相关工具)

收入比例: 70% 订阅 + 20% 广告 + 10% 联盟

主要: AdSense
辅助: 联盟营销
补充: Newsletter 订阅 + 赞助

收入比例: 50% 广告 + 30% 联盟 + 20% 赞助

主要: API 按量付费
辅助: 订阅套餐
补充: 企业定制

收入比例: 80% 订阅/按量 + 20% 企业

主要: 付费会员
辅助: 广告位
补充: 置顶推广

收入比例: 60% 会员 + 30% 广告 + 10% 推广

✅ 域名: 独立域名(不能是 xxx.vercel.app)
✅ 内容: 至少 20-30 篇原创文章
✅ 流量: 每天 100+ UV (持续 1-2 周)
✅ 年龄: 网站运行至少 1-3 个月
✅ 政策: 符合 AdSense 政策(无违规内容)
✅ 页面: 隐私政策、关于页面、联系方式
✅ 导航: 清晰的网站结构和菜单
✅ 语言: 内容语言与申请国家匹配

日收入 = PV × CTR × CPC × 1000

解释:
- PV: 页面浏览量 (Page Views)
- CTR: 广告点击率 (Click Through Rate, 通常 0.5%-2%)
- CPC: 单次点击收入 (Cost Per Click, $0.1-$5)

数据:
- 日 PV: 5000
- CTR: 1%
- CPC: $1.5

计算:
日收入 = 5000 × 1% × $1.5 = $75
月收入 = $75 × 30 = $2250
年收入 = $2250 × 12 = $27,000

数据:
- 日 PV: 10000
- CTR: 0.8%
- CPC: $0.3

计算:
日收入 = 10000 × 0.8% × $0.3 = $24
月收入 = $24 × 30 = $720
年收入 = $720 × 12 = $8,640

# 文章标题
 
文章开头 300-500 字...
 
[广告位 1: 自动广告或展示广告]
 
继续文章 500-800 字...
 
[广告位 2: 信息流广告]  ← 👑 黄金位置!
 
继续文章 300-500 字...
 
[广告位 3: 相关搜索广告]
 
文章结尾...

// components/AdSense.tsx
'use client'
 
import { useEffect } from 'react'
 
export default function AdSense({
  slot,
  format = 'auto',
  responsive = true,
  style = { display: 'block' }
}) {
  useEffect(() => {
    try {
      // @ts-ignore
      (window.adsbygoogle = window.adsbygoogle || []).push({})
    } catch (err) {
      console.error('AdSense error:', err)
    }
  }, [])
 
  return (
    <ins
      className="adsbygoogle"
      style={style}
      data-ad-client={process.env.NEXT_PUBLIC_ADSENSE_ID}
      data-ad-slot={slot}
      data-ad-format={format}
      data-full-width-responsive={responsive}
    />
  )
}
 
// 使用
// app/blog/[slug]/page.tsx
import AdSense from '@/components/AdSense'
 
export default function BlogPost() {
  return (
    <article>
      <h1>文章标题</h1>
      <p>开头内容...</p>
 
      {/* 广告位 1 */}
      <AdSense slot="1234567890" />
 
      <p>中间内容...</p>
 
      {/* 广告位 2 - 黄金位置 */}
      <AdSense
        slot="0987654321"
        format="fluid"
        style={{ display: 'block', textAlign: 'center', minHeight: '250px' }}
      />
 
      <p>结尾内容...</p>
    </article>
  )
}

自动广告(开启) + 手动广告(2-3 个关键位置)

为什么:
- 自动广告覆盖你没想到的位置
- 手动广告控制关键位置(如文章中间)
- 两者配合,收入最大化

标题: "10 张好看的桌面壁纸"
关键词: 壁纸, 桌面, 图片
广告: 图片托管、壁纸 App (低价)

标题: "如何选择最佳项目管理软件 [2025]"
关键词: 项目管理, 软件, SaaS
广告: Asana, Monday.com, ClickUp (高价)

数据(估算):
- 月 PV: 500 万
- 领域: 技术教程(CPC 约 $1.5)
- RPM: 约 $8

计算:
月广告收入 = 5,000,000 ÷ 1000 × $8 = $40,000

实际:
- AdSense + 会员订阅($25/月)
- 会员收入远超广告(约 $300K+/年)
- 但广告为免费用户提供持续收入

数据:
- 日 UV: 4000
- 日 PV: 12000 (每人看 3 页)
- 领域: 娱乐(CPC 约 $0.3)
- CTR: 0.8%

计算:
日收入 = 12000 × 0.8% × $0.3 = $28.8
月收入 = $28.8 × 30 = $864

实际观察:
- 流量很高但 CPC 很低(娱乐类)
- 收入不如预期(需要更高 CPC 领域)

策略:
- 做多个垂直站(10+ 网站)
- 混合高低 CPC 内容
- 总流量: 15 万 UV/月
- 平均 RPM: $5-8

计算:
单站平均: 15,000 UV × 3 PV × RPM $6 ÷ 1000 = $270
10 个站: $270 × 10 = $2700/月

关键:
- 不依赖单一网站
- 分散风险
- 持续产出内容

A: 90% 拒绝原因:
1. 内容不足 → 添加至少 20 篇文章
2. 网站太新 → 运营 1-2 个月后再申请
3. 缺少必要页面 → 添加隐私政策、关于、联系
4. 流量太低 → 等流量稳定在 100+ UV/天

重新申请: 等 30 天,优化后再申请

A: ❌ 绝对不行!
- Google 有完善的检测系统
- 一旦发现,永久封号
- 不要让家人朋友点击
- 不要用 VPN 换 IP 点击
- 不要使用点击机器人

A: 付款流程:
1. 累计满 $10: 验证地址(寄 PIN 码)
2. 累计满 $100: 首次付款
3. 之后每月 21-26 日付款(如余额 > $100)

付款方式:
- 电汇(美国)
- Western Union(部分国家)
- 支票(较慢)

定价: $49 一次性
月销售: 100 份
月收入: $4900

一年后:
- 还是需要每月卖 100 份
- 老客户不再贡献收入
- 增长完全靠新客户

定价: $9/月
月新增: 100 订阅

收入增长:
- 第 1 月: $900 (100 用户)
- 第 2 月: $1800 (100 老 + 100 新)
- 第 3 月: $2700 (200 老 + 100 新)
- 第 6 月: $5400 (500 老 + 100 新)
- 第 12 月: $10,800 (1100 老 + 100 新)

假设流失率 5%/月:
- 实际第 12 月: ~$8000
- 仍然是一次性付费的 1.6 倍!

┌─────────────────────────────────────────┐
│  Free (免费)                             │
│  价格: $0                                │
│  目标: 获取大量用户,降低尝试门槛          │
│  功能:                                   │
│  - 核心功能有限使用                       │
│  - 每天/每月配额限制                      │
│  - 显示品牌水印                          │
│  - 有广告                                │
│  转化目标: 5-10% 转为 Pro                │
└─────────────────────────────────────────┘

┌─────────────────────────────────────────┐
│  Pro (专业版) 👑                         │
│  价格: $9/月 或 $90/年 (Save 17%)        │
│  目标: 主要收入来源,覆盖 90% 用户需求     │
│  功能:                                   │
│  - 所有核心功能无限使用                   │
│  - 无广告                                │
│  - 去除水印                              │
│  - 优先支持                              │
│  - 云存储                                │
│  转化目标: 85-90% 付费用户选择此层级      │
└─────────────────────────────────────────┘

┌─────────────────────────────────────────┐
│  Enterprise (企业版)                     │
│  价格: $49/月 或 $490/年                 │
│  目标: 高价值客户,虽少但利润高            │
│  功能:                                   │
│  - Pro 所有功能                          │
│  - 团队协作(多用户)                       │
│  - API 访问                              │
│  - 自定义品牌                            │
│  - 专属客服                              │
│  - SLA 保证                              │
│  转化目标: 5-10% 付费用户,但贡献 30% 收入 │
└─────────────────────────────────────────┘

Free:
- 基础语法检查
- 每日配额

Premium: $12/月 或 $144/年
- 高级语法建议
- 词汇增强
- 抄袭检查

Business: $15/用户/月
- 团队协作
- 品牌风格指南
- 优先支持

结果:
- 3000 万用户,其中约 1% 付费 ($144/年)
- 年收入估计: $200M+

Free:
- 个人使用,1000 块限制

Plus: $8/用户/月
- 无限块
- 30 天历史

Business: $15/用户/月
- 90 天历史
- SAML SSO

Enterprise: 联系销售
- 高级权限
- 专属支持

策略:
- Free 足够强大,建立网络效应
- Plus 是甜点价格($8)
- 企业版高价,但功能针对性强

# 1. 注册 Stripe 账号
https://dashboard.stripe.com/register
 
# 2. 获取 API 密钥
Dashboard → Developers → API keys
- Publishable key: pk_test_xxxxx (公开,前端用)
- Secret key: sk_test_xxxxx (私密,后端用)

# 安装依赖
pnpm install stripe @stripe/stripe-js

// lib/stripe.ts
import Stripe from 'stripe'
 
export const stripe = new Stripe(process.env.STRIPE_SECRET_KEY!, {
  apiVersion: '2023-10-16',
})
 
// 前端 Stripe
import { loadStripe } from '@stripe/stripe-js'
 
export const stripePromise = loadStripe(
  process.env.NEXT_PUBLIC_STRIPE_PUBLISHABLE_KEY!
)

// app/api/create-checkout-session/route.ts
import { stripe } from '@/lib/stripe'
import { NextRequest, NextResponse } from 'next/server'
 
export async function POST(req: NextRequest) {
  const { priceId, userId } = await req.json()
 
  try {
    // 创建 Checkout Session
    const session = await stripe.checkout.sessions.create({
      mode: 'subscription',
      payment_method_types: ['card'],
      line_items: [
        {
          price: priceId, // price_xxxxx (在 Stripe Dashboard 创建)
          quantity: 1,
        },
      ],
      success_url: `${process.env.NEXT_PUBLIC_URL}/success?session_id={CHECKOUT_SESSION_ID}`,
      cancel_url: `${process.env.NEXT_PUBLIC_URL}/pricing`,
      client_reference_id: userId,
      metadata: {
        userId,
      },
    })
 
    return NextResponse.json({ sessionId: session.id })
  } catch (error: any) {
    return NextResponse.json({ error: error.message }, { status: 500 })
  }
}

// components/PricingCard.tsx
'use client'
 
import { stripePromise } from '@/lib/stripe'
 
export default function PricingCard({
  tier,
  price,
  priceId
}: {
  tier: string
  price: string
  priceId: string
}) {
  const handleSubscribe = async () => {
    // 1. 创建 Checkout Session
    const response = await fetch('/api/create-checkout-session', {
      method: 'POST',
      headers: { 'Content-Type': 'application/json' },
      body: JSON.stringify({
        priceId,
        userId: 'user_123', // 从 session/JWT 获取
      }),
    })
 
    const { sessionId } = await response.json()
 
    // 2. 跳转到 Stripe Checkout
    const stripe = await stripePromise
    await stripe?.redirectToCheckout({ sessionId })
  }
 
  return (
    <div className="pricing-card">
      <h3>{tier}</h3>
      <p className="price">{price}</p>
      <button onClick={handleSubscribe}>
        Subscribe Now
      </button>
    </div>
  )
}

// app/api/webhooks/stripe/route.ts
import { stripe } from '@/lib/stripe'
import { NextRequest, NextResponse } from 'next/server'
import Stripe from 'stripe'
 
// ⚠️ 重要: 禁用 body parser,Stripe 需要原始 body
export const config = {
  api: {
    bodyParser: false,
  },
}
 
export async function POST(req: NextRequest) {
  const body = await req.text()
  const signature = req.headers.get('stripe-signature')!
 
  let event: Stripe.Event
 
  try {
    // 验证 webhook 签名
    event = stripe.webhooks.constructEvent(
      body,
      signature,
      process.env.STRIPE_WEBHOOK_SECRET!
    )
  } catch (err: any) {
    console.error(`Webhook signature verification failed: ${err.message}`)
    return NextResponse.json({ error: err.message }, { status: 400 })
  }
 
  // 处理不同事件
  switch (event.type) {
    case 'checkout.session.completed':
      // 支付成功,激活订阅
      const session = event.data.object as Stripe.Checkout.Session
      const userId = session.client_reference_id
 
      // 更新数据库: 用户订阅状态
      await db.user.update({
        where: { id: userId },
        data: {
          subscriptionStatus: 'active',
          subscriptionId: session.subscription,
        },
      })
      break
 
    case 'customer.subscription.updated':
      // 订阅更新(升级/降级)
      const subscription = event.data.object as Stripe.Subscription
      // 更新数据库...
      break
 
    case 'customer.subscription.deleted':
      // 订阅取消
      const canceledSub = event.data.object as Stripe.Subscription
      // 更新数据库: 用户订阅状态为 inactive
      break
 
    case 'invoice.payment_failed':
      // 支付失败(信用卡过期等)
      // 发送邮件提醒用户更新支付方式
      break
  }
 
  return NextResponse.json({ received: true })
}

# Stripe Dashboard → Developers → Webhooks → Add endpoint
 
URL: https://yoursite.com/api/webhooks/stripe
 
选择事件:
✅ checkout.session.completed
✅ customer.subscription.updated
✅ customer.subscription.deleted
✅ invoice.payment_failed
 
获取 Webhook Secret: whsec_xxxxx

100 访客
  ↓ 30% 注册转化
30 免费用户
  ↓ 5% 付费转化
1.5 付费用户

总转化率: 1.5%

注册表单:
- 姓名*
- 邮箱*
- 密码*
- 确认密码*
- 公司名称*
- 职位*
- 电话*
- 国家*
- 验证码*

问题: 字段太多,用户嫌麻烦

<form>
  <input type="email" placeholder="Enter your email" />
  <button>Continue with Email</button>
 
  <div className="divider">OR</div>
 
  <button className="google-auth">
    <img src="/google.svg" />
    Continue with Google
  </button>
</form>
 
设计:
- 只要邮箱(或社交登录)
- 其他信息后续收集
- 减少摩擦,提高转化

✅ 14 天免费试用
✅ 无需信用卡
✅ 试用期内解锁所有 Pro 功能
✅ 试用快结束时发送提醒邮件

为什么:
- 降低尝试门槛
- 用户体验完整功能后更愿意付费
- 信任感建立

免费版: 完全禁用核心功能

用户点击 → "This feature is only available in Pro"

问题: 用户没体验过,不知道有多好

免费版: 每天 10 次使用

用户使用 10 次后 →
"You've used all 10 daily credits!
Upgrade to Pro for unlimited use.
[See Plans]"

优势:
- 用户已经体验过价值
- 形成习惯
- 更容易转化

<!-- 定价页面 -->
<div className="social-proof">
  <div className="stats">
    <div>
      <strong>12,847</strong>
      <span>Active Users</span>
    </div>
    <div>
      <strong>4.8/5</strong>
      <span>Average Rating</span>
    </div>
  </div>
 
  <div className="testimonials">
    <blockquote>
      "This tool saved me 10 hours every week!"
      <cite>— Sarah, Product Manager</cite>
    </blockquote>
  </div>
 
  <div className="trust-badges">
    <img src="/featured-on-product-hunt.svg" />
    <img src="/as-seen-on-techcrunch.svg" />
  </div>
</div>

<!-- 限时优惠 -->
<div className="pricing-banner">
  <span className="badge">LIMITED TIME</span>
  <p>
    Get 30% off annual plans!
    Offer ends in: <strong>2 days 14:32:05</strong>
  </p>
</div>
 
<!-- 早鸟价格 -->
<div className="early-bird">
  <p>
    🎉 Early Adopter Pricing: $7/mo (Regular $12/mo)
    Only for the first 500 customers!
    <strong>327/500 spots taken</strong>
  </p>
</div>

月流失率 (Churn Rate) = 本月取消订阅数 ÷ 月初订阅总数

示例:
- 月初: 1000 订阅
- 本月取消: 50
- 流失率: 50 ÷ 1000 = 5%

目标:
- ✅ 优秀: < 3%
- ⚠️ 一般: 3-7%
- ❌ 危险: > 7%

定价:
- Free: 3 个项目
- Professional: $12/editor/月
- Organization: $45/editor/月

策略:
- Free 版足够个人用户和小团队
- Professional 针对专业设计师
- Organization 针对大公司(SSO, 高级权限)

结果:
- 2022 年 ARR: $400M
- 被 Adobe 以 $20B 收购(50× ARR)

定价(基于订阅者数量):
- 0-1000 订阅者: Free
- 1000-3000: $29/月
- 3000-5000: $49/月
- ...

策略:
- 用户增长 → 自动升级(收入增长)
- 早期免费吸引创作者
- 成功后自然付费

结果:
- 30,000+ 付费用户
- ARR: $25M+

定价:
- Free: 无限用户(!)
- Standard: $8/用户/月
- Plus: $14/用户/月

策略:
- Free 版功能强大,建立网络效应
- 团队协作功能需要付费
- 目标用户: 技术团队(愿意付费)

结果:
- 估值 $4.6B(2024)
- 增长迅速,SaaS 新星

1. 你在网站/博客中推荐产品
2. 用户通过你的专属链接购买
3. 商家给你佣金(通常 5%-50%)

博客文章: "10 Best AI Tools for Developers in 2025"
  ↓
推荐工具 #1: Cursor
  ↓
附上联盟链接: https://cursor.sh/?ref=yourcode
  ↓
读者点击并购买 Cursor Pro ($20/月)
  ↓
你获得佣金: $8 (40% 佣金率)

标题: "Buy Cursor Now!"
 
内容:
Cursor is the best AI coding tool.
Click here to buy: [link]

标题: "我如何用 AI 编程工具在 3 天内开发一个 SaaS"
 
内容:
最近我挑战用 AI 工具 3 天开发一个完整的 SaaS 产品。
最大的效率提升来自 Cursor...
 
[分享使用过程,遇到的问题,如何解决]
 
如果你也想尝试,可以通过这个链接注册: [link]
(完全透明: 这是联盟链接,你购买我会获得佣金,
但不会增加你的费用)

// lib/affiliate-links.ts
export const affiliateLinks = {
  cursor: {
    url: 'https://cursor.sh/?ref=yourcode',
    commission: '40%',
    tracking: 'cursor',
  },
  digitalocean: {
    url: 'https://m.do.co/c/yourref',
    commission: '$25/signup',
    tracking: 'digitalocean',
  },
  ahrefs: {
    url: 'https://ahrefs.com/?ref=yourcode',
    commission: '$200/sale',
    tracking: 'ahrefs',
  },
}
 
// components/AffiliateLink.tsx
'use client'
 
import { affiliateLinks } from '@/lib/affiliate-links'
import { useEffect } from 'react'
 
export default function AffiliateLink({
  tool,
  children
}: {
  tool: keyof typeof affiliateLinks
  children: React.ReactNode
}) {
  const link = affiliateLinks[tool]
 
  const handleClick = () => {
    // 追踪点击
    if (typeof window !== 'undefined' && window.gtag) {
      window.gtag('event', 'affiliate_click', {
        affiliate_name: link.tracking,
        affiliate_url: link.url,
      })
    }
  }
 
  return (
    <a
      href={link.url}
      onClick={handleClick}
      rel="noopener noreferrer nofollow"  // ← 重要!
      target="_blank"
      className="affiliate-link"
    >
      {children}
    </a>
  )
}
 
// 使用
<AffiliateLink tool="cursor">
  Try Cursor (30-day free trial)
</AffiliateLink>

<!-- 页面顶部或底部 -->
 
## Affiliate Disclosure
 
This post contains affiliate links, which means I may earn a commission if you click through and make a purchase, at no additional cost to you. I only recommend tools I actually use and believe in.
 
**中文版本:**
 
## 联盟链接声明
 
本文包含联盟链接。如果你通过这些链接购买,我可能会获得佣金,但不会增加你的费用。我只推荐我真实使用并认可的工具。

// app/api/track-click/route.ts
import { NextRequest, NextResponse } from 'next/server'
 
export async function POST(req: NextRequest) {
  const { tool, page } = await req.json()
 
  // 记录到数据库
  await db.affiliateClick.create({
    data: {
      tool,
      page,
      timestamp: new Date(),
      referrer: req.headers.get('referer'),
      userAgent: req.headers.get('user-agent'),
    },
  })
 
  return NextResponse.json({ success: true })
}
 
// 分析报表
const clicks = await db.affiliateClick.groupBy({
  by: ['tool'],
  _count: true,
  where: {
    timestamp: {
      gte: new Date(Date.now() - 30 * 24 * 60 * 60 * 1000), // 最近 30 天
    },
  },
})
 
// 输出:
// Cursor: 245 clicks
// DigitalOcean: 132 clicks
// Ahrefs: 89 clicks

网站: smartpassiveincome.com
领域: 在线创业、被动收入

联盟收入(公开):
- 月收入: $100K-150K (其中 30-40% 来自联盟)
- 主要产品: ConvertKit, Teachable, Bluehost

策略:
- 深度评测 + 教程
- 100% 透明(公开收入报告)
- 只推荐自己用的产品
- 建立信任 → 高转化

模式: 产品评测网站
收入来源: 100% 联盟营销(主要 Amazon)

数据:
- 2016 年被纽约时报以 $30M 收购
- 当时年收入约 $150K/月
- 团队 < 10 人

策略:
- 极度深入的评测(测试几十个产品)
- SEO 优化("best XXX" 关键词)
- 建立品牌权威

博客: 技术教程 + 工具评测
月访问: 50,000 UV

联盟收入分布:
- ConvertKit: $800/月 (30% 经常性佣金)
- Ahrefs: $600/月 (每月 3-5 个销售)
- DigitalOcean: $400/月 (每月 16 个注册)
- 其他: $200/月

总计: $2000/月

关键文章:
- "最佳邮件营销工具对比" (500 UV/月) → $800 联盟收入
- "DigitalOcean 完整教程" (300 UV/月) → $400 联盟收入

问题: 文章里塞满联盟链接,每个工具都推荐
结果: 用户不信任,转化率极低

只推荐你真正用过并喜欢的 3-5 个工具
提供真实的使用体验和对比

问题: 不披露联盟链接
结果:
- 法律风险(FTC 罚款)
- 失去用户信任
- 可能被平台封号

清晰披露: "这是联盟链接,我会获得佣金"
反而会增加信任("至少他诚实")

问题: 所有文章都是推销
结果: 用户离开,SEO 下降

80% 纯价值内容(无联盟链接)
20% 推荐内容(有联盟链接)

保持内容质量第一

定价示例 (AI 图片生成 API):

$0.01/image (1-1000 images)
$0.008/image (1001-10000 images)
$0.005/image (10000+ images)

用户用多少,付多少钱

// 计费函数
function calculateCost(imageCount: number): number {
  if (imageCount <= 1000) {
    return imageCount * 0.01
  } else if (imageCount <= 10000) {
    return 1000 * 0.01 + (imageCount - 1000) * 0.008
  } else {
    return 1000 * 0.01 + 9000 * 0.008 + (imageCount - 10000) * 0.005
  }
}
 
// API 调用时扣费
app.post('/api/generate-image', async (req, res) => {
  const { userId, prompt } = req.body
 
  // 1. 检查余额
  const user = await db.user.findUnique({ where: { id: userId } })
  if (user.balance < 0.01) {
    return res.status(402).json({ error: 'Insufficient balance' })
  }
 
  // 2. 生成图片
  const image = await generateImage(prompt)
 
  // 3. 扣费
  await db.user.update({
    where: { id: userId },
    data: { balance: user.balance - 0.01 },
  })
 
  // 4. 记录使用
  await db.apiUsage.create({
    data: {
      userId,
      endpoint: '/api/generate-image',
      cost: 0.01,
      timestamp: new Date(),
    },
  })
 
  res.json({ image })
})

Starter: $9/月
- 1000 API 调用/月
- 基础支持
- 99% SLA

Professional: $49/月
- 10,000 API 调用/月
- 优先支持
- 99.9% SLA

Enterprise: $299/月
- 100,000 API 调用/月
- 专属支持
- 99.99% SLA
- 自定义限制

Pro Plan: $49/月 (包含 10,000 calls)
超额: $0.006/call

示例:
用户调用 12,000 次
费用 = $49 + (12000 - 10000) × $0.006 = $49 + $12 = $61

// 生成 API Key
import crypto from 'crypto'
 
export async function generateAPIKey(userId: string): Promise<string> {
  const apiKey = 'sk_live_' + crypto.randomBytes(32).toString('hex')
 
  await db.apiKey.create({
    data: {
      key: apiKey,
      userId,
      createdAt: new Date(),
      lastUsedAt: null,
    },
  })
 
  return apiKey
}
 
// 验证 API Key 中间件
export async function authenticateAPIKey(req, res, next) {
  const apiKey = req.headers['x-api-key']
 
  if (!apiKey) {
    return res.status(401).json({ error: 'Missing API key' })
  }
 
  const key = await db.apiKey.findUnique({
    where: { key: apiKey },
    include: { user: true },
  })
 
  if (!key) {
    return res.status(401).json({ error: 'Invalid API key' })
  }
 
  // 更新最后使用时间
  await db.apiKey.update({
    where: { key: apiKey },
    data: { lastUsedAt: new Date() },
  })
 
  req.user = key.user
  next()
}

import rateLimit from 'express-rate-limit'
import RedisStore from 'rate-limit-redis'
import Redis from 'ioredis'
 
const redis = new Redis(process.env.REDIS_URL)
 
// 基于用户套餐的动态限流
export function createRateLimiter(plan: 'free' | 'pro' | 'enterprise') {
  const limits = {
    free: { windowMs: 60 * 1000, max: 10 }, // 10 req/min
    pro: { windowMs: 60 * 1000, max: 100 }, // 100 req/min
    enterprise: { windowMs: 60 * 1000, max: 1000 }, // 1000 req/min
  }
 
  return rateLimit({
    store: new RedisStore({
      client: redis,
      prefix: 'rate_limit:',
    }),
    windowMs: limits[plan].windowMs,
    max: limits[plan].max,
    message: {
      error: 'Rate limit exceeded',
      retryAfter: 60,
    },
    keyGenerator: (req) => req.user.id, // 基于用户 ID
  })
}
 
// 使用
app.post('/api/generate',
  authenticateAPIKey,
  (req, res, next) => createRateLimiter(req.user.plan)(req, res, next),
  async (req, res) => {
    // API 逻辑...
  }
)

// 记录每次 API 调用
export async function trackAPIUsage(
  userId: string,
  endpoint: string,
  cost: number
) {
  // 1. 记录使用明细
  await db.apiUsage.create({
    data: {
      userId,
      endpoint,
      cost,
      timestamp: new Date(),
    },
  })
 
  // 2. 更新用户月度统计
  const currentMonth = new Date().toISOString().slice(0, 7) // "2025-01"
 
  await db.monthlyUsage.upsert({
    where: {
      userId_month: {
        userId,
        month: currentMonth,
      },
    },
    update: {
      calls: { increment: 1 },
      cost: { increment: cost },
    },
    create: {
      userId,
      month: currentMonth,
      calls: 1,
      cost,
    },
  })
 
  // 3. 检查是否超出套餐限制
  const usage = await db.monthlyUsage.findUnique({
    where: {
      userId_month: { userId, month: currentMonth },
    },
  })
 
  const user = await db.user.findUnique({ where: { id: userId } })
 
  if (usage.calls > user.monthlyLimit) {
    // 超出限制,发送通知
    await sendEmail(user.email, {
      subject: 'API Usage Limit Exceeded',
      body: `You've used ${usage.calls} calls out of ${user.monthlyLimit} this month.`,
    })
  }
}