From b0f2eabf6bb2e9065973356cc74d07368978d8d3 Mon Sep 17 00:00:00 2001
From: weixin_45799331 <weixin_45799331@noreply.gitcode.com>
Date: Tue, 27 Jan 2026 13:31:03 +0800
Subject: [PATCH] =?UTF-8?q?sse=E5=AE=9E=E6=97=B6=E5=BC=80=E5=8F=91?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../core/framework/config/SecurityConfig.java |  3 -
 .../openhis-application/pom.xml               |  6 --
 .../impl/TriageQueueAppServiceImpl.java       | 19 ++--
 .../controller/TriageQueueController.java     | 46 +++++++++
 .../callnumberdisplay/index.vue               | 94 ++++++++-----------
 5 files changed, 96 insertions(+), 72 deletions(-)

diff --git a/openhis-server-new/core-framework/src/main/java/com/core/framework/config/SecurityConfig.java b/openhis-server-new/core-framework/src/main/java/com/core/framework/config/SecurityConfig.java
index 10d07f47..cce46c80 100644
--- a/openhis-server-new/core-framework/src/main/java/com/core/framework/config/SecurityConfig.java
+++ b/openhis-server-new/core-framework/src/main/java/com/core/framework/config/SecurityConfig.java
@@ -103,9 +103,6 @@ public class SecurityConfig {
                     // 静态资源，可匿名访问
                     .antMatchers(HttpMethod.GET, "/", "/*.html", "/**/*.html", "/**/*.css", "/**/*.js", "/profile/**")
                     .permitAll()
-                    // WebSocket 握手请求允许匿名访问
-                    .antMatchers("/ws/**", "/test-ws")
-                    .permitAll()
                     .antMatchers("/swagger-ui.html", "/swagger-resources/**", "/webjars/**", "/*/api-docs", "/druid/**")
                     .permitAll()
                     .antMatchers("/patientmanage/information/**")
diff --git a/openhis-server-new/openhis-application/pom.xml b/openhis-server-new/openhis-application/pom.xml
index dd0efeab..2c60a5c1 100644
--- a/openhis-server-new/openhis-application/pom.xml
+++ b/openhis-server-new/openhis-application/pom.xml
@@ -70,12 +70,6 @@
             <artifactId>velocity-engine-core</artifactId>
         </dependency>
         
-        <!-- WebSocket 支持 -->
-        <dependency>
-            <groupId>org.springframework.boot</groupId>
-            <artifactId>spring-boot-starter-websocket</artifactId>
-        </dependency>
-        
         <!-- rabbitMQ -->
         <!-- <dependency>
             <groupId>org.springframework.boot</groupId>
diff --git a/openhis-server-new/openhis-application/src/main/java/com/openhis/web/triageandqueuemanage/appservice/impl/TriageQueueAppServiceImpl.java b/openhis-server-new/openhis-application/src/main/java/com/openhis/web/triageandqueuemanage/appservice/impl/TriageQueueAppServiceImpl.java
index 1cddfc12..d2d23fc5 100644
--- a/openhis-server-new/openhis-application/src/main/java/com/openhis/web/triageandqueuemanage/appservice/impl/TriageQueueAppServiceImpl.java
+++ b/openhis-server-new/openhis-application/src/main/java/com/openhis/web/triageandqueuemanage/appservice/impl/TriageQueueAppServiceImpl.java
@@ -15,7 +15,7 @@ import com.openhis.web.triageandqueuemanage.dto.TriageQueueActionReq;
 import com.openhis.web.triageandqueuemanage.dto.TriageQueueAddReq;
 import com.openhis.web.triageandqueuemanage.dto.TriageQueueAdjustReq;
 import com.openhis.web.triageandqueuemanage.dto.TriageQueueEncounterItem;
-import com.openhis.web.triageandqueuemanage.websocket.CallNumberWebSocket;
+import com.openhis.web.triageandqueuemanage.sse.CallNumberSseManager;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 
@@ -36,6 +36,9 @@ public class TriageQueueAppServiceImpl implements TriageQueueAppService {
     @Resource
     private TriageQueueItemService triageQueueItemService;
     
+    @Resource
+    private CallNumberSseManager callNumberSseManager;
+    
     @Resource
     private TriageCandidateExclusionService triageCandidateExclusionService;
 
@@ -242,7 +245,7 @@ public class TriageQueueAppServiceImpl implements TriageQueueAppService {
             selected.setStatus(STATUS_CALLING).setUpdateTime(LocalDateTime.now());
             triageQueueItemService.updateById(selected);
             
-            // ✅ 叫号后推送 WebSocket 消息
+            // ✅ 叫号后推送 SSE 消息（实时通知显示屏刷新）
             pushDisplayUpdate(selected.getOrganizationId(), selected.getQueueDate(), selected.getTenantId());
             
             return R.ok(true);
@@ -329,7 +332,7 @@ public class TriageQueueAppServiceImpl implements TriageQueueAppService {
 
         recalcOrders(actualOrgId, null);
         
-        // ✅ 完成后推送 WebSocket 消息
+        // ✅ 完成后推送 SSE 消息（实时通知显示屏刷新）
         pushDisplayUpdate(actualOrgId, calling.getQueueDate(), tenantId);
         
         return R.ok(true);
@@ -425,7 +428,7 @@ public class TriageQueueAppServiceImpl implements TriageQueueAppService {
 
         recalcOrders(actualOrgId, null);
         
-        // ✅ 过号重排后推送 WebSocket 消息
+        // ✅ 过号重排后推送 SSE 消息（实时通知显示屏刷新）
         pushDisplayUpdate(actualOrgId, calling.getQueueDate(), tenantId);
         
         return R.ok(true);
@@ -714,7 +717,7 @@ public class TriageQueueAppServiceImpl implements TriageQueueAppService {
     }
     
     /**
-     * 推送显示屏更新消息到 WebSocket
+     * 推送显示屏更新消息到 SSE
      * @param organizationId 科室ID
      * @param queueDate 队列日期
      * @param tenantId 租户ID
@@ -731,11 +734,11 @@ public class TriageQueueAppServiceImpl implements TriageQueueAppService {
             message.put("data", displayData);
             message.put("timestamp", System.currentTimeMillis());
             
-            // 推送到该科室的所有 WebSocket 连接
-            CallNumberWebSocket.pushToOrganization(organizationId, message);
+            // 推送到该科室的所有 SSE 连接
+            callNumberSseManager.pushToOrganization(organizationId, message);
             
         } catch (Exception e) {
-            // WebSocket 推送失败不应该影响业务逻辑
+            // SSE 推送失败不应该影响业务逻辑
             System.err.println("推送显示屏更新失败：" + e.getMessage());
         }
     }
diff --git a/openhis-server-new/openhis-application/src/main/java/com/openhis/web/triageandqueuemanage/controller/TriageQueueController.java b/openhis-server-new/openhis-application/src/main/java/com/openhis/web/triageandqueuemanage/controller/TriageQueueController.java
index 53d44177..4aabafe7 100644
--- a/openhis-server-new/openhis-application/src/main/java/com/openhis/web/triageandqueuemanage/controller/TriageQueueController.java
+++ b/openhis-server-new/openhis-application/src/main/java/com/openhis/web/triageandqueuemanage/controller/TriageQueueController.java
@@ -8,13 +8,18 @@ import com.openhis.web.triageandqueuemanage.dto.CallNumberDisplayResp;
 import com.openhis.web.triageandqueuemanage.dto.TriageQueueActionReq;
 import com.openhis.web.triageandqueuemanage.dto.TriageQueueAddReq;
 import com.openhis.web.triageandqueuemanage.dto.TriageQueueAdjustReq;
+import com.openhis.web.triageandqueuemanage.sse.CallNumberSseManager;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.format.annotation.DateTimeFormat;
+import org.springframework.http.MediaType;
 import org.springframework.util.StringUtils;
 import org.springframework.web.bind.annotation.*;
+import org.springframework.web.servlet.mvc.method.annotation.SseEmitter;
 
 import javax.annotation.Resource;
 import java.time.LocalDate;
+import java.util.HashMap;
+import java.util.Map;
 
 @RestController
 @Slf4j
@@ -23,6 +28,9 @@ public class TriageQueueController {
 
     @Resource
     private TriageQueueAppService triageQueueAppService;
+    
+    @Resource
+    private CallNumberSseManager callNumberSseManager;
 
     @GetMapping("/list")
     public R<?> list(@RequestParam(value = "organizationId", required = false) Long organizationId,
@@ -97,6 +105,44 @@ public class TriageQueueController {
             return R.fail("获取显示屏数据失败：" + e.getMessage());
         }
     }
+    
+    /**
+     * 叫号显示屏：SSE 实时推送
+     */
+    @Anonymous
+    @GetMapping(value = "/display/stream", produces = MediaType.TEXT_EVENT_STREAM_VALUE)
+    public SseEmitter streamDisplayData(
+        @RequestParam(required = false) String organizationId,
+        @RequestParam(required = false) @DateTimeFormat(pattern = "yyyy-MM-dd") LocalDate date,
+        @RequestParam(required = false) Integer tenantId
+    ) {
+        // 1) 解析科室与租户（SSE 连接根据科室分组管理）
+        Long orgId = resolveOrganizationId(organizationId);
+        if (orgId == null) {
+            SseEmitter emitter = new SseEmitter(0L);
+            Map<String, Object> error = new HashMap<>();
+            error.put("type", "error");
+            error.put("message", "organizationId参数不合法或未获取到登录用户科室");
+            callNumberSseManager.sendToEmitter(emitter, error);
+            emitter.complete();
+            return emitter;
+        }
+        Integer actualTenantId = resolveTenantId(tenantId);
+        // 2) 创建并注册 SSE 连接
+        SseEmitter emitter = callNumberSseManager.addEmitter(orgId);
+        try {
+            // 3) 连接建立后，先推送一次初始化数据
+            CallNumberDisplayResp data = triageQueueAppService.getDisplayData(orgId, date, actualTenantId);
+            Map<String, Object> init = new HashMap<>();
+            init.put("type", "init");
+            init.put("data", data);
+            init.put("timestamp", System.currentTimeMillis());
+            callNumberSseManager.sendToEmitter(emitter, init);
+        } catch (Exception e) {
+            log.error("SSE初始化数据发送失败", e);
+        }
+        return emitter;
+    }
 
     private Long resolveOrganizationId(String organizationId) {
         if (!StringUtils.hasText(organizationId)) {
diff --git a/openhis-ui-vue3/src/views/triageandqueuemanage/callnumberdisplay/index.vue b/openhis-ui-vue3/src/views/triageandqueuemanage/callnumberdisplay/index.vue
index f18fbf63..20ceafba 100644
--- a/openhis-ui-vue3/src/views/triageandqueuemanage/callnumberdisplay/index.vue
+++ b/openhis-ui-vue3/src/views/triageandqueuemanage/callnumberdisplay/index.vue
@@ -107,10 +107,13 @@ const { orgId: userOrgId, tenantId: userTenantId } = storeToRefs(userStore)
 const ORGANIZATION_ID = computed(() => (userOrgId.value ? String(userOrgId.value) : ''))
 const TENANT_ID = computed(() => (userTenantId.value ? Number(userTenantId.value) : 1))
 const API_BASE_URL = '/triage/queue'
-// WebSocket 地址（通过 Nginx 代理，路径需要加 /openhis 前缀）
-const WS_URL = computed(
-  () => `ws://${window.location.hostname}:18080/openhis/ws/call-number-display/${ORGANIZATION_ID.value}`
-)
+// SSE 地址（走后端 API 代理）
+const SSE_URL = computed(() => {
+  const baseApi = import.meta.env.VITE_APP_BASE_API || ''
+  const orgId = ORGANIZATION_ID.value
+  const tenantId = TENANT_ID.value
+  return `${baseApi}${API_BASE_URL}/display/stream?organizationId=${encodeURIComponent(orgId)}&tenantId=${tenantId}`
+})
 
 // 响应式数据
 const currentTime = ref('')
@@ -121,7 +124,7 @@ const currentPage = ref(1)
 const patientsPerPage = 5
 const autoScrollInterval = ref(null)
 const scrollInterval = 5000 // 5秒自动翻页
-const wsConnection = ref(null) // WebSocket 连接
+const sseConnection = ref(null) // SSE 连接
 const timeInterval = ref(null)
 const isFullscreen = ref(false)
 const screenContainer = ref(null)
@@ -347,72 +350,53 @@ const stopAutoScroll = () => {
 }
 
 /**
- * 初始化 WebSocket 连接
+ * 初始化 SSE 连接
  */
-const initWebSocket = () => {
+const initSse = () => {
   try {
     if (!ORGANIZATION_ID.value) {
-      console.warn('未获取到科室ID，跳过 WebSocket 连接')
+      console.warn('未获取到科室ID，跳过 SSE 连接')
       return
     }
-    console.log('正在连接 WebSocket:', WS_URL.value)
-    wsConnection.value = new WebSocket(WS_URL.value)
+    if (sseConnection.value) {
+      sseConnection.value.close()
+    }
+    console.log('正在连接 SSE:', SSE_URL.value)
+    sseConnection.value = new EventSource(SSE_URL.value)
     
-    wsConnection.value.onopen = () => {
-      console.log('WebSocket 连接成功')
+    sseConnection.value.onopen = () => {
+      console.log('SSE 连接成功')
       ElMessage.success('实时连接已建立')
     }
     
-    wsConnection.value.onmessage = (event) => {
+    sseConnection.value.onmessage = (event) => {
       try {
         const message = JSON.parse(event.data)
-        console.log('收到 WebSocket 消息:', message)
+        console.log('收到 SSE 消息:', message)
         
-        if (message.type === 'connected') {
-          console.log('WebSocket 连接确认:', message.message)
+        if (message.type === 'init') {
+          handleSseUpdate(message.data)
         } else if (message.type === 'update') {
-          // 收到更新消息，刷新显示屏数据
-          console.log('收到更新通知，刷新显示屏数据')
-          handleWebSocketUpdate(message.data)
-        } else if (message.type === 'pong') {
-          // 心跳响应
-          console.log('心跳响应')
+          handleSseUpdate(message.data)
         }
       } catch (error) {
-        console.error('解析 WebSocket 消息失败:', error)
+        console.error('解析 SSE 消息失败:', error)
       }
     }
     
-    wsConnection.value.onerror = (error) => {
-      console.error('WebSocket 错误:', error)
+    sseConnection.value.onerror = (error) => {
+      console.error('SSE 错误:', error)
       ElMessage.error('实时连接出现错误')
     }
-    
-    wsConnection.value.onclose = () => {
-      console.log('WebSocket 连接关闭，5秒后重连')
-      setTimeout(() => {
-        if (!wsConnection.value || wsConnection.value.readyState === WebSocket.CLOSED) {
-          initWebSocket()
-        }
-      }, 5000)
-    }
-    
-    // 心跳检测：每30秒发送一次 ping
-    setInterval(() => {
-      if (wsConnection.value && wsConnection.value.readyState === WebSocket.OPEN) {
-        wsConnection.value.send('ping')
-      }
-    }, 30000)
-    
   } catch (error) {
-    console.error('初始化 WebSocket 失败:', error)
+    console.error('初始化 SSE 失败:', error)
   }
 }
 
 /**
- * 处理 WebSocket 推送的更新数据
+ * 处理 SSE 推送的更新数据
  */
-const handleWebSocketUpdate = (data) => {
+const handleSseUpdate = (data) => {
   if (!data) return
   
   // 更新科室名称
@@ -435,7 +419,7 @@ const handleWebSocketUpdate = (data) => {
     waitingCount.value = data.waitingCount
   }
   
-  console.log('显示屏数据已更新（来自 WebSocket）')
+  console.log('显示屏数据已更新（来自 SSE）')
   
   // 播放语音（如果有新的叫号）
   if (data.currentCall && data.currentCall.number) {
@@ -466,13 +450,13 @@ const playVoiceNotification = (callInfo) => {
 }
 
 /**
- * 关闭 WebSocket 连接
+ * 关闭 SSE 连接
  */
-const closeWebSocket = () => {
-  if (wsConnection.value) {
-    wsConnection.value.close()
-    wsConnection.value = null
-    console.log('WebSocket 连接已关闭')
+const closeSse = () => {
+  if (sseConnection.value) {
+    sseConnection.value.close()
+    sseConnection.value = null
+    console.log('SSE 连接已关闭')
   }
 }
 
@@ -488,8 +472,8 @@ onMounted(async () => {
   // ✅ 获取初始数据（从后端 API）
   await fetchDisplayData()
   
-  // ✅ 初始化 WebSocket 连接（实时推送）
-  initWebSocket()
+  // ✅ 初始化 SSE 连接（实时推送）
+  initSse()
   
   // 启动自动滚动
   startAutoScroll()
@@ -509,7 +493,7 @@ onUnmounted(() => {
     timeInterval.value = null
   }
   stopAutoScroll()
-  closeWebSocket() // ✅ 关闭 WebSocket 连接
+  closeSse() // ✅ 关闭 SSE 连接
   if (tableContainer) {
     tableContainer.removeEventListener('mouseenter', stopAutoScroll)
     tableContainer.removeEventListener('mouseleave', startAutoScroll)