|
@@ -260,7 +260,6 @@ public class MqOeLogicServiceImpl implements MqOeLogicService {
|
|
|| Objects.equals(MqTagEnum.EXAM_START.name(), tag)) {//考试开始
|
|
|| Objects.equals(MqTagEnum.EXAM_START.name(), tag)) {//考试开始
|
|
Long recordId = Long.parseLong(String.valueOf(mqDto.getBody()));
|
|
Long recordId = Long.parseLong(String.valueOf(mqDto.getBody()));
|
|
String mobileWebsocketId = ExamRecordCacheUtil.getMobileWebsocketId(recordId);
|
|
String mobileWebsocketId = ExamRecordCacheUtil.getMobileWebsocketId(recordId);
|
|
- log.info("tag:{},mobileWebsocketId:{}", tag, mobileWebsocketId);
|
|
|
|
if (Objects.nonNull(mobileWebsocketId) && Objects.nonNull(webSocketMap.get(mobileWebsocketId + "-" + MonitorVideoSourceEnum.MOBILE_FIRST.name()))) {
|
|
if (Objects.nonNull(mobileWebsocketId) && Objects.nonNull(webSocketMap.get(mobileWebsocketId + "-" + MonitorVideoSourceEnum.MOBILE_FIRST.name()))) {
|
|
WebSocketMobileServer webSocketMobileServer = webSocketMap.get(mobileWebsocketId + "-" + MonitorVideoSourceEnum.MOBILE_FIRST.name());
|
|
WebSocketMobileServer webSocketMobileServer = webSocketMap.get(mobileWebsocketId + "-" + MonitorVideoSourceEnum.MOBILE_FIRST.name());
|
|
ExamRecordStatusEnum examRecordStatusEnum = ExamRecordCacheUtil.getStatus(recordId);
|
|
ExamRecordStatusEnum examRecordStatusEnum = ExamRecordCacheUtil.getStatus(recordId);
|