cria a views de dados historicos no dataset monitoramento

queries/dbt_project.yml

@@ -123,6 +123,8 @@ vars:
   DATA_SUBSIDIO_V8_INICIO: "2024-07-20"
   # Feature Apuração por faixa horária
   DATA_SUBSIDIO_V9_INICIO: "2024-08-16"
+  # Feature desconsideração de km não vistoriado e não licenciado
+  DATA_SUBSIDIO_V10_INICIO: "2024-09-01"
   # valor_subsidio: "`rj-smtr-dev.projeto_subsidio_sppo.valor_subsidio`"
 
   # Recursos #

queries/models/dashboard_subsidio_sppo_v2/sumario_servico_dia_historico.sql

@@ -0,0 +1,100 @@
+{{
+    config(
+        materialized="incremental",
+        partition_by={"field": "data", "data_type": "date", "granularity": "day"},
+        incremental_strategy="insert_overwrite",
+    )
+}}
+WITH
+  pre_faixa_horaria AS (
+  SELECT
+    data,
+    tipo_dia,
+    consorcio,
+    servico,
+    vista,
+    viagens,
+    km_apurada,
+    km_planejada,
+    perc_km_planejada,
+    valor_subsidio_pago,
+    valor_penalidade
+  FROM
+    {{ ref('sumario_servico_dia_historico')}}
+    -- `rj-smtr.dashboard_subsidio_sppo.sumario_servico_dia_historico`
+  WHERE
+    data < DATE("{{ var("DATA_SUBSIDIO_V9_INICIO") }}")
+    {% if is_incremental() %}
+      AND data BETWEEN DATE("{{ var("start_date") }}")
+      AND DATE_ADD(DATE("{{ var("end_date") }}"), INTERVAL 1 DAY)
+    {% endif %} ),
+  planejada AS (
+  SELECT
+    DISTINCT data,
+    consorcio,
+    servico,
+    vista
+  FROM
+    {{ ref('viagem_planejada')}}
+    -- `rj-smtr.projeto_subsidio_sppo.viagem_planejada`
+  WHERE
+    data >= DATE("{{ var("DATA_SUBSIDIO_V9_INICIO") }}")
+    AND (id_tipo_trajeto = 0
+      OR id_tipo_trajeto IS NULL)
+    AND FORMAT_TIME("%T", TIME(faixa_horaria_inicio)) != "00:00:00" ),
+  pagamento AS (
+  SELECT
+    data,
+    tipo_dia,
+    consorcio,
+    servico,
+    vista,
+    viagens_dia AS viagens,
+    CASE
+      WHEN data >= DATE("{{ var("DATA_SUBSIDIO_V10_INICIO") }}") THEN COALESCE(km_apurada_registrado_com_ar_inoperante,0) + COALESCE(km_apurada_autuado_ar_inoperante,0) + COALESCE(km_apurada_autuado_seguranca,0) + COALESCE(km_apurada_autuado_limpezaequipamento,0) + COALESCE(km_apurada_licenciado_sem_ar_n_autuado,0) + COALESCE(km_apurada_licenciado_com_ar_n_autuado,0) + COALESCE(km_apurada_sem_transacao, 0)
+      ELSE COALESCE(km_apurada_registrado_com_ar_inoperante,0) + COALESCE(km_apurada_autuado_ar_inoperante,0) + COALESCE(km_apurada_autuado_seguranca,0) + COALESCE(km_apurada_autuado_limpezaequipamento,0) + COALESCE(km_apurada_licenciado_sem_ar_n_autuado,0) + COALESCE(km_apurada_licenciado_com_ar_n_autuado,0) + COALESCE(km_apurada_sem_transacao, 0) + COALESCE(km_apurada_n_vistoriado, 0) + COALESCE(km_apurada_n_licenciado, 0)
+  END
+    AS km_apurada,
+    km_planejada_dia AS km_planejada,
+    valor_a_pagar AS valor_subsidio_pago,
+    valor_penalidade
+  FROM
+    {{ ref('subsidio_sumario_servico_dia_pagamento')}} AS sdp
+    -- `rj-smtr.dashboard_subsidio_sppo_v2.sumario_servico_dia_pagamento`
+  LEFT JOIN
+    planejada AS P
+  USING
+    (data,
+      servico,
+      consorcio)
+  WHERE
+    data >= DATE("{{ var("DATA_SUBSIDIO_V9_INICIO") }}")
+	{% if is_incremental() %}
+      AND data BETWEEN DATE("{{ var("start_date") }}")
+      AND DATE_ADD(DATE("{{ var("end_date") }}"), INTERVAL 1 DAY)
+    {% endif %} 
+	),
+  pos_faixa_horaria AS (
+  SELECT
+    data,
+    tipo_dia,
+    consorcio,
+    servico,
+    vista,
+    viagens,
+    km_apurada,
+    km_planejada,
+    100*km_apurada/km_planejada AS perc_km_planejada,
+    valor_subsidio_pago,
+    valor_penalidade
+  FROM
+    pagamento )
+SELECT
+  *
+FROM
+  pre_faixa_horaria
+UNION ALL
+SELECT
+  *
+FROM
+  pos_faixa_horaria

queries/models/dashboard_subsidio_sppo_v2/sumario_servico_dia_tipo_viagem_historico.sql

@@ -0,0 +1,53 @@
+{{
+    config(
+        materialized="incremental",
+        partition_by={"field": "data", "data_type": "date", "granularity": "day"},
+        incremental_strategy="insert_overwrite",
+    )
+}}
+with
+    pre_faixa_horaria as (
+        select
+            data,
+            tipo_dia,
+            consorcio,
+            servico,
+            tipo_viagem,
+            indicador_ar_condicionado,
+            viagens,
+            km_apurada
+        from {{ ref("sumario_servico_tipo_viagem_dia") }}
+        -- `rj-smtr.dashboard_subsidio_sppo.sumario_servico_tipo_viagem_dia`
+        where data < date("{{ var(" data_subsidio_v9_inicio ") }}")
+				{% if is_incremental() %}
+						AND data BETWEEN DATE("{{ var("start_date") }}")
+						AND DATE_ADD(DATE("{{ var("end_date") }}"), INTERVAL 1 DAY)
+				{% endif %}
+    ),
+    pos_faixa_horaria as (
+        select
+            data,
+            tipo_dia,
+            consorcio,
+            servico,
+            tipo_viagem,
+            indicador_ar_condicionado,
+            sum(viagens_faixa) as viagens,
+            sum(km_apurada_faixa) as km_apurada
+        from {{ ref("subsidio_faixa_servico_dia_tipo_viagem") }}
+        -- `rj-smtr.financeiro.subsidio_faixa_servico_dia_tipo_viagem`
+        where
+            data >= date("{{ var(" data_subsidio_v9_inicio ") }}")
+            and tipo_viagem != "Sem viagem apurada"
+						{% if is_incremental() %}
+								AND data BETWEEN DATE("{{ var("start_date") }}")
+								AND DATE_ADD(DATE("{{ var("end_date") }}"), INTERVAL 1 DAY)
+						{% endif %}
+        group by
+            data, tipo_dia, consorcio, servico, tipo_viagem, indicador_ar_condicionado
+    )
+select *
+from pre_faixa_horaria
+union all
+select *
+from pos_faixa_horaria

queries/models/monitoramento/CHANGELOG.md

@@ -1,6 +1,12 @@
 # Changelog - monitoramento
 
+## [1.0.1] - 2024-10-22
+
+### Adicionado
+
+- Cria modelos `sumario_servico_dia_pagamento_historico`, `sumario_servico_dia_tipo_viagem_historico` e `monitoramento_viagem_transacao` (https://github.com/prefeitura-rio/pipelines_rj_smtr/pull/258)
+
 ## [1.0.0] - 2024-10-21
 
 ### Adicionado
-- Cria modelos para tratamento de viagens informadas: `staging_viagem_informada_rioonibus.sql` e `viagem_informada_monitoramento.sql` (https://github.com/prefeitura-rio/pipelines_rj_smtr/pull/276)
+- Cria modelos para tratamento de viagens informadas: `staging_viagem_informada_rioonibus.sql` e `viagem_informada_monitoramento.sql` (https://github.com/prefeitura-rio/pipelines_rj_smtr/pull/276)