gabehf/sqm-dashboards
1
0
Fork 0
mirror of https://github.com/edcommonwealth/sqm-dashboards.git synced 2026-03-07 21:48:16 -08:00
Code Issues Projects Releases Packages Wiki Activity Actions

updating for 2018 data

Browse source
This commit is contained in:
Jared Cosulich 2018-07-20 09:50:40 -04:00
parent c6b10291fd
commit 9d81c39f54
8 changed files with 128 additions and 34 deletions
Download patch file Download diff file Expand all files Collapse all files

1
app/models/attempt.rb
View file

@ -20,6 +20,7 @@ class Attempt < ApplicationRecord
scope :with_no_answer, -> { where('answer_index is null and open_response_id is null')}
scope :not_yet_responded, -> { where(responded_at: nil) }
scope :last_sent, -> { order(sent_at: :desc) }
scope :created_in, -> (year) { where('extract(year from attempts.created_at) = ?', year) }
def messages
child_specific = student.present? ? " (for #{student.name})" : ''

18
app/models/school_category.rb
View file

@ -10,6 +10,7 @@ class SchoolCategory < ApplicationRecord
scope :for, -> (school, category) { where(school: school).where(category: category) }
scope :for_parent_category, -> (school, category=nil) { where(school: school).joins(:category).merge(Category.for_parent(category)) }
scope :in, -> (year) { where(year: year) }
scope :valid, -> { where("response_count > #{MIN_RESPONSE_COUNT} or zscore is not null") }
@ -17,8 +18,9 @@ class SchoolCategory < ApplicationRecord
answer_index_total.to_f / response_count.to_f
end
def aggregated_responses
def aggregated_responses(year)
attempt_data = Attempt.
created_in(year).
for_category(category).
for_school(school).
select('count(attempts.id) as attempt_count').
@ -37,8 +39,8 @@ class SchoolCategory < ApplicationRecord
}
end
def chained_aggregated_responses
_aggregated_responses = aggregated_responses
def chained_aggregated_responses(year)
_aggregated_responses = aggregated_responses(year)
child_school_categories = category.child_categories.collect do |cc|
SchoolCategory.for(school, cc).valid
@ -65,15 +67,15 @@ class SchoolCategory < ApplicationRecord
}
end
def sync_aggregated_responses
def sync_aggregated_responses(year)
return if ENV['BULK_PROCESS']
update_attributes(chained_aggregated_responses)
update_attributes(chained_aggregated_responses(year))
if category.parent_category.present?
parent_school_category = SchoolCategory.for(school, category.parent_category).first
parent_school_category = SchoolCategory.for(school, category.parent_category).in(year).first
if parent_school_category.nil?
parent_school_category = SchoolCategory.create(school: school, category: category.parent_category)
parent_school_category = SchoolCategory.create(school: school, category: category.parent_category, year: year)
end
parent_school_category.sync_aggregated_responses
parent_school_category.sync_aggregated_responses(year)
end
end
end