From 1f5572a1afb8b614f378203fcb009ddbedf27a6d Mon Sep 17 00:00:00 2001
From: Default <ebay@hk.com>
Date: Sun, 23 Mar 2025 19:02:52 +0800
Subject: [PATCH] 1

---
 code/extend/db/DatabaseManage.php          | 115 --------
 code/extend/db/mongo/MongoBase.php         | 191 -------------
 code/extend/ddl/DDLManage.php              |  66 +++++
 code/extend/ddl/DatabaseManage.ddl         | Bin 0 -> 3744 bytes
 code/extend/ddl/MicroCore.ddl              | Bin 0 -> 11120 bytes
 code/extend/ddl/MongoBase.ddl              | Bin 0 -> 6032 bytes
 code/extend/minserver/MicroCore_bak.php    | 302 ---------------------
 code/extend/minserver/ProcessSanitizer.php |  27 --
 code/extend/minserver/QueueManage.php      |  45 ---
 code/extend/minserver/Rout.php             |  17 --
 code/extend/minserver/ScheduledTasks.php   |  19 --
 code/extend/minserver/ServerConsole.php    |  89 ------
 code/extend/minserver/ServerCore.php       |  87 ------
 code/extend/minserver/ServerManage.php     | 129 ---------
 14 files changed, 66 insertions(+), 1021 deletions(-)
 delete mode 100644 code/extend/db/DatabaseManage.php
 delete mode 100644 code/extend/db/mongo/MongoBase.php
 create mode 100644 code/extend/ddl/DDLManage.php
 create mode 100644 code/extend/ddl/DatabaseManage.ddl
 create mode 100644 code/extend/ddl/MicroCore.ddl
 create mode 100644 code/extend/ddl/MongoBase.ddl
 delete mode 100644 code/extend/minserver/MicroCore_bak.php
 delete mode 100644 code/extend/minserver/ProcessSanitizer.php
 delete mode 100644 code/extend/minserver/QueueManage.php
 delete mode 100644 code/extend/minserver/Rout.php
 delete mode 100644 code/extend/minserver/ScheduledTasks.php
 delete mode 100644 code/extend/minserver/ServerConsole.php
 delete mode 100644 code/extend/minserver/ServerCore.php
 delete mode 100644 code/extend/minserver/ServerManage.php

diff --git a/code/extend/db/DatabaseManage.php b/code/extend/db/DatabaseManage.php
deleted file mode 100644
index 06f67b6..0000000
--- a/code/extend/db/DatabaseManage.php
+++ /dev/null
@@ -1,115 +0,0 @@
-<?php
-
-declare(strict_types=1);
-
-namespace db;
-
-use database\seeders\SeedManager;
-use think\console\Command;
-use think\console\Input;
-use think\console\input\Argument;
-use think\console\Output;
-use think\console\input\Option;
-use think\facade\Db;
-
-class DatabaseManage extends Command
-{
-    protected function configure()
-    {
-        $this->setName('db:manage')
-            ->addArgument('action', \think\console\input\Argument::OPTIONAL, 'The action to perform: backup or init or seed')
-            ->setDescription('Manage the database: backup or initialize');
-    }
-
-    protected function execute(Input $input, Output $Output)
-    {
-        $strAction = $input->getArgument('action');
-
-        if ($strAction === 'backup') {
-            $this->backupDatabase($Output);
-        } elseif ($strAction === 'init') {
-            $this->initializeDatabase($Output);
-        } elseif ($strAction === 'seed') {
-            $this->seed($Output);
-        } else {
-            $Output->writeln("Invalid action. Use 'backup' or 'init'. or 'seed'");
-        }
-    }
-
-    private function seed(Output $Output)
-    {
-        $SeedManager = new SeedManager;
-        $Output->writeln("开始数据播种" . PHP_EOL);
-        $SeedManager->handle();
-        $Output->writeln("数据播种结束");
-    }
-
-    private function backupDatabase(Output $Output)
-    {
-        $arrConfig = config('database.connections.mysql');
-        $strDb = $arrConfig['database'];
-        $strUserName = $arrConfig['username'];
-        $strPwd = $arrConfig['password'];
-        $strHost = $arrConfig['hostname'];
-        $strBackupFile = app()->getRootPath() . 'database/schema/mysql-schema.dump';
-
-        $strTempFile = tempnam(sys_get_temp_dir(), 'mysql-schema-') . '.dump';
-
-        $strCmd = "mysqldump -h{$strHost} -u{$strUserName} -p{$strPwd} --no-data {$strDb} > {$strTempFile}";
-
-        system($strCmd, $intResultCode);
-
-        if ($intResultCode === 0) {
-            if (file_exists($strBackupFile)) {
-                unlink($strBackupFile);
-            }
-
-            if (rename($strTempFile, $strBackupFile)) {
-                $Output->writeln("Database backup successful: {$strBackupFile}");
-            } else {
-                $Output->writeln("Failed to move backup file to destination.");
-            }
-        } else {
-            $Output->writeln("Database backup failed.");
-            unlink($strTempFile);
-        }
-    }
-
-    private function initializeDatabase(Output $Output)
-    {
-        $arrConfig = config('database.connections.mysql');
-        $strDb = $arrConfig['database'];
-        $strUserName = $arrConfig['username'];
-        $strPwd = $arrConfig['password'];
-        $strHost = $arrConfig['hostname'];
-        $strPort = $arrConfig['hostport'];
-        $strBackupFile = app()->getRootPath() . 'database/schema/mysql-schema.dump';
-
-        $checkTableQuery = "SHOW TABLES LIKE 'migrations'";
-        $boolMigrateExists = Db::query($checkTableQuery);
-
-        if (!empty($boolMigrateExists)) {
-            $Output->writeln("数据库已存在，跳过初始化导入");
-            return;
-        }
-
-        $strTempFile = tempnam(sys_get_temp_dir(), 'mysql-schema-') . '.dump';
-
-        if (!copy($strBackupFile, $strTempFile)) {
-            $Output->writeln("创建临时导入文件失败.");
-            return;
-        }
-       
-        $strCmd = "mysql -h{$strHost} -P{$strPort} -u{$strUserName} -p{$strPwd} {$strDb} < {$strTempFile}";
-
-        system($strCmd, $intResultCode);
-
-        if ($intResultCode === 0) {
-            $Output->writeln("成功导入初始化文件");
-        } else {
-            $Output->writeln("初始化文件导入失败");
-        }
-
-        unlink($strTempFile);
-    }
-}
diff --git a/code/extend/db/mongo/MongoBase.php b/code/extend/db/mongo/MongoBase.php
deleted file mode 100644
index 582cb23..0000000
--- a/code/extend/db/mongo/MongoBase.php
+++ /dev/null
@@ -1,191 +0,0 @@
-<?php
-
-namespace db\mongo;
-
-use MongoDB\Client;
-use MongoDB\Exception\Exception as MongoDBException;
-use MongoDB\BSON\UTCDateTime;
-
-class MongoBase
-{
-    private $client;
-
-    /**
-     * Undocumented variable
-     *
-     * @var \MongoDB\Database
-     */
-    private $db;
-
-    private static $instance;
-
-    public static function getInstance(): self
-    {
-
-        // return [
-        //     'uri' => 'mongodb://username:password@your_ip:27017',
-        //     'database' => 'your_database',
-        // ];
-
-        if (!self::$instance) {
-            self::$instance = new self();
-        }
-        return self::$instance;
-    }
-
-    /**
-     * 构造函数，初始化 MongoDB 连接
-     * @param string $uri MongoDB 连接字符串
-     * @param string $dbName 数据库名称
-     */
-    public function __construct()
-    {
-        try {
-            $arrConfig = config('mongodb');
-            $strUri = sprintf('mongodb://%s:%s@%s:%s', $arrConfig['username'], $arrConfig['password'], $arrConfig['hostname'], $arrConfig['hostport']);
-
-            $this->client = new Client($strUri);
-            $this->db = $this->client->selectDatabase($arrConfig['database']);
-        } catch (MongoDBException $e) {
-            throw new \Exception("MongoDB connection failed: " . $e->getMessage());
-        }
-    }
-
-    /**
-     * 获取下一个自增序列值
-     * @param string $sequenceName 序列名称
-     * @return int 自增 ID
-     */
-    public function getNextSequence(string $sequenceName): int
-    {
-        try {
-            $counters = $this->db->selectCollection('counters');
-            $result = $counters->findOneAndUpdate(
-                ['_id' => $sequenceName],
-                ['$inc' => ['sequence_value' => 1]],
-                [
-                    'upsert' => true,
-                    'returnDocument' => \MongoDB\Operation\FindOneAndUpdate::RETURN_DOCUMENT_AFTER
-                ]
-            );
-            return $result->sequence_value ?? 1;
-        } catch (MongoDBException $e) {
-            throw new \Exception("Failed to generate sequence: " . $e->getMessage());
-        }
-    }
-
-    /**
-     * 插入单条数据
-     * @param string $collection 集合名称
-     * @param array $data 数据数组
-     * @return mixed 插入的 ID
-     */
-    public function insertOne(string $collection, array $data)
-    {
-        try {
-            $coll = $this->db->selectCollection($collection);
-            $data['created_at'] = new UTCDateTime(); // 自动添加创建时间
-            $result = $coll->insertOne($data);
-            return $result->getInsertedId();
-        } catch (MongoDBException $e) {
-            throw new \Exception("Insert failed: " . $e->getMessage());
-        }
-    }
-
-    public function getDb(): \MongoDB\Database
-    {
-        return $this->db;
-    }
-
-    /**
-     * 插入多条数据
-     * @param string $collection 集合名称
-     * @param array $data 多条数据数组
-     * @return array 插入的 ID 列表
-     */
-    public function insertMany(string $collection, array $data)
-    {
-        try {
-            $coll = $this->db->selectCollection($collection);
-            foreach ($data as &$item) {
-                $item['created_at'] = new UTCDateTime();
-            }
-            $result = $coll->insertMany($data);
-            return $result->getInsertedIds();
-        } catch (MongoDBException $e) {
-            throw new \Exception("Insert many failed: " . $e->getMessage());
-        }
-    }
-
-    /**
-     * 查询单条数据
-     * @param string $collection 集合名称
-     * @param array $filter 查询条件
-     * @param array $options 查询选项
-     * @return ?object 查询结果
-     */
-    public function findOne(string $collection, array $filter = [], array $options = []): ?object
-    {
-        try {
-            $coll = $this->db->selectCollection($collection);
-            return $coll->findOne($filter, $options);
-        } catch (MongoDBException $e) {
-            throw new \Exception("Find one failed: " . $e->getMessage());
-        }
-    }
-
-    /**
-     * 查询多条数据
-     * @param string $collection 集合名称
-     * @param array $filter 查询条件
-     * @param array $options 查询选项
-     * @return array 查询结果
-     */
-    public function findMany(string $collection, array $filter = [], array $options = []): array
-    {
-        try {
-            $coll = $this->db->selectCollection($collection);
-            $cursor = $coll->find($filter, $options);
-            return iterator_to_array($cursor);
-        } catch (MongoDBException $e) {
-            throw new \Exception("Find many failed: " . $e->getMessage());
-        }
-    }
-
-    /**
-     * 更新单条数据
-     * @param string $collection 集合名称
-     * @param array $filter 查询条件
-     * @param array $update 更新内容
-     * @param array $options 更新选项
-     * @return int 受影响的文档数
-     */
-    public function updateOne(string $collection, array $filter, array $update, array $options = []): int
-    {
-        try {
-            $coll = $this->db->selectCollection($collection);
-            $update['$set']['updated_at'] = new UTCDateTime(); // 自动添加更新时间
-            $result = $coll->updateOne($filter, $update, $options);
-            return $result->getModifiedCount();
-        } catch (MongoDBException $e) {
-            throw new \Exception("Update one failed: " . $e->getMessage());
-        }
-    }
-
-    /**
-     * 删除数据
-     * @param string $collection 集合名称
-     * @param array $filter 查询条件
-     * @return int 删除的文档数
-     */
-    public function delete(string $collection, array $filter): int
-    {
-        try {
-            $coll = $this->db->selectCollection($collection);
-            $result = $coll->deleteMany($filter);
-            return $result->getDeletedCount();
-        } catch (MongoDBException $e) {
-            throw new \Exception("Delete failed: " . $e->getMessage());
-        }
-    }
-}
diff --git a/code/extend/ddl/DDLManage.php b/code/extend/ddl/DDLManage.php
new file mode 100644
index 0000000..4326d1e
--- /dev/null
+++ b/code/extend/ddl/DDLManage.php
@@ -0,0 +1,66 @@
+<?php
+
+declare(strict_types=1);
+
+namespace ddl;
+
+class DDLManage
+{
+    private static $arrLoadedModules = [];
+
+    private static $arrModuleFiles = [
+        'MicroServer' => 'extend/ddl/MicroCore.ddl',
+        'MongoBase' => 'extend/ddl/MongoBase.ddl',
+        'DatabaseManage' => 'extend/ddl/DatabaseManage.ddl',
+    ];
+
+    /**
+     * 加载指定模块
+     * @param string $strModuleCode 模块编码
+     * @return bool 加载是否成功
+     */
+    public static function load($strModuleCode)
+    {
+        if (isset(self::$arrLoadedModules[$strModuleCode])) {
+            return true;
+        }
+
+        if (!isset(self::$arrModuleFiles[$strModuleCode])) {
+            return false;
+        }
+
+        $filename = self::$arrModuleFiles[$strModuleCode];
+
+        $strFileName = root_path() .  $filename;
+
+        if (!file_exists($strFileName)) {
+            return false;
+        }
+
+        if (load_module_file($strFileName)) {
+            self::$arrLoadedModules[$strModuleCode] = true;
+            return true;
+        } else {
+            return false;
+        }
+    }
+
+    /**
+     * 检查模块是否已加载
+     * @param string $strModuleCode 类名
+     * @return bool
+     */
+    public static function isLoaded($strModuleCode)
+    {
+        return isset(self::$arrLoadedModules[$strModuleCode]);
+    }
+
+    /**
+     * 获取所有已加载的模块
+     * @return array
+     */
+    public static function getarrLoadedModules()
+    {
+        return array_keys(self::$arrLoadedModules);
+    }
+}
diff --git a/code/extend/ddl/DatabaseManage.ddl b/code/extend/ddl/DatabaseManage.ddl
new file mode 100644
index 0000000000000000000000000000000000000000..e00387a0fe53df4d333e1296603fcddaf35d613c
GIT binary patch
literal 3744
zcmV;R4qx%?0qGmCJ2W1(5;LbQvu+Op*N^i%j$?S|2a~o5<cl@B_A{3#WXhKNp_Zx9
z=l8H-BBO{D@V2Rc6qR>t;2L}TUVo;Sp(To;B9HlIm)_?}oE<f7&{hq20Mv*V<++`~
z$FOG{_lCUZFLw7CJf3{Kl~jJ~^!zFvm)2*II9=?LJY3N-LD5E(9eq=7V}tTD0J)6P
zU%n4*D7X$4`kk(=v~ROn?6mZwQe$D#A4hl6mw(e-T&WjWRdsxtSLu%LBK&^0lwruZ
z=fo1Cfs`KE3nk0x9SC#=y1%C^l^pfFK}kTQu;6G@QE=6TcI=N|&IUJ{R?KDN$~Y{<
z%Wb&%cSLY{8me2PmB0)6{>9T4BHKlS)4$iEQt^S|37CF?;f=2E6ZCqqNIn$J--j2V
z2Oh;2Z!>ixQ#=%4R`01Lzd(JE+`sEkHbIV}$}(uqN+gIx+*wAh99S#Js^V%_s1f&J
zUkH8ZAKHsf;Q%LEVKuw}PdBA^oHn4+_Z2Bqy*}HieH_{5D8LjlAR=L6DsXb3xUJDh
zpEO|1{)l?%>uOYup0QQH#^Zf7Mu%VRN4ljcw*RoAUSmafVcVoaNzcvLzU>XbIV#CH
zoL^u`QGQ;yt9#Q%LM211xp&&YMf@S$Q+6fS=*Ss9NRPjonK@;Iz5H}4rjCa{TGxc>
zEjU&D8mc1Y00;N8DEOuC-s6H;w*jA1Iqt4lqdyTe%g7@eT7h(92bqkSqe;smRrJ1~
zCkL{(NkG6x!P?kHm8IpzPW4qR!<`OVApXzE(1IK3@Runl^hycv%>W<F*SrKvX8iiW
z@gkrdl?H{9m%ibt1`N|sF2GG`K@Zw8CHi@k6kH%!9KJ!@WH*_9=HJv<4aMj+Vl!O9
zdz+ZijrtOf$o!7a@Qe`r*YQsBxtHzVt<fO*(Ty80EILj@9g;@beha-iSOOis6hTaz
zVkg*@IU~YE(!da^EW0^jra?sCu~AjwIzIfHg?;yVJ>G<Spfi?LLp~P(^#?Ahb+#_4
zp5_+MwT6qmxZdH?IC;U!J|W6Ag=l=`v#p%jnZ+(*T=CXT*b2kas&uH4(ds)M-K)aN
zV{5RmuC7n%7qvI^3~83s)NEZ9AnwpEcIRxbblb#HNif%zf6fsGLVfe}?7kD%n}fhS
zTxmNA4OQtl0#I*0yQHFoDW5{MyKg=^E8dRc<!d$y<jwqfEj_s3fl~0pGVWY-R9hkr
zD>!M3nte1hhx(GU3PCyk>ZR9;P~mQE_N+z_K+F8;bcbepB3P-T&%C;CQnh#R?*iT=
zVNo%NrBfPu6b$iq2Y&Rv7y*piD8S|Lr&b>wv>q9^WG*!G3|Xez#JJ{-8eTxocFF3o
zFG#$6G1R2q*)SV`ydHs&p*tOveKM`{q9<U{e>teQ>B2u%*yp3qx_L_f=>Ww*#C~Lh
zFd=w$U;n?v?6CITE+z5=h+$TzBOoJ&Z<0KR9iJMW---v)npd|McSJOIcWGBL=k9$r
z1&_suAs>ip?nH}G3fb!9e}cj&)Y*P^o<8S~<KothpKP(>)@Ue~_aM++(mXT(qF|`%
zzBvK4XchGp2)^FM1mK?>RK(z8o!FHybv8+5NBUZssx4tx_`@VI#zb(BX;7I<nJX-7
zAnn#1&xlf^QUYqP`EXF}P}_~yEyOb<6Pdh<6OC;EOw;q5-nWxRQFWJupn^XpBo_No
zoGFK76mG!I6(yTX*4t*5*mhE!wgwUwEaE=6!5CQFaiA~WY~I0A(suI$>>*!>S}5Rf
zLaN40M1|4|*k(a=4U3b%h&fqb7p$S!N;eMQ4>X<dOSOB^@F-qbvZE3M{3-#x_Lzec
zITfS$*gCIp;l=`u(~$P3&z-e<9wjx>@J#kvSlRTCn!tSSH|=C_g_Znz{Y(V9W0%Wk
z0h-okL_Q~ulinUmq~*Rk9aeNhEbdl5Lr$W(q{-%g`BoIq5MXz{n+O!c&$zXYbOo^(
z`}a1d8o=)(;FS6OKIZ<NdY3Re69CUfoId@?rvYs3001EYr(32eEUbxo8+VHQidc*g
z3BW<Ae1#i>m|U_?HE6I)8GT5^Yp7XUMH{;1XsG~^3#PS!9gY~7twh}@_7^V4oXYw9
zA!t5zZ9H;)-!Ax8v+CaGz%OC&lUA<!F$TEs1ZA&u>Lt-YUzQZ6abY`0Mu8wmNQ3;f
z8F%9G^TU1<y(pwdB3QSw|A!;54x1xRB#&O&YmX!|@O>~p)u$^Oc=!X9Ly=HJn&lo!
z`Tp}m!Q+Eqryyqu3<e*lUso9#S=-&(E{F<)SJhHCvS;-2wKotA02(x=5PEcVIQ+q-
zohBOSzI!mYrcvCbp#fuch?rn*o#vTsj0@ihQH%Q`>*P`8gyJ$zlp#b<B&9}^WV({b
z8KNy3564Y3Pe(6TJq+)2je>L3X;rhy*mS*-&3wcq+!@MT2F4y7Udy@BJkZ8Np?8Dm
z<d;(cH~7?fYQaWYVyPC#Ne{}P4TY58+xF_u*-=b@pamNo@>yeGi4WFQ*B6DyWiREA
z6&v)`DU(zS->XsfA(u}qU=G^7f%Q{eclX`ne!o#6&L88TXPPn9F&&2!sz8;nU)()p
zYw<;;jm3w{MQnTcWkLASZzlTjifiMbdCpt1z+ES8{eFW`yIY*I(DvT5ai1BO69J@z
zYAQ^vqtFpOUpfe)uaRt{mu0I|69C4SS{XF~+uuFZkDJFYZ%^!m8iKnLueqv<J{(!f
zC{6Hm0SE^zRd7)kpv1YOR?z34w@;v}5Sr;~<Hf(bGaI@c_$m@bF=wtlv5RLW%7&JO
zpbFrzFB!kgv-al3is2!d9#|U>g2r5A+|A2e^WN@s7mdC(=`duK_3I<0k>v&=YRf>@
zz`TmRkpG+bsKk=LO-dF}>9>U}kRdc&qc3T&hqy(S_fhCasV8E35IEwYS|g}xSS)3I
zI*#KYj?B~E>}up85TloXEG0WaJ6{!D>U@kIz{|iGb306Stl1bG)vk<NrKfBtAp&s6
zy%(+3P$%v;9M(F9^X|r<BZm8u+r^rK1)bj5>yE_(5W)+`!8-?sfqx28EW(wxkZnlY
z1y8Z9racYD>s0D<BNPXZ)Y`0UlT6#bmhYgljFQwLo_BLk-FkUE;Zkt}Sa`0NYY{04
z6ew(gBzGyG@!jhrOB;_iRpL?A)<f2%@E4*n4Kr{lTjE=Q1Vtk_6-lWR<?EHo23g`O
zC8rEk@k&5r=Y(C9I*)Ml?@hcHu@v20;5ACx0@iZ3bNsP|erI!i8YfjLpkNa`!1(VK
zPzmxjt9J(!4V_K!%pQDuu)%LhawG5)iE?ry@mRq4Ro?}FuDk9JViaear_%C^6bjaD
ze7O~r70WOlDWIx~Z-=mH+WET-b@+5xVEX2?>r1iusvp;>i8y&1E?m!U2iaT=j~Xes
zY0&ek*~ocP?n-pY*{78<KUWWvTFdT4p8u8}^wO?@%@`o!Ki1xQPrEF$aTlDl>{ta1
z)fPks5}d<u3uy;COA>@8p{=vqr3(KG^-(PEFmF6nX+bBe?qgCR>ldkPRlX3(uMg5d
zAb{~=81}31avqYURi=CTpT$k35eBRMr?tJj?I;2NX}M);9!ZU9k<jSVCORDH>!4F>
z)OHT@R;qd>#cTvsYX`ZOKH6l+(#Ex>avUY}=ND(sXZS@(+FnOz;ToqOnYieL#YxiI
z9nP59aFr!1lX1yS3)zwLboQ%@&OT}xIA_@G`#-$>kEHms(Rm?X4x4211pX=ga@VG<
zKr(2=ZH!h_qN^>$0STrocHV&dtU~gD3s-YcyKKh6*sorgbAO&336(H@QBmWutTm%F
zi=|-}A7~b>_HRrWPz4rC&ze~!*e^uV<SZKlU?4OGmiSeg$oW8|)drXj*r(EFu;gl(
zIP}XlehDsRnlPq?>qSrzm@9L2;Md%awjIu0lJr^k=ew+Mu26$59TU#a*La1ujyY%c
zxeiJ$IW=(WvLH2V+6q^hkq!ZPW`@4a2KIqZ5%yrJ%{$s7_X^JL9#9`ym{bP3Tl`%u
z=uYhjnOqi8^cy!a`^`+xY?bXt8Y_H&*(%G)5+4UX$Sg7|coAUusBpV{EaBM%=N5DA
zEvA^U5c6aN0^o0UXJo}GR*Fj6hZ|m8#_K1G$Sb;B&o}w&1WkCCI3zNn8q{Vq|K{lS
zDw77}=wQJH5cZZ<ND!@>@%U%K^FyiHt*^?baVfHKZzJI$<cXq=_OO?uSVc#-zLuO-
zUYT{&GB#)L`Tz-RKeW;MJT0J5?2K*j4)!?b@pnjTy&g}nMo3(5DM7$$h`p!{TyAU4
z@I{YE0->tm$S_}9#@b4YMDv>**XcIEx_(dbFEQVUnSd0zaE6*^zb|+u3zYmxl3456
zcx*2|5v~mFf`a%F;)V%gVMOWx;h0i_A{ueyBZhYFTZ-kVrkRk|Sb%YwCOLx;Pv0QB
z@#FC*O45K<!kqc(;c4cajke!5Gk3dOf)jIPO(4WY+cM2iFkbR!etxK7%1r%bbx#{2
zp=j_RQM0)QbS;cY%^t$HpFH%Nn;c9_cVLPnafcgVU`j|(QHKm9&yKsNXW;IOikO&z
zrGM+HV<*1oY!IYaV5f%&8)x;vOpSjwU(aCLemozKqOKJ9+i?lQEwF-s4t2w(mX|Ad
zr2ohy?GU7rfY6{b26Fe+Jyg=)K--WVu%K`X{)I&JsZA7@C^zx>qV#qbw=Z)<*;k`n
zbAYUt+*IsJ1Xs{Y`noU9%Cc|ERILW{v$y$-RT;#Wfz2bOZEY~VPl!uOfuyK8%oc8W
zr-j3;JGd;fQJAFKS|X#ba%6p*!PvJ9=SKk<D{)g~-^(S~R)89Z<K2zl-j^x4DQp0>
zL*=33?SeFUuk7TVq=9t14WZ^Juspd9p(W-gt?z7Z5TDURPCy&7`mFr?Q!x?;%2-@N
K6)*Q@Zgts-<V}tM

literal 0
HcmV?d00001

diff --git a/code/extend/ddl/MicroCore.ddl b/code/extend/ddl/MicroCore.ddl
new file mode 100644
index 0000000000000000000000000000000000000000..6648f17f900d9152db9539b4f5fb73f329125183
GIT binary patch
literal 11120
zcmV-$E05Iix`(d`A!UY<E}XSJO9zoaRn~<<-BYLEqt;6rTl-MJzBQs6J7_knfg;~0
zB$$fV4)S~bRR*~d>p)C{c`LkoQakIlRnL@_MWkyWuD5q0@x-)lmx!k2v+Cs6D2ep*
zP=vcU96oqP^lX5$!Cb~O3P>!&^<0_No8=ar%CPR{gt)78ROvgf$sAqMsDTU45KA1U
zu6Kg}JC~@8wFk{84pi;o))%Y=1SM6pmlh=5<B-bLO$O*By+l9;p#zSl2HZ5Ix$;^8
z?L(iOmo6f<Rnt3m{`>CemSUnoKcMx*)ReW#F_U~JTbPYAncV$5Ds@Pvb?szSwFDi!
zXJ1QuS-E2A(?rUR*)k-u%Ar3F&=$cPdB?4hUyM`Gtai@JT6u3JVxE})0<gqbL;|>E
zq)}2^L`A2w!xY;N?qzw28o*R|BN{6w>Wx>hXQbp_rf||pU{5y+6~*Si3(r;PU7eUV
zX|=@y0ghzrLgrpIJLMt*ISKFH9Lhk`CJ{6;bCJIY_LW?Tyv77-ANp#aMfN^_UK+s$
zHhvCJF^eaRDqKysl_3~U6ps}#_KI9VnPUUlk&$2Kz>l1BFvL%8o2(?5GEBUZeo#~|
zc_plSUQ%jsP#wWN51>h~OMbI2>RZw}7iPJZM6WwtY2}fTs8@Xq&8f}BP~n^JkQ9(3
z5}!5sGn;xTpAzHc^WE}|WziY{FbfmK$m0d}<AL2M8H`GUHE;3(667GlJ%k#od;JYJ
zap3j9t>n>KsD(Z+SG|>sVge(zMOsHTUWg|V?hgu*uzRLAuMkY(kzfS8V~ziG47FC)
zQWH-OI@3Bp=dTG>|NEvD+{tfUaze?O{gAu)f>V1@7`{ta)O6S#*Ol#fOd5-5^hw&5
z2ge0~QC7T-s*ANe?97WN#VBE`-Rx1^BG@?W$&a$Umh$6c7+Ei;dMMs6%xQc==r`}{
z?Nfz->Ih&7D6yBL&=chYERimu2xSfu{D2mtd$ByyKf>H-w<h^1Vu7$e#3SbBmxs$y
zeUAtYpnC8aUQUgn*CASsSNMw7PMc3yc%@$Z+N=d)Yl)GbP&4ITCT?bS?2P}!Eenok
zx56AJYCoYdnym7lV@K-mFJDux<63e)A>y5a>RgE%{cr?%r@tWro{uv`dr#A%6{}n1
zt~7VW-@WWW_l@p#$sW2FFC=+NDym(Lo)RYtpv%mxiEZWcZq?0b%!-LKo^MRH2PiJZ
z8+779<{Eoa(&(6s-^Co+GMP%)jyee-d?!}LL^;+YJPU%yQ`Nt9>RV(XTjcuoj+aR5
z4tcfZ%{xd2@^aFduhH2dwi`>$c-4{8l-Nh>_d}mKd1T&PI?$><7745w%xzf5FR#WK
zATO1GOZ!x6;Qvck#a;6zjedkS48AZ#evAs!iZBT~hcTasD0?wK_(!s-5OwK|9DaH~
zx@MDcgz2TAxIW4x7Mw(i#~(68z{Co2>$H%+KKB50%;iRoWlx=~z&k>xZxRw;X^4tC
z8TLCH7*?Ij!zhb>8jEV`Zc&(RJr%5!-3?DP5K>-RwQXAlY|>Lpu%$#A<LHGOMA8iL
z`J*OsKkSoX=fQsjTcJ|M`>@3N(~%>nH=74p<~^${-e{#wa!?cej_Lj|U$0Cb0GkF1
zzjDrRJT}uU@5D`st2Ir3bawEJ9|qt3<R@lh)9l!5<*!BJ*U)i-V#ajJa0Woj?StWb
zha2~UBP(#1-El1eACqP5i8qaqNBBdBbE-WQS*We)agCea<BUOdCSC#>WMW^6Znp=D
zT6r%@;@ILotB{|YdT+#;{KEmj89<l`oWnq#o3lX}IZPnPmsZd$p!v%Xs)SaFTDmM3
zjqImWxb<mmsA>H9G6+fk(?F|#sBD)-oQclgRqPCy@eXq;_t`WZX-bMDG-7^@`|HAl
zbPz`3W*j>xe%_PJobO_S>Xix-={&bR6jvsJ?3jODVl+!V_%q>3n0-bF%Q|8>Gj-VA
ziBnYb8617~dWACnL_DzfDt#8`OE@KYB!+_@nDHEfp@O-UF82@ymtD}7lsZK?IP3o0
zBJlpv`+TsU3X;kNXl{M7ROl}fh{sy<c>(sMfTHv%L|ot{U5YMlXJJ<foLr^UOD{b1
zqpw692MK*z?n>WvgjdP+3NZloAajxP4c7KD9;7*BrpEcqN|VUC8jt?m!`cAL`{K;n
zzv+4UC@G!J0@KTuV^Qyy`hyV@5|PBb^()4kRpoA40H8=?fEJ>x5|uY@!InR{Q{)qn
z5Yu>aR&?E@#92p^3;3~6pwZYs&ozR-`6)EhV}C7$44UTkeJnV#C^RNff=#jW1I&B@
zyqr(kjDJ%FT^QSxM{Yx(-NwHfl`~(rQJ6W{ZnEpyT+r|MFhKHIERrw@ZCNArJq((p
z8Az3U6DcxXjN&yLMh7CT2!5Oqh=bZ6F?VnR$cC}nk#$XxV=eSRT7SPKE^!{*#+!?t
zj5*){!`WC*-~+FlbL1cOsC3Cv==$-+WE#jr2#ztCqTiql?d|Xc@q)H6YPB>c4|^ww
zHb?sWu8yWc4m`CS(bB7e);b3xiqh=pVt=A}q@eZ$V-`+$fRAn!+IKuRBFm4$l^6<@
z1h7++5-28zTzGKrs1_AKOr?T+SHudGcs_mB!HRZ(eIq_Qm|ROIx!y=nU9<H8N*3*E
z$8_rfVg0z9oIP8b9g3i$s~`~>SN@9X>SPC0=w)IV_5pDG@7*-r#TwxQPXnpZB&eT%
z1QRKJR<1n=7{LS-z_3$u9JG-;tB3s!K_*_OkZ)KPcub~DK(|n$X$quF8moi{#&!#V
z33H`7h<TOPKX=<x`ipRvj6t|c<YY*-e8p~vMiej9Limw41^77XUCpl!)i`v^3F<^t
z3}-|VtCP*nqMOg5H3|-P!)H#@T{5IqUl;fa*-R;HN5PthjG^Nn(k0k<{KO^&xX~rQ
zE?YmDh0pvBp(A@aG5=M8!bR?_6|r`WL**s0ih{;+LPWkDYrkop3Y{r&03N+<JB4Ow
z0wqJa+xEjtrS00aRQC>JPX3XHZ5{qt89=)<gG2|)caBa5=smJT?wKj^IfjzW_@r!H
z0Fy~9hFptz18nu-1VCl1rp#y84S!1B@VUA2ZLOQW&fuLT1Se4)cv(h5lgxIz&U6Cr
zz2;80WI@hf%;59-N8*eGc9caHqB_?(NZqGVAstsHa_1f}41Xq`gaPXLnq0^`w<e8s
zSQ^n=+(R0EgKG&Wu=j4qTE0}2urRvILqZIy>c4AssyvW%jp;b*y3U3z`Z^&y)Clnv
zx$r2tFru#`9|_+))4-eP@@>=@<Y!X&1dg#QHUpg6!Q7HzdDrXp&dhCAyf)QLd6FRJ
z6&z^3;`q+nen+Wl6vo2oU410QWBzR1m1zcR6LK$te7-7KPRw|0A5@ZI6|_)@pXSMW
zmfrs~*xu|uqHK#VP4;y!53M@_3h#!hf-xYsQI-Ttay#_{;@cukD3Eol&_Jw~-D&fs
z2o0s5nI1mqI|lmC86pJ2^z37<s>Um<M`nryGaV`a1EGy9am6rdu;_93KWvnlXgH$p
z&V`uG9B(elTY~!hl-CjifqiZM746>Gc-ryrK_OY$h+^-r)Smm+OaHApvq2`Y*hZ}l
zIC?E*YpRwBAj=x$T;V*dW3~4x0OTY7++`kZ8SRyi+{K!2GVA)+fut?agLa7P+GcWB
zCGr=1Mg^COXb9Y5UD5>Hvqam>MrN#4&f^RMfH*^H%TB+VeWjjUG8jLQwerW)++;xi
zFGtBmQ(6BtpU!|r?jFd8vg6enPTRM-_xBY%u&^-<?%RugPo&3dX$T~1&pM-@$Lp~F
zdb6?>g9>+}WJNG(WY!N+0@U7E$GjeC?BX<!>M5Wx1V!*z=i_!7b3#(FB<$oG`;>dF
zIVOW9pO-6p#MGvi4Ggokh$h6(gI>Dm0(a|Ldb<itPv6Lyp%!LQ=-d6dDpKNn!1MBN
zuF|PQcoN}uVpj}`N@7DJ;5B@D4Z8ybM=I9d4Ags!DuN*4){ZANk65#tART$S7`72m
zq;%NmRe3wSYMtSDrKP-RGs}_tZ-`R_jP^X{?AwMk<@2&CpY4>^zW=@Ir9gJ0(FJvh
zPh2+Lq<)7qvyWAO!Bkg74jQiqaIzuIBst##R2lg(V{sU_iMF0{SAG}uy)8)&yHU{u
znK&Nk(udsmoIj3lRcJis!P>1vvGq|`q!Df>?xw7ZEr&9ScDF*rgn+ki1odPQ`LF|K
z&L;D(WdK<c9H-T|9e|Y0*@L@O&tvcOfLe{zK@cO3;OPcHxTRMGB4$^P>;6?o{EZIh
z3WS}AXgq<Ir~-(E6^N95Hoq<lB#*MVpTFg|l1S~T@&iXT7k{nIBttbF5cU*IJ_j4z
zVC7|e;=g%U;8F+?ygrxo3dQ9f*h7|aZp@n&FX<gu?;}HN_4CH78Iq1q<e<=jPr>0L
zuRy$-s>7;DQ}TSORnl;AY5e{CSzvONZu*dsu!Hn?VxIW<i7iN3y}!!^Z6Oq)>cQ6u
z(WuMqWeg}C_&V0{srWKf9Ly%|!}Qe+&W{(CJ}jl~lf|K)n_pLm*v0i*$c!*7O(U9j
zra~;hI>TdpHjto)P5e_Fpj7SzjOhf-G2d^*d<~_Erp6J~lPdqMipx99`48ip{1TX*
zLEpf%BYn=!%i9rnA1xmWak=e!tb((;3_}|8WZ)h1zlrvm%+mX(JxbPAi+0NiXj#yx
z^&&+T;&0*>Ke+-H2Cze#$`wlUv5;jS!cg|ez^#UOuedJfXEVjaNFK(uj)b9d1KUT}
z#R9KMu^0^?rAynwx3(Hm;>jl(<*&!t;?8RF$Z+bB<5Rz%JVciqlLocA`|8(#W&5Iu
zU2Y`xt@_Fa=1g>w-7WF}>BVc5*<|bBb09OJ4rAmK#=1F1ON8ki6MkT?Y6tDGtCf9-
zf)gzrfB7SGMDR}bk1h0AK3M*A@;^<)2uyWaDSm(w9W4ZW00#$~*gxseeNZy|_2lc^
zvT2Bl1YG`JH0Rc?OiqUZyI*P34&imq;5h#Hll^ECj%XoCm=1-{A`X#r(Yfac8t^Fs
z6d)6<^2Hn#Yf82q_!EES9__cTlKx1!Wcb8fp9uX+6@Y6Q-)oe<)pC|p_gmPuZeddq
z*y6AsRr**eO(Un$s0Jv3t5}opvFW>(a!`?IC~_13#9E__fy*>-5h1hg;^eO<W<CgE
zir&d+8}y)t7Wfnx)4bcc9V@hC<0UO@$IO+YlCMF0z2E0~{jw;RCG#?_>b%zQqU9G2
zuaWc%=WBDl)VewHrM22sgob`V@L>66WfD7{RB+%_x03{_4A3bQ83+;hC7#;w`^Q|E
z?up<TV}Ax73+m8?iyR$crAuD&e@8IPan%uV6Ez$f<FyFuI62D})gBH%Xg8X65jK!@
z(ojTNh&@a<S$1>>>N_L=V7l+}(ZmSZ07_LjCX_#>qqx8h)Q5mq<d;3V7<%9;!r=Df
z&}!R6HA?qH&+3=39b%{eegL9U37-3+nAOH(?5%tE8b9dIHd$|}ja4q>-WBs;?KTvY
z9w>LQq=Rj_cgwngSkolIg8KGE&EtxUE*BxZMvpHBgb8|LZn~C70xzdnmr)45W!ciW
zJp{6|Pctwst?S~wUwhWqGOC394ph0bYo#CkzvsHwO&At&h#J?U=W5t+X^fUZs#{A6
z(B^spi4$25M<ysm@YJs>&UN>^d$(7!-~)_(^14v;Mk#$A+g|E}m6?VL%R2$H-fD87
zB1zAywp|UyMHn+Ph`1MA@PwLD3M8l?HNgG+gyILS?R$rhIZ|zlntV<r_V*sTp-HPV
z$n<><y&lUG#Tr7!p8IkABQrEkj_ig26sYF5n_jTfD{S~2#{t=FpB(?1oz3JCGcyMi
z4R1n}VR!379ae#umBv&To3>cGDGQ~t%Votx-f>{Hb#)8}4k9f62>pF*28|wy2FOQ(
zDtW~f@|>V^=}5WXC~KAjE4QB#ykoK$kIMI2Yb_ZOGq%8pB1^t>(LWDAg{577Zp>uU
zN{fS^mHozuu(<xOHWH5c7(;N4f%=6gh3o*|07P$KQlD1Nsb9e{IST3=@1rIfv^ida
zd{QptWt5}fhV1ZLMMZEN`$}ZYZ&ewK8LIanNX@94ytW12@<;kpBJvkx0I+i0+I-sS
zAL?O1IA7-(401kB&Zo6uWH;@lx8wd<iy_H3o#dLG{^?x`jbPpihZX6+Wge7?e9wg%
zW>`s3or1TrR1Z@#l~TUsyIe?XaoK20&6iUH213?=G1uG6=k+m8#kQ2*f<8_c^aMl!
z99jokx)zkVDvrrhko*pM{_=fvatzB!4}UoUQX&MGt_L^{Tn4(@2RY8!MQkJPPGKbU
z!GW%j$+gzOJ+2#r^e-Y9)XVyiA?`uu8DwsiimuD-?@w6xcp={Dp*p9*fX(--<J?or
zDeKC`V#cM=E)R9vkR6pdjE*YUw4?3#A_ja9KX1OB?X&u)Ga%o-%zMLogDz>RYr#86
zKwy_@Sa;JA<%?V-KKJq5Cu%wH(BncdsknD`z4_dlqqX#@^Q@9@Vv+5lGckOagWQ6h
zbdPVG`_=!`L&gu~uOqrM_584f_w}hz8Lp#1w<mAlYNXN?#?a>dcdJNOZFwQjK&Q9H
z-h}d9ZC>AbT0w_Q{y*wt-be45Ua)}Bl`!L35a;ytJb~~}d<{U%Pvc>k4>}Fn;jwu&
zy4h=1VDQ;)Y%8T*0{(3|FK1@~#s^=ARjEOS5fZ}F+jGYhA#6n~I*6q-2^v+zpmdOi
zi7r2L&fw)_K6-Pl4O20-N}j2rfxuuY!x0oaM!bIC5t{ti*U&rsuK*XZU@8DeFEP`K
z7q%CV&=Zakq(5%3K$m2vfGFF1dY9cFqc)nK%wMi!`P{_l;XN)h{qFBO#m<*|;;mMl
zDl{JWb3Y%#aUOhMdydgR%0Kp&K0*WQwzN9Dn>0}#BG5O(H6Bl+G3)#R6Un6@PgpPu
z*dp%pPn{SXm~cT+I%$Raw%^7?UN$Tkynv*iD!}+32mm##MNC76X!NH(0<I@0c0-Em
zmB8Djo{I2^-om7Pa)APPilm)!qNX{p#La88L48*boRw!LdLU(o&y7R<A3c(Wau2iu
z2#}`UcqlGqTa_#wpX^}$S})L(56TKj1t>{CDyT+7@f}5*+p#(crYpLP%+HjgP5i?C
zukFR6tVb~@zn{eNa`Axfwm+@@Ep~nvOrF(j5lSos@8ke{dFMo^N|Mj|7eB7uPWAum
z{kSQwgV}`Ra2+5242JyXvy7_Scm`V`F+E;&eH&6mkP=_pykRwl=i_l;wVaG>A%h5X
zx!|RdIGFf%=tVf`va-V=c6IjT90H?!d$U-NAt_5()D<DnHu=U;H|twB^O#59+C3DN
z^NFGNWD<mQ5R^*UY^ev`xg2sg|ILJ*Rou@yBpjB(gO_oYdrX*!n|hQqSJJ<JK_8S?
zgTQPcTb1DhlcGY6bid8EN(e@}Y@P0BZB6sjGF;cORcJ5bBe=5eBkdxj{X4^XPhTw3
z$_4?KX7HlTYxuz+PqaYD?XFL9?_;!%pz&Yn$Fg^o{1{Hg@aj+NpxP?@K+g>tkpRR+
zY0axTsxMfU;Tm)>k_w?cHRn&d!FxjMtvzsOoYIfwxO!M1bteK-5uq(?B;s0fre63N
zPPtUkp(^1=v0H$(U~#eU*NgV%!l=}pOK^AD@_Y5CV_i*SuE%b6DvyGj2kWIdIfHbs
zxgnf(_au+8o3`UcM5PRCx$*5)9)YI?aHC`)cY<QoqQN{C>uaQ*TuM;f>|Pwl&W{7K
zjLs0Dl}Gh=B#1NNGDv3*r?Q+1U}IsWy^JSij24FpGqw_a;p6Yg9<G;{%Ic>*SEBL)
zdp9JgyxNQkl}I!q;<e!Os+_!zY;i~iTJrOcetmA!tWWc0$Z`%dcvHP&$8x~IobQ8}
z+W^c;@6k~*Wx33w#LILt@sh4;9^w(KQutVX(O}C`SRP)FFQNydG+2l=e-hy^W{;JA
zN>9){Yj#$)uww=)td2?c6=*K*61+iD>BK__XC`!%QB5sQ(Qx(mP>f_H1m`fwaAPjQ
z8-juBfj+)OhXD8~qW`Y<^ygYOEol|5j*c)c<^GP-X$dJDx$&BlJ6m5;UAhtl9gq{u
zkrTf>PS=)`?+iXNlh30aDd3IaQ2z78#@j(4{E~R_n)szn_2(=D%#ZRq$78;LV-M}O
zGt2{?oCWC^DGeHry<1-g=T#;S54e4bbu<I_ZBo&D{={2F)lB!!+<J$l-jJ6jXOT_@
z%h*u^@lMdw$EyrX5jSUibhNfrIiZPvwpmOkh)ZQuM{PjQSmd&2nc@aJI#avW3KvO?
zUcS$*+<$Bv0zC~SjIg^HP#mMCiiG(NXb^50Z#tV~+?CrS6Q05>C;5+Qx0E6p1T(`j
zG3>9aP*y6j%<zeFj$gf0$cgxWbq+$Dz8zjF!I}Hm9-@>d|IGbp+AeXV#$c$IgCs>1
z5y?xbV|*QOK$=gea27zwY%!sHPna9%@TXr+<zOr&Gzyx1ZyM@fG{?;a7rNV4^uouq
zE5361WI9H`9d0z`*Y$MsHe_=#-lj-LH9C6LlrOD$TKI8@nD3acKZx$VJfU`>-S;EF
zJ>IEM@A<a{k-%kNYJbPLOAt(`!D32GvBma&3r?A?+}pI)2%bXc3yJ@sRpg$d{UOfu
zr*k!#SQLhi`(=s5ECEjij^rM698P(Q*E2Q^luh#W3=J!tO}hfp%I8n}L677;TWj|A
zQ(#c>P2<<z#->)cs{Y@)Uo~>6KMsjhptISu2M2or6DaO-)QQPU?O!O2W}da~Vq^Sf
zqrNQtW3Eh^h88_bTF@?osZIKYtf`n#V{TW%omGk=8v2hH@mrE6)6pV`3N_x?<|zs^
zuOngf$U_r3DPjPV3Q#R|9liPm(*%FN3z0m~r9!vml!s#QC=?geyYJI7a2}oX3EFfM
z{ak_nRUyM{I3GkGx&i<9h_DLg>3?<tn7wYOCmK-z&YRq1{?IJ|?U-!7m3Ktra$X3I
zQV$NA37yzYAkvB2%}E%d!%6mmOs?b^ASEZ2xZYFTn}39ijXSDd1Dwj{W$F>>HG%C#
z^8R9;Cv6bi<<vzD6lTf^53;V}kQpG(@#CsU4$CJXcm^-5^sec7-(7*b2>*85&**jP
zF#q#ap*26LB~X7$2e<`p7PS}=424>}oXI1zeQiu7c3HyyC%}R)=0#nT`vciL7IgDn
z+5$JDNovJx2LUJ3dy>v)iDGQMmkDBN)rmiPb-Z0tVLn^t?3yOds;vul<VE`e9<nHz
zAR$rJ*6GnBz>B{A+%FeMKPr&*{q8neMhR;u|5`xoaRRG;l42cp^TdvRvHhjm)5lF{
zG*AdS#2{9kyM88TAgI!Ie>`*AAd1W~T*R2I(8cB=0Wdaa8uXqfc>JavCGinJUfRRU
zH6!N>Y|fhCKt8$EjB}J({!E5QIxyIq2O8<i`Ue8?xeR_Cd@e$nmLI<6l$55j2SlL^
zGGY5N`B*QRS_CN7uN*6Xeu2!jPg-UaiJ{}6GJ2|kTjsk9`ga?8boNu9D6Zhm=pwrI
zY<)!~Y_8h3cM(l!s6i-B=ymm`C(-~%3g?nf{?t$n4Ty^fqP7~}E%+e8P;KG@FZOyI
zL(#&S;%d1&p9RoKC>g65JFMG;sya0%{j3`3x*1{aDjWrE+WJ6II;Ep9HRa+Hx%L_h
z@r_#QE!~Z?hx{+HM5DS-{ga!^2TxIR?vbGcTg&N^GR>W_3ZMvRSy+&)o%h0TpuJdj
z$h@khI5FETo~k^BcG(!iKlKh%<7f4px9MHl<<j;0nftd9Vk4}Ha(Sl;H2#jBBV$~{
z;f-|xrHah<1+hY*pU;d&I@9Ip(6sdLA9CoWwcI_eL#GrkHla?p44DO)9Ajuy4Xk?u
zg$-^7Vu}ugL+hgBZ(8NR`NH1;(nblW;uj!{(BsXCRVYS>rYB|ttGYM?TH;|?7BO%U
zm9_O^Zz{Wc)1Ew=@QfBJz#veDcGW@M<(xC3P7FYBiv(<E!uR0EF_Bb@_VNNFo9-iL
zmBrmXd#1@K!^GU^hY(BH7jRts#^e}wwIjU$$PJV5ZqV-Cp}^Al67^MCfvtu6Dye)h
zKO2yZAv}kX#ySkh-(_Qdj+FwY=)HtZ<=Gb7jyytz10+hFH0BkvR&;H@0!o3>%nXdm
zajVW{tboW=)D^oCxPOQ|jBid_Jgz!`Irz@cHgL!mHsxWKZc?;;e}(H=c6!4bm1k#a
zILlANzqYq0F!Odg{rxN!*@J_E1Hvdt@iVsqwUA@`GQipCpGOlCwk5W;sXTobdxFMq
z=Q<}@85Y<-MBjo1L0<+Z+3yYXTt_9}j!uld;-QLM+7awR!1}3K)~>aMkLDq4cv}IY
z0IKEnjWQm}@%OkSvP9~@&FC#Y1su;jkhL)|IEL}$H}~~lI;eT(D*zK|=6mg`AR}1O
zZ5S*pR;4672kf&P^;~l3!1e3g%Rmqu%S+jAkAj?)^^G{7^2yU_y93or3@}y3DDgP#
zDCG^5EPtElYYmp$#AF5k{ESfar~ZN|{@4x@Jt8iK3!EU15nFoT`cITIiL_4E1x^u^
zcoTna1GIBgdE>dV`R5|L*uto;u93QQwTe*MUe+@lf@E;vUM$VfV9AdyHT2Ox0xOLU
z8%ot`0+=N<5WI_sU|NAD*@7Sd00}w*KKd{VwETh}C7<ka1d&vpeU!}qp2G@y9pE_9
z3G?~N)Wz^@?$eFm@#*nRuEqQW^vjapsl>o>TwHGXlonRjiV{2t%}S4a+V}Wz@bKgH
z{K&|dxaqW|M$?^V#Dfdd^XTq0Z<Vog2i6o)ND{WK+sV<V6PgXYHzGPB>sZWxxdN7e
zK<{5DqZoJh6?L-|z$ADKGg6(Fosr;$zhoN_pc-_58F03rtm;r1oSV6L@%()?2b*(b
zrufvTqy40Xn8L30ksEx?^`tb+ER?k!1$Ei+5@Vi+jME<`0{r*miPfZ4b|XOzk~npn
zwt9K8!eJNxa7z@SWea)XTpWZ*tPBR@7rU>T1UdR};EJqpOjaELzaF*1N3b{+&Alz@
z=-F4M$K}yYDRyi|w!yFeHS~e=9yaxetJ>f9Upk&zWChvVzhU@RO2i4DCwfP~LXQ3B
zaOIL9`%e_d$AdiS>VMa<fRJ)?0BRK-N2qn)>>VXr+fITYws*rRh0OR?*Sm5!sy0mN
zTZ^sqhbvzPUl9T%rEADlZ-LSUy95~mPBkz<g3q1Q=OD7VWt@Wp16-$iWH>_4di77X
zUI;t>pC?WdR7H5U%ge0bSX)?wv{Rv5nH;XZspK%Dw{LI2>5<__VEkqQC`U@u`U`Hs
znZ{fb<xu_11gM9N9E~m~ykPOJr1mm{ixAq;Zaum#x?c<)8b-J&TRT+~8WcZhU}s^$
z`IJz%FNoF{D%vviToPgD$u}IA*zO&<S|Mz$hIXJCiImF0_sEd$Rk;Q~$l+XK)P||+
z%aG+Joy#Zo6QbQvpcs(r42kv859`!W1_4G2oK6<a^Pa?u+l?mX+eBhDEj;(7>k&kz
z;`)0t;#WtoKJ(E7-!{cI+X3<sHb%ZosU#^;4sV#>+)wl64c%b;#Pe{5W;NknseejS
zI7q>RgM?z_64a3(8<>aMvN=g_u8TA!Rv-L2U+Foffn~uA08%l8!EkO8OEQC2ue2Jb
zUvwS`%c36N2j1f6cWgd*$Fa88$(Li9w|*rJBDVH*?c;U6Cz{VjRif1+ouW}F=f<E2
zwHD~KPnOv2BG&}OxJh}&skzMs?JV_M!gp503?Pp^ph=R_Q=gJnaio5x6iReRjKGWf
zlsGG?NCYm|H&_bORBUPUed`rTf~3ye2re%W3f6v8Fx@>nr$(qF>RKyJXcGeMXzcFJ
zY&)1E;WNW?yuc|1UCMwt_J7*^p%1Xp#U0p_);htHgT>Odoy{{Iv`q7YNqd`GiG(j^
z5UV{JdAKD9>GP%pxTtu|9|}%i!P#<1W+g2}li+<LXA9N7*Ba>%FqA_|n*(l7^g9r|
z#cq^BVA3sDfar`2BKm@`qwtMTjCf>?lzyz%*2B;;Q^vpzdPH+wWp{VcI+UJgT8k@9
zfC+lm-?sTa$Jfp_-cCJNF!>Q+ic`aFJ^K5r*(>eQC!WaU=ExFqv3wTZuTHaDpIq=!
zMQnS-80N4Np@4^pzF2vxwcXLSanw^yi$F7XSo0MkQ7Dt&3n>~CWGvR=26%3oK}68d
z&O@x2oYkxkPcNGYe%ZD$x1w_Ulj>%A|LBAR_G&->iIXba4MIP7k|X^l1NAdm25Y+b
z%2~ADum|jM#jPWz=;#}ZpwTzPdKf{Grv<iOy(`k+i!{`JmhQ8fNtDPnH6f$F@A!kt
zZo|}S%W*BkPdi4i#PEcCeLeS*Eo!r&6Q)^|jv*Dtr}_fF8E0}cGoov#xk|oDQlIZl
zqotu(DE3e8dLbD0ssvWa+$qcz3>IqH;*<3^$bBohA|K{{*(3FQ-XU@oK<S3$^ylkt
z-?({9>*?Fk-(<AyrYd_?{z}^pOH5B##>42`D$pXE5rtiAl&yu?5Id{S?wH)c@8JJp
zXpXh(EvSfSP4~icOzxTLMrRS=h%N5w1-;g#FnimYQd{r^P|Q(~K1Z|#ZtmR@zNG2T
zU>C3(S}!D!Xi=j<;_E`lzpLGeP$}5dyTdyly{>I`25q@BdxLx9PlT_W(SA3&gCq24
zZd)<W&J@1p&0#I53@QLKr?_k<7yZ?cuCYJ`IH%{|Zu?Y!rlP}5x-9u{AVDK_+zIU@
zEO>!P$^P<7J2<N-tBO7*7qOFsvJQf4zu(DFk9p+%`BbyyM(&DLi7Or|L+4XC1!D#5
zi7!Q3@Nl}0%?dN^BHvt|a<mP0@;~X|%vK=<<Cy``34gv~Q3@Ked3E0W>>RWMl63+V
z5*d)5?<{8?YNEmV6QgB9j&io?NQfIb04=U$(|W%%yr>1+_~Td}bnGut@*EzC8f8}8
z$tO!4&X=;Ab_Q{Os>Cq6?KX1|GgzIrBPg<)n`#1jCEW=6Unu+bTm?8dB^6+Vk-m1=
zRV<Am8oFPlwU2Y5UFFe9B@cA_PjR$DwtvXio`AlEPVsDjx}k#qiA~CIz6jyHtg<aB
zMa=%=%WY+H1Rk#1PiN!FLfzgVEMaQrJ6k)ujDXr#t4kZaZ<V<;Tn>Jgv&cA`3MepB
zyBaHJu`af-MiI}zOIsbU!My*zjiKY_Anm@*z{+!(=THn><aZb{j@cdGd(Ig)L=dz^
z;|f(p>5g^#B>xPUh1XI~rB$%WWX-(ba0=sWrTwaZ_?=!Yq74(m$gw}v{KYW|cc(-L
z;L*=ksP*tn#&9}?stcp%BY~rmpu>MAaB9%{7BKF?`m!M92izaEsN09=)>U7vAm+Pf
zv#nxkdjX&p$bbSGK~~G^;eK#2UZ|F6CC^m)TjzjLMdO9ybkX3sI(&cT77e)L?3^v#
zrlS5u%E?V|)s7dnjD^WRXDpvFG7L;ORS;quU-rIItOaLMQS%uR@`kC6N$l&;+ARKx
zM20T7oi{Has4J0UG?7tS7naV}8;d{kCFJ*)yc~Rz)D$%$B$Y^zJHZc%aSUJeGjitH
zH*PT-^;Sp*z)*oQR6Yl*m6-z(BgNJ)uVBQY9&LJV)3emhHdmd{Z_tU9mtYOj>TpRt
zj`oIS2__wCIH`jGz&HXeKx`GS$6-AVPscE}2%1e;sidD+tY5pdl3VmkmoK1#b7G*B
zJD31{PBpizqOHv2YNCm_D1&x}F5!<v&JztOBXe70GCYWZN=R&pl)f_!jh?>rJjm8N
zgzr|R@1)$J!_nUlBlQgs2#W6tT2o*etyXdjsXe^s@>`9r=<4(|yP~R54<AjLr?Y+W
zu_1o`iIM{KPFVEWnVN&9gJilPC|*ZcuyB)57OeUt2BbkPDY)qMl}@G2t=Fx4RUMm6
zud&`rP`D(3H7Jo7o8>Tg<$X@YV)e@)6&(GPCY2}cWWpQn3kPGU#)l=5UWzdGD=lCj
zrvmctG2m&tSUvb@Ah4WFm2CdYQn@ISGD#uz)yziYu8%SZxHeoY;d2)?&^&a2e9P~K
z4%sW8hQxZ@s2NHPdvxy@h;tjHi*GuxW&y13m5+;-ce76nER9D`Z3;D38Rz2SE0E?c
zQ-@tbA9P4>QH~GUl=p-Cov>g>;+l6zUa{(P<rc8>Klh@Dr7~4^3MCZcbtMzsl|wg7
z1y|vS44*~8b8%|GwbB4Qrm()%)EA>)ELVs_8eo^+l9LQ{ET(;m=SzWH71kN$4eU1L
zmIC!pY)#Kr91-bABYVqQ7?sIK{9Dt^bkaeFg<&?8P_a`af3xc?;J#pi8CWXF$8q_L
zYPKjAXUf?fnm?)`HSr9uS%5@XBtVs<dF4*=V|sD1(0}=6Z?!agD5Q#IC{g7HYP&ZQ
z@b?3_#)Q9aBfH7Apl#@T+aF1;;11j>48RJjRz<7EquNtoq~HTs_E8{G0k*%;J*W@M
zUcV=6w;|S|zBCb$o(33)uMGN{au+#4C!f4$eTE$L4boM_?j3#4835YXVJGWi$%rf*
znorSRsLb*^k!--tE<+(FiQafF)Z|rjZw5ZU$I->bzKaLrCe*2!cucb({vsCyzs5kw
CB&k{e

literal 0
HcmV?d00001

diff --git a/code/extend/ddl/MongoBase.ddl b/code/extend/ddl/MongoBase.ddl
new file mode 100644
index 0000000000000000000000000000000000000000..aeff78dded981f7add304593c4664f6397119ce1
GIT binary patch
literal 6032
zcmV;B7jNj2r@I8|FWBZ3R&lLN-CTqjSuJAY0^1oz(qJnZhR?$J?DDa_jjW4y-usQN
zr-PB(BU)v>O83cLSFt_bSfw?iCttfAZ2Sm7;ikxJO~*y+%%PFlI>)_==E=p(;d&X=
z3T9=|;s2~V=gmwZ8Sp(rr~6*ccP~y7V92QS`jS(NnCcbOl#(mCG=)-SIRAKzWrGhX
zJDzfBP|Ug_15Fz{A*;!$M#sq;DOe+wVnLbOoF)Y}n~%w{#u)8CtG42BN{x=BA5i>b
z`vfVx&`m>R=U~qe<~87=P3XX)FKF~ZfzM!&p<KE(_xtWw-{InNinT?_9EIhkGCw*x
zizRXB3>G!NQh<L9#77Rs=;_Ej5fmIM88TJ|?VX7dI8djEQ$fy&b>ogx`z!g3lc4$9
z9p}U-K4;>H5=lBt%Dl^lfw06ppU#$hTvmJn4)H234Ajk+;Ygy_0zS)<ffEv7X!3dR
zyFRu3jDoKzv0oS|aMEwHlK2VXP_bWoKTz!0=bS}BV)J;`@IjR6E+hjeZ{*Zs-)2r7
z*N$!j<9+5eyPGO7uiuLIh0PJ9Lr4oGcmJ~;zUQ?=?xJp|WlhS+*H1^Zng6oRg?Um-
z1DV9TNu7w<iE^Y{LSO9T31=4d*c|c!%o!=^W1|KCK6P^_I7xX-{5r1O$@YcZ_mP1V
zrjs&<tyTzVwrH2UsR1H~>XiUFBg5?9v(v4)i1IEc|GGD_;y<-#flr9r8m+G9D4{f7
zGwK3V=oM~k@E*qdQ-c5vtRyDoaE~0KL`vzUf|P?>r%<|`YJK8K9cZSyE2bV??LShM
zStS~|!(o98SIgI>;nxZ?NLp>FGw40_O+Z_pwYNopO0BIm)!7fh)Ysw=@{!0FI62S|
z(zXTY_NKHRxjYiRvfHg~xvoR%YlM~eb9FzVJN2J3HTU1#i{ozuL*jck%E5g+J#*S8
znkai_Put)Hv#JM|Wf8xA2{EH>C>MHXdp;9da0A%GnyBzX<*dLt9>DKRV)PKth|ek8
zSq!LDEfOztfC3-PP->*xj_v$eY-(LC&@$-wc<{qMPXH)$ldn->CpOV8#qfpeRZODU
zOOasm&AFq@R67&+_{)zp9`-nvUi8oBX;Jv%6q|UC5y<s@w)vr)bX+foDFJ47Wod__
z>+9BOg;XJC>g=0^`y}UDL_fQvnF}QP5=Zxghb~yIZ9nw<y$MuZT|N~1Yp2TEhEe<f
zo|NRpwv}_g;z4~+XL>`DqC9-3cEm}Mr_b(EMX}327;i9m?q64?U{8S5x<lh3@;S9M
zrP;zf5p_5$SyFVq)=20~S1)82KTmjEu$5Ntm5cSNH_E15<aQ^-KsZ}3b7vR0q;zIZ
zpzWkT$f6>>jr#vbioUtTW(H0-@1|R_U`c!AGmW{7UOY<~%Z1&{>o*kVXV;W}&&T>y
z^fhk?`z`vM4w*e}q-sZ$3a_@%57Az}r|XkpUy&ekzuL+V9Ty}n-6nO6y>X{~trNOT
zxL3KPxZa2ly-j%nW;iJLXs|!ZppB#Dd}rbm3*>`h_TGZQBfwKAE@hweY@;6Tdz<t+
zCl`k)QHiWJzt$FmrQWIokCza-^?*WYg$HkFc+6%@oZlwip&OvJIi*ZOzOYUCb?(q@
zMI-O3YA_CKkE`&voJ5imIiYuJ{XGN9g+;&kXA6e8sclT1h*Mv*i;WRlKwoU*8UB{y
z&YM02c*T3DO1r8tWnxc8=%JF&i|M5Ra625rg1}fIf(xd@2d9ol<5DTWARvLe<`t-?
zRIXk;m(W{2>>|{ccR3pUI8*9iNN+go-W)R_4EP9&WB(Ko9jmWW9Ce6iRM?lY$dbp!
zD6J%HB~TeN#ZZPieSICGywXCM7y(NSNG|w&2@MIgY2hVd0!AH(&<e$zPYZPjQX32)
zEp(B0mvsxWV#&Oul|XGNtnC#|-ORog#ZIDRw}UT&H!};lEuA3BV(Q#Sp|vWV`SQzD
zCxKFD*p_(7ShPrTu86ebvPUnVMWVS$ArK2%-<nyRDda-kqBjzwOCT{_%zKrXO4{dZ
zZUx&`-SyKrtB(N(3Y}eGh7K93Uk@lTcj+`VqTzc4Q;Vpx7I<tXSeaBJ#%;y=ne(U4
zN>Q&q8^Jk-F>if_`#S-40+Qjy*BuSoK@P}sAv$d^URFtX2Cb)>?4j3ZJc&dOzg4EF
zy22nZ&>3YXZZdi|oWBKb9PR-bKh==QE&^!?X;jLB2QSbjp6)(N`ukVpaF8MKT?7%O
zWY5jGQEY1`j?6&5s23KiREk=dkbQ!NVvhL}>yBrMZDkarp0e$rS};g7`}BkNziwv}
zBbXh#%3$kP;v8J@eS)QGd9dLT;3i#Z9&C3Z(*y6D46-sEK14Vv;{6;fcVNoi54I(V
z!r6G7rUp-#UU$0j<kI?I1*6~XEwdLV4!(ql1o6ZhByj09kLbOtFiUR`zb~l;FP(Xd
zkev(cV{ci$jpCa*;x#lG7jZP$4R97{v)uT36%a2&2w;d=xsSmDx9k|(QUiM1h4!C-
z$t%b&K)<Rd#ap%zB)RT6U7AF-Lcy`y-#6~z&|n|CENa{}1oce&*zRt}HIze~*RxED
z(|ef=Rk@4Kh?1e{d-tM0iuO|cff2t>bfH-C%JGrAId&r-$ewYBsPYV%31Y*j>T2zR
z2xP}AS;^-bTMmfB#+S)GwRGXzX7<T0;WzM5_4?OKiUER_yrt-*{a)Zh=%ok@+lwK;
zncC#%hozQbg+f$xtlQ2Vwp2UKtsE334oAS<l@I?>nX+1-*!1;(fAloENMoY$Thvf&
z^*V^+bFws?8#4O_Q~gcaC^t>o)m`{ghkLnH2mH?9lzuFa9S(<>lX9${>F)3GG+Tij
z$|@GE{$j_f0D*u<o{#0Me*oAL4;~qVy)BCYg&}(i*2|(|>NXF?BjN2QI;a%f*}a&}
z(g<e7k_J@4saIC$bAIn;8c)|>r|&zxKA(*8<?vNZ6FNd1Au~cn6r(4A);)M$3bK70
z36VgMW2!wjLQJtJ%rMUb6uZ+#FpQBB!ixbF4C+f08U5lUfm_F86GC{x{AmOYDX|n0
zh~dZJr-6XaO|}=HViFqY=fy7*297OuY9KhBmPorTZnS3+#uxj7q{D^fut&ed-hMYr
zz6neTLQ(yYsDWG}sv>vShNy#pVD7@?bC1;)BITFGfv%j@m^8R&|A<&+(=f;zliQ7c
zY~dJ$M-@9oCJ!*3tyl5X-bb4w{HG9V4(=x#dvV`vL}f<XYQtKs;+kcAt|-O}l(=%!
z7QHmE>3j{REE1-idBFO5?7@8Nhw4UpC}~PRKH<uX@>=8bBZ&=QbxOozz@p%RZA})S
zdOx1?|H>BE#yS^?_`c8CCi|ypBkxhS{M^;X`v(te6hxU2D-%UD-Fz70tz!(0!7Cly
zPuny)u~jM&6I#F^B5%wCv$+t{Kq02nOlaBaeu9E-rjW<z@m2piCM9=A@)WA*Hiebd
zlRe|Ow<$CcFW#5$LX6W<tc~^@@J6E{^JtNak$O*h>!ge8%iZ=LRP1+ba;6DMgy$YN
zf1vXPmL)jk+s671D~`Z9lest*#D6<TY3peM|Lu9oxw%-%2P}nX(3P|nB)lRfOE3FX
z=YFy0416JoLNKHrQ`m2&WU~iY)EVu|DLb}oiLp!HZ*d4Ck78GH?d+0|OO{b+4gJ;t
zKq3k%9ls6Rk-pljU}{?C2X2$TLj-rhru@;2Z4(q9He$l{qUx@~3YiyfkMbo$4fvYM
z_BmIMF9kPgT<DVkvIce?V*a=c?L_xUaml<-*d^|cAk2ANGZzweXwgL^EyFfc6_F}v
zfJ{I{l+8;_nLdDGbWqQ8%3L~CU`vc>sY$Z>Yq)6@%SHmc>e^1~JF&!G?U!`#-$6#S
zQL2aH2n}%!se(|D{1RACzl2RTOG%c5M6_0RKf`rjNQOP+ei4m%uVuP+aJOsJhRo|d
zpYSLWNzjmncgmUVI&*Tgz@Gqk9K&QSh?FatgMd#rtzXVW=%5qyAgy*z2KuK?N9*1%
z>4px0UeNXTBx9VWyG6tOJVEL%5x>EU74r8Dv56yNMLw3}W0@<+e2-(^<EaQu<JVdU
ziA=uQ_bS8tX!~B-WM#EU62P~^B;0npT2Ya25feTkPdQcy6y$Pe*lg}Y=c^d<-xXC^
zBf{KYneHF=;?rw_>O`d7S|J4{%OAJ#9*?xj|LC@;zw^n-ifU@ZbNiIu<SP7)6qZEa
zm~|QoWwr}lp7qhUwNZBEApbprDmk4O#9Sur&p6$q`1HoW_FL6Wg|aMQZ+OQ8%V&~-
z7r@7}B*YxN>w3e{tl}8teKjjb&;`s(P|0`cJ?q~LytjCwaCBP8huqxi)VB(875B^S
zQ=o3TM^p1)9Q|AWYv2rEY4z+MzONqR-%!rRdkc1uu=pZANcXgE3wHJk1E`?0ZPcYJ
z+oTw6SfZ>F&jFOlo94i7>Zu<G10+Y%n(p;(li`LPVf`K@x;K#~F(05M|1_wl7-!<J
zfv)@vp0w<bv-%tAr%CwY(Ml-_&@A+hb7K0CJDIleOJ{4)a_zOx{d+S$@w3-g+`|m`
zpRc4Gu`;Quhd=Cs{8NnymBm=qGtVKgr}E#NoyHF^)4a7d|0@lX7i#S#Y(4362Bek}
zRrD<bB}b2P<wFiom|d|-nh)NPak&2ZN3l*A>&Ovps?P#3idf>xELOHOo=6tXvQQTn
zw8Np%*>YnLfG`X011UWFaucz71ks)(hk@2zIMX-{FK?TSsi2Hd(|54<y9y=3t=3tz
z>ow%-BH$r(Sn2I=VoO3>+nT}3Jr^En4J0O_ArX_a3Y6eQS}4k^AbQ|dC<QSl%)#eJ
zbx(iiBz<QVQh&W45<!&ep%g<fy_u|$@eDwNso*<`qGzM4QSAyo9>B@U5e=7aq6>9t
zJ15~OVSMthqRD~-Ly?GbN}Yq=k6_{aE+9Yy%*v+R5A2&nK4giR4dJo8TQ+co!WuOF
z<5%&@*bhj+)sn8YoN<fp>N!^Ut4zIn%CCQNzRzjkE~J;494>*mA_)}uD%|X(a+*17
z_H)lpV8(!KR}hlW;y*k2dIHzkjZ@4owkxY!trqBH>5}^NHcnAMCrK{yC8Q*%?k))M
zDOA*D4)`w~r`Y?^mYC&ogB{}!eTPWJv`kc++~q;QV3si^6IOkklu__tbLw6Kfy;^*
zfrl`IS@9rTz|C^*jMLNd91!SacMFoqD5z+@dJD<3SrVt&JEo2G7K08=IkvgPEl<-_
zd|)Y-IQ`5F7oYGyCvkbg2i@*LAIQe2Flyii+t)Xw9@D0LwmYLto%K8qOKGKC{9X9D
znp(8B6~5{x>?YrKL%*FeCeD2pWE<3SHrz=c_;6!PD66ne$QuLs+X{I*p4T8zSx&=B
zq_5K0rmwDe2G(?)nk;<Au6)y~*kuL*2`t&sQr^uH^n!dH=;<q~>0?xLw&iEp(nf%I
z?hOzuXG1Tz0^VDH_ODjOtgZ@v2VyP9W8-xIAx$}u4*(_SdPVMAEfC*sVh3t-i&vbk
zoNkYjd}xi8APnnB*>VB%4UjF4m+k^j)EQcoc+k4Clt=X}1>sK<A0P~VXb35jWNx>&
z8RuERyE5mCCDxq&m_LJ8+?z+ptJ{Bju>$K=4Dd$K56QjxS0w-LNbEM2dX5)4T5nUj
zQDr_T_T~h{bcCxHgwS>YyhO6NF+vEdZ?3R*vg)iQ<p=#sY@ib;PAwy7aV7h4vJUDQ
zX?_(ew*k9#8~)aa3_ACy&!fx*9dL*jQj~wPx*RBJn*2M2F7JB1(a*-316@&a0C;P?
zR5SQ{L{M}bGvZb|@e&OUIh89gv~c7t@LAj(Pm*F5w!us5L-)$S<Y49Xlm%XoM_ga#
zTj5tqZ64M7F8Nr?(44tw<j2l;q3j2XMzh)Q`dTvF9BCKuh-_OL^`SF)7gC=dytPt~
z=FOp(Fw8AJpM&!>`ZMl(SLak>4X=J832V!Pca63>j?r!Ld7uAm;j5bF(C3S;9Z8o6
zz)xbkcbR{iKWss{`0hO^lOhVs9OEJ2L%HyjCKxdETB0W(HHM1Ru){b3L*K3q#qpK9
z-2w)C{e{9ske98-Jo%G*Dr<sildW~;DnE!1_OJtO6#IV03tlhKT`U<6T5KJFDOzu`
z4NTj`GG^VW;pHVGr8WCFyvS`$epgJmz!&2OSRao{=|x<x4q}swe|^5ez=+Yf%Bi~6
z#BWk_6g|U6(bUHIHJosI8T6@itP*v*U7sW!vlz2}H!8o~(`2fpyepb5S~C&3$k%*m
z`b7(@N{rW{I-hlvmx%MVug!JVjI~WPW?zsu(h!Yt2#3i533}SFEh%109zxtV6+pIv
zqh*dDPJxx!zOTrZE{2`Rjqm2}ky?e8+xV!zPL~0p>C7LkcY!jvUVnEhxhS1(1ni?u
z`5=ibFoJ1x0smVNn5F?=1nk<CX0A?Nx%A4DT*iY>hZBwZm{FBZ+>5iYC)TG|HC!N$
zSdn)GA!U6Z%chB&0j%iv1Ek9u`C6v@_-a@n4whe1@222&-RlY>p(3IDne~K@>j7R~
z1T)LJQ}hWW%e+g4KmZR@C27!d%a8Oeu;YPPa705>2!J~$zytWSoU)%g_{4D_*<`0k
zB!9}@RxPA>SK-jC%MB2u7n5RTbFL-e>CF094Ny3i9icLP$C<4QrluE&pidK`78-bo
zAElf2gmlsN54h|PE$LaIN$9ryqAr&xYu0@pWH%dHr&QK9k^^??vl^F_TT3i57U%`6
zUNP6j@A=6s$^r>zcdo@a2D#z5$j;C9d#>X*Di#cS3;s!4WV4C-x=Y-rZ8|C*07yfA
zG=SXX+BXM-xHS`Lpq#=VdWn|=cw}8#liZ*)u`kBfT@A&YN|Eb?+Rn+?M{wjWL(NPW
z$1Ov#`n7LB?n2+}I)Sntq&ss{o5RJ?<I%jbbm5CedP!iA>lNf7yjsiv2`~mq*-8vZ
z%Kr+7E)V2(PCV1wws_b_M;3&|aX?!wX2o=U$WB>Qo5dYpo|bcY<Fk7&9z4h(S=8Z2
z8#34APDeis+RhFhQ8By8rgl6b_$7EeT@rtOQ*gI_maL75Zpm+YAp;5or4<{CKb+;n
z{f(~h7gM-TGcP>~crLz1)$LCUb8i)Fng9~2ug=~+(1~ix{kd8m`J5HT?)XZgStjvf
zPqbM%^x>Zmd!q5uQG;u|wa06<BHp`g;gg{>tTghzYN@&f)Y>(o3+|HxrK}SlZA3aS
zGH6gdlWdJdh$!O<AE3=)i>BJjT;~NU$_dKb?<xuYQh97Y^>CF4mwHZ-IEvSEk8r_F
z<B>9{5Kd0e_mO_lSaHc_HQ0;f70bCerbN#4^jB8^2<v<OkE?z!%;%5-<4!Dm`F2`c
zylH7Pc^Ml=okzpGUub*BEE9%HFF`XyA5&o3dDvP7`!2%kKo-jfiaNX>FiiHD{2Lii
zMiOP5FNu7T;?EbYGDvdMJN_Oj^lX463SECsptBu%dT!6-lH13rZE>0Yr|j<;Q&R&w
zo>cH0@KjixxxTyoJseaHm=y$xyT<)eBISwan<-%Y6dKm#G!Kq^l8&F3I(fD~VxRm<
zhpuv67J-2)&GoqMLOr#PeBm!?Dkk$kOwQx|mebyWh}@8N`aMv61sh-Qc!~{CcePhp
zz0_2T-l8hRaE<WbpsI&Q?aD<L>V^Z_#k??}T*}Ah*@HO)cw=>0D?i!A2*K40sgSVN
z$x39s6h+GE2Ani3(-!LJ7v84^E|j>Z*i@Bz7#Olf>=jV%d;~>SSe#bR7s?$dnr62A
zHE^jyqL&62<;;TQL>%wS&BGJaCZw8s11bWBiGKtzX&3Ab<JP|kMvB@jz7Wo%!iT^m
z55+113bVhh(!B%u1k6sZV~XfbGJsk<tWkkV4)JBpNh9z_c|c`+-%bYFzXUDWk7CV^
Kt93PHx<p_C)3`AJ

literal 0
HcmV?d00001

diff --git a/code/extend/minserver/MicroCore_bak.php b/code/extend/minserver/MicroCore_bak.php
deleted file mode 100644
index fac2a94..0000000
--- a/code/extend/minserver/MicroCore_bak.php
+++ /dev/null
@@ -1,302 +0,0 @@
-<?php
-declare (strict_types = 1);
-
-namespace microserver;
-
-use think\Container;
-use think\facade\Db;
-use think\facade\Cache;
-
-class ProcessSanitizer
-{
-    static public function reloadRedis()
-    {
-        Container::getInstance()->delete('cache');
-    }
-
-    static public function reloadDb()
-    {
-        Db::close();
-        Container::getInstance()->delete('think\DbManager');
-    }
-
-    static public function destructConnectSource()
-    {
-        self::reloadDb();
-        self::reloadRedis();
-    }
-}
-
-
-
-class QueueManage
-{
-    public $strQueueName = '';
-
-    static private $arrObj = [];
-
-    static public function getInstance($intIndex = 1, $strQueueName = '')
-    {
-        $strKey = $intIndex . '-' . $strQueueName;
-
-        if (!key_exists($strKey, self::$arrObj)) {
-            self::$arrObj[$strKey] = new self($intIndex, $strQueueName);
-        }
-        return self::$arrObj[$strKey];
-    }
-
-    public function __construct($intIndex = 1, $strQueueName = '')
-    {
-        if ($strQueueName == '') {
-            $arrConfig = config('task.queue');
-            $strQueueName = $arrConfig[$intIndex]['name'];
-        }
-
-        $this->strQueueName = $strQueueName;
-    }
-
-    public function get()
-    {
-        return Cache::store('redis')->lpop($this->strQueueName);
-    }
-
-    public function set($arrData)
-    {
-        $strData = json_encode($arrData);
-        return Cache::store('redis')->rpush($this->strQueueName, $strData);
-    }
-}
-
-
-class Rout
-{
-    static public function httpDispense(\Swoole\Http\Request $Request, \Swoole\Http\Response $Response)
-    {
-        $Response->status(999, 'Hei Guys ~');
-        $Response->header("Content-Type", "text/html; charset=utf-8");
-        $Response->end("<h1>Hello reptile~. #" . rand(1000, 9999) . "</h1>");
-    }
-
-    static public function tcpDispense(\Swoole\Server $server, $fd, $reactor_id, $mixedData) {}
-}
-
-
-
-class ScheduledTasks
-{
-    static public function hander($arrProcessTask = [])
-    {
-        ProcessSanitizer::destructConnectSource();
-
-        call_user_func($arrProcessTask['callback'], $arrProcessTask['param']);
-
-        sleep($arrProcessTask['execution_interval']);
-    }
-}
-
-
-
-class ServerCore
-{
-    private $arrConfig;
-
-    private static $obj;
-
-    private $Server;
-
-    static $Process = NULL;
-
-    static function instance($arrConfig)
-    {
-        if (self::$obj == null) {
-            self::$obj = new self($arrConfig);
-        }
-        return self::$obj;
-    }
-
-    public function __construct($arrConfig)
-    {
-        $this->arrConfig = $arrConfig;
-        $this->createServer();
-    }
-
-    private function serHttpConfig()
-    {
-        $this->Server->set($this->filterConfig());
-        $this->Server->on('request', [Rout::class, 'httpDispense']);
-    }
-
-    private function filterConfig()
-    {
-        $arrConfig = $this->arrConfig;
-        unset($arrConfig['host']);
-        unset($arrConfig['port']);
-        unset($arrConfig['mode']);
-        unset($arrConfig['sockType']);
-        unset($arrConfig['server_type']);
-        return $arrConfig;
-    }
-
-    private function serTcpConfig()
-    {
-        $this->Server->set($this->filterConfig());
-        $this->Server->on('receive', [Rout::class, 'tcpDispense']);
-    }
-
-    private function createServer()
-    {
-        switch ($this->arrConfig['server_type']) {
-            case 'HTTP':
-                $this->Server = new \Swoole\Http\Server($this->arrConfig['host'], $this->arrConfig['port']);
-                $this->serHttpConfig();
-                break;
-            default:
-                $this->Server = new \Swoole\Server($this->arrConfig['host'], $this->arrConfig['port'], $this->arrConfig['mode'], $this->arrConfig['sockType']);
-                $this->serTcpConfig();
-                break;
-        }
-
-        $this->Server->on('task', [$this, 'onTask']);
-
-        $this->Server->on('finish', [$this, 'onFinish']);
-    }
-
-    public function getServer()
-    {
-        return $this->Server;
-    }
-
-    public function onTask($Http, $task_id, $from_id, $arrData)
-    {
-        $mixedResult = call_user_func_array($arrData[0], $arrData[1]);
-
-        $Http->finish($mixedResult);
-    }
-
-    public function onFinish($Http, $task_id, $mixedData) {}
-}
-
-
-
-class ServerManage
-{
-    static $HttpService;
-
-    static $arrDynamicConfig = [];
-
-    public function __init($arrArgvs = [])
-    {
-        $this->setConfigDaemonize($arrArgvs[0]['daemonize'] ?? 'false');
-    }
-
-    private function setConfigDaemonize($strMode)
-    {
-        self::$arrDynamicConfig['daemonize'] = (bool)$strMode;
-    }
-
-    private function getPid()
-    {
-        return file_exists(config('task.service.pid_file')) ? file_get_contents(config('task.service.pid_file')) : NULL;
-    }
-
-    public function start($arrArgvs = [])
-    {
-        $this->__init($arrArgvs);
-
-        $intPid = (int)$this->getPid();
-
-        if ($intPid > 0 && \Swoole\Process::kill($intPid, SIG_DFL)) {
-            echo "  Service is \e[0;32mRunning\e[0m !  " . PHP_EOL;
-            exit;
-        }
-        echo "  Execute the \e[0;32m start\e[0m command ......   " . PHP_EOL;
-
-        $this->createService();
-
-        $this->addProcessList();
-
-        $this->addScheduledTasks();
-
-        self::$HttpService->getServer()->start();
-    }
-
-    public function stop($arrArgvs = [])
-    {
-        $this->__init($arrArgvs);
-
-        $intPid = (int)$this->getPid();
-
-        if ($intPid <= 0) {
-            echo "  Service is \e[0;31mStop\e[0m !  " . PHP_EOL;
-        } else {
-            echo "  Execute the \e[0;32m stop\e[0m command ......   " . PHP_EOL;
-            \Swoole\Process::kill($intPid, SIGTERM);
-            echo "  Service is \e[0;31mStop\e[0m !  " . PHP_EOL;
-        }
-    }
-
-    public function status($arrArgvs = [])
-    {
-        $this->__init($arrArgvs);
-
-        $intPid = (int)$this->getPid();
-
-        if ($intPid <= 0) {
-            echo "  Service is \e[0;31mStop\e[0m !  " . PHP_EOL;
-        } else if (\Swoole\Process::kill($intPid, SIG_DFL)) {
-            echo "  Service is \e[0;32mRunning\e[0m !  " . PHP_EOL;
-        } else {
-            echo "  Service is \e[0;31mStop\e[0m !  " . PHP_EOL;
-        }
-    }
-
-    public function restart($arrArgvs = [])
-    {
-        $this->__init($arrArgvs);
-
-        $intPid = (int)$this->getPid();
-
-        if ($intPid <= 0) {
-            echo "  \e[0;31m Get Pid Error\e[0m !" . PHP_EOL;
-            echo "  Execute the \e[0;32m start\e[0m command ......   " . PHP_EOL;
-            $this->start();
-        } else {
-            echo "  Execute the \e[0;32m restart\e[0m command ......   " . PHP_EOL;
-            \Swoole\Process::kill($intPid, SIGUSR1);
-        }
-    }
-
-    private function addScheduledTasks()
-    {
-        if (config('task.scheduled_tasks_pool')) {
-            foreach (config('task.scheduled_tasks_pool') as $arrProcessTask) {
-                if ($arrProcessTask['status']) {
-                    $Process = new \Swoole\Process(function () use ($arrProcessTask) {
-                        call_user_func([ScheduledTasks::class, 'hander'], $arrProcessTask);
-                    });
-                    self::$HttpService->getServer()->addProcess($Process);
-                }
-            }
-        }
-    }
-
-    private function addProcessList()
-    {
-        if (config('task.process_pool')) {
-            foreach (config('task.process_pool') as $v) {
-                for ($i = 0; $i < $v['Num']; $i++) {
-                    $Process = new \Swoole\Process($v['callback']);
-
-                    self::$HttpService->getServer()->addProcess($Process);
-                }
-            }
-        }
-    }
-
-    private function createService()
-    {
-        $arrHttpServiceConfig = array_merge(config('task.service'), self::$arrDynamicConfig);
-
-        self::$HttpService = ServerCore::instance($arrHttpServiceConfig);
-    }
-}
diff --git a/code/extend/minserver/ProcessSanitizer.php b/code/extend/minserver/ProcessSanitizer.php
deleted file mode 100644
index f507515..0000000
--- a/code/extend/minserver/ProcessSanitizer.php
+++ /dev/null
@@ -1,27 +0,0 @@
-<?php
-declare (strict_types = 1);
-
-namespace minserver;
-
-use think\Container;
-use think\facade\Db;
-
-class ProcessSanitizer
-{
-    static public function reloadRedis()
-    {
-        Container::getInstance()->delete('cache');
-    }
-
-    static public function reloadDb()
-    {
-        Db::close();
-        Container::getInstance()->delete('think\DbManager');
-    }
-
-    static public function destructConnectSource()
-    {
-        self::reloadDb();
-        self::reloadRedis();
-    }
-}
\ No newline at end of file
diff --git a/code/extend/minserver/QueueManage.php b/code/extend/minserver/QueueManage.php
deleted file mode 100644
index 8e856d4..0000000
--- a/code/extend/minserver/QueueManage.php
+++ /dev/null
@@ -1,45 +0,0 @@
-<?php
-
-declare(strict_types=1);
-
-namespace minserver;
-
-use think\facade\Cache;
-
-class QueueManage
-{
-    public $strQueueName = '';
-
-    static private $arrObj = [];
-
-    static public function getInstance($intIndex = 1, $strQueueName = '')
-    {
-        $strKey = $intIndex . '-' . $strQueueName;
-
-        if (!key_exists($strKey, self::$arrObj)) {
-            self::$arrObj[$strKey] = new self($intIndex, $strQueueName);
-        }
-        return self::$arrObj[$strKey];
-    }
-
-    public function __construct($intIndex = 1, $strQueueName = '')
-    {
-        if ($strQueueName == '') {
-            $arrConfig = config('task.queue');
-            $strQueueName = $arrConfig[$intIndex]['name'];
-        }
-
-        $this->strQueueName = $strQueueName;
-    }
-
-    public function get()
-    {
-        return Cache::store('redis')->lpop($this->strQueueName);
-    }
-
-    public function set($arrData)
-    {
-        $strData = json_encode($arrData);
-        return Cache::store('redis')->rpush($this->strQueueName, $strData);
-    }
-}
diff --git a/code/extend/minserver/Rout.php b/code/extend/minserver/Rout.php
deleted file mode 100644
index 4d088d9..0000000
--- a/code/extend/minserver/Rout.php
+++ /dev/null
@@ -1,17 +0,0 @@
-<?php
-
-declare(strict_types=1);
-
-namespace minserver;
-
-class Rout
-{
-    static public function httpDispense(\Swoole\Http\Request $Request, \Swoole\Http\Response $Response)
-    {
-        $Response->status(999, 'Hei Guys ~');
-        $Response->header("Content-Type", "text/html; charset=utf-8");
-        $Response->end("<h1>Hello reptile~. #" . rand(1000, 9999) . "</h1>");
-    }
-
-    static public function tcpDispense(\Swoole\Server $server, $fd, $reactor_id, $mixedData) {}
-}
diff --git a/code/extend/minserver/ScheduledTasks.php b/code/extend/minserver/ScheduledTasks.php
deleted file mode 100644
index 06cb867..0000000
--- a/code/extend/minserver/ScheduledTasks.php
+++ /dev/null
@@ -1,19 +0,0 @@
-<?php
-
-declare(strict_types=1);
-
-namespace minserver;
-
-use minserver\ProcessSanitizer;
-
-class ScheduledTasks
-{
-    static public function hander($arrProcessTask = [])
-    {
-        ProcessSanitizer::destructConnectSource();
-
-        call_user_func($arrProcessTask['callback'], $arrProcessTask['param']);
-
-        sleep($arrProcessTask['execution_interval']);
-    }
-}
diff --git a/code/extend/minserver/ServerConsole.php b/code/extend/minserver/ServerConsole.php
deleted file mode 100644
index cc15fce..0000000
--- a/code/extend/minserver/ServerConsole.php
+++ /dev/null
@@ -1,89 +0,0 @@
-<?php
-
-declare(strict_types=1);
-
-namespace minserver;
-
-use think\console\Command;
-use think\console\Input;
-use think\console\input\Argument;
-use think\console\Output;
-use think\console\input\Option;
-
-class ServerConsole extends Command
-{
-    private $arrArguments = [
-        'action' => ['start', 'stop', 'restart', 'status',],
-        'daemonize' => ['d', "false",],
-        'forcibly' => ['f', "false",],
-    ];
-
-    private $arrReflection = [
-        \minserver\ServerManage::class,
-    ];
-
-    protected function configure()
-    {
-        $this->setName('php think task')
-            ->addArgument('action', Argument::REQUIRED, "action: (" . implode('|', $this->arrArguments['action']) . ')')
-            ->addOption('daemonize', 'd', Option::VALUE_NONE, "daemonize start service")
-            ->addOption('forcibly', 'f', Option::VALUE_NONE, "ignore user forcibly start service")
-            ->setDescription('swoole task server')
-            ->setHelp('php think task <action> [-d] [-f] run server');
-    }
-
-
-    protected function checkUser(Input $Input)
-    {
-
-        if (!$Input->getOption('forcibly')) {
-            $strUser = get_current_user();
-
-            if ($strUser == 'root') {
-                $strError = sprintf("Sorry , Can't start service by [%s] user!,\n but you can add option '-f' forcibly start on you debug ,\n Do not use in production environment   !!!!!!!!!",$strUser);
-                throw new \InvalidArgumentException($strError);
-            }
-
-            if ($strUser != 'www') {
-                throw new \InvalidArgumentException("Sorry , Can't start service by [{$strUser}] user!, please use [www] user !");
-            }
-        }
-    }
-
-    protected function execute(Input $Input, Output $Output)
-    {
-
-        $this->checkArguments(['action'], $Input, $Output);
-
-        $strAction = trim($Input->getArgument('action'));
-
-        if ($strAction == 'start' || $strAction == 'restart') {
-            $this->checkUser($Input);
-        }
-
-        $arrArgs = array_merge($Input->getArguments(), $Input->getOptions());
-
-        $this->{$strAction}($arrArgs);
-    }
-
-    private function checkArguments($arrArguments, Input $Input)
-    {
-        foreach ($arrArguments as $strArguments) {
-            $strVal = trim($Input->getArgument($strArguments));
-
-            if (!in_array($strVal, $this->arrArguments[$strArguments])) {
-                throw new \InvalidArgumentException("Arguments [{$strVal}] is not defined! Optional parameters [" . implode(' ', $this->arrArguments[$strArguments]) . "] !");
-            }
-        }
-    }
-
-    public function __call($strAction, $arrArguments)
-    {
-        foreach ($this->arrReflection as $strClass) {
-            if (method_exists($strClass, $strAction)) {
-                return call_user_func([new $strClass, $strAction], $arrArguments);
-            }
-        }
-        throw new \InvalidArgumentException("Action [{$strAction}] no method available! ");
-    }
-}
diff --git a/code/extend/minserver/ServerCore.php b/code/extend/minserver/ServerCore.php
deleted file mode 100644
index b8f348e..0000000
--- a/code/extend/minserver/ServerCore.php
+++ /dev/null
@@ -1,87 +0,0 @@
-<?php
-
-declare(strict_types=1);
-
-namespace minserver;
-
-class ServerCore
-{
-    private $arrConfig;
-
-    private static $obj;
-
-    private $Server;
-
-    static $Process = NULL;
-
-    static function instance($arrConfig)
-    {
-        if (self::$obj == null) {
-            self::$obj = new self($arrConfig);
-        }
-        return self::$obj;
-    }
-
-    public function __construct($arrConfig)
-    {
-        $this->arrConfig = $arrConfig;
-        $this->createServer();
-    }
-
-    private function serHttpConfig()
-    {
-        $this->Server->set($this->filterConfig());
-        $this->Server->on('request', [\minserver\Rout::class, 'httpDispense']);
-    }
-
-    private function filterConfig()
-    {
-        $arrConfig = $this->arrConfig;
-        unset($arrConfig['host']);
-        unset($arrConfig['port']);
-        unset($arrConfig['mode']);
-        unset($arrConfig['sockType']);
-        unset($arrConfig['server_type']);
-        return $arrConfig;
-    }
-
-    private function serTcpConfig()
-    {
-        $this->Server->set($this->filterConfig());
-        $this->Server->on('receive', [\minserver\Rout::class, 'tcpDispense']);
-    }
-
-    private function createServer()
-    {
-        switch ($this->arrConfig['server_type']) {
-            case 'HTTP':
-                $this->Server = new \Swoole\Http\Server($this->arrConfig['host'], $this->arrConfig['port']);
-                $this->serHttpConfig();
-                break;
-            default:
-                $this->Server = new \Swoole\Server($this->arrConfig['host'], $this->arrConfig['port'], $this->arrConfig['mode'], $this->arrConfig['sockType']);
-                $this->serTcpConfig();
-                break;
-        }
-
-        $this->Server->on('task', [$this, 'onTask']);
-
-        $this->Server->on('finish', [$this, 'onFinish']);
-    }
-
-    public function getServer()
-    {
-        return $this->Server;
-    }
-
-    public function onTask($Http, $task_id, $from_id, $arrData)
-    {
-        $mixedResult = call_user_func_array($arrData[0], $arrData[1]);
-
-        $Http->finish($mixedResult);
-    }
-
-    public function onFinish($Http, $task_id, $mixedData)
-    {
-    }
-}
diff --git a/code/extend/minserver/ServerManage.php b/code/extend/minserver/ServerManage.php
deleted file mode 100644
index f46e7c1..0000000
--- a/code/extend/minserver/ServerManage.php
+++ /dev/null
@@ -1,129 +0,0 @@
-<?php
-
-declare(strict_types=1);
-
-namespace minserver;
-
-class ServerManage
-{
-    static $HttpService;
-
-    static $arrDynamicConfig = [];
-
-    public function __init($arrArgvs = [])
-    {
-        $this->setConfigDaemonize($arrArgvs[0]['daemonize'] ?? 'false');
-    }
-
-    private function setConfigDaemonize($strMode)
-    {
-        self::$arrDynamicConfig['daemonize'] = (bool)$strMode;
-    }
-
-    private function getPid()
-    {
-        return file_exists(config('task.service.pid_file')) ? file_get_contents(config('task.service.pid_file')) : NULL;
-    }
-
-    public function start($arrArgvs = [])
-    {
-        $this->__init($arrArgvs);
-
-        $intPid = (int)$this->getPid();
-
-        if ($intPid > 0 && \Swoole\Process::kill($intPid, SIG_DFL)) {
-            echo "  Service is \e[0;32mRunning\e[0m !  " . PHP_EOL;
-            exit;
-        }
-        echo "  Execute the \e[0;32m start\e[0m command ......   " . PHP_EOL;
-
-        $this->createService();
-
-        $this->addProcessList();
-       
-        $this->addScheduledTasks();
-     
-        self::$HttpService->getServer()->start();
-    
-    }
-
-    public function stop($arrArgvs = [])
-    {
-        $this->__init($arrArgvs);
-
-        $intPid = (int)$this->getPid();
-
-        if ($intPid <= 0) {
-            echo "  Service is \e[0;31mStop\e[0m !  " . PHP_EOL;
-        } else {
-            echo "  Execute the \e[0;32m stop\e[0m command ......   " . PHP_EOL;
-            \Swoole\Process::kill($intPid, SIGTERM);
-            echo "  Service is \e[0;31mStop\e[0m !  " . PHP_EOL;
-        }
-    }
-
-    public function status($arrArgvs = [])
-    {
-        $this->__init($arrArgvs);
-
-        $intPid = (int)$this->getPid();
-
-        if ($intPid <= 0) {
-            echo "  Service is \e[0;31mStop\e[0m !  " . PHP_EOL;
-        } else if (\Swoole\Process::kill($intPid, SIG_DFL)) {
-            echo "  Service is \e[0;32mRunning\e[0m !  " . PHP_EOL;
-        } else {
-            echo "  Service is \e[0;31mStop\e[0m !  " . PHP_EOL;
-        }
-    }
-
-    public function restart($arrArgvs = [])
-    {
-        $this->__init($arrArgvs);
-
-        $intPid = (int)$this->getPid();
-
-        if ($intPid <= 0) {
-            echo "  \e[0;31m Get Pid Error\e[0m !" . PHP_EOL;
-            echo "  Execute the \e[0;32m start\e[0m command ......   " . PHP_EOL;
-            $this->start();
-        } else {
-            echo "  Execute the \e[0;32m restart\e[0m command ......   " . PHP_EOL;
-            \Swoole\Process::kill($intPid, SIGUSR1);
-        }
-    }
-
-    private function addScheduledTasks()
-    {
-        if (config('task.scheduled_tasks_pool')) {
-            foreach (config('task.scheduled_tasks_pool') as $arrProcessTask) {
-                if ($arrProcessTask['status']) {
-                    $Process = new \Swoole\Process(function () use ($arrProcessTask) {
-                        call_user_func([\minserver\ScheduledTasks::class, 'hander'], $arrProcessTask);
-                    });
-                    self::$HttpService->getServer()->addProcess($Process);
-                }
-            }
-        }
-    }
-
-    private function addProcessList()
-    {
-        if (config('task.process_pool')) {
-            foreach (config('task.process_pool') as $v) {
-                for ($i = 0; $i < $v['Num']; $i++) {
-                    $Process = new \Swoole\Process($v['callback']);
-
-                    self::$HttpService->getServer()->addProcess($Process);
-                }
-            }
-        }
-    }
-
-    private function createService()
-    {
-        $arrHttpServiceConfig = array_merge(config('task.service'), self::$arrDynamicConfig);
-
-        self::$HttpService = ServerCore::instance($arrHttpServiceConfig);
-    }
-}