Z991239-4157 #comment mod_mediacontroller实体启动优化

Module/mod_mediacontroller/CMakeLists.txt

@@ -20,6 +20,7 @@ set(${MODULE_PREFIX}_SRCS
     MediaController_def_g.h
     MediaController_msg_g.h
     MediaController_server_g.h
+	mod_mediacontroller.h
 
 	${STDAFXCPP}
 

Module/mod_mediacontroller/mod_mediacontroller.h

@@ -0,0 +1,192 @@
+#pragma once
+
+#include "SpBase.h"
+#include "SpIni.h"
+
+#include "MediaController_server_g.h"
+#include "MediaController_msg_g.h"
+#include "ExternalCameraMsg.h"
+
+#include "../mod_selfchecker/SelfChecker_client_g.h"
+#include "../mod_selfchecker/SelfChecker_def_g.h"
+#include "../include/ModuleMix.h"
+#include "../include/EventCode.h"
+
+// id:0x208
+#include "../mod_assistantchannel/AssistantChannel_client_g.h"
+#include "../mod_assistantchannel/chan_protocol.h"
+
+#include "../mod_ScannerSet/ScannerSet_client_g.h"
+#include "../mod_ScannerSet/ScannerSet_def_g.h"
+
+using namespace ScannerSet;
+using namespace AssistantChannel;
+using namespace SelfChecker;
+using namespace MediaController;
+
+
+struct CCameraBrightValue
+{
+	int nValue;
+	void Serialize(SpBuffer& Buf)
+	{
+		Buf& nValue;
+	}
+};
+
+
+class CMediaControllerEntity;
+
+class SelfChekerClient :public SelfCheckerService_ClientBase
+{
+public:
+	SelfChekerClient(CMediaControllerEntity* pEntity);
+};
+
+class ChannelMediaControllerClient : public ChannelService_ClientBase
+{
+public:
+	ChannelMediaControllerClient(CMediaControllerEntity* pEntity);
+	virtual void OnMessage(ErrorCodeEnum Error, ChannelService_State_Info& Msg, CSmartPointer<IReleasable> pData);
+	virtual void OnMessage(ErrorCodeEnum Error, ChannelService_Packet_Info& Msg, CSmartPointer<IReleasable> pData);
+};
+
+class MediaServiceSession : public MediaService_ServerSessionBase
+{
+public:
+	MediaServiceSession(CMediaControllerEntity* pEntity) : m_pEntity(pEntity) {}
+	virtual void Handle_GetVideoDeviceName(SpReqAnsContext<MediaService_GetVideoDeviceName_Req, MediaService_GetVideoDeviceName_Ans>::Pointer ctx);
+	virtual void Handle_StartCamera(SpOnewayCallContext<MediaService_StartCamera_Info>::Pointer ctx);
+	virtual void Handle_StopCamera(SpOnewayCallContext<MediaService_StopCamera_Info>::Pointer ctx);
+
+	virtual void Handle_StartEnvCamera(SpReqAnsContext<MediaService_StartEnvCamera_Req, MediaService_StartEnvCamera_Ans>::Pointer ctx);
+	virtual void Handle_StopEnvCamera(SpOnewayCallContext<MediaService_StopEnvCamera_Info>::Pointer ctx);
+	//add by clp 20200319
+	virtual void Handle_StartSpeakerRender(SpOnewayCallContext<MediaService_StartSpeakerRender_Info>::Pointer ctx);
+	virtual void Handle_StopSpeakerRender(SpOnewayCallContext<MediaService_StopSpeakerRender_Info>::Pointer ctx);
+
+private:
+	CMediaControllerEntity* m_pEntity;
+};
+
+
+class CMediaControllerEntity : public CEntityBase, public ILogListener, public ITimerListener, public ISysVarListener
+{
+public:
+	CMediaControllerEntity() : m_capture(NULL), m_salesaudio_capture(NULL), m_lCaptureEnvCount(0), m_nCameraErrorCode(Error_Succeed),
+		m_lCaptureEnvOptCount(0), m_lCaptureOptCount(0), m_iEnvEmptyTimes(0), m_iOptEmptyTimes(0), m_bSendCameraError(false),
+		m_nEnvCameraRestartNum(0), m_nOptCameraRestartNum(0), m_nCameraCount(2), m_pSelfcheckClient(NULL),
+		strFrontCam("$"), strRearCam("$"), strEnvCam("$"), strUSBCam("$"), strEwsCam("$"), m_bCustomerwareBegin(false),
+		m_pAudioRenderObj(NULL), m_bRecordPCM(false), m_bIsRemoteRecord(false), m_bHasStartSpeakerRender(false) {
+
+#ifdef RVC_OS_LINUX
+		m_env_mutex = PTHREAD_MUTEX_INITIALIZER;
+		m_opt_mutex = PTHREAD_MUTEX_INITIALIZER;
+		m_envopt_mutex = PTHREAD_MUTEX_INITIALIZER;
+		m_pAudioCap = NULL;
+#endif
+	}
+
+	virtual ~CMediaControllerEntity() {}
+	virtual const char* GetEntityName() const { return "MediaController"; }
+	virtual bool IsService()const { return true; }
+	virtual void OnSysVarEvent(const char* pszKey, const char* pszValue, const char* pszOldValue, const char* pszEntityName);
+	virtual void OnPreStart(CAutoArray<CSimpleStringA> strArgs, CSmartPointer<ITransactionContext> pTransactionContext);
+	virtual void OnStarted();
+	DeviceTypeEnum RvcGetDeviceType();
+	void SetCameraSysVar(int n);
+	ErrorCodeEnum GetSalesRecordAudioParam();
+	ErrorCodeEnum SetEnvCameraOnSysVar(const CSimpleStringA strOnState);
+	ErrorCodeEnum SetCameraSysVar(const CSimpleStringA& newVal);
+	virtual void OnPreClose(EntityCloseCauseEnum eCloseCause, CSmartPointer<ITransactionContext> pTransactionContext);
+	virtual void OnTimeout(DWORD dwTimerID);
+	bool SetAutoBright(ErrorCodeEnum nCode);
+	//camera gain adjust
+	void OnReceivePkt(int sub_type, const char* buffer, int size);
+	ErrorCodeEnum RealSelfCheck();
+	void SendCameraBright();
+	ErrorCodeEnum StartEnvCamera();
+	ErrorCodeEnum StopEnvCamera();
+	ErrorCodeEnum ExternStartCamera();
+	ErrorCodeEnum ExternStopCamera();
+	ErrorCodeEnum SaveInnerCamera();
+	ErrorCodeEnum GetHSPCameras(CAutoArray<CSimpleStringA>& HSPCameras);
+	ErrorCodeEnum HandleSalesRecordPCMAudio(bool bRemoteRecord, const char* pszMessage, audio_frame* pFrame = NULL);
+	void HandleRemoteRecord(const char* pszMessage);
+	ErrorCodeEnum StartSpeakerAudioRender(int iQueue, audio_frame* pFrame, const char* strName);
+	ErrorCodeEnum StopSpeakerAudioRender();
+	ErrorCodeEnum SetSalesRecordAudioCaptureTransActionData(eRvcPCMTransType eType, void* pData);
+
+
+public:
+	bool m_bSendCameraError;
+	int m_iEnvEmptyTimes;
+	int m_iOptEmptyTimes;
+	int m_nEnvCameraRestartNum;
+	int m_nOptCameraRestartNum;
+	DeviceTypeEnum m_eDeviceType;
+	BOOL m_bStartCamera;
+	BOOL m_bExternControlCam;
+	capture_config_t conf;
+	rvc_audio_capture_config_s m_sales_audio_conf;			//销售双录音频配置
+	ErrorCodeEnum m_nCameraErrorCode;     //摄像头故障码，0：无故障，1：env摄像头故障，2：opt摄像头故障，3：双摄像头故障
+	int m_nCurActiveCamera;				//当前正在使用的摄像头
+	CSimpleStringA strFrontCam;
+	CSimpleStringA strRearCam;
+	CSimpleStringA strEnvCam;           //Env摄像头 add by ly 20160331
+	CSimpleStringA strUSBCam;           //外接摄像头 add by ly 20160329
+	CSimpleStringA strEwsCam;			//外部广角摄像头路径名（全程录像用，通常不配置）
+	int m_nCameraCount;                 //当前摄像头数量 add by ly 20160531
+	int m_nSysCallType;					//0:普通模式，1：p2p模式
+	capture_t* m_capture;
+	rvc_sales_audio_capture_t* m_salesaudio_capture;
+	BOOL m_bCustomerwareBegin;
+	bool m_bHasStartSpeakerRender;			//add by clp 20200416	是否已开启扬声器音频采集
+
+
+private:
+	ErrorCodeEnum LoadRunConfig(CSimpleStringA& frontcam, CSimpleStringA& rearcam);
+	ErrorCodeEnum CheckConfigCameraName(capture_config_t* conf);
+	ErrorCodeEnum GetSalesAudioConfig(rvc_audio_capture_config_t* conf, bool bRemoteRecord);
+	ErrorCodeEnum AutoGetVideoDeviceName(capture_config_t* conf);
+	ErrorCodeEnum LoadConfig(capture_config_t* conf);
+	void OnExternalCameraSwitchFailed(const char* pszFailedMsg);
+	virtual void 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, const linkContext& pLinkInfo);
+	virtual void OnSelfTest(EntityTestEnum eTestType, CSmartPointer<ITransactionContext> pTransactionContext);
+	//获取当前使用摄像头，30分钟轮休一次
+	int GetActiveCamera();
+	ErrorCodeEnum ChangeSysvar(ErrorCodeEnum op);
+	void AutoCorrectCameraConfigName(long wait_time);
+	//开始销售双录音频采集函数
+	ErrorCodeEnum StartSalesRecordAudioCapture(bool bRemoteRecord = false, eRvcPCMTransType eType = eUnKnown, void* pData = NULL);
+	//停止销售双录音频采集函数
+	ErrorCodeEnum StopSalesRecordAudioCapture();
+	ErrorCodeEnum StartCamera();
+	ErrorCodeEnum StartCamera(int nCamera);
+	void StartCameraAndTiggerRecord(const char* strSessionId);
+	ErrorCodeEnum ReStartCamera(int nCamera);
+	virtual CServerSessionBase* OnNewSession(const char* pszRemoteEntityName, const char* pszClass);
+	ErrorCodeEnum RvcGetAudioDevice();
+
+private:
+	LONG m_lCaptureEnvCount;
+	LONG m_lCaptureOptCount;
+	LONG m_lCaptureEnvOptCount;
+	CAutoArray<CUUID> m_arrListener;
+	ChannelMediaControllerClient* m_pMediaControllerChannel;
+	SelfChekerClient* m_pSelfcheckClient;
+	IAudioRender* m_pAudioRenderObj;		//add by clp 20200319	扬声器捕捉实体
+	bool m_bRecordPCM;						//add by clp 20200401   是否单独录制PCM音频
+	int m_nSalesAudioSmpPsec;				//add by clp 20200402   销售双录音频采样率
+	bool m_bIsRemoteRecord;					//add by clp 20200403	是否是远程双录
+
+#ifdef RVC_OS_WIN
+#else
+	pthread_mutex_t m_env_mutex;
+	pthread_mutex_t m_opt_mutex;
+	pthread_mutex_t m_envopt_mutex;
+	IAudioMgr* m_pAudioCap;
+#endif
+};