From 208a388e53955d7838fcf34aab8c72cb0724bf18 Mon Sep 17 00:00:00 2001 From: gitadmin Date: Fri, 26 Dec 2025 01:53:51 +0300 Subject: [PATCH] =?UTF-8?q?[=D0=92=D0=9E=D0=9B=D0=9A]=20=D1=84=D0=BB=D0=B0?= =?UTF-8?q?=D0=B3=20=D0=B0=D0=B2=D1=82=D0=BE=D0=BF=D1=83=D0=B1=D0=BB=D0=B8?= =?UTF-8?q?=D0=BA=D0=B0=D1=86=D0=B8=D0=B8=20=D1=81=D0=BE=D0=B1=D1=8B=D1=82?= =?UTF-8?q?=D0=B8=D0=B9=20=D0=B8=20=D0=BA=D0=B0=D1=82=D0=B5=D0=B3=D0=BE?= =?UTF-8?q?=D1=80=D0=B8=D0=B9?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- volk_load.py | 21 ++++++++++++++------- 1 file changed, 14 insertions(+), 7 deletions(-) diff --git a/volk_load.py b/volk_load.py index 36f36cd..bb4109c 100644 --- a/volk_load.py +++ b/volk_load.py @@ -24,6 +24,7 @@ MDB_USER = os.getenv('MDB_USER') MDB_PW = os.getenv('MDB_PW') MDBASE = os.getenv('MDBASE') LOG_FILE = os.getenv('LOG_FILE') +AUTO_PUB_EVT = os.getenv('AUTO_PUB_EVT', 'false').lower() in ('true', '1', 'yes', 'on') def log_message(message, category="VOLK_loader"): """Функция для записи в лог-файл с повторными попытками при блокировке""" @@ -141,12 +142,15 @@ def load_categories(): if not existing: # Вставка новой записи + # Устанавливаем флаг публикации, если AUTO_PUB_EVT включен + marked_for_publication = 1 if AUTO_PUB_EVT else 0 cursor.execute( - "INSERT INTO categories (ID, TITLE, description) VALUES (%s, %s, %s)", - (category_id, title, None) + "INSERT INTO categories (ID, TITLE, description, marked_for_publication) VALUES (%s, %s, %s, %s)", + (category_id, title, None, marked_for_publication) ) inserted_count += 1 - log_message(f"Добавление: Категория {category_id}, Название: {title if title else '(пусто)'}") + pub_status = "для публикации" if AUTO_PUB_EVT else "не для публикации" + log_message(f"Добавление: Категория {category_id}, Название: {title if title else '(пусто)'}, Статус: {pub_status}") else: # Обновление существующей записи (всегда обновляем TITLE, даже если оно пустое) if existing['TITLE'] != title: @@ -445,13 +449,16 @@ def load_events_by_category(category_id): if not existing: # Вставка новой записи # Используем id из JSON для id_event, а для number используем автоинкремент + # Устанавливаем флаг публикации, если AUTO_PUB_EVT включен + marked_to_publication = 1 if AUTO_PUB_EVT else 0 cursor.execute( - """INSERT INTO events (id_event, number, unit_name, name, about, about_social_picture, authors) - VALUES (%s, %s, %s, %s, %s, %s, %s)""", - (id_event, current_number, unit_name, name, about, about_social_picture, authors) + """INSERT INTO events (id_event, number, unit_name, name, about, about_social_picture, authors, marked_to_publication) + VALUES (%s, %s, %s, %s, %s, %s, %s, %s)""", + (id_event, current_number, unit_name, name, about, about_social_picture, authors, marked_to_publication) ) inserted_count += 1 - log_message(f"Добавление: Событие '{name}', id_event: {id_event}, номер: {current_number}, категория: {category_id}") + pub_status = "для публикации" if AUTO_PUB_EVT else "не для публикации" + log_message(f"Добавление: Событие '{name}', id_event: {id_event}, номер: {current_number}, категория: {category_id}, Статус: {pub_status}") current_number += 1 else: # Обновление существующей записи