DROP TABLE IF EXISTS d_mdl_vpc_disc.CONSOLIDADO_VARIABLES_AGENDA

CREATE TABLE d_mdl_vpc_disc.CONSOLIDADO_VARIABLES_AGENDA
WITH ( format = 'Parquet', 
         parquet_compression = 'SNAPPY', 
         partitioned_by = ARRAY['p_periodo'],
         external_location= 's3://sagemaker-us-east-1-058528764918/vpc/propension/athena/CONSOLIDADO_VARIABLES_AGENDA/'
       )
AS (
    
    SELECT U.periodo_campania
          ,U.periodo_ejecucion
          ,U.num_documento
          ,MAX(U.flg_pj) flg_pj
          ,MAX(U.nro_tlv_ibk_p1_p2_p3) nro_tlv_ibk_p1_p2_p3
          ,MAX(U.nro_tlv_bpe_p1_p2_p3) nro_tlv_bpe_p1_p2_p3
          ,MAX(U.nro_lo_pensara_ibk_p1_p2_p3) nro_lo_pensara_ibk_p1_p2_p3
          ,MAX(U.cant_clientes_principalidad_retail) cant_clientes_principalidad_retail
          ,MAX(U.nro_acepta_campana_ibk_p1) nro_acepta_campana_ibk_p1
          ,MAX(U.nro_no_acepta_campana_bpe_p1_p2_p3) nro_no_acepta_campana_bpe_p1_p2_p3
          ,MAX(U.ciiu_val) ciiu_val
          ,MAX(U.promedio_edad_rrll) promedio_edad_rrll
          ,MAX(U.saldo_prom_tot_activo_rrll) saldo_prom_tot_activo_rrll
          ,MAX(U.producto_maximo_rrll) producto_maximo_rrll
          ,MAX(U.nro_acepta_campana_ibk_p1_p2_p3) nro_acepta_campana_ibk_p1_p2_p3
          ,MAX(U.tiempo_alta) tiempo_alta
          ,MAX(U.tip_contribuyente_val) tip_contribuyente_val
          ,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(H.avg_nro_entidades_u12m, 0.0)) avg_nro_entidades_u12m
          ,MAX(coalesce(H.avg_nroregs_coloc_directas_bcos_u6m, 0.0)) avg_nroregs_coloc_directas_bcos_u6m
          ,MAX(coalesce(H.avg_saldo_coloc_direct_vig_cmpt_u6m, 0.0)) avg_saldo_coloc_direct_vig_cmpt_u6m
          ,SUM(coalesce(R.saldo_coloc_direct_tc, 0)) saldo_coloc_direct_tc
          ,SUM(coalesce(R.saldo_coloc_direct_vig, 0)) saldo_coloc_direct_vig
          ,MAX(coalesce(M.deuda_sf_prom_ult3m , 0)) deuda_sf_prom_ult3m_max
          ,MAX(coalesce(M.deuda_sf_prom_ult9m , 0)) deuda_sf_prom_ult9m_max
          ,MAX(coalesce(M.tend_facturacion_ult_mes_mnt, 0)) tend_facturacion_ult_mes_mnt
          ,MAX(coalesce(P.entidad_prin_desc, 'SIN COLOCACION')) entidad_prin_desc
          ,MAX(coalesce(P.flg_banco_prin_no_ibk , 0)) flg_banco_prin_no_ibk
          ,MAX(coalesce(P.flg_entidad_prin_caja , 0)) flg_entidad_prin_caja
          ,MAX(coalesce(P.saldo_entidad_prin_no_ibk , 0)) saldo_entidad_prin_no_ibk
          ,MAX(coalesce(P.flg_sin_colocacion , 0)) flg_sin_colocacion
          
           
          
        ,MAX(U.p_periodo) p_periodo
        
    FROM UNIVERSO_PREVIO_3 U
    LEFT JOIN BASE_RCC 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)
    LEFT JOIN BANCO_PRIN_3 P
    ON U.periodo_campania = P.periodo_campania 
       AND U.periodo_ejecucion = P.periodo_ejecucion
       AND U.num_documento = P.num_documento
    WHERE 1 = 1
    AND U.flg_tiene_info_sunat = 1
    GROUP BY U.periodo_campania
            ,U.periodo_ejecucion
            ,U.num_documento
)