[HOTFIX] Remove trunc (#235)

* remove trunc * registra flow
prefeitura-rio · Sep 16, 2024 · 4fbeca6 · 4fbeca6
1 parent 4df87bf
commit 4fbeca6
Show file tree

Hide file tree

Showing 4 changed files with 12 additions and 12 deletions.
diff --git a/pipelines/migration/projeto_subsidio_sppo/flows.py b/pipelines/migration/projeto_subsidio_sppo/flows.py
@@ -3,7 +3,7 @@
 """
 Flows for projeto_subsidio_sppo
 
-DBT 2024-09-16
+DBT: 2024-09-16
 """
 
 from prefect import Parameter, case, task

diff --git a/queries/models/financeiro/staging/subsidio_faixa_servico_dia.sql b/queries/models/financeiro/staging/subsidio_faixa_servico_dia.sql
@@ -16,7 +16,7 @@ WITH
     servico,
     faixa_horaria_inicio,
     faixa_horaria_fim,
-    TRUNC(distancia_total_planejada, 3) AS km_planejada
+    distancia_total_planejada AS km_planejada
   FROM
     {{ ref("viagem_planejada") }}
     -- rj-smtr.projeto_subsidio_sppo.viagem_planejada

diff --git a/queries/models/financeiro/subsidio_faixa_servico_dia_tipo_viagem.sql b/queries/models/financeiro/subsidio_faixa_servico_dia_tipo_viagem.sql
@@ -100,9 +100,9 @@ WITH
       sfd.pof,
       COALESCE(s.tipo_viagem, "Sem viagem apurada") AS tipo_viagem,
       s.id_viagem,
-      s.distancia_planejada,
-      s.subsidio_km,
-      s.subsidio_km_teto,
+      SAFE_CAST(s.distancia_planejada AS NUMERIC) AS distancia_planejada,
+      SAFE_CAST(s.subsidio_km AS NUMERIC) AS subsidio_km,
+      SAFE_CAST(s.subsidio_km_teto AS NUMERIC) AS subsidio_km_teto,
       s.indicador_viagem_dentro_limite,
       CASE
         WHEN sfd.pof < 60 THEN TRUE
@@ -137,11 +137,11 @@ SELECT
   indicador_viagem_dentro_limite,
   tipo_viagem,
   SAFE_CAST(COALESCE(COUNT(id_viagem), 0) AS INT64) AS viagens_faixa,
-  SAFE_CAST(TRUNC(COALESCE(SUM(distancia_planejada), 0), 3)AS NUMERIC) AS km_apurada_faixa,
-  SAFE_CAST(TRUNC(COALESCE(SUM(IF(tipo_viagem != "Não licenciado", distancia_planejada, 0)), 0), 3) AS NUMERIC) AS km_subsidiada_faixa,
-  SAFE_CAST(TRUNC(SUM(IF(indicador_viagem_dentro_limite = TRUE AND pof >= 80, distancia_planejada*subsidio_km, 0)), 2) AS NUMERIC) AS valor_apurado,
-  SAFE_CAST(-TRUNC(COALESCE(SUM(IF(indicador_viagem_dentro_limite = TRUE, 0, distancia_planejada*subsidio_km)), 0), 2) AS NUMERIC) AS valor_acima_limite,
-  SAFE_CAST(TRUNC(SUM(IF(pof >= 80 AND tipo_viagem != "Não licenciado", distancia_planejada*subsidio_km_teto, 0)) - COALESCE(SUM(IF(indicador_viagem_dentro_limite = TRUE, 0, distancia_planejada*subsidio_km)), 0), 2) AS NUMERIC) AS valor_total_sem_glosa,
+  SAFE_CAST(COALESCE(SUM(distancia_planejada), 0) AS NUMERIC) AS km_apurada_faixa,
+  SAFE_CAST(COALESCE(SUM(IF(tipo_viagem != "Não licenciado", distancia_planejada, 0)), 0) AS NUMERIC) AS km_subsidiada_faixa,
+  SAFE_CAST(SUM(IF(indicador_viagem_dentro_limite = TRUE AND pof >= 80, distancia_planejada*subsidio_km, 0)) AS NUMERIC) AS valor_apurado,
+  SAFE_CAST(-COALESCE(SUM(IF(indicador_viagem_dentro_limite = TRUE, 0, distancia_planejada*subsidio_km)), 0) AS NUMERIC) AS valor_acima_limite,
+  SAFE_CAST(SUM(IF(pof >= 80 AND tipo_viagem != "Não licenciado", distancia_planejada*subsidio_km_teto, 0)) - COALESCE(SUM(IF(indicador_viagem_dentro_limite = TRUE, 0, distancia_planejada*subsidio_km)), 0) AS NUMERIC) AS valor_total_sem_glosa,
   '{{ var("version") }}' as versao,
   CURRENT_DATETIME("America/Sao_Paulo") as datetime_ultima_atualizacao
 FROM

diff --git a/queries/models/financeiro/subsidio_sumario_servico_dia_pagamento.sql b/queries/models/financeiro/subsidio_sumario_servico_dia_pagamento.sql
@@ -72,8 +72,8 @@ WITH
     SUM(s.valor_apurado) + pe.valor_penalidade AS valor_total_com_glosa,
     CASE
       WHEN pe.valor_penalidade != 0 THEN -pe.valor_penalidade
-      ELSE SAFE_CAST(TRUNC((SUM(IF(indicador_viagem_dentro_limite = TRUE AND indicador_penalidade_judicial = TRUE, km_apurada_faixa*subsidio_km_teto, 0))
-           - SUM(IF(indicador_viagem_dentro_limite = TRUE AND indicador_penalidade_judicial = TRUE, km_apurada_faixa*subsidio_km, 0))), 2) AS NUMERIC)
+      ELSE SAFE_CAST((SUM(IF(indicador_viagem_dentro_limite = TRUE AND indicador_penalidade_judicial = TRUE, km_apurada_faixa*subsidio_km_teto, 0))
+           - SUM(IF(indicador_viagem_dentro_limite = TRUE AND indicador_penalidade_judicial = TRUE, km_apurada_faixa*subsidio_km, 0))) AS NUMERIC)
     END AS valor_judicial,
   FROM
     subsidio_dia_tipo_viagem AS s