class BulkUpload include ActiveModel::Model include ActiveModel::Validations include ActiveModel::Conversion SPREADSHEET_CONTENT_TYPES = %w[ application/vnd.ms-excel application/vnd.openxmlformats-officedocument.spreadsheetml.sheet ].freeze FIRST_DATA_ROW = 7 def initialize(file, content_type) @file = file @content_type = content_type end def process(current_user) return unless valid_content_type? xlsx = Roo::Spreadsheet.open(@file, extension: :xlsx) sheet = xlsx.sheet(0) last_row = sheet.last_row if last_row < FIRST_DATA_ROW errors.add(:lettings_log_bulk_upload, "No data found") else data_range = FIRST_DATA_ROW..last_row data_range.map do |row_num| row = sheet.row(row_num) # owning_organisation = Organisation.find(row[111]) # managing_organisation = Organisation.find(row[113]) lettings_log = LettingsLog.create!( owning_organisation: current_user.organisation, managing_organisation: current_user.organisation, created_by: current_user, ) map_row(row).each do |attr_key, attr_val| _update = lettings_log.update(attr_key => attr_val) rescue ArgumentError # TODO: determine what we want to do when bulk upload contains totally invalid data for a field. end end end end def valid_content_type? if SPREADSHEET_CONTENT_TYPES.include?(@content_type) true else errors.add(:lettings_log_bulk_upload, "Invalid file type") false end end def map_row(row) { lettype: row[1], # reg_num_la_core_code: row[3], # managementgroup: row[4], # schemecode: row[5], # firstletting: row[6], tenancycode: row[7], startertenancy: row[8], tenancy: row[9], tenancyother: row[10], # tenancyduration: row[11], hhmemb: hhmemb(row), age1: row[12], age2: row[13], age3: row[14], age4: row[15], age5: row[16], age6: row[17], age7: row[18], age8: row[19], sex1: row[20], sex2: row[21], sex3: row[22], sex4: row[23], sex5: row[24], sex6: row[25], sex7: row[26], sex8: row[27], relat2: row[28], relat3: row[29], relat4: row[30], relat5: row[31], relat6: row[32], relat7: row[33], relat8: row[34], ecstat1: row[35], ecstat2: row[36], ecstat3: row[37], ecstat4: row[38], ecstat5: row[39], ecstat6: row[40], ecstat7: row[41], ecstat8: row[42], ethnic: row[43], national: row[44], armedforces: row[45], reservist: row[46], preg_occ: row[47], hb: row[48], benefits: row[49], net_income_known: row[50].present? ? 1 : nil, earnings: row[50], # increfused: row[51], reason: row[52], reasonother: row[53], underoccupation_benefitcap: row[54], housingneeds_a: row[55], housingneeds_b: row[56], housingneeds_c: row[57], housingneeds_f: row[58], housingneeds_g: row[59], housingneeds_h: row[60], prevten: row[61], prevloc: row[62], # prevpco_unknown: row[65], layear: row[66], waityear: row[67], homeless: row[68], reasonpref: row[69], rp_homeless: row[70], rp_insan_unsat: row[71], rp_medwel: row[72], rp_hardship: row[73], rp_dontknow: row[74], cbl: row[75], chr: row[76], cap: row[77], # referral_source: row[78], period: row[79], brent: row[80], scharge: row[81], pscharge: row[82], supcharg: row[83], tcharge: row[84], # tcharge_care_homes: row[85], # no_rent_or_charge: row[86], hbrentshortfall: row[87], tshortfall: row[88], voiddate: row[89].to_s + row[90].to_s + row[91].to_s, majorrepairs: row[92].present? ? "1" : nil, mrcdate: row[92].to_s + row[93].to_s + row[94].to_s, # supported_scheme: row[95], startdate: date_time(row[98], row[97], row[96]), # startdate_day: row[96], # startdate_month: row[97], # startdate_year: row[98], offered: row[99], # property_reference: row[100], beds: row[101], unittype_gn: row[102], builtype: row[103], wchair: row[104], property_relet: row[105], rsnvac: row[106], la: row[107], # row[110] removed # row[111] is owning organisation used above # username: row[112], # row[113] is managing organisation used above leftreg: row[114], # uprn: row[115], incfreq: row[116], # sheltered_accom: row[117], illness: row[118], illness_type_1: row[119], illness_type_2: row[120], illness_type_3: row[121], illness_type_4: row[122], illness_type_8: row[123], illness_type_5: row[124], illness_type_6: row[125], illness_type_7: row[126], illness_type_9: row[127], illness_type_10: row[128], # london_affordable: row[129], rent_type: row[130], irproduct_other: row[131], # data_protection: row[132], declaration: 1, } end def date_time(year, month, day) return unless year && month && day Time.zone.local("20#{year}", month.to_s, day.to_s) end def hhmemb(row) [14, 15, 16, 17, 18, 19, 20].count { |idx| row[idx].present? } end end