interview-demo-code/backend/src/console/Commands/ScheduleRunCommand.php

<?php

namespace Console\Commands;

use Carbon\Carbon;
use Acme\ECommerceFramework\Config\Settings;
use Acme\ECommerceFramework\Scheduler\SchedulerService;
use Symfony\Component\Console\Command\Command;
use Symfony\Component\Console\Input\InputInterface;
use Symfony\Component\Console\Input\InputOption;
use Symfony\Component\Console\Output\OutputInterface;

class ScheduleRunCommand extends AcmeShopCommand
{
    private SchedulerService $scheduler;
    private Settings $settings;

    protected static $defaultName = 'schedule:run';
    protected static $defaultDescription = 'Run scheduled commands';

    public function __construct(SchedulerService $scheduler, Settings $settings)
    {
        parent::__construct();
        $this->scheduler = $scheduler;
        $this->settings = $settings;
    }

    protected function configure(): void
    {
        $this->addOption(
            'ignore-global-lock',
            null,
            InputOption::VALUE_NONE,
            'Ignore global scheduler lock (e.g. when running multiple cron instances)'
        );
    }

    protected function execute(InputInterface $input, OutputInterface $output): int
    {
        $mode = $this->settings->get('cron.mode', 'disabled');
        if ($mode !== 'system') {
            $output->writeln('<comment>Scheduler not in CRON mode. Skipping CLI execution.</comment>');

            return Command::SUCCESS;
        }

        $output->writeln(
            sprintf(
                '[%s] <info>AcmeShop Scheduler Running...</info>',
                Carbon::now()->toJSON(),
            )
        );

        $ignoreGlobalLock = (bool) $input->getOption('ignore-global-lock');
        $result = $this->scheduler->run($ignoreGlobalLock);

        // Print Executed
        if (empty($result->executed)) {
            $output->writeln('No tasks executed.');
        } else {
            foreach ($result->executed as $item) {
                $output->writeln(sprintf('<info>Executed:</info> %s (%.4fs)', $item['name'], $item['duration']));
            }
        }

        // Print Failed
        foreach ($result->failed as $item) {
            $output->writeln(sprintf('<error>Failed:</error> %s - %s', $item['name'], $item['error']));
        }

        // Print Skipped (verbose only)
        if ($output->isVerbose()) {
            foreach ($result->skipped as $item) {
                $output->writeln(sprintf('<comment>Skipped:</comment> %s - %s', $item['name'], $item['reason']));
            }
        }

        return Command::SUCCESS;
    }
}