From 4fbeca6e5aa584ccc6a12dc331361a98aec9c4f6 Mon Sep 17 00:00:00 2001
From: Guilherme Botelho <guilhermehcb@hotmail.com>
Date: Mon, 16 Sep 2024 17:28:24 -0300
Subject: [PATCH] [HOTFIX] Remove trunc (#235)

* remove trunc

* registra flow
---
 .../migration/projeto_subsidio_sppo/flows.py     |  2 +-
 .../staging/subsidio_faixa_servico_dia.sql       |  2 +-
 .../subsidio_faixa_servico_dia_tipo_viagem.sql   | 16 ++++++++--------
 .../subsidio_sumario_servico_dia_pagamento.sql   |  4 ++--
 4 files changed, 12 insertions(+), 12 deletions(-)

diff --git a/pipelines/migration/projeto_subsidio_sppo/flows.py b/pipelines/migration/projeto_subsidio_sppo/flows.py
index 002e51b9..c0b763c9 100644
--- 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
index 7c40ed7d..381a0ba5 100644
--- 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
index d9f358ed..8ac6f83f 100644
--- 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
index bb506aef..2cced886 100644
--- 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