Update app.py

app.py

@@ -5,6 +5,9 @@ import random
 import string
 from datetime import datetime, timedelta
 import pytz
+import time
+import threading
+from huggingface_hub import HfApi  # импорт API для работы с Hugging Face
 
 # Подключение к базе данных SQLite3
 conn = sqlite3.connect('auth_system.db', check_same_thread=False)
@@ -91,11 +94,9 @@ def record_sales():
     
     total_amount = 0.0
     for product_id, quantity in cart_items:
-        # Получение цены за единицу товара
         c.execute('SELECT sale_price FROM products WHERE id=?', (product_id,))
         sale_price = c.fetchone()[0]
         
-        # Расчет общей суммы для этого товара
         amount = quantity * sale_price
         total_amount += amount
         
@@ -130,7 +131,6 @@ def generate_monthly_report(user_id):
     
     return sales_data, total_sales, total_profit
 
-
 # Функция для получения всех сделок
 def get_all_sales(user_id):
     c.execute('''
@@ -144,7 +144,6 @@ def get_all_sales(user_id):
     sales_data = c.fetchall()
     return sales_data
 
-
 # Функция для получения всех подробностей сделок
 def get_sale_details(sale_id):
     c.execute('''
@@ -192,10 +191,10 @@ def login():
 # Форма добавления товара
 def add_product():
     st.title("Добавление товара")
-    product_name = st.text_input("Название товара").strip().lower()  # Преобразование в нижний регистр
+    product_name = st.text_input("Название товара").strip().lower()
     product_description = st.text_area("Описание товара")
-    purchase_price = st.number_input("Приходная цена", min_value=0.0, step=0.01)  # Запрос приходной цены
-    sale_price = st.number_input("Отпускная цена", min_value=0.0, step=0.01)      # Запрос отпускной цены
+    purchase_price = st.number_input("Приходная цена", min_value=0.0, step=0.01)
+    sale_price = st.number_input("Отпускная цена", min_value=0.0, step=0.01)
     product_quantity = st.number_input("Количество на складе", min_value=0, step=1)
 
     if st.button("Добавить товар"):
@@ -243,9 +242,8 @@ def add_to_cart():
     st.title("Отпуск товара")
     products = c.execute("SELECT id, name, sale_price, quantity_in_stock FROM products WHERE user_id=?", 
                          (st.session_state.user_id,)).fetchall()
-    search_term = st.text_input("Поиск товара").strip().lower()  # Преобразуем ввод в нижний регистр
+    search_term = st.text_input("Поиск товара").strip().lower()
 
-    # Поиск товаров по ключевому слову (без учета регистра)
     c.execute("SELECT id, name, sale_price, quantity_in_stock FROM products WHERE user_id=? AND LOWER(name) LIKE ?", 
               (st.session_state.user_id, f"%{search_term}%"))
     products = c.fetchall()
@@ -254,8 +252,8 @@ def add_to_cart():
         for product in products:
             cols = st.columns(4)
             with cols[0]:
-                st.write(product[1])  # Название товара
-                st.write(f"**Отпускная цена**: {product[2]:.2f}")  # Показываем только отпускную цену
+                st.write(product[1])
+                st.write(f"**Отпускная цена**: {product[2]:.2f}")
                 st.write(f"**Остаток на складе**: {product[3]}")
 
             with cols[1]:
@@ -266,15 +264,12 @@ def add_to_cart():
                 
                 if add_button:
                     if quantity <= product[3]:
-                        # Обработка добавления товара в корзину
                         c.execute('''
                         INSERT INTO cart (product_id, quantity) 
                         VALUES (?, ?)
                         ON CONFLICT(product_id) 
                         DO UPDATE SET quantity = quantity + excluded.quantity
                         ''', (product[0], quantity))
-
-                        # Уменьшаем количество на складе
                         c.execute("UPDATE products SET quantity_in_stock = quantity_in_stock - ? WHERE id=?", 
                                   (quantity, product[0]))
                         conn.commit()
@@ -287,7 +282,6 @@ def add_to_cart():
                 
                 if remove_button:
                     if quantity > 0:
-                        # Обработка удаления товара из корзины
                         current_quantity = c.execute("SELECT quantity FROM cart WHERE product_id=?", (product[0],)).fetchone()
                         if current_quantity:
                             new_quantity = current_quantity[0] - quantity
@@ -300,8 +294,6 @@ def add_to_cart():
                                 ''', (product[0], new_quantity))
                             else:
                                 c.execute("DELETE FROM cart WHERE product_id=?", (product[0],))
-
-                            # Увеличиваем количество на складе
                             c.execute("UPDATE products SET quantity_in_stock = quantity_in_stock + ? WHERE id=?", 
                                       (quantity, product[0]))
                             conn.commit()
@@ -311,18 +303,15 @@ def add_to_cart():
                     else:
                         st.error(f"Введите количество для удаления товара '{product[1]}'.")
 
-        # Отображение состояния корзины
         st.subheader("Состояние корзины")
         items, total_quantity, total_price = get_cart_summary(st.session_state.user_id)
         
         if items:
-            # Создание DataFrame для таблицы
             df = pd.DataFrame(items, columns=["Название", "Количество", "Цена за единицу", "Итого"])
             st.dataframe(df.style.format({"Цена за единицу": "{:.2f}", "Итого": "{:.2f}"}), use_container_width=True)
             
             st.write(f"Общее количество: {total_quantity}, Общая стоимость: {total_price:.2f}")
             
-            # Добавляем кнопку "Пробить" для оформления продажи
             if st.button("Пробить"):
                 sales_details, sale_id, total_amount = record_sales()
                 if sales_details:
@@ -332,11 +321,9 @@ def add_to_cart():
                     st.write(f"**Общая сумма сделки:** {total_amount:.2f}")
                     st.success("Корзина успешно пробита! Все товары добавлены в отчет и корзина очищена.")
                 
-            # Кнопка для отображения сделок
             if st.button("Сделки"):
-                sales_data = get_all_sales()
+                sales_data = get_all_sales(st.session_state.user_id)
                 if sales_data:
-                    sale_ids = [sale[0] for sale in sales_data]
                     for sale_id, sale_date, total_amount in sales_data:
                         st.write(f"**Сделка ID:** {sale_id} ({sale_date}) - **Общая сумма:** {total_amount:.2f}")
                         sale_details = get_sale_details(sale_id)
@@ -355,7 +342,6 @@ def monthly_report():
     st.title("Отчет о продажах за месяц")
     sales_data, total_sales, total_profit = generate_monthly_report(st.session_state.user_id)
     if sales_data:
-        # Создание DataFrame для отчета
         df = pd.DataFrame(sales_data, columns=["Название", "Общее количество", "Отпускная цена", "Общие продажи", "Прибыль"])
         st.write(f"**Отчет за {datetime.now().strftime('%B %Y')}**")
         st.dataframe(df.style.format({"Отпускная цена": "{:.2f}", "Общие продажи": "{:.2f}", "Прибыль": "{:.2f}"}), use_container_width=True)
@@ -363,11 +349,9 @@ def monthly_report():
         st.write(f"**Общая сумма продаж**: {total_sales:.2f}")
         st.write(f"**Общая сумма прибыли**: {total_profit:.2f}")
         
-        # Кнопка для отображения сделок
         if st.button("Сделки"):
             sales_data = get_all_sales(st.session_state.user_id)
             if sales_data:
-                sale_ids = [sale[0] for sale in sales_data]
                 for sale_id, sale_date, total_amount in sales_data:
                     st.write(f"**Сделка ID:** {sale_id} ({sale_date}) - **Общая сумма:** {total_amount:.2f}")
                     sale_details = get_sale_details(sale_id)
@@ -381,11 +365,36 @@ def monthly_report():
     else:
         st.info("Нет данных о продажах за этот месяц.")
 
-# Главная функция приложения
+# --- Функционал резервного копирования базы данных на Hugging Face ---
+hf_token = "YOUR_HF_TOKEN"  # Замените на ваш Hugging Face токен
+
+def upload_db_to_hf():
+    """Загружает файл базы данных в репозиторий Hugging Face (repo_id: Testbase1/testsett)."""
+    try:
+        api = HfApi()
+        api.upload_file(
+            path_or_fileobj="auth_system.db",
+            path_in_repo="auth_system.db",
+            repo_id="Testbase1/testsett",
+            repo_type="dataset",
+            token=hf_token
+        )
+        print("Резервная копия базы данных успешно загружена на Hugging Face.")
+    except Exception as e:
+        print("Ошибка при загрузке резервной к��пии:", e)
+
+def periodic_backup():
+    """Запускает бесконечный цикл резервного копирования с интервалом в 1 час."""
+    while True:
+        upload_db_to_hf()
+        time.sleep(3600)  # ожидание 1 час
+
+# --- Главная функция приложения ---
 def main():
     if 'logged_in' not in st.session_state:
         st.session_state.logged_in = False
 
+    st.sidebar.title("Навигация")
     if st.session_state.logged_in:
         st.sidebar.title(f"Привет, {st.session_state.username}!")
         option = st.sidebar.selectbox("Выберите действие", ["Добавить товар", "Отпуск товара", "Редактировать товары", "Отчет за месяц", "Выйти"])
@@ -411,4 +420,9 @@ def main():
             login()
 
 if __name__ == "__main__":
-    main()
+    # Глобально запускаем поток резервного копирования, если он ещё не запущен.
+    if not globals().get("backup_thread_started", False):
+        backup_thread = threading.Thread(target=periodic_backup, daemon=True)
+        backup_thread.start()
+        globals()["backup_thread_started"] = True
+    main()