Compare commits
2 Commits
8b38421be4
...
42bc5780c1
Author | SHA1 | Date |
---|---|---|
|
42bc5780c1 | |
|
0db2d4b1bb |
|
@ -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);
|
||||||
|
|
|
@ -222,12 +222,15 @@ namespace KLHZ.Trader.Core.Exchange.Services
|
||||||
await AddData(price);
|
await AddData(price);
|
||||||
|
|
||||||
var cachedData = await GetData(price.Figi);
|
var cachedData = await GetData(price.Figi);
|
||||||
|
if ((DateTime.UtcNow - price.Time).TotalMinutes < 5)
|
||||||
|
{
|
||||||
if (ShapeAreaCalculator.TryGetAreasRelation(cachedData.timestamps, cachedData.prices, price.Value, Constants.AreasRelationWindow, out var rel))
|
if (ShapeAreaCalculator.TryGetAreasRelation(cachedData.timestamps, cachedData.prices, price.Value, Constants.AreasRelationWindow, out var rel))
|
||||||
{
|
{
|
||||||
await AddDataTo1MinuteWindowCache(price.Figi, Constants._1minCacheKey, new CachedValue() { Time = price.Time, Value = (decimal)rel });
|
await AddDataTo1MinuteWindowCache(price.Figi, Constants._1minCacheKey, new CachedValue() { Time = price.Time, Value = (decimal)rel });
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
}
|
||||||
|
|
||||||
_ = SyncPortfolioWorker();
|
_ = SyncPortfolioWorker();
|
||||||
_ = WritePricesTask();
|
_ = WritePricesTask();
|
||||||
|
|
Loading…
Reference in New Issue