From 5d5dadf0d52c33f1d49f25d00c27f3df4c63087c Mon Sep 17 00:00:00 2001 From: sonjinyon <2476687577@qq.com> Date: Wed, 13 Nov 2024 10:43:51 +0800 Subject: [PATCH] =?UTF-8?q?=E6=B7=BB=E5=8A=A0=E5=AE=A2=E6=9C=8D=E9=85=8D?= =?UTF-8?q?=E7=BD=AE?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../module/infra/api/websocket/WebSocketSenderApi.java | 7 +++++++ .../module/infra/api/websocket/WebSocketSenderApiImpl.java | 5 +++++ 2 files changed, 12 insertions(+) diff --git a/yudao-module-infra/yudao-module-infra-api/src/main/java/cn/iocoder/yudao/module/infra/api/websocket/WebSocketSenderApi.java b/yudao-module-infra/yudao-module-infra-api/src/main/java/cn/iocoder/yudao/module/infra/api/websocket/WebSocketSenderApi.java index 6694776..c2b87ea 100644 --- a/yudao-module-infra/yudao-module-infra-api/src/main/java/cn/iocoder/yudao/module/infra/api/websocket/WebSocketSenderApi.java +++ b/yudao-module-infra/yudao-module-infra-api/src/main/java/cn/iocoder/yudao/module/infra/api/websocket/WebSocketSenderApi.java @@ -39,6 +39,9 @@ public interface WebSocketSenderApi { */ void send(String sessionId, String messageType, String messageContent); + + void send(String sessionId, Long userId, Integer userType,String messageType, String messageContent); + default void sendObject(Integer userType, Long userId, String messageType, Object messageContent) { send(userType, userId, messageType, JsonUtils.toJsonString(messageContent)); } @@ -51,4 +54,8 @@ public interface WebSocketSenderApi { send(sessionId, messageType, JsonUtils.toJsonString(messageContent)); } + default void sendObject(String sessionId, Long userId, Integer userType,String messageType, Object messageContent) { + send(sessionId,userId,userType, messageType, JsonUtils.toJsonString(messageContent)); + } + } diff --git a/yudao-module-infra/yudao-module-infra-biz/src/main/java/cn/iocoder/yudao/module/infra/api/websocket/WebSocketSenderApiImpl.java b/yudao-module-infra/yudao-module-infra-biz/src/main/java/cn/iocoder/yudao/module/infra/api/websocket/WebSocketSenderApiImpl.java index 046cd2f..3584634 100644 --- a/yudao-module-infra/yudao-module-infra-biz/src/main/java/cn/iocoder/yudao/module/infra/api/websocket/WebSocketSenderApiImpl.java +++ b/yudao-module-infra/yudao-module-infra-biz/src/main/java/cn/iocoder/yudao/module/infra/api/websocket/WebSocketSenderApiImpl.java @@ -31,4 +31,9 @@ public class WebSocketSenderApiImpl implements WebSocketSenderApi { webSocketMessageSender.send(sessionId, messageType, messageContent); } + @Override + public void send(String sessionId, Long userId, Integer userType, String messageType, String messageContent) { + webSocketMessageSender.send(sessionId, userId,userType,messageType, messageContent); + } + }