Update app.py

app.py

@@ -88,6 +88,46 @@ def generate_token():
 def get_new_id(items):
     return max([item.get("id", 0) for item in items], default=0) + 1
 
+# --- Функции для работы с продажами ---
+def record_sales():
+    """
+    Записывает информацию о продажах, обновляет базу данных и очищает корзину.
+    """
+    with db_lock:
+        data = load_db()
+        cart_items = data["cart"]
+        if not cart_items:
+            return None, None, 0.0
+
+        sales_details = []
+        total_amount = 0.0
+        now = datetime.now().strftime("%Y-%m-%d %H:%M:%S")
+        sale_id = generate_token()
+
+        for item in cart_items:
+            product = next((p for p in data["products"] if p["id"] == item["product_id"]), None)
+            if product:
+                sale_amount = item["quantity"] * product["sale_price"]
+                total_amount += sale_amount
+                sales_details.append([product["id"], item["quantity"], sale_amount, now])
+
+                # Добавляем информацию о продаже в базу данных
+                new_sale_id = get_new_id(data["sales"])
+                data["sales"].append({
+                    "id": new_sale_id,
+                    "sale_id": sale_id,
+                    "product_id": product["id"],
+                    "quantity": item["quantity"],
+                    "total_amount": sale_amount,
+                    "sale_date": now
+                })
+
+        # Очищаем корзину
+        data["cart"] = []
+        save_db(data)
+
+        return sales_details, sale_id, total_amount
+
 # --- Страницы приложения ---
 
 def register():
@@ -392,8 +432,8 @@ def main():
             login()
 
 if __name__ == "__main__":
-    main()
     # Ждем 15 секунд после инициализации, затем запускаем фоновый поток резервного копирования
     time.sleep(15)
     backup_thread = threading.Thread(target=periodic_backup, daemon=True)
-    backup_thread.start()
+    backup_thread.start()
+    main()