etl
/
cloud-etl-rule
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

1

master
Cui YongXing 2024-09-10 12:27:15 +08:00
parent 8f7a7b5cb1
commit a39877067a
5 changed files with 15 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
cloud-rule-client/src/main/java/com/muyu/client/basic/RuleConfig.java
View File

@ -10,7 +10,7 @@ import com.muyu.rule.common.domain.RuleEngineVersion;
public interface RuleConfig { public interface RuleConfig {
public Result<RuleEngineVersion> findVersionById( Long id); public Result<RuleEngineVersion> findVersionById( Long id);
public Result testEngine(String className, DataValueFie dataValue); public Result<DataValue> testEngine(String className, DataValueFie dataValue);
public Result testEngine(String className, DataValueRow dataValue); public Result<DataValue[]> testEngine(String className, DataValueRow dataValue);
public Result DataSetEngine(String className, DataValueRows dataValues); public Result<DataValue[][]> DataSetEngine(String className, DataValueRows dataValues);
} }

6
cloud-rule-client/src/main/java/com/muyu/client/basic/impl/RuleConfigImpl.java
View File

@ -23,17 +23,17 @@ public class RuleConfigImpl implements RuleConfig {
} }
@Override @Override
public Result testEngine(String className, DataValueFie dataValue) { public Result<DataValue> testEngine(String className, DataValueFie dataValue) {
return ruleFeign.testEngine(className, dataValue); return ruleFeign.testEngine(className, dataValue);
} }
@Override @Override
public Result testEngine(String className, DataValueRow dataValue) { public Result<DataValue[]> testEngine(String className, DataValueRow dataValue) {
return ruleFeign.testEngine(className, dataValue); return ruleFeign.testEngine(className, dataValue);
} }
@Override @Override
public Result DataSetEngine(String className, DataValueRows dataValues) { public Result<DataValue[][]> DataSetEngine(String className, DataValueRows dataValues) {
return ruleFeign.DataSetEngine(className, dataValues); return ruleFeign.DataSetEngine(className, dataValues);
} }
} }

6
cloud-rule-remote/src/main/java/com/muyu/rule/remote/Factory/RuleFactory.java
View File

@ -26,19 +26,19 @@ public class RuleFactory implements FallbackFactory<RuleFeign> {
} }
@Override @Override
public Result testEngine(String className, DataValueFie dataValue) { public Result<DataValue> testEngine(String className, DataValueFie dataValue) {
log.info(cause); log.info(cause);
return Result.error("网络开小差......"); return Result.error("网络开小差......");
} }
@Override @Override
public Result testEngine(String className, DataValueRow dataValue) { public Result<DataValue[]> testEngine(String className, DataValueRow dataValue) {
log.info(cause); log.info(cause);
return Result.error("网络开小差......"); return Result.error("网络开小差......");
} }
@Override @Override
public Result DataSetEngine(String className, DataValueRows dataValues) { public Result<DataValue[][]> DataSetEngine(String className, DataValueRows dataValues) {
log.info(cause); log.info(cause);
return Result.error("网络开小差......"); return Result.error("网络开小差......");
} }

6
cloud-rule-remote/src/main/java/com/muyu/rule/remote/RuleFeign.java
View File

@ -21,9 +21,9 @@ public interface RuleFeign {
@PostMapping("/version/findVersionById/{id}") @PostMapping("/version/findVersionById/{id}")
public Result<RuleEngineVersion> findVersionById(@PathVariable("id") Long id); public Result<RuleEngineVersion> findVersionById(@PathVariable("id") Long id);
@PostMapping("/version/testEngine/{className}") @PostMapping("/version/testEngine/{className}")
public Result testEngine(@PathVariable("className") String className,@RequestBody DataValueFie dataValue); public Result<DataValue> testEngine(@PathVariable("className") String className,@RequestBody DataValueFie dataValue);
@PostMapping("/version/rowEngine/{className}") @PostMapping("/version/rowEngine/{className}")
public Result testEngine(@PathVariable("className") String className,@RequestBody DataValueRow dataValue); public Result<DataValue[]> testEngine(@PathVariable("className") String className,@RequestBody DataValueRow dataValue);
@PostMapping("/version/DataSetEngine/{className}") @PostMapping("/version/DataSetEngine/{className}")
public Result DataSetEngine(@PathVariable("className") String className,@RequestBody DataValueRows dataValues); public Result<DataValue[][]> DataSetEngine(@PathVariable("className") String className,@RequestBody DataValueRows dataValues);
} }

6
cloud-rule-server/src/main/java/com/muyu/rule/server/controller/RuleEngineVersionController.java
View File

@ -303,7 +303,7 @@ public Result<List<RuleEngineVersion>> selectVersionById(@PathVariable("id") Lon
@PostMapping("/testEngine/{className}") @PostMapping("/testEngine/{className}")
@Operation(summary = "字段规则引擎测试", description = "传入规则引擎的类名,和数据,用规则引擎进行测试数据") @Operation(summary = "字段规则引擎测试", description = "传入规则引擎的类名,和数据,用规则引擎进行测试数据")
public Result testEngine(@PathVariable("className") String className,@RequestBody DataValueFie dataValue){ public Result<DataValue> testEngine(@PathVariable("className") String className,@RequestBody DataValueFie dataValue){
log.info("数据:" + dataValue); log.info("数据:" + dataValue);
//加载对应的规则引擎 //加载对应的规则引擎
loadEngineClass.loadValueEngineClass(className); loadEngineClass.loadValueEngineClass(className);
@ -315,7 +315,7 @@ public Result<List<RuleEngineVersion>> selectVersionById(@PathVariable("id") Lon
@PostMapping("/rowEngine/{className}") @PostMapping("/rowEngine/{className}")
@Operation(summary = "行/记录规则引擎测试", description = "传入规则引擎的类名,和数据,用规则引擎进行测试数据") @Operation(summary = "行/记录规则引擎测试", description = "传入规则引擎的类名,和数据,用规则引擎进行测试数据")
public Result testEngine(@PathVariable("className") String className,@RequestBody DataValueRow dataValue){ public Result<DataValue[]> testEngine(@PathVariable("className") String className,@RequestBody DataValueRow dataValue){
log.info("数据:" + dataValue); log.info("数据:" + dataValue);
//加载对应的规则引擎 //加载对应的规则引擎
loadEngineClass.loadRowEngineClass(className); loadEngineClass.loadRowEngineClass(className);
@ -326,7 +326,7 @@ public Result<List<RuleEngineVersion>> selectVersionById(@PathVariable("id") Lon
} }
@PostMapping("/DataSetEngine/{className}") @PostMapping("/DataSetEngine/{className}")
@Operation(summary = "数据集的规则引擎测试", description = "传入规则引擎的类名,和数据,用规则引擎进行测试数据") @Operation(summary = "数据集的规则引擎测试", description = "传入规则引擎的类名,和数据,用规则引擎进行测试数据")
public Result DataSetEngine(@PathVariable("className") String className,@RequestBody DataValueRows dataValues){ public Result<DataValue[][]> DataSetEngine(@PathVariable("className") String className,@RequestBody DataValueRows dataValues){
loadEngineClass.loadDataSetEngineClass(className); loadEngineClass.loadDataSetEngineClass(className);