OnsDLQMessagePageQueryByGroupIdResult.cc 5.3 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105
  1. /*
  2. * Copyright 2009-2017 Alibaba Cloud All rights reserved.
  3. *
  4. * Licensed under the Apache License, Version 2.0 (the "License");
  5. * you may not use this file except in compliance with the License.
  6. * You may obtain a copy of the License at
  7. *
  8. * http://www.apache.org/licenses/LICENSE-2.0
  9. *
  10. * Unless required by applicable law or agreed to in writing, software
  11. * distributed under the License is distributed on an "AS IS" BASIS,
  12. * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  13. * See the License for the specific language governing permissions and
  14. * limitations under the License.
  15. */
  16. #include <alibabacloud/ons/model/OnsDLQMessagePageQueryByGroupIdResult.h>
  17. #include <json/json.h>
  18. using namespace AlibabaCloud::Ons;
  19. using namespace AlibabaCloud::Ons::Model;
  20. OnsDLQMessagePageQueryByGroupIdResult::OnsDLQMessagePageQueryByGroupIdResult() :
  21. ServiceResult()
  22. {}
  23. OnsDLQMessagePageQueryByGroupIdResult::OnsDLQMessagePageQueryByGroupIdResult(const std::string &payload) :
  24. ServiceResult()
  25. {
  26. parse(payload);
  27. }
  28. OnsDLQMessagePageQueryByGroupIdResult::~OnsDLQMessagePageQueryByGroupIdResult()
  29. {}
  30. void OnsDLQMessagePageQueryByGroupIdResult::parse(const std::string &payload)
  31. {
  32. Json::Reader reader;
  33. Json::Value value;
  34. reader.parse(payload, value);
  35. setRequestId(value["RequestId"].asString());
  36. auto msgFoundDoNode = value["MsgFoundDo"];
  37. if(!msgFoundDoNode["CurrentPage"].isNull())
  38. msgFoundDo_.currentPage = std::stol(msgFoundDoNode["CurrentPage"].asString());
  39. if(!msgFoundDoNode["MaxPageCount"].isNull())
  40. msgFoundDo_.maxPageCount = std::stol(msgFoundDoNode["MaxPageCount"].asString());
  41. if(!msgFoundDoNode["TaskId"].isNull())
  42. msgFoundDo_.taskId = msgFoundDoNode["TaskId"].asString();
  43. auto allMsgFoundListNode = msgFoundDoNode["MsgFoundList"]["OnsRestMessageDo"];
  44. for (auto msgFoundDoNodeMsgFoundListOnsRestMessageDo : allMsgFoundListNode)
  45. {
  46. MsgFoundDo::OnsRestMessageDo onsRestMessageDoObject;
  47. if(!msgFoundDoNodeMsgFoundListOnsRestMessageDo["OffsetId"].isNull())
  48. onsRestMessageDoObject.offsetId = msgFoundDoNodeMsgFoundListOnsRestMessageDo["OffsetId"].asString();
  49. if(!msgFoundDoNodeMsgFoundListOnsRestMessageDo["StoreSize"].isNull())
  50. onsRestMessageDoObject.storeSize = std::stoi(msgFoundDoNodeMsgFoundListOnsRestMessageDo["StoreSize"].asString());
  51. if(!msgFoundDoNodeMsgFoundListOnsRestMessageDo["ReconsumeTimes"].isNull())
  52. onsRestMessageDoObject.reconsumeTimes = std::stoi(msgFoundDoNodeMsgFoundListOnsRestMessageDo["ReconsumeTimes"].asString());
  53. if(!msgFoundDoNodeMsgFoundListOnsRestMessageDo["StoreTimestamp"].isNull())
  54. onsRestMessageDoObject.storeTimestamp = std::stol(msgFoundDoNodeMsgFoundListOnsRestMessageDo["StoreTimestamp"].asString());
  55. if(!msgFoundDoNodeMsgFoundListOnsRestMessageDo["Body"].isNull())
  56. onsRestMessageDoObject.body = msgFoundDoNodeMsgFoundListOnsRestMessageDo["Body"].asString();
  57. if(!msgFoundDoNodeMsgFoundListOnsRestMessageDo["InstanceId"].isNull())
  58. onsRestMessageDoObject.instanceId = msgFoundDoNodeMsgFoundListOnsRestMessageDo["InstanceId"].asString();
  59. if(!msgFoundDoNodeMsgFoundListOnsRestMessageDo["MsgId"].isNull())
  60. onsRestMessageDoObject.msgId = msgFoundDoNodeMsgFoundListOnsRestMessageDo["MsgId"].asString();
  61. if(!msgFoundDoNodeMsgFoundListOnsRestMessageDo["Flag"].isNull())
  62. onsRestMessageDoObject.flag = std::stoi(msgFoundDoNodeMsgFoundListOnsRestMessageDo["Flag"].asString());
  63. if(!msgFoundDoNodeMsgFoundListOnsRestMessageDo["StoreHost"].isNull())
  64. onsRestMessageDoObject.storeHost = msgFoundDoNodeMsgFoundListOnsRestMessageDo["StoreHost"].asString();
  65. if(!msgFoundDoNodeMsgFoundListOnsRestMessageDo["Topic"].isNull())
  66. onsRestMessageDoObject.topic = msgFoundDoNodeMsgFoundListOnsRestMessageDo["Topic"].asString();
  67. if(!msgFoundDoNodeMsgFoundListOnsRestMessageDo["BornTimestamp"].isNull())
  68. onsRestMessageDoObject.bornTimestamp = std::stol(msgFoundDoNodeMsgFoundListOnsRestMessageDo["BornTimestamp"].asString());
  69. if(!msgFoundDoNodeMsgFoundListOnsRestMessageDo["BodyCRC"].isNull())
  70. onsRestMessageDoObject.bodyCRC = std::stoi(msgFoundDoNodeMsgFoundListOnsRestMessageDo["BodyCRC"].asString());
  71. if(!msgFoundDoNodeMsgFoundListOnsRestMessageDo["BornHost"].isNull())
  72. onsRestMessageDoObject.bornHost = msgFoundDoNodeMsgFoundListOnsRestMessageDo["BornHost"].asString();
  73. auto allPropertyListNode = msgFoundDoNodeMsgFoundListOnsRestMessageDo["PropertyList"]["MessageProperty"];
  74. for (auto msgFoundDoNodeMsgFoundListOnsRestMessageDoPropertyListMessageProperty : allPropertyListNode)
  75. {
  76. MsgFoundDo::OnsRestMessageDo::MessageProperty propertyListObject;
  77. if(!msgFoundDoNodeMsgFoundListOnsRestMessageDoPropertyListMessageProperty["Value"].isNull())
  78. propertyListObject.value = msgFoundDoNodeMsgFoundListOnsRestMessageDoPropertyListMessageProperty["Value"].asString();
  79. if(!msgFoundDoNodeMsgFoundListOnsRestMessageDoPropertyListMessageProperty["Name"].isNull())
  80. propertyListObject.name = msgFoundDoNodeMsgFoundListOnsRestMessageDoPropertyListMessageProperty["Name"].asString();
  81. onsRestMessageDoObject.propertyList.push_back(propertyListObject);
  82. }
  83. msgFoundDo_.msgFoundList.push_back(onsRestMessageDoObject);
  84. }
  85. if(!value["HelpUrl"].isNull())
  86. helpUrl_ = value["HelpUrl"].asString();
  87. }
  88. OnsDLQMessagePageQueryByGroupIdResult::MsgFoundDo OnsDLQMessagePageQueryByGroupIdResult::getMsgFoundDo()const
  89. {
  90. return msgFoundDo_;
  91. }
  92. std::string OnsDLQMessagePageQueryByGroupIdResult::getHelpUrl()const
  93. {
  94. return helpUrl_;
  95. }