Skip to content

Instantly share code, notes, and snippets.

ls_arrival_ids = ReverseMigrator::Arrival::CsArrival.where(:arrival_id => cs_arrival_ids).select(:ls_arrival_id).map(&:ls_arrival_id)
grouped_lead_submissions = Persistent::LeadSubmission.where(:arrival_id => ls_arrival_ids, :school_id => school_id).group_by(&:school_id).each do |school_id, lead_submissions|
leads_per_hour = lead_submissions.size / 24
(0..23).each do |i|
leads = lead_submissions[(i*leads_per_hour)..((i+1)*leads_per_hour)]
leads.each_with_index do |ls,i|
Resque.enqueue_in(i.hours, whatever)
end
end
end
school_ids = [50,269,92,34,91,25,468,593,311,171,3,257,764,49,22,123]
ls_arrival_ids = ReverseMigrator::Arrival::CsArrival.where(:arrival_id => cs_arrival_ids).select(:ls_arrival_id).map(&:ls_arrival_id)
school_ids.each do |school_id|
lead_submissions = Persistent::LeadSubmission.where(:arrival_id => ls_arrival_ids, :school_id => school_id).select(:id).all
leads_per_hour = lead_submissions.size / 24
(0..23).each do |i|
leads = lead_submissions[(i*leads_per_hour)..(i+1*leads_per_hour)]
leads.each_with_index do |ls,i|
Resque.enqueue_in(i.hours, whatever)