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.
201 lines
5.5 KiB
201 lines
5.5 KiB
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(:case_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]) |
|
case_log = CaseLog.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 = case_log.update(attr_key => attr_val) |
|
unless update |
|
# TODO: determine what to do when a bulk upload contains field values that don't pass validations |
|
end |
|
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(:case_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], |
|
sale_or_letting: "letting", |
|
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
|
|
|