mirror of
https://github.com/openimsdk/open-im-server.git
synced 2025-05-17 09:44:47 +08:00
group
This commit is contained in:
parent
66ad26b71b
commit
bd6fb0b831
@ -219,6 +219,22 @@ func (g *groupDatabase) PageGroupMember(ctx context.Context, groupIDs []string,
|
|||||||
}
|
}
|
||||||
return uint32(len(totalGroupMembers)), totalGroupMembers, nil
|
return uint32(len(totalGroupMembers)), totalGroupMembers, nil
|
||||||
} else {
|
} else {
|
||||||
|
if groupIDs == nil {
|
||||||
|
for _, userID := range userIDs {
|
||||||
|
groupIDs, err := g.cache.GetJoinedGroupIDs(ctx, userID)
|
||||||
|
if err != nil {
|
||||||
|
return 0, nil, err
|
||||||
|
}
|
||||||
|
for _, groupID := range groupIDs {
|
||||||
|
groupMembers, err := g.cache.GetGroupMembersPage(ctx, groupID, nil, pageNumber, showNumber)
|
||||||
|
if err != nil {
|
||||||
|
return 0, nil, err
|
||||||
|
}
|
||||||
|
totalGroupMembers = append(totalGroupMembers, groupMembers...)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
return
|
||||||
|
}
|
||||||
for _, groupID := range groupIDs {
|
for _, groupID := range groupIDs {
|
||||||
groupMembers, err := g.cache.GetGroupMembersPage(ctx, groupID, userIDs, pageNumber, showNumber)
|
groupMembers, err := g.cache.GetGroupMembersPage(ctx, groupID, userIDs, pageNumber, showNumber)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
|
Loading…
x
Reference in New Issue
Block a user