Incorpora variável 'encontro_contas_modo' para alterar nome da tabe…

…la, de acordo com o modo de execução
prefeitura-rio · Jun 4, 2024 · ade87a6 · ade87a6
1 parent 8b14934
commit ade87a6
Show file tree

Hide file tree

Showing 7 changed files with 35 additions and 1 deletion.
diff --git a/dbt_project.yml b/dbt_project.yml
@@ -176,6 +176,9 @@ vars:
   ### Diretorios ###
   ids_consorcios: {"'221000014'": "'6'", "'221000023'": "'4'", "'221000032'": "'3'", "'221000041'": "'5'", "'221000050'": "NULL", "'229000010'": "'1'"}
 
+  ### Encontro de Contas ###
+  encontro_contas_modo: ""
+
 models:
   +persist_docs:
     relation: true

diff --git a/models/projeto_subsidio_sppo_encontro_contas/balanco_consorcio_ano.sql b/models/projeto_subsidio_sppo_encontro_contas/balanco_consorcio_ano.sql
@@ -1,3 +1,7 @@
+{% if var("encontro_contas_modo") != "" %}
+  {{ config(alias=this.name ~ "_" ~ var('encontro_contas_modo')) }}
+{% endif %}
+
 select
   extract(year from data) as ano,
   consorcio,

diff --git a/models/projeto_subsidio_sppo_encontro_contas/balanco_consorcio_dia.sql b/models/projeto_subsidio_sppo_encontro_contas/balanco_consorcio_dia.sql
@@ -1,3 +1,7 @@
+{% if var("encontro_contas_modo") != "" %}
+  {{ config(alias=this.name ~ "_" ~ var('encontro_contas_modo')) }}
+{% endif %}
+
 select
   data,
   consorcio,

diff --git a/models/projeto_subsidio_sppo_encontro_contas/balanco_servico_ano.sql b/models/projeto_subsidio_sppo_encontro_contas/balanco_servico_ano.sql
@@ -1,3 +1,7 @@
+{% if var("encontro_contas_modo") != "" %}
+  {{ config(alias=this.name ~ "_" ~ var('encontro_contas_modo')) }}
+{% endif %}
+
 select
   extract(year from data) as ano,
   consorcio,

diff --git a/models/projeto_subsidio_sppo_encontro_contas/balanco_servico_dia.sql b/models/projeto_subsidio_sppo_encontro_contas/balanco_servico_dia.sql
@@ -1,3 +1,7 @@
+{% if var("encontro_contas_modo") != "" %}
+  {{ config(alias=this.name ~ "_" ~ var('encontro_contas_modo')) }}
+{% endif %}
+
 -- 0. Lista servicos e dias atípicos (pagos por recurso)
 WITH
   recursos AS (
@@ -114,6 +118,7 @@ rdo AS (
   group by 1,2,3
 ),
 
+{% if var("encontro_contas_modo") == "pos_gt" %}
 -- 4. Considera os serviços conforme tratamento indicado em resposta aos ofícios MTR-OFI-2024/03024, MTR-OFI-2024/03025, MTR-OFI-2024/03026 e MTR-OFI-2024/03027 (Processo MTR-PRO-2024/06270)
 rdo_correcao_servico AS (
   SELECT DISTINCT
@@ -144,6 +149,7 @@ rdo_corrigido AS (
     2,
     3
 ),
+{% endif %}
 
 parametros as (
   SELECT
@@ -174,7 +180,11 @@ parametros as (
     from
       km_subsidiada_filtrada ks
     left join
+      {% if var("encontro_contas_modo") == "pos_gt" %}
       rdo_corrigido AS rdo
+      {% else %}
+      rdo
+      {% endif %}
     using 
       (data, servico, consorcio)
     left join

diff --git a/models/projeto_subsidio_sppo_encontro_contas/balanco_servico_quinzena.sql b/models/projeto_subsidio_sppo_encontro_contas/balanco_servico_quinzena.sql
@@ -1,3 +1,7 @@
+{% if var("encontro_contas_modo") != "" %}
+  {{ config(alias=this.name ~ "_" ~ var('encontro_contas_modo')) }}
+{% endif %}
+
 WITH
   q1 AS (
   SELECT

diff --git a/...projeto_subsidio_sppo_encontro_contas/staging/rdo_correcao_rioonibus_servico_quinzena.sql b/...projeto_subsidio_sppo_encontro_contas/staging/rdo_correcao_rioonibus_servico_quinzena.sql
@@ -2,6 +2,8 @@
   Etapa de tratamento com base na resposta aos ofícios MTR-OFI-2024/03024, MTR-OFI-2024/03025, MTR-OFI-2024/03026 e MTR-OFI-2024/03027 (Processo MTR-PRO-2024/06270)
 */
 
+{% if var("encontro_contas_modo") == "pos_gt" %}
+{{ config(alias=this.name ~ "_" ~ var('encontro_contas_modo')) }}
 SELECT
     quinzena,
     PARSE_DATE("%m/%d/%Y", data_inicio_quinzena) AS data_inicio_quinzena,
@@ -22,4 +24,7 @@ SELECT
   END
     AS servico_corrigido_rioonibus,
 FROM
-    {{ source("projeto_subsidio_sppo_encontro_contas", "rdo_correcao_rioonibus_servico_quinzena") }}
+    {{ source("projeto_subsidio_sppo_encontro_contas", "rdo_correcao_rioonibus_servico_quinzena") }}
+{% else %}
+{{ config(enabled=false) }}
+{% endif %}