myvtm/Module/mod_salesaudiotrans/mod_salesaudiotrans.cpp

#include "mod_salesaudiotrans.h"

#define LOG_EVT_UI_STARTRECORD							0x30B00001				//开始录像
#define LOG_EVT_UI_STOPRECORD							0x30B00002				//停止录像

#define LOG_EVT_SALESRECORD_FINISHED					0x31500003				//销售双录结束

#define LOG_EVT_UI_RECORDFAILED							0x31500001				//双录失败
#define LOG_EVT_SALESRECORD_ENTITY_EXCEPTION			0x31500002				//销售双录实体异常



using namespace SalesAudioTrans;

void SalesAudioTransServiceSession::Handle_StartAudioTrans(SpReqAnsContext<SalesAudioTransService_StartAudioTrans_Req, SalesAudioTransService_StartAudioTrans_Ans>::Pointer ctx)
{
	LOG_FUNCTION();
	ErrorCodeEnum rc = Error_Succeed;
	rc = m_pEntity->StartAudioTrans(ctx->Req.VideoName, ctx->Req.Context, ctx->Req.ContextLen);
	ctx->Answer(rc);
}



ErrorCodeEnum CSalesAudioTransEntity::Load_RestFul_Functions()
{
	ErrorCodeEnum err = Error_NotImpl;

	CSimpleStringA szDllName = "libaudiotransmission.dll";

	if (NULL == m_fcreateobj) {
		m_hInst = LoadLibraryA(szDllName);
		if (m_hInst) {
			m_fcreateobj = (cpprestful_create)GetProcAddress(m_hInst, "CreateIAudioTransObj");
			if (NULL == m_fcreateobj) {
				return err;
			}
			m_fdestoryobj = (cpprestful_destory)GetProcAddress(m_hInst, "DestoryIAudioTransObj");
			if (NULL == m_fdestoryobj) {
				return err;
			}
			err = Error_Succeed;
		}
		else{
			DWORD tmpError = GetLastError();
			Dbg("LoadLibraryA [%s] failed with error %u.", szDllName.GetData(), tmpError);
		}
	}
	return err;
}


void CSalesAudioTransEntity::OnPreStart(CAutoArray<CSimpleStringA> strArgs,CSmartPointer<ITransactionContext> pTransactionContext) 
{ 
	ErrorCodeEnum Error = __OnStart(Error_Succeed);
	pTransactionContext->SendAnswer(Error) ;
}

ErrorCodeEnum CSalesAudioTransEntity::__OnStart( ErrorCodeEnum preOperationError )
{
	LOG_FUNCTION();
	ErrorCodeEnum Error = Error_Succeed;
	//MessageBoxA(0,0,0,0);
	if (Error_Succeed != Load_RestFul_Functions()){
		Dbg("load restful functions failed!");
		return Error;
	}
	else{
		Dbg("load restful functions success!");
	}

	Error = LoadConfig();
	
	int i = 0;
	m_arrListener.Init(5);

	GetFunction()->SubscribeLog(m_arrListener[i++], this, Log_Event, Severity_High, Error_IgnoreAll, LOG_EVT_SALESRECORD_FINISHED, NULL, false);
	GetFunction()->SubscribeLog(m_arrListener[i++], this, Log_Event, Severity_Middle, Error_IgnoreAll, LOG_EVT_UI_STARTRECORD, NULL, false);
	GetFunction()->SubscribeLog(m_arrListener[i++], this, Log_Event, Severity_Middle, Error_IgnoreAll, LOG_EVT_UI_STOPRECORD, NULL, false);
	GetFunction()->SubscribeLog(m_arrListener[i++], this, Log_Event, Severity_Middle, Error_IgnoreAll, LOG_EVT_UI_RECORDFAILED, NULL, false);
	GetFunction()->SubscribeLog(m_arrListener[i++], this, Log_Event, Severity_High, Error_IgnoreAll, LOG_EVT_SALESRECORD_ENTITY_EXCEPTION, NULL, false);

	return Error;
}

ErrorCodeEnum CSalesAudioTransEntity::LoadConfig()
{
	CSmartPointer<IEntityFunction> spFunction = GetFunction();
	CSmartPointer<IConfigInfo> spConfig;
	ErrorCodeEnum Error = spFunction->OpenConfig(Config_CenterSetting, spConfig);
	if (Error == Error_Succeed) {
		CSimpleStringA str_main_server;
		Error = spConfig->ReadConfigValue("SalesAudioTrans", "ASRServer", str_main_server);
		if (Error_Succeed == Error){
			if (str_main_server.GetLength() > MIN_URL_LEN){
				m_main_server = str_main_server;
			}
		}
		Dbg("audio recognize main server[%s]", m_main_server.GetData());

		if (Error_Succeed != Error){
			CSimpleStringA str_backup_server;
			Error = spConfig->ReadConfigValue("SalesAudioTrans", "ASRServer_Backup", str_backup_server);
			if (Error_Succeed == Error){
				if (str_backup_server.GetLength() > MIN_URL_LEN){
					m_backup_server = str_backup_server;
				}
			}
		}
		Dbg("audio recognize backup server[%s]", m_backup_server.GetData());

		int iTimeOut = DEFAULT_CONNECT_TIMEOUT;
		int iSize = DEFAULT_MAX_AUDIO_SEND_SIZE;
		Error = spConfig->ReadConfigValueInt("SalesAudioTrans", "ConnectTimeOut", iTimeOut);
		if (iTimeOut > 0 && iTimeOut < 5*DEFAULT_CONNECT_TIMEOUT){
			m_iconntimeout = iTimeOut;
		}
		Error = spConfig->ReadConfigValueInt("SalesAudioTrans", "MaxAudioSize", iSize);
		m_imaxaudiosendsize = SetMaxAudioSendSize(iSize);

		Dbg("connect timeout is %d, max audio transmission size is %d.",m_iconntimeout, m_imaxaudiosendsize);
	}
	return Error;
}


void CSalesAudioTransEntity::OnStarted()
{
	asr_server_info_t tServerInfo;
	tServerInfo.fCreateObj = m_fcreateobj;
	tServerInfo.fDestoryObj = m_fdestoryobj;
	tServerInfo.iMaxAudioSize = m_imaxaudiosendsize;
	tServerInfo.iTimeOut = m_iconntimeout;
	sprintf_s(tServerInfo.strMainServerURL, MAX_PATH, "%s", m_main_server.GetData());
	sprintf_s(tServerInfo.strBackupServerURL, MAX_PATH, "%s", m_backup_server.GetData());

	m_pAudioTrans = new Caudiotransmission(&tServerInfo);

	if (NULL != m_pAudioTrans){
		Dbg("create Caudiotransmission object success, and m_pAudioTrans address is %0x.", m_pAudioTrans);
	}
}

ErrorCodeEnum CSalesAudioTransEntity::StartAudioTrans(CSimpleStringW strVideoName, CBlob cBuffer, size_t uLen)
{
	LOG_FUNCTION();
	ErrorCodeEnum Error = Error_Succeed;
	if (NULL != m_pAudioTrans){
		char* result[16] = {0};
		auto arr1 = strVideoName.Split('@');
		auto arr2 = CAutoArray<CSimpleStringA>(arr1.GetCount());
		for (int i = 0; i < arr1.GetCount() && i <= 4; ++i)
		{
			arr2[i] = CSimpleStringW2A(arr1[i]);
			result[i] = const_cast<LPSTR>(arr2[i].GetData());
		}

		char strName[MAX_PATH] = {0};
		sprintf_s(strName, MAX_PATH, "%s", result[4]);//录像名：录像类型标志_录像流水号（如S_C13213EF）
		Dbg("record number is %s.", strName);

		if (0 == m_pAudioTrans->StartAudioTransmission(strName, cBuffer.m_pData, uLen)){
			m_bStartTrans = true;
		}
	}
	else{
		Error = Error_NotImpl;
	}

	return Error;
}


ErrorCodeEnum CSalesAudioTransEntity::StopAudioTrans()
{
	LOG_FUNCTION();
	ErrorCodeEnum Error = Error_NotImpl;
	if (m_bStartTrans){
		if (NULL != m_pAudioTrans){
			if (0 == m_pAudioTrans->StopAudioTransmission()){
				Error = Error_Succeed;
				m_bStartTrans = false;
				Dbg("stop audio transmission success!");
			}
			else{
				Dbg("stop audio transmission failed!");
			}
		}
		else{
			Dbg("audio trans object is invalid!");
		}
	}
	else{
		Dbg("audio transmission has stopped.");
	}

	return Error;
}

int CSalesAudioTransEntity::SetMaxAudioSendSize(int iSize)
{
	int iRet = DEFAULT_MAX_AUDIO_SEND_SIZE;
	if (iSize >= SINGLE_AUDIO_FRAME_SIZE && iSize < DEFAULT_MAX_AUDIO_SEND_SIZE)
	{
		iRet = (iSize/SINGLE_AUDIO_FRAME_SIZE)*SINGLE_AUDIO_FRAME_SIZE;
	} 

	return iRet;
}

void CSalesAudioTransEntity::OnLog(const CAutoArray<CUUID> &SubIDs, const CUUID nLogID,const LogTypeEnum eLogType, const SeverityLevelEnum eLevel, const DWORD dwSysError,const DWORD dwUserCode,const DWORD dwEntityInstanceID, const WORD wEntityDevelID, const CAutoArray<DWORD> &Param, const char *pszEntityName, const char *pszModuleName,const char *pszMessage)
{
	LOG_TRACE("user_code = %08x", dwUserCode);
	switch (dwUserCode)
	{
	//case LOG_EVT_UI_STOPRECORD:
	case LOG_EVT_SALESRECORD_FINISHED:
	case LOG_EVT_SALESRECORD_ENTITY_EXCEPTION:
	case LOG_EVT_UI_RECORDFAILED:
		StopAudioTrans();
		break;
	default:
		break;
	}
}

void CSalesAudioTransEntity::OnTimeout(DWORD dwTimerID)
{

}

void CSalesAudioTransEntity::OnSysVarEvent(const char *pszKey,const char *pszValue,const char *pszOldValue,const char *pszEntityName)
{

}


void CSalesAudioTransEntity::OnPreClose(EntityCloseCauseEnum eCloseCause,CSmartPointer<ITransactionContext> pTransactionContext) 
{ 
	ErrorCodeEnum Error = __OnClose(Error_Succeed);
	pTransactionContext->SendAnswer(Error); 
}

ErrorCodeEnum CSalesAudioTransEntity::__OnClose(ErrorCodeEnum preOperationError)
{
	LOG_FUNCTION();

	if (NULL != m_pAudioTrans){
		delete m_pAudioTrans;
		m_pAudioTrans = NULL;
	}

	SAFE_FREE_LIBRARY(m_hInst);
	m_hInst = NULL;

	CSmartPointer<IEntityFunction> spFunction = GetFunction();
	for (int i = 0; i < m_arrListener.GetCount(); ++i)
	{
		spFunction->UnsubscribeLog(m_arrListener[i]);
	}

	return Error_Succeed;
}

void CSalesAudioTransEntity::OnSelfTest(EntityTestEnum eTestType,CSmartPointer<ITransactionContext> pTransactionContext) 
{ 
	pTransactionContext->SendAnswer(Error_Succeed); 
}

CServerSessionBase* CSalesAudioTransEntity::OnNewSession(const char *pszRemoteEntityName, const char * pszParam)
{
	LOG_FUNCTION();
	Dbg("%s connected class = %s!", pszRemoteEntityName, pszParam);
	return new SalesAudioTransServiceSession(this);
}


SP_BEGIN_ENTITY_MAP()
SP_ENTITY(CSalesAudioTransEntity)
SP_END_ENTITY_MAP()