hxtc-order/addons/qingdongams/library/JuheExpress.php

<?php

namespace  addons\qingdongams\library;

//聚合获取快递信息
use think\Log;
use addons\qingdongams\model\AdminConfig;
class JuheExpress
{
    private $apiHost = 'https://v.juhe.cn/exp';
    public function __construct()
    {
        $this->apiKey = AdminConfig::getConfigValue('logist_key','juhe');
    }
    /**
     * 获取支持的快递公司及编号
     */
    public function getCompanys()
    {
        // 组装请求完整URL
        $requestApiUrl = $this->apiHost . '/com?key=' . $this->apiKey;
        // 发起网络请求聚合
        $requestResponseContent = $this->juheHttpRequest($requestApiUrl);
        // 解析结果
        $requestResult = json_decode($requestResponseContent, true);
        if (!$requestResult) {
            // 请求异常，可能网络异常等原因，根据自身逻辑修改
            echo "请求异常";
            return false;
        } else {
            $requestStatusCode = $requestResult['error_code'];
            if ($requestStatusCode === 0) {
                // 请求成功，根据自身逻辑修改
                $companys = $requestResult['result'];
                return $companys;
            } else {
                // 请求失败，根据自身逻辑修改
                echo $requestResult['error_code'] . ':' . $requestResult['reason'];
                return false;
            }
        }
    }
    /**
     * 根据快递公司编号和快递单号查询快递状态
     */
    public function getResult($com,$no,$sender='',$receiver='')
    {
        $apiUrl = $this->apiHost . '/index';
        $requestParams = [
            'key' => $this->apiKey,
            'com' => $com, // 需要查询的快递公司编号
            'no' => $no, // 需要查询的快递单号
            'senderPhone' => $sender,
            'receiverPhone' => $receiver
        ];
        // 发起网络请求聚合
        $requestResponseContent = $this->juheHttpRequest($apiUrl, $requestParams, 1);
        // 解析结果
        $requestResult = json_decode($requestResponseContent, true);
        if (!$requestResult) {
            // 请求异常，可能网络异常等原因，根据自身逻辑修改
            echo "请求异常";
            return false;
        } else {
            $requestStatusCode = $requestResult['error_code'];
            if ($requestStatusCode === 0) {
                // 请求成功，根据自身逻辑修改
                $companys = $requestResult['result'];
                return $companys;
            } else {
                // 请求失败，根据自身逻辑修改
                Log::error('查询订单错误'.$requestResult['error_code'] . ':' . $requestResult['reason']);
                return false;
            }
        }
    }


    /**
     * 发送短信
     */
    public function sendSms($mobile,$code)
    {
        $apiUrl = "http://v.juhe.cn/vercodesms/send.php";
        $requestParams = [
            'key' => '00aec99a637f4647317a472aa71d8806',
            'mobile' => $mobile, //
            'tplId' => 66581, //
            'tplValue' => urlencode("#code#={$code}"),
        ];
        // 发起网络请求聚合
        $requestResponseContent = $this->juheHttpRequest($apiUrl, $requestParams, 1);
        // 解析结果
        $requestResult = json_decode($requestResponseContent, true);
        if (!$requestResult) {
            // 请求异常，可能网络异常等原因，根据自身逻辑修改
            echo "请求异常";
            return false;
        } else {
            $requestStatusCode = $requestResult['error_code'];
            if ($requestStatusCode === 0) {
                // 请求成功，根据自身逻辑修改
                $companys = $requestResult['result'];
                return $companys;
            } else {
                // 请求失败，根据自身逻辑修改
                Log::error('查询订单错误'.$requestResult['error_code'] . ':' . $requestResult['reason']);
                return false;
            }
        }
    }

    /**
     * 发起网络请求函数
     * @param $url 请求的URL
     * @param bool $params 请求的参数内容
     * @param int $ispost 是否POST请求
     * @return bool|string 返回内容
     */
    private function juheHttpRequest($url, $params = false, $ispost = 0)
    {
        // $httpInfo = array();
        $ch = curl_init();

        curl_setopt($ch, CURLOPT_HTTP_VERSION, CURL_HTTP_VERSION_1_1);
        curl_setopt($ch, CURLOPT_USERAGENT, 'Mozilla/5.0 (Windows NT 10.0; WOW64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/41.0.2272.118 Safari/537.36');
        curl_setopt($ch, CURLOPT_CONNECTTIMEOUT, 5);
        curl_setopt($ch, CURLOPT_TIMEOUT, 12);
        curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
        if ($ispost) {
            curl_setopt($ch, CURLOPT_POST, true);
            curl_setopt($ch, CURLOPT_POSTFIELDS, $params);
            curl_setopt($ch, CURLOPT_URL, $url);
        } else {
            if ($params) {
                if (is_array($params)) {
                    curl_setopt($ch, CURLOPT_URL, $url . '?' . http_build_query($params));
                } else {
                    curl_setopt($ch, CURLOPT_URL, $url . '?' . $params);
                }
            } else {
                curl_setopt($ch, CURLOPT_URL, $url);
            }
        }
        $response = curl_exec($ch);
        if ($response === false) {
            return false;
        }
        curl_close($ch);
        return $response;
    }
}