更新

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

@@ -49,7 +49,7 @@ public class UpdateFrameMetaTask {
     SceneGrpcService sceneGrpcService;
     @Autowired
     BreakpointsService breakpointsService;
-    @Scheduled(initialDelay=200, fixedDelay=1000)
+    @Scheduled(initialDelay=200, fixedDelay=1000/30)
    public void updateFrameMetadata(){
        List<UserEntity> userOnline = userService.findUserOnline(true);
        log.info("进入定时任务{}", ArrayUtil.isNotEmpty(userOnline)?userOnline.size():0);
@@ -75,7 +75,7 @@ public class UpdateFrameMetaTask {
             }
 
             List<ActionPO> rotateJoystickList = new ArrayList<ActionPO>();
-            JSONObject myState = redisCache.getCacheObject("UserState"+user.getUserId());
+            JSONObject myState = redisCache.getCacheObject("UserState:"+user.getUserId());
 
             ActionPO _actionPO = list.get(0);
             int firstActionType = _actionPO.getAction_type();
@@ -115,10 +115,10 @@ public class UpdateFrameMetaTask {
                             playerAngle.setYaw(_angle);
                             _actionPO.setPlayerAngle(playerAngle);
                             //更新redis记录
-                            redisCache.setCacheListByIndex("setCacheRequest"+user.getUserId(),0,_actionPO);
+                            redisCache.setCacheListByIndex("setCacheRequest:"+user.getUserId(),0,_actionPO);
 
                             myState.put("isMoving",0);
-                            redisCache.setCacheObject("UserState"+user.getUserId(),myState);
+                            redisCache.setCacheObject("UserState:"+user.getUserId(),myState);
 
                             //moveFrameEntity = moveFrameService.findByAppIAndStartBreakPointIdAndEndBreakPointIdAndAngleAndFrameIndex(user.getAppId(), startBreakPointId, endBreakPointId,_actionPO.getCameraAngle().getYaw(),0);
                             user.setFrameId(rotateFrameEntity.getId());
@@ -130,7 +130,7 @@ public class UpdateFrameMetaTask {
                         //过渡全部结束
                         else{
                             //删除redis里的数据
-                            redisCache.lTrim("setCacheRequest"+user.getUserId(),1,-1);
+                            redisCache.lTrim("setCacheRequest:"+user.getUserId(),1,-1);
                             //更新user表
                             //moveFrameEntity = moveFrameService.findByAppIAndStartBreakPointIdAndEndBreakPointIdAndAngleAndFrameIndex(user.getAppId(), startBreakPointId, endBreakPointId,_actionPO.getCameraAngle().getYaw(),_actionPO.getFrameIndex());
                             user.setPlayerPosition(endBreakpointsEntity.getPosition());
@@ -140,7 +140,7 @@ public class UpdateFrameMetaTask {
                             userService.updateById(user);
 
                             myState.put("isMoving",0);
-                            redisCache.setCacheObject("UserState"+user.getUserId(),myState);
+                            redisCache.setCacheObject("UserState:"+user.getUserId(),myState);
                             //执行下一条记录
                             list.remove(0);
                         }
@@ -160,20 +160,20 @@ public class UpdateFrameMetaTask {
                     playerPosition.setZ((_actionPO.getEndPosition().getZ() - _actionPO.getStartPostion().getZ())/_actionPO.getSubFrameIndex()*_actionPO.getFrameIndex());
                     createMoveFrameMetadata(user.getUserId(),_actionPO.getPlayerAngle(), playerPosition, moveFrameEntity,_actionPO.getTrace_id());
                     //更新redis里的数据
-                    redisCache.setCacheListByIndex("setCacheRequest"+user.getUserId(),0,_actionPO);
+                    redisCache.setCacheListByIndex("setCacheRequest:"+user.getUserId(),0,_actionPO);
                 }
                 else if(myState.getIntValue("isMoving") == 0){
                     if(list.size()>0){
                         //中断,执行下一条记录
                         list.remove(0);
-                        redisCache.lTrim("setCacheRequest"+user.getUserId(),1,-1);
+                        redisCache.lTrim("setCacheRequest:"+user.getUserId(),1,-1);
                         handle( user,list);
                         return ;
                     }
                     else{
                         //过渡
                         myState.put("isMoving",1);
-                        redisCache.setCacheObject("UserState"+user.getUserId(),myState);
+                        redisCache.setCacheObject("UserState:"+user.getUserId(),myState);
 
                         MoveFrameEntity moveFrameEntity = moveFrameService.findByAppIAndStartBreakPointIdAndEndBreakPointIdAndAngleAndFrameIndex(user.getAppId(), startBreakPointId, endBreakPointId,_actionPO.getCameraAngle().getYaw(),_actionPO.getFrameIndex()+1);
                         //更新
@@ -185,7 +185,7 @@ public class UpdateFrameMetaTask {
                         _actionPO.setStartPostion(startBreakpointsEntity.getPosition());
                         _actionPO.setEndPosition(endBreakpointsEntity.getPosition());
                         //更新redis里的数据
-                        redisCache.setCacheListByIndex("setCacheRequest"+user.getUserId(),0,_actionPO);
+                        redisCache.setCacheListByIndex("setCacheRequest:"+user.getUserId(),0,_actionPO);
                     }
                 }
                 /****************************************************************************************/
@@ -209,7 +209,7 @@ public class UpdateFrameMetaTask {
             }
             createRotateFrameMetadata( user, rotateJoystickList, firstActionType);
             //删除redis里的数据
-            redisCache.lTrim("setCacheRequest"+user.getUserId(),rotateJoystickList.size(),-1);
+            redisCache.lTrim("setCacheRequest:"+user.getUserId(),rotateJoystickList.size(),-1);
             //更新user表
             user.setFrameId(lastFrameId);
             userService.updateById(user);