Spaces:
Running
Running
Update app.py
Browse files
app.py
CHANGED
|
@@ -275,7 +275,6 @@ async def run_3_layer_analysis():
|
|
| 275 |
layer2_data.append(ohlcv_data)
|
| 276 |
|
| 277 |
except Exception as e:
|
| 278 |
-
print(f"❌ خطأ في إعداد تحليل {ohlcv_data.get('symbol')}: {e}")
|
| 279 |
continue
|
| 280 |
|
| 281 |
if not layer2_data:
|
|
@@ -356,8 +355,6 @@ async def run_3_layer_analysis():
|
|
| 356 |
timeframes_count = candidate.get('successful_timeframes', 0)
|
| 357 |
total_candles = sum(len(data) for data in ohlcv_data.values())
|
| 358 |
|
| 359 |
-
print(f" 📊 بيانات الشموع: {timeframes_count} إطار زمني, {total_candles} شمعة")
|
| 360 |
-
|
| 361 |
# ✅ إرسال كل عملة للنموذج الضخم على حدة
|
| 362 |
llm_analysis = await llm_service_global.get_trading_decision(candidate)
|
| 363 |
|
|
@@ -434,7 +431,7 @@ async def re_analyze_open_trade_async(trade_data):
|
|
| 434 |
"trade_reanalyzed": True,
|
| 435 |
"symbol": symbol,
|
| 436 |
"action": re_analysis_decision.get('action'),
|
| 437 |
-
|
| 438 |
})
|
| 439 |
|
| 440 |
return {
|
|
@@ -443,11 +440,9 @@ async def re_analyze_open_trade_async(trade_data):
|
|
| 443 |
"current_price": processed_data.get('current_price')
|
| 444 |
}
|
| 445 |
else:
|
| 446 |
-
print(f"⚠️ لا يوجد قرار إعادة تحليل لـ {symbol}")
|
| 447 |
return None
|
| 448 |
|
| 449 |
except Exception as error:
|
| 450 |
-
print(f"❌ Error during trade re-analysis: {error}")
|
| 451 |
await r2_service_global.save_system_logs_async({
|
| 452 |
"reanalysis_error": True,
|
| 453 |
"symbol": symbol,
|
|
|
|
| 275 |
layer2_data.append(ohlcv_data)
|
| 276 |
|
| 277 |
except Exception as e:
|
|
|
|
| 278 |
continue
|
| 279 |
|
| 280 |
if not layer2_data:
|
|
|
|
| 355 |
timeframes_count = candidate.get('successful_timeframes', 0)
|
| 356 |
total_candles = sum(len(data) for data in ohlcv_data.values())
|
| 357 |
|
|
|
|
|
|
|
| 358 |
# ✅ إرسال كل عملة للنموذج الضخم على حدة
|
| 359 |
llm_analysis = await llm_service_global.get_trading_decision(candidate)
|
| 360 |
|
|
|
|
| 431 |
"trade_reanalyzed": True,
|
| 432 |
"symbol": symbol,
|
| 433 |
"action": re_analysis_decision.get('action'),
|
| 434 |
+
'strategy': re_analysis_decision.get('strategy', 'GENERIC')
|
| 435 |
})
|
| 436 |
|
| 437 |
return {
|
|
|
|
| 440 |
"current_price": processed_data.get('current_price')
|
| 441 |
}
|
| 442 |
else:
|
|
|
|
| 443 |
return None
|
| 444 |
|
| 445 |
except Exception as error:
|
|
|
|
| 446 |
await r2_service_global.save_system_logs_async({
|
| 447 |
"reanalysis_error": True,
|
| 448 |
"symbol": symbol,
|