Altera calculo dos kms e pof (#239)

* add coalesce no desvp_pof * remove "Não licenciado" e "Não vistoriado" do calculo do pof * altera regra km_subsidiada_faixa * add changelogs * registra flow
prefeitura-rio · Sep 24, 2024 · 87c2a94 · 87c2a94
1 parent 5af1969
commit 87c2a94
Show file tree

Hide file tree

Showing 8 changed files with 32 additions and 7 deletions.
diff --git a/queries/models/dashboard_subsidio_sppo/CHANGELOG.md b/queries/models/dashboard_subsidio_sppo/CHANGELOG.md
@@ -1,5 +1,11 @@
 # Changelog - dashboard_subsidio_sppo
 
+## [7.0.3] - 2024-09-20
+
+### Alterado
+
+- Remove kms de veículos "Não licenciado" e "Não vistoriado" do cálculo do pof na CTE `servico_faixa_km_apuracao` do modelo `viagens_remuneradas` (https://github.com/prefeitura-rio/pipelines_rj_smtr/pull/239)
+
 ## [7.0.2] - 2024-08-29
 
 ### Alterado

diff --git a/queries/models/dashboard_subsidio_sppo/viagens_remuneradas.sql b/queries/models/dashboard_subsidio_sppo/viagens_remuneradas.sql
@@ -145,7 +145,7 @@ WITH
     p.consorcio,
     p.servico,
     p.km_planejada AS km_planejada,
-    COALESCE(ROUND(100 * SUM(v.distancia_planejada) / p.km_planejada,2), 0) AS pof
+    COALESCE(ROUND(100 * SUM(IF(v.tipo_viagem NOT IN ("Não licenciado","Não vistoriado"),v.distancia_planejada, 0)) / p.km_planejada,2), 0) AS pof
   FROM
     viagem_planejada AS p
   LEFT JOIN

diff --git a/queries/models/dashboard_subsidio_sppo_v2/CHANGELOG.md b/queries/models/dashboard_subsidio_sppo_v2/CHANGELOG.md
@@ -1,5 +1,11 @@
 # Changelog - dashboard_subsidio_sppo_v2
 
+## [1.0.1] - 2024-09-20
+
+### Alterado
+
+- Adiciona coalesce no desvp_pof (https://github.com/prefeitura-rio/pipelines_rj_smtr/pull/239)
+
 ## [1.0.0] - 2024-08-29
 
 ### Adicionado

diff --git a/queries/models/dashboard_subsidio_sppo_v2/sumario_servico_dia_pagamento.sql b/queries/models/dashboard_subsidio_sppo_v2/sumario_servico_dia_pagamento.sql
@@ -14,7 +14,7 @@ WITH
     consorcio,
     servico,
     SAFE_CAST(AVG(pof) AS NUMERIC) AS media_pof,
-    SAFE_CAST(STDDEV(pof) AS NUMERIC) AS desvp_pof
+    SAFE_CAST(COALESCE(STDDEV(pof), 0) AS NUMERIC) AS desvp_pof
   FROM
     {{ ref("subsidio_faixa_servico_dia") }}
     -- rj-smtr.financeiro_staging.subsidio_faixa_servico_dia

diff --git a/queries/models/financeiro/CHANGELOG.md b/queries/models/financeiro/CHANGELOG.md
@@ -1,5 +1,11 @@
 # Changelog - financeiro
 
+## [1.0.1] - 2024-09-20
+
+### Alterado
+
+- Altera `km_subsidiada_faixa` para considerar kms com indicador_viagem_dentro_limite = TRUE, pof >= 80 e subsidio_km > 0 no modelo `subsidio_faixa_servico_dia_tipo_viagem` (https://github.com/prefeitura-rio/pipelines_rj_smtr/pull/239)
+
 ## [1.0.0] - 2024-08-29
 
 ### Adicionado

diff --git a/queries/models/financeiro/staging/CHANGELOG.md b/queries/models/financeiro/staging/CHANGELOG.md
@@ -1,5 +1,11 @@
 # Changelog - financeiro_staging
 
+## [1.0.1] - 2024-09-20
+
+### Alterado
+
+- Remove kms de veículos "Não licenciado" e "Não vistoriado" do cálculo do pof no modelo `subsidio_faixa_servico_dia`(https://github.com/prefeitura-rio/pipelines_rj_smtr/pull/239)
+
 ## [1.0.0] - 2024-09-02
 
 ### Adicionado

diff --git a/queries/models/financeiro/staging/subsidio_faixa_servico_dia.sql b/queries/models/financeiro/staging/subsidio_faixa_servico_dia.sql
@@ -29,13 +29,14 @@ WITH
   viagem AS (
   SELECT
     data,
-    servico_realizado AS servico,
+    servico,
     id_viagem,
+    tipo_viagem,
     datetime_partida,
     distancia_planejada
  FROM
-    {{ ref("viagem_completa") }}
-    -- rj-smtr.projeto_subsidio_sppo.viagem_completa
+    {{ ref("viagem_transacao") }}
+    -- rj-smtr.subsidio.viagem_transacao
   WHERE
     data BETWEEN DATE("{{ var("start_date") }}")
     AND DATE("{{ var("end_date") }}")
@@ -52,7 +53,7 @@ WITH
     SAFE_CAST(p.km_planejada AS NUMERIC) AS km_planejada_faixa,
     SAFE_CAST(COALESCE(COUNT(v.id_viagem), 0) AS INT64) AS viagens_faixa,
     SAFE_CAST(COALESCE(SUM(v.distancia_planejada), 0) AS NUMERIC) AS km_apurada_faixa,
-    SAFE_CAST(COALESCE(ROUND(100 * SUM(v.distancia_planejada) / p.km_planejada, 2), 0) AS NUMERIC) AS pof
+    SAFE_CAST(COALESCE(ROUND(100 * SUM(IF(v.tipo_viagem NOT IN ("Não licenciado","Não vistoriado"),v.distancia_planejada, 0)) / p.km_planejada,2), 0) AS NUMERIC) AS pof
   FROM
     planejado AS p
   LEFT JOIN

diff --git a/queries/models/financeiro/subsidio_faixa_servico_dia_tipo_viagem.sql b/queries/models/financeiro/subsidio_faixa_servico_dia_tipo_viagem.sql
@@ -138,7 +138,7 @@ SELECT
   tipo_viagem,
   SAFE_CAST(COALESCE(COUNT(id_viagem), 0) AS INT64) AS viagens_faixa,
   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(COALESCE(SUM(IF(indicador_viagem_dentro_limite = TRUE AND pof >= 80 AND subsidio_km > 0, 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,