public/liteFlow
1
0
Fork 0
mirror of https://gitee.com/dromara/liteFlow.git synced 2026-05-14 20:22:07 +08:00
Code Issues Packages Projects Releases Wiki Activity

bug #I4FYKA jsonparser好像缺少脚本条件组件的解析

Browse Source
This commit is contained in:
bryan31
2021-11-04 19:54:28 +08:00
parent a380c97209
commit 7ac63c21fc
19 changed files with 323 additions and 16 deletions
Download Patch File Download Diff File Expand all files Collapse all files

69
liteflow-testcase-script-qlexpress/src/test/java/com/yomahub/liteflow/test/script/qlexpress/LiteflowJsonScriptQLExpressTest.java Normal file
View File

@@ -0,0 +1,69 @@
package com.yomahub.liteflow.test.script.qlexpress;
import cn.hutool.core.io.resource.ResourceUtil;
import com.yomahub.liteflow.core.FlowExecutor;
import com.yomahub.liteflow.entity.data.DefaultSlot;
import com.yomahub.liteflow.entity.data.LiteflowResponse;
import com.yomahub.liteflow.enums.FlowParserTypeEnum;
import com.yomahub.liteflow.flow.FlowBus;
import com.yomahub.liteflow.test.BaseTest;
import org.junit.Assert;
import org.junit.Test;
import org.junit.runner.RunWith;
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.junit4.SpringRunner;
import javax.annotation.Resource;
/**
* 测试springboot下的脚本组件
* @author Bryan.Zhang
* @since 2.6.0
*/
@RunWith(SpringRunner.class)
@TestPropertySource(value = "classpath:/json-script/application.properties")
@SpringBootTest(classes = LiteflowJsonScriptQLExpressTest.class)
@EnableAutoConfiguration
@ComponentScan({"com.yomahub.liteflow.test.script.qlexpress.cmp"})
public class LiteflowJsonScriptQLExpressTest extends BaseTest {
@Resource
private FlowExecutor flowExecutor;
//测试普通脚本节点
@Test
public void testScript1() {
LiteflowResponse<DefaultSlot> response = flowExecutor.execute2Resp("chain1", "arg");
Assert.assertTrue(response.isSuccess());
Assert.assertEquals(Integer.valueOf(6), response.getSlot().getData("s1"));
}
//测试条件脚本节点
@Test
public void testScript2() {
LiteflowResponse<DefaultSlot> response = flowExecutor.execute2Resp("chain2", "arg");
Assert.assertTrue(response.isSuccess());
Assert.assertEquals("d==>s2[条件脚本]==>b", response.getSlot().printStep());
}
@Test
public void testScript3() throws Exception{
//根据配置，加载的应该是flow.xml，执行原来的规则
LiteflowResponse<DefaultSlot> responseOld = flowExecutor.execute2Resp("chain2", "arg");
Assert.assertTrue(responseOld.isSuccess());
Assert.assertEquals("d==>s2[条件脚本]==>b", responseOld.getSlot().printStep());
//更改规则，重新加载，更改的规则内容从flow_update.xml里读取，这里只是为了模拟下获取新的内容。不一定是从文件中读取
String newContent = ResourceUtil.readUtf8Str("classpath: /json-script/flow_update.json");
//进行刷新
FlowBus.refreshFlowMetaData(FlowParserTypeEnum.TYPE_JSON, newContent);
//重新执行chain2这个链路，结果会变
LiteflowResponse<DefaultSlot> responseNew = flowExecutor.execute2Resp("chain2", "arg");
Assert.assertTrue(responseNew.isSuccess());
Assert.assertEquals("d==>s2[条件脚本_改]==>a==>s3[普通脚本_新增]", responseNew.getSlot().printStep());
}
}

8
liteflow-testcase-script-qlexpress/src/test/java/com/yomahub/liteflow/test/script/qlexpress/LiteflowScriptQLExpressTest.java → liteflow-testcase-script-qlexpress/src/test/java/com/yomahub/liteflow/test/script/qlexpress/LiteflowXmlScriptQLExpressTest.java
View File

@@ -25,11 +25,11 @@ import javax.annotation.Resource;
* @since 2.6.0
*/
@RunWith(SpringRunner.class)
@TestPropertySource(value = "classpath:/script/application.properties")
@SpringBootTest(classes = LiteflowScriptQLExpressTest.class)
@TestPropertySource(value = "classpath:/xml-script/application.properties")
@SpringBootTest(classes = LiteflowXmlScriptQLExpressTest.class)
@EnableAutoConfiguration
@ComponentScan({"com.yomahub.liteflow.test.script.qlexpress.cmp"})
public class LiteflowScriptQLExpressTest extends BaseTest {
public class LiteflowXmlScriptQLExpressTest extends BaseTest {
@Resource
private FlowExecutor flowExecutor;
@@ -57,7 +57,7 @@ public class LiteflowScriptQLExpressTest extends BaseTest {
Assert.assertTrue(responseOld.isSuccess());
Assert.assertEquals("d==>s2[条件脚本]==>b", responseOld.getSlot().printStep());
//更改规则，重新加载，更改的规则内容从flow_update.xml里读取，这里只是为了模拟下获取新的内容。不一定是从文件中读取
String newContent = ResourceUtil.readUtf8Str("classpath: /script/flow_update.xml");
String newContent = ResourceUtil.readUtf8Str("classpath: /xml-script/flow_update.xml");
//进行刷新
FlowBus.refreshFlowMetaData(FlowParserTypeEnum.TYPE_XML, newContent);

1
liteflow-testcase-script-qlexpress/src/test/resources/json-script/application.properties Normal file
View File

@@ -0,0 +1 @@
liteflow.rule-source=json-script/flow.json

34
liteflow-testcase-script-qlexpress/src/test/resources/json-script/flow.json Normal file
View File

@@ -0,0 +1,34 @@
{
"flow": {
"nodes": {
"node": [
{
"id": "s1",
"name": "普通脚本",
"type": "script",
"value": "a=3;b=2;slot.setData(\"s1\",a*b);"
},
{
"id": "s2",
"name": "条件脚本",
"type": "cond_script",
"value": "count = slot.getData(\"count\");if(count > 100){return \"a\";}else{return \"b\";}"
}
]
},
"chain": [
{
"name": "chain1",
"condition": [
{"type": "then", "value": "a,b,c,s1"}
]
},
{
"name": "chain2",
"condition": [
{"type": "then", "value": "d,s2(a|b)"}
]
}
]
}
}

40
liteflow-testcase-script-qlexpress/src/test/resources/json-script/flow_update.json Normal file
View File

@@ -0,0 +1,40 @@
{
"flow": {
"nodes": {
"node": [
{
"id": "s1",
"name": "普通脚本",
"type": "script",
"value": "a=3;b=2;slot.setData(\"s1\",a*b);"
},
{
"id": "s2",
"name": "条件脚本_改",
"type": "cond_script",
"value": "count = slot.getData(\"count\");if(count > 150){return \"b\";}else{return \"a\";}"
},
{
"id": "s3",
"name": "普通脚本_新增",
"type": "script",
"value": "a=3;b=2;c=10;slot.setData(\"s1\",a*b+c);"
}
]
},
"chain": [
{
"name": "chain1",
"condition": [
{"type": "then", "value": "a,b,c,s1"}
]
},
{
"name": "chain2",
"condition": [
{"type": "then", "value": "d,s2(a|b),s3"}
]
}
]
}
}

1
liteflow-testcase-script-qlexpress/src/test/resources/script/application.properties
View File

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

1
liteflow-testcase-script-qlexpress/src/test/resources/xml-script/application.properties Normal file
View File

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

0
liteflow-testcase-script-qlexpress/src/test/resources/script/flow.xml → liteflow-testcase-script-qlexpress/src/test/resources/xml-script/flow.xml
View File

0
liteflow-testcase-script-qlexpress/src/test/resources/script/flow_update.xml → liteflow-testcase-script-qlexpress/src/test/resources/xml-script/flow_update.xml
View File