Update LLM.py

LLM.py

@@ -457,7 +457,9 @@ class LLMService:
         indicators_summary = self._format_advanced_indicators(advanced_indicators)
         strategies_summary = self._format_strategies_analysis(strategy_scores, recommended_strategy)
         pattern_summary = self._format_pattern_analysis_enhanced(pattern_analysis, payload)
-        whale_analysis_section = self._format_whale_analysis_for_llm(general_whale_activity, whale_data, symbol)
+        
+        # 🆕 استخدام البيانات المحسنة من data_manager
+        whale_analysis_section = self._format_enhanced_whale_analysis_for_llm(general_whale_activity, whale_data, symbol)
 
         strategy_instructions = {
             "AGGRESSIVE_GROWTH": "**Strategy: AGGRESSIVE_GROWTH**: Focus on strong price movements (5-10%) and accept higher risk for higher rewards. Aim for 8-15% on successful trades.",
@@ -511,7 +513,7 @@ class LLMService:
         - Fear & Greed Index: {sentiment_data.get('fear_and_greed_index', 'N/A')} ({sentiment_data.get('sentiment_class', 'N/A')})
         - Market Regime: {sentiment_data.get('market_trend', 'N/A')}
 
-        **6. 🐋 ADVANCED WHALE ANALYSIS:**
+        **6. 🐋 ADVANCED WHALE ANALYSIS (ENHANCED NETFLOW):**
         {whale_analysis_section}
 
         **7. 📰 RECENT NEWS (LAST 3 HOURS):**
@@ -661,22 +663,61 @@ class LLMService:
         
         return "\n".join(analysis_lines)
 
-    def _format_whale_analysis_for_llm(self, general_whale_activity, symbol_whale_data, symbol):
+    def _format_enhanced_whale_analysis_for_llm(self, general_whale_activity, symbol_whale_data, symbol):
+        """🆕 تنسيق محسن لتحليل الحيتان مع بيانات صافي التدفق"""
         analysis_parts = []
         
         if general_whale_activity.get('data_available', False):
+            # استخدام البيانات المحسنة من data_manager
+            netflow_analysis = general_whale_activity.get('netflow_analysis', {})
             critical_flag = " 🚨 CRITICAL ALERT" if general_whale_activity.get('critical_alert') else ""
-            analysis_parts.append(f"📊 **General Market:** {general_whale_activity.get('description', 'Activity detected')}{critical_flag}")
+            
+            if netflow_analysis:
+                inflow = netflow_analysis.get('inflow_to_exchanges', 0)
+                outflow = netflow_analysis.get('outflow_from_exchanges', 0)
+                net_flow = netflow_analysis.get('net_flow', 0)
+                flow_direction = netflow_analysis.get('flow_direction', 'BALANCED')
+                market_impact = netflow_analysis.get('market_impact', 'UNKNOWN')
+                
+                analysis_parts.append(f"📊 **General Market Netflow Analysis:**")
+                analysis_parts.append(f"   • Inflow to Exchanges: ${inflow:,.0f}")
+                analysis_parts.append(f"   • Outflow from Exchanges: ${outflow:,.0f}")
+                analysis_parts.append(f"   • Net Flow: ${net_flow:,.0f} ({flow_direction})")
+                analysis_parts.append(f"   • Market Impact: {market_impact}{critical_flag}")
+                
+                # إضافة إشارات التداول من تحليل صافي التدفق
+                trading_signals = general_whale_activity.get('trading_signals', [])
+                if trading_signals:
+                    analysis_parts.append(f"   • Trading Signals: {len(trading_signals)} active signals")
+                    for signal in trading_signals[:3]:  # عرض أول 3 إشارات فقط
+                        analysis_parts.append(f"     ◦ {signal.get('action')}: {signal.get('reason')} (Confidence: {signal.get('confidence', 0):.2f})")
+            else:
+                analysis_parts.append(f"📊 **General Market:** {general_whale_activity.get('description', 'Activity detected')}{critical_flag}")
         else:
             analysis_parts.append("📊 **General Market:** No significant general whale data available")
         
         if symbol_whale_data.get('data_available', False):
-            analysis_parts.append(f"🎯 **{symbol} Specific:** {symbol_whale_data.get('description', 'Activity detected')}")
+            activity_level = symbol_whale_data.get('activity_level', 'UNKNOWN')
+            large_transfers = symbol_whale_data.get('large_transfers_count', 0)
+            total_volume = symbol_whale_data.get('total_volume', 0)
+            
+            analysis_parts.append(f"🎯 **{symbol} Specific Whale Activity:**")
+            analysis_parts.append(f"   • Activity Level: {activity_level}")
+            analysis_parts.append(f"   • Large Transfers: {large_transfers}")
+            analysis_parts.append(f"   • Total Volume: ${total_volume:,.0f}")
+            
+            recent_transfers = symbol_whale_data.get('recent_large_transfers', [])
+            if recent_transfers:
+                analysis_parts.append(f"   • Recent Large Transfers: {len(recent_transfers)}")
         else:
             analysis_parts.append(f"🎯 **{symbol} Specific:** No contract-based whale data available")
         
         return "\n".join(analysis_parts)
 
+    def _format_whale_analysis_for_llm(self, general_whale_activity, symbol_whale_data, symbol):
+        """النسخة القديمة للحفاظ على التوافق - استخدام النسخة المحسنة بدلاً منها"""
+        return self._format_enhanced_whale_analysis_for_llm(general_whale_activity, symbol_whale_data, symbol)
+
     async def re_analyze_trade_async(self, trade_data: dict, processed_data: dict):
         try:
             symbol = trade_data['symbol']
@@ -768,7 +809,13 @@ class LLMService:
             
         indicators_summary = self._format_advanced_indicators(processed_data.get('advanced_indicators', {}))
         pattern_summary = self._format_pattern_analysis_enhanced(pattern_analysis, processed_data)
-        whale_analysis_section = self._format_whale_analysis_for_llm(processed_data.get('sentiment_data', {}).get('general_whale_activity', {}), processed_data.get('whale_data', {}), symbol)
+        
+        # 🆕 استخدام البيانات المحسنة من data_manager
+        whale_analysis_section = self._format_enhanced_whale_analysis_for_llm(
+            processed_data.get('sentiment_data', {}).get('general_whale_activity', {}), 
+            processed_data.get('whale_data', {}), 
+            symbol
+        )
 
         prompt = f"""
         🔄 **ENHANCED TRADE RE-ANALYSIS WITH CHART PATTERNS**
@@ -1048,4 +1095,4 @@ def local_re_analyze_trade(trade_data, processed_data):
         "strategy": strategy
     }
 
-print("✅ ENHANCED LLM Service loaded successfully - ADVANCED PATTERN ANALYSIS - Performance Tracking - Real-time Pattern Integration")
+print("✅ ENHANCED LLM Service loaded successfully - ADVANCED PATTERN ANALYSIS - Performance Tracking - Real-time Pattern Integration - Enhanced Whale Analysis")