#include "StdAfx.h"
#include "CdrIvrCallOut.h"
#include "SqlWriter.h"


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

	m_strCallerNum = _T("");
	m_strCalleeNum = _T("");
	m_nTimeRingBack = 0;
	m_nIsCallOutSucceed = 0;
	m_nTimeConnected = 0;
	m_nTimeHangUp = 0;
	m_nPeriodTalking = 0;
}


CCdrIvrCallOut::~CCdrIvrCallOut(void)
{
}

/*****************************************************************
**【函数名称】	__VerifyData
**【函数功能】	数据校验
**【参数】		
**【返回值】	
*****************************************************************/
BOOL CCdrIvrCallOut::__verifyData()
{
	return TRUE;
}

/*****************************************************************
**【函数名称】	__onLineStateChanged
**【函数功能】	线路状态变化响应
**【参数】		nHostLine		主控线路
				tEvtState		线路状态变化事件
**【返回值】	
*****************************************************************/
void CCdrIvrCallOut::__onLineStateChanged( UINT nHostLine, T_EvtStateChanged* tEvtState )
{
	// 接收并处理 IvrCallOut表 需要的线路状态
	switch (tEvtState->nLineState)
	{
	case TRUNK_STATE_TALKING:				// 外线通话中
		{
			if (nHostLine == m_nHostLine)
			{
				m_nIsCallOutSucceed = 1;			// 自动外呼成功
				m_nTimeConnected = time(NULL);		// 接通时间
			}
		}
		break;

	case TRUNK_STATE_FREE:					// 外线挂机
		{
			if (m_nHostLine = nHostLine)
			{
				m_nTimeHangUp = time(NULL);			// 通话结束时间
				m_nPeriodTalking = (m_nIsCallOutSucceed == 1) ? (UINT)(m_nTimeHangUp - m_nTimeConnected) : 0;		// 通话时长

				// 更新数据
				toSql();
			}
		}
		break;

	default:
		break;
	} // end switch
}

/*****************************************************************
**【函数名称】	onCallDetail
**【函数功能】	统计事件响应
**【参数】		nEvent			统计事件
				nHostLine		主控线路
				lpParam			统计信息
**【返回值】	
*****************************************************************/
void CCdrIvrCallOut::onCallDetail( REP_EVENT nEvent, UINT nHostLine, void* lpParam )
{
	// 接收并处理 IvrCallOut表 需要的事件
	switch (nEvent)
	{
	case REP_EVENT_IVR_CALL_OUT:			// 自动外呼事件
		{
			T_EvtIvrCallOut* tEvent = (T_EvtIvrCallOut*)lpParam;
			m_strCallerNum.Format(_T("%d"), nHostLine);		// 主叫号码
			m_strCalleeNum = tEvent->szCalleeNum;			// 被叫号码
			m_nTimeRingBack = time(NULL);					// 呼出振铃时间
		}
		break;

	case REP_EVENT_HANG_UP:					// 挂机事件
		{
			if (nHostLine == m_nHostLine)
			{
				m_nTimeHangUp = time(NULL);			// 通话结束时间
				m_nPeriodTalking = (m_nIsCallOutSucceed == 1) ? (UINT)(m_nTimeHangUp - m_nTimeConnected) : 0;		// 通话时长

				// 更新数据
				toSql();
			}
		}
		break;

	case REP_EVENT_STATE_CHANGED:			// 线路变化事件
		{
			T_EvtStateChanged* tEvent = (T_EvtStateChanged*)lpParam;
			__onLineStateChanged(nHostLine, tEvent);
		}
		break;

	default:
		break;
	} // end switch
}

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

	Writer.addSql(strSql);

	// 写入 rep_ivr_call_out 自动外呼子表
	strSql.Format(_T("INSERT INTO rep_ivr_call_out (CallID,ActionID,HostLine,CallerNum,CalleeNum,TimeRingBack,IsCallOutSucceed,TimeConnected,TimeHangUp,PeriodTalking)\
					 VALUES (%lu, %d, %d, '%s', '%s', %s, %d, %s, %s, %d)"),
					 m_uCallId,
					 m_nActionId,
					 m_nHostLine,
					 m_strCallerNum,
					 m_strCalleeNum,
					 FormatTime(m_nTimeRingBack),
					 m_nIsCallOutSucceed,
					 FormatTime(m_nTimeConnected),
					 FormatTime(m_nTimeHangUp),
					 m_nPeriodTalking
					 );
	Writer.addSql(strSql);
}