一,背景
项目中有需要根据规则计算不同收费方费用的需求,后面还会有券、满减、限时折扣之类的规则,同时需要配合不同运营活动动态配置,这些需求对计算的灵活性要求比较高。
Drools是比较常用的规则引擎,可以自己定义计算规则,简化项目代码中的逻辑。
Nacos是Spring Cloud中的常用的配置中心和注册中心,可以动态读取最新的配置。
二,实现
1,Maven引入
<dependency>
<groupId>org.drools</groupId>
<artifactId>drools-compiler</artifactId>
<version>7.74.1.Final</version>
</dependency>
<dependency>
<groupId>org.drools</groupId>
<artifactId>drools-core</artifactId>
<version>7.74.1.Final</version>
</dependency>
<dependency>
<groupId>org.drools</groupId>
<artifactId>drools-templates</artifactId>
<version>7.74.1.Final</version>
</dependency>
<dependency>
<groupId>org.kie</groupId>
<artifactId>kie-api</artifactId>
<version>7.74.1.Final</version>
</dependency>
<dependency>
<groupId>org.kie</groupId>
<artifactId>kie-spring</artifactId>
<version>7.74.1.Final</version>
</dependency>
<dependency>
<groupId>com.alibaba.cloud</groupId>
<artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
</dependency>
<dependency>
<groupId>com.alibaba.cloud</groupId>
<artifactId>spring-cloud-starter-alibaba-nacos-config</artifactId>
</dependency>
2,Drools工具类
@Slf4j
@Configuration
public class DroolsConfig {
private final ExtensionConfig extensionConfig;
private KieBase kieBase;
public DroolsConfig(ExtensionConfig extensionConfig,
NacosConfigManager configManager) throws NacosException {
this.extensionConfig = extensionConfig;
ConfigService configService = configManager.getConfigService();
configService.addListener( SysConstant.DROOLS_DATA_ID, SysConstant.GROUP, new AbstractListener() {
@Override
public void receiveConfigInfo(String config) {
("=====>Drools profit规则更新: {}", config);
//重新获取规则
kieBase = null;
}
});
}
/**
* 调用Drools根据规则计算
*
* @param feePackageDTO
*/
public void getDroolsResult(FeePackageDTO feePackageDTO) {
if (Objects.isNull(kieBase)) {
kieBase = getKieBase();
}
KieSession kieSession = kieBase.newKieSession();
kieSession.insert(feePackageDTO);
kieSession.fireAllRules();
kieSession.destroy();
}
/**
* 重新获取规则
*
* @return
*/
private KieBase getKieBase() {
KieHelper kieHelper = new KieHelper();
kieHelper.addContent(extensionConfig.getContent(), ResourceType.DRL);
this.kieBase = kieHelper.build();
return this.kieBase;
}
}
3,项目启动文件中Nacos配置
# 共享配置
extension-configs:
- data-id: drools-rule
group: DEFAULT_GROUP
file-extension: text
refresh: true
4,动态读取Nacos更新内容
@Configuration
@RefreshScope
@Slf4j
@Data
public class ExtensionConfig {
private String content;
public ExtensionConfig(NacosConfigManager configManager) {
try {
ConfigService configService = configManager.getConfigService();
// 直接从Nacos Config Service获取text配置内容
this.content = configService.getConfig("drools-rule", "default_group", 5000);
} catch (Exception e) {
log.error("获取drools配置异常", e);
}
}
}
5, Nacos中Drools规则配置
5.1, 规则: 配置里必须包含rule, when, then, end。
5.2,优先级: 每一条规则都有一个salience属性,这个属性可以决定规则的执行顺序。在内部匹配队里里面,优先级越高的规则,执行顺序越靠前。默认的优先级的值是0,优先级的值可以是正数,也可以是负数。
5.3,高级配置:
Drools用户手册翻译——第四章 Drools规则引擎(六)执行控制_drools如何执行不同group的规则-CSDN博客
https:///huan1993/p/16284781.html
下面是在nacos中的配置: 格式是text, data-id是drools-rule(随意命名, 只要和项目启动文件里的data-id一致就可以)
package com.xxx.xxx.xxx.drools
import com.xxx.xxx.xxx.drools.FeePackageDTO
import java.math.BigDecimal
// 三方分润模式
rule "tripartite profit sharing"
when
$feePackageDTO: FeePackageDTO(feeModeCode==1)
then
// 商户总费率
BigDecimal rate = new BigDecimal($feePackageDTO.getRate());
$feePackageDTO.setPlatformRate(new BigDecimal($feePackageDTO.getPlatformRate()).multiply(rate).toString());
$feePackageDTO.setChannelRate(new BigDecimal($feePackageDTO.getChannelRate()).multiply(rate).toString());
$feePackageDTO.setProxyRate(rate.subtract(new BigDecimal($feePackageDTO.getChannelRate())).subtract(new BigDecimal($feePackageDTO.getPlatformRate())).toString());
System.out.println("三方分润模式-银行分润比例:" + $feePackageDTO.getChannelRate());
System.out.println("三方分润模式-代理商分润比例:" + $feePackageDTO.getProxyRate());
System.out.println("三方分润模式-XXX分润比例:" + $feePackageDTO.getPlatformRate());
end
6,使用Drools计算费率
private void calcRateWithCostMode(TransFeeDTO transFeeDTO) {
FeePackageDTO dto = new FeePackageDTO();
dto.setFeeModeCode(transFeeDTO.getFeeMode().getCode());
//drools引擎计算费率
("=====>Drools计算参数: {}", JSONUtil.toJsonStr(dto));
droolsConfig.getDroolsResult(dto);
transFeeDTO.setRate(dto.getRate());
transFeeDTO.setChannelRate(dto.getChannelRate());
transFeeDTO.setProxyRate(dto.getProxyRate());
transFeeDTO.setPlatformRate(dto.getPlatformRate());
("=====>Drools计算出的费率: {}", JSONUtil.toJsonStr(transFeeDTO));
}
三,总结
通过Nacos读取动态配置,结合Drools,实现动态规则引擎,可以满足大部分场景的费用计算,需要对计算规则调整时,只需要在Nacos中修改规则就好了,不用修改项目代码,也不用重新部署项目。