From bd2edda494294e0e48bf51a24d22142decbf544a Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E6=89=8B=E7=93=9C=E4=B8=80=E5=8D=81=E9=9B=AA?= Date: Tue, 23 Jul 2024 09:45:00 +0800 Subject: [PATCH] refactor: sendMsg --- src/common/utils/EventTask.ts | 2 +- src/core/src/apis/msg.ts | 3 ++- 2 files changed, 3 insertions(+), 2 deletions(-) diff --git a/src/common/utils/EventTask.ts b/src/common/utils/EventTask.ts index 8bea2ba8..7ce44051 100644 --- a/src/common/utils/EventTask.ts +++ b/src/common/utils/EventTask.ts @@ -84,7 +84,7 @@ export class NTEventWrapper { } //统一回调清理事件 async DispatcherListener(ListenerMainName: string, ListenerSubName: string, ...args: any[]) { - //console.log(ListenerMainName, this.EventTask.get(ListenerMainName), ListenerSubName, this.EventTask.get(ListenerMainName)?.get(ListenerSubName)); + //console.log(ListenerMainName, ListenerSubName, ...args,this.EventTask.get(ListenerMainName)?.get(ListenerSubName)); this.EventTask.get(ListenerMainName)?.get(ListenerSubName)?.forEach((task, uuid) => { //console.log(task.func, uuid, task.createtime, task.timeout); if (task.createtime + task.timeout < Date.now()) { diff --git a/src/core/src/apis/msg.ts b/src/core/src/apis/msg.ts index 561d0496..6cc3ee7e 100644 --- a/src/core/src/apis/msg.ts +++ b/src/core/src/apis/msg.ts @@ -172,10 +172,11 @@ export class NTQQMsgApi { let data = await NTEventDispatch.CallNormalEvent<(msgId: string, peer: Peer, msgElements: SendMessageElement[], map: Map) => Promise, (msgList: RawMessage[]) => void>( 'NodeIKernelMsgService/sendMsg', 'NodeIKernelMsgListener/onMsgInfoListUpdate', - timeout, 1, + 5000, (msgRecords: RawMessage[]) => { for (let msgRecord of msgRecords) { + //console.log(msgRecord); if (msgRecord.msgId === msgId && msgRecord.sendStatus === 2) { return true; }