gemercheung 2 年之前
父節點
當前提交
b59eac6930
共有 2 個文件被更改,包括 3 次插入4 次删除
  1. 2 0
      src/room/users/users.service.ts
  2. 1 4
      src/socket/socket.gateway.ts

+ 2 - 0
src/room/users/users.service.ts

@@ -35,6 +35,7 @@ export class UsersService {
     return Promise.resolve(Boolean(isRoomHasConfig));
   }
   async insertUser(useInfo: UserInfoType): Promise<boolean> {
+    useInfo.IsClient = false;
     const insert = await this.redis.hset(
       `kankan:socket:rooms:${useInfo.RoomId}`,
       useInfo.UserId,
@@ -54,6 +55,7 @@ export class UsersService {
   }
 
   async updateUsers(useInfo: UserInfoType): Promise<boolean> {
+    useInfo.IsClient = false;
     const user = await this.redis.hget(
       `kankan:socket:rooms:${useInfo.RoomId}`,
       useInfo.UserId,

+ 1 - 4
src/socket/socket.gateway.ts

@@ -97,10 +97,7 @@ export class SocketGateway
     // console.log('isRepeat', isRepeat);
     if (!isRepeat) {
       socket.join(message.roomId);
-      console.log('message.isClient', message.isClient);
-      if (!message.isClient) {
-        await this.roomService.handleUserJoin(socket, message);
-      }
+      await this.roomService.handleUserJoin(socket, message);
     }
   }
   async handleRepeatJoin(