From 1038015ba72a261464a63e52cdfae2f9466d7544 Mon Sep 17 00:00:00 2001
From: icey-yu <1186114839@qq.com>
Date: Tue, 10 Sep 2024 16:29:14 +0800
Subject: [PATCH] fix: add logs

---
 pkg/rpccache/online.go | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

diff --git a/pkg/rpccache/online.go b/pkg/rpccache/online.go
index 26b283de9..172235a57 100644
--- a/pkg/rpccache/online.go
+++ b/pkg/rpccache/online.go
@@ -143,6 +143,7 @@ func (o *OnlineCache) doSubscribe(rdb redis.UniversalClient, fn func(ctx context
 		o.Cond.Wait()
 	}
 	o.Lock.Unlock()
+	log.ZInfo(ctx, "begin doSubscribe")
 
 	doMessage := func(message *redis.Message) {
 		userID, platformIDs, err := useronline.ParseUserOnlineStatus(message.Payload)
@@ -150,7 +151,7 @@ func (o *OnlineCache) doSubscribe(rdb redis.UniversalClient, fn func(ctx context
 			log.ZError(ctx, "OnlineCache setHasUserOnline redis subscribe parseUserOnlineStatus", err, "payload", message.Payload, "channel", message.Channel)
 			return
 		}
-
+		log.ZDebug(ctx, fmt.Sprintf("get subscribe %s message", cachekey.OnlineChannel), "useID", userID, "platformIDs", platformIDs)
 		switch o.fullUserCache {
 		case true:
 			if len(platformIDs) == 0 {
@@ -280,7 +281,7 @@ func (o *OnlineCache) GetUsersOnline(ctx context.Context, userIDs []string) ([]s
 		}
 	}
 
-	log.ZWarn(ctx, "get users online", nil, "online users length", len(userIDs), "offline users length", len(offlineUserIDs), "cost", time.Since(t))
+	log.ZInfo(ctx, "get users online", nil, "online users length", len(userIDs), "offline users length", len(offlineUserIDs), "cost", time.Since(t))
 	return userIDs, offlineUserIDs, nil
 }