bug fix

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

@@ -257,7 +257,7 @@ public class MqOeLogicServiceImpl implements MqOeLogicService {
     public void execMqOeMobileLogic(MqDto mqDto, String key) {
         Gson gson = new Gson();
         String tag = mqDto.getTag();
-        AtomicBoolean match = new AtomicBoolean(false);
+//        AtomicBoolean match = new AtomicBoolean(false);
         ConcurrentHashMap<String, WebSocketMobileServer> webSocketMap = WebSocketMobileServer.getWebSocketMap();
         if (Objects.equals(MqTagEnum.EXAM_STOP.name(), tag)//考试退出
                 || Objects.equals(MqTagEnum.EXAM_START.name(), tag)) {//考试开始
@@ -271,7 +271,7 @@ public class MqOeLogicServiceImpl implements MqOeLogicService {
                         && !Objects.equals(ExamRecordStatusEnum.FINISHED, examRecordStatusEnum))
                         && Objects.nonNull(webSocketMobileServer.getRecordId())
                         && webSocketMobileServer.getRecordId().longValue() == recordId.longValue()) {
-                    match.set(true);
+//                    match.set(true);
                     WebsocketDto websocketDto = null;
                     switch (tag.toUpperCase()) {
                         case "EXAM_STOP":
@@ -294,7 +294,7 @@ public class MqOeLogicServiceImpl implements MqOeLogicService {
                         && !Objects.equals(ExamRecordStatusEnum.FINISHED, examRecordStatusEnum))
                         && Objects.nonNull(webSocketMobileServer.getRecordId())
                         && webSocketMobileServer.getRecordId().longValue() == recordId.longValue()) {
-                    match.set(true);
+//                    match.set(true);
                     WebsocketDto websocketDto = null;
                     switch (tag.toUpperCase()) {
                         case "EXAM_STOP":
@@ -310,12 +310,12 @@ public class MqOeLogicServiceImpl implements MqOeLogicService {
                 }
             }
         }
-        if (match.get()) {
+//        if (match.get()) {
             mqDto.setAck(SystemConstant.STANDARD_ACK_TYPE);
             TMRocketMessage tmRocketMessage = gson.fromJson(gson.toJson(mqDto), TMRocketMessage.class);
             tmRocketMessage.setBody(JacksonUtil.parseJson(tmRocketMessage.getBody()));
             tmRocketMessageService.saveOrUpdate(tmRocketMessage);
             redisUtil.delete(key, mqDto.getId());
-        }
+//        }
     }
 }