class UplinkAggregateWorker
  include Sidekiq::Worker
  sidekiq_options :queue => :aggregate_data, :retry => 5, :backtrace => true

  def perform(st, ris, ln_id, hourly=true)
    puts "Uplink Aggregate data for Network[#{ln_id}]: #{st}"
    #Get Timezone from redis
    tz = $redis.hget("network:#{ln_id}", 'tz') || LocationNetwork::DEFAULT_TIMEZONE
    st = Time.zone.parse(st).in_time_zone(tz)
    UplinkAggregateData.save_hourly_data st, ris, ln_id, hourly
  end
end