myvtm/Module/mod_chromium/mod_chromium.h

#ifndef _CHROMIUM_ENTITY_H
#define _CHROMIUM_ENTITY_H
#include "Chromium_server_g.h"
#include "CWebsocketServer.h"
#include<map>
#include<string>
#include<tuple>
#if (defined _WIN32 || defined _WIN64)
#include "job.h"
#else
#include "modVer.h"
#endif
#include "guitask/enum.h"
#include "../mod_healthmanager/HealthManager_msg_g.h"
#include "../mod_ResourceWatcher/ResourceWatcher_msg_g.h"
#include "Chromium_server_g.h"
#include <boost/thread/mutex.hpp>
#include <boost/container/deque.hpp> //不知为什么，vs2010中std::deque没有函数提示


//ns::msg 在gcc下拼接有点问题，暂时不得不重新定义一个
#define SP_MSG_HANDLE_NS_EX(ns, msg, ns_msg, OnMsg) \
	case eMsg_##msg: \
				if (eMsgSig_##msg == dwMessageSignature) { \
					ns_msg t; \
					ErrorCodeEnum Error = SpBuffer2Object(Buffer, t); \
					if (Error == Error_Succeed) \
						OnMsg(pszEntityName, dwMessageId, dwMessageSignature, t); \
				} else { \
					LOG_TRACE("%s signature mismatched!", #msg); \
				} \
				break;




#pragma once
namespace Chromium
{

#define BROWSER_TIMER_ID 0xF002
#define BROWSER_TIMER_INTERVAL 3600000

	typedef struct
	{
		std::string key;
		std::string value;
		std::string oldValue;
		std::string entityName;
	}SYS_EVENT_PARAM;


	class CChromiumEntity;

	class ChromiumSession : public ChromiumSrv_ServerSessionBase
	{
	public:
		ChromiumSession(CChromiumEntity* pEntity) :m_pEntity(pEntity) {}
		virtual ~ChromiumSession() {}
		virtual void Handle_OpenBrowser(SpReqAnsContext<ChromiumSrv_OpenBrowser_Req, ChromiumSrv_OpenBrowser_Ans>::Pointer ctx);
		virtual void Handle_CloseBrowser(SpReqAnsContext<ChromiumSrv_CloseBrowser_Req, ChromiumSrv_CloseBrowser_Ans>::Pointer ctx);

	private:
		CChromiumEntity* m_pEntity;
	};

	class CChromiumEntity : public CEntityBase, public ILogListener, public IBroadcastListener, public ISysVarListener
	{
	public:
		CChromiumEntity();
		virtual ~CChromiumEntity();
		virtual const char* GetEntityName() const { return "Chromium"; }
#if (defined _WIN32 || defined _WIN64)
#else
		const char* GetEntityVersion() const { return MODULE_VERSION_FULL; }
#endif
		virtual bool IsService()const { return true; }

		virtual CServerSessionBase* OnNewSession(const char* /*pszRemoteEntityName*/, const char* /*pszParam*/)
		{
			return new ChromiumSession(this);
		}

		void OpenBrowser(SpReqAnsContext<ChromiumSrv_OpenBrowser_Req, ChromiumSrv_OpenBrowser_Ans>::Pointer ctx);
		void CloseBrowser(SpReqAnsContext<ChromiumSrv_CloseBrowser_Req, ChromiumSrv_CloseBrowser_Ans>::Pointer ctx);


		virtual void OnPaused();
		virtual void OnPreStart(CAutoArray<CSimpleStringA> strArgs, CSmartPointer<ITransactionContext> pTransactionContext);
		virtual void OnPreClose(EntityCloseCauseEnum eCloseCause, CSmartPointer<ITransactionContext> pTransactionContext);
		//void CefClintNotify();
		void exitClean();
		void FetchCustomMainUrl(CAutoArray<CSimpleStringA>& strArgs);
		bool HasCustomMainUrl() const { return !m_strCustomMainUrl.IsNullOrEmpty(); }
		const char* GetCustomMainUrl()  const { return m_strCustomMainUrl; }
		bool HasCustomAdUrl() const { return !m_strCustomAdUrl.IsNullOrEmpty(); }
		const char* GetCustomAdUrl()  const { return m_strCustomAdUrl; }
		bool IsConfigMode()
		{
#if (defined _WIN32 || defined _WIN64)
			return false;
#else
			static bool first(true);
			static bool result(false);

			if (first) {
				first = false;
				CSystemRunInfo runInfo;
				GetFunction()->GetSystemRunInfo(runInfo);
				if (runInfo.eState == FrameworkState_NotConfig)
					result = true;
			}

			return result;
#endif
		}

	private:
		void OnTaskTimerListener(void* pData);
#if (defined _WIN32 || defined _WIN64)
		void JobNotify();
#endif
		void OnBrowserCacheClean(const char* pszEntityName, DWORD dwMessageId, DWORD dwMessageSignature, ResourceWatcher::BrowserCacheClean& evt);
		void generateCefclientTimer();
		void generateBussinessLimitTimer();
		void openMainPage();
		void openAdPage();
		void openExtendPage();
		void startWithCfg();
		bool CheckIsCardStore();

	private:
		CSystemStaticInfo m_sysInfo;
		CWebsocketServer* m_pWsServer;
		ITimerListener* m_pTimerListener, * pBusinessLimitTimerListener;//浏览器监控Timer，业务禁用Timer
		int m_iTcpBridgePort;
		HANDLE m_hIOCP;
		HANDLE m_hThreadIOCP;
		CSimpleStringA m_strCustomMainUrl, m_strCustomAdUrl;
		bool m_runAd/*广告*/, m_runMain/*业务*/, m_runExtend/*低柜副屏*/, m_runLogin/*用户桌面，可能木有用*/, m_withBrowser/*是否需要与browser交互*/;
		bool m_withDebugMode/*是否启动debug模式*/, m_withMagic/*启用随机共享内存*/, m_withNoFileLog/*是否不需要本地日志落盘*/;
		bool m_withMin, m_withClose;

		boost::container::deque<SYS_EVENT_PARAM> m_eventArr;
		boost::mutex m_eventContorl, m_eventConditionMu; //sysvarEvent变化时阻塞修改
		boost::condition_variable_any m_eventCondition;//满足有数据时激活线程
		CAutoArray<CSimpleStringA> m_strArgs;
		CSmartPointer<ITransactionContext> m_pTransactionContext;
	public:
		boost::timed_mutex m_firstStartMain;//首次启动主页
		int getBrowserStartTimes();
	private:
		//subscribe
		CUUID m_uidCameraListener, m_uuidAccessAuth, m_uuidResourceWatch, m_uidBrowserListenser, m_uuidAccessAuthErr, m_uuidAllFault, m_uuidVTMLoader;
		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 OnSysVarEvent(const char* pszKey, const char* pszValue, const char* pszOldValue, const char* pszEntityName);
		void DoWithSysVarEvent();

		void OnTerminalManage(const char* pszEntityName, DWORD dwMessageId, DWORD dwMessageSignature, HealthManager::TerminalManager& evt);//终端锁定罚出

		void OnBusinessLimitTimerListener(void* pData);//每3600s检测业务禁用

		void checkUrlStartTime();

		void DoBrowserCacheClearJob();

		void OnPreStart_Init(CAutoArray<CSimpleStringA>& strArgs, CSmartPointer<ITransactionContext>& pTransactionContext);
		bool OnPreStart_socketStart(CAutoArray<CSimpleStringA>& strArgs, CSmartPointer<ITransactionContext>& pTransactionContext);
		bool OnPreStart_register(CAutoArray<CSimpleStringA>& strArgs, CSmartPointer<ITransactionContext>& pTransactionContext);
		bool OnPreStart_openWeb();
		SP_BEGIN_MSG_DISPATCH_MAP(CChromiumEntity)
			SP_BEGIN_ENTITY_MSG("ResourceWatcher")
			SP_MSG_HANDLE_NS_EX(ResourceWatcher, BrowserCacheClean, ResourceWatcher::BrowserCacheClean, OnBrowserCacheClean)
			SP_END_ENTITY_MSG()
			//SP_BEGIN_ENTITY_MSG("HealthManager")
			//SP_MSG_HANDLE_NS(HealthManager, TradeManage, OnTradeManage)
			//SP_MSG_HANDLE_NS_EX(HealthManager, TerminalManager, HealthManager::TerminalManager, OnTerminalManage)
			//SP_END_ENTITY_MSG()
			SP_END_MSG_DISPATCH_MAP()

	};

}
#endif