Browse Source

测试掉线不拨号强制上线

gemercheung 3 years ago
parent
commit
6406140a69
2 changed files with 6 additions and 3 deletions
  1. 3 2
      src/controller/connectController.js
  2. 3 1
      src/controller/room/index.js

+ 3 - 2
src/controller/connectController.js

@@ -24,7 +24,8 @@ export class ConnectController extends BasicController {
         const from = this.roomController.user.from;
         const roomId = this.roomController.roomId;
         const role = this.roomController.user.role;
-        const user = this.roomController.user;
+        //const user = this.roomController.user;
+        const user = await this.roomController.currentUser();
         this.roomController.logger.info("断开连接", {
           userId,
           from,
@@ -32,7 +33,7 @@ export class ConnectController extends BasicController {
         });
         // if (this.roomController.isHoster(role)) {
         // setTimeout(async () => {
-        console.log("断开设置离线");
+        console.log("断开设置离线", user);
         user.onlineStatus = 0;
         await updateRoomUser(roomId, userId, user);
         await this.roomController.roomAssistant.notifyUsersChange(roomId, user, false);

+ 3 - 1
src/controller/room/index.js

@@ -134,10 +134,10 @@ export class RoomController extends BasicController {
       const isInRoom = await isUserInRooms(this.roomId, this.userId);
       if (isInRoom) {
         if (Number(isInRoom.onlineStatus) === 0) {
+          console.log("在房间人员掉线人员,强制上线!", isInRoom);
           this.setOnlineStatus(this.roomId, this.userId, isInRoom);
         }
       }
-      console.log("isInRoom", isInRoom);
     } else {
       this.logger.info("user-query-不存在 :", this.socket.handshake.query);
       this.socket.disconnect();
@@ -149,6 +149,8 @@ export class RoomController extends BasicController {
     await updateRoomUser(this.roomId, this.userId, user);
   }
 
+  silentUpdateRoom(roomId) {}
+
   async initParams(userId, roomId, oneSceneNum) {
     this.userId = `user:${userId}`;
     this.syncId = `sync:${oneSceneNum}:${userId}`;