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.
		
		
		
		
		
			
		
			
				
					
					
						
							98 lines
						
					
					
						
							3.0 KiB
						
					
					
				
			
		
		
	
	
							98 lines
						
					
					
						
							3.0 KiB
						
					
					
				module Exports | 
						|
  class CaseLogExportService | 
						|
    def initialize(storage_service, logger = Rails.logger) | 
						|
      @storage_service = storage_service | 
						|
      @logger = logger | 
						|
    end | 
						|
 | 
						|
    def export_case_logs | 
						|
      case_logs = retrieve_case_logs | 
						|
      export = save_export_run | 
						|
      write_master_manifest(export) | 
						|
      write_export_data(case_logs) | 
						|
    end | 
						|
 | 
						|
    def is_omitted_field?(field_name) | 
						|
      omitted_attrs = %w[ethnic_group] | 
						|
      pattern_age = /age\d_known/ | 
						|
      field_name.starts_with?("details_known_") || pattern_age.match(field_name) || omitted_attrs.include?(field_name) ? true : false | 
						|
    end | 
						|
 | 
						|
  private | 
						|
 | 
						|
    def save_export_run | 
						|
      today = Time.zone.today | 
						|
      last_daily_run_number = LogsExport.where(created_at: today.beginning_of_day..today.end_of_day).maximum(:daily_run_number) | 
						|
      last_daily_run_number = 0 if last_daily_run_number.nil? | 
						|
 | 
						|
      export = LogsExport.new | 
						|
      export.daily_run_number = last_daily_run_number + 1 | 
						|
      export.save! | 
						|
      export | 
						|
    end | 
						|
 | 
						|
    def write_master_manifest(export) | 
						|
      today = Time.zone.today | 
						|
      increment_number = export.daily_run_number.to_s.rjust(4, "0") | 
						|
      month = today.month.to_s.rjust(2, "0") | 
						|
      day = today.day.to_s.rjust(2, "0") | 
						|
      file_path = "Manifest_#{today.year}_#{month}_#{day}_#{increment_number}.csv" | 
						|
      string_io = build_manifest_csv_io | 
						|
      @storage_service.write_file(file_path, string_io) | 
						|
    end | 
						|
 | 
						|
    def write_export_data(case_logs) | 
						|
      string_io = build_export_xml_io(case_logs) | 
						|
      file_path = "#{get_folder_name}/#{get_file_name}.xml" | 
						|
      @storage_service.write_file(file_path, string_io) | 
						|
    end | 
						|
 | 
						|
    def retrieve_case_logs | 
						|
      params = { from: Time.current.beginning_of_day, to: Time.current, status: CaseLog.statuses[:completed] } | 
						|
      CaseLog.where("updated_at >= :from and updated_at <= :to and status = :status", params) | 
						|
    end | 
						|
 | 
						|
    def build_manifest_csv_io | 
						|
      headers = ["zip-name", "date-time zipped folder generated", "zip-file-uri"] | 
						|
      csv_string = CSV.generate do |csv| | 
						|
        csv << headers | 
						|
      end | 
						|
      StringIO.new(csv_string) | 
						|
    end | 
						|
 | 
						|
    def build_export_xml_io(case_logs) | 
						|
      doc = Nokogiri::XML("<forms/>") | 
						|
 | 
						|
      case_logs.each do |case_log| | 
						|
        form = doc.create_element("form") | 
						|
        doc.at("forms") << form | 
						|
        case_log.attributes.each do |key, _| | 
						|
          if is_omitted_field?(key) | 
						|
            next | 
						|
          else | 
						|
            value = case_log.read_attribute_before_type_cast(key) | 
						|
            form << doc.create_element(key, value) | 
						|
          end | 
						|
        end | 
						|
        form << doc.create_element("providertype", case_log.owning_organisation.read_attribute_before_type_cast(:provider_type)) | 
						|
      end | 
						|
      doc.write_xml_to(StringIO.new, encoding: "UTF-8") | 
						|
    end | 
						|
 | 
						|
    def get_folder_name | 
						|
      "core_#{day_as_string}" | 
						|
    end | 
						|
 | 
						|
    def get_file_name | 
						|
      "dat_core_#{day_as_string}_#{increment_as_string}" | 
						|
    end | 
						|
 | 
						|
    def day_as_string | 
						|
      Time.current.strftime("%Y_%m_%d") | 
						|
    end | 
						|
 | 
						|
    def increment_as_string(increment = 1) | 
						|
      sprintf("%04d", increment) | 
						|
    end | 
						|
  end | 
						|
end
 | 
						|
 |