#include "StdAfx.h"
#include "CdrExtCallIn.h"
#include "SqlWriter.h"


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

	m_nCallType = 0;
	m_nPeerLineType = 0;
	m_nCallerAgentId = 0;
	m_strCallerNum = _T("");
	m_nCalleeAgentId = 0;
	m_strCalleeNum = _T("");
	m_nTimeAlerting = 0;
	m_nIsAnswer = 0;
	m_nPeriodAlerting = 0;
	m_nTimeAnswer = 0;
	m_strRecFileName = _T("");
	m_nTimeHangUp = 0;
	m_nPeriodTalking = 0;
	m_nEventId = REP_EVENT_EXT_CALL_IN;
}


CCdrExtCallIn::~CCdrExtCallIn(void)
{
}

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

/*****************************************************************
**【函数名称】	OnLineStateChanged
**【函数功能】	线路状态变化响应
**【参数】		nHostLine		主控线路
				tEvtState		线路状态变化事件
**【返回值】	
*****************************************************************/
void CCdrExtCallIn::__onLineStateChanged( UINT nHostLine, T_EvtStateChanged* tEvtState )
{
	// 接收并处理 ExtCallIn表 需要的线路状态
	switch (tEvtState->nLineState)
	{
	case INNER_STATE_TALKING:				// 内线通话中
		{
			if (m_nHostLine == nHostLine && m_nIsAnswer == 0)
			{
				m_nIsAnswer = 1;												// 坐席应答
				m_nTimeAnswer = time(NULL);										// 应答时间
				m_nPeriodAlerting = (UINT)(m_nTimeAnswer - m_nTimeAlerting);	// 振铃时长
			}
		}
		break;

	case INNER_STATE_FREE:					// 内线挂机
		{
			if (m_nHostLine == nHostLine)
			{
				m_nTimeHangUp = time(NULL);										// 挂机时间

				if (m_nIsAnswer == 0)	// 未接听挂机
				{
					m_nPeriodTalking = 0;
					m_nPeriodAlerting = (UINT)(m_nTimeHangUp - m_nTimeAlerting);
				}
				else
				{
					m_nPeriodTalking = (UINT)(m_nTimeHangUp - m_nTimeAnswer);	// 通话时长
				}

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

	default:
		break;
	} // end switch
}

/*****************************************************************
**【函数名称】	onCallDetail
**【函数功能】	统计事件响应
**【参数】		nEvent			统计事件
				nHostLine		主控线路
				lpParam			统计信息
**【返回值】	
*****************************************************************/
void CCdrExtCallIn::onCallDetail( REP_EVENT nEvent, UINT nHostLine, void* lpParam )
{
	// 接收并处理 ExtCallIn表 需要的事件
	switch (nEvent)
	{
	case REP_EVENT_EXT_CALL_IN:				// 坐席呼入事件
		{
			if (nHostLine == m_nHostLine)
			{
				T_EvtExtCallIn* tEvent = (T_EvtExtCallIn*)lpParam;
				m_nCallType = tEvent->nCallType;					// 呼入类型
				m_nPeerLineType = tEvent->nPeerLineType;			// 对端线路类型
				m_nCallerAgentId = tEvent->nCallerAgentId;			// 主叫坐席工号
				m_strCallerNum = tEvent->szCallerNum;				// 主叫号码
				m_nCalleeAgentId = tEvent->nCalleeAgentId;			// 被叫坐席工号
				m_strCalleeNum.Format(_T("%d"), nHostLine);			// 被叫号码
				m_nTimeAlerting = time(NULL);						// 来电振铃时间
			}
		}
		break;

	case REP_EVENT_REC_BEGIN:				// 录音开始事件
		{
			if (m_nHostLine == nHostLine)
			{
				T_EvtRecBegin* tEvent = (T_EvtRecBegin*)lpParam;
				m_strRecFileName = tEvent->szFileName;			// 录音文件路径
			}
		}
		break;

	case REP_EVENT_HANG_UP:					// 挂机事件
		{
			if (m_nHostLine == nHostLine)
			{
				m_nTimeHangUp = time(NULL);										// 坐席挂机时间
				m_nPeriodTalking = (m_nIsAnswer == 1) ? (UINT)(m_nTimeHangUp - m_nTimeAnswer) : 0;		// 通话时长

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

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

	default:
		break;
	} // end switch
}

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

	// 数据校验（有关键数据未填写且不适合自动填充时，返回失败）
	if (__verifyData())
		m_bIsActive = FALSE;
	else
		return;
	ILogger::getInstance().log(LOG_CLASS_SOCKET, LOG_LEVEL_NORMAL, _T("CCdrExtCallIn   m_nActionId=%d  m_bIsActive =%d"), m_nActionId,m_bIsActive);

	// 写入 rep_host 主表
	CSqlWriter& Writer = CSqlWriter::GetInstance();
	CString strSql = _T("");
	if (DB_Oracle == IOtlConnection::getInstance()->GetDatabaseType()) {
		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_EXT_CALL_IN,
			m_nHostLine,
			m_strCallerNum,
			m_strCalleeNum,
			FormatTime(m_nTimeAnswer),
			FormatTime(m_nTimeHangUp)
		);
	}
	else {
			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_EXT_CALL_IN,
				m_nHostLine,
				m_strCallerNum,
				m_strCalleeNum,
				FormatTime(m_nTimeAnswer),
				FormatTime(m_nTimeHangUp)
			);
	}
	
	Writer.addSql(strSql);		// 在坐席未接听的情况下重复转坐席 actionID累加，相当于多次呼入，所以主表同样插入记录

	if (DB_Oracle == IOtlConnection::getInstance()->GetDatabaseType()) {
		strSql.Format(_T("INSERT INTO REP_EXT_CALL_IN (CALLID,ACTIONID,CALLTYPE,PEERLINETYPE,CALLERAGENTID,CALLERNUM,CALLEEAGENTID, CALLEENUM,TIMEALERTING,PERIODALERTING,ISANSWER,TIMEANSWER,RECFILENAME,TIMEHANGUP,PERIODTALKING) VALUES  (%lu, %d, %d, %d, %d, '%s', %d, '%s', %s, %d, %d, %s, '%s', %s, %d)"),
			m_uCallId,
			m_nActionId,
			m_nCallType,
			m_nPeerLineType,
			m_nCallerAgentId,
			m_strCallerNum,
			m_nCalleeAgentId,
			m_strCalleeNum,
			FormatTime(m_nTimeAlerting),
			m_nPeriodAlerting,
			m_nIsAnswer,
			FormatTime(m_nTimeAnswer),
			m_strRecFileName,
			FormatTime(m_nTimeHangUp),
			m_nPeriodTalking
		);
	}else {
		strSql.Format(_T("INSERT INTO rep_ext_call_in (CallID,ActionID,CallType,PeerLineType,CallerAgentID,CallerNum,CalleeAgentID,\
					 CalleeNum,TimeAlerting,PeriodAlerting,IsAnswer,TimeAnswer,RecFileName,TimeHangUp,PeriodTalking)\
					 VALUES (%lu, %d, %d, %d, %d, '%s', %d, '%s', %s, %d, %d, %s, '%s', %s, %d)"),
			m_uCallId,
			m_nActionId,
			m_nCallType,
			m_nPeerLineType,
			m_nCallerAgentId,
			m_strCallerNum,
			m_nCalleeAgentId,
			m_strCalleeNum,
			FormatTime(m_nTimeAlerting),
			m_nPeriodAlerting,
			m_nIsAnswer,
			FormatTime(m_nTimeAnswer),
			m_strRecFileName,
			FormatTime(m_nTimeHangUp),
			m_nPeriodTalking
		);
	
	}
	
	Writer.addSql(strSql);
}