фикс блокировок
test / deploy_trader_prod (push) Successful in 1m33s
Details
test / deploy_trader_prod (push) Successful in 1m33s
Details
parent
f36452001e
commit
941e00e346
|
@ -231,7 +231,6 @@ namespace KLHZ.Trader.Core.Exchange.Services
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
continue;
|
|
||||||
if (_tradingInstrumentsFigis.Contains(message.Figi))
|
if (_tradingInstrumentsFigis.Contains(message.Figi))
|
||||||
{
|
{
|
||||||
var currentTime = message.IsHistoricalData ? message.Time : DateTime.UtcNow;
|
var currentTime = message.IsHistoricalData ? message.Time : DateTime.UtcNow;
|
||||||
|
@ -691,7 +690,7 @@ namespace KLHZ.Trader.Core.Exchange.Services
|
||||||
if (acc.Value.Assets.TryGetValue(message.Figi, out var asset))
|
if (acc.Value.Assets.TryGetValue(message.Figi, out var asset))
|
||||||
{
|
{
|
||||||
var order = acc.Value.Orders.Values.FirstOrDefault(o => o.Figi == message.Figi && o.Direction == DealDirection.Sell);
|
var order = acc.Value.Orders.Values.FirstOrDefault(o => o.Figi == message.Figi && o.Direction == DealDirection.Sell);
|
||||||
if (order == null && asset.Count > 0 && await asset.Lock(TimeSpan.FromSeconds(60))
|
if (order == null && asset.Count > 0 && await asset.Lock(TimeSpan.FromSeconds(60)))
|
||||||
{
|
{
|
||||||
var command = new TradeCommand()
|
var command = new TradeCommand()
|
||||||
{
|
{
|
||||||
|
|
Loading…
Reference in New Issue