Split detail page contracts
This commit is contained in:
73
lib/Console/Commands/Scheduler/RunCommand.php
Normal file
73
lib/Console/Commands/Scheduler/RunCommand.php
Normal file
@@ -0,0 +1,73 @@
|
||||
<?php
|
||||
|
||||
namespace MintyPHP\Console\Commands\Scheduler;
|
||||
|
||||
use MintyPHP\Console\Command;
|
||||
use MintyPHP\DB;
|
||||
use MintyPHP\Service\Audit\SystemAuditService;
|
||||
use MintyPHP\Service\Scheduler\SchedulerServicesFactory;
|
||||
|
||||
final class RunCommand extends Command
|
||||
{
|
||||
public function name(): string
|
||||
{
|
||||
return 'scheduler:run';
|
||||
}
|
||||
|
||||
public function description(): string
|
||||
{
|
||||
return 'Execute due scheduled jobs';
|
||||
}
|
||||
|
||||
public function execute(array $args, array $options): int
|
||||
{
|
||||
require_once __DIR__ . '/../../../../bin/cli-bootstrap.php';
|
||||
|
||||
$exitCode = 0;
|
||||
$startedAt = microtime(true);
|
||||
try {
|
||||
cliBootstrapApp('scheduler', 'bin/console scheduler:run');
|
||||
$factory = app(SchedulerServicesFactory::class);
|
||||
$result = $factory->createSchedulerRunService()->runDueJobs();
|
||||
if (!($result['ok'] ?? false)) {
|
||||
$error = (string) ($result['error'] ?? 'unexpected_error');
|
||||
fwrite(STDERR, sprintf("scheduler run failed: %s\n", $error));
|
||||
$exitCode = 1;
|
||||
} else {
|
||||
fwrite(STDOUT, sprintf(
|
||||
"scheduler completed: processed=%d success=%d failed=%d skipped=%d duration_ms=%d\n",
|
||||
(int) ($result['processed'] ?? 0),
|
||||
(int) ($result['success'] ?? 0),
|
||||
(int) ($result['failed'] ?? 0),
|
||||
(int) ($result['skipped'] ?? 0),
|
||||
(int) ($result['duration_ms'] ?? 0)
|
||||
));
|
||||
}
|
||||
} catch (\Throwable $exception) {
|
||||
try {
|
||||
app(SystemAuditService::class)->record('scheduler.run', 'failed', [
|
||||
'error_code' => 'unexpected_error',
|
||||
'metadata' => [
|
||||
'trigger_type' => 'scheduler',
|
||||
'run_status' => 'failed',
|
||||
'processed' => 0,
|
||||
'success_count' => 0,
|
||||
'failed_count' => 0,
|
||||
'skipped_count' => 0,
|
||||
'duration_ms' => max(0, (int) round((microtime(true) - $startedAt) * 1000)),
|
||||
'bootstrap_error' => true,
|
||||
],
|
||||
]);
|
||||
} catch (\Throwable) {
|
||||
// fail-open
|
||||
}
|
||||
|
||||
fwrite(STDERR, sprintf("scheduler run failed: unexpected_error: %s\n", $exception->getMessage()));
|
||||
$exitCode = 1;
|
||||
} finally {
|
||||
DB::close();
|
||||
}
|
||||
|
||||
return $exitCode;
|
||||
}
|
||||
}
|
||||
Reference in New Issue
Block a user