From e9fbfb78e493e1c82439040712ed1d8180528226 Mon Sep 17 00:00:00 2001 From: pluto <2631223275@qq.com> Date: Fri, 4 Aug 2023 19:03:49 +0800 Subject: [PATCH] delete simple log --- internal/rpc/user/user.go | 5 +++-- pkg/common/db/controller/user.go | 5 ----- 2 files changed, 3 insertions(+), 7 deletions(-) diff --git a/internal/rpc/user/user.go b/internal/rpc/user/user.go index 355f11b6e..5425a9c13 100644 --- a/internal/rpc/user/user.go +++ b/internal/rpc/user/user.go @@ -251,11 +251,12 @@ 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", "userID", req.UserID, "userids", req.UserIDs) err = s.UserDatabase.SubscribeUsersStatus(ctx, req.UserID, req.UserIDs) + if err != nil { + return nil, err + } var status []*pbuser.OnlineStatus status, err = s.UserDatabase.GetUserStatus(ctx, req.UserIDs) - log.ZDebug(ctx, "SubscribeUsersStatus after", "userID", req.UserID, "userids", req.UserIDs) if err != nil { return nil, err } diff --git a/pkg/common/db/controller/user.go b/pkg/common/db/controller/user.go index 1c3ce1cd3..a867899d9 100644 --- a/pkg/common/db/controller/user.go +++ b/pkg/common/db/controller/user.go @@ -18,7 +18,6 @@ import ( "context" unRelationTb "github.com/OpenIMSDK/Open-IM-Server/pkg/common/db/table/unrelation" "github.com/OpenIMSDK/protocol/user" - "github.com/OpenIMSDK/tools/log" "time" "github.com/OpenIMSDK/Open-IM-Server/pkg/common/db/cache" @@ -180,9 +179,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 } @@ -212,9 +209,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 }