myvtm/Module/mod_healthmanager/HealthManagerFSM.cpp

#include "stdafx.h"
#include <fstream>
#include <string>
#include <algorithm>
#ifdef RVC_OS_WIN
#include <io.h>
#else
#include <unistd.h>
#include <fcntl.h>
#include <errno.h>
#endif

#include "CommEntityUtil.hpp"
#include "mod_healthmanager.h"
#include "publicFunExport.h"
#include "iniutil.h"

using namespace std;
const int MAX_AYSNC_TIMEOUT = 60000;
const int MAX_IGNORE_TIMEOUT = 100;

unsigned long long GetTickCountRVC() {
#ifdef RVC_OS_WIN
	return GetTickCount64();
#else
	struct timespec ts;
	clock_gettime(CLOCK_MONOTONIC, &ts);
	return (ts.tv_sec * 1000 + ts.tv_nsec / 1000000);
#endif //RVC_OS_WIN
}
unsigned long long GetLastErrorRVC() {
#ifdef RVC_OS_WIN
	return GetLastError();
#else
	return errno;
#endif //RVC_OS_WIN
}

enum EntityOP
{
	OP_STOP_ENTITY,
	OP_START_ENTITY,
	OP_PAUSE_ENTITY,
	OP_TERMINATE_ENTITY,
	OP_CONTINUE_ENTITY,
};

bool StrEqualNoCase(const char *s1, const char *s2,int len)
{
	if (strlen(s1) != strlen(s2))
		return false;
	for (int i = 0; i < len; ++i)
	{
		if (toupper(s1[i]) != toupper(s2[i]))
			return false;
	}
	return true;
}

ErrorCodeEnum CHealthManagerFSM::Initial()
{
    CSmartPointer<IEntityFunction> pFunc = GetEntityBase()->GetFunction();
    CSmartPointer<IEntityFunctionPrivilege> pFuncPrivilege = pFunc.ConvertCase<IEntityFunctionPrivilege>();
    CSmartPointer<IAsynWaitSp> spWait;

    ErrorCodeEnum err;

	CSimpleStringA cfgPath = "";
	CSimpleStringA strCoreBoot("CoreBoot"), strSafeLoad("SafeLoad"), strOp("Operating"), strIEBrower("IEBrowser");
    
    GetEntityBase()->GetFunction()->GetSystemStaticInfo(m_sysInfo);
    Dbg("machinetype[%s],terminalID[%s]", (LPCTSTR)m_sysInfo.strMachineType, (LPCTSTR)m_sysInfo.strTerminalID);

    strCoreBoot = strCoreBoot + "." + m_sysInfo.strMachineType;
    strSafeLoad = strSafeLoad + "." + m_sysInfo.strMachineType;
    strOp = strOp + "." + m_sysInfo.strMachineType;
    m_strURL = strIEBrower + "." + m_sysInfo.strMachineType + ".Url";

    m_AccessAuthTries = 4;
    m_InitTries = 4;
    m_AccessAuthTimeout = 180000;
    m_InitializationTimeout = 180000;
    int tmpAATries, tmpInitTries, tmpAATimeout, tmpInitTimout;

    CSmartPointer<IConfigInfo> spConfig;
    err = GetEntityBase()->GetFunction()->OpenConfig(Config_Software, spConfig);
    if (err != Error_Succeed) {
        Dbg("open cfg file failed!");
        return Error_IO;
    }
    if (spConfig->ReadConfigValueInt("init", "AccessAuthTries", tmpAATries) == Error_Succeed)
        m_AccessAuthTries = tmpAATries;
    if (spConfig->ReadConfigValueInt("init", "InitTries", tmpInitTries) == Error_Succeed)
        m_InitTries = tmpInitTries;
    if (spConfig->ReadConfigValueInt("init", "AccessAuthTimeout", tmpAATimeout) == Error_Succeed)
        m_AccessAuthTimeout = tmpAATimeout;
    if (spConfig->ReadConfigValueInt("init", "InitializationTimeout", tmpInitTimout) == Error_Succeed)
        m_InitializationTimeout = tmpInitTimout;

    CSmartPointer<IConfigInfo> spConfigRoot;
    GetEntityBase()->GetFunction()->OpenConfig(Config_Root, spConfigRoot);
    CSimpleStringA csGpioVendor("");
    spConfigRoot->ReadConfigValue("Device.Gpio", "Vendor", csGpioVendor);
	if (csGpioVendor.GetLength() > 1) {
		m_hasCfgGpioInRootIni = true;
	}

    int count, cbNum, slNum, opNum;
    count = cbNum = slNum = opNum = 0;

    err = GetEntityBase()->GetFunction()->GetPath("cfg", cfgPath);
    cfgPath = cfgPath + "/HealthManager.ini";
    Dbg("cfgpath[%s]", (const char*)cfgPath);

    ifstream is;
    is.open(cfgPath, ios::binary);
    if (!is.is_open()) {
        DWORD dwErr = GetLastErrorRVC();
        Dbg("open cfg file failed. [%d]", dwErr);
        return Error_IO;
    }
    string line;
    long curr, end;
    is.seekg(0, ios_base::end);
    end = is.tellg();
    is.seekg(0, ios_base::beg);
    LoadStage eSection = LOADSTAGE_UNKNOWN;

    do {
        getline(is, line);
        if (line[0] == '[') {
            size_t secEnd = line.find(']', 1);
            if (secEnd != string::npos) {
                string strSec = line.substr(1, secEnd - 1);
                if (StrEqualNoCase(strSec.c_str(), strCoreBoot, strSec.length()))
                    eSection = LOADSTAGE_COREBOOT;
                else if (StrEqualNoCase(strSec.c_str(), strSafeLoad, strSec.length()))
                    eSection = LOADSTAGE_SAFELOAD;
                else if (StrEqualNoCase(strSec.c_str(), strOp, strSec.length()))
                    eSection = LOADSTAGE_OPERATING;
                else
                    eSection = LOADSTAGE_UNKNOWN;
            }
        } else if (((unsigned)(line[0] + 1) > 256) || line[0] == ';') {//Chinese and other...
            curr = is.tellg();
            continue;
        } else if (isalpha(line[0])) {
            if (eSection == LOADSTAGE_UNKNOWN) {
                curr = is.tellg();
                continue;
            }
            size_t keyPos = line.find('=', 0);
            if (keyPos != string::npos) {
                string keyName = line.substr(0, keyPos);
                count++;
                switch (eSection) {
                case LOADSTAGE_COREBOOT:
                    spConfig->ReadConfigValueInt(strCoreBoot, keyName.c_str(), m_coreBootOpt[keyName.c_str()].loadOpt);
                    m_vCoreBoot.push_back(keyName.c_str());
                    m_vAllCfgEntity.push_back(keyName.c_str());
                    m_coreBootOpt[keyName.c_str()].eResult = LOADING_INIT;
                    m_coreBootOpt[keyName.c_str()].initSn = cbNum;
                    cbNum++;
                    break;
                case LOADSTAGE_SAFELOAD:
                    spConfig->ReadConfigValueInt(strSafeLoad, keyName.c_str(), m_safeLoadOpt[keyName.c_str()].loadOpt);
                    m_vSafeLoad.push_back(keyName.c_str());
                    m_vAllCfgEntity.push_back(keyName.c_str());
                    m_safeLoadOpt[keyName.c_str()].eResult = LOADING_INIT;
                    m_safeLoadOpt[keyName.c_str()].initSn = slNum;
                    slNum++;
                    break;
                case LOADSTAGE_OPERATING:
                    spConfig->ReadConfigValueInt(strOp, keyName.c_str(), m_operatingOpt[keyName.c_str()].loadOpt);
                    if (keyName.compare("Gpio") == 0 && !m_hasCfgGpioInRootIni)
                        Dbg("have configure gpio in HealthManager.ini,but can't find gpio in root.ini,ignore start gpio.");
                    else {
                        m_vOperating.push_back(keyName.c_str());
                        m_vAllCfgEntity.push_back(keyName.c_str());
                        m_operatingOpt[keyName.c_str()].eResult = LOADING_INIT;
                        m_operatingOpt[keyName.c_str()].initSn = opNum;
                        opNum++;
                    }
                    break;
                default:
                    break;
                }
            }
        }
        curr = is.tellg();
    } while (curr < end);

    is.close();
    Dbg("opt num:[%d]c[%d]s[%d]o[%d]", count, m_coreBootOpt.size(), m_safeLoadOpt.size(), m_operatingOpt.size());

    //read entity loading history record
    CSimpleStringA sysinfoPath = "";

#if defined(RVC_OS_LINUX)
    if (m_sysInfo.strMachineType.Compare("RVC.Stand2S") != 0) {
        CSimpleStringA strErrMsg = CSimpleStringA::Format("当前版本不支持此机型：%s", (LPCTSTR)m_sysInfo.strMachineType);
        SP::Module::Comm::LogErrorNotiyStruct notifyItem(Error_NotSupport, 0);
        SP::Module::Comm::LogNotiyMessageStruct notifyMsg(strErrMsg);
        notifyItem.Notify(notifyMsg);
        return Error_Succeed;
    }
#endif //RVC_OS_LINUX

    WaitDeamonFinishTask* task = new WaitDeamonFinishTask(this);
    GetEntityBase()->GetFunction()->PostThreadPoolTask(task);

    return Error_Succeed;
}

ErrorCodeEnum CHealthManagerFSM::OnInit(void)
{
	m_hMD5OKEvt = CreateEventA(NULL, FALSE, FALSE, NULL);
	if (m_hMD5OKEvt == NULL)
	{
		Dbg("CreateEvent failed(%d).", GetLastErrorRVC());
	}
	return Initial();
}
ErrorCodeEnum CHealthManagerFSM::OnExit(void)
{
	return Error_Succeed;
}

void CHealthManagerFSM::s0_on_entry(void)
{
	LOG_FUNCTION();
	m_fsmState = HM_FSM_INIT;
}

void CHealthManagerFSM::s0_on_exit(void)
{
}

unsigned int CHealthManagerFSM::s0_on_event(FSMEvent* pEvt)
{
	LOG_FUNCTION();
	int ret = 0;
	switch(pEvt->iEvt)
	{
	case USER_EVT_WAIT_DEAMON_FINISHED:
		ret = pEvt->param1;
		pEvt->SetHandled();
		break;
	default:
		break;
	}
	return ret;
}

/** move here from s1_on_entry [Gifur@2021521]*/
static inline bool IsCoolBootThisTime()
{
    //oilyang@20190924
	//修改为判断冷热启动，热重启不再等待10s
	//系统启动小于3分钟，认为是冷启动
    const ULONGLONG dwElapse = GetTickCountRVC();
    Dbg("have elapsed %d seconds from system start", dwElapse / 1000);
    if (dwElapse < 1000 * 60 * 3) {
        return true;
    }
	return false;
}

//CoreBoot
void CHealthManagerFSM::s1_on_entry()
{
	LOG_FUNCTION();

	m_fsmState = HM_FSM_STATE_COREBOOT;

	if (IsCoolBootThisTime()) {
		GetEntityBase()->GetFunction()->ShowStartupInfo("正在初始化，请稍等片刻......");
		Sleep(10000); 
	}

	ErrorCodeEnum eErrCode;
	eErrCode = GetEntityBase()->GetFunction()->SetSysVar("RunState","B");
	if (eErrCode != Error_Succeed)
	{
		Dbg("set RunState B failed %s.", SpStrError(eErrCode));
	}

	bool bWatchDog = false,bAsync = false;
	m_eStage = LOADSTAGE_COREBOOT;
	int ret = 0;
	map<CSimpleStringA,EntityLoadInfo>::iterator it;
	CSmartPointer<IEntityFunction> pFunc = GetEntityBase()->GetFunction();
	CSmartPointer<IEntityFunctionPrivilege> pFuncPrivilege = pFunc.ConvertCase<IEntityFunctionPrivilege>();
	//start entity
	
	vector<CSimpleStringA>::iterator vIt;
	if (m_coreBootOpt.size() == 0)
		goto COREBOOT_FINISH;

	char startMsg[128];
	for (vIt = m_vCoreBoot.begin(); vIt != m_vCoreBoot.end(); ++ vIt)
	{
		CSmartPointer<IAsynWaitSp> spWait;//oilyang 20160325 see the following comment
		it = m_coreBootOpt.find(*vIt);
		if (it == m_coreBootOpt.end())
		{
			Dbg("cannot find %s",(LPCSTR)*vIt);
			continue;
		}
		Dbg("start,%s,%d",(LPCSTR)it->first,it->second.loadOpt);
		CEntityRunInfo entRunInfo;
		ErrorCodeEnum errCode = pFunc->GetEntityRunInfo(it->first,entRunInfo);
		if (errCode == Error_Succeed && entRunInfo.eState == EntityState_Idle)
		{
			it->second.eResult = LOADING_SUCCEED;
			ret = CheckLoadResult(LOADSTAGE_COREBOOT);
			if (ret == 0 || ret == 2)
				goto COREBOOT_FINISH;
			else
				continue;
		}
		ZeroMemory(startMsg, 128);
		sprintf(startMsg, "正在启动实体%s...", it->first.GetData());
		GetEntityBase()->GetFunction()->ShowStartupInfo(startMsg);
		switch(it->second.loadOpt)
		{
			case LOADOPT_IGNORE:
			{
				pFuncPrivilege->StartEntity(it->first,NULL,spWait);
				if (spWait != NULL)
					spWait->WaitAnswer(MAX_IGNORE_TIMEOUT);//oilyang 20160325 the null pointer
				it->second.eResult = LOADING_SUCCEED;
				ret = CheckLoadResult(LOADSTAGE_COREBOOT);
				if (ret == 0 || ret == 2)
					goto COREBOOT_FINISH;
			}
			break;
		case LOADOPT_ASYNC_VERIFY:
			errCode = AsyncStartEntity(it->first,NULL,NULL);
			Dbg("%d",errCode);
			bAsync = true;
			break;
		case LOADOPT_SYNC_VERIFY:
			{
				pFuncPrivilege->StartEntity(it->first,NULL,spWait);
				if (spWait != NULL)
					errCode = spWait->WaitAnswer(MAX_AYSNC_TIMEOUT);
				Dbg("(coreboot)sync...%d",errCode);
				if (errCode == Error_Succeed)
					it->second.eResult = LOADING_SUCCEED;
				else if (errCode == Error_TimeOut)
					it->second.eResult = LOADING_TIMEOUT;
				else
					it->second.eResult = LOADING_FAILED;

				if (_strnicmp(it->first,"WatchDog",strlen("WatchDog")) == 0 
					&& it->second.eResult == LOADING_SUCCEED)
					bWatchDog = true;

				if (errCode != Error_Succeed) {
					ShowEntityBootFailedAtFront(it->first, errCode);
					return;
				}
				else
					ret = CheckLoadResult(LOADSTAGE_COREBOOT);
				Dbg("s1 check ret %d",ret);
				if (ret == 0 || ret == 2)
					goto COREBOOT_FINISH;
			}
			break;
		default:
			break;
		}
	}

COREBOOT_FINISH:

	//start watchdog if have load it sucessfully
	if (bWatchDog)
	{
		/**TODO(Gifur@5/21/2021): 国产化容易出现卡死现象，找个时间点把看门狗的逻辑加上去 */
	}

	if (!bAsync)
	{
		FSMEvent *e = new FSMEvent(USER_EVT_COREBOOT_FINISHED);
		e->param1 = ret;
		PostEventFIFO(e);
	}
	else
	{
		ret = CheckLoadResult(LOADSTAGE_COREBOOT);
		if (ret == 0 || ret == 2)
		{
			FSMEvent *e = new FSMEvent(USER_EVT_COREBOOT_FINISHED);
			e->param1 = ret;
			PostEventFIFO(e);
		}
	}
	return;
}
void CHealthManagerFSM::s1_on_exit()
{
	LOG_FUNCTION();
}
unsigned int CHealthManagerFSM::s1_on_event(FSMEvent* pEvt)
{
	LOG_FUNCTION();
	Dbg("s1 evt %d",pEvt->iEvt);
	switch(pEvt->iEvt)
	{
	case USER_EVT_COREBOOT_FINISHED:
		pEvt->SetHandled();
		if (pEvt->param1 == 2) {
			ShowEntityBootFailedAtFront(m_csErrEntity, Error_InvalidState);
		}
		return pEvt->param1;
		break;
	case USER_EVT_ENTER_CUSTOMER_MANAGER:
		pEvt->SetHandled();
		break;
	default:
		break;
	}
	return 0;
}

//SafeLoad
void CHealthManagerFSM::s2_on_entry()
{
	LOG_FUNCTION();

	m_fsmState = HM_FSM_STATE_SAFELOAD;
	Sleep(1000);

#if defined(RVC_OS_WIN)
	USBControl();
#endif //RVC_OS_WIN
	
	ErrorCodeEnum eErrCode;
	eErrCode = GetEntityBase()->GetFunction()->SetSysVar("RunState","S");
	if (eErrCode != Error_Succeed)
	{
		Dbg("set RunState S failed (%d).",eErrCode);
	}

	
	bool bAsync = false;
	m_eStage = LOADSTAGE_SAFELOAD;
	int ret = 0;
	map<CSimpleStringA,EntityLoadInfo>::iterator it;
	CSmartPointer<IEntityFunction> pFunc = GetEntityBase()->GetFunction();
	CSmartPointer<IEntityFunctionPrivilege> pFuncPrivilege = pFunc.ConvertCase<IEntityFunctionPrivilege>();
	
	ErrorCodeEnum errCode;
	vector<CSimpleStringA>::iterator vIt;
	if (m_safeLoadOpt.size() == 0)
		goto SAFELOAD_FINISH;
	char startMsg[128];
	for (vIt = m_vSafeLoad.begin(); vIt != m_vSafeLoad.end(); ++vIt)
	{
		CSmartPointer<IAsynWaitSp> spWait;
		it = m_safeLoadOpt.find(*vIt);
		if (it == m_safeLoadOpt.end())
		{
			Dbg("cannot find %s",(LPCSTR)*vIt);
			continue;
		}
		CEntityRunInfo entRunInfo;
		errCode = pFunc->GetEntityRunInfo(it->first,entRunInfo);
		if (errCode == Error_Succeed && entRunInfo.eState == EntityState_Idle)
		{
			it->second.eResult = LOADING_SUCCEED;
			ret = CheckLoadResult(LOADSTAGE_SAFELOAD);
			if (ret == 0 || ret == 2)
				goto SAFELOAD_FINISH;
			else
				continue;
		}
		Dbg("start %s,%d",(LPCTSTR)it->first,it->second.loadOpt);
		ZeroMemory(startMsg, 128);
		sprintf(startMsg, "正在启动实体%s...", it->first.GetData());
		GetEntityBase()->GetFunction()->ShowStartupInfo(startMsg);
		switch(it->second.loadOpt)
		{
		case LOADOPT_IGNORE:
			{
				pFuncPrivilege->StartEntity(it->first,NULL,spWait);
				if (spWait != NULL)
					spWait->WaitAnswer(MAX_IGNORE_TIMEOUT);
				it->second.eResult = LOADING_SUCCEED;
				ret = CheckLoadResult(LOADSTAGE_SAFELOAD);
				if (ret == 0 || ret == 2)
					goto SAFELOAD_FINISH;
			}
			break;
		case LOADOPT_ASYNC_VERIFY:
			AsyncStartEntity(it->first,NULL,NULL);
			bAsync = true;
			break;
		case LOADOPT_SYNC_VERIFY:
			{
				pFuncPrivilege->StartEntity(it->first,NULL,spWait);
				if (spWait != NULL)
					errCode = spWait->WaitAnswer(MAX_AYSNC_TIMEOUT);
				Dbg("sync...%d",eErrCode);
				if (errCode == Error_Succeed) {
					it->second.eResult = LOADING_SUCCEED;

#if defined(RVC_OS_WIN)
                    if (StrEqualNoCase("MaintainWatcher", it->first, strlen("MaintainWatcher"))) {
                        Sleep(10000);
                        if (m_custMngerState == CM_ENTER) {
                            Dbg("enter CMS...");
                            FSMEvent* pEvt = new FSMEvent(USER_EVT_ENTER_CUSTOMER_MANAGER);
                            PostEventFIFO(pEvt);
                            goto SAFELOAD_END;
                        }
                    }
#endif //RVC_OS_WIN

				}
				else if (errCode == Error_TimeOut)
					it->second.eResult = LOADING_TIMEOUT;
				else
					it->second.eResult = LOADING_FAILED;
				if (it->second.eResult != Error_Succeed)
				{
					char tmp[64] = {0};
					sprintf(tmp,"实体 %s 启动失败",it->first.GetData());
					Dbg("%s",tmp);
				}
                if (errCode != Error_Succeed) {
                    ShowEntityBootFailedAtFront(it->first, errCode);
                    return;
                }
				else
					ret = CheckLoadResult(LOADSTAGE_SAFELOAD);
				if (ret == 0 || ret == 2)
					goto SAFELOAD_FINISH;
			}
			break;
		default:
			break;
		}
	}

SAFELOAD_FINISH:

	if (!bAsync)
	{
		FSMEvent *e = new FSMEvent(USER_EVT_SAFELOAD_FINISHED);
		e->param1 = ret;
		PostEventFIFO(e);
	}
	else
	{
		ret = CheckLoadResult(LOADSTAGE_SAFELOAD);
		Dbg("s2 %d",ret);
		if (ret == 0 || ret == 2)
		{
			FSMEvent *e = new FSMEvent(USER_EVT_SAFELOAD_FINISHED);
			e->param1 = ret;
			PostEventFIFO(e);
		}
	}

SAFELOAD_END:

	return ;
}

void CHealthManagerFSM::s2_on_exit()
{
	LOG_FUNCTION();
}
unsigned int CHealthManagerFSM::s2_on_event(FSMEvent* pEvt)
{
	LOG_FUNCTION();
	int ret = 0;
	Dbg("s2 event %d,%d",pEvt->iEvt,pEvt->param1);
	switch(pEvt->iEvt)
	{
	case USER_EVT_SAFELOAD_FINISHED:
		{
			pEvt->SetHandled();
			//ToCheckUPS();
			//oiltmp
			//according to the system varible TerminalState to do sth.
			//Configed
			//Breakdown
			//Blocking
			//Authentication
			{
				if(pEvt->param1 == 0)
				{
					//initializer if configured
					CSimpleStringA csTermStage("");
					ErrorCodeEnum eErrCode;
					eErrCode = GetEntityBase()->GetFunction()->GetSysVar("TerminalStage",csTermStage);
					Dbg("after safeload to get termstage %s",(LPCTSTR)csTermStage);
					//comment this by oilyang 20141018
					//if (csTermStage == "B" || csTermStage == "D" || csTermStage == "N")
					if (csTermStage == "B" || csTermStage == "N")
						return 1;
				}
				else if (pEvt->param1 == 2)
				{
					ShowEntityBootFailedAtFront(m_csErrEntity, Error_InvalidState);
					ret = 2;
				}

			}
			//Unsubscrible
		}
		break;
	case USER_EVT_SAFELOAD_EXMINE_FINISHED:
		if (pEvt->param1 == 0)
			ret = 0;
		//do something else oiltmp
		pEvt->SetHandled();
		break;
	case USER_EVT_ACCESSAUTH_FINISHED:
		pEvt->SetHandled();
		ret = pEvt->param1;
		break;
	case USER_EVT_ENTER_CUSTOMER_MANAGER:
		pEvt->SetHandled();
		break;
	default:
		break;
	}
	return ret;
}

//Operating
void CHealthManagerFSM::s3_on_entry()
{
	LOG_FUNCTION();

	m_fsmState = HM_FSM_STATE_OP;

#if defined(RVC_OS_WIN)
	Sleep(5000);//oilyang for nantian pinpad 20150703
#endif //RVC_OS_WIN

	if (m_custMngerState == CM_ENTER)
	{
		Dbg("in CMS,no need to start hardware.");
		return;
	}
	ErrorCodeEnum eErrCode;
	eErrCode = GetEntityBase()->GetFunction()->SetSysVar("RunState","O");
	if (eErrCode != Error_Succeed)
	{
		Dbg("set RunState O failed (%d).",eErrCode);
	}
	
	bool bAsync = false;
	m_eStage = LOADSTAGE_OPERATING;
	int ret = 0;
	map<CSimpleStringA,EntityLoadInfo>::iterator it;
	CSmartPointer<IEntityFunction> pFunc = GetEntityBase()->GetFunction();
	CSmartPointer<IEntityFunctionPrivilege> pFuncPrivilege = pFunc.ConvertCase<IEntityFunctionPrivilege>();
	//start entity	
	
	ErrorCodeEnum errCode;
	vector<CSimpleStringA>::iterator vIt;
	if (m_operatingOpt.size() == 0)
		goto OPERATING_FINISH;
	char startMsg[128];
	for (vIt = m_vOperating.begin(); vIt != m_vOperating.end(); ++vIt)
	{
		CSmartPointer<IAsynWaitSp> spWait;
		it = m_operatingOpt.find(*vIt);
		if (it == m_operatingOpt.end())
		{
			Dbg("cannot find %s",(LPCSTR)*vIt);
			continue;
		}

		CEntityRunInfo entRunInfo;
		errCode = pFunc->GetEntityRunInfo(it->first,entRunInfo);
		if (errCode == Error_Succeed && entRunInfo.eState == EntityState_Idle)
		{
			it->second.eResult = LOADING_SUCCEED;
			ret = CheckLoadResult(LOADSTAGE_OPERATING);
			if (ret == 0 || ret == 2)
				goto OPERATING_FINISH;
			else
				continue;
		}
		Dbg("op start %s,%d",(LPCTSTR)it->first,it->second.loadOpt);
		ZeroMemory(startMsg, 128);
		sprintf(startMsg, "正在启动实体%s...", it->first.GetData());
		GetEntityBase()->GetFunction()->ShowStartupInfo(startMsg);
		switch(it->second.loadOpt)
		{
		case LOADOPT_IGNORE:
			{
				pFuncPrivilege->StartEntity(it->first,NULL,spWait);
				if (spWait != NULL)
					spWait->WaitAnswer(MAX_IGNORE_TIMEOUT);
				it->second.eResult = LOADING_SUCCEED;
				ret = CheckLoadResult(LOADSTAGE_OPERATING);
				if (ret == 0 || ret == 2)
					goto OPERATING_FINISH;
			}
			break;
		case LOADOPT_ASYNC_VERIFY:
			errCode = AsyncStartEntity(it->first,NULL,NULL);
			bAsync = true;
			break;
		case LOADOPT_SYNC_VERIFY:
			{
				errCode = pFuncPrivilege->StartEntity(it->first,NULL,spWait);
				if (errCode == Error_Succeed)
				{
					if (spWait != NULL)
						errCode = spWait->WaitAnswer(MAX_AYSNC_TIMEOUT);
				}
				else
				{
					Dbg("StartEntity %s failed(%d).",(LPCSTR)it->first,errCode);
					break;
				}
				if (errCode == Error_Succeed)
					it->second.eResult = LOADING_SUCCEED;
				else if (errCode == Error_TimeOut)
					it->second.eResult = LOADING_TIMEOUT;
				else
					it->second.eResult = LOADING_FAILED;
				if (it->second.eResult != Error_Succeed)
				{
					char tmp[64] = {0};
					sprintf(tmp, "实体 %s 启动失败", it->first.GetData());
					Dbg("%s", tmp);
				}
                if (errCode != Error_Succeed) {
                    ShowEntityBootFailedAtFront(it->first, errCode);
                    return;
                }
				else
					ret = CheckLoadResult(LOADSTAGE_OPERATING);
				if (ret == 0 || ret == 2)
					goto OPERATING_FINISH;
			}
			break;
		default:
			break;
		}
	}

OPERATING_FINISH:

	Dbg("s3 ret %d",ret);
	if (!bAsync)
	{
		FSMEvent *e = new FSMEvent(USER_EVT_OPERATING_FINISHED);
		e->param1 = ret;
		PostEventFIFO(e);
	}
	else
	{
		ret = CheckLoadResult(LOADSTAGE_OPERATING);
		if (ret == 0 || ret == 2)
		{
			FSMEvent *e = new FSMEvent(USER_EVT_OPERATING_FINISHED);
			e->param1 = ret;
			PostEventFIFO(e);
		}
	}

	return ;
}
void CHealthManagerFSM::s3_on_exit()
{
	LOG_FUNCTION();
}
unsigned int CHealthManagerFSM::s3_on_event(FSMEvent* pEvt)
{
	LOG_FUNCTION();
	Dbg("s3(Operating) event %d,%d",pEvt->iEvt,pEvt->param1);
	int ret = 0;
	switch(pEvt->iEvt)
	{
	case USER_EVT_OPERATING_FINISHED:
		ret = pEvt->param1;
        if (ret == 2) {
            ShowEntityBootFailedAtFront(m_csErrEntity, Error_InvalidState);
        }
		pEvt->SetHandled();
		break;
	case USER_EVT_ENTER_CUSTOMER_MANAGER:
		pEvt->SetHandled();
		break;
	default:
		break;
	}
	return ret;
}

//Idle(Operating finished)
void CHealthManagerFSM::s4_on_entry()
{
	LOG_FUNCTION();
	m_fsmState = HM_FSM_STATE_IDLE;
	m_accessAuthCheckMD5 = 0;
	CSmartPointer<IEntityFunction> spEntityFunction = GetEntityBase()->GetFunction();
	CSmartPointer<IConfigInfo> spConfig, spCerConfig;
	ErrorCodeEnum eErrCer = spEntityFunction->OpenConfig(Config_CenterSetting, spCerConfig);
	if (eErrCer != Error_Succeed) {
		Dbg("open central cfg file failed!");
	}
	else
		spCerConfig->ReadConfigValueInt("AccessAuthorization", "CheckMD5", m_accessAuthCheckMD5);
	Dbg("before access auth,read MD5 flag:%d",m_accessAuthCheckMD5);
	if (!m_bIdleToMaintain)
	{	
		AccessAuthTask *pTask = new AccessAuthTask(this);
		GetEntityBase()->GetFunction()->PostThreadPoolTask(pTask);
	}
	else
		m_bIdleToMaintain = false;
}

void CHealthManagerFSM::s4_on_exit()
{
	LOG_FUNCTION();
}

unsigned int CHealthManagerFSM::s4_on_event(FSMEvent* pEvt)
{
	LOG_FUNCTION();
	Dbg("s4 event %d,%d",pEvt->iEvt,pEvt->param1);
	switch(pEvt->iEvt)
	{
	case USER_EVT_ACCESSAUTH_FINISHED:
		{
			pEvt->SetHandled();
			if (pEvt->param1 == 1)
			{
				//why to do this???
				//LogEvent(Severity_Middle,EVENT_CONSOLE_REQ_RESTART_SHELL,"AccessAuth failed,to restart spshell.");
				return 1;
			}
			ToLogWarnTermAboutInfo();
			CSimpleStringA csTermStage;
			ErrorCodeEnum eErrCode;
			eErrCode = GetEntityBase()->GetFunction()->GetSysVar("TerminalStage",csTermStage);
			Dbg("after accessauth to get termstage %s",(LPCTSTR)csTermStage);
			//oilyang@20170316@comment
			//for user desktop,start iebrowser no matter what TerminalStage is.
			//if (csTermStage[0] != 'A')
			//	break;
			eErrCode = GetEntityBase()->GetFunction()->SetSysVar("RunState","O");
			if (eErrCode != Error_Succeed)
			{
				Dbg("set RunState O failed (%d).",eErrCode);
			}
			CSmartPointer<IEntityFunction> spEntityFunction = GetEntityBase()->GetFunction();
			CSmartPointer<IConfigInfo> spConfigRun,spCerConfig;
			ErrorCodeEnum eErrIE = spEntityFunction->OpenConfig(Config_Run, spConfigRun);
			if (eErrIE != Error_Succeed) {
				Dbg("open cfg file(ie) failed!");
				//return err;
			}
			ErrorCodeEnum eErrCerUrl = spEntityFunction->OpenConfig(Config_CenterSetting, spCerConfig);
			if (eErrCerUrl != Error_Succeed) {
				Dbg("open central cfg file(ie) failed!");
			}
			//if load successfully,set FailTimes to 0
			spConfigRun->WriteConfigValueInt("Run","FailTimes",0);

			if (m_bAccessAuth)
			{
				m_checkCode = QueryCheckCode();
				if (m_checkCode.GetLength() > 1)
					m_bEverAuthSucWithDevice = true;
				else
					m_bEverAuthSucWithDevice = false;
			}
			else
			{
				AuthStatus as;
				if (m_bEverAuthSucWithDevice)
				{
					as.result = 1;
					as.msg = "设备混用，请接入对应设备或后台重新绑定当前设备";
					SpSendBroadcast(GetEntityBase()->GetFunction(), SP_MSG_OF(AuthStatus), SP_MSG_SIG_OF(AuthStatus), as);
				}
				else
				{
					as.result = 11;
					as.msg = "请检查设备是否正常初始化或是否对应绑定设备";
					SpSendBroadcast(GetEntityBase()->GetFunction(), SP_MSG_OF(AuthStatus), SP_MSG_SIG_OF(AuthStatus), as);
				}
			}
			m_strURLValue = "";

#ifdef RVC_OS_WIN
			eErrCerUrl = spCerConfig->ReadConfigValue(GetEntityBase()->GetEntityName(), m_strURL, m_strURLValue);
			if (eErrIE == Error_Succeed)
			{
				Dbg("write ie url.sys [%s]", (const char*)m_strURLValue);
				GetEntityBase()->GetFunction()->SetSysVar("IEUrl", m_strURLValue);
			}
			CSmartPointer<IAsynWaitSp> spWait;
			CSmartPointer<IEntityFunctionPrivilege> pFuncPrivilege = spEntityFunction.ConvertCase<IEntityFunctionPrivilege>();
			CEntityRunInfo acInfo;
			eErrCode = spEntityFunction->GetEntityRunInfo("IEBrowser",acInfo);
			if (eErrCode == Error_Succeed && acInfo.eState == EntityState_NoStart)
			{
				GetEntityBase()->GetFunction()->ShowStartupInfo("正在启动实体IEBrowser...");
				eErrIE = pFuncPrivilege->StartEntity("IEBrowser", m_strURLValue, spWait);
				if (eErrIE == Error_Succeed)
				{
					if (spWait != NULL)
						eErrIE = spWait->WaitAnswer(MAX_AYSNC_TIMEOUT);
				}
				else
				{
					Dbg("Start IEBrowser failed(%d).",eErrIE);
				}
			}
			else if (eErrCode == Error_Succeed && acInfo.eState == EntityState_Idle)
			{//if IEBrowser start before healthmanager,we suppose healthmanager is restart unexpectly,then set m_bEnterMainPageEver true
				m_bIEBeforeHealth = true;
			}
#endif //RVC_OS_WIN

			if (!m_bAccessAuth)
				PostProcessAfterUpgrade();
		}
		break;
	case USER_EVT_MAITAIN:
		Dbg("to maintain...");
		m_stateBeforeMaintain = m_fsmState;
		m_bIdleToMaintain = true;
		pEvt->SetHandled();
		break;
	case USER_EVT_ENTER_CUSTOMER_MANAGER:
		pEvt->SetHandled();
		break;
	default:
		break;
	}
	return 0;
}

//Fault
void CHealthManagerFSM::s5_on_entry()
{
	LOG_FUNCTION();
	ToLogWarnTermAboutInfo(FALSE);
	m_fsmState = HM_FSM_STATE_FAULT;
	CSmartPointer<IConfigInfo> spConfig,spConfigRun;
	ErrorCodeEnum eErr = GetEntityBase()->GetFunction()->OpenConfig(Config_Software, spConfig);
	eErr = GetEntityBase()->GetFunction()->OpenConfig(Config_Run, spConfigRun);
	int failTimes = 0,maxFailTimes = 3;
	spConfig->ReadConfigValueInt("Run","MaxFailTimes",maxFailTimes);
	spConfigRun->ReadConfigValueInt("Run","FailTimes",failTimes);
	failTimes++;
	if (failTimes > maxFailTimes)
	{
		LogEvent(Severity_Middle,LOG_EVT_HEADLIGHT_RED_ON,"设备故障");
		LogWarn(Severity_Middle,Error_Unexpect,LOG_ERR_HEALTH_FAILED,"HealthManager failed.");

		eErr = GetEntityBase()->GetFunction()->SetSysVar("TerminalStage","D");
		if (eErr != Error_Succeed)
			Dbg("set termstage D failed (%d).",eErr);
		else
			Dbg("Set TerminalStage D.");
	}
	else
	{
		Dbg("have failed %d times.",failTimes);
		spConfigRun->WriteConfigValueInt("Run","FailTimes",failTimes);
		eErr = GetEntityBase()->GetFunction()->SetSysVar("RunState","F");
		if (eErr != Error_Succeed)
		{
			Dbg("set RunState failed (%d).",eErr);
		}
	}
	PostProcessAfterUpgrade();
}
void CHealthManagerFSM::s5_on_exit()
{
	LOG_FUNCTION();
}
unsigned int CHealthManagerFSM::s5_on_event(FSMEvent* pEvt)
{
	LOG_FUNCTION();
	Dbg("s5(Fault) event %d,%d",pEvt->iEvt,pEvt->param1);
	switch(pEvt->iEvt)
	{
	case USER_EVT_MAITAIN:
		Dbg("to maintain...");
		m_stateBeforeMaintain = m_fsmState;
		pEvt->SetHandled();
		break;
	case USER_EVT_ENTER_CUSTOMER_MANAGER:
		pEvt->SetHandled();
		break;
	default:
		break;
	}
	return 0;
}

//Maintaining
void CHealthManagerFSM::s6_on_entry()
{
	LOG_FUNCTION();
	m_preFsmState = m_fsmState;
	m_fsmState = HM_FSM_STATE_MAINTAINING;
	ErrorCodeEnum eErrCode;
	eErrCode = GetEntityBase()->GetFunction()->SetSysVar("RunState","M");
	if (eErrCode != Error_Succeed)
	{
		Dbg("set RunState M failed (%d).",eErrCode);
	}
	CSmartPointer<IEntityFunction> pFunc = GetEntityBase()->GetFunction();
	CSmartPointer<IEntityFunctionPrivilege> pFuncPrivilege = pFunc.ConvertCase<IEntityFunctionPrivilege>();
	if (pFuncPrivilege == NULL)
	{
		Dbg("display screen NoPrivilege");
		return;
	}
	ErrorCodeEnum eErr = pFuncPrivilege->DisplayBlueScreen("暂停服务");
	Dbg("display blue screen %d",eErr);
}

void CHealthManagerFSM::s6_on_exit()
{
	LOG_FUNCTION();
}

unsigned int CHealthManagerFSM::s6_on_event(FSMEvent* pEvt)
{
	LOG_FUNCTION();
	int ret = 0;
	switch(pEvt->iEvt)
	{
	case USER_EVT_MAITAIN_FINISHED:
		pEvt->SetHandled();
		{
			CSmartPointer<IEntityFunction> pFunc = GetEntityBase()->GetFunction();
			CSmartPointer<IEntityFunctionPrivilege> pFuncPrivilege = pFunc.ConvertCase<IEntityFunctionPrivilege>();
			if (pFuncPrivilege == NULL)
			{
				Dbg("un-display screen NoPrivilege");
				return 1;
			}
			ErrorCodeEnum eErr = pFuncPrivilege->UndisplayBlueScreen();
			Dbg("un-display blue screen %d",eErr);
			if (m_stateBeforeMaintain == HM_FSM_STATE_IDLE)
			{
				ErrorCodeEnum eErr = GetEntityBase()->GetFunction()->SetSysVar("RunState","O");
				if (eErr != Error_Succeed)
				{
					Dbg("set RunState O failed (%d).",eErr);
				}
			}
			ret = m_preFsmState;
		}
		break;
	case USER_EVT_ENTER_CUSTOMER_MANAGER:
		pEvt->SetHandled();
		break;
	default:
		break;
	}
	return ret;
}

//PrepareOff
void CHealthManagerFSM::s7_on_entry()
{
	LOG_FUNCTION();
	m_fsmState = HM_FSM_STATE_PREPAREOFF;
	ErrorCodeEnum eErrCode;
	eErrCode = GetEntityBase()->GetFunction()->SetSysVar("RunState","P");
	if (eErrCode != Error_Succeed)
	{
		Dbg("set RunState P failed (%d).",eErrCode);
	}
}

void CHealthManagerFSM::s7_on_exit()
{
	LOG_FUNCTION();
}

unsigned int CHealthManagerFSM::s7_on_event(FSMEvent* pEvt)
{
	LOG_FUNCTION();
	Dbg("s7(PrepareOff) event %d",pEvt->iEvt);
	switch(pEvt->iEvt)
	{
	case USER_EVT_MAITAIN:
		Dbg("to maintain...");
		m_stateBeforeMaintain = m_fsmState;
		pEvt->SetHandled();
		break;
	case USER_EVT_ENTER_CUSTOMER_MANAGER:
		pEvt->SetHandled();
		break;
	default:
		break;
	}
	return 0;
}

//Terminating
void CHealthManagerFSM::s8_on_entry()
{
	LOG_FUNCTION();
	m_fsmState = HM_FSM_STATE_TERMINATING;
	ErrorCodeEnum eErrCode;
	eErrCode = GetEntityBase()->GetFunction()->SetSysVar("RunState","T");
	if (eErrCode != Error_Succeed)
	{
		Dbg("set RunState T failed (%d).",eErrCode);
	}
}

void CHealthManagerFSM::s8_on_exit()
{
	LOG_FUNCTION();
}

unsigned int CHealthManagerFSM::s8_on_event(FSMEvent* pEvt)
{
	LOG_FUNCTION();
	Dbg("s8(Terminating) event %d",pEvt->iEvt);
	switch(pEvt->iEvt)
	{
	case USER_EVT_MAITAIN:
		Dbg("to maintain...");
		m_stateBeforeMaintain = m_fsmState;
		pEvt->SetHandled();
		break;
	case USER_EVT_ENTER_CUSTOMER_MANAGER:
		pEvt->SetHandled();
		break;
	default:
		break;
	}
	return 0;
}

//Exitting
void CHealthManagerFSM::s9_on_entry()
{
	LOG_FUNCTION();
	m_fsmState = HM_FSM_STATE_EXITTING;
	ErrorCodeEnum eErrCode;
	eErrCode = GetEntityBase()->GetFunction()->SetSysVar("RunState","E");
	if (eErrCode != Error_Succeed)
	{
		Dbg("set RunState E failed (%d).",eErrCode);
	}
}

void CHealthManagerFSM::s9_on_exit()
{
	LOG_FUNCTION();
}

unsigned int CHealthManagerFSM::s9_on_event(FSMEvent* pEvt)
{
	LOG_FUNCTION();
	Dbg("s9(Exitting) event %d",pEvt->iEvt);
	switch(pEvt->iEvt)
	{
	case USER_EVT_MAITAIN:
		Dbg("to maintain...");
		m_stateBeforeMaintain = m_fsmState;
		pEvt->SetHandled();
		break;
	case USER_EVT_ENTER_CUSTOMER_MANAGER:
		pEvt->SetHandled();
		break;
	default:
		break;
	}
	return 0;
}

//Sleep(L)
void CHealthManagerFSM::s10_on_entry()
{
	LOG_FUNCTION();
	m_fsmState = HM_FSM_STATE_SLEEP;
	ErrorCodeEnum eErrCode;
	eErrCode = GetEntityBase()->GetFunction()->SetSysVar("RunState","L");
	if (eErrCode != Error_Succeed)
	{
		Dbg("set RunState L failed (%d).",eErrCode);
	}
}

void CHealthManagerFSM::s10_on_exit()
{
	LOG_FUNCTION();
}

unsigned int CHealthManagerFSM::s10_on_event(FSMEvent* pEvt)
{
	LOG_FUNCTION();
	Dbg("s10(Sleep) event %d",pEvt->iEvt);
	switch(pEvt->iEvt)
	{
	case USER_EVT_MAITAIN:
		Dbg("to maintain...");
		m_stateBeforeMaintain = m_fsmState;
		pEvt->SetHandled();
		break;
	case USER_EVT_ENTER_CUSTOMER_MANAGER:
		pEvt->SetHandled();
		break;
	default:
		break;
	}
	return 0;
}

//In Customer Manager System
void CHealthManagerFSM::s11_on_entry()
{
	LOG_FUNCTION();
	m_preFsmState = m_fsmState;
	m_fsmState = HM_FSM_STATE_CMS;
}

void CHealthManagerFSM::s11_on_exit()
{
	LOG_FUNCTION();
}

unsigned int CHealthManagerFSM::s11_on_event(FSMEvent* pEvt)
{
	LOG_FUNCTION();
	Dbg("s11(In CMS) event %d",pEvt->iEvt);
	int ret = 0;
	switch (pEvt->iEvt)
	{
		case USER_EVT_MAITAIN:
			Dbg("to maintain...");
			m_stateBeforeMaintain = m_fsmState;
			pEvt->SetHandled();
			break;
		case USER_EVT_SWITCH_BACK_TO_RVC:
			pEvt->SetHandled();
			ret = m_preFsmState;
			break;
		default:
			break;
	}
	return ret;
}

int CHealthManagerFSM::WaitDeamonFinish()
{
	int count = 0;
	while(1)//max waiting time
	{

		count++;
		//query if update deamon process is started oiltmp
		//case custody
		//case needreboot
		//case rollback
		//case timeout
		if (count > 2)
			break;
		//Sleep(5000);
	}

	return 0;
}
int CHealthManagerFSM::DoInitialization()
{
	LOG_FUNCTION();

	ErrorCodeEnum eErr;
	CSmartPointer<IEntityFunction> pFunc = GetEntityBase()->GetFunction();
	CSmartPointer<IEntityFunctionPrivilege> pFuncPrivilege = pFunc.ConvertCase<IEntityFunctionPrivilege>();
	CEntityRunInfo acInfo;
	eErr = pFunc->GetEntityRunInfo("Initializer",acInfo);
	Dbg("Initializer state return %d",eErr);
	if (eErr == Error_Succeed && (acInfo.eState == EntityState_NoStart || acInfo.eState == EntityState_Idle))
	{
		if (acInfo.eState == EntityState_NoStart)
		{
			CSmartPointer<IAsynWaitSp> spWaitInit;
			eErr = pFuncPrivilege->StartEntity("Initializer",NULL,spWaitInit);
			if (eErr == Error_Succeed)
				eErr = spWaitInit->WaitAnswer(MAX_AYSNC_TIMEOUT);
			eErr = pFunc->GetEntityRunInfo("Initializer",acInfo);
			if (eErr != Error_Succeed || acInfo.eState != EntityState_Idle)
			{
				Dbg("start Initializer failed(%d,%d).",eErr,acInfo.eState);
				return 1;
			}
		}
		if (m_pInitClient == NULL)
		{
			m_pInitClient = new InitializerService_ClientBase(this->GetEntityBase());
			eErr = m_pInitClient->Connect();
			if (eErr != Error_Succeed) {
				Dbg("Initializer connected failed.");
				m_pInitClient->SafeDelete();
				m_pInitClient = NULL;
				return 2;
			}
			else
				Dbg("Initializer connected.");
		}
		InitializerService_Initialize_Info initInfo;
		m_pInitClient->Initialize(initInfo);
		//no need to wait,just go
		return 0;
	}
	else
	{
		Dbg("Get Initializer RunInfo failed(%d).",eErr);
		return 3;
	}
}

//0:auth suc or have already authed;1:auth failed;
int CHealthManagerFSM::AccessAuthDoWork()
{
	//oilyang@20190924 comment the following Sleep(5000);
	//Sleep(5000);//oilyang wait for a few seconds
	if (m_bFirstAccessAuth && m_accessAuthCheckMD5 == 1 && m_havReceiveMD5OK == 0)
	{
		Dbg("wait md5 ok.");
		WaitForSingleObject(m_hMD5OKEvt, INFINITE);
		m_bFirstAccessAuth = false;
		Dbg("have received md5 ok event.");
	}
	CSimpleStringA csTermStage("");
	ErrorCodeEnum eErr;
	eErr = GetEntityBase()->GetFunction()->GetSysVar("TerminalStage",csTermStage);
	Dbg("oninit get termstage %s",(LPCTSTR)csTermStage);
	bool bToDoInit = false;
	if (eErr == Error_Succeed)
	{
		if (csTermStage[0] == 'U')
		{
			bToDoInit = true;
			int initTime = 0;

INITIALIZATION:

			int rc = DoInitialization();
			Dbg("the %d init",initTime);
			initTime++;
			DWORD dwStart = GetTickCountRVC();
			while(1)
			{
				if (!m_bInitSuc && !m_bInitFail)
				{
					Sleep(1000);
					continue;
				}
				else if (m_bInitSuc || m_bInitFail)
				{
					Dbg("init result %d,%d",m_bInitSuc,m_bInitFail);
					if (m_bInitFail)
					{
						Sleep(5000);
						m_bInitFail = false;
						goto INITIALIZATION;
					}
					if (m_bInitSuc)
						break;
				}
			}
		}
	}
	else
	{
		Dbg("get TerminalStage failed(%d).",eErr);
		return 1;
	}
	Dbg("after proc initialization.");
	if (bToDoInit)
	{
		if (m_bInitSuc)
		{
			eErr = GetEntityBase()->GetFunction()->SetSysVar("TerminalStage","C");
			Dbg("set TerminalStage C");
			if (eErr != Error_Succeed)
				Dbg("set TerminalStage C failed(%d).",eErr);
		}
		else
		{
			Dbg("initialization failed.");
			return 1;
		}
	}

	//to accessauth

	ErrorCodeEnum eErrCode;
	eErrCode = GetEntityBase()->GetFunction()->GetSysVar("TerminalStage",csTermStage);
	Dbg("before accessauth get termstage %s",(LPCTSTR)csTermStage);
	if (eErrCode == Error_Succeed)
	{
		//if (csTermStage[0] == 'C' || csTermStage[0] == 'A')
		if (csTermStage[0] != 'U') 
		{
			CSmartPointer<IEntityFunction> pFunc = GetEntityBase()->GetFunction();
			CSmartPointer<IEntityFunctionPrivilege> pFuncPrivilege = pFunc.ConvertCase<IEntityFunctionPrivilege>();
			//terminate pinpad
			//CSmartPointer<IAsynWaitSp> spWait;
			//eErrCode = pFuncPrivilege->CloseEntity("PinPad",spWait);
			//Dbg("close pinpad %d.",eErrCode);
			//eErrCode = spWait->WaitAnswer(MAX_AYSNC_TIMEOUT);
			//if (eErrCode != Error_Succeed)
			//{
			//	//terminate pinpad
			//	CSmartPointer<IAsynWaitSp> spWait;
			//	pFuncPrivilege->TerminateEntity("PinPad",spWait);
			//	spWait->WaitAnswer(MAX_AYSNC_TIMEOUT);
			//}
			//if (eErrCode == Error_Succeed)
			{
				CEntityRunInfo acInfo;
				eErrCode = pFunc->GetEntityRunInfo("AccessAuthorization",acInfo);
				Dbg("AccessAuth state return %d",eErrCode);
				if (eErrCode == Error_Succeed)
				{
					switch(acInfo.eState)
					{
					case EntityState_NoStart:
						{
							CSmartPointer<IAsynWaitSp> spWaitAC;
							eErrCode = pFuncPrivilege->StartEntity("AccessAuthorization",NULL,spWaitAC);
							eErrCode = spWaitAC->WaitAnswer(MAX_AYSNC_TIMEOUT);
							Dbg("start accessauth %d.",eErrCode);
						}
						break;
					case EntityState_Idle:
						Dbg("AccessAuth state idle.");
						break;
					default:
						break;
					}
					
					if (m_pACClient == NULL)
					{
						m_pACClient = new AccessAuthService_ClientBase(this->GetEntityBase());
						eErrCode = m_pACClient->Connect();
						if (eErrCode != Error_Succeed) {
							Dbg("accessauth connected failed.");
							m_pACClient->SafeDelete();
							m_pACClient = NULL;
							StartPinPadEntity();
							return 1;
						}
						else
							Dbg("accessauth connected.");
					}
				}
				else
				{
					Dbg("Get AccessAuth RunInfo failed(%d).",eErrCode);
					StartPinPadEntity();
					return 1;
				}
				if (m_pACClient != NULL)
				{
					DWORD dwStart = GetTickCountRVC();
					int registCount = 0;
REGIST:		eErrCode = m_pACClient->Regist();
					m_bHasAuthEver = true;
					registCount++;
					Dbg("accessauth regist %d",eErrCode);
					if (eErrCode == Error_Succeed)
					{
						while(1)
						{
							DWORD dwEnd = GetTickCountRVC();
							DWORD dwElapse = dwEnd-dwStart;
							if (dwElapse > m_AccessAuthTimeout)
							{
								Dbg("after x minute");
								StartPinPadEntity();
								//auth failed,rollback to C
								eErrCode = GetEntityBase()->GetFunction()->SetSysVar("TerminalStage","C");
								Dbg("auth fail,set TerminalStage C 1");
								if (eErr != Error_Succeed)
									Dbg("set TerminalStage C failed(%d).",eErr);
								m_bFirstAccessAuth = false;
								return 1;
							}
							Sleep(1000);
							if (!m_bAccessAuth && !m_bACFailed)
								continue;
							if (m_bACFailed && registCount < m_AccessAuthTries)
							{
								LogWarn(Severity_Low,Error_Unexpect,LOG_WARN_HEALTH_ACCESSAUTH_FAILED,"AccessAuth failed.");
								m_bACFailed = false;
								Sleep(5000);
								goto REGIST;
							}
							Dbg("regist try %d times",registCount);
							StartPinPadEntity();
							if (!m_bAccessAuth)
							{
								//auth failed,rollback to C
								eErrCode = GetEntityBase()->GetFunction()->SetSysVar("TerminalStage","C");
								Dbg("auth fail,set TerminalStage C 2");
								if (eErr != Error_Succeed)
									Dbg("set TerminalStage C failed(%d).",eErr);
							}
							break;
						}
						m_bFirstAccessAuth = false;
						return 0;
					}
					else
					{
						Dbg("accessauth regist failed(%d).",eErrCode);
						StartPinPadEntity();
						//auth failed,rollback to C
						eErrCode = GetEntityBase()->GetFunction()->SetSysVar("TerminalStage","C");
						Dbg("auth fail,set TerminalStage C 3");
						if (eErr != Error_Succeed)
							Dbg("set TerminalStage C failed(%d).",eErr);
						return 1;
					}
				}
				else
				{
					Dbg("Start accessauth failed(%d).",eErrCode);
					StartPinPadEntity();
					//auth failed,rollback to C
					eErrCode = GetEntityBase()->GetFunction()->SetSysVar("TerminalStage","C");
					Dbg("auth fail,set TerminalStage C 4");
					if (eErr != Error_Succeed)
						Dbg("set TerminalStage C failed(%d).",eErr);
					return 1;
				}
			}
		}
		else
		{
			StartPinPadEntity();
			return 0;
		}
	}
	else
		Dbg("Get termstage failed(%d).",eErrCode);
	return 1;
}

//return value:
//0:all entity have started suc
//1:some entity havn't try to start
//2:all entity have tried to started,but some failed
int CHealthManagerFSM::CheckLoadResult(LoadStage eStage)
{
	int ret = 0;
	map<CSimpleStringA,EntityLoadInfo>::iterator it;
	if (eStage == LOADSTAGE_COREBOOT)
		it = m_coreBootOpt.begin();
	else if (eStage == LOADSTAGE_SAFELOAD)
		it = m_safeLoadOpt.begin();
	else
		it = m_operatingOpt.begin();
	while(1)
	{
		switch(it->second.loadOpt)
		{
		case LOADOPT_IGNORE:
			if (it->second.eResult == LOADING_INIT)
				return 1;
			break;
		case LOADOPT_ASYNC_VERIFY:
		case LOADOPT_SYNC_VERIFY:			
		default:
			if (it->second.eResult == LOADING_INIT)
				return 3;
			else if (it->second.eResult != LOADING_SUCCEED)
			{
				m_csErrEntity = it->first;
				ret = 2;
			}
			break;
		}
		it++;
		if (eStage == LOADSTAGE_COREBOOT && it == m_coreBootOpt.end())
			break;
		else if (eStage == LOADSTAGE_SAFELOAD && it == m_safeLoadOpt.end())
			break;
		else if (eStage == LOADSTAGE_OPERATING && it == m_operatingOpt.end())
			break;
	}
	return ret;
}
void CHealthManagerFSM::SetAccessAuth(bool bResult)
{
	m_bAccessAuth = bResult;
	ErrorCodeEnum eErrCode;
	if (bResult)
		eErrCode = GetEntityBase()->GetFunction()->SetSysVar("TerminalStage","A");
	else
		eErrCode = GetEntityBase()->GetFunction()->SetSysVar("TerminalStage", "C");
	Dbg("SetAccessAuth %d",bResult);
}

int CHealthManagerFSM::StartPinPadEntity()
{
	if (m_coreBootOpt.find("PinPad") == m_coreBootOpt.end() && m_safeLoadOpt.find("PinPad") == m_safeLoadOpt.end()
		&& m_operatingOpt.find("PinPad") == m_operatingOpt.end())
	{
		Dbg("not configure pinpad.");
		return 0;
	}
	CSmartPointer<IEntityFunction> pFunc = GetEntityBase()->GetFunction();
	CSmartPointer<IEntityFunctionPrivilege> pFuncPrivilege = pFunc.ConvertCase<IEntityFunctionPrivilege>();
	CEntityRunInfo acInfo;
	ErrorCodeEnum eErrCode;
	eErrCode = pFunc->GetEntityRunInfo("PinPad",acInfo);
	Dbg("pinpad state %d,%d",eErrCode,acInfo.eState);
	if (acInfo.eState == EntityState_NoStart || acInfo.eState == EntityState_Close || acInfo.eState == EntityState_Killed)
	{

		CSmartPointer<IAsynWaitSp> spWait;

		eErrCode = pFuncPrivilege->StartEntity("PinPad",NULL,spWait);
		Dbg("start pinpad %d.",eErrCode);
		if (spWait != NULL)
			eErrCode = spWait->WaitAnswer(MAX_AYSNC_TIMEOUT);
		Dbg("start pinpad wait %d",eErrCode);
	}
	return eErrCode;
}

void CHealthManagerFSM::ToReAccessAuth(bool bEver)
{
	SetAccessAuth(false);
	AccessAuthTask *pTask = new AccessAuthTask(this);
	GetEntityBase()->GetFunction()->PostThreadPoolTask(pTask);
}

ErrorCodeEnum CHealthManagerFSM::AsyncStartEntity(const char *entity_name, const char *cmdline, void *pData)
{
	CSmartPointer<IEntityFunction> pFunc = m_pEntity->GetFunction();
	ErrorCodeEnum errCode;
	CSmartPointer<IEntityFunctionPrivilege> pFuncPrivilege = pFunc.ConvertCase<IEntityFunctionPrivilege>();
	if (pFuncPrivilege != NULL) {
		CSmartPointer<IAsynWaitSp> spWait;
		errCode = pFuncPrivilege->StartEntity(entity_name, cmdline, spWait);
		Dbg("start entity %s",entity_name);
		if (errCode == Error_Succeed) {
			callback_entry *entry = new callback_entry();
			entry->pRawData = pData;
			entry->EntityName = entity_name;
			entry->ErrorResult = Error_Unexpect;
			entry->op = OP_START_ENTITY;
			if (spWait != NULL)
				spWait->SetCallback(this, entry);
		}
		return errCode;
	} else {
		return Error_NoPrivilege;
	}
}

ErrorCodeEnum CHealthManagerFSM::AsyncStopEntity(const char *entity_name, void *pData)
{
	CSmartPointer<IEntityFunction> pFunc = m_pEntity->GetFunction();
	CSmartPointer<IEntityFunctionPrivilege> pFuncPrivilege = pFunc.ConvertCase<IEntityFunctionPrivilege>();
	if (pFuncPrivilege != NULL) {
		CSmartPointer<IAsynWaitSp> spWait;
		ErrorCodeEnum Error = pFuncPrivilege->StopEntity(entity_name, spWait);
		if (Error == Error_Succeed) {
			callback_entry *entry = new callback_entry();
			entry->pRawData = pData;
			entry->EntityName = entity_name;
			entry->ErrorResult = Error_Unexpect;
			entry->op = OP_STOP_ENTITY;
			if (spWait != NULL)
				spWait->SetCallback(this, entry);
		}
		return Error;
	} else {
		return Error_NoPrivilege;
	}
}

ErrorCodeEnum CHealthManagerFSM::AsyncPauseEntity(const char *entity_name, void *pData)
{
	CSmartPointer<IEntityFunction> pFunc = m_pEntity->GetFunction();
	CSmartPointer<IEntityFunctionPrivilege> pFuncPrivilege = pFunc.ConvertCase<IEntityFunctionPrivilege>();
	if (pFuncPrivilege != NULL) {
		CSmartPointer<IAsynWaitSp> spWait;
		ErrorCodeEnum Error = pFuncPrivilege->PauseEntity(entity_name, spWait);
		if (Error == Error_Succeed) {
			callback_entry *entry = new callback_entry();
			entry->pRawData = pData;
			entry->EntityName = entity_name;
			entry->ErrorResult = Error_Unexpect;
			entry->op = OP_PAUSE_ENTITY;
			if (spWait != NULL)
				spWait->SetCallback(this, entry);
		}
		return Error;
	} else {
		return Error_NoPrivilege;
	}
}

ErrorCodeEnum CHealthManagerFSM::AsyncContinueEntity(const char *entity_name, void *pData)
{
	CSmartPointer<IEntityFunction> pFunc = m_pEntity->GetFunction();
	CSmartPointer<IEntityFunctionPrivilege> pFuncPrivilege = pFunc.ConvertCase<IEntityFunctionPrivilege>();
	if (pFuncPrivilege != NULL) {
		CSmartPointer<IAsynWaitSp> spWait;
		ErrorCodeEnum Error = pFuncPrivilege->ContinueEntity(entity_name, spWait);
		if (Error == Error_Succeed) {
			callback_entry *entry = new callback_entry();
			entry->pRawData = pData;
			entry->EntityName = entity_name;
			entry->ErrorResult = Error_Unexpect;
			entry->op = OP_CONTINUE_ENTITY;
			if (spWait != NULL)
				spWait->SetCallback(this, entry);
		}
		return Error;
	} else {
		return Error_NoPrivilege;
	}
}

ErrorCodeEnum CHealthManagerFSM::AsyncTerminateEntity(const char *entity_name, void *pData)
{
	CSmartPointer<IEntityFunction> pFunc = m_pEntity->GetFunction();
	CSmartPointer<IEntityFunctionPrivilege> pFuncPrivilege = pFunc.ConvertCase<IEntityFunctionPrivilege>();
	if (pFuncPrivilege != NULL) {
		CSmartPointer<IAsynWaitSp> spWait;
		ErrorCodeEnum Error = pFuncPrivilege->TerminateEntity(entity_name, spWait);
		if (Error == Error_Succeed) {
			callback_entry *entry = new callback_entry();
			entry->pRawData = pData;
			entry->EntityName = entity_name;
			entry->ErrorResult = Error_Unexpect;
			entry->op = OP_TERMINATE_ENTITY;
			if (spWait != NULL)
				spWait->SetCallback(this, entry);
		}
		return Error;
	} else {
		return Error_NoPrivilege;
	}
}

void CHealthManagerFSM::OnAnswer(CSmartPointer<IAsynWaitSp> pAsynWaitSp)
{
	CSmartPointer<ICallbackListener> spCallback;
	CSmartPointer<IReleasable> pData;
	pAsynWaitSp->GetCallback(spCallback, pData);
	callback_entry *entry = dynamic_cast<callback_entry*>((IReleasable*)(pData.GetRawPointer()));
	entry->ErrorResult = pAsynWaitSp->AsyncGetAnswer();
	callback_entry *new_entry = new callback_entry();

	new_entry->EntityName = entry->EntityName;
	new_entry->ErrorResult = entry->ErrorResult;
	new_entry->op = entry->op;
	new_entry->state = entry->state;

	map<CSimpleStringA,EntityLoadInfo>::iterator it;
	int ret;
	Dbg("stage %d,%s,result %d",m_eStage,(LPCSTR)new_entry->EntityName,new_entry->ErrorResult);
	if (entry->op == OP_START_ENTITY && new_entry->ErrorResult != Error_Succeed) {
		//ShowEntityBootFailedAtFront(new_entry->EntityName, new_entry->ErrorResult, false);
	}

	switch(m_eStage)
	{
	case LOADSTAGE_COREBOOT:
		it = m_coreBootOpt.find(new_entry->EntityName);
		if (it != m_coreBootOpt.end())
		{
			if (new_entry->ErrorResult == Error_Succeed)
				it->second.eResult = LOADING_SUCCEED;
			else if (new_entry->ErrorResult == Error_TimeOut)
				it->second.eResult = LOADING_TIMEOUT;
			else
				it->second.eResult = LOADING_FAILED;
			if (it->second.eResult != Error_Succeed)
			{
				char tmp[64] = {0};
				sprintf(tmp, "实体 %s 启动失败", it->first.GetData());
				Dbg("%s", tmp);
			}
			ret = CheckLoadResult(LOADSTAGE_COREBOOT);
			if (ret == 0 || ret == 2)
			{
				FSMEvent *e = new FSMEvent(USER_EVT_COREBOOT_FINISHED);
				e->param1 = ret;
				PostEventFIFO(e);
			}
		}
		break;
	case LOADSTAGE_SAFELOAD:
		it = m_safeLoadOpt.find(new_entry->EntityName);
		if (it != m_safeLoadOpt.end())
		{
			if (new_entry->ErrorResult == Error_Succeed)
				it->second.eResult = LOADING_SUCCEED;
			else if (new_entry->ErrorResult == Error_TimeOut)
				it->second.eResult = LOADING_TIMEOUT;
			else
				it->second.eResult = LOADING_FAILED;
			ret = CheckLoadResult(LOADSTAGE_SAFELOAD);
			Dbg("safeload answer %d",ret);
			if (ret == 0 || ret == 2)
			{
				FSMEvent *e = new FSMEvent(USER_EVT_SAFELOAD_FINISHED);
				e->param1 = ret;
				PostEventFIFO(e);
			}
		}
		else
			Dbg("cannot find %s",(LPCTSTR)new_entry->EntityName);
		break;
	case LOADSTAGE_OPERATING:
		it = m_operatingOpt.find(new_entry->EntityName);
		if (it != m_operatingOpt.end())
		{
			if (new_entry->ErrorResult == Error_Succeed)
				it->second.eResult = LOADING_SUCCEED;
			else if (new_entry->ErrorResult == Error_TimeOut)
				it->second.eResult = LOADING_TIMEOUT;
			else
				it->second.eResult = LOADING_FAILED;
			ret = CheckLoadResult(LOADSTAGE_OPERATING);
			if (ret == 0 || ret == 2)
			{
				FSMEvent *e = new FSMEvent(USER_EVT_OPERATING_FINISHED);
				e->param1 = ret;
				PostEventFIFO(e);
			}
		}
		break;
	default:
		break;
	}
}
void CHealthManagerFSM::ToCheckUPS()
{
	CSmartPointer<IEntityFunction> pFunc = GetEntityBase()->GetFunction();
	CSmartPointer<IEntityFunctionPrivilege> pFuncPrivilege = pFunc.ConvertCase<IEntityFunctionPrivilege>();
	CEntityRunInfo acInfo;
	ErrorCodeEnum eErrCode;
	eErrCode = pFunc->GetEntityRunInfo("Ups",acInfo);
	Dbg("ups state %d,%d",eErrCode,acInfo.eState);
	if (acInfo.eState != EntityState_NoStart)
	{
		CSmartPointer<IAsynWaitSp> spWait;
		eErrCode = pFuncPrivilege->TerminateEntity("Ups",spWait);
		Sleep(2000);
		eErrCode = pFuncPrivilege->StartEntity("Ups",NULL,spWait);
		if (spWait != NULL)
			eErrCode = spWait->WaitAnswer(5000);
		Dbg("restart ups wait %d",eErrCode);
	}
}

int CHealthManagerFSM::USBControl()
{
	CSystemStaticInfo sysInfo;
	ErrorCodeEnum eErr = GetEntityBase()->GetFunction()->GetSystemStaticInfo(sysInfo);
	if (eErr != Error_Succeed)
	{
		Dbg("Get system static info failed(%d).",eErr);
		return -1;
	}
	Dbg("machinetype[%s]",(LPCTSTR)sysInfo.strMachineType);
	if (sysInfo.strMachineType.Compare("RVC.PAD") == 0)
	{
		if (m_pDevCtrlClient == NULL)
		{
			m_pDevCtrlClient = new DeviceControlService_ClientBase(this->m_pEntity);
			ErrorCodeEnum eErr = m_pDevCtrlClient->Connect();
			if (eErr != Error_Succeed) {
				Dbg("DeviceControl connected failed(%d).",eErr);
				m_pDevCtrlClient->SafeDelete();
				m_pDevCtrlClient = NULL;
				return -1;
			}
		}
		if (m_pDevCtrlClient != NULL)
		{
			DeviceControlService_USB_Req req;
			DeviceControlService_USB_Ans ans;
			req.open = true;
			eErr = m_pDevCtrlClient->USB(req,ans,5000);
			if (eErr != Error_Succeed)
			{
				Dbg("usb control failed(%d).",eErr);
				return -1;
			}
			else
				Dbg("usb opened.");
		}
	}
	return 0;
}

CSimpleStringA CHealthManagerFSM::GetEntityCfgInfo(CSimpleStringA name,int &loadOpt)
{
	CSimpleStringA entityList("");
	Dbg("GetEntityCfgInfo %s",(LPCTSTR)name);
	if (!name.IsNullOrEmpty() && name.Compare("AllConfiguredEntity") == 0)
	{
		for (auto itor = m_vAllCfgEntity.cbegin(); itor != m_vAllCfgEntity.cend(); itor++)
		{
			entityList += (*itor) + ",";
		}
		return entityList;
	}

#ifdef RVC_OS_WIN
	if (!name.IsNullOrEmpty() && name.Compare("IEBrowser") == 0)
	{
		Dbg("IEBrowser just return 2");
		loadOpt = 2;
		return "";
	}
#endif //RVC_OS_WIN

	map<CSimpleStringA,EntityLoadInfo>::iterator it;
	for (it = m_coreBootOpt.begin(); it != m_coreBootOpt.end(); ++it)
	{
		if (_strnicmp(name,it->first,name.GetLength()) == 0)
		{
			loadOpt = it->second.loadOpt;
			Dbg("GetEntityCfgInfo %d",loadOpt);
			return "";
		}
	}
	for (it = m_safeLoadOpt.begin(); it != m_safeLoadOpt.end(); ++it)
	{
		if (_strnicmp(name,it->first,name.GetLength()) == 0)
		{
			loadOpt = it->second.loadOpt;
			Dbg("GetEntityCfgInfo %d",loadOpt);
			return "";
		}
	}
	for (it = m_operatingOpt.begin(); it != m_operatingOpt.end(); ++it)
	{
		if (_strnicmp(name,it->first,name.GetLength()) == 0)
		{
			loadOpt = it->second.loadOpt;
			Dbg("GetEntityCfgInfo %d",loadOpt);
			return "";
		}
	}
	loadOpt = 99;
	return "";
}

CSimpleStringA CHealthManagerFSM::QueryCheckCode()
{
	ErrorCodeEnum eErr = Error_Unexpect;
	CSimpleStringA tmpCheckCode("");
	PinPadService_ClientBase *pClient = new PinPadService_ClientBase(this->m_pEntity);
	if (pClient != NULL)
	{
		eErr = pClient->Connect();
		if (eErr == Error_Succeed)
		{
			PinPadService_QueryFunc_Req reqQ;
			PinPadService_QueryFunc_Ans ansQ;
			eErr = pClient->QueryFunc(reqQ, ansQ, 5000);
			if (eErr == Error_Succeed)
			{
				PinPadService_GetCheckCode_Req reqG;
				PinPadService_GetCheckCode_Ans ansG;
				if (ansQ.reserved1 == 2)//if sm only
				{
					reqG.mSN.Init(1);
					reqG.wSN.Init(1);
					reqG.mSN[0] = 1;
					reqG.wSN[0] = 0;
					eErr = pClient->GetCheckCode(reqG, ansG, 10000);
					if (eErr == Error_Succeed)
					{
						tmpCheckCode = ansG.checkcode[0];
					}
				}
				else//3des only or 3des&sm both ok
				{
					reqG.mSN.Init(1);
					reqG.wSN.Init(1);
					reqG.mSN[0] = 0;
					reqG.wSN[0] = 0;
					eErr = pClient->GetCheckCode(reqG, ansG, 10000);
					if (eErr == Error_Succeed)
					{
						tmpCheckCode = ansG.checkcode[0];
					}
				}
			}
			else
				Dbg("QueryFunc failed.error code:%d",eErr);
		}
		else
			Dbg("connect to pinpad failed.error code:%d",eErr);
	}
	return tmpCheckCode;
}

CSimpleStringA CHealthManagerFSM::QueryPinPadSM3DesInfo()
{
	ErrorCodeEnum eErr = Error_Unexpect;
	CSimpleStringA sm3desInfo("support:");
	PinPadService_ClientBase* pClient = new PinPadService_ClientBase(this->m_pEntity);
	if (pClient != NULL)
	{
		eErr = pClient->Connect();
		if (eErr == Error_Succeed)
		{
			PinPadService_QueryFunc_Req reqQ;
			PinPadService_QueryFunc_Ans ansQ;
			eErr = pClient->QueryFunc(reqQ, ansQ, 5000);
			if (eErr == Error_Succeed)
			{
				Dbg("support:%d,loaded:%d",ansQ.encryptkey,ansQ.reserved1);
				if (ansQ.encryptkey == 3)
					sm3desInfo += "sm3des";
				else if((ansQ.encryptkey == 2))
					sm3desInfo += "sm";
				else
					sm3desInfo += "3des";
				sm3desInfo += ",loadkey:";
				if (ansQ.reserved1 == 3)
					sm3desInfo += "sm3des";
				else if ((ansQ.reserved1 == 2))
					sm3desInfo += "sm";
				else
					sm3desInfo += "3des";
			}
			else
				Dbg("QueryFunc failed.error code:%d", eErr);
		}
		else
			Dbg("connect to pinpad failed.error code:%d", eErr);
	}
	return sm3desInfo;
}

void CHealthManagerFSM::DeviceReConnect()
{
	//if haven't called access auth ever or in the 1st accessauth processing,no need to call access auth
	if (QueryAccessAuthStatus() == 2 || m_bFirstAccessAuth)
		return;
	CSimpleStringA tmpCheckCode = QueryCheckCode();
	Dbg("pre check code size:%d,now:%d",m_checkCode.GetLength(),tmpCheckCode.GetLength());
	SetAccessFailedFlag(false);
	if (tmpCheckCode.GetLength() == 0 || m_checkCode.Compare(tmpCheckCode, true) != 0 || !GetAccessAuthFlag() || !m_bEverAuthSucWithDevice)
	{
		if (m_checkCode.GetLength() > 1 && tmpCheckCode.GetLength() > 1 && m_checkCode.Compare(tmpCheckCode, true) != 0)
		{
			AuthStatus as;
			as.result = 1;
			as.msg = "设备混用，请接入对应设备或后台重新绑定当前设备";
			SpSendBroadcast(GetEntityBase()->GetFunction(), SP_MSG_OF(AuthStatus), SP_MSG_SIG_OF(AuthStatus), as);
		}
		else if(!m_bFirstAccessAuth)
		{
			if (m_checkCode.GetLength() > 1)
				ToReAccessAuth(true);
			else
				ToReAccessAuth();
		}
	}
}

int CHealthManagerFSM::QuitFrameworkAndSaveInfo(RebootTriggerEnum eTrigger, RebootWayEnum eWay)
{
	CSmartPointer<IEntityFunction> pFunc = GetEntityBase()->GetFunction();
	CSmartPointer<IEntityFunctionPrivilege> pFuncPrivilege = pFunc.ConvertCase<IEntityFunctionPrivilege>();
	Dbg("quit framework and info %d,%d.", eTrigger, eWay);
	const auto result = pFuncPrivilege->Reboot(eTrigger, eWay);
	return (int)result;
}

void CHealthManagerFSM::PostProcessAfterUpgrade()
{
	LOG_FUNCTION();
	CSimpleStringA csRunInfoPath(""), csFileName("");

	ErrorCodeEnum eErr = GetEntityBase()->GetFunction()->GetPath("RunInfo", csRunInfoPath);
	csFileName = csRunInfoPath + "/runcfg/starttime.dat";
	Dbg("file:%s", (const char*)csFileName);
	bool bUpgradeFileExist = false;

#ifdef RVC_OS_WIN
	bUpgradeFileExist = (_access((const char*)csFileName, 0) == 0);
#else
	bUpgradeFileExist = (access((const char*)csFileName, F_OK) == 0);
#endif //RVC_OS_WIN

	if (bUpgradeFileExist)
	{
		Dbg("exist upgrade flag file,to decide if restart framework.");
		//存在升级后的启动文件
		CSmartPointer<IConfigInfo> spConfigRun;
		eErr = GetEntityBase()->GetFunction()->OpenConfig(Config_Run, spConfigRun);
		if (eErr == Error_Succeed)
		{
			int xTimes = 0;
			spConfigRun->ReadConfigValueInt("Run", "UpgradeRestartTimes", xTimes);
			if (xTimes < 3)
			{
				xTimes++;
				Dbg("write Run--UpgradeRestartTimes:%d", xTimes);
				spConfigRun->WriteConfigValueInt("Run", "UpgradeRestartTimes", xTimes);
				if (xTimes == 3)
				{
					//DeleteFileA((const char*)csFileName);
					QuitFrameworkAndSaveInfo(RebootTrigger_Resource, RebootWay_OS);
				}
				else
					QuitFrameworkAndSaveInfo(RebootTrigger_Resource, RebootWay_Framework);
			}
		}
	}
}

CSimpleStringA GetOsVersion()
{
#ifdef RVC_OS_WIN
	char   psBuffer[128];
	FILE* pPipe;

	/* Run DIR so that it writes its output to a pipe. Open this
	 * pipe with read text attribute so that we can read it
	 * like a text file.
	 */
	if ((pPipe = _popen("ver", "rt")) == NULL)
		exit(1);

	/* Read pipe until end of file, or an error occurs. */

	while (fgets(psBuffer, 128, pPipe))
	{
		//puts(psBuffer);
	}

	Dbg("%s", psBuffer);
	/* Close pipe and print return value of pPipe. */
	if (feof(pPipe))
	{
		printf("\nProcess returned %d\n", _pclose(pPipe));
	}
	else
	{
		printf("Error: Failed to read the pipe to the end.\n");
	}
	string str(psBuffer);
	int start = str.find("版本");
	if (start > 0)
		return CSimpleStringA(str.substr(start + 5, str.length() - start - 7).c_str());
	else
		return "";
#else
    const char filePath[] = "/etc/os-version";
	CSimpleStringA strVersion;
    char tmp[33];
    memset(tmp, 0, 33);
    inifile_read_str_s("Version", "MajorVersion", "unknown", tmp, 32, filePath);
    strVersion = tmp;
    strVersion += ".";
    memset(tmp, 0, 33);
    inifile_read_str_s("Version", "MinorVersion", "unknown", tmp, 32, filePath);
    strVersion += tmp;
    strVersion += ".";
    memset(tmp, 0, 33);
    inifile_read_str_s("Version", "OsBuild", "unknown", tmp, 32, filePath);
    strVersion += tmp;
    return strVersion;
#endif
}

void CHealthManagerFSM::UploadEntityStartComsumeTime()
{
    CAutoArray<CSimpleStringA> strEntityNames;
    CAutoArray<int> strEntityIdx;
    CAutoArray<CEntityStartInfo> Infos;
    ErrorCodeEnum eErr = GetEntityBase()->GetFunction()->GetAllEntityStartInfo(strEntityNames, strEntityIdx, Infos);
	int healthmangerStartTimes = 0;
	for (int i = 0; i < strEntityNames.GetCount(); ++i) {
		if (strEntityNames[i].Compare(GetEntityBase()->GetEntityName()) == 0)
		{
            Dbg("%s", (const char*)strEntityNames[i]);
			healthmangerStartTimes = Infos[i].startTimes;
			break;
		}
	}

	if (healthmangerStartTimes == 1) {
		const int i = 0; //SpShell 
		const ULONGLONG curTickCount = GetTickCount64();
		ULONGLONG oldTickCount = 0;
		/** 只有SpShell的结构体才能这样做！！ [Gifur@202193]*/
		memcpy(&oldTickCount, &Infos[i].InitEndTime, sizeof(ULONGLONG));
		const ULONGLONG deltaSeconds = (curTickCount - oldTickCount);
        LogWarn(Severity_Low, Error_Debug, LOG_TRACE_ENTITY_START_TIME,
                SP::Module::Util::generateConsumeTimeJson("total",
                                                          SP::Module::Util::formatTime(Infos[i].startTime).c_str(), deltaSeconds));
	} else {
		Dbg("entity healthmanage start times: %d", healthmangerStartTimes);
	}
}

void CHealthManagerFSM::ToLogWarnTermAboutInfo(BOOL bSuccessFlag)
{
    CSimpleStringA csOSVerion, csWarnMsg(""), csAsiaInfo;
    std::map<std::string, std::string> termInfo;
    termInfo["version"] = m_sysInfo.InstallVersion.ToString();
    if (!m_csErrEntity.IsNullOrEmpty())
        termInfo["ErrEntity"] = m_csErrEntity;
    csOSVerion = GetOsVersion();
    if (!csOSVerion.IsNullOrEmpty())
        termInfo["OSVersion"] = csOSVerion;
#if defined(RVC_OS_WIN)
	csAsiaInfo = GetIsAsiaInfoInstalled();
#else
	csAsiaInfo = "N";
#endif //RVC_OS_WIN
    termInfo["AsiaInfo"] = csAsiaInfo;

    NetworkAddressesList macAddrs;
    NetworkAddressesList ipAddrs;
	SP::Module::Net::GetINETMacAddresses(macAddrs, ipAddrs);
    CSimpleStringA csMac(""), csIP("");
    for (int i = 0; i < macAddrs.GetCount(); i++) {
        csMac += macAddrs[i];
        csMac += ";";
    }
    for (int i = 0; i < ipAddrs.GetCount(); i++) {
        csIP += ipAddrs[i];
        csIP += ";";
    }

    termInfo["MACs"] = csMac;
    termInfo["IPs"] = csIP;
    std::pair<bool, std::string> strResult;
    strResult = generateJsonStr(termInfo);
    Dbg("[%s]", strResult.second.c_str());
    //oilyang@20210323 discard the following rule of throwing LogWarn.Always throw LogWarn 
    //oilyang@20201201 log warn every time if content of msg has changed
    LogWarn(Severity_Low, Error_Unexpect, LOG_WARN_HEALTH_UPLOAD_INFO_ABOUT_TERM, strResult.second.c_str());

	if (bSuccessFlag) {
		UploadEntityStartComsumeTime();
	}
}

void CHealthManagerFSM::ShowEntityBootFailedAtFront(LPCTSTR lpcszEntityName, ErrorCodeEnum bootFailedResult, bool isBlock)
{
#if defined(RVC_OS_LINUX)

	CEntityLastErrorInfo errInfo = {};
	ErrorCodeEnum errCode = GetEntityBase()->GetFunction()->GetEntityLastError(lpcszEntityName, errInfo);
	CSimpleStringA strErrMsg(true);
	if (!errInfo.strErrMsg.IsNullOrEmpty()) {
		strErrMsg = CSimpleStringA::Format("%s 模块初始化失败：%s", lpcszEntityName, (LPCTSTR)errInfo.strErrMsg);
	} else {
		strErrMsg = CSimpleStringA::Format("%s 模块初始化失败：%s", lpcszEntityName, (LPCTSTR)SpStrError(bootFailedResult));
	}

	if (isBlock) {
        SP::Module::Comm::LogErrorNotiyStruct notifyItem(bootFailedResult, 0);
        SP::Module::Comm::LogNotiyMessageStruct notifyMsg(strErrMsg);
        notifyItem.Notify(notifyMsg);
	} else {
		LogError(Severity_High, bootFailedResult, 0, strErrMsg);
	}

#endif //RVC_OS_LINUX
}