Skip to content

Adiciona scripts de validação pós transmissão de listas nominais #55

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
waltmatheus wants to merge 1 commit into
base: main
Choose a base branch
from
Open

Adiciona scripts de validação pós transmissão de listas nominais #55

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
187 changes: 187 additions & 0 deletions validacoes_listas_nominais/validacoes_pos_transmissao_lista_nomical_diabetes.sql
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -0,0 +1,187 @@
DO $$
DECLARE
r RECORD;
BEGIN
-- Criar a tabela se ela não existir
CREATE TEMP TABLE validacao_lista_nominal_diabeticos (
table_schema TEXT,
table_name text,
cont_linhas BIGINT,
cont_chaves_nominais_distintas BIGINT,
diabetes_denominador BIGINT,
cidadaos_autorreferidos BIGINT,
cidadaos_diagnosticados BIGINT,
numerador_diabetes BIGINT,
cidadaos_com_consulta BIGINT,
cidadaos_com_consulta_sem_diagnotico BIGINT
);

-- Itera sobre todas as tabelas 'lista_nominal_diabeticos' nos schemas com prefixo 'dados_nominais_'
FOR r IN
SELECT table_schema, table_name
FROM information_schema.tables
WHERE table_schema LIKE 'dados_nominais_%'
AND table_name in ('lista_nominal_diabeticos' ,'lista_nominal_diabeticos_obsoleta')
LOOP
-- Executa a query para cada tabela e insere os resultados na tabela de validação
EXECUTE format(
'WITH duplicados AS (
SELECT
%L AS table_schema,
%L AS table_name,
COUNT(1) AS cont_linhas,
COUNT(DISTINCT cidadao_nome||dt_nascimento) AS cont_chaves_nominais_distintas
FROM %I.%I
GROUP BY 1
)
-- Checar denominador e numerador
, dem_num AS (
SELECT
%L AS table_schema,
%L AS table_name,
count(DISTINCT l.cidadao_nome||l.dt_nascimento) AS diabetes_denominador,
count(DISTINCT CASE WHEN l.possui_diabetes_autoreferida IS TRUE THEN l.cidadao_nome||l.dt_nascimento END) AS cidadaos_autorreferidos,
count(DISTINCT CASE WHEN l.possui_diabetes_diagnosticada IS TRUE THEN l.cidadao_nome||l.dt_nascimento END) AS cidadaos_diagnosticados,
count(DISTINCT CASE
WHEN l.realizou_consulta_ultimos_6_meses IS TRUE AND realizou_solicitacao_hemoglobina_ultimos_6_meses IS TRUE
THEN l.cidadao_nome||l.dt_nascimento
END) AS numerador_diabetes,
count(DISTINCT CASE WHEN l.dt_consulta_mais_recente IS NOT NULL THEN l.cidadao_nome||l.dt_nascimento END) AS cidadaos_com_consulta,
count(DISTINCT CASE WHEN l.dt_consulta_mais_recente IS NOT NULL AND l.possui_diabetes_diagnosticada IS FALSE THEN l.cidadao_nome||l.dt_nascimento END) AS cidadaos_com_consulta_sem_diagnotico
FROM %I.%I l
GROUP BY 1
)
INSERT INTO validacao_lista_nominal_diabeticos (
table_schema,
table_name,
cont_linhas,
cont_chaves_nominais_distintas,
diabetes_denominador,
cidadaos_autorreferidos,
cidadaos_diagnosticados,
numerador_diabetes,
cidadaos_com_consulta,
cidadaos_com_consulta_sem_diagnotico
)
SELECT
tb1.table_schema,
tb1.table_name,
tb2.cont_linhas,
tb2.cont_chaves_nominais_distintas,
tb1.diabetes_denominador,
tb1.cidadaos_autorreferidos,
tb1.cidadaos_diagnosticados,
tb1.numerador_diabetes,
tb1.cidadaos_com_consulta,
tb1.cidadaos_com_consulta_sem_diagnotico
FROM dem_num tb1
JOIN duplicados tb2 ON tb1.table_schema = tb2.table_schema AND tb1.table_name = tb2.table_name;',
r.table_schema,r.table_name, r.table_schema, r.table_name,
r.table_schema,r.table_name, r.table_schema, r.table_name
);
END LOOP;
end; $$;


WITH
tabela_pivotada AS (
SELECT
table_schema AS schema_municipio,
SUM(CASE
WHEN table_name = 'lista_nominal_diabeticos_obsoleta' THEN cont_linhas
ELSE 0
END) AS cont_linhas_antes_da_alteracao,
SUM(CASE
WHEN table_name = 'lista_nominal_diabeticos' THEN cont_linhas
ELSE 0
END) AS cont_linhas_depois_da_alteracao,
SUM(CASE
WHEN table_name = 'lista_nominal_diabeticos_obsoleta' THEN cont_chaves_nominais_distintas
ELSE 0
END) AS cont_chaves_nominais_distintas_antes_da_alteracao,
SUM(CASE
WHEN table_name = 'lista_nominal_diabeticos' THEN cont_chaves_nominais_distintas
ELSE 0
END) AS cont_chaves_nominais_distintas_depois_da_alteracao,
SUM(CASE
WHEN table_name = 'lista_nominal_diabeticos_obsoleta' THEN diabetes_denominador
ELSE 0
END) AS diabetes_denominador_antes_da_alteracao,
SUM(CASE
WHEN table_name = 'lista_nominal_diabeticos' THEN diabetes_denominador
ELSE 0
END) AS diabetes_denominador_depois_da_alteracao,
SUM(CASE
WHEN table_name = 'lista_nominal_diabeticos_obsoleta' THEN numerador_diabetes
ELSE 0
END) AS numerador_diabetes_antes_da_alteracao,
SUM(CASE
WHEN table_name = 'lista_nominal_diabeticos' THEN numerador_diabetes
ELSE 0
END) AS numerador_diabetes_depois_da_alteracao,
SUM(CASE
WHEN table_name = 'lista_nominal_diabeticos_obsoleta' THEN cidadaos_autorreferidos
ELSE 0
END) AS cidadaos_autorreferidos_antes_da_alteracao,
SUM(CASE
WHEN table_name = 'lista_nominal_diabeticos' THEN cidadaos_autorreferidos
ELSE 0
END) AS cidadaos_autorreferidos_depois_da_alteracao,
SUM(CASE
WHEN table_name = 'lista_nominal_diabeticos_obsoleta' THEN cidadaos_diagnosticados
ELSE 0
END) AS cidadaos_diagnosticados_antes_da_alteracao,
SUM(CASE
WHEN table_name = 'lista_nominal_diabeticos' THEN cidadaos_diagnosticados
ELSE 0
END) AS cidadaos_diagnosticados_depois_da_alteracao,
SUM(CASE
WHEN table_name = 'lista_nominal_diabeticos_obsoleta' THEN cidadaos_com_consulta
ELSE 0
END) AS cidadaos_com_consulta_antes_da_alteracao,
SUM(CASE
WHEN table_name = 'lista_nominal_diabeticos' THEN cidadaos_com_consulta
ELSE 0
END) AS cidadaos_com_consulta_depois_da_alteracao,
SUM(CASE
WHEN table_name = 'lista_nominal_diabeticos_obsoleta' THEN cidadaos_com_consulta_sem_diagnotico
ELSE 0
END) AS cidadaos_com_consulta_sem_diagnotico_antes_da_alteracao,
SUM(CASE
WHEN table_name = 'lista_nominal_diabeticos' THEN cidadaos_com_consulta_sem_diagnotico
ELSE 0
END) AS cidadaos_com_consulta_sem_diagnotico_depois_da_alteracao
FROM validacao_lista_nominal_diabeticos
GROUP BY table_schema
ORDER BY table_schema
)
SELECT
schema_municipio,
cont_linhas_antes_da_alteracao,
cont_linhas_depois_da_alteracao,
(cont_linhas_antes_da_alteracao - cont_linhas_depois_da_alteracao) AS cont_linhas_diabetes_variacao,
cont_chaves_nominais_distintas_antes_da_alteracao,
cont_chaves_nominais_distintas_depois_da_alteracao,
(cont_chaves_nominais_distintas_antes_da_alteracao - cont_chaves_nominais_distintas_depois_da_alteracao) AS cont_chaves_nominais_distintas_diabetes_variacao,
diabetes_denominador_antes_da_alteracao,
diabetes_denominador_depois_da_alteracao,
(diabetes_denominador_antes_da_alteracao - diabetes_denominador_depois_da_alteracao) AS diabetes_denominador_variacao,
numerador_diabetes_antes_da_alteracao,
numerador_diabetes_depois_da_alteracao,
(numerador_diabetes_antes_da_alteracao - numerador_diabetes_depois_da_alteracao) AS numerador_diabetes_variacao,
cidadaos_autorreferidos_antes_da_alteracao,
cidadaos_autorreferidos_depois_da_alteracao,
(cidadaos_autorreferidos_antes_da_alteracao - cidadaos_autorreferidos_depois_da_alteracao) AS cidadaos_autorreferidos_variacao,
cidadaos_diagnosticados_antes_da_alteracao,
cidadaos_diagnosticados_depois_da_alteracao,
(cidadaos_diagnosticados_antes_da_alteracao - cidadaos_diagnosticados_depois_da_alteracao) AS cidadaos_diagnosticados_variacao,
cidadaos_com_consulta_antes_da_alteracao,
cidadaos_com_consulta_depois_da_alteracao,
(cidadaos_com_consulta_antes_da_alteracao - cidadaos_com_consulta_depois_da_alteracao) AS cidadaos_com_consulta_variacao,
cidadaos_com_consulta_sem_diagnotico_antes_da_alteracao,
cidadaos_com_consulta_sem_diagnotico_depois_da_alteracao,
(cidadaos_com_consulta_sem_diagnotico_antes_da_alteracao - cidadaos_com_consulta_sem_diagnotico_depois_da_alteracao) AS cidadaos_com_consulta_sem_diagnotico_variacao
FROM tabela_pivotada;



185 changes: 185 additions & 0 deletions validacoes_listas_nominais/validacoes_pos_transmissao_lista_nomical_hipertensao.sql
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -0,0 +1,185 @@
DO $$
DECLARE
r RECORD;
BEGIN
-- Criar a tabela se ela não existir
CREATE TEMP TABLE validacao_lista_nominal_hipertensos (
table_schema TEXT,
table_name text,
cont_linhas BIGINT,
cont_chaves_nominais_distintas BIGINT,
hipertensao_denominador BIGINT,
cidadaos_autorreferidos BIGINT,
cidadaos_diagnosticados BIGINT,
numerador_hipertensao BIGINT,
cidadaos_com_consulta BIGINT,
cidadaos_com_consulta_sem_diagnotico BIGINT
);

-- Itera sobre todas as tabelas 'lista_nominal_hipertensos' nos schemas com prefixo 'dados_nominais_'
FOR r IN
SELECT table_schema, table_name
FROM information_schema.tables
WHERE table_schema LIKE 'dados_nominais_%'
AND table_name in ('lista_nominal_hipertensos' ,'lista_nominal_hipertensos_obsoleta')
LOOP
-- Executa a query para cada tabela e insere os resultados na tabela de validação
EXECUTE format(
'WITH duplicados AS (
SELECT
%L AS table_schema,
%L AS table_name,
COUNT(1) AS cont_linhas,
COUNT(DISTINCT cidadao_nome||dt_nascimento) AS cont_chaves_nominais_distintas
FROM %I.%I
GROUP BY 1
)
-- Checar denominador e numerador
, dem_num AS (
SELECT
%L AS table_schema,
%L AS table_name,
count(DISTINCT l.cidadao_nome||l.dt_nascimento) AS hipertensao_denominador,
count(DISTINCT CASE WHEN l.possui_hipertensao_autorreferida IS TRUE THEN l.cidadao_nome||l.dt_nascimento END) AS cidadaos_autorreferidos,
count(DISTINCT CASE WHEN l.possui_hipertensao_diagnosticada IS TRUE THEN l.cidadao_nome||l.dt_nascimento END) AS cidadaos_diagnosticados,
count(DISTINCT CASE
WHEN l.realizou_consulta_ultimos_6_meses IS TRUE AND realizou_afericao_ultimos_6_meses IS TRUE
THEN l.cidadao_nome||l.dt_nascimento
END) AS numerador_hipertensao,
Comment on lines +27 to +48
Copy link
Copy Markdown

@coderabbitai coderabbitai bot Feb 6, 2025

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

⚠️ Potential issue

Correção: Qualificação completa do alias na condição CASE

Na definição do CASE para calcular numerador_hipertensao, a condição utiliza l.realizou_consulta_ultimos_6_meses IS TRUE corretamente, porém a segunda condição não está qualificada com o alias (realizou_afericao_ultimos_6_meses IS TRUE). É recomendado incluir o alias para evitar ambiguidade ou erro de coluna não encontrada.

-            WHEN l.realizou_consulta_ultimos_6_meses IS TRUE AND realizou_afericao_ultimos_6_meses IS TRUE 
+            WHEN l.realizou_consulta_ultimos_6_meses IS TRUE AND l.realizou_afericao_ultimos_6_meses IS TRUE
📝 Committable suggestion

‼️ IMPORTANT
Carefully review the code before committing. Ensure that it accurately replaces the highlighted code, contains no missing lines, and has no issues with indentation. Thoroughly test & benchmark the code to ensure it meets the requirements.

Suggested change
EXECUTE format(
'WITH duplicados AS (
SELECT
%L AS table_schema,
%L AS table_name,
COUNT(1) AS cont_linhas,
COUNT(DISTINCT cidadao_nome||dt_nascimento) AS cont_chaves_nominais_distintas
FROM %I.%I
GROUP BY 1
)
-- Checar denominador e numerador
, dem_num AS (
SELECT
%L AS table_schema,
%L AS table_name,
count(DISTINCT l.cidadao_nome||l.dt_nascimento) AS hipertensao_denominador,
count(DISTINCT CASE WHEN l.possui_hipertensao_autorreferida IS TRUE THEN l.cidadao_nome||l.dt_nascimento END) AS cidadaos_autorreferidos,
count(DISTINCT CASE WHEN l.possui_hipertensao_diagnosticada IS TRUE THEN l.cidadao_nome||l.dt_nascimento END) AS cidadaos_diagnosticados,
count(DISTINCT CASE
WHEN l.realizou_consulta_ultimos_6_meses IS TRUE AND realizou_afericao_ultimos_6_meses IS TRUE
THEN l.cidadao_nome||l.dt_nascimento
END) AS numerador_hipertensao,
EXECUTE format(
'WITH duplicados AS (
SELECT
%L AS table_schema,
%L AS table_name,
COUNT(1) AS cont_linhas,
COUNT(DISTINCT cidadao_nome||dt_nascimento) AS cont_chaves_nominais_distintas
FROM %I.%I
GROUP BY 1
)
-- Checar denominador e numerador
, dem_num AS (
SELECT
%L AS table_schema,
%L AS table_name,
count(DISTINCT l.cidadao_nome||l.dt_nascimento) AS hipertensao_denominador,
count(DISTINCT CASE WHEN l.possui_hipertensao_autorreferida IS TRUE THEN l.cidadao_nome||l.dt_nascimento END) AS cidadaos_autorreferidos,
count(DISTINCT CASE WHEN l.possui_hipertensao_diagnosticada IS TRUE THEN l.cidadao_nome||l.dt_nascimento END) AS cidadaos_diagnosticados,
count(DISTINCT CASE
WHEN l.realizou_consulta_ultimos_6_meses IS TRUE AND l.realizou_afericao_ultimos_6_meses IS TRUE
THEN l.cidadao_nome||l.dt_nascimento
END) AS numerador_hipertensao,

count(DISTINCT CASE WHEN l.dt_consulta_mais_recente IS NOT NULL THEN l.cidadao_nome||l.dt_nascimento END) AS cidadaos_com_consulta,
count(DISTINCT CASE WHEN l.dt_consulta_mais_recente IS NOT NULL AND l.possui_hipertensao_diagnosticada IS FALSE THEN l.cidadao_nome||l.dt_nascimento END) AS cidadaos_com_consulta_sem_diagnotico
FROM %I.%I l
GROUP BY 1
)
INSERT INTO validacao_lista_nominal_hipertensos (
table_schema,
table_name,
cont_linhas,
cont_chaves_nominais_distintas,
hipertensao_denominador,
cidadaos_autorreferidos,
cidadaos_diagnosticados,
numerador_hipertensao,
cidadaos_com_consulta,
cidadaos_com_consulta_sem_diagnotico
)
SELECT
tb1.table_schema,
tb1.table_name,
tb2.cont_linhas,
tb2.cont_chaves_nominais_distintas,
tb1.hipertensao_denominador,
tb1.cidadaos_autorreferidos,
tb1.cidadaos_diagnosticados,
tb1.numerador_hipertensao,
tb1.cidadaos_com_consulta,
tb1.cidadaos_com_consulta_sem_diagnotico
FROM dem_num tb1
JOIN duplicados tb2 ON tb1.table_schema = tb2.table_schema AND tb1.table_name = tb2.table_name;',
r.table_schema,r.table_name, r.table_schema, r.table_name,
r.table_schema,r.table_name, r.table_schema, r.table_name
);
END LOOP;
end; $$;


WITH
tabela_pivotada AS (
SELECT
table_schema AS schema_municipio,
SUM(CASE
WHEN table_name = 'lista_nominal_hipertensos_obsoleta' THEN cont_linhas
ELSE 0
END) AS cont_linhas_antes_da_alteracao,
SUM(CASE
WHEN table_name = 'lista_nominal_hipertensos' THEN cont_linhas
ELSE 0
END) AS cont_linhas_depois_da_alteracao,
SUM(CASE
WHEN table_name = 'lista_nominal_hipertensos_obsoleta' THEN cont_chaves_nominais_distintas
ELSE 0
END) AS cont_chaves_nominais_distintas_antes_da_alteracao,
SUM(CASE
WHEN table_name = 'lista_nominal_hipertensos' THEN cont_chaves_nominais_distintas
ELSE 0
END) AS cont_chaves_nominais_distintas_depois_da_alteracao,
SUM(CASE
WHEN table_name = 'lista_nominal_hipertensos_obsoleta' THEN hipertensao_denominador
ELSE 0
END) AS hipertensao_denominador_antes_da_alteracao,
SUM(CASE
WHEN table_name = 'lista_nominal_hipertensos' THEN hipertensao_denominador
ELSE 0
END) AS hipertensao_denominador_depois_da_alteracao,
SUM(CASE
WHEN table_name = 'lista_nominal_hipertensos_obsoleta' THEN numerador_hipertensao
ELSE 0
END) AS numerador_hipertensao_antes_da_alteracao,
SUM(CASE
WHEN table_name = 'lista_nominal_hipertensos' THEN numerador_hipertensao
ELSE 0
END) AS numerador_hipertensao_depois_da_alteracao,
SUM(CASE
WHEN table_name = 'lista_nominal_hipertensos_obsoleta' THEN cidadaos_autorreferidos
ELSE 0
END) AS cidadaos_autorreferidos_antes_da_alteracao,
SUM(CASE
WHEN table_name = 'lista_nominal_hipertensos' THEN cidadaos_autorreferidos
ELSE 0
END) AS cidadaos_autorreferidos_depois_da_alteracao,
SUM(CASE
WHEN table_name = 'lista_nominal_hipertensos_obsoleta' THEN cidadaos_diagnosticados
ELSE 0
END) AS cidadaos_diagnosticados_antes_da_alteracao,
SUM(CASE
WHEN table_name = 'lista_nominal_hipertensos' THEN cidadaos_diagnosticados
ELSE 0
END) AS cidadaos_diagnosticados_depois_da_alteracao,
SUM(CASE
WHEN table_name = 'lista_nominal_hipertensos_obsoleta' THEN cidadaos_com_consulta
ELSE 0
END) AS cidadaos_com_consulta_antes_da_alteracao,
SUM(CASE
WHEN table_name = 'lista_nominal_hipertensos' THEN cidadaos_com_consulta
ELSE 0
END) AS cidadaos_com_consulta_depois_da_alteracao,
SUM(CASE
WHEN table_name = 'lista_nominal_hipertensos_obsoleta' THEN cidadaos_com_consulta_sem_diagnotico
ELSE 0
END) AS cidadaos_com_consulta_sem_diagnotico_antes_da_alteracao,
SUM(CASE
WHEN table_name = 'lista_nominal_hipertensos' THEN cidadaos_com_consulta_sem_diagnotico
ELSE 0
END) AS cidadaos_com_consulta_sem_diagnotico_depois_da_alteracao
FROM validacao_lista_nominal_hipertensos
GROUP BY table_schema
ORDER BY table_schema
)
SELECT
schema_municipio,
cont_linhas_antes_da_alteracao,
cont_linhas_depois_da_alteracao,
(cont_linhas_antes_da_alteracao - cont_linhas_depois_da_alteracao) AS cont_linhas_hipertensao_variacao,
cont_chaves_nominais_distintas_antes_da_alteracao,
cont_chaves_nominais_distintas_depois_da_alteracao,
(cont_chaves_nominais_distintas_antes_da_alteracao - cont_chaves_nominais_distintas_depois_da_alteracao) AS cont_chaves_nominais_distintas_hipertensao_variacao,
hipertensao_denominador_antes_da_alteracao,
hipertensao_denominador_depois_da_alteracao,
(hipertensao_denominador_antes_da_alteracao - hipertensao_denominador_depois_da_alteracao) AS hipertensao_denominador_variacao,
numerador_hipertensao_antes_da_alteracao,
numerador_hipertensao_depois_da_alteracao,
(numerador_hipertensao_antes_da_alteracao - numerador_hipertensao_depois_da_alteracao) AS numerador_hipertensao_variacao,
cidadaos_autorreferidos_antes_da_alteracao,
cidadaos_autorreferidos_depois_da_alteracao,
(cidadaos_autorreferidos_antes_da_alteracao - cidadaos_autorreferidos_depois_da_alteracao) AS cidadaos_autorreferidos_variacao,
cidadaos_diagnosticados_antes_da_alteracao,
cidadaos_diagnosticados_depois_da_alteracao,
(cidadaos_diagnosticados_antes_da_alteracao - cidadaos_diagnosticados_depois_da_alteracao) AS cidadaos_diagnosticados_variacao,
cidadaos_com_consulta_antes_da_alteracao,
cidadaos_com_consulta_depois_da_alteracao,
(cidadaos_com_consulta_antes_da_alteracao - cidadaos_com_consulta_depois_da_alteracao) AS cidadaos_com_consulta_variacao,
cidadaos_com_consulta_sem_diagnotico_antes_da_alteracao,
cidadaos_com_consulta_sem_diagnotico_depois_da_alteracao,
(cidadaos_com_consulta_sem_diagnotico_antes_da_alteracao - cidadaos_com_consulta_sem_diagnotico_depois_da_alteracao) AS cidadaos_com_consulta_sem_diagnotico_variacao
FROM tabela_pivotada;

Loading