pom文件配置一.使用@Configuration 配置，在springboot项目启动时加载
1.配置类2.在service中注入kiession使用3.规则文件内容 二.不使用DRL文件，写在字符串中加载规则
1.使用KieHelper加载规则内容2.根据业务规则，动态生成规则内容字符串。
参考项目
https://github.com/leifchen/hello-drools
pom文件配置7.57.0.Final org.drools drools-bom ${drools.version} pom import org.kie kie-api org.kie kie-spring org.drools drools-compiler runtime
两种使用方式
一.使用@Configuration 配置，在springboot项目启动时加载 1.配置类package com.newland.edc.pub.metainfo.config;
import lombok.extern.slf4j.Slf4j;
import org.kie.api.Kiebase;
import org.kie.api.KieServices;
import org.kie.api.builder.KieBuilder;
import org.kie.api.builder.KieFileSystem;
import org.kie.api.builder.KieRepository;
import org.kie.api.runtime.KieContainer;
import org.kie.api.runtime.KieSession;
import org.kie.internal.io.ResourceFactory;
import org.kie.spring.KModuleBeanFactoryPostProcessor;
import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.core.io.Resource;
import org.springframework.core.io.support.PathMatchingResourcePatternResolver;
import org.springframework.core.io.support.ResourcePatternResolver;
import java.io.IOException;
@Slf4j
@Configuration
public class DroolsConfiguration {
private static final String RULES_PATH = "rules/";
@Bean
@ConditionalOnMissingBean(KieFileSystem.class)
public KieFileSystem kieFileSystem() {
KieFileSystem kieFileSystem = KieServices.Factory.get().newKieFileSystem();
for (Resource ruleFile : getRuleFiles()) {
kieFileSystem.write(ResourceFactory.newClassPathResource(RULES_PATH + ruleFile.getFilename(), "UTF-8"));
}
return kieFileSystem;
}
@Bean
@ConditionalOnMissingBean(KieContainer.class)
public KieContainer kieContainer() {
System.setProperty("drools.dateformat","yyyy-MM-dd");
KieRepository kieRepository = KieServices.Factory.get().getRepository();
kieRepository.addKieModule(kieRepository::getDefaultReleaseId);
KieBuilder kieBuilder = KieServices.Factory.get().newKieBuilder(kieFileSystem());
kieBuilder.buildAll();
return KieServices.Factory.get().newKieContainer(kieRepository.getDefaultReleaseId());
}
@Bean
@ConditionalOnMissingBean(Kiebase.class)
public Kiebase kiebase() {
return kieContainer().getKiebase();
}
@Bean
@ConditionalOnMissingBean(KieSession.class)
public KieSession kieSession() {
return kieContainer().newKieSession();
}
@Bean
@ConditionalOnMissingBean(KModuleBeanFactoryPostProcessor.class)
public KModuleBeanFactoryPostProcessor kModuleBeanFactoryPostProcessor(){
return new KModuleBeanFactoryPostProcessor();
}
private Resource[] getRuleFiles() {
Resource[] resources = new Resource[0];
ResourcePatternResolver resourcePatternResolver = new PathMatchingResourcePatternResolver();
try {
resources = resourcePatternResolver.getResources("classpath*:" + RULES_PATH + "**
private String generateRuleString(StandardRuleBean ruleBean) {
StandardRuleBean standardRule = this.getStandardRule(ruleBean.getRuleId());
//获取获取启停配置详情
List actionStrategyDetail = this.getActionStrategyDetail(ruleBean.getRuleId());
//查询规则操作符
List typeIdList = new ArrayList<>();
typeIdList.add("8002");
List operatorValueList = this.mdiDicCommonDao.getDicValueList(typeIdList);
StringBuilder ruleSB = new StringBuilder();
//根据设计规则详情，生成正则表达式提取数据标准值进行匹配 rulevalueType 1 的是自定义
StringBuilder pattern = new StringBuilder();
pattern.append("^"); //限制开头
List keywordList = new ArrayList<>();
String tableNameInstance = ""; //表名示例
for (StandardRuleDetailBean bean : standardRule.getRulevalueList()
) {
if (1 == bean.getRulevalueType()) {
pattern.append(bean.getRulevalue());
tableNameInstance = tableNameInstance + bean.getRulevalue();
} else {
pattern.append("([A-Za-z0-9]+)");
keywordList.add(bean.getRulevalue());
if ("A_CLASS_COMMENT".equalsIgnoreCase(bean.getRulevalue())) {
tableNameInstance += "分层名称";
} else if ("A_PATH_COMMENT".equalsIgnoreCase(bean.getRulevalue())) {
tableNameInstance += "分域名称";
}else if ("A_LEXICON".equalsIgnoreCase(bean.getRulevalue())) {
tableNameInstance += "词汇库";
}else if ("A_2".equalsIgnoreCase(bean.getRulevalue())) {
tableNameInstance += "数据周期";
}
}
}
pattern.append("$");//限制结尾
// 用于匹配的数据标准列表
String keywordStr = "String[] keywordList = {"";
String join = String.join("","", keywordList);
keywordStr += join;
keywordStr += ""}";
ruleSB.append("package rulesn" +
"n" +
"n" +
"import com.newland.edc.pub.metainfo.mdi.entity.model.*;n" +
"import com.newland.edc.pub.metainfo.standard.code.model.*;n" +
"import java.util.Listn" +
"import java.util.Mapn" +
"import java.util.regex.Matchern" +
"import java.util.regex.Patternn" +
"import java.lang.Stringn" +
"import java.util.HashMapn" +
"import org.apache.commons.lang3.StringUtilsn" +
"import java.util.Arraysn" +
"import com.newland.edc.pub.metainfo.util.metaConstn" +
"import java.util.ArrayListn" +
"n" +
"global List> errListn" +
"global EntityBean entityn" +
"global List codeListn" +
"global List hierarchyListn" +
"global List domainListn" +
"global List dataCycleListn" +
"global org.slf4j.Logger logn" +
"n" +
"//检查物理表名n");
ruleSB.append("rule "checkStandardCodeEntityNameKeyWord_" + ruleBean.getRuleId() + """);
ruleSB.append("n whenn" +
" eval(1 == ");
ruleSB.append(ruleBean.getIsApply() == null ? 0 : ruleBean.getIsApply());
ruleSB.append(") //启用状态");
ruleSB.append("");
ruleSB.append(" n $entity:EntityBean( ");
List whenList = new ArrayList<>();
String when = "";
whenList.add("n tt rootTenantId matches "" + standardRule.getRootTenantId() + """);
if (null != actionStrategyDetail && actionStrategyDetail.size() > 0) {
for (ConfigurationSwitchBean bean : actionStrategyDetail
) {
// 等于操作符 1 为单值匹配
// 稽核时设置 数据周期(entityDesc)、分域名称(pathId )、分层名称(entityComment) 的 中文名，用于作用策略的校验
if ("1".equals(bean.getRuleOperator())) {
when = "n tt ";
if ("A_10".equalsIgnoreCase(bean.getAttrId())) { // 资源类型
when = when + "resourceType";
} else if ("A_PATH_COMMENT".equalsIgnoreCase(bean.getAttrId())) { // 分域中文名
when = when + "pathId";
} else if ("A_CLASS_COMMENT".equalsIgnoreCase(bean.getAttrId())) { // 分层中文名
when = when + "entityComment";
} else if ("A_2".equalsIgnoreCase(bean.getAttrId())) { // 数据周期
when = when + "entityDesc";
}
when = when + " matches "" + bean.getAttrValue().trim().replace(" ", "") + "" //等于 ";
whenList.add(when);
} else { //其他操作符 非1 为多值匹配
// 2 包含 3 不包含 4 开头 5 结尾
String[] arrValueList = bean.getAttrValue().split("\$");
String matches = "(";
List itemList = new ArrayList<>();
for (String str : arrValueList
) {
String tempStr = "";
if ("A_10".equalsIgnoreCase(bean.getAttrId())) { // 资源类型
tempStr = tempStr + "resourceType";
} else if ("A_PATH_COMMENT".equalsIgnoreCase(bean.getAttrId())) { // 分域中文名
tempStr = tempStr + "pathId";
} else if ("A_CLASS_COMMENT".equalsIgnoreCase(bean.getAttrId())) { // 分层中文名
tempStr = tempStr + "entityComment";
} else if ("A_2".equalsIgnoreCase(bean.getAttrId())) { // 数据周期
tempStr = tempStr + "entityDesc";
}
// 2 包含 3 不包含 4 开头 5 结尾
if ("2".equals(bean.getRuleOperator())) {
tempStr = tempStr + " matches ".*" + str + ".*"";
} else if ("3".equals(bean.getRuleOperator())) {
tempStr = tempStr + " not matches ".*" + str + ".*"";
} else if ("4".equals(bean.getRuleOperator())) {
tempStr = tempStr + " matches "" + str + ".*"";
} else if ("5".equals(bean.getRuleOperator())) {
tempStr = tempStr + " matches ".*" + str + """;
}
itemList.add(tempStr);
}
matches = matches + String.join(" || ", itemList);
if ("2".equals(bean.getRuleOperator())) {
matches = matches + ") //包含";
} else if ("3".equals(bean.getRuleOperator())) {
matches = matches + ") //不包含";
} else if ("4".equals(bean.getRuleOperator())) {
matches = matches + ") // 开头";
} else if ("5".equals(bean.getRuleOperator())) {
matches = matches + ") // 结尾";
}
whenList.add(matches);
}
}
}
ruleSB.append(String.join("n ttt &&", whenList));
ruleSB.append(" n )");
ruleSB.append(" n thenn" +
" ");
// 规则执行内容
ruleSB.append(" n tt" + keywordStr +
" ;n Pattern p= Pattern.compile("" + pattern.toString() + ""); n" +
" Matcher matcher =p.matcher(entity.getEntityName());n " +
" log.info("解析的正则:【{}】，待解析的字符串:【{}】",""+pattern.toString()+"",entity.getEntityName());n " +
" log.info("数据标准列表:{}",Arrays.toString(keywordList));n " +
" if (!matcher.find() ) {n" +
" Map errMap= new HashMap<>();n" +
" errMap.put("type","base");n" +
" errMap.put("name","");n" +
" errMap.put("keyword","");n" +
" errMap.put("ruleName","" + standardRule.getRuleName() + "");n" +
" errMap.put("err","表名不符合【"+tableNameInstance+"】");n" +
" errList.add(errMap);n" +
" } else {n" +
" for(int i = 1; i <= matcher.groupCount(); i++) {n" +
" log.info("待匹配的值:{},对应的数据标准编码:{} ",matcher.group(i),keywordList[i-1] ); n" +
" if ( "A_CLASS_COMMENT".equalsIgnoreCase(keywordList[i-1]) ) {n" +
" //分层判断n" +
" log.info("进入分层判断:{} ",matcher.group(i) ); n" +
" matcheWithStandardCode( matcher.group(i),"" + standardRule.getRuleName() + "","分层名称英文简称",hierarchyList,entity.getEntityName(), errList);n" +
" } else if ( "A_PATH_COMMENT".equalsIgnoreCase(keywordList[i-1]) ){n" +
" //分域判断n" +
" log.info("进入分域判断:{} ",matcher.group(i) ); n" +
" matcheWithStandardCode( matcher.group(i),"" + standardRule.getRuleName() + "","分域名称英文简称",domainList,entity.getEntityName(), errList);n" +
" } else if ( "A_2".equalsIgnoreCase(keywordList[i-1]) ){n" +
" //数据周期n" +
" log.info("进入数据周期判断:{} ",matcher.group(i) ); n" +
" matcheWithStandardCode( matcher.group(i),"" + standardRule.getRuleName() + "","数据周期英文简称",dataCycleList,entity.getEntityName(), errList);n" +
" } else {n" +
" log.info("进入词汇判断:{} ",matcher.group(i) ); n" +
" //词汇判断n" +
" matcheWithStandardCode( matcher.group(i),"" + standardRule.getRuleName() + "","词汇英文简称",codeList,entity.getEntityName(), errList);n" +
" }n" +
" }n" +
" }n" +
" ");
ruleSB.append("n" +
"end");
return ruleSB.toString();
}
