ReportGetDocument.php

<?php

declare(strict_types=1);
/**
 *
 * @author   xiaoguo0426
 * @contact  740644717@qq.com
 * @license  MIT
 */

namespace App\Command\Amazon\Report;

use App\Queue\AmazonGetReportDocumentQueue;
use Hyperf\Command\Annotation\Command;
use Hyperf\Command\Command as HyperfCommand;
use Psr\Container\ContainerExceptionInterface;
use Psr\Container\ContainerInterface;
use Psr\Container\NotFoundExceptionInterface;

#[Command]
class ReportGetDocument extends HyperfCommand
{
    public function __construct(protected ContainerInterface $container)
    {
        parent::__construct('amazon:report:gets-document');
    }

    public function configure(): void
    {
        parent::configure();
        $this->setDescription('Amazon Gets Report Document Command');
    }

    /**
     * @throws \JsonException
     * @return void
     */
    public function handle(): void
    {

//        (new AmazonGetReportDocumentQueue())->pop();//单个请求拉取报告
        (new AmazonGetReportDocumentQueue())->coPop(30);//并行请求的数量
    }
}