drools代码示例包

package com.xiongpeng.test; import com.xiongpeng.entity.Customer; import com.xiongpeng.entity.Order; import com.xiongpeng.entity.Person; import org.drools.core.base.RuleNameEndsWithAgendaFilter; import org.drools.core.base.RuleNameEqualsAgendaFilter; import org.junit.Test; import org.kie.api.KieServices; import org.kie.api.runtime.KieContainer; import org.kie.api.runtime.KieSession; import org.kie.api.runtime.rule.QueryResults; import org.kie.api.runtime.rule.QueryResultsRow; import java.util.ArrayList; import java.util.List; public class TestDrools { @Test public void test1() { //第一步 //获取服务 KieServices kieServices = KieServices.Factory.get(); //第二步 //获取服务容器 KieContainer kieContainer = kieServices.getKieClasspathContainer(); //第三步 //会话对象,⽤于和规则引擎交互 KieSession kieSession = kieContainer.newKieSession(); //构造订单对象，设置订单⾦额，由规则引擎计算获得的积分 Order order = new Order(); order.setAmout(200); //第四步 //将数据交给规则引擎，规则引擎会根据提供的数据进⾏规则匹配 kieSession.insert(order); //第五步 //激活规则引擎，如果匹配成功则执⾏规则 kieSession.fireAllRules(); //第六步 // 关闭会话 kieSession.dispose(); //打印结果; System.out.println("订单提交之后积分：" + order.getScore()); } @Test public void test2() { KieServices kieServices = KieServices.Factory.get(); KieContainer kieContainer = kieServices.getKieClasspathContainer(); //会话对象,⽤于和规则引擎交互 KieSession kieSession = kieContainer.newKieSession(); //构造订单对象，设置订单⾦额，由规则引擎计算获得的积分 Order order = new Order(); //匹配规则：$order:Order(); kieSession.insert(order); Customer customer = new Customer(); List<Order> orderList = new ArrayList<Order>(); //匹配规则： $customer:Customer(orderList contains $order); // orderList.add(order); customer.setOrderList(orderList); customer.setName("Jack"); //将数据交给规则引擎，规则引擎会根据提供的数据进⾏规则匹配 kieSession.insert(customer); //激活规则引擎，如果匹配成功则执⾏规则 kieSession.fireAllRules(); //关闭会话 kieSession.dispose(); } @Test public void test3() { KieServices kieServices = KieServices.Factory.get(); KieContainer kieContainer = kieServices.getKieClasspathContainer(); //会话对象,⽤于和规则引擎交互 KieSession kieSession = kieContainer.newKieSession(); //构造订单对象，设置订单⾦额，由规则引擎计算获得的积分 Order order = new Order(); //匹配规则：$order:Order(); kieSession.insert(order); Customer customer = new Customer(); List<Order> orderList = new ArrayList<Order>(); //匹配规则： $customer:Customer(orderList contains $order); // orderList.add(order); customer.setOrderList(orderList); customer.setName("Jack"); //将数据交给规则引擎，规则引擎会根据提供的数据进⾏规则匹配 kieSession.insert(customer); //激活规则引擎，如果匹配成功则执⾏规则 kieSession.fireAllRules(new RuleNameEqualsAgendaFilter("rule4")); //关闭会话 kieSession.dispose(); } @Test public void test4() { KieServices kieServices = KieServices.Factory.get(); KieContainer kieContainer = kieServices.getKieClasspathContainer(); //会话对象,⽤于和规则引擎交互 KieSession kieSession = kieContainer.newKieSession(); //激活规则引擎，如果匹配成功则执⾏规则 kieSession.fireAllRules(); //关闭会话 kieSession.dispose(); } @Test public void test5() { KieServices kieServices = KieServices.Factory.get(); KieContainer kieContainer = kieServices.getKieClasspathContainer(); //会话对象,⽤于和规则引擎交互 KieSession kieSession = kieContainer.newKieSession(); Customer customer = new Customer(); customer.setName("李四"); kieSession.insert(customer); //激活规则引擎，如果匹配成功则执⾏规则 kieSession.fireAllRules(); //关闭会话 kieSession.dispose(); } @Test public void test6() { KieServices kieServices = KieServices.Factory.get(); KieContainer kieContainer = kieServices.getKieClasspathContainer(); //会话对象,⽤于和规则引擎交互 KieSession kieSession = kieContainer.newKieSession(); Customer customer = new Customer(); customer.setName("李四"); kieSession.insert(customer); //激活规则引擎，如果匹配成功则执⾏规则 kieSession.fireAllRules(); //通过规则过滤器实现只执⾏指定规则 // kieSession.fireAllRules(new RuleNameEqualsAgendaFilter("rule5")); // 关闭会话 kieSession.dispose(); } @Test public void test7() { KieServices kieServices = KieServices.Factory.get(); KieContainer kieContainer = kieServices.getKieClasspathContainer(); //会话对象,⽤于和规则引擎交互 KieSession kieSession = kieContainer.newKieSession(); Customer customer = new Customer(); customer.setName("张三"); kieSession.insert(customer); //激活规则引擎，如果匹配成功则执⾏规则 kieSession.fireAllRules(); //激活规则引擎，如果匹配成功则执⾏规则 kieSession.fireAllRules(); // 关闭会话 kieSession.dispose(); } //测试属性部分 @Test public void test8() { //设置修改默认的时间格式 System.setProperty("drools.dateformat", "yyyy-MM-dd"); KieServices kieServices = KieServices.Factory.get(); KieContainer kieContainer = kieServices.getKieClasspathContainer(); //会话对象,⽤于和规则引擎交互 KieSession kieSession = kieContainer.newKieSession(); //激活规则引擎，如果匹配成功则执⾏规则 kieSession.fireAllRules(); // 关闭会话 kieSession.dispose(); } //测试属性部分 @Test public void test9() { //设置修改默认的时间格式 KieServices kieServices = KieServices.Factory.get(); KieContainer kieContainer = kieServices.getKieClasspathContainer(); //会话对象,⽤于和规则引擎交互 KieSession kieSession = kieContainer.newKieSession(); //激活规则引擎，如果匹配成功则执⾏规则 kieSession.fireAllRules(); // 关闭会话 kieSession.dispose(); } //测试属性部分 @Test public void test10() { //设置修改默认的时间格式 KieServices kieServices = KieServices.Factory.get(); KieContainer kieContainer = kieServices.getKieClasspathContainer(); //会话对象,⽤于和规则引擎交互 KieSession kieSession = kieContainer.newKieSession(); kieSession.getAgenda().getAgendaGroup("002").setFocus(); //获得执⾏ 焦点 // 激活规则引擎，如果匹配成功则执⾏规则 kieSession.fireAllRules(); // 关闭会话 kieSession.dispose();