easy-rules-centraldogma-spring-boot-starter 引入外部rule

Posted 2021-08-29 rongfengliang-荣锋亮

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 的使用建议参考一些写的文章

参考资料

https://github.com/rongfengliang/easy-rules-centraldogma-spring-boot-starter
https://www.cnblogs.com/rongfengliang/p/15171851.html