Compare commits

...

60 Commits

Author SHA1 Message Date
0c9dda215d feat: возможность отражения информации действий по базам данных 2026-06-13 18:26:53 +03:00
835f053584 refactor: небольшие изменения 2026-06-13 17:21:04 +03:00
358a238f4e 0.18.1 (fix - корректный экспорт и импорт текстовых данных) 2026-06-08 21:53:15 +03:00
eb11ad8672 config update 2026-06-06 14:10:09 +03:00
39ae2337d4 0.18.0 2026-06-06 14:09:32 +03:00
436a6172e6 feat: BREAKING для упрощения работы с файлами схемами - смена путей с /config/schemeas/ до `/schemas/' 2026-06-06 11:44:08 +03:00
f52d110a59 feat: vis update 2026-05-20 17:06:03 +03:00
d615024640 Merge branch 'main' of https://gitea.madelirihs.ru/madeliri/shiny_form 2026-04-27 11:42:40 +03:00
870f0d93cc fix config work 2026-04-27 11:42:38 +03:00
2544bbbed0 Обновить config_example.yml 2026-04-27 11:39:06 +03:00
8fa6753f31 Добавить config.yml 2026-04-27 11:38:15 +03:00
3bbb903022 Удалить config.yml 2026-04-27 11:37:35 +03:00
66006696ac Обновить config.yml 2026-04-27 11:30:14 +03:00
182d9bcf3e Обновить .gitignore 2026-04-27 11:29:58 +03:00
73df94fe94 .gitignore 2026-04-27 11:26:08 +03:00
ae95389f10 Обновить config_example.yml 2026-04-27 11:23:03 +03:00
91b2deccf6 git: exclude config from git 2026-04-27 11:17:56 +03:00
f5031bfe1c fix: configs change 2026-04-27 11:17:04 +03:00
da277ffb06 fix: корректное создание бэкапа баз данных 2026-04-26 20:53:48 +03:00
c247699b23 refactor: изменение подходов к формированию конфига 2026-04-24 21:48:25 +03:00
b8b2951fd6 0.17.0 2026-04-24 16:22:31 +03:00
317d6e3d64 Merge pull request 'devel' (#1) from devel into main
Reviewed-on: madeliri/shiny_form#1
2026-04-24 16:00:03 +03:00
c63beeef0c feat: работа с орфанными записями 2026-04-24 15:58:29 +03:00
87444b5718 refactor: cleaning and polishing 2026-04-24 14:26:24 +03:00
4b05fbafc2 feat: корректное обновление счетчика задач на кнопке + список просроченных задач 2026-04-24 12:15:38 +03:00
c8da651e72 feat: vis update 2026-04-23 18:04:53 +03:00
fd5a7927cb reafactor: некоторый рефакторинг кода 2026-04-23 14:25:10 +03:00
bc5b4ea208 feat: вызов DT актуальный задач + переход к ID из общего списка 2026-04-23 14:13:03 +03:00
0c3c35936e refactor: some code refactoring 2026-04-23 12:55:39 +03:00
7b6cbc67e4 feat: определение активный схем - в файле конфига 2026-04-23 11:57:50 +03:00
696f2e3ac8 feat: задачи - в отдельном модуле 2026-04-23 11:51:04 +03:00
985cf99f5f feat: empty screen when no tasks 2026-04-23 10:27:04 +03:00
a9bbaf4504 feat: task_module 2026-04-22 18:27:39 +03:00
bb6f94126c fix: корректное формирование бэкапов 2026-04-22 12:15:07 +03:00
43af8c20c4 fix: корректное создание бэкапов 2026-04-22 10:51:02 +03:00
fe7cb9589e fix: выбор нового добавленного вложенного ключа 2026-04-22 10:38:47 +03:00
e7497c7d53 0.16.0 2026-04-21 14:13:28 +03:00
830e9c31a8 feat: бэкапы локальных баз данных 2026-04-21 13:58:52 +03:00
b928f4d356 fix: теперь все правильно (configs) 2026-04-20 19:17:53 +03:00
788541ab2b fix: изменен пайплайн конфигов во избежания ошибок в работе 2026-04-20 19:10:30 +03:00
ac75ab08c2 feat: bring config file back 2026-04-20 18:50:40 +03:00
7a006f6d6b feat: валидация данных в виде модулей 2026-04-20 16:38:14 +03:00
be1623716c refactor: перенос объявление enabled_schema в отдельный файл в папке configs 2026-04-17 16:26:12 +03:00
b5260a510f Merge branch 'main' of https://gitea.madelirihs.ru/madeliri/shiny_form 2026-04-17 14:48:00 +03:00
a000a4e123 gitupdate 2026-04-17 14:47:01 +03:00
f0063f3f83 Merge branch 'main' of https://gitea.madelirihs.ru/madeliri/shiny_form 2026-04-16 17:33:16 +03:00
20f0d52f12 feat: добавление новых строк в формы select_one, select_multiple 2026-04-16 17:33:11 +03:00
65a85d330c Merge branch 'main' of https://gitea.madelirihs.ru/madeliri/shiny_form 2026-04-15 20:38:11 +03:00
e60a21013a what 2026-04-15 20:38:10 +03:00
68faf06e38 fix: корректная работа во вложенных формах при добавлении нового ключа 2026-04-15 17:26:35 +03:00
f344859f92 fix: nested forms for select_one and et cetera 2026-04-15 15:02:33 +03:00
d196715f50 fix: проверка на длину названий вложенных таблиц 2026-04-15 14:53:51 +03:00
c50a259541 fix: некорректная загрузка box-модуля 2026-04-14 17:31:40 +03:00
6cf76641ed refactor: небольшие изменения кода 2026-04-14 11:43:10 +03:00
5a021b7e8f feat: проверка на - в id форм 2026-04-13 20:24:53 +03:00
3f396dedb4 feat: проверка для избежания использования зарезрвированных имен таблиц 2026-04-13 20:19:15 +03:00
c72cf5b815 feat: мета-данные к выгрузке данных 2026-04-13 20:18:47 +03:00
0212726b06 feat: более явный перенос данных (даты, числа, все остальное - текст) 2026-04-13 19:58:17 +03:00
2f62a94afa fix: correct data loading 2026-04-13 19:30:27 +03:00
4c3d339361 fix: корректное отображение столбцов во вложенной форме 2026-04-13 18:01:17 +03:00
23 changed files with 1495 additions and 369 deletions

View File

@@ -1 +1,43 @@
source("renv/activate.R") source("renv/activate.R")
(function() {
paths <- c(
"AUTH_DB_KEY"
)
lines <- paths[Sys.getenv(paths) == ""]
if (length(lines) > 0) {
cli::cli_h3("Настройка путей окружения")
cli::cli_code(paste0(lines, "="))
cli::cli_inform(c(
"i" = "Для нормальной работы скриптов добавьте в {.file .Renviron}:"
))
}
})()
(function() {
if (Sys.getenv("R_CONFIG_ACTIVE") == "") {
Sys.setenv(R_CONFIG_ACTIVE = "prod")
cli::cli_inform(c(
"i" = "Не указана конфигурация по умолчанию, автоматически установлен 'prod'. Для изменения конфигурации добавьте в {.file .Renviron}:"
))
cli::cli_code(paste0("R_CONFIG_ACTIVE", "="))
}
})()
# при первом запуске скопировать пример конфига
(function() {
if (!file.exists("config.yml")) {
file.copy("config_example.yml", "config.yml")
}
})()

2
.gitignore vendored
View File

@@ -1,7 +1,9 @@
/renv /renv
/temp /temp
/_devel
scheme.rds scheme.rds
config.yml
.Renviron .Renviron
.DS_Store .DS_Store

View File

@@ -1,3 +1,31 @@
### 0.18.1 (2026-06-08)
##### fix
- правильный экспорт текстовых данных
### 0.18.0 (2026-06-06)
##### features
- возможность отрганичить доступ к базам данных для отдельных пользователей
### 0.17.0 (2026-04-24)
##### features
- модуль с задачами: для каждой записи в базе можно создать задачи, на главном экране отображается общее количество активных задач, по сроку выполнения на сегодня и просроченные задачи;
- проверка на наличие орфанных записей в базе (сверка существующих ключей из главной таблицы `main` с каждой вложенной таблицей)
##### changes
- определение активных схем - теперь в файле `config.yml`
### 0.16.0 (2026-04-21)
##### features
- возможность импорта данных в базу данных из ранее экспортированных .xlsx таблиц;
- пререндеринг схемы формы (сокращение количества времени на загрузку приложения);
- главная форма для заполнения не отображается если не выбрана/создана запись;
- валидация правильности заполненных данных в формах 'select_one', 'select_multiple', 'radio' и 'checkboxes';
- возможность работы с несколькими формами в пределах одного приложения;
##### changes
- в каждой схеме первый элемент с формой (по id) теперь является ключевым (ранее необходимо было явно указывать id 'main_key' и 'nested_key');
- при экспорте из базы в .xlsx числовые значения всегда экспортируются как текст (чтобы сохранить 'NA' значения);
### 0.15.0 (2026-04-07) ### 0.15.0 (2026-04-07)
##### features ##### features
- added `description_header` form type; - added `description_header` form type;

View File

@@ -12,14 +12,55 @@
... ...
# Quick start
## локально:
Копирование содержимого репозитория
```bash
git clone https://gitea.madelirihs.ru/madeliri/shiny_form.git
```
Восстановление окружения
```r
renv::activate()
renv::init()
```
# Настройки
## переменные окружения
### работа с авторизацией
Пароль базы данных с авторизацией необходимо указать в `.Renviron`:
```
AUTH_DB_KEY = "this_is_your_password"
```
### бэкапы локальных баз
Для создания бэкапов локальных баз данных, необходимо указать путь куда будут сохранятся бэкапы в переменной окружения:
```
FORM_APP_LOCAL_DB_BACKUP_PATH="path_to_backups"
```
Проверка осуществляется при каждом запуске приложения, бэкапы создаются раз в день (при первом запуске).
Количество послдних сохраненных бэкапов:
```
FORM_APP_LOCAL_DB_BACKUP_LIMITS=3
```
# Cтруктура `schema.xlsx` # Cтруктура `schema.xlsx`
Файл, формирующий структуру всей формы, представляет собой таблицу в формате `.xlsx`, состоящий из следующих столбцов: Файл, формирующий структуру всей формы, представляет собой таблицу в формате `.xlsx`, состоящий из следующих столбцов:
- `part` - группировка первого уровня (страницы); - `part` - группировка первого уровня (страницы), используется только в главной схеме ('main');
- `subgroup` - группировка второго уровня (колонки); - `subgroup` - группировка второго уровня (колонки);
- `form_id` - id; - `form_id` - id формы;
- `form_label` - Название формы; - `form_label` - Название формы;
- `form_description` - Описание формы; - `form_description` - Описание формы;
- `form_type` - тип формы, в настоящее время доступные следующие варианты: - `form_type` - тип формы, в настоящее время доступные следующие варианты:
@@ -32,20 +73,17 @@
- `checkboxes` - выбор нескольких вариантов (checkboxes); - `checkboxes` - выбор нескольких вариантов (checkboxes);
- `description` - описание (отображение текста, без формы выбора/ввода); - `description` - описание (отображение текста, без формы выбора/ввода);
- `description_header` - для отображение заголовка; - `description_header` - для отображение заголовка;
- `nested_form` - вложенная форма; - `nested_forms` - вложенная форма;
- `choices` - варианты выбора (если предполагаются типом формы ввода); - `choices` - варианты выбора (если предполагаются типом формы ввода);
- `condition` - условие, при котором форма ввода будет отображаться; - `condition` - условие, при котором форма ввода будет отображаться;
- `required` - проверка заполненности поля: пустое значение - нет проверки, 1 - есть проверка - `required` - проверка заполненности поля: пустое значение - нет проверки, 1 - есть проверка
Первый по порядку id для каждой схемы является ключевой (!)
# Как пользоваться # Как пользоваться
## Авторизация ## Авторизация
Пароль базы данных с авторизацией необходимо указать в `.Renviron`:
```
AUTH_DB_KEY = "this_is_your_password"
```
# trade-ofs # trade-ofs

556
app.R

File diff suppressed because it is too large Load Diff

34
app/forms.R Normal file
View File

@@ -0,0 +1,34 @@
options(box.path = here::here())
box::use(
modules/utils,
)
#' @export
load_data_to_form <- function(
df,
table_name = "main",
mhcs,
ns
) {
input_types <- unname(mhcs()$get_id_type_list(table_name))
input_ids <- names(mhcs()$get_id_type_list(table_name))
if (missing(ns)) ns <- NULL
# rewrite input forms
purrr::walk2(
.x = input_types,
.y = input_ids,
.f = \(x_type, x_id) {
# updating forms with loaded data
utils$update_forms_with_data(
form_id = x_id,
form_type = x_type,
value = df[[x_id]],
scheme = mhcs()$get_scheme(table_name),
ns = ns
)
}
)
}

129
app/logs.R Normal file
View File

@@ -0,0 +1,129 @@
box::use(
shiny[...],
bslib[...]
)
options(box.path = here::here())
box::use(
modules/db,
modules/utils,
app/forms
)
#' @export
server <- function(id, values, scheme, mhcs) {
ns <- NS(id)
moduleServer(id, function(input, output, session) {
# отображение DT-таблицы со списком последних действий
observeEvent(input$show_last_actions, {
con <- db$make_db_connection(scheme(),"show_last_actions")
on.exit(db$close_db_connection(con, "show_last_actions"), add = TRUE)
log_df <- DBI::dbReadTable(con, "log")
# новые записи вначале, формат даты с временем
log_df <- log_df |>
dplyr::arrange(dplyr::desc(date)) |>
dplyr::mutate(date = format(as.POSIXct(date), "%d.%m.%Y %H:%M"))
output$dt_logs <- DT::renderDataTable(
DT::datatable(
log_df,
# caption = 'Table 1: This is a simple caption for the table.',
rownames = FALSE,
colnames = logs_colnames,
extensions = c('KeyTable', "FixedColumns"),
# editable = 'cell',
class = 'cell-border stripe',
selection = "single",
options = list(
# dom = 'tipf',
scrollX = TRUE,
fixedColumns = list(leftColumns = 1),
keys = TRUE,
autoWidth = TRUE,
columnDefs = list(
list(width = "150px", targets = c(0,6)),
list(width = "110px", targets = c(1:4))
)
)
)
)
showModal(modalDialog(
DT::dataTableOutput(ns("dt_logs")),
size = "xl",
# footer = tagList(
# actionButton("nested_form_dt_save", "сохранить изменения")
# ),
easyClose = TRUE
))
})
# observe({
# print(input$dt_logs_rows_selected)
# })
output$display_log <- renderUI({
req(values$main_key)
# получение логов
con <- db$make_db_connection(scheme(),"display_log")
on.exit(db$close_db_connection(con, "display_log"), add = TRUE)
query <- sprintf("SELECT * FROM \"log\" WHERE key = '%s'", values$main_key)
log_df_for_id <- DBI::dbGetQuery(con, query)
if (nrow(log_df_for_id) > 0) {
lines <- log_df_for_id |>
dplyr::mutate(
date = as.POSIXct(date),
date = date + lubridate::hours(3), # fix datetime
date_day = as.Date(date)
) |>
dplyr::mutate(cons_actions = dplyr::consecutive_id(action, user)) |>
dplyr::mutate(n_actions = dplyr::row_number(), .by = c(cons_actions, user, action, date_day)) |>
dplyr::slice(which.max(n_actions), .by = c(user, action, date_day)) |>
dplyr::arrange(date) |>
dplyr::mutate(string_to_print = sprintf(
"<b>[%s %s]</b> %s: %s (%s)",
format(date, "%d.%m.%y"),
format(date, "%H:%M"),
user,
action,
n_actions
)) |>
dplyr::pull(string_to_print) |>
paste(collapse = "</br>")
} else {
lines <- ""
}
div(
strong("Последние действия:"),
br(),
HTML(lines),
style = "font-size:10px;"
)
})
})
}
logs_colnames <- c(
"время" = "date",
"пользователь" = "user",
"приложение" = "app_id",
"версия" = "app_ver",
"ip" = "remote_addr",
"ID записи" = "key",
"действие" = "action"
)

474
app/tasks.R Normal file
View File

@@ -0,0 +1,474 @@
box::use(
shiny[...],
bslib[...]
)
options(box.path = here::here())
box::use(
modules/db,
modules/utils,
app/forms
)
#' @export
server <- function(id, values, scheme, mhcs) {
ns <- NS(id)
moduleServer(id, function(input, output, session) {
# BOOKMARKS SETUP ========================
# observe({
# # print(values$current_user)
# })
# 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)) {
tasks_selector <- values$tasks_data |>
dplyr::filter(task_status == "active") |>
dplyr::pull(task_id)
tasks_selector <- unique(c(values$tasks_id, tasks_selector))
tasks_selector <- sort(tasks_selector)
if (length(values$tasks_id) == 0) {
values$tasks_id <- if (length(tasks_selector) == 0) NULL else tasks_selector[[1]]
}
} else {
tasks_selector <- NULL
}
# ui --------------------
# очень большой костыль
subroup_scheme <- mhcs()$get_scheme("tasks") |>
dplyr::filter(form_id != "dummy")
tab <- if (length(tasks_selector) > 0) {
bslib::nav_panel(
title = "no name provided",
purrr::pmap(
.l = dplyr::distinct(subroup_scheme, form_id, form_label, form_type),
.f = utils$render_forms,
main_scheme = subroup_scheme,
ns = ns
)
)
} else {
bslib::nav_panel("", div("Нет доступных записей.", br(), "Необходимо создать новую запись."))
}
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"), "Новая задача", icon("plus")),
actionButton(ns("tasks_add_autoreview"), "Новая авто-задача (тест)", icon("calendar")),
actionButton(ns("tasks_DT_VIEW"), "DT", icon("table"))
),
tab
)
showModal(modalDialog(
ui,
size = "l",
footer = tagList(
actionButton(ns("tasks_saving_button"), "Сохранить изменения", icon("floppy-disk"))
),
easyClose = TRUE
))
}
## отображение окна -----------------
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)
values$tasks_data <- if ("tasks" %in% DBI::dbListTables(con)) {
DBI::dbGetQuery(con, glue::glue("SELECT * FROM tasks WHERE task_main_key = '{values$main_key}'")) |>
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))
} else {
NULL
}
values$tasks_id <- NULL
show_modal_for_tasks()
})
## изменение выбранной задачи -------
observeEvent(input$tasks_id_selector, {
req(input$tasks_id_selector)
req(values$tasks_id)
# выбранный ключ в форме - перемещаем в RV
values$tasks_id <- input$tasks_id_selector
})
## обновление формы при измененнии id ключа ------
observeEvent(values$tasks_id, {
df <- values$tasks_data |>
dplyr::filter(task_id == values$tasks_id)
forms$load_data_to_form(
df = df,
table_name = "tasks",
mhcs
# ns = ns
)
})
## saving button ------------------------------
observeEvent(input$tasks_saving_button, {
con <- db$make_db_connection(scheme(),"tasks_saving_button")
on.exit(db$close_db_connection(con, "tasks_saving_button"), add = TRUE)
if (!values$main_key %in% db$get_keys_from_table("main", mhcs(), con)) {
showNotification("Невозможно создать задачу для данного ID (нет в базе)", type = "error")
return()
}
id_and_types_list <- mhcs()$get_id_type_list("tasks")
input_types <- unname(id_and_types_list)
input_ids <- names(id_and_types_list)
exported_values <- purrr::map2(
.x = input_ids,
.y = input_types,
.f = \(x_id, x_type) {
input_d <- input[[x_id]]
# return empty if 0 element
if (length(input_d) == 0) {
return(utils$get_empty_data(x_type))
} else {
input_d
}
}
)
exported_df <- stats::setNames(exported_values, input_ids) |>
dplyr::as_tibble()
df <- values$tasks_data
df[df$task_id == values$tasks_id,]$task_status <- exported_df$task_status
df[df$task_id == values$tasks_id,]$task_title <- exported_df$task_title
df[df$task_id == values$tasks_id,]$task_description <- exported_df$task_description
df[df$task_id == values$tasks_id,]$task_due_date <- exported_df$task_due_date
df[df$task_id == values$tasks_id,]$task_user_last_updated <- values$current_user
df[df$task_id == values$tasks_id,]$task_datetime_last_updated <- Sys.time()
if (exported_df$task_status == "completed") {
df[df$task_id == values$tasks_id,]$task_user_completed <- values$current_user
df[df$task_id == values$tasks_id,]$task_datetime_completed <- Sys.time()
}
values$tasks_data <- df
if ("tasks" %in% DBI::dbListTables(con)) {
query <- glue::glue("
DELETE
FROM tasks
WHERE task_main_key = '{values$main_key}'
")
DBI::dbExecute(con, query)
}
DBI::dbWriteTable(con, "tasks", df, append = TRUE)
update_task_button_count(con, values)
showNotification("Задача успешно создана/обновлена", type = "message")
tasks_selector <- values$tasks_data |>
dplyr::filter(task_status != "completed") |>
dplyr::pull(task_id)
selector <- ifelse(!values$tasks_id %in% tasks_selector, tasks_selector[1], values$tasks_id)
updateSelectInput(inputId = "tasks_id_selector", choices = tasks_selector, selected = selector)
})
## 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 = 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,
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(date_cols, "toLocaleDateString", params = list('ru-RU'))
)
showModal(modalDialog(
DT::dataTableOutput(ns("dt_tasks")),
size = "xl",
# footer = tagList(
# actionButton("nested_form_dt_save", "сохранить изменения")
# ),
easyClose = TRUE
))
})
## создание новой задачи -------------
observeEvent(input$tasks_create_new_task, {
new_task <- get_default_task()
values$tasks_data <- rbind(values$tasks_data, new_task)
values$tasks_id <- new_task$task_id
tasks_selector <- values$tasks_data |>
dplyr::filter(task_status != "completed") |>
dplyr::pull(task_id)
updateSelectInput(inputId = "tasks_id_selector", choices = tasks_selector, selected = values$tasks_id)
removeModal()
show_modal_for_tasks()
})
## создание новой авто-задачи -------------
observeEvent(input$tasks_add_autoreview, {
new_task <- get_default_task()
new_task$task_title <- "autoreview"
new_task$task_description <- "напоминание об актуализации данных"
new_task$task_due_date <- Sys.Date() + 28
values$tasks_data <- rbind(values$tasks_data, new_task)
values$tasks_id <- new_task$task_id
tasks_selector <- values$tasks_data |>
dplyr::filter(task_status != "completed") |>
dplyr::pull(task_id)
updateSelectInput(inputId = "tasks_id_selector", choices = tasks_selector, selected = values$tasks_id)
removeModal()
show_modal_for_tasks()
})
# 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)
values$tasks_data <- DBI::dbGetQuery(con, glue::glue("SELECT * FROM tasks WHERE task_status = 'active'")) |>
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) |>
dplyr::arrange(task_due_date)
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 = rename_cols,
extensions = c("FixedColumns"),
# editable = 'cell',
class = 'cell-border stripe',
selection = "single",
options = list(
dom = 'tip',
scrollX = TRUE,
fixedColumns = list(leftColumns = 1),
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(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", 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
main_key_to_jump <- values$tasks_data[input$dt_todays_tasks_rows_selected,]$task_main_key
values$main_key <- main_key_to_jump
removeModal()
}
})
})
}
#' @export
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 {
updateActionButton(inputId = inputID, label = "Задачи: нет активных")
}
}
}
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"
)

10
config_example.yml Normal file
View File

@@ -0,0 +1,10 @@
default:
form_app_version: !expr config::get("form_app_version", file = "descr.yml")
form_id: !expr config::get("form_id", file = "descr.yml")
form_name: !expr config::get("form_name", file = "descr.yml")
prod:
form_app_configure_path: "example_scheme"
form_auth_enabled: false
form_schemes:
example_of_scheme: Тестовая база данных

4
descr.yml Normal file
View File

@@ -0,0 +1,4 @@
default:
form_app_version: 0.18.1
form_id: formy
form_name: FORMY

Binary file not shown.

View File

@@ -1,27 +0,0 @@
#' @description Function check if variable contains some sort of empty data
#' (NULL, NA, "", other 0-length data) and return `TRUE` (`FALSE` if data is
#' not 'empty').
#'
#' Needed for proper data validation.
#' (ДУБЛИРУЕТ МОДУЛЬ `data_manipulation`)
check_for_empty_data <- function(value_to_check) {
# for any 0-length
if (length(value_to_check) == 0) return(TRUE)
# for NA
if (is.logical(value_to_check) && is.na(value_to_check)) return(TRUE)
# for NULL
if (is.null(value_to_check)) return(TRUE)
# for non-empty Date (RETURN FALSE)
if (inherits(value_to_check, "Date") && length(value_to_check) != 0) return(FALSE)
# for empty strings (stands before checking non-empty data for avoid mistakes)
if (value_to_check == "") return(TRUE)
FALSE
}

View File

@@ -4,7 +4,8 @@
#' not 'empty'). #' not 'empty').
#' #'
#' Needed for proper data validation. #' Needed for proper data validation.
check_for_empty_data = function(value_to_check) { #' @export
is_this_empty_value = function(value_to_check) {
# for any 0-length # for any 0-length
if (length(value_to_check) == 0) return(TRUE) if (length(value_to_check) == 0) return(TRUE)
@@ -19,7 +20,14 @@ check_for_empty_data = function(value_to_check) {
if (inherits(value_to_check, "Date") && length(value_to_check) != 0) return(FALSE) if (inherits(value_to_check, "Date") && length(value_to_check) != 0) return(FALSE)
# for empty strings (stands before checking non-empty data for avoid mistakes) # for empty strings (stands before checking non-empty data for avoid mistakes)
if (value_to_check == "") return(TRUE) if (is.character(value_to_check)) {
if (is.na(value_to_check)) return(TRUE)
if (value_to_check == "") return(TRUE)
}
FALSE if (is.double(value_to_check)) {
if (is.na(value_to_check)) return(TRUE)
}
return(FALSE)
} }

View File

@@ -1,21 +1,20 @@
options(box.path = here::here())
box::use(modules/data_manipulations[is_this_empty_value])
#' @export #' @export
init_val = function(scheme, ns) { init_val = function(scheme, ns) {
options(box.path = here::here())
box::use(modules/data_manipulations[check_for_empty_data])
iv <- shinyvalidate::InputValidator$new() iv <- shinyvalidate::InputValidator$new()
# если передана функция с пространством имен, то происходит модификация id # если передана функция с пространством имен, то происходит модификация id
if(!missing(ns)) { if (!missing(ns)) {
scheme <- scheme |> scheme <- scheme |>
dplyr::mutate(form_id = ns(form_id)) dplyr::mutate(form_id = ns(form_id))
} }
# формируем список id - тип # формируем список id - тип
inputs_simple_list <- scheme |> inputs_simple_list <- scheme |>
dplyr::filter(!form_type %in% c("nested_forms","description", "description_header")) |> dplyr::filter(!form_type %in% c("nested_forms", "description", "description_header")) |>
dplyr::distinct(form_id, form_type) |> dplyr::distinct(form_id, form_type) |>
tibble::deframe() tibble::deframe()
@@ -37,18 +36,7 @@ init_val = function(scheme, ns) {
# value `0; 250` -> transform to rule validation value from 0 to 250 # value `0; 250` -> transform to rule validation value from 0 to 250
if (form_type == "number") { if (form_type == "number") {
iv$add_rule(x_input_id, function(x) { iv$add_rule(x_input_id, val_is_a_number)
# exit if empty
if (check_for_empty_data(x)) {
return(NULL)
}
# хак для пропуска значений
if (x == "NA") return(NULL)
# check for numeric
# if (grepl("^[-]?(\\d*\\,\\d+|\\d+\\,\\d*|\\d+)$", x)) NULL else "Значение должно быть числом."
if (grepl("^[+-]?\\d*[\\.|\\,]?\\d+$", x)) NULL else "Значение должно быть числом."
})
# проверка на соответствие диапазону значений # проверка на соответствие диапазону значений
if (!is.na(choices)) { if (!is.na(choices)) {
@@ -59,51 +47,15 @@ init_val = function(scheme, ns) {
if (length(ranges) > 3) { if (length(ranges) > 3) {
warning("Количество переданных элементов'", x_input_id, "' > 2") warning("Количество переданных элементов'", x_input_id, "' > 2")
} else { } else {
iv$add_rule( iv$add_rule(x_input_id, val_number_within_a_range, ranges = ranges)
x_input_id,
function(x) {
# exit if empty
if (check_for_empty_data(x)) {
return(NULL)
}
if (x == "NA") return(NULL)
# замена разделителя десятичных цифр
x <- stringr::str_replace(x, ",", ".")
# check for currect value
if (dplyr::between(as.double(x), ranges[1], ranges[2])) {
NULL
} else {
glue::glue("Значение должно быть между {ranges[1]} и {ranges[2]}.")
}
}
)
} }
} }
} }
if (form_type %in% c("select_multiple", "select_one")) { if (form_type %in% c("select_multiple", "select_one", "radio", "checkbox")) {
iv$add_rule(x_input_id, function(x) { iv$add_rule(x_input_id, val_choice_within_a_dict, choices = choices)
if (length(x) == 1) {
if (check_for_empty_data(x)) return(NULL)
}
# проверка на соответствие вариантов схеме ---------
compare_to_dict <- (x %in% choices)
if (!all(compare_to_dict)) {
text <- paste0("'",x[!compare_to_dict],"'", collapse = ", ")
glue::glue("варианты, не соответствующие схеме: {text}")
}
})
} }
# if in `required` column value is `1` apply standart validation # if in `required` column value is `1` apply standart validation
if (!is.na(val_required) && val_required == 1) { if (!is.na(val_required) && val_required == 1) {
iv$add_rule(x_input_id, shinyvalidate::sv_required(message = "Необходимо заполнить.")) iv$add_rule(x_input_id, shinyvalidate::sv_required(message = "Необходимо заполнить."))
@@ -112,3 +64,54 @@ init_val = function(scheme, ns) {
) )
iv iv
} }
# работа с числовыми значениями ------------------
## проверка является ли значение числом ----------
val_is_a_number = function(x) {
# exit if empty
if (is_this_empty_value(x)) return(NULL)
# хак для пропуска значений
if (x == "NA") return(NULL)
# check for numeric
# if (grepl("^[-]?(\\d*\\,\\d+|\\d+\\,\\d*|\\d+)$", x)) NULL else "Значение должно быть числом."
if (grepl("^[+-]?\\d*[\\.|\\,]?\\d+$", x)) NULL else "Значение должно быть числом."
}
## находится ли число в заданном диапазоне значений -------
val_number_within_a_range = function(x, ranges) {
# exit if empty
if (is_this_empty_value(x)) return(NULL)
if (x == "NA") return(NULL)
# замена разделителя десятичных цифр
x <- stringr::str_replace(x, ",", ".")
# check for currect value
if (dplyr::between(as.double(x), ranges[1], ranges[2])) {
NULL
} else {
glue::glue("Значение должно быть между {ranges[1]} и {ranges[2]}.")
}
}
# списки ---------------------------------------------------------
## являются ли выбранные значения допустимы (согласно файлу схемы)
val_choice_within_a_dict = function(x, choices) {
if (length(x) == 1) {
if (is_this_empty_value(x)) return(NULL)
}
# проверка на соответствие вариантов схеме ---------
compare_to_dict <- (x %in% choices)
if (!all(compare_to_dict)) {
text <- paste0("'",x[!compare_to_dict],"'", collapse = ", ")
glue::glue("варианты, не соответствующие схеме: {text}")
}
}

View File

@@ -3,8 +3,14 @@
#' @description Function to open connection to db, disigned to easy dubugging. #' @description Function to open connection to db, disigned to easy dubugging.
#' @param where text mark to distingiush calss #' @param where text mark to distingiush calss
make_db_connection = function(scheme, where = "") { make_db_connection = function(scheme, where = "") {
if (getOption("APP.DEBUG", FALSE)) message("=== DB CONNECT ", where)
DBI::dbConnect(RSQLite::SQLite(), fs::path("db", scheme, ext = "sqlite")) DBI::dbConnect(RSQLite::SQLite(), fs::path(
config::get("form_app_configure_path"),
"db",
scheme,
ext = "sqlite"
))
} }
#' @export #' @export
@@ -12,12 +18,14 @@ make_db_connection = function(scheme, where = "") {
#' Function to close connection to db, disigned to easy dubugging and #' Function to close connection to db, disigned to easy dubugging and
#' hide warnings. #' hide warnings.
close_db_connection = function(con, where = "") { close_db_connection = function(con, where = "") {
tryCatch( tryCatch(
expr = DBI::dbDisconnect(con), expr = DBI::dbDisconnect(con),
error = function(e) print(e), error = function(e) print(e),
warning = function(w) if (getOption("APP.DEBUG", FALSE)) message("=!= ALREADY DISCONNECTED ", where), warning = function(w) if (getOption("APP.DEBUG", FALSE)) message("=!= ALREADY DISCONNECTED ", where),
finally = if (getOption("APP.DEBUG", FALSE)) message("=/= DB DISCONNECT ", where) finally = if (getOption("APP.DEBUG", FALSE)) message("=/= DB DISCONNECT ", where)
) )
} }
#' @export #' @export
@@ -39,14 +47,13 @@ check_if_table_is_exist_and_init_if_not = function(
if (table_name %in% DBI::dbListTables(con)) { if (table_name %in% DBI::dbListTables(con)) {
cli::cli_inform(c("*" = "проверка таблицы в базе данных: '{table_name}'"))
# если таблица существует, производим проверку структуры таблицы # если таблица существует, производим проверку структуры таблицы
compare_existing_table_with_schema( compare_existing_table_with_schema(
table_name = table_name, table_name = table_name,
schm = schm schm = schm
) )
# инициализируем все таблицы
} else { } else {
if (table_name == "main") { if (table_name == "main") {
@@ -56,6 +63,7 @@ check_if_table_is_exist_and_init_if_not = function(
.before = 1 .before = 1
) )
} }
if (table_name != "main") { if (table_name != "main") {
dummy_df <- get_dummy_df(forms_id_type_list) |> dummy_df <- get_dummy_df(forms_id_type_list) |>
dplyr::mutate( dplyr::mutate(
@@ -114,6 +122,8 @@ compare_existing_table_with_schema = function(
con = rlang::env_get(rlang::caller_env(), nm = "con") con = rlang::env_get(rlang::caller_env(), nm = "con")
) { ) {
cli::cli_progress_step("проверка таблицы в базе данных: '{table_name}'")
main_key <- schm$get_main_key_id main_key <- schm$get_main_key_id
key_id <- schm$get_key_id(table_name) key_id <- schm$get_key_id(table_name)
forms_ids <- schm$get_forms_ids(table_name) forms_ids <- schm$get_forms_ids(table_name)
@@ -185,12 +195,14 @@ write_df_to_db = function(
con con
) { ) {
scheme <- schm$get_schema(table_name) scheme <- schm$get_scheme(table_name)
main_key_id <- schm$get_main_key_id main_key_id <- schm$get_main_key_id
nested_key_id <- schm$get_key_id(table_name) nested_key_id <- schm$get_key_id(table_name)
date_columns <- subset(scheme, form_type == "date", form_id, drop = TRUE) date_columns <- subset(scheme, form_type == "date", form_id, drop = TRUE)
number_columns <- subset(scheme, form_type == "number", form_id, drop = TRUE) number_columns <- subset(scheme, form_type == "number", form_id, drop = TRUE)
# other_cols <- which(colnames(df) %in% c(date_columns, number_columns))
other_cols <- colnames(df)[!(colnames(df) %in% c(date_columns, number_columns))]
df <- df |> df <- df |>
dplyr::mutate( dplyr::mutate(
@@ -198,6 +210,7 @@ write_df_to_db = function(
dplyr::across(tidyselect::all_of({{date_columns}}), \(x) purrr::map_chr(x, excel_to_db_dates_converter)), dplyr::across(tidyselect::all_of({{date_columns}}), \(x) purrr::map_chr(x, excel_to_db_dates_converter)),
# числа - к единому формату десятичных значений # числа - к единому формату десятичных значений
dplyr::across(tidyselect::all_of({{number_columns}}), ~ gsub("\\.", "," , .x)), dplyr::across(tidyselect::all_of({{number_columns}}), ~ gsub("\\.", "," , .x)),
dplyr::across(tidyselect::all_of({{other_cols}}), \(x) dplyr::if_else(x == "", as.character(NA), as.character(x)))
) )
if (table_name == "main") { if (table_name == "main") {
@@ -327,3 +340,126 @@ excel_to_db_dates_converter = function(date) {
fin_date <- as.character(format(fin_date, "%Y-%m-%d")) fin_date <- as.character(format(fin_date, "%Y-%m-%d"))
fin_date fin_date
} }
#' @export
local_db_backup <- function(
db_name,
backups_paths = Sys.getenv("FORM_APP_LOCAL_DB_BACKUP_PATH"),
backups_limit = as.integer(Sys.getenv("FORM_APP_LOCAL_DB_BACKUP_LIMITS", 5))
) {
db_path <- fs::path(config::get("form_app_configure_path"), "db")
db_full_path <- fs::path(db_path, db_name, ext = "sqlite")
backup_folder <- fs::path(backups_paths, db_name)
if (!dir.exists(backup_folder)) dir.create(backup_folder, recursive = TRUE)
date_mark <- format(Sys.time(), "%Y%m%d")
schedule <- c(
daily = 1,
weekly = 7,
monthly = 28
)
purrr::walk2(
.x = schedule,
.y = names(schedule),
.f = \(schedule_days, schedule_name) {
daily_folder <- fs::path(backup_folder, schedule_name)
todays_backup <- fs::path(daily_folder, paste0(db_name, "_", format(Sys.time(), "%Y%m%d")), ext = "sqlite")
if (!dir.exists(daily_folder)) dir.create(daily_folder)
existed_files <- fs::dir_ls(daily_folder, regexp = "((?:19|20)\\d\\d)(0?[1-9]|1[012])([12][0-9]|3[01]|0?[1-9])")
existed_files <- sort(existed_files, decreasing = TRUE)
# если бэкап для сегодняшнего дня есть - скипаем процедуру
if (todays_backup %in% existed_files) {
return()
}
# парсим даты
dates <- stringr::str_extract(existed_files, "((?:19|20)\\d\\d)(0?[1-9]|1[012])([12][0-9]|3[01]|0?[1-9])")
dates <- as.Date(dates, "%Y%m%d")
if (length(existed_files) == 0) {
file.copy(db_full_path, todays_backup)
cli::cli_alert_success("создан {schedule_name}-бэкап для '{db_name}'")
return()
}
# если количество существующих бэкапов превышает установленный лимит, удаляем лишнее
if (length(existed_files) >= backups_limit) {
file.remove(utils::tail(existed_files, length(existed_files) - backups_limit))
}
# если количество существующих бэкапов равно имеющемуся и пора делать бэкап - делаем бэкап
if (dates[1] + schedule_days <= Sys.Date()) {
file.copy(db_full_path, todays_backup)
cli::cli_alert_success("создан {schedule_name}-бэкап для '{db_name}'")
}
}
)
}
#' @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

@@ -3,13 +3,31 @@
set_global_options = function( set_global_options = function(
SYMBOL_DELIM = "; ", SYMBOL_DELIM = "; ",
APP.DEBUG = FALSE, APP.DEBUG = FALSE,
# APP.FILE_DB = fs::path("data.sqlite"),
shiny.host = "127.0.0.1", shiny.host = "127.0.0.1",
shiny.port = 1337, shiny.port = 1338,
... ...
) { ) {
config_params_to_check <- c(
"form_app_version",
"form_id",
"form_name",
"form_app_configure_path",
"form_auth_enabled",
"form_schemes"
)
expected_params_in_config <- config_params_to_check %in% names(config::get())
if (!all(expected_params_in_config)) {
cli::cli_abort(c(
"Необходимо добавить в файл конфига {.file config.yml} следующие параметры:",
paste0(config_params_to_check[!expected_params_in_config], ":")
))
}
options( options(
SYMBOL_DELIM = SYMBOL_DELIM, SYMBOL_DELIM = SYMBOL_DELIM,
# form.db_path = config::get("form_db_path"),
APP.DEBUG = APP.DEBUG, APP.DEBUG = APP.DEBUG,
# APP.FILE_DB = APP.FILE_DB, # APP.FILE_DB = APP.FILE_DB,
shiny.host = shiny.host, shiny.host = shiny.host,
@@ -19,27 +37,37 @@ set_global_options = function(
} }
#' @export #' @export
enabled_schemas <- c( AUTH_ENABLED <- config::get("form_auth_enabled")
`Тестовая база данных` = "example_of_scheme"
# `D2TRA (для отладки)` = "d2tra_t"
)
#' @export #' @export
check_and_init_scheme = function() { check_and_init_scheme = function() {
cli::cli_inform(c("*" = "проверка схемы...")) cli::cli_inform(c("*" = "проверка схемы..."))
options(box.path = here::here())
box::use(modules/db[local_db_backup])
# список файлов, изменение которых, приведут к переинициализиации схемы
files_to_watch <- c( files_to_watch <- c(
"modules/scheme_generator.R" "config.yml",
"modules/scheme_generator.R",
"modules/utils.R"
) )
scheme_names <- enabled_schemas # проверка существования отслеживаемых файлов
scheme_file <- paste0("configs/schemas/", scheme_names, ".xlsx") if (!all(file.exists(files_to_watch))) {
scheme_file <- stats::setNames(scheme_file, scheme_names) cli::cli_abort("проверка схем: {files_to_watch[!file.exists(files_to_watch)]} is not exists")
}
if (!all(file.exists(scheme_file))) cli::cli_abort(c("Отсутствуют файлы схем для следующих наименований:", paste("-", names(scheme_file)[!file.exists(scheme_file)]))) scheme_names <- names(config::get()$form_schemes)
scheme_file <- paste0(config::get("form_app_configure_path"), "/schemas/", scheme_names, ".xlsx")
scheme_file <- stats::setNames(scheme_file, scheme_names)
db_files <- paste0("db/", scheme_names, ".sqlite") if (!all(file.exists(scheme_file))) {
cli::cli_abort(c("Отсутствуют файлы схем для следующих наименований:", paste("-", names(scheme_file)[!file.exists(scheme_file)])))
}
db_files <- paste0(config::get("form_app_configure_path"), "/db/", scheme_names, ".sqlite")
hash_file <- "temp/schema_hash.rds" hash_file <- "temp/schema_hash.rds"
@@ -59,19 +87,26 @@ check_and_init_scheme = function() {
# если данные были изменены проводим реинициализацию таблицы и схемы # если данные были изменены проводим реинициализацию таблицы и схемы
if (!all(exist_hash == saved_hash)) { if (!all(exist_hash == saved_hash)) {
cli::cli_inform(c(">" = "Данные схемы были изменены...")) cli::cli_inform(c(">" = "Данные схем были изменены..."))
init_scheme(scheme_file) init_scheme(scheme_file)
} else { } else {
cli::cli_alert_success("изменений нет") cli::cli_alert_success("изменений нет")
} }
} }
# MAKING BACKUPS
if (Sys.getenv("FORM_APP_LOCAL_DB_BACKUP_PATH") != "") {
cli::cli_inform(c("*" = "создание бэкапов баз данных..."))
purrr::walk(scheme_names, local_db_backup)
}
# перезаписываем файл # перезаписываем файл
if (!dir.exists("temp")) dir.create("temp") if (!dir.exists("temp")) dir.create("temp")
saveRDS(exist_hash, hash_file) saveRDS(exist_hash, hash_file)
} }
init_scheme = function(scheme_file) { init_scheme = function(scheme_file) {
options(box.path = here::here()) options(box.path = here::here())
@@ -80,9 +115,11 @@ init_scheme = function(scheme_file) {
modules/scheme_generator[scheme_R6] modules/scheme_generator[scheme_R6]
) )
if (!dir.exists("db")) dir.create("db") db_path <- fs::path(config::get("form_app_configure_path"), "db")
if (!dir.exists(db_path)) dir.create(db_path)
cli::cli_h1("Инициализация схемы") cli::cli_h1("Инициализация схемы")
schms <- purrr::map2( schms <- purrr::map2(
.x = scheme_file, .x = scheme_file,
.y = names(scheme_file), .y = names(scheme_file),
@@ -91,8 +128,15 @@ init_scheme = function(scheme_file) {
con <- db$make_db_connection(y) con <- db$make_db_connection(y)
on.exit(db$close_db_connection(con), add = TRUE) on.exit(db$close_db_connection(con), add = TRUE)
# новый объект
schm <- scheme_R6$new(x) schm <- scheme_R6$new(x)
# проверка схемы с существующей базой данных и инициализация таблиц
db$check_if_table_is_exist_and_init_if_not(schm, con) db$check_if_table_is_exist_and_init_if_not(schm, con)
# удаление орфанных записей
db$db_clean_orphans(schm = schm, con = con)
schm schm
} }
) )
@@ -102,13 +146,13 @@ init_scheme = function(scheme_file) {
names(schms), names(schms),
\(x) schms[[x]]$nested_tables_names \(x) schms[[x]]$nested_tables_names
) )
nested_tables_ids <- unlist(nested_tables_ids) nested_tables_ids <- unlist(nested_tables_ids)
tab <- table(nested_tables_ids) tab <- table(nested_tables_ids)
# если встречается хоть одно значение несколько раз - начать истошно кричать (могут возникнуть пробемы при вызове всплывающих окон в формах) # если встречается хоть одно значение несколько раз - начать истошно кричать (могут возникнуть пробемы при вызове всплывающих окон в формах)
if (!all(!tab > 1)) { if (!all(!tab > 1)) {
cli::cli_abort(c("В одной или нескольких схемах наименования вложенных форм совпадают:", paste("-", names(tab)[tab > 1]))) cli::cli_abort(c("В одной или нескольких схемах наименования вложенных форм совпадают:", paste("-", names(tab)[tab > 1])))
} }
saveRDS(schms, "scheme.rds") saveRDS(schms, "scheme.rds")

View File

@@ -1,14 +1,14 @@
#' @export #' @export
scheme_R6 <- R6::R6Class( scheme_R6 <- R6::R6Class(
"schemes_f", "schemes_generator",
public = list( public = list(
initialize = function(scheme_file_path = NULL) { initialize = function(scheme_file_path = NULL) {
private$scheme_file_path <- scheme_file_path private$scheme_file_path <- scheme_file_path
# make list of schemas # make list of schemes
private$schemes_list <- list() private$schemes_list <- list()
private$schemes_list[["main"]] <- private$load_scheme_from_xlsx("main") private$schemes_list[["main"]] <- private$load_scheme_from_xlsx("main")
@@ -18,6 +18,14 @@ scheme_R6 <- R6::R6Class(
dplyr::distinct(form_id) |> dplyr::distinct(form_id) |>
dplyr::pull(form_id) dplyr::pull(form_id)
# проверка на не пересечение с зарезервированными именами
check <- private$reserved_table_names %in% private$nested_forms_names
if (any(check)) cli::cli_abort(c("нельзя использовать данные имена вложенных таблиц:", paste("- ", private$reserved_table_names[check])))
# проверка на длину строк
check <- (nchar(private$nested_forms_names) > 31)
if (any(check)) cli::cli_abort(c("нельзя использовать имена длиной более 31 символа:", paste("- ", private$nested_forms_names[check])))
purrr::walk( purrr::walk(
.x = purrr::set_names(private$nested_forms_names), .x = purrr::set_names(private$nested_forms_names),
.f = \(nested_form_id) { .f = \(nested_form_id) {
@@ -32,6 +40,19 @@ scheme_R6 <- R6::R6Class(
} }
) )
# отдельно для тасков
private$schemes_list[["tasks"]] <- tibble::tribble(
~ form_id, ~form_type, ~form_label, ~form_description, ~choices,
"dummy", "text", "dummy", "dummy", NA,
"task_status", "select_one", "Статус задачи", NA, "active",
"task_status", "select_one", "Статус задачи", NA, "completed",
"task_status", "select_one", "Статус задачи", NA, "deleted",
"task_title", "text", "Название задачи", NA, NA,
"task_description", "text", "Описание задачи", "краткое описание", "3",
"task_due_date", "date", "Дата выполнения задачи", NA, NA,
) |>
dplyr::mutate(condition = NA)
# extract main key # extract main key
private$main_key_id <- self$get_key_id("main") private$main_key_id <- self$get_key_id("main")
@@ -67,11 +88,12 @@ scheme_R6 <- R6::R6Class(
# возврат схемы ------------------------------------ # возврат схемы ------------------------------------
## полностью ------- ## полностью -------
get_schema = function(table_name) { get_scheme = function(table_name) {
private$schemes_list[[table_name]] private$schemes_list[[table_name]]
}, },
## с полями имеющие значение ------- ## с полями имеющие значение -------
get_schema_with_values_forms = function(table_name) { get_scheme_with_values_forms = function(table_name) {
private$schemes_list[[table_name]] |> private$schemes_list[[table_name]] |>
dplyr::filter(!form_type %in% private$excluded_types) dplyr::filter(!form_type %in% private$excluded_types)
}, },
@@ -109,6 +131,7 @@ scheme_R6 <- R6::R6Class(
nested_forms_names = NA, nested_forms_names = NA,
bslib_rendered_ui = NA, bslib_rendered_ui = NA,
excluded_types = c("nested_forms", "description", "description_header"), excluded_types = c("nested_forms", "description", "description_header"),
reserved_table_names = c("meta", "log", "main", "tasks"),
load_scheme_from_xlsx = function(sheet_name) { load_scheme_from_xlsx = function(sheet_name) {
@@ -132,8 +155,15 @@ scheme_R6 <- R6::R6Class(
dplyr::pull(form_id) dplyr::pull(form_id)
if (length(duplicate_ids) > 0) { if (length(duplicate_ids) > 0) {
cli::cli_abort(c("В схеме для формы '{sheet_name}' содержатся повторяющиеся id:", paste("-", duplicate_ids))) cli::cli_abort(c("В схеме '{private$scheme_file_path}' для формы '{sheet_name}' содержатся повторяющиеся id:", paste("-", duplicate_ids)))
} }
# проверка на корректные id
input_names_with_dash <- unique(table$form_id)[grepl("-", unique(table$form_id))]
if (length(input_names_with_dash) > 0) {
cli::cli_abort(c("В схеме '{private$scheme_file_path}' в id форм содержатся `-`, может привести к некорректной последующей работой с базой данных", paste("-", input_names_with_dash)))
}
table table
} }
) )
@@ -144,7 +174,7 @@ scheme_R6 <- R6::R6Class(
# schm$get_forms_ids("main") # schm$get_forms_ids("main")
# schm$get_all_ids("main") # schm$get_all_ids("main")
# schm$get_schema("main") # schm$get_scheme("main")
# schm$get_id_type_list("allergo_anamnesis") # schm$get_id_type_list("allergo_anamnesis")

View File

@@ -135,7 +135,8 @@ render_forms = function(
form <- shiny::textAreaInput( form <- shiny::textAreaInput(
inputId = form_id, inputId = form_id,
label = label, label = label,
rows = 1 rows = 1,
resize = "none"
) )
} }
@@ -162,7 +163,7 @@ render_forms = function(
choices = choices, choices = choices,
selected = NULL, selected = NULL,
options = list( options = list(
create = FALSE, create = TRUE,
onInitialize = I('function() { this.setValue(""); }') onInitialize = I('function() { this.setValue(""); }')
) )
) )
@@ -177,7 +178,7 @@ render_forms = function(
selected = NULL, selected = NULL,
multiple = TRUE, multiple = TRUE,
options = list( options = list(
create = FALSE, create = TRUE,
onInitialize = I('function() { this.setValue(""); }') onInitialize = I('function() { this.setValue(""); }')
) )
) )
@@ -264,6 +265,15 @@ update_forms_with_data = function(
ns ns
) { ) {
options(box.path = here::here())
box::use(modules/data_manipulations[is_this_empty_value])
# print("-----------------")
# cli::cli_inform("form_id: {form_id} | form_type: {form_type}")
# print(value)
# print(typeof(value))
# print(is_this_empty_value(value))
filterd_line <- scheme |> filterd_line <- scheme |>
dplyr::filter(form_id == {{form_id}}) dplyr::filter(form_id == {{form_id}})
@@ -294,50 +304,58 @@ update_forms_with_data = function(
new_choices <- unique(c(old_choices, value)) new_choices <- unique(c(old_choices, value))
new_choices <- new_choices[!is.na(new_choices)] new_choices <- new_choices[!is.na(new_choices)]
shiny::updateSelectizeInput(inputId = form_id, selected = value, choices = new_choices) shiny::updateSelectizeInput(inputId = form_id, selected = value, choices = new_choices)
# shiny::updateSelectizeInput(inputId = form_id, selected = value)
} }
# select_multiple # select_multiple
# check if value is not NA and split by delimetr # check if value is not NA and split by delimetr
if (form_type == "select_multiple" && !is.na(value)) { if (form_type == "select_multiple") {
vars <- stringr::str_split_1(value, local_delimeter) if (is_this_empty_value(value)) {
shiny::updateSelectizeInput(inputId = form_id, selected = as.character(0))
} else {
vars <- stringr::str_split_1(value, local_delimeter)
# update choices # update choices
old_choices <- filterd_line$choices old_choices <- filterd_line$choices
new_choices <- unique(c(old_choices, vars)) new_choices <- unique(c(old_choices, vars))
new_choices <- new_choices[!is.na(new_choices)] new_choices <- new_choices[!is.na(new_choices)]
shiny::updateSelectizeInput(inputId = form_id, selected = vars, choices = new_choices)
shiny::updateSelectizeInput(inputId = form_id, selected = vars, choices = new_choices) }
# shiny::updateSelectizeInput(inputId = form_id, selected = vars)
}
# in other case fill with `character(0)` to proper reseting form
if (form_type == "select_multiple" && is.na(value)) {
shiny::updateSelectizeInput(inputId = form_id, selected = character(0))
} }
# radio buttons # radio buttons
if (form_type == "radio" && !is.na(value)) { if (form_type == "radio") {
shiny::updateRadioButtons(inputId = form_id, selected = value) if (is_this_empty_value(value)) {
} shiny::updateRadioButtons(inputId = form_id, selected = character(0))
if (form_type == "radio" && is.na(value)) { } else {
shiny::updateRadioButtons(inputId = form_id, selected = character(0)) # update choices
old_choices <- filterd_line$choices
new_choices <- unique(c(old_choices, value))
new_choices <- new_choices[!is.na(new_choices)]
shiny::updateRadioButtons(inputId = form_id, selected = value, choices = new_choices)
}
} }
# checkboxes # checkboxes
if (form_type == "checkbox" && !is.na(value)) { if (form_type == "checkbox") {
vars <- stringr::str_split_1(value, local_delimeter)
shiny::updateCheckboxGroupInput(inputId = form_id, selected = vars) if (is_this_empty_value(value)) {
} shiny::updateCheckboxGroupInput(inputId = form_id, selected = character(0))
if (form_type == "checkbox" && is.na(value)) { } else {
shiny::updateCheckboxGroupInput(inputId = form_id, selected = character(0))
vars <- stringr::str_split_1(value, local_delimeter)
# update choices
old_choices <- filterd_line$choices
new_choices <- unique(c(old_choices, vars))
new_choices <- new_choices[!is.na(new_choices)]
shiny::updateCheckboxGroupInput(inputId = form_id, selected = vars, choices = new_choices)
}
} }
# if (type == "inline_table") {
# message("EMPTY")
# }
} }
#' @export #' @export
@@ -361,7 +379,7 @@ clean_forms = function(
form_id = x_id, form_id = x_id,
form_type = x_type, form_type = x_type,
value = get_empty_data(x_type), value = get_empty_data(x_type),
scheme = schm$get_schema(table_name), scheme = schm$get_scheme(table_name),
ns = ns ns = ns
) )
} }

View File

@@ -318,6 +318,16 @@
"Repository": "CRAN", "Repository": "CRAN",
"Hash": "14eb0596f987c71535d07c3aff814742" "Hash": "14eb0596f987c71535d07c3aff814742"
}, },
"config": {
"Package": "config",
"Version": "0.3.2",
"Source": "Repository",
"Repository": "RSPM",
"Requirements": [
"yaml"
],
"Hash": "8b7222e9d9eb5178eea545c0c4d33fc2"
},
"cpp11": { "cpp11": {
"Package": "cpp11", "Package": "cpp11",
"Version": "0.5.1", "Version": "0.5.1",

BIN
test.xlsx Normal file

Binary file not shown.

View File

@@ -3,10 +3,11 @@
# SETUP AUTH ============================= # SETUP AUTH =============================
# Init DB using credentials data # Init DB using credentials data
credentials <- data.frame( credentials <- data.frame(
user = c("admin", "user"), user = c("admin", "user", "user2"),
password = c("admin", "user"), password = c("admin", "user", "user2"),
# password will automatically be hashed # password will automatically be hashed
admin = c(TRUE, FALSE), admin = c(TRUE, FALSE, FALSE),
scheme_access = c(NA, "all", "example_of_scheme"), # NA - none | all - all | string with seperate
stringsAsFactors = FALSE stringsAsFactors = FALSE
) )

BIN
www/favicon.ico Normal file

Binary file not shown.

After

Width:  |  Height:  |  Size: 295 KiB