<?php

namespace App\Utils;

use GuzzleHttp\Client;
use GuzzleHttp\HandlerStack;
use Hyperf\Guzzle\CoroutineHandler;
use GuzzleHttp\Exception\ClientException;
use Hyperf\Di\Annotation\Inject;
use Hyperf\Guzzle\ClientFactory;
class Http
{
    use \Hyperf\Di\Aop\ProxyTrait;
    use \Hyperf\Di\Aop\PropertyHandlerTrait;
    function __construct()
    {
        $this->__handlePropertyHandler(__CLASS__);
    }
    /**
     * @Inject
     * @var ClientFactory
     */
    private $clientFactory;
    function get_host($url, &$path)
    {
        $pos = strpos($url, "/", 8);
        if (!$pos) {
            $path = "/";
            return $url;
        }
        $path = substr($url, $pos);
        return substr($url, 0, $pos);
    }
    public function get_content_length($url, $time_out = 60)
    {
        if ($url == "") {
            return 0;
        }
        try {
            $options = ['base_uri' => "", 'handler' => HandlerStack::create(new CoroutineHandler()), 'timeout' => $time_out, 'swoole' => ['timeout' => $time_out, 'socket_buffer_size' => 1024 * 1024 * 2]];
            $path = "";
            $host = $this->get_host($url, $path);
            if ($host == "") {
                return 0;
            }
            $options["base_uri"] = $host;
            $client = $this->clientFactory->create($options);
            $response = $client->get($path);
            if ($response->getStatusCode() != 200) {
                return 0;
            }
            $str_size = $response->getHeader('Content-Length');
            $size = intval($str_size[0]);
            return $size;
        } catch (ClientException $e) {
            //获取协程中出现的异常。
            $response_e = $e->getResponse();
        }
        return 0;
    }
    public function get_web_result($url, $time_out = 10)
    {
        if ($url == "") {
            return "";
        }
        $path = "";
        $host = $this->get_host($url, $path);
        if ($host == "") {
            return "";
        }
        $options = ['base_uri' => $host, 'handler' => HandlerStack::create(new CoroutineHandler()), 'timeout' => $time_out, 'swoole' => ['timeout' => $time_out, 'socket_buffer_size' => 1024 * 1024 * 2]];
        try {
            //var_dump($this->clientFactory);
            $client = $this->clientFactory->create($options);
            $response = $client->get($path);
            if ($response->getStatusCode() == 200) {
                $strContent = $response->getBody()->getContents();
                //echo "$strContent\r\n";
                return $strContent;
            }
        } catch (ClientException $e) {
            //获取协程中出现的异常。
            var_dump($e->getResponse());
        }
        return "";
    }
    public function post_web_result($url, $post_data, $time_out = 10)
    {
        if ($url == "") {
            return "";
        }
        $path = "";
        $host = $this->get_host($url, $path);
        if ($host == "") {
            return "";
        }
        $options = ['base_uri' => $host, 'handler' => HandlerStack::create(new CoroutineHandler()), 'timeout' => $time_out, 'swoole' => ['timeout' => $time_out, 'socket_buffer_size' => 1024 * 1024 * 2]];
        try {
            $client = $this->clientFactory->create($options);
            $response = $client->request('POST', $url, ['form_params' => $post_data]);
            //debug
            //$response = $client->request('POST', $url, ['form_params' => $post_data,'debug' => true]);
            if ($response->getStatusCode() == 200) {
                $strContent = $response->getBody()->getContents();
                //echo "$strContent\r\n";
                return $strContent;
            }
        } catch (ClientException $e) {
            //获取协程中出现的异常。
            //var_dump($e->getResponse());
        }
        return "";
    }
    public function post_json_result($url, $post_data, $time_out = 10)
    {
        if ($url == "") {
            return "";
        }
        $path = "";
        $host = $this->get_host($url, $path);
        if ($host == "") {
            return "";
        }
        $options = ['base_uri' => $host, 'handler' => HandlerStack::create(new CoroutineHandler()), 'timeout' => $time_out, 'swoole' => ['timeout' => $time_out, 'socket_buffer_size' => 1024 * 1024 * 2]];
        try {
            $client = $this->clientFactory->create($options);
            if (is_array($post_data)) {
                $response = $client->request('POST', $url, ['body' => json_encode($post_data), "headers" => ['Accept' => 'application/json']]);
            } else {
                $response = $client->request('POST', $url, ['body' => $post_data, "headers" => ['Accept' => 'application/json']]);
            }
            //debug
            //$response = $client->request('POST', $url, ['form_params' => $post_data,'debug' => true]);
            if ($response->getStatusCode() == 200) {
                $strContent = $response->getBody()->getContents();
                //echo "$strContent\r\n";
                return $strContent;
            }
        } catch (ClientException $e) {
            //获取协程中出现的异常。
            var_dump($e->getResponse());
        }
        return "";
    }
}