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 toUserIds = new ArrayList<>(Sets.newHashSet(webSocketClientMessage.getTo().split(",")));