middleware_xinyang-asr/IVR/CellContinue...

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


IMPLEMENT_CELL_AUTOCREATE(CCellContinueQueue, CELL_NAME_CONTINUE_QUEUE)


CCellContinueQueue::CCellContinueQueue(void)
{
	m_AgentNo = "";
	m_AgentExten = "";
	m_AudioFile = "";
	m_Timeout = 0;
	m_SuccessPos = 0;
	m_TimeoutPos = 0;
	m_HangupPos = 0;
}

CCellContinueQueue::CCellContinueQueue( CCellContinueQueue & cellContinueQueue ) : CCellBase(cellContinueQueue)
{
	m_AgentNo = cellContinueQueue.m_AgentNo;
	m_AgentExten = cellContinueQueue.m_AgentExten;
	m_AudioFile = cellContinueQueue.m_AudioFile;
	m_Timeout = cellContinueQueue.m_Timeout;
	m_SuccessPos = cellContinueQueue.m_SuccessPos;
	m_TimeoutPos = cellContinueQueue.m_TimeoutPos;
	m_HangupPos = cellContinueQueue.m_HangupPos;
}


CCellContinueQueue::~CCellContinueQueue(void)
{
}

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

	CPduEntity cmdContinue(PDU_CMD_IVR_QUEUE_CONTINUE);
	cmdContinue.SetDataInt(1, m_pIvrFlow->id());
	cmdContinue.SetDataULong(2, m_pIvrFlow->assoCallId());
	cmdContinue.SetDataString(5, m_AudioFile);
	cmdContinue.SetDataInt(6, m_Timeout);
	// 2022-06-21
	CString CallerNum = "";
	if (m_pIvrFlow->findVarValue(SYSTEM_VAR_CALLER, CallerNum))
		cmdContinue.SetDataString(4, CallerNum);
	
	if( !CNetworkIvr::GetInstance().send(cmdContinue))
	{
		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 * CCellContinueQueue::copy( void )
{
	CCellBase * pCellBase = new CCellContinueQueue(*this);
	return pCellBase;
}

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

		if(!Provider.getData(CELL_ATTRIBUTE_EXTEN, m_AgentExten))
		{
			Data = _T("座席分机");
			break;
		}

		if(!Provider.getData(CELL_ATTRIBUTE_AUDIO, m_AudioFile))
		{
			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_HANGUP_POS, Data))
		{
			Data = _T("挂机跳转节点");
			break;
		}
		else
		{
			sscanf_s(Data, _T("%d"), &m_HangupPos);
			if(m_HangupPos < 0)
			{
				Data = _T("挂机跳转节点");
				break;
			}
		}

		if(!Provider.getData(CELL_ATTRIBUTE_TIMEOUT_POS, Data))
		{
			Data = _T("超时跳转节点");
			break;
		}
		else
		{
			sscanf_s(Data, _T("%d"), &m_TimeoutPos);
			if(m_TimeoutPos < 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_CONTINUE_QUEUE, Data);
	return false;
}

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

	if(a_pPduEntity->GetIsExecReturn() && a_pPduEntity->GetCmdType() == PDU_CMD_IVR_QUEUE_CONTINUE)
	{
		if(a_pPduEntity->GetDataBool(0))
		{
			CString strExt = "";
			strExt.Format("%u", a_pPduEntity->GetDataUInt(8));
			m_pIvrFlow->addVar(m_AgentExten, strExt);

			CString strAgentNum = "";
			strAgentNum.Format("%u", a_pPduEntity->GetDataUInt(7));
			m_pIvrFlow->addVar(m_AgentNo, strAgentNum);
			ILogger::getInstance().log(LOG_CLASS_BUSI, LOG_LEVEL_NORMAL, _T("{Cell}: 节点[%s]执行结束, 分机[%s], 工号[%s]"), Info, strExt, strAgentNum);
			return m_SuccessPos;
		}
		else
		{
			// 2022-04-02 获取呼入电话的排队位置
			std::string callIndex = "999";
			bool ret = getCallIndex(m_pIvrFlow->id(), callIndex);
			if (!ret)
			{
				ILogger::getInstance().log(LOG_CLASS_BUSI, LOG_LEVEL_WARNING, _T("{Cell}: 节点[%s]获取当前排队位置失败"), Info);
			}
			m_pIvrFlow->addVar(m_AgentNo, callIndex.c_str());
			ILogger::getInstance().log(LOG_CLASS_BUSI, LOG_LEVEL_WARNING, _T("{Cell}: 节点[%s]执行失败, 等待超过最大时长"), Info);
			return m_TimeoutPos;
		}
	}

	// 挂机命令
	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]执行异常, 收到异常消息"), Info);

	return CELL_OP_ERROR;
}