Analyst/lounes tous polluants udi dernier

dbt_/models/intermediate/tous_polluants/_int__tous_polluants_models.yml

@@ -0,0 +1,34 @@
+version: 1
+
+models:
+  - name: int__resultats_tous_polluants_udi_dernier
+    description: "Résultats des derniers prélèvements pour tous les polluants par UDI. Ce modèle sélectionne le dernier prélèvement pour chaque paramètre et agrège les résultats pour identifier les dépassements des seuils sanitaires et/ou règlementaires."
+    columns:
+      - name: cdreseau
+        description: "Code de l'installation (UDI)."
+        tests:
+          - not_null
+          - unique
+
+      - name: dernier_prel_datetime
+        description: "Date et heure du dernier prélèvement pris en compte dans l'analyse."
+        type: TIMESTAMP
+        tests:
+          - not_null
+
+      - name: resultat_all
+        description: "Interprétation du résultat en fonction des seuils sanitaires et règlementaires."
+        type: VARCHAR
+        tests:
+          - accepted_values:
+              values:
+                - "inf_limites"
+                - "min_1_parametre_sup_limite_reg"
+                - "min_1_parametre_sup_limite_sanitaire"
+
+      - name: periode
+        description: "Période d'analyse des prélèvements (ici, toujours 'dernier_prel')."
+        type: VARCHAR
+        tests:
+          - accepted_values:
+              values: ["dernier_prel"]

dbt_/models/intermediate/tous_polluants/int__resultats_tous_polluants_udi_dernier.sql

@@ -0,0 +1,56 @@
+SELECT
+    cdreseau,
+    periode,
+    -- On garde la date du prélèvement la plus récente entre toutes les
+    -- substances
+    MAX(dernier_prel_datetime) AS dernier_prel_datetime,
+    CASE
+        WHEN
+            -- 1 : check si une des substances dépasse la limite sanitaire
+            MAX(CASE
+                WHEN categorie = 'cvm' AND resultat = 'sup_0_5' THEN 1
+                WHEN
+                    categorie = 'pfas'
+                    AND resultat = 'un_pfas_sup_valeur_sanitaire'
+                    THEN 1
+                ELSE 0
+            END) = 1
+            THEN 'min_1_parametre_sup_limite_sanitaire'
+
+        WHEN
+            -- 2 : check si une des substances dépasse la limite règlementaire
+            MAX(CASE
+                WHEN
+                    categorie = 'pfas'
+                    AND resultat IN (
+                        'somme_20pfas_sup_0_1',
+                        'somme_20pfas_inf_0_1_et_4pfas_sup_0_02'
+                    )
+                    THEN 1
+                ELSE 0
+            END) = 1
+            THEN 'min_1_parametre_sup_limite_reg'
+
+        WHEN
+            -- 3 : check si toutes les substances sont en dessous des limites
+            MAX(CASE
+                WHEN
+                    categorie = 'cvm'
+                    AND resultat IN ('non_quantifie', 'inf_0_5')
+                    THEN 0
+                WHEN
+                    categorie = 'pfas'
+                    AND resultat IN (
+                        'aucun_parametre_quantifie',
+                        'somme_20pfas_inf_0_1_et_4pfas_inf_0_02'
+                    )
+                    THEN 0
+                ELSE 1
+            END) = 0
+            THEN 'inf_limites'
+
+        ELSE 'erreur'
+    END AS resultat_all
+FROM {{ ref('int__union_resultats_udi') }}
+WHERE periode = 'dernier_prel'
+GROUP BY cdreseau, periode