diff --git a/src/onebot/index.ts b/src/onebot/index.ts index 58baac16..ecc17613 100644 --- a/src/onebot/index.ts +++ b/src/onebot/index.ts @@ -311,19 +311,19 @@ export class NapCatOneBot11Adapter { } }; - const msgIdSend = new LRUCache(100); + const msgIdSend = new LRUCache(100); const recallMsgs = new LRUCache(100); msgListener.onAddSendMsg = async msg => { if (msg.sendStatus == SendStatusType.KSEND_STATUS_SENDING) { - msgIdSend.put(msg.msgId, true) + msgIdSend.put(msg.msgId, 0); } }; msgListener.onMsgInfoListUpdate = async msgList => { this.emitRecallMsg(msgList, recallMsgs) .catch(e => this.context.logger.logError.bind(this.context.logger)('处理消息失败', e)); for (const msg of msgList.filter(e => e.senderUin == this.core.selfInfo.uin)) { - if (msg.sendStatus == SendStatusType.KSEND_STATUS_SUCCESS && msgIdSend.get(msg.msgId)) { - msgIdSend.put(msg.msgId, true); + if (msg.sendStatus == SendStatusType.KSEND_STATUS_SUCCESS && msgIdSend.get(msg.msgId) == 0) { + msgIdSend.put(msg.msgId, 1); // 完成后再post this.apis.MsgApi.parseMessage(msg) .then((ob11Msg) => {