480e7eafbd
📋 Commit iniziale con: - ✅ Documentazione unificata in docs/ - ✅ Codice Laravel in netgescon-laravel/ - ✅ Script automazione in scripts/ - ✅ Configurazione sync rsync - ✅ Struttura organizzata e pulita 🔄 Versione: 2025.07.19-1644 🎯 Sistema pronto per Git distribuito
75 lines
2.2 KiB
PHP
75 lines
2.2 KiB
PHP
<?php
|
|
|
|
namespace Illuminate\Console\Scheduling;
|
|
|
|
use Illuminate\Console\Application;
|
|
use Illuminate\Console\Command;
|
|
use Illuminate\Support\Carbon;
|
|
use Illuminate\Support\ProcessUtils;
|
|
use Symfony\Component\Console\Attribute\AsCommand;
|
|
use Symfony\Component\Console\Output\OutputInterface;
|
|
use Symfony\Component\Process\Process;
|
|
|
|
#[AsCommand(name: 'schedule:work')]
|
|
class ScheduleWorkCommand extends Command
|
|
{
|
|
/**
|
|
* The name and signature of the console command.
|
|
*
|
|
* @var string
|
|
*/
|
|
protected $signature = 'schedule:work {--run-output-file= : The file to direct <info>schedule:run</info> output to}';
|
|
|
|
/**
|
|
* The console command description.
|
|
*
|
|
* @var string
|
|
*/
|
|
protected $description = 'Start the schedule worker';
|
|
|
|
/**
|
|
* Execute the console command.
|
|
*
|
|
* @return never
|
|
*/
|
|
public function handle()
|
|
{
|
|
$this->components->info(
|
|
'Running scheduled tasks.',
|
|
$this->getLaravel()->environment('local') ? OutputInterface::VERBOSITY_NORMAL : OutputInterface::VERBOSITY_VERBOSE
|
|
);
|
|
|
|
[$lastExecutionStartedAt, $executions] = [Carbon::now()->subMinutes(10), []];
|
|
|
|
$command = Application::formatCommandString('schedule:run');
|
|
|
|
if ($this->option('run-output-file')) {
|
|
$command .= ' >> '.ProcessUtils::escapeArgument($this->option('run-output-file')).' 2>&1';
|
|
}
|
|
|
|
while (true) {
|
|
usleep(100 * 1000);
|
|
|
|
if (Carbon::now()->second === 0 &&
|
|
! Carbon::now()->startOfMinute()->equalTo($lastExecutionStartedAt)) {
|
|
$executions[] = $execution = Process::fromShellCommandline($command);
|
|
|
|
$execution->start();
|
|
|
|
$lastExecutionStartedAt = Carbon::now()->startOfMinute();
|
|
}
|
|
|
|
foreach ($executions as $key => $execution) {
|
|
$output = $execution->getIncrementalOutput().
|
|
$execution->getIncrementalErrorOutput();
|
|
|
|
$this->output->write(ltrim($output, "\n"));
|
|
|
|
if (! $execution->isRunning()) {
|
|
unset($executions[$key]);
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|