This commit is contained in:
abu 2025-04-03 12:15:27 +08:00
parent ef5823cd43
commit 343dcbeb54

View File

@ -58,6 +58,8 @@ public class VlogController extends BaseInfoProperties {
(List<Map<String, Object>>) procedureStateChangeEvent.get("MediaProcessResultSet");
if (mediaProcessResultSet != null) {
String coverUrl=null; // 首帧图
String transVdUrl=null; // 转码后的视频地址
for (Map<String, Object> processResult : mediaProcessResultSet) {
String type = (String) processResult.get("Type");
if ("CoverBySnapshot".equals(type)) {
@ -65,12 +67,20 @@ public class VlogController extends BaseInfoProperties {
Map<String, Object> coverBySnapshotTask =
(Map<String, Object>) processResult.get("CoverBySnapshotTask");
Map<String, Object> output = (Map<String, Object>) coverBySnapshotTask.get("Output");
String coverUrl = (String) output.get("CoverUrl"); // 正确获取 CoverUrl
log.info("任务流 [截取首帧] 完成, FileId: {}, 封面图 URL: {}", fileId, coverUrl);
// TODO: 更新数据库存储首帧图,设置云端地址删除本地视频文件
vlogService.updateVlogFirstImg(fileId,coverUrl,fileUrl);
coverUrl = (String) output.get("CoverUrl"); // 正确获取 CoverUrl
}
if("Transcode".equals(type)){
// 拿到output中的url
Map<String, Object> TranscodeTask =
(Map<String, Object>) processResult.get("TranscodeTask");
Map<String, Object> output = (Map<String, Object>) TranscodeTask.get("Output");
transVdUrl = (String) output.get("Url");
}
}
log.info("任务流 [截取首帧,视频转码,添加水印] 完成, FileId: {}, 封面图 URL: {},视频地址: {}", fileId, coverUrl,transVdUrl);
// TODO: 更新数据库存储首帧图,设置云端地址删除本地视频文件
vlogService.updateVlogFirstImg(fileId,coverUrl,transVdUrl);
} else {
log.warn("MediaProcessResultSet 为空,回调数据: {}", callbackData);
}