wangliang hace 4 años
padre
commit
c19005a345

+ 3 - 12
themis-exam/src/main/java/com/qmth/themis/exam/listener/service/impl/MqOeLogicServiceImpl.java

@@ -204,10 +204,7 @@ public class MqOeLogicServiceImpl implements MqOeLogicService {
                             websocketDto = new WebsocketDto(WebsocketTypeEnum.MOBILE_ANSWER_UPLOAD.name(), prop);
                             break;
                         case "OE_WEBSOCKET_EXAM_STOP":
-                            if (Objects.equals(ExamRecordStatusEnum.PERSISTED, examRecordStatusEnum)
-                                    || Objects.equals(ExamRecordStatusEnum.FINISHED, examRecordStatusEnum)) {
-                                websocketDto = new WebsocketDto(WebsocketTypeEnum.EXAM_STOP.name(), prop);
-                            }
+                            websocketDto = new WebsocketDto(WebsocketTypeEnum.EXAM_STOP.name(), prop);
                             break;
                         case "MONITOR_START":
                             MonitorVideoSourceEnum source = MonitorVideoSourceEnum.valueOf((String) prop.get("source"));
@@ -274,10 +271,7 @@ public class MqOeLogicServiceImpl implements MqOeLogicService {
                     WebsocketDto websocketDto = null;
                     switch (tag.toUpperCase()) {
                         case "EXAM_STOP":
-                            if (Objects.equals(ExamRecordStatusEnum.PERSISTED, examRecordStatusEnum)
-                                    || Objects.equals(ExamRecordStatusEnum.FINISHED, examRecordStatusEnum)) {
-                                websocketDto = new WebsocketDto(WebsocketTypeEnum.EXAM_STOP.name(), mqDto.getProperties());
-                            }
+                            websocketDto = new WebsocketDto(WebsocketTypeEnum.EXAM_STOP.name(), mqDto.getProperties());
                             break;
                         case "EXAM_START":
                             if (!Objects.equals(ExamRecordStatusEnum.PERSISTED, examRecordStatusEnum)
@@ -301,10 +295,7 @@ public class MqOeLogicServiceImpl implements MqOeLogicService {
                     WebsocketDto websocketDto = null;
                     switch (tag.toUpperCase()) {
                         case "EXAM_STOP":
-                            if (Objects.equals(ExamRecordStatusEnum.PERSISTED, examRecordStatusEnum)
-                                    || Objects.equals(ExamRecordStatusEnum.FINISHED, examRecordStatusEnum)) {
-                                websocketDto = new WebsocketDto(WebsocketTypeEnum.EXAM_STOP.name(), mqDto.getProperties());
-                            }
+                            websocketDto = new WebsocketDto(WebsocketTypeEnum.EXAM_STOP.name(), mqDto.getProperties());
                             break;
                         case "EXAM_START":
                             if (!Objects.equals(ExamRecordStatusEnum.PERSISTED, examRecordStatusEnum)