gaoyixia/application/api/controller/OpenSearch.php

<?php
namespace app\api\controller;
require_once("../vendor/alibabacloud/opensearch-sdk-php/OpenSearch/Autoloader/Autoloader.php");
header("Content-Type:text/html;charset=utf-8");
use AlibabaCloud\Client\Clients\BearerTokenClient;
use OpenSearch\Client\OpenSearchClient;
use OpenSearch\Client\DocumentClient;
use OpenSearch\Client\SearchClient;
use OpenSearch\Util\SearchParamsBuilder;

/**
 * @title OpenSearch
 * @controller OpenSearch
 * @group base
 */
class OpenSearch extends Base
{
    public $accessKeyId = 'LTAI5tJ5p12drZegeWVG33xZ';
    public $secret = '82UWAiY5e5wH8tSkRvMtqVoGO0h8SB';
    public $endPoint = 'http://opensearch-cn-shanghai.aliyuncs.com';
    public $appName = 'GYXTEST';
    public $suggestName = 'qc_ts';// 下拉提示名
    public $options = ['debug' => true];


    /**
     * @title 添加
     * @desc  添加
     * @author  qc
     * @url /api/Open_search/add
     * @method POST
     */
    public function add()
    {
        $client = new OpenSearchClient($this->accessKeyId, $this->secret, $this->endPoint, $this->options);
        //设置数据需推送到对应应用表中
        $tableName = 'dd_video_cate';
        //创建文档操作client
        $documentClient = new DocumentClient($client);
        //添加数据
        $docs_to_upload[]= [
            'cmd' => 'ADD',
            'fields' => [
                'id'=>1,
                'title'=>'qc',
            ],
        ];
        //将文档编码成json格式
        $json = json_encode($docs_to_upload);
        //提交推送文档
        $ret = $documentClient->push($json, $this->appName, $tableName);
        $ret_array = json_decode(json_encode($ret),true);
        $ret_val = json_decode($ret_array['result'],true);
        $this->success('ok',$ret_val);
    }

    /**
     * @title 删除
     * @desc  删除
     * @author  qc
     * @url /api/Open_search/delete
     * @method POST
     */
    public function delete()
    {
        $client = new OpenSearchClient($this->accessKeyId, $this->secret, $this->endPoint, $this->options);
        //设置数据需推送到对应应用表中
        $tableName = 'dd_video_cate';
        //创建文档操作client
        $documentClient = new DocumentClient($client);
        //添加数据
        $docs_to_upload[]= [
            'cmd' => 'DELETE',
            'fields' => [
                'id'=>1,
            ],
        ];
        //将文档编码成json格式
        $json = json_encode($docs_to_upload);
        //提交推送文档
        $ret = $documentClient->push($json, $this->appName, $tableName);
        $ret_array = json_decode(json_encode($ret),true);
        $ret_val = json_decode($ret_array['result'],true);
        $this->success('ok',$ret_val);
    }



    /**
     * @title 更新
     * @desc  更新
     * @author  qc
     * @url /api/Open_search/update
     * @method POST
     */
    public function update()
    {
        $client = new OpenSearchClient($this->accessKeyId, $this->secret, $this->endPoint, $this->options);
        //设置数据需推送到对应应用表中
        $tableName = 'dd_video_cate';
        //创建文档操作client
        $documentClient = new DocumentClient($client);
        //添加数据
        $docs_to_upload[]= [
            'cmd' => 'UPDATE',
            'fields' => [
                'id'=>1,
                'title'=>'aaa',
            ],
        ];
        //将文档编码成json格式
        $json = json_encode($docs_to_upload);
        //提交推送文档
        $ret = $documentClient->push($json, $this->appName, $tableName);
        $ret_array = json_decode(json_encode($ret),true);
        $ret_val = json_decode($ret_array['result'],true);
        $this->success('ok',$ret_val);
    }

    /**
     * @title 搜索
     * @desc  搜索
     * @author  qc
     * @url /api/Open_search/select
     * @method POST
     */

    public function select()
    {
        $client = new OpenSearchClient($this->accessKeyId, $this->secret, $this->endPoint, $this->options);
        // 实例化一个搜索类
        $searchClient = new SearchClient($client);
        // 实例化一个搜索参数类
        $params = new SearchParamsBuilder();
        //设置config子句的start值
        $params->setStart($this->off_set);
        //设置config子句的hit值
        $params->setHits($this->page_num);
        // 指定一个应用用于搜索
        $params->setAppName($this->appName);
        // 指定搜索关键词
        $params->setQuery("title:'亚马逊'");
        $params->setFilter('id>0');
        // 指定返回的搜索结果的格式为json
        $params->setFormat("fulljson");
        //添加排序字段
        $params->addSort('id', SearchParamsBuilder::SORT_DECREASE);
       // $params->addSort('RANK', SearchParamsBuilder::SORT_DECREASE);

        //添加distinct子句
       // $params->addDistinct(['key' => 'cate_id', 'distTimes' => 1, 'distCount' => 1, 'reserved' => 'false']);
            //添加摘要
       /* $params->addSummary(['summary_field' => 'name', 'summary_len' => 100,
                'summary_ellipsis' => "。。。", 'summary_snippet' => 2,
                'summary_element_prefix' => '<em>', 'summary_element_postfix' => '</em>']);*/
        //设置需返回哪些字段
        $params->setFetchFields(['id', 'title', 'logo']);
        //$params->addSummary(
        //    array('summary_field' => 'name', 'summary_len' => 200)
        //);
        //设置自定义参数
        //$params->setCustomParam('a', 'b');
        //$params->setCustomParam('c', 'd');
        //$params->setRouteValue('1');
        // 执行搜索，获取搜索结果
        $ret = $searchClient->execute($params->build());
        //添加raw_query参数
        //$params->setRawQuery("字符串");
        // 将json类型字符串解码
        $this->success('ok',['list'=>json_decode($ret->result,true)]);

    }



}