MiddleWares_YiHe/IVR/CellHoldOn.cpp

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

IMPLEMENT_CELL_AUTOCREATE(CCellHoldOn, CELL_NAME_HOLD_ON)


CCellHoldOn::CCellHoldOn(void)
{
	m_Exten = "";
	m_SuccessPos = 0;
	m_FailPos = 0;
	m_Timeout = 0;
	m_TimeoutPos = 0;
	m_HangUpPos = 0;
}

CCellHoldOn::CCellHoldOn(CCellHoldOn & cellHoldOn) : CCellBase(cellHoldOn)
{
	m_Exten = cellHoldOn.m_Exten;
	m_Timeout = cellHoldOn.m_Timeout;
	m_SuccessPos = cellHoldOn.m_SuccessPos;
	m_TimeoutPos = cellHoldOn.m_TimeoutPos;
	m_FailPos = cellHoldOn.m_FailPos;
	m_HangUpPos = cellHoldOn.m_HangUpPos;
	POSITION pos = cellHoldOn.m_VarList.GetHeadPosition();
	while (pos != NULL)
	{
		CString strValue = cellHoldOn.m_VarList.GetNext(pos);
		if (!strValue.IsEmpty())
			this->m_VarList.AddTail(strValue);
	}
}

CCellHoldOn::~CCellHoldOn(void)
{
}
/*****************************************************************
**【函数名称】	operate
**【函数功能】	节点执行函数
**【参数】
**【返回值】	下一个节点编号
****************************************************************/
int CCellHoldOn::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;
		}
	}
	
	//2019-09-11 颐和随访,增加座席状态为来电振铃的字段
	CPduEntity cmdhold(PDU_CMD_AGENT_HOLD);
	cmdhold.SetDataInt(0, true);
	//cmdhold.SetDataUInt(1, 1017);
	cmdhold.SetDataInt(5, m_pIvrFlow->id());
	//cmdhold.SetDataUInt(2, 8000);
	cmdhold.SetDataULong(3, m_pIvrFlow->assoCallId());

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

	//return CELL_OP_WAIT_FOR;
	return m_SuccessPos;
}

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

/*****************************************************************
**【函数名称】	fillData
**【函数功能】	节点解析,填充数据
**【参数】		Provider：数据提供器
**【返回值】	成功true，失败false
****************************************************************/
bool CCellHoldOn::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;*/
	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_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 < 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;
			}
		}
		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;
			}
		}
		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;
			}
		}
		/*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 CCellHoldOn::onOpResultReturn(CPduEntity *a_pPduEntity)
{
	CString Info;
	_getCellInfo(Info);

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