From a6e12e7d47fd4d2640f41eeeaa517473b1576236 Mon Sep 17 00:00:00 2001
From: wanggeng <450292408@qq.com>
Date: Wed, 17 Nov 2021 23:25:00 +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

---
 .../handler/text/WebSocketTextHandler.java        | 15 ++++++++++++---
 1 file changed, 12 insertions(+), 3 deletions(-)

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 612477b3..ba727fa5 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
@@ -49,7 +49,16 @@ public class WebSocketTextHandler {
                 // 客户端注册消息
                 statusBody = clientRegisterSession(ctx.channel(), clientSocketMessage);
             } else if (MessageTypeEnum.MESSAGE.getValue() == clientSocketMessage.getType()) {
-                // 文本消息
+                sendText(ctx.channel(), clientSocketMessage);
+            } else if (MessageTypeEnum.MESSAGE_HREF.getValue() == clientSocketMessage.getType()) {
+                sendText(ctx.channel(), clientSocketMessage);
+            } else if (MessageTypeEnum.MESSAGE_IMAGE.getValue() == clientSocketMessage.getType()) {
+                sendText(ctx.channel(), clientSocketMessage);
+            } else if (MessageTypeEnum.MESSAGE_FILE.getValue() == clientSocketMessage.getType()) {
+                sendText(ctx.channel(), clientSocketMessage);
+            } else if (MessageTypeEnum.MESSAGE_AUDIO.getValue() == clientSocketMessage.getType()) {
+                sendText(ctx.channel(), clientSocketMessage);
+            } else if (MessageTypeEnum.MESSAGE_VIDEO.getValue() == clientSocketMessage.getType()) {
                 sendText(ctx.channel(), clientSocketMessage);
             } else if (MessageTypeEnum.MESSAGE_GROUP.getValue() == clientSocketMessage.getType()) {
                 // 群发消息
@@ -82,7 +91,7 @@ public class WebSocketTextHandler {
             statusBody = new StatusBody(StatusEnum.SESSION_ERROR.getValue(), StatusEnum.SESSION_ERROR, e.getMessage());
         } catch (CustomHandleException e) {
             statusBody = new StatusBody(StatusEnum.CUSTOM_HANDLE_ERROR.getValue(), StatusEnum.SESSION_ERROR, e.getMessage());
-        }catch (JSONException e) {
+        } catch (JSONException e) {
             clientSocketMessage = new WebSocketClientMessage();
             clientSocketMessage.setSystem(true);
             clientSocketMessage.setType(MessageTypeEnum.MESSAGE_SYSTEM.getValue());
@@ -99,7 +108,7 @@ public class WebSocketTextHandler {
     /**
      * 发送接收状态
      *
-     * @param clientSocketMessage 客户端消息
+     * @param webSocketClientMessage 客户端消息
      */
     private void sendReceiveStatus(WebSocketClientMessage webSocketClientMessage) {
         List<String> toUserIds = new ArrayList<>(Sets.newHashSet(webSocketClientMessage.getTo().split(",")));