#include "stdafx.h"
#include "TaskDevCall.h"
#include "Task.h"
#include "LineHolder.h"
#include "LogicLine.h"
#include "LogicLineExt.h"
#include "StatisticsMgr.h"
#include "NetworkCti.h"
#include "CtiCore.h"


CTaskDevCall::CTaskDevCall(EventDevOperation &DevOpInfo): CTask(DevOpInfo)
{
}


CTaskDevCall::~CTaskDevCall(void)
{
}

/*****************************************************************
**【函数名称】	DoTask
**【函数功能】	Task处理
**【参数】		
**【返回值】	void
****************************************************************/
BOOL CTaskDevCall::DoTask()
{
	if(m_pCurrLine == NULL) 
	{
		ILogger::getInstance().log(LOG_CLASS_BUSI, LOG_LEVEL_WARNING, _T("{Task}: 线路[%d]执行设备外呼任务失败：无法获取对应线路"), m_CurrDevOp.nLineId);
		return TRUE;
	}
	
	// 向底层传递信息
	return CCtiCore::GetInstance().getDevLink().exec((long)this, LINE_OP_TRANSFER_INFO,  m_pCurrLine->lineId(), NULL);
}

/*****************************************************************
**【函数名称】	ProcLineOpProcess
**【函数功能】	处理设备操作进展
**【参数】		EvtType 消息事件类型；lpContent 消息内容
**【返回值】	void
****************************************************************/
void CTaskDevCall::OnDevOpProcess(EventOpProcess &EvtInfo)
{
	// 显示日志
	ILogger::getInstance().log(LOG_CLASS_BUSI, LOG_LEVEL_NORMAL, _T("{Task}: [设备外呼], 操作进展, HostLine = %u,  AssoLine = %u, AssoLineType = %u"),
				EvtInfo.nHostLine,
				EvtInfo.nAssoLine,
				EvtInfo.nAssoLineType);

	// 处理会话
	_PrcoCallNode(EvtInfo.nHostLine, 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 = 1;													// 呼出方式（0：ocx外呼，1：话机外呼）
	repInfoCallOut.nPeerLineType = EvtInfo.nAssoLineType;							// 对端线路类型
	repInfoCallOut.nCallerAgentId = m_pCurrLine->getAgentNum();						// 主叫坐席工号			
	repInfoCallOut.nCalleeAgentId = pAssoLine->getAgentNum();						// 被叫坐席工号
	lstrcpy(repInfoCallOut.szCalleeNum, EvtInfo.szCalleeNum);						// 被叫号码
	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;									// 呼入方式（1：转坐席呼入，2：转移呼入，3：会议呼入）
	repInfoCallIn.nPeerLineType = m_pCurrLine->type();				// 对端线路类型
	repInfoCallIn.nCallerAgentId = m_pCurrLine->getAgentNum();		// 主叫坐席工号
	sprintf_s(repInfoCallIn.szCallerNum, REP_PHONE_NUM_LENGTH, "%d", m_pCurrLine->lineId());
	repInfoCallIn.nCalleeAgentId = pAssoLine->getAgentNum();		// 被叫坐席工号
	CStatisticsMgr::GetInstance().onCallDetail(pAssoLine->callId(), REP_EVENT_EXT_CALL_IN, pAssoLine->lineId(), &repInfoCallIn);
}

/*****************************************************************
**【函数名称】	OnDevOpResult
**【函数功能】	底层线路操作结果
**【参数】		EvtType 消息事件类型；lpContent 消息内容
**【返回值】	BOOL
****************************************************************/
BOOL CTaskDevCall::OnDevOpResult(EventOpResult &EvtInfo)
{
	// 向OCX发送外呼结果事件
	CPduEntity Cmd(PDU_CMD_CTI_DEV_CALL);
	Cmd.SetDataBool(0, EvtInfo.bIsSucceed == FALSE ? false : true);		// 外呼结果
	Cmd.SetDataUInt(1, m_pCurrLine->lineId());							// 分机Id
	Cmd.SetDataUInt(2, m_pCurrLine->getAgentNum());						// 坐席工号
	Cmd.SetDataULong(3, m_TaskCallId);									// CallId
	Cmd.SetDataString(4, m_CurrDevOp.szCalleeNum);						// 被叫号码
	Cmd.SetDataUInt(5, m_CurrDevOp.nAssoLineType == 0 ? 1:0);			// 外呼类型 0外线 1 内线
	CNetworkCti::GetInstance().send2ACD(Cmd);

	return TRUE;
}