MiddleWares_YiHe/IVR/CellCallOut....

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

IMPLEMENT_CELL_AUTOCREATE(CCellCallOut, CELL_NAME_CALL)

CCellCallOut::CCellCallOut(void) : m_CalleeNumType(CELL_DATA_VAR), m_CallerNumType(CELL_DATA_VAR), m_Timeout(0), m_SuccessPos(0), m_FailPos(0), m_TimeCount(0)
{
}

CCellCallOut::CCellCallOut( CCellCallOut & cellCallOut ) : CCellBase(cellCallOut)
{
	m_CalleeNumType = cellCallOut.m_CalleeNumType;
	m_CallerNumType = cellCallOut.m_CallerNumType;
	m_Timeout = cellCallOut.m_Timeout;
	m_SuccessPos = cellCallOut.m_SuccessPos;
	m_FailPos = cellCallOut.m_FailPos;
	m_TimeCount = 0;
	m_CalleeNum = cellCallOut.m_CalleeNum;
	m_CallerNum = cellCallOut.m_CallerNum;

	CreateEx(0, AfxRegisterWndClass(CS_GLOBALCLASS), "", 0, 0, 0, 0, 0, 0, 0);
}


CCellCallOut::~CCellCallOut(void)
{
	KillTimer(reinterpret_cast<long>(this));
	DestroyWindow();
}

BEGIN_MESSAGE_MAP(CCellCallOut, CWnd)
	ON_WM_TIMER()
END_MESSAGE_MAP()



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

	// 创建定时器
	if (m_Timeout > 0 )
		SetTimer(reinterpret_cast<long>(this), 1000, NULL);

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

	// 获取被叫
	CString CalleeNum = "";
	if(m_CalleeNumType == CELL_DATA_VAR)	// 目标号码类型为2时，存储的是变量名
	{
		if(!m_pIvrFlow->findVarValue(m_CalleeNum, CalleeNum))
		{
			ILogger::getInstance().log(LOG_CLASS_BUSI, LOG_LEVEL_WARNING, _T("{Cell}: 执行[%s]出错, 被叫号码为空"), Info);
			KillTimer(reinterpret_cast<long>(this));
			return CELL_OP_ERROR;
		}
	}
	else
	{
		CalleeNum = m_CalleeNum;
	}

	// 获取主叫
	CString CallerNum = "";
	if(m_CallerNumType == CELL_DATA_VAR)	// 目标号码类型为2时，存储的是变量名
	{
		if(!m_pIvrFlow->findVarValue(m_CallerNum, CallerNum))
		{
			ILogger::getInstance().log(LOG_CLASS_BUSI, LOG_LEVEL_WARNING, _T("{Cell}: 执行[%s]出错, 主叫号码为空"), Info);
			KillTimer(reinterpret_cast<long>(this));
			return CELL_OP_ERROR;
		}
	}
	else
	{
		CallerNum = m_CallerNum;
	}

	m_pIvrFlow->addVar(SYSTEM_VAR_HUNT_GROUP, CalleeNum);

	CPduEntity cmdCallout(PDU_CMD_IVR_CALL_OUT);
	cmdCallout.SetDataInt(1, m_pIvrFlow->id());
	cmdCallout.SetDataString(4, CalleeNum);
	cmdCallout.SetDataString(5, CallerNum);
	cmdCallout.SetDataUInt(6, m_Timeout);
	if(!CNetworkIvr::GetInstance().send(cmdCallout))
	{
		KillTimer(reinterpret_cast<long>(this));
		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 * CCellCallOut::copy( void )
{
	CCellBase * pCellBase = new CCellCallOut(*this);
	return pCellBase;
}

/*****************************************************************
**【函数名称】	fillData
**【函数功能】	节点解析,填充数据
**【参数】		Provider：数据提供器
**【返回值】	成功true，失败false
****************************************************************/
bool CCellCallOut::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_CALLER_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_CALLER_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_CALL, Data);

	return false;
}

/*****************************************************************
**【函数名称】	onOpResultReturn
**【函数功能】	处理PDU命令
**【参数】		a_pPduEntity：PDU命令
**【返回值】	下一个节点编号
****************************************************************/
int CCellCallOut::onOpResultReturn( CPduEntity *a_pPduEntity )
{
	KillTimer(reinterpret_cast<long>(this));

	CString Info;
	_getCellInfo(Info);

	if(a_pPduEntity->GetIsExecReturn() && a_pPduEntity->GetCmdType() == PDU_CMD_IVR_CALL_OUT)
	{
		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;
}

/*****************************************************************
**【函数名称】	OnTimer
**【函数功能】	定时器响应函数
**【参数】		
**【返回值】	
****************************************************************/
void CCellCallOut::OnTimer( UINT_PTR nIDEvent )
{
	if(nIDEvent != reinterpret_cast<long>(this)) 
		return;

	if( m_TimeCount <= m_Timeout) 
	{
		m_TimeCount++;
	}
	else
	{
		KillTimer(reinterpret_cast<long>(this));

		ILogger::getInstance().log(LOG_CLASS_BUSI, LOG_LEVEL_WARNING, _T("{Cell}: 流程[%d]外呼节点[%d]呼叫超时, 执行挂机操作,"), 
			(m_pIvrFlow != NULL) ? m_pIvrFlow->id() : 0, m_Pos);

		//执行挂机操作
		CPduEntity CmdHangUp(PDU_CMD_IVR_HANGUP);
		CmdHangUp.SetDataInt(1, m_pIvrFlow->id());
		CNetworkIvr::GetInstance().send(CmdHangUp);
	}

	CWnd::OnTimer(nIDEvent);
}