feat(studio): init studio dsl2saa (#2270)

Author: VLSMB

spring-ai-alibaba-studio/spring-ai-alibaba-studio-server/frontend/packages/main/src/pages/App/Workflow/index.tsx

@@ -70,6 +70,7 @@ import {
 } from './types';
 import { getMCPNodeInputParams } from './utils';
 import { transformToBizData, transformToFlowData } from './utils/transform';
+import { convertDifyToSpringAI } from '@/services/difyConverter';
 
 interface IProps {
   onSave: (data: IBizFlowData) => void;
@@ -81,12 +82,13 @@ interface IProps {
 interface IFlowBaseProps extends Omit<IProps, 'setActiveTab' | 'onSave'> {
   actionLoading: boolean;
   handlePublish: () => void;
+  handleExportSAA: () => void;
 }
 
 const lang = $i18n.getCurrentLanguage();
 
 export const FlowBase = memo((props: IFlowBaseProps) => {
-  const { actionLoading, init, appDetail, handlePublish } = props;
+  const { actionLoading, init, appDetail, handlePublish, handleExportSAA } = props;
   const setShowTest = useWorkflowAppStore((state) => state.setShowTest);
   const { initDebug } = useInitDebug();
   const portal = useInnerLayout();
@@ -191,6 +193,13 @@ export const FlowBase = memo((props: IFlowBaseProps) => {
                 </Button>
                 <CheckListBtn />
               </Space.Compact>
+              {/* 新增“导出SAA工程代码”按钮 */}
+              <Button
+                disabled={actionLoading}
+                onClick={handleExportSAA}
+              >
+                导出SAA工程代码
+              </Button>
               <Button
                 disabled={actionLoading}
                 onClick={() => {
@@ -274,6 +283,55 @@ export const FlowEditor = memo((props: IProps) => {
       });
   }, []);
 
+  const handleExportSAA = useCallback(async () => {
+    if (!props.appDetail) return;
+
+    console.log(props.appDetail);
+
+    setActionLoading(true);
+    try {
+      // 准备请求参数
+      const params = {
+        dependencies: 'spring-ai-alibaba-graph,web,spring-ai-alibaba-starter-dashscope',
+        appMode: 'workflow',
+        dslDialectType: 'studio',
+        type: 'maven-project',
+        language: 'java',
+        bootVersion: '3.5.0',
+        baseDir: 'demo',
+        groupId: 'com.example',
+        artifactId: 'demo',
+        name: 'demo',
+        description: 'Demo project for Spring Boot',
+        packageName: 'com.example.demo',
+        packaging: 'jar',
+        javaVersion: '17',
+        dsl: JSON.stringify(props.appDetail),
+      };
+
+      // 调用转换服务
+      const response = await convertDifyToSpringAI(params);
+
+      // 处理 zip 文件下载
+      const blob = response.data;
+      const url = window.URL.createObjectURL(blob);
+      const link = document.createElement('a');
+      link.href = url;
+      link.download = 'spring-ai-alibaba-demo.zip';
+      document.body.appendChild(link);
+      link.click();
+      document.body.removeChild(link);
+      window.URL.revokeObjectURL(url);
+
+      message.success('转换成功！项目文件已开始下载');
+    } catch (error) {
+      console.error('转换失败:', error);
+      message.error(`转换失败：${error.message || '请重试'}`);
+    } finally {
+      setActionLoading(false); // 重置加载状态
+    }
+  }, [props.appDetail]);
+
   const handleSave = useCallback(
     async (data: { nodes: IWorkFlowNode[]; edges: Edge[] }) => {
       setActionLoading(true);
@@ -413,6 +471,7 @@ export const FlowEditor = memo((props: IProps) => {
           appDetail={props.appDetail}
           actionLoading={actionLoading}
           handlePublish={handlePublish}
+          handleExportSAA={handleExportSAA}
           init={props.init}
         />
 

spring-ai-alibaba-studio/spring-ai-alibaba-studio-server/frontend/packages/main/src/pages/Dify/index.tsx

@@ -63,6 +63,7 @@ const DifyConverter: React.FC = () => {
       const params = {
         dependencies: 'spring-ai-alibaba-graph,web,spring-ai-alibaba-starter-dashscope',
         appMode: 'workflow',
+        dslDialectType: 'dify',
         type: 'maven-project',
         language: 'java',
         bootVersion: '3.5.0',

spring-ai-alibaba-studio/spring-ai-alibaba-studio-server/frontend/packages/main/src/services/difyConverter.ts

@@ -3,6 +3,7 @@ import { request } from '@/request';
 export interface DifyConvertParams {
   dependencies: string;
   appMode: string;
+  dslDialectType: string;
   type: string;
   language: string;
   bootVersion: string;

spring-ai-alibaba-studio/spring-ai-alibaba-studio-server/spring-ai-alibaba-studio-server-admin/src/main/java/com/alibaba/cloud/ai/studio/admin/generator/model/workflow/Edge.java

@@ -33,6 +33,9 @@ public class Edge {
 
 	private Integer zIndex = 0;
 
+	// Temp field
+	private boolean isDify = true;
+
 	public String getId() {
 		return id;
 	}
@@ -96,4 +99,13 @@ public Edge setzIndex(Integer zIndex) {
 		return this;
 	}
 
+	public boolean isDify() {
+		return isDify;
+	}
+
+	public Edge setDify(boolean isDify) {
+		this.isDify = isDify;
+		return this;
+	}
+
 }

spring-ai-alibaba-studio/spring-ai-alibaba-studio-server/spring-ai-alibaba-studio-server-admin/src/main/java/com/alibaba/cloud/ai/studio/admin/generator/model/workflow/NodeType.java

@@ -20,55 +20,58 @@
 
 public enum NodeType {
 
-	START("start", "start"),
+	START("start", "start", "Start"),
 
-	END("end", "end"),
+	END("end", "end", "End"),
 
-	ANSWER("answer", "answer"),
+	ANSWER("answer", "answer", "UNSUPPORTED"),
 
-	AGENT("agent", "agent"),
+	AGENT("agent", "agent", "UNSUPPORTED"),
 
-	LLM("llm", "llm"),
+	LLM("llm", "llm", "UNSUPPORTED"),
 
-	CODE("code", "code"),
+	CODE("code", "code", "UNSUPPORTED"),
 
-	RETRIEVER("retriever", "knowledge-retrieval"),
+	RETRIEVER("retriever", "knowledge-retrieval", "UNSUPPORTED"),
 
-	AGGREGATOR("aggregator", "variable-aggregator"),
+	AGGREGATOR("aggregator", "variable-aggregator", "UNSUPPORTED"),
 
-	HUMAN("human", "unsupported"),
+	HUMAN("human", "unsupported", "UNSUPPORTED"),
 
-	BRANCH("branch", "if-else"),
+	BRANCH("branch", "if-else", "UNSUPPORTED"),
 
-	DOC_EXTRACTOR("document-extractor", "document-extractor"),
+	DOC_EXTRACTOR("document-extractor", "document-extractor", "UNSUPPORTED"),
 
-	QUESTION_CLASSIFIER("question-classifier", "question-classifier"),
+	QUESTION_CLASSIFIER("question-classifier", "question-classifier", "UNSUPPORTED"),
 
-	HTTP("http", "http-request"),
+	HTTP("http", "http-request", "UNSUPPORTED"),
 
-	LIST_OPERATOR("list-operator", "list-operator"),
+	LIST_OPERATOR("list-operator", "list-operator", "UNSUPPORTED"),
 
-	PARAMETER_PARSING("parameter-parsing", "parameter-extractor"),
+	PARAMETER_PARSING("parameter-parsing", "parameter-extractor", "UNSUPPORTED"),
 
-	TOOL("tool", "tool"),
+	TOOL("tool", "tool", "UNSUPPORTED"),
 
-	MCP("mcp", "unsupported"),
+	MCP("mcp", "unsupported", "UNSUPPORTED"),
 
-	TEMPLATE_TRANSFORM("template-transform", "template-transform"),
+	TEMPLATE_TRANSFORM("template-transform", "template-transform", "UNSUPPORTED"),
 
-	ITERATION("iteration", "iteration"),
+	ITERATION("iteration", "iteration", "UNSUPPORTED"),
 
-	DIFY_ITERATION_START("__empty__", "iteration-start"),
+	DIFY_ITERATION_START("__empty__", "iteration-start", "UNSUPPORTED"),
 
-	ASSIGNER("assigner", "assigner");
+	ASSIGNER("assigner", "assigner", "UNSUPPORTED");
 
 	private final String value;
 
 	private final String difyValue;
 
-	NodeType(String value, String difyValue) {
+	private final String studioValue;
+
+	NodeType(String value, String difyValue, String studioValue) {
 		this.value = value;
 		this.difyValue = difyValue;
+		this.studioValue = studioValue;
 	}
 
 	public String value() {
@@ -79,6 +82,10 @@ public String difyValue() {
 		return this.difyValue;
 	}
 
+	public String studioValue() {
+		return this.studioValue;
+	}
+
 	public static Optional<NodeType> fromValue(String value) {
 		return Arrays.stream(NodeType.values()).filter(nodeType -> nodeType.value.equals(value)).findFirst();
 	}
@@ -87,4 +94,10 @@ public static Optional<NodeType> fromDifyValue(String difyValue) {
 		return Arrays.stream(NodeType.values()).filter(nodeType -> nodeType.difyValue.equals(difyValue)).findFirst();
 	}
 
+	public static Optional<NodeType> fromStudioValue(String studioValue) {
+		return Arrays.stream(NodeType.values())
+			.filter(nodeType -> nodeType.studioValue.equals(studioValue))
+			.findFirst();
+	}
+
 }

spring-ai-alibaba-studio/spring-ai-alibaba-studio-server/spring-ai-alibaba-studio-server-admin/src/main/java/com/alibaba/cloud/ai/studio/admin/generator/model/workflow/nodedata/EndNodeData.java

@@ -28,6 +28,12 @@ public static Variable getDefaultOutputSchema() {
 		return new Variable("output", VariableType.ARRAY_STRING.value());
 	}
 
+	private String outputKey;
+
+	private String outputType;
+
+	private String textTemplate;
+
 	public String getOutputKey() {
 		return outputKey;
 	}
@@ -37,7 +43,21 @@ public EndNodeData setOutputKey(String outputKey) {
 		return this;
 	}
 
-	private String outputKey;
+	public String getOutputType() {
+		return outputType;
+	}
+
+	public void setOutputType(String outputType) {
+		this.outputType = outputType;
+	}
+
+	public String getTextTemplate() {
+		return textTemplate;
+	}
+
+	public void setTextTemplate(String textTemplate) {
+		this.textTemplate = textTemplate;
+	}
 
 	public EndNodeData() {
 	}

spring-ai-alibaba-studio/spring-ai-alibaba-studio-server/spring-ai-alibaba-studio-server-admin/src/main/java/com/alibaba/cloud/ai/studio/admin/generator/model/workflow/nodedata/StartNodeData.java

@@ -25,8 +25,6 @@ public class StartNodeData extends NodeData {
 
 	private List<StartInput> startInputs;
 
-	private String outputKey;
-
 	public StartNodeData() {
 	}
 
@@ -43,15 +41,6 @@ public StartNodeData setStartInputs(List<StartInput> startInputs) {
 		return this;
 	}
 
-	public String getOutputKey() {
-		return outputKey;
-	}
-
-	public StartNodeData setOutputKey(String outputKey) {
-		this.outputKey = outputKey;
-		return this;
-	}
-
 	public static class StartInput {
 
 		private String label;

spring-ai-alibaba-studio/spring-ai-alibaba-studio-server/spring-ai-alibaba-studio-server-admin/src/main/java/com/alibaba/cloud/ai/studio/admin/generator/service/dsl/AbstractDSLAdapter.java

@@ -15,13 +15,16 @@
  */
 package com.alibaba.cloud.ai.studio.admin.generator.service.dsl;
 
+import java.util.List;
 import java.util.Map;
 import java.util.stream.Collectors;
 import java.util.stream.Stream;
 
 import com.alibaba.cloud.ai.studio.admin.generator.model.App;
 import com.alibaba.cloud.ai.studio.admin.generator.model.AppMetadata;
 import com.alibaba.cloud.ai.studio.admin.generator.model.chatbot.ChatBot;
+import com.alibaba.cloud.ai.studio.admin.generator.model.workflow.NodeData;
+import com.alibaba.cloud.ai.studio.admin.generator.model.workflow.NodeType;
 import com.alibaba.cloud.ai.studio.admin.generator.model.workflow.Workflow;
 
 /**
@@ -31,6 +34,23 @@ public abstract class AbstractDSLAdapter implements DSLAdapter {
 
 	private static final org.slf4j.Logger log = org.slf4j.LoggerFactory.getLogger(AbstractDSLAdapter.class);
 
+	protected final List<NodeDataConverter<? extends NodeData>> nodeDataConverters;
+
+	protected final Serializer serializer;
+
+	protected AbstractDSLAdapter(List<NodeDataConverter<? extends NodeData>> nodeDataConverters,
+			Serializer serializer) {
+		this.nodeDataConverters = nodeDataConverters;
+		this.serializer = serializer;
+	}
+
+	protected NodeDataConverter<? extends NodeData> getNodeDataConverter(NodeType nodeType) {
+		return nodeDataConverters.stream()
+			.filter(converter -> converter.supportNodeType(nodeType))
+			.findFirst()
+			.orElseThrow(() -> new IllegalArgumentException("invalid node type " + nodeType));
+	}
+
 	@Override
 	public App importDSL(String dsl) {
 		log.info("dsl importing: {}", dsl);

spring-ai-alibaba-studio/spring-ai-alibaba-studio-server/spring-ai-alibaba-studio-server-admin/src/main/java/com/alibaba/cloud/ai/studio/admin/generator/service/dsl/DSLDialectType.java

@@ -22,6 +22,8 @@ public enum DSLDialectType {
 
 	DIFY("dify", ".yml"),
 
+	STUDIO("studio", ".json"),
+
 	CUSTOM("custom", ".yml");
 
 	private final String value;
@@ -37,7 +39,7 @@ public String fileExtension() {
 	}
 
 	public static Optional<DSLDialectType> fromValue(String value) {
-		return Arrays.stream(DSLDialectType.values()).filter(t -> t.value.equals(value)).findFirst();
+		return Arrays.stream(DSLDialectType.values()).filter(t -> t.value.equalsIgnoreCase(value)).findFirst();
 	}
 
 	DSLDialectType(String value, String fileExtension) {