qimall/addons/QiShangTong/common/expand/sdk/qishangtong/AbstractRequest.php

<?php

namespace addons\QiShangTong\common\expand\sdk\qishangtong;

use GuzzleHttp\Client;
use GuzzleHttp\Exception\ClientException;
use GuzzleHttp\Exception\GuzzleException;
use Psr\Http\Message\ResponseInterface;
use yii\helpers\Json;

abstract class AbstractRequest
{

    protected $config = [];

    protected $method = 'post';

    protected $route = '';

    //  默认为表单格式，可选参数 form_params | json | multipart | body | query | cookies | allow_redirects
    protected $params_key = 'form_params';

    //  请求错误信息
    protected $error = '';

    //  请求参数
    protected $request_option = [];

    /**
     * @var ResponseInterface
     */
    protected $response;

    /**
     * @var ModelInterface
     */
    protected $paramsModel;

    //  响应数据
    protected $responseData = [];

    //  响应错误信息
    protected $respError = '';

    //  原始响应内容
    protected $rawContent = '';

    /**
     * @var array
     */
    protected $headers = [];

    /**
     * 额外的query参数
     * @var array
     */
    protected $query = [];

    /**
     * @param array $config
     */
    public function __construct(array $config = [])
    {
        $this->config = $config;
    }

    /**
     * @return $this
     */
    public function get()
    {
        $this->method = 'get';
        return $this;
    }

    /**
     * @return $this
     */
    public function post()
    {
        $this->method = 'post';
        return $this;
    }

    protected function getHost()
    {
//        if (true) return 'http://test-open.dongguajie.com';
        return 'http://openapi.dongguajie.com';
    }

    /**
     * @param ModelInterface|null $model
     * @return $this
     * @throws GuzzleException
     */
    public function send(ModelInterface $model = null)
    {

        $client = new Client([
            'base_uri'  => $this->getHost(),
            'headers'   => $this->headers,
            'timeout'   => 30
        ]);

        if (!empty($model)) {
            $this->paramsModel = $model;
            if (in_array($this->params_key, ['multipart'])) {
                foreach ($model->toArray() as $name => $value) {
                    $this->request_option[$this->params_key][] = [
                        "name"      => $name,
                        "contents"  => file_get_contents($value),
                        "filename"  => md5($value . time()),
                    ];
                }
            } else {
                $this->request_option[$this->params_key] = empty($model->toArray()) && $this->params_key == 'json' ? new \stdClass() : $model->toArray();
            }
//            $this->request_option['debug'] = true;
        }

        if (!empty($this->query)) {
            $this->request_option['query'] = array_merge($this->request_option['query'] ?? [], $this->query);
        }

        try {
            $this->response = $client->request($this->method, $this->route, $this->request_option);
        } catch (ClientException $e) {
            $ret = Json::decode($e->getResponse()->getBody()->getContents());
            $this->error = $ret['msg'] ?? $e->getMessage();
        }
        return $this;
    }

    /**
     * @return ResponseInterface
     */
    public function getResponse()
    {
        return $this->response;
    }

    /**
     * @return array
     */
    public function toArray()
    {
        if (empty($this->responseData)) {
            mb_internal_encoding("UTF-8");
            $this->rawContent = $this->response->getBody()->getContents();
            $this->rawContent = mb_convert_encoding($this->rawContent, "UTF-8");
            $this->responseData = Json::decode($this->rawContent);
        }
        return $this->responseData;
    }

    /**
     * @return mixed|string
     */
    public function getRawContent()
    {
        return $this->rawContent;
    }

    /**
     * @return mixed|string
     */
    public function getError()
    {
        return $this->error;
    }

    /**
     * 响应错误
     * @return string
     */
    public function respError()
    {
        if (empty($this->respError)) {
            if (empty($this->paramsModel)) {
                $this->respError = 'params model is empty!';
            } else {
                $this->respError = $this->paramsModel->valid($this->toArray());
            }
        }
        return $this->respError;
    }

    /**
     * @param array $headers
     * @return $this
     */
    public function withHeaders(array $headers)
    {
        $this->headers = $headers;
        return $this;
    }

    /**
     * @param array $params
     * @return $this
     */
    public function withQuery(array $params)
    {
        $this->query = $params;
        return $this;
    }

    /**
     * @return string
     */
    public function getRoute(): string
    {
        return $this->route;
    }
}