临时房间

src/room/delay/delay.service.ts

@@ -56,8 +56,8 @@ export class DelayService {
 
   async handleTempRoomExpiredSubscribe(key: string) {
     const tKey = key.replace('kankan:socket:tempRoom:', '');
-    const params = tKey.split(':');
-    const RoomId = params[0];
+    // const params = tKey.split(':');
+    const RoomId = tKey;
     // const UserId = params[1];
     this.roomService.logger.warn(`解散临时房间 :${RoomId}`, 'temp-room');
     await this.roomService.handleRoomDismiss(RoomId);

src/room/temp/temp.service.ts

@@ -28,16 +28,18 @@ export class TempService {
   }
   async handleInitRoom(socket: Socket) {
     const { RoomId, UserId, Role } = socket.data.user;
-    const temp_key_init = `kankan:socket:tempRoom:${RoomId}:${UserId}`;
-    // const delayTime = 60 * 60;
-    const delayTime = 60 * 1;
+    const temp_key_init = `kankan:socket:tempRoom:${RoomId}`;
+    const delayTime = 60 * 60;
+    // const delayTime = 60 * 1;
     const isExist = await this.redis.exists(temp_key_init);
+    console.log('isExist', isExist);
     if (!isExist) {
       if (Role === 'leader') {
-        this.redis.set(temp_key_init, '', 'EX', delayTime);
-        this.roomService.socketGateway.server
-          .to(RoomId)
-          .emit('action', { type: 'room-valid-time', data: { delayTime } });
+        await this.redis.set(temp_key_init, UserId, 'EX', delayTime);
+        this.roomService.socketGateway.server.to(RoomId).emit('action', {
+          type: 'room-valid-time',
+          data: { ttl: delayTime },
+        });
       }
     } else {
       const ttl = await this.redis.ttl(temp_key_init);