diff --git a/internal/push/push_handler.go b/internal/push/push_handler.go index 249622a592..f83074eba2 100644 --- a/internal/push/push_handler.go +++ b/internal/push/push_handler.go @@ -187,17 +187,18 @@ func (c *ConsumerHandler) GetConnsAndOnlinePush(ctx context.Context, msg *sdkws. onlineUserIDs []string offlineUserIDs []string ) - for _, userID := range pushToUserIDs { - online, err := c.onlineCache.GetUserOnline(ctx, userID) - if err != nil { - return nil, err - } - if online { - onlineUserIDs = append(onlineUserIDs, userID) - } else { - offlineUserIDs = append(offlineUserIDs, userID) - } - } + onlineUserIDs = pushToUserIDs + //for _, userID := range pushToUserIDs { + // online, err := c.onlineCache.GetUserOnline(ctx, userID) + // if err != nil { + // return nil, err + // } + // if online { + // onlineUserIDs = append(onlineUserIDs, userID) + // } else { + // offlineUserIDs = append(offlineUserIDs, userID) + // } + //} log.ZDebug(ctx, "GetConnsAndOnlinePush online cache", "sendID", msg.SendID, "recvID", msg.RecvID, "groupID", msg.GroupID, "sessionType", msg.SessionType, "clientMsgID", msg.ClientMsgID, "serverMsgID", msg.ServerMsgID, "offlineUserIDs", offlineUserIDs, "onlineUserIDs", onlineUserIDs) var result []*msggateway.SingleMsgToUserResults if len(onlineUserIDs) > 0 {