#include "stdafx.h"
#include "OpSetChannelVar.h"
#include "VirtualChan.h"
#include "FsProxy.h"
#include "OperationReactor.h"

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

COpSetChannelVar::~COpSetChannelVar(void)
{
}

bool COpSetChannelVar::attachHostChan(CVirtualChan * pChan)
{
	m_pHostChan = pChan;
	return true;
}

void COpSetChannelVar::detachHostChan(void)
{
	m_pHostChan = NULL;
}

bool COpSetChannelVar::start(LineOpParam * pParam)
{
	LOGGER(LOG_LEVEL_NORMAL, _T("{OpRecord}: 通道[%lu]执行设置通道变量,State:%d;[%s]"), m_pHostChan->no(), m_pHostChan->state(), pParam->szParam4);
	/*if (m_pHostChan->type() == DEV_RES_TYPE_EXT)
		return false;*/
	m_MeetingId.Format("%s", pParam->szParam3);
	LOGGER(LOG_LEVEL_NORMAL, _T("{OpRecord}: 通道[%lu]执行设置通道变量,ChanID[%s]SessionID[%s]"), m_pHostChan->no(), m_pHostChan->chanId(), m_pHostChan->sessionId());
	return CFsProxy::GetInstance().setChannelVariable(uniqueId(), m_pHostChan->chanId(),"asr_info",pParam->szParam4);
}

void COpSetChannelVar::onBackgroudJobDone(PBG_JOB_NOTIFY pNotify)
{
	if (strstr(pNotify->JobBody, ESL_JOB_DONE_RES_OK) == NULL)
		_end(false);
	else
		_end(true);
}

void COpSetChannelVar::_end(bool IsSucceed)
{
	if (IsSucceed)
	{
		LOGGER(LOG_LEVEL_NORMAL, _T("{OpRecord}: 通道[%lu]设置通道变量成功"), m_pHostChan->no());
	}
	else
	{
		LOGGER(LOG_LEVEL_WARNING, _T("{OpRecord}: 通道[%lu]设置通道变量失败"), m_pHostChan->no());
	}
	/*if (m_pHostChan)
		CFsProxy::GetInstance().ExecteApp("lua", "asr.lua "+ m_MeetingId, m_pHostChan->chanId());*/

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

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