Update main.py

main.py

@@ -11,8 +11,13 @@ DATABASE_URL = os.getenv("DATABASE_URL")
 async def handle_feedback(request: Request):
     data = await request.json()
     
-    # Извлекаем данные (те самые, что шлет Flowise)
+    # 1. ТЕПЕРЬ МЫ ИЗВЛЕКАЕМ ВСЁ
     business_name = data.get("business_name", "Unknown")
+    branch = data.get("branch")         # Добавлено
+    contact = data.get("contact")       # Добавлено
+    raw_message = data.get("raw_message") # Добавлено
+    language = data.get("language")     # Добавлено
+    
     risk_level = data.get("risk_level", "Low")
     category = data.get("category", "Other")
     summary = data.get("summary", "")
@@ -20,16 +25,23 @@ async def handle_feedback(request: Request):
     action_required = data.get("action_required", "")
 
     try:
-        # Подключаемся к Neon
         conn = psycopg2.connect(DATABASE_URL)
         cur = conn.cursor()
         
-        # Запрос на вставку (убедись, что имена колонок в базе совпадают)
+        # 2. ОБНОВЛЕННЫЙ ЗАПРОС (Добавлены 4 колонки)
         query = """
-        INSERT INTO feedback (business_name, risk_level, category, summary, sentiment_score, action_required)
-        VALUES (%s, %s, %s, %s, %s, %s)
+        INSERT INTO feedback (
+            business_name, branch, contact, raw_message, language, 
+            risk_level, category, summary, sentiment_score, action_required
+        )
+        VALUES (%s, %s, %s, %s, %s, %s, %s, %s, %s, %s)
         """
-        cur.execute(query, (business_name, risk_level, category, summary, sentiment_score, action_required))
+        
+        # 3. ПЕРЕДАЕМ ВСЕ 10 ПАРАМЕТРОВ
+        cur.execute(query, (
+            business_name, branch, contact, raw_message, language,
+            risk_level, category, summary, sentiment_score, action_required
+        ))
         
         conn.commit()
         cur.close()