diff --git a/internal/push/push_to_client.go b/internal/push/push_to_client.go index 9c38c4069..31cafb0f0 100644 --- a/internal/push/push_to_client.go +++ b/internal/push/push_to_client.go @@ -202,7 +202,7 @@ func (p *Pusher) Push2SuperGroup(ctx context.Context, groupID string, msg *sdkws if msg.ContentType != constant.SignalingNotification { notNotificationUserIDs, err := p.conversationLocalCache.GetRecvMsgNotNotifyUserIDs(ctx, groupID) if err != nil { - log.ZError(ctx, "GetRecvMsgNotNotifyUserIDs failed", err, "groupID", groupID) + // log.ZError(ctx, "GetRecvMsgNotNotifyUserIDs failed", err, "groupID", groupID) return err } needOfflinePushUserIDs = utils.DifferenceString(notNotificationUserIDs, needOfflinePushUserIDs) diff --git a/internal/rpc/user/user.go b/internal/rpc/user/user.go index 5db39a8d1..7f13c3aab 100644 --- a/internal/rpc/user/user.go +++ b/internal/rpc/user/user.go @@ -98,11 +98,9 @@ func (s *userServer) UpdateUserInfo(ctx context.Context, req *pbuser.UpdateUserI if err != nil { return nil, err } - go func() { - for _, v := range friends { - s.notificationSender.FriendInfoUpdatedNotification(ctx, req.UserInfo.UserID, v, mcontext.GetOpUserID(ctx)) - } - }() + for _, v := range friends { + s.notificationSender.FriendInfoUpdatedNotification(ctx, req.UserInfo.UserID, v, mcontext.GetOpUserID(ctx)) + } s.notificationSender.UserInfoUpdatedNotification(ctx, mcontext.GetOpUserID(ctx), req.UserInfo.UserID) return resp, nil }