majiameng / tools

src/exception/TException.php

Spacing +1 added lines, -1 removed lines

@@ -21,7 +21,7 @@
         $this->setHeaders($headers);
 
         /** message */
-        if(empty($message)) $message = isset(StatusCode::$status_code[$statusCode]) ? StatusCode::$status_code[$statusCode] :StatusCode::$status_code[StatusCode::COMMON_UNKNOWN];
+        if (empty($message)) $message = isset(StatusCode::$status_code[$statusCode]) ? StatusCode::$status_code[$statusCode] : StatusCode::$status_code[StatusCode::COMMON_UNKNOWN];
         parent::__construct('ERROR_TINYMENG_TOOL: '.$message, $code, $previous);
     }
 

src/HttpRequest.php

Spacing +27 added lines, -27 removed lines

@@ -33,19 +33,19 @@ 
      * @return mixed
      * @throws \Exception
      */
-    static public function httpPost($url, $param = array(), $httpHeaders = array(),$proxy='', $http_code = null)
+    static public function httpPost($url, $param = array(), $httpHeaders = array(), $proxy = '', $http_code = null)
     {
         /** 参数检测,object或者array进行http_build_query */
-        if(!empty($param) && is_array($param)){
+        if (!empty($param) && is_array($param)) {
             $flag = false;
-            foreach ($param as $value){
+            foreach ($param as $value) {
                 //判断参数是否是一个对象 或者 是一个数组
-                if(is_array($value) || (is_string($value) && is_object($value))){
+                if (is_array($value) || (is_string($value) && is_object($value))) {
                     $flag = true;
                     break;
                 }
             }
-            if($flag == true){
+            if ($flag == true) {
                 $param = http_build_query($param);
             }
         }
@@ -62,12 +62,12 @@ 
         curl_setopt($curl, CURLOPT_POSTFIELDS, $param);
 
         /** 设置请求headers */
-        if(empty($httpHeaders)){
+        if (empty($httpHeaders)) {
             $httpHeaders = array(
                 "user-agent: Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/87.0.4280.66 Safari/537.36"
             );
         }
-        if (is_array($httpHeaders)){
+        if (is_array($httpHeaders)) {
             curl_setopt($curl, CURLOPT_HTTPHEADER, $httpHeaders);
         }
         /** gzip压缩 */
@@ -81,11 +81,11 @@ 
         }
 
         /** http代理 */
-        if(!empty($proxy)){
-            $proxy = explode(':',$proxy);
+        if (!empty($proxy)) {
+            $proxy = explode(':', $proxy);
             curl_setopt($curl, CURLOPT_PROXYAUTH, CURLAUTH_BASIC); //代理认证模式
             curl_setopt($curl, CURLOPT_PROXY, "$proxy[0]"); //代理服务器地址
-            curl_setopt($curl, CURLOPT_PROXYPORT,$proxy[1]); //代理服务器端口
+            curl_setopt($curl, CURLOPT_PROXYPORT, $proxy[1]); //代理服务器端口
         }
 
         /** 请求 */
@@ -95,20 +95,20 @@ 
         /** 关闭请求资源 */
         curl_close($curl);
 
-        if($http_code !== null){
+        if ($http_code !== null) {
             /** 验证网络请求状态 */
             if (intval($info["http_code"]) === 0) {
                 throw new TException(StatusCode::COMMON_TINYMENG_REQUEST_METHOD,
-                    '[httpPost]: POST request was aborted ! Request url :' . $url . ' , post request data : ' . var_export($param,true)
+                    '[httpPost]: POST request was aborted ! Request url :'.$url.' , post request data : '.var_export($param, true)
                 );
-            }elseif(intval($info["http_code"]) != $http_code){
+            }elseif (intval($info["http_code"]) != $http_code) {
                 throw new TException(StatusCode::COMMON_TINYMENG_REQUEST_METHOD,
-                    '[httpPost]: POST request was aborted ! Request url :' . $url . ' , post request data : ' . var_export($param,true).' ,return code : '.$info["http_code"] .' ,return content : '.$content
+                    '[httpPost]: POST request was aborted ! Request url :'.$url.' , post request data : '.var_export($param, true).' ,return code : '.$info["http_code"].' ,return content : '.$content
                 );
             } else {
                 return $content;
             }
-        }else{
+        } else {
             return $content;
         }
     }
@@ -125,13 +125,13 @@ 
      * @return mixed
      * @throws \Exception
      */
-    static public function httpGet($url, $param = array(), $httpHeaders = array(),$proxy= '',  $http_code = 200)
+    static public function httpGet($url, $param = array(), $httpHeaders = array(), $proxy = '', $http_code = 200)
     {
         $curl = curl_init();
 
         /** 设置请求参数 */
         if (!empty($param)) {
-            $url = $url . '?' . http_build_query($param);
+            $url = $url.'?'.http_build_query($param);
         }
 
         /** 设置请求链接 */
@@ -147,20 +147,20 @@ 
         }
 
         /** http代理 */
-        if(!empty($proxy)){
-            $proxy = explode(':',$proxy);
+        if (!empty($proxy)) {
+            $proxy = explode(':', $proxy);
             curl_setopt($curl, CURLOPT_PROXYAUTH, CURLAUTH_BASIC); //代理认证模式
             curl_setopt($curl, CURLOPT_PROXY, "$proxy[0]"); //代理服务器地址
-            curl_setopt($curl, CURLOPT_PROXYPORT,$proxy[1]); //代理服务器端口
+            curl_setopt($curl, CURLOPT_PROXYPORT, $proxy[1]); //代理服务器端口
         }
 
         /** 设置请求headers */
-        if(empty($httpHeaders)){
+        if (empty($httpHeaders)) {
             $httpHeaders = array(
                 "user-agent: Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/87.0.4280.66 Safari/537.36"
             );
         }
-        if (is_array($httpHeaders)){
+        if (is_array($httpHeaders)) {
             curl_setopt($curl, CURLOPT_HTTPHEADER, $httpHeaders);
         }
         /** gzip压缩 */
@@ -174,19 +174,19 @@ 
         curl_close($curl);
 
         /** 验证网络请求状态 */
-        if($http_code !== null){
+        if ($http_code !== null) {
             if (intval($info["http_code"]) === 0) {
                 throw new TException(StatusCode::COMMON_TINYMENG_REQUEST_METHOD,
-                    '[httpGet]: GET request was aborted ! Request url :' . $url
+                    '[httpGet]: GET request was aborted ! Request url :'.$url
                 );
-            }elseif(intval($info["http_code"]) != $http_code){
+            }elseif (intval($info["http_code"]) != $http_code) {
                 throw new TException(StatusCode::COMMON_TINYMENG_REQUEST_METHOD,
-                    '[httpGet]: GET request was aborted ! Request url :' . $url .' ,return code : '.$info["http_code"] .' ,return content : '.$content
+                    '[httpGet]: GET request was aborted ! Request url :'.$url.' ,return code : '.$info["http_code"].' ,return content : '.$content
                 );
             } else {
                 return $content;
             }
-        }else{
+        } else {
             return $content;
         }
     }

src/async/AsyncHook.php

Spacing +4 added lines, -4 removed lines

@@ -1,7 +1,7 @@ 
 <?php
 namespace tinymeng\tools\async;
 
-class AsyncHook{
+class AsyncHook {
 
     /**
      * @var array
@@ -20,7 +20,7 @@ 
      */
     public static function hook(callable $callback, $params) {
         self::$hook_list[] = array('callback' => $callback, 'params' => $params);
-        if(self::$hooked === false) {
+        if (self::$hooked === false) {
             self::$hooked = true;
             //注册一个callback当前在脚本执行完后执行
             register_shutdown_function(array(__CLASS__, '__run'));
@@ -33,10 +33,10 @@ 
      */
     private static function __run() {
         fastcgi_finish_request();
-        if(empty(self::$hook_list)) {
+        if (empty(self::$hook_list)) {
             return;
         }
-        foreach(self::$hook_list as $hook) {
+        foreach (self::$hook_list as $hook) {
             $callback = $hook['callback'];
             $params = $hook['params'];
             call_user_func_array($callback, $params);

src/core/Singleton.php

Spacing +4 added lines, -4 removed lines

@@ -13,11 +13,11 @@ 
      */
     private static $instance = null;
 
-    public function __construct($config=[]){
+    public function __construct($config = []) {
         $this->config = $config;
     }
 
-    private function __clone(){}
+    private function __clone() {}
 
     public function __sleep(): array
     {
@@ -25,7 +25,7 @@ 
         return [];
     }
 
-    protected static function init($gateway, $config=[])
+    protected static function init($gateway, $config = [])
     {
         if (!self::$instance instanceof static) {
             self::$instance = new static($config);
@@ -41,7 +41,7 @@ 
      *@author: JiaMeng <666@majiameng.com>
      * Updater:
      */
-    public static function __callStatic($gateway, array $config=[])
+    public static function __callStatic($gateway, array $config = [])
     {
         return self::init($gateway, ...$config);
     }