diff --git "a/app.py" "b/app.py" deleted file mode 100644--- "a/app.py" +++ /dev/null @@ -1,1657 +0,0 @@ - -from flask import Flask, render_template_string, request, redirect, url_for, session, send_file -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 -from werkzeug.utils import secure_filename - -app = Flask(__name__) -app.secret_key = 'your_unique_secret_key_soola_cosmetics_67890' # Новый уникальный секретный ключ -DATA_FILE = 'data_soola.json' -USERS_FILE = 'users_soola.json' - -# Список файлов для синхронизации -SYNC_FILES = [DATA_FILE, USERS_FILE] # Убрали CONFIG_FILE - -# Настройки Hugging Face -REPO_ID = "Kgshop/Soola" # Оставим тот же репозиторий, если данные схожи, или измените на новый -HF_TOKEN_WRITE = os.getenv("HF_TOKEN") -HF_TOKEN_READ = os.getenv("HF_TOKEN_READ") - -# Адрес магазина -STORE_ADDRESS = "Рынок Дордой, Джунхай, терминал, 38" # Единый адрес - -# Валюта (только KGS) -CURRENCY_CODE = 'KGS' -CURRENCY_NAME = 'Кыргызский сом (с)' - -# Настройка логирования -logging.basicConfig(level=logging.INFO) # Можно изменить на DEBUG для более детального лога - -# --- Функции работы с данными и пользователями --- - -def load_data(): - """Загрузка данных о товарах и категориях.""" - try: - # Попытка скачать актуальные данные перед чтением локальных - download_db_from_hf() - with open(DATA_FILE, 'r', encoding='utf-8') as file: - data = json.load(file) - logging.info(f"Данные успешно загружены из {DATA_FILE}") - # Проверка базовой структуры - if not isinstance(data, dict): - logging.warning(f"{DATA_FILE} не является словарем. Инициализация пустой структурой.") - return {'products': [], 'categories': []} - if 'products' not in data: - data['products'] = [] - if 'categories' not in data: - data['categories'] = [] - return data - except FileNotFoundError: - logging.warning(f"Локальный файл {DATA_FILE} не найден. Попытка скачать с HF.") - try: - download_db_from_hf() - # Повторная попытка чтения после скачивания - with open(DATA_FILE, 'r', encoding='utf-8') as file: - data = json.load(file) - logging.info(f"Данные успешно загружены из {DATA_FILE} после скачивания.") - if not isinstance(data, dict): return {'products': [], 'categories': []} - if 'products' not in data: data['products'] = [] - if 'categories' not in data: data['categories'] = [] - return data - except (FileNotFoundError, RepositoryNotFoundError): - logging.warning(f"Файл {DATA_FILE} не найден локально и в репозитории HF. Создание пустой структуры.") - return {'products': [], 'categories': []} - except json.JSONDecodeError: - logging.error(f"Ошибка декодирования JSON в {DATA_FILE} после скачивания.") - return {'products': [], 'categories': []} - except Exception as e: - logging.error(f"Неизвестная ошибка при загрузке данных после скачивания: {e}") - return {'products': [], 'categories': []} - except json.JSONDecodeError: - logging.error(f"Ошибка декодирования JSON в локальном {DATA_FILE}. Возврат пустой структуры.") - # Здесь можно добавить логику попытки восстановления из бэкапа или HF, если нужно - return {'products': [], 'categories': []} - except Exception as e: - logging.error(f"Неизвестная ошибка при загрузке данных: {e}") - return {'products': [], 'categories': []} - - -def save_data(data): - """Сохранение данных о товарах и категориях.""" - try: - with open(DATA_FILE, 'w', encoding='utf-8') as file: - json.dump(data, file, ensure_ascii=False, indent=4) - logging.info(f"Данные успешно сохранены в {DATA_FILE}") - upload_db_to_hf() # Загрузка на HF после сохранения - except Exception as e: - logging.error(f"Ошибка при сохранении данных в {DATA_FILE}: {e}") - # В реальном приложении можно добавить механизм повторной попытки или уведомления - # raise # Перевыброс исключения может остановить приложение, если не обработан выше - -def load_users(): - """Загрузка данных пользователей.""" - try: - # Попытка скачать актуальные данные перед чтением локальных - # download_db_from_hf() # Можно раскомментировать, если нужна синхронизация при каждом чтении - with open(USERS_FILE, 'r', encoding='utf-8') as file: - users = json.load(file) - logging.info(f"Данные пользователей успешно загружены из {USERS_FILE}") - return users if isinstance(users, dict) else {} - except FileNotFoundError: - logging.warning(f"Локальный файл {USERS_FILE} не найден. Попытка скачать с HF.") - try: - download_db_from_hf() - with open(USERS_FILE, 'r', encoding='utf-8') as file: - users = json.load(file) - logging.info(f"Данные пользователей загружены из {USERS_FILE} после скачивания.") - return users if isinstance(users, dict) else {} - except (FileNotFoundError, RepositoryNotFoundError): - logging.warning(f"Файл {USERS_FILE} не найден локально и в репозитории HF. Возврат пустого словаря.") - return {} - except json.JSONDecodeError: - logging.error(f"Ошибка декодирования JSON в {USERS_FILE} после скачивания.") - return {} - except Exception as e: - logging.error(f"Неизвестная ошибка при загрузке пользователей после скачивания: {e}") - return {} - except json.JSONDecodeError: - logging.error(f"Ошибка декодирования JSON в локальном {USERS_FILE}. Возврат пустого словаря.") - return {} - except Exception as e: - logging.error(f"Неизвестная ошибка при загрузке пользователей: {e}") - return {} - -def save_users(users): - """Сохранение данных пользователей.""" - try: - with open(USERS_FILE, 'w', encoding='utf-8') as file: - json.dump(users, file, ensure_ascii=False, indent=4) - logging.info(f"Данные пользователей успешно сохранены в {USERS_FILE}") - upload_db_to_hf() # Загрузка на HF после сохранения - except Exception as e: - logging.error(f"Ошибка при сохранении данных пользователей в {USERS_FILE}: {e}") - -# --- Функции синхронизации с Hugging Face --- - -def upload_db_to_hf(): - """Загрузка файлов данных на Hugging Face.""" - if not HF_TOKEN_WRITE: - logging.warning("Переменная окружения HF_TOKEN (для записи) не установлена. Загрузка на Hugging Face пропущена.") - return - try: - api = HfApi() - logging.info(f"Начало загрузки файлов на HF репозиторий {REPO_ID}...") - for file_name in SYNC_FILES: - if os.path.exists(file_name): - 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"Авто-бэкап {file_name} {datetime.now().strftime('%Y-%m-%d %H:%M:%S')}" - ) - logging.info(f"Файл {file_name} успешно загружен на Hugging Face.") - else: - logging.warning(f"Файл {file_name} не найден локально, пропуск загрузки.") - logging.info("Загрузка файлов на HF завершена.") - except Exception as e: - logging.error(f"Ошибка при загрузке файлов на Hugging Face: {e}") - -def download_db_from_hf(): - """Скачивание файлов данных с Hugging Face.""" - if not HF_TOKEN_READ: - logging.warning("Переменная окружения HF_TOKEN_READ не установлена. Скачивание с Hugging Face пропущено.") - return # Не прерываем работу, если нет токена на чтение, используем локальные файлы - try: - api = HfApi() # Api() можно использовать и без токена для публичных репо, но лучше с токеном чтения - logging.info(f"Начало скачивания файлов с HF репозитория {REPO_ID}...") - for file_name in SYNC_FILES: - try: - hf_hub_download( - repo_id=REPO_ID, - filename=file_name, - repo_type="dataset", - token=HF_TOKEN_READ, - local_dir=".", # Скачиваем в текущую директорию - local_dir_use_symlinks=False, # Важно для Docker и некоторых ОС - force_download=True # Принудительно скачивать, чтобы получить свежую версию - ) - logging.info(f"Файл {file_name} успешно скачан из Hugging Face.") - except RepositoryNotFoundError: - logging.error(f"Репозиторий {REPO_ID} не найден на Hugging Face.") - # Не прерываем цикл, возможно, другие файлы существуют - except Exception as e: # Ловим исключения для каждого файла отдельно - # Проверяем, является ли ошибка 'Not Found' для конкретного файла - if "404 Client Error" in str(e) and file_name in str(e): - logging.warning(f"Файл {file_name} не найден в репозитории {REPO_ID}. Пропуск скачивания.") - else: - logging.error(f"Ошибка при скачивании файла {file_name} с Hugging Face: {e}") - logging.info("Скачивание файлов с HF завершено.") - except Exception as e: - # Общая ошибка, если не удалось даже инициализировать Api() или что-то глобальное - logging.error(f"Общая ошибка при попытке скачивания с Hugging Face: {e}") - # Не прерываем работу приложения, будем использовать локальные файлы, если они есть - -def periodic_backup(): - """Периодическая загрузка данных на HF.""" - while True: - time.sleep(1800) # Пауза 30 минут (1800 секунд) - logging.info("Запуск периодического резервного копирования...") - upload_db_to_hf() - logging.info("Периодическое резервное копирование завершено.") - - -# --- Маршруты Flask --- - -@app.route('/') -def catalog(): - """Главная страница каталога товаров.""" - data = load_data() - products = data.get('products', []) - categories = data.get('categories', []) - is_authenticated = 'user' in session - - catalog_html = ''' - - - - - - Soola Cosmetics - Каталог {/* Название изменено */} - - - - - - -
-
-

Soola Cosmetics

{/* Название изменено */} -
- {% if is_authenticated %} - Привет, {{ session['user_info'].get('first_name', session['user']) }}! - Выйти - {% else %} - Войти - {# Регистрация #} {/* Ссылка на регистрацию убрана */} - {% endif %} -
- -
- -
Наш адрес: {{ store_address }}
{/* Используем единый адрес */} - -
- - {% for category in categories %} - - {% endfor %} -
- -
- -
- -
- {% for product in products %} -
- {% if product.get('photos') and product['photos']|length > 0 %} -
- {{ product['name'] }} -
- {% else %} -
- No Image -
- {% endif %} -
-

{{ product['name'] }}

- {% if is_authenticated %} -
{{ "%.2f"|format(product['price']) }} {{ currency_code }}
{/* Цена в KGS */} - {% else %} -
Цена доступна после входа
- {% endif %} -

{{ product.get('description', '')[:50] }}{% if product.get('description', '')|length > 50 %}...{% endif %}

-
-
- - {% if is_authenticated %} - - {% endif %} -
-
- {% endfor %} - {% if not products %} -

Товары в этой категории скоро появятся.

- {% endif %} -
-
- - - - - - - - - - - - - - - - - - ''' - return render_template_string( - catalog_html, - products=products, - categories=categories, - repo_id=REPO_ID, - is_authenticated=is_authenticated, - store_address=STORE_ADDRESS, # Передаем единый адрес - session=session, - currency_code=CURRENCY_CODE # Передаем код валюты KGS - ) - - -@app.route('/product/') -def product_detail(index): - """Отдает HTML с деталями одного продукта для модального окна.""" - data = load_data() - products = data.get('products', []) - is_authenticated = 'user' in session - try: - product = products[index] - except IndexError: - return "Товар не найден", 404 - - detail_html = ''' -
{/* Уменьшаем внутренние отступы */} -

{{ product['name'] }}

- {# Swiper Slider for Photos #} -
-
- {% if product.get('photos') and product['photos']|length > 0 %} - {% for photo in product['photos'] %} -
-
- {{ product['name'] }} - фото {{ loop.index }} -
-
- {% endfor %} - {% else %} -
- Изображение отсутствует -
- {% endif %} -
- {# Элементы управления Swiper #} - {% if product.get('photos') and product['photos']|length > 1 %} -
-
-
- {% endif %} -
- - {# Product Details #} -
-

Категория: {{ product.get('category', 'Без категории') }}

- {% if is_authenticated %} -

Цена: {{ "%.2f"|format(product['price']) }} {{ currency_code }}

{/* Цена в KGS */} - {% else %} -

Цена: Доступна после входа

- {% endif %} -

Описание:
{{ product.get('description', 'Описание отсутствует.')|replace('\n', '
')|safe }}

- {% if product.get('colors') and product['colors']|length > 0 and product['colors'] != [''] %} -

Доступные цвета/варианты: {{ product['colors']|join(', ') }}

- {% endif %} -
-
- ''' - return render_template_string( - detail_html, - product=product, - repo_id=REPO_ID, - is_authenticated=is_authenticated, - currency_code=CURRENCY_CODE # Передаем код валюты KGS - ) - -# --- Маршруты аутентификации --- - -# Маршрут регистрации /register УДАЛЕН - -@app.route('/login', methods=['GET', 'POST']) -def login(): - """Страница входа пользователя.""" - if request.method == 'POST': - login = request.form.get('login') - password = request.form.get('password') - users = load_users() - - if login in users and users[login].get('password') == password: - user_info = users[login] - session['user'] = login - # Сохраняем доп. информацию в сессию для использования в приложении - session['user_info'] = { - 'login': login, - 'first_name': user_info.get('first_name', ''), - 'last_name': user_info.get('last_name', ''), - 'country': user_info.get('country', ''), - 'city': user_info.get('city', '') - } - logging.info(f"Пользователь {login} успешно вошел в систему.") - # Сохраняем логин в localStorage для авто-входа - login_response_html = f''' - -

Вход выполнен успешно. Перенаправление...

- Перейти в каталог - ''' - return login_response_html - # return redirect(url_for('catalog')) # Стандартный редирект - else: - logging.warning(f"Неудачная попытка входа для пользователя {login}.") - error_message = "Неверный логин или пароль." - return render_template_string(LOGIN_TEMPLATE, error=error_message), 401 - - # GET запрос - просто показать форму входа - return render_template_string(LOGIN_TEMPLATE, error=None) - -# Шаблон для страницы входа вынесен для читаемости -LOGIN_TEMPLATE = ''' - - - - - - Вход - Soola Cosmetics - - - - -
-

Вход в Soola Cosmetics

- {% if error %} -

{{ error }}

- {% endif %} -
- - - - - -
- {# Ссылка на регистрацию удалена #} - Вернуться в каталог -
- - -''' - -@app.route('/auto_login', methods=['POST']) -def auto_login(): - """Попытка автоматического входа по логину из localStorage.""" - data = request.get_json() - login = data.get('login') - if not login: - return "Логин не предоставлен", 400 - - users = load_users() - if login in users: - user_info = users[login] - session['user'] = login - session['user_info'] = { # Сохраняем нужную инфу - 'login': login, - 'first_name': user_info.get('first_name', ''), - 'last_name': user_info.get('last_name', ''), - 'country': user_info.get('country', ''), - 'city': user_info.get('city', '') - } - logging.info(f"Автоматический вход для пользователя {login} выполнен.") - return "OK", 200 - else: - logging.warning(f"Неудачная попытка автоматического входа для несуществующего пользователя {login}.") - return "Пользователь не найден", 404 # Или 401, если не хотим раскрывать существование - -@app.route('/logout') -def logout(): - """Выход пользователя из системы.""" - logged_out_user = session.get('user') - session.pop('user', None) - session.pop('user_info', None) # Удаляем и доп. информацию - logging.info(f"Пользователь {logged_out_user} вышел из системы.") - # Очищаем localStorage при выходе - logout_response_html = ''' - -

Выход выполнен. Перенаправление...

- Перейти на главную - ''' - return logout_response_html - # return redirect(url_for('catalog')) # Стандартный редирект - -# --- Админ-панель --- - -@app.route('/admin', methods=['GET', 'POST']) -def admin(): - """Админ-панель для управления товарами, категориями и пользователями.""" - # Простая проверка "админа" - можно заменить на реальную аутентификацию админа - # if session.get('user') != 'admin': # Пример простой проверки - # return "Доступ запрещен", 403 - - data = load_data() - products = data.get('products', []) - categories = data.get('categories', []) - users = load_users() - - if request.method == 'POST': - action = request.form.get('action') - logging.info(f"Admin action received: {action}") - - try: # Обернем обработку POST в try-except для отлова ошибок - if action == 'add_category': - category_name = request.form.get('category_name', '').strip() - if category_name and category_name not in categories: - categories.append(category_name) - save_data(data) - logging.info(f"Категория '{category_name}' добавлена.") - elif not category_name: - logging.warning("Попытка добавить пустую категорию.") - # Можно добавить сообщение об ошибке для пользователя - else: - logging.warning(f"Категория '{category_name}' уже существует.") - # Можно добавить сообщение об ошибке для пользователя - return redirect(url_for('admin')) - - elif action == 'delete_category': - category_to_delete = request.form.get('category_name') - if category_to_delete in categories: - categories.remove(category_to_delete) - # Обновляем товары, у которых была эта категория - for product in products: - if product.get('category') == category_to_delete: - product['category'] = 'Без категории' - save_data(data) - logging.info(f"Категория '{category_to_delete}' удалена.") - else: - logging.warning(f"Попытка удалить несуществующую категорию: {category_to_delete}") - return redirect(url_for('admin')) - - elif action == 'add_product': - name = request.form.get('name', '').strip() - price_str = request.form.get('price', '0').replace(',', '.') - description = request.form.get('description', '').strip() - category = request.form.get('category') - photos_files = request.files.getlist('photos') - # Получаем цвета, фильтруем пустые строки и удаляем лишние пробелы - colors = [c.strip() for c in request.form.getlist('colors') if c.strip()] - - if not name or not price_str: - logging.error("Ошибка добавления товара: не указано название или цена.") - # Нужно вернуть сообщение об ошибке пользователю - return "Ошибка: Название и цена обязательны.", 400 - - try: - price = round(float(price_str), 2) # Цена в KGS - if price < 0: price = 0 # Цена не может быть отрицательной - except ValueError: - logging.error(f"Ошибка добавления товара: неверный формат цены '{price_str}'.") - return "Ошибка: Неверный формат цены.", 400 - - photos_list = [] - if photos_files and HF_TOKEN_WRITE: - # Создаем временную папку для загрузок, если ее нет - uploads_dir = 'uploads_temp' - os.makedirs(uploads_dir, exist_ok=True) - api = HfApi() - for photo in photos_files[:10]: # Ограничение на 10 фото - if photo and photo.filename: - try: - photo_filename = secure_filename(f"{datetime.now().strftime('%Y%m%d%H%M%S')}_{photo.filename}") - temp_path = os.path.join(uploads_dir, photo_filename) - photo.save(temp_path) - logging.info(f"Загрузка фото {photo_filename} на HF...") - api.upload_file( - path_or_fileobj=temp_path, - path_in_repo=f"photos/{photo_filename}", - repo_id=REPO_ID, - repo_type="dataset", - token=HF_TOKEN_WRITE, - commit_message=f"Add photo for product {name}" - ) - photos_list.append(photo_filename) - logging.info(f"Фото {photo_filename} успешно загружено.") - os.remove(temp_path) # Удаляем временный файл - except Exception as e: - logging.error(f"Ошибка загрузки фото {photo.filename} на HF: {e}") - # Не прерываем процесс из-за одного фото, но логируем ошибку - elif photo and not photo.filename: - logging.warning("Получен пустой файл фото при добавлении товара.") - - new_product = { - 'name': name, - 'price': price, - 'description': description, - 'category': category if category in categories else 'Без категории', - 'photos': photos_list, - 'colors': colors # Сохраняем отфильтрованный список цветов - } - products.append(new_product) - save_data(data) - logging.info(f"Товар '{name}' добавлен.") - return redirect(url_for('admin')) - - elif action == 'edit_product': - index_str = request.form.get('index') - if index_str is None: - logging.error("Ошибка редактирования: индекс товара не передан.") - return "Ошибка: Индекс товара не указан.", 400 - - try: - index = int(index_str) - if not (0 <= index < len(products)): - raise IndexError("Индекс вне диапазона") - except (ValueError, IndexError): - logging.error(f"Ошибка редактирования: неверный индекс товара '{index_str}'.") - return "Ошибка: Неверный индекс товара.", 400 - - product_to_edit = products[index] - original_name = product_to_edit.get('name', 'N/A') # Для логов - - # Обновляем поля - product_to_edit['name'] = request.form.get('name', product_to_edit['name']).strip() - price_str = request.form.get('price', str(product_to_edit['price'])).replace(',', '.') - product_to_edit['description'] = request.form.get('description', product_to_edit['description']).strip() - category = request.form.get('category') - product_to_edit['category'] = category if category in categories else 'Без категории' - # Обновляем цвета, фильтруя пустые - product_to_edit['colors'] = [c.strip() for c in request.form.getlist('colors') if c.strip()] - - try: - price = round(float(price_str), 2) - if price < 0: price = 0 - product_to_edit['price'] = price - except ValueError: - logging.warning(f"Неверный формат цены '{price_str}' при редактировании товара {original_name}. Цена не изменена.") - # Можно вернуть ошибку пользователю или оставить старую цену - - # Обработка новых фото (если есть и если есть токен) - photos_files = request.files.getlist('photos') - 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 = [] - logging.info(f"Начало загрузки новых фото для товара {product_to_edit['name']}...") - for photo in photos_files[:10]: - if photo and photo.filename: - try: - photo_filename = secure_filename(f"{datetime.now().strftime('%Y%m%d%H%M%S')}_{photo.filename}") - temp_path = os.path.join(uploads_dir, photo_filename) - photo.save(temp_path) - logging.info(f"Загрузка нового фото {photo_filename} на HF...") - api.upload_file( - path_or_fileobj=temp_path, - path_in_repo=f"photos/{photo_filename}", - repo_id=REPO_ID, - repo_type="dataset", - token=HF_TOKEN_WRITE, - commit_message=f"Update photo for product {product_to_edit['name']}" - ) - new_photos_list.append(photo_filename) - logging.info(f"Новое фото {photo_filename} успешно загружено.") - os.remove(temp_path) - except Exception as e: - logging.error(f"Ошибка загрузки нового фото {photo.filename}: {e}") - elif photo and not photo.filename: - logging.warning("Получен пустой файл фото при редактировании товара.") - - # Заменяем старый список фото новым, если были загружены новые - if new_photos_list: - # TODO: Возможно, стоит удалить старые фото с HF, если они больше не нужны - logging.info(f"Список фото для товара {product_to_edit['name']} обновлен.") - product_to_edit['photos'] = new_photos_list - else: - logging.info(f"Новые фото не были загружены, список фото для {product_to_edit['name']} не изменен.") - - - save_data(data) - logging.info(f"Товар '{original_name}' (индекс {index}) обновле��.") - return redirect(url_for('admin')) - - elif action == 'delete_product': - index_str = request.form.get('index') - if index_str is None: - logging.error("Ошибка удаления: индекс товара не передан.") - return "Ошибка: Индекс товара не указан.", 400 - try: - index = int(index_str) - if not (0 <= index < len(products)): - raise IndexError("Индекс вне диапазона") - deleted_product = products.pop(index) - # TODO: По-хорошему, надо бы удалить и связанные фото с HF - save_data(data) - logging.info(f"Товар '{deleted_product.get('name', 'N/A')}' (индекс {index}) удален.") - except (ValueError, IndexError): - logging.error(f"Ошибка удаления: неверный индекс товара '{index_str}'.") - return "Ошибка: Неверный индекс товара.", 400 - return redirect(url_for('admin')) - - # --- Управление пользователями --- - elif action == 'add_user': - login = request.form.get('login', '').strip() - password = request.form.get('password', '').strip() - first_name = request.form.get('first_name', '').strip() - last_name = request.form.get('last_name', '').strip() - country = request.form.get('country', '').strip() - city = request.form.get('city', '').strip() - - if not login or not password: - logging.error("Ошибка добавления пользователя: логин и пароль обязательны.") - # Вернуть сообщение об ошибке - return "Ошибка: Логин и пароль обязательны.", 400 - if login in users: - logging.warning(f"Попытка добавить существующего пользователя: {login}") - # Вернуть сообщение об ошибке - return f"Ошибка: Пользователь с логином '{login}' уже существует.", 400 - - users[login] = { - 'password': password, # В реальном приложении пароль нужно хешировать! - 'first_name': first_name, - 'last_name': last_name, - 'country': country, - 'city': city - } - save_users(users) - logging.info(f"Пользователь '{login}' добавлен.") - return redirect(url_for('admin')) - - elif action == 'delete_user': - login_to_delete = request.form.get('login') - if login_to_delete in users: - del users[login_to_delete] - save_users(users) - logging.info(f"Пользователь '{login_to_delete}' удален.") - else: - logging.warning(f"Попытка удалить несуществующего пользователя: {login_to_delete}") - return redirect(url_for('admin')) - - else: - logging.warning(f"Получено неизвестное действие в админ-панели: {action}") - return redirect(url_for('admin')) # Или показать ошибку - - except Exception as e: - logging.error(f"Ошибка при обработке действия '{action}' в админ-панели: {e}", exc_info=True) - # Можно вернуть страницу с ошибкой - return f"Произошла внутренняя ошибка при выполнении действия '{action}'. Подробности в логе.", 500 - - - # GET запрос для отображения админ-панели - admin_html = ''' - - - - - - Админ-панель - Soola Cosmetics - - - - - -
-
-

Админ-панель Soola Cosmetics

- Перейти в каталог -
- -

Синхронизация с Hugging Face

-
-
- -
-
- -
-
- -
-
-
-

Управление категориями

-
- - - - -
-

Существующие категории:

- {% if categories %} -
- {% for category in categories %} -
- {{ category }} -
- - - -
-
- {% endfor %} -
- {% else %} -

Категорий пока нет.

- {% endif %} -
-
- -
-
-

Управление пользователями

-
- Добавить нового пользователя -
- - - - - - - - - - - - - - -
-
- -

Список пользователей:

- {% if users %} -
- {% for login, user in users.items() %} -
-

Логин: {{ login }}

-

Имя: {{ user.get('first_name', 'N/A') }} {{ user.get('last_name', '') }}

-

Локация: {{ user.get('city', 'N/A') }}, {{ user.get('country', 'N/A') }}

- {# Пароль не отображаем #} -
-
- - - -
- {# Можно добавить кнопку редактирования пользователя #} -
-
- {% endfor %} -
- {% else %} -

Пользователей пока нет.

- {% endif %} -
-
-
- - -
-

Управление товарами

-
- Добавить новый товар -
- - - - {/* Валюта KGS */} - - - - - - - - -
-
- - -
-
- -
- -
-
- -

Список товаров:

- {% if products %} -
- {% for product in products %} -
-

{{ product['name'] }}

-

Категория: {{ product.get('category', 'Без категории') }}

-

Цена: {{ "%.2f"|format(product['price']) }} {{ currency_code }}

-

Описание: {{ product.get('description', 'N/A')[:100] }}{% if product.get('description', '')|length > 100 %}...{% endif %}

-

Цвета/Варианты: {{ product.get('colors', ['Нет'])|join(', ') if product.get('colors') else 'Нет' }}

- {% if product.get('photos') %} -

Фото:

-
- {% for photo in product['photos'] %} - - Фото {{ loop.index }} - - {% endfor %} -
- {% endif %} - -
- -
- - - -
-
- - {# Форма редактирования (скрыта по умолчанию) #} -
-

Редактирование товара: {{ product['name'] }}

-
- - - - - - - - - - - - - -
- {% if product.get('colors') %} - {% for color in product.get('colors', []) %} -
- - -
- {% endfor %} - {% else %} - {# Добавляем одно пустое поле, если цветов нет #} -
- - -
- {% endif %} -
- -
- -
-
-
- {% endfor %} -
- {% else %} -

Товаров пока нет.

- {% endif %} -
- -
- - - - - ''' - return render_template_string( - admin_html, - products=products, - categories=categories, - users=users, - repo_id=REPO_ID, - currency_code=CURRENCY_CODE - ) - -# --- Маршруты для принудительной синхронизации --- - -@app.route('/force_upload', methods=['POST']) -def force_upload(): - # Добавить проверку прав администратора, если необходимо - logging.info("Запущена принудительная загрузка данных на Hugging Face...") - upload_db_to_hf() - # Можно добавить flash сообщение об успехе/ошибке - return redirect(url_for('admin')) - -@app.route('/force_download', methods=['POST']) -def force_download(): - # Добавить проверку прав администратора, если необходимо - logging.info("Запущено принудительное скачивание данных с Hugging Face...") - try: - download_db_from_hf() - # Можно добавить flash сообщение об успехе - except Exception as e: - logging.error(f"Ошибка при принудительном скачивании: {e}") - # Можно добавить flash сообщение об ошибке - return redirect(url_for('admin')) - - -# --- Запуск приложения --- - -if __name__ == '__main__': - # Попытка загрузить данные при старте, чтобы создать файлы, если их нет - load_data() - load_users() - - # Запуск потока для периодического бэкапа - if HF_TOKEN_WRITE: # Запускаем бэкап, только если есть токен для записи - backup_thread = threading.Thread(target=periodic_backup, daemon=True) - backup_thread.start() - logging.info("Поток периодического резервного копирования запущен.") - else: - logging.warning("Периодическое резервное копирование не будет запущено (HF_TOKEN не установлен).") - - # Запуск Flask приложения - # Используйте Gunicorn или Waitress для продакшена вместо встроенного сервера Flask - logging.info("Запуск Flask приложения...") - app.run(debug=False, host='0.0.0.0', port=7860) # debug=False для продакшена