Middleware_hd/IVR/CellTurnAgen...

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


IMPLEMENT_CELL_AUTOCREATE(CCellTurnAgent, CELL_NAME_TURN_AGENT)


CCellTurnAgent::CCellTurnAgent(void)
{
	m_Exten = "";				
	m_SuccessPos = 0;         
	m_FailPos = 0;            
	m_HangUpPos = 0;
}

CCellTurnAgent::CCellTurnAgent( CCellTurnAgent & cellTurnAgent ) : CCellBase(cellTurnAgent)
{
	m_Exten = cellTurnAgent.m_Exten;	
	m_SuccessPos = cellTurnAgent.m_SuccessPos;   
	m_FailPos = cellTurnAgent.m_FailPos;          
	m_HangUpPos = cellTurnAgent.m_HangUpPos;   

	POSITION pos = cellTurnAgent.m_VarList.GetHeadPosition();
	while(pos != NULL)
	{
		CString strValue = cellTurnAgent.m_VarList.GetNext(pos);
		if(!strValue.IsEmpty())
			this->m_VarList.AddTail(strValue);
	}
}

CCellTurnAgent::~CCellTurnAgent(void)
{
}

/*****************************************************************
**【函数名称】	operate
**【函数功能】	节点执行函数
**【参数】		
**【返回值】	下一个节点编号
****************************************************************/
int CCellTurnAgent::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_HangUpPos; 
	}

	// 获取要转移的分机号
	CString strExt = "";
	if(!m_pIvrFlow->findVarValue(m_Exten, strExt))
	{
		ILogger::getInstance().log(LOG_CLASS_BUSI, LOG_LEVEL_WARNING, _T("{Cell}: 执行[%s]出错, 要转移的分机号码为空"), Info);
		return CELL_OP_ERROR;
	}

	// 将需传递给坐席的变量拼成：变量名：变量值|变量名：变量值
	CString strVarInfo = _T("");
	CString strSingleVarInfo = _T("");
	CString strValue = _T("");
	CString strVarName = _T("");
	POSITION pos = m_VarList.GetHeadPosition();
	while(pos != NULL)
	{
		strVarName = m_VarList.GetNext(pos);
		if(!strVarName.IsEmpty() && m_pIvrFlow->findVarValue(strVarName, strValue))
		{
			strSingleVarInfo.Format(_T("%s:%s|"), strVarName, strValue);
			strVarInfo += strSingleVarInfo;
		}
	}

	/*
	CPduEntity cmdTurnAgent(PDU_CMD_IVR_TURN_AGENT);
	cmdTurnAgent.SetDataInt(1, m_pIvrFlow->id());
	cmdTurnAgent.SetDataUInt(4, atoi(strExt));
	cmdTurnAgent.SetDataString(5, strVarInfo);
	 
	if( !CNetworkIvr::GetInstance().send(cmdTurnAgent))
	{
		ILogger::getInstance().log(LOG_CLASS_SOCKET, LOG_LEVEL_WARNING, _T("{Cell}: 执行[%s]出错, 向CTI发送消息失败"), Info);
		return CELL_OP_SEND_ERROR;
	}
	*/
	

	//CString strExt = pPduEntity->GetDataString(4)

	CPduEntity cmdTurnAgent(PDU_CMD_IVR_TURN_AGENT);
	cmdTurnAgent.SetDataInt(1, m_pIvrFlow->id());
	
	cmdTurnAgent.SetDataULong(2, m_pIvrFlow->assoCallId());
	if (CNetworkIvr::GetInstance().send(cmdTurnAgent))
	{
		//ILogger::getInstance().log(LOG_CLASS_BUSI, LOG_LEVEL_NORMAL, _T("{CellTurnAgent}: ivr[%d]"), m_pIvrFlow->id());
	}
	else {
		ILogger::getInstance().log(LOG_CLASS_BUSI, LOG_LEVEL_WARNING, _T("{CellTurnAgent}: Fail,ivr[%d]"), m_pIvrFlow->id());
	}

	return CELL_OP_WAIT_FOR;
}

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

/*****************************************************************
**【函数名称】	fillData
**【函数功能】	节点解析,填充数据
**【参数】		Provider：数据提供器
**【返回值】	成功true，失败false
****************************************************************/
bool CCellTurnAgent::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_EXTEN, m_Exten))
		{
			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 < 1)
			{
				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 < 1)
			{
				Data = _T("失败跳转节点");
				break;
			}
		}

		if(!Provider.getData(CELL_ATTRIBUTE_HANGUP_POS, Data))
		{
			Data = _T("挂机跳转节点");
			break;
		}
		else
		{
			sscanf_s(Data, _T("%d"), &m_HangUpPos);
			if(m_HangUpPos < 1)
			{
				Data = _T("挂机跳转节点");
				break;
			}
		}

		Data.Format(_T("%s[@%s='%d']/%s"), XPATH_CELL, CELL_ATTRIBUTE_POS, m_Pos, FLOW_SUB_NODE_BAND_DATA);
		if(!Provider.getDataSet(Data, CELL_ATTRIBUTE_VAR, m_VarList))
		{
			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_TURN_AGENT, Data);

	return false;
}

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

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

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

	return CELL_OP_ERROR;
}