myvtm/Module/mod_healthmanager/HealthManagerFSM.cpp

#include "stdafx.h"
#include <fstream>
#include <string>
#include <algorithm>
#include "CommEntityUtil.hpp"
#if defined(RVC_OS_WIN)
#include <TlHelp32.h>
#include <iphlpapi.h>
#include <ws2tcpip.h>
#include <Winsock2.h>
#include <io.h>
#include "CSystemStatus.h"
#pragma comment(lib, "IPHLPAPI.lib")
#pragma comment(lib, "libpublicFun.lib")
#else
#include <unistd.h>
#include <fcntl.h>
#include <errno.h>
#include "iniutil.h"
#endif //RVC_OS_WIN


#include "mod_healthmanager.h"
#include "publicFunExport.h"

using namespace std;

const int MAX_AYSNC_TIMEOUT = 60000;
const int MAX_IGNORE_TIMEOUT = 100;

unsigned long long GetTickCountRVC() {
#if defined(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() {
#if defined(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()
{
#if defined(RVC_OS_WIN)
	SaveOsVersion();
#endif
	CSmartPointer<IEntityFunction> pFunc = GetEntityBase()->GetFunction();
	CSmartPointer<IEntityFunctionPrivilege> pFuncPrivilege = pFunc.ConvertCase<IEntityFunctionPrivilege>();
	CSmartPointer<IAsynWaitSp> spWait;
	
	ErrorCodeEnum err;
	GetEntityBase()->GetFunction()->GetSystemStaticInfo(m_sysInfo);
	DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("machinetype[%s],terminalID[%s]", (LPCTSTR)m_sysInfo.strMachineType, (LPCTSTR)m_sysInfo.strTerminalID);

	CSmartPointer<IConfigInfo> spConfigCen;
	GetEntityBase()->GetFunction()->OpenConfig(Config_CenterSetting, spConfigCen);
	m_AccessAuthTries = 4;
	do {
		int value(0);
		spConfigCen->ReadConfigValueInt(GetEntityBase()->GetEntityName(), "AccessAuthTries", value);
		if (value > 0) {
			m_AccessAuthTries = value;
		}
	} while (false);
	m_InitTries = 4;
	do {
		int value(0);
		spConfigCen->ReadConfigValueInt(GetEntityBase()->GetEntityName(), "InitTries", value);
		if (value > 0) {
			m_InitTries = value;
		}
	} while (false);
	m_AccessAuthTimeout = 180000;
	do {
		int value(0);
		spConfigCen->ReadConfigValueInt(GetEntityBase()->GetEntityName(), "AccessAuthTimeout", value);
		if (value > 0) {
			m_AccessAuthTimeout = value;
		}
	} while (false);
	m_InitializationTimeout = 180000;
	do {
		int value(0);
		spConfigCen->ReadConfigValueInt(GetEntityBase()->GetEntityName(), "InitializationTimeout", value);
		if (value > 0) {
			m_InitializationTimeout = value;
		}
	} while (false);

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

	CSmartPointer<IConfigInfo> spConfig;
	err = GetEntityBase()->GetFunction()->OpenConfig(Config_Software, spConfig);
	if (err != Error_Succeed) {
		DbgWithLink(LOG_LEVEL_ERROR, LOG_TYPE_SYSTEM).setAPI(__FUNCTION__)("open cfg file failed!");
		return Error_IO;
	}

#if defined(RVC_OS_LINUX)
    if (!m_sysInfo.strMachineType.IsNullOrEmpty() && m_sysInfo.strMachineType.Compare("RVC.Stand2S") != 0
		&& m_sysInfo.strMachineType.Compare("RVC.Stand1SPlus") != 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

	spConfigCen->ReadConfigValueInt(GetEntityBase()->GetEntityName(), "WKUpdatePeriod", m_wkUpdatePeriod);
	if (m_wkUpdatePeriod <= 0 || m_wkUpdatePeriod > 365)
		m_wkUpdatePeriod = 30;//default
	spConfigCen->ReadConfigValueInt(GetEntityBase()->GetEntityName(), "DoNotUpdateWKDaily", m_iDoNotUpdateWKDaily);
	CSimpleStringA csTmpTS("");
	GetEntityBase()->GetFunction()->GetSysVar("TerminalStage", csTmpTS);
	if (csTmpTS.Compare("N") != 0)
		GetEntityBase()->GetFunction()->SetSysVar("TerminalStage", "X");
	WaitDeamonFinishTask* task = new WaitDeamonFinishTask(this);
	GetEntityBase()->GetFunction()->PostThreadPoolTask(task);

	return Error_Succeed;
}
ErrorCodeEnum CHealthManagerFSM::OnInit(void)
{
	return Initial();
}
ErrorCodeEnum CHealthManagerFSM::OnExit(void)
{
	return Error_Succeed;
}
void CHealthManagerFSM::s0_on_entry(void)
{
	LOG_FUNCTION();
	m_fsmState = HM_FSM_INIT;
	m_ullElapseFromOSStart = SP::Module::Comm::RVCGetTickCount();
	m_elapseTimeFromOSStart = m_ullElapseFromOSStart / 1000;
	CSimpleStringA xMsg = CSimpleStringA::Format("{\"Decripstion\":\"Entity start\",\"version\":\"%s\",\"elapseTime\":\"%d\"}", m_sysInfo.InstallVersion.ToString().GetData(), m_elapseTimeFromOSStart);
	LogWarn(Severity_Low, Error_Unexpect, HealthManager_UserErrorCode_Enter_SafeLoad_State, xMsg.GetData());
}
void CHealthManagerFSM::s0_on_exit(void)
{
}
unsigned int CHealthManagerFSM::s0_on_event(FSMEvent* pEvt)
{
	DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("s0_on_event: %d, %d", pEvt->iEvt, pEvt->param1);
	int ret = 0;
	switch(pEvt->iEvt)
	{
	case USER_EVT_WAIT_DEAMON_FINISHED:
		ret = pEvt->param1;
		pEvt->SetHandled();
		break;
	default:
		break;
	}
	return ret;
}

//Idle(Operating finished)
void CHealthManagerFSM::s4_on_entry()
{
	m_fsmState = HM_FSM_STATE_IDLE;
	LOG_FUNCTION();
	CSmartPointer<IEntityFunction> spEntityFunction = GetEntityBase()->GetFunction();
	CSmartPointer<IConfigInfo> spConfig, spCerConfig;
	ErrorCodeEnum eErrCer = spEntityFunction->OpenConfig(Config_CenterSetting, spCerConfig);
	if (eErrCer != Error_Succeed) {
		DbgWithLink(LOG_LEVEL_WARN,LOG_TYPE_SYSTEM)("open central cfg file failed!");
	}
	else
	{
		m_NewStartPage = "";
		spCerConfig->ReadConfigValue("NonExclusive", "NewStartPage", m_NewStartPage);
	}
}
void CHealthManagerFSM::s4_on_exit()
{
	LOG_FUNCTION();
}
unsigned int CHealthManagerFSM::s4_on_event(FSMEvent* pEvt)
{
	LOG_FUNCTION();
	DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM)("s4 event %d,%d",pEvt->iEvt,pEvt->param1);
	switch(pEvt->iEvt)
	{
	case USER_EVT_ACCESSAUTH_FINISHED:
		{
			pEvt->SetHandled();
			
			CSimpleStringA csTermStage;
			ErrorCodeEnum eErrCode;
			eErrCode = GetEntityBase()->GetFunction()->GetSysVar("TerminalStage",csTermStage);
			DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM)("after accessauth to get termstage %s",(LPCTSTR)csTermStage);
			//oilyang@20220614 添加密钥更新逻辑
			if (csTermStage[0] == 'A')
			{
				DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("after auth suc,to call WKUpdatePeriodTask");
				WKUpdatePeriodTask* pTask = new WKUpdatePeriodTask(this);
				GetEntityBase()->GetFunction()->PostThreadPoolTask(pTask);
			}
			//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)
			{
				DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM)("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) {
				DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM)("open cfg file(ie) failed!");
				//return err;
			}
			ErrorCodeEnum eErrCerUrl = spEntityFunction->OpenConfig(Config_CenterSetting, spCerConfig);
			if (eErrCerUrl != Error_Succeed) {
				DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM)("open central cfg file(ie) failed!");
			}
			//if load successfully,set FailTimes to 0
			spConfigRun->WriteConfigValueInt("Run","FailTimes",0);


			CSmartPointer<IAsynWaitSp> spWait;
			CSmartPointer<IEntityFunctionPrivilege> pFuncPrivilege = spEntityFunction.ConvertCase<IEntityFunctionPrivilege>();
			CEntityRunInfo acInfo;
			eErrCode = spEntityFunction->GetEntityRunInfo("Chromium",acInfo);
			if (eErrCode == Error_Succeed && acInfo.eState == EntityState_NoStart)
			{
			}
			else if (eErrCode == Error_Succeed && acInfo.eState == EntityState_Idle)
			{//if IE/Chromium start before healthmanager,we suppose healthmanager is restart unexpectly,then set m_bEnterMainPageEver true
				//m_bIEBeforeHealth = true;
			}
			LogTermInfoTask* task = new LogTermInfoTask(this);
			GetEntityBase()->GetFunction()->PostThreadPoolTask(task);
			if (m_iAccessAuth == AccessAuth_Fail)
				PostProcessAfterUpgrade();
		}
		break;
	case USER_EVT_MAITAIN:
		DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM)("to maintain...");
		m_stateBeforeMaintain = m_fsmState;
		m_bIdleToMaintain = true;
		pEvt->SetHandled();
		break;
	case USER_EVT_ENTER_CUSTOMER_MANAGER:
		pEvt->SetHandled();
		break;
	case USER_EVT_VTMLOADER_FINISHED:
	{
		pEvt->SetHandled();
		if (pEvt->param1 == 1)
		{
			DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("VtmLoader load entity failed, to Set TerminalStage C.");
			GetEntityBase()->GetFunction()->SetSysVar("TerminalStage", "C");
			break;
		}
		if (!m_bIdleToMaintain)//???no use anymore?
		{
			if (m_iAccessAuth == AccessAuth_Init)
			{
				WaitToCallAccessAuthTask* pTask = new WaitToCallAccessAuthTask(this);
				GetEntityBase()->GetFunction()->PostThreadPoolTask(pTask);
			}
		}
		else
			m_bIdleToMaintain = false;
	}
		break;
	default:
		break;
	}
	return 0;
}
//Fault
void CHealthManagerFSM::s5_on_entry()
{
	LOG_FUNCTION();
	LogTermInfoTask* task = new LogTermInfoTask(this);
	GetEntityBase()->GetFunction()->PostThreadPoolTask(task);
	m_fsmState = HM_FSM_STATE_FAULT;
	CSmartPointer<IConfigInfo> spConfigCen,spConfigRun;
	ErrorCodeEnum eErr = GetEntityBase()->GetFunction()->OpenConfig(Config_CenterSetting, spConfigCen);
	eErr = GetEntityBase()->GetFunction()->OpenConfig(Config_Run, spConfigRun);
	int failTimes = 0,maxFailTimes = 2;
	do {
		int value(0);
		spConfigCen->ReadConfigValueInt(GetEntityBase()->GetEntityName(), "MaxFailTimes", value);
		if (value > 0) {
			maxFailTimes = value;
		}
	} while (false);
	spConfigRun->ReadConfigValueInt("Run","FailTimes",failTimes);
	failTimes++;
	LogWarn(Severity_High, Error_Unexpect, LOG_ERR_HEALTH_FAILED, "HealthManager failed.");
	//oilyang@20210930 add to call for Close Page
	GetEntityBase()->GetFunction()->SetSysVar("TerminalStage", "C");
	if (failTimes > maxFailTimes)
	{
		LogEvent(Severity_Middle,LOG_EVT_HEADLIGHT_RED_ON,"设备故障");
		eErr = GetEntityBase()->GetFunction()->SetSysVar("TerminalStage","D");
		if (eErr != Error_Succeed){
			DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM)("set termstage D failed (%d).",eErr);
		}else{
			DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM)("Set TerminalStage D.");
		}
	}
	else
	{
		DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM)("have failed %d times.",failTimes);
		spConfigRun->WriteConfigValueInt("Run","FailTimes",failTimes);
		eErr = GetEntityBase()->GetFunction()->SetSysVar("RunState","F");
		if (eErr != Error_Succeed)
		{
			DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM)("set RunState failed (%d).",eErr);
		}
	}
	PostProcessAfterUpgrade();
}
void CHealthManagerFSM::s5_on_exit()
{
	LOG_FUNCTION();
}
unsigned int CHealthManagerFSM::s5_on_event(FSMEvent* pEvt)
{
	LOG_FUNCTION();
	DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM)("s5(Fault) event %d,%d",pEvt->iEvt,pEvt->param1);
	switch(pEvt->iEvt)
	{
	case USER_EVT_MAITAIN:
		DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM)("to maintain...");
		m_stateBeforeMaintain = m_fsmState;
		pEvt->SetHandled();
		break;
	case USER_EVT_ENTER_CUSTOMER_MANAGER:
		pEvt->SetHandled();
		break;
	case USER_EVT_ACCESSAUTH_FINISHED:
		pEvt->SetHandled();
		if (pEvt->param1 == 1)
		{
			return 1;
		}
		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)
	{
		DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM)("set RunState M failed (%d).",eErrCode);
	}
	CSmartPointer<IEntityFunction> pFunc = GetEntityBase()->GetFunction();
	CSmartPointer<IEntityFunctionPrivilege> pFuncPrivilege = pFunc.ConvertCase<IEntityFunctionPrivilege>();
	if (pFuncPrivilege == NULL)
	{
		DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM)("display screen NoPrivilege");
		return;
	}
	ErrorCodeEnum eErr = pFuncPrivilege->DisplayBlueScreen("暂停服务");
	DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM)("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)
			{
				DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM)("un-display screen NoPrivilege");
				return 1;
			}
			ErrorCodeEnum eErr = pFuncPrivilege->UndisplayBlueScreen();
			DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM)("un-display blue screen %d",eErr);
			if (m_stateBeforeMaintain == HM_FSM_STATE_IDLE)
			{
				ErrorCodeEnum eErr = GetEntityBase()->GetFunction()->SetSysVar("RunState","O");
				if (eErr != Error_Succeed)
				{
					DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM)("set RunState O failed (%d).",eErr);
				}
			}
			ret = m_preFsmState;
		}
		break;
	case USER_EVT_ENTER_CUSTOMER_MANAGER:
		pEvt->SetHandled();
		break;
	default:
		break;
	}
	return ret;
}
//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();
	DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM)("s11(In CMS) event %d",pEvt->iEvt);
	int ret = 0;
	switch (pEvt->iEvt)
	{
		case USER_EVT_MAITAIN:
			DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM)("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;
}

//0:auth suc or have already authed;1:auth failed;
int CHealthManagerFSM::AccessAuthDoWork()
{
	LOG_FUNCTION();
	//to check if PinPad is ok, wait for 5 seconds,then go on
	//RVC.CardStore have no PinPad
	int waitCount = 0;
	while (waitCount < 5)
	{
		if (m_bPinPadOpenSuc || m_sysInfo.strMachineType.Compare("RVC.CardStore",true) == 0)
			break;
		else
		{
			Sleep(1000);
			waitCount++;
		}
	}

	m_bInAccessAuthDoWork = true;
	CSimpleStringA csTermStage("");
	ErrorCodeEnum eErr;
	eErr = GetEntityBase()->GetFunction()->GetSysVar("TerminalStage", csTermStage);
	DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("oninit get termstage %s", (LPCTSTR)csTermStage);
	if (eErr == Error_Succeed)
	{

	}
	else
	{
		DbgWithLink(LOG_LEVEL_ERROR, LOG_TYPE_SYSTEM).setAPI(__FUNCTION__)("get TerminalStage failed(%d).", eErr);
		m_bInAccessAuthDoWork = false;
		return 1;
	}
	DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("after proc initialization.");

	//to accessauth
	ErrorCodeEnum eErrCode;
	eErrCode = GetEntityBase()->GetFunction()->GetSysVar("TerminalStage", csTermStage);
	DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM).setAPI(__FUNCTION__)("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>();
			{
				CEntityRunInfo acInfo;
				eErrCode = pFunc->GetEntityRunInfo("AccessAuthorization", acInfo);
				DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("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);
						DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("start accessauth %d.", eErrCode);
					}
					break;
					case EntityState_Idle:
						DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("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) {
							DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("accessauth connected failed:%s", SpStrError(eErrCode));
							m_pACClient->SafeDelete();
							m_pACClient = NULL;
							m_bInAccessAuthDoWork = false;
							return 1;
						}
						else {
							DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("accessauth connected.");
						}
					}
				}
				else
				{
					DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("Get AccessAuth RunInfo failed(%d).", eErrCode);
					m_bInAccessAuthDoWork = false;
					return 1;
				}
				if (m_pACClient != NULL)
				{
					DWORD dwStart = GetTickCountRVC();
					int registCount = 0;
#if defined(RVC_OS_WIN)
					GetEntityBase()->GetFunction()->ShowStartupInfo("正在准入");
#endif
				REGIST:
					//存在循环刷数据的情况，暂时不记这个，只记失败
					DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_USER).setLogCode("QLR0402501Z10301")();
					eErrCode = (*m_pACClient)(EntityResource::getLink().upgradeLink())->Regist();
					m_bHasAuthEver = true;
					registCount++;
					DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM).setAPI("AccessAuthDoWork")("accessauth regist %d", eErrCode);
					if (eErrCode == Error_Succeed)
					{
						do {
							if (m_iAccessAuth == AccessAuth_Suc || m_iAccessAuth == AccessAuth_Fail)
								break;
							Sleep(1000);
						} while (1);
						m_bFirstAccessAuth = false;
						m_bInAccessAuthDoWork = false;
						return 0;
					}
					else
					{
						DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_USER).setLogCode("QLR0402501Z10301").setResultCode("RTA5102")("call accessauth Regist failed:%d", eErrCode);
						m_bInAccessAuthDoWork = false;
						return 1;
					}
				}
				else
				{
					m_bInAccessAuthDoWork = false;
					return 1;
				}
			}
		}
		else
		{
			m_bInAccessAuthDoWork = false;
			return 0;
		}
	}
	else {
		DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM).setAPI("AccessAuthDoWork")("Get termstage failed(%d).", eErrCode);
	}
	m_bInAccessAuthDoWork = false;
	return 1;
}

void CHealthManagerFSM::SetAccessAuth(int bResult)
{
	m_iAccessAuth = bResult;
	ErrorCodeEnum eErrCode;
	if (bResult == AccessAuth_Suc)
	{
		eErrCode = GetEntityBase()->GetFunction()->SetSysVar("TerminalStage", "A");
	}
	else if (bResult == AccessAuth_servFail) //准入服务端返回失败
	{
		eErrCode = GetEntityBase()->GetFunction()->SetSysVar("TerminalStage", "S");
	}
	else //准入其他失败
	{
		eErrCode = GetEntityBase()->GetFunction()->SetSysVar("TerminalStage", "C");
	}
	DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("SetAccessAuth")("SetAccessAuth %d",bResult);

}

void CHealthManagerFSM::ToReAccessAuth(bool bEver)
{
	Sleep(1500);//for function "AccessAuthDoWork" to quit while
	if (m_bFirstAccessAuth)
		return;
	ToCallAccessAuthDoWork();
}
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);
		DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("AsyncStartEntity")("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)
{
}
ErrorCodeEnum CHealthManagerFSM::QueryCheckCode(CSimpleStringA& csCkCode, bool bMaster)
{
	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)(EntityResource::getLink().upgradeLink())->QueryFunc(reqQ, ansQ, 5000);
			if (eErr == Error_Succeed)
			{
				PinPadService_GetCheckCode_Req reqG;
				PinPadService_GetCheckCode_Ans ansG;
				//oilyang@20220425 sm only,no more 3des
				//if (ansQ.reserved1 == 2)//if sm only
				{
					reqG.mSN.Init(1);
					reqG.wSN.Init(1);
					reqG.mSN[0] = 1;
					if (bMaster)
						reqG.wSN[0] = 99;
					else
						reqG.wSN[0] = 0;
					eErr = (*pClient)(EntityResource::getLink().upgradeLink())->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;
				//	if (bMaster)
				//		reqG.wSN[0] = 99;
				//	else
				//		reqG.wSN[0] = 0;
				//	eErr = (*pClient)(EntityResource::getLink().upgradeLink())->GetCheckCode(reqG, ansG, 10000);
				//	if (eErr == Error_Succeed)
				//	{
				//		tmpCheckCode = ansG.checkcode[0];
				//	}
				//}
			}else{
				DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("QueryCheckCode")("QueryFunc failed.error code:%d",eErr);
			}
		}else{
			DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("QueryCheckCode")("connect to pinpad failed.error code:%d",eErr);
		}
	}
	csCkCode = tmpCheckCode;
	return eErr;
}
int CHealthManagerFSM::QuitFrameworkAndSaveInfo(RebootTriggerEnum eTrigger, RebootWayEnum eWay)
{
	CSmartPointer<IEntityFunction> pFunc = GetEntityBase()->GetFunction();
	CSmartPointer<IEntityFunctionPrivilege> pFuncPrivilege = pFunc.ConvertCase<IEntityFunctionPrivilege>();
	if (pFuncPrivilege == NULL) {
			DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM)("has no privilege");
		return (int)(Error_NoPrivilege);
	}
	DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM)("quit framework and info %d,%d.", eTrigger, eWay);
	const auto result = pFuncPrivilege->Reboot(eTrigger, eWay);
	return (int)result;
}
void CHealthManagerFSM::PostProcessAfterUpgrade()
{
	LOG_FUNCTION();

	if (IfInUpgradeProcess())
	{
		DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM)("exist upgrade flag file,to decide if restart framework.");
		//存在升级后的启动文件
		CSmartPointer<IConfigInfo> spConfigRun;
		ErrorCodeEnum eErr = GetEntityBase()->GetFunction()->OpenConfig(Config_Run, spConfigRun);
		if (eErr == Error_Succeed)
		{
			int restartOSTime = 0;
			spConfigRun->ReadConfigValueInt("Run", "UpgradeRestartOSTimes", restartOSTime);
			if(restartOSTime==1){
				DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM).setAPI(__FUNCTION__)("升级切换已重启过系统");
				//重启过的系统过的升级，在重试一定次数后等guardian 10分钟回退
				int xTimes = 0;
				spConfigRun->ReadConfigValueInt("Run", "UpgradeRestartTimes", xTimes);
				if (xTimes < 3)
				{
					xTimes++;
					DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("PostProcessAfterUpgrade")("写入: UpgradeRestartTimes:%d", xTimes);
					spConfigRun->WriteConfigValueInt("Run", "UpgradeRestartTimes", xTimes);
					QuitFrameworkAndSaveInfo(RebootTrigger_Resource, RebootWay_Framework);
				}
			}else{
				//未重启过操作系统
				DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("PostProcessAfterUpgrade")("升级切换未重启过系统");
				int xTimes = 0;
				spConfigRun->ReadConfigValueInt("Run", "UpgradeRestartTimes", xTimes);
				if (xTimes < 3)
				{
					xTimes++;
					DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("PostProcessAfterUpgrade")("写入: UpgradeRestartTimes:%d", xTimes);
					spConfigRun->WriteConfigValueInt("Run", "UpgradeRestartTimes", xTimes);
					//oilyang@20211130 change from 3 to 2
					if (xTimes == 2)
					{
						//重启操作系统前把重启框架次数重置，重启OS次数置为1
						DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("PostProcessAfterUpgrade")("准备尝试重启系统后再切换升级");
						spConfigRun->WriteConfigValueInt("Run", "UpgradeRestartTimes", 0);
						spConfigRun->WriteConfigValueInt("Run", "UpgradeRestartOSTimes", 1);
						Sleep(2000);
						QuitFrameworkAndSaveInfo(RebootTrigger_Resource, RebootWay_OS);
					}
					else
						QuitFrameworkAndSaveInfo(RebootTrigger_Resource, RebootWay_Framework);
				}
			}
		}
	}
}
void CHealthManagerFSM::SaveOsVersion()
{
#if defined(RVC_OS_WIN)
	CSimpleStringA runInfoPath;
	ErrorCodeEnum eErr = GetEntityBase()->GetFunction()->GetPath("runinfo", runInfoPath);
	if (eErr != Error_Succeed) {
		DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM)("GetPath runinfo error=%d.", eErr);
		return;
	}
	runInfoPath += "\\runcfg\\osverion";
	ifstream is;
	is.open(runInfoPath.GetData(), ios::binary);
	if (!is.is_open())
	{
		DWORD dwErr = GetLastError();
		DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM)("open runcfg\\osverion file failed. [%d]", dwErr);
		CSimpleStringA csCmd;
		csCmd = CSimpleStringA::Format("cmd /c ver >%s", runInfoPath);
		WinExec((LPCSTR)csCmd, SW_HIDE);
	}
#endif
	return;
}
CSimpleStringA CHealthManagerFSM::GetOsVersion()
{
#if defined(RVC_OS_WIN)
	CSimpleStringA runInfoPath;
	ErrorCodeEnum eErr = GetEntityBase()->GetFunction()->GetPath("runinfo", runInfoPath);
	if (eErr != Error_Succeed) {
		DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("GetOsVersion")("GetPath runinfo error=%d.", eErr);
		return "";
	}
	runInfoPath += "\\runcfg\\osverion";
	ifstream is;
	is.open(runInfoPath.GetData(), ios::binary);
	if (!is.is_open())
	{
		DWORD dwErr = GetLastError();
		DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("GetOsVersion")("open runcfg\\osverion file failed. [%d]", dwErr);
		return "";
	}
	string line;
	while(!is.eof()){
		getline(is, line);
		int start = line.find("版本");
		if (start > 0)
			return CSimpleStringA(line.substr(start + 5, line.length() - start - 7).c_str());
		else
			continue;
	}
	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
}

CSimpleStringA CHealthManagerFSM::GetPathInfo()
{
	CSimpleStringA result("");
	CAutoArray<CSimpleStringA> arrSections, arrKeys;

	CSmartPointer<IConfigInfo> spRootConfig;
	CSmartPointer<IEntityFunction> spEntityFunction = GetEntityBase()->GetFunction();
	spEntityFunction->OpenConfig(Config_Root, spRootConfig);
	ErrorCodeEnum errCode = spRootConfig->ReadAllSections(arrSections);
	if(Error_Succeed != errCode){
		DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("GetPathInfo sections failed.");
		return result;
	}

	if(arrSections.GetCount() == 0){
		DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("Has no section in root.");
		return result;
	}

	for(int i = 0; i < arrSections.GetCount(); ++i)
	{
		if(arrSections[i].Compare("Path") == 0){
			spRootConfig->ReadAllKeys(arrSections[i].GetData(), arrKeys);
			for (int j = 0; j < arrKeys.GetCount(); ++j)
			{
				CSimpleStringA strValue, strMsg;
				spRootConfig->ReadConfigValue(arrSections[i].GetData(), arrKeys[j].GetData(), strValue);
				strMsg = CSimpleStringA::Format("{\"%s\":\"%s\"}", arrKeys[j].GetData(), strValue.GetData());
				result = (j == arrKeys.GetCount() - 1) ? result + strMsg : result + strMsg + ",";
			}
			break;
		}
	}
	return result;
}

#if defined(RVC_OS_WIN)
const char* dmi_string(const dmi_header* dm, BYTE s)
{

	char* bp = (char*)dm;
	size_t i, len;

	if (s == 0)
		return "Not Specified";

	bp += dm->length;
	while (s > 1 && *bp)
	{

		bp += strlen(bp);
		bp++;
		s--;
	}

	if (!*bp)
		return "BAD_INDEX";

	/* ASCII filtering */
	len = strlen(bp);
	for (i = 0; i < len; i++)
		if (bp[i] < 32 || bp[i] == 127)
			bp[i] = '.';

	return bp;
}

void CHealthManagerFSM::QueryComputerInfo()
{
	int ret = 0;
	RawSMBIOSData* Smbios;
	dmi_header* h = NULL;
	int flag = 1;

	ret = GetSystemFirmwareTable('RSMB', 0, 0, 0);
	if (!ret)
	{

		Dbg("Function failed!");
		return;
	}

	DWORD bufsize = ret;
	char* buf = new char[bufsize];
	memset(buf, 0, bufsize);

	ret = GetSystemFirmwareTable('RSMB', 0, buf, bufsize);
	if (!ret)
	{

		Dbg("Function failed!");
		delete[]buf;
		return;
	}

	Smbios = (RawSMBIOSData*)buf;

	BYTE* p = Smbios->SMBIOSTableData;

	if (Smbios->Length != bufsize - 8)
	{

		Dbg("Smbios length error");
		delete[]buf;
		return;
	}

	for (int i = 0; i < Smbios->Length; i++) {
		h = (dmi_header*)p;

		if (h->type == 1)
		{
			m_computerInfo["Manufacturer"] = dmi_string(h, p[0x4]);
			m_computerInfo["ComputerName"] = dmi_string(h, p[0x5]);
			m_computerInfo["ComputerVersion"] = dmi_string(h, p[0x6]);
			m_computerInfo["SerialNumber"] = dmi_string(h, p[0x7]);

			break;
		}
		p += h->length;
		while ((*(WORD*)p) != 0) p++;
		p += 2;
	}
	delete[]buf;
}
#endif //RVC_OS_WIN

DWORD GetDualTime(SYSTEMTIME& t1, SYSTEMTIME& t2)
{
	//assume t2 > t1...
	//oiltest for simple
	int s1, s2;
	s1 = (t1.wMinute * 60 + t1.wSecond) * 1000 + t1.wMilliseconds;
	s2 = (t2.wMinute * 60 + t2.wSecond) * 1000 + t2.wMilliseconds;
	return s2 - s1;
}

void CHealthManagerFSM::ToLogWarnTermAboutInfo()
{
	LOG_FUNCTION();
	bool bTmpEtyNewStart = m_bEntityNewStart;
	if (m_bEntityNewStart)
	{
		SYSTEMTIME shellStartTime;
		ULONGLONG totalCost = 0;
		m_bEntityNewStart = false;
		CAutoArray<CSimpleStringA> strEntityNames;
		CAutoArray<int> strEntityIdx;
		CAutoArray<CEntityStartInfo> Infos;
		ErrorCodeEnum eErr = GetEntityBase()->GetFunction()->GetAllEntityStartInfo(strEntityNames, strEntityIdx, Infos);
		for (int i = 0; i < Infos.GetCount(); ++i)
		{
			if (strEntityIdx[i] == 0)
			{
				shellStartTime = Infos[i].startTime;
				ULONGLONG dwElapseNow = GetTickCount64();
				totalCost = dwElapseNow - m_ullElapseFromOSStart;
				LogWarn(Severity_Low, Error_Debug, LOG_TRACE_ENTITY_START_TIME,
					SP::Module::Util::generateConsumeTimeJson("total", SP::Module::Util::formatTime(shellStartTime).c_str(), totalCost).GetData());
			}				
			LogWarn(Severity_Low, Error_Debug, LOG_TRACE_ENTITY_START_TIME,
					SP::Module::Util::generateConsumeTimeJson(strEntityNames[i], SP::Module::Util::formatTime(Infos[i].startTime).c_str(), GetDualTime(Infos[i].startTime, Infos[i].startEndTime)).GetData());
		}
		
	}
    CSimpleStringA csOSVerion(""), csWarnMsg("");
	std::map<std::string, std::string> termInfo;
	std::map<std::string, std::string> pcInfo;
	termInfo["version"] = m_sysInfo.InstallVersion.ToString();

	if (!m_csErrEntity.IsNullOrEmpty())
	{
		termInfo["ErrEntity"] = m_csErrEntity;

		CSimpleStringA tErr = CSimpleStringA::Format("实体启动失败：%s", m_csErrEntity.SubString(1).GetData());
		DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("auth错误信息为：%s.", tErr.GetData());

		CSimpleStringA tmp;
		GetEntityBase()->GetFunction()->GetSysVar("AuthErrMsg", tmp);//获取当前已保存的报错信息
		
		if (tmp.GetLength() <= 3)
		{
			GetEntityBase()->GetFunction()->SetSysVar("AuthErrMsg", tErr.GetData());//实体启动失败保存到错误页字段
		}

	}
	termInfo["AccessAuth"] = (m_iAccessAuth == AccessAuth_Suc)?"T":"F";//oiltmp modify to init/fail/suc?
	csOSVerion = GetOsVersion();
	if (!csOSVerion.IsNullOrEmpty())
		termInfo["OSVersion"] = csOSVerion;
	pcInfo["TerminalNo"] = m_sysInfo.strTerminalID;//20220704 add by zjw
	pcInfo["MachineType"]  = m_sysInfo.strMachineType;
	pcInfo["MachineVersion"] = CSimpleStringA::Format("%d.%d", m_sysInfo.MachineVersion.GetMajor(), m_sysInfo.MachineVersion.GetMinor());
	pcInfo["Screen"] = CSimpleStringA::Format("%d", m_sysInfo.eScreen);
	pcInfo["Site"]  = m_sysInfo.strSite;
	pcInfo["EnrolGPS"]  = CSimpleStringA::Format("%.3f,%.3f", m_sysInfo.EnrolGPS.GetLongitude(), m_sysInfo.EnrolGPS.GetLatitude());
	pcInfo["EnrolAddr"]  = m_sysInfo.strEnrolAddr;

#if defined(RVC_OS_WIN)
	termInfo["OSType"] = "Windows";
	QueryComputerInfo();
	pcInfo["Manufacturer"] = m_computerInfo["Manufacturer"];
	pcInfo["ComputerName"] = m_computerInfo["ComputerName"];
	pcInfo["ComputerVersion"] = m_computerInfo["ComputerVersion"];
	pcInfo["SerialNumber"] = m_computerInfo["SerialNumber"];
	std::string strOSVersionName, strOSArch;
	CSystemStatus tempStatus;
	tempStatus.GetOsInfo(strOSVersionName, strOSArch);
	if (!strOSArch.empty()) {
		pcInfo["SystemArch"] = strOSArch;
	}
#else
	termInfo["OSType"] = "UOS";
	pcInfo["Manufacturer"] = m_sysInfo.strManufacturer.IsNullOrEmpty() ? "": m_sysInfo.strManufacturer.GetData();
	pcInfo["MachineModel"] = m_sysInfo.strMachineModel.IsNullOrEmpty() ? "" : m_sysInfo.strMachineModel.GetData();
	pcInfo["SN"] = m_sysInfo.strMachineSN.IsNullOrEmpty() ? "" : m_sysInfo.strMachineSN.GetData();
	//???oiltmp
	termInfo["Manufacturer"] = m_sysInfo.strManufacturer.IsNullOrEmpty() ? "" : m_sysInfo.strManufacturer.GetData();
	termInfo["MachineMode"] = m_sysInfo.strMachineModel.IsNullOrEmpty() ? "" : m_sysInfo.strMachineModel.GetData();
	termInfo["MachineSN"] = m_sysInfo.strMachineSN.IsNullOrEmpty() ? "" : m_sysInfo.strMachineSN.GetData();
#endif



	//加载Path节点
	CSimpleStringA pathInfo = GetPathInfo();

	CSmartPointer<IConfigInfo> spConfigRun;
	GetEntityBase()->GetFunction()->OpenConfig(Config_Run, spConfigRun);

	CAutoArray<SP::Module::Net::NetworkAdapterItem> netList;
	SP::Module::Net::GetINETMacAddresses(netList);
	CSimpleStringA csMac(""), csIP("");
    for (int i = 0; i < netList.GetCount(); i++) {
		if (!csMac.IsNullOrEmpty()) {
			csMac += ";";
		}
		csMac += netList[i].mac.c_str();
	}
    for (int i = 0; i < netList.GetCount(); i++) {
		if (!csIP.IsNullOrEmpty()) {
			csIP += ";";
		}
        csIP += netList[i].ip.c_str();
    }

	termInfo["MACs"] = csMac;
	termInfo["IPs"] = csIP;
	char xOSTime[64] = {0};

	char elapseTime[64] = {0};//使用机器启动时间秒数
	ULONGLONG dwElapse = GetTickCountRVC();
	DWORD elapseTimeTemp = dwElapse / 1000;
#if defined(RVC_OS_WIN)
	termInfo["OSTime"] = itoa(m_elapseTimeFromOSStart, xOSTime, 10);
	termInfo["elapseTime"] = itoa(elapseTimeTemp, elapseTime, 10);
#else
	termInfo["OSTime"] = _itoa(m_elapseTimeFromOSStart, xOSTime, 10);
	termInfo["elapseTime"] = _itoa(elapseTimeTemp, elapseTime, 10);
#endif
	
	CSimpleStringA csRunPath("");
	GetEntityBase()->GetFunction()->GetPath("Run", csRunPath);
	termInfo["AppPath"] = csRunPath;

	std::pair<bool, std::string> strResult;
	std::pair<bool, std::string> strPCInfo;
	strResult = generateJsonStr(termInfo);
	strPCInfo = generateJsonStr(pcInfo);

	spConfigRun->ReadConfigValue("Run", "WarnMsg", csWarnMsg);
	DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM)("ToLogWarnTermAboutInfo:[%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
	if (bTmpEtyNewStart)
	{
		LogWarn(Severity_Low, Error_Unexpect, LOG_WARN_HEALTH_UPLOAD_INFO_ABOUT_TERM, strResult.second.c_str());
		LogWarn(Severity_Low, Error_Unexpect, HealthManager_UserErrorCode_First_Info_AboutTerm, strResult.second.c_str());
		LogWarn(Severity_Low, Error_Unexpect, HealthManager_UserErrorCode_First_Info_AboutPC, strPCInfo.second.c_str());
		LogWarn(Severity_Low, Error_Unexpect, HealthManager_UserErrorCode_Upload_PathInfo, pathInfo.GetData());
	}
	else
		LogWarn(Severity_Low, Error_Unexpect, LOG_WARN_HEALTH_UPLOAD_INFO_ABOUT_TERM, strResult.second.c_str());

#if defined(RVC_OS_LINUX)
	/** 上送安装记录信息，包括安装时间，安装耗时时长，使用的安装版本等 [Gifur@2023823]*/
    CSmartPointer<IConfigInfo> pConfig;
	GetEntityBase()->GetFunction()->OpenConfig(Config_Cache, pConfig);
    int stepStatus(0), curStep(0), lastRecordTime(0), beginInstallRecordTime(0);
	CSimpleStringA strInstallVersion(true);
    CSimpleStringA strAdditonalMsg(true);
    pConfig->ReadConfigValueInt("TerminalDeploy", "CurrStep", curStep);

    if (curStep == DeployStep_Finished) {

        pConfig->ReadConfigValueInt("TerminalDeploy", "CurrState", stepStatus);
        pConfig->ReadConfigValueInt("TerminalDeploy", "TimeStamp", lastRecordTime);
		pConfig->ReadConfigValue("TerminalDeploy", "InstallVersion", strInstallVersion);
        pConfig->ReadConfigValue("TerminalDeploy", "LastInfo", strAdditonalMsg);
		pConfig->ReadConfigValueInt("TerminalDeploy", "StartTimeStamp", beginInstallRecordTime);

		const DWORD consumeTick = lastRecordTime - beginInstallRecordTime;

        LogWarn(Severity_High, Error_Debug, LOG_WARN_HEALTH_INSTALL_TIMESTAMP, 
				CSimpleString::Format("{\"begin\":\"%s\",\"finished\":\"%s\", \"consume\":\"%s\", \"step\":%d,\"state\":%d, \"version\":\"%s\", \"msg\":\"%s\"}", 
                                      CSmallDateTime(beginInstallRecordTime).ToTimeString().GetData(),
									  CSmallDateTime(lastRecordTime).ToTimeString().GetData(), 
                                      CSmallDateTime(consumeTick).ToTimeString().GetData(),
									  curStep, stepStatus
									  , strInstallVersion.GetData(), strAdditonalMsg.GetData()));

        pConfig->WriteConfigValueInt("TerminalDeploy", "CurrStep", DeployStep_Begin);
        pConfig->WriteConfigValueInt("TerminalDeploy", "CurrState", DEPLOYSTATE_NOTINIT);
        pConfig->WriteConfigValue("TerminalDeploy", "TimeStamp", CSimpleStringA::Format("0x%08X", (DWORD)CSmallDateTime::GetNow()));
		if (!strAdditonalMsg.IsNullOrEmpty()) {
            pConfig->WriteConfigValue("TerminalDeploy", "LastInfo", NULL);
		}
        pConfig->WriteConfigValue("TerminalDeploy", "StartTimeStamp", NULL);

		do 
		{
            CSmartPointer<IConfigInfo> spConfigRun;
            GetEntityBase()->GetFunction()->OpenConfig(Config_Run, spConfigRun);
			spConfigRun->WriteConfigValue("DeployInfo", "InstallVersion", strInstallVersion);
			spConfigRun->WriteConfigValueInt("DeployInfo", "InstallTimeStamp", lastRecordTime);

		} while (false);
    }
#endif 
}
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 (CSimpleStringA(lpcszEntityName).Compare("SIPPhone", true) == 0)
	{
		GetEntityBase()->GetFunction()->SetSysVar("AuthErrMsg", strErrMsg.GetData());//实体启动失败保存到错误页字段
	}
	
	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
}
void CHealthManagerFSM::ToCallAccessAuthDoWork()
{
	if (!m_bInAccessAuthDoWork)
	{
		DbgWithLink(LOG_LEVEL_INFO,LOG_TYPE_SYSTEM).setAPI("ToCallAccessAuthDoWork")("ToCallAccessAuthDoWork");
		AccessAuthTask* pTask = new AccessAuthTask(this);
		GetEntityBase()->GetFunction()->PostThreadPoolTask(pTask);
	}
}

bool CHealthManagerFSM::IfInUpgradeProcess()
{
	CSimpleStringA csRunCfgPath(""), csFileName("");

	ErrorCodeEnum eErr = GetEntityBase()->GetFunction()->GetPath("RunCfg", csRunCfgPath);
	csFileName = csRunCfgPath + SPLIT_SLASH_STR + "starttime.dat";
	DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("csFileName:%s", csFileName.GetData());
#if defined(RVC_OS_WIN)
	if (_access((const char*)csFileName, 0) == 0) {
#else
	if (access((const char*)csFileName, F_OK) == 0) {
#endif
		DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM).setAPI("IfInUpgradeProcess")("升级切换中");
		return true;
	}
	else
		return false;
}
void CHealthManagerFSM::WaitToCallAccessAuthDoWork()
{
	//WaitForSingleObject
	bool bHaveShowMsg = false;
	while (1)
	{
		CSimpleStringA csHavePath("N");
		GetEntityBase()->GetFunction()->GetSysVar("AccessHavePath", csHavePath);
		if (csHavePath.Compare("Y") == 0 || csHavePath.Compare("E") == 0)
		{
			AccessAuthTask* pTask = new AccessAuthTask(this);
			GetEntityBase()->GetFunction()->PostThreadPoolTask(pTask);
			break;
		}
		else
		{
			Sleep(5000);
			if (m_NewStartPage.IndexOf(m_sysInfo.strMachineType) < 0)
			{
				if (!bHaveShowMsg)
				{
					GetEntityBase()->GetFunction()->ShowStartupInfo("等待准入实体准备好");
					bHaveShowMsg = true;
				}
			}
			else {
				LogWarn(Severity_High, Error_Unexpect, HealthManager_UserErrorCode_WaitForAccessGrayResult, "等待准入实体准备好");
				DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM).setLogCode("QLR0402501Z10301").setResultCode("RTA5107")("等待准入实体准备好");
			}
		}
	}
}
void CHealthManagerFSM::WKUpdatePeriod()
{
	auto pEntity = ((CHealthManagerEntity*)m_pEntity);
	//oilyang@20220413 control update working key by CenterSetting
	if (m_iDoNotUpdateWKDaily == 1)
	{
		// 没有密码键盘 或 集中配置告知无需更新，无需更新
		DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)
			(CSimpleStringA::Format("DoNotUpdateWKDaily:%d, ignore update wk"
				, m_iDoNotUpdateWKDaily));
		return;
	}

	// 检查上次密钥同步时间（一天只同步一次）
	CSmartPointer<IConfigInfo> pConfigRun;
	m_pEntity->GetFunction()->OpenConfig(Config_Run, pConfigRun);

	int nWKLastSyncTime(0);
	pConfigRun->ReadConfigValueInt("Main", "WKSyncSuccTime", nWKLastSyncTime);
	int nWKSyncFailCount(0);
	pConfigRun->ReadConfigValueInt("Main", "WKSyncFailCount", nWKSyncFailCount);

	SYSTEMTIME stSyncTime = CSmallDateTime(nWKLastSyncTime).ToSystemTime();
	DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)
		("last WK sync time: %04d-%02d-%02d %02d:%02d:%02d",
			stSyncTime.wYear, stSyncTime.wMonth, stSyncTime.wDay,
			stSyncTime.wHour, stSyncTime.wMinute, stSyncTime.wSecond);

	SYSTEMTIME stNow = {};
	GetLocalTimeRVC(stNow);
	int lastUpdateDays = sumday(stSyncTime.wYear, stSyncTime.wMonth, stSyncTime.wDay);
	int todayDays = sumday(stNow.wYear, stNow.wMonth, stNow.wDay);
	DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("lastUpdateDays:%d,todayDays:%d,x:%d", lastUpdateDays,todayDays, todayDays-lastUpdateDays);
	//if ((nWKLastSyncTime > 0 && stSyncTime.wYear == stNow.wYear
	//	&& stSyncTime.wMonth == stNow.wMonth && stSyncTime.wDay == stNow.wDay
	//	&& nWKSyncFailCount == 0))	// 最近一次同步成功，才能跳过
	if (todayDays - lastUpdateDays < m_wkUpdatePeriod)
	{
		DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)
			("WK has been updated, last sync time: %s", (const char*)CSmallDateTime(nWKLastSyncTime).ToTimeString());
	}
	else
	{
		//if have exceed the time,we should update working key in the next peroid
		if (todayDays - lastUpdateDays < m_wkUpdatePeriod * 2)
		{
			int xTerm = atoi(m_sysInfo.strTerminalID.SubString(m_sysInfo.strTerminalID.GetLength() - 7, 7));
			if ((todayDays % m_wkUpdatePeriod) != (xTerm % m_wkUpdatePeriod))
			{
				DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("todayDays:%d, xTerm:%d, m_wkUpdatePeriod:%d", todayDays, xTerm, m_wkUpdatePeriod);
				return;
			}
		}
		DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("begin update WK now");
		ErrorCodeEnum eErrCode = Error_Succeed;
		if (m_pACClient == NULL)
		{
			m_pACClient = new AccessAuthService_ClientBase(this->GetEntityBase());
			eErrCode = m_pACClient->Connect();
			if (eErrCode != Error_Succeed) {
				DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("accessauth connected failed.");
				m_pACClient->SafeDelete();
				m_pACClient = NULL;
				m_bInAccessAuthDoWork = false;
				return;
			}
			else {
				DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM).setAPI("WKUpdatePeriod")("accessauth connected.");
			}
		}

		eErrCode = (*m_pACClient)(EntityResource::getLink().upgradeLink())->UpdateWK();
		if(Error_Succeed == eErrCode)
		{
			DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM).setLogCode("QLR0402501Z0001")("accessauth updatewk succ.");
			pConfigRun->WriteConfigValue("Main", "WKSyncSuccTime", 
				(const char*) CSimpleStringA::Format("0x%08X", (DWORD)CSmallDateTime::GetNow()));
			pConfigRun->WriteConfigValueInt("Main", "WKSyncFailCount", 0);

		}
		else
		{
			DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM).setLogCode("QLR0402501Z0001").setResultCode("RTA5110")("accessauth updatewk failed.");
			nWKSyncFailCount++;
			pConfigRun->WriteConfigValueInt("Main", "WKSyncFailCount", nWKSyncFailCount);
		}
	}
}
int CHealthManagerFSM::sumday(int year, int month, int day)
{
	int days[2][13] = { {0,31,59,90,120,151,181,212,243,273,304,334,365},{0,31,60,91,121,152,182,213,244,274,305,335,366} };
	int iLeapYear = 0;
	if ((year % 4 == 0 && year % 100 != 0) || year % 400 == 0)
		iLeapYear = 1;
	int yearday = year * 365 + year / 4 - year / 100 + year / 400;
	int monthday = days[iLeapYear][month - 1];
	return yearday + monthday + day;
}
void CHealthManagerFSM::QueryHardwareInfo(SpReqAnsContext<HealthManagerService_QueryHardwareInfo_Req, HealthManagerService_QueryHardwareInfo_Ans>::Pointer ctx)
{
	CSystemStaticInfo info;
	GetEntityBase()->GetFunction()->GetSystemStaticInfo(info);

	CAutoArray<SP::Module::Net::NetworkAdapterItem> netList;
	SP::Module::Net::GetINETMacAddresses(netList);

	CAutoArray<CSimpleStringA> ipAddrs, macAddrs;
	for (int i = 0; i < netList.GetCount(); i++) {
		CSimpleStringA tmpip = netList[i].ip.c_str();
		CSimpleStringA tmpmac = netList[i].mac.c_str();
		ipAddrs.Append(&tmpip, 0, 1);
		macAddrs.Append(&tmpmac, 0, 1);
	}
	ctx->Ans.ip = ipAddrs;
	ctx->Ans.mac = macAddrs;
	ctx->Ans.machineType = info.strMachineType;
	ctx->Ans.site = info.strSite;
	ctx->Ans.terminalNo = info.strTerminalID;
	ctx->Ans.termLimit = "";
	ctx->Ans.termVersion = info.InstallVersion.ToString();
#if defined(RVC_OS_WIN)
	//oiltmp 备注reserved3、reserved4这是什么情况下用的？看得莫名其妙，在一个常用调用接口里面每次都取，这是不怕亚信？
	//reserved3, 获取windows系统版本
	DWORD dwMajorVer, dwMinorVer, dwBuildNumber;
	BOOL bRet = FALSE;
	HMODULE hModNtdll = NULL;
	if (hModNtdll = ::LoadLibraryW(L"ntdll.dll"))
	{
		typedef void (WINAPI* pfRTLGETNTVERSIONNUMBERS)(DWORD*, DWORD*, DWORD*);
		pfRTLGETNTVERSIONNUMBERS pfRtlGetNtVersionNumbers;
		pfRtlGetNtVersionNumbers = (pfRTLGETNTVERSIONNUMBERS)::GetProcAddress(hModNtdll, "RtlGetNtVersionNumbers");
		if (pfRtlGetNtVersionNumbers)
		{
			pfRtlGetNtVersionNumbers(&dwMajorVer, &dwMinorVer, &dwBuildNumber);
			dwBuildNumber &= 0x0ffff;
			bRet = TRUE;
		}

		::FreeLibrary(hModNtdll);
		hModNtdll = NULL;
	}

	//reserved4
	char buffer[1024];
	sprintf(buffer, "%d.%d.%d", dwMajorVer, dwMinorVer, dwBuildNumber);
	string sysVer = "Windows ver[" + string(buffer) + "]";
	ctx->Ans.reserved3 = CSimpleStringA(sysVer.c_str());

	CSimpleStringA deviceFct("");

	CSmartPointer<IConfigInfo> spConfig;
	GetEntityBase()->GetFunction()->OpenConfig(Config_Root, spConfig);
	spConfig->ReadConfigValue("Device.PinPad", "Vendor", deviceFct);
	ctx->Ans.reserved4 = deviceFct;//oiltmp@20240314 get this for what? the setting have been back saved, no more get from terminal?
#endif //RVC_OS_WIN

	//reserved1
#ifdef DEVOPS_ON_ST /*DevOps流水线编译，ST环境*/
	ctx->Ans.reserved1 = 1;
#elif defined(DEVOPS_ON_UAT)/*DevOps流水线编译，UAT环境*/
	ctx->Ans.reserved1 = 2;
#elif defined(DEVOPS_ON_PRD)/*DevOps流水线编译，PRD环境*/
	ctx->Ans.reserved1 = 3;
#elif defined(DEVOPS_ON_DEV)/*DevOps流水线编译，Dev环境*/
	ctx->Ans.reserved1 = 0;
#else/*本地编译等非DevOps环境编译的版本*/
	ctx->Ans.reserved1 = 0;
#endif	

	//oilyang@20230518 用来标注支持搜狗输入法新旧模式
	ctx->Ans.reserved2 = 0;
	ResourceWatcherService_ClientBase* pClient = new ResourceWatcherService_ClientBase(m_pEntity);
	ErrorCodeEnum ec = pClient->Connect();
	if (IS_SUCCEED(ec)) {
		DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("to Connect ResourceWatcher...");
		ResourceWatcherService_GetThirdPartyInstallState_Req req = {};
		ResourceWatcherService_GetThirdPartyInstallState_Ans ans = {};
		req.mode = 1;
		ec = (*pClient)(EntityResource::getLink().upgradeLink())->GetThirdPartyInstallState(req, ans, 15000);
		if (IS_SUCCEED(ec)) {
			DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("Get Sogou version: %s, %d", ans.version.GetData(), ans.reserverd3);
			DWORD dwUserCode(HealthManager_UserErrorCode_SogouInput_UsingSDK);
			if (ans.reserverd3 == 1) {
				dwUserCode = HealthManager_UserErrorCode_SogouInput_UsingSys;
				ctx->Ans.reserved2 = 1;
			}
			LogWarn(Severity_Low, Error_Debug, dwUserCode,
				CSimpleStringA::Format("{\"version\": %s,\"installTime\": %s}", ans.version.GetData(), ans.reserverd1.GetData()));
		}
		else {
			LogWarn(Severity_Low, ec, HealthManager_UserErrorCode_SogouInput_UsingSDK,
				CSimpleStringA::Format("ResourceWatcher::GetThirdPartyInstallState invoked failed: %s", SpStrError(ec)));
		}
		pClient->GetFunction()->CloseSession();
	}
	else {
		LogWarn(Severity_Low, ec, HealthManager_UserErrorCode_SogouInput_UsingSDK,
			CSimpleStringA::Format("Connet to ResourceWatcher failed: %s", SpStrError(ec)));
		pClient->SafeDelete();
	}

	ctx->Answer(Error_Succeed);
}