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.
81 lines
3.1 KiB
81 lines
3.1 KiB
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|
|
|
scales.each do |scale|
|
|
respondents = Respondent.by_school_and_year(school:, academic_year:)
|
|
next if respondents.nil?
|
|
|
|
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
|
|
|
|
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}"
|
|
|
|
row = [response_rate, scale, school, academic_year]
|
|
|
|
all_grades = respondents.enrollment_by_grade.keys
|
|
grades = "#{all_grades.first}-#{all_grades.last}"
|
|
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
|