Update ML.py

ML.py

@@ -1249,4 +1249,50 @@ def safe_json_parse(json_string):
             print(f"❌ فشل تحليل JSON بعد الإصلاح: {e}")
             return None
 
+
+async def process_multiple_symbols_parallel(self, symbols_data_list, max_concurrent=20):
+    """معالجة متعددة للرموز بشكل متوازي مع التحكم في التزامن"""
+    try:
+        print(f"🚀 بدء المعالجة المتوازية لـ {len(symbols_data_list)} رمز (بحد أقصى {max_concurrent} متزامنة)...")
+        
+        # تقسيم العمل إلى دفعات لتجنب الحمل الزائد
+        batches = [symbols_data_list[i:i + max_concurrent] 
+                  for i in range(0, len(symbols_data_list), max_concurrent)]
+        
+        all_results = []
+        
+        for batch_num, batch in enumerate(batches):
+            print(f"   🔄 معالجة الدفعة {batch_num + 1}/{len(batches)} ({len(batch)} رمز)...")
+            
+            # إنشاء مهام للدفعة الحالية
+            batch_tasks = []
+            for symbol_data in batch:
+                task = asyncio.create_task(self.process_and_score_symbol_enhanced(symbol_data))
+                batch_tasks.append(task)
+            
+            # انتظار انتهاء الدفعة الحالية
+            batch_results = await asyncio.gather(*batch_tasks, return_exceptions=True)
+            
+            # تصفية النتائج الناجحة
+            successful_results = []
+            for result in batch_results:
+                if isinstance(result, Exception):
+                    continue
+                if result and result.get('enhanced_final_score', 0) > 0.4:
+                    successful_results.append(result)
+            
+            all_results.extend(successful_results)
+            print(f"   ✅ اكتملت الدفعة {batch_num + 1}: {len(successful_results)}/{len(batch)} ناجحة")
+            
+            # انتظار قصير بين الدفعات لتجنب rate limits
+            if batch_num < len(batches) - 1:
+                await asyncio.sleep(1)
+        
+        print(f"🎯 اكتملت المعالجة المتوازية: {len(all_results)}/{len(symbols_data_list)} رمز تم تحليلها بنجاح")
+        return all_results
+        
+    except Exception as error:
+        print(f"❌ خطأ في المعالجة المتوازية: {error}")
+        return []
+
 print("✅ ML Processor loaded - No Default Values & Enhanced Analysis")