diff --git a/src/core/src/apis/msg.ts b/src/core/src/apis/msg.ts index 9e281346..e637d259 100644 --- a/src/core/src/apis/msg.ts +++ b/src/core/src/apis/msg.ts @@ -41,17 +41,23 @@ setTimeout(() => { loadMessageUnique().then().catch(); }); }, 100); +//歇菜LocalMsg压根不写Db // setTimeout(async () => { -// let ele: MessageElement = {extBufForUI: '0x' ,...SendMsgElementConstructor.text('测试消息')}; +// let ele: MessageElement = { extBufForUI: '0x', ...SendMsgElementConstructor.text('测试消息') }; // let MsgId = await NTQQMsgApi.getMsgUniqueEx(); -// let peer ={ chatType: 2, peerUid: '809079648', guildId: '' }; -// console.log(await napCatCore.session.getMsgService().addLocalRecordMsg( -// peer, -// MsgId, -// ele, [], true +// let peer = { chatType: 2, peerUid: '', guildId: '' }; +// console.log(await napCatCore.session.getTestPerformanceService().insertMsg( +// { +// peer: peer, +// msgTime: Math.floor(Date.now() / 1000).toString(), +// msgId: MsgId, +// msgSeq: '56564', +// batchNums: 1, +// timesPerBatch: 1, +// numPerTime: 1 +// }, [ele] // )); -// console.log(await NTQQMsgApi.multiForwardMsg(peer,peer,[MsgId])); - +// console.log(await NTQQMsgApi.multiForwardMsg(peer, peer, [MsgId])); // }, 25000) export class NTQQMsgApi { // static napCatCore: NapCatCore | null = null; diff --git a/src/core/src/services/NodeIKernelMsgService.ts b/src/core/src/services/NodeIKernelMsgService.ts index da8e5a76..91479207 100644 --- a/src/core/src/services/NodeIKernelMsgService.ts +++ b/src/core/src/services/NodeIKernelMsgService.ts @@ -361,7 +361,7 @@ export interface NodeIKernelMsgService { setGuildTabUserFlag(...args: unknown[]): unknown; - setBuildMode(flag:number/*0 1 3*/): unknown; + setBuildMode(flag: number/*0 1 3*/): unknown; setConfigurationServiceData(...args: unknown[]): unknown; @@ -663,8 +663,26 @@ export interface NodeIKernelMsgService { dataMigrationGetMsgList(...args: unknown[]): unknown; dataMigrationStopOperation(...args: unknown[]): unknown; - - dataMigrationImportMsgPbRecord(...args: unknown[]): unknown; + + //新的希望 + dataMigrationImportMsgPbRecord(DataMigrationMsgInfo: Array<{ + extensionData: string//"Hex" + extraData: string //"" + chatType: number + chatUin: string + msgType: number + msgTime: string + msgSeq: string + msgRandom: string + }>, DataMigrationResourceInfo: { + extraData: string + filePath: string + fileSize: string + msgRandom: string + msgSeq: string + msgSubType: number + msgType: number + }): unknown; dataMigrationGetResourceLocalDestinyPath(...args: unknown[]): unknown; diff --git a/src/core/src/services/NodeIkernelTestPerformanceService.ts b/src/core/src/services/NodeIkernelTestPerformanceService.ts new file mode 100644 index 00000000..ae774898 --- /dev/null +++ b/src/core/src/services/NodeIkernelTestPerformanceService.ts @@ -0,0 +1,14 @@ +import { MessageElement, Peer } from "../entities"; + +export interface NodeIkernelTestPerformanceService { + insertMsg(MsgParam: { + peer: Peer + msgTime: string + msgId: string + msgSeq: string + batchNums: number + timesPerBatch: number + numPerTime: number + }, msg: Array): Promise; + +} \ No newline at end of file diff --git a/src/core/src/wrapper.ts b/src/core/src/wrapper.ts index 19f2a6e5..661695df 100644 --- a/src/core/src/wrapper.ts +++ b/src/core/src/wrapper.ts @@ -41,6 +41,7 @@ import { NodeIKernelSearchService } from './services/NodeIKernelSearchService'; import { NodeIKernelCollectionService } from './services/NodeIKernelCollectionService'; import { NodeIKernelRecentContactService } from './services/NodeIKernelRecentContactService'; import { NodeIKernelMSFService } from './services/NodeIKernelMSFService'; +import { NodeIkernelTestPerformanceService } from './services/NodeIkernelTestPerformanceService'; const __filename = fileURLToPath(import.meta.url); @@ -210,7 +211,7 @@ export interface NodeIQQNTWrapperSession { getSkinService(): unknown; - getTestPerformanceService(): unknown; + getTestPerformanceService(): NodeIkernelTestPerformanceService; getQQPlayService(): unknown;