MiddleWares_YiHe/FsLink/OpPlayAndDtm...

#include "StdAfx.h"
#include "OpPlayAndDtmf.h"
#include "ChanTrunk.h"
#include "OperationReactor.h"
#include "FsProxy.h"
#include "ChanExten.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_TALKING && pParam == NULL)
	{
		m_bExecuteEnd = FALSE;
		m_bDtmfEnd = FALSE;
		m_bDtmfFinish = FALSE;

		// 初始化放音内容
		ZeroMemory(&m_PlayContent, sizeof(m_PlayContent));
		m_PlayContent.nModel = (PlayVoiceMode)2;
		lstrcpy(m_PlayContent.szFileName, "E:\\middleware_YiHe\\middleware_YiHe\\wav\\keep.mp3");
		//lstrcpy(m_PlayContent.szFileName, "E:\\midware\\ivr\\ivr_Rongji\\wav\\保持音.wav");
		//m_PlayContent.nDtmfCount = 1;
		//m_PlayContent.nDtmfPeriod = 0 ;
		//m_PlayContent.cDtmfEnd = '#';
		m_PlayContent.nTts = 1;			// TTS类型
		//m_PlayContent.nTtsDigitMode = 1;	// TTS数字播报模式
		m_PlayContent.nTtsSpeed = 50;		// TTS语速
		m_PlayContent.nTtsVolume = 50;		// 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<CChanExten*>(m_pHostChan), &m_PlayContent);
		//CFsProxy::GetInstance().ExtenPlayback(uniqueId(), dynamic_cast<CChanExten*>(m_pHostChan), &m_PlayContent);
	}
	// 当前的分机通道播放声音,之前的standby限制了cti中的与中继的通信消息传递
	/*if(m_pHostChan->state() != CHAN_LOGIC_STATE_STANDBY)
		return false;*/
	else
	{
		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);
	}
	
}

/*****************************************************************
**【函数名称】	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 )
{
	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;
	// by 将挂断操作标记修改为true
	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;
	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;
	}
}