vladzvx
/
klhztrader
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

фикс скорости старта
test / deploy_trader_prod (push) Successful in 1m44s Details

dev
vlad zverzhkhovskiy 2025-09-17 17:05:32 +03:00
parent 6e74c05c6d
commit 6c338b1f4f
1 changed files with 5 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
KLHZ.Trader.Core/Exchange/Services/TraderDataProvider.cs
View File

@ -43,6 +43,7 @@ namespace KLHZ.Trader.Core.Exchange.Services
internal readonly ConcurrentDictionary<string, ManagedAccount> Accounts = new(); internal readonly ConcurrentDictionary<string, ManagedAccount> Accounts = new();
private readonly bool _isDataRecievingAllowed = false; private readonly bool _isDataRecievingAllowed = false;
private readonly Channel<object> _forSave = Channel.CreateUnbounded<object>(); private readonly Channel<object> _forSave = Channel.CreateUnbounded<object>();
private readonly SemaphoreSlim _syncSemaphore = new SemaphoreSlim(1, 1);
private readonly SemaphoreSlim _initSemaphore = new SemaphoreSlim(1, 1); private readonly SemaphoreSlim _initSemaphore = new SemaphoreSlim(1, 1);
public TraderDataProvider(InvestApiClient investApiClient, IOptions<ExchangeConfig> options, IDbContextFactory<TraderDbContext> dbContextFactory, ILogger<ManagedAccount> logger) public TraderDataProvider(InvestApiClient investApiClient, IOptions<ExchangeConfig> options, IDbContextFactory<TraderDbContext> dbContextFactory, ILogger<ManagedAccount> logger)
@ -170,7 +171,8 @@ namespace KLHZ.Trader.Core.Exchange.Services
{ {
try try
{ {
await _initSemaphore.WaitAsync(TimeSpan.FromSeconds(3)); var cts = new CancellationTokenSource(TimeSpan.FromSeconds(3));
await _initSemaphore.WaitAsync(cts.Token);
var shares = await _investApiClient.Instruments.SharesAsync(); var shares = await _investApiClient.Instruments.SharesAsync();
foreach (var share in shares.Instruments) foreach (var share in shares.Instruments)
{ {
@ -264,7 +266,7 @@ namespace KLHZ.Trader.Core.Exchange.Services
try try
{ {
await _initSemaphore.WaitAsync(TimeSpan.FromSeconds(5)); await _syncSemaphore.WaitAsync();
var portfolio = await _investApiClient.Operations.GetPortfolioAsync(new PortfolioRequest() var portfolio = await _investApiClient.Operations.GetPortfolioAsync(new PortfolioRequest()
{ {
AccountId = account.AccountId, AccountId = account.AccountId,
@ -354,7 +356,7 @@ namespace KLHZ.Trader.Core.Exchange.Services
_logger.LogError(ex, "Ошибка при синхранизации портфеля счёта {accountId}", account.AccountId); _logger.LogError(ex, "Ошибка при синхранизации портфеля счёта {accountId}", account.AccountId);
} }
_initSemaphore.Release(); _syncSemaphore.Release();
} }
internal async Task UpdateFuturesPrice(INewPrice newPrice, decimal newPriceValue) internal async Task UpdateFuturesPrice(INewPrice newPrice, decimal newPriceValue)