<- spark_read_parquet(sc,
DE_s path = "hdfs:///dataset/MiDAS_v6/FHS/de.parquet",
memory = FALSE)
<- spark_read_parquet(sc,
PJC_s path = "hdfs:///dataset/MiDAS_v6/FNA/pjc.parquet",
memory = FALSE)
<- spark_read_parquet(sc,
PRM_s path = "hdfs:///dataset/MiDAS_v6/FNA/prm.parquet",
memory = FALSE)
<- spark_read_parquet(sc,
BMS_s path = "hdfs:///dataset/MiDAS_v6/Allstat/minsoc/cnaf_indiv_1223.parquet", # à modifier selon la période étudiée
memory = FALSE)
# Période étudiée
<- as.Date("2023-12-31")
date_fin <- as.Date("2023-12-01")
date_ms
# Etape 1 : pour identifier les personnes indemnisables et indemnisées, repartir du code de la fiche "Allocations agrégées et régimes d'indemnisation", qui crée
# la table "alloc_fm" contenant toutes les personnes d'intérêt sur la période étudiée.
<- alloc_fm %>%
pjc_clean select(id_midas,KROD1,KDDPJ,KDFPJ,KCPJC)
# Inscrits à FT
<- DE_s %>%
champ_de_fm filter(DATINS <= date_fin & (is.na(DATANN) | DATANN > date_fin)) %>% # Nombre d'inscrits en fin de mois
select(id_midas,DATINS,DATANN) %>%
distinct(id_midas,.keep_all = T) # On garde une période d'inscription par personne
# Bénéficiaires de minima sociaux
<- BMS_s %>%
champ_bms select(id_midas,DTREFFRE,NUMCAF,NORDALLC,RSAVERS,MTRSAVER,PPAVERS,MTPPAVER,AAHVERS,MTAAHVER) %>%
filter(DTREFFRE == date_ms) %>%
distinct(id_midas,.keep_all = T)
<- pjc_clean %>%
champ_ac_ms full_join(champ_de_fm, by = "id_midas") %>% # Garde les non indemnisables
left_join(champ_bms, by = "id_midas") %>%
mutate(ins = if_else(!(is.na(DATINS)),1,0),
inda = if_else(!(is.na(KDDPJ)),1,0),
non_inda = if_else(inda == 0 & ins == 1,1,0),
inde = if_else(inda == 1 & KCPJC %in% c("1","4"),1,0),
RSA = if_else(RSAVERS %in% c("C","J","E","L") & MTRSAVER > 0,1,0),
PPA = if_else(!(PPAVERS == 0) & MTPPAVER > 0,1,0),
AAH = if_else(!(AAHVERS == 0) & MTAAHVER > 0,1,0))
<- champ_ac_ms %>%
tab_2 filter(non_inda == 1) %>% # à modifier
summarize(eff = n_distinct(id_midas),
eff_rsa = sum(RSA),
eff_ppa = sum(PPA),
eff_aah = sum(AAH)) %>%
mutate(part_rsa = round((eff_rsa/eff)*100),
part_ppa = round((eff_ppa/eff)*100),
part_aah = round((eff_aah/eff)*100)) %>%
collect()
Cumul allocation-chômage et minima sociaux
Cette fiche s’intéresse aux personnes inscrites à France Travail, qu’elles soient indemnisables, indemnisées ou non indemnisables, et qui perçoivent un mois donné un minima social (RSA, prime d’activité, AAH).
Le code ci-dessous permet de reconstituer le tableau précédent sur n’importe qu’elle période.