From 644d25b07f6341c64825bb2004b8752bb0a70ef8 Mon Sep 17 00:00:00 2001 From: wanggeng <450292408@qq.com> Date: Wed, 17 Nov 2021 23:27:15 +0800 Subject: [PATCH] =?UTF-8?q?=E6=96=B0=E5=A2=9E=E4=B8=8D=E5=90=8C=E7=B1=BB?= =?UTF-8?q?=E5=9E=8B=E6=B6=88=E6=81=AF?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../websocket/handler/text/WebSocketTextHandler.java | 10 ++++++++++ 1 file changed, 10 insertions(+) diff --git a/module-instant-message/src/main/java/ink/wgink/module/instantmessage/websocket/handler/text/WebSocketTextHandler.java b/module-instant-message/src/main/java/ink/wgink/module/instantmessage/websocket/handler/text/WebSocketTextHandler.java index ba727fa5..3b23feb7 100644 --- a/module-instant-message/src/main/java/ink/wgink/module/instantmessage/websocket/handler/text/WebSocketTextHandler.java +++ b/module-instant-message/src/main/java/ink/wgink/module/instantmessage/websocket/handler/text/WebSocketTextHandler.java @@ -63,6 +63,16 @@ public class WebSocketTextHandler { } else if (MessageTypeEnum.MESSAGE_GROUP.getValue() == clientSocketMessage.getType()) { // 群发消息 sendGroupText(ctx.channel(), clientSocketMessage); + } else if (MessageTypeEnum.MESSAGE_GROUP_HREF.getValue() == clientSocketMessage.getType()) { + sendGroupText(ctx.channel(), clientSocketMessage); + } else if (MessageTypeEnum.MESSAGE_GROUP_IMAGE.getValue() == clientSocketMessage.getType()) { + sendGroupText(ctx.channel(), clientSocketMessage); + } else if (MessageTypeEnum.MESSAGE_GROUP_FILE.getValue() == clientSocketMessage.getType()) { + sendGroupText(ctx.channel(), clientSocketMessage); + } else if (MessageTypeEnum.MESSAGE_GROUP_AUDIO.getValue() == clientSocketMessage.getType()) { + sendGroupText(ctx.channel(), clientSocketMessage); + } else if (MessageTypeEnum.MESSAGE_GROUP_VIDEO.getValue() == clientSocketMessage.getType()) { + sendGroupText(ctx.channel(), clientSocketMessage); } else if (MessageTypeEnum.SEARCH_ONLINE_USER.getValue() == clientSocketMessage.getType()) { // 用户在线状态 listOnlineUser(ctx.channel(), clientSocketMessage);