MiddleWares_YiHe/FsLink/OpTurnExten....

#include "StdAfx.h"
#include "OpTurnExten.h"
#include "VirtualChan.h"
#include "OperationReactor.h"
#include "FsProxy.h"
#include "ChanExten.h"
#include "ChanTrunk.h"


COpTurnExten::COpTurnExten(COperationReactor* pParent, LONG Instance) : COperation(pParent, Instance)
{
	ZeroMemory(&m_PlayContent, sizeof(m_PlayContent));
	
}


COpTurnExten::~COpTurnExten(void)
{

}

/*****************************************************************
**【函数名称】	_end
**【函数功能】	操作完成
**【参数】		IsSucceed	操作是否成功
				lpData		随路数据
**【返回值】
****************************************************************/
void COpTurnExten::_end(bool IsSucceed)
{

	if (IsSucceed)
	{
		LOGGER(LOG_LEVEL_NORMAL, _T("{OpTurnExten}: 中继[%lu]转分机成功, DestExt = %lu"), m_pHostChan->no(), m_DestExten);
	}
	else
	{
		LOGGER(LOG_LEVEL_WARNING, _T("{OpTurnExten}: 中继[%lu]转分机失败, DestExt = %lu"), m_pHostChan->no(), m_DestExten);
	}

	// 返回执行结果
	if (m_InstanceCancel != FS_LINK_INSTANCE_INVALID)
		m_pParent->onOpResult(m_InstanceCancel, !IsSucceed);
    // 2019-08-11 颐和随访
	m_pParent->onOpResult(m_Instance, this, IsSucceed);
	
}

/*****************************************************************
**【函数名称】	start
**【函数功能】	执行操作
**【参数】
**【返回值】
*****************************************************************/
bool COpTurnExten::start(LineOpParam* pParam)
{
	// 颐和随访
	/*if (m_pHostChan->state() != CHAN_LOGIC_STATE_STANDBY)
	{
		return false;
	}*/

	// 保存被叫信息
	sscanf_s(pParam->szParam2, _T("%u"), &m_DestExten);

	// 根据被叫号码查找对端线路且修正被叫号码
	CVirtualChan* m_Exten = CFsProxy::GetInstance().getExten(m_DestExten);
	if (m_Exten == NULL)
	{
		LOGGER(LOG_LEVEL_WARNING, _T("{OpTurnExten}: 中继[%lu]转分机失败, 查找分机通道[%lu]失败"), m_pHostChan->no(),m_DestExten);
		return false;
	} // end if

	// 校验状态
	/*if (!pExten->isFree())
	{
		LOGGER(LOG_LEVEL_WARNING, _T("{OpTurnExten}: 中继[%lu]转分机失败, 分机通道[%lu]非空闲"), m_pHostChan->no(), m_DestExten);
		return false;
	}
*/
	// 通知启动日志
	LOGGER(LOG_LEVEL_NORMAL, _T("{OpTurnExten}: 中继[%lu]转分机, DestExt = %lu"), /*m_pHostChan->no()*/m_pHostChan->no(), m_DestExten);

	// 初始化放音内容
	ZeroMemory(&m_PlayContent, sizeof(m_PlayContent));

	bool b;
	//b = CFsProxy::GetInstance().bridge(dynamic_cast<CChanTrunk*>(m_pHostChan), pParam->szParam1, pParam->szParam2);
	b= CFsProxy::GetInstance().origine(dynamic_cast<CChanExten*>(m_pHostChan), pParam->szParam1, pParam->szParam2, uniqueId());
	//b = CFsProxy::GetInstance().origine("1002");
	if (b == true)
	{
		// 如何将1替换为业务数据
		CVirtualChan* m_p = CFsProxy::GetInstance().getTrunk(1);
		onSessionChanStateUpdated(m_p);

		// 
		return true;
	}
	else
	{
		return false;
	}
}

/*****************************************************************
**【函数名称】	hangup
**【函数功能】	操作中挂机
**【参数】
**【返回值】
*****************************************************************/
bool COpTurnExten::hangup(LONG InstanceHangup)
{
	// 转座席取消日志
	LOGGER(LOG_LEVEL_NORMAL, _T("{OpTrunk2Trunk}: 中继[%lu]转分机时挂机, DestExt = %lu"), m_pHostChan->no(), m_DestExten);

	m_InstanceCancel = InstanceHangup;
	return CFsProxy::GetInstance().hangup(dynamic_cast<CChanTrunk*>(m_pHostChan));
}

/*****************************************************************
**【函数名称】	onHostChanStateUpdated
**【函数功能】	关联通道状态更新处理
**【参数】
**【返回值】
*****************************************************************/
void COpTurnExten::onHostChanStateUpdated(CVirtualChan* pHostChan)
{
	if (m_pHostChan->state() == CHAN_LOGIC_STATE_FREE)
	{
		LOGGER(LOG_LEVEL_NORMAL, _T("{OpTurnExten:CHAN_LOGIC_STATE_FREE}"));
		_end(false);
	}
	if (m_pHostChan->state() == CHANNEL_EVENT_ANSWER && m_pHostChan->type() == DEV_RES_TYPE_EXT)
	{
		LOGGER(LOG_LEVEL_NORMAL, _T("{OpTurnExten:CHANNEL_EVENT_ANSWER}"));
		_end(true);
	}
	std::cout << "TurnExten:" << pHostChan->sessionId() << endl;
}

/*****************************************************************
**【函数名称】	onSessionChanStateUpdated
**【函数功能】	同会话中通道状态更新处理
**【参数】
**【返回值】
*****************************************************************/
void COpTurnExten::onSessionChanStateUpdated(CVirtualChan* pChan)
{
	std::cout << "COpTurnExten::onSessionChanStateUpdatedonSessionChanStateUpdated" << pChan->sessionId() << endl;
	switch (pChan->state())
	{
		
	case CHAN_LOGIC_STATE_RING_BACK:
	case CHAN_LOGIC_STATE_ALERTING:
		m_pParent->onOpProcess(m_Instance, m_pHostChan->no(), pChan->no(), pChan->type(), pChan->callerNum(), pChan->calleeNum());
		break;

	case CHAN_LOGIC_STATE_TALKING:
	{
		LOGGER(LOG_LEVEL_NORMAL, _T("{OpTurnExten:CHAN_LOGIC_STATE_TALKING}"));
		_end(true);
		break;
	}
	case CHAN_LOGIC_STATE_FREE:
	{
		LOGGER(LOG_LEVEL_NORMAL, _T("{OpTurnExten:CHAN_LOGIC_STATE_FREE}"));
		_end(false);
		break;
	}
	case CHAN_LOGIC_STATE_STANDBY:
	{
		LOGGER(LOG_LEVEL_NORMAL, _T("{OpTurnExten:CHAN_LOGIC_STATE_STANDBY}"));
		m_pParent->onOpProcess(m_Instance, m_pHostChan->no(), pChan->no(), pChan->type(), pChan->callerNum(), pChan->calleeNum());
	}
		
	}
}