wanghongbo

增加屏蔽恢复校验

@@ -14,6 +14,7 @@ import com.wondertek.entity.MonitorMark; @@ -14,6 +14,7 @@ import com.wondertek.entity.MonitorMark;
14 import com.wondertek.entity.StreamTask; 14 import com.wondertek.entity.StreamTask;
15 import com.wondertek.enums.RoomOperationEnum; 15 import com.wondertek.enums.RoomOperationEnum;
16 import com.wondertek.exception.BusinessException; 16 import com.wondertek.exception.BusinessException;
  17 +import com.wondertek.exception.ServiceException;
17 import com.wondertek.mapper.LiveMonitorRoomMapper; 18 import com.wondertek.mapper.LiveMonitorRoomMapper;
18 import com.wondertek.mapper.MonitorMarkMapper; 19 import com.wondertek.mapper.MonitorMarkMapper;
19 import com.wondertek.mapper.StreamTaskMapper; 20 import com.wondertek.mapper.StreamTaskMapper;
@@ -123,6 +124,12 @@ public class RoomOperationServiceImpl implements RoomOperationSerivice { @@ -123,6 +124,12 @@ public class RoomOperationServiceImpl implements RoomOperationSerivice {
123 if (ObjectUtil.isNull(liveMonitorRoom)){ 124 if (ObjectUtil.isNull(liveMonitorRoom)){
124 return ResultBean.error("审片间不存在"); 125 return ResultBean.error("审片间不存在");
125 } 126 }
  127 + //校验当前屏蔽、恢复状态
  128 + if (blockParam.getBlockStatus().toString().equals(liveMonitorRoom.getBrocStatus())){
  129 + String message = blockParam.getBlockStatus().equals(0)?"恢复":"屏蔽";
  130 + throw new ServiceException("当前审片间已处于"+ message +"状态");
  131 + }
  132 +
126 //获取当前播出流 133 //获取当前播出流
127 LambdaQueryWrapper<StreamTask> wrapper = new LambdaQueryWrapper<>(); 134 LambdaQueryWrapper<StreamTask> wrapper = new LambdaQueryWrapper<>();
128 wrapper.eq(StreamTask::getRoomId,blockParam.getRoomId()); 135 wrapper.eq(StreamTask::getRoomId,blockParam.getRoomId());