lyfz_repos/经典版源码/lyfzInternalServer/trunk/InternalServer/DBServerDlg.cpp

/****************************************************************/
/*																*/
/*  ApplicationDlg.cpp											*/
/*																*/
/*  Implementation of the CDBServerDlg class.				*/
/*	This class is a part of the Date Server.						*/
/*																*/
/*  Programmed by LYFZ van der Meer							*/
/*  Copyright LYFZ Software Solutions 2002						*/
/*	http://www.LYFZvandermeer.nl								*/
/*																*/
/*  Last updated: 10 july 2002									*/
/*																*/
/****************************************************************/
//在ApplicationDlg.cpp文件中实现主窗口界面的设计。及其主窗口相应控件的功能和参数的映射。 D4F876E2-w78F-22D5-q98A-Y0B0D07B847C
#include "stdafx.h"
#include "DBServer.h"
#include "theDBServer.h"
#include "DBServerDlg.h"
#include "UserAccountsDlg.h"
#include "WizardPages.h"
#include "AboutDlg.h"
#include <afxpriv.h>
#include <process.h>
//#include "Shlwapi.h"
#include "ClientCenter.h"
#include "MyLock.h"
#include "mysqldata.h"
#include "./helper/ffsco.h"
//#include <tlhelp32.h>
#include "ShowPic3.h"

#include "DogTimeOutDlg.h"
#include "InputAuthDlg.h"

#include "ConnectThread.h"
#pragma   comment(lib, "NETAPI32.LIB ") 
#include "SelYear.h"


/*********ErrorExit(...)函数头文件************/
//#include <strsafe.h>
/***********************************/

#ifdef _DEBUG
#define new DEBUG_NEW
#undef THIS_FILE
static char THIS_FILE[] = __FILE__;
#endif
#define LIMITCOUNT  1 //历史数据每次转10个 autorun
extern BOOL g_bSteal;
extern BOOL g_bConvertHisAll;
extern CDBServer theApp;
extern CtheDBServer theServer;

#define WM_ICON_NOTIFY  WM_USER+12
CDBServerDlg *g_pMainWnd = NULL;
//#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);

//extern BOOL EncryptFile2(BYTE *buffer, DWORD leng, PCHAR szPassword);
//extern CStringArray g_conniparray;

CArray<CDatabase*, CDatabase*>g_pHistoryDBarray[200];
CDatabase *g_pDB[200];
CConnectThread *g_pThreadPt[200];
int g_nDBCount = 0;
/////////////////////////////////////////////////////////////////////////////
// CDBServerDlg dialog
#pragma comment(lib, "Shlwapi.lib")
extern DWORD g_nSendCode;
extern BOOL g_bReturned;

DWORD GetLastDirTime(CString dir)
{
	try
	{
		CString path = dir;
		path.TrimRight("\\");
		path += "\\";
		path += "modifytime";
		CStdioFile fp;
		if (::PathFileExists(path))
		{
			fp.Open(path, CFile::modeRead);
			fp.ReadString(path);
			fp.Close();
			path.TrimLeft(); path.TrimRight();
			path.Replace("-", "");

			return atoi(path);
		}
		else
		{
			using namespace helper_coffs;
			ffsco o;
			o.dirs(1);
			o.find(LPCSTR(dir), LPCSTR("*.jpg"));
			ffsco::typeT coo;
			ffsco::typeT::iterator it;
			coo = o.co_file();
			CString path;
			DWORD maxdate = 0;
			for (it = coo.begin(); coo.end() != it; it++)
			{
				if (g_pMainWnd->m_bTerminate2)return 99999999;	// Jeff.奇葩的返回值！
				path = (*it).c_str();
				maxdate = max(maxdate, atol(GetModifyTime2(path)));
			}
			return maxdate;
		}
	}
	catch (...)
	{
		WriteTextLog("出错");
	}
}

static UINT auIDStatusBar[] =
{
	ID_SEPARATOR,
	ID_INDICATOR_DATA_RECEIVED,
	ID_INDICATOR_DATA_SEND,
	ID_INDICATOR_ONLINELED,
	ID_INDICATOR_OFFLINELED
};


/********************************************************************/
/*																	*/
/* Function name : CDBServerDlg::CDBServerDlg					*/
/* Description   : Constructor										*/
/*																	*/
/********************************************************************/
CDBServerDlg::CDBServerDlg(CWnd* pParent /*=NULL*/)
	: CDialog(CDBServerDlg::IDD, pParent)
{
	//{{AFX_DATA_INIT(CDBServerDlg)
	//}}AFX_DATA_INIT
	m_hIcon = AfxGetApp()->LoadIcon(IDI_DBServer);
	m_bTerminate = false;
	m_bRunning = false;
	m_hThread = NULL;
	m_bTerminate2 = false;
	m_bRunning2 = false;
	m_hThread2 = NULL;
	hInst = NULL;
	CString version = _T("Version 1.0");
	g_bAutoRun = AfxGetApp()->GetProfileInt(version, "brun", 0);


	for (int i = 0; i < 200; i++)
	{
		g_pDB[i] = NULL;
		g_pThreadPt[i] = NULL;
	}
}

/********************************************************************/
/*																	*/
/* Function name : CDBServerDlg::~CDBServerDlg				*/
/* Description   : Destructor										*/
/*																	*/
/********************************************************************/
CDBServerDlg::~CDBServerDlg()
{
	for (int i = 0; i < 200; i++)
	{
		CDatabase *db = g_pDB[i];
		if (db)
		{
			db->Close();
			delete db;
		}
		for (int j = 0; j < g_pHistoryDBarray[i].GetSize(); j++)
		{
			CDatabase *db = g_pHistoryDBarray[i].ElementAt(j);
			if (db)
			{
				db->Close();
				delete db;
			}
		}
		g_pHistoryDBarray[i].RemoveAll();
	}
}


/********************************************************************/
/*																	*/
/* Function name : CDBServerDlg::DoDataExchange					*/
/* Description   : Called by the framework to exchange and validate */
/*				   dialog data.										*/
/*																	*/
/********************************************************************/
void CDBServerDlg::DoDataExchange(CDataExchange* pDX)
{
	CDialog::DoDataExchange(pDX);
	//{{AFX_DATA_MAP(CDBServerDlg)
	DDX_Control(pDX, IDC_INFOBAR, m_InfobarCtrl);
	DDX_Control(pDX, IDC_OUTLOOKBAR, m_OutlookBar);
	//}}AFX_DATA_MAP
}

BEGIN_MESSAGE_MAP(CDBServerDlg, CDialog)
	//{{AFX_MSG_MAP(CDBServerDlg)
	ON_WM_DESTROY()
	ON_COMMAND(ID_SERVER_START, OnServerStart)
	ON_UPDATE_COMMAND_UI(ID_SERVER_START, OnUpdateServerStart)
	ON_COMMAND(ID_SERVER_STOP, OnServerStop)
	ON_UPDATE_COMMAND_UI(ID_SERVER_STOP, OnUpdateServerStop)
	ON_COMMAND(ID_SERVER_EXIT, OnServerExit)
	ON_NOTIFY(NM_CLICK, IDC_OUTLOOKBAR, OnClickOutlookBar)
	ON_NOTIFY(LVN_KEYDOWN, IDC_OUTLOOKBAR, OnKeydownOutlookBar)
	ON_COMMAND(ID_USER_ACCOUNTS, OnUserAccounts)
	ON_WM_CLOSE()
	ON_COMMAND(IDC_VIEW_TRACE, OnViewTrace)
	ON_COMMAND(IDC_VIEW_ONLINE_USERS, OnViewOnlineUsers)
	ON_COMMAND(IDC_VIEW_CONFIGURATION, OnViewConfiguration)
	ON_UPDATE_COMMAND_UI(IDC_VIEW_TRACE, OnUpdateViewTrace)
	ON_UPDATE_COMMAND_UI(IDC_VIEW_ONLINE_USERS, OnUpdateViewOnlineUsers)
	ON_UPDATE_COMMAND_UI(IDC_VIEW_CONFIGURATION, OnUpdateViewConfiguration)
	ON_COMMAND(IDC_VIEW_STATISTICS, OnViewStatistics)
	ON_UPDATE_COMMAND_UI(IDC_VIEW_STATISTICS, OnUpdateViewStatistics)
	ON_COMMAND(IDC_VIEW_SECURITY, OnViewSecurity)
	ON_UPDATE_COMMAND_UI(IDC_VIEW_SECURITY, OnUpdateViewSecurity)
	ON_COMMAND(ID_ACCOUNT_WIZARD, OnAccountWizard)
	ON_WM_TIMER()
	ON_COMMAND(IDM_OPEN, OnOpen)
	ON_COMMAND(IDM_EXIT, OnExit)
	ON_COMMAND(IDM_AUTORUN, OnAutorun)
	//}}AFX_MSG_MAP
	ON_MESSAGE(WM_ICON_NOTIFY, OnTrayNotification)
	ON_REGISTERED_MESSAGE(g_wmClose, OnAbortClose)
END_MESSAGE_MAP()


LRESULT CDBServerDlg::OnAbortClose(WPARAM wParam, LPARAM lParam)
{
	if (wParam == 2)
	{
		WriteTextLog("连接失败,服务将重启");
		OnExit2();
	}
	else if (wParam == 3)//更新分店
	{
		LoadBranchInfo();
	}
	return 1;
}

BOOL CDBServerDlg::OnInitDialog()
{
	g_pMainWnd = this;
	CDialog::OnInitDialog();
	char server[50];
	DWORD leng = 50;
	::GetComputerName(server, &leng);
	g_localip = server;
	MyGetIPByName(g_localip);
	// setup listview ctrl, so that it looks like the outbar control
	SetupOutlookBar();
	// Add statusbar to the dialog
	CreateStatusbar();
	CRect rect;
	GetDlgItem(IDC_STATIC1)->GetWindowRect(rect);
	ScreenToClient(rect);
	rect.right += 4;
	GetDlgItem(IDC_STATIC1)->MoveWindow(rect);

	// create property pages
	m_TracePage.Create(IDD_PROPPAGE_TRACE, this);
	m_OnlineUsersPage.Create(IDD_PROPPAGE_ONLINE, this);
	m_ConfigurationPage.Create(IDD_PROPPAGE_CONFIGURATION, this);
	m_StatisticsPage.Create(IDD_PROPPAGE_STATISTICS, this);
	m_SecurityPage.Create(IDD_PROPPAGE_SECURITY, this);

	// activate main page 
	ActivatePage(0);

	// Set the icon for this dialog.
	SetIcon(m_hIcon, TRUE);			// Set big icon
	SetIcon(m_hIcon, FALSE);		// Set small icon

	g_curdb = &g_db;

	OnButton1(); // Jeff 初始化服务端,内含定时器1;
	GetFileDate(); // Jeff获取文件信息;
	//LoadDB();
	LoadHistoryDB();//Jeff加载历史数据库;

	int aaaa = 30;
	while (aaaa--)
		AddOneConn();//添加数据库连接;

	SetTimer(2, 10, NULL);
	CheckBakState();// 检查相片备份情况

	hInst = LoadLibrary("SENSAPI.DLL");   //加载动态库 ;
	if (hInst)
	{
		typedef   BOOL(WINAPI   *MYFUNC)(LPDWORD);
		MYFUNC   IsNetworkConnect = NULL;
		//取得IsNetworkAlive函数指针   
		IsNetworkConnect = (MYFUNC)GetProcAddress(hInst, "IsNetworkAlive");
		if (IsNetworkConnect)
		{
			DWORD   dwActiveWan = 1;
			if (IsNetworkConnect(&dwActiveWan))
				m_bNetWorkOK = 1;
			else
				m_bNetWorkOK = 0;
			SetTimer(5, 10000, NULL);
		}
		else
			m_bNetWorkOK = 0;
	}
	else
		m_bNetWorkOK = 0;

	return TRUE;
}

/********************************************************************/
/*																	*/
/* Function name : OnDestroy										*/
/* Description   : Handle WM_DESTROY message						*/
/*																	*/
/********************************************************************/
void CDBServerDlg::OnDestroy()
{
	OnServerStop();
	KillTimer(1);
	KillTimer(2);
	KillTimer(3);
	KillTimer(4);
	KillTimer(5);
	KillTimer(6);
	KillTimer(7);
	KillTimer(8);

	CDialog::OnDestroy();
}

/********************************************************************/
/*																	*/
/* Function name : OnServerStart									*/
/* Description   : Start Date Server -> start listening on port 21	*/
/*																	*/
/********************************************************************/
//启动数据服务器，使其在21号端口侦听
void CDBServerDlg::OnServerStart()
{
	ServerStart();
}

BOOL CDBServerDlg::ServerStart()
{
	if (theServer.Start())
	{
		m_wndStatusBar.SetPaneText(0, "数据服务已启动", TRUE);
		SetOnlineLed(TRUE);
		SetOfflineLed(FALSE);
		WriteTextLog("启动成功");
		return 1;
	}
	else
	{
		WriteTextLog("启动失败");
		CDialog::OnCancel();
		return 0;
	}
}

/********************************************************************/
/*																	*/
/* Function name : OnUpdateServerStart								*/
/* Description   : Update 'Start' status							*/
/*																	*/
/********************************************************************/
void CDBServerDlg::OnUpdateServerStart(CCmdUI* pCmdUI)
{
	pCmdUI->Enable(!theServer.IsActive());
}

/********************************************************************/
/*																	*/
/* Function name : OnServerStop										*/
/* Description   : Stop Date Server									*/
/*																	*/
/********************************************************************/
//停止服务器
void CDBServerDlg::OnServerStop()
{
	theServer.Stop();
	m_wndStatusBar.SetPaneText(0, "数据服务已停止", TRUE);
	SetOnlineLed(FALSE);
	SetOfflineLed(TRUE);
}

/********************************************************************/
/*																	*/
/* Function name : OnUpdateServerStop								*/
/* Description   : Update 'Stop' status								*/
/*																	*/
/********************************************************************/
void CDBServerDlg::OnUpdateServerStop(CCmdUI* pCmdUI)
{
	pCmdUI->Enable(theServer.IsActive());
}

/********************************************************************/
/*																	*/
/* Function name : OnServerExit										*/
/* Description   : Let's get out of here...							*/
/*																	*/
/********************************************************************/
void CDBServerDlg::OnServerExit()
{
	OnCancel();
}

/********************************************************************/
/*																	*/
/* Function name : CDBServerDlg::SetupOutlookBar					*/
/* Description   : Initialize listview, change color/iconspacing to	*/
/*				   make it look a little bit like the outlook bar.	*/
/*																	*/
/********************************************************************/
void CDBServerDlg::SetupOutlookBar()
{
	// create Imagelist
	m_ImageList.Create(32, 32, ILC_COLOR16 | ILC_MASK, 1, 4);

	HICON hIcon = ::LoadIcon(AfxGetResourceHandle(), MAKEINTRESOURCE(IDI_LOG));
	m_ImageList.Add(hIcon);
	hIcon = ::LoadIcon(AfxGetResourceHandle(), MAKEINTRESOURCE(IDI_ONLINE_USERS));
	m_ImageList.Add(hIcon);
	hIcon = ::LoadIcon(AfxGetResourceHandle(), MAKEINTRESOURCE(IDI_CONFIGURATION));
	m_ImageList.Add(hIcon);
	hIcon = ::LoadIcon(AfxGetResourceHandle(), MAKEINTRESOURCE(IDI_SECURITY));
	m_ImageList.Add(hIcon);
	hIcon = ::LoadIcon(AfxGetResourceHandle(), MAKEINTRESOURCE(IDI_STATISTICS));
	m_ImageList.Add(hIcon);

	m_OutlookBar.SetImageList(&m_ImageList, LVSIL_NORMAL);

	CRect rc;
	m_OutlookBar.GetClientRect(rc);

	// set new icon spacing
	m_OutlookBar.SetIconSpacing(rc.Width(), 64);

	// change colors
	m_OutlookBar.SetTextColor(RGB(255, 255, 255));
	m_OutlookBar.SetTextBkColor(RGB(128, 128, 128));
	m_OutlookBar.SetBkColor(RGB(128, 128, 128));

	// insert items
	m_OutlookBar.InsertColumn(0, "OutlookBar");

	m_OutlookBar.InsertItem(0, "服务器日志", 0);
	m_OutlookBar.InsertItem(1, "在线用户", 1);
	m_OutlookBar.InsertItem(2, "关于", 2);
	m_OutlookBar.InsertItem(3, "功能区", 3);
	/*	m_OutlookBar.InsertItem(4, "Security", 4);*/

	//	m_OutlookBar.SetExtendedStyle(LVS_EX_TRACKSELECT);
}


/********************************************************************/
/*																	*/
/* Function name : CDBServerDlg::MoveChilds						*/
/* Description   : Move child windows into place holder area.		*/
/*																	*/
/********************************************************************/
void CDBServerDlg::MoveChilds()
{
	// position property pages 
	CRect rcDlgs;

	// get dialog area rect
	GetDlgItem(IDC_DIALOG_AREA)->GetWindowRect(rcDlgs);

	ScreenToClient(rcDlgs);

	m_ConfigurationPage.MoveWindow(rcDlgs);
	m_TracePage.MoveWindow(rcDlgs);
	m_OnlineUsersPage.MoveWindow(rcDlgs);
	m_StatisticsPage.MoveWindow(rcDlgs);
	m_SecurityPage.MoveWindow(rcDlgs);
}

/********************************************************************/
/*																	*/
/* Function name : CDBServerDlg::ActivatePage					*/
/* Description   : Called when an icon on the outlookbar is pressed.*/
/*																	*/
/********************************************************************/
void CDBServerDlg::ActivatePage(int nIndex)
{
	switch (nIndex)
	{
	case 0:
		m_OnlineUsersPage.ShowWindow(SW_HIDE);
		m_ConfigurationPage.ShowWindow(SW_HIDE);
		m_StatisticsPage.ShowWindow(SW_HIDE);
		m_SecurityPage.ShowWindow(SW_HIDE);
		m_TracePage.ShowWindow(SW_SHOW);
		m_InfobarCtrl.SetText("服务器日志");
		break;
	case 1:
		m_TracePage.ShowWindow(SW_HIDE);
		m_ConfigurationPage.ShowWindow(SW_HIDE);
		m_StatisticsPage.ShowWindow(SW_HIDE);
		m_SecurityPage.ShowWindow(SW_HIDE);
		m_OnlineUsersPage.RefreshData();
		m_OnlineUsersPage.ShowWindow(SW_SHOW);
		m_InfobarCtrl.SetText("在线用户");
		break;
	case 2:
		m_OnlineUsersPage.ShowWindow(SW_HIDE);
		m_TracePage.ShowWindow(SW_HIDE);
		m_StatisticsPage.ShowWindow(SW_HIDE);
		m_SecurityPage.ShowWindow(SW_HIDE);
		m_ConfigurationPage.ShowWindow(SW_SHOW);
		m_InfobarCtrl.SetText("关于");
		break;
	case 4:
		m_OnlineUsersPage.ShowWindow(SW_HIDE);
		m_TracePage.ShowWindow(SW_HIDE);
		m_ConfigurationPage.ShowWindow(SW_HIDE);
		m_SecurityPage.ShowWindow(SW_HIDE);
		m_StatisticsPage.ShowWindow(SW_SHOW);
		m_InfobarCtrl.SetText("Statistics");
		break;
	case 3:
		m_OnlineUsersPage.ShowWindow(SW_HIDE);
		m_TracePage.ShowWindow(SW_HIDE);
		m_ConfigurationPage.ShowWindow(SW_HIDE);
		m_SecurityPage.ShowWindow(SW_SHOW);
		m_StatisticsPage.ShowWindow(SW_HIDE);
		m_InfobarCtrl.SetText("功能区");
		break;
	default:
		break;
	}
	MoveChilds();
}

/********************************************************************/
/*																	*/
/* Function name : CDBServerDlg::OnClickOutlookBar				*/
/* Description   : User clicked on our listview -> activate page.	*/
/*																	*/
/********************************************************************/
void CDBServerDlg::OnClickOutlookBar(NMHDR* pNMHDR, LRESULT* pResult)
{
	// get index of selected item
	int nIndex = m_OutlookBar.GetNextItem(-1, LVNI_ALL | LVNI_SELECTED);

	if (nIndex == -1)
		return;

	ActivatePage(nIndex);

	*pResult = 0;
}

/********************************************************************/
/*																	*/
/* Function name : CDBServerDlg::OnKeydownOutlookBar				*/
/* Description   : User pressed a key -> activate page.				*/
/*																	*/
/********************************************************************/
void CDBServerDlg::OnKeydownOutlookBar(NMHDR* pNMHDR, LRESULT* pResult)
{
	LV_KEYDOWN* pLVKeyDow = (LV_KEYDOWN*)pNMHDR;

	// get index of selected item
	int nIndex = m_OutlookBar.GetNextItem(-1, LVNI_ALL | LVNI_SELECTED);

	if (nIndex == -1)
		return;

	if (pLVKeyDow->wVKey == VK_DOWN)
	{
		if (m_OutlookBar.GetItemCount() - 1 > nIndex)
		{
			ActivatePage(nIndex + 1);
		}
	}
	else
		if (pLVKeyDow->wVKey == VK_UP)
		{
		if (nIndex > 0)
		{
			ActivatePage(nIndex - 1);
		}
		}
		else
			if (pLVKeyDow->wVKey == VK_NEXT)
			{
		ActivatePage(m_OutlookBar.GetItemCount() - 1);
			}
			else
				if (pLVKeyDow->wVKey == VK_PRIOR)
				{
		ActivatePage(0);
				}

	*pResult = 0;
}

/********************************************************************/
/*																	*/
/* Function name : CreateStatusbar									*/
/* Description   : This function creates a statusbar on a dialogbox.*/
/*																	*/
/********************************************************************/
BOOL CDBServerDlg::CreateStatusbar()
{
	// Create the Toolbar and attach the resource
	if (!m_wndToolBar.Create(this) || !m_wndToolBar.LoadToolBar(IDR_TOOLBAR1))
	{
		TRACE0("Failed to Create Dialog Toolbar\n");
		return FALSE;
	}

	m_wndToolBar.SetBarStyle(m_wndToolBar.GetBarStyle() | CBRS_SIZE_DYNAMIC | CBRS_TOOLTIPS | CBRS_FLYBY);

	// Make it flat.
	m_wndToolBar.ModifyStyle(0, m_wndToolBar.GetStyle() | TBSTYLE_FLAT);

	// Create status bar at the bottom of the dialog window
	if (m_wndStatusBar.Create(this))
	{
		m_wndStatusBar.SetIndicators(auIDStatusBar, sizeof(auIDStatusBar) / sizeof(UINT));

		m_wndStatusBar.SetPaneText(0, "Date Server is offline", TRUE);
		// Make a sunken or recessed border around the first pane
		m_wndStatusBar.SetPaneInfo(0, m_wndStatusBar.GetItemID(0), SBPS_STRETCH, NULL);

		SetOnlineLed(FALSE);
		SetOfflineLed(FALSE);

		m_wndStatusBar.SetPaneInfo(m_wndStatusBar.CommandToIndex(ID_INDICATOR_ONLINELED), ID_INDICATOR_ONLINELED, SBPS_NOBORDERS, 14);
		//		m_wndStatusBar.GetStatusBarCtrl().SetTipText(m_wndStatusBar.CommandToIndex(ID_INDICATOR_ONLINELED), "This status light is green when the server is online");

		m_wndStatusBar.SetPaneInfo(m_wndStatusBar.CommandToIndex(ID_INDICATOR_OFFLINELED), ID_INDICATOR_OFFLINELED, SBPS_NOBORDERS, 14);
		//		m_wndStatusBar.GetStatusBarCtrl().SetTipText(m_wndStatusBar.CommandToIndex(ID_INDICATOR_OFFLINELED), "This status light is green when the server is online");
	}

	// We need to resize the dialog to make room for control bars.
	// First, figure out how big the control bars are.
	CRect rcClientStart;
	CRect rcClientNow;
	GetClientRect(rcClientStart);
	RepositionBars(AFX_IDW_CONTROLBAR_FIRST, AFX_IDW_CONTROLBAR_LAST, 0, reposQuery, rcClientNow);

	// Now move all the controls so they are in the same relative
	// position within the remaining client area as they would be
	// with no control bars.
	CPoint ptOffset(rcClientNow.left - rcClientStart.left, rcClientNow.top - rcClientStart.top);

	CRect  rcChild;
	CWnd* pwndChild = GetWindow(GW_CHILD);
	while (pwndChild)
	{
		pwndChild->GetWindowRect(rcChild);
		ScreenToClient(rcChild);
		rcChild.OffsetRect(ptOffset);
		pwndChild->MoveWindow(rcChild, FALSE);
		pwndChild = pwndChild->GetNextWindow();
	}

	// Adjust the dialog window dimensions
	CRect rcWindow;
	GetWindowRect(rcWindow);
	rcWindow.right += rcClientStart.Width() - rcClientNow.Width();
	rcWindow.bottom += rcClientStart.Height() - rcClientNow.Height();
	MoveWindow(rcWindow, FALSE);

	// And position the control bars
	RepositionBars(AFX_IDW_CONTROLBAR_FIRST, AFX_IDW_CONTROLBAR_LAST, 0);
	return TRUE;
}

/********************************************************************/
/*																	*/
/* Function name : OnUserAccounts									*/
/* Description   : Show user accounts.								*/
/*																	*/
/********************************************************************/
void CDBServerDlg::OnUserAccounts()
{
	CUserAccountsDlg dlg;
	theServer.m_UserManager.GetUserList(dlg.m_UserArray);
	if (dlg.DoModal() == IDOK)
	{
		theServer.m_UserManager.UpdateUserList(dlg.m_UserArray);
	}
}

/********************************************************************/
/*																	*/
/* Function name : OnFTPUserConnected								*/
/* Description   : A user has connected to our server.				*/
/*																	*/
/********************************************************************/
void CDBServerDlg::OnFTPUserConnected(DWORD nThreadID, LPCTSTR lpszUser, LPCSTR lpszAddress)
{
	m_OnlineUsersPage.AddUser(nThreadID, lpszUser, lpszAddress);
}

/********************************************************************/
/*																	*/
/* Function name : OnFTPUserDisconnected							*/
/* Description   : A user has disconnected from our server.			*/
/*																	*/
/********************************************************************/
void CDBServerDlg::OnFTPUserDisconnected(DWORD nThreadID, LPCTSTR lpszUser)
{
	m_OnlineUsersPage.RemoveUser(nThreadID);
}

/********************************************************************/
/*																	*/
/* Function name : OnFTPStatusChange								*/
/* Description   : FTP Status changed.								*/
/*																	*/
/********************************************************************/
void CDBServerDlg::OnFTPStatusChange(int nType, LPCTSTR lpszText)
{
	m_TracePage.AddTraceLine(nType, lpszText);

	switch (nType)
	{
	case 3:
		theApp.m_LogFile << error_lvl << date << time << lpszText << endl;
		break;
	default:
		theApp.m_LogFile << trace_lvl << date << time << lpszText << endl;
		break;
	}
}

/********************************************************************/
/*																	*/
/* Function name : OnFTPReceivedBytesChange							*/
/* Description   : Number of received bytes has changed.			*/
/*																	*/
/********************************************************************/
void CDBServerDlg::OnFTPReceivedBytesChange(int nBytes)
{
	m_StatisticsPage.SetValue(6, FormatSize(nBytes, 0));

	CString strStatus;
	strStatus.Format("%s received", FormatSize(nBytes, 0));
	m_wndStatusBar.SetPaneText(m_wndStatusBar.CommandToIndex(ID_INDICATOR_DATA_RECEIVED), strStatus, TRUE);

	CClientDC dc(this);
	CSize size = dc.GetTextExtent(strStatus);
	m_wndStatusBar.SetPaneInfo(m_wndStatusBar.CommandToIndex(ID_INDICATOR_DATA_RECEIVED), ID_INDICATOR_DATA_RECEIVED, SBPS_NORMAL, size.cx);
}

/********************************************************************/
/*																	*/
/* Function name : OnFTPSentBytesChange								*/
/* Description   : Number of sent bytes has changed.				*/
/*																	*/
/********************************************************************/
void CDBServerDlg::OnFTPSentBytesChange(int nBytes)
{
	m_StatisticsPage.SetValue(7, FormatSize(nBytes, 0));

	CString strStatus;
	strStatus.Format("%s sent", FormatSize(nBytes, 0));
	m_wndStatusBar.SetPaneText(m_wndStatusBar.CommandToIndex(ID_INDICATOR_DATA_SEND), strStatus, TRUE);
	CClientDC dc(this);
	CSize size = dc.GetTextExtent(strStatus);
	m_wndStatusBar.SetPaneInfo(m_wndStatusBar.CommandToIndex(ID_INDICATOR_DATA_SEND), ID_INDICATOR_DATA_SEND, SBPS_NORMAL, size.cx);
}

/********************************************************************/
/*																	*/
/* Function name : OnViewTrace										*/
/* Description   : Handle menu selection.							*/
/*																	*/
/********************************************************************/
void CDBServerDlg::OnViewTrace()
{
	ActivatePage(0);
}

/********************************************************************/
/*																	*/
/* Function name : OnViewOnlineUsers								*/
/* Description   : Handle menu selection.							*/
/*																	*/
/********************************************************************/
void CDBServerDlg::OnViewOnlineUsers()
{
	ActivatePage(1);
}

/********************************************************************/
/*																	*/
/* Function name : OnViewConfiguration								*/
/* Description   : Handle menu selection.							*/
/*																	*/
/********************************************************************/
void CDBServerDlg::OnViewConfiguration()
{
	ActivatePage(2);
}

/********************************************************************/
/*																	*/
/* Function name : OnViewStatistics									*/
/* Description   : Handle menu selection.							*/
/*																	*/
/********************************************************************/
void CDBServerDlg::OnViewStatistics()
{
	ActivatePage(3);
}

/********************************************************************/
/*																	*/
/* Function name : OnViewSecurity									*/
/* Description   : Handle menu selection.							*/
/*																	*/
/********************************************************************/
void CDBServerDlg::OnViewSecurity()
{
	ActivatePage(4);
}

/********************************************************************/
/*																	*/
/* Function name : OnUpdateViewTrace								*/
/* Description   : Update menu state of Trace item.					*/
/*																	*/
/********************************************************************/
void CDBServerDlg::OnUpdateViewTrace(CCmdUI* pCmdUI)
{
	pCmdUI->SetRadio(m_TracePage.IsWindowVisible());
}

/********************************************************************/
/*																	*/
/* Function name : OnUpdateViewOnlineUsers							*/
/* Description   : Update menu state of Online Users item.			*/
/*																	*/
/********************************************************************/
void CDBServerDlg::OnUpdateViewOnlineUsers(CCmdUI* pCmdUI)
{
	pCmdUI->SetRadio(m_OnlineUsersPage.IsWindowVisible());
}

/********************************************************************/
/*																	*/
/* Function name : OnUpdateViewConfiguration						*/
/* Description   : Update menu state of Configuration item.			*/
/*																	*/
/********************************************************************/
void CDBServerDlg::OnUpdateViewConfiguration(CCmdUI* pCmdUI)
{
	pCmdUI->SetRadio(m_ConfigurationPage.IsWindowVisible());
}

/********************************************************************/
/*																	*/
/* Function name : OnUpdateViewStatistics							*/
/* Description   : Update menu state of Statistics item.			*/
/*																	*/
/********************************************************************/
void CDBServerDlg::OnUpdateViewStatistics(CCmdUI* pCmdUI)
{
	pCmdUI->SetRadio(m_StatisticsPage.IsWindowVisible());
}

/********************************************************************/
/*																	*/
/* Function name : OnUpdateViewSecurity								*/
/* Description   : Update menu state of Security item.				*/
/*																	*/
/********************************************************************/
void CDBServerDlg::OnUpdateViewSecurity(CCmdUI* pCmdUI)
{
	pCmdUI->SetRadio(m_SecurityPage.IsWindowVisible());
}

/********************************************************************/
/*																	*/
/* Function name : SetOnlineLed										*/
/* Description   : Turn online LED on/off.							*/
/*																	*/
/********************************************************************/
void CDBServerDlg::SetOnlineLed(BOOL bOnline)
{
	HICON hIcon = (HICON)::LoadImage(AfxGetInstanceHandle(),
		bOnline ? MAKEINTRESOURCE(IDI_LED_GREEN) : MAKEINTRESOURCE(IDI_LED_OFF),
		IMAGE_ICON, 16, 16, LR_SHARED);
	m_wndStatusBar.GetStatusBarCtrl().SetIcon(m_wndStatusBar.CommandToIndex(ID_INDICATOR_ONLINELED), hIcon);
	m_wndStatusBar.GetStatusBarCtrl().Invalidate();
	m_wndStatusBar.GetStatusBarCtrl().UpdateWindow();
	DestroyIcon(hIcon);
}

/********************************************************************/
/*																	*/
/* Function name : SetOfflineLed									*/
/* Description   : Turn offline LED on/off.							*/
/*																	*/
/********************************************************************/
void CDBServerDlg::SetOfflineLed(BOOL bOffline)
{
	HICON hIcon = (HICON)::LoadImage(AfxGetInstanceHandle(),
		bOffline ? MAKEINTRESOURCE(IDI_LED_RED) : MAKEINTRESOURCE(IDI_LED_OFF),
		IMAGE_ICON, 16, 16, LR_SHARED);
	m_wndStatusBar.GetStatusBarCtrl().SetIcon(m_wndStatusBar.CommandToIndex(ID_INDICATOR_OFFLINELED), hIcon);
	m_wndStatusBar.GetStatusBarCtrl().Invalidate();
	m_wndStatusBar.GetStatusBarCtrl().UpdateWindow();
	DestroyIcon(hIcon);
}

void CDBServerDlg::OnFTPStatisticChange(int nType, int nValue)
{
	m_StatisticsPage.SetValue(nType, nValue);
}

/********************************************************************/
/*																	*/
/* Function name : FormatSize										*/
/* Description   : Format size, the way explorer diplays it			*/
/*																	*/
/********************************************************************/
char* CDBServerDlg::FormatSize(DWORD dwSizeLow, DWORD dwSizeHigh)
{
	static char szBuff[100];

	unsigned __int64 nFileSize = ((unsigned __int64)(((DWORD)(dwSizeLow)) |
		((unsigned __int64)((DWORD)(dwSizeHigh))) << 32));
	unsigned __int64 kb = 0;

	if (nFileSize > 1024)
	{
		kb = nFileSize / 1024;
		if (nFileSize % 1024)
			kb++;
	}

	// make it a string
	_ui64tot(kb, szBuff, 10);

	// add thousand seperators
	int nLength = lstrlen(szBuff);
	if (nLength > 3)
	{
		LPCTSTR ptr = szBuff;
		ptr += (nLength - 1);

		char szTemp[100];

		LPTSTR ptrTemp = szTemp;
		for (int i = 0; i < nLength; i++)
		{
			if (i && ((i % 3) == 0))
			{
				if (*ptrTemp != ',')
				{
					*ptrTemp = ',';
					ptrTemp = _tcsinc(ptrTemp);
				}
			}
			*ptrTemp = *ptr;
			ptrTemp = _tcsinc(ptrTemp);
			ptr = _tcsdec(szBuff, ptr);
		}
		// terminate string
		*ptrTemp = '\0';
		// reverse string
		_tcsrev(szTemp);
		lstrcpy(szBuff, szTemp);
	}
	// add 'KB' to it
	lstrcat(szBuff, " KB");
	return szBuff;
}

/********************************************************************/
/*																	*/
/* Function name : OnAccountWizard									*/
/* Description   : Launch New Account Wizard						*/
/*																	*/
/********************************************************************/
void CDBServerDlg::OnAccountWizard()
{
	CBitmap bmpHeader, bmpWatermark;

	VERIFY(bmpHeader.LoadBitmap(IDB_BANNER));
	VERIFY(bmpWatermark.LoadBitmap(IDB_WATERMARK));

	// show windows 2000-like wizard
	CWizardSheet wizSheet("New Account Wizard", this, 0, bmpWatermark, NULL, bmpHeader);
	wizSheet.m_psh.hInstance = ::GetModuleHandle(NULL);
	if (wizSheet.DoModal() == ID_WIZFINISH)
	{
		CArray<CUser, CUser&> m_UserArray;

		theServer.m_UserManager.GetUserList(m_UserArray);

		int nIndex = -1;
		for (int i = 0; i < m_UserArray.GetSize(); i++)
		{
			// if it already exists -> update it
			if (m_UserArray[i].m_strName.CompareNoCase(wizSheet.m_Page1.m_strAccountName) == 0)
			{
				nIndex = i;
				break;
			}
		}

		// add new account ?
		if (nIndex == -1)
		{
			CUser user;
			nIndex = m_UserArray.Add(user);
		}
		m_UserArray[nIndex].m_bAccountDisabled = FALSE;
		m_UserArray[nIndex].m_strName = wizSheet.m_Page1.m_strAccountName;
		m_UserArray[nIndex].m_strPassword = wizSheet.m_Page2.m_strPassword;

		// add home directory
		CDirectory directory;

		directory.m_strDir = wizSheet.m_Page3.m_strHomeDirectory;
		directory.m_strAlias = "";
		directory.m_bIsHomeDir = TRUE;
		directory.m_bAllowCreateDirectory = wizSheet.m_Page4.m_bAllowCreateDirectory;
		directory.m_bAllowDelete = wizSheet.m_Page4.m_bAllowDelete;
		directory.m_bAllowDownload = wizSheet.m_Page4.m_bAllowDownload;
		directory.m_bAllowRename = wizSheet.m_Page4.m_bAllowRename;
		directory.m_bAllowUpload = wizSheet.m_Page4.m_bAllowUpload;
		directory.m_strAlias = "";

		m_UserArray[nIndex].m_DirectoryArray.Add(directory);

		// update 
		theServer.m_UserManager.UpdateUserList(m_UserArray);
	}
}

void CDBServerDlg::OnCancel()
{

}

void CDBServerDlg::OnOK()
{

}

void CDBServerDlg::OnButton1()
{
	// TODO: Add your control notification handler code here
	try
	{
		theServer.Initialize(this);
		if (ServerStart() == 0)
			return;

		if (g_pSkinData == NULL)
			InitLia();

		/////////////////////
		CString	logdays;
		MyLock lock("dbaccessxiao");
		CRecordset myset(&g_db);
		CString	sql = "select logdays from version";
		myset.Open(CRecordset::forwardOnly, sql);
		myset.GetFieldValue("logdays", logdays);
		myset.Close();

		int days = 180;
		if (logdays == "1个月")
			days = 31;
		else if (logdays == "2个月")
			days = 61;
		else if (logdays == "3个月")
			days = 92;
		else
			days = 183;
		CTime tm = CTime::GetCurrentTime();
		CTimeSpan dt(days, 0, 0, 0);
		tm -= dt;
		CString date = tm.Format("%Y-%m-%d");

		///////////////////
		tm = CTime::GetCurrentTime();
		CTimeSpan dt2(183, 0, 0, 0);
		tm -= dt2;
		date = tm.Format("%Y%m%d%H%M%S");
		sql = "delete from sendreg where [status]='OK' and [timestamp]<'" + date + "'";
		g_db.ExecuteSQL(sql);

		//////////////////////////////////
		sql = "select version from version";
		myset.Open(CRecordset::forwardOnly, sql);
		myset.GetFieldValue("version", sql);
		myset.Close();
		m_ConfigurationPage.m_versionno = "00" + sql;
		m_ConfigurationPage.UpdateData(0);

		/////////////////////
	}
	catch (...)
	{
		WriteTextLog("出错1");
	}
}

void CDBServerDlg::OnClose()
{
	m_TrayIcon.Create(this, WM_ICON_NOTIFY, "影楼管理系统服务器", m_hIcon, IDR_MENUtray); //构造
	ShowWindow(SW_HIDE); //隐藏窗口
}

LRESULT CDBServerDlg::OnTrayNotification(WPARAM wParam, LPARAM lParam)
{
	return m_TrayIcon.OnTrayNotification(wParam, lParam);
}

void CDBServerDlg::OnOpen()
{
	ShowWindow(SW_SHOW);
}

void CDBServerDlg::OnExit2()
{
	try
	{
		TerminateThread();
		TerminateThread2();

		m_TrayIcon.RemoveIcon();
		if (g_pSkinData)delete[]g_pSkinData; g_pSkinData = NULL;
		g_db.Close();
		for (int i = 0; i < g_dbHistoryArray.GetSize(); i++)
		{
			g_dbHistoryArray.ElementAt(i)->Close();
			delete g_dbHistoryArray.ElementAt(i);
		}
		ReleaseBranchDB();
	}
	catch (...)
	{
		WriteTextLog("出错在函数OnExit2中");
	}
	CDialog::OnCancel();
}

void CDBServerDlg::OnExit()
{
	try
	{
		TerminateThread();
		TerminateThread2();

		DWORD id = FindAppProcessID("AutoRun.exe");
		if (id != -1)
		{
			HANDLE ProcessHandle = OpenProcess(PROCESS_ALL_ACCESS, FALSE, id);
			if (ProcessHandle)TerminateProcess(ProcessHandle, 0);
		}

		m_TrayIcon.RemoveIcon();
		if (g_pSkinData)delete[]g_pSkinData; g_pSkinData = NULL;
		g_db.Close();
		for (int i = 0; i < g_dbHistoryArray.GetSize(); i++)
		{
			g_dbHistoryArray.ElementAt(i)->Close();
			delete g_dbHistoryArray.ElementAt(i);
		}
		ReleaseBranchDB();
	}
	catch (...)
	{
		WriteTextLog("出错在函数OnExit中");
	}
	CDialog::OnCancel();
}

void CDBServerDlg::OnTimer(UINT nIDEvent) //定时器;
{
	try
	{
		if (nIDEvent == 1)
		{
			KillTimer(nIDEvent);
			LoadThumbImages();
		}
		else if (nIDEvent == 2)
		{
			KillTimer(nIDEvent);
			OnClose();// 托盘显示;

			try
			{
				CheckHistoryData();  // Jeff:back history db data;
				LoadBranchInfo2();
			}
			catch (...)
			{
			}

			SetTimer(1, 2 * 60 * 1000, NULL);
			SetTimer(4, 1000 * 60 * 2, NULL);
			SetTimer(7, 1000 * 60 * 60 * 1, NULL);
			SetTimer(8, 3000, NULL);
			SetTimer(9, 10000, NULL);
		}
		else if (nIDEvent == 3)
		{
			g_pMainWnd->KillTimer(3);

			DWORD id = FindAppProcessID("MsgServer.exe");
			if (id != -1)
			{
				HANDLE ProcessHandle = OpenProcess(PROCESS_ALL_ACCESS, FALSE, id);
				if (ProcessHandle)
					TerminateProcess(ProcessHandle, 0);
			}
			CString autorunpath = g_mainpath + "\\MsgServer.exe";
			ShellExecute(NULL, _T("open"), autorunpath, NULL, NULL, SW_HIDE);

		}
		else if (nIDEvent == 4) //Jeff.这里也有自动启动MsgServer.exe服务处理,而且是2分钟/次的频率；
		{
			UpdateDate();
			CheckMemberMsg();
			BakPhoto();
		}
		else if (nIDEvent == 5)
		{
			typedef   BOOL(WINAPI   *MYFUNC)(LPDWORD);
			MYFUNC   IsNetworkConnect = NULL;
			//取得IsNetworkAlive函数指针   
			IsNetworkConnect = (MYFUNC)GetProcAddress(hInst, "IsNetworkAlive");
			if (IsNetworkConnect)
			{
				DWORD   dwActiveWan = 1;
				BOOL state;
				if (IsNetworkConnect(&dwActiveWan))
					state = 1;
				else
					state = 0;
				if (m_bNetWorkOK != state)
				{
					KillTimer(nIDEvent);
					WriteTextLog("网络断开");
					OnExit2();
				}
			}
		}
		else if (nIDEvent == 6)
		{
			KillTimer(nIDEvent);
			ShutDown();
		}
		else if (nIDEvent == 7)
		{
			CheckBakState();
			GenUPhoneData();
		}
		else if (nIDEvent == 8)
		{
			CheckConnCount();
		}
#if 0 // Jeff.开启定时关机功能
		else if ( nIDEvent == 11)
		{
			g_curdb=&g_db;
			CString	m_bak6;
			CString strShutDownTime;

			CRecordset myset(g_curdb);
			CString	sql="select * from [version]";
			myset.Open(CRecordset::forwardOnly, sql);
			myset.GetFiledVale("ShutDownTime",strShutDownTime);
			myset.Close();
			CTime tShutDownTime( 
				CTime::GetCurrentTime().GetYear(),
				CTime::GetCurrentTime().GetMonth(),
				CTime::GetCurrentTime().GetDay(),
				atoi(strShutDownTime.Left(2)), 
				atoi(strShutDownTime.Right(2)),
				0);

			if (CTime::GetCurrentTime() >= tShutDownTime)
			{
				MyExitWindows();
			}
		}
#endif
	}
	catch (...)
	{
		WriteTextLog("出错在函数Timer中");
	}
}

void LoadImageFromBuf(Image **img, BYTE *pData, DWORD leng)//g_bakserver1
{
	try
	{
		if (pData == NULL)return;
		if (*img)delete *img;
		*img = NULL;
		// Allocate global memory on which to create stream
		HGLOBAL m_hMem = GlobalAlloc(GMEM_MOVEABLE, leng);
		if (m_hMem == NULL)return;
		BYTE* pmem = (BYTE*)GlobalLock(m_hMem);
		memcpy(pmem, pData, leng);
		IStream* pstm;
		CreateStreamOnHGlobal(m_hMem, TRUE, &pstm);
		// load from stream
		*img = Gdiplus::Image::FromStream(pstm);
		// free/release stuff
		GlobalUnlock(m_hMem);
		pstm->Release();
	}
	catch (...)
	{
	}
}

void LoadImageFromBuf(Image **img, CString path)
{
	try
	{
		CFile fp;
		if (fp.Open(path, CFile::modeRead))
		{
			DWORD leng = fp.GetLength();
			BYTE *pData = new BYTE[leng];
			fp.Read(pData, leng);
			fp.Close();
			LoadImageFromBuf(img, pData, leng);
			delete[]pData;
		}
	}
	catch (...)
	{
	}
}

void LoadImageFromRes(Image **img, LPCTSTR lpszResourceName, LPCTSTR ResourceType)
{
	try
	{
		HGLOBAL  hGlobal = NULL;
		HRSRC  hSource = NULL;
		LPVOID  lpVoid = NULL;
		int   nSize = 0;
		BOOL  bResult = FALSE;
		hSource = FindResource(NULL, lpszResourceName, ResourceType);
		if (hSource == NULL)return;
		hGlobal = LoadResource(NULL, hSource);
		if (hGlobal == NULL)return;
		lpVoid = LockResource(hGlobal);
		if (lpVoid == NULL)return;

		nSize = (UINT)SizeofResource(NULL, hSource);
		LoadImageFromBuf(img, (BYTE*)hGlobal, nSize);
		UnlockResource(hGlobal); // 16Bit Windows Needs This
		FreeResource(hGlobal); // 16Bit Windows Needs This (32Bit - Automatic Release)
	}
	catch (...)
	{
	}
}

// ---------------------------------------------------------------------------------------------------------------------------------------------------------------
// TimeAt: 2014-09-15 AM;
// Remark: Jeff;
// 函数：GenSPhoto
// 描述：对指定文件夹内的相片生成S或M缩略图;
// 参数：
//		dir:		需要生成缩略图的文件目录;
//		bMPhoto:	是否生成M缩略图;	
// 其它：
//		在生成缩略图前,记录jpg文件总数nOldCount，每生成一个缩略图nOldCount++;
//		最后全部图生成完毕,获取新的jpg文件总数nNewCount,if(nOldCount ==  nNewCount)则表示所有相片已生成缩略图完毕,生成ok文件表示成功生成缩略图;
//
// 函数调用全局参数：
//			g_bSteal：意义未明！
// 
// 注意：该函数非线程安全！
// 非线程安全：
//			 获取文件总数nOldCount结束后，若有新文件在本函数以外其他函数或进程、线程被添加，则生成缩略图完成后再次获取文件总数nNewCount就不会与nOldCount++后的结果相等;
//			 而实际上本次缩略图已生成完毕。	
// ---------------------------------------------------------------------------------------------------------------------------------------------------------------
void GenSPhoto(CString dir, BOOL bMPhoto)	// 参数：bMPhoto：是否生成M缩略图;
{
	// 如果是公告附件目录退出;
	if (dir.Find("公告附件") != -1)return;

	// 如果不是客户原片或修好的片目录,设置bMPhoto参数为0,不生成M缩略图;
	if (dir.Find("客户原片(管理软件)$") != -1 || dir.Find("修好的片(管理软件)$") != -1)
	{
	}
	else
		bMPhoto = 0;

	// 对指定文件目录dir进行指定后缀jpg文件遍历;
	using namespace helper_coffs;
	ffsco o;
	o.dirs(1);
	o.find(LPCSTR(dir), LPCSTR("*.jpg"));
	ffsco::typeT coo;
	ffsco::typeT::iterator it;
	coo = o.co_file();
	int oldsize = coo.size();
	CString path, temp, spath, mpath;
	for (it = coo.begin(); coo.end() != it; it++)
	{
		try
		{
			if (g_pMainWnd->m_bTerminate)return;

			// 遍历到的jpg文件如果是缩略图则不处理,继续遍历;
			path = (*it).c_str();
			spath = path.Left(path.ReverseFind('\\') + 1);
			mpath = spath;
			spath += "s";
			mpath += "m";
			temp = path.Right(path.GetLength() - path.ReverseFind('\\') - 1);
			if (temp.GetAt(0) == 's')continue;
			if (temp.GetAt(0) == 'm')continue;
			spath += path.Right(path.GetLength() - path.ReverseFind('\\') - 1);
			mpath += path.Right(path.GetLength() - path.ReverseFind('\\') - 1);
			if (g_bSteal)
			{
				Image *pImg = NULL;
				::LoadImageFromBuf(&pImg, path);
				if (pImg == NULL)continue;
				if (pImg->GetWidth() == 0)continue;	// Jeff.continue前未释放pImg;
				delete pImg;

				EncryptFile3(path);
				if (path.Find("客户原片") != -1)
				{
					int pos = path.Find("管理软件)$");
					if (pos != -1)
					{
						path = g_bakserver1 + path.Right(path.GetLength() - pos - 10);
						EncryptFile3(path);
					}
				}
				else if (path.Find("修好的片") != -1)
				{
					int pos = path.Find("管理软件)$");
					if (pos != -1)
					{
						path = g_bakserver2 + path.Right(path.GetLength() - pos - 10);
						EncryptFile3(path);
					}
				}
				else if (path.Find("精修好的片") != -1)
				{
					int pos = path.Find("管理软件)$");
					if (pos != -1)
					{
						path = g_bakserver3 + path.Right(path.GetLength() - pos - 10);
						EncryptFile3(path);
					}
				}
				else if (path.Find("设计好的片") != -1)
				{
					int pos = path.Find("管理软件)$");
					if (pos != -1)
					{
						path = g_bakserver4 + path.Right(path.GetLength() - pos - 10);
						EncryptFile3(path);
					}
				}
				oldsize++;
			}
			else if (!CheckFileExist(spath))
			{
				Image *pImg = NULL;
				::LoadImageFromBuf(&pImg, path);
				if (pImg == NULL)continue;
				if (pImg->GetWidth() == 0)continue;	// Jeff.返回前未释放pImg;

				CRect rc(0, 0, 100, 90);
				RectFitDes(pImg->GetWidth(), pImg->GetHeight(), rc);
				Image *simg = pImg->GetThumbnailImage(rc.Width(), rc.Height(), NULL, NULL);
				if (simg == NULL)continue;// Jeff.返回前未释放pImg;

				Image *simg2 = NULL;
				if (bMPhoto)
				{
					CRect rc2(0, 0, 2000, 2000);
					RectFitDes(pImg->GetWidth(), pImg->GetHeight(), rc2);
					simg2 = pImg->GetThumbnailImage(rc2.Width(), rc2.Height(), NULL, NULL);
					if (simg2 == NULL)continue;// Jeff.返回前未释放pImg;
				}

				Graphics graphic(simg);//防止GetThumbnailImage影响质量
				graphic.Clear(Color(255, 255, 255, 255));
				graphic.DrawImage(pImg, 0, 0, simg->GetWidth(), simg->GetHeight());

				if (bMPhoto)
				{
					Graphics graphic2(simg2);//防止GetThumbnailImage影响质量
					graphic2.Clear(Color(255, 255, 255, 255));
					graphic2.DrawImage(pImg, 0, 0, simg2->GetWidth(), simg2->GetHeight());
				}
				///////////////////////////////
				UINT totalBufferSize;
				UINT numProperties;
				pImg->GetPropertySize(&totalBufferSize, &numProperties);
				// Allocate the buffer that will receive the property items.
				PropertyItem* pAllItems = (PropertyItem*)malloc(totalBufferSize);
				// Fill the buffer.
				pImg->GetAllPropertyItems(totalBufferSize, numProperties, pAllItems);
				// Print the id data member of each property item.
				for (UINT j = 0; j < numProperties; ++j)
				{
					if (PropertyTagOrientation == pAllItems[j].id)
					{
						short* ptrLong = (short*)(pAllItems[j].value);
						int ret = (int)*ptrLong;
						//	CString str;
						//	str.Format ("%d", ret);
						//	AfxMessageBox(str);
						if (ret == 8)
						{
							if (simg2)simg2->RotateFlip(Rotate270FlipNone);
							simg->RotateFlip(Rotate270FlipNone);
						}
						else if (ret == 6)
						{
							if (simg2)simg2->RotateFlip(Rotate90FlipNone);
							simg->RotateFlip(Rotate90FlipNone);
						}
						break;
					}
				}
				free(pAllItems);
				///////////////////////////////
				::SaveImageToFile(simg, spath); oldsize++;
				delete simg;
				delete pImg;
				if (bMPhoto)
				{
					::SaveImageToFile2(simg2, mpath, 100); oldsize++;
					delete simg2;
				}
			}
		}
		catch (...)
		{
			WriteTextLog("出错在函数GenSPhoto中");
		}
	}

	try
	{
		ffsco o;
		o.dirs(1);
		o.find(LPCSTR(dir), LPCSTR("*.jpg"));
		ffsco::typeT coo;
		ffsco::typeT::iterator it;
		coo = o.co_file();
		int newsize = coo.size();
		if (oldsize == newsize)
		{
			path = dir + "\\ok";
			CFile fp;
			fp.Open(path, CFile::modeCreate | CFile::modeWrite);
			fp.Close();
		}
	}
	catch (...)
	{
		WriteTextLog("出错在函数GenSPhoto2中");
	}
}

//--------------------------------------------------------------------------------
// Remark by Jeff 2014.10.22
// 函数：
// 描述：
//		dir:客户原片、修好的片、精修片、设计片目录的订单文件夹路径;
//		desdir:dir对就的备份目录;
// 参数：
// 返回：
//
// 调用关系：
// 1.
// 2.
// 3.
//--------------------------------------------------------------------------------
BOOL BakAllPhoto(CString dir, CString desdir, CString g_path1, CString g_path2, CString g_path3, CString g_path4)
{
	try
	{
		CString childdir;
		CString srcdir = dir;
		srcdir.MakeLower();
		if (srcdir.Find(g_path1) != -1)
			childdir = srcdir.Right(srcdir.GetLength() - g_path1.GetLength());
		else if (srcdir.Find(g_path2) != -1)
			childdir = srcdir.Right(srcdir.GetLength() - g_path2.GetLength());
		else if (srcdir.Find(g_path3) != -1)
			childdir = srcdir.Right(srcdir.GetLength() - g_path3.GetLength());
		else if (srcdir.Find(g_path4) != -1)
			childdir = srcdir.Right(srcdir.GetLength() - g_path4.GetLength());
		else
		{
			WriteTextLog("备份出错-目录未找到!");
			return 0;
		}
		/*	srcdir.TrimLeft ("\\");
		srcdir.Delete (srcdir.Find ('\\'));

		if(srcdir.Find ('\\')==-1)
		childdir="";
		else
		childdir=srcdir.Right (srcdir.GetLength ()-srcdir.Find ('\\'));*/
		childdir.TrimLeft("\\");
		childdir.TrimRight("\\");

		while (childdir.Find('\\') != -1)
		{
			desdir += "\\";
			desdir += childdir.Left(childdir.Find('\\'));
			//if(CheckFolderFileExist (desdir)==0)
			{
				//	if(!
				CreateDirectory(desdir, NULL);//)return;
			}
			childdir = childdir.Right(childdir.GetLength() - childdir.Find('\\') - 1);
		}
		desdir += "\\";
		desdir += childdir;
		//if(CheckFolderFileExist (desdir)==0)
		{
			//	if(!
			CreateDirectory(desdir, NULL);//)return;
		}
		desdir += "\\";

		// Jeff.进行相片复制操作;
		using namespace helper_coffs;
		ffsco o;
		o.dirs(0);
		o.find(LPCSTR(dir), LPCSTR("*.*"));
		ffsco::typeT coo;
		ffsco::typeT::iterator it;
		coo = o.co_file();
		CString path, temp, despath;
		for (it = coo.begin(); coo.end() != it; it++)
		{
			try
			{
				if (g_pMainWnd->m_bTerminate2)return 0;
				path = (*it).c_str();
				temp = path.Right(path.GetLength() - path.ReverseFind('\\') - 1);
				if (temp.GetAt(0) == 's')continue;
				despath = desdir + path.Right(path.GetLength() - path.ReverseFind('\\') - 1);
				if (CheckFileExist(despath))
				{
					/*	HANDLE hFile=CreateFile(path,GENERIC_READ,0,NULL,OPEN_EXISTING,0,NULL);
					HANDLE hFile2=CreateFile(despath,GENERIC_READ,0,NULL,OPEN_EXISTING,0,NULL);
					FILETIME ftWrite,ftWrite2;
					if(GetFileTime(hFile, NULL, NULL, &ftWrite)==0)
					{
					CloseHandle(hFile);
					CloseHandle(hFile2);
					return;
					}
					if(GetFileTime(hFile2, NULL, NULL, &ftWrite2)==0)
					{
					CloseHandle(hFile);
					CloseHandle(hFile2);
					return;
					}
					CloseHandle(hFile);
					CloseHandle(hFile2);
					if(ftWrite.dwHighDateTime!=ftWrite2.dwHighDateTime || ftWrite.dwLowDateTime!=ftWrite2.dwLowDateTime)
					{*/
					if (::CopyFile(path, despath, 0))
						g_bakphoto = "照片备份成功";
					//	}
				}
				else
				{
					if (::CopyFile(path, despath, 0))
						g_bakphoto = "照片备份成功";
				}
			}
			catch (...)
			{
			}
		}
	}
	catch (...)
	{
		WriteTextLog("出错在函数BakAllPhoto中");
		return 0;
	}
	return 1;
}

//--------------------------------------------------------------------------------
// Remark by Jeff 2014.10.22
// 函数：
// 描述：
// 参数：
// 返回：
//
// 调用关系：
// 1.
// 2.
// 3.
//--------------------------------------------------------------------------------
unsigned __stdcall LoadThumbNail(LPVOID lpParam)
{
	BOOL bMphoto = 0;
	if (g_bSteal == 0)
	{
		CRecordset myset(&g_db);
		CString	sql = "select * from version";
		myset.Open(CRecordset::forwardOnly, sql);
		myset.GetFieldValue("setcheck15", sql);
		myset.Close();
		bMphoto = atoi(sql);
	}

	CDBServerDlg *pDlg = (CDBServerDlg*)lpParam;
	try
	{
		CString g_path1;
		CString g_path2;
		CString g_path3;
		CString g_path4;
		char server[50];
		DWORD leng = 50;
		::GetComputerName(server, &leng);

		g_path1 = g_path2 = g_path3 = g_path4 = server;

		if (g_path2.IsEmpty())return 0;
		g_path1 = "\\\\" + g_path1 + "\\客户原片(管理软件)$";
		g_path2 = "\\\\" + g_path2 + "\\修好的片(管理软件)$";
		g_path3 = "\\\\" + g_path3 + "\\设计好的片(管理软件)$";
		g_path4 = "\\\\" + g_path4 + "\\精修好的片(管理软件)$";

		GetPathFromNetShareName("客户原片(管理软件)$", g_path1);
		GetPathFromNetShareName("修好的片(管理软件)$", g_path2);
		GetPathFromNetShareName("设计好的片(管理软件)$", g_path3);
		GetPathFromNetShareName("精修好的片(管理软件)$", g_path4);


		CStringArray dirarray;

		CString path, path2;
		using namespace helper_coffs;
		CString patharray[4] = { g_path1, g_path2, g_path3, g_path4 };

		// Remark:Jeff.
		// 遍历原片、修好片、设计片、精修片目录,查看是否有ok或ok.dat文件存在;
		// 说明：ok文件在客户端再次导入相片时会被删除;
		// 只有服务端生成小图后，ok才被重新生成;
		int i = 0;
		for ( i = 0; i < 4; i++)
		{
			if (pDlg->m_bTerminate)
			{
				break;
			}

			ffsco o;
			o.dirs(1);
			o.find(LPCSTR(patharray[i]), LPCSTR("*.*"));
			ffsco::typeT coo;
			ffsco::typeT::iterator it;
			coo = o.co_dir();
			it = coo.begin();
			it++;
			for (; coo.end() != it; it++)
			{
				if (pDlg->m_bTerminate)
				{
					break;
				}
				path = (*it).c_str();
				path.TrimRight("\\");
				path2 = path;
				path2 += "\\ok2.dat";
				path += "\\ok";
				if (CheckFileExist(path2) && path2.Find(".ly.com") == -1)
				{
					::DeleteFile(path);		// 删除ok文件;
					::DeleteFile(path2);	// 删除ok.dat文件;
				}

				// g_bCheckAll g_bSteal的意义???
				if (g_bCheckAll || g_bSteal)
				{
					if (FindArray(&dirarray, (*it).c_str()) == -1)
						dirarray.Add((*it).c_str());
				}
				else if (CheckFileExist(path) == 0)
				{
					if (FindArray(&dirarray, (*it).c_str()) == -1)
						dirarray.Add((*it).c_str());
				}
			}
		}

		for (i = 0; i < dirarray.GetSize(); i++)
		{
			if (pDlg->m_bTerminate)
			{
				break;
			}
			GenSPhoto(dirarray.ElementAt(i), bMphoto);
		}
	}
	catch (...)
	{
		WriteTextLog("出错在函数GenThumb中");
	}
	pDlg->m_bRunning = false;
	pDlg->m_bTerminate = false;
	pDlg->SetTimer(1, 60 * 1000, NULL);

	_endthreadex(0);
	return 0;
}

//--------------------------------------------------------------------------------
// Remark by Jeff 2014.10.22
// 函数：LoadThumbNail2
// 描述：线程函数，备份相片.
// 参数：
// 返回：
//
// 调用关系：
// 1.
// 2.
// 3.
//--------------------------------------------------------------------------------
unsigned __stdcall LoadThumbNail2(LPVOID lpParam)//备份
{
	CDBServerDlg *pDlg = (CDBServerDlg*)lpParam;
	int step = 1;
	BOOL bError = 0;
	try
	{
		g_tisks = ::GetTickCount();
		WriteTextLog("开始备份照片");
		CDatabase *g_curdb = &g_db;
		//	CRstPath rsSt;
		CString g_path1;
		CString g_path2;
		CString g_path3;
		CString g_path4;


		g_path1 = g_path2 = g_path3 = g_path4 = g_localname;
		CString localname = g_localname;

		g_path1 = "\\\\" + g_path1 + "\\客户原片(管理软件)$";
		g_path2 = "\\\\" + g_path2 + "\\修好的片(管理软件)$";
		g_path3 = "\\\\" + g_path3 + "\\设计好的片(管理软件)$";
		g_path4 = "\\\\" + g_path4 + "\\精修好的片(管理软件)$";

		GetPathFromNetShareName("客户原片(管理软件)$", g_path1);
		GetPathFromNetShareName("修好的片(管理软件)$", g_path2);
		GetPathFromNetShareName("设计好的片(管理软件)$", g_path3);
		GetPathFromNetShareName("精修好的片(管理软件)$", g_path4);
		step = 2;
		g_path1.MakeLower();
		g_path2.MakeLower();
		g_path3.MakeLower();
		g_path4.MakeLower();

		CString	m_bak1, m_bak2, m_bak3, m_bak4;							// 是否备份(指定的备份目录是否需要备份);
		CString	m_bak11, m_bak22, m_bak33, m_bak44;						// 是否备份(集团版的分店备份目录是否需要备份??);
		CString	m_bakserver1, m_bakserver2, m_bakserver3, m_bakserver4;	// 相片备份目录 ;
		{
			MyLock lock("dbaccessxiao");
			CRstversion rsSt;
			rsSt.m_pDatabase = g_curdb;
			rsSt.Open();
			if (!rsSt.IsEOF())
			{
				m_bak1 = rsSt.m_bak1;
				m_bak2 = rsSt.m_bak2;
				m_bak3 = rsSt.m_bak3;
				m_bak4 = rsSt.m_bak4;
				m_bakserver1 = rsSt.m_bakserver1;
				m_bakserver2 = rsSt.m_bakserver2;
				m_bakserver3 = rsSt.m_bakserver3;
				m_bakserver4 = rsSt.m_bakserver4;
				m_bak11 = rsSt.bak11;
				m_bak22 = rsSt.bak22;
				m_bak33 = rsSt.bak33;
				m_bak44 = rsSt.bak44;
			}
			rsSt.Close();
			step = 3;
		}
#ifdef CHILD_VERSION
		if (m_bakserver1.Find(":") == -1 && m_bakserver1 != "")
			m_bakserver1 = "\\\\" + m_bakserver1 + "\\客户原片备份(儿童管理软件)$";
		if (1)//(localname.CompareNoCase (m_bakserver1)==0 || CompareIP(localname, m_bakserver1)==0) && CheckFolderFileExist("\\\\"+m_bakserver1+"\\客户原片备份(儿童管理软件)$"))
			GetPathFromNetShareName("客户原片备份(儿童管理软件)$", m_bakserver1);

		if (m_bakserver2.Find(":") == -1 && m_bakserver2 != "")
			m_bakserver2 = "\\\\" + m_bakserver2 + "\\修好的片备份(儿童管理软件)$";
		if (1)//((localname.CompareNoCase (m_bakserver2)==0 || CompareIP(localname, m_bakserver2)==0)  && CheckFolderFileExist("\\\\"+m_bakserver1+"\\修好的片备份(儿童管理软件)$"))
			GetPathFromNetShareName("修好的片备份(儿童管理软件)$", m_bakserver2);

		if (m_bakserver3.Find(":") == -1 && m_bakserver3 != "")
			m_bakserver3 = "\\\\" + m_bakserver3 + "\\精修好的片备份(儿童管理软件)$";
		if (1)//((localname.CompareNoCase (m_bakserver3)==0 || CompareIP(localname, m_bakserver3)==0)  && CheckFolderFileExist("\\\\"+m_bakserver1+"\\精修好的片备份(儿童管理软件)$"))
			GetPathFromNetShareName("精修好的片备份(儿童管理软件)$", m_bakserver3);

		if (m_bakserver4.Find(":") == -1 && m_bakserver4 != "")
			m_bakserver4 = "\\\\" + m_bakserver4 + "\\设计好的片备份(儿童管理软件)$";
		if (1)//((localname.CompareNoCase (m_bakserver4)==0 || CompareIP(localname, m_bakserver4)==0)  && CheckFolderFileExist("\\\\"+m_bakserver1+"\\设计好的片备份(儿童管理软件)$"))
			GetPathFromNetShareName("设计好的片备份(儿童管理软件)$", m_bakserver4);
#else
		if (m_bakserver1.Find(":") == -1 && m_bakserver1 != "")
			m_bakserver1 = "\\\\" + m_bakserver1 + "\\客户原片备份(管理软件)$";
		if (1)//((localname.CompareNoCase (m_bakserver1)==0 || CompareIP(localname, m_bakserver1)==0)  && CheckFolderFileExist("\\\\"+m_bakserver1+"\\客户原片备份(管理软件)$"))
			GetPathFromNetShareName("客户原片备份(管理软件)$", m_bakserver1);
		if (m_bakserver2.Find(":") == -1 && m_bakserver2 != "")
			m_bakserver2 = "\\\\" + m_bakserver2 + "\\修好的片备份(管理软件)$";
		if (1)//((localname.CompareNoCase (m_bakserver2)==0 || CompareIP(localname, m_bakserver2)==0)  && CheckFolderFileExist("\\\\"+m_bakserver1+"\\修好的片备份(管理软件)$"))
			GetPathFromNetShareName("修好的片备份(管理软件)$", m_bakserver2);
		if (m_bakserver3.Find(":") == -1 && m_bakserver3 != "")
			m_bakserver3 = "\\\\" + m_bakserver3 + "\\精修好的片备份(管理软件)$";
		if (1)//((localname.CompareNoCase (m_bakserver3)==0 || CompareIP(localname, m_bakserver3)==0)  && CheckFolderFileExist("\\\\"+m_bakserver1+"\\精修好的片备份(管理软件)$"))
			GetPathFromNetShareName("精修好的片备份(管理软件)$", m_bakserver3);
		if (m_bakserver4.Find(":") == -1 && m_bakserver4 != "")
			m_bakserver4 = "\\\\" + m_bakserver4 + "\\设计好的片备份(管理软件)$";
		if (1)//((localname.CompareNoCase (m_bakserver4)==0 || CompareIP(localname, m_bakserver4)==0)  && CheckFolderFileExist("\\\\"+m_bakserver1+"\\设计好的片备份(管理软件)$"))
			GetPathFromNetShareName("设计好的片备份(管理软件)$", m_bakserver4);
#endif
		WriteTextLog(m_bakserver1);	WriteTextLog(m_bakserver2);	WriteTextLog(m_bakserver3);	WriteTextLog(m_bakserver4);

		step = 4;
		CStringArray dirarray;
		CString str, path;
		using namespace helper_coffs;
		BOOL bcheck1 = atoi(m_bak1);
		BOOL bcheck2 = atoi(m_bak2);
		BOOL bcheck3 = atoi(m_bak3);
		BOOL bcheck4 = atoi(m_bak4);
		BOOL bcheck11 = atoi(m_bak11);
		BOOL bcheck22 = atoi(m_bak22);
		BOOL bcheck33 = atoi(m_bak33);
		BOOL bcheck44 = atoi(m_bak44);

		// 下列4变量应该使用结构体保存;
		CString patharray[4] = { g_path1, g_path2, g_path4, g_path3 };
		BOOL bcheck[4] = { bcheck1, bcheck2, bcheck3, bcheck4 };

		// 集团版;
		BOOL bcheckbranch[4] = { bcheck11, bcheck22, bcheck33, bcheck44 };

		CString patharray2[4] = { m_bakserver1, m_bakserver2, m_bakserver3, m_bakserver4 };
		CArray<int, int>posarray;
		int i = 0;
		for ( i = 0; i < 4; i++)
		{
			if (pDlg->m_bTerminate2)
			{
				break;
			}
			//	if(!CheckFolderFileExist (patharray[i]))continue;
			//	if(!CheckFolderFileExist (patharray2[i]))continue;	
			if (bcheck[i] == 0)continue;			// Jeff,跳过没有设置备份要求的相片;
			if (patharray2[i] == "")continue;		// Jeff.跳过没有备份目录的备份;
			if (!::CheckFolderFileExist(patharray2[i]))continue;	// Jeff.跳过备份目录不对的备份;
			if (!::CheckFolderFileExist(patharray[i]))continue;		// Jeff.跳过源目录不对的备份;

			// 获取订单文件夹路径全名;
			ffsco o;
			o.dirs(1);
			o.find(LPCSTR(patharray[i]), LPCSTR("*.*"));
			ffsco::typeT coo;
			ffsco::typeT::iterator it;
			coo = o.co_dir();
			it = coo.begin();
			it++;
			for (; coo.end() != it; it++)
			{
				if (pDlg->m_bTerminate2)
				{
					break;
				}
				str = (*it).c_str();
				if (str.Find(".ly.com") != -1 && bcheckbranch[i] == 0)continue;
				if (FindArray(&dirarray, str) == -1)
				{
					dirarray.Add(str);
					posarray.Add(i);
				}
			}
		}
		step = 5;

		// Jeff.对每个订单文件夹进行相片复制操作;
		bError = 0;
		for (i = 0; i<dirarray.GetSize(); i++)
		{
			if (pDlg->m_bTerminate2)break;
			CTime tm = CTime::GetCurrentTime();
			tm -= CTimeSpan(10, 0, 0, 0);
			CString date = tm.Format("%Y%m%d");
			DWORD dirdate = GetLastDirTime(dirarray.ElementAt(i));
			if (pDlg->m_bTerminate2)break;
			CString ss;
			if (dirdate>atol(date))
			{
				//	ss.Format ("%d>%d", dirdate, atol(date));
				//	WriteTextLog(ss);
				//	WriteTextLog(dirarray.ElementAt (i));
				step = 6;
				if (0 == BakAllPhoto(dirarray.ElementAt(i), patharray2[posarray.ElementAt(i)], g_path1, g_path2, g_path3, g_path4))
					bError = 1;

				CString path = dirarray.ElementAt(i);
				path.TrimRight("\\"); path += "\\";
				path += "modifytime";
				CStdioFile fp;

				if (!::PathFileExists(path))
				{
					fp.Open(path, CFile::modeCreate | CFile::modeWrite);
					fp.WriteString(CTime::GetCurrentTime().Format("%Y-%m-%d"));
					fp.Close();
				}
			}
			else
			{
				step = 7;
				CString path = dirarray.ElementAt(i);
				path.TrimRight("\\"); path += "\\";
				path += "modifytime";
				CStdioFile fp;
				if (!::PathFileExists(path))
				{
					step = 8;
					//		CString ss;
					//	ss.Format ("出错在函数备份照片中-step:%d,文件:%s", step, path);
					//	WriteTextLog(ss);
					fp.Open(path, CFile::modeCreate | CFile::modeWrite);
					fp.WriteString(CTime::GetCurrentTime().Format("%Y-%m-%d"));
					fp.Close();
				}
			}
		}
		if (bError)
			g_bakphoto = "照片备份失败";
		else
			g_bakphoto = "照片备份成功";
		step = 9;
	}
	catch (CException *e)
	{
		TCHAR szError[1024] = { 0 };
		e->GetErrorMessage(szError, 1024);
		WriteTextLog(CString(szError));
		e->Delete();
		if (step != 8)
		{
			CString ss;
			ss.Format("出错在函数备份照片中-step:%d", step);
			WriteTextLog(ss);
			g_bakphoto = "照片备份出错";
		}
		else
		{
			if (bError)
				g_bakphoto = "照片备份失败";
			else
				g_bakphoto = "照片备份成功";
		}
	}

	pDlg->SetTimer(6, 3000, NULL);
	pDlg->m_bRunning2 = false;
	pDlg->m_bTerminate2 = false;
	_endthreadex(0);
	return 0;
}

void CDBServerDlg::LoadThumbImages()
{
	if (m_bRunning)return;
	TerminateThread();
	m_bRunning = true;
	m_hThread = (HANDLE)_beginthreadex(NULL, 0, LoadThumbNail, (LPVOID)this, 0/* CREATE_SUSPENDED*/, &m_dwThreadID);
}

//--------------------------------------------------------------
// Remark by Jeff 2014.10.22
// 函数：LoadThumbImages2
// 描述：
// 参数：
// 返回：
//
// 调用关系：
// 1.LoadThumbImages2() 只由 BakPhoto() 调用;
// 2.BakPhoto（）由CDBServerDlg::SetTimer(4) 调用,调用频率2分钟，周期数直到程序结束。
// 3.CDBServerDlg::SetTimer(4) 由 CDBServerDlg::SetTimer(2) 调用,调用频率10毫秒，只有一个周期。
// 4.CDBServerDlg::SetTimer(2) 由 CDBServerDlg::OnInitDialog() 调用.
//--------------------------------------------------------------
void CDBServerDlg::LoadThumbImages2()
{
	if (m_bRunning2)return;
	TerminateThread2();
	m_bRunning2 = true;
	m_hThread2 = (HANDLE)_beginthreadex(NULL, 0, LoadThumbNail2, (LPVOID)this, 0/* CREATE_SUSPENDED*/, &m_dwThreadID2);
}

BOOL CDBServerDlg::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 (...)
	{
		WriteTextLog("出错在函数TerminateThread中");
	}
}
BOOL CDBServerDlg::TerminateThread2()
{
	try
	{
		if (!m_bRunning2)
			return TRUE;

		m_bTerminate2 = true;

		for (;;)
		{
			if (::WaitForSingleObject(m_hThread2, 0) == WAIT_OBJECT_0)
				break;
			MSG msg;
			while (::PeekMessage(&msg, NULL, 0, 0, PM_NOREMOVE))
			{
				if (!AfxGetApp()->PumpMessage())
					break;
			}
		}
		::CloseHandle(m_hThread2);
		m_bRunning2 = false;
		return TRUE;
	}
	catch (...)
	{
		WriteTextLog("出错在函数TerminateThread2中");
	}
}

void CDBServerDlg::InitLia()
{
	if (g_pSkinData)
		delete[]g_pSkinData;
	g_pSkinData = NULL;


	HGLOBAL	hGlobal = NULL;
	HRSRC	hSource = NULL;
	LPVOID  lpBuffer = NULL;
	BOOL	bResult = FALSE;

	// 1.定位我们的自定义资源，这里因为我们是从本模块定位资源，所以将句柄简单地置为NULL即可
	hSource = FindResource(NULL, MAKEINTRESOURCE(LIA004), _T("SOFTKEY"));
	if (hSource == NULL)
	{
		WriteTextLog(_T("定位资源失败"));
		return;
	}

	// 2.获取资源的大小;
	g_SkinLeng = (UINT)SizeofResource(NULL, hSource);

	// 3.加载资源;
	hGlobal = LoadResource(NULL, hSource);
	if (hGlobal == NULL)
	{
		WriteTextLog(_T("加载资源失败"));
		return;
	}

	// 4.锁定资源,获取buffer;
	lpBuffer = LockResource(hGlobal);
	if (lpBuffer == NULL)
	{
		WriteTextLog(_T("锁定资源失败"));
		return;
	}

	g_pSkinData = new BYTE[g_SkinLeng];
	memcpy(g_pSkinData, lpBuffer, g_SkinLeng);

	UnlockResource(hGlobal);
	FreeResource(hGlobal);
}

BOOL CheckExistDinDan(CString id)
{
	CRecordset myset(&g_db);
	CString	sql = "select count(*) as cot from dindan where id='" + id + "'";
	myset.Open(CRecordset::forwardOnly, sql);
	myset.GetFieldValue("cot", sql);
	myset.Close();
	return  atol(sql);
}

//CString g_nCurConvertDBName="db";	// Jeff.deal
CString g_nCurConvertDBName(g_szDBName);
/************************************************************************/
/* [函数]：CheckHistoryData
/* [描述]：将被检测的数据库已完成的订单数据转到历史数据库中,并删除被检测的数据库已完成的订单;
/* [参数]：
/*			pSrcdb：   源数据库，用于被转历史的数据库;
/*			nSrcYear： 源数据库的年份;
/*			bMode2：   转储模式：0=年度完成的订单; 1=年度所有订单，包含未完成订单;
/* [返回]：void
/*
/************************************************************************/
void CDBServerDlg::CheckHistoryData(CDatabase *pSrcdb /* = NULL */, int nSrcYear /* = 0 */, BOOL bMode2 /* = 0*/)//历史备份;
{
#if JEFF_TEST_ON
	// 取消转将当前数据库完成订单的记录转到年份数据库中,此步直接返回;
	return;
#endif

	try
	{
		//g_nCurConvertDBName="db";
		g_nCurConvertDBName = g_szDBName;
		if (pSrcdb != NULL)
		{
			g_bConvertHisAll = 1;
			g_nCurConvertDBName.Format("%d", nSrcYear);
			if (bMode2)
			{
				//	MessageBox(g_nCurConvertDBName);
			}
		}

		if (g_bConvertHisAll)
		{
			DWORD id = FindAppProcessID("AutoRun.exe");
			if (id != -1)
			{
				HANDLE ProcessHandle = OpenProcess(PROCESS_ALL_ACCESS, FALSE, id);
				if (ProcessHandle)
					TerminateProcess(ProcessHandle, 0);
			}
			ShowWindow(SW_HIDE);
			WriteTextLog("全部转历史开始");
		}

		CString sql;
		g_curdb = &g_db;
		if (pSrcdb != NULL)
			g_curdb = pSrcdb;

		// 1.获取去年年份值 lastyear
		CTime tm = CTime::GetCurrentTime();
		int lastyear = tm.GetYear() - 1;

		CString strdate, strdate2;
		strdate.Format("%04d-%02d-%02d", lastyear, 1, 1);
		strdate2.Format("%04d-%02d-%02d", lastyear, 12, 31);
		CString filter = "time1>='" + strdate + "' and time1<='" + strdate2 + "' and status3='OK'";

		DWORD ii = 0;
		CArray<CStringArray, CStringArray> strOrderNumberArray; //用于记录订单单号;

		// 2.获取得订单号，并存储在CArray<CStringArray,CStringArray>
		if (bMode2)// 存储即将转为历史数据库的所有年度订单的数据库记录（包含未完成）;
		{
			CString filter = "time1>='" + strdate + "' and time1<='" + strdate2 + "'";
			//	AfxMessageBox(filter);
			CRecordset myset(g_curdb);
			CString	sql = "select count(*) as cot from dindan";	// 订单单数;
			if (!filter.IsEmpty())
				sql += " where " + filter;
			myset.Open(CRecordset::forwardOnly, sql);
			myset.GetFieldValue("cot", sql);
			myset.Close();

			//	AfxMessageBox(sql); 
			int count = atol(sql);
			strOrderNumberArray.SetSize(count, 1);
			CRstDindanForm rsSt;
			rsSt.m_pDatabase = g_curdb;
			if (!filter.IsEmpty())
				rsSt.m_strFilter = filter;
			rsSt.Open();
			ii = 0;
			while (!rsSt.IsEOF())
			{
				strOrderNumberArray.ElementAt(ii).RemoveAll();
				//if(CheckExistDinDan(rsSt.id)==0)
				{
					strOrderNumberArray.ElementAt(ii).Add(rsSt.id);
					ii++;
				}
				rsSt.MoveNext();
				if (strOrderNumberArray.GetSize() <= ii)
					break;
			}
			rsSt.Close();
			strOrderNumberArray.SetSize(ii, 1);

		}
		else// 存储即将转为历史数据库的已完成订单的年度数据库记录;
		{
			// 有多少订单完成的;
			CRecordset myset(g_curdb);
			CString	sql = "select count(*) as cot from dindan";
			if (!filter.IsEmpty())
				sql += " where " + filter;
			myset.Open(CRecordset::forwardOnly, sql);
			myset.GetFieldValue("cot", sql);
			myset.Close();
			int count = atol(sql);
			strOrderNumberArray.SetSize(count, 1);
			CRstDindanForm rsSt;
			rsSt.m_pDatabase = g_curdb;
			if (!filter.IsEmpty())
				rsSt.m_strFilter = filter;
			rsSt.Open();
			ii = 0;
			while (!rsSt.IsEOF())
			{
				strOrderNumberArray.ElementAt(ii).RemoveAll();
				strOrderNumberArray.ElementAt(ii).Add(rsSt.id);
				ii++;
				rsSt.MoveNext();
				if (strOrderNumberArray.GetSize() <= ii)
					break;
			}
			rsSt.Close();
			strOrderNumberArray.SetSize(ii, 1);
		}

		// 3.获取该年份名称的数据库;
		CDatabase *pLastYeardb = GetDB(lastyear);
		if (pLastYeardb == NULL)
		{
			CheckYear(lastyear);
			return;
		}

		CDatabase *pdb2Transfer = g_curdb;	// pdb2Transfer需要转为成历史数据库的数据库;
		pLastYeardb = GetDB(lastyear);		// pLastYeardb往年历史数据库;
		if (pLastYeardb == NULL)
		{
			// Jeff数据库中,没有历史数据库存在,退出历史转换任务;
			return;
		}

		// 4.根据订单号,遍历数据;
		int i = 0;
		for ( i = 0; i < strOrderNumberArray.GetSize(); i++)
		{
			//	if("20121013-005"!=g_List1array.ElementAt (i).ElementAt (0))continue;
			// TransDinDan返回：1表示正常, 100及以上表示源数据库里记录 > 目标数据库记录;
			// TransDinDan将源数据库中的订单数据insert into 到目标数据库中;
			int ret = TransDinDan(pdb2Transfer, pLastYeardb, strOrderNumberArray.ElementAt(i).ElementAt(0), lastyear);
			if (ret == 1)
			{
				// ret == 1表示源数据库将订单数据插入到目标数据库成功,则删除源数据库中的订单数据;
				sql = "delete from  dindan where id='" + strOrderNumberArray.ElementAt(i).ElementAt(0) + "'";
				MyExecuteSQL(g_curdb, sql);

				sql = "delete from  dindansp where id='" + strOrderNumberArray.ElementAt(i).ElementAt(0) + "'";
				MyExecuteSQL(g_curdb, sql);

				sql = "delete from  photoprint where id='" + strOrderNumberArray.ElementAt(i).ElementAt(0) + "'";
				MyExecuteSQL(g_curdb, sql);

				sql = "delete from  dindanbukuan where id='" + strOrderNumberArray.ElementAt(i).ElementAt(0) + "'";
				MyExecuteSQL(g_curdb, sql);
				sql = "delete from  dindanbukuan2 where id='" + strOrderNumberArray.ElementAt(i).ElementAt(0) + "'";
				MyExecuteSQL(g_curdb, sql);

				sql = "delete from  client where id='" + strOrderNumberArray.ElementAt(i).ElementAt(0) + "'";
				MyExecuteSQL(g_curdb, sql);

				sql = "delete from  burncdreg where id='" + strOrderNumberArray.ElementAt(i).ElementAt(0) + "'";
				MyExecuteSQL(g_curdb, sql);

				sql = "delete from  digitalwork where id='" + strOrderNumberArray.ElementAt(i).ElementAt(0) + "'";
				MyExecuteSQL(g_curdb, sql);

				sql = "delete from  mywork where id='" + strOrderNumberArray.ElementAt(i).ElementAt(0) + "'";
				MyExecuteSQL(g_curdb, sql);

				sql = "delete from  dindanjd where id='" + strOrderNumberArray.ElementAt(i).ElementAt(0) + "'";
				MyExecuteSQL(g_curdb, sql);

				sql = "delete from  dindansp2 where id='" + strOrderNumberArray.ElementAt(i).ElementAt(0) + "'";
				MyExecuteSQL(g_curdb, sql);
				sql = "delete from  dindansp3 where id='" + strOrderNumberArray.ElementAt(i).ElementAt(0) + "'";
				MyExecuteSQL(g_curdb, sql);
			}
			else
			{
				// ret=105,已经转过，但是2014被删除过，然后再次转时发现2014里没有记录;待定;
				sql.Format("ret:%d", ret);
				WriteTextLog("转历史失败" + strOrderNumberArray.ElementAt(i).ElementAt(0) + sql);
			}
#ifdef LIMITCOUNT 
			if (g_bConvertHisAll == 0)
			{
				if (i > 100)break;
			}
#endif
		}

		////////////////////////////支出
		//WriteTextLog("支出");
		strdate.Format("%04d-%02d-%02d", lastyear, 1, 1);
		strdate2.Format("%04d-%02d-%02d", lastyear, 12, 31);
		filter = "dat>='" + strdate + "' and dat<='" + strdate2 + "'";
		{
			strOrderNumberArray.RemoveAll();
			CRecordset myset(g_curdb);
			CString	sql = "select count(*) as cot from gudingfeiyong";
			if (!filter.IsEmpty())
				sql += " where " + filter;
			myset.Open(CRecordset::forwardOnly, sql);
			myset.GetFieldValue("cot", sql);
			myset.Close();
			int count = atol(sql);
			strOrderNumberArray.SetSize(count, 1);
			CRstPayOutInput rsSt;
			rsSt.m_pDatabase = g_curdb;
			if (!filter.IsEmpty())
				rsSt.m_strFilter = filter;
			rsSt.Open();
			ii = 0;
			while (!rsSt.IsEOF())
			{
				strOrderNumberArray.ElementAt(ii).RemoveAll();
				strOrderNumberArray.ElementAt(ii).Add(rsSt.id);
				ii++;
				rsSt.MoveNext(); if (strOrderNumberArray.GetSize() <= ii)break;
			}
			rsSt.Close(); strOrderNumberArray.SetSize(ii, 1);
		}

		for (i = 0; i < strOrderNumberArray.GetSize(); i++)
		{
			if (TransPayOut(pdb2Transfer, pLastYeardb, strOrderNumberArray.ElementAt(i).ElementAt(0), lastyear))
			{
				{
					sql.Format("delete from  gudingfeiyong where id=%d", atol(strOrderNumberArray.ElementAt(i).ElementAt(0)));
					MyExecuteSQL(g_curdb, sql);
				}
			}
#ifdef LIMITCOUNT 
			if (g_bConvertHisAll == 0)
			{
				if (i > 100)break;
			}
#endif
		}

		////////////////////////////其它收入
		strdate.Format("%04d-%02d-%02d", lastyear, 1, 1);
		strdate2.Format("%04d-%02d-%02d", lastyear, 12, 31);
		filter = "dat>='" + strdate + "' and dat<='" + strdate2 + "'";
		{
			strOrderNumberArray.RemoveAll();
			CRecordset myset(g_curdb);
			CString	sql = "select count(*) as cot from singleincome";
			if (!filter.IsEmpty())
				sql += " where " + filter;
			myset.Open(CRecordset::forwardOnly, sql);
			myset.GetFieldValue("cot", sql);
			myset.Close();
			int count = atol(sql);
			strOrderNumberArray.SetSize(count, 1);
			CRstIncomeInput rsSt;
			rsSt.m_pDatabase = g_curdb;
			if (!filter.IsEmpty())
				rsSt.m_strFilter = filter;
			rsSt.Open();
			ii = 0;
			while (!rsSt.IsEOF())
			{
				strOrderNumberArray.ElementAt(ii).RemoveAll();
				if (atoi(rsSt.balance) == 0)
					strOrderNumberArray.ElementAt(ii).Add(rsSt.id);
				else
				{
					rsSt.MoveNext(); continue;
				}
				ii++;
				rsSt.MoveNext();
				if (strOrderNumberArray.GetSize() <= ii)break;
			}
			rsSt.Close();
			strOrderNumberArray.SetSize(ii, 1);
		}

		for (i = 0; i < strOrderNumberArray.GetSize(); i++)
		{
			if (TransIncome(pdb2Transfer, pLastYeardb, strOrderNumberArray.ElementAt(i).ElementAt(0), lastyear))
			{
				{
					sql.Format("delete from  singleincome where id=%d", atol(strOrderNumberArray.ElementAt(i).ElementAt(0)));
					MyExecuteSQL(g_curdb, sql);

					sql.Format("delete from  singleincomemoney where [id]='%s'", strOrderNumberArray.ElementAt(i).ElementAt(0));
					MyExecuteSQL(g_curdb, sql);
				}
			}
#ifdef LIMITCOUNT 
			if (g_bConvertHisAll == 0)
			{
				if (i > 100)break;
			}
#endif
		}
		////////////////////////////其它二销收款
		filter = "id not in(select id from singleincome)";
		{
			strOrderNumberArray.RemoveAll();
			CRecordset myset(g_curdb);
			CString	sql = "select count(*) as cot from singleincomemoney";
			if (!filter.IsEmpty())
				sql += " where " + filter;
			myset.Open(CRecordset::forwardOnly, sql);
			myset.GetFieldValue("cot", sql);
			myset.Close();
			int count = atol(sql);
			strOrderNumberArray.SetSize(count, 1);
			CRstsingleincomemoney rsSt;
			rsSt.m_pDatabase = g_curdb;
			if (!filter.IsEmpty())
				rsSt.m_strFilter = filter;
			rsSt.Open();
			ii = 0;
			while (!rsSt.IsEOF())
			{
				strOrderNumberArray.ElementAt(ii).RemoveAll();
				strOrderNumberArray.ElementAt(ii).Add(rsSt.id);
				ii++;
				rsSt.MoveNext();
				if (strOrderNumberArray.GetSize() <= ii)
					break;
			}
			rsSt.Close();
			strOrderNumberArray.SetSize(ii, 1);
		}
		////////////////////////////其它二销收款
		for (i = 0; i < strOrderNumberArray.GetSize(); i++)
		{
			if (TransIncomeMoney(pdb2Transfer, pLastYeardb, strOrderNumberArray.ElementAt(i).ElementAt(0), lastyear))
			{
				{
					sql.Format("delete from  singleincomemoney where [id]='%s'", strOrderNumberArray.ElementAt(i).ElementAt(0));
					MyExecuteSQL(g_curdb, sql);
				}
			}
#ifdef LIMITCOUNT 
			if (i > 100)break;
#endif
		}

		///1/////////////////////////client2phonerecord 2010-08-09 16:22:16
		strdate.Format("%04d-%02d-%02d 00:00:00", lastyear, 1, 1);
		strdate2.Format("%04d-%02d-%02d 99:99:99", lastyear, 12, 31);
		filter = "datetime>='" + strdate + "' and datetime<='" + strdate2 + "'";
		{
			strOrderNumberArray.RemoveAll();
			CRecordset myset(g_curdb);
			CString	sql = "select count(*) as cot from client2phonerecord"; if (!filter.IsEmpty())sql += " where " + filter;
			myset.Open(CRecordset::forwardOnly, sql);
			myset.GetFieldValue("cot", sql);
			myset.Close();
			int count = atol(sql);
			strOrderNumberArray.SetSize(count, 1);
			CRstclient2phonerecord rsSt;
			rsSt.m_pDatabase = g_curdb;
			if (!filter.IsEmpty())
				rsSt.m_strFilter = filter;
			rsSt.Open();
			ii = 0;
			while (!rsSt.IsEOF())
			{
				strOrderNumberArray.ElementAt(ii).RemoveAll();
				strOrderNumberArray.ElementAt(ii).Add(rsSt.datetime);
				ii++;
				rsSt.MoveNext();
				if (strOrderNumberArray.GetSize() <= ii)
					break;
			}
			rsSt.Close();
			strOrderNumberArray.SetSize(ii, 1);
		}
		for (i = 0; i < strOrderNumberArray.GetSize(); i++)
		{
			if (Transclient2phonerecord(pdb2Transfer, pLastYeardb, strOrderNumberArray.ElementAt(i).ElementAt(0), lastyear))
			{
				{
					sql.Format("delete from  client2phonerecord where datetime='%s'", strOrderNumberArray.ElementAt(i).ElementAt(0));
					MyExecuteSQL(g_curdb, sql);
				}
			}
#ifdef LIMITCOUNT 
			if (g_bConvertHisAll == 0)
			{
				if (i > 100)break;
			}
#endif
		}
		///////////////////////////
		////////////////////////////client2phonerecordout 2010-08-09 16:22:16
		strdate.Format("%04d-%02d-%02d 00:00:00", lastyear, 1, 1);
		strdate2.Format("%04d-%02d-%02d 99:99:99", lastyear, 12, 31);
		filter = "datetime>='" + strdate + "' and datetime<='" + strdate2 + "'";
		{
			strOrderNumberArray.RemoveAll();
			CRecordset myset(g_curdb);
			CString	sql = "select count(*) as cot from client2phonerecordout";
			if (!filter.IsEmpty())
				sql += " where " + filter;
			myset.Open(CRecordset::forwardOnly, sql);
			myset.GetFieldValue("cot", sql);
			myset.Close();
			int count = atol(sql);
			strOrderNumberArray.SetSize(count, 1);
			CRstclient2phonerecordout rsSt;
			rsSt.m_pDatabase = g_curdb;
			if (!filter.IsEmpty())
				rsSt.m_strFilter = filter;
			rsSt.Open();
			ii = 0;
			while (!rsSt.IsEOF())
			{
				strOrderNumberArray.ElementAt(ii).RemoveAll();
				strOrderNumberArray.ElementAt(ii).Add(rsSt.datetime);
				ii++;
				rsSt.MoveNext(); if (strOrderNumberArray.GetSize() <= ii)break;
			}
			rsSt.Close(); strOrderNumberArray.SetSize(ii, 1);
		}
		for (i = 0; i < strOrderNumberArray.GetSize(); i++)
		{
			if (Transclient2phonerecordout(pdb2Transfer, pLastYeardb, strOrderNumberArray.ElementAt(i).ElementAt(0), lastyear))
			{
				{
					sql.Format("delete from  client2phonerecordout where datetime='%s'", strOrderNumberArray.ElementAt(i).ElementAt(0));
					MyExecuteSQL(g_curdb, sql);
				}
			}
#ifdef LIMITCOUNT 
			if (g_bConvertHisAll == 0)
			{
				if (i > 100)break;
			}
#endif
		}
		///1/////////////////////////client3phonerecord 2010-08-09 16:22:16
		strdate.Format("%04d-%02d-%02d 00:00:00", lastyear, 1, 1);
		strdate2.Format("%04d-%02d-%02d 99:99:99", lastyear, 12, 31);
		filter = "datetime>='" + strdate + "' and datetime<='" + strdate2 + "'";
		{
			strOrderNumberArray.RemoveAll();
			CRecordset myset(g_curdb);
			CString	sql = "select count(*) as cot from client3phonerecord";
			if (!filter.IsEmpty())
				sql += " where " + filter;
			myset.Open(CRecordset::forwardOnly, sql);
			myset.GetFieldValue("cot", sql);
			myset.Close();
			int count = atol(sql);
			strOrderNumberArray.SetSize(count, 1);
			CRstclient3phonerecord rsSt;
			rsSt.m_pDatabase = g_curdb;
			if (!filter.IsEmpty())
				rsSt.m_strFilter = filter;
			rsSt.Open();
			ii = 0;
			while (!rsSt.IsEOF())
			{
				strOrderNumberArray.ElementAt(ii).RemoveAll();
				strOrderNumberArray.ElementAt(ii).Add(rsSt.datetime);
				ii++;
				rsSt.MoveNext();
				if (strOrderNumberArray.GetSize() <= ii)
					break;
			}
			rsSt.Close(); strOrderNumberArray.SetSize(ii, 1);
		}
		for (i = 0; i < strOrderNumberArray.GetSize(); i++)
		{
			if (Transclient3phonerecord(pdb2Transfer, pLastYeardb, strOrderNumberArray.ElementAt(i).ElementAt(0), lastyear))
			{
				{
					sql.Format("delete from  client3phonerecord where datetime='%s'", strOrderNumberArray.ElementAt(i).ElementAt(0));
					MyExecuteSQL(g_curdb, sql);
				}
			}
#ifdef LIMITCOUNT 
			if (g_bConvertHisAll == 0)
			{
				if (i > 100)break;
			}
#endif
		}
		///////////////////////////
		////////////////////////////client3phonerecordout 2010-08-09 16:22:16
		strdate.Format("%04d-%02d-%02d 00:00:00", lastyear, 1, 1);
		strdate2.Format("%04d-%02d-%02d 99:99:99", lastyear, 12, 31);
		filter = "datetime>='" + strdate + "' and datetime<='" + strdate2 + "'";
		{
			strOrderNumberArray.RemoveAll();
			CRecordset myset(g_curdb);
			CString	sql = "select count(*) as cot from client3phonerecordout";
			if (!filter.IsEmpty())
				sql += " where " + filter;
			myset.Open(CRecordset::forwardOnly, sql);
			myset.GetFieldValue("cot", sql);
			myset.Close();
			int count = atol(sql);
			strOrderNumberArray.SetSize(count, 1);
			CRstclient3phonerecordout rsSt;
			rsSt.m_pDatabase = g_curdb;
			if (!filter.IsEmpty())
				rsSt.m_strFilter = filter;
			rsSt.Open();
			ii = 0;
			while (!rsSt.IsEOF())
			{
				strOrderNumberArray.ElementAt(ii).RemoveAll();
				strOrderNumberArray.ElementAt(ii).Add(rsSt.datetime);
				ii++;
				rsSt.MoveNext(); if (strOrderNumberArray.GetSize() <= ii)break;
			}
			rsSt.Close(); strOrderNumberArray.SetSize(ii, 1);
		}
		for (i = 0; i < strOrderNumberArray.GetSize(); i++)
		{
			if (Transclient3phonerecordout(pdb2Transfer, pLastYeardb, strOrderNumberArray.ElementAt(i).ElementAt(0), lastyear))
			{
				{
					sql.Format("delete from  client3phonerecordout where datetime='%s'", strOrderNumberArray.ElementAt(i).ElementAt(0));
					MyExecuteSQL(g_curdb, sql);
				}
			}
#ifdef LIMITCOUNT 
			if (g_bConvertHisAll == 0)
			{
				if (i > 100)break;
			}
#endif
		}
		///////////////////////////
		////////////////////////////employeephonerecord 2010-08-09 16:22:16
		strdate.Format("%04d-%02d-%02d 00:00:00", lastyear, 1, 1);
		strdate2.Format("%04d-%02d-%02d 99:99:99", lastyear, 12, 31);
		filter = "datetime>='" + strdate + "' and datetime<='" + strdate2 + "'";
		{
			strOrderNumberArray.RemoveAll();
			CRecordset myset(g_curdb);
			CString	sql = "select count(*) as cot from employeephonerecord";
			if (!filter.IsEmpty())
				sql += " where " + filter;
			myset.Open(CRecordset::forwardOnly, sql);
			myset.GetFieldValue("cot", sql);
			myset.Close();
			int count = atol(sql);
			strOrderNumberArray.SetSize(count, 1);
			CRstemployeephonerecord rsSt;
			rsSt.m_pDatabase = g_curdb;
			if (!filter.IsEmpty())
				rsSt.m_strFilter = filter;
			rsSt.Open();
			ii = 0;
			while (!rsSt.IsEOF())
			{
				strOrderNumberArray.ElementAt(ii).RemoveAll();
				strOrderNumberArray.ElementAt(ii).Add(rsSt.datetime);
				ii++;
				rsSt.MoveNext();
				if (strOrderNumberArray.GetSize() <= ii)
					break;
			}
			rsSt.Close();
			strOrderNumberArray.SetSize(ii, 1);
		}
		for (i = 0; i < strOrderNumberArray.GetSize(); i++)
		{
			if (Transemployeephonerecord(pdb2Transfer, pLastYeardb, strOrderNumberArray.ElementAt(i).ElementAt(0), lastyear))
			{
				{
					sql.Format("delete from  employeephonerecord where datetime='%s'", strOrderNumberArray.ElementAt(i).ElementAt(0));
					MyExecuteSQL(g_curdb, sql);
				}
			}
#ifdef LIMITCOUNT 
			if (g_bConvertHisAll == 0)
			{
				if (i > 100)break;
			}
#endif
		}
		///////////////////////////
		////////////////////////////employeephonerecordout 2010-08-09 16:22:16
		strdate.Format("%04d-%02d-%02d 00:00:00", lastyear, 1, 1);
		strdate2.Format("%04d-%02d-%02d 99:99:99", lastyear, 12, 31);
		filter = "datetime>='" + strdate + "' and datetime<='" + strdate2 + "'";
		{
			strOrderNumberArray.RemoveAll();
			CRecordset myset(g_curdb);
			CString	sql = "select count(*) as cot from employeephonerecordout";
			if (!filter.IsEmpty())
				sql += " where " + filter;
			myset.Open(CRecordset::forwardOnly, sql);
			myset.GetFieldValue("cot", sql);
			myset.Close();
			int count = atol(sql);
			strOrderNumberArray.SetSize(count, 1);
			CRstemployeephonerecordout rsSt;
			rsSt.m_pDatabase = g_curdb;
			if (!filter.IsEmpty())
				rsSt.m_strFilter = filter;
			rsSt.Open();
			ii = 0;
			while (!rsSt.IsEOF())
			{
				strOrderNumberArray.ElementAt(ii).RemoveAll();
				strOrderNumberArray.ElementAt(ii).Add(rsSt.datetime);
				ii++;
				rsSt.MoveNext();
				if (strOrderNumberArray.GetSize() <= ii)
					break;
			}
			rsSt.Close(); strOrderNumberArray.SetSize(ii, 1);
		}
		for (i = 0; i < strOrderNumberArray.GetSize(); i++)
		{
			if (Transemployeephonerecordout(pdb2Transfer, pLastYeardb, strOrderNumberArray.ElementAt(i).ElementAt(0), lastyear))
			{
				{
					sql.Format("delete from  employeephonerecordout where datetime='%s'", strOrderNumberArray.ElementAt(i).ElementAt(0));
					MyExecuteSQL(g_curdb, sql);
				}
			}
#ifdef LIMITCOUNT 
			if (g_bConvertHisAll == 0)
			{
				if (i > 100)break;
			}
#endif
		}
		///////////////////////////
		////////////////////////////phonerecord 2010-08-09 16:22:16
		strdate.Format("%04d-%02d-%02d 00:00:00", lastyear, 1, 1);
		strdate2.Format("%04d-%02d-%02d 99:99:99", lastyear, 12, 31);
		filter = "datetime>='" + strdate + "' and datetime<='" + strdate2 + "'";
		{
			strOrderNumberArray.RemoveAll();
			CRecordset myset(g_curdb);
			CString	sql = "select count(*) as cot from phonerecord";
			if (!filter.IsEmpty())
				sql += " where " + filter;
			myset.Open(CRecordset::forwardOnly, sql);
			myset.GetFieldValue("cot", sql);
			myset.Close();
			int count = atol(sql);
			strOrderNumberArray.SetSize(count, 1);
			CRstphonerecord rsSt; rsSt.m_pDatabase = g_curdb;
			if (!filter.IsEmpty())
				rsSt.m_strFilter = filter;
			rsSt.Open();
			ii = 0;
			while (!rsSt.IsEOF())
			{
				strOrderNumberArray.ElementAt(ii).RemoveAll();
				strOrderNumberArray.ElementAt(ii).Add(rsSt.datetime);
				ii++;
				rsSt.MoveNext();
				if (strOrderNumberArray.GetSize() <= ii)
					break;
			}
			rsSt.Close();
			strOrderNumberArray.SetSize(ii, 1);
		}
		for (i = 0; i < strOrderNumberArray.GetSize(); i++)
		{
			if (Transphonerecord(pdb2Transfer, pLastYeardb, strOrderNumberArray.ElementAt(i).ElementAt(0), lastyear))
			{
				{
					sql.Format("delete from  phonerecord where datetime='%s'", strOrderNumberArray.ElementAt(i).ElementAt(0));
					MyExecuteSQL(g_curdb, sql);
				}
			}
#ifdef LIMITCOUNT 
			if (g_bConvertHisAll == 0)
			{
				if (i > 100)break;
			}
#endif
		}
		///////////////////////////
		////////////////////////////phonerecordout 2010-08-09 16:22:16
		strdate.Format("%04d-%02d-%02d 00:00:00", lastyear, 1, 1);
		strdate2.Format("%04d-%02d-%02d 99:99:99", lastyear, 12, 31);
		filter = "datetime>='" + strdate + "' and datetime<='" + strdate2 + "'";
		{
			strOrderNumberArray.RemoveAll();
			CRecordset myset(g_curdb);
			CString	sql = "select count(*) as cot from phonerecordout";
			if (!filter.IsEmpty())
				sql += " where " + filter;
			myset.Open(CRecordset::forwardOnly, sql);
			myset.GetFieldValue("cot", sql);
			myset.Close();
			int count = atol(sql);
			strOrderNumberArray.SetSize(count, 1);
			CRstphonerecordout rsSt;
			rsSt.m_pDatabase = g_curdb;
			if (!filter.IsEmpty())
				rsSt.m_strFilter = filter;
			rsSt.Open();
			ii = 0;
			while (!rsSt.IsEOF())
			{
				strOrderNumberArray.ElementAt(ii).RemoveAll();
				strOrderNumberArray.ElementAt(ii).Add(rsSt.datetime);
				ii++;
				rsSt.MoveNext(); if (strOrderNumberArray.GetSize() <= ii)break;
			}
			rsSt.Close(); strOrderNumberArray.SetSize(ii, 1);
		}
		for (i = 0; i < strOrderNumberArray.GetSize(); i++)
		{
			if (Transphonerecordout(pdb2Transfer, pLastYeardb, strOrderNumberArray.ElementAt(i).ElementAt(0), lastyear))
			{
				{
					sql.Format("delete from  phonerecordout where datetime='%s'", strOrderNumberArray.ElementAt(i).ElementAt(0));
					MyExecuteSQL(g_curdb, sql);
				}
			}
#ifdef LIMITCOUNT 
			if (g_bConvertHisAll == 0)
			{
				if (i > 100)break;
			}
#endif
		}
		///////////////////////////
		////////////////////////////unknownphonerecord 2010-08-09 16:22:16
		strdate.Format("%04d-%02d-%02d 00:00:00", lastyear, 1, 1);
		strdate2.Format("%04d-%02d-%02d 99:99:99", lastyear, 12, 31);
		filter = "datetime>='" + strdate + "' and datetime<='" + strdate2 + "'";
		{
			strOrderNumberArray.RemoveAll();
			CRecordset myset(g_curdb);
			CString	sql = "select count(*) as cot from unknownphonerecord";
			if (!filter.IsEmpty())
				sql += " where " + filter;
			myset.Open(CRecordset::forwardOnly, sql);
			myset.GetFieldValue("cot", sql);
			myset.Close();
			int count = atol(sql);
			strOrderNumberArray.SetSize(count, 1);
			CRstunknownphonerecord rsSt;
			rsSt.m_pDatabase = g_curdb;
			if (!filter.IsEmpty())
				rsSt.m_strFilter = filter;
			rsSt.Open();
			ii = 0;
			while (!rsSt.IsEOF())
			{
				strOrderNumberArray.ElementAt(ii).RemoveAll();
				strOrderNumberArray.ElementAt(ii).Add(rsSt.datetime);
				ii++;
				rsSt.MoveNext(); if (strOrderNumberArray.GetSize() <= ii)break;
			}
			rsSt.Close(); strOrderNumberArray.SetSize(ii, 1);
		}
		for (i = 0; i < strOrderNumberArray.GetSize(); i++)
		{
			if (Transunknownphonerecord(pdb2Transfer, pLastYeardb, strOrderNumberArray.ElementAt(i).ElementAt(0), lastyear))
			{
				{
					sql.Format("delete from  unknownphonerecord where datetime='%s'", strOrderNumberArray.ElementAt(i).ElementAt(0));
					MyExecuteSQL(g_curdb, sql);
				}
			}
#ifdef LIMITCOUNT 
			if (g_bConvertHisAll == 0)
			{
				if (i > 100)break;
			}
#endif
		}
		///////////////////////////
		////////////////////////////unknownphonerecordout 2010-08-09 16:22:16
		strdate.Format("%04d-%02d-%02d 00:00:00", lastyear, 1, 1);
		strdate2.Format("%04d-%02d-%02d 99:99:99", lastyear, 12, 31);
		filter = "datetime>='" + strdate + "' and datetime<='" + strdate2 + "'";
		{
			strOrderNumberArray.RemoveAll();
			CRecordset myset(g_curdb);
			CString	sql = "select count(*) as cot from unknownphonerecordout";
			if (!filter.IsEmpty())
				sql += " where " + filter;
			myset.Open(CRecordset::forwardOnly, sql);
			myset.GetFieldValue("cot", sql);
			myset.Close();
			int count = atol(sql);
			strOrderNumberArray.SetSize(count, 1);
			CRstunknownphonerecordout rsSt;
			rsSt.m_pDatabase = g_curdb;
			if (!filter.IsEmpty())
				rsSt.m_strFilter = filter;
			rsSt.Open();
			ii = 0;
			while (!rsSt.IsEOF())
			{
				strOrderNumberArray.ElementAt(ii).RemoveAll();
				strOrderNumberArray.ElementAt(ii).Add(rsSt.datetime);
				ii++;
				rsSt.MoveNext();
				if (strOrderNumberArray.GetSize() <= ii)
					break;
			}
			rsSt.Close();
			strOrderNumberArray.SetSize(ii, 1);
		}
		for (i = 0; i < strOrderNumberArray.GetSize(); i++)
		{
			if (Transunknownphonerecordout(pdb2Transfer, pLastYeardb, strOrderNumberArray.ElementAt(i).ElementAt(0), lastyear))
			{
				{
					sql.Format("delete from  unknownphonerecordout where datetime='%s'", strOrderNumberArray.ElementAt(i).ElementAt(0));
					MyExecuteSQL(g_curdb, sql);
				}
			}
#ifdef LIMITCOUNT 
			if (g_bConvertHisAll == 0)
			{
				if (i > 100)break;
			}
#endif
		}
		///////////////////////////
		////////////////////////////misscallrecord 2010-08-09 16:22:16
		strdate.Format("%04d-%02d-%02d 00:00:00", lastyear, 1, 1);
		strdate2.Format("%04d-%02d-%02d 99:99:99", lastyear, 12, 31);
		filter = "datetime>='" + strdate + "' and datetime<='" + strdate2 + "'";
		{
			strOrderNumberArray.RemoveAll();
			CRecordset myset(g_curdb);
			CString	sql = "select count(*) as cot from misscallrecord";
			if (!filter.IsEmpty())
				sql += " where " + filter;
			myset.Open(CRecordset::forwardOnly, sql);
			myset.GetFieldValue("cot", sql);
			myset.Close();
			int count = atol(sql);
			strOrderNumberArray.SetSize(count, 1);
			CRstmisscallrecord rsSt;
			rsSt.m_pDatabase = g_curdb;
			if (!filter.IsEmpty())
				rsSt.m_strFilter = filter;
			rsSt.Open();
			ii = 0;
			while (!rsSt.IsEOF())
			{
				strOrderNumberArray.ElementAt(ii).RemoveAll();
				strOrderNumberArray.ElementAt(ii).Add(rsSt.datetime);
				ii++;
				rsSt.MoveNext();
				if (strOrderNumberArray.GetSize() <= ii)
					break;
			}
			rsSt.Close();
			strOrderNumberArray.SetSize(ii, 1);
		}
		for (i = 0; i < strOrderNumberArray.GetSize(); i++)
		{
			if (Transmisscallrecord(pdb2Transfer, pLastYeardb, strOrderNumberArray.ElementAt(i).ElementAt(0), lastyear))
			{
				{
					sql.Format("delete from  misscallrecord where datetime='%s'", strOrderNumberArray.ElementAt(i).ElementAt(0));
					MyExecuteSQL(g_curdb, sql);
				}
			}
#ifdef LIMITCOUNT 
			if (g_bConvertHisAll == 0)
			{
				if (i > 100)break;
			}
#endif
		}
		///////////////////////////
		////////////////////////////sendreg
		strdate.Format("%04d%02d%02d000000", lastyear, 1, 1);
		strdate2.Format("%04d%02d%02d999999", lastyear, 12, 31);
		filter = "timestamp>='" + strdate + "' and timestamp<='" + strdate2 + "' and issended='OK'";
		{
			strOrderNumberArray.RemoveAll();
			CRecordset myset(g_curdb);
			CString	sql = "select count(*) as cot from sendreg";
			if (!filter.IsEmpty())
				sql += " where " + filter;
			myset.Open(CRecordset::forwardOnly, sql);
			myset.GetFieldValue("cot", sql);
			myset.Close();
			int count = atol(sql);
			strOrderNumberArray.SetSize(count, 1);
			RstSendReg rsSt;
			rsSt.m_pDatabase = g_curdb;
			if (!filter.IsEmpty())
				rsSt.m_strFilter = filter;
			rsSt.Open();
			ii = 0;
			while (!rsSt.IsEOF())
			{
				strOrderNumberArray.ElementAt(ii).RemoveAll();
				strOrderNumberArray.ElementAt(ii).Add(rsSt.m_timestamp);
				ii++;
				rsSt.MoveNext(); if (strOrderNumberArray.GetSize() <= ii)break;
			}
			rsSt.Close(); strOrderNumberArray.SetSize(ii, 1);
		}
		for (i = 0; i < strOrderNumberArray.GetSize(); i++)
		{
			if (TransSendReg(pdb2Transfer, pLastYeardb, strOrderNumberArray.ElementAt(i).ElementAt(0), lastyear))
			{
				{
					sql.Format("delete from  sendreg where [timestamp]='%s'", strOrderNumberArray.ElementAt(i).ElementAt(0));
					MyExecuteSQL(g_curdb, sql);
				}
			}
#ifdef LIMITCOUNT 
			if (g_bConvertHisAll == 0)
			{
				if (i > 100)break;
			}
#endif
		}
		///////////////////////////
	}
	catch (...)
	{
		WriteTextLog("出错在函数TransHisData中");
	}
	if (g_bConvertHisAll)WriteTextLog("转换完成!");
	g_bConvertHisAll = 0;
	/////////////////////////生成来电精灵数据
	//return;
	/*	g_sendhead.code[0]=80;
	g_sendhead.code[1]=90;
	g_sendhead.code[2]=11;
	g_sendhead.code[3]=138;
	g_sendhead.code[4]=24;
	g_sendhead.code[0]=181;
	g_sendhead.code[0]=65;
	g_sendhead.code[0]=56;*/
	MyLock lock("processChatMessageRequestxiao");
	CArray<int, int>codearray;
	codearray.Add(80);
	codearray.Add(90);
	codearray.Add(11);
	codearray.Add(138);
	codearray.Add(24);
	codearray.Add(181);
	codearray.Add(65);
	codearray.Add(56);
	codearray.Add(179);
	codearray.Add(53);
	CFile fp;
	CString savepath, g_path1;
	char server[50];
	DWORD leng = 50;
	::GetComputerName(server, &leng);
	g_path1 = server;
	g_path1 = "\\\\" + g_path1 + "\\电话录音(管理软件)$";
	GetPathFromNetShareName("电话录音(管理软件)$", g_path1);

	if (g_path1.IsEmpty())return;

	try
	{
		CArray<CDatabase*, CDatabase*>dbarraytemp;
		dbarraytemp.Copy(g_dbHistoryArray);
		dbarraytemp.InsertAt(0, &g_db);

		for (int aa = 0; aa < dbarraytemp.GetSize(); aa++)
		{
			g_curdb = dbarraytemp.ElementAt(aa);
			savepath.Format("%s\\uphonedata%d.dat", g_path1, aa);
			::DeleteFile(savepath);		// 删除uphonedata.dat文件;
			if (fp.Open(savepath, CFile::modeCreate | CFile::modeWrite) == 0)
			{
				WriteTextLog("更新来电精灵数据出错");
				return;
			}
			CConnectSocket consock;
			consock.m_pConndb = g_curdb;

			for (int i = 0; i < codearray.GetSize(); i++)
			{
				BYTE code = codearray.ElementAt(i);
				DWORD length, arraysize;
				BYTE *pReturn = NULL;
				consock.GetDataFromCode(code, &pReturn, length, arraysize, "");
				fp.Write(&code, sizeof(BYTE));
				fp.Write(&length, sizeof(DWORD));
				fp.Write(&arraysize, sizeof(DWORD));
				fp.Write(pReturn, length);
			}
			fp.Close();
		}
		g_curdb = &g_db;
	}
	catch (CException *e)
	{
		TCHAR szError[1024] = { 0 };
		e->GetErrorMessage(szError, 1024);
		WriteTextLog(CString(szError));
		WriteTextLog("获取来电精灵数据出错");
		e->Delete();
	}

	WriteTextLog("转历史数据完成");
}

//------------------------------------------------------------------------------------
// Jeff remark
// 函数：CheckYear
// 描述：
//		1.检查指定年份的历史数据库mdf文件是否存在,存在则直接附加
//		2.不存在,则使用null.mdf文件拷贝创建历史年份数据库mdf并附加;
// 参数：
//		year:被检查年份值;
// 返回：void
//------------------------------------------------------------------------------------
#if JEFF_TEST_ON
void CDBServerDlg::CheckYear(int year)
{
	try
	{
#ifdef SQLSERVER_VERSION
		CString sql;
		// 1.判断年份数据库是否存在;
		CString strPathOfYearmdf;
		CString strPathOfYearldf;

		strPathOfYearmdf.Format("%s\\数据\\%d.mdf", g_mainpath, year);
		strPathOfYearldf.Format("%s\\数据\\%d_log.ldf", g_mainpath, year);

		CString strPathOfnulldbmdf = g_mainpath + "\\数据\\dbnull.mdf";
		CString strPathOfnulldbldf = g_mainpath + "\\数据\\dbnull_log.ldf";

		if (PathFileExists(strPathOfYearmdf) == TRUE)
		{
			if (PathFileExists(strPathOfYearldf) == TRUE)
			{
				sql.Format("exec sp_attach_db '%d',@filename1='%s',@filename2='%s'", year, strPathOfYearmdf, strPathOfYearldf);
			}
			else
			{
				// 此时要删除dbnull_log.ldf文件;
				// 因为如果2015没有对应的ldf文件,在逻辑名仍为dbnull没有改为2015时，他会使用dbnull_log.ldf做为2015数据库的日志文件;
				// 这样造成其他数据库在使用dbnull时会产生错误;
				DeleteFile(strPathOfnulldbldf);
				sql.Format("exec sp_attach_db '%d',@filename1='%s'", year, strPathOfYearmdf);
			}

			g_db.SetQueryTimeout(600);
			try
			{
				g_db.ExecuteSQL(sql);
			}
			catch (CDBException * e)
			{
				WriteTextLog(e->m_strError);
				WriteTextLog("历史数据库初始化失败!");
				e->Delete();
				return;
			}
		}
		else
		{
			// 判断dbnull.mdf文件是否存在;
			if (PathFileExists(strPathOfnulldbmdf) == FALSE)
			{
				WriteTextLog("空数据库丢失!");
				return;
			}

			// 判断拷贝mdf文件是否失败;
			if (FALSE == CopyFile(strPathOfnulldbmdf, strPathOfYearmdf, 1))
			{
				DWORD dwError = ::GetLastError();
				CString strDescription;
				strDescription.Format("dbnull.mdf拷贝为%d.mdf失败", year);
				ErrorExit(strDescription, dwError);
				return;
			}
			else
			{
				DeleteFile(strPathOfYearldf);	// 删除%d_log.LDF文件;
				if (PathFileExists(strPathOfnulldbldf) == TRUE)
				{
					if (FALSE == CopyFile(strPathOfnulldbldf, strPathOfYearldf, 1))
					{
						DWORD dwError = ::GetLastError();
						CString strDescription;
						strDescription.Format("null.mdf拷贝为%d.mdf", year);
						ErrorExit(strDescription, dwError);

						// 此时要删除dbnull_log.ldf文件;
						// 因为如果2015没有对应的ldf文件,在逻辑名仍为dbnull没有改为2015时，他会使用dbnull_log.ldf做为2015数据库的日志文件;
						// 这样造成其他数据库在使用dbnull时会产生错误;
						DeleteFile(strPathOfnulldbldf);
						sql.Format("exec sp_attach_db '%d',@filename1='%s'", year, strPathOfYearmdf);
					}
					else
					{
						sql.Format("exec sp_attach_db '%d',@filename1='%s',@filename2='%s'", year, strPathOfYearmdf, strPathOfYearldf);
					}
				}
				else
				{
					// 此时要删除dbnull_log.ldf文件;
					// 因为如果2015没有对应的ldf文件,在逻辑名仍为dbnull没有改为2015时，他会使用dbnull_log.ldf做为2015数据库的日志文件;
					// 这样造成其他数据库在使用dbnull时会产生错误;
					DeleteFile(strPathOfnulldbldf);
					sql.Format("exec sp_attach_db '%d',@filename1='%s'", year, strPathOfYearmdf);
				}

				g_db.SetQueryTimeout(600);
				try
				{
					g_db.ExecuteSQL(sql);
				}
				catch (CDBException * e)
				{
					WriteTextLog(e->m_strError);
					WriteTextLog("历史数据库初始化失败!");
					e->Delete();
					return;
				}
			}
		}

		// 附加成功后，修改逻辑名称;
		sql.Format("alter database [%d] modify file(name='dbnull',newname='%d')", year, year);
		try
		{
			g_db.ExecuteSQL(sql);
		}
		catch (CDBException * e)
		{
			WriteTextLog(e->m_strError);
			WriteTextLog("修改历史数据库主文件逻辑名失败，请手动修改!");
			e->Delete();
		}

		sql.Format("alter database [%d] modify file(name='dbnull_log',newname='%d_log')", year, year);
		try
		{
			g_db.ExecuteSQL(sql);
		}
		catch (CDBException * e)
		{
			WriteTextLog(e->m_strError);
			WriteTextLog("修改历史数据库日志文件逻辑名失败，请手动修改!");
			e->Delete();
		}

		OnExit2();
#else
		CString path,sql;
		path.Format ("%s\\数据\\%d.mdb", g_mainpath, year);
		if(::PathFileExists (path)==0)
		{
			CString nulldb=g_mainpath+"\\数据\\dbnull.mdb";
			::CopyFile (nulldb, path, 1);
			CDatabase *db=new CDatabase;
			CString strCon;
			strCon.Format("DRIVER=Microsoft Access Driver (*.mdb);DSN='';DBQ=%s;PWD=lijialyfz",path);
			if(db->OpenEx(strCon,CDatabase::noOdbcDialog))
			{
				g_nYearArray.Add (year);
				g_dbHistoryArray.Add (db);
				sql.Format ("insert into historydb([year])values('%d')", year);
				MyExecuteSQL(&g_db, sql);
			}
			else
				delete db;
		}
#endif
	}
	catch (...)
	{
		WriteTextLog("出错在函数CheckYear中");
	}
}
#else
void CDBServerDlg::CheckYear(int year)
{
	try
	{
#ifdef SQLSERVER_VERSION
		CString strPathOfYearmdf;
		CString strPathOfYearldf;
		CString sql;
		strPathOfYearmdf.Format("%s\\数据\\%d.mdf", g_mainpath, year);
		strPathOfYearldf.Format("%s\\数据\\%d_log.LDF", g_mainpath, year);
		::DeleteFile(strPathOfYearldf);	// 删除%d_log.LDF文件;

		{
			CString strPathOfnulldbmdf = g_mainpath + "\\数据\\dbnull.mdf";
			CString strPathOfnulldbldf = g_mainpath + "\\数据\\dbnull_log.LDF";
			::DeleteFile(strPathOfnulldbldf);	// 删除%d_log.LDF文件;

			// 1.判断null.mdf文件是否存在;
			if (::PathFileExists(strPathOfnulldbmdf) == 0)
			{
				WriteTextLog("空数据库丢失!");
				return;
			}

			// 2.若年份mdf文件不存在,用null.mdf复制一份年份mdf数据库文件;
			BOOL bCopyed = 0;
			if (::PathFileExists(strPathOfYearmdf) == 0)
			{
#if 0
				::CopyFile(nulldb, path, 1);
				bCopyed=1;
#else			// Jeff add:判断拷贝文件失败的原因;
				if (!::CopyFile(strPathOfnulldbmdf, strPathOfYearmdf, 1))
				{
					DWORD dwError = ::GetLastError();
					CString strDescription;
					strDescription.Format("null.mdf拷贝为%d.mdf", year);
					ErrorExit(strDescription, dwError);

					// return;//直接返回;
				}
				else
				{
					bCopyed = 1;
				}
#endif
			}

			if (::PathFileExists(strPathOfYearmdf) == 0)
			{
				WriteTextLog("拷贝数据库文件失败!");
				return;
			}
			BOOL bLog = 0;
			if (::PathFileExists(strPathOfnulldbldf))
			{
				bLog = 1;
			}

			// .将年份数据库mdf附加到数据库里;
			CString sql;
			if (bCopyed)
			{
				if (bLog)
					sql.Format("exec sp_attach_db '%s',@filename1='%s',@filename2='%s'", "dbnull", strPathOfYearmdf, strPathOfYearldf);
				else
					sql.Format("exec sp_attach_db '%s',@filename1='%s'", "dbnull", strPathOfYearmdf);
				g_db.SetQueryTimeout(600);
				try
				{
					g_db.ExecuteSQL(sql);
				}
				catch (CDBException * e)
				{
					WriteTextLog(e->m_strError);
					WriteTextLog("历史数据库初始化失败!");
					e->Delete();
				}
				sql.Format("exec sp_renamedb '%s','%d'", "dbnull", year); g_db.ExecuteSQL(sql);
			}
			else // 没有执行CopyFile,年份mdf原本就存在;
			{
				if (bLog)
					sql.Format("exec sp_attach_db '%d',@filename1='%s',@filename2='%s'", year, strPathOfYearmdf, strPathOfYearldf);
				else
					sql.Format("exec sp_attach_db '%d',@filename1='%s'", year, strPathOfYearmdf);
				g_db.SetQueryTimeout(600);
				try
				{
					g_db.ExecuteSQL(sql);
				}
				catch (CDBException * e)
				{
					WriteTextLog(e->m_strError);
					WriteTextLog("历史数据库初始化失败!");
					e->Delete();
				}
			}

			OnExit2();

			/*	g_db.SetQueryTimeout(100);

			  CDatabase *db=new CDatabase;


			  try
			  {
			  CString strCon;
			  strCon.Format(_T("driver={SQL Server};Server=%s;DATABASE=%d;%s"), g_sservrename,year,g_sdbpsw);
			  db->OpenEx(strCon,CDatabase::noOdbcDialog);

			  g_nYearArray.Add (year);
			  dbarray.Add (db);
			  sql.Format ("insert into [historydb]([year])values('%d')", year);
			  MyExecuteSQL(&g_db, sql);
			  }
			  catch(CDBException * e)
			  {
			  delete db;
			  WriteTextLog(e->m_strError);
			  WriteTextLog("历史数据库打开失败!");
			  }*/
		}
#else
		CString path,sql;
		path.Format ("%s\\数据\\%d.mdb", g_mainpath, year);
		if(::PathFileExists (path)==0)
		{
			CString nulldb=g_mainpath+"\\数据\\dbnull.mdb";
			::CopyFile (nulldb, path, 1);
			CDatabase *db=new CDatabase;
			CString strCon;
			strCon.Format("DRIVER=Microsoft Access Driver (*.mdb);DSN='';DBQ=%s;PWD=lijialyfz",path);
			if(db->OpenEx(strCon,CDatabase::noOdbcDialog))
			{
				g_nYearArray.Add (year);
				g_dbHistoryArray.Add (db);
				sql.Format ("insert into historydb([year])values('%d')", year);
				MyExecuteSQL(&g_db, sql);
			}
			else
				delete db;
		}
#endif
	}
	catch (...)
	{
		WriteTextLog("出错在函数CheckYear中");
	}
}
#endif

CDatabase* CDBServerDlg::GetDB(int year)
{
	try
	{
		for (int i = 0; i < g_nYearArray.GetSize(); i++)
		{
			if (g_nYearArray.ElementAt(i) == year)
			{
				return g_dbHistoryArray.ElementAt(i);
			}
		}
		return NULL;
	}
	catch (...)
	{
		WriteTextLog("出错在函数GetDB中");
	}
}

/************************************************************************/
/* mark by Jeff;
/* 函数：CheckDinDanExist
/* 描述：
/* 参数：
/*		pBeConverted_db：（源）
/*		pToConverted_db：（目标）
/*		strOderNumber：
/*		pRetArray：
/*
/* 返回：1表示正常,100及以上表示源数据库里记录 > 目标数据库记录;
/*
/************************************************************************/
BOOL CDBServerDlg::CheckDinDanExist(CDatabase *pBeConverted_db, CDatabase *pToConverted_db, CString strOderNumber, CStringArray *pRetArray)
{
	try
	{
		pRetArray->RemoveAll();
		int count1 = 0;
		int count2 = 0;
		CString sql;
		{
			CRecordset myset(pBeConverted_db);
			sql = "select count(*) as cot from dindan where id='" + strOderNumber + "'";
			myset.Open(CRecordset::forwardOnly, sql);
			myset.GetFieldValue("cot", sql);
			myset.Close();
			count1 = atoi(sql);
		}
		{
			CRecordset myset(pToConverted_db);
			sql = "select count(*) as cot from dindan where id='" + strOderNumber + "'";
			myset.Open(CRecordset::forwardOnly, sql);
			myset.GetFieldValue("cot", sql);
			myset.Close();
			count2 = atoi(sql);
		}
		if (count1 > count2)//100
			pRetArray->Add("0");
		else
			pRetArray->Add("1");

		{
			CRecordset myset(pBeConverted_db);
			sql = "select count(*) as cot from dindansp where id='" + strOderNumber + "'";
			myset.Open(CRecordset::forwardOnly, sql);
			myset.GetFieldValue("cot", sql);
			myset.Close();
			count1 = atoi(sql);
		}
		{
			CRecordset myset(pToConverted_db);
			sql = "select count(*) as cot from dindansp where id='" + strOderNumber + "'";
			myset.Open(CRecordset::forwardOnly, sql);
			myset.GetFieldValue("cot", sql);
			myset.Close();
			count2 = atoi(sql);
		}
		if (count1 > count2)//101
			pRetArray->Add("0");
		else
			pRetArray->Add("1");

		{
			CRecordset myset(pBeConverted_db);
			sql = "select count(*) as cot from dindanbukuan where id='" + strOderNumber + "'";
			myset.Open(CRecordset::forwardOnly, sql);
			myset.GetFieldValue("cot", sql);
			myset.Close();
			count1 = atoi(sql);
		}
		{
			CRecordset myset(pToConverted_db);
			sql = "select count(*) as cot from dindanbukuan where id='" + strOderNumber + "'";
			myset.Open(CRecordset::forwardOnly, sql);
			myset.GetFieldValue("cot", sql);
			myset.Close();
			count2 = atoi(sql);
		}
		if (count1 > count2)//102
			pRetArray->Add("0");
		else
			pRetArray->Add("1");

		{
			CRecordset myset(pBeConverted_db);
			sql = "select count(*) as cot from dindanbukuan2 where id='" + strOderNumber + "'";
			myset.Open(CRecordset::forwardOnly, sql);
			myset.GetFieldValue("cot", sql);
			myset.Close();
			count1 = atoi(sql);
		}
		{
			CRecordset myset(pToConverted_db);
			sql = "select count(*) as cot from dindanbukuan2 where id='" + strOderNumber + "'";
			myset.Open(CRecordset::forwardOnly, sql);
			myset.GetFieldValue("cot", sql);
			myset.Close();
			count2 = atoi(sql);
		}
		if (count1 > count2)//103
			pRetArray->Add("0");
		else
			pRetArray->Add("1");

		{
			CRecordset myset(pBeConverted_db);
			sql = "select count(*) as cot from photoprint where id='" + strOderNumber + "'";
			myset.Open(CRecordset::forwardOnly, sql);
			myset.GetFieldValue("cot", sql);
			myset.Close();
			count1 = atoi(sql);
		}
		{
			CRecordset myset(pToConverted_db);
			sql = "select count(*) as cot from photoprint where id='" + strOderNumber + "'";
			myset.Open(CRecordset::forwardOnly, sql);
			myset.GetFieldValue("cot", sql);
			myset.Close();
			count2 = atoi(sql);
		}
		if (count1 > count2)//104
			pRetArray->Add("0");
		else
			pRetArray->Add("1");

		{
			CRecordset myset(pBeConverted_db);
			sql = "select count(*) as cot from client where id='" + strOderNumber + "'";
			myset.Open(CRecordset::forwardOnly, sql);
			myset.GetFieldValue("cot", sql);
			myset.Close();
			count1 = atoi(sql);
		}
		{
			CRecordset myset(pToConverted_db);
			sql = "select count(*) as cot from client where id='" + strOderNumber + "'";
			myset.Open(CRecordset::forwardOnly, sql);
			myset.GetFieldValue("cot", sql);
			myset.Close();
			count2 = atoi(sql);
		}
		if (count1 > count2)//105
			pRetArray->Add("0");
		else
			pRetArray->Add("1");

		{
			CRecordset myset(pBeConverted_db);
			sql = "select count(*) as cot from burncdreg where id='" + strOderNumber + "'";
			myset.Open(CRecordset::forwardOnly, sql);
			myset.GetFieldValue("cot", sql);
			myset.Close();
			count1 = atoi(sql);
		}
		{
			CRecordset myset(pToConverted_db);
			sql = "select count(*) as cot from burncdreg where id='" + strOderNumber + "'";
			myset.Open(CRecordset::forwardOnly, sql);
			myset.GetFieldValue("cot", sql);
			myset.Close();
			count2 = atoi(sql);
		}
		if (count1 > count2)//7
			pRetArray->Add("0");
		else
			pRetArray->Add("1");

		{
			CRecordset myset(pBeConverted_db);
			sql = "select count(*) as cot from digitalwork where id='" + strOderNumber + "'";
			myset.Open(CRecordset::forwardOnly, sql);
			myset.GetFieldValue("cot", sql);
			myset.Close();
			count1 = atoi(sql);
		}
		{
			CRecordset myset(pToConverted_db);
			sql = "select count(*) as cot from digitalwork where id='" + strOderNumber + "'";
			myset.Open(CRecordset::forwardOnly, sql);
			myset.GetFieldValue("cot", sql);
			myset.Close();
			count2 = atoi(sql);
		}
		if (count1 > count2)//8
			pRetArray->Add("0");
		else
			pRetArray->Add("1");

		{
			CRecordset myset(pBeConverted_db);
			sql = "select count(*) as cot from mywork where id='" + strOderNumber + "'";
			myset.Open(CRecordset::forwardOnly, sql);
			myset.GetFieldValue("cot", sql);
			myset.Close();
			count1 = atoi(sql);
		}
		{
			CRecordset myset(pToConverted_db);
			sql = "select count(*) as cot from mywork where id='" + strOderNumber + "'";
			myset.Open(CRecordset::forwardOnly, sql);
			myset.GetFieldValue("cot", sql);
			myset.Close();
			count2 = atoi(sql);
		}
		if (count1 > count2)//9
			pRetArray->Add("0");
		else
			pRetArray->Add("1");

		{
			CRecordset myset(pBeConverted_db);
			sql = "select count(*) as cot from dindanjd where id='" + strOderNumber + "'";
			myset.Open(CRecordset::forwardOnly, sql);
			myset.GetFieldValue("cot", sql);
			myset.Close();
			count1 = atoi(sql);
		}
		{
			CRecordset myset(pToConverted_db);
			sql = "select count(*) as cot from dindanjd where id='" + strOderNumber + "'";
			myset.Open(CRecordset::forwardOnly, sql);
			myset.GetFieldValue("cot", sql);
			myset.Close();
			count2 = atoi(sql);
		}
		if (count1 > count2)//10
			pRetArray->Add("0");
		else
			pRetArray->Add("1");

		{
			CRecordset myset(pBeConverted_db);
			sql = "select count(*) as cot from dindansp2 where id='" + strOderNumber + "'";
			myset.Open(CRecordset::forwardOnly, sql);
			myset.GetFieldValue("cot", sql);
			myset.Close();
			count1 = atoi(sql);
		}
		{
			CRecordset myset(pToConverted_db);
			sql = "select count(*) as cot from dindansp2 where id='" + strOderNumber + "'";
			myset.Open(CRecordset::forwardOnly, sql);
			myset.GetFieldValue("cot", sql);
			myset.Close();
			count2 = atoi(sql);
		}
		if (count1 > count2)
			pRetArray->Add("0");
		else
			pRetArray->Add("1");

		{
			CRecordset myset(pBeConverted_db);
			sql = "select count(*) as cot from dindansp3 where id='" + strOderNumber + "'";
			myset.Open(CRecordset::forwardOnly, sql);
			myset.GetFieldValue("cot", sql);
			myset.Close();
			count1 = atoi(sql);
		}
		{
			CRecordset myset(pToConverted_db);
			sql = "select count(*) as cot from dindansp3 where id='" + strOderNumber + "'";
			myset.Open(CRecordset::forwardOnly, sql);
			myset.GetFieldValue("cot", sql);
			myset.Close();
			count2 = atoi(sql);
		}
		if (count1 > count2)
			pRetArray->Add("0");
		else
			pRetArray->Add("1");

		for (int i = 0; i < pRetArray->GetSize(); i++)
		{
			if (pRetArray->ElementAt(i) == "0")return 100 + i;
		}
		return 1;
	}
	catch (CDBException * e)
	{
		WriteTextLog(e->m_strError);
		WriteTextLog("出错在函数check1中");
		e->Delete();
	}
	return 100;
}

BOOL CDBServerDlg::CheckPayOutExist(CDatabase *pdb1, CDatabase *pdb2, CString id)
{
	try
	{
		int count1 = 0;
		int count2 = 0;
		CString sql;
		{
			CRecordset myset(pdb1);
			sql.Format("select count(*) as cot from gudingfeiyong where [id]=%d", atol(id));
			myset.Open(CRecordset::forwardOnly, sql);
			myset.GetFieldValue("cot", sql);
			myset.Close();
			count1 = atoi(sql);
		}
		{
			CRecordset myset(pdb2);
			sql = "select count(*) as cot from gudingfeiyong where [id]='" + id + "'";
			myset.Open(CRecordset::forwardOnly, sql);
			myset.GetFieldValue("cot", sql);
			myset.Close();
			count2 = atoi(sql);
		}
		if (count1 > count2)return 0;
		return 1;
	}
	catch (...)
	{
		WriteTextLog("出错在函数check2中");
	}
	return 0;
}
BOOL CDBServerDlg::CheckIncomeExist(CDatabase *pdb1, CDatabase *pdb2, CString id, CStringArray *pretarray)
{
	try
	{
		pretarray->RemoveAll();
		int count1 = 0;
		int count2 = 0;
		CString sql;
		{
			CRecordset myset(pdb1);
			sql.Format("select count(*) as cot from singleincome where [id]=%d", atol(id));
			myset.Open(CRecordset::forwardOnly, sql);
			myset.GetFieldValue("cot", sql);
			myset.Close();
			count1 = atoi(sql);
		}
		{
			CRecordset myset(pdb2);
			sql = "select count(*) as cot from singleincome where [id]='" + id + "'";
			myset.Open(CRecordset::forwardOnly, sql);
			myset.GetFieldValue("cot", sql);
			myset.Close();
			count2 = atoi(sql);
		}
		if (count1 > count2)
			pretarray->Add("0");
		else
			pretarray->Add("1");


		{
			CRecordset myset(pdb1);
			sql.Format("select count(*) as cot from singleincomemoney where [id]='%s'", id);
			myset.Open(CRecordset::forwardOnly, sql);
			myset.GetFieldValue("cot", sql);
			myset.Close();
			count1 = atoi(sql);
		}
		{
			CRecordset myset(pdb2);
			sql.Format("select count(*) as cot from singleincomemoney where [id]='%s'", id);
			myset.Open(CRecordset::forwardOnly, sql);
			myset.GetFieldValue("cot", sql);
			myset.Close();
			count2 = atoi(sql);
		}
		if (count1 > count2)
			pretarray->Add("0");
		else
			pretarray->Add("1");



		for (int i = 0; i < pretarray->GetSize(); i++)
		{
			if (pretarray->ElementAt(i) == "0")return 0;
		}
		return 1;
	}
	catch (...)
	{
		WriteTextLog("出错在函数check3中");
	}
	return 0;
}

BOOL CDBServerDlg::CheckIncomeMoneyExist(CDatabase *pdb1, CDatabase *pdb2, CString id)
{
	try
	{
		int count1 = 0;
		int count2 = 0;
		CString sql;
		{
			CRecordset myset(pdb1);
			sql.Format("select count(*) as cot from singleincomemoney where [id]='%s'", id);
			myset.Open(CRecordset::forwardOnly, sql);
			myset.GetFieldValue("cot", sql);
			myset.Close();
			count1 = atoi(sql);
		}
		{
			CRecordset myset(pdb2);
			sql.Format("select count(*) as cot from singleincomemoney where [id]='%s'", id);
			myset.Open(CRecordset::forwardOnly, sql);
			myset.GetFieldValue("cot", sql);
			myset.Close();
			count2 = atoi(sql);
		}
		if (count1 > count2)return 0;
		return 1;
	}
	catch (...)
	{
		WriteTextLog("出错在函数check3中");
	}
	return 0;
}

/************************************************************************/
/* mark by Jeff
/* 函数：TransDinDan
/* 描述：
/* 参数：
/*		pBeConverted_db：被转换的数据库(源);
/*		pToConverted_db：要转到的数据库(目标);
/*		strOrderNumber： 订单号;
/*		nYear：			 要转换的年份;
/*
/* 返回：
/************************************************************************/
int CDBServerDlg::TransDinDan(CDatabase *pBeConverted_db, CDatabase *pToConverted_db, CString strOrderNumber, int nYear)
{
	int step = 0;
	CStringArray retarray;
	try
	{
		CString	sql, str;
		// CheckDinDanExist返回：1表示正常, 100及以上表示源数据库里记录 > 目标数据库记录;
		if (CheckDinDanExist(pBeConverted_db, pToConverted_db, strOrderNumber, &retarray) == 1)
			return 1;

		step = 1;
		CString temp;
		CODBCFieldInfo fieldinfo;
		int ret = 1;

		// 以下全是insert into 到目录数据库中;
		CRecordset myset(pBeConverted_db);
		try
		{
			if (retarray.ElementAt(0) == "0")
			{
				sql.Format("insert into [%d].[dbo].[dindan] select * from [%s].[dbo].[dindan] where id='%s'", nYear, g_nCurConvertDBName, strOrderNumber);
				MyExecuteSQL(pBeConverted_db, sql);
			}
		}
		catch (CDBException * e)
		{
			WriteTextLog("step2" + e->m_strError);
			e->Delete();
			ret = 2;
		}

		step = 2;
		try
		{
			if (retarray.ElementAt(1) == "0")
			{
				sql.Format("insert into [%d].[dbo].[dindansp] select * from [%s].[dbo].[dindansp] where id='%s'", nYear, g_nCurConvertDBName, strOrderNumber);
				MyExecuteSQL(pBeConverted_db, sql);
			}
		}
		catch (CDBException * e)
		{
			WriteTextLog("step3" + e->m_strError);
			e->Delete();
			ret = 3;
		}

		step = 3;
		try
		{
			if (retarray.ElementAt(2) == "0")
			{
				sql.Format("insert into [%d].[dbo].[dindanbukuan] ([autoid],[id],[money],[ren],[date],[bz],[kind],[ren2],[item],[paytype],[jdd],[financecheck]) select [autoid],[id],[money],[ren],[date],[bz],[kind],[ren2],[item],[paytype],[jdd],[financecheck] from [%s].[dbo].[dindanbukuan] where id='%s'", nYear, g_nCurConvertDBName, strOrderNumber);
				MyExecuteSQL(pBeConverted_db, sql);
			}
		}
		catch (CDBException * e)
		{
			WriteTextLog("step4" + e->m_strError);
			e->Delete();
			ret = 4;
		}

		step = 4;
		try
		{
			if (retarray.ElementAt(3) == "0")
			{
				sql.Format("insert into [%d].[dbo].[dindanbukuan2] ([autoid],[id],[money],[ren],[date],[bz],[kind],[ren2]) select [autoid],[id],[money],[ren],[date],[bz],[kind],[ren2] from [%s].[dbo].[dindanbukuan2] where id='%s'", nYear, g_nCurConvertDBName, strOrderNumber);
				MyExecuteSQL(pBeConverted_db, sql);
			}
		}
		catch (CDBException * e)
		{
			WriteTextLog("step5" + e->m_strError);
			e->Delete();
			ret = 5;
		}

		step = 5;
		try
		{
			if (retarray.ElementAt(4) == "0")
			{
				sql.Format("insert into [%d].[dbo].[photoprint] select * from [%s].[dbo].[photoprint] where id='%s'", nYear, g_nCurConvertDBName, strOrderNumber);
				MyExecuteSQL(pBeConverted_db, sql);
			}
		}
		catch (CDBException * e)
		{
			WriteTextLog("step6" + e->m_strError);
			e->Delete();
			ret = 6;
		}

		step = 6;
		try
		{
			if (retarray.ElementAt(5) == "0")
			{
				sql.Format("insert into [%d].[dbo].[client] select * from [%s].[dbo].[client] where id='%s'", nYear, g_nCurConvertDBName, strOrderNumber);
				MyExecuteSQL(pBeConverted_db, sql);
			}
		}
		catch (CDBException * e)
		{
			WriteTextLog("step7" + e->m_strError);
			e->Delete();
			ret = 7;
		}

		step = 7;
		try
		{
			if (retarray.ElementAt(6) == "0")
			{
				sql.Format("insert into [%d].[dbo].[burncdreg] select * from [%s].[dbo].[burncdreg] where id='%s'", nYear, g_nCurConvertDBName, strOrderNumber);
				MyExecuteSQL(pBeConverted_db, sql);
			}
		}
		catch (CDBException * e)
		{
			WriteTextLog("step8" + e->m_strError);
			e->Delete();
			ret = 8;
		}


		step = 8;
		try
		{
			if (retarray.ElementAt(7) == "0")
			{
				sql.Format("insert into [%d].[dbo].[digitalwork] select * from [%s].[dbo].[digitalwork] where id='%s'", nYear, g_nCurConvertDBName, strOrderNumber);
				MyExecuteSQL(pBeConverted_db, sql);
			}
		}
		catch (CDBException * e)
		{
			WriteTextLog("step9" + e->m_strError);
			e->Delete();
			ret = 9;
		}

		step = 9;
		try
		{
			if (retarray.ElementAt(8) == "0")
			{
				sql.Format("insert into [%d].[dbo].[mywork] select * from [%s].[dbo].[mywork] where id='%s'", nYear, g_nCurConvertDBName, strOrderNumber);
				MyExecuteSQL(pBeConverted_db, sql);
			}
		}
		catch (CDBException * e)
		{
			WriteTextLog("step10" + e->m_strError);
			e->Delete();
			ret = 10;
		}

		step = 10;
		try
		{
			if (retarray.ElementAt(9) == "0")
			{
				sql.Format("insert into [%d].[dbo].[dindanjd] select * from [%s].[dbo].[dindanjd] where id='%s'", nYear, g_nCurConvertDBName, strOrderNumber);
				MyExecuteSQL(pBeConverted_db, sql);
			}
		}
		catch (CDBException * e)
		{
			WriteTextLog("step11" + e->m_strError);
			e->Delete();
			ret = 11;
		}

		step = 11;
		try
		{
			if (retarray.ElementAt(10) == "0")
			{
				sql.Format("insert into [%d].[dbo].[dindansp2] select * from [%s].[dbo].[dindansp2] where id='%s'", nYear, g_nCurConvertDBName, strOrderNumber);
				MyExecuteSQL(pBeConverted_db, sql);
			}
		}
		catch (CDBException * e)
		{
			WriteTextLog("step12" + e->m_strError);
			e->Delete();
			ret = 12;
		}

		step = 12;
		try
		{
			if (retarray.ElementAt(11) == "0")
			{
				sql.Format("insert into [%d].[dbo].[dindansp3] select * from [%s].[dbo].[dindansp3] where id='%s'", nYear, g_nCurConvertDBName, strOrderNumber);
				MyExecuteSQL(pBeConverted_db, sql);
			}
		}
		catch (CDBException * e)
		{
			WriteTextLog("step13" + e->m_strError);
			e->Delete();
			ret = 13;
		}

		if (ret != 1)return 200 + ret;

		// 插入到目标数据库后再到目标数据库里查询是否存在;
		return CheckDinDanExist(pBeConverted_db, pToConverted_db, strOrderNumber, &retarray);
	}
	catch (...)
	{
		CString str;
		str.Format("%d size:%d", step, retarray.GetSize());
		WriteTextLog("出错在函数trans1中-" + str);
	}
	return 0;
}

BOOL CDBServerDlg::TransPayOut(CDatabase *pdb1, CDatabase *pdb2, CString id, int year)
{
	try
	{
		CString	sql;
		if (CheckPayOutExist(pdb1, pdb2, id))return 1;

		CString temp;
		CODBCFieldInfo fieldinfo;
		BOOL ret = 1;
		CRecordset myset(pdb1);
		try
		{
			sql.Format("insert into [%d].[dbo].[gudingfeiyong] select * from [%s].[dbo].[gudingfeiyong] where id=%d", year, g_nCurConvertDBName, atol(id));
			MyExecuteSQL(pdb1, sql);
		}
		catch (CDBException * e)
		{
			WriteTextLog(e->m_strError);
			e->Delete();
			ret = 0;
		}
		if (ret == 0)return 0;
		return CheckPayOutExist(pdb1, pdb2, id);
	}
	catch (...)
	{
		WriteTextLog("出错在函数trans2中");
	}
	return 0;
}
//singleincome
BOOL CDBServerDlg::TransIncome(CDatabase *pdb1, CDatabase *pdb2, CString id, int year)
{
	try
	{
		CString	sql;
		CStringArray retarray;
		if (CheckIncomeExist(pdb1, pdb2, id, &retarray))return 1;

		CString temp;
		CODBCFieldInfo fieldinfo;
		BOOL ret = 1;
		CRecordset myset(pdb1);
		try
		{
			if (retarray.ElementAt(0) == "0")
			{
				sql.Format("insert into [%d].[dbo].[singleincome] select * from [%s].[dbo].[singleincome] where id=%d", year, g_nCurConvertDBName, atol(id));
				MyExecuteSQL(pdb1, sql);
			}
		}
		catch (...)
		{
			ret = 0;
		}

		try
		{
			if (retarray.ElementAt(1) == "0")
			{
				sql.Format("insert into [%d].[dbo].[singleincomemoney] select * from [%s].[dbo].[singleincomemoney] where id='%s'", year, g_nCurConvertDBName, id);
				MyExecuteSQL(pdb1, sql);
			}
		}
		catch (CDBException * e)
		{
			WriteTextLog(e->m_strError);
			e->Delete();
			ret = 0;
		}
		if (ret == 0)return 0;
		return CheckIncomeExist(pdb1, pdb2, id, &retarray);
	}
	catch (...)
	{
		WriteTextLog("出错在函数trans3中");
	}
	return 0;
}

BOOL CDBServerDlg::TransIncomeMoney(CDatabase *pdb1, CDatabase *pdb2, CString id, int year)
{
	try
	{
		CString	sql;
		if (CheckIncomeMoneyExist(pdb1, pdb2, id))return 1;

		CString temp;
		CODBCFieldInfo fieldinfo;
		BOOL ret = 1;
		CRecordset myset(pdb1);
		try
		{
			sql.Format("insert into [%d].[dbo].[singleincomemoney] select * from [%s].[dbo].[singleincomemoney] where id='%s'", year, g_nCurConvertDBName, id);
			MyExecuteSQL(pdb1, sql);
		}
		catch (CDBException * e)
		{
			WriteTextLog(e->m_strError);
			e->Delete();
			ret = 0;
		}
		if (ret == 0)return 0;
		return CheckIncomeMoneyExist(pdb1, pdb2, id);
	}
	catch (...)
	{
		WriteTextLog("出错在函数trans3中");
	}
	return 0;
}

BOOL CDBServerDlg::Checkclient2phonerecordExist(CDatabase *pdb1, CDatabase *pdb2, CString id)
{
	try
	{
		int count1 = 0;
		int count2 = 0;
		CString sql;
		{
			CRecordset myset(pdb1);
			sql = "select count(*) as cot from client2phonerecord where [datetime]='" + id + "'";
			myset.Open(CRecordset::forwardOnly, sql);
			myset.GetFieldValue("cot", sql);
			myset.Close();
			count1 = atoi(sql);
		}
		{
			CRecordset myset(pdb2);
			sql = "select count(*) as cot from client2phonerecord where [datetime]='" + id + "'";
			myset.Open(CRecordset::forwardOnly, sql);
			myset.GetFieldValue("cot", sql);
			myset.Close();
			count2 = atoi(sql);
		}
		if (count1 > count2)return 0;
		return 1;
	}
	catch (...)
	{
		WriteTextLog("出错在函数check3中");
	}
	return 0;
}

BOOL CDBServerDlg::Transclient2phonerecord(CDatabase *pdb1, CDatabase *pdb2, CString id, int year)
{
	try
	{
		CString	sql;
		if (Checkclient2phonerecordExist(pdb1, pdb2, id))return 1;

		CString temp;
		CODBCFieldInfo fieldinfo;
		BOOL ret = 1;
		CRecordset myset(pdb1);
		try
		{
			sql.Format("insert into [%d].[dbo].[client2phonerecord] select * from [%s].[dbo].[client2phonerecord] where [datetime]='%s'", year, g_nCurConvertDBName, id);
			MyExecuteSQL(pdb1, sql);
		}
		catch (...)
		{
			ret = 0;
		}
		if (ret == 0)return 0;
		return Checkclient2phonerecordExist(pdb1, pdb2, id);
	}
	catch (...)
	{
		WriteTextLog("出错在函数trans3中");
	}
	return 0;
}
BOOL CDBServerDlg::Checkclient3phonerecordExist(CDatabase *pdb1, CDatabase *pdb2, CString id)
{
	try
	{
		int count1 = 0;
		int count2 = 0;
		CString sql;
		{
			CRecordset myset(pdb1);
			sql = "select count(*) as cot from client3phonerecord where [datetime]='" + id + "'";
			myset.Open(CRecordset::forwardOnly, sql);
			myset.GetFieldValue("cot", sql);
			myset.Close();
			count1 = atoi(sql);
		}
		{
			CRecordset myset(pdb2);
			sql = "select count(*) as cot from client3phonerecord where [datetime]='" + id + "'";
			myset.Open(CRecordset::forwardOnly, sql);
			myset.GetFieldValue("cot", sql);
			myset.Close();
			count2 = atoi(sql);
		}
		if (count1 > count2)return 0;
		return 1;
	}
	catch (...)
	{
		WriteTextLog("出错在函数check3中");
	}
	return 0;
}

BOOL CDBServerDlg::Transclient3phonerecord(CDatabase *pdb1, CDatabase *pdb2, CString id, int year)
{
	try
	{
		CString	sql;
		if (Checkclient3phonerecordExist(pdb1, pdb2, id))return 1;

		CString temp;
		CODBCFieldInfo fieldinfo;
		BOOL ret = 1;
		CRecordset myset(pdb1);
		try
		{
			sql.Format("insert into [%d].[dbo].[client3phonerecord] select * from [%s].[dbo].[client3phonerecord] where [datetime]='%s'", year, g_nCurConvertDBName, id);
			MyExecuteSQL(pdb1, sql);
		}
		catch (...)
		{
			ret = 0;
		}
		if (ret == 0)return 0;
		return Checkclient3phonerecordExist(pdb1, pdb2, id);
	}
	catch (...)
	{
		WriteTextLog("出错在函数trans3中");
	}
	return 0;
}

BOOL CDBServerDlg::Checkclient2phonerecordoutExist(CDatabase *pdb1, CDatabase *pdb2, CString id)
{
	try
	{
		int count1 = 0;
		int count2 = 0;
		CString sql;
		{
			CRecordset myset(pdb1);
			sql = "select count(*) as cot from client2phonerecordout where [datetime]='" + id + "'";
			myset.Open(CRecordset::forwardOnly, sql);
			myset.GetFieldValue("cot", sql);
			myset.Close();
			count1 = atoi(sql);
		}
		{
			CRecordset myset(pdb2);
			sql = "select count(*) as cot from client2phonerecordout where [datetime]='" + id + "'";
			myset.Open(CRecordset::forwardOnly, sql);
			myset.GetFieldValue("cot", sql);
			myset.Close();
			count2 = atoi(sql);
		}
		if (count1 > count2)return 0;
		return 1;
	}
	catch (...)
	{
		WriteTextLog("出错在函数check3中");
	}
	return 0;
}
BOOL CDBServerDlg::Transclient2phonerecordout(CDatabase *pdb1, CDatabase *pdb2, CString id, int year)
{
	try
	{
		CString	sql;
		if (Checkclient2phonerecordoutExist(pdb1, pdb2, id))return 1;

		CString temp;
		CODBCFieldInfo fieldinfo;
		BOOL ret = 1;
		CRecordset myset(pdb1);
		try
		{
			sql.Format("insert into [%d].[dbo].[client2phonerecordout] select * from [%s].[dbo].[client2phonerecordout] where [datetime]='%s'", year, g_nCurConvertDBName, id);
			MyExecuteSQL(pdb1, sql);
		}
		catch (...)
		{
			ret = 0;
		}
		if (ret == 0)return 0;
		return Checkclient2phonerecordoutExist(pdb1, pdb2, id);
	}
	catch (...)
	{
		WriteTextLog("出错在函数trans3中");
	}
	return 0;
}

BOOL CDBServerDlg::Checkclient3phonerecordoutExist(CDatabase *pdb1, CDatabase *pdb2, CString id)
{
	try
	{
		int count1 = 0;
		int count2 = 0;
		CString sql;
		{
			CRecordset myset(pdb1);
			sql = "select count(*) as cot from client3phonerecordout where [datetime]='" + id + "'";
			myset.Open(CRecordset::forwardOnly, sql);
			myset.GetFieldValue("cot", sql);
			myset.Close();
			count1 = atoi(sql);
		}
		{
			CRecordset myset(pdb2);
			sql = "select count(*) as cot from client3phonerecordout where [datetime]='" + id + "'";
			myset.Open(CRecordset::forwardOnly, sql);
			myset.GetFieldValue("cot", sql);
			myset.Close();
			count2 = atoi(sql);
		}
		if (count1 > count2)return 0;
		return 1;
	}
	catch (...)
	{
		WriteTextLog("出错在函数check3中");
	}
	return 0;
}
BOOL CDBServerDlg::Transclient3phonerecordout(CDatabase *pdb1, CDatabase *pdb2, CString id, int year)
{
	try
	{
		CString	sql;
		if (Checkclient3phonerecordoutExist(pdb1, pdb2, id))return 1;

		CString temp;
		CODBCFieldInfo fieldinfo;
		BOOL ret = 1;
		CRecordset myset(pdb1);
		try
		{
			sql.Format("insert into [%d].[dbo].[client3phonerecordout] select * from [%s].[dbo].[client3phonerecordout] where [datetime]='%s'", year, g_nCurConvertDBName, id);
			MyExecuteSQL(pdb1, sql);
		}
		catch (...)
		{
			ret = 0;
		}
		if (ret == 0)return 0;
		return Checkclient3phonerecordoutExist(pdb1, pdb2, id);
	}
	catch (...)
	{
		WriteTextLog("出错在函数trans3中");
	}
	return 0;
}

BOOL CDBServerDlg::CheckemployeephonerecordExist(CDatabase *pdb1, CDatabase *pdb2, CString id)
{
	try
	{
		int count1 = 0;
		int count2 = 0;
		CString sql;
		{
			CRecordset myset(pdb1);
			sql = "select count(*) as cot from employeephonerecord where [datetime]='" + id + "'";
			myset.Open(CRecordset::forwardOnly, sql);
			myset.GetFieldValue("cot", sql);
			myset.Close();
			count1 = atoi(sql);
		}
		{
			CRecordset myset(pdb2);
			sql = "select count(*) as cot from employeephonerecord where [datetime]='" + id + "'";
			myset.Open(CRecordset::forwardOnly, sql);
			myset.GetFieldValue("cot", sql);
			myset.Close();
			count2 = atoi(sql);
		}
		if (count1 > count2)return 0;
		return 1;
	}
	catch (...)
	{
		WriteTextLog("出错在函数check3中");
	}
	return 0;
}
BOOL CDBServerDlg::Transemployeephonerecord(CDatabase *pdb1, CDatabase *pdb2, CString id, int year)
{
	try
	{
		CString	sql;
		if (CheckemployeephonerecordExist(pdb1, pdb2, id))return 1;

		CString temp;
		CODBCFieldInfo fieldinfo;
		BOOL ret = 1;
		CRecordset myset(pdb1);
		try
		{
			sql.Format("insert into [%d].[dbo].[employeephonerecord] select * from [%s].[dbo].[employeephonerecord] where [datetime]='%s'", year, g_nCurConvertDBName, id);
			MyExecuteSQL(pdb1, sql);
		}
		catch (...)
		{
			ret = 0;
		}
		if (ret == 0)return 0;
		return CheckemployeephonerecordExist(pdb1, pdb2, id);
	}
	catch (...)
	{
		WriteTextLog("出错在函数trans3中");
	}
	return 0;
}

BOOL CDBServerDlg::CheckemployeephonerecordoutExist(CDatabase *pdb1, CDatabase *pdb2, CString id)
{
	try
	{
		int count1 = 0;
		int count2 = 0;
		CString sql;
		{
			CRecordset myset(pdb1);
			sql = "select count(*) as cot from employeephonerecordout where [datetime]='" + id + "'";
			myset.Open(CRecordset::forwardOnly, sql);
			myset.GetFieldValue("cot", sql);
			myset.Close();
			count1 = atoi(sql);
		}
		{
			CRecordset myset(pdb2);
			sql = "select count(*) as cot from employeephonerecordout where [datetime]='" + id + "'";
			myset.Open(CRecordset::forwardOnly, sql);
			myset.GetFieldValue("cot", sql);
			myset.Close();
			count2 = atoi(sql);
		}
		if (count1 > count2)return 0;
		return 1;
	}
	catch (...)
	{
		WriteTextLog("出错在函数check3中");
	}
	return 0;
}
BOOL CDBServerDlg::Transemployeephonerecordout(CDatabase *pdb1, CDatabase *pdb2, CString id, int year)
{
	try
	{
		CString	sql;
		if (CheckemployeephonerecordoutExist(pdb1, pdb2, id))return 1;

		CString temp;
		CODBCFieldInfo fieldinfo;
		BOOL ret = 1;
		CRecordset myset(pdb1);
		try
		{
			sql.Format("insert into [%d].[dbo].[employeephonerecordout] select * from [%s].[dbo].[employeephonerecordout] where [datetime]='%s'", year, g_nCurConvertDBName, id);
			MyExecuteSQL(pdb1, sql);
		}
		catch (...)
		{
			ret = 0;
		}
		if (ret == 0)return 0;
		return CheckemployeephonerecordoutExist(pdb1, pdb2, id);
	}
	catch (...)
	{
		WriteTextLog("出错在函数trans3中");
	}
	return 0;
}

BOOL CDBServerDlg::CheckphonerecordExist(CDatabase *pdb1, CDatabase *pdb2, CString id)
{
	try
	{
		int count1 = 0;
		int count2 = 0;
		CString sql;
		{
			CRecordset myset(pdb1);
			sql = "select count(*) as cot from phonerecord where [datetime]='" + id + "'";
			myset.Open(CRecordset::forwardOnly, sql);
			myset.GetFieldValue("cot", sql);
			myset.Close();
			count1 = atoi(sql);
		}
		{
			CRecordset myset(pdb2);
			sql = "select count(*) as cot from phonerecord where [datetime]='" + id + "'";
			myset.Open(CRecordset::forwardOnly, sql);
			myset.GetFieldValue("cot", sql);
			myset.Close();
			count2 = atoi(sql);
		}
		if (count1 > count2)return 0;
		return 1;
	}
	catch (...)
	{
		WriteTextLog("出错在函数check3中");
	}
	return 0;
}
BOOL CDBServerDlg::Transphonerecord(CDatabase *pdb1, CDatabase *pdb2, CString id, int year)
{
	try
	{
		CString	sql;
		if (CheckphonerecordExist(pdb1, pdb2, id))return 1;

		CString temp;
		CODBCFieldInfo fieldinfo;
		BOOL ret = 1;
		CRecordset myset(pdb1);
		try
		{
			sql.Format("insert into [%d].[dbo].[phonerecord] select * from [%s].[dbo].[phonerecord] where [datetime]='%s'", year, g_nCurConvertDBName, id);
			MyExecuteSQL(pdb1, sql);
		}
		catch (...)
		{
			ret = 0;
		}
		if (ret == 0)return 0;
		return CheckphonerecordExist(pdb1, pdb2, id);
	}
	catch (...)
	{
		WriteTextLog("出错在函数trans3中");
	}
	return 0;
}

BOOL CDBServerDlg::CheckphonerecordoutExist(CDatabase *pdb1, CDatabase *pdb2, CString id)
{
	try
	{
		int count1 = 0;
		int count2 = 0;
		CString sql;
		{
			CRecordset myset(pdb1);
			sql = "select count(*) as cot from phonerecordout where [datetime]='" + id + "'";
			myset.Open(CRecordset::forwardOnly, sql);
			myset.GetFieldValue("cot", sql);
			myset.Close();
			count1 = atoi(sql);
		}
		{
			CRecordset myset(pdb2);
			sql = "select count(*) as cot from phonerecordout where [datetime]='" + id + "'";
			myset.Open(CRecordset::forwardOnly, sql);
			myset.GetFieldValue("cot", sql);
			myset.Close();
			count2 = atoi(sql);
		}
		if (count1 > count2)return 0;
		return 1;
	}
	catch (...)
	{
		WriteTextLog("出错在函数check3中");
	}
	return 0;
}
BOOL CDBServerDlg::Transphonerecordout(CDatabase *pdb1, CDatabase *pdb2, CString id, int year)
{
	try
	{
		CString	sql;
		if (CheckphonerecordoutExist(pdb1, pdb2, id))return 1;

		CString temp;
		CODBCFieldInfo fieldinfo;
		BOOL ret = 1;
		CRecordset myset(pdb1);
		try
		{
			sql.Format("insert into [%d].[dbo].[phonerecordout] select * from [%s].[dbo].[phonerecordout] where [datetime]='%s'", year, g_nCurConvertDBName, id);
			MyExecuteSQL(pdb1, sql);
		}
		catch (...)
		{
			ret = 0;
		}
		if (ret == 0)return 0;
		return CheckphonerecordoutExist(pdb1, pdb2, id);
	}
	catch (...)
	{
		WriteTextLog("出错在函数trans3中");
	}
	return 0;
}

BOOL CDBServerDlg::CheckunknownphonerecordExist(CDatabase *pdb1, CDatabase *pdb2, CString id)
{
	try
	{
		int count1 = 0;
		int count2 = 0;
		CString sql;
		{
			CRecordset myset(pdb1);
			sql = "select count(*) as cot from unknownphonerecord where [datetime]='" + id + "'";
			myset.Open(CRecordset::forwardOnly, sql);
			myset.GetFieldValue("cot", sql);
			myset.Close();
			count1 = atoi(sql);
		}
		{
			CRecordset myset(pdb2);
			sql = "select count(*) as cot from unknownphonerecord where [datetime]='" + id + "'";
			myset.Open(CRecordset::forwardOnly, sql);
			myset.GetFieldValue("cot", sql);
			myset.Close();
			count2 = atoi(sql);
		}
		if (count1 > count2)return 0;
		return 1;
	}
	catch (...)
	{
		WriteTextLog("出错在函数check3中");
	}
	return 0;
}
BOOL CDBServerDlg::Transunknownphonerecord(CDatabase *pdb1, CDatabase *pdb2, CString id, int year)
{
	try
	{
		CString	sql;
		if (CheckunknownphonerecordExist(pdb1, pdb2, id))return 1;

		CString temp;
		CODBCFieldInfo fieldinfo;
		BOOL ret = 1;
		CRecordset myset(pdb1);
		try
		{
			sql.Format("insert into [%d].[dbo].[unknownphonerecord] select * from [%s].[dbo].[unknownphonerecord] where [datetime]='%s'", year, g_nCurConvertDBName, id);
			MyExecuteSQL(pdb1, sql);
		}
		catch (...)
		{
			ret = 0;
		}
		if (ret == 0)return 0;
		return CheckunknownphonerecordExist(pdb1, pdb2, id);
	}
	catch (...)
	{
		WriteTextLog("出错在函数trans3中");
	}
	return 0;
}

BOOL CDBServerDlg::CheckunknownphonerecordoutExist(CDatabase *pdb1, CDatabase *pdb2, CString id)
{
	try
	{
		int count1 = 0;
		int count2 = 0;
		CString sql;
		{
			CRecordset myset(pdb1);
			sql = "select count(*) as cot from unknownphonerecordout where [datetime]='" + id + "'";
			myset.Open(CRecordset::forwardOnly, sql);
			myset.GetFieldValue("cot", sql);
			myset.Close();
			count1 = atoi(sql);
		}
		{
			CRecordset myset(pdb2);
			sql = "select count(*) as cot from unknownphonerecordout where [datetime]='" + id + "'";
			myset.Open(CRecordset::forwardOnly, sql);
			myset.GetFieldValue("cot", sql);
			myset.Close();
			count2 = atoi(sql);
		}
		if (count1 > count2)return 0;
		return 1;
	}
	catch (...)
	{
		WriteTextLog("出错在函数check3中");
	}
	return 0;
}
BOOL CDBServerDlg::Transunknownphonerecordout(CDatabase *pdb1, CDatabase *pdb2, CString id, int year)
{
	try
	{
		CString	sql;
		if (CheckunknownphonerecordoutExist(pdb1, pdb2, id))return 1;

		CString temp;
		CODBCFieldInfo fieldinfo;
		BOOL ret = 1;
		CRecordset myset(pdb1);
		try
		{
			sql.Format("insert into [%d].[dbo].[unknownphonerecordout] select * from [%s].[dbo].[unknownphonerecordout] where [datetime]='%s'", year, g_nCurConvertDBName, id);
			MyExecuteSQL(pdb1, sql);
		}
		catch (...)
		{
			ret = 0;
		}
		if (ret == 0)return 0;
		return CheckunknownphonerecordoutExist(pdb1, pdb2, id);
	}
	catch (...)
	{
		WriteTextLog("出错在函数trans3中");
	}
	return 0;
}

BOOL CDBServerDlg::CheckmisscallrecordExist(CDatabase *pdb1, CDatabase *pdb2, CString id)
{
	try
	{
		int count1 = 0;
		int count2 = 0;
		CString sql;
		{
			CRecordset myset(pdb1);
			sql = "select count(*) as cot from misscallrecord where [datetime]='" + id + "'";
			myset.Open(CRecordset::forwardOnly, sql);
			myset.GetFieldValue("cot", sql);
			myset.Close();
			count1 = atoi(sql);
		}
		{
			CRecordset myset(pdb2);
			sql = "select count(*) as cot from misscallrecord where [datetime]='" + id + "'";
			myset.Open(CRecordset::forwardOnly, sql);
			myset.GetFieldValue("cot", sql);
			myset.Close();
			count2 = atoi(sql);
		}
		if (count1 > count2)return 0;
		return 1;
	}
	catch (...)
	{
		WriteTextLog("出错在函数check3中");
	}
	return 0;
}
BOOL CDBServerDlg::Transmisscallrecord(CDatabase *pdb1, CDatabase *pdb2, CString id, int year)
{
	try
	{
		CString	sql;
		if (CheckmisscallrecordExist(pdb1, pdb2, id))return 1;

		CString temp;
		CODBCFieldInfo fieldinfo;
		BOOL ret = 1;
		CRecordset myset(pdb1);
		try
		{
			sql.Format("insert into [%d].[dbo].[misscallrecord] select * from [%s].[dbo].[misscallrecord] where [datetime]='%s'", year, g_nCurConvertDBName, id);
			MyExecuteSQL(pdb1, sql);
		}
		catch (...)
		{
			ret = 0;
		}
		if (ret == 0)return 0;
		return CheckmisscallrecordExist(pdb1, pdb2, id);
	}
	catch (...)
	{
		WriteTextLog("出错在函数trans3中");
	}
	return 0;
}

BOOL CDBServerDlg::CheckSendReg(CDatabase *pdb1, CDatabase *pdb2, CString id)
{
	try
	{
		int count1 = 0;
		int count2 = 0;
		CString sql;
		{
			CRecordset myset(pdb1);
			sql.Format("select count(*) as cot from sendreg where [timestamp]='%s'", id);
			myset.Open(CRecordset::forwardOnly, sql);
			myset.GetFieldValue("cot", sql);
			myset.Close();
			count1 = atoi(sql);
		}
		{
			CRecordset myset(pdb2);
			sql.Format("select count(*) as cot from sendreg where [timestamp]='%s'", id);
			myset.Open(CRecordset::forwardOnly, sql);
			myset.GetFieldValue("cot", sql);
			myset.Close();
			count2 = atoi(sql);
		}
		if (count1 > count2)return 0;
		return 1;
	}
	catch (...)
	{
		WriteTextLog("出错在函数check3中");
	}
	return 0;
}

BOOL CDBServerDlg::TransSendReg(CDatabase *pdb1, CDatabase *pdb2, CString id, int year)
{
	try
	{
		CString	sql;
		if (CheckSendReg(pdb1, pdb2, id))return 1;

		CString temp;
		CODBCFieldInfo fieldinfo;
		BOOL ret = 1;
		CRecordset myset(pdb1);
		try
		{
			sql.Format("insert into [%d].[dbo].[sendreg] select * from [%s].[dbo].[sendreg] where [timestamp]='%s'", year, g_nCurConvertDBName, id);
			MyExecuteSQL(pdb1, sql);
		}
		catch (...)
		{
			ret = 0;
		}
		if (ret == 0)return 0;
		return CheckSendReg(pdb1, pdb2, id);
	}
	catch (...)
	{
		WriteTextLog("出错在函数trans3中");
	}
	return 0;
}
void CDBServerDlg::MyExecuteSQL(CDatabase* pdb, CString sql)
{
	try
	{
		MyLock lock("dbaccessxiao");
		pdb->ExecuteSQL(sql);
	}
	catch (...)
	{
		//	WriteTextLog("出错在函数executesql中");
	}
}

void CDBServerDlg::UpdateDate()
{
	try
	{
		/*	CString tm,sql;
		tm=CTime::GetCurrentTime ().Format ("%Y-%m-%d");
		sql.Format ("update version set curdate='%s'",tm);
		MyExecuteSQL(&g_db, sql);
		*/

		/*	CTime tm2=CTime::GetCurrentTime ();
		CTimeSpan dt2(365, 0, 0, 0);
		tm2-=dt2;
		tm=tm2.Format ("%Y%m%d%H%M%S");
		sql.Format ("delete from sendreg where timestamp<'%s'",tm);
		MyExecuteSQL(&g_db, sql);*/


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

		CString autorunpath = g_mainpath + "\\AutoRun.exe";
		if (0 == g_bConvertHisAll)
			ShellExecute(NULL, _T("open"), g_mainpath + "\\AutoRun.exe", NULL, NULL, SW_HIDE);

		autorunpath = g_mainpath + "\\MsgServer.exe";
		ShellExecute(NULL, _T("open"), autorunpath, NULL, NULL, SW_HIDE);

#ifdef ENTERPRISE_VERSION
		autorunpath = g_mainpath + "\\DataSyncReceive.exe";
		ShellExecute(NULL, _T("open"), autorunpath, NULL, NULL, SW_HIDE);
		autorunpath = g_mainpath + "\\DataSyncSend.exe";
		ShellExecute(NULL, _T("open"), autorunpath, NULL, NULL, SW_HIDE);
		autorunpath = g_mainpath + "\\CPhotoFTPReceive.exe";
		ShellExecute(NULL, _T("open"), autorunpath, NULL, NULL, SW_HIDE);
		autorunpath = g_mainpath + "\\CPhotoFTPSend.exe";
		ShellExecute(NULL, _T("open"), autorunpath, NULL, NULL, SW_HIDE);
#endif
	}
	catch (...)
	{
		WriteTextLog("出错在函数UpdateDate中");
	}
}

BOOL CheckDateOK(CString str)
{
	try
	{
		CString tip;
		int i;
		CString demo = CTime::GetCurrentTime().Format("%Y-%m-%d");
		if (str.GetLength() != demo.GetLength())
			goto ll;
		//2009-01-01
		if (str.GetAt(4) != '-')
			goto ll;
		if (str.GetAt(7) != '-')
			goto ll;
		for (i = 0; i < str.GetLength(); i++)
		{
			if (i == 4 || i == 7)continue;
			if (str.GetAt(i) < '0' || str.GetAt(i) > '9')
				goto ll;
		}
		return 1;
	ll:
		return 0;
	}
	catch (...)
	{
		WriteTextLog("出错");
	}
}

//--------------------------------------------------------------------------
// Remark by Jeff:2014.10.22
// 函数：AutoDelPhoto
// 描述：自动删除取件后的订单相片，包括客户原片、初修片、精修片、设计片。（不含备份相片）
// 参数：#
// 返回：#
//
// 调用关系：
// 1.AutoDelPhoto()由 BakPhoto()调用。
// 2.BakPhoto（）由CDBServerDlg::SetTimer(4) 调用,调用频率2分钟，周期数直到程序结束。
// 3.CDBServerDlg::SetTimer(4) 由 CDBServerDlg::SetTimer(2) 调用,调用频率10毫秒，只有一个周期。
// 4.CDBServerDlg::SetTimer(2) 由 CDBServerDlg::OnInitDialog() 调用.
//
//--------------------------------------------------------------------------
void CDBServerDlg::AutoDelPhoto()	// Jeff自动删除取件后的订单相片;
{
	try
	{
#ifdef ENTERPRISE_VERSION
		GenYLGL();
#endif
		g_curdb = &g_db;

		CString	m_check1;	// 自动删除客人原片;
		CString m_check2;	// 自动删除客人初修片;
		CString m_check3;	// 自动删除客人精修片;
		CString m_check4;	// 自动删除客人设计片;

		CString	m_edit1;	// 多少个月后删除原片;
		CString m_edit2;	// 多少个月后删除初修片;
		CString m_edit3;	// 多少个月后删除精修片;
		CString m_edit4;	// 多少个月后删除设计片;

		CString	m_bakserver1;	// 自动备份客人原片的备份机器;
		CString m_bakserver2;	// 自动备份客人初修片的备份机器
		CString m_bakserver3;	// 自动备份客人精修片的备份机器;
		CString m_bakserver4;	// 自动备份客人设计片的备份机器;
		// CDBServerDlg::m_bakserver5 : 自动备份系统数据的备份机器;

		// 1.从version表中获取状态信息;
		CRstversion tableOfVersion;
		tableOfVersion.m_pDatabase = g_curdb;
		tableOfVersion.Open();
		if (!tableOfVersion.IsEOF())
		{
			m_check1 = tableOfVersion.m_check1;
			m_check2 = tableOfVersion.m_check2;
			m_check3 = tableOfVersion.m_check3;
			m_check4 = tableOfVersion.m_check4;
			m_edit1 = tableOfVersion.m_edit1;
			m_edit2 = tableOfVersion.m_edit2;
			m_edit3 = tableOfVersion.m_edit3;
			m_edit4 = tableOfVersion.m_edit4;
			m_bakserver1 = tableOfVersion.m_bakserver1;
			m_bakserver2 = tableOfVersion.m_bakserver2;
			m_bakserver3 = tableOfVersion.m_bakserver3;
			m_bakserver4 = tableOfVersion.m_bakserver4;
			m_bakserver5 = tableOfVersion.m_bakserver5;
		}
		tableOfVersion.Close();

		// 2.
		g_bakinfo = "资料未备份";
		g_bakphoto = "照片未备份";
		WriteTextLog("开始备份数据库");
		if (!m_bakserver5.IsEmpty())	// 自动备份系统数据的备份机器;
		{
			CString bakpath;
			CString localname;
			localname = g_localname;
#ifdef CHILD_VERSION
			if (m_bakserver5.Find(":") == -1 && m_bakserver5 != "")
				m_bakserver5 = "\\\\" + m_bakserver5 + "\\数据备份(儿童管理软件)$";
			if (1)//localname.CompareNoCase (m_bakserver5)==0 || CompareIP(localname, m_bakserver5)==0)
				GetPathFromNetShareName("数据备份(儿童管理软件)$", m_bakserver5);
#else
			if (m_bakserver5.Find(":") == -1 && m_bakserver5 != "")
				m_bakserver5 = "\\\\" + m_bakserver5 + "\\数据备份(管理软件)$";
			if (1)//localname.CompareNoCase (m_bakserver5)==0 || CompareIP(localname, m_bakserver5)==0)
				GetPathFromNetShareName("数据备份(管理软件)$", m_bakserver5);
#endif
			WriteTextLog(m_bakserver5);
			if (::CheckFolderFileExist(m_bakserver5))
				BakData(m_bakserver5, 1, 1);
		}
		WriteTextLog("数据库备份完成");	// Jeff:只是备份数据库;

		BOOL bcheck1 = atoi(m_check1);
		BOOL bcheck2 = atoi(m_check2);
		BOOL bcheck3 = atoi(m_check3);
		BOOL bcheck4 = atoi(m_check4);

#if 0	// Jeff:old code;
		if (!(bcheck1 || bcheck2 || bcheck3 || bcheck4))
		{
			return;
		}
#else
		// 四个同时为假,退出删除操作;
		if (!(bcheck1 | bcheck2 | bcheck3 | bcheck4))
		{
			return;
		}
#endif
		int edit1 = atoi(m_edit1);
		int edit2 = atoi(m_edit2);
		int edit3 = atoi(m_edit3);
		int edit4 = atoi(m_edit4);

		// path 4种类型相片的存储目录;
		CStringArray patharray;
		{
			char server[50];
			DWORD leng = 50;
			::GetComputerName(server, &leng);
			CString spathserver = server;
			CString g_path1;
			CString g_path2;
			CString g_path3;
			CString g_path4;
			g_path1 = g_path2 = g_path3 = g_path4 = server;
			g_path1 = "\\\\" + g_path1 + "\\客户原片(管理软件)$";
			g_path2 = "\\\\" + g_path2 + "\\修好的片(管理软件)$";
			g_path3 = "\\\\" + g_path3 + "\\设计好的片(管理软件)$";
			g_path4 = "\\\\" + g_path4 + "\\精修好的片(管理软件)$";

			GetPathFromNetShareName("客户原片(管理软件)$", g_path1);
			GetPathFromNetShareName("修好的片(管理软件)$", g_path2);
			GetPathFromNetShareName("设计好的片(管理软件)$", g_path3);
			GetPathFromNetShareName("精修好的片(管理软件)$", g_path4);

			patharray.Add(g_path1);
			patharray.Add(g_path2);
			patharray.Add(g_path4);
			patharray.Add(g_path3);
		}
		if (patharray.GetSize() == 0)
			return;

		CArray<CDatabase*, CDatabase*>dbarray2;
		dbarray2.Copy(g_dbHistoryArray);
		dbarray2.InsertAt(0, &g_db);

		//------------------------------------------------------------------------------------------------------------------------
		WriteTextLog("开始删除取件后照片");
		for (int n = 0; n < min(3, dbarray2.GetSize()); n++)
		{
			g_curdb = dbarray2.ElementAt(n);
			CArray<CStringArray, CStringArray>strArrayOfPhoto2BeDel;

			CString filter = "status3='OK' and time5 is not null and time5<>''";
			CRecordset myset(g_curdb);
			CString	sql = "select count(*) as cot from dindan";
			if (!filter.IsEmpty())
				sql += " where " + filter;
			myset.Open(CRecordset::forwardOnly, sql);
			myset.GetFieldValue("cot", sql);
			myset.Close();
			int count = atol(sql);
			if (count == 0)continue;

			strArrayOfPhoto2BeDel.SetSize(count, 1);
			CRstDindanForm rsSt;
			rsSt.m_pDatabase = g_curdb;
			if (!filter.IsEmpty())
				rsSt.m_strFilter = filter;
			rsSt.Open();
			INT_PTR nIndex = 0;
			while (!rsSt.IsEOF())
			{
				strArrayOfPhoto2BeDel.ElementAt(nIndex).RemoveAll();
				strArrayOfPhoto2BeDel.ElementAt(nIndex).Add(rsSt.id);
				strArrayOfPhoto2BeDel.ElementAt(nIndex).Add(rsSt.time5);
				nIndex++;
				rsSt.MoveNext();
				if (strArrayOfPhoto2BeDel.GetSize() <= nIndex)break;
			}
			rsSt.Close();
			strArrayOfPhoto2BeDel.SetSize(nIndex, 1);

			CString time5;
			CString id;
			CTime curtm = CTime::GetCurrentTime();
			CString strtime;
			for (int i = 0; i < strArrayOfPhoto2BeDel.GetSize(); i++)
			{
				id = strArrayOfPhoto2BeDel.ElementAt(i).ElementAt(0);
				time5 = strArrayOfPhoto2BeDel.ElementAt(i).ElementAt(1);
				if (bcheck1)//原片
				{
					CTimeSpan sp(edit1 * 30, 0, 0, 0);
					CTime tm = curtm - sp;
					strtime = tm.Format("%Y-%m-%d");
					if (strtime > time5)	// Jeff,这种比较是否正确???
					{
						if (DelPhoto1(patharray.ElementAt(0), strArrayOfPhoto2BeDel.ElementAt(i).ElementAt(0)))
							WriteTextLog("原片" + patharray.ElementAt(0) + "\\" + strArrayOfPhoto2BeDel.ElementAt(i).ElementAt(0));
						//	DelPhoto1(patharray2.ElementAt (0),g_List1array.ElementAt (i).ElementAt (0));
					}
				}
				if (bcheck2)
				{
					CTimeSpan sp(edit2 * 30, 0, 0, 0);
					CTime tm = curtm - sp;
					strtime = tm.Format("%Y-%m-%d");
					if (strtime > time5)
					{
						DelPhoto1(patharray.ElementAt(1), strArrayOfPhoto2BeDel.ElementAt(i).ElementAt(0));
						//	DelPhoto1(patharray2.ElementAt (2),g_List1array.ElementAt (i).ElementAt (0));
					}
				}
				if (bcheck3)
				{
					CTimeSpan sp(edit3 * 30, 0, 0, 0);
					CTime tm = curtm - sp;
					strtime = tm.Format("%Y-%m-%d");
					if (strtime > time5)
					{
						DelPhoto1(patharray.ElementAt(2), strArrayOfPhoto2BeDel.ElementAt(i).ElementAt(0));
						//	DelPhoto1(patharray2.ElementAt (2),g_List1array.ElementAt (i).ElementAt (0));
					}
				}
				if (bcheck4)
				{
					CTimeSpan sp(edit4 * 30, 0, 0, 0);
					CTime tm = curtm - sp;
					strtime = tm.Format("%Y-%m-%d");
					if (strtime > time5)
					{
						DelPhoto1(patharray.ElementAt(3), strArrayOfPhoto2BeDel.ElementAt(i).ElementAt(0));
					}
				}
			}
		}
		//------------------------------------------------------------------------------------------------------------------------
		g_curdb = &g_db;
#ifdef ENTERPRISE_VERSION	// Jeff:若是集团版,会再次删除本店已取件的历史订单一次。多操作了一次！
		WriteTextLog("本店查完,开始检查分店");
		CString g_domain;
		CArray<CStringArray, CStringArray>g_List1array;
		CString autorunpath = g_mainpath + "\\branchdindan.dat";
		CFile fp;
		if (fp.Open(autorunpath, CFile::modeRead))
		{
			int nMessageLen = fp.GetLength();
			BYTE *pData = new BYTE[nMessageLen];
			fp.Read(pData, nMessageLen);
			fp.Close();

			BYTE *szChatMessage = pData;
			int count;
			memcpy(&count, szChatMessage + (nMessageLen - sizeof(int)), sizeof(int));
			CMemFile memfile;
			memfile.Attach(szChatMessage, nMessageLen);
			CArchive ar(&memfile, CArchive::load);
			g_List1array.SetSize(count);
			for (int ii = 0; ii < g_List1array.GetSize(); ii++)
			{
				g_List1array.ElementAt(ii).Serialize(ar);
			}
			ar.Close();
			memfile.Detach();
			delete[]pData;
		}
		CString time5, id;
		CTime curtm = CTime::GetCurrentTime();
		CString strtime;
		for (int i = 0; i < g_List1array.GetSize(); i++)
		{
			g_domain = "\\" + g_List1array.ElementAt(i).ElementAt(0);
			if (g_domain.Find(".ly.com") == -1)continue;
			id = g_List1array.ElementAt(i).ElementAt(1);
			time5 = g_List1array.ElementAt(i).ElementAt(2);
			if (bcheck1)//原片
			{
				CTimeSpan sp(edit1 * 30, 0, 0, 0);
				CTime tm = curtm - sp;
				strtime = tm.Format("%Y-%m-%d");
				if (strtime > time5)
				{
					if (DelPhoto1(patharray.ElementAt(0) + g_domain, id))
						WriteTextLog("分店原片" + patharray.ElementAt(0) + g_domain + "\\" + id);
				}
			}
			if (bcheck2)
			{
				CTimeSpan sp(edit2 * 30, 0, 0, 0);
				CTime tm = curtm - sp;
				strtime = tm.Format("%Y-%m-%d");
				if (strtime > time5)
				{
					DelPhoto1(patharray.ElementAt(1) + g_domain, id);
					//	DelPhoto1(patharray2.ElementAt (2),id);
				}
			}
			if (bcheck3)
			{
				CTimeSpan sp(edit3 * 30, 0, 0, 0);
				CTime tm = curtm - sp;
				strtime = tm.Format("%Y-%m-%d");
				if (strtime > time5)
				{
					DelPhoto1(patharray.ElementAt(2) + g_domain, id);
					//	DelPhoto1(patharray2.ElementAt (2),id);
				}
			}
			if (bcheck4)
			{
				CTimeSpan sp(edit4 * 30, 0, 0, 0);
				CTime tm = curtm - sp;
				strtime = tm.Format("%Y-%m-%d");
				if (strtime > time5)
				{
					DelPhoto1(patharray.ElementAt(3) + g_domain, id);
				}
			}
		}
		g_curdb = &g_db;
#endif
		WriteTextLog("检查删除照片完成");
	}
	catch (...)
	{
		WriteTextLog("出错在函数AutoDelPhoto中");
	}
	g_curdb = &g_db;
}

//------------------------------------------------------------------
// Remark by Jeff:2014.10.11
// 函数：DelPhoto1
// 描述：删除指定路径下的订单文件夹;
// 参数：
//		path:				指定要删除文件的根目录;
//		strOrderNumber:		将要删除的订单号文件夹;
// 返回：
//-----------------------------------------------------------------
BOOL CDBServerDlg::DelPhoto1(CString path, CString strOrderNumber)
{
	if (path == "")
		return 0;

	if (::CheckFolderFileExist(path + "\\" + strOrderNumber))
	{
		DeleteDirectory(path + "\\" + strOrderNumber);
		return 1;
	}
}

//-----------------------------------------------------------------------
// Remark by Jeff 2014.10.22
// 函数：BakPhoto
// 描述：对影楼相片进行备份和删除取件相片
// 参数：#
// 返回：#
//
// 调用关系： 
// 1.BakPhoto（）由CDBServerDlg::SetTimer(4) 调用,调用频率2分钟，周期数直到程序结束。
// 2.CDBServerDlg::SetTimer(4) 由 CDBServerDlg::SetTimer(2) 调用,调用频率10毫秒，只有一个周期。
// 3.CDBServerDlg::SetTimer(2) 由 CDBServerDlg::OnInitDialog() 调用.
//-----------------------------------------------------------------------
void CDBServerDlg::BakPhoto() // Jeff:备份相片/删除取件相片;
{
	try
	{
		g_curdb = &g_db;
		CString	m_bak1, m_bak2, m_bak3, m_bak4, m_bak6, m_baktime;	// Jeff:m_bak6自动备份完毕后自动关机;
		CString	m_bakserver1, m_bakserver2, m_bakserver3, m_bakserver4;
		CString	msgcheck4, msgtime, msgphones, msgphones2, msgcompanyname;
		CString balance, msgaccount;
		{
			MyLock lock("dbaccessxiao");
			CRstversion rsSt;
			rsSt.m_pDatabase = g_curdb;
			rsSt.Open();
			if (!rsSt.IsEOF())
			{
				m_bak1 = rsSt.m_bak1;
				m_bak2 = rsSt.m_bak2;
				m_bak3 = rsSt.m_bak3;
				m_bak4 = rsSt.m_bak4;
				m_bakserver1 = rsSt.m_bakserver1;
				m_bakserver2 = rsSt.m_bakserver2;
				m_bakserver3 = rsSt.m_bakserver3;
				m_bakserver4 = rsSt.m_bakserver4;
				m_bak6 = rsSt.m_bak6;
				m_baktime = rsSt.m_baktime;
				msgcheck4 = rsSt.msgcheck4;
				msgtime = rsSt.msgtime;
				msgphones = rsSt.msgphones;
				msgphones2 = rsSt.msgphones2;
				msgcompanyname = rsSt.msgcompanyname;
				balance = rsSt.msgbalance;
				msgaccount = rsSt.msgaccount;
			}
			rsSt.Close();
		}
		/////////////检测发短信回财务
		if (msgphones2.IsEmpty() == 0)
		{
			MyLock lock("dbaccessxiao");
			CStringArray array, timearray;

			CString timestamp;
			timestamp = CTime::GetCurrentTime().Format("%Y-%m-%d");
			timestamp += "%";
			CRecordset myset(g_curdb);
			CString	sql = "select phones,timestamp from sendregreceive where [timestamp] like '" + timestamp + "' and [content]='001' and [status]='OK'";
			myset.Open(CRecordset::forwardOnly, sql);
			CString phones;
			while (!myset.IsEOF())
			{
				myset.GetFieldValue("phones", phones);
				myset.GetFieldValue("timestamp", timestamp);
				if (msgphones2.Find(phones) != -1)
				{
					array.Add(phones);
					timearray.Add(timestamp);
				}
				myset.MoveNext();
			}
			myset.Close();
			if (array.GetSize())
			{
				int i = 0;
				CString sql;
				for ( i = 0; i < array.GetSize(); i++)
				{
					sql = "update sendregreceive set [status]='' where [timestamp]='" + timearray.ElementAt(i) + "'";
					MyExecuteSQL(&g_db, sql);
				}
				CArray<CStringArray, CStringArray>List11array;
				CArray<CStringArray, CStringArray>List2array;
				CArray<CStringArray, CStringArray>List3array;
				CArray<CStringArray, CStringArray>other2salearray;
				CArray<CStringArray, CStringArray>memberarray;
				CString strdate = CTime::GetCurrentTime().Format("%Y-%m-%d");


				CArray<CDatabase*, CDatabase*>dbarraytemp;
				dbarraytemp.Copy(g_dbHistoryArray);
				while (dbarraytemp.GetSize()>1)
				{
					int last = dbarraytemp.GetSize() - 1;
					dbarraytemp.RemoveAt(last);
				}
				dbarraytemp.InsertAt(0, &g_db);
				for (int a = dbarraytemp.GetSize() - 1; a >= 0; a--)
				{
					g_curdb = dbarraytemp.ElementAt(a);

					CString filter = "[dat]='" + strdate + "'";
					filter = "[dat]='" + strdate + "' and ([sale2type] is null or [sale2type]='')";
					{
						CRecordset myset(g_curdb);
						CString	sql = "select count(*) as cot from singleincome"; if (!filter.IsEmpty())sql += " where " + filter;
						myset.Open(CRecordset::forwardOnly, sql);

						myset.GetFieldValue("cot", sql);
						myset.Close();
						int count = atol(sql);

						int oldsize = List2array.GetSize();
						List2array.SetSize(oldsize + count, 1);
						CRstIncomeInput rsSt; rsSt.m_pDatabase = g_curdb; if (!filter.IsEmpty())rsSt.m_strFilter = filter;
						rsSt.Open();

						int ii = 0;
						while (!rsSt.IsEOF())
						{
							List2array.ElementAt(oldsize + ii).RemoveAll();
							List2array.ElementAt(oldsize + ii).Add(rsSt.id);
							List2array.ElementAt(oldsize + ii).Add(rsSt.name);
							List2array.ElementAt(oldsize + ii).Add(rsSt.money);
							List2array.ElementAt(oldsize + ii).Add(rsSt.date);
							List2array.ElementAt(oldsize + ii).Add(rsSt.renyuan1);
							List2array.ElementAt(oldsize + ii).Add(rsSt.renyuan2);
							List2array.ElementAt(oldsize + ii).Add(rsSt.renyuan3);
							List2array.ElementAt(oldsize + ii).Add(rsSt.bz);
							List2array.ElementAt(oldsize + ii).Add(rsSt.sale2type);
							ii++;
							rsSt.MoveNext(); if (List2array.GetSize() <= ii)break;
						}
						rsSt.Close(); List2array.SetSize(oldsize + ii, 1);
					}

					filter = "[dat]='" + strdate + "'";
					{
						CRecordset myset(g_curdb);
						CString	sql = "select count(*) as cot from gudingfeiyong"; if (!filter.IsEmpty())sql += " where " + filter;
						myset.Open(CRecordset::forwardOnly, sql);
						myset.GetFieldValue("cot", sql);
						myset.Close();
						int count = atol(sql);
						int oldsize = List3array.GetSize();
						List3array.SetSize(oldsize + count, 1);
						CRstPayOutInput rsSt; rsSt.m_pDatabase = g_curdb; if (!filter.IsEmpty())rsSt.m_strFilter = filter;
						rsSt.Open();
						int ii = 0;
						while (!rsSt.IsEOF())
						{
							List3array.ElementAt(oldsize + ii).RemoveAll();
							List3array.ElementAt(oldsize + ii).Add(rsSt.id);
							List3array.ElementAt(oldsize + ii).Add(rsSt.name);
							List3array.ElementAt(oldsize + ii).Add(rsSt.money);
							List3array.ElementAt(oldsize + ii).Add(rsSt.date);
							List3array.ElementAt(oldsize + ii).Add(rsSt.renyuan1);
							List3array.ElementAt(oldsize + ii).Add(rsSt.renyuan2);
							List3array.ElementAt(oldsize + ii).Add(rsSt.bz);
							ii++;
							rsSt.MoveNext(); if (List3array.GetSize() <= ii)break;
						}
						rsSt.Close(); List3array.SetSize(oldsize + ii, 1);
					}


					filter = "[date]='" + strdate + "'";
					{
						CRecordset myset(g_curdb);
						CString	sql = "select count(*) as cot from dindanbukuan"; if (!filter.IsEmpty())sql += " where " + filter;
						myset.Open(CRecordset::forwardOnly, sql);
						myset.GetFieldValue("cot", sql);
						myset.Close();
						int count = atol(sql);
						int oldsize = List11array.GetSize();
						List11array.SetSize(oldsize + count, 1);


						CRstBuKuan rsSt; rsSt.m_pDatabase = g_curdb; if (!filter.IsEmpty())rsSt.m_strFilter = filter;
						rsSt.Open();
						int    ii = 0;
						while (!rsSt.IsEOF())
						{
							List11array.ElementAt(oldsize + ii).RemoveAll();
							List11array.ElementAt(oldsize + ii).Add(rsSt.m_id);
							List11array.ElementAt(oldsize + ii).Add(rsSt.m_ren);
							List11array.ElementAt(oldsize + ii).Add(rsSt.m_money);
							List11array.ElementAt(oldsize + ii).Add(rsSt.m_bz);
							List11array.ElementAt(oldsize + ii).Add(rsSt.m_kind);
							List11array.ElementAt(oldsize + ii).Add(rsSt.m_date);
							ii++;
							rsSt.MoveNext(); if (List11array.GetSize() <= ii)break;
						}
						rsSt.Close(); List11array.SetSize(oldsize + ii, 1);
					}

					filter = "[date]='" + strdate + "'";
					{
						CRecordset myset(g_curdb);
						CString	sql = "select count(*) as cot from singleincomemoneyview"; if (!filter.IsEmpty())sql += " where " + filter;
						myset.Open(CRecordset::forwardOnly, sql);
						myset.GetFieldValue("cot", sql);
						myset.Close();
						int count = atol(sql);

						int oldsize = other2salearray.GetSize();
						other2salearray.SetSize(oldsize + count, 1);

						CRstsingleincomemoneyview rsSt;	rsSt.m_pDatabase = g_curdb; if (!filter.IsEmpty())rsSt.m_strFilter = filter;
						rsSt.Open();
						int ii = 0;
						while (!rsSt.IsEOF())
						{
							other2salearray.ElementAt(oldsize + ii).RemoveAll();
							other2salearray.ElementAt(oldsize + ii).Add(rsSt.name);
							other2salearray.ElementAt(oldsize + ii).Add(rsSt.renyuan1);
							other2salearray.ElementAt(oldsize + ii).Add(rsSt.renyuan3);
							other2salearray.ElementAt(oldsize + ii).Add(rsSt.sale2type);
							other2salearray.ElementAt(oldsize + ii).Add(rsSt.money);
							other2salearray.ElementAt(oldsize + ii).Add(rsSt.date);
							other2salearray.ElementAt(oldsize + ii).Add(rsSt.clerk);
							other2salearray.ElementAt(oldsize + ii).Add(rsSt.paytype);
							other2salearray.ElementAt(oldsize + ii).Add(rsSt.autoid);
							other2salearray.ElementAt(oldsize + ii).Add(rsSt.financecheck);
							ii++;
							rsSt.MoveNext(); if (other2salearray.GetSize() <= ii)break;
						}
						rsSt.Close(); other2salearray.SetSize(oldsize + ii, 1);
					}

					filter = "[date]='" + strdate + "'";
					{
						CRecordset myset(g_curdb);
						CString	sql = "select count(*) as cot from memberview"; if (!filter.IsEmpty())sql += " where " + filter;
						myset.Open(CRecordset::forwardOnly, sql);
						myset.GetFieldValue("cot", sql);
						myset.Close();


						int count = atol(sql);

						int oldsize = memberarray.GetSize();
						memberarray.SetSize(oldsize + count, 1);

						memberviewReg rsSt;	rsSt.m_pDatabase = g_curdb; if (!filter.IsEmpty())rsSt.m_strFilter = filter;
						rsSt.Open();
						DWORD ii = 0;
						while (!rsSt.IsEOF())
						{
							memberarray.ElementAt(oldsize + ii).RemoveAll();
							memberarray.ElementAt(oldsize + ii).Add(rsSt.m_id);
							memberarray.ElementAt(oldsize + ii).Add(rsSt.m_memberno);
							memberarray.ElementAt(oldsize + ii).Add(rsSt.m_name);
							memberarray.ElementAt(oldsize + ii).Add(rsSt.m_money);
							memberarray.ElementAt(oldsize + ii).Add(rsSt.m_date);
							memberarray.ElementAt(oldsize + ii).Add(rsSt.m_clerk);
							memberarray.ElementAt(oldsize + ii).Add(rsSt.m_financecheck);
							memberarray.ElementAt(oldsize + ii).Add(rsSt.m_moneytype);
							ii++;
							rsSt.MoveNext(); if (memberarray.GetSize() <= ii)break;
						}
						rsSt.Close(); memberarray.SetSize(oldsize + ii, 1);
					}
				}//
				g_curdb = &g_db;


				CString str;
				int pos = 0;
				int dindanshu = 0;
				float income = 0;
				float incomedd = 0;
				float incomebk = 0;
				float incomehq = 0;
				float incomeqt = 0;
				float payout = 0;

				for (i = 0; i < List11array.GetSize(); i++)
				{
					str = List11array.ElementAt(i).ElementAt(2);
					income += atof(str);
					//		income2+=atof(str);
					if (List11array.ElementAt(i).ElementAt(3) == "预约收款")
					{
						incomedd += atof(str);
						dindanshu++;
					}
					else if (List11array.ElementAt(i).ElementAt(3) == "预约补款")
					{
						incomebk += atof(str);
					}
					else
					{
						incomehq += atof(str);
					}
					pos++;
				}
				for (i = 0; i < List2array.GetSize(); i++)
				{
					str = List2array.ElementAt(i).ElementAt(2);
					income += atof(str);
					/*	if(List2array.ElementAt (i).ElementAt (8)!="")
					{
					income2+=atof(str);
					}*/

					if (List2array.ElementAt(i).ElementAt(8) == "")
					{
						incomeqt += atof(str);
					}
					pos++;
				}
				for (i = 0; i < List3array.GetSize(); i++)
				{
					str = List3array.ElementAt(i).ElementAt(2);
					payout += atof(str);
					pos++;
				}
				for (i = 0; i < other2salearray.GetSize(); i++)
				{

					str = other2salearray.ElementAt(i).ElementAt(4);

					income += atof(str);
					incomehq += atof(str);
					pos++;
				}
				for (i = 0; i < memberarray.GetSize(); i++)
				{
					str = memberarray.ElementAt(i).ElementAt(3);
					income += atof(str);
					pos++;
				}
				CTime tm = CTime::GetCurrentTime();
				CString content = msgcompanyname + tm.Format("%Y-%m-%d");
				content += "财报:";


				str.Format("%d", (int)income);
				::ConvertToPrice(str);
				content += "收:" + str;

				str.Format("%d", (int)incomedd);
				::ConvertToPrice(str);
				content += "定:" + str;

				str.Format("%d", (int)incomebk);
				::ConvertToPrice(str);
				content += "补:" + str;

				str.Format("%d", (int)incomehq);
				::ConvertToPrice(str);
				content += "后:" + str;

				str.Format("%d", (int)incomeqt);
				::ConvertToPrice(str);
				content += "其它:" + str;


				str.Format("%d", (int)payout);
				::ConvertToPrice(str);
				content += "支出:" + str;

				str.Format("%d", (int)(income - payout));
				::ConvertToPrice(str);
				content += "净收:" + str;

				str.Format("%d", dindanshu);
				content += "定单:" + str;

				if (msgaccount != "")
				{
					if (atoi(balance) < 200)
					{
						content += "您的余额小于两百条，请及时充值。联系电话4006067068";
					}
					else if (atoi(balance) < 500)
					{
						content += "您的余额小于五百条，请及时充值。联系电话4006067068";
					}
					else if (atoi(balance) < 800)
					{
						content += "您的余额小于八百条，请及时充值。联系电话4006067068";
					}
					else if (atoi(balance) < 1000)
					{
						content += "您的余额小于一千条，请及时充值。联系电话4006067068";
					}
				}

				int count = GetLengthEx(content) / MSG_LENGTH;
				if (GetLengthEx(content) % MSG_LENGTH)
					count++;

				int phonenum = 0;
				phonenum = 1;
				count *= phonenum;
				CString scount;
				scount.Format("%d", count);
				CString timestamp = tm.Format("%Y%m%d%H%M%S");
				for (i = 0; i < 1; i++)
				{
					sql = "insert into sendreg([phones],[content],[timestamp],[msgcount],[status],[issended],[isautosend],[ren]) values('" + array.ElementAt(i) + "','" + content + "','" + timestamp + "','" + scount + "','0','0','0','系统自动发送')";
					MyExecuteSQL(&g_db, sql);
				}
			}
		}
		/////////////
		if (atoi(msgcheck4) && msgphones != "")
		{//发老板短信
			if (atoi(msgtime) <= CTime::GetCurrentTime().GetHour())
			{
				MyLock lock("dbaccessxiao");
				CString timestamp;
				timestamp = CTime::GetCurrentTime().Format("%Y%m%d");
				timestamp += "%";
				CRecordset myset(g_curdb);
				CString	sql = "select count(*) as cot from sendreg where [timestamp] like '" + timestamp + "' and [phones]='" + msgphones + "' and [isautosend]='3'";
				myset.Open(CRecordset::forwardOnly, sql);
				myset.GetFieldValue("cot", sql);
				myset.Close();
				int count = atol(sql);
				if (count == 0)
				{
					CArray<CStringArray, CStringArray>List11array;
					CArray<CStringArray, CStringArray>List2array;
					CArray<CStringArray, CStringArray>List3array;
					CArray<CStringArray, CStringArray>other2salearray;
					CArray<CStringArray, CStringArray>memberarray;
					CString strdate = CTime::GetCurrentTime().Format("%Y-%m-%d");
					CArray<CDatabase*, CDatabase*>dbarraytemp;
					dbarraytemp.Copy(g_dbHistoryArray);
					while (dbarraytemp.GetSize() > 1)
					{
						int last = dbarraytemp.GetSize() - 1;
						dbarraytemp.RemoveAt(last);
				}
					dbarraytemp.InsertAt(0, &g_db);
					for (int a = dbarraytemp.GetSize() - 1; a >= 0; a--)
					{
						g_curdb = dbarraytemp.ElementAt(a);

						CString filter = "[dat]='" + strdate + "'";
						filter = "[dat]='" + strdate + "' and ([sale2type] is null or [sale2type]='')";
						{
							CRecordset myset(g_curdb);
							CString	sql = "select count(*) as cot from singleincome"; if (!filter.IsEmpty())sql += " where " + filter;
							myset.Open(CRecordset::forwardOnly, sql);

							myset.GetFieldValue("cot", sql);
							myset.Close();
							int count = atol(sql);

							int oldsize = List2array.GetSize();
							List2array.SetSize(oldsize + count, 1);
							CRstIncomeInput rsSt; rsSt.m_pDatabase = g_curdb; if (!filter.IsEmpty())rsSt.m_strFilter = filter;
							rsSt.Open();

							int ii = 0;
							while (!rsSt.IsEOF())
							{
								List2array.ElementAt(oldsize + ii).RemoveAll();
								List2array.ElementAt(oldsize + ii).Add(rsSt.id);
								List2array.ElementAt(oldsize + ii).Add(rsSt.name);
								List2array.ElementAt(oldsize + ii).Add(rsSt.money);
								List2array.ElementAt(oldsize + ii).Add(rsSt.date);
								List2array.ElementAt(oldsize + ii).Add(rsSt.renyuan1);
								List2array.ElementAt(oldsize + ii).Add(rsSt.renyuan2);
								List2array.ElementAt(oldsize + ii).Add(rsSt.renyuan3);
								List2array.ElementAt(oldsize + ii).Add(rsSt.bz);
								List2array.ElementAt(oldsize + ii).Add(rsSt.sale2type);
								ii++;
								rsSt.MoveNext(); if (List2array.GetSize() <= ii)break;
							}
							rsSt.Close(); List2array.SetSize(oldsize + ii, 1);
						}

						filter = "[dat]='" + strdate + "'";
						{
							CRecordset myset(g_curdb);
							CString	sql = "select count(*) as cot from gudingfeiyong"; if (!filter.IsEmpty())sql += " where " + filter;
							myset.Open(CRecordset::forwardOnly, sql);
							myset.GetFieldValue("cot", sql);
							myset.Close();
							int count = atol(sql);
							int oldsize = List3array.GetSize();
							List3array.SetSize(oldsize + count, 1);
							CRstPayOutInput rsSt; rsSt.m_pDatabase = g_curdb; if (!filter.IsEmpty())rsSt.m_strFilter = filter;
							rsSt.Open();
							int ii = 0;
							while (!rsSt.IsEOF())
							{
								List3array.ElementAt(oldsize + ii).RemoveAll();
								List3array.ElementAt(oldsize + ii).Add(rsSt.id);
								List3array.ElementAt(oldsize + ii).Add(rsSt.name);
								List3array.ElementAt(oldsize + ii).Add(rsSt.money);
								List3array.ElementAt(oldsize + ii).Add(rsSt.date);
								List3array.ElementAt(oldsize + ii).Add(rsSt.renyuan1);
								List3array.ElementAt(oldsize + ii).Add(rsSt.renyuan2);
								List3array.ElementAt(oldsize + ii).Add(rsSt.bz);
								ii++;
								rsSt.MoveNext(); if (List3array.GetSize() <= ii)break;
							}
							rsSt.Close(); List3array.SetSize(oldsize + ii, 1);
						}


						filter = "[date]='" + strdate + "'";
						{
							CRecordset myset(g_curdb);
							CString	sql = "select count(*) as cot from dindanbukuan"; if (!filter.IsEmpty())sql += " where " + filter;
							myset.Open(CRecordset::forwardOnly, sql);
							myset.GetFieldValue("cot", sql);
							myset.Close();
							int count = atol(sql);
							int oldsize = List11array.GetSize();
							List11array.SetSize(oldsize + count, 1);


							CRstBuKuan rsSt; rsSt.m_pDatabase = g_curdb; if (!filter.IsEmpty())rsSt.m_strFilter = filter;
							rsSt.Open();
							int    ii = 0;
							while (!rsSt.IsEOF())
							{
								List11array.ElementAt(oldsize + ii).RemoveAll();
								List11array.ElementAt(oldsize + ii).Add(rsSt.m_id);
								List11array.ElementAt(oldsize + ii).Add(rsSt.m_ren);
								List11array.ElementAt(oldsize + ii).Add(rsSt.m_money);
								List11array.ElementAt(oldsize + ii).Add(rsSt.m_bz);
								List11array.ElementAt(oldsize + ii).Add(rsSt.m_kind);
								List11array.ElementAt(oldsize + ii).Add(rsSt.m_date);
								ii++;
								rsSt.MoveNext(); if (List11array.GetSize() <= ii)break;
							}
							rsSt.Close(); List11array.SetSize(oldsize + ii, 1);
						}

						filter = "[date]='" + strdate + "'";
						{
							CRecordset myset(g_curdb);
							CString	sql = "select count(*) as cot from singleincomemoneyview"; if (!filter.IsEmpty())sql += " where " + filter;
							myset.Open(CRecordset::forwardOnly, sql);
							myset.GetFieldValue("cot", sql);
							myset.Close();
							int count = atol(sql);

							int oldsize = other2salearray.GetSize();
							other2salearray.SetSize(oldsize + count, 1);

							CRstsingleincomemoneyview rsSt;	rsSt.m_pDatabase = g_curdb; if (!filter.IsEmpty())rsSt.m_strFilter = filter;
							rsSt.Open();
							int ii = 0;
							while (!rsSt.IsEOF())
							{
								other2salearray.ElementAt(oldsize + ii).RemoveAll();
								other2salearray.ElementAt(oldsize + ii).Add(rsSt.name);
								other2salearray.ElementAt(oldsize + ii).Add(rsSt.renyuan1);
								other2salearray.ElementAt(oldsize + ii).Add(rsSt.renyuan3);
								other2salearray.ElementAt(oldsize + ii).Add(rsSt.sale2type);
								other2salearray.ElementAt(oldsize + ii).Add(rsSt.money);
								other2salearray.ElementAt(oldsize + ii).Add(rsSt.date);
								other2salearray.ElementAt(oldsize + ii).Add(rsSt.clerk);
								other2salearray.ElementAt(oldsize + ii).Add(rsSt.paytype);
								other2salearray.ElementAt(oldsize + ii).Add(rsSt.autoid);
								other2salearray.ElementAt(oldsize + ii).Add(rsSt.financecheck);
								ii++;
								rsSt.MoveNext(); if (other2salearray.GetSize() <= ii)break;
							}
							rsSt.Close(); other2salearray.SetSize(oldsize + ii, 1);
						}

						filter = "[date]='" + strdate + "'";
						{
							CRecordset myset(g_curdb);
							CString	sql = "select count(*) as cot from memberview"; if (!filter.IsEmpty())sql += " where " + filter;
							myset.Open(CRecordset::forwardOnly, sql);
							myset.GetFieldValue("cot", sql);
							myset.Close();


							int count = atol(sql);

							int oldsize = memberarray.GetSize();
							memberarray.SetSize(oldsize + count, 1);

							memberviewReg rsSt;	rsSt.m_pDatabase = g_curdb; if (!filter.IsEmpty())rsSt.m_strFilter = filter;
							rsSt.Open();
							DWORD ii = 0;
							while (!rsSt.IsEOF())
							{
								memberarray.ElementAt(oldsize + ii).RemoveAll();
								memberarray.ElementAt(oldsize + ii).Add(rsSt.m_id);
								memberarray.ElementAt(oldsize + ii).Add(rsSt.m_memberno);
								memberarray.ElementAt(oldsize + ii).Add(rsSt.m_name);
								memberarray.ElementAt(oldsize + ii).Add(rsSt.m_money);
								memberarray.ElementAt(oldsize + ii).Add(rsSt.m_date);
								memberarray.ElementAt(oldsize + ii).Add(rsSt.m_clerk);
								memberarray.ElementAt(oldsize + ii).Add(rsSt.m_financecheck);
								memberarray.ElementAt(oldsize + ii).Add(rsSt.m_moneytype);
								ii++;
								rsSt.MoveNext(); if (memberarray.GetSize() <= ii)break;
							}
							rsSt.Close(); memberarray.SetSize(oldsize + ii, 1);
						}
					}//
					g_curdb = &g_db;


					CString str;
					int pos = 0;
					int dindanshu = 0;
					float income = 0;
					float incomedd = 0;
					float incomebk = 0;
					float incomehq = 0;
					float incomeqt = 0;
					float payout = 0;

					int i = 0;
					for (i = 0; i < List11array.GetSize(); i++)
					{
						str = List11array.ElementAt(i).ElementAt(2);
						income += atof(str);
						//		income2+=atof(str);
						if (List11array.ElementAt(i).ElementAt(3) == "预约收款")
						{
							incomedd += atof(str);
							dindanshu++;
						}
						else if (List11array.ElementAt(i).ElementAt(3) == "预约补款")
						{
							incomebk += atof(str);
						}
						else
						{
							incomehq += atof(str);
						}
						pos++;
					}

					for (i = 0; i < List2array.GetSize(); i++)
					{
						str = List2array.ElementAt(i).ElementAt(2);
						income += atof(str);
						/*	if(List2array.ElementAt (i).ElementAt (8)!="")
						{
						income2+=atof(str);
						}*/

						if (List2array.ElementAt(i).ElementAt(8) == "")
						{
							incomeqt += atof(str);
						}
						pos++;
					}

					for (i = 0; i < List3array.GetSize(); i++)
					{
						str = List3array.ElementAt(i).ElementAt(2);
						payout += atof(str);
						pos++;
					}
					for (i = 0; i < other2salearray.GetSize(); i++)
					{
						str = other2salearray.ElementAt(i).ElementAt(4);
						income += atof(str);
						incomehq += atof(str);
						pos++;
					}
					for (i = 0; i < memberarray.GetSize(); i++)
					{
						str = memberarray.ElementAt(i).ElementAt(3);
						income += atof(str);
						pos++;
					}


					CTime tm = CTime::GetCurrentTime();
					CString content = msgcompanyname + tm.Format("%Y-%m-%d");
					content += "财报:";


					str.Format("%d", (int)income);
					::ConvertToPrice(str);
					content += "收:" + str;

					str.Format("%d", (int)incomedd);
					::ConvertToPrice(str);
					content += "定:" + str;

					str.Format("%d", (int)incomebk);
					::ConvertToPrice(str);
					content += "补:" + str;

					str.Format("%d", (int)incomehq);
					::ConvertToPrice(str);
					content += "后:" + str;

					str.Format("%d", (int)incomeqt);
					::ConvertToPrice(str);
					content += "其它:" + str;


					str.Format("%d", (int)payout);
					::ConvertToPrice(str);
					content += "支出:" + str;

					str.Format("%d", (int)(income - payout));
					::ConvertToPrice(str);
					content += "净收:" + str;

					str.Format("%d", dindanshu);
					content += "定单:" + str;

					if (msgaccount != "")
					{
						if (atoi(balance) < 200)
						{
							content += "您的余额小于两百条，请及时充值。联系电话4006067068";
						}
						else if (atoi(balance) < 500)
						{
							content += "您的余额小于五百条，请及时充值。联系电话4006067068";
						}
						else if (atoi(balance) < 800)
						{
							content += "您的余额小于八百条，请及时充值。联系电话4006067068";
						}
						else if (atoi(balance) < 1000)
						{
							content += "您的余额小于一千条，请及时充值。联系电话4006067068";
						}
					}


					int count = GetLengthEx(content) / MSG_LENGTH;
					if (GetLengthEx(content) % MSG_LENGTH)
						count++;

					int phonenum = 0;
					str = msgphones;
					pos = str.Find(",");
					if (pos != -1)
					{
						while (pos != -1)
						{
							phonenum++;
							str = str.Right(str.GetLength() - pos - 1);
							pos = str.Find(",");
						}
						phonenum++;
					}
					else
						phonenum = 1;
					count *= phonenum;

					CString scount;
					scount.Format("%d", count);
					timestamp = tm.Format("%Y%m%d%H%M%S");
					sql = "insert into sendreg([phones],[content],[timestamp],[msgcount],[status],[issended],[isautosend],[ren]) values('" + msgphones + "','" + content + "','" + timestamp + "','" + scount + "','0','0','3','系统自动发送')";
					MyExecuteSQL(&g_db, sql);
	}
}
		}

		BOOL bcheck1 = atoi(m_bak1);
		BOOL bcheck2 = atoi(m_bak2);
		BOOL bcheck3 = atoi(m_bak3);
		BOOL bcheck4 = atoi(m_bak4);


		int hour;
		hour = CTime::GetCurrentTime().GetHour();

		// Jeff.这里不合理.如果条件不成立，那当天的数据就不会执行。存在一定安全问题。
		if (atoi(m_baktime) <= hour)
		{
			CStdioFile fp;
			if (fp.Open(g_mainpath + "\\log.txt", CFile::modeRead))
			{
				CString date;
				fp.ReadString(date);
				date.TrimRight("\r\n");
				if (date == CTime::GetCurrentTime().Format("%Y-%m-%d"))
				{
					fp.Close();
					return;
				}
				fp.Close();
			}
			if (g_bConvertHisAll)
			{
				WriteTextLog("转历史数据中, 备份退出");
				return;
			}
			g_bakdate = CTime::GetCurrentTime().Format("%Y-%m-%d");
			KillTimer(4);
			WriteTextLog("备份开始...");

			AutoDelPhoto();
			AutoDelBakPhoto();
			LoadThumbImages2();
		}
	}
	catch (...)
	{
		WriteTextLog("出错在函数bakphoto中");
	}
}

void CDBServerDlg::ShutDown() //Jeff:备份完毕后执行的关机函数;
{
	try
	{
		g_curdb = &g_db;
		CString	m_bak6;
		{
			CRecordset myset(g_curdb);
			CString	sql = "select * from [version]";
			myset.Open(CRecordset::forwardOnly, sql);
			myset.GetFieldValue("bak6", m_bak6);
			myset.Close();
		}
		OnServerStop();	// 停止服务;

		// Jeff.关闭数据库连接,若关机前关闭了数据库的连接,则客户端进行订单无法实现数据库的操作;
		// Jeff.在关机前,不能关闭数据库连接;
		g_db.Close();
		for (int i = 0; i < g_dbHistoryArray.GetSize(); i++)
		{
			g_dbHistoryArray.ElementAt(i)->Close();
			delete g_dbHistoryArray.ElementAt(i);
		}
		ReleaseBranchDB();

		WriteTextLog("备份完成");
		while (m_bRunning)
		{
			::Sleep(1000);
		}
		////////////////
		g_tisks = ::GetTickCount() - g_tisks;
		CString str;
		str.Format("耗时:%d分钟", g_tisks / 60000);

		CStdioFile fp;
		fp.Open(g_mainpath + "\\log.txt", CFile::modeCreate | CFile::modeWrite);
		CTime tm = CTime::GetCurrentTime();
		if (0)//tm.GetHour ()<5)
		{
			CTimeSpan sp(1, 0, 0, 0);
			tm -= sp;
			fp.WriteString(tm.Format("%Y-%m-%d"));
			fp.WriteString("\r\n");
			fp.WriteString(CTime::GetCurrentTime().Format("%Y-%m-%d %H:%M:%S"));
			fp.WriteString(str);
		}
		else
		{
			fp.WriteString(g_bakdate);
			fp.WriteString("\r\n");
			fp.WriteString(tm.Format("%Y-%m-%d %H:%M:%S"));
			fp.WriteString(str);
		}
		fp.WriteString("\r\n");
		fp.WriteString(g_bakinfo);
		fp.WriteString("\r\n");
		fp.WriteString(g_bakphoto);
		fp.Close();

		//	OnButton3();
		// Jeff.备份完成后自动关机;
		if (atoi(m_bak6))
		{
#if 1
			// Jeff.关闭运行中的线程;
			TerminateThread();
			TerminateThread2();

			// Jeff.关闭AutoRun.exe程序;
			DWORD id = FindAppProcessID("AutoRun.exe");
			if (id != -1)
			{
				HANDLE ProcessHandle = OpenProcess(PROCESS_ALL_ACCESS, FALSE, id);
				if (ProcessHandle)TerminateProcess(ProcessHandle, 0);
			}

			// Jeff.移除托盘图标;
			m_TrayIcon.RemoveIcon();
			if (g_pSkinData)delete[]g_pSkinData; g_pSkinData = NULL;

			// Jeff.关闭计算机;
			MyExitWindows();
#else	// Jeff.开启定时关机功能;
			SetTimer(11, 60000, NULL);// 1分钟检测一次是否到达关机时间;
#endif
		}
		else//重启
		{
			TerminateThread();
			TerminateThread2();

			m_TrayIcon.RemoveIcon();
			if (g_pSkinData)
				delete[]g_pSkinData;
			g_pSkinData = NULL;
			WriteTextLog("备份完成,服务器重启");
			CDialog::OnCancel();
		}
	}
	catch (...)
	{
		WriteTextLog("出错在函数shutdown中");
	}
}

void CDBServerDlg::MyExitWindows()
{
	try
	{
		UINT   t = EWX_SHUTDOWN | EWX_FORCE;
		OSVERSIONINFO   osv;     //定义一个操作系统信息的结构体   
		osv.dwOSVersionInfoSize = sizeof   OSVERSIONINFO;
		GetVersionEx(&osv);       //查询当前操作系统   
		if (osv.dwPlatformId == VER_PLATFORM_WIN32_NT)     //判断是否是2000/NT   
		{
			//下面为向操作系统获取权限操作   
			HANDLE   hProcess, hToken;
			TOKEN_PRIVILEGES   Privileges;
			LUID   luid;
			hProcess = GetCurrentProcess();
			//下面为打开当前进程对话   
			OpenProcessToken(hProcess, TOKEN_ADJUST_PRIVILEGES, &hToken);
			Privileges.PrivilegeCount = 1;
			LookupPrivilegeValue(NULL, SE_SHUTDOWN_NAME, &luid);
			Privileges.Privileges[0].Luid = luid;
			Privileges.Privileges[0].Attributes = SE_PRIVILEGE_ENABLED;
			AdjustTokenPrivileges(hToken, FALSE, &Privileges, NULL, NULL, NULL);
			ExitWindowsEx(t, 0);
		}
		else
		{
			ExitWindowsEx(t, 0);//调用ExitWindowsEx关闭机器。     
			PostQuitMessage(0);
		}
	}
	catch (...)
	{
		WriteTextLog("出错在函数exitwindows中");
	}
}

void CDBServerDlg::OnAutorun()
{
	// TODO: Add your command handler code here
	g_bAutoRun = !g_bAutoRun;
	CString version = _T("Version 1.0");
	AfxGetApp()->WriteProfileInt(version, "brun", g_bAutoRun);
	TCHAR szKey[MAX_PATH];
	HKEY hKey = 0;
	DWORD disp = 0;
	lstrcpy(szKey, "SOFTWARE\\Microsoft\\Windows\\CurrentVersion\\Run");
	if (g_bAutoRun)
	{
		int lResult = RegCreateKeyEx(HKEY_LOCAL_MACHINE, szKey, 0, NULL, REG_OPTION_VOLATILE, KEY_ALL_ACCESS, NULL, &hKey, &disp);
		if (lResult == ERROR_SUCCESS)
		{
			TCHAR szDir[MAX_PATH];
			::GetModuleFileName(NULL, szDir, MAX_PATH);
			lResult = RegSetValueEx(hKey, "YLGLDBSERVER", 0, REG_SZ, (const unsigned char*)szDir, lstrlen(szDir));
			RegCloseKey(hKey);
		}
	}
	else
	{
		int lResult = RegCreateKeyEx(HKEY_LOCAL_MACHINE, szKey, 0, NULL, REG_OPTION_NON_VOLATILE, KEY_ALL_ACCESS, NULL, &hKey, &disp);
		if (lResult == ERROR_SUCCESS)
		{
			RegDeleteValue(hKey, "YLGLDBSERVER");
			RegDeleteKey(hKey, "YLGLDBSERVER");
			RegCloseKey(hKey);
		}
	}
}


void CDBServerDlg::GetFileDate()
{
	CStringArray filesarray;
	CStringArray filesarray2;
	filesarray.Add("AutoUpdate.exe");					// 1.
	filesarray.Add("skin\\1.lia");
	filesarray.Add("skin\\2.lia");
	filesarray.Add("skin\\3.lia");
	filesarray.Add("skin\\4.lia");
	filesarray.Add("skin\\10.lia");
	filesarray.Add("skin\\logo.jpg");
	filesarray.Add("skin\\标题-选片.jpg");
	filesarray.Add("skin\\标题-看设计.jpg");
	filesarray.Add("图片\\欢迎.jpg");					// 10.
	filesarray.Add("图片\\连接.jpg");
	filesarray.Add("图片\\标题.jpg");
	filesarray.Add("图片\\背景.jpg");
	filesarray.Add("图片-红色风格\\欢迎.jpg");
	filesarray.Add("图片-红色风格\\连接.jpg");
	filesarray.Add("图片-红色风格\\标题.jpg");
	filesarray.Add("图片-红色风格\\背景.jpg");
	filesarray.Add("图片-红色风格\\选片.jpg");
	filesarray.Add("图片-红色风格\\看设计.jpg");
	filesarray.Add("skin\\1-red.lia");					// 20.
	filesarray.Add("skin\\2-red.lia");
	filesarray.Add("skin\\10-red.lia");
	filesarray.Add("skin\\6.lia");
	filesarray.Add("图片\\掌中宝.jpg");
	filesarray.Add("regsvr32.exe");					// 25.
	filesarray.Add("MSCHRT20.OCX");					// 26.	// Jeff.2014.09.06.添加MSCHRT20.OCX,由服务器传递;
	///////////////
	filesarray2.Add("AutoUpdate.exe");
	filesarray2.Add("skin\\1.lia");
	filesarray2.Add("skin\\2.lia");
	filesarray2.Add("skin\\3.lia");
	filesarray2.Add("skin\\4.lia");
	filesarray2.Add("skin\\5.lia");
	filesarray2.Add("skin\\10.lia");
	filesarray2.Add("skin\\5-red.lia");
	filesarray2.Add("skin\\10-red.lia");
	filesarray2.Add("图片\\logo.jpg");
	filesarray2.Add("图片\\标题-选片.jpg");
	filesarray2.Add("图片\\标题-看设计.jpg");
	filesarray2.Add("图片\\选片.jpg");
	filesarray2.Add("图片\\看设计.jpg");
	filesarray2.Add("图片\\欢迎.jpg");
	filesarray2.Add("图片\\连接.jpg");
	filesarray2.Add("图片\\标题.jpg");
	filesarray2.Add("图片\\背景.jpg");
	filesarray2.Add("图片-红色风格\\欢迎.jpg");
	filesarray2.Add("图片-红色风格\\连接.jpg");
	filesarray2.Add("图片-红色风格\\标题.jpg");
	filesarray2.Add("图片-红色风格\\背景.jpg");
	filesarray2.Add("skin\\6.lia");
	filesarray2.Add("图片\\掌中宝.jpg");
	filesarray2.Add("regsvr32.exe");
	filesarray2.Add("MSCHRT20.OCX");			// 26.	// Jeff.2014.09.06.添加MSCHRT20.OCX,由服务器传递;
	int i = 0;
	for ( i = 0; i < filesarray.GetSize(); i++)
	{
		g_filedatearray.Add(GetModifyTime(g_mainpath + "\\系统文件\\" + filesarray.ElementAt(i)));
	}
	g_filedatearraynew.Copy(filesarray2);
	for (i = 0; i < filesarray2.GetSize(); i++)
	{
		g_filedatearraynew.Add(GetFileSize(g_mainpath + "\\系统文件\\" + filesarray2.ElementAt(i)));
	}
}

//extern 	CString g_sdomain;
#ifdef ENTERPRISE_VERSION
CString g_bMain;
#endif
void CDBServerDlg::LoadBranchInfo()
{

}

void CDBServerDlg::ReleaseBranchDB()
{

}
//savebranchinfo

void CDBServerDlg::LoadBranchInfo2()
{

}

int __cdecl CompareByLabel6(const void *elem1, const void *elem2)
{
	CStringArray *p1 = (CStringArray*)elem1;
	CStringArray *p2 = (CStringArray*)elem2;

	return atoi(p1->ElementAt(5)) > atoi(p2->ElementAt(5));
}

//--------------------------------------------------------------
// Remark by Jeff 2014.12.16
// 函数：CheckMemberMsg
// 描述：
// 参数：
// 返回：
//
// 调用关系：
// 1.CheckMemberMsg() 只由 CDBServerDlg::SetTimer(4) 调用,调用频率2分钟，周期数直到程序结束。
// 2.CDBServerDlg::SetTimer(4) 由 CDBServerDlg::SetTimer(2) 调用,调用频率10毫秒，只有一个周期。
// 3.CDBServerDlg::SetTimer(2) 由 CDBServerDlg::OnInitDialog() 调用.
//--------------------------------------------------------------
void CDBServerDlg::CheckMemberMsg()	// Jeff.由定时器SetTimer两分钟执行一次
{
	try
	{
		g_curdb = &g_db;
		CString sql = "delete from sendreg where [log]='0/0'";
		MyExecuteSQL(&g_db, sql);
		{
			CStringArray idarray;
			CString timestamp;
			CTime tm = CTime::GetCurrentTime();
			tm -= CTimeSpan(0, 1, 0, 0);
			timestamp = tm.Format("%Y%m%d%H%M%S");

			CRecordset myset(g_curdb);
			CString	sql = "select [autoid] from sendregdelay where [timestamp]<'" + timestamp + "'";
			myset.Open(CRecordset::forwardOnly, sql);
			while (!myset.IsEOF())
			{
				myset.GetFieldValue("autoid", sql);
				idarray.Add(sql);
				myset.MoveNext();
			}
			myset.Close();
			for (int i = 0; i < idarray.GetSize(); i++)
			{
				// Jeff.deal
				//sql.Format("insert into [db].[dbo].sendreg([timestamp],[msgcount],[log],[status],[issended],[isautosend],[phones],[content],[ren]) select [timestamp],[msgcount],[log],[status],[issended],[isautosend],[phones],[content],[ren] from [db].[dbo].sendregdelay where [autoid]=%d", atol(idarray.ElementAt(i)));
				sql.Format("insert into sendreg([msgtype],[timestamp],[msgcount],[log],[status],[issended],[isautosend],[phones],[content],[ren]) select [msgtype],[timestamp],[msgcount],[log],[status],[issended],[isautosend],[phones],[content],[ren] from sendregdelay where [autoid]=%d", atol(idarray.ElementAt(i)));
				MyExecuteSQL(&g_db, sql);

				sql.Format("delete from sendregdelay where [autoid]=%d", atol(idarray.ElementAt(i)));
				MyExecuteSQL(&g_db, sql);
			}
		}

		int covertrate = 100;
		CString spoint;
		{
			CRecordset myset(g_curdb);
			CString	sql = "select * from version";
			myset.Open(CRecordset::forwardOnly, sql);
			myset.GetFieldValue("rate2", sql);
			myset.Close();
			covertrate = atoi(sql);
			if (covertrate == 0)covertrate = 100;
		}

		CString filter;
		CArray<CStringArray, CStringArray>rulearray;
		CArray<CStringArray, CStringArray>memberarray;
		{
			CRecordset myset(g_curdb);
			CString	sql = "select count(*) as cot from msgtemp2";
			if (!filter.IsEmpty())sql += " where " + filter;
			myset.Open(CRecordset::forwardOnly, sql);
			myset.GetFieldValue("cot", sql);
			myset.Close();
			int count = atol(sql);
			rulearray.SetSize(count, 1);
			CRstmsgtemp2 rsSt; rsSt.m_pDatabase = g_curdb;
			if (!filter.IsEmpty())rsSt.m_strFilter = filter;
			rsSt.Open();
			DWORD ii = 0;
			while (!rsSt.IsEOF())
			{
				rulearray.ElementAt(ii).RemoveAll();
				rulearray.ElementAt(ii).Add(rsSt.name);
				rulearray.ElementAt(ii).Add(rsSt.content1);
				rulearray.ElementAt(ii).Add(rsSt.content2);
				rulearray.ElementAt(ii).Add(rsSt.check1);
				rulearray.ElementAt(ii).Add(rsSt.check2);
				rulearray.ElementAt(ii).Add(rsSt.point);
				ii++;
				rsSt.MoveNext();
				if (rulearray.GetSize() <= ii)break;
			}
			rsSt.Close(); rulearray.SetSize(ii, 1);
		}
		if (rulearray.GetSize() == 0)return;
		qsort(static_cast<void*>(&rulearray[0]), rulearray.GetSize(), sizeof(rulearray[0]), CompareByLabel6);
		/////////////
		{
			CRecordset myset(g_curdb);
			CString	sql = "select count(*) as cot from membermanage"; if (!filter.IsEmpty())sql += " where " + filter;
			myset.Open(CRecordset::forwardOnly, sql);
			myset.GetFieldValue("cot", sql);
			myset.Close();
			memberarray.SetSize(atol(sql), 1);
			RstMemberReg rsSt; rsSt.m_pDatabase = g_curdb; if (!filter.IsEmpty())rsSt.m_strFilter = filter;
			rsSt.Open();
			DWORD ii = 0;
			if (covertrate != 100)
			{
				while (!rsSt.IsEOF())
				{
					memberarray.ElementAt(ii).RemoveAll();
					memberarray.ElementAt(ii).Add(rsSt.m_memberno);
					memberarray.ElementAt(ii).Add(rsSt.m_name);
					memberarray.ElementAt(ii).Add(rsSt.m_sex);
					memberarray.ElementAt(ii).Add(rsSt.m_phone);


					spoint.Format("%d", atoi(rsSt.m_money)*covertrate / 100);
					memberarray.ElementAt(ii).Add(spoint);

					memberarray.ElementAt(ii).Add(rsSt.m_sendmark1);
					memberarray.ElementAt(ii).Add(rsSt.m_sendmark2);
					ii++;
					rsSt.MoveNext(); if (memberarray.GetSize() <= ii)break;
				}
			}
			else
			{
				while (!rsSt.IsEOF())
				{
					memberarray.ElementAt(ii).RemoveAll();
					memberarray.ElementAt(ii).Add(rsSt.m_memberno);
					memberarray.ElementAt(ii).Add(rsSt.m_name);
					memberarray.ElementAt(ii).Add(rsSt.m_sex);
					memberarray.ElementAt(ii).Add(rsSt.m_phone);
					memberarray.ElementAt(ii).Add(rsSt.m_money);
					memberarray.ElementAt(ii).Add(rsSt.m_sendmark1);
					memberarray.ElementAt(ii).Add(rsSt.m_sendmark2);
					ii++;
					rsSt.MoveNext(); if (memberarray.GetSize() <= ii)break;
				}
			}
			rsSt.Close(); memberarray.SetSize(ii, 1);
		}

		CString memberno, name, sex, phone, point, mark1, mark2, rulename, rulecheck1, rulecheck2, rulepoint, rulecontent1, rulecontent2;
		for (int i = 0; i < memberarray.GetSize(); i++)
		{
			memberno = memberarray.ElementAt(i).ElementAt(0);
			name = memberarray.ElementAt(i).ElementAt(1);
			sex = memberarray.ElementAt(i).ElementAt(2);
			phone = memberarray.ElementAt(i).ElementAt(3);
			point = memberarray.ElementAt(i).ElementAt(4);
			mark1 = "," + memberarray.ElementAt(i).ElementAt(5) + ",";
			mark2 = "," + memberarray.ElementAt(i).ElementAt(6) + ",";
			if (atoi(point) == 0)continue;
			if (phone.IsEmpty())continue;
			if (-1 == CheckPhoneType(phone))continue;

			int j = 0;
			for ( j = 0; j < rulearray.GetSize(); j++)
			{
				if (mark1.GetLength()>4000)break;
				rulename = "," + rulearray.ElementAt(j).ElementAt(0) + ",";
				rulecontent1 = name + rulearray.ElementAt(j).ElementAt(1);
				rulecontent2 = name + rulearray.ElementAt(j).ElementAt(2);
				rulecheck1 = rulearray.ElementAt(j).ElementAt(3);
				rulecheck2 = rulearray.ElementAt(j).ElementAt(4);
				rulepoint = rulearray.ElementAt(j).ElementAt(5);
				if (atoi(rulecheck1) == 0 && atoi(rulecheck2) == 0)continue;

				if (atoi(rulecheck1))
				{
					if (rulecontent1.IsEmpty())continue;
					if (mark1.Find(rulename) != -1)break;
					if (atoi(point) >= atoi(rulepoint))continue;
					if (atoi(point) < atoi(rulepoint) * 80 / 100)continue;
					//	if(sex=="男")
					//	    rulecontent1.Replace ("xxx先生/女士", name+"先生");
					//	else
					//	    rulecontent1.Replace ("xxx先生/女士", name+"女士");

					int count = GetLengthEx(rulecontent1) / MSG_LENGTH;
					if (GetLengthEx(rulecontent1) % MSG_LENGTH)
						count++;
					int phonenum = 1;
					count *= phonenum;
					CString scount;
					scount.Format("%d", count);
					CString timestamp = CTime::GetCurrentTime().Format("%Y%m%d%H%M%S");
					CString sql;
					mark1.TrimLeft(",");
					mark1.TrimRight(",");
					if (mark1.IsEmpty() == 0)
						mark1 += ",";
					rulename.TrimLeft(",");
					rulename.TrimRight(",");
					mark1 += rulename;
					sql = "update membermanage set sendmark1='" + mark1 + "' where memberno='" + memberno + "'";
					MyExecuteSQL(&g_db, sql);
					mark1 = "," + mark1 + ",";

					sql = "insert into sendreg([phones],[content],[timestamp],[msgcount],[status],[issended],[isautosend],[ren]) values('" + phone + "','" + rulecontent1 + "','" + timestamp + "','" + scount + "','0','0','0','系统自动发送')";
					MyExecuteSQL(&g_db, sql);
				}
			}
			///////////////////
			BOOL bSended = 0;
			for (j = 0; j < rulearray.GetSize(); j++)
			{
				if (mark2.GetLength() > 4000)break;
				if (bSended)break;
				rulename = "," + rulearray.ElementAt(j).ElementAt(0) + ",";
				rulecontent1 = name + rulearray.ElementAt(j).ElementAt(1);
				rulecontent2 = name + rulearray.ElementAt(j).ElementAt(2);
				rulecheck1 = rulearray.ElementAt(j).ElementAt(3);
				rulecheck2 = rulearray.ElementAt(j).ElementAt(4);
				rulepoint = rulearray.ElementAt(j).ElementAt(5);
				if (atoi(rulecheck1) == 0 && atoi(rulecheck2) == 0)continue;
				if (atoi(rulecheck2))
				{
					if (rulecontent2.IsEmpty())continue;
					if (mark2.Find(rulename) != -1)break;
					if (atoi(point) < atoi(rulepoint))continue;

					//	if(sex=="男")
					//	    rulecontent2.Replace ("xxx先生/女士", name+"先生");
					//	else
					//	    rulecontent2.Replace ("xxx先生/女士", name+"女士");

					int count = GetLengthEx(rulecontent2) / MSG_LENGTH;
					if (GetLengthEx(rulecontent2) % MSG_LENGTH)
						count++;
					int phonenum = 1;
					count *= phonenum;
					CString scount;
					scount.Format("%d", count);
					CString timestamp = CTime::GetCurrentTime().Format("%Y%m%d%H%M%S");
					CString sql;
					mark2.TrimLeft(",");
					mark2.TrimRight(",");
					if (mark2.IsEmpty() == 0)
						mark2 += ",";
					rulename.TrimLeft(",");
					rulename.TrimRight(",");
					mark2 += rulename;
					sql = "update membermanage set sendmark2='" + mark2 + "' where memberno='" + memberno + "'";
					MyExecuteSQL(&g_db, sql);
					mark2 = "," + mark2 + ",";

					sql = "insert into sendreg([phones],[content],[timestamp],[msgcount],[status],[issended],[isautosend],[ren]) values('" + phone + "','" + rulecontent2 + "','" + timestamp + "','" + scount + "','0','0','0','系统自动发送')";
					MyExecuteSQL(&g_db, sql);
					bSended = 1;
				}
			}
		}
	}
#if 1
	catch (...)
	{
		WriteTextLog("出错2");
	}
#else // Jeff.add
	catch (CDBException *e)
	{
		WriteTextLog(e->m_strError);
		e->Delete();
	}
#endif
}

void CDBServerDlg::CheckBakState() // Jeff.检查数据库bakstate表;
{
	try
	{
		g_curdb = &g_db;
		CString filter;
		CArray<CStringArray, CStringArray> strArray;
		CRecordset myset(g_curdb);
		CString	sql = "select count(*) as cot from bakstate";
		if (!filter.IsEmpty())
			sql += " where " + filter;

		myset.Open(CRecordset::forwardOnly, sql);
		myset.GetFieldValue("cot", sql);
		myset.Close();
		int count = atol(sql);
		strArray.SetSize(count, 1);

		CRstbakstate rsSt;
		rsSt.m_pDatabase = g_curdb;
		if (!filter.IsEmpty())
			rsSt.m_strFilter = filter;
		rsSt.Open();
		int ii = 0;
		while (!rsSt.IsEOF())
		{
			strArray.ElementAt(ii).RemoveAll();
			strArray.ElementAt(ii).Add(rsSt.date);
			strArray.ElementAt(ii).Add(rsSt.photo);
			strArray.ElementAt(ii).Add(rsSt.info);
			ii++;
			rsSt.MoveNext();
			if (strArray.GetSize() <= ii)
				break;
		}
		rsSt.Close(); strArray.SetSize(ii, 1);

		while (strArray.GetSize() > 7)
		{
			CString sql = "delete from bakstate where [date]='" + strArray.ElementAt(0).ElementAt(0) + "'";
			MyExecuteSQL(&g_db, sql);
			strArray.RemoveAt(0);
		}

		CString path;
		path.Format("%s\\log.txt", g_mainpath);
		if (::PathFileExists(path))
		{
			CString str;
			CStdioFile fp;
			if (fp.Open(path, CFile::modeRead))
			{
				CString temp;
				fp.ReadString(temp);
				CString date = temp; date.TrimRight();
				while (!feof(fp.m_pStream))
				{
					fp.ReadString(temp);
					str += temp;
				}
				fp.Close();
				if (date.GetLength() != 10)return;
				BOOL bBak = 0;
				int i = 0;
				for ( i = 0; i < strArray.GetSize(); i++)
				{
					if (date == strArray.ElementAt(i).ElementAt(0))
					{
						bBak = 1;
						break;
					}
				}
				if (bBak == 0)
				{
					CString state1 = "0";
					CString state2 = "0";
					if (str.Find("照片备份成功") != -1)state1 = "1";
					if (str.Find("资料备份成功") != -1)state2 = "1";
					sql = "insert into bakstate([date],[photo],[info])values('" + date + "','" + state1 + "','" + state2 + "')";
					MyExecuteSQL(&g_db, sql);
				}
				else
				{
					CString state1 = "0";
					CString state2 = "0";
					if (str.Find("照片备份成功") != -1)state1 = "1";
					if (str.Find("资料备份成功") != -1)state2 = "1";
					sql = "update bakstate set [photo]='" + state1 + "',[info]='" + state2 + "' where [date]='" + date + "'";
					MyExecuteSQL(&g_db, sql);
				}

				//判断昨天
				CTime tm = CTime::GetCurrentTime();
				CTimeSpan dt(1, 0, 0, 0);
				tm -= dt;
				CString yesterday = tm.Format("%Y-%m-%d");
				for (i = 0; i < strArray.GetSize(); i++)
				{
					if (yesterday == strArray.ElementAt(i).ElementAt(0))return;
				}
				if (yesterday == date)return;
				sql = "insert into bakstate([date],[photo],[info])values('" + yesterday + "','0','0')";
				MyExecuteSQL(&g_db, sql);
			}
			else
			{
				CTime tm = CTime::GetCurrentTime();
				CTimeSpan dt(1, 0, 0, 0);
				tm -= dt;
				sql = "insert into bakstate([date],[photo],[info])values('" + tm.Format("%Y-%m-%d") + "','0','0')";
				MyExecuteSQL(&g_db, sql);
			}
		}
		else
		{
			CTime tm = CTime::GetCurrentTime();
			CTimeSpan dt(1, 0, 0, 0);
			tm -= dt;
			for (int i = 0; i < strArray.GetSize(); i++)
			{
				if (tm.Format("%Y-%m-%d") == strArray.ElementAt(i).ElementAt(0))return;
			}

			sql = "insert into bakstate([date],[photo],[info])values('" + tm.Format("%Y-%m-%d") + "','0','0')";
			MyExecuteSQL(&g_db, sql);
		}
	}
	catch (...)
	{
		WriteTextLog("出错3");
	}
}
//数据备份

CString CDBServerDlg::GetRegCode(int m_id, int m_time1, int m_time2)
{
	return "";
}


int g_ndogtimes = 0;
void CDBServerDlg::CheckRegCode()	// 检查注册码信息;
{
	
}

BOOL IsCtrlDown()
{
	short state = GetKeyState(VK_LCONTROL);
	BYTE sta = (BYTE)(state >> 8);
	state = GetKeyState(VK_RCONTROL);
	BYTE sta2 = (BYTE)(state >> 8);
	if (sta || sta2)
		return 1;
	else
		return 0;
}

//extern CTime GetTmFromStr(CString date);
BOOL CDBServerDlg::PreTranslateMessage(MSG* pMsg)
{
	if (pMsg->message == WM_KEYDOWN)
	{
		switch (pMsg->wParam)
		{
		case 67:
			AfxMessageBox("c");
			break;
		case VK_F8:
			if (IsCtrlDown())GenYLGL();
			break;
		case VK_F9:
			if (IsCtrlDown())
			{
				CString g_domain;
				CArray<CStringArray, CStringArray>g_List1array;
				CString autorunpath = g_mainpath + "\\branchdindan.dat";
				CFile fp;
				if (fp.Open(autorunpath, CFile::modeRead))
				{
					int nMessageLen = fp.GetLength();
					BYTE *pData = new BYTE[nMessageLen];
					fp.Read(pData, nMessageLen);
					fp.Close();

					BYTE *szChatMessage = pData;
					int count;
					memcpy(&count, szChatMessage + (nMessageLen - sizeof(int)), sizeof(int));
					CMemFile memfile;
					memfile.Attach(szChatMessage, nMessageLen);
					CArchive ar(&memfile, CArchive::load);
					g_List1array.SetSize(count);
					for (int ii = 0; ii < g_List1array.GetSize(); ii++)
					{
						g_List1array.ElementAt(ii).Serialize(ar);
					}
					ar.Close();
					memfile.Detach();
					delete[]pData;
				}
				CString time5, id;
				for (int i = 0; i < g_List1array.GetSize(); i++)
				{
					g_domain = "\\" + g_List1array.ElementAt(i).ElementAt(0);
					id = g_List1array.ElementAt(i).ElementAt(1);
					time5 = g_List1array.ElementAt(i).ElementAt(2);

					WriteTextLog(g_domain + "\\" + id + time5);
				}
			}
			break;
#ifdef LYFZ_VERSION
		case VK_F7:
			if (IsCtrlDown())
			{
				if (AfxMessageBox("是否继续?", MB_YESNO | MB_ICONINFORMATION) != IDYES)return 1;

				CStringArray array1;
				CRstDindanForm rsSt; rsSt.m_pDatabase = &g_db;
				rsSt.Open();
				while (!rsSt.IsEOF())
				{
					array1.Add(rsSt.id);
					rsSt.MoveNext();
				}
				rsSt.Close();
				CString id, sql;
				sql.Format("update dindan set status5='%s'", "无");
				MyExecuteSQL(&g_db, sql);


				BOOL bHasPhoto = 0;
				for (int i = 0; i < array1.GetSize(); i++)
				{
					id = array1.ElementAt(i);
					bHasPhoto = 0;
					CRstClientPhoto rsSt;
					rsSt.m_strFilter = "id='" + id + "'";
					rsSt.Open();
					if (rsSt.photo.m_dwDataLength>0)
					{
						bHasPhoto = 1;
					}
					rsSt.Close();

					if (bHasPhoto)
					{
						sql.Format("update dindan set status5='%s' where id='%s'", "有", id);
						MyExecuteSQL(&g_db, sql);
					}

				}

				AfxMessageBox("完成");
			}
			break;
#endif 
		case VK_F2:
			if (IsCtrlDown())
			{
				SelYear dlg;
				if (dlg.DoModal() != IDOK)return 1;
				int year = dlg.m_year;
				int hisyear = CTime::GetCurrentTime().GetYear() - 1;
				if (year == hisyear)
				{
					AfxMessageBox("不能选该年");
					return 1;
				}
				CString str;
				str.Format("此操作将%d年数据导入%d中, 确认吗?", year, hisyear);
				if (AfxMessageBox(str, MB_YESNO | MB_ICONINFORMATION) != IDYES)return 1;
				CDatabase *pdb = GetDB(year);
				if (pdb == NULL)
				{
					str.Format("没有找到%d, 操作失败", year);
					AfxMessageBox(str); return 1;
				}
				str.Format("开始%d->%d", year, hisyear);
				WriteTextLog(str);
				CheckHistoryData(pdb, year);
				str.Format("%d->%d完成", year, hisyear);
				WriteTextLog(str);
			}
			break;
		case VK_F3:
			if (IsCtrlDown())
			{
				SelYear dlg;
				if (dlg.DoModal() != IDOK)return 1;
				int year = dlg.m_year;
				int hisyear = CTime::GetCurrentTime().GetYear() - 1;
				if (year == hisyear)
				{
					AfxMessageBox("不能选该年");
					return 1;
				}
				CString str;
				str.Format("此操作将%d年数据导入%d中(当前数据库中没有的订单全转), 确认吗?", year, hisyear);
				if (AfxMessageBox(str, MB_YESNO | MB_ICONINFORMATION) != IDYES)return 1;
				CDatabase *pdb = GetDB(year);
				if (pdb == NULL)
				{
					str.Format("没有找到%d, 操作失败", year);
					AfxMessageBox(str); return 1;
				}
				str.Format("开始%d->%d", year, hisyear);
				WriteTextLog(str);
				CheckHistoryData(pdb, year, 1);
				str.Format("%d->%d完成", year, hisyear);
				WriteTextLog(str);
			}
			break;
		case VK_F1:
			CString str;
			if (g_conniparray.GetSize() == 0)str = "当前无客户端连接至服务器!";
			for (int i = 0; i < g_conniparray.GetSize(); i++)
			{
				str += "\r\n连接ip:" + g_conniparray.ElementAt(i);
			}
			AfxMessageBox(str);
#ifdef  CONNCOUNT_VERSION
			//  CStringArray g_conniparray;
#endif
			return 1;
		}
	}
	return CDialog::PreTranslateMessage(pMsg);
}

void CDBServerDlg::GenUPhoneData()
{
	return;
	MyLock lock("processChatMessageRequestxiao");
	CArray<int, int>codearray;
	codearray.Add(80);
	codearray.Add(90);
	codearray.Add(11);
	codearray.Add(138);
	codearray.Add(24);
	codearray.Add(181);
	codearray.Add(65);
	codearray.Add(56);
	codearray.Add(179);
	codearray.Add(53);
	CFile fp;
	CString savepath, g_path1;
	char server[50];
	DWORD leng = 50;
	::GetComputerName(server, &leng);
	g_path1 = server;
	g_path1 = "\\\\" + g_path1 + "\\电话录音(管理软件)$";
	GetPathFromNetShareName("电话录音(管理软件)$", g_path1);
	if (g_path1.IsEmpty())
	{
		WriteTextLog("获取电精灵数据出错");
		return;
	}

	try
	{
		int aa = 0;
		g_curdb = &g_db;
		savepath.Format("%s\\uphonedata%d.dat", g_path1, aa);
		::DeleteFile(savepath);		// 删除 uphonedata%d.dat 文件;
		if (fp.Open(savepath, CFile::modeCreate | CFile::modeWrite) == 0)
		{
			WriteTextLog("更新来电精灵数据出错");
			return;
		}
		CConnectSocket consock;
		consock.m_pConndb = &g_db;


		for (int i = 0; i < codearray.GetSize(); i++)
		{
			BYTE code = codearray.ElementAt(i);
			DWORD length, arraysize;
			BYTE *pReturn = NULL;
			consock.GetDataFromCode(code, &pReturn, length, arraysize, "");
			fp.Write(&code, sizeof(BYTE));
			fp.Write(&length, sizeof(DWORD));
			fp.Write(&arraysize, sizeof(DWORD));
			fp.Write(pReturn, length);
		}
		fp.Close();
	}
	catch (...)
	{
		WriteTextLog("获取来电精灵数据出错");
	}
}
//initlia

void CDBServerDlg::LoadHistoryDB() // 加载历史数据库;
{
	CString path;
	CString sql;
	sql = "delete from historydb";
	MyExecuteSQL(&g_db, sql);
	CDatabase g_masterdb;
	try
	{
		CString strCon;
		strCon.Format(_T("driver={SQL Server};Server=%s;DATABASE=master;%s"), g_strdbServrename, g_strdbpsw);
		g_masterdb.OpenEx(strCon, CDatabase::noOdbcDialog);
	}
	catch (CDBException * e)
	{
		e->Delete();
	}
	for (int i = CTime::GetCurrentTime().GetYear() - 1; i >= 2009; i--)
	{
		CDatabase *db = new CDatabase;
		try
		{
			CString strCon;
			strCon.Format(_T("driver={SQL Server};Server=%s;DATABASE=%d;%s"), g_strdbServrename, i, g_strdbpsw);
			db->OpenEx(strCon, CDatabase::noOdbcDialog);

			g_nYearArray.Add(i);
			g_dbHistoryArray.Add(db);
			sql.Format("insert into [historydb]([year])values('%d')", i);
			MyExecuteSQL(&g_db, sql);
		}
		catch (CDBException * e)
		{
			CString strPathOfYearmdf;
			CString strPathOfYearldf;
			CString sql;
			strPathOfYearmdf.Format("%s\\数据\\%d.mdf", g_mainpath, i);
			strPathOfYearldf.Format("%s\\数据\\%d_log.LDF", g_mainpath, i);
			if (PathFileExists(strPathOfYearmdf))
			{
				BOOL bLog = 0;
				if (PathFileExists(strPathOfYearldf))
				{
					bLog = 1;
				}
				g_masterdb.SetQueryTimeout(600);

				if (bLog)
					sql.Format("exec sp_attach_db '%d',@filename1='%s',@filename2='%s'", i, strPathOfYearmdf, strPathOfYearldf);
				else
					sql.Format("exec sp_attach_db '%d',@filename1='%s'", i, strPathOfYearmdf);
				try
				{
					g_masterdb.ExecuteSQL(sql);
				}
				catch (CDBException * e)
				{
					WriteTextLog(e->m_strError);
					WriteTextLog("历史数据库初始化失败!!");
					g_masterdb.SetQueryTimeout(100);
					e->Delete();
					break;
				}
				g_masterdb.SetQueryTimeout(100);

				CString strCon;
				strCon.Format(_T("driver={SQL Server};Server=%s;DATABASE=%d;%s"), g_strdbServrename, i, g_strdbpsw);
				db->OpenEx(strCon, CDatabase::noOdbcDialog);

				g_nYearArray.Add(i);
				g_dbHistoryArray.Add(db);
				sql.Format("insert into [historydb]([year])values('%d')", i);
				MyExecuteSQL(&g_db, sql);

				}
			else
			{
				e->Delete();
				break;
			}
			}
		}
	g_masterdb.Close();
	}


void CDBServerDlg::AddOneConn()
{
	try
	{
		MyLock lock("AddOneConnxiao");
		if (g_nDBCount >= 200)
		{
			WriteTextLog("连接超数!"); return;
		}
		CDatabase *db = new CDatabase;
		//if(AddConn(db, "db")==0)// Jeff.deal;
		if (AddConn(db, g_szDBName) == 0)
		{
			return;
		}
		g_pDB[g_nDBCount] = db;
		CString dbname;
		for (int i = 0; i < g_nYearArray.GetSize(); i++)
		{
			dbname.Format("%d", g_nYearArray.ElementAt(i));
			CDatabase *db = new CDatabase;
			AddConn(db, dbname);
			g_pHistoryDBarray[g_nDBCount].Add(db);
		}
		g_nDBCount++;
	}
	catch (...)
	{
		WriteTextLog("AddOneConn error");
	}
}

void GetOneConn(CDatabase **m_pdb, CArray<CDatabase*, CDatabase*>*m_dbarray, CConnectThread *pThread)
{
	MyLock lock("GetOneConnxiao");
ll:	for (int i = 0; i < 200; i++)
{
	if (g_pDB[i] != NULL && g_pThreadPt[i] == NULL)
	{
		*m_pdb = g_pDB[i];
		m_dbarray->Copy(g_pHistoryDBarray[i]);
		g_pThreadPt[i] = pThread;
		return;
	}
}
	if (g_nDBCount >= 200)
	{
		WriteTextLog("连接超数2!");
		*m_pdb = &g_db;
		m_dbarray->Copy(g_dbHistoryArray);
		return;
	}
	g_pMainWnd->AddOneConn();
	::Sleep(1000);
	goto ll;
}

void CDBServerDlg::CheckConnCount()
{
	int count = 0;
	for (int i = 0; i < 200; i++)
	{
		if (g_pDB[i] != NULL && g_pThreadPt[i] == NULL)
		{
			count++;
			if (count > 9)
				return;
		}
	}
	AddOneConn();
}
//delete from 背景.jpg

void CDBServerDlg::RestoreHQ()
{
	CString sql;
	g_curdb = &g_db;
	DWORD ii = 0;
	CArray<CStringArray, CStringArray>g_List1array;
	{
		CRecordset myset(g_curdb);
		CString	sql = "select count(*) as cot from dindan";
		myset.Open(CRecordset::forwardOnly, sql);
		myset.GetFieldValue("cot", sql);
		myset.Close();
		int count = atol(sql);
		g_List1array.SetSize(count, 1);
		CRstDindanForm rsSt; rsSt.m_pDatabase = g_curdb;
		rsSt.Open();
		ii = 0;
		while (!rsSt.IsEOF())
		{
			g_List1array.ElementAt(ii).RemoveAll();
			g_List1array.ElementAt(ii).Add(rsSt.id);
			ii++;
			rsSt.MoveNext(); if (g_List1array.GetSize() <= ii)break;
		}
		rsSt.Close(); g_List1array.SetSize(ii, 1);
	}

	for (int i = 0; i < g_List1array.GetSize(); i++)
	{
		//	int ret=TransDinDan(pdb1, pdb2, g_List1array.ElementAt (i).ElementAt (0), lastyear);
		// Jeff.deal;
		//sql.Format("SELECT distinct [name],[count] FROM [db].[dbo].[dindansp2] where id='%s' and name in(select spname from shangpin where splb='婚庆服务')", g_List1array.ElementAt (i).ElementAt (0));
		sql.Format("SELECT distinct [name],[count] FROM [dbo].[dindansp2] where id='%s' and name in(select spname from shangpin where splb='婚庆服务')", g_List1array.ElementAt(i).ElementAt(0));

		CRecordset myset(g_curdb);
		myset.Open(CRecordset::forwardOnly, sql);
		CStringArray namearray;
		CStringArray countarray;
		while (!myset.IsEOF())
		{
			sql = "";
			myset.GetFieldValue("name", sql);
			namearray.Add(sql);
			sql = "";
			myset.GetFieldValue("count", sql);
			countarray.Add(sql);
			myset.MoveNext();
		}
		myset.Close();

		for (int j = 0; j < namearray.GetSize(); j++)
		{
			CString spid, spjiage2;
			//	WriteTextLog("name:"+namearray.ElementAt (j));
			// Jeff.deal;
			//sql.Format("SELECT [spid],[spjiage2] FROM [db].[dbo].[shangpin] where spname='%s'", namearray.ElementAt (j));
			sql.Format("SELECT [spid],[spjiage2] FROM [dbo].[shangpin] where spname='%s'", namearray.ElementAt(j));
			//WriteTextLog(sql);
			CRecordset myset(g_curdb);

			myset.Open(CRecordset::forwardOnly, sql);

			if (!myset.IsEOF())
			{
				myset.GetFieldValue("spid", spid);
				myset.GetFieldValue("spjiage2", spjiage2);
			}
			myset.Close();


			// Jeff.deal;
			//sql.Format("SELECT count(*) as cot FROM [db].[dbo].[dindansp] where name='%s' and id='%s' and kind='2'", namearray.ElementAt (j), g_List1array.ElementAt (i).ElementAt (0));
			sql.Format("SELECT count(*) as cot FROM [dbo].[dindansp] where name='%s' and id='%s' and kind='2'", namearray.ElementAt(j), g_List1array.ElementAt(i).ElementAt(0));
			myset.Open(CRecordset::forwardOnly, sql);
			sql = "";
			if (!myset.IsEOF())
			{
				myset.GetFieldValue("cot", sql);
			}
			myset.Close();
			if (atoi(sql))continue;



			sql.Format("insert into [dindansp]([id],[name],[shuliang],[price],[spid],[kind])values('%s','%s','%s','%s','%s','%s')",
				g_List1array.ElementAt(i).ElementAt(0), namearray.ElementAt(j), countarray.ElementAt(j), spjiage2, spid, "2");
			//WriteTextLog(sql);
			g_db.ExecuteSQL(sql);
		}

	}
}

void CDBServerDlg::ManagePhoto()
{
	//	CClientCenter dlg1;
	//	dlg1.DoModal ();
	ShowPic3 dlg;
	dlg.DoModal();
}
//数据备份(管理软件)$

//--------------------------------------------------------------------------
// Remark by Jeff:2014.10.22
// 函数：AutoDelBakPhoto
// 描述：自动删除取件后的订单备份相片，包括客户备份原片、备份初修片、备份精修片、备份设计片。
// 参数：#
// 返回：#
//
// 调用关系：
// 1.AutoDelBakPhoto()由 BakPhoto()调用。
// 2.BakPhoto() 由CDBServerDlg::SetTimer(4) 调用,调用频率2分钟，周期数直到程序结束。
// 3.CDBServerDlg::SetTimer(4) 由 CDBServerDlg::SetTimer(2) 调用,调用频率10毫秒，只有一个周期。
// 4.CDBServerDlg::SetTimer(2) 由 CDBServerDlg::OnInitDialog() 调用.
//
//--------------------------------------------------------------------------
void CDBServerDlg::AutoDelBakPhoto()
{
	try
	{
		g_curdb = &g_db;

		CString	m_check1, m_check2, m_check3, m_check4;
		CString	m_edit1, m_edit2, m_edit3, m_edit4;
		CString g_path1;
		CString g_path2;
		CString g_path3;
		CString g_path4;
		CString	m_bakserver1, m_bakserver2, m_bakserver3, m_bakserver4;
		{
			CRstversion rsSt; rsSt.m_pDatabase = g_curdb;
			rsSt.Open();
			if (!rsSt.IsEOF())
			{
				m_check1 = rsSt.m_delcheck1;
				m_check2 = rsSt.m_delcheck2;
				m_check3 = rsSt.m_delcheck3;
				m_check4 = rsSt.m_delcheck4;
				m_edit1 = rsSt.m_deledit1;
				m_edit2 = rsSt.m_deledit2;
				m_edit3 = rsSt.m_deledit3;
				m_edit4 = rsSt.m_deledit4;


				g_path1 = rsSt.m_bakserver1;
				g_path2 = rsSt.m_bakserver2;
				g_path4 = rsSt.m_bakserver3;
				g_path3 = rsSt.m_bakserver4;
			}
			rsSt.Close();
		}



		BOOL bcheck1 = atoi(m_check1);
		BOOL bcheck2 = atoi(m_check2);
		BOOL bcheck3 = atoi(m_check3);
		BOOL bcheck4 = atoi(m_check4);
		if (!(bcheck1 || bcheck2 || bcheck3 || bcheck4))
		{
			return;
		}
		int edit1 = atoi(m_edit1);
		int edit2 = atoi(m_edit2);
		int edit3 = atoi(m_edit3);
		int edit4 = atoi(m_edit4);

		//path
		CStringArray patharray;
		{



#ifdef CHILD_VERSION
			if (g_path1.Find(":") == -1 && g_path1 != "")
				g_path1 = "\\\\" + g_path1 + "\\客户原片备份(儿童管理软件)$";
			if (1)//(localname.CompareNoCase (g_path1)==0 || CompareIP(localname, g_path1)==0) && CheckFolderFileExist("\\\\"+g_path1+"\\客户原片备份(儿童管理软件)$"))
				GetPathFromNetShareName("客户原片备份(儿童管理软件)$", g_path1);

			if (g_path2.Find(":") == -1 && g_path2 != "")
				g_path2 = "\\\\" + g_path2 + "\\修好的片备份(儿童管理软件)$";
			if (1)//((localname.CompareNoCase (g_path2)==0 || CompareIP(localname, g_path2)==0)  && CheckFolderFileExist("\\\\"+g_path1+"\\修好的片备份(儿童管理软件)$"))
				GetPathFromNetShareName("修好的片备份(儿童管理软件)$", g_path2);

			if (g_path4.Find(":") == -1 && g_path4 != "")
				g_path4 = "\\\\" + g_path4 + "\\精修好的片备份(儿童管理软件)$";
			if (1)//((localname.CompareNoCase (g_path4)==0 || CompareIP(localname, g_path4)==0)  && CheckFolderFileExist("\\\\"+g_path1+"\\精修好的片备份(儿童管理软件)$"))
				GetPathFromNetShareName("精修好的片备份(儿童管理软件)$", g_path4);

			if (g_path3.Find(":") == -1 && g_path3 != "")
				g_path3 = "\\\\" + g_path3 + "\\设计好的片备份(儿童管理软件)$";
			if (1)//((localname.CompareNoCase (g_path3)==0 || CompareIP(localname, g_path3)==0)  && CheckFolderFileExist("\\\\"+g_path1+"\\设计好的片备份(儿童管理软件)$"))
				GetPathFromNetShareName("设计好的片备份(儿童管理软件)$", g_path3);
#else
			if (g_path1.Find(":") == -1 && g_path1 != "")
				g_path1 = "\\\\" + g_path1 + "\\客户原片备份(管理软件)$";
			if (1)//((localname.CompareNoCase (g_path1)==0 || CompareIP(localname, g_path1)==0)  && CheckFolderFileExist("\\\\"+g_path1+"\\客户原片备份(管理软件)$"))
				GetPathFromNetShareName("客户原片备份(管理软件)$", g_path1);
			if (g_path2.Find(":") == -1 && g_path2 != "")
				g_path2 = "\\\\" + g_path2 + "\\修好的片备份(管理软件)$";
			if (1)//((localname.CompareNoCase (g_path2)==0 || CompareIP(localname, g_path2)==0)  && CheckFolderFileExist("\\\\"+g_path1+"\\修好的片备份(管理软件)$"))
				GetPathFromNetShareName("修好的片备份(管理软件)$", g_path2);
			if (g_path4.Find(":") == -1 && g_path4 != "")
				g_path4 = "\\\\" + g_path4 + "\\精修好的片备份(管理软件)$";
			if (1)//((localname.CompareNoCase (g_path4)==0 || CompareIP(localname, g_path4)==0)  && CheckFolderFileExist("\\\\"+g_path1+"\\精修好的片备份(管理软件)$"))
				GetPathFromNetShareName("精修好的片备份(管理软件)$", g_path4);
			if (g_path3.Find(":") == -1 && g_path3 != "")
				g_path3 = "\\\\" + g_path3 + "\\设计好的片备份(管理软件)$";
			if (1)//((localname.CompareNoCase (g_path3)==0 || CompareIP(localname, g_path3)==0)  && CheckFolderFileExist("\\\\"+g_path1+"\\设计好的片备份(管理软件)$"))
				GetPathFromNetShareName("设计好的片备份(管理软件)$", g_path3);
#endif

			patharray.Add(g_path1);
			patharray.Add(g_path2);
			patharray.Add(g_path4);
			patharray.Add(g_path3);


		}
		if (patharray.GetSize() == 0)return;


		CArray<CDatabase*, CDatabase*>dbarray2;
		dbarray2.Copy(g_dbHistoryArray);
		dbarray2.InsertAt(0, &g_db);

		WriteTextLog("开始删除取件后的备份照片");
		for (int n = 0; n < min(3, dbarray2.GetSize()); n++)
		{
			g_curdb = dbarray2.ElementAt(n);
			DWORD ii = 0;
			CArray<CStringArray, CStringArray>g_List1array;
			{
				CString filter = "status3='OK' and time5 is not null and time5<>''";
				CRecordset myset(g_curdb);
				CString	sql = "select count(*) as cot from dindan"; if (!filter.IsEmpty())sql += " where " + filter;
				myset.Open(CRecordset::forwardOnly, sql);
				myset.GetFieldValue("cot", sql);
				myset.Close();
				int count = atol(sql);
				if (count == 0)continue;
				g_List1array.SetSize(count, 1);
				CRstDindanForm rsSt; rsSt.m_pDatabase = g_curdb; if (!filter.IsEmpty())rsSt.m_strFilter = filter;
				rsSt.Open();
				ii = 0;
				while (!rsSt.IsEOF())
				{
					g_List1array.ElementAt(ii).RemoveAll();
					g_List1array.ElementAt(ii).Add(rsSt.id);
					g_List1array.ElementAt(ii).Add(rsSt.time5);
					ii++;
					rsSt.MoveNext(); if (g_List1array.GetSize() <= ii)break;
				}
				rsSt.Close();
				g_List1array.SetSize(ii, 1);

				CString time5, id;
				CTime curtm = CTime::GetCurrentTime();
				CString strtime;
				for (int i = 0; i < g_List1array.GetSize(); i++)
				{
					id = g_List1array.ElementAt(i).ElementAt(0);
					time5 = g_List1array.ElementAt(i).ElementAt(1);
					if (bcheck1)//原片
					{
						CTimeSpan sp(edit1 * 30, 0, 0, 0);
						CTime tm = curtm - sp;
						strtime = tm.Format("%Y-%m-%d");
						if (strtime > time5)
						{
							if (DelPhoto1(patharray.ElementAt(0), g_List1array.ElementAt(i).ElementAt(0)))
								WriteTextLog("原片备份" + patharray.ElementAt(0) + "\\" + g_List1array.ElementAt(i).ElementAt(0));
							//	DelPhoto1(patharray2.ElementAt (0),g_List1array.ElementAt (i).ElementAt (0));
						}
					}
					if (bcheck2)
					{
						CTimeSpan sp(edit2 * 30, 0, 0, 0);
						CTime tm = curtm - sp;
						strtime = tm.Format("%Y-%m-%d");
						if (strtime > time5)
						{
							DelPhoto1(patharray.ElementAt(1), g_List1array.ElementAt(i).ElementAt(0));
							//	DelPhoto1(patharray2.ElementAt (2),g_List1array.ElementAt (i).ElementAt (0));
						}
					}
					if (bcheck3)
					{
						CTimeSpan sp(edit3 * 30, 0, 0, 0);
						CTime tm = curtm - sp;
						strtime = tm.Format("%Y-%m-%d");
						if (strtime > time5)
						{
							DelPhoto1(patharray.ElementAt(2), g_List1array.ElementAt(i).ElementAt(0));
							//	DelPhoto1(patharray2.ElementAt (2),g_List1array.ElementAt (i).ElementAt (0));
						}
					}
					if (bcheck4)
					{
						CTimeSpan sp(edit4 * 30, 0, 0, 0);
						CTime tm = curtm - sp;
						strtime = tm.Format("%Y-%m-%d");
						if (strtime > time5)
						{
							DelPhoto1(patharray.ElementAt(3), g_List1array.ElementAt(i).ElementAt(0));
						}
					}
				}
			}
		}
		g_curdb = &g_db;
#ifdef ENTERPRISE_VERSION
		WriteTextLog("本店查完,开始检查分店备份");
		CString g_domain;
		CArray<CStringArray, CStringArray>g_List1array;
		CString autorunpath = g_mainpath + "\\branchdindan.dat";
		CFile fp;
		if (fp.Open(autorunpath, CFile::modeRead))
		{
			int nMessageLen = fp.GetLength();
			BYTE *pData = new BYTE[nMessageLen];
			fp.Read(pData, nMessageLen);
			fp.Close();

			BYTE *szChatMessage = pData;
			int count;
			memcpy(&count, szChatMessage+(nMessageLen-sizeof(int)), sizeof(int));
			CMemFile memfile;
			memfile.Attach (szChatMessage, nMessageLen);
			CArchive ar(&memfile, CArchive::load);
			g_List1array.SetSize(count);
			for(int ii=0; ii<g_List1array.GetSize (); ii++)
			{
				g_List1array.ElementAt (ii).Serialize (ar);
			}
			ar.Close();
			memfile.Detach (); 
			delete []pData;
		}



		CString time5,id;
		CTime curtm=CTime::GetCurrentTime ();
		CString strtime;
		for(int i=0; i<g_List1array.GetSize (); i++)
		{
			g_domain="\\"+g_List1array.ElementAt (i).ElementAt (0);
			if(g_domain.Find (".ly.com")==-1)continue;
			id=g_List1array.ElementAt (i).ElementAt (1);
			time5=g_List1array.ElementAt (i).ElementAt (2);

			if(bcheck1)//原片
			{
				CTimeSpan sp(edit1*30, 0, 0, 0);
				CTime tm=curtm-sp;
				strtime=tm.Format ("%Y-%m-%d");
				if(strtime>time5)
				{
					if(DelPhoto1(patharray.ElementAt (0)+g_domain,id))
						WriteTextLog("分店原片备份"+ patharray.ElementAt (0)+g_domain+"\\"+id );
				}
			}
			if(bcheck2)
			{
				CTimeSpan sp(edit2*30, 0, 0, 0);
				CTime tm=curtm-sp;
				strtime=tm.Format ("%Y-%m-%d");
				if(strtime>time5)
				{
					DelPhoto1(patharray.ElementAt (1)+g_domain,id);
					//	DelPhoto1(patharray2.ElementAt (2),id);
				}
			}
			if(bcheck3)
			{
				CTimeSpan sp(edit3*30, 0, 0, 0);
				CTime tm=curtm-sp;
				strtime=tm.Format ("%Y-%m-%d");
				if(strtime>time5)
				{
					DelPhoto1(patharray.ElementAt (2)+g_domain,id);
					//	DelPhoto1(patharray2.ElementAt (2),id);
				}
			}
			if(bcheck4)
			{
				CTimeSpan sp(edit4*30, 0, 0, 0);
				CTime tm=curtm-sp;
				strtime=tm.Format ("%Y-%m-%d");
				if(strtime>time5)
				{
					DelPhoto1(patharray.ElementAt (3)+g_domain,id);
		}
	}
}
		g_curdb = &g_db;
#endif
		WriteTextLog("检查删除备份照片完成");
}
	catch (...)
	{
		WriteTextLog("出错在函数AutoDelBakPhoto中");
	}
	g_curdb = &g_db;
}
//10.lia

//----------------------------------------------------------------------------
// Remark by Jeff 2014.10.22
// 函数：GenYLGL
// 描述：调用本地客户端;
// 参数：#
// 返回：#
// 
// 调用关系：
// 1.只由AutoDelPhoto()主动调用。
// 
// 说明：传递genbranchdata给客户端，使客户端能够自动遍历branchinfo.dat里的分店信息,
//		 客户端顺序连接所有分店并获取分店历史订单已完成取件的订单。最终将所有分店历史
//		 订单已完成取件的送回服务端，保存在branchdindan.dat中.
//----------------------------------------------------------------------------
void CDBServerDlg::GenYLGL()
{
	// 1.Jeff.删除文件,g_mainpath服务器DBServer.exe的目录;
	CString autorunpath = g_mainpath + "\\YLGL.exe";
	::DeleteFile(autorunpath);	// 删除YLGL.exe

	WriteTextLog("命令行启动：" + autorunpath);
	// 2.重新生成YLGL.exe
	CRstUpdate rsSt;
	rsSt.m_pDatabase = &g_db;
	rsSt.Open();
	if (!rsSt.IsEOF())
	{
		CFile fp;
		if (fp.Open(autorunpath, CFile::modeCreate | CFile::modeWrite))
		{
			void *pData = GlobalLock(rsSt.data.m_hData);
			fp.Write(pData, rsSt.data.m_dwDataLength);
			fp.Close();
			GlobalUnlock(rsSt.data.m_hData);
		}
	}
	rsSt.Close();

	// 3.执行YLGL.exe
	ShellExecute(NULL, _T("open"), autorunpath, "genbranchdata", NULL, SW_HIDE);
}
//105