// MBAMDBConnect.cpp : implementation file
|
//
|
|
#include "stdafx.h"
|
#include "mbamdb.h"
|
#include "MBAMDBConnect.h"
|
#include "MBAMDBFun.h"
|
#include "MBAMDBDef.h"
|
#include "msg.h"
|
|
// CMBAMDBConnect
|
CCriticalSection m_csConnectDB;
|
|
CMBAMDBConnect::CMBAMDBConnect()
|
{
|
m_nAddRef = 0;
|
m_strLogin = _T("");
|
m_strServerID = _T("");
|
m_strDBFile = _T("");
|
m_bOpenDB = FALSE;
|
}
|
|
CMBAMDBConnect::~CMBAMDBConnect()
|
{
|
}
|
|
|
// CMBAMDBConnect member functions
|
void CMBAMDBConnect::AddRef()
|
{
|
m_nAddRef++;
|
//CMBAMDBFun::WriteDBErrToFile(strLog);
|
}
|
void CMBAMDBConnect::Release()
|
{
|
m_nAddRef--;
|
if(m_nAddRef < 1 )
|
{
|
if( CloseDB() )
|
delete this;
|
}
|
}
|
int CMBAMDBConnect::OpenDB( CString strLogin, CString strServerID, BOOL &bFirstDB )
|
{
|
bFirstDB = TRUE;
|
if ( strLogin.IsEmpty() || strServerID.IsEmpty() )
|
{
|
return STKERR_DB_NOLOGINSERVER;
|
}
|
CloseDB();
|
m_nAddRef = 0;
|
CString strPathName, strFileName;
|
CString strTemplateDBFile;
|
CString strDBPassword;
|
BOOL bExistFile = false;
|
|
strTemplateDBFile.Format( _T("%s\\stkclient.db3"),CBaseCommFun::GetAMDataDir( ));
|
strFileName.Format( _T("%s\\STKClient.db3"), CBaseCommFun::GetAMUserDataDir(strLogin,strServerID ) );
|
bExistFile = CBaseCommFun::ExistFile( strFileName );
|
if ( bExistFile )
|
{
|
bFirstDB = FALSE;
|
}
|
else
|
{
|
if ( strTemplateDBFile.IsEmpty() )
|
return STKERR_DB_NOTEMPLETFILE;
|
if ( !CopyFile( strTemplateDBFile, strFileName, false ) )
|
{
|
return STKERR_DB_COYPTEMPLETFAILED;
|
}
|
}
|
GetDBPassword( strDBPassword );
|
if ( !m_AConnect.Open( strFileName ,strDBPassword ) )
|
return STKERR_DB_OPENFAILED;
|
AddRef();
|
m_strLogin = strLogin;
|
m_strServerID = strServerID;
|
m_strDBFile = strFileName;
|
m_bOpenDB = TRUE;
|
return 0;
|
}
|
int CMBAMDBConnect::OpenDB( CString strDBFile)
|
{
|
if ( strDBFile.IsEmpty())
|
{
|
return STKERR_DB_NOLOGINSERVER;
|
}
|
CloseDB();
|
m_nAddRef = 0;
|
CString strDBPassword;
|
if ( !CBaseCommFun::ExistFile( strDBFile ) )
|
{
|
return STKERR_DB_NODBFILE;
|
}
|
GetDBPassword( strDBPassword );
|
if ( !m_AConnect.Open( strDBFile ,strDBPassword ) )
|
return STKERR_DB_OPENFAILED;
|
AddRef();
|
m_strDBFile = strDBFile;
|
m_bOpenDB = TRUE;
|
return 0;
|
}
|
|
BOOL CMBAMDBConnect::CloseDB()
|
{
|
if ( m_bOpenDB )
|
{
|
m_AConnect.Close();
|
m_bOpenDB = FALSE;
|
m_strDBFile = _T( "" );
|
m_strLogin = _T("");
|
m_strServerID = _T("");
|
return TRUE;
|
}
|
return FALSE;
|
}
|
CDBConnect* CMBAMDBConnect::GetDBConnect( )
|
{
|
return &m_AConnect;
|
}
|
|
BOOL CMBAMDBConnect::IsThisDB( CString strLogin, CString strServerID )
|
{
|
if ( strLogin.CompareNoCase( m_strLogin ) == 0
|
&& strServerID.CompareNoCase( m_strServerID ) == 0 )
|
{
|
return true;
|
}
|
|
return false;
|
}
|
BOOL CMBAMDBConnect::IsOpenDB( )
|
{
|
return m_bOpenDB;
|
}
|
void CMBAMDBConnect::GetDBPassword( CString &strDBPassword )
|
{
|
CString strInitFile;
|
TCHAR szValue[256] = { 0 };
|
|
strInitFile = CMBAMDBFun::GetDefaultIniFile();
|
GetPrivateProfileString(SYSSET_STK_SECTION, SYSSET_STK_SECTION_DBPASSWORD,_T(""),szValue,256, strInitFile );
|
strDBPassword = szValue;
|
CEncrypt::Decrypt( strDBPassword, PSW_EMKEY );
|
}
|
|
BOOL CMBAMDBConnect::StartTransaction()
|
{
|
return m_AConnect.StartTransaction();
|
}
|
BOOL CMBAMDBConnect::Commit()
|
{
|
return m_AConnect.Commit();
|
}
|
BOOL CMBAMDBConnect::Abort()
|
{
|
return m_AConnect.Abort();
|
}
|
BOOL CMBAMDBConnect::InsertPropStringData( CString strPropClass,
|
CString strPropName, int nPropVer,CString strPropValue, CString strPropExtValue )
|
{
|
if ( strPropClass.IsEmpty() || strPropName.IsEmpty() )
|
return FALSE;
|
//CSingleLock lock( &m_csConnectDB, true );
|
if ( !m_bOpenDB )
|
return FALSE;
|
CString strSQL;
|
BOOL bReturn = TRUE;
|
CString strWhere;
|
|
strSQL.Format( _T("INSERT INTO TN_STK_USEREXTPROPERTY(S_C1 , S_C2 , N_C3 , S_C4, B_C5) VALUES ( \
|
'%s', '%s', %d, '%s', ?)"), CMBAMDBFun::GetDBReplaceStr( strPropClass ),CMBAMDBFun::GetDBReplaceStr( strPropName ), nPropVer, CMBAMDBFun::GetDBReplaceStr( strPropValue ));
|
try
|
{
|
|
bReturn = CDBBlob::SaveString(&m_AConnect,strSQL, strPropExtValue);
|
}
|
catch ( CDBSQliteException ex )
|
{
|
CString strError = ex.GetErrInfo();
|
CString strErrInfo;
|
|
strErrInfo.Format(_T("InsertPropStringData(%s) - %s"),strSQL, strError);
|
CMBAMDBFun::WriteDBErrToFile( strErrInfo );
|
return FALSE;
|
}
|
|
return bReturn;
|
}
|
BOOL CMBAMDBConnect::UpdatePropStringData( CString strPropClass,
|
CString strPropName, int nPropVer,CString strPropValue, CString strPropExtValue )
|
{
|
if ( strPropClass.IsEmpty() || strPropName.IsEmpty() )
|
return FALSE;
|
// CSingleLock lock( &m_csConnectDB, true );
|
if ( !m_bOpenDB )
|
return FALSE;
|
|
CString strSQL, strWhere;
|
CDBRecord ARecordset;
|
BOOL bReturn = true;
|
int nCount = 0;
|
|
strSQL.Format( _T("SELECT COUNT(*) FROM TN_STK_USEREXTPROPERTY WHERE S_C1='%s' AND S_C2='%s'"),CMBAMDBFun::GetDBReplaceStr( strPropClass ),CMBAMDBFun::GetDBReplaceStr( strPropName ));
|
try
|
{
|
|
ARecordset.Open( &m_AConnect,strSQL );
|
while (S_OK == ARecordset.MoveNext() )
|
{
|
ARecordset.GetValue( 1, nCount );
|
break;
|
}
|
if(nCount > 0 )
|
{
|
strSQL.Format( _T("UPDATE TN_STK_USEREXTPROPERTY SET N_C3 = %d,S_C4 = '%s',B_C5=? WHERE S_C1='%s' AND S_C2='%s'"),
|
nPropVer,CMBAMDBFun::GetDBReplaceStr( strPropValue ),CMBAMDBFun::GetDBReplaceStr( strPropClass ),CMBAMDBFun::GetDBReplaceStr( strPropName ) );
|
|
}
|
else
|
{
|
strSQL.Format( _T("INSERT INTO TN_STK_USEREXTPROPERTY(S_C1 , S_C2 , N_C3 , S_C4, B_C5) VALUES ( \
|
'%s', '%s', %d, '%s', ?)"), CMBAMDBFun::GetDBReplaceStr( strPropClass ),CMBAMDBFun::GetDBReplaceStr( strPropName ), nPropVer, CMBAMDBFun::GetDBReplaceStr( strPropValue ));
|
}
|
bReturn = CDBBlob::SaveString(&m_AConnect,strSQL, strPropExtValue);
|
}
|
catch ( CDBSQliteException ex )
|
{
|
CString strError, strErrInfo;
|
|
strError = ex.GetErrInfo();
|
strErrInfo.Format(_T("UpdatePropData(%s) - %s"),strSQL, strError);
|
CMBAMDBFun::WriteDBErrToFile( strErrInfo );
|
return FALSE;
|
}
|
return bReturn;
|
}
|
|
BOOL CMBAMDBConnect::InsertPropFileData( CString strPropClass,
|
CString strPropName, int nPropVer, CString strPropValue, CString strPropDataFile )
|
{
|
|
if ( strPropClass.IsEmpty() || strPropName.IsEmpty() )
|
return FALSE;
|
//CSingleLock lock( &m_csConnectDB, true );
|
if ( !m_bOpenDB )
|
return FALSE;
|
CString strSQL;
|
BOOL bReturn = TRUE;
|
CString strWhere;
|
|
strSQL.Format( _T("INSERT INTO TN_STK_USEREXTPROPERTY(S_C1 , S_C2 , N_C3 , S_C4, B_C5) VALUES ( \
|
'%s', '%s', %d, '%s', ?)"), CMBAMDBFun::GetDBReplaceStr( strPropClass ),CMBAMDBFun::GetDBReplaceStr( strPropName ), nPropVer, CMBAMDBFun::GetDBReplaceStr( strPropValue ));
|
try
|
{
|
if(CBaseCommFun::ExistFile(strPropDataFile))
|
{
|
bReturn = CDBBlob::SaveFile(&m_AConnect,strSQL, strPropDataFile);
|
}
|
else
|
{
|
bReturn = CDBBlob::SaveString(&m_AConnect,strSQL, _T(""));
|
}
|
|
}
|
catch ( CDBSQliteException ex )
|
{
|
CString strError = ex.GetErrInfo();
|
CString strErrInfo;
|
|
strErrInfo.Format(_T("InsertPropFileData(%s) - %s"),strSQL, strError);
|
CMBAMDBFun::WriteDBErrToFile( strErrInfo );
|
return FALSE;
|
}
|
return bReturn;
|
}
|
BOOL CMBAMDBConnect::UpdatePropFileData( CString strPropClass,
|
CString strPropName, int nPropVer,CString strPropValue, CString strPropDataFile )
|
{
|
if ( strPropClass.IsEmpty() || strPropName.IsEmpty() )
|
return FALSE;
|
//CSingleLock lock( &m_csConnectDB, true );
|
if ( !m_bOpenDB )
|
return FALSE;
|
|
CString strSQL;
|
CDBRecord ARecordset;
|
BOOL bReturn = true;
|
int nCount = 0;
|
|
strSQL.Format( _T("SELECT COUNT(*) FROM TN_STK_USEREXTPROPERTY WHERE S_C1='%s' AND S_C2='%s'"),CMBAMDBFun::GetDBReplaceStr( strPropClass ),CMBAMDBFun::GetDBReplaceStr( strPropName ));
|
try
|
{
|
|
ARecordset.Open( &m_AConnect,strSQL );
|
while ( S_OK == ARecordset.MoveNext() )
|
{
|
ARecordset.GetValue( 1, nCount );
|
break;
|
}
|
if(nCount > 0 )
|
{
|
strSQL.Format( _T("UPDATE TN_STK_USEREXTPROPERTY SET N_C3 = %d, S_C4='%s', B_C5=? WHERE S_C1='%s' AND S_C2='%s'"),
|
nPropVer, CMBAMDBFun::GetDBReplaceStr( strPropValue ), CMBAMDBFun::GetDBReplaceStr( strPropClass ),CMBAMDBFun::GetDBReplaceStr( strPropName ) );
|
}
|
else
|
{
|
strSQL.Format( _T("INSERT INTO TN_STK_USEREXTPROPERTY(S_C1 , S_C2 , N_C3, S_C4,B_C5) VALUES ( \
|
'%s', '%s', %d,'%s',?)"), CMBAMDBFun::GetDBReplaceStr( strPropClass ),CMBAMDBFun::GetDBReplaceStr( strPropName ), nPropVer, CMBAMDBFun::GetDBReplaceStr( strPropValue ));
|
|
}
|
if(CBaseCommFun::ExistFile(strPropDataFile))
|
{
|
bReturn = CDBBlob::SaveFile(&m_AConnect,strSQL, strPropDataFile);
|
}
|
else
|
{
|
bReturn = CDBBlob::SaveString(&m_AConnect,strSQL, _T(""));
|
}
|
|
}
|
catch ( CDBSQliteException ex )
|
{
|
CString strError = ex.GetErrInfo();
|
CString strErrInfo;
|
|
strErrInfo.Format(_T("UpdatePropFileData(%s) - %s"),strSQL, strError);
|
CMBAMDBFun::WriteDBErrToFile( strErrInfo );
|
return FALSE;
|
}
|
|
return bReturn;
|
}
|
|
BOOL CMBAMDBConnect::GetPropFileData( CString strPropClass,
|
CString strPropName, int &nPropVer,CString &strPropValue, CString strPropDataFile )
|
{
|
if ( strPropClass.IsEmpty() || strPropName.IsEmpty() )
|
return FALSE;
|
//CSingleLock lock( &m_csConnectDB, true );
|
if ( !m_bOpenDB )
|
return FALSE;
|
CString strSQL;
|
CDBRecord ARecordset;
|
BOOL bReturn = FALSE;
|
BOOL bFlag = FALSE;
|
CString strVaule;
|
int nVaule;
|
|
nPropVer = 0;
|
strPropValue = _T("");
|
strSQL.Format( _T("SELECT N_C3, S_C4 FROM TN_STK_USEREXTPROPERTY WHERE S_C1='%s' AND S_C2='%s'"),CMBAMDBFun::GetDBReplaceStr( strPropClass ),CMBAMDBFun::GetDBReplaceStr( strPropName ));
|
try
|
{
|
|
ARecordset.Open( &m_AConnect,strSQL );
|
while ( S_OK == ARecordset.MoveNext() )
|
{
|
nVaule = 0;
|
ARecordset.GetValue( 1, nVaule );
|
nPropVer = nVaule;
|
strVaule = _T("");
|
ARecordset.GetValue( 2, strVaule );
|
strPropValue = strVaule;
|
bFlag = TRUE;
|
break;
|
}
|
if( bFlag )
|
{
|
if( !strPropDataFile.IsEmpty())
|
{
|
strSQL.Format( _T("SELECT B_C5 FROM TN_STK_USEREXTPROPERTY WHERE S_C1='%s' AND S_C2='%s'"),CMBAMDBFun::GetDBReplaceStr( strPropClass ),CMBAMDBFun::GetDBReplaceStr( strPropName ));
|
bReturn = CDBBlob::ReadFile(&m_AConnect, strSQL, strPropDataFile);
|
}
|
}
|
}
|
catch ( CDBSQliteException ex )
|
{
|
CString strError = ex.GetErrInfo();
|
CString strErrInfo;
|
|
strErrInfo.Format(_T("GetPropFileData(%s) - %s"),strSQL, strError);
|
CMBAMDBFun::WriteDBErrToFile( strErrInfo );
|
return FALSE;
|
}
|
|
return bReturn;
|
}
|
BOOL CMBAMDBConnect::GetPropStringData(CString strPropClass,
|
CString strPropName, int &nPropVer,CString &strPropValue, CString &strPropExtValue )
|
{
|
if ( strPropClass.IsEmpty() || strPropName.IsEmpty() )
|
return FALSE;
|
//CSingleLock lock( &m_csConnectDB, true );
|
if ( !m_bOpenDB )
|
return FALSE;
|
CString strSQL;
|
CDBRecord ARecordset;
|
BOOL bReturn = FALSE;
|
BOOL bFlag = FALSE;
|
CString strVaule;
|
int nVaule;
|
|
nPropVer = 0;
|
strPropValue = _T("");
|
strPropExtValue = _T("");
|
strSQL.Format( _T("SELECT N_C3, S_C4 FROM TN_STK_USEREXTPROPERTY WHERE S_C1='%s' AND S_C2='%s'"),CMBAMDBFun::GetDBReplaceStr( strPropClass ),CMBAMDBFun::GetDBReplaceStr( strPropName ));
|
try
|
{
|
ARecordset.Open( &m_AConnect,strSQL );
|
while ( S_OK == ARecordset.MoveNext() )
|
{
|
nVaule = 0;
|
ARecordset.GetValue( 1, nVaule );
|
nPropVer = nVaule;
|
strVaule = _T("");
|
ARecordset.GetValue( 2, strVaule );
|
strPropValue = strVaule;
|
bFlag = TRUE;
|
break;
|
}
|
if( bFlag )
|
{
|
strSQL.Format( _T("SELECT B_C5 FROM TN_STK_USEREXTPROPERTY WHERE S_C1='%s' AND S_C2='%s'"),CMBAMDBFun::GetDBReplaceStr( strPropClass ),CMBAMDBFun::GetDBReplaceStr( strPropName ));
|
bReturn = CDBBlob::ReadString(&m_AConnect, strSQL, strPropExtValue);
|
}
|
}
|
catch ( CDBSQliteException ex )
|
{
|
CString strError = ex.GetErrInfo();
|
CString strErrInfo;
|
|
strErrInfo.Format(_T("GetPropStringData(%s) - %s"),strSQL, strError);
|
CMBAMDBFun::WriteDBErrToFile( strErrInfo );
|
return FALSE;
|
}
|
|
return bReturn;
|
}
|
|
BOOL CMBAMDBConnect::GetPropVersion(CString strPropClass, CString strPropName, int &nPropVer )
|
{
|
if ( strPropClass.IsEmpty() || strPropName.IsEmpty() )
|
return FALSE;
|
//CSingleLock lock( &m_csConnectDB, true );
|
if ( !m_bOpenDB )
|
return FALSE;
|
CString strSQL;
|
CDBRecord ARecordset;
|
BOOL bReturn = FALSE;
|
int nVaule;
|
|
nPropVer =0;
|
strSQL.Format( _T("SELECT N_C3 FROM TN_STK_USEREXTPROPERTY WHERE S_C1='%s' AND S_C2='%s'"),CMBAMDBFun::GetDBReplaceStr( strPropClass ),CMBAMDBFun::GetDBReplaceStr( strPropName ));
|
try
|
{
|
ARecordset.Open( &m_AConnect,strSQL );
|
while ( S_OK == ARecordset.MoveNext() )
|
{
|
nVaule = 0;
|
ARecordset.GetValue( 1, nVaule );
|
nPropVer = nVaule;
|
bReturn = TRUE;
|
break;
|
}
|
}
|
catch ( CDBSQliteException ex )
|
{
|
CString strError = ex.GetErrInfo();
|
CString strErrInfo;
|
|
strErrInfo.Format(_T("GetPropVersion(%s) - %s"),strSQL, strError);
|
CMBAMDBFun::WriteDBErrToFile( strErrInfo );
|
return FALSE;
|
}
|
return bReturn;
|
}
|
|
BOOL CMBAMDBConnect::SetPropVersion(CString strPropClass, CString strPropName, int nPropVer )
|
{
|
if ( strPropClass.IsEmpty() || strPropName.IsEmpty() )
|
return FALSE;
|
if ( !m_bOpenDB )
|
return FALSE;
|
|
CString strSQL;
|
CDBRecord ARecordset;
|
BOOL bReturn = true;
|
int nCount = 0;
|
strSQL.Format( _T("SELECT COUNT(*) FROM TN_STK_USEREXTPROPERTY WHERE S_C1='%s' AND S_C2='%s'"),CMBAMDBFun::GetDBReplaceStr( strPropClass ),CMBAMDBFun::GetDBReplaceStr( strPropName ));
|
try
|
{
|
|
ARecordset.Open( &m_AConnect,strSQL );
|
while ( S_OK == ARecordset.MoveNext() )
|
{
|
ARecordset.GetValue( 1, nCount );
|
break;
|
}
|
if(nCount > 0 )
|
{
|
strSQL.Format( _T("UPDATE TN_STK_USEREXTPROPERTY SET N_C3 = %d WHERE S_C1='%s' AND S_C2='%s'"),
|
nPropVer,CMBAMDBFun::GetDBReplaceStr( strPropClass ),CMBAMDBFun::GetDBReplaceStr( strPropName ) );
|
}
|
else
|
{
|
strSQL.Format( _T("INSERT INTO TN_STK_USEREXTPROPERTY(S_C1 , S_C2 , N_C3) VALUES ( '%s', '%s', %d)"),
|
CMBAMDBFun::GetDBReplaceStr( strPropClass ),CMBAMDBFun::GetDBReplaceStr( strPropName ),nPropVer );
|
}
|
bReturn = CDBSQLiteCommFun::RunSQL(strSQL, &m_AConnect);
|
}
|
catch ( CDBSQliteException ex )
|
{
|
CString strError = ex.GetErrInfo();
|
CString strErrInfo;
|
|
strErrInfo.Format(_T("SetPropVersion(%s) - %s"),strSQL, strError);
|
CMBAMDBFun::WriteDBErrToFile( strErrInfo );
|
return FALSE;
|
}
|
return bReturn;
|
}
|
|
BOOL CMBAMDBConnect::GetPropertyData(CString strPropClass, CString strPropName, CString &strPropValue )
|
{
|
if ( strPropClass.IsEmpty() || strPropName.IsEmpty() )
|
return FALSE;
|
if ( !m_bOpenDB )
|
return FALSE;
|
CString strSQL;
|
CDBRecord ARecordset;
|
BOOL bReturn = FALSE;
|
CString strVaule;
|
|
strPropValue = _T("");
|
strSQL.Format( _T("SELECT S_C3 FROM TN_STK_EXTPROPERTY WHERE S_C1='%s' AND S_C2='%s'"),CMBAMDBFun::GetDBReplaceStr( strPropClass ),CMBAMDBFun::GetDBReplaceStr( strPropName ));
|
try
|
{
|
ARecordset.Open( &m_AConnect,strSQL );
|
while ( S_OK == ARecordset.MoveNext() )
|
{
|
ARecordset.GetValue( 1, strVaule );
|
strPropValue = strVaule;
|
bReturn = TRUE;
|
break;
|
}
|
}
|
catch ( CDBSQliteException ex )
|
{
|
CString strError = ex.GetErrInfo();
|
CString strErrInfo;
|
|
strErrInfo.Format(_T("GetPropertyData(%s) - %s"),strSQL, strError);
|
CMBAMDBFun::WriteDBErrToFile( strErrInfo );
|
return FALSE;
|
}
|
return bReturn;
|
}
|
|
BOOL CMBAMDBConnect::SetPropertyData(CString strPropClass, CString strPropName, CString strPropValue )
|
{
|
if ( strPropClass.IsEmpty() || strPropName.IsEmpty() )
|
return FALSE;
|
if ( !m_bOpenDB )
|
return FALSE;
|
|
CString strSQL;
|
CDBRecord ARecordset;
|
BOOL bReturn = true;
|
int nCount = 0;
|
|
strSQL.Format( _T("SELECT COUNT(*) FROM TN_STK_EXTPROPERTY WHERE S_C1='%s' AND S_C2='%s'"),CMBAMDBFun::GetDBReplaceStr( strPropClass ),CMBAMDBFun::GetDBReplaceStr( strPropName ));
|
try
|
{
|
|
ARecordset.Open( &m_AConnect,strSQL );
|
while ( S_OK == ARecordset.MoveNext() )
|
{
|
ARecordset.GetValue( 1, nCount );
|
break;
|
}
|
if(nCount > 0 )
|
{
|
strSQL.Format( _T("UPDATE TN_STK_EXTPROPERTY SET S_C3 = %d WHERE S_C1='%s' AND S_C2='%s'"),
|
strPropValue,CMBAMDBFun::GetDBReplaceStr( strPropClass ),CMBAMDBFun::GetDBReplaceStr( strPropName ) );
|
}
|
else
|
{
|
strSQL.Format( _T("INSERT INTO TN_STK_EXTPROPERTY(S_C1 , S_C2 , S_C3) VALUES ( '%s', '%s', '%s')"),
|
CMBAMDBFun::GetDBReplaceStr( strPropClass ),CMBAMDBFun::GetDBReplaceStr( strPropName ),strPropValue );
|
}
|
bReturn = CDBSQLiteCommFun::RunSQL(strSQL, &m_AConnect);
|
}
|
catch ( CDBSQliteException ex )
|
{
|
CString strError = ex.GetErrInfo();
|
CString strErrInfo;
|
|
strErrInfo.Format(_T("SetPropertyData(%s) - %s"),strSQL, strError);
|
CMBAMDBFun::WriteDBErrToFile( strErrInfo );
|
return FALSE;
|
}
|
return bReturn;
|
}
|
|
BOOL CMBAMDBConnect::RemoveLastContact( CString strID, int nType)
|
{
|
if ( strID.IsEmpty() )
|
return FALSE;
|
if ( !m_bOpenDB )
|
return FALSE;
|
CString strSQL;
|
BOOL bReturn = FALSE;
|
|
if(nType != AM_VIEWITEMTYPE_USER && nType != AM_VIEWITEMTYPE_CROWD )
|
return TRUE;
|
strSQL.Format( _T("DELETE FROM TN_STK_LASTCONTACT WHERE S_C1= '%s' AND N_C4 =%d"), CMBAMDBFun::GetDBReplaceStr( strID), nType );
|
try
|
{
|
|
bReturn = CDBSQLiteCommFun::RunSQL( (LPCTSTR)strSQL,&m_AConnect);
|
}
|
catch ( CDBSQliteException ex )
|
{
|
CString strError = ex.GetErrInfo();
|
CString strErrInfo;
|
|
strErrInfo = _T("RemoveLastContact - ") + strError;
|
CMBAMDBFun::WriteDBErrToFile( strErrInfo );
|
return FALSE;
|
}
|
return bReturn;
|
}
|
BOOL CMBAMDBConnect::LoadLastContact(CArraySTKLastContact &arLastContact, int nLimitCount )
|
{
|
CString strID, strName;
|
CString strSQL, strValue;
|
CDBRecord ARecordset;
|
COleDateTime aDate;
|
CString strSubject;
|
int nType = AM_VIEWITEMTYPE_NONE;
|
stSTKLastContact itemLastContact;
|
CMapStringToString mapLastContact;
|
CString strLastOldDate= _T("");
|
arLastContact.RemoveAll();
|
if ( !m_bOpenDB )
|
return FALSE;
|
CString strLimitSQL = _T("");
|
if(nLimitCount > 0)
|
strLimitSQL.Format( _T("limit 0,%d"), nLimitCount);
|
strSQL.Format( _T("SELECT S_C1, S_C2, T_C3,N_C4, S_C5 ")
|
_T("FROM TN_STK_LASTCONTACT ")
|
_T(" ORDER BY T_C3 DESC %s"), strLimitSQL);
|
|
try
|
{
|
mapLastContact.RemoveAll();
|
ARecordset.Open( &m_AConnect,strSQL );
|
while ( S_OK == ARecordset.MoveNext() )
|
{
|
ARecordset.GetValue( 1, strValue, true );
|
strID = strValue;
|
strValue = _T("");
|
|
if(mapLastContact.Lookup(strID,strValue))
|
{
|
continue;
|
}
|
nType = AM_VIEWITEMTYPE_USER;
|
mapLastContact.SetAt(strID,strID);
|
ARecordset.GetValue( 2, strValue, true );
|
strName = strValue;
|
strValue = _T("");
|
ARecordset.GetValue( 3, aDate );
|
ARecordset.GetValue( 4, nType );
|
ARecordset.GetValue( 5, strValue, true );
|
strSubject = strValue;
|
itemLastContact.strID = strID;
|
itemLastContact.strName = strName;
|
itemLastContact.nType = nType;
|
itemLastContact.dtDate = aDate;
|
itemLastContact.strSubject = strSubject;
|
arLastContact.Add(itemLastContact);
|
strLastOldDate = CMBAMDBFun::FormatDBTIMEToStr( aDate );
|
}
|
if( !strLastOldDate.IsEmpty())
|
{
|
strSQL.Format( _T("DELETE FROM TN_STK_LASTCONTACT WHERE T_C3<'%s'"), strLastOldDate );
|
CDBSQLiteCommFun::RunSQL( (LPCTSTR)strSQL,&m_AConnect);
|
}
|
|
}
|
catch( CDBSQliteException ex )
|
{
|
CString strError = ex.GetErrInfo();
|
CString strErrInfo;
|
|
strErrInfo = _T("LoadLastContact - ") + strError;
|
CMBAMDBFun::WriteDBErrToFile( strErrInfo );
|
|
return FALSE;
|
}
|
return TRUE;
|
}
|
BOOL CMBAMDBConnect::GetLastContactItem(CString strID, int nType,stSTKLastContact &itemLastContact )
|
{
|
CString strName;
|
CString strSQL, strValue;
|
CDBRecord ARecordset;
|
CString strSubject;
|
COleDateTime aDate;
|
BOOL bRet = FALSE ;
|
if ( !m_bOpenDB )
|
return FALSE;
|
strSQL.Format( _T("SELECT S_C1, S_C2, T_C3,N_C4, S_C5 ")
|
_T("FROM TN_STK_LASTCONTACT WHERE S_C1='%s' AND N_C4=%d"), strID,nType);
|
try
|
{
|
ARecordset.Open( &m_AConnect,strSQL );
|
while ( S_OK == ARecordset.MoveNext() )
|
{
|
ARecordset.GetValue( 2, strValue, true );
|
strName = strValue;
|
strValue = _T("");
|
ARecordset.GetValue( 3, aDate );
|
ARecordset.GetValue( 5, strValue, true );
|
strSubject = strValue;
|
itemLastContact.strID = strID;
|
itemLastContact.strName = strName;
|
itemLastContact.nType = nType;
|
itemLastContact.dtDate = aDate;
|
itemLastContact.strSubject = strSubject;
|
bRet = TRUE ;
|
break;
|
}
|
|
}
|
catch( CDBSQliteException ex )
|
{
|
CString strError = ex.GetErrInfo();
|
CString strErrInfo;
|
|
strErrInfo = _T("GetLastContactItem - ") + strError;
|
CMBAMDBFun::WriteDBErrToFile( strErrInfo );
|
|
return FALSE;
|
}
|
return bRet;
|
}
|
int CMBAMDBConnect::GetUnreadMsgCount( CString strID, int nType)
|
{
|
if ( !m_bOpenDB )
|
return 0;
|
CString strSQL;
|
CDBRecord ARecordset;
|
int nRecordCount = 0;
|
|
if(nType == AM_VIEWITEMTYPE_USER)
|
{
|
strSQL.Format(_T("SELECT COUNT(G_C1) FROM TN_STK_UNREADMSG WHERE S_C2='%s'"),strID);
|
}
|
else if(nType == AM_VIEWITEMTYPE_CROWD)
|
strSQL.Format(_T("SELECT COUNT(G_C1) FROM TN_STK_CROWDMSG WHERE G_C2='%s' AND N_C7 <= 1 "),strID);
|
else
|
return 0;
|
try
|
{
|
|
ARecordset.Open( &m_AConnect,strSQL );
|
while ( S_OK == ARecordset.MoveNext() )
|
{
|
ARecordset.GetValue( 1, nRecordCount );
|
break;
|
}
|
}
|
catch( CDBSQliteException ex )
|
{
|
CString strError = ex.GetErrInfo();
|
CString strErrInfo;
|
|
strErrInfo = _T("GetUnreadMsgCount - ") + strError;
|
CMBAMDBFun::WriteDBErrToFile( strErrInfo );
|
return 0;
|
}
|
return nRecordCount;
|
}
|
int CMBAMDBConnect::GetUnreadMsgCount()
|
{
|
if ( !m_bOpenDB )
|
return 0;
|
CString strSQL,strSQL2;
|
CDBRecord ARecordset;
|
int nRecordCount = 0;
|
int nValue = 0;
|
|
strSQL.Format(_T("SELECT COUNT(G_C1) FROM TN_STK_UNREADMSG"));
|
strSQL2.Format(_T("SELECT COUNT(G_C1) FROM TN_STK_CROWDMSG WHERE N_C7 <= 1 "));
|
try
|
{
|
|
ARecordset.Open( &m_AConnect,strSQL );
|
while ( S_OK == ARecordset.MoveNext() )
|
{
|
ARecordset.GetValue( 1, nValue );
|
nRecordCount += nValue;
|
break;
|
}
|
ARecordset.Close();
|
ARecordset.Open( &m_AConnect,strSQL2 );
|
while ( S_OK == ARecordset.MoveNext() )
|
{
|
ARecordset.GetValue( 1, nValue );
|
nRecordCount += nValue;
|
break;
|
}
|
}
|
catch( CDBSQliteException ex )
|
{
|
CString strError = ex.GetErrInfo();
|
CString strErrInfo;
|
|
strErrInfo = _T("GetUnreadMsgCount - ") + strError;
|
CMBAMDBFun::WriteDBErrToFile( strErrInfo );
|
return 0;
|
}
|
return nRecordCount;
|
}
|
BOOL CMBAMDBConnect::RemoveUnreadMsg(CString strMsgID)
|
{
|
//return true;
|
CString strSQL;
|
BOOL bReturn = true;
|
if ( !m_bOpenDB )
|
return FALSE;
|
strSQL.Format( _T("DELETE FROM TN_STK_UNREADMSG WHERE G_C1='%s'"), strMsgID);
|
try
|
{
|
bReturn = CDBSQLiteCommFun::RunSQL(strSQL, &m_AConnect);
|
}
|
catch ( CDBSQliteException ex )
|
{
|
CString strError = ex.GetErrInfo();
|
CString strErrInfo;
|
|
strErrInfo = _T("RemoveUnreadMsg - Msg- ") + strError;
|
CMBAMDBFun::WriteDBErrToFile( strErrInfo );
|
return false;
|
}
|
return true;
|
}
|
int CMBAMDBConnect::CheckMsgExist( LPCTSTR lpszMsgID )
|
{ // ʹÓÃÕâ¸öº¯Êý£¬¹ýÂËÌõ¼þÎÞЧ
|
if ( lpszMsgID == NULL )
|
return 0;
|
CDBRecord ARecordset;
|
CString strSQL;
|
int nCount = 0;
|
if ( !m_bOpenDB )
|
return 0;
|
strSQL.Format( _T("SELECT COUNT(G_C1) FROM TN_STK_MSG WHERE G_C1 = '%s'"), lpszMsgID);
|
try
|
{
|
ARecordset.Close( );
|
ARecordset.Open(&m_AConnect, strSQL );
|
while(S_OK == ARecordset.MoveNext())
|
{
|
ARecordset.GetValue(1,nCount );
|
break;
|
}
|
}
|
catch( CDBSQliteException ex )
|
{
|
CString strError;
|
|
strError = (LPCTSTR)ex.GetErrInfo( );
|
return 0;
|
}
|
return nCount;
|
}
|
|
BOOL CMBAMDBConnect::GetMsgFileInfo(CString strMsgID, CString strFileID, CString &strFileName,
|
CString &strFileSflag, __int64 &nFileSize )
|
{
|
strFileName = _T("");
|
strFileSflag = _T("");
|
nFileSize = 0;
|
if(strFileID.IsEmpty())
|
return FALSE;
|
//CSingleLock lock( &m_csConnectDB, true );
|
if ( !m_bOpenDB )
|
return FALSE;
|
CString strSQL, strTemp;
|
CDBRecord ARecordset;
|
BOOL bReturn = true;
|
|
strFileName = _T("");
|
strSQL.Format( _T("SELECT S_C2, S_C6, N_C3 FROM TN_STK_ATTACHMENT WHERE G_C5 ='%s' AND G_C1 ='%s'"), strFileID,strMsgID);
|
try
|
{
|
|
ARecordset.Open( &m_AConnect, strSQL );
|
if ( S_OK == ARecordset.MoveNext() )
|
{
|
ARecordset.GetValue( 1, strTemp, true );
|
strFileName = strTemp;
|
ARecordset.GetValue( 2, strTemp, true );
|
strFileSflag = strTemp;
|
nFileSize = 0;
|
ARecordset.GetValue( 3,nFileSize);
|
}
|
}
|
catch ( CDBSQliteException ex )
|
{
|
CString strError, strErrInfo;
|
|
strError = ex.GetErrInfo();
|
strErrInfo = _T("GetMsgFileInfo - ") + strError;
|
CMBAMDBFun::WriteDBErrToFile( strErrInfo );
|
|
return false;
|
}
|
|
return true;
|
}
|
|
BOOL CMBAMDBConnect::GetMsgFilesInfo( CString strMsgID,CStringArray &arAttachID/*, CString &strFileSflag*/)
|
{
|
arAttachID.RemoveAll();
|
//strFileSflag = _T("");
|
if(strMsgID.IsEmpty())
|
return FALSE;
|
//CSingleLock lock( &m_csConnectDB, true );
|
if ( !m_bOpenDB )
|
return FALSE;
|
CString strSQL, strTemp;
|
CDBRecord ARecordset;
|
BOOL bReturn = true;
|
|
strSQL.Format( _T("SELECT G_C5 FROM TN_STK_ATTACHMENT WHERE G_C1 ='%s'"), strMsgID);
|
try
|
{
|
|
ARecordset.Open( &m_AConnect ,strSQL);
|
while ( S_OK == ARecordset.MoveNext() )
|
{
|
ARecordset.GetValue( 1, strTemp, true );
|
arAttachID.Add((LPCTSTR)strTemp);
|
//ARecordset.GetValue( 2, strTemp, true );
|
//strFileSflag = (LPCTSTR)strTemp;
|
}
|
}
|
catch ( CDBSQliteException ex )
|
{
|
CString strError, strErrInfo;
|
|
strError = ex.GetErrInfo();
|
strErrInfo = _T("GetMsgFilesInfo - ") + strError;
|
CMBAMDBFun::WriteDBErrToFile( strErrInfo );
|
return false;
|
}
|
return true;
|
}
|
|
BOOL CMBAMDBConnect::GetMsgFilePath(CString strMsgID, CString strFileID, CString &strFilePath )
|
{
|
strFilePath = _T("");
|
if(strFileID.IsEmpty())
|
return FALSE;
|
// CSingleLock lock( &m_csConnectDB, true );
|
if ( !m_bOpenDB )
|
return FALSE;
|
CString strSQL, strTemp;
|
CDBRecord ARecordset;
|
BOOL bReturn = true;
|
|
strFilePath = _T("");
|
strSQL.Format( _T("SELECT S_C8 FROM TN_STK_ATTACHMENT WHERE G_C5 ='%s' AND G_C1 ='%s'"), strFileID,strMsgID);
|
try
|
{
|
ARecordset.Open( &m_AConnect,strSQL );
|
if ( S_OK == ARecordset.MoveNext() )
|
{
|
ARecordset.GetValue( 1, strTemp, true );
|
strFilePath = (LPCTSTR)strTemp;
|
}
|
}
|
catch ( CDBSQliteException ex )
|
{
|
CString strError, strErrInfo;
|
|
strError = ex.GetErrInfo();
|
strErrInfo = _T("GetMsgFilePath - ") + strError;
|
CMBAMDBFun::WriteDBErrToFile( strErrInfo );
|
|
return false;
|
}
|
|
return true;
|
}
|
|
//=========================================================
|
// Ö»ÄÜÊǸüÐÂÒ»Ìõ¼Ç¼,²»¿ÉÄÜÊǶàÌõµÄ¼Ç¼
|
//=========================================================
|
BOOL CMBAMDBConnect::SetMsgFilePath(CString strMsgID, CString strFileID, CString strFilePath )
|
{
|
if(strFileID.IsEmpty())
|
return FALSE;
|
//CSingleLock lock( &m_csConnectDB, true );
|
if ( !m_bOpenDB )
|
return FALSE;
|
CString strSQL;
|
BOOL bReturn = true;
|
|
strSQL.Format( _T("UPDATE TN_STK_ATTACHMENT SET S_C8 = '%s' WHERE G_C5 = '%s' AND G_C1 ='%s'"), CMBAMDBFun::GetDBReplaceStr( strFilePath ), strFileID,strMsgID);
|
|
try
|
{
|
|
bReturn = CDBSQLiteCommFun::RunSQL(strSQL, &m_AConnect);
|
}
|
catch ( CDBSQliteException ex )
|
{
|
CString strError = ex.GetErrInfo();
|
CString strErrInfo;
|
|
strErrInfo = _T("SetMsgFilePath - ") + strError;
|
CMBAMDBFun::WriteDBErrToFile( strErrInfo );
|
return false;
|
}
|
|
return true;
|
}
|
BOOL CMBAMDBConnect::ListUnReadMsg( CObList &listMsg )
|
{
|
CString strSQL, strValue;
|
CDBRecord ARecordset;
|
CMsgItem *pMsg;
|
if ( !m_bOpenDB )
|
return FALSE;
|
strSQL.Format( _T("SELECT G_C1,S_C2 ,S_C3,S_C4 ,T_C5 FROM TN_STK_UNREADMSG "));
|
try
|
{
|
ARecordset.Open( &m_AConnect,strSQL );
|
while ( S_OK == ARecordset.MoveNext() )
|
{
|
pMsg = new CMsgItem;
|
ARecordset.GetValue( 1, strValue, true );
|
pMsg->m_strID = strValue;
|
ARecordset.GetValue( 2, strValue, true );
|
pMsg->m_strSender = strValue;
|
ARecordset.GetValue( 3, strValue, true );
|
pMsg->m_strSenderName = strValue;
|
ARecordset.GetValue( 4, strValue, true );
|
pMsg->m_strSubject = strValue;
|
ARecordset.GetValue( 5, pMsg->m_tmDate );
|
listMsg.AddTail( (CObject*)pMsg );
|
}
|
}
|
catch( CDBSQliteException ex )
|
{
|
CString strError = ex.GetErrInfo();
|
CString strErrInfo;
|
|
strErrInfo = _T("ListUnReadMsg - ") + strError;
|
CMBAMDBFun::WriteDBErrToFile( strErrInfo );
|
return FALSE;
|
}
|
return TRUE;
|
}
|
BOOL CMBAMDBConnect::DeletCrowdMsg( CString strMsgID,CString strGroupID)
|
{
|
CDBRecord ARecordset;
|
CString strSQL;
|
BOOL bReturn = true;
|
int nCount = 0;
|
if ( !m_bOpenDB )
|
return FALSE;
|
if(strMsgID.IsEmpty() || strGroupID.IsEmpty() )
|
return FALSE;
|
try
|
{
|
strSQL.Format( _T("DELETE FROM TN_STK_CROWDMSG WHERE G_C1='%s' AND G_C2='%s'"),strMsgID,strGroupID);
|
bReturn = CDBSQLiteCommFun::RunSQL(strSQL, &m_AConnect);
|
}
|
catch( CDBSQliteException ex )
|
{
|
CString strError = ex.GetErrInfo();
|
CString strErrInfo;
|
|
strErrInfo = _T("DeletCrowdMsg - ") + strError;
|
CMBAMDBFun::WriteDBErrToFile( strErrInfo );
|
return FALSE;
|
}
|
return TRUE;
|
}
|
BOOL CMBAMDBConnect::DeleteGroupFileInfo( CString strGroupID, CString strShareID)
|
{
|
CDBRecord ARecordset;
|
CString strSQL;
|
BOOL bReturn = true;
|
int nCount = 0;
|
if ( !m_bOpenDB )
|
return FALSE;
|
if(strShareID.IsEmpty())
|
return FALSE;
|
try
|
{
|
strSQL.Format( _T("DELETE FROM TN_STK_GROUPFILE WHERE G_C1='%s' AND G_C2='%s'"),strGroupID,strShareID);
|
bReturn = CDBSQLiteCommFun::RunSQL(strSQL, &m_AConnect);
|
}
|
catch( CDBSQliteException ex )
|
{
|
CString strError = ex.GetErrInfo();
|
CString strErrInfo;
|
|
strErrInfo = _T("DeleteGroupFileInfo - ") + strError;
|
CMBAMDBFun::WriteDBErrToFile( strErrInfo );
|
return FALSE;
|
}
|
return TRUE;
|
}
|
BOOL CMBAMDBConnect::UpdateGroupFileInfo( CString strGroupID, CString strShareID, CString strFilePath, CString strFileName, __int64 nFileSize )
|
{
|
CDBRecord ARecordset;
|
CString strSQL;
|
BOOL bReturn = true;
|
int nCount = 0;
|
if ( !m_bOpenDB )
|
return FALSE;
|
if(strShareID.IsEmpty())
|
return FALSE;
|
strSQL.Format( _T("SELECT COUNT(*) FROM TN_STK_GROUPFILE WHERE G_C1='%s' AND G_C2='%s'"),strGroupID,strShareID);
|
try
|
{
|
ARecordset.Open( &m_AConnect,strSQL );
|
while ( S_OK == ARecordset.MoveNext() )
|
{
|
ARecordset.GetValue( 1, nCount );
|
break;
|
}
|
if(nCount > 0)
|
{
|
strSQL.Format( _T("UPDATE TN_STK_GROUPFILE SET S_C3='%s' WHERE G_C1='%s' AND G_C2='%s'"),strFilePath,strGroupID,strShareID);
|
}
|
else
|
{
|
if(strFileName.IsEmpty())
|
strFileName = CBaseCommFun::GetFileName( strFilePath);
|
strSQL.Format( _T("INSERT INTO TN_STK_GROUPFILE (G_C1,G_C2,S_C3,S_C4,N_C5) VALUES('%s', '%s','%s','%s',%I64d)"),strGroupID,strShareID,strFilePath,strFileName,nFileSize);
|
}
|
bReturn = CDBSQLiteCommFun::RunSQL(strSQL, &m_AConnect);
|
}
|
catch( CDBSQliteException ex )
|
{
|
CString strError = ex.GetErrInfo();
|
CString strErrInfo;
|
|
strErrInfo = _T("UpdateGroupFileInfo - ") + strError;
|
CMBAMDBFun::WriteDBErrToFile( strErrInfo );
|
return FALSE;
|
}
|
return TRUE;
|
}
|
BOOL CMBAMDBConnect::AddGroupFileInfo( CString strGroupID, CString strShareID, CString strFileName, __int64 nFileSize )
|
{
|
CDBRecord ARecordset;
|
CString strSQL;
|
BOOL bReturn = true;
|
int nCount = 0;
|
if ( !m_bOpenDB )
|
return FALSE;
|
if(strShareID.IsEmpty())
|
return FALSE;
|
strSQL.Format( _T("SELECT COUNT(*) FROM TN_STK_GROUPFILE WHERE G_C1='%s' AND G_C2='%s'"),strGroupID,strShareID);
|
try
|
{
|
ARecordset.Open( &m_AConnect,strSQL );
|
while ( S_OK == ARecordset.MoveNext() )
|
{
|
ARecordset.GetValue( 1, nCount );
|
break;
|
}
|
if(nCount > 0)
|
{
|
strSQL.Format( _T("UPDATE TN_STK_GROUPFILE SET S_C4='%s',N_C5=%I64d WHERE G_C1='%s' AND G_C2='%s'"),strFileName,nFileSize,strGroupID,strShareID);
|
}
|
else
|
{
|
strSQL.Format( _T("INSERT INTO TN_STK_GROUPFILE (G_C1,G_C2,S_C4,N_C5) VALUES('%s', '%s','%s',%I64d)"),strGroupID,strShareID,strFileName,nFileSize);
|
}
|
bReturn = CDBSQLiteCommFun::RunSQL(strSQL, &m_AConnect);
|
}
|
catch( CDBSQliteException ex )
|
{
|
CString strError = ex.GetErrInfo();
|
CString strErrInfo;
|
|
strErrInfo = _T("AddGroupFileInfo - ") + strError;
|
CMBAMDBFun::WriteDBErrToFile( strErrInfo );
|
return FALSE;
|
}
|
return TRUE;
|
}
|
BOOL CMBAMDBConnect::LoadGroupFilePath( CString strGroupID, CString strShareID, CString &strFilePath )
|
{
|
CString strSQL, strValue;
|
CDBRecord ARecordset;
|
|
strFilePath = _T("");
|
if ( !m_bOpenDB )
|
return FALSE;
|
if(strShareID.IsEmpty())
|
return FALSE;
|
strSQL.Format( _T("SELECT S_C3 FROM TN_STK_GROUPFILE WHERE G_C1='%s' AND G_C2='%s'"),strGroupID,strShareID);
|
try
|
{
|
ARecordset.Open( &m_AConnect,strSQL );
|
while ( S_OK == ARecordset.MoveNext() )
|
{
|
ARecordset.GetValue( 1, strValue, true );
|
strFilePath = strValue;
|
break;
|
}
|
}
|
catch( CDBSQliteException ex )
|
{
|
CString strError = ex.GetErrInfo();
|
CString strErrInfo;
|
|
strErrInfo = _T("LoadGroupFilePath - ") + strError;
|
CMBAMDBFun::WriteDBErrToFile( strErrInfo );
|
return FALSE;
|
}
|
return TRUE;
|
}
|
BOOL CMBAMDBConnect::LoadGroupFileInfo( CString strGroupID, CString strShareID, CString &strFileName, __int64 &nFileSize )
|
{
|
CString strSQL, strValue;
|
CDBRecord ARecordset;
|
|
strFileName = _T("");
|
nFileSize = 0;
|
if ( !m_bOpenDB )
|
return FALSE;
|
if(strShareID.IsEmpty())
|
return FALSE;
|
strSQL.Format( _T("SELECT S_C4,N_C5 FROM TN_STK_GROUPFILE WHERE G_C1='%s' AND G_C2='%s'"),strGroupID,strShareID);
|
try
|
{
|
ARecordset.Open( &m_AConnect,strSQL );
|
while ( S_OK == ARecordset.MoveNext() )
|
{
|
ARecordset.GetValue( 1, strValue, true );
|
strFileName = strValue;
|
ARecordset.GetValue(2, nFileSize );
|
break;
|
}
|
}
|
catch( CDBSQliteException ex )
|
{
|
CString strError = ex.GetErrInfo();
|
CString strErrInfo;
|
|
strErrInfo = _T("LoadGroupFileInfo - ") + strError;
|
CMBAMDBFun::WriteDBErrToFile( strErrInfo );
|
return FALSE;
|
}
|
return TRUE;
|
}
|
BOOL CMBAMDBConnect::LoadGroupFileInfo2( CString strGroupID, CString strShareID, CString &strFileName, CString &strFilePath, __int64 &nFileSize )
|
{
|
CString strSQL, strValue;
|
CDBRecord ARecordset;
|
|
strFileName = _T("");
|
strFilePath = _T("");
|
nFileSize = 0;
|
if ( !m_bOpenDB )
|
return FALSE;
|
if(strShareID.IsEmpty())
|
return FALSE;
|
strSQL.Format( _T("SELECT S_C4,S_C3,N_C5 FROM TN_STK_GROUPFILE WHERE G_C1='%s' AND G_C2='%s'"),strGroupID,strShareID);
|
try
|
{
|
ARecordset.Open( &m_AConnect,strSQL );
|
while ( S_OK == ARecordset.MoveNext() )
|
{
|
ARecordset.GetValue( 1, strValue, true );
|
strFileName = strValue;
|
ARecordset.GetValue( 2, strValue, true );
|
strFilePath = strValue;
|
ARecordset.GetValue(3, nFileSize );
|
break;
|
}
|
}
|
catch( CDBSQliteException ex )
|
{
|
CString strError = ex.GetErrInfo();
|
CString strErrInfo;
|
|
strErrInfo = _T("LoadGroupFileInfo2 - ") + strError;
|
CMBAMDBFun::WriteDBErrToFile( strErrInfo );
|
return FALSE;
|
}
|
return TRUE;
|
}
|
BOOL CMBAMDBConnect::ListMsg(CString strDate,CString strSender,long nLimitCount,CArrayShortMsg &arUserMsg,BOOL bTimeAsc)
|
{
|
CString strSQL, strValue;
|
CDBRecord ARecordset;
|
stSTKShortMsg itemMsg;
|
arUserMsg.RemoveAll();
|
if ( !m_bOpenDB )
|
return FALSE;
|
CString strLimitSQL = _T("");
|
if(nLimitCount > 0)
|
strLimitSQL.Format( _T("limit 0,%d"), nLimitCount);
|
if(bTimeAsc)
|
strSQL.Format( _T("SELECT ST.G_C1,ST.S_C3 FROM(SELECT M1.G_C1,M1.S_C3,M1.T_C6 FROM(SELECT G_C1,S_C3,T_C6 FROM TN_STK_MSG WHERE S_C4='%s' AND T_C6<='%s' ORDER BY T_C6 DESC limit 0,%d)M1 UNION SELECT M2.G_C1,M2.S_C3,M2.T_C6 FROM(SELECT G_C1,S_C3,T_C6 FROM TN_STK_MSG WHERE S_C4='%s' AND T_C6>'%s' ORDER BY T_C6 ASC %s)M2)ST ORDER BY ST.T_C6 ASC"),strSender,strDate,nLimitCount,strSender,strDate,strLimitSQL);
|
else
|
strSQL.Format( _T("SELECT ST.G_C1,ST.S_C3 FROM(SELECT M1.G_C1,M1.S_C3,M1.T_C6 FROM(SELECT G_C1,S_C3,T_C6 FROM TN_STK_MSG WHERE S_C4='%s' AND T_C6<='%s' ORDER BY T_C6 DESC limit 0,%d)M1 UNION SELECT M2.G_C1,M2.S_C3,M2.T_C6 FROM(SELECT G_C1,S_C3,T_C6 FROM TN_STK_MSG WHERE S_C4='%s' AND T_C6>'%s' ORDER BY T_C6 ASC %s)M2)ST ORDER BY ST.T_C6 DESC"),strSender,strDate,nLimitCount,strSender,strDate,strLimitSQL);
|
try
|
{
|
ARecordset.Open( &m_AConnect,strSQL );
|
while ( S_OK == ARecordset.MoveNext() )
|
{
|
ARecordset.GetValue( 1, strValue, true );
|
itemMsg.strMsgID = strValue;
|
ARecordset.GetValue( 2, strValue, true );
|
itemMsg.strSubject = strValue;
|
arUserMsg.Add(itemMsg);
|
}
|
}
|
catch( CDBSQliteException ex )
|
{
|
CString strError = ex.GetErrInfo();
|
CString strErrInfo;
|
|
strErrInfo = _T("ListMsg - ") + strError;
|
CMBAMDBFun::WriteDBErrToFile( strErrInfo );
|
return FALSE;
|
}
|
return TRUE;
|
}
|
|
BOOL CMBAMDBConnect::ListMsg2(CString strDate,CString strExtType,long nLimitCount,CArrayShortMsg &arUserMsg,BOOL bTimeAsc)
|
{
|
CString strSQL, strValue;
|
CDBRecord ARecordset;
|
stSTKShortMsg itemMsg;
|
arUserMsg.RemoveAll();
|
if ( !m_bOpenDB )
|
return FALSE;
|
CString strLimitSQL = _T("");
|
if(nLimitCount > 0)
|
strLimitSQL.Format( _T("limit 0,%d"), nLimitCount);
|
if(bTimeAsc)
|
strSQL.Format( _T("SELECT ST.G_C1,ST.S_C3 FROM(SELECT M1.G_C1,M1.S_C3,M1.T_C6 FROM(SELECT G_C1,S_C3,T_C6 FROM TN_STK_MSG WHERE S_C10='%s' AND T_C6<='%s' ORDER BY T_C6 DESC limit 0,%d)M1 UNION SELECT M2.G_C1,M2.S_C3,M2.T_C6 FROM(SELECT G_C1,S_C3,T_C6 FROM TN_STK_MSG WHERE S_C10='%s' AND T_C6>'%s' ORDER BY T_C6 ASC %s)M2)ST ORDER BY ST.T_C6 ASC"),strExtType,strDate,nLimitCount,strExtType,strDate,strLimitSQL);
|
else
|
strSQL.Format( _T("SELECT ST.G_C1,ST.S_C3 FROM(SELECT M1.G_C1,M1.S_C3,M1.T_C6 FROM(SELECT G_C1,S_C3,T_C6 FROM TN_STK_MSG WHERE S_C10='%s' AND T_C6<='%s' ORDER BY T_C6 DESC limit 0,%d)M1 UNION SELECT M2.G_C1,M2.S_C3,M2.T_C6 FROM(SELECT G_C1,S_C3,T_C6 FROM TN_STK_MSG WHERE S_C10='%s' AND T_C6>'%s' ORDER BY T_C6 ASC %s)M2)ST ORDER BY ST.T_C6 DESC"),strExtType,strDate,nLimitCount,strExtType,strDate,strLimitSQL);
|
try
|
{
|
ARecordset.Open( &m_AConnect,strSQL );
|
while ( S_OK == ARecordset.MoveNext() )
|
{
|
ARecordset.GetValue( 1, strValue, true );
|
itemMsg.strMsgID = strValue;
|
ARecordset.GetValue( 2, strValue, true );
|
itemMsg.strSubject = strValue;
|
arUserMsg.Add(itemMsg);
|
}
|
}
|
catch( CDBSQliteException ex )
|
{
|
CString strError = ex.GetErrInfo();
|
CString strErrInfo;
|
|
strErrInfo = _T("ListMsg2 - ") + strError;
|
CMBAMDBFun::WriteDBErrToFile( strErrInfo );
|
return FALSE;
|
}
|
return TRUE;
|
}
|
BOOL CMBAMDBConnect::ClearReceiveBoxMsg(CString strStartDate,CString strEndDate, CString strUser,CString strUserName,CString strContentKey, int nAttach)
|
{
|
CDBRecord ARecordset;
|
BOOL bReturn = FALSE;
|
if ( !m_bOpenDB )
|
return FALSE;
|
CString strMsgSQL;
|
CString strMsgSQL2;
|
CString strMsgSQL3;
|
CString strMsgSQL4;
|
CString strMsgSQL5;
|
CString strSQLWhere = _T("");
|
CString strValue;
|
CString strSQLTemp;
|
CHighTime tmHigh;
|
SYSTEMTIME tmSystem;
|
|
strUser.MakeLower();
|
strSQLWhere.Format(_T(" N_C8=%d "), MANAGER_FOLDER_BOX_IN );
|
if( !strContentKey.IsEmpty())
|
{
|
strSQLTemp.Format( _T(" AND (S_C3 LIKE '%%%s%%' OR S_C25 LIKE '%%%s%%') "), strContentKey,strContentKey );
|
strSQLWhere += strSQLTemp;
|
}
|
// Set Filter
|
if ( !strStartDate.IsEmpty() && tmHigh.ParseDateTime( strStartDate ) )
|
{
|
tmHigh.GetAsSystemTime( tmSystem );
|
if ( tmSystem.wSecond < 0 )
|
tmSystem.wSecond = 0;
|
strValue.Format(_T("%04d-%02d-%02d %02d:%02d:%02d"), tmSystem.wYear, tmSystem.wMonth, tmSystem.wDay,
|
tmSystem.wHour, tmSystem.wMinute, tmSystem.wSecond );
|
strSQLTemp.Format(_T(" AND T_C6 >='%s'"),strValue);
|
strSQLWhere += strSQLTemp;
|
}
|
if ( !strEndDate.IsEmpty() && tmHigh.ParseDateTime( strEndDate ) )
|
{
|
tmHigh.GetAsSystemTime( tmSystem );
|
if ( tmSystem.wSecond < 0 )
|
tmSystem.wSecond = 0;
|
strValue.Format(_T("%04d-%02d-%02d %02d:%02d:%02d"), tmSystem.wYear, tmSystem.wMonth, tmSystem.wDay,
|
tmSystem.wHour, tmSystem.wMinute, tmSystem.wSecond );
|
strSQLTemp.Format(_T(" AND T_C6 <='%s'"),strValue);
|
strSQLWhere += strSQLTemp;
|
}
|
if(nAttach > 0)
|
{
|
strSQLTemp.Format( _T(" AND N_C12>0") );
|
strSQLWhere += strSQLTemp;
|
}
|
else if(nAttach == 0)
|
{
|
strSQLTemp.Format( _T(" AND N_C12=0") );
|
strSQLWhere += strSQLTemp;
|
}
|
strSQLTemp.Format( _T(" AND S_C10='' ") );
|
strSQLWhere += strSQLTemp;
|
if( !strUser.IsEmpty())
|
{
|
if(strUserName.IsEmpty() )
|
{
|
strSQLTemp.Format( _T("AND (S_C4 LIKE '%s%%' OR S_C5 LIKE '%s%%') "), strUser,strUser );
|
}
|
else
|
strSQLTemp.Format( _T("AND S_C4='%s' "), strUser );
|
strSQLWhere += strSQLTemp;
|
}
|
strMsgSQL.Format( _T("DELETE FROM TN_STK_MSG WHERE %s"),strSQLWhere );
|
strMsgSQL2.Format( _T("DELETE FROM TN_STK_ATTACHMENT WHERE G_C1 IN ( SELECT G_C1 FROM TN_STK_MSG WHERE %s) "), strSQLWhere );
|
strMsgSQL3.Format( _T("DELETE FROM TN_STK_MSGOWNER WHERE G_C1 IN ( SELECT G_C1 FROM TN_STK_MSG WHERE %s) "), strSQLWhere );
|
strMsgSQL4.Format( _T("DELETE FROM TN_STK_MSGPROPERTY WHERE G_C1 IN ( SELECT G_C1 FROM TN_STK_MSG WHERE %s) "), strSQLWhere );
|
strMsgSQL5.Format( _T("DELETE FROM TN_STK_UNREADMSG WHERE G_C1 IN ( SELECT G_C1 FROM TN_STK_MSG WHERE %s ) "), strSQLWhere );
|
try
|
{
|
m_AConnect.StartTransaction(); // Æô¶¯ÊÂÎñ
|
CDBSQLiteCommFun::RunSQL(strMsgSQL2, &m_AConnect);
|
CDBSQLiteCommFun::RunSQL(strMsgSQL3, &m_AConnect);
|
CDBSQLiteCommFun::RunSQL(strMsgSQL4, &m_AConnect);
|
CDBSQLiteCommFun::RunSQL(strMsgSQL5, &m_AConnect);
|
bReturn = CDBSQLiteCommFun::RunSQL(strMsgSQL, &m_AConnect);
|
m_AConnect.Commit(); // Ìá½»ÊÂÎñ
|
}
|
catch( CDBSQliteException ex )
|
{
|
CString strError = ex.GetErrInfo();
|
CString strErrInfo;
|
|
strErrInfo = _T("ClearReceiveBoxMsg - ") + strError;
|
CMBAMDBFun::WriteDBErrToFile( strErrInfo );
|
return FALSE;
|
}
|
return TRUE;
|
}
|
BOOL CMBAMDBConnect::ClearSendBoxMsg(CString strStartDate,CString strEndDate, CString strUser,CString strUserName,CString strContentKey, int nAttach)
|
{
|
CDBRecord ARecordset;
|
BOOL bReturn = FALSE;
|
if ( !m_bOpenDB )
|
return FALSE;
|
CString strMsgSQL;
|
CString strMsgSQL2;
|
CString strMsgSQL3;
|
CString strMsgSQL4;
|
CString strSelectSQL;
|
CString strSQLWhere = _T("");
|
CString strValue;
|
CString strSQLTemp;
|
CHighTime tmHigh;
|
SYSTEMTIME tmSystem;
|
|
strUser.MakeLower();
|
strSQLWhere.Format(_T(" N_C8=%d "), MANAGER_FOLDER_BOX_OUT );
|
if( !strContentKey.IsEmpty())
|
{
|
strSQLTemp.Format( _T(" AND (S_C3 LIKE '%%%s%%' OR S_C25 LIKE '%%%s%%') "), strContentKey,strContentKey );
|
strSQLWhere += strSQLTemp;
|
}
|
// Set Filter
|
if ( !strStartDate.IsEmpty() && tmHigh.ParseDateTime( strStartDate ) )
|
{
|
tmHigh.GetAsSystemTime( tmSystem );
|
if ( tmSystem.wSecond < 0 )
|
tmSystem.wSecond = 0;
|
strValue.Format(_T("%04d-%02d-%02d %02d:%02d:%02d"), tmSystem.wYear, tmSystem.wMonth, tmSystem.wDay,
|
tmSystem.wHour, tmSystem.wMinute, tmSystem.wSecond );
|
strSQLTemp.Format(_T(" AND T_C6 >='%s'"),strValue);
|
strSQLWhere += strSQLTemp;
|
}
|
if ( !strEndDate.IsEmpty() && tmHigh.ParseDateTime( strEndDate ) )
|
{
|
tmHigh.GetAsSystemTime( tmSystem );
|
if ( tmSystem.wSecond < 0 )
|
tmSystem.wSecond = 0;
|
strValue.Format(_T("%04d-%02d-%02d %02d:%02d:%02d"), tmSystem.wYear, tmSystem.wMonth, tmSystem.wDay,
|
tmSystem.wHour, tmSystem.wMinute, tmSystem.wSecond );
|
strSQLTemp.Format(_T(" AND T_C6 <='%s'"),strValue);
|
strSQLWhere += strSQLTemp;
|
}
|
if(nAttach > 0)
|
{
|
strSQLTemp.Format( _T(" AND N_C12>0") );
|
strSQLWhere += strSQLTemp;
|
}
|
else if(nAttach == 0)
|
{
|
strSQLTemp.Format( _T(" AND N_C12=0") );
|
strSQLWhere += strSQLTemp;
|
}
|
strSQLTemp.Format( _T(" AND S_C10='' ") );
|
strSQLWhere += strSQLTemp;
|
if( !strUser.IsEmpty())
|
{
|
if(strUserName.IsEmpty() )
|
{
|
strSelectSQL.Format( _T("SELECT A.G_C1 ")
|
_T("FROM TN_STK_MSG A ")
|
_T("INNER JOIN (")
|
_T("SELECT AA.G_C1 ")
|
_T("FROM ( ")
|
_T("SELECT G_C1, C_C17,S_C18,S_C19 ")
|
_T("FROM TN_STK_MSG Where %s ")
|
_T(") AA ")
|
_T("LEFT JOIN TN_STK_MSGOWNER BB ")
|
_T("ON AA.G_C1 = BB.G_C1 ")
|
_T("WHERE (AA.C_C17='0' AND (AA.S_C18 LIKE '%s%%' OR AA.S_C19 LIKE '%s%%') ) ")
|
_T("OR ( AA.C_C17='1' AND (BB.S_C2 LIKE '%s%%' OR BB.S_C3 LIKE '%s%%') ) ")
|
_T("GROUP BY AA.G_C1 ")
|
_T(") B ")
|
_T("ON A.G_C1 = B.G_C1 "),
|
strSQLWhere, strUser,strUser, strUser,strUser );
|
}
|
else
|
{
|
strSelectSQL.Format( _T("SELECT A.G_C1 ")
|
_T("FROM TN_STK_MSG A ")
|
_T("INNER JOIN (")
|
_T("SELECT AA.G_C1 ")
|
_T("FROM ( ")
|
_T("SELECT G_C1, C_C17,S_C18 ")
|
_T("FROM TN_STK_MSG Where %s ")
|
_T(") AA ")
|
_T("LEFT JOIN TN_STK_MSGOWNER BB ")
|
_T("ON AA.G_C1 = BB.G_C1 ")
|
_T("WHERE (AA.C_C17='0' AND AA.S_C18='%s' ) ")
|
_T("OR ( AA.C_C17='1' AND BB.S_C2='%s' ) ")
|
_T("GROUP BY AA.G_C1 ")
|
_T(") B ")
|
_T("ON A.G_C1 = B.G_C1 "),
|
strSQLWhere, strUser, strUser );
|
}
|
}
|
else
|
{
|
strSelectSQL.Format( _T("SELECT G_C1 FROM TN_STK_MSG Where %s "),strSQLWhere );
|
}
|
strMsgSQL.Format( _T("DELETE FROM TN_STK_MSG WHERE G_C1 IN ( %s)"),strSelectSQL );
|
strMsgSQL2.Format( _T("DELETE FROM TN_STK_ATTACHMENT WHERE G_C1 IN ( %s) "), strSelectSQL );
|
strMsgSQL3.Format( _T("DELETE FROM TN_STK_MSGOWNER WHERE G_C1 IN ( %s) "), strSelectSQL );
|
strMsgSQL4.Format( _T("DELETE FROM TN_STK_MSGPROPERTY WHERE G_C1 IN ( %s) "), strSelectSQL );
|
try
|
{
|
m_AConnect.StartTransaction(); // Æô¶¯ÊÂÎñ
|
CDBSQLiteCommFun::RunSQL(strMsgSQL2, &m_AConnect);
|
CDBSQLiteCommFun::RunSQL(strMsgSQL3, &m_AConnect);
|
CDBSQLiteCommFun::RunSQL(strMsgSQL4, &m_AConnect);
|
bReturn = CDBSQLiteCommFun::RunSQL(strMsgSQL, &m_AConnect);
|
m_AConnect.Commit(); // Ìá½»ÊÂÎñ
|
}
|
catch( CDBSQliteException ex )
|
{
|
CString strError = ex.GetErrInfo();
|
CString strErrInfo;
|
|
strErrInfo = _T("ClearSendBoxMsg - ") + strError;
|
CMBAMDBFun::WriteDBErrToFile( strErrInfo );
|
return FALSE;
|
}
|
return TRUE;
|
}
|
BOOL CMBAMDBConnect::ClearSysBoxMsg(CString strStartDate,CString strEndDate)
|
{
|
CDBRecord ARecordset;
|
BOOL bReturn = FALSE;
|
if ( !m_bOpenDB )
|
return FALSE;
|
CString strMsgSQL;
|
CString strMsgSQL2;
|
CString strMsgSQL3;
|
CString strMsgSQL4;
|
CString strSQLWhere = _T("");
|
CString strValue;
|
CString strSubSQL;
|
CHighTime tmHigh;
|
SYSTEMTIME tmSystem;
|
// Set Filter
|
strSQLWhere.Format( _T("N_C7=%d OR N_C7=%d"), AM_MSGTYPE_BROADCAST ,AM_MSGTYPE_GUNGHO );
|
if ( !strStartDate.IsEmpty() && tmHigh.ParseDateTime( strStartDate ) )
|
{
|
tmHigh.GetAsSystemTime( tmSystem );
|
if ( tmSystem.wSecond < 0 )
|
tmSystem.wSecond = 0;
|
strValue.Format(_T("%04d-%02d-%02d %02d:%02d:%02d"), tmSystem.wYear, tmSystem.wMonth, tmSystem.wDay,
|
tmSystem.wHour, tmSystem.wMinute, tmSystem.wSecond );
|
strSubSQL.Format(_T(" AND T_C6 >='%s'"),strValue);
|
strSQLWhere += strSubSQL;
|
}
|
if ( !strEndDate.IsEmpty() && tmHigh.ParseDateTime( strEndDate ) )
|
{
|
tmHigh.GetAsSystemTime( tmSystem );
|
if ( tmSystem.wSecond < 0 )
|
tmSystem.wSecond = 0;
|
strValue.Format(_T("%04d-%02d-%02d %02d:%02d:%02d"), tmSystem.wYear, tmSystem.wMonth, tmSystem.wDay,
|
tmSystem.wHour, tmSystem.wMinute, tmSystem.wSecond );
|
strSubSQL.Format(_T(" AND T_C6 <='%s'"),strValue);
|
strSQLWhere += strSubSQL;
|
}
|
strMsgSQL.Format( _T("DELETE FROM TN_STK_MSG WHERE %s"), strSQLWhere );
|
strMsgSQL2.Format( _T("DELETE FROM TN_STK_ATTACHMENT WHERE G_C1 IN ( SELECT G_C1 FROM TN_STK_MSG WHERE %s) "),strSQLWhere );
|
strMsgSQL3.Format( _T("DELETE FROM TN_STK_MSGOWNER WHERE G_C1 IN ( SELECT G_C1 FROM TN_STK_MSG WHERE %s) "), strSQLWhere);
|
strMsgSQL4.Format( _T("DELETE FROM TN_STK_MSGPROPERTY WHERE G_C1 IN ( SELECT G_C1 FROM TN_STK_MSG WHERE %s) "), strSQLWhere );
|
try
|
{
|
m_AConnect.StartTransaction(); // Æô¶¯ÊÂÎñ
|
CDBSQLiteCommFun::RunSQL(strMsgSQL2, &m_AConnect);
|
CDBSQLiteCommFun::RunSQL(strMsgSQL3, &m_AConnect);
|
CDBSQLiteCommFun::RunSQL(strMsgSQL4, &m_AConnect);
|
bReturn = CDBSQLiteCommFun::RunSQL(strMsgSQL, &m_AConnect);
|
m_AConnect.Commit(); // Ìá½»ÊÂÎñ
|
}
|
catch( CDBSQliteException ex )
|
{
|
CString strError = ex.GetErrInfo();
|
CString strErrInfo;
|
|
strErrInfo = _T("ClearSysBoxMsg - ") + strError;
|
CMBAMDBFun::WriteDBErrToFile( strErrInfo );
|
return FALSE;
|
}
|
return TRUE;
|
}
|
BOOL CMBAMDBConnect::ClearFavBoxMsg(CString strStartDate,CString strEndDate, CString strContentKey, int nFavFolder)
|
{
|
CDBRecord ARecordset;
|
BOOL bReturn = FALSE;
|
if ( !m_bOpenDB )
|
return FALSE;
|
CString strMsgSQL;
|
CString strMsgSQL2;
|
CString strMsgSQL3;
|
CString strMsgSQL4;
|
CString strSQLWhere = _T("");
|
CString strValue;
|
CString strSQLTemp;
|
CHighTime tmHigh;
|
SYSTEMTIME tmSystem;
|
// Set Filter
|
strSQLWhere.Format(_T("N_C8=%d "), nFavFolder );
|
if( !strContentKey.IsEmpty())
|
{
|
strSQLTemp.Format( _T(" AND (S_C3 LIKE '%%%s%%' OR S_C25 LIKE '%%%s%%') "), strContentKey ,strContentKey );
|
strSQLWhere += strSQLTemp;
|
}
|
if ( !strStartDate.IsEmpty() && tmHigh.ParseDateTime( strStartDate ) )
|
{
|
tmHigh.GetAsSystemTime( tmSystem );
|
if ( tmSystem.wSecond < 0 )
|
tmSystem.wSecond = 0;
|
strValue.Format(_T("%04d-%02d-%02d %02d:%02d:%02d"), tmSystem.wYear, tmSystem.wMonth, tmSystem.wDay,
|
tmSystem.wHour, tmSystem.wMinute, tmSystem.wSecond );
|
strSQLTemp.Format(_T(" AND T_C6 >='%s'"),strValue);
|
strSQLWhere += strSQLTemp;
|
}
|
if ( !strEndDate.IsEmpty() && tmHigh.ParseDateTime( strEndDate ) )
|
{
|
tmHigh.GetAsSystemTime( tmSystem );
|
if ( tmSystem.wSecond < 0 )
|
tmSystem.wSecond = 0;
|
strValue.Format(_T("%04d-%02d-%02d %02d:%02d:%02d"), tmSystem.wYear, tmSystem.wMonth, tmSystem.wDay,
|
tmSystem.wHour, tmSystem.wMinute, tmSystem.wSecond );
|
strSQLTemp.Format(_T(" AND T_C6 <='%s'"),strValue);
|
strSQLWhere += strSQLTemp;
|
}
|
strSQLTemp.Format( _T(" AND S_C10='' ") );
|
strSQLWhere += strSQLTemp;
|
strMsgSQL.Format( _T("DELETE FROM TN_STK_MSG WHERE %s"), strSQLWhere );
|
strMsgSQL2.Format( _T("DELETE FROM TN_STK_ATTACHMENT WHERE G_C1 IN ( SELECT G_C1 FROM TN_STK_MSG WHERE %s) "),strSQLWhere );
|
strMsgSQL3.Format( _T("DELETE FROM TN_STK_MSGOWNER WHERE G_C1 IN ( SELECT G_C1 FROM TN_STK_MSG WHERE %s) "), strSQLWhere);
|
strMsgSQL4.Format( _T("DELETE FROM TN_STK_MSGPROPERTY WHERE G_C1 IN ( SELECT G_C1 FROM TN_STK_MSG WHERE %s) "), strSQLWhere );
|
try
|
{
|
m_AConnect.StartTransaction(); // Æô¶¯ÊÂÎñ
|
CDBSQLiteCommFun::RunSQL(strMsgSQL2, &m_AConnect);
|
CDBSQLiteCommFun::RunSQL(strMsgSQL3, &m_AConnect);
|
CDBSQLiteCommFun::RunSQL(strMsgSQL4, &m_AConnect);
|
bReturn = CDBSQLiteCommFun::RunSQL(strMsgSQL, &m_AConnect);
|
m_AConnect.Commit(); // Ìá½»ÊÂÎñ
|
}
|
catch( CDBSQliteException ex )
|
{
|
CString strError = ex.GetErrInfo();
|
CString strErrInfo;
|
|
strErrInfo = _T("ClearFavBoxMsg - ") + strError;
|
CMBAMDBFun::WriteDBErrToFile( strErrInfo );
|
return FALSE;
|
}
|
return TRUE;
|
}
|
|
BOOL CMBAMDBConnect::ClearCrowdMsgBox(CString strStartDate,CString strEndDate, CString strCrowdID, CString strKey)
|
{
|
CDBRecord ARecordset;
|
BOOL bReturn = FALSE;
|
if ( !m_bOpenDB )
|
return FALSE;
|
if ( strCrowdID.IsEmpty() )
|
return FALSE;
|
CString strMsgSQL;
|
CString strSQLWhere = _T("");
|
CString strValue;
|
CString strSQLTemp;
|
CHighTime tmHigh;
|
SYSTEMTIME tmSystem;
|
// Set Filter
|
strSQLWhere.Format(_T("G_C2='%s' "), strCrowdID );
|
if( !strKey.IsEmpty())
|
{
|
strSQLTemp.Format( _T(" AND S_C12 LIKE '%%%s%%' "), strKey );
|
strSQLWhere += strSQLTemp;
|
}
|
if ( !strStartDate.IsEmpty() && tmHigh.ParseDateTime( strStartDate ) )
|
{
|
tmHigh.GetAsSystemTime( tmSystem );
|
if ( tmSystem.wSecond < 0 )
|
tmSystem.wSecond = 0;
|
strValue.Format(_T("%04d-%02d-%02d %02d:%02d:%02d"), tmSystem.wYear, tmSystem.wMonth, tmSystem.wDay,
|
tmSystem.wHour, tmSystem.wMinute, tmSystem.wSecond );
|
strSQLTemp.Format(_T(" AND T_C6 >='%s'"),strValue);
|
strSQLWhere += strSQLTemp;
|
}
|
if ( !strEndDate.IsEmpty() && tmHigh.ParseDateTime( strEndDate ) )
|
{
|
tmHigh.GetAsSystemTime( tmSystem );
|
if ( tmSystem.wSecond < 0 )
|
tmSystem.wSecond = 0;
|
strValue.Format(_T("%04d-%02d-%02d %02d:%02d:%02d"), tmSystem.wYear, tmSystem.wMonth, tmSystem.wDay,
|
tmSystem.wHour, tmSystem.wMinute, tmSystem.wSecond );
|
strSQLTemp.Format(_T(" AND T_C6 <='%s'"),strValue);
|
strSQLWhere += strSQLTemp;
|
}
|
strMsgSQL.Format( _T("DELETE FROM TN_STK_CROWDMSG WHERE %s"), strSQLWhere );
|
try
|
{
|
m_AConnect.StartTransaction(); // Æô¶¯ÊÂÎñ
|
bReturn = CDBSQLiteCommFun::RunSQL(strMsgSQL, &m_AConnect);
|
m_AConnect.Commit(); // Ìá½»ÊÂÎñ
|
}
|
catch( CDBSQliteException ex )
|
{
|
CString strError = ex.GetErrInfo();
|
CString strErrInfo;
|
|
strErrInfo = _T("ClearCrowdMsgBox - ") + strError;
|
CMBAMDBFun::WriteDBErrToFile( strErrInfo );
|
return FALSE;
|
}
|
return TRUE;
|
}
|
/******************************************
|
Ãû³Æ£º
|
»ñÈ¡ÁªÏµÈË
|
|
²ÎÊý£ºCArrayAMObject &arAMObject
|
|
|
·µ»ØÖµ£º
|
false - ×°ÔØʧ°Ü true - ×°Ôسɹ¦
|
******************************************/
|
bool CMBAMDBConnect::GetSendPerson(CArrayAMObject &arAMObject)
|
{
|
CString strSQL, strValue, strLogin, strName;
|
CDBRecord ARecordset;
|
CMapStringToString mapUser;
|
stAMObject itemObj;
|
arAMObject.RemoveAll();
|
strSQL.Format( _T("SELECT S_C4 AS SLOGIN, S_C5 AS SNAME FROM TN_STK_MSG WHERE N_C7=0 AND N_C8=%d AND S_C10='' GROUP BY S_C4 ORDER BY S_C5 ASC"), MANAGER_FOLDER_BOX_IN);
|
try
|
{
|
ARecordset.Open( &m_AConnect,strSQL );
|
while ( S_OK == ARecordset.MoveNext() )
|
{
|
ARecordset.GetValue( 1, strValue, true );
|
strLogin = strValue;
|
ARecordset.GetValue( 2, strValue, true );
|
strName = strValue;
|
if ( mapUser.Lookup(strLogin,strName))
|
{
|
continue;
|
}
|
mapUser.SetAt(strLogin,strLogin);
|
itemObj.strID = strLogin;
|
if ( strName.IsEmpty() )
|
itemObj.strName = strLogin;
|
else
|
itemObj.strName = strName;
|
arAMObject.Add(itemObj);
|
}
|
}
|
catch( CDBSQliteException ex )
|
{
|
CString strError = ex.GetErrInfo();
|
CString strErrInfo;
|
|
strErrInfo = _T("GetSendPerson - ") + strError;
|
CMBAMDBFun::WriteDBErrToFile( strErrInfo );
|
return FALSE;
|
}
|
return true;
|
}
|
bool CMBAMDBConnect::GetReceivePerson(CArrayAMObject &arAMObject)
|
{
|
CString strSQL, strValue, strLogin, strName;
|
CDBRecord ARecordset;
|
CMapStringToString mapUser;
|
stAMObject itemObj;
|
arAMObject.RemoveAll();
|
strSQL.Format( _T("SELECT DISTINCT S_C18 AS SLOGIN, S_C19 AS SNAME FROM TN_STK_MSG WHERE C_C17=0 AND N_C7=0 AND N_C8=%d AND S_C10='' GROUP BY S_C18 ORDER BY S_C19 ASC "),MANAGER_FOLDER_BOX_OUT);
|
try
|
{
|
ARecordset.Open( &m_AConnect,strSQL );
|
while ( S_OK == ARecordset.MoveNext() )
|
{
|
ARecordset.GetValue( 1, strValue, true );
|
strLogin = strValue;
|
ARecordset.GetValue( 2, strValue, true );
|
strName = strValue;
|
if ( mapUser.Lookup(strLogin,strName))
|
{
|
continue;
|
}
|
mapUser.SetAt(strLogin,strLogin);
|
itemObj.strID = strLogin;
|
if ( strName.IsEmpty() )
|
itemObj.strName = strLogin;
|
else
|
itemObj.strName = strName;
|
arAMObject.Add(itemObj);
|
}
|
}
|
catch( CDBSQliteException ex )
|
{
|
CString strError = ex.GetErrInfo();
|
CString strErrInfo;
|
|
strErrInfo = _T("GetReceivePerson - ") + strError;
|
CMBAMDBFun::WriteDBErrToFile( strErrInfo );
|
return FALSE;
|
}
|
strSQL.Format( _T("SELECT AA.S_C2,AA.S_C3 FROM TN_STK_MSGOWNER AA INNER JOIN TN_STK_MSG BB ON AA.G_C1 = BB.G_C1 WHERE BB.C_C17=1 AND BB.N_C7=0 AND BB.N_C8=%d AND BB.S_C10='' GROUP BY AA.S_C2 ORDER BY AA.S_C3 ASC"), MANAGER_FOLDER_BOX_OUT);
|
try
|
{
|
ARecordset.Open( &m_AConnect,strSQL );
|
while ( S_OK == ARecordset.MoveNext() )
|
{
|
ARecordset.GetValue( 1, strValue, true );
|
strLogin = strValue;
|
ARecordset.GetValue( 2, strValue, true );
|
strName = strValue;
|
if ( mapUser.Lookup(strLogin,strName))
|
{
|
continue;
|
}
|
mapUser.SetAt(strLogin,strLogin);
|
itemObj.strID = strLogin;
|
if ( strName.IsEmpty() )
|
itemObj.strName = strLogin;
|
else
|
itemObj.strName = strName;
|
arAMObject.Add(itemObj);
|
}
|
}
|
catch( CDBSQliteException ex )
|
{
|
CString strError = ex.GetErrInfo();
|
CString strErrInfo;
|
|
strErrInfo = _T("GetReceivePerson - ") + strError;
|
CMBAMDBFun::WriteDBErrToFile( strErrInfo );
|
return FALSE;
|
}
|
return true;
|
}
|
/******************************************
|
Ãû³Æ£º
|
»ñÈ¡¸øµ±Ç°Óû§·¢Ë͹ý¸½¼þµÄÓû§
|
|
²ÎÊý£º
|
|
|
·µ»ØÖµ£º
|
false - ×°ÔØʧ°Ü true - ×°Ôسɹ¦
|
******************************************/
|
bool CMBAMDBConnect::GetSendAttachPerson(CArrayAMObject &arAMObject)
|
{
|
CString strSQL, strValue, strLogin, strName;
|
CDBRecord ARecordset;
|
CMapStringToString mapUser;
|
stAMObject itemObj;
|
arAMObject.RemoveAll();
|
strSQL.Format( _T("SELECT DISTINCT S_C4 AS SLOGIN, S_C5 AS SNAME FROM TN_STK_MSG WHERE N_C12>0 ORDER BY S_C5 ASC"));
|
try
|
{
|
ARecordset.Open( &m_AConnect,strSQL );
|
while ( S_OK == ARecordset.MoveNext() )
|
{
|
ARecordset.GetValue( 1, strValue, true );
|
strLogin = strValue;
|
ARecordset.GetValue( 2, strValue, true );
|
strName = strValue;
|
if ( mapUser.Lookup(strLogin,strName))
|
{
|
continue;
|
}
|
mapUser.SetAt(strLogin,strLogin);
|
itemObj.strID = strLogin;
|
if ( strName.IsEmpty() )
|
itemObj.strName = strLogin;
|
else
|
itemObj.strName = strName;
|
arAMObject.Add(itemObj);
|
}
|
}
|
catch( CDBSQliteException ex )
|
{
|
CString strError = ex.GetErrInfo();
|
CString strErrInfo;
|
|
strErrInfo = _T("GetSendAttachPerson - ") + strError;
|
CMBAMDBFun::WriteDBErrToFile( strErrInfo );
|
return FALSE;
|
}
|
return true;
|
}
|
|
/******************************************
|
Ãû³Æ£º
|
»ñȡȺ
|
|
²ÎÊý£º
|
|
|
·µ»ØÖµ£º
|
false - ×°ÔØʧ°Ü true - ×°Ôسɹ¦
|
******************************************/
|
bool CMBAMDBConnect::GetCrowds(CArrayAMObject &arAMObject)
|
{
|
CString strSQL, strValue, strLogin, strName;
|
CDBRecord ARecordset;
|
CMapStringToString mapUser;
|
stAMObject itemObj;
|
arAMObject.RemoveAll();
|
strSQL.Format( _T("SELECT G_C2, S_C3 FROM TN_STK_CROWDMSG GROUP BY G_C2 ORDER BY S_C3 ASC") );
|
try
|
{
|
ARecordset.Open( &m_AConnect,strSQL );
|
while ( S_OK == ARecordset.MoveNext() )
|
{
|
ARecordset.GetValue( 1, strValue, true );
|
strLogin = strValue;
|
ARecordset.GetValue( 2, strValue, true );
|
strName = strValue;
|
if ( mapUser.Lookup(strLogin,strName))
|
{
|
continue;
|
}
|
mapUser.SetAt(strLogin,strLogin);
|
itemObj.strID = strLogin;
|
if ( strName.IsEmpty() )
|
itemObj.strName = strLogin;
|
else
|
itemObj.strName = strName;
|
arAMObject.Add(itemObj);
|
}
|
}
|
catch( CDBSQliteException ex )
|
{
|
CString strError = ex.GetErrInfo();
|
CString strErrInfo;
|
|
strErrInfo = _T("GetSendAttachPerson - ") + strError;
|
CMBAMDBFun::WriteDBErrToFile( strErrInfo );
|
return FALSE;
|
}
|
return true;
|
}
|
|
BOOL CMBAMDBConnect::LoadPropStringValue( CString strPropClass,CString strPropName, int &nPropVer,CString &strPropValue)
|
{
|
//CSingleLock lock( &m_csConnectDB, true );
|
if ( !m_bOpenDB )
|
return FALSE;
|
CString strName;
|
CString strValue = _T("");
|
CDBRecord ARecordset;
|
CString strSQL;
|
|
if(strPropClass.IsEmpty() || strPropName.IsEmpty())
|
return FALSE;
|
nPropVer = 0;
|
strPropValue = _T("");
|
strSQL.Format( _T("SELECT N_C3, S_C4 FROM TN_STK_USEREXTPROPERTY WHERE S_C1 ='%s' AND S_C2= '%s'"), CMBAMDBFun::GetDBReplaceStr( strPropClass ),CMBAMDBFun::GetDBReplaceStr( strPropName ));
|
try
|
{
|
|
ARecordset.Open( &m_AConnect,strSQL );
|
while ( S_OK == ARecordset.MoveNext() )
|
{
|
ARecordset.GetValue( 1, nPropVer );
|
ARecordset.GetValue( 2, strValue );
|
strPropValue = strValue;
|
break;
|
}
|
}
|
catch ( CDBSQliteException ex )
|
{
|
CString strError = ex.GetErrInfo();
|
CString strErrInfo;
|
|
strErrInfo = _T("LoadPropStringValue - ") + strError;
|
CMBAMDBFun::WriteDBErrToFile( strErrInfo );
|
}
|
return TRUE;
|
}
|
BOOL CMBAMDBConnect::UpdatePropStringValue( CString strPropClass,CString strPropName, int nPropVer,CString strPropValue)
|
{
|
if ( strPropClass.IsEmpty() || strPropName.IsEmpty() )
|
return FALSE;
|
if ( !m_bOpenDB )
|
return FALSE;
|
CString strSQL, strWhere;
|
CDBRecord ARecordset;
|
BOOL bReturn = true;
|
int nCount = 0;
|
|
strSQL.Format( _T("SELECT COUNT(*) FROM TN_STK_USEREXTPROPERTY WHERE S_C1='%s' AND S_C2='%s'"),CMBAMDBFun::GetDBReplaceStr( strPropClass ),CMBAMDBFun::GetDBReplaceStr( strPropName ));
|
try
|
{
|
|
ARecordset.Open( &m_AConnect,strSQL );
|
while (S_OK == ARecordset.MoveNext() )
|
{
|
ARecordset.GetValue( 1, nCount );
|
break;
|
}
|
if(nCount > 0 )
|
{
|
strSQL.Format( _T("UPDATE TN_STK_USEREXTPROPERTY SET N_C3 = %d,S_C4 = '%s' WHERE S_C1='%s' AND S_C2='%s'"),
|
nPropVer,CMBAMDBFun::GetDBReplaceStr( strPropValue ),CMBAMDBFun::GetDBReplaceStr( strPropClass ),CMBAMDBFun::GetDBReplaceStr( strPropName ) );
|
|
}
|
else
|
{
|
strSQL.Format( _T("INSERT INTO TN_STK_USEREXTPROPERTY(S_C1 , S_C2 , N_C3 , S_C4) VALUES ( '%s', '%s', %d, '%s')"),
|
CMBAMDBFun::GetDBReplaceStr( strPropClass ),CMBAMDBFun::GetDBReplaceStr( strPropName ), nPropVer, CMBAMDBFun::GetDBReplaceStr( strPropValue ));
|
}
|
bReturn = CDBSQLiteCommFun::RunSQL( (LPCTSTR)strSQL,&m_AConnect);
|
}
|
catch ( CDBSQliteException ex )
|
{
|
CString strError, strErrInfo;
|
|
strError = ex.GetErrInfo();
|
strErrInfo.Format(_T("UpdatePropStringValue(%s) - %s"),strSQL, strError);
|
CMBAMDBFun::WriteDBErrToFile( strErrInfo );
|
return FALSE;
|
}
|
return bReturn;
|
}
|
|
BOOL CMBAMDBConnect::RemovePropStringValue( CString strPropClass,CString strPropName)
|
{
|
if ( strPropClass.IsEmpty() || strPropName.IsEmpty() )
|
return FALSE;
|
if ( !m_bOpenDB )
|
return FALSE;
|
CString strSQL, strWhere;
|
CDBRecord ARecordset;
|
BOOL bReturn = true;
|
int nCount = 0;
|
|
strSQL.Format( _T("DELETE FROM TN_STK_USEREXTPROPERTY WHERE S_C1='%s' AND S_C2='%s'"), CMBAMDBFun::GetDBReplaceStr( strPropClass ),CMBAMDBFun::GetDBReplaceStr( strPropName ) );
|
try
|
{
|
bReturn = CDBSQLiteCommFun::RunSQL( (LPCTSTR)strSQL,&m_AConnect);
|
}
|
catch ( CDBSQliteException ex )
|
{
|
CString strError, strErrInfo;
|
|
strError = ex.GetErrInfo();
|
strErrInfo.Format(_T("RemovePropStringValue(%s) - %s"),strSQL, strError);
|
CMBAMDBFun::WriteDBErrToFile( strErrInfo );
|
return FALSE;
|
}
|
return bReturn;
|
}
|
BOOL CMBAMDBConnect::LoadUsersPropValue(CString strClass, CMapStringToString &mapPropValue)
|
{
|
//CSingleLock lock( &m_csConnectDB, true );
|
if ( !m_bOpenDB )
|
return FALSE;
|
CString strName;
|
CString strValue = _T("");
|
CDBRecord ARecordset;
|
CString strSQL;
|
|
mapPropValue.RemoveAll();
|
strSQL.Format( _T("SELECT S_C2, S_C4 FROM TN_STK_USEREXTPROPERTY WHERE S_C1 ='%s'"), strClass );
|
try
|
{
|
|
ARecordset.Open( &m_AConnect,strSQL );
|
while ( S_OK == ARecordset.MoveNext() )
|
{
|
ARecordset.GetValue( 1, strValue );
|
strName = strValue;
|
ARecordset.GetValue( 2, strValue );
|
mapPropValue.SetAt(strName, strValue);
|
}
|
}
|
catch ( CDBSQliteException ex )
|
{
|
CString strError = ex.GetErrInfo();
|
CString strErrInfo;
|
|
strErrInfo = _T("LoadUsersPropValue - ") + strError;
|
CMBAMDBFun::WriteDBErrToFile( strErrInfo );
|
}
|
return TRUE;
|
}
|
|
CString CMBAMDBConnect::GetOldestMsg()
|
{
|
CString strDate = _T("");
|
CString strSQL;
|
if ( !m_bOpenDB )
|
return strDate;
|
strSQL.Format(_T("SELECT T_C6 FROM TN_STK_MSG ORDER BY T_C6 ASC LIMIT 0,1 "));
|
CString strTempValue;
|
CDBRecord ARecordset;
|
try
|
{
|
ARecordset.Open( &m_AConnect,strSQL );
|
while ( S_OK == ARecordset.MoveNext() )
|
{
|
ARecordset.GetValue( 1, strTempValue );
|
strDate = strTempValue ;
|
break;
|
}
|
}
|
catch ( CDBSQliteException ex )
|
{
|
CString strError;
|
CString strErrInfo;
|
strError = (LPCTSTR)ex.GetErrInfo( );
|
strErrInfo = _T("GetOldestMsg - ") + strError;
|
CMBAMDBFun::WriteDBErrToFile( strErrInfo );
|
return strDate;
|
}
|
return strDate;
|
}
|
CString CMBAMDBConnect::GetUpToDateMsg()
|
{
|
CString strDate = _T("");
|
CString strSQL;
|
if ( !m_bOpenDB )
|
return strDate;
|
strSQL.Format(_T("SELECT T_C6 FROM TN_STK_MSG ORDER BY T_C6 DESC LIMIT 0,1 "));
|
CString strTempValue;
|
CDBRecord ARecordset;
|
try
|
{
|
ARecordset.Open( &m_AConnect,strSQL );
|
while ( S_OK == ARecordset.MoveNext() )
|
{
|
ARecordset.GetValue( 1, strTempValue );
|
strDate = strTempValue ;
|
break;
|
}
|
}
|
catch ( CDBSQliteException ex )
|
{
|
CString strError;
|
CString strErrInfo;
|
strError = (LPCTSTR)ex.GetErrInfo( );
|
strErrInfo = _T("GetUpToDateMsg - ") + strError;
|
CMBAMDBFun::WriteDBErrToFile( strErrInfo );
|
return strDate;
|
}
|
return strDate;
|
}
|
BOOL CMBAMDBConnect::GetMsgDataCount(long &nMsgCount,long &nRelatedCount)
|
{
|
nMsgCount = 0;
|
nRelatedCount = 0;
|
CString strSQL;
|
if ( !m_bOpenDB )
|
return FALSE;
|
strSQL.Format(_T(" SELECT COUNT(*) FROM TN_STK_MSG"));
|
long nTempValue = 0;
|
CDBRecord ARecordset;
|
try
|
{
|
ARecordset.Open( &m_AConnect,strSQL );
|
while ( S_OK == ARecordset.MoveNext() )
|
{
|
ARecordset.GetValue( 1, nTempValue );
|
nMsgCount += nTempValue ;
|
break;
|
}
|
ARecordset.Close();
|
strSQL.Format(_T("SELECT COUNT(*) FROM TN_STK_CROWDMSG"));
|
ARecordset.Open( &m_AConnect,strSQL );
|
while ( S_OK == ARecordset.MoveNext() )
|
{
|
ARecordset.GetValue( 1, nTempValue );
|
nMsgCount += nTempValue ;
|
break;
|
}
|
ARecordset.Close();
|
strSQL.Format(_T("SELECT COUNT(*) FROM TN_STK_MSGOWNER"));
|
ARecordset.Open( &m_AConnect,strSQL );
|
while ( S_OK == ARecordset.MoveNext() )
|
{
|
ARecordset.GetValue( 1, nTempValue );
|
nRelatedCount += nTempValue ;
|
break;
|
}
|
ARecordset.Close();
|
strSQL.Format(_T("SELECT COUNT(*) FROM TN_STK_ATTACHMENT"));
|
ARecordset.Open( &m_AConnect,strSQL );
|
while ( S_OK == ARecordset.MoveNext() )
|
{
|
ARecordset.GetValue( 1, nTempValue );
|
nRelatedCount += nTempValue ;
|
break;
|
}
|
ARecordset.Close();
|
strSQL.Format(_T("SELECT COUNT(*) FROM TN_STK_MSGPROPERTY"));
|
ARecordset.Open( &m_AConnect,strSQL );
|
while ( S_OK == ARecordset.MoveNext() )
|
{
|
ARecordset.GetValue( 1, nTempValue );
|
nRelatedCount += nTempValue ;
|
break;
|
}
|
}
|
catch ( CDBSQliteException ex )
|
{
|
CString strError;
|
CString strErrInfo;
|
strError = (LPCTSTR)ex.GetErrInfo( );
|
strErrInfo = _T("GetMsgDataCount - ") + strError;
|
CMBAMDBFun::WriteDBErrToFile( strErrInfo );
|
return FALSE;
|
}
|
return TRUE;
|
}
|
BOOL CMBAMDBConnect::CleanDateBeforeMsg(CString strDate)
|
{
|
CString strMsgSQL;
|
CString strAttachSQL;
|
CString strOwnerSQL;
|
CString strPropertySQL;
|
CString strCrowdMsgSQL;
|
if ( !m_bOpenDB )
|
return FALSE;
|
strMsgSQL.Format( _T("DELETE FROM TN_STK_MSG WHERE T_C6 <='%s' "),strDate );
|
strAttachSQL.Format( _T("DELETE FROM TN_STK_ATTACHMENT WHERE G_C1 IN ( SELECT G_C1 FROM TN_STK_MSG WHERE T_C6 <='%s') "), strDate );
|
strOwnerSQL.Format( _T("DELETE FROM TN_STK_MSGOWNER WHERE G_C1 IN ( SELECT G_C1 FROM TN_STK_MSG WHERE T_C6 <='%s' ) "), strDate );
|
strPropertySQL.Format( _T("DELETE FROM TN_STK_MSGPROPERTY WHERE G_C1 IN ( SELECT G_C1 FROM TN_STK_MSG WHERE T_C6 <='%s' ) "), strDate );
|
strCrowdMsgSQL.Format( _T("DELETE FROM TN_STK_CROWDMSG WHERE T_C6 <='%s' "),strDate );
|
try
|
{
|
m_AConnect.StartTransaction(); // Æô¶¯ÊÂÎñ
|
CDBSQLiteCommFun::RunSQL( strAttachSQL, &m_AConnect );
|
CDBSQLiteCommFun::RunSQL( strOwnerSQL, &m_AConnect );
|
CDBSQLiteCommFun::RunSQL( strPropertySQL, &m_AConnect );
|
CDBSQLiteCommFun::RunSQL( strMsgSQL, &m_AConnect );
|
CDBSQLiteCommFun::RunSQL( strCrowdMsgSQL, &m_AConnect );
|
m_AConnect.Commit(); // Ìá½»ÊÂÎñ
|
}
|
catch ( CDBSQliteException ex )
|
{
|
CString strError;
|
CString strErrInfo;
|
strError = (LPCTSTR)ex.GetErrInfo( );
|
strErrInfo = _T("CleanDateBeforeMsg - ") + strError;
|
CMBAMDBFun::WriteDBErrToFile( strErrInfo );
|
return FALSE;
|
}
|
return TRUE;
|
}
|
BOOL CMBAMDBConnect::CleanDateAfterMsg(CString strDate)
|
{
|
CString strMsgSQL;
|
CString strAttachSQL;
|
CString strOwnerSQL;
|
CString strPropertySQL;
|
CString strCrowdMsgSQL;
|
if ( !m_bOpenDB )
|
return FALSE;
|
strMsgSQL.Format( _T("DELETE FROM TN_STK_MSG WHERE T_C6 >'%s' "),strDate );
|
strAttachSQL.Format( _T("DELETE FROM TN_STK_ATTACHMENT WHERE G_C1 IN ( SELECT G_C1 FROM TN_STK_MSG WHERE T_C6 >'%s') "), strDate );
|
strOwnerSQL.Format( _T("DELETE FROM TN_STK_MSGOWNER WHERE G_C1 IN ( SELECT G_C1 FROM TN_STK_MSG WHERE T_C6 >'%s' ) "), strDate );
|
strPropertySQL.Format( _T("DELETE FROM TN_STK_MSGPROPERTY WHERE G_C1 IN ( SELECT G_C1 FROM TN_STK_MSG WHERE T_C6 >'%s' ) "), strDate );
|
strCrowdMsgSQL.Format( _T("DELETE FROM TN_STK_CROWDMSG WHERE T_C6 >'%s' "),strDate );
|
try
|
{
|
m_AConnect.StartTransaction(); // Æô¶¯ÊÂÎñ
|
CDBSQLiteCommFun::RunSQL( strAttachSQL, &m_AConnect );
|
CDBSQLiteCommFun::RunSQL( strOwnerSQL, &m_AConnect );
|
CDBSQLiteCommFun::RunSQL( strPropertySQL, &m_AConnect );
|
CDBSQLiteCommFun::RunSQL( strMsgSQL, &m_AConnect );
|
CDBSQLiteCommFun::RunSQL( strCrowdMsgSQL, &m_AConnect );
|
m_AConnect.Commit(); // Ìá½»ÊÂÎñ
|
}
|
catch ( CDBSQliteException ex )
|
{
|
CString strError;
|
CString strErrInfo;
|
strError = (LPCTSTR)ex.GetErrInfo( );
|
strErrInfo = _T("CleanDateAfterMsg - ") + strError;
|
CMBAMDBFun::WriteDBErrToFile( strErrInfo );
|
return FALSE;
|
}
|
return TRUE;
|
}
|
|
BOOL CMBAMDBConnect::CleanAMExtraData()
|
{
|
CString strSQL;
|
if ( !m_bOpenDB )
|
return FALSE;
|
try
|
{
|
m_AConnect.StartTransaction(); // Æô¶¯ÊÂÎñ
|
strSQL = _T("DELETE FROM TN_STK_LASTCONTACT ") ;
|
CDBSQLiteCommFun::RunSQL( strSQL, &m_AConnect );
|
strSQL = _T("DELETE FROM TN_STK_SYSMSG ") ;
|
CDBSQLiteCommFun::RunSQL( strSQL, &m_AConnect );
|
strSQL = _T("DELETE FROM TN_STK_USEREXTPROPERTY ") ;
|
CDBSQLiteCommFun::RunSQL( strSQL, &m_AConnect );
|
strSQL = _T("DELETE FROM TN_STK_UNREADMSG ") ;
|
CDBSQLiteCommFun::RunSQL( strSQL, &m_AConnect );
|
m_AConnect.Commit(); // Ìá½»ÊÂÎñ
|
}
|
catch ( CDBSQliteException ex )
|
{
|
CString strError;
|
CString strErrInfo;
|
strError = (LPCTSTR)ex.GetErrInfo( );
|
strErrInfo = _T("CleanAMExtraData - ") + strError;
|
CMBAMDBFun::WriteDBErrToFile( strErrInfo );
|
return FALSE;
|
}
|
return TRUE;
|
}
|
BOOL CMBAMDBConnect::DeleteMsgFromDB( CString strMsgID)
|
{
|
CString strSQL;
|
CString strSQL2;
|
CString strSQL3;
|
CString strSQL4;
|
CString strSQL5;
|
BOOL bReturn = true;
|
int nCount = 0;
|
if ( !m_bOpenDB )
|
return FALSE;
|
if(strMsgID.IsEmpty())
|
return FALSE;
|
try
|
{
|
strSQL.Format( _T("DELETE FROM TN_STK_MSG WHERE G_C1='%s'"),strMsgID);
|
strSQL2.Format( _T("DELETE FROM TN_STK_ATTACHMENT WHERE G_C1='%s'"),strMsgID);
|
strSQL3.Format( _T("DELETE FROM TN_STK_MSGOWNER WHERE G_C1='%s'"),strMsgID);
|
strSQL4.Format( _T("DELETE FROM TN_STK_MSGPROPERTY WHERE G_C1='%s'"),strMsgID);
|
strSQL5.Format( _T("DELETE FROM TN_STK_UNREADMSG WHERE G_C1='%s'"),strMsgID);
|
m_AConnect.StartTransaction(); // Æô¶¯ÊÂÎñ
|
CDBSQLiteCommFun::RunSQL(strSQL2, &m_AConnect);
|
CDBSQLiteCommFun::RunSQL(strSQL3, &m_AConnect);
|
CDBSQLiteCommFun::RunSQL(strSQL4, &m_AConnect);
|
CDBSQLiteCommFun::RunSQL(strSQL5, &m_AConnect);
|
bReturn = CDBSQLiteCommFun::RunSQL(strSQL, &m_AConnect);
|
m_AConnect.Commit(); // Ìá½»ÊÂÎñ
|
bReturn = CDBSQLiteCommFun::RunSQL(strSQL, &m_AConnect);
|
}
|
catch( CDBSQliteException ex )
|
{
|
CString strError = ex.GetErrInfo();
|
CString strErrInfo;
|
|
strErrInfo = _T("DeleteMsgFromDB - ") + strError;
|
CMBAMDBFun::WriteDBErrToFile( strErrInfo );
|
return FALSE;
|
}
|
return TRUE;
|
}
|
|
//==============================================
|
// ɾ³ýÊղؼÐ
|
//==============================================
|
BOOL CMBAMDBConnect::DeleteFolder(long nFolderID,int nMoveMsg)
|
{
|
if(nFolderID < FOLDERID_BASE)
|
return FALSE;
|
CString strFolderSQL;
|
CString strSQL;
|
CString strSQL2;
|
CString strSQL3;
|
CString strSQL4;
|
CString strSQL5;
|
CString strSelectSQL;
|
BOOL bReturn = true;
|
int nCount = 0;
|
CString strSubFonderSQL = _T("");
|
CString strWhereSQL= _T("");
|
CString strMsgWhereSQL= _T("");
|
if ( !m_bOpenDB )
|
return FALSE;
|
try
|
{
|
|
strSQL.Format(_T("SELECT N_C1 FROM TN_STK_MSGFOLDER WHERE N_C3 = %d "),nFolderID);
|
CString strTempValue;
|
CDBRecord ARecordset;
|
ARecordset.Open( &m_AConnect,strSQL );
|
while ( S_OK == ARecordset.MoveNext() )
|
{
|
ARecordset.GetValue( 1, strTempValue );
|
strFolderSQL.Format(_T("%s,"),strTempValue);
|
strSubFonderSQL +=strFolderSQL;
|
}
|
if(strSubFonderSQL.IsEmpty())
|
{
|
strMsgWhereSQL.Format( _T(" N_C8=%d "), nFolderID );
|
strWhereSQL.Format( _T(" N_C1=%d "), nFolderID );
|
}
|
else
|
{
|
strMsgWhereSQL.Format( _T(" N_C8 IN(%s%d)"), strSubFonderSQL,nFolderID );
|
strWhereSQL.Format( _T(" N_C1 IN(%s%d)"), strSubFonderSQL,nFolderID );
|
}
|
strFolderSQL.Format(_T("DELETE FROM TN_STK_MSGFOLDER WHERE %s"),strWhereSQL );
|
if(nMoveMsg == 0) //ÏûÏ¢ÒÆ»ØÔÀ´·¢¼þÏä»òÊÕ¼þÏä
|
{
|
strSQL.Format( _T("UPDATE TN_STK_MSG SET N_C8 = %d WHERE %s AND S_C4='%s'"),MANAGER_FOLDER_BOX_OUT, strMsgWhereSQL,m_strLogin );
|
strSQL2.Format( _T("UPDATE TN_STK_MSG SET N_C8 = %d WHERE %s AND S_C4<>'%s'"),MANAGER_FOLDER_BOX_IN, strMsgWhereSQL,m_strLogin );
|
m_AConnect.StartTransaction(); // Æô¶¯ÊÂÎñ
|
bReturn |=CDBSQLiteCommFun::RunSQL(strSQL, &m_AConnect);
|
bReturn |=CDBSQLiteCommFun::RunSQL(strSQL2, &m_AConnect);
|
m_AConnect.Commit(); // Ìá½»ÊÂÎñ
|
}
|
else if(nMoveMsg == 1) //ɾ³ýÕâЩÏûÏ¢
|
{
|
strSelectSQL.Format( _T("SELECT G_C1 FROM TN_STK_MSG Where %s "),strMsgWhereSQL );
|
strSQL.Format( _T("DELETE FROM TN_STK_MSG WHERE Where %s "),strMsgWhereSQL );
|
strSQL2.Format( _T("DELETE FROM TN_STK_ATTACHMENT WHERE G_C1 IN ( %s) "), strSelectSQL );
|
strSQL3.Format( _T("DELETE FROM TN_STK_MSGOWNER WHERE G_C1 IN ( %s) "), strSelectSQL );
|
strSQL4.Format( _T("DELETE FROM TN_STK_MSGPROPERTY WHERE G_C1 IN ( %s) "), strSelectSQL );
|
strSQL5.Format( _T("DELETE FROM TN_STK_UNREADMSG WHERE G_C1 IN ( %s) "), strSelectSQL );
|
m_AConnect.StartTransaction(); // Æô¶¯ÊÂÎñ
|
bReturn |=CDBSQLiteCommFun::RunSQL(strSQL2, &m_AConnect);
|
bReturn |=CDBSQLiteCommFun::RunSQL(strSQL3, &m_AConnect);
|
bReturn |=CDBSQLiteCommFun::RunSQL(strSQL4, &m_AConnect);
|
bReturn |=CDBSQLiteCommFun::RunSQL(strSQL5, &m_AConnect);
|
bReturn |= CDBSQLiteCommFun::RunSQL(strSQL, &m_AConnect);
|
m_AConnect.Commit(); // Ìá½»ÊÂÎñ
|
bReturn |= CDBSQLiteCommFun::RunSQL(strSQL, &m_AConnect);
|
}
|
bReturn |= CDBSQLiteCommFun::RunSQL(strFolderSQL, &m_AConnect);
|
}
|
catch( CDBSQliteException ex )
|
{
|
CString strError = ex.GetErrInfo();
|
CString strErrInfo;
|
|
strErrInfo = _T("DeleteFolder - ") + strError;
|
CMBAMDBFun::WriteDBErrToFile( strErrInfo );
|
return FALSE;
|
}
|
return TRUE;
|
}
|
//==============================================
|
// ×°ÔØÖ¸¶¨ÀàÐÍÁªÏµÈ˵ÄÏûÏ¢ÏÔʾȨÏÞ
|
//==============================================
|
BOOL CMBAMDBConnect::LoadContactMsgRight( CString strClass, CMapStringToInt &mapMsgRight)
|
{
|
if ( !m_bOpenDB )
|
return FALSE;
|
CString strName;
|
CString strValue = _T("");
|
CDBRecord ARecordset;
|
CString strSQL;
|
int nRight;
|
|
mapMsgRight.RemoveAll();
|
strSQL.Format( _T("SELECT S_C2, S_C4 FROM TN_STK_USEREXTPROPERTY WHERE S_C1 ='%s' AND S_C4 <> '0'"), strClass );
|
try
|
{
|
|
ARecordset.Open( &m_AConnect,strSQL );
|
while ( S_OK == ARecordset.MoveNext() )
|
{
|
ARecordset.GetValue( 1, strValue );
|
strName = strValue;
|
ARecordset.GetValue( 2, strValue );
|
nRight = _tstol(strValue);
|
if(nRight > 0)
|
mapMsgRight.SetAt(strName, nRight);
|
}
|
}
|
catch ( CDBSQliteException ex )
|
{
|
CString strError = ex.GetErrInfo();
|
CString strErrInfo;
|
|
strErrInfo = _T("LoadUserMsgRight - ") + strError;
|
CMBAMDBFun::WriteDBErrToFile( strErrInfo );
|
}
|
return TRUE;
|
}
|
