from flask import Flask, render_template_string, request, redirect, url_for, send_from_directory 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 import urllib.parse app = Flask(__name__) DATA_FILE = 'dataasdem.json' PHOTOS_DIR = 'photos' REPO_ID = "flpolprojects/dataasdem" HF_TOKEN_WRITE = os.getenv("HF_TOKEN") HF_TOKEN_READ = os.getenv("HF_TOKEN_READ") LOGO_URL = "https://cdn-avatars.huggingface.co/v1/production/uploads/67b22aaeae9b6a59f1cfb849/NQvBksXzJItYt6hfFjyaB.jpeg" logging.basicConfig(level=logging.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("Данные успешно загружены из JSON") if not isinstance(data, dict) or 'products' not in data or 'categories' not in data: if isinstance(data, list): return {'products': data, 'categories': []} else: logging.warning("Неожиданный формат данных в JSON.") return {'products': [], 'categories': []} return data except FileNotFoundError: logging.warning(f"Локальный файл базы данных ({DATA_FILE}) не найден после скачивания.") return {'products': [], 'categories': []} except json.JSONDecodeError: logging.error("Ошибка: Невозможно декодировать JSON файл.") return {'products': [], 'categories': []} except RepositoryNotFoundError: logging.error(f"Репозиторий '{REPO_ID}' не найден на Hugging Face. Создание локальной базы данных.") return {'products': [], 'categories': []} except HfHubHTTPError as e: logging.error(f"Ошибка HTTP при скачивании из Hugging Face: {e}") logging.warning(f"Попытка загрузить локальный файл '{DATA_FILE}' если существует.") try: with open(DATA_FILE, 'r', encoding='utf-8') as file: data = json.load(file) logging.info("Данные успешно загружены из локального JSON после ошибки HF.") if not isinstance(data, dict) or 'products' not in data or 'categories' not in data: if isinstance(data, list): return {'products': data, 'categories': []} else: logging.warning("Неожиданный формат данных в локальном JSON.") return {'products': [], 'categories': []} return data except FileNotFoundError: logging.warning(f"Локальный файл '{DATA_FILE}' также не найден.") return {'products': [], 'categories': []} except json.JSONDecodeError: logging.error("Ошибка: Невозможно декодировать локальный JSON файл.") 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("Данные успешно сохранены в JSON") upload_db_to_hf() except Exception as e: logging.error(f"Ошибка при сохранении данных: {e}") raise def upload_db_to_hf(): if not HF_TOKEN_WRITE: logging.warning("HF_TOKEN не установлен. Пропуск загрузки на Hugging Face.") return try: api = HfApi() api.upload_file( path_or_fileobj=DATA_FILE, path_in_repo=DATA_FILE, repo_id=REPO_ID, repo_type="dataset", token=HF_TOKEN_WRITE, commit_message=f"Автоматическое резервное копирование базы данных {datetime.now().strftime('%Y-%m-%d %H:%M:%S')}" ) logging.info("Резервная копия JSON базы успешно загружена на Hugging Face.") except Exception as e: logging.error(f"Ошибка при загрузке резервной копии на Hugging Face: {e}") def download_db_from_hf(): if not HF_TOKEN_READ: logging.warning("HF_TOKEN_READ не установлен. Пропуск скачивания из Hugging Face.") return try: hf_hub_download( repo_id=REPO_ID, filename=DATA_FILE, repo_type="dataset", token=HF_TOKEN_READ, local_dir=".", local_dir_use_symlinks=False ) logging.info("JSON база успешно скачана из Hugging Face.") except RepositoryNotFoundError: logging.warning(f"Репозиторий '{REPO_ID}' не найден. Скачивание невозможно.") raise except Exception as e: logging.error(f"Ошибка при скачивании JSON базы из Hugging Face: {e}") raise def periodic_backup(): while True: upload_db_to_hf() time.sleep(800) catalog_html = ''' Asdem - нижнее белье оптом

Каталог

{% for category in categories %} {% endfor %}
{% for product in products %}
{% if product.get('photos') and product['photos']|length > 0 %}
{{ product['name']|e }}
{% endif %}

{{ product['name']|e }}

{{ product['price'] }} с

{{ product['description'][:100] }}{% if product['description']|length > 100 %}...{% endif %}

{% endfor %}
''' detail_html = '''

{{ product['name']|e }}

{% if product.get('photos') %} {% for photo in product['photos'] %}
{{ product['name']|e }}
{% endfor %} {% else %}
No Image
{% endif %}
{% if product.get('photos') and product['photos']|length > 1 %}
{% endif %}

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

Цена: {{ product['price'] }} с

Описание: {{ product['description']|e }}

Доступные цвета: {{ product.get('colors', ['Нет цветов'])|join(', ')|e }}

''' admin_html = ''' Админ-панель

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

Добавление товара

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

Список категорий

{% for category in categories %}

{{ category|e }}

{% endfor %}

Управление базой данных

Список товаров ({{ products|length }})

{% for product in products %}

{{ product['name']|e }}

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

Цена: {{ product['price'] }} с

Описание: {{ product['description'][:150] }}{% if product['description']|length > 150 %}...{% endif %}

Цвета: {{ product.get('colors', ['Нет цветов'])|join(', ')|e }}

{% if product.get('photos') and product['photos']|length > 0 %}
{% for photo in product['photos'] %} {{ product['name']|e }} {% endfor %}
{% endif %}
Редактировать
{% for color in product.get('colors', []) %}
{% endfor %}
{% endfor %}
''' @app.route('/') def catalog(): data = load_data() products_for_display = sorted(data.get('products', []), key=lambda x: x.get('added_at', ''), reverse=True) categories = data.get('categories', []) return render_template_string(catalog_html, products=products_for_display, categories=categories, repo_id=REPO_ID, LOGO_URL=LOGO_URL) @app.route('/product_by_name/') def product_detail_by_name(product_name): data = load_data() product = next((p for p in data.get('products', []) if p['name'] == product_name), None) if product: return render_template_string(detail_html, product=product, repo_id=REPO_ID) else: return "Продукт не найден", 404 @app.route('/admin', methods=['GET', 'POST']) def admin(): data = load_data() products = data.get('products', []) categories = data.get('categories', []) if request.method == 'POST': action = request.form.get('action') 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) return redirect(url_for('admin')) return "Ошибка: Категория уже существует или не указано название", 400 elif action == 'delete_category': try: category_name_to_delete = request.form.get('category_name_to_delete') if category_name_to_delete in categories: categories.remove(category_name_to_delete) for product in products: if product.get('category') == category_name_to_delete: product['category'] = 'Без категории' save_data(data) return redirect(url_for('admin')) else: return "Ошибка: Категория не найдена.", 400 except Exception as e: logging.error(f"Ошибка при удалении категории: {e}") return f"Ошибка при удалении категории: {e}", 500 elif action == 'add': name = request.form.get('name').strip() price_str = request.form.get('price').strip() 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()] try: price = float(price_str.replace(',', '.')) except ValueError: return "Ошибка: Неверный формат цены", 400 if not name or price is None or not description: return "Ошибка: Заполните все обязательные поля", 400 photos_list = [] if photos_files: for photo in photos_files: if photo and photo.filename: original_filename = secure_filename(photo.filename) timestamp = datetime.now().strftime("%Y%m%d%H%M%S%f") photo_filename = f"{timestamp}_{original_filename}" uploads_dir = 'uploads' os.makedirs(uploads_dir, exist_ok=True) temp_path = os.path.join(uploads_dir, photo_filename) try: photo.save(temp_path) api = HfApi() 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"Добавлено фото '{original_filename}' для товара '{name}'" ) photos_list.append(photo_filename) except Exception as e: logging.error(f"Ошибка при загрузке фото {original_filename} на HF: {e}") pass finally: if os.path.exists(temp_path): os.remove(temp_path) new_product = { 'name': name, 'price': price, 'description': description, 'category': category if category in categories else 'Без категории', 'photos': photos_list, 'colors': colors, 'added_at': datetime.now().isoformat() } products.append(new_product) save_data(data) return redirect(url_for('admin')) elif action == 'edit': try: index = int(request.form.get('index')) if 0 <= index < len(products): product_to_edit = products[index] name = request.form.get('name').strip() price_str = request.form.get('price').strip() 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()] try: price = float(price_str.replace(',', '.')) except ValueError: return "Ошибка: Неверный формат цены", 400 if not name or price is None or not description: return "Ошибка: Заполните все обязательные поля для редактирования", 400 if photos_files and any(photo.filename for photo in photos_files): new_photos_list = [] for photo in photos_files: if photo and photo.filename: original_filename = secure_filename(photo.filename) timestamp = datetime.now().strftime("%Y%m%d%H%M%S%f") photo_filename = f"{timestamp}_{original_filename}" uploads_dir = 'uploads' os.makedirs(uploads_dir, exist_ok=True) temp_path = os.path.join(uploads_dir, photo_filename) try: photo.save(temp_path) api = HfApi() 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"Обновлено/добавлено фото '{original_filename}' для товара '{name}'" ) new_photos_list.append(photo_filename) except Exception as e: logging.error(f"Ошибка при загрузке фото {original_filename} на HF во время редактирования: {e}") pass finally: if os.path.exists(temp_path): os.remove(temp_path) product_to_edit['photos'] = new_photos_list product_to_edit['name'] = name product_to_edit['price'] = price product_to_edit['description'] = description product_to_edit['category'] = category if category in categories else 'Без категории' product_to_edit['colors'] = colors save_data(data) return redirect(url_for('admin')) else: return "Ошибка: Товар с указанным индексом не найден.", 404 except ValueError: return "Ошибка: Неверный индекс товара.", 400 except Exception as e: logging.error(f"Ошибка при редактировании товара: {e}") return f"Ошибка при редактировании товара: {e}", 500 elif action == 'delete': try: index = int(request.form.get('index')) if 0 <= index < len(products): del products[index] save_data(data) return redirect(url_for('admin')) else: return "Ошибка: Товар с указанным индексом не найден.", 404 except ValueError: return "Ошибка: Неверный индекс товара.", 400 except Exception as e: logging.error(f"Ошибка при удалении товара: {e}") return f"Ошибка при удалении товара: {e}", 500 return render_template_string(admin_html, products=products, categories=categories, repo_id=REPO_ID, LOGO_URL=LOGO_URL) @app.route('/backup', methods=['POST']) def backup(): try: upload_db_to_hf() return "Резервная копия базы данных успешно создана на Hugging Face.", 200 except Exception as e: return f"Ошибка при создании резервной копии: {e}", 500 @app.route('/download', methods=['GET']) def download(): try: download_db_from_hf() return "База данных успешно скачана с Hugging Face.", 200 except Exception as e: return f"Ошибка при скачивании базы данных: {e}", 500 if __name__ == '__main__': os.makedirs('uploads', exist_ok=True) backup_thread = threading.Thread(target=periodic_backup, daemon=True) backup_thread.start() try: load_data() except Exception as e: logging.error(f"Не удалось выполнить начальную загрузку базы данных при запуске: {e}") app.run(debug=True, host='0.0.0.0', port=7860)