From 1da380ace342d6c69319c1bd76e77b748f9e5329 Mon Sep 17 00:00:00 2001
From: lanyuanxiaoyao <lanyuanxiaoyao@gmail.com>
Date: Sun, 2 Mar 2025 23:48:46 +0800
Subject: [PATCH] =?UTF-8?q?=E6=B5=8B=E8=AF=95=E5=B9=B6=E8=A1=8C?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../ai/analysis/AnalysisApplication.java      |  8 +++++++
 .../ai/analysis/flow/RunningFlow.java         | 21 +++++++++++++++++++
 src/main/resources/application.yml            |  3 +++
 src/main/resources/config/flow.xml            |  6 ++++++
 4 files changed, 38 insertions(+)
 create mode 100644 src/main/java/com/lanyuanxiaoyao/ai/analysis/flow/RunningFlow.java
 create mode 100644 src/main/resources/config/flow.xml

diff --git a/src/main/java/com/lanyuanxiaoyao/ai/analysis/AnalysisApplication.java b/src/main/java/com/lanyuanxiaoyao/ai/analysis/AnalysisApplication.java
index b22601d..ad12cf1 100644
--- a/src/main/java/com/lanyuanxiaoyao/ai/analysis/AnalysisApplication.java
+++ b/src/main/java/com/lanyuanxiaoyao/ai/analysis/AnalysisApplication.java
@@ -1,5 +1,8 @@
 package com.lanyuanxiaoyao.ai.analysis;
 
+import com.yomahub.liteflow.core.FlowExecutor;
+import com.yomahub.liteflow.flow.LiteflowResponse;
+import jakarta.annotation.Resource;
 import java.net.http.HttpClient;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.boot.ApplicationArguments;
@@ -18,8 +21,13 @@ public class AnalysisApplication implements ApplicationRunner {
     SpringApplication.run(AnalysisApplication.class, args);
   }
 
+  @Resource
+  private FlowExecutor flowExecutor;
+
   @Override
   public void run(ApplicationArguments args) {
+    LiteflowResponse response = flowExecutor.execute2Resp("chain_1");
+    log.info(String.valueOf(response.isSuccess()));
   }
 
   @Bean
diff --git a/src/main/java/com/lanyuanxiaoyao/ai/analysis/flow/RunningFlow.java b/src/main/java/com/lanyuanxiaoyao/ai/analysis/flow/RunningFlow.java
new file mode 100644
index 0000000..8bcbca6
--- /dev/null
+++ b/src/main/java/com/lanyuanxiaoyao/ai/analysis/flow/RunningFlow.java
@@ -0,0 +1,21 @@
+package com.lanyuanxiaoyao.ai.analysis.flow;
+
+import com.yomahub.liteflow.annotation.LiteflowComponent;
+import com.yomahub.liteflow.annotation.LiteflowMethod;
+import com.yomahub.liteflow.core.NodeComponent;
+import com.yomahub.liteflow.enums.LiteFlowMethodEnum;
+import lombok.extern.slf4j.Slf4j;
+
+@Slf4j
+@LiteflowComponent
+public class RunningFlow {
+  @LiteflowMethod(value = LiteFlowMethodEnum.PROCESS, nodeId = "A")
+  public void processA(NodeComponent bind){
+    log.info("Process A");
+  }
+
+  @LiteflowMethod(value = LiteFlowMethodEnum.PROCESS, nodeId = "B")
+  public void processB(NodeComponent bind){
+    log.info("Process B");
+  }
+}
diff --git a/src/main/resources/application.yml b/src/main/resources/application.yml
index 1aee99e..1857c2c 100644
--- a/src/main/resources/application.yml
+++ b/src/main/resources/application.yml
@@ -48,3 +48,6 @@ logging:
   level:
     #    root: debug
     org.springframework.ai: debug
+liteflow:
+  print-banner: false
+  rule-source: config/flow.xml
\ No newline at end of file
diff --git a/src/main/resources/config/flow.xml b/src/main/resources/config/flow.xml
new file mode 100644
index 0000000..7540f7f
--- /dev/null
+++ b/src/main/resources/config/flow.xml
@@ -0,0 +1,6 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<flow>
+    <chain name="chain_1">
+        SER(A,B)
+    </chain>
+</flow>
\ No newline at end of file