55 lines
2.3 KiB
Ruby
55 lines
2.3 KiB
Ruby
# frozen_string_literal: true
|
|
|
|
class CorrectDedicationContacts < ActiveRecord::Migration[4.2]
|
|
def up
|
|
json_dedications = Qx.select('id', 'dedication').from(:donations)
|
|
.where("dedication IS NOT NULL AND dedication != ''")
|
|
.and_where('is_valid_json(dedication)').ex
|
|
parsed_dedications = json_dedications.map { |i| { id: i['id'], dedication: JSON.parse(i['dedication']) } }
|
|
with_contact_to_correct = parsed_dedications.select { |i| !i[:dedication]['contact'].blank? && i[:dedication]['contact'].is_a?(String) }
|
|
really_icky_dedications, easy_to_split_strings = with_contact_to_correct.partition { |i| i[:dedication]['contact'].split(' - ').count > 3 }
|
|
|
|
easy_to_split_strings.map do |i|
|
|
split_contact = i[:dedication]['contact'].split(' - ')
|
|
i[:dedication]['contact'] = {
|
|
email: split_contact[0],
|
|
phone: split_contact[1],
|
|
address: split_contact[2]
|
|
}
|
|
puts i
|
|
i
|
|
end.each_with_index do |i, index|
|
|
unless i[:id]
|
|
raise Error("Item at index #{index} is invalid. Object:#{i}")
|
|
end
|
|
|
|
Qx.update(:donations).where('id = $id', id: i[:id]).set(dedication: JSON.generate(i[:dedication])).ex
|
|
end
|
|
|
|
puts "Corrected #{easy_to_split_strings.count} records."
|
|
|
|
puts ''
|
|
puts ''
|
|
puts 'You must manually fix the following dedications: '
|
|
really_icky_dedications.each do |i|
|
|
puts i
|
|
end
|
|
end
|
|
|
|
def down
|
|
json_dedications = Qx.select('id', 'dedication').from(:donations)
|
|
.where("dedication IS NOT NULL AND dedication != ''")
|
|
.and_where('is_valid_json(dedication)').ex
|
|
|
|
parsed_dedications = json_dedications.map { |i| { 'id' => i['id'], 'dedication' => JSON.parse(i['dedication']) } }
|
|
|
|
with_contact_to_correct = parsed_dedications.select { |i| i['dedication']['contact'].is_a?(Hash) }
|
|
|
|
puts "#{with_contact_to_correct.count} to revert"
|
|
with_contact_to_correct.each do |i|
|
|
contact_string = "#{i['dedication']['contact']['email']} - #{i['dedication']['contact']['phone']} - #{i['dedication']['contact']['address']}"
|
|
i['dedication']['contact'] = contact_string
|
|
Qx.update(:donations).where('id = $id', id: i['id']).set(dedication: JSON.generate(i['dedication'])).ex
|
|
end
|
|
end
|
|
end
|