diff --git a/kernel-s-message/message-sdk-db/src/main/java/cn/stylefeng/roses/kernel/message/db/MessageDbServiceImpl.java b/kernel-s-message/message-sdk-db/src/main/java/cn/stylefeng/roses/kernel/message/db/MessageDbServiceImpl.java
index a48d14e84..2618d793e 100644
--- a/kernel-s-message/message-sdk-db/src/main/java/cn/stylefeng/roses/kernel/message/db/MessageDbServiceImpl.java
+++ b/kernel-s-message/message-sdk-db/src/main/java/cn/stylefeng/roses/kernel/message/db/MessageDbServiceImpl.java
@@ -110,13 +110,12 @@ public class MessageDbServiceImpl implements MessageApi {
                 sendMsgList.add(sysMessage);
             }
         });
-
-        // 给用户发送通知
-        for (Long userId : userIdSet) {
-            socketOperatorApi.sendMsgOfUserSession(ServerMessageTypeEnum.SYS_NOTICE_MSG_TYPE.getCode(), userId.toString(), messageSendRequest);
-        }
         sysMessageService.saveBatch(sendMsgList);
 
+        // 给用户发送通知
+        for (SysMessage item : sendMsgList) {
+            socketOperatorApi.sendMsgOfUserSession(ServerMessageTypeEnum.SYS_NOTICE_MSG_TYPE.getCode(), item.getReceiveUserId().toString(), item);
+        }
     }
 
     @Override
diff --git a/kernel-s-message/message-sdk-db/src/main/java/cn/stylefeng/roses/kernel/message/db/entity/SysMessage.java b/kernel-s-message/message-sdk-db/src/main/java/cn/stylefeng/roses/kernel/message/db/entity/SysMessage.java
index 6089e9e08..8a45bc7c0 100644
--- a/kernel-s-message/message-sdk-db/src/main/java/cn/stylefeng/roses/kernel/message/db/entity/SysMessage.java
+++ b/kernel-s-message/message-sdk-db/src/main/java/cn/stylefeng/roses/kernel/message/db/entity/SysMessage.java
@@ -25,6 +25,8 @@
 package cn.stylefeng.roses.kernel.message.db.entity;
 
 import cn.stylefeng.roses.kernel.db.api.pojo.entity.BaseEntity;
+import com.alibaba.fastjson.annotation.JSONField;
+import com.alibaba.fastjson.serializer.ToStringSerializer;
 import com.baomidou.mybatisplus.annotation.*;
 import lombok.Data;
 import lombok.EqualsAndHashCode;
@@ -46,18 +48,21 @@ public class SysMessage extends BaseEntity {
      * 主键
      */
     @TableId(value = "message_id", type = IdType.ASSIGN_ID)
+    @JSONField(serializeUsing= ToStringSerializer.class)
     private Long messageId;
 
     /**
      * 接收用户id
      */
     @TableField(value = "receive_user_id")
+    @JSONField(serializeUsing= ToStringSerializer.class)
     private Long receiveUserId;
 
     /**
      * 发送用户id
      */
     @TableField(value = "send_user_id")
+    @JSONField(serializeUsing= ToStringSerializer.class)
     private Long sendUserId;
 
     /**
@@ -94,6 +99,7 @@ public class SysMessage extends BaseEntity {
      * 业务id
      */
     @TableField(value = "business_id")
+    @JSONField(serializeUsing= ToStringSerializer.class)
     private Long businessId;
 
     /**