系统架构实战：短剧平台中的多维权益分层与计费流转设计

// 剧集权限配置的数据模型抽象
type EpisodeConfig struct {
    EpisodeID   uint64 `json:"episode_id"`
    DramaID     uint64 `json:"drama_id"`
    EpisodeNum  int    `json:"episode_num"`
    IsFree      bool   `json:"is_free"`       // 是否为免费集
    RequireVIP  bool   `json:"require_vip"`   // 是否要求VIP权限
    UnlockPrice int    `json:"unlock_price"`  // 虚拟币解锁单价
}

// 多级鉴权网关逻辑
func CheckWatchPermission(ctx context.Context, userID uint64, episode EpisodeConfig) bool {
    // 1. 第一级放行：免费集直接放行
    if episode.IsFree {
        return true
    }
    
    // 2. 第二级放行：校验用户是否在VIP有效期内
    if episode.RequireVIP && IsUserVIPValid(ctx, userID) {
        return true
    }
    
    // 3. 第三级放行：校验是否已使用虚拟币购买过本集
    if HasPurchasedEpisode(ctx, userID, episode.EpisodeID) {
        return true
    }
    
    // 无权限，抛出拦截异常
    return false
}

CREATE TABLE `virtual_currency_ledger` (
  `id` BIGINT UNSIGNED NOT NULL AUTO_INCREMENT,
  `user_id` BIGINT UNSIGNED NOT NULL COMMENT '用户ID',
  `action_type` TINYINT NOT NULL COMMENT '1:充值 2:赠送 3:解锁单集 4:广告奖励',
  `amount` INT NOT NULL COMMENT '变动数量，消耗为负数',
  `balance_after` INT NOT NULL COMMENT '变动后的绝对余额',
  `related_biz_id` VARCHAR(64) DEFAULT NULL COMMENT '关联的订单或剧集ID，用于追溯',
  `created_at` TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
  PRIMARY KEY (`id`),
  INDEX `idx_user_action` (`user_id`, `action_type`)
) ENGINE=InnoDB COMMENT='虚拟资产流水账本';

// 广告回调服务端校验逻辑
func HandleRewardedAdCallback(req *AdCallbackRequest) error {
    // 1. 验证第三方广告平台传递的签名防篡改
    if !VerifyAdSignature(req.Sign, req.TransID, config.AdSecret) {
        return errors.New("非法伪造的回调请求")
    }
    
    // 2. 利用 Redis 实现分布式锁，防止同一 TransID 重复下发奖励
    lockKey := "ad_reward_lock:" + req.TransID
    if !redisClient.SetNX(ctx, lockKey, 1, time.Hour).Val() {
        return errors.New("该广告订单已处理")
    }
    
    // 3. 执行资产发放或剧集解锁事务...
    return DispatchAdReward(req.UserID, req.RewardType)
}

// 统一播放地址下发网关
func GenerateSignedPlayURL(ctx context.Context, userID uint64, episodeID uint64) (string, error) {
    // 1. 查询剧集配置与用户权限（复用上文的 CheckWatchPermission）
    episodeConf := GetEpisodeConfig(episodeID)
    if !CheckWatchPermission(ctx, userID, episodeConf) {
        return "", errors.New("权限不足，请先解锁或开通VIP")
    }
    
    // 2. 鉴权通过，生成带有 5 分钟有效期的 CDN 防盗链 URL
    rawVideoPath := GetVideoStoragePath(episodeID)
    signedURL := signVideoURL(rawVideoPath, time.Now().Add(5 * time.Minute).Unix(), config.CdnKey)
    
    return signedURL, nil
}