1585346868/aliyun-openapi-cpp-sdk
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fixed #51

Browse Source
This commit is contained in:
wb-hx510875
2019-09-19 11:14:07 +08:00
parent 2f6036b803
commit ba463ae2dc
1795 changed files with 41555 additions and 38367 deletions
Download Patch File Download Diff File Expand all files Collapse all files

20
ons/src/model/OnsConsumerAccumulateResult.cc
View File

@@ -50,18 +50,18 @@ void OnsConsumerAccumulateResult::parse(const std::string &payload)
data_.lastTimestamp = std::stol(dataNode["LastTimestamp"].asString());
if(!dataNode["DelayTime"].isNull())
data_.delayTime = std::stol(dataNode["DelayTime"].asString());
auto allDetailInTopicList = value["DetailInTopicList"]["DetailInTopicDo"];
for (auto value : allDetailInTopicList)
auto allDetailInTopicListNode = dataNode["DetailInTopicList"]["DetailInTopicDo"];
for (auto dataNodeDetailInTopicListDetailInTopicDo : allDetailInTopicListNode)
{
Data::DetailInTopicDo detailInTopicDoObject;
if(!value["Topic"].isNull())
detailInTopicDoObject.topic = value["Topic"].asString();
if(!value["TotalDiff"].isNull())
detailInTopicDoObject.totalDiff = std::stol(value["TotalDiff"].asString());
if(!value["LastTimestamp"].isNull())
detailInTopicDoObject.lastTimestamp = std::stol(value["LastTimestamp"].asString());
if(!value["DelayTime"].isNull())
detailInTopicDoObject.delayTime = std::stol(value["DelayTime"].asString());
if(!dataNodeDetailInTopicListDetailInTopicDo["Topic"].isNull())
detailInTopicDoObject.topic = dataNodeDetailInTopicListDetailInTopicDo["Topic"].asString();
if(!dataNodeDetailInTopicListDetailInTopicDo["TotalDiff"].isNull())
detailInTopicDoObject.totalDiff = std::stol(dataNodeDetailInTopicListDetailInTopicDo["TotalDiff"].asString());
if(!dataNodeDetailInTopicListDetailInTopicDo["LastTimestamp"].isNull())
detailInTopicDoObject.lastTimestamp = std::stol(dataNodeDetailInTopicListDetailInTopicDo["LastTimestamp"].asString());
if(!dataNodeDetailInTopicListDetailInTopicDo["DelayTime"].isNull())
detailInTopicDoObject.delayTime = std::stol(dataNodeDetailInTopicListDetailInTopicDo["DelayTime"].asString());
data_.detailInTopicList.push_back(detailInTopicDoObject);
}
if(!value["HelpUrl"].isNull())

20
ons/src/model/OnsConsumerGetConnectionResult.cc
View File

@@ -40,18 +40,18 @@ void OnsConsumerGetConnectionResult::parse(const std::string &payload)
reader.parse(payload, value);
setRequestId(value["RequestId"].asString());
auto dataNode = value["Data"];
auto allConnectionList = value["ConnectionList"]["ConnectionDo"];
for (auto value : allConnectionList)
auto allConnectionListNode = dataNode["ConnectionList"]["ConnectionDo"];
for (auto dataNodeConnectionListConnectionDo : allConnectionListNode)
{
Data::ConnectionDo connectionDoObject;
if(!value["ClientId"].isNull())
connectionDoObject.clientId = value["ClientId"].asString();
if(!value["ClientAddr"].isNull())
connectionDoObject.clientAddr = value["ClientAddr"].asString();
if(!value["Language"].isNull())
connectionDoObject.language = value["Language"].asString();
if(!value["Version"].isNull())
connectionDoObject.version = value["Version"].asString();
if(!dataNodeConnectionListConnectionDo["ClientId"].isNull())
connectionDoObject.clientId = dataNodeConnectionListConnectionDo["ClientId"].asString();
if(!dataNodeConnectionListConnectionDo["ClientAddr"].isNull())
connectionDoObject.clientAddr = dataNodeConnectionListConnectionDo["ClientAddr"].asString();
if(!dataNodeConnectionListConnectionDo["Language"].isNull())
connectionDoObject.language = dataNodeConnectionListConnectionDo["Language"].asString();
if(!dataNodeConnectionListConnectionDo["Version"].isNull())
connectionDoObject.version = dataNodeConnectionListConnectionDo["Version"].asString();
data_.connectionList.push_back(connectionDoObject);
}
if(!value["HelpUrl"].isNull())

136
ons/src/model/OnsConsumerStatusResult.cc
View File

@@ -58,97 +58,97 @@ void OnsConsumerStatusResult::parse(const std::string &payload)
data_.rebalanceOK = dataNode["RebalanceOK"].asString() == "true";
if(!dataNode["InstanceId"].isNull())
data_.instanceId = dataNode["InstanceId"].asString();
auto allConnectionSet = value["ConnectionSet"]["ConnectionDo"];
for (auto value : allConnectionSet)
auto allConnectionSetNode = dataNode["ConnectionSet"]["ConnectionDo"];
for (auto dataNodeConnectionSetConnectionDo : allConnectionSetNode)
{
Data::ConnectionDo connectionDoObject;
if(!value["ClientId"].isNull())
connectionDoObject.clientId = value["ClientId"].asString();
if(!value["ClientAddr"].isNull())
connectionDoObject.clientAddr = value["ClientAddr"].asString();
if(!value["Language"].isNull())
connectionDoObject.language = value["Language"].asString();
if(!value["Version"].isNull())
connectionDoObject.version = value["Version"].asString();
if(!value["RemoteIP"].isNull())
connectionDoObject.remoteIP = value["RemoteIP"].asString();
if(!dataNodeConnectionSetConnectionDo["ClientId"].isNull())
connectionDoObject.clientId = dataNodeConnectionSetConnectionDo["ClientId"].asString();
if(!dataNodeConnectionSetConnectionDo["ClientAddr"].isNull())
connectionDoObject.clientAddr = dataNodeConnectionSetConnectionDo["ClientAddr"].asString();
if(!dataNodeConnectionSetConnectionDo["Language"].isNull())
connectionDoObject.language = dataNodeConnectionSetConnectionDo["Language"].asString();
if(!dataNodeConnectionSetConnectionDo["Version"].isNull())
connectionDoObject.version = dataNodeConnectionSetConnectionDo["Version"].asString();
if(!dataNodeConnectionSetConnectionDo["RemoteIP"].isNull())
connectionDoObject.remoteIP = dataNodeConnectionSetConnectionDo["RemoteIP"].asString();
data_.connectionSet.push_back(connectionDoObject);
}
auto allDetailInTopicList = value["DetailInTopicList"]["DetailInTopicDo"];
for (auto value : allDetailInTopicList)
auto allDetailInTopicListNode = dataNode["DetailInTopicList"]["DetailInTopicDo"];
for (auto dataNodeDetailInTopicListDetailInTopicDo : allDetailInTopicListNode)
{
Data::DetailInTopicDo detailInTopicDoObject;
if(!value["Topic"].isNull())
detailInTopicDoObject.topic = value["Topic"].asString();
if(!value["TotalDiff"].isNull())
detailInTopicDoObject.totalDiff = std::stol(value["TotalDiff"].asString());
if(!value["LastTimestamp"].isNull())
detailInTopicDoObject.lastTimestamp = std::stol(value["LastTimestamp"].asString());
if(!value["DelayTime"].isNull())
detailInTopicDoObject.delayTime = std::stol(value["DelayTime"].asString());
if(!dataNodeDetailInTopicListDetailInTopicDo["Topic"].isNull())
detailInTopicDoObject.topic = dataNodeDetailInTopicListDetailInTopicDo["Topic"].asString();
if(!dataNodeDetailInTopicListDetailInTopicDo["TotalDiff"].isNull())
detailInTopicDoObject.totalDiff = std::stol(dataNodeDetailInTopicListDetailInTopicDo["TotalDiff"].asString());
if(!dataNodeDetailInTopicListDetailInTopicDo["LastTimestamp"].isNull())
detailInTopicDoObject.lastTimestamp = std::stol(dataNodeDetailInTopicListDetailInTopicDo["LastTimestamp"].asString());
if(!dataNodeDetailInTopicListDetailInTopicDo["DelayTime"].isNull())
detailInTopicDoObject.delayTime = std::stol(dataNodeDetailInTopicListDetailInTopicDo["DelayTime"].asString());
data_.detailInTopicList.push_back(detailInTopicDoObject);
}
auto allConsumerConnectionInfoList = value["ConsumerConnectionInfoList"]["ConsumerConnectionInfoDo"];
for (auto value : allConsumerConnectionInfoList)
auto allConsumerConnectionInfoListNode = dataNode["ConsumerConnectionInfoList"]["ConsumerConnectionInfoDo"];
for (auto dataNodeConsumerConnectionInfoListConsumerConnectionInfoDo : allConsumerConnectionInfoListNode)
{
Data::ConsumerConnectionInfoDo consumerConnectionInfoDoObject;
if(!value["ClientId"].isNull())
consumerConnectionInfoDoObject.clientId = value["ClientId"].asString();
if(!value["Connection"].isNull())
consumerConnectionInfoDoObject.connection = value["Connection"].asString();
if(!value["Language"].isNull())
consumerConnectionInfoDoObject.language = value["Language"].asString();
if(!value["Version"].isNull())
consumerConnectionInfoDoObject.version = value["Version"].asString();
if(!value["ConsumeModel"].isNull())
consumerConnectionInfoDoObject.consumeModel = value["ConsumeModel"].asString();
if(!value["ConsumeType"].isNull())
consumerConnectionInfoDoObject.consumeType = value["ConsumeType"].asString();
if(!value["ThreadCount"].isNull())
consumerConnectionInfoDoObject.threadCount = std::stoi(value["ThreadCount"].asString());
if(!value["StartTimeStamp"].isNull())
consumerConnectionInfoDoObject.startTimeStamp = std::stol(value["StartTimeStamp"].asString());
if(!value["LastTimeStamp"].isNull())
consumerConnectionInfoDoObject.lastTimeStamp = std::stol(value["LastTimeStamp"].asString());
auto allSubscriptionSet = value["SubscriptionSet"]["SubscriptionData"];
for (auto value : allSubscriptionSet)
if(!dataNodeConsumerConnectionInfoListConsumerConnectionInfoDo["ClientId"].isNull())
consumerConnectionInfoDoObject.clientId = dataNodeConsumerConnectionInfoListConsumerConnectionInfoDo["ClientId"].asString();
if(!dataNodeConsumerConnectionInfoListConsumerConnectionInfoDo["Connection"].isNull())
consumerConnectionInfoDoObject.connection = dataNodeConsumerConnectionInfoListConsumerConnectionInfoDo["Connection"].asString();
if(!dataNodeConsumerConnectionInfoListConsumerConnectionInfoDo["Language"].isNull())
consumerConnectionInfoDoObject.language = dataNodeConsumerConnectionInfoListConsumerConnectionInfoDo["Language"].asString();
if(!dataNodeConsumerConnectionInfoListConsumerConnectionInfoDo["Version"].isNull())
consumerConnectionInfoDoObject.version = dataNodeConsumerConnectionInfoListConsumerConnectionInfoDo["Version"].asString();
if(!dataNodeConsumerConnectionInfoListConsumerConnectionInfoDo["ConsumeModel"].isNull())
consumerConnectionInfoDoObject.consumeModel = dataNodeConsumerConnectionInfoListConsumerConnectionInfoDo["ConsumeModel"].asString();
if(!dataNodeConsumerConnectionInfoListConsumerConnectionInfoDo["ConsumeType"].isNull())
consumerConnectionInfoDoObject.consumeType = dataNodeConsumerConnectionInfoListConsumerConnectionInfoDo["ConsumeType"].asString();
if(!dataNodeConsumerConnectionInfoListConsumerConnectionInfoDo["ThreadCount"].isNull())
consumerConnectionInfoDoObject.threadCount = std::stoi(dataNodeConsumerConnectionInfoListConsumerConnectionInfoDo["ThreadCount"].asString());
if(!dataNodeConsumerConnectionInfoListConsumerConnectionInfoDo["StartTimeStamp"].isNull())
consumerConnectionInfoDoObject.startTimeStamp = std::stol(dataNodeConsumerConnectionInfoListConsumerConnectionInfoDo["StartTimeStamp"].asString());
if(!dataNodeConsumerConnectionInfoListConsumerConnectionInfoDo["LastTimeStamp"].isNull())
consumerConnectionInfoDoObject.lastTimeStamp = std::stol(dataNodeConsumerConnectionInfoListConsumerConnectionInfoDo["LastTimeStamp"].asString());
auto allSubscriptionSetNode = allConsumerConnectionInfoListNode["SubscriptionSet"]["SubscriptionData"];
for (auto allConsumerConnectionInfoListNodeSubscriptionSetSubscriptionData : allSubscriptionSetNode)
{
Data::ConsumerConnectionInfoDo::SubscriptionData subscriptionSetObject;
if(!value["Topic"].isNull())
subscriptionSetObject.topic = value["Topic"].asString();
if(!value["SubString"].isNull())
subscriptionSetObject.subString = value["SubString"].asString();
if(!value["SubVersion"].isNull())
subscriptionSetObject.subVersion = std::stol(value["SubVersion"].asString());
if(!allConsumerConnectionInfoListNodeSubscriptionSetSubscriptionData["Topic"].isNull())
subscriptionSetObject.topic = allConsumerConnectionInfoListNodeSubscriptionSetSubscriptionData["Topic"].asString();
if(!allConsumerConnectionInfoListNodeSubscriptionSetSubscriptionData["SubString"].isNull())
subscriptionSetObject.subString = allConsumerConnectionInfoListNodeSubscriptionSetSubscriptionData["SubString"].asString();
if(!allConsumerConnectionInfoListNodeSubscriptionSetSubscriptionData["SubVersion"].isNull())
subscriptionSetObject.subVersion = std::stol(allConsumerConnectionInfoListNodeSubscriptionSetSubscriptionData["SubVersion"].asString());
auto allTagsSet = value["TagsSet"]["Tag"];
for (auto value : allTagsSet)
subscriptionSetObject.tagsSet.push_back(value.asString());
consumerConnectionInfoDoObject.subscriptionSet.push_back(subscriptionSetObject);
}
auto allRunningDataList = value["RunningDataList"]["ConsumerRunningDataDo"];
for (auto value : allRunningDataList)
auto allRunningDataListNode = allConsumerConnectionInfoListNode["RunningDataList"]["ConsumerRunningDataDo"];
for (auto allConsumerConnectionInfoListNodeRunningDataListConsumerRunningDataDo : allRunningDataListNode)
{
Data::ConsumerConnectionInfoDo::ConsumerRunningDataDo runningDataListObject;
if(!value["GroupId"].isNull())
runningDataListObject.groupId = value["GroupId"].asString();
if(!value["Topic"].isNull())
runningDataListObject.topic = value["Topic"].asString();
if(!value["Rt"].isNull())
runningDataListObject.rt = std::stof(value["Rt"].asString());
if(!value["OkTps"].isNull())
runningDataListObject.okTps = std::stof(value["OkTps"].asString());
if(!value["FailedTps"].isNull())
runningDataListObject.failedTps = std::stof(value["FailedTps"].asString());
if(!value["FailedCountPerHour"].isNull())
runningDataListObject.failedCountPerHour = std::stol(value["FailedCountPerHour"].asString());
if(!allConsumerConnectionInfoListNodeRunningDataListConsumerRunningDataDo["GroupId"].isNull())
runningDataListObject.groupId = allConsumerConnectionInfoListNodeRunningDataListConsumerRunningDataDo["GroupId"].asString();
if(!allConsumerConnectionInfoListNodeRunningDataListConsumerRunningDataDo["Topic"].isNull())
runningDataListObject.topic = allConsumerConnectionInfoListNodeRunningDataListConsumerRunningDataDo["Topic"].asString();
if(!allConsumerConnectionInfoListNodeRunningDataListConsumerRunningDataDo["Rt"].isNull())
runningDataListObject.rt = std::stof(allConsumerConnectionInfoListNodeRunningDataListConsumerRunningDataDo["Rt"].asString());
if(!allConsumerConnectionInfoListNodeRunningDataListConsumerRunningDataDo["OkTps"].isNull())
runningDataListObject.okTps = std::stof(allConsumerConnectionInfoListNodeRunningDataListConsumerRunningDataDo["OkTps"].asString());
if(!allConsumerConnectionInfoListNodeRunningDataListConsumerRunningDataDo["FailedTps"].isNull())
runningDataListObject.failedTps = std::stof(allConsumerConnectionInfoListNodeRunningDataListConsumerRunningDataDo["FailedTps"].asString());
if(!allConsumerConnectionInfoListNodeRunningDataListConsumerRunningDataDo["FailedCountPerHour"].isNull())
runningDataListObject.failedCountPerHour = std::stol(allConsumerConnectionInfoListNodeRunningDataListConsumerRunningDataDo["FailedCountPerHour"].asString());
consumerConnectionInfoDoObject.runningDataList.push_back(runningDataListObject);
}
auto allJstack = value["Jstack"]["ThreadTrackDo"];
for (auto value : allJstack)
auto allJstackNode = allConsumerConnectionInfoListNode["Jstack"]["ThreadTrackDo"];
for (auto allConsumerConnectionInfoListNodeJstackThreadTrackDo : allJstackNode)
{
Data::ConsumerConnectionInfoDo::ThreadTrackDo jstackObject;
if(!value["Thread"].isNull())
jstackObject.thread = value["Thread"].asString();
if(!allConsumerConnectionInfoListNodeJstackThreadTrackDo["Thread"].isNull())
jstackObject.thread = allConsumerConnectionInfoListNodeJstackThreadTrackDo["Thread"].asString();
auto allTrackList = value["TrackList"]["Track"];
for (auto value : allTrackList)
jstackObject.trackList.push_back(value.asString());

12
ons/src/model/OnsDLQMessageGetByIdResult.cc
View File

@@ -66,14 +66,14 @@ void OnsDLQMessageGetByIdResult::parse(const std::string &payload)
data_.reconsumeTimes = std::stoi(dataNode["ReconsumeTimes"].asString());
if(!dataNode["InstanceId"].isNull())
data_.instanceId = dataNode["InstanceId"].asString();
auto allPropertyList = value["PropertyList"]["MessageProperty"];
for (auto value : allPropertyList)
auto allPropertyListNode = dataNode["PropertyList"]["MessageProperty"];
for (auto dataNodePropertyListMessageProperty : allPropertyListNode)
{
Data::MessageProperty messagePropertyObject;
if(!value["Name"].isNull())
messagePropertyObject.name = value["Name"].asString();
if(!value["Value"].isNull())
messagePropertyObject.value = value["Value"].asString();
if(!dataNodePropertyListMessageProperty["Name"].isNull())
messagePropertyObject.name = dataNodePropertyListMessageProperty["Name"].asString();
if(!dataNodePropertyListMessageProperty["Value"].isNull())
messagePropertyObject.value = dataNodePropertyListMessageProperty["Value"].asString();
data_.propertyList.push_back(messagePropertyObject);
}
if(!value["HelpUrl"].isNull())

68
ons/src/model/OnsDLQMessagePageQueryByGroupIdResult.cc
View File

@@ -46,44 +46,44 @@ void OnsDLQMessagePageQueryByGroupIdResult::parse(const std::string &payload)
msgFoundDo_.maxPageCount = std::stol(msgFoundDoNode["MaxPageCount"].asString());
if(!msgFoundDoNode["CurrentPage"].isNull())
msgFoundDo_.currentPage = std::stol(msgFoundDoNode["CurrentPage"].asString());
auto allMsgFoundList = value["MsgFoundList"]["OnsRestMessageDo"];
for (auto value : allMsgFoundList)
auto allMsgFoundListNode = msgFoundDoNode["MsgFoundList"]["OnsRestMessageDo"];
for (auto msgFoundDoNodeMsgFoundListOnsRestMessageDo : allMsgFoundListNode)
{
MsgFoundDo::OnsRestMessageDo onsRestMessageDoObject;
if(!value["Topic"].isNull())
onsRestMessageDoObject.topic = value["Topic"].asString();
if(!value["Flag"].isNull())
onsRestMessageDoObject.flag = std::stoi(value["Flag"].asString());
if(!value["Body"].isNull())
onsRestMessageDoObject.body = value["Body"].asString();
if(!value["StoreSize"].isNull())
onsRestMessageDoObject.storeSize = std::stoi(value["StoreSize"].asString());
if(!value["BornTimestamp"].isNull())
onsRestMessageDoObject.bornTimestamp = std::stol(value["BornTimestamp"].asString());
if(!value["BornHost"].isNull())
onsRestMessageDoObject.bornHost = value["BornHost"].asString();
if(!value["StoreTimestamp"].isNull())
onsRestMessageDoObject.storeTimestamp = std::stol(value["StoreTimestamp"].asString());
if(!value["StoreHost"].isNull())
onsRestMessageDoObject.storeHost = value["StoreHost"].asString();
if(!value["MsgId"].isNull())
onsRestMessageDoObject.msgId = value["MsgId"].asString();
if(!value["OffsetId"].isNull())
onsRestMessageDoObject.offsetId = value["OffsetId"].asString();
if(!value["BodyCRC"].isNull())
onsRestMessageDoObject.bodyCRC = std::stoi(value["BodyCRC"].asString());
if(!value["ReconsumeTimes"].isNull())
onsRestMessageDoObject.reconsumeTimes = std::stoi(value["ReconsumeTimes"].asString());
if(!value["InstanceId"].isNull())
onsRestMessageDoObject.instanceId = value["InstanceId"].asString();
auto allPropertyList = value["PropertyList"]["MessageProperty"];
for (auto value : allPropertyList)
if(!msgFoundDoNodeMsgFoundListOnsRestMessageDo["Topic"].isNull())
onsRestMessageDoObject.topic = msgFoundDoNodeMsgFoundListOnsRestMessageDo["Topic"].asString();
if(!msgFoundDoNodeMsgFoundListOnsRestMessageDo["Flag"].isNull())
onsRestMessageDoObject.flag = std::stoi(msgFoundDoNodeMsgFoundListOnsRestMessageDo["Flag"].asString());
if(!msgFoundDoNodeMsgFoundListOnsRestMessageDo["Body"].isNull())
onsRestMessageDoObject.body = msgFoundDoNodeMsgFoundListOnsRestMessageDo["Body"].asString();
if(!msgFoundDoNodeMsgFoundListOnsRestMessageDo["StoreSize"].isNull())
onsRestMessageDoObject.storeSize = std::stoi(msgFoundDoNodeMsgFoundListOnsRestMessageDo["StoreSize"].asString());
if(!msgFoundDoNodeMsgFoundListOnsRestMessageDo["BornTimestamp"].isNull())
onsRestMessageDoObject.bornTimestamp = std::stol(msgFoundDoNodeMsgFoundListOnsRestMessageDo["BornTimestamp"].asString());
if(!msgFoundDoNodeMsgFoundListOnsRestMessageDo["BornHost"].isNull())
onsRestMessageDoObject.bornHost = msgFoundDoNodeMsgFoundListOnsRestMessageDo["BornHost"].asString();
if(!msgFoundDoNodeMsgFoundListOnsRestMessageDo["StoreTimestamp"].isNull())
onsRestMessageDoObject.storeTimestamp = std::stol(msgFoundDoNodeMsgFoundListOnsRestMessageDo["StoreTimestamp"].asString());
if(!msgFoundDoNodeMsgFoundListOnsRestMessageDo["StoreHost"].isNull())
onsRestMessageDoObject.storeHost = msgFoundDoNodeMsgFoundListOnsRestMessageDo["StoreHost"].asString();
if(!msgFoundDoNodeMsgFoundListOnsRestMessageDo["MsgId"].isNull())
onsRestMessageDoObject.msgId = msgFoundDoNodeMsgFoundListOnsRestMessageDo["MsgId"].asString();
if(!msgFoundDoNodeMsgFoundListOnsRestMessageDo["OffsetId"].isNull())
onsRestMessageDoObject.offsetId = msgFoundDoNodeMsgFoundListOnsRestMessageDo["OffsetId"].asString();
if(!msgFoundDoNodeMsgFoundListOnsRestMessageDo["BodyCRC"].isNull())
onsRestMessageDoObject.bodyCRC = std::stoi(msgFoundDoNodeMsgFoundListOnsRestMessageDo["BodyCRC"].asString());
if(!msgFoundDoNodeMsgFoundListOnsRestMessageDo["ReconsumeTimes"].isNull())
onsRestMessageDoObject.reconsumeTimes = std::stoi(msgFoundDoNodeMsgFoundListOnsRestMessageDo["ReconsumeTimes"].asString());
if(!msgFoundDoNodeMsgFoundListOnsRestMessageDo["InstanceId"].isNull())
onsRestMessageDoObject.instanceId = msgFoundDoNodeMsgFoundListOnsRestMessageDo["InstanceId"].asString();
auto allPropertyListNode = allMsgFoundListNode["PropertyList"]["MessageProperty"];
for (auto allMsgFoundListNodePropertyListMessageProperty : allPropertyListNode)
{
MsgFoundDo::OnsRestMessageDo::MessageProperty propertyListObject;
if(!value["Name"].isNull())
propertyListObject.name = value["Name"].asString();
if(!value["Value"].isNull())
propertyListObject.value = value["Value"].asString();
if(!allMsgFoundListNodePropertyListMessageProperty["Name"].isNull())
propertyListObject.name = allMsgFoundListNodePropertyListMessageProperty["Name"].asString();
if(!allMsgFoundListNodePropertyListMessageProperty["Value"].isNull())
propertyListObject.value = allMsgFoundListNodePropertyListMessageProperty["Value"].asString();
onsRestMessageDoObject.propertyList.push_back(propertyListObject);
}
msgFoundDo_.msgFoundList.push_back(onsRestMessageDoObject);

32
ons/src/model/OnsGroupListResult.cc
View File

@@ -39,24 +39,24 @@ void OnsGroupListResult::parse(const std::string &payload)
Json::Value value;
reader.parse(payload, value);
setRequestId(value["RequestId"].asString());
auto allData = value["Data"]["SubscribeInfoDo"];
for (auto value : allData)
auto allDataNode = value["Data"]["SubscribeInfoDo"];
for (auto valueDataSubscribeInfoDo : allDataNode)
{
SubscribeInfoDo dataObject;
if(!value["Owner"].isNull())
dataObject.owner = value["Owner"].asString();
if(!value["GroupId"].isNull())
dataObject.groupId = value["GroupId"].asString();
if(!value["UpdateTime"].isNull())
dataObject.updateTime = std::stol(value["UpdateTime"].asString());
if(!value["Remark"].isNull())
dataObject.remark = value["Remark"].asString();
if(!value["InstanceId"].isNull())
dataObject.instanceId = value["InstanceId"].asString();
if(!value["IndependentNaming"].isNull())
dataObject.independentNaming = value["IndependentNaming"].asString() == "true";
if(!value["CreateTime"].isNull())
dataObject.createTime = std::stol(value["CreateTime"].asString());
if(!valueDataSubscribeInfoDo["Owner"].isNull())
dataObject.owner = valueDataSubscribeInfoDo["Owner"].asString();
if(!valueDataSubscribeInfoDo["GroupId"].isNull())
dataObject.groupId = valueDataSubscribeInfoDo["GroupId"].asString();
if(!valueDataSubscribeInfoDo["UpdateTime"].isNull())
dataObject.updateTime = std::stol(valueDataSubscribeInfoDo["UpdateTime"].asString());
if(!valueDataSubscribeInfoDo["Remark"].isNull())
dataObject.remark = valueDataSubscribeInfoDo["Remark"].asString();
if(!valueDataSubscribeInfoDo["InstanceId"].isNull())
dataObject.instanceId = valueDataSubscribeInfoDo["InstanceId"].asString();
if(!valueDataSubscribeInfoDo["IndependentNaming"].isNull())
dataObject.independentNaming = valueDataSubscribeInfoDo["IndependentNaming"].asString() == "true";
if(!valueDataSubscribeInfoDo["CreateTime"].isNull())
dataObject.createTime = std::stol(valueDataSubscribeInfoDo["CreateTime"].asString());
data_.push_back(dataObject);
}
if(!value["HelpUrl"].isNull())

12
ons/src/model/OnsGroupSubDetailResult.cc
View File

@@ -46,14 +46,14 @@ void OnsGroupSubDetailResult::parse(const std::string &payload)
data_.online = dataNode["Online"].asString() == "true";
if(!dataNode["MessageModel"].isNull())
data_.messageModel = dataNode["MessageModel"].asString();
auto allSubscriptionDataList = value["SubscriptionDataList"]["SubscriptionDataListItem"];
for (auto value : allSubscriptionDataList)
auto allSubscriptionDataListNode = dataNode["SubscriptionDataList"]["SubscriptionDataListItem"];
for (auto dataNodeSubscriptionDataListSubscriptionDataListItem : allSubscriptionDataListNode)
{
Data::SubscriptionDataListItem subscriptionDataListItemObject;
if(!value["Topic"].isNull())
subscriptionDataListItemObject.topic = value["Topic"].asString();
if(!value["SubString"].isNull())
subscriptionDataListItemObject.subString = value["SubString"].asString();
if(!dataNodeSubscriptionDataListSubscriptionDataListItem["Topic"].isNull())
subscriptionDataListItemObject.topic = dataNodeSubscriptionDataListSubscriptionDataListItem["Topic"].asString();
if(!dataNodeSubscriptionDataListSubscriptionDataListItem["SubString"].isNull())
subscriptionDataListItemObject.subString = dataNodeSubscriptionDataListSubscriptionDataListItem["SubString"].asString();
data_.subscriptionDataList.push_back(subscriptionDataListItemObject);
}

28
ons/src/model/OnsInstanceInServiceListResult.cc
View File

@@ -39,22 +39,22 @@ void OnsInstanceInServiceListResult::parse(const std::string &payload)
Json::Value value;
reader.parse(payload, value);
setRequestId(value["RequestId"].asString());
auto allData = value["Data"]["InstanceVO"];
for (auto value : allData)
auto allDataNode = value["Data"]["InstanceVO"];
for (auto valueDataInstanceVO : allDataNode)
{
InstanceVO dataObject;
if(!value["InstanceId"].isNull())
dataObject.instanceId = value["InstanceId"].asString();
if(!value["InstanceStatus"].isNull())
dataObject.instanceStatus = std::stoi(value["InstanceStatus"].asString());
if(!value["ReleaseTime"].isNull())
dataObject.releaseTime = std::stol(value["ReleaseTime"].asString());
if(!value["InstanceType"].isNull())
dataObject.instanceType = std::stoi(value["InstanceType"].asString());
if(!value["InstanceName"].isNull())
dataObject.instanceName = value["InstanceName"].asString();
if(!value["IndependentNaming"].isNull())
dataObject.independentNaming = value["IndependentNaming"].asString() == "true";
if(!valueDataInstanceVO["InstanceId"].isNull())
dataObject.instanceId = valueDataInstanceVO["InstanceId"].asString();
if(!valueDataInstanceVO["InstanceStatus"].isNull())
dataObject.instanceStatus = std::stoi(valueDataInstanceVO["InstanceStatus"].asString());
if(!valueDataInstanceVO["ReleaseTime"].isNull())
dataObject.releaseTime = std::stol(valueDataInstanceVO["ReleaseTime"].asString());
if(!valueDataInstanceVO["InstanceType"].isNull())
dataObject.instanceType = std::stoi(valueDataInstanceVO["InstanceType"].asString());
if(!valueDataInstanceVO["InstanceName"].isNull())
dataObject.instanceName = valueDataInstanceVO["InstanceName"].asString();
if(!valueDataInstanceVO["IndependentNaming"].isNull())
dataObject.independentNaming = valueDataInstanceVO["IndependentNaming"].asString() == "true";
data_.push_back(dataObject);
}
if(!value["HelpUrl"].isNull())

68
ons/src/model/OnsMessageGetByKeyResult.cc
View File

@@ -39,44 +39,44 @@ void OnsMessageGetByKeyResult::parse(const std::string &payload)
Json::Value value;
reader.parse(payload, value);
setRequestId(value["RequestId"].asString());
auto allData = value["Data"]["OnsRestMessageDo"];
for (auto value : allData)
auto allDataNode = value["Data"]["OnsRestMessageDo"];
for (auto valueDataOnsRestMessageDo : allDataNode)
{
OnsRestMessageDo dataObject;
if(!value["Topic"].isNull())
dataObject.topic = value["Topic"].asString();
if(!value["Flag"].isNull())
dataObject.flag = std::stoi(value["Flag"].asString());
if(!value["Body"].isNull())
dataObject.body = value["Body"].asString();
if(!value["StoreSize"].isNull())
dataObject.storeSize = std::stoi(value["StoreSize"].asString());
if(!value["BornTimestamp"].isNull())
dataObject.bornTimestamp = std::stol(value["BornTimestamp"].asString());
if(!value["BornHost"].isNull())
dataObject.bornHost = value["BornHost"].asString();
if(!value["StoreTimestamp"].isNull())
dataObject.storeTimestamp = std::stol(value["StoreTimestamp"].asString());
if(!value["StoreHost"].isNull())
dataObject.storeHost = value["StoreHost"].asString();
if(!value["MsgId"].isNull())
dataObject.msgId = value["MsgId"].asString();
if(!value["OffsetId"].isNull())
dataObject.offsetId = value["OffsetId"].asString();
if(!value["BodyCRC"].isNull())
dataObject.bodyCRC = std::stoi(value["BodyCRC"].asString());
if(!value["ReconsumeTimes"].isNull())
dataObject.reconsumeTimes = std::stoi(value["ReconsumeTimes"].asString());
if(!value["InstanceId"].isNull())
dataObject.instanceId = value["InstanceId"].asString();
auto allPropertyList = value["PropertyList"]["MessageProperty"];
for (auto value : allPropertyList)
if(!valueDataOnsRestMessageDo["Topic"].isNull())
dataObject.topic = valueDataOnsRestMessageDo["Topic"].asString();
if(!valueDataOnsRestMessageDo["Flag"].isNull())
dataObject.flag = std::stoi(valueDataOnsRestMessageDo["Flag"].asString());
if(!valueDataOnsRestMessageDo["Body"].isNull())
dataObject.body = valueDataOnsRestMessageDo["Body"].asString();
if(!valueDataOnsRestMessageDo["StoreSize"].isNull())
dataObject.storeSize = std::stoi(valueDataOnsRestMessageDo["StoreSize"].asString());
if(!valueDataOnsRestMessageDo["BornTimestamp"].isNull())
dataObject.bornTimestamp = std::stol(valueDataOnsRestMessageDo["BornTimestamp"].asString());
if(!valueDataOnsRestMessageDo["BornHost"].isNull())
dataObject.bornHost = valueDataOnsRestMessageDo["BornHost"].asString();
if(!valueDataOnsRestMessageDo["StoreTimestamp"].isNull())
dataObject.storeTimestamp = std::stol(valueDataOnsRestMessageDo["StoreTimestamp"].asString());
if(!valueDataOnsRestMessageDo["StoreHost"].isNull())
dataObject.storeHost = valueDataOnsRestMessageDo["StoreHost"].asString();
if(!valueDataOnsRestMessageDo["MsgId"].isNull())
dataObject.msgId = valueDataOnsRestMessageDo["MsgId"].asString();
if(!valueDataOnsRestMessageDo["OffsetId"].isNull())
dataObject.offsetId = valueDataOnsRestMessageDo["OffsetId"].asString();
if(!valueDataOnsRestMessageDo["BodyCRC"].isNull())
dataObject.bodyCRC = std::stoi(valueDataOnsRestMessageDo["BodyCRC"].asString());
if(!valueDataOnsRestMessageDo["ReconsumeTimes"].isNull())
dataObject.reconsumeTimes = std::stoi(valueDataOnsRestMessageDo["ReconsumeTimes"].asString());
if(!valueDataOnsRestMessageDo["InstanceId"].isNull())
dataObject.instanceId = valueDataOnsRestMessageDo["InstanceId"].asString();
auto allPropertyListNode = allDataNode["PropertyList"]["MessageProperty"];
for (auto allDataNodePropertyListMessageProperty : allPropertyListNode)
{
OnsRestMessageDo::MessageProperty propertyListObject;
if(!value["Name"].isNull())
propertyListObject.name = value["Name"].asString();
if(!value["Value"].isNull())
propertyListObject.value = value["Value"].asString();
if(!allDataNodePropertyListMessageProperty["Name"].isNull())
propertyListObject.name = allDataNodePropertyListMessageProperty["Name"].asString();
if(!allDataNodePropertyListMessageProperty["Value"].isNull())
propertyListObject.value = allDataNodePropertyListMessageProperty["Value"].asString();
dataObject.propertyList.push_back(propertyListObject);
}
data_.push_back(dataObject);

12
ons/src/model/OnsMessageGetByMsgIdResult.cc
View File

@@ -66,14 +66,14 @@ void OnsMessageGetByMsgIdResult::parse(const std::string &payload)
data_.reconsumeTimes = std::stoi(dataNode["ReconsumeTimes"].asString());
if(!dataNode["InstanceId"].isNull())
data_.instanceId = dataNode["InstanceId"].asString();
auto allPropertyList = value["PropertyList"]["MessageProperty"];
for (auto value : allPropertyList)
auto allPropertyListNode = dataNode["PropertyList"]["MessageProperty"];
for (auto dataNodePropertyListMessageProperty : allPropertyListNode)
{
Data::MessageProperty messagePropertyObject;
if(!value["Name"].isNull())
messagePropertyObject.name = value["Name"].asString();
if(!value["Value"].isNull())
messagePropertyObject.value = value["Value"].asString();
if(!dataNodePropertyListMessageProperty["Name"].isNull())
messagePropertyObject.name = dataNodePropertyListMessageProperty["Name"].asString();
if(!dataNodePropertyListMessageProperty["Value"].isNull())
messagePropertyObject.value = dataNodePropertyListMessageProperty["Value"].asString();
data_.propertyList.push_back(messagePropertyObject);
}
if(!value["HelpUrl"].isNull())

68
ons/src/model/OnsMessagePageQueryByTopicResult.cc
View File

@@ -46,44 +46,44 @@ void OnsMessagePageQueryByTopicResult::parse(const std::string &payload)
msgFoundDo_.maxPageCount = std::stol(msgFoundDoNode["MaxPageCount"].asString());
if(!msgFoundDoNode["CurrentPage"].isNull())
msgFoundDo_.currentPage = std::stol(msgFoundDoNode["CurrentPage"].asString());
auto allMsgFoundList = value["MsgFoundList"]["OnsRestMessageDo"];
for (auto value : allMsgFoundList)
auto allMsgFoundListNode = msgFoundDoNode["MsgFoundList"]["OnsRestMessageDo"];
for (auto msgFoundDoNodeMsgFoundListOnsRestMessageDo : allMsgFoundListNode)
{
MsgFoundDo::OnsRestMessageDo onsRestMessageDoObject;
if(!value["Topic"].isNull())
onsRestMessageDoObject.topic = value["Topic"].asString();
if(!value["Flag"].isNull())
onsRestMessageDoObject.flag = std::stoi(value["Flag"].asString());
if(!value["Body"].isNull())
onsRestMessageDoObject.body = value["Body"].asString();
if(!value["StoreSize"].isNull())
onsRestMessageDoObject.storeSize = std::stoi(value["StoreSize"].asString());
if(!value["BornTimestamp"].isNull())
onsRestMessageDoObject.bornTimestamp = std::stol(value["BornTimestamp"].asString());
if(!value["BornHost"].isNull())
onsRestMessageDoObject.bornHost = value["BornHost"].asString();
if(!value["StoreTimestamp"].isNull())
onsRestMessageDoObject.storeTimestamp = std::stol(value["StoreTimestamp"].asString());
if(!value["StoreHost"].isNull())
onsRestMessageDoObject.storeHost = value["StoreHost"].asString();
if(!value["MsgId"].isNull())
onsRestMessageDoObject.msgId = value["MsgId"].asString();
if(!value["OffsetId"].isNull())
onsRestMessageDoObject.offsetId = value["OffsetId"].asString();
if(!value["BodyCRC"].isNull())
onsRestMessageDoObject.bodyCRC = std::stoi(value["BodyCRC"].asString());
if(!value["ReconsumeTimes"].isNull())
onsRestMessageDoObject.reconsumeTimes = std::stoi(value["ReconsumeTimes"].asString());
if(!value["InstanceId"].isNull())
onsRestMessageDoObject.instanceId = value["InstanceId"].asString();
auto allPropertyList = value["PropertyList"]["MessageProperty"];
for (auto value : allPropertyList)
if(!msgFoundDoNodeMsgFoundListOnsRestMessageDo["Topic"].isNull())
onsRestMessageDoObject.topic = msgFoundDoNodeMsgFoundListOnsRestMessageDo["Topic"].asString();
if(!msgFoundDoNodeMsgFoundListOnsRestMessageDo["Flag"].isNull())
onsRestMessageDoObject.flag = std::stoi(msgFoundDoNodeMsgFoundListOnsRestMessageDo["Flag"].asString());
if(!msgFoundDoNodeMsgFoundListOnsRestMessageDo["Body"].isNull())
onsRestMessageDoObject.body = msgFoundDoNodeMsgFoundListOnsRestMessageDo["Body"].asString();
if(!msgFoundDoNodeMsgFoundListOnsRestMessageDo["StoreSize"].isNull())
onsRestMessageDoObject.storeSize = std::stoi(msgFoundDoNodeMsgFoundListOnsRestMessageDo["StoreSize"].asString());
if(!msgFoundDoNodeMsgFoundListOnsRestMessageDo["BornTimestamp"].isNull())
onsRestMessageDoObject.bornTimestamp = std::stol(msgFoundDoNodeMsgFoundListOnsRestMessageDo["BornTimestamp"].asString());
if(!msgFoundDoNodeMsgFoundListOnsRestMessageDo["BornHost"].isNull())
onsRestMessageDoObject.bornHost = msgFoundDoNodeMsgFoundListOnsRestMessageDo["BornHost"].asString();
if(!msgFoundDoNodeMsgFoundListOnsRestMessageDo["StoreTimestamp"].isNull())
onsRestMessageDoObject.storeTimestamp = std::stol(msgFoundDoNodeMsgFoundListOnsRestMessageDo["StoreTimestamp"].asString());
if(!msgFoundDoNodeMsgFoundListOnsRestMessageDo["StoreHost"].isNull())
onsRestMessageDoObject.storeHost = msgFoundDoNodeMsgFoundListOnsRestMessageDo["StoreHost"].asString();
if(!msgFoundDoNodeMsgFoundListOnsRestMessageDo["MsgId"].isNull())
onsRestMessageDoObject.msgId = msgFoundDoNodeMsgFoundListOnsRestMessageDo["MsgId"].asString();
if(!msgFoundDoNodeMsgFoundListOnsRestMessageDo["OffsetId"].isNull())
onsRestMessageDoObject.offsetId = msgFoundDoNodeMsgFoundListOnsRestMessageDo["OffsetId"].asString();
if(!msgFoundDoNodeMsgFoundListOnsRestMessageDo["BodyCRC"].isNull())
onsRestMessageDoObject.bodyCRC = std::stoi(msgFoundDoNodeMsgFoundListOnsRestMessageDo["BodyCRC"].asString());
if(!msgFoundDoNodeMsgFoundListOnsRestMessageDo["ReconsumeTimes"].isNull())
onsRestMessageDoObject.reconsumeTimes = std::stoi(msgFoundDoNodeMsgFoundListOnsRestMessageDo["ReconsumeTimes"].asString());
if(!msgFoundDoNodeMsgFoundListOnsRestMessageDo["InstanceId"].isNull())
onsRestMessageDoObject.instanceId = msgFoundDoNodeMsgFoundListOnsRestMessageDo["InstanceId"].asString();
auto allPropertyListNode = allMsgFoundListNode["PropertyList"]["MessageProperty"];
for (auto allMsgFoundListNodePropertyListMessageProperty : allPropertyListNode)
{
MsgFoundDo::OnsRestMessageDo::MessageProperty propertyListObject;
if(!value["Name"].isNull())
propertyListObject.name = value["Name"].asString();
if(!value["Value"].isNull())
propertyListObject.value = value["Value"].asString();
if(!allMsgFoundListNodePropertyListMessageProperty["Name"].isNull())
propertyListObject.name = allMsgFoundListNodePropertyListMessageProperty["Name"].asString();
if(!allMsgFoundListNodePropertyListMessageProperty["Value"].isNull())
propertyListObject.value = allMsgFoundListNodePropertyListMessageProperty["Value"].asString();
onsRestMessageDoObject.propertyList.push_back(propertyListObject);
}
msgFoundDo_.msgFoundList.push_back(onsRestMessageDoObject);

20
ons/src/model/OnsMessageTraceResult.cc
View File

@@ -39,18 +39,18 @@ void OnsMessageTraceResult::parse(const std::string &payload)
Json::Value value;
reader.parse(payload, value);
setRequestId(value["RequestId"].asString());
auto allData = value["Data"]["MessageTrack"];
for (auto value : allData)
auto allDataNode = value["Data"]["MessageTrack"];
for (auto valueDataMessageTrack : allDataNode)
{
MessageTrack dataObject;
if(!value["ConsumerGroup"].isNull())
dataObject.consumerGroup = value["ConsumerGroup"].asString();
if(!value["TrackType"].isNull())
dataObject.trackType = value["TrackType"].asString();
if(!value["ExceptionDesc"].isNull())
dataObject.exceptionDesc = value["ExceptionDesc"].asString();
if(!value["InstanceId"].isNull())
dataObject.instanceId = value["InstanceId"].asString();
if(!valueDataMessageTrack["ConsumerGroup"].isNull())
dataObject.consumerGroup = valueDataMessageTrack["ConsumerGroup"].asString();
if(!valueDataMessageTrack["TrackType"].isNull())
dataObject.trackType = valueDataMessageTrack["TrackType"].asString();
if(!valueDataMessageTrack["ExceptionDesc"].isNull())
dataObject.exceptionDesc = valueDataMessageTrack["ExceptionDesc"].asString();
if(!valueDataMessageTrack["InstanceId"].isNull())
dataObject.instanceId = valueDataMessageTrack["InstanceId"].asString();
data_.push_back(dataObject);
}
if(!value["HelpUrl"].isNull())

44
ons/src/model/OnsMqttGroupIdListResult.cc
View File

@@ -39,30 +39,30 @@ void OnsMqttGroupIdListResult::parse(const std::string &payload)
Json::Value value;
reader.parse(payload, value);
setRequestId(value["RequestId"].asString());
auto allData = value["Data"]["MqttGroupIdDo"];
for (auto value : allData)
auto allDataNode = value["Data"]["MqttGroupIdDo"];
for (auto valueDataMqttGroupIdDo : allDataNode)
{
MqttGroupIdDo dataObject;
if(!value["Id"].isNull())
dataObject.id = std::stol(value["Id"].asString());
if(!value["ChannelId"].isNull())
dataObject.channelId = std::stoi(value["ChannelId"].asString());
if(!value["Owner"].isNull())
dataObject.owner = value["Owner"].asString();
if(!value["GroupId"].isNull())
dataObject.groupId = value["GroupId"].asString();
if(!value["Topic"].isNull())
dataObject.topic = value["Topic"].asString();
if(!value["Status"].isNull())
dataObject.status = std::stoi(value["Status"].asString());
if(!value["CreateTime"].isNull())
dataObject.createTime = std::stol(value["CreateTime"].asString());
if(!value["UpdateTime"].isNull())
dataObject.updateTime = std::stol(value["UpdateTime"].asString());
if(!value["InstanceId"].isNull())
dataObject.instanceId = value["InstanceId"].asString();
if(!value["IndependentNaming"].isNull())
dataObject.independentNaming = value["IndependentNaming"].asString() == "true";
if(!valueDataMqttGroupIdDo["Id"].isNull())
dataObject.id = std::stol(valueDataMqttGroupIdDo["Id"].asString());
if(!valueDataMqttGroupIdDo["ChannelId"].isNull())
dataObject.channelId = std::stoi(valueDataMqttGroupIdDo["ChannelId"].asString());
if(!valueDataMqttGroupIdDo["Owner"].isNull())
dataObject.owner = valueDataMqttGroupIdDo["Owner"].asString();
if(!valueDataMqttGroupIdDo["GroupId"].isNull())
dataObject.groupId = valueDataMqttGroupIdDo["GroupId"].asString();
if(!valueDataMqttGroupIdDo["Topic"].isNull())
dataObject.topic = valueDataMqttGroupIdDo["Topic"].asString();
if(!valueDataMqttGroupIdDo["Status"].isNull())
dataObject.status = std::stoi(valueDataMqttGroupIdDo["Status"].asString());
if(!valueDataMqttGroupIdDo["CreateTime"].isNull())
dataObject.createTime = std::stol(valueDataMqttGroupIdDo["CreateTime"].asString());
if(!valueDataMqttGroupIdDo["UpdateTime"].isNull())
dataObject.updateTime = std::stol(valueDataMqttGroupIdDo["UpdateTime"].asString());
if(!valueDataMqttGroupIdDo["InstanceId"].isNull())
dataObject.instanceId = valueDataMqttGroupIdDo["InstanceId"].asString();
if(!valueDataMqttGroupIdDo["IndependentNaming"].isNull())
dataObject.independentNaming = valueDataMqttGroupIdDo["IndependentNaming"].asString() == "true";
data_.push_back(dataObject);
}
if(!value["HelpUrl"].isNull())

16
ons/src/model/OnsMqttQueryClientByClientIdResult.cc
View File

@@ -48,16 +48,16 @@ void OnsMqttQueryClientByClientIdResult::parse(const std::string &payload)
mqttClientInfoDo_.socketChannel = mqttClientInfoDoNode["SocketChannel"].asString();
if(!mqttClientInfoDoNode["LastTouch"].isNull())
mqttClientInfoDo_.lastTouch = std::stol(mqttClientInfoDoNode["LastTouch"].asString());
auto allSubScriptonData = value["SubScriptonData"]["SubscriptionDo"];
for (auto value : allSubScriptonData)
auto allSubScriptonDataNode = mqttClientInfoDoNode["SubScriptonData"]["SubscriptionDo"];
for (auto mqttClientInfoDoNodeSubScriptonDataSubscriptionDo : allSubScriptonDataNode)
{
MqttClientInfoDo::SubscriptionDo subscriptionDoObject;
if(!value["ParentTopic"].isNull())
subscriptionDoObject.parentTopic = value["ParentTopic"].asString();
if(!value["SubTopic"].isNull())
subscriptionDoObject.subTopic = value["SubTopic"].asString();
if(!value["Qos"].isNull())
subscriptionDoObject.qos = std::stoi(value["Qos"].asString());
if(!mqttClientInfoDoNodeSubScriptonDataSubscriptionDo["ParentTopic"].isNull())
subscriptionDoObject.parentTopic = mqttClientInfoDoNodeSubScriptonDataSubscriptionDo["ParentTopic"].asString();
if(!mqttClientInfoDoNodeSubScriptonDataSubscriptionDo["SubTopic"].isNull())
subscriptionDoObject.subTopic = mqttClientInfoDoNodeSubScriptonDataSubscriptionDo["SubTopic"].asString();
if(!mqttClientInfoDoNodeSubScriptonDataSubscriptionDo["Qos"].isNull())
subscriptionDoObject.qos = std::stoi(mqttClientInfoDoNodeSubScriptonDataSubscriptionDo["Qos"].asString());
mqttClientInfoDo_.subScriptonData.push_back(subscriptionDoObject);
}
if(!value["HelpUrl"].isNull())

12
ons/src/model/OnsMqttQueryHistoryOnlineResult.cc
View File

@@ -46,14 +46,14 @@ void OnsMqttQueryHistoryOnlineResult::parse(const std::string &payload)
data_.xUnit = dataNode["XUnit"].asString();
if(!dataNode["YUnit"].isNull())
data_.yUnit = dataNode["YUnit"].asString();
auto allRecords = value["Records"]["StatsDataDo"];
for (auto value : allRecords)
auto allRecordsNode = dataNode["Records"]["StatsDataDo"];
for (auto dataNodeRecordsStatsDataDo : allRecordsNode)
{
Data::StatsDataDo statsDataDoObject;
if(!value["X"].isNull())
statsDataDoObject.x = std::stol(value["X"].asString());
if(!value["Y"].isNull())
statsDataDoObject.y = std::stof(value["Y"].asString());
if(!dataNodeRecordsStatsDataDo["X"].isNull())
statsDataDoObject.x = std::stol(dataNodeRecordsStatsDataDo["X"].asString());
if(!dataNodeRecordsStatsDataDo["Y"].isNull())
statsDataDoObject.y = std::stof(dataNodeRecordsStatsDataDo["Y"].asString());
data_.records.push_back(statsDataDoObject);
}
if(!value["HelpUrl"].isNull())

12
ons/src/model/OnsMqttQueryMsgTransTrendResult.cc
View File

@@ -46,14 +46,14 @@ void OnsMqttQueryMsgTransTrendResult::parse(const std::string &payload)
data_.xUnit = dataNode["XUnit"].asString();
if(!dataNode["YUnit"].isNull())
data_.yUnit = dataNode["YUnit"].asString();
auto allRecords = value["Records"]["StatsDataDo"];
for (auto value : allRecords)
auto allRecordsNode = dataNode["Records"]["StatsDataDo"];
for (auto dataNodeRecordsStatsDataDo : allRecordsNode)
{
Data::StatsDataDo statsDataDoObject;
if(!value["X"].isNull())
statsDataDoObject.x = std::stol(value["X"].asString());
if(!value["Y"].isNull())
statsDataDoObject.y = std::stof(value["Y"].asString());
if(!dataNodeRecordsStatsDataDo["X"].isNull())
statsDataDoObject.x = std::stol(dataNodeRecordsStatsDataDo["X"].asString());
if(!dataNodeRecordsStatsDataDo["Y"].isNull())
statsDataDoObject.y = std::stof(dataNodeRecordsStatsDataDo["Y"].asString());
data_.records.push_back(statsDataDoObject);
}
if(!value["HelpUrl"].isNull())

32
ons/src/model/OnsRegionListResult.cc
View File

@@ -39,24 +39,24 @@ void OnsRegionListResult::parse(const std::string &payload)
Json::Value value;
reader.parse(payload, value);
setRequestId(value["RequestId"].asString());
auto allData = value["Data"]["RegionDo"];
for (auto value : allData)
auto allDataNode = value["Data"]["RegionDo"];
for (auto valueDataRegionDo : allDataNode)
{
RegionDo dataObject;
if(!value["Id"].isNull())
dataObject.id = std::stol(value["Id"].asString());
if(!value["OnsRegionId"].isNull())
dataObject.onsRegionId = value["OnsRegionId"].asString();
if(!value["RegionName"].isNull())
dataObject.regionName = value["RegionName"].asString();
if(!value["ChannelId"].isNull())
dataObject.channelId = std::stoi(value["ChannelId"].asString());
if(!value["ChannelName"].isNull())
dataObject.channelName = value["ChannelName"].asString();
if(!value["CreateTime"].isNull())
dataObject.createTime = std::stol(value["CreateTime"].asString());
if(!value["UpdateTime"].isNull())
dataObject.updateTime = std::stol(value["UpdateTime"].asString());
if(!valueDataRegionDo["Id"].isNull())
dataObject.id = std::stol(valueDataRegionDo["Id"].asString());
if(!valueDataRegionDo["OnsRegionId"].isNull())
dataObject.onsRegionId = valueDataRegionDo["OnsRegionId"].asString();
if(!valueDataRegionDo["RegionName"].isNull())
dataObject.regionName = valueDataRegionDo["RegionName"].asString();
if(!valueDataRegionDo["ChannelId"].isNull())
dataObject.channelId = std::stoi(valueDataRegionDo["ChannelId"].asString());
if(!valueDataRegionDo["ChannelName"].isNull())
dataObject.channelName = valueDataRegionDo["ChannelName"].asString();
if(!valueDataRegionDo["CreateTime"].isNull())
dataObject.createTime = std::stol(valueDataRegionDo["CreateTime"].asString());
if(!valueDataRegionDo["UpdateTime"].isNull())
dataObject.updateTime = std::stol(valueDataRegionDo["UpdateTime"].asString());
data_.push_back(dataObject);
}
if(!value["HelpUrl"].isNull())

40
ons/src/model/OnsTopicListResult.cc
View File

@@ -39,28 +39,28 @@ void OnsTopicListResult::parse(const std::string &payload)
Json::Value value;
reader.parse(payload, value);
setRequestId(value["RequestId"].asString());
auto allData = value["Data"]["PublishInfoDo"];
for (auto value : allData)
auto allDataNode = value["Data"]["PublishInfoDo"];
for (auto valueDataPublishInfoDo : allDataNode)
{
PublishInfoDo dataObject;
if(!value["Topic"].isNull())
dataObject.topic = value["Topic"].asString();
if(!value["Owner"].isNull())
dataObject.owner = value["Owner"].asString();
if(!value["Relation"].isNull())
dataObject.relation = std::stoi(value["Relation"].asString());
if(!value["RelationName"].isNull())
dataObject.relationName = value["RelationName"].asString();
if(!value["CreateTime"].isNull())
dataObject.createTime = std::stol(value["CreateTime"].asString());
if(!value["Remark"].isNull())
dataObject.remark = value["Remark"].asString();
if(!value["MessageType"].isNull())
dataObject.messageType = std::stoi(value["MessageType"].asString());
if(!value["InstanceId"].isNull())
dataObject.instanceId = value["InstanceId"].asString();
if(!value["IndependentNaming"].isNull())
dataObject.independentNaming = value["IndependentNaming"].asString() == "true";
if(!valueDataPublishInfoDo["Topic"].isNull())
dataObject.topic = valueDataPublishInfoDo["Topic"].asString();
if(!valueDataPublishInfoDo["Owner"].isNull())
dataObject.owner = valueDataPublishInfoDo["Owner"].asString();
if(!valueDataPublishInfoDo["Relation"].isNull())
dataObject.relation = std::stoi(valueDataPublishInfoDo["Relation"].asString());
if(!valueDataPublishInfoDo["RelationName"].isNull())
dataObject.relationName = valueDataPublishInfoDo["RelationName"].asString();
if(!valueDataPublishInfoDo["CreateTime"].isNull())
dataObject.createTime = std::stol(valueDataPublishInfoDo["CreateTime"].asString());
if(!valueDataPublishInfoDo["Remark"].isNull())
dataObject.remark = valueDataPublishInfoDo["Remark"].asString();
if(!valueDataPublishInfoDo["MessageType"].isNull())
dataObject.messageType = std::stoi(valueDataPublishInfoDo["MessageType"].asString());
if(!valueDataPublishInfoDo["InstanceId"].isNull())
dataObject.instanceId = valueDataPublishInfoDo["InstanceId"].asString();
if(!valueDataPublishInfoDo["IndependentNaming"].isNull())
dataObject.independentNaming = valueDataPublishInfoDo["IndependentNaming"].asString() == "true";
data_.push_back(dataObject);
}
if(!value["HelpUrl"].isNull())

16
ons/src/model/OnsTopicSubDetailResult.cc
View File

@@ -42,16 +42,16 @@ void OnsTopicSubDetailResult::parse(const std::string &payload)
auto dataNode = value["Data"];
if(!dataNode["Topic"].isNull())
data_.topic = dataNode["Topic"].asString();
auto allSubscriptionDataList = value["SubscriptionDataList"]["SubscriptionDataListItem"];
for (auto value : allSubscriptionDataList)
auto allSubscriptionDataListNode = dataNode["SubscriptionDataList"]["SubscriptionDataListItem"];
for (auto dataNodeSubscriptionDataListSubscriptionDataListItem : allSubscriptionDataListNode)
{
Data::SubscriptionDataListItem subscriptionDataListItemObject;
if(!value["GroupId"].isNull())
subscriptionDataListItemObject.groupId = value["GroupId"].asString();
if(!value["SubString"].isNull())
subscriptionDataListItemObject.subString = value["SubString"].asString();
if(!value["MessageModel"].isNull())
subscriptionDataListItemObject.messageModel = value["MessageModel"].asString();
if(!dataNodeSubscriptionDataListSubscriptionDataListItem["GroupId"].isNull())
subscriptionDataListItemObject.groupId = dataNodeSubscriptionDataListSubscriptionDataListItem["GroupId"].asString();
if(!dataNodeSubscriptionDataListSubscriptionDataListItem["SubString"].isNull())
subscriptionDataListItemObject.subString = dataNodeSubscriptionDataListSubscriptionDataListItem["SubString"].asString();
if(!dataNodeSubscriptionDataListSubscriptionDataListItem["MessageModel"].isNull())
subscriptionDataListItemObject.messageModel = dataNodeSubscriptionDataListSubscriptionDataListItem["MessageModel"].asString();
data_.subscriptionDataList.push_back(subscriptionDataListItemObject);
}

84
ons/src/model/OnsTraceGetResultResult.cc
View File

@@ -58,54 +58,54 @@ void OnsTraceGetResultResult::parse(const std::string &payload)
traceData_.updateTime = std::stol(traceDataNode["UpdateTime"].asString());
if(!traceDataNode["InstanceId"].isNull())
traceData_.instanceId = traceDataNode["InstanceId"].asString();
auto allTraceList = value["TraceList"]["TraceMapDo"];
for (auto value : allTraceList)
auto allTraceListNode = traceDataNode["TraceList"]["TraceMapDo"];
for (auto traceDataNodeTraceListTraceMapDo : allTraceListNode)
{
TraceData::TraceMapDo traceMapDoObject;
if(!value["PubTime"].isNull())
traceMapDoObject.pubTime = std::stol(value["PubTime"].asString());
if(!value["Topic"].isNull())
traceMapDoObject.topic = value["Topic"].asString();
if(!value["PubGroupName"].isNull())
traceMapDoObject.pubGroupName = value["PubGroupName"].asString();
if(!value["MsgId"].isNull())
traceMapDoObject.msgId = value["MsgId"].asString();
if(!value["Tag"].isNull())
traceMapDoObject.tag = value["Tag"].asString();
if(!value["MsgKey"].isNull())
traceMapDoObject.msgKey = value["MsgKey"].asString();
if(!value["BornHost"].isNull())
traceMapDoObject.bornHost = value["BornHost"].asString();
if(!value["CostTime"].isNull())
traceMapDoObject.costTime = std::stoi(value["CostTime"].asString());
if(!value["Status"].isNull())
traceMapDoObject.status = value["Status"].asString();
auto allSubList = value["SubList"]["SubMapDo"];
for (auto value : allSubList)
if(!traceDataNodeTraceListTraceMapDo["PubTime"].isNull())
traceMapDoObject.pubTime = std::stol(traceDataNodeTraceListTraceMapDo["PubTime"].asString());
if(!traceDataNodeTraceListTraceMapDo["Topic"].isNull())
traceMapDoObject.topic = traceDataNodeTraceListTraceMapDo["Topic"].asString();
if(!traceDataNodeTraceListTraceMapDo["PubGroupName"].isNull())
traceMapDoObject.pubGroupName = traceDataNodeTraceListTraceMapDo["PubGroupName"].asString();
if(!traceDataNodeTraceListTraceMapDo["MsgId"].isNull())
traceMapDoObject.msgId = traceDataNodeTraceListTraceMapDo["MsgId"].asString();
if(!traceDataNodeTraceListTraceMapDo["Tag"].isNull())
traceMapDoObject.tag = traceDataNodeTraceListTraceMapDo["Tag"].asString();
if(!traceDataNodeTraceListTraceMapDo["MsgKey"].isNull())
traceMapDoObject.msgKey = traceDataNodeTraceListTraceMapDo["MsgKey"].asString();
if(!traceDataNodeTraceListTraceMapDo["BornHost"].isNull())
traceMapDoObject.bornHost = traceDataNodeTraceListTraceMapDo["BornHost"].asString();
if(!traceDataNodeTraceListTraceMapDo["CostTime"].isNull())
traceMapDoObject.costTime = std::stoi(traceDataNodeTraceListTraceMapDo["CostTime"].asString());
if(!traceDataNodeTraceListTraceMapDo["Status"].isNull())
traceMapDoObject.status = traceDataNodeTraceListTraceMapDo["Status"].asString();
auto allSubListNode = allTraceListNode["SubList"]["SubMapDo"];
for (auto allTraceListNodeSubListSubMapDo : allSubListNode)
{
TraceData::TraceMapDo::SubMapDo subListObject;
if(!value["SubGroupName"].isNull())
subListObject.subGroupName = value["SubGroupName"].asString();
if(!value["SuccessCount"].isNull())
subListObject.successCount = std::stoi(value["SuccessCount"].asString());
if(!value["FailCount"].isNull())
subListObject.failCount = std::stoi(value["FailCount"].asString());
auto allClientList = value["ClientList"]["SubClientInfoDo"];
for (auto value : allClientList)
if(!allTraceListNodeSubListSubMapDo["SubGroupName"].isNull())
subListObject.subGroupName = allTraceListNodeSubListSubMapDo["SubGroupName"].asString();
if(!allTraceListNodeSubListSubMapDo["SuccessCount"].isNull())
subListObject.successCount = std::stoi(allTraceListNodeSubListSubMapDo["SuccessCount"].asString());
if(!allTraceListNodeSubListSubMapDo["FailCount"].isNull())
subListObject.failCount = std::stoi(allTraceListNodeSubListSubMapDo["FailCount"].asString());
auto allClientListNode = allSubListNode["ClientList"]["SubClientInfoDo"];
for (auto allSubListNodeClientListSubClientInfoDo : allClientListNode)
{
TraceData::TraceMapDo::SubMapDo::SubClientInfoDo clientListObject;
if(!value["SubGroupName"].isNull())
clientListObject.subGroupName = value["SubGroupName"].asString();
if(!value["SubTime"].isNull())
clientListObject.subTime = std::stol(value["SubTime"].asString());
if(!value["ClientHost"].isNull())
clientListObject.clientHost = value["ClientHost"].asString();
if(!value["ReconsumeTimes"].isNull())
clientListObject.reconsumeTimes = std::stoi(value["ReconsumeTimes"].asString());
if(!value["CostTime"].isNull())
clientListObject.costTime = std::stoi(value["CostTime"].asString());
if(!value["Status"].isNull())
clientListObject.status = value["Status"].asString();
if(!allSubListNodeClientListSubClientInfoDo["SubGroupName"].isNull())
clientListObject.subGroupName = allSubListNodeClientListSubClientInfoDo["SubGroupName"].asString();
if(!allSubListNodeClientListSubClientInfoDo["SubTime"].isNull())
clientListObject.subTime = std::stol(allSubListNodeClientListSubClientInfoDo["SubTime"].asString());
if(!allSubListNodeClientListSubClientInfoDo["ClientHost"].isNull())
clientListObject.clientHost = allSubListNodeClientListSubClientInfoDo["ClientHost"].asString();
if(!allSubListNodeClientListSubClientInfoDo["ReconsumeTimes"].isNull())
clientListObject.reconsumeTimes = std::stoi(allSubListNodeClientListSubClientInfoDo["ReconsumeTimes"].asString());
if(!allSubListNodeClientListSubClientInfoDo["CostTime"].isNull())
clientListObject.costTime = std::stoi(allSubListNodeClientListSubClientInfoDo["CostTime"].asString());
if(!allSubListNodeClientListSubClientInfoDo["Status"].isNull())
clientListObject.status = allSubListNodeClientListSubClientInfoDo["Status"].asString();
subListObject.clientList.push_back(clientListObject);
}
traceMapDoObject.subList.push_back(subListObject);

12
ons/src/model/OnsTrendGroupOutputTpsResult.cc
View File

@@ -46,14 +46,14 @@ void OnsTrendGroupOutputTpsResult::parse(const std::string &payload)
data_.xUnit = dataNode["XUnit"].asString();
if(!dataNode["YUnit"].isNull())
data_.yUnit = dataNode["YUnit"].asString();
auto allRecords = value["Records"]["StatsDataDo"];
for (auto value : allRecords)
auto allRecordsNode = dataNode["Records"]["StatsDataDo"];
for (auto dataNodeRecordsStatsDataDo : allRecordsNode)
{
Data::StatsDataDo statsDataDoObject;
if(!value["X"].isNull())
statsDataDoObject.x = std::stol(value["X"].asString());
if(!value["Y"].isNull())
statsDataDoObject.y = std::stof(value["Y"].asString());
if(!dataNodeRecordsStatsDataDo["X"].isNull())
statsDataDoObject.x = std::stol(dataNodeRecordsStatsDataDo["X"].asString());
if(!dataNodeRecordsStatsDataDo["Y"].isNull())
statsDataDoObject.y = std::stof(dataNodeRecordsStatsDataDo["Y"].asString());
data_.records.push_back(statsDataDoObject);
}
if(!value["HelpUrl"].isNull())

12
ons/src/model/OnsTrendTopicInputTpsResult.cc
View File

@@ -46,14 +46,14 @@ void OnsTrendTopicInputTpsResult::parse(const std::string &payload)
data_.xUnit = dataNode["XUnit"].asString();
if(!dataNode["YUnit"].isNull())
data_.yUnit = dataNode["YUnit"].asString();
auto allRecords = value["Records"]["StatsDataDo"];
for (auto value : allRecords)
auto allRecordsNode = dataNode["Records"]["StatsDataDo"];
for (auto dataNodeRecordsStatsDataDo : allRecordsNode)
{
Data::StatsDataDo statsDataDoObject;
if(!value["X"].isNull())
statsDataDoObject.x = std::stol(value["X"].asString());
if(!value["Y"].isNull())
statsDataDoObject.y = std::stof(value["Y"].asString());
if(!dataNodeRecordsStatsDataDo["X"].isNull())
statsDataDoObject.x = std::stol(dataNodeRecordsStatsDataDo["X"].asString());
if(!dataNodeRecordsStatsDataDo["Y"].isNull())
statsDataDoObject.y = std::stof(dataNodeRecordsStatsDataDo["Y"].asString());
data_.records.push_back(statsDataDoObject);
}
if(!value["HelpUrl"].isNull())