add log

internal/rpc/user/user.go

@@ -251,11 +251,11 @@ 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, "SubscribeUsersStatus pre")
+		log.ZDebug(ctx, "SubscribeUsersStatus pre", "userID", req.UserID, "userids", req.UserIDs)
 		err = s.UserDatabase.SubscribeUsersStatus(ctx, req.UserID, req.UserIDs)
 		var status []*pbuser.OnlineStatus
 		status, err = s.UserDatabase.GetUserStatus(ctx, req.UserIDs)
-		log.ZDebug(ctx, "SubscribeUsersStatus after")
+		log.ZDebug(ctx, "SubscribeUsersStatus after", "userID", req.UserID, "userids", req.UserIDs)
 		if err != nil {
 			return nil, err
 		}

pkg/common/db/controller/user.go

@@ -180,6 +180,7 @@ func (u *userDatabase) CountRangeEverydayTotal(ctx context.Context, start time.T
 
 // SubscribeUsersStatus Subscribe or unsubscribe a user's presence status
 func (u *userDatabase) SubscribeUsersStatus(ctx context.Context, userID string, userIDs []string) error {
+	log.ZDebug(ctx, "----mongo---controller-----pre", "userid", userID, "userids", userIDs)
 	err := u.mongoDB.AddSubscriptionList(ctx, userID, userIDs)
 	log.ZDebug(ctx, "----mongo---controller-----")
 	return err
@@ -211,6 +212,7 @@ func (u *userDatabase) GetSubscribedList(ctx context.Context, userID string) ([]
 
 // GetUserStatus get user status
 func (u *userDatabase) GetUserStatus(ctx context.Context, userIDs []string) ([]*user.OnlineStatus, error) {
+	log.ZDebug(ctx, "========redis status========pre", "userids", userIDs)
 	onlineStatusList, err := u.cache.GetUserStatus(ctx, userIDs)
 	log.ZDebug(ctx, "========redis status========")
 	return onlineStatusList, err