feat: работа с орфанными записями

app.R

@@ -16,40 +16,35 @@ box::use(
   modules/global_options,
   modules/db,
   modules/data_validation,
-  modules/scheme_generator[scheme_R6]
+  app/forms,
+  app/tasks
 )
 
+# global settings:
 global_options$set_global_options(
-  shiny.host = "0.0.0.0"
+  shiny.host = "0.0.0.0",
-  # APP.DEBUG = TRUE
+  APP.DEBUG = FALSE
 )
+
+# init:
 global_options$check_and_init_scheme()
 
-# global vars
+# global vars:
 box::use(
   modules/global_options[AUTH_ENABLED]
 )
+enabled_schemes <- unlist(config::get()$form_schemes)
+enabled_schemes <- setNames(names(enabled_schemes), enabled_schemes)
 
-# MODULES
+# load schemes object:
-box::use(app/forms)
+schms <- readRDS("scheme.rds")
-box::use(app/tasks)
 
-# refactor LATER ---------
+# CHECK FOR PANDOC ----------
-vv <- unlist(config::get()$form_schemes)
-enabled_schemes <- names(vv)
-vvvv            <- unname(vv)
-names(enabled_schemes) <- vvvv
-# ------------------------
-
-# CHECK FOR PANDOC
-# TEMP ! NEED TO HANDLE
 rmarkdown::find_pandoc(dir = "/opt/homebrew/bin/")
 
 # TODO: dynamic button render depend on pandoc installation
 if (!rmarkdown::pandoc_available()) warning("Can't find pandoc!")
 
-# SCHEME_MAIN UNPACK ==========================
-schms <- readRDS("scheme.rds")
 
 # UI =======================
 ui <- page_sidebar(
@@ -76,7 +71,7 @@ ui <- page_sidebar(
     uiOutput("status_message"),
     textOutput("status_message2"),
     uiOutput("display_log"),
-    actionButton("tasks-display_task_modal", "Задачи: нет активных"),
+    actionButton("tasks-display_task_modal", "Задачи: нет активных", icon("list-check")),
     position = "left",
     open = list(mobile = "always")
   ),
@@ -137,9 +132,7 @@ server <- function(input, output, session) {
     if (AUTH_ENABLED) {
       reactiveValuesToList(res_auth)
       if (res_auth$admin) {
-        # print("admin")
       } else {
-        # print("not_admin")
         showing_buttons <- FALSE
       }
     }
@@ -160,32 +153,10 @@ server <- function(input, output, session) {
     }
   })
 
-  output$base_data <- renderUI({
+  # ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
-
-    con <- db$make_db_connection(scheme(),"base_data")
-    on.exit(db$close_db_connection(con, "base_data"), add = TRUE)
-
-    # записей в базе всего
-    query <- glue::glue("SELECT COUNT ({mhcs()$get_main_key_id}) FROM main")
-    records_count <- DBI::dbGetQuery(con, query) |>
-      dplyr::pull()
-
-    # задачи на сегодня
-    if ("tasks" %in% DBI::dbListTables(con)) {
-      query <- glue::glue("SELECT COUNT (task_id) FROM tasks WHERE task_status = 'active'")
-      tasks_count <- DBI::dbGetQuery(con, query) |>
-        dplyr::pull()
-    } else {
-      tasks_count <- 0
-    }
-
-    div(
-      strong("Записей всего:"), records_count, br(),
-      if (tasks_count > 0) p(strong("Задач на сегодня:"), actionLink("tasks-show_dt_today", tasks_count)) else "Задач нет"
-    )
-  })
-
   # REACTIVE VALUES =================================
+  # ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
+
   # Create a reactive values object to store the input data
   values <- reactiveValues(
     data     = NULL,
@@ -206,21 +177,28 @@ server <- function(input, output, session) {
   validator_nested <- reactiveVal(NULL)
 
   # ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
-  # ГЛАВНАЯ СТРАНИЦА ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
+  # reactive ui       -------------------------------
   # ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
+
+  ## reactive ui -----------------------------------
+  ### main screen ------
   output$main_ui_navset <- renderUI({
 
     if (main_form_is_empty()) {
       validator_main(NULL)
       div(
+        h5("Выбрать базу данных для работы:"),
         shiny::radioButtons(
           "schmes_selector",
-          label = strong("Выбрать базу данных для работы:"),
+          label = NULL,
           choices = enabled_schemes,
           selected = scheme()
         ),
+        hr(),
         uiOutput("base_data"),
+        hr(),
         "Для начала работы нужно создать новую запись или загрузить существующую!",
+        hr(),
         # сво
         # загрузка панели для работы с базой данных
         uiOutput("admin_buttons_panel")
@@ -235,9 +213,60 @@ server <- function(input, output, session) {
     }
   })
 
+  ### bases info ----------------
+  observeEvent(main_form_is_empty(), {
+
+    output$base_data <- renderUI({
+
+      if (main_form_is_empty() == TRUE) {
+        con <- db$make_db_connection(scheme(),"base_data")
+        on.exit(db$close_db_connection(con, "base_data"), add = TRUE)
+
+        tasks$update_task_button_count(con, values, NS("tasks"))
+
+        # записей в базе всего
+        records_count <- DBI::dbGetQuery(con, glue::glue("SELECT COUNT ({mhcs()$get_main_key_id}) FROM main")) |>
+          dplyr::pull()
+
+        # задачи на сегодня
+        if ("tasks" %in% DBI::dbListTables(con)) {
+
+          tasks_count <- DBI::dbGetQuery(con, glue::glue("SELECT COUNT (task_id) FROM tasks WHERE task_status = 'active'")) |>
+            dplyr::pull()
+
+          tasks_today_count <- DBI::dbGetQuery(con, glue::glue("SELECT COUNT (task_id) FROM tasks WHERE task_status = 'active' AND task_due_date = {as.integer(Sys.Date())}")) |>
+            dplyr::pull()
+
+          tasks_overdue_count <- DBI::dbGetQuery(con, glue::glue("SELECT COUNT (task_id) FROM tasks WHERE task_status = 'active' AND task_due_date < {as.integer(Sys.Date())}")) |>
+            dplyr::pull()
+
+        } else {
+
+          tasks_count <- 0
+          tasks_today_count <- 0
+          tasks_overdue_count <- 0
+
+        }
+
+        div(
+          h5("Общая информация о базе данных:"),
+          strong("Записей всего:"), records_count, 
+          hr(),
+          h5("Задачи:"),
+          span(strong("Активных всего:"),      if (tasks_count > 0)       actionLink("tasks-show_dt_all", tasks_count) else "0", br()),
+          span(strong("Активных на сегодня:"), if (tasks_today_count > 0) actionLink("tasks-show_dt_today", tasks_today_count) else "0", br()),
+          span(strong("Просроченных:"),        if (tasks_overdue_count > 0) actionLink("tasks-show_dt_overdue", tasks_overdue_count) else "0", br())
+        )
+      }
+    })
+  })
+
+  # обновление данных схем ------
   observeEvent(input$schmes_selector, {
+
     scheme(input$schmes_selector)
     mhcs(schms[[input$schmes_selector]])
+
   })
 
   # ==========================================
@@ -320,6 +349,7 @@ server <- function(input, output, session) {
   # ====================================
   # NESTED FORMS =======================
   # ====================================
+
   ## кнопки для каждой вложенной таблицы -------------------------------
   observe({
 
@@ -349,6 +379,7 @@ server <- function(input, output, session) {
     observers_started(c(
       isolate(observers_started()), isolate(scheme())
     ))
+
   })
 
   ## функция отображения вложенной формы для выбранной таблицы --------
@@ -388,6 +419,7 @@ server <- function(input, output, session) {
 
     # nested ui
     nested_form_panels <- if (!is.null(values$nested_key)) {
+
       purrr::map(
         .x = unique(this_nested_form_scheme$subgroup),
         .f = \(subgroup) {
@@ -408,7 +440,9 @@ server <- function(input, output, session) {
         }
       )
     } else {
+
       list(bslib::nav_panel("", div("Нет доступных записей.", br(), "Необходимо создать новую запись.")))
+
     }
 
     # ui для всплывающего окна 
@@ -473,7 +507,7 @@ server <- function(input, output, session) {
     output$dt_nested <- DT::renderDataTable(
       DT::datatable(
         values$data,
-        caption = 'Table 1: This is a simple caption for the table.',
+        caption = 'В данной таблице можно изменять данные',
         rownames = FALSE,
         colnames = col_types |> dplyr::pull(form_id, form_label),
         extensions = c('KeyTable', "FixedColumns"),
@@ -494,7 +528,7 @@ server <- function(input, output, session) {
       DT::dataTableOutput("dt_nested"),
       size = "xl",
       footer = tagList(
-        actionButton("nested_form_dt_save", "сохранить изменения")
+        actionButton("nested_form_dt_save", "Сохранить изменения", icon("floppy-disk"))
       ),
       easyClose = TRUE
     ))
@@ -508,8 +542,9 @@ server <- function(input, output, session) {
 
   ### кнопка: отображение DT -----------------------------
   observeEvent(input$nested_form_dt_button, {
-    con <- db$make_db_connection(scheme(),"nested_form_save_button")
+
-    on.exit(db$close_db_connection(con, "nested_form_save_button"), add = TRUE)
+    con <- db$make_db_connection(scheme(),"nested_form_dt_button")
+    on.exit(db$close_db_connection(con, "nested_form_dt_button"), add = TRUE)
 
     removeModal()
     show_modal_for_nested_form_dt(con)
@@ -593,8 +628,8 @@ server <- function(input, output, session) {
 
   observeEvent(values$nested_key, {
 
-    con <- db$make_db_connection(scheme(),"nested_tables")
+    con <- db$make_db_connection(scheme(),"nested_key")
-    on.exit(db$close_db_connection(con, "nested_tables"), add = TRUE)
+    on.exit(db$close_db_connection(con, "nested_key"), add = TRUE)
 
     kyes_for_this_table <- db$get_nested_keys_from_table(values$nested_form_id, mhcs(), values$main_key, con)
 
@@ -651,8 +686,8 @@ server <- function(input, output, session) {
   observeEvent(input$confirm_create_new_nested_key, {
     req(input[[mhcs()$get_key_id(values$nested_form_id)]])
 
-    con <- db$make_db_connection(scheme(),"confirm_create_new_key")
+    con <- db$make_db_connection(scheme(),"confirm_create_new_nested_key")
-    on.exit(db$close_db_connection(con, "confirm_create_new_key"), add = TRUE)
+    on.exit(db$close_db_connection(con, "confirm_create_new_nested_key"), add = TRUE)
 
     existed_key <- db$get_nested_keys_from_table(
       table_name = values$nested_form_id,
@@ -856,11 +891,11 @@ server <- function(input, output, session) {
 
   ## логика: смена ключа -------
   observeEvent(values$main_key, {
-    req(values$main_key)
 
     con <- db$make_db_connection(scheme(),"load_data")
     on.exit(db$close_db_connection(con, "load_data"), add = TRUE)
 
+    if (!is.null(values$main_key)) {
       existed_main_keys <- db$get_keys_from_table("main", mhcs(), con)
 
       if (values$main_key %in% existed_main_keys) {
@@ -886,10 +921,11 @@ server <- function(input, output, session) {
 
       }
 
-    # обновление счетичка задач
-    tasks$update_task_button_count(con, values, NS("tasks"))
-
       main_form_is_empty(FALSE)
+
+    }
+
+    tasks$update_task_button_count(con, values, NS("tasks"))
     removeModal()
 
   })
@@ -1191,13 +1227,15 @@ server <- function(input, output, session) {
         append = TRUE
       )
 
-      message <- glue::glue("Данные таблицы '{table_name}' успешно обновлены (добавлено {nrow(df)} записей)")
+      message <- glue::glue("Данные таблицы '{table_name}' успешно загружены (добавлено {nrow(df)} записей)")
       showNotification(
         message,
         type = "message"
       )
       cli::cli_alert_success(message)
     }
+
+    db$db_clean_orphans(mhcs(), con)
     log_action_to_db("importing data from xlsx", con = con)
     removeModal()
   })

app/forms.R

@@ -3,7 +3,6 @@ box::use(
   modules/utils,
 )
 
-
 #' @export
 load_data_to_form <- function(
   df,
@@ -16,10 +15,6 @@ load_data_to_form <- function(
   input_ids   <- names(mhcs()$get_id_type_list(table_name))
   if (missing(ns)) ns <- NULL
 
-  # transform df to list
-  # loaded_df_for_id <- as.list(df)
-  # loaded_df_for_id <- df[input_ids]
-
   # rewrite input forms
   purrr::walk2(
     .x = input_types,

app/tasks.R

@@ -24,6 +24,27 @@ server <- function(id, values, scheme, mhcs) {
     # })
 
     # functions -------------------
+    ## new tasks ----------------
+    get_default_task <- function() {
+
+      tibble::tibble(
+        task_id = paste0(format(Sys.time(), "%Y%m%d%H%M%S"), "_", values$main_key),
+        task_main_key = values$main_key,
+        task_status = "active",
+        task_title = "НОВАЯ ЗАДАЧА",
+        task_description = "",
+        task_due_date = NA,
+        task_user_created = values$current_user,
+        task_datetime_created = Sys.time(),
+        task_user_last_updated = NA,
+        task_datetime_last_updated = NA,
+        task_user_completed = NA,
+        task_datetime_completed = NA
+      )
+    }
+
+    # logic ---------------------
+    ## modal fun -----
     show_modal_for_tasks <- function() {
 
       if (!is.null(values$tasks_data)) {
@@ -40,7 +61,9 @@ server <- function(id, values, scheme, mhcs) {
         }
 
       } else {
+
         tasks_selector <- NULL
+
       }
 
       # ui --------------------
@@ -65,9 +88,9 @@ server <- function(id, values, scheme, mhcs) {
       ui <- layout_sidebar(
         sidebar = tagList(
           selectizeInput(ns("tasks_id_selector"), label = "ID задачи:", choices = tasks_selector, selected = values$tasks_id),
-          actionButton(ns("tasks_create_new_task"), "new_task"),
+          actionButton(ns("tasks_create_new_task"), "Новая задача", icon("plus")),
-          actionButton(ns("tasks_add_autoreview"), "add autotask"),
+          actionButton(ns("tasks_add_autoreview"), "Новая авто-задача (тест)", icon("calendar")),
-          actionButton(ns("tasks_DT_VIEW"), "DT")
+          actionButton(ns("tasks_DT_VIEW"), "DT", icon("table"))
         ),
         tab
       )
@@ -76,35 +99,20 @@ server <- function(id, values, scheme, mhcs) {
         ui,
         size = "l",
         footer = tagList(
-          actionButton(ns("tasks_saving_button"), "сохранить изменения")
+          actionButton(ns("tasks_saving_button"), "Сохранить изменения", icon("floppy-disk"))
         ),
         easyClose = TRUE
       ))
     }
 
-    ## new tasks ----------------
-    get_default_task <- function() {
-
-      tibble::tibble(
-        task_id = paste0(format(Sys.time(), "%Y%m%d%H%M%S"), "_", values$main_key),
-        task_main_key = values$main_key,
-        task_status = "active",
-        task_title = "НОВАЯ ЗАДАЧА",
-        task_description = "",
-        task_due_date = NA,
-        task_user_created = values$current_user,
-        task_datetime_created = Sys.time(),
-        task_user_last_updated = NA,
-        task_datetime_last_updated = NA,
-        task_user_completed = NA,
-        task_datetime_completed = NA
-      )
-    }
-
-    # button logic ---------------------
     ## отображение окна -----------------
     observeEvent(input$display_task_modal, {
       
+      if (is.null(values$main_key)) {
+        showNotification("необходимо выбрать запись", type = "error")
+        return()
+      }
+
       con <- db$make_db_connection(scheme(),"display_task_modal")
       on.exit(db$close_db_connection(con, "display_task_modal"), add = TRUE)
 
@@ -217,23 +225,41 @@ server <- function(id, values, scheme, mhcs) {
     ## show DT --------------------------
     observeEvent(input$tasks_DT_VIEW, {
 
+      rename_cols <- tasks_colnames[tasks_colnames %in% colnames(values$tasks_data)]
+      
+      date_cols <- c("task_datetime_created", "task_datetime_completed", "task_datetime_last_updated", "task_due_date")
+      date_cols <- which(colnames(values$tasks_data) %in% date_cols)
+
       output$dt_tasks <- DT::renderDataTable(
         DT::datatable(
           values$tasks_data,
           caption = 'Table 1: This is a simple caption for the table.',
           rownames = FALSE,
-          # colnames = col_types |> dplyr::pull(form_id, form_label),
+          colnames = rename_cols,
           extensions = c('KeyTable', "FixedColumns"),
           # editable = 'cell',
+          class = 'cell-border stripe',
           selection = "none",
           options = list(
             dom = 'tip',
             scrollX = TRUE,
             fixedColumns = list(leftColumns = 1),
-            keys = TRUE
+            keys = TRUE,
+            autoWidth = TRUE,
+            columnDefs = list(
+              list(
+                targets = 3:4,
+                width = '200px',
+                render = htmlwidgets::JS(
+                  "function(data, type, row, meta) {",
+                  "return type === 'display' && data.length > 20 ?",
+                  "'<span title=\"' + data + '\">' + data.substr(0, 20) + '...</span>' : data;",
+                  "}")
+              )
+            )
           )
         ) |>
-          DT::formatDate(c("task_datetime_created", "task_datetime_completed", "task_datetime_last_updated", "task_due_date"), "toLocaleDateString", params = list('ru-RU'))
+          DT::formatDate(date_cols, "toLocaleDateString", params = list('ru-RU'))
       )
 
       showModal(modalDialog(
@@ -283,8 +309,9 @@ server <- function(id, values, scheme, mhcs) {
       show_modal_for_tasks()
     })
 
-    ## отображение списка задач для текущего дня ------------
+    # review задач ----------------
-    observeEvent(input$show_dt_today, {
+    ### все активные задачи ------------
+    observeEvent(input$show_dt_all, {
 
       con <- db$make_db_connection(scheme(),"display_task_modal")
       on.exit(db$close_db_connection(con, "display_task_modal"), add = TRUE)
@@ -293,36 +320,88 @@ server <- function(id, values, scheme, mhcs) {
         dplyr::mutate(dplyr::across(c("task_datetime_created", "task_datetime_last_updated", "task_datetime_completed"), as.POSIXct)) |>
         dplyr::mutate(dplyr::across(c("task_due_date"), as.Date))
 
+      display_tasks_dt_review()
+    })
+
+    ### задачи для текущего дня ------------
+    observeEvent(input$show_dt_today, {
+
+      con <- db$make_db_connection(scheme(),"display_task_modal")
+      on.exit(db$close_db_connection(con, "display_task_modal"), add = TRUE)
+
+      values$tasks_data <- DBI::dbGetQuery(con, glue::glue("SELECT * FROM tasks WHERE task_status = 'active' AND task_due_date = {as.integer(Sys.Date())}")) |>
+        dplyr::mutate(dplyr::across(c("task_datetime_created", "task_datetime_last_updated", "task_datetime_completed"), as.POSIXct)) |>
+        dplyr::mutate(dplyr::across(c("task_due_date"), as.Date))
+
+      display_tasks_dt_review()
+    })
+
+    ### просроченные ------------
+    observeEvent(input$show_dt_overdue, {
+
+      con <- db$make_db_connection(scheme(),"display_task_modal")
+      on.exit(db$close_db_connection(con, "display_task_modal"), add = TRUE)
+
+      values$tasks_data <- DBI::dbGetQuery(con, glue::glue("SELECT * FROM tasks WHERE task_status = 'active' AND task_due_date < {as.integer(Sys.Date())}")) |>
+        dplyr::mutate(dplyr::across(c("task_datetime_created", "task_datetime_last_updated", "task_datetime_completed"), as.POSIXct)) |>
+        dplyr::mutate(dplyr::across(c("task_due_date"), as.Date))
+
+      display_tasks_dt_review()
+    })
+
+    ### modal -----
+    display_tasks_dt_review <- function() {
+
+      values$tasks_data <- values$tasks_data |>
+        dplyr::select(task_id:task_datetime_last_updated)
+
+      rename_cols <- tasks_colnames[tasks_colnames %in% colnames(values$tasks_data)]
+      
+      date_cols <- c("task_datetime_created", "task_datetime_completed", "task_datetime_last_updated", "task_due_date")
+      date_cols <- which(colnames(values$tasks_data) %in% date_cols)
+
       output$dt_todays_tasks <- DT::renderDataTable(
         DT::datatable(
           values$tasks_data,
           caption = 'Table 1: This is a simple caption for the table.',
           rownames = FALSE,
-          # colnames = col_types |> dplyr::pull(form_id, form_label),
+          colnames = rename_cols,
-          extensions = c('KeyTable', "FixedColumns"),
+          extensions = c("FixedColumns"),
           # editable = 'cell',
           selection = "single",
           options = list(
             dom = 'tip',
             scrollX = TRUE,
             fixedColumns = list(leftColumns = 1),
-            keys = TRUE
+            autoWidth = TRUE,
+            columnDefs = list(
+              list(
+                targets = 3:4,
+                width = '200px',
+                render = htmlwidgets::JS(
+                  "function(data, type, row, meta) {",
+                  "return type === 'display' && data.length > 20 ?",
+                  "'<span title=\"' + data + '\">' + data.substr(0, 20) + '...</span>' : data;",
+                  "}")
+              )
+            )
           )
         ) |>
-          DT::formatDate(c("task_datetime_created", "task_datetime_completed", "task_datetime_last_updated", "task_due_date"), "toLocaleDateString", params = list('ru-RU'))
+        DT::formatDate(date_cols, "toLocaleDateString", params = list('ru-RU'))
       )
 
       showModal(modalDialog(
         DT::dataTableOutput(ns("dt_todays_tasks")),
         size = "xl",
         footer = tagList(
-          actionButton(ns("jump_to_main_key"), "перейти к id")
+          actionButton(ns("jump_to_main_key"), "перейти к id", icon("right-to-bracket"))
         ),
         easyClose = TRUE
       ))
 
-    })
+    }
 
+    ### jump to main_key ---------
     observeEvent(input$jump_to_main_key, {
 
       if (is.null(input$dt_todays_tasks_rows_selected)) {
@@ -330,14 +409,11 @@ server <- function(id, values, scheme, mhcs) {
       } else {
 
         # get key
-        new_main_key <- values$tasks_data[input$dt_todays_tasks_rows_selected,]$task_main_key
+        main_key_to_jump <- values$tasks_data[input$dt_todays_tasks_rows_selected,]$task_main_key
-        values$main_key <- new_main_key
+        values$main_key <- main_key_to_jump
 
-        showNotification("TODO: если ключа нет в таблице?!", type = "warning", duration = NULL)
         removeModal()
 
-        # log_action_to_db("loading data", values$main_key, con = con)
-
       }
     })
 
@@ -350,9 +426,21 @@ update_task_button_count <- function(con, values, ns) {
   inputID <- "display_task_modal"
   if (!missing(ns)) inputID <- ns(inputID)
   
+
+  # если ключ не определен - выход из функции
+  if (is.null(values$main_key)) {
+
+    updateActionButton(inputId = inputID, label = "Задачи")
+    return()
+
+  }
+
+  # при наличии таблицы - полу
   if ("tasks" %in% DBI::dbListTables(con)) {
+
     tasks_num <- DBI::dbGetQuery(con, glue::glue("SELECT COUNT ('task_id') FROM tasks WHERE task_main_key = '{values$main_key}' AND task_status = 'active'")) |>
       dplyr::pull()
+
     if (tasks_num > 0) {
       updateActionButton(inputId = inputID, label = paste("активных задач:", tasks_num))
     } else {
@@ -361,3 +449,18 @@ update_task_button_count <- function(con, values, ns) {
   }
 
 }
+
+tasks_colnames <- c(
+  "id задачи"       = "task_id",
+  "id записи"       = "task_main_key",
+  "статус"          = "task_status",
+  "задача"          = "task_title",
+  "описание"        = "task_description",
+  "срок выполнения" = "task_due_date",
+  "создана"         = "task_user_created",
+  "дата создания"   = "task_datetime_created",
+  "обновлено"       = "task_user_last_updated",
+  "дата обновления" = "task_datetime_last_updated",
+  "завершено"       = "task_user_completed",
+  "дата выполнения" = "task_datetime_completed"
+)

config.yml

@@ -11,8 +11,10 @@ prod:
     main_register: АВЗ и АМИЛОИОДОЗЫ
 
 devel:
-  form_app_configure_path: _devel/antifib
+  form_app_configure_path: _devel/new_bases
   form_auth_enabled: false
   form_app_version: 0.16.0 dev
   form_schemes:
     antifib: антифибротическая
+    d2tra_t: D2TRA_test
+    

modules/data_validation.R

@@ -71,6 +71,7 @@ val_is_a_number = function(x) {
 
   # exit if empty
   if (is_this_empty_value(x)) return(NULL)
+
   # хак для пропуска значений
   if (x == "NA") return(NULL)
 

modules/db.R

@@ -46,14 +46,13 @@ check_if_table_is_exist_and_init_if_not = function(
 
       if (table_name %in% DBI::dbListTables(con)) {
 
-        cli::cli_inform(c("*" = "проверка таблицы в базе данных: '{table_name}'"))
-
         # если таблица существует, производим проверку структуры таблицы
         compare_existing_table_with_schema(
           table_name = table_name,
           schm = schm
         )
 
+      # инициализируем все таблицы
       } else {
 
         if (table_name == "main") {
@@ -63,6 +62,7 @@ check_if_table_is_exist_and_init_if_not = function(
               .before = 1
             )
         }
+
         if (table_name != "main") {
           dummy_df <- get_dummy_df(forms_id_type_list) |>
             dplyr::mutate(
@@ -121,6 +121,8 @@ compare_existing_table_with_schema = function(
   con = rlang::env_get(rlang::caller_env(), nm = "con")
 ) {
 
+  cli::cli_progress_step("проверка таблицы в базе данных: '{table_name}'")
+
   main_key  <- schm$get_main_key_id
   key_id    <- schm$get_key_id(table_name)
   forms_ids <- schm$get_forms_ids(table_name)
@@ -403,3 +405,59 @@ local_db_backup <- function(
   )
 }
 
+#' @export
+db_clean_orphans = function(schm, con) {
+
+  main_key      <- schm$get_main_key_id
+  nested_tables <- schm$nested_tables_names
+
+  all_main_keys <- DBI::dbGetQuery(con, glue::glue("SELECT DISTINCT {main_key} FROM main"))
+  all_main_keys <- dplyr::pull(all_main_keys)
+
+  purrr::walk(
+    .x = nested_tables,
+    .f = \(table_name) clear_orphans(table_name = table_name, main_key = main_key, all_main_keys = all_main_keys, con = con)
+  )
+
+  clear_orphans(table_name = "tasks", main_key = "task_main_key", all_main_keys = all_main_keys, con = con, drop_na_keys = FALSE)
+  clear_orphans(table_name = "log", main_key = "key", all_main_keys = all_main_keys, con = con, drop_na_keys = FALSE)
+
+}
+
+clear_orphans <- function(
+  table_name,
+  main_key,
+  all_main_keys,
+  con,
+  drop_na_keys = TRUE
+) {
+
+  if (!table_name %in% DBI::dbListTables(con)) return(invisible())
+
+  all_main_keys_from_nested <- DBI::dbGetQuery(con, glue::glue("SELECT DISTINCT {main_key} FROM {table_name}"))
+  all_main_keys_from_nested <- dplyr::pull(all_main_keys_from_nested)
+
+  if (!drop_na_keys) {
+    all_main_keys_from_nested <- all_main_keys_from_nested[!is.na(all_main_keys_from_nested)]
+  }
+
+  if (all(all_main_keys_from_nested %in% all_main_keys)) {
+    cli::cli_alert_success("Все ключи в таблице '{table_name}' соответствуют действующим")
+  } else {
+
+    orphaned_keys <- all_main_keys_from_nested[!all_main_keys_from_nested %in% all_main_keys]
+    cli::cli_alert_warning(c("В таблице '{table_name}' найдены орфанные записи для следующих ID: ", paste("\n  -", orphaned_keys)))
+    
+    orphaned_keys <- paste0("'", orphaned_keys, "'", collapse = ", ")
+    del_query <- glue::glue("DELETE FROM {table_name} WHERE {main_key} IN ({orphaned_keys})")
+    deleted <- DBI::dbExecute(con, del_query)
+
+    if (drop_na_keys) {
+      deleted <- deleted + DBI::dbExecute(con, glue::glue("DELETE FROM {table_name} WHERE {main_key} IS NULL"))
+    }
+
+    cli::cli_alert_success("Из таблицы '{table_name}' было удалено {deleted} орфанных записей")
+
+  }
+
+}

modules/global_options.R

@@ -110,6 +110,7 @@ init_scheme = function(scheme_file) {
   if (!dir.exists(db_path)) dir.create(db_path)
 
   cli::cli_h1("Инициализация схемы")
+
   schms <- purrr::map2(
     .x = scheme_file,
     .y = names(scheme_file),
@@ -118,8 +119,15 @@ init_scheme = function(scheme_file) {
       con <- db$make_db_connection(y)
       on.exit(db$close_db_connection(con), add = TRUE)
 
+      # новый объект
       schm <- scheme_R6$new(x)
+
+      # проверка схемы с существующей базой данных и инициализация таблиц
       db$check_if_table_is_exist_and_init_if_not(schm, con)
+
+      # удаление орфанных записей
+
+      db$db_clean_orphans(schm = schm, con = con)
       schm
     }
   )
@@ -129,13 +137,13 @@ init_scheme = function(scheme_file) {
     names(schms),
     \(x) schms[[x]]$nested_tables_names
   )
+
   nested_tables_ids <- unlist(nested_tables_ids)
   tab <- table(nested_tables_ids)
 
   # если встречается хоть одно значение несколько раз - начать истошно кричать (могут возникнуть пробемы при вызове всплывающих окон в формах)
   if (!all(!tab > 1)) {
     cli::cli_abort(c("В одной или нескольких схемах наименования вложенных форм совпадают:", paste("-", names(tab)[tab > 1])))
-    
   }
   
   saveRDS(schms, "scheme.rds")

modules/scheme_generator.R

@@ -48,8 +48,8 @@ scheme_R6 <- R6::R6Class(
         "task_status",        "select_one",  "Статус задачи",          NA,                 "completed",
         "task_status",        "select_one",  "Статус задачи",          NA,                 "deleted",
         "task_title",         "text",        "Название задачи",        NA,                 NA,
-        "task_description",   "text",        "Описание задачи",        "краткое описание", NA,
+        "task_description",   "text",        "Описание задачи",        "краткое описание", "3",
-        "task_due_date",      "date",        "Дата выполнения задачи", "YE DJN",           NA,
+        "task_due_date",      "date",        "Дата выполнения задачи", NA,                 NA,
       ) |>
         dplyr::mutate(condition = NA)
 

modules/utils.R

@@ -135,7 +135,8 @@ render_forms = function(
     form <- shiny::textAreaInput(
       inputId = form_id,
       label = label,
-      rows = 1
+      rows = 1,
+      resize = "none"
     )
   }