#region S# License
/******************************************************************************************
NOTICE!!!  This program and source code is owned and licensed by
StockSharp, LLC, www.stocksharp.com
Viewing or use of this code requires your acceptance of the license
agreement found at https://github.com/StockSharp/StockSharp/blob/master/LICENSE
Removal of this comment is a violation of the license agreement.

Project: SampleQuikCandles.SampleQuikCandlesPublic
File: MainWindow.xaml.cs
Created: 2015, 11, 11, 2:32 PM

Copyright 2010 by StockSharp, LLC
*******************************************************************************************/
#endregion S# License
namespace SampleQuikCandles
{
	using System.Collections.Generic;
	using System.ComponentModel;
	using System.Net;
	using System.Security;
	using System.Windows;

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

	using StockSharp.Algo;
	using StockSharp.Algo.Candles;
	using StockSharp.BusinessEntities;
	using StockSharp.Localization;
	using StockSharp.Logging;
	using StockSharp.Quik;
	using StockSharp.Xaml.Charting;
    using StockSharp.Algo.Storages;
    using StockSharp.Algo.Storages.Csv;
    using StockSharp.Messages;
    using StockSharp.Quik.Lua;

	partial class MainWindow
	{
		private readonly Dictionary<CandleSeries, ChartWindow> _chartWindows = new Dictionary<CandleSeries, ChartWindow>();
		private Connector _trader;
		private CandleManager _candleManager;
		private readonly LogManager _logManager;

		public MainWindow()
		{
			InitializeComponent();

			// попробовать сразу найти месторасположение Quik по запущенному процессу
			QuikPath.Folder = QuikTerminal.GetDefaultPath();

			//Добавим логирование
			_logManager = new LogManager
			{
				Application = { LogLevel = LogLevels.Debug }
			};

			_logManager.Listeners.Add(new FileLogListener
			{
				LogDirectory = @"Logs\",
				SeparateByDates = SeparateByDateModes.SubDirectories,
				Append = false,
			});
		}

		private void ConnectClick(object sender, RoutedEventArgs e)
		{
			var isLua = IsLua.IsChecked == true;

			if (isLua)
			{
				if (Address.Text.IsEmpty())
				{
					MessageBox.Show(this, LocalizedStrings.Str2977);
					return;
				}

				if (Login.Text.IsEmpty())
				{
					MessageBox.Show(this, LocalizedStrings.Str2978);
					return;
				}

				if (Password.Password.IsEmpty())
				{
					MessageBox.Show(this, LocalizedStrings.Str2979);
					return;
				}
			}
			else
			{
				if (QuikPath.Folder.IsEmpty())
				{
					MessageBox.Show(this, LocalizedStrings.Str2983);
					return;
				}
			}

			if (_trader == null)
			{
				// создаем подключение
				//_trader = isLua
				//	? new QuikTrader
				//	{
				//		LuaFixServerAddress = Address.Text.To<EndPoint>(),
				//		LuaLogin = Login.Text,
				//		LuaPassword = Password.Password.To<SecureString>()
				//	}
				//	: new QuikTrader(QuikPath.Folder) { IsDde = true };

				//if (_trader.IsDde)
				//{
				//	_trader.DdeTables = new[] { _trader.SecuritiesTable, _trader.TradesTable };
				//}

				//_logManager.Sources.Add(_trader);

                CsvEntityRegistry entityRegistry = new CsvEntityRegistry("c:\\Users\\Evgeny\\AppData\\Roaming\\StockSharpSLN\\");
                IMarketDataDrive dataDrive = new LocalMarketDataDrive("e:\\Evgeny\\Documents\\Trading\\Данные\\PRD\\");
                StorageRegistry storage = new StorageRegistry { DefaultDrive = dataDrive };
                //_trader.InitializeStorage(entityRegistry, storage);

                _trader = new Connector(entityRegistry, storage);
                IMessageAdapter adapter1 = new LuaFixMarketDataMessageAdapter(_trader.TransactionIdGenerator);
                _trader.Adapter.InnerAdapters.Add(adapter1);
                IMessageAdapter adapter2 = new LuaFixTransactionMessageAdapter(_trader.TransactionIdGenerator);
                _trader.Adapter.InnerAdapters.Add(adapter2);
                _logManager.Sources.Add(_trader);

                // подписываемся на событие об успешном восстановлении соединения
                _trader.Restored += () => this.GuiAsync(() => MessageBox.Show(this, LocalizedStrings.Str2958));

				// подписываемся на событие разрыва соединения
				_trader.ConnectionError += error => this.GuiAsync(() => MessageBox.Show(this, error.ToString()));

				// подписываемся на ошибку обработки данных (транзакций и маркет)
				_trader.Error += error =>
					this.GuiAsync(() => MessageBox.Show(this, error.ToString(), "Ошибка обработки данных"));

				// подписываемся на ошибку подписки маркет-данных
				_trader.MarketDataSubscriptionFailed += (security, msg, error) =>
					this.GuiAsync(() => MessageBox.Show(this, error.ToString(), LocalizedStrings.Str2956Params.Put(msg.DataType, security)));

				Security.SecurityProvider = new FilterableSecurityProvider(_trader);

				_trader.Connect();

				_candleManager = new CandleManager(_trader);
				_candleManager.Processing += DrawCandle;

				ConnectBtn.IsEnabled = false;
			}
		}

		private void DrawCandle(CandleSeries series, Candle candle)
		{
			var wnd = _chartWindows.TryGetValue(series);

			if (wnd != null)
				wnd.Chart.Draw((ChartCandleElement)wnd.Chart.Areas[0].Elements[0], candle);
		}

		protected override void OnClosing(CancelEventArgs e)
		{
			foreach (var pair in _chartWindows)
				pair.Value.DeleteHideable();

			if (_trader != null)
			{
				_trader.Dispose();
			}

			base.OnClosing(e);
		}

		private Security SelectedSecurity => Security.SelectedSecurity;

		private void OnSecuritySelected()
		{
			ShowChart.IsEnabled = SelectedSecurity != null;
		}

		private void ShowChartClick(object sender, RoutedEventArgs e)
		{
			var security = SelectedSecurity;

			var series = new CandleSeries(CandlesSettings.Settings.CandleType, security, CandlesSettings.Settings.Arg);

			_chartWindows.SafeAdd(series, key =>
			{
				var wnd = new ChartWindow
				{
					Title = "{0} {1} {2}".Put(security.Code, series.CandleType.Name, series.Arg)
				};

				wnd.MakeHideable();

				var area = new ChartArea();
				wnd.Chart.Areas.Add(area);

				var candlesElem = new ChartCandleElement();
				area.Elements.Add(candlesElem);

				return wnd;
			}).Show();

            series.Security.WhenNewTrade(_trader).Do((Trade trade) =>
            {
                int a = 1;
            }).Apply();
            _candleManager.WhenCandlesFinished(series).Do((Candle candle) =>
            {
                int b = 1;
            }).Apply();
			_candleManager.Start(series, new System.DateTimeOffset(2017, 08, 1, 0, 0, 0, new System.TimeSpan(3, 0, 0)), System.DateTimeOffset.MaxValue);
		}



    }
}