fix

Author: tayueliuxiang

Framework/Base/BaseObject.php

@@ -0,0 +1,55 @@
+<?php
+/**
+ * Created by PhpStorm.
+ * User: zhjx
+ * Date: 2018/11/5
+ * Time: 11:30
+ */
+
+namespace Framework\Base;
+
+
+use Framework\Framework;
+
+abstract class BaseObject implements Objects
+{
+
+    public function __construct($config = [])
+    {
+        if (!empty($config)) {
+            Framework::configure($this, $config);
+        }
+        $this->init();
+    }
+
+    public static function className()
+    {
+        return get_called_class();
+    }
+
+    public function init(){
+
+    }
+
+    public function __get($name)
+    {
+        // TODO: Implement __get() method.
+    }
+
+    public function __set($name, $value)
+    {
+        $setter = 'set' . $name;
+        if (method_exists($this, $setter)) {
+            $this->$setter($value);
+        } elseif (method_exists($this, 'get' . $name)) {
+            throw new Exception('Setting read-only property: ' . get_class($this) . '::' . $name);
+        } else {
+            throw new Exception('Setting unknown property: ' . get_class($this) . '::' . $name);
+        }
+    }
+
+    public function __isset($name)
+    {
+        // TODO: Implement __isset() method.
+    }
+}

Framework/Base/Objects.php

@@ -0,0 +1,14 @@
+<?php
+/**
+ * Created by PhpStorm.
+ * User: zhjx
+ * Date: 2018/11/5
+ * Time: 11:24
+ */
+
+namespace Framework\Base;
+
+
+interface Objects
+{
+}

Framework/Tool/Log.php

@@ -0,0 +1,96 @@
+<?php
+/**
+ * Created by PhpStorm.
+ * User: Administrator
+ * Date: 2018/11/22
+ * Time: 16:07
+ */
+
+namespace Framework\Tool;
+
+use Framework\Tool\Tool;
+
+class Log
+{
+    use \Framework\Traits\SingletonTrait;
+    const INFO = 0;
+    const NOTICE = 1;
+    const TRACE = 2;
+    const ERROR = 3;
+    public $level = self::INFO;
+
+    static $levelInfo = [
+        self::INFO => 'INFO',
+        self::NOTICE => 'NOTICE',
+        self::TRACE => 'TRACE',
+        self::ERROR => 'ERROR',
+    ];
+
+
+    public $config = [
+        'is_display' => false,
+        'level' => self::INFO,
+        'log_file' => 'Log.log'
+    ];
+
+    public function setConfig($config)
+    {
+        $this->config = array_merge($this->config, $config);
+    }
+
+    public function setLevel($level)
+    {
+        if (isset($level) && in_array($level, array_keys(self::$levelInfo))) {
+            $this->level = $level;
+        }
+
+    }
+
+    public static function Conversion($level = '')
+    {
+        if (!$level) {
+            $level = self::INFO;
+            return self::$levelInfo[$level];
+        }
+        $level = strtoupper($level);
+        if (in_array($level, self::$levelInfo)) {
+            $tmp = array_flip(self::$levelInfo);
+            return $tmp[$level];
+        }
+        $level = self::INFO;
+        return self::$levelInfo[$level];
+
+    }
+
+    function put($msg, $level = '')
+    {
+        $level = self::Conversion($level);
+        if ($this->config['is_display']) {
+            echo $this->format($msg, $level);
+        } else { //写入到日志里面
+            $log_dir = $this->config['log_dir']; //日志目录
+            if (!is_dir($log_dir)) {
+                $is_dir = Tool::createDir($log_dir);
+                if (!$is_dir) {
+                    throw new Exception("目录{$log_dir}创建失败!!");
+                }
+            }
+            if (!$msg) {
+                return;
+            }
+            $logFilePath = $log_dir . DIRECTORY_SEPARATOR . date("Y_m_d_") . $this->config['log_file'];
+            $msg = $this->format($msg, $level);
+            $msg = $msg . "\r\n";
+            file_put_contents($logFilePath, $msg, FILE_APPEND);
+        }
+    }
+
+    public function format($msg, $level = '')
+    {
+        if (!$level) {
+            $level = $this->level;
+        }
+        $dateFormatStr = "[Y-m-d H:i:s]";
+        return date($dateFormatStr) . "\t" . self::$levelInfo[$level] . "\t" . $msg;
+    }
+}

Server/Task/ProcessAsyncTask.php

@@ -0,0 +1,36 @@
+<?php
+/**
+ * Created by PhpStorm.
+ * User: hdeng
+ * Date: 2018/11/29
+ * Time: 9:21
+ */
+
+namespace Server\Task;
+
+
+class ProcessAsyncTask
+{
+    public function onPipeMessage($processObjectData, $processObjectParams)
+    {   print_r($processObjectData);
+        print_r($processObjectParams);
+        list($classNameSpacePath, $method) = $processObjectData;
+        $classObject = new $classNameSpacePath();
+        $controllerInstance = new \ReflectionClass($classNameSpacePath);
+        if ($controllerInstance->hasMethod($method)) {
+            $classMethod = new \ReflectionMethod($classNameSpacePath, $method);
+            if ($classMethod->isPublic()) {
+                try {
+                    $classObject->$method(...$processObjectParams);
+                } catch (\Exception $e) {
+                    throw new \Exception($e->getMessage(), 2);
+                } catch (\Throwable $t) {
+
+                    throw new \Exception($t->getMessage(), 1);
+                }
+            } else {
+                throw new \Exception('class method ' . $method . ' is static or private, protected property, can not be object call!', 1);
+            }
+        }
+    }
+}