Correction requête exhaustivité

donnees.R

@@ -112,21 +112,23 @@ rum %<>%
 # Exhaustivité ----
 print("8/9 - Exhaustivité")
 exhau_pims <- read_csv("exhau_pims.csv")
-names(exhau_pims) <- c("Pole", "Service", "RUM", "DP", "Erreur", "Sortie", "Duree")
+names(exhau_pims) <- c("Pole", "Service", "RUM", "DP", "Erreur", "Sortie", "Duree", "RSS")
 
 exhau_pims %<>%
   mutate(Sortie = Sortie %>% as.Date) %>%
   filter(month(Sortie) <= mois)
 
 dbConnect(MySQL(), host = "localhost", dbname = "pmsi_dim", user = user, password = password) %>%
-  dbWriteTable("exhaustivite", data.frame(annee = annee, mois = mois, nb_rss_tot = exhau_pims %>% nrow, nb_rss_manq = exhau_pims %>% filter(is.na(DP)) %>% nrow), row.names = F, append = T)
+  dbWriteTable("exhaustivite", data.frame(annee = annee, mois = mois, nb_rss_tot = exhau_pims %>% distinct(RSS, .keep_all = T) %>% nrow, nb_rss_manq = exhau_pims %>% distinct(RSS, .keep_all = T) %>% filter(is.na(DP)) %>% nrow), row.names = F, append = T)
+
+an <- annee
 
 src_mysql("pmsi_dim", "localhost", user = user, password = password) %>%
   tbl("exhaustivite") %>%
-  filter(annee == annee) %>%
-  collect %>%
+  collect(n = Inf) %>%
+  filter(annee == an) %>%
   full_join(data.frame(mois = 1:12), by = "mois") %>%
-  select(mois, rss = nb_rss_tot, manq = nb_rss_manq) -> exhau
+  select(annee, mois, rss = nb_rss_tot, manq = nb_rss_manq) -> exhau
 
 # Écriture des données ----
 print("9/9 - Écriture des données")