Сообщество. StockSharp

Событие изменения цены Bid / Ask

2012-04-04T06:04:29Z

Прошу извинения, если вопрос глупый, но я не нашел, есть ли какое событие которое вызывается когда изменилась цена Bid / Ask по инструменту? Интересует именно изменение цены, изменение количество контрактов выставленных по наилучшим ценам не важно для меня. Заранее спасибо!

Все свои сделки с начала дня

2012-04-03T16:49:26Z

Есть ли способ получить все свои сделки с начала дня (SmartCOM) ? После запуска экспорта поле MyTrades (объекта класса SmartTrader) содержит 0 сделок.
Запустил Sample Smart - похоже что неправильно отображается время заявок и количество сделок. При этом всего сделок в SmartTrade - 3 штуки, а в приложении отображается только одна. В чем может быть проблема ?

http://s13.postimage.org/whrk5tiol/screen.png

S# версия 4.0.23

Как BaseTrader выполняет MultiCast делегаты?

2012-04-03T14:30:20Z

Каждый из делегатов MultiCast делегата может попасть в свою нить? Или же все делегаты одного MultiCast делагата выполняются в общей нити?

Формат данных для Гидры

2012-04-03T12:31:46Z

В версии S# 4.0 формат данных был 1.XXX. В версии S# 4.1 было два формата, 2.0 и 3.0. Ниже два скрипта. Первый переводит 1.XXX в 2.0. Второй переводит из 2.0 в 3.0. Кто использует Гидру 4.0, нужно использовать оба скрипта, и прогнать их друг за другом. Кто уже использовал 4.1, то прогнать только второй. Пути, естественно, заменить в коде.

Конвертация в формат 2.0:

foreach (var secDir in Directory.EnumerateDirectories(@"d:\SS\D\HydraRi3"))
{
	if (Directory.EnumerateFiles(secDir).Any())
		continue;
				
	var dateDirs = Directory.GetDirectories(secDir);

	var prefixes = new[] { "trades", "quotes" };
	foreach (var prefix in prefixes)
	{
				
		var metaInfo = new Dictionary<DateTime, IDictionary<string, object>>();



		foreach (var dir in dateDirs)
		{
			var date = Path.GetFileName(dir).ToDateTime("yyyy_MM_dd");

			var files = Directory.GetFiles(dir);


			var meta = files.FirstOrDefault(f => Path.GetFileName(f) == prefix+".xml");
			var data = files.FirstOrDefault(f => Path.GetFileName(f) == prefix+".bin");
			if (null != meta)
			{
				CultureInfo.InvariantCulture.DoInCulture(() => metaInfo.Add(date, new XmlSerializer<IDictionary<string, object>>().Deserialize(meta)));

				File.Move(data, Path.Combine(secDir, prefix + "_" + Path.GetFileName(dir) + ".bin"));
			}
		}
		CultureInfo.InvariantCulture.DoInCulture(() => new XmlSerializer<IDictionary<DateTime, IDictionary<string, object>>>().Serialize(metaInfo, Path.Combine(secDir, prefix+".xml")));
	}

	foreach (var dir in dateDirs)
	{
		Directory.Delete(dir, true);
	}

	Console.WriteLine(Path.GetFileName(secDir));
}

Конвертация в формат 3.0:

var input = @"d:\SS\D\HydraRi3";
var output = @"d:\SS\D\HydraRi5.1";

foreach (var secDir in Directory.EnumerateDirectories(input))
{
	var prefixes = new[] { "quotes", "trades", "orderLog" };
	var secId = Path.GetFileName(secDir);
	Directory.CreateDirectory(Path.Combine(output,secId));
	foreach (var prefix in prefixes)
	{
		var metafile = secDir + "\\" + prefix + ".xml";
		if (File.Exists(metafile))
		{
			IDictionary<DateTime, IDictionary<string, object>> data=null; 
			CultureInfo.InvariantCulture.DoInCulture(() => data = new XmlSerializer<IDictionary<DateTime, IDictionary<string, object>>>().Deserialize(metafile));
			//Directory.EnumerateFiles(secDir);
			foreach (var date in data.Keys)
			{
				var fileName = "{0}_{1}.bin".Put(prefix, date.ToString("yyyy_MM_dd"));
				fileName = Path.Combine(secDir,fileName);
				if (File.Exists(fileName))
				{
					var outSecDir = Path.Combine(output, secId, date.ToString("yyyy_MM_dd"));
					Directory.CreateDirectory(outSecDir);

					var outFile = Path.Combine(outSecDir, prefix + ".bin");
					using (var s = new FileStream(outFile, FileMode.Create, FileAccess.Write))
					{
						var dict = data[date];

						s.WriteByte(3); s.WriteByte(0);
						s.Write((int)dict["count"]);
						s.Write((decimal)dict["minStepSize"]);
						s.Write((decimal)0);
						s.Write(new DateTime(dict["firstTime"].To<long>()));
						s.Write(new DateTime(dict["prevTime"].To<long>()));

						if (prefix.Equals("trades"))
						{
							s.Write((long)dict["firstId"]);
							s.Write((long)dict["prevId"]);
							s.Write((decimal)dict["firstPrice"]);
							s.Write((decimal)dict["prevPrice"]); 
						}
						else if (prefix.Equals("quotes"))
						{
							s.Write((decimal)dict["firstPrice"]);
							s.Write((decimal)dict["prevPrice"]); 									
						}
						else if (prefix.Equals("orderLog"))
						{
							s.Write((long)dict["firstOrderId"]);
							s.Write((long)dict["firstTradeId"]);
							s.Write((long)dict["prevOrderId"]);
							s.Write((long)dict["prevTradeId"]);
							s.Write((decimal)dict["firstPrice"]);
							s.Write((decimal)dict["prevPrice"]);
						}

						s.WriteRaw(File.ReadAllBytes(fileName));
					}
				}
			}
		}
	}
}

Какой теперь формат у файлов гидры?

2012-04-03T11:34:55Z

Был S# 4.1 - 15891

Данные для 4.1 конвертировал из 4.0 с помощью этого

Обновился до 4.1 - 15979. Формат данных поменялся

Чем теперь конвертировать? И из какого формата? Из 4.0 или из старого 4.1?

подключение с помощью OEC коннектора к демо доступу

2012-04-03T10:39:43Z

Попробовал подключиться с данными для демо доступа к api.openecry.com:9200 Видно для демо доступа другой адрес. Есть у кого нить эти данные, а то в тех. поддержки OEC меня так и не поняли.

не все заявки в QuikTrader.Orders в последней версии 23

2012-04-03T08:49:19Z

решил обновиться до новой версии, в Квике висит открытая лимита , в коллекции заявок её нету. откатился назад до декабрьской 16ой, всё гуд

Синхронизация времени с биржей

2012-04-03T06:44:43Z

Есть такой код по синхронизации времени:


Trader = new QuikTrader(Path.Text);
this.GuiAsync(() => Trader.SyncMarketTime(Exchange.Rts));

После выполнения этого кода, если сравнить время Trader.MarketTime и время в терминале Quik, то видно что разница составляет примерно 23 секунды. Пробовал вторую строку заменить на такую:

this.GuiAsync(() => Trader.SyncMarketTime(Exchange.Micex));

Так же время отличается.

Уточнял у брокера, сказали что время у них на сервер одинаковое с биржей.

Подскажите почему не верно синхронизируется время?

Requested Clipboard operation did not succeed

2012-04-03T03:59:50Z

Вылетает при запуске гидры на слабых машинах под win2k3.. жалуется на:

Securities.ForEach(_trader.Trader.RegisterQuotes)

Можно как-то вылечить?

Получение не всех сделок из quik

2012-04-03T03:46:41Z

Как из quik получить не все последние сделки, а сделки:

за последние N секунд(минут)
N последних сделок. это возможно?

последняя dev-версия, ошибка

2012-04-02T18:40:47Z

В TradesWindow.xaml.cs возникает ошибка. Подробнее на скриншоте:

v4.0.23 RIM2 MinStepPrice

2012-04-02T10:42:01Z

MinStepPrice не правильно показывает значения, у RIM2 ~ 2.94, а Security.MinStepPrice = 1 (у других инструментов не проверял)

Утечки памяти при тестировании на исторических данных

2012-04-02T09:41:15Z

Обнаружил утечки памяти при тестировании на исторических данных, при многократном повторении. Сначал грешил на свою стратегию, потом попробовал запускать пример SampleHistoryTesting многократно, При достижении 30-40 повторений программа подвисала, не выдавая никаких сообщений.

Далее, для чистоты эксперимента подправил код SampleHistoryTesting:

		private void StartBtn_Click( object sender, RoutedEventArgs e ) {
				
			for( int i = 1; i < 1000; i++ ) {
				Run();

				if( _trader.State != EmulationStates.Started ) { Thread.Sleep( 10 );  }
				if( _trader.State != EmulationStates.Stopped ) { Thread.Sleep( 10 ); }
			}

			MessageBox.Show( "Закончено" );
		}
		
		
		private void Run()
		{
		
		// Ну а тут сам код стратегии, что был раньше в StartBtn_Click 
		
		...
		
		// изменил только период, для более быстрого тестирования
			var startTime = new DateTime(2009, 6, 1);
			var stopTime = new DateTime(2009, 6, 3);
		
		....
		
		}

После запуска данный код через некоторое время выдает Out of memory эксепшн. (Пробовал, как с включенным выводом инфы в форму, так и выключеным)

на 100 итерациях уже все нормально проходит.

Памяти достаточно - 4 гб озу

Текст исключения:

System.OutOfMemoryException: Выдано исключение типа "System.OutOfMemoryException".

в System.Linq.Buffer1.ToArray() в System.Linq.Enumerable.ToArray[TSource](IEnumerable1 source) в Ecng.Common.RandomArray1..ctor(T min, T max, Int32 count) в StockSharp.Algo.Testing.MarketDataGenerator1.Init() в StockSharp.Algo.Testing.TrendMarketDepthGenerator.Init() в StockSharp.Algo.Testing.EmulationTrader.Start(DateTime startDate, DateTime stopDate) в SampleHistoryTesting.MainWindow.Run() в C:\Projects\VS\OrigSampleHistoryTesting\MainWindow.xaml.cs:строка 219 в SampleHistoryTesting.MainWindow.StartBtn_Click(Object sender, RoutedEventArgs e) в C:\Projects\VS\OrigSampleHistoryTesting\MainWindow.xaml.cs:строка 63 в System.Windows.RoutedEventHandlerInfo.InvokeHandler(Object target, RoutedEventArgs routedEventArgs) в System.Windows.EventRoute.InvokeHandlersImpl(Object source, RoutedEventArgs args, Boolean reRaised) в System.Windows.UIElement.RaiseEventImpl(DependencyObject sender, RoutedEventArgs args) в System.Windows.UIElement.RaiseEvent(RoutedEventArgs e) в System.Windows.Controls.Primitives.ButtonBase.OnClick() в System.Windows.Controls.Button.OnClick() в System.Windows.Controls.Primitives.ButtonBase.OnMouseLeftButtonUp(MouseButtonEventArgs e) в System.Windows.UIElement.OnMouseLeftButtonUpThunk(Object sender, MouseButtonEventArgs e) в System.Windows.Input.MouseButtonEventArgs.InvokeEventHandler(Delegate genericHandler, Object genericTarget) в System.Windows.RoutedEventArgs.InvokeHandler(Delegate handler, Object target) в System.Windows.RoutedEventHandlerInfo.InvokeHandler(Object target, RoutedEventArgs routedEventArgs) в System.Windows.EventRoute.InvokeHandlersImpl(Object source, RoutedEventArgs args, Boolean reRaised) в System.Windows.UIElement.ReRaiseEventAs(DependencyObject sender, RoutedEventArgs args, RoutedEvent newEvent) в System.Windows.UIElement.OnMouseUpThunk(Object sender, MouseButtonEventArgs e) в System.Windows.Input.MouseButtonEventArgs.InvokeEventHandler(Delegate genericHandler, Object genericTarget) в System.Windows.RoutedEventArgs.InvokeHandler(Delegate handler, Object target) в System.Windows.RoutedEventHandlerInfo.InvokeHandler(Object target, RoutedEventArgs routedEventArgs) в System.Windows.EventRoute.InvokeHandlersImpl(Object source, RoutedEventArgs args, Boolean reRaised) в System.Windows.UIElement.RaiseEventImpl(DependencyObject sender, RoutedEventArgs args) в System.Windows.UIElement.RaiseTrustedEvent(RoutedEventArgs args) в System.Windows.UIElement.RaiseEvent(RoutedEventArgs args, Boolean trusted) в System.Windows.Input.InputManager.ProcessStagingArea() в System.Windows.Input.InputManager.ProcessInput(InputEventArgs input) в System.Windows.Input.InputProviderSite.ReportInput(InputReport inputReport) в System.Windows.Interop.HwndMouseInputProvider.ReportInput(IntPtr hwnd, InputMode mode, Int32 timestamp, RawMouseActions actions, Int32 x, Int32 y, Int32 wheel) в System.Windows.Interop.HwndMouseInputProvider.FilterMessage(IntPtr hwnd, WindowMessage msg, IntPtr wParam, IntPtr lParam, Boolean& handled) в System.Windows.Interop.HwndSource.InputFilterMessage(IntPtr hwnd, Int32 msg, IntPtr wParam, IntPtr lParam, Boolean& handled) в MS.Win32.HwndWrapper.WndProc(IntPtr hwnd, Int32 msg, IntPtr wParam, IntPtr lParam, Boolean& handled) в MS.Win32.HwndSubclass.DispatcherCallbackOperation(Object o) в System.Windows.Threading.ExceptionWrapper.InternalRealCall(Delegate callback, Object args, Int32 numArgs) в MS.Internal.Threading.ExceptionFilterHelper.TryCatchWhen(Object source, Delegate method, Object args, Int32 numArgs, Delegate catchHandler)

Создание своей StrategyRule в новых версиях

2012-04-02T04:50:10Z

Проблема появилась насколько помню после версии 4.0.21.

Нужно создать правило стратегии которое не принимает никаких аргументов - всегда делал это как написано в хелпе:


  private sealed class NewMyTradesStrategyRule : StrategyRule
  {
    ...
  }

Но после вышеуказанной версии данный код не работает с ошибкой:

Incorrect number of type parameters in reference to class 'StockSharp.Algo.Strategies.StrategyRule<TArg>'

Прошу прощения конечно за лоховство, тут наверное вопрос в знании С#, но пишу так как есть ошибочный пример в справке :)

Finam: не загружаются тики по склееному фьючерсу RTS (SPFB.RTS@RTS)

2012-04-01T06:03:10Z

Перестали загружаться тики по склеенному фьючерсу RTS с Финама:


Finam 11:36:41.2794157 Старт с 06.03.2012 для SPFB.RTS@RTS.
Finam 11:39:41.3397145 System.Net.WebException: Время ожидания операции истекло
   в System.Net.WebClient.DownloadDataInternal(Uri address, WebRequest& request)
   в System.Net.WebClient.DownloadString(Uri address)
   в StockSharp.Algo.History.Finam.FinamHistorySource.#=qScP2Jc5w3eE90Y3dMpNLtw==(Uri #=qZSDCjTj6KYNNBniIIdPPPQ==, String #=qHmykUNvDW$qFhELcRzT0Ng==)
   в StockSharp.Algo.History.Finam.FinamHistorySource.#=qn1OPeZc93j2GhsdQKUey_6Ehp2xoxSdxs$IDWvwRkq0=.#=qOA1sEbu9QMIYlXz6sSXkbeVCmXbX87YQ7_rOo2GmXVE=()
   в StockSharp.Algo.History.Finam.FinamHistorySource.#=qHbifJmfBUsQDj7cUJ1Q4LQ==[T](String #=qHgafCQS_YPdZsvZe9MyC5w==, Func`1 #=qLVCqCWlkOQwpBKQB0NxVFw==, Func`2 #=qiCxwInTpjqGgLS8ZVOzDGw==)
   в StockSharp.Algo.History.Finam.FinamHistorySource.GetTrades(Security security, DateTime time)
   в StockSharp.Hydra.Finam.FinamSource.Load() в F:\Sources\StockSharpReleases\StockSharp_4.0.23\Hydra\Plugins\Finam\FinamSource.cs:строка 151
   в StockSharp.Hydra.Worker.<>c__DisplayClass13.<Download>b__10(IMarketDataSource source) в F:\Sources\StockSharpReleases\StockSharp_4.0.23\Hydra\Hydra\Worker.cs:строка 187

По другим склеенным фьючерсам данные загружаются:


Finam 11:43:48.3688438 Старт с 06.03.2012 для SPFB.SBRF@RTS.
Для SPFB.SBRF@RTS загружено 97232 сделок.
Finam 11:44:18.3735600 Дата 30.03.2012 вне диапазона для SPFB.GAZR@RTS.
Finam 11:44:18.3735600 Старт с 07.03.2012 для SPFB.SBRF@RTS.
Для SPFB.SBRF@RTS загружено 77533 сделок.

Hydra 4.0.23

Ошибка System.Net.WebException: Требуется проверка подлинности посредника

2012-03-30T02:50:34Z

Не обновляется список инструментов в Гидре. Нажимаю на "Инструменты", выбираю "Finam" нажимаю обновить, возникает ошибка: "System.Net.WebException: Удаленный сервер возвратил ошибку (407). Требуется проверка подлинности посредника"

При этом закачка данных с РТС при нажатии на "Старт" в начальном окне осуществляется, значит подключиться к интернету получается. Выход в инет через прокси MS ISA. Почему так происходит? Как решить проблему?

Событийная модель

2012-03-29T19:35:59Z

Коллеги, прошу помощи! Есть много условий на выставление и изменение(перерегистрация)заявок. Все работает но в один момент заявка почему-то не выставляется. Понял что скорость анализа данных и выполнения условий мала.


private void button1_Click(object sender, RoutedEventArgs e)
        {
            bool flag=false;
            Globals.Trader.QuotesChanged += depth =>
            {
                List<MarketDepthPair> t = Globals.Trader.GetMarketDepth(security).GetTopPairs(1).ToList();
                foreach (MarketDepthPair t1 in t)
                {
                    decimal spread = t1.Ask.Price - t1.Bid.Price;
                    if (условие 1)
                    {
                        if (  flag==false)
                        {
                            Dispatcher.BeginInvoke(new Action(() =>
                            {
                                
                                order_buy = new Order
                                 {
                                     Portfolio = Portfolio,
                                     Price = ...,
                                     Security = security,
                                     Volume = 1,
                                     Direction = OrderDirections.Buy,
                                 };
                                Globals.Trader.RegisterOrder(order_buy);
                                order_sell = new Order
                                {
                                    Portfolio = Portfolio,
                                    Price = ...,
                                    Security = security,
                                    Volume = 1,
                                    Direction = OrderDirections.Sell,
                                };
                                Globals.Trader.RegisterOrder(order_sell);
                            }));
                            flag = true; 
                        }
                        else if(order_buy.State == OrderStates.Done && order_sell.State==OrderStates.Active) 
                        {
                            if (условие)
                            {
                                Dispatcher.BeginInvoke(new Action(() =>
                                {
                                    Globals.Trader.CancelOrder(order_sell);
                                    
                                    order_sell = new Order
                                    {
                                        Portfolio = Portfolio,
                                        Price = ....,
                                        Security = security,
                                        Volume = 1,
                                        Direction = OrderDirections.Sell,
                                    };
                                    Globals.Trader.RegisterOrder(order_sell);
                                }));
                            }
                            flag = true;
                        }
                        
                        else if (order_sell.State == OrderStates.Done && order_buy.State == OrderStates.Active)
                        {
                            if (условие)
                            {
                                Dispatcher.BeginInvoke(new Action(() =>
                                {
                                    Globals.Trader.CancelOrder(order_buy);
                                    order_buy = new Order
                                    {
                                        Portfolio = Portfolio,
                                        Price = ....,
                                        Security = security,
                                        Volume = 1,
                                        Direction = OrderDirections.Buy,
                                    };
                                    Globals.Trader.RegisterOrder(order_buy);
                                }));
                                flag = true;
                            }
                        }
                        else if (order_sell.State == OrderStates.Done && order_buy.State == OrderStates.Done)
                        {
                         
                            flag = false;
                        }
                        
                    }
                }
                
            };
            
        }

Понимаю, что if else - очень замедляет switch не подойдет, анализирую несколько переменных. Думаю создать события на каждое из условий. Может есть уже какие нибудь стандартизированные методы решения такой задачи?

Заранее благодарю!

SmartCOM и исторические данные

2012-03-29T14:37:41Z

Насколько корректные приходят исторические данные через SmartCOM ? Пытаюсь получить свечки за предыдущие дни, приходят данные не соответствующие данным в терминале. На форуме есть темы, что получать историю через SmartCOM - лучше не стоит. Так ли это ?

SampleCandles 4.1 ошибка NullReferenceException

2012-03-29T11:25:58Z

Версия 15891 Запускаю SampleCandles

Нажимаю на кнопку график, окно которое отрисовывает график подвисает и через некоторое время вываливается ошибка.

StackTrace


   в AmCharts.Windows.Stock.Data.DataSet.ProcessDataBoundItems()
   в AmCharts.Windows.Stock.Data.DataSet.ProcessItems()
   в AmCharts.Windows.Stock.Data.DataSet.get_AggregateData()
   в AmCharts.Windows.Stock.Graph.get_ActiveDataSet()
   в AmCharts.Windows.Stock.Graph.SetVisibleDataItems()
   в AmCharts.Windows.Stock.Graph.get_VisibleDataItems()
   в AmCharts.Windows.Stock.Graph.GetMinimumValue(DateTime fromDate, DateTime toDate)
   в AmCharts.Windows.Stock.Primitives.ValueAxis.SetLinearMinMax(DateTime fromDate, DateTime toDate, Int32 grid_count)
   в AmCharts.Windows.Stock.Primitives.ValueAxis.SetMinMax(DateTime fromDate, DateTime toDate, Int32 grid_count)
   в AmCharts.Windows.Stock.Chart.RecalculateValueAxes()
   в AmCharts.Windows.Stock.Chart.AdjustParts()
   в AmCharts.Windows.Stock.Chart.MeasureOverride(Size constraint)
   в System.Windows.FrameworkElement.MeasureCore(Size availableSize)
   в System.Windows.UIElement.Measure(Size availableSize)
   в System.Windows.ContextLayoutManager.UpdateLayout()
   в System.Windows.ContextLayoutManager.UpdateLayoutCallback(Object arg)
   в System.Windows.Media.MediaContext.InvokeOnRenderCallback.DoWork()
   в System.Windows.Media.MediaContext.FireInvokeOnRenderCallbacks()
   в System.Windows.Media.MediaContext.RenderMessageHandlerCore(Object resizedCompositionTarget)
   в System.Windows.Media.MediaContext.RenderMessageHandler(Object resizedCompositionTarget)
   в System.Windows.Threading.ExceptionWrapper.InternalRealCall(Delegate callback, Object args, Int32 numArgs)
   в MS.Internal.Threading.ExceptionFilterHelper.TryCatchWhen(Object source, Delegate method, Object args, Int32 numArgs, Delegate catchHandler)
   в System.Windows.Threading.DispatcherOperation.InvokeImpl()
   в System.Windows.Threading.DispatcherOperation.InvokeInSecurityContext(Object state)
   в System.Threading.ExecutionContext.runTryCode(Object userData)
   в System.Runtime.CompilerServices.RuntimeHelpers.ExecuteCodeWithGuaranteedCleanup(TryCode code, CleanupCode backoutCode, Object userData)
   в System.Threading.ExecutionContext.RunInternal(ExecutionContext executionContext, ContextCallback callback, Object state)
   в System.Threading.ExecutionContext.Run(ExecutionContext executionContext, ContextCallback callback, Object state, Boolean ignoreSyncCtx)
   в System.Threading.ExecutionContext.Run(ExecutionContext executionContext, ContextCallback callback, Object state)
   в System.Windows.Threading.DispatcherOperation.Invoke()
   в System.Windows.Threading.Dispatcher.ProcessQueue()
   в System.Windows.Threading.Dispatcher.WndProcHook(IntPtr hwnd, Int32 msg, IntPtr wParam, IntPtr lParam, Boolean& handled)
   в MS.Win32.HwndWrapper.WndProc(IntPtr hwnd, Int32 msg, IntPtr wParam, IntPtr lParam, Boolean& handled)
   в MS.Win32.HwndSubclass.DispatcherCallbackOperation(Object o)
   в System.Windows.Threading.ExceptionWrapper.InternalRealCall(Delegate callback, Object args, Int32 numArgs)
   в MS.Internal.Threading.ExceptionFilterHelper.TryCatchWhen(Object source, Delegate method, Object args, Int32 numArgs, Delegate catchHandler)
   в System.Windows.Threading.Dispatcher.InvokeImpl(DispatcherPriority priority, TimeSpan timeout, Delegate method, Object args, Int32 numArgs)
   в MS.Win32.HwndSubclass.SubclassWndProc(IntPtr hwnd, Int32 msg, IntPtr wParam, IntPtr lParam)
   в MS.Win32.UnsafeNativeMethods.DispatchMessage(MSG& msg)
   в System.Windows.Threading.Dispatcher.PushFrameImpl(DispatcherFrame frame)
   в System.Windows.Threading.Dispatcher.PushFrame(DispatcherFrame frame)
   в System.Windows.Threading.Dispatcher.Run()
   в System.Windows.Application.RunDispatcher(Object ignore)
   в System.Windows.Application.RunInternal(Window window)
   в System.Windows.Application.Run(Window window)
   в System.Windows.Application.Run()
   в SampleCandles.App.Main() в d:\StockSharp 4.1\Project\SampleCandles\obj\Debug\App.g.cs:строка 0
   в System.AppDomain._nExecuteAssembly(RuntimeAssembly assembly, String[] args)
   в System.AppDomain.ExecuteAssembly(String assemblyFile, Evidence assemblySecurity, String[] args)
   в Microsoft.VisualStudio.HostingProcess.HostProc.RunUsersAssembly()
   в System.Threading.ThreadHelper.ThreadStart_Context(Object state)
   в System.Threading.ExecutionContext.Run(ExecutionContext executionContext, ContextCallback callback, Object state, Boolean ignoreSyncCtx)
   в System.Threading.ExecutionContext.Run(ExecutionContext executionContext, ContextCallback callback, Object state)
   в System.Threading.ThreadHelper.ThreadStart()

Не приходят данные в CandleManager

2012-03-28T18:57:44Z

Доброго дня!

Пытаюсь получить Real Time данные через SmartCom. S# версия 4.0.22 Однако не происходят события на получение/изменение свечей. Подскажи, где у меня ошибка ?


using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Windows;
using System.Windows.Controls;
using System.Windows.Data;
using System.Windows.Documents;
using System.Windows.Input;
using System.Windows.Media;
using System.Windows.Media.Imaging;
using System.Windows.Navigation;
using System.Windows.Shapes;
using System.Threading;

using Ecng.Collections;
using Ecng.Common;
using Ecng.ComponentModel;
using Ecng.Xaml;

using StockSharp.Algo;
using StockSharp.Algo.Candles;
using StockSharp.Algo.Logging;
using StockSharp.Algo.Strategies;
using StockSharp.BusinessEntities;
using StockSharp.Smart;
using StockSharp.Xaml;

namespace SimpleRobot
{
    /// <summary>
    /// Логика взаимодействия для MainWindow.xaml
    /// </summary>
    public partial class MainWindow : Window
    {
        
        private string _login = "";
        private string _password = "";
        private string _account = "";
        private string _ipAddress = "95.131.26.246";
        private string secCode = "RIM2";

        private readonly TimeSpan _timeFrame = (TimeSpan)SmartTimeFrames.Minute15;  //Таймфрейм
        private static Portfolio _portfolio;    //Портфель
        private Security _sec;                  //Эмитент - Акция/Фьючерс/Опцион

        private SmartTrader _trader;            //Шлюз для SmartCOM
        private Logger _logger;                 //Логгер событий
        private CandleManager _candleManager;   //Менеджер свечей

        private bool _isConnected = false;              //Подключены ли
        private bool _isStartRecivePorfolio = false;    //Начилась ли загрузка портфелей
        private bool _isStartReciveSecurity = false;    //Начилась ли загрузка эмитентов

        private CandleToken token;


        public MainWindow()
        {
            InitializeComponent();
        }


        //Инициализация робота
        private void button1_Click(object sender, RoutedEventArgs e)
        {

            //Логгер
            _logger = new Logger(textBox1);

            //Ip address
            System.Net.IPAddress addr = System.Net.IPAddress.Parse(_ipAddress);
            System.Net.IPEndPoint server = new System.Net.IPEndPoint(addr, 8090);

            //Create Smart Trade шлюз
            _trader = new SmartTrader(_login, _password, server);

            //Подписываемся на все необходимые события
            _trader.Connected += Trader_Connected;
            _trader.Disconnected += Trader_Disconnected;
            _trader.NewHistoryCandles += Trader_GetHistoryCandles;
            _trader.ReConnectionSettings.ConnectionRestored += Trader_ConnectionRestored;
            _trader.ConnectionError += Trader_ConnectionError;
            _trader.NewPortfolios += Trader_NewPortfolios;
            _trader.NewSecurities += Trader_NewSecurities;

            // инициализируем механизм переподключения (будет автоматически соединяться
            // каждые 10 секунд, если шлюз потеряется связь с сервером)
            _trader.ReConnectionSettings.Interval = TimeSpan.FromSeconds(10);
            _trader.ReConnectionSettings.WorkingTime = Exchange.Rts.WorkingTime;

            _logger.Write("Инициализия программы");
        }


        //Соединение и передача данных
        private void button2_Click(object sender, RoutedEventArgs e)
        {
            //Устанавливаем соединение
            _trader.Connect();
        }



        //Запуск робота
        private void button3_Click(object sender, RoutedEventArgs e)
        {
            //Создаем менеджер свечей и подписываемся на события
            _candleManager = new CandleManager(_trader);
            _candleManager.CandlesStarted += CandleManager_GetCandles;
            _candleManager.CandlesChanged += CandleManager_GetCandles;
            _candleManager.CandlesFinished += CandleManager_GetCandles;

            //Устанавливаени таймфрейм для менеджер свечей
            TimeSpan currentTimeFrame = TimeSpan.FromSeconds(60);
            token = _candleManager.RegisterTimeFrameCandles(_sec, currentTimeFrame);
            //token = _candleManager.RegisterTimeFrameCandles(_sec, 1000);
            
            /*
            var candles = _candleManager.GetTimeFrameCandles(_sec, _timeFrame);

            foreach (Candle candle in candles)
            {
                //Выводим свечи в формате OHLC
                _logger.Write(candle.Time.ToString() + " " + candle.OpenPrice + " " + candle.HighPrice + " " + candle.LowPrice + " " + candle.ClosePrice + " " + candle.CloseVolume);
            }
            */
        }




        private void Trader_Connected()
        {
            this.GuiAsync(() =>
            {
                _isConnected = true;
                _logger.Write("Успешно подключены");

                //Начинаем Экспорт данных
                _trader.StartExport();
            });
        }


        private void Trader_Disconnected()
        {
            this.GuiAsync(() =>
            {
                if (_isConnected)
                {
                    _isConnected = false;
                    _trader.Disconnect();
                    _logger.Write("Отключены");
                }
            });
        }


        private void Trader_GetHistoryCandles(CandleToken token, IEnumerable<TimeFrameCandle> candles)
        {
            this.GuiAsync(() =>
            {
                _logger.Write("Принимаю исторические данные");
                //_candlesStarted.SafeInvoke(token, candles);
                //_candlesFinished.SafeInvoke(token, candles);
            });
        }


        private void Trader_ConnectionRestored()
        {
            this.GuiAsync(() =>
            {
                _logger.Write("Соединение восстановлено");
            });
        }


        private void Trader_ConnectionError(Exception e)
        {
            this.GuiAsync(() =>
            {
                _logger.Write("ОШИБКА: Ошибка соединения" + e.Message + " [" + e.ToString() + "]");
            });
        }

        
        private void Trader_NewPortfolios(IEnumerable<Portfolio> portfolios)
        {
            this.GuiAsync(() =>
            {
                if (_isConnected)
                {
                    if (!_isStartRecivePorfolio)
                    {
                        _logger.Write("Получение портфелей...");
                        _isStartRecivePorfolio = true;
                    }


                    // необходимое условие работы в SmartCOM
                    int pCount = 0;
                    foreach (Portfolio p in portfolios)
                    {
                        pCount++;
                        _trader.RegisterPortfolio(p);
                        _logger.Write("Инициализация портфеля " + p.ToString());
                    }

                    if (pCount == 0)
                    {
                        _logger.Write("Портфели не найдены");
                    }
                    else
                    {
                        // находим нужный портфель и присваиваем его переменной _portfolio
                        _portfolio = portfolios.FirstOrDefault(p => p.Name == _account);

                        if (_portfolio != null)
                        {
                            _logger.Write("Портфель " + _account + " появился");
                        }
                    }
                }
            });
        }



        private void Trader_NewSecurities(IEnumerable<Security> securities)
        {
            this.GuiAsync(() =>
            {
                if (_isConnected)
                {
                    if (!_isStartReciveSecurity)
                    {
                        _logger.Write("Получение инструментов...");
                        _isStartReciveSecurity = true;
                    }


                    if (_isConnected)
                    {
                        var sec = securities.FirstOrDefault(s => s.Code == secCode && s.Type == SecurityTypes.Future);
                        if (sec != null)
                        {
                            _logger.Write("Инструмент " + secCode + " успешно найден");

                            _sec = sec;
                        }
                    }
                }
            });
        }



        private void CandleManager_GetCandles(CandleToken token, IEnumerable<Candle> candles)
        {
            this.GuiAsync(() =>
            {
                foreach (Candle candle in candles)
                {
                    //Выводим свечи в формате OHLC
                    _logger.Write(candle.Time.ToString() + " " + candle.OpenPrice + " " + candle.HighPrice + " " + candle.LowPrice + " " + candle.ClosePrice + " " + candle.CloseVolume);
                }
            });
        }



    }
}