|
|
@@ -29,7 +29,7 @@ public class DynamicRuleManager {
|
|
|
private final AtomicReference<KieContainer> currentKieContainer = new AtomicReference<>();
|
|
|
|
|
|
// 记录每条规则的当前版本(key:规则唯一标识,如名称或ID;value:版本号)
|
|
|
- private Map<String, Integer> ruleVersionMap = new HashMap<>();
|
|
|
+ private Map<String, String> ruleVersionMap = new HashMap<>();
|
|
|
|
|
|
public DynamicRuleManager(RuleDefinitionsService ruleDefinitionsService) {
|
|
|
this.ruleDefinitionsService = ruleDefinitionsService;
|
|
|
@@ -112,8 +112,8 @@ public class DynamicRuleManager {
|
|
|
// 检查新规则中是否有版本变化或新增规则
|
|
|
for (RuleDefinitionsDO rule : newRules) {
|
|
|
String ruleName = rule.getName();
|
|
|
- Integer newVersion = rule.getVersion();
|
|
|
- Integer currentVersion = ruleVersionMap.get(ruleName);
|
|
|
+ String newVersion = rule.getVersion();
|
|
|
+ String currentVersion = ruleVersionMap.get(ruleName);
|
|
|
|
|
|
// 规则新增(当前版本Map中无此规则)或版本提升,需要更新
|
|
|
if (currentVersion == null || !currentVersion.equals(newVersion)) {
|
|
|
@@ -137,7 +137,7 @@ public class DynamicRuleManager {
|
|
|
* 更新规则版本Map(存储当前所有规则的最新版本)
|
|
|
*/
|
|
|
private void updateRuleVersionMap(List<RuleDefinitionsDO> newRules) {
|
|
|
- Map<String, Integer> newVersionMap = new HashMap<>();
|
|
|
+ Map<String, String> newVersionMap = new HashMap<>();
|
|
|
for (RuleDefinitionsDO rule : newRules) {
|
|
|
newVersionMap.put(rule.getName(), rule.getVersion());
|
|
|
}
|