You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
91 lines
3.3 KiB
91 lines
3.3 KiB
class SchoolCategory < ApplicationRecord
|
|
|
|
MIN_RESPONSE_COUNT = 10
|
|
|
|
belongs_to :school
|
|
belongs_to :category
|
|
|
|
has_many :school_questions
|
|
|
|
validates_associated :school
|
|
validates_associated :category
|
|
|
|
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("zscore is not null or valid_child_count is not null") }
|
|
|
|
def root_index
|
|
category.root_index
|
|
end
|
|
|
|
def answer_index_average
|
|
answer_index_total.to_f / response_count.to_f
|
|
end
|
|
|
|
def aggregated_responses
|
|
attempt_data = Attempt.
|
|
created_in(year).
|
|
for_category(category).
|
|
for_school(school).
|
|
select('count(attempts.id) as attempt_count').
|
|
select('count(attempts.answer_index) as response_count').
|
|
select('sum(case when questions.reverse then 6 - attempts.answer_index else attempts.answer_index end) as answer_index_total')[0]
|
|
|
|
return {
|
|
attempt_count: attempt_data.attempt_count || 0,
|
|
response_count: attempt_data.response_count || 0,
|
|
answer_index_total: attempt_data.answer_index_total || 0,
|
|
zscore: attempt_data.answer_index_total.nil? ?
|
|
(attempt_data.response_count > MIN_RESPONSE_COUNT ? zscore : nil) :
|
|
(attempt_data.response_count > MIN_RESPONSE_COUNT ?
|
|
(attempt_data.answer_index_total.to_f / attempt_data.response_count.to_f - 3.to_f) :
|
|
nil)
|
|
}
|
|
end
|
|
|
|
def chained_aggregated_responses
|
|
_aggregated_responses = aggregated_responses
|
|
|
|
child_school_categories = category.child_categories.collect do |cc|
|
|
SchoolCategory.for(school, cc).in(year).valid
|
|
end.flatten.compact
|
|
|
|
return {} if child_school_categories.blank?
|
|
|
|
average_zscore = nil
|
|
zscore_categories = child_school_categories.select { |csc| csc.zscore.present? && !csc.zscore.nan? }
|
|
if zscore_categories.length > 0
|
|
total_zscore = zscore_categories.inject(0) { |total, zc| total + zc.zscore }
|
|
average_zscore = total_zscore / zscore_categories.length
|
|
end
|
|
|
|
return {
|
|
attempt_count:
|
|
_aggregated_responses[:attempt_count] +
|
|
child_school_categories.inject(0) { |total, csc| total + (csc.attempt_count || 0) },
|
|
response_count:
|
|
_aggregated_responses[:response_count] +
|
|
child_school_categories.inject(0) { |total, csc| total + (csc.response_count || 0) },
|
|
answer_index_total:
|
|
_aggregated_responses[:answer_index_total] +
|
|
child_school_categories.inject(0) { |total, csc| total + (csc.answer_index_total || 0) },
|
|
zscore: average_zscore.present? ? average_zscore : _aggregated_responses[:zscore]
|
|
}
|
|
end
|
|
|
|
def sync_aggregated_responses
|
|
return if ENV['BULK_PROCESS']
|
|
update_attributes(chained_aggregated_responses)
|
|
return if response_count == 0 && zscore.nil?
|
|
if category.parent_category.present?
|
|
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, year: year)
|
|
end
|
|
parent_school_category.sync_aggregated_responses
|
|
end
|
|
end
|
|
end
|