myvtm/Module/mod_RomoteController/mod_RemoteController.cpp

#include "stdafx.h"
#include "SpBase.h"
#include "Event.h"

#include "RemoteController_server_g.h"
using namespace RemoteController;

#include "RemoteControllerFSM.h"

// Ô¶³Ì¿ØÖÆ 0x504
class CRemoteControllerEntity;

class CRemoteControllerSession : public RemoteControllerService_ServerSessionBase
{
public:
	CRemoteControllerSession(CRemoteControllerEntity *pEntity) : m_pEntity(pEntity) {}
	virtual ~CRemoteControllerSession() {}

private:
	CRemoteControllerEntity *m_pEntity;
};

//class PinPadClass;
class CRemoteControllerEntity : public CEntityBase, public ILogListener
{
public:
	CRemoteControllerEntity()	{ }	
	virtual ~CRemoteControllerEntity() {}

	virtual const char *GetEntityName() const { return "RemoteController"; }
	virtual bool IsService()const{return true;}

	virtual void OnStarted()
	{
		m_FSM.Init(this);
		// subscribe heartbeat entity event for create remote control channel
		GetFunction()->SubscribeLog(m_LogSubID, this, Log_Event,  Severity_None, Error_IgnoreAll, EVENT_START_REMOTE_CONTROL, "HeartBeat", true);
	}	

	virtual void OnPreClose(EntityCloseCauseEnum eCloseCause,CSmartPointer<ITransactionContext> pTransactionContext)
	{
		m_FSM.PostExitEvent();

		GetFunction()->UnsubscribeLog(m_LogSubID);
		pTransactionContext->SendAnswer(Error_Succeed);
	}
		
	virtual CServerSessionBase *OnNewSession(const char* /*pszRemoteEntityName*/, const char * /*pszClass*/)
	{
		return new CRemoteControllerSession(this);
	}

	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)
	{
		//assert(dwUserCode == EVENT_START_REMOTE_CONTROL);
		DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM).setAPI("OnLog")("recv log event: %d", dwUserCode);
		if (dwUserCode == EVENT_START_REMOTE_CONTROL)
		{
			if (m_FSM.GetCurrStateName() != "None")
			{
				DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM).setAPI("OnLog")("already in remote control mode, terminate it now");
				m_FSM.PostEventFIFO(new FSMEvent(CRemoteControllerFSM::Event_ReleaseChannel));		
			}

			DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM).setAPI("OnLog")("trigger event Event_CreateChannel");
			m_FSM.PostEventFIFO(new FSMEvent(CRemoteControllerFSM::Event_CreateChannel));		
		}
	}
		
protected:
	CUUID m_LogSubID;
	CRemoteControllerFSM m_FSM;
};

SP_BEGIN_ENTITY_MAP()
	SP_ENTITY(CRemoteControllerEntity)
SP_END_ENTITY_MAP()