From 51087e9a6a88f7bbc37d7f4c3dacdc4be1743cf3 Mon Sep 17 00:00:00 2001
From: Yannick Passarelli <yannick.passarelli@gmail.com>
Date: Wed, 8 Jan 2025 12:42:36 +0100
Subject: [PATCH] fix yearly hours etp

---
 dbt/models/marts/weekly/suivi_etp_realises_v2.sql | 8 +++++---
 dbt/models/staging/properties.yml                 | 8 ++++----
 dbt/models/staging/stg_ref_montant_heures_iae.sql | 6 ++++++
 3 files changed, 15 insertions(+), 7 deletions(-)
 create mode 100644 dbt/models/staging/stg_ref_montant_heures_iae.sql

diff --git a/dbt/models/marts/weekly/suivi_etp_realises_v2.sql b/dbt/models/marts/weekly/suivi_etp_realises_v2.sql
index 407c7a7e..6b9d3180 100644
--- a/dbt/models/marts/weekly/suivi_etp_realises_v2.sql
+++ b/dbt/models/marts/weekly/suivi_etp_realises_v2.sql
@@ -15,8 +15,10 @@ select distinct
     af.af_numero_convention,
     af.af_etat_annexe_financiere_code,
     af.af_montant_unitaire_annuel_valeur,
+    af.af_montant_unitaire_annuel_id,
     firmi.rmi_libelle,
     firmi.rmi_valeur,
+    firmi.rmi_id,
     af.af_mesure_dispositif_code,
     ref_asp.type_structure,
     ref_asp.type_structure_emplois,
@@ -49,9 +51,9 @@ left join {{ ref('fluxIAE_AnnexeFinanciere_v2') }} as af
     on
         emi.emi_afi_id = af.af_id_annexe_financiere
         and emi.emi_sme_annee >= constantes.annee_en_cours_2
-left join {{ source('fluxIAE', 'fluxIAE_RefMontantIae') }} as firmi
+left join {{ ref('stg_ref_montant_heures_iae') }} as firmi
     on
-        af.af_montant_unitaire_annuel_id = firmi.rmi_id
+        af.af_mesure_dispositif_id = firmi.rme_id
 left join {{ ref('fluxIAE_Structure_v2') }} as structure
     on
         af.af_id_structure = structure.structure_id_siae
@@ -67,6 +69,6 @@ left join {{ ref('stg_etat_mensuel_individuel_avec_brsa') }} as brsa
         and emi.emi_dsm_id = brsa.emi_dsm_id
 where
     emi.emi_sme_annee >= constantes.annee_en_cours_2
-    and firmi.rmi_libelle = 'Nombre d''heures annuelles théoriques pour un salarié à taux plein'
     and af.af_etat_annexe_financiere_code in ('VALIDE', 'PROVISOIRE', 'CLOTURE')
     and af.af_mesure_dispositif_code not like '%FDI%'
+
diff --git a/dbt/models/staging/properties.yml b/dbt/models/staging/properties.yml
index 2a1d767a..69e5b08c 100644
--- a/dbt/models/staging/properties.yml
+++ b/dbt/models/staging/properties.yml
@@ -164,10 +164,6 @@ models:
   - name: stg_nb_utilisateurs_revenus_semaine
     description: >
       Compte le nb d'utilisateurs qui se sont connectés plusieurs fois sur un tableau de bord sur une semaine donnée.
-  - name: stg_france_travail
-    description: >
-      Les données France travail étaient traitées via un notebook python développé par Jules.
-      Ce premier script sql permet de faire une partie du traitement effectué par le notebook.
   - name: stg_candidats_asp_derniere_sortie
     description: >
       Vue permettant d'isoler les motifs et causes de sortie ainsi que les dates de derniere sortie et candidature afin de permettre l'identification des id salarie asp en decrochage.
@@ -187,3 +183,7 @@ models:
     description: >
       vue permettant d'isoler les candidats + structures dont les candidatures ont pour origine "Employeur".
       Cette vue permet de créer la table (candidatures_inconnues_employeurs_orienteurs) suivant les employeurs orienteurs qui transfèrent les candidatures de candidats n'étant jamais passé chez eux.
+  - name: stg_ref_montant_heures_iae
+    description: >
+      vue permettant d'isoler le nombre d'heures à l'instant T heures nécessaires pour réaliser un ETP.
+
diff --git a/dbt/models/staging/stg_ref_montant_heures_iae.sql b/dbt/models/staging/stg_ref_montant_heures_iae.sql
new file mode 100644
index 00000000..b0af359f
--- /dev/null
+++ b/dbt/models/staging/stg_ref_montant_heures_iae.sql
@@ -0,0 +1,6 @@
+select
+    {{ pilo_star(source('fluxIAE', 'fluxIAE_RefMontantIae')) }}
+from {{ source('fluxIAE', 'fluxIAE_RefMontantIae') }}
+where
+    (rmi_date_fin_effet is null or (to_date(rmi_date_fin_effet, 'DD/MM/YYYY') >= current_date))
+    and rmi_libelle = 'Nombre d''heures annuelles théoriques pour un salarié à taux plein'