如何验证FTL模板生成的动态Drools规则？校验报错求助

一、现有规则的语法错误修复 #

1. "Check Trade Amount" 规则错误修复 #

原规则的核心问题：

• 误用AND/OR作为逻辑运算符，DRL规范中需使用&&（与）和||（或）
• 多个独立eval语句的组合写法不符合DRL语法，需将逻辑表达式合并，或利用MVEL方言特性直接在Map约束中编写表达式

修正后的规则（推荐简洁的Map约束写法）：

rule "Check Trade Amount"
salience 99
enabled true
dialect "mvel"
when
    $map : Map(
        // 逻辑分组：满足任一条件触发规则
        (String.valueOf(get("product.type")) == "Physical Goods" && Integer.parseInt(get("payment.amount")) > 200000) ||
        (String.valueOf(get("product.type")) == "Bank Transfer" && Integer.parseInt(get("payment.amount")) > 30000)
    )
then
    System.out.println("Decision: escalate");
    $map.put("decision", "Escalate");
end

若坚持使用eval，写法如下：

rule "Check Trade Amount"
salience 99
enabled true
dialect "mvel"
when
    $map : Map()
    eval(
        (String.valueOf($map.get("product.type")) == "Physical Goods" && Integer.parseInt($map.get("payment.amount")) > 200000) ||
        (String.valueOf($map.get("product.type")) == "Bank Transfer" && Integer.parseInt($map.get("payment.amount")) > 30000)
    )
then
    System.out.println("Decision: escalate");
    $map.put("decision", "Escalate");
end

2. "Check White List" 规则错误修复 #

原规则的核心问题：

• 直接使用transaction.payee，但当前Fact是Map，必须通过Map的get方法获取属性值
• 需确保memberOf语法符合MVEL规范，作用于从Map中取出的支付方值

修正后的规则：

rule "Check White List"
salience 98
enabled true
dialect "mvel"
when
    $map : Map(
        get("transaction.payee") memberOf ["Mark", "bill gates", "Good guy"]
    )
then
    System.out.println("Decision: escalate");
    $map.put("decision", "Escalate");
end

二、动态Drools规则的最优校验方法 #

1. 基础语法校验：使用Drools PackageBuilder #

快速检测DRL语法错误，是校验的基础环节，代码示例：

import org.drools.compiler.compiler.PackageBuilder;
import org.drools.core.io.impl.ByteArrayResource;
import org.kie.api.io.ResourceType;

public boolean validateRuleSyntax(String drlContent) {
    try {
        PackageBuilder packageBuilder = new PackageBuilder();
        ByteArrayResource resource = new ByteArrayResource(drlContent.getBytes());
        packageBuilder.addResource(resource, ResourceType.DRL);
        
        if (packageBuilder.hasErrors()) {
            System.err.println("语法错误: " + packageBuilder.getErrors().toString());
            return false;
        }
        return true;
    } catch (Exception e) {
        e.printStackTrace();
        return false;
    }
}

2. 语义逻辑校验：使用Drools Verifier #

除语法外，还能检测规则逻辑问题（如重复规则、死条件、冗余约束等），需确保Verifier版本与Drools版本兼容，代码示例：

import org.drools.verifier.Verifier;
import org.drools.verifier.builder.VerifierBuilder;
import org.drools.verifier.builder.VerifierBuilderFactory;
import org.drools.core.io.impl.ByteArrayResource;
import org.kie.api.io.ResourceType;

public boolean verifyRuleLogic(String drlContent) {
    VerifierBuilder builder = VerifierBuilderFactory.newVerifierBuilder();
    Verifier verifier = builder.newVerifier();
    
    ByteArrayResource resource = new ByteArrayResource(drlContent.getBytes());
    verifier.addResource(resource, ResourceType.DRL);
    verifier.fireAnalysis();
    
    if (verifier.hasErrors()) {
        verifier.getErrors().forEach(error -> System.err.println("逻辑错误: " + error.getMessage()));
        return false;
    }
    
    // 可选：输出潜在逻辑问题的警告
    verifier.getWarnings().forEach(warning -> System.out.println("规则警告: " + warning.getMessage()));
    return true;
}

3. 业务行为校验：动态加载并执行测试用例 #

确保规则不仅语法正确，还符合业务预期，通过临时加载规则并执行测试数据验证结果，代码示例：

import org.kie.api.KieServices;
import org.kie.api.runtime.KieContainer;
import org.kie.api.runtime.KieSession;
import java.util.HashMap;
import java.util.Map;

public boolean testRuleBehavior(String drlContent) {
    KieServices kieServices = KieServices.Factory.get();
    org.kie.api.builder.KieFileSystem kfs = kieServices.newKieFileSystem();
    kfs.write("src/main/resources/test-rules.drl", drlContent);
    
    org.kie.api.builder.KieBuilder kieBuilder = kieServices.newKieBuilder(kfs).buildAll();
    if (kieBuilder.getResults().hasMessages(org.kie.api.builder.Message.Level.ERROR)) {
        throw new RuntimeException("规则构建失败: " + kieBuilder.getResults().toString());
    }
    
    KieContainer kieContainer = kieServices.newKieContainer(kieServices.getRepository().getDefaultReleaseId());
    KieSession kieSession = kieContainer.newKieSession();
    
    // 构造测试数据
    Map<String, Object> testMap = new HashMap<>();
    testMap.put("transaction.payee", "Mark");
    kieSession.insert(testMap);
    
    kieSession.fireAllRules();
    
    // 验证业务结果
    boolean result = "Escalate".equals(testMap.get("decision"));
    kieSession.dispose();
    return result;
}

4. 整合校验流程 #

将三个步骤整合为完整的校验服务：

1. 先执行语法校验，不通过则直接返回错误
2. 语法校验通过后，执行语义逻辑校验
3. 最后执行业务行为测试，确保规则符合预期
4. 只有全部通过的规则，才传入其他模块执行

内容的提问来源于stack exchange，提问作者Tim