Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

Ajout des types de contrats sur les tables contrats et candidatures. #346

Merged
merged 1 commit into from
Aug 8, 2024
Merged

Ajout des types de contrats sur les tables contrats et candidatures. #346

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
3 changes: 3 additions & 0 deletions dbt/models/_sources.yml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -56,6 +56,9 @@ sources:
- name: demandes_de_prolongation
- name: prolongations
- name: structures_v0
- name: c1_ref_type_contrat
description: >
Table de correspondance entre le code d'un type de contrat et son label affiché sur les emplois.
- name: c1_ref_type_prescripteur
- name: c1_ref_motif_de_refus
description: >
Expand Down
31 changes: 17 additions & 14 deletions dbt/models/marts/weekly/contrats_aci.sql
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -2,32 +2,35 @@ select
ctr.contrat_id_structure,
ctr.contrat_id_pph,
salarie.hash_nir,
max(structs.code_dept_structure) as departement_structure,
max(structs.nom_departement_structure) as nom_departement_structure,
max(structs.nom_region_structure) as nom_region_structure,
max(motif_sortie) as motif_sortie,
count(distinct ctr.type_contrat) as types_contrats_distincts,
array_agg(ctr.type_contrat order by ctr.contrat_date_embauche) as types_contrats,
(array_agg(ctr.type_contrat order by ctr.contrat_date_embauche))[1] as type_contrat_embauche,
max(structs.code_dept_structure) as departement_structure,
max(structs.nom_departement_structure) as nom_departement_structure,
max(structs.nom_region_structure) as nom_region_structure,
max(motif_sortie) as motif_sortie,
case
when max(motif_sortie) is null then 'Non'
else 'Oui'
end as salarie_sorti,
array_agg(ctr.contrat_id_ctr) as id_contrats,
max(contrat_mesure_disp_code) as type_aci,
min(ctr.contrat_date_embauche) as date_embauche_premier_contrat,
max(ctr.contrat_date_fin_contrat) as date_fin_dernier_contrat,
max(ctr.contrat_date_sortie_definitive) as date_sortie_definitive_dernier_contrat,
end as salarie_sorti,
array_agg(ctr.contrat_id_ctr order by ctr.contrat_date_embauche) as id_contrats,
max(contrat_mesure_disp_code) as type_aci,
min(ctr.contrat_date_embauche) as date_embauche_premier_contrat,
max(ctr.contrat_date_fin_contrat) as date_fin_dernier_contrat,
max(ctr.contrat_date_sortie_definitive) as date_sortie_definitive_dernier_contrat,
case
when max(ctr.contrat_date_sortie_definitive) is not null then {{ duration_in_days('min(ctr.contrat_date_embauche)', 'max(ctr.contrat_date_sortie_definitive)') }}
else {{ duration_in_days('min(ctr.contrat_date_embauche)', 'max(ctr.contrat_date_fin_contrat)') }}
end as duree_contrat_jours,
end as duree_contrat_jours,
case
when max(ctr.contrat_date_sortie_definitive) is not null then {{ duration_in_months('min(ctr.contrat_date_embauche)', 'max(ctr.contrat_date_sortie_definitive)') }}
else {{ duration_in_months('min(ctr.contrat_date_embauche)', 'max(ctr.contrat_date_fin_contrat)') }}
end as duree_contrat_mois,
sum(ctr.contrat_duree_contrat) as duree_contrat_asp_mois,
end as duree_contrat_mois,
sum(ctr.contrat_duree_contrat) as duree_contrat_asp_mois,
case
when cgv_structs.siret is not null then 'Oui'
else 'Non'
end as structure_convergence
end as structure_convergence
from {{ ref('stg_contrats') }} as ctr
left join {{ ref("fluxIAE_Structure_v2") }} as structs
on ctr.contrat_id_structure = structs.structure_id_siae
Expand Down
5 changes: 4 additions & 1 deletion dbt/models/staging/stg_candidatures.sql
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,8 +1,9 @@
select
{{ pilo_star(source('emplois', 'candidatures'),
except=["date_mise_à_jour_metabase", "état", "motif_de_refus", "origine", "origine_détaillée", "candidature_archivee"], relation_alias='candidatures') }},
except=["date_mise_à_jour_metabase", "état", "motif_de_refus", "origine", "origine_détaillée", "candidature_archivee", "type_contrat"], relation_alias='candidatures') }},
{{ pilo_star(ref('stg_organisations'),
except=["id", "date_mise_à_jour_metabase", "ville", "code_commune", "type", "date_inscription", "total_candidatures", "total_membres", "total_embauches", "date_dernière_candidature"], relation_alias='org_prescripteur') }},
c_type.label as type_contrat_candidature,
struct.bassin_d_emploi as bassin_emploi_structure,
org_prescripteur.zone_emploi as bassin_emploi_prescripteur,
org_prescripteur.type as type_org_prescripteur,
Expand Down Expand Up @@ -40,6 +41,8 @@ select
extract(year from candidatures.date_candidature) as annee_candidature
from
{{ source('emplois', 'candidatures') }} as candidatures
left join {{ source('emplois', 'c1_ref_type_contrat') }} as c_type
on candidatures.type_contrat = c_type.code
left join {{ ref('stg_structures') }} as struct
on candidatures.id_structure = struct.id
left join {{ ref('stg_organisations') }} as org_prescripteur
Expand Down
6 changes: 5 additions & 1 deletion dbt/models/staging/stg_contrats.sql
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,8 @@ select distinct
ctr.contrat_duree_contrat,
ctr.contrat_date_embauche,
ctr.contrat_date_fin_contrat,
ctr.contrat_type_contrat,
ctr.contrat_type_contrat as num_reconduction,
rfc.rfc_lib_forme_contrat as type_contrat,
motif_sortie.rms_libelle as motif_sortie,
sum(emi.emi_nb_heures_travail) as contrat_nb_heures,
to_date(ctr.contrat_date_sortie_definitive, 'DD/MM/YYYY') as contrat_date_sortie_definitive,
Expand All @@ -17,6 +18,8 @@ select distinct
from {{ ref('fluxIAE_EtatMensuelIndiv_v2') }} as emi
left join {{ ref('fluxIAE_ContratMission_v2') }} as ctr
on ctr.contrat_id_ctr = emi.emi_ctr_id
left join {{ source("fluxIAE", "fluxIAE_RefFormeContrat") }} as rfc
on ctr."contrat_format_contrat_code" = rfc."rfc_code_forme_contrat"
left join {{ ref('fluxIAE_RefMotifSort_v2') }} as motif_sortie
on emi.emi_motif_sortie_id = motif_sortie.rms_id
group by
Expand All @@ -28,6 +31,7 @@ group by
ctr.contrat_date_embauche,
ctr.contrat_date_fin_contrat,
ctr.contrat_type_contrat,
rfc.rfc_lib_forme_contrat,
ctr.contrat_date_sortie_definitive,
motif_sortie.rms_libelle
-- because we consider only contracts starting in 2021
Expand Down
2 changes: 1 addition & 1 deletion dbt/models/staging/stg_recrutements.sql
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -5,7 +5,7 @@ select
min(contrat_date_embauche) as date_recrutement,
max(contrat_date_fin_contrat) as date_fin_recrutement,
max(contrat_date_sortie_definitive) as date_sortie_definitive,
max(contrat_type_contrat) as nb_reconductions
max(num_reconduction) as nb_reconductions
from {{ ref('stg_contrats') }}
group by
contrat_id_pph,
Expand Down