wangli/im-center
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

REQ-3345: 发送消息时重新查询数据

Browse Source
This commit is contained in:
yanglin 2025-02-07 13:50:06 +08:00
parent 3c64e82a5c
commit c274f7d105
1 changed files with 6 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
im-center-server/src/main/java/cn/axzo/im/group/GroupBroadcaster.java
View File

@ -27,13 +27,14 @@ class GroupBroadcaster {
private final GroupDao groupDao; private final GroupDao groupDao;
void fireGroupChanged(Group group, MqEventType eventType) { void fireGroupChanged(Group group, MqEventType eventType) {
Group effectiveGroup = groupDao.getById(group.getId());
GroupChangedMessage message = new GroupChangedMessage(); GroupChangedMessage message = new GroupChangedMessage();
message.setGroup(BeanMapper.copyBean(group, GroupInfo.class)); message.setGroup(BeanMapper.copyBean(effectiveGroup, GroupInfo.class));
Event event = Event.builder() Event event = Event.builder()
.targetId(group.getTid() + "") .targetId(effectiveGroup.getTid() + "")
.targetType(eventType.getModel()) .targetType(eventType.getModel())
.eventCode(eventType.getEventCode()) .eventCode(eventType.getEventCode())
.shardingKey(group.getTid() + "") .shardingKey(effectiveGroup.getTid() + "")
.data(message) .data(message)
.build(); .build();
mqProducer.send(event); mqProducer.send(event);
@ -49,10 +50,10 @@ class GroupBroadcaster {
message.setGroup(BeanMapper.copyBean(effectiveGroup, GroupInfo.class)); message.setGroup(BeanMapper.copyBean(effectiveGroup, GroupInfo.class));
message.setMember(BeanMapper.copyBean(account, GroupMemberInfo.class)); message.setMember(BeanMapper.copyBean(account, GroupMemberInfo.class));
Event event = Event.builder() Event event = Event.builder()
.targetId(group.getTid() + "") .targetId(effectiveGroup.getTid() + "")
.targetType(eventType.getModel()) .targetType(eventType.getModel())
.eventCode(eventType.getEventCode()) .eventCode(eventType.getEventCode())
.shardingKey(group.getTid() + "") .shardingKey(effectiveGroup.getTid() + "")
.data(message) .data(message)
.build(); .build();
mqProducer.send(event); mqProducer.send(event);