From c274f7d105bd4ae90d84846bdb37cc840a2a9fba Mon Sep 17 00:00:00 2001 From: yanglin Date: Fri, 7 Feb 2025 13:50:06 +0800 Subject: [PATCH] =?UTF-8?q?REQ-3345:=20=E5=8F=91=E9=80=81=E6=B6=88?= =?UTF-8?q?=E6=81=AF=E6=97=B6=E9=87=8D=E6=96=B0=E6=9F=A5=E8=AF=A2=E6=95=B0?= =?UTF-8?q?=E6=8D=AE?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../main/java/cn/axzo/im/group/GroupBroadcaster.java | 11 ++++++----- 1 file changed, 6 insertions(+), 5 deletions(-) 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);