#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); 
}