Remove CSVImportable#process!

The intention is to make the import processing simpler to understand. Since
nearly all the processing happens in the sub-classes we just call that directly
from the ProcessImportJob.

Jira-Issue: MAV-6063

Author: misaka

app/models/concerns/csv_importable.rb

@@ -145,12 +145,6 @@ def processed?
     processed_at != nil
   end
 
-  def process!
-    process_import!
-
-    TeamCachedCounts.new(team).reset_import_issues!
-  end
-
   def remove!
     return if csv_removed?
     update!(csv_data: nil, csv_removed_at: Time.zone.now)

app/models/immunisation_import.rb

@@ -64,6 +64,36 @@ def records_count
     end
   end
 
+  def process!
+    raise "'rows' are empty. Call parse_rows! before processing." if rows.nil?
+
+    counts = count_columns.index_with(0)
+
+    @vaccination_records_batch = Set.new
+    @patients_batch = Set.new
+    @patient_locations_batch = Set.new
+    @archive_reasons_batch = Set.new
+
+    ActiveRecord::Base.transaction do
+      rows.each do |row|
+        count_column_to_increment = process_row(row)
+        counts[count_column_to_increment] += 1
+        bulk_import(rows: 100)
+      end
+
+      bulk_import(rows: :all)
+
+      postprocess_rows!
+
+      update_columns(processed_at: Time.zone.now, status: :processed, **counts)
+    end
+
+    post_commit!
+    UpdatePatientsFromPDS.call(patients, queue: :imports)
+
+    TeamCachedCounts.new(team).reset_import_issues!
+  end
+
   private
 
   # TODO: This is called by the `rows_are_valid` validation. Move it to it's own validation.
@@ -125,32 +155,6 @@ def process_row(row)
     count_column_to_increment
   end
 
-  def process_import!
-    counts = count_columns.index_with(0)
-
-    @vaccination_records_batch = Set.new
-    @patients_batch = Set.new
-    @patient_locations_batch = Set.new
-    @archive_reasons_batch = Set.new
-
-    ActiveRecord::Base.transaction do
-      rows.each do |row|
-        count_column_to_increment = process_row(row)
-        counts[count_column_to_increment] += 1
-        bulk_import(rows: 100)
-      end
-
-      bulk_import(rows: :all)
-
-      postprocess_rows!
-
-      update_columns(processed_at: Time.zone.now, status: :processed, **counts)
-    end
-
-    post_commit!
-    UpdatePatientsFromPDS.call(patients, queue: :imports)
-  end
-
   def bulk_import(rows: 100)
     return if rows != :all && @vaccination_records_batch.size < rows
 

app/models/patient_import.rb

@@ -34,7 +34,9 @@ def records_count
     changesets.from_file.count
   end
 
-  def process_import!
+  def process!
+    raise "'rows' are empty. Call parse_rows! before processing." if rows.nil?
+
     changesets =
       rows.each_with_index.map do |row, row_number|
         PatientChangeset.from_import_row(row:, import: self, row_number:)
@@ -54,6 +56,8 @@ def process_import!
     return if changesets_are_invalid?
 
     enqueue_review_jobs(self.changesets)
+
+    TeamCachedCounts.new(team).reset_import_issues!
   end
 
   def validate_pds_match_rate!