// CrowdMsgItem.cpp : implementation file
//

#include "stdafx.h"
#include "mbamdb.h"
#include "CrowdMsg.h"
#include "MBAMDBFun.h"
#include "PerfTimer.h"


#define		LISTMSG_TYPE_NONE			( 0 )		// ĬÈÏÏÔʾµÄÏûÏ¢
#define		LISTMSG_TYPE_MAGADMIN		( 3 )		// ÁгöÏûÏ¢ID


// CCrowdMsgItem
extern CCriticalSection  	m_csConnectDB;
CCrowdMsgItem::CCrowdMsgItem()
{
	m_nRowType	= ROWTYPE_CROWDMSG;
	Clear();
}

CCrowdMsgItem::~CCrowdMsgItem()
{
}


// CCrowdMsgItem member functions
void CCrowdMsgItem::Clear()
{
	m_strID			= GUID_EMPTY;
	m_strSender		= _T("");
	m_strSenderName	= _T("");
	m_strCrowdID	= _T("");
	m_strCrowdName	= _T("");
	m_tmDate	= COleDateTime::GetCurrentTime( );
	m_nMsgFlag			= 0;
	m_nReadState		= 0;
	m_strContentType = _T("");
	m_strContent = _T("");
	m_nContentSize = 0;
	m_strContentText = _T("");
}

BOOL CCrowdMsgItem::GetItemValue( CString strName, COleVariant &varData )
{  
	varData.Clear();
	if ( strName.IsEmpty() )
		return	false;

	if ( strName.CompareNoCase( _T( "ID" ) ) == 0 )
		varData		= m_strID;
	else if ( strName.CompareNoCase( _T("CrowdID") ) == 0 )
		varData		= m_strCrowdID;
	else if ( strName.CompareNoCase( _T("CrowdName") ) == 0 )
		varData		= m_strCrowdName;
	else if ( strName.CompareNoCase( _T( "Sender" ) ) == 0 )
		varData		= m_strSender;
	else if ( strName.CompareNoCase( _T( "SenderName" ) ) == 0 )
		varData		= m_strSenderName;
	else if ( strName.CompareNoCase( _T( "SendDate" ) ) == 0 )
	{
		if( !( m_tmDate.GetStatus() == COleDateTime::valid ) )
		{
			COleDateTime  temptime(2000,1,1, 0, 0, 0);
			m_tmDate = temptime;
		}
		
		COleDateTime	oleDate( m_tmDate.GetYear(), m_tmDate.GetMonth(), m_tmDate.GetDay(), m_tmDate.GetHour(), 
							m_tmDate.GetMinute(), m_tmDate.GetSecond() );
		varData		= oleDate;
	}
	else if ( strName.CompareNoCase( _T( "ReadState" ) ) == 0 )
		varData		= m_nReadState;
	else if ( strName.CompareNoCase( _T( "MsgFlag" ) ) == 0 )
		varData		= m_nMsgFlag;
	else if ( strName.CompareNoCase( _T( "SenderName" ) ) == 0 )
		varData		= m_strSenderName;
	if ( strName.CompareNoCase( _T( "ContentType" ) ) == 0 )
		varData		= m_strContentType;
	else if ( strName.CompareNoCase( _T( "ContentSize" ) ) == 0 )
		varData		= (long)m_nContentSize;
	else if ( strName.CompareNoCase( _T( "Content" ) ) == 0 )
		varData		= m_strContent;
	else
		return	false;

	return	true;
}

BOOL CCrowdMsgItem::InsertRecord( CDBConnect *pAConnect)
{
	CString			strSQL;
	BOOL			bReturn = true;

	strSQL.Format( _T("INSERT INTO TN_STK_CROWDMSG(G_C1, G_C2 ,S_C3, S_C4, S_C5, T_C6, \
			N_C7, N_C8,S_C9,N_C10,S_C11,S_C12 ) VALUES ( \
		'%s', '%s', '%s', '%s', '%s','%s', %d, %d,'%s', %d,'%s','%s' )"),  
		m_strID, m_strCrowdID,m_strCrowdName, CMBAMDBFun::GetDBReplaceStr( m_strSender ),
		CMBAMDBFun::GetDBReplaceStr( m_strSenderName ), CMBAMDBFun::FormatDBTIMEToStr( m_tmDate ),
		m_nReadState, m_nMsgFlag, CMBAMDBFun::GetDBReplaceStr( m_strContentType), m_nContentSize ,
		CMBAMDBFun::GetDBReplaceStr( m_strContent ),CMBAMDBFun::GetDBReplaceStr( m_strContentText)  );
	try
	{
		bReturn = CDBSQLiteCommFun::RunSQL(strSQL, pAConnect);
	}
	catch ( CDBSQliteException ex )
	{
		CString		strError = ex.GetErrInfo();
		CString		strErrInfo;

		strErrInfo = _T("InsertRecord - CrowdMsg- ") + strError;
		CMBAMDBFun::WriteDBErrToFile( strErrInfo );
		return false;
	}
	return true;
}
BOOL CCrowdMsgItem::UpdateRecord( CDBConnect *pAConnect )
{
	CString			strSQL;
	BOOL			bReturn = true;

	strSQL.Format( _T("UPDATE TN_STK_CROWDMSG SET G_C2 = '%s' ,S_C3= '%s', S_C4 = '%s', S_C5 = '%s', T_C6 = '%s',\
		N_C7 = %d, N_C8 =%d , S_C9 ='%s', N_C10 =%d, S_C11 ='%s',S_C12 ='%s' WHERE G_C1 = '%s'"), 
		m_strCrowdID,m_strCrowdName, CMBAMDBFun::GetDBReplaceStr( m_strSender ), CMBAMDBFun::GetDBReplaceStr( m_strSenderName ),
		CMBAMDBFun::FormatDBTIMEToStr( m_tmDate ),m_nReadState, m_nMsgFlag, CMBAMDBFun::GetDBReplaceStr( m_strContentType ),
		m_nContentSize,CMBAMDBFun::GetDBReplaceStr( m_strContent ),CMBAMDBFun::GetDBReplaceStr( m_strContentText ),  m_strID );
	try
	{
		bReturn = CDBSQLiteCommFun::RunSQL(strSQL, pAConnect);
	}
	catch ( CDBSQliteException ex )
	{
		CString		strError = ex.GetErrInfo();
		CString		strErrInfo;

		strErrInfo.Format( _T("UpdateRecord(%s) - CrowdMsg - %s "),strSQL, strError);
		CMBAMDBFun::WriteDBErrToFile( strErrInfo );
		return false;
	}
	return true;
}

CCrowdMsgs::CCrowdMsgs(CMBAMDBConnect *pAConnect)
{
	m_pAConnect = pAConnect;
	InitFilter();
	
}

CCrowdMsgs::~CCrowdMsgs()
{
	
}
void CCrowdMsgs::operator =( const CCrowdMsgs& item )
{
	m_nListMsgType	= item.m_nListMsgType;
	m_tmStartDate		= item.m_tmStartDate;
	m_tmEndDate			= item.m_tmEndDate;
	m_nReaded			= item.m_nReaded; // "-1"±íʾ²»Ö¸¶¨Õâ¸ö¹ýÂËÌõ¼þ
	m_pAConnect			= item.m_pAConnect;
	m_strSQL			= item.m_strSQL;
	m_nRowType			= item.m_nRowType;
	m_strID = item.m_strID;
	m_strCrowdID = item.m_strCrowdID;
	m_strCrowdName = item.m_strCrowdName;
	m_strSender = item.m_strSender;
	m_strSenderName = item.m_strSenderName;
	m_tmDate = item.m_tmDate;
	m_nReadState = item.m_nReadState;
	m_nMsgFlag = item.m_nMsgFlag;
	m_strContentType = item.m_strContentType;
	m_nContentSize = item.m_nContentSize;
	m_strContent = item.m_strContent;
}
void CCrowdMsgs::InitFilter()
{ 
	// ³õʼ»¯¹ýÂËÆ÷ʹȥ³ý¹ýÂË
	m_tmStartDate	= COleDateTime( 1970, 1, 1, 0, 0, 0 );
	m_tmEndDate		= COleDateTime( 1970, 1, 1, 0, 0, 0 );
	m_nListMsgType = LISTMSG_TYPE_NONE;
	m_nReaded		= -1; // "-1"±íʾ²»Ö¸¶¨Õâ¸ö¹ýÂËÌõ¼þ
}
int CCrowdMsgs::ListUnreadMsg( )
{
	CString			strSQL;
	int				nCount;
	// end modify
	strSQL.Format(_T("SELECT G_C1, G_C2 ,S_C3, S_C4, S_C5, T_C6, \
			N_C7, N_C8,S_C9,N_C10,S_C11,S_C12 \
			FROM TN_STK_CROWDMSG WHERE N_C7 <= 1 ORDER BY T_C6 DESC") );
	m_strSQL = strSQL; // 2: IOPEN , 1: InBox

	if( !m_pAConnect || !m_pAConnect->IsOpenDB())
		return	0;
	try
	{
		nCount = ListRecordCount();
		m_ARecordSet.Close();
		m_ARecordSet.Open( m_pAConnect->GetDBConnect(), strSQL );
		if(nCount >0)
			m_ARecordSet.MoveFirst();
		
	}
	catch( CDBSQliteException ex )
	{
		CString		strError;

		strError = (LPCTSTR)ex.GetErrInfo();

		return 0;
	}

	if ( nCount > 0 )
		GetData( );

	return nCount;
}
void CCrowdMsgs::SetCrowdMsgReadState(CString  strCrowdID  )
{
	CString			strSQL;
	// end modify
	strSQL.Format(_T("UPDATE TN_STK_CROWDMSG SET N_C7=%d WHERE N_C7 <= 1 AND G_C2 ='%s'"), MSG_READSTATE_IOPEN,strCrowdID);
	m_strSQL = strSQL; // 2: IOPEN , 1: InBox

	if( !m_pAConnect || !m_pAConnect->IsOpenDB())
		return;
	try
	{
		CDBSQLiteCommFun::RunSQL( (LPCTSTR)strSQL,m_pAConnect->GetDBConnect());
		
	}
	catch( CDBSQliteException ex )
	{
		CString		strError;

		strError = (LPCTSTR)ex.GetErrInfo();

		return ;
	}
	return ;
}

int CCrowdMsgs::ListCrowdAll2(CString  strCrowdID,long nLimitCount,  BOOL bTimeAsc /*= FALSE*/ )
{ // ʹÓÃÕâ¸öº¯Êý¹ýÂËÆ÷ÎÞЧ
	CString			strSQL;
	int					nCount = 0;
	CString 			strStartDate;
	CString		    	strEndDate;
	CString		    	strSQLTempM;
	if( !m_pAConnect || !m_pAConnect->IsOpenDB())
		return	0;
	if ( m_tmStartDate.GetYear() > 1970 || m_tmEndDate.GetYear() > 1970 )
	{
		if ( m_tmEndDate.GetYear() == 1970 )
			m_tmEndDate = COleDateTime::GetCurrentTime( );	
		
		strStartDate	= CMBAMDBFun::FormatDBTIMEToStr( m_tmStartDate );
		strEndDate		= CMBAMDBFun::FormatDBTIMEToStr( m_tmEndDate );
		
		strSQLTempM.Format( _T(" AND T_C6 >= '%s' AND T_C6 <= '%s'"), strStartDate, strEndDate );
	}
	CString strLimitSQL = _T("");
	if(nLimitCount > 0)
		strLimitSQL.Format( _T("limit 0,%d"), nLimitCount);
	if( bTimeAsc)
		strSQL.Format(_T("SELECT T.* FROM ( \
			SELECT G_C1, G_C2 ,S_C3, S_C4, S_C5, T_C6, \
			N_C7, N_C8,S_C9,N_C10,S_C11,S_C12 \
			FROM TN_STK_CROWDMSG WHERE G_C2 = '%s' %s ORDER BY T_C6 DESC %s)T ORDER BY T.T_C6 ASC "), strCrowdID, strSQLTempM,strLimitSQL);
	else
		strSQL.Format(_T("SELECT G_C1, G_C2 ,S_C3, S_C4, S_C5, T_C6, \
			N_C7, N_C8,S_C9,N_C10,S_C11,S_C12 \
			FROM TN_STK_CROWDMSG WHERE G_C2 = '%s' %s ORDER BY T_C6 DESC %s"), strCrowdID, strSQLTempM,strLimitSQL);
	m_strSQL = strSQL;
	if( !m_pAConnect || !m_pAConnect->IsOpenDB())
		return	0;
	try
	{
		nCount = ListRecordCount();
		m_ARecordSet.Close();
		m_ARecordSet.Open( m_pAConnect->GetDBConnect(), strSQL );
		//m_ARecordSet.MoveFirst();
		//nCount = m_ARecordSet.GetRecordCount( );	
	}
	catch( CDBSQliteException ex )
	{
		CString		strError;

		strError = (LPCTSTR)ex.GetErrInfo(  );

		return 0;
	}

	return nCount;
}

int CCrowdMsgs::ListCrowdAll(CString  strCrowdID, BOOL bTimeAsc /*= FALSE*/ )
{ // ʹÓÃÕâ¸öº¯Êý¹ýÂËÆ÷ÎÞЧ
	CString			strSQL;
	int					nCount = 0;
	CString 			strStartDate;
	CString		    	strEndDate;
	CString		    	strSQLTempM;

	if( !m_pAConnect || !m_pAConnect->IsOpenDB())
		return	0;
	if ( m_tmStartDate.GetYear() > 1970 || m_tmEndDate.GetYear() > 1970 )
	{
		if ( m_tmEndDate.GetYear() == 1970 )
			m_tmEndDate = COleDateTime::GetCurrentTime( );	
		
		strStartDate	= CMBAMDBFun::FormatDBTIMEToStr( m_tmStartDate );
		strEndDate		= CMBAMDBFun::FormatDBTIMEToStr( m_tmEndDate );
		
		strSQLTempM.Format( _T(" AND T_C6 >= '%s' AND T_C6 <= '%s'"), strStartDate, strEndDate );
	}
	if( bTimeAsc)
		strSQL.Format(_T("SELECT G_C1, G_C2 ,S_C3, S_C4, S_C5, T_C6, \
			N_C7, N_C8,S_C9,N_C10,S_C11,S_C12 \
			FROM TN_STK_CROWDMSG WHERE G_C2 = '%s' %s ORDER BY T_C6 ASC "), strCrowdID,strSQLTempM);
	else
		strSQL.Format(_T("SELECT G_C1, G_C2 ,S_C3, S_C4, S_C5, T_C6, \
			N_C7, N_C8,S_C9,N_C10,S_C11,S_C12 \
			FROM TN_STK_CROWDMSG WHERE G_C2 = '%s' %s ORDER BY T_C6 DESC "), strCrowdID,strSQLTempM);
	m_strSQL = strSQL;
	if( !m_pAConnect || !m_pAConnect->IsOpenDB())
		return	0;
	try
	{
		nCount = ListRecordCount();
		m_ARecordSet.Close();
		m_ARecordSet.Open( m_pAConnect->GetDBConnect(), strSQL );
		//m_ARecordSet.MoveFirst();
		//nCount = m_ARecordSet.GetRecordCount( );	
	}
	catch( CDBSQliteException ex )
	{
		CString		strError;

		strError = (LPCTSTR)ex.GetErrInfo(  );

		return 0;
	}

	return nCount;
}

bool CCrowdMsgs::GetMsgData( )
{
	CString		strFieldName;
	CString		strTempValue;

	try	
	{
		m_ARecordSet.GetValue( 1, strTempValue, true );
		m_strID			= strTempValue;

		m_ARecordSet.GetValue( 2, strTempValue, true );
		m_strCrowdID	= strTempValue;

		m_ARecordSet.GetValue( 3, strTempValue, true );
		m_strCrowdName	= strTempValue;

		m_ARecordSet.GetValue( 4, strTempValue, true );
		m_strSender		= strTempValue;

		m_ARecordSet.GetValue( 5, strTempValue, true );
		m_strSenderName = strTempValue;

		m_ARecordSet.GetValue( 6, m_tmDate);
		m_ARecordSet.GetValue( 7, m_nReadState );
		m_ARecordSet.GetValue( 8, m_nMsgFlag );

		m_ARecordSet.GetValue( 9, strTempValue, true );
		m_strContentType = strTempValue;
		m_ARecordSet.GetValue( 10, m_nContentSize );
		m_ARecordSet.GetValue( 11, strTempValue, true );
		m_strContent = strTempValue;
		m_ARecordSet.GetValue( 12, strTempValue, true );
		m_strContentText = strTempValue;
	}
	catch ( CDBSQliteException ex )
	{
		CString		strError;

		strError = (LPCTSTR)ex.GetErrInfo( );
		return false;
	}

	return true;
}
bool CCrowdMsgs::GetMsgAdminData( )
{
	if( !m_pAConnect || !m_pAConnect->IsOpenDB())
		return	0;
	CDBRecord	ARecordset;
	CString				strTempValue;
	try	
	{
		m_ARecordSet.GetValue( 1, strTempValue, true );
		m_strID			= strTempValue;
	}
	catch ( CDBSQliteException ex )
	{
		CString		strError;

		strError = (LPCTSTR)ex.GetErrInfo();
		return false;
	}

	return true;
}
bool CCrowdMsgs::GetData( )
{
	InitMsgData( );
	if(m_nListMsgType == LISTMSG_TYPE_MAGADMIN)
	{
		GetMsgAdminData( );
	}
	else
		GetMsgData( );
	return true;
}
void CCrowdMsgs::InitMsgData( )
{
	Clear( );
}
int CCrowdMsgs::ListSpMsgID( LPCTSTR lpszMsgID )
{ // ʹÓÃÕâ¸öº¯Êý£¬¹ýÂËÌõ¼þÎÞЧ
	if ( lpszMsgID == NULL )
		return	0;

	CString			strSQL;
	int					nCount;
	strSQL.Format( _T("SELECT G_C1, G_C2 ,S_C3, S_C4, S_C5, T_C6, \
			N_C7, N_C8,S_C9,N_C10,S_C11,S_C12 \
			FROM TN_STK_CROWDMSG WHERE G_C1 = '%s'"), lpszMsgID);
	m_strSQL = strSQL;


	if( !m_pAConnect || !m_pAConnect->IsOpenDB())
		return	0;
	try
	{
		m_ARecordSet.Close();
		m_ARecordSet.Open( m_pAConnect->GetDBConnect(), strSQL );
		m_ARecordSet.MoveFirst();
		nCount = m_ARecordSet.GetRecordCount( );
		m_strID = lpszMsgID;
	}
	catch( CDBSQliteException ex )
	{
		CString		strError;

		strError = (LPCTSTR)ex.GetErrInfo( );

		return 0;
	}

	return nCount;
}

int CCrowdMsgs::ListSearchCrowdAll(CString  strCrowdID, CString strKey, BOOL bTimeAsc /*= FALSE*/ )
{ // ʹÓÃÕâ¸öº¯Êý¹ýÂËÆ÷ÎÞЧ
	CString			strSQL;
	int				nCount = 0;
	CString			strTemp;
	CString 			strStartDate;
	CString		    	strEndDate;
	CString				strSQLTempM;

	
	if ( m_tmStartDate.GetYear() > 1970 || m_tmEndDate.GetYear() > 1970 )
	{
		if ( m_tmEndDate.GetYear() == 1970 )
			m_tmEndDate = COleDateTime::GetCurrentTime( );	
		
		strStartDate	= CMBAMDBFun::FormatDBTIMEToStr( m_tmStartDate );
		strEndDate		= CMBAMDBFun::FormatDBTIMEToStr( m_tmEndDate );
		
		strSQLTempM.Format( _T(" AND T_C6 >= '%s' AND T_C6 <= '%s'"), strStartDate, strEndDate );
	}
	if( !strKey.IsEmpty() )
	strTemp.Format( _T("AND S_C12 LIKE '%%%s%%' "), strKey );

	if( bTimeAsc)
		strSQL.Format(_T("SELECT G_C1, G_C2 ,S_C3, S_C4, S_C5, T_C6, \
			N_C7, N_C8,S_C9,N_C10,S_C11,S_C12 \
			FROM TN_STK_CROWDMSG WHERE G_C2 = '%s'%s %s ORDER BY T_C6 ASC "), strCrowdID, strSQLTempM, strTemp);
	else
		strSQL.Format(_T("SELECT G_C1, G_C2 ,S_C3, S_C4, S_C5, T_C6, \
			N_C7, N_C8,S_C9,N_C10,S_C11,S_C12 \
			FROM TN_STK_CROWDMSG WHERE G_C2 = '%s'%s %s ORDER BY T_C6 DESC "), strCrowdID,strSQLTempM, strTemp);
	m_strSQL = strSQL;

	if( !m_pAConnect || !m_pAConnect->IsOpenDB())
		return	0;
	try
	{
		nCount = ListRecordCount();
		m_ARecordSet.Close();
		m_ARecordSet.Open( m_pAConnect->GetDBConnect(), strSQL );
		//m_ARecordSet.MoveFirst();
		//nCount = m_ARecordSet.GetRecordCount( );	
	}
	catch( CDBSQliteException ex )
	{
		CString		strError;

		strError = (LPCTSTR)ex.GetErrInfo(  );

		return 0;
	}

	return nCount;
}

BOOL CCrowdMsgs::DoSaveCrowdMsg( CCrowdMsgItem *pMsg )
{
	if ( !pMsg || pMsg->m_strID.IsEmpty() )
		return	false;
	if( !m_pAConnect || !m_pAConnect->IsOpenDB())
		return	0;
	CDBConnect	*pAConnect = m_pAConnect->GetDBConnect();
	long			nMsgIndex(0);
	BOOL			bRetValue = false;
	CPerfTimer		pt;
	CString			strMsgID;
	
	strMsgID			= pMsg->m_strID;
	m_strID			= pMsg->m_strID;
	m_strCrowdID	= pMsg->m_strCrowdID;
	m_strCrowdName	= pMsg->m_strCrowdName;
	m_strSender		= pMsg->m_strSender;
	m_strSenderName	= pMsg->m_strSenderName;
	m_tmDate		= pMsg->m_tmDate;;
	m_nMsgFlag			= pMsg->m_nMsgFlag;
	m_nReadState	= pMsg->m_nReadState;
	m_strContentType	= pMsg->m_strContentType;
	m_nContentSize	= pMsg->m_strContent.GetLength();
	m_strContent		= pMsg->m_strContent;
	m_strContentText		= pMsg->m_strContentText;

	{
		pt.Start();
		InsertRecord( pAConnect );
		pt.Stop();
		pt.Trace( _T("DoSaveCrowdMsg\r\n") );
	}
	CString strSubject,strTempData;
	strTempData = CMBAMDBFun::GetSubjectFromFormatText(m_strContent);
	strTempData = CMBAMDBFun::GetRelSubject(strTempData, 64);

	strSubject.Format(_T("%s:%s"),m_strSenderName,strTempData);
	UpldateLastContactDate( m_strCrowdID,m_strCrowdName, CMBAMDBFun::FormatDBTIMEToStr( m_tmDate ),strSubject  );
	return	true;
}

long CCrowdMsgs::ListRecordCount(  )
{
	CString strTempSQL;
	if(m_strSQL.IsEmpty())
		return  m_ARecordSet.GetRecordCount( );	
	else
	{
		strTempSQL.Format(_T("	SELECT COUNT(*) FROM ( %s)T"), m_strSQL);
		long			nTempValue = 0;
		if( !m_pAConnect || !m_pAConnect->IsOpenDB())
			return	nTempValue;
		CDBRecord	ARecordset;
		try	
		{
			ARecordset.Open( m_pAConnect->GetDBConnect(), strTempSQL );
			while ( S_OK == ARecordset.MoveNext() )
			{
				ARecordset.GetValue( 1, nTempValue );
				break;
			}
		}
		catch ( CDBSQliteException ex )
		{
			CString		strError;

			strError = (LPCTSTR)ex.GetErrInfo( );
			return	nTempValue;
		}
		return	nTempValue;
	}
}
BOOL CCrowdMsgs::UpldateLastContactDate( CString strID, CString strName, CString strLastDate, CString strSubject)
{
	CString			strSQL;
	CDBRecord		ARecordset;
	BOOL			bReturn = FALSE;
	int				nVaule = 0;
	CString			strSubSQL = _T("");
	CHighTime		dtCurrent = CHighTime::GetPresentTime();

	if( !m_pAConnect || !m_pAConnect->IsOpenDB())
		return	0;
	CDBConnect	*pAConnect = m_pAConnect->GetDBConnect();

	if( strID.IsEmpty() )
		return TRUE;
	if( !strName.IsEmpty() && strName.CompareNoCase(strID) != 0)
	{
		strSubSQL.Format( _T("S_C2 ='%s',"), CMBAMDBFun::GetDBReplaceStr( strName));
	}
	strSQL.Format( _T("SELECT COUNT(*) FROM TN_STK_LASTCONTACT WHERE S_C1='%s' AND  N_C4=%d "),CMBAMDBFun::GetDBReplaceStr( strID),AM_VIEWITEMTYPE_CROWD);
	try
	{
		ARecordset.Open( pAConnect,strSQL );
		while ( S_OK == ARecordset.MoveNext()  )
		{
			nVaule = 0;
			ARecordset.GetValue( 1, nVaule );
			bReturn = TRUE;
			break;
		}
		if( nVaule > 1 )
		{
			strSQL.Format( _T("DELETE FROM TN_STK_LASTCONTACT WHERE S_C1= '%s' AND  N_C4=%d "), CMBAMDBFun::GetDBReplaceStr( strID),AM_VIEWITEMTYPE_CROWD );
			bReturn = CDBSQLiteCommFun::RunSQL( (LPCTSTR)strSQL,pAConnect);
			if( !bReturn)
				return false;
			strSQL.Format( _T("INSERT INTO TN_STK_LASTCONTACT(S_C1, S_C2 ,T_C3, N_C4, S_C5 ) VALUES ( \
				'%s', '%s', '%s', %d, '%s' )"),  CMBAMDBFun::GetDBReplaceStr( strID), CMBAMDBFun::GetDBReplaceStr( strName),strLastDate,AM_VIEWITEMTYPE_CROWD,CMBAMDBFun::GetDBReplaceStr( strSubject)  );
			bReturn = CDBSQLiteCommFun::RunSQL( (LPCTSTR)strSQL,pAConnect);
			return bReturn;
		}
		else if( nVaule == 1 )
		{
			strSQL.Format( _T("UPDATE TN_STK_LASTCONTACT SET S_C2='%s', T_C3 ='%s', S_C5 ='%s' WHERE S_C1= '%s' AND  N_C4=%d  AND (T_C3<= '%s' OR T_C3 > '%s')"), CMBAMDBFun::GetDBReplaceStr( strName),strLastDate, CMBAMDBFun::GetDBReplaceStr( strSubject), CMBAMDBFun::GetDBReplaceStr( strID),AM_VIEWITEMTYPE_CROWD, strLastDate, CMBAMDBFun::FormatDBTIMEToStr( dtCurrent )  );
			bReturn = CDBSQLiteCommFun::RunSQL( (LPCTSTR)strSQL,pAConnect);
			return bReturn;
		}
		else
		{
			strSQL.Format( _T("INSERT INTO TN_STK_LASTCONTACT(S_C1, S_C2 ,T_C3, N_C4, S_C5 ) VALUES ( \
				'%s', '%s', '%s', %d, '%s' )"),  CMBAMDBFun::GetDBReplaceStr( strID), CMBAMDBFun::GetDBReplaceStr( strName),strLastDate,AM_VIEWITEMTYPE_CROWD,CMBAMDBFun::GetDBReplaceStr( strSubject)  );
			bReturn = CDBSQLiteCommFun::RunSQL( (LPCTSTR)strSQL,pAConnect);
			return bReturn;
		}
	}
	catch ( CDBSQliteException ex )
	{
		CString		strError, strErrInfo;
		
		strError	= ex.GetErrInfo();
		strErrInfo	= _T("CCrowdMsgs UpldateLastContactDate - ") + strError;
		CMBAMDBFun::WriteDBErrToFile( strErrInfo );
		return FALSE;
	}
	return bReturn;
}

int CCrowdMsgs::ListSearchCrowdMsgBox(CString  strCrowdID, CString strKey, BOOL bTimeAsc /*= FALSE*/ )
{ // ʹÓÃÕâ¸öº¯Êý¹ýÂËÆ÷ÎÞЧ
	CString			strSQL;
	int				nCount = 0;
	CString			strTemp;
	CString 			strStartDate;
	CString		    	strEndDate;
	CString				strSQLTempM;

	
	if ( m_tmStartDate.GetYear() > 1970 || m_tmEndDate.GetYear() > 1970 )
	{
		if ( m_tmEndDate.GetYear() == 1970 )
			m_tmEndDate = COleDateTime::GetCurrentTime( );	
		
		strStartDate	= CMBAMDBFun::FormatDBTIMEToStr( m_tmStartDate );
		strEndDate		= CMBAMDBFun::FormatDBTIMEToStr( m_tmEndDate );
		
		strSQLTempM.Format( _T(" AND T_C6 >= '%s' AND T_C6 <= '%s'"), strStartDate, strEndDate );
	}
	if( !strKey.IsEmpty() )
	strTemp.Format( _T("AND S_C12 LIKE '%%%s%%' "), strKey );

	if( bTimeAsc)
		strSQL.Format(_T("SELECT G_C1,T_C6 FROM TN_STK_CROWDMSG WHERE G_C2 = '%s'%s %s ORDER BY T_C6 ASC "), strCrowdID, strSQLTempM, strTemp);
	else
		strSQL.Format(_T("SELECT G_C1,T_C6 FROM TN_STK_CROWDMSG WHERE G_C2 = '%s'%s %s ORDER BY T_C6 DESC "), strCrowdID,strSQLTempM, strTemp);
	m_strSQL = strSQL;

	if( !m_pAConnect || !m_pAConnect->IsOpenDB())
		return	0;
	try
	{
		nCount = ListRecordCount();
		m_ARecordSet.Close();
		m_ARecordSet.Open( m_pAConnect->GetDBConnect(), strSQL );
	}
	catch( CDBSQliteException ex )
	{
		CString		strError;

		strError = (LPCTSTR)ex.GetErrInfo(  );

		return 0;
	}
	m_nListMsgType = LISTMSG_TYPE_MAGADMIN;
	return nCount;
}