<?php

namespace App\Console\Commands;


use App\Exceptions\InquiryFilterException;
use App\Services\SyncSubmitTaskService;
use Illuminate\Console\Command;
use App\Models\SyncSubmitTask\SyncSubmitTask as SyncSubmitTaskModel;
use Illuminate\Support\Facades\Redis;
use Illuminate\Support\Str;

/**
 *
 * Class SyncSubmitTask
 * @package App\Console\Commands
 * @author zbj
 * @date 2023/11/28
 */
class SyncSubmitTask extends Command
{

    protected $signature = 'sync_submit_task';
    protected $description = '询盘、访问异步任务';

    public function handle()
    {
        while (true) {
            $task_id = $this->getTaskId();
            if (empty($task_id)) {
                sleep(5);
                continue;
            }
            $this->output('任务' . $task_id . '开始');
            $task_info = SyncSubmitTaskModel::find($task_id);
            if (empty($task_info) || $task_info->status) {
                $this->output('任务不存在或者已执行');
                continue;
            }
            try {
                SyncSubmitTaskService::handler($task_info);
                $task_info->status = 1;
                $task_info->save();

                $this->output('任务完成');
            } catch (InquiryFilterException $e){
                $task_info->status = 1;
                $task_info->is_filtered = 1;
                $task_info->remark = $e->getMessage();
                $task_info->save();

                $this->output('任务完成');
            } catch (\Exception $e) {
                $task_info->retry = $task_info->retry + 1;
                if ($task_info->retry >= 3) {
                    $task_info->status = 2;
                    $task_info->remark = Str::substr($e->getMessage(), 0, 200);
                } else {
                    Redis::lpush('sync_submit_task', $task_id);
                }
                $task_info->save();

                $this->output('任务失败：' . $e->getMessage());
            }
        }
    }

    public function getTaskId(){
        $task_id = Redis::rpop('sync_submit_task');
        if (empty($task_id)) {
            $ids = SyncSubmitTaskModel::where('status', 0)->pluck('id');
            foreach($ids as $id){
                Redis::lpush('sync_submit_task', $id);
            }
            $task_id = Redis::rpop('sync_submit_task');
        }
        return $task_id;
    }

    /**
     * 输出处理日志
     */
    public function output($message): bool
    {
        echo date('Y-m-d H:i:s') . ' | ' . $message . PHP_EOL;
        return true;
    }

}