gaoyixia/application/common/service/Elastic.php

<?php
namespace app\common\service;
use \Exception;
use AlibabaCloud\Tea\Exception\TeaError;
use AlibabaCloud\Tea\Utils\Utils;
use Darabonba\OpenApi\Models\Config;
use AlibabaCloud\Tea\Utils\Utils\RuntimeOptions;
//require_once '../vendor/autoload.php';
/*require_once '../vendor/elastic/transport/src/NodePool/NodePoolInterface.php';
require_once '../vendor/elastic/transport/src/NodePool/Selector/RoundRobin.php';
require_once '../vendor/elastic/transport/src/NodePool/Resurrect/NoResurrect.php';
require_once '../vendor/elasticsearch/elasticsearch/src/ClientBuilder.php';
require_once '../vendor/elastic/transport/src/TransportBuilder.php';
require_once '../vendor/elastic/transport/src/NodePool/SimpleNodePool.php';
require_once '../vendor/elastic/transport/src/Exception/NoNodeAvailableException.php';
require_once '../vendor/elastic/transport/src/NodePool/Node.php';
require_once '../vendor/elastic/transport/src/Transport.php';
require_once '../vendor/php-http/httplug/src/HttpAsyncClient.php';
require_once '../vendor/php-http/discovery/src/Psr17FactoryDiscovery.php';
require_once '../vendor/php-http/discovery/src/Exception/NoCandidateFoundException.php';

require_once '../vendor/php-http/discovery/src/Strategy/CommonPsr17ClassesStrategy.php';*/

/**
 * Elasticsearch
 * Class Elasticsearch
 */
class Elastic
{

     static $access_key    = 'LTAI5tJ5p12drZegeWVG33xZ';// key
     static $access_secret = '82UWAiY5e5wH8tSkRvMtqVoGO0h8SB';//secret
     static $InstanceId = 'es-cn-x0r34s6ff000qy2qe';
    // static $host = 'http://es-cn-wwo34hg5t0006xtsj.public.elasticsearch.aliyuncs.com:9200';
     static $host = 'http://es-cn-x0r34s6ff000qy2qe.public.elasticsearch.aliyuncs.com:9200';
     static $user_name = 'elastic';
     static $password = '1234QWERasdf';


    /**
     * 云产品管控接口 start
     * 也许用不到
     */

    /**
     * 使用AK&SK初始化账号Client
     * @param string $accessKeyId
     * @param string $accessKeySecret
     * @return Elasticsearch Client
     */
    public static function createClient(){
        $config = new Config([
            // 必填，您的 AccessKey ID
            "accessKeyId" => static::$access_key,
            // 必填，您的 AccessKey Secret
            "accessKeySecret" => static::$access_secret,
        ]);
        // 访问的域名
        $config->endpoint = "elasticsearch.cn-shanghai.aliyuncs.com";
        //$config->endpoint = "es-cn-wwo34hg5t0006xtsj.elasticsearch.aliyuncs.com";
        return new Elasticsearch($config);
    }

    public static function body()
    {
        return [
            'mappings'=>[
                'properties'=>[
                    'id'=>['type'=>'long'],
                    'status'=>['type'=>'byte'],
                    'logo'=>['type'=>'text'],
                    'name'=>['type'=>'text'],
                ]
            ]
        ];
    }

    /**
     * 云产品管控接口 end
     */

    /**
     * elasticsearch API
     */

    // elastic链接
    public static function es(){

        //  if(!$es) $es = \Elasticsearch\ClientBuilder::create()->setHosts(['es-cn-wwo34hg5t0006xtsj.public.elasticsearch.aliyuncs.com:9200'])->build();
        $es = \Elasticsearch\ClientBuilder::create()
            ->setHosts([static::$host])
            ->setBasicAuthentication(static::$user_name, static::$password)
            ->build();
        return $es;
    }

    //获取mapping（结构）
    public static function  getMapping($index)
    {
        return  self::es()->indices()->getMapping(['index'=>$index]);
    }

    public static function getProperties($module)
    {
        switch ($module) {
            default:
                $ret_val =  [
                    'module'=>['type'=>'keyword'],//模块
                    'id'=>['type'=>'keyword'],
                    'title'=>['type'=>'text'],
                    'label'=>['type'=>'text'],
                    'desc'=>['type'=>'text'],
                    'desc_text'=>['type'=>'text'],
                    'content'=>['type'=>'text'],
                    'detail'=>['type'=>'text'],
                    'user_id'=>['type'=>'integer'],
                    'is_deleted'=>['type'=>'integer'],
                    'status'=>['type'=>'integer'],
                    'create_at'=>['type'=>'date'],
                    'release_time'=>['type'=>'date'],
                    'extend'=>['type'=>'text'],
                    'level' => ['type'=>'integer'],
                    'read_num'=>['type'=>'integer'],
                    'comment_num'=>['type'=>'integer'],
                    'like_num'=>['type'=>'integer'],
                    'transmit_num'=>['type'=>'integer'],
                    'collect_num'=>['type'=>'integer'],
                    'down_num'=>['type'=>'integer'],
                    'is_over'=>['type'=>'integer'],
                    'city'=>['type'=>'keyword'],
                ];
                break;
        }
        return $ret_val;
    }

    // 创建索引
    public static function createIndex($module)
    {
        $client = self::es();
        $index = [
            "index"=>$module,
            "body"=>[
                "mappings"=>[
                    "properties"=>static::getProperties($module)
                ]
            ]
        ];
        $response = $client->indices()->create($index);
        return $response;
    }


    // 添加字段
    public static function addColumn($module)
    {
        $client = self::es();
        $index = [
            "index"=>$module,
            "body"=>[
               // "properties"=>['level' => ['type'=>'integer']]
              // "properties"=>['is_over' => ['type'=>'integer']]
               "properties"=>['city' => ['type'=>'keyword']]
            ]
        ];
        $response = $client->indices()->putMapping($index);
        return $response;
    }


    /**
     *  删除索引
     * @param $index
     * @return array
     */
    public static function delIndex($index)
    {
        return  self::es()->indices()->delete(['index'=>$index]);
    }


    /**
     * 判断索引是否存在
     * @param $index
     * @return bool
     */
    public static function checkIndex($index)
    {
        return self::es()->indices()->exists(['index'=>$index]);
    }

    // 添加数据【插入文档】
    public static function add($index,$id,$body)
    {
        $doc = [
            "index"=>$index,
            "id"=>$id,
            "body"=>$body
        ];
        return self::es()->index($doc);
    }


    // 删除数据
    public static function delete($index,$id)
    {
        return self::es()->delete(['index'=>$index,'id'=>$id]);
    }

    // 获取详情
    public static function getInfo($index,$id)
    {
        return  self::es()->get(['index'=>$index,'id'=>$id]);
    }

    // 更新数据
    public static function update($index,$id,$body)
    {
        $doc = [
            'index'=>$index,
            'id'=>$id,
            'body'=>[
                'doc'=>$body
            ]
        ];
      return  self::es()->update($doc);
    }

    /**
     *查询
     * @param $index
     * @param $match
     * @return array
     */
    public static function select($index,$select)
    {
        $list = static::es()->search($select);
        return $list;
    }

























}