myvtm/Module/mod_IDCertificate/mod_IDCertificate.h

#ifndef MOD_IDCERTIFICATE_H
#define MOD_IDCERTIFICATE_H

#ifdef RVC_OS_LINUX
#include "SpTest.h"
#endif

#include "modVer.h"
#include "IDCertFSM.h"
#include "IDCertificate_server_g.h"
#include "IDCertificate_UserErrorCode.h"

class CIDCertEntity;

class IDCertServerSession : public IDCertificate::IDCertService_ServerSessionBase
{
public:
	IDCertServerSession(CIDCertEntity* pEntity) : m_pEntity(pEntity){}
	virtual ~IDCertServerSession(){}
	virtual void Handle_CancelRead(SpOnewayCallContext<IDCert_CancelRead_Info>::Pointer ctx);
	virtual void Handle_CancelReadJS(SpReqAnsContext<IDCert_CancelReadJS_Req, IDCert_CancelReadJS_Ans>::Pointer ctx);
	virtual void Handle_Exit(SpOnewayCallContext<IDCert_Exit_Info>::Pointer ctx);
	virtual void Handle_GetDevInfo(SpReqAnsContext<IDCert_GetDevInfo_Req, IDCert_GetDevInfo_Ans>::Pointer ctx);
	virtual void Handle_ReadAndScanUTF8(SpReqAnsContext<IDCert_ReadAndScanUTF8_Req, IDCert_ReadAndScanUTF8_Ans>::Pointer ctx); //ex1
	virtual void Handle_ReadAndScanUTF8JS(SpReqAnsContext<IDCert_ReadAndScanUTF8JS_Req, IDCert_ReadAndScanUTF8JS_Ans>::Pointer ctx);
private:
	CIDCertEntity* m_pEntity;
};
class CIDCertEntity : public CDevAdptEntityBase
{
public:
	CIDCertEntity(){}
	virtual ~CIDCertEntity(){}
	virtual const char *GetEntityName() const { return "IDCertificate"; }
	const char* GetEntityVersion() const { return MODULE_VERSION_FULL; }

	virtual void OnPreStart(CAutoArray<CSimpleStringA> strArgs,CSmartPointer<ITransactionContext> pTransactionContext) 
	{
		LOG_FUNCTION();
		ErrorCodeEnum rt = m_fsm.Init(this);
		pTransactionContext->SendAnswer(rt);
	}

	virtual void OnPrePause(CSmartPointer<ITransactionContext> pTransactionContext)
	{
		pTransactionContext->SendAnswer(Error_Succeed);
	}

	virtual void OnPreContinue(CSmartPointer<ITransactionContext> pTransactionContext)
	{
		pTransactionContext->SendAnswer(Error_Succeed);
	}

	virtual void OnPreClose(EntityCloseCauseEnum eCloseCause,CSmartPointer<ITransactionContext> pTransactionContext)
	{
		m_fsm.OnExit();
		pTransactionContext->SendAnswer(Error_Succeed);
	}

	virtual void OnSelfTest(EntityTestEnum eTestType,CSmartPointer<ITransactionContext> pTransactionContext)
	{
		m_fsm.SelfTest(eTestType,pTransactionContext);
	}

	virtual CServerSessionBase* OnNewSession(const char*,const char*)
	{
		return new IDCertServerSession(this);
	}

	void CancelRead(SpOnewayCallContext<IDCert_CancelRead_Info>::Pointer ctx)
	{
		CancelReadEvent* e = new CancelReadEvent();
		m_fsm.PostEventFIFO(e);
	}

	void CancelReadJS(SpReqAnsContext<IDCert_CancelReadJS_Req, IDCert_CancelReadJS_Ans>::Pointer ctx) //ex2
	{
		if (!m_fsm.GetDevInitFlag())
		{
			ctx->Answer(Error_DevNotAvailable, IDCertificate_UserErrorCode_DevOpenFailed);
			LogWarn(Severity_Middle, Error_DevNotAvailable, IDCertificate_UserErrorCode_DevOpenFailed, "Open Dev failed.(ReadAndScanUTF8JS)");

			return;
		}
		else if(!m_fsm.GetReadFlag())
		{
			ctx->Answer(Error_Unexpect, IDCertificate_UserErrorCode_ReadAndScan_NotOnReading);
			return;
		}

		CancelReadEvent* e = new CancelReadEvent();
		m_fsm.PostEventFIFO(e);
		ctx->Answer(Error_Succeed);
	}

	void Exit(SpOnewayCallContext<IDCert_Exit_Info>::Pointer ctx)
	{
		FSMEvent* evt = new FSMEvent(USER_EVT_EXIT);
		m_fsm.PostEventFIFO(evt);
	}

	void ReadAndScanUTF8(SpReqAnsContext<IDCert_ReadAndScanUTF8_Req, IDCert_ReadAndScanUTF8_Ans>::Pointer ctx) //ex2
	{
		if (!m_fsm.GetDevInitFlag())
		{
			ctx->Answer(Error_DevNotAvailable, IDCertificate_UserErrorCode_DevOpenFailed);
			LogWarn(Severity_Middle, Error_DevNotAvailable, IDCertificate_UserErrorCode_DevOpenFailed, "Open Dev failed.(ReadAndScanUTF8)");

			return;
		}

		ReadAndScanUTF8Event* e = new ReadAndScanUTF8Event();
		e->ctx = ctx;
		m_fsm.PostEventFIFO(e);
	}

	void ReadAndScanUTF8JS(SpReqAnsContext<IDCert_ReadAndScanUTF8JS_Req, IDCert_ReadAndScanUTF8JS_Ans>::Pointer ctx) //ex2
	{
		if (!m_fsm.GetDevInitFlag())
		{
			ctx->Answer(Error_DevNotAvailable, IDCertificate_UserErrorCode_DevOpenFailed);
			LogWarn(Severity_Middle, Error_DevNotAvailable, IDCertificate_UserErrorCode_DevOpenFailed, "Open Dev failed.(ReadAndScanUTF8JS)");

			return;
		}

		ReadAndScanUTF8JSEvent* e = new ReadAndScanUTF8JSEvent();
		e->ctx = ctx;
		m_fsm.PostEventFIFO(e);
	}

	void GetDevInfo(SpReqAnsContext<IDCert_GetDevInfo_Req, IDCert_GetDevInfo_Ans>::Pointer ctx)
	{
		if (m_fsm.m_bOpening)
		{
			ctx->Answer(Error_NotInit);
		}
		else if(!m_fsm.GetDevInitFlag())
		{
			ctx->Answer(Error_DevNotAvailable, IDCertificate_UserErrorCode_DevOpenFailed);
			return;
		}
		else
		{
			DevCategoryInfo devCatInfo;
			CSimpleStringA devType = "";
			ctx->Ans.state = m_fsm.GetDevCatInfo(devCatInfo, devType);
			ctx->Ans.model = devCatInfo.szModel;
			ctx->Ans.type = devCatInfo.szType;
			ctx->Ans.type += ((devType == "4") ? "#IG" : "#");

			ctx->Answer(Error_Succeed);

			return;
		}
	}

	virtual bool IsService()const{return true;}
	virtual bool IsMultiThread()const{return false;}
private:
	CIDCertFSM m_fsm;
};

#endif // MOD_IDCERTIFICATE_H