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

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

dev
vlad zverzhkhovskiy 2025-09-17 16:48:53 +03:00
parent 0db2d4b1bb
commit 42bc5780c1
1 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
KLHZ.Trader.Core/Exchange/Services/Trader.cs
View File

@ -76,7 +76,7 @@ namespace KLHZ.Trader.Core.Exchange.Services
public async Task StartAsync(CancellationToken cancellationToken) public async Task StartAsync(CancellationToken cancellationToken)
{ {
//await _tradeDataProvider.Init(); await _tradeDataProvider.Init();
_dataBus.AddChannel(nameof(Trader), _pricesChannel); _dataBus.AddChannel(nameof(Trader), _pricesChannel);
_dataBus.AddChannel(nameof(Trader), _ordersbookChannel); _dataBus.AddChannel(nameof(Trader), _ordersbookChannel);
_ = ProcessPrices(); _ = ProcessPrices();
@ -445,7 +445,11 @@ namespace KLHZ.Trader.Core.Exchange.Services
var sells = sberSells.Sum(s => s.Value); var sells = sberSells.Sum(s => s.Value);
var buys = sberBuys.Sum(s => s.Value); var buys = sberBuys.Sum(s => s.Value);
var su = sells + buys; var su = sells + buys;
if (su!=0)
{
var dsell = (sells / su - 0.5m) * 2; var dsell = (sells / su - 0.5m) * 2;
}
var mavTask = CheckByWindowAverageMean(data, message, windowMaxSize, -1, 2m); var mavTask = CheckByWindowAverageMean(data, message, windowMaxSize, -1, 2m);