Ver código fonte

增加更新设备与报警条件关联关系的消息处理方法

lixing 3 anos atrás
pai
commit
c3b90a504b

+ 8 - 2
AlarmEngineStarter/src/main/java/com/persagy/apm/energyalarmstarter/alarmengine/jms/AlarmEngineMsgHandler.java

@@ -123,7 +123,7 @@ public class AlarmEngineMsgHandler {
      * @version V1.0 2021/10/26 7:51 下午
      */
     public void syncNewObjConditionRelList(DmpMessage msg) {
-        JSONArray relList = JSONObject.parseArray(msg.getStr1());
+        JSONArray createdRelList = JSONObject.parseArray(msg.getStr1());
         // TODO: 2021/11/16 更新redis
     }
 
@@ -135,8 +135,14 @@ public class AlarmEngineMsgHandler {
      * @version V1.0 2021/10/26 7:51 下午
      */
     public void syncDeletedObjConditionRelList(DmpMessage msg) {
-        JSONArray relList = JSONObject.parseArray(msg.getStr1());
+        JSONArray deletedRelList = JSONObject.parseArray(msg.getStr1());
         // TODO: 2021/11/16 更新redis
     }
 
+    public void syncUpdateObjConditionRelList(DmpMessage msg) {
+        JSONArray deletedRelList = JSONObject.parseArray(msg.getStr1());
+        JSONArray createdRelList = JSONObject.parseArray(msg.getStr2());
+        // 先删除,再创建
+        // TODO: 2021/11/16 更新redis
+    }
 }

+ 3 - 0
AlarmEngineStarter/src/main/java/com/persagy/apm/energyalarmstarter/alarmengine/jms/JmsConfig.java

@@ -134,6 +134,9 @@ public class JmsConfig {
             if (JmsTypeEnum.DELETE_OBJ_CONDITION_REL.getType().equals(msg.getType())) {
                 msgHandler.syncDeletedObjConditionRelList(msg);
             }
+            if (JmsTypeEnum.UPDATE_OBJ_CONDITION_REL.getType().equals(msg.getType())) {
+                msgHandler.syncUpdateObjConditionRelList(msg);
+            }
         } catch (Exception e) {
             log.error("报警条件消息消费失败,{}", e.getMessage());
         }

+ 2 - 1
AlarmEngineStarter/src/main/java/com/persagy/apm/energyalarmstarter/alarmengine/jms/JmsTypeEnum.java

@@ -22,7 +22,8 @@ public enum JmsTypeEnum {
     UPDATE_CONDITION("update_condition", "更新报警条件"),
     DELETE_CONDITION("delete_condition", "删除报警条件"),
     NEW_OBJ_CONDITION_REL("new_obj_condition_rel", "新增条件和设备的关联关系"),
-    DELETE_OBJ_CONDITION_REL("delete_obj_condition_rel", "删除条件和设备的关联关系");
+    DELETE_OBJ_CONDITION_REL("delete_obj_condition_rel", "删除条件和设备的关联关系"),
+    UPDATE_OBJ_CONDITION_REL("update_obj_condition_rel", "更新条件和设备的关联关系");
 
 
     @Setter