backend/java-mall
6
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

im问题修复-rabbimq发送异常

Browse Source
This commit is contained in:
liyj 2025-11-18 16:11:56 +08:00
parent 485cad13ed
commit a047598703
1 changed files with 11 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
mall-im/src/main/java/com/suisung/mall/im/common/websocket/service/MessageConsumerService.java
View File

@ -140,25 +140,25 @@ public class MessageConsumerService {
// 设置基本字段 // 设置基本字段
if (messageMap.get("toid") != null) { if (messageMap.get("toid") != null) {
sendVO.setToid((String) messageMap.get("toid")); sendVO.setToid(String.valueOf(messageMap.get("toid")));
} }
if (messageMap.get("id") != null) { if (messageMap.get("id") != null) {
sendVO.setId((String) messageMap.get("id")); sendVO.setId(String.valueOf(messageMap.get("id")));
} }
if (messageMap.get("content") != null) { if (messageMap.get("content") != null) {
sendVO.setContent((String) messageMap.get("content")); sendVO.setContent(String.valueOf(messageMap.get("content")));
} }
if (messageMap.get("type") != null) { if (messageMap.get("type") != null) {
sendVO.setType((String) messageMap.get("type")); sendVO.setType(String.valueOf(messageMap.get("type")));
} }
if (messageMap.get("username") != null) { if (messageMap.get("username") != null) {
sendVO.setUsername((String) messageMap.get("username")); sendVO.setUsername(String.valueOf(messageMap.get("username")));
} }
if (messageMap.get("avatar") != null) { if (messageMap.get("avatar") != null) {
sendVO.setAvatar((String) messageMap.get("avatar")); sendVO.setAvatar(String.valueOf(messageMap.get("avatar")));
} }
if (messageMap.get("fromid") != null) { if (messageMap.get("fromid") != null) {
sendVO.setFromid((String) messageMap.get("fromid")); sendVO.setFromid(String.valueOf(messageMap.get("fromid")));
} }
if (messageMap.get("time") != null) { if (messageMap.get("time") != null) {
sendVO.setTime((Long) messageMap.get("time")); sendVO.setTime((Long) messageMap.get("time"));
@ -167,16 +167,16 @@ public class MessageConsumerService {
sendVO.setStatus((Integer) messageMap.get("status")); sendVO.setStatus((Integer) messageMap.get("status"));
} }
if (messageMap.get("msg_type") != null) { if (messageMap.get("msg_type") != null) {
sendVO.setMsg_type((String) messageMap.get("msg_type")); sendVO.setMsg_type(String.valueOf(messageMap.get("msg_type")));
} }
if (messageMap.get("item_id") != null) { if (messageMap.get("item_id") != null) {
sendVO.setItem_id(Long.valueOf((String) messageMap.get("item_id"))); sendVO.setItem_id(Long.valueOf((String) messageMap.get("item_id")));
} }
if (messageMap.get("message_length") != null) { if (messageMap.get("message_length") != null) {
sendVO.setMessage_length((String) messageMap.get("message_length")); sendVO.setMessage_length(String.valueOf(messageMap.get("message_length")));
} }
if (messageMap.get("zid") != null) { if (messageMap.get("zid") != null) {
sendVO.setZid((String) messageMap.get("zid")); sendVO.setZid(String.valueOf(messageMap.get("zid")));
} }
if (messageMap.get("user_id") != null) { if (messageMap.get("user_id") != null) {
sendVO.setUser_id((Integer) messageMap.get("user_id")); sendVO.setUser_id((Integer) messageMap.get("user_id"));
@ -185,7 +185,7 @@ public class MessageConsumerService {
sendVO.setFriend_id((Integer) messageMap.get("friend_id")); sendVO.setFriend_id((Integer) messageMap.get("friend_id"));
} }
if (messageMap.get("sendmethod") != null) { if (messageMap.get("sendmethod") != null) {
sendVO.setSendmethod((String) messageMap.get("sendmethod")); sendVO.setSendmethod(String.valueOf( messageMap.get("sendmethod")));
} }
if (messageMap.get("message_id") != null) { if (messageMap.get("message_id") != null) {
sendVO.setMessage_id(Integer.valueOf((String) messageMap.get("message_id"))); sendVO.setMessage_id(Integer.valueOf((String) messageMap.get("message_id")));