Merge pull request #13 from onefact/add-sydhr-models

Add sydhr models
onefact · Oct 6, 2024 · 506cf86 · 506cf86
2 parents a7a6ad9 + b873f19
commit 506cf86
Show file tree

Hide file tree

Showing 9 changed files with 741 additions and 23 deletions.
diff --git a/data_processing/models/ahrq.gov/syh_dr/person/syhdr_commercial_person.sql b/data_processing/models/ahrq.gov/syh_dr/person/syhdr_commercial_person.sql
@@ -0,0 +1,5 @@
+select
+    *,
+    'commercial' as insurance
+from {{ source('syh_dr', 'commercial_person') }}
+
diff --git a/data_processing/models/ahrq.gov/syh_dr/person/syhdr_medicaid_person.sql b/data_processing/models/ahrq.gov/syh_dr/person/syhdr_medicaid_person.sql
@@ -0,0 +1,4 @@
+select
+    *,
+    'medicaid' as insurance
+from {{ source('syh_dr', 'medicaid_person') }}
diff --git a/data_processing/models/ahrq.gov/syh_dr/person/syhdr_medicare_person.sql b/data_processing/models/ahrq.gov/syh_dr/person/syhdr_medicare_person.sql
@@ -0,0 +1,4 @@
+select
+    *,
+    'medicare' as insurance
+from {{ source('syh_dr', 'medicare_person') }}
diff --git a/data_processing/models/ahrq.gov/syh_dr/person/syhdr_person.sql b/data_processing/models/ahrq.gov/syh_dr/person/syhdr_person.sql
@@ -0,0 +1,12 @@
+{{ config(
+    materialized = 'external',
+    location = '../data/ahrq.gov/syh_dr/syhdr_person.parquet'
+) }}
+
+{{ dbt_utils.union_relations(
+    relations = [
+        ref('syhdr_commercial_person'),
+        ref('syhdr_medicaid_person'),
+        ref('syhdr_medicare_person'),
+    ]
+) }}
diff --git a/data_processing/models/ahrq.gov/syh_dr/syhdr_inpatient.sql b/data_processing/models/ahrq.gov/syh_dr/syhdr_inpatient.sql
@@ -0,0 +1,29 @@
+{{ config(
+    materialized = 'external',
+    location = '../data/ahrq.gov/syh_dr/syhdr_inpatient.parquet'
+)}}
+
+select
+    *,
+    replace(replace(PLAN_PMT_AMT, '$', ''), ',', '')::float as plan_payment_amount,
+    replace(replace(PLAN_PMT_AMT, '$', ''), ',', '')::float as total_charge_amount,
+    'commercial' as insurance
+from {{ source('syh_dr', 'commercial_inpatient') }}
+
+union all
+
+select
+    *,
+    replace(replace(PLAN_PMT_AMT, '$', ''), ',', '')::float as plan_payment_amount,
+    replace(replace(PLAN_PMT_AMT, '$', ''), ',', '')::float as total_charge_amount,
+    'medicaid' as insurance
+from {{ source('syh_dr', 'medicaid_inpatient') }}
+
+union all
+
+select
+    *,
+    replace(replace(PLAN_PMT_AMT, '$', ''), ',', '')::float as plan_payment_amount,
+    replace(replace(PLAN_PMT_AMT, '$', ''), ',', '')::float as total_charge_amount,
+    'medicare' as insurance
+from {{ source('syh_dr', 'medicare_inpatient') }}
diff --git a/data_processing/models/ahrq.gov/syh_dr/syhdr_outpatient.sql b/data_processing/models/ahrq.gov/syh_dr/syhdr_outpatient.sql
@@ -0,0 +1,29 @@
+{{ config(
+    materialized = 'external',
+    location = '../data/ahrq.gov/syh_dr/syhdr_outpatient.parquet'
+)}}
+
+select
+    *,
+    replace(replace(PLAN_PMT_AMT, '$', ''), ',', '')::float as plan_payment_amount,
+    replace(replace(PLAN_PMT_AMT, '$', ''), ',', '')::float as total_charge_amount,
+    'commercial' as insurance
+from {{ source('syh_dr', 'commercial_outpatient') }}
+
+union all
+
+select
+    *,
+    replace(replace(PLAN_PMT_AMT, '$', ''), ',', '')::float as plan_payment_amount,
+    replace(replace(PLAN_PMT_AMT, '$', ''), ',', '')::float as total_charge_amount,
+    'medicaid' as insurance
+from {{ source('syh_dr', 'medicaid_outpatient') }}
+
+union all
+
+select
+    *,
+    replace(replace(PLAN_PMT_AMT, '$', ''), ',', '')::float as plan_payment_amount,
+    replace(replace(PLAN_PMT_AMT, '$', ''), ',', '')::float as total_charge_amount,
+    'medicare' as insurance
+from {{ source('syh_dr', 'medicare_outpatient') }}
diff --git a/data_processing/models/ahrq.gov/syh_dr/syhdr_pharmacy.sql b/data_processing/models/ahrq.gov/syh_dr/syhdr_pharmacy.sql
@@ -0,0 +1,29 @@
+{{ config(
+    materialized = 'external',
+    location = '../data/ahrq.gov/syh_dr/syhdr_pharmacy.parquet'
+)}}
+
+select
+    *,
+    replace(replace(PLAN_PMT_AMT, '$', ''), ',', '')::float as plan_payment_amount,
+    replace(replace(PLAN_PMT_AMT, '$', ''), ',', '')::float as total_charge_amount,
+    'commercial' as insurance
+from {{ source('syh_dr', 'commercial_pharmacy') }}
+
+union all
+
+select
+    *,
+    replace(replace(PLAN_PMT_AMT, '$', ''), ',', '')::float as plan_payment_amount,
+    replace(replace(PLAN_PMT_AMT, '$', ''), ',', '')::float as total_charge_amount,
+    'medicaid' as insurance
+from {{ source('syh_dr', 'medicaid_pharmacy') }}
+
+union all
+
+select
+    *,
+    replace(replace(PLAN_PMT_AMT, '$', ''), ',', '')::float as plan_payment_amount,
+    replace(replace(PLAN_PMT_AMT, '$', ''), ',', '')::float as total_charge_amount,
+    'medicare' as insurance
+from {{ source('syh_dr', 'medicare_pharmacy') }}
diff --git a/data_processing/models/ahrq.gov/syh_dr/syhdr_provider.sql b/data_processing/models/ahrq.gov/syh_dr/syhdr_provider.sql
@@ -0,0 +1,16 @@
+{{ config(
+    materialized = 'external',
+    location = '../data/ahrq.gov/syh_dr/syhdr_provider.parquet'
+)}}
+
+select
+    *,
+    'medicaid' as insurance
+from {{ source('syh_dr', 'medicaid_provider') }}
+
+union all
+
+select
+    *,
+    'medicare' as insurance
+from {{ source('syh_dr', 'medicare_provider') }}