Class: ScheduleWorkers::SendUpdateTotalCoversEventWorker

Inherits:
ApplicationWorker show all
Defined in:
app/workers/schedule_workers/send_update_total_covers_event_worker.rb

Overview

send update total covers event to kafka

Instance Method Summary collapse

Methods inherited from ApplicationWorker

unlimited_retry

Instance Method Details

#perform ⇒ Object 



5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
 
# File 'app/workers/schedule_workers/send_update_total_covers_event_worker.rb', line 5

def perform
  current_time_in_bangkok = Time.use_zone('Asia/Bangkok') { Time.zone.now }

  start_date = current_time_in_bangkok.beginning_of_day
  end_date = current_time_in_bangkok.end_of_day

  HhClickHouseRestaurant.joins(:reservations).
    where('reservations.created_at BETWEEN ? AND ?', start_date, end_date).
    group('restaurants.id').pluck(:id).each do |id|
    # send event to kafka
    send_event(id)
  end
rescue StandardError => e
  APMErrorHandler.report e
  raise e
end