Oda/managing-apps
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Use bot allocation on running strategies only

Browse Source
This commit is contained in:
cryptooda
2025-10-04 13:54:14 +07:00
parent f72bfc4ab8
commit 3635fb4c29
1 changed files with 36 additions and 36 deletions
Download Patch File Download Diff File Expand all files Collapse all files

72
src/Managing.Application/Bots/Grains/AgentGrain.cs
View File

@@ -169,7 +169,7 @@ public class AgentGrain : Grain, IAgentGrain
try try
{ {
// Get all positions for this agent's bots as initiator // Get all positions for this agent's bots as initiator
var positions = await _tradingService.GetPositionByUserIdAsync((int)this.GetPrimaryKeyLong()); var positions = (await _tradingService.GetPositionByUserIdAsync((int)this.GetPrimaryKeyLong())).ToList();
// Calculate aggregated statistics from position data // Calculate aggregated statistics from position data
var totalPnL = positions.Sum(p => p.ProfitAndLoss?.Realized ?? 0); var totalPnL = positions.Sum(p => p.ProfitAndLoss?.Realized ?? 0);
@@ -201,28 +201,24 @@ public class AgentGrain : Grain, IAgentGrain
{ {
var userId = (int)this.GetPrimaryKeyLong(); var userId = (int)this.GetPrimaryKeyLong();
var user = await _userService.GetUserByIdAsync(userId); var user = await _userService.GetUserByIdAsync(userId);
var userAccounts = await _accountService.GetAccountsByUserAsync(user, hideSecrets: true, true);
if (user != null) foreach (var account in userAccounts)
{ {
var userAccounts = await _accountService.GetAccountsByUserAsync(user, hideSecrets: true, true); // Get USDC balance
var usdcBalances = await GetOrRefreshBalanceDataAsync(account.Name);
foreach (var account in userAccounts) var usdcBalance = usdcBalances?.UsdcValue ?? 0;
{ usdcWalletValue += usdcBalance;
// Get USDC balance
var usdcBalances = await GetOrRefreshBalanceDataAsync(account.Name);
var usdcBalance = usdcBalances?.UsdcValue ?? 0;
usdcWalletValue += usdcBalance;
}
foreach (var position in positions.Where(p => !p.IsFinished()))
{
var positionUsd = position.Open.Price * position.Open.Quantity;
var realized = position.ProfitAndLoss?.Realized ?? 0;
usdcInPositionsValue += positionUsd + realized;
}
totalBalance = usdcWalletValue + usdcInPositionsValue;
} }
foreach (var position in positions.Where(p => !p.IsFinished()))
{
var positionUsd = position.Open.Price * position.Open.Quantity;
var realized = position.ProfitAndLoss?.Realized ?? 0;
usdcInPositionsValue += positionUsd + realized;
}
totalBalance = usdcWalletValue + usdcInPositionsValue;
} }
catch (Exception ex) catch (Exception ex)
{ {
@@ -232,23 +228,24 @@ public class AgentGrain : Grain, IAgentGrain
usdcInPositionsValue = 0; usdcInPositionsValue = 0;
} }
var bots = await ServiceScopeHelpers.WithScopedService<IBotService, IEnumerable<Bot>>(_scopeFactory, var activeStrategies = await ServiceScopeHelpers.WithScopedService<IBotService, List<Bot>>(_scopeFactory,
async (botService) => { return await botService.GetBotsByUser((int)this.GetPrimaryKeyLong()); }); async (botService) =>
{
return (await botService.GetBotsByUser((int)this.GetPrimaryKeyLong()))
.Where(b => b.Status == BotStatus.Running)
.ToList();
});
// Calculate Runtime based on the earliest position date // Calculate Runtime based on the earliest position date
DateTime? runtime = null; DateTime? runtime = null;
if (positions.Any())
{
runtime = bots.Min(p => p.StartupTime);
}
var activeStrategiesCount = bots.Count(b => b.Status == BotStatus.Running);
// Calculate bots allocation USD value from bot configurations
var botsAllocationUsdValue = 0m; var botsAllocationUsdValue = 0m;
if (bots.Any())
if (activeStrategies.Any())
{ {
var botIds = bots.Select(b => b.Identifier); runtime = activeStrategies.Min(p => p.StartupTime);
// Calculate bots allocation USD value from bot configurations
var botIds = activeStrategies.Select(b => b.Identifier);
var botConfigs = var botConfigs =
await ServiceScopeHelpers.WithScopedService<IBotService, IEnumerable<TradingBotConfig>>( await ServiceScopeHelpers.WithScopedService<IBotService, IEnumerable<TradingBotConfig>>(
_scopeFactory, _scopeFactory,
@@ -266,7 +263,7 @@ public class AgentGrain : Grain, IAgentGrain
Losses = totalLosses, Losses = totalLosses,
TotalROI = totalROI, TotalROI = totalROI,
Runtime = runtime, Runtime = runtime,
ActiveStrategiesCount = activeStrategiesCount, ActiveStrategiesCount = activeStrategies.Count(),
TotalVolume = totalVolume, TotalVolume = totalVolume,
TotalBalance = totalBalance, TotalBalance = totalBalance,
TotalFees = totalFees, TotalFees = totalFees,
@@ -276,7 +273,8 @@ public class AgentGrain : Grain, IAgentGrain
await _agentService.SaveOrUpdateAgentSummary(summary); await _agentService.SaveOrUpdateAgentSummary(summary);
// Insert balance tracking data // Insert balance tracking data
InsertBalanceTrackingData(totalBalance, botsAllocationUsdValue, netPnL, usdcWalletValue, usdcInPositionsValue); InsertBalanceTrackingData(totalBalance, botsAllocationUsdValue, netPnL, usdcWalletValue,
usdcInPositionsValue);
_logger.LogDebug( _logger.LogDebug(
"Updated agent summary from position data for user {UserId}: NetPnL={NetPnL}, TotalPnL={TotalPnL}, Fees={Fees}, Volume={Volume}, Wins={Wins}, Losses={Losses}", "Updated agent summary from position data for user {UserId}: NetPnL={NetPnL}, TotalPnL={TotalPnL}, Fees={Fees}, Volume={Volume}, Wins={Wins}, Losses={Losses}",
@@ -633,7 +631,8 @@ public class AgentGrain : Grain, IAgentGrain
/// <summary> /// <summary>
/// Inserts balance tracking data into the AgentBalanceRepository /// Inserts balance tracking data into the AgentBalanceRepository
/// </summary> /// </summary>
private void InsertBalanceTrackingData(decimal totalAccountUsdValue, decimal botsAllocationUsdValue, decimal pnl, decimal usdcWalletValue, decimal usdcInPositionsValue) private void InsertBalanceTrackingData(decimal totalAccountUsdValue, decimal botsAllocationUsdValue, decimal pnl,
decimal usdcWalletValue, decimal usdcInPositionsValue)
{ {
try try
{ {
@@ -657,7 +656,8 @@ public class AgentGrain : Grain, IAgentGrain
} }
catch (Exception ex) catch (Exception ex)
{ {
_logger.LogError(ex, "Error inserting balance tracking data for user {UserId}", (int)this.GetPrimaryKeyLong()); _logger.LogError(ex, "Error inserting balance tracking data for user {UserId}",
(int)this.GetPrimaryKeyLong());
} }
} }
} }