1.提交Map规则测试用例

src/main/java/com/wezone/drools/model/Customer.java

@@ -0,0 +1,14 @@
+package com.wezone.drools.model;
+
+import lombok.Data;
+
+import java.util.List;
+
+/**
+ * @author 陈韦龙
+ * @date 2022/06/30/ 16:41
+ */
+@Data
+public class Customer {
+    private List<Order> orderList;
+}

src/main/java/com/wezone/drools/model/Order.java

@@ -0,0 +1,15 @@
+package com.wezone.drools.model;
+
+import lombok.Data;
+
+import java.math.BigDecimal;
+
+/**
+ * @author 陈韦龙
+ * @date 2022/06/30/ 16:38
+ */
+@Data
+public class Order {
+    private BigDecimal amount;
+    private Integer score;
+}

src/main/resources/META-INF/kmodule.xml

@@ -0,0 +1,6 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<kmodule xmlns="http://www.drools.org/xsd/kmodule">
+    <kbase name="myKBase1" packages="rules" default="true">
+        <ksession name="kSession-rule" default="true"/>
+    </kbase>
+</kmodule>

src/main/resources/rules/score-rules.drl

@@ -0,0 +1,34 @@
+package rules;
+
+import java.util.Map;
+import java.util.List;
+import com.wezone.drools.model.*
+
+rule "测试map"
+    no-loop true
+when
+    $first:Map(["first"] != null);
+    $second:Map(["amount"] != null) from $first.get("first")
+    $map:Map(["amount"] != null) from $second.get("second")
+
+then
+    System.out.println("测试map");
+    $map.put("score", "100");
+//    retract($map);
+end
+
+rule "测试contains"
+when
+    $order:Order();
+    $customer:Customer(orderList contains $order);
+then
+    System.out.println("触发规则-测试contains");
+end
+
+rule "测试memberOf"
+when
+    $amountList:List();
+    $order:Order(amount memberOf $amountList);
+then
+    System.out.println("触发规则-测试memberOf");
+end

src/test/java/com/wezone/drools/test/ConditionTest.java

@@ -7,10 +7,17 @@ import cn.hutool.json.JSONObject;
 import cn.hutool.json.JSONUtil;
 import com.googlecode.aviator.AviatorEvaluator;
 import com.wezone.drools.enums.MathOperatorEnum;
+import com.wezone.drools.model.*;
+import org.assertj.core.util.Lists;
+import org.drools.core.base.RuleNameEndsWithAgendaFilter;
+import org.drools.core.base.RuleNameEqualsAgendaFilter;
 import org.junit.jupiter.api.Test;
+import org.kie.api.KieServices;
+import org.kie.api.runtime.KieContainer;
+import org.kie.api.runtime.KieSession;
 
-import java.util.Set;
-import java.util.StringJoiner;
+import java.math.BigDecimal;
+import java.util.*;
 
 public class ConditionTest {
 
@@ -69,4 +76,79 @@ public class ConditionTest {
         Console.log("{} = {}", stringBuffer.toString(), executeB);
     }
 
+    @Test
+    public void testMap() {
+        // 事实对象
+        Map<String, Map<String, Map<String, String>>> topMap = new HashMap<>();
+        Map<String, Map<String, String>> secondMap = new HashMap<>();
+        Map<String, String> map = new HashMap<>();
+        map.put("amount", "500");
+        map.put("score", "0");
+        secondMap.put("second", map);
+        topMap.put("first", secondMap);
+        //第一步：获取服务
+        KieServices kieServices = KieServices.Factory.get();
+        // 第二步：通过服务获取容器
+        KieContainer container = kieServices.getKieClasspathContainer();
+        // 第三步：通过容器获取KieSession，由KieSession去和规则引擎交互
+        KieSession kieSession = container.newKieSession();
+        // 第四步：将数据交给规则引擎，规则引擎会根据提供的数据进行规则匹配
+        kieSession.insert(topMap);
+        // 第五步：执行规则引擎，触发规则
+//        kieSession.fireAllRules();
+        kieSession.fireAllRules(new RuleNameEqualsAgendaFilter("测试map"));
+        // 第六步：关闭容器
+        kieSession.dispose();
+
+        System.out.println(JSONUtil.toJsonStr(topMap));
+    }
+
+    @Test
+    public void testContains() {
+        // 事实对象
+        Order order = new Order();
+        order.setAmount(BigDecimal.valueOf(100));
+        Customer customer = new Customer();
+        customer.setOrderList(Lists.newArrayList(order));
+        //第一步：获取服务
+        KieServices kieServices = KieServices.Factory.get();
+        // 第二步：通过服务获取容器
+        KieContainer container = kieServices.getKieClasspathContainer();
+        // 第三步：通过容器获取KieSession，由KieSession去和规则引擎交互
+        KieSession kieSession = container.newKieSession();
+        // 第四步：将数据交给规则引擎，规则引擎会根据提供的数据进行规则匹配
+        kieSession.insert(order);
+        kieSession.insert(customer);
+        // 第五步：执行规则引擎，触发规则
+//        kieSession.fireAllRules();
+        kieSession.fireAllRules(new RuleNameEqualsAgendaFilter("测试contains"));
+        // 第六步：关闭容器
+        kieSession.dispose();
+
+    }
+
+    @Test
+    public void testMemberOf() {
+        // 事实对象
+        Order order = new Order();
+        order.setAmount(BigDecimal.valueOf(100));
+
+        List<BigDecimal> list = Lists.newArrayList(BigDecimal.valueOf(100));
+        //第一步：获取服务
+        KieServices kieServices = KieServices.Factory.get();
+        // 第二步：通过服务获取容器
+        KieContainer container = kieServices.getKieClasspathContainer();
+        // 第三步：通过容器获取KieSession，由KieSession去和规则引擎交互
+        KieSession kieSession = container.newKieSession();
+        // 第四步：将数据交给规则引擎，规则引擎会根据提供的数据进行规则匹配
+        kieSession.insert(order);
+        kieSession.insert(list);
+        // 第五步：执行规则引擎，触发规则
+//        kieSession.fireAllRules();
+        kieSession.fireAllRules(new RuleNameEqualsAgendaFilter("测试memberOf"));
+        // 第六步：关闭容器
+        kieSession.dispose();
+
+    }
+
 }