更新定时任务

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

@@ -138,8 +138,9 @@ public class sceneGrpcServer extends SceneGrpcServiceGrpc.SceneGrpcServiceImplBa
             userEntity.setPlayerAngle(player_angle);
             userService.save(userEntity);
 			//todo 存入redis
-//			redisCache.setCacheObject(user_id,null);
-    	}
+			// redisCache.set("updateFrameMetadata:"+userEntity.getUserId(),a.toJSONString());
+
+		}
     	catch(Exception e) {
     		e.printStackTrace();
     	}

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

@@ -1,6 +1,7 @@
 package com.fdkk.fdkkmeta.task;
 
 import cn.hutool.core.util.ArrayUtil;
+import com.alibaba.fastjson.JSONObject;
 import com.fdkk.fdkkmeta.domain.entity.mysql.UserEntity;
 import com.fdkk.fdkkmeta.redis.RedisCache;
 import com.fdkk.fdkkmeta.service.UserService;
@@ -27,10 +28,12 @@ public class UpdateFrameMetaTask {
    public void updateFrameMetadata(){
        List<UserEntity> userOnline = userService.findUserOnline(true);
        log.info("进入定时任务{}", ArrayUtil.isNotEmpty(userOnline)?userOnline.size():0);
+//        JSONObject a=new JSONObject();
+//        a.put("123123",123123);
        //使用并行流处理数据
        userOnline.parallelStream().forEach(
                userEntity -> {
-                   redisCache.setCacheObject("updateFrameMetadata:"+userEntity.getUserId(),null);
+//                   redisCache.set("updateFrameMetadata:"+userEntity.getUserId(),a.toJSONString());
                }
        );