package rules; ???????????????????????????????????????????????// 規則包名路徑

import com.xxx.vo.ProductManageVo ???????????// 引入類
import com.xxx.BackList
import com.xxx.service.ProductRiskService
import java.util.HashMap
import java.util.Map

dialect "java" ???????????????????????????????????????????????// 定于語言,標識規則中的代碼表達式
global ProductRiskService productRiskService ?????????????????// 引入外部服務

rule "1001_product" ??????????????????????????????????????????// 規則名稱，全局唯一
????salience 1001 ????????????????????????????????????????????// 規則優先級，值越大越先執行
????lock-on-active true ??????????????????????????????????????// 事件是否重復執行該規則?true 至執行一次
????when ?????????????????????????????????????????????????????// 條件判斷關鍵字
????????event:ProductManageVo() ??????????????????????????????// 條件判斷,是否需要進入action-判斷事件對象是否是ProductManageVo對象并賦值于event
????then ?????????????????????????????????????????????????????// 執行事件關鍵字
????????if(event.getThirdPrice().doubleValue()/event.getTopPrice() <= 0.5){ ?// 事件業務邏輯,支持java編碼
????????????Map<String,Object> ruleContent = new HashMap<>();
????????????ruleContent.put("thirdPrice",event.getThirdPrice().doubleValue());
????????????ruleContent.put("topPrice",event.getTopPrice());
????????????ruleContent.put("message","三方價格小于TOP原價5折");
????????????productRiskService.saveProductRiskInfo("1001_product",event,ruleContent);
????????}
????end ??????????????????????????????????????????????????????????// 規則結束關鍵字

約束

描述

!.

使用此運算符可以以空安全的方式取消引用屬性。!.運算符左側的值不能為null（解釋為!= null）

[]

按List索引訪問值或Map按鍵訪問值

<，<=，>，>=

在具有自然順序的屬性上使用這些運算符

==, !=

在約束中使用這些運算符作為equals()和!equals()方法

&&，||

組合關系條件

matches，not matches

使用這些運算符可以指示字段與指定的Java正則表達式匹配或不匹配

contains，not contains

使用這些運算符可以驗證Array或字段是否包含或不包含指定值

memberOf，not memberOf

使用這些運算符可以驗證字段是否為定義為變量Array的成員

soundslike

使用英語發音來驗證單詞是否具有與給定值幾乎相同的聲音（類似于該matches運算符）

in，notin

使用這些運算符可以指定一個以上的可能值來匹配約束（復合值限制）

<dependency>
????<groupId>org.drools</groupId>
????<artifactId>drools-compiler</artifactId>
????<version>6.4.0.Final</version>
????<scope>runtime</scope>
</dependency>
<dependency>
????<groupId>org.kie</groupId>
????<artifactId>kie-ci</artifactId>
????<version>6.4.0.Final</version>
</dependency>

@Service
@Slf4j
public class KieServiceImpl implements KieService {

????private StatelessKieSession kieSession;

????private KnowledgeBase kbase = KnowledgeBaseFactory.newKnowledgeBase();

????@Resource
????private RiskConfigService riskConfigService;
????//商品規則處理
????@Resource
????private ProductRiskService productRiskService;

????@Override
????public void loadRules(String ruleCode) {
????????RiskConfig riskConfig = riskConfigService.queryRiskConfig(ruleCode);
????????if(riskConfig!=null){
????????????loadRule(ruleCode,riskConfig.getRiskContent());
????????}
????}

????/**
?????* 單一規則下線
?????*
?????* @param ruleName
?????*/
????@Override
????public void removeRule(String ruleName) {
????????if (kbase.getRule("rules", ruleName) != null) {
????????????kbase.removeRule("rules", ruleName);
????????????log.info("remove rule: rules." + ruleName);
????????????kieSession = kbase.newStatelessKieSession();
????????????printRules();
????????} else {
????????????log.error("no rule: rules." + ruleName);
????????}
????}

????/**
?????* 規則引擎執行
?????*
?????* @param object
?????*/
????@Override
????public void execute(Object object) {
????????this.kieSession.execute(object);
????}

????/**
?????* drools全局服務變量
?????*/
????@PostConstruct
????public void init() {
????????loadRulesAll();
????}

????/**
?????* @description: 加載所有規則模板
?????* @param:
?????* @return:
????*/
????private void loadRulesAll() {
????????RiskConfig config = new RiskConfig();
????????List<RiskConfig> riskConfigList = riskConfigService.queryRiskConfigs(config);
????????if(riskConfigList!=null){
????????????for(RiskConfig riskConfig : riskConfigList){
????????????????loadRule(riskConfig.getRiskCode(),riskConfig.getRiskContent());
????????????}
????????}
????}

????/**
?????* 單一規則上線
?????*
?????* @param ruleCode
?????* @param ruleContent
?????*/
????private void loadRule(String ruleCode,String ruleContent){
????????try {
????????????KnowledgeBuilder kbuilder = KnowledgeBuilderFactory.newKnowledgeBuilder();
????????????kbuilder.add(ResourceFactory.newByteArrayResource(ruleContent.getBytes()), ResourceType.DRL);
????????????if(kbuilder.hasErrors()){
????????????????log.error("加載規則模板引擎異常{},{}",ruleCode,kbuilder.getErrors());
????????????????return;
????????????}
????????????kbase.addKnowledgePackages(kbuilder.getKnowledgePackages());
????????????kieSession = kbase.newStatelessKieSession();
????????????printRules();
????????????setGlobal();
????????}catch (Exception e){
????????????log.error("加載規則模板引擎異常",e);
????????}
????}

????/**
?????* @description: 設置全區實現對象
?????* @param:
?????* @return:
????*/
????private void setGlobal(){
????????kieSession.setGlobal("productRiskService", productRiskService);
????}

????/**
?????* 打印規則
?????*/
????private void printRules() {
????????log.info("print rule start: ---------");
???????kbase.getKnowledgePackages().forEach(knowledgePackage ->
????????????????knowledgePackage.getRules().forEach(rule ->
????????????????????????log.info("print rule: " + knowledgePackage.getName() + "." + rule.getName())));
????????log.info("print rule end: ---------");
????}
}