【Easylive】auditVideo方法详细解析

【Easylive】项目常见问题解答（自用&持续更新中…） 汇总版

auditVideo 方法是视频审核的核心方法，负责处理视频审核状态的变更、用户积分奖励、数据同步以及文件清理等操作。下面我将从功能、流程、设计思路等方面进行全面解析。

1. 方法概述

@Override
@Transactional(rollbackFor = Exception.class)
public void auditVideo(String videoId, Integer status, String reason) {// 方法实现
}

功能：处理视频审核流程，包括：

1. 验证审核状态合法性
2. 更新视频审核状态
3. 处理审核通过/不通过的逻辑分支
4. 用户积分奖励（首次发布）
5. 数据同步到正式表
6. 清理待删除文件
7. 同步数据到搜索引擎

参数：
• videoId：视频唯一标识
• status：目标审核状态
• reason：审核原因（如不通过原因）

事务控制：@Transactional(rollbackFor = Exception.class) 确保方法内所有数据库操作要么全部成功，要么全部回滚

2. 方法流程详解

2.1 状态验证

VideoStatusEnum videoStatusEnum = VideoStatusEnum.getByStatus(status);
if (videoStatusEnum == null) {throw new BusinessException(ResponseCodeEnum.CODE_600);
}

作用：验证传入的审核状态是否合法

关键点：
• 使用枚举VideoStatusEnum管理所有可能的视频状态
• 非法状态直接抛出业务异常

2.2 更新视频状态（带条件）

VideoInfoPost videoInfoPost = new VideoInfoPost();
videoInfoPost.setStatus(status);VideoInfoPostQuery videoInfoPostQuery = new VideoInfoPostQuery();
videoInfoPostQuery.setStatus(VideoStatusEnum.STATUS2.getStatus());
videoInfoPostQuery.setVideoId(videoId);
Integer auditCount = this.videoInfoPostMapper.updateByParam(videoInfoPost, videoInfoPostQuery);if (auditCount == 0) {throw new BusinessException("审核失败，请稍后重试");
}

作用：将视频从"待审核"状态更新为目标审核状态

设计亮点：

1. 乐观锁机制：
   • 更新条件包含当前状态(STATUS2表示待审核)
   • 防止并发修改导致状态混乱
   • 如果影响行数为0，说明视频不满足更新条件（可能已被其他审核员处理）

2. 安全更新：
   • 确保只有处于"待审核"状态的视频才能被审核
   • 避免重复审核或状态跳跃

2.3 更新关联文件状态

VideoInfoFilePost videoInfoFilePost = new VideoInfoFilePost();
videoInfoFilePost.setUpdateType(VideoFileUpdateTypeEnum.NO_UPDATE.getStatus());VideoInfoFilePostQuery filePostQuery = new VideoInfoFilePostQuery();
filePostQuery.setVideoId(videoId);
this.videoInfoFilePostMapper.updateByParam(videoInfoFilePost, filePostQuery);

作用：将所有关联文件的updateType标记为"无需更新"

业务意义：
• 表示这些文件已经完成审核流程
• 后续可能用于区分哪些文件需要重新处理

2.4 处理审核不通过情况

if (VideoStatusEnum.STATUS4 == videoStatusEnum) { // 审核不通过return;
}

逻辑：
• 如果审核状态为"不通过"(STATUS4)，直接返回
• 不执行后续的积分奖励、数据同步等操作

2.5 首次发布奖励积分

VideoInfoPost infoPost = this.videoInfoPostMapper.selectByVideoId(videoId);
VideoInfo dbVideoInfo = this.videoInfoMapper.selectByVideoId(videoId);
if (dbVideoInfo == null) {SysSettingDto sysSettingDto = redisComponent.getSysSettingDto();userInfoMapper.updateCoinCountInfo(infoPost.getUserId(), sysSettingDto.getPostVideoCoinCount());
}

业务逻辑：

1. 检查视频是否首次发布（正式表中不存在记录）
2. 如果是首次发布：
   • 从系统设置获取奖励积分数
   • 给视频作者增加相应积分

设计考虑：
• 奖励机制鼓励用户发布内容
• 通过dbVideoInfo是否存在判断是否首次发布，避免重复奖励
• 积分数量配置在系统设置中，便于灵活调整

2.6 同步数据到正式表

// 将发布信息复制到正式表
VideoInfo videoInfo = CopyTools.copy(infoPost, VideoInfo.class);
this.videoInfoMapper.insertOrUpdate(videoInfo);// 先删除旧文件信息
VideoInfoFileQuery videoInfoFileQuery = new VideoInfoFileQuery();
videoInfoFileQuery.setVideoId(videoId);
this.videoInfoFileMapper.deleteByParam(videoInfoFileQuery);// 从发布表查询并插入到正式表
VideoInfoFilePostQuery videoInfoFilePostQuery = new VideoInfoFilePostQuery();
videoInfoFilePostQuery.setVideoId(videoId);
List<VideoInfoFilePost> videoInfoFilePostList = this.videoInfoFilePostMapper.selectList(videoInfoFilePostQuery);List<VideoInfoFile> videoInfoFileList = CopyTools.copyList(videoInfoFilePostList, VideoInfoFile.class);
this.videoInfoFileMapper.insertBatch(videoInfoFileList);

数据同步流程：

1. 主表同步：将发布表(VideoInfoPost)数据拷贝到正式表(VideoInfo)
2. 文件表同步：
   • 先删除正式文件表中该视频的所有记录
   • 从发布文件表查询所有相关文件
   • 批量插入到正式文件表

技术亮点：
• 使用CopyTools实现对象深拷贝，隔离两套表结构
• 先删除后插入确保数据一致性
• 批量操作提高性能

2.7 清理待删除文件

List<String> filePathList = redisComponent.getDelFileList(videoId);
if (filePathList != null) {for (String path : filePathList) {File file = new File(appConfig.getProjectFolder() + Constants.FILE_FOLDER + path);if (file.exists()) {try {FileUtils.deleteDirectory(file);} catch (IOException e) {log.error("删除文件失败", e);}}}
}
redisComponent.cleanDelFileList(videoId);

作用：清理被标记为待删除的文件

实现机制：

1. 从Redis获取该视频的待删除文件列表
2. 遍历列表删除实际文件
3. 清理Redis中的记录

业务场景：
• 用户编辑视频时删除的旧文件
• 转码过程中生成的临时文件
• 审核通过后不再需要的中间文件

2.8 同步到搜索引擎

esSearchComponent.saveDoc(videoInfo);

作用：将视频信息索引到Elasticsearch

业务价值：
• 使视频可被搜索
• 支持复杂的搜索条件和排序

3. 状态机设计

从代码中推断出的视频状态流转：

状态枚举	状态含义	可流转至
STATUS0	待处理/初始状态	STATUS2
STATUS2	待审核	STATUS3/STATUS4
STATUS3	审核通过	-
STATUS4	审核不通过	-

关键规则：

1. 只有STATUS2(待审核)状态的视频才能被审核
2. 审核后变为STATUS3(通过)或STATUS4(不通过)
3. 状态变更采用乐观锁控制

4. 数据表设计分析

从方法中可以看出系统至少包含以下表：

1. 发布表（待审核数据）：
   • video_info_post：视频主信息
   • video_info_file_post：视频文件信息

2. 正式表（已审核数据）：
   • video_info：视频主信息
   • video_info_file：视频文件信息

3. 用户表：
   • user_info：存储用户积分

设计优势：
• 发布与正式数据隔离，避免审核中数据污染生产环境
• 两套表结构相同，便于使用工具类拷贝
• 审核通过后才同步到正式表，保证数据质量

5. 异常处理设计

方法中体现的异常处理策略：

1. 业务异常：
   • 非法状态参数：立即抛出
   • 更新行数为0：视为并发冲突，提示重试

2. 系统异常：
   • 文件删除失败：记录日志但不中断流程
   • 其他异常由事务注解处理，自动回滚

3. 事务控制：
   • 方法级事务保证数据一致性
   • 非关键操作（如文件删除）在事务外处理

6. 潜在优化建议

1. 审核日志：
   • 当前未记录审核人和审核原因，建议增加审计日志

2. 性能优化：
   • 大批量文件删除可考虑异步化
   • Elasticsearch同步可加入队列异步处理

3. 状态扩展：
   • 可增加"审核中"状态，避免长时间审核导致的并发问题

4. 文件清理：
   • 增加删除重试机制，提高文件清理成功率

5. 配置灵活性：
   • 审核通过后的操作（如积分奖励）可通过策略模式实现动态配置

7. 总结

auditVideo 方法是一个完整的视频审核解决方案，具有以下特点：

1. 严谨的状态管理：通过枚举和乐观锁确保状态流转安全
2. 数据隔离设计：发布数据与正式数据物理分离
3. 完整的业务流程：涵盖状态更新、积分奖励、数据同步、文件清理等
4. 良好的异常处理：区分业务异常和系统异常，关键操作事务保障
5. 可扩展性：模块化设计便于新增审核后操作

该方法体现了生产级审核系统的核心设计思想，兼顾了功能性、安全性和可维护性。