瀏覽代碼

更改代码redis db select

gaoyu 3 年之前
父節點
當前提交
23e521a46b
共有 1 個文件被更改,包括 8 次插入1 次删除
  1. 8 1
      src/main/java/com/persagy/cache/AlarmRedisCache.java

+ 8 - 1
src/main/java/com/persagy/cache/AlarmRedisCache.java

@@ -7,6 +7,9 @@ import javax.annotation.Resource;
 
 import org.apache.commons.lang3.StringUtils;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.dao.DataAccessException;
+import org.springframework.data.redis.connection.RedisConnection;
+import org.springframework.data.redis.core.RedisCallback;
 import org.springframework.data.redis.core.RedisTemplate;
 import org.springframework.stereotype.Component;
 
@@ -66,7 +69,11 @@ public class AlarmRedisCache implements RedisCache {
 	}
 
 	public AlarmCondition getAlarmConditionRedis(String conditionId) {
-		String str = emsRedisTemplate.opsForHash().get(RedisConstant.ALARMCONDITION_ID, conditionId).toString();
+		String str = emsRedisTemplate.execute((RedisCallback<String>) conn -> {
+			conn.select(14);
+			byte[] condition = conn.hGet(RedisConstant.ALARMCONDITION_ID.getBytes(), conditionId.getBytes());
+			return new String(condition);
+		});
 		JSONObject object = JSONObject.parseObject(str);
 		AlarmCondition alarmCondition = JSON.toJavaObject(object, AlarmCondition.class);
 		return alarmCondition;