Compare commits

..

4 Commits

9 changed files with 342 additions and 136 deletions

194
app.R
View File

@@ -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"
# APP.DEBUG = TRUE
shiny.host = "0.0.0.0",
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
box::use(app/forms)
box::use(app/tasks)
# load schemes object:
schms <- readRDS("scheme.rds")
# refactor LATER ---------
vv <- unlist(config::get()$form_schemes)
enabled_schemes <- names(vv)
vvvv <- unname(vv)
names(enabled_schemes) <- vvvv
# ------------------------
# CHECK FOR PANDOC
# TEMP ! NEED TO HANDLE
# CHECK FOR PANDOC ----------
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")
on.exit(db$close_db_connection(con, "nested_tables"), add = TRUE)
con <- db$make_db_connection(scheme(),"nested_key")
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")
on.exit(db$close_db_connection(con, "confirm_create_new_key"), add = TRUE)
con <- db$make_db_connection(scheme(),"confirm_create_new_nested_key")
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,40 +891,41 @@ 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)
existed_main_keys <- db$get_keys_from_table("main", mhcs(), con)
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) {
if (values$main_key %in% existed_main_keys) {
df <- db$read_df_from_db_by_id(
table_name = "main",
schm = mhcs(),
main_key_value = values$main_key,
con = con
)
df <- db$read_df_from_db_by_id(
table_name = "main",
schm = mhcs(),
main_key_value = values$main_key,
con = con
)
forms$load_data_to_form(
df = df,
table_name = "main",
mhcs
)
forms$load_data_to_form(
df = df,
table_name = "main",
mhcs
)
log_action_to_db("loading data", values$main_key, con = con)
log_action_to_db("loading data", values$main_key, con = con)
} else {
} else {
utils$clean_forms("main", mhcs())
utils$clean_forms("main", mhcs())
}
main_form_is_empty(FALSE)
}
# обновление счетичка задач
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()
})

View File

@@ -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,

View File

@@ -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_add_autoreview"), "add autotask"),
actionButton(ns("tasks_DT_VIEW"), "DT")
actionButton(ns("tasks_create_new_task"), "Новая задача", icon("plus")),
actionButton(ns("tasks_add_autoreview"), "Новая авто-задача (тест)", icon("calendar")),
actionButton(ns("tasks_DT_VIEW"), "DT", icon("table"))
),
tab
)
@@ -76,34 +99,19 @@ 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()
})
## отображение списка задач для текущего дня ------------
observeEvent(input$show_dt_today, {
# review задач ----------------
### все активные задачи ------------
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,50 +320,99 @@ 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),
extensions = c('KeyTable', "FixedColumns"),
colnames = rename_cols,
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)) {
showNotification("необходимо выбрать задачу", type = "error")
} else {
# get key
new_main_key <- values$tasks_data[input$dt_todays_tasks_rows_selected,]$task_main_key
values$main_key <- new_main_key
showNotification("TODO: если ключа нет в таблице?!", type = "warning", duration = NULL)
removeModal()
# log_action_to_db("loading data", values$main_key, con = con)
# get key
main_key_to_jump <- values$tasks_data[input$dt_todays_tasks_rows_selected,]$task_main_key
values$main_key <- main_key_to_jump
removeModal()
}
})
@@ -349,10 +425,22 @@ 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 {
@@ -360,4 +448,19 @@ 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"
)

View File

@@ -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: антифибротическая
antifib: антифибротическая
d2tra_t: D2TRA_test

View File

@@ -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)
@@ -82,7 +83,7 @@ val_is_a_number = function(x) {
## находится ли число в заданном диапазоне значений -------
val_number_within_a_range = function(x, ranges) {
# exit if empty
if (is_this_empty_value(x)) return(NULL)
if (x == "NA") return(NULL)

View File

@@ -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} орфанных записей")
}
}

View File

@@ -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")

View File

@@ -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_due_date", "date", "Дата выполнения задачи", "YE DJN", NA,
"task_description", "text", "Описание задачи", "краткое описание", "3",
"task_due_date", "date", "Дата выполнения задачи", NA, NA,
) |>
dplyr::mutate(condition = NA)

View File

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