当前位置：首页 > wzjs >正文

滨州市建设局网站个人网站模板免费下载

wzjs 2025/9/2 6:46:14

滨州市建设局网站,个人网站模板免费下载,宿迁优化推广,本周新闻热点10条【Easylive】项目常见问题解答（自用&持续更新中…） 汇总版 saveVideoInfo 方法是一个用于保存视频信息及其关联文件的复杂业务方法，主要处理视频信息的创建、更新以及关联文件的管理。以下是详细解析： 1. 方法概述 Overrid…

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

saveVideoInfo 方法是一个用于保存视频信息及其关联文件的复杂业务方法，主要处理视频信息的创建、更新以及关联文件的管理。以下是详细解析：

1. 方法概述

@Override
@Transactional(rollbackFor = Exception.class)
public void saveVideoInfo(VideoInfoPost videoInfoPost, List<VideoInfoFilePost> uploadFileList)

• 事务注解：@Transactional(rollbackFor = Exception.class) 表示该方法在一个事务中执行，遇到任何异常都会回滚
• 参数：
• videoInfoPost：视频主信息
• uploadFileList：视频关联的文件列表

2. 分P数校验

if (uploadFileList.size() > redisComponent.getSysSettingDto().getVideoPCount()) {throw new BusinessException(ResponseCodeEnum.CODE_600);
}

• 功能：检查上传的视频分P数是否超过系统设置的最大限制
• 实现：
• 从Redis获取系统设置
• 比较上传文件列表大小与系统允许的最大分P数
• 超过则抛出业务异常

3. 视频ID存在性校验

if(!StringTools.isEmpty(videoInfoPost.getVideoId())){VideoInfoPost videoInfoPostDb = this.videoInfoPostMapper.selectByVideoId(videoInfoPost.getVideoId());if (videoInfoPostDb == null) {throw new BusinessException(ResponseCodeEnum.CODE_600);}if (ArrayUtils.contains(new Integer[]{VideoStatusEnum.STATUS0.getStatus(), VideoStatusEnum.STATUS2.getStatus()}, videoInfoPostDb.getStatus())) {throw new BusinessException(ResponseCodeEnum.CODE_600);}
}

• 功能：当videoId不为空时，检查视频是否存在及状态是否允许修改
• 逻辑：

1. 查询数据库中是否存在该videoId对应的记录
2. 不存在则抛出异常
3. 检查视频状态是否为"审核中"或"待审核"，是则不允许修改

4. 初始化变量

Date curDate = new Date();
String videoId = videoInfoPost.getVideoId();
List<VideoInfoFilePost> deleteFileList = new ArrayList<>();
List<VideoInfoFilePost> addFileList = uploadFileList;

• 变量说明：
• curDate：当前时间，用于设置创建/更新时间
• videoId：视频ID
• deleteFileList：待删除的文件列表
• addFileList：待添加的文件列表（初始化为全部上传文件）

5. 新增视频逻辑

if (StringTools.isEmpty(videoId)) {videoId = StringTools.getRandomString(Constants.LENGTH_10);videoInfoPost.setVideoId(videoId);videoInfoPost.setCreateTime(curDate);videoInfoPost.setLastUpdateTime(curDate);videoInfoPost.setStatus(VideoStatusEnum.STATUS0.getStatus());this.videoInfoPostMapper.insert(videoInfoPost);
}

• 条件：videoId为空表示新增视频
• 操作：

1. 生成随机videoId
2. 设置创建时间、更新时间
3. 设置初始状态为"待审核"
4. 插入数据库

6. 更新视频逻辑

else {// 查询数据库中的文件列表VideoInfoFilePostQuery fileQuery = new VideoInfoFilePostQuery();fileQuery.setVideoId(videoId);fileQuery.setUserId(videoInfoPost.getUserId());List<VideoInfoFilePost> dbInfoFileList = this.videoInfoFilePostMapper.selectList(fileQuery);// 将上传文件列表转为Map方便查询Map<String, VideoInfoFilePost> uploadFileMap = uploadFileList.stream().collect(Collectors.toMap(item -> item.getUploadId(), Function.identity(), (data1, data2) -> data2));Boolean updateFileName = false;// 比较数据库文件和上传文件for(VideoInfoFilePost fileInfo : dbInfoFileList){VideoInfoFilePost updateFile = uploadFileMap.get(fileInfo.getUploadId());if (updateFile == null) {deleteFileList.add(fileInfo);} else if (!updateFile.getFileName().equals(fileInfo.getFileName())) {updateFileName = true;}}// 筛选新增文件addFileList = uploadFileList.stream().filter(item->item.getFileId()==null).collect(Collectors.toList());// 更新视频信息videoInfoPost.setLastUpdateTime(curDate);Boolean changeVideoInfo = this.changeVideoInfo(videoInfoPost);// 设置视频状态if (addFileList != null && !addFileList.isEmpty()) {videoInfoPost.setStatus(VideoStatusEnum.STATUS0.getStatus());} else if (changeVideoInfo || updateFileName) {videoInfoPost.setStatus(VideoStatusEnum.STATUS2.getStatus());}this.videoInfoPostMapper.updateByVideoId(videoInfoPost, videoInfoPost.getVideoId());
}

• 核心逻辑：

1. 查询数据库中该视频已有的文件列表
2. 比较数据库文件和上传文件：◦ 数据库有但上传没有 → 加入删除列表◦ 文件名被修改 → 标记为需要更新
3. 筛选出新增文件（fileId为null）
4. 根据情况设置视频状态：◦ 有新增文件 → 待审核◦ 视频信息或文件名被修改 → 待审核
5. 更新视频主信息

7. 处理待删除文件

if (!deleteFileList.isEmpty()) {List<String> delFileList = deleteFileList.stream().map(item->item.getFileId()).collect(Collectors.toList());this.videoInfoFilePostMapper.deleteBatchByFileId(delFileList, videoInfoPost.getUserId());List<String> delFilePathList = deleteFileList.stream().map(item->item.getFilePath()).collect(Collectors.toList());redisComponent.addFile2DelQueue(videoId, delFilePathList);
}

• 操作：

1. 从数据库批量删除文件记录
2. 将要删除的文件路径加入Redis删除队列（异步删除实际文件）

8. 处理文件索引和新增文件

Integer index = 1;
for (VideoInfoFilePost videoInfoFile : uploadFileList) {videoInfoFile.setFileIndex(index++);videoInfoFile.setVideoId(videoId);videoInfoFile.setUserId(videoInfoPost.getUserId());if (videoInfoFile.getFileId() == null) {videoInfoFile.setFileId(StringTools.getRandomString(Constants.LENGTH_20));videoInfoFile.setUpdateType(VideoFileUpdateTypeEnum.UPDATE.getStatus());videoInfoFile.setTransferResult(VideoFileTransferResultEnum.TRANSFER.getStatus());}
}
this.videoInfoFilePostMapper.insertOrUpdateBatch(uploadFileList);

• 操作：

1. 为每个文件设置索引（排序）
2. 设置视频ID和用户ID
3. 对新文件（fileId为null）：◦ 生成随机fileId◦ 设置更新类型为"更新"◦ 设置传输结果为"待传输"
4. 批量插入或更新文件记录

9. 处理新增文件传输

if (addFileList != null && !addFileList.isEmpty()) {for (VideoInfoFilePost file : addFileList) {file.setUserId(videoInfoPost.getUserId());file.setVideoId(videoId);}redisComponent.addFile2TransferQueue(addFileList);
}