db_ljq.cpp

使用文本文件

// DB_Ljq.cpp: implementation of the CDB_Ljq class.
//
//////////////////////////////////////////////////////////////////////

#include "stdafx.h"
#include "DB_Ljq.h"

#ifdef _DEBUG
#undef THIS_FILE
static char THIS_FILE[]=__FILE__;
#define new DEBUG_NEW
#endif

//////////////////////////////////////////////////////////////////////
// Construction/Destruction
//////////////////////////////////////////////////////////////////////

CDB_Ljq::CDB_Ljq()
{
	CoInitialize(NULL);
}

CDB_Ljq::~CDB_Ljq()
{
                
}

BOOL CDB_Ljq::OpenDB(CString DATABASE)
{
	HRESULT hr = _ctp.CreateInstance(__uuidof(Connection));
	if(!SUCCEEDED(hr)){return false;}
	char szServer[255];
	char szUser[255];
	char szPassword[255];
	char szDef[255];

	GetPrivateProfileString(DATABASE, "SERVER",                   
                           "", szServer, sizeof(szServer), 
                           "./SmsLink.ini");
	GetPrivateProfileString(DATABASE, "USER", 
                           "", szUser, sizeof(szServer), 
                           "./SmsLink.ini");
	GetPrivateProfileString(DATABASE, "PASSWORD", 
                           "", szPassword, sizeof(szServer), 
                           "./SmsLink.ini");
	GetPrivateProfileString(DATABASE, "DEFDATABASE", 
                           "", szDef, sizeof(szServer), 
                           "./SmsLink.ini");

	char strConnect[512];
	sprintf(strConnect,"provider = sqloledb;server=%s;database=%s;"
			,szServer,szDef);

	try{
		hr=_ctp->Open(_bstr_t(strConnect),_bstr_t(szUser),_bstr_t(szPassword),0);  //adConnectUnspecified
		if(!SUCCEEDED(hr))	return false;

	}
	catch(_com_error & e)
	{
		e.Description();   
		CString message;
		message.Format("错误提示%s",LPCTSTR(e.Description()));
                     
//		WriteLog(LPCTSTR(e.Description()));
		return false;
	}

	return TRUE;
}

BOOL CDB_Ljq::CloseDB()
{
	_ctp->Close();
	return true;
}

BOOL CDB_Ljq::ExecSQL(CString strQuery)
{
	try
	{
		_variant_t v(0L);
		_ctp->Execute(_bstr_t(strQuery),&v,0);           
	}
	catch(_com_error & e) 
	{
		MessageBox(NULL,"",LPCTSTR(e.Description()),MB_OK);
	}
	return TRUE;
}

BOOL CDB_Ljq::RegisterUser(char *szSim,CString &strUID)
{
	try
	{
		_variant_t v(0L);
		CString strQuery;
		strQuery.Format("select * from sh_user where l_handset='%s' and l_RealReg=0",szSim);
		_RecordsetPtr _rp=_ctp->Execute(_bstr_t(strQuery),&v,3);	 
		if(_rp->GetadoEOF())   
		{
			_rp->Close();
			//预注册
			strQuery.Format("insert into sh_user (l_handset,l_Sex,l_Nickname) values ('%s','%s','%s')"
				,szSim
				,"女"
				,"靓妹");    
			_ctp->Execute(_bstr_t(strQuery),&v,0);
		}
		_rp->Close();
	}
	catch(_com_error &e) 
	{
		CString str;
		str.Format("%s",LPCTSTR(e.Description()));
	}
	return TRUE;
}

BOOL CDB_Ljq::getUserInfo(char *szSim)
{
	return TRUE;
}

BOOL CDB_Ljq::IsRegistered(char *szSim) 
{
	try
	{
		_variant_t v(0L);
		CString strQuery;
		strQuery.Format("select * from sh_user where l_handset='%s' and l_RealReg=1"
			,szSim);
		_RecordsetPtr _rp=_ctp->Execute(_bstr_t(strQuery),&v,3);	
		if(!_rp->GetadoEOF())     
		{
			_rp->Close();
			return TRUE;
		}
		_rp->Close();

	}
	catch(_com_error & e) 
	{
		e.Description();
		return FALSE;
	}
	return FALSE;
}

BOOL CDB_Ljq::OpenDB(CString Server,CString User,CString PassWord,CString DATABASE)
{
	HRESULT hr = _ctp.CreateInstance(__uuidof(Connection));
	if(!SUCCEEDED(hr))
		return false;

	char strConnect[512];
	sprintf(strConnect,"provider = sqloledb;server=%s;database=%s;"
			,Server,DATABASE);

	try
	{
		hr=_ctp->Open(_bstr_t(strConnect),_bstr_t(User),_bstr_t(PassWord),0);  //adConnectUnspecified
		if(!SUCCEEDED(hr))	return false;

	}
	catch(_com_error & e)
	{
		e.Description();
		return false;
	}
	return TRUE;
}
_RecordsetPtr CDB_Ljq::GetWeb()
{
	_RecordsetPtr m_pOrderRst;
	try
	{
		_variant_t v(0L);
		CString strQuery;
		strQuery="SELECT * FROM [web_info] order by id desc";
		m_pOrderRst=_ctp->Execute(_bstr_t(strQuery),&v,adCmdText);
		
	}
	catch(_com_error *e)
	{
		AfxMessageBox(e->ErrorMessage());
	}
	return m_pOrderRst;
}

_RecordsetPtr CDB_Ljq::GetColum(char *id)
{
	_RecordsetPtr m_pOrderRst;
	CString sql;
	try
	{
		_variant_t v(0L);
		sql.Format("SELECT ID,web_item,web_url FROM [web_item] where web_name=%s order by id desc",id);
		m_pOrderRst=_ctp->Execute(_bstr_t(sql),&v,adCmdText);
	}
	catch(_com_error *e)
	{
		AfxMessageBox(e->ErrorMessage());
	}
	return m_pOrderRst;
}

_RecordsetPtr CDB_Ljq::GetList(char *id)
{
	_RecordsetPtr m_pOrderRst;
	CString sql;
	try
	{
		_variant_t v(0L);
		sql.Format("SELECT ID,web_title,web_url,web_date FROM [web_content] where web_id=%s order by id desc",id);
		m_pOrderRst=_ctp->Execute(_bstr_t(sql),&v,adCmdText);
	}
	catch(_com_error *e)
	{
		AfxMessageBox(e->ErrorMessage());
	}
	return m_pOrderRst;
}

CString CDB_Ljq::GetContent(char *PhoneNum)
{
//	LPCTSTR s;
	_RecordsetPtr m_pOrderRst;
	CString sql,dir;
	_variant_t var1,var2,var3;
	try
	{
		_variant_t v(0L);
		sql.Format("select servername+document as dir from [Sound_Document] where (select starttime from aaa.dbo.callstat_incallout where called='%s')>=begindate and (select starttime from aaa.dbo.callstat_incallout where called='%s')<=enddate",PhoneNum,PhoneNum);
		m_pOrderRst=_ctp->Execute(_bstr_t(sql),&v,adCmdText);
		if(!m_pOrderRst->GetadoEOF())
		{
			var1=m_pOrderRst->GetCollect("dir");
			dir=(LPCSTR)_bstr_t(var1);
			m_pOrderRst->Close();
		}
		else
			return "";
	}
	catch(_com_error *e)
	{
		AfxMessageBox(e->ErrorMessage());
	}
	return dir;
}
_RecordsetPtr CDB_Ljq::GetContentRs(char *PhoneNum)
{
//	LPCTSTR s;
	_RecordsetPtr m_pOrderRst;
	CString sql,dir;
	_variant_t var1,var2,var3;
	try
	{
		_variant_t v(0L);
		sql.Format("select starttime,left(replace(replace(CONVERT(varchar,starttime, 120 ),'-',''),' ',''),10) as dir,recfile from aaa.dbo.callstat_incallout where called='%s'",PhoneNum);
		m_pOrderRst=_ctp->Execute(_bstr_t(sql),&v,adCmdText);
	}
	catch(_com_error *e)
	{
		AfxMessageBox(e->ErrorMessage());
	}
	return m_pOrderRst;
}


_RecordsetPtr CDB_Ljq::GetFileName(char *time)
{
	_RecordsetPtr m_pOrderRst;
	CString sql,dir;
	_variant_t var1;
	try
	{
		_variant_t v(0L);
		//sql.Format("select RecFile,left(replace(replace(CONVERT(varchar,starttime, 120 ),'-',''),' ',''),10) as dir from aaa.dbo.callstat_incallout where called='%s'",time);
		sql.Format("select servername+document as dir from [Sound_Document] where '%s'>begindate and '%s'<enddate",time,time);
		m_pOrderRst=_ctp->Execute(_bstr_t(sql),&v,adCmdText);
	
		return m_pOrderRst;
	}
	catch(_com_error *e)
	{
		AfxMessageBox(e->ErrorMessage());
	}
	return m_pOrderRst;
}