<?php
namespace app\models;

use Yii;
use yii\elasticsearch\Query;

class Index_data_query extends Query
{
    /*
     * 返回所有index
     */
    public function getAllindex(){
        $rows = $this->createCommand();//使用query类连接配置的集群，获取节点
        $rows = json_decode(json_encode( $rows),true);
        $nodes=$rows['db']['nodes'];
        $output = array();
        $index_arr = array();
        foreach ($nodes as $k=>$v){
            $url = $v['protocol']."://".$v['http_address']."/_cat/indices?format=json";//以json的格式返回所有节点下面所有的index相关信息
            $ch = curl_init($url) ;
            curl_setopt($ch, CURLOPT_RETURNTRANSFER, true) ; // 获取数据返回
            curl_setopt($ch, CURLOPT_BINARYTRANSFER, true) ; // 在启用 CURLOPT_RETURNTRANSFER 时候将获取数据返回
            $output[] = curl_exec($ch) ;
        }
        if($output){
            foreach ($output as $kk=>$vv){
                $info_arr = json_decode($vv,true);
                if($info_arr){
                    foreach ($info_arr as $i_k=>$i_v){
                        $index_arr[] = $i_v['index'];//只获取index的名称
                    }
                }
            }
        }
        $index_arr = array_unique($index_arr);
        return $index_arr;
    }
}