MiddleWare_SLWY/Middleware-S.../CTI/CdrConferenc...

#include "StdAfx.h"
#include "CdrConference.h"
#include "SqlWriter.h"


CCdrConference::CCdrConference(ULONG uCallId, UINT nActionId, UINT nHostLine) : m_uCallId(uCallId), m_nActionId(nActionId), m_nHostLine(nHostLine)
{
	m_bIsActive = TRUE;

	m_nPeerLineType = 0;
	m_nCallerAgentId = 0;
	m_strCallerNum = _T("");
	m_nCalleeAgentId = 0;
	m_strCalleeNum = _T("");
	m_nTimeConference = 0;
	m_nIsConferenceSucceed = 0;
	m_nTimeConnected = 0;
	m_nTimeConferenceEnd = 0;
}


CCdrConference::~CCdrConference(void)
{
}

/*****************************************************************
**【函数名称】	__verifyData
**【函数功能】	数据校验
**【参数】		
**【返回值】	
*****************************************************************/
BOOL CCdrConference::__verifyData()
{
	// 会话销毁时，填充三方结束时间
	if(m_nTimeConferenceEnd == 0) m_nTimeConferenceEnd = time(NULL);

	return TRUE;
}

/*****************************************************************
**【函数名称】	onCallDetail
**【函数功能】	统计事件响应
**【参数】		nEvent			统计事件
				nHostLine		主控线路
				lpParam			统计信息
**【返回值】	
*****************************************************************/
void CCdrConference::onCallDetail( REP_EVENT nEvent, UINT nHostLine, void* lpParam )
{
	// 接收并处理 Conference表 需要的事件
	switch (nEvent)
	{
	case REP_EVENT_CONFERENCE:			// 会议事件
		{
			if(nHostLine != m_nHostLine) return;

			T_EvtConference* tEvent = (T_EvtConference*)lpParam;
			m_nCallerAgentId = tEvent->nCallerAgentId;		// 主叫坐席工号
			m_strCallerNum.Format(_T("%d"), nHostLine);		// 主叫号码
			m_nCalleeAgentId = tEvent->nCalleeAgentId;		// 被叫坐席工号
			m_strCalleeNum = tEvent->szCalleeNum;			// 被叫号码
			m_nTimeConference = time(NULL);					// 发起会议时间
			m_nTimeConnected = time(NULL);					// 接通时间
			m_nPeerLineType = tEvent->nPeerLineType;		// 对端线路类型
		}
		break;

	case REP_EVENT_CONF_RESULT:			// 三方结束事件
		{
			if(nHostLine != m_nHostLine) return;

			T_EvtConference* tEvent = (T_EvtConference*)lpParam;
			m_nTimeConferenceEnd = time(NULL);				// 记录结束时间
			if(tEvent->bEvtResult)
			{
				m_nIsConferenceSucceed = 1;					// 会议成功
			}

			// 提交数据
			toSql();										
		}
		break;
	default:
		break;
	} // end switch
}

/*****************************************************************
**【函数名称】	toSql
**【函数功能】	更新数据库表数据
**【参数】		
**【返回值】	
*****************************************************************/
void CCdrConference::toSql()
{
	// 表被关闭，不再更新数据
	if (!m_bIsActive) return;

	// 数据校验（有关键数据未填写且不适合自动填充时，返回失败）
	if (__verifyData())
		m_bIsActive = FALSE;
	else
		return;

	// 写入 rep_host 主表
	CSqlWriter& Writer = CSqlWriter::GetInstance();
	CString strSql = _T("");
	strSql.Format(_T("INSERT INTO rep_host (CallID, ActionID, CallTypeOpType, HostLine, CallerNum, CalleeNum, TimeConnected, TimeHangUp)\
					 VALUES (%lu, %d, %d, %d, '%s', '%s', %s, %s)"),
					 m_uCallId,
					 m_nActionId,
					 REP_EVENT_CONFERENCE,
					 m_nHostLine,
					 m_strCallerNum,
					 m_strCalleeNum,
					 FormatTime(m_nTimeConnected),
					 FormatTime(0)
					 );

	Writer.addSql(strSql);

	// 写入 rep_conference 会议子表
	strSql.Format(_T("INSERT INTO rep_conference (CallID,ActionID,PeerLineType,CallerAgentID,CallerNum,CalleeAgentID,CalleeNum,\
					 TimeConference,IsConferenceSucceed,TimeConnected,TimeConferenceEnd)\
					 VALUES (%lu, %d, %d, %d, '%s', %d, '%s', %s, %d, %s, %s)"),
					 m_uCallId,
					 m_nActionId,
					 m_nPeerLineType,
					 m_nCallerAgentId,
					 m_strCallerNum,
					 m_nCalleeAgentId,
					 m_strCalleeNum,
					 FormatTime(m_nTimeConference),
					 m_nIsConferenceSucceed,
					 FormatTime(m_nTimeConnected),
					 FormatTime(m_nTimeConferenceEnd)
					 );
	Writer.addSql(strSql);
}