release: v2.0.32

fix: 多处修改

.github/workflows/release.yml

@@ -98,11 +98,16 @@ jobs:
     
     - name: Compress subdirectories
       run: |
-       for dir in */; do
-          base=$(basename "$dir")
-          zip -r "${base}.zip" "$dir"
-        done 
-    
+        cd ./NapCat.Shell/
+        zip -q -r NapCat.Shell.zip *
+        cd ..
+        cd ./NapCat.Framework/
+        zip -q -r NapCat.Framework.zip *
+        cd ..
+        rm ./NapCat.Shell.zip -rf
+        rm ./NapCat.Framework.zip -rf
+        mv ./NapCat.Shell/NapCat.Shell.zip ./
+        mv ./NapCat.Framework/NapCat.Framework.zip ./
     - name: Extract version from tag
       run: echo "VERSION=${GITHUB_REF#refs/tags/v}" >> $GITHUB_ENV
       
@@ -118,6 +123,4 @@ jobs:
         files: |
           NapCat.Framework.zip
           NapCat.Shell.zip
-#          NapCat.darwin.x64.zip
-#          NapCat.darwin.arm64.zip
         draft: true

LICENSE

@@ -1,4 +1,4 @@
-                    GNU GENERAL PUBLIC LICENSE
+   GNU GENERAL PUBLIC Without Social media promotion LICENSE 
                        Version 2, June 1991
 
  Copyright (C) 1989, 1991 Free Software Foundation, Inc.,
@@ -111,6 +111,10 @@ above, provided that you also meet all of these conditions:
     does not normally print such an announcement, your work based on
     the Program is not required to print an announcement.)
 
+    d）You may use this software in accordance with the above terms, 
+    but you are not allowed to promote this project or your projects
+    based on this project on any public social media.
+
 These requirements apply to the modified work as a whole.  If
 identifiable sections of that work are not derived from the Program,
 and can be reasonably considered independent and separate works in

README.md

@@ -3,6 +3,8 @@
 </div>
 
 ---
+## To Be Continued
+当前版本请使用低于27187 (不包含) 高于26702 (包含) 的QQ版本运行
 
 ## 项目介绍
 NapCatQQ 是现代化的基于 NTQQ 的 Bot 协议端实现。

manifest.json

@@ -1,10 +1,10 @@
 {
   "manifest_version": 4,
   "type": "extension",
-  "name": "NapCat",
-  "slug": "NapCat",
-  "description": "现代化的 OneBot 11 协议实现",
-  "version": "2.0.20",
+  "name": "NapCatQQ",
+  "slug": "NapCat.Framework",
+  "description": "高性能的 OneBot 11 协议实现",
+  "version": "2.0.32",
   "icon": "./logo.png",
   "authors": [
     {

package.json

@@ -2,7 +2,7 @@
   "name": "napcat",
   "private": true,
   "type": "module",
-  "version": "2.0.20",
+  "version": "2.0.32",
   "scripts": {
     "build:framework": "vite build --mode framework",
     "build:shell": "vite build --mode shell",

src/common/framework/napcat.ts

@@ -2,7 +2,7 @@ import path, { dirname } from 'path';
 import { fileURLToPath } from 'url';
 import fs from 'fs';
 
-export const napcat_version = '2.0.20';
+export const napcat_version = '2.0.32';
 
 export class NapCatPathWrapper {
     binaryPath: string;

src/common/utils/file.ts

@@ -1,10 +1,9 @@
 import fs from 'fs';
-import fsPromise, { stat } from 'fs/promises';
+import { stat } from 'fs/promises';
 import crypto, { randomUUID } from 'crypto';
 import util from 'util';
 import path from 'node:path';
 import * as fileType from 'file-type';
-import { LogWrapper } from './log';
 
 export function isGIF(path: string) {
     const buffer = Buffer.alloc(4);
@@ -13,7 +12,6 @@ export function isGIF(path: string) {
     fs.closeSync(fd);
     return buffer.toString() === 'GIF8';
 }
-
 // 定义一个异步函数来检查文件是否存在
 export function checkFileReceived(path: string, timeout: number = 3000): Promise<void> {
     return new Promise((resolve, reject) => {
@@ -94,7 +92,6 @@ export async function file2base64(path: string) {
     return result;
 }
 
-
 export function calculateFileMD5(filePath: string): Promise<string> {
     return new Promise((resolve, reject) => {
         // 创建一个流式读取器
@@ -166,136 +163,105 @@ type Uri2LocalRes = {
     isLocal: boolean
 }
 
-export async function uri2local(TempDir: string, UriOrPath: string, fileName: string | null = null): Promise<Uri2LocalRes> {
-    const res = {
-        success: false,
-        errMsg: '',
-        fileName: '',
-        ext: '',
-        path: '',
-        isLocal: false,
-    };
-    if (!fileName) fileName = randomUUID();
-    let filePath = path.join(TempDir, fileName);//临时目录
-    let url = null;
-    //区分path和uri
+export async function checkFileV2(filePath: string) {
     try {
-        if (fs.existsSync(UriOrPath)) url = new URL('file://' + UriOrPath);
-    } catch (error: any) {
+        const ext: string | undefined = (await fileType.fileTypeFromFile(filePath))?.ext;
+        if (ext) {
+            fs.renameSync(filePath, filePath + `.${ext}`);
+            filePath += `.${ext}`;
+            return { success: true, ext: ext, path: filePath };
+        }
+    } catch (e) {
+        // log("获取文件类型失败", filePath,e.stack)
+    }
+    return { success: false, ext: '', path: filePath };
+}
+
+export enum FileUriType {
+    Unknown = 0,
+    Local = 1,
+    Remote = 2,
+    Base64 = 3
+}
+
+export async function checkUriType(Uri: string) {
+    //先判断是否是本地文件
+    try {
+        if (fs.existsSync(Uri)) return { Uri: Uri, Type: FileUriType.Local };
+    } catch (error) {
     }
     try {
-        url = new URL(UriOrPath);
-    } catch (error: any) {
-    }
-
-    //验证url
-    if (!url) {
-        res.errMsg = `UriOrPath ${UriOrPath} 解析失败,可能${UriOrPath}不存在`;
-        return res;
-    }
-
-    if (url.protocol == 'base64:') {
-        // base64转成文件
-        const base64Data = UriOrPath.split('base64://')[1];
-        try {
-            const buffer = Buffer.from(base64Data, 'base64');
-            fs.writeFileSync(filePath, buffer);
-        } catch (e: any) {
-            res.errMsg = 'base64文件下载失败,' + e.toString();
-            return res;
+        //再判断是否是Http
+        if (Uri.startsWith('http://') || Uri.startsWith('https://')) {
+            return { Uri: Uri, Type: FileUriType.Remote };
         }
-    } else if (url.protocol == 'http:' || url.protocol == 'https:') {
-        // 下载文件
-        let buffer: Buffer | null = null;
-        try {
-            buffer = await httpDownload(UriOrPath);
-        } catch (e: any) {
-            res.errMsg = `${url}下载失败,` + e.toString();
-            return res;
+        //再判断是否是Base64
+        if (Uri.startsWith('base64://')) {
+            return { Uri: Uri, Type: FileUriType.Base64 };
         }
-        try {
-            const pathInfo = path.parse(decodeURIComponent(url.pathname));
-            if (pathInfo.name) {
-                fileName = pathInfo.name;
-                if (pathInfo.ext) {
-                    fileName += pathInfo.ext;
-                    // res.ext = pathInfo.ext
-                }
-            }
-            fileName = fileName.replace(/[/\\:*?"<>|]/g, '_');
-            res.fileName = fileName;
-            filePath = path.join(TempDir, randomUUID() + fileName);
-            fs.writeFileSync(filePath, buffer);
-        } catch (e: any) {
-            res.errMsg = `${url}下载失败,` + e.toString();
-            return res;
-        }
-    } else {
-        let pathname: string;
-        if (url.protocol === 'file:') {
+        if (Uri.startsWith('file://')) {
+            let pathname: string;
+            let filePath: string;
             // await fs.copyFile(url.pathname, filePath);
-            pathname = decodeURIComponent(url.pathname);
+            pathname = decodeURIComponent(new URL(Uri).pathname);
             if (process.platform === 'win32') {
                 filePath = pathname.slice(1);
             } else {
                 filePath = pathname;
             }
-        } else {
-            // 26702执行forword file文件操作 不应该在这里乱来
-            // const cache = await dbUtil.getFileCacheByName(uri);
-            // if (cache) {
-            //   filePath = cache.path;
-            // } else {
-            //   filePath = uri;
-            // }
-        }
-        res.isLocal = true;
-    }
-    // else{
-    //     res.errMsg = `不支持的file协议,` + url.protocol
-    //     return res
-    // }
-    // if (isGIF(filePath) && !res.isLocal) {
-    //     await fs.rename(filePath, filePath + ".gif");
-    //     filePath += ".gif";
-    // }
-    if (!res.isLocal && !res.ext) {
-        try {
-            const ext: string | undefined = (await fileType.fileTypeFromFile(filePath))?.ext;
-            if (ext) {
-                fs.renameSync(filePath, filePath + `.${ext}`);
-                filePath += `.${ext}`;
-                res.fileName += `.${ext}`;
-                res.ext = ext;
-            }
-        } catch (e) {
-            // log("获取文件类型失败", filePath,e.stack)
-        }
-    }
-    res.success = true;
-    res.path = filePath;
-    return res;
-}
-
-export async function copyFolder(sourcePath: string, destPath: string, logger: LogWrapper) {
-    try {
-        const entries = await fsPromise.readdir(sourcePath, { withFileTypes: true });
-        await fsPromise.mkdir(destPath, { recursive: true });
-        for (const entry of entries) {
-            const srcPath = path.join(sourcePath, entry.name);
-            const dstPath = path.join(destPath, entry.name);
-            if (entry.isDirectory()) {
-                await copyFolder(srcPath, dstPath, logger);
-            } else {
-                try {
-                    await fsPromise.copyFile(srcPath, dstPath);
-                } catch (error) {
-                    logger.logError(`无法复制文件 '${srcPath}' 到 '${dstPath}': ${error}`);
-                    // 这里可以决定是否要继续复制其他文件
-                }
-            }
+            return { Uri: filePath, Type: FileUriType.Local };
         }
     } catch (error) {
-        logger.logError('复制文件夹时出错:', error);
     }
+    return { Uri: Uri, Type: FileUriType.Unknown };
+}
+
+export async function uri2local(dir: string, uri: string, filename: string | undefined = undefined): Promise<Uri2LocalRes> {
+    const { Uri: HandledUri, Type: UriType } = await checkUriType(uri);
+    //解析失败
+
+    if (UriType == FileUriType.Unknown) {
+        return { success: false, errMsg: '未知文件类型', fileName: '', ext: '', path: '', isLocal: false };
+    }
+    //解析File协议和本地文件
+    if (UriType == FileUriType.Local) {
+        const fileExt = path.extname(HandledUri);
+        const filename = path.basename(HandledUri, fileExt);
+        return { success: true, errMsg: '', fileName: filename, ext: fileExt, path: HandledUri, isLocal: true };
+    }
+    //接下来都要有文件名
+    if (!filename) filename = randomUUID();
+    //解析Http和Https协议
+    
+    if (UriType == FileUriType.Remote) {
+        const pathInfo = path.parse(decodeURIComponent(new URL(HandledUri).pathname));
+        if (pathInfo.name) {
+            filename = pathInfo.name;
+          if (pathInfo.ext) {
+            filename += pathInfo.ext;
+          }
+        }
+        filename = filename.replace(/[/\\:*?"<>|]/g, '_');
+        const fileExt = path.extname(HandledUri);
+        const filePath = path.join(dir, filename);
+        const buffer = await httpDownload(HandledUri);
+        fs.writeFileSync(filePath, buffer);
+        return { success: true, errMsg: '', fileName: filename, ext: fileExt, path: filePath, isLocal: true };
+    }
+    //解析Base64
+    if (UriType == FileUriType.Base64) {
+        const base64 = HandledUri.replace(/^base64:\/\//, '');
+        const buffer = Buffer.from(base64, 'base64');
+        let filePath = path.join(dir, filename);
+        let fileExt = '';
+        fs.writeFileSync(filePath, buffer);
+        const { success, ext, path: fileTypePath } = await checkFileV2(filePath);
+        if (success) {
+            filePath = fileTypePath;
+            fileExt = ext;
+            filename = path.basename(filePath, fileExt);
+        }
+        return { success: true, errMsg: '', fileName: filename, ext: fileExt, path: filePath, isLocal: true };
+    }
+    return { success: false, errMsg: '未知文件类型', fileName: '', ext: '', path: '', isLocal: false };
 }

src/common/utils/helper.ts

@@ -53,12 +53,6 @@ export async function runAllWithTimeout<T>(tasks: Promise<T>[], timeout: number)
         .map((result) => (result as { status: 'fulfilled'; value: T }).value);
 }
 
-export function getMd5(s: string) {
-    const h = crypto.createHash('md5');
-    h.update(s);
-    return h.digest('hex');
-}
-
 export function isNull(value: any) {
     return value === undefined || value === null;
 }
@@ -137,28 +131,6 @@ export function getQQVersionConfigPath(exePath: string = ''): string | undefined
     return configVersionInfoPath;
 }
 
-export async function deleteOldFiles(directoryPath: string, daysThreshold: number) {
-    try {
-        const files = await fsPromise.readdir(directoryPath);
-
-        for (const file of files) {
-            const filePath = path.join(directoryPath, file);
-            const stats = await fsPromise.stat(filePath);
-            const lastModifiedTime = stats.mtimeMs;
-            const currentTime = Date.now();
-            const timeDifference = currentTime - lastModifiedTime;
-            const daysDifference = timeDifference / (1000 * 60 * 60 * 24);
-
-            if (daysDifference > daysThreshold) {
-                await fsPromise.unlink(filePath); // Delete the file
-                //console.log(`Deleted: ${filePath}`);
-            }
-        }
-    } catch (error) {
-        //console.error('Error deleting files:', error);
-    }
-}
-
 export function calcQQLevel(level: QQLevel) {
     const { crownNum, sunNum, moonNum, starNum } = level;
     return crownNum * 64 + sunNum * 16 + moonNum * 4 + starNum;

src/core/apis/friend.ts

@@ -26,10 +26,6 @@ export class NTQQFriendApi {
         return Array.from(data.values());
     }
 
-    async getBuddyIdMapCache(refresh = false): Promise<LimitedHashTable<string, string>> {
-        return await this.getBuddyIdMap(refresh);
-    }
-
     async getBuddyIdMap(refresh = false): Promise<LimitedHashTable<string, string>> {
         const uids: string[] = [];
         const retMap: LimitedHashTable<string, string> = new LimitedHashTable<string, string>(5000);

src/core/apis/group.ts

@@ -253,22 +253,45 @@ export class NTQQGroupApi {
     }
 
     async getGroupMemberV2(GroupCode: string, uid: string, forced = false) {
-        type ListenerType = NodeIKernelGroupListener['onMemberInfoChange'];
+        //type ListenerType = NodeIKernelGroupListener['onMemberInfoChange'];
         type EventType = NodeIKernelGroupService['getMemberInfo'];
         // NTEventDispatch.CreatListenerFunction('NodeIKernelGroupListener/onGroupMemberInfoUpdate', 
         //return napCatCore.session.getGroupService().getMemberInfo(GroupCode, [uid], forced);
-        const [, , , _members] = await this.core.eventWrapper.CallNormalEvent<EventType, ListenerType>
+        const Listener = this.core.eventWrapper.RegisterListen<(params: any) => void>
         (
-            'NodeIKernelGroupService/getMemberInfo',
             'NodeIKernelGroupListener/onMemberInfoChange',
             1,
-            5000,
-            (groupCode: string, changeType: number, members: Map<string, GroupMember>) => {
-                return groupCode == GroupCode && members.has(uid);
+            forced ? 5000 : 500,
+            (params) => {
+                return params === GroupCode;
             },
-            GroupCode, [uid], forced,
         );
-        return _members.get(uid);
+        const EventFunc = this.core.eventWrapper.createEventFunction<EventType>('NodeIKernelGroupService/getMemberInfo');
+        const retData = await EventFunc!(GroupCode, [uid], forced);
+        if (retData.result !== 0) {
+            throw new Error(`获取群成员信息失败: ${retData.errMsg}`);
+        }
+        const result = await Listener as unknown;
+        let member: GroupMember | undefined;
+        if (Array.isArray(result) && result?.[2] instanceof Map) {
+            let members = result[2] as Map<string, GroupMember>;
+            member = members.get(uid);
+        };
+        return member;
+
+        // 原本的方法: (no_cache 下效率很高, cache 下效率一致)
+        // const [, , , _members] = await this.core.eventWrapper.CallNormalEvent<EventType, ListenerType>
+        // (
+        //     'NodeIKernelGroupService/getMemberInfo',
+        //     'NodeIKernelGroupListener/onMemberInfoChange',
+        //     1,
+        //     5000,
+        //     (groupCode: string, changeType: number, members: Map<string, GroupMember>) => {
+        //         return groupCode == GroupCode && members.has(uid);
+        //     },
+        //     GroupCode, [uid], forced,
+        // );
+        // return _members.get(uid);
     }
 
     async getGroupMembers(groupQQ: string, num = 3000): Promise<Map<string, GroupMember>> {

src/core/apis/msg.ts

@@ -1,4 +1,4 @@
-import { ChatType, GetFileListParam, Peer, RawMessage, SendMessageElement } from '@/core/entities';
+import { ChatType, GetFileListParam, Peer, RawMessage, SendMessageElement, SendStatusType } from '@/core/entities';
 import { InstanceContext, NapCatCore } from '@/core';
 import { onGroupFileInfoUpdateParamType } from '@/core/listeners';
 import { GeneralCallResult } from '@/core/services/common';
@@ -16,6 +16,9 @@ export class NTQQMsgApi {
         return this.context.session.getMsgService().fetchLongMsg(peer, msgId);
     }
 
+    async sendShowInputStatusReq(peer: Peer, eventType: number) {
+        return this.context.session.getMsgService().sendShowInputStatusReq(peer.chatType, eventType, peer.peerUid);
+    }
     async getMsgEmojiLikesList(peer: Peer, msgSeq: string, emojiId: string, emojiType: string, count: number = 20) {
         //console.log(peer, msgSeq, emojiId, emojiType, count);
         //注意此处emojiType 可选值一般为1-2 2好像是unicode表情dec值 大部分情况 Taged M likiowa
@@ -37,7 +40,6 @@ export class NTQQMsgApi {
         emojiId = emojiId.toString();
         return this.context.session.getMsgService().setMsgEmojiLikes(peer, msgSeq, emojiId, emojiId.length > 3 ? '2' : '1', set);
     }
-
     async getMultiMsg(peer: Peer, rootMsgId: string, parentMsgId: string): Promise<GeneralCallResult & {
         msgList: RawMessage[]
     } | undefined> {
@@ -94,7 +96,22 @@ export class NTQQMsgApi {
     async getMsgsBySeqAndCount(peer: Peer, seq: string, count: number, desc: boolean, z: boolean) {
         return await this.context.session.getMsgService().getMsgsBySeqAndCount(peer, seq, count, desc, z);
     }
-
+    async getMsgExBySeq(peer: Peer, msgSeq: string) {
+        const DateNow = Math.floor(Date.now() / 1000);
+        const filterMsgFromTime = (DateNow - 300).toString();
+        const filterMsgToTime = DateNow.toString();
+        const ret = await this.context.session.getMsgService().queryMsgsWithFilterEx('0', '0', msgSeq, {
+            chatInfo: peer,//此处为Peer 为关键查询参数 没有啥也没有 by mlik iowa
+            filterMsgType: [],
+            filterSendersUid: [],
+            filterMsgToTime: filterMsgToTime,
+            filterMsgFromTime: filterMsgFromTime,
+            isReverseOrder: false,
+            isIncludeCurrent: true,
+            pageLimit: 100,
+        });
+        return ret;
+    }
     async setMsgRead(peer: Peer) {
         return this.context.session.getMsgService().setMsgRead(peer);
     }
@@ -103,18 +120,18 @@ export class NTQQMsgApi {
         const data = await this.core.eventWrapper.CallNormalEvent<
             (GroupCode: string, params: GetFileListParam) => Promise<unknown>,
             (groupFileListResult: onGroupFileInfoUpdateParamType) => void
-                >(
-                'NodeIKernelRichMediaService/getGroupFileList',
-                'NodeIKernelMsgListener/onGroupFileInfoUpdate',
-                1,
-                5000,
-                (groupFileListResult: onGroupFileInfoUpdateParamType) => {
+        >(
+            'NodeIKernelRichMediaService/getGroupFileList',
+            'NodeIKernelMsgListener/onGroupFileInfoUpdate',
+            1,
+            5000,
+            (groupFileListResult: onGroupFileInfoUpdateParamType) => {
                 //Developer Mlikiowa Todo: 此处有问题 无法判断是否成功
-                    return true;
-                },
-                GroupCode,
-                params,
-                );
+                return true;
+            },
+            GroupCode,
+            params,
+        );
         return data[1].item;
     }
 
@@ -129,61 +146,6 @@ export class NTQQMsgApi {
             peerUid: peer.peerUid,
         }, msgIds);
     }
-
-    async sendMsgV2(peer: Peer, msgElements: SendMessageElement[], waitComplete = true, timeout = 10000) {
-        function generateMsgId() {
-            const timestamp = Math.floor(Date.now() / 1000);
-            const random = Math.floor(Math.random() * Math.pow(2, 32));
-            const buffer = Buffer.alloc(8);
-            buffer.writeUInt32BE(timestamp, 0);
-            buffer.writeUInt32BE(random, 4);
-            const msgId = BigInt('0x' + buffer.toString('hex')).toString();
-            return msgId;
-        }
-
-        // 此处有采用Hack方法 利用数据返回正确得到对应消息
-        // 与之前 Peer队列 MsgSeq队列 真正的MsgId并发不同
-        // 谨慎采用 目前测试暂无问题  Developer.Mlikiowa
-        let msgId: string;
-        try {
-            msgId = await this.getMsgUnique(peer.chatType, await this.getServerTime());
-        } catch (error) {
-            //if (!napCatCore.session.getMsgService()['generateMsgUniqueId'])
-            //兜底识别策略V2
-            msgId = generateMsgId().toString();
-        }
-        const data = await this.core.eventWrapper.CallNormalEvent<
-            (msgId: string, peer: Peer, msgElements: SendMessageElement[], map: Map<any, any>) => Promise<unknown>,
-            (msgList: RawMessage[]) => void
-                >(
-                'NodeIKernelMsgService/sendMsg',
-                'NodeIKernelMsgListener/onMsgInfoListUpdate',
-                1,
-                timeout,
-                (msgRecords: RawMessage[]) => {
-                    for (const msgRecord of msgRecords) {
-                        if (msgRecord.msgId === msgId && msgRecord.sendStatus === 2) {
-                            return true;
-                        }
-                    }
-                    return false;
-                },
-                msgId,
-                peer,
-                msgElements,
-                new Map(),
-                );
-        const retMsg = data[1].find(msgRecord => {
-            if (msgRecord.msgId === msgId) {
-                return true;
-            }
-        });
-        return retMsg;
-    }
-
-    sendMsgEx(peer: Peer, msgElements: SendMessageElement[], waitComplete = true, timeout = 10000) {
-        //return NTQQMsgApi.sendMsgV1(peer, msgElements, waitComplete, timeout);
-    }
     async PrepareTempChat(toUserUid: string, GroupCode: string, nickname: string) {
         //By Jadx/Ida Mlikiowa
         const TempGameSession = {
@@ -215,29 +177,29 @@ export class NTQQMsgApi {
                 await this.PrepareTempChat(peer.peerUid, peer.guildId, member.nick);
             }
         }
-        const msgId = await this.getMsgUnique(peer.chatType, await this.getServerTime());
+        const msgId = await this.generateMsgUniqueId(peer.chatType, await this.getServerTime());
         peer.guildId = msgId;
         const data = await this.core.eventWrapper.CallNormalEvent<
             (msgId: string, peer: Peer, msgElements: SendMessageElement[], map: Map<any, any>) => Promise<unknown>,
             (msgList: RawMessage[]) => void
-                >(
-                'NodeIKernelMsgService/sendMsg',
-                'NodeIKernelMsgListener/onMsgInfoListUpdate',
-                1,
-                timeout,
-                (msgRecords: RawMessage[]) => {
-                    for (const msgRecord of msgRecords) {
-                        if (msgRecord.guildId === msgId && msgRecord.sendStatus === 2) {
-                            return true;
-                        }
+        >(
+            'NodeIKernelMsgService/sendMsg',
+            'NodeIKernelMsgListener/onMsgInfoListUpdate',
+            1,
+            timeout,
+            (msgRecords: RawMessage[]) => {
+                for (const msgRecord of msgRecords) {
+                    if (msgRecord.guildId === msgId && msgRecord.sendStatus === SendStatusType.KSEND_STATUS_SUCCESS) {
+                        return true;
                     }
-                    return false;
-                },
-                '0',
-                peer,
-                msgElements,
-                new Map(),
-                );
+                }
+                return false;
+            },
+            '0',
+            peer,
+            msgElements,
+            new Map(),
+        );
         const retMsg = data[1].find(msgRecord => {
             if (msgRecord.guildId === msgId) {
                 return true;
@@ -246,21 +208,14 @@ export class NTQQMsgApi {
         return retMsg;
     }
 
-    async getMsgUnique(chatType: number, time: string) {
-        if (this.context.basicInfoWrapper.requireMinNTQQBuild('26702')) {
-            return this.context.session.getMsgService().generateMsgUniqueId(chatType, time);
-        }
-        return this.context.session.getMsgService().getMsgUniqueId(time);
+    async generateMsgUniqueId(chatType: number, time: string) {
+        return this.context.session.getMsgService().generateMsgUniqueId(chatType, time);
     }
 
     async getServerTime() {
         return this.context.session.getMSFService().getServerTime();
     }
 
-    async getServerTimeV2() {
-        return this.core.eventWrapper.callNoListenerEvent<() => string>('NodeIKernelMsgService/getServerTime', 5000);
-    }
-
     async forwardMsg(srcPeer: Peer, destPeer: Peer, msgIds: string[]) {
         return this.context.session.getMsgService().forwardMsg(msgIds, srcPeer, [destPeer], new Map());
     }
@@ -272,25 +227,25 @@ export class NTQQMsgApi {
         const data = await this.core.eventWrapper.CallNormalEvent<
             (msgInfo: typeof msgInfos, srcPeer: Peer, destPeer: Peer, comment: Array<any>, attr: Map<any, any>) => Promise<unknown>,
             (msgList: RawMessage[]) => void
-                >(
-                'NodeIKernelMsgService/multiForwardMsgWithComment',
-                'NodeIKernelMsgListener/onMsgInfoListUpdate',
-                1,
-                5000,
-                (msgRecords: RawMessage[]) => {
-                    for (const msgRecord of msgRecords) {
-                        if (msgRecord.peerUid == destPeer.peerUid && msgRecord.senderUid == this.core.selfInfo.uid) {
-                            return true;
-                        }
+        >(
+            'NodeIKernelMsgService/multiForwardMsgWithComment',
+            'NodeIKernelMsgListener/onMsgInfoListUpdate',
+            1,
+            5000,
+            (msgRecords: RawMessage[]) => {
+                for (const msgRecord of msgRecords) {
+                    if (msgRecord.peerUid == destPeer.peerUid && msgRecord.senderUid == this.core.selfInfo.uid) {
+                        return true;
                     }
-                    return false;
-                },
-                msgInfos,
-                srcPeer,
-                destPeer,
-                [],
-                new Map(),
-                );
+                }
+                return false;
+            },
+            msgInfos,
+            srcPeer,
+            destPeer,
+            [],
+            new Map(),
+        );
         for (const msg of data[1]) {
             const arkElement = msg.elements.find(ele => ele.arkElement);
             if (!arkElement) {

src/core/apis/user.ts

@@ -100,7 +100,7 @@ export class NTQQUserApi {
         return retData;
     }
 
-    async fetchUserDetailInfo(uid: string) {
+    async fetchUserDetailInfo(uid: string, mode: UserDetailSource = UserDetailSource.KDB) {
         type EventService = NodeIKernelProfileService['fetchUserDetailInfo'];
         type EventListener = NodeIKernelProfileListener['onUserDetailInfoChanged'];
         const [_retData, profile] = await this.core.eventWrapper.CallNormalEvent<EventService, EventListener>(
@@ -111,7 +111,7 @@ export class NTQQUserApi {
             (profile) => profile.uid === uid,
             'BuddyProfileStore',
             [uid],
-            UserDetailSource.KSERVER,
+            mode,
             [ProfileBizType.KALL],
         );
         const RetUser: User = {
@@ -121,31 +121,19 @@ export class NTQQUserApi {
             ...profile.commonExt,
             ...profile.simpleInfo.baseInfo,
             qqLevel: profile.commonExt.qqLevel,
+            age: profile.simpleInfo.baseInfo.age,
             pendantId: '',
         };
         return RetUser;
     }
 
     async getUserDetailInfo(uid: string) {
-        if (this.context.basicInfoWrapper.requireMinNTQQBuild('26702')) {
-            return this.fetchUserDetailInfo(uid);
+        const ret = await this.fetchUserDetailInfo(uid, UserDetailSource.KDB);
+        if (ret.uin === '0') {
+            console.log('[NapCat] [Mark] getUserDetailInfo Mode1 Failed.')
+            return await this.fetchUserDetailInfo(uid, UserDetailSource.KSERVER);
         }
-        return this.getUserDetailInfoOld(uid);
-    }
-
-    async getUserDetailInfoOld(uid: string) {
-        type EventService = NodeIKernelProfileService['getUserDetailInfoWithBizInfo'];
-        type EventListener = NodeIKernelProfileListener['onProfileDetailInfoChanged'];
-        const [_retData, profile] = await this.core.eventWrapper.CallNormalEvent<EventService, EventListener>(
-            'NodeIKernelProfileService/getUserDetailInfoWithBizInfo',
-            'NodeIKernelProfileListener/onProfileDetailInfoChanged',
-            2,
-            5000,
-            (profile) => profile.uid === uid,
-            uid,
-            [0],
-        );
-        return profile;
+        return ret;
     }
 
     async modifySelfProfile(param: ModifyProfileParams) {
@@ -203,39 +191,14 @@ export class NTQQUserApi {
         return skey;
     }
 
-    /**
-     * @deprecated
-     */
-    async getUidByUin(Uin: string) {
-        if (this.context.basicInfoWrapper.requireMinNTQQBuild('26702')) {
-            return await this.getUidByUinV2(Uin);
-        }
-        return await this.getUidByUinV1(Uin);
-    }
-
-    /**
-     * @deprecated
-     */
-    async getUinByUid(Uid: string) {
-        if (this.context.basicInfoWrapper.requireMinNTQQBuild('26702')) {
-            return await this.getUinByUidV2(Uid);
-        }
-        return await this.getUinByUidV1(Uid);
-    }
-
     //后期改成流水线处理
     async getUidByUinV2(Uin: string) {
-        let uid = (await this.context.session.getProfileService().getUidByUin('FriendsServiceImpl', [Uin])).get(Uin);
+        let uid = (await this.context.session.getGroupService().getUidByUins([Uin])).uids.get(Uin);
         if (uid) return uid;
-        uid = (await this.context.session.getGroupService().getUidByUins([Uin])).uids.get(Uin);
+        uid = (await this.context.session.getProfileService().getUidByUin('FriendsServiceImpl', [Uin])).get(Uin);
         if (uid) return uid;
         uid = (await this.context.session.getUixConvertService().getUid([Uin])).uidInfo.get(Uin);
         if (uid) return uid;
-        // console.log((await this.core.getApiContext().FriendApi.getBuddyIdMapCache(true)));
-        uid = (await this.core.apis.FriendApi.getBuddyIdMapCache(true)).getValue(Uin);//从Buddy缓存获取Uid
-        if (uid) return uid;
-        uid = (await this.core.apis.FriendApi.getBuddyIdMap(true)).getValue(Uin);
-        if (uid) return uid;
         const unveifyUid = (await this.getUserDetailInfoByUinV2(Uin)).detail.uid;//从QQ Native 特殊转换
         if (unveifyUid.indexOf('*') == -1) uid = unveifyUid;
         //if (uid) return uid;
@@ -250,44 +213,12 @@ export class NTQQUserApi {
         if (uin) return uin;
         uin = (await this.context.session.getUixConvertService().getUin([Uid])).uinInfo.get(Uid);
         if (uin) return uin;
-        uin = (await this.core.apis.FriendApi.getBuddyIdMapCache(true)).getKey(Uid);//从Buddy缓存获取Uin
-        if (uin) return uin;
         uin = (await this.core.apis.FriendApi.getBuddyIdMap(true)).getKey(Uid);
         if (uin) return uin;
         uin = (await this.getUserDetailInfo(Uid)).uin; //从QQ Native 转换
         return uin;
     }
 
-    async getUidByUinV1(Uin: string) {
-        // 通用转换开始尝试
-        let uid = (await this.context.session.getUixConvertService().getUid([Uin])).uidInfo.get(Uin);
-        if (!uid) {
-            const unveifyUid = (await this.getUserDetailInfoByUin(Uin)).info.uid;//从QQ Native 特殊转换 方法三
-            if (unveifyUid.indexOf('*') == -1) {
-                uid = unveifyUid;
-            }
-        }
-        return uid;
-    }
-
-    async getUinByUidV1(Uid: string) {
-        const ret = await this.core.eventWrapper.callNoListenerEvent<(Uin: string[]) => Promise<{
-            uinInfo: Map<string, string>
-        }>>
-            ('NodeIKernelUixConvertService/getUin', 5000, [Uid]);
-        let uin = ret.uinInfo.get(Uid);
-        if (!uin) {
-            uin = (await this.getUserDetailInfo(Uid)).uin; //从QQ Native 转换
-        }
-        // if (!uin) {
-        //   uin = (await NTQQFriendApi.getFriends(false)).find((t) => { t.uid == Uid })?.uin;  //从QQ Native 缓存转换
-        // }
-        // if (!uin) {
-        //   uin = (await NTQQFriendApi.getFriends(true)).find((t) => { t.uid == Uid })?.uin;  //从QQ Native 非缓存转换
-        // }
-        return uin;
-    }
-
     async getRecentContactListSnapShot(count: number) {
         return await this.context.session.getRecentContactService().getRecentContactListSnapShot(count);
     }
@@ -309,11 +240,6 @@ export class NTQQUserApi {
             ('NodeIKernelProfileService/getUserDetailInfoByUin', 5000, Uin);
     }
 
-    async getUserDetailInfoByUin(Uin: string) {
-        return this.core.eventWrapper.callNoListenerEvent<(Uin: string) => Promise<UserDetailInfoByUin>>
-            ('NodeIKernelProfileService/getUserDetailInfoByUin', 5000, Uin);
-    }
-
     async forceFetchClientKey() {
         return await this.context.session.getTicketService().forceFetchClientKey('');
     }

src/core/core.ts

@@ -93,6 +93,9 @@ export class NapCatCore {
         msgListener.onRecvMsg = (msgs) => {
             msgs.forEach(msg => this.context.logger.logMessage(msg, this.selfInfo));
         };
+        msgListener.onAddSendMsg = (msg) => {
+            this.context.logger.logMessage(msg, this.selfInfo);
+        };
         //await sleep(2500);
         this.context.session.getMsgService().addKernelMsgListener(
             new this.context.wrapper.NodeIKernelMsgListener(proxiedListenerOf(msgListener, this.context.logger)),

src/core/entities/group.ts

@@ -1,4 +1,4 @@
-import { QQLevel, Sex } from './user';
+import { QQLevel, Sex, User } from './user';
 
 export enum GroupListUpdateType {
     REFRESHALL,
@@ -65,6 +65,7 @@ export interface GroupMember {
     uin: string; // QQ号
     isRobot: boolean;
     sex?: Sex;
+    age?: number;
     qqLevel?: QQLevel;
     isChangeRole: boolean;
     joinTime: string;

src/core/entities/msg.ts

@@ -614,13 +614,28 @@ export interface PicElement {
     originImageUrl?: string;  // http url, 没有host，host是https://gchat.qpic.cn/, 带download参数的是https://multimedia.nt.qq.com.cn
 }
 
-export enum GrayTipElementSubType {
-    INVITE_NEW_MEMBER = 12,
-    MEMBER_NEW_TITLE = 17
+export enum NTGrayTipElementSubTypeV2 {
+    GRAYTIP_ELEMENT_SUBTYPE_AIOOP = 15,
+    GRAYTIP_ELEMENT_SUBTYPE_BLOCK = 14,
+    GRAYTIP_ELEMENT_SUBTYPE_BUDDY = 5,
+    GRAYTIP_ELEMENT_SUBTYPE_BUDDYNOTIFY = 9,
+    GRAYTIP_ELEMENT_SUBTYPE_EMOJIREPLY = 3,
+    GRAYTIP_ELEMENT_SUBTYPE_ESSENCE = 7,
+    GRAYTIP_ELEMENT_SUBTYPE_FEED = 6,
+    GRAYTIP_ELEMENT_SUBTYPE_FEEDCHANNELMSG = 11,
+    GRAYTIP_ELEMENT_SUBTYPE_FILE = 10,
+    GRAYTIP_ELEMENT_SUBTYPE_GROUP = 4,
+    GRAYTIP_ELEMENT_SUBTYPE_GROUPNOTIFY = 8,
+    GRAYTIP_ELEMENT_SUBTYPE_JSON = 17,
+    GRAYTIP_ELEMENT_SUBTYPE_LOCALMSG = 13,
+    GRAYTIP_ELEMENT_SUBTYPE_PROCLAMATION = 2,
+    GRAYTIP_ELEMENT_SUBTYPE_REVOKE = 1,
+    GRAYTIP_ELEMENT_SUBTYPE_UNKNOWN = 0,
+    GRAYTIP_ELEMENT_SUBTYPE_WALLET = 16,
+    GRAYTIP_ELEMENT_SUBTYPE_XMLMSG = 12,
 }
-
 export interface GrayTipElement {
-    subElementType: GrayTipElementSubType;
+    subElementType: NTGrayTipElementSubTypeV2;
     revokeElement: {
         operatorRole: string;
         operatorUid: string;
@@ -876,6 +891,12 @@ export enum NTSubMsgType {
     KMSGSUBTYPEMIXTEXT = 0,
     KMSGSUBTYPETENCENTDOC = 6
 }
+export enum SendStatusType {
+    KSEND_STATUS_FAILED = 0,
+    KSEND_STATUS_SENDING = 1,
+    KSEND_STATUS_SUCCESS = 2,
+    KSEND_STATUS_SUCCESS_NOSEQ = 3
+}
 export interface RawMessage {
     parentMsgPeer: Peer;
 
@@ -935,7 +956,7 @@ export interface RawMessage {
     /**
      * 消息状态，别人发的 2 是已撤回，自己发的 2 是已发送
      */
-    sendStatus?: number;
+    sendStatus?: SendStatusType;
 
     /**
      * 撤回时间，"0" 是没有撤回

src/core/entities/user.ts

@@ -231,6 +231,7 @@ export interface User {
     longNick?: string; // 签名
     remark?: string;
     sex?: Sex;
+    age?: number;
     qqLevel?: QQLevel;
     qid?: string;
     birthday_year?: number;

src/onebot/action/extends/FetchCustomFace.ts

@@ -5,7 +5,7 @@ import { ActionName } from '../types';
 const SchemaData = {
     type: 'object',
     properties: {
-        count: { type: 'number' },
+        count: { type: ['number', 'string'] },
     },
 } as const satisfies JSONSchema;
 
@@ -17,7 +17,7 @@ export class FetchCustomFace extends BaseAction<Payload, string[]> {
 
     async _handle(payload: Payload) {
         //48 可能正好是QQ需要的一个页面的数量 Tagged Mlikiowa
-        const ret = await this.CoreContext.apis.MsgApi.fetchFavEmojiList(payload.count || 48);
+        const ret = await this.CoreContext.apis.MsgApi.fetchFavEmojiList(parseInt((payload.count || '0').toString()) || 48);
         return ret.emojiInfoList.map(e => e.url);
     }
 }

src/onebot/action/extends/FetchEmojiLike.ts

@@ -12,7 +12,7 @@ const SchemaData = {
         emojiId: { type: 'string' },
         emojiType: { type: 'string' },
         message_id: { type: ['string', 'number'] },
-        count: { type: 'number' },
+        count: { type: ['string', 'number'] },
     },
     required: ['emojiId', 'emojiType', 'message_id'],
 } as const satisfies JSONSchema;
@@ -22,12 +22,11 @@ type Payload = FromSchema<typeof SchemaData>;
 export class FetchEmojiLike extends BaseAction<Payload, any> {
     actionName = ActionName.FetchEmojiLike;
     PayloadSchema = SchemaData;
-
     async _handle(payload: Payload) {
         const NTQQMsgApi = this.CoreContext.apis.MsgApi;
         const msgIdPeer = MessageUnique.getMsgIdAndPeerByShortId(parseInt(payload.message_id.toString()));
         if (!msgIdPeer) throw new Error('消息不存在');
         const msg = (await NTQQMsgApi.getMsgsByMsgId(msgIdPeer.Peer, [msgIdPeer.MsgId])).msgList[0];
-        return await NTQQMsgApi.getMsgEmojiLikesList(msgIdPeer.Peer, msg.msgSeq, payload.emojiId, payload.emojiType, payload.count);
+        return await NTQQMsgApi.getMsgEmojiLikesList(msgIdPeer.Peer, msg.msgSeq, payload.emojiId, payload.emojiType, parseInt((payload.count || '0').toString()) || 20);
     }
 }

src/onebot/action/extends/GetCollectionList.ts

@@ -5,8 +5,8 @@ import { FromSchema, JSONSchema } from 'json-schema-to-ts';
 const SchemaData = {
     type: 'object',
     properties: {
-        category: { type: 'number' },
-        count: { type: 'number' },
+        category: { type: ['number', 'string'] },
+        count: { type: ['number', 'string'] },
     },
     required: ['category', 'count'],
 } as const satisfies JSONSchema;
@@ -16,9 +16,8 @@ type Payload = FromSchema<typeof SchemaData>;
 export class GetCollectionList extends BaseAction<Payload, any> {
     actionName = ActionName.GetCollectionList;
     PayloadSchema = SchemaData;
-
     async _handle(payload: Payload) {
         const NTQQCollectionApi = this.CoreContext.apis.CollectionApi;
-        return await NTQQCollectionApi.getAllCollection(payload.category, payload.count);
+        return await NTQQCollectionApi.getAllCollection(parseInt(payload.category.toString()), parseInt(payload.count.toString()));
     }
 }

src/onebot/action/extends/GetFriendWithCategory.ts

@@ -4,7 +4,6 @@ import { ActionName } from '../types';
 
 export class GetFriendWithCategory extends BaseAction<void, any> {
     actionName = ActionName.GetFriendsWithCategory;
-
     async _handle(payload: void) {
         return (await this.CoreContext.apis.FriendApi.getBuddyV2ExWithCate(true)).map(category => ({
             ...category,

src/onebot/action/extends/GetProfileLike.ts

@@ -9,7 +9,7 @@ export class GetProfileLike extends BaseAction<void, any> {
         const ret = await NTQQUserApi.getProfileLike(this.CoreContext.selfInfo.uid);
         const listdata: any[] = ret.info.userLikeInfos[0].favoriteInfo.userInfos;
         for (let i = 0; i < listdata.length; i++) {
-            listdata[i].uin = parseInt((await NTQQUserApi.getUinByUid(listdata[i].uid)) || '');
+            listdata[i].uin = parseInt((await NTQQUserApi.getUinByUidV2(listdata[i].uid)) || '');
         }
         return listdata;
     }

src/onebot/action/extends/OCRImage.ts

@@ -3,7 +3,6 @@ import { ActionName } from '../types';
 import { FromSchema, JSONSchema } from 'json-schema-to-ts';
 import { checkFileReceived, uri2local } from '@/common/utils/file';
 import fs from 'fs';
-
 const SchemaData = {
     type: 'object',
     properties: {

src/onebot/action/extends/SetInputStatus.ts

@@ -0,0 +1,44 @@
+import { FromSchema, JSONSchema } from 'json-schema-to-ts';
+import BaseAction from '../BaseAction';
+import { ActionName } from '../types';
+import { ChatType, Peer } from '@/core';
+
+const SchemaData = {
+    type: 'object',
+    properties: {
+        eventType: { type: 'string' },
+        group_id: { type: 'string' },
+        user_id: { type: 'string' }
+    },
+    required: ['eventType'],
+} as const satisfies JSONSchema;
+
+type Payload = FromSchema<typeof SchemaData>;
+
+export class SetInputStatus extends BaseAction<Payload, any> {
+    actionName = ActionName.SetInputStatus;
+
+    async _handle(payload: Payload) {
+        const NTQQUserApi = this.CoreContext.apis.UserApi;
+        const NTQQMsgApi = this.CoreContext.apis.MsgApi;
+        let peer: Peer;
+        if (payload.group_id) {
+            peer = {
+                chatType: ChatType.group,
+                peerUid: payload.group_id
+            }
+        } else if (payload.user_id) {
+            let uid = await NTQQUserApi.getUidByUinV2(payload.user_id);
+            if (!uid) throw new Error('uid is empty');
+            peer = {
+                chatType: ChatType.friend,
+                peerUid: uid
+            }
+        } else {
+            throw new Error('请指定 group_id 或 user_id');
+        }
+
+        const ret = await NTQQMsgApi.sendShowInputStatusReq(peer, parseInt(payload.eventType));
+        return ret;
+    }
+}

src/onebot/action/extends/SetOnlineStatus.ts

@@ -6,9 +6,9 @@ import { FromSchema, JSONSchema } from 'json-schema-to-ts';
 const SchemaData = {
     type: 'object',
     properties: {
-        status: { type: 'number' },
-        extStatus: { type: 'number' },
-        batteryStatus: { type: 'number' },
+        status: { type: ['number', 'string'] },
+        extStatus: { type: ['number', 'string'] },
+        batteryStatus: { type: ['number', 'string'] },
     },
     required: ['status', 'extStatus', 'batteryStatus'],
 } as const satisfies JSONSchema;
@@ -20,14 +20,12 @@ export class SetOnlineStatus extends BaseAction<Payload, null> {
     PayloadSchema = SchemaData;
 
     async _handle(payload: Payload) {
-        // 可设置状态
-        // { status: 10, extStatus: 1027, batteryStatus: 0 }
-        // { status: 30, extStatus: 0, batteryStatus: 0 }
-        // { status: 50, extStatus: 0, batteryStatus: 0 }
-        // { status: 60, extStatus: 0, batteryStatus: 0 }
-        // { status: 70, extStatus: 0, batteryStatus: 0 }
         const NTQQUserApi = this.CoreContext.apis.UserApi;
-        const ret = await NTQQUserApi.setSelfOnlineStatus(payload.status, payload.extStatus, payload.batteryStatus);
+        const ret = await NTQQUserApi.setSelfOnlineStatus(
+            parseInt(payload.status.toString()),
+            parseInt(payload.extStatus.toString()),
+            parseInt(payload.batteryStatus.toString())
+        );
         if (ret.result !== 0) {
             throw new Error('设置在线状态失败');
         }

src/onebot/action/extends/SetSelfProfile.ts

@@ -7,7 +7,7 @@ const SchemaData = {
     properties: {
         nick: { type: 'string' },
         longNick: { type: 'string' },
-        sex: { type: 'number' },//传Sex值？建议传0
+        sex: { type: ['number', 'string'] },//传Sex值？建议传0
     },
     required: ['nick', 'longNick', 'sex'],
 } as const satisfies JSONSchema;
@@ -23,7 +23,7 @@ export class SetSelfProfile extends BaseAction<Payload, any | null> {
         const ret = await NTQQUserApi.modifySelfProfile({
             nick: payload.nick,
             longNick: payload.longNick,
-            sex: payload.sex,
+            sex: parseInt(payload.sex.toString()),
             birthday: { birthday_year: '', birthday_month: '', birthday_day: '' },
             location: undefined,
         });

src/onebot/action/go-cqhttp/DownloadFile.ts

@@ -13,7 +13,7 @@ interface FileResponse {
 const SchemaData = {
     type: 'object',
     properties: {
-        thread_count: { type: 'number' },
+        thread_count: { type: ['number', 'string'] },
         url: { type: 'string' },
         base64: { type: 'string' },
         name: { type: 'string' },

src/onebot/action/go-cqhttp/GetStrangerInfo.ts

@@ -21,20 +21,23 @@ export default class GoCQHTTPGetStrangerInfo extends BaseAction<Payload, OB11Use
     async _handle(payload: Payload): Promise<OB11User> {
         const NTQQUserApi = this.CoreContext.apis.UserApi;
         const user_id = payload.user_id.toString();
-        const extendData = await NTQQUserApi.getUserDetailInfoByUin(user_id);
+        const extendData = await NTQQUserApi.getUserDetailInfoByUinV2(user_id);
         const uid = (await NTQQUserApi.getUidByUinV2(user_id))!;
         if (!uid || uid.indexOf('*') != -1) {
             const ret = {
-                ...extendData,
-                user_id: parseInt(extendData.info.uin) || 0,
-                nickname: extendData.info.nick,
+                ...extendData.detail.simpleInfo.coreInfo,
+                ...extendData.detail.commonExt,
+                ...extendData.detail.simpleInfo.baseInfo,
+                ...extendData.detail.simpleInfo.relationFlags,
+                user_id: parseInt(extendData.detail.uin) || 0,
+                nickname: extendData.detail.simpleInfo.coreInfo.nick,
                 sex: OB11UserSex.unknown,
-                age: (extendData.info.birthday_year == 0) ? 0 : new Date().getFullYear() - extendData.info.birthday_year,
-                qid: extendData.info.qid,
-                level: extendData.info.qqLevel && calcQQLevel(extendData.info.qqLevel) || 0,
+                age: extendData.detail.simpleInfo.baseInfo.age || 0,
+                qid: extendData.detail.simpleInfo.baseInfo.qid,
+                level: calcQQLevel(extendData.detail.commonExt?.qqLevel ?? 0) || 0,
                 login_days: 0,
-                uid: '',
-            };
+                uid: ''
+              };
             return ret;
         }
         const data = { ...extendData, ...(await NTQQUserApi.getUserDetailInfo(uid)) };

src/onebot/action/group/GetGroupInfo.ts

@@ -21,11 +21,8 @@ class GetGroupInfo extends BaseAction<Payload, OB11Group> {
     async _handle(payload: Payload) {
         const NTQQGroupApi = this.CoreContext.apis.GroupApi;
         const group = (await NTQQGroupApi.getGroups()).find(e => e.groupCode == payload.group_id.toString());
-        if (group) {
-            return OB11Constructor.group(group);
-        } else {
-            throw `群${payload.group_id}不存在`;
-        }
+        if (!group) throw `群${payload.group_id}不存在`;
+        return OB11Constructor.group(group);
     }
 }
 

src/onebot/action/group/GetGroupList.ts

@@ -20,7 +20,7 @@ class GetGroupList extends BaseAction<Payload, OB11Group[]> {
 
     async _handle(payload: Payload) {
         const NTQQGroupApi = this.CoreContext.apis.GroupApi;
-        const groupList: Group[] = await NTQQGroupApi.getGroups(payload?.no_cache === true || payload.no_cache === 'true');
+        const groupList: Group[] = await NTQQGroupApi.getGroups(typeof payload.no_cache === 'string' ? payload.no_cache === 'true' : !!payload.no_cache);
         return OB11Constructor.groups(groupList);
     }
 }

src/onebot/action/group/GetGroupMemberInfo.ts

@@ -24,15 +24,11 @@ class GetGroupMemberInfo extends BaseAction<Payload, OB11GroupMember> {
         const NTQQUserApi = this.CoreContext.apis.UserApi;
         const NTQQGroupApi = this.CoreContext.apis.GroupApi;
         const NTQQWebApi = this.CoreContext.apis.WebApi;
-        const isNocache = payload.no_cache == true || payload.no_cache === 'true';
+        const isNocache = typeof payload.no_cache === 'string' ? payload.no_cache === 'true' : !!payload.no_cache;
         const uid = await NTQQUserApi.getUidByUinV2(payload.user_id.toString());
-        if (!uid) {
-            throw (`Uin2Uid Error ${payload.user_id}不存在`);
-        }
+        if (!uid) throw (`Uin2Uid Error ${payload.user_id}不存在`);
         const member = await NTQQGroupApi.getGroupMemberV2(payload.group_id.toString(), uid, isNocache);
-        if (!member) {
-            throw (`群(${payload.group_id})成员${payload.user_id}不存在`);
-        }
+        if (!member) throw (`群(${payload.group_id})成员${payload.user_id}不存在`);
         try {
             const info = (await NTQQUserApi.getUserDetailInfo(member.uid));
             this.CoreContext.context.logger.logDebug('群成员详细信息结果', info);
@@ -42,37 +38,8 @@ class GetGroupMemberInfo extends BaseAction<Payload, OB11GroupMember> {
         }
         const date = Math.round(Date.now() / 1000);
         const retMember = OB11Constructor.groupMember(payload.group_id.toString(), member);
-        if (!this.CoreContext.context.basicInfoWrapper.requireMinNTQQBuild('26702')) {
-            const SelfInfoInGroup = await NTQQGroupApi.getGroupMemberV2(payload.group_id.toString(), this.CoreContext.selfInfo.uid, isNocache);
-            let isPrivilege = false;
-            if (SelfInfoInGroup) {
-                isPrivilege = SelfInfoInGroup.role === 3 || SelfInfoInGroup.role === 4;
-            }
-            if (isPrivilege) {
-                const webGroupMembers = await NTQQWebApi.getGroupMembers(payload.group_id.toString());
-                for (let i = 0, len = webGroupMembers.length; i < len; i++) {
-                    if (webGroupMembers[i]?.uin && webGroupMembers[i].uin === retMember.user_id) {
-                        retMember.join_time = webGroupMembers[i]?.join_time;
-                        retMember.last_sent_time = webGroupMembers[i]?.last_speak_time;
-                        retMember.qage = webGroupMembers[i]?.qage;
-                        retMember.level = webGroupMembers[i]?.lv.level.toString();
-                    }
-                }
-            } else {
-                const LastestMsgList = await NTQQGroupApi.getLatestMsg(payload.group_id.toString(), [payload.user_id.toString()]);
-                if (LastestMsgList?.msgList?.length && LastestMsgList?.msgList?.length > 0) {
-                    const last_send_time = LastestMsgList.msgList[0].msgTime;
-                    if (last_send_time && last_send_time != '0' && last_send_time != '') {
-                        retMember.last_sent_time = parseInt(last_send_time);
-                        retMember.join_time = Math.round(Date.now() / 1000);//兜底数据 防止群管乱杀
-                    }
-                }
-            }
-        } else {
-            // Mlikiowa V2.0.20 Refactor Todo
-            // retMember.last_sent_time = parseInt((await getGroupMember(payload.group_id.toString(), retMember.user_id))?.lastSpeakTime || date.toString());
-            // retMember.join_time = parseInt((await getGroupMember(payload.group_id.toString(), retMember.user_id))?.joinTime || date.toString());
-        }
+        retMember.last_sent_time = parseInt((await this.CoreContext.apis.GroupApi.getGroupMember(payload.group_id.toString(), retMember.user_id))?.lastSpeakTime || date.toString());
+        retMember.join_time = parseInt((await this.CoreContext.apis.GroupApi.getGroupMember(payload.group_id.toString(), retMember.user_id))?.joinTime || date.toString());
         return retMember;
     }
 }

src/onebot/action/group/GetGroupMemberList.ts

@@ -22,23 +22,16 @@ class GetGroupMemberList extends BaseAction<Payload, OB11GroupMember[]> {
     async _handle(payload: Payload) {
         const NTQQGroupApi = this.CoreContext.apis.GroupApi;
         const NTQQWebApi = this.CoreContext.apis.WebApi;
-        const isNocache = payload.no_cache == true || payload.no_cache === 'true';
-        // const GroupList = await NTQQGroupApi.getGroups(isNocache);
-        // const group = GroupList.find(item => item.groupCode == payload.group_id);
-        // if (!group) {
-        //     throw (`群${payload.group_id}不存在`);
-        // }
         const groupMembers = await NTQQGroupApi.getGroupMembers(payload.group_id.toString());
         const groupMembersArr = Array.from(groupMembers.values());
-        const groupMembersUids = groupMembersArr.map(e => e.uid);
+
         let _groupMembers = groupMembersArr.map(item => {
             return OB11Constructor.groupMember(payload.group_id.toString(), item);
         });
 
         const MemberMap: Map<number, OB11GroupMember> = new Map<number, OB11GroupMember>();
-        // 转为Map 方便索引
-        const GroupMemberUids: string[] = [];
         const date = Math.round(Date.now() / 1000);
+
         for (let i = 0, len = _groupMembers.length; i < len; i++) {
             // 保证基础数据有这个 同时避免群管插件过于依赖这个杀了
             _groupMembers[i].join_time = date;
@@ -46,58 +39,30 @@ class GetGroupMemberList extends BaseAction<Payload, OB11GroupMember[]> {
             MemberMap.set(_groupMembers[i].user_id, _groupMembers[i]);
         }
 
-        if (!this.CoreContext.context.basicInfoWrapper.requireMinNTQQBuild('26702')) {
-            const selfRole = groupMembers.get(this.CoreContext.selfInfo.uid)?.role;
-            const isPrivilege = selfRole === 3 || selfRole === 4;
+        const selfRole = groupMembers.get(this.CoreContext.selfInfo.uid)?.role;
+        const isPrivilege = selfRole === 3 || selfRole === 4;
 
-            if (isPrivilege) {
-                const webGroupMembers = await NTQQWebApi.getGroupMembers(payload.group_id.toString());
-                for (let i = 0, len = webGroupMembers.length; i < len; i++) {
-                    if (!webGroupMembers[i]?.uin) {
-                        continue;
-                    }
-                    const MemberData = MemberMap.get(webGroupMembers[i]?.uin);
-                    if (MemberData) {
-                        MemberData.join_time = webGroupMembers[i]?.join_time;
-                        MemberData.last_sent_time = webGroupMembers[i]?.last_speak_time;
-                        MemberData.qage = webGroupMembers[i]?.qage;
-                        MemberData.level = webGroupMembers[i]?.lv.level.toString();
-                        MemberMap.set(webGroupMembers[i]?.uin, MemberData);
-                    }
+        _groupMembers.forEach(item => {
+            item.last_sent_time = date;
+            item.join_time = date;
+        });
+
+        if (isPrivilege) {
+            const webGroupMembers = await NTQQWebApi.getGroupMembers(payload.group_id.toString());
+            for (let i = 0, len = webGroupMembers.length; i < len; i++) {
+                if (!webGroupMembers[i]?.uin) {
+                    continue;
                 }
-            } else {
-                if (isNocache) {
-                    const DateMap = await NTQQGroupApi.getGroupMemberLatestSendTimeCache(payload.group_id.toString(), groupMembersUids);//开始从本地拉取
-                    for (const DateUin of DateMap.keys()) {
-                        const MemberData = MemberMap.get(parseInt(DateUin));
-                        if (MemberData) {
-                            MemberData.last_sent_time = parseInt(DateMap.get(DateUin)!);
-                            //join_time 有基础数据兜底
-                        }
-                    }
-                } else {
-                    _groupMembers.forEach(item => {
-                        item.last_sent_time = date;
-                        item.join_time = date;
-                    });
+                const MemberData = MemberMap.get(webGroupMembers[i]?.uin);
+                if (MemberData) {
+                    MemberData.join_time = webGroupMembers[i]?.join_time;
+                    MemberData.last_sent_time = webGroupMembers[i]?.last_speak_time;
+                    MemberData.qage = webGroupMembers[i]?.qage;
+                    MemberData.level = webGroupMembers[i]?.lv.level.toString();
+                    MemberMap.set(webGroupMembers[i]?.uin, MemberData);
                 }
             }
-        } else {
-            // Mlikiowa V2.0.20 Refactor Todo
-            // _groupMembers.forEach(async item => {
-            //   item.last_sent_time = parseInt((await getGroupMember(payload.group_id.toString(), item.user_id))?.lastSpeakTime || date.toString());
-            //   item.join_time = parseInt((await getGroupMember(payload.group_id.toString(), item.user_id))?.joinTime || date.toString());
-            // });
         }
-        // 还原索引到Array 一同返回
-
-        // let retData: any[] = [];
-        // for (let retMem of MemberMap.values()) {
-        //   retMem.level = TypeConvert.toString(retMem.level) as any;
-        //   retData.push(retMem)
-        // }
-
-        // _groupMembers = Array.from(retData);
         
         _groupMembers = Array.from(MemberMap.values());
         return _groupMembers;

src/onebot/action/group/GetGroupSystemMsg.ts

@@ -24,22 +24,22 @@ export class GetGroupSystemMsg extends BaseAction<void, any> {
             if (SSNotify.type == 1) {
                 retData.InvitedRequest.push({
                     request_id: SSNotify.seq,
-                    invitor_uin: await NTQQUserApi.getUinByUid(SSNotify.user1?.uid),
+                    invitor_uin: await NTQQUserApi.getUinByUidV2(SSNotify.user1?.uid),
                     invitor_nick: SSNotify.user1?.nickName,
                     group_id: SSNotify.group?.groupCode,
                     group_name: SSNotify.group?.groupName,
                     checked: SSNotify.status === 1 ? false : true,
-                    actor: await NTQQUserApi.getUinByUid(SSNotify.user2?.uid) || 0,
+                    actor: await NTQQUserApi.getUinByUidV2(SSNotify.user2?.uid) || 0,
                 });
             } else if (SSNotify.type == 7) {
                 retData.join_requests.push({
                     request_id: SSNotify.seq,
-                    requester_uin: await NTQQUserApi.getUinByUid(SSNotify.user1?.uid),
+                    requester_uin: await NTQQUserApi.getUinByUidV2(SSNotify.user1?.uid),
                     requester_nick: SSNotify.user1?.nickName,
                     group_id: SSNotify.group?.groupCode,
                     group_name: SSNotify.group?.groupName,
                     checked: SSNotify.status === 1 ? false : true,
-                    actor: await NTQQUserApi.getUinByUid(SSNotify.user2?.uid) || 0,
+                    actor: await NTQQUserApi.getUinByUidV2(SSNotify.user2?.uid) || 0,
                 });
             }
         }

src/onebot/action/group/SetGroupAdmin.ts

@@ -8,7 +8,7 @@ const SchemaData = {
     properties: {
         group_id: { type: ['number', 'string'] },
         user_id: { type: ['number', 'string'] },
-        enable: { type: 'boolean' },
+        enable: { type: ['boolean', 'string'] },
     },
     required: ['group_id', 'user_id'],
 } as const satisfies JSONSchema;
@@ -20,11 +20,12 @@ export default class SetGroupAdmin extends BaseAction<Payload, null> {
     PayloadSchema = SchemaData;
 
     async _handle(payload: Payload): Promise<null> {
+        const enable = typeof payload.enable === 'string' ? payload.enable === 'true' : !!payload.enable;
         const NTQQGroupApi = this.CoreContext.apis.GroupApi;
         const NTQQUserApi = this.CoreContext.apis.UserApi;
         const uid = await NTQQUserApi.getUidByUinV2(payload.user_id.toString());
         if (!uid) throw new Error('get Uid Error');
-        await NTQQGroupApi.setMemberRole(payload.group_id.toString(), uid, payload.enable ? GroupMemberRole.admin : GroupMemberRole.normal);
+        await NTQQGroupApi.setMemberRole(payload.group_id.toString(), uid, enable ? GroupMemberRole.admin : GroupMemberRole.normal);
         return null;
     }
 }

src/onebot/action/group/SetGroupLeave.ts

@@ -6,7 +6,7 @@ const SchemaData = {
     type: 'object',
     properties: {
         group_id: { type: ['number', 'string'] },
-        is_dismiss: { type: 'boolean' },
+        is_dismiss: { type: ['boolean', 'string'] },
     },
     required: ['group_id'],
 } as const satisfies JSONSchema;

src/onebot/action/index.ts

@@ -78,6 +78,7 @@ import { NapCatCore } from '@/core';
 import { NapCatOneBot11Adapter } from '@/onebot';
 import GetGuildProfile from './guild/GetGuildProfile';
 import SetModelShow from './go-cqhttp/SetModelShow';
+import { SetInputStatus } from './extends/SetInputStatus';
 
 export type ActionMap = Map<string, BaseAction<any, any>>;
 
@@ -165,6 +166,7 @@ export function createActionMap(onebotContext: NapCatOneBot11Adapter, coreContex
         new GoCQHTTPUploadPrivateFile(onebotContext, coreContext),
         new GetGuildProfile(onebotContext, coreContext),
         new SetModelShow(onebotContext, coreContext),
+        new SetInputStatus(onebotContext, coreContext),
     ];
     const actionMap = new Map();
     for (const action of actionHandlers) {

src/onebot/action/msg/ForwardSingleMsg.ts

@@ -7,7 +7,7 @@ import { MessageUnique } from '@/common/utils/MessageUnique';
 const SchemaData = {
     type: 'object',
     properties: {
-        message_id: { type: 'number' },
+        message_id: { type: ['number', 'string'] },
         group_id: { type: ['number', 'string'] },
         user_id: { type: ['number', 'string'] },
     },
@@ -31,7 +31,7 @@ class ForwardSingleMsg extends BaseAction<Payload, null> {
 
     async _handle(payload: Payload): Promise<null> {
         const NTQQMsgApi = this.CoreContext.apis.MsgApi;
-        const msg = MessageUnique.getMsgIdAndPeerByShortId(payload.message_id);
+        const msg = MessageUnique.getMsgIdAndPeerByShortId(parseInt(payload.message_id.toString()));
         if (!msg) {
             throw new Error(`无法找到消息${payload.message_id}`);
         }

src/onebot/action/msg/SendMsg/create-send-elements.ts

@@ -56,7 +56,7 @@ const _handlers: {
         if (atQQ === 'all') return SendMsgElementConstructor.at(coreContext, atQQ, atQQ, AtType.atAll, '全体成员');
 
         // then the qq is a group member
-        // Mlikiowa V2.0.19 Refactor Todo
+        // Mlikiowa V2.0.32 Refactor Todo
         const uid = await coreContext.apis.UserApi.getUidByUinV2(`${atQQ}`);
         if (!uid) throw new Error('Get Uid Error');
         return SendMsgElementConstructor.at(coreContext, atQQ, uid, AtType.atUser, '');
@@ -161,7 +161,7 @@ const _handlers: {
         } else {
             postData = data;
         }
-        // Mlikiowa V2.0.19 Refactor Todo
+        // Mlikiowa V2.0.32 Refactor Todo
         const signUrl = obContext.configLoader.configData.musicSignUrl;
         if (!signUrl) {
             if (data.type === 'qq') {

src/onebot/action/msg/SendMsg/index.ts

@@ -88,11 +88,9 @@ async function createContext(coreContext: NapCatCore, payload: OB11PostSendMsg,
     // This function determines the type of message by the existence of user_id / group_id,
     // not message_type.
     // This redundant design of Ob11 here should be blamed.
-    const NTQQGroupApi = coreContext.apis.GroupApi;
     const NTQQFriendApi = coreContext.apis.FriendApi;
     const NTQQUserApi = coreContext.apis.UserApi;
     if ((contextMode === ContextMode.Group || contextMode === ContextMode.Normal) && payload.group_id) {
-        const group = (await NTQQGroupApi.getGroups()).find(e => e.groupCode == payload.group_id?.toString());
         return {
             chatType: ChatType.group,
             peerUid: payload.group_id.toString(),
@@ -134,26 +132,22 @@ export class SendMsg extends BaseAction<OB11PostSendMsg, ReturnDataType> {
                 message: '转发消息不能和普通消息混在一起发送,转发需要保证message只有type为node的元素',
             };
         }
-        // if (payload.message_type !== 'private' && payload.group_id && !(await getGroup(payload.group_id))) {
-        //   return { valid: false, message: `群${payload.group_id}不存在` };
-        // }
         if (payload.user_id && payload.message_type !== 'group') {
             const uid = await NTQQUserApi.getUidByUinV2(payload.user_id.toString());
             const isBuddy = await NTQQFriendApi.isBuddy(uid!);
-            // 此处有问题
-            if (!isBuddy) {
-                //return { valid: false, message: '异常消息' };
-            }
+            if (!isBuddy) {}
         }
         return { valid: true };
     }
 
     async _handle(payload: OB11PostSendMsg): Promise<{ message_id: number }> {
+        if (payload.message_type === 'group') this.contextMode = ContextMode.Group;
+        if (payload.message_type === 'private') this.contextMode = ContextMode.Private;
         const peer = await createContext(this.CoreContext, payload, this.contextMode);
 
         const messages = normalize(
             payload.message,
-            payload.auto_escape === true || payload.auto_escape === 'true',
+            typeof payload.auto_escape === 'string' ? payload.auto_escape === 'true' : !!payload.auto_escape
         );
 
         if (getSpecialMsgNum(payload, OB11MessageDataType.node)) {

src/onebot/action/types.ts

@@ -106,5 +106,6 @@ export enum ActionName {
     TestApi01 = 'test_api_01',
     FetchEmojiLike = 'fetch_emoji_like',
     GetGuildProfile = "get_guild_service_profile",
-    SetModelShow = "_set_model_show"
+    SetModelShow = "_set_model_show",
+    SetInputStatus = "set_input_status"
 }

src/onebot/action/user/GetFriendList.ts

@@ -20,6 +20,6 @@ export default class GetFriendList extends BaseAction<Payload, OB11User[]> {
     async _handle(payload: Payload) {
         //全新逻辑
         const NTQQFriendApi = this.CoreContext.apis.FriendApi;
-        return OB11Constructor.friendsV2(await NTQQFriendApi.getBuddyV2(payload?.no_cache === true || payload?.no_cache === 'true'));
+        return OB11Constructor.friendsV2(await NTQQFriendApi.getBuddyV2(typeof payload.no_cache === 'string' ? payload.no_cache === 'true' : !!payload.no_cache));
     }
 }

src/onebot/event/notice/OB11InputStatusEvent.ts

@@ -6,14 +6,14 @@ export class OB11InputStatusEvent extends OB11BaseNoticeEvent {
     notice_type = 'notify';
     sub_type = 'input_status';
     status_text = '对方正在输入...';
-    eventType = 1;
+    event_type = 1;
     user_id = 0;
     group_id = 0;
 
     constructor(core: NapCatCore, user_id: number, eventType: number, status_text: string) {
         super(core);
         this.user_id = user_id;
-        this.eventType = eventType;
+        this.event_type = eventType;
         this.status_text = status_text;
     }
 }

src/onebot/helper/data.ts

@@ -15,9 +15,9 @@ import {
     FaceIndex,
     Friend,
     FriendV2,
-    GrayTipElementSubType,
     Group,
     GroupMember,
+    NTGrayTipElementSubTypeV2,
     Peer,
     RawMessage,
     SelfInfo,
@@ -119,7 +119,7 @@ export class OB11Constructor {
                     const { atNtUid, content } = element.textElement;
                     let atQQ = element.textElement.atUid;
                     if (!atQQ || atQQ === '0') {
-                        atQQ = await NTQQUserApi.getUinByUid(atNtUid);
+                        atQQ = await NTQQUserApi.getUinByUidV2(atNtUid);
                     }
                     if (atQQ) {
                         qq = atQQ as `${number}`;
@@ -149,6 +149,7 @@ export class OB11Constructor {
                 message_data['type'] = OB11MessageDataType.reply;
                 //log("收到回复消息", element.replyElement);
                 try {
+                    let oldMsgFlag = false;
                     const records = msg.records.find(msgRecord => msgRecord.msgId === element?.replyElement?.sourceMsgIdInRecords);
                     const peer = {
                         chatType: msg.chatType,
@@ -161,14 +162,15 @@ export class OB11Constructor {
                         peerUid: msg.peerUid,
                         guildId: '',
                         chatType: msg.chatType,
-                    }, element.replyElement.replayMsgSeq, 1, true, true)).msgList[0];
+                    }, element.replyElement.replayMsgSeq, 1, true, true)).msgList.find(msg => msg.msgRandom === records.msgRandom);
                     if (!replyMsg || records.msgRandom !== replyMsg.msgRandom) {
+                        if (!replyMsg && records.msgRandom === '0') oldMsgFlag = true;
                         replyMsg = (await NTQQMsgApi.getSingleMsg(peer, element.replyElement.replayMsgSeq)).msgList[0];
                     }
                     if (msg.peerUin == '284840486') {
                         //合并消息内侧 消息具体定位不到
                     }
-                    if ((!replyMsg || records.msgRandom !== replyMsg.msgRandom) && msg.peerUin !== '284840486') {
+                    if ((!replyMsg || (records.msgRandom !== replyMsg.msgRandom && !oldMsgFlag || (oldMsgFlag && records.msgSeq !== replyMsg.msgSeq))) && msg.peerUin !== '284840486') {
                         throw new Error('回复消息消息验证失败');
                     }
                     message_data['data']['id'] = MessageUnique.createMsg({
@@ -286,13 +288,13 @@ export class OB11Constructor {
                     chatType: msg.chatType,
                     guildId: '',
                 },
-                msg.msgId,
-                msg.msgSeq,
-                msg.senderUid,
-                element.elementId,
-                element.elementType.toString(),
-                element.pttElement.fileSize || '0',
-                element.pttElement.fileUuid || '',
+                    msg.msgId,
+                    msg.msgSeq,
+                    msg.senderUid,
+                    element.elementId,
+                    element.elementType.toString(),
+                    element.pttElement.fileSize || '0',
+                    element.pttElement.fileUuid || '',
                 );
                 //以uuid作为文件名
             } else if (element.arkElement) {
@@ -377,7 +379,7 @@ export class OB11Constructor {
         }
         for (const element of msg.elements) {
             if (element.grayTipElement) {
-                if (element.grayTipElement.subElementType == GrayTipElementSubType.MEMBER_NEW_TITLE) {
+                if (element.grayTipElement.subElementType == NTGrayTipElementSubTypeV2.GRAYTIP_ELEMENT_SUBTYPE_JSON) {
                     const json = JSON.parse(element.grayTipElement.jsonGrayTipElement.jsonStr);
 
                     if (element.grayTipElement.jsonGrayTipElement.busiId == 1061) {
@@ -398,7 +400,7 @@ export class OB11Constructor {
                     }
                     //下面得改 上面也是错的grayTipElement.subElementType == GrayTipElementSubType.MEMBER_NEW_TITLE
                 }
-                if (element.grayTipElement.subElementType == GrayTipElementSubType.INVITE_NEW_MEMBER) {
+                if (element.grayTipElement.subElementType == NTGrayTipElementSubTypeV2.GRAYTIP_ELEMENT_SUBTYPE_XMLMSG) {
                     //好友添加成功事件
                     if (element.grayTipElement.xmlElement.templId === '10229' && msg.peerUin !== '') {
                         return new OB11FriendAddNoticeEvent(core, parseInt(msg.peerUin));
@@ -417,7 +419,7 @@ export class OB11Constructor {
             return;
         }
         //log("group msg", msg);
-        // Mlikiowa V2.0.20 Refactor Todo
+        // Mlikiowa V2.0.32 Refactor Todo
         // if (msg.senderUin && msg.senderUin !== '0') {
         //   const member = await getGroupMember(msg.peerUid, msg.senderUin);
         //   if (member && member.cardName !== msg.sendMemberName) {
@@ -530,18 +532,18 @@ export class OB11Constructor {
                         const senderUin = emojiLikeData.gtip.qq.jp;
                         const msgSeq = emojiLikeData.gtip.url.msgseq;
                         const emojiId = emojiLikeData.gtip.face.id;
-
-                        const replyMsgList = (await NTQQMsgApi.getMsgsBySeqAndCount({
+                        const peer = {
                             chatType: ChatType.group,
                             guildId: '',
-                            peerUid: msg.peerUid,
-                        }, msgSeq, 1, true, true)).msgList;
+                            peerUid: msg.peerUid
+                        }
+                        const replyMsgList = (await NTQQMsgApi.getMsgExBySeq(peer, msgSeq)).msgList;
                         if (replyMsgList.length < 1) {
                             return;
                         }
-
-                        const replyMsg = replyMsgList[0];
-                        console.log('表情回应消息', msgSeq, ' 结算ID', replyMsg.msgId);
+                        const replyMsg = replyMsgList.filter(e => e.msgSeq == msgSeq).sort((a, b) => parseInt(a.msgTime) - parseInt(b.msgTime))[0];
+                        //console.log("表情回应消息长度检测", msgSeq, replyMsg.elements);
+                        if (!replyMsg) throw new Error('找不到回应消息');
                         return new OB11GroupMsgEmojiLikeEvent(
                             core,
                             parseInt(msg.peerUid),
@@ -556,7 +558,7 @@ export class OB11Constructor {
                         logger.logError('解析表情回应消息失败', e.stack);
                     }
                 }
-                if (grayTipElement.subElementType == GrayTipElementSubType.INVITE_NEW_MEMBER) {
+                if (grayTipElement.subElementType == NTGrayTipElementSubTypeV2.GRAYTIP_ELEMENT_SUBTYPE_XMLMSG) {
                     logger.logDebug('收到新人被邀请进群消息', grayTipElement);
                     const xmlElement = grayTipElement.xmlElement;
                     if (xmlElement?.content) {
@@ -582,7 +584,7 @@ export class OB11Constructor {
                     }
                 }
                 //代码歧义 GrayTipElementSubType.MEMBER_NEW_TITLE
-                else if (grayTipElement.subElementType == GrayTipElementSubType.MEMBER_NEW_TITLE) {
+                else if (grayTipElement.subElementType == NTGrayTipElementSubTypeV2.GRAYTIP_ELEMENT_SUBTYPE_JSON) {
                     const json = JSON.parse(grayTipElement.jsonGrayTipElement.jsonStr);
                     if (grayTipElement.jsonGrayTipElement.busiId == 1061) {
                         //判断业务类型
@@ -709,7 +711,7 @@ export class OB11Constructor {
             nickname: member.nick,
             card: member.cardName,
             sex: OB11Constructor.sex(member.sex!),
-            age: 0,
+            age: member.age ?? 0,
             area: '',
             level: '0',
             qq_level: member.qqLevel && calcQQLevel(member.qqLevel) || 0,

src/onebot/helper/msg.ts

@@ -18,10 +18,11 @@ import {
     SendVideoElement,
     viedo_type,
 } from '@/core';
+import * as fsnormal from 'node:fs';
 import { promises as fs } from 'node:fs';
 import ffmpeg from 'fluent-ffmpeg';
 import { calculateFileMD5, isGIF } from '@/common/utils/file';
-import { getVideoInfo } from '@/common/utils/video';
+import { defaultVideoThumbB64, getVideoInfo } from '@/common/utils/video';
 import { encodeSilk } from '@/common/utils/audio';
 import faceConfig from '@/core/external/face_config.json';
 import * as pathLib from 'node:path';
@@ -140,11 +141,7 @@ export class SendMsgElementConstructor {
     }
 
     static async video(coreContext: NapCatCore, filePath: string, fileName: string = '', diyThumbPath: string = '', videotype: viedo_type = viedo_type.VIDEO_FORMAT_MP4): Promise<SendVideoElement> {
-        const NTQQGroupApi = coreContext.apis.GroupApi;
-        const NTQQUserApi = coreContext.apis.UserApi;
         const NTQQFileApi = coreContext.apis.FileApi;
-        const NTQQMsgApi = coreContext.apis.MsgApi;
-        const NTQQFriendApi = coreContext.apis.FriendApi;
         const logger = coreContext.context.logger;
         const { fileName: _fileName, path, fileSize, md5 } = await NTQQFileApi.uploadFile(filePath, ElementType.VIDEO);
         if (fileSize === 0) {
@@ -179,7 +176,8 @@ export class SendMsgElementConstructor {
                             resolve(thumbPath);
                         }).catch(reject);
                     } else {
-                        resolve(undefined);
+                        fsnormal.writeFileSync(thumbPath, Buffer.from(defaultVideoThumbB64, 'base64'));
+                        resolve(thumbPath);
                     }
                 })
                 .screenshots({
@@ -224,6 +222,21 @@ export class SendMsgElementConstructor {
                 // sourceVideoCodecFormat: 2
             },
         };
+        // "fileElement": {
+        //     "fileMd5": "",
+        //     "fileName": "1.mp4",
+        //     "filePath": "C:\\Users\\nanae\\OneDrive\\Desktop\\1.mp4",
+        //     "fileSize": "1847007",
+        //     "picHeight": 1280,
+        //     "picWidth": 720,
+        //     "picThumbPath": {},
+        //     "file10MMd5": "",
+        //     "fileSha": "",
+        //     "fileSha3": "",
+        //     "fileUuid": "",
+        //     "fileSubId": "",
+        //     "thumbFileSize": 750
+        //   }
         return element;
     }
 

src/onebot/index.ts

@@ -8,6 +8,7 @@ import {
     MsgListener,
     NapCatCore,
     RawMessage,
+    SendStatusType,
 } from '@/core';
 import { OB11Config, OB11ConfigLoader } from '@/onebot/helper/config';
 import { OneBotApiContextType } from '@/onebot/types';
@@ -250,7 +251,7 @@ export class NapCatOneBot11Adapter {
                 .catch(e => this.context.logger.logError('处理消息失败', e));
 
             for (const msg of msgList.filter(e => e.senderUin == this.core.selfInfo.uin)) {
-                if (msg.sendStatus == 2 && !msgIdSend.get(msg.msgId)) {
+                if (msg.sendStatus == SendStatusType.KSEND_STATUS_SUCCESS && !msgIdSend.get(msg.msgId)) {
                     msgIdSend.put(msg.msgId, true);
                     // 完成后再post
                     OB11Constructor.message(this.core, this, msg)
@@ -290,8 +291,8 @@ export class NapCatOneBot11Adapter {
                     await this.networkManager.emitEvent(new OB11FriendRequestEvent(
                         this.core,
                         parseInt(requesterUin!),
-                        req.friendUid + '|' + req.reqTime,
                         req.extWords,
+                        req.friendUid + '|' + req.reqTime,
                     ));
                 } catch (e) {
                     this.context.logger.logDebug('获取加好友者QQ号失败', e);
@@ -325,11 +326,6 @@ export class NapCatOneBot11Adapter {
                     const flag = notify.group.groupCode + '|' + notify.seq + '|' + notify.type;
                     this.context.logger.logDebug('收到群通知', notify);
 
-                    // let member2: GroupMember;
-                    // if (notify.user2.uid) {
-                    //     member2 = await getGroupMember(notify.group.groupCode, null, notify.user2.uid);
-                    // }
-
                     if ([
                         GroupNotifyTypes.ADMIN_SET,
                         GroupNotifyTypes.ADMIN_UNSET,
@@ -400,12 +396,12 @@ export class NapCatOneBot11Adapter {
                         } catch (e) {
                             this.context.logger.logError('获取加群人QQ号失败 Uid:', notify.user1.uid, e);
                         }
-                    } else if (notify.type == GroupNotifyTypes.INVITE_ME) {
+                    } else if (notify.type == GroupNotifyTypes.INVITE_ME && notify.status == 1) {
                         this.context.logger.logDebug(`收到邀请我加群通知:${notify}`);
                         const groupInviteEvent = new OB11GroupRequestEvent(
                             this.core,
                             parseInt(notify.group.groupCode),
-                            parseInt(notify.user1.uid),
+                            parseInt(await this.core.apis.UserApi.getUinByUidV2(notify.user2.uid)),
                             'invite',
                             notify.postscript,
                             flag,

src/onebot/network/active-http.ts

@@ -44,14 +44,16 @@ export class OB11ActiveHttpAdapter implements IOB11NetworkAdapter {
                 resJson = await res.json();
                 //logDebug('新消息事件HTTP上报返回快速操作: ', JSON.stringify(resJson));
             } catch (e) {
-                this.logger.logDebug('新消息事件HTTP上报没有返回快速操作，不需要处理');
+                this.logger.logDebug('[OneBot] [Http Client] 新消息事件HTTP上报没有返回快速操作，不需要处理');
                 return;
             }
             try {
                 handleQuickOperation(this.coreContext, this.obContext, event as QuickActionEvent, resJson).then().catch(this.logger.logError);
             } catch (e: any) {
-                this.logger.logError('新消息事件HTTP上报返回快速操作失败', e);
+                this.logger.logError('[OneBot] [Http Client] 新消息事件HTTP上报返回快速操作失败', e);
             }
+        }).catch((e) => {
+            this.logger.logError('[OneBot] [Http Client] 新消息事件HTTP上报失败', e);
         });
     }
 

src/onebot/network/active-websocket.ts

@@ -135,6 +135,7 @@ export class OB11ActiveWebSocketAdapter implements IOB11NetworkAdapter {
             const packet = Object.assign({}, retdata);
             this.checkStateAndReply<any>(packet);
         } catch (e) {
+            this.logger.logError('[OneBot] [WebSocket Client] 发生错误', e);
             this.checkStateAndReply<any>(OB11Response.error('不支持的api ' + receiveData.action, 1404, echo));
         }
     }

src/onebot/network/passive-http.ts

@@ -4,6 +4,7 @@ import http from 'http';
 import { NapCatCore } from '@/core';
 import { OB11Response } from '../action/OB11Response';
 import { ActionMap } from '@/onebot/action';
+import cors from 'cors';
 
 export class OB11PassiveHttpAdapter implements IOB11NetworkAdapter {
     private app: Express | undefined;
@@ -43,13 +44,24 @@ export class OB11PassiveHttpAdapter implements IOB11NetworkAdapter {
         this.server?.close();
         this.app = undefined;
     }
-
     private initializeServer() {
         this.app = express();
         this.server = http.createServer(this.app);
 
-        this.app.use(express.json());
-        this.app.use(express.urlencoded({ extended: false }));
+        this.app.use(cors());
+        this.app.use(express.urlencoded({ extended: true, limit: '5000mb' }));
+        this.app.use((req, res, next) => {
+            // 兼容处理没有带content-type的请求
+            req.headers['content-type'] = 'application/json';
+            const originalJson = express.json({ limit: '5000mb' });
+            originalJson(req, res, (err) => {
+                if (err) {
+                    return res.status(400).send('Invalid JSON');
+                }
+                next();
+            });
+        });
+
         this.app.use((req, res, next) => this.authorize(this.token, req, res, next));
         this.app.use((req, res) => this.handleRequest(req, res));
 

src/webui/ui/NapCat.ts

@@ -30,7 +30,7 @@ async function onSettingWindowCreated(view: Element) {
                 SettingItem(
                     '<span id="napcat-update-title">Napcat</span>',
                     undefined,
-                    SettingButton('V2.0.20', 'napcat-update-button', 'secondary'),
+                    SettingButton('V2.0.32', 'napcat-update-button', 'secondary'),
                 ),
             ]),
             SettingList([

static/assets/renderer.js

@@ -164,7 +164,7 @@ async function onSettingWindowCreated(view) {
         SettingItem(
           '<span id="napcat-update-title">Napcat</span>',
           void 0,
-          SettingButton("V2.0.20", "napcat-update-button", "secondary")
+          SettingButton("V2.0.32", "napcat-update-button", "secondary")
         )
       ]),
       SettingList([