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.
53 lines
2.0 KiB
53 lines
2.0 KiB
3 months ago
|
def process_duplicate_rent_periods(log_groups: true)
|
||
|
|
duplicate_groups = OrganisationRentPeriod
|
||
|
|
.select("organisation_id, rent_period")
|
||
|
|
.group("organisation_id, rent_period")
|
||
|
|
.having("COUNT(*) > 1")
|
||
|
|
|
||
|
|
affected_records = OrganisationRentPeriod
|
||
|
|
.where(organisation_id: duplicate_groups.map(&:organisation_id), rent_period: duplicate_groups.map(&:rent_period))
|
||
|
|
|
||
|
|
if log_groups
|
||
|
|
duplicate_groups.each do |group|
|
||
|
|
group_records = affected_records.where(organisation_id: group.organisation_id, rent_period: group.rent_period)
|
||
|
|
group_records.each do |record|
|
||
|
|
Rails.logger.info "ID: #{record.id}, Organisation ID: #{record.organisation_id}, Rent Period: #{record.rent_period}"
|
||
|
|
end
|
||
|
|
Rails.logger.info "----------------------"
|
||
|
|
end
|
||
|
|
end
|
||
|
|
|
||
|
|
to_keep_ids = OrganisationRentPeriod
|
||
|
|
.select("MIN(id) as id")
|
||
|
|
.group("organisation_id, rent_period")
|
||
|
|
.having("COUNT(*) > 1")
|
||
|
|
.map(&:id)
|
||
|
|
|
||
|
|
duplicate_ids = affected_records.pluck(:id) - to_keep_ids
|
||
|
|
|
||
|
|
{
|
||
|
|
affected_records:,
|
||
|
|
to_keep_ids:,
|
||
|
|
duplicate_ids:,
|
||
|
|
}
|
||
|
|
end
|
||
|
|
|
||
|
|
desc "Find and output each group of duplicate rent periods with counts"
|
||
|
|
task find_duplicate_rent_periods: :environment do
|
||
|
|
result = process_duplicate_rent_periods(log_groups: true)
|
||
|
|
|
||
|
|
Rails.logger.info "Total number of records: #{OrganisationRentPeriod.count}"
|
||
|
|
Rails.logger.info "Number of affected records: #{result[:affected_records].size}"
|
||
|
|
Rails.logger.info "Number of affected records to delete: #{result[:duplicate_ids].size}"
|
||
|
|
Rails.logger.info "Number of affected records to keep: #{result[:to_keep_ids].size}"
|
||
|
|
end
|
||
|
|
|
||
|
|
desc "Delete duplicate rent periods"
|
||
|
|
task delete_duplicate_rent_periods: :environment do
|
||
|
|
result = process_duplicate_rent_periods(log_groups: false)
|
||
|
|
|
||
|
|
OrganisationRentPeriod.where(id: result[:duplicate_ids]).delete_all
|
||
|
|
|
||
|
|
Rails.logger.info "Number of deleted duplicate records: #{result[:duplicate_ids].size}"
|
||
|
|
end
|