bingyu-duanxinwangzhan/message-code/message-admin/application/common/lazada/lazop/LazopClient.php

<?php
/**
 * Created by PhpStorm.
 * User: lock
 * Date: 2020/8/22
 * Time: 11:43 AM
 */

namespace app\common\lazada\lazop;


use think\Exception;

class LazopClient
{
    public $appkey;

    public $secretKey;

    public $gatewayUrl;

    public $connectTimeout;

    public $readTimeout;

    protected $signMethod = "sha256";

    protected $sdkVersion = "lazop-sdk-php-20180422";

    public $logLevel;

    public function getAppkey()
    {
        return $this->appkey;
    }

    public function __construct($url = "",$appkey = "",$secretKey = "")
    {
        $length = strlen($url);
        if($length == 0)
        {
            throw new Exception("url is empty",0);
        }
        $this->gatewayUrl = $url;
        $this->appkey = $appkey;
        $this->secretKey = $secretKey;
        $this->logLevel = Constants::$log_level_error;
    }

    protected function generateSign($apiName,$params)
    {
        ksort($params);

        $stringToBeSigned = '';
        $stringToBeSigned .= $apiName;
        foreach ($params as $k => $v)
        {
            $stringToBeSigned .= "$k$v";
        }
        unset($k, $v);

        return strtoupper($this->hmac_sha256($stringToBeSigned,$this->secretKey));
    }


    function hmac_sha256($data, $key){
        return hash_hmac('sha256', $data, $key);
    }

    public function curl_get($url,$apiFields = null,$headerFields = null)
    {
        $ch = curl_init();

        foreach ($apiFields as $key => $value)
        {
            $url .= "&" ."$key=" . urlencode($value);
        }

        curl_setopt($ch, CURLOPT_URL, $url);
        curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
        curl_setopt($ch, CURLOPT_FAILONERROR, false);
        curl_setopt($ch, CURLOPT_HEADER, false);
        curl_setopt($ch, CURLOPT_FOLLOWLOCATION, 1);

        if($headerFields)
        {
            $headers = array();
            foreach ($headerFields as $key => $value)
            {
                $headers[] = "$key: $value";
            }
            curl_setopt($ch, CURLOPT_HTTPHEADER, $headers);
            unset($headers);
        }

        if ($this->readTimeout)
        {
            curl_setopt($ch, CURLOPT_TIMEOUT, $this->readTimeout);
        }

        if ($this->connectTimeout)
        {
            curl_setopt($ch, CURLOPT_CONNECTTIMEOUT, $this->connectTimeout);
        }

        curl_setopt ( $ch, CURLOPT_USERAGENT, $this->sdkVersion );

        //https ignore ssl check ?
        if(strlen($url) > 5 && strtolower(substr($url,0,5)) == "https" )
        {
            curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false);
            curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, false);
        }

        $output = curl_exec($ch);

        $errno = curl_errno($ch);

        if ($errno)
        {
            curl_close($ch);
            throw new Exception($errno,0);
        }
        else
        {
            $httpStatusCode = curl_getinfo($ch, CURLINFO_HTTP_CODE);
            curl_close($ch);
            if (200 !== $httpStatusCode)
            {
                throw new Exception($output,$httpStatusCode);
            }
        }

        return $output;
    }

    public function curl_post($url, $postFields = null, $fileFields = null,$headerFields = null)
    {
        $ch = curl_init();
        curl_setopt($ch, CURLOPT_URL, $url);
        curl_setopt($ch, CURLOPT_FAILONERROR, false);
        curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);

        if ($this->readTimeout)
        {
            curl_setopt($ch, CURLOPT_TIMEOUT, $this->readTimeout);
        }

        if ($this->connectTimeout)
        {
            curl_setopt($ch, CURLOPT_CONNECTTIMEOUT, $this->connectTimeout);
        }

        if($headerFields)
        {
            $headers = array();
            foreach ($headerFields as $key => $value)
            {
                $headers[] = "$key: $value";
            }
            curl_setopt($ch, CURLOPT_HTTPHEADER, $headers);
            unset($headers);
        }

        curl_setopt ( $ch, CURLOPT_USERAGENT, $this->sdkVersion );

        //https ignore ssl check ?
        if(strlen($url) > 5 && strtolower(substr($url,0,5)) == "https" )
        {
            curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false);
            curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, false);
        }

        $delimiter = '-------------' . uniqid();
        $data = '';
        if($postFields != null)
        {
            foreach ($postFields as $name => $content)
            {
                $data .= "--" . $delimiter . "\r\n";
                $data .= 'Content-Disposition: form-data; name="' . $name . '"';
                $data .= "\r\n\r\n" . $content . "\r\n";
            }
            unset($name,$content);
        }

        if($fileFields != null)
        {
            foreach ($fileFields as $name => $file)
            {
                $data .= "--" . $delimiter . "\r\n";
                $data .= 'Content-Disposition: form-data; name="' . $name . '"; filename="' . $file['name'] . "\" \r\n";
                $data .= 'Content-Type: ' . $file['type'] . "\r\n\r\n";
                $data .= $file['content'] . "\r\n";
            }
            unset($name,$file);
        }
        $data .= "--" . $delimiter . "--";

        curl_setopt($ch, CURLOPT_POST, true);
        curl_setopt($ch, CURLOPT_HTTPHEADER ,
            array(
                'Content-Type: multipart/form-data; boundary=' . $delimiter,
                'Content-Length: ' . strlen($data)
            )
        );

        curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
        curl_setopt($ch, CURLOPT_POSTFIELDS, $data);

        $response = curl_exec($ch);
        unset($data);

        $errno = curl_errno($ch);
        if ($errno)
        {
            curl_close($ch);
            throw new Exception($errno,0);
        }
        else
        {
            $httpStatusCode = curl_getinfo($ch, CURLINFO_HTTP_CODE);
            curl_close($ch);
            if (200 !== $httpStatusCode)
            {
                throw new Exception($response,$httpStatusCode);
            }
        }

        return $response;
    }

    public function execute(LazopRequest $request, $accessToken = null)
    {
        $sysParams["app_key"] = $this->appkey;
        $sysParams["sign_method"] = $this->signMethod;
        $sysParams["timestamp"] = $this->msectime();
        if (null != $accessToken)
        {
            $sysParams["access_token"] = $accessToken;
        }

        $apiParams = $request->udfParams;

        $requestUrl = $this->gatewayUrl;

        if($this->endWith($requestUrl,"/"))
        {
            $requestUrl = substr($requestUrl, 0, -1);
        }

        $requestUrl .= $request->apiName;
        $requestUrl .= '?';

        $sysParams["partner_id"] = $this->sdkVersion;

        if($this->logLevel == Constants::$log_level_debug)
        {
            $sysParams["debug"] = 'true';
        }

        $sysParams["sign"] = $this->generateSign($request->apiName,array_merge($apiParams, $sysParams));

        foreach ($sysParams as $sysParamKey => $sysParamValue)
        {
            $requestUrl .= "$sysParamKey=" . urlencode($sysParamValue) . "&";
        }

        $requestUrl = substr($requestUrl, 0, -1);

        $resp = '';

        try
        {
            if($request->httpMethod == 'POST')
            {
                $resp = $this->curl_post($requestUrl, $apiParams, $request->fileParams,$request->headerParams);
            }
            else
            {
                $resp = $this->curl_get($requestUrl, $apiParams,$request->headerParams);
            }
        }
        catch (Exception $e)
        {
            $this->logApiError($requestUrl,"HTTP_ERROR_" . $e->getCode(),$e->getMessage());
            throw $e;
        }

        unset($apiParams);

        $respObject = json_decode($resp);
        if(isset($respObject->code) && $respObject->code != "0")
        {
            $this->logApiError($requestUrl, $respObject->code, $respObject->message);
        } else
        {
            if($this->logLevel == Constants::$log_level_debug || $this->logLevel == Constants::$log_level_info)
            {
                $this->logApiError($requestUrl, '', '');
            }
        }
        return $resp;
    }

    protected function logApiError($requestUrl, $errorCode, $responseTxt)
    {
        $localIp = isset($_SERVER["SERVER_ADDR"]) ? $_SERVER["SERVER_ADDR"] : "CLI";
        $logger = new LazopLogger;
        $logger->conf["log_file"] = $_SERVER['DOCUMENT_ROOT'].'/' . "logs/lazopsdk.log." . date("Y-m-d");
        $logger->conf["separator"] = "^_^";
        $logData = array(
            date("Y-m-d H:i:s"),
            $this->appkey,
            $localIp,
            PHP_OS,
            $this->sdkVersion,
            $requestUrl,
            $errorCode,
            str_replace("\n","",$responseTxt)
        );
        $logger->log($logData);
    }

    function msectime() {
        list($msec, $sec) = explode(' ', microtime());
        return $sec . '000';
    }

    function endWith($haystack, $needle) {
        $length = strlen($needle);
        if($length == 0)
        {
            return false;
        }
        return (substr($haystack, -$length) === $needle);
    }
}