All Migration Script Consolidation

Gemfile

@@ -5,12 +5,11 @@ git_source(:github) { |repo| "https://github.com/#{repo}.git" }
 
 ruby '~> 3.2.0'
 
-
 # Gems for managing background jobs
+gem 'activejob-uniqueness'
+gem 'redis'
 gem 'sidekiq'
 gem 'sidekiq-cron'
-gem 'redis'
-gem 'activejob-uniqueness'
 
 # Bundle edge Rails instead: gem 'rails', github: 'rails/rails'
 gem 'rails', '~> 7.0.6'
@@ -63,7 +62,7 @@ gem 'his_emr_api_lab', '~> 2.0.9'
 gem 'parallel', '~> 1.20.1'
 gem 'time_difference'
 
-gem "audited"
+gem 'audited'
 
 group :development, :test do
   # Call 'byebug' anywhere in the code to stop execution and get a debugger console
@@ -91,7 +90,13 @@ gem 'concurrent-ruby', '= 1.3.4'
 # gems for reading excel and csv files
 gem 'roo', '~> 2.8'
 
-#gem for object matching
+# gem for object matching
 gem 'whitesimilarity'
 
 gem 'mongoid', '~> 9.0', '>= 9.0.6'
+
+# gems for centralized migration
+gem 'sys-cpu'
+gem 'sys-filesystem'
+gem 'sys-memory'
+gem 'sys-proctable'

README.md

@@ -13,6 +13,7 @@
     - [DDE](#dde)
       - [Configuration](#configuration-1)
       - [Enabling DDE](#enabling-dde)
+    - [EMR to MAHIS Migration](#emr_mahis_migration)
     - [Updating Metadata](#updating-metadata)
     - [EMC to POC](#emc-to-poc)
     - [AIT Intergration](#ait-intergration)
@@ -200,6 +201,16 @@ curl -X POST -H "Authorization: AiJViSpF3spb" -H "Content-Type: application/json
 }' "http://127.0.0.1:3000/api/v1/properties"
 ```
 
+### EMR_Mahis_Migration
+
+- Set database you would like to migrate into Mahis under centralized_source_db: in config/database.yml if not there copy from config/database.yml.example
+- Make sure MAHIS is up to date
+- Run the migrations script using:
+
+  ```bash
+  rails r bin/emr_api_to_mahis_data_migrator.rb
+  ```
+
 ### Updating Metadata
 
 - Facilities

app/controllers/api/v1/facilities_controller.rb

@@ -117,23 +117,18 @@ def search_params
             end
 
             def serialize_facility(facility)
-            {
-                id: facility.id,
-                code: facility.code,
-                name: facility.name,
-                display_name: facility.display_name,
-                type: facility.facility_type,
-                status: facility.status,
-                district: facility.district,
-                coordinates: facility.coordinates,
-                has_coordinates: facility.has_coordinates?,
-                created_at: facility.created_at,
-                updated_at: facility.updated_at
-            }
+                # the custom 'as_json' logic in the Location model.
+                facility.as_json(
+                    include: {
+                    location_attributes: {
+                        only: %i[location_attribute_id attribute_type_id value_reference]
+                    }
+                    }
+                )
             end
-
+                    
             def serialize_facilities(facilities)
-            facilities.map { |facility| serialize_facility(facility) }
+                facilities.map { |facility| serialize_facility(facility) }
             end
         end
     end

app/controllers/api/v1/location_attribute_controller.rb

@@ -0,0 +1,5 @@
+class Api::V1::LocationAttributeController < ApplicationController
+  def show
+    render json: LocationAttribute.where(location_id: params[:id])
+  end
+end

app/controllers/api/v1/locations_controller.rb

@@ -20,21 +20,35 @@ def index
         tag = params[:tag]
         city_village = params[:city_village]
 
-        locations = paginate(Location.order(:name))
+        # Eager load location_attributes to prevent N+1 queries
+        locations = paginate(Location.includes(:location_attributes).order(:name))
 
         locations = locations.where('name like ?', "%#{name}%") unless name.blank?
         locations = filter_locations_by_tag locations, tag if tag
 
         locations = locations.where('city_village like ?', "%#{city_village}%") unless city_village.blank?
 
-        render json: locations
+        # Pass 'include' option to trigger custom as_json and define fields
+        render json: locations, include: {
+          location_attributes: {
+            only: %i[location_attribute_id attribute_type_id value_reference]
+          }
+        }
       end
 
       # Retrieve single location by its id
       #
       # GET /locations/:id
       def show
-        render json: Facility.find_by(code: params[:id])
+        # Eager load location_attributes for the single record
+        location = Location.includes(:location_attributes).find_by(location_id: params[:id])
+
+        # Pass 'include' option to trigger custom as_json and define fields
+        render json: location, include: {
+          location_attributes: {
+            only: %i[location_attribute_id attribute_type_id value_reference]
+          }
+        }
       end
 
       # Retrieve the current configured facility

app/controllers/application_controller.rb

@@ -38,11 +38,12 @@ def authenticate
     end
 
     User.current = user
+    Location.current = user.location
     true
   end
 
   def check_location
-    location_id = GlobalProperty.where(property: CURRENT_LOCATION_PROPERTY).first.property_value
+    location_id = GlobalProperty.unscoped.where(property: CURRENT_LOCATION_PROPERTY).first.property_value
     unless location_id
       render json: { errors: ['Current location not set'] }, status: :service_unavailable
       return false

app/jobs/sync/facility_sync_job.rb

@@ -4,7 +4,10 @@ class FacilitySyncJob < BaseSyncJob
 
     # Sync all facilities to CouchDB
     def perform(batch_size = 100)
-      sync_records_to_couchdb(Facility, 'facilities', batch_size)
+      sync_records_to_couchdb(Location, 'facilities', batch_size) do |model_class|
+        model_class.where(retired: false)
+                  .where.not(city_village: [nil, ""])
+      end
     end
 
     private
@@ -13,26 +16,18 @@ def prepare_document(facility)
       {
         "type" => "facility",
         "dde_activated" => false,
-        "facility_id" => facility.id,
-        "code" => facility.code,
+        "location_id" => facility.location_id,
         "name" => facility.name,
-        "common" => facility.common,
-        "ownership" => facility.ownership,
-        "facility_type" => facility.facility_type,
-        "status" => facility.status,
-        "regulatory_status" => facility.regulatory_status,
-        "district" => facility.district,
-        "date_opened" => facility.date_opened&.iso8601,
+        "district" => facility.city_village,
         "latitude" => facility.latitude,
         "longitude" => facility.longitude,
-        "created_at" => facility.created_at&.iso8601,
-        "updated_at" => facility.updated_at&.iso8601,
+        "date_created" => facility.date_created&.iso8601,
         "synced_at" => Time.current.iso8601
       }
     end
 
     def generate_document_id(facility)
-      "facility_#{facility.id}"
+      "facility_#{facility.location_id}"
     end
   end
 end

app/models/concerns/Locatable.rb

@@ -0,0 +1,43 @@
+# rubocop:disable Naming/FileName
+# frozen_string_literal: true
+
+# rubocop:disable Style/Documentation
+
+# this class is responsible for assigning a
+# site id to a record on save
+
+# when a table has a site id attached to it,
+# make sure its assigned during save
+# the site_id is collected from the logged in user who belongs to a location
+
+module Locatable
+  extend ActiveSupport::Concern
+
+  included do
+    if location_id_column?
+
+      belongs_to :location, foreign_key: :location_id, primary_key: :location_id, optional: true
+
+      default_scope { where(location_id: current_location_id) }
+      validates :location_id, presence: true
+      before_save :set_location_id
+
+    end
+  end
+
+  def set_location_id
+    self.location_id ||= current_location_id
+  end
+
+  class_methods do
+    def location_id_column?
+      column_names.include?('location_id')
+    end
+
+    def current_location_id
+      User.current&.location&.id || Location.current&.id
+    end
+  end
+end
+
+# rubocop:enable Style/Documentation, Naming/FileName

app/models/drug_ingredient.rb

@@ -6,6 +6,8 @@ class DrugIngredient < ActiveRecord::Base
   self.table_name = 'drug_ingredient'
   self.primary_keys = %i[ingredient_id concept_id]
 
+  include Locatable
+
   belongs_to :concept, foreign_key: :concept_id
   belongs_to :ingredient, foreign_key: :ingredient_id, class_name: 'Concept'
 

app/models/drug_order.rb

@@ -4,6 +4,8 @@ class DrugOrder < ApplicationRecord
   self.table_name = :drug_order
   self.primary_key = :order_id
 
+  include Locatable
+
   belongs_to :drug, foreign_key: :drug_inventory_id
   belongs_to :order, foreign_key: :order_id
 

app/models/encounter.rb

@@ -4,6 +4,8 @@ class Encounter < VoidableRecord
   self.table_name = :encounter
   self.primary_key = :encounter_id
 
+  include Locatable
+
   # before_save :before_save
   after_create :after_create
   after_void :after_void

app/models/global_property.rb

@@ -3,4 +3,6 @@
 class GlobalProperty < ApplicationRecord
   self.table_name = :global_property
   # self.primary_key = :property
+
+  include Locatable
 end