EventDao.cpp

#include "stdafx.h"
#include "EventDao.h"
#include "MyReader-DUI-MFC.h"
#include "EventDBHelper.h"


CEventDao::CEventDao(void)
{
	
	
}





CEventDao::~CEventDao(void)
{
}

void CEventDao::InsertOrUpdateUserInfo(CUserInfo userInfo)
{
	SYSTEMTIME curTime;
	::GetLocalTime(&curTime);
	CString updateTime;

	updateTime.Format(L"%d-%02d-%02d %02d:%02d:%02d",curTime.wYear, curTime.wMonth, curTime.wDay, curTime.wHour, curTime.wMinute, curTime.wSecond);
	CString sql;
	sql.Format(_T("replace into user_info(user_id,user_name,login_name,password,organ_name,organ_id,dept_name,grade,grade_id,user_type,image) \
	values('%s','%s','%s','%s','%s','%s','%s','%s','%s','%s','%s')"),userInfo.strUserId,userInfo.strRealName,userInfo.strLoginName,userInfo.strPassword,userInfo.strSchool,userInfo.strSchoolCode,userInfo.strDeptName,userInfo.strGrade,userInfo.strGradeId,userInfo.strType,userInfo.strHeadImage);

	CDataTable dt;
	pSqliteHelper->ExecuteNonQuery(sql);
}
CString CEventDao::GetTimeStamp(void)  
{  

	SYSTEMTIME tmSys;
	GetLocalTime(&tmSys);
	CTime tm3(tmSys);
	__int64 tmDst = __int64(tm3.GetTime())*1000 + tmSys.wMilliseconds;
	tmDst= tmDst+600000;
	CString strSignExp=L"",strSign=L"";
	strSignExp.Format(L"%lld",tmDst);

	return strSignExp;  
}
void CEventDao::AddEventLog(CString strData)
{
	//strData.Replace(_T("\\"),_T("\\\\"));
	CString sql;
	sql.Format(_T("insert into Log(id,text,isSend,isTestMode) \
				  values('%s','%s',%d,%d)"),GetTimeStamp(),strData,0,theApp.m_bTestMode);

	CDataTable dt;
	pSqliteHelper->ExecuteNonQuery(sql);
}

void CEventDao::LoadEventLogForSend(std::vector<Log_Data>& Logdata)
{
	

	CString sql;
	sql.Format(L"select * from Log where isSend=0 and isTestMode=%d limit 0,50",theApp.m_bTestMode);
	CFunction fun;
	CDataTable dt;
	pSqliteHelper->ExecuteQueryTable(sql, dt);
	
	if (dt.Rows.Count>0)
	{
		for (int i = 0; i<dt.Rows.Count; i++)
		{
			Log_Data data;
			data.id = dt.Rows[i][0];
			data.strData = dt.Rows[i][1];
			data.bSend = _ttoi(dt.Rows[i][2]);
			//data.strData=fun.UnicodeToUTF8(data.strData);
			Logdata.push_back(data);
		}

	}
}

bool CEventDao::Lock()
{
	return(m_lock.Lock());
}

bool CEventDao::UnLock()
{
	return(m_lock.Unlock());
}

void CEventDao::UpdateStatus( CString id )
{
	CString sql;
	//sql.Format(_T("update Log set isSend=1 where id='%s'"),id);
	sql.Format(_T("delete from Log where id='%s'"),id);
	CDataTable dt;
	pSqliteHelper->ExecuteNonQuery(sql);
}