using System;
using System.Collections.Generic;
using System.Text;
using System.Diagnostics;
using System.Runtime.InteropServices;
using System.IO;
using System.Threading;
using System.Runtime.Serialization.Formatters.Binary;
using SlimDX;
using SlimDX.Direct3D9;
using FDK;
using SampleFramework;

namespace DTXMania
{
	internal class CEnumSongs							// #27060 2011.2.7 yyagi 曲リストを取得するクラス
	{													// ファイルキャッシュ(songslist.db)からの取得と、ディスクからの取得を、この一つのクラスに集約。

		public CSongs管理 Songs管理						// 曲の探索結果はこのSongs管理に読み込まれる
		{
			get;
			private set;
		}

		public bool IsSongListEnumCompletelyDone		// 曲リスト探索と、実際の曲リストへの反映が完了した？
		{
			get
			{
				return ( this.state == DTXEnumState.CompletelyDone );
			}
		}
		public bool IsSongListEnumerated				// 曲リスト探索が完了したが、実際の曲リストへの反映はまだ？
		{
			get
			{
				return ( this.state == DTXEnumState.Enumeratad );
			}
		}
		public bool IsSongListEnumStarted				// 曲リスト探索開始後？(探索完了も含む)
		{
			get
			{
				return ( this.state != DTXEnumState.None );
			}
		}
		public void SongListEnumCompletelyDone()
		{
			this.state = DTXEnumState.CompletelyDone;
		}
		private readonly string strPathSongsDB = CDTXMania.strEXEのあるフォルダ + "songs.db";
		private readonly string strPathSongList = CDTXMania.strEXEのあるフォルダ + "songlist.db";

		public Thread thDTXFileEnumerate
		{
			get;
			private set;
		}
		private enum DTXEnumState
		{
			None,
			Ongoing,
			Suspended,
			Enumeratad,			// 探索完了、現在の曲リストに未反映
			CompletelyDone		// 探索完了、現在の曲リストに反映完了
		}
		private DTXEnumState state = DTXEnumState.None;


		/// <summary>
		/// Constractor
		/// </summary>
		public CEnumSongs()
		{
			this.Songs管理 = new CSongs管理();
		}

		public void Init( List<Cスコア> ls, int n )
		{
			if ( state == DTXEnumState.None )
			{
				this.Songs管理.listSongsDB = ls;
				this.Songs管理.nSongsDBから取得できたスコア数 = n;
			}
		}

		/// <summary>
		/// 曲リストのキャッシュ(songlist.db)取得スレッドの開始
		/// </summary>
		public void StartEnumFromCache()
		{
			this.thDTXFileEnumerate = new Thread( new ThreadStart( this.t曲リストの構築1 ) );
			this.thDTXFileEnumerate.Name = "曲リストの構築";
			this.thDTXFileEnumerate.IsBackground = true;
			this.thDTXFileEnumerate.Start();
		}

		/// <summary>
		/// 
		/// </summary>
		public delegate void AsyncDelegate();

		/// <summary>
		/// 曲検索スレッドの開始
		/// </summary>
		public void StartEnumFromDisk()
		{
			if ( state == DTXEnumState.None )
			{
				Trace.TraceInformation( "★曲データ検索スレッドを起動しました。" );
				lock ( this )
				{
					state = DTXEnumState.Ongoing;
				}
				// this.autoReset = new AutoResetEvent( true );

				this.thDTXFileEnumerate = new Thread( new ThreadStart( this.t曲リストの構築2 ) );
				this.thDTXFileEnumerate.Name = "曲リストの構築";
				this.thDTXFileEnumerate.IsBackground = true;
				this.thDTXFileEnumerate.Priority = System.Threading.ThreadPriority.Lowest;
				this.thDTXFileEnumerate.Start();
			}
		}


		/// <summary>
		/// 曲探索スレッドのサスペンド
		/// </summary>
		public void Suspend()
		{
			if ( this.state != DTXEnumState.CompletelyDone &&
				( thDTXFileEnumerate.ThreadState == System.Threading.ThreadState.Background ) )
			{
				// this.thDTXFileEnumerate.Suspend();		// obsoleteにつき使用中止
				this.Songs管理.bIsSuspending = true;
				this.state = DTXEnumState.Suspended;
				Trace.TraceInformation( "★曲データ検索スレッドを中断しました。" );
			}
		}

		/// <summary>
		/// 曲探索スレッドのレジューム
		/// </summary>
		public void Resume()
		{
			if ( this.state == DTXEnumState.Suspended )
			{
				if ( ( this.thDTXFileEnumerate.ThreadState & ( System.Threading.ThreadState.WaitSleepJoin | System.Threading.ThreadState.StopRequested ) ) != 0 )	//
				{
					// this.thDTXFileEnumerate.Resume();	// obsoleteにつき使用中止
					this.Songs管理.bIsSuspending = false;
					this.Songs管理.AutoReset.Set();
					this.state = DTXEnumState.Ongoing;
					Trace.TraceInformation( "★曲データ検索スレッドを再開しました。" );
				}
			}
		}

		/// <summary>
		/// 曲探索スレッドにサスペンド指示を出してから、本当にサスペンド状態に遷移するまでの間、ブロックする
		/// 500ms * 10回＝5秒でタイムアウトし、サスペンド完了して無くてもブロック解除する
		/// </summary>
		public void WaitUntilSuspended()
		{
			// 曲検索が一時中断されるまで待機
			for ( int i = 0; i < 10; i++ )
			{
				if ( this.state == DTXEnumState.CompletelyDone ||
					( thDTXFileEnumerate.ThreadState & ( System.Threading.ThreadState.WaitSleepJoin | System.Threading.ThreadState.Background ) ) != 0 )
				{
					break;
				}
				Trace.TraceInformation( "★曲データ検索スレッドの中断待ちです: {0}", this.thDTXFileEnumerate.ThreadState.ToString() );
				Thread.Sleep( 500 );
			}

		}




		/// <summary>
		/// songlist.dbからの曲リスト構築
		/// </summary>
		public void t曲リストの構築1()
		{
			// ！注意！
			// 本メソッドは別スレッドで動作するが、プラグイン側でカレントディレクトリを変更しても大丈夫なように、
			// すべてのファイルアクセスは「絶対パス」で行うこと。(2010.9.16)
			// 構築が完了したら、DTXEnumerateState state を DTXEnumerateState.Done にすること。(2012.2.9)
			DateTime now = DateTime.Now;

			try
			{
				#region [ 0) システムサウンドの構築  ]
				//-----------------------------
				CDTXMania.stage起動.eフェーズID = CStage.Eフェーズ.起動0_システムサウンドを構築;

				Trace.TraceInformation( "0) システムサウンドを構築します。" );
				Trace.Indent();

				try
				{
					for ( int i = 0; i < CDTXMania.Skin.nシステムサウンド数; i++ )
					{
						CSkin.Cシステムサウンド cシステムサウンド = CDTXMania.Skin[ i ];
						if ( !CDTXMania.bコンパクトモード || cシステムサウンド.bCompact対象 )
						{
							try
							{
								cシステムサウンド.t読み込み();
								Trace.TraceInformation( "システムサウンドを読み込みました。({0})",cシステムサウンド.strファイル名 );
								if ( ( cシステムサウンド == CDTXMania.Skin.bgm起動画面 ) && cシステムサウンド.b読み込み成功 )
								{
									cシステムサウンド.t再生する();
								}
							}
							catch ( FileNotFoundException )
							{
								Trace.TraceWarning( "システムサウンドが存在しません。({0})", cシステムサウンド.strファイル名 );
							}
							catch ( Exception e )
							{
								Trace.TraceError( e.Message );
								Trace.TraceWarning( "システムサウンドの読み込みに失敗しました。({0})", cシステムサウンド.strファイル名 );
							}
						}
					}
					lock ( CDTXMania.stage起動.list進行文字列 )
					{
						CDTXMania.stage起動.list進行文字列.Add( "Loading system sounds ... OK " );
					}
				}
				finally
				{
					Trace.Unindent();
				}
				//-----------------------------
				#endregion

				if ( CDTXMania.bコンパクトモード )
				{
					Trace.TraceInformation( "コンパクトモードなので残りの起動処理は省略します。" );
					return;
				}

				#region [ 00) songlist.dbの読み込みによる曲リストの構築  ]
				//-----------------------------
				CDTXMania.stage起動.eフェーズID = CStage.Eフェーズ.起動00_songlistから曲リストを作成する;

				Trace.TraceInformation( "1) songlist.dbを読み込みます。" );
				Trace.Indent();

				try
				{
					if ( !CDTXMania.ConfigIni.bConfigIniがないかDTXManiaのバージョンが異なる )
					{
						CSongs管理 s = new CSongs管理();
						s = Deserialize( strPathSongList );		// 直接this.Songs管理にdeserialize()結果を代入するのは避ける。nullにされてしまうことがあるため。
						if ( s != null )
						{
							this.Songs管理 = s;
						}

						int scores = this.Songs管理.n検索されたスコア数;
						Trace.TraceInformation( "songlist.db の読み込みを完了しました。[{0}スコア]", scores );
						lock ( CDTXMania.stage起動.list進行文字列 )
						{
							CDTXMania.stage起動.list進行文字列.Add( "Loading songlist.db ... OK" );
						}
					}
					else
					{
						Trace.TraceInformation( "初回の起動であるかまたはDTXManiaのバージョンが上がったため、songlist.db の読み込みをスキップします。" );
						lock ( CDTXMania.stage起動.list進行文字列 )
						{
							CDTXMania.stage起動.list進行文字列.Add( "Loading songlist.db ... Skip" );
						}
					}
				}
				finally
				{
					Trace.Unindent();
				}

				#endregion

				#region [ 1) songs.db の読み込み ]
				//-----------------------------
				CDTXMania.stage起動.eフェーズID = CStage.Eフェーズ.起動1_SongsDBからスコアキャッシュを構築;

				Trace.TraceInformation( "2) songs.db を読み込みます。" );
				Trace.Indent();

				try
				{
					if ( !CDTXMania.ConfigIni.bConfigIniがないかDTXManiaのバージョンが異なる )
					{
						try
						{
							this.Songs管理.tSongsDBを読み込む( strPathSongsDB );
						}
						catch
						{
							Trace.TraceError( "songs.db の読み込みに失敗しました。" );
						}

						int scores = ( this.Songs管理 == null ) ? 0 : this.Songs管理.nSongsDBから取得できたスコア数;	// 読み込み途中でアプリ終了した場合など、CDTXMania.Songs管理 がnullの場合があるので注意
						Trace.TraceInformation( "songs.db の読み込みを完了しました。[{0}スコア]", scores );
						lock ( CDTXMania.stage起動.list進行文字列 )
						{
							CDTXMania.stage起動.list進行文字列.Add( "Loading songs.db ... OK" );
						}
					}
					else
					{
						Trace.TraceInformation( "初回の起動であるかまたはDTXManiaのバージョンが上がったため、songs.db の読み込みをスキップします。" );
						lock ( CDTXMania.stage起動.list進行文字列 )
						{
							CDTXMania.stage起動.list進行文字列.Add( "Loading songs.db ... Skip" );
						}
					}
				}
				finally
				{
					Trace.Unindent();
				}
				//-----------------------------
				#endregion

			}
			finally
			{
				CDTXMania.stage起動.eフェーズID = CStage.Eフェーズ.起動7_完了;
				TimeSpan span = (TimeSpan) ( DateTime.Now - now );
				Trace.TraceInformation( "起動所要時間: {0}", span.ToString() );
			}
			lock ( this )
			{
				state = DTXEnumState.CompletelyDone;
			}
		}


		/// <summary>
		/// 起動してタイトル画面に遷移した後にバックグラウンドで発生させる曲検索
		/// #27060 2012.2.6 yyagi
		/// </summary>
		private void t曲リストの構築2()
		{
			// ！注意！
			// 本メソッドは別スレッドで動作するが、プラグイン側でカレントディレクトリを変更しても大丈夫なように、
			// すべてのファイルアクセスは「絶対パス」で行うこと。(2010.9.16)
			// 構築が完了したら、DTXEnumerateState state を DTXEnumerateState.Done にすること。(2012.2.9)

			DateTime now = DateTime.Now;
			bool bIsAvailableSongList = false;
			bool bIsAvailableSongsDB = false;
			bool bSucceededFastBoot = false;

			try
			{

				#region [ 2) 曲データの検索 ]
				//-----------------------------
				//	base.eフェーズID = CStage.Eフェーズ.起動2_曲を検索してリストを作成する;

				Trace.TraceInformation( "enum2) 曲データを検索します。" );
				Trace.Indent();

				try
				{
					if ( !string.IsNullOrEmpty( CDTXMania.ConfigIni.str曲データ検索パス ) )
					{
						string[] strArray = CDTXMania.ConfigIni.str曲データ検索パス.Split( new char[] { ';' } );
						if ( strArray.Length > 0 )
						{
							// 全パスについて…
							foreach ( string str in strArray )
							{
								string path = str;
								if ( !Path.IsPathRooted( path ) )
								{
									path = CDTXMania.strEXEのあるフォルダ + str;	// 相対パスの場合、絶対パスに直す(2010.9.16)
								}

								if ( !string.IsNullOrEmpty( path ) )
								{
									Trace.TraceInformation( "検索パス: " + path );
									Trace.Indent();

									try
									{
										this.Songs管理.t曲を検索してリストを作成する( path, true );
									}
									catch ( Exception e )
									{
										Trace.TraceError( e.Message );
										Trace.TraceError( e.StackTrace );
										Trace.TraceError( "例外が発生しましたが処理を継続します。" );
								}
										finally
									{
										Trace.Unindent();
									}
								}
							}
						}
					}
					else
					{
						Trace.TraceWarning( "曲データの検索パス(DTXPath)の指定がありません。" );
					}
				}
				finally
				{
					Trace.TraceInformation( "曲データの検索を完了しました。[{0}曲{1}スコア]", this.Songs管理.n検索された曲ノード数, this.Songs管理.n検索されたスコア数 );
					Trace.Unindent();
				}
				//	lock ( this.list進行文字列 )
				//	{
				//		this.list進行文字列.Add( string.Format( "{0} ... {1} scores ({2} songs)", "Enumerating songs", this..Songs管理_裏読.n検索されたスコア数, this.Songs管理_裏読.n検索された曲ノード数 ) );
				//	}
				//-----------------------------
				#endregion
				#region [ 3) songs.db 情報の曲リストへの反映 ]
				//-----------------------------
				//					base.eフェーズID = CStage.Eフェーズ.起動3_スコアキャッシュをリストに反映する;
				Trace.TraceInformation( "enum3) songs.db の情報を曲リストへ反映します。" );
				Trace.Indent();

				try
				{
					if ( this.Songs管理.listSongsDB != null )
					{
						this.Songs管理.tスコアキャッシュを曲リストに反映する();
					}
				}
				catch ( Exception e )
				{
					Trace.TraceError( e.Message );
					Trace.TraceError( e.StackTrace );
					Trace.TraceError( "例外が発生しましたが処理を継続します。" );
				}
				finally
				{
					Trace.TraceInformation( "曲リストへの反映を完了しました。[{0}/{1}スコア]", this.Songs管理.nスコアキャッシュから反映できたスコア数, this.Songs管理.n検索されたスコア数 );
					Trace.Unindent();
				}
				//	lock ( this.list進行文字列 )
				//	{
				//		this.list進行文字列.Add( string.Format( "{0} ... {1}/{2}", "Loading score properties from songs.db", CDTXMania.Songs管理_裏読.nスコアキャッシュから反映できたスコア数, cs.n検索されたスコア数 ) );
				//	}
				//-----------------------------
				#endregion
				#region [ 4) songs.db になかった曲データをファイルから読み込んで反映 ]
				//-----------------------------
				//					base.eフェーズID = CStage.Eフェーズ.起動4_スコアキャッシュになかった曲をファイルから読み込んで反映する;

				int num2 = this.Songs管理.n検索されたスコア数 - this.Songs管理.nスコアキャッシュから反映できたスコア数;

				Trace.TraceInformation( "{0}, {1}", this.Songs管理.n検索されたスコア数, this.Songs管理.nスコアキャッシュから反映できたスコア数 );
				Trace.TraceInformation( "enum4) songs.db になかった曲データ[{0}スコア]の情報をファイルから読み込んで反映します。", num2 );
				Trace.Indent();

				try
				{
					this.Songs管理.tSongsDBになかった曲をファイルから読み込んで反映する();
				}
				catch ( Exception e )
				{
					Trace.TraceError( e.Message );
					Trace.TraceError( e.StackTrace );
					Trace.TraceError( "例外が発生しましたが処理を継続します。" );
				}
				finally
				{
					Trace.TraceInformation( "曲データへの反映を完了しました。[{0}/{1}スコア]", this.Songs管理.nファイルから反映できたスコア数, num2 );
					Trace.Unindent();
				}
				//					lock ( this.list進行文字列 )
				//					{
				//						this.list進行文字列.Add( string.Format( "{0} ... {1}/{2}", "Loading score properties from files", CDTXMania.Songs管理_裏読.nファイルから反映できたスコア数, CDTXMania.Songs管理_裏読.n検索されたスコア数 - cs.nスコアキャッシュから反映できたスコア数 ) );
				//					}
				//-----------------------------
				#endregion
				#region [ 5) 曲リストへの後処理の適用 ]
				//-----------------------------
				//					base.eフェーズID = CStage.Eフェーズ.起動5_曲リストへ後処理を適用する;

				Trace.TraceInformation( "enum5) 曲リストへの後処理を適用します。" );
				Trace.Indent();

				try
				{
					this.Songs管理.t曲リストへ後処理を適用する();
				}
				catch ( Exception e )
				{
					Trace.TraceError( e.Message );
					Trace.TraceError( e.StackTrace );
					Trace.TraceError( "例外が発生しましたが処理を継続します。" );
				}
				finally
				{
					Trace.TraceInformation( "曲リストへの後処理を完了しました。" );
					Trace.Unindent();
				}
				//					lock ( this.list進行文字列 )
				//					{
				//						this.list進行文字列.Add( string.Format( "{0} ... OK", "Building songlists" ) );
				//					}
				//-----------------------------
				#endregion
				#region [ 6) songs.db への保存 ]
				//-----------------------------
				//					base.eフェーズID = CStage.Eフェーズ.起動6_スコアキャッシュをSongsDBに出力する;

				Trace.TraceInformation( "enum6) 曲データの情報を songs.db へ出力します。" );
				Trace.Indent();

				try
				{
					this.Songs管理.tスコアキャッシュをSongsDBに出力する( strPathSongsDB );
				}
				catch ( Exception e )
				{
					Trace.TraceError( e.Message );
					Trace.TraceError( e.StackTrace );
					Trace.TraceError( "例外が発生しましたが処理を継続します。" );
				}
				finally
				{
					Trace.TraceInformation( "songs.db への出力を完了しました。[{0}スコア]", this.Songs管理.nSongsDBへ出力できたスコア数 );
					Trace.Unindent();
				}
				//					lock ( this.list進行文字列 )
				//					{
				//						this.list進行文字列.Add( string.Format( "{0} ... OK", "Saving songs.db" ) );
				//					}
				#endregion

				//				if ( !bSucceededFastBoot )	// songs2.db読み込みに成功したなら、songs2.dbを新たに作らない
				#region [ 7) songs2.db への保存 ]		// #27060 2012.1.26 yyagi
				Trace.TraceInformation( "enum7) 曲データの情報を songlist.db へ出力します。" );
				Trace.Indent();

				SerializeSongList( this.Songs管理, strPathSongList );
				Trace.TraceInformation( "songlist.db への出力を完了しました。[{0}スコア]", this.Songs管理.nSongsDBへ出力できたスコア数 );
				Trace.Unindent();
				//-----------------------------
				#endregion
				//				}

			}
			finally
			{
				//				base.eフェーズID = CStage.Eフェーズ.起動7_完了;
				TimeSpan span = (TimeSpan) ( DateTime.Now - now );
				Trace.TraceInformation( "曲探索所要時間: {0}", span.ToString() );
			}
			lock ( this )
			{
				// state = DTXEnumState.Done;		// DoneにするのはCDTXMania.cs側にて。
				state = DTXEnumState.Enumeratad;
			}
		}



		/// <summary>
		/// 曲リストのserialize
		/// </summary>
		private static void SerializeSongList( CSongs管理 cs, string strPathSongList )
		{
			bool bSucceededSerialize = true;
			Stream output = null;
			try
			{
				output = File.Create( strPathSongList );
				BinaryFormatter formatter = new BinaryFormatter();
				formatter.Serialize( output, cs );
			}
			catch ( Exception e )
			{
				bSucceededSerialize = false;
				Trace.TraceError( e.Message );
				Trace.TraceError( e.StackTrace );
				Trace.TraceError( "例外が発生しましたが処理を継続します。" );
			}
			finally
			{
				output.Close();
				if ( !bSucceededSerialize )
				{
					try
					{
						File.Delete( strPathSongList );	// serializeに失敗したら、songs2.dbファイルを消しておく
					}
					catch ( Exception )
					{
						// 特に何もしない
					}
				}
			}
		}

		/// <summary>
		/// 曲リストのdeserialize
		/// </summary>
		/// <param name="songs管理"></param>
		/// <param name="strPathSongList"></param>
		private CSongs管理 Deserialize( string strPathSongList )
		{
			CSongs管理 songs管理 = null;
			try
			{
				#region [ SongListDB(songlist.db)を読み込む ]
				//	byte[] buf = File.ReadAllBytes( SongListDBファイル名 );			// 一旦メモリにまとめ読みしてからdeserializeした方が高速かと思ったら全く変わらなかったので削除
				//	using ( MemoryStream input = new MemoryStream(buf, false) )
				using ( Stream input = File.OpenRead( strPathSongList ) )
				{
					try
					{
						BinaryFormatter formatter = new BinaryFormatter();
						songs管理 = (CSongs管理) formatter.Deserialize( input );
					}
					catch ( Exception )
					{
						// songs管理 = null;
					}
				}
				#endregion
			}
			catch
			{
				Trace.TraceError( "songlist.db の読み込みに失敗しました。" );
			}
			return songs管理;
		}
	}
}