from flask import Flask, render_template_string, request, redirect, url_for, session 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_12345' DATA_FILE = 'data_detobuv.json' USERS_FILE = 'users_detobuv.json' CONFIG_FILE = 'config.json' SYNC_FILES = [DATA_FILE, USERS_FILE, CONFIG_FILE] REPO_ID = "Kgshop/clients" HF_TOKEN_WRITE = os.getenv("HF_TOKEN") HF_TOKEN_READ = os.getenv("HF_TOKEN_READ") WHOLESALE_ADDRESS = "Дордой, рынок Кербен, 9 ряд, 06 бутик" RETAIL_ADDRESS = "Дордой Мир Обуви, номер 150" CURRENCIES = { 'USD': 'Доллар США ($)', 'KGS': 'Кыргызский сом (с)' } logging.basicConfig(level=logging.DEBUG) def load_config(): try: with open(CONFIG_FILE, 'r', encoding='utf-8') as file: config = json.load(file) return config.get('kgs_to_usd', 89.0) except (FileNotFoundError, json.JSONDecodeError): return 89.0 def save_config(kgs_to_usd): with open(CONFIG_FILE, 'w', encoding='utf-8') as file: json.dump({'kgs_to_usd': kgs_to_usd}, file, ensure_ascii=False, indent=4) def convert_price(price_usd, currency): kgs_to_usd = load_config() if currency == 'KGS': return round(price_usd * kgs_to_usd, 2) return round(price_usd, 2) 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: return {'products': [], 'categories': [] if not isinstance(data, list) else data} return data except FileNotFoundError: logging.warning("Локальный файл базы данных не найден после скачивания.") return {'products': [], 'categories': []} except json.JSONDecodeError: logging.error("Ошибка: Невозможно декодировать JSON файл.") return {'products': [], 'categories': []} except RepositoryNotFoundError: logging.error("Репозиторий не найден. Создание локальной базы данных.") 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 load_users(): try: with open(USERS_FILE, 'r', encoding='utf-8') as file: return json.load(file) except FileNotFoundError: return {} except json.JSONDecodeError: return {} def save_users(users): with open(USERS_FILE, 'w', encoding='utf-8') as file: json.dump(users, file, ensure_ascii=False, indent=4) upload_db_to_hf() def upload_db_to_hf(): try: api = HfApi() 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} не найден для загрузки.") except Exception as e: logging.error(f"Ошибка при загрузке резервной копии: {e}") def download_db_from_hf(): try: api = HfApi() for file_name in SYNC_FILES: hf_hub_download( repo_id=REPO_ID, filename=file_name, repo_type="dataset", token=HF_TOKEN_READ, local_dir=".", local_dir_use_symlinks=False ) logging.info(f"Файл {file_name} успешно скачан из Hugging Face.") except RepositoryNotFoundError as e: logging.error(f"Репозиторий не найден: {e}") raise except Exception as e: logging.error(f"Ошибка при скачивании файлов: {e}") raise def periodic_backup(): while True: upload_db_to_hf() time.sleep(800) @app.route('/') def catalog(): data = load_data() products = data['products'] categories = data['categories'] is_authenticated = 'user' in session selected_currency = session.get('currency', 'USD') if is_authenticated else 'USD' kgs_to_usd = load_config() catalog_html = ''' Детская обувь оптом и в розницу

Каталог

{% if is_authenticated %} Добро пожаловать, {{ session['user'] }}!
Выйти {% else %} Войти Регистрация {% endif %}
Опт: {{ wholesale_address }} | Розница: {{ retail_address }}
{% for category in categories %} {% endfor %}
{% for product in products %}
{% if product.get('photos') and product['photos']|length > 0 %}
{{ product['name'] }}
{% endif %}

{{ product['name'] }}

{% if is_authenticated %}
{{ convert_price(product['price'], selected_currency) }} {{ selected_currency }}
{% else %}
Цена доступна после входа
{% endif %}

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

{% if is_authenticated %} {% endif %}
{% endfor %}
''' return render_template_string(catalog_html, products=products, categories=categories, repo_id=REPO_ID, is_authenticated=is_authenticated, wholesale_address=WHOLESALE_ADDRESS, retail_address=RETAIL_ADDRESS, session=session, convert_price=convert_price, selected_currency=selected_currency, currencies=CURRENCIES, kgs_to_usd=kgs_to_usd) @app.route('/product/') def product_detail(index): data = load_data() products = data['products'] is_authenticated = 'user' in session selected_currency = session.get('currency', 'USD') if is_authenticated else 'USD' try: product = products[index] except IndexError: return "Продукт не найден", 404 detail_html = '''

{{ product['name'] }}

{% if product.get('photos') %} {% for photo in product['photos'] %}
{{ product['name'] }}
{% endfor %} {% else %}
No Image
{% endif %}

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

{% if is_authenticated %}

Цена: {{ convert_price(product['price'], selected_currency) }} {{ selected_currency }}

{% else %}

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

{% endif %}

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

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

''' return render_template_string(detail_html, product=product, repo_id=REPO_ID, is_authenticated=is_authenticated, convert_price=convert_price, selected_currency=selected_currency) @app.route('/set_currency', methods=['POST']) def set_currency(): if 'user' in session: currency = request.form.get('currency') if currency in CURRENCIES: session['currency'] = currency return redirect(url_for('catalog')) @app.route('/register', methods=['GET', 'POST']) def register(): if request.method == 'POST': login = request.form.get('login') password = request.form.get('password') first_name = request.form.get('first_name') last_name = request.form.get('last_name') country = request.form.get('country') city = request.form.get('city') purchase_type = request.form.get('purchase_type') if purchase_type == 'retail': return render_template_string('''

Мы продаем только оптом

Назад к регистрации

''') users = load_users() if login in users: return "Пользователь с таким логином уже существует", 400 users[login] = { 'password': password, 'first_name': first_name, 'last_name': last_name, 'country': country, 'city': city, 'purchase_type': purchase_type } save_users(users) session['user'] = login session['country'] = country session['city'] = city session['currency'] = 'USD' return redirect(url_for('catalog')) return render_template_string(''' Регистрация

Регистрация

Уже есть аккаунт? Войти

''') @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]['password'] == password: session['user'] = login session['country'] = users[login]['country'] session['city'] = users[login]['city'] session['currency'] = 'USD' return redirect(url_for('catalog')) return "Неверный логин или пароль", 401 return render_template_string(''' Вход

Вход

Нет аккаунта? Зарегистрироваться

''') @app.route('/auto_login', methods=['POST']) def auto_login(): data = request.get_json() login = data.get('login') users = load_users() if login in users: session['user'] = login session['country'] = users[login]['country'] session['city'] = users[login]['city'] session['currency'] = 'USD' return "OK", 200 return "Ошибка авторизации", 401 @app.route('/logout') def logout(): session.pop('user', None) session.pop('country', None) session.pop('city', None) session.pop('currency', None) return redirect(url_for('catalog')) @app.route('/admin', methods=['GET', 'POST']) def admin(): data = load_data() products = data['products'] categories = data['categories'] users = load_users() kgs_to_usd = load_config() if request.method == 'POST': action = request.form.get('action') if action == 'add_category': category_name = request.form.get('category_name') 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': category_index = int(request.form.get('category_index')) deleted_category = categories.pop(category_index) for product in products: if product.get('category') == deleted_category: product['category'] = 'Без категории' save_data(data) return redirect(url_for('admin')) elif action == 'add': name = request.form.get('name') price = request.form.get('price') description = request.form.get('description') category = request.form.get('category') photos_files = request.files.getlist('photos') colors = request.form.getlist('colors') photos_list = [] if photos_files: for photo in photos_files[:10]: if photo and photo.filename: photo_filename = secure_filename(photo.filename) uploads_dir = 'uploads' os.makedirs(uploads_dir, exist_ok=True) temp_path = os.path.join(uploads_dir, photo_filename) 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"Добавлено фото для товара {name}" ) photos_list.append(photo_filename) if os.path.exists(temp_path): os.remove(temp_path) if not name or not price or not description: return "Ошибка: Заполните все обязательные поля", 400 price = float(price.replace(',', '.')) new_product = { 'name': name, 'price': price, 'description': description, 'category': category if category in categories else 'Без категории', 'photos': photos_list, 'colors': colors if colors else [] } products.append(new_product) save_data(data) return redirect(url_for('admin')) elif action == 'edit': index = int(request.form.get('index')) name = request.form.get('name') price = request.form.get('price') description = request.form.get('description') category = request.form.get('category') photos_files = request.files.getlist('photos') colors = request.form.getlist('colors') if photos_files and any(photo.filename for photo in photos_files): new_photos_list = [] for photo in photos_files[:10]: if photo and photo.filename: photo_filename = secure_filename(photo.filename) uploads_dir = 'uploads' os.makedirs(uploads_dir, exist_ok=True) temp_path = os.path.join(uploads_dir, photo_filename) 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"Обновлено фото для товара {name}" ) new_photos_list.append(photo_filename) if os.path.exists(temp_path): os.remove(temp_path) products[index]['photos'] = new_photos_list products[index]['name'] = name products[index]['price'] = float(price.replace(',', '.')) products[index]['description'] = description products[index]['category'] = category if category in categories else 'Без категории' products[index]['colors'] = colors if colors else [] save_data(data) return redirect(url_for('admin')) elif action == 'delete': index = int(request.form.get('index')) del products[index] save_data(data) return redirect(url_for('admin')) elif action == 'set_exchange_rate': kgs_to_usd = float(request.form.get('kgs_to_usd').replace(',', '.')) save_config(kgs_to_usd) upload_db_to_hf() return redirect(url_for('admin')) elif action == 'delete_user': login = request.form.get('login') if login in users: del users[login] save_users(users) return redirect(url_for('admin')) admin_html = ''' Админ-панель

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

Установка курса KGS к USD

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

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

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

{% for category in categories %}

{{ category }}

{% endfor %}

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

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

{% for product in products %}

{{ product['name'] }}

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

Цена: {{ product['price'] }} USD ({{ convert_price(product['price'], 'KGS') }} KGS)

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

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

{% if product.get('photos') and product['photos']|length > 0 %}
{% for photo in product['photos'] %} {{ product['name'] }} {% endfor %}
{% endif %}
Редактировать
{% for color in product.get('colors', []) %}
{% endfor %}
{% endfor %}

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

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

Логин: {{ login }}

Имя: {{ user['first_name'] }}

Фамилия: {{ user['last_name'] }}

Страна: {{ user['country'] }}

Город: {{ user['city'] }}

{% endfor %}
''' return render_template_string(admin_html, products=products, categories=categories, repo_id=REPO_ID, users=users, kgs_to_usd=kgs_to_usd, convert_price=convert_price) @app.route('/backup', methods=['POST']) def backup(): upload_db_to_hf() return "Резервная копия создана.", 200 @app.route('/download', methods=['GET']) def download(): download_db_from_hf() return "База данных скачана.", 200 if __name__ == '__main__': 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)