Как отформатировать поток реактивности в надежный объект xlsx в блестящем с несколькими входами данных - PullRequest
Новая
       4

Как отформатировать поток реактивности в надежный объект xlsx в блестящем с несколькими входами данных

0 голосов
/ 18 января 2019

Я выполнил скрипт rmd, который автоматизирует периодический процесс на моей работе.Чтобы сделать его более удобным для пользователя, я пытаюсь преобразовать его в блестящее приложение (у меня очень мало опыта работы с блестящим).Конечным результатом является рабочая книга, которая содержит таблицы непредвиденных обстоятельств и необработанные данные.Требуются 3 пользовательских ввода: число, обозначающее месячный период, и 2 набора необработанных данных.Из-за необходимого анализа я должен создать несколько переменных (например, изменения месяца по месяцам для переменных в двух наборах данных).Я изо всех сил пытаюсь правильно отформатировать реактивный поток для этих переменных, чтобы они в конечном итоге были опубликованы в окончательной рабочей книге Excel, загруженной из приложения.Чтобы защитить данные компании, я публикую упрощенную версию скрипта, в которой в качестве входных данных используются фиктивные данные, приведенные ниже:

(не имеет значения, какой является ввод файла текущего и предыдущего месяца, а также текущий месяц).Индексное значение имеет значение для целей данного конкретного кода)

Файл1: СУММА ЕДИНИЦЫ SAT ABC 45 TYPE1 ABC 34 TYPE1 ABC 23 TYPE1 DEF 12 TYPE1 DEF 23 TYPE2 DEF 12 TYPE2 DEF 54 TYPE3 GHI 65 TYPE3 GHI 45 TYPE 3 * 5*

Файл2: СУММА ЕДИНИЦЫ SAT DEF 23 ТИП2 ABC 23 ТИП2 ABC 34 ТИП1 ABC 45 ТИП1 DEF 56 ТИП2 ABC 76 ТИП1 DEF 54 ТИП3 GHI 23 ТИП3 GHI 34 ТИП2 GHI 34 ТИП 2 ABC 76 * 100* В целом фактические данные, загружаемые из скрипта, даже не являются книгой Excel.Как именно отформатировать реактивный поток, чтобы конечный пользователь мог действительно загрузить правильный объект рабочей книги?

библиотека (tidyr) библиотека (plyr) библиотека (dplyr) библиотека (data.table) библиотека (openxlsx) библиотека(readxl) библиотека (блестящая) 

ui <- fluidPage(

   titlePanel("Title"),
   sidebarLayout(
      sidebarPanel(
         numericInput("Month",
                      "Current Month Index",
                      value = 1,
                      min = 1,
                      max = 12),
         fileInput(inputId = "CUR_MONTH_FILE",
                   label = "Current Month File"),
         fileInput(inputId = "PREV_MONTH_FILE",
                   label = "Previous Month File"),
         downloadButton("downloadData", "Download")),
      mainPanel(
         submitButton("Submit")
      )
    )
  )

server <- function(input, output) {
  observeEvent(input$Submit, {  
  DESIRED_MONTH_INDEX <- reactive({input$Month})
  CURR_DATA <- reactive({input$CUR_MONTH_FILE})
  PREV_DATA <- reactive({input$PREV_MONTH_FILE})

  COB <- Sys.Date()
  COB_DAY <- as.character(substr(COB, start = 9, stop =  10))
  COB_MONTH <- as.character(substr(COB, start = 6, stop = 7))
  COB_YEAR <- as.character(substr(COB, start = 1, stop = 4))
  PREV_COB_YEAR <- as.character(substr(COB, start = 1, stop = 4))
  if (COB_MONTH == "01") {
    COB_YEAR <- as.numeric(COB_YEAR) - 1
    COB_YEAR <- as.character(COB_YEAR)
    PREV_COB_YEAR <- as.numeric(PREV_COB_YEAR) - 1
    PREV_COB_YEAR <- as.character(PREV_COB_YEAR)
  }
  if (COB_MONTH == "02") {
    PREV_COB_YEAR <- as.numeric(PREV_COB_YEAR) - 1
    PREV_COB_YEAR <- as.character(PREV_COB_YEAR)
  }
  months <- c("January", "February", "March", "April", "May", "June", "July", "August", "September", "October", "November", "December")

PREV_MONTH_INDEX <- reactive({DESIRED_MONTH_INDEX - 1
if (DESIRED_MONTH_INDEX == 1) {
  PREV_MONTH_INDEX = 12
}})
########
CURR_DATA_ALL <- read_xlsx(path = CURR_DATA)
PREV_DATA_ALL <- read_xlsx(path = PREV_DATA)
########
CURR_DATA_SUB <- CURR_DATA_ALL %>%
  select(names((CURR_DATA_ALL[1])), names((CURR_DATA_ALL[2])), names((CURR_DATA_ALL[3])))
PREV_DATA_SUB <- PREV_DATA_ALL %>%
  select(names((PREV_DATA_ALL[1])), names((PREV_DATA_ALL[2])), names((PREV_DATA_ALL[3])))
########
CURR_UNITS <- as.vector(unique(as.character(CURR_DATA_SUB[[1]])))
PREV_UNITS <- as.vector(unique(as.character(PREV_DATA_SUB[[1]])))
a <- setdiff(CURR_UNITS, PREV_UNITS) 
CURR_UNITS_TEST <- identical(a, character(0))
b <- setdiff(PREV_UNITS, CURR_UNITS) 
PREV_UNITS_TEST <- identical(b, character(0))
entity_added <- setdiff(CURR_UNITS, PREV_UNITS)
entity_removed <- setdiff(PREV_UNITS, CURR_UNITS)
entity_check <- if(CURR_UNITS_TEST == TRUE & PREV_UNITS_TEST == TRUE) {
  print(paste("No entities were added or removed for the month of", months[DESIRED_MONTH_INDEX]))
} else if(CURR_UNITS_TEST == FALSE & PREV_UNITS_TEST == FALSE) {
  print(paste("The entity (or entities)", entity_added, "was added and", entity_removed, "was removed", "for the month of", months[DESIRED_MONTH_INDEX]))
} else if(length(CURR_UNITS) - length(PREV_UNITS) >= 1) {
  print(paste("The entity (or entities)", entity_added, "was added for the month of", months[DESIRED_MONTH_INDEX]))
} else if(length(CURR_UNITS) - length(PREV_UNITS) < 1) {
  print(paste("The entity (or entities)", entity_removed, "was removed for the month of", months[DESIRED_MONTH_INDEX]))
}
########
CURR_SAT <- as.vector(unique(as.character(CURR_DATA_SUB[[3]])))
PREV_SAT <- as.vector(unique(as.character(PREV_DATA_SUB[[3]])))
c <- setdiff(CURR_SAT, PREV_SAT) 
CURR_SAT_TEST <- identical(c, character(0))
d <- setdiff(PREV_SAT, CURR_SAT) 
PREV_SAT_TEST <- identical(d, character(0))
sat_added <- setdiff(CURR_SAT, PREV_SAT)
sat_removed <- setdiff(PREV_SAT, CURR_SAT)
SAT_Check <- if(CURR_SAT_TEST == TRUE & PREV_SAT_TEST == TRUE) {
  print(paste("No SAT accounts were added or removed for the month of", months[DESIRED_MONTH_INDEX]))
} else if(CURR_SAT_TEST == FALSE & PREV_SAT_TEST == FALSE) {
  print(paste("The SAT account (or accounts)", sat_added, "was added and", sat_removed, "was removed", "for the month of", months[DESIRED_MONTH_INDEX])) 
} else if(length(CURR_SAT) - length(PREV_SAT) >= 1) {
  print(paste("The SAT account (or accounts)", sat_added, "was added for the month of", months[DESIRED_MONTH_INDEX]))
}  else if(length(CURR_SAT) - length(PREV_SAT) < 1) {
  print(paste("The SAT account (or accounts)", sat_removed, "was removed for the month of", months[DESIRED_MONTH_INDEX]))
} 
########
CONTING_CURR <- table(CURR_DATA_SUB[,c(3, 1)])
CONTING_PREV <- table(PREV_DATA_SUB[,c(3, 1)])
CONTING_CURR_DF <- as.data.frame.matrix(CONTING_CURR)
CONTING_PREV_DF <- as.data.frame.matrix(CONTING_PREV)
COL_TOTALS_CURR <- CONTING_CURR_DF %>%
  summarise_each(funs(sum))
COL_TOTALS_PREV <- CONTING_PREV_DF %>%
  summarise_each(funs(sum))
CONTING_CURR_DF["COL GRAND TOTALs",] <- COL_TOTALS_CURR
CONTING_PREV_DF["COL GRAND TOTALs",] <- COL_TOTALS_PREV
CONTING_CURR_DF[,"ROW GRAND TOTALS"] <- rowSums(CONTING_CURR_DF)
CONTING_PREV_DF[,"ROW GRAND TOTALS"] <- rowSums(CONTING_PREV_DF)
########
CURR_DF_CALC <- CONTING_CURR_DF
PREV_DF_CALC <- CONTING_PREV_DF
if(CURR_SAT_TEST != TRUE) {
  PREV_DF_CALC[sat_added,] <- CURR_DF_CALC[sat_added,] * 0
}
if(PREV_SAT_TEST != TRUE) {
  CURR_DF_CALC[sat_removed,] <- PREV_DF_CALC[sat_removed,] * 0
}
if(CURR_UNITS_TEST != TRUE) {
  PREV_DF_CALC[,entity_added] <- CURR_DF_CALC[,entity_added] * 0
}
if(PREV_BUS_UNITS_TEST != TRUE) {
  CURR_DF_CALC[,entity_removed] <- PREV_DF_CALC[,entity_removed] * 0
}
MoM_CHANGE_DF <- CURR_DF_CALC[order(rownames(CURR_DF_CALC)),order(colnames(CURR_DF_CALC))] - PREV_DF_CALC[order(rownames(PREV_DF_CALC)),order(colnames(PREV_DF_CALC))]
MoM_COL_TOTALS <- MoM_CHANGE_DF %>%
  summarise_all(funs(sum))
MoM_CHANGE_DF["COL GRAND TOTALs",] <- MoM_COL_TOTALS
MoM_CHANGE_DF[,"ROW GRAND TOTALS"] <- rowSums(MoM_CHANGE_DF)
########
names(CURR_DATA_ALL[,2]) <- "AMOUNT"
bt <- CURR_DATA_ALL %>% 
  group_by(SAT) %>%
  summarise(BASE = sum(`AMOUNT`))
bt_amounts <- bt %>%
  select(BASE)
bt_sums <- colSums(bt_amounts)
bt[nrow(bt)+1,] <- c("Totals", bt_sums[[1]])
bt_final <- as.data.frame(bt)
bt_final$BASE <- as.numeric(bt_final$BASE)
})
########
  output$downloadData <- downloadHandler(
    filename = "pivot_file",
    content = function(file) {
      wkb <- openxlsx::createWorkbook()
      addWorksheet(wkb, "CURRENT")
      addWorksheet(wkb, "PREVIOUS")
      reactive({addWorksheet(wkb, months[DESIRED_MONTH_INDEX])})
      reactive({addWorksheet(wkb, months[PREV_MONTH_INDEX])})
      addWorksheet(wkb, "Summary")

      reactive({writeData(wkb, sheet = "Summary", SAT_Check, startCol = 1, startRow = 1, colNames = FALSE, rowNames = FALSE)})
      reactive({writeData(wkb, sheet = "Summary", entity_check, startCol = 1, startRow = 2, colNames = FALSE, rowNames = FALSE)})

      CD <- reactive({CURR_DATA_ALL})
      reactive({writeData(wkb, sheet = months[DESIRED_MONTH_INDEX], CD, startCol = 1, startRow = 1, colNames = TRUE, rowNames = FALSE)})
      PD <- reactive({PREV_DATA_ALL})
      reactive({writeData(wkb, sheet = months[PREV_MONTH_INDEX], PD, startCol = 1, startRow = 1, colNames = TRUE, rowNames = FALSE)})

      reactive({writeData(wkb, sheet = "CURRENT", CONTING_CURR, startCol = 1, startRow = 1)})
      reactive({writeData(wkb, sheet = "PREVIOUS", CONTING_PREV, startCol = 1, startRow = 1)})
      saveWorkbook(wkb, file)
    })
  }

shinyApp(ui = ui, server = server)
...