repointing equipe table

prefeitura-rio · Aug 29, 2024 · 54eaf46 · 54eaf46
1 parent 06df3d8
commit 54eaf46
Show file tree

Hide file tree

Showing 5 changed files with 21 additions and 29 deletions.
diff --git a/models/intermediate/core/int_cnes_web__profissional_sus_deduplicado.sql b/models/intermediate/core/int_cnes_web__profissional_sus_deduplicado.sql
@@ -1,11 +1,5 @@
-{{
-    config(
-        schema="saude_dados_mestres",
-        alias="profissional_saude_datasus_dedupl",
-        materialized="table",
-        tags=["weekly"],
-    )
-}}
+-- pega ultima versao da carga em cada id_sus e pega ultima versao de id_sus 
+-- para cada cns
 with unique_id_datasus as (
     select             
     id_codigo_sus,

diff --git a/models/intermediate/core/int_profissional_saude__vinculo_estabelecimento_serie_historica.sql b/models/intermediate/core/int_profissional_saude__vinculo_estabelecimento_serie_historica.sql
@@ -1,19 +1,11 @@
 -- cria serie historica de vinculacao nos estabelecimentos de saude da atenção
 -- primaria do rio de janeiro
-{{
-    config(
-        schema="saude_dados_mestres",
-        alias="int_nova_profissional_saude",
-        materialized="table",
-        tags=["weekly"],
-    )
-}}
 with
     profissional_sus as (
         select
             sus.nome,
             sus.cns,
-            sus.data_atualizacao
+            sus.data_atualizacao,
             array_codigo_sus,
         from {{ ref("int_cnes_web__profissional_sus_deduplicado") }} as sus
         where cns != ""
@@ -68,7 +60,7 @@ with
     select
     p.data_registro,
     p.id_estabelecimento_cnes as id_cnes,
-    cod_sus.array_codigo_sus as profissional_codigo_sus,
+    profissional_sus.array_codigo_sus as id_codigo_sus,
     p.profissional_cns,
     p.profissional_nome,
     vinculacao.descricao as vinculacao,
@@ -92,6 +84,5 @@ left join
 left join
     (select * from vinculo where ordenacao = 1) as vinculacao
     on p.id_vinculacao = vinculacao.id_vinculacao
-left join
-    (select * from profissional_sus) as cod_sus
-    on p.profissional_cns = cod_sus.cns
+left join profissional_sus
+    on p.profissional_cns = profissional_sus.cns
diff --git a/models/marts/core/dimensions/_dimensions_schema.yml b/models/marts/core/dimensions/_dimensions_schema.yml
@@ -370,9 +370,6 @@ models:
       - name: id_profissional_sus
         description: Código SUS do profissional
         data_type: string
-        tests:
-          - unique:
-              name: core__dim_profissional_saude__id_ine__unique
       - name: cpf
         description: CPF do profissional
         data_type: string
@@ -383,6 +380,9 @@ models:
         data_type: string
         policy_tags:
           - '{{ var ("TAG_CNS") }}'
+        tests:
+          - unique:
+              name: core__dim_profissional_saude__cns__unique
       - name: nome
         description: Nome do profissional de saúde.
         data_type: string

diff --git a/models/marts/core/dimensions/dim_equipe.sql b/models/marts/core/dimensions/dim_equipe.sql
@@ -10,7 +10,14 @@ with
         select * from {{ ref("raw_datasus__cbo") }}
     ),
     profissionais_mestre as (
-        select * from {{ ref("dim_profissional_saude") }} 
+        select 
+        cpf,
+        cns,
+        nome,
+        cbo,
+        conselho,
+        id_sus
+        from {{ ref("dim_profissional_saude") }}, unnest(id_profissional_sus) as id_sus
     ),
     profissionais_enriquecido as (
         select
@@ -52,7 +59,7 @@ with
                 order by equipe_p.data_particao desc
             ) as ordenacao
         from {{ ref("raw_cnes_web__equipe_profissionais") }} as equipe_p
-        inner join profissionais_mestre on profissionais_mestre.id_profissional_sus = equipe_p.id_profissional_sus 
+        inner join profissionais_mestre on profissionais_mestre.id_sus = equipe_p.id_profissional_sus 
         left join cbo on cbo.id_cbo = equipe_p.id_cbo
         where id_municipio = '330455'
 

diff --git a/models/marts/core/dimensions/dim_profissional_saude.sql b/models/marts/core/dimensions/dim_profissional_saude.sql
@@ -10,7 +10,7 @@
 with
     estabelecimentos as (select distinct id_cnes from {{ ref("dim_estabelecimento") }}),
     alocacao as (
-        select profissional_codigo_sus, 
+        select id_sus as profissional_codigo_sus, 
         id_cbo, 
         cbo, 
         id_cbo_familia, 
@@ -19,7 +19,7 @@ with
         id_registro_conselho
         from
             {{ ref("int_profissional_saude__vinculo_estabelecimento_serie_historica") }}
-            as v
+            as v, unnest(id_codigo_sus) as id_sus
         inner join estabelecimentos on estabelecimentos.id_cnes = v.id_cnes
         where
             data_registro = (
@@ -78,7 +78,7 @@ select
     profissionais_datasus.nome,
     cbo_agg.cbo,
     conselho_agg.conselho,
-    array_agg(profissionais_datasus.id_codigo_sus) as id_profissional_sus
+    array_agg(distinct profissionais_datasus.id_codigo_sus ignore nulls) as id_profissional_sus
 from profissionais_datasus
 left join
     cpf_profissionais