From b62e3ba4685e85d03bd0b58a9ebfde74a9aee1b6 Mon Sep 17 00:00:00 2001 From: pluto <2631223275@qq.com> Date: Wed, 16 Aug 2023 12:24:13 +0800 Subject: [PATCH] debug --- pkg/common/db/cache/user.go | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/pkg/common/db/cache/user.go b/pkg/common/db/cache/user.go index b6059af74..539065fe1 100644 --- a/pkg/common/db/cache/user.go +++ b/pkg/common/db/cache/user.go @@ -18,6 +18,7 @@ import ( "context" "encoding/json" "github.com/OpenIMSDK/protocol/constant" + "github.com/OpenIMSDK/tools/log" "hash/crc32" "strconv" "time" @@ -204,6 +205,7 @@ func (u *UserCacheRedis) GetUserStatus(ctx context.Context, userIDs []string) ([ // SetUserStatus Set the user status and save it in redis. func (u *UserCacheRedis) SetUserStatus(ctx context.Context, list []*user.OnlineStatus) error { + log.ZDebug(ctx, "====================================SetUserStatus=============================", "list", list) for _, status := range list { var isNewKey int64 UserIDNum := crc32.ChecksumIEEE([]byte(status.UserID)) @@ -219,11 +221,13 @@ func (u *UserCacheRedis) SetUserStatus(ctx context.Context, list []*user.OnlineS } if isNewKey == 0 { _, err = u.rdb.HSet(ctx, key, status.UserID, string(jsonData)).Result() + log.ZDebug(ctx, "====================================SetUserStatus isNewKey == 0=============================", "userid", status.UserID, "jsonData", string(jsonData)) if err != nil { return errs.Wrap(err) } u.rdb.Expire(ctx, key, userOlineStatusExpireTime) } else { + log.ZDebug(ctx, "====================================SetUserStatus isNewKey != 0=============================", "userid", status.UserID, "jsonData", string(jsonData)) result, err := u.rdb.HGet(ctx, key, status.UserID).Result() if err != nil { return errs.Wrap(err)