|
@@ -188,11 +188,19 @@ func (*groupApp) DeleteMember(ctx context.Context, groupId int64, userId int64, |
|
|
|
|
|
|
|
|
// GetMembers 获取群组成员 |
|
|
// GetMembers 获取群组成员 |
|
|
func (*groupApp) GetMembers(ctx context.Context, groupId, limit int64) ([]*pb.GroupMember, error) { |
|
|
func (*groupApp) GetMembers(ctx context.Context, groupId, limit int64) ([]*pb.GroupMember, error) { |
|
|
group, err := repo.GroupRepo.GetLimit(groupId, limit) |
|
|
|
|
|
if err != nil { |
|
|
|
|
|
return nil, err |
|
|
|
|
|
|
|
|
if limit == 0 { |
|
|
|
|
|
group, err := repo.GroupRepo.Get(groupId) |
|
|
|
|
|
if err != nil { |
|
|
|
|
|
return nil, err |
|
|
|
|
|
} |
|
|
|
|
|
return group.GetMembers(ctx) |
|
|
|
|
|
} else { |
|
|
|
|
|
group, err := repo.GroupRepo.GetLimit(groupId, limit) |
|
|
|
|
|
if err != nil { |
|
|
|
|
|
return nil, err |
|
|
|
|
|
} |
|
|
|
|
|
return group.GetMembers(ctx) |
|
|
} |
|
|
} |
|
|
return group.GetMembers(ctx) |
|
|
|
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
// SendMessage 发送群组消息 |
|
|
// SendMessage 发送群组消息 |
|
|