-
Soola Cosmetics
-
- {% if is_authenticated %}
+CATALOG_TEMPLATE = '''
+
+
+
+
+
+ Soola Cosmetics - Каталог
+
+
+
+
+
+
+
-
+
+
+
- Soola Cosmetics
+
+ {% if is_authenticated %}
Привет, {{ session.get('user_info', {}).get('first_name', session['user']) }}!
- Админка
+
Выйти
- {% else %}
+ {% else %}
Войти
- Админка
- {% endif %}
-
+ {# Регистрация #} {# Добавить, если будет регистрация #}
+ {% endif %}
Наш адрес: {{ store_address }}
+ Наш адрес: {{ store_address }}
+
{% for category in categories %}
@@ -429,666 +436,1182 @@ def catalog():
-
+
+
- {# Цикл по товарам #}
- {% for product in products %}
-
-
-
-
- {% if product.get('photos') and product['photos']|length > 0 %}
- {# Генерируем URL изображения с HF #}
- ![{{ product['name'] }}](https://huggingface.co/datasets/{{ repo_id }}/resolve/main/photos/{{ product['photos'][0] }}?download=false)
- {% else %}
- 
- {% endif %}
-
-
- {% else %}
-
- {% endif %}
-
-
- {{ product['name'] }}
- {% if is_authenticated %} -{{ "%.2f"|format(product['price']) }} {{ currency_code }}
- {% else %}
- Цена доступна после входа
- {% endif %}
- {# Укороченное описание #}
- {{ product.get('description', '')[:50] }}{% if product.get('description', '')|length > 50 %}...{% endif %}
-
-
- {% if is_authenticated %}
-
- {% else %}
- {# Можно добавить кнопку "Войти, чтобы заказать", если нужно #}
- {% endif %}
-
+
+ {% for product in products %}
+
+
+
+ {% endfor %}
+ {# Сообщение, если нет товаров ПОСЛЕ фильтрации, будет добавлено через JS #}
+ {% if not products %}
+
+ {% endif %}
+ {% if product.get('photos') and product['photos']|length > 0 %}
+ {# Используем правильный URL для Hugging Face Datasets #}
+ ![{{ product['name'] }}](https://huggingface.co/datasets/{{ repo_id }}/resolve/main/photos/{{ product['photos'][0] }})
+ {% else %}
+ 
+ {% endif %}
+
+
+ {% else %}
+
+ {% endif %}
+
+
+ {{ product['name'] }}
+ {% if is_authenticated %} +{{ "%.2f"|format(product['price']) }} {{ currency_code }}
+ {% else %}
+ Цена доступна после входа
+ {% endif %}
+ {{ product.get('description', '') }}
+
+
+ {% if is_authenticated %}
+
+ {% endif %}
- {% endfor %}
- {# Конец цикла по товарам #}
-
- {# Сообщение, если нет товаров ПОСЛЕ фильтрации, будет добавлено через JS #}
- {% if not products %}
-
- {% endif %}
-
- ×
-
Загрузка...
+
+
+
+
-
-
-
+
+
+
+
-
-
-
- ×
-
- Вход - Soola Cosmetics
+
+
+
+
+ Админ-панель - Soola Cosmetics
+
+
+
+
+
+ Вход - Soola Cosmetics
-
-
-
-
- Вход выполнен
+ Перенаправление...
+ Выход...
+ Админ-панель - Soola Cosmetics
-
-
-
-
-
-
Ваша корзина
-Ваша корзина пуста.
- Итого: 0.00 {{ currency_code }}
-
-
-
-
-
+
+
+
+
-
-
-
-
-
-
-
-
+
+
+
+'''
- // --- Notifications ---
- function showNotification(message, duration = 3000, type = 'info') {
- const placeholder = document.getElementById('notification-placeholder');
- if (!placeholder) {
- console.error("Notification placeholder not found.");
- return;
- }
+PRODUCT_DETAIL_TEMPLATE = '''
+{# Используем Jinja комментарий, а не HTML #}
+ {# Добавлен класс для специфичных стилей, если нужно #}
+
+'''
- // Добавляем иконку в зависимости от типа
- let iconClass = 'fas fa-info-circle'; // По умолчанию info
- if (type === 'success') iconClass = 'fas fa-check-circle';
- else if (type === 'error') iconClass = 'fas fa-exclamation-circle';
- else if (type === 'warning') iconClass = 'fas fa-exclamation-triangle';
- notification.innerHTML = ` ${message}`;
+LOGIN_TEMPLATE = '''
+
+
+
+
+
+ {{ product['name'] }}
{# Темно-зеленый заголовок #} + + {# Swiper Slider for Photos #} + {# Убраны инлайн-стили, управляются через CSS #}
+
- const notification = document.createElement('div');
- notification.className = `notification notification-${type}`; // Доб��вляем класс типа
- notification.textContent = message;
+ {# Product Details - Используем классы вместо инлайн-стилей #}
+
+ {% if product.get('photos') and product['photos']|length > 0 %}
+ {% for photo in product['photos'] %}
+
+ {# Элементы управления Swiper (показываем только если фото больше 1) #}
+ {% if product.get('photos') and product['photos']|length > 1 %}
+
+
+
+ {% endif %}
+
+
+ {% endfor %}
+ {% else %}
+ {# Контейнер для зума #}
+ ![{{ product['name'] }} - фото {{ loop.index }}](https://huggingface.co/datasets/{{ repo_id }}/resolve/main/photos/{{ photo }})
+
+
+
+
+ {% endif %}
+
+ 
+
+
+
+
тегов из описания #} +
+Категория: {{ product.get('category', 'Без категории') }}
+ {% if is_authenticated %} +Цена: {{ "%.2f"|format(product['price']) }} {{ currency_code }}
+ {% else %} +Цена: Доступна после входа
+ {% endif %} + {# Используем safe фильтр для рендерингатегов из описания #} +
Описание:
{{ product.get('description', 'Описание отсутствует.')|replace('\\n', '
')|safe }}
Доступные цвета/варианты: {{ colors|join(', ') }}
+ {% endif %} +
+
+
+
+'''
+
+ADMIN_TEMPLATE = '''
+
+
+
+
+
+ Вход в Soola Cosmetics
+ {# Используем стандартные flash сообщения Flask #} + {% with messages = get_flashed_messages(with_categories=true) %} + {% if messages %} + {% for category, message in messages %} + {# Исправляем баг - используем category как класс #} + + {% endfor %} + {% endif %} + {% endwith %} + {# Вывод ошибки из переменной error (если она передана, для совместимости) #} + {% if error %} + + {% endif %} + + + ← Вернуться в каталог +
+
+
+
+ {# Сообщения об успехе/ошибке #}
+ {% with messages = get_flashed_messages(with_categories=true) %}
+ {% if messages %}
+ {% for category, message in messages %}
+
+ {% endfor %}
+ {% endif %}
+ {% endwith %}
+
+
+
+
+
+ {# Секция Товары #}
+
- // Удаление через указанное время
- setTimeout(() => {
- notification.classList.remove('show');
- // Ждем завершения анимации исчезновения перед удалением из DOM
- notification.addEventListener('transitionend', () => {
- if (notification.parentNode === placeholder) { // Проверяем, не удален ли уже
- placeholder.removeChild(notification);
- }
- }, { once: true }); // Обработчик сработает только один раз
- }, duration);
- }
+
- // --- Event Listeners and Initial Setup ---
- document.addEventListener('DOMContentLoaded', () => {
- console.log("DOM fully loaded and parsed");
- applyInitialTheme(); // Установить тему при загрузке
- attemptAutoLogin(); // Попробовать авто-вход (должен быть до updateCartButton)
- updateCartButton(); // Показать/скрыть кнопку корзины и обновить счетчик
- setupFilters(); // Настроить поиск и фильтры категорий
-
- // Глобальный обработчик кликов для закрытия модальных окон при клике вне их контента
- window.addEventListener('click', function(event) {
- // Закрываем модальное окно, только если клик был на самом фоне модального окна (элемент с классом 'modal')
- if (event.target.classList.contains('modal')) {
- closeModal(event.target.id);
- }
- });
+
+
+
+'''
- // Глобальный обработчик нажатий клавиш для закрытия модальных окон по Escape
- window.addEventListener('keydown', function(event) {
- if (event.key === 'Escape' || event.key === 'Esc') { // Обрабатываем оба варианта
- // Находим все ВИДИМЫЕ модальные окна
- const openModals = document.querySelectorAll('.modal[style*="display: block"]');
- // Закрываем самое верхнее (последнее в списке)
- if (openModals.length > 0) {
- closeModal(openModals[openModals.length - 1].id);
- }
- }
- });
+# --- Маршруты Flask ---
- console.log("Initial setup complete.");
- });
+@app.route('/')
+def catalog():
+ """Главная страница каталога товаров."""
+ data = load_data()
+ # Сортировка данных перед отображением
+ products = sorted(data.get('products', []), key=lambda x: x.get('name', '').lower())
+ categories = sorted(data.get('categories', []))
+ is_authenticated = 'user' in session
-
-
-
- '''
return render_template_string(
- catalog_html,
+ CATALOG_TEMPLATE, # Используем переменную с шаблоном
products=products,
categories=categories,
repo_id=REPO_ID,
@@ -1103,84 +1626,17 @@ def catalog():
def product_detail(index):
"""Отдает HTML с деталями одного продукта для модального окна."""
data = load_data()
- products = data.get('products', [])
+ # Получаем продукты, отсортированные так же, как на главной
+ products = sorted(data.get('products', []), key=lambda x: x.get('name', '').lower())
is_authenticated = 'user' in session
try:
- # Получаем продукт по индексу из *текущего* списка (который может быть отсортирован)
- # Важно: Если список на главной сортируется, индексы могут не совпадать с исходным файлом.
- # Лучше передавать уникальный ID продукта, если он есть. Но для простоты оставим индекс.
- # Убедимся, что продукты отсортированы так же, как на главной
- products.sort(key=lambda x: x.get('name', '').lower())
product = products[index]
except IndexError:
- logging.warning(f"Попытка доступа к продукту с некорректным индексом {index}")
- return "Товар не найден", 404
- except Exception as e:
- logging.error(f"Ошибка при получении деталей продукта по индексу {index}: {e}", exc_info=True)
- return "Ошибка сервера при загрузке товара", 500
-
- # HTML для деталей продукта
- detail_html = '''
- {# Используем Jinja комментарий для ясности #}
- Админ-панель Soola Cosmetics
+ Перейти в каталог {# Средне-зеленая кнопка каталога #} +Синхронизация с Hugging Face
+ +Резервное копирование на Hugging Face происходит автоматически каждые 30 минут, а также после сохранения товаров, категорий или пользователей. Используйте эти кнопки для немедленной ручной синхронизации.
+
+
- // Устанавливаем цвет фона в зависимости от типа
- let bgColor = '#38a169'; // success/info по умолчанию
- if (type === 'error') bgColor = '#f56565'; // red
- else if (type === 'warning') bgColor = '#ecc94b'; // yellow
- else if (type === 'info') bgColor = '#4a90e2'; // blue
- notification.style.backgroundColor = bgColor;
+ {# Колонка Категории #}
+
+
+
+
+ Категории
+
+
+
+ Добавить новую категорию
+
+
+
+ Существующие категории:
+ {% if categories %} + {# Используем block для простого списка #}
+ {% for category in categories %}
+
+ {% else %}
+
+ {{ category }}
+
+
+ {% endfor %}
+ Категорий пока нет.
+ {% endif %} + {# Колонка Пользователи #}
+
+
+
+ Пользователи
+
+
+
+ Добавить нового пользователя
+
+
+
+ Список пользователей:
+ {% if users %} +
+ {% for login, user_data in users.items() %}
+
+ {% else %}
+
+
+ {% endfor %}
+ Логин: {{ login }}
+Имя: {{ user_data.get('first_name', 'N/A') }} {{ user_data.get('last_name', '') }}
+Локация: {{ user_data.get('city', 'N/A') }}, {{ user_data.get('country', 'N/A') }}
+ {# Пароль не отображаем! #} +
+
+ {# Кнопка Редактировать пользователя (если понадобится)
+
+ #}
+
+ Пользователей пока нет.
+ {% endif %} +Товары
+
+
- placeholder.appendChild(notification);
+ Добавить новый товар
+
+
+
+ Список товаров:
+ {% if products %} +
+ {% for product in products %}
+
+ {% else %}
+
+
+ {% endfor %}
+
+ {# Превью первого фото #}
+
- // Плавное появление (используем requestAnimationFrame для надежности)
- requestAnimationFrame(() => {
- notification.classList.add('show');
- });
+ {# Убираем верхний отступ у превью #}
+ {% if product.get('photos') and product['photos']|length > 0 %}
+
+
+
+ {% else %}
+ 
+ {% endif %}
+
+ {# Информация о товаре #}
+
+
+ {% else %}
+
+ {% endif %}
+
+
+ {{ product['name'] }}
+Категория: {{ product.get('category', 'Без категории') }}
+Цена: {{ "%.2f"|format(product['price']) }} {{ currency_code }}
+Описание: {{ product.get('description', 'N/A')[:150] }}{% if product.get('description', '')|length > 150 %}...{% endif %}
+ {% set colors = product.get('colors', [])|select('ne', '')|list %} {# Фильтруем пустые строки #} +Цвета/Вар-ты: {{ colors|join(', ') if colors else 'Нет' }}
+ {% if product.get('photos') and product['photos']|length > 1 %} +(Всего фото: {{ product['photos']|length }})
+ {% elif product.get('photos') and product['photos']|length == 1 %} +(1 фото)
+ {% endif %} +
+
+
+
+ {# Форма редактирования (скрыта по умолчанию) #}
+
+
+ Редактирование: {{ product['name'] }}
+ +Товаров пока нет.
+ {% endif %} +
-
- '''
return render_template_string(
- detail_html,
+ PRODUCT_DETAIL_TEMPLATE, # Используем отдельный шаблон для деталей
product=product,
repo_id=REPO_ID,
is_authenticated=is_authenticated,
@@ -1189,161 +1645,119 @@ def product_detail(index):
# --- Маршруты аутентификации ---
-# Шаблон для страницы входа
-LOGIN_TEMPLATE = '''
-
-
-
-
-
- {{ product['name'] }}
{# Темно-зеленый заголовок #} - - {# Swiper Slider for Photos - Убедимся, что классы совпадают с JS инициализацией #} - - - {# Product Details #} -![{{ product['name'] }} - фото {{ loop.index }}](https://huggingface.co/datasets/{{ repo_id }}/resolve/main/photos/{{ photo }}?download=false)
{# Добавляем lazy loading #}
- 
-
-
- Категория: {{ product.get('category', 'Без категории') }}
- {% if is_authenticated %} -Цена: {{ "%.2f"|format(product['price']) }} {{ currency_code }}
{# Темно-зеленая цена #} - {% else %} -Цена: Доступна после входа
{# Средне-зеленая ссылка #} - {% endif %} + logging.warning(f"Попытка доступа к несуществующему продукту с индексом {index}") + return "Товар не найден.
", 404 - {# Описание с обработкой переносов строк #} - {% if product.get('description') %} -Описание:
-{{ product.get('description', 'Описание отсутствует.') }}
- {% else %}
- Описание: Описание отсутствует.
- {% endif %} - - {# Доступные цвета/варианты (только если они есть и не пустые) #} - {% set valid_colors = product.get('colors', [])|select('ne', '')|list %} - {% if valid_colors %} -Доступные цвета/варианты: {{ valid_colors|join(', ') }}
- {% endif %} -
-
-
-
-'''
-
@app.route('/login', methods=['GET', 'POST'])
def login():
"""Страница входа пользователя."""
+ if 'user' in session:
+ return redirect(url_for('catalog')) # Уже вошел - редирект в каталог
+
+ error_message = None # Используем None вместо пустой строки для проверки в шаблоне
+
if request.method == 'POST':
- login = request.form.get('login', '').strip()
- password = request.form.get('password') # Пароль не тримим
+ login_attempt = request.form.get('login')
+ password_attempt = request.form.get('password')
- if not login or not password:
- flash("Логин и пароль не могут быть пустыми.", "error")
- # Не редирект, а рендерим шаблон снова с ошибкой
- return render_template_string(LOGIN_TEMPLATE), 400
+ if not login_attempt or not password_attempt:
+ flash("Логин и пароль обязательны.", 'error')
+ # Возвращаем шаблон с сообщением об ошибке
+ return render_template_string(LOGIN_TEMPLATE, error=None), 400
users = load_users()
- # Проверка пользователя и пароля (ВАЖНО: пароли должны хешироваться в реальном приложении)
- user_data = users.get(login)
- if user_data and user_data.get('password') == password: # Заменить на проверку хеша!
+ # --- ВАЖНО: НЕБЕЗОПАСНОЕ СРАВНЕНИЕ ПАРОЛЕЙ ---
+ # В реальном приложении ИСПОЛЬЗУЙТЕ ХЕШИРОВАНИЕ ПАРОЛЕЙ (например, passlib или werkzeug.security)
+ # Пример с Werkzeug:
+ # from werkzeug.security import check_password_hash
+ # stored_hash = users.get(login_attempt, {}).get('password_hash')
+ # if stored_hash and check_password_hash(stored_hash, password_attempt):
+ # # Успех
+ # else:
+ # # Неудача
+
+ # --- Текущая (небезопасная) проверка ---
+ user_data = users.get(login_attempt)
+ if user_data and user_data.get('password') == password_attempt:
# Успешный вход
- session['user'] = login
- # Сохраняем больше информации о пользователе в сессии для удобства
+ session['user'] = login_attempt
+ # Сохраняем нужную информацию о пользователе в сессии
session['user_info'] = {
- 'login': login,
+ 'login': login_attempt,
'first_name': user_data.get('first_name', ''),
'last_name': user_data.get('last_name', ''),
'country': user_data.get('country', ''),
'city': user_data.get('city', '')
}
- session.permanent = True # Делаем сессию постоянной (по умолчанию зависит от браузера)
- app.permanent_session_lifetime = timedelta(days=30) # Пример: сессия живет 30 дней
-
- logging.info(f"Пользователь {login} успешно вошел в систему.")
- flash(f"Добро пожаловать, {session['user_info'].get('first_name', login)}!", "success")
+ session.permanent = True # Делаем сессию постоянной (зависит от настройки app.permanent_session_lifetime)
+ logging.info(f"Пользователь '{login_attempt}' успешно вошел в систему.")
- # Ответ с JS для сохранения логина в localStorage и редиректа
+ # Ответ с JS для сохранения логина в localStorage и редиректом
login_response_html = f'''
- Вход в Soola Cosmetics
- {# Отображение Flash сообщений #} - {% with messages = get_flashed_messages(with_categories=true) %} - {% if messages %} - {% for category, message in messages %} - {# Используем 'error' для ошибок, 'warning' для предупреждений, иначе 'info' #} - - {% endfor %} - {% endif %} - {% endwith %} - - - ← Вернуться в каталог -Вход выполнен успешно. Перенаправление в каталог...
-Вход выполнен успешно. Перенаправление в каталог...
''' return login_response_html else: # Неудачный вход - logging.warning(f"Неудачная попытка входа для пользователя '{login}'.") - flash("Неверный логин или пароль.", "error") - return render_template_string(LOGIN_TEMPLATE), 401 # Код 401 Unauthorized + logging.warning(f"Неудачная попытка входа для пользователя '{login_attempt}'.") + error_message = "Неверный логин или пароль." + flash(error_message, 'error') + # Возвращаем шаблон с сообщением об ошибке, статус 401 + return render_template_string(LOGIN_TEMPLATE, error=error_message), 401 - # GET запрос - просто отображаем форму - return render_template_string(LOGIN_TEMPLATE) + # GET запрос - просто отображаем форму входа + return render_template_string(LOGIN_TEMPLATE, error=error_message) @app.route('/auto_login', methods=['POST']) def auto_login(): - """API для попытки автоматического входа по логину из localStorage.""" - if not request.is_json: - logging.warning("Запрос auto_login не является JSON.") - return {"error": "Неверный формат запроса"}, 400 + """Попытка автоматического входа по логину из localStorage.""" + if 'user' in session: + # Пользователь уже в сессии, ничего не делаем + return "Already logged in", 200 data = request.get_json() - login = data.get('login') + if not data or 'login' not in data: + logging.warning("Запрос auto_login без данных или ключа 'login'.") + return "Неверный запрос", 400 - if not login: + login_from_storage = data.get('login') + if not login_from_storage: logging.warning("Попытка auto_login с пустым логином.") - return {"error": "Логин не предоставлен"}, 400 - - # Проверяем, не залогинен ли уже пользователь в текущей сессии Flask - if 'user' in session and session['user'] == login: - logging.info(f"Пользователь {login} уже аутентифицирован в сессии Flask.") - return {"message": "Already authenticated"}, 200 # Уже залогинен + return "Логин не предоставлен", 400 users = load_users() - user_data = users.get(login) + user_data = users.get(login_from_storage) - # При авто-логине доверяем только наличию логина и существованию пользователя - # Пароль не проверяем, так как он не передается if user_data: - # Если пользователь найден, создаем сессию Flask - session['user'] = login + # Пользователь найден. Входим без проверки пароля (доверие localStorage). + # Это менее безопасно, чем полноценный вход. + session['user'] = login_from_storage session['user_info'] = { - 'login': login, - 'first_name': user_data.get('first_name', ''), - 'last_name': user_data.get('last_name', ''), - 'country': user_data.get('country', ''), - 'city': user_data.get('city', '') - } - session.permanent = True # Можно сделать сессию постоянной - logging.info(f"Автоматический вход для пользователя {login} выполнен успешно.") - return {"message": "Auto-login successful"}, 200 + 'login': login_from_storage, + 'first_name': user_data.get('first_name', ''), + 'last_name': user_data.get('last_name', ''), + 'country': user_data.get('country', ''), + 'city': user_data.get('city', '') + } + session.permanent = True + logging.info(f"Автоматический вход для пользователя '{login_from_storage}' выполнен.") + return "OK", 200 else: - # Если пользователь с таким логином не найден в базе, сообщаем об ошибке - logging.warning(f"Неудачная попытка автоматического входа: пользователь '{login}' не найден.") - # Возвращаем ошибку, чтобы JS удалил невалидный логин из localStorage - return {"error": "User not found or invalid"}, 404 # Или 403 + # Пользователь из localStorage не найден в базе (возможно, удален) + logging.warning(f"Неудачная попытка автоматического входа: пользователь '{login_from_storage}' не найден.") + # Возвращаем ошибку, чтобы JS удалил невалидный ключ из localStorage + return "User not found", 404 # Или 403 Forbidden, или 400 + @app.route('/logout') def logout(): @@ -1352,645 +1766,183 @@ def logout(): # Очищаем сессию session.pop('user', None) session.pop('user_info', None) - # session.clear() # Можно очистить всю сессию - if logged_out_user: - logging.info(f"Пользователь {logged_out_user} вышел из системы.") - flash("Вы успешно вышли из системы.", "info") - else: - flash("Вы не были авторизованы.", "info") # Если пытались выйти без входа + logging.info(f"Пользователь '{logged_out_user}' вышел из системы.") + flash(f"Вы успешно вышли из системы.", 'success') # Сообщение пользователю - # Ответ с JS для очистки localStorage и редиректом на главную - logout_response_html = ''' + # Ответ с JS для очистки localStorage и редиректом + logout_response_html = f'''Выход выполнен. Перенаправление на главную страницу...
-Выход выполнен. Перенаправление на главную страницу...
''' return logout_response_html - # --- Админ-панель --- -# Шаблон админ-панели -ADMIN_TEMPLATE = ''' - - - - - -
-
-
-
-
-
-'''
-
-# --- Вспомогательные функции для админки ---
-def _check_admin_auth():
- """Проверяет, авторизован ли пользователь (базовая проверка)."""
- # !! ВАЖНО: Замените 'admin' на реальный логин администратора
- # !! или реализуйте систему ролей, если нужно несколько админов.
- required_admin_login = os.getenv('ADMIN_LOGIN', 'admin') # Загружаем из .env или используем 'admin'
- if 'user' not in session:
- flash("Требуется вход для доступа к этой странице.", 'warning')
- return False
- # if session['user'] != required_admin_login:
- # flash("Недостаточно прав для доступа к админ-панели.", 'error')
- # return False
- return True # Пока разрешаем доступ любому залогиненному пользователю
-
-def _upload_photos_to_hf(photos_files, product_name):
- """Загружает список файлов фото на HF и возвращает список имен файлов."""
- if not photos_files or not any(f.filename for f in photos_files) or not HF_TOKEN_WRITE:
- return [] # Нет файлов, нет токена или пустые файлы
-
- uploads_dir = 'uploads_temp_photos' # Используем отдельную временную папку
- os.makedirs(uploads_dir, exist_ok=True)
- api = HfApi()
- uploaded_photos_list = []
- photo_limit = 10
- uploaded_count = 0
- error_occurred = False
-
- logging.info(f"Начало загрузки фото для товара '{product_name}'...")
- for photo in photos_files:
- if uploaded_count >= photo_limit:
- logging.warning(f"Достигнут лимит фото ({photo_limit}), остальные фото проигнорированы.")
- flash(f"Загружено только первые {photo_limit} фото.", "warning")
- break
- if photo and photo.filename:
- try:
- # Генерируем безопасное и уникальное имя файла
- base, ext = os.path.splitext(photo.filename)
- # Используем secure_filename для базового имени и добавляем timestamp/хеш
- safe_base = secure_filename(base)[:50] # Ограничиваем длину базы
- timestamp = datetime.now().strftime('%Y%m%d%H%M%S%f')
- photo_filename = f"{safe_base}_{timestamp}{ext}"
- temp_path = os.path.join(uploads_dir, photo_filename)
-
- photo.save(temp_path) # Сохраняем во временную папку
-
- # Путь в репозитории HF
- repo_path = f"photos/{photo_filename}"
-
- logging.info(f"Загрузка фото {photo_filename} в {repo_path}...")
- api.upload_file(
- path_or_fileobj=temp_path,
- path_in_repo=repo_path,
- repo_id=REPO_ID,
- repo_type="dataset",
- token=HF_TOKEN_WRITE,
- commit_message=f"Add photo {photo_filename} for product {product_name}"
- )
- uploaded_photos_list.append(photo_filename)
- logging.info(f"Фото {photo_filename} успешно загружено.")
- uploaded_count += 1
-
- try:
- os.remove(temp_path) # Удаляем временный файл после успешной загрузки
- except OSError as e:
- logging.warning(f"Не удалось удалить временный файл фото {temp_path}: {e}")
-
- except Exception as e:
- logging.error(f"Ошибка загрузки фото {photo.filename} на HF: {e}", exc_info=True)
- flash(f"Ошибка при загрузке фото {photo.filename}.", 'error')
- error_occurred = True
- # Пытаемся удалить временный файл, если он был создан
- if 'temp_path' in locals() and os.path.exists(temp_path):
- try: os.remove(temp_path)
- except OSError as e_rem: logging.warning(f"Не удалось удалить временный файл {temp_path} после ошибки: {e_rem}")
- elif photo and not photo.filename:
- logging.warning("Получен пустой объект файла фото при загрузке.")
-
- # Пытаемся удалить временную папку, если она пуста
- try:
- if os.path.exists(uploads_dir) and not os.listdir(uploads_dir):
- os.rmdir(uploads_dir)
- except OSError as e:
- logging.warning(f"Не удалось удалить временную папку {uploads_dir}: {e}")
- if not error_occurred and uploaded_count > 0:
- flash(f"Успешно загружено {uploaded_count} фото.", "success")
- elif error_occurred and uploaded_count > 0:
- flash(f"Загружено {uploaded_count} фото, но при загрузке некоторых возникли ошибки.", "warning")
+# Простая проверка прав администратора (замените на свою логику, если нужно)
+def is_admin():
+ # Пример: разрешить доступ всем вошедшим пользователям
+ # Для более строгой проверки: return session.get('user') == 'admin_login'
+ # Или проверить роль пользователя из session['user_info']
+ return 'user' in session
- return uploaded_photos_list
-
-def _delete_photos_from_hf(photos_list, product_name):
- """Удаляет список файлов фото с HF."""
- if not photos_list or not HF_TOKEN_WRITE:
- return False # Нечего удалять или нет токена
-
- api = HfApi()
- paths_in_repo = [f"photos/{p}" for p in photos_list if p] # Формируем пути
- if not paths_in_repo: return False
-
- logging.info(f"Попытка удаления фото товара '{product_name}' с HF: {paths_in_repo}")
- try:
- api.delete_files(
- repo_id=REPO_ID,
- paths_in_repo=paths_in_repo,
- repo_type="dataset",
- token=HF_TOKEN_WRITE,
- commit_message=f"Delete photos for product {product_name}",
- missing_ok=True # Не считать ошибкой, если файл уже удален
- )
- logging.info(f"Фото {paths_in_repo} для товара '{product_name}' успешно удалены или не найдены на HF.")
- return True
- except Exception as e:
- logging.error(f"Ошибка при удалении фото {paths_in_repo} для товара '{product_name}' с HF: {e}", exc_info=True)
- flash(f"Не удалось удалить некоторые фото для товара '{product_name}' с сервера.", "warning")
- return False
-
-
-# --- Маршрут админ-панели ---
@app.route('/admin', methods=['GET', 'POST'])
def admin():
- """Админ-панель для управления данными."""
- # Проверка авторизации администратора
- if not _check_admin_auth():
- # Сообщение об ошибке уже добавлено в _check_admin_auth
- return redirect(url_for('login')) # Перенаправляем на вход
+ """Админ-панель для управления товарами, категориями и пользователями."""
+ if not is_admin():
+ flash("Доступ к админ-панели запрещен.", 'error')
+ return redirect(url_for('login'))
data = load_data()
- products = data.get('products', [])
- categories = data.get('categories', [])
- users = load_users()
+ # Сортируем для обработки и отображения
+ products = sorted(data.get('products', []), key=lambda x: x.get('name', '').lower())
+ categories = sorted(data.get('categories', []))
+ users = load_users() # Пользователи уже отсортированы при сохранении
if request.method == 'POST':
action = request.form.get('action')
- logging.info(f"Admin action received: {action}")
+ logging.info(f"Admin action received: {action} by user {session.get('user')}")
try:
- # --- Управление Категориями ---
+ # --- Обработка Категорий ---
if action == 'add_category':
category_name = request.form.get('category_name', '').strip()
- if category_name:
- if category_name not in categories:
- categories.append(category_name)
- categories.sort() # Сортируем
- save_data(data)
- logging.info(f"Категория '{category_name}' добавлена.")
- flash(f"Категория '{category_name}' успешно добавлена.", 'success')
- else:
- logging.warning(f"Попытка добавить существующую категорию: {category_name}")
- flash(f"Категория '{category_name}' уже существует.", 'warning')
- else:
+ if category_name and category_name not in categories:
+ data['categories'].append(category_name) # Добавляем в исходный словарь data
+ save_data(data) # Сохраняем весь data
+ logging.info(f"Категория '{category_name}' добавлена.")
+ flash(f"Категория '{category_name}' успешно добавлена.", 'success')
+ elif not category_name:
logging.warning("Попытка добавить пустую категорию.")
flash("Название категории не может быть пустым.", 'error')
+ else:
+ logging.warning(f"Категория '{category_name}' уже существует.")
+ flash(f"Категория '{category_name}' уже существует.", 'warning')
elif action == 'delete_category':
category_to_delete = request.form.get('category_name')
- if category_to_delete and category_to_delete in categories:
- categories.remove(category_to_delete)
- # Обновляем товары, у которых была эта категория
+ if category_to_delete and category_to_delete in data.get('categories', []):
+ data['categories'].remove(category_to_delete)
updated_count = 0
- for product in products:
+ for product in data.get('products', []):
if product.get('category') == category_to_delete:
product['category'] = 'Без категории'
updated_count += 1
save_data(data)
logging.info(f"Категория '{category_to_delete}' удалена. Обновлено товаров: {updated_count}.")
flash(f"Категория '{category_to_delete}' удалена ({updated_count} товаров обновлено).", 'success')
- elif category_to_delete == 'Без категории':
- flash("Категорию 'Без категории' нельзя удалить.", 'warning')
else:
logging.warning(f"Попытка удалить несуществующую или пустую категорию: {category_to_delete}")
- flash(f"Не удалось найти категорию '{category_to_delete}' для удаления.", 'error')
+ flash(f"Не удалось удалить категорию '{category_to_delete}'.", 'error')
- # --- Управление Товарами ---
+ # --- Обработка Товаров ---
elif action == 'add_product':
name = request.form.get('name', '').strip()
price_str = request.form.get('price', '').replace(',', '.')
description = request.form.get('description', '').strip()
- category = request.form.get('category', 'Без категории')
+ category = request.form.get('category')
photos_files = request.files.getlist('photos')
- # Получаем цвета, фильтруем пустые строки и удаляем дубликаты
- colors = sorted(list(set(c.strip() for c in request.form.getlist('colors') if c.strip())))
+ # Получаем список цветов, фильтруем пустые строки
+ colors = [c.strip() for c in request.form.getlist('colors') if c.strip()]
if not name or not price_str:
flash("Название и цена товара обязательны.", 'error')
- return redirect(url_for('admin'))
+ # Не делаем редирект, чтобы пользователь не потерял введенные данные
+ return render_template_string(
+ ADMIN_TEMPLATE, products=products, categories=categories, users=users,
+ repo_id=REPO_ID, currency_code=CURRENCY_CODE
+ )
try:
price = round(float(price_str), 2)
if price < 0: raise ValueError("Цена не может быть отрицательной")
- except ValueError as e:
- flash(f"Неверный формат цены: {e}", 'error')
- return redirect(url_for('admin'))
+ except ValueError as ve:
+ flash(f"Неверный формат цены: {ve}", 'error')
+ return render_template_string(
+ ADMIN_TEMPLATE, products=products, categories=categories, users=users,
+ repo_id=REPO_ID, currency_code=CURRENCY_CODE
+ )
- # Загрузка фото на HF
- uploaded_photos = _upload_photos_to_hf(photos_files, name)
+ # --- Обработка фото ---
+ photos_list = []
+ if photos_files and any(f.filename for f in photos_files):
+ if not HF_TOKEN_WRITE:
+ flash("Ошибка: Токен для записи (HF_TOKEN) не настроен. Фото не могут быть загружены.", 'error')
+ else:
+ uploads_dir = 'uploads_temp'
+ os.makedirs(uploads_dir, exist_ok=True)
+ api = HfApi()
+ photo_limit = 10
+ uploaded_count = 0
+ for photo in photos_files:
+ # Пропускаем пустые файлы или если лимит достигнут
+ if not photo or not photo.filename or uploaded_count >= photo_limit:
+ if uploaded_count >= photo_limit and photo and photo.filename:
+ logging.warning(f"Достигнут лимит фото ({photo_limit}), фото {photo.filename} проигнорировано.")
+ flash(f"Достигнут лимит ({photo_limit} фото), некоторые файлы проигнорированы.", "warning")
+ continue
+
+ try:
+ # Создаем уникальное имя файла
+ base, ext = os.path.splitext(photo.filename)
+ # Делаем имя более безопасным и уникальным
+ safe_base = secure_filename(base)[:50] # Ограничиваем длину имени
+ photo_filename = f"{safe_base}_{datetime.now().strftime('%Y%m%d%H%M%S%f')}{ext}"
+ temp_path = os.path.join(uploads_dir, photo_filename)
+ photo.save(temp_path)
+ logging.info(f"Загрузка фото {photo_filename} на HF для товара {name}...")
+ # Убедимся, что путь в репозитории правильный
+ repo_photo_path = f"photos/{photo_filename}"
+ api.upload_file(
+ path_or_fileobj=temp_path,
+ path_in_repo=repo_photo_path,
+ repo_id=REPO_ID,
+ repo_type="dataset",
+ token=HF_TOKEN_WRITE,
+ commit_message=f"Add photo {photo_filename} for product {name}"
+ )
+ photos_list.append(photo_filename)
+ logging.info(f"Фото {photo_filename} успешно загружено на {repo_photo_path}.")
+ os.remove(temp_path) # Удаляем временный файл
+ uploaded_count += 1
+ except Exception as e:
+ logging.error(f"Ошибка загрузки фото {photo.filename} на HF: {e}", exc_info=True)
+ flash(f"Ошибка при загрузке фото {photo.filename}. Оно не будет добавлено.", 'error')
+ # Очистка временного файла, если он остался
+ if 'temp_path' in locals() and os.path.exists(temp_path):
+ try: os.remove(temp_path)
+ except OSError: pass
+ # Удаляем временную папку, если она пуста
+ try:
+ if not os.listdir(uploads_dir):
+ os.rmdir(uploads_dir)
+ except OSError as e:
+ logging.warning(f"Не удалось удалить временную папку {uploads_dir}: {e}")
+ # --- Конец обработки фото ---
new_product = {
- 'name': name, 'price': price, 'description': description,
+ 'name': name,
+ 'price': price,
+ 'description': description,
'category': category if category in categories else 'Без категории',
- 'photos': uploaded_photos, # Используем список загруженных фото
- 'colors': colors
+ 'photos': photos_list, # Список имен файлов
+ 'colors': colors # Список цветов/вариантов
}
- products.append(new_product)
- products.sort(key=lambda x: x.get('name', '').lower()) # Сортируем
- save_data(data)
+ data['products'].append(new_product)
+ save_data(data) # Сохранение вызовет сортировку и загрузку на HF
logging.info(f"Товар '{name}' добавлен.")
- # Flash сообщение о загрузке фото уже есть в _upload_photos_to_hf
flash(f"Товар '{name}' успешно добавлен.", 'success')
+ return redirect(url_for('admin')) # Редирект после успешного добавления
elif action == 'edit_product':
index_str = request.form.get('index')
@@ -2000,58 +1952,146 @@ def admin():
try:
index = int(index_str)
- if not (0 <= index < len(products)): raise IndexError("Индекс вне диапазона")
- product_to_edit = products[index]
- original_name = product_to_edit.get('name', 'N/A') # Сохраняем старое имя для логов
+ # Используем не отсортированный список для получения индекса
+ original_products = load_data().get('products', []) # Загружаем данные еще раз для точности индекса
+ if not (0 <= index < len(original_products)): raise IndexError("Индекс вне диапазона")
+
+ # Находим товар в текущем (возможно, уже отсортированном) списке data['products'] по имени (или другому уникальному идентификатору)
+ # Это менее надежно, если имена могут повторяться. Лучше использовать ID, если он будет.
+ # Пока что ищем по индексу в неотсортированном списке и предполагаем, что порядок в data['products'] еще не изменился сильно.
+ # Для надежности, лучше перезагружать data перед редактированием или передавать уникальный ID товара.
+ # Простой подход (менее надежный):
+ if not (0 <= index < len(data['products'])):
+ # Если индекс стал невалидным после сортировки, пытаемся найти по имени (если оно уникально)
+ # Это сложно, поэтому пока оставим поиск по индексу, предполагая, что пользователь работает с видимым списком
+ flash(f"Ошибка редактирования: не удалось найти товар с индексом '{index_str}' после возможной сортировки.", 'error')
+ return redirect(url_for('admin'))
+
+ product_to_edit = data['products'][index]
+ original_name = product_to_edit.get('name', 'N/A')
+ original_photos = list(product_to_edit.get('photos', [])) # Копируем старый список фото
+
except (ValueError, IndexError) as e:
- logging.error(f"Ошибка при получении товара для редактирования: {e}, index={index_str}")
- flash(f"Ошибка редактирования: неверный индекс товара '{index_str}'.", 'error')
+ flash(f"Ошибка редактирования: неверный индекс товара '{index_str}'. {e}", 'error')
return redirect(url_for('admin'))
# Обновляем поля
- new_name = request.form.get('name', original_name).strip()
- price_str = request.form.get('price', str(product_to_edit.get('price', '0'))).replace(',', '.')
- description = request.form.get('description', product_to_edit.get('description', '')).strip()
- category = request.form.get('category', 'Без категории')
- # Получаем цвета, фильтруем пустые, убираем дубли и сортируем
- colors = sorted(list(set(c.strip() for c in request.form.getlist('colors') if c.strip())))
-
- product_to_edit['name'] = new_name
- product_to_edit['description'] = description
- product_to_edit['category'] = category if category in categories else 'Без категории'
- product_to_edit['colors'] = colors
+ new_name = request.form.get('name', product_to_edit['name']).strip()
+ price_str = request.form.get('price', str(product_to_edit['price'])).replace(',', '.')
+ new_description = request.form.get('description', product_to_edit['description']).strip()
+ new_category = request.form.get('category')
+ new_colors = [c.strip() for c in request.form.getlist('colors') if c.strip()]
+
+ if not new_name or not price_str:
+ flash("Название и цена товара обязательны при редактировании.", 'error')
+ # Не делаем редирект
+ return render_template_string(
+ ADMIN_TEMPLATE, products=products, categories=categories, users=users,
+ repo_id=REPO_ID, currency_code=CURRENCY_CODE
+ )
try:
- price = round(float(price_str), 2)
- if price < 0: raise ValueError("Цена не может быть отрицательной")
- product_to_edit['price'] = price
- except ValueError as e:
- logging.warning(f"Неверный формат цены '{price_str}' при редактировании товара '{original_name}'. Цена не изменена.")
- flash(f"Неверный формат цены для товара '{new_name}'. Цена не изменена ({e}).", 'warning')
- # Не прерываем, остальные поля могут быть изменены
+ new_price = round(float(price_str), 2)
+ if new_price < 0: raise ValueError("Цена не может быть отрицательной")
+ except ValueError as ve:
+ flash(f"Неверный формат цены при редактировании: {ve}. Изменения не сохранены.", 'error')
+ return render_template_string(
+ ADMIN_TEMPLATE, products=products, categories=categories, users=users,
+ repo_id=REPO_ID, currency_code=CURRENCY_CODE
+ )
+
+ # Обновляем данные в словаре товара
+ product_to_edit['name'] = new_name
+ product_to_edit['price'] = new_price
+ product_to_edit['description'] = new_description
+ product_to_edit['category'] = new_category if new_category in categories else 'Без категории'
+ product_to_edit['colors'] = new_colors
- # Обработка новых фото (замена старых)
+ # --- Обработка новых фото (ЗАМЕНА старых) ---
photos_files = request.files.getlist('photos')
- if photos_files and any(f.filename for f in photos_files):
- logging.info(f"Обнаружены новые фото для товара '{new_name}'. Начинаем обработку.")
- # 1. Загружаем новые фото
- new_uploaded_photos = _upload_photos_to_hf(photos_files, new_name)
-
- # 2. Если новые фото успешно загружены, удаляем старые
- if new_uploaded_photos:
- old_photos = product_to_edit.get('photos', [])
- _delete_photos_from_hf(old_photos, new_name) # Пытаемся удалить старые
- product_to_edit['photos'] = new_uploaded_photos # Заменяем список фото
- # Сообщение об успехе/ошибках загрузки уже добавлено в _upload_photos_to_hf
- else:
- # Если новые фото НЕ были загружены (из-за ошибки или лимита)
- logging.warning(f"Новые фото для товара '{new_name}' не были загружены. Старые фото остаются.")
- flash("Новые фотографии не были загружены (возможно, из-за ошибки или лимита). Старые фото сохранены.", "warning")
+ new_photos_list = [] # Список имен НОВЫХ загруженных файлов
+ has_new_photo_files = photos_files and any(f.filename for f in photos_files)
- products.sort(key=lambda x: x.get('name', '').lower()) # Сортируем
- save_data(data)
+ if has_new_photo_files:
+ if not HF_TOKEN_WRITE:
+ flash("Ошибка: Токен для записи (HF_TOKEN) не настроен. Фото не могут быть обновлены.", 'error')
+ else:
+ uploads_dir = 'uploads_temp'
+ os.makedirs(uploads_dir, exist_ok=True)
+ api = HfApi()
+ photo_limit = 10
+ uploaded_count = 0
+ logging.info(f"Загрузка новых фото для товара {new_name}...")
+ for photo in photos_files:
+ if not photo or not photo.filename or uploaded_count >= photo_limit:
+ if uploaded_count >= photo_limit and photo and photo.filename:
+ logging.warning(f"Достигнут лимит фото ({photo_limit}), фото {photo.filename} проигнорировано.")
+ flash(f"Достигнут лимит ({photo_limit} фото), некоторые новые файлы проигнорированы.", "warning")
+ continue
+ try:
+ base, ext = os.path.splitext(photo.filename)
+ safe_base = secure_filename(base)[:50]
+ photo_filename = f"{safe_base}_{datetime.now().strftime('%Y%m%d%H%M%S%f')}{ext}"
+ temp_path = os.path.join(uploads_dir, photo_filename)
+ photo.save(temp_path)
+ repo_photo_path = f"photos/{photo_filename}"
+ logging.info(f"Загрузка нового фото {photo_filename} на HF...")
+ api.upload_file(path_or_fileobj=temp_path, path_in_repo=repo_photo_path,
+ repo_id=REPO_ID, repo_type="dataset", token=HF_TOKEN_WRITE,
+ commit_message=f"Update photo {photo_filename} for product {new_name}")
+ new_photos_list.append(photo_filename) # Добавляем имя успешно загруженного файла
+ logging.info(f"Новое фото {photo_filename} успешно загружено.")
+ os.remove(temp_path)
+ uploaded_count += 1
+ except Exception as e:
+ logging.error(f"Ошибка загрузки нового фото {photo.filename}: {e}", exc_info=True)
+ flash(f"Ошибка при загрузке нового фото {photo.filename}. Оно не будет добавлено.", 'error')
+ if 'temp_path' in locals() and os.path.exists(temp_path):
+ try: os.remove(temp_path)
+ except OSError: pass
+
+ # Удаляем временную папку, если она пуста
+ try:
+ if not os.listdir(uploads_dir): os.rmdir(uploads_dir)
+ except OSError: pass
+
+ # Если были успешно загружены НОВЫЕ фото, ЗАМЕНЯЕМ ими старые и удаляем старые с HF
+ if new_photos_list:
+ logging.info(f"Список фото для товара {new_name} будет заменен на: {new_photos_list}")
+ product_to_edit['photos'] = new_photos_list # Заменяем список фото в данных
+
+ # Пытаемся удалить СТАРЫЕ фото с HF
+ if original_photos:
+ logging.info(f"Попытка удаления старых фото с HF: {original_photos}")
+ try:
+ # Формируем полные пути к старым фото в репозитории
+ paths_to_delete = [f"photos/{p}" for p in original_photos if p]
+ if paths_to_delete:
+ api.delete_files(
+ repo_id=REPO_ID,
+ paths_in_repo=paths_to_delete,
+ repo_type="dataset",
+ token=HF_TOKEN_WRITE,
+ commit_message=f"Delete old photos for product {new_name} during update"
+ )
+ logging.info(f"Старые фото {original_photos} удалены с HF.")
+ else:
+ logging.info("Нет старых фото для удаления с HF.")
+ except Exception as e:
+ logging.error(f"Ошибка при удалении старых фото {original_photos} с HF: {e}", exc_info=True)
+ flash("Не удалось удалить старые фотографии с сервера.", "warning")
+ flash("Фотографии товара успешно обновлены.", "success")
+ elif uploaded_count == 0:
+ # Если были выбраны файлы, но ни один не загрузился
+ flash("Не удалось загрузить ни одного из выбранных новых фото. Старые фото сохранены.", "error")
+ # В этом случае НЕ меняем product_to_edit['photos']
+ # Если файлы не выбирались (has_new_photo_files == False), то product_to_edit['photos'] остается без изменений
+ # --- Конец обработки фото ---
+
+ save_data(data) # Сохраняем все изменения в data.json
logging.info(f"Товар '{original_name}' (индекс {index}) обновлен на '{new_name}'.")
flash(f"Товар '{new_name}' успешно обновлен.", 'success')
+ return redirect(url_for('admin'))
elif action == 'delete_product':
@@ -2061,26 +2101,56 @@ def admin():
return redirect(url_for('admin'))
try:
index = int(index_str)
- if not (0 <= index < len(products)): raise IndexError("Индекс вне диапазона")
-
- deleted_product = products.pop(index) # Удаляем из списка Python
+ # Снова используем оригинальный (несортированный) список для удаления
+ original_products = load_data().get('products', [])
+ if not (0 <= index < len(original_products)): raise IndexError("Индекс вне диапазона")
+
+ # Находим товар в текущем data['products'] (предполагая, что он там есть)
+ # Этот шаг может быть неточным, если были добавления/удаления до этого запроса.
+ # Безопаснее было бы передавать ID товара.
+ # Простой подход:
+ if not (0 <= index < len(data['products'])):
+ flash(f"Ошибка удаления: не удалось найти товар с индексом '{index_str}'. Возможно, список был изменен.", 'error')
+ return redirect(url_for('admin'))
+
+ deleted_product = data['products'].pop(index) # Удаляем из текущего списка data
product_name = deleted_product.get('name', 'N/A')
-
- # Удаляем фото с HF
photos_to_delete = deleted_product.get('photos', [])
- _delete_photos_from_hf(photos_to_delete, product_name) # Пытаемся удалить фото
- save_data(data) # Сохраняем обновленный список товаров
- logging.info(f"Товар '{product_name}' (старый индекс {index}) удален.")
+ # --- Удаление фото с HF при удалении товара ---
+ if photos_to_delete and HF_TOKEN_WRITE:
+ logging.info(f"Попытка удаления фото товара '{product_name}' с HF: {photos_to_delete}")
+ try:
+ api = HfApi()
+ paths_to_delete = [f"photos/{p}" for p in photos_to_delete if p]
+ if paths_to_delete:
+ api.delete_files(
+ repo_id=REPO_ID,
+ paths_in_repo=paths_to_delete,
+ repo_type="dataset",
+ token=HF_TOKEN_WRITE,
+ commit_message=f"Delete photos for deleted product {product_name}"
+ )
+ logging.info(f"Фото товара '{product_name}' ({paths_to_delete}) удалены с HF.")
+ else:
+ logging.info(f"Нет связанных фото для удаления с HF для товара {product_name}.")
+ except Exception as e:
+ logging.error(f"Ошибка при удалении фото {photos_to_delete} для товара '{product_name}' с HF: {e}", exc_info=True)
+ flash(f"Не удалось удалить фото для товара '{product_name}' с сервера. Сам товар удален.", "warning")
+ # --- Конец удаления фото ---
+
+ save_data(data) # Сохраняем изменения
+ logging.info(f"Товар '{product_name}' (индекс {index}) удален.")
flash(f"Товар '{product_name}' удален.", 'success')
except (ValueError, IndexError) as e:
- logging.error(f"Ошибка при удалении товара: {e}, index={index_str}")
- flash(f"Ошибка удаления: неверный индекс товара '{index_str}'.", 'error')
+ flash(f"Ошибка удаления: неверный индекс товара '{index_str}'. {e}", 'error')
+ return redirect(url_for('admin'))
- # --- Управление Пользователями ---
+
+ # --- Обработка Пользователей ---
elif action == 'add_user':
login = request.form.get('login', '').strip()
- password = request.form.get('password', '').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()
@@ -2088,205 +2158,146 @@ def admin():
if not login or not password:
flash("Логин и пароль пользователя обязательны.", 'error')
- return redirect(url_for('admin'))
- if login in users:
+ elif login in users:
flash(f"Пользователь с логином '{login}' уже существует.", 'error')
- return redirect(url_for('admin'))
-
- # !! ВАЖНО: Хранить пароли в открытом виде НЕБЕЗОПАСНО !!
- # Используйте хеширование для реальных приложений.
- # Пример с passlib:
- # from passlib.hash import pbkdf2_sha256
- # password_hash = pbkdf2_sha256.hash(password)
- users[login] = {
- 'password': password, # ЗАМЕНИТЬ НА: 'password_hash': password_hash
- 'first_name': first_name, 'last_name': last_name,
- 'country': country, 'city': city
- }
- save_users(users)
- logging.info(f"Пользователь '{login}' добавлен.")
- flash(f"Пользователь '{login}' успешно добавлен.", 'success')
+ else:
+ # ВАЖНО: Используйте хеширование паролей в реальном приложении!
+ # from werkzeug.security import generate_password_hash
+ # password_hash = generate_password_hash(password)
+ users[login] = {
+ 'password': password, # ЗАМЕНИТЬ НА 'password_hash': password_hash
+ 'first_name': first_name,
+ 'last_name': last_name,
+ 'country': country,
+ 'city': city
+ }
+ save_users(users) # Сохранение вызовет сортировку и загрузку на HF
+ logging.info(f"Пользователь '{login}' добавлен.")
+ flash(f"Пользователь '{login}' успешно добавлен.", 'success')
+ return redirect(url_for('admin')) # Редирект в любом случае после обработки
elif action == 'delete_user':
login_to_delete = request.form.get('login')
- if login_to_delete == session.get('user'): # Запрет удаления самого себя
- flash("Вы не можете удалить свою учетную запись из админ-панели.", 'error')
- return redirect(url_for('admin'))
-
if login_to_delete and login_to_delete in users:
+ # Не позволяем удалить текущего пользователя (если это админ)
+ # if login_to_delete == session.get('user'):
+ # flash("Вы не можете удалить свою учетную запись.", 'error')
+ # else:
del users[login_to_delete]
save_users(users)
logging.info(f"Пользователь '{login_to_delete}' удален.")
flash(f"Пользователь '{login_to_delete}' удален.", 'success')
+ elif not login_to_delete:
+ flash("Не указан логин пользователя для удаления.", 'error')
else:
- logging.warning(f"Попытка удалить несуществующего или пустого пользователя: {login_to_delete}")
+ logging.warning(f"Попытка удалить несуществующего пользователя: {login_to_delete}")
flash(f"Не удалось найти пользователя '{login_to_delete}' для удаления.", 'error')
+ return redirect(url_for('admin'))
else:
logging.warning(f"Получено неизвестное действие в админ-панели: {action}")
flash(f"Неизвестное действие: {action}", 'warning')
-
- # После ЛЮБОГО успешного POST-запроса делаем редирект GET /admin
- return redirect(url_for('admin'))
+ return redirect(url_for('admin'))
except Exception as e:
- # Ловим любые другие ошибки во время обработки POST
logging.error(f"Критическая ошибка при обработке действия '{action}' в админ-панели: {e}", exc_info=True)
- flash(f"Произошла внутренняя ошибка сервера при выполнении действия '{action}'. Подробности в логе.", 'error')
- return redirect(url_for('admin')) # Редирект даже при ошибке
-
- # --- GET Запрос ---
- # Отображаем админ-панель
- # Сортируем данные для консистентного отображения
- products.sort(key=lambda x: x.get('name', '').lower())
- categories.sort()
- # Сортируем пользователей по логину (ключу словаря)
- sorted_users = dict(sorted(users.items()))
+ flash(f"Произошла серьезная ошибка при выполнении действия '{action}'. Подробности в логе сервера.", 'error')
+ return redirect(url_for('admin')) # Редирект даже при критической ошибке
+ # GET запрос для отображения админ-панели
+ # Данные уже загружены и отсортированы в начале функции
return render_template_string(
- ADMIN_TEMPLATE, # Используем переменную с шаблоном
+ ADMIN_TEMPLATE,
products=products,
categories=categories,
- users=sorted_users, # Передаем отсортированных пользователей
+ users=users, # Передаем отсортированных пользователей
repo_id=REPO_ID,
- currency_code=CURRENCY_CODE,
- session=session # Передаем сессию для отображения имени пользователя
+ currency_code=CURRENCY_CODE
)
# --- Маршруты для принудительной синхронизации ---
@app.route('/force_upload', methods=['POST'])
def force_upload():
- """Принудительная загрузка данных (JSON + фото) на Hugging Face."""
- if not _check_admin_auth():
+ if not is_admin():
+ flash("Доступ запрещен.", 'error')
return redirect(url_for('login'))
- logging.info("Запущена принудительная загрузка данных на Hugging Face...")
- success = False
+ logging.info(f"Запущена принудительная загрузка данных на Hugging Face пользователем {session.get('user')}...")
try:
- # Загружаем JSON файлы
- json_success = upload_db_to_hf() # Загружает DATA_FILE и USERS_FILE
-
- # Загружаем папку с фото, если она есть
- photos_success = True # Считаем успешным, если папки нет или она пуста
- photos_dir_local = 'photos' # Ожидаем, что фото хранятся локально в папке 'photos' (если они вообще есть локально)
-
- # --- Логика загрузки папки с фото (если нужна) ---
- # Закомментировано, т.к. фото загружаются по одному при добавлении/редактировании
- # Если вы хотите синхронизировать всю папку photos:
- # if os.path.isdir(photos_dir_local) and HF_TOKEN_WRITE:
- # logging.info(f"Начинается загрузка папки {photos_dir_local} на HF...")
- # try:
- # api = HfApi()
- # api.upload_folder(
- # folder_path=photos_dir_local,
- # path_in_repo="photos", # Путь в репозитории
- # repo_id=REPO_ID,
- # repo_type="dataset",
- # token=HF_TOKEN_WRITE,
- # commit_message="Sync photos folder",
- # ignore_patterns=["*.tmp", "__pycache__"], # Игнорировать временные файлы
- # delete_patterns=["*.old"] # Пример: удалить старые файлы на HF
- # )
- # logging.info(f"Папка {photos_dir_local} успешно загружена на HF.")
- # photos_success = True
- # except Exception as e_photos:
- # logging.error(f"Ошибка при загрузке папки {photos_dir_local} на HF: {e_photos}", exc_info=True)
- # flash(f"Ошибка при загрузке папки с фотографиями: {e_photos}", 'error')
- # photos_success = False
- # else:
- # logging.info("Локальная папка 'photos' не найдена или отсутствует токен записи, синхронизация фото пропущена.")
- # --- Конец логики загрузки папки с фото ---
-
- success = json_success # Пока успех зависит только от JSON
-
+ success = upload_db_to_hf() # Загружает оба файла
if success:
- flash("Файлы данных успешно загружены на Hugging Face.", 'success')
+ flash("Локальные данные успешно загружены на Hugging Face.", 'success')
else:
- flash("Во время загрузки файлов данных на Hugging Face произошли ошибки. Проверьте логи.", 'error')
-
+ flash("Во время загрузки на Hugging Face возникли ошибки (см. лог). Некоторые файлы могли не загрузиться.", 'warning')
except Exception as e:
logging.error(f"Критическая ошибка при принудительной загрузке: {e}", exc_info=True)
flash(f"Критическая ошибка при загрузке на Hugging Face: {e}", 'error')
- success = False
-
return redirect(url_for('admin'))
@app.route('/force_download', methods=['POST'])
def force_download():
- """Принудительное скачивание JSON данных с Hugging Face."""
- if not _check_admin_auth():
+ if not is_admin():
+ flash("Доступ запрещен.", 'error')
return redirect(url_for('login'))
- logging.info("Запущено принудительное скачивание JSON данных с Hugging Face...")
+ logging.info(f"Запущено принудительное скачивание данных с Hugging Face пользователем {session.get('user')}...")
try:
- # Скачиваем только JSON файлы (DATA_FILE, USERS_FILE)
- success = download_db_from_hf() # Скачивает все SYNC_FILES
-
+ success = download_db_from_hf() # Скачивает оба файла
if success:
- flash("Файлы данных успешно скачаны с Hugging Face. Локальные файлы обновлены.", 'success')
+ flash("Данные успешно скачаны с Hugging Face. Локальные файлы обновлены.", 'success')
else:
- flash("Во время скачивания файлов данных с Hugging Face произошли ошибки. Проверьте логи.", 'error')
-
- # НЕ скачиваем папку с фото принудительно, т.к. фото используются напрямую с HF
- # Если нужно скачивать фото локально:
- # logging.info("Скачивание папки 'photos' не реализовано в принудительном режиме.")
-
+ flash("Не удалось скачать все файлы с Hugging Face (см. лог). Локальные файлы могут быть неактуальны.", 'warning')
except Exception as e:
logging.error(f"Критическая ошибка при принудительном скачивании: {e}", exc_info=True)
flash(f"Критическая ошибка при скачивании с Hugging Face: {e}", 'error')
-
- # Перезагружаем данные в приложении после скачивания
- load_data()
- load_users()
- flash("Данные в приложении перезагружены после скачивания.", 'info')
-
return redirect(url_for('admin'))
# --- Запуск приложения ---
-from datetime import timedelta # Импорт для app.permanent_session_lifetime
if __name__ == '__main__':
- # Начальная загрузка/создание файлов и проверка HF при старте
- logging.info("Инициализация приложения...")
- load_data() # Попытка скачать и загрузить данные товаров
- load_users() # Попытка скачать и загрузить данные пользователей
+ # Устанавливаем время жизни постоянной сессии (например, 7 дней)
+ app.permanent_session_lifetime = timedelta(days=7)
- # Создаем необходимые папки, если их нет (например, для временных файлов)
- os.makedirs('uploads_temp_photos', exist_ok=True)
+ # Попытка загрузить/создать файлы данных при старте
+ logging.info("Инициализация приложения...")
+ load_data()
+ load_users()
+ logging.info("Файлы данных инициализированы.")
- # Запуск потока для периодического бэкапа только если есть токен для записи
+ # Запуск потока для периодического бэкапа, только если есть токен для записи
if HF_TOKEN_WRITE:
- backup_thread = threading.Thread(target=periodic_backup, name="PeriodicBackupThread", daemon=True)
+ backup_thread = threading.Thread(target=periodic_backup, daemon=True, name="PeriodicBackupThread")
backup_thread.start()
+ logging.info("Поток периодического резервного копирования запущен.")
else:
- logging.warning("HF_TOKEN (для записи) не установлен. Периодическое резервное копирование НЕ будет запущено.")
+ logging.warning("Периодическое резервное копирование НЕ будет запущено (HF_TOKEN для записи не установлен).")
- # Определение порта
- # Используем Render's PORT переменную окружения или 7860 по умолчанию
+ # Запуск Flask приложения
+ # Используйте переменную окружения PORT или 7860 по умолчанию
port = int(os.environ.get('PORT', 7860))
- # Устанавливаем хост 0.0.0.0 для доступности извне (важно для Render)
- host = '0.0.0.0'
-
- # Установка времени жизни сессии
- app.permanent_session_lifetime = timedelta(days=30) # Например, 30 дней
+ host = '0.0.0.0' # Слушать на всех интерфейсах
- logging.info(f"Запуск Flask приложения на {host}:{port}")
+ # ВАЖНО: debug=True НЕЛЬЗЯ использовать в продакшене!
+ # Установите debug=False для развертывания.
+ use_debug = os.environ.get('FLASK_DEBUG', 'false').lower() == 'true'
- # Важно: debug=False для продакшена (на Render)
- # Используйте WSGI сервер (например, gunicorn, waitress) для реального деплоя.
- # Пример команды для gunicorn (часто используется на Render):
- # gunicorn --bind 0.0.0.0:10000 app:app
- # Render сам настроит порт через переменную PORT.
- # Для локальной разработки можно оставить app.run()
- # app.run(debug=False, host=host, port=port)
-
- # Рекомендуемый способ запуска для продакшена с Waitress (простой WSGI сервер):
- try:
- from waitress import serve
- serve(app, host=host, port=port)
- except ImportError:
- logging.warning("Waitress не установлен. Запуск через встроенный сервер Flask (НЕ рекомендуется для продакшена).")
- app.run(debug=False, host=host, port=port) # Только для локальной отладки!
+ logging.info(f"Запуск Flask приложения на http://{host}:{port}/ (Debug: {use_debug})")
+ # Для разработки:
+ if use_debug:
+ # use_reloader=False может быть полезен, если возникают проблемы с потоками и релоадером
+ app.run(debug=True, host=host, port=port, use_reloader=True)
+ else:
+ # Для продакшена рекомендуется использовать WSGI сервер, например, Waitress или Gunicorn:
+ # Пример с Waitress (установите waitress: pip install waitress):
+ try:
+ from waitress import serve
+ logging.info("Запуск с использованием Waitress WSGI сервера...")
+ serve(app, host=host, port=port, threads=8) # Увеличьте threads по необходимости
+ except ImportError:
+ logging.warning("Waitress не найден. Запуск с использованием встроенного сервера Flask (НЕ РЕКОМЕНДУЕТСЯ ДЛЯ ПРОДАКШЕНА).")
+ app.run(debug=False, host=host, port=port)
+ # Пример с Gunicorn (Linux/macOS):
+ # gunicorn --bind 0.0.0.0:7860 --workers 4 app:app
\ No newline at end of file
-
-
- {# Отображение Flash сообщений #}
- {% with messages = get_flashed_messages(with_categories=true) %}
- {% if messages %}
- {% for category, message in messages %}
- {% set icon = 'info-circle' %} {# default icon #}
- {% if category == 'success' %}{% set icon = 'check-circle' %}
- {% elif category == 'error' %}{% set icon = 'exclamation-circle' %}
- {% elif category == 'warning' %}{% set icon = 'exclamation-triangle' %}
- {% endif %}
-
- {% endfor %}
- {% endif %}
- {% endwith %}
-
- Админ-панель Soola Cosmetics
- -
-
-
-
- Синхронизация с Hugging Face
- -Резервное копирование на Hugging Face происходит автоматически каждые 30 минут и после сохранения данных. Используйте кнопки для немедленной синхронизации.
-
-
-
-
- {# Колонка Категории #}
-
-
-
-
- Категории
-
-
-
- Добавить категорию
-
-
-
- Существующие категории:
- {% if categories %} -
- {% for category in categories %}
-
- {% else %}
-
- {{ category }}
-
-
- {% endfor %}
- Категорий пока нет.
- {% endif %} - {# Колонка Пользователи #}
-
-
-
- Пользователи
-
-
-
- Добавить пользователя
-
-
-
- Список пользователей:
- {% if users %} -
- {% for login, user_data in users.items() %}
-
- {% else %}
-
-
- {% endfor %}
- Логин: {{ login }}
-Имя: {{ user_data.get('first_name', 'N/A') }} {{ user_data.get('last_name', '') }}
-Локация: {{ user_data.get('city', 'N/A') }}, {{ user_data.get('country', 'N/A') }}
-Пароль: *** (скрыт)
{# Не показываем пароль #} -
-
- {# TODO: Добавить кнопку редактирования пользователя #}
-
- Пользователей пока нет.
- {% endif %} - {# Секция Товары #}
-
-
- Товары
-
-
-
- Добавить новый товар
-
-
-
- Список товаров ({{ products|length }} шт.):
- {% if products %} -
- {% for product in products %}
-
- {% else %}
-
-
- {% endfor %}
-
- {# Превью первого фото #}
-
-
-
- {% if product.get('photos') and product['photos']|length > 0 %}
-
- 
{# Добавил latest=true #}
-
- {% else %}
-
- {% endif %}
-
- {# Информация о товаре #}
- {# Добавил latest=true #}
-
- {% else %}
-
- {% endif %}
-
-
- {{ product['name'] }}
{# Цвет текста заголовка #} -Категория: {{ product.get('category', 'Без категории') }}
-Цена: {{ "%.2f"|format(product['price']) }} {{ currency_code }}
-Описание: {{ product.get('description', 'N/A') }}
- {% set valid_colors = product.get('colors', [])|select('ne', '')|list %} -Цвета/Вар-ты: {{ valid_colors|join(', ') if valid_colors else 'Нет' }}
- {% if product.get('photos') %} -(Фото: {{ product['photos']|length }} шт.)
- {% endif %} -
- {# Основная темно-зеленая кнопка #}
-
-
-
- {# Форма редактирования (скрыта по умолчанию) #}
-
-
- Редактирование: {{ product['name'] }}
- -Товаров пока нет. Добавьте первый товар!
- {% endif %} -