lyfz_repos/经典版源码/lyfzServer/branches/712/Global.cpp

#include "StdAfx.h"
#include "Global.h"
#include "./helper/ffsco.h"
// ----stat头文件;
#include <sys/types.h>
#include <sys/stat.h>
// ----stat头文件;
#define BAKDB_FORMAT _T("BACKUP DATABASE [%s] TO DISK='%s' WITH FORMAT")
TCHAR g_szHostName[MAX_PATH] = {0};				// 本机名称;
TCHAR g_ModulePath[MAX_PATH] = _T("");			// 软件目录;
TCHAR g_ModuleFileName[MAX_PATH] = _T("");		// 软件名称;
TCHAR g_szConnectString[MAX_PATH] = _T("");		// DB连接串;

// 服务器信息;
TCHAR g_szDBSource[MAX_PATH] = _T("");		// 数据库源(服务所在IP或计算机名);
TCHAR g_szDBSourcePort[MAX_PATH] = _T("");	// 数据库源端口;
DWORD g_dwDBServerPort = 0;					// 数据库源端口;
TCHAR g_szDBAccount[MAX_PATH] = _T("");		// 数据库登录用户;
TCHAR g_szDBPassWord[MAX_PATH] = _T("");	// 数据库登录密码;
TCHAR g_szDBName[MAX_PATH] = _T("");		// 数据库名称;	
TCHAR g_szLogDBName[MAX_PATH] = _T("");		// Log数据库名称;	
DWORD g_dwCSPort = 0;
TCHAR g_szShareAccount[MAX_PATH] = {0};
TCHAR g_szSharePasswd[MAX_PATH] = {0};
TCHAR g_szN8ViewSvrIP[MAX_PATH] = {0};			// N8选版服务器IP;
TCHAR g_szN8ViewUserDir[MAX_PATH] = {0};		// N8选版服务器用户目录(共享目录);
TCHAR g_szN8ViewStsDir[MAX_PATH] = {0};			// N8选版服务器统计数据目录(共享目录);
TCHAR g_szN8ViewProductDir[MAX_PATH] = {0};		// N8选版产品配置目录(共享目录);
TCHAR g_szN8ViewShareDir[MAX_PATH] = {0};		// N8选版共享目录;
TCHAR g_szN8ViewShareName[MAX_PATH] = {0};
BOOL g_bEnableClound = FALSE;					// 是否启用云选功能;
BOOL g_bExportBarCode = FALSE;					// 是否导出条形码位图;
DWORD g_dwSoftRunTime = 0;						// 软件剩余可运行时间;
TCHAR g_szCloundDiskAccount[MAX_PATH] ={0};		// 云盘账号;
TCHAR g_szCloundDiskPsw[MAX_PATH] = {0};		// 云盘密码（保存时需要加密）;
DWORD g_dwDBPoolMaxCount = 1;
DWORD g_dwDBPoolDef = 1;
BOOL  g_bIsCatalogDamage = FALSE;
BOOL  g_bCheckdb = FALSE;
DWORD g_dwCheckdbTimeOut = 30;
DWORD g_dwStartDelayTime = 30;					// 服务程序延时启动(单位：秒);

// start+------------------------------------------------------------------
// Jeff:以下为原本程序全局变量;
#if THE_PRIMARY_GLOBAL_VARIABLE
int g_TCPport = 5678;			// Jeff.通信端口;
BOOL g_bReg = 0;
CString g_strdbpsw;				// 数据库账号、密码;
CString g_strdbServrename;		// 数据库服务名(地址)8
CString g_bakinfo;
CString g_bakphoto;
CString g_mainpath;

SoftKey ytSoftKey;
CString g_localname;		// 本地计算机名;

//CDatabase g_db;				// 名为"db"的数据库,本年度使用的数据库;
CArray<int, int>	g_nYearArray;						// 年份（用于命名历史数据库）
//CArray<CDatabase*,CDatabase*>g_dbArray;				// 历史数据库;
CArray<CDatabase*, CDatabase*>g_dbHistoryArray;				// 历史数据库;
CArray<CDatabase*, CDatabase*>g_branchdbarray;
CArray<CDatabase*, CDatabase*>g_branchdb2array;//除历史年度的分店DB
CStringArray g_branchnamearray;
CStringArray g_branchname2array;
CStringArray g_branchiparray;
CStringArray g_branchdomainarray;
CDatabase	 *g_pMaindb = NULL;
int			 g_conncount = -1;			// Jeff.加密狗中的座席版数量;
CString		 g_sdomain;

CStringArray g_conniparray;
CStringArray g_connidarray;

BOOL g_bCheckAll = 0;
BYTE *g_pSkinData = NULL;
DWORD  g_SkinLeng;
BOOL g_bAutoRun = 0;
CStringArray g_filedatearray;
CStringArray g_filedatearraynew;
CString g_bakdate;
CString g_localip;

BOOL g_bSteal = 0;
CString	g_bakserver1;
CString g_bakserver2;
CString g_bakserver3;
CString g_bakserver4;

DWORD g_tisks = 0;

#if 0
int		g_nBakDays = 10;					// 备份几天前的时间设置(单位:天数)
int		g_nBackupModel = 1;
#endif //#if 0

int		g_bAutoCheckSvc = 1;				// (1是/0否)自动检查服务(次/小时)

HINSTANCE g_hDllInst = NULL;

HINSTANCE g_Instance = NULL;
#endif
// endof+------------------------------------------------------------------

/************************************************************************/
/*  函数：InitSocketLibrary[2/29/2016 IT];
/*  描述：Initialize Winsock library. This function calls WSAStartup;
/*  参数：;
/*  	[IN] wVersion：Winsock version use MAKEWORD macro if possible (e.g.: MAKEWORD(2,2));
/*  返回：return true if successful;
/*  注意：关联ReleaseSocketLibrary;
/*  示例：;
/*
/*  修改：;
/*  日期：;
/*  内容：;
/************************************************************************/
bool InitSocketLibrary(IN WORD wVersion)
{
	WSADATA WSAData = { 0 };
	return ( 0 == WSAStartup( wVersion, &WSAData ) );
}


/************************************************************************/
/*  函数：ReleaseSocketLibrary[2/29/2016 IT];
/*  描述：Release Winsock library;
/*  参数：;
/*  返回：return true if successful;
/*  注意：关联InitSocketLibrary;
/*  示例：;
/*
/*  修改：;
/*  日期：;
/*  内容：;
/************************************************************************/
bool ReleaseSocketLibrary()
{
	return ( 0 == WSACleanup() );
}


/************************************************************************/
/*  函数：[5/20/2016 IT];
/*  描述：;
/*  参数：;
/*  	[IN] ：;
/*  	[OUT] ：;
/*  	[IN/OUT] ：;
/*  返回：void;
/*  注意：;
/*  示例：;
/*
/*  修改：;
/*  日期：;
/*  内容：;
/************************************************************************/
int GetIniInfo(const char *szPath, const char *szIniName)
{
	TCHAR szDrive[_MAX_DRIVE];
	TCHAR szDir[_MAX_DIR];
	::GetModuleFileName(NULL, g_ModulePath, sizeof(g_ModulePath) / sizeof(TCHAR));
	sprintf(g_ModuleFileName, "%s", g_ModulePath);

	_tsplitpath(g_ModulePath, szDrive, szDir, NULL, NULL);
	_tcscpy(g_ModulePath, szDrive);
	_tcscat(g_ModulePath, szDir);

	// -----------------------------------------------------//
	CHAR szFile[MAX_PATH + 1] = "";
	if (szPath != NULL && szIniName != NULL)
		wsprintf(szFile, "%s\\%s", szPath, szIniName);
	else
		wsprintf(szFile, "%s\\ServiceInfo.ini", g_ModulePath);

	TRACE("szFile =%s\n", szFile);

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

	if (ERROR_FILE_NOT_FOUND == GetLastError())
	{
		return -1;
	}

	CloseHandle(hFile);
	hFile = NULL;

	// 获取服务器端信息;
	GetPrivateProfileString("DatabaseInfo", "dbSource", "", g_szDBSource, MAX_PATH, szFile);
	g_dwDBServerPort = GetPrivateProfileInt("DatabaseInfo", "dbServerPort", 0, szFile);
	GetPrivateProfileString("DatabaseInfo", "dbAccount", "", g_szDBAccount, MAX_PATH, szFile);
	GetPrivateProfileString("DatabaseInfo", "dbPassWord", "", g_szDBPassWord, MAX_PATH, szFile);
	GetPrivateProfileString("DatabaseInfo", "dbName", "", g_szDBName, MAX_PATH, szFile);

	g_dwDBPoolMaxCount = GetPrivateProfileInt(_T("DatabaseInfo"), _T("dbpoolMaxObj"), 50, szFile);
	g_dwDBPoolDef = GetPrivateProfileInt(_T("DatabaseInfo"), _T("dbpoolDef"), 3, szFile);

#if USE_ADO_OPT_DB
	GetPrivateProfileString("DatabaseInfo", "LogdbName", "", g_szLogDBName, MAX_PATH, szFile);
#endif//#if USE_ADO_OPT_DB
	
	g_dwCSPort = GetPrivateProfileInt("NetWorkInfo", "TCPChatPort", 5678, szFile);

	if (g_dwDBServerPort != 0)
	{
		if ( _tcscmp(g_szDBAccount, _T("")) == 0 )
			sprintf(g_szConnectString, DB_SW_CONN_WITH_PORT, g_szDBSource, g_dwDBServerPort,g_szDBName);
		else
			sprintf(g_szConnectString, DB_SS_CONN_WITH_PORT,g_szDBSource, g_dwDBServerPort, g_szDBName, g_szDBAccount, g_szDBPassWord);
	}
	else
	{
		if ( _tcscmp(g_szDBAccount, _T("")) == 0 )
			sprintf(g_szConnectString, DB_SW_CONN_WITHOUT_PORT, g_szDBSource, g_szDBName);
		else
			sprintf(g_szConnectString, DB_SS_CONN_WITHOUT_PORT,g_szDBSource, g_szDBName, g_szDBAccount, g_szDBPassWord);
	}
#if 0
	g_nBakDays = GetPrivateProfileInt("Back", "uBakDays", 10, szFile);
	g_nBackupModel = GetPrivateProfileInt("Back", "uBackupModel", 1, szFile);
#endif //#if 0

	g_bAutoCheckSvc = GetPrivateProfileInt("Back", "AutoCheckSvc", 1, szFile);

	// 局域网共享账号和密码;
	GetPrivateProfileString("NetWorkInfo", "ShareAccount", "", g_szShareAccount, MAX_PATH, szFile);
	GetPrivateProfileString("NetWorkInfo", "SharePasswd", "", g_szSharePasswd, MAX_PATH, szFile);

	// NemoInfo;
	GetPrivateProfileString("NemoInfo", "N8ViewSvr", "", g_szN8ViewSvrIP, MAX_PATH, szFile);
	GetPrivateProfileString("NemoInfo", "N8ViewUserDir", "", g_szN8ViewUserDir, MAX_PATH, szFile);
	GetPrivateProfileString("NemoInfo", "N8ViewStsDir", "", g_szN8ViewStsDir, MAX_PATH, szFile);
	GetPrivateProfileString("NemoInfo", "N8ViewProductDir", "", g_szN8ViewProductDir, MAX_PATH, szFile);
	GetPrivateProfileString("NemoInfo", "N8ViewShareDir", "", g_szN8ViewShareDir, MAX_PATH, szFile);
	GetPrivateProfileString("NemoInfo", "N8ViewShareName", "", g_szN8ViewShareName, MAX_PATH, szFile);

	//////////////////////////////////////////////////////////////////////////
	// SystemInfo;
	g_bExportBarCode = GetPrivateProfileInt(_T("SystemInfo"), _T("ExportBarCode"), 0, szFile);
	g_bEnableClound = GetPrivateProfileInt(_T("SystemInfo"), _T("EnableClound"), 0, szFile);
	// 云盘账号;
	GetPrivateProfileString(_T("SystemInfo"), _T("CloundDiskAccount"), _T(""), g_szCloundDiskAccount, MAX_PATH, szFile);
	// 云盘密码;
	GetPrivateProfileString(_T("SystemInfo"), _T("CloundDiskPsw"), _T(""), g_szCloundDiskPsw, MAX_PATH, szFile);
	// 解密云盘密码;
	CString strResult;
	des_crypt((CString)g_szCloundDiskPsw, strResult, DES_DECRYPT);
	_stprintf_s(g_szCloundDiskPsw, MAX_PATH, _T("%s"), strResult);
	// 是否检测数据库;
	g_bCheckdb = GetPrivateProfileInt(_T("SystemInfo"), _T("Checkdb"), 1, szFile);
	// 检测数据库的超时值;
	g_dwCheckdbTimeOut = GetPrivateProfileInt(_T("SystemInfo"), _T("CheckdbTimeOut"), 30, szFile);
	if ( !g_bCheckdb )
	{
		g_bIsCatalogDamage = FALSE;
	}
	
	g_dwStartDelayTime = GetPrivateProfileInt(_T("SystemInfo"), _T("StartDelayTime"), 0, szFile );

	return 0;
}

//------------------------------------------------------------
// 以下全局函数为原程序所有;
#if THE_PRIMARY_GLOBAL_FUNCTION
BOOL AddConn(CDatabase *m_conndb, CString dbname)
{
	try	{
		CString strCon;
		strCon.Format(DB_SS_CONN_WITHOUT_PORT, g_strdbServrename, dbname, g_szDBAccount, g_szDBPassWord);
		m_conndb->OpenEx(strCon, CDatabase::noOdbcDialog);
	}
	catch (CDBException * e)
	{
		WriteTextLog(_T("新建连接时出错:%s"),e->m_strError);
#ifdef _DEBUG
		e->ReportError();
#endif
		e->Delete();
		return 0;
	}
	return 1;
}

void WriteError(CString str)
{
	MyLock lock("DBServerWriteError");
	CStdioFile fp;
	CString path = g_mainpath + "\\MsgError.txt";
	if (::PathFileExists(path))
	{
		fp.Open(path, CFile::modeWrite);
		int length = fp.GetLength();
		if (length > 1024 * 1024)
		{
			fp.Close();
			::DeleteFile(path);		// 删除MsgError.txt
			return;
		}
		fp.SeekToEnd();
	}
	else
		fp.Open(path, CFile::modeCreate | CFile::modeWrite);
	fp.WriteString(CTime::GetCurrentTime().Format("%Y-%m-%d %H:%M:%S ") + str + "\n");
	fp.Close();
}

void WritePswWrong(CString str)
{
	MyLock lock("DBServerWritePswWrong");
	CStdioFile fp;
	CString path = g_mainpath + "\\PswWrong.txt";
	if (::PathFileExists(path))
	{
		fp.Open(path, CFile::modeWrite);
		int length = fp.GetLength();
		if (length > 1024 * 1024)
		{
			fp.Close();
			::DeleteFile(path);	// 删除PswWrong.txt
			return;
		}
		fp.SeekToEnd();
	}
	else
		fp.Open(path, CFile::modeCreate | CFile::modeWrite);
	fp.WriteString(CTime::GetCurrentTime().Format("%Y-%m-%d %H:%M:%S ") + str + "\n");
	fp.Close();
}

void WriteNullBalance(CString str)
{
	MyLock lock("DBServerWriteNullBalance");
	CStdioFile fp;
	CString path = g_mainpath + "\\NullBalance.txt";
	if (::PathFileExists(path))
	{
		fp.Open(path, CFile::modeWrite);
		int length = fp.GetLength();
		if (length > 1024 * 1024)
		{
			fp.Close();
			::DeleteFile(path);	// 删除NullBalance.txt
			return;
		}
		fp.SeekToEnd();
	}
	else
		fp.Open(path, CFile::modeCreate | CFile::modeWrite);
	fp.WriteString(CTime::GetCurrentTime().Format("%Y-%m-%d %H:%M:%S ") + str + "\n");
	fp.Close();
}

void WriteUnallowIP(CString str)
{
	CStdioFile fp;
	CString path = g_mainpath + "\\UnallowIP.txt";
	if (::PathFileExists(path))
	{
		fp.Open(path, CFile::modeWrite);
		int length = fp.GetLength();
		if (length > 1024 * 1024)
		{
			fp.Close();
			::DeleteFile(path);		// 删除UnallowIP.txt
			return;
		}
		fp.SeekToEnd();
	}
	else
		fp.Open(path, CFile::modeCreate | CFile::modeWrite);
	fp.WriteString(CTime::GetCurrentTime().Format("%Y-%m-%d %H:%M:%S ") + str + "\n");
	fp.Close();
}

int GetEncoderClsid(const WCHAR* format, CLSID* pClsid)
{
	UINT  num = 0;          // number of image encoders
	UINT  size = 0;         // size of the image encoder array in bytes CheckFolderFileExist

	ImageCodecInfo* pImageCodecInfo = NULL;

	GetImageEncodersSize(&num, &size);
	if (size == 0)
		return -1;  // Failure

	pImageCodecInfo = (ImageCodecInfo*)(malloc(size));
	if (pImageCodecInfo == NULL)
		return -1;  // Failure

	GetImageEncoders(num, size, pImageCodecInfo);

	for (UINT j = 0; j < num; ++j)
	{
		if (wcscmp(pImageCodecInfo[j].MimeType, format) == 0)
		{
			*pClsid = pImageCodecInfo[j].Clsid;
			free(pImageCodecInfo);
			return j;  // Success
		}
	}

	free(pImageCodecInfo);
	return -1;  // Failure
}

void SaveImageToFile(Image *img, CString path)
{
	try
	{
		if (img == NULL)return;
		CLSID   encoderClsid;
		BSTR bstr = path.AllocSysString();
		path.MakeLower();
		if (path.Right(3) == "bmp")
		{
			GetEncoderClsid(L"image/bmp", &encoderClsid);
			img->Save(bstr, &encoderClsid, NULL);
		}
		else if (path.Right(3) == "png")
		{
			GetEncoderClsid(L"image/png", &encoderClsid);
			img->Save(bstr, &encoderClsid, NULL);
		}
		else// if(path.Right (3)=="jpg")
		{
			GetEncoderClsid(L"image/jpeg", &encoderClsid);
			EncoderParameters encoderParameters;
			ULONG             quality;
			encoderParameters.Count = 1;
			encoderParameters.Parameter[0].Guid = EncoderQuality;
			encoderParameters.Parameter[0].Type = EncoderParameterValueTypeLong;
			encoderParameters.Parameter[0].NumberOfValues = 1;
			// Save the image as a JPEG with quality level 100.
			quality = 100;
			encoderParameters.Parameter[0].Value = &quality;
			img->Save(bstr, &encoderClsid, &encoderParameters);
		}
		SysFreeString(bstr);
	}
	catch (...)
	{
	}
}

void SaveImageToFile2(Image *img, CString path, ULONG quality)
{
	try
	{
		if (img == NULL)return;
		CLSID   encoderClsid;
		BSTR bstr = path.AllocSysString();
		path.MakeLower();
		if (path.Right(3) == "bmp")
		{
			GetEncoderClsid(L"image/bmp", &encoderClsid);
			img->Save(bstr, &encoderClsid, NULL);
		}
		else if (path.Right(3) == "png")
		{
			GetEncoderClsid(L"image/png", &encoderClsid);
			img->Save(bstr, &encoderClsid, NULL);
		}
		else// if(path.Right (3)=="jpg")
		{
			GetEncoderClsid(L"image/jpeg", &encoderClsid);
			EncoderParameters encoderParameters;
			encoderParameters.Count = 1;
			encoderParameters.Parameter[0].Guid = EncoderQuality;
			encoderParameters.Parameter[0].Type = EncoderParameterValueTypeLong;
			encoderParameters.Parameter[0].NumberOfValues = 1;
			// Save the image as a JPEG with quality level 100.
			encoderParameters.Parameter[0].Value = &quality;
			img->Save(bstr, &encoderClsid, &encoderParameters);
		}
		SysFreeString(bstr);
	}
	catch (...)
	{
	}
}

void RectFitDes(int width, int height, CRect &rc)
{
	float fscale = (float)width / (float)height;
	float rcscale = ((float)rc.Width()) / ((float)rc.Height());
	int rcwid = rc.Width();
	int rchei = rc.Height();
	int dt = 0;
	if (rcscale < fscale)
	{
		dt = (rchei - rcwid / fscale) / 2;
		rc.top += dt;
		rc.bottom -= dt;
	}
	else
	{
		dt = (rcwid - rchei*fscale) / 2;
		rc.left += dt;
		rc.right -= dt;
	}
}

///目录是否存在的检查： 支持网络文件,判断文件时有漏洞
bool  CheckFolderFileExist(CString &strPath)
{
	strPath.MakeLower();
	/*
	if (strPath.Find("c:\\") != -1 || strPath.Find("d:\\") != -1 || strPath.Find("e:\\") != -1 || strPath.Find("f:\\") != -1 || strPath.Find("g:\\") != -1 || strPath.Find("h:\\") != -1 || strPath.Find("i:\\") != -1 || strPath.Find("j:\\") != -1 || strPath.Find("k:\\") != -1 || strPath.Find("l:\\") != -1 || strPath.Find("m:\\") != -1)
	{
		return ::PathFileExists(strPath);
	}
	*/
	if(!PathFileExists(strPath))
		return 0;

	CString path = strPath;
	CFile fp;
	if (fp.Open(path, CFile::modeRead))
	{
		fp.Close();
		return 1;
	}

	if (strPath.Right(1) != "\\")
		path += "\\";
	path += "zaqw1234.dat";
	::DeleteFile(path);// 删除zaqw1234.dat文件;

	if (fp.Open(path, CFile::modeCreate) == 0)
		return 0;
	fp.Close();
	::DeleteFile(path);		// 删除zaqw1234.dat文件;
	return 1;
}

bool  CheckFileExist(CString &strPath)
{
	strPath.MakeLower();
	if (strPath.Find("c:\\") != -1 || strPath.Find("d:\\") != -1 || strPath.Find("e:\\") != -1 || strPath.Find("f:\\") != -1 || strPath.Find("g:\\") != -1 || strPath.Find("h:\\") != -1 || strPath.Find("i:\\") != -1 || strPath.Find("j:\\") != -1 || strPath.Find("k:\\") != -1 || strPath.Find("l:\\") != -1 || strPath.Find("m:\\") != -1)
	{
		return ::PathFileExists(strPath);
	}
	CString path = strPath;
	CFile fp;
	if (fp.Open(path, CFile::modeRead))
	{
		fp.Close();
		return 1;
	}
	return 0;
}

BOOL EncryptFile2(BYTE *buffer, DWORD leng, PCHAR szPassword)
{
	try
	{
		HCRYPTPROV hCryptProv;
		HCRYPTKEY hKey;
		HCRYPTHASH hHash;

		PBYTE pbBuffer;
		DWORD dwBlockLen;
		DWORD dwBufferLen;
		DWORD dwCount;

		//以下获得一个CSP句柄
		if (CryptAcquireContext(
			&hCryptProv,
			NULL,				//NULL表示使用默认密钥容器，默认密钥容器名为用户登陆名
			NULL,
			PROV_RSA_FULL,
			0))
		{
			printf("A cryptographic provider has been acquired. \n");
		}
		else//密钥容器不存在
		{
			if (CryptAcquireContext(
				&hCryptProv,
				NULL,
				NULL,
				PROV_RSA_FULL,
				CRYPT_NEWKEYSET))//创建密钥容器
			{
				//创建密钥容器成功，并得到CSP句柄
				printf("A new key container has been created.\n");
			}
			else
			{
				return 0;
			}

		}

		//--------------------------------------------------------------------
		// 创建一个会话密钥（session key）
		// 会话密钥也叫对称密钥，用于对称加密算法。
		// （注: 一个Session是指从调用函数CryptAcquireContext到调用函数
		//   CryptReleaseContext 期间的阶段。）

		//--------------------------------------------------------------------
		// Create a hash object. 
		if (CryptCreateHash(
			hCryptProv,
			CALG_MD5,
			0,
			0,
			&hHash))
		{
			printf("A hash object has been created. \n");
		}
		else
		{
			return 0;
		}

		//--------------------------------------------------------------------
		// 用输入的密码产生一个散列
		if (CryptHashData(
			hHash,
			(BYTE *)szPassword,
			strlen(szPassword),
			0))
		{
			printf("The password has been added to the hash. \n");
		}
		else
		{
			return 0;
		}

		//--------------------------------------------------------------------
		// 通过散列生成会话密钥(session key)
		if (CryptDeriveKey(
			hCryptProv,
			ENCRYPT_ALGORITHM,
			hHash,
			KEYLENGTH,
			&hKey))
		{
			printf("An encryption key is derived from the password hash. \n");
		}
		else
		{
			return 0;
		}
		//--------------------------------------------------------------------
		// Destroy the hash object. 

		CryptDestroyHash(hHash);
		hHash = NULL;

		//--------------------------------------------------------------------
		//  The session key is now ready. 

		//--------------------------------------------------------------------
		// 因为加密算法是按ENCRYPT_BLOCK_SIZE 大小的块加密的，所以被加密的
		// 数据长度必须是ENCRYPT_BLOCK_SIZE 的整数倍。下面计算一次加密的
		// 数据长度。

		dwBlockLen = 1000 - 1000 % ENCRYPT_BLOCK_SIZE;

		//--------------------------------------------------------------------
		// Determine the block size. If a block cipher is used, 
		// it must have room for an extra block. 

		if (ENCRYPT_BLOCK_SIZE > 1)
			dwBufferLen = dwBlockLen + ENCRYPT_BLOCK_SIZE;
		else
			dwBufferLen = dwBlockLen;
		dwCount = dwBufferLen;
		//--------------------------------------------------------------------
		// In a do loop, encrypt the source file and write to the source file. 
		int count;
		//	if(leng%dwBlockLen==0)
		count = leng / dwBufferLen;
		//	else
		//	count=leng/dwBlockLen+1;
		int i = 0;
		for (i = 0; i < count; i++)
		{
			pbBuffer = buffer + i*dwBufferLen;
			// 加密数据
			if (!CryptEncrypt(
				hKey,			//密钥
				0,				//如果数据同时进行散列和加密，这里传入一个散列对象
				0,	//如果是最后一个被加密的块，输入TRUE.如果不是输入FALSE.
				//这里通过判断是否到文件尾来决定是否为最后一块。
				0,				//保留
				pbBuffer,		//输入被加密数据，输出加密后的数据
				&dwCount,		//输入被加密数据实际长度，输出加密后数据长度
				dwBufferLen))	//pbBuffer的大小。
			{
				return 0;
			}
		}
		if (leng%dwBlockLen)
		{
			pbBuffer = buffer + i*dwBufferLen;
			dwCount = leng - i*dwBufferLen;
			if (!CryptEncrypt(
				hKey,			//密钥
				0,				//如果数据同时进行散列和加密，这里传入一个散列对象
				TRUE,	//如果是最后一个被加密的块，输入TRUE.如果不是输入FALSE.
				//这里通过判断是否到文件尾来决定是否为最后一块。
				0,				//保留
				pbBuffer,		//输入被加密数据，输出加密后的数据
				&dwCount,		//输入被加密数据实际长度，输出加密后数据长度
				dwBufferLen))	//pbBuffer的大小。
			{
				return 0;
			}
		}

		//--------------------------------------------------------------------
		// Destroy session key. 

		if (hKey)
			CryptDestroyKey(hKey);

		//--------------------------------------------------------------------
		// Destroy hash object. 

		if (hHash)
			CryptDestroyHash(hHash);

		//--------------------------------------------------------------------
		// Release provider handle. 

		if (hCryptProv)
			CryptReleaseContext(hCryptProv, 0);
		return(TRUE);
	}
	catch (...)
	{
	}
}

/************************************************************************/
/*  函数：[3/15/2016 IT];
/*  描述：;
/*  参数：;
/*  	[IN] strBackupDir：数据库的备份路径;
/*  	[IN] bBackupToday： 是否备份今天的数据库;
/*  	[IN] bBackupHistory：是否备份历史数据库;
/*  返回：void;
/*  注意：;
/*  示例：;
/*
/*  修改：;
/*  日期：;
/*  内容：;
/************************************************************************/
void BackupDatabase( IN CString strBackupDir, IN BOOL bBackupToday, IN BOOL bBackupHistory )
{
	// 1.使用master系统数据库来备份;
	CDatabase tagMaster;
	try
	{
		TCHAR szConnectString[MAX_PATH] = _T("");
		if( g_dwDBServerPort != 0)
		{
			if ( _tcscmp(g_szDBAccount, _T("")) == 0 )
				sprintf(szConnectString,DB_SW_CONN_WITH_PORT, g_szDBSource,g_dwDBServerPort, _T("master"), g_szDBName);
			else
				sprintf(szConnectString,DB_SS_CONN_WITH_PORT,g_szDBSource,g_dwDBServerPort, _T("master"), g_szDBAccount,g_szDBPassWord);
		}
		else
		{
			if ( _tcscmp(g_szDBAccount, _T("")) == 0 )
				sprintf(szConnectString,DB_SW_CONN_WITHOUT_PORT, g_szDBSource, _T("master"), g_szDBName);
			else
				sprintf(szConnectString,DB_SS_CONN_WITHOUT_PORT,g_szDBSource, _T("master"), g_szDBAccount,g_szDBPassWord);
		}

		tagMaster.OpenEx(szConnectString, CDatabase::noOdbcDialog);
	}
	catch (CDBException *e)
	{
#ifdef _DEBUG
		e->ReportError();
#endif
		e->Delete();
	}

	try
	{
		// 2.获取昨天的日期tm2;
		CTime tToday = CTime::GetCurrentTime();
		CTimeSpan tSpan(1, 0, 0, 0);
		CTime tYesterday;
		if (bBackupToday)
			tYesterday = tToday;
		else
			tYesterday = tToday - tSpan;

		CString savepath;
		savepath.Format(_T("%s\\%s(sql).bak"), strBackupDir, tYesterday.Format(_T("%Y%m%d")));

		BOOL bBak = 0;	// 是否备份成功;
		BOOL bBak2 = 0;	// 是否备份历史年限数据库成功;

		// 3.如果没找到<昨天>备份数据库,则进行备份;
		if (!PathFileExists(savepath))
		{
			tagMaster.SetQueryTimeout(600);
			{
				CString sql;
				sql.Format(_T("BACKUP DATABASE [%s] TO DISK='%s' WITH FORMAT"), g_szDBName, savepath);
				try
				{
					tagMaster.ExecuteSQL(sql);
					bBak = 1;
					g_bakinfo = _T("资料备份成功");
				}
				catch (CDBException * e)
				{
#ifdef _DEBUG
					e->ReportError();
#endif
					WriteTextLog(_T("备份失败：%s"),e->m_strError);
					e->Delete();
				}
			}
			tagMaster.SetQueryTimeout(100);
		}

		// 4.Jeff.是否备份历史数据库;
		if (bBackupHistory)
		{
			for (int i = CTime::GetCurrentTime().GetYear() - 1; i >= 2009; i--)
			{
				tagMaster.SetQueryTimeout(600);
				{
					CString savepath2;
					savepath2.Format(_T("%s\\%s-%d(sql).bak"), strBackupDir, tYesterday.Format(_T("%Y%m%d")), i);
					CString sql;
					sql.Format(_T("BACKUP DATABASE [%d] TO DISK='%s' WITH FORMAT"), i, savepath2);
					try
					{
						tagMaster.ExecuteSQL(sql);
						bBak2 = 1;
					}
					catch (CDBException * e)
					{
#ifdef _DEBUG
						e->ReportError();
#endif
						e->Delete();
						break;
					}
				}
				tagMaster.SetQueryTimeout(100);
			}
		}

		// 5.昨天的数据库备份是否备份成功;
		if (bBak)
		{
			CTimeSpan dt2(31, 0, 0, 0);
			CTimeSpan dt3(365, 0, 0, 0);

			// tm:今天, tm3:1个月前, tm4:1年前;
			CTime tm3 = tToday - dt2;
			CTime tm4 = tToday - dt3;

			// 6.循环删除数据库备份;
			while (tm3 > tm4)
			{
				savepath.Format(_T("%s\\%s.bak"), strBackupDir, tm3.Format(_T("%Y%m%d")));
#ifdef SQLSERVER_VERSION
				savepath.Format(_T("%s\\%s(sql).bak"), strBackupDir, tm3.Format(_T("%Y%m%d")));
#endif
				// Jeff.删除一个月前的数据库备份;
				if (!CheckFileExist(savepath))
					break;
				::DeleteFile(savepath);		// 删除备份的数据库文件*.bak;
				tm3 -= tSpan;	// dt 1天的间隔;
			}
		}

		if (bBak2)
		{
			CTimeSpan dt2(15, 0, 0, 0);
			CTimeSpan dt3(365, 0, 0, 0);
			for (int i = tToday.GetYear() - 1; i >= 2009; i--)
			{
				CTime tm3 = tToday - dt2;
				CTime tm4 = tToday - dt3;
				while (tm3 > tm4)
				{
					savepath.Format(_T("%s\\%s-%d.bak"), strBackupDir, tm3.Format(_T("%Y%m%d")), i);
#ifdef SQLSERVER_VERSION
					savepath.Format(_T("%s\\%s-%d(sql).bak"), strBackupDir, tm3.Format(_T("%Y%m%d")), i);
#endif
					if (!CheckFileExist(savepath))
						break;
					::DeleteFile(savepath);	// 删除备份的数据库文件*.bak;
					tm3 -= tSpan;
				}
			}
		}
	}
	catch (...)
	{
		WriteTextLog("出错在函数BackupDatabase中");
	}

	tagMaster.Close();
}

void BakData(CString savedir, BOOL bToday, BOOL bBakHis)// back data
{
#ifdef SQLSERVER_VERSION
	BackupDatabase(savedir, bToday, bBakHis);
	return;
#endif
	try
	{
		CTime tm = CTime::GetCurrentTime();
		CTimeSpan dt(1, 0, 0, 0);
		CTime tm2;
		if (bToday)
			tm2 = tm;
		else
			tm2 = tm - dt;

		CString savepath;
		savepath.Format("%s\\%s.bak", savedir, tm2.Format("%Y%m%d"));
#ifdef SQLSERVER_VERSION
		savepath.Format("%s\\%s(sql).bak", savedir, tm2.Format("%Y%m%d"));
#endif
		BOOL bBak = 0;
		BOOL bBak2 = 0;
		{
			TCHAR szDBFile[MAX_PATH] = _T("");	// Jeff.add
#ifdef SQLSERVER_VERSION
			_stprintf_s(szDBFile, _T("%s\\数据\\%s.mdf"), g_ModulePath, g_szDBName);
			//if(::CopyFile (g_mainpath+"\\数据\\db.mdf", savepath, 0))
#else
			sprintf(szDBFile, "%s\\数据\\%s.mdb", g_ModulePath, g_szDBName);
			//if(::CopyFile (g_mainpath+"\\数据\\db.mdb", savepath, 0))
#endif	
			if (::CopyFile(szDBFile, savepath, 0))
			{
				bBak = 1;
				g_bakinfo = "资料备份成功";
			}
		}

		if (bBak)
		{
			CTimeSpan dt2(15, 0, 0, 0);
			CTimeSpan dt3(365, 0, 0, 0);
			CTime tm3 = tm - dt2;
			CTime tm4 = tm - dt3;
			while (tm3 > tm4)
			{
				savepath.Format("%s\\%s.bak", savedir, tm3.Format("%Y%m%d"));
#ifdef SQLSERVER_VERSION
				savepath.Format("%s\\%s(sql).bak", savedir, tm3.Format("%Y%m%d"));
#endif
				if (!CheckFileExist(savepath))
					break;
				::DeleteFile(savepath);	// 删除备份的数据库文件*.bak;
				tm3 -= dt;
			}
		}

		//备份历史数据
		for (int i = tm.GetYear() - 1; i >= 1900; i--)
		{
#ifdef SQLSERVER_VERSION
			savepath.Format("%s\\数据\\%d.mdf", g_mainpath, i);
#else
			savepath.Format("%s\\数据\\%d.mdb", g_mainpath, i);
#endif
			if (CheckFileExist(savepath) == 0)
				break;

			CString savepath2 = _T("");
			savepath2.Format("%s\\%s-%d.bak", savedir, tm2.Format("%Y%m%d"), i);
#ifdef SQLSERVER_VERSION
			savepath2.Format("%s\\%s-%d(sql).bak", savedir, tm2.Format("%Y%m%d"), i);
#endif
			if (::CopyFile(savepath, savepath2, 0))
				bBak2 = 1;
		}

		if (bBak2)
		{
			CTimeSpan dt2(7, 0, 0, 0);
			CTimeSpan dt3(365, 0, 0, 0);

			for (int i = tm.GetYear() - 1; i >= 1900; i--)
			{
#ifdef SQLSERVER_VERSION
				savepath.Format("%s\\数据\\%d.mdf", g_mainpath, i);
#else
				savepath.Format("%s\\数据\\%d.mdb", g_mainpath, i);
#endif
				if (CheckFileExist(savepath) == 0)break;
				CTime tm3 = tm - dt2;
				CTime tm4 = tm - dt3;
				while (tm3 > tm4)
				{
					savepath.Format("%s\\%s-%d.bak", savedir, tm3.Format("%Y%m%d"), i);
#ifdef SQLSERVER_VERSION
					savepath.Format("%s\\%s-%d(sql).bak", savedir, tm3.Format("%Y%m%d"), i);
#endif
					if (!CheckFileExist(savepath))
						break;
					::DeleteFile(savepath);	// 删除备份的数据库文件*.bak;
					tm3 -= dt;
				}
			}
		}
	}
	catch (...)
	{
		WriteTextLog("出错在函数BakData中");
	}
}


DWORD FindAppProcessID(CString path)
{
	try
	{
		HANDLE handle = ::CreateToolhelp32Snapshot(TH32CS_SNAPALL, 0);
		PROCESSENTRY32 Info;
		Info.dwSize = sizeof(PROCESSENTRY32);
		path.MakeLower();
		if (::Process32First(handle, &Info))
		{
			do
			{
				CString ss = Info.szExeFile;
				ss.MakeLower();
				if (ss == path)
				{
					::CloseHandle(handle);
					return Info.th32ProcessID;
				}
			} while (::Process32Next(handle, &Info));
			::CloseHandle(handle);
		}
		return 0;
	}
	catch (...)
	{
	}

	return 0;
}

BOOL lyfzCopyFileEx(LPCTSTR lpExistingFileName, LPCTSTR lpNewFileName, const BOOL &bFailIfExists)
{
	// 1.如果是覆盖选项;
	if (!bFailIfExists)
		return CopyFile(lpExistingFileName, lpNewFileName, bFailIfExists);

	// 2.如果不是覆盖选项;
	TCHAR szNewFileName[1024] = { 0 };
	TCHAR szDrive[_MAX_DRIVE] = { 0 };
	TCHAR szDir[_MAX_DIR] = { 0 };
	TCHAR szFna[_MAX_FNAME] = { 0 };
	TCHAR szExt[_MAX_EXT] = { 0 };

	sprintf(szNewFileName, _T("%s"), lpNewFileName);
	_tsplitpath(szNewFileName, szDrive, szDir, szFna, szExt);

	int nIndex = 1;
	while (PathFileExists(szNewFileName))
	{
		sprintf(szNewFileName, _T("%s%s%s (%d)%s"), szDrive, szDir, szFna, nIndex++, szExt);
	}

	return CopyFile(lpExistingFileName, szNewFileName, bFailIfExists);
}

void GetPathFromNetShareName(CString name, CString &sRet)
{
	if (sRet.Find(":") != -1)return;
	NET_API_STATUS   res;
	SHARE_INFO_502   *   psi = NULL;
	WCHAR   wszShareName[255];

	TCHAR   szPathName[255];
	TCHAR   path[255];
	memset(path, 0, 255);
	//转换成宽字符
	MultiByteToWideChar(CP_ACP, 0, name, -1, wszShareName, 255);
#if 0
	res = NetShareGetInfo(NULL, (char *)wszShareName, 502, (LPBYTE *)&psi);
#else
	res = NetShareGetInfo(NULL, wszShareName, 502, (LPBYTE *)&psi);
#endif
	if (res == NERR_Success)
	{
		wsprintf((char*)szPathName, "%S ", psi->shi502_path);
		sRet = szPathName;
		sRet.TrimRight();
	}
	else
	{
		CString str;
#if 0	// Jeff delete;
		str.Format("转换路径失败-%d", res);
		::WriteTextLog(str);//Jeff delete,此处使用了系统域符号,其实完全没作用.
#else
		str.Format("转换路径失败(\"%s\"),", sRet);
		ErrorExit(str, res);
#endif
	}

	//释放缓冲
	NetApiBufferFree(psi);
}

CString GetModifyTime2(CString path)
{
	try
	{
		CFileFind finder;
		BOOL bWorking = finder.FindFile(path);
		if (bWorking)
		{
			finder.FindNextFile();
			CTime tm;
			finder.GetLastWriteTime(tm);
			CString   stime;
			stime.Format("%d%02d%02d", tm.GetYear(), tm.GetMonth(), tm.GetDay());
			return stime;
		}
		return "";
	}
	catch (CFileException *e)
	{
		WriteTextLog(_T("2.读文件[%s]修改时间出错:%d"), e->m_strFileName, e->m_lOsError);
		e->Delete();
	}

	return _T("");
}

CString GetModifyTime(CString path)
{
	try
	{
		HANDLE   hFile;
		WIN32_FIND_DATA   wfd;
		//	SYSTEMTIME   systime;   
		FILETIME   localtime;
		CString   stime;     //输出时间   
		memset(&wfd, 0, sizeof(wfd));
		if ((hFile = FindFirstFile(path, &wfd)) == INVALID_HANDLE_VALUE)
			return "";
		//ok,转换时间
		FileTimeToLocalFileTime(&wfd.ftLastWriteTime, &localtime);
		stime.Format("%16d%16d", localtime.dwHighDateTime, localtime.dwLowDateTime);
		return stime;
	}
	catch (CFileException *e)
	{
		CString strError;
		WriteTextLog(_T("读文件[%s]修改时间出错:%d"), e->m_strFileName, e->m_lOsError);
		e->Delete();
	}

	return _T("");
}

//--------------------------------------------------------------------------------
// Jeff add 2014.06.23;
// 函数：ErrorExit
// 描述：
// 参数:
//     lpszFunction：函数名;
//     dwError：错误码; 
//
//--------------------------------------------------------------------------------
void ErrorExit(CString strDescription, const DWORD &dwError)
{
#if 1
	LPVOID lpMsgBuf;

	BOOL fOk = FormatMessage(
		FORMAT_MESSAGE_ALLOCATE_BUFFER |
		FORMAT_MESSAGE_FROM_SYSTEM |
		FORMAT_MESSAGE_IGNORE_INSERTS,
		NULL,
		dwError,
		MAKELANGID(LANG_NEUTRAL, SUBLANG_DEFAULT),
		(LPTSTR)&lpMsgBuf,
		0, NULL);

	if (!fOk)
	{
		// Is it a network-related error?
		HMODULE hDll = LoadLibraryEx(TEXT("netmsg.dll"), NULL, DONT_RESOLVE_DLL_REFERENCES);

		if (hDll != NULL) 
		{
			FormatMessage(
				FORMAT_MESSAGE_FROM_HMODULE |
				FORMAT_MESSAGE_FROM_SYSTEM |
				FORMAT_MESSAGE_IGNORE_INSERTS,
				hDll,
				dwError,
				MAKELANGID(LANG_ENGLISH, SUBLANG_ENGLISH_US),
				(LPTSTR)&lpMsgBuf,
				0,
				NULL);

			FreeLibrary(hDll);
		}
	}

	if (lpMsgBuf != NULL)
	{
		WriteTextLog("%s.错误码=%d,Windows描述:%s", strDescription, dwError, (LPCTSTR)LocalLock(lpMsgBuf));
		LocalFree(lpMsgBuf);
	}
	else
	{
		WriteTextLog(strDescription);
	}
#else
	HLOCAL hlocal = NULL;   // Buffer that gets the error message string

	// Get the error code's textual description
	BOOL fOk = FormatMessage(
		FORMAT_MESSAGE_FROM_SYSTEM |
		FORMAT_MESSAGE_ALLOCATE_BUFFER |
		FORMAT_MESSAGE_IGNORE_INSERTS,
		NULL,
		dwError,
		MAKELANGID(LANG_ENGLISH, SUBLANG_ENGLISH_US),
		(PTSTR)&hlocal,
		0,
		NULL);

	if (!fOk)
	{
		// Is it a network-related error?
		HMODULE hDll = LoadLibraryEx(TEXT("netmsg.dll"), NULL, DONT_RESOLVE_DLL_REFERENCES);

		if (hDll != NULL) 
		{
			FormatMessage(
				FORMAT_MESSAGE_FROM_HMODULE |
				FORMAT_MESSAGE_FROM_SYSTEM |
				FORMAT_MESSAGE_IGNORE_INSERTS,
				hDll,
				dwError,
				MAKELANGID(LANG_ENGLISH, SUBLANG_ENGLISH_US),
				(PTSTR)&hlocal,
				0,
				NULL);
			FreeLibrary(hDll);
		}
	}

	if (hlocal != NULL)
	{
		CString strDisplay;
		strDisplay.Format("%s 失败错误码=%d,Windows系统描述:%s", strDescription, dwError, (PCTSTR)LocalLock(hlocal));
		WriteTextLog(strDisplay);
		LocalFree(hlocal);
	}
	else
	{
		WriteTextLog("Error number not found.");
	}
#endif

}

void MyGetIPByName(CString &name)
{
	CString strIP = name;
	name.Empty();
	DWORD dwServerIP = 0;
	HOSTENT   *host = gethostbyname(strIP);
	struct   in_addr   addr;
	if (host != NULL)
	{
		for (int i = 0; host->h_addr_list[i] != NULL; i++)
		{
			memset(&addr, 0, sizeof(addr));
			memcpy(&addr.S_un.S_addr, host->h_addr_list[i], host->h_length);
			dwServerIP = ntohl(addr.S_un.S_addr);
		}
		BYTE*   pIP = (BYTE*)&dwServerIP;
		name.Format(_T("%d.%d.%d.%d"), pIP[3], pIP[2], pIP[1], pIP[0]);
	}
}

void EncryptFile3(CString path)
{
	CFile fp;
	if (fp.Open(path, CFile::modeRead) == 0)return;
	DWORD leng = fp.GetLength();
	BYTE *pData = new BYTE[leng];
	fp.Read(pData, leng);
	fp.Close();

	EncryptFile2(pData, leng, "z9871234abcd");
	fp.Open(path, CFile::modeWrite);
	fp.Write(pData, leng);
	fp.Close();
	delete[]pData;
}

int FindArray(CStringArray *pArray, CString Str)
{
	for (int i = 0; i < pArray->GetSize(); i++)
	{
		if (pArray->ElementAt(i) == Str)
			return i;
	}
	return -1;
}

BOOL isInnerIP(DWORD a_ip)
{
	BOOL bValid = 0;
	if ((a_ip >> 24 == 0xa) || (a_ip >> 16 == 0xc0a8) || (a_ip >> 22 == 0x2b0))
	{
		bValid = 1;
	}
	return bValid;
}

BOOL CompareIP(CString name1, CString name2)
{
	CStringArray g_serverarray1;
	CStringArray g_serverarray2;
	CString strIP = name1;
	DWORD dwServerIP = 0;
	HOSTENT   *host = gethostbyname(strIP);
	struct   in_addr   addr;
	if (host != NULL)
	{
		for (int i = 0; host->h_addr_list[i] != NULL; i++)
		{
			memset(&addr, 0, sizeof(addr));
			memcpy(&addr.S_un.S_addr, host->h_addr_list[i], host->h_length);
			dwServerIP = ntohl(addr.S_un.S_addr);
			BYTE*   pIP = (BYTE*)&dwServerIP;
			strIP.Format(_T("%d.%d.%d.%d"), pIP[3], pIP[2], pIP[1], pIP[0]);
			g_serverarray1.Add(strIP);
		}
	}
	while (g_serverarray1.GetSize() > 1)
	{
		CString name;
		BOOL bFind = 0;
		for (int i = 0; i < g_serverarray1.GetSize(); i++)
		{
			DWORD dwServerIP = inet_addr(g_serverarray1.ElementAt(i));
			dwServerIP = htonl(dwServerIP);//加了才正确
			if (isInnerIP(dwServerIP) == 0)
			{
				g_serverarray1.RemoveAt(i);
				bFind = 1;
				break;
			}
		}
		if (bFind == 0)
		{
			break;
		}
	}
	//////////
	{
		CString strIP = name2;
		DWORD dwServerIP = 0;
		HOSTENT   *host = gethostbyname(strIP);
		struct   in_addr   addr;
		if (host != NULL)
		{
			for (int i = 0; host->h_addr_list[i] != NULL; i++)
			{
				memset(&addr, 0, sizeof(addr));
				memcpy(&addr.S_un.S_addr, host->h_addr_list[i], host->h_length);
				dwServerIP = ntohl(addr.S_un.S_addr);
				BYTE*   pIP = (BYTE*)&dwServerIP;
				strIP.Format(_T("%d.%d.%d.%d"), pIP[3], pIP[2], pIP[1], pIP[0]);
				g_serverarray2.Add(strIP);
			}
		}
		while (g_serverarray2.GetSize() > 1)
		{
			CString name;
			BOOL bFind = 0;
			for (int i = 0; i < g_serverarray2.GetSize(); i++)
			{
				DWORD dwServerIP = inet_addr(g_serverarray2.ElementAt(i));
				dwServerIP = htonl(dwServerIP);//加了才正确
				if (isInnerIP(dwServerIP) == 0)
				{
					g_serverarray2.RemoveAt(i);
					bFind = 1;
					break;
				}
			}
			if (bFind == 0)
			{
				break;
			}
		}
	}
	if (g_serverarray1.GetSize() == 0 || g_serverarray2.GetSize() == 0)return 1;
	for (int i = 0; i < g_serverarray1.GetSize(); i++)
	{
		for (int j = 0; j < g_serverarray2.GetSize(); j++)
		{
			if (g_serverarray1.ElementAt(i) == g_serverarray2.ElementAt(j))return 0;
		}
	}
	return 1;
}

void DeleteDirectory(CString strDir)
{
	if ( strDir.IsEmpty() || !PathFileExists(strDir) )
	{
		WriteTextLog(_T("DeleteDirectory:路径无效!"));
		return;
	}

	try
	{
		// 首先删除文件及子文件夹;   
		CFileFind   ff;
		BOOL   bFound = ff.FindFile(strDir + _T("\\*"), 0);
		while (bFound)
		{
			bFound = ff.FindNextFile();
			if (ff.GetFileName() == _T(".") || ff.GetFileName() == _T(".."))
				continue;
			// 去掉文件(夹)只读等属性;   
			if ( SetFileAttributes(ff.GetFilePath(), FILE_ATTRIBUTE_NORMAL) )
			{
				if (ff.IsDirectory())
				{   // 递归删除子文件夹;   
					DeleteDirectory(ff.GetFilePath());
					RemoveDirectory(ff.GetFilePath());
				}
				else
				{
					DeleteFile(ff.GetFilePath());   // Jeff：删除某文件夹下的所有子文件;
					WriteTextLog(ff.GetFilePath());
				}
			}
			else
			{
				WriteTextLog(_T("设置文件[%s]属性失败：%d"), ff.GetFilePath(), GetLastError());
			}
		}
		ff.Close();
		// 然后删除该文件夹;   
		RemoveDirectory(strDir);
	}
	catch (...)
	{
		WriteTextLog(_T("出错在函数deldir中"));
	}
}

int GetLengthEx(CString str)
{
	wchar_t   wstr[500];
	int   k = MultiByteToWideChar(CP_ACP, MB_PRECOMPOSED, str, strlen(str), wstr, 500);
	return k;
}

CString GetFileSize(CString path)
{
	CString str = "0";
	try
	{
		CFile fp;
		fp.Open(path, CFile::modeRead);
		str.Format("%d", fp.GetLength());
		fp.Close();
	}
	catch (...)
	{
	}
	return str;
}

void SortArray(CStringArray &datearray)
{
	try
	{
		CString  strtemp;
		float  ftemp;
		int last = datearray.GetSize() - 1;
		bool sorted = true;

		do {
			sorted = true;
			for (int i = 0; i < last; i++)
			{
				if (datearray[i] < datearray[i + 1])
				{
					strtemp = datearray[i];
					datearray[i] = datearray[i + 1];
					datearray[i + 1] = strtemp;



					sorted = false;
				}

			}
			last--;
		} while (!sorted);
	}
	catch (...)
	{
		WriteTextLog("SortArray出错");
	}
}

int CheckPhoneType(CString phoneno)//移动:0 联通:1 电信:2 小灵通:3 未知:-1
{
	if (phoneno.IsEmpty())return -1;
	int i = 0;
	for (i = 0; i < phoneno.GetLength(); i++)
	{
		if (phoneno.GetAt(i) < '0' || phoneno.GetAt(i) > '9')return -1;
	}
	if (phoneno.GetAt(0) == '1')
	{
		if (phoneno.GetLength() != 11)
			return -1;
		int mobile[] = { 139, 138, 137, 136, 135, 134, 159, 158, 152, 151, 150, 157, 188, 187, 144, 182, 147, 183, 184 };
		int unicom[] = { 130, 131, 132, 155, 156, 186, 185 };
		int telecom[] = { 133, 153, 189, 180, 181 };

		for (i = 0; i < sizeof(mobile) / sizeof(int); i++)
		{
			if (mobile[i] == atoi(phoneno.Left(3)))
			{
				return 0;
			}
		}
		for (i = 0; i < sizeof(unicom) / sizeof(int); i++)
		{
			if (unicom[i] == atoi(phoneno.Left(3)))
			{
				return 1;
			}
		}
		for (i = 0; i < sizeof(telecom) / sizeof(int); i++)
		{
			if (telecom[i] == atoi(phoneno.Left(3)))
			{
				return 2;
			}
		}
		return -1;
	}
	/*	else if(phoneno.GetAt (0)=='0')
	{
	if(phoneno.GetLength ()>=10 && phoneno.GetLength ()<=12)
	{
	return 3;
	}
	}*/
	return -1;
}

CTime GetTmFromStr(CString date)
{

	try
	{
		CTime tm(atoi(date.Mid(0, 4)), atoi(date.Mid(5, 2)), atoi(date.Mid(8, 2)), 0, 0, 0);
		CString ss;
		ss.Format("%d-%d-%d", tm.GetYear(), tm.GetMonth(), tm.GetDay());
		return tm;
	}
	catch (...)
	{
		date = "1980-01-01";
		CTime tm(atoi(date.Mid(0, 4)), atoi(date.Mid(5, 2)), atoi(date.Mid(8, 2)), 0, 0, 0);
		return tm;
	}
}

void ConvertToPrice(CString &str)
{
	if (str.Find('.') == -1)return;
	str.TrimRight('0');
	str.TrimRight('.');
}

void SortArray(CArray<CStringArray, CStringArray>*List1array, int pos)
{
	CString  stemp;
	int last = List1array->GetSize() - 1;
	int ret = last;
	bool sorted = true;
	do
	{
		sorted = true;
		for (int i = 0; i < last; i++)
		{
			if (List1array->ElementAt(i).ElementAt(pos) < List1array->ElementAt(i + 1).ElementAt(pos))
			{
				for (int a = 0; a < List1array->ElementAt(i).GetSize(); a++)
				{
					stemp = List1array->ElementAt(i).ElementAt(a);
					List1array->ElementAt(i).SetAt(a, List1array->ElementAt(i + 1).ElementAt(a));
					List1array->ElementAt(i + 1).SetAt(a, stemp);
				}
				sorted = false;
			}
		}
		last--;
	} while (!sorted);
}

void DeCodePicCount(int &value1, int &value2)
{
	//	SoftKey ytSoftKey;
	int ret = 0;//ytSoftKey.Ini();
	if (ret != 0)
	{
		return;
	}
	int d[8]; double f[8];
	TCHAR s0[50] = _T(""), s1[50] = _T(""), s2[50] = _T(""), s3[50] = _T(""), s4[50] = _T(""), s5[50] = _T(""), s6[50] = _T(""), s7[50] = _T("");
	//运行自定义函数
	ret = ytSoftKey.decryptpiccount(&value1, &value2, &d[2], &d[3], &d[4], &d[5], &d[6], &d[7],
		&f[0], &f[1], &f[2], &f[3], &f[4], &f[5], &f[6], &f[7],
		s0, s1, s2, s3, s4, s5, s6, s7);
	if (ret != 0 && ret != -43)
	{
		exit(0);
	}
}

void DeCodelong1(int &value1, int &value2, int &value3, int &value4, int &value5, int &value6, int &value7, int &value8)
{
	//	SoftKey ytSoftKey;
	int ret = 0;//ytSoftKey.Ini();
	if (ret != 0)
	{
		return;
	}

	double f[8];
	TCHAR s0[50] = _T(""), s1[50] = _T(""), s2[50] = _T(""), s3[50] = _T(""), s4[50] = _T(""), s5[50] = _T(""), s6[50] = _T(""), s7[50] = _T("");
	//运行自定义函数
	ret = ytSoftKey.decryptlong1(&value1, &value2, &value3, &value4, &value5, &value6, &value7, &value8,
		&f[0], &f[1], &f[2], &f[3], &f[4], &f[5], &f[6], &f[7],
		s0, s1, s2, s3, s4, s5, s6, s7);
	if (ret != 0 && ret != -43)
	{
		exit(0);
	}
}

void DeCodelong2(int &value1, int &value2, int &value3, int &value4, int &value5, int &value6, int &value7, int &value8)
{
	//	SoftKey ytSoftKey;
	int ret = 0;//ytSoftKey.Ini();
	if (ret != 0)
	{
		return;
	}

	double f[8];
	TCHAR s0[50] = _T(""), s1[50] = _T(""), s2[50] = _T(""), s3[50] = _T(""), s4[50] = _T(""), s5[50] = _T(""), s6[50] = _T(""), s7[50] = _T("");
	//运行自定义函数
	ret = ytSoftKey.decryptlong2(&value1, &value2, &value3, &value4, &value5, &value6, &value7, &value8,
		&f[0], &f[1], &f[2], &f[3], &f[4], &f[5], &f[6], &f[7],
		s0, s1, s2, s3, s4, s5, s6, s7);
	if (ret != 0 && ret != -43)
	{
		exit(0);
	}
}

void DeCodelong3(int &value1, int &value2, int &value3, int &value4, int &value5, int &value6, int &value7, int &value8)
{
	//	SoftKey ytSoftKey;
	int ret = 0;//ytSoftKey.Ini();
	if (ret != 0)
	{
		return;
	}

	double f[8];
	TCHAR s0[50] = _T(""), s1[50] = _T(""), s2[50] = _T(""), s3[50] = _T(""), s4[50] = _T(""), s5[50] = _T(""), s6[50] = _T(""), s7[50] = _T("");
	//运行自定义函数
	ret = ytSoftKey.decryptlong3(&value1, &value2, &value3, &value4, &value5, &value6, &value7, &value8,
		&f[0], &f[1], &f[2], &f[3], &f[4], &f[5], &f[6], &f[7],
		s0, s1, s2, s3, s4, s5, s6, s7);
	if (ret != 0 && ret != -43)
	{

		exit(0);
	}
}

void DeCodelong4(int &value1, int &value2, int &value3, int &value4, int &value5, int &value6, int &value7, int &value8)
{
	//	SoftKey ytSoftKey;
	int ret = 0;//ytSoftKey.Ini();
	if (ret != 0)
	{
		exit(0);
	}

	double f[8];
	TCHAR s0[50] = _T(""), s1[50] = _T(""), s2[50] = _T(""), s3[50] = _T(""), s4[50] = _T(""), s5[50] = _T(""), s6[50] = _T(""), s7[50] = _T("");
	//运行自定义函数
	ret = ytSoftKey.decryptlong4(&value1, &value2, &value3, &value4, &value5, &value6, &value7, &value8,
		&f[0], &f[1], &f[2], &f[3], &f[4], &f[5], &f[6], &f[7],
		s0, s1, s2, s3, s4, s5, s6, s7);
	if (ret != 0 && ret != -43)
	{
		exit(0);
	}
}

#endif
#if JEFF_TEST_ON
/************************************************************************/
/* 
	函数:IsValidDate
	描述:判断输入的公历日期是否有效;
	参数:
		IN:		lpDate 要判断的日期字符串;
	返回:日期有效返回TRUE,否则返回FALSE;
	要求:
	注意:
	示例:
*/
/************************************************************************/
BOOL IsValidDate(IN LPCTSTR lpDate)
{
	if (lpDate == NULL || _tcscmp(lpDate, _T("")) == 0)
		return FALSE;

	CString strDate = lpDate;
	if (strDate.IsEmpty()) return FALSE;

	// 判断日期合法性;
	static int nYear = 0;
	static int nMonth = 0;
	static int nDay = 0;

	nYear = nMonth = nDay = 0;
	nYear = _ttoi(strDate.Left(4));

	nMonth = _ttoi(strDate.Mid(5, 2));
	nDay = _ttoi(strDate.Mid(8, 2));

	CONST static INT nNormalMonth[12] = { 31, 28, 31, 30, 31, 30, 31, 31, 30, 31, 30, 31 };
	CONST static INT nLeapMonth[12] = { 31, 29, 31, 30, 31, 30, 31, 31, 30, 31, 30, 31 };

	if ((nDay <= 0) || (nDay > 31) || (nMonth <= 0) || (nMonth > 12)) return FALSE;

	if ((nYear % 400 == 0) || (nYear % 4 == 0 && nYear % 100 != 0))
	{
		if (nDay > nLeapMonth[nMonth - 1])	return FALSE;
	}
	else
	{
		if (nDay > nNormalMonth[nMonth - 1]) return FALSE;
	}

	return TRUE;
}

#endif

/************************************************************************/
/* 
	函数:LoadBackupModuleDll
	描述:加载备份模块
	参数:
		IN CONST CString strDll				文件全路径
	返回:1成功，0失败
*/
/************************************************************************/
int	 LoadBackupModuleDll(IN CONST CString strDll)
{
	if (!::PathFileExists(strDll))
		return 0;

	HRESULT hr = NULL;
	if(g_hDllInst)
		return 1;

	if(g_hDllInst == NULL)
	{
		g_hDllInst = LoadLibrary(strDll);
		if(g_hDllInst == NULL)
		{
			WriteTextLog(_T("加载") + strDll + _T("失败\n"));
			return 0;
		}
	}
	WriteTextLog(_T("加载") + strDll + _T("成功\n"));
	return 1;
}

/************************************************************************/
/* 
	函数:FreeBackupModuleDll
	描述:卸载备份模块
	参数:
	返回:
*/
/************************************************************************/
void FreeBackupModuleDll()
{
	if(g_hDllInst != NULL)
		FreeLibrary(g_hDllInst);
	g_hDllInst = NULL;
}

static INT CALLBACK BrowseCallbackProc(HWND hwnd, UINT uMsg, LPARAM lp, LPARAM pData)
{
	switch (uMsg)
	{
	case BFFM_INITIALIZED:
		SendMessage(hwnd, BFFM_SETSELECTION, TRUE, NULL);
		break;
	case   BFFM_SELCHANGED:
		{
			TCHAR szFileName[MAX_PATH];
			LPITEMIDLIST pidlCurrent = (LPITEMIDLIST)lp;
			SHGetPathFromIDList(pidlCurrent, szFileName);
			SendMessage(hwnd, BFFM_SETSTATUSTEXT, 0, (LPARAM)szFileName);
		}
		break;
		// 这个不能让默认目录为桌面;
		// 	case BFFM_INITIALIZED:
		// 		{
		// 			// WParam is TRUE since you are passing a path.
		// 			// It would be FALSE if you were passing a pidl.
		// 			TCHAR szDir[MAX_PATH] = { 0 };
		// 			GetCurrentDirectory(sizeof(szDir) / sizeof(TCHAR), szDir);
		// 			SendMessage(hwnd, BFFM_SETSELECTION, TRUE, (LPARAM)szDir);
		// 		}
		// 		break;
	}
	return 0;
}

BOOL GetFilePath(OUT TCHAR *FilePath, IN HWND hParentWnd, IN TCHAR* InstructionString, IN UINT ulFlags)
{
	BROWSEINFO bInfo;
	LPITEMIDLIST pidl, pidlDesktop;
	ZeroMemory((PVOID)&bInfo, sizeof(BROWSEINFO));

	HRESULT hr = SHGetSpecialFolderLocation(NULL, CSIDL_DESKTOP, &pidlDesktop);
	if ( hr != S_OK )
	{
		//WriteClientLog(_T("获取打开目录路径失败"));
		return FALSE;
	}

	bInfo.pidlRoot = pidlDesktop;
	bInfo.hwndOwner = hParentWnd;
	bInfo.pszDisplayName = FilePath;
	bInfo.lpszTitle = InstructionString;
	bInfo.ulFlags = ulFlags;
	bInfo.lpfn = BrowseCallbackProc;
	bInfo.lParam = 0;

	if ((pidl = ::SHBrowseForFolder(&bInfo)) == NULL)    
	{
		//WriteClientLog(_T("获取打开目录路径失败1"));
		return FALSE;
	}

	if (::SHGetPathFromIDList(pidl, FilePath) == FALSE)   
	{
		//WriteClientLog(_T("获取打开目录路径失败2"));
		return FALSE;
	}

	return TRUE;
}

TCHAR* GetGuidString()
{
	GUID guid;
	static TCHAR szBuf[64] = {0};
	memset(szBuf, 0, 64*sizeof(TCHAR));
	CoInitialize(NULL);
	if (S_OK == ::CoCreateGuid(&guid))
	{
		sprintf(szBuf, _T("{%08X-%04X-%04X-%02X%02X-%02X%02X%02X%02X%02X%02X}"),
			guid.Data1,
			guid.Data2,
			guid.Data3,
			guid.Data4[0], 
			guid.Data4[1],
			guid.Data4[2], 
			guid.Data4[3],
			guid.Data4[4], 
			guid.Data4[5],
			guid.Data4[6], 
			guid.Data4[7]
		);
	}
	CoUninitialize();

	return szBuf;
}

DWORD GetSoftRunTime()
{
	DWORD id;
	TCHAR HKey[50] = "ffffffff",LKey[50]="ffffffff";
	TCHAR OutTime[50];
	TCHAR DevicePath[ 260];
	if(FindPort(0,DevicePath)!=0)
		return 0;

	//LIBC.LIB,libcp.lib,msvcprt.lib
	TCHAR  year[10],month[10],day[10],hour[10],minute[10],second[10];
	ReadTimeAuthFromEprom(HKey,LKey, OutTime, &id, 30128, HKey, LKey, DevicePath);
	CString str=OutTime;
	CString temp="年";
	int pos=str.Find (temp);
	temp=str.Left (pos);
	str=str.Right (str.GetLength ()-pos-2);
	strcpy(year, temp.GetBuffer (0));temp.ReleaseBuffer ();

	temp="月";
	pos=str.Find (temp);
	temp=str.Left (pos);
	str=str.Right (str.GetLength ()-pos-2);
	strcpy(month, temp.GetBuffer (0));temp.ReleaseBuffer ();

	temp="日";
	pos=str.Find (temp);
	temp=str.Left (pos);
	str=str.Right (str.GetLength ()-pos-2);
	strcpy(day, temp.GetBuffer (0));temp.ReleaseBuffer ();

	temp="小时";
	pos=str.Find (temp);
	temp=str.Left (pos);
	str=str.Right (str.GetLength ()-pos-4);
	strcpy(hour, temp.GetBuffer (0));temp.ReleaseBuffer ();

	temp="分钟";
	pos=str.Find (temp);
	temp=str.Left (pos);
	str=str.Right (str.GetLength ()-pos-4);
	strcpy(minute, temp.GetBuffer (0));temp.ReleaseBuffer ();
	temp="0";
	strcpy(second, temp.GetBuffer (0));temp.ReleaseBuffer ();
	long time1=ConvertStringToTimerReal(year, month, day, hour, minute, second);

	GetRunTimer(year, month, day, hour, minute, second, DevicePath);
	long time2=ConvertStringToTimerReal(year, month, day, hour, minute, second);

	// 软件可运行时间;
	return time1 - time2;
}


/************************************************************************/
/*  函数：WriteTextLog[7/28/2016 IT];
/*  描述：写文本日志;
/*  参数：;
/*  	[IN] ：;
/*  返回：void;
/*  注意：;
/*  示例：;
/*
/*  修改：;
/*  日期：;
/*  内容：;
/************************************************************************/
void WriteTextLog(const TCHAR *format, ...)
{
	try
	{
		static ThreadSection _critSection;
		AutoThreadSection aSection(&_critSection);
		// 解析出日志路径;
		TCHAR szlogpath[MAX_PATH] = {0};
		static TCHAR szModulePath[MAX_PATH] = {0};
		static TCHAR szFna[_MAX_DIR] = { 0 };
		if ( szModulePath[0] == _T('\0') )
		{
			TCHAR szDrive[_MAX_DRIVE] = { 0 };
			TCHAR szDir[_MAX_DIR] = { 0 };
			TCHAR szExt[_MAX_DIR] = { 0 };
			::GetModuleFileName(NULL, szModulePath, sizeof(szModulePath) / sizeof(TCHAR));
			_tsplitpath_s(szModulePath, szDrive, szDir, szFna, szExt);
			_tcscpy_s(szModulePath, szDrive);
			_tcscat_s(szModulePath, szDir);
		}

		_stprintf_s(szlogpath, _T("%s日志\\%s%s.txt"), szModulePath, szFna, CTime::GetCurrentTime().Format("[%Y-%m-%d]"));

		// 打开或创建文件;
		CStdioFile fp;
		if (PathFileExists(szlogpath))
		{
			if (fp.Open(szlogpath, CFile::modeWrite) == FALSE)
			{
				return;
			}
			fp.SeekToEnd();
		}
		else
		{
			if ( !fp.Open(szlogpath, CFile::modeCreate | CFile::modeWrite) )
				return;
		}

		// 格式化前设置语言区域;
		TCHAR* old_locale = _tcsdup(_tsetlocale(LC_CTYPE, NULL));
		_tsetlocale(LC_CTYPE, _T("chs"));//设定中文;

		// 格式化日志内容;
		va_list		args = NULL;
		int			len = 0;
		TCHAR		*buffer = NULL;
		va_start( args, format );
		// _vscprintf doesn't count. terminating '\0'
		len = _vsctprintf_p( format, args );
		if ( len == -1 )
		{
			goto clear;
		}

		len++;
		buffer = (TCHAR*)malloc( len * sizeof(TCHAR) );
		_vstprintf_s( buffer, len, format, args ); // C4996
		// Note: vsprintf is deprecated; consider using vsprintf_s instead

		// 将日志内容输入到文件中;
		fp.WriteString( CTime::GetCurrentTime().Format(_T("%Y-%m-%d %H:%M:%S ")) );
		fp.WriteString(buffer);
		fp.WriteString(_T("\n"));

		// 关闭文件，释放资源并设置回原语言区域;
		free( buffer );
clear:
		_tsetlocale(LC_CTYPE, old_locale);
		free(old_locale);//还原区域设定;
		fp.Close();
	}
	catch (CException *e)
	{
		e->ReportError();
		e->Delete();
	}
}

/************************************************************************/
/*  函数：ExectueScript[8/11/2016 IT];
/*  描述：;
/*  参数：;
/*  	[IN] lpCatalogSvr：数据库地址;
/*  	[IN] lpCatalogUser：数据库用户名;
/*  	[IN] lpCatalogPsw：数据库密码;
/*  	[IN] lpScriptFile：要执行的数据库脚本文件;
/*  	[IN] lpCatalogLog：执行脚本后输出的日志文件;
/*  返回：成功执行sqlcmd返回true;
/*  注意：;
/*  示例：;
/*
/*  修改：;
/*  日期：;
/*  内容：;
/************************************************************************/
BOOL ExectueScript(IN LPCTSTR lpCatalogSvr, IN LPCTSTR lpCatalogUser, IN LPCTSTR lpCatalogPsw, IN LPCTSTR lpScriptFile, IN LPCTSTR lpCatalogLog)
{
	// 参数有效性判断;
	if ( lpCatalogSvr == NULL || lpCatalogSvr[0] == _T('\0')	||
		 lpCatalogUser == NULL || lpCatalogUser[0] == _T('\0')	||
		 lpCatalogPsw == NULL || lpCatalogPsw[0] == _T('\0')	||
		 lpScriptFile == NULL || lpScriptFile[0] == _T('\0')	||  !PathFileExists(lpScriptFile)	||
		 lpCatalogLog == NULL || lpCatalogLog[0] == _T('\0')	  )
	{
		WriteTextLog(_T("%s-%d-%s:参数无效！"),__FILE__, __LINE__, __FUNCTION__);
		return FALSE;
	}

	SHELLEXECUTEINFO stuExecInfo = { 0 };
	DWORD dwExitCode = STILL_ACTIVE;

	CString strCommandLine;
	strCommandLine.Format(_T(" -S %s -U %s -P %s -d master -i \"%s\" -o \"%s\""), lpCatalogSvr, lpCatalogUser, lpCatalogPsw, lpScriptFile, lpCatalogLog);// 创建数据库时,不能用/d选项;

	stuExecInfo.cbSize = sizeof(SHELLEXECUTEINFO);
	stuExecInfo.lpFile = _T("sqlcmd");
	stuExecInfo.lpParameters = strCommandLine;
	stuExecInfo.nShow = SW_HIDE;
	stuExecInfo.fMask = SEE_MASK_NOCLOSEPROCESS | SEE_MASK_FLAG_NO_UI;

	if (!ShellExecuteEx(&stuExecInfo))
	{
		WriteTextLog(_T("执行ShellExecuteEx失败,错误码:%d"), GetLastError());
		return FALSE;
	}

	HANDLE hProcess = stuExecInfo.hProcess;
	if ( hProcess != NULL )
	{
		WaitForSingleObject(hProcess,INFINITE);
		CloseHandle(hProcess);
	}

	return TRUE;
}

/************************************************************************/
/*  函数：ExectueStatement[8/11/2016 IT];
/*  描述：;
/*  参数：;
/*  	[IN] lpCatalogSvr：数据库地址;
/*  	[IN] lpCatalogUser：数据库用户名;
/*  	[IN] lpCatalogPsw：数据库密码;
/*  	[IN] lpCatalogName：对象数据库名称;
/*  	[IN] lpSQLScript：要执行的SQL语句;
/*  	[IN] dwQueryTimeOut：查询超时值，单位秒;
/*  返回：成功返回日志内容;
/*  注意：;
/*  示例：;
/*
/*  修改：;
/*  日期：;
/*  内容：;
/************************************************************************/
BOOL ExectueStatement(IN LPCTSTR lpCatalogSvr, IN LPCTSTR lpCatalogUser, IN LPCTSTR lpCatalogPsw, IN LPCTSTR lpCatalogName, IN LPCTSTR lpSQLScript, IN LPCTSTR lpCatalogLog, IN const DWORD& dwQueryTimeOut /* = 15 */ )
{
	// 参数有效性判断;
	if ( lpCatalogSvr == NULL || lpCatalogSvr[0] == _T('\0')	||
		lpCatalogUser == NULL || lpCatalogUser[0] == _T('\0')	||
		lpCatalogPsw == NULL || lpCatalogPsw[0] == _T('\0')		||
		lpCatalogName == NULL || lpCatalogName[0] == _T('\0')	||
		lpSQLScript == NULL || lpSQLScript[0] == _T('\0')	    ||
		lpCatalogLog == NULL || lpCatalogLog[0] == _T('\0') )
	{
		WriteTextLog(_T("%s-%d-%s:参数无效！"),__FILE__, __LINE__, __FUNCTION__);
		return FALSE;
	}

	SHELLEXECUTEINFO stuExecInfo = { 0 };
	DWORD dwExitCode = STILL_ACTIVE;

	CString strCommandLine;
	strCommandLine.Format(_T(" -S %s -U %s -P %s -d %s -Q \"%s\" -t %d -o %s"), lpCatalogSvr, lpCatalogUser, lpCatalogPsw, lpCatalogName, lpSQLScript, dwQueryTimeOut, lpCatalogLog);

	stuExecInfo.cbSize = sizeof(SHELLEXECUTEINFO);
	stuExecInfo.lpFile = _T("sqlcmd");
	stuExecInfo.lpParameters = strCommandLine;
	stuExecInfo.nShow = SW_HIDE;
	stuExecInfo.fMask = SEE_MASK_NOCLOSEPROCESS | SEE_MASK_FLAG_NO_UI;

	if (!ShellExecuteEx(&stuExecInfo))
	{
		WriteTextLog(_T("执行ShellExecuteEx失败,错误码:%d"), GetLastError());
		return FALSE;
	}

	HANDLE hProcess = stuExecInfo.hProcess;
	if ( hProcess != NULL )
	{
		WaitForSingleObject(hProcess,INFINITE);
		CloseHandle(hProcess);
	}

	if ( !PathFileExists(lpCatalogLog) )
	{
		WriteTextLog(_T("执行sqlcmd无日志文件返回"));
		return FALSE;
	}

	return TRUE;
}

BOOL IsCatalogDamage()
{
	CString strInfo;
	strInfo.Format(_T("dbcc checkdb('%s')"), g_szDBName);
	if ( ExectueStatement(g_szDBSource, g_szDBAccount, g_szDBPassWord, _T("master"), strInfo, _T("sqlerr"), g_dwCheckdbTimeOut ? g_dwCheckdbTimeOut : 30) )
	{
		struct stat statbuf;
		stat(_T("sqlerr"), &statbuf);
		if ( statbuf.st_size == 0 )
		{
			WriteTextLog(_T("执行sqlcmd日志文件长度0"));
			return FALSE;
		}

		TCHAR *perr = new TCHAR[statbuf.st_size+1];
		memset(perr, 0, statbuf.st_size+1);

		FILE *err = NULL;
		_tfopen_s(&err, _T("sqlerr"), _T("r"));
		if ( err )
		{
			fread_s(perr, statbuf.st_size, sizeof(TCHAR), statbuf.st_size, err);
			fclose(err);
		}
		else
		{
			WriteTextLog(_T("打开sqlcmd日志文件失败"));
			return FALSE;
		}

		strInfo = perr;
		if ( perr )
			delete []perr;

		if ( !strInfo.IsEmpty() )
		{
			CString strFind;
			strFind.Format(_T("CHECKDB 在数据库 '%s' 中发现 0 个分配错误和 0 个一致性错误。"),g_szDBName);
			if ( -1 == strInfo.Find(strFind) )
			{
				// 没有找到,表示数据库可能损坏;
				WriteTextLog(_T("sqlerr未找到匹配信息：%s"), strFind);
				return TRUE;
			}
		}
	}
	else
	{
		WriteTextLog(_T("执行dbcc checkdb失败"));
	}

	return FALSE;
}

DWORD WINAPI CheckdbThread(LPVOID lpParamter)
{
	// 检查数据库的完整性;
	g_bIsCatalogDamage = IsCatalogDamage();
	return 0;
}