Middleware_5.1/FsLink/OpTrunk2Trun...

#include "StdAfx.h"
#include "OpTrunk2Trunk.h"
#include "ChanTrunk.h"
#include "OperationReactor.h"
#include "FsProxy.h"


COpTrunk2Trunk::COpTrunk2Trunk(COperationReactor* pParent, LONG Instance) : COperation(pParent, Instance)
{
}


COpTrunk2Trunk::~COpTrunk2Trunk(void)
{
}

/*****************************************************************
**【函数名称】	_end
**【函数功能】	操作完成
**【参数】		IsSucceed	操作是否成功
				lpData		随路数据
**【返回值】	
****************************************************************/
void COpTrunk2Trunk::_end( bool IsSucceed )
{
	if(IsSucceed)
	{
		LOGGER(LOG_LEVEL_NORMAL, _T("{OpTrunk2Trunk}: 中继[%lu]转外线成功, DestNum = %s"), m_pHostChan->no(), m_DestNumber);
	}
	else
	{
		
		
		LOGGER(LOG_LEVEL_WARNING, _T("{OpTrunk2Trunk}: 中继[%lu]转外线失败, DestNum = %s"), m_pHostChan->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 COpTrunk2Trunk::start( LineOpParam* pParam )
{
	// 校验状态
	if(m_pHostChan->state() != CHAN_LOGIC_STATE_STANDBY) 
		return false;

	// 保存被叫信息
	m_DestNumber = pParam->szParam2;

	// 通知启动日志
	LOGGER(LOG_LEVEL_NORMAL, _T("{OpTrunk2Trunk}: 中继[%lu]转外线, DestNum = %s"), m_pHostChan->no(), m_DestNumber);
	return false;

//	return CFsProxy::GetInstance().bridge(dynamic_cast<CChanTrunk*>(m_pHostChan), pParam->szParam1, m_DestNumber);
}

/*****************************************************************
**【函数名称】	hangup
**【函数功能】	操作中挂机
**【参数】		
**【返回值】	
*****************************************************************/
bool COpTrunk2Trunk::hangup( LONG InstanceHangup )
{
	// 转座席取消日志
	LOGGER(LOG_LEVEL_NORMAL, _T("{OpTrunk2Trunk}: 中继[%lu]转外线时挂机, DestNum = %s"), m_pHostChan->no(), m_DestNumber);

	m_InstanceCancel = InstanceHangup;
	return CFsProxy::GetInstance().hangup(dynamic_cast<CChanTrunk*>(m_pHostChan));
}

/*****************************************************************
**【函数名称】	onHostChanStateUpdated
**【函数功能】	关联通道状态更新处理
**【参数】		
**【返回值】	
*****************************************************************/
void COpTrunk2Trunk::onHostChanStateUpdated( CVirtualChan* pHostChan )
{
	if(m_pHostChan->state() == CHAN_LOGIC_STATE_FREE)
		
		_end(false);
}

/*****************************************************************
**【函数名称】	onSessionChanStateUpdated
**【函数功能】	同会话中通道状态更新处理
**【参数】		
**【返回值】	
*****************************************************************/
void COpTrunk2Trunk::onSessionChanStateUpdated( CVirtualChan* pChan )
{
	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);
		break;
	}
}