Correction rattachement RUM à RSS pour date de sortie

cloture.Rmd

@@ -83,9 +83,8 @@ data_frame(Dates = rep(date, 5),
 rum %>%
   filter(annee_sortie == annee) %>%
   tally %>%
-  bind_rows(rum %>%
+  bind_rows(rss %>%
               filter(annee_sortie == annee) %>%
-              distinct(idrss) %>%
               tally) %>%
 
   datatable(rownames = c("RUM", "RSS"),

donnees.R

@@ -55,10 +55,7 @@ src_mysql("pmsi_dim", "localhost", user = user, password = password) %>%
           SELECT idhosp, idrss, idrum, date_entree, date_sortie, cmd, um FROM fix117")) %>%
   collect %>%
   mutate(date_entree = date_entree %>% as.Date,
-         date_sortie = date_sortie %>% as.Date,
-         annee_sortie = year(date_sortie),
-         mois_sortie = month(date_sortie)) %>%
-  filter(annee_sortie > annee - 3) %>% # Données rum/rss depuis 3 ans
+         date_sortie = date_sortie %>% as.Date) %>%
   left_join(src_mysql("pmsi_dim_nom", "localhost", user = user, password = password) %>%
             tbl("structure") %>%
             filter(um != "") %>%
@@ -77,10 +74,18 @@ src_mysql("pmsi_dim", "localhost", user = user, password = password) %>%
   left_join(group_by(., idrss) %>%
             summarise(duree_rss = sum(duree_rum))) -> rum
 
+# RSS
+print("Création des RSS")
 rum %>%
   group_by(idrss) %>%
   filter(idrum == max(idrum)) %>%
-  ungroup -> rss
+  ungroup %>%
+  mutate(annee_sortie = year(date_sortie),
+         mois_sortie = month(date_sortie)) %>%
+  filter(annee_sortie > annee - 3) -> rss
+
+rum %<>%
+  right_join(rss %>% select(idrss, annee_sortie, mois_sortie))
 
 # GAM et structure --> hospit non codées
 print("LIVENNE : GAM")