Añadir la sincronización de tablas para CC.

BDAccess/app.R

@@ -24,13 +24,13 @@ ui <- fluidPage(
     navbarPage("BDAccess",
         tabPanel("Update",
             sidebarPanel(
-                selectInput("dbtype", "", selected="UM", choices=c("UM", "OV")),
+                selectInput("dbtype", "", selected="UM", choices=c("UM", "OV","CC")),
                 checkboxInput(inputId = "backup", label="Backup", value=F),
                 actionButton("butdbtype", "Carrega BD"),
                 hr(),
                 fileInput(inputId = "file_query", label = "Plantilla", multiple = F),
                 actionButton("impNHC", "Importa NHC"),
-                actionButton("goButton", "Genera CodiID"),
+                actionButton("goButton", "Genera PATID"),
                 hr(),
                 actionButton("filltemplate", "Plantilla"),
                 hr(),
@@ -79,6 +79,7 @@ server <- function(input, output) {
     observeEvent(input$butdbtype, {
         print(UMfile)
         print(OVfile)
+        print(CCfile)
         if (input$dbtype == "UM"){
             dta<<-odbcConnectAccess2007(access.file = UMfile, 
                                         pwd = .rs.askForPassword("Enter password:"))
@@ -87,10 +88,18 @@ server <- function(input, output) {
             dta<<-odbcConnectAccess2007(access.file = OVfile, 
                                         pwd = .rs.askForPassword("Enter password:"))
         }
-        
+        if (input$dbtype == "CC"){
+            dta<<-odbcConnectAccess2007(access.file = CCfile, 
+                                        pwd = .rs.askForPassword("Enter password:"))
+        }
         print(dta)
         if (input$backup == T){
-            sqlBackUp()   
+            if (! input$dbtype %in% c("UM","OV")){
+                sqlBackUp(bu.dir="CC_BU")
+            }else{
+                sqlBackUp()   
+            }
+                
         }
     })
     
@@ -218,14 +227,22 @@ server <- function(input, output) {
     
     observeEvent(input$goButton, {
 
-        sqlGenOVID(dta, nhcs = values[["DF"]]$NHC, sinc=T)
+        if (input$dbtype %in% c("UM","OV")){
-
+            sqlGenOVID(dta, nhcs = values[["DF"]]$NHC, sinc=T)
+        }
+        if (input$dbtype %in% c("CC")){
+            sqlGenOVID(dta, nhcs = values[["DF"]]$NHC, sinc=T, dbtype = input$dbtype)
+        }
+            
         if (input$dbtype == "UM"){
             values[["DF"]]<-merge(values[["DF"]], sqlFetch(dta, "UMID"))
         }
         if (input$dbtype == "OV"){
             values[["DF"]]<-merge(values[["DF"]], sqlFetch(dta, "OVID"))
         }
+        if (input$dbtype == "CC"){
+            values[["DF"]]<-merge(values[["DF"]], sqlFetch(dta, "PATID"))
+        }
         print(values[["DF"]])
     })
 
@@ -315,6 +332,61 @@ server <- function(input, output) {
             values[["CLINICS"]]<-upd.clinics %>% mutate(across(lubridate::is.POSIXct, as.character))
         }
         
+        if (input$dbtype %in% c("CC")){
+            upd.umid<-sqlFetch(dta, "PATID") %>% filter(NHC %in% values[["DF"]]$NHC)
+            ## Generar código para las nuevas muestras
+            samples<-sqlFetch(dta, "MUESTRAS")
+            if(sum(grepl(paste0(input$dbtype,Sys.time() %>% format("%y")), samples$CODIGO)) > 0){
+                next.samp<-gsub(paste0(input$dbtype,Sys.time() %>% format("%y")),"", samples$CODIGO) %>% as.numeric %>% max(na.rm=T)+1  
+            }else{
+                next.samp<-1
+            }
+            last.samp<-next.samp+(length(values[["DF"]]$NHC)-1)
+            new.samp<-sprintf("%s%s%02d",input$dbtype,Sys.time() %>% format("%y"),next.samp:last.samp)
+            new.samp.df<-data.frame("NHC"=values[["DF"]]$NHC, "CODIGO"=new.samp) %>% merge(sqlFetch(dta,"PATID"), all.x=T) %>% arrange(CODIGO)
+            samples.exp<-merge(samples %>% slice(0), new.samp.df %>% select(-NHC), all=T) %>% select(colnames(samples)) %>% arrange(CODIGO)
+            if (today==TRUE){
+                samples.exp$FECHA_RECEPCION<-format(Sys.Date(), "%d/%m/%y")
+            }
+            
+            nhc.table<-values[["DF"]]
+            
+            if (any(sapply(nhc.table$Samples, function(x) "cnag" %in% strsplit(x,",")[[1]]) == T)){
+                nhcs.cnag<-nhc.table[sapply(nhc.table$Samples, function(x) "cnag" %in% strsplit(x,",")[[1]]),"NHC"]
+                umid.cnag<-sqlFetch(dta, "PATID") %>% filter(NHC %in% nhcs.cnag) %>% pull(PATID)
+                sample.cnag<-samples.exp %>% filter(PATID %in% umid.cnag) %>% pull(CODIGO)
+                cnag.exp<-merge(data.frame("PATID"=umid.cnag, "CODIGO"=sample.cnag), sqlFetch(dta, "CNAG") %>% slice(0), all=T)
+                if (today==TRUE){
+                    cnag.exp$FECHA_ENVIO<-format(Sys.Date(), "%d/%m/%y")
+                }
+            }else{
+                cnag.exp<-sqlFetch(dta, "CNAG") %>% slice(0) %>% 
+                    mutate(across(lubridate::is.POSIXct, as.character))
+            }
+            if (any(sapply(nhc.table$Samples, function(x) "rna" %in% strsplit(x,",")[[1]]) == T)){
+                nhcs.rna<-nhc.table[sapply(nhc.table$Samples, function(x) "rna" %in% strsplit(x,",")[[1]]),"NHC"]
+                umid.rna<-sqlFetch(dta, "PATID") %>% filter(NHC %in% nhcs.rna) %>% pull(PATID)
+                sample.rna<-samples.exp %>% filter(PATID %in% umid.rna) %>% pull(CODIGO)
+                rna.exp<-merge(data.frame("PATID"=umid.rna, "CODIGO"=sample.rna), sqlFetch(dta, "RNADNA") %>% slice(0)%>% 
+                                   mutate(across(lubridate::is.POSIXct, as.character)), all=T)
+            }else{
+                rna.exp<-sqlFetch(dta, "RNADNA") %>% slice(0) %>% 
+                    mutate(across(lubridate::is.POSIXct, as.character))
+            }
+            
+            ## Importar los datos clínicos de pacientes existentes y generar nueva entrada par los nuevos
+            upd.clinics<-sqlFetch(dta, "CLINICOS")
+            umid.new<-sqlFetch(dta, "PATID") %>% filter(NHC %in% values[["DF"]]$NHC)
+            upd.clinics<-merge(umid.new,upd.clinics, all.x=T, by="PATID")
+            upd.clinics$NHC<-as.character(upd.clinics$NHC)
+            for (i in colnames(upd.clinics)[sapply(upd.clinics, lubridate::is.POSIXct)]){upd.clinics[,i]<-as.Date(upd.clinics[,i])}
+            
+            values[["samples"]]<-samples.exp
+            values[["CLINICS"]]<-upd.clinics
+            values[["cnag"]]<-cnag.exp
+            values[["rna"]]<-rna.exp
+        }
+        
     })
     
     observeEvent(input$synctemplate,{
@@ -448,6 +520,77 @@ server <- function(input, output) {
             sqlSave(dta, clinics.new, tablename="CLINICS", append = T, varTypes = varTypes, rownames = F)
             print("Tabla CLINICS sincronizada.")
         }
+        if (input$dbtype %in% c("CC")){
+            ## Nuevas entradas en MUESTRAS
+            nsamples<-values[["samples"]] %>% nrow
+            upd.samples<-values[["samples"]]
+            if (nrow(upd.samples) > 0){rownames(upd.samples)<-(nsamples+1):(nsamples+nrow(upd.samples)) %>% as.character}
+            
+            if (nrow(upd.samples) > 0){
+                upd.samples$FECHA_RECEPCION<-lubridate::parse_date_time(upd.samples$FECHA_RECEPCION, c("d/m/Y","d/m/y")) %>% as.Date()
+                upd.samples$TIPO<-as.character(upd.samples$TIPO)
+                upd.samples$OBS<-as.character(upd.samples$OBS)
+                ### !! Atención, esto cambia la base de datos:
+                sqlSave(dta, upd.samples, tablename="MUESTRAS", append = T, varTypes = c("FECHA_RECEPCION"="Date"), rownames = F)
+                print("Tabla MUESTRAS sincronizada.")
+            }
+            
+            ## Entradas modificadas en CLINICOS
+            upd.clinics<-values[["CLINICS"]]
+            PATID.mod<-upd.clinics$PATID[upd.clinics$PATID %in% (sqlFetch(dta, "CLINICOS") %>% pull(PATID))]
+            rnames<-sqlFetch(dta, "CLINICOS") %>% filter(PATID %in% PATID.mod) %>% rownames
+            clinics.mod<-upd.clinics %>% filter(PATID %in% PATID.mod) %>% select(-NHC)
+            rownames(clinics.mod)<-rnames
+            
+            ### !! Atención, esto cambia la base de datos:
+            fechas<-colnames(clinics.mod)[grepl("date|MET_DX|DoB", colnames(clinics.mod), ignore.case = T)]
+            for (i in fechas){
+                clinics.mod[,i]<-lubridate::parse_date_time(clinics.mod[,i], c("d/m/Y","d/m/y")) %>% as.Date()
+            }
+            sqlUpdate(dta, clinics.mod,"CLINICOS", index="PATID")
+            print("Tabla CLINICOS modificada.")
+            
+            ## Nuevas entradas en CLINICOS
+            nsamples.clin<-sqlFetch(dta, "CLINICOS") %>% nrow
+            PATID.new<-upd.clinics$PATID[!upd.clinics$PATID %in% (sqlFetch(dta, "CLINICOS") %>% pull(PATID))]
+            clinics.new<-upd.clinics %>% filter(PATID %in% PATID.new) %>% select(-NHC)
+            if (length(PATID.new) > 0){rownames(clinics.new)<-(nsamples.clin+1):(nsamples.clin+nrow(clinics.new)) %>% as.character}
+            
+            ### !! Atención, esto cambia la base de datos:
+            fechas<-colnames(clinics.new)[grepl("date|MET_DX|DoB", colnames(clinics.new), ignore.case = T)]
+            varTypes<-rep("Date",length(fechas))
+            names(varTypes)<-fechas
+            for (i in fechas){
+                clinics.new[,i]<-lubridate::parse_date_time(clinics.new[,i], c("d/m/Y","d/m/y","Y-m-d")) %>% as.Date()
+            }
+            sqlSave(dta, clinics.new, tablename="CLINICOS", append = T, varTypes = varTypes, rownames = F)
+            print("Tabla CLINICOS sincronizada.")
+            
+            ## Nuevas entradas en CNAG
+            if (nrow(values[["cnag"]]) > 0){
+                cnag.sync<-values[["cnag"]]
+                fechas<-colnames(cnag.sync)[sqlFetch(dta, "CNAG") %>% sapply(lubridate::is.POSIXct)]
+                varTypes<-rep("Date",length(fechas))
+                names(varTypes)<-fechas
+                print(fechas)
+                for (i in fechas){
+                    cnag.sync[,i]<-lubridate::parse_date_time(cnag.sync[,i], c("d/m/Y","d/m/y","Y-m-d")) %>% as.Date()
+                }
+                sqlSave(dta, cnag.sync, tablename="CNAG", append = T, varTypes = varTypes, rownames = F)
+            }
+            
+            ## Nuevas entradas en RNADNA
+            if (nrow(values[["rna"]]) > 0){
+                rna.sync<-values[["rna"]]
+                fechas<-colnames(rna.sync)[sqlFetch(dta, "RNADNA") %>% sapply(lubridate::is.POSIXct)]
+                varTypes<-rep("Date",length(fechas))
+                names(varTypes)<-fechas
+                for (i in fechas){
+                    rna.sync[,i]<-lubridate::parse_date_time(rna.sync[,i], c("d/m/Y","d/m/y","Y-m-d")) %>% as.Date()
+                }
+                sqlSave(dta, rna.sync, tablename="RNADNA", append = T, varTypes = varTypes, rownames = F)
+            }
+        }
     })
     
     ## Visor

sqlFunctions.R

@@ -66,19 +66,25 @@ sqlGenOVID<-function(conn=dta, nhcs=nhc.test, verb=T, sinc=F, dbtype=NULL){
   if(sqlTables(conn) %>% filter(TABLE_NAME == "OVID") %>% nrow > 0){dbtype<-"OV"}
   
   if (dbtype == "OV"){
-    db<-c("dbcode"="OVID")
+    db<-c("dbcode"="OVID", "dbpref"="OVID")
   }
   if (dbtype == "UM"){
-    db<-c("dbcode"="UMID")
+    db<-c("dbcode"="UMID","dbpref"="UMID")
+  }
+  if (dbtype == "CC"){
+    db<-c("dbcode"="PATID", "dbpref"="CCID")
   }
   
   dbid<-sqlFetch(conn,db["dbcode"])
-  
   new.nhc<-nhcs[!nhcs %in% dbid$NHC] %>% unique()
+
   if(length(new.nhc) > 0){
+    if (nrow(dbid) == 0){next.num<-1}else{
     next.num<-gsub(db["dbcode"],"",dbid[,db["dbcode"]]) %>% as.numeric %>% max(na.rm=T)+1
+    }
+    print(next.num)
     last.num<-next.num+(length(new.nhc)-1)
-    newtab<-data.frame("NHC"=new.nhc, "ID"=sprintf("%s%04d",db["dbcode"],next.num:last.num)) %>% rename(!!db["dbcode"]:="ID")
+    newtab<-data.frame("NHC"=new.nhc, "ID"=sprintf("%s%04d",db["dbpref"],next.num:last.num)) %>% rename(!!db["dbcode"]:="ID")
     if(dbtype=="OV"){
       dbid<-rbind(dbid,newtab)
     }
@@ -87,6 +93,10 @@ sqlGenOVID<-function(conn=dta, nhcs=nhc.test, verb=T, sinc=F, dbtype=NULL){
       # dbid$Id<-as.numeric(rownames(dbid))
       dbid$NHC<-as.numeric(dbid$NHC)
     }
+    if (dbtype=="CC"){
+      dbid<-merge(dbid, newtab, all=T) %>% select(NHC,PATID) %>% arrange(PATID)
+      dbid$NHC<-as.numeric(dbid$NHC)
+    }
     rownames(dbid)<-as.character(1:nrow(dbid))
     dbid<-filter(dbid, NHC %in% new.nhc) %>% mutate(NHC=as.character(NHC))