<?php

namespace App\Console\Commands\RankData;

use App\Helper\QuanqiusouApi;
use App\Http\Logic\Bside\RankData\RankDataLogic;
use App\Models\Com\NoticeLog;
use Illuminate\Console\Command;
use Illuminate\Support\Facades\Log;

/**
 * Class GoogleRank
 * @package App\Console\Commands
 * @author zbj
 * @date 2023/5/6
 */
class RankDataTask extends Command
{
    /**
     * The name and signature of the console command.
     *
     * @var string
     */
    protected $signature = 'rank_data_task';

    /**
     * The console command description.
     * The console command description.
     *
     * @var string
     */
    protected $description = '谷歌排名数据';


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


    /**
     * @author zbj
     * @date 2023/5/6
     */
    public function handle()
    {
        $list = NoticeLog::where('type', NoticeLog::TYPE_RANK_DATA)->where('status', NoticeLog::STATUS_PENDING)->get();
        foreach ($list as $item) {
            echo 'start:' . $item['id'] . PHP_EOL;
            $error_msg = [];
            $rankDataLogic = new RankDataLogic();
            try {
                //排名数据
                $api = new QuanqiusouApi();
                $site_res = $api->getSiteRes();
                $rankDataLogic->syncRankData($item['data']['api_no'], $site_res, true);
            } catch (\Exception $e) {
                Log::channel('rank_data')->error('排名数据更新失败' . $e->getMessage(), $item->toArray());
                $error_msg[] = $e->getMessage();
            }

            try {
                //外链数据
                $rankDataLogic->syncExternalLinks($item['data']['api_no'], true);
                //外链引荐域名
                $rankDataLogic->syncRecommDomain($item['data']['api_no'], true);
                //测速
                $rankDataLogic->syncSpeed($item['data']['api_no'], true);
                //每周排名数据
                $rankDataLogic->syncRankWeek($item['data']['api_no'], true);

                $item->status = NoticeLog::STATUS_SUCCESS;
                $item->save();
                echo 'success:' . $item['id'] . PHP_EOL;
            } catch (\Exception $e){
                echo 'error:' . $item['id'] . $e->getMessage() . PHP_EOL;
                Log::channel('rank_data')->error('排名数据更新失败' . $e->getMessage(), $item->toArray());
                $error_msg[] = $e->getMessage();
            }

            if($error_msg){
                $this->retry($item, implode(',', $error_msg));
            }
        }
    }

    /**
     * @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();
    }
}