fn_b/app/Services/TomTool/HttpV2.php

<?php

// 版本：25-12-12

declare(strict_types=1);

namespace App\Services\TomTool;

use App\Services\TomTool\Flow;
use Exception;

/**
 
 默认：
    method:post
 
 new:
    HttpV2::make($url)
 
 基本：
    HttpV2::make($url)->send()
 
 进阶：
    HttpV2::make($url, "get")->setDataA($aData)->enableJsonAs()->enableAsync()->optMethod("get")->send();
 
 action:
    send()
 
 data:
    xData()
    sData()
    jData()
    sData()
 
 set:
    optMethod()
    enableJsonAs()
    enableJsonSend()
    enableJsonReturn()
 
 @note:
    默认关闭 SSL 验证（适用于开发环境），生产环境建议开启
    异步模式下不会返回响应内容，仅快速触发请求
 
 */


class HttpV2
{
    protected string $method;
    protected $data = [];
    protected string $url;
    protected bool $sendJson = false;
    protected bool $returnJson = false;
    protected bool $async = false;
    // 匈牙利命名法，仅新增一个 token 变量
    protected string $sToken = '';

    public static function make(string $url, string $method = 'post'): self
    {
        $instance = new self();
        $instance->url = $url;
        $instance->optMethod($method);
        return $instance;
    }
    
    public function optMethod(string $method): self
    {
        $this->method = strtolower($method);
        return $this;
    }

    /**
     * 新增：支持携带 Token
     * 如果不传值，默认从环境变量 token_base 获取
     */
    public function withToken(?string $sToken = null): self
    {
        $this->sToken = $sToken ?? (string)env('token_base', false);
        return $this;
    }
    
    public function setDataX($xData)
    {
        $this->setData($xData);
        return $this;
    }
    
    public function setDataA($aData)
    {
        $this->setData($aData);
        return $this;
    }
    
    public function setDataS($sData)
    {
        $this->setData($sData);
        return $this;
    }
    
    public function setData($xData)
    {
        $this->data = $xData;
        return $this;
    }

    public function enableJsonSend(bool $flag = true): self
    {
        $this->sendJson = $flag;
        return $this;
    }

    public function enableJsonReturn(bool $flag = true): self
    {
        $this->returnJson = $flag;
        return $this;
    }
    
    public function enableJsonAs(): self
    {
        $this->sendJson = true;
        $this->returnJson = true;
        return $this;
    }

    public function enableAsync(bool $flag = true): self
    {
        $this->async = $flag;
        return $this;
    }

    public function send(): string
    {
        $oFlow = Flow::make("HttpV2::send");
        
        $ch = curl_init();
        $headers = [];

        // --- 核心嵌入：如果 sToken 有值且不是 false，塞进 Header ---
        if ($this->sToken && $this->sToken !== 'false') {
            $headers[] = 'Authorization: Bearer ' . $this->sToken;
        }

        // 构建 URL 和请求体 (完全保留原样)
        if ($this->method === 'get') {
            $url = $this->url . '?' . http_build_query($this->data);
            curl_setopt($ch, CURLOPT_URL, $url);
            curl_setopt($ch, CURLOPT_HTTPGET, true);
        } else {
            curl_setopt($ch, CURLOPT_URL, $this->url);
            $payload = $this->sendJson ? json_encode($this->data) : http_build_query($this->data);
            curl_setopt($ch, CURLOPT_POSTFIELDS, $payload);

            if ($this->method === 'post') {
                curl_setopt($ch, CURLOPT_POST, true);
            } else {
                curl_setopt($ch, CURLOPT_CUSTOMREQUEST, strtoupper($this->method));
            }

            if ($this->sendJson) {
                $headers[] = 'Content-Type: application/json';
                $headers[] = 'Content-Length: ' . strlen($payload);
            }
        }

        if ($this->returnJson) {
            $headers[] = 'Accept: application/json';
        }

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

        // SSL 设置 (完全保留原样)
        curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false);
        curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, false);

        // 异步发送 (完全保留原样)
        if ($this->async) {
            curl_setopt($ch, CURLOPT_TIMEOUT_MS, 200);
            curl_setopt($ch, CURLOPT_CONNECTTIMEOUT_MS, 200);
            curl_setopt($ch, CURLOPT_NOSIGNAL, true);
            curl_setopt($ch, CURLOPT_RETURNTRANSFER, false);
            curl_exec($ch);
            curl_close($ch);
            return 'sent';
        }

        // 阻塞执行 (完全保留原样)
        curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
        $response = curl_exec($ch);

        if (curl_errno($ch)) {
            $error = curl_error($ch);
            curl_close($ch);
            throw new Exception("cURL Error: {$error}");
        }

        curl_close($ch);
        
        return $response;
    }
}