mirror of
https://github.com/edcommonwealth/sqm-dashboards.git
synced 2026-03-07 21:48:16 -08:00
058cbb0f6e
# Fixed reported grades
# Runs faster
"Measure - District only"
# Should only be run per district
# Runs faster
# Fixed reported grades
"Measure - School & District"
# Reports the grades that took the survey for that school+year; not the grades that responded to the measure
# Runs faster
# Fixed reported grades
"Beyond Learning Loss"
# Runs faster
"Beyond Learning Loss - Response Rate"
# Fixed reported grades
"Survey Item - By Item"
# may be able to speed it up by getting all averages in a single request
# Fixed reported grades
"Survey Item - By Grade"
# Fixed reported grades
#may be able to speed it up by getting all averages in a single request
"Survey Entries - by Measure"
# No changes
80 lines
3.1 KiB
Ruby
80 lines
3.1 KiB
Ruby
module Report
|
|
class BeyondLearningLoss
|
|
def self.create_report(schools: School.all.includes(:district), academic_years: AcademicYear.all, scales: ::Scale.all, filename: "bll_report.csv")
|
|
data = to_csv(schools:, academic_years:, scales:)
|
|
FileUtils.mkdir_p Rails.root.join("tmp", "reports")
|
|
filepath = Rails.root.join("tmp", "reports", filename)
|
|
write_csv(data:, filepath:)
|
|
data
|
|
end
|
|
|
|
def self.to_csv(schools:, academic_years:, scales:)
|
|
data = []
|
|
mutex = Thread::Mutex.new
|
|
data << ["District", "School", "School Code", "Academic Year", "Recorded Date Range", "Grades", "Measure", "Scale",
|
|
"All Score (Average)"]
|
|
pool_size = 2
|
|
jobs = Queue.new
|
|
schools.each { |school| jobs << school }
|
|
|
|
workers = pool_size.times.map do
|
|
Thread.new do
|
|
while school = jobs.pop(true)
|
|
academic_years.each do |academic_year|
|
|
respondents = Respondent.by_school_and_year(school:, academic_year:)
|
|
next if respondents.nil?
|
|
|
|
begin_date = ::SurveyItemResponse.where(school:,
|
|
academic_year:).where.not(recorded_date: nil).order(:recorded_date).first&.recorded_date&.to_date
|
|
end_date = ::SurveyItemResponse.where(school:,
|
|
academic_year:).where.not(recorded_date: nil).order(:recorded_date).last&.recorded_date&.to_date
|
|
date_range = "#{begin_date} - #{end_date}"
|
|
all_grades = Respondent.grades_that_responded_to_survey(academic_year:, school:)
|
|
grades = "#{all_grades.first}-#{all_grades.last}"
|
|
|
|
scales.each do |scale|
|
|
response_rate = scale.measure.subcategory.response_rate(school:, academic_year:)
|
|
next unless response_rate.meets_student_threshold? || response_rate.meets_teacher_threshold?
|
|
|
|
score = if scale.scale_id.starts_with?("a-")
|
|
AdminDataValue.where(admin_data_item: scale.admin_data_items, school:,
|
|
academic_year:).map do |item|
|
|
item.likert_score
|
|
end.average
|
|
else
|
|
scale.score(school:, academic_year:)
|
|
end
|
|
|
|
row = [response_rate, scale, school, academic_year]
|
|
|
|
mutex.synchronize do
|
|
data << [school.district.name,
|
|
school.name,
|
|
school.dese_id,
|
|
academic_year.range,
|
|
date_range,
|
|
grades,
|
|
scale.measure.measure_id,
|
|
scale.scale_id,
|
|
score]
|
|
end
|
|
end
|
|
end
|
|
end
|
|
rescue ThreadError
|
|
end
|
|
end
|
|
|
|
workers.each(&:join)
|
|
CSV.generate do |csv|
|
|
data.each do |row|
|
|
csv << row
|
|
end
|
|
end
|
|
end
|
|
|
|
def self.write_csv(data:, filepath:)
|
|
File.write(filepath, csv)
|
|
end
|
|
end
|
|
end
|