class OrgAggregateWorker
  include Sidekiq::Worker
  sidekiq_options :queue => :organisation_aggregate_data, :retry => 5, :backtrace => true

  def perform(st, ln_id, interval)
    puts "Aggregate data for Network[#{ln_id}]: #{st}"
    tz = $redis.hget("network:#{ln_id}", 'tz') 
    tz = tz.present? ? tz : LocationNetwork::DEFAULT_TIMEZONE
    st = Time.zone.parse(st).in_time_zone(tz)
    LnAggregateData.save_dynamic_data(st, ln_id, interval)  # aggregate data for 5 min
  end
end