Middleware_5.1/CTI/CdrTransfer....

#include "StdAfx.h"
#include "CdrTransfer.h"
#include "SqlWriter.h"


CCdrTransfer::CCdrTransfer(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_nTimeTransferBegin = 0;
	m_nIsTransferSucceed = 0;
	m_nTimeConnected = 0;
	m_nTimeTransferEnd = 0;
	m_nTimeTransferSuccess = 0;
}


CCdrTransfer::~CCdrTransfer(void)
{
}

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

	return TRUE;
}

/*****************************************************************
**【函数名称】	onCallDetail
**【函数功能】	统计事件响应
**【参数】		nEvent			统计事件
				nHostLine		主控线路
				lpParam			统计信息
**【返回值】	
*****************************************************************/
void CCdrTransfer::onCallDetail( REP_EVENT nEvent, UINT nHostLine, void* lpParam )
{
	// 接收并处理 Transfer表 需要的事件
	switch (nEvent)
	{
	case REP_EVENT_TRANSFER:				// 转移事件
		{
			if (nHostLine != m_nHostLine) return;
			T_EvtTransfer* tEvent = (T_EvtTransfer*)lpParam;
			m_nCallerAgentId = tEvent->nCallerAgentId;		// 主叫坐席工号
			m_strCallerNum = tEvent->szCallerNum;			// 主叫号码
			m_nCalleeAgentId = tEvent->nCalleeAgentId;		// 被叫坐席工号
			m_strCalleeNum = tEvent->szCalleeNum;			// 被叫号码
			m_nTimeTransferBegin = time(NULL);				// 转移开始时间
			m_nPeerLineType = tEvent->nPeerLineType;			// 对端线路类型
		}
		break;

	case REP_EVENT_CONSUL_RESULT:		// 协商呼叫成功
		{
			if (nHostLine != m_nHostLine) return;
			m_nTimeConnected = time(NULL);					// 接通时间
		}
		break;

	case REP_EVENT_TRANSFER_RESULT:		// 转移结果事件
		{
			if (nHostLine != m_nHostLine) return;
			T_EvtTransfer* tEvent = (T_EvtTransfer*)lpParam;
			if(tEvent->bEvtResult)
			{
				m_nIsTransferSucceed = tEvent->bEvtResult;		// 转移成功
				m_nTimeTransferSuccess = time(NULL);			// 转移成功时间
				if(m_nTimeConnected == 0) 
					m_nTimeConnected = time(NULL);				// 呼通通话时间
			}
			m_nTimeTransferEnd = time(NULL);					// 转移结束时间
			toSql();											// 提交数据
		}
		break;
	default:
		break;
	} // end switch
}

/*****************************************************************
**【函数名称】	toSql
**【函数功能】	更新数据库表数据
**【参数】		
**【返回值】	
*****************************************************************/
void CCdrTransfer::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_TRANSFER,
					 m_nHostLine,
					 m_strCallerNum,
					 m_strCalleeNum,
					 FormatTime(m_nTimeConnected),
					 FormatTime(0)
					 );

	Writer.addSql(strSql);

	// 写入 rep_transfer 转移子表
	strSql.Format(_T("INSERT INTO rep_transfer (CallId,ActionID,PeerLineType,CallerAgentID,CallerNum,CalleeAgentID,CalleeNum,TimeBeginTransfer,\
					 IsTransferSucceed,TimeConnected,TimeTransferSucceed,TimeEndTransfer)\
					 VALUES (%lu, %d, %d, %d, '%s', %d, '%s', %s, %d, %s, %s, %s)"),
					 m_uCallId,
					 m_nActionId,
					 m_nPeerLineType,
					 m_nCallerAgentId,
					 m_strCallerNum,
					 m_nCalleeAgentId,
					 m_strCalleeNum,
					 FormatTime(m_nTimeTransferBegin),
					 m_nIsTransferSucceed,
					 FormatTime(m_nTimeConnected),
					 FormatTime(m_nTimeTransferSuccess),
					 FormatTime(m_nTimeTransferEnd)
					 );
	Writer.addSql(strSql);
}