gitee
/
roses
mirror of https://gitee.com/stylefeng/roses
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

新增消息id,修改发送给前端的数据为字符串类型

pull/22/head
rays 2021-06-21 16:02:05 +08:00
parent 2bd4b82ec0
commit 767fa4cb58
2 changed files with 10 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
kernel-s-message/message-sdk-db/src/main/java/cn/stylefeng/roses/kernel/message/db/MessageDbServiceImpl.java
View File

@ -110,13 +110,12 @@ public class MessageDbServiceImpl implements MessageApi {
sendMsgList.add(sysMessage); sendMsgList.add(sysMessage);
} }
}); });
// 给用户发送通知
for (Long userId : userIdSet) {
socketOperatorApi.sendMsgOfUserSession(ServerMessageTypeEnum.SYS_NOTICE_MSG_TYPE.getCode(), userId.toString(), messageSendRequest);
}
sysMessageService.saveBatch(sendMsgList); sysMessageService.saveBatch(sendMsgList);
// 给用户发送通知
for (SysMessage item : sendMsgList) {
socketOperatorApi.sendMsgOfUserSession(ServerMessageTypeEnum.SYS_NOTICE_MSG_TYPE.getCode(), item.getReceiveUserId().toString(), item);
}
} }
@Override @Override

6
kernel-s-message/message-sdk-db/src/main/java/cn/stylefeng/roses/kernel/message/db/entity/SysMessage.java
View File

@ -25,6 +25,8 @@
package cn.stylefeng.roses.kernel.message.db.entity; package cn.stylefeng.roses.kernel.message.db.entity;
import cn.stylefeng.roses.kernel.db.api.pojo.entity.BaseEntity; 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 com.baomidou.mybatisplus.annotation.*;
import lombok.Data; import lombok.Data;
import lombok.EqualsAndHashCode; import lombok.EqualsAndHashCode;
@ -46,18 +48,21 @@ public class SysMessage extends BaseEntity {
* 主键 * 主键
*/ */
@TableId(value = "message_id", type = IdType.ASSIGN_ID) @TableId(value = "message_id", type = IdType.ASSIGN_ID)
@JSONField(serializeUsing= ToStringSerializer.class)
private Long messageId; private Long messageId;
/** /**
* 接收用户id * 接收用户id
*/ */
@TableField(value = "receive_user_id") @TableField(value = "receive_user_id")
@JSONField(serializeUsing= ToStringSerializer.class)
private Long receiveUserId; private Long receiveUserId;
/** /**
* 发送用户id * 发送用户id
*/ */
@TableField(value = "send_user_id") @TableField(value = "send_user_id")
@JSONField(serializeUsing= ToStringSerializer.class)
private Long sendUserId; private Long sendUserId;
/** /**
@ -94,6 +99,7 @@ public class SysMessage extends BaseEntity {
* 业务id * 业务id
*/ */
@TableField(value = "business_id") @TableField(value = "business_id")
@JSONField(serializeUsing= ToStringSerializer.class)
private Long businessId; private Long businessId;
/** /**