myvtm/Module/mod_SalesRecorder/mod_SalesRecorder.h

#ifndef _MOD_SALES_RECORD_H_
#define _MOD_SALES_RECORD_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 "libwmvrecord/libwmvrecord.h"
#include "UploadOFLRecord.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;


	// 录像字幕要素 add by ly. edit by ly 2018/02/27
	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);

	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 CWmvHostApi, 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), m_pConnection(NULL) { 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 void Debug(const char* fmt, ...);

		virtual void OnRecordFailed(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 AudioPlayFinished(){}
		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, ...);
#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);


		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 StartPhone2PadRecord(const int fps, const char* wmvfilename, int videoquality, int audioOutBitRate, SubtitleParam* subtitleParam, BOOL bWholeSection, BOOL bSessionManage, eRvcRecordType eRecordType);

		void StartOnSiteSalesRecord(const int fps, const char* wmvfilename, int videoquality, int audioOutBitRate, SubtitleParam* subtitleParam, BOOL bWholeSection, BOOL bSessionManage, eRvcRecordType eRecordType);

		BOOL GetStandardQualityOnSiteSalesRecorder(const eRvcRecordType eRecordType);

		BOOL GetHighQualityOnSiteSalesRecorder(const eRvcRecordType eRecordType);

		ErrorCodeEnum StopRecord();

		ErrorCodeEnum ShowVideo(const char *wmvfilename);
		ErrorCodeEnum PlaySalesRecordVideo(const char *wmvfilename, int iWndX, int iWndY, int iWndWidth, int iWndHeight);
		void DeleteAllVideo(const char *wmvfilename);

		void DeleteVideo(const char *wmvfilename);

		ErrorCodeEnum SaveVideo(const char *wmvfilename);

		// 检查网络状态
		ErrorCodeEnum CheckNetState();

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

		ErrorCodeEnum LoadServerConfig();

		bool SecureClientConnect();

		void SecureClientRelease();

		void OnEndUploadRecord(const char *videoserialid, int result);

		ErrorCodeEnum StopRecordVideo();

		// 初始化离线双录记录
		BOOL OFLRecordInit(char *pszVideoParam[]);

		// 保存离线双录时长
		void SaveOFLRecordDuration(int nDuration);

		// 提交离线双录记录
		void UploadOFLVideoRecord(const char *videorecordname);

		// 获取待上传的离线双录记录（返回给用户桌面）
		CSimpleStringW GetOFLVideoRecords(CSimpleStringA Name, CSimpleStringA CardNo, CSimpleStringA BeginTime, CSimpleStringA EndTime);

		//add by clp 20190919
		//void HandleStartRecord(const char *pszMessage);
		ErrorCodeEnum HandleStopRecord(const char *pszMessage);
		ErrorCodeEnum HandleDisplayVideo();
		ErrorCodeEnum HandleSaveVideo();
		void HandleDeleteVideo();
		void HandleReturnMenu();
		void HandleUkeyPullout();
		void HandleVideoAppendWatermark(const char* pszMessage);
		void HandleStartRecord(const char *pszMessage, const bool bRemoteRecord);
		ErrorCodeEnum HandleSalesRecordEntityException(const char* pszMessage);
		ErrorCodeEnum RealSelfCheck();

		void UploadTempPathVideos();
		int GetSystemMemoryUsage();
		double GetSystemCpuUsage();
		ErrorCodeEnum SetRecordAudioQuality(int iAudioQuality);
		ErrorCodeEnum SetRecordAudioNsPolicy(int iNsPolicy);

		ErrorCodeEnum HandleSetAudioTransmissionFlag(bool bFlag);
		ErrorCodeEnum HandleStopAudioStreamEnTransQueue();
		DeviceTypeEnum RvcGetDeviceType();

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

		int m_nUploadResult;				// 上传结果 -1:调用失败 0:上传失败 1:上传成功  add by ly 20180213
	private:
		DeviceTypeEnum m_eDeviceType;
		int nActiveCamera;
		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;                //0:普通模式，1：手机模式  add by chh 20170320    
		BOOL m_bStarted;
		Clibwmvrecord *m_pRecorder;

		CSimpleStringA m_terminalNo;        // 设备终端号   add by ly 20180213
		CSimpleStringA m_TempDir;			// 录像临时目录 add by ly 20180213
		CSimpleStringA m_RecordSaveDir;		// 录像上传目录 add by ly 20180213

		CUploadOFLRecordConnection *m_pConnection;

		CSimpleStringA m_server1;           // 分行服务地址（主） add by ly 20170320 add by ly 20180213
		int m_server1_port;                 // 分行服务端口（主） add by ly 20170320 add by ly 20180213
		CSimpleStringA m_server2;           // 分行服务地址（备） add by ly 20170320 add by ly 20180213
		int m_server2_port;                 // 分行服务端口（备） add by ly 20170320 add by ly 20180213

		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;
		bool m_bIsAudioTransOn;

		friend class CUploadOFLRecordConnection;
		friend class SalesRecordServiceSession;

		__int64  m_xIdlePre,m_xKernelPre,m_xUserPre;
	};

	struct UploadOFLVideoRecordTask : public ITaskSp
	{
		explicit UploadOFLVideoRecordTask(CSalesRecorderEntity* pEntity) 
			: m_pEntity(pEntity) {}

		void Process();

	private:
		CSalesRecorderEntity* m_pEntity;
	};


#endif