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-08 15:36:05 +08:00
parent 0d42fd82ff
commit 449c172641
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
im-center-server/src/main/java/cn/axzo/im/group/member/GroupMemberSyncer.java
View File

@ -57,11 +57,11 @@ public class GroupMemberSyncer {
Sets.SetView<PersonAccountAttribute> removedPersons = Sets.difference(oldPersons, newPersons); Sets.SetView<PersonAccountAttribute> removedPersons = Sets.difference(oldPersons, newPersons);
groupMemberDao.deleteByPersons(group.getTid(), removedPersons); groupMemberDao.deleteByPersons(group.getTid(), removedPersons);
Sets.SetView<PersonAccountAttribute> addedPersons = Sets.difference(newPersons, oldPersons); Sets.SetView<PersonAccountAttribute> addedPersons = Sets.difference(newPersons, oldPersons);
List<GroupMember> addedMembers = newMembers.stream() List<GroupMember> addMembers = newMembers.stream()
.filter(newMember -> addedPersons.contains(newMember.asPerson())) .filter(newMember -> addedPersons.contains(newMember.asPerson()))
.collect(toList()); .collect(toList());
if (!addedMembers.isEmpty()) if (!addMembers.isEmpty())
groupMemberDao.saveBatch(addedMembers); groupMemberDao.saveBatch(addMembers);
groupDao.updateMembersCount(group.getTid(), newMembers.size()); groupDao.updateMembersCount(group.getTid(), newMembers.size());
}); });
} }