Pārlūkot izejas kodu

增加缓存处理

xiewenjie 3 gadi atpakaļ
vecāks
revīzija
a4e6aa2301

+ 4 - 2
src/main/java/com/fdkk/fdkkmeta/task/UpdateFrameMetaTask.java

@@ -49,7 +49,7 @@ public class UpdateFrameMetaTask {
     SceneGrpcService sceneGrpcService;
     @Autowired
     BreakpointsService breakpointsService;
-    @Scheduled(initialDelay=1000, fixedDelay=1000/30)
+    @Scheduled(initialDelay=200, fixedDelay=1000)
    public void updateFrameMetadata(){
        List<UserEntity> userOnline = userService.findUserOnline(true);
        log.info("进入定时任务{}", ArrayUtil.isNotEmpty(userOnline)?userOnline.size():0);
@@ -60,7 +60,7 @@ public class UpdateFrameMetaTask {
                userEntity -> {
                    //UserEntity user = redisCache.getCacheObject("setCacheRequest:" + userEntity.getUserId());
 //                   redisCache.set("updateFrameMetadata:"+userEntity.getUserId(),a.toJSONString());
-                   List<ActionPO> list = redisCache.getCacheList("setCacheRequest"+userEntity.getUserId());
+                   List<ActionPO> list = redisCache.getCacheList("setCacheRequest:"+userEntity.getUserId());
                    handle( userEntity,list);
                }
        );
@@ -350,6 +350,8 @@ public class UpdateFrameMetaTask {
         builder.setCode(200);
         builder.setMsg("ok");
 
+        String mediaSrc = metaConfig.getVideoFramePath()+"/"+"0000000001"+"/"+rotateFrameEntity.getBreakPointId()+"/"+rotateFrameEntity.getDirectory()+"/"+rotateFrameEntity.getFileName();
+        builder.setMediaSrc(mediaSrc);
         redisCache.lLeftPush("updateFrameMetadata:"+user.getUserId(),ProtoJsonUtils.toJson(builder));
 
         //更新user表