midware_ws/NetLib/FsLink/OpTransfer.cpp

#include "StdAfx.h"
#include "OpTransfer.h"
#include "VirtualChan.h"
#include "OperationReactor.h"
#include "FsProxy.h"


COpTransfer::COpTransfer(COperationReactor* pParent, LONG Instance) : COperation(pParent, Instance), m_pHostExtChan(NULL)
{
}


COpTransfer::~COpTransfer(void)
{
}

/*****************************************************************
**【函数名称】	_end
**【函数功能】	操作完成
**【参数】		IsSucceed	操作是否成功
				lpData		随路数据
**【返回值】	
****************************************************************/
void COpTransfer::_end( bool IsSucceed )
{
	if(IsSucceed)
	{
		LOGGER(LOG_LEVEL_NORMAL, _T("{OpTransfer}: 分机[%lu]转移成功, DestNum = %s"), m_pHostExtChan->no(), m_DestNumber);
	}
	else
	{
		LOGGER(LOG_LEVEL_WARNING, _T("{OpTransfer}: 分机[%lu]转移失败, DestNum = %s"), m_pHostExtChan->no(), m_DestNumber);
	}

	// 返回执行结果
	if(m_InstanceCancel != FS_LINK_INSTANCE_INVALID) 
		m_pParent->onOpResult(m_InstanceCancel, !IsSucceed);

	m_pParent->onOpResult(m_Instance, this, IsSucceed);
}

/*****************************************************************
**【函数名称】	start
**【函数功能】	执行操作
**【参数】		
**【返回值】	
*****************************************************************/
bool COpTransfer::start( LineOpParam* pParam )
{
	// 校验状态
	if(m_pHostChan->state() != CHAN_LOGIC_STATE_TALKING) 
		return false;

	// 获取待转移的通道
	CVirtualChan* pDestChan = CFsProxy::GetInstance().getAssoChanInSession(m_pHostChan);
	if(pDestChan == NULL || pDestChan->currOp() != NULL)
		return false;

	// 保存被叫信息
	CString CallerNum = pParam->szParam1;
	m_DestNumber = pParam->szParam2;
	m_pHostExtChan = m_pHostChan;
	
	detachHostChan();
	attachHostChan(pDestChan);

	// 通知启动日志
	LOGGER(LOG_LEVEL_NORMAL, _T("{OpConsult}: 分机[%lu]执行转移, DestNum = %s"), m_pHostExtChan->no(), m_DestNumber);

	return CFsProxy::GetInstance().transfer(uniqueId(), pDestChan, m_DestNumber);
}

/*****************************************************************
**【函数名称】	onBackgroudJobDone
**【函数功能】	后台命令执行结束事件处理
**【参数】		
**【返回值】	
*****************************************************************/
void COpTransfer::onBackgroudJobDone( PBG_JOB_NOTIFY pNotify )
{
	if(strstr(pNotify->JobBody, ESL_JOB_DONE_RES_FAILED) != NULL)
		_end(false);
}

void COpTransfer::onHostChanStateUpdated(CVirtualChan * pHostChan)
{
	if (m_pHostChan->state() == CHAN_LOGIC_STATE_FREE)
		_end(false);
}

/*****************************************************************
**【函数名称】	onSessionChanStateUpdated
**【函数功能】	同会话中通道状态更新处理
**【参数】		
**【返回值】	
*****************************************************************/
void COpTransfer::onSessionChanStateUpdated( CVirtualChan* pChan )
{
	if(pChan == m_pHostExtChan)
		return;

	switch(pChan->state())
	{
	case CHAN_LOGIC_STATE_RING_BACK:
	case CHAN_LOGIC_STATE_ALERTING:
		m_pParent->onOpProcess(m_Instance, m_pHostChan->no(), pChan->no(), pChan->type(), pChan->callerNum(), pChan->calleeNum());
		break;

	case CHAN_LOGIC_STATE_TALKING:
		_end(true);
		break;

	case CHAN_LOGIC_STATE_FREE:
		_end(false);
	}
}