KingChan
/
liteFlow
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

feature #I9H6GN 完善测试用例

This commit is contained in:
Dale Lee 2024-05-02 22:25:50 +08:00
parent 33f05eb7cc
commit c3a64bd0f4
60 changed files with 1610 additions and 163 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

93
liteflow-testcase-el/liteflow-testcase-el-script-kotlin-springboot/src/test/java/com/yomahub/liteflow/test/script/kotlin/T2.java
View File

@ -1,93 +0,0 @@
package com.yomahub.liteflow.test.script.kotlin;
import com.yomahub.liteflow.slot.DefaultContext;
import org.junit.jupiter.api.Test;
import javax.script.Bindings;
import javax.script.Compilable;
import javax.script.CompiledScript;
import javax.script.ScriptEngine;
import javax.script.ScriptEngineManager;
import javax.script.ScriptException;
import javax.script.SimpleBindings;
public class T2 {
@Test
public void test1() throws ScriptException {
// 初始化 ScriptEngineManager 和 Kotlin 脚本引擎
ScriptEngineManager manager = new ScriptEngineManager();
ScriptEngine engine = manager.getEngineByName("kotlin");
if (engine == null) {
throw new IllegalStateException("Kotlin script engine not found");
}
// 假设我们有以下Kotlin脚本，它期望一个名为'message'的外部参数
String script = "fun greet(name: String) {\n" +
" println(\"Hello, $name!\")\n" +
" }\n" +
" println(bindings[\"message\"])";
// 编译脚本为CompiledScript对象
Compilable compilable = (Compilable) engine;
CompiledScript compiledScript = compilable.compile(script);
// 准备脚本上下文，用于传递外部参数
Bindings bindings = engine.createBindings();
// 设置外部参数
bindings.put("message", "User");
// 使用相同的上下文多次执行已编译的脚本
for (int i = 0; i < 2; i++) {
compiledScript.eval(bindings);
}
// engine.put("message","User");
// engine.eval(script);
//engine.eval(script,bindings);
}
@Test
public void test2() throws ScriptException {
ScriptEngineManager manager = new ScriptEngineManager();
ScriptEngine engine = manager.getEngineByName("kotlin");
String script = "" +
"var defaultContext = bindings[\"defaultContext\"]\n" +
"println(defaultContext.getData(\"key\"))";
// 编译脚本为CompiledScript对象
Compilable compilable = (Compilable) engine;
CompiledScript compiledScript = compilable.compile(script);
// 准备脚本上下文，用于传递外部参数
Bindings bindings = new SimpleBindings();
DefaultContext context = new DefaultContext();
context.setData("key", "value");
// 设置外部参数
bindings.put("defaultContext", context);
compiledScript.eval(bindings);
}
@Test
public void test3() throws ScriptException {
ScriptEngineManager manager = new ScriptEngineManager();
ScriptEngine engine = manager.getEngineByName("kotlin");
String script =
"fun getNum() = 15\n" +
"getNum()";
// 编译脚本为CompiledScript对象
Compilable compilable = (Compilable) engine;
CompiledScript compiledScript = compilable.compile(script);
// 准备脚本上下文，用于传递外部参数
// Bindings bindings = new SimpleBindings();
// DefaultContext context = new DefaultContext();
// context.setData("key", "value");
// // 设置外部参数
// bindings.put("defaultContext", context);
/* Object res = compiledScript.eval();
System.out.println(res);*/
Object eval = engine.eval(script);
System.out.println(eval);
}
}

49
liteflow-testcase-el/liteflow-testcase-el-script-kotlin-springboot/src/test/java/com/yomahub/liteflow/test/script/kotlin/TestKotlin.java
View File

@ -1,49 +0,0 @@
package com.yomahub.liteflow.test.script.kotlin;
import com.yomahub.liteflow.enums.ScriptTypeEnum;
import javax.script.Compilable;
import javax.script.CompiledScript;
import javax.script.ScriptEngine;
import javax.script.ScriptEngineManager;
import javax.script.ScriptException;
public class TestKotlin {
public static void main(String[] args) throws ScriptException, NoSuchMethodException {
// 获取脚本引擎管理器
ScriptEngineManager manager = new ScriptEngineManager();
// 获取Kotlin脚本引擎
ScriptEngine engine = manager.getEngineByName(ScriptTypeEnum.KOTLIN.getEngineName()); // ".kts" 是Kotlin脚本文件的扩展名
// 检查是否找到了Kotlin脚本引擎
if (engine == null) {
System.out.println("No Kotlin script engine found.");
return;
}
System.out.println(engine instanceof Compilable);
// 定义一个Kotlin脚本
String script = "println(\"Hello, Kotlin JSR 223!\")";
Compilable compilable = (Compilable) engine;
CompiledScript compile = compilable.compile(script);
compile.eval();
// 编译并执行脚本
engine.eval(script);
// 如果ScriptEngine也实现了Invocable接口，我们可以调用脚本中的函数
// if (engine instanceof Invocable) {
// Invocable inv = (Invocable) engine;
//
// // 调用脚本中的greet函数
// String greeting = (String) inv.invokeFunction("greet", "World");
// System.out.println(greeting); // 输出: Hello, World!
// } else {
// System.out.println("The script engine does not support Invocable interface.");
// }
}
}

36
liteflow-testcase-el/liteflow-testcase-el-script-kotlin-springboot/src/test/java/com/yomahub/liteflow/test/script/kotlin/cmpdata/LiteFlowCmpDataKotlinScriptELTest.java Normal file
View File

@ -0,0 +1,36 @@
package com.yomahub.liteflow.test.script.kotlin.cmpdata;
import com.yomahub.liteflow.core.FlowExecutor;
import com.yomahub.liteflow.flow.LiteflowResponse;
import com.yomahub.liteflow.slot.DefaultContext;
import com.yomahub.liteflow.test.script.BaseTest;
import org.junit.jupiter.api.Assertions;
import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.extension.ExtendWith;
import org.springframework.boot.autoconfigure.EnableAutoConfiguration;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.context.annotation.ComponentScan;
import org.springframework.test.context.TestPropertySource;
import org.springframework.test.context.junit.jupiter.SpringExtension;
import javax.annotation.Resource;
@ExtendWith(SpringExtension.class)
@TestPropertySource(value = "classpath:/cmpdata/application.properties")
@SpringBootTest(classes = LiteFlowCmpDataKotlinScriptELTest.class)
@EnableAutoConfiguration
@ComponentScan({ "com.yomahub.liteflow.test.script.kotlin.cmpdata.cmp" })
public class LiteFlowCmpDataKotlinScriptELTest extends BaseTest {
@Resource
private FlowExecutor flowExecutor;
@Test
public void testCmpData1() throws Exception {
LiteflowResponse response = flowExecutor.execute2Resp("chain1", "arg");
DefaultContext context = response.getFirstContextBean();
Assertions.assertTrue(response.isSuccess());
Assertions.assertEquals("1995-10-01", context.getData("s1"));
}
}

22
liteflow-testcase-el/liteflow-testcase-el-script-kotlin-springboot/src/test/java/com/yomahub/liteflow/test/script/kotlin/cmpdata/cmp/ACmp.java Normal file
View File

@ -0,0 +1,22 @@
/**
* <p>Title: liteflow</p>
* <p>Description: 轻量级的组件式流程框架</p>
* @author Bryan.Zhang
* @email weenyc31@163.com
* @Date 2020/4/1
*/
package com.yomahub.liteflow.test.script.kotlin.cmpdata.cmp;
import com.yomahub.liteflow.core.NodeComponent;
import org.springframework.stereotype.Component;
@Component("a")
public class ACmp extends NodeComponent {
@Override
public void process() {
System.out.println(this.getCmpData(String.class));
System.out.println("ACmp executed!");
}
}

51
liteflow-testcase-el/liteflow-testcase-el-script-kotlin-springboot/src/test/java/com/yomahub/liteflow/test/script/kotlin/common/LiteFlowKotlinScriptCommonELTest.java
View File

@ -15,6 +15,12 @@ import org.springframework.test.context.junit.jupiter.SpringExtension;
import javax.annotation.Resource;
/**
* Kotlin 脚本测试
*
* @author DaleLee
*/
@ExtendWith(SpringExtension.class)
@TestPropertySource(value = "classpath:/common/application.properties")
@SpringBootTest(classes = LiteFlowKotlinScriptCommonELTest.class)
@ -26,43 +32,60 @@ public class LiteFlowKotlinScriptCommonELTest extends BaseTest {
private FlowExecutor flowExecutor;
@Test
public void testCommon1() {
LiteflowResponse response = flowExecutor.execute2Resp("chain1", "arg");
public void testCommonScript1() {
LiteflowResponse response = flowExecutor.execute2Resp("testCommonScript1", "arg");
Assertions.assertTrue(response.isSuccess());
DefaultContext context = response.getFirstContextBean();
Assertions.assertEquals(Integer.valueOf(5), context.getData("s1"));
}
@Test
public void testFor1() {
public void testForScript1() {
DefaultContext context = new DefaultContext();
context.setData("k1", 1);
context.setData("k2", 2);
LiteflowResponse response = flowExecutor.execute2Resp("chain2", "arg", context);
LiteflowResponse response = flowExecutor.execute2Resp("testForScript1", "arg", context);
Assertions.assertTrue(response.isSuccess());
Assertions.assertEquals("s2==>a==>a==>a",response.getExecuteStepStr());
Assertions.assertEquals("s2==>a==>a==>a", response.getExecuteStepStr());
}
@Test
public void testIf1() {
LiteflowResponse response = flowExecutor.execute2Resp("chain3", "arg");
public void testBooleanScript1() {
LiteflowResponse response = flowExecutor.execute2Resp("testBooleanScript1", "arg");
Assertions.assertTrue(response.isSuccess());
Assertions.assertEquals("s3==>b",response.getExecuteStepStr());
Assertions.assertEquals("s3==>b", response.getExecuteStepStr());
}
@Test
public void testIf2() {
LiteflowResponse response = flowExecutor.execute2Resp("chain4", "arg");
public void testBooleanScript2() {
LiteflowResponse response = flowExecutor.execute2Resp("testBooleanScript2", "arg");
Assertions.assertTrue(response.isSuccess());
Assertions.assertEquals("s4",response.getExecuteStepStr());
Assertions.assertEquals("s4", response.getExecuteStepStr());
}
@Test
public void testSwitch1() {
public void testBooleanScript3() {
DefaultContext context = new DefaultContext();
context.setData("count", 2);
LiteflowResponse response = flowExecutor.execute2Resp("testBooleanScript3", "arg", context);
Assertions.assertTrue(response.isSuccess());
Assertions.assertEquals("s3==>b==>s6==>s3==>b==>s6==>s3==>b==>s6",response.getExecuteStepStr());
}
@Test
public void testSwitchScript1() {
DefaultContext context = new DefaultContext();
context.setData("id", "c");
LiteflowResponse response = flowExecutor.execute2Resp("chain5", "arg", context);
LiteflowResponse response = flowExecutor.execute2Resp("testSwitchScript1", "arg", context);
Assertions.assertTrue(response.isSuccess());
Assertions.assertEquals("s5==>c",response.getExecuteStepStr());
Assertions.assertEquals("s5==>c", response.getExecuteStepStr());
}
@Test
public void testFileScript1() {
LiteflowResponse response = flowExecutor.execute2Resp("testFileScript1", "arg");
Assertions.assertTrue(response.isSuccess());
DefaultContext context = response.getFirstContextBean();
Assertions.assertEquals(Integer.valueOf(6), context.getData("s7"));
}
}

57
liteflow-testcase-el/liteflow-testcase-el-script-kotlin-springboot/src/test/java/com/yomahub/liteflow/test/script/kotlin/contextbean/LiteFlowScriptContextbeanKotlinELTest.java Normal file
View File

@ -0,0 +1,57 @@
package com.yomahub.liteflow.test.script.kotlin.contextbean;
import com.yomahub.liteflow.core.FlowExecutor;
import com.yomahub.liteflow.flow.LiteflowResponse;
import com.yomahub.liteflow.test.script.BaseTest;
import com.yomahub.liteflow.test.script.kotlin.contextbean.bean.CheckContext;
import com.yomahub.liteflow.test.script.kotlin.contextbean.bean.Order2Context;
import com.yomahub.liteflow.test.script.kotlin.contextbean.bean.OrderContext;
import org.junit.jupiter.api.Assertions;
import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.extension.ExtendWith;
import org.springframework.boot.autoconfigure.EnableAutoConfiguration;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.context.annotation.ComponentScan;
import org.springframework.test.context.TestPropertySource;
import org.springframework.test.context.junit.jupiter.SpringExtension;
import javax.annotation.Resource;
@ExtendWith(SpringExtension.class)
@TestPropertySource(value = "classpath:/contextbean/application.properties")
@SpringBootTest(classes = LiteFlowScriptContextbeanKotlinELTest.class)
@EnableAutoConfiguration
@ComponentScan({ "com.yomahub.liteflow.test.script.kotlin.contextbean.cmp",
"com.yomahub.liteflow.test.script.kotlin.contextbean.bean" })
public class LiteFlowScriptContextbeanKotlinELTest extends BaseTest {
@Resource
private FlowExecutor flowExecutor;
@Test
public void testContextBean1() {
LiteflowResponse response = flowExecutor.execute2Resp("chain1", "arg", OrderContext.class, CheckContext.class,
Order2Context.class);
Assertions.assertTrue(response.isSuccess());
OrderContext orderContext = response.getContextBean(OrderContext.class);
CheckContext checkContext = response.getContextBean(CheckContext.class);
Order2Context order2Context = response.getContextBean(Order2Context.class);
Assertions.assertEquals("order1", orderContext.getOrderNo());
Assertions.assertEquals("sign1", checkContext.getSign());
Assertions.assertEquals("order2", order2Context.getOrderNo());
}
@Test
public void testContextBean2() throws Exception {
OrderContext orderContext = new OrderContext();
orderContext.setOrderNo("order1");
CheckContext checkContext = new CheckContext();
checkContext.setSign("sign1");
Order2Context orderContext2 = new Order2Context();
orderContext2.setOrderNo("order2");
LiteflowResponse response = flowExecutor.execute2Resp("chain2", null, orderContext, checkContext,
orderContext2);
Assertions.assertTrue(response.isSuccess());
}
}

28
liteflow-testcase-el/liteflow-testcase-el-script-kotlin-springboot/src/test/java/com/yomahub/liteflow/test/script/kotlin/contextbean/bean/CheckContext.java Normal file
View File

@ -0,0 +1,28 @@
package com.yomahub.liteflow.test.script.kotlin.contextbean.bean;
import com.yomahub.liteflow.context.ContextBean;
@ContextBean
public class CheckContext {
private String sign;
private int randomId;
public String getSign() {
return sign;
}
public void setSign(String sign) {
this.sign = sign;
}
public int getRandomId() {
return randomId;
}
public void setRandomId(int randomId) {
this.randomId = randomId;
}
}

37
liteflow-testcase-el/liteflow-testcase-el-script-kotlin-springboot/src/test/java/com/yomahub/liteflow/test/script/kotlin/contextbean/bean/Order2Context.java Normal file
View File

@ -0,0 +1,37 @@
package com.yomahub.liteflow.test.script.kotlin.contextbean.bean;
import java.util.Date;
public class Order2Context {
private String orderNo;
private int orderType;
private Date createTime;
public String getOrderNo() {
return orderNo;
}
public void setOrderNo(String orderNo) {
this.orderNo = orderNo;
}
public int getOrderType() {
return orderType;
}
public void setOrderType(int orderType) {
this.orderType = orderType;
}
public Date getCreateTime() {
return createTime;
}
public void setCreateTime(Date createTime) {
this.createTime = createTime;
}
}

40
liteflow-testcase-el/liteflow-testcase-el-script-kotlin-springboot/src/test/java/com/yomahub/liteflow/test/script/kotlin/contextbean/bean/OrderContext.java Normal file
View File

@ -0,0 +1,40 @@
package com.yomahub.liteflow.test.script.kotlin.contextbean.bean;
import com.yomahub.liteflow.context.ContextBean;
import java.util.Date;
@ContextBean("order")
public class OrderContext {
private String orderNo;
private int orderType;
private Date createTime;
public String getOrderNo() {
return orderNo;
}
public void setOrderNo(String orderNo) {
this.orderNo = orderNo;
}
public int getOrderType() {
return orderType;
}
public void setOrderType(int orderType) {
this.orderType = orderType;
}
public Date getCreateTime() {
return createTime;
}
public void setCreateTime(Date createTime) {
this.createTime = createTime;
}
}

21
liteflow-testcase-el/liteflow-testcase-el-script-kotlin-springboot/src/test/java/com/yomahub/liteflow/test/script/kotlin/contextbean/cmp/ACmp.java Normal file
View File

@ -0,0 +1,21 @@
/**
* <p>Title: liteflow</p>
* <p>Description: 轻量级的组件式流程框架</p>
* @author Bryan.Zhang
* @email weenyc31@163.com
* @Date 2020/4/1
*/
package com.yomahub.liteflow.test.script.kotlin.contextbean.cmp;
import com.yomahub.liteflow.core.NodeComponent;
import org.springframework.stereotype.Component;
@Component("a")
public class ACmp extends NodeComponent {
@Override
public void process() {
System.out.println("ACmp executed!");
}
}

21
liteflow-testcase-el/liteflow-testcase-el-script-kotlin-springboot/src/test/java/com/yomahub/liteflow/test/script/kotlin/contextbean/cmp/BCmp.java Normal file
View File

@ -0,0 +1,21 @@
/**
* <p>Title: liteflow</p>
* <p>Description: 轻量级的组件式流程框架</p>
* @author Bryan.Zhang
* @email weenyc31@163.com
* @Date 2020/4/1
*/
package com.yomahub.liteflow.test.script.kotlin.contextbean.cmp;
import com.yomahub.liteflow.core.NodeComponent;
import org.springframework.stereotype.Component;
@Component("b")
public class BCmp extends NodeComponent {
@Override
public void process() {
System.out.println("BCmp executed!");
}
}

21
liteflow-testcase-el/liteflow-testcase-el-script-kotlin-springboot/src/test/java/com/yomahub/liteflow/test/script/kotlin/contextbean/cmp/CCmp.java Normal file
View File

@ -0,0 +1,21 @@
/**
* <p>Title: liteflow</p>
* <p>Description: 轻量级的组件式流程框架</p>
* @author Bryan.Zhang
* @email weenyc31@163.com
* @Date 2020/4/1
*/
package com.yomahub.liteflow.test.script.kotlin.contextbean.cmp;
import com.yomahub.liteflow.core.NodeComponent;
import org.springframework.stereotype.Component;
@Component("c")
public class CCmp extends NodeComponent {
@Override
public void process() {
System.out.println("CCmp executed!");
}
}

37
liteflow-testcase-el/liteflow-testcase-el-script-kotlin-springboot/src/test/java/com/yomahub/liteflow/test/script/kotlin/meta/LiteflowKotlinScriptMetaELTest.java Normal file
View File

@ -0,0 +1,37 @@
package com.yomahub.liteflow.test.script.kotlin.meta;
import com.yomahub.liteflow.core.FlowExecutor;
import com.yomahub.liteflow.flow.LiteflowResponse;
import com.yomahub.liteflow.slot.DefaultContext;
import com.yomahub.liteflow.test.script.BaseTest;
import org.junit.jupiter.api.Assertions;
import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.extension.ExtendWith;
import org.springframework.boot.autoconfigure.EnableAutoConfiguration;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.context.annotation.ComponentScan;
import org.springframework.test.context.TestPropertySource;
import org.springframework.test.context.junit.jupiter.SpringExtension;
import javax.annotation.Resource;
@ExtendWith(SpringExtension.class)
@TestPropertySource(value = "classpath:/meta/application.properties")
@SpringBootTest(classes = LiteflowKotlinScriptMetaELTest.class)
@EnableAutoConfiguration
@ComponentScan({"com.yomahub.liteflow.test.script.kotlin.meta.cmp"})
public class LiteflowKotlinScriptMetaELTest extends BaseTest {
@Resource
private FlowExecutor flowExecutor;
@Test
public void testMeta() {
LiteflowResponse response = flowExecutor.execute2Resp("chain1", "arg");
DefaultContext context = response.getFirstContextBean();
Assertions.assertTrue(response.isSuccess());
Assertions.assertEquals("chain1", context.getData("currChainId"));
Assertions.assertEquals("arg", context.getData("requestData"));
Assertions.assertEquals("s1", context.getData("nodeId"));
}
}

21
liteflow-testcase-el/liteflow-testcase-el-script-kotlin-springboot/src/test/java/com/yomahub/liteflow/test/script/kotlin/meta/cmp/ACmp.java Normal file
View File

@ -0,0 +1,21 @@
/**
* <p>Title: liteflow</p>
* <p>Description: 轻量级的组件式流程框架</p>
* @author Bryan.Zhang
* @email weenyc31@163.com
* @Date 2020/4/1
*/
package com.yomahub.liteflow.test.script.kotlin.meta.cmp;
import com.yomahub.liteflow.annotation.LiteflowComponent;
import com.yomahub.liteflow.core.NodeComponent;
@LiteflowComponent("a")
public class ACmp extends NodeComponent {
@Override
public void process() {
System.out.println("ACmp executed!");
}
}

21
liteflow-testcase-el/liteflow-testcase-el-script-kotlin-springboot/src/test/java/com/yomahub/liteflow/test/script/kotlin/meta/cmp/BCmp.java Normal file
View File

@ -0,0 +1,21 @@
/**
* <p>Title: liteflow</p>
* <p>Description: 轻量级的组件式流程框架</p>
* @author Bryan.Zhang
* @email weenyc31@163.com
* @Date 2020/4/1
*/
package com.yomahub.liteflow.test.script.kotlin.meta.cmp;
import com.yomahub.liteflow.annotation.LiteflowComponent;
import com.yomahub.liteflow.core.NodeComponent;
@LiteflowComponent("b")
public class BCmp extends NodeComponent {
@Override
public void process() {
System.out.println("BCmp executed!");
}
}

21
liteflow-testcase-el/liteflow-testcase-el-script-kotlin-springboot/src/test/java/com/yomahub/liteflow/test/script/kotlin/meta/cmp/CCmp.java Normal file
View File

@ -0,0 +1,21 @@
/**
* <p>Title: liteflow</p>
* <p>Description: 轻量级的组件式流程框架</p>
* @author Bryan.Zhang
* @email weenyc31@163.com
* @Date 2020/4/1
*/
package com.yomahub.liteflow.test.script.kotlin.meta.cmp;
import com.yomahub.liteflow.annotation.LiteflowComponent;
import com.yomahub.liteflow.core.NodeComponent;
@LiteflowComponent("c")
public class CCmp extends NodeComponent {
@Override
public void process() {
System.out.println("CCmp executed!");
}
}

48
liteflow-testcase-el/liteflow-testcase-el-script-kotlin-springboot/src/test/java/com/yomahub/liteflow/test/script/kotlin/refresh/LiteflowKotlinScriptRefreshELTest.java Normal file
View File

@ -0,0 +1,48 @@
package com.yomahub.liteflow.test.script.kotlin.refresh;
import cn.hutool.core.io.resource.ResourceUtil;
import com.yomahub.liteflow.core.FlowExecutor;
import com.yomahub.liteflow.enums.FlowParserTypeEnum;
import com.yomahub.liteflow.flow.FlowBus;
import com.yomahub.liteflow.flow.LiteflowResponse;
import com.yomahub.liteflow.test.script.BaseTest;
import org.junit.jupiter.api.Assertions;
import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.extension.ExtendWith;
import org.springframework.boot.autoconfigure.EnableAutoConfiguration;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.context.annotation.ComponentScan;
import org.springframework.test.context.TestPropertySource;
import org.springframework.test.context.junit.jupiter.SpringExtension;
import javax.annotation.Resource;
@ExtendWith(SpringExtension.class)
@TestPropertySource(value = "classpath:/refresh/application.properties")
@SpringBootTest(classes = LiteflowKotlinScriptRefreshELTest.class)
@EnableAutoConfiguration
@ComponentScan({ "com.yomahub.liteflow.test.script.kotlin.refresh.cmp" })
public class LiteflowKotlinScriptRefreshELTest extends BaseTest {
@Resource
private FlowExecutor flowExecutor;
// 测试脚本的热重载
@Test
public void testRefresh1() throws Exception {
// 根据配置，加载的应该是flow.xml，执行原来的规则
LiteflowResponse responseOld = flowExecutor.execute2Resp("chain1", "arg");
Assertions.assertTrue(responseOld.isSuccess());
Assertions.assertEquals("d==>s1[选择脚本]==>a", responseOld.getExecuteStepStr());
// 更改规则，重新加载，更改的规则内容从flow_update.xml里读取，这里只是为了模拟下获取新的内容。不一定是从文件中读取
String newContent = ResourceUtil.readUtf8Str("classpath: /refresh/flow_update.xml");
// 进行刷新
FlowBus.refreshFlowMetaData(FlowParserTypeEnum.TYPE_EL_XML, newContent);
// 重新执行chain2这个链路，结果会变
LiteflowResponse responseNew = flowExecutor.execute2Resp("chain1", "arg");
Assertions.assertTrue(responseNew.isSuccess());
Assertions.assertEquals("d==>s1[选择脚本_改]==>b==>s2[普通脚本_新增]", responseNew.getExecuteStepStr());
}
}

21
liteflow-testcase-el/liteflow-testcase-el-script-kotlin-springboot/src/test/java/com/yomahub/liteflow/test/script/kotlin/refresh/cmp/ACmp.java Normal file
View File

@ -0,0 +1,21 @@
/**
* <p>Title: liteflow</p>
* <p>Description: 轻量级的组件式流程框架</p>
* @author Bryan.Zhang
* @email weenyc31@163.com
* @Date 2020/4/1
*/
package com.yomahub.liteflow.test.script.kotlin.refresh.cmp;
import com.yomahub.liteflow.annotation.LiteflowComponent;
import com.yomahub.liteflow.core.NodeComponent;
@LiteflowComponent("a")
public class ACmp extends NodeComponent {
@Override
public void process() {
System.out.println("ACmp executed!");
}
}

21
liteflow-testcase-el/liteflow-testcase-el-script-kotlin-springboot/src/test/java/com/yomahub/liteflow/test/script/kotlin/refresh/cmp/BCmp.java Normal file
View File

@ -0,0 +1,21 @@
/**
* <p>Title: liteflow</p>
* <p>Description: 轻量级的组件式流程框架</p>
* @author Bryan.Zhang
* @email weenyc31@163.com
* @Date 2020/4/1
*/
package com.yomahub.liteflow.test.script.kotlin.refresh.cmp;
import com.yomahub.liteflow.annotation.LiteflowComponent;
import com.yomahub.liteflow.core.NodeComponent;
@LiteflowComponent("b")
public class BCmp extends NodeComponent {
@Override
public void process() {
System.out.println("BCmp executed!");
}
}

21
liteflow-testcase-el/liteflow-testcase-el-script-kotlin-springboot/src/test/java/com/yomahub/liteflow/test/script/kotlin/refresh/cmp/CCmp.java Normal file
View File

@ -0,0 +1,21 @@
/**
* <p>Title: liteflow</p>
* <p>Description: 轻量级的组件式流程框架</p>
* @author Bryan.Zhang
* @email weenyc31@163.com
* @Date 2020/4/1
*/
package com.yomahub.liteflow.test.script.kotlin.refresh.cmp;
import com.yomahub.liteflow.annotation.LiteflowComponent;
import com.yomahub.liteflow.core.NodeComponent;
@LiteflowComponent("c")
public class CCmp extends NodeComponent {
@Override
public void process() {
System.out.println("CCmp executed!");
}
}

24
liteflow-testcase-el/liteflow-testcase-el-script-kotlin-springboot/src/test/java/com/yomahub/liteflow/test/script/kotlin/refresh/cmp/DCmp.java Normal file
View File

@ -0,0 +1,24 @@
/**
* <p>Title: liteflow</p>
* <p>Description: 轻量级的组件式流程框架</p>
* @author Bryan.Zhang
* @email weenyc31@163.com
* @Date 2020/4/1
*/
package com.yomahub.liteflow.test.script.kotlin.refresh.cmp;
import com.yomahub.liteflow.annotation.LiteflowComponent;
import com.yomahub.liteflow.core.NodeComponent;
import com.yomahub.liteflow.slot.DefaultContext;
@LiteflowComponent("d")
public class DCmp extends NodeComponent {
@Override
public void process() {
DefaultContext context = this.getFirstContextBean();
context.setData("count", 198);
System.out.println("DCmp executed!");
}
}

114
liteflow-testcase-el/liteflow-testcase-el-script-kotlin-springboot/src/test/java/com/yomahub/liteflow/test/script/kotlin/remove/LiteFlowKotlinScriptRemoveELTest.java Normal file
View File

@ -0,0 +1,114 @@
package com.yomahub.liteflow.test.script.kotlin.remove;
import com.yomahub.liteflow.builder.el.LiteFlowChainELBuilder;
import com.yomahub.liteflow.core.FlowExecutor;
import com.yomahub.liteflow.enums.ScriptTypeEnum;
import com.yomahub.liteflow.exception.ELParseException;
import com.yomahub.liteflow.flow.FlowBus;
import com.yomahub.liteflow.flow.LiteflowResponse;
import com.yomahub.liteflow.script.ScriptExecutor;
import com.yomahub.liteflow.script.ScriptExecutorFactory;
import com.yomahub.liteflow.script.exception.ScriptLoadException;
import com.yomahub.liteflow.slot.DefaultContext;
import com.yomahub.liteflow.test.script.BaseTest;
import org.junit.jupiter.api.Assertions;
import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.extension.ExtendWith;
import org.springframework.boot.autoconfigure.EnableAutoConfiguration;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.test.context.TestPropertySource;
import org.springframework.test.context.junit.jupiter.SpringExtension;
import javax.annotation.Resource;
import java.util.List;
/**
* 测试脚本的卸载和重载功能
*
* @author DaleLee
*/
@ExtendWith(SpringExtension.class)
@TestPropertySource(value = "classpath:/remove/application.properties")
@SpringBootTest(classes = LiteFlowKotlinScriptRemoveELTest.class)
@EnableAutoConfiguration
public class LiteFlowKotlinScriptRemoveELTest extends BaseTest {
@Resource
private FlowExecutor flowExecutor;
private ScriptExecutor scriptExecutor = ScriptExecutorFactory.loadInstance()
.getScriptExecutor(ScriptTypeEnum.KOTLIN.getDisplayName());
// 仅卸载脚本
@Test
public void testUnload() {
flowExecutor.reloadRule();
// 获取节点id
List<String> nodeIds = scriptExecutor.getNodeIds();
Assertions.assertEquals(2, nodeIds.size());
Assertions.assertTrue(nodeIds.contains("s1"));
Assertions.assertTrue(nodeIds.contains("s2"));
// 保证脚本可以正常运行
LiteflowResponse response = flowExecutor.execute2Resp("chain1", "arg");
Assertions.assertTrue(response.isSuccess());
DefaultContext context = response.getFirstContextBean();
Assertions.assertEquals(Integer.valueOf(6), context.getData("s1"));
// 卸载脚本
scriptExecutor.unLoad("s1");
response = flowExecutor.execute2Resp("chain1", "arg");
Assertions.assertFalse(response.isSuccess());
Assertions.assertEquals(ScriptLoadException.class, response.getCause().getClass());
Assertions.assertEquals("script for node[s1] is not loaded", response.getMessage());
// 脚本已卸载
Assertions.assertFalse(scriptExecutor.getNodeIds().contains("s1"));
}
// 卸载节点和脚本
@Test
public void testRemove() {
flowExecutor.reloadRule();
// 保证脚本可以正常运行
LiteflowResponse response = flowExecutor.execute2Resp("chain2", "arg");
Assertions.assertTrue(response.isSuccess());
DefaultContext context = response.getFirstContextBean();
Assertions.assertEquals(Integer.valueOf(5), context.getData("s2"));
// 卸载节点
FlowBus.unloadScriptNode("s2");
// 旧 chain 报脚本加载错误
response = flowExecutor.execute2Resp("chain2", "arg");
Assertions.assertEquals(ScriptLoadException.class, response.getCause().getClass());
// 新 chian 会找不到节点
Assertions.assertThrows(ELParseException.class,
() -> LiteFlowChainELBuilder.createChain()
.setChainId("chain3")
.setEL("THEN(s2)")
.build());
// 节点已卸载
Assertions.assertFalse(FlowBus.containNode("s2"));
// 脚本已卸载
Assertions.assertFalse(scriptExecutor.getNodeIds().contains("s2"));
}
// 重载脚本
@Test
public void testReloadScript() {
flowExecutor.reloadRule();
String script = "(bindings[\"defaultContext\"] as? DefaultContext)?.setData(\"s1\", \"abc\")";
FlowBus.reloadScript("s1", script);
LiteflowResponse response = flowExecutor.execute2Resp("chain1", "arg");
DefaultContext context = response.getFirstContextBean();
// 执行结果变更
Assertions.assertEquals("abc", context.getData("s1"));
// 脚本变更
Assertions.assertEquals(FlowBus.getNode("s1").getScript(), script);
}
}

103
liteflow-testcase-el/liteflow-testcase-el-script-kotlin-springboot/src/test/java/com/yomahub/liteflow/test/script/kotlin/scriptbean/LiteFlowScriptScriptbeanKotlinELTest.java Normal file
View File

@ -0,0 +1,103 @@
package com.yomahub.liteflow.test.script.kotlin.scriptbean;
import com.yomahub.liteflow.core.FlowExecutor;
import com.yomahub.liteflow.exception.ScriptBeanMethodInvokeException;
import com.yomahub.liteflow.flow.LiteflowResponse;
import com.yomahub.liteflow.script.ScriptBeanManager;
import com.yomahub.liteflow.slot.DefaultContext;
import com.yomahub.liteflow.test.script.BaseTest;
import org.junit.jupiter.api.Assertions;
import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.extension.ExtendWith;
import org.springframework.boot.autoconfigure.EnableAutoConfiguration;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.context.annotation.ComponentScan;
import org.springframework.test.context.TestPropertySource;
import org.springframework.test.context.junit.jupiter.SpringExtension;
import javax.annotation.Resource;
import java.util.HashMap;
import java.util.Map;
@ExtendWith(SpringExtension.class)
@TestPropertySource(value = "classpath:/scriptbean/application.properties")
@SpringBootTest(classes = LiteFlowScriptScriptbeanKotlinELTest.class)
@EnableAutoConfiguration
@ComponentScan({ "com.yomahub.liteflow.test.script.kotlin.scriptbean.cmp",
"com.yomahub.liteflow.test.script.kotlin.scriptbean.bean" })
public class LiteFlowScriptScriptbeanKotlinELTest extends BaseTest {
@Resource
private FlowExecutor flowExecutor;
@Test
public void testScriptBean1() throws Exception {
LiteflowResponse response = flowExecutor.execute2Resp("chain1", "arg");
Assertions.assertTrue(response.isSuccess());
DefaultContext context = response.getFirstContextBean();
Assertions.assertEquals("hello", context.getData("demo"));
}
@Test
public void testScriptBean2() throws Exception {
LiteflowResponse response = flowExecutor.execute2Resp("chain2", "arg");
Assertions.assertTrue(response.isSuccess());
DefaultContext context = response.getFirstContextBean();
Assertions.assertEquals("hello,kobe", context.getData("demo"));
}
// 测试scriptBean includeMethodName配置包含情况下
@Test
public void testScriptBean3() throws Exception {
LiteflowResponse response = flowExecutor.execute2Resp("chain3", "arg");
Assertions.assertTrue(response.isSuccess());
DefaultContext context = response.getFirstContextBean();
Assertions.assertEquals("hello,kobe", context.getData("demo"));
}
// 测试scriptBean includeMethodName配置不包含情况下
@Test
public void testScriptBean4() throws Exception {
LiteflowResponse response = flowExecutor.execute2Resp("chain4", "arg");
Assertions.assertFalse(response.isSuccess());
Assertions.assertEquals(ScriptBeanMethodInvokeException.class, response.getCause().getClass());
}
// 测试scriptBean excludeMethodName配置不包含情况下
@Test
public void testScriptBean5() throws Exception {
LiteflowResponse response = flowExecutor.execute2Resp("chain5", "arg");
Assertions.assertTrue(response.isSuccess());
DefaultContext context = response.getFirstContextBean();
Assertions.assertEquals("hello,kobe", context.getData("demo"));
}
// 测试scriptBean excludeMethodName配置包含情况下
@Test
public void testScriptBean6() throws Exception {
LiteflowResponse response = flowExecutor.execute2Resp("chain6", "arg");
Assertions.assertFalse(response.isSuccess());
Assertions.assertEquals(ScriptBeanMethodInvokeException.class, response.getCause().getClass());
}
// 测试在ScriptBeanManager里放入上下文，实现自定义脚本引用名称
@Test
public void testScriptBean7() throws Exception {
Map<String, String> map = new HashMap<>();
ScriptBeanManager.addScriptBean("abcCx", map);
LiteflowResponse response = flowExecutor.execute2Resp("chain7", "arg", map);
Assertions.assertTrue(response.isSuccess());
Map<String, String> context = response.getFirstContextBean();
Assertions.assertEquals("hello", context.get("demo"));
}
//测试用构造方法的方式注入bean的场景
@Test
public void testScriptBean8() throws Exception {
LiteflowResponse response = flowExecutor.execute2Resp("chain8", "arg");
Assertions.assertTrue(response.isSuccess());
DefaultContext context = response.getFirstContextBean();
Assertions.assertEquals("hello,jordan", context.getData("demo"));
}
}

23
liteflow-testcase-el/liteflow-testcase-el-script-kotlin-springboot/src/test/java/com/yomahub/liteflow/test/script/kotlin/scriptbean/bean/DemoBean1.java Normal file
View File

@ -0,0 +1,23 @@
package com.yomahub.liteflow.test.script.kotlin.scriptbean.bean;
import com.yomahub.liteflow.script.annotation.ScriptBean;
import org.springframework.stereotype.Component;
import javax.annotation.Resource;
@Component
@ScriptBean("demo")
public class DemoBean1 {
@Resource
private DemoBean2 demoBean2;
public String getDemoStr1() {
return "hello";
}
public String getDemoStr2(String name) {
return demoBean2.getDemoStr2(name);
}
}

12
liteflow-testcase-el/liteflow-testcase-el-script-kotlin-springboot/src/test/java/com/yomahub/liteflow/test/script/kotlin/scriptbean/bean/DemoBean2.java Normal file
View File

@ -0,0 +1,12 @@
package com.yomahub.liteflow.test.script.kotlin.scriptbean.bean;
import org.springframework.stereotype.Component;
@Component
public class DemoBean2 {
public String getDemoStr2(String name) {
return "hello," + name;
}
}

22
liteflow-testcase-el/liteflow-testcase-el-script-kotlin-springboot/src/test/java/com/yomahub/liteflow/test/script/kotlin/scriptbean/bean/DemoBean3.java Normal file
View File

@ -0,0 +1,22 @@
package com.yomahub.liteflow.test.script.kotlin.scriptbean.bean;
import com.yomahub.liteflow.script.annotation.ScriptBean;
import org.springframework.stereotype.Component;
@Component
@ScriptBean(name = "demo3", includeMethodName = { "test1", "test2" })
public class DemoBean3 {
public String test1(String name) {
return "hello," + name;
}
public String test2(String name) {
return "hello," + name;
}
public String test3(String name) {
return "hello," + name;
}
}

22
liteflow-testcase-el/liteflow-testcase-el-script-kotlin-springboot/src/test/java/com/yomahub/liteflow/test/script/kotlin/scriptbean/bean/DemoBean4.java Normal file
View File

@ -0,0 +1,22 @@
package com.yomahub.liteflow.test.script.kotlin.scriptbean.bean;
import com.yomahub.liteflow.script.annotation.ScriptBean;
import org.springframework.stereotype.Component;
@Component
@ScriptBean(name = "demo4", excludeMethodName = { "test2", "test3" })
public class DemoBean4 {
public String test1(String name) {
return "hello," + name;
}
public String test2(String name) {
return "hello," + name;
}
public String test3(String name) {
return "hello," + name;
}
}

24
liteflow-testcase-el/liteflow-testcase-el-script-kotlin-springboot/src/test/java/com/yomahub/liteflow/test/script/kotlin/scriptbean/bean/DemoBean5.java Normal file
View File

@ -0,0 +1,24 @@
package com.yomahub.liteflow.test.script.kotlin.scriptbean.bean;
import com.yomahub.liteflow.script.annotation.ScriptBean;
import org.springframework.stereotype.Component;
@Component
@ScriptBean("demo5")
public class DemoBean5 {
private final DemoBean2 demoBean2;
public DemoBean5(DemoBean2 demoBean2) {
this.demoBean2 = demoBean2;
}
public String getDemoStr1() {
return "hello";
}
public String getDemoStr2(String name) {
return demoBean2.getDemoStr2(name);
}
}

21
liteflow-testcase-el/liteflow-testcase-el-script-kotlin-springboot/src/test/java/com/yomahub/liteflow/test/script/kotlin/scriptbean/cmp/ACmp.java Normal file
View File

@ -0,0 +1,21 @@
/**
* <p>Title: liteflow</p>
* <p>Description: 轻量级的组件式流程框架</p>
* @author Bryan.Zhang
* @email weenyc31@163.com
* @Date 2020/4/1
*/
package com.yomahub.liteflow.test.script.kotlin.scriptbean.cmp;
import com.yomahub.liteflow.core.NodeComponent;
import org.springframework.stereotype.Component;
@Component("a")
public class ACmp extends NodeComponent {
@Override
public void process() {
System.out.println("ACmp executed!");
}
}

21
liteflow-testcase-el/liteflow-testcase-el-script-kotlin-springboot/src/test/java/com/yomahub/liteflow/test/script/kotlin/scriptbean/cmp/BCmp.java Normal file
View File

@ -0,0 +1,21 @@
/**
* <p>Title: liteflow</p>
* <p>Description: 轻量级的组件式流程框架</p>
* @author Bryan.Zhang
* @email weenyc31@163.com
* @Date 2020/4/1
*/
package com.yomahub.liteflow.test.script.kotlin.scriptbean.cmp;
import com.yomahub.liteflow.core.NodeComponent;
import org.springframework.stereotype.Component;
@Component("b")
public class BCmp extends NodeComponent {
@Override
public void process() {
System.out.println("BCmp executed!");
}
}

21
liteflow-testcase-el/liteflow-testcase-el-script-kotlin-springboot/src/test/java/com/yomahub/liteflow/test/script/kotlin/scriptbean/cmp/CCmp.java Normal file
View File

@ -0,0 +1,21 @@
/**
* <p>Title: liteflow</p>
* <p>Description: 轻量级的组件式流程框架</p>
* @author Bryan.Zhang
* @email weenyc31@163.com
* @Date 2020/4/1
*/
package com.yomahub.liteflow.test.script.kotlin.scriptbean.cmp;
import com.yomahub.liteflow.core.NodeComponent;
import org.springframework.stereotype.Component;
@Component("c")
public class CCmp extends NodeComponent {
@Override
public void process() {
System.out.println("CCmp executed!");
}
}

45
liteflow-testcase-el/liteflow-testcase-el-script-kotlin-springboot/src/test/java/com/yomahub/liteflow/test/script/kotlin/scriptmethod/LiteFlowScriptScriptMethodKotlinELTest.java Normal file
View File

@ -0,0 +1,45 @@
package com.yomahub.liteflow.test.script.kotlin.scriptmethod;
import com.yomahub.liteflow.core.FlowExecutor;
import com.yomahub.liteflow.flow.LiteflowResponse;
import com.yomahub.liteflow.slot.DefaultContext;
import com.yomahub.liteflow.test.script.BaseTest;
import org.junit.jupiter.api.Assertions;
import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.extension.ExtendWith;
import org.springframework.boot.autoconfigure.EnableAutoConfiguration;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.context.annotation.ComponentScan;
import org.springframework.test.context.TestPropertySource;
import org.springframework.test.context.junit.jupiter.SpringExtension;
import javax.annotation.Resource;
@ExtendWith(SpringExtension.class)
@TestPropertySource(value = "classpath:/scriptmethod/application.properties")
@SpringBootTest(classes = LiteFlowScriptScriptMethodKotlinELTest.class)
@EnableAutoConfiguration
@ComponentScan({ "com.yomahub.liteflow.test.script.kotlin.scriptmethod.cmp",
"com.yomahub.liteflow.test.script.kotlin.scriptmethod.bean" })
public class LiteFlowScriptScriptMethodKotlinELTest extends BaseTest {
@Resource
private FlowExecutor flowExecutor;
@Test
public void testScriptBean1() throws Exception {
LiteflowResponse response = flowExecutor.execute2Resp("chain1", "arg");
Assertions.assertTrue(response.isSuccess());
DefaultContext context = response.getFirstContextBean();
Assertions.assertEquals("hello", context.getData("demo"));
}
@Test
public void testScriptBean2() throws Exception {
LiteflowResponse response = flowExecutor.execute2Resp("chain2", "arg");
Assertions.assertTrue(response.isSuccess());
DefaultContext context = response.getFirstContextBean();
Assertions.assertEquals("hello,kobe", context.getData("demo"));
}
}

24
liteflow-testcase-el/liteflow-testcase-el-script-kotlin-springboot/src/test/java/com/yomahub/liteflow/test/script/kotlin/scriptmethod/bean/DemoBean1.java Normal file
View File

@ -0,0 +1,24 @@
package com.yomahub.liteflow.test.script.kotlin.scriptmethod.bean;
import com.yomahub.liteflow.script.annotation.ScriptMethod;
import org.springframework.stereotype.Component;
import javax.annotation.Resource;
@Component
public class DemoBean1 {
@Resource
private DemoBean2 demoBean2;
@ScriptMethod("demo")
public String getDemoStr1() {
return "hello";
}
@ScriptMethod("demo2")
public String getDemoStr2(String name) {
return demoBean2.getDemoStr2(name);
}
}

12
liteflow-testcase-el/liteflow-testcase-el-script-kotlin-springboot/src/test/java/com/yomahub/liteflow/test/script/kotlin/scriptmethod/bean/DemoBean2.java Normal file
View File

@ -0,0 +1,12 @@
package com.yomahub.liteflow.test.script.kotlin.scriptmethod.bean;
import org.springframework.stereotype.Component;
@Component
public class DemoBean2 {
public String getDemoStr2(String name) {
return "hello," + name;
}
}

21
liteflow-testcase-el/liteflow-testcase-el-script-kotlin-springboot/src/test/java/com/yomahub/liteflow/test/script/kotlin/scriptmethod/cmp/ACmp.java Normal file
View File

@ -0,0 +1,21 @@
/**
* <p>Title: liteflow</p>
* <p>Description: 轻量级的组件式流程框架</p>
* @author Bryan.Zhang
* @email weenyc31@163.com
* @Date 2020/4/1
*/
package com.yomahub.liteflow.test.script.kotlin.scriptmethod.cmp;
import com.yomahub.liteflow.core.NodeComponent;
import org.springframework.stereotype.Component;
@Component("a")
public class ACmp extends NodeComponent {
@Override
public void process() {
System.out.println("ACmp executed!");
}
}

21
liteflow-testcase-el/liteflow-testcase-el-script-kotlin-springboot/src/test/java/com/yomahub/liteflow/test/script/kotlin/scriptmethod/cmp/BCmp.java Normal file
View File

@ -0,0 +1,21 @@
/**
* <p>Title: liteflow</p>
* <p>Description: 轻量级的组件式流程框架</p>
* @author Bryan.Zhang
* @email weenyc31@163.com
* @Date 2020/4/1
*/
package com.yomahub.liteflow.test.script.kotlin.scriptmethod.cmp;
import com.yomahub.liteflow.core.NodeComponent;
import org.springframework.stereotype.Component;
@Component("b")
public class BCmp extends NodeComponent {
@Override
public void process() {
System.out.println("BCmp executed!");
}
}

21
liteflow-testcase-el/liteflow-testcase-el-script-kotlin-springboot/src/test/java/com/yomahub/liteflow/test/script/kotlin/scriptmethod/cmp/CCmp.java Normal file
View File

@ -0,0 +1,21 @@
/**
* <p>Title: liteflow</p>
* <p>Description: 轻量级的组件式流程框架</p>
* @author Bryan.Zhang
* @email weenyc31@163.com
* @Date 2020/4/1
*/
package com.yomahub.liteflow.test.script.kotlin.scriptmethod.cmp;
import com.yomahub.liteflow.core.NodeComponent;
import org.springframework.stereotype.Component;
@Component("c")
public class CCmp extends NodeComponent {
@Override
public void process() {
System.out.println("CCmp executed!");
}
}

15
liteflow-testcase-el/liteflow-testcase-el-script-kotlin-springboot/src/test/java/com/yomahub/liteflow/test/script/kotlin/throwException/TestException.java Normal file
View File

@ -0,0 +1,15 @@
package com.yomahub.liteflow.test.script.kotlin.throwException;
import com.yomahub.liteflow.exception.LiteFlowException;
public class TestException extends LiteFlowException {
public TestException(String message) {
super(message);
}
public TestException(String code, String message) {
super(code, message);
}
}

37
liteflow-testcase-el/liteflow-testcase-el-script-kotlin-springboot/src/test/java/com/yomahub/liteflow/test/script/kotlin/throwException/ThrowExceptionScriptKotlinELTest.java Normal file
View File

@ -0,0 +1,37 @@
package com.yomahub.liteflow.test.script.kotlin.throwException;
import com.yomahub.liteflow.core.FlowExecutor;
import com.yomahub.liteflow.flow.LiteflowResponse;
import com.yomahub.liteflow.test.script.BaseTest;
import org.junit.jupiter.api.Assertions;
import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.extension.ExtendWith;
import org.springframework.boot.autoconfigure.EnableAutoConfiguration;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.context.annotation.ComponentScan;
import org.springframework.test.context.TestPropertySource;
import org.springframework.test.context.junit.jupiter.SpringExtension;
import javax.annotation.Resource;
/**
* 测试 springboot下的 Kotlin 脚本抛错
*/
@ExtendWith(SpringExtension.class)
@TestPropertySource(value = "classpath:/throwException/application.properties")
@SpringBootTest(classes = ThrowExceptionScriptKotlinELTest.class)
@EnableAutoConfiguration
@ComponentScan({ "com.yomahub.liteflow.test.script.kotlin.throwException.cmp" })
public class ThrowExceptionScriptKotlinELTest extends BaseTest {
@Resource
private FlowExecutor flowExecutor;
@Test
public void test1() {
LiteflowResponse response = flowExecutor.execute2Resp("chain1", "arg");
Assertions.assertFalse(response.isSuccess());
Assertions.assertEquals("T01", response.getCode());
}
}

21
liteflow-testcase-el/liteflow-testcase-el-script-kotlin-springboot/src/test/java/com/yomahub/liteflow/test/script/kotlin/throwException/cmp/ACmp.java Normal file
View File

@ -0,0 +1,21 @@
/**
* <p>Title: liteflow</p>
* <p>Description: 轻量级的组件式流程框架</p>
* @author Bryan.Zhang
* @email weenyc31@163.com
* @Date 2020/4/1
*/
package com.yomahub.liteflow.test.script.kotlin.throwException.cmp;
import com.yomahub.liteflow.annotation.LiteflowComponent;
import com.yomahub.liteflow.core.NodeComponent;
@LiteflowComponent("a")
public class ACmp extends NodeComponent {
@Override
public void process() {
System.out.println("ACmp executed!");
}
}

26
liteflow-testcase-el/liteflow-testcase-el-script-kotlin-springboot/src/test/java/com/yomahub/liteflow/test/script/kotlin/validate/ValidateKotlinScriptComponentTest.java Normal file
View File

@ -0,0 +1,26 @@
package com.yomahub.liteflow.test.script.kotlin.validate;
import com.yomahub.liteflow.enums.ScriptTypeEnum;
import com.yomahub.liteflow.script.validator.ScriptValidator;
import org.junit.jupiter.api.Assertions;
import org.junit.jupiter.api.Test;
import org.springframework.boot.autoconfigure.EnableAutoConfiguration;
import org.springframework.boot.test.context.SpringBootTest;
@SpringBootTest(classes = ValidateKotlinScriptComponentTest.class)
@EnableAutoConfiguration
public class ValidateKotlinScriptComponentTest {
@Test
public void testGroovyScriptComponentValidateFunction(){
// 编译错误，字符串不能直接赋值给Int
String wrongScript = "val number: Int = \"123\"";
// 使用转换函数
String correctScript = "val number: Int = \"123\".toInt()";
Assertions.assertTrue(ScriptValidator.validate(correctScript));
Assertions.assertFalse(ScriptValidator.validate(wrongScript));
Assertions.assertTrue(ScriptValidator.validate(correctScript, ScriptTypeEnum.KOTLIN));
Assertions.assertFalse(ScriptValidator.validate(correctScript, ScriptTypeEnum.JS));
}
}

1
liteflow-testcase-el/liteflow-testcase-el-script-kotlin-springboot/src/test/resources/cmpdata/application.properties Normal file
View File

@ -0,0 +1 @@
liteflow.rule-source=cmpdata/flow.xml

27
liteflow-testcase-el/liteflow-testcase-el-script-kotlin-springboot/src/test/resources/cmpdata/flow.xml Normal file
View File

@ -0,0 +1,27 @@
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE flow PUBLIC "liteflow" "liteflow.dtd">
<flow>
<nodes>
<node id="s1" type="script" language="kotlin">
<![CDATA[
//defaultContext.setData("s1", _meta.cmpData.birth);
import com.yomahub.liteflow.slot.DefaultContext
var _meta = bindings["_meta"] as Map<String, *>
println(_meta)
var cmpData = _meta["cmpData"] as Map<String, *>
var context = bindings["defaultContext"] as DefaultContext
context.setData("s1", cmpData["birth"])
]]>
</node>
</nodes>
<chain name="chain1">
cmpData = '{"name":"jack","age":27,"birth":"1995-10-01"}';
THEN(
s1.data(cmpData),
a
);
</chain>
</flow>

41
liteflow-testcase-el/liteflow-testcase-el-script-kotlin-springboot/src/test/resources/common/flow.xml
View File

@ -8,6 +8,7 @@
fun sum(a: Int, b: Int) = a + b
var a = 2
var b = 3
// 从 bindings 中获取上下文
val defaultContext = bindings["defaultContext"] as DefaultContext
defaultContext.setData("s1", sum(a, b))
println("Hello Kotlin!")
@ -15,20 +16,22 @@
</node>
<node id="s2" type="for_script" language="kotlin">
<![CDATA[
import com.yomahub.liteflow.slot.DefaultContext
fun getCount(): Int {
val ctx = bindings["defaultContext"] as DefaultContext
var n1 = ctx.getData("k1") as Int;
var n2 = ctx.getData("k2") as Int;
return n1 + n2;
}
// 函数名可以自定义，但必须返回 Int
// 以最后调用的函数返回结果作为脚本的返回值
// 最后调用的函数结果不能赋值给其他变量
getCount()
]]>
</node>
<node id="s3" type="boolean_script" language="kotlin">
<![CDATA[
fun getBoolean1() = 2 > 1
// 函数名可以自定义，但必须返回 Boolean
getBoolean1()
]]>
</node>
@ -45,28 +48,52 @@
fun getId(ctx: DefaultContext) : String {
return ctx.getData("id") as String
}
// 函数名可以自定义，但必须返回 String
getId(bindings["defaultContext"] as DefaultContext)
]]>
</node>
<node id="s6" type="boolean_script" language="kotlin">
<![CDATA[
import com.yomahub.liteflow.slot.DefaultContext
fun isBreak() : Boolean {
val ctx = bindings["defaultContext"] as DefaultContext
var count = ctx.getData("count") as Int;
ctx.setData("count", --count)
println("count: $count")
return count < 0;
}
isBreak()
]]>
</node>
<node id="s7" type="script" language="kotlin" file="script-file/s7.kts"/>
</nodes>
<chain name="chain1">
<chain name="testCommonScript1">
THEN(a, b, c, s1);
</chain>
<chain name="chain2">
<chain name="testForScript1">
FOR(s2).DO(a);
</chain>
<chain name="chain3">
<chain name="testBooleanScript1">
IF(s3, b);
</chain>
<chain name="chain4">
<chain name="testBooleanScript2">
IF(s4, b);
</chain>
<chain name="chain5">
<chain name="testBooleanScript3">
WHILE(s3).DO(b).BREAK(s6);
</chain>
<chain name="testSwitchScript1">
SWITCH(s5).TO(a, b, c);
</chain>
<chain name="testFileScript1">
THEN(s7);
</chain>
</flow>

1
liteflow-testcase-el/liteflow-testcase-el-script-kotlin-springboot/src/test/resources/contextbean/application.properties Normal file
View File

@ -0,0 +1 @@
liteflow.rule-source=contextbean/flow.xml

45
liteflow-testcase-el/liteflow-testcase-el-script-kotlin-springboot/src/test/resources/contextbean/flow.xml Normal file
View File

@ -0,0 +1,45 @@
<?xml version="1.0" encoding="UTF-8"?>
<flow>
<nodes>
<node id="d" type="script" language="kotlin">
<![CDATA[
import com.yomahub.liteflow.test.script.kotlin.contextbean.bean.*
var order = bindings["order"] as OrderContext
var checkContext = bindings["checkContext"] as CheckContext
var order2Context = bindings["order2Context"] as Order2Context
order.setOrderNo("order1")
checkContext.setSign("sign1")
order2Context.setOrderNo("order2")
]]>
</node>
<node id="e" type="script" language="kotlin">
<![CDATA[
import com.yomahub.liteflow.test.script.kotlin.contextbean.bean.*
var order = bindings["order"] as OrderContext
var checkContext = bindings["checkContext"] as CheckContext
var order2Context = bindings["order2Context"] as Order2Context
var orderNo = order.getOrderNo()
println(orderNo)
var sign = checkContext.getSign()
println(sign)
var orderNo2 = order2Context.getOrderNo()
println(orderNo2)
]]>
</node>
</nodes>
<chain name="chain1">
THEN(a,b,c,d);
</chain>
<chain name="chain2">
THEN(a,b,c,e);
</chain>
</flow>

1
liteflow-testcase-el/liteflow-testcase-el-script-kotlin-springboot/src/test/resources/meta/application.properties Normal file
View File

@ -0,0 +1 @@
liteflow.rule-source=meta/flow.xml

24
liteflow-testcase-el/liteflow-testcase-el-script-kotlin-springboot/src/test/resources/meta/flow.xml Normal file
View File

@ -0,0 +1,24 @@
<?xml version="1.0" encoding="UTF-8"?>
<flow>
<nodes>
<node id="s1" name="普通脚本1" type="script" language="kotlin">
<![CDATA[
import com.yomahub.liteflow.slot.DefaultContext
var _meta = bindings["_meta"] as Map<String, Any>
var nodeId = _meta["nodeId"]
var currChainId = _meta["currChainId"]
var requestData = _meta["requestData"]
var context = bindings["defaultContext"] as DefaultContext
context.setData("nodeId",nodeId)
context.setData("currChainId",currChainId)
context.setData("requestData",requestData)
]]>
</node>
</nodes>
<chain id="chain1">
THEN(a, b, c, s1);
</chain>
</flow>

1
liteflow-testcase-el/liteflow-testcase-el-script-kotlin-springboot/src/test/resources/refresh/application.properties Normal file
View File

@ -0,0 +1 @@
liteflow.rule-source=refresh/flow.xml

27
liteflow-testcase-el/liteflow-testcase-el-script-kotlin-springboot/src/test/resources/refresh/flow.xml Normal file
View File

@ -0,0 +1,27 @@
<?xml version="1.0" encoding="UTF-8"?>
<flow>
<nodes>
<node id="s1" name="选择脚本" type="switch_script" language="kotlin">
<![CDATA[
import com.yomahub.liteflow.slot.DefaultContext
fun getId(): String {
val context = bindings["defaultContext"] as DefaultContext
var count = context.getData("count") as Int;
if(count > 100) {
return "a";
} else {
return "b";
}
}
getId()
]]>
</node>
</nodes>
<chain name="chain1">
THEN(d, SWITCH(s1).to(a,b));
</chain>
</flow>

36
liteflow-testcase-el/liteflow-testcase-el-script-kotlin-springboot/src/test/resources/refresh/flow_update.xml Normal file
View File

@ -0,0 +1,36 @@
<?xml version="1.0" encoding="UTF-8"?>
<flow>
<nodes>
<node id="s1" name="选择脚本_改" type="switch_script" language="kotlin">
<![CDATA[
import com.yomahub.liteflow.slot.DefaultContext
fun getId(): String {
val context = bindings["defaultContext"] as DefaultContext
var count = context.getData("count") as Int;
if(count > 100) {
return "b";
} else {
return "a";
}
}
getId()
]]>
</node>
<node id="s2" name="普通脚本_新增" type="script" language="kotlin">
<![CDATA[
import com.yomahub.liteflow.slot.DefaultContext
var a = 3
var b = 2
var c = 10
(bindings["defaultContext"] as? DefaultContext)?.setData("s2", a*b+c)
]]>
</node>
</nodes>
<chain name="chain1">
THEN(d, SWITCH(s1).to(a,b), s2);
</chain>
</flow>

1
liteflow-testcase-el/liteflow-testcase-el-script-kotlin-springboot/src/test/resources/remove/application.properties Normal file
View File

@ -0,0 +1 @@
liteflow.rule-source=remove/flow.xml

34
liteflow-testcase-el/liteflow-testcase-el-script-kotlin-springboot/src/test/resources/remove/flow.xml Normal file
View File

@ -0,0 +1,34 @@
<?xml version="1.0" encoding="UTF-8"?>
<flow>
<nodes>
<node id="s1" name="普通脚本1" type="script" language="kotlin">
<![CDATA[
import com.yomahub.liteflow.slot.DefaultContext
var a = 1
var b = 2
var c = 3
(bindings["defaultContext"] as? DefaultContext)?.setData("s1", a+b+c)
]]>
</node>
<node id="s2" name="普通脚本2" type="script" language="kotlin">
<![CDATA[
import com.yomahub.liteflow.slot.DefaultContext
var a = 1
var b = 2
var c = 3
(bindings["defaultContext"] as? DefaultContext)?.setData("s2", a*b+c)
]]>
</node>
</nodes>
<chain name="chain1">
THEN(s1);
</chain>
<chain name="chain2">
THEN(s2);
</chain>
</flow>

6
liteflow-testcase-el/liteflow-testcase-el-script-kotlin-springboot/src/test/resources/script-file/s7.kts Normal file
View File

@ -0,0 +1,6 @@
import com.yomahub.liteflow.slot.DefaultContext
var a = 2
var b = 3
val defaultContext = bindings["defaultContext"] as DefaultContext
defaultContext.setData("s7", a * b)

1
liteflow-testcase-el/liteflow-testcase-el-script-kotlin-springboot/src/test/resources/scriptbean/application.properties Normal file
View File

@ -0,0 +1 @@
liteflow.rule-source=scriptbean/flow.xml

134
liteflow-testcase-el/liteflow-testcase-el-script-kotlin-springboot/src/test/resources/scriptbean/flow.xml Normal file
View File

@ -0,0 +1,134 @@
<?xml version="1.0" encoding="UTF-8"?>
<flow>
<nodes>
<node id="d" type="script" language="kotlin">
<![CDATA[
import com.yomahub.liteflow.slot.DefaultContext
import com.yomahub.liteflow.test.script.kotlin.scriptbean.bean.*
var demo = bindings["demo"] as DemoBean1
var str = demo.getDemoStr1()
var defaultContext = bindings["defaultContext"] as DefaultContext
defaultContext.setData("demo", str)
]]>
</node>
<node id="e" type="script" language="kotlin">
<![CDATA[
import com.yomahub.liteflow.slot.DefaultContext
import com.yomahub.liteflow.test.script.kotlin.scriptbean.bean.*
var demo = bindings["demo"] as DemoBean1
var str = demo.getDemoStr2("kobe")
var defaultContext = bindings["defaultContext"] as DefaultContext
defaultContext.setData("demo", str)
]]>
</node>
<node id="s1" type="script" language="kotlin">
<![CDATA[
import com.yomahub.liteflow.slot.DefaultContext
import com.yomahub.liteflow.test.script.kotlin.scriptbean.bean.*
var demo3 = bindings["demo3"] as DemoBean3
var str = demo3.test1("kobe")
var defaultContext = bindings["defaultContext"] as DefaultContext
defaultContext.setData("demo", str)
]]>
</node>
<node id="s2" type="script" language="kotlin">
<![CDATA[
import com.yomahub.liteflow.slot.DefaultContext
import com.yomahub.liteflow.test.script.kotlin.scriptbean.bean.*
var demo3 = bindings["demo3"] as DemoBean3
var str = demo3.test3("kobe")
var defaultContext = bindings["defaultContext"] as DefaultContext
defaultContext.setData("demo", str)
]]>
</node>
<node id="s3" type="script" language="kotlin">
<![CDATA[
import com.yomahub.liteflow.slot.DefaultContext
import com.yomahub.liteflow.test.script.kotlin.scriptbean.bean.*
var demo4 = bindings["demo4"] as DemoBean4
var str = demo4.test1("kobe")
var defaultContext = bindings["defaultContext"] as DefaultContext
defaultContext.setData("demo", str)
]]>
</node>
<node id="s4" type="script" language="kotlin">
<![CDATA[
import com.yomahub.liteflow.slot.DefaultContext
import com.yomahub.liteflow.test.script.kotlin.scriptbean.bean.*
var demo4 = bindings["demo4"] as DemoBean4
var str = demo4.test3("kobe")
var defaultContext = bindings["defaultContext"] as DefaultContext
defaultContext.setData("demo", str)
]]>
</node>
<node id="s5" type="script" language="kotlin">
<![CDATA[
import com.yomahub.liteflow.slot.DefaultContext
import com.yomahub.liteflow.test.script.kotlin.scriptbean.bean.*
import java.util.HashMap
var demo = bindings["demo"] as DemoBean1
var str = demo.getDemoStr1()
var abcCx = bindings["abcCx"] as HashMap<String, String>
abcCx.put("demo", str)
]]>
</node>
<node id="f" type="script" language="kotlin">
<![CDATA[
import com.yomahub.liteflow.slot.DefaultContext
import com.yomahub.liteflow.test.script.kotlin.scriptbean.bean.*
var demo5 = bindings["demo5"] as DemoBean5
var str = demo5.getDemoStr2("jordan")
var defaultContext = bindings["defaultContext"] as DefaultContext
defaultContext.setData("demo", str)
]]>
</node>
</nodes>
<chain name="chain1">
THEN(a,b,c,d);
</chain>
<chain name="chain2">
THEN(a,b,c,e);
</chain>
<chain name="chain3">
THEN(a,b,c,s1);
</chain>
<chain name="chain4">
THEN(a,b,c,s2);
</chain>
<chain name="chain5">
THEN(a,b,c,s3);
</chain>
<chain name="chain6">
THEN(a,b,c,s4);
</chain>
<chain name="chain7">
THEN(a,b,c,s5);
</chain>
<chain name="chain8">
THEN(a,b,c,f);
</chain>
</flow>

1
liteflow-testcase-el/liteflow-testcase-el-script-kotlin-springboot/src/test/resources/scriptmethod/application.properties Normal file
View File

@ -0,0 +1 @@
liteflow.rule-source=scriptmethod/flow.xml

37
liteflow-testcase-el/liteflow-testcase-el-script-kotlin-springboot/src/test/resources/scriptmethod/flow.xml Normal file
View File

@ -0,0 +1,37 @@
<?xml version="1.0" encoding="UTF-8"?>
<flow>
<nodes>
<node id="d" type="script" language="kotlin">
<![CDATA[
import com.yomahub.liteflow.slot.DefaultContext
import com.yomahub.liteflow.test.script.kotlin.scriptmethod.bean.*
var demo = bindings["demo"] as DemoBean1
var str = demo.getDemoStr1()
var defaultContext = bindings["defaultContext"] as DefaultContext
defaultContext.setData("demo", str)
]]>
</node>
<node id="e" type="script" language="kotlin">
<![CDATA[
import com.yomahub.liteflow.slot.DefaultContext
import com.yomahub.liteflow.test.script.kotlin.scriptmethod.bean.*
var demo2 = bindings["demo2"] as DemoBean1
var str = demo2.getDemoStr2("kobe")
var defaultContext = bindings["defaultContext"] as DefaultContext
defaultContext.setData("demo", str)
]]>
</node>
</nodes>
<chain name="chain1">
THEN(a,b,c,d);
</chain>
<chain name="chain2">
THEN(a,b,c,e);
</chain>
</flow>

1
liteflow-testcase-el/liteflow-testcase-el-script-kotlin-springboot/src/test/resources/throwException/application.properties Normal file
View File

@ -0,0 +1 @@
liteflow.rule-source=throwException/flow.xml

17
liteflow-testcase-el/liteflow-testcase-el-script-kotlin-springboot/src/test/resources/throwException/flow.xml Normal file
View File

@ -0,0 +1,17 @@
<?xml version="1.0" encoding="UTF-8"?>
<flow>
<nodes>
<node id="s1" name="普通脚本1" type="script" language="kotlin">
<![CDATA[
import com.yomahub.liteflow.test.script.kotlin.throwException.TestException
throw TestException("T01", "测试错误")
]]>
</node>
</nodes>
<chain name="chain1">
THEN(a, s1);
</chain>
</flow>