From 69b7b1ddb3ba056b8ed458bdd44cf36e4080b5bd Mon Sep 17 00:00:00 2001
From: fuliqi <fuliqi@qq.com>
Date: 星期四, 04 七月 2024 17:57:59 +0800
Subject: [PATCH] mq配置修改2
---
src/main/java/com/ycl/jxkg/service/impl/ExamServiceImpl.java | 6 ++++++
1 files changed, 6 insertions(+), 0 deletions(-)
diff --git a/src/main/java/com/ycl/jxkg/service/impl/ExamServiceImpl.java b/src/main/java/com/ycl/jxkg/service/impl/ExamServiceImpl.java
index 03ff2fa..1139c33 100644
--- a/src/main/java/com/ycl/jxkg/service/impl/ExamServiceImpl.java
+++ b/src/main/java/com/ycl/jxkg/service/impl/ExamServiceImpl.java
@@ -885,6 +885,9 @@
WebsocketDataVO websocket = new WebsocketDataVO();
websocket.setCommend(WebsocketCommendEnum.DELAYED.getCommend());
websocket.setData(form);
+ if (! websocketServer.checkUserOnline(form.getUserId())) {
+ throw new RuntimeException("璇ュ鍛樹笉鍦ㄧ嚎锛屾棤娉曟墽琛岃鎿嶄綔");
+ }
// 鍙戦�亀ebsocket娑堟伅
websocketServer.sendOneMessage(form.getUserId(), JSON.toJSONString(form));
return Result.ok("鎿嶄綔鎴愬姛");
@@ -895,6 +898,9 @@
WebsocketDataVO websocket = new WebsocketDataVO();
websocket.setCommend(WebsocketCommendEnum.FORCE_SUBMIT.getCommend());
websocket.setData(form);
+ if (! websocketServer.checkUserOnline(form.getUserId())) {
+ throw new RuntimeException("璇ュ鍛樹笉鍦ㄧ嚎锛屾棤娉曟墽琛岃鎿嶄綔");
+ }
// 鍙戦�亀ebsocket娑堟伅
websocketServer.sendOneMessage(form.getUserId(), JSON.toJSONString(form));
return Result.ok("鎿嶄綔鎴愬姛");
--
Gitblit v1.8.0