From 07e90c372537375914a790c995ed9324f01c49f2 Mon Sep 17 00:00:00 2001 From: "everywhere.z" Date: Mon, 14 Apr 2025 11:00:17 +0800 Subject: [PATCH] =?UTF-8?q?feature=20#IBW9PC=20=E4=B8=8A=E4=B8=8B=E6=96=87?= =?UTF-8?q?=E8=A1=A8=E8=BE=BE=E5=BC=8F=E6=90=9C=E7=B4=A2&=E8=AE=BE?= =?UTF-8?q?=E7=BD=AE=EF=BC=8C=E6=91=86=E8=84=B1=E5=AF=B9=E4=B8=8A=E4=B8=8B?= =?UTF-8?q?=E6=96=87=E7=9A=84=E4=BE=9D=E8=B5=96?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../yomahub/liteflow/slot/DefaultContext.java | 3 +++ .../SearchContextSpringbootTest.java | 12 ++++++++++ .../test/searchContext/cmp/A6Cmp.java | 22 +++++++++++++++++++ .../src/test/resources/searchContext/flow.xml | 4 ++++ 4 files changed, 41 insertions(+) create mode 100644 liteflow-testcase-el/liteflow-testcase-el-springboot/src/test/java/com/yomahub/liteflow/test/searchContext/cmp/A6Cmp.java diff --git a/liteflow-core/src/main/java/com/yomahub/liteflow/slot/DefaultContext.java b/liteflow-core/src/main/java/com/yomahub/liteflow/slot/DefaultContext.java index 857394eaf..1e4b00352 100644 --- a/liteflow-core/src/main/java/com/yomahub/liteflow/slot/DefaultContext.java +++ b/liteflow-core/src/main/java/com/yomahub/liteflow/slot/DefaultContext.java @@ -34,4 +34,7 @@ public class DefaultContext { putDataMap(key, t); } + public ConcurrentHashMap getDataMap() { + return dataMap; + } } diff --git a/liteflow-testcase-el/liteflow-testcase-el-springboot/src/test/java/com/yomahub/liteflow/test/searchContext/SearchContextSpringbootTest.java b/liteflow-testcase-el/liteflow-testcase-el-springboot/src/test/java/com/yomahub/liteflow/test/searchContext/SearchContextSpringbootTest.java index ad84cb12d..bfbd87514 100644 --- a/liteflow-testcase-el/liteflow-testcase-el-springboot/src/test/java/com/yomahub/liteflow/test/searchContext/SearchContextSpringbootTest.java +++ b/liteflow-testcase-el/liteflow-testcase-el-springboot/src/test/java/com/yomahub/liteflow/test/searchContext/SearchContextSpringbootTest.java @@ -97,4 +97,16 @@ public class SearchContextSpringbootTest extends BaseTest { Assertions.assertEquals("test info", context.getData("test")); } + // 测试获取DefaultContext + @Test + public void testSearchContext6() throws Exception { + DefaultContext context = new DefaultContext(); + context.setData("k1", "v1"); + + LiteflowResponse response = flowExecutor.execute2Resp("chain6", "arg", context); + Assertions.assertTrue(response.isSuccess()); + context = response.getContextBean(DefaultContext.class); + Assertions.assertEquals("v1", context.getData("test")); + } + } diff --git a/liteflow-testcase-el/liteflow-testcase-el-springboot/src/test/java/com/yomahub/liteflow/test/searchContext/cmp/A6Cmp.java b/liteflow-testcase-el/liteflow-testcase-el-springboot/src/test/java/com/yomahub/liteflow/test/searchContext/cmp/A6Cmp.java new file mode 100644 index 000000000..bbabeba64 --- /dev/null +++ b/liteflow-testcase-el/liteflow-testcase-el-springboot/src/test/java/com/yomahub/liteflow/test/searchContext/cmp/A6Cmp.java @@ -0,0 +1,22 @@ +/** + *

Title: liteflow

+ *

Description: 轻量级的组件式流程框架

+ * @author Bryan.Zhang + * @email weenyc31@163.com + * @Date 2020/4/1 + */ +package com.yomahub.liteflow.test.searchContext.cmp; + +import com.yomahub.liteflow.core.NodeComponent; +import org.springframework.stereotype.Component; + +@Component("a6") +public class A6Cmp extends NodeComponent { + + @Override + public void process() { + String str = this.getContextValue("dataMap.k1"); + this.setContextValue("setData", "test", str); + + } +} diff --git a/liteflow-testcase-el/liteflow-testcase-el-springboot/src/test/resources/searchContext/flow.xml b/liteflow-testcase-el/liteflow-testcase-el-springboot/src/test/resources/searchContext/flow.xml index 8ff81a09c..db07b7da1 100644 --- a/liteflow-testcase-el/liteflow-testcase-el-springboot/src/test/resources/searchContext/flow.xml +++ b/liteflow-testcase-el/liteflow-testcase-el-springboot/src/test/resources/searchContext/flow.xml @@ -20,4 +20,8 @@ THEN(a5); + + + THEN(a6); + \ No newline at end of file