update SECURITY.md

update to 1.2.1
add phar build script
2026-07-03 23:05:37 +08:00 · 2020-05-02 23:28:11 +08:00 · 2020-05-02 23:27:26 +08:00 · 2020-04-29 18:11:21 +08:00 · 2020-04-29 17:56:44 +08:00 · 2020-04-29 15:58:24 +08:00
39 changed files with 1182 additions and 262 deletions
--- a/.gitignore
+++ b/.gitignore
@@ -4,4 +4,5 @@
 /vendor/
 zm.json
 /zm_data/
-composer.lock
+composer.lock
+/resources/server.phar
--- a/README.md
+++ b/README.md
@@ -2,12 +2,12 @@

 [![作者QQ](https://img.shields.io/badge/作者QQ-627577391-orange.svg)]()
 [![zhamao License](https://img.shields.io/hexpm/l/plug.svg?maxAge=2592000)](https://github.com/zhamao-robot/zhamao-framework/blob/master/LICENSE)
-[![版本](https://img.shields.io/badge/version-1.1-green.svg)]()
+[![版本](https://img.shields.io/badge/version-1.2-green.svg)]()

-[![goto counter](https://img.shields.io/github/search/zhamao-robot/zhamao-framework/goto.svg)](https://github.com/zhamao-robot/zhamao-framework/search?q=goto)
+[![stupid counter](https://img.shields.io/github/search/zhamao-robot/zhamao-framework/stupid.svg)](https://github.com/zhamao-robot/zhamao-framework/search?q=stupid)
 [![TODO counter](https://img.shields.io/github/search/zhamao-robot/zhamao-framework/TODO.svg)](https://github.com/zhamao-robot/zhamao-framework/search?q=TODO)

-一个异步、多平台兼容的 **聊天机器人** 框架。
+协程高性能的 **QQ 机器人 + Web 服务器** 开发框架（炸毛框架）。

 <img src="https://avatars0.githubusercontent.com/u/48620312" height = "200" alt="炸毛框架" align=center/>

@@ -19,7 +19,7 @@ zhamao-framework 是一个基于 酷Q 的 PHP Swoole 的机器人框架，它会
 除了起到解析消息的作用，炸毛框架 还提供了完整的 WebSocket + HTTP 服务器，你还能用此框架构建出高性能的 API 接口服务器。

 ## 开始
-你可以使用 GitHub 的 `Use This Template` 功能快速将本项目克隆到你的公开或私有仓库，也可以直接 clone 本项目到本地私有开发。
+你可以使用 GitHub 的 `Use This Template` 功能快速将本项目克隆到你的公开或私有仓库，也可以从 `release` 中下载本项目的最新版本到本地私有开发。

 ## 文档
 本项目文档正在努力编写中。
@@ -35,6 +35,7 @@ Pages：[https://framework.zhamao.xin/](https://framework.zhamao.xin/)
 - 常驻内存，全局缓存变量随处使用
 - 自带 MySQL 查询器、数据库连接池等数据库连接方案
 - 自带 HTTP 服务器、WebSocket 服务器可复用，可以构建属于自己的 HTTP API 接口
+- 静态文件服务器

 ## 炸毛特色模块

@@ -47,18 +48,19 @@ Pages：[https://framework.zhamao.xin/](https://framework.zhamao.xin/)
 - [ ] WebSocket测试脚本（客户端）
 - [X] Session 和中间层管理模块
 - [ ] 支持本地和远程两种方式的定时器（计划任务）
- [ ] 常驻服务脚本
+- [X] 常驻服务脚本
 - [ ] 一些常用的通用 API 例如经济（用户积分、亲密度等）的模块
 - [ ] 图灵机器人/腾讯AI 聊天模块
 - [ ] 分词模块（可能会放弃计划，因为目前好用的分词都是其他语言的）
 - [ ] HTTP 过滤器、Auth 模块、完整的 MVC 兼容（可能会放弃计划，因为框架主打机器人开发）
 - [ ] Redis 连接池或开箱即用的相应功能内置
 - [ ] 2.0 版本抛弃 `ModBase` 继承结构，完全使用上下文代替
- [ ] 更好的 Logger，稳定和漂亮的控制台输出
+- [X] 更好的 Logger，稳定和漂亮的控制台输出
 - [ ] 日志服务
 - [ ] 模块支持 Phar 打包（可能会比较靠后支持）
 - [ ] 兼容面向过程的模块编写方案（可能会比较靠后支持）
 - [ ] 完整的单元测试（如果有需求则尽快开发）
+- [X] 静态文件服务器

 ## 从 cqbot-swoole 升级
 目前新的框架采用了全新的注解机制，所以旧版的框架上写的模块到新框架需要重新编写。当然为了减少工作量，新的框架也最大限度地保留了旧版框架编写的风格，一般情况下根据新版框架的文档仅需修改少量地方即可完成重写。
--- a/SECURITY.md
+++ b/SECURITY.md
@@ -0,0 +1,13 @@
+# Security Policy
+
+## Supported Versions
+
+| Version | Supported          |
+| ------- | ------------------ |
+| 1.2.x   | :white_check_mark: |
+| 1.1.x   | :x: |
+| 1.0.x   | :x:                |
+
+## Reporting a Vulnerability
+
+If you find a bug which is safety related, you should post a new issue named **Security Issue**, and I will check it as soon as possible.
--- a/bin/phar-build
+++ b/bin/phar-build
--- a/bin/systemd
+++ b/bin/systemd
@@ -0,0 +1,26 @@
+#!/usr/bin/env php
+<?php /** @since 1.2 */
+switch ($argv[1] ?? '') {
+    case '--generate':
+        generate();
+        break;
+    case '--help':
+    case '-h':
+    default:
+        echo "\nUsage: " . $argv[0] . " [OPTION]\n";
+        echo "\nzhamao-framework systemd generator.";
+        echo "\n\n  -h, --help\t\tShow this help menu";
+        echo "\n  --generate\tGenerate a systemd service file\n\n";
+        break;
+}
+
+function generate() {
+    $s = "[Unit]\nDescription=zhamao-framework Daemon\nAfter=rc-local.service\n\n[Service]\nType=simple";
+    $s .= "\nUser=" . exec("whoami");
+    $s .= "\nGroup=" . exec("groups | awk '{print $1}'");
+    $s .= "\nWorkingDirectory=" . getcwd();
+    $s .= "\nExecStart=" . getcwd() . "/bin/start server --disable-console-input";
+    $s .= "\nRestart=always\n\n[Install]\nWantedBy=multi-user.target\n";
+    file_put_contents(getcwd() . "/resources/zhamao.service", $s);
+    echo "File successfully generated. Path: " . getcwd() . "/resources/zhamao.service\n";
+}
--- a/composer.json
+++ b/composer.json
@@ -3,7 +3,7 @@
    "description": "high-performance intelligent assistant",
    "minimum-stability": "stable",
    "license": "proprietary",
-    "version": "1.0",
+    "version": "1.2.1",
    "authors": [
        {
            "name": "whale",
@@ -18,10 +18,12 @@
        "swoole/ide-helper": "@dev",
        "ext-mbstring": "*",
        "swlib/saber": "^1.0",
-        "doctrine/annotations": "^1.8",
+        "doctrine/annotations": "<1.10.2",
        "ext-json": "*",
        "ext-posix": "*",
-        "ext-ctype": "*"
+        "ext-ctype": "*",
+        "ext-pcntl": "*",
+        "nikic/php-parser": "^4.4"
    },
    "repositories": {
        "packagist": {
--- a/config/global.php
+++ b/config/global.php
@@ -58,7 +58,7 @@ $config['init_atomics'] = [
    'out_count' => 0,       //消息发送（调用send_*_msg的统计数量）
    'reload_time' => 0,     //调用reload功能统计数量
    'wait_msg_id' => 0,     //协程挂起id自增
-    'info_level' => 0,      //终端显示的log等级
+    'info_level' => 2,      //终端显示的log等级
 ];

 /** 自动保存的缓存保存时间（秒） */
--- a/phar-starter.php
+++ b/phar-starter.php
@@ -0,0 +1,82 @@
+<?php
+
+global $is_phar;
+
+use Framework\FrameworkLoader;
+
+$is_phar = true;
+
+if (substr(__DIR__, 0, 7) != 'phar://') {
+    die("You can not run this script directly!\n");
+}
+
+testEnvironment();
+
+spl_autoload_register(function ($class) {
+    //echo $class."\n";
+    $exp = str_replace("\\", '/', $class);
+    $exp = __DIR__ . '/src/' . $exp . '.php';
+    if (is_file($exp)) {
+        require_once $exp;
+    }
+});
+
+loadPhp(__DIR__ . '/src');
+
+Swoole\Coroutine::set([
+    'max_coroutine' => 30000,
+]);
+
+date_default_timezone_set("Asia/Shanghai");
+
+define('WORKING_DIR', __DIR__);
+
+$s = new FrameworkLoader($argv);
+
+function loadPhp($dir) {
+    $dirs = scandir($dir);
+    foreach ($dirs as $v) {
+        $path = $dir . '/' . $v;
+        if (is_dir($path)) {
+            loadPhp($path);
+        } else {
+            if (pathinfo($dir . '/' . $v)['extension'] == 'php') {
+                //echo 'loading '.$path.PHP_EOL;
+                require_once $path;
+            }
+        }
+    }
+}
+
+function testEnvironment() {
+    $current_dir = realpath('.');
+    @mkdir($current_dir . '/config/');
+    if (!is_file($current_dir . '/config/global.php')) {
+        echo "Exporting default global config...\n";
+        $global = file_get_contents(__DIR__ . '/config/global.php');
+        $global = str_replace("WORKING_DIR", 'realpath("../")', $global);
+        file_put_contents($current_dir . '/config/global.php', $global);
+    }
+    if (!is_file($current_dir . '/config/file_header.json')) {
+        echo "Exporting default file_header config...\n";
+        $global = file_get_contents(__DIR__ . '/config/file_header.json');
+        file_put_contents($current_dir . '/config/file_header.json', $global);
+    }
+    if (!is_dir($current_dir . '/resources')) mkdir($current_dir . '/resources');
+    if (!is_dir($current_dir . '/src')) mkdir($current_dir . '/src');
+    if (!is_dir($current_dir . '/src')) mkdir($current_dir . '/src');
+    if (!is_dir($current_dir . '/src/Module')) {
+        mkdir($current_dir . '/src/Module');
+        mkdir($current_dir . '/src/Module/Example');
+        file_put_contents($current_dir . '/src/Module/Example/Hello.php', file_get_contents(__DIR__ . '/tmp/Hello.php.bak'));
+        mkdir($current_dir . '/src/Module/Middleware');
+        file_put_contents($current_dir . '/src/Module/Middleware/TimerMiddleware.php', file_get_contents(__DIR__ . '/tmp/TimerMiddleware.php.bak'));
+    }
+    if (!is_dir($current_dir . '/src/Custom')) {
+        mkdir($current_dir . '/src/Custom');
+        mkdir($current_dir . '/src/Custom/Annotation');
+        mkdir($current_dir . '/src/Custom/Connection');
+        file_put_contents($current_dir . '/src/Custom/global_function.php', "<?php\n\n//这里写你的全局方法");
+    }
+}
+
--- a/src/Framework/Console.php
+++ b/src/Framework/Console.php
@@ -14,8 +14,7 @@ use Exception;

 class Console
 {
-    static function setColor($string, $color = "")
-    {
+    static function setColor($string, $color = "") {
        switch ($color) {
            case "red":
                return "\x1b[38;5;203m" . $string . "\x1b[m";
@@ -25,6 +24,7 @@ class Console
                return "\x1b[38;5;227m" . $string . "\x1b[m";
            case "blue":
                return "\033[34m" . $string . "\033[0m";
+            case "pink": // I really don't know what stupid color it is.
            case "lightpurple":
                return "\x1b[38;5;207m" . $string . "\x1b[m";
            case "lightblue":
@@ -33,8 +33,6 @@ class Console
                return "\x1b[38;5;214m" . $string . "\x1b[m";
            case "gray":
                return "\x1b[38;5;59m" . $string . "\x1b[m";
-            case "pink":
-                return "\x1b[38;5;207m" . $string . "\x1b[m";
            case "lightlightblue":
                return "\x1b[38;5;63m" . $string . "\x1b[m";
            default:
@@ -42,9 +40,8 @@ class Console
        }
    }

-    static function error($obj, $head = null)
-    {
-        if ($head === null) $head = date("[H:i:s ") . "ERROR] ";
+    static function error($obj, $head = null) {
+        if ($head === null) $head = date("[H:i:s] ") . "[E] ";
        if (ZMBuf::$info_level !== null && in_array(ZMBuf::$info_level->get(), [1, 2])) {
            $trace = debug_backtrace()[1] ?? ['file' => '', 'function' => ''];
            $trace = "[" . basename($trace["file"], ".php") . ":" . $trace["function"] . "] ";
@@ -58,90 +55,80 @@ class Console
        echo(self::setColor($head . ($trace ?? "") . $obj, "red") . "\n");
    }

-    static function warning($obj, $head = null)
-    {
-        if ($head === null) $head = date("[H:i:s") . " WARN] ";
+    static function warning($obj, $head = null) {
+        if ($head === null) $head = date("[H:i:s]") . " [W] ";
        if (ZMBuf::$info_level !== null && in_array(ZMBuf::$info_level->get(), [1, 2])) {
            $trace = debug_backtrace()[1] ?? ['file' => '', 'function' => ''];
            $trace = "[" . basename($trace["file"], ".php") . ":" . $trace["function"] . "] ";
        }
-        if (!is_string($obj)) {
-            if (isset($trace)) {
-                var_dump($obj);
-                return;
-            } else $obj = "{Object}";
+        if(ZMBuf::$atomics["info_level"]->get() >= 1) {
+            if (!is_string($obj)) {
+                if (isset($trace)) {
+                    var_dump($obj);
+                    return;
+                } else $obj = "{Object}";
+            }
+            echo(self::setColor($head . ($trace ?? "") . $obj, "yellow") . "\n");
        }
-        echo(self::setColor($head . ($trace ?? "") . $obj, "yellow") . "\n");
    }

-    static function info($obj, $head = null)
-    {
-        if ($head === null) $head = date("[H:i:s ") . "INFO] ";
+    static function info($obj, $head = null) {
+        if ($head === null) $head = date("[H:i:s] ") . "[I] ";
        if (ZMBuf::$info_level !== null && in_array(ZMBuf::$info_level->get(), [1, 2])) {
            $trace = debug_backtrace()[1] ?? ['file' => '', 'function' => ''];
            $trace = "[" . basename($trace["file"], ".php") . ":" . $trace["function"] . "] ";
        }
-        if (!is_string($obj)) {
-            if (isset($trace)) {
-                var_dump($obj);
-                return;
-            } else $obj = "{Object}";
+        if(ZMBuf::$atomics["info_level"]->get() >= 2) {
+            if (!is_string($obj)) {
+                if (isset($trace)) {
+                    var_dump($obj);
+                    return;
+                } else $obj = "{Object}";
+            }
+            echo(self::setColor($head . ($trace ?? "") . $obj, "lightblue") . "\n");
        }
-        echo(self::setColor($head . ($trace ?? "") . $obj, "lightblue") . "\n");
    }

-    static function log($obj, $color = "")
-    {
+    static function success($obj, $head = null) {
+        if ($head === null) $head = date("[H:i:s] ") . "[S] ";
+        if (ZMBuf::$info_level !== null && in_array(ZMBuf::$info_level->get(), [1, 2])) {
+            $trace = debug_backtrace()[1] ?? ['file' => '', 'function' => ''];
+            $trace = "[" . basename($trace["file"], ".php") . ":" . $trace["function"] . "] ";
+        }
+        if(ZMBuf::$atomics["info_level"]->get() >= 2) {
+            if (!is_string($obj)) {
+                if (isset($trace)) {
+                    var_dump($obj);
+                    return;
+                } else $obj = "{Object}";
+            }
+            echo(self::setColor($head . ($trace ?? "") . $obj, "green") . "\n");
+        }
+    }
+
+    static function verbose($obj, $head = null) {
+        if($head === null) $head = date("[H:i:s] ") . "[V] ";
+        if(ZMBuf::$atomics["info_level"]->get() >= 3) {
+            if (!is_string($obj)) {
+                if (isset($trace)) {
+                    var_dump($obj);
+                    return;
+                } else $obj = "{Object}";
+            }
+            echo(self::setColor($head . ($trace ?? "") . $obj, "blue") . "\n");
+        }
+    }
+
+    static function debug($obj) {
+        debug($obj);
+    }
+
+    static function log($obj, $color = "") {
        if (!is_string($obj)) var_dump($obj);
        else echo(self::setColor($obj, $color) . "\n");
    }

-    static function msg($obj, $self_id = "")
-    {
-        if (ZMBuf::$info_level !== null && ZMBuf::$info_level->get() == 3) {
-            if (!isset($obj["post_type"])) {
-                switch ($obj["action"]) {
-                    case "send_private_msg":
-                        $msg = Console::setColor(date("H:i:s ") . "[" . (ZMBuf::globals("robot_alias")[$self_id] ?? "Null") . "] ", "lightlightblue");
-                        $msg .= Console::setColor("私聊↑(" . $obj["params"]["user_id"] . ")", "lightlightblue");
-                        $msg .= Console::setColor(" > ", "gray");
-                        $msg .= $obj["params"]["message"];
-                        Console::log($msg);
-                        break;
-                    case "send_group_msg":
-                        //TODO: 写新的控制台消息（API消息处理）
-                        Console::log(Console::setColor("[" . date("H:i:s") . " GROUP:" . $obj["params"]["group_id"] . "] ", "blue") . Console::setColor($obj["params"]["user_id"] ?? "", "yellow") . Console::setColor(" > ", "gray") . ($obj["params"]["message"] ?? ""));
-                        break;
-                    case "send_discuss_msg":
-                        Console::log(Console::setColor("[" . date("H:i:s") . " DISCUSS:" . $obj["params"]["discuss_id"] . "] ", "blue") . Console::setColor($obj["params"]["user_id"] ?? "", "yellow") . Console::setColor(" > ", "gray") . ($obj["params"]["message"] ?? ""));
-                        break;
-                    case "send_msg":
-                        $obj["action"] = "send_" . $obj["message_type"] . "_msg";
-                        self::msg($obj);
-                        break;
-                    case "send_wechat_msg":
-                        Console::log(Console::setColor("[" . date("H:i:s") . " WECHAT] ", "blue") . Console::setColor($obj["params"]["user_id"] ?? "", "yellow") . Console::setColor(" > ", "gray") . ($obj["params"]["message"] ?? ""));
-                        break;
-                    default:
-                        break;
-                }
-            } else {
-                if ($obj["post_type"] == "message") {
-                    switch ($obj["message_type"]) {
-                        case "group":
-                            //
-                            //TODO: 写新的控制台消息（event处理）
-                        case "private":
-                        case "discuss":
-                        case "wechat":
-                    }
-                }
-            }
-        }
-    }
-
-    static function stackTrace()
-    {
+    static function stackTrace() {
        $log = "Stack trace:\n";
        $trace = debug_backtrace();
        //array_shift($trace);
@@ -165,8 +152,7 @@ class Console
        echo $log;
    }

-    static function listenConsole()
-    {
+    static function listenConsole() {
        if (in_array('--disable-console-input', FrameworkLoader::$argv)) {
            self::info("ConsoleCommand disabled.");
            return;
@@ -183,10 +169,18 @@ class Console
     * @param string $cmd
     * @return bool
     */
-    private static function executeCommand(string $cmd)
-    {
+    private static function executeCommand(string $cmd) {
        $it = explodeMsg($cmd);
        switch ($it[0] ?? '') {
+            case 'logtest':
+                Console::log(date("[H:i:s]"). " [L] This is normal msg. (0)");
+                Console::error("This is error msg. (0)");
+                Console::warning("This is warning msg. (1)");
+                Console::info("This is info msg. (2)");
+                Console::success("This is success msg. (2)");
+                Console::verbose("This is verbose msg. (3)");
+                Console::debug("This is debug msg. (4)");
+                return true;
            case 'call':
                $class_name = $it[1];
                $function_name = $it[2];
@@ -203,6 +197,9 @@ class Console
            case 'echo':
                Console::info($it[1]);
                return true;
+            case 'color':
+                Console::log($it[2], $it[1]);
+                return true;
            case 'stop':
                ZMUtil::stop();
                return false;
@@ -210,6 +207,12 @@ class Console
            case 'r':
                ZMUtil::reload();
                return false;
+            case 'save':
+                $origin = ZMBuf::$atomics["info_level"]->get();
+                ZMBuf::$atomics["info_level"]->set(3);
+                DataProvider::saveBuffer();
+                ZMBuf::$atomics["info_level"]->set($origin);
+                return true;
            case '':
                return true;
            default:
@@ -218,9 +221,8 @@ class Console
        }
    }

-    public static function withSleep(string $string, int $int)
-    {
+    public static function withSleep(string $string, int $int) {
        self::info($string);
        sleep($int);
    }
-}
+}
--- a/src/Framework/DataProvider.php
+++ b/src/Framework/DataProvider.php
@@ -0,0 +1,63 @@
+<?php
+
+
+namespace Framework;
+
+
+class DataProvider
+{
+    public static $buffer_list = [];
+
+    public static function getResourceFolder() {
+        return self::getWorkingDir() . '/resources/';
+    }
+
+    public static function getWorkingDir() {
+        global $is_phar;
+        if($is_phar === true) {
+            return realpath('.');
+        }  else {
+            return WORKING_DIR;
+        }
+    }
+
+    public static function getDataConfig() {
+        return CONFIG_DIR;
+    }
+
+    public static function addSaveBuffer($buf_name, $sub_folder = null) {
+        $name = ($sub_folder ?? "") . "/" . $buf_name . ".json";
+        self::$buffer_list[$buf_name] = $name;
+        Console::debug("Added ".$buf_name . " at $sub_folder");
+        ZMBuf::set($buf_name, self::getJsonData($name));
+    }
+
+    public static function saveBuffer() {
+        $head = Console::setColor(date("[H:i:s] ") . "[V] Saving buffer......", "blue");
+        if (ZMBuf::$atomics["info_level"]->get() >= 3)
+            echo $head;
+        foreach (self::$buffer_list as $k => $v) {
+            self::setJsonData($v, ZMBuf::get($k));
+        }
+        if (ZMBuf::$atomics["info_level"]->get() >= 3)
+            echo Console::setColor("saved", "blue") . PHP_EOL;
+    }
+
+    public static function getFrameworkLink() {
+        return ZMBuf::globals("http_reverse_link");
+    }
+
+    public static function getJsonData(string $string) {
+        if (!file_exists(self::getDataConfig() . $string)) return [];
+        return json_decode(file_get_contents(self::getDataConfig() . $string), true);
+    }
+
+    private static function setJsonData($filename, array $args) {
+        Console::debug("Saving ".$filename);
+        file_put_contents(self::getDataConfig() . $filename, json_encode($args, JSON_UNESCAPED_UNICODE | JSON_PRETTY_PRINT | JSON_BIGINT_AS_STRING));
+    }
+
+    public static function getDataFolder() {
+        return ZM_DATA;
+    }
+}
--- a/src/Framework/FrameworkLoader.php
+++ b/src/Framework/FrameworkLoader.php
@@ -3,7 +3,10 @@

 namespace Framework;

+use Co;
+use Swoole\Http\Request;
 use Swoole\Runtime;
+use Swoole\WebSocket\Frame;
 use ZM\Event\EventHandler;
 use Exception;
 use Swoole\WebSocket\Server;
@@ -36,12 +39,16 @@ class FrameworkLoader
        if (self::$instance !== null) die("Cannot run two FrameworkLoader in one process!");
        self::$instance = $this;
        self::$argv = $args;
-
-        chdir(__DIR__ . '/../..');
-        define('WORKING_DIR', getcwd());
-        Runtime::enableCoroutine();
        $this->requireGlobalFunctions();
+        if (!isPharMode()) {
+            define('WORKING_DIR', getcwd());
+        } else {
+            echo "Phar mode: " . WORKING_DIR . PHP_EOL;
+        }
        $this->registerAutoloader('classLoader');
+        Runtime::enableCoroutine();
+
+
        self::$settings = new GlobalConfig();
        ZMBuf::$globals = self::$settings;
        if (!self::$settings->success) die("Failed to load global config. Please check config/global.php file");
@@ -52,17 +59,46 @@ class FrameworkLoader
        try {
            $this->server = new Server(self::$settings->get("host"), self::$settings->get("port"));
            if (in_array("--remote-shell", $args)) RemoteShell::listen($this->server, "127.0.0.1");
-            $this->server->set(self::$settings->get("swoole"));
+            $settings = self::$settings->get("swoole");
+            if (in_array("--daemon", $args)) {
+                $settings["daemonize"] = 1;
+                Console::log("已启用守护进程，输出重定向到 " . $settings["log_file"]);
+                self::$argv[] = "--disable-console-input";
+            }
+            $this->server->set($settings);
            $this->server->on("WorkerStart", [$this, "onWorkerStart"]);
-            $this->server->on("message", function ($server, $frame) { EventHandler::callSwooleEvent("message", $server, $frame); });
+            $this->server->on("message", function ($server, Frame $frame) {
+                Console::debug("Calling Swoole \"message\" event from fd=" . $frame->fd);
+                EventHandler::callSwooleEvent("message", $server, $frame);
+            });
            $this->server->on("request", function ($request, $response) {
                $response = new Response($response);
+                Console::debug("Receiving Http request event, cid=" . Co::getCid());
                EventHandler::callSwooleEvent("request", $request, $response);
            });
-            $this->server->on("open", function ($server, $request) { EventHandler::callSwooleEvent("open", $server, $request); });
-            $this->server->on("close", function ($server, $fd) { EventHandler::callSwooleEvent("close", $server, $fd); });
+            $this->server->on("open", function ($server, Request $request) {
+                Console::debug("Calling Swoole \"open\" event from fd=" . $request->fd);
+                EventHandler::callSwooleEvent("open", $server, $request);
+            });
+            $this->server->on("close", function ($server, $fd) {
+                Console::debug("Calling Swoole \"close\" event from fd=" . $fd);
+                EventHandler::callSwooleEvent("close", $server, $fd);
+            });
            ZMBuf::initAtomic();
-            Console::info("host: ".self::$settings->get("host").", port: ".self::$settings->get("port"));
+            if (in_array("--log-error", $args)) ZMBuf::$atomics["info_level"]->set(0);
+            if (in_array("--log-warning", $args)) ZMBuf::$atomics["info_level"]->set(1);
+            if (in_array("--log-info", $args)) ZMBuf::$atomics["info_level"]->set(2);
+            if (in_array("--log-verbose", $args)) ZMBuf::$atomics["info_level"]->set(3);
+            if (in_array("--log-debug", $args)) ZMBuf::$atomics["info_level"]->set(4);
+            Console::log(
+                "host: " . self::$settings->get("host") .
+                ", port: " . self::$settings->get("port") .
+                ", log_level: " . ZMBuf::$atomics["info_level"]->get() .
+                ", version: " . json_decode(file_get_contents(WORKING_DIR . "/composer.json"), true)["version"] .
+                "\nworking_dir: ".(isPharMode() ? realpath('.') : WORKING_DIR)
+            );
+            global $motd;
+            echo $motd . PHP_EOL;
            $this->server->start();
        } catch (Exception $e) {
            Console::error("Framework初始化出现错误，请检查！");
@@ -72,7 +108,7 @@ class FrameworkLoader
    }

    private function requireGlobalFunctions() {
-        require __DIR__ . '/global_functions.php';
+        require_once __DIR__ . '/global_functions.php';
    }

    private function registerAutoloader(string $string) {
@@ -111,3 +147,14 @@ class FrameworkLoader
        EventHandler::callSwooleEvent("WorkerStart", $server, $worker_id);
    }
 }
+
+global $motd;
+$motd = <<<EOL
+ ______                                 
+|__  / |__   __ _ _ __ ___   __ _  ___  
+  / /| '_ \ / _` | '_ ` _ \ / _` |/ _ \ 
+ / /_| | | | (_| | | | | | | (_| | (_) |
+/____|_| |_|\__,_|_| |_| |_|\__,_|\___/ 
+
+EOL;
+
--- a/src/Framework/GlobalConfig.php
+++ b/src/Framework/GlobalConfig.php
@@ -18,7 +18,8 @@ class GlobalConfig
    public $success = false;

    public function __construct() {
-        include_once WORKING_DIR . '/config/global.php';
+        /** @noinspection PhpIncludeInspection */
+        include_once DataProvider::getWorkingDir() . '/config/global.php';
        global $config;
        $this->success = true;
        $this->config = $config;
--- a/src/Framework/InfoLevel.php
+++ b/src/Framework/InfoLevel.php
@@ -1,10 +0,0 @@
-<?php
-
-
-namespace Framework;
-
-
-class InfoLevel
-{
-    const INFO = 0;
-}
--- a/src/Framework/Logger.php
+++ b/src/Framework/Logger.php
@@ -1,18 +0,0 @@
-<?php
-
-
-namespace Framework;
-
-
-use Swoole\Coroutine\System;
-
-class Logger
-{
-    private static function getTimeFormat($type = "I") {
-        return "[" . date("Y-m-d H:i:s") . "]\t[" . $type . "]\t";
-    }
-
-    public static function writeSwooleLog($log) {
-        System::writeFile(CRASH_DIR . "swoole_error.log", "\n" . self::getTimeFormat() . $log, FILE_APPEND);
-    }
-}
--- a/src/Framework/ZMBuf.php
+++ b/src/Framework/ZMBuf.php
@@ -11,7 +11,6 @@ namespace Framework;
 use Swoole\Atomic;
 use swoole_atomic;
 use ZM\connection\WSConnection;
-use ZM\Utils\Scheduler;
 use ZM\Utils\SQLPool;

 class ZMBuf
@@ -22,8 +21,7 @@ class ZMBuf
    /** @var WSConnection[] */
    static $connect = [];//储存连接实例的数组
    //Scheduler计划任务连接实例，只可以在单worker_num时使用
-    /** @var Scheduler|null */
-    static $scheduler = null;
+    static $scheduler = null; //This is stupid warning...

    //Swoole SQL连接池，多进程下每个进程一个连接池
    /** @var SQLPool */
@@ -52,6 +50,7 @@ class ZMBuf
    public static $req_mapping = [];
    public static $config = [];
    public static $context = [];
+    public static $instance = [];

    static function get($name, $default = null) {
        return self::$cache[$name] ?? $default;
@@ -106,6 +105,7 @@ class ZMBuf
        self::$cache = [];
        self::$connect = [];
        self::$time_nlp = null;
+        self::$instance = [];
    }

    /**
--- a/src/Framework/global_functions.php
+++ b/src/Framework/global_functions.php
@@ -1,9 +1,14 @@
 <?php

 use Framework\Console;
+use Framework\DataProvider;
 use Framework\ZMBuf;
 use ZM\Context\ContextInterface;

+function isPharMode(){
+    return substr(__DIR__, 0, 7) == 'phar://';
+}
+
 function classLoader($p) {
    $filepath = getClassPath($p);
    if ($filepath === null)
@@ -19,11 +24,16 @@ function classLoader($p) {

 function getClassPath($class_name) {
    $dir = str_replace("\\", "/", $class_name);
-    $dir = WORKING_DIR . "/src/" . $dir . ".php";
-    //echo "@@@".$dir.PHP_EOL;
-    $dir = str_replace("\\", "/", $dir);
-    if (file_exists($dir)) return $dir;
-    else return null;
+    $dir2 = WORKING_DIR . "/src/" . $dir . ".php";
+    //echo "@@@".$dir2.PHP_EOL;
+    $dir2 = str_replace("\\", "/", $dir2);
+    if (file_exists($dir2)) return $dir2;
+    else {
+        $dir = DataProvider::getWorkingDir() . "/src/" . $dir . ".php";
+        //echo "###".$dir.PHP_EOL;
+        if (file_exists($dir)) return $dir;
+        else return null;
+    }
 }

 /**
@@ -176,6 +186,6 @@ function context() {
 }

 function debug($msg) {
-    if (ZMBuf::$atomics["info_level"]->get() == 1)
-        Console::log(date("[H:i:s ") . "DEBUG] " . $msg, 'gray');
+    if (ZMBuf::$atomics["info_level"]->get() >= 4)
+        Console::log(date("[H:i:s] ") . "[D] " . $msg, 'gray');
 }
--- a/src/Module/Example/Hello.php
+++ b/src/Module/Example/Hello.php
@@ -15,35 +15,41 @@ use ZM\ModBase;
 /**
 * Class Hello
 * @package Module\Example
+ * @since 1.0
 */
 class Hello extends ModBase
 {
    /**
+     * 在机器人连接后向终端输出信息
     * @SwooleEventAt("open",rule="connectType:qq")
     * @param $conn
     */
-    public function onConnect(CQConnection $conn){
-        Console::info("机器人 ".$conn->getQQ()." 已连接！");
+    public function onConnect(CQConnection $conn) {
+        Console::info("机器人 " . $conn->getQQ() . " 已连接！");
    }
+
    /**
+     * 向机器人发送"你好"，即可回复这句话
     * @CQCommand("你好")
     */
-    public function hello(){
+    public function hello() {
        return "你好啊，我是由炸毛框架构建的机器人！";
    }

    /**
-     * @RequestMapping("/test/ping")
+     * 中间件测试的一个示例函数
+     * @RequestMapping("/httpTimer")
     * @Middleware("timer")
     */
-    public function pong(){
-        return "pong";
+    public function timer() {
+        return "This page is used as testing TimerMiddleware! Do not use it in production.";
    }

    /**
+     * 框架会默认关闭未知的WebSocket链接，因为这个绑定的事件，你可以根据你自己的需求进行修改
     * @SwooleEventAt(type="open",rule="connectType:unknown")
     */
-    public function closeUnknownConn(){
+    public function closeUnknownConn() {
        Console::info("Unknown connection , I will close it.");
        $this->connection->close();
    }
--- a/src/ZM/API/CQ.php
+++ b/src/ZM/API/CQ.php
@@ -18,7 +18,7 @@ class CQ
        if (is_numeric($qq) || $qq === "all") {
            return "[CQ:at,qq=" . $qq . "]";
        }
-        Console::error("传入的QQ号码($qq)错误！");
+        Console::warning("传入的QQ号码($qq)错误！");
        return " ";
    }

@@ -31,7 +31,7 @@ class CQ
        if (is_numeric($id)) {
            return "[CQ:face,id=" . $id . "]";
        }
-        Console::error("传入的face id($id)错误！");
+        Console::warning("传入的face id($id)错误！");
        return " ";
    }

@@ -44,7 +44,7 @@ class CQ
        if (is_numeric($id)) {
            return "[CQ:emoji,id=" . $id . "]";
        }
-        Console::error("传入的emoji id($id)错误！");
+        Console::warning("传入的emoji id($id)错误！");
        return " ";
    }

@@ -66,7 +66,7 @@ class CQ
        if (is_numeric($id)) {
            return "[CQ:sface,id=" . $id . "]";
        }
-        Console::error("传入的sface id($id)错误！");
+        Console::warning("传入的sface id($id)错误！");
        return " ";
    }

@@ -151,7 +151,7 @@ class CQ
                return "[CQ:music,type=$type,id=$id_or_url]";
            case "custom":
                if ($title === null || $audio === null) {
-                    Console::error("传入CQ码实例的标题和音频链接不能为空！");
+                    Console::warning("传入CQ码实例的标题和音频链接不能为空！");
                    return " ";
                }
                if ($content === null) $c = "";
@@ -160,7 +160,7 @@ class CQ
                else $i = ",image=" . $image;
                return "[CQ:music,type=custom,url=" . $id_or_url . ",audio=" . $audio . ",title=" . $title . $c . $i . "]";
            default:
-                Console::error("传入的music type($type)错误！");
+                Console::warning("传入的music type($type)错误！");
                return " ";
        }
    }
@@ -217,4 +217,4 @@ class CQ
        }
        return $msg;
    }
-}
+}
--- a/src/ZM/API/CQAPI.php
+++ b/src/ZM/API/CQAPI.php
@@ -10,6 +10,7 @@ use Framework\ZMBuf;
 use ZM\Connection\ConnectionManager;
 use ZM\Connection\CQConnection;
 use ZM\Connection\WSConnection;
+use ZM\Utils\ZMRobot;

 /**
 * @method static send_private_msg($self_id, $params, $function = null)
@@ -68,19 +69,26 @@ use ZM\Connection\WSConnection;
 */
 class CQAPI
 {
-    public static function quick_reply(WSConnection $conn, $data, $msg, $yield = null) {
+    public static function quick_reply(CQConnection $conn, $data, $msg, $yield = null) {
        switch ($data["message_type"]) {
            case "group":
-                return self::send_group_msg($conn, ["group_id" => $data["group_id"], "message" => $msg], $yield);
+                return (new ZMRobot($conn))->setCallback($yield)->sendGroupMsg($data["group_id"], $msg);
            case "private":
-                return self::send_private_msg($conn, ["user_id" => $data["user_id"], "message" => $msg], $yield);
+                return (new ZMRobot($conn))->setCallback($yield)->sendPrivateMsg($data["user_id"], $msg);
            case "discuss":
-                return self::send_discuss_msg($conn, ["discuss_id" => $data["discuss_id"], "message" => $msg], $yield);
+                return (new ZMRobot($conn))->setCallback($yield)->sendDiscussMsg($data["discuss_id"], $msg);
        }
        return null;
    }

+    /**
+     * @param $name
+     * @param $arg
+     * @return bool
+     * @deprecated
+     */
    public static function __callStatic($name, $arg) {
+        trigger_error("This dynamic CQAPI calling method will be removed after 2.0 version.", E_USER_DEPRECATED);
        $all = self::getSupportedAPIs();
        $find = null;
        if (in_array($name, $all)) $find = $name;
@@ -93,12 +101,12 @@ class CQAPI
            }
        }
        if ($find === null) {
-            Console::error("Unknown API " . $name);
+            Console::warning("Unknown API " . $name);
            return false;
        }
        $reply = ["action" => $find];
        if (!is_array($arg[1])) {
-            Console::error("Error when parsing params. Please make sure your params is an array.");
+            Console::warning("Error when parsing params. Please make sure your params is an array.");
            return false;
        }
        if ($arg[1] != []) {
@@ -107,7 +115,7 @@ class CQAPI
        if (!($arg[0] instanceof CQConnection)) {
            $robot = ConnectionManager::getByType("qq", ["self_id" => $arg[0]]);
            if ($robot == []) {
-                Console::error("发送错误，机器人连接不存在！");
+                Console::warning("发送错误，机器人连接不存在！");
                return false;
            }
            $arg[0] = $robot[0];
@@ -195,7 +203,7 @@ class CQAPI
     * @param |null $function
     * @return bool
     */
-    private static function processAPI($connection, $reply, $function = null) {
+    public static function processAPI($connection, $reply, $function = null) {
        $api_id = ZMBuf::$atomics["wait_msg_id"]->get();
        $reply["echo"] = $api_id;
        ZMBuf::$atomics["wait_msg_id"]->add(1);
@@ -222,7 +230,7 @@ class CQAPI
            ]);
        }
        if ($connection->push(json_encode($reply))) {
-            Console::msg($reply, $connection->getQQ());
+            //Console::msg($reply, $connection->getQQ());
            ZMBuf::$atomics["out_count"]->add(1);
            if ($function === true) {
                Co::suspend();
@@ -232,6 +240,7 @@ class CQAPI
            }
            return true;
        } else {
+            Console::warning("CQAPI send failed, websocket push error.");
            $response = [
                "status" => "failed",
                "retcode" => 999,
@@ -246,4 +255,4 @@ class CQAPI
            return false;
        }
    }
-}
+}
--- a/src/ZM/Annotation/AnnotationParser.php
+++ b/src/ZM/Annotation/AnnotationParser.php
@@ -10,14 +10,16 @@ use ReflectionException;
 use ReflectionMethod;
 use ZM\Annotation\CQ\{CQAfter, CQBefore, CQCommand, CQMessage, CQMetaEvent, CQNotice, CQRequest};
 use ZM\Annotation\Http\{After, Before, Controller, HandleException, Middleware, MiddlewareClass, RequestMapping};
+use Swoole\Timer;
 use ZM\Annotation\Interfaces\CustomAnnotation;
 use ZM\Annotation\Interfaces\Level;
 use ZM\Annotation\Module\{Closed, InitBuffer, SaveBuffer};
-use ZM\Annotation\Swoole\{OnStart, SwooleEventAfter, SwooleEventAt};
+use ZM\Annotation\Swoole\{OnStart, OnTick, SwooleEventAfter, SwooleEventAt};
 use ZM\Annotation\Interfaces\Rule;
 use ZM\Connection\WSConnection;
 use ZM\Http\MiddlewareInterface;
-use ZM\Utils\DataProvider;
+use Framework\DataProvider;
+use ZM\Utils\ZMUtil;

 class AnnotationParser
 {
@@ -28,7 +30,7 @@ class AnnotationParser
     */
    public static function registerMods() {
        self::loadAnnotationClasses();
-        $all_class = getAllClasses(WORKING_DIR . "/src/Module/", "Module");
+        $all_class = getAllClasses(DataProvider::getWorkingDir() . "/src/Module/", "Module");
        ZMBuf::$req_mapping[0] = [
            'id' => 0,
            'pid' => -1,
@@ -36,6 +38,7 @@ class AnnotationParser
        ];
        $reader = new AnnotationReader();
        foreach ($all_class as $v) {
+            Console::debug("正在检索 ".$v);
            $reflection_class = new ReflectionClass($v);
            $class_prefix = '';
            $methods = $reflection_class->getMethods(ReflectionMethod::IS_PUBLIC);
@@ -45,13 +48,15 @@ class AnnotationParser
                if ($vs instanceof Closed) {
                    continue 2;
                } elseif ($vs instanceof Controller) {
+                    Console::debug("找到 Controller 中间件: " . $vs->class);
                    $class_prefix = $vs->prefix;
                } elseif ($vs instanceof SaveBuffer) {
+                    Console::debug("注册自动保存的缓存变量: " . $vs->buf_name . " (Dir:" . $vs->sub_folder . ")");
                    DataProvider::addSaveBuffer($vs->buf_name, $vs->sub_folder);
                } elseif ($vs instanceof InitBuffer) {
                    ZMBuf::set($vs->buf_name, []);
                } elseif ($vs instanceof MiddlewareClass) {
-                    Console::info("正在注册中间件 " . $vs->class);
+                    Console::verbose("正在注册中间件 " . $reflection_class->getName());
                    $result = [
                        "class" => "\\" . $reflection_class->getName()
                    ];
@@ -95,13 +100,14 @@ class AnnotationParser
                    elseif ($vss instanceof CQCommand) ZMBuf::$events[CQCommand::class][] = $vss;
                    elseif ($vss instanceof RequestMapping) {
                        self::registerRequestMapping($vss, $vs, $reflection_class, $class_prefix);
-                        if($middleware_addon !== null)
+                        if ($middleware_addon !== null)
                            ZMBuf::$events[MiddlewareInterface::class][$vss->class][$vss->method] = $middleware_addon->middleware;
                    } elseif ($vss instanceof CustomAnnotation) ZMBuf::$events[get_class($vss)][] = $vss;
                    elseif ($vss instanceof CQBefore) ZMBuf::$events[CQBefore::class][$vss->cq_event][] = $vss;
                    elseif ($vss instanceof CQAfter) ZMBuf::$events[CQAfter::class][$vss->cq_event][] = $vss;
                    elseif ($vss instanceof OnStart) ZMBuf::$events[OnStart::class][] = $vss;
                    elseif ($vss instanceof Middleware) ZMBuf::$events[MiddlewareInterface::class][$vss->class][$vss->method] = $vss->middleware;
+                    elseif ($vss instanceof OnTick) self::addTimerTick($vss);
                }
            }
        }
@@ -123,6 +129,10 @@ class AnnotationParser
                }
            }
        }
+        if (ZMBuf::isset("timer_count")) {
+            Console::info("Added " . ZMBuf::get("timer_count") . " timer(s)!");
+            ZMBuf::unsetCache("timer_count");
+        }
    }

    private static function getRuleCallback($rule_str) {
@@ -290,9 +300,9 @@ class AnnotationParser
            $s = WORKING_DIR . '/src/' . str_replace("\\", "/", $v) . ".php";
            require_once $s;
        }
-        $class = getAllClasses(WORKING_DIR . "/src/Custom/Annotation/", "Custom\\Annotation");
+        $class = getAllClasses(DataProvider::getWorkingDir() . "/src/Custom/Annotation/", "Custom\\Annotation");
        foreach ($class as $v) {
-            $s = WORKING_DIR . '/src/' . str_replace("\\", "/", $v) . ".php";
+            $s = DataProvider::getWorkingDir() . '/src/' . str_replace("\\", "/", $v) . ".php";
            require_once $s;
        }
    }
@@ -306,4 +316,9 @@ class AnnotationParser
                $tree[] = &$items[$item['id']];
        return $tree;
    }
+
+    private static function addTimerTick(?OnTick $vss) {
+        ZMBuf::set("timer_count", ZMBuf::get("timer_count", 0) + 1);
+        Timer::tick($vss->tick_ms, [ZMUtil::getModInstance($vss->class), $vss->method]);
+    }
 }
--- a/src/ZM/Annotation/Swoole/OnTick.php
+++ b/src/ZM/Annotation/Swoole/OnTick.php
@@ -0,0 +1,25 @@
+<?php
+
+
+namespace ZM\Annotation\Swoole;
+
+
+use Doctrine\Common\Annotations\Annotation\Required;
+use Doctrine\Common\Annotations\Annotation\Target;
+use ZM\Annotation\AnnotationBase;
+
+/**
+ * Class OnTick
+ * @package ZM\Annotation\Swoole
+ * @Annotation
+ * @Target("METHOD")
+ * @since 1.2
+ */
+class OnTick extends AnnotationBase
+{
+    /**
+     * @var int
+     * @Required()
+     */
+    public $tick_ms;
+}
--- a/src/ZM/Connection/CQConnection.php
+++ b/src/ZM/Connection/CQConnection.php
@@ -20,4 +20,4 @@ class CQConnection extends WSConnection
    public function getType() {
        return "qq";
    }
-}
+}
--- a/src/ZM/Connection/ConnectionManager.php
+++ b/src/ZM/Connection/ConnectionManager.php
@@ -5,13 +5,14 @@ namespace ZM\Connection;


 use Framework\ZMBuf;
+use Framework\DataProvider;

 class ConnectionManager
 {
    /**
     * 通过server的fd获取WSConnection实例化对象
     * @param int $fd
-     * @return WSConnection
+     * @return WSConnection|CQConnection|ProxyConnection
     */
    public static function get(int $fd) {
        foreach (ZMBuf::$connect as $v) {
@@ -23,7 +24,7 @@ class ConnectionManager
    /**
     * @param string $type
     * @param array $option
-     * @return WSConnection[]
+     * @return WSConnection[]|CQConnection[]
     */
    public static function getByType(string $type, $option = []) {
        $conn = [];
@@ -67,7 +68,7 @@ class ConnectionManager
    }

    public static function registerCustomClass() {
-        $classes = getAllClasses(WORKING_DIR . "/src/Custom/Connection/", "Custom\\Connection");
+        $classes = getAllClasses(DataProvider::getWorkingDir(). "/src/Custom/Connection/", "Custom\\Connection");
        ZMBuf::$custom_connection_class = $classes;
    }
-}
+}
--- a/src/ZM/Connection/WSConnection.php
+++ b/src/ZM/Connection/WSConnection.php
@@ -5,7 +5,6 @@ namespace ZM\Connection;


 use Framework\Console;
-use Framework\Logger;
 use swoole_websocket_server;

 abstract class WSConnection
@@ -43,10 +42,10 @@ abstract class WSConnection
        }
        if ($this->server->push($this->fd, $data) === false) {
            $data = unicode_decode($data);
-            if ($push_error_record) Logger::writeSwooleLog("API push failed. Data: " . $data);
-            Console::error("websocket数据未成功推送，长度：" . strlen($data));
+            if ($push_error_record) Console::warning("API push failed. Data: " . $data);
+            Console::warning("websocket数据未成功推送，长度：" . strlen($data));
            return false;
        }
        return true;
    }
-}
+}
--- a/src/ZM/Context/Context.php
+++ b/src/ZM/Context/Context.php
@@ -7,7 +7,10 @@ namespace ZM\Context;
 use Swoole\Http\Request;
 use Swoole\WebSocket\Frame;
 use swoole_server;
+use ZM\Connection\ConnectionManager;
+use ZM\Connection\CQConnection;
 use ZM\Http\Response;
+use ZM\Utils\ZMRobot;

 class Context implements ContextInterface
 {
@@ -68,4 +71,12 @@ class Context implements ContextInterface
    public function getCid() {
        return $this->cid;
    }
+
+    /**
+     * @return ZMRobot|null
+     */
+    public function getRobot() {
+        $conn = ConnectionManager::get($this->getFrame()->fd);
+        return $conn instanceof CQConnection ? new ZMRobot($conn) : null;
+    }
 }
--- a/src/ZM/Context/ContextInterface.php
+++ b/src/ZM/Context/ContextInterface.php
@@ -8,6 +8,7 @@ use Swoole\Http\Request;
 use Swoole\WebSocket\Frame;
 use Swoole\WebSocket\Server;
 use ZM\Http\Response;
+use ZM\Utils\ZMRobot;

 interface ContextInterface
 {
@@ -30,4 +31,7 @@ interface ContextInterface

    /** @return Request */
    public function getRequest();
+
+    /** @return ZMRobot */
+    public function getRobot();
 }
--- a/src/ZM/DB/DB.php
+++ b/src/ZM/DB/DB.php
@@ -14,6 +14,9 @@ class DB
 {
    private static $table_list = [];

+    /**
+     * @throws DbException
+     */
    public static function initTableList() {
        $result = self::rawQuery("select TABLE_NAME from INFORMATION_SCHEMA.TABLES where TABLE_SCHEMA='" . ZMBuf::globals("sql_config")["sql_database"] . "';", []);
        foreach ($result as $v) {
@@ -40,10 +43,19 @@ class DB
        return Table::getTableInstance($table_name);
    }

+    /**
+     * @param $line
+     * @throws DbException
+     */
    public static function statement($line) {
        self::rawQuery($line, []);
    }

+    /**
+     * @param $line
+     * @return bool
+     * @throws DbException
+     */
    public static function unprepared($line) {
        if (ZMBuf::get("sql_log") === true) {
            $starttime = microtime(true);
@@ -64,15 +76,22 @@ class DB
                    "] " . $line . " (Error:" . $e->getMessage() . ")\n";
                Coroutine::writeFile(CRASH_DIR . "sql.log", $log, FILE_APPEND);
            }
-            Console::error($e->getMessage());
-            return false;
+            Console::warning($e->getMessage());
+            throw $e;
        }
    }

+    /**
+     * @param string $line
+     * @param array $params
+     * @return mixed
+     * @throws DbException
+     */
    public static function rawQuery(string $line, $params = []) {
        if (ZMBuf::get("sql_log") === true) {
            $starttime = microtime(true);
        }
+        Console::debug("MySQL: ".$line);
        try {
            $conn = ZMBuf::$sql_pool->get();
            if ($conn === false) {
@@ -113,8 +132,8 @@ class DB
                    "] " . $line . " " . json_encode($params, JSON_UNESCAPED_UNICODE) . " (Error:" . $e->getMessage() . ")\n";
                Coroutine::writeFile(CRASH_DIR . "sql.log", $log, FILE_APPEND);
            }
-            Console::error($e->getMessage());
-            return false;
+            Console::warning($e->getMessage());
+            throw $e;
        }
    }

--- a/src/ZM/DB/DeleteBody.php
+++ b/src/ZM/DB/DeleteBody.php
@@ -4,6 +4,8 @@
 namespace ZM\DB;


+use ZM\Exception\DbException;
+
 class DeleteBody
 {
    use WhereBody;
@@ -21,8 +23,12 @@ class DeleteBody
        $this->table = $table;
    }

+    /**
+     * @return mixed
+     * @throws DbException
+     */
    public function save() {
        list($sql, $param) = $this->getWhereSQL();
        return DB::rawQuery("DELETE FROM " . $this->table->getTableName() . " WHERE " . $sql, $param);
    }
-}
+}
--- a/src/ZM/DB/InsertBody.php
+++ b/src/ZM/DB/InsertBody.php
@@ -4,6 +4,8 @@
 namespace ZM\DB;


+use ZM\Exception\DbException;
+
 class InsertBody
 {
    /**
@@ -22,6 +24,9 @@ class InsertBody
        $this->row = $row;
    }

+    /**
+     * @throws DbException
+     */
    public function save() {
        DB::rawQuery('INSERT INTO ' . $this->table->getTableName() . ' VALUES ('.implode(',', array_fill(0, count($this->row), '?')).')', $this->row);
    }
--- a/src/ZM/DB/SelectBody.php
+++ b/src/ZM/DB/SelectBody.php
@@ -5,6 +5,7 @@ namespace ZM\DB;


 use Framework\Console;
+use ZM\Exception\DbException;

 class SelectBody
 {
@@ -23,8 +24,16 @@ class SelectBody
        $this->select_thing = $select_thing;
    }

+    /**
+     * @return null
+     * @throws DbException
+     */
    public function get() { return $this->fetchAll(); }

+    /**
+     * @return null
+     * @throws DbException
+     */
    public function fetchAll() {
        if ($this->table->isCacheEnabled()) {
            $rr = md5(implode(",", $this->select_thing) . serialize($this->where_thing));
@@ -40,10 +49,19 @@ class SelectBody
        return $this->getResult();
    }

+    /**
+     * @return mixed|null
+     * @throws DbException
+     */
    public function fetchFirst() {
        return $this->fetchAll()[0] ?? null;
    }

+    /**
+     * @param null $key
+     * @return mixed|null
+     * @throws DbException
+     */
    public function value($key = null) {
        $r = $this->fetchFirst();
        if ($r === null) return null;
@@ -52,6 +70,9 @@ class SelectBody
        else return $r[$key] ?? null;
    }

+    /**
+     * @throws DbException
+     */
    public function execute() {
        $str = $this->queryPrepare();
        $this->result = DB::rawQuery($str[0], $str[1]);
--- a/src/ZM/Event/EventHandler.php
+++ b/src/ZM/Event/EventHandler.php
@@ -11,6 +11,7 @@ use Framework\Console;
 use Framework\ZMBuf;
 use ZM\Event\Swoole\{MessageEvent, RequestEvent, WorkerStartEvent, WSCloseEvent, WSOpenEvent};
 use ZM\Http\Response;
+use Framework\DataProvider;
 use ZM\Utils\ZMUtil;

 class EventHandler
@@ -21,15 +22,22 @@ class EventHandler
        switch ($event_name) {
            case "workerstart":
                try {
+                    register_shutdown_function(function () {
+                        $error = error_get_last();
+                        if ($error["type"] != 0) {
+                            Console::error("Internal fatal error: " . $error["message"] . " at " . $error["file"] . "({$error["line"]})");
+                        }
+                        DataProvider::saveBuffer();
+                        ZMBuf::$server->shutdown();
+                    });
                    (new WorkerStartEvent($param0, $param1))->onActivate()->onAfter();
                    Console::log("\n=== Worker #" . $param0->worker_id . " 已启动 ===\n", "gold");
                } catch (Exception $e) {
                    Console::error("Worker加载出错！停止服务！");
                    Console::error($e->getMessage() . "\n" . $e->getTraceAsString());
-
                    ZMUtil::stop();
                    return;
-                } catch(Error $e) {
+                } catch (Error $e) {
                    var_export($e);
                    ZMUtil::stop();
                }
@@ -43,8 +51,8 @@ class EventHandler
                } catch (Exception $e) {
                    /** @var Response $param1 */
                    $param1->status(500);
-                    Console::info($param0->server["remote_addr"].":".$param0->server["remote_port"].
-                        " [".$param1->getStatusCode()."] ".$param0->server["request_uri"]
+                    Console::info($param0->server["remote_addr"] . ":" . $param0->server["remote_port"] .
+                        " [" . $param1->getStatusCode() . "] " . $param0->server["request_uri"]
                    );
                    if (!$param1->isEnd()) $param1->end("Internal server error: " . $e->getMessage());
                    Console::error("Internal server error (500), caused by uncaught exception.");
--- a/src/ZM/Event/Swoole/MessageEvent.php
+++ b/src/ZM/Event/Swoole/MessageEvent.php
@@ -60,7 +60,7 @@ class MessageEvent implements SwooleEvent
                }
            }
        } catch (Exception $e) {
-            Console::error("出现错误: " . $e->getMessage());
+            Console::warning("Websocket message event exception: " . $e->getMessage());
        }
        return $this;
    }
--- a/src/ZM/Event/Swoole/RequestEvent.php
+++ b/src/ZM/Event/Swoole/RequestEvent.php
@@ -17,6 +17,7 @@ use ZM\Http\MiddlewareInterface;
 use ZM\Http\Response;
 use ZM\ModBase;
 use ZM\ModHandleType;
+use Framework\DataProvider;
 use ZM\Utils\ZMUtil;

 class RequestEvent implements SwooleEvent
@@ -90,7 +91,7 @@ class RequestEvent implements SwooleEvent
                $path = realpath($base_dir . urldecode($uri));
                if ($path !== false) {
                    if (is_dir($path)) $path = $path . '/';
-                    $work = realpath(WORKING_DIR) . '/';
+                    $work = realpath(DataProvider::getWorkingDir()) . '/';
                    if (strpos($path, $work) !== 0) {
                        $this->responseStatus(403);
                        return $this;
--- a/src/ZM/Event/Swoole/WorkerStartEvent.php
+++ b/src/ZM/Event/Swoole/WorkerStartEvent.php
@@ -9,6 +9,7 @@ use Doctrine\Common\Annotations\AnnotationException;
 use Exception;
 use ReflectionException;
 use Swoole\Coroutine;
+use Swoole\Process;
 use Swoole\Timer;
 use ZM\Annotation\AnnotationBase;
 use ZM\Annotation\AnnotationParser;
@@ -21,10 +22,12 @@ use Framework\Console;
 use Framework\GlobalConfig;
 use Framework\ZMBuf;
 use Swoole\Server;
+use ZM\Exception\DbException;
 use ZM\ModBase;
 use ZM\ModHandleType;
-use ZM\Utils\DataProvider;
+use Framework\DataProvider;
 use ZM\Utils\SQLPool;
+use ZM\Utils\ZMUtil;

 class WorkerStartEvent implements SwooleEvent
 {
@@ -43,9 +46,14 @@ class WorkerStartEvent implements SwooleEvent
     * @return WorkerStartEvent
     * @throws AnnotationException
     * @throws ReflectionException
+     * @throws DbException
     */
    public function onActivate(): WorkerStartEvent {
        Console::info("Worker启动中");
+        Process::signal(SIGINT, function () {
+            Console::warning("Server interrupted by keyboard.");
+            ZMUtil::stop(true);
+        });
        ZMBuf::resetCache(); //清空变量缓存
        ZMBuf::set("wait_start", []); //添加队列，在workerStart运行完成前先让其他协程等待执行
        $this->resetConnections();//释放所有与framework的连接
@@ -53,16 +61,16 @@ class WorkerStartEvent implements SwooleEvent
        //设置炸毛buf中储存的对象
        ZMBuf::$globals = new GlobalConfig();
        ZMBuf::$config = [];
-        $file = scandir(WORKING_DIR . '/config/');
+        $file = scandir(DataProvider::getWorkingDir() . '/config/');
        unset($file[0], $file[1]);
        foreach ($file as $k => $v) {
            if ($v == "global.php") continue;
            $name = explode(".", $v);
            if (($prefix = end($name)) == "json") {
-                ZMBuf::$config[$name[0]] = json_decode(Co::readFile(WORKING_DIR . '/config/' . $v), true);
+                ZMBuf::$config[$name[0]] = json_decode(Co::readFile(DataProvider::getWorkingDir() . '/config/' . $v), true);
                Console::info("已读取配置文件：" . $v);
            } elseif ($prefix == "php") {
-                ZMBuf::$config[$name[0]] = include_once WORKING_DIR . '/config/' . $v;
+                ZMBuf::$config[$name[0]] = include_once DataProvider::getWorkingDir() . '/config/' . $v;
                if (is_array(ZMBuf::$config[$name[0]]))
                    Console::info("已读取配置文件：" . $v);
            }
@@ -90,7 +98,7 @@ class WorkerStartEvent implements SwooleEvent
            Coroutine::resume($v);
        }
        ZMBuf::unsetCache("wait_start");
-        foreach(ZMBuf::$events[OnStart::class] ?? [] as $v) {
+        foreach (ZMBuf::$events[OnStart::class] ?? [] as $v) {
            $class_name = $v->class;
            /** @var ModBase $class */
            $class = new $class_name(["server" => $this->server, "worker_id" => $this->worker_id], ModHandleType::SWOOLE_WORKER_START);
@@ -128,7 +136,7 @@ class WorkerStartEvent implements SwooleEvent
    private function loadAllClass() {
        //加载phar包
        Console::info("加载外部phar包中");
-        $dir = WORKING_DIR . "/resources/package/";
+        $dir = DataProvider::getWorkingDir() . "/resources/package/";
        if (is_dir($dir)) {
            $list = scandir($dir);
            unset($list[0], $list[1]);
@@ -139,8 +147,12 @@ class WorkerStartEvent implements SwooleEvent
        }

        //加载composer类
-        Console::info("加载composer资源中");
-        require_once WORKING_DIR . "/vendor/autoload.php";
+        if (file_exists(DataProvider::getWorkingDir() . "/vendor/autoload.php")) {
+            Console::info("加载composer资源中");
+            require_once DataProvider::getWorkingDir() . "/vendor/autoload.php";
+        } else {
+            if(isPharMode()) require_once WORKING_DIR . "/vendor/autoload.php";
+        }

        //加载各个模块的注解类，以及反射
        Console::info("检索Module中");
@@ -150,8 +162,8 @@ class WorkerStartEvent implements SwooleEvent
        ConnectionManager::registerCustomClass();

        //加载自定义的全局函数
-        if(file_exists(WORKING_DIR."/src/Custom/global_function.php"))
-            require_once WORKING_DIR."/src/Custom/global_function.php";
+        if (file_exists(DataProvider::getWorkingDir() . "/src/Custom/global_function.php"))
+            require_once DataProvider::getWorkingDir() . "/src/Custom/global_function.php";
        $this->afterCheck();
    }

@@ -167,7 +179,7 @@ class WorkerStartEvent implements SwooleEvent
     */
    private function afterCheck() {
        $context_class = ZMBuf::globals("context_class");
-        if(!is_a($context_class, ContextInterface::class, true)) {
+        if (!is_a($context_class, ContextInterface::class, true)) {
            throw new Exception("Context class must implemented from ContextInterface!");
        }
    }
--- a/src/ZM/Exception/RobotNotFoundException.php
+++ b/src/ZM/Exception/RobotNotFoundException.php
@@ -0,0 +1,20 @@
+<?php
+
+
+namespace ZM\Exception;
+
+
+use Exception;
+use Throwable;
+
+/**
+ * Class RobotNotFoundException
+ * @package ZM\Exception
+ * @since 1.2
+ */
+class RobotNotFoundException extends Exception
+{
+    public function __construct($message = "", $code = 0, Throwable $previous = null) {
+        parent::__construct($message, $code, $previous);
+    }
+}
--- a/src/ZM/Utils/DataProvider.php
+++ b/src/ZM/Utils/DataProvider.php
@@ -1,54 +0,0 @@
-<?php
-
-
-namespace ZM\Utils;
-
-
-use Co;
-use Framework\Console;
-use Framework\ZMBuf;
-
-class DataProvider
-{
-    public static $buffer_list = [];
-
-    public static function getResourceFolder() {
-        return WORKING_DIR . '/resources/';
-    }
-
-    public static function getDataConfig(){
-        return CONFIG_DIR;
-    }
-
-    public static function addSaveBuffer($buf_name, $sub_folder = null) {
-        $name = ($sub_folder ?? "") . "/" . $buf_name . ".json";
-        self::$buffer_list[$buf_name] = $name;
-        ZMBuf::set($buf_name, self::getJsonData($name));
-    }
-
-    public static function saveBuffer() {
-        $head = Console::setColor(date("[H:i:s ") . "INFO] Saving buffer......", "lightblue");
-        echo $head;
-        foreach(self::$buffer_list as $k => $v) {
-            self::setJsonData($v, ZMBuf::get($k));
-        }
-        echo Console::setColor("saved", "lightblue").PHP_EOL;
-    }
-
-    public static function getFrameworkLink(){
-        return ZMBuf::globals("http_reverse_link");
-    }
-
-    public static function getJsonData(string $string) {
-        if(!file_exists(self::getDataConfig().$string)) return [];
-        return json_decode(Co::readFile(self::getDataConfig().$string), true);
-    }
-
-    private static function setJsonData($filename, array $args) {
-        Co::writeFile(self::getDataConfig() . $filename, json_encode($args, JSON_UNESCAPED_UNICODE | JSON_PRETTY_PRINT | JSON_BIGINT_AS_STRING));
-    }
-
-    public static function getDataFolder() {
-        return ZM_DATA;
-    }
-}
--- a/src/ZM/Utils/ZMRobot.php
+++ b/src/ZM/Utils/ZMRobot.php
@@ -0,0 +1,412 @@
+<?php
+
+
+namespace ZM\Utils;
+
+use ZM\API\CQAPI;
+use ZM\Connection\ConnectionManager;
+use ZM\Connection\CQConnection;
+use ZM\Exception\RobotNotFoundException;
+
+/**
+ * Class ZMRobot
+ * @package ZM\Utils
+ * @since 1.2
+ */
+class ZMRobot
+{
+    const API_ASYNC = 1;
+    const API_NORMAL = 0;
+    const API_RATE_LIMITED = 2;
+
+    private $connection;
+
+    private $callback = null;
+    private $prefix = 0;
+
+    /**
+     * @param $robot_id
+     * @return ZMRobot
+     * @throws RobotNotFoundException
+     */
+    public static function get($robot_id) {
+        $r = ConnectionManager::getByType("qq", ["self_id" => $robot_id]);
+        if ($r == []) throw new RobotNotFoundException("机器人 " . $robot_id . " 未连接到框架！");
+        return new ZMRobot($r[0]);
+    }
+
+    /**
+     * @throws RobotNotFoundException
+     * @return ZMRobot
+     */
+    public static function getRandom() {
+        $r = ConnectionManager::getByType("qq");
+        if($r == []) throw new RobotNotFoundException("没有任何机器人连接到框架！");
+        return new ZMRobot($r[array_rand($r)]);
+    }
+
+    public function __construct(CQConnection $connection) {
+        $this->connection = $connection;
+    }
+
+    public function setCallback($callback = true) {
+        $this->callback = $callback;
+        return $this;
+    }
+
+    public function setPrefix($prefix = self::API_NORMAL) {
+        $this->prefix = $prefix;
+        return $this;
+    }
+
+    public function sendPrivateMsg($user_id, $message, $auto_escape = false) {
+        return CQAPI::processAPI($this->connection, [
+            'action' => $this->getActionName(__FUNCTION__),
+            'params' => [
+                'user_id' => $user_id,
+                'message' => $message,
+                'auto_escape' => $auto_escape
+            ]
+        ], $this->callback);
+    }
+
+    public function sendGroupMsg($group_id, $message, $auto_escape = false) {
+        return CQAPI::processAPI($this->connection, [
+            'action' => $this->getActionName(__FUNCTION__),
+            'params' => [
+                'group_id' => $group_id,
+                'message' => $message,
+                'auto_escape' => $auto_escape
+            ]
+        ], $this->callback);
+    }
+
+    public function sendDiscussMsg($discuss_id, $message, $auto_escape = false) {
+        return CQAPI::processAPI($this->connection, [
+            'action' => $this->getActionName(__FUNCTION__),
+            'params' => [
+                'discuss_id' => $discuss_id,
+                'message' => $message,
+                'auto_escape' => $auto_escape
+            ]
+        ], $this->callback);
+    }
+
+    public function sendMsg($message_type, $target_id, $message, $auto_escape = false) {
+        return CQAPI::processAPI($this->connection, [
+            'action' => $this->getActionName(__FUNCTION__),
+            'params' => [
+                'message_type' => $message_type,
+                ($message_type == 'private' ? 'user' : $message_type) . '_id' => $target_id,
+                'message' => $message,
+                'auto_escape' => $auto_escape
+            ]
+        ], $this->callback);
+    }
+
+    public function deleteMsg($message_id) {
+        return CQAPI::processAPI($this->connection, [
+            'action' => $this->getActionName(__FUNCTION__),
+            'params' => [
+                'message_id' => $message_id
+            ]
+        ], $this->callback);
+    }
+
+    public function sendLike($user_id, $times = 1) {
+        return CQAPI::processAPI($this->connection, [
+            'action' => $this->getActionName(__FUNCTION__),
+            'params' => [
+                'user_id' => $user_id,
+                'times' => $times
+            ]
+        ], $this->callback);
+    }
+
+    public function setGroupKick($group_id, $user_id, $reject_add_request = false) {
+        return CQAPI::processAPI($this->connection, [
+            'action' => $this->getActionName(__FUNCTION__),
+            'params' => [
+                'group_id' => $group_id,
+                'user_id' => $user_id,
+                'reject_add_request' => $reject_add_request
+            ]
+        ], $this->callback);
+    }
+
+    public function setGroupBan($group_id, $user_id, $duration = 1800) {
+        return CQAPI::processAPI($this->connection, [
+            'action' => $this->getActionName(__FUNCTION__),
+            'params' => [
+                'group_id' => $group_id,
+                'user_id' => $user_id,
+                'duration' => $duration
+            ]
+        ], $this->callback);
+    }
+
+    public function setGroupAnonymousBan($group_id, $anonymous_or_flag, $duration = 1800) {
+        return CQAPI::processAPI($this->connection, [
+            'action' => $this->getActionName(__FUNCTION__),
+            'params' => [
+                'group_id' => $group_id,
+                (is_string($anonymous_or_flag) ? 'flag' : 'anonymous') => $anonymous_or_flag,
+                'duration' => $duration
+            ]
+        ], $this->callback);
+    }
+
+    public function setGroupWholeBan($group_id, $enable = true) {
+        return CQAPI::processAPI($this->connection, [
+            'action' => $this->getActionName(__FUNCTION__),
+            'params' => [
+                'group_id' => $group_id,
+                'enable' => $enable
+            ]
+        ], $this->callback);
+    }
+
+    public function setGroupAdmin($group_id, $user_id, $enable = true) {
+        return CQAPI::processAPI($this->connection, [
+            'action' => $this->getActionName(__FUNCTION__),
+            'params' => [
+                'group_id' => $group_id,
+                'user_id' => $user_id,
+                'enable' => $enable
+            ]
+        ], $this->callback);
+    }
+
+    public function setGroupAnonymous($group_id, $enable = true) {
+        return CQAPI::processAPI($this->connection, [
+            'action' => $this->getActionName(__FUNCTION__),
+            'params' => [
+                'group_id' => $group_id,
+                'enable' => $enable
+            ]
+        ], $this->callback);
+    }
+
+    public function setGroupCard($group_id, $user_id, $card = "") {
+        return CQAPI::processAPI($this->connection, [
+            'action' => $this->getActionName(__FUNCTION__),
+            'params' => [
+                'group_id' => $group_id,
+                'user_id' => $user_id,
+                'card' => $card
+            ]
+        ], $this->callback);
+    }
+
+    public function setGroupLeave($group_id, $is_dismiss = false) {
+        return CQAPI::processAPI($this->connection, [
+            'action' => $this->getActionName(__FUNCTION__),
+            'params' => [
+                'group_id' => $group_id,
+                'is_dismiss' => $is_dismiss
+            ]
+        ], $this->callback);
+    }
+
+    public function setGroupSpecialTitle($group_id, $user_id, $special_title = "", $duration = -1) {
+        return CQAPI::processAPI($this->connection, [
+            'action' => $this->getActionName(__FUNCTION__),
+            'params' => [
+                'group_id' => $group_id,
+                'user_id' => $user_id,
+                'special_title' => $special_title,
+                'duration' => $duration
+            ]
+        ], $this->callback);
+    }
+
+    public function setDiscussLeave($discuss_id) {
+        return CQAPI::processAPI($this->connection, [
+            'action' => $this->getActionName(__FUNCTION__),
+            'params' => [
+                'discuss_id' => $discuss_id
+            ]
+        ], $this->callback);
+    }
+
+    public function setFriendAddRequest($flag, $approve = true, $remark = "") {
+        return CQAPI::processAPI($this->connection, [
+            'action' => $this->getActionName(__FUNCTION__),
+            'params' => [
+                'flag' => $flag,
+                'approve' => $approve,
+                'remark' => $remark
+            ]
+        ], $this->callback);
+    }
+
+    public function setGroupAddRequest($flag, $sub_type, $approve = true, $reason = "") {
+        return CQAPI::processAPI($this->connection, [
+            'action' => $this->getActionName(__FUNCTION__),
+            'params' => [
+                'flag' => $flag,
+                'sub_type' => $sub_type,
+                'approve' => $approve,
+                'reason' => $reason
+            ]
+        ], $this->callback);
+    }
+
+    public function getLoginInfo() {
+        return CQAPI::processAPI($this->connection, ['action' => $this->getActionName(__FUNCTION__)], $this->callback);
+    }
+
+    public function getStrangerInfo($user_id, $no_cache = false) {
+        return CQAPI::processAPI($this->connection, [
+            'action' => $this->getActionName(__FUNCTION__),
+            'params' => [
+                'user_id' => $user_id,
+                'no_cache' => $no_cache
+            ]
+        ], $this->callback);
+    }
+
+    public function getFriendList() {
+        return CQAPI::processAPI($this->connection, [
+            'action' => $this->getActionName(__FUNCTION__)
+        ], $this->callback);
+    }
+
+    public function getGroupList() {
+        return CQAPI::processAPI($this->connection, [
+            'action' => $this->getActionName(__FUNCTION__)
+        ], $this->callback);
+    }
+
+    public function getGroupInfo($group_id, $no_cache = false) {
+        return CQAPI::processAPI($this->connection, [
+            'action' => $this->getActionName(__FUNCTION__),
+            'params' => [
+                'group_id' => $group_id,
+                'no_cache' => $no_cache
+            ]
+        ], $this->callback);
+    }
+
+    public function getGroupMemberInfo($group_id, $user_id, $no_cache = false) {
+        return CQAPI::processAPI($this->connection, [
+            'action' => $this->getActionName(__FUNCTION__),
+            'params' => [
+                'group_id' => $group_id,
+                'user_id' => $user_id,
+                'no_cache' => $no_cache
+            ]
+        ], $this->callback);
+    }
+
+    public function getGroupMemberList($group_id) {
+        return CQAPI::processAPI($this->connection, [
+            'action' => $this->getActionName(__FUNCTION__),
+            'params' => [
+                'group_id' => $group_id
+            ]
+        ]);
+    }
+
+    public function getCookies($domain = "") {
+        return CQAPI::processAPI($this->connection, [
+            'action' => $this->getActionName(__FUNCTION__),
+            'params' => [
+                'domain' => $domain
+            ]
+        ]);
+    }
+
+    public function getCsrfToken() {
+        return CQAPI::processAPI($this->connection, [
+            'action' => $this->getActionName(__FUNCTION__)
+        ], $this->callback);
+    }
+
+    public function getCredentials($domain = "") {
+        return CQAPI::processAPI($this->connection, [
+            'action' => $this->getActionName(__FUNCTION__),
+            'params' => [
+                'domain' => $domain
+            ]
+        ], $this->callback);
+    }
+
+    public function getRecord($file, $out_format, $full_path = false) {
+        return CQAPI::processAPI($this->connection, [
+            'action' => $this->getActionName(__FUNCTION__),
+            'params' => [
+                'file' => $file,
+                'out_format' => $out_format,
+                'full_path' => $full_path
+            ]
+        ], $this->callback);
+    }
+
+    public function getImage($file) {
+        return CQAPI::processAPI($this->connection, [
+            'action' => $this->getActionName(__FUNCTION__),
+            'params' => [
+                'file' => $file
+            ]
+        ], $this->callback);
+    }
+
+    public function canSendImage() {
+        return CQAPI::processAPI($this->connection, [
+            'action' => $this->getActionName(__FUNCTION__)
+        ], $this->callback);
+    }
+
+    public function canSendRecord() {
+        return CQAPI::processAPI($this->connection, [
+            'action' => $this->getActionName(__FUNCTION__)
+        ], $this->callback);
+    }
+
+    public function getStatus() {
+        return CQAPI::processAPI($this->connection, [
+            'action' => $this->getActionName(__FUNCTION__)
+        ], $this->callback);
+    }
+
+    public function getVersionInfo() {
+        return CQAPI::processAPI($this->connection, [
+            'action' => $this->getActionName(__FUNCTION__)
+        ], $this->callback);
+    }
+
+    public function setRestartPlugin($delay = 0) {
+        return CQAPI::processAPI($this->connection, [
+            'action' => $this->getActionName(__FUNCTION__),
+            'params' => [
+                'delay' => $delay
+            ]
+        ], $this->callback);
+    }
+
+    public function cleanDataDir($data_dir) {
+        return CQAPI::processAPI($this->connection, [
+            'action' => $this->getActionName(__FUNCTION__),
+            'params' => [
+                'data_dir' => $data_dir
+            ]
+        ], $this->callback);
+    }
+
+    public function cleanPluginLog() {
+        return CQAPI::processAPI($this->connection, [
+            'action' => $this->getActionName(__FUNCTION__)
+        ], $this->callback);
+    }
+
+    public function getExperimentAPI() {
+        return new ZMRobotExperiment($this->connection, $this->callback, $this->prefix);
+    }
+
+    private function getActionName(string $method) {
+        $prefix = ($this->prefix == self::API_ASYNC ? '_async' : ($this->prefix == self::API_RATE_LIMITED ? '_rate_limited' : ''));
+        $func_name = strtolower(preg_replace('/(?<=[a-z])([A-Z])/', '_$1', $method));
+        return $prefix . $func_name;
+    }
+}
--- a/src/ZM/Utils/ZMRobotExperiment.php
+++ b/src/ZM/Utils/ZMRobotExperiment.php
@@ -0,0 +1,104 @@
+<?php
+
+
+namespace ZM\Utils;
+
+
+use ZM\API\CQAPI;
+use ZM\Connection\CQConnection;
+
+/**
+ * Class ZMRobotExperiment
+ * @package ZM\Utils
+ * @since 1.2
+ */
+class ZMRobotExperiment
+{
+    /**
+     * @var CQConnection
+     */
+    private $connection;
+
+    private $callback = null;
+    private $prefix = 0;
+
+    public function __construct(CQConnection $connection, $callback, $prefix) {
+        $this->connection = $connection;
+        $this->callback = $callback;
+        $this->prefix = $prefix;
+    }
+
+    public function setCallback($callback = true) {
+        $this->callback = $callback;
+        return $this;
+    }
+
+    public function setPrefix($prefix = ZMRobot::API_NORMAL) {
+        $this->prefix = $prefix;
+        return $this;
+    }
+
+    public function getFriendList($flat = false) {
+        return CQAPI::processAPI($this->connection, [
+            'action' => '_' . $this->getActionName(__FUNCTION__),
+            'params' => [
+                'flat' => $flat
+            ]
+        ], $this->callback);
+    }
+
+    public function getGroupInfo($group_id) {
+        return CQAPI::processAPI($this->connection, [
+            'action' => '_' . $this->getActionName(__FUNCTION__),
+            'params' => [
+                'group_id' => $group_id
+            ]
+        ], $this->callback);
+    }
+
+    public function getVipInfo($user_id) {
+        return CQAPI::processAPI($this->connection, [
+            'action' => '_' . $this->getActionName(__FUNCTION__),
+            'params' => [
+                'user_id' => $user_id
+            ]
+        ], $this->callback);
+    }
+
+    public function getGroupNotice($group_id) {
+        return CQAPI::processAPI($this->connection, [
+            'action' => '_' . $this->getActionName(__FUNCTION__),
+            'params' => [
+                'group_id' => $group_id
+            ]
+        ], $this->callback);
+    }
+
+    public function sendGroupNotice($group_id, $title, $content) {
+        return CQAPI::processAPI($this->connection, [
+            'action' => '_' . $this->getActionName(__FUNCTION__),
+            'params' => [
+                'group_id' => $group_id,
+                'title' => $title,
+                'content' => $content
+            ]
+        ], $this->callback);
+    }
+
+    public function setRestart($clean_log = false, $clean_cache = false, $clean_event = false) {
+        return CQAPI::processAPI($this->connection, [
+            'action' => '_' . $this->getActionName(__FUNCTION__),
+            'params' => [
+                'clean_log' => $clean_log,
+                'clean_cache' => $clean_cache,
+                'clean_event' => $clean_event
+            ]
+        ], $this->callback);
+    }
+
+    private function getActionName(string $method) {
+        $prefix = ($this->prefix == ZMRobot::API_ASYNC ? '_async' : ($this->prefix == ZMRobot::API_RATE_LIMITED ? '_rate_limited' : ''));
+        $func_name = strtolower(preg_replace('/(?<=[a-z])([A-Z])/', '_$1', $method));
+        return $prefix . $func_name;
+    }
+}
--- a/src/ZM/Utils/ZMUtil.php
+++ b/src/ZM/Utils/ZMUtil.php
@@ -6,6 +6,7 @@ namespace ZM\Utils;

 use Co;
 use framework\Console;
+use Framework\DataProvider;
 use Framework\ZMBuf;

 class ZMUtil
@@ -14,25 +15,26 @@ class ZMUtil
     * 检查workerStart是否运行结束
     */
    public static function checkWait() {
-        if(ZMBuf::isset("wait_start")) {
+        if (ZMBuf::isset("wait_start")) {
            ZMBuf::append("wait_start", Co::getCid());
            Co::suspend();
        }
    }

-    public static function stop() {
+    public static function stop($without_shutdown = false) {
        Console::info(Console::setColor("Stopping server...", "red"));
        foreach (ZMBuf::$server->connections as $v) {
            ZMBuf::$server->close($v);
        }
        DataProvider::saveBuffer();
-        ZMBuf::$server->shutdown();
+        if (!$without_shutdown)
+            ZMBuf::$server->shutdown();
        ZMBuf::$server->stop();
    }

    public static function getHttpCodePage(int $http_code) {
-        if(isset(ZMBuf::globals("http_default_code_page")[$http_code])) {
-            return Co::readFile(DataProvider::getResourceFolder()."html/".ZMBuf::globals("http_default_code_page")[$http_code]);
+        if (isset(ZMBuf::globals("http_default_code_page")[$http_code])) {
+            return Co::readFile(DataProvider::getResourceFolder() . "html/" . ZMBuf::globals("http_default_code_page")[$http_code]);
        } else return null;
    }

@@ -68,4 +70,13 @@ class ZMUtil
        }
        return ["type" => $type, "params" => $array, "start" => $start, "end" => $end];
    }
-}
+
+    public static function getModInstance($class) {
+        if (!isset(ZMBuf::$instance[$class])) {
+            ZMBuf::$instance[$class] = new $class();
+            return ZMBuf::$instance[$class];
+        } else {
+            return ZMBuf::$instance[$class];
+        }
+    }
+}
Author	SHA1	Message	Date
whale	17ce0c20ae	update SECURITY.md	2020-05-02 23:28:11 +08:00
whale	82a1f86bbd	update to 1.2.1 add phar build script	2020-05-02 23:27:26 +08:00
whale	97e579b8a1	update README.md	2020-04-29 18:11:21 +08:00
whale	3f286c057b	fix ZMRobot function name and deprecate CQAPI	2020-04-29 17:56:44 +08:00
whale	a94746b9fb	update README.md	2020-04-29 15:58:24 +08:00
whale	f726be554a	update SECURITY.md	2020-04-29 15:56:05 +08:00
whale	ac54459ec8	update README.md	2020-04-29 15:53:50 +08:00
whale	b4cef11a55	add MOTD	2020-04-29 15:38:57 +08:00
whale	169a751e0f	update to 1.2 version Generate systemd script Default info_level set to 2 Modify & add some comment for Example module Brand new Console Add daemon command argument Add #OnTick annotation Add ZMRobot API class	2020-04-29 15:29:56 +08:00
whale	e1983d6dd8	update some argument	2020-04-29 11:56:28 +08:00
whale	52f01446b5	add systemd generator.	2020-04-29 11:52:08 +08:00
whale	fa699ac5e0	fix composer dependency version bugs.	2020-04-28 11:19:39 +08:00
Whale	0e952c39f5	Update README.md	2020-04-26 18:15:49 +08:00
Whale	16b885da54	Create SECURITY.md	2020-04-26 18:12:06 +08:00
whale	7e35596f9b	update README.md	2020-04-26 17:39:45 +08:00