Update app.py

app.py

@@ -8,9 +8,10 @@ import threading
 import time
 from datetime import datetime
 from huggingface_hub import HfApi, hf_hub_download
-from huggingface_hub.utils import RepositoryNotFoundError
+from huggingface_hub.utils import RepositoryNotFoundError, HfHubHTTPError
 from werkzeug.utils import secure_filename
 from dotenv import load_dotenv
+import filelock # Добавлен импорт
 
 load_dotenv()
 
@@ -18,6 +19,7 @@ app = Flask(__name__)
 app.secret_key = 'your_unique_secret_key_soola_cosmetics_67890'
 DATA_FILE = 'data_soola.json'
 USERS_FILE = 'users_soola.json'
+LOCK_FILE_SUFFIX = ".lock"
 
 SYNC_FILES = [DATA_FILE, USERS_FILE]
 
@@ -32,104 +34,132 @@ CURRENCY_NAME = 'Кыргызский сом (с)'
 
 logging.basicConfig(level=logging.INFO, format='%(asctime)s - %(levelname)s - %(message)s')
 
+# --- Helper for file locking ---
+def get_lock(filename):
+    return filelock.FileLock(filename + LOCK_FILE_SUFFIX, timeout=10) # 10 секунд таймаут
+
+# --- Modified Download Function with Retries ---
+def download_db_from_hf(specific_file=None, max_retries=3, retry_delay=5):
+    if not HF_TOKEN_READ:
+        logging.warning("Переменная окружения HF_TOKEN_READ не установлена. Попытка скачивания с Hugging Face без токена.")
+
+    files_to_download = [specific_file] if specific_file else SYNC_FILES
+    logging.info(f"Начало скачивания файлов {files_to_download} с HF репозитория {REPO_ID}...")
+    all_successful = True
+
+    for file_name in files_to_download:
+        download_successful = False
+        for attempt in range(max_retries):
+            try:
+                logging.info(f"Попытка {attempt + 1}/{max_retries} скачивания файла {file_name}...")
+                lock = get_lock(file_name)
+                with lock:
+                    local_path = hf_hub_download(
+                        repo_id=REPO_ID,
+                        filename=file_name,
+                        repo_type="dataset",
+                        token=HF_TOKEN_READ,
+                        local_dir=".",
+                        local_dir_use_symlinks=False,
+                        force_download=True,
+                        resume_download=False # Добавлено для большей надежности при перезаписи
+                    )
+                logging.info(f"Файл {file_name} успешно скачан из Hugging Face в {local_path}.")
+                download_successful = True
+                break # Выход из цикла ретраев при успехе
+            except RepositoryNotFoundError:
+                 logging.error(f"Репозиторий {REPO_ID} не найден на Hugging Face. Скачивание прервано.")
+                 all_successful = False
+                 return False # Нет смысла ретраить, если репо нет
+            except HfHubHTTPError as e:
+                 if "404" in str(e) or "not found" in str(e).lower():
+                     logging.warning(f"Файл {file_name} не найден в репозитории {REPO_ID} (попытка {attempt + 1}/{max_retries}). Пропуск скачивания этого файла.")
+                     # Не считаем это полным провалом, просто файла нет на HF
+                     download_successful = True # Считаем "успешным" в плане отсутствия ошибки скачивания
+                     break
+                 else:
+                    logging.error(f"Ошибка HTTP при скачивании {file_name} (попытка {attempt + 1}/{max_retries}): {e}")
+            except Exception as e:
+                logging.error(f"Ошибка при скачивании файла {file_name} с Hugging Face (попытка {attempt + 1}/{max_retries}): {e}", exc_info=True)
+
+            if attempt < max_retries - 1:
+                logging.info(f"Ожидание {retry_delay} секунд перед следующей попыткой...")
+                time.sleep(retry_delay)
+            else:
+                 logging.error(f"Не удалось скачать файл {file_name} после {max_retries} попыток.")
+                 all_successful = False
+
+        if not download_successful:
+             all_successful = False # Помечаем общую неуспешность если хотя бы один файл не скачался
+
+    logging.info(f"Скачивание файлов с HF завершено. Общий результат: {'Успех' if all_successful else 'Неудача'}.")
+    return all_successful
+
+
+# --- Modified Load Functions ---
 def load_data():
+    file_path = DATA_FILE
+    logging.info(f"Попытка загрузки данных из {file_path}...")
+    download_success = download_db_from_hf(specific_file=file_path)
+
+    if download_success:
+        logging.info(f"С��ачивание {file_path} с HF успешно (или файл отсутствовал на HF). Попытка загрузки локальной версии.")
+    else:
+        logging.warning(f"Не удалось скачать {file_path} с 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):
-                 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:
-            if not os.path.exists(DATA_FILE):
-                with open(DATA_FILE, 'w', encoding='utf-8') as f: json.dump({'products': [], 'categories': []}, f)
-                logging.info(f"Создан пустой файл {DATA_FILE}")
-                return {'products': [], 'categories': []}
-            else:
-                 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) as e:
-             logging.warning(f"Файл {DATA_FILE} не найден локально и ошибка при доступе к репозиторию HF ({e}). Создание пустой структуры.")
-             if not os.path.exists(DATA_FILE):
-                 with open(DATA_FILE, 'w', encoding='utf-8') as f: json.dump({'products': [], 'categories': []}, f)
+        lock = get_lock(file_path)
+        with lock:
+            with open(file_path, 'r', encoding='utf-8') as file:
+                data = json.load(file)
+        logging.info(f"Данные успешно загружены из локального файла {file_path}")
+        if not isinstance(data, dict):
+             logging.warning(f"{file_path} не является словарем. Инициализация пустой структурой.")
              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': []}
+        if 'products' not in data: data['products'] = []
+        if 'categories' not in data: data['categories'] = []
+        return data
+    except FileNotFoundError:
+        logging.critical(f"КРИТИЧЕСКАЯ ОШИБКА: Файл {file_path} не найден локально И не удалось его скачать с HF. Инициализация пустой структурой.")
+        # Не создаем пустой файл здесь!
+        return {'products': [], 'categories': []}
     except json.JSONDecodeError:
-        logging.error(f"Ошибка декодирования JSON в локальном {DATA_FILE}. Файл может быть поврежден. Возврат пустой структуры.")
+        logging.error(f"Ошибка декодирования JSON в локальном {file_path}. Файл может быть поврежден. Возврат пустой структуры.")
         return {'products': [], 'categories': []}
     except Exception as e:
-        logging.error(f"Неизвестная ошибка при загрузке данных ({DATA_FILE}): {e}", exc_info=True)
+        logging.error(f"Неизвестная ошибка при загрузке данных ({file_path}): {e}", exc_info=True)
         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(specific_file=DATA_FILE)
-    except Exception as e:
-        logging.error(f"Ошибка при сохранении данных в {DATA_FILE}: {e}", exc_info=True)
-
 def load_users():
+    file_path = USERS_FILE
+    logging.info(f"Попытка загрузки данных пользователей из {file_path}...")
+    download_success = download_db_from_hf(specific_file=file_path)
+
+    if download_success:
+        logging.info(f"Скачивание {file_path} с HF успешно (или файл отсутствовал на HF). Попытка загрузки локальной версии.")
+    else:
+        logging.warning(f"Не удалось скачать {file_path} с HF после всех попыток. Попытка загрузить существующий локальный файл (если есть).")
+
     try:
-        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 {}
+        lock = get_lock(file_path)
+        with lock:
+            with open(file_path, 'r', encoding='utf-8') as file:
+                users = json.load(file)
+        logging.info(f"Данные пользователей успешно загружены из локального файла {file_path}")
+        return users if isinstance(users, dict) else {}
     except FileNotFoundError:
-        logging.warning(f"Локальный файл {USERS_FILE} не найден. Попытка скачать с HF.")
-        try:
-            download_db_from_hf(specific_file=USERS_FILE)
-            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. Создание пустого файла.")
-             with open(USERS_FILE, 'w', encoding='utf-8') as f: json.dump({}, f)
-             return {}
-        except json.JSONDecodeError:
-             logging.error(f"Ошибка декодирования JSON в {USERS_FILE} после скачивания.")
-             return {}
-        except Exception as e:
-             logging.error(f"Неизвестная ошибка при загрузке пользователей после скачивания: {e}", exc_info=True)
-             return {}
+        logging.critical(f"КРИТИЧЕСКАЯ ОШИБКА: Файл {file_path} не найден локально И не удалось его скачать с HF. Инициализация пустым словарем.")
+        # Не создаем пустой файл здесь!
+        return {}
     except json.JSONDecodeError:
-        logging.error(f"Ошибка декодирования JSON в локальном {USERS_FILE}. Файл может быть поврежден. Возврат пустого словаря.")
+        logging.error(f"Ошибка декодирования JSON в локальном {file_path}. Файл может быть поврежден. Возврат пустого словаря.")
         return {}
     except Exception as e:
-        logging.error(f"Неизвестная ошибка при загрузке пользователей ({USERS_FILE}): {e}", exc_info=True)
+        logging.error(f"Неизвестная ошибка при загрузке пользователей ({file_path}): {e}", exc_info=True)
         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(specific_file=USERS_FILE)
-    except Exception as e:
-        logging.error(f"Ошибка при сохранении данных пользователей в {USERS_FILE}: {e}", exc_info=True)
-
-
+# --- Modified Upload Function with Safety Check ---
 def upload_db_to_hf(specific_file=None):
     if not HF_TOKEN_WRITE:
         logging.warning("Переменная окружения HF_TOKEN (для записи) не установлена. Загрузка на Hugging Face пропущена.")
@@ -141,15 +171,39 @@ def upload_db_to_hf(specific_file=None):
 
         for file_name in files_to_upload:
             if os.path.exists(file_name):
+                # --- Safety Check ---
                 try:
-                    api.upload_file(
-                        path_or_fileobj=file_name,
-                        path_in_repo=file_name,
-                        repo_id=REPO_ID,
-                        repo_type="dataset",
-                        token=HF_TOKEN_WRITE,
-                        commit_message=f"Sync {file_name} {datetime.now().strftime('%Y-%m-%d %H:%M:%S')}"
-                    )
+                    lock = get_lock(file_name)
+                    with lock: # Блокируем чтение на время проверки
+                        with open(file_name, 'r', encoding='utf-8') as f:
+                            content_check = json.load(f)
+
+                    if file_name == DATA_FILE and content_check == {'products': [], 'categories': []}:
+                        logging.warning(f"ПРЕДОТВРАЩЕНИЕ ЗАГРУЗКИ: Локальный файл {file_name} пуст (содержит только {'{products: [], categories: []}'}). Загрузка на HF пропущена.")
+                        continue # Пропустить этот файл
+                    if file_name == USERS_FILE and content_check == {}:
+                         logging.warning(f"ПРЕДОТВРАЩЕНИЕ ЗАГРУЗКИ: Локальный файл {file_name} пуст (содержит только {'{}'}). Загрузка на HF пропущена.")
+                         continue # Пропустить этот файл
+
+                except json.JSONDecodeError:
+                    logging.error(f"Ошибка чтения JSON в локальном файле {file_name} перед загрузкой. Загрузка на HF для этого файла пропущена.")
+                    continue
+                except Exception as e:
+                    logging.error(f"Ошибка при проверке файла {file_name} перед загрузкой: {e}. Загрузка на HF для этого файла пропущена.")
+                    continue
+                # --- End Safety Check ---
+
+                try:
+                    lock = get_lock(file_name)
+                    with lock: # Блокируем на время чтения для загрузки
+                        api.upload_file(
+                            path_or_fileobj=file_name,
+                            path_in_repo=file_name,
+                            repo_id=REPO_ID,
+                            repo_type="dataset",
+                            token=HF_TOKEN_WRITE,
+                            commit_message=f"Sync {file_name} {datetime.now().strftime('%Y-%m-%d %H:%M:%S')}"
+                        )
                     logging.info(f"Файл {file_name} успешно загружен на Hugging Face.")
                 except Exception as e:
                      logging.error(f"Ошибка при загрузке файла {file_name} на Hugging Face: {e}")
@@ -159,52 +213,53 @@ def upload_db_to_hf(specific_file=None):
     except Exception as e:
         logging.error(f"Общая ошибка при инициализации или загрузке на Hugging Face: {e}", exc_info=True)
 
-def download_db_from_hf(specific_file=None):
-    if not HF_TOKEN_READ:
-        logging.warning("Переменная окружения HF_TOKEN_READ не установлена. Попытка скачивания с Hugging Face без токена (может не сработать для приватных репо).")
 
-    files_to_download = [specific_file] if specific_file else SYNC_FILES
-    logging.info(f"Начало скачивания файлов {files_to_download} с HF репозитория {REPO_ID}...")
-    downloaded_files_count = 0
+# --- Modified Save Functions ---
+def save_data(data):
     try:
-        for file_name in files_to_download:
-            try:
-                local_path = hf_hub_download(
-                    repo_id=REPO_ID,
-                    filename=file_name,
-                    repo_type="dataset",
-                    token=HF_TOKEN_READ,
-                    local_dir=".",
-                    local_dir_use_symlinks=False,
-                    force_download=True
-                )
-                logging.info(f"Файл {file_name} успешно скачан из Hugging Face в {local_path}.")
-                downloaded_files_count += 1
-            except RepositoryNotFoundError:
-                 logging.error(f"Репозиторий {REPO_ID} не найден на Hugging Face. Скачивание прервано.")
-                 break
-            except Exception as e:
-                if "404" in str(e) or isinstance(e, FileNotFoundError):
-                     logging.warning(f"Файл {file_name} не найден в репозитории {REPO_ID} или ошибка доступа. Пропуск скачивания этого файла.")
-                else:
-                    logging.error(f"Ошибка при скачивании файла {file_name} с Hugging Face: {e}", exc_info=True)
-        logging.info(f"Скачивание файлов с HF завершено. Скачано файлов: {downloaded_files_count}/{len(files_to_download)}.")
-    except RepositoryNotFoundError:
-        logging.error(f"Репозиторий {REPO_ID} не найден на Hugging Face. Скачивание не выполнено.")
+        lock = get_lock(DATA_FILE)
+        with lock:
+            with open(DATA_FILE, 'w', encoding='utf-8') as file:
+                json.dump(data, file, ensure_ascii=False, indent=4)
+        logging.info(f"Данные успешно сохранены в {DATA_FILE}")
+        # Загрузка на HF вызывается после сохранения, но с проверкой внутри upload_db_to_hf
+        upload_db_to_hf(specific_file=DATA_FILE)
+    except filelock.Timeout:
+        logging.error(f"Не удалось получить блокировку для сохранения файла {DATA_FILE}. Сохранение и загрузка на HF пропущены.")
+        flash("Внимание: Не удалось сохранить изменения из-за блокировки файла. Попробуйте позже.", "error")
+    except Exception as e:
+        logging.error(f"Ошибка при сохранении данных в {DATA_FILE}: {e}", exc_info=True)
+
+def save_users(users):
+    try:
+        lock = get_lock(USERS_FILE)
+        with lock:
+            with open(USERS_FILE, 'w', encoding='utf-8') as file:
+                json.dump(users, file, ensure_ascii=False, indent=4)
+        logging.info(f"Данные пользователей успешно сохранены в {USERS_FILE}")
+        # Загрузка на HF вызывается после сохранения, но с проверкой внутри upload_db_to_hf
+        upload_db_to_hf(specific_file=USERS_FILE)
+    except filelock.Timeout:
+        logging.error(f"Не удалось получить блокировку для сохранения файла {USERS_FILE}. Сохранение и загрузка на HF пропущены.")
+        flash("Внимание: Не удалось сохранить изменения пользователя из-за блокировки файла. Попробуйте позже.", "error")
     except Exception as e:
-        logging.error(f"Общая ошибка при попытке скачивания с Hugging Face: {e}", exc_info=True)
+        logging.error(f"Ошибка при сохранении данных пользователей в {USERS_FILE}: {e}", exc_info=True)
 
 
+# --- Periodic Backup ---
 def periodic_backup():
     backup_interval = 1800
     logging.info(f"Настройка периодического резервного копирования каждые {backup_interval} секунд.")
     while True:
         time.sleep(backup_interval)
         logging.info("Запуск периодического резервного копирования...")
+        # upload_db_to_hf уже содержит проверку на пустые файлы
         upload_db_to_hf()
         logging.info("Периодическое резервное копирование завершено.")
 
 
+# --- Flask Routes (Без изменений в HTML/JS, только вызовы функций) ---
+
 @app.route('/')
 def catalog():
     data = load_data()
@@ -322,7 +377,11 @@ def catalog():
             body.dark-mode .no-results-message { color: #8aa39a; }
             .top-product-indicator { position: absolute; top: 8px; right: 8px; background-color: rgba(255, 215, 0, 0.8); color: #333; padding: 2px 6px; font-size: 0.7rem; border-radius: 4px; font-weight: bold; z-index: 10; backdrop-filter: blur(2px); }
             .product { position: relative; }
-
+            .flash-messages { list-style: none; padding: 0; margin: 0 0 20px 0; }
+            .flash-messages li { padding: 10px 15px; margin-bottom: 10px; border-radius: 6px; font-size: 0.9rem;}
+            .flash-messages .success { background-color: #d4edda; color: #155724; border: 1px solid #c3e6cb;}
+            .flash-messages .error { background-color: #f8d7da; color: #721c24; border: 1px solid #f5c6cb;}
+            .flash-messages .warning { background-color: #fff3cd; color: #856404; border: 1px solid #ffeeba; }
         </style>
     </head>
     <body>
@@ -342,6 +401,16 @@ def catalog():
                 </button>
             </div>
 
+            {% with messages = get_flashed_messages(with_categories=true) %}
+                {% if messages %}
+                    <ul class="flash-messages">
+                    {% for category, message in messages %}
+                        <li class="{{ category }}">{{ message }}</li>
+                    {% endfor %}
+                    </ul>
+                {% endif %}
+            {% endwith %}
+
             <div class="store-address">Наш адрес: {{ store_address }}</div>
 
             <div class="filters-container">
@@ -486,7 +555,7 @@ def catalog():
                             window.location.reload();
                         } else {
                             response.text().then(text => console.log(`Auto-login failed: ${response.status} ${text}`));
-                            localStorage.removeItem('soolaUser');
+                            localStorage.removeItem('soolaUser'); // Remove invalid stored user
                         }
                     })
                     .catch(error => {
@@ -583,6 +652,11 @@ def catalog():
                 } else {
                     colorSelect.style.display = 'none';
                     if(colorLabel) colorLabel.style.display = 'none';
+                    // Добавляем один пустой option, чтобы значение select было пустым
+                    const option = document.createElement('option');
+                    option.value = '';
+                    option.text = '';
+                    colorSelect.appendChild(option);
                 }
 
                 document.getElementById('quantityInput').value = 1;
@@ -714,47 +788,49 @@ def catalog():
                     return;
                 }
                 let total = 0;
-                let orderText = "🛍️ *Новый Заказ от Soola Cosmetics* 🛍️";
-                orderText += "----------------------------------------";
-                orderText += "*Детали заказа:*%0A";
-                orderText += "---------------------------------------- ";
+                let orderText = "🛍️ *Новый Заказ от Soola Cosmetics*\n"; // Используем \n для переноса строки в тексте
+                orderText += "----------------------------------------\n";
+                orderText += "*Детали заказа:*\n";
+                orderText += "----------------------------------------\n";
                 cart.forEach((item, index) => {
                     const itemTotal = item.price * item.quantity;
                     total += itemTotal;
                     const colorText = item.color !== 'N/A' ? ` (${item.color})` : '';
-                    orderText += `${index + 1}. *${item.name}*${colorText} `;
-                    orderText += `   Кол-во: ${item.quantity} `;
-                    orderText += `   Цена: ${item.price.toFixed(2)} ${currencyCode} `;
-                    orderText += `   *Сумма: ${itemTotal.toFixed(2)} ${currencyCode}  `;
+                    orderText += `${index + 1}. *${item.name}*${colorText}\n`;
+                    orderText += `   Кол-во: ${item.quantity}\n`;
+                    orderText += `   Цена: ${item.price.toFixed(2)} ${currencyCode}\n`;
+                    orderText += `   *Сумма: ${itemTotal.toFixed(2)} ${currencyCode}*\n\n`;
                 });
-                orderText += "----------------------------------------";
-                orderText += `*ИТОГО: ${total.toFixed(2)} ${currencyCode} `;
-                orderText += "---------------------------------------- ";
+                orderText += "----------------------------------------\n";
+                orderText += `*ИТОГО: ${total.toFixed(2)} ${currencyCode}*\n`;
+                orderText += "----------------------------------------\n\n";
 
                 if (userInfo && userInfo.login) {
-                     orderText += "*Данные клиента: ";
-                     orderText += `Имя: ${userInfo.first_name || ''} ${userInfo.last_name || ''} `;
-                     orderText += `Логин: ${userInfo.login} `;
+                     orderText += "*Данные клиента:*\n";
+                     orderText += `Имя: ${userInfo.first_name || ''} ${userInfo.last_name || ''}\n`;
+                     orderText += `Логин: ${userInfo.login}\n`;
                      if (userInfo.phone) {
-                         orderText += `Телефон: ${userInfo.phone}%0A`;
+                         orderText += `Телефон: ${userInfo.phone}\n`;
                      }
-                     orderText += `Страна: ${userInfo.country || 'Не указана'} `;
-                     orderText += `Город: ${userInfo.city || 'Не указан'} `;
+                     orderText += `Страна: ${userInfo.country || 'Не указана'}\n`;
+                     orderText += `Город: ${userInfo.city || 'Не указан'}\n`;
                 } else {
-                     orderText += "*Клиент не авторизован ";
+                     orderText += "*Клиент не авторизован*\n";
                 }
-                orderText += "----------------------------------------  ";
+                orderText += "----------------------------------------\n\n";
 
                 const now = new Date();
                 const dateTimeString = now.toLocaleString('ru-RU', { dateStyle: 'short', timeStyle: 'short' });
-                orderText += `Дата заказа: ${dateTimeString} `;
+                orderText += `Дата заказа: ${dateTimeString}\n`;
                 orderText += `_Сформировано автоматически_`;
 
-                const whatsappNumber = "996997703090";
+                const whatsappNumber = "996997703090"; // Убедитесь, что номер правильный
+                // Заменяем \n на %0A для URL-кодирования переносов строк
                 const whatsappUrl = `https://api.whatsapp.com/send?phone=${whatsappNumber}&text=${encodeURIComponent(orderText)}`;
                 window.open(whatsappUrl, '_blank');
             }
 
+
             function filterProducts() {
                 const searchTerm = document.getElementById('search-input').value.toLowerCase().trim();
                 const activeCategoryButton = document.querySelector('.category-filter.active');
@@ -807,7 +883,7 @@ def catalog():
                          filterProducts();
                      });
                  });
-                 filterProducts(); // Initial filter on load
+                 filterProducts();
              }
 
              function showNotification(message, duration = 3000) {
@@ -917,8 +993,9 @@ def product_detail(index):
             {% endif %}
             <p><strong>Описание:</strong><br> {{ product.get('description', 'Описание отсутствует.')|replace('\\n', '<br>')|safe }}</p>
             {% set colors = product.get('colors', []) %}
-            {% if colors and colors|select('ne', '')|list|length > 0 %}
-                <p><strong>Доступные цвета/варианты:</strong> {{ colors|select('ne', '')|join(', ') }}</p>
+            {% set valid_colors = colors|select('ne', '')|list %}
+            {% if valid_colors|length > 0 %}
+                <p><strong>Доступные цвета/варианты:</strong> {{ valid_colors|join(', ') }}</p>
             {% endif %}
         </div>
     </div>
@@ -1040,6 +1117,7 @@ def auto_login():
         return "OK", 200
     else:
         logging.warning(f"Неудачная попытка автоматического входа для несуществующего пользователя {login}.")
+        # Не удаляем localStorage здесь, чтобы не мешать нормальному входу
         return "Ошибка авто-входа", 400
 
 @app.route('/logout')
@@ -1150,14 +1228,14 @@ ADMIN_TEMPLATE = '''
             <div class="section">
                 <h2><i class="fas fa-sync-alt"></i> Синхронизация с Датацентром</h2>
                 <div class="sync-buttons">
-                    <form method="POST" action="{{ url_for('force_upload') }}" style="display: inline;" onsubmit="return confirm('Вы уверены, что хотите принудительно загрузить локальные данные на сервер? Это перезапишет данные на сервере.');">
+                    <form method="POST" action="{{ url_for('force_upload') }}" style="display: inline;" onsubmit="return confirm('Вы уверены, что хотите принудительно загрузить локальные данные на сервер? Это перезапишет данные на сервере (если локальные файлы не пустые).');">
                         <button type="submit" class="button" title="Загрузить локальные файлы на Hugging Face"><i class="fas fa-upload"></i> Загрузить БД</button>
                     </form>
                     <form method="POST" action="{{ url_for('force_download') }}" style="display: inline;" onsubmit="return confirm('Вы уверены, что хотите принудительно скачать данные с сервера? Это перезапишет ваши локальные файлы.');">
                         <button type="submit" class="button download-hf-button" title="Скачать файлы  (перезапишет локальные)"><i class="fas fa-download"></i> Скачать БД</button>
                     </form>
                 </div>
-                 <p style="font-size: 0.85rem; color: #5e6e68;">Резервное копирование происходит автоматически каждые 30 минут, а также после каждого сохранения данных. Используйте эти кнопки для немедленной синхронизации.</p>
+                 <p style="font-size: 0.85rem; color: #5e6e68;">Резервное копирование происходит автоматически каждые 30 минут, а также после каждого сохранения данных (с проверкой на пустые файлы). Используйте эти кнопки для немедленной синхронизации.</p>
             </div>
 
 
@@ -1240,7 +1318,11 @@ ADMIN_TEMPLATE = '''
                                          <input type="hidden" name="login" value="{{ login }}">
                                          <button type="submit" class="delete-button"><i class="fas fa-user-slash"></i> Удалить</button>
                                      </form>
+                                     <!-- Кнопка редактирования пользователя (если нужна) -->
+                                     <!-- <button type="button" class="button" onclick="toggleEditForm('edit-user-{{ login|replace('.', '-') }}')"><i class="fas fa-edit"></i> Редактировать</button> -->
                                  </div>
+                                 <!-- Скрытая форма редактирования пользователя (если нужна) -->
+                                 <!-- <div id="edit-user-{{ login|replace('.', '-') }}" class="edit-form-container"> ... </div> -->
                              </div>
                              {% endfor %}
                          </div>
@@ -1304,7 +1386,7 @@ ADMIN_TEMPLATE = '''
                     <div class="item">
                         <div style="display: flex; gap: 15px; align-items: flex-start;">
                              <div class="photo-preview" style="flex-shrink: 0;">
-                                {% if product.get('photos') %}
+                                {% if product.get('photos') and product.photos|length > 0 %}
                                 <a href="https://huggingface.co/datasets/{{ repo_id }}/resolve/main/photos/{{ product['photos'][0] }}" target="_blank" title="Посмотреть первое фото">
                                    <img src="https://huggingface.co/datasets/{{ repo_id }}/resolve/main/photos/{{ product['photos'][0] }}" alt="Фото">
                                 </a>
@@ -1328,7 +1410,8 @@ ADMIN_TEMPLATE = '''
                                 <p><strong>Цена:</strong> {{ "%.2f"|format(product['price']) }} {{ currency_code }}</p>
                                 <p class="description" title="{{ product.get('description', '') }}"><strong>Описание:</strong> {{ product.get('description', 'N/A')[:150] }}{% if product.get('description', '')|length > 150 %}...{% endif %}</p>
                                 {% set colors = product.get('colors', []) %}
-                                <p><strong>Цвета/Вар-ты:</strong> {{ colors|select('ne', '')|join(', ') if colors|select('ne', '')|list|length > 0 else 'Нет' }}</p>
+                                {% set valid_colors = colors|select('ne', '')|list %}
+                                <p><strong>Цвета/Вар-ты:</strong> {{ valid_colors|join(', ') if valid_colors|length > 0 else 'Нет' }}</p>
                                 {% if product.get('photos') and product['photos']|length > 1 %}
                                     <p style="font-size: 0.8rem; color: #5e6e68;">(Всего фото: {{ product['photos']|length }})</p>
                                 {% endif %}
@@ -1364,7 +1447,7 @@ ADMIN_TEMPLATE = '''
                                 </select>
                                 <label>Заменить фотографии (выберите новые файлы, до 10 шт.):</label>
                                 <input type="file" name="photos" accept="image/*" multiple>
-                                 {% if product.get('photos') %}
+                                 {% if product.get('photos') and product.photos|length > 0 %}
                                     <p style="font-size: 0.85rem; margin-top: 5px;">Текущие фото:</p>
                                     <div class="photo-preview">
                                         {% for photo in product['photos'] %}
@@ -1375,14 +1458,13 @@ ADMIN_TEMPLATE = '''
                                 <label>Цвета/Варианты:</label>
                                 <div id="edit-color-inputs-{{ loop.index0 }}">
                                     {% set current_colors = product.get('colors', []) %}
-                                    {% if current_colors and current_colors|select('ne', '')|list|length > 0 %}
-                                        {% for color in current_colors %}
-                                            {% if color.strip() %}
+                                    {% set valid_current_colors = current_colors|select('ne', '')|list %}
+                                    {% if valid_current_colors|length > 0 %}
+                                        {% for color in valid_current_colors %}
                                             <div class="color-input-group">
                                                 <input type="text" name="colors" value="{{ color }}">
                                                 <button type="button" class="remove-color-btn" onclick="removeColorInput(this)"><i class="fas fa-times"></i></button>
                                             </div>
-                                            {% endif %}
                                         {% endfor %}
                                      {% else %}
                                          <div class="color-input-group">
@@ -1444,10 +1526,8 @@ ADMIN_TEMPLATE = '''
                 const group = button.closest('.color-input-group');
                 if (group) {
                     const container = group.parentNode;
-                     // Only remove if it's not the last one (or handle adding a placeholder if it is)
-                    // For simplicity, let's allow removing all. Add logic if needed later.
                     group.remove();
-                    // Optional: If container is now empty, add a placeholder input back
+                    // Если удалили последний инпут, добавим новый пустой
                     if (container && container.children.length === 0) {
                          const placeholderGroup = document.createElement('div');
                          placeholderGroup.className = 'color-input-group';
@@ -1491,7 +1571,7 @@ def admin():
                      flash("Название категории не может быть пустым.", 'error')
                 else:
                      logging.warning(f"Категория '{category_name}' уже существует.")
-                     flash(f"Категория '{category_name}' уже существует.", 'error')
+                     flash(f"Категория '{category_name}' уже существует.", 'warning')
 
             elif action == 'delete_category':
                 category_to_delete = request.form.get('category_name')
@@ -1533,46 +1613,59 @@ def admin():
                      return redirect(url_for('admin'))
 
                 photos_list = []
-                if photos_files and HF_TOKEN_WRITE:
-                    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 uploaded_count >= photo_limit:
-                            logging.warning(f"Достигнут лимит фото ({photo_limit}), остальные фото проигнорированы.")
-                            flash(f"Загружено только первые {photo_limit} фото.", "warning")
-                            break
-                        if photo and photo.filename:
-                            try:
-                                ext = os.path.splitext(photo.filename)[1]
-                                photo_filename = secure_filename(f"{name.replace(' ','_')}_{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}...")
-                                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)
-                                uploaded_count += 1
-                            except Exception as e:
-                                logging.error(f"Ошибка загрузки фото {photo.filename} на HF: {e}", exc_info=True)
-                                flash(f"Ошибка при загрузке фото {photo.filename}.", 'error')
-                        elif photo and not photo.filename:
-                             logging.warning("Получен пустой объект файла фото при добавлении товара.")
-                    try:
-                         if not os.listdir(uploads_dir):
-                             os.rmdir(uploads_dir)
-                    except OSError as e:
-                        logging.warning(f"Не удалось удалить временную папку {uploads_dir}: {e}")
+                if photos_files and any(f.filename for f in photos_files):
+                    if not HF_TOKEN_WRITE:
+                        flash("HF_TOKEN для записи не установлен. Фотографии не будут загружены.", 'warning')
+                        logging.warning("HF_TOKEN_WRITE не установлен, пропуск загрузки фото.")
+                    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 uploaded_count >= photo_limit:
+                                logging.warning(f"Достигнут лимит фото ({photo_limit}), остальные фото проигнорированы.")
+                                flash(f"Загружено только первые {photo_limit} фото.", "warning")
+                                break
+                            if photo and photo.filename:
+                                try:
+                                    ext = os.path.splitext(photo.filename)[1].lower()
+                                    if ext not in ['.png', '.jpg', '.jpeg', '.gif', '.webp']:
+                                         logging.warning(f"Пропущен файл с неподдерживаемым расширением: {photo.filename}")
+                                         flash(f"Файл {photo.filename} имеет неподдерживаемый тип.", 'warning')
+                                         continue
+
+                                    safe_original_filename = secure_filename(os.path.splitext(photo.filename)[0])
+                                    photo_filename = f"{name.replace(' ','_')}_{safe_original_filename}_{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}...")
+
+                                    lock = get_lock(os.path.join("photos", photo_filename)) # Lock for HF upload path
+                                    with lock:
+                                        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)
+                                    uploaded_count += 1
+                                except Exception as e:
+                                    logging.error(f"Ошибка загрузки фото {photo.filename} на HF: {e}", exc_info=True)
+                                    flash(f"Ошибка при загрузке фото {photo.filename}.", 'error')
+                            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}")
 
 
                 new_product = {
@@ -1581,7 +1674,12 @@ def admin():
                     'photos': photos_list, 'colors': colors,
                     'in_stock': in_stock, 'is_top': is_top
                 }
-                products.append(new_product)
+                # Добавляем в начало списка, если Топ, иначе в конец (для примерной сортировки при добавлении)
+                if is_top:
+                    products.insert(0, new_product)
+                else:
+                    products.append(new_product)
+
 
                 save_data(data)
                 logging.info(f"Товар '{name}' добавлен.")
@@ -1595,15 +1693,14 @@ def admin():
 
                 try:
                     index = int(index_str)
-
-                    # We need to find the *original* index in the unsorted/unfiltered list
-                    original_product_list = data.get('products', [])
+                    original_product_list = data.get('products', []) # Работаем с оригинальным списком
                     if not (0 <= index < len(original_product_list)): raise IndexError("Индекс вне диапазона")
                     product_to_edit = original_product_list[index]
                     original_name = product_to_edit.get('name', 'N/A')
 
                 except (ValueError, IndexError):
                      flash(f"Ошибка редактирова��ия: неверный индекс товара '{index_str}'.", 'error')
+                     logging.error(f"Ошибка редактирования: неверный индекс {index_str}. Всего товаров: {len(original_product_list)}")
                      return redirect(url_for('admin'))
 
                 product_to_edit['name'] = request.form.get('name', product_to_edit['name']).strip()
@@ -1625,63 +1722,80 @@ def admin():
                      flash(f"Неверный формат цены для товара '{original_name}'. Цена не изменена.", 'warning')
 
                 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 = []
-                    photo_limit = 10
-                    uploaded_count = 0
-                    logging.info(f"Загрузка новых фото для товара {product_to_edit['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:
-                                ext = os.path.splitext(photo.filename)[1]
-                                photo_filename = secure_filename(f"{product_to_edit['name'].replace(' ','_')}_{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...")
-                                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)
-                                uploaded_count += 1
-                            except Exception as e:
-                                logging.error(f"Ошибка загрузки нового фото {photo.filename}: {e}", exc_info=True)
-                                flash(f"Ошибка при загрузке нового фото {photo.filename}.", 'error')
-                    try:
-                         if not os.listdir(uploads_dir):
-                             os.rmdir(uploads_dir)
-                    except OSError as e:
-                        logging.warning(f"Не удалось удалить временную папку {uploads_dir}: {e}")
-
-                    if new_photos_list:
-                        logging.info(f"Список фото для товара {product_to_edit['name']} обновлен.")
-                        old_photos = product_to_edit.get('photos', [])
-                        if old_photos:
-                            logging.info(f"Попытка удаления старых фото: {old_photos}")
-                            try:
-                                api.delete_files(
-                                    repo_id=REPO_ID,
-                                    paths_in_repo=[f"photos/{p}" for p in old_photos],
-                                    repo_type="dataset",
-                                    token=HF_TOKEN_WRITE,
-                                    commit_message=f"Delete old photos for product {product_to_edit['name']}"
-                                )
-                                logging.info(f"Старые фото для товара {product_to_edit['name']} удалены с HF.")
-                            except Exception as e:
-                                logging.error(f"Ошибка при удалении старых фото {old_photos} с HF: {e}", exc_info=True)
-                                flash("Не удалось удалить старые фотографии с сервера.", "warning")
-                        product_to_edit['photos'] = new_photos_list
-                        flash("Фотографии товара успешно обновлены.", "success")
-                    elif uploaded_count == 0 and any(f.filename for f in photos_files):
-                         flash("Не удалось загрузить новые фотографии.", "error")
+                if photos_files and any(f.filename for f in photos_files):
+                    if not HF_TOKEN_WRITE:
+                        flash("HF_TOKEN для записи не установлен. Фотографии не будут обновлены.", 'warning')
+                        logging.warning("HF_TOKEN_WRITE не установлен, пропуск обновления фото.")
+                    else:
+                        uploads_dir = 'uploads_temp'
+                        os.makedirs(uploads_dir, exist_ok=True)
+                        api = HfApi()
+                        new_photos_list = []
+                        photo_limit = 10
+                        uploaded_count = 0
+                        logging.info(f"Загрузка новых фото для товара {product_to_edit['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:
+                                    ext = os.path.splitext(photo.filename)[1].lower()
+                                    if ext not in ['.png', '.jpg', '.jpeg', '.gif', '.webp']:
+                                         logging.warning(f"Пропущен файл с неподдерживаемым расширением при редактировании: {photo.filename}")
+                                         flash(f"Файл {photo.filename} имеет неподдерживаемый тип и был пропущен.", 'warning')
+                                         continue
+
+                                    safe_original_filename = secure_filename(os.path.splitext(photo.filename)[0])
+                                    photo_filename = f"{product_to_edit['name'].replace(' ','_')}_{safe_original_filename}_{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...")
+
+                                    lock = get_lock(os.path.join("photos", photo_filename)) # Lock for HF upload path
+                                    with lock:
+                                        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)
+                                    uploaded_count += 1
+                                except Exception as e:
+                                    logging.error(f"Ошибка загрузки нового фото {photo.filename}: {e}", exc_info=True)
+                                    flash(f"Ошибка при загрузке нового фото {photo.filename}.", 'error')
+                        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 new_photos_list:
+                            logging.info(f"Список фото для товара {product_to_edit['name']} обновлен.")
+                            old_photos = product_to_edit.get('photos', [])
+                            if old_photos:
+                                logging.info(f"Попытка удаления старых фото: {old_photos}")
+                                try:
+                                    paths_to_delete = [f"photos/{p}" for p in old_photos]
+                                    # Lock deletion? Might be complex. HF Hub handles concurrent ops.
+                                    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 {product_to_edit['name']}"
+                                    )
+                                    logging.info(f"Старые фото для товара {product_to_edit['name']} удалены с HF.")
+                                except Exception as e:
+                                    # Log error but don't block the main update
+                                    logging.error(f"Ошибка при удалении старых фото {old_photos} с HF: {e}", exc_info=True)
+                                    flash("Не удалось удалить старые фотографии с сервера (возможно, их уже нет).", "warning")
+                            product_to_edit['photos'] = new_photos_list
+                            flash("Фотографии товара успешно обновлены.", "success")
+                        elif uploaded_count == 0 and any(f.filename for f in photos_files):
+                             # This case means files were selected, but none were valid/uploaded
+                             flash("Не удалось загрузить ни одну из выбранных новых фотографий (проверьте тип файлов).", "warning")
 
 
                 save_data(data)
@@ -1696,38 +1810,46 @@ def admin():
                     return redirect(url_for('admin'))
                 try:
                     index = int(index_str)
-                    original_product_list = data.get('products', [])
+                    original_product_list = data.get('products', []) # Работаем с оригинальным списком
                     if not (0 <= index < len(original_product_list)): raise IndexError("Индекс вне диапазона")
+
                     deleted_product = original_product_list.pop(index)
                     product_name = deleted_product.get('name', 'N/A')
 
                     photos_to_delete = deleted_product.get('photos', [])
-                    if photos_to_delete and HF_TOKEN_WRITE:
-                        logging.info(f"Попытка удаления фото товара '{product_name}' с HF: {photos_to_delete}")
-                        try:
-                            api = HfApi()
-                            api.delete_files(
-                                repo_id=REPO_ID,
-                                paths_in_repo=[f"photos/{p}" for p in photos_to_delete],
-                                repo_type="dataset",
-                                token=HF_TOKEN_WRITE,
-                                commit_message=f"Delete photos for deleted product {product_name}"
-                            )
-                            logging.info(f"Фото товара '{product_name}' удалены с HF.")
-                        except Exception as e:
-                             logging.error(f"Ошибка при удалении фото {photos_to_delete} для товара '{product_name}' с HF: {e}", exc_info=True)
-                             flash(f"Не удалось удалить фото для товара '{product_name}' с сервера.", "warning")
+                    if photos_to_delete:
+                        if not HF_TOKEN_WRITE:
+                            flash(f"HF_TOKEN для записи не установлен. Фотографии товара '{product_name}' не будут удалены с сервера.", 'warning')
+                            logging.warning(f"HF_TOKEN_WRITE не установлен, пропуск удаления фото для {product_name}.")
+                        else:
+                            logging.info(f"Попытка удаления фото товара '{product_name}' с HF: {photos_to_delete}")
+                            try:
+                                api = HfApi()
+                                paths_to_delete = [f"photos/{p}" for p in photos_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}' удалены с HF.")
+                            except Exception as e:
+                                 # Log error but don't block the main delete
+                                 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):
                      flash(f"Ошибка удаления: неверный индекс товара '{index_str}'.", 'error')
+                     logging.error(f"Ошибка удаления: неверный индекс {index_str}. Всего товаров: {len(original_product_list)}")
 
 
             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()
                  phone = request.form.get('phone', '').strip()
@@ -1768,26 +1890,23 @@ def admin():
 
             return redirect(url_for('admin'))
 
+        except filelock.Timeout:
+             logging.error(f"Таймаут блокировки файла при обработке действия '{action}' в админ-панели.")
+             flash("Не удалось выполнить действие из-за конфликта доступа к файлу. Попробуйте снова.", 'error')
+             return redirect(url_for('admin'))
         except Exception as e:
              logging.error(f"Ошибка при обработке действия '{action}' в админ-панели: {e}", exc_info=True)
              flash(f"Произошла внутренняя ошибка при выполнении действия '{action}'. Подробности в логе сервера.", 'error')
              return redirect(url_for('admin'))
 
-    # Pass the original, unsorted product list to the admin template with original indices
-    original_products_with_indices = list(enumerate(data.get('products', [])))
-    # Sort the indexed list for display purposes if needed, but keep original index
-    display_products = sorted(original_products_with_indices, key=lambda item: item[1].get('name', '').lower())
-    # Reconstruct list of products in display order for the template
-    # Need to pass the original index within the product data or handle it carefully
-    # Let's pass the original product list directly for simplicity in the template loops
+    # Передаем оригинальный, несортированный список продуктов для сохранения индексов
     original_product_list = data.get('products', [])
-
     categories.sort()
     sorted_users = dict(sorted(users.items()))
 
     return render_template_string(
         ADMIN_TEMPLATE,
-        products=original_product_list, # Pass the original list to preserve indices
+        products=original_product_list,
         categories=categories,
         users=sorted_users,
         repo_id=REPO_ID,
@@ -1798,8 +1917,9 @@ def admin():
 def force_upload():
     logging.info("Запущена принудительная загрузка данных на Hugging Face...")
     try:
+        # upload_db_to_hf уже содержит проверку на пустые файлы
         upload_db_to_hf()
-        flash("Данные успешно загружены на Hugging Face.", 'success')
+        flash("Попытка загрузки данных на Hugging Face инициирована (пустые файлы будут пропущены).", 'success')
     except Exception as e:
         logging.error(f"Ошибка при принудительной загрузке: {e}", exc_info=True)
         flash(f"Ошибка при загрузке на Hugging Face: {e}", 'error')
@@ -1809,8 +1929,14 @@ def force_upload():
 def force_download():
     logging.info("Запущено принудительное скачивание данных с Hugging Face...")
     try:
-        download_db_from_hf()
-        flash("Данные успешно скачаны с Hugging Face. Локальные файлы обновлены.", 'success')
+        success = download_db_from_hf()
+        if success:
+            flash("Данные успешно скачаны с Hugging Face. Локальные файлы обновлены.", 'success')
+            # Перезагружаем данные в память после успешного скачивания
+            load_data()
+            load_users()
+        else:
+            flash("Не удалось скачать данные с Hugging Face после нескольких попыток. Локальные файлы не изменены.", 'error')
     except Exception as e:
         logging.error(f"Ошибка при принудительном скачивании: {e}", exc_info=True)
         flash(f"Ошибка при скачивании с Hugging Face: {e}", 'error')
@@ -1818,6 +1944,7 @@ def force_download():
 
 
 if __name__ == '__main__':
+    # Первоначальная загрузка при старте
     load_data()
     load_users()
 
@@ -1826,9 +1953,9 @@ if __name__ == '__main__':
         backup_thread.start()
         logging.info("Поток периодического резервного копирования запущен.")
     else:
-        logging.warning("Периодическое резервное копирование НЕ будет запущено (HF_TOKEN или HF_TOKEN_WRITE не установлена).")
+        logging.warning("Периодическое резервное копирование НЕ будет запущено (HF_TOKEN_WRITE не установлен).")
 
     port = int(os.environ.get('PORT', 7860))
     logging.info(f"Запуск Flask приложения на хосте 0.0.0.0 и порту {port}")
+    # debug=False важно для продакшена и работы с потоками/блокировками
     app.run(debug=False, host='0.0.0.0', port=port)
-