From 0051a05e4d7460ddd09a6dc143475195ef5c46de Mon Sep 17 00:00:00 2001 From: Rafael Carvalho Pinheiro <74972217+pixuimpou@users.noreply.github.com> Date: Mon, 20 May 2024 19:57:44 -0300 Subject: [PATCH] =?UTF-8?q?[HOTFIX]=20Bilhetagem=20-=20Corrige=20servi?= =?UTF-8?q?=C3=A7o=20nas=20tabelas=20agregadas=20de=20GPS=20(#317)?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit * adiciona coluna servico nas tabelas da jae * adiciona changelog * Corrige CHANGELOG.md * altera serviços para os dados da jae * adiciona colunas novas no schema * altera changelog * correções validação * corrigir referencia das colunas do gps_validador * corrigir nome das colunas gps_validador * corrige alias * corrige servico * corrige servico * corrige servico brt * corrige id linha * correcao ordem_pagamento * corrige typo changelog --- models/br_rj_riodejaneiro_bilhetagem/CHANGELOG.md | 3 ++- .../ordem_pagamento_servico_operador_dia.sql | 3 ++- models/br_rj_riodejaneiro_bilhetagem/transacao.sql | 2 +- .../gps_agregado_brt.sql | 12 ++++++------ .../gps_agregado_vlt.sql | 12 ++++++------ 5 files changed, 17 insertions(+), 15 deletions(-) diff --git a/models/br_rj_riodejaneiro_bilhetagem/CHANGELOG.md b/models/br_rj_riodejaneiro_bilhetagem/CHANGELOG.md index a9dbb4e7..850ad5c0 100644 --- a/models/br_rj_riodejaneiro_bilhetagem/CHANGELOG.md +++ b/models/br_rj_riodejaneiro_bilhetagem/CHANGELOG.md @@ -3,7 +3,8 @@ ## [1.2.1] - 2024-05-20 ### Corrigido -- Altera alias da tabela `linha_sem_ressarcimento` no modelo `transacao.sql` +- Altera alias da tabela `linha_sem_ressarcimento` no modelo `transacao.sql` (https://github.com/prefeitura-rio/queries-rj-smtr/pull/317) +- Corrige select servico no modelo `ordem_pagamento_servico_operador_dia.sql` ((https://github.com/prefeitura-rio/queries-rj-smtr/pull/317) ## [1.2.0] - 2024-05-20 diff --git a/models/br_rj_riodejaneiro_bilhetagem/ordem_pagamento_servico_operador_dia.sql b/models/br_rj_riodejaneiro_bilhetagem/ordem_pagamento_servico_operador_dia.sql index a3916430..85b0c7c3 100644 --- a/models/br_rj_riodejaneiro_bilhetagem/ordem_pagamento_servico_operador_dia.sql +++ b/models/br_rj_riodejaneiro_bilhetagem/ordem_pagamento_servico_operador_dia.sql @@ -77,7 +77,8 @@ SELECT o.id_operadora, o.operadora, o.id_servico_jae, - o.servico, + o.servico_jae, + o.descricao_servico_jae, o.id_ordem_pagamento, o.id_ordem_ressarcimento, o.quantidade_transacao_debito, diff --git a/models/br_rj_riodejaneiro_bilhetagem/transacao.sql b/models/br_rj_riodejaneiro_bilhetagem/transacao.sql index 2e0bd832..5de57120 100644 --- a/models/br_rj_riodejaneiro_bilhetagem/transacao.sql +++ b/models/br_rj_riodejaneiro_bilhetagem/transacao.sql @@ -169,7 +169,7 @@ ON LEFT JOIN {{ ref("staging_linha_sem_ressarcimento") }} lsr ON - t.cd_linha = l.id_linha + t.cd_linha = lsr.id_linha WHERE lsr.id_linha IS NULL AND DATE(data_transacao) >= "2023-07-17" \ No newline at end of file diff --git a/models/dashboard_bilhetagem_implantacao_jae/gps_agregado_brt.sql b/models/dashboard_bilhetagem_implantacao_jae/gps_agregado_brt.sql index ef62d38a..01e086ae 100644 --- a/models/dashboard_bilhetagem_implantacao_jae/gps_agregado_brt.sql +++ b/models/dashboard_bilhetagem_implantacao_jae/gps_agregado_brt.sql @@ -19,20 +19,20 @@ WITH gps_agregado AS ( primeiro_datetime_gps, MINUTE ) + 1 AS qtde_min_entre_a_prim_e_ultima_transmissao, - COUNT(*) OVER (PARTITION BY servico, id_validador) AS qtde_registros_gps, - COUNT(DISTINCT FORMAT_TIMESTAMP("%F %H:%M", datetime_gps)) OVER (PARTITION BY servico, id_validador) AS qtde_min_distintos_houve_transmissao, + COUNT(*) OVER (PARTITION BY servico_jae, id_validador) AS qtde_registros_gps, + COUNT(DISTINCT FORMAT_TIMESTAMP("%F %H:%M", datetime_gps)) OVER (PARTITION BY servico_jae, id_validador) AS qtde_min_distintos_houve_transmissao, SUM( CASE WHEN latitude != 0 AND longitude != 0 AND latitude IS NOT NULL AND longitude IS NOT NULL THEN 1 ELSE 0 END - ) OVER (PARTITION BY servico, id_validador) AS qtde_registros_gps_georreferenciados, - ROW_NUMBER() OVER (PARTITION BY servico, id_validador ORDER BY datetime_gps) AS rn + ) OVER (PARTITION BY servico_jae, id_validador) AS qtde_registros_gps_georreferenciados, + ROW_NUMBER() OVER (PARTITION BY servico_jae, id_validador ORDER BY datetime_gps) AS rn FROM ( SELECT *, - MIN(datetime_gps) OVER (PARTITION BY servico, id_validador) AS primeiro_datetime_gps, - MAX(datetime_gps) OVER (PARTITION BY servico, id_validador) AS ultimo_datetime_gps, + MIN(datetime_gps) OVER (PARTITION BY servico_jae, id_validador) AS primeiro_datetime_gps, + MAX(datetime_gps) OVER (PARTITION BY servico_jae, id_validador) AS ultimo_datetime_gps, ROW_NUMBER() OVER (PARTITION BY id_transmissao_gps ORDER BY datetime_captura DESC) AS rn FROM {{ ref("gps_validador") }} diff --git a/models/dashboard_bilhetagem_implantacao_jae/gps_agregado_vlt.sql b/models/dashboard_bilhetagem_implantacao_jae/gps_agregado_vlt.sql index 167de6c5..b735ca6f 100644 --- a/models/dashboard_bilhetagem_implantacao_jae/gps_agregado_vlt.sql +++ b/models/dashboard_bilhetagem_implantacao_jae/gps_agregado_vlt.sql @@ -19,20 +19,20 @@ WITH gps_agregado AS ( primeiro_datetime_gps, MINUTE ) + 1 AS qtde_min_entre_a_prim_e_ultima_transmissao, - COUNT(*) OVER (PARTITION BY servico, id_validador) AS qtde_registros_gps, - COUNT(DISTINCT FORMAT_TIMESTAMP("%F %H:%M", datetime_gps)) OVER (PARTITION BY servico, id_validador) AS qtde_min_distintos_houve_transmissao, + COUNT(*) OVER (PARTITION BY servico_jae, id_validador) AS qtde_registros_gps, + COUNT(DISTINCT FORMAT_TIMESTAMP("%F %H:%M", datetime_gps)) OVER (PARTITION BY servico_jae, id_validador) AS qtde_min_distintos_houve_transmissao, SUM( CASE WHEN latitude != 0 AND longitude != 0 AND latitude IS NOT NULL AND longitude IS NOT NULL THEN 1 ELSE 0 END - ) OVER (PARTITION BY servico, id_validador) AS qtde_registros_gps_georreferenciados, - ROW_NUMBER() OVER (PARTITION BY servico, id_validador ORDER BY datetime_gps) AS rn + ) OVER (PARTITION BY servico_jae, id_validador) AS qtde_registros_gps_georreferenciados, + ROW_NUMBER() OVER (PARTITION BY servico_jae, id_validador ORDER BY datetime_gps) AS rn FROM ( SELECT *, - MIN(datetime_gps) OVER (PARTITION BY servico, id_validador) AS primeiro_datetime_gps, - MAX(datetime_gps) OVER (PARTITION BY servico, id_validador) AS ultimo_datetime_gps, + MIN(datetime_gps) OVER (PARTITION BY servico_jae, id_validador) AS primeiro_datetime_gps, + MAX(datetime_gps) OVER (PARTITION BY servico_jae, id_validador) AS ultimo_datetime_gps, ROW_NUMBER() OVER (PARTITION BY id_transmissao_gps ORDER BY datetime_captura DESC) AS rn FROM {{ ref("gps_validador") }}