Support AnalyzeLineage API.

2023-05-25 06:57:36 +00:00
parent af64ff1838
commit cd65c6d063
24 changed files with 1076 additions and 4 deletions
--- a/dms-enterprise/src/Dms-enterpriseClient.cc
+++ b/dms-enterprise/src/Dms-enterpriseClient.cc
@@ -195,6 +195,42 @@ Dms_enterpriseClient::AddTaskFlowEdgesOutcomeCallable Dms_enterpriseClient::addT
 	return task->get_future();
 }

+Dms_enterpriseClient::AnalyzeSQLLineageOutcome Dms_enterpriseClient::analyzeSQLLineage(const AnalyzeSQLLineageRequest &request) const
+{
+	auto endpointOutcome = endpointProvider_->getEndpoint();
+	if (!endpointOutcome.isSuccess())
+		return AnalyzeSQLLineageOutcome(endpointOutcome.error());
+
+	auto outcome = makeRequest(endpointOutcome.result(), request);
+
+	if (outcome.isSuccess())
+		return AnalyzeSQLLineageOutcome(AnalyzeSQLLineageResult(outcome.result()));
+	else
+		return AnalyzeSQLLineageOutcome(outcome.error());
+}
+
+void Dms_enterpriseClient::analyzeSQLLineageAsync(const AnalyzeSQLLineageRequest& request, const AnalyzeSQLLineageAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
+{
+	auto fn = [this, request, handler, context]()
+	{
+		handler(this, request, analyzeSQLLineage(request), context);
+	};
+
+	asyncExecute(new Runnable(fn));
+}
+
+Dms_enterpriseClient::AnalyzeSQLLineageOutcomeCallable Dms_enterpriseClient::analyzeSQLLineageCallable(const AnalyzeSQLLineageRequest &request) const
+{
+	auto task = std::make_shared<std::packaged_task<AnalyzeSQLLineageOutcome()>>(
+			[this, request]()
+			{
+			return this->analyzeSQLLineage(request);
+			});
+
+	asyncExecute(new Runnable([task]() { (*task)(); }));
+	return task->get_future();
+}
+
 Dms_enterpriseClient::ApproveOrderOutcome Dms_enterpriseClient::approveOrder(const ApproveOrderRequest &request) const
 {
 	auto endpointOutcome = endpointProvider_->getEndpoint();
@@ -2103,6 +2139,42 @@ Dms_enterpriseClient::GetDBTopologyOutcomeCallable Dms_enterpriseClient::getDBTo
 	return task->get_future();
 }

+Dms_enterpriseClient::GetDataArchiveOrderDetailOutcome Dms_enterpriseClient::getDataArchiveOrderDetail(const GetDataArchiveOrderDetailRequest &request) const
+{
+	auto endpointOutcome = endpointProvider_->getEndpoint();
+	if (!endpointOutcome.isSuccess())
+		return GetDataArchiveOrderDetailOutcome(endpointOutcome.error());
+
+	auto outcome = makeRequest(endpointOutcome.result(), request);
+
+	if (outcome.isSuccess())
+		return GetDataArchiveOrderDetailOutcome(GetDataArchiveOrderDetailResult(outcome.result()));
+	else
+		return GetDataArchiveOrderDetailOutcome(outcome.error());
+}
+
+void Dms_enterpriseClient::getDataArchiveOrderDetailAsync(const GetDataArchiveOrderDetailRequest& request, const GetDataArchiveOrderDetailAsyncHandler& handler, const std::shared_ptr<const AsyncCallerContext>& context) const
+{
+	auto fn = [this, request, handler, context]()
+	{
+		handler(this, request, getDataArchiveOrderDetail(request), context);
+	};
+
+	asyncExecute(new Runnable(fn));
+}
+
+Dms_enterpriseClient::GetDataArchiveOrderDetailOutcomeCallable Dms_enterpriseClient::getDataArchiveOrderDetailCallable(const GetDataArchiveOrderDetailRequest &request) const
+{
+	auto task = std::make_shared<std::packaged_task<GetDataArchiveOrderDetailOutcome()>>(
+			[this, request]()
+			{
+			return this->getDataArchiveOrderDetail(request);
+			});
+
+	asyncExecute(new Runnable([task]() { (*task)(); }));
+	return task->get_future();
+}
+
 Dms_enterpriseClient::GetDataCorrectBackupFilesOutcome Dms_enterpriseClient::getDataCorrectBackupFiles(const GetDataCorrectBackupFilesRequest &request) const
 {
 	auto endpointOutcome = endpointProvider_->getEndpoint();
--- a/dms-enterprise/src/model/AnalyzeSQLLineageRequest.cc
+++ b/dms-enterprise/src/model/AnalyzeSQLLineageRequest.cc
@@ -0,0 +1,54 @@
+/*
+ * Copyright 2009-2017 Alibaba Cloud All rights reserved.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+#include <alibabacloud/dms-enterprise/model/AnalyzeSQLLineageRequest.h>
+
+using AlibabaCloud::Dms_enterprise::Model::AnalyzeSQLLineageRequest;
+
+AnalyzeSQLLineageRequest::AnalyzeSQLLineageRequest()
+    : RpcServiceRequest("dms-enterprise", "2018-11-01", "AnalyzeSQLLineage") {
+  setMethod(HttpRequest::Method::Post);
+}
+
+AnalyzeSQLLineageRequest::~AnalyzeSQLLineageRequest() {}
+
+std::string AnalyzeSQLLineageRequest::getSqlContent() const {
+  return sqlContent_;
+}
+
+void AnalyzeSQLLineageRequest::setSqlContent(const std::string &sqlContent) {
+  sqlContent_ = sqlContent;
+  setParameter(std::string("SqlContent"), sqlContent);
+}
+
+long AnalyzeSQLLineageRequest::getTid() const {
+  return tid_;
+}
+
+void AnalyzeSQLLineageRequest::setTid(long tid) {
+  tid_ = tid;
+  setParameter(std::string("Tid"), std::to_string(tid));
+}
+
+long AnalyzeSQLLineageRequest::getDbId() const {
+  return dbId_;
+}
+
+void AnalyzeSQLLineageRequest::setDbId(long dbId) {
+  dbId_ = dbId;
+  setParameter(std::string("DbId"), std::to_string(dbId));
+}
+
--- a/dms-enterprise/src/model/AnalyzeSQLLineageResult.cc
+++ b/dms-enterprise/src/model/AnalyzeSQLLineageResult.cc
@@ -0,0 +1,110 @@
+/*
+ * Copyright 2009-2017 Alibaba Cloud All rights reserved.
+ * 
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ * 
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ * 
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+#include <alibabacloud/dms-enterprise/model/AnalyzeSQLLineageResult.h>
+#include <json/json.h>
+
+using namespace AlibabaCloud::Dms_enterprise;
+using namespace AlibabaCloud::Dms_enterprise::Model;
+
+AnalyzeSQLLineageResult::AnalyzeSQLLineageResult() :
+	ServiceResult()
+{}
+
+AnalyzeSQLLineageResult::AnalyzeSQLLineageResult(const std::string &payload) :
+	ServiceResult()
+{
+	parse(payload);
+}
+
+AnalyzeSQLLineageResult::~AnalyzeSQLLineageResult()
+{}
+
+void AnalyzeSQLLineageResult::parse(const std::string &payload)
+{
+	Json::Reader reader;
+	Json::Value value;
+	reader.parse(payload, value);
+	setRequestId(value["RequestId"].asString());
+	auto lineageResultNode = value["LineageResult"];
+	auto allLineagesNode = lineageResultNode["Lineages"]["LineageItem"];
+	for (auto lineageResultNodeLineagesLineageItem : allLineagesNode)
+	{
+		LineageResult::LineageItem lineageItemObject;
+		if(!lineageResultNodeLineagesLineageItem["LineageType"].isNull())
+			lineageItemObject.lineageType = lineageResultNodeLineagesLineageItem["LineageType"].asString();
+		if(!lineageResultNodeLineagesLineageItem["Src"].isNull())
+			lineageItemObject.src = lineageResultNodeLineagesLineageItem["Src"].asString();
+		if(!lineageResultNodeLineagesLineageItem["Dst"].isNull())
+			lineageItemObject.dst = lineageResultNodeLineagesLineageItem["Dst"].asString();
+		if(!lineageResultNodeLineagesLineageItem["OperType"].isNull())
+			lineageItemObject.operType = lineageResultNodeLineagesLineageItem["OperType"].asString();
+		auto processDetailNode = value["ProcessDetail"];
+		if(!processDetailNode["Code"].isNull())
+			lineageItemObject.processDetail.code = processDetailNode["Code"].asString();
+		if(!processDetailNode["CalWay"].isNull())
+			lineageItemObject.processDetail.calWay = processDetailNode["CalWay"].asString();
+		lineageResult_.lineages.push_back(lineageItemObject);
+	}
+	auto allObjectMetadataNode = lineageResultNode["ObjectMetadata"]["ObjectMetadataItem"];
+	for (auto lineageResultNodeObjectMetadataObjectMetadataItem : allObjectMetadataNode)
+	{
+		LineageResult::ObjectMetadataItem objectMetadataItemObject;
+		if(!lineageResultNodeObjectMetadataObjectMetadataItem["Name"].isNull())
+			objectMetadataItemObject.name = lineageResultNodeObjectMetadataObjectMetadataItem["Name"].asString();
+		if(!lineageResultNodeObjectMetadataObjectMetadataItem["Type"].isNull())
+			objectMetadataItemObject.type = lineageResultNodeObjectMetadataObjectMetadataItem["Type"].asString();
+		if(!lineageResultNodeObjectMetadataObjectMetadataItem["Source"].isNull())
+			objectMetadataItemObject.source = lineageResultNodeObjectMetadataObjectMetadataItem["Source"].asString();
+		auto allFieldsNode = lineageResultNodeObjectMetadataObjectMetadataItem["Fields"]["Field"];
+		for (auto lineageResultNodeObjectMetadataObjectMetadataItemFieldsField : allFieldsNode)
+		{
+			LineageResult::ObjectMetadataItem::Field fieldsObject;
+			if(!lineageResultNodeObjectMetadataObjectMetadataItemFieldsField["Name"].isNull())
+				fieldsObject.name = lineageResultNodeObjectMetadataObjectMetadataItemFieldsField["Name"].asString();
+			objectMetadataItemObject.fields.push_back(fieldsObject);
+		}
+		lineageResult_.objectMetadata.push_back(objectMetadataItemObject);
+	}
+	if(!value["Success"].isNull())
+		success_ = value["Success"].asString() == "true";
+	if(!value["ErrorMessage"].isNull())
+		errorMessage_ = value["ErrorMessage"].asString();
+	if(!value["ErrorCode"].isNull())
+		errorCode_ = value["ErrorCode"].asString();
+
+}
+
+AnalyzeSQLLineageResult::LineageResult AnalyzeSQLLineageResult::getLineageResult()const
+{
+	return lineageResult_;
+}
+
+std::string AnalyzeSQLLineageResult::getErrorCode()const
+{
+	return errorCode_;
+}
+
+std::string AnalyzeSQLLineageResult::getErrorMessage()const
+{
+	return errorMessage_;
+}
+
+bool AnalyzeSQLLineageResult::getSuccess()const
+{
+	return success_;
+}
+
--- a/dms-enterprise/src/model/BackFillRequest.cc
+++ b/dms-enterprise/src/model/BackFillRequest.cc
@@ -81,6 +81,17 @@ void BackFillRequest::setStartNodeIds(const std::vector<BackFillRequest::long> &
  }
 }

+std::vector<BackFillRequest::long> BackFillRequest::getFilterNodeIds() const {
+  return filterNodeIds_;
+}
+
+void BackFillRequest::setFilterNodeIds(const std::vector<BackFillRequest::long> &filterNodeIds) {
+  filterNodeIds_ = filterNodeIds;
+  for(int dep1 = 0; dep1 != filterNodeIds.size(); dep1++) {
+    setParameter(std::string("FilterNodeIds") + "." + std::to_string(dep1 + 1), std::to_string(filterNodeIds[dep1]));
+  }
+}
+
 std::string BackFillRequest::getBackFillDateBegin() const {
  return backFillDateBegin_;
 }
--- a/dms-enterprise/src/model/BackFillResult.cc
+++ b/dms-enterprise/src/model/BackFillResult.cc
@@ -45,6 +45,8 @@ void BackFillResult::parse(const std::string &payload)
 		errorMessage_ = value["ErrorMessage"].asString();
 	if(!value["Success"].isNull())
 		success_ = value["Success"].asString() == "true";
+	if(!value["DagInstanceId"].isNull())
+		dagInstanceId_ = std::stol(value["DagInstanceId"].asString());
 	if(!value["NodeId"].isNull())
 		nodeId_ = std::stol(value["NodeId"].asString());

@@ -65,6 +67,11 @@ std::string BackFillResult::getErrorMessage()const
 	return errorMessage_;
 }

+long BackFillResult::getDagInstanceId()const
+{
+	return dagInstanceId_;
+}
+
 bool BackFillResult::getSuccess()const
 {
 	return success_;
--- a/dms-enterprise/src/model/GetDataArchiveOrderDetailRequest.cc
+++ b/dms-enterprise/src/model/GetDataArchiveOrderDetailRequest.cc
@@ -0,0 +1,45 @@
+/*
+ * Copyright 2009-2017 Alibaba Cloud All rights reserved.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+#include <alibabacloud/dms-enterprise/model/GetDataArchiveOrderDetailRequest.h>
+
+using AlibabaCloud::Dms_enterprise::Model::GetDataArchiveOrderDetailRequest;
+
+GetDataArchiveOrderDetailRequest::GetDataArchiveOrderDetailRequest()
+    : RpcServiceRequest("dms-enterprise", "2018-11-01", "GetDataArchiveOrderDetail") {
+  setMethod(HttpRequest::Method::Post);
+}
+
+GetDataArchiveOrderDetailRequest::~GetDataArchiveOrderDetailRequest() {}
+
+long GetDataArchiveOrderDetailRequest::getTid() const {
+  return tid_;
+}
+
+void GetDataArchiveOrderDetailRequest::setTid(long tid) {
+  tid_ = tid;
+  setParameter(std::string("Tid"), std::to_string(tid));
+}
+
+long GetDataArchiveOrderDetailRequest::getOrderId() const {
+  return orderId_;
+}
+
+void GetDataArchiveOrderDetailRequest::setOrderId(long orderId) {
+  orderId_ = orderId;
+  setParameter(std::string("OrderId"), std::to_string(orderId));
+}
+
--- a/dms-enterprise/src/model/GetDataArchiveOrderDetailResult.cc
+++ b/dms-enterprise/src/model/GetDataArchiveOrderDetailResult.cc
@@ -0,0 +1,299 @@
+/*
+ * Copyright 2009-2017 Alibaba Cloud All rights reserved.
+ * 
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ * 
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ * 
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+#include <alibabacloud/dms-enterprise/model/GetDataArchiveOrderDetailResult.h>
+#include <json/json.h>
+
+using namespace AlibabaCloud::Dms_enterprise;
+using namespace AlibabaCloud::Dms_enterprise::Model;
+
+GetDataArchiveOrderDetailResult::GetDataArchiveOrderDetailResult() :
+	ServiceResult()
+{}
+
+GetDataArchiveOrderDetailResult::GetDataArchiveOrderDetailResult(const std::string &payload) :
+	ServiceResult()
+{
+	parse(payload);
+}
+
+GetDataArchiveOrderDetailResult::~GetDataArchiveOrderDetailResult()
+{}
+
+void GetDataArchiveOrderDetailResult::parse(const std::string &payload)
+{
+	Json::Reader reader;
+	Json::Value value;
+	reader.parse(payload, value);
+	setRequestId(value["RequestId"].asString());
+	auto dataArchiveOrderDetailNode = value["DataArchiveOrderDetail"];
+	if(!dataArchiveOrderDetailNode["Comment"].isNull())
+		dataArchiveOrderDetail_.comment = dataArchiveOrderDetailNode["Comment"].asString();
+	if(!dataArchiveOrderDetailNode["Committer"].isNull())
+		dataArchiveOrderDetail_.committer = dataArchiveOrderDetailNode["Committer"].asString();
+	if(!dataArchiveOrderDetailNode["CommitterId"].isNull())
+		dataArchiveOrderDetail_.committerId = std::stol(dataArchiveOrderDetailNode["CommitterId"].asString());
+	if(!dataArchiveOrderDetailNode["GmtCreate"].isNull())
+		dataArchiveOrderDetail_.gmtCreate = dataArchiveOrderDetailNode["GmtCreate"].asString();
+	if(!dataArchiveOrderDetailNode["GmtModified"].isNull())
+		dataArchiveOrderDetail_.gmtModified = dataArchiveOrderDetailNode["GmtModified"].asString();
+	if(!dataArchiveOrderDetailNode["Id"].isNull())
+		dataArchiveOrderDetail_.id = std::stol(dataArchiveOrderDetailNode["Id"].asString());
+	if(!dataArchiveOrderDetailNode["PluginType"].isNull())
+		dataArchiveOrderDetail_.pluginType = dataArchiveOrderDetailNode["PluginType"].asString();
+	if(!dataArchiveOrderDetailNode["StatusCode"].isNull())
+		dataArchiveOrderDetail_.statusCode = dataArchiveOrderDetailNode["StatusCode"].asString();
+	if(!dataArchiveOrderDetailNode["StatusDesc"].isNull())
+		dataArchiveOrderDetail_.statusDesc = dataArchiveOrderDetailNode["StatusDesc"].asString();
+	if(!dataArchiveOrderDetailNode["WorkflowInstanceId"].isNull())
+		dataArchiveOrderDetail_.workflowInstanceId = std::stol(dataArchiveOrderDetailNode["WorkflowInstanceId"].asString());
+	if(!dataArchiveOrderDetailNode["WorkflowStatusDesc"].isNull())
+		dataArchiveOrderDetail_.workflowStatusDesc = dataArchiveOrderDetailNode["WorkflowStatusDesc"].asString();
+	auto pluginExtraDataNode = dataArchiveOrderDetailNode["PluginExtraData"];
+	if(!pluginExtraDataNode["InstanceTotal"].isNull())
+		dataArchiveOrderDetail_.pluginExtraData.instanceTotal = std::stol(pluginExtraDataNode["InstanceTotal"].asString());
+	if(!pluginExtraDataNode["PageIndex"].isNull())
+		dataArchiveOrderDetail_.pluginExtraData.pageIndex = std::stol(pluginExtraDataNode["PageIndex"].asString());
+	if(!pluginExtraDataNode["PageSize"].isNull())
+		dataArchiveOrderDetail_.pluginExtraData.pageSize = std::stol(pluginExtraDataNode["PageSize"].asString());
+	auto allInstancesNode = pluginExtraDataNode["Instances"]["InstancesItem"];
+	for (auto pluginExtraDataNodeInstancesInstancesItem : allInstancesNode)
+	{
+		DataArchiveOrderDetail::PluginExtraData::InstancesItem instancesItemObject;
+		if(!pluginExtraDataNodeInstancesInstancesItem["BusinessTime"].isNull())
+			instancesItemObject.businessTime = pluginExtraDataNodeInstancesInstancesItem["BusinessTime"].asString();
+		if(!pluginExtraDataNodeInstancesInstancesItem["DagId"].isNull())
+			instancesItemObject.dagId = std::stol(pluginExtraDataNodeInstancesInstancesItem["DagId"].asString());
+		if(!pluginExtraDataNodeInstancesInstancesItem["EndTime"].isNull())
+			instancesItemObject.endTime = pluginExtraDataNodeInstancesInstancesItem["EndTime"].asString();
+		if(!pluginExtraDataNodeInstancesInstancesItem["GmtCreate"].isNull())
+			instancesItemObject.gmtCreate = pluginExtraDataNodeInstancesInstancesItem["GmtCreate"].asString();
+		if(!pluginExtraDataNodeInstancesInstancesItem["GmtModified"].isNull())
+			instancesItemObject.gmtModified = pluginExtraDataNodeInstancesInstancesItem["GmtModified"].asString();
+		if(!pluginExtraDataNodeInstancesInstancesItem["HistoryDagId"].isNull())
+			instancesItemObject.historyDagId = std::stol(pluginExtraDataNodeInstancesInstancesItem["HistoryDagId"].asString());
+		if(!pluginExtraDataNodeInstancesInstancesItem["Id"].isNull())
+			instancesItemObject.id = std::stol(pluginExtraDataNodeInstancesInstancesItem["Id"].asString());
+		if(!pluginExtraDataNodeInstancesInstancesItem["LastRunningContext"].isNull())
+			instancesItemObject.lastRunningContext = pluginExtraDataNodeInstancesInstancesItem["LastRunningContext"].asString();
+		if(!pluginExtraDataNodeInstancesInstancesItem["Msg"].isNull())
+			instancesItemObject.msg = pluginExtraDataNodeInstancesInstancesItem["Msg"].asString();
+		if(!pluginExtraDataNodeInstancesInstancesItem["Status"].isNull())
+			instancesItemObject.status = std::stol(pluginExtraDataNodeInstancesInstancesItem["Status"].asString());
+		if(!pluginExtraDataNodeInstancesInstancesItem["TenantId"].isNull())
+			instancesItemObject.tenantId = pluginExtraDataNodeInstancesInstancesItem["TenantId"].asString();
+		if(!pluginExtraDataNodeInstancesInstancesItem["TriggerType"].isNull())
+			instancesItemObject.triggerType = std::stol(pluginExtraDataNodeInstancesInstancesItem["TriggerType"].asString());
+		if(!pluginExtraDataNodeInstancesInstancesItem["Version"].isNull())
+			instancesItemObject.version = pluginExtraDataNodeInstancesInstancesItem["Version"].asString();
+		dataArchiveOrderDetail_.pluginExtraData.instances.push_back(instancesItemObject);
+	}
+	auto dagInfoNode = pluginExtraDataNode["DagInfo"];
+	if(!dagInfoNode["CreatorId"].isNull())
+		dataArchiveOrderDetail_.pluginExtraData.dagInfo.creatorId = dagInfoNode["CreatorId"].asString();
+	if(!dagInfoNode["CronBeginDate"].isNull())
+		dataArchiveOrderDetail_.pluginExtraData.dagInfo.cronBeginDate = dagInfoNode["CronBeginDate"].asString();
+	if(!dagInfoNode["CronEndDate"].isNull())
+		dataArchiveOrderDetail_.pluginExtraData.dagInfo.cronEndDate = dagInfoNode["CronEndDate"].asString();
+	if(!dagInfoNode["CronTrigger"].isNull())
+		dataArchiveOrderDetail_.pluginExtraData.dagInfo.cronTrigger = dagInfoNode["CronTrigger"].asString() == "true";
+	if(!dagInfoNode["DWDevelop"].isNull())
+		dataArchiveOrderDetail_.pluginExtraData.dagInfo.dWDevelop = dagInfoNode["DWDevelop"].asString() == "true";
+	if(!dagInfoNode["DagName"].isNull())
+		dataArchiveOrderDetail_.pluginExtraData.dagInfo.dagName = dagInfoNode["DagName"].asString();
+	if(!dagInfoNode["DagOwnerId"].isNull())
+		dataArchiveOrderDetail_.pluginExtraData.dagInfo.dagOwnerId = dagInfoNode["DagOwnerId"].asString();
+	if(!dagInfoNode["DeployId"].isNull())
+		dataArchiveOrderDetail_.pluginExtraData.dagInfo.deployId = std::stol(dagInfoNode["DeployId"].asString());
+	if(!dagInfoNode["Description"].isNull())
+		dataArchiveOrderDetail_.pluginExtraData.dagInfo.description = dagInfoNode["Description"].asString();
+	if(!dagInfoNode["EditDagId"].isNull())
+		dataArchiveOrderDetail_.pluginExtraData.dagInfo.editDagId = std::stol(dagInfoNode["EditDagId"].asString());
+	if(!dagInfoNode["GmtCreate"].isNull())
+		dataArchiveOrderDetail_.pluginExtraData.dagInfo.gmtCreate = dagInfoNode["GmtCreate"].asString();
+	if(!dagInfoNode["GmtModified"].isNull())
+		dataArchiveOrderDetail_.pluginExtraData.dagInfo.gmtModified = dagInfoNode["GmtModified"].asString();
+	if(!dagInfoNode["Id"].isNull())
+		dataArchiveOrderDetail_.pluginExtraData.dagInfo.id = std::stol(dagInfoNode["Id"].asString());
+	if(!dagInfoNode["IsPublic"].isNull())
+		dataArchiveOrderDetail_.pluginExtraData.dagInfo.isPublic = std::stol(dagInfoNode["IsPublic"].asString());
+	if(!dagInfoNode["Legacy"].isNull())
+		dataArchiveOrderDetail_.pluginExtraData.dagInfo.legacy = dagInfoNode["Legacy"].asString() == "true";
+	if(!dagInfoNode["System"].isNull())
+		dataArchiveOrderDetail_.pluginExtraData.dagInfo.system = dagInfoNode["System"].asString() == "true";
+	if(!dagInfoNode["TenantId"].isNull())
+		dataArchiveOrderDetail_.pluginExtraData.dagInfo.tenantId = dagInfoNode["TenantId"].asString();
+	if(!dagInfoNode["TriggerOnce"].isNull())
+		dataArchiveOrderDetail_.pluginExtraData.dagInfo.triggerOnce = dagInfoNode["TriggerOnce"].asString() == "true";
+	auto dbBaseInfoNode = pluginExtraDataNode["DbBaseInfo"];
+	if(!dbBaseInfoNode["Alias"].isNull())
+		dataArchiveOrderDetail_.pluginExtraData.dbBaseInfo.alias = dbBaseInfoNode["Alias"].asString();
+	if(!dbBaseInfoNode["AlterTimeout"].isNull())
+		dataArchiveOrderDetail_.pluginExtraData.dbBaseInfo.alterTimeout = std::stol(dbBaseInfoNode["AlterTimeout"].asString());
+	if(!dbBaseInfoNode["AssetControl"].isNull())
+		dataArchiveOrderDetail_.pluginExtraData.dbBaseInfo.assetControl = dbBaseInfoNode["AssetControl"].asString() == "true";
+	if(!dbBaseInfoNode["CatalogName"].isNull())
+		dataArchiveOrderDetail_.pluginExtraData.dbBaseInfo.catalogName = dbBaseInfoNode["CatalogName"].asString();
+	if(!dbBaseInfoNode["ClusterNode"].isNull())
+		dataArchiveOrderDetail_.pluginExtraData.dbBaseInfo.clusterNode = dbBaseInfoNode["ClusterNode"].asString();
+	if(!dbBaseInfoNode["DbId"].isNull())
+		dataArchiveOrderDetail_.pluginExtraData.dbBaseInfo.dbId = std::stol(dbBaseInfoNode["DbId"].asString());
+	if(!dbBaseInfoNode["DbType"].isNull())
+		dataArchiveOrderDetail_.pluginExtraData.dbBaseInfo.dbType = dbBaseInfoNode["DbType"].asString();
+	if(!dbBaseInfoNode["DbaId"].isNull())
+		dataArchiveOrderDetail_.pluginExtraData.dbBaseInfo.dbaId = std::stol(dbBaseInfoNode["DbaId"].asString());
+	if(!dbBaseInfoNode["DbaName"].isNull())
+		dataArchiveOrderDetail_.pluginExtraData.dbBaseInfo.dbaName = dbBaseInfoNode["DbaName"].asString();
+	if(!dbBaseInfoNode["Description"].isNull())
+		dataArchiveOrderDetail_.pluginExtraData.dbBaseInfo.description = dbBaseInfoNode["Description"].asString();
+	if(!dbBaseInfoNode["Encoding"].isNull())
+		dataArchiveOrderDetail_.pluginExtraData.dbBaseInfo.encoding = dbBaseInfoNode["Encoding"].asString();
+	if(!dbBaseInfoNode["EnvType"].isNull())
+		dataArchiveOrderDetail_.pluginExtraData.dbBaseInfo.envType = dbBaseInfoNode["EnvType"].asString();
+	if(!dbBaseInfoNode["Follow"].isNull())
+		dataArchiveOrderDetail_.pluginExtraData.dbBaseInfo.follow = dbBaseInfoNode["Follow"].asString() == "true";
+	if(!dbBaseInfoNode["Host"].isNull())
+		dataArchiveOrderDetail_.pluginExtraData.dbBaseInfo.host = dbBaseInfoNode["Host"].asString();
+	if(!dbBaseInfoNode["Idc"].isNull())
+		dataArchiveOrderDetail_.pluginExtraData.dbBaseInfo.idc = dbBaseInfoNode["Idc"].asString();
+	if(!dbBaseInfoNode["IdcTitle"].isNull())
+		dataArchiveOrderDetail_.pluginExtraData.dbBaseInfo.idcTitle = dbBaseInfoNode["IdcTitle"].asString();
+	if(!dbBaseInfoNode["InstanceId"].isNull())
+		dataArchiveOrderDetail_.pluginExtraData.dbBaseInfo.instanceId = std::stol(dbBaseInfoNode["InstanceId"].asString());
+	if(!dbBaseInfoNode["InstanceSource"].isNull())
+		dataArchiveOrderDetail_.pluginExtraData.dbBaseInfo.instanceSource = dbBaseInfoNode["InstanceSource"].asString();
+	if(!dbBaseInfoNode["LastSyncTime"].isNull())
+		dataArchiveOrderDetail_.pluginExtraData.dbBaseInfo.lastSyncTime = dbBaseInfoNode["LastSyncTime"].asString();
+	if(!dbBaseInfoNode["Level"].isNull())
+		dataArchiveOrderDetail_.pluginExtraData.dbBaseInfo.level = dbBaseInfoNode["Level"].asString();
+	if(!dbBaseInfoNode["Logic"].isNull())
+		dataArchiveOrderDetail_.pluginExtraData.dbBaseInfo.logic = dbBaseInfoNode["Logic"].asString() == "true";
+	if(!dbBaseInfoNode["Port"].isNull())
+		dataArchiveOrderDetail_.pluginExtraData.dbBaseInfo.port = std::stol(dbBaseInfoNode["Port"].asString());
+	if(!dbBaseInfoNode["SchemaName"].isNull())
+		dataArchiveOrderDetail_.pluginExtraData.dbBaseInfo.schemaName = dbBaseInfoNode["SchemaName"].asString();
+	if(!dbBaseInfoNode["SearchName"].isNull())
+		dataArchiveOrderDetail_.pluginExtraData.dbBaseInfo.searchName = dbBaseInfoNode["SearchName"].asString();
+	if(!dbBaseInfoNode["State"].isNull())
+		dataArchiveOrderDetail_.pluginExtraData.dbBaseInfo.state = dbBaseInfoNode["State"].asString();
+	if(!dbBaseInfoNode["TableCount"].isNull())
+		dataArchiveOrderDetail_.pluginExtraData.dbBaseInfo.tableCount = std::stol(dbBaseInfoNode["TableCount"].asString());
+	if(!dbBaseInfoNode["TnsName"].isNull())
+		dataArchiveOrderDetail_.pluginExtraData.dbBaseInfo.tnsName = dbBaseInfoNode["TnsName"].asString();
+	if(!dbBaseInfoNode["UnitType"].isNull())
+		dataArchiveOrderDetail_.pluginExtraData.dbBaseInfo.unitType = dbBaseInfoNode["UnitType"].asString();
+	auto standardGroupNode = dbBaseInfoNode["StandardGroup"];
+	if(!standardGroupNode["DbType"].isNull())
+		dataArchiveOrderDetail_.pluginExtraData.dbBaseInfo.standardGroup.dbType = standardGroupNode["DbType"].asString();
+	if(!standardGroupNode["Description"].isNull())
+		dataArchiveOrderDetail_.pluginExtraData.dbBaseInfo.standardGroup.description = standardGroupNode["Description"].asString();
+	if(!standardGroupNode["FreeOrStable"].isNull())
+		dataArchiveOrderDetail_.pluginExtraData.dbBaseInfo.standardGroup.freeOrStable = standardGroupNode["FreeOrStable"].asString() == "true";
+	if(!standardGroupNode["GmtCreate"].isNull())
+		dataArchiveOrderDetail_.pluginExtraData.dbBaseInfo.standardGroup.gmtCreate = standardGroupNode["GmtCreate"].asString();
+	if(!standardGroupNode["GmtModified"].isNull())
+		dataArchiveOrderDetail_.pluginExtraData.dbBaseInfo.standardGroup.gmtModified = standardGroupNode["GmtModified"].asString();
+	if(!standardGroupNode["GroupMode"].isNull())
+		dataArchiveOrderDetail_.pluginExtraData.dbBaseInfo.standardGroup.groupMode = standardGroupNode["GroupMode"].asString();
+	if(!standardGroupNode["GroupName"].isNull())
+		dataArchiveOrderDetail_.pluginExtraData.dbBaseInfo.standardGroup.groupName = standardGroupNode["GroupName"].asString();
+	if(!standardGroupNode["Id"].isNull())
+		dataArchiveOrderDetail_.pluginExtraData.dbBaseInfo.standardGroup.id = std::stol(standardGroupNode["Id"].asString());
+	if(!standardGroupNode["LastMenderId"].isNull())
+		dataArchiveOrderDetail_.pluginExtraData.dbBaseInfo.standardGroup.lastMenderId = std::stol(standardGroupNode["LastMenderId"].asString());
+		auto allOwnerIds = dbBaseInfoNode["OwnerIds"]["OwnerIds"];
+		for (auto value : allOwnerIds)
+			dataArchiveOrderDetail_.pluginExtraData.dbBaseInfo.ownerIds.push_back(value.asString());
+		auto allOwnerNames = dbBaseInfoNode["OwnerNames"]["OwnerNames"];
+		for (auto value : allOwnerNames)
+			dataArchiveOrderDetail_.pluginExtraData.dbBaseInfo.ownerNames.push_back(value.asString());
+	auto nextFireTimeResultNode = pluginExtraDataNode["NextFireTimeResult"];
+	if(!nextFireTimeResultNode["CronFireType"].isNull())
+		dataArchiveOrderDetail_.pluginExtraData.nextFireTimeResult.cronFireType = nextFireTimeResultNode["CronFireType"].asString();
+	auto pluginParamNode = dataArchiveOrderDetailNode["PluginParam"];
+	if(!pluginParamNode["ArchiveMethod"].isNull())
+		dataArchiveOrderDetail_.pluginParam.archiveMethod = pluginParamNode["ArchiveMethod"].asString();
+	if(!pluginParamNode["DbSchema"].isNull())
+		dataArchiveOrderDetail_.pluginParam.dbSchema = pluginParamNode["DbSchema"].asString();
+	if(!pluginParamNode["Logic"].isNull())
+		dataArchiveOrderDetail_.pluginParam.logic = pluginParamNode["Logic"].asString() == "true";
+	if(!pluginParamNode["RunMethod"].isNull())
+		dataArchiveOrderDetail_.pluginParam.runMethod = pluginParamNode["RunMethod"].asString();
+	if(!pluginParamNode["SourceDatabaseId"].isNull())
+		dataArchiveOrderDetail_.pluginParam.sourceDatabaseId = std::stol(pluginParamNode["SourceDatabaseId"].asString());
+	if(!pluginParamNode["TargetInstanceId"].isNull())
+		dataArchiveOrderDetail_.pluginParam.targetInstanceId = pluginParamNode["TargetInstanceId"].asString();
+	auto allTableIncludesNode = pluginParamNode["TableIncludes"]["IncludeTables"];
+	for (auto pluginParamNodeTableIncludesIncludeTables : allTableIncludesNode)
+	{
+		DataArchiveOrderDetail::PluginParam::IncludeTables includeTablesObject;
+		if(!pluginParamNodeTableIncludesIncludeTables["TableName"].isNull())
+			includeTablesObject.tableName = pluginParamNodeTableIncludesIncludeTables["TableName"].asString();
+		if(!pluginParamNodeTableIncludesIncludeTables["TableWhere"].isNull())
+			includeTablesObject.tableWhere = pluginParamNodeTableIncludesIncludeTables["TableWhere"].asString();
+		dataArchiveOrderDetail_.pluginParam.tableIncludes.push_back(includeTablesObject);
+	}
+		auto allOrderAfter = pluginParamNode["OrderAfter"]["AfterOrder"];
+		for (auto value : allOrderAfter)
+			dataArchiveOrderDetail_.pluginParam.orderAfter.push_back(value.asString());
+		auto allTableMapping = pluginParamNode["TableMapping"]["MappingTable"];
+		for (auto value : allTableMapping)
+			dataArchiveOrderDetail_.pluginParam.tableMapping.push_back(value.asString());
+		auto allVariables = pluginParamNode["Variables"]["Variables"];
+		for (auto value : allVariables)
+			dataArchiveOrderDetail_.pluginParam.variables.push_back(value.asString());
+		auto allRelatedUserList = dataArchiveOrderDetailNode["RelatedUserList"]["RelatedUserList"];
+		for (auto value : allRelatedUserList)
+			dataArchiveOrderDetail_.relatedUserList.push_back(value.asString());
+		auto allRelatedUserNickList = dataArchiveOrderDetailNode["RelatedUserNickList"]["RelatedUserNickList"];
+		for (auto value : allRelatedUserNickList)
+			dataArchiveOrderDetail_.relatedUserNickList.push_back(value.asString());
+	if(!value["TraceId"].isNull())
+		traceId_ = value["TraceId"].asString();
+	if(!value["Success"].isNull())
+		success_ = value["Success"].asString() == "true";
+	if(!value["ErrorMessage"].isNull())
+		errorMessage_ = value["ErrorMessage"].asString();
+	if(!value["ErrorCode"].isNull())
+		errorCode_ = value["ErrorCode"].asString();
+
+}
+
+std::string GetDataArchiveOrderDetailResult::getTraceId()const
+{
+	return traceId_;
+}
+
+std::string GetDataArchiveOrderDetailResult::getErrorCode()const
+{
+	return errorCode_;
+}
+
+GetDataArchiveOrderDetailResult::DataArchiveOrderDetail GetDataArchiveOrderDetailResult::getDataArchiveOrderDetail()const
+{
+	return dataArchiveOrderDetail_;
+}
+
+std::string GetDataArchiveOrderDetailResult::getErrorMessage()const
+{
+	return errorMessage_;
+}
+
+bool GetDataArchiveOrderDetailResult::getSuccess()const
+{
+	return success_;
+}
+
--- a/dms-enterprise/src/model/ListTaskFlowInstanceRequest.cc
+++ b/dms-enterprise/src/model/ListTaskFlowInstanceRequest.cc
@@ -25,6 +25,15 @@ ListTaskFlowInstanceRequest::ListTaskFlowInstanceRequest()

 ListTaskFlowInstanceRequest::~ListTaskFlowInstanceRequest() {}

+bool ListTaskFlowInstanceRequest::getUseBizDate() const {
+  return useBizDate_;
+}
+
+void ListTaskFlowInstanceRequest::setUseBizDate(bool useBizDate) {
+  useBizDate_ = useBizDate;
+  setParameter(std::string("UseBizDate"), useBizDate ? "true" : "false");
+}
+
 int ListTaskFlowInstanceRequest::getTriggerType() const {
  return triggerType_;
 }
@@ -88,3 +97,12 @@ void ListTaskFlowInstanceRequest::setStartTimeEnd(const std::string &startTimeEn
  setParameter(std::string("StartTimeEnd"), startTimeEnd);
 }

+int ListTaskFlowInstanceRequest::getStatus() const {
+  return status_;
+}
+
+void ListTaskFlowInstanceRequest::setStatus(int status) {
+  status_ = status;
+  setParameter(std::string("Status"), std::to_string(status));
+}
+
--- a/dms-enterprise/src/model/ListTaskFlowInstanceResult.cc
+++ b/dms-enterprise/src/model/ListTaskFlowInstanceResult.cc
@@ -47,6 +47,8 @@ void ListTaskFlowInstanceResult::parse(const std::string &payload)
 			dAGInstanceListObject.id = std::stol(valueDAGInstanceListDAGInstance["Id"].asString());
 		if(!valueDAGInstanceListDAGInstance["BusinessTime"].isNull())
 			dAGInstanceListObject.businessTime = valueDAGInstanceListDAGInstance["BusinessTime"].asString();
+		if(!valueDAGInstanceListDAGInstance["startTime"].isNull())
+			dAGInstanceListObject.startTime = valueDAGInstanceListDAGInstance["startTime"].asString();
 		if(!valueDAGInstanceListDAGInstance["EndTime"].isNull())
 			dAGInstanceListObject.endTime = valueDAGInstanceListDAGInstance["EndTime"].asString();
 		if(!valueDAGInstanceListDAGInstance["DagId"].isNull())
--- a/dms-enterprise/src/model/ListTaskFlowsByPageRequest.cc
+++ b/dms-enterprise/src/model/ListTaskFlowsByPageRequest.cc
@@ -34,6 +34,17 @@ void ListTaskFlowsByPageRequest::setSearchKey(const std::string &searchKey) {
  setParameter(std::string("SearchKey"), searchKey);
 }

+std::vector<ListTaskFlowsByPageRequest::long> ListTaskFlowsByPageRequest::getDagIdList() const {
+  return dagIdList_;
+}
+
+void ListTaskFlowsByPageRequest::setDagIdList(const std::vector<ListTaskFlowsByPageRequest::long> &dagIdList) {
+  dagIdList_ = dagIdList;
+  for(int dep1 = 0; dep1 != dagIdList.size(); dep1++) {
+    setParameter(std::string("DagIdList") + "." + std::to_string(dep1 + 1), std::to_string(dagIdList[dep1]));
+  }
+}
+
 long ListTaskFlowsByPageRequest::getTid() const {
  return tid_;
 }
@@ -61,6 +72,15 @@ void ListTaskFlowsByPageRequest::setPageIndex(int pageIndex) {
  setParameter(std::string("PageIndex"), std::to_string(pageIndex));
 }

+long ListTaskFlowsByPageRequest::getScenarioId() const {
+  return scenarioId_;
+}
+
+void ListTaskFlowsByPageRequest::setScenarioId(long scenarioId) {
+  scenarioId_ = scenarioId;
+  setParameter(std::string("ScenarioId"), std::to_string(scenarioId));
+}
+
 bool ListTaskFlowsByPageRequest::getNeedLastDagInstance() const {
  return needLastDagInstance_;
 }
--- a/dms-enterprise/src/model/ListTaskFlowsByPageResult.cc
+++ b/dms-enterprise/src/model/ListTaskFlowsByPageResult.cc
@@ -63,6 +63,20 @@ void ListTaskFlowsByPageResult::parse(const std::string &payload)
 			taskFlowListObject.latestInstanceStatus = std::stoi(valueTaskFlowListTaskFlow["LatestInstanceStatus"].asString());
 		if(!valueTaskFlowListTaskFlow["LatestInstanceTime"].isNull())
 			taskFlowListObject.latestInstanceTime = valueTaskFlowListTaskFlow["LatestInstanceTime"].asString();
+		if(!valueTaskFlowListTaskFlow["ScenarioId"].isNull())
+			taskFlowListObject.scenarioId = valueTaskFlowListTaskFlow["ScenarioId"].asString();
+		if(!valueTaskFlowListTaskFlow["CronSwitch"].isNull())
+			taskFlowListObject.cronSwitch = valueTaskFlowListTaskFlow["CronSwitch"].asString() == "true";
+		if(!valueTaskFlowListTaskFlow["CronStr"].isNull())
+			taskFlowListObject.cronStr = valueTaskFlowListTaskFlow["CronStr"].asString();
+		if(!valueTaskFlowListTaskFlow["CronParam"].isNull())
+			taskFlowListObject.cronParam = valueTaskFlowListTaskFlow["CronParam"].asString();
+		if(!valueTaskFlowListTaskFlow["TriggerType"].isNull())
+			taskFlowListObject.triggerType = std::stoi(valueTaskFlowListTaskFlow["TriggerType"].asString());
+		if(!valueTaskFlowListTaskFlow["CronType"].isNull())
+			taskFlowListObject.cronType = std::stoi(valueTaskFlowListTaskFlow["CronType"].asString());
+		if(!valueTaskFlowListTaskFlow["TimeZoneId"].isNull())
+			taskFlowListObject.timeZoneId = valueTaskFlowListTaskFlow["TimeZoneId"].asString();
 		taskFlowList_.push_back(taskFlowListObject);
 	}
 	if(!value["ErrorCode"].isNull())