更新定时任务

src/main/java/com/fdkk/fdkkmeta/domain/entity/mysql/UserEntity.java

@@ -27,4 +27,6 @@ public class UserEntity extends BaseEntity {
     private AnglePO playerAngle;
 
     private String sessionId;
+
+    private Boolean online;
 }

src/main/java/com/fdkk/fdkkmeta/grpcService/sceneGrpcServer.java

@@ -129,7 +129,7 @@ public class sceneGrpcServer extends SceneGrpcServiceGrpc.SceneGrpcServiceImplBa
             userEntity.setSkinId(skin_id);
             userEntity.setFrameId(1L);
             userEntity.setBreakPointId(1L);
-
+			userEntity.setOnline(true);
           //初始化的时候可以写死
             AnglePO player_angle = new AnglePO();
             player_angle.setPitch(0);
@@ -137,6 +137,8 @@ public class sceneGrpcServer extends SceneGrpcServiceGrpc.SceneGrpcServiceImplBa
             player_angle.setRoll(0);
             userEntity.setPlayerAngle(player_angle);
             userService.save(userEntity);
+			//todo 存入redis
+//			redisCache.setCacheObject(user_id,null);
     	}
     	catch(Exception e) {
     		e.printStackTrace();

src/main/java/com/fdkk/fdkkmeta/service/UserService.java

@@ -11,4 +11,7 @@ import java.util.List;
  */
 public interface UserService extends IBaseService<UserEntity> {
     UserEntity findUserId(String userId);
+
+    List<UserEntity> findUserOnline(boolean isOnline);
+
 }

src/main/java/com/fdkk/fdkkmeta/task/FFmpegTask.java

@@ -1,31 +0,0 @@
-package com.fdkk.fdkkmeta.task;
-
-import cn.hutool.core.date.DateUtil;
-import com.fdkk.fdkkmeta.redis.RedisCache;
-import lombok.extern.slf4j.Slf4j;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.scheduling.annotation.Scheduled;
-import org.springframework.stereotype.Component;
-
-import java.util.List;
-import java.util.Set;
-
-/**
- * @author Xiewj
- * @date 2022/3/30
- */
-@Component
-@Slf4j
-public class FFmpegTask {
-   @Autowired
-   RedisCache redisCache;
-
-//   @Scheduled(initialDelay=1000, fixedDelay=2000)
-   public void checkFFmpegByPid(){
-      Set<String> allScene = redisCache.getMembers("allScene");
-      for (String sceneCode : allScene) {
-          Set<String> allPid = redisCache.getMembers("scene:"+sceneCode);
-            log.info("allpid{}",allPid);
-      }
-   }
-}

src/main/java/com/fdkk/fdkkmeta/task/UpdateFrameMeta.java

@@ -0,0 +1,34 @@
+package com.fdkk.fdkkmeta.task;
+
+import com.fdkk.fdkkmeta.domain.entity.mysql.UserEntity;
+import com.fdkk.fdkkmeta.redis.RedisCache;
+import com.fdkk.fdkkmeta.service.UserService;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.scheduling.annotation.Scheduled;
+import org.springframework.stereotype.Component;
+
+import java.util.List;
+
+/**
+ * @author Xiewj
+ * @date 2022/3/30
+ */
+@Component
+@Slf4j
+public class UpdateFrameMeta {
+   @Autowired
+   RedisCache redisCache;
+   @Autowired
+    UserService userService;
+
+   @Scheduled(initialDelay=1000, fixedDelay=1000/30)
+   public void updateFrameMetadata(){
+       List<UserEntity> userOnline = userService.findUserOnline(true);
+       for (UserEntity userEntity : userOnline) {
+            redisCache.setCacheObject("updateFrameMetadata:"+userEntity.getUserId(),null);
+       }
+
+
+   }
+}