// CrowdMsgRowSet.cpp : implementation file
|
//
|
|
#include "stdafx.h"
|
#include "mbamdb.h"
|
#include "CrowdMsgRowSet.h"
|
|
|
// CCrowdMsgRowSet
|
|
CCrowdMsgRowSet::CCrowdMsgRowSet()
|
{
|
m_pDBConnect = NULL;
|
m_pMsgs = NULL;
|
m_nType = ROWTYPE_NONE;
|
}
|
|
CCrowdMsgRowSet::~CCrowdMsgRowSet()
|
{
|
CleanDataSet( );
|
}
|
|
|
// CCrowdMsgRowSet member functions
|
void CCrowdMsgRowSet::operator = ( const CCrowdMsgRowSet &Item )
|
{
|
m_strStartDate = Item.m_strStartDate;
|
m_strEndDate = Item.m_strEndDate;
|
m_pDBConnect = Item.m_pDBConnect;
|
m_pMsgs = Item.m_pMsgs;
|
m_nType = Item.m_nType;
|
}
|
|
void CCrowdMsgRowSet::CleanDataSet( )
|
{
|
switch ( m_nType )
|
{
|
case ROWTYPE_CROWDMSG:
|
if(m_pMsgs)
|
delete m_pMsgs;
|
m_pMsgs = NULL;
|
break;
|
default:
|
break;
|
}
|
|
m_nType = ROWTYPE_NONE;
|
}
|
|
bool CCrowdMsgRowSet::SetDBConnect( CMBAMDBConnect *pDBConnect )
|
{
|
m_pDBConnect = pDBConnect;
|
|
return true;
|
}
|
bool CCrowdMsgRowSet::ListCrowdMsg2( CString strCrowdID, long nLimitCount, long &nCount, BOOL bTimeAsc/* = FALSE */ )
|
{
|
nCount = 0;
|
if ( strCrowdID.IsEmpty() )
|
return false;
|
if ( !m_pDBConnect || !m_pDBConnect->IsOpenDB() )
|
return false;
|
CleanDataSet();
|
|
m_pDBConnect->AddRef();
|
m_pMsgs = new CCrowdMsgs( m_pDBConnect );
|
|
CHighTime tmHigh;
|
SYSTEMTIME tmSystem;
|
// Set Filter
|
if ( !m_strStartDate.IsEmpty() && tmHigh.ParseDateTime( m_strStartDate ) )
|
{
|
tmHigh.GetAsSystemTime( tmSystem );
|
if ( tmSystem.wSecond < 0 )
|
tmSystem.wSecond = 0;
|
|
m_pMsgs->m_tmStartDate = COleDateTime( tmSystem.wYear, tmSystem.wMonth, tmSystem.wDay,
|
tmSystem.wHour, tmSystem.wMinute, tmSystem.wSecond );
|
}
|
if ( !m_strEndDate.IsEmpty() && tmHigh.ParseDateTime( m_strEndDate ) )
|
{
|
tmHigh.GetAsSystemTime( tmSystem );
|
if ( tmSystem.wSecond < 0 )
|
tmSystem.wSecond = 0;
|
|
m_pMsgs->m_tmEndDate = COleDateTime( tmSystem.wYear, tmSystem.wMonth, tmSystem.wDay,
|
tmSystem.wHour, tmSystem.wMinute, tmSystem.wSecond );
|
}
|
|
int nMsgCount(0);
|
nMsgCount = m_pMsgs->ListCrowdAll2( strCrowdID,nLimitCount, bTimeAsc);
|
if ( nMsgCount <= 0 )
|
{
|
delete m_pMsgs;
|
m_pMsgs = NULL;
|
return true;
|
}
|
|
m_pMsgs->GetData( );
|
m_nType = ROWTYPE_CROWDMSG;
|
nCount = nMsgCount;
|
return true;
|
}
|
bool CCrowdMsgRowSet::ListCrowdMsg( CString strCrowdID, long &nCount, BOOL bTimeAsc/* = FALSE */ )
|
{
|
nCount = 0;
|
if ( strCrowdID.IsEmpty() )
|
return false;
|
if ( !m_pDBConnect || !m_pDBConnect->IsOpenDB() )
|
return false;
|
CleanDataSet();
|
|
m_pDBConnect->AddRef();
|
m_pMsgs = new CCrowdMsgs( m_pDBConnect );
|
|
CHighTime tmHigh;
|
SYSTEMTIME tmSystem;
|
// Set Filter
|
if ( !m_strStartDate.IsEmpty() && tmHigh.ParseDateTime( m_strStartDate ) )
|
{
|
tmHigh.GetAsSystemTime( tmSystem );
|
if ( tmSystem.wSecond < 0 )
|
tmSystem.wSecond = 0;
|
|
m_pMsgs->m_tmStartDate = COleDateTime( tmSystem.wYear, tmSystem.wMonth, tmSystem.wDay,
|
tmSystem.wHour, tmSystem.wMinute, tmSystem.wSecond );
|
}
|
if ( !m_strEndDate.IsEmpty() && tmHigh.ParseDateTime( m_strEndDate ) )
|
{
|
tmHigh.GetAsSystemTime( tmSystem );
|
if ( tmSystem.wSecond < 0 )
|
tmSystem.wSecond = 0;
|
|
m_pMsgs->m_tmEndDate = COleDateTime( tmSystem.wYear, tmSystem.wMonth, tmSystem.wDay,
|
tmSystem.wHour, tmSystem.wMinute, tmSystem.wSecond );
|
}
|
|
int nMsgCount(0);
|
nMsgCount = m_pMsgs->ListCrowdAll( strCrowdID, bTimeAsc);
|
if ( nMsgCount <= 0 )
|
{
|
delete m_pMsgs;
|
m_pMsgs = NULL;
|
return true;
|
}
|
|
m_pMsgs->GetData( );
|
m_nType = ROWTYPE_CROWDMSG;
|
nCount = nMsgCount;
|
return true;
|
}
|
|
bool CCrowdMsgRowSet::SetMsgFilterDate( CString strStartDate, CString strEndDate )
|
{
|
m_strStartDate = strStartDate;
|
m_strEndDate = strEndDate;
|
|
return true;
|
}
|
bool CCrowdMsgRowSet::Top( )
|
{
|
switch ( m_nType )
|
{
|
case ROWTYPE_CROWDMSG:
|
if ( !m_pMsgs->MoveFirst() )
|
return false;
|
break;
|
default:
|
return false;
|
break;
|
}
|
return true;
|
}
|
|
|
bool CCrowdMsgRowSet::Prev()
|
{
|
switch ( m_nType )
|
{
|
case ROWTYPE_CROWDMSG:
|
if ( !m_pMsgs->MovePrev() )
|
return false;
|
break;
|
default:
|
return false;
|
break;
|
}
|
|
return true;
|
}
|
|
bool CCrowdMsgRowSet::Next( )
|
{
|
switch ( m_nType )
|
{
|
case ROWTYPE_CROWDMSG:
|
if ( !m_pMsgs->MoveNext() )
|
return false;
|
break;
|
default:
|
return false;
|
break;
|
}
|
|
return true;
|
}
|
|
bool CCrowdMsgRowSet::MoveTo( long nPos )
|
{
|
switch ( m_nType )
|
{
|
case ROWTYPE_CROWDMSG:
|
if ( !m_pMsgs->MoveTo( nPos ) )
|
return false;
|
break;
|
|
default:
|
return false;
|
break;
|
}
|
|
return true;
|
}
|
|
bool CCrowdMsgRowSet::GetRow( CCrowdMsgRow *pCrowdRow )
|
{
|
if ( !pCrowdRow )
|
return false;
|
pCrowdRow->m_pCursor = m_pMsgs;
|
return true;
|
}
|
|
bool CCrowdMsgRowSet::GetItemValue( CString strItemName, VARIANT &vData )
|
{
|
vData.vt = VT_EMPTY;
|
|
CString strName = strItemName;
|
if ( strName.IsEmpty() )
|
return false;
|
|
COleVariant oleData;
|
|
switch ( m_nType )
|
{
|
case ROWTYPE_CROWDMSG:
|
{
|
if ( !m_pMsgs )
|
return false;
|
|
m_pMsgs->GetData( );
|
if ( !((*m_pMsgs).GetItemValue( strName, oleData )) )
|
return false;
|
}
|
break;
|
default:
|
return false;
|
break;
|
}
|
|
vData = oleData;
|
return true;
|
}
|
|
bool CCrowdMsgRowSet::GetItemValueStr( CString strItemName, CString &strData )
|
{
|
CString strValue = _T( "" );
|
CString strName = strItemName;
|
if ( strName.IsEmpty() )
|
return false;
|
|
switch ( m_nType )
|
{
|
case ROWTYPE_CROWDMSG:
|
{
|
if ( !m_pMsgs )
|
return false;
|
|
m_pMsgs->GetData( );
|
if ( !((*m_pMsgs).GetItemValue( strName, strValue )) )
|
return false;
|
}
|
break;
|
default:
|
return false;
|
break;
|
}
|
|
strData = strValue;
|
return true;
|
}
|
|
bool CCrowdMsgRowSet::ListSearchCrowdMsg( CString strCrowdID, CString strKey, long &nCount, BOOL bTimeAsc/* = FALSE */ )
|
{
|
nCount = 0;
|
if ( strCrowdID.IsEmpty() )
|
return false;
|
if ( !m_pDBConnect || !m_pDBConnect->IsOpenDB() )
|
return false;
|
CleanDataSet();
|
|
m_pDBConnect->AddRef();
|
m_pMsgs = new CCrowdMsgs( m_pDBConnect );
|
|
CHighTime tmHigh;
|
SYSTEMTIME tmSystem;
|
// Set Filter
|
if ( !m_strStartDate.IsEmpty() && tmHigh.ParseDateTime( m_strStartDate ) )
|
{
|
tmHigh.GetAsSystemTime( tmSystem );
|
if ( tmSystem.wSecond < 0 )
|
tmSystem.wSecond = 0;
|
|
m_pMsgs->m_tmStartDate = COleDateTime( tmSystem.wYear, tmSystem.wMonth, tmSystem.wDay,
|
tmSystem.wHour, tmSystem.wMinute, tmSystem.wSecond );
|
}
|
if ( !m_strEndDate.IsEmpty() && tmHigh.ParseDateTime( m_strEndDate ) )
|
{
|
tmHigh.GetAsSystemTime( tmSystem );
|
if ( tmSystem.wSecond < 0 )
|
tmSystem.wSecond = 0;
|
|
m_pMsgs->m_tmEndDate = COleDateTime( tmSystem.wYear, tmSystem.wMonth, tmSystem.wDay,
|
tmSystem.wHour, tmSystem.wMinute, tmSystem.wSecond );
|
}
|
|
int nMsgCount(0);
|
nMsgCount = m_pMsgs->ListSearchCrowdAll( strCrowdID,strKey, bTimeAsc);
|
if ( nMsgCount <= 0 )
|
{
|
delete m_pMsgs;
|
m_pMsgs = NULL;
|
return true;
|
}
|
m_pMsgs->GetData( );
|
m_nType = ROWTYPE_CROWDMSG;
|
nCount = nMsgCount;
|
return true;
|
}
|
|
bool CCrowdMsgRowSet::ListRecordCount( long &nCount )
|
{
|
nCount = 0;
|
switch ( m_nType )
|
{
|
case ROWTYPE_CROWDMSG:
|
if ( m_pMsgs )
|
nCount = m_pMsgs->ListRecordCount();
|
break;
|
default:
|
return false;
|
break;
|
}
|
|
return true;
|
}
|
|
bool CCrowdMsgRowSet::ListSearchCrowdMsgBox( CString strCrowdID, CString strKey, long &nCount, BOOL bTimeAsc/* = FALSE */ )
|
{
|
nCount = 0;
|
if ( strCrowdID.IsEmpty() )
|
return false;
|
if ( !m_pDBConnect || !m_pDBConnect->IsOpenDB() )
|
return false;
|
CleanDataSet();
|
|
m_pDBConnect->AddRef();
|
m_pMsgs = new CCrowdMsgs( m_pDBConnect );
|
|
CHighTime tmHigh;
|
SYSTEMTIME tmSystem;
|
// Set Filter
|
if ( !m_strStartDate.IsEmpty() && tmHigh.ParseDateTime( m_strStartDate ) )
|
{
|
tmHigh.GetAsSystemTime( tmSystem );
|
if ( tmSystem.wSecond < 0 )
|
tmSystem.wSecond = 0;
|
|
m_pMsgs->m_tmStartDate = COleDateTime( tmSystem.wYear, tmSystem.wMonth, tmSystem.wDay,
|
tmSystem.wHour, tmSystem.wMinute, tmSystem.wSecond );
|
}
|
if ( !m_strEndDate.IsEmpty() && tmHigh.ParseDateTime( m_strEndDate ) )
|
{
|
tmHigh.GetAsSystemTime( tmSystem );
|
if ( tmSystem.wSecond < 0 )
|
tmSystem.wSecond = 0;
|
|
m_pMsgs->m_tmEndDate = COleDateTime( tmSystem.wYear, tmSystem.wMonth, tmSystem.wDay,
|
tmSystem.wHour, tmSystem.wMinute, tmSystem.wSecond );
|
}
|
|
int nMsgCount(0);
|
nMsgCount = m_pMsgs->ListSearchCrowdMsgBox( strCrowdID,strKey, bTimeAsc);
|
if ( nMsgCount <= 0 )
|
{
|
delete m_pMsgs;
|
m_pMsgs = NULL;
|
return true;
|
}
|
m_pMsgs->GetData( );
|
m_nType = ROWTYPE_CROWDMSG;
|
nCount = nMsgCount;
|
return true;
|
}
|
