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;

    }

}