myvtm/Module/mod_ResourceWatcher/ResourceWatcherFSM.cpp

#include "stdafx.h"
#include "ResourceWatcherFSM.h"
#include <string.h>
#include <string> 
#include <assert.h>
#include <algorithm>
#include "fileutil.h"
#include "osutil.h"
#include <ctime>
#include "SpUtility.h"
#include "RestfulFunc.h"
#include <stdio.h>
#include <stdlib.h>
#include <vector>
#include "ResourceWatcher_UserCode.h"

#ifdef RVC_OS_LINUX

#include <vector>
#include <dirent.h>
#include <sstream>  
#include <fstream> 
#include <iostream> 
#include "publicFunExport.h"
#include "toolkit.h"
#include "iniutil.h"
#include "osutil.h"
#include <winpr/file.h>

#define PROCESS_ITEM 14 //进程CPU信息读取位置参数
const int MAX_MAINLINK_CHECK_TIME = 5000;
const int TIMER_MAINLINK_CHECK = 4;
#define SECNAME_SFINSTALL "SoftwareInstallDetect%d"
#else

#include <intrin.h>
#include <ShlObj.h>
#include <ShellAPI.h>
#include <Pdh.h>
#include <io.h>
#include <direct.h>
#include "memutil.h"
#include "array.h"
#include <Windows.h>
#include <wintrust.h>  
#include <direct.h>
#include <Mscat.h>
#include <Softpub.h>  
#include <wlanapi.h>
#include <Netlistmgr.h>  //网络检测添加
#include <psapi.h>  
#include <tlhelp32.h>
#include <WtsApi32.h>
#include <sysinfoapi.h>
#include "Mmdeviceapi.h"
#include "Propidl.h"

const int MILLION = 1048576;
#define SECNAME_SFINSTALL "SoftwareInstallDetectWIN%d"
#define ENCODING (X509_ASN_ENCODING | PKCS_7_ASN_ENCODING)
#endif // RVC_OS_LINUX

static int hardwareCheckTime = 60 * 1000;  //初始化硬件检测间隔
static int hardwareCheckFlag = 1;
static int cpuWarnTime = 0;
static int cpuWarnThreshold = 10;
static int memWarnTime = 0;
static int memWarnThreshold = 10;    //初始化CUP、内存告警阈值次数
static int diskCheckTime = 4 * 60 * 60 * 1000; //初始化硬盘检测间隔
static int diskCheckFlag = 1;

#define MAX_SOFTWARE_INSTALLED_DETECT_COUNT 50
#define STARTUP_DIR_FULL_PATH "C:\\ProgramData\\Microsoft\\Windows\\Start Menu\\Programs\\StartUp"
#ifdef DEVOPS_ON_ST /*DevOps流水线编译，ST环境*/
const char* CMB_LINK_FILE_NAME = "招商银行可视柜台（ST测试）.lnk";
#elif defined(DEVOPS_ON_UAT)/*DevOps流水线编译，UAT环境*/
const char* CMB_LINK_FILE_NAME = "招商银行可视柜台（UAT测试）.lnk";
#elif defined(DEVOPS_ON_PRD)/*DevOps流水线编译，PRD环境*/
const char* CMB_LINK_FILE_NAME = "招商银行可视柜台.lnk";
#elif defined(DEVOPS_ON_DEV)/*DevOps流水线编译，Dev环境*/
const char* CMB_LINK_FILE_NAME = "招商银行可视柜台（开发）.lnk";
#else/*本地编译等非DevOps环境编译的版本*/
const char* CMB_LINK_FILE_NAME = "招商银行可视柜台.lnk";
#endif
const char* STRATUP_FILENAME_FROM_SCRIPTS = "spexplorerauto.lnk";

bool cmp(const pair<int, double>& a, const pair<int, double>& b) {
    return a.second > b.second;
}

bool cmpPid(const pair<int, CSimpleStringA>& a, const pair<int, CSimpleStringA>& b) {
    return a.first < b.first;
}

#if defined(RVC_OS_WIN)
//https://blog.csdn.net/aflyeaglenku/article/details/51742820
typedef struct _dmi_header
{
	BYTE type;
	BYTE length;
	WORD handle;
}dmi_header;

typedef struct _RawSMBIOSData
{

	BYTE    Used20CallingMethod;
	BYTE    SMBIOSMajorVersion;
	BYTE    SMBIOSMinorVersion;
	BYTE    DmiRevision;
	DWORD   Length;
	BYTE    SMBIOSTableData[];
}RawSMBIOSData;

void ResourceWatcherFSM::GetAutoStartFile(std::string& userDirPath, std::vector<std::string>& userDirFiles, std::string& pubDirPath, std::vector<std::string>& pubDirFiles)
{
	CSimpleStringA startMenuPublicPath(true);
    GetCommStartupDirectory(startMenuPublicPath);
    if (!startMenuPublicPath.IsNullOrEmpty()) {
		auto arr = fileutil_get_sub_files(startMenuPublicPath);
		pubDirPath = startMenuPublicPath.GetData();
		if (arr != NULL) {
			for (int i = 0; i < arr->nelts; ++i) {
				char* file = ARRAY_IDX(arr, i, char*);
				char* filename = strrchr(file, '\\');
				if (filename != NULL) { filename += 1; }
				else { filename = file; }
				pubDirFiles.push_back(std::string(filename));
			}
			toolkit_array_free2(arr);
		}
    }

    CSimpleStringA startMenuFullPath(true);
    GetUserStartupDirectory(startMenuFullPath);
	if (!startMenuFullPath.IsNullOrEmpty()) {
        auto arr = fileutil_get_sub_files(startMenuFullPath);
		userDirPath = startMenuFullPath.GetData();
		if (arr != NULL) {
			for (int i = 0; i < arr->nelts; ++i) {
				char* file = ARRAY_IDX(arr, i, char*);
				char* filename = strrchr(file, '\\');
				if (filename != NULL) { filename += 1; }
				else { filename = file; }
				userDirFiles.push_back(std::string(filename));
			}
			toolkit_array_free2(arr);
		}
	}
}

#endif //RVC_OS_WIN

struct SetupSoftInfo
{
	std::string displayName;       //软件名称
	std::string publisher;         //发行商
	std::string displayVersion;    //版本
	std::string installDate;       //安装日期
	std::string uninstallString;   //卸载命令及参数
    bool quietFalg;
    bool systemCompoentFalg;
	void Display()
	{
		DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("软件名称:%s|发行商:%s|版本:%s|安装日期:%s|卸载命令:%s|系统组件:%s",displayName.c_str(), publisher.c_str(), displayVersion.c_str(), installDate.c_str(), uninstallString.c_str(), systemCompoentFalg ? "Y":"N");
	}
};

ResourceWatcherFSM::ResourceWatcherFSM(void)
    :m_bFirstRunAfterBoot(FALSE),
    m_cpuTop(0), flag4DeleteKeyAutoStartFile(false), flag4DoAutoStartTaskIgnoreBoot(FALSE), m_skipDesktopDetect(FALSE)
    , m_strLoginedUserName(true)
{
#ifdef RVC_OS_WIN
    m_iNonSignedTotal = 0;
    m_bNeedForceDiskCheck = false;
#endif // RVC_OS_WIN
}

ResourceWatcherFSM::~ResourceWatcherFSM(void)
{
}

void ResourceWatcherFSM::s0_on_entry()
{
#if defined(RVC_OS_WIN)
    this->PostEventFIFO(new RunEvent());
#endif //RVC_OS_WIN
}

unsigned int ResourceWatcherFSM::s0_on_event(FSMEvent* e)
{
    unsigned int unRes = 0;
    switch (e->iEvt)
    {
    case USER_EVT_RUN:
    {
        e->SetHandled();
    }
    break;
    default:
    {
		DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("Unexpecetd Event(%d)", e->iEvt);
    }
    break;
    }
    return unRes;
}

void ResourceWatcherFSM::s0_on_exit()
{

}

void ResourceWatcherFSM::s1_on_entry()
{
}

unsigned int ResourceWatcherFSM::s1_on_event(FSMEvent* e)
{
    unsigned int unRes = 0;
    e->SetHandled();
    return unRes;
}

void ResourceWatcherFSM::s1_on_exit()
{
}


#ifdef RVC_OS_LINUX
bool ResourceWatcherFSM::GetMonitorInfo(CSimpleStringA& outInfo)
{
    std::string sucContent, failedContent;
    CSimpleStringA strCmd("xrandr | grep \" connected\" | sed -e \"s/\([A-Z0-9]\+\) connected.*/\1/\"");
    bool ret = SP::Module::Util::ShellExecute(strCmd.GetData(), sucContent, failedContent);
    //DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("{%s}:{%s}{%s}", strCmd.GetData(), sucContent.c_str(), failedContent.c_str());
    std::string msg = SP::Utility::ToTrim(sucContent);
    SP::Utility::replaceInPlace(msg, "\n", "|");
    outInfo = msg.c_str();
    return ret;
}

bool ResourceWatcherFSM::GetSysActiveStatus(CSimpleStringA& outInfo)
{
    std::string sucContent, failedContent;
    CSimpleStringA strCmd("uos-activator-cmd -q");
    bool ret = SP::Module::Util::ShellExecute(strCmd.GetData(), sucContent, failedContent);
    std::string msg = SP::Utility::ToTrim(sucContent);
    SP::Utility::replaceInPlace(msg, "\n", "|");
    outInfo = msg.c_str();
    return ret;
}

#endif // RVC_OS_LINUX

//首页状态变化时触发的功能
void ResourceWatcherFSM::TriggerAtStatusChanged(bool bMStatus)
{
    if (neverMainPage)//首次进入首页
    {
        neverMainPage = false;

        CSmartPointer<IConfigInfo> spRunConfig;
        CSmartPointer<IConfigInfo> spCtSettingConfig;
        GetEntityBase()->GetFunction()->OpenConfig(Config_Run, spRunConfig);
        GetEntityBase()->GetFunction()->OpenConfig(Config_CenterSetting, spCtSettingConfig);
        spCtSettingConfig->ReadConfigValueInt(m_pEntity->GetEntityName(), "VerifySignature", m_iVerify);
#if defined(RVC_OS_WIN)
		if (m_iVerify == 1) {//文件签名校验
			DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("Verify digitsign...");
			VerifyDigitSignTask* task = new VerifyDigitSignTask(this);
			GetEntityBase()->GetFunction()->PostThreadPoolTask(task);
		}
        
#endif //RVC_OS_WIN
        
        if (!forceFileOpt) //默认情况下，进入首页才进行文件相关操作功能：版本删除、占用扫描等
        {
            spCtSettingConfig->ReadConfigValueInt("ResourceWatcher", "DiskCheckTime", diskCheckTime);
            spCtSettingConfig->ReadConfigValueInt("ResourceWatcher", "DiskCheckFlag", diskCheckFlag);
            spCtSettingConfig->ReadConfigValueInt("ResourceWatcher", "HardDiskTooHighPercent", m_diskHighPercent);

            if (diskCheckTime <= 0) {
                diskCheckTime = DEFAULT_DISK_CHECK_TIME;
            }
            
            //终端清理逻辑
            DiskAndFilesTask* deleteAndFilesTask = new DiskAndFilesTask(this);
            deleteAndFilesTask->flag = diskCheckFlag;
            deleteAndFilesTask->checkTime = diskCheckTime;
            GetEntityBase()->GetFunction()->PostThreadPoolTask(deleteAndFilesTask);
        }

        if (m_bFirstRunAfterBoot) {
#if defined(RVC_OS_LINUX)
            UINT sysVer = 0;
            UploadSysVersionInfo(sysVer);
            ConfirmWindowEffectHasBeenOpen();
            DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("fetch os version: %u", sysVer);
            if (1031 < sysVer) {
                ConfirmDDEClipboardDisable();
                ConfirmNotificationCenterDisable();
            }
            else {
                RecoverDDEClipboardEnable();
            }
#endif //RVC_OS_LINUX
            AlarmSystemBasicInfo();
            GetEntityBase()->GetFunction()->PostThreadPoolTask(new DetectSoftwareInstallStatusTask(this));
        }
    }
}

void ResourceWatcherFSM::TriggerProccessUpload()
{
    CSmartPointer<IConfigInfo> spCtSettingConfig;
    GetEntityBase()->GetFunction()->OpenConfig(Config_CenterSetting, spCtSettingConfig);
    int CloseUploadSysProcFlag = 0; //关闭进程信息上送标志
    spCtSettingConfig->ReadConfigValueInt(m_pEntity->GetEntityName(), "CloseUploadSysProcFlag", CloseUploadSysProcFlag);
    if (CloseUploadSysProcFlag != 1) {
        UploadSysProcInfoTask* uploadProcInfo = new UploadSysProcInfoTask(this);
        GetEntityBase()->GetFunction()->PostThreadPoolTask(uploadProcInfo);
    }
}

void ResourceWatcherFSM::TriggerFileListUpload()
{
    CSmartPointer<IConfigInfo> spCtSettingConfig;
    GetEntityBase()->GetFunction()->OpenConfig(Config_CenterSetting, spCtSettingConfig);
    //集中配置读取需要上送的路径
    CSimpleStringA fileListPath("");
    spCtSettingConfig->ReadConfigValue(m_pEntity->GetEntityName(), "DirPathToUploadFileList", fileListPath);
    if (!fileListPath.IsNullOrEmpty())
    {
        m_fileListPath = fileListPath.Split('|');
        UploadDirPathFileListTask* uploadFileListTask = new UploadDirPathFileListTask(this);
        GetEntityBase()->GetFunction()->PostThreadPoolTask(uploadFileListTask);
    }
}

ErrorCodeEnum ResourceWatcherFSM::OnInit()
{
    neverMainPage = true;		//是否未进入过首页

    ErrorCodeEnum erroCode = Error_Succeed;
    DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("Complied at: %s %s", __DATE__, __TIME__);
    CSmartPointer<IConfigInfo> spRunConfig;
    CSmartPointer<IConfigInfo> spCtSettingConfig;
    GetEntityBase()->GetFunction()->OpenConfig(Config_Run, spRunConfig);
    GetEntityBase()->GetFunction()->OpenConfig(Config_CenterSetting, spCtSettingConfig);
    erroCode = GetEntityBase()->GetFunction()->GetSystemStaticInfo(m_RvcSysinfo);
    m_bFirstRunAfterBoot = DetectIsFirstRunAtBoot();
    if (m_bFirstRunAfterBoot) {
        DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("First time to run after system boot.");
    }
    spCtSettingConfig->ReadConfigValueInt(m_pEntity->GetEntityName(), "DisplayCnt", m_iNonSignedDisplay);
    if (m_iNonSignedDisplay <= 0)
        m_iNonSignedDisplay = 10;
    int nValue(0);
    spCtSettingConfig->ReadConfigValueInt(m_pEntity->GetEntityName(), "DoAutoStartTaskFlag", nValue);
    if (!!nValue) {
        flag4DoAutoStartTaskIgnoreBoot = TRUE;
    }
    nValue = 0;
    spCtSettingConfig->ReadConfigValueInt(m_pEntity->GetEntityName(), "SkipDetectDesktopIcon", nValue);
    if (!!nValue) {
        m_skipDesktopDetect = TRUE;
    }
    spRunConfig->ReadConfigValueInt("WarnRecord", "disk", m_diskLastWarnHour);

    return Error_Succeed;
}

ErrorCodeEnum ResourceWatcherFSM::OnExit()
{
#ifdef RVC_OS_LINUX
    GetEntityBase()->GetFunction()->KillTimer(TIMER_HARDWARE_CHECK);
#endif // RVC_OS_LINUX
    return Error_Succeed;
}

void ResourceWatcherFSM::AfterInit()
{
    //实体启动成功后执行的功能
    CSmartPointer<IConfigInfo> spCtSettingConfig;
    GetEntityBase()->GetFunction()->OpenConfig(Config_CenterSetting, spCtSettingConfig);
    spCtSettingConfig->ReadConfigValueInt("ResourceWatcher", "ForceFileOpt", forceFileOpt);
    if (forceFileOpt)//如配置了文件操作的强制处理，则实体启动后就开始文件操作，无需进入首页. 注意：包含版本清理！！
    {
        spCtSettingConfig->ReadConfigValueInt("ResourceWatcher", "DiskCheckTime", diskCheckTime);
        spCtSettingConfig->ReadConfigValueInt("ResourceWatcher", "DiskCheckFlag", diskCheckFlag);
        spCtSettingConfig->ReadConfigValueInt("ResourceWatcher", "HardDiskTooHighPercent", m_diskHighPercent);

        if (diskCheckTime <= 0) {
            diskCheckTime = DEFAULT_DISK_CHECK_TIME;
        }

        //终端清理逻辑
        DiskAndFilesTask* deleteAndFilesTask = new DiskAndFilesTask(this);
        deleteAndFilesTask->flag = diskCheckFlag;
        deleteAndFilesTask->checkTime = diskCheckTime;
        GetEntityBase()->GetFunction()->PostThreadPoolTask(deleteAndFilesTask);
    }

    spCtSettingConfig->ReadConfigValueInt("ResourceWatcher", "HardwareCheckTime", hardwareCheckTime);
    spCtSettingConfig->ReadConfigValueInt("ResourceWatcher", "HardwareCheckFlag", hardwareCheckFlag);
    spCtSettingConfig->ReadConfigValueInt("ResourceWatcher", "CpuTooHighPercent", m_cpuHighPercent);
    spCtSettingConfig->ReadConfigValueInt("ResourceWatcher", "CpuWarnThreshold", cpuWarnThreshold);
    spCtSettingConfig->ReadConfigValueInt("ResourceWatcher", "MemoryTooHighPercent", m_memHighPercent);
    spCtSettingConfig->ReadConfigValueInt("ResourceWatcher", "MemWarnThreshold", memWarnThreshold);
    if (hardwareCheckFlag)
    {
        if (hardwareCheckTime <= 0) { //非法数值情况下设置为默认一分钟
            hardwareCheckTime = DEFAULT_HARDWARE_CHECK_TIME;
        }

        void* pTmpData = NULL;
        ITimerListener* pListener = new TimerOutHelper<ResourceWatcherFSM>(this, &ResourceWatcherFSM::HardwareInfoTimer, pTmpData);
        GetEntityBase()->GetFunction()->SetTimer(TIMER_HARDWARE_CHECK, pListener, hardwareCheckTime);
        DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("Set Hardware Timer!");
    }

#if defined(RVC_OS_WIN)
    InitUserInfo();
    if (m_bFirstRunAfterBoot || flag4DoAutoStartTaskIgnoreBoot) {
        InitCustomAutoStartFileSheet();
        AggerateAutoStatTask* task = new AggerateAutoStatTask(this);
		GetEntityBase()->GetFunction()->PostThreadPoolTask(task);
    }
	DetectVersionHasChangedAndWarnCover();
#else
	if (m_bFirstRunAfterBoot) {
		AggerateAutoStatTask* task = new AggerateAutoStatTask(this);
		GetEntityBase()->GetFunction()->PostThreadPoolTask(task);
	}
#endif //RVC_OS_WIN
}

void ResourceWatcherFSM::LinkDetect(int detectType, const char* url, bool& status, unsigned int& delay, int warnFlag)
{
    string tUrl = url;
    string host = "http://";

    int flag = 0;
    unsigned int tInterval = 0;

    string msg;
    if (tUrl.find("http") == string::npos) {
        tUrl = host + tUrl;
    }
    DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("Check url:[%s].", tUrl.c_str());
    ULLINT begin, end;
    begin = SP::Module::Comm::RVCGetTickCount();
    int curFlag = HttpProbe(tUrl, msg, 5);
    end = SP::Module::Comm::RVCGetTickCount();
    tInterval = end - begin;

    if (curFlag > 0 && curFlag < 400) {
        flag = true;
    }
    else {
        flag = false;
    }

    if (flag == false) {
        status = false;
    }
    else {
        status = true;
    }

    delay = tInterval > 0 ? tInterval:1;
}

ErrorCodeEnum ResourceWatcherFSM::BizLinkDetect(
    SpReqAnsContext<ResourceWatcherService_BizLinkDetect_Req, ResourceWatcherService_BizLinkDetect_Ans>::Pointer ctx)
{
    LOG_FUNCTION();
    ErrorCodeEnum ec = Error_Succeed;

    int detectType = ctx->Req.protocol;
    CSimpleStringA url = ctx->Req.bizLink;
    bool linkStatus = false;
    unsigned int delay = 0;

    LinkDetect(detectType, url.GetData(), linkStatus, delay);

    ctx->Ans.bizLinkStatus = linkStatus;
    ctx->Ans.bizLinkDelayMS = delay;
    ctx->Ans.intParam = 0;

    CSimpleStringA warn;
    if (!linkStatus) {
        warn = CSimpleStringA::Format("BizLink disconnected[%s].", url.GetData());
    }
    else
    {
        warn = CSimpleStringA::Format("BizLink connected[%s], Delay time [%d]ms.", url.GetData(), delay);
    }
    LogWarn(Severity_Low, Error_Param, LOG_WARN_BIZLINK_CONNECT_CHECK, warn.GetData());
    if (ctx != NULL) {
        ctx->Answer(ec);
    }
    return ec;

}

int ResourceWatcherFSM::ExpandDir(LPCTSTR macorStr, CSimpleStringA& outDir)
{
    const int len = macorStr == NULL ? 0 : strlen(macorStr);
    if (len == 0) {
        return -1;
    }
    if (len < strlen("$(1)") /*最小的长度*/) {
        return -1;
    }
    CSimpleStringA strOrigin(macorStr);
    int end = 0;
    if (!(strOrigin.IsStartWith("$(") && (end = strOrigin.IndexOf(")")) >= 3)) {
        return -1;
    }
    for (int i = strlen("$("); i < end; ++i) {
        if (!((strOrigin[i] >= 'a' && strOrigin[i] <= 'z') || (strOrigin[i] >= 'A' && strOrigin[i] <= 'Z'))) {
            return -1;
        }
    }

	char macroInnerStr[MAX_PATH] = { 0 };
	int nIndex = 0;
	bool bUtilMeetMacroMark = false;
	const char* pStr = macorStr;
    int startIndex = 0;
	for (; *pStr != '\0'; pStr++, startIndex++)
	{
		if (!bUtilMeetMacroMark)
		{
			if (*pStr == '$' && *(pStr + 1) == '(')
			{
				pStr++;
                startIndex++;
				bUtilMeetMacroMark = true;
			}
		}
		else
		{
			if (*pStr == ')')
			{
                startIndex++;
				break;
			}
			macroInnerStr[nIndex++] = *pStr;
		}
	}
    LOG_ASSERT(nIndex != 0);
	ErrorCodeEnum erroCode = GetEntityBase()->GetFunction()->GetPath(macroInnerStr, outDir);
	if (erroCode != Error_Succeed) {
		DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("Get original path of $(%s) failed with error 0x%x", macorStr, erroCode);
		return -2;
	}
	return startIndex;
}

//通过集中配置额外执行的清理策略
void ResourceWatcherFSM::CenterSettingDelete()
{
    CSmartPointer<IConfigInfo> spCtSettingConfig;
    GetEntityBase()->GetFunction()->OpenConfig(Config_CenterSetting, spCtSettingConfig);
    CSimpleStringA tempPath("");
    int closeRmDir = 0, backDay = 0;
    spCtSettingConfig->ReadConfigValue("ResourceWatcher", "DocumentCleanPath", tempPath);
    spCtSettingConfig->ReadConfigValueInt("ResourceWatcher", "DocumentCleanCloseRmDir", closeRmDir);
    spCtSettingConfig->ReadConfigValueInt("ResourceWatcher", "DocumentCleanBackDay", backDay);

    if (tempPath.GetLength() == 0) {
        return;
    }
    CSimpleStringA implePath(true);
    int nIndex(0);
    if (tempPath.IsStartWith("$(") && (nIndex = ExpandDir(tempPath.GetData(), implePath)) > 0) {
        CSimpleStringA newPath(implePath);
        if (nIndex < tempPath.GetLength()) {
            newPath += tempPath.SubString(nIndex);
        }
        tempPath = newPath;
        DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("innner:[%s]", tempPath.GetData());
    }

    ErrorCodeEnum erroCode = Error_Succeed;
    CSmartPointer<IEntityFunction> pFunc = GetEntityBase()->GetFunction();
    bool bFailFlag = false;

    //执行清理逻辑
    const bool delDir = (closeRmDir == 0) ? true : false;
    DeleteResult delResult;
    DeleteParam delParam(tempPath.GetData());
	delParam.saveBackDay = backDay;
    delParam.SetRmDirFlag(delDir);
    delParam.rtaCode = "RTA5A14";
    const int nFileCount = ProcessFileDelete(delParam, delResult);
    DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("Process result(%s): count(%d), suc(%d), failed(%d).", tempPath.GetData(), nFileCount, delResult.sucCnt, delResult.failCnt);
    if (delResult.failCnt != 0) {
        bFailFlag = true;
    }
    else if(delResult.sucCnt > 0){
		LogWarn(Severity_Low, Error_Debug, LOG_WARN_FILE_DELETE_SUC, CSimpleStringA::Format("Delete files in [%s] success", tempPath.GetData()));
    }
}

time_t ResourceWatcherFSM::GetPathTimeSeconds(const char* inPath)
{
    if (!inPath)
    {
        DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("GetPathFileDays PATH = NULL.", inPath);
        return 0;
    }

    time_t lCreateTime = 0;

#ifdef RVC_OS_WIN
    struct _finddata_t fileinfo;//文件信息读取结构
    string p;
    long hFile = _findfirst(inPath, &fileinfo);
    if (hFile == -1L)
    {
        DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("Get [%s] fileinfo failed. GLE = %u.", inPath, GetLastError());
        return 0;
    }
    
    lCreateTime = fileinfo.time_write; //文件最后修改时间
    _findclose(hFile);
#else
    struct stat stFile;
    if (stat(inPath, &stFile) == -1)
    {
        DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("[%s] Failed to get file stats. GLE=%d.", inPath, GetLastError());
        return 0;
    }

    lCreateTime = stFile.st_mtime; //文件状态最后修改时间
#endif // RVC_OS_WIN

    //reTimes = lCreateTime; //文件时间
    return lCreateTime;

}

//所有文件删除功能都用这个函数来处理 
int ResourceWatcherFSM::ProcessFileDelete(const DeleteParam& delParam, DeleteResult& delResult)
{
    int fileCnt = 0;

    DWORD attrs = GetFileAttributesA(delParam.path);
    if (attrs == INVALID_FILE_ATTRIBUTES)
    {
        const DWORD lastError = GetLastError();
        if (lastError != 2) /*NOT Found*/
        {
			CSimpleStringA errMsg = CSimpleStringA::Format("Can not find path：[%s], GLE = %u.", delParam.path.GetData(), lastError);
			DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM).setLogCode(delParam.logCode).setResultCode(delParam.rtaCode).setAPI("DeleteFiles")(errMsg.GetData());
			LogWarn(Severity_Middle, Error_Debug, LOG_WARN_FILE_DELETE_FAILED, errMsg);
			delResult.failCnt++;
        }
    }
    else if (attrs & FILE_ATTRIBUTE_DIRECTORY) //文件夹类型
    {
        if (delParam.delDirFlag) //若要删除目录，则不保留任何文件
        {
            bool deleteDir = RemoveDirRecursiveA(delParam.path);
            if (!deleteDir)
            {
                CSimpleStringA errMsg = CSimpleStringA::Format("RemoveDir [%s] failed, GLE = %u.", delParam.path.GetData(), GetLastError());
                DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM).setLogCode(delParam.logCode).setResultCode(delParam.rtaCode).setAPI("DeleteFiles")(errMsg.GetData());
                LogWarn(Severity_Middle, Error_Debug, LOG_WARN_FILE_DELETE_FAILED, errMsg.GetData());
                delResult.failCnt++;
            }
            else
            {
                DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM).setLogCode(delParam.logCode)("Remove directory(%s) succ.", delParam.path.GetData());
                delResult.sucCnt++;
                fileCnt++;
            }
            return fileCnt;
        }

        array_header_t* arr;
        arr = fileutil_get_sub_dirs_a(delParam.path.GetData());
        if (arr)
        {
            int i;
            for (i = 0; i < arr->nelts; ++i)//子目录
            {
                char* tmp = ARRAY_IDX(arr, i, char*);
                bool delSubDir = true; //默认移除子目录
                if (delParam.saveBackDay != 0)
                {
                    //读取路径时间
                    time_t lSystemTime;
                    time(&lSystemTime);

                    time_t fileTime = GetPathTimeSeconds(tmp); //获取路径的最后改动时间
                    const int delDays = (lSystemTime - fileTime) / SECONDS_OF_DAY;
                    if (delDays <= delParam.saveBackDay) //未达需要清理的天数阈值，保留目录
                    {
                        delSubDir = false;
                        DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("[%s]存留天数[%d], 删除阈值[%u], 保留目录.", tmp, (int)delDays, delParam.saveBackDay);
                    }
                }
                DeleteParam subDelParam(delParam);
                subDelParam.path = tmp;
                subDelParam.SetRmDirFlag(delSubDir);
                fileCnt += ProcessFileDelete(subDelParam, delResult); //子目录递归处理
            }
            toolkit_array_free2(arr);
        }

        arr = fileutil_get_sub_files_a(delParam.path); //子文件
        if (arr) {
            int i;
            for (i = 0; i < arr->nelts; ++i) {
                char* tmp = ARRAY_IDX(arr, i, char*);
				DeleteParam subDelParam(delParam);
				subDelParam.path = tmp;
                fileCnt += ProcessFileDelete(subDelParam, delResult); //子目录递归处理
            }
            toolkit_array_free2(arr);
        }
    }
    else //文件类型
    {
        if (delParam.saveBackDay != 0)
        {
            //读取文件时间
            time_t lSystemTime;
            time(&lSystemTime);

            time_t fileTime = GetPathTimeSeconds(delParam.path); //获取文件的最后改动时间
            const int delDays = (lSystemTime - fileTime) / SECONDS_OF_DAY;
            if (delDays < delParam.saveBackDay) // 未达到需要清理的天数阈值，无需清理
            {
                DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("[%s]存留天数[%d], 删除阈值[%u],无需清理.", delParam.path.GetData(), delDays, delParam.saveBackDay);
                return fileCnt;
            }
        }

        if (RemoveFileA(delParam.path) == true)
        {
            DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM).setLogCode(delParam.logCode)("Remove file(%s) succ.", delParam.path.GetData());
            delResult.sucCnt++;
            fileCnt++;
        }
        else
        {
            delResult.failCnt++;
            CSimpleStringA errMsg = CSimpleStringA::Format("RemoveFileA [%s] failed, GLE = %u.", delParam.path.GetData(), GetLastError());
            DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM).setLogCode(delParam.logCode).setResultCode(delParam.rtaCode.GetData()).setAPI("DeleteFiles")(errMsg.GetData());
            LogWarn(Severity_Middle, Error_Debug, LOG_WARN_FILE_DELETE_FAILED, errMsg.GetData());
        }
    }
    return fileCnt;
}

//终端默认执行的终端清理策略
void ResourceWatcherFSM::AutoDeleteFiles()
{
    CSmartPointer<IEntityFunction> pFunc = GetEntityBase()->GetFunction();
    CSmartPointer<IConfigInfo> spConfig;
    pFunc->OpenConfig(Config_CenterSetting, spConfig);

    //判断是否升级完毕，未完成升级不进行删除任务
    CSimpleStringA strRunCfg, strStartTime;
    if (m_pEntity->GetFunction()->GetPath("RunCfg", strRunCfg) == Error_Succeed) {
        strStartTime = strRunCfg + SPLIT_SLASH_STR + "starttime.dat";
        if (!ExistsFileA(strStartTime.GetData())) {
            DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("upgrade prpcess done, try to delete version files.");//完成升级过程，通过
        }
        else
        {
            DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("upgrade process is not end ,should not delete files.");
            return;//升级未完成，不进行删除
        }
    }
    else
    {
        DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("upgrade process is not end ,get runinfo path error, should not version files.");
        return;//失败,继续等待
    }

    //清理版本相关文件
    DeleteVersionPackage(); 
    //清理录像文件
    DeleteVideoFiles();

    return;

}

//终端升级后会执行版本清理功能
BOOL ResourceWatcherFSM::DeleteVersionPackage()
{
    ErrorCodeEnum erroCode = Error_Succeed;
    CSmartPointer<IEntityFunction> pFunc = GetEntityBase()->GetFunction();
    CSmartPointer<IConfigInfo> spConfig;
    pFunc->OpenConfig(Config_CenterSetting, spConfig);
    CSystemStaticInfo info;
    if (pFunc->GetSystemStaticInfo(info) != Error_Succeed) {
        DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("Get system static info error");
        return FALSE;
    }

    //--------------------------------------------------------------------------------------------
    //清理ver文件夹
    int closeVerClear = 0;
    spConfig->ReadConfigValueInt("ResourceWatcher", "CloseVerClear", closeVerClear);
    if (!closeVerClear)
    {
        int verSaved = DEFAULT_VERSION_SAVED_COUNT;
        int tmpSaved = 0;
        vector<CVersion> intallInfoVects;
        vector<CVersion> loaclVerInfo;
        vector<string> files;

        spConfig->ReadConfigValueInt("ResourceWatcher", "VerSaveCnt", tmpSaved);
        if (tmpSaved > 0) //非法数值时，保留默认值（5）个版本
        {
            verSaved = tmpSaved;
        }

        //获取当前目录下的文件夹名称, 将符合命名规则的终端版本名称push_back
        CSimpleStringA csPath, verPath;
        ErrorCodeEnum Error = m_pEntity->GetFunction()->GetPath("RootVer", csPath);   //获取当前版本路劲 例如：C:\Run
        if (Error_Succeed == Error) {
            if (csPath.IsNullOrEmpty()) {
                DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("get currVer path is null");
                return FALSE;
            }
            else
            {
                verPath = csPath; //csPath在后面被用了，还需要个存储version路径变量
                DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("CUR VERSION PATH = %s.", csPath.GetData());
            }
        }
        else
        {
            DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("get Ver path error = %u.", Error);
            return FALSE;
        }

        //判断哪些是版本文件夹
#ifdef RVC_OS_LINUX
        DIR* dp;
        struct dirent* dirp;
        //过滤非目标版本文件夹
        if ((dp = opendir(csPath.GetData())) != NULL) {
            while ((dirp = readdir(dp)) != NULL) {
                //files.push_back(string(dirp->d_name));
                CInstallInfo verInfo = {};
                DWORD dwMajor(0), dwMinor(0), dwRevision(0), dwBuild(0);
                int n = sscanf(dirp->d_name, "%d.%d.%d.%d", &dwMajor, &dwMinor, &dwRevision, &dwBuild);
                if (n != 4)
                {
                    DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("Not target version file.[%s]", dirp->d_name);
                    continue;
                }
                else {
                    CVersion verName(dwMajor, dwMinor, dwRevision, dwBuild);
                    if (verName.IsValid())
                    {
                        loaclVerInfo.push_back(verName);
                    }
                    if (verName.IsValid() && verName < info.InstallVersion)   //对高于自身版本的文件不予删除
                    {
                        intallInfoVects.push_back(verName);
                    }
                    else {
                        DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("Not target version file.[%s]", dirp->d_name);
                    }
                }
            }
            closedir(dp);
        }
#else
        long hFile = 0;
        struct _finddata_t fileinfo;//文件信息读取结构
        string p;

        if ((hFile = _findfirst(p.assign(string(csPath.GetData())).append("\\*").c_str(), &fileinfo)) != -1) {
            do {
                CInstallInfo verInfo = {};
                DWORD dwMajor(0), dwMinor(0), dwRevision(0), dwBuild(0);
                int n = sscanf(fileinfo.name, "%d.%d.%d.%d", &dwMajor, &dwMinor, &dwRevision, &dwBuild);
                if (n != 4)
                {
                    DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("Not target version file.[%s]", fileinfo.name);
                    continue;
                }
                else {
                    CVersion verName(dwMajor, dwMinor, dwRevision, dwBuild);
                    if (verName.IsValid())
                    {
                        loaclVerInfo.push_back(verName);
                    }

                    if (verName.IsValid() && verName < info.InstallVersion)
                    {
                        intallInfoVects.push_back(verName);
                    }
                    else {
                        DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("Not target version file.[%s]", fileinfo.name);
                    }
                }
            } while (_findnext(hFile, &fileinfo) == 0);
            _findclose(hFile);
        }
#endif // RVC_OS_LINUX

        int nPackCount = intallInfoVects.size();
        DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("Install Package's count: %d", nPackCount);
        bool bFailFlag = false;
        int nDelVersionCnt = 0;
        std::string tInfo(""), curVerInfo("");

        //统计本地版本
        if (loaclVerInfo.size() > 0)
        {
            sort(loaclVerInfo.begin(), loaclVerInfo.end());
            vector<CVersion>::reverse_iterator riter = loaclVerInfo.rbegin();
            while (riter != loaclVerInfo.rend()) {
                curVerInfo = curVerInfo + "|" + std::string((*riter).ToString().GetData());
                riter++;
            }
        }
        std::string verWarn = "本地留存版本: " + curVerInfo + "；当前版本：" + string(info.InstallVersion.ToString().GetData()) + "。";
        LogWarn(Severity_Low, Error_Debug, LOG_INFO_LOCAL_VERSION, verWarn.c_str());

        //执行版本删除流程
        if (nPackCount != 0) {
            int nSavedCount = 0;
            sort(intallInfoVects.begin(), intallInfoVects.end());
            vector<CVersion>::reverse_iterator riter = intallInfoVects.rbegin();
            while (riter != intallInfoVects.rend()) {
                DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("InstallPackage Info: %s", (LPCTSTR)(*riter).ToString());
                if (++nSavedCount <= verSaved) {
                    DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("Save above version");
                    riter++;
                    continue;
                }

                CSimpleStringA tVerPath;
                DeleteResult delResult;
                int nFileCount = 0;
                tVerPath = verPath + SPLIT_SLASH_STR + (*riter).ToString();
                DeleteParam delParam(tVerPath.GetData());
                delParam.rtaCode = "RTA5A12";
                delParam.SetRmDirFlag();//版本文件夹连目录一起清理
                nFileCount = ProcessFileDelete(delParam, delResult); 
				DbgWithLink(delResult.failCnt > 0 ? LOG_LEVEL_WARN : LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("Delete Version result(%s): count(%d), suc(%d), failed(%d).",
					tVerPath.GetData(), nFileCount, delResult.sucCnt, delResult.failCnt);
                if (delResult.failCnt > 0)
                {
                    bFailFlag = true;
                }
                else
                {
                    nDelVersionCnt++;
                    tInfo = tInfo + "|" + std::string((*riter).ToString().GetData());
                }
                riter++;
            }
        }

        if (nDelVersionCnt > 0) {
            std::string warn = "Delete Vesion file count : " + std::to_string((long long)nDelVersionCnt) + ".  ----- " + tInfo + ".";
            LogWarn(Severity_Low, Error_Debug, LOG_WARN_VER_DELETE, CSimpleStringA::Format("%s", warn.c_str()));
        }
    }
    return TRUE;
}

void ResourceWatcherFSM::DeleteVideoFiles()
{
    int backDays = 0, closeVideoClear = 0;
    CSmartPointer<IEntityFunction> pFunc = GetEntityBase()->GetFunction();
    CSmartPointer<IConfigInfo> spConfig;
    pFunc->OpenConfig(Config_CenterSetting, spConfig);
    spConfig->ReadConfigValueInt("ResourceWatcher", "CloseVideoClear", closeVideoClear);
    if (closeVideoClear)
    {
        DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("CenterSetting no need video clear.");
        return;
    }

    spConfig->ReadConfigValueInt("ResourceWatcher", "VideoBackDays", backDays);
    if (backDays <= 0)
    {
        DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("video default backdays：30 days.");
        backDays = VIDEO_DEFAULT_BACKDAYS;
    }

    CSimpleStringA videoPath, verPath;
    ErrorCodeEnum Error = m_pEntity->GetFunction()->GetPath("LocalVideo", videoPath);   //获取Video路径
    if (Error_Succeed == Error) {
        if (videoPath.IsNullOrEmpty()) {
            DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("get LocalVideo path NULL");
            return;
        }
        else
        {
            DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("VIDEO PATH = %s.", videoPath.GetData());
        }
    }
    else
    {
        DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("get LocalVideo error. error = %u.", Error);
        return;
    }
    DeleteResult delResult;
    DeleteParam delParam(videoPath.GetData());
    delParam.rtaCode = "RTA5A13";
    delParam.saveBackDay = backDays;
    const int nFileCount = ProcessFileDelete(delParam, delResult);
	DbgWithLink(delResult.failCnt > 0 ? LOG_LEVEL_WARN : LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("Delete [Video] result(%s): count(%d), suc(%d), failed(%d).", videoPath.GetData(), nFileCount, delResult.sucCnt, delResult.failCnt);
}

void ResourceWatcherFSM::SelfTest(EntityTestEnum eTestType,
    CSmartPointer<ITransactionContext> pTransactionContext)
{
    if (Test_ShakeHand == eTestType) 
    {
        pTransactionContext->SendAnswer(Error_Succeed);
    }
}

void ResourceWatcherFSM::HardwareInfoTimer(void* pData)
{
    GetSystemCPUStatus();
    GetSystemMemoryStatus();

    GetEntityBase()->GetFunction()->ResetTimer(TIMER_HARDWARE_CHECK, hardwareCheckTime);
}

void ResourceWatcherFSM::DiskCheckTimer(void* pData)
{
    GetSystemDiskStatus();
    GetEntityBase()->GetFunction()->ResetTimer(TIMER_DISK_CHECK, diskCheckTime);
}

ErrorCodeEnum ResourceWatcherFSM::CheckNetType(
    SpReqAnsContext<ResourceWatcherService_CheckNetType_Req, ResourceWatcherService_CheckNetType_Ans>::Pointer ctx)
{
    ErrorCodeEnum ec = Error_Succeed;
    int netType = 0; //默认未知

#ifdef RVC_OS_LINUX
    int i = 0;
    int sockfd;
    struct ifconf ifconf;
    struct ifreq* ifreq;
    char buf[1024];

    //初始化ifconf
    ifconf.ifc_len = 1024;
    ifconf.ifc_buf = buf;
    if ((sockfd = socket(AF_INET, SOCK_STREAM, 0)) < 0) {
        DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("socket error");
    }
    //获取所有接口信息
    ioctl(sockfd, SIOCGIFCONF, &ifconf);

    //逐个获取Ip地址
    int size = ifconf.ifc_len / sizeof(struct ifreq);
    ifreq = (struct ifreq*)buf;
    string netName(ifreq->ifr_name);

    if (size == 1 && netName == "lo") //只有逻辑地址 -- 网线被拔出
    {
        netType = 1;
    }
    else
    {
        for (i = size; i > 0; i--) {
            string netName(ifreq->ifr_name); //有其他网卡 -- 有线
            if (netName != "lo") {
                netType = 2;
            }
            ifreq++;
        }
    }

#else
    CoInitialize(NULL);
    //  通过NLA接口获取网络状态
    IUnknown* pUnknown = NULL;
    bool  bOnline = true;//是否在线  
    HRESULT Result = CoCreateInstance(CLSID_NetworkListManager, NULL, CLSCTX_ALL,
        IID_IUnknown, (void**)&pUnknown);
    if (SUCCEEDED(Result)) {
        INetworkListManager* pNetworkListManager = NULL;
        if (pUnknown)
            Result = pUnknown->QueryInterface(IID_INetworkListManager, (void
                **)&pNetworkListManager);
        if (SUCCEEDED(Result)) {
            VARIANT_BOOL IsConnect = VARIANT_FALSE;
            if (pNetworkListManager) {
                //Result = pNetworkListManager->get_IsConnectedToInternet(&IsConnect);  //检测互联网连接
                Result = pNetworkListManager->get_IsConnected(&IsConnect); //检测本地网络
            }
            if (SUCCEEDED(Result)) {
                bOnline = (IsConnect == VARIANT_TRUE) ? true : false;
            }
        }
        if (pNetworkListManager)
            pNetworkListManager->Release();
    }
    if (pUnknown)
        pUnknown->Release();

    if (bOnline == true) {
        netType = 2;
    }
    else
    {
        netType = 1;
    }
#endif // RVC_OS_LINUX

    if (ctx != NULL) {
        ctx->Ans.netType = netType;
        ctx->Answer(ec);
    }
    return ec;
}

ErrorCodeEnum ResourceWatcherFSM::GetBizLinks(
    SpReqAnsContext<ResourceWatcherService_GetBizLinks_Req, ResourceWatcherService_GetBizLinks_Ans>::Pointer ctx)
{
    ErrorCodeEnum ec = Error_Succeed;

    int filter = ctx->Req.filter;  //后续过滤使用
    CAutoArray<CSimpleStringA> bizLinks;
    CAutoArray<CSimpleStringA> bizNames;

    CSmartPointer<IConfigInfo> spCtSettingConfig;
    GetEntityBase()->GetFunction()->OpenConfig(Config_CenterSetting, spCtSettingConfig);

    if (filter == 0) //用户管理桌面业务网址
    {
        CSimpleStringA mLink(""), adLink(""), tLink("");
        spCtSettingConfig->ReadConfigValue("Chromium", "UserMgrUrlFulture", mLink);
        if (mLink.GetLength() != 0) {
            CSimpleStringA tName = CSimpleStringA("主站点");
            bizNames.Append(&tName, 0, 1);
            bizLinks.Append(&mLink, 0, 1);
        }

        spCtSettingConfig->ReadConfigValue("Chromium", "UserMgrAd", adLink);
        if (adLink.GetLength() != 0) {
            CSimpleStringA tName = CSimpleStringA("广告站点");
            bizNames.Append(&tName, 0, 1);
            bizLinks.Append(&adLink, 0, 1);
        }

        int bizCnt = 0;
        CSimpleStringA info(""), getLink("");
        do {// 主站点|www.test.com
            bizCnt++;
            CSimpleStringA chineseName("");
            CSimpleStringA url("");
            getLink = CSimpleStringA("DesktopDetectUrl").Append(std::to_string(bizCnt).c_str());
            spCtSettingConfig->ReadConfigValue("ResourceWatcher", getLink.GetData(), info);
            if (info.GetLength() != 0) {
                CAutoArray<CSimpleStringA> arr = info.Split('|');
                int len = arr.GetCount();
                if (len != 2) {
                    DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("[%s]Not Detect Url", info.GetData());
                }
                else
                {
                    chineseName = arr[0];
                    url = arr[1];
                    bizNames.Append(&chineseName, 0, 1);
                    bizLinks.Append(&url, 0, 1);
                }
            }
        } while (info.GetLength() != 0);
    }
    else if (filter == 1) //错误页集中配置、准入网址
    {
        int bizCnt = 0;
        CSimpleStringA info(""), getLink("");
        do {// 准入服务|AccessAuth|accessUrl
            bizCnt++;
            CSimpleStringA chineseName(""), entityName(""), key("");
            CSimpleStringA url("");
            getLink = CSimpleStringA("ErrPageDetectUrl").Append(std::to_string(bizCnt).c_str());
            spCtSettingConfig->ReadConfigValue("ResourceWatcher", (LPCTSTR)getLink, info);
            if (info.GetLength() != 0) {
                CAutoArray<CSimpleStringA> arr = info.Split('|');
                int len = arr.GetCount();
                if (len != 3) {
                    DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("[%s]Not errPage Check config info.", info.GetData());
                }
                else
                {
                    chineseName = arr[0];
                    entityName = arr[1];
                    key = arr[2];

                    spCtSettingConfig->ReadConfigValue(entityName.GetData(), key.GetData(), url);
                    if (url.GetLength() != 0) {
                        bizNames.Append(&chineseName, 0, 1);
                        bizLinks.Append(&url, 0, 1);
                    }
                    else
                    {
                        DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("Get errPage detecet url failed. EntityName:(%s), Key:(%s).",
                            entityName.GetData(), key.GetData());
                    }
                }
            }
        } while (info.GetLength() != 0);
    }
    ctx->Ans.bizLinks = bizLinks;
    ctx->Ans.bizNames = bizNames;

    if (ctx != NULL) {
        ctx->Answer(ec);
    }
    return ec;
}

#ifdef RVC_OS_WIN
ErrorCodeEnum ResourceWatcherFSM::CreateLinkFile(const CSimpleStringA& szStartAppPath, const CSimpleStringA& szAddCmdLine,
    const CSimpleStringA& szDestLnkPath, const CSimpleStringA& szIconPath)
{
    HRESULT hr = CoInitialize(NULL);
    ErrorCodeEnum result(Error_Unexpect);
    if (SUCCEEDED(hr))
    {
        IShellLink* pShellLink;
        hr = CoCreateInstance(CLSID_ShellLink, NULL, CLSCTX_INPROC_SERVER, IID_IShellLink, (void**)&pShellLink);
        if (SUCCEEDED(hr))
        {
            hr = pShellLink->SetPath(szStartAppPath);
			if (SUCCEEDED(hr)) {
				string strTmp = szStartAppPath;
				int nStart = strTmp.find_last_of("/\\");
				hr = pShellLink->SetWorkingDirectory(strTmp.substr(0, nStart).c_str());
                if (SUCCEEDED(hr)) {
                    hr = pShellLink->SetArguments(szAddCmdLine);
					if (szIconPath)
					{
						hr = pShellLink->SetIconLocation(szIconPath, 0);
                        if (!SUCCEEDED(hr)) {
							DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM).setAPI(__FUNCTION__)("SetIconLocation failed: %u", hr);
                        }
					}
					IPersistFile* pPersistFile;
					hr = pShellLink->QueryInterface(IID_IPersistFile, (void**)&pPersistFile);
					if (SUCCEEDED(hr))
					{
						hr = pPersistFile->Save(CSimpleStringA2W(szDestLnkPath).GetData(), FALSE);
						if (SUCCEEDED(hr))
						{
                            result = Error_Succeed;
						}
						else {
							DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM).setAPI(__FUNCTION__)("Save failed: %u", hr);
						}
						pPersistFile->Release();
					}
					else {
						DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM).setAPI(__FUNCTION__)("QueryInterface failed: %u", hr);
					}
				}
				else {
					DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM).setAPI(__FUNCTION__)("SetWorkingDirectory failed: %u", hr);
				}
            }
            else {
                DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM).setAPI(__FUNCTION__)("SetPath failed: %u", hr);
            }
            pShellLink->Release();
        }
        else {
			DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM).setAPI(__FUNCTION__)("CoCreateInstance failed: %u", hr);
        }
        CoUninitialize();
    }
    else {
        DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM).setAPI(__FUNCTION__)("CoInitialize failed: %u", hr);
    }
    return result;
}

ErrorCodeEnum ResourceWatcherFSM::CreateLink(int nType, const CSimpleStringA& exePath)
{
    ErrorCodeEnum result = Error_Unexpect;
	CSimpleStringA icoPath;
	ErrorCodeEnum Error = GetEntityBase()->GetFunction()->GetPath("Bin", icoPath);
	icoPath = icoPath + "\\" + "VTM.ico";
	CSimpleStringA strRvc(true);
	GetEntityBase()->GetFunction()->GetPath("rvc", strRvc);
	if (!strRvc.IsNullOrEmpty()) {
		strRvc += "\\Resources";
		if (!ExistsDirA(strRvc)) {
			CreateDirA(strRvc, TRUE);
		}
		strRvc += "\\VTM.ico";
		if (!ExistsFileA(strRvc) && ExistsFileA(icoPath)) {
			CopyFileA(icoPath, strRvc, FALSE);
		}
		if (ExistsFileA(strRvc)) {
			icoPath = strRvc.GetData();
		}
	}
	if (!ExistsFileA(icoPath)) {
        DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM).setAPI(__FUNCTION__)("%s is not exist", icoPath.GetData());
        return result;
	}

    LPITEMIDLIST lp;
	CHAR lstr[MAX_PATH] = "";
    if (nType == 0) {
		CSimpleStringA s(true);
        const bool exist = IsDesktopIconExist(s);
		if (!s.IsNullOrEmpty()) {
			DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("to create %s", s.GetData());
			if (Error_Succeed != (result = CreateLinkFile(exePath, "", s, icoPath))) {
				DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("Create link file for DESKTOP fail");
			}
        }
    }
    else if (nType == 2) {
		CSimpleStringA s(true);
		const bool exist = IsStartupIconExist(s);
		if (!s.IsNullOrEmpty()) {
			DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("to create %s", s.GetData());
			if (Error_Succeed != (result = CreateLinkFile(exePath, "", s, icoPath))) {
				DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("Create link file for STARTUP fail");
			}
		}
    }
    else {
        DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM).setAPI(__FUNCTION__)("cannot support link create type: %d", nType);
    }
    return result;
}


bool ResourceWatcherFSM::GetVTMExePath(CSimpleStringA& strValue, bool FailIfNotExist)
{
    bool result(false);
	CSimpleStringA exePath(true);
    strValue = "";
	ErrorCodeEnum rc = GetEntityBase()->GetFunction()->GetPath("RootVer", exePath);
	if (exePath.IsNullOrEmpty() || rc != Error_Succeed) {
        DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("Get RootVer path failed: %s", SpStrError(rc));
	}
	else {
		exePath.Append("\\VTM.exe");
		if (FailIfNotExist && !ExistsFileA(exePath)) {
            DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("[% s] is not existed!", exePath.GetData());
        }
        else {
			result = true;
        }
		strValue = exePath;
	}
    return result;
}

bool ResourceWatcherFSM::CopyExeToRoot(const CSimpleStringA& csVersion, const CSimpleStringA& aimExePath)
{
    CSimpleStringA rootVerPath(true), exePath(true);
    ErrorCodeEnum rc = GetEntityBase()->GetFunction()->GetPath("RootVer", rootVerPath);
    if (rc == Error_Succeed)
    {
        CSimpleStringA srcExePath, csPath = rootVerPath;
		srcExePath = rootVerPath + "\\" + csVersion.GetData() + "\\bin\\VTM.exe";
		DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("srcExePath:%s exePath：%s", srcExePath.GetData());
        if (!ExistsFileA(srcExePath)) {
			DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("%s is not exist!", srcExePath.GetData());
			return false;
        }
		if (!CopyFileA(srcExePath.GetData(), aimExePath.GetData(), FALSE))
		{
			DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("CopyFileA Fail error :%d ", GetLastError());
			return false;
		}
    }
    else {
        DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("GetPath 4 RootVer failed: %s", SpStrError(rc));
        return false;
    }
    return true;
}

bool ResourceWatcherFSM::GetVtmVersionFromActiveTxt(CSimpleStringA& csVersion)
{
    bool bRet = false;
    CSimpleStringA rootVerPath;
    ErrorCodeEnum rc = GetEntityBase()->GetFunction()->GetPath("RootVer", rootVerPath);//获取version根路径
    if (rc != Error_Succeed) {
        LogWarn(Severity_Middle, Error_Exception, LOG_RESOURCEWATCHER_OPEN_ACTIVE_FAIL, "testActive fail , get RootVer path is failed");
        DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM).setResultCode("RTA5A06")("testActive fail , get RootVer path is failed！");
        return false;
    }
    CSimpleStringA strActiveFile = CSimpleStringA::Format("%s\\active.txt", rootVerPath.GetData());
    FILE* pFile = fopen(strActiveFile.GetData(), "rb+");
    if (pFile != NULL)
    {
        char szTemp[256] = {};
        char szVersion[32] = {};
        int n = fread(szTemp, 1, 256, pFile);
        strncpy_s(szVersion, sizeof(szVersion), szTemp, _TRUNCATE);
        csVersion = szVersion;
        fclose(pFile);
        bRet = true;
    }
    else
    {
        DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("Open active.txt failed.");
        bRet = false;
    }
    return bRet;

}

bool ResourceWatcherFSM::GetRegValue(HKEY hKey, LPCTSTR lpcszParam, CSimpleStringA& strValue)
{
    DWORD dwType = REG_SZ;
    TCHAR szValue[MAX_PATH + 1] = { 0 };
    DWORD dwSize = MAX_PATH * sizeof(CHAR);
	memset(szValue, '\0', MAX_PATH + 1);
    LONG lResult = RegQueryValueExA(hKey, lpcszParam, NULL, &dwType, (LPBYTE)szValue, &dwSize);
    if (lResult == ERROR_SUCCESS) {
        strValue = szValue;
        return true;
    }
    else {
        DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("RegQueryValueEx for \"%s\" error, result=%ld.", lpcszParam, lResult);
        return false;
    }
}
/** 方案设计见：https://processon.paas.cmbchina.com/home/view/link/66d12df48139570821109ecf#WIN端应用开机自启动方式优化（实体实现）  [Gifur@2024830]*/
void ResourceWatcherFSM::DetectAutoStartupCover()
{
    LOG_FUNCTION();
    CSimpleStringA strStartupPath(true);
    const int nStartupType = DetectAutoStartupType(strStartupPath);
    ErrorCodeEnum rc = Error_InvalidState;
    const int setType = InitialAutoStartupSetType();
    /** 是否去移除开始自启动菜单中对应的文件  [Gifur@2024830]*/
    bool toDeleteAutoStartFile(false);
    DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("current startup type:%d, aim start type:%d", nStartupType, setType);
    switch (setType)
    {
    case 1://将VBS改成EXE，前提是VBS必须已在注册表
        if (nStartupType == 1) {
            rc = ChangeAutoStartupWithExe();
        }
        break;
    case 2: //设置使用EXE注册表自启动，包括之前VBS、没设置、老安装的开机自启动
		if (nStartupType == 1 || nStartupType == 0 || nStartupType == 3) {
			rc = ChangeAutoStartupWithExe();
			if (rc == Error_Succeed && nStartupType == 3) {
                toDeleteAutoStartFile = true;
			}
        }
        break;
    case 3: //不设置开机自启动
		if (nStartupType == 1 || nStartupType == 2) {
			rc = ChangeAutoStartupWithExe(false, true);
        }
        else if (nStartupType == 3 || nStartupType == 4 || nStartupType == 5) {
            toDeleteAutoStartFile = true;
            //这里不做清理，因为可以自动的一个一个删除
        }
        break;
    case 4: //恢复VBS启动（防止EXE启动失败），几乎不会用到
		if (nStartupType == 2 || nStartupType == 0) {
			rc = ChangeAutoStartupWithExe(true);
		}
        break;
	case 5: //设置使用EXE注册表自启动（涵盖所有类型）
		if (nStartupType == 1 || nStartupType == 0 || nStartupType == 3 || nStartupType == 4 || nStartupType == 5) {
			rc = ChangeAutoStartupWithExe();
			if (rc == Error_Succeed && (nStartupType == 3 || nStartupType == 4 || nStartupType == 5)) {
				toDeleteAutoStartFile = true;
				//这里不做清理，因为以前也没有问题
			}
		}
		break;
	case 6: //设置为开机后开始菜单自启动（涵盖所有类型）
    {
        CSimpleStringA exePath(true);
        if (nStartupType == 1 || nStartupType == 2 || nStartupType == 3 || nStartupType == 5 || nStartupType == 0) {
            CSimpleStringA strNoUse(true);
            if (!m_skipDesktopDetect && !IsDesktopIconExist(strNoUse)) {
				LogWarn(Severity_Low, Error_InvalidState, LOG_WARN_CREATE_EXELINK_FROMAUTOSTART_ABORT,
					CSimpleStringA::Format("detect desktop icon is not exist, abort the op, old start type: %d", nStartupType));
                break;
            }
			if (GetVTMExePath(exePath, true)) {
				if (nStartupType == 1 || nStartupType == 2) {
					//TODO: 如果出现修改注册表成功但是设置自启动图标失败的情况  [Gifur@202492]
					rc = ChangeAutoStartupWithExe(false, true);
				}
				else if (nStartupType == 3 || nStartupType == 5 || nStartupType == 0) {
                    rc = Error_Succeed;
				}
				if (rc == Error_Succeed) {
					rc = CreateLink(2, exePath);
					if (rc != Error_Succeed) {
						LogWarn(Severity_Middle, Error_InvalidState, LOG_WARN_CREATE_EXELINK_FROMAUTOSTART_FAILED,
							CSimpleStringA::Format("Create autostart lnk failed, old start type: %d", nStartupType));
					}
					else {
						LogWarn(Severity_Low, Error_Debug, LOG_WARN_CREATE_EXELINK_FROMAUTOSTART_SUCC,
							CSimpleStringA::Format("Create autostart lnk succ, old start type: %d", nStartupType));
                        if ((nStartupType == 3 || nStartupType == 5)) { toDeleteAutoStartFile = true; }
						if(nStartupType != 0) DeleteDuplicateAutoStartFile(true);
					}
				}
			}
			else {
				LogWarn(Severity_Middle, Error_InvalidState, LOG_WARN_CREATE_EXELINK_FROMAUTOSTART_FAILED,
					CSimpleStringA::Format("[%d][%s] is not exist", setType, exePath.GetData()));
			}
        }
    }
    break;
	case 7: //设置为开机后开始菜单自启动（针对仅有桌面开机自启动的）
	{
		CSimpleStringA exePath(true);
		if ((nStartupType == 3 || nStartupType == 5)) {
            CSimpleStringA strNoUse(true);
			if (!m_skipDesktopDetect && !IsDesktopIconExist(strNoUse)) {
				LogWarn(Severity_Low, Error_InvalidState, LOG_WARN_CREATE_EXELINK_FROMAUTOSTART_ABORT,
                    CSimpleStringA::Format("detect desktop icon is not exist, abort the op, old start type: %d", nStartupType));
				break;
			}
			if (GetVTMExePath(exePath, true)) {
				if ((rc = CreateLink(2, exePath)) != Error_Succeed) {
					LogWarn(Severity_Middle, Error_InvalidState, LOG_WARN_CREATE_EXELINK_FROMAUTOSTART_FAILED,
						CSimpleStringA::Format("Create autostart lnk failed, old start type: %d", nStartupType));
				}
				else {
					LogWarn(Severity_Low, Error_Debug, LOG_WARN_CREATE_EXELINK_FROMAUTOSTART_SUCC,
						CSimpleStringA::Format("Create autostart lnk succ, old start type: %d", nStartupType));
					toDeleteAutoStartFile = true;
					DeleteDuplicateAutoStartFile(true);
				}
			}
			else {
				LogWarn(Severity_Middle, Error_InvalidState, LOG_WARN_CREATE_EXELINK_FROMAUTOSTART_FAILED,
					CSimpleStringA::Format("[%d][%s] is not exist", setType, exePath.GetData()));
			}
		}
	   }
		break;
    default:
        break;
    }

    if (toDeleteAutoStartFile) {
		if (!strStartupPath.IsNullOrEmpty() && ExistsFileA(strStartupPath)) {
			BOOL rmRet = RemoveFileA(strStartupPath);
            if (!rmRet && ExistsFileA(strStartupPath)) {
				DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("remove auto start lnk file failed: %s, GLE=%u", strStartupPath.GetData(), GetLastError());
            }
            else {
				DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("remove auto start lnk file: %s", strStartupPath.GetData());
            }
		}
    }
	else {
		DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("there is nothing to delete");
	}
}

int ResourceWatcherFSM::DetectAutoStartupType(CSimpleStringA& strValue)
{
    LOG_FUNCTION();

    int vbsType = -1;
    DWORD dwFlag = KEY_READ | KEY_QUERY_VALUE | KEY_ENUMERATE_SUB_KEYS;
    if (osutil_is32r64_platform() == 1) {
        dwFlag |= KEY_WOW64_64KEY;
    }
    bool explorerSet = false;
    CSimpleStringA regeditValue(true);
    HKEY hKey;
    LONG lResult = RegOpenKeyEx(HKEY_LOCAL_MACHINE,
        TEXT("SOFTWARE\\Microsoft\\Windows NT\\CurrentVersion\\Winlogon"),
        0, dwFlag, &hKey);
    if (lResult == ERROR_SUCCESS) {
        DWORD dwType = REG_SZ;
        DWORD dwSize = MAX_PATH * sizeof(TCHAR);
        TCHAR szValue[MAX_PATH + 1] = { 0 };
        memset(szValue, '\0', MAX_PATH + 1);
        lResult = RegQueryValueExA(hKey, "Shell", NULL, &dwType, (LPBYTE)szValue, &dwSize);
        if (lResult == ERROR_SUCCESS) {
            std::string sValue(szValue);
            regeditValue = szValue;
            sValue = SP::Utility::ToLower(sValue);
            CSimpleStringA value(sValue.c_str());
			if (value.IsStartWith("wscript", true) && value.IsEndWith(".vbs", true)) {
				LogWarn(Severity_Low, Error_Debug, LOG_WARN_AUTO_STARTUP_FROM_REGIST, regeditValue);
				vbsType = 1;
			}
			else if (value.IsEndWith("vtm.exe", true)) {
				LogWarn(Severity_Low, Error_Debug, LOG_WARN_CHECK_AUTO_STARTUP_WITH_EXE, regeditValue);
				vbsType = 2;
			}
			else if (value.Compare("explorer.exe") == 0) {
                vbsType = 0;
                explorerSet = true;
            }
            else {
				LogWarn(Severity_Low, Error_Debug, LOG_WARN_CHECK_AUTO_STARTUP_UNKNOWN, regeditValue);
                vbsType = 0;
            }
        }
        else {
            LogWarn(Severity_Low, Error_Unexpect, LOG_WARN_CHECK_AUTO_STARTUP_FROM_REGIST_FAILED,
                CSimpleStringA::Format("RegQueryValueEx error returned %u, GLE=%u.", lResult, GetLastError()));
        }
    }
    else {
        LogWarn(Severity_Low, Error_Unexpect, LOG_WARN_CHECK_AUTO_STARTUP_FROM_REGIST_FAILED,
            CSimpleStringA::Format("RegOpenKeyEx error, GLE=%u.", GetLastError()));
    }
    RegCloseKey(hKey);

    if (vbsType == 0 || vbsType == -1) {
		CSimpleStringA strLnkPath(true);
        int scriptType;
		if (IsHasSetAutoStartupByFolder(strLnkPath, scriptType)) {
            if (0 == scriptType) {
				LogWarn(Severity_Low, Error_Debug, LOG_WARN_CHECK_AUTO_STARTUP_WITH_STARTMENU_FROMSETUP, strLnkPath);
				vbsType = 3;
            }
            else if(1 == scriptType){
				LogWarn(Severity_Low, Error_Debug, LOG_WARN_CHECK_AUTO_STARTUP_WITH_STARTMENU_FROMSCRIPT, strLnkPath);
				vbsType = 4;
            }
            else {
				LogWarn(Severity_Low, Error_Debug, LOG_WARN_CHECK_AUTO_STARTUP_WITH_STARTMENU_FROMCUSTOM, strLnkPath);
                vbsType = 5;
            }
            regeditValue = strLnkPath;
        }
        else if (vbsType == 0 && explorerSet) {
			LogWarn(Severity_Low, Error_Debug, LOG_WARN_NOT_AUTO_STARTUP_FROM_REGIST, regeditValue);
        }
    }
    strValue = regeditValue;
    return vbsType;
}

ErrorCodeEnum ResourceWatcherFSM::ChangeAutoStartupWithExe(bool resetVBS, bool resetExplorer)
{
    const char* exploreExe = "explorer.exe";
    ErrorCodeEnum result(Error_Succeed);
    CSimpleStringA exePath(true);
    if (resetExplorer) {
        exePath = exploreExe;
    }
    else
    {
        result = GetEntityBase()->GetFunction()->GetPath("RootVer", exePath);
        if (exePath.IsNullOrEmpty() || result != Error_Succeed) {
            DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM).setResultCode("RTA5A09").setAPI("ChangeAutoStartupWithExe")("Get RootVer path failed: %d", result);
			LogWarn(Severity_Middle, Error_Unexpect, LOG_WARN_UPDATE_AUTO_STARTUP_WITH_EXE_FAILED, CSimpleStringA::Format("Get RootVer path failed: %d", result));
            return Error_Unexpect;
        }
        if (!resetVBS)
            exePath.Append("\\VTM.exe");
        else 
            exePath.Append("\\spexplorerfast.vbs");

        if (!ExistsFileA(exePath)) {
            DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM).setResultCode("RTA5A09").setAPI("ChangeAutoStartupWithExe")("[%s] is not existed!", exePath.GetData());
			LogWarn(Severity_Middle, Error_Unexpect, LOG_WARN_UPDATE_AUTO_STARTUP_WITH_EXE_FAILED, CSimpleStringA::Format("[%s] is not existed!", exePath.GetData()));
            return Error_NotExist;
        }
    }

    DWORD dwFlag = KEY_WRITE;
    if (osutil_is32r64_platform() == 1) {
        dwFlag |= KEY_WOW64_64KEY;
    }
    HKEY hKey;
    LONG lResult = RegOpenKeyEx(HKEY_LOCAL_MACHINE,
        TEXT("SOFTWARE\\Microsoft\\Windows NT\\CurrentVersion\\Winlogon"), 0, dwFlag, &hKey);
    if (lResult == ERROR_SUCCESS) {
        lResult = RegSetValueExA(hKey, "Shell", 0, REG_SZ, (const BYTE*)exePath.GetData(), exePath.GetLength());
        if (lResult == ERROR_SUCCESS) {
            LogWarn(Severity_Low, Error_Debug, LOG_WARN_UPDATE_AUTO_STARTUP_WITH_EXE_SUCC
                , CSimpleStringA::Format("RegSetValueExA for Shell with %s succ!", exePath.GetData()));
            result = Error_Succeed;
        }
        else
        {
            DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM).setResultCode("RTA5A09").setAPI("ChangeAutoStartupWithExe")
                ("RegSetValueExA for Shell with %s failed: %d", exePath.GetData(), lResult);
            LogWarn(Severity_Middle, Error_Unexpect, LOG_WARN_UPDATE_AUTO_STARTUP_WITH_EXE_FAILED
                , CSimpleStringA::Format("RegSetValueExA for Shell with %s failed: %d", exePath.GetData(), lResult));
            result = Error_Unexpect;
        }
    }
    else
    {
        DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM).setResultCode("RTA5A09").setAPI("ChangeAutoStartupWithExe")
            ("RegOpenKeyEx for write %s failed: %d", exePath.GetData(), lResult);
        LogWarn(Severity_Middle, Error_Unexpect, LOG_WARN_UPDATE_AUTO_STARTUP_WITH_EXE_FAILED
            , CSimpleStringA::Format("RegOpenKeyEx for write %s failed: %d", exePath.GetData(), lResult));
        result = Error_Unexpect;
    }

    RegCloseKey(hKey);
    return result;
}

int ResourceWatcherFSM::InitialAutoStartupSetType()
{
    int ret = 0;
    CSmartPointer<IConfigInfo> spConfig;
    GetEntityBase()->GetFunction()->OpenConfig(Config_CenterSetting, spConfig);
    int value(0);
    spConfig->ReadConfigValueInt(GetEntityBase()->GetEntityName(), "AutoStartCMD", value);
    if (value != 0) {
        ret = value;
    }
    return ret;
}

void ResourceWatcherFSM::UploadScreenInfo()
{
	//GetSystemMetrics (SM_CMONITORS) 计数仅显示可见的显示器
	const int screenNums = GetSystemMetrics(SM_CMONITORS);
	const int aimScreenNums4Stand2S = 2;
	const int aimScreenNums4Other = 1;
    const MachineTypeEnum mt = SpStr2MachineType(m_RvcSysinfo.strMachineType);

	if (mt == RVC_Stand2S && screenNums != aimScreenNums4Stand2S) {
		LogWarn(Severity_Low, Error_Unexpect, LOG_RESOURCEWATCHER_LACK_OF_MONITOR
			, CSimpleStringA::Format("{\"subject\":\"screen_count\",\"machine_type\":\"%s\",\"expect\":%d,\"actual\":%d}"
				, m_RvcSysinfo.strMachineType.GetData(), aimScreenNums4Stand2S, screenNums));
	}
	else if (mt != RVC_Stand2S && screenNums != aimScreenNums4Other) {
		LogWarn(Severity_Low, Error_Unexpect, LOG_RESOURCEWATCHER_LACK_OF_MONITOR
			, CSimpleStringA::Format("{\"subject\":\"screen_count\",\"machine_type\":\"%s\",\"expect\":%d,\"actual\":%d}"
				, m_RvcSysinfo.strMachineType.GetData(), aimScreenNums4Other, screenNums));
	}
}

void ResourceWatcherFSM::DeleteDuplicateAutoStartFile(bool toDeleteLastLegity)
{
	std::vector<std::string> userlist;
	std::vector<std::string> publist;
	std::string userPath(""), pubPath("");
	std::vector<std::string> autolist;
	autolist.push_back(CMB_LINK_FILE_NAME);
	GetAutoStartFile(userPath, userlist, pubPath, publist);
	if (!keyPublist.empty() || !keyUserlist.empty()) {
        /** 移除集中配置中配置的文件（用户目录下）  [Gifur@20241031]*/
		for (auto it = userlist.cbegin(); keyUserlist.size() > 0 && it != userlist.cend(); ++it) {
			for (auto kt = keyUserlist.cbegin(); kt != keyUserlist.cend(); ++kt) {
				CSimpleStringA strfilename(it->c_str());
				if (strfilename.Compare(kt->c_str()) == 0) {
					CSimpleStringA fullStartFileNameFromScripts(userPath.c_str());
					fullStartFileNameFromScripts += "\\";
					fullStartFileNameFromScripts += strfilename;
					if (ExistsFileA(fullStartFileNameFromScripts)) {
                        const auto r = DeleteFileA(fullStartFileNameFromScripts);
                        DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("Delete AutoStart File:[%s]", fullStartFileNameFromScripts);
					}
				}
			}
            if (toDeleteLastLegity) {
                /** 移除正规的文件（用户目录下）  [Gifur@20241031]*/
				for (auto kt = autolist.cbegin(); kt != autolist.cend(); ++kt) {
					CSimpleStringA strfilename(it->c_str());
					if (strfilename.Compare(kt->c_str()) == 0) {
						CSimpleStringA fullStartFileNameFromScripts(userPath.c_str());
						fullStartFileNameFromScripts += "\\";
						fullStartFileNameFromScripts += strfilename;
						if (ExistsFileA(fullStartFileNameFromScripts)) {
							const auto r = DeleteFileA(fullStartFileNameFromScripts);
							DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("Delete AutoStart from autolist File:[%s]", fullStartFileNameFromScripts);
						}
					}
				}
            }
		}
        /** 移除集中配置中配置的文件（公共目录下）  [Gifur@20241031]*/
		for (auto it = publist.cbegin(); keyPublist.size() > 0 && it != publist.cend(); ++it) {
			for (auto kt = keyPublist.cbegin(); kt != keyPublist.cend(); ++kt) {
				CSimpleStringA strfilename(it->c_str());
				if (strfilename.Compare(kt->c_str()) == 0) {
					CSimpleStringA fullStartFileNameFromScripts(pubPath.c_str());
					fullStartFileNameFromScripts += "\\";
					fullStartFileNameFromScripts += strfilename;
					if (ExistsFileA(fullStartFileNameFromScripts)) {
						const auto r = DeleteFileA(fullStartFileNameFromScripts);
						DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("Delete AutoStart File:[%s]", fullStartFileNameFromScripts);
					}
				}
			}
            if (toDeleteLastLegity) {
				/** 移除正规的文件（公共目录下）  [Gifur@20241031]*/
				for (auto kt = autolist.cbegin(); kt != autolist.cend(); ++kt) {
					CSimpleStringA strfilename(it->c_str());
					if (strfilename.Compare(kt->c_str()) == 0) {
						CSimpleStringA fullStartFileNameFromScripts(pubPath.c_str());
						fullStartFileNameFromScripts += "\\";
						fullStartFileNameFromScripts += strfilename;
						if (ExistsFileA(fullStartFileNameFromScripts)) {
							const auto r = DeleteFileA(fullStartFileNameFromScripts);
							DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("Delete AutoStart from autolist File:[%s]", fullStartFileNameFromScripts);
						}
					}
				}
            }
		}
	}
}

BOOL ResourceWatcherFSM::IsHasSetAutoStartupByFolder(CSimpleStringA& strPath, int& setType)
{
    BOOL result(FALSE);
    strPath.Clear();
    setType = -1;
	std::vector<std::string> userlist;
	std::vector<std::string> publist;
	std::string userPath(""), pubPath("");
	GetAutoStartFile(userPath, userlist, pubPath, publist);

    //检查是否有由用户自定义的开机自启动快捷键
	if (!result && (!keyPublist.empty() || !keyUserlist.empty())) {
		for (auto it = userlist.cbegin(); !result && keyUserlist.size() > 0 && it != userlist.cend(); ++it) {
			for (auto kt = keyUserlist.cbegin(); kt != keyUserlist.cend(); ++kt) {
				CSimpleStringA strfilename(it->c_str());
				if (strfilename.Compare(kt->c_str()) == 0) {
					CSimpleStringA fullStartFileNameFromScripts(userPath.c_str());
					fullStartFileNameFromScripts += "\\";
					fullStartFileNameFromScripts += strfilename;
					if (ExistsFileA(fullStartFileNameFromScripts)) {
						setType = 2;
						strPath = fullStartFileNameFromScripts;
						result = TRUE;
						break;
					}
					else {
						DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("[%d]file is not exist:%s", __LINE__, fullStartFileNameFromScripts.GetData());
					}
				}
			}
		}
		for (auto it = publist.cbegin(); !result && keyPublist.size() > 0 && it != publist.cend(); ++it) {
			for (auto kt = keyPublist.cbegin(); kt != keyPublist.cend(); ++kt) {
				CSimpleStringA strfilename(it->c_str());
				if (strfilename.Compare(kt->c_str()) == 0) {
					CSimpleStringA fullStartFileNameFromScripts(pubPath.c_str());
					fullStartFileNameFromScripts += "\\";
					fullStartFileNameFromScripts += strfilename;
					if (ExistsFileA(fullStartFileNameFromScripts)) {
						setType = 2;
						strPath = fullStartFileNameFromScripts;
						result = TRUE;
						break;
					}
					else {
						DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("[%d]file is not exist:%s", __LINE__, fullStartFileNameFromScripts.GetData());
					}
				}
			}
		}
	}
    if (!result) {
        //检查是否有由旧安装向导安装的脚本
		for (auto it = publist.cbegin(); !result && it != publist.cend(); ++it) {
			CSimpleStringA strfilename(it->c_str());
			const int tmpType = (strfilename.Compare(CMB_LINK_FILE_NAME) == 0 || (strfilename.IsStartWith("招商银行可视柜台") && strfilename.IsEndWith(".lnk"))) ? 0 : -1;
			if (tmpType == 0) {
				CSimpleStringA fullStartFileNameFromScripts(pubPath.c_str());
				fullStartFileNameFromScripts += "\\";
				fullStartFileNameFromScripts += strfilename;
				if (ExistsFileA(fullStartFileNameFromScripts)) {
					setType = tmpType;
					strPath = fullStartFileNameFromScripts;
					result = TRUE;
					break;
				}
				else {
					DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("[%d]file is not exist:%s", __LINE__, fullStartFileNameFromScripts.GetData());
				}
			}
		}
		for (auto it = userlist.cbegin(); !result && it != userlist.cend(); ++it) {
			CSimpleStringA strfilename(it->c_str());
			const int tmpType = (strfilename.Compare(CMB_LINK_FILE_NAME) == 0 || (strfilename.IsStartWith("招商银行可视柜台") && strfilename.IsEndWith(".lnk"))) ? 0 : -1;
			if (tmpType == 0) {
				CSimpleStringA fullStartFileNameFromScripts(userPath.c_str());
				fullStartFileNameFromScripts += "\\";
				fullStartFileNameFromScripts += strfilename;
				if (ExistsFileA(fullStartFileNameFromScripts)) {
					setType = tmpType;
					strPath = fullStartFileNameFromScripts;
					result = TRUE;
					break;
				}
				else {
					DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("[%d]file is not exist:%s", __LINE__, fullStartFileNameFromScripts.GetData());
				}
			}
		}
    }
	if (!result) {
        //最终再检查是否有由安装脚本执行的安装向导
		for (auto it = publist.cbegin(); !result && it != publist.cend(); ++it) {
			CSimpleStringA strfilename(it->c_str());
			if (strfilename.Compare(STRATUP_FILENAME_FROM_SCRIPTS) == 0) {
				CSimpleStringA fullStartFileNameFromScripts(pubPath.c_str());
				fullStartFileNameFromScripts += "\\";
				fullStartFileNameFromScripts += strfilename;
				if (ExistsFileA(fullStartFileNameFromScripts)) {
					setType = 1;
					strPath = fullStartFileNameFromScripts;
					result = TRUE;
					break;
				}
				else {
					DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("[%d]file is not exist:%s", __LINE__, fullStartFileNameFromScripts.GetData());
				}
			}
		}
		for (auto it = userlist.cbegin(); !result && it != userlist.cend(); ++it) {
			CSimpleStringA strfilename(it->c_str());
			if (strfilename.Compare(STRATUP_FILENAME_FROM_SCRIPTS) == 0) {
				CSimpleStringA fullStartFileNameFromScripts(userPath.c_str());
				fullStartFileNameFromScripts += "\\";
				fullStartFileNameFromScripts += strfilename;
				if (ExistsFileA(fullStartFileNameFromScripts)) {
					setType = 1;
					strPath = fullStartFileNameFromScripts;
					result = TRUE;
					break;
				}
				else {
					DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("[%d]file is not exist:%s", __LINE__, fullStartFileNameFromScripts.GetData());
				}
			}
		}
	}
    return result;
}

void ResourceWatcherFSM::DetectVersionHasChangedAndWarn()
{
    CSmartPointer<IConfigInfo> spRunConfig;
    GetEntityBase()->GetFunction()->OpenConfig(Config_Run, spRunConfig);
    UINT64 utVersion = 0;
    spRunConfig->ReadConfigValueHexInt("VersionMonitor", "LastVer", utVersion);
    CVersion lastVer(utVersion);
    if (lastVer.IsValid() && lastVer > m_RvcSysinfo.InstallVersion) {
        CSimpleStringA rootVerPath;
        CSimpleStringA warnInfo = CSimpleStringA::Format("version changed from %s to %s", lastVer.ToString().GetData(), m_RvcSysinfo.InstallVersion.ToString().GetData());
        GetEntityBase()->GetFunction()->GetPath("RootVer", rootVerPath);
        CSimpleStringA csPath = rootVerPath + SPLIT_SLASH_STR + "active.txt";
        if (!ExistsFileA(csPath)) {
            DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM).setResultCode("RTA5A0A").setAPI(__FUNCTION__)
                ("%s: active.txt not exist!", warnInfo.GetData());
            LogWarn(Severity_Middle, Error_Debug, LOG_WARN_ACTIVE_FILE_CHANGE, CSimpleStringA::Format("%s: active.txt not exist!", warnInfo.GetData()));
        }
        else
        {
            CSimpleFileComponent activeFileInfo;
            HANDLE hFile = CreateFileA(
                csPath,
                GENERIC_READ,
                FILE_SHARE_READ,
                NULL,
                OPEN_EXISTING,
                FILE_ATTRIBUTE_NORMAL | FILE_FLAG_BACKUP_SEMANTICS,
                NULL);
            if (hFile == INVALID_HANDLE_VALUE) {
                DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM).setResultCode("RTA5A0A").setAPI(__FUNCTION__)
                    ("%s: active.txt open failed %u", warnInfo.GetData(), GetLastError());
                LogWarn(Severity_Middle, Error_Debug, LOG_WARN_ACTIVE_FILE_CHANGE, CSimpleStringA::Format("%s: active.txt open failed %u", warnInfo.GetData(), GetLastError()));
            }
            else
            {
                GetFileTime(hFile, (LPFILETIME)&activeFileInfo.mftCreate,
                    (LPFILETIME)&activeFileInfo.mftAccess, (LPFILETIME)&activeFileInfo.mftModified);
                CloseHandle(hFile);
                char szFormat1[128] = { 0 };
                GetTimeFormatStr(szFormat1, 128, (FILETIME*)&activeFileInfo.mftCreate);
                char szFormat2[128] = { 0 };
                GetTimeFormatStr(szFormat2, 128, (FILETIME*)&activeFileInfo.mftAccess);
                char szFormat3[128] = { 0 };
                GetTimeFormatStr(szFormat3, 128, (FILETIME*)&activeFileInfo.mftModified);
                DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM).setResultCode("RTA5A0A").setAPI(__FUNCTION__)
                    ("%s: active.txt create at %s, access at %s, modified at %s", warnInfo.GetData(), szFormat1, szFormat2, szFormat3);
                LogWarn(Severity_Middle, Error_Debug, LOG_WARN_ACTIVE_FILE_CHANGE, CSimpleStringA::Format(
                    "%s: active.txt create at %s, access at %s, modified at %s", warnInfo.GetData(), szFormat1, szFormat2, szFormat3));
            }
        }
    }
    if (!lastVer.IsValid() || lastVer != m_RvcSysinfo.InstallVersion) {
        spRunConfig->WriteConfigValueHexInt("VersionMonitor", "LastVer", m_RvcSysinfo.InstallVersion.GetVersion64());
    }
}

void ResourceWatcherFSM::MakeSureWin8IntoDesktopPageAtLogon()
{
    const bool isWow64 = (osutil_is32r64_platform() == 1);
	DWORD dwFlag = KEY_READ | KEY_QUERY_VALUE | KEY_ENUMERATE_SUB_KEYS;
	if (isWow64) {
		dwFlag |= KEY_WOW64_64KEY;
	}
    bool isWin8(false);
    bool toSetOpenAtLogon(false);
	HKEY hKey;
	LONG lResult = RegOpenKeyEx(HKEY_LOCAL_MACHINE,"SOFTWARE\\Microsoft\\Windows NT\\CurrentVersion", 0, dwFlag, &hKey);
    if (lResult == ERROR_SUCCESS) {
		CSimpleStringA strValue(true);
        if (GetRegValue(hKey, "ProductName", strValue)) {
            DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("Current Windows version:%s", strValue.GetData());
            if (!strValue.IsNullOrEmpty() && strValue.IndexOf("8.1") != -1) {
                isWin8 = true;
            }
        }
        RegCloseKey(hKey);
    }
    if (isWin8) {
        lResult = RegOpenKeyEx(HKEY_CURRENT_USER, "Software\\Microsoft\\Windows\\CurrentVersion\\Explorer\\StartPage", 0, dwFlag, &hKey);
		if (lResult == ERROR_SUCCESS) {
            DWORD dwValue(0);
			if (GetRegValueInt(hKey, "OpenAtLogon", dwValue)) {
				DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("Current OpenAtLogon value:%d", dwValue);
                if (dwValue != 0) {
                    toSetOpenAtLogon = true;
                }
			}
            RegCloseKey(hKey);
		}
    }
    if (toSetOpenAtLogon) {
		dwFlag = KEY_WRITE;
		if (isWow64) {
			dwFlag |= KEY_WOW64_64KEY;
		}
        DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("to Set OpenAtLogon");
		lResult = RegOpenKeyEx(HKEY_CURRENT_USER, "Software\\Microsoft\\Windows\\CurrentVersion\\Explorer\\StartPage", 0, dwFlag, &hKey);
		if (lResult == ERROR_SUCCESS) {
			DWORD dwType = REG_DWORD;
			DWORD dwValue = 0;
			DWORD dwSize = sizeof(DWORD);
            lResult = RegSetValueExA(hKey, "OpenAtLogon", 0, dwType, (BYTE*)&dwValue, dwSize);
			if (lResult == ERROR_SUCCESS) {
                DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM).setAPI(__FUNCTION__)("Set Value with %d for OpenAtLogon in NewStartPanel succ.", dwValue);
            }
            else {
                DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM).setAPI(__FUNCTION__)("Set Value with %d for OpenAtLogon error, result=%ld.", dwValue, lResult);
            }
			RegCloseKey(hKey);
		}
    }
}

bool ResourceWatcherFSM::RegRdVtmVersion(CSimpleStringA& VTMpath, CSimpleStringA& vtmVersion, CSimpleStringA& verPath)
{
    bool bRet = false;
    HKEY key;
    CSimpleStringA regPath = "SOFTWARE\\Microsoft\\Windows\\CurrentVersion\\App Paths\\vtm.exe";
	CSimpleStringA regParaPath = "path";
    CSimpleStringA regParaVersion = "version";
    LONG lResult = RegOpenKeyEx(HKEY_LOCAL_MACHINE, regPath, 0, KEY_ALL_ACCESS, &key);
    if (ERROR_SUCCESS == lResult)
    {
        bool res1 = GetRegValue(key, NULL, VTMpath);
        if (res1) {
            bRet = true;
        }
        else {
            bRet = false;
            RegCloseKey(key);
            return bRet;
        }
		bool res2 = GetRegValue(key, regParaPath, verPath);
		if (res2) {
			bRet = true;
		}
		else {
			bRet = false;
			RegCloseKey(key);
			return bRet;
		}
        bool res3 = GetRegValue(key, regParaVersion, vtmVersion);
        if (res3) {
            bRet = true;
        }
        else {
            bRet = false;
            RegCloseKey(key);
            return bRet;
        }
    }
    else
    {
        DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("%s::RegOpenKeyEx error, Result=%ld.", __FUNCTION__, lResult);
        bRet = false;
    }
    RegCloseKey(key);
    return bRet;
}

bool ResourceWatcherFSM::RegWtVtmPath(const CSimpleStringA& vtmExtPath, const CSimpleStringA& rootPath)
{
    bool bRet = true;
    HKEY key;
    CSimpleStringA regPath = "SOFTWARE\\Microsoft\\Windows\\CurrentVersion\\App Paths";
    if (ERROR_SUCCESS != RegOpenKeyEx(HKEY_LOCAL_MACHINE, regPath, 0, KEY_ALL_ACCESS, &key))
    {
        DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("Open Reg failed.");
        bRet = false;
    }

    DWORD dwDisposition;
    regPath += "\\vtm.exe";
    if (ERROR_SUCCESS != RegCreateKeyExA(HKEY_LOCAL_MACHINE, regPath.GetData(), 0, NULL,
        REG_OPTION_NON_VOLATILE, KEY_ALL_ACCESS, NULL, &key, &dwDisposition))
    {
        DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("Create key failed");
        bRet = false;
    }
    if (ERROR_SUCCESS != RegOpenKeyEx(HKEY_LOCAL_MACHINE, regPath.GetData(), 0, KEY_ALL_ACCESS, &key))
    {
        DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("Set value failed");
        bRet = false;
    }
    CSimpleStringA exePath = vtmExtPath.GetData();
    if (!exePath.IsNullOrEmpty())
    {
        if (ERROR_SUCCESS != RegSetValueExA(key, NULL, 0, REG_SZ, (BYTE*)exePath.GetData(), exePath.GetLength()+1))
        {
            DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("Set path value failed");
            bRet = false;
        }
    }
    else
    {
        DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("Vtm.exe path is failed");
    }
	if (bRet)
	{
        CSimpleStringA para = "path";
		if (ERROR_SUCCESS != RegSetValueExA(key, para, 0, REG_SZ, (BYTE*)rootPath.GetData(), rootPath.GetLength() + 1))
		{
			DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("Set path value failed");
			bRet = false;
		}
	}
	else
	{
		DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("Set path for %s failed", rootPath.GetData());
	}
    ::RegCloseKey(key);
    return bRet;
}

bool ResourceWatcherFSM::RegWtVtmVersion(const CSimpleStringA& vtmVer)
{
    bool bRet = true;
    HKEY key;
    CSimpleStringA regPath = "SOFTWARE\\Microsoft\\Windows\\CurrentVersion\\App Paths";
    if (ERROR_SUCCESS != RegOpenKeyEx(HKEY_LOCAL_MACHINE, regPath, 0, KEY_ALL_ACCESS, &key))
    {
        DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("Open Reg failed.");
        bRet = false;
    }

    DWORD dwDisposition;
    regPath += "\\vtm.exe";
    if (ERROR_SUCCESS != RegCreateKeyExA(HKEY_LOCAL_MACHINE, regPath.GetData(), 0, NULL,
        REG_OPTION_NON_VOLATILE, KEY_ALL_ACCESS, NULL, &key, &dwDisposition))
    {
        DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("Create key failed");
        bRet = false;
    }

    if (ERROR_SUCCESS != RegOpenKeyEx(HKEY_LOCAL_MACHINE, regPath.GetData(), 0, KEY_ALL_ACCESS, &key))
    {
        DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("Set value failed");
        bRet = false;
    }
    CSimpleStringA para = "version";
    CSimpleStringA csVersion = vtmVer.GetData();
    if (!csVersion.IsNullOrEmpty())
    {
        //RegSetValueEx(key, para.GetData(), 0, REG_SZ, (BYTE*)csVersion.GetData(), MAX_PATH);
        if (ERROR_SUCCESS != RegSetValueExA(key, para.GetData(), 0, REG_SZ, (BYTE*)csVersion.GetData(), csVersion.GetLength()+1))
        {
            DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("Set value failed");
            bRet = false;
        }
    }
    else
    {
        DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("Get version of VTM.exe failed.");
    }

    ::RegCloseKey(key);
    return bRet;
}

bool ResourceWatcherFSM::RegOperation4LnkFile()
{
    bool bRet = true;
    CSimpleStringA  csVersion(true), VtmRegPath(true), VtmRegVersion(true), VtmRegVerPath(true);
    bool bGetActive = GetVtmVersionFromActiveTxt(csVersion);
    bool bRegRead = RegRdVtmVersion(VtmRegPath, VtmRegVersion, VtmRegVerPath);
    CSimpleStringA rootVerPath(true), exePath(true);
    ErrorCodeEnum rc = GetEntityBase()->GetFunction()->GetPath("RootVer", rootVerPath);
    DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("csVersion :%s ,VtmRegVersion:%s, %d", csVersion.GetData(), VtmRegVersion.GetData(), bRegRead);
	if (GetVTMExePath(exePath, false) && !ExistsFileA(exePath) && !CopyExeToRoot(csVersion, exePath))
	{
		DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("Copy VTM.exe to version root fail.");
		bRet = false;
	}
    CSimpleStringA fullregVersionPath = VtmRegVerPath + "\\" + VtmRegVersion;
	CSimpleStringA curVersionPath = rootVerPath + "\\" + csVersion;
    if(bRet && !rootVerPath.IsNullOrEmpty() && !csVersion.IsNullOrEmpty() && (!bRegRead || 0 != curVersionPath.Compare(fullregVersionPath, true))) {
		if (!RegWtVtmPath(exePath, rootVerPath))
		{
			DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("RegWtVtmPath failed.");
		}
		if (!RegWtVtmVersion(csVersion))
		{
			DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("RegWtVtmVersion failed.");
		}
    }
    CSimpleStringA strNoUse(true);
    if (bRet && !IsDesktopIconExist(strNoUse)) {
        DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("to create desktop application lnk");
        bRet = (CreateLink(0, exePath) == Error_Succeed);
    }
    else {
        DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("desktop application lnk is already exist");
    }
    return bRet;
}

bool ResourceWatcherFSM::GetRegValueInt(HKEY hKey, LPCTSTR lpcszParam, DWORD& dwValue)
{
	DWORD dwType = REG_DWORD;
	DWORD dwValue1 = 0;
	DWORD dwSize = sizeof(DWORD);
	LONG lResult = RegQueryValueExA(hKey, lpcszParam, NULL, &dwType, (LPBYTE)&dwValue1, &dwSize);
	if (lResult == ERROR_SUCCESS) {
        dwValue = dwValue1;
		return true;
	}
	else {
		DbgWithLink(LOG_LEVEL_ERROR, LOG_TYPE_SYSTEM)("RegQueryValueEx for \"%s\" error, result=%ld.", lpcszParam, lResult);
		return false;
	}
}

void ResourceWatcherFSM::VerifySignature()
{
    LOG_FUNCTION();
    CSimpleStringA strMsg(true);
    char* buffer = new char[MAX_PATH];
    getcwd(buffer, MAX_PATH);
    strcat(buffer, "\\*");
    DWORD elapsed = 0;
    DWORD dwStart = GetTickCount();
    DWORD dwEnd = GetTickCount();

    VerifySignature(buffer);
    if (m_nonSignedFiles.size() > 0)
    {
        CSimpleStringA fileList = "";
        for (size_t i = 0; i < m_nonSignedFiles.size(); i++)
        {

            fileList += GetFileName(m_nonSignedFiles[i]);
            if (i < m_nonSignedFiles.size() - 1)
                fileList += ",";
        }

        int toDisplay = m_iNonSignedTotal < m_iNonSignedDisplay ? m_iNonSignedTotal : m_iNonSignedDisplay;

        strMsg = CSimpleStringA::Format("共有%d个文件未签名，其中%d个为：%s.",
            m_iNonSignedTotal, toDisplay, fileList.GetData());
    }

    dwEnd = GetTickCount();
    elapsed = dwEnd - dwStart;

    strMsg = strMsg + CSimpleStringA::Format("签名耗时:%dms", elapsed);
    LogWarn(Severity_Low, Error_Unexpect, LOG_WARN_FILE_NOT_TRUSTED, (LPCTSTR)strMsg);
    delete[] buffer;
}

void ResourceWatcherFSM::VerifySignature(const CSimpleStringA& filePath)
{
    HANDLE hFind = NULL;
    WIN32_FIND_DATA fileInfo;
    DWORD64 dwSize = 0;
    hFind = FindFirstFile(filePath, &fileInfo);
    if (hFind == INVALID_HANDLE_VALUE)
        return;

    string strDirPath = filePath;
    if (strDirPath.find("\\dep\\*") != std::string::npos) return;
    do
    {
        if (fileInfo.dwFileAttributes & FILE_ATTRIBUTE_DIRECTORY)
        {
            if (!strcmp(fileInfo.cFileName, ".") || !strcmp(fileInfo.cFileName, ".."))
            {
                //Do nothing for "." and ".." folders
            }
            else
            {
                strDirPath.insert(strDirPath.find("*"), string(fileInfo.cFileName) + "\\");
                VerifySignature(strDirPath.c_str());
                strDirPath = filePath;
            }
        }
        else
        {
            CSimpleStringA fileName = fileInfo.cFileName;
            string strFileName = fileName;
            string strFilePath;

            if(strFileName.empty() 
                || (strFileName.rfind(".dll") != strFileName.length() - 4 
                    && strFileName.rfind(".exe") != strFileName.length() - 4))
                continue;

            strFilePath = strDirPath;
            strFilePath.replace(strFilePath.find("*"), strFilePath.length(), string(fileInfo.cFileName));
            if (!RetrieveDigitalSignatureInfo(strFilePath.c_str()))
            {
                if (m_iNonSignedTotal < m_iNonSignedDisplay)
                {
                    m_nonSignedFiles.push_back(strFilePath.c_str());
                }
                m_iNonSignedTotal++;
            }
        }
    } while (FindNextFile(hFind, &fileInfo));
    FindClose(hFind);
}

CSimpleStringA ResourceWatcherFSM::GetFileName(const CSimpleStringA& filePath)
{
    CSimpleStringA tmp = filePath;
    auto arrPath = tmp.Split('\\');
    int size = arrPath.GetCount();
    return arrPath[size - 1];
}

bool ResourceWatcherFSM::RetrieveDigitalSignatureInfo(const char* pFilePath)
{
    HCERTSTORE hStore = NULL;
    HCRYPTMSG hMsg = NULL;

    WCHAR* wpFilePath = NULL;
    int len = ::MultiByteToWideChar(CP_ACP, 0, pFilePath, -1, NULL, 0);
    if (len > 0) {
        wpFilePath = new wchar_t[len + 1];
        std::memset(wpFilePath, 0, (len + 1) * sizeof(wchar_t));
        ::MultiByteToWideChar(CP_ACP, 0, pFilePath, -1, &wpFilePath[0], len);
    }

    if (CryptQueryObject(CERT_QUERY_OBJECT_FILE,
        wpFilePath,
        CERT_QUERY_CONTENT_FLAG_PKCS7_SIGNED_EMBED,
        CERT_QUERY_FORMAT_FLAG_BINARY,
        0,
        NULL,
        NULL,
        NULL,
        &hStore,
        &hMsg,
        NULL))
    {
        DWORD dwCountSigners = 0;
        DWORD dwcbSz = sizeof(dwCountSigners);
        if (CryptMsgGetParam(hMsg, CMSG_SIGNER_COUNT_PARAM, 0, &dwCountSigners, &dwcbSz))
        {
            if (dwCountSigners != 0)
            {
                dwcbSz = 0;
                CryptMsgGetParam(hMsg, CMSG_SIGNER_INFO_PARAM, 0, NULL, &dwcbSz);
                if (dwcbSz)
                {
                    PCMSG_SIGNER_INFO pSignerInfo = (PCMSG_SIGNER_INFO)new (std::nothrow) BYTE[dwcbSz];
                    if (pSignerInfo)
                    {
                        DWORD dwcbSz2 = dwcbSz;
                        if (CryptMsgGetParam(hMsg, CMSG_SIGNER_INFO_PARAM, 0, pSignerInfo, &dwcbSz) &&
                            dwcbSz == dwcbSz2)
                        {
                            if (VerifyFirstCertificate(hStore, pSignerInfo)
                                || VerifyOtherCertificate(pSignerInfo))

                                delete[] pSignerInfo;

								if (wpFilePath != NULL) {
									delete[] wpFilePath;
									wpFilePath = NULL;
								}
                                return true;
                        }

                        delete[] pSignerInfo;
                        pSignerInfo = NULL;
                    }
                }
            }
        }
    }

    if (hStore != NULL)
    {
        CertCloseStore(hStore, 0);
        hStore = NULL;
    }

    if (hMsg != NULL)
    {
        CryptMsgClose(hMsg);
        hMsg = NULL;
    }

	if (wpFilePath != NULL) {
		delete[] wpFilePath;
		wpFilePath = NULL;
	}

    return false;
}

bool ResourceWatcherFSM::VerifyFirstCertificate(HCERTSTORE hStore, PCMSG_SIGNER_INFO pSignerInfo)
{
    CERT_INFO ci = { 0 };
    ci.Issuer = pSignerInfo->Issuer;
    ci.SerialNumber = pSignerInfo->SerialNumber;

    PCCERT_CONTEXT pCertContext = NULL;

    int c = 0;
    bool ret = false;
    for (;; c++)
    {
        pCertContext = CertFindCertificateInStore(hStore,
            ENCODING, 0, CERT_FIND_SUBJECT_CERT,
            (PVOID)&ci, pCertContext);

        if (!pCertContext)
        {
            break;
        }

        DWORD dwcbSz;
        char* pBuff;
        dwcbSz = CertGetNameString(pCertContext, CERT_NAME_SIMPLE_DISPLAY_TYPE, 0, NULL, NULL, 0);
        if (dwcbSz != 0)
        {
            pBuff = new (std::nothrow) char[dwcbSz];
            if (pBuff)
            {
                if (CertGetNameString(pCertContext, CERT_NAME_SIMPLE_DISPLAY_TYPE, 0, NULL, pBuff, dwcbSz) == dwcbSz)
                {
                    if (!strcmp(pBuff, "China Merchants Bank Co., Ltd") || !strcmp(pBuff, "Microsoft Corporation"))
                        ret = true;
                }

                delete[] pBuff;
                pBuff = NULL;
            }
        }
    }

    if (pCertContext)
    {
        CertFreeCertificateContext(pCertContext);
        pCertContext = NULL;
    }

    return ret;
}

bool ResourceWatcherFSM::VerifyOtherCertificate(PCMSG_SIGNER_INFO pSignerInfo)
{
    int ret = false;
    for (DWORD a = 0; a < pSignerInfo->UnauthAttrs.cAttr; a++)
    {
#ifndef szOID_NESTED_SIGNATURE
#define szOID_NESTED_SIGNATURE              "1.3.6.1.4.1.311.2.4.1"
#endif

        if (pSignerInfo->UnauthAttrs.rgAttr[a].pszObjId &&
            lstrcmpA(pSignerInfo->UnauthAttrs.rgAttr[a].pszObjId, szOID_NESTED_SIGNATURE) == 0)
        {
            HCRYPTMSG hMsg = ::CryptMsgOpenToDecode(X509_ASN_ENCODING | PKCS_7_ASN_ENCODING, 0, 0, NULL, NULL, NULL);
            if (hMsg)
            {
                if (::CryptMsgUpdate(hMsg,
                    pSignerInfo->UnauthAttrs.rgAttr[a].rgValue->pbData,
                    pSignerInfo->UnauthAttrs.rgAttr[a].rgValue->cbData,
                    TRUE))
                {
                    DWORD dwSignerInfo = 0;
                    ::CryptMsgGetParam(hMsg, CMSG_SIGNER_INFO_PARAM, 0, NULL, &dwSignerInfo);
                    if (dwSignerInfo != 0)
                    {
                        PCMSG_SIGNER_INFO pSignerInfo2 = (PCMSG_SIGNER_INFO)new (std::nothrow) BYTE[dwSignerInfo];
                        if (pSignerInfo2)
                        {
                            if (::CryptMsgGetParam(hMsg, CMSG_SIGNER_INFO_PARAM,
                                0, (PVOID)pSignerInfo2, &dwSignerInfo))
                            {
                                CRYPT_DATA_BLOB c7Data;
                                c7Data.cbData = pSignerInfo->UnauthAttrs.rgAttr[a].rgValue->cbData;
                                c7Data.pbData = pSignerInfo->UnauthAttrs.rgAttr[a].rgValue->pbData;

                                //ret = FindAppropriateStoreAndVerifyFirstCertificate(pSignerInfo2, &c7Data);

                                HCERTSTORE hStore = NULL;

                                hStore = CertOpenStore(CERT_STORE_PROV_PKCS7, X509_ASN_ENCODING | PKCS_7_ASN_ENCODING, NULL, 0, &c7Data);
                                ret = hStore && VerifyFirstCertificate(hStore, pSignerInfo2);

                                if (hStore)
                                {
                                    ::CertCloseStore(hStore, CERT_CLOSE_STORE_FORCE_FLAG);
                                    hStore = NULL;
                                }
                            }

                            delete[] pSignerInfo2;
                            pSignerInfo2 = NULL;
                        }
                    }
                }

                ::CryptMsgClose(hMsg);
            }
        }
    }
    return ret;
}

long long GetDirSizeFsm(string dirPath)
{
    long long fileLen = 0;
    long hFile = 0;
    //文件信息
    struct _finddata_t fileinfo;
    string p;
    if ((hFile = _findfirst(p.assign(dirPath).append("\\*").c_str(), &fileinfo)) != -1)
    {
        do
        {
            //如果是目录,迭代之
            //如果不是,加入列表
            if ((fileinfo.attrib & _A_SUBDIR))
            {
                if (strcmp(fileinfo.name, ".") != 0 && strcmp(fileinfo.name, "..") != 0)
                    fileLen += GetDirSizeFsm(p.assign(dirPath).append("\\").append(fileinfo.name));
            }
            else
            {
                fileLen += fileinfo.size;
            }
        } while (_findnext(hFile, &fileinfo) == 0);
        _findclose(hFile);
    }
    return fileLen;
}


struct CmpByValueFromBiggest //从最大的排起
{
    bool operator()(const pair<string, long>& l, const pair<string, long>& r) {
        return l.second > r.second;
    }
};

//unordered_map<string, long> fileSpace;
unordered_map<string, long> fileIncreasedSpace;
vector<pair<string, long>> sortFileIncreasedSpace;
unordered_map<string, long> fileSpace;
vector<pair<string, long>> sortFileSpace;

static bool spaceLock = false;

void ResourceWatcherFSM::CheckDiskFileSpace()
{
    if (spaceLock)
    {
        DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("当前已有硬盘扫描进行中，跳过。");
        return;
    }
    else
    {
        spaceLock = true; //加锁
    }



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

    int lastDiskUsed = 0;
    unsigned long long lastVer = 0;
    int spaceIncrease = 0; //硬盘增长阈值

    spConfigRun->ReadConfigValueHexInt("SpaceInfo", "OptVer", lastVer);
    spConfigRun->ReadConfigValueInt("SpaceInfo", "DiskTotalUsed(GB)", lastDiskUsed);
    spCtSettingConfig->ReadConfigValueInt(GetEntityBase()->GetEntityName(), "DiskUsedIncreaseInt(GB)", spaceIncrease);
    if (spaceIncrease == 0)
    {
        spaceIncrease = 5; //默认阈值5GB
    }

    if (!m_bNeedForceDiskCheck) //是否需要强制全盘扫描 - 硬盘使用过高是会强制
    {
        if (lastVer == m_RvcSysinfo.InstallVersion.GetVersion64())
        {
            if (lastDiskUsed != 0 && ((int)(GetDiskUsedByte() / (1024 * 1024 * 1024)) - lastDiskUsed) < spaceIncrease) //增长值判定
            {
                if (spaceLock)
                {
                    spaceLock = false; //释放锁
                }
                return;
            }
            else
            {
                //降低磁盘扫描频率
                SYSTEMTIME localTime;
                GetLocalTime(&localTime);
                if (m_diskLastWarnHour != localTime.wHour)
                {
                    m_diskLastWarnHour = localTime.wHour;
                    CSmartPointer<IConfigInfo> spConfigRun;
                    ErrorCodeEnum eErr = GetEntityBase()->GetFunction()->OpenConfig(Config_Run, spConfigRun);
                    if (eErr == Error_Succeed) {
                        spConfigRun->WriteConfigValueInt("WarnRecord", "disk", m_diskLastWarnHour);
                    }
                    DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("硬盘增长超过阈值，重点目录扫描！");
                }
                else
                {
                    //DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("磁盘增长最近1小时已扫描一次，暂不扫描。");
                    if (spaceLock)
                    {
                        spaceLock = false; //释放锁
                    }
                    return;
                }
            }
        }
        else
        {
            spConfigRun->WriteConfigValueHexInt("SpaceInfo", "OptVer", m_RvcSysinfo.InstallVersion.GetVersion64());
            DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("新版本，重点目录扫描");
        }
    }
    else
    {
        DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("强制扫描。");
    }
    
    string path = "D:";
    DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("扫描D盘。");
    long long fileLen = 0;
    long hFile = 0;
    //文件信息
    struct _finddata_t fileinfo;
    string p;
    if ((hFile = _findfirst(p.assign(path).append("\\*").c_str(), &fileinfo)) != -1)
    {
        do
        {
            //如果是目录,迭代之
            //如果不是,加入列表
            if ((fileinfo.attrib & _A_SUBDIR))
            {
                if (strcmp(fileinfo.name, ".") != 0 && strcmp(fileinfo.name, "..") != 0)
                    fileLen = GetDirSizeFsm(p.assign(path).append("\\").append(fileinfo.name));
                else
                {
                    continue;
                }
            }
            else
            {
                fileLen = fileinfo.size;
            }


            CSimpleStringA resLen = CSimpleStringA::Format("%lld B", fileLen);
            if (fileLen >= 1024 && fileLen < (1024 * 1024))
            {
                DOUBLE len = (DOUBLE)fileLen / 1024;
                resLen = CSimpleStringA::Format("%.2f KB", len);
            }
            else if (fileLen >= (1024 * 1024) && fileLen < (1024 * 1024 * 1024))
            {
                DOUBLE len = (DOUBLE)fileLen / (1024 * 1024);
                resLen = CSimpleStringA::Format("%.2f MB", len);
            }
            else if (fileLen >= (1024 * 1024 * 1024))
            {
                DOUBLE len = (DOUBLE)fileLen / (1024 * 1024 * 1024);
                resLen = CSimpleStringA::Format("%.2f GB", len);
            }


            CSimpleStringA oldLenStr("");
            long oldLen = 0;
            spConfigRun->ReadConfigValue("SpaceInfo",
                p.assign(path).append("\\").append(fileinfo.name).c_str(), oldLenStr);
            oldLen = atol(oldLenStr.GetData());

            fileIncreasedSpace[p.assign(path).append("\\").append(fileinfo.name)] = (long)(fileLen / (1024 * 1024)) - oldLen; //保存在unordered_map中
            fileSpace[p.assign(path).append("\\").append(fileinfo.name)] = (long)(fileLen / (1024 * 1024));
            DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("[%s] 大小为 [%s]",
                p.assign(path).append("\\").append(fileinfo.name).c_str(), resLen.GetData());

            if (lastVer != m_RvcSysinfo.InstallVersion.GetVersion64())
            {
                spConfigRun->WriteConfigValue("SpaceInfo", p.assign(path).append("\\").append(fileinfo.name).c_str(),
                    CSimpleStringA::Format("%ld MB", (long)(fileLen / (1024 * 1024))));
            }
        } while (_findnext(hFile, &fileinfo) == 0);
        _findclose(hFile);
    }


    //获取version目录下的文件夹大小	
    CSimpleStringA csPath;
    ErrorCodeEnum Error = m_pEntity->GetFunction()->GetPath("RootVer", csPath);   //获取当前版本路劲 例如：C:\Run

    fileLen = 0;
    hFile = 0;
    p = "";
    if ((hFile = _findfirst(p.assign(csPath.GetData()).append("\\*").c_str(), &fileinfo)) != -1)
    {
        do
        {
            //如果是目录,迭代之
            //如果不是,加入列表
            if ((fileinfo.attrib & _A_SUBDIR))
            {
                if (strcmp(fileinfo.name, ".") != 0 && strcmp(fileinfo.name, "..") != 0)
                    fileLen = GetDirSizeFsm(p.assign(csPath.GetData()).append("\\").append(fileinfo.name));
                else
                {
                    continue;
                }
            }
            else
            {
                fileLen = fileinfo.size;
            }


            CSimpleStringA resLen = CSimpleStringA::Format("%lld B", fileLen);
            if (fileLen >= 1024 && fileLen < (1024 * 1024))
            {
                DOUBLE len = (DOUBLE)fileLen / 1024;
                resLen = CSimpleStringA::Format("%.2f KB", len);
            }
            else if (fileLen >= (1024 * 1024) && fileLen < (1024 * 1024 * 1024))
            {
                DOUBLE len = (DOUBLE)fileLen / (1024 * 1024);
                resLen = CSimpleStringA::Format("%.2f MB", len);
            }
            else if (fileLen >= (1024 * 1024 * 1024))
            {
                DOUBLE len = (DOUBLE)fileLen / (1024 * 1024 * 1024);
                resLen = CSimpleStringA::Format("%.2f GB", len);
            }

            CSimpleStringA oldLenStr(""); //MB
            long oldLen = 0;
            spConfigRun->ReadConfigValue("SpaceInfo",
                p.assign(csPath.GetData()).append("\\").append(fileinfo.name).c_str(), oldLenStr);
            oldLen = atol(oldLenStr.GetData());
            fileIncreasedSpace[p.assign(csPath.GetData()).append("\\").append(fileinfo.name)] = (long)(fileLen / (1024 * 1024)) - oldLen; //保存在unordered_map中
            fileSpace[p.assign(csPath.GetData()).append("\\").append(fileinfo.name)] = (long)(fileLen / (1024 * 1024));

            DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("[%s] 大小为 [%s]",
                p.assign(csPath.GetData()).append("\\").append(fileinfo.name).c_str(), resLen.GetData());

            if (lastVer != m_RvcSysinfo.InstallVersion.GetVersion64())
            {
                spConfigRun->WriteConfigValue("SpaceInfo", p.assign(csPath.GetData()).append("\\").append(fileinfo.name).c_str(),
                    CSimpleStringA::Format("%ld MB", (long)(fileLen / (1024 * 1024))));
            }
        } while (_findnext(hFile, &fileinfo) == 0);
        _findclose(hFile);
    }


    //获取rvc目录下的文件夹大小	
    fileLen = 0;
    hFile = 0;
    p = "";
    if ((hFile = _findfirst(p.assign(path).append("\\rvc\\*").c_str(), &fileinfo)) != -1)
    {
        do
        {
            //如果是目录,迭代之
            //如果不是,加入列表
            if ((fileinfo.attrib & _A_SUBDIR))
            {
                if (strcmp(fileinfo.name, ".") != 0 && strcmp(fileinfo.name, "..") != 0)
                    fileLen = GetDirSizeFsm(p.assign(path).append("\\rvc\\").append(fileinfo.name));
                else
                {
                    continue;
                }
            }
            else
            {
                fileLen = fileinfo.size;
            }
            

            CSimpleStringA resLen = CSimpleStringA::Format("%lld B", fileLen);
            if (fileLen >= 1024 && fileLen < (1024 * 1024))
            {
                DOUBLE len = (DOUBLE)fileLen / 1024;
                resLen = CSimpleStringA::Format("%.2f KB", len);
            }
            else if (fileLen >= (1024 * 1024) && fileLen < (1024 * 1024 * 1024))
            {
                DOUBLE len = (DOUBLE)fileLen / (1024 * 1024);
                resLen = CSimpleStringA::Format("%.2f MB", len);
            }
            else if (fileLen >= (1024 * 1024 * 1024))
            {
                DOUBLE len = (DOUBLE)fileLen / (1024 * 1024 * 1024);
                resLen = CSimpleStringA::Format("%.2f GB", len);
            }

            CSimpleStringA oldLenStr("");
            long oldLen = 0;
            spConfigRun->ReadConfigValue("SpaceInfo",
                p.assign(path).append("\\rvc\\").append(fileinfo.name).c_str(), oldLenStr);
            oldLen = atol(oldLenStr.GetData());

            fileIncreasedSpace[p.assign(path).append("\\rvc\\").append(fileinfo.name)] = (long)(fileLen / (1024 * 1024)) - oldLen; //保存在unordered_map中
            fileSpace[p.assign(path).append("\\rvc\\").append(fileinfo.name)] = (long)(fileLen / (1024 * 1024));
            DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("[%s] 大小为 [%s]",
                p.assign(path).append("\\rvc\\").append(fileinfo.name).c_str(), resLen.GetData());

            if (lastVer != m_RvcSysinfo.InstallVersion.GetVersion64())
            {
                spConfigRun->WriteConfigValue("SpaceInfo", p.assign(path).append("\\rvc\\").append(fileinfo.name).c_str(),
                    CSimpleStringA::Format("%ld MB", (long)(fileLen / (1024 * 1024))));
            }
        } while (_findnext(hFile, &fileinfo) == 0);
        _findclose(hFile);
    }


    if (lastVer != m_RvcSysinfo.InstallVersion.GetVersion64())
    {
        //写入硬盘量
        spConfigRun->WriteConfigValueInt("SpaceInfo", "DiskTotalUsed(GB)", GetDiskUsedByte() / (1024 * 1024 * 1024));
        if (spaceLock)
        {
            spaceLock = false; //释放锁
        }
        return; //新版本无需上报文件信息，更新完运行时文件后即可结束
    }

    //获取增量最大的前十文件夹信息
    sortFileIncreasedSpace = vector<pair<string, long>>(fileIncreasedSpace.begin(), fileIncreasedSpace.end());
    sort(sortFileIncreasedSpace.begin(), sortFileIncreasedSpace.end(), CmpByValueFromBiggest());
    int topFileNum = sortFileIncreasedSpace.size();
    if (topFileNum > 10)
    {
        topFileNum = 10;
    }
    DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("变化最大的%d个文件夹信息。", topFileNum);

    fileLen = 0;
    for (int i = 0; i < topFileNum; i++)
    {
        fileLen = sortFileIncreasedSpace[i].second;
        if (fileLen == 0) break;
        CSimpleStringA warn1 = CSimpleStringA::Format("TOP %d: [%s], 增量[%ld]MB",
            i + 1, sortFileIncreasedSpace[i].first.c_str(), sortFileIncreasedSpace[i].second);
        LogWarn(Severity_Low, Error_Resource, LOG_RESOURCEWATCHER_FILE_TOPINCREASED_SPACE, warn1.GetData());
    }


    if (m_bNeedForceDiskCheck)
    {
        //获取空间占用最大前十文件夹信息
        sortFileSpace = vector<pair<string, long>>(fileSpace.begin(), fileSpace.end());
        sort(sortFileSpace.begin(), sortFileSpace.end(), CmpByValueFromBiggest());

        int topFileSize = sortFileSpace.size();
        if (topFileSize > 10)
        {
            topFileSize = 10;
        }
        DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("空间占用最大的%d个文件夹信息。", topFileSize);

        fileLen = 0;
        for (int i = 0; i < topFileSize; i++)
        {
            fileLen = sortFileSpace[i].second;
            if (fileLen == 0) break;
            CSimpleStringA warn2 = CSimpleStringA::Format("空间占用排名 %d: [%s], 大小[%ld]MB",
                i + 1, sortFileSpace[i].first.c_str(), sortFileSpace[i].second);
            LogWarn(Severity_Low, Error_Resource, LOG_RESOURCEWATCHER_FILE_TOPUSED_SPACE, warn2.GetData());
        }

        m_bNeedForceDiskCheck = false;
    }

    if (spaceLock)
    {
        spaceLock = false; //释放锁
    }
}

void ResourceWatcherFSM::GetSystemDiskStatus()
{
    if (m_diskHighPercent <= 0)
    {
        m_diskHighPercent = 90; //默认硬盘告警百分比90%
    }

    ULARGE_INTEGER ulAvailFree, ulTotalBytes, ulTotalFree;
    BOOL ret = GetDiskFreeSpaceEx(NULL, &ulAvailFree, &ulTotalBytes, &ulTotalFree);
    if (ret == 0)
    {
        DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("GetSystemDiskStatus.GetDiskFreeSpaceEx failed(%d).", GetLastError());
        return;
    }

    CSimpleStringA csBinPath;
    ErrorCodeEnum Error = m_pEntity->GetFunction()->GetPath("Bin", csBinPath);   //获取当前终端运行磁盘位置

    DWORD dwAvFree = ulAvailFree.QuadPart / MILLION;
    DWORD dwTotal = ulTotalBytes.QuadPart / MILLION;
    DWORD dwTotalFree = ulTotalFree.QuadPart / MILLION;
    int ratio = dwTotalFree * 100 / dwTotal;

    if ((100 - ratio) > m_diskHighPercent)
    {
        DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("The disk has %d MB(%d%%) available.\n", dwTotalFree, ratio);
        string test(csBinPath.GetData());
        char diskMessage[1024];
        sprintf(diskMessage, "{\"Disk\":\"%c:\",\"total\":\"%0.2f GByte\",\"free ratio\":\"%d%%\"}",
            csBinPath.GetData()[0], (double)dwTotal / 1024, ratio);

        //oilyang@20200526 根据wq建议，降低磁盘空间偏少的告警频率
        //SYSTEMTIME localTime;
        //GetLocalTime(&localTime);
        //if (m_diskLastWarnHour != localTime.wHour) //需要告警时才强制全盘扫描
        //{
        //	m_diskLastWarnHour = localTime.wHour;
        //	CSmartPointer<IConfigInfo> spConfigRun;
        //	ErrorCodeEnum eErr = GetEntityBase()->GetFunction()->OpenConfig(Config_Run, spConfigRun);
        //	if (eErr == Error_Succeed) {
        //		spConfigRun->WriteConfigValueInt("WarnRecord", "disk", m_diskLastWarnHour);
        //	}
        //	//LogWarn(Severity_Low, Error_Resource, LOG_EVT_SELFCHECK_HARDDISK_TOO_HIGH, "Harddisk free space is few.");
        //	LogWarn(Severity_Middle, Error_Resource, LOG_EVT_RESOURCE_HARDDISK_TOO_HIGH, diskMessage);

        //	m_bNeedForceDiskCheck = true;
        //}

        LogWarn(Severity_Middle, Error_Resource, LOG_EVT_RESOURCE_HARDDISK_TOO_HIGH, diskMessage);
        DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM).setResultCode("RTA5A05").setAPI("DiskUsedCheck")(diskMessage);
        m_bNeedForceDiskCheck = true;
    }
    else
    {
        m_bNeedForceDiskCheck = false;
    }
    CheckDiskFileSpaceTask* task4 = new CheckDiskFileSpaceTask(this);
    GetEntityBase()->GetFunction()->PostThreadPoolTask(task4);

}

ULONGLONG ResourceWatcherFSM::GetDiskUsedByte()
{
    ULARGE_INTEGER ulAvailFree, ulTotalBytes, ulTotalFree;
    BOOL ret = GetDiskFreeSpaceEx(NULL, &ulAvailFree, &ulTotalBytes, &ulTotalFree);
    if (ret == 0)
    {
        DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("GetSystemDiskStatus.GetDiskFreeSpaceEx failed(%d).", GetLastError());
        return -1;
    }

    CSimpleStringA csBinPath;
    ErrorCodeEnum Error = m_pEntity->GetFunction()->GetPath("Bin", csBinPath);   //获取当前终端运行磁盘位置
    return ulTotalBytes.QuadPart - ulTotalFree.QuadPart;
}

long long Filetime2Int64(const FILETIME& ftime)
{
    LARGE_INTEGER li;
    li.LowPart = ftime.dwLowDateTime;
    li.HighPart = ftime.dwHighDateTime;
    return li.QuadPart;
}

long long CompareFileTime2(const FILETIME& preTime, const FILETIME& nowTime)
{
    return Filetime2Int64(nowTime) - Filetime2Int64(preTime);
}

void ResourceWatcherFSM::GetSystemCPUStatus()
{
    oldProcessTime.clear();
    newProcessTime.clear();
    processName.clear();
    processCpu.clear();

    FILETIME preIdleTime;
    FILETIME preKernelTime;
    FILETIME preUserTime;
    FILETIME preProcCreateTime;
    FILETIME preProcExitTime;
    FILETIME preProcKernelTime;
    FILETIME preProcUserTime;
    GetSystemTimes(&preIdleTime, &preKernelTime, &preUserTime);

    PROCESSENTRY32 pe32Old;
    pe32Old.dwSize = sizeof(pe32Old);
    //获得系统进程快照的句柄  
    HANDLE hProcessSnapOld = CreateToolhelp32Snapshot(TH32CS_SNAPPROCESS, 0);
    if (hProcessSnapOld == INVALID_HANDLE_VALUE)
    {
        DbgWithLink(LOG_LEVEL_ERROR, LOG_TYPE_SYSTEM)("CreateToolhelp32Snapshot error.");
        return;
    }

    //首先获得第一个进程  
    BOOL bProcessOld = Process32First(hProcessSnapOld, &pe32Old);
    //循环获得所有进程  
    while (bProcessOld)
    {
        //进程名和进程ID  
        HANDLE hProcess = OpenProcess(PROCESS_ALL_ACCESS, false, pe32Old.th32ProcessID);
        GetProcessTimes(hProcess, &preProcCreateTime, &preProcExitTime, &preProcKernelTime, &preProcUserTime);
        oldProcessTime[pe32Old.th32ProcessID] = Filetime2Int64(preProcKernelTime) + Filetime2Int64(preProcUserTime);
        bProcessOld = Process32Next(hProcessSnapOld, &pe32Old);
    }
    CloseHandle(hProcessSnapOld);
    
    // 等待一段时间
    Sleep(1000); // 1000毫秒

    FILETIME idleTime;
    FILETIME kernelTime;
    FILETIME userTime;
    FILETIME ProcCreateTime;
    FILETIME ProcExitTime;
    FILETIME procKernelTime;
    FILETIME procUserTime;
    GetSystemTimes(&idleTime, &kernelTime, &userTime);
    PROCESSENTRY32 pe32New;
    pe32New.dwSize = sizeof(pe32New);
    //获得系统进程快照的句柄  
    HANDLE hProcessSnapNew = CreateToolhelp32Snapshot(TH32CS_SNAPPROCESS, 0);
    if (hProcessSnapNew == INVALID_HANDLE_VALUE)
    {
        DbgWithLink(LOG_LEVEL_ERROR, LOG_TYPE_SYSTEM)("CreateToolhelp32Snapshot error.");
        return;
    }

    //首先获得第一个进程  
    BOOL bProcessNew = Process32First(hProcessSnapNew, &pe32New);
    //循环获得所有进程  
    while (bProcessNew)
    {
        //进程名和进程ID  
        HANDLE hProcess = OpenProcess(PROCESS_ALL_ACCESS, false, pe32New.th32ProcessID);
        GetProcessTimes(hProcess, &ProcCreateTime, &ProcExitTime, &procKernelTime, &procUserTime);
        newProcessTime[pe32New.th32ProcessID] = Filetime2Int64(procKernelTime) + Filetime2Int64(procUserTime);
        processName[pe32New.th32ProcessID] = CSimpleStringA(pe32New.szExeFile);
        bProcessNew = Process32Next(hProcessSnapNew, &pe32New);
    }
    CloseHandle(hProcessSnapNew);

    long long idle = CompareFileTime2(preIdleTime, idleTime);
    long long kernel = CompareFileTime2(preKernelTime, kernelTime);
    long long user = CompareFileTime2(preUserTime, userTime);

    if (kernel + user == 0)
        return;

    //计算总CPU使用率
    double cpuRatio = 100.0 * (kernel + user - idle) / (kernel + user);
    if (m_cpuHighPercent <= 0)
    {
        m_cpuHighPercent = 80; //默认告警线：80%
    }
    if (cpuWarnThreshold <= 0)
    {
        cpuWarnThreshold = 10;  //默认满10次告一次警
    }

    //超过设置的告警线时进行告警
    if (cpuRatio > (double)m_cpuHighPercent)
    {
        cpuWarnTime = cpuWarnTime % cpuWarnThreshold;
        if (cpuWarnTime == 0) //CPU使用率过高达到一定次数告警一次
        {
            //终端进程名称转换
            CSystemRunInfo runInfo = { 0 };
            GetEntityBase()->GetFunction()->GetSystemRunInfo(runInfo);
            for (int i = 0; i < runInfo.strRunningEntityNames.GetCount(); i++) //实体进程的名称默认全为sphost，需转换为对应实体名
            {
                runInfo.strRunningEntityNames[i];
                CEntityRunInfo entityInfo = { 0 };
                GetEntityBase()->GetFunction()->GetEntityRunInfo(runInfo.strRunningEntityNames[i].GetData(), entityInfo);
                processName[entityInfo.dwProcessID] = runInfo.strRunningEntityNames[i];
            }

            //进程占用率计算
            unordered_map<int, long long>::iterator it;
            for (it = newProcessTime.begin(); it != newProcessTime.end(); ++it)
            {
                int tPid = it->first;
                //进程的占用率 = 单位时间间隔里进程的CPU时间片占用 / 单位时间间隔里CPU的整体时间片
                if (oldProcessTime.find(tPid) == oldProcessTime.end())
                {
                    continue;
                }

                if (sysProcName.find(processName[tPid].GetData()) != std::string::npos)
                {
                    continue;
                }

                // 转换为百分比
                if (newProcessTime[tPid] >= oldProcessTime[tPid]) //数据合法
                {
                    double tRatio = 100.0 * (newProcessTime[tPid] - oldProcessTime[tPid]) / (kernel + user);
                    processCpu[tPid] = tRatio;
                }
            }

            //根据CPU使用率对进程从大到小进行排序
            vector<pair<int, double>> vec(processCpu.begin(), processCpu.end());
            sort(vec.begin(), vec.end(), cmp); 
            int len = min(10, vec.size());
            CSimpleStringA procWarn = "";
            for (int i = 0; i < len; ++i) //构建进程的CPU使用告警信息
            {
                procWarn = procWarn + ",\"" + processName[vec[i].first] + "\":\"" + CSimpleStringA::Format("%.2f", processCpu[vec[i].first]) + "%\"";
                DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM) //上传校验信息
                    ("CPU use info. [vec[%d].second]:%.2f; [processCpu[%d]]:%.2f",
                        i, vec[i].second, vec[i].first, processCpu[vec[i].first]);
            }

            //构建告警信息
            CSimpleStringA warn = CSimpleStringA::Format("{\"type\":\"cpu\", \"total_used\":\" %.2f", cpuRatio);
            warn = warn + "%\"" + procWarn + "}";
            if (cpuRatio > 98) //cpu极端异常情况
            {
                LogWarn(Severity_Middle, Error_Resource, LOG_EVT_RESOURCE_CPU_ERROR, warn.GetData());
                DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM).setResultCode("RTA5A02").setAPI("CpuUsedCheck")(warn.GetData());
            }
            else
            {
                LogWarn(Severity_Middle, Error_Resource, LOG_EVT_RESOURCE_CPU_TOO_HIGH, warn.GetData());
                DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM).setResultCode("RTA5A03").setAPI("CpuUsedCheck")(warn.GetData());
            }
        }
        cpuWarnTime++;
    }
}

unsigned long long convert_time_format(const FILETIME* ftime)
{
    LARGE_INTEGER li;

    li.LowPart = ftime->dwLowDateTime;
    li.HighPart = ftime->dwHighDateTime;
    return li.QuadPart;
}

/// 时间转换
static uint64_t file_time_2_utc(const FILETIME* ftime)
{
    LARGE_INTEGER li;

    li.LowPart = ftime->dwLowDateTime;
    li.HighPart = ftime->dwHighDateTime;
    return li.QuadPart;
}

/// 获得CPU的核数
static int get_processor_number()
{
    SYSTEM_INFO info;
    GetSystemInfo(&info);
    return (int)info.dwNumberOfProcessors;
}

int ResourceWatcherFSM::GetCpuUsageRatio(int pid)
{
    //cpu数量
    static int processor_count_ = -1;
    //上一次的时间
    static int64_t last_time_ = 0;
    static int64_t last_system_time_ = 0;

    FILETIME now;
    FILETIME creation_time;
    FILETIME exit_time;
    FILETIME kernel_time;
    FILETIME user_time;
    int64_t system_time;
    int64_t time;
    int64_t system_time_delta;
    int64_t time_delta;

    int cpu = -1;

    if (processor_count_ == -1)
    {
        processor_count_ = get_processor_number();
    }

    GetSystemTimeAsFileTime(&now);

    HANDLE hProcess = OpenProcess(PROCESS_ALL_ACCESS, false, pid);
    if (!GetProcessTimes(hProcess, &creation_time, &exit_time, &kernel_time, &user_time))
    {
        return -1;
    }
    system_time = (file_time_2_utc(&kernel_time) + file_time_2_utc(&user_time))
        / processor_count_;
    time = file_time_2_utc(&now);

    if ((last_system_time_ == 0) || (last_time_ == 0))
    {
        last_system_time_ = system_time;
        last_time_ = time;
        return -1;
    }

    system_time_delta = system_time - last_system_time_;
    time_delta = time - last_time_;

    if (time_delta == 0)
        return -1;

    cpu = (int)((system_time_delta * 100 + time_delta / 2) / time_delta);
    last_system_time_ = system_time;
    last_time_ = time;
    return cpu;

}

double GetMemoryUsageGB(int pid)
{
#ifdef WIN32
    DWORDLONG mem = 0, vmem = 0;
    PROCESS_MEMORY_COUNTERS pmc;
    // get process hanlde by pid
    HANDLE process = OpenProcess(PROCESS_ALL_ACCESS, FALSE, pid);
    if (GetProcessMemoryInfo(process, &pmc, sizeof(pmc)))
    {
        mem = pmc.WorkingSetSize;
        vmem = pmc.PagefileUsage;
    }
    CloseHandle(process);
    // use GetCurrentProcess() can get current process and no need to close handle

    // convert mem from B to GB
    double memGB = mem / (1024.0 * 1024.0 * 1024.0);
    return memGB;

#else
    char file_name[64] = { 0 };
    FILE* fd;
    char line_buff[512] = { 0 };
    sprintf(file_name, "/proc/%d/status", pid);

    fd = fopen(file_name, "r");
    if (nullptr == fd)
        return 0;

    char name[64];
    int vmrss = 0;
    for (int i = 0; i < VMRSS_LINE - 1; i++)
        fgets(line_buff, sizeof(line_buff), fd);

    fgets(line_buff, sizeof(line_buff), fd);
    sscanf(line_buff, "%s %d", name, &vmrss);
    fclose(fd);

    // cnvert VmRSS from KB to MB
    return vmrss / 1024.0;
#endif
}

unordered_map<int, double> processMem;
void ResourceWatcherFSM::GetSystemMemoryStatus()
{
    MEMORYSTATUSEX statex;

    statex.dwLength = sizeof(statex);
    GlobalMemoryStatusEx(&statex);
    double totalMem = statex.ullTotalPhys / (1024.0 * 1024.0 * 1024.0); //GB

    unordered_map<int, CSimpleStringA>::iterator it;
    for (it = processName.begin(); it != processName.end(); ++it)
    {
        int tPid = it->first;
        double tmp = GetMemoryUsageGB(it->first);

        if (tmp > 0.0 && tmp < 100)
        {
            processMem[tPid] = 100 * (tmp / totalMem);
        }
    }
    //return;

    vector<pair<int, double>> vec(processMem.begin(), processMem.end());
    sort(vec.begin(), vec.end(), cmp); //根据CPU使用率从大到小进行排序
    int len = min(10, vec.size());
    CSimpleStringA procWarn = "";
    for (int i = 0; i < len; ++i) //构建进程的CPU使用告警信息
    {
        procWarn = procWarn + ",\"" + processName[vec[i].first] + "\":\"" + CSimpleStringA::Format("%.1f", vec[i].second) + "%\"";
    }

    if (m_memHighPercent <= 0)
    {
        m_memHighPercent = 80; //默认告警百分比80%
    }

    if (memWarnThreshold <= 0)
    {
        memWarnThreshold = 10; //默认告警阈值10次
    }

    if (statex.dwMemoryLoad > m_memHighPercent)
    {
        memWarnTime = memWarnTime % memWarnThreshold;
        if (memWarnTime == 0) //每达到阈值告警一次
        {
            CSimpleStringA warn = CSimpleStringA::Format("{\"type\":\"mem\", \"total\":\"%.1f GByte\",\"total_used\":\" %d%%\"", totalMem, statex.dwMemoryLoad);
            warn = warn + procWarn + "}";
            LogWarn(Severity_Middle, Error_Resource, LOG_EVT_RESOURCE_MEMORY_TOO_HIGH, warn.GetData());
            DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM).setResultCode("RTA5A04").setAPI("MemUsedCheck")(warn.GetData());
        }
        memWarnTime++;
    }
}

void ResourceWatcherFSM::DetectWallpaperAndWarn()
{
	//////////////////////////////////////////////////////////////////////////
	CSmartPointer<IConfigInfo> spCtSettingConfig;
	GetEntityBase()->GetFunction()->OpenConfig(Config_CenterSetting, spCtSettingConfig);
	int value(0);
	spCtSettingConfig->ReadConfigValueInt(GetEntityBase()->GetEntityName(), "MakeSureCMBWallPaper", value);
	if (!value) {
		return;
    }
    bool wallpapaerSetCMD = true;
    const bool isWow64 = (osutil_is32r64_platform() == 1);
	DWORD dwFlag = KEY_READ | KEY_QUERY_VALUE | KEY_ENUMERATE_SUB_KEYS;
	if (isWow64) {
		dwFlag |= KEY_WOW64_64KEY;
	}
    bool wellDone = false;
	CSimpleStringA regeditValue(true);
	HKEY hKey;
	LONG lResult = RegOpenKeyEx(HKEY_CURRENT_USER,"Control Panel\\Desktop", 0, dwFlag, &hKey);
	if (lResult == ERROR_SUCCESS) {
		DWORD dwType = REG_SZ;
		DWORD dwSize = MAX_PATH * sizeof(TCHAR);
		TCHAR szValue[MAX_PATH + 1] = { 0 };
		memset(szValue, '\0', MAX_PATH + 1);
		lResult = RegQueryValueEx(hKey, "Wallpaper", NULL, &dwType, (LPBYTE)szValue, &dwSize);
		if (lResult == ERROR_SUCCESS) {
			//CSimpleStringA strMsg = CSimpleStringA::Format("{\"subject\":\"wallpaper_path\",\"value\":\"%s\"}", szValue);
			//LogWarn(Severity_Low, Error_Debug, LOG_INFO_DESKTOP_WALLPAPER_PATH, strMsg);
            regeditValue = szValue;
            wellDone = true;
		}
		else {
			CSimpleStringA strMsg = CSimpleStringA::Format("{\"subject\":\"wallpaper_path\",\"error\":\"RegQueryValueEx for Wallpaper returned %u, GLE=%u\"}", lResult, GetLastError());
			LogWarn(Severity_Low, Error_Unexpect, LOG_WARN_DESKTOP_WALLPAPER_PATH_FETCHFAILE, strMsg);
		}
	}
	else {
		CSimpleStringA strMsg = CSimpleStringA::Format("{\"subject\":\"wallpaper_path\",\"error\":\"RegOpenKeyEx for Desktop returned %u, GLE=%u\"}", lResult, GetLastError());
		LogWarn(Severity_Low, Error_Unexpect, LOG_WARN_DESKTOP_WALLPAPER_PATH_FETCHFAILE, strMsg);
	}
    RegCloseKey(hKey);


	CSimpleStringA RVCWallpaperName("WallPaper1920.png");
    if (wellDone && !regeditValue.IsNullOrEmpty() && regeditValue.IndexOf(RVCWallpaperName) != -1 && ExistsFileA(regeditValue)) {
        wallpapaerSetCMD = false;
        DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("alreay set wallpaper.");
    }

	if (wallpapaerSetCMD && wellDone) {
		CSimpleStringA resWallPaper(true), rvcWallPaper(true);
		this->GetEntityBase()->GetFunction()->GetPath("Base", resWallPaper);
		this->GetEntityBase()->GetFunction()->GetPath("rvc", rvcWallPaper);
		if (!resWallPaper.IsNullOrEmpty()) {
			resWallPaper += SPLIT_SLASH_STR;
			resWallPaper += "res\\Media\\";
			resWallPaper += RVCWallpaperName;
		}
		if (!rvcWallPaper.IsNullOrEmpty()) {
			rvcWallPaper += SPLIT_SLASH_STR;
			rvcWallPaper += "Resources";
			if (!ExistsDirA(rvcWallPaper)) { CreateDirA(rvcWallPaper, TRUE); }
			rvcWallPaper += "\\";
			rvcWallPaper += RVCWallpaperName;
		}

		CSimpleStringA sysWallPaper("C:\\Windows\\Web\\Wallpaper");
		if (!ExistsDirA(sysWallPaper)) { CreateDirA(sysWallPaper, TRUE); }
		sysWallPaper += "\\";
		sysWallPaper += RVCWallpaperName;

		if (ExistsFileA(resWallPaper)) {
			if (!ExistsFileA(rvcWallPaper)) { CopyFileA(resWallPaper, rvcWallPaper, TRUE); }
			if (!ExistsFileA(sysWallPaper)) { CopyFileA(resWallPaper, sysWallPaper, TRUE); }
		}

		CSimpleStringA aimWallPaper(sysWallPaper);
		if (!ExistsFileA(aimWallPaper) && ExistsFileA(rvcWallPaper)) { aimWallPaper = rvcWallPaper; }

		if (ExistsFileA(aimWallPaper)) {
			dwFlag = KEY_WRITE;
			if (isWow64) {
				dwFlag |= KEY_WOW64_64KEY;
			}
			lResult = RegOpenKeyEx(HKEY_CURRENT_USER, "Control Panel\\Desktop", 0, dwFlag, &hKey);
			if (lResult == ERROR_SUCCESS) {
				lResult = RegSetValueExA(hKey, "Wallpaper", 0, REG_SZ, (const BYTE*)aimWallPaper.GetData(), aimWallPaper.GetLength()+1);
				if (lResult == ERROR_SUCCESS) {
					LogWarn(Severity_Low, Error_Debug, LOG_WARN_DESKTOP_WALLPAPER_PATH_SET_SUCC
						, CSimpleStringA::Format("RegSetValueExA for Wallpaper with %s succ!", aimWallPaper.GetData()));
				}
				else
				{
					DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM).setResultCode("RTA5A0F").setAPI(__FUNCTION__)
						("RegSetValueExA for Shell with %s failed: %d", aimWallPaper.GetData(), lResult);
					LogWarn(Severity_Middle, Error_Unexpect, LOG_WARN_DESKTOP_WALLPAPER_PATH_SET_FAILED
						, CSimpleStringA::Format("RegSetValueExA for Wallpaper with %s failed: %d", aimWallPaper.GetData(), lResult));
				}
			}
			else
			{
				DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM).setResultCode("RTA5A0F").setAPI(__FUNCTION__)
					("RegOpenKeyEx for write %s failed: %d", aimWallPaper.GetData(), lResult);
				LogWarn(Severity_Middle, Error_Unexpect, LOG_WARN_DESKTOP_WALLPAPER_PATH_SET_FAILED
					, CSimpleStringA::Format("RegOpenKeyEx for write %s failed: %d", aimWallPaper.GetData(), lResult));
			}
			RegCloseKey(hKey);
        }
        else {
			LogWarn(Severity_Middle, Error_Unexpect, LOG_WARN_DESKTOP_WALLPAPER_PATH_SET_FAILED
				, CSimpleStringA::Format("WallPaper file %s is not exist", aimWallPaper.GetData()));
        }
	}
}

void ResourceWatcherFSM::InitCustomAutoStartFileSheet()
{
	CSmartPointer<IConfigInfo> spCtSettingConfig;
	GetEntityBase()->GetFunction()->OpenConfig(Config_CenterSetting, spCtSettingConfig);
	CSimpleStringA strFileInterestSheet(true);
	spCtSettingConfig->ReadConfigValue(GetEntityBase()->GetEntityName(), "AutoStartUserFileSheet", strFileInterestSheet);
	if (!strFileInterestSheet.IsNullOrEmpty()) {
		auto fileNames = strFileInterestSheet.Split('|');
		if (fileNames.GetCount() > 0) {
			for (int i = 0; i < fileNames.GetCount(); ++i) {
				DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("AutoStartUserFileSheet[%s]", fileNames[i].GetData());
				keyUserlist.push_back(fileNames[i].GetData());
			}
		}
	}
	strFileInterestSheet.Clear();
	spCtSettingConfig->ReadConfigValue(GetEntityBase()->GetEntityName(), "AutoStartPubFileSheet", strFileInterestSheet);
	if (!strFileInterestSheet.IsNullOrEmpty()) {
		auto fileNames = strFileInterestSheet.Split('|');
		if (fileNames.GetCount() > 0) {
			for (int i = 0; i < fileNames.GetCount(); ++i) {
				DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("AutoStartPubFileSheet[%s]", fileNames[i].GetData());
				keyPublist.push_back(fileNames[i].GetData());
			}
		}
	}
	//int value(0);
 //   spCtSettingConfig->ReadConfigValueInt(GetEntityBase()->GetEntityName(), "DeleteCustomAutoStartFile", value);
	//if (!!value) {
	//	DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("Get DeleteCustomAutoStartFile execute flag from CenterSettings");
	//	flag4DeleteKeyAutoStartFile = !!value;
	//}
}

void ResourceWatcherFSM::InitUserInfo()
{
	DWORD dwSessionId = WTSGetActiveConsoleSessionId();
	LPTSTR pBuffer = NULL;
	DWORD dwBufferLen;
	BOOL bRes = WTSQuerySessionInformation(WTS_CURRENT_SERVER_HANDLE, dwSessionId, WTSUserName, &pBuffer, &dwBufferLen);
	if (bRes)
	{
		m_strLoginedUserName = pBuffer;
		DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("Current logined user name:%s", m_strLoginedUserName.GetData());
    }
    else {
		DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("WTSQuerySessionInformation failed, GLE=%u", GetLastError());
    }
	if (pBuffer) {
		WTSFreeMemory(pBuffer);
	}
}

void ResourceWatcherFSM::ToListCurrentUserStartupFile(const std::string& userDirPath, std::vector<std::string>& files, std::vector<std::string>& keyfiles)
{
    std::string fulPath(userDirPath);
    fulPath += "\\AppData\\Roaming\\Microsoft\\Windows\\Start Menu\\Programs\\Startup";
    files.clear();
    keyfiles.clear();
    if (ExistsDirA(fulPath.c_str())) {
		auto arr = fileutil_get_sub_files(fulPath.c_str());
		if (arr != NULL) {
			for (int i = 0; i < arr->nelts; ++i) {
				char* file = ARRAY_IDX(arr, i, char*);
				char* filename = strrchr(file, '\\');
				if (filename != NULL) { filename += 1; }
				else { filename = file; }
                files.push_back(std::string(filename));
			}
			toolkit_array_free2(arr);
		}

        for (auto kt = keyUserlist.cbegin(); kt != keyUserlist.cend(); ++kt) {
            std::string sub_file(fulPath);
            sub_file += "\\";
            sub_file += kt->c_str();
            if (ExistsFileA(sub_file.c_str())) {
                keyfiles.push_back(*kt);
            }
        }
    }
}

void ResourceWatcherFSM::GetCommDesktopDirectory(CSimpleStringA& outDir)
{
	outDir.Clear();
	LPITEMIDLIST lp;
	CHAR lstr[MAX_PATH] = "";
	HRESULT hr = SHGetSpecialFolderLocation(0, CSIDL_COMMON_DESKTOPDIRECTORY, &lp);
	if (SUCCEEDED(hr)) {
		memset(lstr, 0, strlen(lstr));
		SHGetPathFromIDListA(lp, lstr);
		outDir = lstr;
		DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("CSIDL_COMMON_DESKTOPDIRECTORY: %s", outDir.GetData());
	}
	else {
		DbgWithLink(LOG_LEVEL_ERROR, LOG_TYPE_SYSTEM).setAPI(__FUNCTION__)("SHGetSpecialFolderLocation for CSIDL_COMMON_DESKTOPDIRECTORY failed:%u", hr);
        outDir = "C:\\Users\\Public\\Desktop";
	}
	return;
}

void ResourceWatcherFSM::GetUserDesktopDirectory(CSimpleStringA& outDir)
{
    outDir.Clear();
	LPITEMIDLIST lp;
	CHAR lstr[MAX_PATH] = "";
    HRESULT hr = SHGetSpecialFolderLocation(0, CSIDL_DESKTOP, &lp);
	if (SUCCEEDED(hr)) {
		memset(lstr, 0, strlen(lstr));
		SHGetPathFromIDListA(lp, lstr);
        outDir = lstr;
		DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("CSIDL_DESKTOP: %s", outDir.GetData());
    }
    else {
        DbgWithLink(LOG_LEVEL_ERROR, LOG_TYPE_SYSTEM).setAPI(__FUNCTION__)("SHGetSpecialFolderLocation for CSIDL_DESKTOP failed:%u", hr);
		if (!m_strLoginedUserName.IsNullOrEmpty()) {
			CSimpleStringA desktopFullPath = CSimpleStringA::Format("C:\\Users\\%s\\Desktop", m_strLoginedUserName.GetData());
			outDir = desktopFullPath;
		}
		else {
			DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM).setAPI(__FUNCTION__)("LoginedUserName is empty.");
		}
    }
	return;
}

bool ResourceWatcherFSM::IsDesktopIconExist(CSimpleStringA& strPath)
{
	CSimpleStringA s(true);
	GetUserDesktopDirectory(s);
	if (!s.IsNullOrEmpty()) {
		s += "\\可视柜台.lnk";
		strPath = s.GetData();
		return !!ExistsFileA(s);
	}
	return false;
}

void ResourceWatcherFSM::GetCommStartupDirectory(CSimpleStringA& outDir)
{
	outDir.Clear();
	LPITEMIDLIST lp;
	CHAR lstr[MAX_PATH] = "";
	HRESULT hr = SHGetSpecialFolderLocation(0, CSIDL_COMMON_STARTUP, &lp);
	if (SUCCEEDED(hr)) {
		memset(lstr, 0, strlen(lstr));
		SHGetPathFromIDListA(lp, lstr);
		outDir = lstr;
		DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("CSIDL_COMMON_STARTUP: %s", outDir.GetData());
	}
	else {
		DbgWithLink(LOG_LEVEL_ERROR, LOG_TYPE_SYSTEM).setAPI(__FUNCTION__)("SHGetSpecialFolderLocation for CSIDL_COMMON_STARTUP failed:%u", hr);
        outDir = STARTUP_DIR_FULL_PATH;
	}
	return;
}

void ResourceWatcherFSM::GetUserStartupDirectory(CSimpleStringA& outDir)
{
	outDir.Clear();
	LPITEMIDLIST lp;
	CHAR lstr[MAX_PATH] = "";
    HRESULT hr = SHGetSpecialFolderLocation(0, CSIDL_STARTUP, &lp);
	if (SUCCEEDED(hr)) {
		memset(lstr, 0, strlen(lstr));
		SHGetPathFromIDListA(lp, lstr);
        outDir = lstr;
		DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("CSIDL_STARTUP: %s", outDir.GetData());
    }
    else {
		DbgWithLink(LOG_LEVEL_ERROR, LOG_TYPE_SYSTEM).setAPI(__FUNCTION__)("SHGetSpecialFolderLocation for CSIDL_STARTUP failed:%u", hr);
		if (!m_strLoginedUserName.IsNullOrEmpty()) {
			CSimpleStringA startMenuFullPath = CSimpleStringA::Format("C:\\Users\\%s\\AppData\\Roaming\\Microsoft\\Windows\\Start Menu\\Programs\\Startup", m_strLoginedUserName.GetData());
			outDir = startMenuFullPath;
		}
		else {
			DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM).setAPI(__FUNCTION__)("LoginedUserName is empty.");
		}
    }
	return;
}

bool ResourceWatcherFSM::IsStartupIconExist(CSimpleStringA& strPath)
{
	CSimpleStringA s(true);
    GetUserStartupDirectory(s);
	if (!s.IsNullOrEmpty()) {
        s += "\\";
		s += STRATUP_FILENAME_FROM_SCRIPTS;
		strPath = s.GetData();
		return !!ExistsFileA(s);
	}
	return false;
}

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 FetchSoftewareInstall(vector<SetupSoftInfo>& stupInfo, DWORD& dwInitFlag)
{
    DWORD dwFlag = KEY_READ | KEY_QUERY_VALUE | KEY_ENUMERATE_SUB_KEYS;
    if (dwInitFlag == 0 && osutil_is32r64_platform() == 1) {
        dwInitFlag = 1;
        DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("with KEY_WOW64_64KEY");
        dwFlag |= KEY_WOW64_64KEY;
    }
    HKEY hKey;
    DWORD dwCount = MAX_PATH;
    LONG lResult = RegOpenKeyEx(dwInitFlag != 2 ? HKEY_LOCAL_MACHINE : HKEY_CURRENT_USER, "SOFTWARE\\Microsoft\\Windows\\CurrentVersion\\Uninstall", 0, dwFlag, &hKey);
    if (lResult == ERROR_SUCCESS) {
        if (RegQueryInfoKey(hKey, NULL, NULL, NULL, &dwCount, NULL, NULL, NULL, NULL, NULL, NULL, NULL) == ERROR_SUCCESS) {
            for (int i = 0; i < (int)dwCount; i++) {
                DWORD dwRegSize = MAX_PATH;
                TCHAR szValue[MAX_PATH + 1] = { 0 };
                memset(szValue, '\0', MAX_PATH + 1);
                RegEnumKeyEx(hKey, i, szValue, &dwRegSize, NULL, NULL, NULL, NULL);
                DWORD dwType;
                HKEY hSubKey;
                if (RegOpenKeyEx(hKey, szValue, NULL, KEY_READ, &hSubKey) == ERROR_SUCCESS)
                {
                    SetupSoftInfo info;
                    info.displayName = szValue;
                    info.quietFalg = info.systemCompoentFalg = false;

                    TCHAR regBufferValue[MAX_PATH] = { 0 };
                    dwRegSize = MAX_PATH;
                    RegQueryValueEx(hSubKey, "DisplayName", 0, &dwType, (LPBYTE)regBufferValue, &dwRegSize);
                    if (strcmp(regBufferValue, "") != 0) {
                        info.displayName = regBufferValue;//软件名称
                    }

                    dwRegSize = MAX_PATH;
                    memset(regBufferValue, '\0', MAX_PATH);
                    RegQueryValueEx(hSubKey, "DisplayVersion", 0, &dwType, (LPBYTE)regBufferValue, &dwRegSize);
                    info.displayVersion = regBufferValue;    //版本

                    /*
                    dwRegSize = MAX_PATH;
                    memset(regBufferValue, '\0', MAX_PATH);
                    RegQueryValueEx(hSubKey, "Publisher", 0, &dwType, (LPBYTE)regBufferValue, &dwRegSize);
                    info.publisher = regBufferValue;//发行商

                    dwRegSize = MAX_PATH;
                    memset(regBufferValue, '\0', MAX_PATH);
                    // 判断是否能在注册表中获取到安装时间, 否取子项创建时间
                    if (RegQueryValueEx(hSubKey, "InstallDate", 0, &dwType, (LPBYTE)regBufferValue, &dwRegSize) == ERROR_SUCCESS)
                    {
                        info.installDate = regBufferValue;
                    }
                    else
                    {
                        FILETIME fileLastTime;
                        RegQueryInfoKey(hSubKey, NULL, NULL, NULL, NULL, NULL, NULL, NULL,NULL, NULL, NULL, &fileLastTime);
                        SYSTEMTIME sTime, stLocal;
                        FileTimeToSystemTime(&fileLastTime, &sTime);
                        SystemTimeToTzSpecificLocalTime(NULL, &sTime, &stLocal);
                        TCHAR tchTime[MAX_PATH] = { 0 };
                        _stprintf(tchTime, "%d%02d%02d", stLocal.wYear, stLocal.wMonth, stLocal.wDay);
                        info.installDate = tchTime;
                    }
                    dwRegSize = MAX_PATH;
                    memset(regBufferValue, '\0', MAX_PATH);
                    RegQueryValueEx(hSubKey, "UninstallString", 0, &dwType, (LPBYTE)regBufferValue, &dwRegSize);
                    info.uninstallString = regBufferValue;//卸载命令及参数

                    dwRegSize = MAX_PATH;
                    memset(regBufferValue, '\0', MAX_PATH);
                    RegQueryValueEx(hSubKey, "QuietUninstallString", 0, &dwType, (LPBYTE)regBufferValue, &dwRegSize);
                    if (strcmp(regBufferValue, "") != 0)
                    {
                        info.uninstallString = regBufferValue;
                        info.quietFalg = true;
                    }

                    do
                    {
                        DWORD dwType = REG_DWORD;
                        DWORD dwValue = 0;
                        DWORD dwSize = sizeof(DWORD);
                        lResult = RegQueryValueExA(hSubKey, "SystemComponent", NULL, &dwType, (LPBYTE)&dwValue, &dwSize);
                        if (dwValue == 1) {
                            info.systemCompoentFalg = true;
                        }
                    } while (false);
                    */
                    dwRegSize = MAX_PATH;
                    memset(regBufferValue, '\0', MAX_PATH);
                    // 取ParentKeyName键值,判断是否是补丁信息, 是补丁信息键值为"OperatingSystem"
                    RegQueryValueEx(hSubKey, "ParentKeyName", 0, &dwType, (LPBYTE)regBufferValue, &dwRegSize);
                    if (info.displayName != "" && (0 != strcmp(regBufferValue, "OperatingSystem"))) //判断是否是补丁信息
                    {
                        stupInfo.push_back(info);
                    }

                    RegCloseKey(hSubKey);
                }
            }
        }
    }
    RegCloseKey(hKey);
}

#endif // _MSC_VER end硬件资源监控相关系统功能 CPU、内存、硬盘、网络wifi

#ifdef RVC_OS_LINUX
static bool spaceLock = false;

void ResourceWatcherFSM::CheckDiskFileSpace()
{
    if (spaceLock)
    {
        DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("当前已有硬盘扫描进行中，跳过。");
        return;
    }
    else
    {
        spaceLock = true; //加锁
    }

    //获取opt文件夹下的文件占用信息
    FILE* fp = NULL;
    CSimpleStringA cmd = "du -h -s /opt/* | sort -rn | head";
    if ((fp = popen(cmd.GetData(), "r")) == NULL) {
        DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("popen failed:%d", GetLastError());
        return;
    }

    char buf[1024] = { 0 };
    CSimpleStringA warnMsg(true);
    while (fgets(buf, sizeof(buf), fp))
    {
        warnMsg = warnMsg + "|" + buf;
    }
    if (warnMsg.GetLength() > 0)
    {
        LogWarn(Severity_Low, Error_Resource, LOG_RESOURCEWATCHER_FILE_TOPUSED_SPACE, warnMsg.GetData()); //告警opt下的文件夹
    }
    pclose(fp);

    //获取opt/rvc文件夹下的文件占用信息
    FILE* fp2 = NULL;
    CSimpleStringA cmd2 = "du -h -s /opt/rvc/* | sort -rn | head";
    if ((fp2 = popen(cmd2.GetData(), "r")) == NULL) {
        DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("popen failed:%d", GetLastError());
        return;
    }

    CSimpleStringA warnMsg2(true);
    char buf2[1024] = { 0 };
    while (fgets(buf2, sizeof(buf2), fp2))
    {
        warnMsg2 = warnMsg2 + "|" + buf2;
    }
    if (warnMsg2.GetLength() > 0)
    {
        LogWarn(Severity_Low, Error_Resource, LOG_RESOURCEWATCHER_FILE_TOPUSED_SPACE, warnMsg2.GetData()); //告警opt/rvc下的文件夹
    }
    pclose(fp2);

    if (spaceLock)
    {
        spaceLock = false; //释放锁
    }
}
#endif // RVC_OS_LINUX


ErrorCodeEnum ResourceWatcherFSM::CatchSystemBasicInfo(SystemBasicInfo& info)
{
#if defined(RVC_OS_WIN)
    //通过输入 ‘Get-CimInstance -ClassName Win32_ComputerSystemProduct’ 指令获取）
	int ret = 0;
	RawSMBIOSData* Smbios;
	dmi_header* h = NULL;
	int flag = 1;

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

		DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("Function failed!");
		return Error_Unexpect;
	}

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

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

        DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("Function failed!");
		delete[]buf;
		return Error_Unexpect;
	}

	Smbios = (RawSMBIOSData*)buf;

	BYTE* p = Smbios->SMBIOSTableData;

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

        DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("Smbios length error");
		delete[]buf;
		return Error_Unexpect;
	}

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

		if (h->type == 1)
		{
            info.strManufacturer = dmi_string(h, p[0x4]);
			info.strProductName = dmi_string(h, p[0x5]);
			info.strSerialNumber = dmi_string(h, p[0x7]);
			break;
		}
		p += h->length;
		while ((*(WORD*)p) != 0) p++;
		p += 2;
	}
	delete[]buf;
    return Error_Succeed;
#else
    CSimpleStringA runCfgPath;
    ErrorCodeEnum errCode = GetEntityBase()->GetFunction()->GetPath("RunCfg", runCfgPath);
    if (runCfgPath.IsNullOrEmpty()) return Error_Null;
    CSimpleStringA storeFilePath = runCfgPath + SPLIT_SLASH_STR + "SMBIOSData.txt";

    if (!ExistsFileA(storeFilePath)) {
        RemoveFileA(storeFilePath);
    }

    std::string succStr, errStr;
    std::string runStr("dmidecode -t system > ");
    runStr += storeFilePath.GetData();
    if (!SP::Module::Util::ShellExecute(runStr, succStr, errStr)) {
        DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("execute '%s' failed!", runStr.c_str());
        if (!ExistsFileA(storeFilePath)) {
            RemoveFileA(storeFilePath);
        }
        return Error_Unexpect;
    }

    do {
        std::string succStr, errStr;
        std::string runStr("awk -F ':' '(NR>=7)&&(NR<=14)&&($0~\"Manufacturer\"){print$2}' ");
        runStr += storeFilePath.GetData();
        if (SP::Module::Util::ShellExecute(runStr, succStr, errStr)) {
            info.strManufacturer = SP::Utility::ToTrim(succStr).c_str();
        }
        else
        {
            succStr = "";
            DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("fetch 'Manufacturer' failed!");
        }
    } while (false);

    do {
        std::string succStr, errStr;
        std::string runStr("awk -F ':' '(NR>=7)&&(NR<=14)&&($0~\"Product Name\"){print$2}' ");
        runStr += storeFilePath.GetData();
        if (SP::Module::Util::ShellExecute(runStr, succStr, errStr)) {
            info.strProductName = SP::Utility::ToTrim(succStr).c_str();
        }
        else
        {
            succStr = "";
            DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("fetch 'Product Name' failed!");
        }
    } while (false);

    do {
        std::string succStr, errStr;
        std::string runStr("awk -F ':' '(NR>=7)&&(NR<=14)&&($0~\"Serial Number\"){print$2}' ");
        runStr += storeFilePath.GetData();
        if (SP::Module::Util::ShellExecute(runStr, succStr, errStr)) {
            info.strSerialNumber = SP::Utility::ToTrim(succStr).c_str();
        }
        else
        {
            succStr = "";
            DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("fetch 'Serial Number' failed!");
        }
    } while (false);

    if (!ExistsFileA(storeFilePath)) {
        RemoveFileA(storeFilePath);
    }
    return Error_Succeed;
#endif //RVC_OS_WIN
}

void ResourceWatcherFSM::AlarmSystemBasicInfo()
{
    SystemBasicInfo info;
    if (Error_Succeed == CatchSystemBasicInfo(info)) {
        CSimpleStringA strResult("{");
        if (!info.strManufacturer.IsNullOrEmpty()) {
            strResult += CSimpleStringA::Format("\"Manufacturer\":\"%s\"", info.strManufacturer.GetData());
        }
        if (!info.strProductName.IsNullOrEmpty()) {
            if (strResult.GetLength() > 1) {
                strResult += ", ";
            }
            strResult += CSimpleStringA::Format("\"Product Name\":\"%s\"", info.strProductName.GetData());
        }
        if (!info.strSerialNumber.IsNullOrEmpty()) {
            if (strResult.GetLength() > 1) {
                strResult += ", ";
            }
            strResult += CSimpleStringA::Format("\"Serial Number\":\"%s\"", info.strSerialNumber.GetData());
        }
        strResult += "}";
        DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM).setAPI("InfoAboutManufacturer")(strResult.GetData());
    }
}

BOOL ResourceWatcherFSM::DetectIsFirstRunAtBoot()
{
	CSystemRunInfo runInfo = { 0 };
	ErrorCodeEnum ec = GetEntityBase()->GetFunction()->GetSystemRunInfo(runInfo);
	if (ec == Error_Succeed) {
		CBootInfo bootInfo = { 0 };
		CSmallDateTime dateTime;
		DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("systemRunInfo time: %s", (LPCTSTR)runInfo.tmStart.ToTimeString());
		ec = GetEntityBase()->GetFunction()->GetRebootInfo(/*runInfo.tmStart*/dateTime, bootInfo);
		DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("bootInfor time: %s", (LPCTSTR)bootInfo.tmStart.ToTimeString());
        tk_systime_t sy_t;
		SYSTEMTIME systemTime;
        if (0 == osutil_system_boot_time(&sy_t)) {
			systemTime.wYear = sy_t.year;
			systemTime.wMonth = sy_t.month;
			systemTime.wDayOfWeek = sy_t.dayofweek;
			systemTime.wDay = sy_t.day;
			systemTime.wHour = sy_t.hour;
			systemTime.wMinute = sy_t.minute;
			systemTime.wSecond = sy_t.second;
			systemTime.wMilliseconds = sy_t.milli_seconds;
			CSmallDateTime systemBootTime;
			systemBootTime.FromSystemTime(systemTime);

			if (systemBootTime > bootInfo.tmStart) {
				std::map<std::string, std::string> srcData;
				CSimpleStringA strData = CSimpleStringA::Format("{\"AppLastStartTime\":\"%s\",\"AppStartTime\":\"%s\",\"OSStartTime\":\"%s\"}"
					, (LPCTSTR)bootInfo.tmStart.ToTimeString(), (LPCTSTR)runInfo.tmStart.ToTimeString(), systemBootTime.ToTimeString().GetData());
				LogWarn(Severity_Low, Error_Debug, LOG_RESOURCEWATCHER_FIRST_RUN_AFTER_BOOT, strData.GetData());

				ErrorCodeEnum eRet = GetEntityBase()->GetFunction()->SetSysVar(SYSVAR_FRAMEWORK_FIRST_BOOT, SYSVAR_FRAMEWORK_FIRST_BOOT_YES);
				if (eRet != Error_Succeed) {
					DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("Set %s with %s failed: %d", SYSVAR_FRAMEWORK_FIRST_BOOT, SYSVAR_FRAMEWORK_FIRST_BOOT_YES, eRet);
				}

                return TRUE;
			}
        }
	}
    GetEntityBase()->GetFunction()->SetSysVar(SYSVAR_FRAMEWORK_FIRST_BOOT, SYSVAR_FRAMEWORK_FIRST_BOOT_NO);
    return FALSE;
}

void ResourceWatcherFSM::DetectSoftwareInstallStatus()
{
	CSmartPointer<IConfigInfo> spCtSettingConfig;
	GetEntityBase()->GetFunction()->OpenConfig(Config_CenterSetting, spCtSettingConfig);
	CSimpleStringA strSoftwaresNames[MAX_SOFTWARE_INSTALLED_DETECT_COUNT];
	CSimpleStringA strSoftwaresVers[MAX_SOFTWARE_INSTALLED_DETECT_COUNT];
	int nNameCounts = 0;
	for (int i = 0; i < MAX_SOFTWARE_INSTALLED_DETECT_COUNT; i++) {
		strSoftwaresNames[i] = "";
		strSoftwaresVers[i] = "";
        CSimpleStringA item = CSimpleStringA::Format(SECNAME_SFINSTALL, i);
		CSimpleStringA value(true);
		spCtSettingConfig->ReadConfigValue(GetEntityBase()->GetEntityName(), item, value);
		if (value.IsNullOrEmpty()) {
			break;
		}
		if (value.IndexOf("#") != -1) {
			/** CSimpleString会带Trim操作，在这里不适用  [Gifur@202485]*/
			auto items = SP::Utility::Split(std::string(value.GetData()), '#');
			strSoftwaresNames[i] = items[0].c_str();
			strSoftwaresVers[i] = items[1].c_str();
		}
		else
		{
			strSoftwaresNames[i] = value;
		}
		DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("Detect SoftDetect from CentralSetting, %d: [%s],[%s],[%s]"
			, i, item.GetData(), strSoftwaresNames[i].GetData(), strSoftwaresVers[i].GetData());
		nNameCounts++;
	}

	if (nNameCounts > 0) {

#if defined(RVC_OS_WIN)
        vector<SetupSoftInfo> stupInfo;
        DWORD dwInitFlag(0);
        FetchSoftewareInstall(stupInfo, dwInitFlag);
        if (dwInitFlag == 1) {
			FetchSoftewareInstall(stupInfo, dwInitFlag);
        }
        dwInitFlag = 2;
		FetchSoftewareInstall(stupInfo, dwInitFlag);
        for (int i = 0; i < nNameCounts; ++i) {
            bool found(false);
			for (int j = 0; j < stupInfo.size(); j++) {
                if (strSoftwaresNames[i].Compare(stupInfo[j].displayName.c_str()) == 0) {
					if (strSoftwaresVers[i].IsNullOrEmpty() || strSoftwaresVers[i].Compare(stupInfo[j].displayVersion.c_str()) == 0) {
						CSimpleStringA strMsg = CSimpleStringA::Format("{\"software_name\":\"%s\", \"version_status\":\"%s\", \"detect_flag\":1}"
							, stupInfo[j].displayName.c_str(), stupInfo[j].displayVersion.c_str());
							LogWarn(Severity_Low, Error_Debug, LOG_WARN_SOFTWARE_DETECT_EXISTS_BASE_WIN + i, strMsg);
							DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM).setAPI("SoftwareInstallStatus")(strMsg.GetData());
                            found = true;
					}
					else
					{
						CSimpleStringA strMsg = CSimpleStringA::Format("{\"software_name\":\"%s\", \"version_status\":\"%s\", \"expected\":\"%s\",\"detect_flag\":0}"
                            , stupInfo[j].displayName.c_str(), stupInfo[j].displayVersion.c_str(), strSoftwaresVers[i].GetData());
							LogWarn(Severity_Low, Error_Debug, LOG_WARN_SOFTWARE_DETECT_NOT_EXISTS_BASE_WIN + i, strMsg);
						DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM).setAPI("SoftwareInstallStatus")(strMsg.GetData());
                        found = true;
					}
                    break;
                }
			}
            if (!found) {
                if (stupInfo.size() > 0) {
					CSimpleStringA strMsg = CSimpleStringA::Format("{\"software_name\":\"%s\", \"version_status\":\"not installed\",\"detect_flag\":0}", strSoftwaresNames[i].GetData());
					LogWarn(Severity_Low, Error_Debug, LOG_WARN_SOFTWARE_DETECT_NOT_EXISTS_BASE_WIN + i, strMsg);
					DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM).setAPI("SoftwareInstallStatus")(strMsg.GetData());
                }
                else {
					CSimpleStringA strMsg = CSimpleStringA::Format("{\"software_name\":\"%s\", \"version_status\":\"detect failed\", \"expected\":\"%s\",\"detect_flag\":0}"
						, strSoftwaresNames[i].GetData(), strSoftwaresVers[i].GetData());
					LogWarn(Severity_Low, Error_Debug, LOG_WARN_SOFTWARE_DETECT_EXISTS_STATUS_FAILED, strMsg);
					DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM).setAPI("SoftwareInstallStatus").setResultCode("RTA5A0D")(strMsg.GetData());
                }

            }
        }
#else
		for (int i = 0; i < nNameCounts; ++i) {
			CSimpleStringA runItem = CSimpleStringA::Format("dpkg -l | grep \"%s\" | awk '{print $3}'", strSoftwaresNames[i].GetData());
			std::string additional("");
			std::string succStr, errStr;
			std::string runStr(runItem.GetData());
			if (SP::Module::Util::ShellExecute(runStr, succStr, errStr)) {
				if (succStr.empty()) {
					CSimpleStringA strMsg = CSimpleStringA::Format("{\"software_name\":\"%s\", \"version_status\":\"not installed\",\"detect_flag\":0}", strSoftwaresNames[i].GetData());
					LogWarn(Severity_Low, Error_Debug, LOG_WARN_SOFTWARE_DETECT_NOT_EXISTS_BASE + i, strMsg);
					DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM).setAPI("SoftwareInstallStatus")(strMsg.GetData());
				}
				else
				{
					succStr = SP::Utility::ToTrim(succStr);
					if (strSoftwaresVers[i].IsNullOrEmpty() || strSoftwaresVers[i].Compare(succStr.c_str()) == 0) {
						CSimpleStringA strMsg = CSimpleStringA::Format("{\"software_name\":\"%s\", \"version_status\":\"%s\",\"detect_flag\":1}"
							, strSoftwaresNames[i].GetData(), succStr.c_str());
						LogWarn(Severity_Low, Error_Debug, LOG_WARN_SOFTWARE_DETECT_EXISTS_BASE + i, strMsg);
						DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM).setAPI("SoftwareInstallStatus")(strMsg.GetData());
					}
					else
					{
						CSimpleStringA strMsg = CSimpleStringA::Format("{\"software_name\":\"%s\", \"version_status\":\"%s\", \"expected\":\"%s\",\"detect_flag\":0}"
							, strSoftwaresNames[i].GetData(), succStr.c_str(), strSoftwaresVers[i].GetData());
						LogWarn(Severity_Low, Error_Debug, LOG_WARN_SOFTWARE_DETECT_NOT_EXISTS_BASE + i, strMsg);
						DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM).setAPI("SoftwareInstallStatus")(strMsg.GetData());
					}
				}
			}
			else
			{
				CSimpleStringA strMsg = CSimpleStringA::Format("{\"software_name\":\"%s\", \"version_status\":\"detect failed\", \"expected\":\"%s\",\"detect_flag\":0}"
					, strSoftwaresNames[i].GetData(), strSoftwaresVers[i].GetData());
				LogWarn(Severity_Low, Error_Debug, LOG_WARN_SOFTWARE_DETECT_EXISTS_STATUS_FAILED, strMsg);
				DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM).setAPI("SoftwareInstallStatus").setResultCode("RTA5A0D")(strMsg.GetData());
			}
	}
#endif //RVC_OS_WIN
	}
}

#ifdef RVC_OS_LINUX
UINT ResourceWatcherFSM::GetSystemDisplayVersion(CSimpleStringA& strVersion)
{
    UINT result = 0;

    const char filePath[] = "/etc/os-version";
    strVersion.Clear();
    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 += ".";

    result = atoi(tmp);

    memset(tmp, 0, 33);
    inifile_read_str_s("Version", "OsBuild", "unknown", tmp, 32, filePath);
    strVersion += tmp;

    return result;
}

void ResourceWatcherFSM::UploadSysVersionInfo(UINT& ver)
{
    std::map<std::string, std::string> srcData;
    CSimpleStringA osver;
    ver = GetSystemDisplayVersion(osver);
    srcData.insert(std::make_pair("os-version", osver)); ////当前操作系统版本（系统信息）
    tk_utsname_t t;
    osutil_uname(&t);

    srcData.insert(std::make_pair("sysname", t.sysname)); ////当前操作系统名
    srcData.insert(std::make_pair("release", t.release)); ////当前发布级别
    srcData.insert(std::make_pair("version", t.version)); ////当前发布版本
    srcData.insert(std::make_pair("machine", t.machine)); ////当前硬件体系类型

    do {
        std::string sucContent, failedContent;
        std::string cmd("cat /proc/cpuinfo |grep \"model name\" | awk 'NR==1'");
        bool ret = SP::Module::Util::ShellExecute(cmd, sucContent, failedContent);
        DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("{%s}:{%s}{%s}", cmd.c_str(), sucContent.c_str(), failedContent.c_str());
        auto elems = SP::Utility::Split(sucContent, ':');
        if (elems.size() > 1) {
            sucContent = SP::Utility::ToTrim(elems[1]);
        }
        srcData.insert(std::make_pair("cpu-type", sucContent));
    } while (false);
    auto ret = generateJsonStr(srcData);
    DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM).setAPI("SystemBaseInfo")(ret.second.c_str());
}

void ResourceWatcherFSM::UploadSysActivationStatus()
{
	//获取系统激活状态
	CSimpleStringA value(true);
	CSimpleStringA warnMsg(true);
	bool res = GetSysActiveStatus(value);
	if (!value.IsNullOrEmpty()) {
		auto elems = value.Split('|');
		std::map<std::string, std::string> info;
		info["subject"] = "system_activation";
		if (elems.GetCount() > 0) {
			for (int i = 0; i < elems.GetCount(); ++i) {
				auto sub_elems = elems[i].Split('：');
				if (sub_elems.GetCount() == 2) {
					CSimpleStringA val = sub_elems[1].GetData();
					CSimpleStringA key(true);
					//因为UOS内容用了中文的冒号，而Split函数无法拆分中文冒号（拆出来前面的内容有乱码），只能这样去操作
					if (sub_elems[0].IndexOf("服务器") != -1) {
						key = "server_addr";
					}
					else if (sub_elems[0].IndexOf("激活状") != -1) {
						key = "activation_status";
					}
					else if (sub_elems[0].IndexOf("授权状") != -1) {
						key = "authorization_status";
					}
					else if (sub_elems[0].IndexOf("到期时") != -1) {
						key = "deadline_status";
					}
					else if (sub_elems[0].IndexOf("序列") != -1) {
						key = "serial_number";
						if (val.GetLength() >= 23) {
							//NNAAA-7AAAY-*****-*****-MT6SK
							val[12] = val[13] = val[14] = val[15] = val[16] = '*';
							val[18] = val[19] = val[20] = val[21] = val[22] = '*';
						}
					}
					else {
						key = CSimpleStringA::Format("other%02d", i);
					}
					info[key.GetData()] = val.GetData();
				}
			}
		}
		info["fetch_status"] = "succ";
		std::pair<bool, std::string> strResult;
		strResult = generateJsonStr(info);
		value = strResult.second.c_str();
	}
	else {
		warnMsg = CSimpleStringA::Format("{\"subject\":\"system_activation\", \"fetch_status\":\"failed\"}");
	}
    DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM).setAPI("SystemActivationStatus")(value);
}

string ResourceWatcherFSM::MemoryProcessStatus()
{
    CSmartPointer<IEntityFunction> spFunction = this->GetEntityBase()->GetFunction();
    ErrorCodeEnum erroCode = Error_Unexpect;
    int memTop = 10;  //10个进程   

    map<string, string> nameProcess;
    CSystemRunInfo runInfo = { 0 };
    GetEntityBase()->GetFunction()->GetSystemRunInfo(runInfo);
    for (int i = 0; i < runInfo.strRunningEntityNames.GetCount(); i++)
    {
        string entityName = runInfo.strRunningEntityNames[i].GetData();
        CEntityRunInfo entityInfo = { 0 };
        GetEntityBase()->GetFunction()->GetEntityRunInfo(entityName.c_str(), entityInfo);
        nameProcess[to_string(entityInfo.dwProcessID)] = entityName;
    }

    FILE* fp;
    char buffer[2048];
    string cmd = "ps c -eo pid,%mem,rss,command | sort -k3 -rn | head -" + to_string(memTop);
    fp = popen(cmd.c_str(), "r");
    int i = 0;

    string s;
    string str[4];
    //mem
    DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("MEM TOP %d PROCESS!", memTop);
    string topMessage = "";
    while (i < memTop)
    {
        fgets(buffer, sizeof(buffer), fp);
        s = buffer;
        istringstream is(s);
        is >> str[0] >> str[1] >> str[2] >> str[3];
        double temp;
        stringstream ss1;
        ss1 << str[2];
        ss1 >> temp;
        temp = temp / (1024 * 1024);

        stringstream ss2;
        ss2 << std::setiosflags(std::ios::fixed) << std::setprecision(2) << temp;
        str[2] = ss2.str();

        if (nameProcess.find(str[0]) != nameProcess.end())
        {
            str[3] = nameProcess[str[0]];
        }

        topMessage = topMessage + "\"" + str[3] + "\"" + ":" + "\"" + str[1] + "%\"";

        if (i != memTop - 1)
        {
            topMessage += ",";
        }

        ++i;
    }
    topMessage += "}";
    pclose(fp);
    return topMessage;
}

long ResourceWatcherFSM::GetCPURunTime(CPUInfo* cpu) //获取CPU的当前信息，同时返回CPU使用时间
{
    FILE* fd;
    char buff[1024] = { 0 };
    CPUInfo* cpuInfo = cpu;

    fd = fopen("/proc/stat", "r");
    if (!fd) {
        //DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("Read CPU Info FAILED!");
        return -1;
    }

    fgets(buff, sizeof(buff), fd);
    char name[64] = { 0 };
    sscanf(buff, "%s %u %u %u %u %u %u %u",
        cpuInfo->name, &cpuInfo->user, &cpuInfo->nice, &cpuInfo->system, &cpuInfo->idle, &cpuInfo->lowait, &cpuInfo->irq, &cpuInfo->softirq);
    fclose(fd);

    return (cpuInfo->user + cpuInfo->nice + cpuInfo->system + cpuInfo->idle + cpuInfo->lowait + cpuInfo->irq + cpuInfo->softirq);
}


long ResourceWatcherFSM::ReadProcCPURunTime(DWORD pid, ProcCPUInfo* pInfo) { //根据pid读取进程占用的CPU时间

    char file_name[64] = { 0 };
    FILE* fd;
    char line_buff[1024] = { 0 };
    sprintf(file_name, "/proc/%d/stat", pid);

    fd = fopen(file_name, "r");
    if (nullptr == fd) {
        //DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("Read PROCESS[%d] CPU Info FAILED!", pid);
        return -1;
    }

    fgets(line_buff, sizeof(line_buff), fd);

    sscanf(line_buff, "%u %s", &pInfo->pid, pInfo->pname);
    const char* q = GetItems(line_buff, PROCESS_ITEM);
    sscanf(q, "%ld %ld %ld %ld", &pInfo->utime, &pInfo->stime, &pInfo->cutime, &pInfo->cstime);
    fclose(fd);

    return (pInfo->utime + pInfo->stime + pInfo->cutime + pInfo->cstime);
}


//获取第N项开始的指针
const char* ResourceWatcherFSM::GetItems(const char* buffer, unsigned int item) {

    const char* p = buffer;

    int len = strlen(buffer);
    int count = 0;

    for (int i = 0; i < len; i++) {
        if (' ' == *p) {
            count++;
            if (count == item - 1) {
                p++;
                break;
            }
        }
        p++;
    }

    return p;
}

/* -----------------------
   根据先后两个时间的CPU信息，
   计算CPU的总占用量和各个进程的占用量
   -----------------------      */
void ResourceWatcherFSM::GetSystemCPUStatus()
{
    //int cpu_num = sysconf(_SC_NPROCESSORS_CONF);      //CPU核数

    oldProcessTime.clear();
    newProcessTime.clear();
    processName.clear();
    processCpu.clear();

    CPUInfo* cpuOld = new CPUInfo;
    CPUInfo* cpuNew = new CPUInfo;

    const char* tPath = "/proc";

    long oldTotalTime = GetCPURunTime(cpuOld);  //旧CPU运行总时间
    if (oldTotalTime == -1)
    {
        return;
    }

    struct dirent* oldDirp;
    DIR* oldDp = opendir(tPath);
    if (oldDp != NULL) {
        while ((oldDirp = readdir(oldDp)) != NULL) {  //获取旧时刻 每一个进程的pid、CPU运行时间、进程名
            string fileName = oldDirp->d_name;
            BOOL isPid = TRUE;
            for (int i = 0; i < fileName.length(); ++i)  //判断进程id的文件夹 是否文件名是否纯数字
            {
                if (!isdigit(fileName[i]))
                {
                    isPid = FALSE;
                    break;
                }
            }
            if (!isPid) continue;

            DWORD pid;
            long oldTime;
            ProcCPUInfo* oldProcCPU = new ProcCPUInfo;
            sscanf(oldDirp->d_name, "%d", &pid);  //读取文件夹名
            oldTime = ReadProcCPURunTime(pid, oldProcCPU);
            if (oldTime == -1)
            {
                return;
            }

            oldProcessTime[pid] = oldTime;
            processName[pid] = oldProcCPU->pname;

            delete oldProcCPU;
        }
        closedir(oldDp);
    }

    sleep(1);

    long newTotalTime = GetCPURunTime(cpuNew);  //新CPU运行总时间
    if (newTotalTime == -1)
    {
        return;
    }

    struct dirent* newDirp;
    DIR* newDp = opendir(tPath);
    if (newDp != NULL) {
        while ((newDirp = readdir(newDp)) != NULL) {  //获取新时刻 每一个进程的pid、CPU运行时间、进程名

            string fileName = newDirp->d_name;
            BOOL isPid = TRUE;
            for (int i = 0; i < fileName.length(); ++i)  //判断进程id的文件夹 是否文件名是否纯数字
            {
                if (!isdigit(fileName[i]))
                {
                    isPid = FALSE;
                    break;
                }
            }
            if (!isPid) continue;

            DWORD pid;
            long newTime;
            ProcCPUInfo* newProcCPU = new ProcCPUInfo;
            sscanf(newDirp->d_name, "%d", &pid);  //读取文件夹名
            newTime = ReadProcCPURunTime(pid, newProcCPU);
            if (newTime == -1)
            {
                return;
            }

            newProcessTime[pid] = newTime;

            string tName = newProcCPU->pname;
            tName.erase(tName.begin());
            tName.erase(tName.begin() + (tName.length() - 1));

            processName[pid] = tName.c_str();

            delete newProcCPU;
        }
        closedir(newDp);
    }

    unordered_map<int, long long>::iterator it;
    for (it = newProcessTime.begin(); it != newProcessTime.end(); ++it)
    {
        DWORD tPid = it->first;
        //进程的占用率 = 单位时间间隔里进程的CPU时间片占用 / 单位时间间隔里CPU的整体时间片
        double tRatio = 100.0 * (newProcessTime[tPid] - oldProcessTime[tPid]) / (newTotalTime - oldTotalTime);
        processCpu[tPid] = tRatio;
    }

    unsigned long oldInfo, newInfo;
    double cUsedRate = 0;

    //第一次(用户+优先级+系统+空闲)的时间  
    //oldInfo = (unsigned long)(cpuOld->user + cpuOld->nice + cpuOld->system + cpuOld->idle + cpuOld->lowait + cpuOld->irq + cpuOld->softirq);
    //第二次(用户+优先级+系统+空闲)的时间
    //newInfo = (unsigned long)(cpuNew->user + cpuNew->nice + cpuNew->system + cpuNew->idle + cpuNew->lowait + cpuNew->irq + cpuNew->softirq);
    double totalTime = newTotalTime - oldTotalTime;
    double freeTime = cpuNew->idle - cpuOld->idle;
    cUsedRate = (totalTime - freeTime) / totalTime;

    if (m_cpuHighPercent <= 0)
    {
        m_cpuHighPercent = 80; //默认告警百分比80%
    }

    if (cpuWarnThreshold <= 0)
    {
        cpuWarnThreshold = 10;  //默认满10次告一次警
    }

    if ((cUsedRate * 100) > m_cpuHighPercent) 
    {
        cpuWarnTime = cpuWarnTime % cpuWarnThreshold;
        if (cpuWarnTime == 0) //每达到一次阈值告警一次
        {
            CSystemRunInfo runInfo = { 0 };
            GetEntityBase()->GetFunction()->GetSystemRunInfo(runInfo);

            for (int i = 0; i < runInfo.strRunningEntityNames.GetCount(); i++) //实体进程的名称默认全为sphost，需转换为对应实体名
            {
                CSimpleStringA entityName = runInfo.strRunningEntityNames[i].GetData();
                CEntityRunInfo entityInfo = { 0 };
                GetEntityBase()->GetFunction()->GetEntityRunInfo(entityName.GetData(), entityInfo);
                processName[entityInfo.dwProcessID] = entityName;
            }

            vector<pair<int, double>> vec(processCpu.begin(), processCpu.end());
            sort(vec.begin(), vec.end(), cmp); //根据CPU使用率从大到小进行排序

            int cpuTop = 10;
            int len = MIN(cpuTop, vec.size()); //确认要展示的进程数量
            CSimpleStringA procWarn = "";
            for (int i = 0; i < len; ++i) //构建进程的CPU使用告警信息
            {
                char* tUsage = new char[20];
                sprintf(tUsage, "%.2lf", vec[i].second);
                procWarn = procWarn + ",\"" + processName[vec[i].first] + "\":\"" + tUsage + "%\"";

                delete tUsage;
            }

            stringstream tss;
            tss << std::setiosflags(std::ios::fixed) << std::setprecision(2) << cUsedRate * 100;

            CSimpleStringA warn = "";
            warn = warn + "{\"type\":\"cpu\", \"total_used\":\"" + tss.str().c_str() + "%\"" + procWarn + "}";
            LogWarn(Severity_Middle, Error_Resource, LOG_EVT_RESOURCE_CPU_TOO_HIGH, CSimpleStringA::Format("%s", warn.GetData()));
            DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM).setResultCode("RTA5A03").setAPI("CpuUsedCheck")(warn.GetData());
        }
        cpuWarnTime++;
    }

    delete cpuNew;
    delete cpuOld;

}

void ResourceWatcherFSM::GetSystemMemoryStatus()
{
    MemInfo* memInfo = new MemInfo();

    FILE* fd;
    char buff[256];

    fd = fopen("/proc/meminfo", "r");
    if (!fd) {
        //DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("Read Memory INFO FAILED!");
        return;
    }

    fgets(buff, sizeof(buff), fd);
    sscanf(buff, "%s %lu ", memInfo->infoName1, &memInfo->memTotal);
    fgets(buff, sizeof(buff), fd);
    sscanf(buff, "%s %lu ", memInfo->infoName2, &memInfo->memFree);
    fgets(buff, sizeof(buff), fd);
    sscanf(buff, "%s %lu ", memInfo->infoName3, &memInfo->memAvail);
    fclose(fd);

    double mUsedRate = 0;
    mUsedRate = (double)(memInfo->memTotal - memInfo->memAvail) / (double)memInfo->memTotal;

    char szResult[DEFAULT_OUTPUT_FORMAT_SIZE];
    char szResult2[DEFAULT_OUTPUT_FORMAT_SIZE];
    char szResult3[DEFAULT_OUTPUT_FORMAT_SIZE];

    ByteSprintf(szResult, (double)(memInfo->memTotal) * 1024, 'G'); // 内存信息在 /proc/meminfo 中的单位为 KB
    ByteSprintf(szResult2, (double)(memInfo->memFree) * 1024, 'G');
    ByteSprintf(szResult3, (double)(memInfo->memAvail) * 1024, 'G');

    if (m_memHighPercent <= 0)
    {
        m_memHighPercent = 80; //默认告警百分比80%
    }

    if (memWarnThreshold <= 0)
    {
        memWarnThreshold = 10; //默认告警阈值10次
    }

    if ((mUsedRate * 100) > m_memHighPercent) 
    {
        memWarnTime = memWarnTime % memWarnThreshold;
        if (memWarnTime == 0) //每达到阈值告警一次
        {
            char usedResult[DEFAULT_OUTPUT_FORMAT_SIZE];
            ByteSprintf(usedResult, (double)(memInfo->memTotal) * 1024 * mUsedRate, 'G');

            stringstream ss1;
            ss1 << std::setiosflags(std::ios::fixed) << std::setprecision(2) << mUsedRate * 100;

            string warn = "{\"type\":\"mem\", \"total\":\"" + string(szResult) + "\"," +
                "\"total_used\":\"" + ss1.str() + "%\"," + MemoryProcessStatus();
            LogWarn(Severity_Middle, Error_Resource, LOG_EVT_RESOURCE_MEMORY_TOO_HIGH, CSimpleStringA::Format("%s", warn.c_str()));
            DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM).setResultCode("RTA5A04").setAPI("MemUsedCheck")(warn.c_str());
        }
        memWarnTime++;
    }
}

void ResourceWatcherFSM::GetDiskStatusFrom(LPCTSTR path)
{
    if (m_diskHighPercent <= 0)
    {
        m_diskHighPercent = 90; //默认硬盘告警百分比90%
    }

    unsigned long long uiTotalBytes;
    unsigned long long uiFreeDiskBytes;

    char szResult[DEFAULT_OUTPUT_FORMAT_SIZE];
    char szResult2[DEFAULT_OUTPUT_FORMAT_SIZE];

    BOOL readFlag = DiskInfo::GetDiskSpace(path, uiTotalBytes, uiFreeDiskBytes);
    double dUsedRate = 1 - (uiFreeDiskBytes * kConversion[3]) / (uiTotalBytes * kConversion[3]);

    ByteSprintf(szResult, (double)uiTotalBytes);
    ByteSprintf(szResult2, (double)uiFreeDiskBytes);

    if (readFlag && (dUsedRate * 100 < m_diskHighPercent)) {
        //DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("[Disk# %s] total: %s, free: %s, [Disk] used rate: %.1lf%%.", path, szResult, szResult2, dUsedRate * 100);
    }
    else
    {
        CSimpleStringA warnStr = CSimpleStringA::Format("\"Disk\":\"%s\",\"total\":\"%s\",\"free\":\"%s\",\"used rate\":\"%.1lf%%\"",
                                                         path, szResult, szResult2, dUsedRate * 100);
        LogWarn(Severity_Middle, Error_Resource, LOG_EVT_RESOURCE_HARDDISK_TOO_HIGH, warnStr.GetData());
        DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM).setResultCode("RTA5A05").setAPI("DiskUsedCheck")(warnStr.GetData());

        CheckDiskFileSpaceTask* task4 = new CheckDiskFileSpaceTask(this);
        GetEntityBase()->GetFunction()->PostThreadPoolTask(task4);
    }
}

void ResourceWatcherFSM::GetSystemDiskStatus()
{
    GetDiskStatusFrom("/");
}


void ResourceWatcherFSM::switchWindowsEffect(const char* cfgFilePath, bool enable)
{
    char tmp[33];
    memset(tmp, 0, 33);
    inifile_read_str_s("Compositing", "Enabled", "", tmp, 32, cfgFilePath);
    if (strlen(tmp) == 0 || stricmp(tmp, "false") == 0) {
        if (enable) {
            inifile_write_str(cfgFilePath, "Compositing", "Enabled", "true");
            LogWarn(Severity_Low, Error_InvalidState, LOG_RESOURCEWATCHER_COMPOSITING_CHANGE_ON, "to active window effect");
        }
    }
    else if (stricmp(tmp, "true") == 0) {
        if (!enable) {
            inifile_write_str(cfgFilePath, "Compositing", "Enabled", "false");
            LogWarn(Severity_Low, Error_InvalidState, LOG_RESOURCEWATCHER_COMPOSITING_CHANGE_OFF, "to inactive window effect");
        }
    }
}

void ResourceWatcherFSM::RecoverDDEClipboardEnable()
{
    const std::string clipboardPath = "/usr/bin/dde-clipboard";
    const std::string clipboardPathBak = "/usr/bin/dde-clipboard.bak";
    if (!ExistsFileA(clipboardPath.c_str()) && ExistsFileA(clipboardPathBak.c_str())) {
        fileutil_copy_file(clipboardPath.c_str(), clipboardPathBak.c_str());
        //fileutil_delete_file(clipboardPathBak.c_str());
        LogWarn(Severity_Low, Error_Debug, LOG_RESOURCEWATCHER_CLIPBOARD_RECOVER_ENABLE, "recover clipboard succ.");
    }
    else {
        DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("%s exists.", clipboardPath.c_str());
    }
}

void ResourceWatcherFSM::ConfirmDDEClipboardDisable()
{
    const std::string clipboardPath = "/usr/bin/dde-clipboard";
    const std::string clipboardPathBak = "/usr/bin/dde-clipboard.bak";
    char* clipboards[] = { "dde-clipboard", "dde-clipboardloader" };

    if (!ExistsFileA(clipboardPath.c_str())) {
        DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("There are no any %s files.", clipboardPath.c_str());
        if (ExistsFileA(clipboardPathBak.c_str())) {
            DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("%s exists.", clipboardPathBak.c_str());
        }
        return;
    }

    if (0 != fileutil_copy_file(clipboardPathBak.c_str(), clipboardPath.c_str())) {
        LogWarn(Severity_Low, Error_Unexpect, LOG_RESOURCEWATCHER_CLIPBOARD_REMOVE_FAILED, "remove clipboard failed");
    }
    else {
        fileutil_delete_file(clipboardPath.c_str());
        osutil_terminate_related_process(clipboards, array_size(clipboards), 0);
        LogWarn(Severity_Low, Error_Process, LOG_RESOURCEWATCHER_CLIPBOARD_REMOVE_SUCC, "remove clipboard succ.");
    }
}

void ResourceWatcherFSM::ConfirmNotificationCenterDisable()
{
    const char* osd_file_path = "/usr/lib/deepin-daemon/dde-osd";
    const char* osd_bak_file_path = "/usr/lib/deepin-daemon/dde-osd.bak";

    CSmartPointer<IConfigInfo> spConfig;
    GetEntityBase()->GetFunction()->OpenConfig(Config_Cache, spConfig);
    int flag = 0;
    spConfig->ReadConfigValueInt("UOSFeatures", "NotifyCenterSupport", flag);
    if (flag == 1) {
        DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("allow the dde-osd process alive.");
        if (!ExistsFileA(osd_file_path) && ExistsFileA(osd_bak_file_path)) {
            fileutil_copy_file(osd_file_path, osd_bak_file_path);
            LogWarn(Severity_Low, Error_Debug, LOG_RESOURCEWATCHER_OSD_RECOVER_ENABLE, "recover dde osd succ.");
        }
    }
    else {
        if (ExistsFileA(osd_file_path) && !ExistsFileA(osd_bak_file_path)) {
            char* relates[] = { "dde-osd" };
            if (0 != fileutil_copy_file(osd_bak_file_path, osd_file_path)) {
                LogWarn(Severity_Low, Error_Unexpect, LOG_RESOURCEWATCHER_CLIPBOARD_REMOVE_FAILED, "remove dde osd failed");
            }
            else {
                osutil_terminate_related_process(relates, array_size(relates), 0);
                fileutil_delete_file(osd_file_path);
                LogWarn(Severity_Low, Error_Process, LOG_RESOURCEWATCHER_OSD_REMOVE_SUCC, "remove dde osd succ.");
            }
        }
    }
}

void ResourceWatcherFSM::ConfirmWindowEffectHasBeenOpen()
{
    array_header_t* arr;
    arr = fileutil_get_sub_dirs_a("/home");
    if (arr) {
        int i;
        for (i = 0; i < arr->nelts; ++i) {
            char szDestSubDir[256] = { 0 };
            char* dir = ARRAY_IDX(arr, i, char*);
            DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("sub dir: %s", dir);
            strcpy(szDestSubDir, dir);
            strcat(szDestSubDir, SPLIT_SLASH_STR);
            strcat(szDestSubDir, ".config/kwinrc");
            if (ExistsFileA(szDestSubDir)) {
                switchWindowsEffect(szDestSubDir, true);
            }
        }
        toolkit_array_free2(arr);
    }
}
#endif // RVC_OS_LINUX

void ResourceWatcherFSM::UploadSystemProccess()
{
    if(processName.empty())
    {
        DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("Get Sys Process error, it's empty!");
        return;
    }

    int len = 0;
    CSimpleStringA curProcStr = "";
    CSimpleStringA endStr = ",";
    CSimpleStringA totalProcStr = "{";

    vector<pair<int, CSimpleStringA>> vec(processName.begin(), processName.end());
    sort(vec.begin(), vec.end(), cmpPid);

    for (int i = 0; i < vec.size(); i++)
    {
        curProcStr = CSimpleStringA("\"") + to_string(vec[i].first).c_str() + "\":\"" + vec[i].second + "\"";
        len = totalProcStr.GetLength() + curProcStr.GetLength();
        if (len > 1000 || i == (vec.size()-1))
        {
            endStr = "}";
            if (i == (vec.size() - 1)) //最后一个
            {
                totalProcStr = totalProcStr + curProcStr + endStr;
                DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM).setAPI("GetSystemProccess")(totalProcStr.GetData());
                break;
            }
            else //长度超限
            {
                totalProcStr[totalProcStr.GetLength() - 1] = '}';
                DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM).setAPI("GetSystemProccess")(totalProcStr.GetData());
                totalProcStr = CSimpleStringA("{") + curProcStr + ","; //超过长度则从当前进程开始重新搭建日志
            }
        }
        else
        {
            endStr = ",";
            totalProcStr = totalProcStr + curProcStr + endStr;
        }
        
    }
}

void ResourceWatcherFSM::UploadDirPathFileList(CSimpleStringA dirFilePath)
{
    CSimpleStringA realPath(true);
    int res = ExpandDir(dirFilePath, realPath);
    switch (res)
    {
    case -1: //映射无效，使用原数据
    {
        realPath = dirFilePath;
        break;
    }
    case -2: //GetPath映射错误，ExpandDir有报错，这里就不报了
    {
        return;
    }
    default:
        break;
    }

    DWORD attrs = GetFileAttributesA(realPath);
    if (attrs == INVALID_FILE_ATTRIBUTES)
    {
        const DWORD lastError = GetLastError();
        DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM).setResultCode("RTA5A15")("Acess to path error：[%s], GLE = %u.", realPath.GetData(), lastError);
        return;
    }
    else  if (!(attrs & FILE_ATTRIBUTE_DIRECTORY))
    { //非文件夹类型
        DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM).setResultCode("RTA5A15")("Path [%s]  is not Directory!", realPath.GetData());
        return;
    }

    int len = 0;
    vector<CSimpleStringA> fileList = GetFileListFromDirectory(realPath);
    if (!fileList.empty())
    {

        string tPath = realPath.GetData();
        string jsonPath;
        for (char c : tPath) { //替换反斜杠
            if (c == '\\') {
                jsonPath += '\\';
                jsonPath += '\\';
            }
            else {
                jsonPath += c;
            }
        }
        CSimpleStringA curListStr = "";
        CSimpleStringA endStr = ",";
        CSimpleStringA totalListStr = CSimpleStringA::Format("{\"path\":\"%s\", \"fileList\":[", jsonPath.c_str());

        if (totalListStr.GetLength() > 1000)
        {
            DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("Dir Path length over 1000!");
            DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("%s", totalListStr.SubString(0, 1000));
            return;
        }

        for (int i = 0; i < fileList.size(); i++)
        {
            curListStr = CSimpleStringA("\"") + fileList[i] + "\"";
            len = totalListStr.GetLength() + curListStr.GetLength();
            if (len > 1000 || i == (fileList.size() - 1))
            {
                endStr = "]}";
                if (i == (fileList.size() - 1)) //最后一个
                {
                    totalListStr = totalListStr + curListStr + endStr;
                    DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM).setAPI("GetFileListFromDirectory")(totalListStr.GetData());
                    break;
                }
                else //长度超限
                {
                    totalListStr[totalListStr.GetLength() - 1] = ']';
                    totalListStr = totalListStr + "}";
                    DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM).setAPI("GetFileListFromDirectory")(totalListStr.GetData());
                    totalListStr = CSimpleStringA::Format("{\"path\":\"%s\", \"fileList\":[", jsonPath.c_str()) + curListStr + ","; //超过长度则从当前进程开始重新搭建日志
                }
            }
            else
            {
                endStr = ",";
                totalListStr = totalListStr + curListStr + endStr;
            }
        }
    }
}

vector<CSimpleStringA> ResourceWatcherFSM::GetFileListFromDirectory(CSimpleStringA path)
{
    vector<CSimpleStringA> files;
#ifdef _WIN32
    WIN32_FIND_DATAA data;
    HANDLE hFind;

    CSimpleStringA searchPath = path + "\\*";
    hFind = FindFirstFileA(searchPath.GetData(), &data);
    if (hFind != INVALID_HANDLE_VALUE) {
        do {
            if (strcmp(data.cFileName, ".") == 0 || strcmp(data.cFileName, "..") == 0)
                continue;
            
            files.push_back(data.cFileName);

            if ((data.dwFileAttributes & FILE_ATTRIBUTE_DIRECTORY) != 0) { //文件夹类型，只传文件夹名
                CSimpleStringA fullPath = path + "\\" + data.cFileName;
                UploadDirPathFileList(fullPath); //上送子文件夹下的文件列表
            }
        } while (FindNextFileA(hFind, &data) != 0);
        FindClose(hFind);
    }
#else
    DIR* dir = opendir(path.GetData());
    if (!dir) return files;

    struct dirent* entry;
    while ((entry = readdir(dir)) != nullptr) {
        if (CSimpleStringA(entry->d_name) == "." || CSimpleStringA(entry->d_name) == "..")
            continue;
        
        files.push_back(entry->d_name);

        CSimpleStringA fullPath = path + "/" + entry->d_name;
        DWORD attrs = GetFileAttributesA(fullPath);
        if (attrs & FILE_ATTRIBUTE_DIRECTORY) { //文件夹类型，只传文件夹名
            UploadDirPathFileList(fullPath); //上送子文件夹下的文件列表
        }
    }
    closedir(dir);
#endif

    return files;
}