// MBAMBaseDBMgr.cpp : implementation file
|
//
|
|
#include "stdafx.h"
|
#include "mbamdb.h"
|
#include "MBAMBaseDBMgr.h"
|
#include "MBAMDBFun.h"
|
#include "MBAMDBDef.h"
|
|
// CMBAMBaseDBMgr
|
extern CCriticalSection m_csConnectDB;
|
|
CMBAMBaseDBMgr::CMBAMBaseDBMgr()
|
{
|
m_bIsCloseDB = TRUE;
|
m_pDBConnect = NULL;
|
m_arSaveToDBMsg.RemoveAll();
|
m_arSaveToDBCrowdMsg.RemoveAll();
|
m_arBatchSaveToDBSyncMsg.RemoveAll();
|
m_arAMOpenMsg.RemoveAll();
|
m_arBackupDBFile.RemoveAll();
|
}
|
|
CMBAMBaseDBMgr::~CMBAMBaseDBMgr()
|
{
|
m_arSaveToDBMsg.RemoveAll();
|
m_arSaveToDBCrowdMsg.RemoveAll();
|
m_arAMOpenMsg.RemoveAll();
|
}
|
|
|
// CMBAMBaseDBMgr member functions
|
void CMBAMBaseDBMgr::CleanDBConnect( )
|
{
|
//SaveAMMsgsOpenDate();
|
CSingleLock lock( &m_csConnectDB, true );
|
if( m_bIsCloseDB)
|
return;
|
m_bIsCloseDB = TRUE;
|
if ( m_pDBConnect )
|
{
|
m_pDBConnect->Release();
|
m_pDBConnect = NULL;
|
}
|
}
|
int CMBAMBaseDBMgr::Logined( CString strLoginName, CString strPassword, CString strServerID, BOOL &bFirstDB)
|
{
|
bFirstDB = FALSE;
|
CMBAMDBConnect *pDBConnect = NULL;
|
BOOL bIsNew = false;
|
|
strLoginName.MakeLower();
|
m_dwLocalVer = VER_STKCLIENTDB;
|
{
|
if ( m_pDBConnect )
|
{
|
if(m_pDBConnect->IsThisDB( strLoginName, strServerID ))
|
{
|
if( m_pDBConnect->IsOpenDB())
|
{
|
return 0;
|
}
|
}
|
if( m_pDBConnect->IsOpenDB())
|
{
|
CleanDBConnect( );
|
m_pDBConnect = NULL;
|
}
|
}
|
if( !m_pDBConnect)
|
{
|
pDBConnect = new CMBAMDBConnect;
|
try
|
{
|
int nRet = pDBConnect->OpenDB( strLoginName, strServerID, bFirstDB ) ;
|
if(nRet)
|
{
|
delete pDBConnect;
|
pDBConnect = NULL;
|
return nRet;
|
}
|
|
}
|
catch ( ... )
|
{
|
return STKERR_DB_OPENEXCEPTION;
|
}
|
m_pDBConnect = pDBConnect;
|
}
|
m_bIsCloseDB = FALSE;
|
if ( !VerifyDBVersion( m_dwLocalVer ) )
|
{
|
CleanDBConnect( );
|
return STKERR_DB_VERIFYDBVERFERROR;
|
}
|
}
|
SetUserInfo( strLoginName, strPassword );
|
SetDBVersion( m_dwLocalVer );
|
m_strServerID = strServerID;
|
m_strLoginName = strLoginName;
|
//SaveNeedSaveMsg();
|
LoadBackupDBFile();
|
return 0;
|
}
|
int CMBAMBaseDBMgr::CreateDBConnect( CString strLoginName,CString strDBFile)
|
{
|
CMBAMDBConnect *pDBConnect = NULL;
|
BOOL bIsNew = false;
|
|
strLoginName.MakeLower();
|
m_dwLocalVer = VER_STKCLIENTDB;
|
{
|
if ( m_pDBConnect )
|
{
|
if( m_pDBConnect->IsOpenDB())
|
{
|
CleanDBConnect( );
|
m_pDBConnect = NULL;
|
}
|
}
|
if( !m_pDBConnect)
|
{
|
pDBConnect = new CMBAMDBConnect;
|
try
|
{
|
int nRet = pDBConnect->OpenDB( strDBFile ) ;
|
if(nRet)
|
{
|
delete pDBConnect;
|
pDBConnect = NULL;
|
return nRet;
|
}
|
|
}
|
catch ( ... )
|
{
|
return STKERR_DB_OPENEXCEPTION;
|
}
|
m_pDBConnect = pDBConnect;
|
}
|
m_bIsCloseDB = FALSE;
|
}
|
m_strLoginName = strLoginName;
|
return 0;
|
}
|
BOOL CMBAMBaseDBMgr::VerifyDBVersion( DWORD dwVersion )
|
{
|
CString strValue = _T("");
|
DWORD dwDBVersion;
|
CSingleLock lock( &m_csConnectDB, true );
|
CMBAMDBConnect* pDBConnect = GetMBAMDBConnect();
|
if ( !pDBConnect )
|
return FALSE;
|
pDBConnect->GetPropertyData( CLASS_DBVERSION, _T( "DBVersion" ),strValue );
|
if ( strValue.IsEmpty() )
|
{
|
return true;
|
}
|
CEncrypt::Decrypt( strValue, PSW_KEY );
|
dwDBVersion = _tstoi( strValue );
|
if ( dwVersion > dwDBVersion )
|
{
|
if( !UpdateNewDBTableInfo(dwDBVersion))
|
{
|
return false;
|
}
|
return true;
|
}
|
return true;
|
}
|
|
CMBAMDBConnect* CMBAMBaseDBMgr::GetMBAMDBConnect( )
|
{
|
if(m_pDBConnect)
|
{
|
m_pDBConnect->AddRef();
|
return m_pDBConnect;
|
}
|
return NULL;
|
}
|
|
//==============================================
|
// ±£´æµÇ¼Óû§µÄ±¾µØÊý¾Ý¿â°æ±¾ÐÅÏ¢
|
//==============================================
|
BOOL CMBAMBaseDBMgr::SetDBVersion( DWORD dwVersion )
|
{
|
CSingleLock lock( &m_csConnectDB, true );
|
CMBAMDBConnect* pDBConnect = GetMBAMDBConnect();
|
if ( !pDBConnect )
|
return FALSE;
|
CString strDWVersion;
|
strDWVersion.Format( _T("%d"), dwVersion );
|
CEncrypt::Encrypt( strDWVersion, PSW_KEY );
|
pDBConnect->SetPropertyData( CLASS_DBVERSION, _T( "DBVersion" ),strDWVersion );
|
return true;
|
}
|
|
//==============================================
|
// ±£´æµÇ¼Óû§µÄÐÅÏ¢
|
//==============================================
|
BOOL CMBAMBaseDBMgr::SetUserInfo( CString strLogin, CString strPassword )
|
{
|
if ( strLogin.IsEmpty() )
|
return false;
|
CSingleLock lock( &m_csConnectDB, true );
|
CMBAMDBConnect* pDBConnect = GetMBAMDBConnect();
|
if ( !pDBConnect )
|
return FALSE;
|
CString strDWVersion;
|
CEncrypt::Encrypt( strPassword, PSW_KEY );
|
pDBConnect->SetPropertyData( CLASS_SYSTEM, _T( "LoginName" ),strPassword );
|
return true;
|
}
|
BOOL CMBAMBaseDBMgr::UpdateNewDBTableInfo(int nVer )
|
{
|
return TRUE;
|
}
|
//==============================================
|
// ÒƳý×î½üÁªÏµÈË
|
//==============================================
|
BOOL CMBAMBaseDBMgr::RemoveLastContact( CString strID, int nType)
|
{
|
BOOL bRet;
|
CSingleLock lock( &m_csConnectDB, true );
|
CMBAMDBConnect* pDBConnect = GetMBAMDBConnect();
|
if ( !pDBConnect )
|
return FALSE;
|
bRet = pDBConnect->RemoveLastContact(strID, nType);
|
pDBConnect->Release();
|
return bRet;
|
}
|
//==============================================
|
// »ñÈ¡×î½üÁªÏµÈË
|
//==============================================
|
BOOL CMBAMBaseDBMgr::LoadLastContact(CArraySTKLastContact &arLastContact, int nLimitCount )
|
{
|
CSingleLock lock( &m_csConnectDB, true );
|
CMBAMDBConnect* pDBConnect = GetMBAMDBConnect();
|
if ( !pDBConnect )
|
return FALSE;
|
BOOL bRet = pDBConnect->LoadLastContact(arLastContact,nLimitCount );
|
pDBConnect->Release();
|
return true;
|
}
|
BOOL CMBAMBaseDBMgr::GetLastContactItem(CString strID, int nType,stSTKLastContact &itemLastContact )
|
{
|
CSingleLock lock( &m_csConnectDB, true );
|
CMBAMDBConnect* pDBConnect = GetMBAMDBConnect();
|
if ( !pDBConnect )
|
return FALSE;
|
BOOL bRet = pDBConnect->GetLastContactItem(strID,nType,itemLastContact );
|
pDBConnect->Release();
|
return bRet;
|
}
|
//==============================================
|
// »ñÈ¡Ö¸¶¨Óû§»òÕßȺµÄδ¶ÁÏûÏ¢ÊýÄ¿
|
//==============================================
|
int CMBAMBaseDBMgr::GetUnreadMsgCount( CString strID, int nType)
|
{
|
CSingleLock lock( &m_csConnectDB, true );
|
CMBAMDBConnect* pDBConnect = GetMBAMDBConnect();
|
if ( !pDBConnect )
|
return 0;
|
int nUnreadCnt = pDBConnect->GetUnreadMsgCount(strID,nType );
|
pDBConnect->Release();
|
return nUnreadCnt;
|
}
|
//==============================================
|
// »ñȡδ¶ÁÏûÏ¢ÊýÄ¿
|
//==============================================
|
int CMBAMBaseDBMgr::GetUnreadMsgCount( )
|
{
|
CSingleLock lock( &m_csConnectDB, true );
|
CMBAMDBConnect* pDBConnect = GetMBAMDBConnect();
|
if ( !pDBConnect )
|
return 0;
|
int nUnreadCnt = pDBConnect->GetUnreadMsgCount( );
|
pDBConnect->Release();
|
return nUnreadCnt;
|
}
|
//=======================================================
|
// µÃµ½ÏûÏ¢Ö¸¶¨µÄFolderÃû³Æ
|
//=======================================================
|
long CMBAMBaseDBMgr::GetMsgFolderID( long nParentFolderID, CString strFolderName )
|
{
|
if ( strFolderName.IsEmpty() )
|
return 0L;
|
CSingleLock lock( &m_csConnectDB, true );
|
CMBAMDBConnect* pDBConnect = GetMBAMDBConnect();
|
if ( !pDBConnect )
|
return 0L;
|
CMsgFolders Folders( pDBConnect );
|
CMsgFolderItem folder;
|
long nFolderID;
|
|
if ( Folders.ListSpFolder( nParentFolderID, strFolderName ) > 0 )
|
{
|
Folders.GetData( );
|
return Folders.m_nID;
|
}
|
nFolderID = Folders.GetMaxFolderID( );
|
if ( nFolderID < FOLDERID_BASE )
|
nFolderID = FOLDERID_BASE;
|
nFolderID++;
|
folder.m_nID = nFolderID;
|
folder.m_strName = strFolderName;
|
folder.m_nParentID = nParentFolderID;
|
Folders.AddFloder( &folder );
|
return nFolderID;
|
}
|
long CMBAMBaseDBMgr::GetMsgFolderID( CString strFolderName )
|
{
|
if ( strFolderName.IsEmpty() )
|
return 0L;
|
CSingleLock lock( &m_csConnectDB, true );
|
CMBAMDBConnect* pDBConnect = GetMBAMDBConnect();
|
if ( !pDBConnect )
|
return 0L;
|
long nParentFolderID = 0;
|
long nFolderID = 0;
|
CString strItem;
|
CMsgFolders Folders( pDBConnect );
|
while ( CMBAMDBFun::GetElementItem( strFolderName, strItem, _T( "\\" ) ) )
|
{
|
if ( !strItem.IsEmpty() )
|
{
|
nFolderID = GetMsgFolderID( nParentFolderID, strItem );
|
if ( nFolderID == 0 )
|
break;
|
nParentFolderID = nFolderID;
|
}
|
}
|
return nFolderID;
|
}
|
//==============================================
|
// µÃµ½FolderÃû³Æ
|
//==============================================
|
bool CMBAMBaseDBMgr::GetFolderName( long nFolderID, CString &strFolderName )
|
{
|
strFolderName =_T( "" );
|
|
if ( nFolderID <= 0 )
|
return false;
|
CSingleLock lock( &m_csConnectDB, true );
|
CMBAMDBConnect* pDBConnect = GetMBAMDBConnect();
|
if ( !pDBConnect )
|
return false;
|
CMsgFolders Folders( pDBConnect);
|
|
if ( Folders.ListSpFolder( nFolderID ) <= 0 )
|
return false;
|
Folders.GetData( );
|
strFolderName = Folders.m_strName;
|
return true;
|
}
|
//========================================
|
// ±£´æÏûÏ¢µ½±¾µØÊý¾Ý¿â
|
//========================================
|
BOOL CMBAMBaseDBMgr::SaveSendMulMsgToDB( CMsgItem *pMsg )
|
{
|
BOOL bReturn = false;
|
if ( !pMsg )
|
return false;
|
if ( pMsg->m_strID.IsEmpty() )
|
return false;
|
CSingleLock lock( &m_csConnectDB, true );
|
CMBAMDBConnect* pDBConnect = GetMBAMDBConnect();
|
if ( !pDBConnect )
|
{
|
return false;
|
}
|
CMsgs Msgs( pDBConnect);
|
//pDBConnect->StartTransaction( );
|
bReturn = Msgs.DoSaveSendMulMsg( pMsg);
|
// pDBConnect->Commit( );
|
return bReturn;
|
}
|
//========================================
|
// ±£´æÏûÏ¢µ½±¾µØÊý¾Ý¿â
|
//========================================
|
BOOL CMBAMBaseDBMgr::SaveMsgToDB( CMsgItem *pMsg, long nComfirmFlag/* = 0*/ )
|
{
|
BOOL bReturn = false;
|
if ( !pMsg )
|
return false;
|
if ( pMsg->m_strID.IsEmpty() )
|
return false;
|
CSingleLock lock( &m_csConnectDB, true );
|
CMBAMDBConnect* pDBConnect = GetMBAMDBConnect();
|
if ( !pDBConnect )
|
{
|
m_arSaveToDBMsg.Add(*pMsg);
|
return false;
|
}
|
CMsgs Msgs( pDBConnect);
|
bool bNeedConfirm = false;
|
bool bIsSendMsg = false;
|
|
if ( nComfirmFlag == 0 )
|
bNeedConfirm = false;
|
else
|
bNeedConfirm = true;
|
if(pMsg->m_strSender.CompareNoCase(m_strLoginName) == 0)
|
bIsSendMsg = true;;
|
//pDBConnect->StartTransaction( );
|
bReturn = Msgs.DoSaveMsg( pMsg, bIsSendMsg, bNeedConfirm );
|
// pDBConnect->Commit( );
|
return bReturn;
|
}
|
|
|
void CMBAMBaseDBMgr::AddBatchSaveSyncMsgToDB( CMsgItem *pMsg )
|
{
|
|
m_arBatchSaveToDBSyncMsg.Add(*pMsg);
|
}
|
|
void CMBAMBaseDBMgr::BatchSaveSyncMsgToDB( )
|
{
|
CSingleLock lock( &m_csConnectDB, true );
|
CMBAMDBConnect* pDBConnect = GetMBAMDBConnect();
|
if ( !pDBConnect )
|
return;
|
CMsgItem itemMsg;
|
try
|
{
|
if(m_arBatchSaveToDBSyncMsg.GetCount() < 1)
|
return;
|
//CSTKDBFun::WriteDBErrToFile( _T("BatchSaveMsgToDB") );
|
pDBConnect->StartTransaction( );
|
for(int i =0; i < m_arBatchSaveToDBSyncMsg.GetCount(); i++)
|
{
|
itemMsg = m_arBatchSaveToDBSyncMsg.GetAt(i);
|
if ( !itemMsg.m_strID.IsEmpty() )
|
{
|
pDBConnect->AddRef();
|
CMsgs Msgs( pDBConnect);
|
bool bNeedConfirm = false;
|
bool bIsSendMsg = false;
|
if ( itemMsg.m_nNeedConfirm == 0 )
|
bNeedConfirm = false;
|
else
|
bNeedConfirm = true;
|
if(itemMsg.m_strSender.CompareNoCase(m_strLoginName) == 0)
|
bIsSendMsg = true;;
|
Msgs.DoSaveSyncMsg( &itemMsg, bIsSendMsg, bNeedConfirm );
|
}
|
}
|
pDBConnect->Commit( );
|
}
|
catch( ... )
|
{
|
pDBConnect->Abort();
|
m_arBatchSaveToDBSyncMsg.RemoveAll();
|
pDBConnect->Release();
|
return;
|
}
|
//CSTKDBFun::WriteDBErrToFile( _T("BatchSaveMsgToDB 2") );
|
m_arBatchSaveToDBSyncMsg.RemoveAll();
|
pDBConnect->Release();
|
return;
|
}
|
void CMBAMBaseDBMgr::SaveNeedSaveMsg()
|
{
|
CSingleLock lock( &m_csConnectDB, true );
|
CMBAMDBConnect* pDBConnect = GetMBAMDBConnect();
|
if ( !pDBConnect )
|
return;
|
CMsgItem itemMsg;
|
try
|
{
|
if(m_arSaveToDBMsg.GetCount() > 0)
|
{
|
for(int i =0; i < m_arSaveToDBMsg.GetCount(); i++)
|
{
|
itemMsg = m_arSaveToDBMsg.GetAt(i);
|
if ( !itemMsg.m_strID.IsEmpty() )
|
{
|
pDBConnect->AddRef();
|
CMsgs Msgs( pDBConnect);
|
bool bNeedConfirm = false;
|
bool bIsSendMsg = false;
|
if ( itemMsg.m_nNeedConfirm == 0 )
|
bNeedConfirm = false;
|
else
|
bNeedConfirm = true;
|
if(itemMsg.m_strSender.CompareNoCase(m_strLoginName) == 0)
|
bIsSendMsg = true;;
|
|
Msgs.DoSaveMsg( &itemMsg, bIsSendMsg, bNeedConfirm );
|
|
}
|
}
|
}
|
}
|
catch( ... )
|
{
|
pDBConnect->Release();
|
///pDBConnect->Commit( );
|
//m_arSaveToDBMsg.RemoveAll();
|
return ;
|
}
|
m_arSaveToDBMsg.RemoveAll();
|
try
|
{
|
CCrowdMsgItem itemCrowdMsg;
|
if(m_arSaveToDBCrowdMsg.GetCount() > 0)
|
{
|
pDBConnect->StartTransaction( );
|
for(int i =0; i < m_arSaveToDBCrowdMsg.GetCount(); i++)
|
{
|
itemCrowdMsg = m_arSaveToDBCrowdMsg.GetAt(i);
|
if ( !itemCrowdMsg.m_strID.IsEmpty() )
|
{
|
pDBConnect->AddRef();
|
CCrowdMsgs Msgs( pDBConnect);
|
|
Msgs.DoSaveCrowdMsg( &itemCrowdMsg );
|
|
}
|
}
|
pDBConnect->Commit( );
|
}
|
}
|
catch( ... )
|
{
|
pDBConnect->Abort();
|
pDBConnect->Release();
|
//pDBConnect->Commit( );
|
//m_arSaveToDBCrowdMsg.RemoveAll();
|
return ;
|
}
|
m_arSaveToDBCrowdMsg.RemoveAll();
|
pDBConnect->Release();
|
}
|
|
|
//=======================================================
|
// ÅÉ·¢ÐÅÏ¢
|
// ±¾µØÏûÏ¢
|
//=======================================================
|
void CMBAMBaseDBMgr::DispatchMsg( CMsgItem * pMsgItem )
|
{
|
|
pMsgItem->m_tmDate = COleDateTime::GetCurrentTime();
|
pMsgItem->m_nReadState = pMsgItem->m_nReadState | MSG_READSTATE_DOWNLOAD;
|
|
if ( !(pMsgItem->m_nMsgFlag & MSGFLAG_CLIENT_NOSAVE) )
|
{
|
if ( pMsgItem->m_strFolderName.IsEmpty() )
|
{
|
if ( pMsgItem->m_strSender.CompareNoCase( m_strLoginName ) == 0 )
|
pMsgItem->m_nMsgFolder = FOLDER_BOX_OUT;
|
else
|
pMsgItem->m_nMsgFolder = FOLDER_BOX_IN;
|
}
|
else
|
pMsgItem->m_nMsgFolder = GetMsgFolderID( pMsgItem->m_strFolderName );
|
|
SaveMsgToDB( pMsgItem, 0 );
|
}
|
}
|
|
//========================================
|
// ÅúÁ¿±£´æÏûÏ¢ÒѶÁÐÅÏ¢µ½±¾µØÊý¾Ý¿â
|
//========================================
|
void CMBAMBaseDBMgr::SaveAMMsgsOpenDate( )
|
{
|
CString strLog;
|
CArrayAMOpenMsg arAMOpenMsg;
|
arAMOpenMsg.RemoveAll();
|
{
|
CSingleLock lock( &m_csAMOpenMsg, true );
|
if(m_arAMOpenMsg.GetCount() > 0)
|
{
|
arAMOpenMsg.Copy(m_arAMOpenMsg);
|
m_arAMOpenMsg.RemoveAll();
|
}
|
else
|
return;
|
}
|
try
|
{
|
strLog.Format(_T("SaveAMMsgsOpenDate£¡"));
|
//CSTKDBFun::WriteDBErrToFile(strLog);
|
CSingleLock lock( &m_csConnectDB, true );
|
CMBAMDBConnect* pDBConnect = GetMBAMDBConnect();
|
if ( !pDBConnect )
|
return;
|
CMapStringToLong mapGroupSendMsg;
|
stAMOpenMsg itemMsg;
|
CMsgOwners msgOwners( pDBConnect );
|
CMsgs Msgs( pDBConnect );
|
CHighTime tmCur;
|
SYSTEMTIME tmSystem;
|
mapGroupSendMsg.RemoveAll();
|
pDBConnect->AddRef();
|
pDBConnect->StartTransaction( );
|
for(int i=0;i < arAMOpenMsg.GetCount();i++)
|
{
|
itemMsg = arAMOpenMsg.GetAt(i);
|
if ( Msgs.ListSpMsgID( itemMsg.strMsgID ) <= 0 )
|
break ;
|
Msgs.GetMsgData( );
|
if ( itemMsg.strOpenDate.IsEmpty() || !tmCur.ParseDateTime( itemMsg.strOpenDate ) )
|
tmCur = tmCur.GetPresentTime( true );
|
tmCur.GetAsSystemTime( tmSystem );
|
if ( tmSystem.wSecond < 0 )
|
tmSystem.wSecond = 0;
|
if( !Msgs.m_nIsGroupSend)
|
{
|
Msgs.m_nReadState = Msgs.m_nReadState | MSG_READSTATE_IOPEN | MSG_READSTATE_ALL;
|
Msgs.m_tmOpenDate = COleDateTime( tmSystem.wYear, tmSystem.wMonth, tmSystem.wDay,
|
tmSystem.wHour, tmSystem.wMinute, tmSystem.wSecond );
|
|
Msgs.UpdateRecord( pDBConnect->GetDBConnect() );
|
}
|
else
|
{
|
if ( msgOwners.ListSpMsgID( itemMsg.strMsgID, itemMsg.strUser ) != 0 )
|
{
|
msgOwners.GetData( );
|
msgOwners.m_tmOpenDate = COleDateTime( tmSystem.wYear, tmSystem.wMonth, tmSystem.wDay,
|
tmSystem.wHour, tmSystem.wMinute, tmSystem.wSecond );
|
|
msgOwners.UpdateRecord( pDBConnect->GetDBConnect() );
|
}
|
mapGroupSendMsg.SetAt( itemMsg.strMsgID, Msgs.m_nReadState );
|
}
|
}
|
pDBConnect->Commit( );
|
|
if(mapGroupSendMsg.GetCount() > 0)
|
{
|
CString strMsgID;
|
long nTempReadState;
|
long nReadState;
|
pDBConnect->StartTransaction( );
|
for(POSITION pos= mapGroupSendMsg.GetStartPosition();pos;pos)
|
{
|
mapGroupSendMsg.GetNextAssoc(pos, strMsgID, nReadState);
|
msgOwners.ListSpMsgID( strMsgID );
|
nTempReadState = MSG_READSTATE_IOPEN | MSG_READSTATE_DOWNLOAD | MSG_READSTATE_ALL;
|
do
|
{
|
msgOwners.GetData( );
|
if ( msgOwners.m_tmOpenDate.GetYear() <= 1990 )
|
{
|
nTempReadState = MSG_READSTATE_IOPEN | MSG_READSTATE_DOWNLOAD | MSG_READSTATE_LITTLE;
|
break;
|
}
|
|
}while (msgOwners.MoveNext());
|
if(nReadState != nTempReadState)
|
{
|
Msgs.ListSpMsgID( strMsgID );
|
Msgs.GetMsgData();
|
Msgs.m_nReadState = nTempReadState;
|
Msgs.UpdateRecord( pDBConnect->GetDBConnect() );
|
}
|
}
|
pDBConnect->Commit( );
|
}
|
}
|
catch( ... )
|
{
|
strLog.Format(_T("SaveAMMsgsOpenDateÒì³£"));
|
//CSTKDBFun::WriteDBErrToFile(strLog);
|
return;
|
}
|
strLog.Format(_T("SaveAMMsgsOpenDate½áÊø"));
|
//CSTKDBFun::WriteDBErrToFile(strLog);
|
}
|
//========================================
|
// ±£´æÏûÏ¢µ½±¾µØÊý¾Ý¿â
|
//========================================
|
BOOL CMBAMBaseDBMgr::SaveSendMsgToDB( CMsgItem *pMsg, long nComfirmFlag/* = 0*/ )
|
{
|
BOOL bReturn = false;
|
if ( !pMsg )
|
{
|
CString strLog;
|
strLog.Format(_T("SaveSendMsgToDB MsgÒì³££¡"));
|
//CSTKDBFun::WriteDBErrToFile(strLog);
|
return false;
|
}
|
if ( pMsg->m_strID.IsEmpty() )
|
{
|
CString strLog;
|
strLog.Format(_T("SaveSendMsgToDB ÏûÏ¢IDΪ¿Õ£¡"));
|
//CSTKDBFun::WriteDBErrToFile(strLog);
|
return false;
|
}
|
CSingleLock lock( &m_csConnectDB, true );
|
CMBAMDBConnect* pDBConnect = GetMBAMDBConnect();
|
if ( !pDBConnect )
|
{
|
CString strLog;
|
strLog.Format(_T("SaveSendMsgToDB GetMBAMDBConnectʧ°Ü£¡"));
|
//CSTKDBFun::WriteDBErrToFile(strLog);
|
return false;
|
}
|
CMsgs Msgs( pDBConnect);
|
bool bNeedConfirm = false;
|
if ( nComfirmFlag == 0 )
|
bNeedConfirm = true;
|
else
|
bNeedConfirm = false;
|
// pDBConnect->StartTransaction( );
|
bReturn = Msgs.DoSaveMsg( pMsg, true, bNeedConfirm );
|
// pDBConnect->Commit( );
|
return bReturn;
|
}
|
//==============================================
|
// ¸üÐÂÏûÏ¢½ÓÊÕÕß
|
//==============================================
|
BOOL CMBAMBaseDBMgr::UpdateMsgOwnerOpened( CString strMsgID, CString strOwner, CString strOpenDate )
|
{
|
if ( strMsgID.IsEmpty() || strOwner.IsEmpty() )
|
return FALSE;
|
stAMOpenMsg itemMsg;
|
itemMsg.strMsgID = strMsgID;
|
itemMsg.strUser = strOwner;
|
itemMsg.strUser.MakeLower();
|
itemMsg.strOpenDate = strOpenDate;
|
{
|
CSingleLock lock( &m_csAMOpenMsg, true );
|
m_arAMOpenMsg.Add(itemMsg);
|
}
|
return TRUE;
|
}
|
|
bool CMBAMBaseDBMgr::SetMsgReaded( CString strMsgID )
|
{
|
if ( strMsgID.IsEmpty() )
|
return false;
|
CSingleLock lock( &m_csConnectDB, true );
|
CMBAMDBConnect* pDBConnect = GetMBAMDBConnect();
|
if ( !pDBConnect )
|
return false;
|
CMsgs Msgs( pDBConnect);
|
if ( Msgs.ListSpMsgID( strMsgID ) <= 0 )
|
{
|
pDBConnect->RemoveUnreadMsg(strMsgID);
|
return false;
|
}
|
|
Msgs.GetMsgData( );
|
if( Msgs.m_nReadState & MSG_READSTATE_IOPEN )
|
{
|
pDBConnect->RemoveUnreadMsg(strMsgID);
|
return true;
|
}
|
|
// ÉèÖôò¿ªµÄ״̬
|
COleDateTime tmCur;
|
SYSTEMTIME tmSys;
|
tmCur = COleDateTime::GetCurrentTime();
|
tmCur.GetAsSystemTime( tmSys );
|
if ( tmSys.wSecond < 0 )
|
tmSys.wSecond = 0;
|
Msgs.m_tmOpenDate = COleDateTime( tmSys.wYear, tmSys.wMonth, tmSys.wDay,
|
tmSys.wHour, tmSys.wMinute, tmSys.wSecond );
|
|
Msgs.m_nReadState = Msgs.m_nReadState | MSG_READSTATE_IOPEN;
|
Msgs.UpdateRecord( pDBConnect->GetDBConnect() );
|
pDBConnect->RemoveUnreadMsg(strMsgID);
|
// ÉèÖÃÎÒ´ò¿ªÏûÏ¢µÄʱ¼ä
|
pDBConnect->AddRef();
|
CMsgOwners msgOwners(pDBConnect );
|
if ( msgOwners.ListSpMsgID( strMsgID, m_strLoginName ) != 0 )
|
{
|
msgOwners.GetData( );
|
if ( msgOwners.m_tmOpenDate.GetYear() <= 1990 )
|
{
|
tmCur = COleDateTime::GetCurrentTime();
|
tmCur.GetAsSystemTime( tmSys );
|
if ( tmSys.wSecond < 0 )
|
tmSys.wSecond = 0;
|
msgOwners.m_tmOpenDate = COleDateTime( tmSys.wYear, tmSys.wMonth, tmSys.wDay,
|
tmSys.wHour, tmSys.wMinute, tmSys.wSecond );
|
|
msgOwners.UpdateRecord( pDBConnect->GetDBConnect() );
|
}
|
}
|
return true;
|
}
|
|
BOOL CMBAMBaseDBMgr::SetCrowdMsgReaded(CString strMsgID )
|
{
|
if ( strMsgID.IsEmpty() )
|
return false;
|
CSingleLock lock( &m_csConnectDB, true );
|
CMBAMDBConnect* pDBConnect = GetMBAMDBConnect();
|
if ( !pDBConnect )
|
return false;
|
CCrowdMsgs CrowdMsgs( pDBConnect );
|
|
if ( CrowdMsgs.ListSpMsgID( strMsgID ) <= 0 )
|
return false;
|
CrowdMsgs.GetMsgData( );
|
if( CrowdMsgs.m_nReadState & MSG_READSTATE_IOPEN )
|
return true;
|
CrowdMsgs.m_nReadState = CrowdMsgs.m_nReadState | MSG_READSTATE_IOPEN;
|
{
|
CrowdMsgs.UpdateRecord( pDBConnect->GetDBConnect() );
|
}
|
return true;
|
}
|
|
bool CMBAMBaseDBMgr::SetMsgIgnore( CString strMsgID )
|
{
|
if ( strMsgID.IsEmpty() )
|
return false;
|
CSingleLock lock( &m_csConnectDB, true );
|
CMBAMDBConnect* pDBConnect = GetMBAMDBConnect();
|
if ( !pDBConnect )
|
return false;
|
|
CMsgs Msgs( pDBConnect );
|
|
if ( Msgs.ListSpMsgID( strMsgID ) <= 0 )
|
{
|
pDBConnect->RemoveUnreadMsg(strMsgID);
|
return false;
|
}
|
Msgs.GetMsgData( );
|
Msgs.m_nReadState = MSG_READSTATE_IGNORE;
|
{
|
Msgs.UpdateRecord( pDBConnect->GetDBConnect() );
|
}
|
pDBConnect->RemoveUnreadMsg(strMsgID);
|
return true;
|
|
}
|
bool CMBAMBaseDBMgr::SetCrowdMsgIgnore( CString strMsgID )
|
{
|
if ( strMsgID.IsEmpty() )
|
return false;
|
CSingleLock lock( &m_csConnectDB, true );
|
CMBAMDBConnect* pDBConnect = GetMBAMDBConnect();
|
if ( !pDBConnect )
|
return false;
|
CCrowdMsgs Msgs( pDBConnect );
|
if ( Msgs.ListSpMsgID( strMsgID ) <= 0 )
|
{
|
pDBConnect->RemoveUnreadMsg(strMsgID);
|
return false;
|
}
|
Msgs.GetMsgData( );
|
Msgs.m_nReadState = MSG_READSTATE_IGNORE;
|
{
|
Msgs.UpdateRecord( pDBConnect->GetDBConnect() );
|
}
|
pDBConnect->RemoveUnreadMsg(strMsgID);
|
return true;
|
|
}
|
//=========================================================
|
// µÃµ½ÈËÔ±ÏêϸÐÅÏ¢
|
//=========================================================
|
BOOL CMBAMBaseDBMgr::LoadUserInfo( CString strLogin, CString &strXml, int &nVer)
|
{
|
CSingleLock lock( &m_csConnectDB, true );
|
CMBAMDBConnect* pDBConnect = GetMBAMDBConnect();
|
if ( !pDBConnect )
|
return FALSE;
|
CString strClass, strName;
|
CString strValue = _T("");
|
BOOL bRet;
|
|
strClass = _T("_UserInfo");
|
strName = strLogin;
|
|
bRet = pDBConnect->GetPropStringData(strClass,strName, nVer,strValue,strXml);
|
pDBConnect->Release();
|
return bRet;
|
}
|
BOOL CMBAMBaseDBMgr::SaveUserInfo( CString strLogin, CString strXml, int nVer)
|
{
|
CSingleLock lock( &m_csConnectDB, true );
|
CMBAMDBConnect* pDBConnect = GetMBAMDBConnect();
|
if ( !pDBConnect )
|
return FALSE;
|
CString strClass, strName;
|
CString strValue = _T("");
|
BOOL bRet;
|
|
strClass = _T("_UserInfo");
|
strName = strLogin;
|
|
bRet = pDBConnect->UpdatePropStringData(strClass,strName, nVer,strValue,strXml);
|
pDBConnect->Release();
|
return bRet;
|
}
|
|
BOOL CMBAMBaseDBMgr::LoadUserInfoVer( CString strLogin, int &nVer)
|
{
|
CSingleLock lock( &m_csConnectDB, true );
|
CMBAMDBConnect* pDBConnect = GetMBAMDBConnect();
|
if ( !pDBConnect )
|
return FALSE;
|
CString strClass, strName;
|
CString strValue = _T("");
|
BOOL bRet;
|
|
strClass = _T("_UserInfo");
|
strName = strLogin;
|
|
bRet = pDBConnect->GetPropVersion(strClass,strName, nVer);
|
pDBConnect->Release();
|
return bRet;
|
}
|
BOOL CMBAMBaseDBMgr::UpdateUserAttitude(CString strID, CString strUser, CString strAttitude)
|
{
|
BOOL bReturn = false;
|
if ( strID.IsEmpty() )
|
return false;
|
CSingleLock lock( &m_csConnectDB, true );
|
CMBAMDBConnect* pDBConnect = GetMBAMDBConnect();
|
if ( !pDBConnect )
|
{
|
return false;
|
}
|
if( !pDBConnect->IsOpenDB())
|
{
|
pDBConnect->Release();
|
return FALSE;
|
}
|
CMsgItem itemMsg;
|
itemMsg.m_strID = strID;
|
itemMsg.UpdateUserAttitude(pDBConnect->GetDBConnect(), strAttitude);
|
CMsgOwnerItem itemMsgOwner;
|
itemMsgOwner.m_strOwner = strUser;
|
itemMsgOwner.m_strMsgID = strID;
|
itemMsgOwner.UpdateUserAttitude(pDBConnect->GetDBConnect(), strAttitude);
|
pDBConnect->Release();
|
return bReturn;
|
}
|
BOOL CMBAMBaseDBMgr::HasMsg( CString strMsgID )
|
{
|
CSingleLock lock( &m_csConnectDB, true );
|
CMBAMDBConnect* pDBConnect = GetMBAMDBConnect();
|
if ( !pDBConnect )
|
return FALSE;
|
//CSTKDBFun::WriteDBErrToFile( _T("HasMsg ") );
|
int nCount = pDBConnect->CheckMsgExist(strMsgID);
|
pDBConnect->Release();
|
//CSTKDBFun::WriteDBErrToFile( _T("HasMsg 2") );
|
if(nCount > 0)
|
return TRUE;
|
return FALSE;
|
}
|
bool CMBAMBaseDBMgr::ListTalking3(CString strStartDate,CString strEndDate, CString strUser, CSTKMsgRowSet *pMsgRowSet ,long nLimitCount,long &nCount, BOOL bTimeAsc )
|
{
|
{
|
strUser.MakeLower();
|
CSingleLock lock( &m_csConnectDB, true );
|
CMBAMDBConnect* pDBConnect = GetMBAMDBConnect();
|
if ( !pDBConnect )
|
return false;
|
pMsgRowSet->SetDBConnect(pDBConnect);
|
pMsgRowSet->SetMsgFilterDate(strStartDate, strEndDate);
|
pMsgRowSet->ListTalking3(strUser,nLimitCount, nCount, bTimeAsc);
|
pDBConnect->Release();
|
}
|
//pMsgRowSet->ListRecordCount(nCount);
|
//pMsgRowSet->Top();
|
return true;
|
}
|
bool CMBAMBaseDBMgr::ListTalking2(CString strStartDate,CString strEndDate, CString strUser, CSTKMsgRowSet *pMsgRowSet ,long nLimitCount,long &nCount, BOOL bTimeAsc )
|
{
|
{
|
strUser.MakeLower();
|
CSingleLock lock( &m_csConnectDB, true );
|
CMBAMDBConnect* pDBConnect = GetMBAMDBConnect();
|
if ( !pDBConnect )
|
return false;
|
pMsgRowSet->SetDBConnect(pDBConnect);
|
pMsgRowSet->SetMsgFilterDate(strStartDate, strEndDate);
|
pMsgRowSet->ListTalking2(strUser,nLimitCount, nCount, bTimeAsc);
|
pDBConnect->Release();
|
}
|
//pMsgRowSet->ListRecordCount(nCount);
|
//pMsgRowSet->Top();
|
return true;
|
}
|
bool CMBAMBaseDBMgr::ListTalking(CString strStartDate,CString strEndDate, CString strUser, CSTKMsgRowSet *pMsgRowSet ,long &nCount,bool bOnlyAttachmentMsg,bool bGroupSend, BOOL bTimeAsc )
|
{
|
DWORD dwTickCount;
|
DWORD dwTickCount2;
|
DWORD dwInterset;
|
DWORD dwInterset2;
|
strUser.MakeLower();
|
//CSTKDBFun::WriteDBErrToFile(_T("CMBAMBaseDBMgr::ListTalking 1"));
|
{
|
dwTickCount = ::GetTickCount();
|
CSingleLock lock( &m_csConnectDB, true );
|
CMBAMDBConnect* pDBConnect = GetMBAMDBConnect();
|
if ( !pDBConnect )
|
return false;
|
dwTickCount2 = ::GetTickCount();
|
dwInterset = dwTickCount2 - dwTickCount;
|
//CSTKDBFun::WriteDBErrToFile(_T("CMBAMBaseDBMgr::ListTalking 2"));
|
pMsgRowSet->SetDBConnect(pDBConnect);
|
pMsgRowSet->SetMsgFilterDate(strStartDate, strEndDate);
|
pMsgRowSet->ListTalking(strUser,nCount,bOnlyAttachmentMsg,bGroupSend,bTimeAsc);
|
dwTickCount2 = ::GetTickCount();
|
dwInterset2 = dwTickCount2 - dwTickCount;
|
pDBConnect->Release();
|
}
|
//pMsgRowSet->ListRecordCount(nCount);
|
//pMsgRowSet->Top();
|
//strLog.Format(_T("CMBAMBaseDBMgr::ListTalking ²éѯʱ¼ä(%d-%d-%d-%d)"),dwInterset,dwInterset2);
|
//CSTKDBFun::WriteDBErrToFile(strLog);
|
return true;
|
}
|
bool CMBAMBaseDBMgr::ListSearchingTalking(CString strStartDate,CString strEndDate, CString strUser, CString strKey,bool bOnlyAttachmentMsg, CSTKMsgRowSet *pMsgRowSet, long &nCount,bool bGroupSend , BOOL bTimeAsc )
|
{
|
{
|
CMBAMDBConnect* pDBConnect = GetMBAMDBConnect();
|
if ( !pDBConnect )
|
return false;
|
pMsgRowSet->SetDBConnect(pDBConnect);
|
pMsgRowSet->SetMsgFilterDate(strStartDate, strEndDate);
|
pMsgRowSet->ListSearchingTalking(strUser,strKey,bOnlyAttachmentMsg, nCount,bGroupSend, bTimeAsc);
|
pDBConnect->Release();
|
}
|
//pMsgRowSet->ListRecordCount(nCount);
|
//pMsgRowSet->Top();
|
return true;
|
}
|
bool CMBAMBaseDBMgr::ListTalkingAllMsg(CString strStartDate,CString strEndDate, CString strUser, CSTKMsgRowSet *pMsgRowSet ,long &nCount, BOOL bTimeAsc )
|
{
|
DWORD dwTickCount;
|
DWORD dwTickCount2;
|
DWORD dwInterset;
|
DWORD dwInterset2;
|
strUser.MakeLower();
|
//CSTKDBFun::WriteDBErrToFile(_T("CMBAMBaseDBMgr::ListTalking 1"));
|
{
|
dwTickCount = ::GetTickCount();
|
CSingleLock lock( &m_csConnectDB, true );
|
CMBAMDBConnect* pDBConnect = GetMBAMDBConnect();
|
if ( !pDBConnect )
|
return false;
|
dwTickCount2 = ::GetTickCount();
|
dwInterset = dwTickCount2 - dwTickCount;
|
//CSTKDBFun::WriteDBErrToFile(_T("CMBAMBaseDBMgr::ListTalking 2"));
|
pMsgRowSet->SetDBConnect(pDBConnect);
|
pMsgRowSet->SetMsgFilterDate(strStartDate, strEndDate);
|
pMsgRowSet->ListTalkingAllMsg(strUser,nCount,bTimeAsc);
|
dwTickCount2 = ::GetTickCount();
|
dwInterset2 = dwTickCount2 - dwTickCount;
|
pDBConnect->Release();
|
}
|
//pMsgRowSet->ListRecordCount(nCount);
|
//pMsgRowSet->Top();
|
//strLog.Format(_T("CMBAMBaseDBMgr::ListTalking ²éѯʱ¼ä(%d-%d-%d-%d)"),dwInterset,dwInterset2);
|
//CSTKDBFun::WriteDBErrToFile(strLog);
|
return true;
|
}
|
bool CMBAMBaseDBMgr::ListSearchingTalkingAllMsg(CString strStartDate,CString strEndDate, CString strUser, CString strKey, CSTKMsgRowSet *pMsgRowSet, long &nCount, BOOL bTimeAsc )
|
{
|
{
|
|
CSingleLock lock( &m_csConnectDB, true );
|
strUser.MakeLower();
|
CMBAMDBConnect* pDBConnect = GetMBAMDBConnect();
|
if ( !pDBConnect )
|
return false;
|
pMsgRowSet->SetDBConnect(pDBConnect);
|
pMsgRowSet->SetMsgFilterDate(strStartDate, strEndDate);
|
pMsgRowSet->ListSearchingTalkingAllMsg(strUser,strKey,nCount, bTimeAsc);
|
pDBConnect->Release();
|
}
|
return true;
|
}
|
bool CMBAMBaseDBMgr::ListCrowdMsg2(CString strStartDate,CString strEndDate, CString strCrowdID, CCrowdMsgRowSet *pMsgRowSet ,long nLimitCount, long &nCount, BOOL bTimeAsc )
|
{
|
{
|
CSingleLock lock( &m_csConnectDB, true );
|
CMBAMDBConnect* pDBConnect = GetMBAMDBConnect();
|
if ( !pDBConnect )
|
return false;
|
pMsgRowSet->SetDBConnect(pDBConnect);
|
pMsgRowSet->SetMsgFilterDate(strStartDate, strEndDate);
|
pMsgRowSet->ListCrowdMsg2(strCrowdID, nLimitCount, nCount, bTimeAsc);
|
pDBConnect->Release();
|
}
|
//pMsgRowSet->ListRecordCount(nCount);
|
//pMsgRowSet->Top();
|
return true;
|
}
|
bool CMBAMBaseDBMgr::ListCrowdMsg(CString strStartDate,CString strEndDate, CString strCrowdID, CCrowdMsgRowSet *pMsgRowSet , long &nCount, BOOL bTimeAsc )
|
{
|
{
|
CSingleLock lock( &m_csConnectDB, true );
|
CMBAMDBConnect* pDBConnect = GetMBAMDBConnect();
|
if ( !pDBConnect )
|
return false;
|
pMsgRowSet->SetDBConnect(pDBConnect);
|
pMsgRowSet->SetMsgFilterDate(strStartDate, strEndDate);
|
pMsgRowSet->ListCrowdMsg(strCrowdID, nCount, bTimeAsc);
|
pDBConnect->Release();
|
}
|
//pMsgRowSet->ListRecordCount(nCount);
|
//pMsgRowSet->Top();
|
return true;
|
}
|
bool CMBAMBaseDBMgr::ListSearchCrowdMsg(CString strStartDate,CString strEndDate, CString strCrowdID, CString strKey, CCrowdMsgRowSet *pMsgRowSet , long &nCount, BOOL bTimeAsc )
|
{
|
{
|
CSingleLock lock( &m_csConnectDB, true );
|
CMBAMDBConnect* pDBConnect = GetMBAMDBConnect();
|
if ( !pDBConnect )
|
return false;
|
pMsgRowSet->SetDBConnect(pDBConnect);
|
pMsgRowSet->SetMsgFilterDate(strStartDate, strEndDate);
|
pMsgRowSet->ListSearchCrowdMsg(strCrowdID,strKey, nCount, bTimeAsc);
|
pDBConnect->Release();
|
}
|
// pMsgRowSet->ListRecordCount(nCount);
|
//pMsgRowSet->Top();
|
return true;
|
}
|
bool CMBAMBaseDBMgr::ListReceiveBoxMsg(CString strStartDate,CString strEndDate, CString strSender,CString strSenderName,CString strContentKey, int nAttach, CSTKMsgRowSet *pMsgRowSet,long &nCount )
|
{
|
strSender.MakeLower();
|
CSingleLock lock( &m_csConnectDB, true );
|
CMBAMDBConnect* pDBConnect = GetMBAMDBConnect();
|
if ( !pDBConnect )
|
return false;
|
pMsgRowSet->SetDBConnect(pDBConnect);
|
pMsgRowSet->SetMsgFilterDate(strStartDate, strEndDate);
|
pMsgRowSet->ListReceiveBoxMsg(strSender,strSenderName,strContentKey,nAttach,nCount);
|
pDBConnect->Release();
|
return true;
|
}
|
bool CMBAMBaseDBMgr::ListSendBoxMsg(CString strStartDate,CString strEndDate, CString strReceiver,CString strReceiverName,CString strContentKey, int nAttach, CSTKMsgRowSet *pMsgRowSet,long &nCount )
|
{
|
strReceiver.MakeLower();
|
CSingleLock lock( &m_csConnectDB, true );
|
CMBAMDBConnect* pDBConnect = GetMBAMDBConnect();
|
if ( !pDBConnect )
|
return false;
|
pMsgRowSet->SetDBConnect(pDBConnect);
|
pMsgRowSet->SetMsgFilterDate(strStartDate, strEndDate);
|
pMsgRowSet->ListSendBoxMsg(strReceiver,strReceiverName,strContentKey,nAttach,nCount);
|
pDBConnect->Release();
|
return true;
|
}
|
bool CMBAMBaseDBMgr::ListFavBoxMsg(CString strStartDate,CString strEndDate, CString strSender,CString strSenderName, CString strContentKey,int nFavFolder, CSTKMsgRowSet *pMsgRowSet,long &nCount )
|
{
|
strSender.MakeLower();
|
CSingleLock lock( &m_csConnectDB, true );
|
CMBAMDBConnect* pDBConnect = GetMBAMDBConnect();
|
if ( !pDBConnect )
|
return false;
|
pMsgRowSet->SetDBConnect(pDBConnect);
|
pMsgRowSet->SetMsgFilterDate(strStartDate, strEndDate);
|
pMsgRowSet->ListFavBoxMsg(strSender,strSenderName,strContentKey,nFavFolder,nCount);
|
pDBConnect->Release();
|
return true;
|
}
|
bool CMBAMBaseDBMgr::ListSysBoxMsg(CString strStartDate,CString strEndDate, CSTKMsgRowSet *pMsgRowSet,long &nCount )
|
{
|
CSingleLock lock( &m_csConnectDB, true );
|
CMBAMDBConnect* pDBConnect = GetMBAMDBConnect();
|
if ( !pDBConnect )
|
return false;
|
pMsgRowSet->SetDBConnect(pDBConnect);
|
pMsgRowSet->SetMsgFilterDate(strStartDate, strEndDate);
|
pMsgRowSet->ListSysBoxMsg(nCount);
|
pDBConnect->Release();
|
return true;
|
}
|
bool CMBAMBaseDBMgr::ListSyncBoxMsg(CString strSynchDate,CSTKMsgRowSet *pMsgRowSet,long &nCount )
|
{
|
CSingleLock lock( &m_csConnectDB, true );
|
CMBAMDBConnect* pDBConnect = GetMBAMDBConnect();
|
if ( !pDBConnect )
|
return false;
|
pMsgRowSet->SetDBConnect(pDBConnect);
|
pMsgRowSet->ListSyncBoxMsg(strSynchDate,nCount);
|
pDBConnect->Release();
|
return true;
|
}
|
bool CMBAMBaseDBMgr::ListMsgAttachment(CString strStartDate,CString strEndDate, CString strSender,CString strSenderName, CString strKey,CSTKMsgRowSet *pMsgRowSet,long &nCount )
|
{
|
strSender.MakeLower();
|
CSingleLock lock( &m_csConnectDB, true );
|
CMBAMDBConnect* pDBConnect = GetMBAMDBConnect();
|
if ( !pDBConnect )
|
return false;
|
pMsgRowSet->SetDBConnect(pDBConnect);
|
pMsgRowSet->SetMsgFilterDate(strStartDate, strEndDate);
|
pMsgRowSet->ListAttachments(strSender,strSenderName,strKey,nCount);
|
pDBConnect->Release();
|
return true;
|
}
|
bool CMBAMBaseDBMgr::ListSearchingTalkingMsg(CString strStartDate,CString strEndDate, CString strUser, CString strKey, CSTKMsgRowSet *pMsgRowSet, long &nCount, BOOL bTimeAsc )
|
{
|
CSingleLock lock( &m_csConnectDB, true );
|
strUser.MakeLower();
|
CMBAMDBConnect* pDBConnect = GetMBAMDBConnect();
|
if ( !pDBConnect )
|
return false;
|
pMsgRowSet->SetDBConnect(pDBConnect);
|
pMsgRowSet->SetMsgFilterDate(strStartDate, strEndDate);
|
pMsgRowSet->ListSearchingTalkingMsg(strUser,strKey,nCount, bTimeAsc);
|
pDBConnect->Release();
|
return true;
|
}
|
bool CMBAMBaseDBMgr::ListSearchCrowdMsgBox(CString strStartDate,CString strEndDate, CString strCrowdID, CString strKey,CCrowdMsgRowSet *pMsgRowSet, long &nCount, BOOL bTimeAsc )
|
{
|
CSingleLock lock( &m_csConnectDB, true );
|
CMBAMDBConnect* pDBConnect = GetMBAMDBConnect();
|
if ( !pDBConnect )
|
return false;
|
pMsgRowSet->SetDBConnect(pDBConnect);
|
pMsgRowSet->SetMsgFilterDate(strStartDate, strEndDate);
|
pMsgRowSet->ListSearchCrowdMsgBox(strCrowdID,strKey, nCount, bTimeAsc);
|
pDBConnect->Release();
|
return true;
|
}
|
BOOL CMBAMBaseDBMgr::ClearReceiveBoxMsg(CString strStartDate,CString strEndDate, CString strSender,CString strSenderName,CString strContentKey, int nAttach)
|
{
|
BOOL bRet;
|
CSingleLock lock( &m_csConnectDB, true );
|
CMBAMDBConnect* pDBConnect = GetMBAMDBConnect();
|
if ( !pDBConnect )
|
return FALSE;
|
bRet = pDBConnect->ClearReceiveBoxMsg(strStartDate, strEndDate , strSender,strSenderName,strContentKey,nAttach);
|
pDBConnect->Release();
|
return bRet;
|
}
|
BOOL CMBAMBaseDBMgr::ClearSendBoxMsg(CString strStartDate,CString strEndDate,CString strReceiver,CString strReceiverName,CString strContentKey, int nAttach)
|
{
|
BOOL bRet;
|
CSingleLock lock( &m_csConnectDB, true );
|
CMBAMDBConnect* pDBConnect = GetMBAMDBConnect();
|
if ( !pDBConnect )
|
return FALSE;
|
bRet = pDBConnect->ClearSendBoxMsg(strStartDate, strEndDate,strReceiver,strReceiverName,strContentKey,nAttach );
|
pDBConnect->Release();
|
return bRet;
|
}
|
BOOL CMBAMBaseDBMgr::ClearSysBoxMsg(CString strStartDate,CString strEndDate)
|
{
|
BOOL bRet;
|
CSingleLock lock( &m_csConnectDB, true );
|
CMBAMDBConnect* pDBConnect = GetMBAMDBConnect();
|
if ( !pDBConnect )
|
return FALSE;
|
bRet = pDBConnect->ClearSysBoxMsg(strStartDate, strEndDate );
|
pDBConnect->Release();
|
return bRet;
|
}
|
BOOL CMBAMBaseDBMgr::ClearFavBoxMsg(CString strStartDate,CString strEndDate, CString strContentKey, int nFavFolder)
|
{
|
BOOL bRet;
|
CSingleLock lock( &m_csConnectDB, true );
|
CMBAMDBConnect* pDBConnect = GetMBAMDBConnect();
|
if ( !pDBConnect )
|
return FALSE;
|
bRet = pDBConnect->ClearFavBoxMsg(strStartDate, strEndDate,strContentKey, nFavFolder);
|
pDBConnect->Release();
|
return bRet;
|
}
|
BOOL CMBAMBaseDBMgr::ClearCrowdMsgBox(CString strStartDate,CString strEndDate, CString strCrowdID, CString strKey)
|
{
|
BOOL bRet;
|
CSingleLock lock( &m_csConnectDB, true );
|
CMBAMDBConnect* pDBConnect = GetMBAMDBConnect();
|
if ( !pDBConnect )
|
return FALSE;
|
bRet = pDBConnect->ClearCrowdMsgBox(strStartDate, strEndDate,strCrowdID, strKey);
|
pDBConnect->Release();
|
return bRet;
|
}
|
BOOL CMBAMBaseDBMgr::GetMsgFileInfo( CString strMsgID, CString strFileID, CString &strFileName,
|
CString &strFileSflag, __int64 &nFileSize )
|
{
|
BOOL bRet;
|
|
if(strFileID.IsEmpty())
|
return FALSE;
|
strFileSflag = _T("");
|
strFileName = _T("");
|
nFileSize = 0;
|
CSingleLock lock( &m_csConnectDB, true );
|
CMBAMDBConnect* pDBConnect = GetMBAMDBConnect();
|
if ( !pDBConnect )
|
return FALSE;
|
bRet = pDBConnect->GetMsgFileInfo(strMsgID,strFileID,strFileName, strFileSflag, nFileSize );
|
pDBConnect->Release();
|
return bRet;
|
}
|
BOOL CMBAMBaseDBMgr::GetMsgFilesInfo( CString strMsgID,CStringArray &arAttachID)
|
{
|
BOOL bRet;
|
|
if(strMsgID.IsEmpty())
|
return FALSE;
|
//CString strFileSflag = _T("");
|
arAttachID.RemoveAll();
|
CSingleLock lock( &m_csConnectDB, true );
|
CMBAMDBConnect* pDBConnect = GetMBAMDBConnect();
|
if ( !pDBConnect )
|
return FALSE;
|
bRet = pDBConnect->GetMsgFilesInfo(strMsgID,arAttachID);
|
pDBConnect->Release();
|
return bRet;
|
}
|
BOOL CMBAMBaseDBMgr::GetMsgFilePath(CString strMsgID, CString strFileID, CString &strFilePath )
|
{
|
BOOL bRet;
|
|
if(strFileID.IsEmpty())
|
return FALSE;
|
strFilePath = _T("");
|
CSingleLock lock( &m_csConnectDB, true );
|
CMBAMDBConnect* pDBConnect = GetMBAMDBConnect();
|
if ( !pDBConnect )
|
return FALSE;
|
bRet = pDBConnect->GetMsgFilePath(strMsgID,strFileID,strFilePath );
|
pDBConnect->Release();
|
return bRet;
|
}
|
|
BOOL CMBAMBaseDBMgr::SetMsgFilePath(CString strMsgID, CString strFileID, CString strFilePath )
|
{
|
BOOL bRet;
|
|
if(strFileID.IsEmpty())
|
return FALSE;
|
CSingleLock lock( &m_csConnectDB, true );
|
CMBAMDBConnect* pDBConnect = GetMBAMDBConnect();
|
if ( !pDBConnect )
|
return FALSE;
|
|
bRet = pDBConnect->SetMsgFilePath(strMsgID,strFileID,strFilePath );
|
pDBConnect->Release();
|
return bRet;
|
}
|
BOOL CMBAMBaseDBMgr::ListUnReadCrowdMsg( CObList &listMsg )
|
{
|
CSingleLock lock( &m_csConnectDB, true );
|
CMBAMDBConnect* pDBConnect = GetMBAMDBConnect();
|
if ( !pDBConnect )
|
return false;
|
//CSTKDBFun::WriteDBErrToFile(_T("CMBAMBaseDBMgr::ListUnReadCrowdMsg"));
|
int nMsgCount, nMsgIndex;
|
CCrowdMsgs msgs( pDBConnect );
|
CCrowdMsgItem *pMsg = NULL;
|
nMsgCount = msgs.ListUnreadMsg( );
|
for ( nMsgIndex = 0; nMsgIndex < nMsgCount; nMsgIndex++ )
|
{
|
pMsg = new CCrowdMsgItem;
|
listMsg.AddTail( (CObject*)pMsg );
|
pMsg->m_strID = msgs.m_strID;
|
pMsg->m_strCrowdID = msgs.m_strCrowdID;
|
pMsg->m_strCrowdName = msgs.m_strCrowdName;
|
pMsg->m_strSender = msgs.m_strSender;
|
pMsg->m_strSenderName = msgs.m_strSenderName;
|
pMsg->m_nReadState = msgs.m_nReadState;
|
|
if ( pMsg->m_strSenderName.IsEmpty() )
|
{
|
pMsg->m_strSenderName = pMsg->m_strSender;
|
}
|
pMsg->m_tmDate = msgs.m_tmDate;
|
pMsg->m_strContent = msgs.m_strContent;
|
pMsg->m_nMsgFlag = msgs.m_nMsgFlag;
|
msgs.MoveNext();
|
}
|
// CSTKDBFun::WriteDBErrToFile(_T("CMBAMBaseDBMgr::ListUnReadCrowdMsg 2"));
|
return true;
|
}
|
|
BOOL CMBAMBaseDBMgr::ListUnReadMsg( CObList &listMsg )
|
{
|
CSingleLock lock( &m_csConnectDB, true );
|
CMBAMDBConnect* pDBConnect = GetMBAMDBConnect();
|
if ( !pDBConnect )
|
return false;
|
pDBConnect->ListUnReadMsg(listMsg);
|
pDBConnect->Release();
|
return true;
|
}
|
|
BOOL CMBAMBaseDBMgr::LoadUserPictureVer( CString strLoginName, int &nVer )
|
{
|
CSingleLock lock( &m_csConnectDB, true );
|
CMBAMDBConnect* pDBConnect = GetMBAMDBConnect();
|
if ( !pDBConnect )
|
return false;
|
|
CString strClass, strName;
|
BOOL bRet;
|
strClass = _T("_UserPicture");
|
strName = strLoginName;
|
|
bRet = pDBConnect->GetPropVersion(strClass,strName, nVer);
|
pDBConnect->Release();
|
if( !bRet)
|
return FALSE;
|
return TRUE;
|
}
|
BOOL CMBAMBaseDBMgr::SaveUserPictureVer( CString strLoginName, int nVer )
|
{
|
CSingleLock lock( &m_csConnectDB, true );
|
CMBAMDBConnect* pDBConnect = GetMBAMDBConnect();
|
if ( !pDBConnect )
|
return false;
|
CString strClass, strName;
|
CString strFileDir;
|
BOOL bRet;
|
int nTmpVer = 0;
|
|
strClass = _T("_UserPicture");
|
strName = strLoginName;
|
nTmpVer= nVer;
|
if(nTmpVer <= 0)
|
{
|
LoadUserPictureVer(strLoginName, nTmpVer) ;
|
nTmpVer++;
|
}
|
bRet = pDBConnect->SetPropVersion(strClass,strName, nTmpVer);
|
pDBConnect->Release();
|
return bRet;
|
}
|
BOOL CMBAMBaseDBMgr::SaveCrowdMsg( CCrowdMsgItem *pMsg)
|
{
|
BOOL bReturn = false;
|
if ( !pMsg )
|
return false;
|
if ( pMsg->m_strID.IsEmpty() )
|
return false;
|
CSingleLock lock( &m_csConnectDB, true );
|
CMBAMDBConnect* pDBConnect = GetMBAMDBConnect();
|
if ( !pDBConnect )
|
{
|
m_arSaveToDBCrowdMsg.Add(*pMsg);
|
return false;
|
}
|
CCrowdMsgs Msgs( pDBConnect);
|
pDBConnect->StartTransaction( );
|
bReturn = Msgs.DoSaveCrowdMsg( pMsg );
|
pDBConnect->Commit( );
|
return bReturn;
|
}
|
//==============================================
|
// ÉèÖÃÏûÏ¢µÄ´ò¿ª³ö´í
|
//==============================================
|
bool CMBAMBaseDBMgr::SetMsgReadError( CString strMsgID )
|
{
|
if ( strMsgID.IsEmpty() )
|
return false;
|
CSingleLock lock( &m_csConnectDB, true );
|
CMBAMDBConnect* pDBConnect = GetMBAMDBConnect();
|
if ( !pDBConnect )
|
return FALSE;
|
|
CMsgs Msgs( pDBConnect );
|
if ( Msgs.ListSpMsgID( strMsgID ) <= 0 )
|
{
|
pDBConnect->RemoveUnreadMsg(strMsgID);
|
return false;
|
}
|
Msgs.GetMsgData( );
|
if( Msgs.m_nReadState & MSG_READSTATE_ERROR )
|
{
|
pDBConnect->RemoveUnreadMsg(strMsgID);
|
return true;
|
}
|
// ÉèÖôò¿ªµÄ״̬
|
Msgs.m_nReadState = Msgs.m_nReadState | MSG_READSTATE_ERROR;
|
Msgs.UpdateRecord( pDBConnect->GetDBConnect() );
|
pDBConnect->RemoveUnreadMsg(strMsgID);
|
return true;
|
}
|
//==============================================
|
// ɾ³ýȺÐÅÏ¢
|
//==============================================
|
BOOL CMBAMBaseDBMgr::DeletCrowdMsg( CString strMsgID,CString strGroupID)
|
{
|
if(strMsgID.IsEmpty() || strGroupID.IsEmpty() )
|
return FALSE;
|
CSingleLock lock( &m_csConnectDB, true );
|
CMBAMDBConnect* pDBConnect = GetMBAMDBConnect();
|
if ( !pDBConnect )
|
return FALSE;
|
BOOL bRet;
|
bRet = pDBConnect->DeletCrowdMsg(strMsgID,strGroupID);
|
pDBConnect->Release();
|
return bRet;
|
}
|
//==============================================
|
// ɾ³ýȺ¹²ÏíÎļþÐÅÏ¢
|
//==============================================
|
BOOL CMBAMBaseDBMgr::DeleteGroupFileInfo( CString strGroupID, CString strShareID )
|
{
|
if(strShareID.IsEmpty())
|
return FALSE;
|
CSingleLock lock( &m_csConnectDB, true );
|
CMBAMDBConnect* pDBConnect = GetMBAMDBConnect();
|
if ( !pDBConnect )
|
return FALSE;
|
BOOL bRet;
|
bRet = pDBConnect->DeleteGroupFileInfo(strGroupID,strShareID);
|
pDBConnect->Release();
|
return bRet;
|
}
|
//==============================================
|
// ×°ÔØȺ¹²ÏíÎļþÐÅÏ¢
|
//==============================================
|
BOOL CMBAMBaseDBMgr::UpdateGroupFileInfo( CString strGroupID, CString strShareID, CString strFilePath, CString strFileName, __int64 nFileSize )
|
{
|
if(strShareID.IsEmpty())
|
return FALSE;
|
CSingleLock lock( &m_csConnectDB, true );
|
CMBAMDBConnect* pDBConnect = GetMBAMDBConnect();
|
if ( !pDBConnect )
|
return FALSE;
|
BOOL bRet;
|
bRet = pDBConnect->UpdateGroupFileInfo(strGroupID,strShareID, strFilePath,strFileName ,nFileSize );
|
pDBConnect->Release();
|
return bRet;
|
}
|
//==============================================
|
// Ìí¼ÓÊÕµ½Èº¹²ÏíÎļþÐÅÏ¢
|
//==============================================
|
BOOL CMBAMBaseDBMgr::AddGroupFileInfo( CString strGroupID, CString strShareID, CString strFileName, __int64 nFileSize )
|
{
|
if(strShareID.IsEmpty())
|
return FALSE;
|
CSingleLock lock( &m_csConnectDB, true );
|
CMBAMDBConnect* pDBConnect = GetMBAMDBConnect();
|
if ( !pDBConnect )
|
return FALSE;
|
BOOL bRet;
|
bRet = pDBConnect->AddGroupFileInfo(strGroupID,strShareID, strFileName, nFileSize);
|
pDBConnect->Release();
|
return bRet;
|
}
|
//==============================================
|
// ×°ÔØȺ¹²ÏíÎļþÐÅÏ¢
|
//==============================================
|
BOOL CMBAMBaseDBMgr::LoadGroupFilePath( CString strGroupID, CString strShareID, CString &strFilePath )
|
{
|
strFilePath = _T("");
|
if(strShareID.IsEmpty())
|
return FALSE;
|
CSingleLock lock( &m_csConnectDB, true );
|
CMBAMDBConnect* pDBConnect = GetMBAMDBConnect();
|
if ( !pDBConnect )
|
return FALSE;
|
BOOL bRet;
|
bRet = pDBConnect->LoadGroupFilePath(strGroupID,strShareID, strFilePath);
|
pDBConnect->Release();
|
if(strFilePath.IsEmpty())
|
return FALSE;
|
return bRet;
|
}
|
//==============================================
|
// ×°ÔØȺ¹²ÏíÎļþÐÅÏ¢
|
//==============================================
|
BOOL CMBAMBaseDBMgr::LoadGroupFileInfo( CString strGroupID, CString strShareID, CString &strFileName, __int64 &nFileSize )
|
{
|
strFileName = _T("");
|
nFileSize = 0;
|
if(strShareID.IsEmpty())
|
return FALSE;
|
CSingleLock lock( &m_csConnectDB, true );
|
CMBAMDBConnect* pDBConnect = GetMBAMDBConnect();
|
if ( !pDBConnect )
|
return FALSE;
|
BOOL bRet;
|
bRet = pDBConnect->LoadGroupFileInfo(strGroupID,strShareID, strFileName,nFileSize );
|
pDBConnect->Release();
|
if(strFileName.IsEmpty())
|
return FALSE;
|
return bRet;
|
}
|
|
BOOL CMBAMBaseDBMgr::LoadGroupFileInfo2( CString strGroupID, CString strShareID, CString &strFileName, CString &strFilePath, __int64 &nFileSize )
|
{
|
strFileName = _T("");
|
nFileSize = 0;
|
if(strShareID.IsEmpty())
|
return FALSE;
|
CSingleLock lock( &m_csConnectDB, true );
|
CMBAMDBConnect* pDBConnect = GetMBAMDBConnect();
|
if ( !pDBConnect )
|
return FALSE;
|
BOOL bRet;
|
bRet = pDBConnect->LoadGroupFileInfo2(strGroupID,strShareID, strFileName,strFilePath,nFileSize );
|
pDBConnect->Release();
|
if(strFileName.IsEmpty())
|
return FALSE;
|
return bRet;
|
}
|
|
BOOL CMBAMBaseDBMgr::LoadMsgFromDB( CString strMsgID, CMsgItem *pMsg )
|
{
|
CSingleLock lock( &m_csConnectDB, true );
|
CMBAMDBConnect* pDBConnect = GetMBAMDBConnect();
|
if ( !pDBConnect )
|
return FALSE;
|
CMsgs msgs(pDBConnect);
|
int nCount= msgs.ListSpMsgID(strMsgID);
|
if(nCount > 0)
|
{
|
msgs.GetData();
|
*pMsg = msgs;
|
|
long nPropertyCount = 0;
|
long nNum = 0;
|
CString strAttribName;
|
CString strAttribValue;
|
CString strAttitudeset;
|
CString strRightButton;
|
CString strAttitudeOk;
|
|
if ( pMsg->m_nMsgFlag & MSGFLAG_RESERTBUTTON )
|
{
|
strAttitudeset = pMsg->m_strAttitudeset ;
|
|
//Row.GetProp( (_T("rightbutton")), strRightButton );
|
if ( !strAttitudeset.IsEmpty() )
|
pMsg->SetProp( _T("attitudeset"), strAttitudeset );
|
if ( !strRightButton.IsEmpty() )
|
{
|
strAttitudeOk.Format( _T("%d"), pMsg->IsAttitudeOk( strRightButton ) );
|
pMsg->SetProp( _T("attitudeok"), strAttitudeOk );
|
}
|
}
|
|
return TRUE;
|
}
|
return FALSE;
|
|
}
|
BOOL CMBAMBaseDBMgr::LoadMsgAttachmentFromDB( CString strMsgID, CString strFileID, CMsgAttachmentItem *pMsg )
|
{
|
|
if ( strMsgID.IsEmpty() || strFileID.IsEmpty() )
|
return FALSE;
|
CSingleLock lock( &m_csConnectDB, true );
|
CMBAMDBConnect* pDBConnect = GetMBAMDBConnect();
|
if ( !pDBConnect )
|
return FALSE;
|
CMsgAttachments msgAttachments(pDBConnect);
|
int nCount= msgAttachments.ListSpMsgID(strMsgID,strFileID);
|
if(nCount > 0)
|
{
|
msgAttachments.GetData();
|
*pMsg = msgAttachments;
|
return TRUE;
|
}
|
return FALSE;
|
|
}
|
//==============================================
|
// ɾ³ýÏûÏ¢
|
//==============================================
|
BOOL CMBAMBaseDBMgr::DeleteMsgFromDB( CString strMsgID)
|
{
|
if(strMsgID.IsEmpty())
|
return FALSE;
|
CSingleLock lock( &m_csConnectDB, true );
|
CMBAMDBConnect* pDBConnect = GetMBAMDBConnect();
|
if ( !pDBConnect )
|
return FALSE;
|
BOOL bRet;
|
bRet = pDBConnect->DeleteMsgFromDB(strMsgID);
|
pDBConnect->Release();
|
return bRet;
|
}
|
bool CMBAMBaseDBMgr::ListMsg(CString strDate,CString strSender,long nLimitCount,CArrayShortMsg &arUserMsg,BOOL bTimeAsc )
|
{
|
CSingleLock lock( &m_csConnectDB, true );
|
CMBAMDBConnect* pDBConnect = GetMBAMDBConnect();
|
if ( !pDBConnect )
|
return FALSE;
|
pDBConnect->ListMsg(strDate,strSender,nLimitCount,arUserMsg, bTimeAsc);
|
pDBConnect->Release();
|
return true;
|
}
|
bool CMBAMBaseDBMgr::ListMsg2(CString strDate,CString strExtType,long nLimitCount,CArrayShortMsg &arUserMsg,BOOL bTimeAsc )
|
{
|
CSingleLock lock( &m_csConnectDB, true );
|
CMBAMDBConnect* pDBConnect = GetMBAMDBConnect();
|
if ( !pDBConnect )
|
return FALSE;
|
pDBConnect->ListMsg2(strDate,strExtType,nLimitCount,arUserMsg, bTimeAsc);
|
pDBConnect->Release();
|
return true;
|
}
|
|
bool CMBAMBaseDBMgr::MoveMsg( CString strMsgID, long nNewFolderID )
|
{
|
if ( strMsgID.IsEmpty() || nNewFolderID <= 0 )
|
return false;
|
|
CSingleLock lock( &m_csConnectDB, true );
|
CMBAMDBConnect* pDBConnect = GetMBAMDBConnect();
|
if ( !pDBConnect )
|
return FALSE;
|
CMsgs msgs( pDBConnect );
|
return msgs.MoveMsg(strMsgID, nNewFolderID);
|
}
|
bool CMBAMBaseDBMgr::ListFolder(long nParentFolderID, CSTKMsgRowSet *pMsgRowSet, long &nCount)
|
{
|
{
|
CSingleLock lock( &m_csConnectDB, true );
|
CMBAMDBConnect* pDBConnect = GetMBAMDBConnect();
|
if ( !pDBConnect )
|
return FALSE;
|
pMsgRowSet->SetDBConnect(pDBConnect);
|
pMsgRowSet->ListFolder(nParentFolderID, nCount);
|
pDBConnect->Release();
|
}
|
pMsgRowSet->ListRecordCount(nCount);
|
pMsgRowSet->Top();
|
return true;
|
}
|
//==============================================
|
// ɾ³ýÊղؼÐ
|
//==============================================
|
BOOL CMBAMBaseDBMgr::DeleteFolder(long nFolderID,int nMoveMsg)
|
{
|
if(nFolderID < FOLDERID_BASE)
|
return FALSE;
|
CSingleLock lock( &m_csConnectDB, true );
|
CMBAMDBConnect* pDBConnect = GetMBAMDBConnect();
|
if ( !pDBConnect )
|
return FALSE;
|
BOOL bRet;
|
bRet = pDBConnect->DeleteFolder( nFolderID,nMoveMsg);
|
pDBConnect->Release();
|
return bRet;
|
}
|
BOOL CMBAMBaseDBMgr::LoadCrowdMsgFromDB( CString strMsgID, CCrowdMsgItem *pMsg )
|
{
|
CSingleLock lock( &m_csConnectDB, true );
|
CMBAMDBConnect* pDBConnect = GetMBAMDBConnect();
|
if ( !pDBConnect )
|
return FALSE;
|
CCrowdMsgs msgs(pDBConnect);
|
int nCount= msgs.ListSpMsgID(strMsgID);
|
if(nCount > 0)
|
{
|
msgs.GetData();
|
*pMsg = msgs;
|
return TRUE;
|
}
|
return FALSE;
|
|
}
|
bool CMBAMBaseDBMgr::GetSendPerson( CArrayAMObject &arAMObject)
|
{
|
CSingleLock lock( &m_csConnectDB, true );
|
CMBAMDBConnect* pDBConnect = GetMBAMDBConnect();
|
if ( !pDBConnect )
|
return FALSE;
|
pDBConnect->GetSendPerson(arAMObject);
|
pDBConnect->Release();
|
return true;
|
}
|
bool CMBAMBaseDBMgr::GetReceivePerson( CArrayAMObject &arAMObject)
|
{
|
CSingleLock lock( &m_csConnectDB, true );
|
CMBAMDBConnect* pDBConnect = GetMBAMDBConnect();
|
if ( !pDBConnect )
|
return FALSE;
|
pDBConnect->GetReceivePerson(arAMObject);
|
pDBConnect->Release();
|
return true;
|
}
|
bool CMBAMBaseDBMgr::GetSendAttachPerson(CArrayAMObject &arAMObject)
|
{
|
CSingleLock lock( &m_csConnectDB, true );
|
CMBAMDBConnect* pDBConnect = GetMBAMDBConnect();
|
if ( !pDBConnect )
|
return FALSE;
|
pDBConnect->GetSendAttachPerson(arAMObject);
|
pDBConnect->Release();
|
return true;
|
}
|
bool CMBAMBaseDBMgr::GetCrowds(CArrayAMObject &arAMObject)
|
{
|
CSingleLock lock( &m_csConnectDB, true );
|
CMBAMDBConnect* pDBConnect = GetMBAMDBConnect();
|
if ( !pDBConnect )
|
return FALSE;
|
pDBConnect->GetCrowds(arAMObject);
|
pDBConnect->Release();
|
return true;
|
}
|
|
//=========================================================
|
// µÃµ½ÈËÔ±±¸×¢Ãû
|
//=========================================================
|
BOOL CMBAMBaseDBMgr::SaveUserRemarks( CString strLogin,CString strRemarks)
|
{
|
CSingleLock lock( &m_csConnectDB, true );
|
CMBAMDBConnect* pDBConnect = GetMBAMDBConnect();
|
if ( !pDBConnect )
|
return FALSE;
|
CString strClass;
|
BOOL bRet;
|
strClass = _T("_UserRemarks");
|
strLogin.MakeLower();
|
if(strRemarks.IsEmpty())
|
{
|
bRet = pDBConnect->RemovePropStringValue(strClass, strLogin);
|
}
|
else
|
bRet = pDBConnect->UpdatePropStringValue(strClass, strLogin,0,strRemarks);
|
pDBConnect->Release();
|
|
return bRet;
|
}
|
BOOL CMBAMBaseDBMgr::LoadUsersRemarks(CMapStringToString &mapUserRemarks)
|
{
|
CSingleLock lock( &m_csConnectDB, true );
|
CMBAMDBConnect* pDBConnect = GetMBAMDBConnect();
|
if ( !pDBConnect )
|
return FALSE;
|
CString strClass;
|
BOOL bRet;
|
mapUserRemarks.RemoveAll();
|
strClass = _T("_UserRemarks");
|
bRet = pDBConnect->LoadUsersPropValue(strClass,mapUserRemarks);
|
pDBConnect->Release();
|
return bRet;
|
}
|
|
BOOL CMBAMBaseDBMgr::LoadBackupDBFile()
|
{
|
m_arBackupDBFile.RemoveAll();
|
CString strTmpPath;
|
CString strTmpDir;
|
CString strTmpName;
|
ULONGLONG nSize = 0;
|
WIN32_FIND_DATA wfd;
|
ULONGLONG nMaxDword = MAXDWORD;
|
strTmpDir = CBaseCommFun::GetAMUserDataDir(m_strLoginName,m_strServerID );
|
strTmpPath.Format(_T("%s\\STKClient_*.db3"), strTmpDir );
|
HANDLE hFind = FindFirstFile(strTmpPath,&wfd);
|
if(hFind == INVALID_HANDLE_VALUE)
|
return FALSE;
|
do
|
{
|
if(wfd.dwFileAttributes & FILE_ATTRIBUTE_DIRECTORY)
|
{
|
continue ;
|
}
|
else
|
{
|
strTmpName.Format(_T("%s"), wfd.cFileName);
|
if(strTmpName.GetLength() == 31)
|
{
|
strTmpPath.Format(_T("%s\\%s"), strTmpDir, strTmpName);
|
m_arBackupDBFile.Add(strTmpPath);
|
}
|
}
|
}
|
while(FindNextFile(hFind,&wfd));
|
FindClose(hFind);
|
return TRUE;
|
}
|
BOOL CMBAMBaseDBMgr::GetBackupDBFile(CStringArray &arBackupDB)
|
{
|
arBackupDB.RemoveAll();
|
arBackupDB.Copy(m_arBackupDBFile);
|
return TRUE;
|
}
|
|
CString CMBAMBaseDBMgr::GetOldestMsg()
|
{
|
CString strDate = _T("");
|
CSingleLock lock( &m_csConnectDB, true );
|
CMBAMDBConnect* pDBConnect = GetMBAMDBConnect();
|
if ( !pDBConnect )
|
return strDate;
|
strDate= pDBConnect->GetOldestMsg();
|
pDBConnect->Release();
|
return strDate;
|
}
|
CString CMBAMBaseDBMgr::GetUpToDateMsg()
|
{
|
CString strDate = _T("");
|
CSingleLock lock( &m_csConnectDB, true );
|
CMBAMDBConnect* pDBConnect = GetMBAMDBConnect();
|
if ( !pDBConnect )
|
return strDate;
|
strDate= pDBConnect->GetUpToDateMsg();
|
pDBConnect->Release();
|
return strDate;
|
}
|
BOOL CMBAMBaseDBMgr::GetMsgDataCount(long &nMsgCount,long &nRelatedCount)
|
{
|
BOOL bRet = FALSE;
|
CSingleLock lock( &m_csConnectDB, true );
|
CMBAMDBConnect* pDBConnect = GetMBAMDBConnect();
|
if ( !pDBConnect )
|
return bRet;
|
bRet = pDBConnect->GetMsgDataCount(nMsgCount,nRelatedCount);
|
pDBConnect->Release();
|
return bRet;
|
}
|
BOOL CMBAMBaseDBMgr::CleanDateBeforeMsg(CString strDate)
|
{
|
BOOL bRet = FALSE;
|
CSingleLock lock( &m_csConnectDB, true );
|
CMBAMDBConnect* pDBConnect = GetMBAMDBConnect();
|
if ( !pDBConnect )
|
return bRet;
|
bRet = pDBConnect->CleanDateBeforeMsg(strDate);
|
pDBConnect->Release();
|
return bRet;
|
}
|
BOOL CMBAMBaseDBMgr::CleanDateAfterMsg(CString strDate)
|
{
|
BOOL bRet = FALSE;
|
CSingleLock lock( &m_csConnectDB, true );
|
CMBAMDBConnect* pDBConnect = GetMBAMDBConnect();
|
if ( !pDBConnect )
|
return bRet;
|
bRet = pDBConnect->CleanDateAfterMsg(strDate);
|
pDBConnect->Release();
|
return bRet;
|
}
|
|
BOOL CMBAMBaseDBMgr::CleanAMExtraData()
|
{
|
BOOL bRet = FALSE;
|
CSingleLock lock( &m_csConnectDB, true );
|
CMBAMDBConnect* pDBConnect = GetMBAMDBConnect();
|
if ( !pDBConnect )
|
return bRet;
|
bRet = pDBConnect->CleanAMExtraData();
|
pDBConnect->Release();
|
return bRet;
|
}
|
BOOL CMBAMBaseDBMgr::LoadGetUnreadMsgTime( CString &strLastTime )
|
{
|
strLastTime = _T("");
|
CSingleLock lock( &m_csConnectDB, true );
|
CMBAMDBConnect* pDBConnect = GetMBAMDBConnect();
|
if ( !pDBConnect )
|
return FALSE;
|
int nPropVer;
|
CString strPropExtValue;
|
CString strClass, strName;
|
BOOL bRet;
|
strClass = _T("_UnreadMsgTime");
|
strName = strClass;
|
bRet = pDBConnect->GetPropStringData(strClass,strName, nPropVer,strLastTime,strPropExtValue);
|
pDBConnect->Release();
|
if( !bRet)
|
return FALSE;
|
return TRUE;
|
}
|
BOOL CMBAMBaseDBMgr::SaveGetUnreadMsgTime( CString strLastTime)
|
{
|
CSingleLock lock( &m_csConnectDB, true );
|
CMBAMDBConnect* pDBConnect = GetMBAMDBConnect();
|
if ( !pDBConnect )
|
return FALSE;
|
CString strClass, strName;
|
CString strFileDir;
|
BOOL bRet;
|
int nTmpVer = 0;
|
|
strClass = _T("_UnreadMsgTime");
|
strName = strClass;
|
bRet = pDBConnect->UpdatePropFileData(strClass,strName, nTmpVer,strLastTime,_T(""));
|
pDBConnect->Release();
|
return bRet;
|
}
|
|
//=========================================================
|
// µÃµ½ÈËÔ±ÏûÏ¢ÏÔʾȨÏÞ
|
//=========================================================
|
BOOL CMBAMBaseDBMgr::LoadContactMsgRight( CMapStringToInt &mapMsgRight,int nContactType)
|
{
|
mapMsgRight.RemoveAll();
|
CSingleLock lock( &m_csConnectDB, true );
|
CMBAMDBConnect* pDBConnect = GetMBAMDBConnect();
|
if ( !pDBConnect )
|
return FALSE;
|
CString strClass;
|
BOOL bRet;
|
if(nContactType == AM_VIEWITEMTYPE_USER )
|
{
|
strClass = _T("_UserMsgRight");
|
}
|
else if(nContactType == AM_VIEWITEMTYPE_CROWD )
|
{
|
strClass = _T("_CrowdMsgRight");
|
}
|
else
|
{
|
pDBConnect->Release();
|
return FALSE;
|
}
|
bRet = pDBConnect->LoadContactMsgRight(strClass, mapMsgRight);
|
pDBConnect->Release();
|
return bRet;
|
}
|
BOOL CMBAMBaseDBMgr::SaveContactMsgRight( CString strID, int nMsgRight,int nContactType)
|
{
|
if(strID.IsEmpty())
|
return FALSE;
|
CSingleLock lock( &m_csConnectDB, true );
|
CMBAMDBConnect* pDBConnect = GetMBAMDBConnect();
|
if ( !pDBConnect )
|
return FALSE;
|
CString strClass, strName;
|
CString strValue = _T("");
|
BOOL bRet;
|
if(nContactType == AM_VIEWITEMTYPE_USER )
|
{
|
strClass = _T("_UserMsgRight");
|
}
|
else if(nContactType == AM_VIEWITEMTYPE_CROWD )
|
{
|
strClass = _T("_CrowdMsgRight");
|
}
|
else
|
{
|
pDBConnect->Release();
|
return FALSE;
|
}
|
strName = strID;
|
strValue.Format(_T("%d"), nMsgRight);
|
bRet = pDBConnect->UpdatePropStringData(strClass,strName, 0,strValue,_T(""));
|
pDBConnect->Release();
|
return bRet;
|
}
|
