added stdout to log file

This commit is contained in:
Oleg Hasjanov 2021-07-13 12:04:54 +03:00
parent 8063d538a6
commit 0950361e0a
2 changed files with 59 additions and 5 deletions

View file

@ -1,11 +1,37 @@
class MigrateBeforeForceDeleteStatusesJob < ApplicationJob class MigrateBeforeForceDeleteStatusesJob < ApplicationJob
def perform def perform
logger.info 'Ran MigrateBeforeForceDeleteStatusesJob!'
domains = Domain.where.not(statuses_before_force_delete: nil) domains = Domain.where.not(statuses_before_force_delete: nil)
logger.info "Total domains are #{domains.count}"
interate_domain_in_batches(domains)
end
private
def interate_domain_in_batches(domains)
count = 0
domains.find_in_batches do |domain_batches| domains.find_in_batches do |domain_batches|
count += domain_batches.count
logger.info "Proccesing #{count} domains of #{domains.count}"
domain_batches.each do |domain| domain_batches.each do |domain|
migrate_data_to_statuses_history(domain)
end
end
end
def migrate_data_to_statuses_history(domain)
domain.force_delete_domain_statuses_history = domain.statuses_before_force_delete domain.force_delete_domain_statuses_history = domain.statuses_before_force_delete
domain.save domain.save
end rescue StandardError => e
end logger.warn "#{domain.name} crashed!"
logger.warn e.to_s
raise e
end
def logger
@logger ||= Logger.new(Rails.root.join('log', 'migrate_before_force_delete_statuses.log'))
end end
end end

View file

@ -1,9 +1,37 @@
class MigrateStatusesToDomainHistoryJob < ApplicationJob class MigrateStatusesToDomainHistoryJob < ApplicationJob
def perform def perform
logger.info 'Ran MigrateStatusesToDomainHistoryJob!'
domains = Domain.where(locked_by_registrant_at: nil) domains = Domain.where(locked_by_registrant_at: nil)
domains.each do |domain| logger.info "Total domains are #{domains.count}"
interate_domain_in_batches(domains)
end
private
def interate_domain_in_batches(domains)
count = 0
domains.find_in_batches do |domain_batches|
count += domain_batches.count
logger.info "Proccesing #{count} domains of #{domains.count}"
domain_batches.each do |domain|
migrate_data_to_admin_store_field(domain)
end
end
end
def migrate_data_to_admin_store_field(domain)
domain.admin_store_statuses_history = domain.statuses domain.admin_store_statuses_history = domain.statuses
domain.save domain.save
end rescue StandardError => e
logger.warn "#{domain.name} crashed!"
logger.warn e.to_s
raise e
end
def logger
@logger ||= Logger.new(Rails.root.join('log', 'migrate_statuses_to_domain_history.log'))
end end
end end