diff --git a/mall-im/src/main/java/com/suisung/mall/im/common/websocket/service/onchat/MallsuiteImSocketHandler.java b/mall-im/src/main/java/com/suisung/mall/im/common/websocket/service/onchat/MallsuiteImSocketHandler.java
index 5efe29c2..0d238ce4 100644
--- a/mall-im/src/main/java/com/suisung/mall/im/common/websocket/service/onchat/MallsuiteImSocketHandler.java
+++ b/mall-im/src/main/java/com/suisung/mall/im/common/websocket/service/onchat/MallsuiteImSocketHandler.java
@@ -130,7 +130,7 @@ public class MallsuiteImSocketHandler implements WebSocketHandler {
                     chat.setMsg(msg);
                     chat.setType("friend");
                     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) {
                         chat.setStatus("1");
                     } else {
@@ -140,7 +140,7 @@ public class MallsuiteImSocketHandler implements WebSocketHandler {
                         sendVO.setMsg_type("text");
                         sendVO.setMessage_length("0");
                         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");
                     }
                     chatHistoryService.saveNew(chat);