<?php

namespace app\util;

use Exception;

/**
 * HTTP 请求工具类
 * 提供简单的 HTTP GET 和 POST 请求方法
 */
class HttpClient
{
    private static int $defaultTimeout = 30;

    /**
     * 发送 HTTP GET 请求
     *
     * @param string $url 请求URL
     * @param array $params 查询参数
     * @param array $headers 请求头
     * @param int $timeout 超时时间（秒）
     * @return array 响应数据（JSON解码后的数组）
     * @throws Exception
     */
    public static function httpGet(
        string $url,
        array $params = [],
        array $headers = [],
        int $timeout = 0
    ): array {
        if (!empty($params)) {
            $url .= '?' . http_build_query($params);
        }

        $ch = curl_init();

        curl_setopt($ch, CURLOPT_URL, $url);
        curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
        curl_setopt($ch, CURLOPT_TIMEOUT, $timeout ?: self::$defaultTimeout);
        curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false);

        if (!empty($headers)) {
            curl_setopt($ch, CURLOPT_HTTPHEADER, $headers);
        }

        $response = curl_exec($ch);
        $httpCode = curl_getinfo($ch, CURLINFO_HTTP_CODE);
        $error = curl_error($ch);

        // PHP 8.0+ curl 资源自动关闭，无需 curl_close()

        self::logRequest('GET', $url, [], $response, $httpCode);

        if ($error) {
            throw new Exception("HTTP GET 请求失败: {$error}");
        }

        if ($httpCode !== 200) {
            throw new Exception("HTTP GET 请求失败: HTTP {$httpCode}, Response: {$response}");
        }

        $result = json_decode($response, true);

        if (json_last_error() !== JSON_ERROR_NONE) {
            throw new Exception('JSON 解析失败: ' . $response);
        }

        return $result;
    }

    /**
     * 发送 HTTP POST 请求
     *
     * @param string $url 请求URL
     * @param array $data 请求数据
     * @param array $headers 请求头
     * @param int $timeout 超时时间（秒）
     * @return array 响应数据（JSON解码后的数组）
     * @throws Exception
     */
    public static function httpPost(
        string $url,
        array $data = [],
        array $headers = [],
        int $timeout = 0
    ): array {
        $ch = curl_init();

        curl_setopt($ch, CURLOPT_URL, $url);
        curl_setopt($ch, CURLOPT_POST, true);
        curl_setopt($ch, CURLOPT_POSTFIELDS, json_encode($data));
        curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
        curl_setopt($ch, CURLOPT_TIMEOUT, $timeout ?: self::$defaultTimeout);
        curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false);

        $defaultHeaders = [
            'Content-Type: application/json',
        ];

        curl_setopt($ch, CURLOPT_HTTPHEADER, array_merge($defaultHeaders, $headers));

        $response = curl_exec($ch);
        $httpCode = curl_getinfo($ch, CURLINFO_HTTP_CODE);
        $error = curl_error($ch);

        // PHP 8.0+ curl 资源自动关闭，无需 curl_close()

        self::logRequest('POST', $url, $data, $response, $httpCode);

        if ($error) {
            throw new Exception("HTTP POST 请求失败: {$error}");
        }

        if ($httpCode !== 200) {
            throw new Exception("HTTP POST 请求失败: HTTP {$httpCode}, Response: {$response}");
        }

        $result = json_decode($response, true);

        if (json_last_error() !== JSON_ERROR_NONE) {
            throw new Exception('JSON 解析失败: ' . $response);
        }

        return $result;
    }

    /**
     * 记录请求日志
     *
     * @param string $method 请求方法
     * @param string $url 请求URL
     * @param array $requestData 请求数据
     * @param string $response 响应数据
     * @param int $httpCode HTTP状态码
     */
    private static function logRequest(
        string $method,
        string $url,
        array $requestData,
        string $response,
        int $httpCode
    ): void {
        $emoji = $method === 'GET' ? '🌐' : '📤';
        $methodLower = strtolower($method);
        $logMessage = "{$emoji} HTTP {$method} {$url} -> HTTP {$httpCode}";

        error_log($logMessage);

        if (!empty($requestData)) {
            error_log("📤 Request: " . json_encode($requestData));
        }

        error_log("📥 Response: {$response}");
    }

    /**
     * 设置默认超时时间
     *
     * @param int $timeout 超时时间（秒）
     */
    public static function setDefaultTimeout(int $timeout): void
    {
        self::$defaultTimeout = $timeout;
    }
}