| 1234567891011121314151617181920212223242526272829303132 |
- <?php
- namespace App\Console\Commands;
- use App\Services\Simulation\SimulationRunner;
- use App\Services\Simulation\SimulationSettings;
- use App\Support\MemberAudience;
- use App\Support\SyncCommandLock;
- use Illuminate\Console\Command;
- use Illuminate\Support\Facades\Schema;
- class SimulationRun extends Command
- {
- protected $signature = 'simulation:run {--once : 只推进一次(调试用)}';
- protected $description = '模拟管理:推进自动任务。每分钟由调度启动,进程内每 2 秒推进一次,约 55 秒后退出';
- public function handle(SyncCommandLock $lock): int
- {
- if (!MemberAudience::enabled() || !Schema::hasTable('simulation_task_runs') || !SimulationSettings::enabled()) return self::SUCCESS;
- $lock->run('simulation:run', function () {
- $deadline = microtime(true) + 55;
- do {
- $done = SimulationRunner::tick();
- if ($this->option('once')) { $this->info("执行了 {$done} 个动作"); break; }
- sleep(2);
- } while (microtime(true) < $deadline);
- return 0;
- });
- return self::SUCCESS;
- }
- }
|