wanghongbo

日志输出修改、垫片配置保存垫片路径

@@ -123,6 +123,7 @@ public class BackupMaterialServiceImpl extends ServiceImpl<BackupMaterialMapper, @@ -123,6 +123,7 @@ public class BackupMaterialServiceImpl extends ServiceImpl<BackupMaterialMapper,
123 backupConfig.setBackupId(backupMaterial.getId()); 123 backupConfig.setBackupId(backupMaterial.getId());
124 backupConfig.setBackupOrder(backupUploadVo.getBackupOrder()); 124 backupConfig.setBackupOrder(backupUploadVo.getBackupOrder());
125 backupConfig.setBackupStatus(backupUploadVo.getBackupStatus()); 125 backupConfig.setBackupStatus(backupUploadVo.getBackupStatus());
  126 + backupConfig.setBackupPath(relativePath);
126 backupConfigMapper.insertOrUpdate(backupConfig); 127 backupConfigMapper.insertOrUpdate(backupConfig);
127 128
128 //对应垫片任务切源(转码平台演示环境已挂载统一存储),请求转码平台修改垫片任务直播源 129 //对应垫片任务切源(转码平台演示环境已挂载统一存储),请求转码平台修改垫片任务直播源
@@ -140,22 +140,22 @@ public class RoomOperationServiceImpl implements RoomOperationSerivice { @@ -140,22 +140,22 @@ public class RoomOperationServiceImpl implements RoomOperationSerivice {
140 .header("Content-Type", "application/json") 140 .header("Content-Type", "application/json")
141 .body(JSONUtils.obj2json(paramsMap)).timeout(30000).execute(); 141 .body(JSONUtils.obj2json(paramsMap)).timeout(30000).execute();
142 if (execute.isOk()) { 142 if (execute.isOk()) {
143 - log.info("-->请求转码系统屏蔽接口,url:{},paramsMap:{}",blockStatusUrl,paramsMap); 143 + log.info("-->请求转码系统屏蔽/恢复接口,url:{},paramsMap:{}",blockStatusUrl,paramsMap);
144 String body = execute.body(); 144 String body = execute.body();
145 ResponseData response = JSONUtils.jsonToObject(body, new TypeReference<ResponseData>() { 145 ResponseData response = JSONUtils.jsonToObject(body, new TypeReference<ResponseData>() {
146 }); 146 });
147 if (response.getResultCode().equals("0")) { 147 if (response.getResultCode().equals("0")) {
148 - log.info("请求转码系统屏蔽接口成功"); 148 + log.info("请求转码系统屏蔽/恢复接口成功");
149 }else { 149 }else {
150 - log.info("请求转码系统屏蔽接口响应失败,response:{}",response); 150 + log.info("请求转码系统屏蔽/恢复接口响应失败,response:{}",response);
151 throw new BusinessException("block_status_error", "屏蔽状态错误"); 151 throw new BusinessException("block_status_error", "屏蔽状态错误");
152 } 152 }
153 } else { 153 } else {
154 - log.error("请求转码系统屏蔽接口失败,url:{},body:{}", blockStatusUrl, execute.body()); 154 + log.error("请求转码系统屏蔽/恢复接口失败,url:{},body:{}", blockStatusUrl, execute.body());
155 throw new BusinessException("block_status_error", "屏蔽状态错误"); 155 throw new BusinessException("block_status_error", "屏蔽状态错误");
156 } 156 }
157 } catch (Exception e) { 157 } catch (Exception e) {
158 - log.error("请求转码系统屏蔽接口失败,url:{}", blockStatusUrl, e); 158 + log.error("请求转码系统屏蔽/恢复接口失败,url:{}", blockStatusUrl, e);
159 throw new BusinessException("block_status_error", "屏蔽状态错误"); 159 throw new BusinessException("block_status_error", "屏蔽状态错误");
160 } 160 }
161 }); 161 });
@@ -165,7 +165,7 @@ public class RoomOperationServiceImpl implements RoomOperationSerivice { @@ -165,7 +165,7 @@ public class RoomOperationServiceImpl implements RoomOperationSerivice {
165 monitorMark.setRoomId(blockParam.getRoomId()); 165 monitorMark.setRoomId(blockParam.getRoomId());
166 monitorMark.setCreatedTime(LocalDateTime.now()); 166 monitorMark.setCreatedTime(LocalDateTime.now());
167 monitorMark.setCreatedBy("admin"); 167 monitorMark.setCreatedBy("admin");
168 - monitorMark.setOperationType(blockParam.getBlockStatus().equals("0") ? RoomOperationEnum.RECOVER.getCode() : RoomOperationEnum.BLOCK.getCode()); 168 + monitorMark.setOperationType(blockParam.getBlockStatus()==0 ? RoomOperationEnum.RECOVER.getCode() : RoomOperationEnum.BLOCK.getCode());
169 monitorMark.setOperationTime(LocalDateTime.now()); 169 monitorMark.setOperationTime(LocalDateTime.now());
170 monitorMarkMapper.insert(monitorMark); 170 monitorMarkMapper.insert(monitorMark);
171 171