Etapa 1 • Fundação Estruturante

⏱️ Flag de Fluxo do EGP: 5 Dias

De-Para Arquitetural: SAS Legado ➔ Lakehouse FMK

Mapeamento linear das 5 colunas medalhão para o pipeline BASE_ORIGEM_FINAL (Matera & PSA). Clique em qualquer card para inspecionar atributos e rastrear linhagem.

5 Dias

Flag de Fluxo (EGP)

SLA Total de Entrega Homologada

8 Modelos

Staging Layer (SL)

dbt format_check (sem query)

5 Modelos

Target Layer (TL)

dbt integral (Cura, Maturity)

3 Modelos

Business Layer (BL)

Visões analíticas de consumo

160+

WORK.* Eliminadas

Convertidas em CTEs em memória

1. Ingestão 8

INP-01 Posicional

FP_*498_*.TXT

Circular 498: Chrysler, Planta e Usados.

05_498 .txt pos

INP-02 Cadastro

Planilha_Codigo_BUC.xlsx

De-Para CNPJ Dealer ↔ Phenix ↔ BUC.

PSA / 08 .xlsx

INP-03 BACEN SCR

TH_BANCO_3040

CADOC 3040: Contratos e atrasos oficiais.

SASDATA sas7bdat

INP-04 Garantias

TH_BANCO_GARANTIAS

Alienações fiduciárias, avais e hipotecas.

SASDATA sas7bdat

INP-05 LSI PSA

TH_LSI_CITROEN / PEUG

Limites rotativos concedidos e tomados.

SASDATA sas7bdat

INP-06 Perdas

PUBLICO_MARCA_PREJ_NOVO3

Histórico analítico de prejuízos.

Bruno_MS sas7bdat

INP-07 Fechamento

CONSOLIDADO_202301

Portfólio histórico CDC, Leasing, Finame.

Bruno_MS sas7bdat

INP-08 Subsídios

PSA.BASE_PSA

Base setorial de subsídios de rede PSA.

Cristian_MS sas7bdat

2. Staging (SL) 8

SL-01 format_check

st_fp_arquivo_498

Parsing posicional e unificação dos 498.

Task 03 models/sl

SL-02 format_check

st_cad_depara_buc

De-Para CNPJ Dealer ↔ Phenix ↔ BUC.

Task 05 models/sl

SL-03 format_check

st_bacen_cadoc_3040

Contratos e dias de atraso SCR BACEN.

Task 05 models/sl

SL-04 format_check

st_bacen_garantias_3040

Valores e tipos de garantias por contrato.

Task 05 models/sl

SL-05 format_check

st_lsi_limites_dealers

Limites e saldos Citroën e Peugeot.

Task 05 models/sl

SL-06 format_check

st_hist_marca_prejuizo

Marcas históricas de perdas contábeis.

Task 04 models/sl

SL-07 format_check

st_carteira_credito_historico

Portfólio histórico e saldos contábeis.

Task 01 models/sl

SL-08 format_check

st_base_setorial_psa

Subsídios de rede e marcas PSA.

Task 10 models/sl

3. Target (TL) 5

TL-01 integral

tb_credito_duplicatas_empilhada

Deduplicação QUALIFY, filtro temporal e flag PAGOU=1.

Tasks 01-04 models/tl

TL-02 integral

tb_credito_garantias_limites

Agregação SUM(garantias) e limites tomados por rede.

Task 05 models/tl

TL-03 integral

tb_credito_maturity_amortizacao

DATEDIFF(month) e curva de % amortizado por carteira.

Task 06 models/tl

TL-04 integral

tb_credito_motor_cura_probation

Default (>90d/prejuízo), 12m probation e raiz CNPJ (8d).

Tasks 07-09 models/tl

TL-05 • MESTRE Target Mestre

tb_credito_base_origem_consolidada

Consolidação estruturante unificada de contratos, limites, cura e marcas PSA.

Task 10 (PP.EMPILHADA_NOVA) models/tl

4. Business (BL) 3

BL-01 view

bl_credito_visao_contratos

Visão analítica de batimento de carteira e contratos.

Crédito / Risco models/bl

BL-02 view

bl_credito_painel_dealers

Painel de exposição e limites por rede dealer.

Rede Dealers models/bl

BL-03 table

bl_esteira_cura_default

Esteira regulatória BACEN 4966 de probation e cura.

Regulatório models/bl

5. Consumidores 3

EGP-01 Etapa 2

EGP: COMPLETO_2

Consome a base empilhada saneada para carteira.

Derivado 18 scripts

EGP-02 Etapa 2

EGP: PDD_COMPLETO

Motor central de cálculo de provisão de crédito.

Motor Central 30 scripts

EGP-03 Etapa 3

EGP: Motor_Tributario

Motor fiscal e tributário de fechamento contábil.

Fechamento 12 scripts

Target Layer (TL)

tb_credito_base_origem_consolidada

Materialização dbt integral

Origem Legada SAS PP.EMPILHADA_NOVA.sas7bdat

Tasks SAS Relacionadas Task 10 (10_08_Bases_PSA.sas)

Atributos & Chaves Principais cd_contrato, num_duplicata, cd_buc, dt_base, vl_saldo_atual

Regras de Negócio Junção mestre de contratos, limites de rede, status de cura/probation e marcas PSA.

Camada FMK	Origem / Objeto SAS Legado	Task SAS	Objeto FMK (Modelo / Tabela)	Materialização	Regra / Transformação de Negócio	Equivalência Snowflake / FMK	Status
SL (Staging)	FP_CHAA498, PLAA, USAA	`03_01_Tratamento_View`	st_fp_arquivo_498	`format_check`	Parsing posicional das duplicatas de Floor Plan e unificação de layouts.	`SUBSTR() + TRY_TO_DECIMAL()`	🟢 Validado
SL (Staging)	SASDATA.TH_BANCO_3040	`05_03_Cruzamento_PSA`	st_bacen_cadoc_3040	`format_check`	Base de atraso e dados cadastrais oficiais reportados ao BACEN (CADOC 3040 SCR).	`st_bacen_cadoc_3040`	🟢 Validado
SL (Staging)	SASDATA.TH_BANCO_GARANTIAS	`05_03_Cruzamento_PSA`	st_bacen_garantias_3040	`format_check`	Módulo regulatório de garantias (alienações fiduciárias, avais e hipotecas).	`st_bacen_garantias_3040`	🟢 Validado
SL (Staging)	TH_LSI_CITROEN / PEUGEOT	`05_03_Cruzamento_PSA`	st_lsi_limites_dealers	`format_check`	Limites rotativos concedidos, adicionais (over) e saldos utilizados por rede.	`UNION ALL com tag de rede`	🟢 Validado
SL (Staging)	Planilha_Codigo_BUC.xlsx	`05_03_Cruzamento_PSA`	st_cad_depara_buc	`format_check`	De-Para cadastral: CNPJ Dealer ↔ Código Phenix ↔ Código BUC formatado.	`LPAD(TRIM(cnpj), 14, '0')`	🟢 Validado
SL (Staging)	PUBLICO_MARCA_PREJ_NOVO3	`04_02_Base_Analise`	st_hist_marca_prejuizo	`format_check`	Marcas históricas de prejuízo contábil por contrato.	`st_hist_marca_prejuizo`	🟢 Validado
SL (Staging)	BRUNO.CONSOLIDADO_202301	`01_00_LIBNAMES`	st_carteira_credito_historico	`format_check`	Carteira de crédito com saldos contábeis e status histórico.	`st_carteira_credito_historico`	🟢 Validado
SL (Staging)	PSA.BASE_PSA	`10_08_Bases_PSA`	st_base_setorial_psa	`format_check`	Base de subsídios de rede e marcas específicas de portfólio PSA.	`st_base_setorial_psa`	🟢 Validado
TL (Target)	EMP.EMPILHADA_PAGTO_2025	`Tasks 01, 02, 03, 04`	tb_credito_duplicatas_empilhada	`integral`	Filtro de portfólio (CDC/Leasing), corte temporal (dt_base > 2018-04-30), cálculo de adimplência (PAGOU=1) e deduplicação de parcelas.	`QUALIFY ROW_NUMBER() = 1`	🟢 Validado
TL (Target)	CRIS.BASE_GARANTIAS / AUX_3040_*	`Task 05 (03_Cruzamento_PSA)`	tb_credito_garantias_limites	`integral`	Totalização de garantias agregadas por contrato (SUM) e consolidação de limites tomados vs. disponíveis por concessionária Citroën/Peugeot.	`LEFT JOIN + SUM(...) GROUP BY`	🟢 Validado
TL (Target)	GU_PARC.PERCENTUAL / MATURITY	`Task 06 (04_Maturity)`	tb_credito_maturity_amortizacao	`integral`	Cálculo de prazo residual (maturity) e curva de percentual acumulado de liquidação/amortização de duplicatas por carteira.	`DATEDIFF('month', dt_e, dt_v)`	🟢 Validado
TL (Target)	G_CURA.C_CONTRATOS / DEFAULT_FP	`Tasks 07, 08, 09 (Cura & Reproc)`	tb_credito_motor_cura_probation	`integral`	Motor de cura e probation: Default primário (>90d ou prejuízo), janela de 12 meses adimplente, raiz CNPJ (8 dígitos) e contrato mãe temp.	`COUNT_IF(atraso = 0) OVER (...) = 12`	🟢 Validado
TL (Target)	PP.EMPILHADA_NOVA (Target Mestre)	`Task 10 (08_Bases_PSA)`	tb_credito_base_origem_consolidada	`integral`	Target Mestre Estruturante que une contratos saneados, limites, status de cura e marcas PSA. Insumo oficial para COMPLETO_2 e PDD.	`JOIN tb_duplicatas + tb_cura + tb_garantias`	🟢 Validado
BL (Business)	Consumo Geral de Crédito	`Visão Analítica`	bl_credito_visao_contratos	`view`	Visão analítica de contratos consolidados para alimentação dos motores PDD e COMPLETO_2.	`SELECT ... FROM tb_credito_base_origem`	🟢 Validado
BL (Business)	Gestão de Rede Dealers	`Visão Analítica`	bl_credito_painel_dealers	`view`	Painel de acompanhamento de limites concedidos vs. saldo tomado por rede Citroën/Peugeot.	`SELECT ... GROUP BY dealer, rede`	🟢 Validado
BL (Business)	Regulatório BACEN 4966	`Visão Analítica`	bl_credito_esteira_cura_default	`table`	Esteira regulatória de monitoramento de entrada e saída de probation / cura.	`SELECT ... WHERE fl_probation = true`	🟢 Validado

Task 01 01_00_LIBNAMES.sas — Mapeamento de Libnames e Filtro de Portfólio Inicial

🟢 Validado

Origem Legada

• BRUNO.CONSOLIDADO_202301
• Filtro: PRODUTO IN ('CDC', 'LEASING', 'FINAME', 'CESSAO')

WORK.* Eliminadas

• WORK.BASE_EMPILHADA_PORD
• WORK.AVALIACAO

Destino no FMK

CTE filtro_portfolio_elegivel dentro do modelo TL
tb_credito_duplicatas_empilhada.sql

Task 02 02_Query_Builder.sas — Totalização de Saldos e Agregação por Flags

🟢 Validado

Origem Legada

• WORK.BASE_EMPILHADA_PORD
• SUM(DIAS_ATRASO_SOT), SUM(VL_SALDO_ATUAL_SOT)

WORK.* Eliminadas

• WORK.QUERY_FOR_BASE_EMPILHADA_PORD

Destino no FMK

CTE agregacao_flags_escopo (consolidada sem gravação física)

Task 03 03_01_Tratamento_View.sas — Ingestão Posicional Floor Plan 498 e Empilhamento

🟢 Validado

Origem Legada

• Arquivos: FP_CHAA498_*.TXT, FP_PLAA498_*.TXT, FP_USAA498_*.TXT
• Filtro: VL_SALDO_ATUAL > 0 AND DT_BASE > '30APR2018'd

WORK.* Eliminadas

• CHR_498, PLA_498, USA_498, EMPILHADA_498
• EMPILHADA_CTR, DATA_VIEW, PARCELAS

Destino no FMK

Modelo SL st_fp_arquivo_498.sql + Modelo TL tb_credito_duplicatas_empilhada.sql (com QUALIFY ROW_NUMBER() = 1)

Task 04 04_02_Base_Analise.sas — Cruzamento com Histórico de Prejuízo e Recálculo de Juros

🟢 Validado

Origem Legada

• BRUNO.MARCA_PUBLICO_ENTRA_PREJ
• BRUNO.TOTAL_VIEW2
• LIB_PREJ.PUBLICO_MARCA_PREJ_NOVO3

WORK.* Eliminadas

• PUBLICO_ANALISE, PUBLICO_ANALISE2_1
• AUX1, PUBLICO_ANALISE2_2

Destino no FMK

CTEs de recálculo de juros e amortização dentro de tb_credito_duplicatas_empilhada.sql

Task 05 05_03_Cruzamento_PSA.sas — Enriquecimento CADOC 3040, Garantias e Limites LSI

🟢 Validado

Origem Legada

• Planilha_Codigo_BUC.xlsx
• TH_BANCO_3040, TH_BANCO_GARANTIAS
• TH_LSI_CITROEN, TH_LSI_PEUGEOT

WORK.* Eliminadas

• COD_BUC_PSA, CRIS.AUX_3040_GARANTIAS
• CRIS.AUX_3040_CTR, CRIS.AUX_3040_PGT

Destino no FMK

Modelos SL (st_bacen_cadoc_3040, st_bacen_garantias_3040, st_lsi_limites_dealers) + Modelo TL tb_credito_garantias_limites.sql

Task 06 06_04_Maturity.sas — Apuração de Maturidade e Curva de Amortização

🟢 Validado

Origem Legada

• INTCK('month', DT_EMISSAO_DUPLICATA, DT_VENCIMENTO)
• Classificação em 4 carteiras (Recebíveis, Corporate, Empréstimos, Floorplan)

WORK.* Eliminadas

• BASE_EMPILHADA_1, BASE_EMPILHADA_NOVA
• MINIMO_DATA, EMPILHADA_DIAS, MATURITY_INDIVIDUAL

Destino no FMK

Modelo TL: tb_credito_maturity_amortizacao.sql com DATEDIFF('month', dt_emissao, dt_vencimento)

Task 07 07_05_Cura_Primeira_Analise.sas — Motor Regulatório de Default, Cura e Probation

🟢 Validado

Origem Legada

• Regra Default: ATRASO > 90 OR FL_PREJUIZO = 1
• Probation: 12 meses consecutivos de adimplência
• Raiz CNPJ: SUBSTR(COD_CPF_CNPJ, 1, 8)

WORK.* Eliminadas

• CURA_SEM_FP, DEU_DEFAULT_2, TEMP_8
• G_CURA.C_CONTRATOS_ANTES, C_CONTRATOS_COM_NULO

Destino no FMK

Modelo TL dedicado: tb_credito_motor_cura_probation.sql com Window Functions de contagem temporal

Task 08 08_06_Reprocessamento.sas — Tratamento de Saltos de Atraso e Exceções Cadastrais

🟢 Validado

Origem Legada

• Análise de salto de atraso: ATRASO_CONTRATO > LAG(ATRASO_CONTRATO) + 62
• Tratamento de exceções por APL e duplicata

WORK.* Eliminadas

• OLHA1, OLHA2, CRUZA_2
• G_CURA.MARCA_ATRASO_FP, MARCA_ATRASO

Destino no FMK

CTE de saneamento com LAG(atraso) OVER (PARTITION BY contrato ORDER BY dt_base) no motor de cura

Task 09 09_07_Assinala_contrato.sas — Vinculação de Contratos Não Cadastrados e Contrato Mãe

🟢 Validado

Origem Legada

• Atribuição de CONTRATO_MAE_TEMP para Floor Plan
• Tratamento de contratos não cadastrados vinculados à raiz 00024605

WORK.* Eliminadas

• SELEC_NAO_CAD, CONTAINS, D1, D2
• DELETA_CNPJ, SELECIONA

Destino no FMK

CTE vinculacao_contrato_mae dentro de tb_credito_motor_cura_probation.sql

Task 10 10_08_Bases_PSA.sas — Fechamento e Consolidação Final do Target Mestre

🟢 Validado

Origem Legada

• União de G_CURA.ATRASO com PSA.BASE_PSA
• Geração do arquivo oficial de saída: PP.EMPILHADA_NOVA.sas7bdat

WORK.* Eliminadas

• WORK.DT, WORK.DT2, WORK.MUDA

Destino no FMK

Modelo TL Mestre Final: tb_credito_base_origem_consolidada.sql (Insumo para PDD e COMPLETO_2)