|
@@ -146,8 +146,8 @@ public class WebSocketMobileServer implements Concurrently {
|
|
|
//判断是否是正常退出
|
|
|
ExamRecordCacheUtil.setMonitorStatus(recordId, this.source.name(), MonitorStatusSourceEnum.STOP, true);
|
|
|
ConcurrentHashMap<Long, WebSocketOeServer> webSocketMap = WebSocketOeServer.getWebSocketMap();
|
|
|
- if (Objects.nonNull(webSocketMap.get(recordId + "-" + this.source.name()))) {
|
|
|
- WebSocketOeServer webSocketOeServer = webSocketMap.get(recordId + "-" + this.source.name());
|
|
|
+ if (Objects.nonNull(webSocketMap.get(recordId))) {
|
|
|
+ WebSocketOeServer webSocketOeServer = webSocketMap.get(recordId);
|
|
|
Map map = new HashMap<>();
|
|
|
map.put(SystemConstant.RECORD_ID, recordId);
|
|
|
map.put("monitorVideoSource", this.source.name());
|