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.
45 lines
2.3 KiB
45 lines
2.3 KiB
namespace :core do |
|
desc "Update lettings log database field from data XMLs provided by Softwire" |
|
task :lettings_data_import_field, %i[field path] => :environment do |_task, args| |
|
field = args[:field] |
|
path = args[:path] |
|
raise "Usage: rake core:lettings_data_import_field['field','path/to/xml_files']" if path.blank? || field.blank? |
|
|
|
# We only allow a reduced list of known fields to be updatable |
|
case field |
|
when "tenancycode", "major_repairs", "lettings_allocation", "offered", "address", "reason", "homeless", "created_by", "sex_and_relat", "general_needs_referral", "person_details" |
|
s3_service = Storage::S3Service.new(PlatformHelper.is_paas? ? Configuration::PaasConfigurationService.new : Configuration::EnvConfigurationService.new, ENV["IMPORT_PAAS_INSTANCE"]) |
|
archive_io = s3_service.get_file_io(path) |
|
archive_service = Storage::ArchiveService.new(archive_io) |
|
if archive_service.folder_present?("logs") |
|
Rails.logger.info("Start importing field from folder logs") |
|
Imports::LettingsLogsFieldImportService.new(archive_service).update_field(field, "logs") |
|
Rails.logger.info("Imported") |
|
end |
|
else |
|
raise "Field #{field} cannot be updated by lettings_data_import_field" |
|
end |
|
end |
|
|
|
desc "Update sales log database field from data XMLs provided by Softwire" |
|
task :sales_data_import_field, %i[field path] => :environment do |_task, args| |
|
field = args[:field] |
|
path = args[:path] |
|
raise "Usage: rake core:sales_data_import_field['field','path/to/xml_files']" if path.blank? || field.blank? |
|
|
|
# We only allow a reduced list of known fields to be updatable |
|
case field |
|
when "owning_organisation_id", "old_form_id", "created_by" |
|
s3_service = Storage::S3Service.new(PlatformHelper.is_paas? ? Configuration::PaasConfigurationService.new : Configuration::EnvConfigurationService.new, ENV["IMPORT_PAAS_INSTANCE"]) |
|
archive_io = s3_service.get_file_io(path) |
|
archive_service = Storage::ArchiveService.new(archive_io) |
|
if archive_service.folder_present?("logs") |
|
Rails.logger.info("Start importing field from folder logs") |
|
Imports::SalesLogsFieldImportService.new(archive_service).update_field(field, "logs") |
|
Rails.logger.info("Imported") |
|
end |
|
else |
|
raise "Field #{field} cannot be updated by sales_data_import_field" |
|
end |
|
end |
|
end
|
|
|