GetJobInfoResult.cc 7.2 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150
  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/schedulerx2/model/GetJobInfoResult.h>
  17. #include <json/json.h>
  18. using namespace AlibabaCloud::Schedulerx2;
  19. using namespace AlibabaCloud::Schedulerx2::Model;
  20. GetJobInfoResult::GetJobInfoResult() :
  21. ServiceResult()
  22. {}
  23. GetJobInfoResult::GetJobInfoResult(const std::string &payload) :
  24. ServiceResult()
  25. {
  26. parse(payload);
  27. }
  28. GetJobInfoResult::~GetJobInfoResult()
  29. {}
  30. void GetJobInfoResult::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 dataNode = value["Data"];
  37. auto jobConfigInfoNode = dataNode["JobConfigInfo"];
  38. if(!jobConfigInfoNode["JobId"].isNull())
  39. data_.jobConfigInfo.jobId = std::stol(jobConfigInfoNode["JobId"].asString());
  40. if(!jobConfigInfoNode["Status"].isNull())
  41. data_.jobConfigInfo.status = std::stoi(jobConfigInfoNode["Status"].asString());
  42. if(!jobConfigInfoNode["Parameters"].isNull())
  43. data_.jobConfigInfo.parameters = jobConfigInfoNode["Parameters"].asString();
  44. if(!jobConfigInfoNode["Description"].isNull())
  45. data_.jobConfigInfo.description = jobConfigInfoNode["Description"].asString();
  46. if(!jobConfigInfoNode["ExecuteMode"].isNull())
  47. data_.jobConfigInfo.executeMode = jobConfigInfoNode["ExecuteMode"].asString();
  48. if(!jobConfigInfoNode["MaxConcurrency"].isNull())
  49. data_.jobConfigInfo.maxConcurrency = jobConfigInfoNode["MaxConcurrency"].asString();
  50. if(!jobConfigInfoNode["Name"].isNull())
  51. data_.jobConfigInfo.name = jobConfigInfoNode["Name"].asString();
  52. if(!jobConfigInfoNode["MaxAttempt"].isNull())
  53. data_.jobConfigInfo.maxAttempt = std::stoi(jobConfigInfoNode["MaxAttempt"].asString());
  54. if(!jobConfigInfoNode["Content"].isNull())
  55. data_.jobConfigInfo.content = jobConfigInfoNode["Content"].asString();
  56. if(!jobConfigInfoNode["JarUrl"].isNull())
  57. data_.jobConfigInfo.jarUrl = jobConfigInfoNode["JarUrl"].asString();
  58. if(!jobConfigInfoNode["ClassName"].isNull())
  59. data_.jobConfigInfo.className = jobConfigInfoNode["ClassName"].asString();
  60. if(!jobConfigInfoNode["JobType"].isNull())
  61. data_.jobConfigInfo.jobType = jobConfigInfoNode["JobType"].asString();
  62. if(!jobConfigInfoNode["AttemptInterval"].isNull())
  63. data_.jobConfigInfo.attemptInterval = std::stoi(jobConfigInfoNode["AttemptInterval"].asString());
  64. if(!jobConfigInfoNode["XAttrs"].isNull())
  65. data_.jobConfigInfo.xAttrs = jobConfigInfoNode["XAttrs"].asString();
  66. auto mapTaskXAttrsNode = jobConfigInfoNode["MapTaskXAttrs"];
  67. if(!mapTaskXAttrsNode["TaskMaxAttempt"].isNull())
  68. data_.jobConfigInfo.mapTaskXAttrs.taskMaxAttempt = std::stoi(mapTaskXAttrsNode["TaskMaxAttempt"].asString());
  69. if(!mapTaskXAttrsNode["TaskAttemptInterval"].isNull())
  70. data_.jobConfigInfo.mapTaskXAttrs.taskAttemptInterval = std::stoi(mapTaskXAttrsNode["TaskAttemptInterval"].asString());
  71. if(!mapTaskXAttrsNode["ConsumerSize"].isNull())
  72. data_.jobConfigInfo.mapTaskXAttrs.consumerSize = std::stoi(mapTaskXAttrsNode["ConsumerSize"].asString());
  73. if(!mapTaskXAttrsNode["QueueSize"].isNull())
  74. data_.jobConfigInfo.mapTaskXAttrs.queueSize = std::stoi(mapTaskXAttrsNode["QueueSize"].asString());
  75. if(!mapTaskXAttrsNode["DispatcherSize"].isNull())
  76. data_.jobConfigInfo.mapTaskXAttrs.dispatcherSize = std::stoi(mapTaskXAttrsNode["DispatcherSize"].asString());
  77. if(!mapTaskXAttrsNode["PageSize"].isNull())
  78. data_.jobConfigInfo.mapTaskXAttrs.pageSize = std::stoi(mapTaskXAttrsNode["PageSize"].asString());
  79. auto timeConfigNode = jobConfigInfoNode["TimeConfig"];
  80. if(!timeConfigNode["Calendar"].isNull())
  81. data_.jobConfigInfo.timeConfig.calendar = timeConfigNode["Calendar"].asString();
  82. if(!timeConfigNode["TimeType"].isNull())
  83. data_.jobConfigInfo.timeConfig.timeType = std::stoi(timeConfigNode["TimeType"].asString());
  84. if(!timeConfigNode["DataOffset"].isNull())
  85. data_.jobConfigInfo.timeConfig.dataOffset = std::stoi(timeConfigNode["DataOffset"].asString());
  86. if(!timeConfigNode["TimeExpression"].isNull())
  87. data_.jobConfigInfo.timeConfig.timeExpression = timeConfigNode["TimeExpression"].asString();
  88. auto jobMonitorInfoNode = jobConfigInfoNode["JobMonitorInfo"];
  89. auto allContactInfoNode = jobMonitorInfoNode["ContactInfo"]["ContactInfoItem"];
  90. for (auto jobMonitorInfoNodeContactInfoContactInfoItem : allContactInfoNode)
  91. {
  92. Data::JobConfigInfo::JobMonitorInfo::ContactInfoItem contactInfoItemObject;
  93. if(!jobMonitorInfoNodeContactInfoContactInfoItem["UserPhone"].isNull())
  94. contactInfoItemObject.userPhone = jobMonitorInfoNodeContactInfoContactInfoItem["UserPhone"].asString();
  95. if(!jobMonitorInfoNodeContactInfoContactInfoItem["UserName"].isNull())
  96. contactInfoItemObject.userName = jobMonitorInfoNodeContactInfoContactInfoItem["UserName"].asString();
  97. if(!jobMonitorInfoNodeContactInfoContactInfoItem["UserMail"].isNull())
  98. contactInfoItemObject.userMail = jobMonitorInfoNodeContactInfoContactInfoItem["UserMail"].asString();
  99. if(!jobMonitorInfoNodeContactInfoContactInfoItem["Ding"].isNull())
  100. contactInfoItemObject.ding = jobMonitorInfoNodeContactInfoContactInfoItem["Ding"].asString();
  101. data_.jobConfigInfo.jobMonitorInfo.contactInfo.push_back(contactInfoItemObject);
  102. }
  103. auto monitorConfigNode = jobMonitorInfoNode["MonitorConfig"];
  104. if(!monitorConfigNode["Timeout"].isNull())
  105. data_.jobConfigInfo.jobMonitorInfo.monitorConfig.timeout = std::stol(monitorConfigNode["Timeout"].asString());
  106. if(!monitorConfigNode["SendChannel"].isNull())
  107. data_.jobConfigInfo.jobMonitorInfo.monitorConfig.sendChannel = monitorConfigNode["SendChannel"].asString();
  108. if(!monitorConfigNode["TimeoutKillEnable"].isNull())
  109. data_.jobConfigInfo.jobMonitorInfo.monitorConfig.timeoutKillEnable = monitorConfigNode["TimeoutKillEnable"].asString() == "true";
  110. if(!monitorConfigNode["TimeoutEnable"].isNull())
  111. data_.jobConfigInfo.jobMonitorInfo.monitorConfig.timeoutEnable = monitorConfigNode["TimeoutEnable"].asString() == "true";
  112. if(!monitorConfigNode["FailEnable"].isNull())
  113. data_.jobConfigInfo.jobMonitorInfo.monitorConfig.failEnable = monitorConfigNode["FailEnable"].asString() == "true";
  114. if(!monitorConfigNode["MissWorkerEnable"].isNull())
  115. data_.jobConfigInfo.jobMonitorInfo.monitorConfig.missWorkerEnable = monitorConfigNode["MissWorkerEnable"].asString() == "true";
  116. if(!value["Code"].isNull())
  117. code_ = std::stoi(value["Code"].asString());
  118. if(!value["Message"].isNull())
  119. message_ = value["Message"].asString();
  120. if(!value["Success"].isNull())
  121. success_ = value["Success"].asString() == "true";
  122. }
  123. std::string GetJobInfoResult::getMessage()const
  124. {
  125. return message_;
  126. }
  127. GetJobInfoResult::Data GetJobInfoResult::getData()const
  128. {
  129. return data_;
  130. }
  131. int GetJobInfoResult::getCode()const
  132. {
  133. return code_;
  134. }
  135. bool GetJobInfoResult::getSuccess()const
  136. {
  137. return success_;
  138. }