CNDE-1913: Preprocess service and proc changes for F_STD_PAGE_CASE

investigation-service/src/main/java/gov/cdc/etldatapipeline/investigation/repository/model/dto/Investigation.java

@@ -324,4 +324,56 @@ public class Investigation {
 
     @Column(name = "investigation_form_cd")
     private String investigationFormCd;
+
+    @Column(name = "ca_supervisor_of_phc_uid")
+    private Long caSupervisorOfPhcUid;
+
+    @Column(name = "closure_investgr_of_phc_uid")
+    private Long closureInvestgrOfPhcUid;
+
+    @Column(name = "dispo_fld_fupinvestgr_of_phc_uid")
+    private Long dispoFldFupinvestgrOfPhcUid;
+
+    @Column(name = "fld_fup_investgr_of_phc_uid")
+    private Long fldFupInvestgrOfPhcUid;
+
+    @Column(name = "fld_fup_prov_of_phc_uid")
+    private Long fldFupProvOfPhcUid;
+
+    @Column(name = "fld_fup_supervisor_of_phc_uid")
+    private Long fldFupSupervisorOfPhcUid;
+
+    @Column(name = "init_fld_fup_investgr_of_phc_uid")
+    private Long initFldFupInvestgrOfPhcUid;
+
+    @Column(name = "init_fup_investgr_of_phc_uid")
+    private Long initFupInvestgrOfPhcUid;
+
+    @Column(name ="init_interviewer_of_phc_uid")
+    private Long initInterviewerOfPhcUid;
+
+    @Column(name = "interviewer_of_phc_uid")
+    private Long interviewerOfPhcUid;
+
+    @Column(name = "surv_investgr_of_phc_uid")
+    private Long survInvestgrOfPhcUid;
+
+    @Column(name = "fld_fup_facility_of_phc_uid")
+    private Long fldFupFacilityOfPhcUid;
+
+    @Column(name = "org_as_hospital_of_delivery_uid")
+    private Long orgAsHospitalOfDeliveryUid;
+
+    @Column(name = "per_as_provider_of_delivery_uid")
+    private Long perAsProviderOfDeliveryUid;
+
+    @Column(name = "per_as_provider_of_obgyn_uid")
+    private Long perAsProviderOfObgynUid;
+
+    @Column(name = "per_as_provider_of_pediatrics_uid")
+    private Long perAsProviderOfPediatricsUid;
+
+    @Column(name = "org_as_reporter_uid")
+    private Long orgAsReporterUid;
+
 }

investigation-service/src/main/java/gov/cdc/etldatapipeline/investigation/repository/model/reporting/InvestigationReporting.java

@@ -114,4 +114,21 @@ public class InvestigationReporting {
     private Long caseCount;
     private String investigatorAssignedDatetime;
     private String investigationFormCd;
+    private Long caSupervisorOfPhcUid;
+    private Long closureInvestgrOfPhcUid;
+    private Long dispoFldFupinvestgrOfPhcUid;
+    private Long fldFupInvestgrOfPhcUid;
+    private Long fldFupProvOfPhcUid;
+    private Long fldFupSupervisorOfPhcUid;
+    private Long initFldFupInvestgrOfPhcUid;
+    private Long initFupInvestgrOfPhcUid;
+    private Long initInterviewerOfPhcUid;
+    private Long interviewerOfPhcUid;
+    private Long survInvestgrOfPhcUid;
+    private Long fldFupFacilityOfPhcUid;
+    private Long orgAsHospitalOfDeliveryUid;
+    private Long perAsProviderOfDeliveryUid;
+    private Long perAsProviderOfObgynUid;
+    private Long perAsProviderOfPediatricsUid;
+    private Long orgAsReporterUid;
 }

liquibase-service/src/main/resources/db/odse/routines/010-sp_investigation_event-002.sql

@@ -95,7 +95,7 @@ BEGIN
                results.hospitalized_ind,
                results.transmission_mode_cd,
                results.transmission_mode,
-               results.outcome_cd,
+             results.outcome_cd,
                results.die_frm_this_illness_ind,
                results.day_care_ind_cd,
                results.day_care_ind,
@@ -130,6 +130,23 @@ BEGIN
                investigation_act_entity.person_as_reporter_uid,
                investigation_act_entity.hospital_uid,
                investigation_act_entity.ordering_facility_uid,
+               investigation_act_entity.ca_supervisor_of_phc_uid,
+                investigation_act_entity.closure_investgr_of_phc_uid,
+                investigation_act_entity.dispo_fld_fupinvestgr_of_phc_uid,
+                investigation_act_entity.fld_fup_investgr_of_phc_uid,
+                investigation_act_entity.fld_fup_prov_of_phc_uid,
+                investigation_act_entity.fld_fup_supervisor_of_phc_uid,
+                investigation_act_entity.init_fld_fup_investgr_of_phc_uid,
+                investigation_act_entity.init_fup_investgr_of_phc_uid,
+                investigation_act_entity.init_interviewer_of_phc_uid,
+                investigation_act_entity.interviewer_of_phc_uid,
+                investigation_act_entity.surv_investgr_of_phc_uid,
+                investigation_act_entity.fld_fup_facility_of_phc_uid,
+                investigation_act_entity.org_as_hospital_of_delivery_uid,
+                investigation_act_entity.per_as_provider_of_delivery_uid,
+                investigation_act_entity.per_as_provider_of_obgyn_uid,
+                investigation_act_entity.per_as_provider_of_pediatrics_uid,
+                investigation_act_entity.org_as_reporter_uid,
                results.act_ids,
                results.investigation_observation_ids,
                results.person_participations,
@@ -767,12 +784,30 @@ BEGIN
                            on results.contact_inv_status_cd = cvg2.code and cvg2.code_set_nm = 'PHC_IN_STS'
                  LEFT OUTER JOIN nbs_odse.dbo.case_management cm WITH (NOLOCK) on results.public_health_case_uid = cm.public_health_case_uid
                  LEFT JOIN
-             (SELECT DISTINCT act_uid       AS                                                 nac_page_case_uid,
-                              MAX(last_chg_time) AS                                                  nac_last_chg_time,
-                              MIN(add_time)      AS                                                 nac_add_time,
-                              MAX(CASE WHEN type_cd = 'PerAsReporterOfPHC' THEN entity_uid END) person_as_reporter_uid,
-                              MAX(CASE WHEN type_cd = 'HospOfADT' THEN entity_uid END)          hospital_uid,
-                              MAX(CASE WHEN type_cd = 'OrgAsClinicOfPHC' THEN entity_uid END)   ordering_facility_uid
+             (SELECT DISTINCT
+                act_uid  AS  nac_page_case_uid,
+                MAX(last_chg_time) AS                                                  nac_last_chg_time,
+                MIN(add_time)      AS                                                 nac_add_time,
+                  MAX(CASE WHEN type_cd = 'PerAsReporterOfPHC' THEN entity_uid END) person_as_reporter_uid,
+                  MAX(CASE WHEN type_cd = 'HospOfADT' THEN entity_uid END)          hospital_uid,
+                  MAX(CASE WHEN type_cd = 'OrgAsClinicOfPHC' THEN entity_uid END)   ordering_facility_uid,
+                  MAX(CASE WHEN type_cd = 'CASupervisorOfPHC' THEN entity_uid END) ca_supervisor_of_phc_uid,
+                    MAX(CASE WHEN type_cd = 'ClosureInvestgrOfPHC' THEN entity_uid END) closure_investgr_of_phc_uid,
+                    MAX(CASE WHEN type_cd = 'DispoFldFupInvestgrOfPHC' THEN entity_uid END) dispo_fld_fupinvestgr_of_phc_uid,
+                    MAX(CASE WHEN type_cd = 'FldFupInvestgrOfPHC' THEN entity_uid END) fld_fup_investgr_of_phc_uid,
+                    MAX(CASE WHEN type_cd = 'FldFupProvOfPHC' THEN entity_uid END) fld_fup_prov_of_phc_uid,
+                    MAX(CASE WHEN type_cd = 'FldFupSupervisorOfPHC' THEN entity_uid END) fld_fup_supervisor_of_phc_uid,
+                    MAX(CASE WHEN type_cd = 'InitFldFupInvestgrOfPHC' THEN entity_uid END) init_fld_fup_investgr_of_phc_uid,
+                    MAX(CASE WHEN type_cd = 'InitFupInvestgrOfPHC' THEN entity_uid END) init_fup_investgr_of_phc_uid,
+                    MAX(CASE WHEN type_cd = 'InitInterviewerOfPHC' THEN entity_uid END) init_interviewer_of_phc_uid,
+                    MAX(CASE WHEN type_cd = 'InterviewerOfPHC' THEN entity_uid END) interviewer_of_phc_uid,
+                    MAX(CASE WHEN type_cd = 'SurvInvestgrOfPHC' THEN entity_uid END) surv_investgr_of_phc_uid,
+                    MAX(CASE WHEN type_cd = 'FldFupFacilityOfPHC' THEN entity_uid END) fld_fup_facility_of_phc_uid,
+                    MAX(CASE WHEN type_cd = 'OrgAsHospitalOfDelivery' THEN entity_uid END) org_as_hospital_of_delivery_uid,
+                    MAX(CASE WHEN type_cd = 'PerAsProviderOfDelivery' THEN entity_uid END) per_as_provider_of_delivery_uid,
+                    MAX(CASE WHEN type_cd = 'PerAsProviderOfOBGYN' THEN entity_uid END) per_as_provider_of_obgyn_uid,
+                    MAX(CASE WHEN type_cd = 'PerAsProvideroOfPediatrics' THEN entity_uid END) per_as_provider_of_pediatrics_uid,
+                    MAX(CASE WHEN type_cd = 'OrgAsReporterOfPHC' THEN entity_uid END) org_as_reporter_uid
               FROM nbs_act_entity nac WITH (NOLOCK)
               GROUP BY act_uid) AS investigation_act_entity
              ON investigation_act_entity.nac_page_case_uid = results.public_health_case_uid

liquibase-service/src/main/resources/db/rdb_modern/tables/007-create_nrt_investigation-005.sql

@@ -0,0 +1,73 @@
+IF EXISTS (SELECT 1 FROM sysobjects WHERE name = 'nrt_investigation' and xtype = 'U')
+BEGIN
+
+IF NOT EXISTS(SELECT 1 FROM sys.columns WHERE name = N'ca_supervisor_of_phc_uid' AND Object_ID = Object_ID(N'nrt_investigation'))
+BEGIN
+ALTER TABLE dbo.nrt_investigation ADD ca_supervisor_of_phc_uid bigint;
+END;
+IF NOT EXISTS(SELECT 1 FROM sys.columns WHERE name = N'closure_investgr_of_phc_uid' AND Object_ID = Object_ID(N'nrt_investigation'))
+BEGIN
+ALTER TABLE dbo.nrt_investigation ADD closure_investgr_of_phc_uid bigint;
+END;
+IF NOT EXISTS(SELECT 1 FROM sys.columns WHERE name = N'dispo_fld_fupinvestgr_of_phc_uid' AND Object_ID = Object_ID(N'nrt_investigation'))
+BEGIN
+ALTER TABLE dbo.nrt_investigation ADD dispo_fld_fupinvestgr_of_phc_uid bigint;
+END;
+IF NOT EXISTS(SELECT 1 FROM sys.columns WHERE name = N'fld_fup_investgr_of_phc_uid' AND Object_ID = Object_ID(N'nrt_investigation'))
+BEGIN
+ALTER TABLE dbo.nrt_investigation ADD fld_fup_investgr_of_phc_uid bigint;
+END;
+IF NOT EXISTS(SELECT 1 FROM sys.columns WHERE name = N'fld_fup_prov_of_phc_uid' AND Object_ID = Object_ID(N'nrt_investigation'))
+BEGIN
+ALTER TABLE dbo.nrt_investigation ADD fld_fup_prov_of_phc_uid bigint;
+END;
+IF NOT EXISTS(SELECT 1 FROM sys.columns WHERE name = N'fld_fup_supervisor_of_phc_uid' AND Object_ID = Object_ID(N'nrt_investigation'))
+BEGIN
+ALTER TABLE dbo.nrt_investigation ADD fld_fup_supervisor_of_phc_uid bigint;
+END;
+IF NOT EXISTS(SELECT 1 FROM sys.columns WHERE name = N'init_fld_fup_investgr_of_phc_uid' AND Object_ID = Object_ID(N'nrt_investigation'))
+BEGIN
+ALTER TABLE dbo.nrt_investigation ADD init_fld_fup_investgr_of_phc_uid bigint;
+END;
+IF NOT EXISTS(SELECT 1 FROM sys.columns WHERE name = N'init_fup_investgr_of_phc_uid' AND Object_ID = Object_ID(N'nrt_investigation'))
+BEGIN
+ALTER TABLE dbo.nrt_investigation ADD init_fup_investgr_of_phc_uid bigint;
+END;
+IF NOT EXISTS(SELECT 1 FROM sys.columns WHERE name = N'init_interviewer_of_phc_uid' AND Object_ID = Object_ID(N'nrt_investigation'))
+BEGIN
+ALTER TABLE dbo.nrt_investigation ADD init_interviewer_of_phc_uid bigint;
+END;
+IF NOT EXISTS(SELECT 1 FROM sys.columns WHERE name = N'interviewer_of_phc_uid' AND Object_ID = Object_ID(N'nrt_investigation'))
+BEGIN
+ALTER TABLE dbo.nrt_investigation ADD interviewer_of_phc_uid bigint;
+END;
+IF NOT EXISTS(SELECT 1 FROM sys.columns WHERE name = N'surv_investgr_of_phc_uid' AND Object_ID = Object_ID(N'nrt_investigation'))
+BEGIN
+ALTER TABLE dbo.nrt_investigation ADD surv_investgr_of_phc_uid bigint;
+END;
+IF NOT EXISTS(SELECT 1 FROM sys.columns WHERE name = N'fld_fup_facility_of_phc_uid' AND Object_ID = Object_ID(N'nrt_investigation'))
+BEGIN
+ALTER TABLE dbo.nrt_investigation ADD fld_fup_facility_of_phc_uid bigint;
+END;
+IF NOT EXISTS(SELECT 1 FROM sys.columns WHERE name = N'org_as_hospital_of_delivery_uid' AND Object_ID = Object_ID(N'nrt_investigation'))
+BEGIN
+ALTER TABLE dbo.nrt_investigation ADD org_as_hospital_of_delivery_uid bigint;
+END;
+IF NOT EXISTS(SELECT 1 FROM sys.columns WHERE name = N'per_as_provider_of_delivery_uid' AND Object_ID = Object_ID(N'nrt_investigation'))
+BEGIN
+ALTER TABLE dbo.nrt_investigation ADD per_as_provider_of_delivery_uid bigint;
+END;
+IF NOT EXISTS(SELECT 1 FROM sys.columns WHERE name = N'per_as_provider_of_obgyn_uid' AND Object_ID = Object_ID(N'nrt_investigation'))
+BEGIN
+ALTER TABLE dbo.nrt_investigation ADD per_as_provider_of_obgyn_uid bigint;
+END;
+IF NOT EXISTS(SELECT 1 FROM sys.columns WHERE name = N'per_as_provider_of_pediatrics_uid' AND Object_ID = Object_ID(N'nrt_investigation'))
+BEGIN
+ALTER TABLE dbo.nrt_investigation ADD per_as_provider_of_pediatrics_uid bigint;
+END;
+IF NOT EXISTS(SELECT 1 FROM sys.columns WHERE name = N'org_as_reporter_uid' AND Object_ID = Object_ID(N'nrt_investigation'))
+BEGIN
+ALTER TABLE dbo.nrt_investigation ADD org_as_reporter_uid bigint;
+END;
+
+END;