<?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('have version');
            $errarr = array();
            $ver = '';
            // 新版本大于旧版本
            for($version['version'];$version['version'] < $oldversion;$version['version']++){
                $name = "Version".$version['version'];
                $output->writeln("upgrading...");
                if(file_exists(__DIR__."/../../common/versionsql/".$name)){
                    $info = file_get_contents(__DIR__."/../../common/versionsql/".$name);
                    if(empty($info)){
                        $output->writeln("\e[31m have no info \e[0m");
                        continue;
                    }else{
                        $output->writeln("find the document");
                    }
                    $sqlarr = explode(';',$info);
                    foreach ($sqlarr as $k => $v) {
                        if(empty($v)){
                            continue;
                        }
                        try{
                            $output->writeln($v);
                            $result = DB::execute($v);
                            $output->writeln("success");
                        }catch(\Exception $e){
                            $output->writeln("\033[31m SQL error，--".$e->getMessage()." \033[0m");
                        }
                    }
                    DB::table('version')->where('id',1)->update(['version'=>($version['version']+1)]);
                }else{
                    $output->writeln("\033[31m document id not find \033[0m");
                }
            }
        }
    }
}