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.
173 lines
6.6 KiB
173 lines
6.6 KiB
module Imports |
|
class SchemeLocationImportService < ImportService |
|
def create_scheme_locations(folder) |
|
import_from(folder, :create_scheme_location) |
|
end |
|
|
|
def create_scheme_location(xml_document) |
|
management_group = location_field_value(xml_document, "mgmtgroup") |
|
schemes = Scheme.where(old_id: management_group) |
|
raise "Scheme not found with legacy ID #{management_group}" if schemes.empty? |
|
|
|
if schemes.size == 1 && schemes.first.locations&.empty? |
|
scheme = update_scheme(schemes.first, xml_document) |
|
else |
|
scheme = find_scheme_to_merge(xml_document) |
|
scheme ||= duplicate_scheme(schemes, xml_document) |
|
end |
|
add_location(scheme, xml_document) |
|
end |
|
|
|
private |
|
|
|
REGISTERED_UNDER_CARE_ACT = { |
|
2 => "(Part-registered care home)", |
|
3 => "(Registered personal care home)", |
|
4 => "(Registered nursing care home)", |
|
}.freeze |
|
|
|
def create_scheme(source_scheme, xml_doc) |
|
attributes = scheme_attributes(xml_doc) |
|
attributes["owning_organisation_id"] = source_scheme.owning_organisation_id |
|
attributes["managing_organisation_id"] = source_scheme.managing_organisation_id |
|
attributes["service_name"] = source_scheme.service_name |
|
attributes["arrangement_type"] = source_scheme.arrangement_type |
|
attributes["old_id"] = source_scheme.old_id |
|
attributes["old_visible_id"] = source_scheme.old_visible_id |
|
Scheme.create!(attributes) |
|
end |
|
|
|
def update_scheme(scheme, xml_doc) |
|
attributes = scheme_attributes(xml_doc) |
|
scheme.update!(attributes) |
|
scheme |
|
end |
|
|
|
def scheme_attributes(xml_doc) |
|
attributes = {} |
|
attributes["scheme_type"] = safe_string_as_integer(xml_doc, "scheme-type") |
|
registered_under_care_act = safe_string_as_integer(xml_doc, "reg-home-type") |
|
attributes["registered_under_care_act"] = registered_under_care_act.zero? ? nil : registered_under_care_act |
|
attributes["support_type"] = safe_string_as_integer(xml_doc, "support-type") |
|
attributes["intended_stay"] = string_or_nil(xml_doc, "intended-stay") |
|
attributes["primary_client_group"] = string_or_nil(xml_doc, "client-group-1") |
|
attributes["secondary_client_group"] = string_or_nil(xml_doc, "client-group-2") |
|
attributes["secondary_client_group"] = nil if attributes["primary_client_group"] == attributes["secondary_client_group"] |
|
attributes["sensitive"] = sensitive(xml_doc) |
|
attributes["end_date"] = parse_end_date(xml_doc) |
|
attributes |
|
end |
|
|
|
def add_location(scheme, xml_doc) |
|
end_date = parse_end_date(xml_doc) |
|
old_id = string_or_nil(xml_doc, "id") |
|
|
|
if end_date.nil? || end_date >= Time.zone.now |
|
# wheelchair_adaptation: string_or_nil(xml_doc, "mobility-type"), |
|
begin |
|
Location.create!( |
|
name: string_or_nil(xml_doc, "name"), |
|
postcode: string_or_nil(xml_doc, "postcode"), |
|
units: safe_string_as_integer(xml_doc, "total-units"), |
|
type_of_unit: safe_string_as_integer(xml_doc, "unit-type"), |
|
old_visible_id: safe_string_as_integer(xml_doc, "visible-id"), |
|
old_id:, |
|
scheme:, |
|
) |
|
rescue ActiveRecord::RecordNotUnique |
|
@logger.warn("Location is already present with legacy ID #{old_id}, skipping") |
|
end |
|
else |
|
@logger.warn("Location with legacy ID #{old_id} is expired (#{end_date}), skipping") |
|
end |
|
end |
|
|
|
def find_scheme_to_merge(xml_doc) |
|
attributes = scheme_attributes(xml_doc) |
|
|
|
Scheme.find_by( |
|
scheme_type: attributes["scheme_type"], |
|
registered_under_care_act: attributes["registered_under_care_act"], |
|
support_type: attributes["support_type"], |
|
intended_stay: attributes["intended_stay"], |
|
primary_client_group: attributes["primary_client_group"], |
|
secondary_client_group: attributes["secondary_client_group"], |
|
) |
|
end |
|
|
|
def duplicate_scheme(schemes, xml_doc) |
|
# Since all schemes in the array are different, pick the first one |
|
# In the future, consider a better selection method if needed |
|
old_scheme = schemes.first |
|
new_scheme = create_scheme(old_scheme, xml_doc) |
|
|
|
if old_scheme.scheme_type != new_scheme.scheme_type |
|
rename_schemes(old_scheme, new_scheme, :scheme_type) |
|
elsif old_scheme.registered_under_care_act != new_scheme.registered_under_care_act |
|
rename_registered_care(old_scheme, new_scheme) |
|
elsif old_scheme.support_type != new_scheme.support_type |
|
rename_schemes(old_scheme, new_scheme, :support_type) |
|
elsif old_scheme.intended_stay != new_scheme.intended_stay |
|
rename_schemes(old_scheme, new_scheme, :intended_stay) |
|
elsif old_scheme.primary_client_group != new_scheme.primary_client_group |
|
rename_schemes(old_scheme, new_scheme, :primary_client_group) |
|
elsif old_scheme.secondary_client_group != new_scheme.secondary_client_group |
|
rename_schemes(old_scheme, new_scheme, :secondary_client_group) |
|
end |
|
|
|
new_scheme |
|
end |
|
|
|
def rename_registered_care(*schemes) |
|
schemes.each do |scheme| |
|
if REGISTERED_UNDER_CARE_ACT.key?(scheme.registered_under_care_act_before_type_cast) |
|
suffix = REGISTERED_UNDER_CARE_ACT[scheme.registered_under_care_act_before_type_cast] |
|
scheme.update!(service_name: "#{scheme.service_name} - #{suffix}") |
|
end |
|
end |
|
end |
|
|
|
def rename_schemes(old_scheme, new_scheme, attribute) |
|
old_scheme_attribute = old_scheme.send(attribute) |
|
new_scheme_attribute = new_scheme.send(attribute) |
|
|
|
if old_scheme_attribute |
|
old_scheme_name = "#{old_scheme.service_name} - #{old_scheme_attribute}" |
|
old_scheme.update!(service_name: old_scheme_name) |
|
end |
|
if new_scheme_attribute |
|
new_scheme_name = "#{new_scheme.service_name} - #{new_scheme_attribute}" |
|
new_scheme.update!(service_name: new_scheme_name) |
|
end |
|
end |
|
|
|
def location_field_value(xml_doc, field) |
|
field_value(xml_doc, "scheme", field) |
|
end |
|
|
|
def string_or_nil(xml_doc, attribute) |
|
str = location_field_value(xml_doc, attribute) |
|
str.presence |
|
end |
|
|
|
# Safe: A string that represents only an integer (or empty/nil) |
|
def safe_string_as_integer(xml_doc, attribute) |
|
str = location_field_value(xml_doc, attribute) |
|
Integer(str, exception: false) |
|
end |
|
|
|
def sensitive(xml_doc) |
|
value = string_or_nil(xml_doc, "sensitive") |
|
if value == "true" |
|
1 |
|
else |
|
0 |
|
end |
|
end |
|
|
|
def parse_end_date(xml_doc) |
|
end_date = string_or_nil(xml_doc, "end-date") |
|
Time.zone.parse(end_date) if end_date |
|
end |
|
end |
|
end
|
|
|