Hotfix - corrige referencias e variavel de data na validação da Jaé (#…

…323) * corrige referencias e variavel de data * adiciona changelog * adiciona tag
prefeitura-rio · May 28, 2024 · 88ebceb · 88ebceb
1 parent f0caad5
commit 88ebceb
Show file tree

Hide file tree

Showing 3 changed files with 16 additions and 10 deletions.
diff --git a/models/validacao_dados_jae/CHANGELOG.md b/models/validacao_dados_jae/CHANGELOG.md
@@ -1,12 +1,18 @@
 # Changelog - validacao_dados_jae
 
+## [1.0.2] - 2024-05-22
+
+### Corrigido
+- Corrige variável de data no modelo `ordem_pagamento_consorcio_dia_validacao.sql` (https://github.com/prefeitura-rio/queries-rj-smtr/pull/323)
+- Corrige referências nos modelos `ordem_pagamento_consorcio_dia_validacao.sql` e `ordem_pagamento_validacao.sql` (https://github.com/prefeitura-rio/queries-rj-smtr/pull/323)
+
 ## [1.0.1] - 2024-05-20
 
 ### Alterado
 - Adiciona colunas `servico_jae` e `descricao_servico_jae` do modelo `transacao_invalida.sql` (https://github.com/prefeitura-rio/queries-rj-smtr/pull/311)
 - Altera nome da coluna `indicador_geolocalizacao_fora_rj` para `indicador_geolocalizacao_fora_rio` no modelo `transacao_invalida.sql` (https://github.com/prefeitura-rio/queries-rj-smtr/pull/311)
 
- ### Corrigido
+### Corrigido
 - Remove comentários do modelo `ordem_pagamento_validacao.sql` (https://github.com/prefeitura-rio/queries-rj-smtr/pull/311)
 - Corrige nome da coluna `indicador_intervalo_transacao_suspeito` no filtro final do modelo `integracao_invalida.sql` (https://github.com/prefeitura-rio/queries-rj-smtr/pull/311)
 

diff --git a/models/validacao_dados_jae/ordem_pagamento_validacao.sql b/models/validacao_dados_jae/ordem_pagamento_validacao.sql
@@ -71,8 +71,8 @@ ordem_pagamento_dia AS (
 ),
 validacao AS (
   SELECT
-    cd.data_ordem,
-    cd.id_ordem_pagamento,
+    d.data_ordem,
+    d.id_ordem_pagamento,
     ROUND(cd.valor_total_transacao_liquido, 2) != ROUND(d.valor_total_transacao_liquido, 2) OR cd.quantidade_total_transacao != d.quantidade_total_transacao AS indicador_agregacao_invalida,
     indicador_servico_operador_invalido,
     indicador_consorcio_operador_invalido,

diff --git a/models/validacao_dados_jae/staging/ordem_pagamento_consorcio_dia_validacao.sql b/models/validacao_dados_jae/staging/ordem_pagamento_consorcio_dia_validacao.sql
@@ -21,7 +21,7 @@ WITH ordem_pagamento_consorcio_operador_dia AS (
     {{ ref("ordem_pagamento_consorcio_operador_dia_validacao") }}
   {% if is_incremental() %}
     WHERE
-      data_ordem BETWEEN DATE("{{var('date_range_start')}}") AND DATE("{{var('date_range_end')}}")
+      data_ordem = DATE("{{var('run_date')}}")
   {% endif %}
   GROUP BY
     1,
@@ -43,12 +43,12 @@ ordem_pagamento_consorcio_dia AS (
   {% endif %}
 )
 SELECT
-  cod.data_ordem,
-  cod.id_consorcio,
-  cod.id_ordem_pagamento,
-  cod.quantidade_total_transacao,
-  cod.valor_total_transacao_liquido,
-  cod.indicador_captura_invalida,
+  cd.data_ordem,
+  cd.id_consorcio,
+  cd.id_ordem_pagamento,
+  cd.quantidade_total_transacao,
+  cd.valor_total_transacao_liquido,
+  cd.indicador_captura_invalida,
   ROUND(cd.valor_total_transacao_liquido, 2) != ROUND(cod.valor_total_transacao_liquido, 2) OR cd.quantidade_total_transacao != cod.quantidade_total_transacao AS indicador_agregacao_invalida,
   '{{ var("version") }}' AS versao
 FROM