<?php

namespace App\Console\Commands;

use App\Http\Logic\Aside\Project\ProjectLogic;
use App\Models\Com\NoticeLog;
use App\Models\Project\Project;
use App\Services\ProjectServer;
use Illuminate\Console\Command;
use Illuminate\Support\Facades\DB;

/**
 * 初始化项目
 * Class InitProject
 * @package App\Console\Commands
 * @author zbj
 * @date 2023/10/8
 */
class InitProject extends Command
{
    /**
     * The name and signature of the console command.
     *
     * @var string
     */
    protected $signature = 'init_project';

    /**
     * The console command description.
     *
     * @var string
     */
    protected $description = '初始化项目';

    /**
     * Create a new command instance.
     *
     * @return void
     */
    public function __construct()
    {
        parent::__construct();
    }

    /**
     * @return bool
     */
    public function handle()
    {
        while (true){
            $list = NoticeLog::where('type', NoticeLog::TYPE_INIT_PROJECT)->where('status', NoticeLog::STATUS_PENDING)->get();
            foreach ($list as $item){
                echo 'start:' . $item['id'] . PHP_EOL;
                try {
                    $project = Project::find($item['data']['project_id']);

                    $project_logic = new ProjectLogic();
                    //初始化数据库
                    if(!empty($project['mysql_id'])){
                        $project_logic->initializationMysql($project['id']);
                    }
                    //初始账号
                    if(!empty($project['mobile'])){
                        $project_logic->createUser($project['mobile'],$project['id'],$project['lead_name']);
                    }
                    //更改服务器状态
                    if(!empty($project['serve_id'])){
                        $project_logic->updateServe($project['serve_id']);
                    }

                    $item->status = NoticeLog::STATUS_SUCCESS;
                    $item->save();
                    echo 'success:' . $item['id'] . PHP_EOL;
                }catch (\Exception $e){
                    echo 'error:' . $item['id'] . $e->getMessage() . PHP_EOL;
                    errorLog('项目初始化失败', $item, $e);
                    $this->retry($item, $e->getMessage());
                }
            }
            sleep(2);
        }
    }

    /**
     * @param NoticeLog $log
     */
    public function retry($log, $remark){
        if($log->retry >= 3){
            $log->status = NoticeLog::STATUS_FAIL;
            $log->remark = mb_substr($remark, 0, 250);
        }else{
            $log->retry = $log->retry + 1;
        }
        $log->save();
    }
}