用户 CRUD 操作

// 基础用户
const basicUser = {
  name: "测试用户",
  note: "这是一个测试账号",
  rpm: 100,
  dailyQuota: 100,
  isEnabled: true,
};

// 带过期时间的临时用户
const tempUser = {
  name: "临时用户",
  note: "30天试用账号",
  rpm: 60,
  dailyQuota: 50,
  isEnabled: true,
  expiresAt: new Date("2026-01-01T23:59:59.999Z"),
};

// 完整配置的高级用户
const advancedUser = {
  name: "高级用户",
  note: "团队负责人账号",
  providerGroup: "premium,backup",
  tags: ["team-lead", "priority"],
  rpm: 1000,
  dailyQuota: 500,
  limit5hUsd: 100,
  limitWeeklyUsd: 2000,
  limitMonthlyUsd: 8000,
  limitTotalUsd: 50000,
  limitConcurrentSessions: 10,
  dailyResetMode: "fixed",
  dailyResetTime: "00:00",
  isEnabled: true,
  allowedModels: ["claude-3-5-sonnet", "gpt-4"],
};

{
  ok: true,
  data: {
    user: {
      id: 123,
      name: "测试用户",
      role: "user",
      // ... 其他字段
    },
    defaultKey: {
      id: 456,
      name: "default",
      key: "sk-abc123...",  // 仅此时返回完整密钥
    }
  }
}

// 获取用户列表（带关联数据）
const users = await getUsers();

const result = await getUsersBatch({
  cursor: 0,           // 起始位置
  limit: 50,           // 每页数量
  searchTerm: "test",  // 搜索关键词
  tagFilters: ["vip"], // 标签筛选
  keyGroupFilters: ["group1"], // 密钥分组筛选
  statusFilter: "active", // 状态筛选
  sortBy: "createdAt", // 排序字段
  sortOrder: "asc",    // 排序方向
});

// 返回结果
{
  users: [...],       // 用户列表
  nextCursor: 50,     // 下一页游标
  hasMore: true,      // 是否还有更多
}

// 只更新名称
await editUser(123, { name: "新名称" });

// 更新多个字段
await editUser(123, {
  note: "更新后的备注",
  tags: ["new-tag"],
  dailyQuota: 200,
});

{
  "ok": false,
  "error": "权限不足: rpm, dailyQuota",
  "errorCode": "PERMISSION_DENIED"
}

const result = await batchUpdateUsers({
  userIds: [1, 2, 3, 4, 5],
  updates: {
    note: "批量更新的备注",
    tags: ["batch-updated"],
    dailyQuota: 100,
  },
});

// 返回结果
{
  ok: true,
  data: {
    requestedCount: 5,
    updatedCount: 5,
    updatedIds: [1, 2, 3, 4, 5],
  }
}

await removeUser(123);

// 禁用用户
await toggleUserEnabled(123, false);

// 启用用户
await toggleUserEnabled(123, true);

// 仅更新过期时间
await renewUser(123, {
  expiresAt: "2026-12-31T23:59:59",
});

// 同时启用用户
await renewUser(123, {
  expiresAt: "2026-12-31T23:59:59",
  enableUser: true,
});

// 基础限额（RPM + 日消费）
const usage = await getUserLimitUsage(123);

// 返回结果
{
  ok: true,
  data: {
    rpm: {
      current: 45,        // 当前分钟请求数
      limit: 100,         // 限制值
      window: "per_minute",
    },
    dailyCost: {
      current: 12.50,     // 今日消费
      limit: 100,         // 日限额
      resetAt: Date,      // 下次重置时间
    },
  }
}

const allUsage = await getUserAllLimitUsage(123);

// 返回结果
{
  ok: true,
  data: {
    limit5h: { usage: 8.50, limit: 20 },
    limitDaily: { usage: 12.50, limit: 100 },
    limitWeekly: { usage: 45.00, limit: 300 },
    limitMonthly: { usage: 120.00, limit: 1000 },
    limitTotal: { usage: 500.00, limit: 5000 },
  }
}

export const users = pgTable('users', {
  id: serial('id').primaryKey(),
  name: varchar('name').notNull(),
  description: text('description'),
  role: varchar('role').default('user'),
  rpmLimit: integer('rpm_limit'),
  dailyLimitUsd: numeric('daily_limit_usd', { precision: 10, scale: 2 }),
  providerGroup: varchar('provider_group', { length: 200 }).default('default'),
  tags: jsonb('tags').$type<string[]>().default([]),
  
  // 多时间维度配额
  limit5hUsd: numeric('limit_5h_usd', { precision: 10, scale: 2 }),
  limitWeeklyUsd: numeric('limit_weekly_usd', { precision: 10, scale: 2 }),
  limitMonthlyUsd: numeric('limit_monthly_usd', { precision: 10, scale: 2 }),
  limitTotalUsd: numeric('limit_total_usd', { precision: 10, scale: 2 }),
  limitConcurrentSessions: integer('limit_concurrent_sessions'),
  
  // 每日限额重置配置
  dailyResetMode: dailyResetModeEnum('daily_reset_mode').default('fixed').notNull(),
  dailyResetTime: varchar('daily_reset_time', { length: 5 }).default('00:00').notNull(),
  
  // 状态管理
  isEnabled: boolean('is_enabled').notNull().default(true),
  expiresAt: timestamp('expires_at', { withTimezone: true }),
  
  // 访问限制
  allowedClients: jsonb('allowed_clients').$type<string[]>().default([]),
  allowedModels: jsonb('allowed_models').$type<string[]>().default([]),
  
  // 时间戳
  createdAt: timestamp('created_at', { withTimezone: true }).defaultNow(),
  updatedAt: timestamp('updated_at', { withTimezone: true }).defaultNow(),
  deletedAt: timestamp('deleted_at', { withTimezone: true }),
});

{
  "ok": false,
  "error": "用户名不能为空",
  "errorCode": "INVALID_FORMAT",
  "errorParams": { "field": "name" }
}

const [keysMap, usageMap, statisticsMap] = await Promise.all([
  findKeyListBatch(userIds),
  findKeyUsageTodayBatch(userIds),
  findKeysWithStatisticsBatch(userIds),
]);