mod_localmediaplay.h 6.6 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215
  1. #include "SpBase.h"
  2. #include "SpIni.h"
  3. #ifdef RVC_OS_WIN
  4. #include <Shlwapi.h>
  5. #include "../../Other/libwmpplayer/libwmpplayer.h"
  6. #include "../../Other/libimgplayer/libimgplayer.h"
  7. #else
  8. #include <pthread.h>
  9. #include <signal.h>
  10. #include "../../Other/libmediaplayer/libmediaplayer.h"
  11. #include "../../Other/libpictureplayer/libpictureplayer.h"
  12. #endif // RVC_OS_WIN
  13. #include "LocalMediaPlay_server_g.h"
  14. #include "AdvertBase/AdvertSync.h"
  15. #include "AdvertManage/mediaManage.h"
  16. #include <iostream>
  17. //#include "SpTest.h"
  18. #include "modVer.h"
  19. using namespace LocalMediaPlay;
  20. #define LOG_EVT_SELFCHECK_IEBROWSER_IDLE 0x50500007 //IEBrowser重启
  21. #define MAX_PLAY_CHANNELS 3 //最大播放通道数
  22. typedef struct {
  23. int nCfgInx;
  24. int nWndX;
  25. int nWndY;
  26. int nWndWidth;
  27. int nWndHeight;
  28. }MediaPlayParam;
  29. //DWORD WINAPI qryMedia(LPVOID lpv);
  30. //DWORD WINAPI MediaPlayThread(LPVOID param);
  31. //DWORD WINAPI clearOutdata(LPVOID lpv);
  32. //DWORD WINAPI CheckAudioThread(LPVOID param);
  33. #ifdef RVC_OS_WIN
  34. class CLocalMediaPlayEntity : public CWmpHostApi, public CImgHostApi, public CEntityBase, public ILogListener
  35. #else
  36. class CLocalMediaPlayEntity : public CMediaHostApi, public CPicHostApi, public CEntityBase, public ILogListener
  37. #endif // RVC_OS_WIN
  38. {
  39. public:
  40. CLocalMediaPlayEntity();
  41. virtual ~CLocalMediaPlayEntity();
  42. virtual const char *GetEntityName() const { return "LocalMediaPlay"; }
  43. virtual bool IsService() const { return true; }
  44. const char* GetEntityVersion() const override
  45. {
  46. return MODULE_VERSION_FULL;
  47. }
  48. virtual CServerSessionBase *OnNewSession(const char* pszRemoteEntityName, const char * pszClass);
  49. #ifdef RVC_OS_WIN
  50. virtual BOOL LoadPlayConfig(CWmpPlayConfig& config, int CfgInx);
  51. virtual BOOL LoadPlayConfig(CImgPlayConfig& config, int CfgInx);
  52. virtual void WmpDebug(const char* fmt, ...);
  53. virtual void ImgDebug(const char* fmt, ...);
  54. #else
  55. virtual int LoadPlayConfig(CMediaPlayConfig& config, int CfgInx);
  56. virtual int LoadPlayConfig(CPicPlayConfig& config, int CfgInx);
  57. virtual void Debug(const char* fmt, ...);
  58. virtual void PicDebug(const char* fmt, ...);
  59. #endif // _WIN32
  60. virtual void OnLog(const CAutoArray<CUUID> &SubIDs, const CUUID nLogID, const LogTypeEnum eLogType, const SeverityLevelEnum eLevel,
  61. const DWORD dwSysError, const DWORD dwUserCode, const DWORD dwEntityInstanceID, const WORD wEntityDevelID,
  62. const CAutoArray<DWORD> &Param, const char *pszEntityName, const char *pszModuleName, const char *pszMessage);
  63. virtual void OnPreStart(CAutoArray<CSimpleStringA> strArgs, CSmartPointer<ITransactionContext> pTransactionContext);
  64. ErrorCodeEnum __OnStart(ErrorCodeEnum preOperationError);
  65. virtual void OnPreClose(EntityCloseCauseEnum eCloseCause, CSmartPointer<ITransactionContext> pTransactionContext);
  66. ErrorCodeEnum __OnClose(ErrorCodeEnum preOperationError);
  67. void StartVideo(int nCfgInx, int nWndX, int nWndY, int nWndWidth, int nWndHeight);
  68. void StartAudio(const char *pAudioNames);
  69. void StartImage(int nCfgInx, int nWndX, int nWndY, int nWndWidth, int nWndHeight);
  70. void StopVideo(int nCfgInx);
  71. void StopAudio();
  72. void StopImage(int nCfgInx);
  73. void StopAll();
  74. bool GetLocalVideoVolume(int nCfgInx, int &nVolume);
  75. bool SetLocalVideoVolume(int nCfgInx, int nVolume);
  76. std::pair<bool, int> GetLocalAudioVolume();
  77. bool SetLocalAudioVolume(int nVolume);
  78. bool IsRunConfigExist();
  79. protected:
  80. // 音频播放对象指针
  81. #ifdef RVC_OS_WIN
  82. Clibwmpplayer* m_pAudioPlayer;
  83. #else
  84. Clibmediaplayer* m_pMediaAudioPlayer;
  85. #endif // RVC_OS_WIN
  86. private:
  87. virtual void OnSelfTest(EntityTestEnum eTestType, CSmartPointer<ITransactionContext> pTransactionContext);
  88. // 按分隔符分隔字符串
  89. void CStringSplit(char *str, char **result, const char *del);
  90. //friend DWORD WINAPI clearOutdata(LPVOID lpv);
  91. #ifdef RVC_OS_WIN
  92. friend DWORD WINAPI MediaPlayThread(LPVOID param);
  93. friend DWORD WINAPI qryMedia(LPVOID lpv);
  94. friend DWORD WINAPI CheckAudioThread(LPVOID param);
  95. #else
  96. friend void* queryMedia(void* param);
  97. friend void* CheckAudioPlayingThreadFunc(void* param);
  98. friend int StartMediaPlay(void* param);
  99. #endif // RVC_OS_WIN
  100. void setMediaPath();
  101. void SecureClientRelease();
  102. bool SecureClientConnect();
  103. void loadDefaultMedia();
  104. private:
  105. int m_id_seq;
  106. CUUID m_SubIDIEIdle;
  107. #ifdef RVC_OS_WIN
  108. // 视频播放对象指针数组
  109. Clibwmpplayer* m_pVideoPlayer[MAX_PLAY_CHANNELS];
  110. // 图片播放对象指针数组
  111. Clibimgplayer* m_pImagePlayer[MAX_PLAY_CHANNELS];
  112. #else
  113. // 媒体播放对象指针数组
  114. Clibmediaplayer* m_pMediaPlayer[MAX_PLAY_CHANNELS];
  115. // 图片播放对象指针数组 add by clp 20201103
  116. Clibpictureplayer* m_pPicturePlayer[MAX_PLAY_CHANNELS];
  117. #endif // RVC_OS_WIN
  118. //连接获取最新广告资源
  119. CAdvertSyncConnection *m_connection;
  120. mediaManage m_mediaManage;
  121. MediaPlayParam m_mediaParam;
  122. int m_defaultVolum;
  123. std::string m_lastPlayAudio;
  124. #ifdef RVC_OS_WIN
  125. HANDLE m_scanThread, m_playThread;
  126. vector<CWmpPlayConfig> m_defaultVideo;
  127. vector<CWmpPlayConfig> m_defaultAudio;
  128. vector<CImgPlayConfig> m_defaultImg;
  129. #else
  130. pthread_t m_scanThreadId;
  131. vector<CMediaPlayConfig> m_Videos;
  132. vector<CMediaPlayConfig> m_Audios;
  133. vector<CPicPlayConfig> m_defaultPic;
  134. #endif // RVC_OS_WIN
  135. };
  136. class CLocalMediaPlaySession : public PlayService_ServerSessionBase
  137. {
  138. public:
  139. CLocalMediaPlaySession(CLocalMediaPlayEntity* pEntity, int id) : m_id(id), m_pEntity(pEntity)
  140. {
  141. }
  142. virtual void Handle_StartPlayVideo(SpReqAnsContext<PlayService_StartPlayVideo_Req, PlayService_StartPlayVideo_Ans>::Pointer ctx);
  143. virtual void Handle_StartPlayAudio(SpReqAnsContext<PlayService_StartPlayAudio_Req, PlayService_StartPlayAudio_Ans>::Pointer ctx);
  144. virtual void Handle_StartPlayImage(SpReqAnsContext<PlayService_StartPlayImage_Req, PlayService_StartPlayImage_Ans>::Pointer ctx);
  145. virtual void Handle_StopPlayVideo(SpReqAnsContext<PlayService_StopPlayVideo_Req, PlayService_StopPlayVideo_Ans>::Pointer ctx);
  146. virtual void Handle_StopPlayAudio(SpReqAnsContext<PlayService_StopPlayAudio_Req, PlayService_StopPlayAudio_Ans>::Pointer ctx);
  147. virtual void Handle_StopPlayImage(SpReqAnsContext<PlayService_StopPlayImage_Req, PlayService_StopPlayImage_Ans>::Pointer ctx);
  148. virtual void OnClose(ErrorCodeEnum eErrorCode);
  149. virtual void Handle_GetLocalVideoVolume(SpReqAnsContext<PlayService_GetLocalVideoVolume_Req, PlayService_GetLocalVideoVolume_Ans>::Pointer ctx);
  150. virtual void Handle_SetLocalVideoVolume(SpReqAnsContext<PlayService_SetLocalVideoVolume_Req, PlayService_SetLocalVideoVolume_Ans>::Pointer ctx);
  151. virtual void Handle_GetLocalAudioVolume(SpReqAnsContext<PlayService_GetLocalAudioVolume_Req, PlayService_GetLocalAudioVolume_Ans>::Pointer ctx);
  152. virtual void Handle_SetLocalAudioVolume(SpReqAnsContext<PlayService_SetLocalAudioVolume_Req, PlayService_SetLocalAudioVolume_Ans>::Pointer ctx);
  153. private:
  154. int m_id;
  155. CLocalMediaPlayEntity* m_pEntity;
  156. };