Create main.py

main.py

@@ -0,0 +1,44 @@
+import os
+import psycopg2
+from fastapi import FastAPI, Request
+
+app = FastAPI()
+
+# Берем данные из переменных окружения
+DATABASE_URL = os.getenv("DATABASE_URL")
+
+@app.post("/webhook")
+async def handle_feedback(request: Request):
+    data = await request.json()
+    
+    # Извлекаем данные (те самые, что шлет Flowise)
+    business_name = data.get("business_name", "Unknown")
+    risk_level = data.get("risk_level", "Low")
+    category = data.get("category", "Other")
+    summary = data.get("summary", "")
+    sentiment_score = data.get("sentiment_score", 0)
+    action_required = data.get("action_required", "")
+
+    try:
+        # Подключаемся к Neon
+        conn = psycopg2.connect(DATABASE_URL)
+        cur = conn.cursor()
+        
+        # Запрос на вставку (убедись, что имена колонок в базе совпадают)
+        query = """
+        INSERT INTO feedback (business_name, risk_level, category, summary, sentiment_score, action_required)
+        VALUES (%s, %s, %s, %s, %s, %s)
+        """
+        cur.execute(query, (business_name, risk_level, category, summary, sentiment_score, action_required))
+        
+        conn.commit()
+        cur.close()
+        conn.close()
+        
+        return {"status": "success", "message": "Feedback saved to Neon"}
+    except Exception as e:
+        return {"status": "error", "message": str(e)}
+
+@app.get("/")
+def read_root():
+    return {"message": "Python Bridge is Running!"}