Jonhon_MiddWareWinStandard/FsLink/OpLeaveWord....

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


COpLeaveWord::COpLeaveWord(COperationReactor* pParent, LONG Instance) : COperation(pParent, Instance)
{
}


COpLeaveWord::~COpLeaveWord(void)
{
}

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

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

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

/*****************************************************************
**【函数名称】	__makeDir
**【函数功能】	创建录音目录
**【参数】
**【返回值】
****************************************************************/
bool COpLeaveWord::__makeDir(CString& LeaveFile)
{
	int index = LeaveFile.ReverseFind('\\');
	if (index == -1)
		index = LeaveFile.ReverseFind('/');

	CString Dir = LeaveFile.Left(index + 1);
	SHCreateDirectoryEx(NULL, Dir, NULL);
	LeaveFile.Replace("\\", "/");

	return true;
}

/*****************************************************************
**【函数名称】	start
**【函数功能】	执行操作
**【参数】		
**【返回值】	
*****************************************************************/
bool COpLeaveWord::start( LineOpParam* pParam )
{
	// 线路是否在通话中
	if(m_pHostChan->state() != CHAN_LOGIC_STATE_STANDBY) 
		return false;

	UINT LimitTime = pParam->nParam3;
	m_FileName =  pParam->szParam3;
	// 2019-12-31 创建留言文件夹
	if (!__makeDir(m_FileName))
		return false;

	// 录音启动日志
	LOGGER(LOG_LEVEL_NORMAL, _T("{OpLeaveWord}: 中继[%lu]执行留言, FileName = %s, LimitTime = %lu(s), FinishKey = '%s'"),
		m_pHostChan->no(), m_FileName, LimitTime, pParam->szParam1);

	return CFsProxy::GetInstance().leaveWord(dynamic_cast<CChanTrunk*>(m_pHostChan), m_FileName, LimitTime, pParam->szParam1[0]);
}

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

/*****************************************************************
**【函数名称】	onChanAppExecuted
**【函数功能】	通道任务执行结束事件处理
**【参数】		
**【返回值】	
*****************************************************************/
void COpLeaveWord::onChanAppExecuted( CVirtualChan* pHostChan, PAPP_EXEC_NOTIFY pNotify )
{
	ASSERT(pNotify != NULL);
	if (pNotify == NULL)
		return;
	if(lstrcmp(pNotify->App, ESL_APP_LEAVEWORD) == 0)
		_end(true);
}