diff --git a/internal/msggateway/hub_server.go b/internal/msggateway/hub_server.go index e4124a5af..22abf17d6 100644 --- a/internal/msggateway/hub_server.go +++ b/internal/msggateway/hub_server.go @@ -88,6 +88,8 @@ func (s *Server) SuperGroupOnlineBatchPushOneMsg(ctx context.Context, req *msgga } clients, ok := s.LongConnServer.GetUserAllCons(v) if !ok { + tempT.Resp = resp + singleUserResult = append(singleUserResult, tempT) continue } log.ZDebug(ctx, "SuperGroupOnlineBatchPushOneMsg", "clients", clients) diff --git a/internal/msggateway/n_ws_server.go b/internal/msggateway/n_ws_server.go index f11891d1e..237c89666 100644 --- a/internal/msggateway/n_ws_server.go +++ b/internal/msggateway/n_ws_server.go @@ -132,6 +132,8 @@ func (ws *WsServer) registerClient(client *Client) { if clientOK { //已经有同平台的连接存在 ws.clients.Set(client.userID, client) ws.multiTerminalLoginChecker(cli) + log.ZInfo(client.ctx, "repeat login", "userID", client.userID, "platformID", client.platformID) + atomic.AddInt64(&ws.onlineUserConnNum, 1) } else { ws.clients.Set(client.userID, client) atomic.AddInt64(&ws.onlineUserConnNum, 1)