Middlewares-Linux/FreeSWITCH-l.../OpListen.cpp

#include "OpListen.h"

#include "ChanExten.h"
#include "OperationReactor.h"
#include "FsProxy.h"


COpListen::COpListen(COperationReactor* pParent, long Instance) : COperation(pParent, Instance), m_DestExten(0)
{
}


COpListen::~COpListen(void)
{
}

/*****************************************************************
**【函数名称】	_end
**【函数功能】	操作完成
**【参数】		IsSucceed	操作是否成功
				lpData		随路数据
**【返回值】
****************************************************************/
void COpListen::_end(bool IsSucceed)
{
	if (IsSucceed)
	{
		LOG_INFO("{OpListen}: 分机[%lu]监听成功, DestExten = %lu", m_pHostChan->no(), m_DestExten);
	}
	else
	{
		LOG_WARN("{OpListen}: 分机[%lu]监听失败, DestExten = %lu", m_pHostChan->no(), m_DestExten);
	}

	SqlWrite::GetInstance()->addSql(toSql(IsSucceed, "监听"));

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

	m_pParent->onOpResult(m_Instance, this, IsSucceed,std::to_string(m_pHostChan->no()));
}

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

	// 查找被监听的分机
	sscanf(pParam->szParam2.c_str(), "%lu", &m_DestExten);
	ChanExten* pDestExten = CFsProxy::GetInstance().getExten(m_DestExten);
	if (pDestExten == nullptr)
	{
		LOG_WARN("{OpListen}: 分机[%lu]执行监听失败, 查找目标分机[%lu]失败", m_pHostChan->no(), m_DestExten);
		return false;
	}

	// 被监听分机状态校验
	if (pDestExten->state() != CHAN_LOGIC_STATE_TALKING)
	{
		LOG_WARN("{OpListen}: 分机[%lu]执行监听失败, 目标分机[%lu]未在通话中", m_pHostChan->no(), m_DestExten);
		return false;
	}

	LOG_INFO("{OpListen}: 分机[%lu]执行监听, DestExten = %lu", m_pHostChan->no(), m_DestExten);

	auto pAssoChan = CFsProxy::GetInstance().getAssoChanInSession(pDestExten);
	if (pAssoChan != nullptr)
		m_SessionId = pAssoChan->sessionId();

	m_Caller = std::to_string(m_pHostChan->no());
	m_CallerAgent = CFsProxy::GetInstance().getAgentByExten(m_Caller);
	m_Callee = pParam->szParam2;
	m_CalleeAgent = CFsProxy::GetInstance().getAgentByExten(m_Callee);
	m_OpTime = Util::CurTime();

	m_pHostChan->opNumber() = pParam->szParam2;
	//if (pAssoChan != nullptr)
	//	m_pHostChan->opNumber() = pAssoChan->callerNum();   // 对端线路主叫号，来电弹屏时使用
	return CFsProxy::GetInstance().listen(uniqueId(), m_pHostChan, pDestExten->chanId());
}

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