InitKeyword.php 2.2 KB
<?php

namespace App\Console\Commands;

use App\Http\Logic\Aside\Project\ProjectLogic;
use App\Models\Com\NoticeLog;
use App\Models\Product\Keyword;
use App\Models\Project\Project;
use App\Models\RouteMap\RouteMap;
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 InitKeyword extends Command
{
    /**
     * The name and signature of the console command.
     *
     * @var string
     */
    protected $signature = 'init_keyword';

    /**
     * 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_KEYWORD)->where('status', NoticeLog::STATUS_PENDING)->get();
            if(!empty($list)){
                foreach ($list as $item){
                    echo 'start:' . $item['data']['project_id'] . PHP_EOL;
                    ProjectServer::useProject($item['data']['project_id']);
                    $keywordModel = new Keyword();
                    $list = $keywordModel->list(['route'=>'']);
                    echo 'start:' . json_encode($list) . PHP_EOL;
                    foreach ($list as $v){
                        $route = RouteMap::setRoute($v['title'],RouteMap::SOURCE_PRODUCT_KEYWORD,$v['id'],$item['data']['project_id']);
                        if(empty($route)){
                            $keywordModel->del(['id'=>$v['id']]);
                            continue;
                        }
                        $keywordModel->edit(['route'=>$route],['id'=>$v['id']]);
                    }
                    $item->status = NoticeLog::STATUS_SUCCESS;
                    $item->save();
                    DB::disconnect('custom_mysql');
                }
            }
            sleep(2);
        }
    }

}