Update app.py

app.py

@@ -342,18 +342,25 @@ async def run_3_layer_analysis():
                 symbol = candidate['symbol']
                 print(f"   🤔 تحليل {symbol} بالنموذج الضخم...")
                 
-                # ✅ التأكد من تمرير بيانات OHLCV بشكل صحيح
-                ohlcv_data = candidate.get('ohlcv') or candidate.get('raw_ohlcv')
+                # ✅ التأكد من تمرير بيانات OHLCV بشكل صحيح - الإصلاح الرئيسي هنا
+                ohlcv_data = candidate.get('raw_ohlcv') or candidate.get('ohlcv')
                 if not ohlcv_data:
                     print(f"      ⚠️ لا توجد بيانات شموع لـ {symbol}")
                     continue
                 
-                # ✅ التأكد من تمرير البيانات الخام للنموذج
+                # ✅ التأكد من تمرير البيانات الخام للنموذج - الإصلاح الرئيسي
                 candidate['raw_ohlcv'] = ohlcv_data
                 candidate['ohlcv'] = ohlcv_data
                 
+                # ✅ التحقق من جودة البيانات قبل الإرسال للنموذج
                 timeframes_count = candidate.get('successful_timeframes', 0)
-                total_candles = sum(len(data) for data in ohlcv_data.values())
+                total_candles = sum(len(data) for data in ohlcv_data.values()) if ohlcv_data else 0
+                
+                if total_candles < 30:  # تخفيف الشرط من 50 إلى 30 شمعة
+                    print(f"      ⚠️ بيانات شموع غير كافية لـ {symbol}: {total_candles} شمعة فقط")
+                    continue
+                
+                print(f"      📊 إرسال {symbol} للنموذج: {total_candles} شمعة في {timeframes_count} إطار زمني")
                 
                 # ✅ إرسال كل عملة للنموذج الضخم على حدة
                 llm_analysis = await llm_service_global.get_trading_decision(candidate)
@@ -422,6 +429,10 @@ async def re_analyze_open_trade_async(trade_data):
             if not processed_data:
                 return None
             
+            # ✅ التأكد من تمرير بيانات الشموع بشكل صحيح
+            processed_data['raw_ohlcv'] = ohlcv_data.get('raw_ohlcv') or ohlcv_data.get('ohlcv')
+            processed_data['ohlcv'] = processed_data['raw_ohlcv']
+            
             # استخدام LLM لإعادة التحليل
             re_analysis_decision = await llm_service_global.re_analyze_trade_async(trade_data, processed_data)