CLDC-2999 Deactivate locations on merged orgs (#2069)

* Deactivate locations on merged orgs

* Move inactive schemes/locations over

* Refactor tests

* Do not validate removing reactivation date

app/services/merge/merge_organisations_service.rb

@@ -67,14 +67,19 @@ private
   def merge_schemes_and_locations(merging_organisation)
     @merged_schemes[merging_organisation.name] = []
     merging_organisation.owned_schemes.each do |scheme|
-      next if scheme.deactivated?
-
-      new_scheme = Scheme.create!(scheme.attributes.except("id", "owning_organisation_id", "old_id", "old_visible_id").merge(owning_organisation: @absorbing_organisation, startdate: @merge_date))
+      new_scheme = Scheme.create!(scheme.attributes.except("id", "owning_organisation_id", "old_id", "old_visible_id").merge(owning_organisation: @absorbing_organisation, startdate: [scheme&.startdate, @merge_date].compact.max))
+      scheme.scheme_deactivation_periods.each do |deactivation_period|
+        split_scheme_deactivation_period_between_organisations(deactivation_period, new_scheme)
+      end
       scheme.locations.each do |location|
-        new_scheme.locations << Location.new(location.attributes.except("id", "scheme_id", "old_id", "old_visible_id").merge(startdate: [location&.startdate, @merge_date].compact.max)) unless location.deactivated?
+        new_location = Location.create!(location.attributes.except("id", "scheme_id", "old_id", "old_visible_id").merge(scheme: new_scheme, startdate: [location&.startdate, @merge_date].compact.max))
+        location.location_deactivation_periods.each do |deactivation_period|
+          split_location_deactivation_period_between_organisations(deactivation_period, new_location)
+        end
+        LocationDeactivationPeriod.create!(location:, deactivation_date: [location&.startdate, scheme&.startdate, @merge_date].compact.max) unless location.status_at(@merge_date) == :deactivated
       end
       @merged_schemes[merging_organisation.name] << { name: new_scheme.service_name, code: new_scheme.id }
-      SchemeDeactivationPeriod.create!(scheme:, deactivation_date: @merge_date)
+      SchemeDeactivationPeriod.create!(scheme:, deactivation_date: [scheme&.startdate, @merge_date].compact.max) unless scheme.status_at(@merge_date) == :deactivated
     end
   end
 
@@ -170,4 +175,42 @@ private
 
     merging_organisation.users.where.not(id: new_dpo.id)
   end
+
+  def deactivation_happenned_before_merge?(deactivation_period)
+    deactivation_period.deactivation_date <= @merge_date && deactivation_period.reactivation_date.present? && deactivation_period.reactivation_date <= @merge_date
+  end
+
+  def deactivation_happenned_during_merge?(deactivation_period)
+    deactivation_period.deactivation_date <= @merge_date && (deactivation_period.reactivation_date.blank? || deactivation_period.reactivation_date.present? && deactivation_period.reactivation_date >= @merge_date)
+  end
+
+  def split_scheme_deactivation_period_between_organisations(deactivation_period, new_scheme)
+    return if deactivation_happenned_before_merge?(deactivation_period)
+
+    if deactivation_happenned_during_merge?(deactivation_period)
+      SchemeDeactivationPeriod.create!(deactivation_period.attributes.except("id", "scheme_id", "deactivation_date").merge(scheme: new_scheme, deactivation_date: @merge_date))
+      if deactivation_period.reactivation_date.present?
+        deactivation_period.reactivation_date = nil
+        deactivation_period.save!(validate: false)
+      end
+    else
+      SchemeDeactivationPeriod.create!(deactivation_period.attributes.except("id", "scheme_id").merge(scheme: new_scheme))
+      deactivation_period.destroy!
+    end
+  end
+
+  def split_location_deactivation_period_between_organisations(deactivation_period, new_location)
+    return if deactivation_happenned_before_merge?(deactivation_period)
+
+    if deactivation_happenned_during_merge?(deactivation_period)
+      LocationDeactivationPeriod.create!(deactivation_period.attributes.except("id", "location_id", "deactivation_date").merge(location: new_location, deactivation_date: @merge_date))
+      if deactivation_period.reactivation_date.present?
+        deactivation_period.reactivation_date = nil
+        deactivation_period.save!(validate: false)
+      end
+    else
+      LocationDeactivationPeriod.create!(deactivation_period.attributes.except("id", "location_id").merge(location: new_location))
+      deactivation_period.destroy!
+    end
+  end
 end

spec/services/merge/merge_organisations_service_spec.rb

@@ -133,6 +133,269 @@ RSpec.describe Merge::MergeOrganisationsService do
       end
 
       context "and merging organisation schemes and locations" do
+        context "when a scheme and location have no deactivations or startdates" do
+          let!(:scheme) { create(:scheme, owning_organisation: merging_organisation, old_id: "scheme_old_id", old_visible_id: "scheme_old_visible_id") }
+          let!(:location) { create(:location, scheme:, old_id: "location_old_id", old_visible_id: "location_old_visible_id") }
+
+          it "copies the schemes and locations to absorbing organisation" do
+            merge_organisations_service.call
+
+            absorbing_organisation.reload
+            expect(absorbing_organisation.owned_schemes.count).to eq(1)
+
+            absorbed_scheme = absorbing_organisation.owned_schemes.first
+            expect(absorbed_scheme.locations.count).to eq(1)
+            absorbed_location = absorbed_scheme.locations.first
+
+            expect(absorbed_scheme.service_name).to eq(scheme.service_name)
+            expect(absorbed_scheme.old_id).to be_nil
+            expect(absorbed_scheme.old_visible_id).to be_nil
+            expect(absorbed_scheme.startdate).to eq(Time.zone.today)
+
+            expect(absorbed_location.postcode).to eq(location.postcode)
+            expect(absorbed_location.old_id).to be_nil
+            expect(absorbed_location.old_visible_id).to be_nil
+            expect(absorbed_location.startdate).to eq(Time.zone.today)
+          end
+
+          it "deactivates schemes and locations on the merged organisation" do
+            merge_organisations_service.call
+            expect(scheme.owning_organisation).to eq(merging_organisation)
+            expect(location.scheme).to eq(scheme)
+            expect(scheme.scheme_deactivation_periods.count).to eq(1)
+            expect(scheme.scheme_deactivation_periods.first.deactivation_date).to eq(Time.zone.today)
+            expect(location.location_deactivation_periods.count).to eq(1)
+            expect(location.location_deactivation_periods.first.deactivation_date).to eq(Time.zone.today)
+          end
+        end
+
+        context "when a scheme and location have a startdate but no deactivations" do
+          context "and the startdate is before the merge date" do
+            let!(:scheme) { create(:scheme, owning_organisation: merging_organisation, old_id: "scheme_old_id", old_visible_id: "scheme_old_visible_id", startdate: Time.zone.today - 1.month) }
+            let!(:location) { create(:location, scheme:, old_id: "location_old_id", old_visible_id: "location_old_visible_id", startdate: Time.zone.today - 1.month) }
+
+            it "sets the startdate to merge date for schemes and locations moved to absorbed organisation" do
+              merge_organisations_service.call
+
+              absorbing_organisation.reload
+              expect(absorbing_organisation.owned_schemes.count).to eq(1)
+
+              absorbed_scheme = absorbing_organisation.owned_schemes.first
+              expect(absorbed_scheme.locations.count).to eq(1)
+              absorbed_location = absorbed_scheme.locations.first
+
+              expect(absorbed_scheme.startdate).to eq(Time.zone.today)
+              expect(absorbed_location.startdate).to eq(Time.zone.today)
+            end
+
+            it "deactivates schemes and locations on the merged organisation" do
+              merge_organisations_service.call
+
+              absorbing_organisation.reload
+              expect(scheme.owning_organisation).to eq(merging_organisation)
+              expect(location.scheme).to eq(scheme)
+              expect(scheme.scheme_deactivation_periods.count).to eq(1)
+              expect(scheme.scheme_deactivation_periods.first.deactivation_date).to eq(Time.zone.today)
+              expect(location.location_deactivation_periods.count).to eq(1)
+              expect(location.location_deactivation_periods.first.deactivation_date).to eq(Time.zone.today)
+            end
+          end
+
+          context "and the startdate is after the merge date" do
+            let!(:scheme) { create(:scheme, owning_organisation: merging_organisation, old_id: "scheme_old_id", old_visible_id: "scheme_old_visible_id", startdate: Time.zone.today + 1.month) }
+            let!(:location) { create(:location, scheme:, old_id: "location_old_id", old_visible_id: "location_old_visible_id", startdate: Time.zone.today + 1.month) }
+
+            it "keeps the existing startdate for schemes and locations moved to absorbed organisation" do
+              merge_organisations_service.call
+
+              absorbing_organisation.reload
+              expect(absorbing_organisation.owned_schemes.count).to eq(1)
+
+              absorbed_scheme = absorbing_organisation.owned_schemes.first
+              expect(absorbed_scheme.locations.count).to eq(1)
+              absorbed_location = absorbed_scheme.locations.first
+
+              expect(absorbed_scheme.startdate).to eq(Time.zone.today + 1.month)
+              expect(absorbed_location.startdate).to eq(Time.zone.today + 1.month)
+            end
+
+            it "deactivates schemes and locations on the merged organisation on the startdate" do
+              merge_organisations_service.call
+
+              expect(scheme.owning_organisation).to eq(merging_organisation)
+              expect(location.scheme).to eq(scheme)
+              expect(scheme.scheme_deactivation_periods.count).to eq(1)
+              expect(scheme.scheme_deactivation_periods.first.deactivation_date).to eq(Time.zone.today + 1.month)
+              expect(location.location_deactivation_periods.count).to eq(1)
+              expect(location.location_deactivation_periods.first.deactivation_date).to eq(Time.zone.today + 1.month)
+            end
+          end
+        end
+
+        context "when a scheme and location have a deactivations but no startdates" do
+          context "and deactivation is before the merge date" do
+            let!(:scheme) { create(:scheme, owning_organisation: merging_organisation, old_id: "scheme_old_id", old_visible_id: "scheme_old_visible_id", startdate: nil) }
+            let!(:location) { create(:location, scheme:, old_id: "location_old_id", old_visible_id: "location_old_visible_id", startdate: nil) }
+
+            before do
+              create(:scheme_deactivation_period, scheme:, deactivation_date: Time.zone.today - 2.months, reactivation_date: Time.zone.today - 1.month)
+              create(:location_deactivation_period, location:, deactivation_date: Time.zone.today - 2.months, reactivation_date: Time.zone.today - 1.month)
+              merge_organisations_service.call
+
+              absorbing_organisation.reload
+              scheme.scheme_deactivation_periods.reload
+              location.location_deactivation_periods.reload
+            end
+
+            it "does not move the deactivation" do
+              expect(absorbing_organisation.owned_schemes.count).to eq(1)
+
+              absorbed_scheme = absorbing_organisation.owned_schemes.first
+              expect(absorbed_scheme.locations.count).to eq(1)
+              absorbed_location = absorbed_scheme.locations.first
+
+              expect(absorbed_scheme.startdate).to eq(Time.zone.today)
+              expect(absorbed_scheme.scheme_deactivation_periods.count).to eq(0)
+
+              expect(absorbed_location.startdate).to eq(Time.zone.today)
+              expect(absorbed_location.location_deactivation_periods.count).to eq(0)
+            end
+
+            it "deactivates schemes and locations on the merged organisation" do
+              expect(scheme.owning_organisation).to eq(merging_organisation)
+              expect(location.scheme).to eq(scheme)
+              expect(scheme.scheme_deactivation_periods.count).to eq(2)
+              expect(scheme.scheme_deactivation_periods.last.deactivation_date).to eq(Time.zone.today)
+              expect(location.location_deactivation_periods.count).to eq(2)
+              expect(location.location_deactivation_periods.last.deactivation_date).to eq(Time.zone.today)
+            end
+          end
+
+          context "and deactivation is after the merge date" do
+            let!(:scheme) { create(:scheme, owning_organisation: merging_organisation, old_id: "scheme_old_id", old_visible_id: "scheme_old_visible_id", startdate: nil) }
+            let!(:location) { create(:location, scheme:, old_id: "location_old_id", old_visible_id: "location_old_visible_id", startdate: nil) }
+
+            before do
+              create(:scheme_deactivation_period, scheme:, deactivation_date: Time.zone.today + 1.month, reactivation_date: Time.zone.today + 2.months)
+              create(:location_deactivation_period, location:, deactivation_date: Time.zone.today + 3.months)
+              merge_organisations_service.call
+              absorbing_organisation.reload
+              scheme.scheme_deactivation_periods.reload
+              location.location_deactivation_periods.reload
+            end
+
+            it "moves the deactivations to absorbing organisation and removes them from merging organisations" do
+              expect(absorbing_organisation.owned_schemes.count).to eq(1)
+
+              absorbed_scheme = absorbing_organisation.owned_schemes.first
+              expect(absorbed_scheme.locations.count).to eq(1)
+              absorbed_location = absorbed_scheme.locations.first
+
+              expect(absorbed_scheme.startdate).to eq(Time.zone.today)
+              expect(absorbed_scheme.scheme_deactivation_periods.count).to eq(1)
+
+              expect(absorbed_location.startdate).to eq(Time.zone.today)
+              expect(absorbed_location.location_deactivation_periods.count).to eq(1)
+            end
+
+            it "deactivates schemes and locations on the merged organisation" do
+              expect(scheme.owning_organisation).to eq(merging_organisation)
+              expect(location.scheme).to eq(scheme)
+              expect(scheme.scheme_deactivation_periods.count).to eq(1)
+              expect(scheme.scheme_deactivation_periods.last.deactivation_date).to eq(Time.zone.today)
+              expect(location.location_deactivation_periods.count).to eq(1)
+              expect(location.location_deactivation_periods.last.deactivation_date).to eq(Time.zone.today)
+            end
+          end
+
+          context "and deactivation is during the merge date and it has a reactivation date" do
+            let!(:scheme) { create(:scheme, owning_organisation: merging_organisation, old_id: "scheme_old_id", old_visible_id: "scheme_old_visible_id", startdate: nil) }
+            let!(:location) { create(:location, scheme:, old_id: "location_old_id", old_visible_id: "location_old_visible_id", startdate: nil) }
+
+            before do
+              create(:scheme_deactivation_period, scheme:, deactivation_date: Time.zone.today - 1.month, reactivation_date: Time.zone.today + 1.month)
+              create(:location_deactivation_period, location:, deactivation_date: Time.zone.today - 3.months, reactivation_date: Time.zone.today + 1.month)
+              merge_organisations_service.call
+
+              absorbing_organisation.reload
+              scheme.scheme_deactivation_periods.reload
+              location.location_deactivation_periods.reload
+            end
+
+            it "moves the deactivation to absorbing organisation with merge_date as deactivation_date and removes reactivation date on merged organisation scheme and location" do
+              expect(absorbing_organisation.owned_schemes.count).to eq(1)
+
+              absorbed_scheme = absorbing_organisation.owned_schemes.first
+              expect(absorbed_scheme.locations.count).to eq(1)
+              absorbed_location = absorbed_scheme.locations.first
+
+              expect(absorbed_scheme.startdate).to eq(Time.zone.today)
+              expect(absorbed_scheme.scheme_deactivation_periods.count).to eq(1)
+              expect(absorbed_scheme.scheme_deactivation_periods.first.deactivation_date).to eq(Time.zone.today)
+              expect(absorbed_scheme.scheme_deactivation_periods.first.reactivation_date).to eq(Time.zone.today + 1.month)
+
+              expect(absorbed_location.startdate).to eq(Time.zone.today)
+              expect(absorbed_location.location_deactivation_periods.count).to eq(1)
+              expect(absorbed_location.location_deactivation_periods.first.deactivation_date).to eq(Time.zone.today)
+              expect(absorbed_location.location_deactivation_periods.first.reactivation_date).to eq(Time.zone.today + 1.month)
+            end
+
+            it "deactivates schemes and locations on the merged organisation" do
+              expect(scheme.owning_organisation).to eq(merging_organisation)
+              expect(location.scheme).to eq(scheme)
+              expect(scheme.scheme_deactivation_periods.count).to eq(1)
+              expect(scheme.scheme_deactivation_periods.first.deactivation_date.to_date).to eq(Time.zone.today - 1.month)
+              expect(scheme.scheme_deactivation_periods.first.reactivation_date).to be_nil
+              expect(location.location_deactivation_periods.count).to eq(1)
+              expect(location.location_deactivation_periods.first.deactivation_date.to_date).to eq(Time.zone.today - 3.months)
+              expect(location.location_deactivation_periods.first.reactivation_date).to be_nil
+            end
+          end
+
+          context "and deactivation is during the merge date and it doesn't have a reactivation date" do
+            let!(:scheme) { create(:scheme, owning_organisation: merging_organisation, old_id: "scheme_old_id", old_visible_id: "scheme_old_visible_id", startdate: nil) }
+            let!(:location) { create(:location, scheme:, old_id: "location_old_id", old_visible_id: "location_old_visible_id", startdate: nil) }
+
+            before do
+              create(:scheme_deactivation_period, scheme:, deactivation_date: Time.zone.today - 1.month)
+              create(:location_deactivation_period, location:, deactivation_date: Time.zone.today - 3.months)
+            end
+
+            it "moves the deactivation to absorbing organisation with merge_date as deactivation_date and does not deactivate merged org schemes and locations again" do
+              merge_organisations_service.call
+
+              absorbing_organisation.reload
+              scheme.scheme_deactivation_periods.reload
+              location.location_deactivation_periods.reload
+              expect(absorbing_organisation.owned_schemes.count).to eq(1)
+
+              absorbed_scheme = absorbing_organisation.owned_schemes.first
+              expect(absorbed_scheme.locations.count).to eq(1)
+              absorbed_location = absorbed_scheme.locations.first
+
+              expect(absorbed_scheme.startdate).to eq(Time.zone.today)
+              expect(absorbed_scheme.scheme_deactivation_periods.count).to eq(1)
+              expect(absorbed_scheme.scheme_deactivation_periods.first.deactivation_date).to eq(Time.zone.today)
+              expect(absorbed_scheme.scheme_deactivation_periods.first.reactivation_date).to be_nil
+
+              expect(absorbed_location.startdate).to eq(Time.zone.today)
+              expect(absorbed_location.location_deactivation_periods.count).to eq(1)
+              expect(absorbed_location.location_deactivation_periods.first.deactivation_date).to eq(Time.zone.today)
+              expect(absorbed_location.location_deactivation_periods.first.reactivation_date).to be_nil
+
+              expect(scheme.owning_organisation).to eq(merging_organisation)
+              expect(location.scheme).to eq(scheme)
+              expect(scheme.scheme_deactivation_periods.count).to eq(1)
+              expect(scheme.scheme_deactivation_periods.first.deactivation_date.to_date).to eq(Time.zone.today - 1.month)
+              expect(scheme.scheme_deactivation_periods.first.reactivation_date).to be_nil
+              expect(location.location_deactivation_periods.count).to eq(1)
+              expect(location.location_deactivation_periods.first.deactivation_date.to_date).to eq(Time.zone.today - 3.months)
+              expect(location.location_deactivation_periods.first.reactivation_date).to be_nil
+            end
+          end
+        end
+
+        context "with multiple schemes and locations" do
           let!(:scheme) { create(:scheme, owning_organisation: merging_organisation, old_id: "scheme_old_id", old_visible_id: "scheme_old_visible_id") }
           let!(:location) { create(:location, scheme:, old_id: "location_old_id", old_visible_id: "location_old_visible_id") }
           let!(:deactivated_location) { create(:location, scheme:) }
@@ -148,25 +411,66 @@ RSpec.describe Merge::MergeOrganisationsService do
             create(:lettings_log, startdate: Time.zone.tomorrow, managing_organisation: merging_organisation)
           end
 
-        it "combines organisation schemes and locations" do
+          it "logs the merged schemes and locations" do
             expect(Rails.logger).to receive(:info).with("Merged users from fake org:")
             expect(Rails.logger).to receive(:info).with("\tDanny Rojas (#{merging_organisation.data_protection_officers.first.email})")
             expect(Rails.logger).to receive(:info).with("\tfake name (fake@email.com)")
             expect(Rails.logger).to receive(:info).with("New schemes from fake org:")
             expect(Rails.logger).to receive(:info).with(/\t#{scheme.service_name} \(S/)
+            expect(Rails.logger).to receive(:info).with(/\t#{deactivated_scheme.service_name} \(S/)
             merge_organisations_service.call
+          end
 
+          context "when combining organisation schemes and locations" do
+            before do
+              merge_organisations_service.call
               absorbing_organisation.reload
-          expect(absorbing_organisation.owned_schemes.count).to eq(1)
-          expect(absorbing_organisation.owned_schemes.first.service_name).to eq(scheme.service_name)
-          expect(absorbing_organisation.owned_schemes.first.old_id).to be_nil
-          expect(absorbing_organisation.owned_schemes.first.old_visible_id).to eq(nil)
-          expect(absorbing_organisation.owned_schemes.first.locations.count).to eq(1)
-          expect(absorbing_organisation.owned_schemes.first.locations.first.postcode).to eq(location.postcode)
-          expect(absorbing_organisation.owned_schemes.first.locations.first.old_id).to be_nil
-          expect(absorbing_organisation.owned_schemes.first.locations.first.old_visible_id).to eq(nil)
+              deactivated_scheme.reload
+              deactivated_location.reload
+              merging_organisation.reload
+            end
+
+            it "moves active schemes and locations to absorbing organisation" do
+              expect(absorbing_organisation.owned_schemes.count).to eq(2)
+
+              absorbed_active_scheme = absorbing_organisation.owned_schemes.find_by(service_name: scheme.service_name)
+              absorbed_active_location = absorbed_active_scheme.locations.find_by(postcode: location.postcode)
+              expect(absorbed_active_scheme.service_name).to eq(scheme.service_name)
+              expect(absorbed_active_scheme.old_id).to be_nil
+              expect(absorbed_active_scheme.old_visible_id).to be_nil
+              expect(absorbed_active_scheme.locations.count).to eq(2)
+              expect(absorbed_active_location.postcode).to eq(location.postcode)
+              expect(absorbed_active_location.old_id).to be_nil
+              expect(absorbed_active_location.old_visible_id).to be_nil
+            end
+
+            it "deactivates active schemes and locations on merging organisation" do
               expect(scheme.scheme_deactivation_periods.count).to eq(1)
               expect(scheme.scheme_deactivation_periods.first.deactivation_date.to_date).to eq(Time.zone.today)
+              expect(scheme.locations.find_by(postcode: location.postcode).location_deactivation_periods.count).to eq(1)
+              expect(scheme.locations.find_by(postcode: location.postcode).location_deactivation_periods.first.deactivation_date.to_date).to eq(Time.zone.today)
+            end
+
+            it "does not deactivate inactive locations on merging organisation again" do
+              expect(scheme.locations.find_by(postcode: deactivated_location.postcode).location_deactivation_periods.count).to eq(1)
+            end
+
+            it "moves inactive schemes and their locations to absorbing organisation" do
+              absorbed_inactive_scheme = absorbing_organisation.owned_schemes.find_by(service_name: deactivated_scheme.service_name)
+              expect(absorbed_inactive_scheme.scheme_deactivation_periods.count).to eq(1)
+              expect(absorbed_inactive_scheme.scheme_deactivation_periods.first.deactivation_date).to eq(merging_organisation.merge_date)
+              expect(absorbed_inactive_scheme.locations.count).to eq(1)
+              expect(absorbed_inactive_scheme.locations.first.location_deactivation_periods.count).to eq(0)
+              expect(deactivated_scheme.scheme_deactivation_periods.count).to eq(1)
+            end
+
+            it "moves inactive locations of active schemes to absorbing organisation" do
+              absorbed_active_scheme = absorbing_organisation.owned_schemes.find_by(service_name: scheme.service_name)
+              absorbed_inactive_location = absorbed_active_scheme.locations.find_by(postcode: deactivated_location.postcode)
+              expect(absorbed_active_scheme.scheme_deactivation_periods.count).to eq(0)
+              expect(absorbed_inactive_location.location_deactivation_periods.count).to eq(1)
+              expect(absorbed_inactive_location.location_deactivation_periods.first.deactivation_date).to eq(merging_organisation.merge_date)
+            end
           end
 
           it "moves relevant logs and assigns the new scheme" do
@@ -179,7 +483,7 @@ RSpec.describe Merge::MergeOrganisationsService do
             expect(absorbing_organisation.owned_lettings_logs.find(owned_lettings_log.id).scheme).to eq(absorbing_organisation.owned_schemes.first)
             expect(absorbing_organisation.owned_lettings_logs.find(owned_lettings_log.id).location).to eq(absorbing_organisation.owned_schemes.first.locations.first)
             expect(absorbing_organisation.owned_lettings_logs.find(owned_lettings_log_no_location.id).scheme).to eq(absorbing_organisation.owned_schemes.first)
-          expect(absorbing_organisation.owned_lettings_logs.find(owned_lettings_log_no_location.id).location).to eq(absorbing_organisation.owned_schemes.first.locations.first)
+            expect(absorbing_organisation.owned_lettings_logs.find(owned_lettings_log_no_location.id).location).to eq(nil)
           end
 
           it "rolls back if there's an error" do
@@ -193,10 +497,12 @@ RSpec.describe Merge::MergeOrganisationsService do
             merging_organisation.reload
             expect(absorbing_organisation.owned_schemes.count).to eq(0)
             expect(scheme.scheme_deactivation_periods.count).to eq(0)
+            expect(scheme.locations.first.location_deactivation_periods.count).to eq(0)
             expect(owned_lettings_log.owning_organisation).to eq(merging_organisation)
             expect(owned_lettings_log_no_location.owning_organisation).to eq(merging_organisation)
           end
         end
+      end
 
       context "and merging sales logs" do
         let!(:sales_log) { create(:sales_log, :completed, saledate: Time.zone.tomorrow, owning_organisation: merging_organisation) }
@@ -363,25 +669,72 @@ RSpec.describe Merge::MergeOrganisationsService do
             let!(:location_with_past_startdate) { create(:location, scheme:, startdate: Time.zone.today - 2.months) }
             let!(:location_with_future_startdate) { create(:location, scheme:, startdate: Time.zone.today + 2.months) }
 
-            it "combines organisation schemes and locations" do
+            it "logs the merged schemes" do
               expect(Rails.logger).to receive(:info).with("Merged users from fake org:")
               expect(Rails.logger).to receive(:info).with("\tDanny Rojas (#{merging_organisation.data_protection_officers.first.email})")
               expect(Rails.logger).to receive(:info).with("\tfake name (fake@email.com)")
               expect(Rails.logger).to receive(:info).with("New schemes from fake org:")
               expect(Rails.logger).to receive(:info).with(/\t#{scheme.service_name} \(S/)
+              expect(Rails.logger).to receive(:info).with(/\t#{deactivated_scheme.service_name} \(S/)
+
+              merge_organisations_service.call
+            end
+
+            context "when combining organisation schemes and locations" do
+              before do
                 merge_organisations_service.call
 
                 absorbing_organisation.reload
-              expect(absorbing_organisation.owned_schemes.count).to eq(1)
-              expect(absorbing_organisation.owned_schemes.first.service_name).to eq(scheme.service_name)
-              expect(absorbing_organisation.owned_schemes.first.startdate).to eq(Time.zone.yesterday)
-              expect(absorbing_organisation.owned_schemes.first.locations.count).to eq(4)
-              expect(absorbing_organisation.owned_schemes.first.locations.map(&:postcode)).to match_array([location, location_without_startdate, location_with_past_startdate, location_with_future_startdate].map(&:postcode))
+                deactivated_scheme.reload
+                deactivated_location.reload
+                merging_organisation.reload
+              end
+
+              it "moves active schemes and locations to absorbing organisation" do
+                expect(absorbing_organisation.owned_schemes.count).to eq(2)
+
+                expect(absorbing_organisation.owned_schemes.first.locations.map(&:postcode)).to match_array([location, deactivated_location, location_without_startdate, location_with_past_startdate, location_with_future_startdate].map(&:postcode))
                 expect(absorbing_organisation.owned_schemes.first.locations.find_by(postcode: location_without_startdate.postcode).startdate).to eq(Time.zone.yesterday)
                 expect(absorbing_organisation.owned_schemes.first.locations.find_by(postcode: location_with_past_startdate.postcode).startdate).to eq(Time.zone.yesterday)
                 expect(absorbing_organisation.owned_schemes.first.locations.find_by(postcode: location_with_future_startdate.postcode).startdate).to eq(Time.zone.today + 2.months)
+                absorbed_active_scheme = absorbing_organisation.owned_schemes.find_by(service_name: scheme.service_name)
+                absorbed_active_location = absorbed_active_scheme.locations.find_by(postcode: location.postcode)
+                expect(absorbed_active_scheme.service_name).to eq(scheme.service_name)
+                expect(absorbed_active_scheme.old_id).to be_nil
+                expect(absorbed_active_scheme.old_visible_id).to be_nil
+                expect(absorbed_active_scheme.locations.count).to eq(5)
+                expect(absorbed_active_location.postcode).to eq(location.postcode)
+                expect(absorbed_active_location.old_id).to be_nil
+                expect(absorbed_active_location.old_visible_id).to be_nil
+              end
+
+              it "deactivates active schemes and locations on merging organisation" do
                 expect(scheme.scheme_deactivation_periods.count).to eq(1)
                 expect(scheme.scheme_deactivation_periods.first.deactivation_date.to_date).to eq(Time.zone.yesterday)
+                expect(scheme.locations.find_by(postcode: location.postcode).location_deactivation_periods.count).to eq(1)
+                expect(scheme.locations.find_by(postcode: location.postcode).location_deactivation_periods.first.deactivation_date.to_date).to eq(Time.zone.yesterday)
+              end
+
+              it "does not deactivate inactive locations on merging organisation again" do
+                expect(scheme.locations.find_by(postcode: deactivated_location.postcode).location_deactivation_periods.count).to eq(1)
+              end
+
+              it "moves inactive schemes and their locations to absorbing organisation" do
+                absorbed_inactive_scheme = absorbing_organisation.owned_schemes.find_by(service_name: deactivated_scheme.service_name)
+                expect(absorbed_inactive_scheme.scheme_deactivation_periods.count).to eq(1)
+                expect(absorbed_inactive_scheme.scheme_deactivation_periods.first.deactivation_date).to eq(merging_organisation.merge_date)
+                expect(absorbed_inactive_scheme.locations.count).to eq(1)
+                expect(absorbed_inactive_scheme.locations.first.location_deactivation_periods.count).to eq(0)
+                expect(deactivated_scheme.scheme_deactivation_periods.count).to eq(1)
+              end
+
+              it "moves inactive locations of active schemes to absorbing organisation" do
+                absorbed_active_scheme = absorbing_organisation.owned_schemes.find_by(service_name: scheme.service_name)
+                absorbed_inactive_location = absorbed_active_scheme.locations.find_by(postcode: deactivated_location.postcode)
+                expect(absorbed_active_scheme.scheme_deactivation_periods.count).to eq(0)
+                expect(absorbed_inactive_location.location_deactivation_periods.count).to eq(1)
+                expect(absorbed_inactive_location.location_deactivation_periods.first.deactivation_date).to eq(merging_organisation.merge_date)
+              end
             end
           end
 
@@ -395,7 +748,7 @@ RSpec.describe Merge::MergeOrganisationsService do
             expect(absorbing_organisation.owned_lettings_logs.find(owned_lettings_log.id).scheme).to eq(absorbing_organisation.owned_schemes.first)
             expect(absorbing_organisation.owned_lettings_logs.find(owned_lettings_log.id).location).to eq(absorbing_organisation.owned_schemes.first.locations.first)
             expect(absorbing_organisation.owned_lettings_logs.find(owned_lettings_log_no_location.id).scheme).to eq(absorbing_organisation.owned_schemes.first)
-            expect(absorbing_organisation.owned_lettings_logs.find(owned_lettings_log_no_location.id).location).to eq(absorbing_organisation.owned_schemes.first.locations.first)
+            expect(absorbing_organisation.owned_lettings_logs.find(owned_lettings_log_no_location.id).location).to eq(nil)
           end
 
           it "rolls back if there's an error" do
@@ -409,6 +762,7 @@ RSpec.describe Merge::MergeOrganisationsService do
             merging_organisation.reload
             expect(absorbing_organisation.owned_schemes.count).to eq(0)
             expect(scheme.scheme_deactivation_periods.count).to eq(0)
+            expect(scheme.locations.first.location_deactivation_periods.count).to eq(0)
             expect(owned_lettings_log.owning_organisation).to eq(merging_organisation)
             expect(owned_lettings_log_no_location.owning_organisation).to eq(merging_organisation)
           end
@@ -747,25 +1101,65 @@ RSpec.describe Merge::MergeOrganisationsService do
           create(:lettings_log, startdate: Time.zone.tomorrow, managing_organisation: merging_organisation)
         end
 
-        it "combines organisation schemes and locations" do
+        it "logs the merged schemes" do
           expect(Rails.logger).to receive(:info).with("Merged users from fake org:")
           expect(Rails.logger).to receive(:info).with("\tDanny Rojas (#{merging_organisation.data_protection_officers.first.email})")
           expect(Rails.logger).to receive(:info).with("\tfake name (fake@email.com)")
           expect(Rails.logger).to receive(:info).with("New schemes from fake org:")
           expect(Rails.logger).to receive(:info).with(/\t#{scheme.service_name} \(S/)
+          expect(Rails.logger).to receive(:info).with(/\t#{deactivated_scheme.service_name} \(S/)
           merge_organisations_service.call
+        end
 
+        context "when combining organisation schemes and locations" do
+          before do
+            merge_organisations_service.call
             new_absorbing_organisation.reload
-          expect(new_absorbing_organisation.owned_schemes.count).to eq(1)
-          expect(new_absorbing_organisation.owned_schemes.first.service_name).to eq(scheme.service_name)
-          expect(new_absorbing_organisation.owned_schemes.first.old_id).to be_nil
-          expect(new_absorbing_organisation.owned_schemes.first.old_visible_id).to be_nil
-          expect(new_absorbing_organisation.owned_schemes.first.locations.count).to eq(1)
-          expect(new_absorbing_organisation.owned_schemes.first.locations.first.postcode).to eq(location.postcode)
-          expect(new_absorbing_organisation.owned_schemes.first.locations.first.old_id).to be_nil
-          expect(new_absorbing_organisation.owned_schemes.first.locations.first.old_visible_id).to be_nil
+            deactivated_scheme.reload
+            deactivated_location.reload
+            merging_organisation.reload
+          end
+
+          it "moves active schemes and locations to absorbing organisation" do
+            expect(new_absorbing_organisation.owned_schemes.count).to eq(2)
+            absorbed_active_scheme = new_absorbing_organisation.owned_schemes.find_by(service_name: scheme.service_name)
+            absorbed_active_location = absorbed_active_scheme.locations.find_by(postcode: location.postcode)
+            expect(absorbed_active_scheme.service_name).to eq(scheme.service_name)
+            expect(absorbed_active_scheme.old_id).to be_nil
+            expect(absorbed_active_scheme.old_visible_id).to be_nil
+            expect(absorbed_active_scheme.locations.count).to eq(2)
+            expect(absorbed_active_location.postcode).to eq(location.postcode)
+            expect(absorbed_active_location.old_id).to be_nil
+            expect(absorbed_active_location.old_visible_id).to be_nil
+          end
+
+          it "deactivates active schemes and locations on merging organisation" do
             expect(scheme.scheme_deactivation_periods.count).to eq(1)
             expect(scheme.scheme_deactivation_periods.first.deactivation_date.to_date).to eq(Time.zone.today)
+            expect(scheme.locations.find_by(postcode: location.postcode).location_deactivation_periods.count).to eq(1)
+            expect(scheme.locations.find_by(postcode: location.postcode).location_deactivation_periods.first.deactivation_date.to_date).to eq(Time.zone.today)
+          end
+
+          it "does not deactivate inactive locations on merging organisation again" do
+            expect(scheme.locations.find_by(postcode: deactivated_location.postcode).location_deactivation_periods.count).to eq(1)
+          end
+
+          it "moves inactive schemes and their locations to absorbing organisation" do
+            absorbed_inactive_scheme = new_absorbing_organisation.owned_schemes.find_by(service_name: deactivated_scheme.service_name)
+            expect(absorbed_inactive_scheme.scheme_deactivation_periods.count).to eq(1)
+            expect(absorbed_inactive_scheme.scheme_deactivation_periods.first.deactivation_date).to eq(merging_organisation.merge_date)
+            expect(absorbed_inactive_scheme.locations.count).to eq(1)
+            expect(absorbed_inactive_scheme.locations.first.location_deactivation_periods.count).to eq(0)
+            expect(deactivated_scheme.scheme_deactivation_periods.count).to eq(1)
+          end
+
+          it "moves inactive locations of active schemes to absorbing organisation" do
+            absorbed_active_scheme = new_absorbing_organisation.owned_schemes.find_by(service_name: scheme.service_name)
+            absorbed_inactive_location = absorbed_active_scheme.locations.find_by(postcode: deactivated_location.postcode)
+            expect(absorbed_active_scheme.scheme_deactivation_periods.count).to eq(0)
+            expect(absorbed_inactive_location.location_deactivation_periods.count).to eq(1)
+            expect(absorbed_inactive_location.location_deactivation_periods.first.deactivation_date).to eq(merging_organisation.merge_date)
+          end
         end
 
         it "moves relevant logs and assigns the new scheme" do
@@ -778,7 +1172,7 @@ RSpec.describe Merge::MergeOrganisationsService do
           expect(new_absorbing_organisation.owned_lettings_logs.find(owned_lettings_log.id).scheme).to eq(new_absorbing_organisation.owned_schemes.first)
           expect(new_absorbing_organisation.owned_lettings_logs.find(owned_lettings_log.id).location).to eq(new_absorbing_organisation.owned_schemes.first.locations.first)
           expect(new_absorbing_organisation.owned_lettings_logs.find(owned_lettings_log_no_location.id).scheme).to eq(new_absorbing_organisation.owned_schemes.first)
-          expect(new_absorbing_organisation.owned_lettings_logs.find(owned_lettings_log_no_location.id).location).to eq(new_absorbing_organisation.owned_schemes.first.locations.first)
+          expect(new_absorbing_organisation.owned_lettings_logs.find(owned_lettings_log_no_location.id).location).to eq(nil)
         end
 
         it "rolls back if there's an error" do
@@ -792,6 +1186,7 @@ RSpec.describe Merge::MergeOrganisationsService do
           merging_organisation.reload
           expect(new_absorbing_organisation.owned_schemes.count).to eq(0)
           expect(scheme.scheme_deactivation_periods.count).to eq(0)
+          expect(scheme.locations.first.location_deactivation_periods.count).to eq(0)
           expect(owned_lettings_log.owning_organisation).to eq(merging_organisation)
           expect(owned_lettings_log_no_location.owning_organisation).to eq(merging_organisation)
         end
@@ -917,21 +1312,66 @@ RSpec.describe Merge::MergeOrganisationsService do
             create(:lettings_log, startdate: Time.zone.tomorrow, managing_organisation: merging_organisation)
           end
 
-          it "combines organisation schemes and locations" do
+          it "logs the merged schemes" do
             expect(Rails.logger).to receive(:info).with("Merged users from fake org:")
             expect(Rails.logger).to receive(:info).with("\tDanny Rojas (#{merging_organisation.data_protection_officers.first.email})")
             expect(Rails.logger).to receive(:info).with("\tfake name (fake@email.com)")
             expect(Rails.logger).to receive(:info).with("New schemes from fake org:")
             expect(Rails.logger).to receive(:info).with(/\t#{scheme.service_name} \(S/)
+            expect(Rails.logger).to receive(:info).with(/\t#{deactivated_scheme.service_name} \(S/)
             merge_organisations_service.call
+          end
 
+          context "when combining organisation schemes and locations" do
+            before do
+              merge_organisations_service.call
               new_absorbing_organisation.reload
-            expect(new_absorbing_organisation.owned_schemes.count).to eq(1)
-            expect(new_absorbing_organisation.owned_schemes.first.service_name).to eq(scheme.service_name)
-            expect(new_absorbing_organisation.owned_schemes.first.locations.count).to eq(1)
-            expect(new_absorbing_organisation.owned_schemes.first.locations.first.postcode).to eq(location.postcode)
+              deactivated_scheme.reload
+              deactivated_location.reload
+              merging_organisation.reload
+            end
+
+            it "moves active schemes and locations to absorbing organisation" do
+              expect(new_absorbing_organisation.owned_schemes.count).to eq(2)
+
+              absorbed_active_scheme = new_absorbing_organisation.owned_schemes.find_by(service_name: scheme.service_name)
+              absorbed_active_location = absorbed_active_scheme.locations.find_by(postcode: location.postcode)
+              expect(absorbed_active_scheme.service_name).to eq(scheme.service_name)
+              expect(absorbed_active_scheme.old_id).to be_nil
+              expect(absorbed_active_scheme.old_visible_id).to be_nil
+              expect(absorbed_active_scheme.locations.count).to eq(2)
+              expect(absorbed_active_location.postcode).to eq(location.postcode)
+              expect(absorbed_active_location.old_id).to be_nil
+              expect(absorbed_active_location.old_visible_id).to be_nil
+            end
+
+            it "deactivates active schemes and locations on merging organisation" do
               expect(scheme.scheme_deactivation_periods.count).to eq(1)
               expect(scheme.scheme_deactivation_periods.first.deactivation_date.to_date).to eq(Time.zone.yesterday)
+              expect(scheme.locations.find_by(postcode: location.postcode).location_deactivation_periods.count).to eq(1)
+              expect(scheme.locations.find_by(postcode: location.postcode).location_deactivation_periods.first.deactivation_date.to_date).to eq(Time.zone.yesterday)
+            end
+
+            it "does not deactivate inactive locations on merging organisation again" do
+              expect(scheme.locations.find_by(postcode: deactivated_location.postcode).location_deactivation_periods.count).to eq(1)
+            end
+
+            it "moves inactive schemes and their locations to absorbing organisation" do
+              absorbed_inactive_scheme = new_absorbing_organisation.owned_schemes.find_by(service_name: deactivated_scheme.service_name)
+              expect(absorbed_inactive_scheme.scheme_deactivation_periods.count).to eq(1)
+              expect(absorbed_inactive_scheme.scheme_deactivation_periods.first.deactivation_date).to eq(merging_organisation.merge_date)
+              expect(absorbed_inactive_scheme.locations.count).to eq(1)
+              expect(absorbed_inactive_scheme.locations.first.location_deactivation_periods.count).to eq(0)
+              expect(deactivated_scheme.scheme_deactivation_periods.count).to eq(1)
+            end
+
+            it "moves inactive locations of active schemes to absorbing organisation" do
+              absorbed_active_scheme = new_absorbing_organisation.owned_schemes.find_by(service_name: scheme.service_name)
+              absorbed_inactive_location = absorbed_active_scheme.locations.find_by(postcode: deactivated_location.postcode)
+              expect(absorbed_active_scheme.scheme_deactivation_periods.count).to eq(0)
+              expect(absorbed_inactive_location.location_deactivation_periods.count).to eq(1)
+              expect(absorbed_inactive_location.location_deactivation_periods.first.deactivation_date).to eq(merging_organisation.merge_date)
+            end
           end
 
           it "moves relevant logs and assigns the new scheme" do
@@ -945,7 +1385,7 @@ RSpec.describe Merge::MergeOrganisationsService do
             expect(new_absorbing_organisation.owned_lettings_logs.find(owned_lettings_log.id).scheme).to eq(new_absorbing_organisation.owned_schemes.first)
             expect(new_absorbing_organisation.owned_lettings_logs.find(owned_lettings_log.id).location).to eq(new_absorbing_organisation.owned_schemes.first.locations.first)
             expect(new_absorbing_organisation.owned_lettings_logs.find(owned_lettings_log_no_location.id).scheme).to eq(new_absorbing_organisation.owned_schemes.first)
-            expect(new_absorbing_organisation.owned_lettings_logs.find(owned_lettings_log_no_location.id).location).to eq(new_absorbing_organisation.owned_schemes.first.locations.first)
+            expect(new_absorbing_organisation.owned_lettings_logs.find(owned_lettings_log_no_location.id).location).to eq(nil)
           end
 
           it "rolls back if there's an error" do
@@ -959,6 +1399,7 @@ RSpec.describe Merge::MergeOrganisationsService do
             merging_organisation.reload
             expect(new_absorbing_organisation.owned_schemes.count).to eq(0)
             expect(scheme.scheme_deactivation_periods.count).to eq(0)
+            expect(scheme.locations.first.location_deactivation_periods.count).to eq(0)
             expect(owned_lettings_log.owning_organisation).to eq(merging_organisation)
             expect(owned_lettings_log_no_location.owning_organisation).to eq(merging_organisation)
           end