Ajout du champs nature_eau et consolidation des code_station avec les codes BSS

dev/flat_insert_ars_into_prelevement.Rmd

@@ -22,7 +22,7 @@ pkgload::load_all(export_all = FALSE)
 
 # Consolidation et insertion des données de l'ARS dans la table des prélèvements
 
-## Chargement des données ARS brutes
+## Chargement des données ARS brutes et des stations ESO
 
 La table des données brutes Nitrates de l'ARS est chargée :
 ```{r load-nitrate_data_analyse_ars, eval=FALSE}
@@ -34,6 +34,16 @@ nitrate_data_analyse_ars <- datalibaba::importer_data(
 )
 ```
 
+La table des stations ESO est chargée :
+```{r load-nitrate_data_analyse_ars, eval=FALSE}
+station_eso <- datalibaba::importer_data(
+  table = "station_eso",
+  schema = "stations",
+  db = "si_eau",
+  user = "admin"
+)
+```
+
 ## Consolidation des données ARS
 
 On ajoute les variables `source` et `code_support` :
@@ -63,6 +73,7 @@ nitrate_data_analyse_ars <- nitrate_data_analyse_ars |>
                 date_prelevement = plv_date,
                 heure_prelevement = plv_heure,
                 code_support,
+                nature_eau,
                 id_usage = usage,
                 id_prelevement_motif = plv_motif)
 
@@ -76,6 +87,18 @@ nitrate_data_analyse_ars <- nitrate_data_analyse_ars |>
   dplyr::distinct(code_station, date_prelevement, .keep_all = TRUE)
 ```
 
+On met à jour le champs code_station avec le code BSS :
+```{r}
+# Jointure entre nitrate_data_analyse_ars et station_eso
+nitrate_data_analyse_ars_updated <- nitrate_data_analyse_ars |>
+  dplyr::left_join(station_eso, by = c("code_station" = "code_sise_eaux")) |>
+  dplyr::mutate(code_station = ifelse(!is.na(code_station.y), code_station.y, code_station.x)) |>
+  dplyr::select(-code_station.y, -code_station.x)
+
+# Visualiser le résultat
+head(nitrate_data_analyse_ars_updated)
+```
+
 ```{r function-add_code_prelevement, eval=FALSE} 
 #' Ajouter une variable code_prelevement au dataframe
 #'
@@ -129,7 +152,7 @@ On ajoute un identifiant unique s'appuyant sur une séquence stockée en base :
 ```{r add_code_prelevement_ars, eval=FALSE}
 # Utiliser la fonction add_code_prelevement_ars avec la version souhaitée
 nitrate_data_analyse_ars <- add_code_prelevement(
-  nitrate_data_analyse_ars, "v0_15")
+  nitrate_data_analyse_ars, "v0_16")
 
 # Afficher le dataframe pour vérifier les modifications
 print(nitrate_data_analyse_ars)
@@ -137,10 +160,10 @@ print(nitrate_data_analyse_ars)
 ```
 
 On charge les données consolidées dans un table dédiée :
-```{r insert-into_nitrate_prelevement_v0_15, eval=FALSE}
+```{r insert-into_nitrate_prelevement_v0_16, eval=FALSE}
 # Charger les données dans une nouvelle table en base
 datalibaba::poster_data(data = nitrate_data_analyse_ars, 
-                        table = "nitrate_prelevement_ars_v0_15", 
+                        table = "nitrate_prelevement_ars_v0_16", 
                         schema = "nitrates", 
                         db = "si_eau",
                         overwrite = TRUE,
@@ -154,9 +177,9 @@ On insère enfin les enregistrements de cette table dans la table globale :
 ```{r import_and_merge_tables_ars, eval=FALSE}
 # Insérer les données de la table du dernier millésime vers la table complète
 collectr::import_and_merge_tables(database = "si_eau",
-                                  source_table = "nitrate_prelevement_ars_v0_15", 
+                                  source_table = "nitrate_prelevement_ars_v0_16", 
                                   source_schema = "nitrates", 
-                                  target_table = "nitrate_prelevement_v0_15", 
+                                  target_table = "nitrate_prelevement_v0_16", 
                                   target_schema = "nitrates",
                                   role = "admin")