Middleware_hd/IVR/CellTransfer...

#include "StdAfx.h"
#include "CellTransferOut.h"
#include "NetworkIvr.h"
#include "IvrFlow.h"
#include "FlowDataProvider.h"


IMPLEMENT_CELL_AUTOCREATE(CCellTransferOut, CELL_NAME_TRANSFER_OUT)


CCellTransferOut::CCellTransferOut(void)
{
	m_CalleeNumType = CELL_DATA_VAR;
	m_CalleeNum = "";
	m_TimeOut = 0;
	m_SuccessPos = 0;
	m_FailPos = 0;
}

CCellTransferOut::CCellTransferOut( CCellTransferOut & CellTransferOut ) : CCellBase(CellTransferOut)
{
	m_CalleeNumType = CellTransferOut.m_CalleeNumType;
	m_CalleeNum = CellTransferOut.m_CalleeNum;
	m_TimeOut = CellTransferOut.m_TimeOut;
	m_SuccessPos = CellTransferOut.m_SuccessPos;
	m_FailPos = CellTransferOut.m_FailPos;
}

CCellTransferOut::~CCellTransferOut(void)
{
}

/*****************************************************************
**【函数名称】	operate
**【函数功能】	节点执行函数
**【参数】		
**【返回值】	下一个节点编号
****************************************************************/
int CCellTransferOut::operate( void )
{
	if(m_pIvrFlow == NULL) 
		return CELL_OP_ERROR;

	CString Info;
	_getCellInfo(Info);
	ILogger::getInstance().log(LOG_CLASS_BUSI, LOG_LEVEL_NORMAL, _T("{Cell}: 开始执行[%s]"), Info);

	if(m_pIvrFlow->hangUpSign())
	{
		m_pIvrFlow->hangUpSign() = false;
		ILogger::getInstance().log(LOG_CLASS_BUSI ,LOG_LEVEL_NORMAL, _T("{Cell}: 节点[%s]取消执行, 检测到外线挂机"), Info);
		return m_FailPos; 
	}

	// 获取主叫
	CString strCallerNum = "";
	m_pIvrFlow->findVarValue(SYSTEM_VAR_CALLER, strCallerNum);

	// 获取被叫
	CString strCalleeNum = "";
	if(m_CalleeNumType == CELL_DATA_VAR)
	{
		if(!m_pIvrFlow->findVarValue(m_CalleeNum, strCalleeNum))
		{
			ILogger::getInstance().log(LOG_CLASS_BUSI, LOG_LEVEL_WARNING, _T("{Cell}: 执行[%s]出错, 被叫号码为空"), Info);
			return CELL_OP_ERROR;
		}
	}
	else
	{
		strCalleeNum = m_CalleeNum;
	}

	CPduEntity cmdTransfer(PDU_CMD_IVR_TURN_OUTLINE);
	cmdTransfer.SetDataInt(1, m_pIvrFlow->id());
	cmdTransfer.SetDataString(4, strCalleeNum);
	cmdTransfer.SetDataString(5, strCallerNum);
	cmdTransfer.SetDataUInt(6, m_TimeOut);

	if(!CNetworkIvr::GetInstance().send(cmdTransfer))
	{
		ILogger::getInstance().log(LOG_CLASS_SOCKET, LOG_LEVEL_WARNING, _T("{Cell}: 执行[%s]出错, 向CTI发送消息失败"), Info);
		return CELL_OP_SEND_ERROR;
	}

	return CELL_OP_WAIT_FOR;
}

/*****************************************************************
**【函数名称】	copy
**【函数功能】	拷贝自身
**【参数】		
**【返回值】	拷贝副本
****************************************************************/
CCellBase * CCellTransferOut::copy( void )
{
	CCellBase * pCellBase = new CCellTransferOut(*this);
	return pCellBase;
}

/*****************************************************************
**【函数名称】	fillData
**【函数功能】	节点解析,填充数据
**【参数】		Provider：数据提供器
**【返回值】	成功true，失败false
****************************************************************/
bool CCellTransferOut::fillData( IFlowDataProvider& Provider )
{
	CString Data;

	do 
	{
		if(!Provider.getData(CELL_ATTRIBUTE_POS, Data))
		{
			Data = _T("节点号");
			break;
		}
		else
		{
			sscanf_s(Data, _T("%d"), &m_Pos);
			if(m_Pos < 1)
			{
				Data = _T("节点号");
				break;
			}
		}

		if(!Provider.getData(CELL_ATTRIBUTE_CALLEE_NUM_TYPE, Data))
		{
			Data = _T("目标号码类型");
			break;
		}
		else
		{
			sscanf_s(Data, _T("%d"), &m_CalleeNumType);
			if(m_CalleeNumType != CELL_DATA_VAL && m_CalleeNumType != CELL_DATA_VAR)
			{
				Data = _T("目标号码类型");
				break;
			}
		}

		if(!Provider.getData(CELL_ATTRIBUTE_CALLEE_NUM, m_CalleeNum))
		{
			Data = _T("目标号码");
			break;
		}

		if(!Provider.getData(CELL_ATTRIBUTE_TIMEOUT, Data))
		{
			Data = _T("呼叫超时");
			break;
		}
		else
		{
			sscanf_s(Data, _T("%d"), &m_TimeOut);
			if(m_TimeOut < 0)
			{
				Data = _T("呼叫超时");
				break;
			}
		}

		if(!Provider.getData(CELL_ATTRIBUTE_SUCCESS_POS, Data))
		{
			Data = _T("成功跳转节点");
			break;
		}
		else
		{
			sscanf_s(Data, _T("%d"), &m_SuccessPos);
			if(m_SuccessPos < 0)
			{
				Data = _T("成功跳转节点");
				break;
			}
		}

		if(!Provider.getData(CELL_ATTRIBUTE_FAIL_POS, Data))
		{
			Data = _T("失败跳转节点");
			break;
		}
		else
		{
			sscanf_s(Data, _T("%d"), &m_FailPos);
			if(m_FailPos < 0)
			{
				Data = _T("失败跳转节点");
				break;
			}
		}

		Provider.getData(CELL_ATTRIBUTE_NOTE, m_Note);

		return true;

	} while (false);

	ILogger::getInstance().log(LOG_CLASS_BUSI, LOG_LEVEL_ERROR, _T("{Cell}: 节点[%s]解析失败, '%s'错误"), CELL_NAME_TRANSFER_OUT, Data);

	return false;
}

/*****************************************************************
**【函数名称】	onOpResultReturn
**【函数功能】	处理PDU命令
**【参数】		a_pPduEntity：PDU命令
**【返回值】	下一个节点编号
****************************************************************/
int CCellTransferOut::onOpResultReturn( CPduEntity *a_pPduEntity )
{
	CString Info;
	_getCellInfo(Info);

	if(a_pPduEntity->GetIsExecReturn() && a_pPduEntity->GetCmdType() == PDU_CMD_IVR_TURN_OUTLINE)
	{
		if(a_pPduEntity->GetDataBool(0))
		{
			ILogger::getInstance().log(LOG_CLASS_BUSI, LOG_LEVEL_NORMAL, _T("{Cell}: 节点[%s]执行成功"), Info);
			return m_SuccessPos;
		}
		else
		{
			ILogger::getInstance().log(LOG_CLASS_BUSI, LOG_LEVEL_NORMAL, _T("{Cell}: 节点[%s]执行失败"), Info);
			return m_FailPos;
		}
	}
	// 挂机命令
	if(a_pPduEntity->GetCmdType() == PDU_CMD_CTI_IVR_HANGUP)
	{
		ILogger::getInstance().log(LOG_CLASS_BUSI, LOG_LEVEL_NORMAL, _T("{Cell}; 节点[%s]执行结束, 收到挂机消息"), Info);
		return m_FailPos;
	}

	ILogger::getInstance().log(LOG_CLASS_BUSI, LOG_LEVEL_WARNING, _T("{Cell}: 节点[%s]执行异常, 收到异常PDU"), Info);

	return CELL_OP_ERROR;
}