midware_ws/NetLib/CTI/TaskIvrTurnO...

#include "stdafx.h"
#include "TaskIvrTurnOut.h"
#include "LineHolder.h"
#include "LogicLine.h"
#include "CtiCore.h"
#include "StatisticsMgr.h"


#include "CallSession.h"
#include "SessionHolder.h"

#include "SqlWriter.h"

CTaskIvrTurnOut::CTaskIvrTurnOut(CPduEntity &PduEntity) : CTask(PduEntity)
{
}


CTaskIvrTurnOut::~CTaskIvrTurnOut(void)
{
}

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

	// 设置当前操作类型
	if (m_pCurrLine == NULL)return FALSE;
	m_pCurrLine->opType() = PDU_CMD_IVR_TURN_OUTLINE;

	// 底层设备发送命令
	LineOpParam pLineOpParam;
	memset(&pLineOpParam, 0, sizeof(pLineOpParam));
	pLineOpParam.nParam1 = m_CurrCmd.GetDataUInt(6);				// 呼叫时长
	lstrcpy(pLineOpParam.szParam1, m_CurrCmd.GetDataString(5));		// 主叫号码
	lstrcpy(pLineOpParam.szParam2, m_CurrCmd.GetDataString(4));		// 转移号码
	 
	T_EvtIvrCallOut repInfo;
	memset(&repInfo, 0, sizeof(repInfo)); 						// 线路 
	lstrcpy(repInfo.szCalleeNum, pLineOpParam.szParam2);		// 被叫号码
 
	CStatisticsMgr::GetInstance().onCallDetail(m_pCurrLine->callId(), REP_EVENT_TRANSFER_TRUNK, m_pCurrLine->lineId(), &repInfo);

	return CCtiCore::GetInstance().getDevLink().exec((long)this, LINE_OP_TURNOUT, m_pCurrLine->lineId(), &pLineOpParam);
}

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

	// 状态校验,外线状态应该是通话
	if(m_pCurrLine->status() != TRUNK_STATE_TALKING) 
	{
		ILogger::getInstance().log(LOG_CLASS_BUSI, LOG_LEVEL_WARNING, _T("{Task}: 线路[%d]执行IVR转外线任务校验时失败：当前线路正在通话中"), m_pCurrLine->lineId());
		return FALSE;
	}

	return TRUE;
}

/*****************************************************************
**【函数名称】	ShowLog
**【函数功能】	显示日志
**【参数】		
**【返回值】		void
****************************************************************/
void CTaskIvrTurnOut::ShowLog()
{
	// 显示日志
	ILogger::getInstance().log(LOG_CLASS_SOCKET, LOG_LEVEL_NORMAL, _T("IVR->CTI, CMD = [IVR转外线], \
				IVR = %d, HostLine = %u, DestNum = %s, CallTimeOut = %d"),
				m_CurrCmd.GetDataInt(1),
				m_CurrCmd.GetDataUInt(3),
				m_CurrCmd.GetDataString(4),
				m_CurrCmd.GetDataUInt(6));
}

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

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

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

	// 统计转移 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", m_pCurrLine->lineId());	// 转移表中主叫号码为发起转移者的号码
	repInfoTransfer.nCallerAgentId = 0; // m_pCurrLine->getAgentNum();		// 主叫工号
	repInfoTransfer.nCalleeAgentId = 0; //pAssoLine->getAgentNum();			// 被叫坐席工号
	lstrcpy(repInfoTransfer.szCalleeNum, m_CurrCmd.GetDataString(3));	// 转移号码
	repInfoTransfer.szTrunkId = pAssoLine->lineId();					// 被转移线路Id
	CStatisticsMgr::GetInstance().onCallDetail(m_pCurrLine->callId(), REP_EVENT_TRANSFER, m_pCurrLine->lineId(), &repInfoTransfer);
	
}
BOOL CTaskIvrTurnOut::OnDevOpResult(EventOpResult &EvtInfo)
{

	CCallSession* pSession = CSessionHolder::GetInstance().findSession(m_pCurrLine->callId());
	if (pSession == NULL) {
		ILogger::getInstance().log(LOG_CLASS_SOCKET, LOG_LEVEL_NORMAL, _T("CTaskIvrTurnOut,SessionNull"));
	}
	/*if (EvtInfo.bIsSucceed) {
		pSession->onRecord(m_pCurrLine);
	}
	else 
	{
		ILogger::getInstance().log(LOG_CLASS_SOCKET, LOG_LEVEL_NORMAL, _T("CTaskIvrTurnOut,NotRecord"));
	}*/
	// 命令返回
	_ProcCmdReturn(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;
}
void CTaskIvrTurnOut::addtosql(CString strNum)
{

	CSqlWriter& Writer = CSqlWriter::GetInstance();
	CString strSql = _T("");

	strSql.Format(_T("INSERT INTO rep_trunk_call_in_called_num (CalleeNum\
					   )\
					 VALUES ('%s')"),
					 strNum
					 );

	Writer.addSql(strSql);
}