upload flow compare info to schedulis

Author: xlinliu

dss-appconn/appconns/dss-eventchecker-appconn/src/main/scala/com/webank/wedatasphere/dss/appconn/eventchecker/execution/EventCheckerRefExecutionOperation.scala

@@ -70,6 +70,7 @@ class EventCheckerRefExecutionOperation
   }
 
   override def submit(requestRef: RefExecutionRequestRef.RefExecutionContextRequestRef): RefExecutionAction = {
+    requestRef.getExecutionRequestRefContext
     val nodeAction = new EventCheckerExecutionAction()
     nodeAction.setId(UUID.randomUUID().toString)
     import scala.collection.JavaConversions.mapAsScalaMap

dss-appconn/appconns/dss-schedulis-appconn/src/main/java/com/webank/wedatasphere/dss/appconn/schedulis/utils/SchedulisHttpUtils.java

@@ -80,4 +80,15 @@ public static String getHttpPostResult(String url,
         return getHttpResult(url, getAction, ssoRequestOperation, workspace);
     }
 
+    public static String getHttpPostResult(String url,
+                                           Map<String, String> params,
+                                           Map<String, Object> payloads,
+                                           SSORequestOperation<HttpAction, HttpResult> ssoRequestOperation,
+                                           Workspace workspace) {
+        DSSPostAction getAction = new DSSPostAction();
+        getAction.getFormParams().putAll(params);
+        getAction.getRequestPayloads().putAll(payloads);
+        return getHttpResult(url, getAction, ssoRequestOperation, workspace);
+    }
+
 }

dss-orchestrator/dss-orchestrator-common/src/main/java/com/webank/wedatasphere/dss/orchestrator/common/protocol/RequestOrchestratorVersion.java

@@ -22,13 +22,12 @@ public class RequestOrchestratorVersion {
     private String username;
     private Long projectId;
     private Long orchestratorId;
-    private String dssLabel;
 
 
-    public static RequestOrchestratorVersion newInstance(String username, Long projectId, Long orchestratorId, String dssLabel) {
+
+    public static RequestOrchestratorVersion newInstance(String username, Long projectId, Long orchestratorId) {
         RequestOrchestratorVersion requestOrchestratorVersion = new RequestOrchestratorVersion();
         requestOrchestratorVersion.setOrchestratorId(orchestratorId);
-        requestOrchestratorVersion.setDssLabel(dssLabel);
         requestOrchestratorVersion.setProjectId(projectId);
         requestOrchestratorVersion.setUsername(username);
         return requestOrchestratorVersion;
@@ -59,11 +58,7 @@ public void setOrchestratorId(Long orchestratorId) {
         this.orchestratorId = orchestratorId;
     }
 
-    public String getDssLabel() {
-        return dssLabel;
-    }
 
-    public void setDssLabel(String dssLabel) {
-        this.dssLabel = dssLabel;
-    }
+
+
 }

dss-orchestrator/orchestrators/dss-workflow/dss-workflow-sdk/src/main/java/com/webank/wedatasphere/dss/workflow/core/entity/Workflow.java

@@ -34,6 +34,9 @@ public interface Workflow extends Flow {
 
     List<Map<String, Object>> getFlowProperties();
 
+
+     List<Workflow> getChildren();
+
     Long getCreateTime();
 
     Long getUpdateTime();