Update appp.py

appp.py

@@ -248,6 +248,16 @@ async def predict_signal(symbol, timeframe="1h"):
         risk_usd = CAPITAL_VIRTUEL * (risk_pct / 100)
         gain_estime_usd = risk_usd * (tp_m / sl_m)
 
+        db_task = (
+            datetime.now(timezone.utc).isoformat(), 
+            symbol, 
+            timeframe, # <-- LA NOUVELLE VARIABLE EST ICI
+            'HAUSSIER' if final_p > 0.5 else 'BAISSIER', 
+            float(final_p), float(price), float(tp), float(sl), 
+            'EN_COURS', regime, float(time_prob), float(ml_prob), float(lstm_prob), float(p_sent)
+        )
+        asyncio.create_task(save_to_db(db_task))
+
         return {
             "symbol": symbol,
             "timeframe": timeframe,
@@ -327,6 +337,23 @@ async def run_judge_api():
     except Exception as e:
         return str(e)
 
+# --- FONCTION DE SAUVEGARDE DB ---
+async def save_to_db(task):
+    try:
+        conn = sqlite3.connect("alphatrade_v9.db")
+        cur = conn.cursor()
+        
+        # ⚠️ On a ajouté 'timeframe' juste après 'symbol' et un '?' en plus dans VALUES
+        cur.execute("""
+            INSERT INTO signals 
+            (timestamp, symbol, timeframe, direction, prob, price, tp, sl, status, regime, prob_xgb, prob_rf, prob_lstm, prob_sent) 
+            VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)
+        """, task)
+        
+        conn.commit()
+        conn.close()
+    except Exception as e:
+        print(f"❌ Erreur DB: {e}")
 # ================================
 # 🔌 SHUTDOWN SAFE
 # ================================