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

import { Injectable, Logger, OnModuleInit } from '@nestjs/common';
import { ConfigService } from '@nestjs/config';
import { readFileSync } from 'fs';
import { join } from 'path';
import { CacheService } from 'src/cache/cache.service';
import { RotateService } from 'src/rotate/rotate.service';

// import * as  BreakPointIds from '../../ws/points-BreakPointId.json';
// 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 MoveService implements OnModuleInit {
  constructor(
    private cacheService: CacheService,
    private rotateService: RotateService,
    private configService: ConfigService,
  ) {}
  private logger: Logger = new Logger('MoveService');
  private Actions = {
    Clicking: 1,
    Rotation: 1014,
    Joystick: 15,
  };
  public users = this.rotateService.users;

  private reply = {
    traceIds: [],
    vehicle: null,
    mediaSrc: null,
    moveOver:false,
    moveStart:false,
    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: -700, y: 0, z: 0 },
            angle: {
              pitch: 0,
              yaw: 0,
              roll: 0,
            },
          },
          camera: {
            position: { x: -1145, y: 0, z: 160 },
            angle: {
              pitch: 0,
              yaw: 0,
              roll: 0,
            },
          },
          cameraCenter: { x: -700, y: 0, z: 0 },
        },
        renderInfo: {
          renderType: 0,
          videoFrame: null,
          cameraStateType: 3,
          isMoving: 1,
          needIfr: 0,
          isVideo: 0,
          stillFrame: 0,
          isRotating: 0,
          isFollowing: 0,
          clientPanoTitlesBitmap: [],
          clientPanoTreceId: '',
          prefetchVideoId: '',
          noMedia: false,
        },
        event: null,
        relation: 1,
      },
    ],
    actionResponses: [
      {
        actionType: 1,
        pointType: 100,
        extra: '',
        traceId: '',
        packetId: '',
        nps: [],
        peopleNum: 0,
        zoneId: '',
        echoMsg: '',
        reserveDetail: null,
        userWithAvatarList: [],
        newUserStates: [],
        code: 0,
        msg: '',
      },
    ],
    getStateType: 0,
    code: 0,
    msg: 'OK',
  };
  private breakPointInfo: any;

  private cameraInfos = [];
  public sendingFrameForJoystick = false;

  // eslint-disable-next-line @typescript-eslint/no-empty-function
  async onModuleInit() {
    const app_id = '0000000003';
    const prefix = '/mnt/metaverse/scene';
    let path;
    // let path: string;
    if (process.env.NODE_ENV === 'development') {
      path = join(__dirname, `../ws/${app_id}/points-${app_id}.json`);
      console.log('测试服JSON', path);
    }
    if (process.env.NODE_ENV === 'production') {
      path = join(`${prefix}/${app_id}/points-${app_id}.json`);
      console.log('正式服JSON', path);
    }
    this.loadJSON(path);
  }

  async loadJSON(path) {
    try {
      const data = await readFileSync(path);
      const BreakPointInfo = JSON.parse(Buffer.from(data).toString('utf-8'));
      this.breakPointInfo = BreakPointInfo;
      // console.log('BreakPointInfo', BreakPointInfo);
    } catch (error) {
      this.logger.error('load-json-error', error);
    }
  }

  init(app_id, userId) {
    const user = {
      appId: null,
      userId: null,
      breakPointId: null,
      roomId: null,
      player: {
        position: { x: -700, y: 0, z: 0 },
        angle: {
          pitch: 0,
          yaw: 0,
          roll: 0,
        },
      },
      camera: {
        position: { x: -1145, y: 0, z: 160 },
        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 = Number(this.configService.get('app.startPoint')) || 0;
    console.log('user-init', user);
    this.users[userId] = user;
  }

  async move(pathArray, actionRequest) {
    try {
      const userId = actionRequest['user_id'];
      const traceId = actionRequest['trace_id'];
      const actionType = actionRequest['action_type'];
      const user = this.users[userId];

      const appId = user.appId;
      const path = pathArray || [100, 101, 102]; //需要计算路径
      const angle = user.camera.angle.yaw % 45; //纠正需要
      const replys = [];
      const traceIds = [];
      traceIds.push(traceId);

      const checkReplys = await this.modeifyCameraAngle(
        angle,
        userId,
        traceId,
        actionType,
      );
      for (let i = 0; i < checkReplys.length; ++i) {
        checkReplys[i].actionResponses[0].actionType = actionType;
      }
      //replys['P' + user.breakPointId + 'T' + user.breakPointId] = checkReplys;
      replys.push(checkReplys);
      console.log('路径：' + path);
      //过渡传到缓存里
      this.reply.traceIds = traceIds;
      this.reply['newUserStates'][0].userId = userId;
      this.reply['actionResponses'][0].traceId = traceId;
      const index = Math.floor((user.camera.angle.yaw + 1) / 45); //过渡需要
      for (let i = 0; i < path.length - 1; ++i) {
        let pathReplys = [];
        const start_break_point_id = path[i];
        const end_break_point_id = path[i + 1];
        //读redis里的数据，按照frame_index的大小排序
        const key =
          'moveframe:app_id:' +
          appId +
          ':start_break_point_id:' +
          start_break_point_id +
          ':end_break_point_id:' +
          end_break_point_id +
          ':angle:' +
          index;
        const moveFramesRes = await this.cacheService.get(key);
        if (moveFramesRes == null) {
          return replys;
        }
        const moveFrames = JSON.parse(moveFramesRes);
        pathReplys = this.createCacheReplys(
          appId,
          moveFrames,
          traceId,
          userId,
          start_break_point_id,
          end_break_point_id,
          false,
        );

        if (i == path.length - 2) {
          pathReplys[pathReplys.length - 1][
            'newUserStates'
          ][0].renderInfo.isMoving = 0;
        }
        for (let j = 0; j < pathReplys.length; ++j) {
          pathReplys[j].actionResponses[0].actionType = actionType;
        }
        replys.push(pathReplys);
        //replys['P' + start_break_point_id + 'T' + end_break_point_id] =pathReplys;
      }
      return replys;
    } catch (error) {
      console.log('MoveService', error);
    }
  }

  createCacheReplys(
    appId,
    moveFrames,
    traceId,
    userId,
    startBreakPointId,
    endBreakPointId,
    isFromUser,
  ) {
    const replys = [];
    const startPosition = this.breakPointInfo[startBreakPointId].position;
    const endPosition = this.breakPointInfo[endBreakPointId].position;
    const angle = this.getAngle(
      startPosition,
      {
        x: startPosition.x + 1,
        y: startPosition.y,
      },
      endPosition,
    );
    const user = this.users[userId];
    let i;
    for (i = 1; i < moveFrames.length; i += 5) {
      const moveFrame = moveFrames[i];
      const reply = JSON.parse(JSON.stringify(this.reply));
      if (reply.traceIds.indexOf(traceId) == -1) {
        reply.traceIds.push(traceId);
      }
      reply['newUserStates'][0].userId = userId;

      if (!isFromUser) {
        reply['newUserStates'][0].playerState.player.position = {
          x:
            startPosition.x +
            ((endPosition.x - startPosition.x) / moveFrames.length) * i,
          y:
            startPosition.y +
            ((endPosition.y - startPosition.y) / moveFrames.length) * i,
          z:
            startPosition.z +
            ((endPosition.z - startPosition.z) / moveFrames.length) * i,
        };

        reply['newUserStates'][0].playerState.player.angle.yaw = angle;
        reply['newUserStates'][0].playerState.cameraCenter =
          reply['newUserStates'][0].playerState.player.position;
      } else {
        reply['newUserStates'][0].playerState.player.position = JSON.parse(
          JSON.stringify(user.player.position),
        );
        reply['newUserStates'][0].playerState.player.angle.yaw =
          user.player.angle.yaw;
        reply['newUserStates'][0].playerState.cameraCenter = JSON.parse(
          JSON.stringify(user.player.position),
        );
      }

      reply['newUserStates'][0].playerState.camera.position = JSON.parse(
        JSON.stringify(moveFrame.camera_position),
      );
      if (i == 1) {
        console.log('move-2' + moveFrame.camera_angle.yaw);
      }
      if (moveFrame.camera_angle.yaw < 0) {
        moveFrame.camera_angle.yaw += 360;
      } else if (moveFrame.camera_angle.yaw > 359) {
        moveFrame.camera_angle.yaw -= 360;
      }

      reply['newUserStates'][0].playerState.camera.angle =
        moveFrame.camera_angle;
      reply['newUserStates'][0].renderInfo.isMoving = 1;
      reply['actionResponses'][0].traceId = traceId;

      reply.mediaSrc =
        '/' +
        appId +
        '/' +
        startBreakPointId +
        '/' +
        moveFrame.file_name.substring(0, moveFrame.file_name.indexOf('.')) +
        '/' +
        moveFrame.file_name +
        '?m=' +
        new Date().getTime();
      if (moveFrame.file_name == '6_7_0.0031.h264') {
        debugger;
      }
      reply.startBreakPointId = startBreakPointId;
      reply.endBreakPointId = endBreakPointId;
      replys.push(reply);
    }
    if (i != moveFrames.length - 1) {
      i = moveFrames.length - 1;
      const moveFrame = moveFrames[i];
      const reply = JSON.parse(JSON.stringify(this.reply));
      reply.traceIds.push(traceId);
      reply['newUserStates'][0].userId = userId;

      if (!isFromUser) {
        reply['newUserStates'][0].playerState.player.position = {
          x:
            startPosition.x +
            ((endPosition.x - startPosition.x) / moveFrames.length) * i,
          y:
            startPosition.y +
            ((endPosition.y - startPosition.y) / moveFrames.length) * i,
          z:
            startPosition.z +
            ((endPosition.z - startPosition.z) / moveFrames.length) * i,
        };

        reply['newUserStates'][0].playerState.player.angle.yaw = angle;
        reply['newUserStates'][0].playerState.cameraCenter =
          reply['newUserStates'][0].playerState.player.position;
      } else {
        reply['newUserStates'][0].playerState.player.position = JSON.parse(
          JSON.stringify(user.player.position),
        );
        reply['newUserStates'][0].playerState.player.angle.yaw =
          user.player.angle.yaw;
        reply['newUserStates'][0].playerState.cameraCenter = JSON.parse(
          JSON.stringify(user.player.position),
        );
      }

      reply['newUserStates'][0].playerState.camera.position =
        moveFrame.camera_position;
      if (moveFrame.camera_angle.yaw < 0) {
        moveFrame.camera_angle.yaw += 360;
      } else if (moveFrame.camera_angle.yaw > 359) {
        moveFrame.camera_angle.yaw -= 360;
      }

      reply['newUserStates'][0].playerState.camera.angle =
        moveFrame.camera_angle;

      reply['actionResponses'][0].traceId = traceId;

      reply.mediaSrc =
        '/' +
        appId +
        '/' +
        startBreakPointId +
        '/' +
        moveFrame.file_name.substring(0, moveFrame.file_name.indexOf('.')) +
        '/' +
        moveFrame.file_name +
        '?m=' +
        new Date().getTime();
      reply.startBreakPointId = startBreakPointId;
      reply.endBreakPointId = endBreakPointId;
      replys.push(reply);
    }
    return replys;
  }

  //需要通知user，人物和相机走到哪一个呼吸点位了
  updateUser(userId, breakPointId, lastReply) {
    const user = this.users[userId];
    user.breakPointId = breakPointId;
    console.log('handlejoystick:updateUser');
    if (lastReply.actionResponses[0].actionType != 15) {
      user.player.position =
        lastReply['newUserStates'][0].playerState.player.position;
    }
    user.player.angle = lastReply['newUserStates'][0].playerState.player.angle;
    user.camera.position =
      lastReply['newUserStates'][0].playerState.camera.position;
    user.camera.angle = lastReply['newUserStates'][0].playerState.camera.angle;
  }

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

    const user = this.users[userId];
    const appId = user.appId;
    const breakPointId = user.breakPointId;

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

    //const breakPoints = await this.cacheService.get('breakpoints:app_id:'+appId+':break_point_id:'+breakPointId);
    //获取redis表全部元素，'breakpoints:app_id:'+appId+':break_point_id:'开头的
    //const keys = await this.cacheService.keys(`breakpoints:app_id:${appId}*`);
    for (const key in this.breakPointInfo) {
      const breakPoint = this.breakPointInfo[key];
      //const breakPoint = JSON.parse(breakPointRes);
      //const position = breakPoint.position;
      reply['nps'].push({
        position: breakPoint.position,
        breakPointId: Number(key),
      });
    }
    // for (let i = 0; i < keys.length; ++i) {
    //   const breakPointRes = await this.cacheService.get(keys[i]);
    //   const breakPoint = JSON.parse(breakPointRes);
    //   const position = breakPoint.position;
    //   reply['nps'].push({
    //     position: position,
    //     breakPointId: breakPoint.breakPointId,
    //   });
    // }
    return reply;
  }

  getAngle(point, point1, point2) {
    const x1 = point1.x - point.x;
    const y1 = point1.y - point.y;

    const x2 = point2.x - point.x;
    const y2 = point2.y - point.y;

    const dot = x1 * x2 + y1 * y2;
    const det = x1 * y2 - y1 * x2;
    const angle = (Math.atan2(det, dot) / Math.PI) * 180;
    return (angle + 360) % 360;
  }

  async stop(traceId, userId, breakPointId, cameraAngle, playerAngle) {
    //const breakPointId = movePointIds.substring(movePointIds.indexOf('-') + 1);
    const user = this.users[userId];
    const startBreakPointId = user.breakPointId;
    user.breakPointId = breakPointId;
    const appId = user.appId;

    const breakPoint = this.breakPointInfo[breakPointId];
    user.player.position = breakPoint.position;
    user.player.angle = playerAngle;

    const rotateKey =
      'rotateframe:app_id:' +
      appId +
      ':frame_index:' +
      cameraAngle.yaw +
      ':break_point_id:' +
      breakPointId;

    const rotateDataRes = await this.cacheService.get(rotateKey);
    const rotateData = JSON.parse(rotateDataRes);
    user.camera.position = rotateData.cameraPosition;
    user.camera.angle = rotateData.cameraAngle;

    const reply = JSON.parse(JSON.stringify(this.reply));
    reply.traceIds.push(traceId);
    reply['newUserStates'][0].userId = userId;
    reply['newUserStates'][0].playerState.player.position = breakPoint.position;
    reply['newUserStates'][0].playerState.player.angle = playerAngle;
    reply['newUserStates'][0].playerState.camera.position =
      rotateData.cameraPosition;
    reply['newUserStates'][0].playerState.camera.angle = rotateData.cameraAngle;
    reply['newUserStates'][0].playerState.cameraCenter = breakPoint.position;
    reply['actionResponses'][0].traceId = traceId;
    reply.mediaSrc =
      '/' +
      appId +
      '/' +
      breakPointId +
      '/' +
      rotateData.directory +
      '/' +
      rotateData.fileName +
      '?m=' +
      new Date().getTime();
    reply.startBreakPointId = startBreakPointId;
    reply.endBreakPointId = breakPointId;
    reply['newUserStates'][0].renderInfo.isMoving = 0;
    return reply;
  }
  // 顺序旋转请求
  seqExeJoystick = seqExeAsyncFn(this.joystick);

  // async joystick(actionRequest) {
  //   try {
  //     const userId = actionRequest['user_id'];
  //     const traceId = actionRequest['trace_id'];
  //     const dir_action = actionRequest['dir_action'];
  //     const actionType = actionRequest['action_type'];
  //     const user = this.users[userId];
  //     const breakPointId = user.breakPointId;
  //     const appId = user.appId;

  //     const replys = [];
  //     const step = 0.3;
  //     const closestDis = 85; //小于这个距离就跳到邻居呼吸点
  //     const distance = step * dir_action.speed_level;
  //     let angle = null;
  //     let move_angle = dir_action.move_angle + user.camera.angle.yaw;
  //     move_angle = move_angle % 360;

  //     //TODO 临时增加断言
  //     const playerPosition: Point = { x: 0, y: 0, z: 0 };
  //     playerPosition.x =
  //       user.player.position.x +
  //       distance * Math.cos((move_angle / 360) * 2 * Math.PI);
  //     playerPosition.y =
  //       user.player.position.y +
  //       distance * Math.sin((move_angle / 360) * 2 * Math.PI);

  //     //找到邻居点，判断user.player.position与邻居点的距离，如果距离小于closestDis，就要更新camera的position
  //     let chooseBreakPointId = null;
  //     const breakPoint = this.breakPointInfo[breakPointId];
  //     const surroundPointIds = breakPoint.contact;
  //     //const neighAngles = [];
  //     const traceIds = [];

  //     user.player.angle.yaw = move_angle;
  //     traceIds.push(traceId);
  //     this.reply.traceIds = traceIds;
  //     this.reply['newUserStates'][0].userId = userId;
  //     this.reply['actionResponses'][0].traceId = traceId;
  //     this.reply['newUserStates'][0].playerState.player.angle.yaw = move_angle;

  //     this.reply['newUserStates'][0].playerState.camera.angle = JSON.parse(
  //       JSON.stringify(user.camera.angle),
  //     );
  //     this.reply['newUserStates'][0].playerState.camera.position = JSON.parse(
  //       JSON.stringify(user.camera.position),
  //     );
  //     this.reply['newUserStates'][0].playerState.cameraCenter = JSON.parse(
  //       JSON.stringify(breakPoint.position),
  //     );
  //     this.reply['newUserStates'][0].renderInfo.isMoving = 1;
  //     this.reply['actionResponses'][0].traceId = traceId;
  //     this.reply.mediaSrc = null;

  //     if (surroundPointIds.length == 1) {
  //       return await this.moveDirect(
  //         playerPosition,
  //         closestDis,
  //         breakPointId,
  //         surroundPointIds[0],
  //         appId,
  //         userId,
  //         traceId,
  //         actionType,
  //       );
  //     }

  //     let count = 0;
  //     const neighPoints = [];
  //     //人在哪个角度
  //     let _angle = this.getAngle(
  //       breakPoint.position,
  //       { x: breakPoint.position.x + 1, y: breakPoint.position.y },
  //       playerPosition,
  //     );
  //     if (_angle < 0) {
  //       _angle += 360;
  //     }

  //     let singleInfo = null;
  //     for (let i = 0; i < surroundPointIds.length; ++i) {
  //       const neighPoint = this.breakPointInfo[surroundPointIds[i]];
  //       neighPoint.breakPointId = surroundPointIds[i];
  //       angle = this.getAngle(
  //         breakPoint.position,
  //         { x: breakPoint.position.x + 1, y: breakPoint.position.y },
  //         neighPoint.position,
  //       );
  //       if (angle < 0) {
  //         angle += 360;
  //       }

  //       //if(angle<45&&angle!=0){
  //       if (
  //         // Math.abs(angle - move_angle) < 45 &&
  //         // Math.abs(angle - move_angle) != 0
  //         Math.abs(angle - _angle) < 45 &&
  //         Math.abs(angle - _angle) != 0
  //       ) {
  //         neighPoint.angle = angle;
  //         neighPoints.push(neighPoint);
  //         ++count;
  //       } else if (Math.abs(angle - move_angle) == 0) {
  //         return await this.moveDirect(
  //           playerPosition,
  //           closestDis,
  //           breakPointId,
  //           surroundPointIds[i],
  //           appId,
  //           userId,
  //           traceId,
  //           actionType,
  //         );
  //       }

  //       //if (angle == 0 && Math.abs(360 - move_angle) < 45) {
  //       if (angle == 0 && Math.abs(360 - _angle) < 45) {
  //         neighPoint.angle = angle;
  //         neighPoints.push(neighPoint);
  //         ++count;
  //       }

  //       if(Math.abs(angle - move_angle)<45||Math.abs(angle+360 - move_angle)<45){
  //         if(singleInfo == null){
  //           singleInfo = {
  //             angle:angle,
  //             breakPointId:surroundPointIds[i]
  //           }
  //         }
  //       }
  //     }

  //     if (count == 2) {
  //       //人物移动
  //       user.player.position = JSON.parse(JSON.stringify(playerPosition));
  //       this.reply['newUserStates'][0].playerState.player.position = JSON.parse(
  //         JSON.stringify(playerPosition),
  //       );
  //     }
  //     else{
  //       if(singleInfo != null){
  //         return await this.moveDirect(
  //           playerPosition,
  //           closestDis,
  //           breakPointId,
  //           singleInfo.breakPointId,
  //           appId,
  //           userId,
  //           traceId,
  //           actionType,
  //         );
  //       }
  //       else if (count == 1) {
  //         return await this.moveDirect(
  //           playerPosition,
  //           closestDis,
  //           breakPointId,
  //           neighPoints[0].breakPointId,
  //           appId,
  //           userId,
  //           traceId,
  //           actionType,
  //         );
  //       }
  //       else if (count == 0) {
  //         this.reply['newUserStates'][0].playerState.player.position = JSON.parse(
  //           JSON.stringify(user.player.position),
  //         );
  //         this.reply.actionResponses[0].actionType = actionType;
  //         return this.reply;
  //       }
  //     }

  //     //count == 2
  //     //超出范围了
  //     if (this.getDistance(playerPosition, breakPoint.position) > closestDis) {
  //       let offsetAngle1 = Math.abs(_angle - neighPoints[0].angle);
  //       if (neighPoints[0].angle == 0) {
  //         offsetAngle1 = Math.min(offsetAngle1, Math.abs(_angle - 360));
  //       }

  //       let offsetAngle2 = Math.abs(_angle - neighPoints[1].angle);
  //       if (neighPoints[1].angle == 0) {
  //         offsetAngle2 = Math.min(offsetAngle2, Math.abs(_angle - 360));
  //       }

  //       if (offsetAngle1 > offsetAngle2) {
  //         chooseBreakPointId = neighPoints[1].breakPointId;
  //       } else {
  //         chooseBreakPointId = neighPoints[0].breakPointId;
  //       }
  //       return await this.moveCamera(
  //         breakPointId,
  //         chooseBreakPointId,
  //         appId,
  //         userId,
  //         traceId,
  //         actionType,
  //       );
  //     } else {
  //       user.player.position = JSON.parse(JSON.stringify(playerPosition));
  //       this.reply['newUserStates'][0].playerState.player.position = JSON.parse(
  //         JSON.stringify(user.player.position),
  //       );
  //       this.reply.actionResponses[0].actionType = actionType;
  //       return this.reply;
  //     }
  //   } catch (error) {
  //     console.log('MoveService', error);
  //     debugger;
  //     return null;
  //   }
  // }

  async joystick(actionRequest) {
    //try {

    if (this.sendingFrameForJoystick) {
      return null;
    }

    const userId = actionRequest['user_id'];
    const traceId = actionRequest['trace_id'];
    const dir_action = actionRequest['dir_action'];
    const actionType = actionRequest['action_type'];
    const user = this.users[userId];
    const breakPointId = user.breakPointId;
    const appId = user.appId;
    const step = 0.3;
    const closestDis = 85; //小于这个距离就跳到邻居呼吸点
    const distance = step * dir_action.speed_level;
    let angle = null;
    let move_angle = dir_action.move_angle + user.camera.angle.yaw;
    move_angle = move_angle % 360;

    //TODO 临时增加断言
    const playerPosition: Point = { x: 0, y: 0, z: 0 };
    playerPosition.x =
      user.player.position.x +
      distance * Math.cos((move_angle / 360) * 2 * Math.PI);
    playerPosition.y =
      user.player.position.y +
      distance * Math.sin((move_angle / 360) * 2 * Math.PI);

    //找到邻居点，判断user.player.position与邻居点的距离，如果距离小于closestDis，就要更新camera的position
    let chooseBreakPointId = null;
    const breakPoint = this.breakPointInfo[breakPointId];
    const surroundPointIds = breakPoint.contact;
    const traceIds = [];

    user.player.angle.yaw = move_angle;
    traceIds.push(traceId);
    this.reply.traceIds = traceIds;
    this.reply['newUserStates'][0].userId = userId;
    this.reply['actionResponses'][0].traceId = traceId;
    this.reply['newUserStates'][0].playerState.player.angle.yaw = move_angle;

    this.reply['newUserStates'][0].playerState.camera.angle = JSON.parse(
      JSON.stringify(user.camera.angle),
    );
    this.reply['newUserStates'][0].playerState.camera.position = JSON.parse(
      JSON.stringify(user.camera.position),
    );
    this.reply['newUserStates'][0].playerState.cameraCenter = JSON.parse(
      JSON.stringify(breakPoint.position),
    );
    this.reply['newUserStates'][0].renderInfo.isMoving = 1;
    this.reply['actionResponses'][0].traceId = traceId;
    this.reply.mediaSrc = null;

    console.log('joystickjoystick:' + this.cameraInfos.length);

    if (surroundPointIds.length == 1) {
      console.log(
        'joystick校验--->' + breakPointId + '-' + surroundPointIds[0],
      );
      return await this.moveDirect(
        playerPosition,
        closestDis,
        breakPointId,
        surroundPointIds[0],
        appId,
        userId,
        traceId,
        actionType,
      );
    }

    let count = 0;
    const neighPoints = [];
    //人在哪个角度
    let _angle = this.getAngle(
      breakPoint.position,
      { x: breakPoint.position.x + 1, y: breakPoint.position.y },
      playerPosition,
    );
    if (_angle < 0) {
      _angle += 360;
    }

    let singleInfo = null;
    for (let i = 0; i < surroundPointIds.length; ++i) {
      const neighPoint = this.breakPointInfo[surroundPointIds[i]];
      neighPoint.breakPointId = surroundPointIds[i];
      angle = this.getAngle(
        breakPoint.position,
        { x: breakPoint.position.x + 1, y: breakPoint.position.y },
        neighPoint.position,
      );

      //if(angle<45&&angle!=0){
      if (
        // Math.abs(angle - move_angle) < 45 &&
        // Math.abs(angle - move_angle) != 0
        Math.abs(angle - _angle) < 45 &&
        Math.abs(angle - _angle) != 0
      ) {
        neighPoint.angle = angle;
        neighPoints.push(neighPoint);
        ++count;
      } else if (Math.abs(angle - move_angle) == 0) {
        console.log(
          'joystick直走--->' + breakPointId + '-' + surroundPointIds[i],
        );
        return await this.moveDirect(
          playerPosition,
          closestDis,
          breakPointId,
          surroundPointIds[i],
          appId,
          userId,
          traceId,
          actionType,
        );
      }

      //if (angle == 0 && Math.abs(360 - move_angle) < 45) {
      if (angle == 0 && Math.abs(360 - _angle) < 45) {
        neighPoint.angle = angle;
        neighPoints.push(neighPoint);
        ++count;
      }

      if (
        Math.abs(angle - move_angle) < 45 ||
        Math.abs(angle + 360 - move_angle) < 45
      ) {
        if (singleInfo == null) {
          singleInfo = {
            angle: angle,
            breakPointId: surroundPointIds[i],
          };
        }
      }
    }

    if (count == 2) {
      //人物移动
      user.player.position = JSON.parse(JSON.stringify(playerPosition));
      this.reply['newUserStates'][0].playerState.player.position = JSON.parse(
        JSON.stringify(playerPosition),
      );
    } else {
      if (singleInfo != null) {
        console.log(
          'joystick校验--->' + breakPointId + '-' + singleInfo.breakPointId,
        );
        return await this.moveDirect(
          playerPosition,
          closestDis,
          breakPointId,
          singleInfo.breakPointId,
          appId,
          userId,
          traceId,
          actionType,
        );
      } else if (count == 1) {
        console.log(
          'joystick校验--->' + breakPointId + '-' + neighPoints[0].breakPointId,
        );
        return await this.moveDirect(
          playerPosition,
          closestDis,
          breakPointId,
          neighPoints[0].breakPointId,
          appId,
          userId,
          traceId,
          actionType,
        );
      } else if (count == 0) {
        this.reply['newUserStates'][0].playerState.player.position = JSON.parse(
          JSON.stringify(user.player.position),
        );
        this.reply.actionResponses[0].actionType = actionType;
        return this.reply;
      }
    }

    //count == 2
    //超出范围了
    if (this.getDistance(playerPosition, breakPoint.position) > closestDis) {
      let offsetAngle1 = Math.abs(_angle - neighPoints[0].angle);
      if (neighPoints[0].angle == 0) {
        offsetAngle1 = Math.min(offsetAngle1, Math.abs(_angle - 360));
      }

      let offsetAngle2 = Math.abs(_angle - neighPoints[1].angle);
      if (neighPoints[1].angle == 0) {
        offsetAngle2 = Math.min(offsetAngle2, Math.abs(_angle - 360));
      }

      if (offsetAngle1 > offsetAngle2) {
        chooseBreakPointId = neighPoints[1].breakPointId;
      } else {
        chooseBreakPointId = neighPoints[0].breakPointId;
      }
      console.log(
        'joystick镜头过渡--->' + breakPointId + '-' + chooseBreakPointId,
      );
      return await this.moveCamera(
        breakPointId,
        chooseBreakPointId,
        appId,
        userId,
        traceId,
        actionType,
      );
    } else {
      user.player.position = JSON.parse(JSON.stringify(playerPosition));
      this.reply['newUserStates'][0].playerState.player.position = JSON.parse(
        JSON.stringify(user.player.position),
      );
      this.reply.actionResponses[0].actionType = actionType;
      const cameraInfo = this.getCameraInfo();
      if (cameraInfo != null) {
        console.log('joystick自由--->合并');
        this.reply['newUserStates'][0].playerState.camera.position =
          cameraInfo.camera_position;
        this.reply['newUserStates'][0].playerState.camera.angle =
          cameraInfo.camera_angle;

        if (cameraInfo.mediaSrc) {
          this.reply.mediaSrc = cameraInfo.mediaSrc;
        } 
        if (this.cameraInfos.length == 0) {
          this.reply.moveOver = true;
        }
        this.sendingFrameForJoystick = true;
      } else {
        console.log('joystick自由--->不合并');
      }
      return this.reply;
    }
    // }
    // catch (error) {
    //   console.log('MoveService', error);
    //   debugger;
    //   return null;
    // }
  }

  //沿着最合适的neighBreakPointId走
  async moveDirect(
    playerPosition,
    closestDis,
    breakPointId,
    neighBreakPointId,
    appId,
    userId,
    traceId,
    actionType,
  ) {
    const breakPoint = this.breakPointInfo[breakPointId];
    const user = this.users[userId];
    const player_Position = this.getTarget(
      playerPosition,
      breakPoint.position,
      this.breakPointInfo[neighBreakPointId].position,
    );

    if (player_Position != null) {
      playerPosition.x = player_Position.x;
      playerPosition.y = player_Position.y;
      user.player.position = JSON.parse(JSON.stringify(playerPosition));
    }

    if (this.getDistance(playerPosition, breakPoint.position) > closestDis) {
      return await this.moveCamera(
        breakPointId,
        neighBreakPointId,
        appId,
        userId,
        traceId,
        actionType,
      );
    } else {
      this.reply['newUserStates'][0].playerState.player.position = JSON.parse(
        JSON.stringify(user.player.position),
      );
      this.reply.actionResponses[0].actionType = actionType;
      const cameraInfo = this.getCameraInfo();
      if (cameraInfo != null) {
        this.reply['newUserStates'][0].playerState.camera.position =
          cameraInfo.camera_position;
        this.reply['newUserStates'][0].playerState.camera.angle =
          cameraInfo.camera_angle;

        if (cameraInfo.mediaSrc) {
          this.reply.mediaSrc = cameraInfo.mediaSrc;
        } 
        if (this.cameraInfos.length == 0) {
          this.reply.moveOver = true;
        }
        this.sendingFrameForJoystick = true;
      }
      return this.reply;
    }
  }

  async moveCamera(
    breakPointId,
    chooseBreakPointId,
    appId,
    userId,
    traceId,
    actionType,
  ) {
    const user = this.users[userId];
    if (chooseBreakPointId == null) {
      this.reply['newUserStates'][0].playerState.player.position = JSON.parse(
        JSON.stringify(user.player.position),
      );
      this.reply.actionResponses[0].actionType = actionType;
      return this.reply;
    }
    //判断人物离该邻接点的距离是否在最小路径内，如果是，跳到这个邻接点里
    //相机纠正加过渡
    else {
      if (chooseBreakPointId == user.breakPointId) {
        this.reply['newUserStates'][0].playerState.player.position = JSON.parse(
          JSON.stringify(user.player.position),
        );
        return this.reply;
      }

      const angle = user.camera.angle.yaw % 45; //纠正需要
      //通过user.camera.angle矫正相机的angle
      const checkReplys = await this.modeifyCameraAngle(
        angle,
        userId,
        traceId,
        actionType,
      );

      for (let i = 0; i < checkReplys.length; ++i) {
        //checkReplys[i].actionResponses[0].actionType = actionType;
        this.addCameraInfo(
          checkReplys[i]['newUserStates'][0].playerState.camera.position,
          checkReplys[i]['newUserStates'][0].playerState.camera.angle,
          checkReplys[i].mediaSrc,
        );
      }

      //replys.push(checkReplys);
      //读redis里的数据，按照frame_index的大小排序
      const key =
        'moveframe:app_id:' +
        appId +
        ':start_break_point_id:' +
        breakPointId +
        ':end_break_point_id:' +
        chooseBreakPointId +
        ':angle:' +
        Math.floor(user.camera.angle.yaw / 45);
      const moveFramesRes = await this.cacheService.get(key);
      const moveFrames = JSON.parse(moveFramesRes);
      this.setCameraInfo(appId,moveFrames,breakPointId,chooseBreakPointId);
      //user.breakPointId = chooseBreakPointId;
      const cameraInfo = this.getCameraInfo();
      if (cameraInfo != null) {
        this.reply['newUserStates'][0].playerState.camera.position =
          cameraInfo.camera_position;
        this.reply['newUserStates'][0].playerState.camera.angle =
          cameraInfo.camera_angle;

        user.camera.position = JSON.parse(
          JSON.stringify(cameraInfo.camera_position),
        );
        user.camera.angle.yaw = cameraInfo.camera_angle.yaw;

        if (cameraInfo.mediaSrc) {
          this.reply.mediaSrc = cameraInfo.mediaSrc;
        } 
        this.reply.moveStart = true;
        this.sendingFrameForJoystick = true;
      }
      return this.reply;
    }
  }

  setCameraInfo(appId,moveFrames,startBreakPointId,endBreakPointId) {
    for (let i = 0; i < moveFrames.length; i += 5) {
      moveFrames[i].endBreakPointId = endBreakPointId;
      moveFrames[i].mediaSrc =  '/' + appId +'/' + startBreakPointId +'/' + moveFrames[i].file_name.substring( 0, moveFrames[i].file_name.indexOf('.'), ) + '/' +moveFrames[i].file_name + '?m=' +new Date().getTime();
      this.cameraInfos.push(moveFrames[i]);
    }
  }

  addCameraInfo(cameraPosition, cameraAngle, mediaSrc) {
    this.cameraInfos.push({
      camera_position: cameraPosition,
      camera_angle: cameraAngle,
      mediaSrc: mediaSrc,
    });
  }

  getCameraInfo() {
    if (this.cameraInfos.length > 0) {
      const item = this.cameraInfos.shift();
      return item;
    } else {
      return null;
    }
  }

  complementFrame(userId){
    if (this.cameraInfos.length > 0) {
      const user = this.users[userId];
      const cameraInfo = this.cameraInfos.shift();
      this.reply.traceIds = [];
      this.reply['newUserStates'][0].userId = userId;
      this.reply['actionResponses'][0].traceId = null;
      this.reply['newUserStates'][0].playerState.player.angle.yaw = user.player.angle.yaw;
      this.reply['newUserStates'][0].playerState.player.position = JSON.parse(
        JSON.stringify(user.player.position),
      );
      this.reply['newUserStates'][0].playerState.camera.angle = JSON.parse(
        JSON.stringify(cameraInfo.camera_angle),
      );
      this.reply['newUserStates'][0].playerState.camera.position = JSON.parse(
        JSON.stringify(cameraInfo.camera_position),
      );

      this.reply['newUserStates'][0].playerState.cameraCenter = JSON.parse(
        JSON.stringify(user.player.position),
      );
      this.reply['newUserStates'][0].renderInfo.isMoving = 0;
      this.reply['actionResponses'][0].traceId = null;
      
      if (cameraInfo.mediaSrc) {
        this.reply.mediaSrc = cameraInfo.mediaSrc;
      } 
      return this.reply;
    } 
    else {
      return null;
    }
  }

  async modeifyCameraAngle(angle, userId, traceId, actionType) {
    const checkReplys = [];
    if (angle > 22) {
      angle = 45 - angle;
      for (let i = 0; i < angle; ++i) {
        // console.warn('矫正一次：' + i);
        const reply = await this.rotateService.rotateForAngle(userId, 1);
        // console.warn(
        //   '矫正：' + reply.newUserStates[0].playerState.camera.angle.yaw,
        // );
        reply.traceIds = [];
        reply.traceIds.push(traceId);
        const actionResponse = this.rotateService.createActionResponse(
          actionType,
          traceId,
        );
        reply.actionResponses = [];
        reply.actionResponses.push(actionResponse);
        checkReplys.push(reply);
      }
    } else if (angle != 0) {
      for (let i = angle; i > -1; --i) {
        // console.warn('矫正一次：' + i);
        const reply = await this.rotateService.rotateForAngle(userId, -1);
        // console.warn(
        //   '矫正：' + reply.newUserStates[0].playerState.camera.angle.yaw,
        // );
        reply.traceIds = [];
        reply.traceIds.push(traceId);
        const actionResponse = this.rotateService.createActionResponse(
          actionType,
          traceId,
        );
        reply.actionResponses = [];
        reply.actionResponses.push(actionResponse);
        checkReplys.push(reply);
      }
    }
    return checkReplys;
  }

  getTarget(position, position1, position2) {
    const line = this.createLine1(position1, position2);
    const join = this.getJoinLinePoint(position, line);
    // if (this.isContainForSegment(join, position1, position2)) {
    //   return join;
    // } else {
    //   return null;
    // }
    return join;
  }

  getDistance(position1, position2) {
    return Math.sqrt(
      (position1.x - position2.x) * (position1.x - position2.x) +
        (position1.y - position2.y) * (position1.y - position2.y),
    );
  }

  isContainForSegment(point, startPoint, endPoint) {
    const minDis = 0.1;
    const dis1 =
      this.getDistance(startPoint, point) + this.getDistance(endPoint, point);
    const dis2 = this.getDistance(startPoint, endPoint);
    if (Math.abs(dis1 - dis2) < minDis) {
      return true;
    } else {
      return false;
    }
  }

  //两条线的交点
  getIntersectionPoint(parameter1, parameter2) {
    if (this.isParallel(parameter1, parameter2)) {
      return null;
    }
    if (
      typeof parameter1.a == 'undefined' &&
      typeof parameter2.a != 'undefined'
    ) {
      if (parameter1.x) {
        return {
          x: parameter1.x,
          y: parameter2.a * parameter1.x + parameter2.b,
        };
      } else if (parameter1.y) {
        return {
          x: (parameter1.y - parameter2.b) / parameter2.a,
          y: parameter1.y,
        };
      }
    } else if (
      typeof parameter2.a == 'undefined' &&
      typeof parameter1.a != 'undefined'
    ) {
      if (parameter2.x) {
        return {
          x: parameter2.x,
          y: parameter1.a * parameter2.x + parameter1.b,
        };
      } else if (parameter2.y) {
        return {
          x: (parameter2.y - parameter1.b) / parameter1.a,
          y: parameter2.y,
        };
      }
    } else if (
      typeof parameter2.a == 'undefined' &&
      typeof parameter1.a == 'undefined'
    ) {
      if (parameter1.hasOwnProperty('x') && parameter2.hasOwnProperty('y')) {
        return { x: parameter1.x, y: parameter2.y };
      } else if (
        parameter1.hasOwnProperty('y') &&
        parameter2.hasOwnProperty('x')
      ) {
        return { x: parameter2.x, y: parameter1.y };
      } else {
        return null;
      }
    }

    if (parameter1.a == parameter2.a) {
      return null;
    }

    const joinpointx =
      (parameter2.b - parameter1.b) / (parameter1.a - parameter2.a);
    const joinpointy =
      (parameter1.a * parameter2.b - parameter2.a * parameter1.b) /
      (parameter1.a - parameter2.a);

    const point = { x: joinpointx, y: joinpointy };
    return point;
  }

  // 垂直线
  getVerticalLine(line, point) {
    if (typeof line.a === 'undefined') {
      if (line.hasOwnProperty('x')) {
        return { y: point.y };
      } else if (line.hasOwnProperty('y')) {
        return { x: point.x };
      } else {
        return null;
      }
    } else if (line.a == 0) {
      return { x: point.x };
    } else {
      const tl = {} as any as VerticalLineType;
      tl.a = -1 / line.a;
      const result = this.createLine2(tl, point);
      return result;
    }
  }

  // 经过point且与line垂直的直线，该直线与line的交点
  getJoinLinePoint(point, line) {
    const verticalLine = this.getVerticalLine(line, point);
    const join = this.getIntersectionPoint(line, verticalLine);
    return join;
  }

  // 与lineA平行并且point在线上
  createLine2(lineA, point) {
    const parameter = {} as any as {
      x: number;
      y: number;
      a: number;
      b: number;
    };
    if (typeof lineA.a === 'undefined') {
      if (typeof lineA.x !== 'undefined') {
        parameter.x = point.x;
      } else if (typeof lineA.y !== 'undefined') {
        parameter.y = point.y;
      }
    } else {
      parameter.a = lineA.a;
      parameter.b = point.y - point.x * lineA.a;
    }
    return parameter;
  }

  createLine1(point1, point2) {
    if (point1.x == point2.x && point1.y == point2.y) {
      return null;
    } else if (this.getFixed(Math.abs(point1.x - point2.x)) == 0) {
      return { x: point1.x };
    } else if (this.getFixed(Math.abs(point1.y - point2.y)) == 0) {
      return { y: point1.y };
    }

    const parametera = (point1.y - point2.y) / (point1.x - point2.x);
    const parameterb =
      (point1.x * point2.y - point2.x * point1.y) / (point1.x - point2.x);
    if (this.getFixed(parametera) == 0) {
      return { y: this.getFixed(parameterb) };
    }
    const parameter = {
      a: this.getFixed(parametera),
      b: this.getFixed(parameterb),
    };
    return parameter;
  }

  //返回true表示平行
  isParallel(line1, line2) {
    if (typeof line1.a == 'undefined' && typeof line2.a == 'undefined') {
      if (line1.hasOwnProperty('x') && line2.hasOwnProperty('x')) {
        return true;
      } else if (line1.hasOwnProperty('y') && line2.hasOwnProperty('y')) {
        return true;
      } else {
        return false;
      }
    } else if (typeof line1.a == 'undefined' || typeof line2.a == 'undefined') {
      return false;
    } else if (this.getFixed(line1.a) == this.getFixed(line2.a)) {
      return true;
    } else {
      return false;
    }
  }

  getFixed(num) {
    const decimal = 2;
    return parseFloat(num.toFixed(decimal));
  }

  isPointInPoly(position, breakPointIds) {
    const x = position.x;
    const y = position.y;

    let inside = false;

    for (
      let i = 0, j = breakPointIds.length - 1;
      i < breakPointIds.length;
      j = i++
    ) {
      const pt1 = this.breakPointInfo[breakPointIds[i]];
      const pt2 = this.breakPointInfo[breakPointIds[j]];

      const xi = pt1.x;
      const yi = pt1.y;
      const xj = pt2.x;
      const yj = pt2.y;

      const intersect =
        yi > y != yj > y && x < ((xj - xi) * (y - yi)) / (yj - yi) + xi;
      if (intersect) inside = !inside;
    }

    return inside;
  }
}