Rename to person_id_crosswalk and add data types

models/core/core_models.yml

@@ -876,15 +876,15 @@ models:
       - name: tuva_last_run
         description: '{{ doc("tuva_last_run") }}'
 
-  - name: core__patient_crosswalk
+  - name: core__person_id_crosswalk
     description: >
-      The patient crosswalk table contains all source patient identifiers from 
+      The person id crosswalk table contains all source patient identifiers from 
       the input layer eligibility (claims) and patient (clinical).
     config:
       schema: |
         {%- if var('tuva_schema_prefix',None) != None -%}{{var('tuva_schema_prefix')}}_core
         {% else %}core{%- endif -%}
-      alias: patient_crosswalk
+      alias: person_id_crosswalk
       tags: core
       materialized: table
     tests:

models/core/final/core__person_id_crosswalk.sql

@@ -0,0 +1,49 @@
+{{ config(
+     enabled = var('claims_enabled',var('clinical_enabled',var('tuva_marts_enabled',False)))
+ | as_bool
+   )
+}}
+
+{% if var('clinical_enabled', var('tuva_marts_enabled',False)) == true and var('claims_enabled', var('tuva_marts_enabled',False)) == true -%}
+
+select distinct
+      cast(person_id as {{ dbt.type_string() }}) as person_id
+    , cast(null as {{ dbt.type_string() }}) as patient_id
+    , cast(member_id as {{ dbt.type_string() }}) as member_id
+    , cast(payer as {{ dbt.type_string() }}) as payer
+    , cast({{ quote_column('plan') }} as {{ dbt.type_string() }}) as {{ quote_column('plan') }}
+    , cast(data_source as {{ dbt.type_string() }}) as data_source
+from {{ ref('normalized_input__eligibility')}}
+union all
+select distinct
+      cast(person_id as {{ dbt.type_string() }}) as person_id
+    , cast(patient_id as {{ dbt.type_string() }}) as patient_id
+    , cast(null as {{ dbt.type_string() }}) as member_id
+    , cast(null as {{ dbt.type_string() }}) as payer
+    , cast(null as {{ dbt.type_string() }}) as {{ quote_column('plan') }}
+    , cast(data_source as {{ dbt.type_string() }}) as data_source
+from {{ ref('patient') }}
+
+{% elif var('clinical_enabled', var('tuva_marts_enabled',False)) == true -%}
+
+select distinct
+      cast(person_id as {{ dbt.type_string() }}) as person_id
+    , cast(patient_id as {{ dbt.type_string() }}) as patient_id
+    , cast(null as {{ dbt.type_string() }}) as member_id
+    , cast(null as {{ dbt.type_string() }}) as payer
+    , cast(null as {{ dbt.type_string() }}) as {{ quote_column('plan') }}
+    , cast(data_source as {{ dbt.type_string() }}) as data_source
+from {{ ref('patient') }}from {{ ref('patient') }}
+
+{% elif var('claims_enabled', var('tuva_marts_enabled',False)) == true -%}
+
+select distinct
+      cast(person_id as {{ dbt.type_string() }}) as person_id
+    , cast(null as {{ dbt.type_string() }}) as patient_id
+    , cast(member_id as {{ dbt.type_string() }}) as member_id
+    , cast(payer as {{ dbt.type_string() }}) as payer
+    , cast({{ quote_column('plan') }} as {{ dbt.type_string() }}) as {{ quote_column('plan') }}
+    , cast(data_source as {{ dbt.type_string() }}) as data_source
+from {{ ref('normalized_input__eligibility') }}
+
+{%- endif %}