原子计费机制

传统方案：
1. 扣除 100 积分 → 成功
2. 调用 LLM API → 网络超时，失败
3. 结果：用户损失 100 积分，但没有获得服务

原子计费方案：
1. 开启事务
2. 扣除 100 积分（暂未提交）
3. 调用 LLM API → 失败
4. 事务回滚，积分退回
5. 结果：用户积分无损失 ✅

传统方案：
1. 扣除 100 积分 → 成功
2. 开始生成报告 → 服务器崩溃
3. 结果：用户损失 100 积分，报告未生成

原子计费方案：
1. 开启事务
2. 扣除 100 积分（暂未提交）
3. 开始生成报告 → 服务器崩溃
4. 事务自动回滚（数据库保证）
5. 结果：用户积分无损失 ✅

传统方案：
1. 用户点击"生成报告"
2. 扣除 100 积分
3. 网络延迟，前端超时
4. 用户再次点击
5. 再次扣除 100 积分
6. 结果：重复扣费 200 积分 ❌

原子计费方案：
1. 检查是否有进行中的任务
2. 如果有 → 拒绝重复提交
3. 如果没有 → 开启事务
4. 扣费 + 创建任务记录（原子操作）
5. 结果：避免重复扣费 ✅

// 伪代码示例
async function generateReportWithBilling(userId, templateId) {
  // 1. 开启数据库事务
  return await prisma.$transaction(async (tx) => {
    // 2. 检查积分余额
    const user = await tx.user.findUnique({ where: { id: userId } })
    if (user.credits < estimatedCost) {
      throw new Error('Insufficient credits')
    }

    // 3. 扣除积分（暂未提交）
    await tx.user.update({
      where: { id: userId },
      data: { credits: user.credits - estimatedCost }
    })

    // 4. 创建积分交易记录（暂未提交）
    await tx.creditTransaction.create({
      data: {
        userId,
        amount: -estimatedCost,
        type: 'REPORT_GENERATION',
        status: 'PENDING'
      }
    })

    // 5. 创建报告任务（暂未提交）
    const report = await tx.report.create({
      data: { userId, templateId, status: 'PENDING' }
    })

    // 6. 事务提交（所有操作一起成功或失败）
    return report
  })

  // 7. 异步执行报告生成
  //    如果失败，通过 Worker 回调退款
}

// 伪代码
async function refundOnFailure(taskId, reason) {
  return await prisma.$transaction(async (tx) => {
    // 1. 查找任务和扣费记录
    const task = await tx.report.findUnique({ where: { id: taskId } })
    const transaction = await tx.creditTransaction.findFirst({
      where: {
        type: 'REPORT_GENERATION',
        reportId: taskId,
        amount: { lt: 0 } // 扣费记录
      }
    })

    // 2. 创建退款记录
    await tx.creditTransaction.create({
      data: {
        userId: task.userId,
        amount: Math.abs(transaction.amount), // 正数（退款）
        type: 'REFUND',
        description: `任务失败自动退款：${reason}`
      }
    })

    // 3. 更新用户积分
    await tx.user.update({
      where: { id: task.userId },
      data: {
        credits: { increment: Math.abs(transaction.amount) }
      }
    })

    // 4. 更新任务状态
    await tx.report.update({
      where: { id: taskId },
      data: { status: 'FAILED', error: reason }
    })
  })
}

// 伪代码
async function createTaskWithCheck(userId, templateId) {
  // 1. 检查是否有相同任务在执行
  const existingTask = await prisma.report.findFirst({
    where: {
      userId,
      templateId,
      status: { in: ['PENDING', 'PROCESSING'] }
    }
  })

  if (existingTask) {
    throw new Error('任务已在执行中，请勿重复提交')
  }

  // 2. 创建新任务（原子计费）
  return await createReportWithBilling(userId, templateId)
}

// 用户积分消费明细
积分管理 → 消费明细

示例记录：
┌─────────────────────┬────────┬──────────┬───────────────────────┐
│ 时间                │ 金额   │ 类型     │ 描述                  │
├─────────────────────┼────────┼──────────┼───────────────────────┤
│ 2025-10-27 10:00    │ -200   │ 报告生成 │ 每日新闻摘要          │
│ 2025-10-27 10:05    │ +200   │ 退款     │ 任务失败自动退款      │
│ 2025-10-27 11:00    │ -50    │ 数据收集 │ RSS订阅源执行         │
│ 2025-10-27 12:00    │ -20    │ 问答     │ 知识库问答            │
│ 2025-10-27 14:00    │ +10000 │ 兑换码   │ 充值码：ABC123        │
└─────────────────────┴────────┴──────────┴───────────────────────┘

用户当前余额：100 积分

情况 1：单个任务
- 预估成本：80 积分
- 检查结果：余额充足 ✅
- 操作：允许提交

情况 2：并发任务
- 用户同时提交 2 个任务，每个 60 积分
- 事务 A：扣除 60 积分 → 余额 40 → 提交成功
- 事务 B：尝试扣除 60 积分 → 余额不足 → 回滚
- 结果：只有 1 个任务成功，避免超支 ✅

情况 3：实际成本超出预估
- 预估成本：100 积分
- 实际成本：120 积分（LLM token 超出预估）
- 处理：任务失败 + 退款 100 积分
- 提示：请充值后重试