瀏覽代碼

修改redisTemplate的保存方法

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

+ 2 - 1
src/main/java/com/persagy/apm/diagnose/indicatorrecord/service/impl/MonitorIndicatorRecordServiceImpl.java

@@ -1,6 +1,7 @@
 package com.persagy.apm.diagnose.indicatorrecord.service.impl;
 
 import cn.hutool.json.JSONUtil;
+import com.alibaba.fastjson.JSON;
 import com.alibaba.fastjson.JSONArray;
 import com.alibaba.fastjson.JSONObject;
 import com.persagy.apm.diagnose.config.ComputePropertiesConfig;
@@ -605,7 +606,7 @@ public class MonitorIndicatorRecordServiceImpl implements IMonitorIndicatorRecor
      */
     private void updateRedisConfigItemSendTimeDTO(String projectId, String objeIdAndAlarmItemCode, ConfigItemDataSendTimeDTO sendTimeDTO) {
         log.info("更新发数时间:[{}], [{}]", getRedisSendDataKey(projectId, objeIdAndAlarmItemCode), sendTimeDTO);
-        redisUtil.set(getRedisSendDataKey(projectId, objeIdAndAlarmItemCode), sendTimeDTO);
+        redisUtil.set(getRedisSendDataKey(projectId, objeIdAndAlarmItemCode), JSON.toJSONString(sendTimeDTO));
         log.info("更新发数时间完毕");
     }
 

+ 1 - 1
src/main/java/com/persagy/apm/diagnose/maintenance/service/impl/ProjectDataRecordServiceImpl.java

@@ -334,7 +334,7 @@ public class ProjectDataRecordServiceImpl implements IProjectDataRecordService {
     }
 
     private void updateRedisConfigItemSendTimeDTO(String projectId, String objIdAndAlarmItemCode, ConfigItemDataSendTimeDTO sendTimeDTO) {
-        redisUtil.set(getRedisSendDataKey(projectId, objIdAndAlarmItemCode), sendTimeDTO, SendDataTimeKeyTime);
+        redisUtil.set(getRedisSendDataKey(projectId, objIdAndAlarmItemCode), JSON.toJSONString(sendTimeDTO), SendDataTimeKeyTime);
     }
 
     private List<MonitorIndicatorRecord> getMonitorIndicatorRecordsGtLte(String projectId, String objId, Date lastSendTime, List<String> infoCodes, Date endTime) throws Exception {

+ 7 - 5
src/main/java/com/persagy/apm/diagnose/utils/RedisUtil.java

@@ -7,11 +7,14 @@ import java.util.concurrent.TimeUnit;
 
 import javax.annotation.Resource;
 
+import com.alibaba.fastjson.JSON;
+import lombok.extern.slf4j.Slf4j;
 import org.springframework.data.redis.core.RedisTemplate;
 import org.springframework.stereotype.Component;
 import org.springframework.util.CollectionUtils;
 
 @Component
+@Slf4j
 public class RedisUtil {
 
     @Resource(name = "alarmRedisTemplate")
@@ -117,17 +120,16 @@ public class RedisUtil {
      * @return true成功 false失败
      */
 
-    public boolean set(String key, Object value) {
+    public boolean set(String key, String value) {
 
         try {
-
             redisTemplate.opsForValue().set(key, value);
 
             return true;
 
         } catch (Exception e) {
 
-            e.printStackTrace();
+            log.error("redis保存数据失败", e);
 
             return false;
 
@@ -144,7 +146,7 @@ public class RedisUtil {
      * @return true成功 false 失败
      */
 
-    public boolean set(String key, Object value, long time) {
+    public boolean set(String key, String value, long time) {
 
         try {
 
@@ -162,7 +164,7 @@ public class RedisUtil {
 
         } catch (Exception e) {
 
-            e.printStackTrace();
+            log.error("redis保存数据失败", e);
 
             return false;