Adiciona transações de Van na tabela passageiros_hora (#110)

* adiciona vans na tabela passageiros_hora * adiciona valor padrão para tipo_gratuidade * add changelog * atualiza data do dbt --------- Co-authored-by: mergify[bot] <37929162+mergify[bot]@users.noreply.github.com>
prefeitura-rio · Jul 18, 2024 · 0358a86 · 0358a86
1 parent 112af25
commit 0358a86
Show file tree

Hide file tree

Showing 4 changed files with 20 additions and 3 deletions.
diff --git a/pipelines/migration/br_rj_riodejaneiro_bilhetagem/flows.py b/pipelines/migration/br_rj_riodejaneiro_bilhetagem/flows.py
@@ -2,7 +2,7 @@
 """
 Flows for br_rj_riodejaneiro_bilhetagem
 
-DBT: 2024-07-17 3
+DBT: 2024-07-18
 """
 
 from copy import deepcopy

diff --git a/queries/models/br_rj_riodejaneiro_bilhetagem/CHANGELOG.md b/queries/models/br_rj_riodejaneiro_bilhetagem/CHANGELOG.md
@@ -1,5 +1,13 @@
 # Changelog - bilhetagem
 
+## [2.1.3] - 2024-07-18
+
+### Adicionado
+- Adiciona transações de Van no modelo `passageiros_hora.sql` (https://github.com/prefeitura-rio/pipelines_rj_smtr/pull/110)
+
+### Alterado
+- Define o tipo_gratuidade de transações do tipo `Gratuidade` que o cliente não foi encontrado na tabela `br_rj_riodejaneiro_bilhetagem_staging.aux_gratuidade` como `Não Identificado` no modelo `transacao.sql` (https://github.com/prefeitura-rio/pipelines_rj_smtr/pull/110)
+
 ## [2.1.2] - 2024-07-05
 
 ### Adicionado

diff --git a/queries/models/br_rj_riodejaneiro_bilhetagem/transacao.sql b/queries/models/br_rj_riodejaneiro_bilhetagem/transacao.sql
@@ -318,7 +318,10 @@ SELECT
     WHEN t.tipo_transacao IN ("Débito", "Botoeira") THEN "Integral"
     ELSE t.tipo_transacao
   END AS tipo_transacao_smtr,
-  t.tipo_gratuidade,
+  CASE
+    WHEN t.tipo_transacao = "Gratuidade" AND t.tipo_gratuidade IS NULL THEN "Não Identificado"
+    ELSE t.tipo_gratuidade
+  END AS tipo_gratuidade,
   t.id_tipo_integracao,
   t.id_integracao,
   t.latitude,

diff --git a/queries/models/br_rj_riodejaneiro_bilhetagem_staging/passageiros_hora_aux.sql b/queries/models/br_rj_riodejaneiro_bilhetagem_staging/passageiros_hora_aux.sql
@@ -64,5 +64,11 @@ WHERE
   {% endif %}
   AND id_servico_jae NOT IN ("140", "142")
   AND id_operadora != "2"
-  AND (modo = "BRT" OR (modo = "VLT" AND data >= DATE("2024-02-24")) OR (modo = "Ônibus" AND data >= DATE("2024-04-19")))
+  AND (
+      modo = "BRT"
+      OR (modo = "VLT" AND data >= DATE("2024-02-24"))
+      OR (modo = "Ônibus" AND data >= DATE("2024-04-19"))
+      OR (modo = "Van" AND consorcio = "STPC" AND data >= DATE("2024-07-01"))
+      OR (modo = "Van" AND consorcio = "STPL" AND data >= DATE("2024-07-15"))
+  )
   AND tipo_transacao IS NOT NULL