MidWare_WinStandard1.0/IVR/CellLeaveWor...

#include "StdAfx.h"
#include "CellLeaveWord.h"
#include "NetworkIvr.h"
#include "IvrFlow.h"
#include "FlowDataProvider.h"
#include "Config.h"


IMPLEMENT_CELL_AUTOCREATE(CCellLeaveWord, CELL_NAME_LEAVE_WORD)

CCellLeaveWord::CCellLeaveWord(void)
{
	m_MaxTime = 0;	
	m_TimeoutPos = 0;
	m_HangUpPos = 0;
	m_FinishPos = 0;
	m_Path = "";	
	m_FinishKey = "";
}

CCellLeaveWord::CCellLeaveWord( CCellLeaveWord &cellLeaveWord ) : CCellBase(cellLeaveWord)
{
	m_MaxTime = cellLeaveWord.m_MaxTime;	
	m_TimeoutPos = cellLeaveWord.m_TimeoutPos;
	m_HangUpPos = cellLeaveWord.m_HangUpPos;
	m_FinishPos = cellLeaveWord.m_FinishPos;
	m_Path = cellLeaveWord.m_Path;	
	m_FinishKey = cellLeaveWord.m_FinishKey;
}

CCellLeaveWord::~CCellLeaveWord(void)
{
}

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

	CString Path;
	// 替换留言文件名中的变量
	if(!m_pIvrFlow->replaceVar(m_Path, Path))
	{
		ILogger::getInstance().log(LOG_CLASS_BUSI, LOG_LEVEL_WARNING, _T("{Cell}: 执行[%s]出错, 替换留言文件名中变量失败, Path = %s"), Info, Path);
		return CELL_OP_ERROR;
	}
	// 2019-12-31 修改留言文件路径，以当前日期存放
	CTime TimeNow = CTime::GetCurrentTime();
	CString DateMark = TimeNow.Format(_T("%Y%m%d")); // 日期标识
	CString lwp = CConfig::leaveWordPath();
    Path.Replace(lwp, "");
	lwp.Format(_T("%s\\%s%s"), CConfig::leaveWordPath(), DateMark,Path);
	Path = lwp;

	CPduEntity cmdLeaveWord(PDU_CMD_IVR_LEAVE_WORD);
	cmdLeaveWord.SetDataInt(1, m_pIvrFlow->id());
	cmdLeaveWord.SetDataUInt(4, m_MaxTime);		
	cmdLeaveWord.SetDataString(5, m_FinishKey);
	cmdLeaveWord.SetDataString(6, Path);		
	if(!CNetworkIvr::GetInstance().send(cmdLeaveWord))
	{
		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 * CCellLeaveWord::copy( void )
{
	CCellBase * pCellBase = new CCellLeaveWord(*this);
	return pCellBase;
}

/*****************************************************************
**【函数名称】	fillData
**【函数功能】	节点解析,填充数据
**【参数】		Provider：数据提供器
**【返回值】	成功true，失败false
****************************************************************/
bool CCellLeaveWord::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_PATH, Data))
		{
			Data = _T("留言文件名称");
			break;
		}
		else
		{
			if(Data.IsEmpty() || CConfig::leaveWordPath().IsEmpty())
			{
				Data = _T("留言文件名称");
				break;
			}

			m_Path.Format(_T("%s\\%s"), CConfig::leaveWordPath(), Data);
		}

		if(!Provider.getData(CELL_ATTRIBUTE_FINISH_KEY, m_FinishKey))
		{
			Data = _T("结束按键");
			break;
		}

		if(!Provider.getData(CELL_ATTRIBUTE_TIMEOUT, Data))
		{
			Data = _T("留言时长");
			break;
		}
		else
		{
			sscanf_s(Data, _T("%d"), &m_MaxTime);
			if(m_MaxTime < 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;
			}
		}

		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_FINISH_POS, Data))
		{
			Data = _T("留言结束跳转节点");
			break;
		}
		else
		{
			sscanf_s(Data, _T("%d"), &m_FinishPos);
			if(m_FinishPos < 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_LEAVE_WORD, Data);

	return false;
}

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

	if(a_pPduEntity->GetIsExecReturn() && a_pPduEntity->GetCmdType() == PDU_CMD_IVR_LEAVE_WORD)
	{
		if(a_pPduEntity->GetDataBool(0))
		{
			ILogger::getInstance().log(LOG_CLASS_BUSI, LOG_LEVEL_NORMAL, _T("{Cell}: 节点[%s]执行成功"), Info);
			return m_FinishPos;
		}
		else
		{
			ILogger::getInstance().log(LOG_CLASS_BUSI, LOG_LEVEL_NORMAL, _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]执行异常, 收到异常PDU"), Info);

	return CELL_OP_ERROR;
}