Toplan\PhpSms\Agent

Complexity

Total Complexity

12

Size/Duplication

Total Lines	169
Duplicated Lines	0 %

Coupling/Cohesion

Components	0
Dependencies	0

Test Coverage

Coverage

100%

Importance

Changes	11
Bugs	4	Features	3

9 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
	sendSms()	0	1	?
	sendContentSms()	0	1	?
	sendTemplateSms()	0	1	?
	voiceVerify()	0	1	?
B	sockPost()	0	26	4
B	curl()	0	26	4
A	getResult()	0	4	1
A	__get()	0	8	2

<?php

namespace Toplan\PhpSms;

abstract class Agent
{
    /**
     * agent config
     *
     * @var array
     */
    protected $config;

    /**
     * sent result info
     *
     * @var array
     */
    protected $result = [
        'success' => false,
        'info'    => '',
        'code'    => 0,
    ];

    /**
     * construct for create a instance
     *
     * @param array $config
     */
    public function __construct(array $config = [])
    {
        $this->config = $config;
    }

    /**
     * sms send process
     *
     * @param       $tempId
     * @param       $to
     * @param array $data
     * @param       $content
     */
    abstract public function sendSms($tempId, $to, array $data, $content);

    /**
     * content sms send process
     *
     * @param $to
     * @param $content
     */
    abstract public function sendContentSms($to, $content);

    /**
     * template sms send process
     *
     * @param       $tempId
     * @param       $to
     * @param array $data
     */
    abstract public function sendTemplateSms($tempId, $to, array $data);

    /**
     * voice verify
     *
     * @param $to
     * @param $code
     */
    abstract public function voiceVerify($to, $code);

    /**
     * http post request
     *
     * @codeCoverageIgnore
     *
     * @param       $url
     * @param array $query
     * @param       $port
     *
     * @return mixed
     */
    public function sockPost($url, $query, $port = 80)
    {
        $data = '';
        $info = parse_url($url);
        $fp = fsockopen($info['host'], $port, $errno, $errstr, 30);
        if (!$fp) {
            return $data;
        }
        $head = 'POST ' . $info['path'] . " HTTP/1.0\r\n";
        $head .= 'Host: ' . $info['host'] . "\r\n";
        $head .= 'Referer: http://' . $info['host'] . $info['path'] . "\r\n";
        $head .= "Content-type: application/x-www-form-urlencoded\r\n";
        $head .= 'Content-Length: ' . strlen(trim($query)) . "\r\n";
        $head .= "\r\n";
        $head .= trim($query);
        $write = fwrite($fp, $head);

$write is not used, you could remove the assignment.

        $header = '';
        while ($str = trim(fgets($fp, 4096))) {
            $header .= $str;
        }
        while (!feof($fp)) {
            $data .= fgets($fp, 4096);
        }

        return $data;
    }

    /**
     * cURl
     *
     * @codeCoverageIgnore
     *
     * @param string   $url    [请求的URL地址]
     * @param array    $params [请求的参数]
     * @param int|bool $isPost [是否采用POST形式]
     *
     * @return array ['request', 'response']
     *               request:是否请求成功
     *               response:响应数据
     */
    public function curl($url, array $params = [], $isPost = false)
    {
        $request = true;
        $ch = curl_init();
        curl_setopt($ch, CURLOPT_HTTP_VERSION, CURL_HTTP_VERSION_1_1);
        curl_setopt($ch, CURLOPT_USERAGENT, 'Mozilla/5.0 (Windows NT 5.1) AppleWebKit/537.22 (KHTML, like Gecko) Chrome/25.0.1364.172 Safari/537.22');
        curl_setopt($ch, CURLOPT_CONNECTTIMEOUT, 30);
        curl_setopt($ch, CURLOPT_TIMEOUT, 30);
        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 {
            $params = http_build_query($params);
            curl_setopt($ch, CURLOPT_URL, $params ? "$url?$params" : $url);
        }
        $response = curl_exec($ch);
        if ($response === false) {
            $request = false;
            $response = curl_getinfo($ch);
        }
        curl_close($ch);

        return compact('request', 'response');
    }

    /**
     * get result
     *
     * @return array
     */
    public function getResult()
    {
        return $this->result;
    }

    /**
     * overload object attribute
     *
     * @param $name
     *
     * @return mixed
     */
    public function __get($name)
    {
        if (array_key_exists($name, $this->config)) {
            return $this->config["$name"];
        }

        return;
    }
}