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


COpTurnIvr::COpTurnIvr(COperationReactor* pParent, LONG Instance) : COperation(pParent, Instance), m_pAssoChan(NULL)
{
}


COpTurnIvr::~COpTurnIvr(void)
{
}

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

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

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

	m_pAssoChan = CFsProxy::GetInstance().getTrunk(pParam->nParam2);
	ASSERT(m_pAssoChan != NULL);
	if(m_pAssoChan == NULL)
	{
		LOGGER(LOG_LEVEL_WARNING, _T("{OpTurnIvr}: 通道[%lu]转IVR失败, 查找目标通道[%d]失败"), m_pHostChan->no(), pParam->nParam2);
		return false;
	}

	bool IsTurnBack = pParam->nParam3 == 1 ? true : false;
	if(IsTurnBack)
		return CFsProxy::GetInstance().transfer2Context(uniqueId(), m_pHostChan->chanId(), FS_PARK_EXTEN_IN_CONTEXT, CConfig::extContext());
	else
		return CFsProxy::GetInstance().kill(uniqueId(), m_pHostChan);
}

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