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
)

Add a code snippet to your website: www.paste.org