update

src/move/move.service.ts

@@ -199,7 +199,7 @@ export class MoveService implements OnModuleInit {
           reply.actionResponses.push(actionResponse);
           checkReplys.push(reply);
         }
-      } else {
+      } else if(angle != 0){
         for (let i = angle; i > -1; --i) {
           // console.warn('矫正一次：' + i);
           const reply = await this.rotateService.rotateForAngle(userId, -1);

src/rotate/rotate.service.ts

@@ -10,7 +10,7 @@ const seqExeAsyncFn = (asyncFn) => {
       runPromise = asyncFn.apply(this, args);
       runPromise.then((data) => {
         //debugger;
-        console.log('seq result', data);
+        // console.log('seq result', data);
       });
       runPromise.then(() => (runPromise = null));
       return runPromise;

src/scene/scene.service.ts

@@ -59,7 +59,7 @@ export class SceneService implements OnModuleInit, OnModuleDestroy {
   private clickQueueSub: any;
 
   private streamServiceSub: any;
-  // private roRequestQueue: RxQueue = new DelayQueue(25);
+  // private roRequestQueue: RxQueue = new DelayQueue(20);
   private roQueue: RxQueue = new DelayQueue(10);
   private clickQueue: RxQueue = new DebounceQueue(500);
   private moveQueue: RxQueue = new DelayQueue(20);
@@ -242,7 +242,6 @@ export class SceneService implements OnModuleInit, OnModuleDestroy {
   async handleRotate(request) {
     // this.roRequestQueueSub = this.roRequestQueue.subscribe(
     //   async (request: RotateRequest) => {
-
     try {
       if (this.firstRender) {
         if (!this.roQueueSubscription) {
@@ -317,7 +316,7 @@ export class SceneService implements OnModuleInit, OnModuleDestroy {
       this.logger.error('rotate', error);
       console.log('error', error);
     }
-    // },
+    //   },
     // );
   }