gaoyixia/application/common/service/OpenSearch.php

<?php
namespace app\common\service;
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;

/**
 *
 * Class SerBase
 */
class OpenSearch
{

    public static $accessKeyId = 'LTAI5tJ5p12drZegeWVG33xZ';
    public static $secret = '82UWAiY5e5wH8tSkRvMtqVoGO0h8SB';
    public static $endPoint = 'http://opensearch-cn-shanghai.aliyuncs.com';
    public static $appName = 'GYXTEST';
    public static $suggestName = 'qc_ts';// 下拉提示名
    public static $tableName = 'dd_video_cate';// 结构
    public static $options = ['debug' => true];

    /**
     * opensearch数据推送
     * @param $module 模块
     * @param $id  记录id
     * @param int $type 推送类型1新增2更新
     * @return mixed
     */
    public static function push($module,$id,$type = 1)
    {
        $client = new OpenSearchClient(static::$accessKeyId, static::$secret, static::$endPoint, static::$options);
        //设置数据需推送到对应应用表中
        //创建文档操作client
        $documentClient = new DocumentClient($client);
        $push_data= [];
        $push_data['cmd'] = $type == 1 ?  'ADD' : 'UPDATE';
        $push_data['fields'] = [];
        switch ($module)
        {
            case 'video':
                break;
            case 'atricle':
                break;
            case 'datum':
                break;
        }
        //提交推送文档
        $ret = $documentClient->push(json_encode([$push_data]), static::$appName, static::$tableName);
        $ret_array = json_decode(json_encode($ret),true);
        $ret_val = json_decode($ret_array['result'],true);
        return  $ret_val;
    }


}