FinishScheduleJob.php 2.1 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768
  1. <?php
  2. namespace App\Jobs;
  3. use App\Models\Schedule;
  4. use Carbon\Carbon;
  5. use Illuminate\Bus\Queueable;
  6. use Illuminate\Contracts\Queue\ShouldQueue;
  7. use Illuminate\Foundation\Bus\Dispatchable;
  8. use Illuminate\Queue\InteractsWithQueue;
  9. use Illuminate\Queue\SerializesModels;
  10. use Illuminate\Support\Facades\Log;
  11. class FinishScheduleJob implements ShouldQueue
  12. {
  13. use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;
  14. public function __construct(
  15. public int $scheduleId
  16. ) {}
  17. public function handle()
  18. {
  19. try {
  20. $schedule = Schedule::find($this->scheduleId);
  21. $date_cleaned = Carbon::parse($schedule->date)->format('Y-m-d');
  22. if (!$schedule) {
  23. return;
  24. }
  25. Log::channel('schedule_end_jobs')->info('Verificando status do agendamento id: ' . $schedule->id);
  26. Log::channel('schedule_end_jobs')->info('Status do agendamento: ' . $schedule->status);
  27. if ($schedule->status !== 'started') {
  28. return;
  29. }
  30. Log::channel('schedule_end_jobs')->info('Verificando data');
  31. Log::channel('schedule_end_jobs')->info('Data do agendamento: ' . $date_cleaned);
  32. Log::channel('schedule_end_jobs')->info('Data atual: ' . now()->toDateString());
  33. if ($date_cleaned > now()->toDateString()) {
  34. return;
  35. }
  36. Log::channel('schedule_end_jobs')->info('Verificando horário');
  37. Log::channel('schedule_end_jobs')->info('Horário do agendamento: ' . $schedule->end_time);
  38. Log::channel('schedule_end_jobs')->info('Horário atual: ' . now()->toTimeString());
  39. $end_date_time = Carbon::parse($date_cleaned . ' ' . $schedule->end_time);
  40. if ($end_date_time > now()) {
  41. return;
  42. }
  43. Log::channel('schedule_end_jobs')->info('Validado com sucesso, atualizado agendamento id: ' . $schedule->id . ' para status finalizado');
  44. $schedule->update([
  45. 'status' => 'finished'
  46. ]);
  47. } catch (\Exception $e) {
  48. Log::channel('schedule_end_jobs')->error('Erro ao finalizar agendamento id: ' . $this->scheduleId . '. Erro: ' . $e->getMessage());
  49. return;
  50. }
  51. }
  52. }