from flask import Flask, render_template_string, request, redirect, url_for, flash, jsonify import json import os import logging import threading import time from datetime import datetime from huggingface_hub import HfApi, hf_hub_download from huggingface_hub.utils import RepositoryNotFoundError, HfHubHTTPError from werkzeug.utils import secure_filename from dotenv import load_dotenv import requests import uuid import copy from math import ceil load_dotenv() app = Flask(__name__) app.secret_key = os.getenv("FLASK_SECRET_KEY", 'your_unique_secret_key_emir_shop_12345_no_login') DATA_FILE = 'data.json' SYNC_FILES = [DATA_FILE] REPO_ID = "Aleksmorshen/emirkuh" HF_TOKEN_WRITE = os.getenv("HF_TOKEN") HF_TOKEN_READ = os.getenv("HF_TOKEN_READ") CURRENCY_CODE = 'KGS' ADMIN_PRODUCTS_PER_PAGE = 25 DOWNLOAD_RETRIES = 3 DOWNLOAD_DELAY = 5 logging.basicConfig(level=logging.INFO, format='%(asctime)s - %(levelname)s - %(message)s') APP_DATA = {} data_lock = threading.Lock() translations = { 'ru': { 'site_name': 'emir', 'catalog_title': 'emir - Каталог', 'admin_title': 'Админ-панель - emir', 'order_title': 'Заказ №{order_id} - emir', 'all_categories': 'Все категории', 'all_suppliers': 'Все поставщики', 'search_placeholder': 'Поиск по названию или описанию...', 'no_products_yet': 'Товары пока не добавлены.', 'details': 'Подробнее', 'add_to_cart': 'В корзину', 'loading': 'Загрузка...', 'specify_quantity_color': 'Укажите количество и цвет', 'quantity': 'Количество:', 'color_variant': 'Цвет/Вариант:', 'confirm_add_to_cart': 'Добавить в корзину', 'your_cart': 'Ваша корзина', 'cart_empty': 'Ваша корзина пуста.', 'total': 'Итого:', 'clear_cart': 'Очистить корзину', 'formulate_order': 'Сформировать заказ', 'open_cart_aria': 'Открыть корзину', 'error_product_not_found': 'Ошибка: товар не найден.', 'error_invalid_quantity': 'Пожалуйста, укажите корректное количество (больше 0).', 'error_adding_product_not_found': 'Ошибка добавления: товар не найден.', 'product_added_to_cart': '{product_name} добавлен в корзину!', 'cart_item_color_prefix': ' (Цвет: ', 'cart_item_color_suffix': ')', 'remove_item_title': 'Удалить товар', 'confirm_clear_cart': 'Вы уверены, что хотите очистить корзину?', 'cart_empty_for_order': 'Корзина пуста! Добавьте товары перед формированием заказа.', 'formulating_order': 'Формируем заказ...', 'failed_to_create_order': 'Не удалось создать заказ', 'order_id_not_received': 'Не получен ID заказа от сервера.', 'error_generic': 'Ошибка: {error_message}', 'no_products_found_for_query': 'По вашему запросу товары не найдены.', 'product_detail_photo_alt': '{product_name} - фото {loop_index}', 'no_image_alt': 'Изображение отсутствует', 'category': 'Категория:', 'subcategory': 'Подкатегория:', 'supplier': 'Поставщик:', 'no_category': 'Без категории', 'no_subcategory': 'Без подкатегории', 'no_supplier': 'Без поставщика', 'price': 'Цена:', 'description': 'Описание:', 'description_absent': 'Описание отсутствует.', 'available_colors_variants': 'Доступные цвета/варианты:', 'order_page_title': 'Ваш Заказ №{order_id}', 'creation_date': 'Дата создания:', 'products_in_order': 'Товары в заказе', 'total_products_sum': 'Общая сумма товаров:', 'total_to_pay': 'ИТОГО К ОПЛАТЕ:', 'order_status': 'Статус заказа', 'anonymous_order_notice': 'Этот заказ был оформлен без входа в систему.', 'contact_whatsapp_notice': 'Пожалуйста, свяжитесь с нами по WhatsApp для подтверждения и уточнения деталей.', 'send_order_button': 'Отправить в WhatsApp', 'back_to_catalog': '← Вернуться в каталог', 'error_page_title': 'Ошибка', 'order_not_found_by_id': 'Заказ с таким ID не найден.', 'whatsapp_greeting': 'Здравствуйте! Хочу подтвердить свой заказ на emir:', 'whatsapp_product_inquiry': 'Здравствуйте! Хочу уточнить цену на товар: {product_name}', 'whatsapp_order_number': 'Номер заказа:', 'whatsapp_order_link': 'Ссылка на заказ:', 'whatsapp_contact_request': 'Пожалуйста, свяжитесь со мной для уточнения деталей оплаты и доставки.', 'whatsapp_request_price_calculation': 'Пожалуйста, рассчитайте стоимость заказа.', 'admin_panel_h1': 'Админ-панель emir', 'go_to_catalog': 'Перейти в каталог', 'sync_with_dc': 'Синхронизация с Датацентром', 'upload_db': 'Загрузить БД', 'download_db': 'Скачать БД', 'confirm_force_upload': 'Вы уверены, что хотите принудительно загрузить локальные данные на сервер? Это перезапишет данные на сервере.', 'confirm_force_download': 'Вы уверены, что хотите принудительно скачать данные с сервера? Это перезапишет ваши локальные файлы.', 'sync_info_text': 'Резервное копирование происходит автоматически каждые 30 минут, а также после каждого сохранения данных. Используйте эти кнопки для немедленной синхронизации.', 'manage_categories': 'Управление категориями', 'add_new_category': 'Добавить новую категорию', 'new_category_name_label': 'Название новой категории:', 'add_button': 'Добавить', 'existing_categories': 'Существующие категории:', 'confirm_delete_category': "Вы уверены, что хотите удалить категорию '{category_name}'? Все ее подкатегории и связанные товары будут помечены как 'Без категории'.", 'no_categories_yet': 'Категорий пока нет.', 'manage_subcategories': 'Управление подкатегориями', 'add_new_subcategory': 'Добавить новую подкатегорию', 'new_subcategory_name_label': 'Название новой подкатегории:', 'parent_category_label': 'Родительская категория:', 'select_parent_category': 'Выберите родительскую категорию', 'existing_subcategories': 'Существующие подкатегории:', 'confirm_delete_subcategory': "Вы уверены, что хотите удалить подкатегорию '{subcategory_name}'? Товары этой подкатегории будут помечены как 'Без подкатегории'.", 'no_subcategories_yet': 'Подкатегорий пока нет.', 'manage_suppliers': 'Управление поставщиками', 'add_new_supplier': 'Добавить нового поставщика', 'new_supplier_name_label': 'Название нового поставщика:', 'existing_suppliers': 'Существующие поставщики:', 'confirm_delete_supplier': "Вы уверены, что хотите удалить поставщика '{supplier_name}'? Товары этого поставщика будут помечены как 'Без поставщика'.", 'no_suppliers_yet': 'Поставщиков пока нет.', 'information_section_title': 'Информация', 'user_management_disabled_info': 'Управление пользователями отключено, так как сайт не требует входа.', 'anonymous_orders_whatsapp_info': 'Заказы создаются анонимно и должны быть подтверждены через WhatsApp.', 'manage_products': 'Управление товарами', 'add_new_product': 'Добавить новый товар', 'product_name_label': 'Название товара *:', 'product_price_kgs_label': 'Цена (KGS):', 'product_discount_percent_label': 'Скидка (%):', 'product_description_label': 'Описание:', 'product_category_label': 'Категория:', 'product_subcategory_label': 'Подкатегория:', 'product_supplier_label': 'Поставщик:', 'no_category_option': 'Без категории', 'no_subcategory_option': 'Без подкатегории', 'no_supplier_option': 'Без поставщика', 'select_category_first': 'Сначала выберите категорию', 'photos_label': 'Фотографии (до 10 шт.):', 'video_label': 'Видео (1 файл, .mp4, .webm):', 'colors_variants_label': 'Цвета/Варианты (оставьте пустым, если нет):', 'color_placeholder_example': 'Например: Синий', 'add_color_field_button': 'Добавить поле для цвета/варианта', 'in_stock_label': 'В наличии', 'top_product_label': 'Топ товар (показывать наверху)', 'on_order_label': 'На заказ', 'add_product_button': 'Добавить товар', 'product_list_title': 'Список товаров:', 'view_first_photo_title': 'Посмотреть первое фото', 'photo_alt': 'Фото', 'no_photo_alt': 'Нет фото', 'status_in_stock': 'В наличии', 'status_out_of_stock': 'Нет в наличии', 'status_on_order': 'На заказ', 'status_top_product': 'Топ', 'description_label_item': 'Описание:', 'description_not_available': 'Отсутствует', 'colors_variants_item_label': 'Цвета/Вар-ты:', 'colors_not_available': 'Нет', 'discount_label_item': 'Скидка:', 'discount_badge_text': 'Скидка {discount}%', 'total_photos_count': '(Всего фото: {count})', 'view_video_button': 'Посмотреть видео', 'edit_button': 'Редактировать', 'confirm_delete_product': "Вы уверены, что хотите удалить товар '{product_name}'?", 'delete_button': 'Удалить', 'editing_product_title': 'Редактирование: {product_name}', 'product_name_edit_label': 'Название *:', 'product_price_kgs_edit_label': 'Цена (KGS):', 'product_discount_percent_edit_label': 'Скидка (%):', 'product_description_edit_label': 'Описание:', 'product_category_edit_label': 'Категория:', 'product_subcategory_edit_label': 'Подкатегория:', 'product_supplier_edit_label': 'Поставщик:', 'replace_photos_label': 'Заменить фотографии (выберите новые файлы, до 10 шт.):', 'replace_video_label': 'Заменить видео (выберите новый файл):', 'current_photos_label': 'Текущие фото:', 'current_video_label': 'Текущее видео:', 'photo_alt_indexed': 'Фото {loop_index}', 'colors_variants_edit_label': 'Цвета/Варианты:', 'color_placeholder_generic': 'Например: Цвет', 'add_color_field_edit_button': 'Добавить поле для цвета', 'in_stock_edit_label': 'В наличии', 'top_product_edit_label': 'Топ товар', 'on_order_edit_label': 'На заказ', 'save_changes_button': 'Сохранить изменения', 'no_products_yet_admin': 'Товаров пока нет.', 'js_new_color_variant_placeholder': 'Новый цвет/вариант', 'flash_category_added_success': "Категория '{category_name}' успешно добавлена.", 'flash_category_name_empty': 'Название категории не может быть пустым.', 'flash_category_already_exists': "Категория '{category_name}' уже существует.", 'flash_category_delete_success': "Категория '{category_name}' удалена.", 'flash_category_delete_failed': "Не удалось удалить категорию '{category_name}'.", 'flash_subcategory_added_success': "Подкатегория '{subcategory_name}' успешно добавлена.", 'flash_subcategory_name_empty': 'Название подкатегодии не может быть пустым.', 'flash_parent_category_not_selected': 'Необходимо выбрать родительскую категорию.', 'flash_subcategory_already_exists': "Подкатегория '{subcategory_name}' уже существует в этой категории.", 'flash_subcategory_delete_success': "Подкатегория '{subcategory_name}' удалена.", 'flash_subcategory_delete_failed': "Не удалось удалить подкатегодию.", 'flash_supplier_added_success': "Поставщик '{supplier_name}' успешно добавлен.", 'flash_supplier_name_empty': 'Имя поставщика не может быть пустым.', 'flash_supplier_already_exists': "Поставщик '{supplier_name}' уже существует.", 'flash_supplier_delete_success': "Поставщик '{supplier_name}' удален.", 'flash_supplier_delete_failed': "Не удалось удалить поставщика '{supplier_name}'.", 'flash_product_name_price_required': 'Название товара обязательно.', 'flash_invalid_price_format': 'Неверный формат цены.', 'flash_invalid_discount_format': 'Неверный формат скидки (0-100).', 'flash_photo_limit_reached': 'Загружено только первые {photo_limit} фото.', 'flash_file_not_image_skipped': 'Файл {filename} не является изображением и был пропущен.', 'flash_file_not_video_skipped': 'Файл {filename} не является видео и был пропущен.', 'flash_photo_upload_error': 'Ошибка при загрузке фото {filename}.', 'flash_video_upload_error': 'Ошибка при загрузке видео {filename}.', 'flash_hf_token_write_not_set_files_not_uploaded': 'HF_TOKEN (write) не настроен. Файлы не были загружены.', 'flash_product_added_success': "Товар '{product_name}' успешно добавлен.", 'flash_edit_error_no_id': 'Ошибка редактирования: ID товара не передан.', 'flash_edit_error_not_found': "Ошибка редактирования: товар с ID '{product_id}' не найден.", 'flash_invalid_price_format_edit_warning': "Неверный формат цены для товара '{product_name}'. Цена не изменена.", 'flash_invalid_discount_format_edit_warning': "Неверный формат скидки для товара '{product_name}'. Скидка не изменена.", 'flash_photos_updated_success': 'Фотографии товара успешно обновлены.', 'flash_video_updated_success': 'Видео товара успешно обновлено.', 'flash_failed_to_upload_new_files_format_error': 'Не удалось загрузить новые файлы (возможно, неверный формат).', 'flash_hf_token_write_not_set_files_not_updated': 'HF_TOKEN (write) не настроен. Файлы не были обновлены.', 'flash_product_updated_success': "Товар '{product_name}' успешно обновлен.", 'flash_delete_error_no_id': 'Ошибка удаления: ID товара не передан.', 'flash_failed_delete_hf_files_warning': "Не удалось удалить файлы для товара '{product_name}' с сервера. Товар удален локально.", 'flash_hf_token_write_not_set_files_not_deleted_warning': "Товар '{product_name}' удален локально, но файлы не удалены с сервера (токен не задан).", 'flash_product_deleted_success': "Товар '{product_name}' удален.", 'flash_delete_error_not_found': "Ошибка удаления: товар с таким ID не найден.", 'flash_unknown_action': 'Неизвестное действие: {action}', 'flash_internal_error': "Произошла внутренняя ошибка при выполнении действия '{action}'. Подробности в логе сервера.", 'flash_data_uploaded_hf_success': 'Данные успешно загружены на Hugging Face.', 'flash_data_upload_hf_error': 'Ошибка при загрузке на Hugging Face: {error}', 'flash_data_downloaded_hf_success': 'Данные успешно скачаны с Hugging Face. Локальные файлы обновлены.', 'flash_data_download_hf_error_retries': 'Не удалось скачать данные с Hugging Face после нескольких попыток. Проверьте логи.', 'flash_data_download_hf_error': 'Ошибка при скачивании с Hugging Face: {error}', 'currency_name': 'Кыргызский сом', 'close_button_aria': 'Закрыть', 'admin_settings_title': 'Настройки магазина', 'admin_prices_visibility_label': 'Видимость цен на сайте:', 'admin_prices_enabled_checkbox_label': 'Цены включены', 'save_settings_button': 'Сохранить настройки', 'flash_settings_updated': 'Настройки успешно обновлены.', 'prices_disabled_notice_catalog': 'Цены временно не отображаются. Добавьте товары в корзину для запроса стоимости.', 'prices_disabled_notice_cart': 'Цены не отображаются. Стоимость будет рассчитана после оформления заказа.', 'request_price_calculation_button': 'Уточнить цену в WhatsApp', 'price_on_request': 'Цена по запросу', 'video_modal_title': 'Видео о товаре', 'save_all_changes_button': 'Сохранить все изменения ({count})', 'admin_search_placeholder': 'Поиск товаров по названию или описанию...', 'admin_search_button': 'Найти', 'admin_reset_search_button': 'Сбросить', 'admin_no_products_found_for_query': 'По вашему запросу товары не найдены.', } } def get_translation(key, **kwargs): translation_template = translations['ru'].get(key, f"MISSING_TRANSLATION: {key}") return translation_template.format(**kwargs) if kwargs else translation_template def download_db_from_hf(specific_file=None, retries=DOWNLOAD_RETRIES, delay=DOWNLOAD_DELAY): if not HF_TOKEN_READ and not HF_TOKEN_WRITE: logging.warning("HF_TOKEN_READ/HF_TOKEN_WRITE not set. Download might fail for private repos.") token_to_use = HF_TOKEN_READ if HF_TOKEN_READ else HF_TOKEN_WRITE files_to_download = [specific_file] if specific_file else SYNC_FILES logging.info(f"Attempting download for {files_to_download} from {REPO_ID}...") all_successful = True for file_name in files_to_download: success = False for attempt in range(retries + 1): try: logging.info(f"Downloading {file_name} (Attempt {attempt + 1}/{retries + 1})...") local_path = hf_hub_download( repo_id=REPO_ID, filename=file_name, repo_type="dataset", token=token_to_use, local_dir=".", local_dir_use_symlinks=False, force_download=True, resume_download=False ) logging.info(f"Successfully downloaded {file_name} to {local_path}.") success = True break except RepositoryNotFoundError: logging.error(f"Repository {REPO_ID} not found. Download cancelled for all files.") return False except HfHubHTTPError as e: if e.response.status_code == 404: logging.warning(f"File {file_name} not found in repo {REPO_ID} (404). Skipping this file.") if attempt == 0 and not os.path.exists(file_name): try: if file_name == DATA_FILE: with open(file_name, 'w', encoding='utf-8') as f: json.dump({'products': [], 'categories': [], 'subcategories': [], 'suppliers': [], 'orders': {}, 'config': {'prices_enabled': True}}, f) logging.info(f"Created empty local file {file_name} because it was not found on HF.") except Exception as create_e: logging.error(f"Failed to create empty local file {file_name}: {create_e}") success = False break else: logging.error(f"HTTP error downloading {file_name} (Attempt {attempt + 1}): {e}. Retrying in {delay}s...") except requests.exceptions.RequestException as e: logging.error(f"Network error downloading {file_name} (Attempt {attempt + 1}): {e}. Retrying in {delay}s...") except Exception as e: logging.error(f"Unexpected error downloading {file_name} (Attempt {attempt + 1}): {e}. Retrying in {delay}s...", exc_info=True) if attempt < retries: time.sleep(delay) if not success and file_name == DATA_FILE: logging.error(f"Failed to download critical file {file_name} after {retries + 1} attempts.") all_successful = False elif not success: logging.warning(f"Failed to download non-critical file {file_name} after {retries + 1} attempts.") logging.info(f"Download process finished. Overall success for critical files: {all_successful}") return all_successful def upload_db_to_hf(specific_file=None): if not HF_TOKEN_WRITE: logging.warning("HF_TOKEN (for writing) not set. Skipping upload to Hugging Face.") return try: api = HfApi() files_to_upload = [specific_file] if specific_file else SYNC_FILES logging.info(f"Starting upload of {files_to_upload} to HF repo {REPO_ID}...") for file_name in files_to_upload: if os.path.exists(file_name): try: api.upload_file( path_or_fileobj=file_name, path_in_repo=file_name, repo_id=REPO_ID, repo_type="dataset", token=HF_TOKEN_WRITE, commit_message=f"Sync {file_name} {datetime.now().strftime('%Y-%m-%d %H:%M:%S')}" ) logging.info(f"File {file_name} successfully uploaded to Hugging Face.") except Exception as e: logging.error(f"Error uploading file {file_name} to Hugging Face: {e}") else: logging.warning(f"File {file_name} not found locally, skipping upload.") logging.info("Finished uploading files to HF.") except Exception as e: logging.error(f"General error during Hugging Face upload initialization or process: {e}", exc_info=True) def periodic_backup(): backup_interval = 1800 logging.info(f"Setting up periodic backup every {backup_interval} seconds.") while True: time.sleep(backup_interval) logging.info("Starting periodic backup...") upload_db_to_hf() logging.info("Periodic backup finished.") def _save_data_background(data_to_save): try: if '_cache' in data_to_save: data_to_save.pop('_cache') with open(DATA_FILE, 'w', encoding='utf-8') as file: json.dump(data_to_save, file, ensure_ascii=False, indent=4) logging.info(f"Data successfully saved to {DATA_FILE} in background.") upload_db_to_hf(specific_file=DATA_FILE) except Exception as e: logging.error(f"Error saving data in background thread: {e}", exc_info=True) def update_and_save_data(new_data): global APP_DATA with data_lock: APP_DATA = new_data data_copy_for_saving = copy.deepcopy(APP_DATA) save_thread = threading.Thread(target=_save_data_background, args=(data_copy_for_saving,)) save_thread.start() def get_data(): with data_lock: return copy.deepcopy(APP_DATA) def run_migrations(data): migration_performed = False for product in data.get('products', []): if 'id' not in product or not product.get('id'): product['id'] = str(uuid.uuid4()) migration_performed = True if data.get('categories') and all(isinstance(c, str) for c in data['categories']): logging.info("Running migration: Converting categories to object structure.") old_categories = data['categories'] new_categories = [] new_subcategories = [] for cat_name in old_categories: if cat_name == 'Без категории': continue new_cat_id = str(uuid.uuid4()) new_categories.append({'id': new_cat_id, 'name': cat_name}) new_subcat_id = str(uuid.uuid4()) new_subcategories.append({'id': new_subcat_id, 'name': cat_name, 'parent_id': new_cat_id}) for p in data['products']: if p.get('category') == cat_name: p['subcategory_id'] = new_subcat_id p.pop('category', None) data['categories'] = new_categories data['subcategories'] = data.get('subcategories', []) + new_subcategories migration_performed = True for p in data['products']: if 'category' in p and 'subcategory_id' in p: del p['category'] migration_performed = True for cat in data.get('categories', []): if 'id' not in cat or not cat.get('id'): cat['id'] = str(uuid.uuid4()) migration_performed = True for subcat in data.get('subcategories', []): if 'id' not in subcat or not subcat.get('id'): subcat['id'] = str(uuid.uuid4()) migration_performed = True subcat.setdefault('parent_id', None) if migration_performed: logging.info("Data migration complete.") else: logging.info("No data migration needed.") return data, migration_performed def initialize_data(): default_data = {'products': [], 'categories': [], 'subcategories': [], 'suppliers': [], 'orders': {}, 'config': {'prices_enabled': True}} data_loaded = False try: with open(DATA_FILE, 'r', encoding='utf-8') as file: data = json.load(file) logging.info(f"Local data loaded successfully from {DATA_FILE}") data_loaded = True except (FileNotFoundError, json.JSONDecodeError): logging.warning(f"Local file {DATA_FILE} not found or corrupt. Attempting download from HF.") if not data_loaded: if download_db_from_hf(specific_file=DATA_FILE): try: with open(DATA_FILE, 'r', encoding='utf-8') as file: data = json.load(file) logging.info(f"Data loaded successfully from {DATA_FILE} after download.") except (FileNotFoundError, json.JSONDecodeError) as e: logging.error(f"Error reading or decoding downloaded {DATA_FILE}: {e}. Using default.") data = default_data else: logging.error(f"Failed to download {DATA_FILE} from HF. Using empty default data structure.") data = default_data if not os.path.exists(DATA_FILE): try: with open(DATA_FILE, 'w', encoding='utf-8') as f: json.dump(default_data, f) logging.info(f"Created empty local file {DATA_FILE} after failed download.") except Exception as create_e: logging.error(f"Failed to create empty local file {DATA_FILE}: {create_e}") if not isinstance(data, dict): logging.error(f"Loaded data is not a dictionary. Resetting to default.") data = default_data data.setdefault('products', []) data.setdefault('categories', []) data.setdefault('subcategories', []) data.setdefault('suppliers', []) data.setdefault('orders', {}) data.setdefault('config', {'prices_enabled': True}) data['config'].setdefault('prices_enabled', True) if 'usd_to_kgs_rate' in data['config']: del data['config']['usd_to_kgs_rate'] if 'usd_to_uzs_rate' in data['config']: del data['config']['usd_to_uzs_rate'] for prod in data.get('products', []): prod.setdefault('supplier', 'Без поставщика') prod.setdefault('on_order', False) if 'price_usd' in prod: prod['price_kgs'] = float(prod.pop('price_usd', 0.0)) elif 'price' in prod: try: prod['price_kgs'] = float(prod.pop('price')) except (ValueError, TypeError): prod['price_kgs'] = 0.0 prod.setdefault('price_kgs', 0.0) prod.setdefault('discount_percent', 0) try: prod['discount_percent'] = int(prod['discount_percent']) if not (0 <= prod['discount_percent'] <= 100): prod['discount_percent'] = 0 except (ValueError, TypeError): prod['discount_percent'] = 0 if 'video' in prod and 'video_filename' not in prod: prod['video_filename'] = prod.pop('video') data, migration_was_performed = run_migrations(data) categories_by_id = {c['id']: c for c in data.get('categories', [])} subcategories_by_id = {s['id']: s for s in data.get('subcategories', [])} data['_cache'] = { 'categories_by_id': categories_by_id, 'subcategories_by_id': subcategories_by_id } global APP_DATA with data_lock: APP_DATA = data logging.info("Initial data loaded and cached in memory.") if migration_was_performed: logging.info("Saving data after migration...") update_and_save_data(data) def get_full_product_info(product, data): info = product.copy() cache = data.get('_cache', {}) categories_by_id = cache.get('categories_by_id', {}) subcategories_by_id = cache.get('subcategories_by_id', {}) category_id_resolved = None category_name = get_translation('no_category') subcategory_name = get_translation('no_subcategory') subcategory_id = product.get('subcategory_id') if subcategory_id and subcategory_id in subcategories_by_id: subcat = subcategories_by_id[subcategory_id] subcategory_name = subcat['name'] category_id_resolved = subcat.get('parent_id') if category_id_resolved and category_id_resolved in categories_by_id: cat = categories_by_id[category_id_resolved] category_name = cat['name'] info['category_name'] = category_name info['subcategory_name'] = subcategory_name info['supplier_name'] = product.get('supplier', get_translation('no_supplier')) info['category_id'] = category_id_resolved return info @app.context_processor def inject_global_vars(): lang_translations = translations['ru'] data = get_data() app_config = data.get('config', {'prices_enabled': True}) js_trans_keys = [ 'error_product_not_found', 'error_invalid_quantity', 'error_adding_product_not_found', 'product_added_to_cart', 'cart_item_color_prefix', 'cart_item_color_suffix', 'remove_item_title', 'confirm_clear_cart', 'cart_empty_for_order', 'formulating_order', 'failed_to_create_order', 'order_id_not_received', 'error_generic', 'no_products_found_for_query', 'cart_empty', 'loading', 'no_products_yet', 'js_new_color_variant_placeholder', 'prices_disabled_notice_cart', 'price_on_request', 'save_all_changes_button', 'select_category_first', 'no_subcategory_option' ] js_translations_dict = {key: lang_translations.get(key, key) for key in js_trans_keys} return dict( get_translation=get_translation, js_translations=js_translations_dict, app_config=app_config ) CATALOG_TEMPLATE = ''' {{ get_translation('catalog_title') }}

{{ get_translation('site_name') }}

{% if not app_config.prices_enabled %}
{{ get_translation('prices_disabled_notice_catalog') }}
{% endif %}

{{ get_translation('supplier') }}

{% for supplier_name in suppliers %} {% endfor %}

{{ get_translation('category') }}

{% for category in categories %}
{{ category.name }} {% if category.subcategories|length > 0 %} {% endif %}
{% for subcategory in category.subcategories %} {% endfor %}
{% endfor %}
{% for product in products %}
{% if product.get('on_order', False) %}
{{ get_translation('status_on_order') }}
{% elif not product.get('in_stock', True) %}
{{ get_translation('status_out_of_stock') }}
{% endif %} {% if product.get('is_top', False) %} {{ get_translation('status_top_product') }} {% endif %}
{% if product.get('photos') and product['photos']|length > 0 %} {{ product['name'] }} {% else %} {{ get_translation('no_image_alt') }} {% endif %}

{{ product['name'] }}

{% set discount = product.get('discount_percent', 0) %} {% set original_price_kgs = product.price_kgs %} {% if app_config.prices_enabled %} {% if discount > 0 %} {% set discounted_price_kgs = original_price_kgs * (100 - discount) / 100 %} {{ "%.2f"|format(original_price_kgs) }} {{ currency_code }}
{{ "%.2f"|format(discounted_price_kgs) }} {{ currency_code }} {{ get_translation('discount_badge_text', discount=discount) }} {% else %} {% if original_price_kgs > 0 %} {{ "%.2f"|format(original_price_kgs) }} {{ currency_code }} {% else %}
{{ get_translation('price_on_request') }}
{% endif %} {% endif %} {% else %}
{{ get_translation('price_on_request') }}
{% endif %}
{% if product.get('video_filename') %} {% endif %} {% if app_config.prices_enabled %} {% else %} {% endif %}
{% endfor %} {% if not products %}

{{ get_translation('no_products_yet') }}

{% endif %}
''' PRODUCT_DETAIL_TEMPLATE = '''

{{ product_info['name'] }}

{% if product_info.get('photos') and product_info['photos']|length > 0 %} {% for photo in product_info['photos'] %}
{{ get_translation('product_detail_photo_alt', product_name=product_info['name'], loop_index=loop.index) }}
{% endfor %} {% else %}
{{ get_translation('no_image_alt') }}
{% endif %}
{% if product_info.get('photos') and product_info['photos']|length > 1 %}
{% endif %}
{% if product_info.get('video_filename') %}

{{ get_translation('video_modal_title') }}

{% endif %}

{{ get_translation('supplier') }}: {{ product_info.supplier_name }}

{{ get_translation('category') }}: {{ product_info.category_name }}

{{ get_translation('subcategory') }}: {{ product_info.subcategory_name }}

{% set discount = product_info.get('discount_percent', 0) %} {% set original_price_kgs = product_info.price_kgs %} {% if app_config.prices_enabled %}
{{ get_translation('price') }} {% if discount > 0 %} {% set discounted_price_kgs = original_price_kgs * (100 - discount) / 100 %} {{ "%.2f"|format(discounted_price_kgs) }} {{ currency_code }} {{ "%.2f"|format(original_price_kgs) }} {{ currency_code }} {% else %} {% if original_price_kgs > 0 %} {{ "%.2f"|format(original_price_kgs) }} {{ currency_code }} {% else %} {{ get_translation('price_on_request') }} {% endif %} {% endif %}
{% else %}

{{ get_translation('price') }}: {{ get_translation('price_on_request') }}

{% endif %}

{{ get_translation('description') }}:
{{ product_info.get('description', get_translation('description_absent'))|replace('\\n', '
')|safe }}

{% set colors = product_info.get('colors', []) %} {% if colors and colors|select('ne', '')|list|length > 0 %}

{{ get_translation('available_colors_variants') }}: {{ colors|select('ne', '')|join(', ') }}

{% endif %}
''' ORDER_TEMPLATE = ''' {{ get_translation('order_title', order_id=order.id if order else 'N/A') }}
{% if order %}

{{ get_translation('order_page_title', order_id=order.id) }}

{{ get_translation('creation_date') }} {{ order.created_at }}

{{ get_translation('products_in_order') }}

{% for item in order.cart %}
{{ item.name }}
{{ item.name }} {% if item.color != 'N/A' %}({{ item.color }}){% endif %} {% if order.prices_were_enabled_at_order and item.price_kgs_at_order > 0 %} {{ "%.2f"|format(item.price_kgs_at_order) }} {{ currency_code }} × {{ item.quantity }} {% else %} {{ get_translation('quantity') }} {{ item.quantity }} {% endif %}
{% if order.prices_were_enabled_at_order and item.price_kgs_at_order > 0 %}
{{ "%.2f"|format(item.price_kgs_at_order * item.quantity) }} {{ currency_code }}
{% else %}
{{ get_translation('price_on_request') }}
{% endif %}
{% endfor %}
{% if order.prices_were_enabled_at_order and order.total_price_kgs > 0 %}

{{ get_translation('total_products_sum') }} {{ "%.2f"|format(order.total_price_kgs) }} {{ currency_code }}

{% else %}

{{ get_translation('prices_disabled_notice_cart') }}

{% endif %}

{{ get_translation('order_status') }}

{{ get_translation('anonymous_order_notice') }}

{{ get_translation('contact_whatsapp_notice') }}

{{ get_translation('back_to_catalog') }} {% else %}

{{ get_translation('error_page_title') }}

{{ get_translation('order_not_found_by_id') }}

{{ get_translation('back_to_catalog') }} {% endif %}
''' ADMIN_TEMPLATE = ''' {{ get_translation('admin_title') }}

{{ get_translation('admin_panel_h1') }}

{{ get_translation('go_to_catalog') }}
{% with messages = get_flashed_messages(with_categories=true) %} {% if messages %} {% for category, message in messages %}
{{ message }}
{% endfor %} {% endif %} {% endwith %}

{{ get_translation('admin_settings_title') }}

{{ get_translation('sync_with_dc') }}

{{ get_translation('sync_info_text') }}

{{ get_translation('manage_categories') }}

{{ get_translation('add_new_category') }}

{{ get_translation('existing_categories') }}

{% if categories %}
{% for category in categories %}
{{ category.name }}
{% endfor %}
{% else %}

{{ get_translation('no_categories_yet') }}

{% endif %}

{{ get_translation('manage_subcategories') }}

{{ get_translation('add_new_subcategory') }}

{{ get_translation('existing_subcategories') }}

{% if subcategories %}
{% for subcategory in subcategories %}
{{ subcategory.name }} ({{ subcategory.parent_name }})
{% endfor %}
{% else %}

{{ get_translation('no_subcategories_yet') }}

{% endif %}

{{ get_translation('manage_suppliers') }}

{{ get_translation('add_new_supplier') }}

{{ get_translation('existing_suppliers') }}

{% if suppliers %}
{% for supplier_name in suppliers %}
{{ supplier_name }}
{% endfor %}
{% else %}

{{ get_translation('no_suppliers_yet') }}

{% endif %}

{{ get_translation('manage_products') }}

{{ get_translation('add_new_product') }}


{{ get_translation('product_list_title') }}

{% if search_query %} {{ get_translation('admin_reset_search_button') }} {% endif %}
{% if products_with_info %}
{% for product_info in products_with_info %}
{% if product_info.get('photos') %} {{ get_translation('photo_alt') }} {% else %} {{ get_translation('no_photo_alt') }} {% endif %}

{{ product_info['name'] }} {% if product_info.get('in_stock', True) %} {{ get_translation('status_in_stock') }} {% elif product_info.get('on_order', False) %} {{ get_translation('status_on_order') }} {% else %} {{ get_translation('status_out_of_stock') }} {% endif %} {% if product_info.get('is_top', False) %} {{ get_translation('status_top_product') }} {% endif %}

{{ get_translation('supplier') }}: {{ product_info.supplier_name }}

{{ get_translation('category') }}: {{ product_info.category_name }}

{{ get_translation('subcategory') }}: {{ product_info.subcategory_name }}

{{ get_translation('price') }}: {% if product_info.price_kgs > 0 %} {{ "%.2f"|format(product_info.price_kgs) }} {{ currency_code }} {% else %} {{ get_translation('price_on_request') }} {% endif %}

{% if product_info.get('discount_percent', 0) > 0 %}

{{ get_translation('discount_label_item') }} {{ product_info.discount_percent }}%

{% endif %}

{{ get_translation('description_label_item') }}: {{ product_info.get('description', get_translation('description_not_available'))[:150] }}{% if product_info.get('description', '')|length > 150 %}...{% endif %}

{{ get_translation('editing_product_title', product_name=product_info['name']) }}

{% if product_info.get('photos') %}

{{ get_translation('current_photos_label') }}

{% for photo in product_info['photos'] %} {{ get_translation('photo_alt_indexed', loop_index=loop.index) }} {% endfor %}
{% endif %} {% if product_info.get('video_filename') %}

{{ get_translation('current_video_label') }}

{% endif %}
{% set current_colors = product_info.get('colors', []) %} {% if current_colors and current_colors|select('ne', '')|list|length > 0 %} {% for color in current_colors %} {% if color.strip() %}
{% endif %} {% endfor %} {% else %}
{% endif %}


{% endfor %}
{% else %} {% if search_query %}

{{ get_translation('admin_no_products_found_for_query') }}

{% else %}

{{ get_translation('no_products_yet_admin') }}

{% endif %} {% endif %} {% if total_pages > 1 %}
{% if current_page > 1 %} « Назад {% endif %} Страница {{ current_page }} из {{ total_pages }} {% if current_page < total_pages %} Вперед » {% endif %}
{% endif %}
''' @app.route('/') def catalog(): data = get_data() all_products_raw = data.get('products', []) categories_raw = data.get('categories', []) subcategories_raw = data.get('subcategories', []) suppliers_orig = sorted(list(set(p['supplier'] for p in all_products_raw if 'supplier' in p))) app_config = data.get('config', {'prices_enabled': True}) cache = data.get('_cache', {}) subcategories_by_id = cache.get('subcategories_by_id', {}) categories_for_template = [] for cat in categories_raw: cat_copy = cat.copy() cat_copy['subcategories'] = sorted([sub for sub in subcategories_raw if sub.get('parent_id') == cat['id']], key=lambda x: x['name']) categories_for_template.append(cat_copy) categories_for_template.sort(key=lambda x: x['name']) products_enriched = [] for prod in all_products_raw: enriched_prod = get_full_product_info(prod, data) products_enriched.append(enriched_prod) products_to_display = [p for p in products_enriched if p.get('in_stock', True) or p.get('on_order', False)] products_sorted = sorted(products_to_display, key=lambda p: (not p.get('is_top', False), p.get('name', '').lower())) return render_template_string( CATALOG_TEMPLATE, products=products_sorted, categories=categories_for_template, suppliers=suppliers_orig, repo_id=REPO_ID, currency_code=CURRENCY_CODE, app_config=app_config ) @app.route('/product/') def product_detail(index): data = get_data() all_products = data.get('products', []) app_config = data.get('config', {'prices_enabled': True}) products_to_display = [p for p in all_products if p.get('in_stock', True) or p.get('on_order', False)] products_sorted = sorted(products_to_display, key=lambda p: (not p.get('is_top', False), p.get('name', '').lower())) try: product = products_sorted[index] product_info = get_full_product_info(product, data) except IndexError: logging.warning(f"Attempted access to non-existent or out-of-stock product with index {index}") return get_translation('error_product_not_found'), 404 return render_template_string( PRODUCT_DETAIL_TEMPLATE, product_info=product_info, repo_id=REPO_ID, currency_code=CURRENCY_CODE, app_config=app_config ) @app.route('/create_order', methods=['POST']) def create_order(): order_data = request.get_json() current_data_full = get_data() app_config = current_data_full.get('config', {'prices_enabled': True}) prices_currently_enabled = app_config.get('prices_enabled', True) if not order_data or 'cart' not in order_data or not order_data['cart']: logging.warning("Create order request missing cart data or cart is empty.") return jsonify({"error": get_translation('cart_empty_for_order')}), 400 cart_items = order_data['cart'] total_price_kgs = 0 processed_cart = [] for item in cart_items: if not all(k in item for k in ('name', 'price_kgs', 'quantity')): logging.error(f"Invalid cart item structure received: {item}") return jsonify({"error": "Invalid cart item format."}), 400 try: price_kgs_in_cart = float(item['price_kgs']) original_price_kgs = float(item.get('original_price_kgs', price_kgs_in_cart)) quantity = int(item['quantity']) if quantity <= 0: raise ValueError("Invalid quantity") # If prices are enabled OR the price is positive, calculate total if prices_currently_enabled and price_kgs_in_cart > 0: total_price_kgs += price_kgs_in_cart * quantity processed_cart.append({ "name": item['name'], "price_kgs_at_order": round(price_kgs_in_cart, 2), "original_price_kgs_at_order": round(original_price_kgs, 2), "discount_percent_at_order": int(item.get('discount_percent', 0)), "quantity": quantity, "color": item.get('color', 'N/A'), "photo": item.get('photo'), "photo_url": f"https://huggingface.co/datasets/{REPO_ID}/resolve/main/photos/{item['photo']}" if item.get('photo') else "https://via.placeholder.com/60x60.png?text=N%2FA" }) except (ValueError, TypeError) as e: logging.error(f"Invalid price/quantity in cart item: {item}. Error: {e}") return jsonify({"error": "Invalid price or quantity in item."}), 400 order_id = f"{datetime.now().strftime('%Y%m%d%H%M%S')}-{uuid.uuid4().hex[:6]}" order_timestamp = datetime.now().strftime('%Y-%m-%d %H:%M:%S') new_order = { "id": order_id, "created_at": order_timestamp, "cart": processed_cart, "total_price_kgs": round(total_price_kgs, 2) if prices_currently_enabled else 0, "prices_were_enabled_at_order": prices_currently_enabled, "user_info": None, "status": "new" } try: data = get_data() if 'orders' not in data or not isinstance(data.get('orders'), dict): data['orders'] = {} data['orders'][order_id] = new_order update_and_save_data(data) logging.info(f"Order {order_id} created successfully. Prices enabled at creation: {prices_currently_enabled}") return jsonify({"order_id": order_id}), 201 except Exception as e: logging.error(f"Failed to save order {order_id}: {e}", exc_info=True) return jsonify({"error": "Server error while saving order."}), 500 @app.route('/order/') def view_order(order_id): data = get_data() order = data.get('orders', {}).get(order_id) app_config = data.get('config', {'prices_enabled': True}) if order: logging.info(f"Displaying order {order_id}") else: logging.warning(f"Order {order_id} not found.") return render_template_string(ORDER_TEMPLATE, order=order, repo_id=REPO_ID, currency_code=CURRENCY_CODE, app_config=app_config) @app.route('/admin') def admin(): page = request.args.get('page', 1, type=int) search_query = request.args.get('q', '').strip() data = get_data() all_products = data.get('products', []) categories = sorted(data.get('categories', []), key=lambda c: c['name']) subcategories_raw = data.get('subcategories', []) suppliers = sorted(data.get('suppliers', [])) current_app_config = data.get('config', {'prices_enabled': True}) cache = data.get('_cache', {}) categories_by_id = cache.get('categories_by_id', {}) all_products_with_info = [] for p in sorted(all_products, key=lambda p: p.get('name', '').lower()): full_info = get_full_product_info(p, data) all_products_with_info.append(full_info) subcategories_with_parent = [] for subcat in sorted(subcategories_raw, key=lambda s: s['name']): subcat_info = subcat.copy() parent_cat = categories_by_id.get(subcat.get('parent_id')) subcat_info['parent_name'] = parent_cat['name'] if parent_cat else 'N/A' subcategories_with_parent.append(subcat_info) filtered_products = all_products_with_info if search_query: filtered_products = [ p for p in all_products_with_info if search_query.lower() in p.get('name', '').lower() or \ search_query.lower() in p.get('description', '').lower() ] total_products = len(filtered_products) total_pages = ceil(total_products / ADMIN_PRODUCTS_PER_PAGE) start_index = (page - 1) * ADMIN_PRODUCTS_PER_PAGE end_index = start_index + ADMIN_PRODUCTS_PER_PAGE paginated_products = filtered_products[start_index:end_index] return render_template_string( ADMIN_TEMPLATE, products_with_info=paginated_products, categories=categories, subcategories=subcategories_with_parent, suppliers=suppliers, repo_id=REPO_ID, currency_code=CURRENCY_CODE, app_config=current_app_config, current_page=page, total_pages=total_pages, search_query=search_query ) @app.route('/api/subcategories/') def api_get_subcategories(category_id): data = get_data() subcategories = [ sub for sub in data.get('subcategories', []) if sub.get('parent_id') == category_id ] return jsonify(sorted(subcategories, key=lambda s: s['name'])) @app.route('/admin_api', methods=['POST']) def admin_api(): data = get_data() products = data.get('products', []) categories = data.get('categories', []) suppliers = data.get('suppliers', []) action = request.form.get('action') logging.info(f"Admin API action received: {action}") try: if action == 'add_product': name = request.form.get('name', '').strip() if not name: return jsonify({'error': get_translation('flash_product_name_price_required')}), 400 price_kgs_str = request.form.get('price_kgs', '0').replace(',', '.') if not price_kgs_str.strip(): price_kgs_str = '0' try: price_kgs = round(float(price_kgs_str), 2) if price_kgs < 0: price_kgs = 0 except ValueError: return jsonify({'error': get_translation('flash_invalid_price_format')}), 400 discount_percent_str = request.form.get('discount_percent', '0') try: discount_percent = int(discount_percent_str) if not (0 <= discount_percent <= 100): discount_percent = 0 except ValueError: discount_percent = 0 description = request.form.get('description', '').strip() subcategory_id = request.form.get('subcategory_id') or None supplier = request.form.get('supplier') colors = [c.strip() for c in request.form.getlist('colors') if c.strip()] in_stock = 'in_stock' in request.form on_order = 'on_order' in request.form is_top = 'is_top' in request.form if in_stock and on_order: # Ensure mutual exclusion on_order = False photos_list = [] video_filename = None photos_files = request.files.getlist('photos') video_file = request.files.get('video') if HF_TOKEN_WRITE: uploads_dir = 'uploads_temp' os.makedirs(uploads_dir, exist_ok=True) api = HfApi() photo_limit = 10 uploaded_count = 0 for photo_idx, photo in enumerate(photos_files): if uploaded_count >= photo_limit: break if photo and photo.filename: ext = os.path.splitext(photo.filename)[1].lower() if ext not in ['.jpg', '.jpeg', '.png', '.gif', '.webp']: continue safe_name = secure_filename(name.replace(' ', '_'))[:50] p_filename = f"{safe_name}_photo_{datetime.now().strftime('%Y%m%d%H%M%S%f')}_{photo_idx}{ext}" temp_path = os.path.join(uploads_dir, p_filename) photo.save(temp_path) api.upload_file(path_or_fileobj=temp_path, path_in_repo=f"photos/{p_filename}", repo_id=REPO_ID, repo_type="dataset", token=HF_TOKEN_WRITE) photos_list.append(p_filename) os.remove(temp_path) uploaded_count += 1 if video_file and video_file.filename: ext = os.path.splitext(video_file.filename)[1].lower() if ext in ['.mp4', '.webm']: safe_name = secure_filename(name.replace(' ', '_'))[:50] v_filename = f"{safe_name}_video_{datetime.now().strftime('%Y%m%d%H%M%S%f')}{ext}" temp_path = os.path.join(uploads_dir, v_filename) video_file.save(temp_path) api.upload_file(path_or_fileobj=temp_path, path_in_repo=f"videos/{v_filename}", repo_id=REPO_ID, repo_type="dataset", token=HF_TOKEN_WRITE) video_filename = v_filename os.remove(temp_path) try: if os.path.exists(uploads_dir) and not os.listdir(uploads_dir): os.rmdir(uploads_dir) except OSError: pass new_product = { 'id': str(uuid.uuid4()), 'name': name, 'price_kgs': price_kgs, 'discount_percent': discount_percent, 'description': description, 'subcategory_id': subcategory_id, 'supplier': supplier if supplier in suppliers or supplier == 'Без поставщика' else 'Без поставщика', 'photos': photos_list, 'video_filename': video_filename, 'colors': colors, 'in_stock': in_stock, 'on_order': on_order, 'is_top': is_top } products.append(new_product) data['products'] = products update_and_save_data(data) return jsonify({'success': True, 'message': get_translation('flash_product_added_success', product_name=name)}) elif action == 'edit_product': product_id = request.form.get('product_id') if not product_id: return jsonify({'error': get_translation('flash_edit_error_no_id')}), 400 product_to_edit = next((p for p in products if p.get('id') == product_id), None) if not product_to_edit: return jsonify({'error': get_translation('flash_edit_error_not_found', product_id=product_id)}), 404 product_to_edit['name'] = request.form.get('name', product_to_edit['name']).strip() price_kgs_str = request.form.get('price_kgs') if price_kgs_str is not None: price_kgs_str = price_kgs_str.replace(',', '.') if not price_kgs_str.strip(): price_kgs_str = '0' try: price_kgs = round(float(price_kgs_str), 2) if price_kgs < 0: price_kgs = 0 product_to_edit['price_kgs'] = price_kgs except ValueError: logging.warning(get_translation('flash_invalid_price_format_edit_warning', product_name=product_to_edit['name'])) discount_percent_str = request.form.get('discount_percent', str(product_to_edit.get('discount_percent',0))) try: discount_percent = int(discount_percent_str) if not (0 <= discount_percent <= 100): discount_percent = product_to_edit.get('discount_percent', 0) product_to_edit['discount_percent'] = discount_percent except ValueError: pass product_to_edit['description'] = request.form.get('description', product_to_edit.get('description', '')).strip() product_to_edit['subcategory_id'] = request.form.get('subcategory_id') or None supplier = request.form.get('supplier') product_to_edit['supplier'] = supplier if supplier in suppliers or supplier == 'Без поставщика' else 'Без поставщика' product_to_edit['colors'] = [c.strip() for c in request.form.getlist('colors') if c.strip()] in_stock_new = 'in_stock' in request.form on_order_new = 'on_order' in request.form if in_stock_new and on_order_new: product_to_edit['in_stock'] = True product_to_edit['on_order'] = False else: product_to_edit['in_stock'] = in_stock_new product_to_edit['on_order'] = on_order_new product_to_edit['is_top'] = 'is_top' in request.form photos_files = request.files.getlist('photos') video_file = request.files.get('video') if photos_files and any(f.filename for f in photos_files) and HF_TOKEN_WRITE: uploads_dir = 'uploads_temp' os.makedirs(uploads_dir, exist_ok=True) api = HfApi() new_photos_list = [] photo_limit = 10 uploaded_count = 0 for photo_idx, photo in enumerate(photos_files): if uploaded_count >= photo_limit: break if photo and photo.filename: ext = os.path.splitext(photo.filename)[1].lower() if ext not in ['.jpg', '.jpeg', '.png', '.gif', '.webp']: continue safe_name = secure_filename(product_to_edit['name'].replace(' ', '_'))[:50] p_filename = f"{safe_name}_photo_{datetime.now().strftime('%Y%m%d%H%M%S%f')}_{photo_idx}{ext}" temp_path = os.path.join(uploads_dir, p_filename) photo.save(temp_path) api.upload_file(path_or_fileobj=temp_path, path_in_repo=f"photos/{p_filename}", repo_id=REPO_ID, repo_type="dataset", token=HF_TOKEN_WRITE) new_photos_list.append(p_filename) os.remove(temp_path) uploaded_count += 1 if new_photos_list: old_photos = product_to_edit.get('photos', []) if old_photos: for p in old_photos: try: api.delete_file(repo_id=REPO_ID, path_in_repo=f"photos/{p}", repo_type="dataset", token=HF_TOKEN_WRITE) except HfHubHTTPError as e: if e.response.status_code != 404: pass else: raise e product_to_edit['photos'] = new_photos_list try: if os.path.exists(uploads_dir) and not os.listdir(uploads_dir): os.rmdir(uploads_dir) except OSError: pass if video_file and video_file.filename and HF_TOKEN_WRITE: uploads_dir = 'uploads_temp' os.makedirs(uploads_dir, exist_ok=True) api = HfApi() ext = os.path.splitext(video_file.filename)[1].lower() if ext in ['.mp4', '.webm']: old_video = product_to_edit.get('video_filename') if old_video: try: api.delete_file(repo_id=REPO_ID, path_in_repo=f"videos/{old_video}", repo_type="dataset", token=HF_TOKEN_WRITE) except HfHubHTTPError as e: if e.response.status_code != 404: pass else: raise e safe_name = secure_filename(product_to_edit['name'].replace(' ', '_'))[:50] v_filename = f"{safe_name}_video_{datetime.now().strftime('%Y%m%d%H%M%S%f')}{ext}" temp_path = os.path.join(uploads_dir, v_filename) video_file.save(temp_path) api.upload_file(path_or_fileobj=temp_path, path_in_repo=f"videos/{v_filename}", repo_id=REPO_ID, repo_type="dataset", token=HF_TOKEN_WRITE) product_to_edit['video_filename'] = v_filename os.remove(temp_path) try: if os.path.exists(uploads_dir) and not os.listdir(uploads_dir): os.rmdir(uploads_dir) except OSError: pass data['products'] = products update_and_save_data(data) return jsonify({'success': True, 'message': get_translation('flash_product_updated_success', product_name=product_to_edit['name'])}) else: return jsonify({'error': get_translation('flash_unknown_action', action=action)}), 400 except Exception as e: logging.error(f"An internal error occurred while performing action '{action}': {e}", exc_info=True) return jsonify({'error': get_translation('flash_internal_error', action=action)}), 500 @app.route('/admin_actions', methods=['POST']) def admin_actions(): data = get_data() products = data.get('products', []) categories = data.get('categories', []) subcategories = data.get('subcategories', []) suppliers = data.get('suppliers', []) action = request.form.get('action') logging.info(f"Admin action received via form: {action}") try: if action == 'update_settings': prices_enabled_form = 'prices_enabled' in request.form data['config']['prices_enabled'] = prices_enabled_form update_and_save_data(data) flash(get_translation('flash_settings_updated'), 'success') elif action == 'add_category': category_name = request.form.get('category_name', '').strip() if category_name and not any(c['name'].lower() == category_name.lower() for c in categories): new_cat = {'id': str(uuid.uuid4()), 'name': category_name} categories.append(new_cat) data['categories'] = categories update_and_save_data(data) flash(get_translation('flash_category_added_success', category_name=category_name), 'success') elif not category_name: flash(get_translation('flash_category_name_empty'), 'error') else: flash(get_translation('flash_category_already_exists', category_name=category_name), 'error') elif action == 'delete_category': category_id_to_delete = request.form.get('category_id') category_to_delete = next((c for c in categories if c.get('id') == category_id_to_delete), None) if category_to_delete: data['categories'] = [c for c in categories if c.get('id') != category_id_to_delete] subs_to_delete = {s['id'] for s in subcategories if s.get('parent_id') == category_id_to_delete} data['subcategories'] = [s for s in subcategories if s.get('parent_id') != category_id_to_delete] for product in products: if product.get('subcategory_id') in subs_to_delete: product['subcategory_id'] = None data['products'] = products update_and_save_data(data) flash(get_translation('flash_category_delete_success', category_name=category_to_delete['name']), 'success') else: flash(get_translation('flash_category_delete_failed', category_name=category_id_to_delete), 'error') elif action == 'add_subcategory': subcategory_name = request.form.get('subcategory_name', '').strip() parent_id = request.form.get('parent_category_id') if not subcategory_name: flash(get_translation('flash_subcategory_name_empty'), 'error') elif not parent_id: flash(get_translation('flash_parent_category_not_selected'), 'error') elif any(s['name'].lower() == subcategory_name.lower() and s.get('parent_id') == parent_id for s in subcategories): flash(get_translation('flash_subcategory_already_exists', subcategory_name=subcategory_name), 'error') else: new_subcat = {'id': str(uuid.uuid4()), 'name': subcategory_name, 'parent_id': parent_id} subcategories.append(new_subcat) data['subcategories'] = subcategories update_and_save_data(data) flash(get_translation('flash_subcategory_added_success', subcategory_name=subcategory_name), 'success') elif action == 'delete_subcategory': subcategory_id_to_delete = request.form.get('subcategory_id') subcategory_to_delete = next((s for s in subcategories if s.get('id') == subcategory_id_to_delete), None) if subcategory_to_delete: data['subcategories'] = [s for s in subcategories if s.get('id') != subcategory_id_to_delete] for product in products: if product.get('subcategory_id') == subcategory_id_to_delete: product['subcategory_id'] = None data['products'] = products update_and_save_data(data) flash(get_translation('flash_subcategory_delete_success', subcategory_name=subcategory_to_delete['name']), 'success') else: flash(get_translation('flash_subcategory_delete_failed'), 'error') elif action == 'add_supplier': supplier_name = request.form.get('supplier_name', '').strip() if supplier_name and supplier_name not in suppliers: suppliers.append(supplier_name) data['suppliers'] = suppliers update_and_save_data(data) flash(get_translation('flash_supplier_added_success', supplier_name=supplier_name), 'success') elif not supplier_name: flash(get_translation('flash_supplier_name_empty'), 'error') else: flash(get_translation('flash_supplier_already_exists', supplier_name=supplier_name), 'error') elif action == 'delete_supplier': supplier_to_delete = request.form.get('supplier_name') if supplier_to_delete and supplier_to_delete in suppliers: suppliers.remove(supplier_to_delete) updated_count = 0 for product in products: if product.get('supplier') == supplier_to_delete: product['supplier'] = 'Без поставщика' updated_count += 1 data['suppliers'] = suppliers data['products'] = products update_and_save_data(data) flash(get_translation('flash_supplier_delete_success', supplier_name=supplier_to_delete, updated_count=updated_count), 'success') else: flash(get_translation('flash_supplier_delete_failed', supplier_name=supplier_to_delete), 'error') elif action == 'delete_product': product_id_to_delete = request.form.get('product_id') if not product_id_to_delete: flash(get_translation('flash_delete_error_no_id'), 'error') else: product_to_delete = next((p for p in products if p.get('id') == product_id_to_delete), None) if product_to_delete: product_name = product_to_delete.get('name', 'N/A') products.remove(product_to_delete) if HF_TOKEN_WRITE: api = HfApi() photos_to_delete = product_to_delete.get('photos', []) video_to_delete = product_to_delete.get('video_filename') for p_filename in photos_to_delete: try: api.delete_file(repo_id=REPO_ID, path_in_repo=f"photos/{p_filename}", repo_type="dataset", token=HF_TOKEN_WRITE) except HfHubHTTPError as e: if e.response.status_code != 404: pass else: raise e if video_to_delete: try: api.delete_file(repo_id=REPO_ID, path_in_repo=f"videos/{video_to_delete}", repo_type="dataset", token=HF_TOKEN_WRITE) except HfHubHTTPError as e: if e.response.status_code != 404: pass else: raise e data['products'] = products update_and_save_data(data) flash(get_translation('flash_product_deleted_success', product_name=product_name), 'success') else: flash(get_translation('flash_delete_error_not_found', product_id=product_id_to_delete), 'error') else: flash(get_translation('flash_unknown_action', action=action), 'warning') return redirect(url_for('admin')) except Exception as e: logging.error(f"An internal error occurred while performing action '{action}': {e}", exc_info=True) flash(get_translation('flash_internal_error', action=action), 'error') return redirect(url_for('admin')) @app.route('/force_upload', methods=['POST']) def force_upload(): logging.info("Forcing upload to Hugging Face...") try: upload_db_to_hf() flash(get_translation('flash_data_uploaded_hf_success'), 'success') except Exception as e: logging.error(f"Error during forced upload: {e}", exc_info=True) flash(get_translation('flash_data_upload_hf_error', error=str(e)), 'error') return redirect(url_for('admin')) @app.route('/force_download', methods=['POST']) def force_download(): logging.info("Forcing download from Hugging Face...") try: if download_db_from_hf(): initialize_data() flash(get_translation('flash_data_downloaded_hf_success'), 'success') else: flash(get_translation('flash_data_download_hf_error_retries'), 'error') except Exception as e: logging.error(f"Error during forced download: {e}", exc_info=True) flash(get_translation('flash_data_download_hf_error', error=str(e)), 'error') return redirect(url_for('admin')) if __name__ == '__main__': logging.info("Application starting up. Performing initial data load/download...") initialize_data() if HF_TOKEN_WRITE: backup_thread = threading.Thread(target=periodic_backup, daemon=True) backup_thread.start() logging.info("Periodic backup thread started.") else: logging.warning("Periodic backup will NOT run (HF_TOKEN for writing not set).") port = int(os.environ.get('PORT', 7860)) logging.info(f"Starting Flask app on host 0.0.0.0 and port {port}") app.run(debug=False, host='0.0.0.0', port=port)