yuanchengpasc/application/admin/command/Upgrade.php

<?php
namespace app\admin\command;

use think\console\Command;
use think\console\Input;
use think\Db;
use think\console\Output;
use app\common\controller\Version;

class Upgrade extends Command
{

    protected function configure()
    {
        $this->setName('upgrade')->setDescription('Version upgrades');
    }

    protected function execute(Input $input, Output $output)
    {
        // 没有版本表格的话  读取 创建
        $ve = file_get_contents(__DIR__."/../../common/versionsql/createversion");
        DB::execute($ve);
        // 旧版本号
        $version = DB::table('version')->where('id',1)->field('version')->find();
        if(empty($version)){
            $version['version'] = 1;
            DB::table('version')->insert(['id'=>1,'version'=>1]);
        }
        // 新版本号
        $oldversion = Version::getVersion();
        $output->writeln($version);
        if($version['version'] < $oldversion){
            $output->writeln('存在版本差异');
            $errarr = array();
            $ver = '';
            // 新版本大于旧版本
            for($version['version'];$version['version'] < $oldversion;$version['version']++){
                $name = "Version".$version['version'];
                $output->writeln("版本更新中...");
                if(file_exists(__DIR__."/../../common/versionsql/".$name)){
                    $info = file_get_contents(__DIR__."/../../common/versionsql/".$name);
                    if(empty($info)){
                        $output->writeln("找到版本文件");
                        continue;
                    }else{
                        $output->writeln("\033[31m 没有找到对应文件 \033[0m");
                    }
                    $sqlarr = explode(';',$info);
                    foreach ($sqlarr as $k => $v) {
                        if(empty($v)){
                            continue;
                        }
                        $output->writeln("执行版本文件");
                        try{
                            $result = DB::execute($v);
                            if($result == 0){
                                // 执行成功
                                $output->writeln("执行成功，版本");
                            }else{
                                $errarr[] = $v;
                                $output->writeln("\033[31m 执行失败 \033[0m");
                            }
                        }catch(\Exception $e){
                            $output->writeln("\033[31m SQL错误，".$e->getMessage()." \033[0m");
                        }
                    }
                }else{
                    $output->writeln("\033[31m 未找到版本更新文件 \033[0m");
                }
                $ver = $oldversion;
            }
            if(empty($errarr)){
                //  没有执行错误
                // 数据库版本更新
                DB::table('version')->where('id',1)->update(['version'=>$ver]);
            }else{
                $output->writeln("\033[31m $errarr \033[0m");
            }
        }
    }
}