middleware_xinyang-asr/FsLink/OpTurnExten....

#include "StdAfx.h"
#include "OpTurnExten.h"
#include "VirtualChan.h"
#include "OperationReactor.h"
#include "FsProxy.h"
#include "ChanExten.h"
#include "ChanTrunk.h"


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


COpTurnExten::~COpTurnExten(void)
{
}

/*****************************************************************
**【函数名称】	_end
**【函数功能】	操作完成
**【参数】		IsSucceed	操作是否成功
				lpData		随路数据
**【返回值】	
****************************************************************/
void COpTurnExten::_end( bool IsSucceed )
{
	if(IsSucceed)
	{
		LOGGER(LOG_LEVEL_NORMAL, _T("{OpTurnExten}: 中继[%lu]转分机成功, DestExt = %lu"), m_pHostChan->no(), m_DestExten);
	}
	else
	{
		LOGGER(LOG_LEVEL_WARNING, _T("{OpTurnExten}: 中继[%lu]转分机失败, DestExt = %lu"), m_pHostChan->no(), m_DestExten);
	}

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

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

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

	// 保存被叫信息
	sscanf_s(pParam->szParam2, _T("%u"), &m_DestExten);

	// 根据被叫号码查找对端线路且修正被叫号码
	CChanExten* pExten = CFsProxy::GetInstance().getExten(m_DestExten);
	if(pExten == NULL)
	{
		LOGGER(LOG_LEVEL_WARNING, _T("{OpTurnExten}: 中继[%lu]转分机失败, 查找分机通道[%lu]失败"), m_pHostChan->no(), m_DestExten);
		return false;
	} // end if

	// 校验状态
	if(!pExten->isFree())
	{
		LOGGER(LOG_LEVEL_WARNING, _T("{OpTurnExten}: 中继[%lu]转分机失败, 分机通道[%lu]非空闲"), m_pHostChan->no(), m_DestExten);
		return false;
	}

	// 通知启动日志
	LOGGER(LOG_LEVEL_NORMAL, _T("{OpTurnExten}: 中继[%lu]转分机, DestExt = %lu"), m_pHostChan->no(), m_DestExten);

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

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

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

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

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