Poc 739

app/facility-mappings/registers.js

@@ -0,0 +1,20 @@
+var db = require('../../etl-db');
+
+var defs = {
+  getPrEPRegisterData: (params) => {
+    return new Promise((resolve, reject) => {
+      let queryParts = {};
+      let sql =
+        'SELECT l.name as location_name, fps.encounter_id, pi.identifier AS PrEP_Number, pi2.identifier AS National_ID, pi3.identifier AS NUPI, fps.encounter_datetime AS Date_Of_Visit, EXTRACT(YEAR FROM fps.encounter_datetime) - EXTRACT(YEAR FROM fps.birthdate) - CASE WHEN (EXTRACT(MONTH FROM fps.encounter_datetime) < EXTRACT(MONTH FROM fps.birthdate)) OR (EXTRACT(MONTH FROM fps.encounter_datetime) = EXTRACT(MONTH FROM fps.birthdate) AND EXTRACT(DAY FROM fps.encounter_datetime) < EXTRACT(DAY FROM fps.birthdate)) THEN 1 ELSE 0 END Age, fps.gender AS Sex, fps.population_type, NULL AS client_prep_status, NULL AS prep_method, CASE WHEN COALESCE(fps.hiv_rapid_test_result) = 664 THEN "N" WHEN COALESCE(fps.hiv_rapid_test_result) = 703 THEN "P" END AS HIV_result, NULL AS with_STI, COALESCE(fps.initiation_reason, fps.discontinued_reason) AS remarks FROM etl.flat_prep_summary_v1_1 fps LEFT JOIN amrs.location l ON l.location_id = fps.location_id LEFT JOIN amrs.patient_identifier pi ON fps.person_id = pi.patient_id AND pi.identifier_type = 44 LEFT JOIN amrs.patient_identifier pi2 ON fps.person_id = pi2.patient_id AND pi2.identifier_type = 5 LEFT JOIN amrs.patient_identifier pi3 ON fps.person_id = pi3.patient_id AND pi3.identifier_type = 45 WHERE DATE(fps.encounter_datetime)= "2024-01-02" AND fps.location_id in (1,13,14)';
+      queryParts = {
+        sql: sql
+      };
+      return db.queryServer(queryParts, function (result) {
+        result.sql = sql;
+        resolve(result.result);
+      });
+    });
+  }
+};
+
+module.exports = defs;

app/lab-integration/utils/poc-eid-payload-helper.js

@@ -55,6 +55,7 @@
               lab: '',
               amrs_location: getLocation(payload, 'mrsId')
             };
+            console.log('DNAPCR PAYLOAD: ', eidPayload);
             break;
           case 'CD4':
             eidPayload = {

app/registers-framework/registers-db.js

@@ -0,0 +1,164 @@
+var db = require('../../etl-db');
+
+var defs = {
+  getHeiDetails: (params) => {
+    return new Promise((resolve, reject) => {
+      let queryParts = {};
+      let sql = `
+    SELECT 
+        fhi.person_id, 
+        fhi.date_enrolled, 
+        fhi.birth_date, 
+        fhi.gender, 
+        CONCAT(p.given_name, ' ', p.middle_name, ' ', p.family_name) AS Infant_name, 
+        l.name AS Location, 
+        pi1.identifier AS Birth_Certificate_number, 
+        pi2.identifier AS AMRS_Number, 
+        pi3.identifier AS HEI_ID, 
+        pi4.identifier AS NUPI, 
+        pa.value AS parent_name, 
+        pa2.value AS Phone_Number, 
+        fhi.initial_hiv_dna_pcr_order_date, 
+        FLOOR(DATEDIFF(fhi.initial_hiv_dna_pcr_order_date, fhi.birth_date) / 7) AS age_in_weeks_on_first_pcr, 
+        fhi.hiv_dna_pcr_1_date AS first_pcr_date, 
+        CASE 
+            WHEN COALESCE(fhi.hiv_dna_pcr_resulted, fhi.hiv_dna_pcr_1) = 664 THEN 'N' 
+            WHEN COALESCE(fhi.hiv_dna_pcr_resulted, fhi.hiv_dna_pcr_1) = 703 THEN 'P' 
+        END AS results_pcr_first_pcr, 
+        (EXTRACT(YEAR FROM fhi.hiv_dna_pcr_2_date) - EXTRACT(YEAR FROM fhi.birth_date)) * 12 + 
+        (EXTRACT(MONTH FROM fhi.hiv_dna_pcr_2_date) - EXTRACT(MONTH FROM fhi.birth_date)) AS age_in_months_on_second_pcr, 
+        fhi.hiv_dna_pcr_2_date AS second_pcr_date, 
+        CASE 
+            WHEN COALESCE(fhi.hiv_dna_pcr_2) = 664 THEN 'N' 
+            WHEN COALESCE(fhi.hiv_dna_pcr_2) = 703 THEN 'P' 
+        END AS results_pcr_second_pcr, 
+        (EXTRACT(YEAR FROM fhi.hiv_dna_pcr_3_date) - EXTRACT(YEAR FROM fhi.birth_date)) * 12 + 
+        (EXTRACT(MONTH FROM fhi.hiv_dna_pcr_3_date) - EXTRACT(MONTH FROM fhi.birth_date)) AS age_in_months_on_third_pcr, 
+        fhi.hiv_dna_pcr_3_date AS third_pcr_date, 
+        CASE 
+            WHEN COALESCE(fhi.hiv_dna_pcr_3) = 664 THEN 'N' 
+            WHEN COALESCE(fhi.hiv_dna_pcr_3) = 703 THEN 'P' 
+        END AS results_pcr_third_pcr, 
+        (EXTRACT(YEAR FROM fhi.hiv_dna_pcr_4_date) - EXTRACT(YEAR FROM fhi.birth_date)) * 12 + 
+        (EXTRACT(MONTH FROM fhi.hiv_dna_pcr_4_date) - EXTRACT(MONTH FROM fhi.birth_date)) AS age_in_months_on_confirm_pcr, 
+        fhi.hiv_dna_pcr_4_date AS confirm_pcr_date, 
+        CASE 
+            WHEN COALESCE(fhi.hiv_dna_pcr_4) = 664 THEN 'N' 
+            WHEN COALESCE(fhi.hiv_dna_pcr_4) = 703 THEN 'P' 
+        END AS results_confirm_pcr, 
+        (EXTRACT(YEAR FROM fhi.antibody_screen_1_date) - EXTRACT(YEAR FROM fhi.birth_date)) * 12 + 
+        (EXTRACT(MONTH FROM fhi.antibody_screen_1_date) - EXTRACT(MONTH FROM fhi.birth_date)) AS age_in_months_on_first_antibody, 
+        fhi.antibody_screen_1_date AS first_antibody_date, 
+        CASE 
+            WHEN COALESCE(fhi.antibody_screen_1) = 664 THEN 'N' 
+            WHEN COALESCE(fhi.antibody_screen_1) = 703 THEN 'P' 
+        END AS results_first_antibody, 
+        (EXTRACT(YEAR FROM fhi.antibody_screen_2_date) - EXTRACT(YEAR FROM fhi.birth_date)) * 12 + 
+        (EXTRACT(MONTH FROM fhi.antibody_screen_2_date) - EXTRACT(MONTH FROM fhi.birth_date)) AS age_in_months_on_second_antibody, 
+        fhi.antibody_screen_2_date AS second_antibody_date, 
+        CASE 
+            WHEN fhi.antibody_screen_2 = 664 THEN 'N' 
+            WHEN fhi.antibody_screen_2 = 703 THEN 'P' 
+        END AS results_second_antibody, 
+        CASE 
+            WHEN fhi.infant_feeding_method IN (5, 15, 6, 9) THEN 'BF' 
+            WHEN fhi.infant_feeding_method IN (17, 8, 3) THEN 'NBF' 
+        END AS infant_feeding, 
+        CASE 
+            WHEN fhi.hei_outcome = 1 THEN 'Infected' 
+            WHEN fhi.hei_outcome = 2 THEN 'Uninfected' 
+            WHEN fhi.hei_outcome = 3 THEN 'Lost to Follow' 
+            WHEN fhi.hei_outcome = 4 THEN 'Transfer Out' 
+            WHEN fhi.hei_outcome = 5 THEN 'Dead' 
+            WHEN fhi.hei_outcome = 6 THEN 'f' 
+        END AS hei_outcome 
+    FROM 
+        etl.flat_hei_summary fhi 
+        LEFT JOIN amrs.person_name p ON p.person_id = fhi.person_id 
+        LEFT JOIN amrs.location l ON l.location_id = fhi.location_id 
+        LEFT JOIN amrs.patient_identifier pi1 ON pi1.patient_id = fhi.person_id AND pi1.identifier_type = 46 
+        LEFT JOIN amrs.patient_identifier pi2 ON pi2.patient_id = fhi.person_id AND pi2.identifier_type = 8 
+        LEFT JOIN amrs.patient_identifier pi3 ON pi3.patient_id = fhi.person_id AND pi3.identifier_type = 38 
+        LEFT JOIN amrs.patient_identifier pi4 ON pi4.patient_id = fhi.person_id AND pi4.identifier_type = 45 
+        LEFT JOIN amrs.person_attribute pa ON pa.person_id = fhi.person_id AND pa.person_attribute_type_id = 12 
+        LEFT JOIN amrs.person_attribute pa2 ON pa2.person_id = fhi.person_id AND pa2.person_attribute_type_id = 10 
+    WHERE 
+        DATE_FORMAT(fhi.birth_date, '%Y-%m') = '2023-04' 
+        AND fhi.location_id IN (315) 
+    GROUP BY 
+        fhi.person_id
+`;
+
+      queryParts = {
+        sql: sql
+      };
+      return db.queryServer(queryParts, function (result) {
+        result.sql = sql;
+        resolve(result.result);
+      });
+    });
+  },
+  getCareTreatmentDetails: (params) => {
+    console.log('CareNATreatment: ', params);
+    return new Promise((resolve, reject) => {
+      let queryParts = {};
+      let sql = `
+      SELECT 
+      fhs.encounter_datetime AS DATE,
+      pi.identifier AS National_ID,
+      pi3.identifier AS NUPI,
+      pi2.identifier AS CCC_Number,
+      EXTRACT(YEAR FROM fhs.encounter_datetime) - EXTRACT(YEAR FROM p.birthdate) - CASE
+          WHEN
+              (EXTRACT(MONTH FROM fhs.encounter_datetime) < EXTRACT(MONTH FROM p.birthdate))
+                  OR (EXTRACT(MONTH FROM fhs.encounter_datetime) = EXTRACT(MONTH FROM p.birthdate)
+                  AND EXTRACT(DAY FROM fhs.encounter_datetime) < EXTRACT(DAY FROM p.birthdate))
+          THEN
+              1
+          ELSE 0
+      END AS Age,
+      CASE
+          WHEN DATE(fhs.encounter_datetime) = DATE(fhs.hiv_start_date) THEN 1
+          ELSE 0
+      END AS started_on_art,
+      fhs.tb_screen as screened_for_tb,
+      CASE
+          WHEN DATE(fhs.encounter_datetime) = DATE(fhs.ipt_start_date) THEN 1
+          ELSE 0
+      END AS started_on_tpt, 
+      null as Dsd_status,
+      null as Dsd_type,
+      null as remarks
+  FROM
+      etl.flat_hiv_summary_v15b fhs
+          INNER JOIN
+      amrs.person p ON p.person_id = fhs.person_id
+      left join 
+      amrs.location l on l.location_id and fhs.location_id
+          LEFT JOIN
+      amrs.patient_identifier pi ON pi.patient_id = fhs.person_id
+          AND pi.identifier_type = 5
+          LEFT JOIN
+      amrs.patient_identifier pi2 ON fhs.person_id = pi2.patient_id
+          AND pi2.identifier_type = 28
+          LEFT JOIN
+      amrs.patient_identifier pi3 ON fhs.person_id = pi3.patient_id
+          AND pi3.identifier_type = 45
+  WHERE
+     fhs.is_clinical_encounter=1
+      and DATE(fhs.encounter_datetime) = '2024-04-02'
+      and fhs.location_id in (315) group by fhs.person_id
+`;
+
+      queryParts = {
+        sql: sql
+      };
+      return db.queryServer(queryParts, function (result) {
+        result.sql = sql;
+        resolve(result.result);
+      });
+    });
+  }
+};
+
+module.exports = defs;

app/routes/register.route.js

@@ -0,0 +1,60 @@
+var authorizer = require('../../authorization/etl-authorizer');
+var privileges = authorizer.getAllPrivileges();
+var dbRegister = require('../registers-framework/registers-db');
+
+const routes = [
+  {
+    method: 'GET',
+    path: '/etl/hei-register',
+    config: {
+      plugins: {},
+      handler: function (request, reply) {
+        dbRegister
+          .getHeiDetails(request.query.p)
+          .then((result) => {
+            reply(result);
+          })
+          .catch((error) => {
+            reply(error);
+          });
+      },
+      description: 'List of facilities with MFL code',
+      notes: 'Returns facilities list',
+      tags: ['api'],
+      validate: {
+        options: {
+          allowUnknown: true
+        },
+        params: {}
+      }
+    }
+  },
+  {
+    method: 'GET',
+    path: '/etl/care-and-treatment-register',
+    config: {
+      plugins: {},
+      handler: function (request, reply) {
+        dbRegister
+          .getCareTreatmentDetails(request.query.p)
+          .then((result) => {
+            reply(result);
+          })
+          .catch((error) => {
+            reply(error);
+          });
+      },
+      description: 'List of facilities with MFL code',
+      notes: 'Returns facilities list',
+      tags: ['api'],
+      validate: {
+        options: {
+          allowUnknown: true
+        },
+        params: {}
+      }
+    }
+  }
+];
+
+exports.routes = (server) => server.route(routes);

app/routes/registers.route.js

@@ -0,0 +1,34 @@
+var authorizer = require('../../authorization/etl-authorizer');
+var privileges = authorizer.getAllPrivileges();
+var facilitymappings = require('../facility-mappings/registers');
+
+const routes = [
+  {
+    method: 'GET',
+    path: '/etl/prepregisterdata',
+    config: {
+      plugins: {},
+      handler: function (request, reply) {
+        facilitymappings
+          .getPrEPRegisterData(request.query)
+          .then((result) => {
+            reply(result);
+          })
+          .catch((error) => {
+            reply(error);
+          });
+      },
+      description: 'List of facilities with MFL code',
+      notes: 'Returns facilities list',
+      tags: ['api'],
+      validate: {
+        options: {
+          allowUnknown: true
+        },
+        params: {}
+      }
+    }
+  }
+];
+
+exports.routes = (server) => server.route(routes);