|
|
@@ -1,795 +0,0 @@
|
|
|
-#include "stdafx.h"
|
|
|
-#include "CenterSettingConn.h"
|
|
|
-#include "Event.h"
|
|
|
-#include <map>
|
|
|
-#include <regex>
|
|
|
-using namespace std;
|
|
|
-using std::regex;
|
|
|
-#include "mod_centersetting.h"
|
|
|
-#include <iostream>
|
|
|
-#include <sys/types.h>
|
|
|
-#include <sys/stat.h>
|
|
|
-#include <fstream>
|
|
|
-#include "fileutil.h"
|
|
|
-#pragma comment(lib, "crypt32.lib")
|
|
|
-
|
|
|
-#ifdef RVC_OS_LINUX
|
|
|
-#include "CommEntityUtil.hpp"
|
|
|
-#include "iniutil.h"
|
|
|
-#include "json/json.h"
|
|
|
-#include "CommEntityRestful.hpp"
|
|
|
-#include "SpUtility.h"
|
|
|
-#include "RVCComm.h"
|
|
|
-#endif //RVC_OS_WIN
|
|
|
-
|
|
|
-#ifdef RVC_OS_WIN
|
|
|
-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;
|
|
|
-}
|
|
|
-
|
|
|
-void ConvertUtf8ToGBK(std::string& str)
|
|
|
-{
|
|
|
- char* dst = ConvertUtf8ToGBK(str.c_str());
|
|
|
- str = dst;
|
|
|
- delete[] dst;
|
|
|
-}
|
|
|
-
|
|
|
-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;
|
|
|
-}
|
|
|
-
|
|
|
-void ConvertGBKToUtf8(std::string& str)
|
|
|
-{
|
|
|
- //char *src = new char[str.length() + 1];
|
|
|
- //strncpy(src, str.c_str(), str.length() + 1);
|
|
|
- int len = 0;
|
|
|
- char* dst = ConvertGBKToUtf8(str.c_str(), &len);
|
|
|
-
|
|
|
- str = dst;
|
|
|
- //delete[] src;
|
|
|
- delete[] dst;
|
|
|
-}
|
|
|
-
|
|
|
-static char* ConvertBytesToHexStr(BYTE *pBuf, int nLen)
|
|
|
-{
|
|
|
- char *pRet = (char*)malloc(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;
|
|
|
-}
|
|
|
-#endif //RVC_OS_WIN
|
|
|
-
|
|
|
-void convert(string& str)
|
|
|
-{
|
|
|
- //将单斜杠转为双斜杠
|
|
|
- for (size_t i = 0; i < str.size(); i++) {
|
|
|
- if (str[i] == '\\') {
|
|
|
- str.insert(i, string("\\"));
|
|
|
- i++;
|
|
|
- }
|
|
|
- }
|
|
|
-}
|
|
|
-
|
|
|
-void transferblank(string& str)
|
|
|
-{
|
|
|
- int oldLen = str.length();
|
|
|
- int cnt = 0;
|
|
|
- for(int idx = 0; idx < oldLen; idx++)
|
|
|
- {
|
|
|
- if(str[idx] == ' ')
|
|
|
- cnt++;
|
|
|
- }
|
|
|
-
|
|
|
- str.resize(oldLen + cnt * 2);
|
|
|
- int j = oldLen - 1;
|
|
|
- int i = str.length() - 1;
|
|
|
- while( i >= 0 )
|
|
|
- {
|
|
|
- if(str[j] == ' ')
|
|
|
- {
|
|
|
- str[i--] = '0';
|
|
|
- str[i--] = '2';
|
|
|
- str[i--] = '%';
|
|
|
- j--;
|
|
|
- }
|
|
|
- else
|
|
|
- {
|
|
|
- str[i--] = str[j--];
|
|
|
- }
|
|
|
- }
|
|
|
-}
|
|
|
-
|
|
|
-#ifndef WITH_CPPRESTSDK_IN_CENTER
|
|
|
-bool CenterSettingResponse::Parse(string strData)
|
|
|
-{
|
|
|
- Json::Value root;
|
|
|
- Json::Reader reader;
|
|
|
- Json::Value arrConfig;
|
|
|
-
|
|
|
- reader.parse(strData, root, false);
|
|
|
-
|
|
|
- m_success = root["success"].asBool();
|
|
|
-
|
|
|
- if(m_success)
|
|
|
- {
|
|
|
- m_message = root["message"].asString();
|
|
|
- m_is_update = root["data"]["is_update"].asBool();
|
|
|
- m_is_reset = root["data"]["is_reset"].asBool();
|
|
|
- m_version_no = root["data"]["version_no"].asString();
|
|
|
- transferblank(m_version_no);
|
|
|
- DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("m_version_no:%s", m_version_no.c_str());
|
|
|
- DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("m_is_reset:%d", m_is_reset ? 1 : 0);
|
|
|
- m_sm3 = root["data"]["sm3"].asString();
|
|
|
- m_strConfig = root["data"]["config"].asString();
|
|
|
-
|
|
|
- if(m_is_update)
|
|
|
- {
|
|
|
- reader.parse(m_strConfig, arrConfig, false);
|
|
|
- if(arrConfig.isArray())
|
|
|
- {
|
|
|
- for(int j = 0; j < arrConfig.size(); j++)
|
|
|
- {
|
|
|
- ConfigItem configItem;
|
|
|
-
|
|
|
- configItem.m_moudle = arrConfig[j]["moudle"].asString();
|
|
|
- configItem.m_name = arrConfig[j]["name"].asString();
|
|
|
- configItem.m_value = arrConfig[j]["value"].asString();
|
|
|
-
|
|
|
- m_config.push_back(configItem);
|
|
|
- }
|
|
|
- }
|
|
|
- }
|
|
|
- }
|
|
|
- return true;
|
|
|
-}
|
|
|
-#endif
|
|
|
-
|
|
|
-bool AddVersionResponse::Parse(string strData)
|
|
|
-{
|
|
|
- Json::Value root;
|
|
|
- Json::Reader reader;
|
|
|
- reader.parse(strData, root, false);
|
|
|
- m_success = root["success"].asBool();
|
|
|
- return m_success;
|
|
|
-}
|
|
|
-
|
|
|
-CenterSettingsMicroServiceHelper::CenterSettingsMicroServiceHelper(CEntityBase* pEntity)
|
|
|
- :m_pEntity(pEntity), m_strLastTime(true), m_strCurSite(true), m_arrKeys(NULL), m_arrURLs(NULL), m_isFirst(true)
|
|
|
-{
|
|
|
- m_pEntity->GetFunction()->OpenConfig(Config_CenterSetting, m_pCenterConfig);
|
|
|
- m_pEntity->GetFunction()->OpenConfig(Config_Run, m_pRunConfig);
|
|
|
-
|
|
|
- m_pEntity->GetFunction()->GetSystemStaticInfo(m_terminalInfo);
|
|
|
- m_pHttpFunc = create_http(HTTPLogCallback);
|
|
|
-
|
|
|
- InitCenterSettingInfo();
|
|
|
-}
|
|
|
-
|
|
|
-#ifdef RVC_OS_WIN
|
|
|
-int CenterSettingsMicroServiceHelper::GetCenterSetting()
|
|
|
-{
|
|
|
-#else
|
|
|
-int CenterSettingsMicroServiceHelper::GetCenterSetting(bool byHand)
|
|
|
-{
|
|
|
-#endif
|
|
|
- LOG_FUNCTION();
|
|
|
-
|
|
|
- if(m_strUrl.IsNullOrEmpty() && m_urlsFromShell.size() <= 0)
|
|
|
- {
|
|
|
- m_strErrMsg = "集中配置服务地址不存在";
|
|
|
- return AllAddressNull;
|
|
|
- }
|
|
|
-
|
|
|
- CenterSettingReq req;
|
|
|
- CenterSettingResponse res;
|
|
|
- req.m_terminal_no = m_terminalInfo.strTerminalID.GetData();
|
|
|
-
|
|
|
- DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("m_strFilePath:%s", m_strFilePath.GetData());
|
|
|
-#ifdef RVC_OS_WIN
|
|
|
- if(!ExistsFile(m_strFilePath))
|
|
|
- {
|
|
|
- Dbg("!ExistsFile(m_strFilePath)");
|
|
|
-#else
|
|
|
-if ((byHand && !m_isFirst) || !ExistsFile(m_strFilePath))
|
|
|
- {
|
|
|
- if (byHand && !m_isFirst && ExistsFileA(m_strFilePath)) {
|
|
|
- LogWarn(Severity_Low, Error_Debug, EVENT_MOD_CENTERSETTING_UPDATE_CENTER_FORCE, "尝试强制重新下载集中配置");
|
|
|
- }
|
|
|
-#endif
|
|
|
- req.m_version = "";
|
|
|
- req.m_config = "";
|
|
|
- }
|
|
|
- else
|
|
|
- {
|
|
|
-#ifdef RVC_OS_LINUX
|
|
|
-if (m_isFirst) //如果是第一次更新则强制下载集中配置
|
|
|
- {
|
|
|
- req.m_version = "";
|
|
|
- req.m_config = "";
|
|
|
- }
|
|
|
- else
|
|
|
-#endif
|
|
|
- {
|
|
|
- req.m_version = m_strVersion.GetData();
|
|
|
- req.m_config = GetLocalConfig();
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- if(m_isFirst) m_isFirst = false;
|
|
|
-
|
|
|
- DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM)("m_strVersion:%s", req.m_version.c_str());
|
|
|
- req.m_update_time = GetUpdateTime();
|
|
|
- GetTimeoutValue(req.m_timeOut);
|
|
|
-
|
|
|
- DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM).setAPI("GetCenterSetting")(CSimpleStringA::Format("timeout:%d", req.m_timeOut));
|
|
|
-
|
|
|
- int ret1 = MANUAL, ret2 = MANUAL;
|
|
|
- if(!m_strUrl.IsNullOrEmpty())
|
|
|
- {
|
|
|
- req.m_url = m_strUrl;
|
|
|
- m_strCurUrl = req.m_url;
|
|
|
- req.m_url += "?update_time=" + req.m_update_time + "&terminal_no=" + req.m_terminal_no + "&version=" + req.m_version;
|
|
|
-#ifdef RVC_OS_WIN
|
|
|
- ret1 = OnRequest(req, res, m_strErrMsg);
|
|
|
-#else
|
|
|
- ret1 = GetCenterSettingsFromHttp(req, m_strErrMsg);
|
|
|
-#endif
|
|
|
- }
|
|
|
- else
|
|
|
- {
|
|
|
- DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM).setAPI("GetCenterSetting")("集中配置文件中地址为空，使用默认地址");
|
|
|
- }
|
|
|
-
|
|
|
- if(SUCC != ret1 && ret1 != EXIST)
|
|
|
- {
|
|
|
-
|
|
|
- if(m_urlsFromShell.size() <= 0)
|
|
|
- {
|
|
|
- DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM).setAPI("GetCenterSetting")("shell.ini中找不到集中配置地址");
|
|
|
- return ret1;
|
|
|
- }
|
|
|
-
|
|
|
- for(int i = 0; i < m_urlsFromShell.size(); i++)
|
|
|
- {
|
|
|
- req.m_url = m_urlsFromShell[i].GetData();
|
|
|
- m_strCurUrl = m_urlsFromShell[i].GetData();
|
|
|
- req.m_url += "?update_time=" + req.m_update_time + "&terminal_no=" + req.m_terminal_no + "&version=" + req.m_version;
|
|
|
-#ifdef RVC_OS_WIN
|
|
|
- ret2 = OnRequest(req, res);
|
|
|
- if(ret2 == SUCC)
|
|
|
- break;
|
|
|
-#else
|
|
|
- ret1 = GetCenterSettingsFromHttp(req, m_strErrMsg);
|
|
|
- if (ret1 == SUCC || ret1 == EXIST)
|
|
|
- break;
|
|
|
-#endif
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
-#ifdef RVC_OS_WIN
|
|
|
- if(SUCC == ret1 || SUCC == ret2)
|
|
|
- {
|
|
|
- if(!res.m_is_update)
|
|
|
- {
|
|
|
- DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM).setAPI("GetCenterSetting")("Centersetting not changed.");
|
|
|
- m_strErrMsg = "集中配置已是最新版本";
|
|
|
- return EXIST;
|
|
|
- }
|
|
|
-
|
|
|
- if(WriteToConfig(res))
|
|
|
- {
|
|
|
- m_strVersion = res.m_version_no.c_str();
|
|
|
- Dbg("WriteToConfig m_strVersion:%s", m_strVersion.GetData());
|
|
|
- m_pEntity->GetFunction()->OpenConfig(Config_CenterSetting, m_pCenterConfig, true);
|
|
|
- m_pRunConfig->WriteConfigValue("CenterSetting", "version", m_strVersion);
|
|
|
- UpdateVersion();
|
|
|
- if(res.m_is_reset)
|
|
|
- LogEvent(Severity_Middle, EVENT_MOD_CENTERSETTING_CRITICAL_UPDATE, "Update centersetting with critical items.");
|
|
|
-
|
|
|
- return SUCC;
|
|
|
- }
|
|
|
- }
|
|
|
-#endif
|
|
|
-
|
|
|
- return ret1;
|
|
|
-}
|
|
|
-
|
|
|
-void CenterSettingsMicroServiceHelper::InitCenterSettingInfo()
|
|
|
-{
|
|
|
- CSmartPointer<IConfigInfo> shellConfig;
|
|
|
- m_pEntity->GetFunction()->OpenConfig(Config_Shell, shellConfig);
|
|
|
-
|
|
|
- m_pCenterConfig->ReadConfigValue("CenterSetting", "LastUpdateTime", m_strLastTime);
|
|
|
- m_pRunConfig->ReadConfigValue("CenterSetting", "version", m_strVersion);
|
|
|
-#ifdef RVC_OS_LINUX
|
|
|
- if (!m_strVersion.IsNullOrEmpty()) {
|
|
|
- std::string tmp = m_strVersion.GetData();
|
|
|
- transferblank(tmp);
|
|
|
- m_strVersion = tmp.c_str();
|
|
|
- }
|
|
|
-#endif
|
|
|
- //从集中配置和shell.ini获取url
|
|
|
- m_pCenterConfig->ReadConfigValue("CenterSetting", "CenterConfigUrlNew", m_strUrl);
|
|
|
- if(m_strUrl.IsNullOrEmpty())
|
|
|
- {
|
|
|
- DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM).setAPI("InitCenterSettingInfo")("集中配置中的服务链接为空，使用默认链接");
|
|
|
- }
|
|
|
- else
|
|
|
- {
|
|
|
- DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("CenterConfigUrlNew:%s", m_strUrl.GetData());
|
|
|
- }
|
|
|
-
|
|
|
- CSimpleStringA strMicroServiceURLSection = "MicroServiceURL";
|
|
|
-
|
|
|
-#ifdef RVC_OS_WIN /** UOS配置后置后没这堆玩意，至少现在的配置中没有 但是windows还有[Gifur@202397]*/
|
|
|
-#ifdef DEVOPS_ON_ST /*DevOps流水线编译，ST环境*/
|
|
|
- strMicroServiceURLSection = "MicroServiceURL-ST";
|
|
|
-#elif defined(DEVOPS_ON_UAT)/*DevOps流水线编译，UAT环境*/
|
|
|
- strMicroServiceURLSection = "MicroServiceURL-UAT";
|
|
|
-#elif defined(DEVOPS_ON_PRD)/*DevOps流水线编译，PRD环境*/
|
|
|
- //strMicroServiceURLSection = "MicroServiceURL-PRD";
|
|
|
-#elif defined(DEVOPS_ON_DEV)/*DevOps流水线编译，Dev环境*/
|
|
|
- strMicroServiceURLSection = "MicroServiceURL-Dev";
|
|
|
-#else/*本地编译等非DevOps环境编译的版本*/
|
|
|
- strMicroServiceURLSection = "MicroServiceURL-Dev";
|
|
|
-#endif
|
|
|
-#endif //RVC_OS_WIN
|
|
|
-
|
|
|
- DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM).setAPI("InitCenterSettingInfo")("获取集中配置服务地址 Section name:%s", strMicroServiceURLSection.GetData());
|
|
|
-
|
|
|
- shellConfig->ReadAllKeys(strMicroServiceURLSection, m_arrKeys);
|
|
|
-
|
|
|
- CSimpleStringA strUrl;
|
|
|
- for(int i = 0; i < m_arrKeys.GetCount() && m_arrKeys[i].IsStartWith("CenterConfigUrl", true); i++)
|
|
|
- {
|
|
|
- shellConfig->ReadConfigValue(strMicroServiceURLSection, m_arrKeys[i].GetData(), strUrl);
|
|
|
- if(!strUrl.IsNullOrEmpty())
|
|
|
- {
|
|
|
- DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("add CenterURL:%s", strUrl.GetData());
|
|
|
- m_urlsFromShell.push_back(strUrl);
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- //获取集中配置路径、文件名、场所
|
|
|
- m_pEntity->GetFunction()->GetPath("CenterSetting", m_strFilePath);
|
|
|
- m_pEntity->GetFunction()->GetPath("RunInfo", m_strBakPath);
|
|
|
-#ifdef RVC_OS_WIN
|
|
|
- m_strBakPath += "\\runcfg\\CenterSetting.ini";
|
|
|
-#else
|
|
|
- m_strBakPath += SPLIT_SLASH_STR "runcfg" SPLIT_SLASH_STR "CenterSetting.ini";
|
|
|
-#endif
|
|
|
-}
|
|
|
-
|
|
|
-bool CenterSettingsMicroServiceHelper::WriteToConfig(const CenterSettingResponse& sResponse)
|
|
|
-{
|
|
|
- CSimpleStringA newPath = m_strBakPath + ".new";
|
|
|
-
|
|
|
- DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("config size: %d", sResponse.m_config.size());
|
|
|
- for(int i = 0; i < sResponse.m_config.size(); i++)
|
|
|
- {
|
|
|
- string module = sResponse.m_config[i].m_moudle;
|
|
|
- string name = sResponse.m_config[i].m_name;
|
|
|
- string value = sResponse.m_config[i].m_value;
|
|
|
-
|
|
|
-#ifdef RVC_OS_WIN
|
|
|
- if(!WritePrivateProfileStringA(module.c_str(), name.c_str(), value.c_str(), newPath))
|
|
|
- {
|
|
|
-#else
|
|
|
- if (inifile_write_str(newPath.GetData(), module.c_str(), name.c_str(), value.c_str()) == -1)
|
|
|
- {
|
|
|
-#endif
|
|
|
- DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM).setAPI("WriteToConfig")
|
|
|
- ("write %s:%s:%s fail", module.c_str(), name.c_str(), value.c_str());
|
|
|
- m_strErrMsg = "集中配置写入失败";
|
|
|
- LogWarn(Severity_Middle, Error_Unexpect, ERR_MOD_CENTERSETTING_WRITE_FAILED,
|
|
|
- CSimpleStringA::Format("集中配置写入失败：%s:%s:%s", module.c_str(), name.c_str(), value.c_str()));
|
|
|
- return false;
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM).setAPI("WriteToConfig")("集中配置写入成功");
|
|
|
-#ifdef RVC_OS_WIN
|
|
|
- CopyFileA(newPath, m_strFilePath, FALSE);
|
|
|
- DeleteFileA(newPath);
|
|
|
-#else
|
|
|
- fileutil_copy_file(m_strFilePath, newPath);
|
|
|
- fileutil_delete_file(newPath);
|
|
|
-#endif
|
|
|
- return true;
|
|
|
-}
|
|
|
-
|
|
|
-string CenterSettingsMicroServiceHelper::GetLocalConfig()
|
|
|
-{
|
|
|
- CAutoArray<CSimpleStringA> arrSections, arrKeys;
|
|
|
- CSimpleStringA strItem;
|
|
|
-
|
|
|
- if(Error_Succeed != m_pCenterConfig->ReadAllSections(arrSections))
|
|
|
- DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM).setAPI("GetLocalConfig")("Read all sections failed.");
|
|
|
-
|
|
|
- if(arrSections.GetCount() == 0)
|
|
|
- return "";
|
|
|
-
|
|
|
- for(int i = 0; i < arrSections.GetCount(); ++i)
|
|
|
- {
|
|
|
- m_pCenterConfig->ReadAllKeys(arrSections[i].GetData(), arrKeys);
|
|
|
- for(int j = 0; j < arrKeys.GetCount(); ++j)
|
|
|
- {
|
|
|
- CSimpleStringA value, tmp;
|
|
|
- m_pCenterConfig->ReadConfigValue(arrSections[i].GetData(), arrKeys[j].GetData(), value);
|
|
|
-
|
|
|
- tmp = CSimpleStringA::Format("{\"moudle\":\"%s\", \"name\":\"%s\", \"value\":\"%s\"}",
|
|
|
- arrSections[i].GetData(), arrKeys[j].GetData(), value.GetData());
|
|
|
-
|
|
|
- strItem += tmp + ",";
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
-
|
|
|
- string strConfig = strItem.SubString(0, strItem.GetLength() - 1).GetData();
|
|
|
- convert(strConfig);
|
|
|
- return strConfig;
|
|
|
-}
|
|
|
-
|
|
|
-void CenterSettingsMicroServiceHelper::UpdateVersion()
|
|
|
-{
|
|
|
- AddVersionReq sReq;
|
|
|
- AddVersionResponse sResponse;
|
|
|
-#ifdef RVC_OS_WIN
|
|
|
- CSimpleStringA url;
|
|
|
- m_pCenterConfig->ReadConfigValue("CenterSetting", "UpdateVersionUrl", url);
|
|
|
- sReq.m_url = url.GetData();
|
|
|
- sReq.m_terminal_no = m_terminalInfo.strTerminalID.GetData();
|
|
|
- sReq.m_version = m_strVersion;
|
|
|
- sReq.m_update_time = GetUpdateTime();
|
|
|
- GetTimeoutValue(sReq.m_timeOut);
|
|
|
-
|
|
|
- //IHttpFunc* m_pHttpFunc = create_http(HTTPLogCallback);
|
|
|
- PROCESS_LINK_CONTEXT("LR0402101UploadVersion")
|
|
|
- bool ret = m_pHttpFunc->Post(sReq, sResponse, &nextLink);
|
|
|
-
|
|
|
- if(ret && sResponse.m_success)
|
|
|
- {
|
|
|
- CSimpleStringA msg = CSimpleStringA::Format("上传版本号成功：{version : %s, update_time : %s}",
|
|
|
- sReq.m_version.c_str(), sReq.m_update_time.c_str());
|
|
|
- LogWarn(Severity_Low, Error_Succeed, EVENT_MOD_CENTERSETTING_UPDATE_VERSION_SUCC, msg.GetData());
|
|
|
- }
|
|
|
- else
|
|
|
- {
|
|
|
- CSimpleStringA msg = CSimpleStringA::Format("上传版本号失败:%s", sResponse.m_errMsg.c_str());
|
|
|
- LogWarn(Severity_Middle, Error_Succeed, EVENT_MOD_CENTERSETTING_UPDATE_VERSION_FAILED, msg.GetData());
|
|
|
-
|
|
|
- }
|
|
|
-#else
|
|
|
- struct UpdateVersionReq //Req和Ans的变量名必须和服务端json要求的一致，切记！
|
|
|
- {
|
|
|
- string terminal_no;
|
|
|
- string version_no;
|
|
|
- string terminal_update_time;
|
|
|
- JSONCONVERT2OBJECT_MEMEBER_REGISTER(terminal_no, version_no, terminal_update_time)
|
|
|
- } updateVersionReq;
|
|
|
-
|
|
|
- CSimpleStringA url;
|
|
|
- m_pCenterConfig->ReadConfigValue("CenterSetting", "UpdateVersionUrl", url);
|
|
|
-
|
|
|
- HttpClientResponseResult result;
|
|
|
- HttpClientRequestConfig config(HttpRequestMethod::POST, url.GetData(), &SpGetToken);
|
|
|
-
|
|
|
- updateVersionReq.terminal_no = m_terminalInfo.strTerminalID.GetData();
|
|
|
- updateVersionReq.version_no = m_strVersion;
|
|
|
- updateVersionReq.terminal_update_time = GetUpdateTime();
|
|
|
-
|
|
|
- SP::Module::Restful::FulfillRequestJsonBody(&config, updateVersionReq);
|
|
|
-
|
|
|
- RestfulClient client = RestfulClient::getInstance();
|
|
|
- PROCESS_LINK_CONTEXT("LR0402101UpdateVersion");
|
|
|
- config.PreDo();
|
|
|
- client.Do(&config, &result, &nextLink);
|
|
|
-
|
|
|
- DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("返回内容为 %s", result.content.length() > 1000 ? result.content.substr(0, 1000).c_str() : result.content.c_str());
|
|
|
-
|
|
|
- if (!result.ResponseOK()) {
|
|
|
- DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("Do failed: %s", result.WhatError().c_str());
|
|
|
- return;
|
|
|
- }
|
|
|
-
|
|
|
- SP::Module::Restful::CommResponseJson responseStatus;
|
|
|
- SP::Module::Restful::GetStatusFromDebranchResponse(result.content, responseStatus);
|
|
|
-
|
|
|
- if (responseStatus.success) {
|
|
|
- CSimpleStringA msg = CSimpleStringA::Format("上传版本号成功：{version : %s, update_time : %s}",
|
|
|
- updateVersionReq.version_no.c_str(), updateVersionReq.terminal_update_time.c_str());
|
|
|
- LogWarn(Severity_Low, Error_Succeed, EVENT_MOD_CENTERSETTING_UPDATE_VERSION_SUCC, msg.GetData());
|
|
|
- } else {
|
|
|
- CSimpleStringA msg = CSimpleStringA::Format("上传版本号失败:%s", result.content.c_str());
|
|
|
- LogWarn(Severity_Middle, Error_Succeed, EVENT_MOD_CENTERSETTING_UPDATE_VERSION_FAILED, msg.GetData());
|
|
|
-
|
|
|
- }
|
|
|
-#endif
|
|
|
-}
|
|
|
-
|
|
|
-SYSTEMTIME GetModifyTime(const string& strFilename)
|
|
|
-{
|
|
|
-#if defined(_MSC_VER)
|
|
|
- struct _stat64i32 statbuf;
|
|
|
- _stat64i32(strFilename.c_str(), &statbuf);
|
|
|
- struct tm* temptm = _localtime64(&statbuf.st_mtime);
|
|
|
-#else
|
|
|
- struct stat statbuf;
|
|
|
- ZeroMemory(&statbuf, sizeof(statbuf));
|
|
|
- stat(strFilename.c_str(), &statbuf);
|
|
|
- struct tm* temptm = localtime(&statbuf.st_mtime);
|
|
|
-#endif //_MSC_VER
|
|
|
-
|
|
|
- SYSTEMTIME st = { 1900 + temptm->tm_year,
|
|
|
- 1 + temptm->tm_mon,
|
|
|
- temptm->tm_wday,
|
|
|
- temptm->tm_mday,
|
|
|
- temptm->tm_hour,
|
|
|
- temptm->tm_min,
|
|
|
- temptm->tm_sec,
|
|
|
- 0 };
|
|
|
-
|
|
|
- return st;
|
|
|
-}
|
|
|
-
|
|
|
-string CenterSettingsMicroServiceHelper::GetUpdateTime()
|
|
|
-{
|
|
|
- CSimpleStringA strUpdateTime;
|
|
|
-
|
|
|
- /** 配置后置后本地没有这个实体文件，都被框架放到运行时了，所以需要处理这个逻辑 [Gifur@202397]*/
|
|
|
- if(ExistsFileA(m_strFilePath))
|
|
|
- {
|
|
|
-#ifdef RVC_OS_WIN
|
|
|
- struct _stat64i32 statbuf;
|
|
|
- _stat64i32(m_strFilePath.GetData(), &statbuf);
|
|
|
-#endif
|
|
|
- SYSTEMTIME st = GetModifyTime(m_strFilePath.GetData());
|
|
|
- strUpdateTime = CSimpleStringA::Format("%d-%02d-%02d-%02d:%02d:%02d",
|
|
|
- st.wYear, st.wMonth, st.wDay, st.wHour, st.wMinute, st.wSecond);
|
|
|
- }
|
|
|
- else
|
|
|
- {
|
|
|
-#ifdef RVC_OS_WIN
|
|
|
- SYSTEMTIME st, stLocal;
|
|
|
- GetSystemTime(&st);
|
|
|
- SystemTimeToTzSpecificLocalTime(NULL, &st, &stLocal);
|
|
|
-#else
|
|
|
- SYSTEMTIME stLocal = CSmallDateTime::GetNow().ToSystemTime();
|
|
|
-#endif
|
|
|
- strUpdateTime = CSimpleStringA::Format("%d-%02d-%02d-%02d:%02d:%02d",
|
|
|
- stLocal.wYear, stLocal.wMonth, stLocal.wDay,
|
|
|
- stLocal.wHour, stLocal.wMinute, stLocal.wSecond);
|
|
|
- }
|
|
|
- return strUpdateTime.GetData();
|
|
|
-}
|
|
|
-
|
|
|
-void CenterSettingsMicroServiceHelper::GetTimeoutValue(int& timeout)
|
|
|
-{
|
|
|
- int timeoutFromConfig = 0;
|
|
|
- m_pCenterConfig->ReadConfigValueInt("CenterSetting", "Timeout", timeoutFromConfig);
|
|
|
- if(timeoutFromConfig == 0)
|
|
|
- return;
|
|
|
- else
|
|
|
- timeout = timeoutFromConfig;
|
|
|
-}
|
|
|
-
|
|
|
-#ifdef RVC_OS_WIN
|
|
|
-int CenterSettingsMicroServiceHelper::OnRequest(CenterSettingReq& req, CenterSettingResponse& res, string& errMsg)
|
|
|
-{
|
|
|
- PROCESS_LINK_CONTEXT("LR0402101SyncCenter")
|
|
|
- bool ret = m_pHttpFunc->Post(req, res, &nextLink);
|
|
|
-
|
|
|
- if(ret && res.m_success)
|
|
|
- {
|
|
|
- if(!res.m_is_update)
|
|
|
- return SUCC;
|
|
|
-
|
|
|
- ConvertGBKToUtf8(res.m_strConfig);
|
|
|
- string strConfig = res.m_strConfig;
|
|
|
-
|
|
|
-
|
|
|
- BYTE sm3[32] = {};
|
|
|
- if(strConfig.length() > 2)
|
|
|
- {
|
|
|
- if (!SM3Hash((BYTE*)(strConfig.c_str()), strlen(strConfig.c_str()), sm3))
|
|
|
- {
|
|
|
- errMsg = "计算SM3失败";
|
|
|
- DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM).setAPI("OnRequest")
|
|
|
- (CSimpleStringA::Format("计算SM3失败(%s)", req.m_url.c_str()));
|
|
|
- return CalcSM3Fail;
|
|
|
- }
|
|
|
- else
|
|
|
- {
|
|
|
- int sm3len = sizeof(sm3);
|
|
|
- char* strsm3 = ConvertBytesToHexStr(sm3, 32);
|
|
|
-
|
|
|
- if(0 != strcmp(strsm3, res.m_sm3.c_str()))
|
|
|
- {
|
|
|
- errMsg = "SM3校验失败";
|
|
|
- DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM).setAPI("OnRequest")
|
|
|
- (CSimpleStringA::Format("SM3校验失败(%s)", req.m_url.c_str()));
|
|
|
- return CheckSM3Fail;
|
|
|
- }
|
|
|
-
|
|
|
- m_strVersion = res.m_version_no.c_str();
|
|
|
-
|
|
|
- return SUCC;
|
|
|
- }
|
|
|
- }
|
|
|
- }
|
|
|
- else
|
|
|
- {
|
|
|
- //ConvertUtf8ToGBK(res.m_errMsg);
|
|
|
- errMsg = res.m_errMsg;
|
|
|
- DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM).setAPI("OnRequest")
|
|
|
- (CSimpleStringA::Format("访问失败：%s", res.m_errMsg.c_str()));
|
|
|
-
|
|
|
- if(res.m_sysCode == 28 || res.m_sysCode == 7)
|
|
|
- return AccessServiceFail;
|
|
|
-
|
|
|
- return MANUAL;
|
|
|
- }
|
|
|
-}
|
|
|
-#else
|
|
|
-int CenterSettingsMicroServiceHelper::GetCenterSettingsFromHttp(CenterSettingReq& req, string& errMsg)
|
|
|
-{
|
|
|
- LOG_FUNCTION();
|
|
|
- CenterSettingResponse res;
|
|
|
-
|
|
|
- struct GetCenterSettingReq //Req和Ans的变量名必须和服务端json要求的一致，切记！
|
|
|
- {
|
|
|
- string m_terminal_no;
|
|
|
- string m_version;
|
|
|
- string m_update_time;
|
|
|
- string m_config;
|
|
|
- JSONCONVERT2OBJECT_MEMEBER_REGISTER(m_terminal_no, m_version, m_update_time, m_config)
|
|
|
- } getCenterSettingReq;
|
|
|
-
|
|
|
- struct GetCenterSettingAns //Req和Ans的变量名必须和服务端json要求的一致，切记！
|
|
|
- {
|
|
|
- bool success;
|
|
|
- string message;
|
|
|
- bool is_update;
|
|
|
- bool is_reset;
|
|
|
- string version_no;
|
|
|
- string sm3;
|
|
|
- string config;
|
|
|
- JSONCONVERT2OBJECT_MEMEBER_REGISTER(success, message, is_update, is_reset, version_no, sm3, config)
|
|
|
- }getCenterSettingAns;
|
|
|
-
|
|
|
- HttpClientResponseResult result;
|
|
|
- HttpClientRequestConfig config(HttpRequestMethod::POST, req.m_url, &SpGetToken);
|
|
|
- if (req.m_timeOut > 0) config.SetTimeout(req.m_timeOut);
|
|
|
-
|
|
|
- getCenterSettingReq.m_terminal_no = req.m_terminal_no;
|
|
|
- getCenterSettingReq.m_version = req.m_version;
|
|
|
- getCenterSettingReq.m_update_time = req.m_update_time;
|
|
|
- getCenterSettingReq.m_config = req.m_config;
|
|
|
-
|
|
|
- SP::Module::Restful::FulfillRequestJsonBody(&config, getCenterSettingReq);
|
|
|
-
|
|
|
- Dbg("Geting centtersetting...");
|
|
|
-
|
|
|
- RestfulClient client = RestfulClient::getInstance();
|
|
|
- PROCESS_LINK_CONTEXT("LR0402101GetCenterSetting");
|
|
|
- config.PreDo();
|
|
|
- client.Do(&config, &result, &nextLink);
|
|
|
-
|
|
|
- Dbg("ret result.ResponseOK() = %d.", result.ResponseOK());
|
|
|
- if (!result.ResponseOK()) {
|
|
|
- DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("Do failed: %s", result.WhatError().c_str());
|
|
|
- errMsg = result.WhatError();
|
|
|
- return AccessServiceFail;
|
|
|
- }
|
|
|
- SP::Module::Restful::CommResponseJson responseStatus;
|
|
|
- SP::Module::Restful::GetStatusFromDebranchResponse(result.content, responseStatus);
|
|
|
- if (!responseStatus.IsOperatedOK()) {
|
|
|
- DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)(result.content.c_str());
|
|
|
- errMsg = responseStatus.WhatError().c_str();
|
|
|
- return MANUAL;
|
|
|
- }
|
|
|
-
|
|
|
- DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("%s", result.content.length() > 1000 ? result.content.substr(0, 1000).c_str() : result.content.c_str());
|
|
|
- if (!SP::Module::Restful::ExtractDataFromDebranchResponse(result.content, getCenterSettingAns)) {
|
|
|
- DbgWithLink(LOG_LEVEL_ERROR, LOG_TYPE_SYSTEM)("parse json data node failed: ");
|
|
|
- errMsg = "解析集中配置返回的信息失败";
|
|
|
- return UNknown;
|
|
|
- }
|
|
|
- //transferblank(centerSettingAns.version_no);
|
|
|
- ///** 当时粤超开发Windows版本时，要求服务端将数组转化为字符串传送，这边信创为了兼容，需要重新转为数组处理（信创是支持JSON数组） [Gifur@202398]*/
|
|
|
- //string strConfig = centerSettingAns.config;
|
|
|
- //vector<ConfigItem> m_config;
|
|
|
- //SP::Utility::replaceInPlace(centerSettingAns.config, "\\\"", "\"");
|
|
|
- //if (!Json2Object(m_config, centerSettingAns.config)) {
|
|
|
- // DbgWithLink(LOG_LEVEL_WARN, LOG_TYPE_SYSTEM)("parse config content failed!");
|
|
|
- // errMsg = "解析集中配置返回的配置信息失败";
|
|
|
- // return UNknown;
|
|
|
- //}
|
|
|
- res.Parse(result.content);
|
|
|
- string strConfig = SP::Utility::GBK2UTF8(res.m_strConfig);
|
|
|
-
|
|
|
- if (!res.m_is_update) {
|
|
|
- DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM).setAPI("GetCenterSetting")("Centersetting not changed.");
|
|
|
- errMsg = "集中配置已是最新版本";
|
|
|
- return EXIST;
|
|
|
- }
|
|
|
-
|
|
|
- DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("config length:%d", strConfig.length());
|
|
|
-
|
|
|
- BYTE sm3[32] = {};
|
|
|
- if (strConfig.length() > 2) {
|
|
|
- if (!SM3Hash((BYTE*)(strConfig.c_str()), strConfig.length(), sm3)) {
|
|
|
- errMsg = "计算SM3失败";
|
|
|
- DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM).setAPI("GetCenterSettingsFromHttp")("计算SM3失败(%s)", req.m_url.c_str());
|
|
|
- return CalcSM3Fail;
|
|
|
- } else {
|
|
|
- DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("sm3:%s", res.m_sm3.c_str());
|
|
|
- char* strsm3 = SP::Module::Util::ConvertBytesToHexStr(sm3, 32);
|
|
|
- if (0 != strcmp(strsm3, res.m_sm3.c_str())) {
|
|
|
- errMsg = "SM3校验失败";
|
|
|
- DbgWithLink(LOG_LEVEL_INFO, LOG_TYPE_SYSTEM).setAPI("GetCenterSettingsFromHttp")("SM3校验失败(%s)", req.m_url.c_str());
|
|
|
- delete[] strsm3;
|
|
|
- return CheckSM3Fail;
|
|
|
- }
|
|
|
- m_strVersion = res.m_version_no.c_str();
|
|
|
- delete[] strsm3;
|
|
|
- }
|
|
|
-
|
|
|
- if (WriteToConfig(res)) {
|
|
|
- m_strVersion = res.m_version_no.c_str();
|
|
|
- DbgWithLink(LOG_LEVEL_DEBUG, LOG_TYPE_SYSTEM)("WriteToConfig m_strVersion:%s", m_strVersion.GetData());
|
|
|
- m_pEntity->GetFunction()->OpenConfig(Config_CenterSetting, m_pCenterConfig, true);
|
|
|
- m_pRunConfig->WriteConfigValue("CenterSetting", "version", m_strVersion);
|
|
|
- UpdateVersion();
|
|
|
- if (res.m_is_reset) {
|
|
|
- LogEvent(Severity_Middle, EVENT_MOD_CENTERSETTING_CRITICAL_UPDATE, "Update centersetting with critical items.");
|
|
|
- }
|
|
|
- return SUCC;
|
|
|
- }
|
|
|
- }
|
|
|
- return UNknown;
|
|
|
-}
|
|
|
-#endif
|
陈纪林80310970