扩展功能

2019-12-06 09:17:40 +08:00
parent 397c8bb7f7
commit 5c7765c97f
18 changed files with 1396 additions and 0 deletions
--- a/extend/catcher/command/InstallCommand.php
+++ b/extend/catcher/command/InstallCommand.php
@@ -0,0 +1,329 @@
+<?php
+namespace catcher\command;
+
+use think\console\Command;
+use think\console\Input;
+use think\console\input\Argument;
+use think\console\input\Option;
+use think\console\Output;
+use think\facade\Console;
+use think\facade\Db;
+
+class InstallCommand extends Command
+{
+
+    protected $dataInstall = true;
+
+    protected function configure()
+    {
+        $this->setName('install:project')
+            // ->addArgument('module', Argument::REQUIRED, 'module name')
+            ->setDescription('install project');
+    }
+
+    /**
+     *
+     * @time 2019年11月29日
+     * @param Input $input
+     * @param Output $output
+     * @return int|void|null
+     */
+    protected function execute(Input $input, Output $output)
+    {
+        $this->detectionEnvironment();
+
+        $this->firstStep();
+
+        $this->secondStep();
+
+        $this->thirdStep();
+
+        $this->finished();
+
+        $this->project();
+    }
+
+    /**
+     * 环境检测
+     *
+     * @time 2019年11月29日
+     * @return void
+     */
+    protected function detectionEnvironment(): void
+    {
+        $this->output->info('environment begin to check...');
+
+        if (version_compare(PHP_VERSION, '7.1.0', '<')) {
+            $this->output->error('php version should >= 7.1.0');
+            exit();
+        }
+
+        $this->output->info('php version ' . PHP_VERSION);
+
+        if (!extension_loaded('mbstring')) {
+            $this->output->error('mbstring extension not install');exit();
+        }
+        $this->output->info('mbstring extension is installed');
+
+        if (!extension_loaded('json')) {
+            $this->output->error('json extension not install');
+            exit();
+        }
+        $this->output->info('json extension is installed');
+
+        if (!extension_loaded('openssl')) {
+            $this->output->error('openssl extension not install');
+            exit();
+        }
+        $this->output->info('openssl extension is installed');
+
+        if (!extension_loaded('pdo')) {
+            $this->output->error('pdo extension not install');
+            exit();
+        }
+        $this->output->info('pdo extension is installed');
+
+        if (!extension_loaded('xml')) {
+            $this->output->error('xml extension not install');
+            exit();
+        }
+
+        $this->output->info('xml extension is installed');
+
+        $this->output->info('🎉 environment checking finished');
+    }
+
+    /**
+     * 安装第一步
+     *
+     * @time 2019年11月29日
+     * @return bool
+     */
+    protected function firstStep(): bool
+    {
+        if (file_exists($this->app->getRootPath() . '.env')) {
+            return false;
+        }
+
+        $answer = strtolower($this->output->ask($this->input, '🤔️ Did You Need to Set Database information? (Y/N): '));
+
+        if ($answer === 'y' || $answer === 'yes') {
+            $charset = $this->output->ask($this->input, '👉 please input database charset, default (utf8mb4):') ? : 'utf8mb4';
+            $database = '';
+            while (!$database) {
+                $database = $this->output->ask($this->input, '👉 please input database name: ');
+                if ($database) {
+                    break;
+                }
+            }
+            $host = $this->output->ask($this->input, '👉 please input database host, default (127.0.0.1):') ? : '127.0.0.1';
+            $port = $this->output->ask($this->input, '👉 please input database host port, default (3306):') ? : '3306';
+            $prefix = $this->output->ask($this->input, '👉 please input table prefix, default (null):') ? : '';
+            $username = $this->output->ask($this->input, '👉 please input database username default (root): ') ? : 'root';
+            $password = '';
+            while (!$password) {
+                $password = $this->output->ask($this->input, '👉 please input database password: ');
+                if ($password) {
+                    break;
+                }
+            }
+
+            $this->generateEnvFile($host, $database, $username, $password, $port, $charset, $prefix);
+        }
+    }
+
+    /**
+     * 安装第二部
+     *
+     * @time 2019年11月29日
+     * @return void
+     */
+    protected function secondStep(): void
+    {
+        $modulePaths = glob(root_path('module') . '*');
+
+        $this->checkRootDatabase();
+
+        foreach ($modulePaths as $path) {
+            if (is_dir($path)) {
+                $moduleDatabasePath = $path . DIRECTORY_SEPARATOR . 'database' . DIRECTORY_SEPARATOR;
+                if (is_dir($moduleDatabasePath)) {
+                    if (is_dir($moduleDatabasePath . 'migrations' . DIRECTORY_SEPARATOR)) {
+                        $migrationFiles = glob($moduleDatabasePath . 'migrations' . DIRECTORY_SEPARATOR . '*.php');
+                        foreach ($migrationFiles as $file) {
+                            copy($file,
+                                root_path('database') . 'migrations'. DIRECTORY_SEPARATOR .
+                                pathinfo($file, PATHINFO_BASENAME));
+                        }
+                    }
+
+                    if (is_dir($moduleDatabasePath . 'seeds' . DIRECTORY_SEPARATOR)) {
+                        $seedFiles = glob($moduleDatabasePath . 'seeds' . DIRECTORY_SEPARATOR . '*.php');
+                        foreach ($seedFiles as $file) {
+                            copy($file,
+                                root_path('database') . 'seeds' . DIRECTORY_SEPARATOR .
+                                pathinfo($file, PATHINFO_BASENAME));
+                        }
+                    }
+                }
+            }
+        }
+    }
+
+    /**
+     * 安装第四步
+     *
+     * @time 2019年11月29日
+     * @return void
+     */
+    protected function thirdStep(): void
+    {
+        Console::call('catch:cache');
+    }
+
+    /**
+     * finally
+     *
+     * @time 2019年11月30日
+     * @return void
+     */
+    protected function finished(): void
+    {
+        // todo something
+        if ($this->dataInstall) {
+            rmdir($this->app->getRootPath() . 'database');
+        }
+    }
+
+    /**
+     * generate env file
+     *
+     * @time 2019年11月29日
+     * @param $host
+     * @param $database
+     * @param $username
+     * @param $password
+     * @param $port
+     * @param $charset
+     * @param $prefix
+     * @return void
+     */
+    protected function generateEnvFile($host, $database, $username, $password, $port, $charset, $prefix): void
+    {
+            $env = \parse_ini_file(root_path() . '.example.env', true);
+
+            $env['DATABASE']['HOSTNAME'] = $host;
+            $env['DATABASE']['DATABASE'] = $database;
+            $env['DATABASE']['USERNAME'] = $username;
+            $env['DATABASE']['PASSWORD'] = $password;
+            $env['DATABASE']['HOSTPORT'] = $port;
+            $env['DATABASE']['CHARSET'] = $charset;
+            if ($prefix) {
+                $env['DATABASE']['PREFIX'] = $prefix;
+            }
+            $dotEnv = '';
+            foreach ($env as $key => $e) {
+                if (is_string($e)) {
+                    $dotEnv .= sprintf('%s = %s', $key, $e === '1' ? 'true' : ($e === '' ? 'false' : $e)) . PHP_EOL;
+                    $dotEnv .= PHP_EOL;
+                } else {
+                    $dotEnv .= sprintf('[%s]', $key) . PHP_EOL;
+                    foreach ($e as $k => $v) {
+                        $dotEnv .= sprintf('%s = %s', $k, $v === '1' ? 'true' : ($v === '' ? 'false' : $v)) . PHP_EOL;
+                    }
+
+                    $dotEnv .= PHP_EOL;
+                }
+            }
+
+            file_put_contents(root_path() . '.env', $dotEnv);
+
+            if ($this->getEnvFile()) {
+                $this->output->info('env file has been generated');
+            }
+
+            if ((new \mysqli($host, $username, $password, null, $port))->query(sprintf('CREATE DATABASE IF NOT EXISTS %s DEFAULT CHARSET %s COLLATE %s_general_ci;',
+                $database, $charset, $charset))) {
+                $this->output->info(sprintf('🎉 create database %s successfully', $database));
+
+                exec(sprintf('%s %s migrate:run',  getenv('_'), root_path() . DIRECTORY_SEPARATOR . 'think'));
+
+                $this->output->info('🎉 database table install successfully');
+
+                exec(sprintf('%s %s seed:run', getenv('_'),root_path() . DIRECTORY_SEPARATOR . 'think'));
+
+                $this->output->info('🎉 Fill database table successfully ');
+            } else {
+                $this->dataInstall = false;
+                $this->output->warning(sprintf('create database %s failed, you should create it by yourself', $database));
+                $this->output->warning('you should use `php think migrate:run` to create tables');
+                $this->output->warning('you should use `php think seed:run` to fill tables data');
+            }
+    }
+
+    /**
+     *
+     * @time 2019年11月29日
+     * @return string
+     */
+    protected function getEnvFile(): string
+    {
+        return file_exists(root_path() . '.env') ? root_path() . '.env' : '';
+    }
+
+    /**
+     * 检测根目录
+     *
+     * @time 2019年11月28日
+     * @return bool
+     */
+    protected function checkRootDatabase(): bool
+    {
+        $databasePath = root_path('database');
+
+        if (!is_dir($databasePath)) {
+            if (!mkdir($databasePath, 0777, true) && !is_dir($databasePath)) {
+                throw new \RuntimeException(sprintf('Directory "%s" was not created', $databasePath));
+            }
+        }
+
+        $migrationPath = $databasePath . DIRECTORY_SEPARATOR . 'migrations' . DIRECTORY_SEPARATOR;
+
+        $seedPath = $databasePath . DIRECTORY_SEPARATOR . 'seeds' . DIRECTORY_SEPARATOR;
+
+        if (!is_dir($migrationPath)) {
+            if (!mkdir($migrationPath, 0777, true) && !is_dir($migrationPath)) {
+                throw new \RuntimeException(sprintf('Directory "%s" was not created', $migrationPath));
+            }
+        }
+
+        if (!is_dir($seedPath)) {
+            if (!mkdir($seedPath, 0777, true) && !is_dir($seedPath)) {
+                throw new \RuntimeException(sprintf('Directory "%s" was not created', $seedPath));
+            }
+        }
+
+        return true;
+    }
+
+
+    protected function project()
+    {
+        $year = date('Y');
+
+        $this->output->info('🎉 project is installed, welcome!');
+
+        $this->output->info(sprintf('
+ /-------------------- welcome to use -------------------------\                     
+|               __       __       ___       __          _      |
+|   _________ _/ /______/ /_     /   | ____/ /___ ___  (_)___  |
+|  / ___/ __ `/ __/ ___/ __ \   / /| |/ __  / __ `__ \/ / __ \ |
+| / /__/ /_/ / /_/ /__/ / / /  / ___ / /_/ / / / / / / / / / / |
+| \___/\__,_/\__/\___/_/ /_/  /_/  |_\__,_/_/ /_/ /_/_/_/ /_/  |
+|                                                              |   
+ \ __ __ __ __ _ __ _ __ enjoy it ! _ __ __ __ __ __ __ ___ _ @ 2017 ～ %s 
+                                                       
+', $year));
+
+    }
+}
--- a/extend/catcher/command/MigrateRunCommand.php
+++ b/extend/catcher/command/MigrateRunCommand.php
@@ -0,0 +1,64 @@
+<?php
+namespace catcher\command;
+
+use catcher\CatchAdmin;
+use think\console\Input;
+use think\console\input\Argument;
+use think\console\input\Option as InputOption;
+use think\console\Output;
+use think\migration\command\migrate\Run;
+
+class MigrateRunCommand extends Run
+{
+    protected $module;
+
+    public function configure()
+    {
+        $this->setName('catch-migrate:run')
+            ->setDescription('Migrate the database')
+            ->addArgument('module', Argument::REQUIRED, 'migrate the module database')
+            ->addOption('--target', '-t', InputOption::VALUE_REQUIRED, 'The version number to migrate to')
+            ->addOption('--date', '-d', InputOption::VALUE_REQUIRED, 'The date to migrate to')
+            ->setHelp(<<<EOT
+The <info>migrate:run</info> command runs all available migrations, optionally up to a specific version
+
+<info>php think catch-migrate:run module</info>
+<info>php think catch-migrate:run -t 20110103081132</info>
+<info>php think catch-migrate:run -d 20110103</info>
+<info>php think catch-migrate:run -v</info>
+
+EOT
+            );
+    }
+
+    protected function execute(Input $input, Output $output)
+    {
+        $this->module = strtolower($input->getArgument('module'));
+        $version = $input->getOption('target');
+        $date    = $input->getOption('date');
+
+        // run the migrations
+        $start = microtime(true);
+        if (null !== $date) {
+            $this->migrateToDateTime(new \DateTime($date));
+        } else {
+            $this->migrate($version);
+        }
+        $end = microtime(true);
+
+        $output->writeln('');
+        $output->writeln('<comment>All Done. Took ' . sprintf('%.4fs', $end - $start) . '</comment>');
+    }
+
+    /**
+     * 获取 migration path
+     *
+     * @time 2019年12月03日
+     * @param $module
+     * @return string
+     */
+    protected function getPath()
+    {
+        return CatchAdmin::moduleMigrationsDirectory($this->module);
+    }
+}
--- a/extend/catcher/command/ModelGeneratorCommand.php
+++ b/extend/catcher/command/ModelGeneratorCommand.php
@@ -0,0 +1,95 @@
+<?php
+
+namespace catcher\command;
+
+use catcher\CatchAdmin;
+use think\console\Command;
+use think\console\Input;
+use think\console\input\Argument;
+use think\console\input\Option as InputOption;
+use think\console\Output;
+use think\facade\Db;
+use think\helper\Str;
+
+class ModelGeneratorCommand extends Command
+{
+    protected function configure()
+    {
+        $this->setName('create:model')
+            ->addArgument('model', Argument::REQUIRED, 'model name')
+            ->addArgument('module', Argument::REQUIRED, 'module name')
+            ->setDescription('create model');
+    }
+
+    protected function execute(Input $input, Output $output)
+    {
+        $model = ucfirst($input->getArgument('model'));
+        $module = strtolower($input->getArgument('module'));
+
+        $table = Str::snake($model);
+
+        $modelFile= CatchAdmin::getModuleModelDirectory($module) . $model . '.php';
+
+        file_put_contents($modelFile, $this->replaceContent([
+            $module, $model, $table, $this->generateFields($this->getTableFields($table))
+        ]));
+
+        if (file_exists($modelFile)) {
+            $output->info(sprintf('%s Create Successfully!', $modelFile));
+        } else {
+            $output->error(sprintf('%s Create Failed!', $modelFile));
+        }
+    }
+
+
+
+    private function getTableFields($table): array
+    {
+        $fields = Db::query('show full columns from ' .
+            config('database.connections.mysql.prefix') . $table);
+
+        $new = [];
+
+        foreach ($fields as $field) {
+            $new[$field['Field']] = $field['Comment'];
+        }
+
+        return $new;
+    }
+
+    private function generateFields($fields)
+    {
+        $f = '';
+        foreach ($fields as $field => $comment) {
+            $f .= sprintf("'%s', // %s" . "\r\n\t\t\t", $field, $comment);
+        }
+
+        return $f;
+    }
+
+    private function replaceContent(array $replace)
+    {
+        return str_replace([
+            '{Module}', '{Class}', '{Name}', '{Field}'
+        ], $replace, $this->content());
+    }
+
+    private function content()
+    {
+        return <<<EOT
+<?php
+namespace catchAdmin\{Module}\model;
+
+use cather\Model;
+
+class {Class} extends Model
+{
+    protected \$name = '{Name}';
+    
+    protected \$field = [
+            {Field}   
+    ];  
+}
+EOT;
+    }
+}
--- a/extend/catcher/command/ModuleCacheCommand.php
+++ b/extend/catcher/command/ModuleCacheCommand.php
@@ -0,0 +1,30 @@
+<?php
+declare (strict_types = 1);
+
+namespace catcher\command;
+
+use catcher\CatchAdmin;
+use think\console\Command;
+use think\console\Input;
+use think\console\input\Argument;
+use think\console\input\Option;
+use think\console\Output;
+
+class ModuleCacheCommand extends Command
+{
+    protected function configure()
+    {
+        // 指令配置
+        $this->setName('catch:cache')
+            ->setDescription('cache routes, views, services of module');
+    }
+
+    protected function execute(Input $input, Output $output)
+    {
+        CatchAdmin::cacheRoutes();
+        CatchAdmin::cacheServices();
+        CatchAdmin::cacheViews();
+    	// 指令输出
+    	$output->info('succeed!');
+    }
+}