myvtm/Module/mod_SalesRecorder/mod_SalesRecorder.h

#pragma once

#include "SpBase.h"
#include "SpIni.h"
#include "SpTest.h"

#ifdef RVC_OS_WIN
#include "libwmpplayer/libwmpplayer.h"
#else
#include "libmediaplayer/libmediaplayer.h"
#endif // RVC_OS_WIN
#include "libvideorecord/libvideorecord.h"
#include "EventCode.h"

#include "SalesRecorder_server_g.h"
#include "SalesRecorder_msg_g.h"

#include "mod_selfchecker/SelfChecker_client_g.h"
#include "mod_selfchecker/SelfChecker_def_g.h"

using namespace SalesRecorder;

namespace SalesRecorder {
	typedef struct
	{
		char CustCardNo[24];
		char CustName[32];
		char ProductCode[32];
		char ProductName[128];
		char SapID[12];
		char CustManagerName[32];
		char Reserved1[128];
		char Reserved2[128];
	} RecordSubTitle;

	
	class CSalesRecorderEntity;
	
	class SalesRecordServiceSession : public SalesRecorderSerVice_ServerSessionBase
	{
	public:
		explicit SalesRecordServiceSession(CSalesRecorderEntity *pEntity) : m_pEntity(pEntity){}
		virtual void Handle_GetOFLVideoRecords(SpReqAnsContext<SalesRecorderSerVice_GetOFLVideoRecords_Req, SalesRecorderSerVice_GetOFLVideoRecords_Ans>::Pointer ctx);
		virtual void Handle_CheckVideoDiskStatus(SpReqAnsContext<SalesRecorderSerVice_CheckVideoDiskStatus_Req, SalesRecorderSerVice_CheckVideoDiskStatus_Ans>::Pointer ctx);
		virtual void Handle_PlayVideo(SpReqAnsContext<SalesRecorderSerVice_PlayVideo_Req, SalesRecorderSerVice_PlayVideo_Ans>::Pointer ctx);
		virtual void Handle_SaveVideo(SpReqAnsContext<SalesRecorderSerVice_SaveVideo_Req, SalesRecorderSerVice_SaveVideo_Ans>::Pointer ctx);
		virtual void Handle_StopRecord(SpReqAnsContext<SalesRecorderSerVice_StopRecord_Req, SalesRecorderSerVice_StopRecord_Ans>::Pointer ctx);
		virtual void Handle_SetAudioTransFlag(SpReqAnsContext<SalesRecorderSerVice_SetAudioTransFlag_Req, SalesRecorderSerVice_SetAudioTransFlag_Ans>::Pointer ctx);
		virtual void Handle_StopShowVideo(SpReqAnsContext<SalesRecorderSerVice_StopShowVideo_Req, SalesRecorderSerVice_StopShowVideo_Ans>::Pointer ctx);
		virtual void Handle_PlaySalesRecord(SpReqAnsContext<SalesRecorderSerVice_PlaySalesRecord_Req, SalesRecorderSerVice_PlaySalesRecord_Ans>::Pointer ctx);
		virtual void Handle_StartRemoteRecord(SpReqAnsContext<SalesRecorderSerVice_StartRemoteRecord_Req, SalesRecorderSerVice_StartRemoteRecord_Ans>::Pointer ctx);

	private:
		CSalesRecorderEntity *m_pEntity;
	};


	class SelfChekerClient:public SelfChecker::SelfCheckerService_ClientBase
	{
	public:
		explicit SelfChekerClient(CSalesRecorderEntity*pEntity);
	};

#ifdef RVC_OS_WIN
	class CSalesRecorderEntity : public CEntityBase, public CWmvHostApi, public CWmpHostApi, public ILogListener, public ISysVarListener, public ITimerListener
#else
	class CSalesRecorderEntity : public CEntityBase, public CHostApi, public CMediaHostApi, public ILogListener, public ISysVarListener, public ITimerListener
#endif // RVC_OS_WIN
	{
	public:
		CSalesRecorderEntity(): m_pRecorder(NULL), m_bStarted(FALSE), /*m_pPlayer(NULL),*/  m_bIsShowVideo(FALSE) { ZeroMemory(m_SalesVideoName, MAX_PATH); }
		virtual ~CSalesRecorderEntity() { /*empty implementation*/ }

		virtual const char *GetEntityName() const { return "SalesRecorder"; }

		const char* GetEntityVersion() const { return MODULE_VERSION_FULL; }

		ON_ENTITYT_TEST()

		virtual bool IsService() const{ return true; }

		virtual CServerSessionBase *OnNewSession(const char* pszRemoteEntityName, const char * pszClass);

		virtual void OnPreStart(CAutoArray<CSimpleStringA> strArgs,CSmartPointer<ITransactionContext> pTransactionContext);

		ErrorCodeEnum __OnStart(ErrorCodeEnum preOperationError);

		virtual void OnStarted();

		virtual void OnPreClose(EntityCloseCauseEnum eCloseCause,CSmartPointer<ITransactionContext> pTransactionContext);

		ErrorCodeEnum __OnClose(ErrorCodeEnum preOperationError);

		virtual void OnSelfTest(EntityTestEnum eTestType,CSmartPointer<ITransactionContext> pTransactionContext);

		virtual int GetActiveCamera();

		virtual int GetCameraState();

		virtual void Debug(record_loglevel elevel, const char* fmt, ...);
		
		virtual void vDebug(record_loglevel elevel, const char* str, va_list list);

		virtual void OnRecordFailed(eRvcRecordFailedCase eCase, const char* pszMessage, bool bRecordDevFault);

		virtual void OnRecordEntityExcption();

		virtual void OnRecordFinished();

#ifdef RVC_OS_WIN
		// CWmpHostAPI
		virtual void WmpDebug(const char *fmt, ...);
		virtual BOOL LoadPlayConfig(CWmpPlayConfig &config, int CfgInx) { return TRUE; }
#else
		virtual int LoadPlayConfig(CMediaPlayConfig& config, int CfgInx = 0) { return TRUE; }
		//virtual void Debug(const char* fmt, ...);
		virtual void MediaPlayFinished(int iMediaType){}
		virtual int GetMediaPlayerIcoPath(char* strPath, size_t uLen) {}
		virtual int GetAudioOutDevName(char* strDev, size_t uLen) {}
		virtual void Debug(media_loglevel log_level, const char* fmt, ...);
		virtual int PlayingAudioDataCallback(audio_param_t* param, const void* input, unsigned long uaudiolen) {}
#endif // RVC_OS_WIN

		virtual void OnTimeout(DWORD dwTimerID);

		virtual void OnSysVarEvent(const char *pszKey, const char *pszValue,const char *pszOldValue,const char *pszEntityName);

		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);

		ErrorCodeEnum DecideCameraCount(int &nCount);

		void StartRecord(const char *wmvfilename, int videoquality, int audioOutBitRate, SubtitleParam *subtitleParam = NULL, BOOL bWholeSection = FALSE, BOOL bSessionManage = FALSE, eRvcRecordType eRecordType = eSingleSide);

		void StartOnSiteSalesRecord(const int fps, const char* wmvfilename, int videoquality, int audioOutBitRate, SubtitleParam* subtitleParam, BOOL bWholeSection, BOOL bSessionManage, eRvcRecordType eRecordType);
		
		bool GetStandardQualityOnSiteSalesRecorder();
		
		bool GetHighQualityOnSiteSalesRecorder();
		
		ErrorCodeEnum StopRecord();
		
		ErrorCodeEnum ShowVideo(const char *wmvfilename);
		
		ErrorCodeEnum PlaySalesRecordVideo(const char *wmvfilename, int iWndX, int iWndY, int iWndWidth, int iWndHeight);

		void DeleteVideo(const char *wmvfilename);

		ErrorCodeEnum SaveVideo(const char *wmvfilename);

		// 获取终端准入状态（这个系统变量为A是表示准入通过）
		CSimpleStringA GetTerminalStage();

		bool SecureClientConnect();

		void SecureClientRelease();

		ErrorCodeEnum StopRecordVideo();

		ErrorCodeEnum HandleStopRecord(const char *pszMessage);
		ErrorCodeEnum HandleDisplayVideo();
		ErrorCodeEnum HandleSaveVideo();
		void HandleDeleteVideo();
		void HandleVideoAppendWatermark(const char* pszMessage);
		ErrorCodeEnum HandleStartRecord(const char *pszMessage, const bool bRemoteRecord);
		ErrorCodeEnum HandleSalesRecordEntityException(const char* pszMessage);
		ErrorCodeEnum RealSelfCheck();

		void UploadTempPathVideos();
		ErrorCodeEnum SetRecordAudioQuality(int iAudioQuality);
		ErrorCodeEnum SetRecordAudioNsPolicy(int iNsPolicy);

		DeviceTypeEnum RvcGetDeviceType();

		ErrorCodeEnum HandleStopShowVideo();
		ErrorCodeEnum HandlePlaySalesRecordVideo(int iWndX, int iWndY, int iWndWidth, int iWndHeight);

		bool InitSalesRecorder();
		bool ReleaseSalesRecorder();

	private:
		DeviceTypeEnum m_eDeviceType;
		int m_iActiveCamera;
		int m_iCameraState;
		bool m_bNeedRestart;		//add by clp 20200102

		// add by ly
#ifdef RVC_OS_WIN
		Clibwmpplayer* m_pPlayer;
#else
		//Clibmediaplayer* m_pPlayer;
#endif // RVC_OS_WIN
		bool m_bIsShowVideo;
		CAutoArray<CUUID> m_arrListener;
		char m_SalesVideoName[MAX_PATH];
		int  m_nSysCallType;                
		bool m_bStarted;
		Clibvideorecord *m_pRecorder;

		CSimpleStringA m_terminalNo;        
		CSimpleStringA m_TempDir;			
		CSimpleStringA m_RecordSaveDir;		

		bool m_last_disk_overtop;		    // 最近一次磁盘检查是否占用过高 add by ly at 2018/02/24
		int m_max_disk_percent;			    // 磁盘最大占用百分比 add by ly at 2018/02/24
		int m_audio_samplerate;             // 音频采样率 add by ly at 2018/06/13
		int m_audio_out_bitrate;            // 音频输出比特率 add by ly at 2018/06/07
		bool m_bWholeSection;               // 是否录一整段像 add by ly at 2018/06/07

		bool m_bApplyHighQuality;           // 是否应用高质量 add by ly@2019/04/18
		bool m_bEwsRecord;                  // 是否使用广角摄像头双录 add by ly@2019/04/18

		eAudioOutPutType m_eAudioOutQuality;
		bool m_bIsAudioNsOn;
		int m_iAudioNsPolicy;
		friend class SalesRecordServiceSession;
		eVideoFormat m_eRecordType;
	};
}