MiddleWares_YiHe/FsLink/OpHoldon.cpp

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


COpHoldon::COpHoldon(COperationReactor* pParent, LONG Instance) : COperation(pParent, Instance), m_IsTakeBack(false)
{
}


COpHoldon::~COpHoldon(void)
{
}

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

		// 返回执行结果
		m_pParent->onOpResult(m_InstanceCancel, IsSucceed);			
	}
	else
	{
		if(IsSucceed)
		{
			LOGGER(LOG_LEVEL_NORMAL, _T("{OpHoldon}: 分机[%lu]保持成功"), m_pHostChan->no());
			
		}
		else
		{
			LOGGER(LOG_LEVEL_WARNING, _T("{OpHoldon}: 分机[%lu]保持失败"), m_pHostChan->no());
		}

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

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

/*****************************************************************
**【函数名称】	start
**【函数功能】	执行操作
**【参数】		
**【返回值】	
*****************************************************************/
bool COpHoldon::start( LineOpParam* pParam )
{
	// 校验状态 by 屏蔽掉了原有的通道判断条件
	/*if(m_pHostChan->state() != CHAN_LOGIC_STATE_TALKING) 
		return false;*/

	LOGGER(LOG_LEVEL_NORMAL, _T("{OpHoldon}: 分机[%lu]呼叫保持"), m_pHostChan->no());
	
	bool result = CFsProxy::GetInstance().holdon(uniqueId(), m_pHostChan);
	onHostChanStateUpdated(m_pHostChan);
	return result;
}

/*****************************************************************
**【函数名称】	cancel
**【函数功能】	取消操作
**【参数】		
**【返回值】	
*****************************************************************/
bool COpHoldon::cancel( LONG InstanceCancel )
{
	LOGGER(LOG_LEVEL_NORMAL, _T("{OpHoldon}: 分机[%lu]呼叫接回"), /*m_pHostChan->no()*/1);

	m_InstanceCancel = InstanceCancel;
	m_IsTakeBack = true;
	bool b=CFsProxy::GetInstance().takeBack(uniqueId(), m_pHostChan);
	m_pHostChan->releaseOp(m_pHostChan->currOp()); //TJ 保持接回后，释放当前操作。否则无法挂机   2017.6.17
	return b;
}

/*****************************************************************
**【函数名称】	hangup
**【函数功能】	操作中挂机
**【参数】		
**【返回值】	
*****************************************************************/
bool COpHoldon::hangup( LONG InstanceHangup )
{
	if(m_InstanceCancel != FS_LINK_INSTANCE_INVALID)
		return false;

	LOGGER(LOG_LEVEL_NORMAL, _T("{OpHoldon}: 分机[%lu]保持中挂机"), m_pHostChan->no());

	m_InstanceCancel = InstanceHangup;

	if(CFsProxy::GetInstance().kill(uniqueId(), m_pHostChan))
	{
		_end(false);
		return true;
	}
	else
	{
		_end(true);
		return false;
	}
}

/*****************************************************************
**【函数名称】	onBackgroudJobDone
**【函数功能】	后台命令执行结束事件处理
**【参数】		
**【返回值】	
*****************************************************************/
void COpHoldon::onBackgroudJobDone( PBG_JOB_NOTIFY pNotify )
{
	if(m_IsTakeBack)
	{
		if(strstr(pNotify->JobBody, ESL_JOB_DONE_RES_OK) == NULL)
			m_pParent->onOpResult(m_InstanceCancel, false);	// 接回不成功不删该操作，以备再次接回之用
		else
			_end(true);
	}
	else
	{
		if(strstr(pNotify->JobBody, ESL_JOB_DONE_RES_OK) == NULL)
			_end(false);
		else
			m_pParent->onOpResult(m_Instance, true);	// 保持成功不删该操作，以备接回之用
	}
}

/*****************************************************************
**【函数名称】	onHostChanStateUpdated
**【函数功能】	关联通道状态更新处理
**【参数】		
**【返回值】	
*****************************************************************/
void COpHoldon::onHostChanStateUpdated( CVirtualChan* pHostChan )
{
	if(m_pHostChan->state() == CHAN_LOGIC_STATE_FREE)
	{
		//LOGGER(LOG_LEVEL_NORMAL, _T("{OpHoldon}: 分机[%lu] 对方挂机"), m_pHostChan->no());
		_end(false);
// 		COperation* pOp = m_pHostChan->currOp();
// 		if(pOp != NULL  )
// 		{
// 			pOp->hangup(FS_LINK_INSTANCE_INVALID);
// 			pOp->detachHostChan();
// 			FS_LINK_DELETE(pOp);	
// 		}
// 		else
// 		{
// 				CFsProxy::GetInstance().kill(FS_LINK_JOBID_INVALID, m_pHostChan);
// 		} // end if


	}
	else
	{
		_end(true);
	}
		
}