FinishScheduleJob.php 2.4 KB

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