Middleware_hd/IVR/CellDefineVa...

#include "StdAfx.h"
#include "CellDefineVar.h"
#include "IvrFlow.h"
#include "FlowDataProvider.h"


IMPLEMENT_CELL_AUTOCREATE(CCellDefineVar, CELL_NAME_DEFINE_VAR)

CCellDefineVar::CCellDefineVar(void) : m_NextPos(0)
{
}

CCellDefineVar::CCellDefineVar( CCellDefineVar & cellDefineVar ) : CCellBase(cellDefineVar)
{
	m_NextPos = cellDefineVar.m_NextPos;

	POSITION pos = cellDefineVar.m_VarList.GetHeadPosition();
	while(pos != NULL)
	{
		VarInfo *pVarInfo = cellDefineVar.m_VarList.GetNext(pos);
		ASSERT(pVarInfo != NULL);

		VarInfo *pVarInfoTmp =  new VarInfo(*pVarInfo);
		ASSERT(pVarInfoTmp != NULL);
		m_VarList.AddTail(pVarInfoTmp);
	}
}

CCellDefineVar::~CCellDefineVar(void)
{
	__release();
}

/*****************************************************************
**【函数名称】	__release
**【函数功能】	释放资源
**【参数】		
**【返回值】	
****************************************************************/
void CCellDefineVar::__release( void )
{
	while(!m_VarList.IsEmpty())
		delete m_VarList.RemoveHead();
}

/*****************************************************************
**【函数名称】	addVar
**【函数功能】	添加变量接口
**【参数】		VarType：变量类型
				VarName：变量名
				VarVal：变量值
**【返回值】	
****************************************************************/
void CCellDefineVar::addVar( int VarType, const CString& VarName, const CString& VarVal )
{
	VarInfo *pVarInfo = new VarInfo(VarType, VarName, VarVal);
	ASSERT(pVarInfo != NULL);

	if(pVarInfo == NULL)
	{
		CString Info;
		_getCellInfo(Info);
		ILogger::getInstance().log(LOG_CLASS_BUSI, LOG_LEVEL_WARNING, _T("{Cell}: 执行[%s]时创建变量结构失败"), Info);
	}
	else
	{
		m_VarList.AddTail(pVarInfo);
	}
}

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

	POSITION pos = m_VarList.GetHeadPosition();
	while(pos != NULL)
	{
		VarInfo *pVarInfo = m_VarList.GetNext(pos);
		ASSERT(pVarInfo != NULL);

		CString strVarValue = "";
		if(pVarInfo->nVarType == CELL_DATA_VAR)
		{
			if(!m_pIvrFlow->findVarValue(pVarInfo->szVarValue, strVarValue))
				ILogger::getInstance().log(LOG_CLASS_BUSI, LOG_LEVEL_WARNING, _T("{Cell}: 执行[%s]出错，变量[%s]未找到对应值"), Info, pVarInfo->szVarValue);
		}
		else
		{
			strVarValue = pVarInfo->szVarValue;
		}

		m_pIvrFlow->addVar(pVarInfo->szVarName, strVarValue);
	}

	return m_NextPos;
}

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

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

		Data.Format(_T("%s[@%s='%d']/%s"), XPATH_CELL, CELL_ATTRIBUTE_POS, m_Pos, FLOW_SUB_NODE_DEF_VAR);
		if(!Provider.getFlowDefVar(Data, *this))
		{
			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_DEFINE_VAR, Data);

	return false;
}