Welcome, guest! Login / Register - Why register?
Psst.. new poll here.
Psst.. new forums here.
Microsoft is blocking us again (TY IP Reputation!) so dont bother with any of their useless mail servers here and just use oauth login instead. Thank the nice Russians for causing that. :)

Paste

Pasted as SQL by registered user vvillacorta ( 4 years ago )
SELECT COUNT(1) FROM d_mdl_vpc_disc.STAGE_HM_PREVIO_UNIVERSO_NUEVO_AGENDA  --- 974259
DROP TABLE d_mdl_vpc_disc.STAGE_HM_PREVIO_UNIVERSO_NUEVO_AGENDA


CREATE TABLE d_mdl_vpc_disc.STAGE_HM_PREVIO_UNIVERSO_NUEVO_AGENDA
    WITH ( format = 'Parquet', 
             parquet_compression = 'SNAPPY', 
             partitioned_by = ARRAY['p_periodo'],
             external_location= 's3://sagemaker-us-east-1-058528764918/vpc/propension/athena/STAGE_HM_PREVIO_UNIVERSO_NUEVO_AGENDA/'
           )
    AS (

SELECT AA.periodo_campania
       ,AA.periodo_ejecucion
       ,AA.num_documento
       ,MAX(AA.flg_acepta_campana_bpe) target_agenda
       ,MAX(AA.periodo_p1) periodo_p1
       ,MAX(AA.periodo_p2) periodo_p2
       ,MAX(AA.periodo_p3) periodo_p3
       ,SUM(AA.nro_llamadas_registradas_ibk_p1) nro_llamadas_registradas_ibk_p1
       ,SUM(AA.nro_llamadas_registradas_ibk_p1_p2_p3) nro_llamadas_registradas_ibk_p1_p2_p3
       ,SUM(AA.nro_llamadas_timbradas_ibk_p1) nro_llamadas_timbradas_ibk_p1   
       ,SUM(AA.nro_llamadas_timbradas_ibk_p1_p2_p3) nro_llamadas_timbradas_ibk_p1_p2_p3
       ,SUM(AA.nro_llamadas_ce_ibk_p1) nro_llamadas_ce_ibk_p1
       ,SUM(AA.nro_llamadas_ce_ibk_p1_p2_p3) nro_llamadas_ce_ibk_p1_p2_p3
       ,SUM(AA.nro_llamadas_cne_ibk_p1) nro_llamadas_cne_ibk_p1
       ,SUM(AA.nro_llamadas_cne_ibk_p1_p2_p3) nro_llamadas_cne_ibk_p1_p2_p3
       ,SUM(AA.nro_tlv_ibk_p1) nro_tlv_ibk_p1   
       ,SUM(AA.nro_tlv_ibk_p1_p2_p3) nro_tlv_ibk_p1_p2_p3
       ,SUM(AA.nro_gestionado_ibk_p1) nro_gestionado_ibk_p1   
       ,SUM(AA.nro_gestionado_ibk_p1_p2_p3) nro_gestionado_ibk_p1_p2_p3
       ,SUM(AA.minutos_totales_ibk_p1) minutos_totales_ibk_p1
       ,SUM(AA.minutos_totales_ibk_p1_p2_p3) minutos_totales_ibk_p1_p2_p3
       ,SUM(AA.minutos_ibk_ce_p1) minutos_ibk_ce_p1   
       ,SUM(AA.minutos_ibk_ce_p1_p2_p3) minutos_ibk_ce_p1_p2_p3
       ,SUM(AA.nro_ce_ibk_p1) nro_ce_ibk_p1
       ,SUM(AA.nro_ce_ibk_p1_p2_p3) nro_ce_ibk_p1_p2_p3   
       ,SUM(AA.nro_cne_ibk_p1) nro_cne_ibk_p1 
       ,SUM(AA.nro_cne_ibk_p1_p2_p3) nro_cne_ibk_p1_p2_p3
       ,SUM(AA.nro_acepta_campana_ibk_p1) nro_acepta_campana_ibk_p1
       ,SUM(AA.nro_acepta_campana_ibk_p1_p2_p3) nro_acepta_campana_ibk_p1_p2_p3 
       ,SUM(AA.nro_no_acepta_campana_ibk_p1) nro_no_acepta_campana_ibk_p1   
       ,SUM(AA.nro_no_acepta_campana_ibk_p1_p2_p3) nro_no_acepta_campana_ibk_p1_p2_p3
       ,SUM(AA.nro_no_califica_ibk_p1) nro_no_califica_ibk_p1
       ,SUM(AA.nro_no_califica_ibk_p1_p2_p3) nro_no_califica_ibk_p1_p2_p3   
       ,SUM(AA.nro_lo_pensara_ibk_p1) nro_lo_pensara_ibk_p1
       ,SUM(AA.nro_lo_pensara_ibk_p1_p2_p3) nro_lo_pensara_ibk_p1_p2_p3 
       ,SUM(AA.nro_llamadas_registradas_bpe_p1) nro_llamadas_registradas_bpe_p1
       ,SUM(AA.nro_llamadas_registradas_bpe_p1_p2_p3) nro_llamadas_registradas_bpe_p1_p2_p3
       ,SUM(AA.nro_llamadas_timbradas_bpe_p1) nro_llamadas_timbradas_bpe_p1   
       ,SUM(AA.nro_llamadas_timbradas_bpe_p1_p2_p3) nro_llamadas_timbradas_bpe_p1_p2_p3
       ,SUM(AA.nro_llamadas_ce_bpe_p1) nro_llamadas_ce_bpe_p1
       ,SUM(AA.nro_llamadas_ce_bpe_p1_p2_p3) nro_llamadas_ce_bpe_p1_p2_p3
       ,SUM(AA.nro_llamadas_cne_bpe_p1) nro_llamadas_cne_bpe_p1
       ,SUM(AA.nro_llamadas_cne_bpe_p1_p2_p3) nro_llamadas_cne_bpe_p1_p2_p3
       ,SUM(AA.nro_tlv_bpe_p1) nro_tlv_bpe_p1   
       ,SUM(AA.nro_tlv_bpe_p1_p2_p3) nro_tlv_bpe_p1_p2_p3
       ,SUM(AA.nro_gestionado_bpe_p1) nro_gestionado_bpe_p1   
       ,SUM(AA.nro_gestionado_bpe_p1_p2_p3) nro_gestionado_bpe_p1_p2_p3
       ,SUM(AA.minutos_bpe_p1) minutos_totales_bpe_p1
       ,SUM(AA.minutos_bpe_p1_p2_p3) minutos_totales_bpe_p1_p2_p3
       ,SUM(AA.minutos_bpe_ce_p1) minutos_bpe_ce_p1   
       ,SUM(AA.minutos_bpe_ce_p1_p2_p3) minutos_bpe_ce_p1_p2_p3
       ,SUM(AA.nro_ce_bpe_p1) nro_ce_bpe_p1
       ,SUM(AA.nro_ce_bpe_p1_p2_p3) nro_ce_bpe_p1_p2_p3   
       ,SUM(AA.nro_cne_bpe_p1) nro_cne_bpe_p1 
       ,SUM(AA.nro_cne_bpe_p1_p2_p3) nro_cne_bpe_p1_p2_p3
       ,SUM(AA.nro_acepta_campana_bpe_p1) nro_acepta_campana_bpe_p1
       ,SUM(AA.nro_acepta_campana_bpe_p1_p2_p3) nro_acepta_campana_bpe_p1_p2_p3 
       ,SUM(AA.nro_no_acepta_campana_bpe_p1) nro_no_acepta_campana_bpe_p1   
       ,SUM(AA.nro_no_acepta_campana_bpe_p1_p2_p3) nro_no_acepta_campana_bpe_p1_p2_p3
       ,SUM(AA.nro_no_califica_bpe_p1) nro_no_califica_bpe_p1
       ,SUM(AA.nro_no_califica_bpe_p1_p2_p3) nro_no_califica_bpe_p1_p2_p3   
       ,SUM(AA.nro_lo_pensara_bpe_p1) nro_lo_pensara_bpe_p1
       ,SUM(AA.nro_lo_pensara_bpe_p1_p2_p3) nro_lo_pensara_bpe_p1_p2_p3
       ,CASE WHEN MAX(SS.numruc_val) IS NOT NULL THEN 1 ELSE 0 END flg_tiene_info_sunat
       ,MAX(SS.flg_pn) flg_pn
       ,MAX(SS.flg_pj) flg_pj
       ,AA.periodo_ejecucion p_periodo
FROM(

    SELECT PRESENTE.periodo_val periodo_campania
           ,substr(replace(substr(cast(date_add('month', -1, date_parse(PRESENTE.periodo_val ,'%Y%m')) as varchar), 1, 10), '-', ''), 1, 6) periodo_ejecucion
           ,PRESENTE.num_documento
           ,PRESENTE.flg_acepta_campana_bpe
           ,P1.periodo_val periodo_p1
           ,P2.periodo_val periodo_p2
           ,P3.periodo_val periodo_p3
               ,coalesce(P1.nro_llamadas_registradas_ibk, 0) nro_llamadas_registradas_ibk_p1
               ,coalesce(P1.nro_llamadas_registradas_ibk, 0) + coalesce(P2.nro_llamadas_registradas_ibk, 0) + coalesce(P3.nro_llamadas_registradas_ibk, 0)nro_llamadas_registradas_ibk_p1_p2_p3
               ,coalesce(P1.nro_llamadas_timbradas_ibk, 0) nro_llamadas_timbradas_ibk_p1
               ,coalesce(P1.nro_llamadas_timbradas_ibk, 0) + coalesce(P2.nro_llamadas_timbradas_ibk, 0) + coalesce(P3.nro_llamadas_timbradas_ibk, 0) nro_llamadas_timbradas_ibk_p1_p2_p3
               ,coalesce(P1.nro_llamadas_ce_ibk, 0) nro_llamadas_ce_ibk_p1
               ,coalesce(P1.nro_llamadas_ce_ibk, 0) + coalesce(P2.nro_llamadas_ce_ibk, 0) +  coalesce(P3.nro_llamadas_ce_ibk, 0) nro_llamadas_ce_ibk_p1_p2_p3
               ,coalesce(P1.nro_llamadas_cne_ibk, 0) nro_llamadas_cne_ibk_p1
               ,coalesce(P1.nro_llamadas_cne_ibk, 0) + coalesce(P2.nro_llamadas_cne_ibk, 0) +  coalesce(P3.nro_llamadas_cne_ibk, 0)nro_llamadas_cne_ibk_p1_p2_p3
               ,coalesce(P1.flg_tlv_ibk, 0) nro_tlv_ibk_p1
               ,coalesce(P1.flg_tlv_ibk, 0) + coalesce(P2.flg_tlv_ibk, 0) +  coalesce(P3.flg_tlv_ibk, 0) nro_tlv_ibk_p1_p2_p3
               ,coalesce(P1.flg_gestionado_ibk, 0) nro_gestionado_ibk_p1
               ,coalesce(P1.flg_gestionado_ibk, 0) + coalesce(P2.flg_gestionado_ibk, 0) +  coalesce(P3.flg_gestionado_ibk, 0) nro_gestionado_ibk_p1_p2_p3
               ,coalesce(P1.minutos_totales_ibk, 0) minutos_totales_ibk_p1
               ,coalesce(P1.minutos_totales_ibk, 0) + coalesce(P2.minutos_totales_ibk, 0) +  coalesce(P3.minutos_totales_ibk, 0) minutos_totales_ibk_p1_p2_p3
               ,coalesce(P1.minutos_ibk_ce, 0) minutos_ibk_ce_p1
               ,coalesce(P1.minutos_ibk_ce, 0) + coalesce(P2.minutos_ibk_ce, 0) +  coalesce(P3.minutos_ibk_ce, 0) minutos_ibk_ce_p1_p2_p3
               ,coalesce(P1.flg_ce_ibk, 0) nro_ce_ibk_p1
               ,coalesce(P1.flg_ce_ibk, 0) + coalesce(P2.flg_ce_ibk, 0) +  coalesce(P3.flg_ce_ibk, 0) nro_ce_ibk_p1_p2_p3
               ,coalesce(P1.flg_cne_ibk, 0) nro_cne_ibk_p1
              ,PRESENTE.periodo_val p_periodo
              
    FROM e_perm_aws.t_fact_vpc_tlv_feedback PRESENTE
    LEFT JOIN e_perm_aws.t_fact_vpc_tlv_feedback P1 
    ON PRESENTE.num_documento = P1.num_documento AND PRESENTE.periodo_val = substr(replace(substr(cast(date_add('month', +1, date_parse(P1.periodo_val ,'%Y%m')) as varchar), 1, 10), '-', ''), 1, 6)
    LEFT JOIN e_perm_aws.t_fact_vpc_tlv_feedback P2 
    ON PRESENTE.num_documento = P2.num_documento AND PRESENTE.periodo_val = substr(replace(substr(cast(date_add('month', +2, date_parse(P2.periodo_val ,'%Y%m')) as varchar), 1, 10), '-', ''), 1, 6)
    LEFT JOIN e_perm_aws.t_fact_vpc_tlv_feedback P3 
    ON PRESENTE.num_documento = P3.num_documento AND PRESENTE.periodo_val = substr(replace(substr(cast(date_add('month', +3, date_parse(P3.periodo_val ,'%Y%m')) as varchar), 1, 10), '-', ''), 1, 6)
    WHERE 1 = 1 
    AND PRESENTE.flg_creditos_nuevos_bpe = 1
    AND PRESENTE.periodo_val >= '202106'
) AA
LEFT JOIN e_perm_aws.t_fact_vpc_agg_sunat_reniec SS
ON AA.periodo_ejecucion = SS.periodo_val
   AND AA.num_documento = SS.numruc_val
GROUP BY AA.periodo_campania
       ,AA.periodo_ejecucion
       ,AA.num_documento
)

----------------------------------------------------------------------------------------------------------------------------------------
----------------------------------------------------------------------------------------------------------------------------------------
----------------------------------------------------------------------------------------------------------------------------------------
----------------------------------------------------------------------------------------------------------------------------------------
----------------------------------------------------------------------------------------------------------------------------------------
SELECT fecha_sbs_dt, banca_fin_val, count(1) 
FROM e_perm_aws.t_vpc_segmentacion_merc
GROUP BY fecha_sbs_dt, banca_fin_val
ORDER BY fecha_sbs_dt desc, banca_fin_val

--SELECT COUNT(1) FROM d_mdl_vpc_disc.STAGE_HM_BASE_RCC_AGENDA
DROP TABLE d_mdl_vpc_disc.STAGE_HM_BASE_RCC_AGENDA

CREATE TABLE d_mdl_vpc_disc.STAGE_HM_BASE_RCC_AGENDA
WITH ( format = 'Parquet', 
         parquet_compression = 'SNAPPY', 
         partitioned_by = ARRAY['p_periodo'],
         external_location= 's3://sagemaker-us-east-1-058528764918/vpc/propension/athena/STAGE_HM_BASE_RCC_AGENDA/'
       )
AS (
    SELECT * FROM
    (
          SELECT S.periodo_campania
                ,S.periodo_ejecucion
                ,R.periodo_val periodo_rcc
                ,R.fecha_sbs_dt
                ,S.num_documento
                ,R.cod_sbs_val,
                 S.periodo_ejecucion p_periodo
          FROM d_mdl_vpc_disc.STAGE_HM_PREVIO_UNIVERSO_NUEVO_AGENDA S 
          INNER JOIN e_perm_aws.t_fact_vpc_detalle_cliente_rcc R
          ON S.cod_sbs_empresa_1 =  R.cod_sbs_val
             AND S.periodo_ejecucion = substr(replace(substr(cast(date_add('month', +1, date_parse(R.periodo_val ,'%Y%m')) as varchar), 1, 10), '-', ''), 1, 6)
          WHERE 1 = 1
          and S.num_documento is not null
          and S.cod_sbs_empresa_1 is not null
          and S.cod_sbs_empresa_1 not like ''
          and S.cod_sbs_empresa_1 != '.'
    )
    UNION
    (
          SELECT S.periodo_campania
                ,S.periodo_ejecucion
                ,R.periodo_val periodo_rcc
                ,R.fecha_sbs_dt
                ,S.num_documento
                ,R.cod_sbs_val,
                 S.periodo_ejecucion p_periodo
          FROM d_mdl_vpc_disc.STAGE_HM_PREVIO_UNIVERSO_NUEVO_AGENDA S 
          INNER JOIN e_perm_aws.t_fact_vpc_detalle_cliente_rcc R
          ON S.cod_sbs_empresa_2 =  R.cod_sbs_val
             AND S.periodo_ejecucion = substr(replace(substr(cast(date_add('month', +1, date_parse(R.periodo_val ,'%Y%m')) as varchar), 1, 10), '-', ''), 1, 6)
          WHERE 1 = 1
          and S.num_documento is not null
          and S.cod_sbs_empresa_2 is not null
          and S.cod_sbs_empresa_2 not like ''
          and S.cod_sbs_empresa_2 != '.'
    )
    UNION
    (
          SELECT S.periodo_campania
                ,S.periodo_ejecucion
                ,R.periodo_val periodo_rcc
                ,R.fecha_sbs_dt
                ,S.num_documento
                ,R.cod_sbs_val,
                 S.periodo_ejecucion p_periodo
          FROM d_mdl_vpc_disc.STAGE_HM_PREVIO_UNIVERSO_NUEVO_AGENDA S 
          INNER JOIN e_perm_aws.t_fact_vpc_detalle_cliente_rcc R
          ON S.cod_sbs_empresa_3 =  R.cod_sbs_val
             AND S.periodo_ejecucion = substr(replace(substr(cast(date_add('month', +1, date_parse(R.periodo_val ,'%Y%m')) as varchar), 1, 10), '-', ''), 1, 6)
          WHERE 1 = 1
          and S.num_documento is not null
          and S.cod_sbs_empresa_3 is not null
          and S.cod_sbs_empresa_3 not like ''
          and S.cod_sbs_empresa_3 != '.'
    )
    UNION
    (
          SELECT S.periodo_campania
                ,S.periodo_ejecucion
                ,R.periodo_val periodo_rcc
                ,R.fecha_sbs_dt
                ,S.num_documento
                ,R.cod_sbs_val,
                 S.periodo_ejecucion p_periodo
          FROM d_mdl_vpc_disc.STAGE_HM_PREVIO_UNIVERSO_NUEVO_AGENDA S 
          INNER JOIN e_perm_aws.t_fact_vpc_detalle_cliente_rcc R
          ON S.cod_sbs_empresa_4 =  R.cod_sbs_val
             AND S.periodo_ejecucion = substr(replace(substr(cast(date_add('month', +1, date_parse(R.periodo_val ,'%Y%m')) as varchar), 1, 10), '-', ''), 1, 6)
          WHERE 1 = 1
          and S.num_documento is not null
          and S.cod_sbs_empresa_4 is not null
          and S.cod_sbs_empresa_4 not like ''
          and S.cod_sbs_empresa_4 != '.'
    )
    UNION
    (
          SELECT S.periodo_campania
                ,S.periodo_ejecucion
                ,R.periodo_val periodo_rcc
                ,R.fecha_sbs_dt
                ,S.num_documento
                ,R.cod_sbs_val,
                 S.periodo_ejecucion p_periodo
          FROM d_mdl_vpc_disc.STAGE_HM_PREVIO_UNIVERSO_NUEVO_AGENDA S 
          INNER JOIN e_perm_aws.t_fact_vpc_detalle_cliente_rcc R
          ON S.cod_sbs_rrll_1 =  R.cod_sbs_val
             AND S.periodo_ejecucion = substr(replace(substr(cast(date_add('month', +1, date_parse(R.periodo_val ,'%Y%m')) as varchar), 1, 10), '-', ''), 1, 6)
          WHERE 1 = 1
          and S.num_documento is not null
          and S.cod_sbs_rrll_1 is not null
          and S.cod_sbs_rrll_1 not like ''
          and S.cod_sbs_rrll_1 != '.'
          AND (cod_sbs_empresa_1 IS NULL OR cod_sbs_empresa_1 like '' OR cod_sbs_empresa_1 = '.')
    )
    UNION
    (
          SELECT S.periodo_campania
                ,S.periodo_ejecucion
                ,R.periodo_val periodo_rcc
                ,R.fecha_sbs_dt
                ,S.num_documento
                ,R.cod_sbs_val,
                 S.periodo_ejecucion p_periodo
          FROM d_mdl_vpc_disc.STAGE_HM_PREVIO_UNIVERSO_NUEVO_AGENDA S 
          INNER JOIN e_perm_aws.t_fact_vpc_detalle_cliente_rcc R
          ON S.cod_sbs_rrll_2 =  R.cod_sbs_val
             AND S.periodo_ejecucion = substr(replace(substr(cast(date_add('month', +1, date_parse(R.periodo_val ,'%Y%m')) as varchar), 1, 10), '-', ''), 1, 6)
          WHERE 1 = 1
          and S.num_documento is not null
          and S.cod_sbs_rrll_2 is not null
          and S.cod_sbs_rrll_2 not like ''
          and S.cod_sbs_rrll_2 != '.'
          AND (cod_sbs_empresa_1 IS NULL OR cod_sbs_empresa_1 like '' OR cod_sbs_empresa_1 = '.')
    )
    UNION
    (
          SELECT S.periodo_campania
                ,S.periodo_ejecucion
                ,R.periodo_val periodo_rcc
                ,R.fecha_sbs_dt
                ,S.num_documento
                ,R.cod_sbs_val,
                 S.periodo_ejecucion p_periodo
          FROM d_mdl_vpc_disc.STAGE_HM_PREVIO_UNIVERSO_NUEVO_AGENDA S 
          INNER JOIN e_perm_aws.t_fact_vpc_detalle_cliente_rcc R
          ON S.cod_sbs_rrll_3 =  R.cod_sbs_val
             AND S.periodo_ejecucion = substr(replace(substr(cast(date_add('month', +1, date_parse(R.periodo_val ,'%Y%m')) as varchar), 1, 10), '-', ''), 1, 6)
          WHERE 1 = 1
          and S.num_documento is not null
          and S.cod_sbs_rrll_3 is not null
          and S.cod_sbs_rrll_3 not like ''
          and S.cod_sbs_rrll_3 != '.'
          AND (cod_sbs_empresa_1 IS NULL OR cod_sbs_empresa_1 like '' OR cod_sbs_empresa_1 = '.')
    )
)

SELECT periodo_campania, COUNT(1), count(distinct(cod_sbs_val))
FROM d_mdl_vpc_disc.STAGE_HM_BASE_RCC_AGENDA
GROUP BY periodo_campania
ORDER BY periodo_campania DESC


----------------------------------------------------------------------------------------------------------------------------------------
----------------------------------------------------------------------------------------------------------------------------------------
----------------------------------------------------------------------------------------------------------------------------------------
----------------------------------------------------------------------------------------------------------------------------------------
----------------------------------------------------------------------------------------------------------------------------------------

SELECT * FROM d_mdl_vpc_disc.STAGE_HM_BASE_RCC_AGENDA LIMIT 100
SELECT * FROM d_mdl_vpc_disc.STAGE_HM_PREVIO_UNIVERSO_NUEVO_AGENDA LIMIT 100
SELECT * FROM  d_mdl_vpc_disc.stage_hm_universo_mercado_rcc_agenda LIMIT 100

CREATE TABLE d_mdl_vpc_disc.STAGE_HM_UNIVERSO_MERCADO_RCC_AGENDA
WITH ( format = 'Parquet', 
         parquet_compression = 'SNAPPY', 
         partitioned_by = ARRAY['p_periodo'],
         external_location= 's3://sagemaker-us-east-1-058528764918/vpc/propension/athena/STAGE_HM_UNIVERSO_MERCADO_RCC_AGENDA/'
       )
AS (
    
    SELECT U.periodo_campania
          ,U.periodo_ejecucion
          ,U.num_documento
          ,CASE WHEN MAX(B.periodo_rcc) is not null THEN 1 ELSE 0 END flg_tiene_info_rcc
          ,MAX(B.periodo_rcc) periodo_rcc
          ,MAX(B.fecha_sbs_dt) fecha_sbs_dt,
         MAX(coalesce(R.nro_tipo_entidad, 0)) nro_tipo_entidad,
         MAX(coalesce(R.nro_entidades, 0)) nro_entidades,
         SUM(coalesce(R.nroregs_garantia_reactiva_bcos, 0)) nroregs_garantia_reactiva_bcos,
         SUM(coalesce(R.nroregs_reactiva_bcos, 0)) nroregs_reactiva_bcos,
         SUM(coalesce(R.nroregs_inmobiliario_bcos, 0)) nroregs_inmobiliario_bcos,
         SUM(coalesce(R.nroregs_garantias_bcos, 0)) nroregs_garantias_bcos,
         SUM(coalesce(R.nroregs_reprogramados_bcos, 0)) nroregs_reprogramados_bcos,
         SUM(coalesce(R.nroregs_cred_castigados_bcos, 0)) nroregs_cred_castigados_bcos,
         SUM(coalesce(R.nroregs_garantia_fae_bcos, 0)) nroregs_garantia_fae_bcos,
         SUM(coalesce(R.nroregs_fae_bcos, 0)) nroregs_fae_bcos,
         SUM(coalesce(R.nroregs_coloc_directas_bcos, 0)) nroregs_coloc_directas_bcos,
         SUM(coalesce(R.nroregs_coloc_indirectas_bcos, 0)) nroregs_coloc_indirectas_bcos,
         SUM(coalesce(R.nroregs_garantia_reactiva_cajas, 0)) nroregs_garantia_reactiva_cajas,
         SUM(coalesce(R.nroregs_reactiva_cajas, 0)) nroregs_reactiva_cajas,
         SUM(coalesce(R.nroregs_inmobiliario_cajas, 0)) nroregs_inmobiliario_cajas,
         SUM(coalesce(R.nroregs_garantias_cajas, 0)) nroregs_garantias_cajas,
         SUM(coalesce(R.nroregs_reprogramados_cajas, 0)) nroregs_reprogramados_cajas,
         SUM(coalesce(R.nroregs_cred_castigados_cajas, 0)) nroregs_cred_castigados_cajas,
         SUM(coalesce(R.nroregs_garantia_fae_cajas, 0)) nroregs_garantia_fae_cajas,
         SUM(coalesce(R.nroregs_fae_cajas, 0)) nroregs_fae_cajas,
         SUM(coalesce(R.nroregs_coloc_directas_cajas, 0)) nroregs_coloc_directas_cajas,
         SUM(coalesce(R.nroregs_coloc_indirectas_cajas, 0)) nroregs_coloc_indirectas_cajas,
         MAX(coalesce(R.flg_clasif_normal, 0)) flg_clasif_normal,
         MAX(coalesce(R.flg_clasif_cpp, 0)) flg_clasif_cpp,
         MAX(coalesce(R.flg_clasif_deficiente, 0)) flg_clasif_deficiente,
         MAX(coalesce(R.flg_clasif_dudosa, 0)) flg_clasif_dudosa,
         MAX(coalesce(R.flg_clasif_perdida, 0)) flg_clasif_perdida,
         SUM(coalesce(R.saldo_vig_con_lm, 0)) saldo_vig_con_lm,
         SUM(coalesce(R.saldo_vig_sin_lm, 0)) saldo_vig_sin_lm,
         SUM(coalesce(R.saldo_venc_con_lm, 0)) saldo_venc_con_lm,
         SUM(coalesce(R.saldo_venc_sin_lm, 0)) saldo_venc_sin_lm,
         SUM(coalesce(R.saldo_garantia_reactiva, 0)) saldo_garantia_reactiva,
         SUM(coalesce(R.saldo_reactiva, 0)) saldo_reactiva,
         SUM(coalesce(R.saldo_inmobiliario, 0)) saldo_inmobiliario,
         SUM(coalesce(R.saldo_garantias, 0)) saldo_garantias,
         SUM(coalesce(R.saldo_reprogramados, 0)) saldo_reprogramados,
         SUM(coalesce(R.saldo_creditos_castigados, 0)) saldo_creditos_castigados,
         SUM(coalesce(R.saldo_garantia_fae, 0)) saldo_garantia_fae,
         SUM(coalesce(R.saldo_fae, 0)) saldo_fae,
        ,MAX(U.p_periodo) p_periodo
        
    FROM d_mdl_vpc_disc.STAGE_HM_PREVIO_UNIVERSO_NUEVO_AGENDA U
    LEFT JOIN d_mdl_vpc_disc.STAGE_HM_BASE_RCC_AGENDA B
    ON U.periodo_campania = B.periodo_campania 
       AND U.periodo_ejecucion = B.periodo_ejecucion
       AND U.num_documento = B.num_documento
    LEFT JOIN e_perm_aws.T_FACT_VPC_DESEMBOLSO_MERCADO M
    ON B.periodo_rcc = M.periodo
       AND B.cod_sbs_val = M.cod_sbs_val
    LEFT JOIN e_perm_aws.T_FACT_VPC_DETALLE_CLIENTE_RCC R
    ON B.cod_sbs_val = R.cod_sbs_val  
       AND B.periodo_rcc = R.periodo_val
    LEFT JOIN e_perm_aws.t_fact_vpc_historico_rcc H
    ON cast(B.cod_sbs_val as varchar)  = H.cod_sbs_val
       AND B.fecha_sbs_dt = H.fecha_sbs_dt
    LEFT JOIN e_perm_aws.t_fact_vpc_tendencia_rcc T
    ON B.cod_sbs_val = T.cod_sbs_val 
       AND B.periodo_rcc = cast(T.periodo_val as varchar)
       
    GROUP BY U.periodo_campania
            ,U.periodo_ejecucion
            ,U.num_documento
)

 

Revise this Paste

Your Name: Code Language: