MiddleWares_YiHe/FsLink/OpPlayAndDtm...

#include "StdAfx.h"
#include "OpPlayAndDtmfExten.h"
#include "ChanTrunk.h"
#include "OperationReactor.h"
#include "FsProxy.h"
#include "ChanExten.h"


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


COpPlayAndDtmfExten::~COpPlayAndDtmfExten(void)
{
}

/*****************************************************************
**【函数名称】	_end
**【函数功能】	操作完成
**【参数】		IsSucceed	操作是否成功
				lpData		随路数据
**【返回值】
****************************************************************/
void COpPlayAndDtmfExten::_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 COpPlayAndDtmfExten::start1(LineOpParam* pParam,int n)
{
	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音量

	// 放音启动日志
	LOGGER(LOG_LEVEL_NORMAL, _T("{OpPlayAndDtmf}: 中继[%lu]放音收号, FileName = %s, Mode = %lu"),
		m_pHostChan->no(), m_PlayContent.szFileName, m_PlayContent.nModel);
	return CFsProxy::GetInstance().playAndDtmf(dynamic_cast<CChanTrunk*>(m_pHostChan), &m_PlayContent);
}
bool COpPlayAndDtmfExten::start(LineOpParam* pParam)
{
	CString EslCmd;
	// 初始化放音内容
	ZeroMemory(&m_PlayContent, sizeof(m_PlayContent));
	m_PlayContent.nModel = (PlayVoiceMode)pParam->nParam1;
	m_PlayContent.nTts = 1;
	lstrcpy(m_PlayContent.szFileName, "E:\\midware\\ivr\\ivr_Rongji\\wav\\mydstart.wav");


	return CFsProxy::GetInstance().playAndDtmf(dynamic_cast<CChanExten*>(m_pHostChan), &m_PlayContent);
}
/*****************************************************************
**【函数名称】	cancel
**【函数功能】	取消操作
**【参数】
**【返回值】
*****************************************************************/
bool COpPlayAndDtmfExten::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 COpPlayAndDtmfExten::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 COpPlayAndDtmfExten::onHostChanDtmf(LPCTSTR Dtmf)
{
	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 COpPlayAndDtmfExten::onHostChanStateUpdated(CVirtualChan* pHostChan)
{
	if (m_pHostChan == NULL) return;
	if (m_pHostChan->state() == CHAN_LOGIC_STATE_FREE)
		_end(false);
}

/*****************************************************************
**【函数名称】	onChanAppExecuted
**【函数功能】	通道任务执行结束事件处理
**【参数】
**【返回值】
*****************************************************************/
void COpPlayAndDtmfExten::onChanAppExecuted(CVirtualChan* pHostChan, PAPP_EXEC_NOTIFY pNotify)
{
	ASSERT(pNotify != NULL);
	if (pNotify == NULL)
		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;
	}
}