";
            var_dump($headers);
        }

        $curl = curl_init();
        $timeout = 5;
        curl_setopt($curl, CURLOPT_URL, $url);
        curl_setopt($curl, CURLOPT_SSL_VERIFYPEER, false);
        curl_setopt($curl, CURLOPT_RETURNTRANSFER, 1);
        curl_setopt($curl, CURLOPT_CONNECTTIMEOUT, $timeout);
        if ($method == 'post') {
            curl_setopt($curl, CURLOPT_POST, 1);
            curl_setopt($curl, CURLOPT_POSTFIELDS, Json::encode($data));
        }
        curl_setopt($curl, CURLOPT_HTTPHEADER, $headers);
        $curl_data = curl_exec($curl);
        if (curl_error($curl)) {
            $error = '错误：' . $url . '=>' . curl_error($curl);
            throw new Exception($error);
        }
        return Json::decode($curl_data);
    }

    /**
     * 请求池
     *
     * @param array $requests
     * @return array
     */
    public function pool($requests, $data, $result = null)
    {
        $relation = $result === null ? false : true;
        $pool = new Pool($this->getClient(), $requests($data), [
            'concurrency' => $this->concurrency,
            'fulfilled' => function ($response, $index) use (&$result, $relation) {
                // this is delivered each successful response
                $relation 
                    ? $result[$index] = array_merge(
                        $result[$index],
                        ['data' => $this->getResponseData($response, $index)]
                    )
                    : $result[] = $this->getResponseData($response, $index);
            },
            'rejected' => function ($reason, $index) {
                // this is delivered each failed request
            },
        ]);
        $promise = $pool->promise();
        $promise->wait();

        return $result;
    }

    /**
     * 使用Guzz请求
     *
     * @param string $api
     * @param array $data
     * @param string $method
     * @return array
     */
    private function guzz($api, $data = [], $method = 'post')
    {
        // 客户端
        $client = $this->getClient();
        // Header头
        $data = array_filter($data, function ($item) {
            return $item !== null && $item !== '';
        });
        $response = $client->send($this->getRequest($api, $data, $method));

        return $this->getResponseData($response);
    }

    /**
     * 获取响应数据
     *
     * @param ResponseInterface $response
     * @param integer|null $index
     * @return array|void
     */
    private function getResponseData($response, $index = null)
    {
        $code = $response->getStatusCode();
        $reason = $response->getReasonPhrase();
        $content = $response->getBody()->getContents();

        \Yii::$app->custom->logs('星链响应信息', $content);
        if ($code == 200) {
            $data = Json::decode($content);
            // 返回状态码
            if ($data['status'] == 200) {
                return $data['data'] ?? [];
            }
            if (!$this->exception) {
                return [];
            }
            throw new Exception($data['msg']);
        }
        throw new Exception('查询失败');
    }

    /**
     * 获取请求
     *
     * @param array $data
     * @param string $method
     * @return Request
     */
    public function getRequest($api, $data, $method)
    {
        \Yii::$app->custom->logs('星链请求信息', $api);
        \Yii::$app->custom->logs('请求数据', $data);
        if ($this->debug) {
            echo "API:";
            var_dump($api);
            echo "
";
            echo "DATA:";
            var_dump($data);
            echo "
";
        }

        $body = empty($data) ? '{}' : Json::encode($data);
        return new Request(strtoupper($method), $api, $this->getHeaders($data), $body);
    }

    /**
     * 获取guzz客户端
     *
     * @return Client
     */
    public function getClient()
    {
        return new Client([
            'base_uri' => $this->url,
            'verify' => false
        ]);
    }

    /**
     * 获取请求头
     *
     * @param array $body
     * @return array
     */
    private function getHeaders($body = [])
    {
        mt_srand();
        // appKey、version、timeStamp、randomNumber
        $headers = [
            'appKey' => $this->app_key,
            'version' => $this->version,
            'timeStamp' => time() - 3  . '000',
            // 'timeStamp' => '1638424611703',
            'randomNumber' => mt_rand(1000000, 9999999),
            // 'randomNumber' => '5441080065398753214',
        ];

        // 签名
        $headers['sign'] = $this->getSign($headers, $body);
        $headers['Content-Type'] = 'application/json';

        \Yii::$app->custom->logs('星链请求头', $headers);
        if ($this->debug) {
            echo "HEADERS:";
            var_dump($headers);
            echo "
";
        }
        return $headers;
    }
    
    /**
     * 转换header头 curl使用
     *
     * @param array $headers
     * @return array
     */
    private function formatHeader($headers)
    {
        // 转换
        $result = [];
        foreach ($headers as $k => $v) {
            $result[] = $k . ':' . $v;
        }
        return $result;
    }

    /**
     * 获取签名
     *
     * @param array $headers
     * @param array $body
     * @return string
     */
    private function getSign($headers, $body)
    {
        $arr = array_merge($headers, $body);
        ksort($arr);

        $str = '';
        foreach ($arr as $k => $v) {
            $str .= $k . '=' . (is_array($v) ? Json::encode($v) : $v) . '&';
        }

        $str .= $this->app_secret;
        $str = trim($str);

        \Yii::$app->custom->logs('星链签名', $str);
        return md5($str);
    }

    /**
     * 设置不抛异常
     *
     * @param boolean $boolean
     * @return void
     */
    public function setNotExcption($boolean = false)
    {
        return $this->exception = false;
    }
}