Middleware_5.1/FsLink/OpHangup.cpp

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


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


COpHangup::~COpHangup(void)
{
}

/*****************************************************************
**【函数名称】	_end
**【函数功能】	操作完成
**【参数】		IsSucceed	操作是否成功
				lpData		随路数据
**【返回值】	
****************************************************************/
void COpHangup::_end( bool IsSucceed )
{
	if(IsSucceed)
	{
		LOGGER(LOG_LEVEL_NORMAL, _T("{OpHangup}: 通道[%lu]挂机成功"), m_pHostChan->no());
	}
	else
	{
		LOGGER(LOG_LEVEL_WARNING, _T("{OpHangup}: 通道[%lu]挂机失败"), m_pHostChan->no());
	}

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

/*****************************************************************
**【函数名称】	start
**【函数功能】	执行操作
**【参数】		
**【返回值】	
*****************************************************************/
bool COpHangup::start( LineOpParam* pParam )
{
	// 通知启动日志
	LOGGER(LOG_LEVEL_NORMAL, _T("{OpHangup}: 通道[%lu]执行挂机"), m_pHostChan->no());

	// 开始应答
	if(m_pHostChan->type() == DEV_RES_TYPE_EXT)
		return CFsProxy::GetInstance().kill(uniqueId(), m_pHostChan);
	else
		return CFsProxy::GetInstance().hangup(dynamic_cast<CChanTrunk*>(m_pHostChan));
}

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

/*****************************************************************
**【函数名称】	onChanAppExecuted
**【函数功能】	通道任务执行结束事件处理
**【参数】		
**【返回值】	
*****************************************************************/
void COpHangup::onChanAppExecuted( CVirtualChan* pHostChan, PAPP_EXEC_NOTIFY pNotify )
{
	if (pNotify == NULL)  
		return;
	 
	if(lstrcmp(pNotify->App, ESL_APP_HANGUP) == 0)
		_end(true);
}