Middleware_5.1/CTI/TaskAgentCal...

#include "stdafx.h"
#include "TaskAgentCall.h"
#include "LineHolder.h"
#include "LogicLine.h"
#include "LogicLineExt.h"
#include "StatisticsMgr.h"
#include "CtiCore.h"

CTaskAgentCall::CTaskAgentCall(CPduEntity &PduEntity) : CTask(PduEntity)
{
	m_HeadNumber="";
	m_VisitStr="";
}


CTaskAgentCall::~CTaskAgentCall(void)
{
}

/*****************************************************************
**【函数名称】	DoTask
**【函数功能】	Task处理
**【参数】		
**【返回值】		void
****************************************************************/
BOOL CTaskAgentCall::DoTask()
{
	// 显示日志
	ShowLog();
	
	// 校验
	if(!Verify()) return FALSE;

	// 设置当前操作类型
	m_pCurrLine->opType() = PDU_CMD_AGENT_MAKECALL;

	// 向底层设备发送外呼命令
	LineOpParam pLineOpParam;
	memset(&pLineOpParam, 0, sizeof(pLineOpParam));
	lstrcpy(pLineOpParam.szParam1, m_CurrCmd.GetDataString(5));
	lstrcpy(pLineOpParam.szParam2, m_CurrCmd.GetDataString(4));
	m_HeadNumber= m_CurrCmd.GetDataString(7);
	m_VisitStr  = m_CurrCmd.GetDataString(8);
	return CCtiCore::GetInstance().getDevLink().exec((long)this, LINE_OP_MAKE_CALL,  m_pCurrLine->lineId(), &pLineOpParam);
}

/*****************************************************************
**【函数名称】	Verify
**【函数功能】	校验
**【参数】		
**【返回值】	BOOL
****************************************************************/
BOOL CTaskAgentCall::Verify()
{
	// 获取对端线路
	int nAssoLineId;
	sscanf_s(m_CurrCmd.GetDataString(4).GetBuffer(), "%d", &nAssoLineId);
	CLogicLine *pAssoLine = CLineHolder::GetInstance().getLogicLine(nAssoLineId);
	
	// 设置返回命令外呼类型(0呼外线，1呼坐席)
	if(pAssoLine == NULL) 
		m_CurrCmd.SetDataUInt(6, 0);
	else
		m_CurrCmd.SetDataUInt(6, pAssoLine->type() == DEV_RES_TYPE_EXT ? 1:0);

	// 线路绑定校验
	if(!_bindLogicLine(m_CurrCmd.GetDataUInt(1))) 
		return FALSE;

	// 本端状态校验
	if((m_pCurrLine->status() & 0xFF) != INNER_STATE_INIT && (m_pCurrLine->status() & 0xFF) != INNER_STATE_FREE) 
	{
		ILogger::getInstance().log(LOG_CLASS_BUSI, LOG_LEVEL_WARNING, _T("{Task}: 线路[%d]执行座席呼叫任务校验时失败：当前线路忙"), m_pCurrLine->lineId());
		return FALSE;
	}

	// 对端线路状态验证
	if(pAssoLine != NULL &&  pAssoLine->type() == DEV_RES_TYPE_EXT &&
		pAssoLine->status() != INNER_STATE_INIT &&
		pAssoLine->status() != INNER_STATE_FREE)
	{
		ILogger::getInstance().log(LOG_CLASS_BUSI, LOG_LEVEL_WARNING, _T("{Task}: 线路[%d]执行座席呼叫任务校验时失败：关联线路状态校验不通过"), m_pCurrLine->lineId());
		return FALSE;
	}

	return TRUE;
}

/*****************************************************************
**【函数名称】	ShowLog
**【函数功能】	显示日志
**【参数】		
**【返回值】		void
****************************************************************/
void CTaskAgentCall::ShowLog()
{
	// 显示日志
	ILogger::getInstance().log(LOG_CLASS_SOCKET, LOG_LEVEL_NORMAL, _T("AGENT->CTI, CMD = [座席呼叫], \
				Exten = %d, DestNum = %s"),	m_CurrCmd.GetDataUInt(1), m_CurrCmd.GetDataString(4));
}

/*****************************************************************
**【函数名称】	ProcLineOpProcess
**【函数功能】	处理设备操作进展
**【参数】		EvtType 消息事件类型；lpContent 消息内容
**【返回值】		void
****************************************************************/
void CTaskAgentCall::OnDevOpProcess(EventOpProcess &EvtInfo)
{	
	// 处理会话
	_PrcoCallNode(m_pCurrLine->lineId(), EvtInfo.nAssoLine);

	// 获取对端线路
	CLogicLine *pAssoLine = CLineHolder::GetInstance().getLogicLine(EvtInfo.nAssoLine);
	if(pAssoLine == NULL) return;

	// 统计 REP_EVENT_EXT_CALL_OUT
	T_EvtExtCallOut repInfoCallOut;
	memset(&repInfoCallOut, 0, sizeof(repInfoCallOut));
	repInfoCallOut.nCallType = 0;													// 呼出方式（0：ocx外呼，1：话机外呼）
	repInfoCallOut.nPeerLineType = EvtInfo.nAssoLineType;							// 对端线路类型
	repInfoCallOut.nCallerAgentId = m_pCurrLine->getAgentNum();						// 主叫坐席工号			
	repInfoCallOut.nCalleeAgentId = pAssoLine->getAgentNum();						// 被叫坐席工号
	lstrcpy(repInfoCallOut.szCalleeNum, m_CurrCmd.GetDataString(4));				// 被叫号码
	lstrcpy(repInfoCallOut.szCalleeHeader,m_HeadNumber);                              // 号码前缀
	lstrcpy(repInfoCallOut.szVisitstr,m_VisitStr);                                  //回访字符串
	CStatisticsMgr::GetInstance().onCallDetail(m_pCurrLine->callId(), REP_EVENT_EXT_CALL_OUT, m_pCurrLine->lineId(), &repInfoCallOut);

	// 统计REP_EVENT_EXT_CALL_IN
	T_EvtExtCallIn repInfoCallIn;
	if(pAssoLine->type() != DEV_RES_TYPE_EXT) return;
	memset(&repInfoCallIn, 0, sizeof(repInfoCallIn));
	repInfoCallIn.nCallType = 0;									// 呼入方式（0:坐席呼入 1：转坐席呼入，2：转移呼入，3：会议呼入）
	repInfoCallIn.nPeerLineType = m_pCurrLine->type();				// 对端线路类型
	repInfoCallIn.nCallerAgentId = m_pCurrLine->getAgentNum();		// 主叫坐席工号
	lstrcpy(repInfoCallIn.szCallerNum, EvtInfo.szCallerNum);		// 主叫号码
	repInfoCallIn.nCalleeAgentId = pAssoLine->getAgentNum();		// 被叫坐席工号
	CStatisticsMgr::GetInstance().onCallDetail(pAssoLine->callId(), REP_EVENT_EXT_CALL_IN, pAssoLine->lineId(), &repInfoCallIn);
}