Middleware_5.1/CTI/TaskAgentCon...

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


CTaskAgentConsulCall::CTaskAgentConsulCall(CPduEntity &PduEntity): CTask(PduEntity), m_OpStep(0)
{
}


CTaskAgentConsulCall::~CTaskAgentConsulCall(void)
{
}

/*****************************************************************
**【函数名称】	DoTask
**【函数功能】	Task处理
**【参数】		
**【返回值】		void
****************************************************************/
BOOL CTaskAgentConsulCall::DoTask()
{
	// 显示日志
	ShowLog();

	// 校验
	if(!Verify()) return FALSE;
	
	// 设置当前操作类型
	m_pCurrLine->opType() = PDU_CMD_AGENT_CONSULTATION_CALL;

	// 向底层设备发送协商呼叫操作
	LineOpParam Param;
	memset(&Param, 0, sizeof(Param));
	lstrcpy(Param.szParam1, m_CurrCmd.GetDataString(5));
	lstrcpy(Param.szParam2, m_CurrCmd.GetDataString(4));
	return CCtiCore::GetInstance().getDevLink().exec((long)this, LINE_OP_CONSULT_CALL_BEGIN,  m_pCurrLine->lineId(), &Param);
}

/*****************************************************************
**【函数名称】	Verify
**【函数功能】	校验
**【参数】		
**【返回值】	BOOL
****************************************************************/
BOOL CTaskAgentConsulCall::Verify()
{
	// 线路绑定校验
	if(!_bindLogicLine(m_CurrCmd.GetDataUInt(1))) 
		return FALSE;

	// 本端状态校验
	if(m_pCurrLine->status() != INNER_STATE_TALKING)
	{
		ILogger::getInstance().log(LOG_CLASS_BUSI, LOG_LEVEL_WARNING, _T("{Task}: 线路[%d]执行座席协商呼叫任务校验时失败：当前线路未在通话中"), m_pCurrLine->lineId());
		return FALSE;
	}

	return TRUE;
}

/*****************************************************************
**【函数名称】	ShowLog
**【函数功能】	显示日志
**【参数】		
**【返回值】		void
****************************************************************/
void CTaskAgentConsulCall::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));
}

/*****************************************************************
**【函数名称】	OnDevOpProcess
**【函数功能】	处理设备操作进展
**【参数】		EvtType 消息事件类型；lpContent 消息内容
**【返回值】		void
****************************************************************/
void CTaskAgentConsulCall::OnDevOpProcess(EventOpProcess &EvtInfo)
{
	// 获取对端线路
	CLogicLine *pAssoLine = CLineHolder::GetInstance().getLogicLine(EvtInfo.nAssoLine);
	if(pAssoLine == NULL) return;

	// 处理会话
	_PrcoCallNode(m_pCurrLine->lineId(), EvtInfo.nAssoLine);

	// 获取主叫的工号
	CLogicLine *pCallerLine = CLineHolder::GetInstance().getLogicLine(atoi(EvtInfo.szCallerNum));
	UINT nCallerAgentId = (pCallerLine == NULL ? 0 : pCallerLine->getAgentNum());

	UINT nCurrLineId = m_pCurrLine->lineId();

	// 统计转移 REP_EVENT_TRANSFER
	T_EvtTransfer repInfoTransfer;
	memset(&repInfoTransfer, 0, sizeof(repInfoTransfer));
	repInfoTransfer.nPeerLineType = pAssoLine->type();					// 对端线路类型
	//lstrcpy(repInfoTransfer.szCallerNum, EvtInfo.szCallerNum);		// 主叫号码	
	//repInfoTransfer.nCallerAgentId = nCallerAgentId;					// 主叫工号
	sprintf_s(repInfoTransfer.szCallerNum, "%lu", nCurrLineId);			// 转移表中主叫号码为发起转移者的号码
	repInfoTransfer.nCallerAgentId = m_pCurrLine->getAgentNum();		// 主叫工号
	repInfoTransfer.nCalleeAgentId = pAssoLine->getAgentNum();			// 被叫坐席工号
	lstrcpy(repInfoTransfer.szCalleeNum, m_CurrCmd.GetDataString(4));	// 转移号码
	repInfoTransfer.szTrunkId = pAssoLine->lineId();					// 被转移线路Id
	CStatisticsMgr::GetInstance().onCallDetail(m_pCurrLine->callId(), REP_EVENT_TRANSFER, m_pCurrLine->lineId(), &repInfoTransfer);

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

/*****************************************************************
**【函数名称】	OnDevOpResult
**【函数功能】	设备操作结果返回
**【参数】		成功还是失败
**【返回值】		void
****************************************************************/
BOOL CTaskAgentConsulCall::OnDevOpResult(EventOpResult &EvtInfo)
{
	// 命令返回
	_ProcCmdReturn(EvtInfo.bIsSucceed);	

	// 协商呼叫结果返回成功
	if(m_OpStep == 0 && EvtInfo.bIsSucceed)	
	{
		m_OpStep++;
		
		// 统计-协商呼叫成功
		CStatisticsMgr::GetInstance().onCallDetail(m_TaskCallId, REP_EVENT_CONSUL_RESULT, m_pCurrLine->lineId(), NULL);
		return (!EvtInfo.bIsSucceed);
	}
	
	// 统计-转移结果
	T_EvtTransfer repInfoTransfer;
	memset(&repInfoTransfer, 0, sizeof(repInfoTransfer));
	repInfoTransfer.bEvtResult = EvtInfo.bIsSucceed;
	CStatisticsMgr::GetInstance().onCallDetail(m_TaskCallId, REP_EVENT_TRANSFER_RESULT, m_pCurrLine->lineId(), &repInfoTransfer);

	return TRUE;
}

/*****************************************************************
**【函数名称】	OnCmdOperation
**【函数功能】	Task命令处理
**【参数】		PduEntity 命令实体
**【返回值】	
****************************************************************/
BOOL CTaskAgentConsulCall::OnCmdOperation(CPduEntity &PduEntity)
{
	// 处理确认转移命令
	if(PduEntity.GetCmdType() != PDU_CMD_AGENT_CONFIRM_TRANSFER || m_OpStep == 0) 
	{
		PduEntity.SetToExecReturn();
		PduEntity.SetDataBool(0, false);
		CInterfaceWindow::getIocpCommInstance()->Send(&PduEntity, PduEntity.GetLocalDevType(), PduEntity.GetLocalDevId());
		return FALSE;
	}

	// 设置当前命令
	m_CurrCmd = PduEntity;

	// 显示日志
	ILogger::getInstance().log(LOG_CLASS_SOCKET, LOG_LEVEL_NORMAL, _T("AGENT->CTI, CMD = [坐席确认转移], Exten = %d"), m_CurrCmd.GetDataUInt(1));

	// 向底层发送确认转移命令
	LineOpParam param = { 0 };
	param.nParam1 = PduEntity.GetDataUInt(3);
	return (!CCtiCore::GetInstance().getDevLink().exec((long)this, LINE_OP_CONSULT_CALL_CONFIRM, m_pCurrLine->lineId(), &param));
}