修复BUG

themis-business/src/main/java/com/qmth/themis/business/service/TEExamService.java

@@ -15,7 +15,6 @@ import com.qmth.themis.business.enums.ScoreStatusEnum;
 import com.qmth.themis.business.enums.SystemOperationEnum;
 import org.springframework.web.multipart.MultipartFile;
 
-import java.security.NoSuchAlgorithmException;
 import java.util.List;
 import java.util.Map;
 

themis-business/src/main/java/com/qmth/themis/business/service/impl/TEExamServiceImpl.java

@@ -49,7 +49,6 @@ import java.io.File;
 import java.io.IOException;
 import java.io.InputStream;
 import java.math.BigDecimal;
-import java.security.NoSuchAlgorithmException;
 import java.text.SimpleDateFormat;
 import java.util.*;
 import java.util.regex.Matcher;

themis-exam/src/main/java/com/qmth/themis/exam/api/TEExamController.java

@@ -29,6 +29,7 @@ import com.qmth.themis.common.exception.BusinessException;
 import com.qmth.themis.common.util.Result;
 import com.qmth.themis.common.util.ResultUtil;
 import com.qmth.themis.exam.config.ExamConstant;
+import com.qmth.themis.exam.websocket.WebSocketOeServer;
 import io.swagger.annotations.*;
 import org.springframework.web.bind.annotation.*;
 import org.springframework.web.multipart.MultipartFile;
@@ -37,6 +38,7 @@ import javax.annotation.Resource;
 import java.io.IOException;
 import java.security.NoSuchAlgorithmException;
 import java.util.*;
+import java.util.concurrent.ConcurrentHashMap;
 
 @Api(tags = "考试Controller")
 @RestController
@@ -141,7 +143,12 @@ public class TEExamController {
                 throw new BusinessException(ExceptionResultEnum.EXAM_STATUS_ERROR);
             }
         }
-        ExamConstant.clientWebsocketClose(Long.parseLong(recordId));
+        ConcurrentHashMap<String, WebSocketOeServer> webSocketMap = WebSocketOeServer.getWebSocketMap();
+        String clientWebsocketId = ExamRecordCacheUtil.getClientWebsocketId(Long.parseLong(recordId));
+        if (Objects.nonNull(clientWebsocketId)) {
+            WebSocketOeServer webSocketOeServer = webSocketMap.get(clientWebsocketId);
+            WebSocketOeServer.close(webSocketOeServer);
+        }
 
         Long examStudentId = ExamRecordCacheUtil.getExamStudentId(Long.parseLong(recordId));
         ExamStudentCacheBean examStudentCacheBean = teExamStudentService.getExamStudentCacheBean(examStudentId);
@@ -302,7 +309,7 @@ public class TEExamController {
     @ApiOperation(value = "结束考试")
     @RequestMapping(value = "/finish", method = RequestMethod.POST)
     @ApiResponses({@ApiResponse(code = 200, message = "试卷信息")})
-    public Result finish(@RequestBody FinishParamBean param) throws IOException, NoSuchAlgorithmException {
+    public Result finish(@RequestBody FinishParamBean param) {
         TEStudentCacheDto teStudent = (TEStudentCacheDto) ServletUtil.getRequestStudentAccount();
         String lockKey = SystemConstant.REDIS_LOCK_STUDENT_PREFIX + teStudent.getId();
         Boolean lock = redisUtil.lock(lockKey, SystemConstant.REDIS_CACHE_TIME_OUT);
@@ -319,13 +326,7 @@ public class TEExamController {
             if (param.getDurationSeconds() == null) {
                 throw new BusinessException("总用时秒数不能为空");
             }
-            ExamFinishBean examFinishBean = teExamService.finish(teStudent.getId(), param.getRecordId(), param.getType(), param.getDurationSeconds());
-            SystemConstant.clientMonitorStatusStop(param.getRecordId());
-            ExamConstant.clientWebsocketClose(param.getRecordId());
-
-            SystemConstant.mobileMonitorStatusStop(teStudent.getId(), param.getRecordId(), false);
-            ExamConstant.mobileWebsocketClose(param.getRecordId());
-            return ResultUtil.ok(examFinishBean);
+            return ResultUtil.ok(teExamService.finish(teStudent.getId(), param.getRecordId(), param.getType(), param.getDurationSeconds()));
         } finally {
             redisUtil.releaseLock(lockKey);
         }

themis-exam/src/main/java/com/qmth/themis/exam/api/TEStudentController.java

@@ -46,7 +46,6 @@ import org.springframework.web.bind.annotation.RestController;
 
 import javax.annotation.Resource;
 import java.io.File;
-import java.io.IOException;
 import java.security.NoSuchAlgorithmException;
 import java.util.*;
 
@@ -109,7 +108,7 @@ public class TEStudentController {
                     @ApiJsonProperty(key = "password", description = "密码"),
                     @ApiJsonProperty(key = "orgId", type = "long", example = "1", description = "机构id"),
                     @ApiJsonProperty(key = "examId", type = "long", example = "1", description = "批次id")}) @ApiParam(value = "学生信息", required = true) @RequestBody Map<String, Object> mapParameter)
-            throws NoSuchAlgorithmException, IOException {
+            throws NoSuchAlgorithmException {
         if (Objects.isNull(mapParameter)) {
             throw new BusinessException(ExceptionResultEnum.STUDENT_IS_NULL);
         }
@@ -184,7 +183,7 @@ public class TEStudentController {
      * @return
      * @throws NoSuchAlgorithmException
      */
-    private Result userLoginCommon(TEStudent teStudent, Long examId, Long orgId) throws NoSuchAlgorithmException, IOException {
+    private Result userLoginCommon(TEStudent teStudent, Long examId, Long orgId) throws NoSuchAlgorithmException {
         //停用
         if (teStudent.getEnable().intValue() == 0) {
             throw new BusinessException(ExceptionResultEnum.STUDENT_ENABLE);

themis-exam/src/main/java/com/qmth/themis/exam/api/TIeInvigilateCallMobileController.java

@@ -3,13 +3,11 @@ package com.qmth.themis.exam.api;
 import com.qmth.themis.business.annotation.ApiJsonObject;
 import com.qmth.themis.business.annotation.ApiJsonProperty;
 import com.qmth.themis.business.cache.ExamRecordCacheUtil;
-import com.qmth.themis.business.cache.bean.ExamStudentCacheBean;
 import com.qmth.themis.business.constant.SystemConstant;
 import com.qmth.themis.business.dto.MqDto;
 import com.qmth.themis.business.entity.TIeExamInvigilateCallLog;
 import com.qmth.themis.business.enums.*;
 import com.qmth.themis.business.service.MqDtoService;
-import com.qmth.themis.business.service.TEExamStudentService;
 import com.qmth.themis.business.service.TOeExamRecordService;
 import com.qmth.themis.business.util.MqUtil;
 import com.qmth.themis.common.enums.ExceptionResultEnum;
@@ -17,7 +15,6 @@ import com.qmth.themis.common.exception.BusinessException;
 import com.qmth.themis.common.util.Result;
 import com.qmth.themis.common.util.ResultUtil;
 import com.qmth.themis.exam.config.DictionaryConfig;
-import com.qmth.themis.exam.config.ExamConstant;
 import io.swagger.annotations.*;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
@@ -28,9 +25,10 @@ import org.springframework.web.bind.annotation.RequestMethod;
 import org.springframework.web.bind.annotation.RestController;
 
 import javax.annotation.Resource;
-import java.io.IOException;
-import java.security.NoSuchAlgorithmException;
-import java.util.*;
+import java.util.Collections;
+import java.util.HashMap;
+import java.util.Map;
+import java.util.Objects;
 
 /**
  * @Description: mobile监考监控通话信息 前端控制器
@@ -57,9 +55,6 @@ public class TIeInvigilateCallMobileController {
     @Resource
     TOeExamRecordService tOeExamRecordService;
 
-    @Resource
-    TEExamStudentService teExamStudentService;
-
 //    @Deprecated
 //    @ApiOperation(value = "监控观看地址更新接口")
 //    @RequestMapping(value = "/live_url", method = RequestMethod.POST)
@@ -160,7 +155,7 @@ public class TIeInvigilateCallMobileController {
             @ApiJsonProperty(key = "source", description = "监考视频源", required = true),
             @ApiJsonProperty(key = "status", description = "当前状态", required = true),
             @ApiJsonProperty(key = "type", description = "异常类型，status=stop时需要传递")
-    }) @ApiParam(value = "监控信息", required = true) @RequestBody Map<String, Object> mapParameter) throws IOException, NoSuchAlgorithmException {
+    }) @ApiParam(value = "监控信息", required = true) @RequestBody Map<String, Object> mapParameter) {
         if (Objects.isNull(mapParameter.get("recordId")) || Objects.equals(mapParameter.get("recordId"), "")) {
             throw new BusinessException(ExceptionResultEnum.RECORD_ID_IS_NULL);
         }
@@ -205,12 +200,6 @@ public class TIeInvigilateCallMobileController {
             //监控结束
             MqDto mqDtoStop = new MqDto(mqUtil.getMqGroupDomain().getTopic(), MqTagEnum.MONITOR_STOP.name(), recordId, MqTagEnum.MONITOR_STOP, String.valueOf(recordId), mqMap, String.valueOf(recordId));
             mqDtoService.assembleSendOneOrderMsg(mqDtoStop);
-
-            Long examStudentId = ExamRecordCacheUtil.getExamStudentId(recordId);
-            ExamStudentCacheBean examStudentCacheBean = teExamStudentService.getExamStudentCacheBean(examStudentId);
-            Optional.ofNullable(examStudentCacheBean).orElseThrow(() -> new BusinessException("考生数据为空"));
-            SystemConstant.mobileMonitorStatusStop(examStudentCacheBean.getStudentId(), recordId, true);
-            ExamConstant.mobileWebsocketClose(recordId);
         }
         Map map = new HashMap();
         map.put("status", status.name());

themis-exam/src/main/java/com/qmth/themis/exam/config/ExamConstant.java

@@ -13,13 +13,9 @@ import com.qmth.themis.business.service.TEExamStudentService;
 import com.qmth.themis.business.service.TOeExamRecordService;
 import com.qmth.themis.business.util.MqUtil;
 import com.qmth.themis.common.exception.BusinessException;
-import com.qmth.themis.exam.websocket.WebSocketMobileServer;
-import com.qmth.themis.exam.websocket.WebSocketOeServer;
 
-import java.io.IOException;
 import java.security.NoSuchAlgorithmException;
 import java.util.*;
-import java.util.concurrent.ConcurrentHashMap;
 
 /**
  * @Description: 考试系统常量
@@ -36,7 +32,7 @@ public class ExamConstant {
      * @param recordId
      * @param clientStop
      */
-    public static void sendExamStopMsg(Long recordId, boolean clientStop, boolean mobileStop) throws NoSuchAlgorithmException, IOException {
+    public static void sendExamStopMsg(Long recordId, boolean clientStop, boolean mobileStop) throws NoSuchAlgorithmException {
         MqUtil mqUtil = SpringContextHolder.getBean(MqUtil.class);
         MqDtoService mqDtoService = SpringContextHolder.getBean(MqDtoService.class);
         TEExamStudentService teExamStudentService = SpringContextHolder.getBean(TEExamStudentService.class);
@@ -47,7 +43,6 @@ public class ExamConstant {
         if (clientStop) {
             MqDto mqDto = new MqDto(mqUtil.getMqGroupDomain().getTopic(), MqTagEnum.OE_WEBSOCKET_EXAM_STOP.name(), recordId, MqTagEnum.OE_WEBSOCKET_EXAM_STOP, String.valueOf(recordId), mapParameter, String.valueOf(recordId));
             mqDtoService.assembleSendOneOrderMsg(mqDto);
-            SystemConstant.clientMonitorStatusStop(recordId);
         } else {//结束推流状态
             SystemConstant.clientMonitorStatusStop(recordId);
             TOeExamRecordService toeExamRecordService = SpringContextHolder.getBean(TOeExamRecordService.class);
@@ -62,7 +57,6 @@ public class ExamConstant {
             MqDto mqDto = new MqDto(mqUtil.getMqGroupDomain().getTopic(), MqTagEnum.EXAM_STOP.name(), recordId, MqTagEnum.EXAM_STOP, String.valueOf(recordId), mapParameter, String.valueOf(recordId));
             mqDtoService.assembleSendOneOrderMsg(mqDto);
             SystemConstant.mobileMonitorStatusStop(examStudentCacheBean.getStudentId(), recordId, false);
-            mobileWebsocketClose(recordId);
         }
     }
 
@@ -79,39 +73,4 @@ public class ExamConstant {
         MqDto mqDto = new MqDto(mqUtil.getMqGroupDomain().getTopic(), MqTagEnum.EXAM_START.name(), recordId, MqTagEnum.EXAM_START, String.valueOf(recordId), mapParameter, String.valueOf(recordId));
         mqDtoService.assembleSendOneOrderMsg(mqDto);
     }
-
-    /**
-     * 关闭客户端websocket
-     *
-     * @param recordId
-     * @throws IOException
-     */
-    public static void clientWebsocketClose(Long recordId) throws IOException {
-        ConcurrentHashMap<String, WebSocketOeServer> webSocketMap = WebSocketOeServer.getWebSocketMap();
-        String clientWebsocketId = ExamRecordCacheUtil.getClientWebsocketId(recordId);
-        if (Objects.nonNull(clientWebsocketId)) {
-            WebSocketOeServer webSocketOeServer = webSocketMap.get(clientWebsocketId);
-            WebSocketOeServer.close(webSocketOeServer);
-        }
-    }
-
-    /**
-     * 关闭移动端websocket
-     *
-     * @param recordId
-     * @throws IOException
-     */
-    public static void mobileWebsocketClose(Long recordId) throws IOException {
-        ConcurrentHashMap<String, WebSocketMobileServer> webSocketMap = WebSocketMobileServer.getWebSocketMap();
-        String mobileFirstWebsocketId = ExamRecordCacheUtil.getMobileFirstWebsocketId(recordId);
-        if (Objects.nonNull(mobileFirstWebsocketId)) {
-            WebSocketMobileServer webSocketMobileFirstServer = webSocketMap.get(mobileFirstWebsocketId + "-" + MonitorVideoSourceEnum.MOBILE_FIRST.name());
-            WebSocketMobileServer.close(webSocketMobileFirstServer);
-        }
-        String mobileSecondWebsocketId = ExamRecordCacheUtil.getMobileSecondWebsocketId(recordId);
-        if (Objects.nonNull(mobileSecondWebsocketId)) {
-            WebSocketMobileServer webSocketMobileSecondServer = webSocketMap.get(mobileSecondWebsocketId + "-" + MonitorVideoSourceEnum.MOBILE_SECOND.name());
-            WebSocketMobileServer.close(webSocketMobileSecondServer);
-        }
-    }
 }

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

@@ -206,6 +206,14 @@ public class MqOeLogicServiceImpl implements MqOeLogicService {
                         case "OE_WEBSOCKET_EXAM_STOP":
                             if (!Objects.equals(ExamRecordStatusEnum.ANSWERING, examRecordStatusEnum)) {
                                 websocketDto = new WebsocketDto(WebsocketTypeEnum.EXAM_STOP.name(), prop);
+                                SystemConstant.clientMonitorStatusStop(recordId);
+                                Map<String, Object> properties = mqDto.getProperties();
+                                if (Objects.nonNull(properties) && properties.size() > 0) {
+                                    Boolean removeWebsocket = (Boolean) properties.get(SystemConstant.REMOVE_WEBSOCKET);
+                                    if (Objects.nonNull(removeWebsocket) && removeWebsocket) {
+                                        WebSocketOeServer.close(webSocketOeServer);
+                                    }
+                                }
                             }
                             break;
                         case "MONITOR_START":
@@ -224,6 +232,26 @@ public class MqOeLogicServiceImpl implements MqOeLogicService {
                                     && Objects.nonNull(monitorStatusBean.getTimestamp())
                                     && mqDto.getTimestamp().longValue() >= monitorStatusBean.getTimestamp().longValue()) {
                                 websocketDto = new WebsocketDto(WebsocketTypeEnum.MOBILE_MONITOR_STOP.name(), prop);
+                                ConcurrentHashMap<String, WebSocketMobileServer> webSocketMobileMap = WebSocketMobileServer.getWebSocketMap();
+
+                                String mobileWebsocketId = null;
+//                                WebsocketStatusEnum websocketStatusEnum = null;
+                                if (source == MonitorVideoSourceEnum.MOBILE_FIRST) {
+                                    mobileWebsocketId = ExamRecordCacheUtil.getMobileFirstWebsocketId(recordId);
+//                                    websocketStatusEnum = ExamRecordCacheUtil.getMobileFirstWebsocketStatus(recordId);
+                                } else if (source == MonitorVideoSourceEnum.MOBILE_SECOND) {
+                                    mobileWebsocketId = ExamRecordCacheUtil.getMobileSecondWebsocketId(recordId);
+//                                    websocketStatusEnum = ExamRecordCacheUtil.getMobileSecondWebsocketStatus(recordId);
+                                }
+//                                if (Objects.nonNull(websocketStatusEnum) && websocketStatusEnum == WebsocketStatusEnum.ON_LINE) {
+                                WebSocketMobileServer webSocketMobileServer = webSocketMobileMap.get(mobileWebsocketId + "-" + source.name());
+                                Long examStudentId = ExamRecordCacheUtil.getExamStudentId(recordId);
+                                ExamStudentCacheBean examStudentCacheBean = teExamStudentService.getExamStudentCacheBean(examStudentId);
+                                Optional.ofNullable(examStudentCacheBean).orElseThrow(() -> new BusinessException("考生数据为空"));
+
+                                SystemConstant.mobileMonitorStatusStop(examStudentCacheBean.getStudentId(), recordId, true);
+                                WebSocketMobileServer.close(webSocketMobileServer);
+//                                }
                             }
                             break;
                         case "OE_WEBSOCKET_MOBILE_MONITOR_STATUS":
@@ -287,6 +315,14 @@ public class MqOeLogicServiceImpl implements MqOeLogicService {
                         case "EXAM_STOP":
                             if (!Objects.equals(ExamRecordStatusEnum.ANSWERING, examRecordStatusEnum)) {
                                 websocketDto = new WebsocketDto(WebsocketTypeEnum.EXAM_STOP.name(), mqDto.getProperties());
+                                SystemConstant.mobileMonitorStatusStop(examStudentCacheBean.getStudentId(), recordId, false);
+                                Map<String, Object> properties = mqDto.getProperties();
+                                if (Objects.nonNull(properties) && properties.size() > 0) {
+                                    Boolean removeWebsocket = (Boolean) properties.get(SystemConstant.REMOVE_WEBSOCKET);
+                                    if (Objects.nonNull(removeWebsocket) && removeWebsocket) {
+                                        WebSocketMobileServer.close(webSocketFirstMobileServer);
+                                    }
+                                }
                             }
                             break;
                         case "EXAM_START":
@@ -312,6 +348,14 @@ public class MqOeLogicServiceImpl implements MqOeLogicService {
                         case "EXAM_STOP":
                             if (!Objects.equals(ExamRecordStatusEnum.ANSWERING, examRecordStatusEnum)) {
                                 websocketDto = new WebsocketDto(WebsocketTypeEnum.EXAM_STOP.name(), mqDto.getProperties());
+                                SystemConstant.mobileMonitorStatusStop(examStudentCacheBean.getStudentId(), recordId, false);
+                                Map<String, Object> properties = mqDto.getProperties();
+                                if (Objects.nonNull(properties) && properties.size() > 0) {
+                                    Boolean mobileRemoveWebsocket = (Boolean) properties.get(SystemConstant.REMOVE_WEBSOCKET);
+                                    if (Objects.nonNull(mobileRemoveWebsocket) && mobileRemoveWebsocket) {
+                                        WebSocketMobileServer.close(webSocketSecondMobileServer);
+                                    }
+                                }
                             }
                             break;
                         case "EXAM_START":

themis-exam/src/main/java/com/qmth/themis/exam/websocket/WebSocketMobileServer.java

@@ -3,7 +3,6 @@ package com.qmth.themis.exam.websocket;
 import com.alibaba.fastjson.JSONObject;
 import com.google.gson.Gson;
 import com.qmth.themis.business.cache.ExamRecordCacheUtil;
-import com.qmth.themis.business.cache.bean.ExamStudentCacheBean;
 import com.qmth.themis.business.constant.SpringContextHolder;
 import com.qmth.themis.business.constant.SystemConstant;
 import com.qmth.themis.business.dto.MqDto;
@@ -11,7 +10,6 @@ import com.qmth.themis.business.dto.WebsocketDto;
 import com.qmth.themis.business.entity.TBSession;
 import com.qmth.themis.business.enums.*;
 import com.qmth.themis.business.service.MqDtoService;
-import com.qmth.themis.business.service.TEExamStudentService;
 import com.qmth.themis.business.service.TOeExamRecordService;
 import com.qmth.themis.business.util.*;
 import com.qmth.themis.common.contanst.Constants;
@@ -33,8 +31,10 @@ import javax.websocket.server.ServerEndpoint;
 import java.io.IOException;
 import java.lang.reflect.Method;
 import java.net.InetSocketAddress;
-import java.security.NoSuchAlgorithmException;
-import java.util.*;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+import java.util.Objects;
 import java.util.concurrent.ConcurrentHashMap;
 
 /**
@@ -96,7 +96,7 @@ public class WebSocketMobileServer implements Concurrently {
      * 连接关闭调用的方法
      */
     @OnClose
-    public void onClose() throws NoSuchAlgorithmException, IOException {
+    public void onClose() {
         log.info("onClose is come in");
         if (webSocketMap.containsKey(this.websocketSessionId + "-" + this.source.name())) {
             webSocketMap.remove(this.websocketSessionId + "-" + this.source.name());
@@ -120,12 +120,6 @@ public class WebSocketMobileServer implements Concurrently {
             //监控结束
             MqDto mqDtoStop = new MqDto(mqUtil.getMqGroupDomain().getTopic(), MqTagEnum.MONITOR_STOP.name(), recordId, MqTagEnum.MONITOR_STOP, String.valueOf(recordId), mqMap, String.valueOf(recordId));
             mqDtoService.assembleSendOneOrderMsg(mqDtoStop);
-
-            TEExamStudentService teExamStudentService = SpringContextHolder.getBean(TEExamStudentService.class);
-            Long examStudentId = ExamRecordCacheUtil.getExamStudentId(this.recordId);
-            ExamStudentCacheBean examStudentCacheBean = teExamStudentService.getExamStudentCacheBean(examStudentId);
-            Optional.ofNullable(examStudentCacheBean).orElseThrow(() -> new BusinessException("考生数据为空"));
-            SystemConstant.mobileMonitorStatusStop(examStudentCacheBean.getStudentId(), this.recordId, true);
         }
         log.info("用户退出:{},当前在线人数为:{},updateTime:{}", this.sessionId, getOnlineCount(), this.updateTime);
     }

themis-exam/src/main/java/com/qmth/themis/exam/websocket/WebSocketOeServer.java

@@ -103,7 +103,7 @@ public class WebSocketOeServer implements Concurrently {
      * 连接关闭调用的方法
      */
     @OnClose
-    public void onClose() throws NoSuchAlgorithmException, IOException {
+    public void onClose() throws NoSuchAlgorithmException {
         log.info("onClose is come in");
         if (webSocketMap.containsKey(this.websocketSessionId)) {
             webSocketMap.remove(this.websocketSessionId);