SimulationRun.php 1.1 KB

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