myvtm/Module/include/CommEntityUtil.hpp

#ifndef RVC_MOD_COMM_ENTITY_UTIL_HPP_
#define RVC_MOD_COMM_ENTITY_UTIL_HPP_

#if defined(_MSC_VER)
#include <Windows.h>
#include <TlHelp32.h>
#include <iphlpapi.h>
#include <ws2tcpip.h>
#include <Winsock2.h>
#include <IPTypes.h>
#include <WinInet.h>
#include <ShlObj.h>
#include <Pdh.h>

#pragma comment(lib, "IPHLPAPI.lib")
#pragma comment(lib, "Wininet.lib")
#pragma comment(lib, "pdh.lib")
#define streq stricmp

#else
#include <linux/ethtool.h>
#include <linux/sockios.h>
#include <net/if.h>
#include <sys/ioctl.h>
#include <sys/sysinfo.h>
#include <unistd.h>
#include <thread>
#include <chrono>
#define streq strcasecmp

#endif //_MSC_VER

#include "path.h"
#include "toolkit.h"
#include <string>
#include <iostream>
#include <sstream>
#include <map>
#include "SpBase.h"
#include "publicFunExport.h"

#define MACSESION 6
#define DIV (1024 * 1024)
#define DAY_DIV (24 * 60 * 60)
#define HOURS_DIV (60 * 60)
#define MINUS_DIV (60)

typedef unsigned long long ULLINT;


#define SLEEP(interval) std::this_thread::sleep_for(std::chrono::milliseconds(interval))

namespace SP
{
namespace Module
{

	namespace System
	{

		static BOOL GetSystemBootTime(CSmallDateTime& systemBootTime)
		{
#if defined(_MSC_VER)
			const char* SystemElapsedQuery = "\\System\\System Up Time";
			PDH_STATUS Status;
			HQUERY Query = NULL;
			HCOUNTER hcElapsedTimeCount;
			BOOL fSuc = FALSE;
			/** 杀毒软件会对附件这几个系统调用函数有所监控，导致有时会耗费5s时间 Gifur@20221019]*/
			Status = PdhOpenQuery(NULL, NULL, &Query);
			PDH_FMT_COUNTERVALUE counterValue;
			if (Status != ERROR_SUCCESS) {
				DbgWithLink(LOG_LEVEL_ERROR, LOG_TYPE_SYSTEM)("PdhOpenQuery failed with status 0x%x.", Status);
				goto Cleanup;
			}
			Status = PdhAddCounter(Query, SystemElapsedQuery, NULL, &hcElapsedTimeCount);
			if (Status != ERROR_SUCCESS) {
				DbgWithLink(LOG_LEVEL_ERROR, LOG_TYPE_SYSTEM)("PdhAddCounter for SystemElapsedQuery failed with status 0x%x.", Status);
				goto Cleanup;
			}
			// 查询性能监视器数据
			Status = PdhCollectQueryData(Query);
			if (Status != ERROR_SUCCESS) {
				DbgWithLink(LOG_LEVEL_ERROR, LOG_TYPE_SYSTEM)("PdhCollectQueryData failed with 0x%x.", Status);
				goto Cleanup;
			}
			Status = PdhGetFormattedCounterValue(hcElapsedTimeCount, PDH_FMT_LARGE, NULL, &counterValue);
			if (Status == ERROR_SUCCESS) {
				ULONGLONG ulSinceSeconds = counterValue.largeValue;
				ULONG days = 0, hours = 0, minutes = 0, seconds = 0;
				days = ULONG(ulSinceSeconds / DAY_DIV);
				ulSinceSeconds %= DAY_DIV;
				hours = ULONG(ulSinceSeconds / HOURS_DIV);
				ulSinceSeconds %= HOURS_DIV;
				minutes = ULONG(ulSinceSeconds / MINUS_DIV);
				ulSinceSeconds %= MINUS_DIV;
				seconds = ULONG(ulSinceSeconds);

				DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("SystemElapseTime: %u %02u:%02u:%02u", days, hours, minutes, seconds);

				FILETIME ftCurTime, ftStartTime;
				GetSystemTimeAsFileTime(&ftCurTime);
				ULARGE_INTEGER uliCurTime;
				uliCurTime.HighPart = ftCurTime.dwHighDateTime;
				uliCurTime.LowPart = ftCurTime.dwLowDateTime;
				uliCurTime.QuadPart -= counterValue.largeValue * 1e7;

				ftStartTime.dwHighDateTime = uliCurTime.HighPart;
				ftStartTime.dwLowDateTime = uliCurTime.LowPart;

				SYSTEMTIME stUTC, stLocal;

				FileTimeToSystemTime(&ftStartTime, &stUTC);
				char temp[22];
				SystemTimeToTzSpecificLocalTime(NULL, &stUTC, &stLocal);
				sprintf_s(temp, 22, "%d-%02d-%02d %02d:%02d:%02d",
					stLocal.wYear, stLocal.wMonth, stLocal.wDay, stLocal.wHour, stLocal.wMinute, stLocal.wSecond);
				DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("OSStartTime: %s", temp);
				systemBootTime.FromSystemTime(stLocal);
				fSuc = TRUE;
			}
		Cleanup:
			Status = PdhRemoveCounter(hcElapsedTimeCount);
			if (Query) {
				PdhCloseQuery(Query);
			}
			return fSuc;
#else
			DWORD ticks = 0;
			SYSTEMTIME systemTime;

			struct sysinfo info;
			time_t curTime = 0;
			time_t bootTime = 0;
			struct tm* ptm = NULL;
			if (sysinfo(&info)) {
				DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("Failed to get sysinfo, errno:%u, reason:%s", errno, strerror(errno));
				return FALSE;
			}
			time(&curTime);
			if (curTime > info.uptime) {
				bootTime = curTime - info.uptime;
			}
			else
			{
				bootTime = info.uptime - curTime;
			}
			ptm = localtime(&bootTime);
			struct timespec ts;
			if (!clock_gettime(CLOCK_MONOTONIC_RAW, &ts))
				ticks = (ts.tv_sec * 1000) + (ts.tv_nsec / 1000000);

			systemTime.wYear = (WORD)(ptm->tm_year + 1900);
			systemTime.wMonth = (WORD)(ptm->tm_mon + 1);
			systemTime.wDayOfWeek = (WORD)ptm->tm_wday;
			systemTime.wDay = (WORD)ptm->tm_mday;
			systemTime.wHour = (WORD)ptm->tm_hour;
			systemTime.wMinute = (WORD)ptm->tm_min;
			systemTime.wSecond = (WORD)ptm->tm_sec;
			systemTime.wMilliseconds = (WORD)(ticks % 1000);

			systemBootTime.FromSystemTime(systemTime);
			DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("OSStartTime: %s", systemBootTime.ToTimeString().GetData());
			return TRUE;
#endif //_MSC_VER
		}
	}//system

namespace Comm
{

/** Rely on  ${OTHER_LIB_BASE_DIR}/libpublicFun and library target libpublicFun*/
struct LogNotiyMessageStruct
{
	std::string Reason;
	std::string ErrMsg;
	std::string RebootTime;

	LogNotiyMessageStruct(const CSimpleStringA& reason, const CSimpleStringA& errmsg, const CSimpleStringA& rebootTime)
		:Reason(reason.GetData()), ErrMsg(reason.GetData()), RebootTime(reason.GetData())
	{
	}
    LogNotiyMessageStruct(const std::string& reason, const std::string& errmsg, const std::string& rebootTime)
        :Reason(reason), ErrMsg(errmsg), RebootTime(rebootTime)
    {
    }
    LogNotiyMessageStruct(const char* reason, const char* errmsg, char* rebootTime)
        :Reason(reason), ErrMsg(errmsg), RebootTime(rebootTime)
    {
    }

    LogNotiyMessageStruct(const char* errmsg)
        :Reason(""), ErrMsg(errmsg), RebootTime("")
    {
    }

	std::string ToJsonString() const {
        std::map<std::string, std::string> srcData;
        srcData.insert(std::make_pair("reason", Reason));
        srcData.insert(std::make_pair("errmsg", ErrMsg));
        srcData.insert(std::make_pair("rebootTime", RebootTime));
		auto ret = generateJsonStr(srcData);
        if (ret.first) {
			return ret.second;
		} else {
			return ErrMsg;
		}
	}

};

struct LogCommNotiyStruct
{
	NotifyLevelEnum eLevel;
	ErrorCodeEnum eSysCode;
	DWORD dwUserCode;
	LogCommNotiyStruct() :eLevel(Notify_None), eSysCode(Error_Unexpect), dwUserCode(0) {}

	LogCommNotiyStruct(NotifyLevelEnum level, ErrorCodeEnum errorCode, DWORD dwUserCode)
		:eLevel(level), eSysCode(errorCode), dwUserCode(dwUserCode) {}

    LogCommNotiyStruct(NotifyLevelEnum level, ErrorCodeEnum errorCode)
        :eLevel(level), eSysCode(errorCode), dwUserCode(0)
    { }

	virtual ~LogCommNotiyStruct() {}

	virtual void Notify(const LogNotiyMessageStruct& notifyMessage)
	{
		LogNotify(eLevel, eSysCode, dwUserCode, notifyMessage.ToJsonString().c_str());
	}
};

struct LogInfoNotiyStruct : public LogCommNotiyStruct
{
	LogInfoNotiyStruct(ErrorCodeEnum errorCode, DWORD dwUserCode) 
		:LogCommNotiyStruct(Notify_Info, errorCode, dwUserCode){}
    ~LogInfoNotiyStruct() {}

};

struct LogWarnNotiyStruct : public LogCommNotiyStruct
{
	LogWarnNotiyStruct(ErrorCodeEnum errorCode, DWORD dwUserCode)
        :LogCommNotiyStruct(Notify_Warn, errorCode, dwUserCode)
    {
    }
    ~LogWarnNotiyStruct() {}

};

struct LogErrorNotiyStruct : public LogCommNotiyStruct
{
	LogErrorNotiyStruct(ErrorCodeEnum errorCode, DWORD dwUserCode)
        :LogCommNotiyStruct(Notify_Error, errorCode, dwUserCode)
    {
    }
    ~LogErrorNotiyStruct() {}
};

static BOOL IsFirsRunAppAfterSystemBoot(CEntityBase* pEntity, DWORD theReportUserCode = 0)
{
	BOOL result(FALSE);
	CSystemRunInfo runInfo = { 0 };
	ErrorCodeEnum ec = pEntity->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 = pEntity->GetFunction()->GetRebootInfo(/*runInfo.tmStart*/dateTime, bootInfo);
		DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("bootInfor time: %s", (LPCTSTR)bootInfo.tmStart.ToTimeString());
		CSmallDateTime systemBootTime;
		const BOOL bRet = System::GetSystemBootTime(systemBootTime);
		if (bRet && systemBootTime > bootInfo.tmStart) {
			result = TRUE;
			if (theReportUserCode != 0) {
				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, theReportUserCode, strData.GetData());
			}
		}
	}
	return result;
}

inline
CSimpleStringA GetCurrMachineType(CEntityBase* pEntity)
{
    CSystemStaticInfo sysInfo;
    pEntity->GetFunction()->GetSystemStaticInfo(sysInfo);
    return sysInfo.strMachineType;
}
            enum Site
            {
                CMB_UNKNOWN,
                CMB_LIB,       /** 行内大堂*/
                CMB_FLB,      /** 离行机器*/
            };

#define SITE_ENUM_TYPE(MACRO)	\
		MACRO(LIB)\
		MACRO(FLB)


#define ENUM_MAP_CONVERT(elem) \
	if (streq(lpcszSiteName, "CMB."#elem) == 0) return CMB_##elem;
/*!
 * convert cmb site name to enum type.
 */
static Site Str2Site(LPCSTR lpcszSiteName)
{
	if (lpcszSiteName == NULL || strlen(lpcszSiteName) == 0)
		return CMB_UNKNOWN;
	SITE_ENUM_TYPE(ENUM_MAP_CONVERT)
		return CMB_UNKNOWN;
}

#undef ENUM_MAP_CONVERT
#define ENUM_MAP_CONVERT(elem) case CMB_##elem: return "CMB."#elem;

static LPCSTR Site2Str(Site site)
{
	switch (site) {
		SITE_ENUM_TYPE(ENUM_MAP_CONVERT)
	default:
		break;
	}
	return "Unkown";
}

            enum What
            {
                RVC_UNKNOWN,
                RVC_Stand2S,          /** 落地式大机*/
                RVC_PAD,                /** PAD*/
                RVC_Desk2S,           /** 低柜双屏*/
                RVC_CardStore,		/** 卡库*/
                RVC_CardPrinter,     /** 制卡机*/
				RVC_Stand1SPlus     /** 单屏大机*/
            };

#define MACHINE_ENUM_TYPE(MACRO)	\
		MACRO(Stand2S)\
		MACRO(PAD)\
		MACRO(Desk2S)\
		MACRO(CardStore)\
		MACRO(CardPrinter)\
		MACRO(Stand1SPlus)

#undef ENUM_MAP_CONVERT
#define ENUM_MAP_CONVERT(elem) \
	if (streq(lpcszTypeName, "RVC."#elem) == 0) return RVC_##elem;
/*!
 * convert cmb site name to enum type.
 */
static What Str2Type(LPCSTR lpcszTypeName)
{
	if (lpcszTypeName == NULL || strlen(lpcszTypeName) == 0)
		return RVC_UNKNOWN;
	MACHINE_ENUM_TYPE(ENUM_MAP_CONVERT)
	return RVC_UNKNOWN;
}

#undef ENUM_MAP_CONVERT
#define ENUM_MAP_CONVERT(elem) case RVC_##elem: return "RVC."#elem;

static LPCSTR Type2Str(What what)
{
	switch (what) {
		MACHINE_ENUM_TYPE(ENUM_MAP_CONVERT)
	default:
		break;
	}
	return "Unkown";
}

struct TerminalMachineInfo
{
	Site site;
	What type;
    struct {
        WORD minor;
        WORD major;
    } gen;
};

inline TerminalMachineInfo GetTerminalMachineInfo(CEntityBase* pEntity)
{
    CSystemStaticInfo sysInfo;
	TerminalMachineInfo termInfo;
	pEntity->GetFunction()->GetSystemStaticInfo(sysInfo);
	termInfo.site = Str2Site(sysInfo.strSite);
	termInfo.type = Str2Type(sysInfo.strMachineType);
	termInfo.gen.major = sysInfo.MachineVersion.GetMajor();
	termInfo.gen.minor = sysInfo.MachineVersion.GetMinor();
	return termInfo;
}

inline ULLINT RVCGetTickCount()
{
#ifdef RVC_OS_WIN
	return GetTickCount64();
#else
	struct timespec ts;
	clock_gettime(CLOCK_MONOTONIC, &ts);

	return (ts.tv_sec * 1000 + ts.tv_nsec / 1000000);
#endif // RVC_OS_WIN

}

} // comm

namespace Util
{
static int StrBuf2HexBuf(const char* strBuf, PBYTE* hexBuf)
{
    int len = strlen(strBuf);
    if (len == 0 || len % 2 != 0)
        return 0;
    BYTE* buf = new BYTE[len / 2];
    if (buf == NULL)
        return 0;
    int j = 0;
    for (int i = 0; i < len;) {
        int tmpVal;
        sscanf(strBuf + i, "%2X", &tmpVal);
        buf[j] = tmpVal;
        i += 2;
        j++;
    }
    *hexBuf = buf;
    return j;
}
static int HexBuf2StrBuf(PBYTE hexBuf, char** strBuf, DWORD len)
{
    char* tmpStr = *strBuf;
	DWORD count = 0;
    for (DWORD i = 0; i < len; ++i) {
        sprintf(tmpStr + count, "%0.2X", hexBuf[i]);
        count += 2;
    }
    return 0;
}

//tips: need to delete result char*
static char* ConvertBytesToHexStr(BYTE* pBuf, int nLen)
{
    char* pRet = (char*)new char[nLen * 2 + 1];
    memset(pRet, '\0', nLen * 2 + 1);
    char* p = pRet;
    for (int i = 0; i < nLen; i++) {
        BYTE b = pBuf[i];
        BYTE l = (b >> 4) & 0x0F;
        if (l >= 10)
            *p = l - 10 + 'a';
        else
            *p = l + '0';

        p++;
        BYTE r = b & 0x0F;
        if (r >= 10)
            *p = r - 10 + 'a';
        else
            *p = r + '0';
        p++;
    }

    return pRet;
}


static char HexChar2Dec(char c)
{
	if ((c >= '0') && (c <= '9'))
		return c - '0';
	else if ((c >= 'A') && (c <= 'F'))
		return c - 'A' + 10;
	else if ((c >= 'a') && (c <= 'f'))
		return c - 'a' + 10;
	else
		return 0x10;
}

static int Hex2Int(char* s)
{
	int ret = 0;
	while (*s) {
		int t = HexChar2Dec(*s);
		ret = ret * 16 + t;
		++s;
	}
	return ret;
}

static void ConvAscii(unsigned char* Hex, char* Ascii, unsigned int len)
{
	const unsigned char hextable[] = { "0123456789ABCDEF" };
	unsigned int i;
	for (i = 0; i < len; i++) {
		Ascii[2 * i] = hextable[Hex[i] >> 4];
		Ascii[2 * i + 1] = hextable[Hex[i] & 0xf];
	}
	Ascii[2 * len] = 0;
}

static void AsciiToHex(char* Ascii, unsigned char* Hex, int len)
{
	int i;
	unsigned char ch;
	for (i = 0; i < len; i = i + 2) {
		ch = (Ascii[i] & 0xf);
		if (Ascii[i] > '9')
			ch += 9;
		Hex[i / 2] = ch << 4;
		ch = Ascii[i + 1] & 0xf;
		if (Ascii[i + 1] > '9')
			ch += 9;
		Hex[i / 2] += ch;
	}
}

static bool IsNoStr(const char* str)
{
	int len = strlen(str);
	if (len == 0)
		return true;
	for (int i = 0; i < len; ++i) {
		if (*(str + i) != ' ')
			return false;
	}
	return true;
}

static DWORD GetDuration(const SYSTEMTIME& time1, const SYSTEMTIME& time2)
{
#if defined(RVC_OS_WIN)

    ULARGE_INTEGER fTime1;/*FILETIME*/
    ULARGE_INTEGER fTime2;/*FILETIME*/

    SystemTimeToFileTime(&time1, (FILETIME*)&fTime1);
    SystemTimeToFileTime(&time2, (FILETIME*)&fTime2);

    unsigned __int64 dft = fTime2.QuadPart - fTime1.QuadPart;
    return DWORD(dft / 10000);

#else
    ///**TODO(Gifur@9/3/2021): Bug 不能这样简单的实现，考虑凌晨，切换月份甚至是年份 */
    DWORD s1, s2;
    s1 = (time1.wMinute * 60 + time1.wSecond) * 1000 + time1.wMilliseconds;
    s2 = (time2.wMinute * 60 + time2.wSecond) * 1000 + time2.wMilliseconds;

    return s2 - s1;

#endif //RVC_OS_WIN
}

static std::string formatTime(const SYSTEMTIME& time)
{
    char tBuf[1024] = "";
    sprintf(tBuf, "%04u-%02u-%02u %02u:%02u:%02u:%03u", time.wYear, time.wMonth, time.wDay, time.wHour, time.wMinute, time.wSecond, time.wMilliseconds);
    return tBuf;
}

static bool ShellExecute(const std::string& cmd, std::string& succResult, std::string& errResult)
{
#if defined(_MSC_VER)
    ///*TODO(80374374@3/7/2023):  */
    return false;
#else
	char buf_ps[1024];
	char ps[1024] = { 0 };
	char result[2049] = { 0 };
	FILE* ptr;

	strcpy(ps, cmd.c_str());
	succResult = errResult = "";

	if ((ptr = popen(ps, "r")) != NULL) {
		while (fgets(buf_ps, 1024, ptr) != NULL) {
			if (strlen(result) + strlen(buf_ps) > 2048)
				break;
			strcat(result, buf_ps);
		}
		pclose(ptr);
		const int len = strlen(result);
		for (int i = len - 1; i >= 0 && (result[i] == '\r' || result[i] == '\n'); --i) {
			result[i] = '\0';
		}
		succResult = result;
		return true;
	} else {
		sprintf(result, "popen %s error: %d", ps, errno);
		errResult = result;
		return false;
	}
#endif //_MSC_VER
}

static CSimpleStringA generateConsumeTimeJson(const CSimpleStringA& entityName, const CSimpleStringA& startTime, int cost)
{
    return CSimpleStringA::Format("{\"name\":\"%s\",\"time\":\"%s\",\"cost\":%d}", entityName.GetData(), startTime.GetData(), cost);
}

#if defined(_MSC_VER)
static char* ConvertUtf8ToGBK(const char* strUtf8)
{
	int len = MultiByteToWideChar(CP_UTF8, 0, strUtf8, -1, NULL, 0);
	WCHAR* wszGBK = new WCHAR[len + 1];
	memset(wszGBK, 0, len * 2 + 2);
	MultiByteToWideChar(CP_UTF8, 0, strUtf8, -1, wszGBK, len);

	len = WideCharToMultiByte(CP_ACP, 0, wszGBK, -1, NULL, 0, NULL, NULL);
	char* szGBK = new char[len + 1];
	memset(szGBK, 0, len + 1);
	WideCharToMultiByte(CP_ACP, 0, wszGBK, -1, szGBK, len, NULL, NULL);
	delete[] wszGBK;

	return szGBK;
}

static void ConvertUtf8ToGBK(std::string& str)
{
	char* dst = ConvertUtf8ToGBK(str.c_str());
	str = dst;
	delete[] dst;
}

static char* ConvertGBKToUtf8(const char* gbk, int* n)
{
	int len = MultiByteToWideChar(CP_ACP, 0, gbk, -1, NULL, 0);
	WCHAR* wszGBK = new WCHAR[len + 1];
	memset(wszGBK, 0, len * 2 + 2);
	MultiByteToWideChar(CP_ACP, 0, gbk, -1, wszGBK, len);

	len = WideCharToMultiByte(CP_UTF8, 0, wszGBK, -1, NULL, 0, NULL, NULL);
	char* szUtf8 = new char[len + 1];
	memset(szUtf8, 0, len + 1);
	WideCharToMultiByte(CP_UTF8, 0, wszGBK, -1, szUtf8, len, NULL, NULL);

	delete[] wszGBK;
	*n = len - 1;
	return szUtf8;
}

static void ConvertGBKToUtf8(std::string& str)
{
	int len = 0;
	char* dst = ConvertGBKToUtf8(str.c_str(), &len);
	str = dst;
	delete[] dst;
}
#endif //_MSC_VER

static std::string W2S(const std::wstring wstr)
{
#if defined(_MSC_VER)
	char* str = NULL;
	int n = ::WideCharToMultiByte(CP_ACP, 0, wstr.c_str(), -1, NULL, 0, NULL, NULL);
	if (n > 0) {
		str = new char[n + 1];
		if (str == NULL) {
			return std::string();
		}
		std::memset(str, 0, sizeof(char) * (n + 1));
		::WideCharToMultiByte(CP_ACP, 0, wstr.c_str(), -1, &str[0], n, NULL, NULL);
		std::string strr(str);
		delete str;
		return strr;
	}
#else
	///*TODO(80374374@3/7/2023):  */
#endif //_MSC_VER
	return std::string();
}

static std::wstring S2W(const std::string str)
{
#if defined(_MSC_VER)
	wchar_t* wstr = NULL;
	int n = ::MultiByteToWideChar(CP_ACP, 0, str.c_str(), -1, NULL, 0);
	if (n > 0) {
		wstr = new wchar_t[n + 1];
		if (wstr == NULL) {
			return std::wstring();
		}
		std::memset(wstr, 0, (n + 1) * sizeof(wchar_t));
		::MultiByteToWideChar(CP_ACP, 0, str.c_str(), -1, &wstr[0], n);
		std::wstring strr(wstr);
		delete wstr;
		return strr;
	}
#else
	///*TODO(80374374@3/7/2023):  */
#endif //_MSC_VER
	return std::wstring();
}

} //namespace Util

namespace Net{

	struct NetworkAdapterItem
	{
		int idx;
		std::string friend_name;
		std::string adapter_name;
		std::string description;
		std::string ip;
		std::string mask;
		std::string mac;
		std::string gateway;
		std::string dhcp;
		bool is_physical;
		DWORD type;
		int operStatus;
		bool isLocal;

		NetworkAdapterItem() :idx(0), friend_name(""), adapter_name(""), description(""), ip(""), mask(""),
			mac(""), gateway(""), dhcp(""), is_physical(true), type(0), operStatus(0), isLocal(false)
		{
		}
	};

static bool IsLocalAdapter(const std::string& name)
	{
#if defined(_MSC_VER)
		if (name.length() <= 0) {
			return false;
	}
		std::string key("SYSTEM\\CurrentControlSet\\Control\\Network\\{4D36E972-E325-11CE-BFC1-08002BE10318}");
		HKEY h_sub_key = NULL;
		LONG ret = RegOpenKeyEx(HKEY_LOCAL_MACHINE, key.c_str(), 0, KEY_READ, &h_sub_key);
		if (ret != 0) {
			return false;
		}
		std::ostringstream str;
		str << name << "\\Connection";
		HKEY h_local_key = NULL;
		ret = RegOpenKeyEx(h_sub_key, str.str().c_str(), 0, KEY_READ, &h_local_key);
		if (0 != ret) {
			RegCloseKey(h_sub_key);
			return false;
		}
		DWORD type = REG_SZ;
		TCHAR buf[250];
		DWORD buf_size = 250;
		ret = RegQueryValueEx(h_local_key, "PnPInstanceId", 0, &type, (BYTE*)(buf), &buf_size);
		RegCloseKey(h_sub_key);
		RegCloseKey(h_local_key);
		if (0 != ret) {
			return false;
		}
		if (0 == strnicmp(buf, "PCI", strlen("PCI")) || 0 == strnicmp(buf, "USB", strlen("USB"))) {
			return true;
		}
		return false;
#else
		///*TODO(80374374@3/7/2023):  */
		return true;
#endif //_MSC_VER
	}

static ErrorCodeEnum GetINETMacAddresses(CAutoArray<NetworkAdapterItem>& netLists)
{
#if defined(RVC_OS_WIN)
	PIP_ADAPTER_ADDRESSES pAddresses = NULL;
	ULONG family = AF_INET;
	ULONG flags = GAA_FLAG_INCLUDE_PREFIX;
	ULONG outBufLen = sizeof(IP_ADAPTER_ADDRESSES);
	// Make an initial call to GetAdaptersAddresses to get the 
	// size needed into the outBufLen variable
	if (GetAdaptersAddresses(family, flags, NULL, pAddresses, &outBufLen) == ERROR_BUFFER_OVERFLOW) {
		pAddresses = static_cast<PIP_ADAPTER_ADDRESSES>(HeapAlloc(GetProcessHeap(), 0, outBufLen));
	}

	if (NULL == pAddresses) {
		DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("pAddresses = NULL");
		return Error_Unexpect;
	}
	DWORD dwRetVal = GetAdaptersAddresses(family, flags, NULL, pAddresses, &outBufLen);
	/*		MACAddresses vAddress;*/
	if (dwRetVal != ERROR_SUCCESS) {
		DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("dwRetVal = %d", dwRetVal);
		return Error_Unexpect;
	}
	PIP_ADAPTER_ADDRESSES pFirst = pAddresses;
	while (pAddresses) {
		if (pAddresses->FirstUnicastAddress &&
			pAddresses->IfType != IF_TYPE_SOFTWARE_LOOPBACK &&
			pAddresses->OperStatus == IfOperStatusUp &&
			pAddresses->FirstUnicastAddress->Address.lpSockaddr->sa_family == AF_INET 
			) {
			NetworkAdapterItem netItem;
			BYTE* pa = pAddresses->PhysicalAddress;
			if (!pa) {
				pAddresses = pAddresses->Next ? pAddresses->Next : NULL;
				continue;
			}

			CSimpleStringA strFriendlyName(true);
			CSimpleStringA strDescription(true);

			DWORD dwNum = WideCharToMultiByte(CP_OEMCP, NULL, pAddresses->FriendlyName, -1, NULL, 0, NULL, FALSE);
			char* psText = new char[dwNum];
			if (psText != NULL) {
				WideCharToMultiByte(CP_OEMCP, NULL, pAddresses->FriendlyName, -1, psText, dwNum, NULL, FALSE);
				strFriendlyName = psText;
				delete[] psText;
			}

			dwNum = WideCharToMultiByte(CP_OEMCP, NULL, pAddresses->Description, -1, NULL, 0, NULL, FALSE);
			psText = new char[dwNum];
			if (psText != NULL) {
				WideCharToMultiByte(CP_OEMCP, NULL, pAddresses->Description, -1, psText, dwNum, NULL, FALSE);
				strDescription = psText;
				delete[] psText;
			}

			char bAddressBytes[MACSESION];
			int bAddressInt[MACSESION];
			memset(bAddressBytes, 0, MACSESION);
			size_t nAddressSize = pAddresses->PhysicalAddressLength;
			memcpy(bAddressBytes, pa, (nAddressSize < MACSESION ? nAddressSize : MACSESION));
			for (int i = 0; i < MACSESION; ++i) {
				bAddressInt[i] = bAddressBytes[i];
				bAddressInt[i] &= 0x000000ff; // avoid "ff" leading bytes when "char" is lager then 0x7f
			}
			CSimpleStringA tmpmac = CSimpleStringA::Format("%02x:%02x:%02x:%02x:%02x:%02x",
				bAddressInt[0],
				bAddressInt[1],
				bAddressInt[2],
				bAddressInt[3],
				bAddressInt[4],
				bAddressInt[5]);

			sockaddr_in* sa_in = (sockaddr_in*)pAddresses->FirstUnicastAddress->Address.lpSockaddr;
			char buf_addr[100] = { 0 };
			CSimpleStringA tmpip = CSimpleStringA(inet_ntop(AF_INET, &(sa_in->sin_addr), buf_addr, 100));
			
			if (tmpip.Compare("127.0.0.1") == 0 && tmpmac.Compare("00:00:00:00:00:00") == 0) {
				//skip
			}
			else
			{
				netItem.friend_name = strFriendlyName;
				netItem.description = strDescription;
				netItem.mac = tmpmac;
				netItem.ip = tmpip;
				netItem.operStatus = (pAddresses->OperStatus == IfOperStatusUp) ? 1 : 0;//stay the same value with Linux/UOS
				netItem.type = pAddresses->IfType;
				netLists.Append(&netItem, 0, 1);
			}
			DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("%s, %s: OperStatus: %d, IfType = %d, ip=%s, mac=%s"
				, strFriendlyName.GetData(), strDescription.GetData()
				, pAddresses->OperStatus, pAddresses->IfType, tmpip.GetData(), tmpmac.GetData());
		}
		pAddresses = pAddresses->Next ? pAddresses->Next : NULL;
	}
	HeapFree(GetProcessHeap(), 0, pFirst);
	return Error_Succeed;

#else
	std::map<std::string, std::string> inteIPs;
	std::map<std::string, std::string> inteMacs;
	std::map<std::string, int> inteStatus;

	char buf[512];
	toolkit_interface_address_t* info;
	int count, i;
	toolkit_interface_addresses(&info, &count);
	i = count;
	DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("Number of interfaces: %d", count);
	while (i--) {
		toolkit_interface_address_t interface = info[i];

		DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("Name: %s", interface.name);
		DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("Internal? %s", interface.is_internal ? "Yes" : "No");
		if (interface.address.address4.sin_family == AF_INET) {
			toolkit_ip4_name(&interface.address.address4, buf, sizeof(buf));
			DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("IPv4 address: %s", buf);
			inteIPs[interface.name] = buf;
		}
		else if (interface.address.address4.sin_family == AF_INET6) {
			toolkit_ip6_name(&interface.address.address6, buf, sizeof(buf));
			DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("IPv6 address: %s", buf);
			//inteIPs[interface.name] = buf;
		}
	}

	toolkit_free_interface_addresses(info, count);

	int fd, interface;
	struct ifreq bufIfreq[16];
	struct ifconf ifc;
	char mac[32] = { 0 };
	if ((fd = socket(AF_INET, SOCK_DGRAM, 0)) >= 0) {
		int i = 0;
		ifc.ifc_len = sizeof(bufIfreq);
		ifc.ifc_buf = (caddr_t)bufIfreq;
		if (!ioctl(fd, SIOCGIFCONF, (char*)& ifc)) {
			interface = ifc.ifc_len / sizeof(struct ifreq);
			DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("interface num is %d", interface);
			while (i < interface) {
				DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("Name: %s", bufIfreq[i].ifr_name);
				if (!(ioctl(fd, SIOCGIFHWADDR, (char*)& bufIfreq[i]))) {
					sprintf(mac, "%02X:%02X:%02X:%02X:%02X:%02X",
						(unsigned char)bufIfreq[i].ifr_hwaddr.sa_data[0],
						(unsigned char)bufIfreq[i].ifr_hwaddr.sa_data[1],
						(unsigned char)bufIfreq[i].ifr_hwaddr.sa_data[2],
						(unsigned char)bufIfreq[i].ifr_hwaddr.sa_data[3],
						(unsigned char)bufIfreq[i].ifr_hwaddr.sa_data[4],
						(unsigned char)bufIfreq[i].ifr_hwaddr.sa_data[5]);
					DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("HWaddr %s", mac);
					inteMacs[bufIfreq[i].ifr_name] = mac;
				}
				struct ethtool_value edata;

				edata.cmd = ETHTOOL_GLINK;
				edata.data = 0;
				bufIfreq[i].ifr_data = (char*)& edata;
				//oiltmp@20231026 只检测了以太网卡
				if (ioctl(fd, SIOCETHTOOL, (char*)& bufIfreq[i]) == -1) {
					//up down
					DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("Name: %s is down", bufIfreq[i].ifr_name);
					inteStatus[bufIfreq[i].ifr_name] = 0;
				}
				else
				{
					DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("Name: %s is up", bufIfreq[i].ifr_name);
					inteStatus[bufIfreq[i].ifr_name] = 1;
				}
				i++;
			}
		}
		close(fd);
	}

	std::map<std::string, std::string>::const_iterator map_it = inteIPs.begin();
	while (map_it != inteIPs.end()) {
		NetworkAdapterItem netItem;
		CSimpleStringA tmpip(map_it->second.c_str());
		CSimpleStringA tmpmac(true);
		CSimpleStringA tmpname(true);
		auto it = inteMacs.find(std::string(map_it->first));
		if (it != inteMacs.end()) {
			tmpmac = it->second.c_str();
		}
		if (tmpip.Compare("127.0.0.1") == 0 && tmpmac.Compare("00:00:00:00:00:00") == 0) {
			//skip
		}
		else {
			tmpname = map_it->first.c_str();
			netItem.friend_name = "";//oiltmp
			netItem.description = tmpname;
			netItem.mac = tmpmac;
			netItem.ip = tmpip;
			netItem.operStatus = inteStatus[map_it->first];
			netItem.type = 6;//oiltest haven't find the in linux
			netLists.Append(&netItem, 0, 1);
		}
		++map_it;
	}
	return Error_Succeed;

#endif //RVC_OS_WIN

}


static std::vector<NetworkAdapterItem> GetNetAdapterItems()
{
	std::vector<NetworkAdapterItem> results;
#if defined(_MSC_VER)
	ULONG flags = GAA_FLAG_INCLUDE_PREFIX | GAA_FLAG_INCLUDE_GATEWAYS;
	ULONG family = AF_UNSPEC;
	PIP_ADAPTER_ADDRESSES address_ptr = nullptr;
	ULONG out_buf_len = 15000;
	DWORD ret_val = 0;
	PIP_ADAPTER_ADDRESSES cur_addr_ptr = nullptr;
	PIP_ADAPTER_UNICAST_ADDRESS unicast_ptr = nullptr;
	PIP_ADAPTER_ANYCAST_ADDRESS anycast_ptr = nullptr;
	PIP_ADAPTER_MULTICAST_ADDRESS multicast_ptr = nullptr;
	PIP_ADAPTER_DNS_SERVER_ADDRESS dns_server_ptr = nullptr;
	IP_ADAPTER_PREFIX* prefix_ptr = nullptr;

	do {
		address_ptr = (PIP_ADAPTER_ADDRESSES)malloc(out_buf_len);
		if (address_ptr == nullptr) {
			return results;
		}
		ret_val = GetAdaptersAddresses(family, flags, NULL, address_ptr, &out_buf_len);
		if (ERROR_BUFFER_OVERFLOW == ret_val) {
			free(address_ptr);
		}
	} while (ret_val == ERROR_BUFFER_OVERFLOW);

	if (NO_ERROR == ret_val) {
		cur_addr_ptr = address_ptr;
		while (cur_addr_ptr) {
			std::string description = Util::W2S(cur_addr_ptr->Description);
			bool is_local = IsLocalAdapter(cur_addr_ptr->AdapterName);
			std::string friend_name = Util::W2S(cur_addr_ptr->FriendlyName);
			NetworkAdapterItem item;
			item.idx = cur_addr_ptr->IfIndex;
			item.adapter_name = cur_addr_ptr->AdapterName;
			item.description = description;
			DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)(">>>>>>>>>>>>>>> friendly name: %s", friend_name.c_str());
			item.friend_name = friend_name;
			if (is_local) {
				DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("Adapter Desc: %s", description.c_str());
				DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("Adapter Name: %s", cur_addr_ptr->AdapterName);
				item.isLocal = true;
			}
			if (cur_addr_ptr->PhysicalAddressLength != 0) {
				char sz_addr[32] = { 0 };
				std::stringstream str;
				for (int i = 0; i < (int)cur_addr_ptr->PhysicalAddressLength; i++) {
					if (i == ((int)cur_addr_ptr->PhysicalAddressLength - 1))
						sprintf_s(sz_addr, "%.2X", (int)cur_addr_ptr->PhysicalAddress[i]);
					else
						sprintf_s(sz_addr, "%.2X:", (int)cur_addr_ptr->PhysicalAddress[i]);
					str << sz_addr;
				}
				item.mac = str.str();
			}
			item.type = cur_addr_ptr->IfType;
			item.operStatus = cur_addr_ptr->OperStatus;
			switch (cur_addr_ptr->IfType) {
			case MIB_IF_TYPE_OTHER:
				break;
			case MIB_IF_TYPE_ETHERNET:
				break;
			case MIB_IF_TYPE_TOKENRING:
				break;
			case MIB_IF_TYPE_FDDI:
				break;
			case MIB_IF_TYPE_PPP:
				break;
			case MIB_IF_TYPE_LOOPBACK:
				break;
			case MIB_IF_TYPE_SLIP:
				break;
			case IF_TYPE_IEEE80211:
				break;
			case IF_TYPE_WWANPP:
			case IF_TYPE_WWANPP2:
				//WWAN devices
				break;
			default:
				DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("Unknown type %d", cur_addr_ptr->IfType);
				break;
			}
			unicast_ptr = cur_addr_ptr->FirstUnicastAddress;
			while (unicast_ptr) {
				char ip[120] = { 0 };
				if (AF_INET == unicast_ptr->Address.lpSockaddr->sa_family) {
					inet_ntop(PF_INET, &((sockaddr_in*)unicast_ptr->Address.lpSockaddr)->sin_addr, ip, sizeof(ip));
				} else if (AF_INET6 == unicast_ptr->Address.lpSockaddr->sa_family) {
					inet_ntop(PF_INET6, &((sockaddr_in*)unicast_ptr->Address.lpSockaddr)->sin_addr, ip, sizeof(ip));
				}
				unicast_ptr = unicast_ptr->Next;
			}
			if (cur_addr_ptr->Dhcpv4Server.lpSockaddr) {
				char ip[120] = { 0 };
				if (AF_INET == cur_addr_ptr->Dhcpv4Server.lpSockaddr->sa_family) {
					inet_ntop(PF_INET, &((sockaddr_in*)cur_addr_ptr->Dhcpv4Server.lpSockaddr)->sin_addr, ip, sizeof(ip));
				} else if (AF_INET6 == cur_addr_ptr->Dhcpv4Server.lpSockaddr->sa_family) {
					inet_ntop(PF_INET6, &((sockaddr_in*)cur_addr_ptr->Dhcpv4Server.lpSockaddr)->sin_addr, ip, sizeof(ip));
				}
				item.dhcp = ip;
			}
			dns_server_ptr = cur_addr_ptr->FirstDnsServerAddress;
			while (dns_server_ptr) {
				char ip[120] = { 0 };
				if (AF_INET == dns_server_ptr->Address.lpSockaddr->sa_family) {
					inet_ntop(PF_INET, &((sockaddr_in*)dns_server_ptr->Address.lpSockaddr)->sin_addr, ip, sizeof(ip));
				} else if (AF_INET6 == dns_server_ptr->Address.lpSockaddr->sa_family) {
					inet_ntop(PF_INET6, &((sockaddr_in*)dns_server_ptr->Address.lpSockaddr)->sin_addr, ip, sizeof(ip));
				}
				dns_server_ptr = dns_server_ptr->Next;
			}
			auto gateway_ptr = cur_addr_ptr->FirstGatewayAddress;
			while (gateway_ptr) {
				char ip[120] = { 0 };
				if (AF_INET == gateway_ptr->Address.lpSockaddr->sa_family) {
					inet_ntop(PF_INET, &((sockaddr_in*)gateway_ptr->Address.lpSockaddr)->sin_addr, ip, sizeof(ip));
				} else if (AF_INET6 == gateway_ptr->Address.lpSockaddr->sa_family) {
					inet_ntop(PF_INET6, &((sockaddr_in*)gateway_ptr->Address.lpSockaddr)->sin_addr, ip, sizeof(ip));
				}
				gateway_ptr = gateway_ptr->Next;
			}
			results.push_back(item);
			cur_addr_ptr = cur_addr_ptr->Next;
		}
	} else {
		DbgWithLink(LOG_LEVEL_ERROR, LOG_TYPE_SYSTEM)("GetAdaptersAddresses failed with error: %d", ret_val);
	}
	free(address_ptr);
#else
///*TODO(80374374@3/7/2023):  */
#endif //_MSC_VER
	return results;
}

static BOOL CheckLANConnectStatus()
{
#if defined(_MSC_VER)
	DWORD dwFlag(0);
	BOOL bRet = InternetGetConnectedState(&dwFlag, 0);

	if ((dwFlag & INTERNET_CONNECTION_CONFIGURED) == INTERNET_CONNECTION_CONFIGURED) {
		DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("Local system has a valid connection to the Internet, but it might or might not be currently connected.");
	}
	if ((dwFlag & INTERNET_CONNECTION_LAN) == INTERNET_CONNECTION_LAN) {
		DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("Local system uses a local area network to connect to the Internet.");
	}
	if ((dwFlag & INTERNET_CONNECTION_MODEM) == INTERNET_CONNECTION_MODEM) {
		DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("Local system uses a modem to connect to the Internet.");
	}
	if ((dwFlag & INTERNET_CONNECTION_MODEM_BUSY) == INTERNET_CONNECTION_MODEM_BUSY) {
		DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("No longer used: INTERNET_CONNECTION_MODEM_BUSY");
	}
	if ((dwFlag & INTERNET_CONNECTION_OFFLINE) == INTERNET_CONNECTION_OFFLINE) {
		DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("Local system is in offline mode.");
	}
	if ((dwFlag & INTERNET_CONNECTION_PROXY) == INTERNET_CONNECTION_PROXY) {
		DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("Local system uses a proxy server to connect to the Internet.");
	}
	if ((dwFlag & INTERNET_RAS_INSTALLED) == INTERNET_RAS_INSTALLED) {
		DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("Local system has RAS installed.");
	}

	if (bRet) {
		DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("InternetGetConnectedState Succeed: 0x%08X", dwFlag);
	} else {
		DbgWithLink(LOG_LEVEL_ERROR, LOG_TYPE_SYSTEM)("InternetGetConnectedState failed: 0x%08X, GLE=%u", dwFlag, GetLastError());
	}
	return bRet;
#else
	return FALSE;
#endif //_MSC_VER

}

static std::string GetWWWInfoThroughDig(const std::string& wwwUrl)
{
    std::string succStr, errStr;
    std::string runStr("dig ");
    runStr += wwwUrl;
    if (SP::Module::Util::ShellExecute(runStr, succStr, errStr)) {
        return succStr;
    } else {
        return std::string("ShellExecute(") + wwwUrl +  ") failed";
    }
}

}//Net

} // mod
} // sp



#endif //RVC_MOD_COMM_ENTITY_UTIL_HPP_