Файл: vendor/laravel/framework/src/Illuminate/Console/Scheduling/ScheduleListCommand.php
Строк: 673
<?php
namespace IlluminateConsoleScheduling;
use Closure;
use CronCronExpression;
use DateTimeZone;
use IlluminateConsoleCommand;
use IlluminateSupportArr;
use IlluminateSupportCarbon;
use IlluminateSupportCollection;
use ReflectionClass;
use ReflectionFunction;
use SymfonyComponentConsoleAttributeAsCommand;
use SymfonyComponentConsoleTerminal;
#[AsCommand(name: 'schedule:list')]
class ScheduleListCommand extends Command
{
/**
* The console command name.
*
* @var string
*/
protected $signature = 'schedule:list
{--timezone= : The timezone that times should be displayed in}
{--environment=* : Display the tasks scheduled to run on this environment}
{--next : Sort the listed tasks by their next due date}
{--json : Output the scheduled tasks as JSON}
';
/**
* The console command description.
*
* @var string
*/
protected $description = 'List all scheduled tasks';
/**
* The terminal width resolver callback.
*
* @var Closure|null
*/
protected static $terminalWidthResolver;
/**
* Execute the console command.
*
* @param IlluminateConsoleSchedulingSchedule $schedule
* @return void
*
* @throws Exception
*/
public function handle(Schedule $schedule)
{
$environments = Arr::wrap($this->option('environment'));
$events = new Collection(
empty($environments)
? $schedule->events()
: $schedule->eventsForEnvironments($environments)
);
if ($events->isEmpty()) {
if ($this->option('json')) {
$this->output->writeln('[]');
} else {
$this->components->info('No scheduled tasks have been defined.');
}
return;
}
$timezone = new DateTimeZone($this->option('timezone') ?? config('app.timezone'));
$events = $this->sortEvents($events, $timezone);
$this->display($events, $timezone);
}
/**
* Render the scheduled tasks information as JSON.
*
* @param IlluminateSupportCollection $events
* @param DateTimeZone $timezone
* @return void
*/
protected function displayJson(Collection $events, DateTimeZone $timezone)
{
$this->output->writeln($events->flatMap(function ($event) use ($timezone) {
$nextDueDate = $this->getNextDueDateForEvent($event, $timezone);
$command = $event->command ?? '';
if (! $this->output->isVerbose()) {
$command = $event->normalizeCommand($command);
}
if ($event instanceof CallbackEvent) {
$command = $event->getSummaryForDisplay();
if (in_array($command, ['Closure', 'Callback'])) {
$command = 'Closure at: '.$this->getClosureLocation($event);
}
}
return (new Collection(CronExpressionTimezoneConverter::forEvent($event, $timezone)))->map(fn ($expression) => [
'expression' => $expression,
'command' => $command,
'description' => $event->description ?? null,
'next_due_date' => $nextDueDate->format('Y-m-d H:i:s P'),
'next_due_date_human' => $nextDueDate->diffForHumans(),
'timezone' => $timezone->getName(),
'has_mutex' => $event->mutex->exists($event),
'repeat_seconds' => $event->isRepeatable() ? $event->repeatSeconds : null,
'environments' => $event->environments,
]);
})->values()->toJson());
}
/**
* Render the scheduled tasks information formatted for the CLI.
*
* @param IlluminateSupportCollection $events
* @param DateTimeZone $timezone
* @return void
*/
protected function displayForCli(Collection $events, DateTimeZone $timezone)
{
$terminalWidth = self::getTerminalWidth();
$expressionSpacing = $this->getCronExpressionSpacing($events, $timezone);
$repeatExpressionSpacing = $this->getRepeatExpressionSpacing($events);
$events = $events->flatMap(function ($event) use ($terminalWidth, $expressionSpacing, $repeatExpressionSpacing, $timezone) {
return (new Collection(CronExpressionTimezoneConverter::forEvent($event, $timezone)))->map(
fn ($expression) => $this->listEvent($event, $terminalWidth, $expressionSpacing, $repeatExpressionSpacing, $timezone, $expression),
);
});
$this->line(
$events->flatten()->filter()->prepend('')->push('')->toArray(),
);
}
/**
* Get the spacing to be used on each event row.
*
* @param IlluminateSupportCollection $events
* @return array<int, int>
*/
private function getCronExpressionSpacing($events, DateTimeZone $timezone)
{
$rows = $events->flatMap(fn ($event) => (new Collection(CronExpressionTimezoneConverter::forEvent($event, $timezone)))
->map(fn ($expression) => array_map(mb_strlen(...), preg_split("/s+/", $expression))));
return (new Collection($rows[0] ?? []))->keys()->map(fn ($key) => $rows->max($key))->all();
}
/**
* Get the spacing to be used on each event row.
*
* @param IlluminateSupportCollection $events
* @return int
*/
private function getRepeatExpressionSpacing($events)
{
return $events->map(fn ($event) => mb_strlen($this->getRepeatExpression($event)))->max();
}
/**
* List the given even in the console.
*
* @param IlluminateConsoleSchedulingEvent $event
* @param int $terminalWidth
* @param array $expressionSpacing
* @param int $repeatExpressionSpacing
* @param DateTimeZone $timezone
* @param string|null $convertedExpression
* @return array
*/
private function listEvent($event, $terminalWidth, $expressionSpacing, $repeatExpressionSpacing, $timezone, $convertedExpression = null)
{
$expression = $this->formatCronExpression($convertedExpression ?? $event->expression, $expressionSpacing);
$repeatExpression = str_pad($this->getRepeatExpression($event), $repeatExpressionSpacing);
$command = $event->command ?? '';
$description = $event->description ?? '';
if (! $this->output->isVerbose()) {
$command = $event->normalizeCommand($command);
}
if ($event instanceof CallbackEvent) {
$command = $event->getSummaryForDisplay();
if (in_array($command, ['Closure', 'Callback'])) {
$command = 'Closure at: '.$this->getClosureLocation($event);
}
}
$command = mb_strlen($command) > 1 ? "{$command} " : '';
$nextDueDateLabel = 'Next Due:';
$nextDueDate = $this->getNextDueDateForEvent($event, $timezone);
$nextDueDate = $this->output->isVerbose()
? $nextDueDate->format('Y-m-d H:i:s P')
: $nextDueDate->diffForHumans();
$hasMutex = $event->mutex->exists($event) ? 'Has Mutex › ' : '';
$dots = str_repeat('.', max(
$terminalWidth - mb_strwidth($expression.$repeatExpression.$command.$nextDueDateLabel.$nextDueDate.$hasMutex) - 8, 0,
));
// Highlight the parameters...
$command = preg_replace("#(php artisan [w-:]+) (.+)#", '$1 <fg=yellow;options=bold>$2</>', $command);
return [sprintf(
' <fg=yellow>%s</> <fg=#6C7280>%s</> %s<fg=#6C7280>%s %s%s %s</>',
$expression,
$repeatExpression,
$command,
$dots,
$hasMutex,
$nextDueDateLabel,
$nextDueDate,
), $this->output->isVerbose() && mb_strlen($description) > 1 ? sprintf(
' <fg=#6C7280>%s%s %s</>',
str_repeat(' ', mb_strlen($expression) + 2),
'⇁',
$description,
) : ''];
}
/**
* Get the repeat expression for an event.
*
* @param IlluminateConsoleSchedulingEvent $event
* @return string
*/
private function getRepeatExpression($event)
{
return $event->isRepeatable() ? "{$event->repeatSeconds}s " : '';
}
/**
* Sort the events by due date if option set.
*
* @param IlluminateSupportCollection $events
* @param DateTimeZone $timezone
* @return IlluminateSupportCollection
*/
private function sortEvents(IlluminateSupportCollection $events, DateTimeZone $timezone)
{
return $this->option('next')
? $events->sortBy(fn ($event) => $this->getNextDueDateForEvent($event, $timezone))
: $events;
}
/**
* Render the scheduled tasks information.
*
* @param IlluminateSupportCollection $events
* @param DateTimeZone $timezone
* @return void
*/
protected function display(Collection $events, DateTimeZone $timezone)
{
$this->option('json') ? $this->displayJson($events, $timezone) : $this->displayForCli($events, $timezone);
}
/**
* Get the next due date for an event.
*
* @param IlluminateConsoleSchedulingEvent $event
* @param DateTimeZone $timezone
* @return IlluminateSupportCarbon
*/
private function getNextDueDateForEvent($event, DateTimeZone $timezone)
{
$nextDueDate = Carbon::instance(
(new CronExpression($event->expression))
->getNextRunDate(Carbon::now()->setTimezone($event->timezone))
->setTimezone($timezone),
);
if (! $event->isRepeatable()) {
return $nextDueDate;
}
$previousDueDate = Carbon::instance(
(new CronExpression($event->expression))
->getPreviousRunDate(Carbon::now()->setTimezone($event->timezone), allowCurrentDate: true)
->setTimezone($timezone),
);
$now = Carbon::now()->setTimezone($event->timezone);
if (! $now->copy()->startOfMinute()->eq($previousDueDate)) {
return $nextDueDate;
}
return $now
->endOfSecond()
->ceilSeconds($event->repeatSeconds);
}
/**
* Format the cron expression based on the spacing provided.
*
* @param string $expression
* @param array<int, int> $spacing
* @return string
*/
private function formatCronExpression($expression, $spacing)
{
$expressions = preg_split("/s+/", $expression);
return (new Collection($spacing))
->map(fn ($length, $index) => str_pad($expressions[$index], $length))
->implode(' ');
}
/**
* Get the file and line number for the event closure.
*
* @param IlluminateConsoleSchedulingCallbackEvent $event
* @return string
*/
private function getClosureLocation(CallbackEvent $event)
{
$callback = (new ReflectionClass($event))->getProperty('callback')->getValue($event);
if ($callback instanceof Closure) {
$function = new ReflectionFunction($callback);
return sprintf(
'%s:%s',
str_replace($this->laravel->basePath().DIRECTORY_SEPARATOR, '', $function->getFileName() ?: ''),
$function->getStartLine(),
);
}
if (is_string($callback)) {
return $callback;
}
if (is_array($callback)) {
$className = is_string($callback[0]) ? $callback[0] : $callback[0]::class;
return sprintf('%s::%s', $className, $callback[1]);
}
return sprintf('%s::__invoke', $callback::class);
}
/**
* Get the terminal width.
*
* @return int
*/
public static function getTerminalWidth()
{
return is_null(static::$terminalWidthResolver)
? (new Terminal)->getWidth()
: call_user_func(static::$terminalWidthResolver);
}
/**
* Set a callback that should be used when resolving the terminal width.
*
* @param Closure|null $resolver
* @return void
*/
public static function resolveTerminalWidthUsing($resolver)
{
static::$terminalWidthResolver = $resolver;
}
}