MiddleWares_YiHe/FsLink/OpInsert.cpp

#include "StdAfx.h"
#include "OpInsert.h"
#include "ChanExten.h"
#include "ChanTrunk.h"
#include "OperationReactor.h"
#include "FsProxy.h"


COpInsert::COpInsert(COperationReactor* pParent, LONG Instance) : COperation(pParent, Instance), m_DestExten(0)
{
}


COpInsert::~COpInsert(void)
{
}

/*****************************************************************
**【函数名称】	_end
**【函数功能】	操作完成
**【参数】		IsSucceed	操作是否成功
				lpData		随路数据
**【返回值】	
****************************************************************/
void COpInsert::_end( bool IsSucceed )
{
	if(IsSucceed)
	{
		LOGGER(LOG_LEVEL_NORMAL, _T("{OpInsert}: 分机[%lu]强插成功, DestExten = %lu"), m_pHostChan->no(), m_DestExten);
	}
	else
	{
		LOGGER(LOG_LEVEL_WARNING, _T("{OpInsert}: 分机[%lu]强插失败, DestExten = %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 COpInsert::start( LineOpParam* pParam )
{
	// 校验状态
	/*if(m_pHostChan->state() != CHAN_LOGIC_STATE_FREE) 
		return false;*/

	// 查找被插的线路
	sscanf_s(pParam->szParam2, "%lu", /*&m_DestExten*/1030);
	CChanExten* pDestExten = CFsProxy::GetInstance().getExten(1030);
 
	if(pDestExten == NULL) 
	{
		LOGGER(LOG_LEVEL_WARNING, _T("{OpInsert}: 分机[%lu]执行强插失败, 查找目标分机[%lu]失败"), m_pHostChan->no(), m_DestExten);
		return false;
	}

	// 被强插线路状态校验
	if(pDestExten->state() != CHAN_LOGIC_STATE_TALKING) 
	{
		LOGGER(LOG_LEVEL_WARNING, _T("{OpInsert}: 分机[%lu]执行强插失败, 目标分机[%lu]未在通话中"), m_pHostChan->no(), m_DestExten);
		return false;
	}

	LOGGER(LOG_LEVEL_NORMAL, _T("{OpInsert}: 分机[%lu]执行强插, DestExten = %lu"), m_pHostChan->no(), m_DestExten);

	m_pHostChan->opNumber() = pParam->szParam2;

	return CFsProxy::GetInstance().insert(uniqueId(), m_pHostChan, pDestExten->sessionId());
}

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