fix: force removing duplicate encounters

prefeitura-rio · Aug 28, 2024 · 0a04536 · 0a04536
1 parent e817de4
commit 0a04536
Show file tree

Hide file tree

Showing 2 changed files with 19 additions and 5 deletions.
diff --git a/models/marts/historico_clinico/mart_historico_clinico__episodio.sql b/models/marts/historico_clinico/mart_historico_clinico__episodio.sql
@@ -59,7 +59,14 @@ with
             -- Encounter Data
             merged_data.*,
         from merged_data
+    ),
+    ranked as (
+        select
+            *,
+            row_number() over (partition by id_atendimento) as rank
+        from fingerprinted
     )
 select 
     *,
-from fingerprinted
+from ranked
+where rank = 1
diff --git a/models/marts/historico_clinico_app/mart_historico_clinico_app__episodio.sql b/models/marts/historico_clinico_app/mart_historico_clinico_app__episodio.sql
@@ -58,10 +58,17 @@ with
             array(
                 select descricao from unnest(condicoes) where descricao is not null
             ) as active_cids,
-            struct(
-                profissional_saude_responsavel[safe_offset(0)].nome as name,
-                profissional_saude_responsavel[safe_offset(0)].especialidade as role
-            ) as responsible,
+            case
+                when 
+                    profissional_saude_responsavel[safe_offset(0)].nome is not null and
+                    profissional_saude_responsavel[safe_offset(0)].especialidade is not null
+                then 
+                    struct(
+                        profissional_saude_responsavel[safe_offset(0)].nome as name,
+                        profissional_saude_responsavel[safe_offset(0)].especialidade as role
+                    )
+                else null
+            end as responsible,
             motivo_atendimento as clinical_motivation,
             desfecho_atendimento as clinical_outcome,
             case