wanghongbo

增加输出日志

... ... @@ -117,6 +117,8 @@ public class RoomOperationServiceImpl implements RoomOperationSerivice {
@Override
public ResultBean blockStatus(BlockParam blockParam) {
Long start = System.currentTimeMillis();
LiveMonitorRoom liveMonitorRoom = liveMonitorRoomMapper.selectById(blockParam.getRoomId());
if (ObjectUtil.isNull(liveMonitorRoom)){
return ResultBean.error("审片间不存在");
... ... @@ -129,6 +131,8 @@ public class RoomOperationServiceImpl implements RoomOperationSerivice {
if (CollectionUtils.isEmpty(streamTasks)){
return ResultBean.error("当前审片间没有播放任务");
}
log.info("-->审片间屏蔽前置逻辑耗时:{}ms",System.currentTimeMillis()-start);
streamTasks.forEach(streamTask -> {
//调用屏蔽接口
Map<String, Object> paramsMap = new HashMap<>();
... ... @@ -136,11 +140,13 @@ public class RoomOperationServiceImpl implements RoomOperationSerivice {
paramsMap.put("blockStatus", blockParam.getBlockStatus());
HttpResponse execute = null;
try {
long tag1 = System.currentTimeMillis();
execute = HttpRequest.put(blockStatusUrl)
.header("Content-Type", "application/json")
.body(JSONUtils.obj2json(paramsMap)).timeout(30000).execute();
if (execute.isOk()) {
log.info("-->请求转码系统屏蔽/恢复接口,url:{},paramsMap:{}",blockStatusUrl,paramsMap);
log.info("请求转码系统屏蔽/恢复接口,请求耗时:{}ms",System.currentTimeMillis()-tag1);
String body = execute.body();
ResponseData response = JSONUtils.jsonToObject(body, new TypeReference<ResponseData>() {
});
... ...