瀏覽代碼

把报警条件和关联关系转换为string后放入redis中

lixing 3 年之前
父節點
當前提交
b5dc3b8b39

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

@@ -189,6 +189,9 @@ public class AlarmEngineMsgHandler {
             // 报警对象id
             String objId = objConditionRel.getObjId();
             ObjConditionInfo objConditionInfo = redisUtil.get(RedisConstants.OBJ_CONDITION_REL, objId, ObjConditionInfo.class);
+            if (objConditionInfo == null) {
+                continue;
+            }
             ItemCodeCondition condition = new ItemCodeCondition();
             condition.setConditionId(objConditionRel.getConditionId());
             condition.setItemCode(objConditionRel.getItemCode());

+ 3 - 2
AlarmEngineStarter/src/main/java/com/persagy/apm/energyalarmstarter/alarmengine/redis/RedisUtil4EngineStater.java

@@ -2,6 +2,7 @@ package com.persagy.apm.energyalarmstarter.alarmengine.redis;
 
 import cn.hutool.json.JSONUtil;
 import com.alibaba.fastjson.JSON;
+import com.alibaba.fastjson.JSONObject;
 import lombok.SneakyThrows;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.data.redis.core.RedisTemplate;
@@ -35,11 +36,11 @@ public class RedisUtil4EngineStater {
         if (obj == null) {
             return null;
         }
-        return JSONUtil.toBean(JSON.toJSONString(obj), resultClazz);
+        return JSONUtil.toBean(obj.toString(), resultClazz);
     }
 
     public void put(String mapName, String key, Object value) {
-        alarmRedisTemplate.opsForHash().put(mapName, key, value);
+        alarmRedisTemplate.opsForHash().put(mapName, key, JSONObject.toJSONString(value));
     }
 
     public void delete(String mapName, String key) {