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.
57 lines
2.6 KiB
57 lines
2.6 KiB
module Imports |
|
class ImportReportService |
|
def initialize(storage_service, institutions_csv, logger = Rails.logger) |
|
@storage_service = storage_service |
|
@logger = logger |
|
@institutions_csv = institutions_csv |
|
end |
|
|
|
BYTE_ORDER_MARK = "\uFEFF".freeze # Required to ensure Excel always reads CSV as UTF-8 |
|
|
|
def create_reports(report_suffix) |
|
generate_missing_data_coordinators_report(report_suffix) |
|
generate_logs_report(report_suffix) |
|
end |
|
|
|
def generate_missing_data_coordinators_report(report_suffix) |
|
report_csv = "Organisation ID,Old Organisation ID,Organisation Name\n" |
|
organisations = @institutions_csv.map { |row| Organisation.find_by(name: row[0]) }.compact |
|
organisations.each do |organisation| |
|
if organisation.users.none? { |user| user.data_coordinator? && user.active? } |
|
report_csv += "#{organisation.id},#{organisation.old_visible_id},#{organisation.name}\n" |
|
end |
|
end |
|
|
|
report_name = "OrganisationsWithoutDataCoordinators_#{report_suffix}" |
|
@storage_service.write_file(report_name, BYTE_ORDER_MARK + report_csv) |
|
|
|
@logger.info("Missing data coordinators report available in s3 import bucket at #{report_name}") |
|
end |
|
|
|
def generate_logs_report(report_suffix) |
|
Rails.logger.info("Generating migrated logs report") |
|
|
|
rep = CSV.generate do |report| |
|
headers = ["Institution name", "Id", "Old Completed lettings logs", "Old In progress lettings logs", "Old Completed sales logs", "Old In progress sales logs", "New Completed lettings logs", "New In Progress lettings logs", "New Completed sales logs", "New In Progress sales logs"] |
|
report << headers |
|
|
|
@institutions_csv.each do |row| |
|
name = row[0] |
|
organisation = Organisation.find_by(name:) |
|
next unless organisation |
|
|
|
completed_sales_logs = organisation.owned_sales_logs.where(status: "completed").count |
|
in_progress_sales_logs = organisation.owned_sales_logs.where(status: "in_progress").count |
|
completed_lettings_logs = organisation.owned_lettings_logs.where(status: "completed").count |
|
in_progress_lettings_logs = organisation.owned_lettings_logs.where(status: "in_progress").count |
|
report << row.push(completed_lettings_logs, in_progress_lettings_logs, completed_sales_logs, in_progress_sales_logs) |
|
end |
|
end |
|
|
|
report_name = "MigratedLogsReport_#{report_suffix}" |
|
@storage_service.write_file(report_name, BYTE_ORDER_MARK + rep) |
|
|
|
@logger.info("Logs report available in s3 import bucket at #{report_name}") |
|
end |
|
end |
|
end
|
|
|