if(overdueDays>a && overdueDays<b && overdueAmt <W){
    taskQuene = "A佇列";
}
else if(overdueDays>c && overdueDays<d && overdueAmt <W){
    taskQuene = "B佇列";
}
else if(overdueDays>e && overdueDays<f && overdueAmt <W){
    taskQuene = "C佇列";
}
else if(overdueDays>h && overdueDays<g && overdueAmt <W){
    taskQuene = "D佇列";
}
……

package  //包名，這個包名只是邏輯上的包名，不必與物理包路徑一致。
 
import   //匯入類 同java
 
function  //  自定義函數
 
query  //  查詢
 
global   //  全域性變數
 
rule "rule name"  //  定義規則名稱，名稱唯一不能重複
    attribute //  規則屬性
    when
        //  規則條件
    then
        //  觸發行為
end
 
rule "rule2 name"
 
...

function String hello(String applicantName) {
    return "Hello " + applicantName + "!";
}
 
rule "Using a function"
  when
    // Empty
  then
    System.out.println( hello( "James" ) );
end

query "people under the age of 21"
    $person : Person( age < 21 )
end
 

QueryResults results = ksession.getQueryResults( "people under the age of 21" );
System.out.println( "we have " + results.size() + " people under the age  of 21" );
 

List<String> list = new ArrayList<>();
KieSession kieSession = kiebase.newKieSession();
kieSession.setGlobal( "myGlobalList", list );
 

global java.util.List myGlobalList;
 
rule "Using a global"
  when
    // Empty
  then
    myGlobalList.add( "My global list" );
end

rule "Underage"
  when
    application : LoanApplication()//表示存在Application事實物件且age屬性滿足<21
    Applicant( age < 21 )
  then
    // Actions
end

rule "Underage"
  when
    application : LoanApplication()
    Applicant( age < 21 )
  then
    application.setApproved( false );
end

rule "Underage"
  when
    Applicant( age < 21 )
  then
    Applicant application = new application();
    application.setAge(22);
    insert(application);//插入fact重新匹配規則，age>21的規則直接被觸發
end

rule "Underage"
  when
    Applicant( age < 21 )
  then
    Applicant application = new application();
    application.setAge(22);
    insert(application);//插入fact重新匹配規則，age>21的規則直接被觸發
end

<kmodule xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
        xmlns="http://www.drools.org/xsd/kmodule">
  <kbase name="KBase1" default="true" packages="org.domain.pkg1">
    <ksession name="KSession2_1" type="stateful" default="true"/>
    <ksession name="KSession2_2" type="stateless" default="false"/>
  </kbase>
  <kbase name="KBase2" default="false" packages="org.domain.pkg2, org.domain.pkg3">
    <ksession name="KSession3_1" type="stateful" default="false">
    </ksession>
  </kbase>
</kmodule>

KieServices kieServices = KieServices.Factory.get();
KieContainer kContainer = kieServices.getKieClasspathContainer();
KieBase kBase1 = kContainer.getKieBase("KBase1"); //獲取指定的KBase
KieSession kieSession1 = kContainer.newKieSession("KSession2_1"); //獲取指定的KSession
kieSession1.insert(facts);//規則插入到工作記憶體
kSession.fireAllRules();//開始執行
kSession.dispose();//關閉對話

rule "Rete"
  when
    A(a1==1,$a:a1)
    B(b1==1,b1==$a,$b:b2)
    C(c2==$b)
  then
    System.out.print("匹配成功");
end

rule "Rete1"
when
    Cheese( $cheddar : name == "cheddar" )
    $person : Person( favouriteCheese == $cheddar )
then
    System.out.println( $person.getName() + " likes cheddar" );
end
 
rule "Rete2"
when
    Cheese( $cheddar : name == "cheddar" )
    $person : Person( favouriteCheese != $cheddar )
then
    System.out.println( $person.getName() + " does not like cheddar" );
end

package vivoPhoneTaskRule;
 
import com.worldline.wcs.service.rule.CaseSumNewWrapper;
 
 
rule "rule1"
    salience 1
    when
        caseSumNew:CaseSumNewWrapper(overdueDD > a && overdueDD < b && overdueAmt <= W)
    then
        caseSumNew.setTaskType("A佇列");
end
 
rule "rule2"
    salience 2
    when
        caseSumNew:CaseSumNewWrapper(overdueDD > c && overdueDD < d && overdueAmt <= W)
    then
        caseSumNew.setTaskType("B佇列");
end
 
rule "rule3"
    salience 3
    when
        caseSumNew:CaseSumNewWrapper(overdueDD > e && overdueDD < f && overdueAmt <= W)
    then
        caseSumNew.setTaskType("C佇列");
end
 
rule "rule4"
    salience 4
    when
        caseSumNew:CaseSumNewWrapper(overdueDD > h && overdueDD < g && overdueAmt > W)
    then
        caseSumNew.setTaskType("D佇列");
end

<rule package="phoneTask">
    <entitys>
        <entity note="collectionCaseInfo" cls="com.worldline.wcs.service.rule.FactWrapper" alias="caseSumNew">
            <attribute attr="caseSumNew.overdueDD" />
            <attribute attr="caseSumNew.totalOverdueAmt"/>
        </entity>
    </entitys>
    <resultDefs>
        <resultDef key="1" seq="1" enumKey="ruleTaskType">
            <script><![CDATA[caseSumNew.setTaskType("@param");]]></script>
        </resultDef>
    </resultDefs>
</rule>

/**
* 生成規則指令碼
* rule規則基本資訊：包括規則表欄位名定義等
* def 業務人員具體錄入規則集的條件和結果等資料
*/
public String generateDRLScript(DroolsRuleEditBO rule, DroolsRuleTableBO def) {
        //解析事實物件對映XML檔案，生成條件定義與結果定義
        RuleSetDef ruleSetDef = RuleSetDefHelper.getRuleSetDef(rule.getRuleTypeCode());
 
        // 1.宣告規則包
        StringBuilder drl = new StringBuilder("package ").append(rule.getRuleTypeCode()).append(";\n\n");
        HashMap<String, String> myEntityMap = Maps.newHashMap(); // k,v => caseSumNew,CaseSumNewWrapper
        // 2.匯入 entity 對應執行類
        ruleSetDef.getEntitys().forEach(d -> {
            String cls = d.getCls();
            drl.append("import ").append(cls).append(";\n\n");
            myEntityMap.put(d.getAlias(), cls.substring(cls.lastIndexOf('.') + 1));
        });
        // 3.規則指令碼註釋
        drl.append("// ").append(rule.getRuleTypeCode()).append(" : ").append(rule.getRuleTypeName()).append("\n");
        drl.append("// version : ").append(rule.getCode()).append("\n");
        drl.append("// createTime : ").append(DateUtil.getSysDate(DateUtil.PATTERN_TIME_DEFAULT)).append("\n\n");
 
        Map<String, String> myResultMap = def.getResultDefs().stream().collect(Collectors.toMap(DroolsRuleCondBO::getCondKey, DroolsRuleCondBO::getScript));
 
        // 4.寫規則
        AtomicInteger maxRowSize = new AtomicInteger(0); // 總規則數
        rule.getTables().forEach(table -> {
            String tableCode = table.getTableCode();
            table.getRows().stream().filter(r -> !Objects.equals(r.getStatus(), 3))
           .forEach(row -> {
                // 3.1.規則屬性及優先順序
                drl.append("// generated from row: ").append(row.getRowCode()).append("\n");
                //TODO 需要保證row.getRowSort()不重複，否則生成同樣的規則編號
                drl.append("rule \"").append(rule.getRuleTypeCode()).append("_").append(tableCode).append("_TR_").append(row.getRowSort()).append("\"\n");  // pkg_tableCode_TR_rowSort
                drl.append("\tsalience ").append((maxRowSize.incrementAndGet())).append("\n");
 
                // 4.2.條件判定
                drl.append("\twhen\n");
                // 每個entity一行,多條件合併
                // when=condEntityKey:cls(condKeyMethod colOperator.drlStr colValue), 其中cls=myEntityMap.value(key=condEntityKey)
                drl.append(
                        row.getColumns()
                                .stream().collect(Collectors.groupingBy(d -> d.getCondition().getCondEntityKey()))
                                .entrySet().stream()
                                .map(entityType -> "\t\t" + entityType.getKey() + ":" + myEntityMap.get(entityType.getKey()) + "(" +
                                        entityType.getValue().stream()
                                                .filter(col -> StringUtils.isNotBlank(col.getColValue())) // 排除無效條件
                                                .sorted(Comparator.comparing(col -> col.getCondition().getCondSort())) // 排序
                                                .map(col -> {
                                                    String condKey = col.getCondition().getCondKey();
                                                    String condKeyMethod = condKey.substring(condKey.indexOf('.') + 1);
                                                    String[] exec = ParamTypeHelper.get(col.getColOperator()).getDrlStr(condKeyMethod, col.getColValue());
                                                    if (exec.length > 0) {
                                                        return Arrays.stream(exec).filter(StringUtils::isNotBlank).collect(Collectors.joining(" && "));
                                                    }
                                                    return null;
                                                })
                                                .collect(Collectors.joining(" && ")) + ")\n"
                                )
                                .collect(Collectors.joining()));
 
                // 4.3.規則結果
                drl.append("\tthen\n");
                row.getResults().forEach(r -> {
                    String script = myResultMap.get(r.getResultKey());
                    drl.append("\t\t").append(script.replace("@param", r.getResultValue())).append("\n"); // 使用 resultValue 替換 @param
                });
                drl.append("end\n\n");
            });
        });
        return drl.toString();
    }

//核心流程程式碼：
KnowledgeBuilder kb = KnowledgeBuilderFactory.newKnowledgeBuilder();
kb.add(ResourceFactory.newByteArrayResource(script.getBytes(StandardCharsets.UTF_8)), ResourceType.DRL); //script為規則指令碼
InternalKnowledgeBase base = KnowledgeBaseFactory.newKnowledgeBase();
KieSession ksession = base.newKieSession();
AgendaFilter filter = RuleConstant.DroolsRuleNameFilter.getFilter(ruleTypeCode);//獲取一個過濾器
kSession.insert(fact);
kSession.fireAllRules(filter);
kSession.dispose();