wanghongbo

垫片上传问题修改

@@ -137,7 +137,7 @@ public class BackupMaterialServiceImpl extends ServiceImpl<BackupMaterialMapper, @@ -137,7 +137,7 @@ public class BackupMaterialServiceImpl extends ServiceImpl<BackupMaterialMapper,
137 //对应垫片任务切源(转码平台演示环境已挂载统一存储),请求转码平台修改垫片任务直播源 137 //对应垫片任务切源(转码平台演示环境已挂载统一存储),请求转码平台修改垫片任务直播源
138 changeChannelSource(streamTask.getTaskId(), destFilePath); 138 changeChannelSource(streamTask.getTaskId(), destFilePath);
139 //判断是否需要修改当前播出流的垫片 139 //判断是否需要修改当前播出流的垫片
140 - if("1".equals(backupConfig.getBackupOrder())){ 140 + if("1".equals(backupConfig.getBackupStatus())){
141 //切换播出流垫片(主、备) 141 //切换播出流垫片(主、备)
142 LambdaQueryWrapper<StreamTask> playWrapper = new LambdaQueryWrapper<>(); 142 LambdaQueryWrapper<StreamTask> playWrapper = new LambdaQueryWrapper<>();
143 playWrapper.eq(StreamTask::getRoomId,backupUploadVo.getRoomId()); 143 playWrapper.eq(StreamTask::getRoomId,backupUploadVo.getRoomId());
@@ -153,6 +153,11 @@ public class BackupMaterialServiceImpl extends ServiceImpl<BackupMaterialMapper, @@ -153,6 +153,11 @@ public class BackupMaterialServiceImpl extends ServiceImpl<BackupMaterialMapper,
153 return ResultBean.ok("上传成功"); 153 return ResultBean.ok("上传成功");
154 } 154 }
155 155
  156 + /**
  157 + * 修改转码任务垫片
  158 + * @param taskId
  159 + * @param destFilePath
  160 + */
156 private void changeBackup(String taskId, String destFilePath) { 161 private void changeBackup(String taskId, String destFilePath) {
157 Map<String, Object> paramsMap = new HashMap<>(); 162 Map<String, Object> paramsMap = new HashMap<>();
158 paramsMap.put("taskId", taskId); 163 paramsMap.put("taskId", taskId);