From 3ef62d4aa5b32df5324cd0dfd02b4344844b3802 Mon Sep 17 00:00:00 2001 From: withchao <993506633@qq.com> Date: Fri, 28 Jun 2024 16:57:01 +0800 Subject: [PATCH] fix --- internal/msggateway/online.go | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/internal/msggateway/online.go b/internal/msggateway/online.go index a4a1c1f15..61549083a 100644 --- a/internal/msggateway/online.go +++ b/internal/msggateway/online.go @@ -49,7 +49,7 @@ func (ws *WsServer) ChangeOnlineStatus(concurrent int) { req := &pbuser.SetUserOnlineStatusReq{ Status: datautil.Slice(status, local2pb), } - changeStatus[i] = status[0:] + changeStatus[i] = status[:0] select { case requestChs[i] <- req: default: @@ -67,7 +67,7 @@ func (ws *WsServer) ChangeOnlineStatus(concurrent int) { req := &pbuser.SetUserOnlineStatusReq{ Status: datautil.Slice(status, local2pb), } - changeStatus[i] = status[0:] + changeStatus[i] = status[:0] select { case requestChs[i] <- req: default: @@ -100,6 +100,7 @@ func (ws *WsServer) ChangeOnlineStatus(concurrent int) { case now := <-scanTicker.C: pushUserState(ws.clients.GetAllUserStatus(now.Add(-cachekey.OnlineExpire/3), now)...) case state := <-ws.clients.UserState(): + log.ZDebug(context.Background(), "user online change", "userID", state.UserID, "online", state.Online, "offline", state.Offline) pushUserState(state) } }