~wah/mbc-soui.git

#include "StdAfx.h"
#include "SvrConnect.h"
#include "mbvaultdef.h"
 
CSvrConnect::CSvrConnect(IIpcHandle * pHandle,CMBVaultDbMgr *pVaultDbMgr) :m_ipcHandle(pHandle)
{
    m_pVaultDbMgr = pVaultDbMgr;
}
 
 
CSvrConnect::~CSvrConnect()
{
    m_ipcHandle = NULL;
}
 
IIpcHandle * CSvrConnect::GetIpcHandle()
{
    return m_ipcHandle;
}
 
void CSvrConnect::BuildShareBufferName(ULONG_PTR idLocal, ULONG_PTR idRemote, TCHAR szBuf[MAX_PATH]) const
{
    _stprintf(szBuf, VAULT_SHARE_BUF_NAME_FMT, (DWORD)(((LPARAM)idLocal) & 0xffffffff), (DWORD)(((LPARAM)idRemote) & 0xffffffff));
}
 
 
//CString ->string
//a=CT2A(aa);
//
//string->CString
//bb=CA2T(b);
 
void CSvrConnect::OnDbInit(Param_DbInit &param)
{
    CString strErrInfo;
    param.ret = m_pVaultDbMgr->DbInit(strErrInfo);
    param.errInfo = CT2A(strErrInfo); 
}
 
void CSvrConnect::OnSetUserSessionID(Param_SetUserSessionID &param )
{
    CString strSessionID;
 
    strSessionID = CA2T(param.userSessionID.c_str());
    m_pVaultDbMgr->SetUserSessionID(strSessionID);
}
 
 
 
 
void CSvrConnect::OnSetDbPath(Param_SetDbPath &param)
{
    CString strExePath,strCfgPath;
 
    strExePath = CA2T(param.exePath.c_str());
    strCfgPath = CA2T(param.cfgPath.c_str());
     
    m_pVaultDbMgr->SetDbPath(strExePath,strCfgPath);
    param.ret = true;
}
 
void CSvrConnect::OnSyncInit(Param_SyncInit &param)
{
    CString strErrInfo;
 
    param.ret =  m_pVaultDbMgr->SyncInit(strErrInfo);
    param.errInfo = CT2A(strErrInfo);     
}
 
void CSvrConnect::OnSyncDb(Param_SyncDb &param)
{
    CString strErrInfo;
 
    param.ret =  m_pVaultDbMgr->SyncDb( strErrInfo );
 
    param.errInfo = CT2A(strErrInfo);     
}
 
void CSvrConnect::OnSetSvrInfo(Param_SetSvrInfo &param)
{
    int nPort = 0;
    CString strSvrIP,strUserID,strUserName,strPwd;
 
    strSvrIP = CA2T(param.svrIP.c_str());
    strUserID = CA2T(param.userID.c_str());
    strUserName = CA2T(param.userName.c_str());
    strPwd = CA2T(param.pwd.c_str());
     
    nPort  = param.nPort;
 
    m_pVaultDbMgr->SetSvrInfo( strSvrIP,nPort,strUserID,strUserName, strPwd );
 
    param.ret =  true;
}
 
void CSvrConnect::OnVaultGetList(Param_VaultGetList &param)
{
    CString strVaultList,strErrInfo;
 
    param.ret =  m_pVaultDbMgr->VaultGetList( strVaultList,strErrInfo  );
 
    param.errInfo   = CT2A(strErrInfo); 
    param.vaultList = CT2A(strVaultList);  
}
 
void CSvrConnect::OnVaultGetInfo(Param_VaultGetInfo &param)
{
    CString strVaultID,strVaultInfo,strErrInfo;
 
 
    strVaultID  = CA2T(param.vaultID.c_str());
 
    param.ret = m_pVaultDbMgr->VaultGetInfo( strVaultID, strVaultInfo,strErrInfo   );
 
    param.vaultInfo   = CT2A(strVaultInfo); 
    param.errInfo     = CT2A(strErrInfo);  
}
 
void CSvrConnect::OnVaultCatalogGetList(Param_VaultCatalogGetList &param)
{
    CString strVaultID, strParentID,strCatalogList,strErrInfo;
 
    strVaultID  = CA2T(param.vaultID.c_str());
    strParentID = CA2T(param.parentID.c_str());
     
    param.ret = m_pVaultDbMgr->VaultCatalogGetList( strVaultID, strParentID, strCatalogList,strErrInfo );           
 
    param.catalogList   = CT2A(strCatalogList); 
    param.errInfo     = CT2A(strErrInfo);  
}
 
void CSvrConnect::OnVaultQueryCatalogObj(Param_VaultQueryCatalogObj &param)
{
    CString strClsID,strVaultID,strCatalogID,strResult,strErrInfo;
 
    strClsID         = CA2T(param.clsID.c_str());
    strVaultID       = CA2T(param.vaultID.c_str());
    strCatalogID     = CA2T(param.catalogID.c_str());
 
    
    param.ret = m_pVaultDbMgr->VaultQueryCatalogObj( strClsID,strVaultID,strCatalogID,strResult,strErrInfo  );
 
 
    param.result      = CT2A(strResult); 
    param.errInfo     = CT2A(strErrInfo);  
}
 
void CSvrConnect::OnVaultQueryCatalogList(Param_VaultQueryCatalogList &param)
{ 
    CString strVaultID,strQueryContent,strCatalogList,strErrInfo; 
     
    strVaultID          = CA2T(param.vaultID.c_str());
    strQueryContent     = CA2T(param.queryContent.c_str()); 
    
    param.ret = m_pVaultDbMgr->VaultQueryCatalogList( strVaultID, strQueryContent, strCatalogList,strErrInfo   ); 
 
    param.catalogLst      = CT2A(strCatalogList); 
    param.errInfo         = CT2A(strErrInfo); 
}
 
void CSvrConnect::OnFireSyncDb(Param_FireSyncDb &param)
{
    CString strErrInfo,strParam;
 
    strParam = CA2T(param.param.c_str());
 
    param.ret =  m_pVaultDbMgr->FireSyncDb( strParam,strErrInfo );
 
    param.errInfo = CT2A(strErrInfo); 
}
 
 
void CSvrConnect::OnIsExistDataInTNXXXXXX(Param_IsExistDataInTNXXXXXX &param)
{
    bool bExsit = false;
    CString strErrInfo;
 
    param.ret =  m_pVaultDbMgr->IsExsitDataInTNXXXXXX( bExsit,strErrInfo );
 
    param.bExsit          =    bExsit;
    param.errInfo         = CT2A(strErrInfo); 
}
 
void CSvrConnect::OnGetFireParam(Param_GetFireParam &param)
{
    CString strParam;
     
    strParam = m_pVaultDbMgr->GetFireParam(); 
    
    param.fireParam =  CT2A(strParam); 
}
 
 
void CSvrConnect::OnTNXXXXXXQueryKey(Param_TNXXXXXXQueryKey &param)
{
    CString strKey,strResult,strErrInfo;
    
    strKey = CA2T(param.key.c_str());
 
    param.ret = m_pVaultDbMgr->TNXXXXXXQueryKey( strKey, strResult,strErrInfo );
 
    param.errInfo    =  CT2A(strErrInfo);
    param.result     =  CT2A(strResult);
}
 
 
 
void CSvrConnect::OnTNXXXXXXQueryByID(Param_TNXXXXXXQueryByID &param)
{
    CString strMID,strSID,strResult,strErrInfo;
    
    strMID = CA2T(param.mID.c_str());
    strSID = CA2T(param.sID.c_str());
 
    param.ret = m_pVaultDbMgr->TNXXXXXXQueryByID( strMID,strSID,strResult,strErrInfo );
 
    param.errInfo    =  CT2A(strErrInfo);
    param.result     =  CT2A(strResult);
}
 
 
void CSvrConnect::OnTNXXXQueryByKeyValue(Param_TNXXXQueryByKeyValue &param)
{
    CString strKeyValue,strResult,strErrInfo;
    
    strKeyValue = CA2T(param.keyValue.c_str());
 
    param.ret = m_pVaultDbMgr->TNXXXQueryByKeyValue( strKeyValue, strResult,strErrInfo );
 
    param.errInfo    =  CT2A(strErrInfo);
    param.result     =  CT2A(strResult);
}
 
 
// OI_VERSION
void CSvrConnect::OnGetFireVersion(Param_GetFireVersion &param)
{ 
    CString strTime,strResult,strErrInfo;
    
    param.ret = m_pVaultDbMgr->GetVersionFromDb( FIRE_VERSION,strTime,strErrInfo );
 
    param.errInfo    =  CT2A(strErrInfo);
    param.time       =  CT2A(strTime);
}
//bool CMBVaultDbMgr::DelDb( CString &strErrInfo )
void CSvrConnect::OnDelDb(Param_DelDb &param )
{ 
    CString strErrInfo;
    
    param.ret = m_pVaultDbMgr->DelDb( strErrInfo );
 
    param.errInfo    =  CT2A(strErrInfo); 
}