<?php

namespace App\Domains\Virtual\Commands\Sync;

use Carbon\Carbon;
use App\Models\Card\Card;
use Illuminate\Support\Arr;
use Illuminate\Support\Collection;
use Illuminate\Support\Facades\DB;
use Illuminate\Support\Facades\Artisan;
use App\Domains\Virtual\Jobs\CardSyncJob;
use App\Domains\Config\Services\ConfigService;
use App\Domains\Card\Repositories\CardRepository;

class CardSync extends Command
{
    protected $name = 'virtual:sync-card';

    protected $description = '同步VD卡信息数据';

    const CURSOR_KEY = 'sync_card_cursor';

    protected $limit = 1000;

    public function handle()
    {
        $maxId = app(ConfigService::class)->get(self::CURSOR_KEY) ?: 0;

        $query = DB::connection('vd_old')->table('ckb_custom')->where('id', '>', $maxId)->orderBy('id');

        $nextId = $query->max('id');

        $total = $query->count();

        $this->line('待同步条数:' . $total);

        if ($total) {
            Artisan::call('real:sync-bloc');
        }

        $page = 2;

        $jobs = new Collection();

        while ($total) {
            if (($page - 1) * $this->limit >= $total) {
                break;
            }

            $jobs->push(new CardSyncJob($page, $this->limit, $maxId));

            $page++;
        }

        $total && CardSyncJob::withChain($jobs->toArray())
            ->dispatch(1, $this->limit, $maxId)
            ->allOnQueue('sync');

        $nextId && app(ConfigService::class)->set(self::CURSOR_KEY, $nextId);
    }
}