架构防腐：流媒体短剧后台高危批量操作的防御与 RBAC 权限边界设计

func BatchDeleteDramas(ctx context.Context, dramaIDs []uint64) error {
    // 1. 安全边界：限制单次批量操作的数量上限，防止锁表与内存溢出
    if len(dramaIDs) == 0 || len(dramaIDs) > 50 {
        return errors.New("批量操作数量必须在1~50之间")
    }

    return db.Transaction(func(tx *gorm.DB) error {
        // 2. 严禁物理删除，执行软删除（更新 deleted_at 时间戳）
        // GORM 在开启 Soft Delete 时，Delete 动作会自动转为 UPDATE
        if err := tx.Where("id IN ?", dramaIDs).Delete(&Drama{}).Error; err != nil {
            return err
        }
        
        // 3. 级联软删除：同步下线关联的独立集数，但不清除用户的购买账本
        if err := tx.Where("drama_id IN ?", dramaIDs).Delete(&Episode{}).Error; err != nil {
            return err
        }
        
        return nil
    })
}

func CheckRBACPermission(requiredResource string, requiredAction string) gin.HandlerFunc {
    return func(c *gin.Context) {
        // 从 JWT 中解析出当前管理员的 RoleID
        roleID := c.MustGet("admin_role_id").(uint64)
        
        // 超级管理员直接放行
        if roleID == RoleSuperAdmin {
            c.Next()
            return
        }

        // 校验当前角色是否被授权了目标资源的特定操作 (如: Resource="finance", Action="write")
        hasPermission := rbacService.Enforce(roleID, requiredResource, requiredAction)
        if !hasPermission {
            c.JSON(http.StatusForbidden, gin.H{
                "code": 403, 
                "msg": "越权拦截：您所在的岗位无权执行该操作",
            })
            c.Abort()
            return
        }
        c.Next()
    }
}

func DemoEnvironmentProtection() gin.HandlerFunc {
    return func(c *gin.Context) {
        // 判断当前登录的管理员是否为受限的演示账号
        isDemoAccount := c.GetBool("is_demo_account")
        
        // 演示账号仅允许发起 GET/HEAD 等安全请求
        if isDemoAccount && c.Request.Method != http.MethodGet && c.Request.Method != http.MethodHead {
            c.JSON(http.StatusForbidden, gin.H{
                "code": 403, 
                "msg": "受限模式：演示环境仅支持浏览，禁止新增、修改或删除操作",
            })
            c.Abort() // 硬拦截写操作
            return
        }
        
        c.Next()
    }
}

func UpdatePaymentConfig(ctx context.Context, adminID uint64, newConfig PaymentConfig, verificationCode string) error {
    // 1. 高危操作必须进行实时的二次安全校验 (如通过 Google Authenticator 校验动态码)
    if !totpService.Verify(adminID, verificationCode) {
        return errors.New("高危操作：二次安全校验失败")
    }

    // 2. 变更资产/支付配置前，记录变更前的配置快照
    oldConfig := GetCurrentPaymentConfig()
    
    // 3. 执行配置更新
    if err := savePaymentConfig(newConfig); err != nil {
        return err
    }
    
    // 4. 强制落盘系统级高危操作日志，便于追责与快速回滚
    SysLogService.Record(adminID, "UPDATE_PAY_CONFIG", oldConfig, newConfig)
    return nil
}