box-nestjs-monorepo/prisma/mongo-stats/schema/events.prisma

model AdClickEvents {
  id           String  @id @map("_id") @default(auto()) @db.ObjectId

  uid          String                          // 设备码（from JWT / device）
  adId         String  @db.ObjectId            // 广告 ID
  adsModuleId  String  @db.ObjectId            // 广告模块 ID
  channelId    String  @db.ObjectId            // 渠道 ID
  scene        String                          // 业务场景（页面/流）
  slot         String                          // 广告位
  adType       String                          // 广告类型 (BANNER/STARTUP/...)

  clickedAt    BigInt                          // 点击时间 (epoch)
  ip           String                          // 点击 IP
  userAgent    String                          // UA
  appVersion   String                          // 客户端版本
  os           String                          // iOS / Android / Web
  countryCode  String?                         // 国家码 (optional)
  city         String?                         // 城市 (optional)

  createAt     BigInt                          // 记录创建时间
  updateAt     BigInt                          // 记录更新时间

  // Query helpers
  // 1. 查某广告的点击列表
  @@index([adId, clickedAt])
  // 2. 查某设备的点击轨迹
  @@index([uid, clickedAt])
  // 3. 按渠道/模块聚合
  @@index([channelId, clickedAt])
  @@index([adsModuleId, clickedAt])
  // 4. 按广告类型/时间分析
  @@index([adType, clickedAt])
  // 5. 全局按时间片
  @@index([clickedAt])

  @@map("adClickEvents")
}

model VideoClickEvents {
  id          String  @id @map("_id") @default(auto()) @db.ObjectId

  uid         String                          // 设备码
  videoId     String  @db.ObjectId            // 视频 ID
  channelId   String  @db.ObjectId            // 渠道 ID
  categoryId  String? @db.ObjectId            // 分类 ID (optional)
  scene       String                          // 业务场景

  clickedAt   BigInt                          // 点击时间 (epoch)
  ip          String                          // 点击 IP
  userAgent   String                          // UA
  appVersion  String                          // 客户端版本
  os          String                          // iOS / Android / Web
  countryCode String?                         // 国家码 (optional)
  city        String?                         // 城市 (optional)

  createAt    BigInt                          // 记录创建时间
  updateAt    BigInt                          // 记录更新时间

  // Query helpers
  // 1. 查某视频的点击
  @@index([videoId, clickedAt])
  // 2. 查设备点击
  @@index([uid, clickedAt])
  // 3. 按渠道/分类
  @@index([channelId, clickedAt])
  @@index([categoryId, clickedAt])
  // 4. 全局时间窗口
  @@index([clickedAt])

  @@map("videoClickEvents")
}

model AdImpressionEvents {
  id                String  @id @map("_id") @default(auto()) @db.ObjectId

  uid               String                          // 设备码
  adId              String  @db.ObjectId            // 广告 ID
  adsModuleId       String  @db.ObjectId            // 广告模块 ID
  channelId         String  @db.ObjectId            // 渠道 ID
  scene             String                          // 业务场景（页面/流）
  slot              String                          // 广告位
  adType            String                          // 广告类型 (BANNER/STARTUP/...)

  impressionAt      BigInt                          // 曝光时间 (epoch)
  visibleDurationMs BigInt?                         // 可见时长（毫秒，optional）
  ip                String                          // IP
  userAgent         String                          // UA
  appVersion        String                          // 客户端版本
  os                String                          // iOS / Android / Web
  countryCode       String?                         // 国家码 (optional)
  city              String?                         // 城市 (optional)

  createAt          BigInt                          // 记录创建时间
  updateAt          BigInt                          // 记录更新时间

  // Query helpers
  // 1. 按广告查看曝光
  @@index([adId, impressionAt])
  // 2. 设备曝光轨迹
  @@index([uid, impressionAt])
  // 3. 渠道/模块/广告位
  @@index([channelId, impressionAt])
  @@index([adsModuleId, impressionAt])
  @@index([slot, impressionAt])
  // 4. 按广告类型
  @@index([adType, impressionAt])
  // 5. 时间片
  @@index([impressionAt])

  @@map("adImpressionEvents")
}

model ProcessedMessage {
  id          String @id @map("_id") @default(auto()) @db.ObjectId
  messageId   String @unique                         // 去重用的唯一消息 ID
  eventType   String                                 // 事件类型（如 stats.ad.click）
  processedAt BigInt                                 // 处理时间（epoch ms）
  createdAt   BigInt                                 // 创建时间（epoch ms）

  @@map("processedMessages")
}

model VideoGlobalStats {
  id                  String @id @map("_id") @default(auto()) @db.ObjectId
  videoId             String @unique @db.ObjectId    // 视频 ID（唯一）
  impressions         BigInt @default(0)             // 曝光总数
  clicks              BigInt @default(0)             // 点击总数
  firstSeenAt         BigInt                         // 首次出现时间 (epoch)
  lastSeenAt          BigInt                         // 最后活跃时间 (epoch)
  computedCtr         Float  @default(0)             // 计算的点击率 (clicks/impressions)
  computedPopularity  Float  @default(0)             // 计算的热度得分
  computedRecency     Float  @default(0)             // 计算的时效性得分
  computedScore       Float  @default(0)             // 综合得分
  createAt            BigInt                         // 创建时间 (epoch)
  updateAt            BigInt                         // 更新时间 (epoch)

  // Query helpers
  // 1. videoId has unique index via @unique
  // 2. 按综合得分排序（热门视频推荐）
  @@index([computedScore])
  // 3. 按时效性排序（最新热点）
  @@index([computedRecency, computedScore])
  // 4. 按点击率排序（高转化内容）
  @@index([computedCtr])
  // 5. 按最后活跃时间排序
  @@index([lastSeenAt])

  @@map("videoGlobalStats")
}

model AdsGlobalStats {
  id                  String @id @map("_id") @default(auto()) @db.ObjectId
  adId                String @unique @db.ObjectId    // 广告 ID（唯一）
  impressions         BigInt @default(0)             // 曝光总数
  clicks              BigInt @default(0)             // 点击总数
  firstSeenAt         BigInt                         // 首次出现时间 (epoch)
  lastSeenAt          BigInt                         // 最后活跃时间 (epoch)
  computedCtr         Float  @default(0)             // 计算的点击率 (clicks/impressions)
  computedPopularity  Float  @default(0)             // 计算的热度得分
  computedRecency     Float  @default(0)             // 计算的时效性得分
  computedScore       Float  @default(0)             // 综合得分
  createAt            BigInt                         // 创建时间 (epoch)
  updateAt            BigInt                         // 更新时间 (epoch)

  // Query helpers
  // 1. adId has unique index via @unique
  // 2. 按综合得分排序（热门广告推荐）
  @@index([computedScore])
  // 3. 按时效性排序（最新热点）
  @@index([computedRecency, computedScore])
  // 4. 按点击率排序（高转化广告）
  @@index([computedCtr])
  // 5. 按最后活跃时间排序
  @@index([lastSeenAt])

  @@map("adsGlobalStats")
}