update

2 years ago · 0348e66287
parent 33fb4dfd8f
commit 0348e66287
1 changed files with 1 additions and 0 deletions
--- a/internal/rpc/user/user.go
+++ b/internal/rpc/user/user.go
@ -251,6 +251,7 @@ func (s *userServer) GetAllUserID(ctx context.Context, req *pbuser.GetAllUserIDR
 // SubscribeOrCancelUsersStatus Subscribe online or cancel online users.
 func (s *userServer) SubscribeOrCancelUsersStatus(ctx context.Context, req *pbuser.SubscribeOrCancelUsersStatusReq) (resp *pbuser.SubscribeOrCancelUsersStatusResp, err error) {
 	if req.Genre == constant.SubscriberUser {
+		log.ZDebug(ctx, "========== SubscribeOrCancelUsersStatus_pre ======= ", err)
 		err = s.UserDatabase.SubscribeUsersStatus(ctx, req.UserID, req.UserIDs)
 		var status []*pbuser.OnlineStatus
 		status, err = s.UserDatabase.GetUserStatus(ctx, req.UserIDs)