if (ruleTemp != null) {\r
throw new CorrelationException("A rule with the same name already exists.");\r
}\r
- String packageName = deployRule2Engine(correlationRule, ruleCreateRequest.getLoopControlName());\r
+ String packageName = deployRule2Engine(correlationRule);\r
correlationRule.setPackageName(packageName);\r
CorrelationRule result = null;\r
try {\r
int oldEnabled = oldCorrelationRule.getEnabled();\r
String newDes = newCorrelationRule.getDescription();\r
String oldDes = oldCorrelationRule.getDescription();\r
- if (newContent.equals(oldContent) && newEnabled == oldEnabled && newDes.equals(oldDes)) {\r
+ String oldControlLoop = oldCorrelationRule.getClosedControlLoopName();\r
+ String newControlLoop = newCorrelationRule.getClosedControlLoopName();\r
+ if (newContent.equals(oldContent) && newEnabled == oldEnabled\r
+ && newDes.equals(oldDes) && newControlLoop.equals(oldControlLoop)) {\r
return false;\r
}\r
return true;\r
correlationRule.setCreator(userName);\r
correlationRule.setModifier(userName);\r
correlationRule.setEnabled(ruleCreateRequest.getEnabled());\r
+ correlationRule.setClosedControlLoopName(ruleCreateRequest.getLoopControlName());\r
return correlationRule;\r
}\r
\r
correlationRule.setUpdateTime(new Date());\r
correlationRule.setModifier(modifier);\r
correlationRule.setName(ruleName);\r
+ correlationRule.setClosedControlLoopName(ruleUpdateRequest.getLoopControlName());\r
return correlationRule;\r
}\r
\r
return "";\r
}\r
\r
- private String deployRule2Engine(CorrelationRule correlationRule, String loopControlName)\r
- throws CorrelationException {\r
- if (engineWarpper.checkRuleFromEngine(correlationRules2CheckRule(correlationRule)) && (\r
- correlationRule.getEnabled() == RuleMgtConstant.STATUS_RULE_OPEN)) {\r
- return engineWarpper.deployEngine(correlationRules2DeployRule(correlationRule, loopControlName));\r
- }\r
- return "";\r
- }\r
-\r
public RuleQueryListResponse getCorrelationRuleByCondition(\r
RuleQueryCondition ruleQueryCondition) throws CorrelationException {\r
List<CorrelationRule> correlationRule = correlationRuleQueryDao\r
ruleResult4API.setUpdateTime(correlationRule.getUpdateTime());\r
ruleResult4API.setModifier(correlationRule.getModifier());\r
ruleResult4API.setEnabled(correlationRule.getEnabled());\r
+ ruleResult4API.setClosedControlLoopName(correlationRule.getClosedControlLoopName());\r
ruleResult4APIs.add(ruleResult4API);\r
}\r
return ruleResult4APIs;\r
CorrelationDeployRule4Engine correlationDeployRule4Engine = new CorrelationDeployRule4Engine();\r
correlationDeployRule4Engine.setContent(correlationRule.getContent());\r
correlationDeployRule4Engine.setEngineId(correlationRule.getEngineID());\r
- return correlationDeployRule4Engine;\r
- }\r
-\r
- private CorrelationDeployRule4Engine correlationRules2DeployRule(\r
- CorrelationRule correlationRule, String loopControlName) {\r
- CorrelationDeployRule4Engine correlationDeployRule4Engine = new CorrelationDeployRule4Engine();\r
- correlationDeployRule4Engine.setContent(correlationRule.getContent());\r
- correlationDeployRule4Engine.setEngineId(correlationRule.getEngineID());\r
- correlationDeployRule4Engine.setLoopControlName(loopControlName);\r
+ correlationDeployRule4Engine.setLoopControlName(correlationRule.getClosedControlLoopName());\r
return correlationDeployRule4Engine;\r
}\r
\r