/*******************************************************************************
*
*		模 块 名：DBService           文件名：ServiceInit.c
*		相关文件：ServiceInit.h 
*		z提交日期：2012.2.1          作  者：Alex
*		版    本：0.1
*		模块描述:
*			相当于事务处理模块的构造和析构模块
*			ServiceInit();
*			ServiceDeInit();
*		修改记录：
*			日  期		版本		修改人		修改内容
*			
*
*******************************************************************************/
#ifdef _WIN32

#define _SERVICEINIT_CPP
#include "IOCmpltThread.h"
//#include <windows.h>
#include <process.h>
#include <stdio.h>
#include <tchar.h>
#include <direct.h>

#include "DbService.h"
#include "MessageThread.h"
#include "ServiceInit.h"
#include "debug.h"
#include "DataBuffers.h"
#include "ResponseManager.h"
#include "DBInterface.h"
//#define CTYPE_GBK	936
//#define CTYPE_UTF8	65001

CUDPMessageReceiveThread * g_pMessageReceiveThread = NULL;
CIOCmpltThread * g_pIOCmpltThread = NULL;
CDataBufferManager* g_pDataBuffers = NULL;
CResponseManager* g_pResponses = NULL;
int g_aStyleRecomList[MAX_STYLE_NUM+1];
TQNAITEM g_lstCommonQnA[200];
TNOTICEITEM g_lstPublicNotice[MAX_NOTICE_NUM];
int g_nCommonQnANum = 0, g_nPublicNoticeNum = 0;

HINSTANCE g_hDBAccessDll = NULL,
		g_hParamDll = NULL;

extern MHTHREADLIST g_lstMessageHandleThreads;

TCLIENTVERSION* g_pVersionClient = NULL;
TTESTVERSION* g_pVersionClientTest = NULL;

int g_nClientTypeNum = 0,
	g_nClientTestNum = 0;
HANDLE g_hEvClientCheck = NULL;
char g_strStyleFileDir[256] = "";
char g_strWebFileDir[256] = "";
char g_strMusicFileDir[256] = "";
char g_strMusicLocation[8] = "";
char g_strServiceDir[256] = "";
//UINT g_locale_ctype = 0;
/*
void UpdateStyleInfo()
{	
typedef int (*CM_GetStyleTracksInfo)( int len, BYTE data[], char tracks[4][8][16][3] );

	//加载ComposeModule
	HINSTANCE hStyleDll = LoadLibrary( "StyleUpdate.dll" );
	if( hStyleDll==NULL ){
		DWORD dwRet = GetLastError();

		DebugPrint( "载入风格模块失败, 程序终止! errcode=%d", dwRet );

		return;
	}

	CM_GetStyleTracksInfo f_CM_GetStyleTracksInfo = (CM_GetStyleTracksInfo)GetProcAddress( hStyleDll, "CM_GetStyleTracksInfo" ); 

	if( !( f_CM_GetStyleTracksInfo ) ){

		DebugPrint( "获取风格模块访问函数失败, 程序终止!\n" );

		return;
	}

	char strFileName[256];
	char buf[20];	

	int id = 1;
	while( true ){ 	
		//打开原风格文件
		strcpy( strFileName, g_strStyleFileDir );
		UINT nDir = ((UINT)id-1) >> 13;
		sprintf( buf, "%08X\\", nDir );
		strcat( strFileName, buf );
	
		sprintf( buf, "%08X.YSF", id );
		strcat( strFileName, buf );
		
		FILE *fp = fopen( strFileName, "r+b" );

		if( !fp ){
			int err = GetLastError();
			DebugPrint( "修改完毕，或文件读取错误err=%d\n", err );

			return;
		}
		else{
			//读取原风格信息
			fseek( fp, 0, SEEK_END );
			int len = ftell( fp );
			
			int nDataSize = len - sizeof(TSTYLEINFO0);
			BYTE * pData = new BYTE[nDataSize];

			TMAKESTYLEINFO infoNew;
			TSTYLEINFO0 infoOld;

			fseek( fp, 0, SEEK_SET );
			fread( &infoOld, 1, sizeof(TSTYLEINFO0), fp );
			fread( pData, 1, nDataSize, fp );

			//读取轨道信息
			char tracks[4][8][16][3];
			int size = sizeof( tracks );
			memset( tracks, -1, size );
			
			int err = f_CM_GetStyleTracksInfo( nDataSize, pData, tracks );
			if( 0==err ){
				//修改info
//				infoNew.idStyle = id;

				memcpy( infoNew.detail.type, infoOld.detail.type, sizeof(infoOld.detail.type) );
				memcpy( infoNew.detail.chordRecom, infoOld.detail.chordRecom, sizeof(infoOld.detail.chordRecom) );
				memcpy( infoNew.detail.aIntroBars, infoOld.detail.aIntroBars, sizeof(infoOld.detail.aIntroBars) );
				memcpy( infoNew.detail.aEndingBars, infoOld.detail.aEndingBars, sizeof(infoOld.detail.aEndingBars) );

				for( int s=0; s<4; s++ ){
					for( int i=0; i<8; i++ ){
						for( int j=0; j<16; j++ ){
							infoNew.detail.tracks[s][i][j].no = tracks[s][i][j][0];
							infoNew.detail.tracks[s][i][j].prog = tracks[s][i][j][1];
							infoNew.detail.tracks[s][i][j].vol = tracks[s][i][j][2];
						}
					}
				}

				err = f_DB_UpdateStyle( id, &infoNew );
				if( 0==err ){
					fseek( fp, 0, SEEK_SET );
					fwrite( &infoNew, 1, sizeof(TSTYLEINFO), fp );
					fwrite( pData, 1, nDataSize, fp );	
					
//					DebugPrint( "Style %d updating OK\n", infoNew.idStyle );
				}
			}

			if( err!=0 ){
				DebugPrint( "Style %d updating failed! err=%d\n", id, err );
			}
		
			delete[] pData;
			fclose( fp );	
		}

		id++;
	}
}
*/

void ModifyStyleDesc()
{
	char strFileName[256];
	char buf[20];
//	int ids[3] = {404,418,422};
//	char desc[3][120] = { "模仿周杰伦《东风破》的简单中国风，竖琴可换琵琶或古筝，鼓换电鼓",
//						"模仿王菲《闷》的摇滚风格，还原前间奏，乐器协调性是美中不足",
//						"麒麟谱，四不像，伪中国风。《红妆》编曲的收获，感谢花枝。" };

	for( UINT i=g_iChkStyle; ; i++ ){
		char strFileName[256];
		char buf[20];

		strcpy( strFileName, g_strStyleFileDir );

		UINT nDir = (i-1) >> 13;
		sprintf( buf, "%08X\\", nDir );
		strcat( strFileName, buf );

		sprintf( buf, "%08X.YSI", i );
		strcat( strFileName, buf );
		
		FILE *fp = fopen( strFileName, "r+b" );

		if( !fp ){
			int err = GetLastError();
			DebugPrint( "打开风格%d失败，err=%d\n", i, err );
			return;
		}
		else{
			short len = 0;

			fread( &len, 1, sizeof(short), fp );

			if( len>0 ){
				char* pData = new char[len];
				fread( pData, 1, len, fp );

				TSTYLEDETAIL detail;
                int ret = StyleTrans2Detail( detail, len, (char*)pData );
                if( ret<0 ){
                	DebugPrint( "Style %d size error\n", i );
                }
                else{
                    if( ret>0 ){
	                    DebugPrint( "Trunc style %d %s\n", i, ret==1 ? "Author"
                        									: ret==2 ? "AtyleName"
                                                            : "Description" );

    //					string ansiName;
    //
    //					UTF8ToGBK( detail.strDescription, ansiName );
    //					GBKToUTF8( desc[i], ansiName);
    //					strcpy( detail.strDescription, ansiName.c_str() );

                        int size;
                        ret = StyleDetail2Trans( detail, size, pData );
                        if( ret>0 )
                            DebugPrint( "Trunc style %d %s\n", i, ret==1 ? "Author"
                                                                : ret==2 ? "AtyleName"
                                                                : "Description" );

                        len = size;
                        fseek( fp, 0, SEEK_SET );
                        fwrite( &len, 1, sizeof(short), fp );
                        fwrite( pData, 1, len, fp );
                    }
				}
			}

			fclose( fp );	
		}
	}
}

void CreateLog()
{
	SYSTEMTIME st;
	GetLocalTime(&st); 
	char szBufPath[MAX_PATH] = "";

	sprintf( szBufPath, "%slog\\", g_strServiceDir );

	if( _chdir(szBufPath) == -1)
	{
		_mkdir(szBufPath);
	}

	sprintf( szBufPath, "%s%04d-%02d-%02d.log", szBufPath, st.wYear, st.wMonth, st.wDay);

	DebugModuleClose();

	int iDebug = g_eDebug>0 ? g_eDebug : 1;

	DebugModuleInitialize( 0xFFFF, (EDPrintDest)iDebug, szBufPath );
}

void GetStyleRecomList()
{
	int tempList[MAX_STYLE_NUM+1];
	memset( tempList, 0, sizeof(int)*(MAX_STYLE_NUM+1) );
	int num = MAX_STYLE_NUM;
	int ret = f_DB_GetRecomStyleIDs( &num, tempList );

	if( ret==0 ){
		tempList[MAX_STYLE_NUM] = num;
		memcpy( g_aStyleRecomList, tempList, sizeof(int)*(MAX_STYLE_NUM+1) );

		DebugPrint( "Recommand style num : %d\n", num );
	}
	else{
		DebugPrint( "DB_GetRecomStyleIDs return %d\n", ret );
	}
}

void GetCommonQnAList()
{
	int dtUpdate = 0;
	for( int i=0; i<g_nCommonQnANum; i++ ){
		if( dtUpdate<g_lstCommonQnA[i].dtUpdate ){
			dtUpdate = g_lstCommonQnA[i].dtUpdate;
		}
	}

	g_nCommonQnANum = f_DB_GetCommonQnA( dtUpdate, g_nCommonQnANum, g_lstCommonQnA );

	DebugPrint( "Common QnA num : %d\n", g_nCommonQnANum );
}

void GetPublicNoticeList()
{
	g_nPublicNoticeNum = f_DB_GetNotice( MAX_NOTICE_NUM, g_lstPublicNotice, 0 );

	DebugPrint( "Public notice num : %d\n", g_nPublicNoticeNum );
}

#define INI_FILE_NAME				"DBService.ini"
#define STR_TESTVERSION_SECTION		"TEST_VERSIONS"
#define STR_TESTVERSION				"VERSIONS_STRING"
FILETIME g_ftIniModify;

void ReadConfigParams()
{
	char szBufPath[MAX_PATH] = "";
	sprintf( szBufPath, "%s%s", g_strServiceDir, INI_FILE_NAME );

    HANDLE hFile = CreateFile( szBufPath, GENERIC_READ, FILE_SHARE_READ, NULL, 
														OPEN_EXISTING, 0, NULL);

    if( hFile == INVALID_HANDLE_VALUE ){
        DebugPrint( "No ini file\n" );
        return;
    }

	int ret = -1;
	FILETIME ftWrite;
    ret = GetFileTime(hFile, NULL, NULL, &ftWrite);

	CloseHandle( hFile );

	if( !ret ){
        DebugPrint( "Get ini file time error: %d\n", GetLastError());
        return;
	}

	if( ftWrite.dwLowDateTime!=g_ftIniModify.dwLowDateTime 
				|| ftWrite.dwHighDateTime!=g_ftIniModify.dwHighDateTime ){
		if( WAIT_OBJECT_0!=WaitForSingleObject( g_hEvClientCheck, INFINITE ) )
			return;
		
		//printf( "retrive config.\n" );
		TTESTVERSION aVersion[10];
		int num = 0;
		char szBuf[32] = "";
		
		ret = GetPrivateProfileString( STR_TESTVERSION_SECTION, STR_TESTVERSION, "", szBuf, 32, szBufPath );

		if( ret>0 ){
			char *tokenPtr=strtok( szBuf, "|" );
			for( ; tokenPtr!=NULL; num++ ){
				int iInner, iMaj, iMin, iMod, iBuil;
				sscanf( tokenPtr, "%d,%d.%d.%d", &iInner, &iMaj, &iMin, &iMod );//, &iBuil );

				aVersion[num].iClientType = iInner;
				aVersion[num].version.majorVersion = iMaj;
				aVersion[num].version.minorVersion = iMin;
				aVersion[num].version.modifyVersion = iMod;
//				aVersion[num].version.buildVersion = iBuil;

				tokenPtr = strtok( NULL, "|" );
			}
		}

		if( g_nClientTestNum>0 && g_nClientTestNum!=num ){
			delete[] g_pVersionClientTest;
			g_pVersionClientTest = NULL;
		}

		g_nClientTestNum = num;
		
		if( num>0 ){
			if( !g_pVersionClientTest ){
				g_pVersionClientTest = new TTESTVERSION[num];
			}

			for( int i=0; i<num; i++ ){
				TTESTVERSION* pVersion = &(g_pVersionClientTest[i]);
				memcpy( pVersion, &aVersion[i], sizeof(TTESTVERSION) );

				DebugPrint( "测试版本：%d.%d.%d\n软件内部编号：%d\n",
							pVersion->version.majorVersion, pVersion->version.minorVersion,
							pVersion->version.modifyVersion, //pVersion->version.buildVersion, //不设置构建版本
							pVersion->iClientType );
			}
		}
		else{
			DebugPrint( "No test version.\n" );
		}

		SetEvent( g_hEvClientCheck );
		
		g_ftIniModify.dwLowDateTime = ftWrite.dwLowDateTime;
		g_ftIniModify.dwHighDateTime = ftWrite.dwHighDateTime;	
	}
	else{
		DebugPrint( "No config update.\n" );
	}
}

void GetClientUpdateVersion()
{
	if( WAIT_OBJECT_0!=WaitForSingleObject( g_hEvClientCheck, INFINITE ) ){
		return;
	}

	int nOldTypeNum = g_nClientTypeNum;
	g_nClientTypeNum = f_DB_GetClientTypeNumber();

	if( nOldTypeNum>0 && g_nClientTypeNum!=nOldTypeNum ){
		delete[] g_pVersionClient;
		g_pVersionClient = NULL;
	}

	if( g_nClientTypeNum>0 ){
		if( !g_pVersionClient ){
			g_pVersionClient = new TCLIENTVERSION[g_nClientTypeNum];
		}

		if( f_DB_GetClientVersion( g_pVersionClient, g_nClientTypeNum )>=0 ){	
			for( int i=0; i<g_nClientTypeNum; i++ ){
				TCLIENTVERSION* pVersion = &(g_pVersionClient[i]);

				string ansiDescribe;
				UTF8ToGBK( pVersion->swInfo.strDescribe, ansiDescribe );

				DebugPrint( "软件内部编号：%d\n最新客户端版本：%d.%d.%d.%04d\n  发布时间：%d-%d-%d\n  文件大小：%dK\n  文件描述：%s\n", 
						pVersion->iClientType,
						pVersion->swInfo.version.majorVersion, pVersion->swInfo.version.minorVersion, 
						pVersion->swInfo.version.modifyVersion, pVersion->swInfo.version.buildVersion,
						pVersion->swInfo.tIssueDate>>16, (pVersion->swInfo.tIssueDate&0xFF00)>>8, (pVersion->swInfo.tIssueDate&0xFF),
						pVersion->swInfo.nFileSize, ansiDescribe.c_str() );
			
			}
		}
		else{
			DebugPrint( "获取最新客户端版本信息失败!\n" );
		}
	}
	else if( g_nClientTypeNum<0 ){
		DebugPrint( "获取最新客户端类型数失败!\n" );
	}

	SetEvent( g_hEvClientCheck );
}

void OnTimerFunc( void *dummy )
{
	CreateLog();
//	GetClientUpdateVersion();
	GetStyleRecomList();
	GetCommonQnAList();
//	GetPublicNoticeList();

	DebugPrint( "OnTimerFunc exit.\n" );
}

bool ServiceInit()
{
	g_hEvServiceThread = CreateEvent(
        NULL,    // no security attributes
        TRUE,    // manual reset event
        FALSE,   // not-signalled
        NULL);   // no name

	g_hEvClientCheck = CreateEvent(
        NULL,    // no security attributes
        FALSE,    // auto reset event
        TRUE,   //  signalled
        NULL);   // no name

	if( !(g_hEvServiceThread && g_hEvClientCheck )){
		return false;
	}
	WORD wVersionRequested;
	WSADATA wsaData;
	int err;
/*
	//获取本地编码格式
	char* locname = setlocale(LC_CTYPE, "");
	char* code = strchr( locname, '.' );
	//DebugPrint( "locale code: %s\n", code);
	if( !strcmp(code, ".936") || !strcmp(code, ".GBK") ){
		g_locale_ctype = CTYPE_GBK;
	}
*/
	wVersionRequested = MAKEWORD( 2, 2 );

	err = WSAStartup( wVersionRequested, &wsaData );
	if ( err != 0 ) {
		// Tell the user that we could not find a usable
		// WinSock DLL.    
        _tprintf(TEXT("CreateService failed - can't startup wsock.\n"));

		if( g_hEvServiceThread ){
			CloseHandle( g_hEvServiceThread );
			g_hEvServiceThread = NULL;
		}
		return false;
	}

	//设置debug参数
	HKEY hRootKey;
	DWORD nFlag=1, dwLength=4;
	
	if( ERROR_SUCCESS==RegOpenKeyEx( HKEY_LOCAL_MACHINE, "Software\\YHD\\ComposerService", 
				0, KEY_ALL_ACCESS, &hRootKey ) ){
		if( RegQueryValueEx(hRootKey,"DebugFlag",NULL,NULL,(BYTE*)&nFlag,&dwLength)!=ERROR_SUCCESS ){
			RegSetValueEx(hRootKey,"DebugFlag",0,REG_DWORD,(BYTE*)&nFlag,4 );
		}
		RegCloseKey( hRootKey );
	}

	char chTemp[2560];
	GetModuleFileName( NULL, chTemp, 256 );	
	*(strrchr(chTemp, '\\')+1) = '\0';
	strcpy( g_strServiceDir, chTemp );
	//DebugModuleInitialize( 0xFFFF, (EDPrintDest)g_eDebug, NULL );
	CreateLog();
	//DebugPrint("DebugModuleInitialize success!\n");

	//载入数据库访问模块
	if( !LoadDB() ){
		return FALSE;
	}

//    int ret = f_DB_InitDatabases("localhost", "root", "168soft.xyz");

	f_DB_GetPath( g_strStyleFileDir, g_strWebFileDir, g_strMusicFileDir );
	DebugPrint( "Style_dir: %s\nWeb_dir: %s\nMusic_dir: %s\n", g_strStyleFileDir, g_strWebFileDir, g_strMusicFileDir );
	if( strlen(g_strMusicFileDir)>0 ){
		char* pos = strstr( g_strMusicFileDir, "File" )+4;
		if( pos[0]!='/' && pos[0]!='\\' ){
			int num;
			sscanf( pos, "%d", &num );
			sprintf( g_strMusicLocation, "%d", num );
		}
	}

/////////////////////////////////////////////////////////////
//修改风格信息专用
//#ifdef _UPDATE
    if( g_iChkStyle>0 ){
    //	UpdateStyleInfo();
        ModifyStyleDesc();
        return FALSE;
    }
//#endif
/////////////////////////////////////////////////////////////

	GetClientUpdateVersion();
	memset( g_aStyleRecomList, 0, sizeof(int)*(MAX_STYLE_NUM+1) );
	GetStyleRecomList();

	g_ftIniModify.dwLowDateTime = 0;
	g_ftIniModify.dwHighDateTime = 0;
	ReadConfigParams();

	GetCommonQnAList();
	GetPublicNoticeList();

	//创建数据接收
	g_pDataBuffers = new CDataBufferManager;

	//创建消息响应管理
	g_pResponses = new CResponseManager;

	//生成消息接收线程
	CUDPSocket * pSocket = new CUDPSocket( 12071 );

	if( pSocket && pSocket->IsOpen() ){
		g_pMessageReceiveThread = new CUDPMessageReceiveThread( 3000, pSocket );
		g_pMessageReceiveThread->Resume();
	}

	//生成消息处理线程池
	for( int i=0; i<20; i++ ){
		pSocket = new CUDPSocket();
		if( pSocket && pSocket->IsOpen() ){
			CMessageHandleThread* pThread = new CMessageHandleThread( 3000, pSocket );
			g_lstMessageHandleThreads.push_back( pThread );
		}
	}

	//生成IOComplete线程
	g_pIOCmpltThread = new CIOCmpltThread(3000);
	g_pIOCmpltThread->Resume();

	_tprintf(TEXT("Composer Service is running...\n"));

	return true;
}

void ServiceDeInit()
{
    _tprintf(TEXT("Composer Service is stopping...\n"));

	if( g_hEvClientCheck ){
		CloseHandle( g_hEvClientCheck );
	}

	if( g_pVersionClient ){
		delete[] g_pVersionClient;
		g_pVersionClient = NULL;
	}

	if( g_pMessageReceiveThread ){
		g_pMessageReceiveThread->Terminate();
		delete g_pMessageReceiveThread;
		g_pMessageReceiveThread = NULL;
	}

	MHTHREADLIST::iterator iMT = g_lstMessageHandleThreads.begin();
	while( iMT!=g_lstMessageHandleThreads.end() ){
		(*iMT)->Terminate();
		delete (*iMT);

		iMT = g_lstMessageHandleThreads.erase( iMT );
	}	
	
	if( g_pIOCmpltThread ){
		g_pIOCmpltThread->Terminate();
		delete g_pIOCmpltThread;
		g_pIOCmpltThread = NULL;
	}

	FreeDB();

	if( g_pDataBuffers ){
		delete g_pDataBuffers;
		g_pDataBuffers = NULL;
	}

	if( g_pResponses ){
		delete g_pResponses;
		g_pResponses = NULL;
	}

	DebugModuleClose();

    WSACleanup( );

	DebugPrint( "System unloaded!" );

	if( g_hEvServiceThread ){
		SetEvent( g_hEvServiceThread );
	}

    _tprintf(TEXT("Composer Service stopped.\n"));
}
/*
#ifndef  _DEBUG
	#pragma comment( linker, "/subsystem:\"windows\" /entry:\"mainCRTStartup\"" ) // 设置入口地址 
#endif
*/
DWORD WINAPI DBMain(void* pParam)
{
	MSG msg;

	if( !ServiceInit() ){
//		return 1;
	}

    SYSTEMTIME st;
    GetLocalTime(&st);  

	DWORD timeCount = st.wHour * 60 * 60 + st.wMinute * 60 + st.wSecond;
//	timeCount = 0; //test

	UINT uTimer = SetTimer( NULL, 0, 1000, NULL );

	while( GetMessage(&msg, NULL, 0, 0) && msg.message!=WM_CLOSE ){
		if( msg.message==WM_TIMER && msg.wParam==uTimer ){
			if( g_pIOCmpltThread ){
				g_pIOCmpltThread->OnTimer();
			}

			if( g_pDataBuffers ){
				g_pDataBuffers->OnTimer();
			}

			if( g_pResponses ){
				g_pResponses->OnTimer();
			}

			if( ++timeCount>=86400 ){ //00:00:00
//			if( ++timeCount>=600 ){ //test 10 minutes
//				timeCount = 0; //test				
				GetLocalTime(&st);  
				timeCount = st.wHour * 60 * 60 + st.wMinute * 60 + st.wSecond;

				if( st.wHour==0 ){
//					_beginthread( OnTimerFunc, 0, NULL );
					CreateThread( 0, 0, (LPTHREAD_START_ROUTINE)OnTimerFunc, 0, 0, 0 );
				}
			}

			if( ( timeCount & 0x1FF )==0 ){ //512s~9m
				f_DB_CleanVipLog();
			}

			if( ( timeCount & 0xFFF )==0 ){ //4095s~68m~1h 获取测试版本信息
				ReadConfigParams();
			}

			if( ( timeCount & 0x1FFF )==0 ){ //8191s~136m~2h 获取发布版本信息
				GetClientUpdateVersion();
			}

			continue;
		}

		try{
			TranslateMessage (&msg);
			DispatchMessage (&msg);
		}catch (...){
		    _tprintf(TEXT("!!!!!!Unexpected exception in WMain()!!!!!!\n"));
		}
	}

	KillTimer( NULL, uTimer );

	IF_DEBUG_SYSMANAGER(DebugPrint("%X:In %s Line %d WMain ExitThread!\n",
			TRACE_NUMBER(e_Trace_SysManager,e_Trace_Normal),
			__FILE__,__LINE__))

	ServiceDeInit();

    _tprintf(TEXT("WMain() ExitThread!\n"));


	ExitThread(0);

	return 0;
}

#endif