Add module holms-rule-management code

Issue-ID:HOLMES-4

Change-Id: I3a22053acfdf0789acb6fcbbc5e8740d25d6b2eb
Signed-off-by: youbowu <wu.youbo@zte.com.cn>

16 files changed, 1065 insertions, 6 deletions

diff --git a/rulemgt/pom.xml b/rulemgt/pom.xml
index 8fd548f..ac28b37 100644
--- a/rulemgt/pom.xml
+++ b/rulemgt/pom.xml
@@ -30,6 +30,10 @@
 
     <dependencies>
         <dependency>
+            <groupId>org.openo.holmes.actions</groupId>
+            <artifactId>holmes-actions</artifactId>
+        </dependency>
+        <dependency>
             <groupId>junit</groupId>
             <artifactId>junit</artifactId>
         </dependency>
@@ -49,42 +53,36 @@
             <groupId>io.dropwizard</groupId>
             <artifactId>dropwizard-db</artifactId>
         </dependency>
-
         <dependency>
             <groupId>org.hamcrest</groupId>
             <artifactId>hamcrest-library</artifactId>
             <version>1.3</version>
             <scope>test</scope>
         </dependency>
-
         <dependency>
             <groupId>org.powermock</groupId>
             <artifactId>powermock-module-junit4</artifactId>
             <version>1.4.10</version>
             <scope>test</scope>
         </dependency>
-
         <dependency>
             <groupId>org.powermock</groupId>
             <artifactId>powermock-api-easymock</artifactId>
             <version>1.4.10</version>
             <scope>test</scope>
         </dependency>
-
         <dependency>
             <groupId>org.easymock</groupId>
             <artifactId>easymock</artifactId>
             <version>3.0</version>
             <scope>test</scope>
         </dependency>
-
         <dependency>
             <groupId>org.javassist</groupId>
             <artifactId>javassist</artifactId>
             <version>3.15.0-GA</version>
             <scope>test</scope>
         </dependency>
-
     </dependencies>
     <build>
         <plugins>
@@ -101,6 +99,15 @@
             </plugin>
             <plugin>
                 <groupId>org.apache.maven.plugins</groupId>
+                <artifactId>maven-compiler-plugin</artifactId>
+                <version>3.3</version>
+                <configuration>
+                    <source>1.8</source>
+                    <target>1.8</target>
+                </configuration>
+            </plugin>
+            <plugin>
+                <groupId>org.apache.maven.plugins</groupId>
                 <artifactId>maven-shade-plugin</artifactId>
                 <configuration>
                     <createDependencyReducedPom>true</createDependencyReducedPom>
diff --git a/rulemgt/src/main/java/org/openo/holmes/rulemgt/bean/request/CorrelationDeployRule4Engine.java b/rulemgt/src/main/java/org/openo/holmes/rulemgt/bean/request/CorrelationDeployRule4Engine.java
new file mode 100644
index 0000000..3ed4c4d
--- /dev/null
+++ b/rulemgt/src/main/java/org/openo/holmes/rulemgt/bean/request/CorrelationDeployRule4Engine.java
@@ -0,0 +1,31 @@
+/**

+ * Copyright 2017 ZTE Corporation.

+ *

+ * Licensed under the Apache License, Version 2.0 (the "License");

+ * you may not use this file except in compliance with the License.

+ * You may obtain a copy of the License at

+ *

+ *     http://www.apache.org/licenses/LICENSE-2.0

+ *

+ * Unless required by applicable law or agreed to in writing, software

+ * distributed under the License is distributed on an "AS IS" BASIS,

+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.

+ * See the License for the specific language governing permissions and

+ * limitations under the License.

+ */

+package org.openo.holmes.rulemgt.bean.request;

+

+import com.fasterxml.jackson.annotation.JsonProperty;

+import lombok.Getter;

+import lombok.Setter;

+

+@Getter

+@Setter

+public class CorrelationDeployRule4Engine {

+    @JsonProperty(value = "content")

+    private String content;

+

+    @JsonProperty(value = "engineid")

+    private String engineId;

+

+}

diff --git a/rulemgt/src/main/java/org/openo/holmes/rulemgt/bean/request/RuleCreateRequest.java b/rulemgt/src/main/java/org/openo/holmes/rulemgt/bean/request/RuleCreateRequest.java
new file mode 100644
index 0000000..9407b99
--- /dev/null
+++ b/rulemgt/src/main/java/org/openo/holmes/rulemgt/bean/request/RuleCreateRequest.java
@@ -0,0 +1,33 @@
+/**

+ * Copyright 2017 ZTE Corporation.

+ *

+ * Licensed under the Apache License, Version 2.0 (the "License");

+ * you may not use this file except in compliance with the License.

+ * You may obtain a copy of the License at

+ *

+ *     http://www.apache.org/licenses/LICENSE-2.0

+ *

+ * Unless required by applicable law or agreed to in writing, software

+ * distributed under the License is distributed on an "AS IS" BASIS,

+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.

+ * See the License for the specific language governing permissions and

+ * limitations under the License.

+ */

+package org.openo.holmes.rulemgt.bean.request;

+

+import com.fasterxml.jackson.annotation.JsonProperty;

+import lombok.Getter;

+import lombok.Setter;

+

+@Setter

+@Getter

+public class RuleCreateRequest {

+    @JsonProperty(value = "rulename")

+    private String ruleName;

+    @JsonProperty

+    private String description;

+    @JsonProperty

+    private String content;

+    @JsonProperty

+    private int enabled;

+}

diff --git a/rulemgt/src/main/java/org/openo/holmes/rulemgt/bean/request/RuleDeleteRequest.java b/rulemgt/src/main/java/org/openo/holmes/rulemgt/bean/request/RuleDeleteRequest.java
new file mode 100644
index 0000000..ac9d795
--- /dev/null
+++ b/rulemgt/src/main/java/org/openo/holmes/rulemgt/bean/request/RuleDeleteRequest.java
@@ -0,0 +1,28 @@
+/**

+ * Copyright 2017 ZTE Corporation.

+ *

+ * Licensed under the Apache License, Version 2.0 (the "License");

+ * you may not use this file except in compliance with the License.

+ * You may obtain a copy of the License at

+ *

+ *     http://www.apache.org/licenses/LICENSE-2.0

+ *

+ * Unless required by applicable law or agreed to in writing, software

+ * distributed under the License is distributed on an "AS IS" BASIS,

+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.

+ * See the License for the specific language governing permissions and

+ * limitations under the License.

+ */

+package org.openo.holmes.rulemgt.bean.request;

+

+import com.fasterxml.jackson.annotation.JsonProperty;

+import lombok.Getter;

+import lombok.Setter;

+

+

+@Setter

+@Getter

+public class RuleDeleteRequest {

+    @JsonProperty(value = "ruleid")

+    private String ruleId;

+}

diff --git a/rulemgt/src/main/java/org/openo/holmes/rulemgt/bean/request/RuleQueryCondition.java b/rulemgt/src/main/java/org/openo/holmes/rulemgt/bean/request/RuleQueryCondition.java
new file mode 100644
index 0000000..c68b40d
--- /dev/null
+++ b/rulemgt/src/main/java/org/openo/holmes/rulemgt/bean/request/RuleQueryCondition.java
@@ -0,0 +1,34 @@
+/**

+ * Copyright 2017 ZTE Corporation.

+ *

+ * Licensed under the Apache License, Version 2.0 (the "License");

+ * you may not use this file except in compliance with the License.

+ * You may obtain a copy of the License at

+ *

+ *     http://www.apache.org/licenses/LICENSE-2.0

+ *

+ * Unless required by applicable law or agreed to in writing, software

+ * distributed under the License is distributed on an "AS IS" BASIS,

+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.

+ * See the License for the specific language governing permissions and

+ * limitations under the License.

+ */

+package org.openo.holmes.rulemgt.bean.request;

+

+import com.fasterxml.jackson.annotation.JsonProperty;

+import lombok.Getter;

+import lombok.Setter;

+

+@Getter

+@Setter

+public class RuleQueryCondition {

+

+    @JsonProperty(value = "ruleid")

+    private String rid;

+    @JsonProperty(value = "rulename")

+    private String name;

+    private int enabled;

+    private String creator;

+    private String modifier;

+

+}

diff --git a/rulemgt/src/main/java/org/openo/holmes/rulemgt/bean/request/RuleUpdateRequest.java b/rulemgt/src/main/java/org/openo/holmes/rulemgt/bean/request/RuleUpdateRequest.java
new file mode 100644
index 0000000..6ce265a
--- /dev/null
+++ b/rulemgt/src/main/java/org/openo/holmes/rulemgt/bean/request/RuleUpdateRequest.java
@@ -0,0 +1,33 @@
+/**

+ * Copyright 2017 ZTE Corporation.

+ *

+ * Licensed under the Apache License, Version 2.0 (the "License");

+ * you may not use this file except in compliance with the License.

+ * You may obtain a copy of the License at

+ *

+ *     http://www.apache.org/licenses/LICENSE-2.0

+ *

+ * Unless required by applicable law or agreed to in writing, software

+ * distributed under the License is distributed on an "AS IS" BASIS,

+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.

+ * See the License for the specific language governing permissions and

+ * limitations under the License.

+ */

+package org.openo.holmes.rulemgt.bean.request;

+

+import com.fasterxml.jackson.annotation.JsonProperty;

+import lombok.Getter;

+import lombok.Setter;

+

+@Getter

+@Setter

+public class RuleUpdateRequest {

+    @JsonProperty

+    private String description;

+    @JsonProperty

+    private String content;

+    @JsonProperty

+    private int enabled;

+    @JsonProperty(value="ruleid")

+    private String ruleId;

+}

diff --git a/rulemgt/src/main/java/org/openo/holmes/rulemgt/bean/response/RuleAddAndUpdateResponse.java b/rulemgt/src/main/java/org/openo/holmes/rulemgt/bean/response/RuleAddAndUpdateResponse.java
new file mode 100644
index 0000000..e5597b8
--- /dev/null
+++ b/rulemgt/src/main/java/org/openo/holmes/rulemgt/bean/response/RuleAddAndUpdateResponse.java
@@ -0,0 +1,29 @@
+/**

+ * Copyright 2017 ZTE Corporation.

+ *

+ * Licensed under the Apache License, Version 2.0 (the "License");

+ * you may not use this file except in compliance with the License.

+ * You may obtain a copy of the License at

+ *

+ *     http://www.apache.org/licenses/LICENSE-2.0

+ *

+ * Unless required by applicable law or agreed to in writing, software

+ * distributed under the License is distributed on an "AS IS" BASIS,

+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.

+ * See the License for the specific language governing permissions and

+ * limitations under the License.

+ */

+package org.openo.holmes.rulemgt.bean.response;

+

+import com.fasterxml.jackson.annotation.JsonInclude;

+import com.fasterxml.jackson.annotation.JsonProperty;

+import lombok.Getter;

+import lombok.Setter;

+

+@JsonInclude(JsonInclude.Include.ALWAYS)

+@Getter

+@Setter

+public class RuleAddAndUpdateResponse{

+    @JsonProperty(value="ruleid")

+    private String ruleId;

+}

diff --git a/rulemgt/src/main/java/org/openo/holmes/rulemgt/bean/response/RuleQueryListResponse.java b/rulemgt/src/main/java/org/openo/holmes/rulemgt/bean/response/RuleQueryListResponse.java
new file mode 100644
index 0000000..a720eca
--- /dev/null
+++ b/rulemgt/src/main/java/org/openo/holmes/rulemgt/bean/response/RuleQueryListResponse.java
@@ -0,0 +1,34 @@
+/**

+ * Copyright 2017 ZTE Corporation.

+ *

+ * Licensed under the Apache License, Version 2.0 (the "License");

+ * you may not use this file except in compliance with the License.

+ * You may obtain a copy of the License at

+ *

+ *     http://www.apache.org/licenses/LICENSE-2.0

+ *

+ * Unless required by applicable law or agreed to in writing, software

+ * distributed under the License is distributed on an "AS IS" BASIS,

+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.

+ * See the License for the specific language governing permissions and

+ * limitations under the License.

+ */

+package org.openo.holmes.rulemgt.bean.response;

+

+import com.fasterxml.jackson.annotation.JsonInclude;

+import com.fasterxml.jackson.annotation.JsonProperty;

+import lombok.Getter;

+import lombok.Setter;

+

+import java.util.ArrayList;

+import java.util.List;

+

+@JsonInclude(JsonInclude.Include.ALWAYS)

+@Getter

+@Setter

+public class RuleQueryListResponse {

+    @JsonProperty(value = "rules")

+    private List<RuleResult4API> correlationRules = new ArrayList<RuleResult4API>();

+    @JsonProperty(value = "totalcount")

+    private int totalCount;

+}

diff --git a/rulemgt/src/main/java/org/openo/holmes/rulemgt/bean/response/RuleResult4API.java b/rulemgt/src/main/java/org/openo/holmes/rulemgt/bean/response/RuleResult4API.java
new file mode 100644
index 0000000..ee948d0
--- /dev/null
+++ b/rulemgt/src/main/java/org/openo/holmes/rulemgt/bean/response/RuleResult4API.java
@@ -0,0 +1,42 @@
+/**

+ * Copyright 2017 ZTE Corporation.

+ *

+ * Licensed under the Apache License, Version 2.0 (the "License");

+ * you may not use this file except in compliance with the License.

+ * You may obtain a copy of the License at

+ *

+ *     http://www.apache.org/licenses/LICENSE-2.0

+ *

+ * Unless required by applicable law or agreed to in writing, software

+ * distributed under the License is distributed on an "AS IS" BASIS,

+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.

+ * See the License for the specific language governing permissions and

+ * limitations under the License.

+ */

+package org.openo.holmes.rulemgt.bean.response;

+

+import com.fasterxml.jackson.annotation.JsonInclude;

+import com.fasterxml.jackson.annotation.JsonProperty;

+import lombok.Getter;

+import lombok.Setter;

+

+import java.util.Date;

+

+@JsonInclude(JsonInclude.Include.ALWAYS)

+@Setter

+@Getter

+public class RuleResult4API {

+    @JsonProperty(value = "ruleid")

+    private String ruleId;

+    @JsonProperty(value = "rulename")

+    private String ruleName;

+    private String description;

+    private String content;

+    @JsonProperty(value = "createtime")

+    private Date createTime;

+    private String creator;

+    @JsonProperty(value = "updatetime")

+    private Date updateTime;

+    private String modifier;

+    private int enabled;

+}

diff --git a/rulemgt/src/main/java/org/openo/holmes/rulemgt/bolt/enginebolt/EngineWrapper.java b/rulemgt/src/main/java/org/openo/holmes/rulemgt/bolt/enginebolt/EngineWrapper.java
new file mode 100644
index 0000000..e2f4fdd
--- /dev/null
+++ b/rulemgt/src/main/java/org/openo/holmes/rulemgt/bolt/enginebolt/EngineWrapper.java
@@ -0,0 +1,41 @@
+/**

+ * Copyright 2017 ZTE Corporation.

+ *

+ * Licensed under the Apache License, Version 2.0 (the "License");

+ * you may not use this file except in compliance with the License.

+ * You may obtain a copy of the License at

+ *

+ *     http://www.apache.org/licenses/LICENSE-2.0

+ *

+ * Unless required by applicable law or agreed to in writing, software

+ * distributed under the License is distributed on an "AS IS" BASIS,

+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.

+ * See the License for the specific language governing permissions and

+ * limitations under the License.

+ */

+package org.openo.holmes.rulemgt.bolt.enginebolt;

+

+import lombok.extern.slf4j.Slf4j;

+import org.jvnet.hk2.annotations.Service;

+import org.openo.holmes.common.exception.CallException;

+import org.openo.holmes.rulemgt.bean.request.CorrelationCheckRule4Engine;

+import org.openo.holmes.rulemgt.bean.request.CorrelationDeployRule4Engine;

+

+@Service

+@Slf4j

+public class EngineWrapper {

+

+

+    public String deployEngine(CorrelationDeployRule4Engine correlationRule) throws CallException {

+        return "";

+    }

+

+    public boolean deleteRuleFromEngine(String packageName) throws CallException {

+        return true;

+    }

+

+    public boolean checkRuleFromEngine(CorrelationCheckRule4Engine correlationCheckRule4Engine)

+        throws CallException {

+        return true;

+    }

+}

diff --git a/rulemgt/src/main/java/org/openo/holmes/rulemgt/constant/RuleMgtConstant.java b/rulemgt/src/main/java/org/openo/holmes/rulemgt/constant/RuleMgtConstant.java
new file mode 100644
index 0000000..55c3cd8
--- /dev/null
+++ b/rulemgt/src/main/java/org/openo/holmes/rulemgt/constant/RuleMgtConstant.java
@@ -0,0 +1,23 @@
+/**

+ * Copyright 2017 ZTE Corporation.

+ *

+ * Licensed under the Apache License, Version 2.0 (the "License");

+ * you may not use this file except in compliance with the License.

+ * You may obtain a copy of the License at

+ *

+ *     http://www.apache.org/licenses/LICENSE-2.0

+ *

+ * Unless required by applicable law or agreed to in writing, software

+ * distributed under the License is distributed on an "AS IS" BASIS,

+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.

+ * See the License for the specific language governing permissions and

+ * limitations under the License.

+ */

+package org.openo.holmes.rulemgt.constant;

+

+public class RuleMgtConstant {

+    public static final int STATUS_RULE_OPEN = 1;

+    public static final int STATUS_RULE_CLOSE = 0;

+    public static final int STATUS_RULE_ALL = 2;

+    public static final String PACKAGE_NAME = "packagename";

+}

diff --git a/rulemgt/src/main/java/org/openo/holmes/rulemgt/db/CorrelationRuleDao.java b/rulemgt/src/main/java/org/openo/holmes/rulemgt/db/CorrelationRuleDao.java
new file mode 100644
index 0000000..7a7a0eb
--- /dev/null
+++ b/rulemgt/src/main/java/org/openo/holmes/rulemgt/db/CorrelationRuleDao.java
@@ -0,0 +1,85 @@
+/**

+ * Copyright 2017 ZTE Corporation.

+ *

+ * Licensed under the Apache License, Version 2.0 (the "License");

+ * you may not use this file except in compliance with the License.

+ * You may obtain a copy of the License at

+ *

+ *     http://www.apache.org/licenses/LICENSE-2.0

+ *

+ * Unless required by applicable law or agreed to in writing, software

+ * distributed under the License is distributed on an "AS IS" BASIS,

+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.

+ * See the License for the specific language governing permissions and

+ * limitations under the License.

+ */

+package org.openo.holmes.rulemgt.db;

+

+import org.openo.holmes.common.api.entity.CorrelationRule;

+import org.openo.holmes.rulemgt.db.mapper.CorrelationRuleMapper;

+import org.skife.jdbi.v2.sqlobject.Bind;

+import org.skife.jdbi.v2.sqlobject.BindBean;

+import org.skife.jdbi.v2.sqlobject.GetGeneratedKeys;

+import org.skife.jdbi.v2.sqlobject.SqlQuery;

+import org.skife.jdbi.v2.sqlobject.SqlUpdate;

+import org.skife.jdbi.v2.sqlobject.customizers.RegisterMapper;

+

+import java.util.List;

+

+@RegisterMapper(CorrelationRuleMapper.class)

+public abstract class CorrelationRuleDao {

+    @GetGeneratedKeys

+    @SqlUpdate("INSERT INTO APLUS_RULE  (NAME,DESCRIPTION,ENABLE,TEMPLATEID,ENGINETYPE,CREATOR,UPDATOR,PARAMS,DOMAIN ,CONTENT ,VENDOR,CREATETIME,UPDATETIME,ENGINEID,ISMANUAL,PACKAGE,RID) VALUES (:name,:description,:enabled,:templateID,:engineType,:creator,:modifier,:params,:domain,:content,:vendor,:createTime,:updateTime,:engineId,:isManual,:packageName,:rid)")

+    protected abstract int addRule(@BindBean CorrelationRule correlationRule);

+

+    @SqlUpdate("UPDATE APLUS_RULE SET DESCRIPTION=:description,ENABLE=:enabled,CONTENT=:content,UPDATOR=:modifier,UPDATETIME=:updateTime WHERE RID=:rid")

+    protected abstract int updateRuleByRid(@BindBean CorrelationRule correlationRule);

+

+    @SqlUpdate("DELETE FROM APLUS_RULE WHERE RID=:rid")

+    protected abstract int deleteRuleByRid(@Bind("rid") String rid);

+

+    @SqlUpdate("DELETE FROM APLUS_RULE WHERE RID=:rid AND NAME=:name")

+    protected abstract int deleteRuleByRidAndName(@Bind("rid") String rid, @Bind("name") String name);

+

+    @SqlQuery("SELECT * FROM APLUS_RULE")

+    protected abstract List<CorrelationRule> queryAllRules();

+

+    @SqlQuery("SELECT * FROM APLUS_RULE WHERE RID=:rid")

+    public abstract CorrelationRule queryRuleByRid(@Bind("rid") String rid);

+

+    @SqlQuery("SELECT * FROM APLUS_RULE WHERE NAME=:name")

+    public abstract CorrelationRule queryRuleByName(@Bind("name") String name);

+

+    private void deleteRule2DbInner(CorrelationRule correlationRule) {

+        String name = correlationRule.getName() != null ? correlationRule.getName().trim() : "";

+        String rid = correlationRule.getRid() != null ? correlationRule.getRid().trim() : "";

+        if (!name.equals("") && !rid.equals("")) {

+            deleteRuleByRidAndName(rid, name);

+        } else if (!rid.equals("")) {

+            deleteRuleByRid(rid);

+        }

+    }

+

+    public CorrelationRule saveRule(CorrelationRule correlationRule) {

+        addRule(correlationRule);

+        return correlationRule;

+    }

+

+    public void updateRule(CorrelationRule correlationRule){

+        updateRuleByRid(correlationRule);

+    }

+

+    public void deleteRule(CorrelationRule correlationRule) {

+        deleteRule2DbInner(correlationRule);

+    }

+

+

+    public CorrelationRule getRuleByRid(String rid) {

+        return queryRuleByRid(rid);

+    }

+

+    public CorrelationRule queryRuleByRuleName(String name) {

+        return queryRuleByName(name);

+    }

+}

+

diff --git a/rulemgt/src/main/java/org/openo/holmes/rulemgt/db/CorrelationRuleQueryDao.java b/rulemgt/src/main/java/org/openo/holmes/rulemgt/db/CorrelationRuleQueryDao.java
new file mode 100644
index 0000000..9b66ae5
--- /dev/null
+++ b/rulemgt/src/main/java/org/openo/holmes/rulemgt/db/CorrelationRuleQueryDao.java
@@ -0,0 +1,127 @@
+/**

+ * Copyright 2017 ZTE Corporation.

+ *

+ * Licensed under the Apache License, Version 2.0 (the "License");

+ * you may not use this file except in compliance with the License.

+ * You may obtain a copy of the License at

+ *

+ *     http://www.apache.org/licenses/LICENSE-2.0

+ *

+ * Unless required by applicable law or agreed to in writing, software

+ * distributed under the License is distributed on an "AS IS" BASIS,

+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.

+ * See the License for the specific language governing permissions and

+ * limitations under the License.

+ */

+package org.openo.holmes.rulemgt.db;

+

+import org.openo.holmes.common.api.entity.CorrelationRule;

+import org.openo.holmes.common.exception.DataFormatException;

+import org.openo.holmes.common.exception.DbException;

+import org.openo.holmes.common.utils.DbDaoUtil;

+import org.openo.holmes.common.utils.I18nProxy;

+import org.openo.holmes.rulemgt.bean.request.RuleQueryCondition;

+import org.openo.holmes.rulemgt.constant.RuleMgtConstant;

+import lombok.extern.slf4j.Slf4j;

+import org.jvnet.hk2.annotations.Service;

+import org.skife.jdbi.v2.Handle;

+import org.skife.jdbi.v2.Query;

+

+import javax.inject.Inject;

+import java.beans.PropertyDescriptor;

+import java.lang.reflect.Field;

+import java.lang.reflect.Method;

+import java.util.ArrayList;

+import java.util.Date;

+import java.util.List;

+import java.util.Map;

+import java.util.Properties;

+

+@Service

+@Slf4j

+public class CorrelationRuleQueryDao {

+    @Inject

+    private DbDaoUtil dbDaoUtil;

+

+    public List<CorrelationRule> getCorrelationRulesByCondition(RuleQueryCondition ruleQueryCondition) throws DataFormatException, DbException {

+        List<CorrelationRule> correlationRules = new ArrayList<CorrelationRule>();

+        Handle handle = null;

+        String whereStr = getWhereStrByRequestEntity(ruleQueryCondition);

+        try {

+            StringBuilder querySql = new StringBuilder("SELECT * FROM APLUS_RULE ").append(whereStr);

+            handle = dbDaoUtil.getHandle();

+            Query query = handle.createQuery(querySql.toString());

+            for (Object value : query.list()) {

+                CorrelationRule correlationRule = getCorrelationRule((Map) value);

+                correlationRules.add(correlationRule);

+            }

+            return correlationRules;

+        } catch (Exception e) {

+            log.warn("Query rule: rule id =" + ruleQueryCondition.getRid() + " failed");

+            throw new DbException(I18nProxy.RULE_MANAGEMENT_QUERY_RULE_FAILED, e);

+        } finally {

+            dbDaoUtil.close(handle);

+        }

+    }

+

+    private CorrelationRule getCorrelationRule(Map value) {

+        CorrelationRule correlationRule = new CorrelationRule();

+        correlationRule.setName((String) value.get("name"));

+        correlationRule.setRid((String) value.get("rid"));

+        correlationRule.setDescription((String) value.get("description"));

+        correlationRule.setEnabled((Integer) value.get("enable"));

+        correlationRule.setTemplateID((Integer) value.get("templateID"));

+        correlationRule.setEngineId((String) value.get("engineID"));

+        correlationRule.setEngineType((String) value.get("engineType"));

+        correlationRule.setCreator((String) value.get("creator"));

+        correlationRule.setCreateTime((Date) value.get("createTime"));

+        correlationRule.setModifier((String) value.get("updator"));

+        correlationRule.setUpdateTime((Date) value.get("updateTime"));

+        correlationRule.setParams((Properties) value.get("params"));

+        correlationRule.setDomain((String) value.get("domain"));

+        correlationRule.setContent((String) value.get("content"));

+        correlationRule.setIsManual((Integer) value.get("isManual"));

+        correlationRule.setVendor((String) value.get("vendor"));

+        correlationRule.setPackageName((String) value.get("package"));

+        return correlationRule;

+    }

+

+    private String getWhereStrByRequestEntity(RuleQueryCondition ruleQueryCondition) throws DataFormatException {

+        try {

+            Class clazz = ruleQueryCondition.getClass();

+            Field[] fields = clazz.getDeclaredFields();

+            String whereSql = " WHERE ";

+

+            for (Field field : fields) {

+                PropertyDescriptor pd = new PropertyDescriptor(field.getName(),

+                        clazz);

+                Method getMethod = pd.getReadMethod();//获得get方法

+                Object o = getMethod.invoke(ruleQueryCondition);//执行get方法返回一个Object

+                if (o != null) {

+                    if (field.getName().equals("enabled")) {

+                        int enabled = (int) o;

+                        if (enabled != RuleMgtConstant.STATUS_RULE_ALL) {

+                            whereSql = whereSql + "enable =" + enabled;

+                            whereSql += " AND ";

+                        }

+                    } else if (field.getName().equals("name")) {

+                        if (!"".equals(o.toString().trim())) {

+                            whereSql = whereSql + field.getName() + "  like '%" + o + "%'  AND ";

+                        }

+                    } else {

+                        if (!"".equals(o.toString().trim())) {

+                            whereSql = whereSql + field.getName() + "='" + o + "'  AND ";

+                        }

+                    }

+                }

+            }

+            if (whereSql.indexOf("AND") > -1) {

+                whereSql = whereSql.trim();

+                return whereSql.substring(0, whereSql.length() - "AND".length());

+            }

+            return "";

+        } catch (Exception e) {

+            throw new DataFormatException(I18nProxy.RULE_MANAGEMENT_CREATE_QUERY_SQL_FAILED, e);

+        }

+    }

+}

diff --git a/rulemgt/src/main/java/org/openo/holmes/rulemgt/db/mapper/CorrelationRuleMapper.java b/rulemgt/src/main/java/org/openo/holmes/rulemgt/db/mapper/CorrelationRuleMapper.java
new file mode 100644
index 0000000..d318de9
--- /dev/null
+++ b/rulemgt/src/main/java/org/openo/holmes/rulemgt/db/mapper/CorrelationRuleMapper.java
@@ -0,0 +1,50 @@
+/**

+ * Copyright 2017 ZTE Corporation.

+ *

+ * Licensed under the Apache License, Version 2.0 (the "License");

+ * you may not use this file except in compliance with the License.

+ * You may obtain a copy of the License at

+ *

+ *     http://www.apache.org/licenses/LICENSE-2.0

+ *

+ * Unless required by applicable law or agreed to in writing, software

+ * distributed under the License is distributed on an "AS IS" BASIS,

+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.

+ * See the License for the specific language governing permissions and

+ * limitations under the License.

+ */

+package org.openo.holmes.rulemgt.db.mapper;

+

+import org.openo.holmes.common.api.entity.CorrelationRule;

+import org.skife.jdbi.v2.StatementContext;

+import org.skife.jdbi.v2.tweak.ResultSetMapper;

+

+import java.sql.ResultSet;

+import java.sql.SQLException;

+import java.util.Properties;

+

+public class CorrelationRuleMapper implements ResultSetMapper<CorrelationRule> {

+    @Override

+    public CorrelationRule map(int i, ResultSet resultSet, StatementContext statementContext) throws SQLException {

+        CorrelationRule correlationRule = new CorrelationRule();

+        correlationRule.setName(resultSet.getString("name"));

+        correlationRule.setRid(resultSet.getString("rid"));

+        correlationRule.setDescription(resultSet.getString("description"));

+        correlationRule.setEnabled(resultSet.getInt("enable"));

+        correlationRule.setTemplateID(resultSet.getInt("templateID"));

+        correlationRule.setEngineId(resultSet.getString("engineID"));

+        correlationRule.setEngineType(resultSet.getString("engineType"));

+        correlationRule.setCreator(resultSet.getString("creator"));

+        correlationRule.setCreateTime(resultSet.getDate("createTime"));

+        correlationRule.setModifier(resultSet.getString("updator"));

+        correlationRule.setUpdateTime(resultSet.getDate("updateTime"));

+        correlationRule.setParams((Properties)resultSet.getObject("params"));

+        correlationRule.setDomain(resultSet.getString("domain"));

+        correlationRule.setContent(resultSet.getString("content"));

+        correlationRule.setIsManual(resultSet.getInt("isManual"));

+        correlationRule.setVendor(resultSet.getString("vendor"));

+        correlationRule.setPackageName(resultSet.getString("package"));

+        return correlationRule;

+    }

+

+}

diff --git a/rulemgt/src/main/java/org/openo/holmes/rulemgt/resources/RuleMgtResources.java b/rulemgt/src/main/java/org/openo/holmes/rulemgt/resources/RuleMgtResources.java
new file mode 100644
index 0000000..71bd812
--- /dev/null
+++ b/rulemgt/src/main/java/org/openo/holmes/rulemgt/resources/RuleMgtResources.java
@@ -0,0 +1,207 @@
+/**

+ * Copyright 2017 ZTE Corporation.

+ *

+ * Licensed under the Apache License, Version 2.0 (the "License");

+ * you may not use this file except in compliance with the License.

+ * You may obtain a copy of the License at

+ *

+ *     http://www.apache.org/licenses/LICENSE-2.0

+ *

+ * Unless required by applicable law or agreed to in writing, software

+ * distributed under the License is distributed on an "AS IS" BASIS,

+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.

+ * See the License for the specific language governing permissions and

+ * limitations under the License.

+ */

+package org.openo.holmes.rulemgt.resources;

+

+import com.codahale.metrics.annotation.Timed;

+import io.swagger.annotations.Api;

+import io.swagger.annotations.ApiOperation;

+import io.swagger.annotations.ApiParam;

+import io.swagger.annotations.SwaggerDefinition;

+import java.io.IOException;

+import java.util.Locale;

+import javax.inject.Inject;

+import javax.servlet.http.HttpServletRequest;

+import javax.ws.rs.DELETE;

+import javax.ws.rs.GET;

+import javax.ws.rs.POST;

+import javax.ws.rs.PUT;

+import javax.ws.rs.Path;

+import javax.ws.rs.Produces;

+import javax.ws.rs.QueryParam;

+import javax.ws.rs.core.Context;

+import javax.ws.rs.core.MediaType;

+import lombok.extern.slf4j.Slf4j;

+import org.jvnet.hk2.annotations.Service;

+import org.openo.holmes.common.exception.CallException;

+import org.openo.holmes.common.exception.DataFormatException;

+import org.openo.holmes.common.exception.DbException;

+import org.openo.holmes.common.utils.ExceptionUtil;

+import org.openo.holmes.common.utils.I18nProxy;

+import org.openo.holmes.common.utils.JacksonUtil;

+import org.openo.holmes.common.utils.LanguageUtil;

+import org.openo.holmes.common.utils.UserUtil;

+import org.openo.holmes.rulemgt.bean.request.RuleCreateRequest;

+import org.openo.holmes.rulemgt.bean.request.RuleDeleteRequest;

+import org.openo.holmes.rulemgt.bean.request.RuleQueryCondition;

+import org.openo.holmes.rulemgt.bean.request.RuleUpdateRequest;

+import org.openo.holmes.rulemgt.bean.response.RuleAddAndUpdateResponse;

+import org.openo.holmes.rulemgt.bean.response.RuleQueryListResponse;

+import org.openo.holmes.rulemgt.wrapper.RuleMgtWrapper;

+

+@SwaggerDefinition

+@Service

+@Path("/rule")

+@Api(tags = {"CorrelationRules"})

+@Produces(MediaType.APPLICATION_JSON)

+@Slf4j

+public class RuleMgtResources {

+

+    @Inject

+    private RuleMgtWrapper ruleMgtWrapper;

+

+    @PUT

+    @Produces(MediaType.APPLICATION_JSON)

+    @ApiOperation(value = "Save the alarm+ rule to the database, and deployed to the engine when the enable to open.", response = RuleAddAndUpdateResponse.class)

+    @Timed

+    public RuleAddAndUpdateResponse addCorrelationRule(@Context HttpServletRequest request,

+        @ApiParam(value = "alarm+ rule create request.<br>[rulename]:<font color=\"red\">required</font><br>[content]:<font color=\"red\">required</font><br>[enabled]:<font color=\"red\">required</font>", required = true) RuleCreateRequest ruleCreateRequest) {

+        Locale locale = LanguageUtil.getLocale(request);

+        RuleAddAndUpdateResponse ruleChangeResponse;

+        try {

+            ruleChangeResponse = ruleMgtWrapper

+                .addCorrelationRule(UserUtil.getUserName(request), ruleCreateRequest);

+            log.info("create rule:" + ruleCreateRequest.getRuleName() + " success.");

+            return ruleChangeResponse;

+        } catch (CallException e) {

+            log.error("create rule:" + ruleCreateRequest.getRuleName() + " failed", e);

+            throw ExceptionUtil.buildExceptionResponse(I18nProxy.getInstance().getValue(locale,

+                e.getMessage()));

+        } catch (DbException e) {

+            log.error("create rule:" + ruleCreateRequest.getRuleName() + " failed", e);

+            throw ExceptionUtil.buildExceptionResponse(I18nProxy.getInstance().getValue(locale,

+                e.getMessage()));

+        } catch (DataFormatException e) {

+            log.error("create rule:" + ruleCreateRequest.getRuleName() + " failed", e);

+            throw ExceptionUtil.buildExceptionResponse(I18nProxy.getInstance().getValue(locale,

+                e.getMessage()));

+        } catch (Exception e) {

+            log.error("create rule:" + ruleCreateRequest.getRuleName() + " failed", e);

+            throw ExceptionUtil.buildExceptionResponse(I18nProxy.getInstance().getValue(locale,

+                I18nProxy.RULE_MANAGEMENT_UNKNOWN_EXCEPTION));

+        }

+    }

+

+    @POST

+    @Produces(MediaType.APPLICATION_JSON)

+    @ApiOperation(value = "Update the alarm+ rule and deployed to the engine when the enable to open.", response = RuleAddAndUpdateResponse.class)

+    @Timed

+    public RuleAddAndUpdateResponse updateCorrelationRule(@Context HttpServletRequest request,

+        @ApiParam(value = "alarm+ rule update request.<br>[ruleid]:<font color=\"red\">required</font>", required = true) RuleUpdateRequest ruleUpdateRequest) {

+        Locale locale = LanguageUtil.getLocale(request);

+        RuleAddAndUpdateResponse ruleChangeResponse;

+        try {

+            ruleChangeResponse = ruleMgtWrapper

+                .updateCorrelationRule(UserUtil.getUserName(request), ruleUpdateRequest);

+            return ruleChangeResponse;

+        } catch (CallException e) {

+            log.error("create rule:" + ruleUpdateRequest.getContent() + " failed", e);

+            throw ExceptionUtil.buildExceptionResponse(I18nProxy.getInstance().getValue(locale,

+                e.getMessage()));

+        } catch (DataFormatException e) {

+            log.error("update alarm plus rule:" + ruleUpdateRequest.getContent() + " failed", e);

+            throw ExceptionUtil.buildExceptionResponse(I18nProxy.getInstance().getValue(locale,

+                e.getMessage()));

+        } catch (DbException e) {

+            log.error("update rule:" + ruleUpdateRequest.getContent() + " failed", e);

+            throw ExceptionUtil.buildExceptionResponse(I18nProxy.getInstance().getValue(locale,

+                e.getMessage()));

+        } catch (Exception e) {

+            throw ExceptionUtil.buildExceptionResponse(I18nProxy.getInstance().getValue(locale,

+                I18nProxy.RULE_MANAGEMENT_UNKNOWN_EXCEPTION));

+        }

+    }

+

+    @DELETE

+    @Produces(MediaType.APPLICATION_JSON)

+    @ApiOperation(value = "Delete the alarm+ rule,and when the enable is open also removed from the engine.")

+    @Timed

+    public boolean deleteCorrelationRule(@Context HttpServletRequest request,

+        @ApiParam(value = "alarm+ rule delete request.<br>[ruleid]:<font color=\"red\">required</font>", required = true) RuleDeleteRequest ruleDeleteRequest) {

+        Locale locale = LanguageUtil.getLocale(request);

+        try {

+            ruleMgtWrapper.deleteCorrelationRule(ruleDeleteRequest);

+            log.info("delete rule:" + ruleDeleteRequest.getRuleId() + " successful");

+            return true;

+        } catch (DataFormatException e) {

+            log.error("delete rule:" + ruleDeleteRequest.getRuleId() + " failed", e);

+            throw ExceptionUtil.buildExceptionResponse(I18nProxy.getInstance().getValue(locale,

+                e.getMessage()));

+        } catch (DbException e) {

+            log.error("delete rule:" + ruleDeleteRequest.getRuleId() + " failed", e);

+            throw ExceptionUtil.buildExceptionResponse(I18nProxy.getInstance().getValue(locale,

+                e.getMessage()));

+        } catch (CallException e) {

+            log.error("delete rule:" + ruleDeleteRequest.getRuleId() + " failed", e);

+            throw ExceptionUtil.buildExceptionResponse(I18nProxy.getInstance().getValue(locale,

+                e.getMessage()));

+        } catch (Exception e) {

+            log.error("delete rule:" + ruleDeleteRequest.getRuleId() + " failed", e);

+            throw ExceptionUtil.buildExceptionResponse(I18nProxy.getInstance().getValue(locale,

+                I18nProxy.RULE_MANAGEMENT_UNKNOWN_EXCEPTION));

+        }

+    }

+

+    @GET

+    @Produces(MediaType.APPLICATION_JSON)

+    @ApiOperation(value = "According to the conditions query the alarm + rules", response = RuleQueryListResponse.class)

+    @Timed

+    public RuleQueryListResponse getCorrelationRules(@Context HttpServletRequest request,

+        @ApiParam(value = "query condition:<br>" + " <b>[ruleid]</b>:Rule ID;<br>"

+            + "<b>[rulename]</b>:Rule name;<br>" + "<b>[creator]</b>:creator of the rule;<br>"

+            + "<b>[modifier]</b>:modifier of the rule;<br>"

+            + "<b>[enabled]</b>: 0 is Enabled,1 is disabled;<br><font color=\"red\">for example:</font><br>{\"ruleid\":\"rule_1484727187317\"}", required = false) @QueryParam("queryrequest") String ruleQueryRequest) {

+        Locale locale = LanguageUtil.getLocale(request);

+        RuleQueryListResponse ruleQueryListResponse;

+        RuleQueryCondition ruleQueryCondition = getRuleQueryCondition(ruleQueryRequest, request);

+        try {

+            ruleQueryListResponse = ruleMgtWrapper

+                .getCorrelationRuleByCondition(ruleQueryCondition);

+            return ruleQueryListResponse;

+        } catch (DataFormatException e) {

+            log.error("query rule failed,cause query condition conversion failure", e);

+            throw ExceptionUtil.buildExceptionResponse(I18nProxy.getInstance().getValue(locale,

+                e.getMessage()));

+        } catch (DbException e) {

+            log.error("query rule failed", e);

+            throw ExceptionUtil.buildExceptionResponse(I18nProxy.getInstance().getValue(locale,

+                e.getMessage()));

+        } catch (Exception e) {

+            log.error("query rule failed", e);

+            throw ExceptionUtil.buildExceptionResponse(I18nProxy.getInstance().getValue(locale,

+                I18nProxy.RULE_MANAGEMENT_UNKNOWN_EXCEPTION));

+        }

+    }

+

+    private RuleQueryCondition getRuleQueryCondition(String queryRequest,

+        HttpServletRequest request) {

+        Locale locale = LanguageUtil.getLocale(request);

+        try {

+            RuleQueryCondition ruleQueryCondition = JacksonUtil

+                .jsonToBean(queryRequest, RuleQueryCondition.class);

+            if (queryRequest == null) {

+                ruleQueryCondition.setEnabled(2);

+            } else if (queryRequest.indexOf("enabled") == -1) {

+                ruleQueryCondition.setEnabled(2);

+            }

+            return ruleQueryCondition;

+        } catch (IOException e) {

+            log.warn("queryRequest convert to json failed", e);

+            throw ExceptionUtil.buildExceptionResponse(I18nProxy.getInstance().getValue(locale,

+                I18nProxy.RULE_MANAGEMENT_DATA_FORMAT_ERROR));

+        }

+    }

+

+}

diff --git a/rulemgt/src/main/java/org/openo/holmes/rulemgt/wrapper/RuleMgtWrapper.java b/rulemgt/src/main/java/org/openo/holmes/rulemgt/wrapper/RuleMgtWrapper.java
new file mode 100644
index 0000000..60bce08
--- /dev/null
+++ b/rulemgt/src/main/java/org/openo/holmes/rulemgt/wrapper/RuleMgtWrapper.java
@@ -0,0 +1,255 @@
+/**

+ * Copyright 2017 ZTE Corporation.

+ *

+ * Licensed under the Apache License, Version 2.0 (the "License");

+ * you may not use this file except in compliance with the License.

+ * You may obtain a copy of the License at

+ *

+ *     http://www.apache.org/licenses/LICENSE-2.0

+ *

+ * Unless required by applicable law or agreed to in writing, software

+ * distributed under the License is distributed on an "AS IS" BASIS,

+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.

+ * See the License for the specific language governing permissions and

+ * limitations under the License.

+ */

+package org.openo.holmes.rulemgt.wrapper;

+

+import java.util.ArrayList;

+import java.util.Date;

+import java.util.List;

+import javax.inject.Inject;

+import javax.inject.Singleton;

+import lombok.extern.slf4j.Slf4j;

+import org.jvnet.hk2.annotations.Service;

+import org.openo.holmes.common.api.entity.CorrelationRule;

+import org.openo.holmes.common.exception.CallException;

+import org.openo.holmes.common.exception.DataFormatException;

+import org.openo.holmes.common.exception.DbException;

+import org.openo.holmes.common.utils.DbDaoUtil;

+import org.openo.holmes.common.utils.I18nProxy;

+import org.openo.holmes.rulemgt.bean.request.CorrelationCheckRule4Engine;

+import org.openo.holmes.rulemgt.bean.request.CorrelationDeployRule4Engine;

+import org.openo.holmes.rulemgt.bean.request.RuleCreateRequest;

+import org.openo.holmes.rulemgt.bean.request.RuleDeleteRequest;

+import org.openo.holmes.rulemgt.bean.request.RuleQueryCondition;

+import org.openo.holmes.rulemgt.bean.request.RuleUpdateRequest;

+import org.openo.holmes.rulemgt.bean.response.RuleAddAndUpdateResponse;

+import org.openo.holmes.rulemgt.bean.response.RuleQueryListResponse;

+import org.openo.holmes.rulemgt.bean.response.RuleResult4API;

+import org.openo.holmes.rulemgt.bolt.enginebolt.EngineWrapper;

+import org.openo.holmes.rulemgt.constant.RuleMgtConstant;

+import org.openo.holmes.rulemgt.db.CorrelationRuleDao;

+import org.openo.holmes.rulemgt.db.CorrelationRuleQueryDao;

+

+

+@Service

+@Singleton

+@Slf4j

+public class RuleMgtWrapper {

+

+    @Inject

+    private CorrelationRuleQueryDao correlationRuleQueryDao;

+    @Inject

+    private EngineWrapper engineWarpper;

+    @Inject

+    private DbDaoUtil daoUtil;

+

+    public RuleAddAndUpdateResponse addCorrelationRule(String creator,

+        RuleCreateRequest ruleCreateRequest)

+        throws DataFormatException, CallException, DbException {

+        CorrelationRule correlationRule = convertRuleCreateRequest2CorrelationRule(creator,

+            ruleCreateRequest);

+        if (correlationRule.getName() == null || "".equals(correlationRule.getName().trim())) {

+            throw new DbException(I18nProxy.RULE_MANAGEMENT_RULE_NAME_IS_EMPTY);

+        }

+        CorrelationRule ruleTemp = daoUtil.getJdbiDaoByOnDemand(CorrelationRuleDao.class)

+            .queryRuleByRuleName(correlationRule.getName());

+        if (ruleTemp != null) {

+            throw new DbException(I18nProxy.RULE_MANAGEMENT_REPEAT_RULE_NAME);

+        }

+        correlationRule.setPackageName(deployRule2Engine(correlationRule));

+        try {

+            correlationRule = daoUtil.getJdbiDaoByOnDemand(CorrelationRuleDao.class)

+                .saveRule(correlationRule);

+        } catch (RuntimeException e) {

+            throw new DbException(I18nProxy.RULE_MANAGEMENT_CREATE_RULE_FAILED, e);

+        }

+        RuleAddAndUpdateResponse ruleAddAndUpdateResponse = new RuleAddAndUpdateResponse();

+        ruleAddAndUpdateResponse.setRuleId(correlationRule.getRid());

+        return ruleAddAndUpdateResponse;

+    }

+

+    public RuleAddAndUpdateResponse updateCorrelationRule(String modifier,

+        RuleUpdateRequest ruleUpdateRequest)

+        throws DataFormatException, DbException, CallException {

+        if (ruleUpdateRequest != null) {

+            CorrelationRule oldCorrelationRule = daoUtil

+                .getJdbiDaoByOnDemand(CorrelationRuleDao.class)

+                .getRuleByRid(ruleUpdateRequest.getRuleId());

+            if (oldCorrelationRule == null) {

+                throw new DbException(I18nProxy.RULE_MANAGEMENT_RULE_NOT_EXIST_DATABASE);

+            }

+            CorrelationRule newCorrelationRule = convertRuleUpdateRequest2CorrelationRule(modifier,

+                ruleUpdateRequest);

+            checkCorrelation(newCorrelationRule, oldCorrelationRule);

+            RuleAddAndUpdateResponse ruleChangeResponse = new RuleAddAndUpdateResponse();

+            try {

+                if (oldCorrelationRule.getEnabled() == RuleMgtConstant.STATUS_RULE_OPEN) {

+                    engineWarpper.deleteRuleFromEngine(oldCorrelationRule.getPackageName());

+                }

+                daoUtil.getJdbiDaoByOnDemand(CorrelationRuleDao.class)

+                    .updateRule(newCorrelationRule);

+            } catch (RuntimeException e) {

+                throw new DbException(I18nProxy.RULE_MANAGEMENT_UPDATE_RULE_FAILED, e);

+            }

+            ruleChangeResponse.setRuleId(newCorrelationRule.getRid());

+            deployRule2Engine(newCorrelationRule);

+            return ruleChangeResponse;

+        } else {

+            throw new DataFormatException(I18nProxy.RULE_MANAGEMENT_REQUEST_OBJECT_IS_EMPTY);

+        }

+

+    }

+

+    public void checkCorrelation(CorrelationRule newCorrelationRule,

+        CorrelationRule oldCorrelationRule) throws DataFormatException {

+        int newEnabled = newCorrelationRule.getEnabled();

+        if (newCorrelationRule.getContent() == null) {

+            newCorrelationRule.setContent(oldCorrelationRule.getContent());

+        }

+        if (newEnabled != RuleMgtConstant.STATUS_RULE_CLOSE

+            && newEnabled != RuleMgtConstant.STATUS_RULE_OPEN) {

+            throw new DataFormatException(I18nProxy.RULE_MANAGEMENT_PARAMETER_ENABLED_ERROR);

+        }

+    }

+

+    public void deleteCorrelationRule(RuleDeleteRequest ruleDeleteRequest)

+        throws DbException, DataFormatException, CallException {

+        if (ruleDeleteRequest != null) {

+            CorrelationRule correlationRule = daoUtil

+                .getJdbiDaoByOnDemand(CorrelationRuleDao.class)

+                .getRuleByRid(ruleDeleteRequest.getRuleId());

+            if (correlationRule == null) {

+                log.warn("the rule:rule id=" + ruleDeleteRequest.getRuleId()

+                    + " does not exist the database.");

+                throw new DbException(I18nProxy.RULE_MANAGEMENT_RULE_NOT_EXIST_DATABASE);

+            }

+            try {

+                if (correlationRule.getEnabled() == RuleMgtConstant.STATUS_RULE_OPEN) {

+                    engineWarpper.deleteRuleFromEngine(correlationRule.getPackageName());

+                }

+                daoUtil.getJdbiDaoByOnDemand(CorrelationRuleDao.class)

+                    .deleteRule(correlationRule);

+            } catch (RuntimeException e) {

+                throw new DbException(I18nProxy.RULE_MANAGEMENT_DELETE_RULE_FAILED, e);

+            }

+        } else

+

+        {

+            throw new DataFormatException(I18nProxy.RULE_MANAGEMENT_REQUEST_OBJECT_IS_EMPTY);

+        }

+

+    }

+

+    public CorrelationRule convertRuleCreateRequest2CorrelationRule(String userName,

+        RuleCreateRequest ruleCreateRequest) throws DataFormatException {

+        if (ruleCreateRequest != null) {

+            if (ruleCreateRequest.getEnabled() != RuleMgtConstant.STATUS_RULE_OPEN

+                && ruleCreateRequest.getEnabled() != RuleMgtConstant.STATUS_RULE_CLOSE) {

+                throw new DataFormatException(I18nProxy.RULE_MANAGEMENT_REQUEST_OBJECT_IS_EMPTY);

+            }

+            CorrelationRule correlationRule = new CorrelationRule();

+            String ruleId = "rule_" + System.currentTimeMillis();

+            correlationRule.setRid(ruleId);

+            correlationRule.setContent(ruleCreateRequest.getContent());

+            correlationRule.setDescription(ruleCreateRequest.getDescription());

+            correlationRule.setCreateTime(new Date());

+            correlationRule.setUpdateTime(new Date());

+            correlationRule.setName(ruleCreateRequest.getRuleName());

+            correlationRule.setEngineId("correlation-d");

+            correlationRule.setEngineType("");

+            correlationRule.setIsManual(0);

+            correlationRule.setTemplateID(0);

+            correlationRule.setVendor("");

+            correlationRule.setCreator(userName);

+            correlationRule.setModifier(userName);

+            correlationRule.setEnabled(ruleCreateRequest.getEnabled());

+            return correlationRule;

+        } else {

+            throw new DataFormatException(I18nProxy.RULE_MANAGEMENT_REQUEST_OBJECT_IS_EMPTY);

+        }

+

+    }

+

+    private CorrelationRule convertRuleUpdateRequest2CorrelationRule(String modifier,

+        RuleUpdateRequest ruleUpdateRequest) throws DataFormatException {

+        if (ruleUpdateRequest != null) {

+            CorrelationRule correlationRule = new CorrelationRule();

+            correlationRule.setRid(ruleUpdateRequest.getRuleId());

+            correlationRule.setContent(ruleUpdateRequest.getContent());

+            correlationRule.setDescription(ruleUpdateRequest.getDescription());

+            correlationRule.setEnabled(ruleUpdateRequest.getEnabled());

+            correlationRule.setUpdateTime(new Date());

+            correlationRule.setModifier(modifier);

+            return correlationRule;

+        } else {

+            throw new DataFormatException(I18nProxy.RULE_MANAGEMENT_REQUEST_OBJECT_IS_EMPTY);

+        }

+

+    }

+

+    private String deployRule2Engine(CorrelationRule correlationRule) throws CallException {

+        if (engineWarpper.checkRuleFromEngine(correlationRules2CheckRule(correlationRule))) {

+            if (correlationRule.getEnabled() == RuleMgtConstant.STATUS_RULE_OPEN) {

+                return engineWarpper.deployEngine(correlationRules2DeployRule(correlationRule));

+            }

+        }

+        return "";

+    }

+

+    public RuleQueryListResponse getCorrelationRuleByCondition(

+        RuleQueryCondition ruleQueryCondition) throws DataFormatException, DbException {

+        List<CorrelationRule> correlationRule = correlationRuleQueryDao

+            .getCorrelationRulesByCondition(ruleQueryCondition);

+        RuleQueryListResponse ruleQueryListResponse = new RuleQueryListResponse();

+        ruleQueryListResponse.setTotalCount(correlationRule.size());

+        ruleQueryListResponse

+            .setCorrelationRules(correlationRules2RuleResult4APIs(correlationRule));

+        return ruleQueryListResponse;

+    }

+

+    private List<RuleResult4API> correlationRules2RuleResult4APIs(

+        List<CorrelationRule> correlationRules) {

+        List<RuleResult4API> ruleResult4APIs = new ArrayList<RuleResult4API>();

+        for (CorrelationRule correlationRule : correlationRules) {

+            RuleResult4API ruleResult4API = new RuleResult4API();

+            ruleResult4API.setRuleId(correlationRule.getRid());

+            ruleResult4API.setRuleName(correlationRule.getName());

+            ruleResult4API.setDescription(correlationRule.getDescription());

+            ruleResult4API.setContent(correlationRule.getContent());

+            ruleResult4API.setCreateTime(correlationRule.getCreateTime());

+            ruleResult4API.setCreator(correlationRule.getCreator());

+            ruleResult4API.setUpdateTime(correlationRule.getUpdateTime());

+            ruleResult4API.setModifier(correlationRule.getModifier());

+            ruleResult4API.setEnabled(correlationRule.getEnabled());

+            ruleResult4APIs.add(ruleResult4API);

+        }

+        return ruleResult4APIs;

+    }

+

+    private CorrelationDeployRule4Engine correlationRules2DeployRule(

+        CorrelationRule correlationRule) {

+        CorrelationDeployRule4Engine correlationDeployRule4Engine = new CorrelationDeployRule4Engine();

+        correlationDeployRule4Engine.setContent(correlationRule.getContent());

+        correlationDeployRule4Engine.setEngineId(correlationRule.getEngineId());

+        return correlationDeployRule4Engine;

+    }

+

+    private CorrelationCheckRule4Engine correlationRules2CheckRule(

+        CorrelationRule correlationRule) {

+        CorrelationCheckRule4Engine correlationCheckRule4Engine = new CorrelationCheckRule4Engine();

+        correlationCheckRule4Engine.setContent(correlationRule.getContent());

+        return correlationCheckRule4Engine;

+    }

+}