[HOTFIX] kms apuração subsídio (#223)

* altera select km_apurada, adiciona coalesce nas kms por tipo e corrige refs * registra flow
prefeitura-rio · Sep 13, 2024 · a11dfbf · a11dfbf
1 parent df5091e
commit a11dfbf
Show file tree

Hide file tree

Showing 7 changed files with 35 additions and 19 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-13
+DBT: 2024-09-13
 """
 
 from prefect import Parameter, case, task

diff --git a/queries/models/dashboard_subsidio_sppo_v2/sumario_faixa_servico_dia.sql b/queries/models/dashboard_subsidio_sppo_v2/sumario_faixa_servico_dia.sql
@@ -16,12 +16,11 @@ WITH
     consorcio,
     servico,
     viagens_faixa,
-    km_apurada_faixa,
     km_planejada_faixa,
     pof
   FROM
-    -- rj-smtr-dev.financeiro.subsidio_faixa_servico_dia
     {{ ref("subsidio_faixa_servico_dia") }}
+    -- rj-smtr.financeiro_staging.subsidio_faixa_servico_dia
   WHERE
     data BETWEEN DATE("{{ var("start_date") }}")
     AND DATE("{{ var("end_date") }}")
@@ -34,13 +33,14 @@ WITH
     faixa_horaria_fim,
     consorcio,
     servico,
+    SUM(km_apurada_faixa) AS km_apurada_faixa,
     SUM(km_subsidiada_faixa) AS km_subsidiada_faixa,
     SUM(valor_apurado) AS valor_apurado,
     SUM(valor_acima_limite) AS valor_acima_limite,
     SUM(valor_total_sem_glosa) AS valor_total_sem_glosa
   FROM
-    -- rj-smtr-dev.financeiro.subsidio_faixa_servico_dia_tipo_viagem
     {{ ref("subsidio_faixa_servico_dia_tipo_viagem") }}
+    -- rj-smtr.financeiro.subsidio_faixa_servico_dia_tipo_viagem
   WHERE
     data BETWEEN DATE("{{ var("start_date") }}")
     AND DATE("{{ var("end_date") }}")
@@ -67,7 +67,7 @@ WITH
       km_apurada_faixa
     FROM
       {{ ref("subsidio_faixa_servico_dia_tipo_viagem") }}
-      -- rj-smtr-dev.financeiro.subsidio_faixa_servico_dia_tipo_viagem
+      -- rj-smtr.financeiro.subsidio_faixa_servico_dia_tipo_viagem
     WHERE
       data BETWEEN DATE("{{ var("start_date") }}")
       AND DATE("{{ var("end_date") }}")
@@ -91,11 +91,19 @@ SELECT
   s.consorcio,
   s.servico,
   s.viagens_faixa,
-  s.km_apurada_faixa,
+  agg.km_apurada_faixa,
   agg.km_subsidiada_faixa,
   s.km_planejada_faixa,
   s.pof,
-  pd.* EXCEPT(data, tipo_dia, faixa_horaria_inicio, faixa_horaria_fim, servico, consorcio),
+  COALESCE(km_apurada_registrado_com_ar_inoperante, 0) AS km_apurada_registrado_com_ar_inoperante,
+  COALESCE(km_apurada_n_licenciado, 0) AS km_apurada_n_licenciado,
+  COALESCE(km_apurada_autuado_ar_inoperante, 0) AS km_apurada_autuado_ar_inoperante,
+  COALESCE(km_apurada_autuado_seguranca, 0) AS km_apurada_autuado_seguranca,
+  COALESCE(km_apurada_autuado_limpezaequipamento, 0) AS km_apurada_autuado_limpezaequipamento,
+  COALESCE(km_apurada_licenciado_sem_ar_n_autuado, 0) AS km_apurada_licenciado_sem_ar_n_autuado,
+  COALESCE(km_apurada_licenciado_com_ar_n_autuado, 0) AS km_apurada_licenciado_com_ar_n_autuado,
+  COALESCE(km_apurada_n_vistoriado, 0) AS km_apurada_n_vistoriado,
+  COALESCE(km_apurada_sem_transacao, 0) AS km_apurada_sem_transacao,
   agg.valor_apurado,
   agg.valor_acima_limite,
   agg.valor_total_sem_glosa,

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
@@ -17,7 +17,7 @@ WITH
     SAFE_CAST(STDDEV(pof) AS NUMERIC) AS desvp_pof
   FROM
     {{ ref("subsidio_faixa_servico_dia") }}
-    -- rj-smtr-dev.financeiro.subsidio_faixa_servico_dia
+    -- rj-smtr.financeiro_staging.subsidio_faixa_servico_dia
   WHERE
     data BETWEEN DATE("{{ var("start_date") }}")
     AND DATE("{{ var("end_date") }}")
@@ -32,7 +32,7 @@ WITH
     *
   FROM
     {{ ref("subsidio_sumario_servico_dia_pagamento") }}
-    -- rj-smtr-dev.financeiro.subsidio_sumario_servico_dia_pagamento
+    -- rj-smtr.financeiro.subsidio_sumario_servico_dia_pagamento
   WHERE
     data BETWEEN DATE("{{ var("start_date") }}")
     AND DATE("{{ var("end_date") }}")
@@ -50,7 +50,7 @@ WITH
       km_apurada_faixa
     FROM
       {{ ref("subsidio_faixa_servico_dia_tipo_viagem") }}
-      -- rj-smtr-dev.financeiro.subsidio_faixa_servico_dia_tipo_viagem
+      -- rj-smtr.financeiro.subsidio_faixa_servico_dia_tipo_viagem
     WHERE
       data BETWEEN DATE("{{ var("start_date") }}")
       AND DATE("{{ var("end_date") }}")
@@ -77,7 +77,15 @@ SELECT
   vs.km_planejada_dia,
   sd.media_pof,
   sd.desvp_pof,
-  pd.* EXCEPT(data, tipo_dia, servico, consorcio),
+  COALESCE(km_apurada_registrado_com_ar_inoperante, 0) AS km_apurada_registrado_com_ar_inoperante,
+  COALESCE(km_apurada_n_licenciado, 0) AS km_apurada_n_licenciado,
+  COALESCE(km_apurada_autuado_ar_inoperante, 0) AS km_apurada_autuado_ar_inoperante,
+  COALESCE(km_apurada_autuado_seguranca, 0) AS km_apurada_autuado_seguranca,
+  COALESCE(km_apurada_autuado_limpezaequipamento, 0) AS km_apurada_autuado_limpezaequipamento,
+  COALESCE(km_apurada_licenciado_sem_ar_n_autuado, 0) AS km_apurada_licenciado_sem_ar_n_autuado,
+  COALESCE(km_apurada_licenciado_com_ar_n_autuado, 0) AS km_apurada_licenciado_com_ar_n_autuado,
+  COALESCE(km_apurada_n_vistoriado, 0) AS km_apurada_n_vistoriado,
+  COALESCE(km_apurada_sem_transacao, 0) AS km_apurada_sem_transacao,
   vs.valor_a_pagar,
   vs.valor_glosado,
   vs.valor_acima_limite,

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,
-    distancia_total_planejada AS km_planejada
+    TRUNC(distancia_total_planejada, 3) AS km_planejada
   FROM
     {{ ref("viagem_planejada") }}
     -- rj-smtr.projeto_subsidio_sppo.viagem_planejada
@@ -35,7 +35,7 @@ WITH
     distancia_planejada
  FROM
     {{ ref("viagem_completa") }}
-  --  rj-smtr.projeto_subsidio_sppo.viagem_completa
+    -- rj-smtr.projeto_subsidio_sppo.viagem_completa
   WHERE
     data BETWEEN DATE("{{ var("start_date") }}")
     AND DATE("{{ var("end_date") }}")

diff --git a/queries/models/financeiro/subsidio_faixa_servico_dia_tipo_viagem.sql b/queries/models/financeiro/subsidio_faixa_servico_dia_tipo_viagem.sql
@@ -18,7 +18,7 @@ WITH
     pof
   FROM
     {{ ref("subsidio_faixa_servico_dia") }}
-    -- rj-smtr.financeiro.subsidio_faixa_servico_dia
+    -- rj-smtr.financeiro_staging.subsidio_faixa_servico_dia
   WHERE
     data BETWEEN DATE("{{ var("start_date") }}")
     AND DATE("{{ var("end_date") }}")

diff --git a/queries/models/financeiro/subsidio_penalidade_servico_dia.sql b/queries/models/financeiro/subsidio_penalidade_servico_dia.sql
@@ -16,7 +16,7 @@ WITH
     MIN(pof) AS min_pof
   FROM
     {{ ref("subsidio_faixa_servico_dia") }}
-    -- rj-smtr-dev.financeiro.subsidio_faixa_servico_dia
+    -- rj-smtr.financeiro_staging.subsidio_faixa_servico_dia
   WHERE
     data BETWEEN DATE("{{ var("start_date") }}")
     AND DATE("{{ var("end_date") }}")

diff --git a/queries/models/financeiro/subsidio_sumario_servico_dia_pagamento.sql b/queries/models/financeiro/subsidio_sumario_servico_dia_pagamento.sql
@@ -14,11 +14,10 @@ WITH
     consorcio,
     servico,
     SUM(viagens_faixa) AS viagens_dia,
-    SUM(km_apurada_faixa) AS km_apurada_dia,
     SUM(km_planejada_faixa) AS km_planejada_dia
   FROM
     {{ ref("subsidio_faixa_servico_dia") }}
-    -- rj-smtr.financeiro.subsidio_faixa_servico_dia
+    -- rj-smtr.financeiro_staging.subsidio_faixa_servico_dia
   WHERE
     data BETWEEN DATE("{{ var("start_date") }}")
     AND DATE("{{ var("end_date") }}")
@@ -37,7 +36,7 @@ WITH
     MAX(subsidio_km) OVER (PARTITION BY data_inicio, data_fim) AS subsidio_km_teto
   FROM
     {{ ref("subsidio_valor_km_tipo_viagem") }}
-    -- rj-smtr-staging.dashboard_subsidio_sppo_staging.subsidio_valor_km_tipo_viagem
+    -- rj-smtr.dashboard_subsidio_sppo_staging.subsidio_valor_km_tipo_viagem
 ),
   penalidade AS (
   SELECT
@@ -66,6 +65,7 @@ WITH
     s.consorcio,
     s.servico,
     pe.valor_penalidade,
+    SUM(s.km_apurada_faixa) AS km_apurada_dia,
     SUM(s.km_subsidiada_faixa) AS km_subsidiada_dia,
     COALESCE(SUM(s.valor_acima_limite), 0) AS valor_acima_limite,
     COALESCE(SUM(s.valor_total_sem_glosa), 0) AS valor_total_sem_glosa,
@@ -99,7 +99,7 @@ SELECT
   sd.consorcio,
   sd.servico,
   sd.viagens_dia,
-  sd.km_apurada_dia,
+  vc.km_apurada_dia,
   vc.km_subsidiada_dia,
   sd.km_planejada_dia,
   vc.valor_total_com_glosa AS valor_a_pagar,