批量编辑tableu节点视图ID属性 #AI commit#

Author: SunPengWan

dss-orchestrator/orchestrators/dss-workflow/dss-workflow-server/src/main/java/com/webank/wedatasphere/dss/workflow/entity/request/EditFlowRequest.java

@@ -12,6 +12,8 @@ public class EditFlowRequest {
     private String desc;
     private String businessTag;
     private String appTag;
+    private String viewId;
+    private String datasourceId;
     private String params;
     private String ecConfTemplateId;
     private String ecConfTemplateName;
@@ -80,6 +82,22 @@ public void setAppTag(String appTag) {
         this.appTag = appTag;
     }
 
+    public String getViewId() {
+        return viewId;
+    }
+
+    public void setViewId(String viewId) {
+        this.viewId = viewId;
+    }
+
+    public String getDatasourceId() {
+        return datasourceId;
+    }
+
+    public void setDatasourceId(String datasourceId) {
+        this.datasourceId = datasourceId;
+    }
+
     public String getEcConfTemplateId() {
         return ecConfTemplateId;
     }

dss-orchestrator/orchestrators/dss-workflow/dss-workflow-server/src/main/java/com/webank/wedatasphere/dss/workflow/service/impl/DSSFlowServiceImpl.java

@@ -2641,6 +2641,8 @@ private String modifyJson(String flowJson, EditFlowRequest editFlowRequest, Long
         String desc = editFlowRequest.getDesc();
         String appTag = editFlowRequest.getAppTag();
         String businessTag = editFlowRequest.getBusinessTag();
+        String viewId = editFlowRequest.getViewId();
+        String datasourceId = editFlowRequest.getDatasourceId();
         String ecConfTemplateId = editFlowRequest.getEcConfTemplateId();
         String ecConfTemplateName = editFlowRequest.getEcConfTemplateName();
         JsonObject jsonObject = JsonParser.parseString(flowJson).getAsJsonObject();
@@ -2660,6 +2662,27 @@ private String modifyJson(String flowJson, EditFlowRequest editFlowRequest, Long
                 flowJsonAddPointProperty(obj, "desc", desc);
                 flowJsonAddProperty(obj, "appTag", appTag);
                 flowJsonAddProperty(obj, "businessTag", businessTag);
+
+                if (StringUtils.isNotEmpty(viewId)) {
+                    JsonObject jobContent = new JsonObject();
+                    if (obj.has("jobContent") && obj.get("jobContent").isJsonObject()) {
+                        jobContent = obj.getAsJsonObject("jobContent");
+                    } else {
+                        obj.add("jobContent", jobContent);
+                    }
+                    jobContent.addProperty("viewId", viewId);
+                }
+
+                if (StringUtils.isNotEmpty(datasourceId)) {
+                    JsonObject jobContent = new JsonObject();
+                    if (obj.has("jobContent") && obj.get("jobContent").isJsonObject()) {
+                        jobContent = obj.getAsJsonObject("jobContent");
+                    } else {
+                        obj.add("jobContent", jobContent);
+                    }
+                    jobContent.addProperty("datasourceId", datasourceId);
+                }
+
                 flowJsonAddProperty(obj, "ecConfTemplateId", ecConfTemplateId);
                 flowJsonAddProperty(obj, "ecConfTemplateName", ecConfTemplateName);
                 break;