meta-server/src/rotate/rotate.service.ts

import { Injectable, Logger } from '@nestjs/common';
import { CacheService } from 'src/cache/cache.service';
// import { SceneService } from 'src/scene/scene.service';

const seqExeAsyncFn = (asyncFn) => {
  let runPromise = null;
  return function seq(...args) {
    if (!runPromise) {
      //debugger;
      runPromise = asyncFn.apply(this, args);
      runPromise.then((data) => {
        //debugger;
        // console.log('seq result', data);
      });
      runPromise.then(() => (runPromise = null));
      return runPromise;
    } else {
      return runPromise.then(() => seq.apply(this, args));
    }
  };
};

@Injectable()
export class RotateService {
  constructor(
    private cacheService: CacheService, // private sceneService: SceneService,
  ) {}
  private actionRequestPool = {};
  private logger: Logger = new Logger('rotateService');
  private Actions = {
    Clicking: 1,
    Rotation: 1014,
    Joystick: 15,
  };
  public users = {};
  private replies = {};

  init(app_id: string, userId: string) {
    const user = {
      appId: null,
      userId: null,
      breakPointId: null,
      roomId: null,
      player: {
        position: { x: -800.0, y: 100.0, z: 0.0 },
        angle: {
          pitch: 0,
          yaw: 0,
          roll: 0,
        },
      },
      camera: {
        position: { x: -1139.3031005859375, y: 99.99999237060548, z: 120.0 },
        angle: {
          pitch: 0,
          yaw: 0,
          roll: 0,
        },
      },
      rotateInfo: {
        frameIndex: 0,
        horizontal_move: 0,
      },
      moveInfo: {},
      // traceIds: [],
      // actionResponses:[]
    };

    user.appId = app_id;
    user.userId = userId;
    user.breakPointId = 93;
    this.users[userId] = user;

    const reply = {
      traceIds: [],
      vehicle: null,
      mediaSrc: null,
      newUserStates: [
        {
          userId: 'dcff36ae4fc1d',
          playerState: {
            roomTypeId: '',
            person: 0,
            avatarId: '',
            skinId: '',
            roomId: '',
            isHost: false,
            isFollowHost: false,
            skinDataVersion: '',
            avatarComponents: '',
            nickName: '',
            movingMode: 0,
            attitude: '',
            areaName: '',
            pathName: '',
            pathId: '',
            avatarSize: 1,
            extra: '',
            prioritySync: false,
            player: {
              position: { x: 100.0, y: 100.0, z: 0.0 },
              angle: {
                pitch: 0,
                yaw: 0,
                roll: 0,
              },
            },
            camera: {
              position: { x: -338.0, y: 100, z: 120.0 },
              angle: {
                pitch: 0,
                yaw: 0,
                roll: 0,
              },
            },
            cameraCenter: { x: 100.0, y: 100.0, z: 0.0 },
          },
          renderInfo: {
            renderType: 0,
            videoFrame: null,
            cameraStateType: 3,
            isMoving: 0,
            needIfr: 0,
            isVideo: 0,
            stillFrame: 0,
            isRotating: 0,
            isFollowing: 0,
            clientPanoTitlesBitmap: [],
            clientPanoTreceId: '',
            prefetchVideoId: '',
            noMedia: false,
          },
          event: null,
          relation: 1,
        },
      ],
      actionResponses: [
        // {
        //     "actionType": 15,
        //     "pointType": 100,
        //     "extra": "",
        //     "traceId": "d0864cd0-378d-4d49-b7b0-3e8e1b9494c3",
        //     "packetId": "d44bd2f5-f877-4dd7-868b-803c64f99082",
        //     "nps": [],
        //     "peopleNum": 0,
        //     "zoneId": "",
        //     "echoMsg": "",
        //     "reserveDetail": null,
        //     "userWithAvatarList": [],
        //     "newUserStates": [],
        //     "code": 0,
        //     "msg": ""
        // }
      ],
      getStateType: 0,
      code: 0,
      msg: 'OK',
    };

    reply['newUserStates'][0]['userId'] = userId;
    this.replies[userId] = reply;
    return reply;
  }

  // 顺序旋转请求
  seqExeRotate = seqExeAsyncFn(this.rotate);

  //旋转请求
  async rotate(actionRequest) {
    // return new Promise(async (resolve, reject) => {
    try {
      const userId = actionRequest['user_id'];
      if (this.actionRequestPool[userId]) {
        this.actionRequestPool[userId].push(actionRequest);
      } else {
        this.actionRequestPool[userId] = [];
        this.actionRequestPool[userId].push(actionRequest);
      }

      let reply = this.replies[userId];

      const actionRequests = this.actionRequestPool[userId];
      const user = this.users[userId];
      // debugger;
      let horizontal_move = user.rotateInfo.horizontal_move;
      //const traceIds = user.traceIds;
      let sub = 0;
      for (let i = 0; i < actionRequests.length; ++i) {
        if (actionRequests[i].action_type == this.Actions.Rotation) {
          horizontal_move += actionRequests[i].rotation_action.horizontal_move;
          reply.traceIds.push(actionRequests[i].trace_id);
          const actionResponse = this.createActionResponse(
            actionRequests[i].action_type,
            actionRequests[i].trace_id,
          );
          reply.actionResponses.push(actionResponse);
          ++sub;
        } else {
          break;
        }
      }

      actionRequests.splice(0, sub);
      const hAngle = horizontal_move * 90;
      if (Math.abs(hAngle) < 1) {
        user.rotateInfo.horizontal_move = horizontal_move;
        //user.traceIds = traceIds;
        this.replies[userId] = reply;
        return null;
      }
      reply = await this.rotateForAngle(userId, Math.floor(hAngle));
      // console.log('rotate-cameraAngle：, yaw: %s, ', user.camera.angle.yaw);
      return reply;
      // return resolve(reply);
    } catch (error) {
      throw error;
      // console.log('RotateService', error);
      // return reject(error);
    }
    // });
  }

  // test(){
  //   while(true){
  //     if(this.actionRequests.length>0){
  //       let actionRequest = this.actionRequests[0];
  //       //执行
  //       //添加队列
  //     }
  //   }
  // }

  // receiveRotate(actionRequest){
  //   this.actionRequests.push(actionRequest)
  // }

  rotateForAngle(userId, hAngle): Promise<any> {
    return new Promise(async (resolve, reject) => {
      try {
        const user = this.users[userId];
        // console.log(
        //   '当前镜头角度, yaw: %s, hAngle: %s',
        //   user.camera.angle.yaw,
        //   hAngle,
        // );
        // console.time('当前镜头角度 %s', user.camera.angle.yaw, '旋转角度：', hAngle);
        user.camera.angle.yaw += Math.floor(hAngle);
        if (user.camera.angle.yaw < 0) {
          user.camera.angle.yaw = 360 + user.camera.angle.yaw;
        } else if (user.camera.angle.yaw > 359) {
          user.camera.angle.yaw -= 360;
        }
        const reply = JSON.parse(JSON.stringify(this.replies[userId]));
        reply['newUserStates'][0]['userId'] = userId;
        //从redis里取
        //let key = user.appId + "-"+user.breakPointId+"-"+user.rotateInfo.frameIndex;
        const key =
          'rotateframe:app_id:' +
          user.appId +
          ':frame_index:' +
          user.camera.angle.yaw +
          ':break_point_id:' +
          user.breakPointId;
        // const value = null;

        const redisData = await this.cacheService.get(key);
        //if (redisData && redisData.length > 0) {
        const value = JSON.parse(redisData); //redisData ? JSON.parse(redisData) : null;
        // console.log('rotate-service', value);
        user.camera['position'] = JSON.parse(JSON.stringify(value.cameraPosition)); //value ? value.cameraPosition : '';
        user.camera['angle'] = JSON.parse(JSON.stringify(value.cameraAngle)); //value ? value.cameraAngle : '';

        reply['newUserStates'][0]['playerState'].player.position = JSON.parse(JSON.stringify(user.player.position));
        reply['newUserStates'][0]['playerState'].player.angle = JSON.parse(JSON.stringify(user.player.angle));
        //this.reply['newUserStates'][0]['playerState'] .player
        reply['newUserStates'][0]['playerState'].camera.position = JSON.parse(JSON.stringify(value.cameraPosition));
        reply['newUserStates'][0]['playerState'].camera.angle = JSON.parse(JSON.stringify(value.cameraAngle));
        reply['newUserStates'][0]['playerState'].cameraCenter = JSON.parse(JSON.stringify(user.player.position));
        // debugger
        reply.mediaSrc =
          '/' +
          user.appId +
          '/' +
          user.breakPointId +
          '/' +
          value.directory +
          '/' +
          value.fileName +
          '?m=' +
          new Date().getTime();
        reply.breakPointId = user.breakPointId;
        this.replies[userId].traceIds = [];
        this.replies[userId].actionResponses = [];

        user.rotateInfo.horizontal_move = 0;
        return resolve(reply);
        //}
        // else {
        //   return null;
        // }
      } catch (error) {
        this.logger.error('rotateForAngle::function', error);
        return reject(error);
      }
    });
  }

  createActionResponse(actionType, traceId) {
    const actionResponse = {
      actionType: actionType,
      pointType: 100,
      extra: '',
      traceId: traceId,
      packetId: '',
      nps: [],
      peopleNum: 0,
      zoneId: '',
      echoMsg: '',
      reserveDetail: null,
      userWithAvatarList: [],
      newUserStates: [],
      code: 0,
      msg: '',
    };
    return actionResponse;
  }

  getNewUserStateRequest(actionRequest) {
    try {
      const userId = actionRequest['user_id'];
      const actionType = actionRequest['action_type'];
      const traceId = actionRequest['trace_id'];

      const reply = {
        actionType: actionType,
        pointType: 100,
        extra: '',
        traceId: traceId,
        packetId: '',
        nps: [],
        peopleNum: 0,
        zoneId: '',
        echoMsg: '',
        reserveDetail: null,
        userWithAvatarList: [],
        newUserStates: [],
        code: 0,
        msg: '',
      };

      const userIds = Object.keys(this.users);
      for (let i = 0; i < userIds.length; ++i) {
        const _user = this.users[userIds[i]];
        const newUserState = {
          userId: userIds[i],
          playerState: {
            roomTypeId: '',
            person: 0,
            avatarId: 'KGe_Boy',
            skinId: '10089',
            roomId: 'e629ef3e-022d-4e64-8654-703bb96410eb',
            isHost: false,
            isFollowHost: false,
            skinDataVersion: '1008900008',
            avatarComponents: '',
            nickName: userIds[i],
            movingMode: 0,
            attitude: 'walk',
            areaName: '',
            pathName: 'thirdwalk',
            pathId: 'thirdwalk',
            avatarSize: 1,
            extra: '{"removeWhenDisconnected":true}',
            prioritySync: false,
            player: {
              position: _user.player.position,
              angle: _user.player.angle,
            },
            camera: null,
            cameraCenter: null,
          },
          renderInfo: {
            renderType: 0,
            videoFrame: null,
            cameraStateType: 0,
            isMoving: 0,
            needIfr: 0,
            isVideo: 0,
            stillFrame: 0,
            isRotating: 0,
            isFollowing: 0,
            clientPanoTitlesBitmap: [],
            clientPanoTreceId: '',
            prefetchVideoId: '',
            noMedia: false,
          },
          event: {
            id: '',
            type: 0,
            points: [],
            rotateEvent: null,
            removeVisitorEvent: null,
          },
          relation: 0,
        };

        reply['newUserStates'].push(newUserState);
      }

      return reply;
    } catch (error) {
      this.logger.error('getNewUserStateRequest::function', error);
    }
  }

  async echo(userId: string, isFirst: boolean) {
    const user = this.users[userId];
    const reply = JSON.parse(JSON.stringify(this.replies[userId]));
    reply['newUserStates'][0]['userId'] = userId;
    reply['newUserStates'][0]['playerState'].player.position =
      user.player.position;
    reply['newUserStates'][0]['playerState'].player.angle = user.player.angle;
    reply['newUserStates'][0]['playerState'].camera.position =
      user.camera['position'];
    reply['newUserStates'][0]['playerState'].camera.angle =
      user.camera['angle'];
    reply['newUserStates'][0]['playerState'].cameraCenter =
      user.player.position;

    if (isFirst) {
      reply.mediaSrc =
        '/' +
        user.appId +
        '/' +
        user.breakPointId +
        '/' +
        user.breakPointId +
        '/' +
        `${user.breakPointId}.0000.h264` +
        '?m=' +
        new Date().getTime();
      reply.breakPointId = user.breakPointId;
      return reply;
    } else {
      const key =
        'rotateframe:app_id:' +
        user.appId +
        ':frame_index:' +
        user.camera.angle.yaw +
        ':break_point_id:' +
        user.breakPointId;
      const redisData = await this.cacheService.get(key);
      if (redisData && redisData.length > 0) {
        const value = redisData ? JSON.parse(redisData) : null;
        reply.mediaSrc =
          '/' +
          user.appId +
          '/' +
          user.breakPointId +
          '/' +
          value.directory +
          '/' +
          value.fileName +
          '?m=' +
          new Date().getTime();
        reply.breakPointId = user.breakPointId;
        return reply;
      } else {
        this.logger.error('echo返回null', key);
        return {};
      }
    }
  }
}