Наблюдаю на 4.1.8
Проявляет себя как не вызывание события NewMyTrades у объекта EmulationTrader as ITrader (существует и такой по мимо RealTimeEmulationTrader).
Схема такая: ( прошу не задавать вопросы зачем это нужно :) )
1) создаем объект EmulationTrader, нацеленный на некоторую базу гидры.
2) создаем объект new RealTimeEmulationTrader<ITrader> (EmulationTrader as ITrader)
3) Создаем стратегию new MyStrategy(EmulationTrader as ITrader) с примерно следующим конструктором.
Code
MyStrategy(ITrader iDataSource)
{
iDataSource.NewMyTrades += (obj) => { MessageBox.Show("Приехали сделки"); };
}
запускаем и наблюдаем, что сделки то не приезжают.
Дальше веселее. Если поменять пункт 2 и 3 по порядку то есть сделать так:
1) создаем объект EmulationTrader, нацеленный на некоторую базу гидры.
3) Создаем стратегию new MyStrategy(EmulationTrader as ITrader)
2) создаем объект new RealTimeEmulationTrader<ITrader> (EmulationTrader as ITrader).
Сделки приедут.
В логах можно обнаружить следующее.
Quote:
2012/02/24 10:06:10.000|Error |EmulationTrader|System.InvalidOperationException: Ордер с transactionId=101 не найден
at StockSharp.Algo.Testing.RealTimeEmulationTrader`1.#=qoYen7SIGXXIHC5yDoBmtakvI8ajVk$YMRTG2hIXiflw=(Int64 #=qO9iU2Mv29dcXgUc$4EMffw==)
at StockSharp.Algo.Testing.RealTimeEmulationTrader`1.#=qW_NOGPO8hUy5l8I2xNZCL$oRPjjivnoDpJ2KizA3TPo=(IEnumerable`1 #=qA0Q6xXtG5Oyta7t6dDl7yg==)
at System.Action`1.Invoke(T obj)
at Ecng.Common.DelegateHelper.SafeInvoke[T](Action`1 handler, T arg)
at Ecng.ComponentModel.EventsContainer`1.Raise(IEnumerable`1 items)
2012/02/24 10:06:10.000| |EmulationTrader|New order: 102/2 Покупка Цена=7025,00000 Объем=1 Сост=Active Бал=1
2012/02/24 10:06:10.000|Error |EmulationTrader|System.InvalidOperationException: Ордер с transactionId=102 не найден
at StockSharp.Algo.Testing.RealTimeEmulationTrader`1.#=qoYen7SIGXXIHC5yDoBmtakvI8ajVk$YMRTG2hIXiflw=(Int64 #=qO9iU2Mv29dcXgUc$4EMffw==)
at StockSharp.Algo.Testing.RealTimeEmulationTrader`1.#=qW_NOGPO8hUy5l8I2xNZCL$oRPjjivnoDpJ2KizA3TPo=(IEnumerable`1 #=qA0Q6xXtG5Oyta7t6dDl7yg==)
at System.Action`1.Invoke(T obj)
at Ecng.Common.DelegateHelper.SafeInvoke[T](Action`1 handler, T arg)
at Ecng.ComponentModel.EventsContainer`1.Raise(IEnumerable`1 items)
Что наводит нас на мысли о том, что мы отправляем заявки через EmulationTrader он их обрабатывает и генерирует MyTrade которые выдает ее через событие NewMyTrades. Данные MyTrades перехватываются RealTimeEmulationTrader и обрабатываются в методе.
Code
private void NewMyTradesHandler(IEnumerable<MyTrade> trades)
{
foreach(var trade in trades)
{
trade.Order = GetOrderByTransaction(trade.Order.TransactionId);
}
NewMyTrades.SafeInvoke(trades);
}
и далее
private Order GetOrderByTransaction(long transactionId)
{
var order = _byTransactionOrders.TryGetValue(transactionId);
if(order == null)
throw new InvalidOperationException("Ордер с transactionId="+transactionId+" не найден");
return order;
}
Который выбрасывает исключение (потому что заявка подавалась не через эмулятор).
На событие NewMyTrades есть два подписчика. Подписчики лежат в чем то типо List<Action<IEnumerable<MyTrade>>> и при NewMyTrades.Invoke начинают вызываться в порядке в котором на событие были подписаны (ITrader.NewMyTrades += ... ) и соответственно при порядке исполнения 1),3),2) вначале вызывается обработчик стратегии а потом обработчик RealTimeEmulationTrader и вроде все хорошо. При порядке 1), 2), 3) выброшенное, необработанное исключение RealTimeEmulationTrader'ом прерывает перечисление обработчиков в List<Action<IEnumerable<MyTrade>>> и соответственно до обработчика стратегии действие не доходит и он не вызывается и получаем то, что имеем. (По крайней мере так я вижу проблему)
Как вариант, возможно есть смысл, немного подправить обработчик NewOrderHandler RealTimeEmulationTrader
Code
private void NewOrderHandler(Order state)
{
var order = GetOrderByTransaction(state.TransactionId); // (здесь кстати происходит точно такая же ситуация, только с событием NewOrder. Со всеми вытекающими.)
using (order.BeginUpdate())
{
order.Id = state.Id;
order.LastChangeTime = state.LastChangeTime;
order.Time = state.Time;
order.Balance = state.Balance;
order.State = state.State;
}
if (order.Type == OrderTypes.Conditional)
NewStopOrdersHandler(new[] { order });
else
NewOrdersHandler(new[] { order });
}
Что бы при выбрасывании исключения
Code
var order = GetOrderByTransaction(state.TransactionId);
оно обрабатывалось добавление нового ордера в коллекцию RealTimeEmulationTrader'а и что в свою очередь уберет проблему с выбрасыванием исключений при NewMyTrades (так как ордер уже будет в RealTimeEmulationTrader)