easy-rules-centraldogma-spring-boot-starter 当前是基于json 以及只支持spel 格式的解析的
如果我们需要添加其他格式的,当前只直接不能支持的,但是也可以使用其他模式解决
解决方法
自己定义rule,添加到starter提供的bean 中
参考代码
- rule
package com.dalong.rule;
import org.jeasy.rules.annotation.Action;
import org.jeasy.rules.annotation.Condition;
import org.jeasy.rules.annotation.Fact;
import org.jeasy.rules.annotation.Rule;
@Rule(priority = 0,description = "demo")
public class MyRule {
@Condition
public boolean itRains(@Fact("biz") User user) {
System.out.println(user.toString());
return true;
}
@Action
public void takeAnUmbrella(@Fact("biz") User user) {
System.out.println("run from first");
user.setAge((int)(Math.random()*100));
System.out.println(user.toString());
}
}
- 集成
public class RuleApi {
@Autowired
private Map<String, Rules> centralDogmaRules;
@Autowired
private RulesEngine rulesEngine;
@Autowired
private ObjectMapper objectMapper;
@RequestMapping(value = "/myrule", method = RequestMethod.POST)
public Object info(@RequestBody CloudEvent user) throws Exception {
centralDogmaRules.forEach(new BiConsumer<String, Rules>() {
@Override
public void accept(String s, Rules rules) {
System.out.println(s);
rules.forEach(new Consumer<Rule>() {
@Override
public void accept(Rule rule) {
System.out.println(rule.getDescription());
}
});
}
});
Rules rules = centralDogmaRules.get("demoapp");
PojoCloudEventData<User> cloudEventData = mapData(
user,
PojoCloudEventDataMapper.from(objectMapper,User.class)
);
// 注册了我们的rule
rules.register(new MyRule());
Facts facts = new Facts();
// 生成一个唯一id,方便基于数据id规则流程查询
facts.put("biz",cloudEventData.getValue());
facts.put("result",new MyResult());
rulesEngine.fire(rules,facts);
Object userResult= facts.get("biz");
MyResult result =facts.get("result");
if(Objects.isNull(result.getJsonNode())){
return "not execute";
}
System.out.println(result.getJsonNode().toPrettyString());
System.out.println("result from final ruls"+userResult.toString());
return result;
}
}
说明
此内容主要是关于如果扩展的,具体关于starter 的使用建议参考一些写的文章