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

!19 组件的功能点测试

Browse Source 
Merge pull request !19 from dongguo.tao/v2.5.0-SNAPSHOT
This commit is contained in:
铂赛东
2021-04-07 15:56:41 +08:00
committed by Gitee
parent 316c738325 1beab89c76
commit c4174fafd7
21 changed files with 540 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

88
liteflow-spring-boot-starter/src/test/java/com/yomahub/liteflow/test/component/FlowExecutorTest.java Normal file
View File

@@ -0,0 +1,88 @@
package com.yomahub.liteflow.test.component;
import com.yomahub.liteflow.core.FlowExecutor;
import com.yomahub.liteflow.entity.data.LiteflowResponse;
import com.yomahub.liteflow.entity.data.Slot;
import com.yomahub.liteflow.exception.ChainEndException;
import com.yomahub.liteflow.test.BaseTest;
import org.junit.Assert;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
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 org.springframework.util.ReflectionUtils;
import javax.annotation.Resource;
import java.lang.reflect.UndeclaredThrowableException;
/**
* 组件功能点测试
* 单元测试
*
* @author donguo.tao
*/
@RunWith(SpringRunner.class)
@TestPropertySource(value = "classpath:/component/application.properties")
@SpringBootTest(classes = FlowExecutorTest.class)
@EnableAutoConfiguration
@ComponentScan({"com.yomahub.liteflow.test.component.cmp1","com.yomahub.liteflow.test.component.cmp2"})
public class FlowExecutorTest extends BaseTest {
private static final Logger LOG = LoggerFactory.getLogger(FlowExecutorTest.class);
@Resource
private FlowExecutor flowExecutor;
//isAccess方法的功能测试
@Test
public void testIsAccess() throws Exception {
LiteflowResponse<Slot> response = flowExecutor.execute("chain1", 101);
Assert.assertTrue(response.isSuccess());
Assert.assertNotNull(response.getData().getResponseData());
}
//组件抛错的功能点测试
@Test(expected = ArithmeticException.class)
public void testComponentException() throws Exception {
LiteflowResponse<Slot> response = flowExecutor.execute("chain2", 0);
Assert.assertFalse(response.isSuccess());
Assert.assertEquals("/ by zero", response.getMessage());
ReflectionUtils.rethrowException(response.getCause());
}
//isContinueOnError方法的功能点测试
@Test(expected = UndeclaredThrowableException.class)
public void testIsContinueOnError() throws Exception {
LiteflowResponse<Slot> response = flowExecutor.execute("chain3", 0);
Assert.assertTrue(response.isSuccess());
ReflectionUtils.rethrowException(response.getCause());
}
//isEnd方法的功能点测试
@Test(expected = ChainEndException.class)
public void testIsEnd() throws Exception {
LiteflowResponse<Slot> response = flowExecutor.execute("chain4", 10);
Assert.assertFalse(response.isSuccess());
ReflectionUtils.rethrowException(response.getCause());
}
//setIsEnd方法的功能点测试
@Test(expected = ChainEndException.class)
public void testSetIsEnd() throws Exception {
LiteflowResponse<Slot> response = flowExecutor.execute("chain5", 10);
Assert.assertFalse(response.isSuccess());
ReflectionUtils.rethrowException(response.getCause());
}
//条件组件的功能点测试
@Test
public void testNodeCondComponent() throws Exception {
LiteflowResponse<Slot> response = flowExecutor.execute("chain6", 0);
Assert.assertTrue(response.isSuccess());
}
}

26
liteflow-spring-boot-starter/src/test/java/com/yomahub/liteflow/test/component/cmp1/ACmp.java Normal file
View File

@@ -0,0 +1,26 @@
package com.yomahub.liteflow.test.component.cmp1;
import com.yomahub.liteflow.core.NodeComponent;
import org.springframework.stereotype.Component;
import java.util.Objects;
@Component("a")
public class ACmp extends NodeComponent {
@Override
public void process() {
System.out.println("AComp executed!");
this.getSlot().setResponseData("AComp executed!");
}
@Override
public boolean isAccess() {
Integer requestData = this.getSlot().getRequestData();
if (Objects.nonNull(requestData) && requestData > 100){
return true;
}
System.out.println("AComp isAccess false.");
return false;
}
}

29
liteflow-spring-boot-starter/src/test/java/com/yomahub/liteflow/test/component/cmp1/BCmp.java Normal file
View File

@@ -0,0 +1,29 @@
package com.yomahub.liteflow.test.component.cmp1;
import com.yomahub.liteflow.core.NodeComponent;
import org.springframework.stereotype.Component;
import java.util.Objects;
@Component("b")
public class BCmp extends NodeComponent {
@Override
public void process() {
System.out.println("BComp executed!");
Integer requestData = this.getSlot().getRequestData();
Integer divisor = 130;
Integer result = divisor / requestData;
this.getSlot().setResponseData(result);
}
@Override
public boolean isAccess() {
Integer requestData = this.getSlot().getRequestData();
if (Objects.nonNull(requestData)){
return true;
}
return false;
}
}

29
liteflow-spring-boot-starter/src/test/java/com/yomahub/liteflow/test/component/cmp1/CCmp.java Normal file
View File

@@ -0,0 +1,29 @@
package com.yomahub.liteflow.test.component.cmp1;
import com.yomahub.liteflow.core.NodeComponent;
import org.springframework.stereotype.Component;
import java.util.Objects;
@Component("c")
public class CCmp extends NodeComponent {
@Override
public void process() {
System.out.println("CComp executed!");
Integer requestData = this.getSlot().getRequestData();
Integer divisor = 130;
Integer result = divisor / requestData;
this.getSlot().setResponseData(result);
System.out.println("responseData="+Integer.parseInt(this.getSlot().getResponseData()));
}
@Override
public boolean isContinueOnError() {
Integer requestData = this.getSlot().getRequestData();
if (Objects.nonNull(requestData)){
return true;
}
return false;
}
}

26
liteflow-spring-boot-starter/src/test/java/com/yomahub/liteflow/test/component/cmp1/DCmp.java Normal file
View File

@@ -0,0 +1,26 @@
package com.yomahub.liteflow.test.component.cmp1;
import com.yomahub.liteflow.core.NodeComponent;
import org.springframework.stereotype.Component;
import java.util.Objects;
@Component("d")
public class DCmp extends NodeComponent {
@Override
public void process() throws Exception {
System.out.println("DComp executed!");
}
@Override
public boolean isEnd() {
//组件的process执行完之后才会执行isEnd
Object requestData = this.getSlot().getResponseData();
if (Objects.isNull(requestData)){
System.out.println("DComp flow isEnd, because of responseData is null.");
return true;
}
return false;
}
}

24
liteflow-spring-boot-starter/src/test/java/com/yomahub/liteflow/test/component/cmp1/ECmp.java Normal file
View File

@@ -0,0 +1,24 @@
package com.yomahub.liteflow.test.component.cmp1;
import com.alibaba.fastjson.JSON;
import com.yomahub.liteflow.core.NodeComponent;
import org.springframework.stereotype.Component;
import java.util.Objects;
@Component("e")
public class ECmp extends NodeComponent {
@Override
public void process() throws Exception {
System.out.println("EComp executed!");
Object responseData = this.getSlot().getResponseData();
if (Objects.isNull(responseData)){
System.out.println("EComp responseData flow must be set end .");
//执行到某个条件时，手动结束流程。
this.setIsEnd(true);
}
System.out.println("EComp responseData responseData=" + JSON.toJSONString(responseData));
}
}

22
liteflow-spring-boot-starter/src/test/java/com/yomahub/liteflow/test/component/cmp2/FCondCmp.java Normal file
View File

@@ -0,0 +1,22 @@
package com.yomahub.liteflow.test.component.cmp2;
import com.yomahub.liteflow.core.NodeCondComponent;
import org.springframework.stereotype.Component;
import java.util.Objects;
@Component("f")
public class FCondCmp extends NodeCondComponent {
@Override
public String processCond() {
Integer requestData = this.getSlot().getRequestData();
if (Objects.isNull(requestData)){
return "d";
} else if(requestData == 0){
return "c";
} else {
return "b";
}
}
}

17
liteflow-spring-boot-starter/src/test/java/com/yomahub/liteflow/test/parsecustom/CustomJsonFlowParser.java Normal file
View File

@@ -0,0 +1,17 @@
package com.yomahub.liteflow.test.parsecustom;
import com.yomahub.liteflow.parser.ClassJsonFlowParser;
/**
* 模拟用户自定义源解析
* @author dongguo.tao
* @date 2021/4/7
*/
public class CustomJsonFlowParser extends ClassJsonFlowParser {
@Override
public String parseCustom() {
//模拟自定义解析结果
String content = "{\"flow\":{\"nodes\":{\"node\":[{\"id\":\"a\",\"class\":\"com.yomahub.liteflow.test.parsecustom.cmp.ACmp\"},{\"id\":\"b\",\"class\":\"com.yomahub.liteflow.test.parsecustom.cmp.BCmp\"},{\"id\":\"c\",\"class\":\"com.yomahub.liteflow.test.parsecustom.cmp.CCmp\"},{\"id\":\"d\",\"class\":\"com.yomahub.liteflow.test.parsecustom.cmp.DCmp\"},{\"id\":\"e\",\"class\":\"com.yomahub.liteflow.test.parsecustom.cmp.ECmp\"},{\"id\":\"f\",\"class\":\"com.yomahub.liteflow.test.parsecustom.cmp.FCmp\"},{\"id\":\"g\",\"class\":\"com.yomahub.liteflow.test.parsecustom.cmp.GCmp\"}]},\"chain\":[{\"name\":\"chain2\",\"condition\":[{\"type\":\"then\",\"value\":\"c,g,f\"}]},{\"name\":\"chain1\",\"condition\":[{\"type\":\"then\",\"value\":\"a,c\"},{\"type\":\"when\",\"value\":\"b,d,e(f|g)\"},{\"type\":\"then\",\"value\":\"chain2\"}]}]}}";
return content;
}
}

33
liteflow-spring-boot-starter/src/test/java/com/yomahub/liteflow/test/parsecustom/CustomParserJsonSpringTest.java Normal file
View File

@@ -0,0 +1,33 @@
package com.yomahub.liteflow.test.parsecustom;
import com.yomahub.liteflow.core.FlowExecutor;
import com.yomahub.liteflow.entity.data.LiteflowResponse;
import com.yomahub.liteflow.entity.data.Slot;
import com.yomahub.liteflow.test.BaseTest;
import org.junit.Assert;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.test.context.ContextConfiguration;
import org.springframework.test.context.junit4.SpringRunner;
import javax.annotation.Resource;
/**
* spring环境的自定义json parser单元测试
* @author dongguo.tao
* @since 2.5.0
*/
@RunWith(SpringRunner.class)
@ContextConfiguration("classpath:/parsecustom/application.xml")
public class CustomParserJsonSpringTest extends BaseTest {
@Resource
private FlowExecutor flowExecutor;
//测试spring场景的自定义json parser
@Test
public void testSpringboot() throws Exception{
LiteflowResponse<Slot> response = flowExecutor.execute("chain1", "args");
Assert.assertTrue(response.isSuccess());
}
}

39
liteflow-spring-boot-starter/src/test/java/com/yomahub/liteflow/test/parsecustom/CustomParserJsonSpringbootTest.java Normal file
View File

@@ -0,0 +1,39 @@
package com.yomahub.liteflow.test.parsecustom;
import com.yomahub.liteflow.core.FlowExecutor;
import com.yomahub.liteflow.entity.data.LiteflowResponse;
import com.yomahub.liteflow.entity.data.Slot;
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环境的自定义json parser单元测试
* @author dongguo.tao
* @since 2.5.0
*/
@RunWith(SpringRunner.class)
@TestPropertySource(value = "classpath:/parsecustom/application.properties")
@SpringBootTest(classes = CustomParserJsonSpringbootTest.class)
@EnableAutoConfiguration
@ComponentScan({"com.yomahub.liteflow.test.parsecustom.cmp"})
public class CustomParserJsonSpringbootTest extends BaseTest {
@Resource
private FlowExecutor flowExecutor;
//测试springboot场景的自定义json parser
@Test
public void testSpringboot() throws Exception{
LiteflowResponse<Slot> response = flowExecutor.execute("chain1", "args");
Assert.assertTrue(response.isSuccess());
}
}

26
liteflow-spring-boot-starter/src/test/java/com/yomahub/liteflow/test/parsecustom/cmp/ACmp.java Normal file
View File

@@ -0,0 +1,26 @@
/**
* <p>Title: liteflow</p>
* <p>Description: 轻量级的组件式流程框架</p>
* @author Bryan.Zhang
* @email weenyc31@163.com
* @Date 2020/4/1
*/
package com.yomahub.liteflow.test.parsecustom.cmp;
import cn.hutool.core.util.StrUtil;
import com.yomahub.liteflow.core.NodeComponent;
import com.yomahub.liteflow.exception.FlowSystemException;
import org.springframework.stereotype.Component;
@Component("a")
public class ACmp extends NodeComponent {
@Override
public void process() {
String str = this.getSlot().getRequestData();
if(StrUtil.isNotBlank(str) && str.equals("exception")) {
throw new FlowSystemException("chain execute execption");
}
System.out.println("ACmp executed!");
}
}

21
liteflow-spring-boot-starter/src/test/java/com/yomahub/liteflow/test/parsecustom/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.parsecustom.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-spring-boot-starter/src/test/java/com/yomahub/liteflow/test/parsecustom/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.parsecustom.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!");
}
}

21
liteflow-spring-boot-starter/src/test/java/com/yomahub/liteflow/test/parsecustom/cmp/DCmp.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.parsecustom.cmp;
import com.yomahub.liteflow.core.NodeComponent;
import org.springframework.stereotype.Component;
@Component("d")
public class DCmp extends NodeComponent {
@Override
public void process() {
System.out.println("DCmp executed!");
}
}

20
liteflow-spring-boot-starter/src/test/java/com/yomahub/liteflow/test/parsecustom/cmp/ECmp.java Normal file
View File

@@ -0,0 +1,20 @@
/**
* <p>Title: liteflow</p>
* <p>Description: 轻量级的组件式流程框架</p>
* @author Bryan.Zhang
* @email weenyc31@163.com
* @Date 2020/4/1
*/
package com.yomahub.liteflow.test.parsecustom.cmp;
import com.yomahub.liteflow.core.NodeCondComponent;
import org.springframework.stereotype.Component;
@Component("e")
public class ECmp extends NodeCondComponent {
@Override
public String processCond() throws Exception {
return "g";
}
}

21
liteflow-spring-boot-starter/src/test/java/com/yomahub/liteflow/test/parsecustom/cmp/FCmp.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.parsecustom.cmp;
import com.yomahub.liteflow.core.NodeComponent;
import org.springframework.stereotype.Component;
@Component("f")
public class FCmp extends NodeComponent {
@Override
public void process() {
System.out.println("FCmp executed!");
}
}

21
liteflow-spring-boot-starter/src/test/java/com/yomahub/liteflow/test/parsecustom/cmp/GCmp.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.parsecustom.cmp;
import com.yomahub.liteflow.core.NodeComponent;
import org.springframework.stereotype.Component;
@Component("g")
public class GCmp extends NodeComponent {
@Override
public void process() {
System.out.println("GCmp executed!");
}
}

1
liteflow-spring-boot-starter/src/test/resources/component/application.properties Normal file
View File

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

26
liteflow-spring-boot-starter/src/test/resources/component/flow.xml Normal file
View File

@@ -0,0 +1,26 @@
<?xml version="1.0" encoding="UTF-8"?>
<flow>
<chain name="chain1">
<then value="a"/>
</chain>
<chain name="chain2">
<then value="b"/>
</chain>
<chain name="chain3">
<then value="c"/>
</chain>
<chain name="chain4">
<then value="a,d,c"/>
</chain>
<chain name="chain5">
<then value="a,e,c"/>
</chain>
<chain name="chain6">
<then value="f(d | c | b)" />
</chain>
</flow>

1
liteflow-spring-boot-starter/src/test/resources/parsecustom/application.properties Normal file
View File

@@ -0,0 +1 @@
liteflow.rule-source=com.yomahub.liteflow.test.parsecustom.CustomJsonFlowParser

28
liteflow-spring-boot-starter/src/test/resources/parsecustom/application.xml Normal file
View File

@@ -0,0 +1,28 @@
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns="http://www.springframework.org/schema/beans"
xmlns:context="http://www.springframework.org/schema/context"
xsi:schemaLocation="http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans-4.0.xsd
http://www.springframework.org/schema/context
http://www.springframework.org/schema/context/spring-context-4.0.xsd">
<context:component-scan base-package="com.yomahub.liteflow.test.parsecustom.cmp" />
<bean id="liteflowConfig" class="com.yomahub.liteflow.property.LiteflowConfig">
<property name="ruleSource" value="com.yomahub.liteflow.test.parsecustom.CustomJsonFlowParser"/>
</bean>
<bean id="flowExecutor" class="com.yomahub.liteflow.core.FlowExecutor">
<property name="liteflowConfig" ref="liteflowConfig"/>
</bean>
<!-- <bean id="flowExecutor" class="com.yomahub.liteflow.core.FlowExecutor">-->
<!-- <property name="rulePath">-->
<!-- <list>-->
<!-- <value>com.yomahub.liteflow.test.parsecustom.CustomJsonFlowParser</value>-->
<!-- </list>-->
<!-- </property>-->
<!-- </bean>-->
</beans>