|
@@ -273,17 +273,16 @@ public class MqLogicServiceImpl implements MqLogicService {
|
|
//考试断点异常原因 发送mq end
|
|
//考试断点异常原因 发送mq end
|
|
//更新场次-考试记录缓存
|
|
//更新场次-考试记录缓存
|
|
ExamActivityRecordCacheUtil.setExamRecordStatus(examActivityId, recordId, new ExamActivityRecordCacheBean(ExamRecordCacheUtil.getExamStudentId(recordId), ExamRecordCacheUtil.getStatus(recordId)));
|
|
ExamActivityRecordCacheUtil.setExamRecordStatus(examActivityId, recordId, new ExamActivityRecordCacheBean(ExamRecordCacheUtil.getExamStudentId(recordId), ExamRecordCacheUtil.getStatus(recordId)));
|
|
-
|
|
|
|
- //更新客户端摄像头推流状态为stop
|
|
|
|
- MonitorStatusSourceEnum cameraStatusSourceEnum = ExamRecordCacheUtil.getMonitorStatus(recordId, MonitorVideoSourceEnum.CLIENT_CAMERA.name());
|
|
|
|
- if (Objects.nonNull(cameraStatusSourceEnum)) {
|
|
|
|
- ExamRecordCacheUtil.setMonitorStatus(recordId, cameraStatusSourceEnum.name(), MonitorStatusSourceEnum.STOP, true);
|
|
|
|
- }
|
|
|
|
- //更新客户端屏幕推流状态为stop
|
|
|
|
- MonitorStatusSourceEnum screenStatusSourceEnum = ExamRecordCacheUtil.getMonitorStatus(recordId, MonitorVideoSourceEnum.CLIENT_SCREEN.name());
|
|
|
|
- if (Objects.nonNull(screenStatusSourceEnum)) {
|
|
|
|
- ExamRecordCacheUtil.setMonitorStatus(recordId, screenStatusSourceEnum.name(), MonitorStatusSourceEnum.STOP, true);
|
|
|
|
- }
|
|
|
|
|
|
+ }
|
|
|
|
+ //更新客户端摄像头推流状态为stop
|
|
|
|
+ MonitorStatusSourceEnum cameraStatusSourceEnum = ExamRecordCacheUtil.getMonitorStatus(recordId, MonitorVideoSourceEnum.CLIENT_CAMERA.name());
|
|
|
|
+ if (Objects.nonNull(cameraStatusSourceEnum)) {
|
|
|
|
+ ExamRecordCacheUtil.setMonitorStatus(recordId, cameraStatusSourceEnum.name(), MonitorStatusSourceEnum.STOP, true);
|
|
|
|
+ }
|
|
|
|
+ //更新客户端屏幕推流状态为stop
|
|
|
|
+ MonitorStatusSourceEnum screenStatusSourceEnum = ExamRecordCacheUtil.getMonitorStatus(recordId, MonitorVideoSourceEnum.CLIENT_SCREEN.name());
|
|
|
|
+ if (Objects.nonNull(screenStatusSourceEnum)) {
|
|
|
|
+ ExamRecordCacheUtil.setMonitorStatus(recordId, screenStatusSourceEnum.name(), MonitorStatusSourceEnum.STOP, true);
|
|
}
|
|
}
|
|
//发送移动端监考退出考试mq消息 start
|
|
//发送移动端监考退出考试mq消息 start
|
|
MqDto mqDtoExamStop = new MqDto(MqTopicEnum.THEMIS_TOPIC.getCode(), MqTagEnum.EXAM_STOP.name(), recordId, MqTagEnum.EXAM_STOP, String.valueOf(recordId), String.valueOf(recordId));
|
|
MqDto mqDtoExamStop = new MqDto(MqTopicEnum.THEMIS_TOPIC.getCode(), MqTagEnum.EXAM_STOP.name(), recordId, MqTagEnum.EXAM_STOP, String.valueOf(recordId), String.valueOf(recordId));
|