admin_consumer/app/Controller/EsController.php

<?php

declare (strict_types = 1);

namespace App\Controller;

use App\JsonRpc\EsServiceInterface;
use App\JsonRpc\UserServiceInterface;
use App\Tools\Result;
use Hyperf\Context\Context;
use Hyperf\Di\Annotation\Inject;
use Hyperf\HttpServer\Contract\RequestInterface;
use Hyperf\HttpServer\Contract\ResponseInterface;
use Hyperf\Validation\Contract\ValidatorFactoryInterface;

/**
 * Class EsController
 * @package App\Controller
 */
class EsController extends AbstractController
{
    #[Inject]
    protected ValidatorFactoryInterface $validationFactory;

    /**
     * @var EsServiceInterface
     */
    #[Inject]
    private $EsServiceClient;
    #[Inject]
    private UserServiceInterface $userServiceClient;
    public function createIndex()
    {
        
        $requireData = $this->request->all();
        $result = $this->EsServiceClient->createIndex($requireData)??[];
        return $result && $result['code'] != 0 ? Result::success($result['data']) : Result::error($result['message']);
    }
    public function deleteIndex(){
        $requireData = $this->request->all();
        $result = $this->EsServiceClient->deleteIndex($requireData)??[];
        return $result && $result['code'] != 0 ? Result::success($result['data']) : Result::error($result['message']);
    }
    public function getDocument(){
        $requireData = $this->request->all();
        $result = $this->EsServiceClient->getDocument($requireData)??[];
        return $result && $result['code'] != 0 ? Result::success($result['data']) : Result::error($result['message']);
    }
    public function updateData(){
        $requireData = $this->request->all();
        $result = $this->EsServiceClient->updateData($requireData)??[];
        return $result && $result['code'] != 0 ? Result::success($result['data']) : Result::error($result['message']);
    }
    public function deleteData(){
        $requireData = $this->request->all();
        $result = $this->EsServiceClient->deleteData($requireData)??[];
        return $result && $result['code'] != 0 ? Result::success($result['data']) : Result::error($result['message']);
    }
    public function associateData(){
        $requireData = $this->request->all();
        $result = $this->EsServiceClient->associateData($requireData)??[];
        return $result && $result['code'] != 0 ? Result::success($result['data']) : Result::error($result['message']);
    }
    public function searchIndex(){
        $requireData = $this->request->all();
        $result = $this->EsServiceClient->searchIndex($requireData)??[];
        return $result && $result['code'] != 0 ? Result::success($result['data']) : Result::error($result['message']);
    }


}