diff --git a/src/app/module/chat/domain/use-case/room/room-bold-sync-use-case.service.ts b/src/app/module/chat/domain/use-case/room/room-bold-sync-use-case.service.ts index 5a220f3b2..30f61ae1d 100644 --- a/src/app/module/chat/domain/use-case/room/room-bold-sync-use-case.service.ts +++ b/src/app/module/chat/domain/use-case/room/room-bold-sync-use-case.service.ts @@ -80,14 +80,15 @@ export class RoomBoldSyncUseCaseService { @XTracerAsync({name:'RoomBoldSyncUseCaseService/onInsertToDB', module:'chat', bugPrint: true}) private onInsertToDB(tracing?: TracingType) { + let delay = 2000 this.messageLocalRepository.onCreateObservable().pipe( filter(e => e?.origin == 'history'), - filter(e => e.sender.wxUserId != SessionStore.user.UserId) + filter(e => e.sender.wxUserId != SessionStore.user.UserId), ).subscribe(async (newMessage)=> { - const haveSeen = MessageEntity.haveSeen(newMessage.info) - if(!haveSeen) { - setTimeout(async ()=> { + setTimeout(async ()=> { + const haveSeen = MessageEntity.haveSeen(newMessage.info) + if(!haveSeen) { await this.boldLocalRepository.open() const result = await this.boldLocalRepository.findOne({roomId: newMessage.roomId}) @@ -98,8 +99,10 @@ export class RoomBoldSyncUseCaseService { } else { tracing.hasError("failed to set bold",{}) } - }, 2000) - } + } + + }, delay); + delay = 0 }) } }