|
@@ -19,7 +19,7 @@ export class DelayService {
|
|
|
@Inject(forwardRef(() => RoomService))
|
|
|
public readonly roomService: RoomService,
|
|
|
public readonly tempService: TempService,
|
|
|
- ) {}
|
|
|
+ ) { }
|
|
|
|
|
|
init(): void {
|
|
|
const redisDB = this.configService.get<string>('REDIS_DB');
|
|
@@ -69,7 +69,7 @@ export class DelayService {
|
|
|
const RoomId = params[0];
|
|
|
const UserId = params[1];
|
|
|
const delayUser = await this.userService.getUsersBy(RoomId, UserId);
|
|
|
- if (delayUser) {
|
|
|
+ if (delayUser && !delayUser.IsOnline) {
|
|
|
const roomUsers = await this.userService.getRoomUsers(RoomId);
|
|
|
const filterRoomUser = roomUsers.filter((i) => i.UserId !== UserId);
|
|
|
console.log('delayUser', delayUser.UserId);
|