Bläddra i källkod

增加缓存处理

xiewenjie 3 år sedan
förälder
incheckning
8f2879b7eb

+ 3 - 2
src/main/java/com/fdkk/fdkkmeta/redis/RedisCache.java

@@ -1,6 +1,7 @@
 package com.fdkk.fdkkmeta.redis;
 package com.fdkk.fdkkmeta.redis;
 
 
 import cn.hutool.extra.spring.SpringUtil;
 import cn.hutool.extra.spring.SpringUtil;
+import com.alibaba.fastjson.JSON;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.data.redis.connection.*;
 import org.springframework.data.redis.connection.*;
 import org.springframework.data.redis.core.*;
 import org.springframework.data.redis.core.*;
@@ -44,9 +45,9 @@ public class RedisCache
      * @param key 缓存的键值
      * @param key 缓存的键值
      * @param value 缓存的值
      * @param value 缓存的值
      */
      */
-    public <T> void setStringObject(final String key, final String value)
+    public <T> void setJsonStrObject(final String key, final T value)
     {
     {
-        stringRedisTemplate.opsForValue().set(key, value);
+        stringRedisTemplate.opsForValue().set(key, JSON.toJSONString(value));
     }
     }
     /**
     /**
      * 缓存基本的对象,Integer、String、实体类等
      * 缓存基本的对象,Integer、String、实体类等

+ 3 - 6
src/main/java/com/fdkk/fdkkmeta/task/UpdateFrameMetaTask.java

@@ -17,15 +17,12 @@ import com.fdkk.fdkkmeta.service.BreakpointsService;
 import com.fdkk.fdkkmeta.service.MoveFrameService;
 import com.fdkk.fdkkmeta.service.MoveFrameService;
 import com.fdkk.fdkkmeta.service.UserService;
 import com.fdkk.fdkkmeta.service.UserService;
 import com.fdkk.fdkkmeta.service.RotateFrameService;
 import com.fdkk.fdkkmeta.service.RotateFrameService;
-import com.fdkk.fdkkmeta.util.kesar.GetRoute;
 import lombok.extern.slf4j.Slf4j;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.scheduling.annotation.Scheduled;
 import org.springframework.scheduling.annotation.Scheduled;
 import org.springframework.stereotype.Component;
 import org.springframework.stereotype.Component;
 
 
-import java.io.File;
 import java.util.ArrayList;
 import java.util.ArrayList;
-import java.util.Arrays;
 import java.util.List;
 import java.util.List;
 
 
 /**
 /**
@@ -258,7 +255,7 @@ public class UpdateFrameMetaTask {
         String mediaSrc = metaConfig.getVideoFramePath()+"/"+"0000000001"+"/"+rotateFrameEntity.getBreakPointId()+"/"+rotateFrameEntity.getDirectory()+"/"+rotateFrameEntity.getFileName();
         String mediaSrc = metaConfig.getVideoFramePath()+"/"+"0000000001"+"/"+rotateFrameEntity.getBreakPointId()+"/"+rotateFrameEntity.getDirectory()+"/"+rotateFrameEntity.getFileName();
         metaDataFramePO.setMediaSrc(mediaSrc);
         metaDataFramePO.setMediaSrc(mediaSrc);
 
 
-        redisCache.setCacheObject("updateFrameMetadata:"+user.getUserId(), JSON.toJSONString(metaDataFramePO));
+        redisCache.setJsonStrObject("updateFrameMetadata:"+user.getUserId(), JSON.toJSONString(metaDataFramePO));
     }
     }
 
 
     private void createMoveFrameMetadata(String user_id,AnglePO playerAngle,PointPO playerPosition,MoveFrameEntity moveFrameEntity,String traceId){
     private void createMoveFrameMetadata(String user_id,AnglePO playerAngle,PointPO playerPosition,MoveFrameEntity moveFrameEntity,String traceId){
@@ -300,7 +297,7 @@ public class UpdateFrameMetaTask {
 
 
         String mediaSrc = metaConfig.getVideoFramePath()+"/"+"0000000001"+"/"+moveFrameEntity.getStartBreakPointId()+"/"+moveFrameEntity.getDirectory()+"/"+moveFrameEntity.getFileName();
         String mediaSrc = metaConfig.getVideoFramePath()+"/"+"0000000001"+"/"+moveFrameEntity.getStartBreakPointId()+"/"+moveFrameEntity.getDirectory()+"/"+moveFrameEntity.getFileName();
         metaDataFramePO.setMediaSrc(mediaSrc);
         metaDataFramePO.setMediaSrc(mediaSrc);
-        redisCache.setCacheObject("updateFrameMetadata:"+user_id,metaDataFramePO);
+        redisCache.setJsonStrObject("updateFrameMetadata:"+user_id,metaDataFramePO);
     }
     }
 
 
     private void createRotateFrameMetadata(UserEntity user,List<ActionPO> rotateJoystickList,int firstActionType){
     private void createRotateFrameMetadata(UserEntity user,List<ActionPO> rotateJoystickList,int firstActionType){
@@ -351,7 +348,7 @@ public class UpdateFrameMetaTask {
         metaDataFramePO.setGetStateType(0);
         metaDataFramePO.setGetStateType(0);
         metaDataFramePO.setCode(0);
         metaDataFramePO.setCode(0);
         metaDataFramePO.setMsg("");
         metaDataFramePO.setMsg("");
-        redisCache.setCacheObject("updateFrameMetadata:"+user.getUserId(),metaDataFramePO);
+        redisCache.setJsonStrObject("updateFrameMetadata:"+user.getUserId(),metaDataFramePO);
 
 
         //更新user表
         //更新user表
         user.setFrameId(lastActionPO.getFrameId());
         user.setFrameId(lastActionPO.getFrameId());