midware_ws/NetLib/FsLink/OpPlayAndDtm...

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


COpPlayAndDtmf::COpPlayAndDtmf(COperationReactor* pParent, LONG Instance) : COperation(pParent, Instance),m_Dtmf("")
{
	m_bExecuteEnd = FALSE;
	m_bDtmfEnd = FALSE;
	m_bDtmfFinish = FALSE;
	ZeroMemory(&m_PlayContent, sizeof(m_PlayContent));
}


COpPlayAndDtmf::~COpPlayAndDtmf(void)
{
}

/*****************************************************************
**【函数名称】	_end
**【函数功能】	操作完成
**【参数】		IsSucceed	操作是否成功
				lpData		随路数据
**【返回值】	
****************************************************************/
void COpPlayAndDtmf::_end( bool IsSucceed )
{
	if(IsSucceed)
	{
		LOGGER(LOG_LEVEL_NORMAL, _T("{OpPlayAndDtmf}: 中继[%lu]放音收号成功, DTMF = %s"), m_pHostChan->no(), m_Dtmf);
	}
	else
	{
		LOGGER(LOG_LEVEL_WARNING, _T("{OpPlayAndDtmf}: 中继[%lu]放音收号失败, DTMF = %s"), m_pHostChan->no(), m_Dtmf);
	}

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

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

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

	m_bExecuteEnd = FALSE;
	m_bDtmfEnd = FALSE;
	m_bDtmfFinish = FALSE;

	// 初始化放音内容
	ZeroMemory(&m_PlayContent, sizeof(m_PlayContent));
	m_PlayContent.nModel = (PlayVoiceMode)pParam->nParam1;
	lstrcpy(m_PlayContent.szFileName, pParam->szParam3);
	m_PlayContent.nDtmfCount = pParam->nParam7;
	m_PlayContent.nDtmfPeriod = pParam->nParam8;
	m_PlayContent.cDtmfEnd = pParam->szParam1[0];
	m_PlayContent.nTts = pParam->nParam2;			// TTS类型
	m_PlayContent.nTtsDigitMode = pParam->nParam3;	// TTS数字播报模式
	m_PlayContent.nTtsSpeed = pParam->nParam5;		// TTS语速
	m_PlayContent.nTtsVolume = pParam->nParam6;		// TTS音量
	m_PlayContent.nPlayCount = pParam->nParam10 <= 0 ? 1 : pParam->nParam10;    // 放音收号时，询问按键次数
	// 放音启动日志
	LOGGER(LOG_LEVEL_NORMAL, _T("{OpPlayAndDtmf}: 中继[%lu][%s]放音收号, FileName = %s, Mode = %lu"),
		m_pHostChan->no(), m_pHostChan->callerNum(), m_PlayContent.szFileName, m_PlayContent.nModel);

	// 启动放音
	return CFsProxy::GetInstance().playAndDtmf(dynamic_cast<CChanTrunk*>(m_pHostChan), &m_PlayContent);
}

/*****************************************************************
**【函数名称】	cancel
**【函数功能】	取消操作
**【参数】		
**【返回值】	
*****************************************************************/
bool COpPlayAndDtmf::cancel( LONG InstanceCancel )
{
	// 放音停止日志
	LOGGER(LOG_LEVEL_NORMAL, _T("{OpPlayAndDtmf}: 中继[%lu]取消放音收号"), m_pHostChan->no());

	m_InstanceCancel = InstanceCancel;
	if(CFsProxy::GetInstance().cancel(dynamic_cast<CChanTrunk*>(m_pHostChan)))
	{
		_end(false);
		return true;
	}
	else
	{
		return false;
	}
}

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

	LOGGER(LOG_LEVEL_NORMAL, _T("{OpPlayAndDtmf}: 中继[%lu]放音收号中挂机"), m_pHostChan->no());

	m_InstanceCancel = InstanceHangup;

	if(CFsProxy::GetInstance().hangup(dynamic_cast<CChanTrunk*>(m_pHostChan)))
	{
		_end(false);
		return true;
	}
	else
	{
		return false;
	}
}

/*****************************************************************
**【函数名称】	onHostChanDtmf
**【函数功能】	关联通道DTMF处理
**【参数】		
**【返回值】	
*****************************************************************/
void COpPlayAndDtmf::onHostChanDtmf( LPCTSTR Dtmf )
{
	// 2022-03-11 放音收号 ,只通过app执行完成获取按键信息，不通过通道按键事件
	if (m_PlayContent.nModel == PVM_PLAY_WAIT_DIGIT)
	{
		return;
	}

	ASSERT(Dtmf != NULL);
	m_Dtmf += Dtmf;

	if (m_PlayContent.nDtmfCount <= m_Dtmf.GetLength())
	{
		m_bDtmfEnd = TRUE; // 收号完成
	}

	if (m_bExecuteEnd == TRUE && m_bDtmfEnd == TRUE) // 如果 onChanAppExecuted 先执行完成  
	{
		_end(true);
		return;
	}
	else if (m_bDtmfEnd == TRUE)
	{
		m_bDtmfFinish = TRUE;
		return;
	}
}

/*****************************************************************
**【函数名称】	onHostChanStateUpdated
**【函数功能】	关联通道状态更新处理
**【参数】		
**【返回值】	
*****************************************************************/
void COpPlayAndDtmf::onHostChanStateUpdated( CVirtualChan* pHostChan )
{
	if (m_pHostChan == NULL) return;
	if(m_pHostChan->state() == CHAN_LOGIC_STATE_FREE)
		_end(false);
}

/*****************************************************************
**【函数名称】	onChanAppExecuted
**【函数功能】	通道任务执行结束事件处理
**【参数】		
**【返回值】	
*****************************************************************/
void COpPlayAndDtmf::onChanAppExecuted( CVirtualChan* pHostChan, PAPP_EXEC_NOTIFY pNotify )
{
	ASSERT(pNotify != NULL);
	if (pNotify == NULL)
		return;
	// 2022-03-11 放音收号 ,只通过app执行完成获取按键信息，不通过通道按键事件
	if (m_PlayContent.nModel == PVM_PLAY_WAIT_DIGIT)
	{
		m_Dtmf = pNotify->Result;
		if (m_Dtmf.IsEmpty() || m_Dtmf == "" || m_Dtmf.GetLength() == 0)
		{
			_end(false);
		}
		else
		{
			_end(true);
		}	
		return;
	}

	if (lstrcmp(pNotify->App, ESL_APP_PLAY_DTMF) == 0 || lstrcmp(pNotify->App, ESL_APP_PLAY) == 0)
	{
		if (m_PlayContent.nModel == PVM_PLAY_WAIT_DIGIT || m_PlayContent.nModel == PVM_WAIT_DIGIT)
		{
			if (m_bDtmfFinish == TRUE)
			{
				_end(true);
				return;
			}		
		}
		else
		{
			_end(true);
			return;
		}
		m_bExecuteEnd = TRUE;
		return;
	}
}