diff --git a/im-center-server/src/main/java/cn/axzo/im/group/GroupBroadcaster.java b/im-center-server/src/main/java/cn/axzo/im/group/GroupBroadcaster.java index c5886c7..4ba1f3c 100644 --- a/im-center-server/src/main/java/cn/axzo/im/group/GroupBroadcaster.java +++ b/im-center-server/src/main/java/cn/axzo/im/group/GroupBroadcaster.java @@ -27,13 +27,14 @@ class GroupBroadcaster { private final GroupDao groupDao; void fireGroupChanged(Group group, MqEventType eventType) { + Group effectiveGroup = groupDao.getById(group.getId()); GroupChangedMessage message = new GroupChangedMessage(); - message.setGroup(BeanMapper.copyBean(group, GroupInfo.class)); + message.setGroup(BeanMapper.copyBean(effectiveGroup, GroupInfo.class)); Event event = Event.builder() - .targetId(group.getTid() + "") + .targetId(effectiveGroup.getTid() + "") .targetType(eventType.getModel()) .eventCode(eventType.getEventCode()) - .shardingKey(group.getTid() + "") + .shardingKey(effectiveGroup.getTid() + "") .data(message) .build(); mqProducer.send(event); @@ -49,10 +50,10 @@ class GroupBroadcaster { message.setGroup(BeanMapper.copyBean(effectiveGroup, GroupInfo.class)); message.setMember(BeanMapper.copyBean(account, GroupMemberInfo.class)); Event event = Event.builder() - .targetId(group.getTid() + "") + .targetId(effectiveGroup.getTid() + "") .targetType(eventType.getModel()) .eventCode(eventType.getEventCode()) - .shardingKey(group.getTid() + "") + .shardingKey(effectiveGroup.getTid() + "") .data(message) .build(); mqProducer.send(event);