wxl
/
cloud-server
2
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix:完善规则引擎版本测试方法

master
Wang XinLong 2024-05-16 21:25:25 +08:00
parent 3eb39d11b1
commit 69df6a4718
1 changed files with 8 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
muyu-modules/muyu-rule-engine/muyu-rule-engine-client/src/main/java/com/muyu/source/engine/client/config/RuleEngineClientConfig.java
View File

@ -1,7 +1,6 @@
package com.muyu.source.engine.client.config;
import com.muyu.common.core.domain.Result;
import com.muyu.ruleEngine.constant.RuleOperationConstants;
import com.muyu.ruleEngine.context.DataModelContextHolder;
import com.muyu.ruleEngine.context.DataSetContextHolder;
import com.muyu.ruleEngine.context.RecordContextHolder;
@ -44,7 +43,7 @@ public class RuleEngineClientConfig {
if (testReq.getScope() == 4) {
DataProcessModel dataProcessModel = DataProcessModel.builder().dataModel(testReq.getDataModel()).build();
DataModelContextHolder.set(dataProcessModel);
} else if(testReq.getScope() == 3){
} else if (testReq.getScope() == 3) {
RecordModel recordModel = RecordModel.builder().dataModels(testReq.getDataModelList()).build();
RecordProcessModel recordProcessModel = RecordProcessModel.builder()
.keys(testReq.getKeys())
@ -55,8 +54,8 @@ public class RuleEngineClientConfig {
List<RecordModel> recordModelList = new ArrayList<>();
List<List<DataModel>> dataModelLists = testReq.getDataModelLists();
dataModelLists.stream().forEach(dataModelList -> {
RecordModel recordModel1 = RecordModel.builder().dataModels(dataModelList).build();
recordModelList.add(recordModel1);
RecordModel recordModel = RecordModel.builder().dataModels(dataModelList).build();
recordModelList.add(recordModel);
});
DataSetModel dataSetModel = DataSetModel.builder()
.recordModels(recordModelList)
@ -73,14 +72,14 @@ public class RuleEngineClientConfig {
try {
@SuppressWarnings("resource")
DynamicLoader.MemoryClassLoader classLoader = new DynamicLoader.MemoryClassLoader(engineMap);
Class<?> clazz = classLoader.loadClass(engineVersion.getVersionClass());
Class<?> aClass = classLoader.loadClass(engineVersion.getVersionClass());
// 调用ruleTest方法
Method mainMethod = clazz.getDeclaredMethod("execution");
Object o = clazz.newInstance();
mainMethod.invoke(o);
Method method = aClass.getDeclaredMethod("execution");
Object o = aClass.newInstance();
method.invoke(o);
} catch (Exception e) {
log.info(e.getMessage());
return Result.success("程序异常: 信息["+e.getLocalizedMessage()+"]异常");
return Result.success("程序异常: 信息[" + e.getLocalizedMessage() + "]异常");
}
return Result.success("测试正常,无异常数据返回");
}