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-06 11:47:31 +08:00
parent 7bd2ca0d07
commit 4bc6ec2f8a
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/GroupManager.java
View File

@ -80,7 +80,9 @@ public class GroupManager {
group = groupDao.getById(group.getId()); group = groupDao.getById(group.getId());
groupBroadcaster.fireGroupChanged(group, MqEventType.GROUP_CREATED); groupBroadcaster.fireGroupChanged(group, MqEventType.GROUP_CREATED);
groupMemberSyncer.syncMembers(group); groupMemberSyncer.syncMembers(group);
groupBroadcaster.fireMembersChanged(group, groupMemberDao.getByTid(nimResponse.getTid()), MqEventType.GROUP_ADD_MEMBERS); groupBroadcaster.fireMembersChanged(group,
groupMemberDao.getByTid(nimResponse.getTid()),
MqEventType.GROUP_ADD_MEMBERS);
GroupCreateResponse response = new GroupCreateResponse(); GroupCreateResponse response = new GroupCreateResponse();
response.setTid(nimResponse.getTid()); response.setTid(nimResponse.getTid());
response.setAccountsNotFound(imAccounts.getAccountNotFoundPersons( response.setAccountsNotFound(imAccounts.getAccountNotFoundPersons(
@ -132,8 +134,7 @@ public class GroupManager {
BizAssertions.assertTrue(nimResponse.isSuccess(), "添加群成员失败: {}", nimResponse.getDesc()); BizAssertions.assertTrue(nimResponse.isSuccess(), "添加群成员失败: {}", nimResponse.getDesc());
// sync members 2 // sync members 2
groupMemberSyncer.syncMembers(group); groupMemberSyncer.syncMembers(group);
groupBroadcaster.fireMembersChanged( groupBroadcaster.fireMembersChanged(group,
group,
groupMemberDao.getByPersons(group.getTid(), toAddMembers), groupMemberDao.getByPersons(group.getTid(), toAddMembers),
MqEventType.GROUP_ADD_MEMBERS); MqEventType.GROUP_ADD_MEMBERS);
GroupAddMembersResponse response = new GroupAddMembersResponse(); GroupAddMembersResponse response = new GroupAddMembersResponse();
@ -164,8 +165,8 @@ public class GroupManager {
log.info("移除群成员, request={}, response={}", nimRequest, nimResponse); log.info("移除群成员, request={}, response={}", nimRequest, nimResponse);
groupMemberSyncer.syncMembers(group); groupMemberSyncer.syncMembers(group);
// 不比较直接发消息 // 不比较直接发消息
groupBroadcaster.fireMembersChanged( groupBroadcaster.fireMembersChanged(group,
group, toRemoveMembers, MqEventType.GROUP_REMOVE_MEMBERS); toRemoveMembers, MqEventType.GROUP_REMOVE_MEMBERS);
} }
@NotNull @NotNull