POC-739 created dataset for HEI and Care and treatment registers

app/registers-framework/registers-db.js

@@ -0,0 +1,163 @@
+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) => {
+    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);
+`;
+
+      queryParts = {
+        sql: sql
+      };
+      return db.queryServer(queryParts, function (result) {
+        result.sql = sql;
+        resolve(result.result);
+      });
+    });
+  }
+};
+
+module.exports = defs;