This commit is contained in:
手瓜一十雪 2024-07-31 15:52:28 +08:00
parent 26b4a9b15b
commit 3d516df01e
2 changed files with 8 additions and 3 deletions

View File

@ -244,9 +244,14 @@ export class NTQQMsgApi {
}
return false;
}).catch(logError);
await napCatCore.session.getMsgService().sendMsg("0", peer, msgElements, new Map());
let data = await napCatCore.session.getMsgService().sendMsg("0", peer, msgElements, new Map());
//await NTEventDispatch.CallNoListenerEvent<NodeIKernelMsgService['sendMsg']>('NodeIKernelMsgService/sendMsg', timeout, "0", peer, msgElements, new Map());
await EventListener;
if (data.result !== 0 && rawMsg) {
//发送失败msgid
await napCatCore.session.getMsgService().deleteMsg(peer, [rawMsg.msgId]);
throw new Error('发送消息失败');
}
await EventListener2;
// console.log("rawMsg", JSON.stringify(rawMsg, null, 4));
if (rawMsg) {

View File

@ -5,7 +5,7 @@ import { GeneralCallResult } from '@/core/services/common';
export interface NodeIKernelMsgService {
addKernelMsgListener(nodeIKernelMsgListener: NodeIKernelMsgListener): number;
sendMsg(msgId: string, peer: Peer, msgElements: SendMessageElement[], map: Map<any, any>): Promise<unknown>;
sendMsg(msgId: string, peer: Peer, msgElements: SendMessageElement[], map: Map<any, any>): Promise<GeneralCallResult>;
recallMsg(peer: Peer, msgIds: string[]): Promise<GeneralCallResult>;
@ -117,7 +117,7 @@ export interface NodeIKernelMsgService {
addLocalRecordMsg(Peer: Peer, msgId: string, ele: MessageElement, attr: Array<any> | number, front: boolean): Promise<unknown>;
deleteMsg(...args: unknown[]): unknown;
deleteMsg(Peer: Peer, msgIds: Array<string>): Promise<any>;
updateElementExtBufForUI(...args: unknown[]): unknown;