HIE Data Presantion at clinian page

.vscode/settings.json

@@ -0,0 +1,3 @@
+{
+    "java.configuration.updateBuildConfiguration": "interactive"
+}

README.md

@@ -1,2 +1,3 @@
-openmrs-module-rwandaemr
-===================================
+## openmrs-module-rwandaemr
+
+The module hold all source code from imbemr module

api/src/main/java/org/openmrs/module/rwandaemr/RwandaEmrConfig.java

@@ -9,25 +9,31 @@
  */
 package org.openmrs.module.rwandaemr;
 
+import lombok.Getter;
 import org.apache.commons.lang.StringUtils;
 import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
 import org.openmrs.EncounterType;
+import org.openmrs.Location;
 import org.openmrs.LocationAttributeType;
 import org.openmrs.PatientIdentifierType;
 import org.openmrs.PersonAttributeType;
+import org.openmrs.Provider;
 import org.openmrs.api.EncounterService;
 import org.openmrs.api.LocationService;
 import org.openmrs.api.PatientService;
 import org.openmrs.api.PersonService;
+import org.openmrs.api.ProviderService;
 import org.openmrs.module.initializer.api.InitializerService;
+import org.openmrs.module.rwandaemr.radiology.RadiologyConfig;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
 
 /**
  * Config used by the Rwanda EMR module
  */
 @Component
+@Getter
 public class RwandaEmrConfig {
 
 	protected Log log = LogFactory.getLog(getClass());
@@ -36,18 +42,25 @@ public class RwandaEmrConfig {
 	private final PatientService patientService;
 	private final LocationService locationService;
 	private final EncounterService encounterService;
+	private final ProviderService providerService;
 	private final InitializerService initializerService;
+	private final RadiologyConfig radiologyConfig;
 
-	public RwandaEmrConfig(@Autowired PatientService patientService,
+	public RwandaEmrConfig(
+						   @Autowired PatientService patientService,
 						   @Autowired PersonService personService,
 						   @Autowired LocationService locationService,
 						   @Autowired EncounterService encounterService,
-						   @Autowired InitializerService initializerService) {
+						   @Autowired ProviderService providerService,
+						   @Autowired InitializerService initializerService,
+						   @Autowired RadiologyConfig radiologyConfig) {
 		this.patientService = patientService;
 		this.personService = personService;
 		this.locationService = locationService;
 		this.encounterService = encounterService;
+		this.providerService = providerService;
 		this.initializerService = initializerService;
+		this.radiologyConfig = radiologyConfig;
 	}
 
 	public PatientIdentifierType getPrimaryCareIdentifierType() {
@@ -106,6 +119,18 @@ public LocationAttributeType getFosaId() {
 		return getLocationAttributeTypeByJsonKey("locationAttribute.fosaId.uuid");
 	}
 
+	public Location getUnknownLocation() {
+		return locationService.getLocation("Unknown location");
+	}
+
+	public Provider getUnknownProvider() {
+		return providerService.getUnknownProvider();
+	}
+
+	public Provider getProviderByIdentifier(String identifier) {
+		return providerService.getProviderByIdentifier(identifier);
+	}
+
 	public PatientIdentifierType getPatientIdentifierTypeByJsonKey(String jsonKey) {
 		String uuid = initializerService.getValueFromKey(jsonKey);
 		return getPatientIdentifierTypeByUuid(uuid);

api/src/main/java/org/openmrs/module/rwandaemr/RwandaEmrService.java

@@ -13,7 +13,10 @@
  */
 package org.openmrs.module.rwandaemr;
 
+import org.openmrs.Encounter;
 import org.openmrs.Location;
+import org.openmrs.Obs;
+import org.openmrs.Order;
 import org.openmrs.Patient;
 import org.openmrs.api.OpenmrsService;
 
@@ -26,6 +29,10 @@
 @Transactional
 public interface RwandaEmrService extends OpenmrsService {
 
+	List<Obs> getObsByOrder(Order order);
+
+	void saveEncounters(List<Encounter> encounters);
+
 	List<String> triggerSyncForPatient(Patient patient);
 
 	void updateVisitAndLoginLocations(List<Location> visitLocations, List<Location> loginLocations);

api/src/main/java/org/openmrs/module/rwandaemr/RwandaEmrServiceImpl.java

@@ -13,6 +13,7 @@
  */
 package org.openmrs.module.rwandaemr;
 
+import lombok.Setter;
 import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
 import org.openmrs.Encounter;
@@ -31,15 +32,17 @@
 import org.openmrs.Relationship;
 import org.openmrs.Visit;
 import org.openmrs.annotation.Authorized;
+import org.openmrs.api.EncounterService;
 import org.openmrs.api.LocationService;
 import org.openmrs.api.context.Context;
+import org.openmrs.api.db.hibernate.DbSessionFactory;
 import org.openmrs.api.db.hibernate.ImmutableOrderInterceptor;
 import org.openmrs.api.impl.BaseOpenmrsService;
 import org.openmrs.module.emrapi.EmrApiConstants;
 import org.openmrs.util.PrivilegeConstants;
 import org.openmrs.validator.ValidateUtil;
+import org.springframework.transaction.annotation.Transactional;
 
-import javax.transaction.Transactional;
 import java.util.ArrayList;
 import java.util.Calendar;
 import java.util.Date;
@@ -53,6 +56,28 @@ public class RwandaEmrServiceImpl extends BaseOpenmrsService implements RwandaEm
 
 	protected Log log = LogFactory.getLog(getClass());
 
+	@Setter
+	private DbSessionFactory sessionFactory;
+
+	@Setter
+	private EncounterService encounterService;
+
+	@Transactional(readOnly = true)
+	@Authorized(PrivilegeConstants.GET_OBS)
+	@SuppressWarnings("unchecked")
+	public List<Obs> getObsByOrder(Order order) {
+		String query = "select o from Obs o where o.order = :order and o.voided = false";
+		return sessionFactory.getCurrentSession().createQuery(query).setParameter("order", order).list();
+	}
+
+	@Transactional
+	@Authorized(PrivilegeConstants.ADD_ENCOUNTERS)
+	public void saveEncounters(List<Encounter> encounters) {
+		for (Encounter encounter : encounters) {
+			encounterService.saveEncounter(encounter);
+		}
+	}
+
 	@Transactional
 	@Authorized(PrivilegeConstants.EDIT_PATIENTS)
 	public List<String> triggerSyncForPatient(Patient patient) {

api/src/main/java/org/openmrs/module/rwandaemr/config/AuthenticationSetup.java

@@ -41,6 +41,7 @@ public static void configureAuthenticationSchemes() {
         whitelist.add("/authenticationui/login/login.page");
         whitelist.add("/appui/session/getLoginLocations.action");
         whitelist.add("/csrfguard");
+        whitelist.add("/spa/**/*");
         whitelist.add("*.js");
         whitelist.add("*.css");
         whitelist.add("*.gif");

api/src/main/java/org/openmrs/module/rwandaemr/config/EventSetup.java

@@ -1,11 +1,16 @@
 package org.openmrs.module.rwandaemr.config;
 
+import org.openmrs.Encounter;
+import org.openmrs.Obs;
 import org.openmrs.Patient;
 import org.openmrs.api.context.Context;
 import org.openmrs.event.Event;
-import org.openmrs.event.EventListener;
 import org.openmrs.module.rwandaemr.event.CreateInsurancePatientListener;
+import org.openmrs.module.rwandaemr.event.HieEventListener;
 import org.openmrs.module.rwandaemr.integration.UpdateClientRegistryPatientListener;
+import org.openmrs.module.rwandaemr.integration.UpdateShrEncounterListener;
+import org.openmrs.module.rwandaemr.integration.UpdateShrObsListener;
+import org.openmrs.module.rwandaemr.radiology.RadiologyOrderEventListener;
 
 /**
  * Setup event listeners
@@ -16,20 +21,43 @@ public static void setup() {
         Event.subscribe(Patient.class, Event.Action.CREATED.name(), getCreateInsurancePatientListener());
         Event.subscribe(Patient.class, Event.Action.CREATED.name(), getUpdateClientRegistryPatientListener());
         Event.subscribe(Patient.class, Event.Action.UPDATED.name(), getUpdateClientRegistryPatientListener());
+        /**
+         * Event for EMR to HIE encounter synchronization
+         */
+        Event.subscribe(Encounter.class, Event.Action.CREATED.name(), getUpdateShrEncounterEventListener());
+        /**
+         * Event for EMR to HIE OBS synchronization
+         */
+        Event.subscribe(Obs.class, Event.Action.CREATED.name(), getUpdateShrObservationEventListener());
+        getRadiologyOrderEventListener().setup();
     }
 
     public static void teardown() {
         Event.unsubscribe(Patient.class, Event.Action.CREATED, getCreateInsurancePatientListener());
         Event.unsubscribe(Patient.class, Event.Action.CREATED, getUpdateClientRegistryPatientListener());
         Event.unsubscribe(Patient.class, Event.Action.UPDATED, getUpdateClientRegistryPatientListener());
+        Event.unsubscribe(Encounter.class, Event.Action.CREATED, getUpdateShrEncounterEventListener());
+        Event.unsubscribe(Obs.class, Event.Action.CREATED, getUpdateShrObservationEventListener());
+        getRadiologyOrderEventListener().teardown();
     }
 
-    public static EventListener getCreateInsurancePatientListener() {
+    public static CreateInsurancePatientListener getCreateInsurancePatientListener() {
         return Context.getRegisteredComponents(CreateInsurancePatientListener.class).get(0);
     }
 
-    public static EventListener getUpdateClientRegistryPatientListener() {
+    public static UpdateClientRegistryPatientListener getUpdateClientRegistryPatientListener() {
         return Context.getRegisteredComponents(UpdateClientRegistryPatientListener.class).get(0);
     }
 
+    public static HieEventListener getUpdateShrEncounterEventListener(){
+        return Context.getRegisteredComponents(UpdateShrEncounterListener.class).get(0);
+    }
+
+    public static HieEventListener getUpdateShrObservationEventListener(){
+        return Context.getRegisteredComponents(UpdateShrObsListener.class).get(0);
+    }
+    public static RadiologyOrderEventListener getRadiologyOrderEventListener() {
+        return Context.getRegisteredComponents(RadiologyOrderEventListener.class).get(0);
+    }
+
 }

api/src/main/java/org/openmrs/module/rwandaemr/event/CreateInsurancePatientListener.java

@@ -109,7 +109,7 @@ public void handlePatient(String patientUuid, MapMessage mapMessage) {
 				Admission admission = new Admission();
 				admission.setAdmissionDate(new Date());
 				admission.setInsurancePolicy(policy);
-				admission.setIsAdmitted(true);
+				admission.setIsAdmitted(false);
 				admission.setCreator(Context.getAuthenticatedUser());
 				admission.setCreatedDate(new Date());
 				admission.setDiseaseType("Default Disease Type");

api/src/main/java/org/openmrs/module/rwandaemr/event/HieEventListener.java

@@ -0,0 +1,40 @@
+package org.openmrs.module.rwandaemr.event;
+
+import javax.jms.MapMessage;
+import javax.jms.Message;
+
+import org.apache.commons.lang.StringUtils;
+import org.apache.commons.logging.Log;
+import org.apache.commons.logging.LogFactory;
+import org.openmrs.api.context.Daemon;
+import org.openmrs.event.EventListener;
+import org.openmrs.module.DaemonToken;
+
+import lombok.Setter;
+
+public abstract class HieEventListener implements EventListener{
+    protected final Log log = LogFactory.getLog(getClass());
+    @Setter private static DaemonToken daemonToken;
+
+    @Override
+    public void onMessage(Message message){
+        try {
+            if(!(message instanceof MapMessage)){
+                throw new IllegalArgumentException("Message is not a MapMessage object");
+            }
+
+            MapMessage mapMessage = (MapMessage) message;
+            String uuid = mapMessage.getString("uuid");
+            if(StringUtils.isBlank(uuid)){
+                throw new IllegalArgumentException("Unable to retrieve encounter uuid from message: " + message);
+            }
+
+            Daemon.runInDaemonThread(() -> handle(uuid, mapMessage), daemonToken);
+        } catch(Exception e){
+            handleException(e);
+        }
+    }
+
+    public abstract void handle(String encounterUuid, MapMessage mapMessage);
+    public abstract void handleException(Exception e);
+}

api/src/main/java/org/openmrs/module/rwandaemr/integration/ClientRegistryPatientProvider.java

@@ -75,7 +75,7 @@ public ClientRegistryPatient fetchPatientFromClientRegistry(String identifier, S
 					data = EntityUtils.toString(entity);
 				} catch (Exception ignored) {
 				}
-				log.debug("Data: " + data);
+				// log.debug("Data: " + data);
 				if (statusCode != 200) {
 					throw new IllegalStateException("Http Status Code: " + statusCode + "; Response: " + data);
 				}

api/src/main/java/org/openmrs/module/rwandaemr/integration/IntegrationResponse.java

@@ -0,0 +1,24 @@
+/*
+ * This Source Code Form is subject to the terms of the Mozilla Public License,
+ * v. 2.0. If a copy of the MPL was not distributed with this file, You can
+ * obtain one at http://mozilla.org/MPL/2.0/. OpenMRS is also distributed under
+ * the terms of the Healthcare Disclaimer located at http://openmrs.org/license.
+ *
+ * Copyright (C) OpenMRS Inc. OpenMRS is a registered trademark and the OpenMRS
+ * graphic logo is a trademark of OpenMRS Inc.
+ */
+package org.openmrs.module.rwandaemr.integration;
+
+import lombok.Data;
+
+/**
+ * Represents a generic response to hitting an integration endpoint
+ */
+@Data
+public class IntegrationResponse {
+    private boolean enabled;
+    private boolean endpointAccessible;
+    private Integer responseCode;
+    private Object responseEntity;
+    private String errorMessage;
+}

api/src/main/java/org/openmrs/module/rwandaemr/integration/ShrEncounter.java

@@ -0,0 +1,59 @@
+package org.openmrs.module.rwandaemr.integration;
+
+import java.util.Date;
+import javax.validation.constraints.NotNull;
+import org.hl7.fhir.r4.model.Encounter;
+
+import lombok.Data;
+
+@Data
+public class ShrEncounter {
+
+    private final Encounter encounter;
+
+    public ShrEncounter(@NotNull Encounter encounter){
+        this.encounter = encounter;
+    }
+
+    public String getEncounterUuid(){
+        if(encounter.hasId()){
+            return encounter.getIdBase();
+        }
+        return null;
+    }
+
+    public Encounter.EncounterLocationComponent getEncounterLocation(){
+        if(encounter.hasLocation()){
+            return encounter.getLocationFirstRep();
+        }
+        return null;
+    }
+
+    public String getEncounterTypeString(){
+        if(encounter.hasType()){
+            return encounter.getTypeFirstRep().getCodingFirstRep().getCode();
+        }
+        return null;
+    }
+
+    public String getEncounterTypeDisplay(){
+        if(encounter.hasType()){
+            return encounter.getTypeFirstRep().getCodingFirstRep().getDisplay();
+        }
+        return null;
+    }
+
+    public Encounter.EncounterParticipantComponent getEncounterSubject(){
+        if(encounter.hasSubject()){
+            return encounter.getParticipantFirstRep();
+        }
+        return null;
+    }
+
+    public Date getEncounterDate(){
+        if(encounter.hasPeriod()){
+            return encounter.getPeriod().getStart();
+        }
+        return null;
+    }
+}