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

im分布式测试方案-单机测试

Browse Source
This commit is contained in:
liyj 2025-11-19 17:40:00 +08:00
parent fddd1750a1
commit 1b97836bea
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
mall-im/src/main/java/com/suisung/mall/im/common/websocket/service/onchat/MallsuiteImSocketHandler.java
View File

@ -130,7 +130,7 @@ public class MallsuiteImSocketHandler implements WebSocketHandler {
chat.setMsg(msg); chat.setMsg(msg);
chat.setType("friend"); chat.setType("friend");
chat.setCreate_date(new Date()); chat.setCreate_date(new Date());
boolean isSuccess = distributedMessageService.sendToUser(String.valueOf(toUserId), sendVO,localSessionManager.getUserSessions()); boolean isSuccess = distributedMessageService.sendToUser(String.valueOf(receiveDTO.getTo().getFriend_id()), sendVO,localSessionManager.getUserSessions());
if (isSuccess) { if (isSuccess) {
chat.setStatus("1"); chat.setStatus("1");
} else { } else {
@ -140,7 +140,7 @@ public class MallsuiteImSocketHandler implements WebSocketHandler {
sendVO.setMsg_type("text"); sendVO.setMsg_type("text");
sendVO.setMessage_length("0"); sendVO.setMessage_length("0");
sendVO.setId(to.getId()); sendVO.setId(to.getId());
distributedMessageService.sendToUser(String.valueOf(toUserId), sendVO,localSessionManager.getUserSessions()); distributedMessageService.sendToUser(String.valueOf(receiveDTO.getTo().getFriend_id()), sendVO,localSessionManager.getUserSessions());
chat.setStatus("0"); chat.setStatus("0");
} }
chatHistoryService.saveNew(chat); chatHistoryService.saveNew(chat);