midware_ws/NetLib/CTI/CdrTrunkCall...

#include "StdAfx.h"
#include "CdrTrunkCallIn.h"
#include "SqlWriter.h"


CCdrTrunkCallIn::CCdrTrunkCallIn(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_nTimeCallIn = 0;
	m_nIsLeaveMsg = 0;
	m_strMsgFileName = _T("");
	m_nIsWantAgent = 0;
	m_nTimeWantAgent = 0;
	m_nIsWantAgentSucceed = 0;
	m_nPeriodWantAgent = 0;
	m_nTimeTurnAgent = 0;
	m_nAgentId = 0;
	m_nPeriodTurnAgent = 0;
	m_nIsTurnAgentSucceed = 0;
	m_nTimeConnected = 0;
	m_nFinalAgentId = 0;
	m_strFinalAgentNum  = _T("");
	m_strRecFileName = _T("");
	m_nTimeHangUp = 0;
	m_nPeriodTalking = 0;
	m_IsSuccess = 1;
	m_FailType = 0;
}


CCdrTrunkCallIn::~CCdrTrunkCallIn(void)
{
}

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

/*****************************************************************
**【函数名称】	__onLineStateChanged
**【函数功能】	线路状态变化响应
**【参数】		nHostLine		主控线路
				tEvtState		线路状态变化事件
**【返回值】	
*****************************************************************/
void CCdrTrunkCallIn::__onLineStateChanged( UINT nHostLine, T_EvtStateChanged* tEvtState )
{
	// 接收并处理 TrunkCallIn表 需要的线路状态
	switch (tEvtState->nLineState)
	{
	case INNER_STATE_TALKING:				// 内线通话中
		{
			// 接通的坐席不一定是被分配的坐席，可能代接，所以这里用主叫区分
			// 在转坐席成功后，可能接听坐席操作转移，主叫仍然不变，所以加上m_nIsTurnAgentSucceed条件
			// ivr直接转坐席没有记录时间
			if (m_nIsTurnAgentSucceed == 0 && m_strCallerNum.Compare(tEvtState->szCallerNum) == 0)
			{
				m_nIsTurnAgentSucceed = 1;											// 转坐席成功
				m_nTimeConnected = time(NULL);										// 坐席接通时间
				m_nPeriodTurnAgent = (UINT)(m_nTimeConnected - m_nTimeTurnAgent);	// 转坐席振铃时长
				m_nFinalAgentId = tEvtState->nAgentId;								// 接听坐席工号
				m_strFinalAgentNum.Format(_T("%d"), nHostLine);						// 接听坐席分机号
			}
		}
		break;

	case TRUNK_STATE_TALKING:				//外转外通话
		{
			if(m_nHostLine != nHostLine)
			{
				ILogger::getInstance().log(LOG_CLASS_BUSI, LOG_LEVEL_NORMAL,_T("{CdrTrunk}:外线呼入转外线接通"));
				m_nTimeConnected = time(NULL);	// 转外线接通时间

				m_nIsWantAgentSucceed = 1;
			}
		}
		break;

	case TRUNK_STATE_FREE:					// 外线挂机
		{
			// 可能有坐席评价，所以中继挂机时记录的通话时长与坐席端的通话时长会不同
			if (m_nHostLine == nHostLine)
			{

				m_nTimeHangUp = time(NULL);																	// 通话结束时间
				m_nPeriodTalking = (m_nTimeConnected == 0) ? 0 : (UINT)(m_nTimeHangUp - m_nTimeConnected);	// 通话时长

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

	case INNER_STATE_FREE:					// 坐席挂机
		{
			// 坐席接通后可能操作转移，所以不以坐席挂机判断通话结束
		}
		break;

	default:
		break;
	} // end switch
}

/*****************************************************************
**【函数名称】	onCallDetail
**【函数功能】	统计事件响应
**【参数】		nEvent			统计事件
				nHostLine		主控线路
				lpParam			统计信息
**【返回值】	
*****************************************************************/
void CCdrTrunkCallIn::onCallDetail( REP_EVENT nEvent, UINT nHostLine, void* lpParam )
{
	// 接收并处理 TrunkCallIn表 需要的事件
	switch (nEvent)
	{
	case REP_EVENT_TRUNK_CALL_IN:			// 中继呼入事件
		{
			T_EvtTrunkCallIn* tEvent = (T_EvtTrunkCallIn*)lpParam;
			m_strCallerNum = tEvent->szCallerNum;		// 主叫号码
			m_strCalleeNum = tEvent->szCalleeNum;		// 被叫号码
			m_nTimeCallIn = time(NULL);					// 呼入中继时间
		}
		break;

	case REP_EVENT_WANT_AGENT:				// 请求坐席
		{
			m_nIsWantAgent = 1;					// 请求坐席
			m_nTimeWantAgent = time(NULL);		// 请求坐席开始时间
		}
		break;

	case REP_EVENT_TURN_AGENT:				// 转坐席
		{
			T_EvtTurnAgent* tEvent = (T_EvtTurnAgent*)lpParam;
			m_nIsWantAgentSucceed = 1;											// 请求坐席成功
			m_nTimeTurnAgent = time(NULL);										// 转坐席开始时间
			m_nPeriodWantAgent = (m_nIsWantAgent == 1) ? (UINT)(m_nTimeTurnAgent - m_nTimeWantAgent) : 0;	// 请求坐席时长
			m_nAgentId = tEvent->nAgentId;										// 被分配坐席工号
		}
		break;

	case REP_EVENT_REC_BEGIN:				// 录音开始事件
		{
			// 中继录音方式(在T_ReportInfo中定义)
			if (m_nHostLine == nHostLine)
			{
				T_EvtRecBegin* tEvent = (T_EvtRecBegin*)lpParam;
				m_strRecFileName = tEvent->szFileName;
			}
		}
		break;

	case REP_EVENT_LEAVE_MSG:				// 留言
		{
			T_EvtLeaveMsg* tEvent = (T_EvtLeaveMsg*)lpParam;
			m_nIsLeaveMsg = 1;							// 外线留言
			m_strMsgFileName = tEvent->szFileName;		// 留言文件路径
		}
		break;

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

	case REP_EVENT_ERROR:					// 呼入过程异常
		{
			T_EvtError* tEvent = (T_EvtError*)lpParam;
			m_IsSuccess = 0;						//记录呼入失败
			m_FailType = tEvent->nErrorType;		//记录失败类型

			ILogger::getInstance().log(LOG_CLASS_BUSI, LOG_LEVEL_WARNING, _T("{CdrTrunk}：外线呼入过程异常,ErrorType = %d！"), tEvent->nErrorType);

		}
		break;
	case REP_EVENT_TRANSFER_TRUNK:
		{
			m_nIsLeaveMsg = 2;				// 转外线留言
			T_EvtIvrCallOut *tEvent = (T_EvtIvrCallOut*)lpParam;
			m_strFinalAgentNum = tEvent->szCalleeNum;
		}
		
		break;
	default:
		break;
	} // end switch
}

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

	Writer.addSql(strSql);

	// 写入 rep_trunk_call_in 中继呼入子表
	if (DB_Oracle == IOtlConnection::getInstance()->GetDatabaseType()) {
		strSql.Format(_T("INSERT INTO REP_TRUNK_CALL_IN (CALLID,ACTIONID,CALLERNUM,CALLEENUM,TIMECALLIN,ISLEAVEMSG,MSGFILENAME,\
					 ISWANTAGENT,TIMEWANTAGENT,ISWANTAGENTSUCCEED,PERIODWANTAGENT,TIMETURNAGENT,ISTURNAGENTSUCCEED,AGENTID,\
					 PERIODTURNAGENT,TIMECONNECTED,FINALAGENTID,FINALEAGENTNUM,RECFILENAME,TIMEHANGUP,PERIODTALKING,ISSUCCESS,FAILTYPE)\
					 VALUES (%lu, %d, '%s', '%s', %s, %d, '%s', %d, %s, %d, %d, %s, %d, %d, %d, %s, %d, '%s', '%s', %s, %d, %d, %d)"),
			m_uCallId,
			m_nActionId,
			m_strCallerNum,
			m_strCalleeNum,

			FormatTime(m_nTimeCallIn),
			m_nIsLeaveMsg,
			m_strMsgFileName,
			m_nIsWantAgent,
			FormatTime(m_nTimeWantAgent),
			m_nIsWantAgentSucceed,
			m_nPeriodWantAgent,
			FormatTime(m_nTimeTurnAgent),
			m_nIsTurnAgentSucceed,
			m_nAgentId,
			m_nPeriodTurnAgent,
			FormatTime(m_nTimeConnected),
			m_nFinalAgentId,
			m_strFinalAgentNum,
			m_strRecFileName,
			FormatTime(m_nTimeHangUp),
			m_nPeriodTalking,
			m_IsSuccess,
			m_FailType
		);
	}else {
		strSql.Format(_T("INSERT INTO rep_trunk_call_in (CallID,ActionID,CallerNum,CalleeNum,TimeCallIn,IsLeaveMsg,MsgFileName,\
					 IsWantAgent,TimeWantAgent,IsWantAgentSucceed,PeriodWantAgent,TimeTurnAgent,IsTurnAgentSucceed,AgentID,\
					 PeriodTurnAgent,TimeConnected,FinalAgentID,FinaleAgentNum,RecFileName,TimeHangUp,PeriodTalking,IsSuccess,FailType)\
					 VALUES (%lu, %d, '%s', '%s', %s, %d, '%s', %d, %s, %d, %d, %s, %d, %d, %d, %s, %d, '%s', '%s', %s, %d, %d, %d)"),
			m_uCallId,
			m_nActionId,
			m_strCallerNum,
			m_strCalleeNum,

			FormatTime(m_nTimeCallIn),
			m_nIsLeaveMsg,
			m_strMsgFileName,
			m_nIsWantAgent,
			FormatTime(m_nTimeWantAgent),
			m_nIsWantAgentSucceed,
			m_nPeriodWantAgent,
			FormatTime(m_nTimeTurnAgent),
			m_nIsTurnAgentSucceed,
			m_nAgentId,
			m_nPeriodTurnAgent,
			FormatTime(m_nTimeConnected),
			m_nFinalAgentId,
			m_strFinalAgentNum,
			m_strRecFileName,
			FormatTime(m_nTimeHangUp),
			m_nPeriodTalking,
			m_IsSuccess,
			m_FailType
		);
	}


	Writer.addSql(strSql);
}