관리-도구

편집 파일: ScheduleWorkCommand.php

<?php

namespace Illuminate\Console\Scheduling;

use Illuminate\Console\Command;
use Illuminate\Support\Carbon;
use Symfony\Component\Process\Process;

class ScheduleWorkCommand extends Command
{
    /**
     * The console command name.
     *
     * @var string
     */
    protected $name = 'schedule:work';

/**
     * The console command description.
     *
     * @var string
     */
    protected $description = 'Start the schedule worker';

/**
     * Execute the console command.
     *
     * @return void
     */
    public function handle()
    {
        $this->info('Schedule worker started successfully.');

[$lastExecutionStartedAt, $keyOfLastExecutionWithOutput, $executions] = [null, null, []];

while (true) {
            usleep(100 * 1000);

if (Carbon::now()->second === 0 &&
                ! Carbon::now()->startOfMinute()->equalTo($lastExecutionStartedAt)) {
                $executions[] = $execution = new Process([PHP_BINARY, 'artisan', 'schedule:run']);

$execution->start();

$lastExecutionStartedAt = Carbon::now()->startOfMinute();
            }

foreach ($executions as $key => $execution) {
                $output = trim($execution->getIncrementalOutput()).
                          trim($execution->getIncrementalErrorOutput());

if (! empty($output)) {
                    if ($key !== $keyOfLastExecutionWithOutput) {
                        $this->info(PHP_EOL.'['.date('c').'] Execution #'.($key + 1).' output:');

$keyOfLastExecutionWithOutput = $key;
                    }

$this->output->writeln($output);
                }

if (! $execution->isRunning()) {
                    unset($executions[$key]);
                }
            }
        }
    }
}