Merge branch 'main' into pre-commit-ci-update-config

prefeitura-rio · Apr 8, 2024 · bf81873 · bf81873
2 parents fa978eb + 025c810
commit bf81873
Show file tree

Hide file tree

Showing 2 changed files with 23 additions and 67 deletions.
diff --git a/pipelines/ergon/dump_db_ergon/schedules.py b/pipelines/ergon/dump_db_ergon/schedules.py
@@ -183,12 +183,13 @@
             SELECT
                 DATAINI, SETOR, NOMESETOR, PAISETOR, TIPOSETOR,
                 DATAFIM, TIPOLOG, NOMELOG, NUMEROLOG, COMPLEMENTO,
-                BAIRRO, CEP, CIDADE, UF, FONE, FAX, CENTRO_CUSTO,
+                BAIRRO, CIDADE, UF, FONE, FAX, CENTRO_CUSTO,
                 TIPOACESSO, TIPOLOGIA, OBS, MBAIRRO_MUNICIPIO_CODIGO,
                 MBAIRRO_CODIGO, CGC, HLOCAL, PAISETOR1, PAISETOR2, PAISETOR3,
                 PAISETOR4, EMP_CODIGO, SUBEMP_CODIGO, FLEX_CAMPO_01, FLEX_CAMPO_02,
                 FLEX_CAMPO_05, EXTINTO, FLEX_CAMPO_14, FLEX_CAMPO_15, PONTPUBL,
-                NOMESETORLONGO, CIDADE_COD
+                REPLACE(REPLACE(NOMESETORLONGO, CHR(13), ''), CHR(10), '') AS NOMESETORLONGO,
+                CIDADE_COD, CEP
             FROM C_ERGON.VW_DLK_ERG_HSETOR_
         """,
     },

diff --git a/pipelines/sigma/dump_db_compras_materiais/schedules.py b/pipelines/sigma/dump_db_compras_materiais/schedules.py
@@ -40,34 +40,12 @@
         "dump_mode": "overwrite",
         "execute_query": """
             SELECT
-                CPF_CNPJ,
-                TIPO_CPF_CNPJ,
-                INSCRICAO_MUNICIPAL,
-                INSCRICAO_ESTADUAL,
-                RAZAO_SOCIAL,
-                NOME_FANTASIA,
-                NOME_CONTATO,
-                EMAIL,
-                EMAIL_CONTATO,
-                FAX,
-                DDD,
-                DDI,
-                RAMAL,
-                TELEFONE,
-                LOGRADOURO,
-                NUMERO_PORTA,
-                COMPLEMENTO,
-                BAIRRO,
-                MUNICIPIO,
-                UF,
-                CEP,
-                ATIVO_INATIVO_BLOQUEADO,
-                CD_NATUREZA_JURIDICA,
-                DS_NATUREZA_JURIDICA,
-                RAMO_ATIVIDADE,
-                CD_PORTE_EMPRESA,
-                DATA_ULTIMA_ATUALIZACAO,
-                FORNECEDOR_EVENTUAL
+                CPF_CNPJ, TIPO_CPF_CNPJ, INSCRICAO_MUNICIPAL, INSCRICAO_ESTADUAL,
+                RAZAO_SOCIAL, NOME_FANTASIA, NOME_CONTATO, EMAIL, EMAIL_CONTATO,
+                FAX, DDD, DDI, RAMAL, TELEFONE, LOGRADOURO, NUMERO_PORTA, COMPLEMENTO,
+                BAIRRO, MUNICIPIO, UF, CEP, ATIVO_INATIVO_BLOQUEADO, CD_NATUREZA_JURIDICA,
+                DS_NATUREZA_JURIDICA, CD_RAMO_ATIVIDADE, DS_RAMO_ATIVIDADE, CD_PORTE_EMPRESA,
+                DATA_ULTIMA_ATUALIZACAO, TIPO_FORNECEDOR
             FROM SIGMA.VW_FORNECEDOR
         """,  # noqa
     },
@@ -78,12 +56,12 @@
         "dump_mode": "overwrite",
         "execute_query": """
             SELECT
-                CPF_CNPJ,
-                TIPO_CPF_CNPJ,
-                NOME,
-                NUMERO_PORTA,
-                COMPLEMENTO
-            FROM SIGMA.VW_FORNECEDOR_SEM_VINCULO
+                CPF_CNPJ, TIPO_CPF_CNPJ, NOME, EMAIL, FAX, DDD, DDI,
+                RAMAL, TELEFONE, LOGRADOURO, NUMERO_PORTA, COMPLEMENTO,
+                BAIRRO, MUNICIPIO, UF, CEP, ATIVO_INATIVO_BLOQUEADO,
+                CD_NATUREZA_JURIDICA, DS_NATUREZA_JURIDICA, RAMO_ATIVIDADE,
+                CD_PORTE_EMPRESA, DATA_ULTIMA_ATUALIZACAO
+            FROM SIGMA.VW_FORNECEDOR_SEM_VINCULO_OLD
         """,  # noqa
     },
     "grupo": {
@@ -105,37 +83,14 @@
         "materialization_mode": "prod",
         "dump_mode": "overwrite",
         "execute_query": """
-            SELECT C
-                D_MATERIAL,
-                CD_GRUPO,
-                CD_CLASSE,
-                CD_SUBCLASSE,
-                SEQUENCIAL,
-                DV1,
-                DV2,
-                NM_PADRONIZADO,
-                NM_COMPLEMENTAR_MATERIAL,
-                UNIDADE,
-                DS_DETALHE_MATERIAL,
-                DT_DESATIVACAO,
-                ST_STATUS,
-                REMUME,
-                ACONDICIONAMENTO,
-                TP_GENERO,
-                CD_MATERIAL_SUBSTITUTO,
-                NM_FANTASIA,
-                CD_COMPRASNET,
-                TP_MATERIAL,
-                ST_REFERENCIA,
-                ST_SISTEMA_REGISTRO_PRECO,
-                TERMOLABEL,
-                ST_CONTROLADO,
-                ST_PADRONIZADO,
-                ST_USO_GERAL,
-                ST_CONTINUADO,
-                ST_TABELADO,
-                ST_ITEM_SUSTENTAVEL,
-                OBSERVACAO
+            SELECT
+                CD_MATERIAL, CD_GRUPO, CD_CLASSE, CD_SUBCLASSE, SEQUENCIAL,
+                DV1, DV2, NM_PADRONIZADO, NM_COMPLEMENTAR_MATERIAL, UNIDADE,
+                DS_DETALHE_MATERIAL, DT_DESATIVACAO, ST_STATUS, REMUME,
+                ACONDICIONAMENTO, TP_GENERO, CD_MATERIAL_SUBSTITUTO, NM_FANTASIA,
+                CD_COMPRASNET, TP_MATERIAL, ST_REFERENCIA, ST_SISTEMA_REGISTRO_PRECO,
+                TERMOLABEL, ST_CONTROLADO, ST_PADRONIZADO, ST_USO_GERAL, ST_CONTINUADO,
+                ST_TABELADO, ST_ITEM_SUSTENTAVEL, OBSERVACAO
             FROM SIGMA.VW_MATERIAL
         """,  # noqa
     },