#include "StdAfx.h"
#include "CdrExtCallOut.h"
#include "SqlWriter.h"


CCdrExtCallOut::CCdrExtCallOut(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_strCallerNum = _T("");
	m_nCallerAgentId = 0;
	m_strCalleeNum = _T("");
	m_nCalleeAgentId = 0;
	m_nTimeRingBack = 0;
	m_nIsCallOutSucceed = 0;
	m_nTimeConnected = 0;
	m_nFinalAgentId = 0;
	m_strFinalAgentNum = _T("");
	m_strRecFileName = _T("");
	m_nTimeHangUp = 0;
	m_nPeriodTalking = 0;
	m_sVisit = "";
	m_nEventId = REP_EVENT_EXT_CALL_OUT;
}


CCdrExtCallOut::~CCdrExtCallOut(void)
{
}

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

/*****************************************************************
**【函数名称】	__onLineStateChanged
**【函数功能】	线路状态变化响应
**【参数】		nHostLine		主控线路
				tEvtState		线路状态变化事件
**【返回值】
*****************************************************************/
void CCdrExtCallOut::__onLineStateChanged(UINT nHostLine, T_EvtStateChanged* tEvtState)
{
	// 接收并处理 ExtCallOut表 需要的线路状态
	switch (tEvtState->nLineState)
	{
	case INNER_STATE_TALKING:				// 内线通话中
	{
		// 接听坐席不一定是被叫，可能被代接，以主叫为标志区分
		// 接听成功后可能有转移操作
		if (m_nHostLine == nHostLine)
		{
			if (m_nIsCallOutSucceed == 0)
			{
				m_nIsCallOutSucceed = 1;								// 呼出成功
				m_nTimeConnected = time(NULL);							// 接通时间
			}
		}
		else
		{
			if (m_nFinalAgentId == 0 && m_nPeerLineType == DEV_RES_TYPE_EXT)
			{
				m_nFinalAgentId = tEvtState->nAgentId;					// 接听坐席工号
				m_strFinalAgentNum.Format(_T("%d"), nHostLine);			// 接听坐席分机号
			}
		}
	}
	break;

	case INNER_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 CCdrExtCallOut::onCallDetail(REP_EVENT nEvent, UINT nHostLine, void* lpParam)
{
	// 接收并处理 ExtCallOut表 需要的事件
	switch (nEvent)
	{
	case REP_EVENT_EXT_CALL_OUT:			// 坐席呼出事件
	{
		T_EvtExtCallOut* tEvent = (T_EvtExtCallOut*)lpParam;
		m_nCallType = tEvent->nCallType;						// 呼出方式
		m_nPeerLineType = tEvent->nPeerLineType;				// 被叫线路类型
		m_nCallerAgentId = tEvent->nCallerAgentId;				// 主叫坐席工号
		m_strCallerNum.Format(_T("%d"), nHostLine);				// 主叫号码
		m_nCalleeAgentId = tEvent->nCalleeAgentId;				// 被叫坐席工号

		CString CalleeHeader = tEvent->szCalleeHeader;           //号码前缀
		m_strCalleeNum = tEvent->szCalleeNum;					// 被叫号码
		if (0 != strcmp(CalleeHeader, ""))                       //如果有号码前缀，则剔除前缀保存真实号码
		{
			m_strCalleeNum = m_strCalleeNum.Mid(CalleeHeader.GetLength(), m_strCalleeNum.GetLength());
		}

		m_sVisit = tEvent->szVisitstr;






		m_nTimeRingBack = time(NULL);							// 呼出振铃时间
	}
	break;

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

	case REP_EVENT_HANG_UP:					// 挂机事件
	{
		if (m_nHostLine == 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* tEvtState = (T_EvtStateChanged*)lpParam;
		__onLineStateChanged(nHostLine, tEvtState);
	}
	break;

	default:
		break;
	} // end switch
}

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

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

	// 写入 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_OUT,
			m_nHostLine,
			m_strCallerNum,
			m_strCalleeNum,
			FormatTime(m_nTimeConnected),
			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_OUT,
			m_nHostLine,
			m_strCallerNum,
			m_strCalleeNum,
			FormatTime(m_nTimeConnected),
			FormatTime(m_nTimeHangUp)
		);
	}

	Writer.addSql(strSql);

	CString TaskType = m_sVisit.Mid(0, m_sVisit.Find('|'));
	CString VisitLeft = m_sVisit.Mid(m_sVisit.Find('|') + 1, m_sVisit.GetLength());

	CString TaskPhoneID = VisitLeft.Mid(0, VisitLeft.Find('|'));

	CString TaskID = VisitLeft.Mid(VisitLeft.Find('|') + 1, VisitLeft.GetLength());                //回访字符串解析

	if (DB_Oracle == IOtlConnection::getInstance()->GetDatabaseType()) {
		strSql.Format(_T("INSERT INTO REP_EXT_CALL_OUT (CALLID,ACTIONID,CALLTYPE,PEERLINETYPE,CALLERAGENTID,CALLERNUM,CALLEEAGENTID,CALLEENUM, TIMERINGBACK,ISCALLOUTSUCCEED,TIMECONNECTED,FINALAGENTID,FINALAGENTNUM,RECFILENAME,TIMEHANGUP,PERIODTALKING,TASKTYPE,TASKPHONEID,TASKID)   VALUES  (%lu, %d, %d, %d, %d, '%s', %d, '%s', %s, %d, %s, %d, '%s', '%s', %s, %d,'%s','%s','%s')"),
			m_uCallId,
			m_nActionId,
			m_nCallType,
			m_nPeerLineType,
			m_nCallerAgentId,
			m_strCallerNum,
			m_nCalleeAgentId,
			m_strCalleeNum,
			FormatTime(m_nTimeRingBack),
			m_nIsCallOutSucceed,
			FormatTime(m_nTimeConnected),
			m_nFinalAgentId,
			m_strFinalAgentNum,
			m_strRecFileName,
			FormatTime(m_nTimeHangUp),
			m_nPeriodTalking,
			TaskType,
			TaskPhoneID,
			TaskID
		);
	}
	else {
		strSql.Format(_T("INSERT INTO rep_ext_call_out (CallID,ActionID,CallType,PeerLineType,CallerAgentID,CallerNum,CalleeAgentID,CalleeNum,\
					 TimeRingBack,IsCallOutSucceed,TimeConnected,FinalAgentId,FinalAgentNum,RecFileName,TimeHangUp,PeriodTalking,TaskType,TaskPhoneID,TaskID)\
					 VALUES (%lu, %d, %d, %d, %d, '%s', %d, '%s', %s, %d, %s, %d, '%s', '%s', %s, %d,'%s','%s','%s')"),
			m_uCallId,
			m_nActionId,
			m_nCallType,
			m_nPeerLineType,
			m_nCallerAgentId,
			m_strCallerNum,
			m_nCalleeAgentId,
			m_strCalleeNum,
			FormatTime(m_nTimeRingBack),
			m_nIsCallOutSucceed,
			FormatTime(m_nTimeConnected),
			m_nFinalAgentId,
			m_strFinalAgentNum,
			m_strRecFileName,
			FormatTime(m_nTimeHangUp),
			m_nPeriodTalking,
			TaskType,
			TaskPhoneID,
			TaskID
		);
	}
	
	Writer.addSql(strSql);
}