blackteay/open-im-server
1
0
Fork 0
mirror of https://github.com/openimsdk/open-im-server.git synced 2026-01-07 12:17:02 +08:00
Code Issues Packages Projects Releases Wiki Activity

delete simple log

Browse Source
This commit is contained in:
pluto 2023-08-04 19:03:49 +08:00
parent 8f2fdb6957
commit e9fbfb78e4
2 changed files with 3 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
internal/rpc/user/user.go
View File

@ -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
}

5
pkg/common/db/controller/user.go
View File

@ -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
}