Tenlion/wg-basic
5
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

新增不同类型消息

Browse Source
This commit is contained in:
wanggeng 2021-11-17 23:25:00 +08:00
parent 4af0ebbd6b
commit a6e12e7d47
1 changed files with 12 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
module-instant-message/src/main/java/ink/wgink/module/instantmessage/websocket/handler/text/WebSocketTextHandler.java
View File

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