online_status迁移到redis-cluster

domain/model/tim_m/user.go

@@ -387,10 +387,10 @@ func getOnlineStatus(extIds []string) ([]interface{}, error) {
 	for _, e := range extIds {
 		keys = append(keys, redis_key.GetOnLineStatusKey(e))
 	}
-	return redisCli.RedisClient.MGet(context.Background(), keys...).Result()
+	return redisCli.RedisClusterClient.MGet(context.Background(), keys...).Result()
 }
 
 func setOnlineStatus(extId string, status uint, ttl time.Duration) error {
 	key := redis_key.GetOnLineStatusKey(extId)
-	return redisCli.RedisClient.Set(context.Background(), key, status, ttl).Err()
+	return redisCli.RedisClusterClient.Set(context.Background(), key, status, ttl).Err()
 }