Northern_Lights/NapCatQQ
1
0
Fork 0
mirror of https://github.com/NapNeko/NapCatQQ.git synced 2026-02-06 13:05:09 +00:00
Code Issues Actions 8 Packages Projects Releases Wiki Activity

fix

Browse Source
This commit is contained in:
手瓜一十雪
2024-04-24 12:13:34 +08:00
parent 8bfb27f165
commit 467030affb
91 changed files with 16295 additions and 127 deletions
Download Patch File Download Diff File Expand all files Collapse all files

38
src/onebot11/action/go-cqhttp/GetFriendMsgHistory.ts
View File

@@ -19,25 +19,25 @@ interface Response {
}
export default class GetFriendMsgHistory extends BaseAction<Payload, Response> {
actionName = ActionName.GetFriendMsgHistory;
actionName = ActionName.GetFriendMsgHistory;
protected async _handle(payload: Payload): Promise<Response> {
let uid = getUidByUin(payload.user_id.toString())
if (!uid) {
throw `记录${payload.user_id}不存在`;
}
const startMsgId = (await dbUtil.getMsgByShortId(payload.message_seq))?.msgId || '0';
let friend = await getFriend(uid);
let historyResult = (await NTQQMsgApi.getMsgHistory({
chatType: friend ? ChatType.friend : ChatType.temp,
peerUid: uid
}, startMsgId, parseInt(payload.count?.toString()) || 20));
console.log(historyResult);
const msgList = historyResult.msgList;
await Promise.all(msgList.map(async msg => {
msg.id = await dbUtil.addMsg(msg);
}));
const ob11MsgList = await Promise.all(msgList.map(msg => OB11Constructor.message(msg)));
return { 'messages': ob11MsgList };
protected async _handle(payload: Payload): Promise<Response> {
const uid = getUidByUin(payload.user_id.toString());
if (!uid) {
throw `记录${payload.user_id}不存在`;
}
const startMsgId = (await dbUtil.getMsgByShortId(payload.message_seq))?.msgId || '0';
const friend = await getFriend(uid);
const historyResult = (await NTQQMsgApi.getMsgHistory({
chatType: friend ? ChatType.friend : ChatType.temp,
peerUid: uid
}, startMsgId, parseInt(payload.count?.toString()) || 20));
console.log(historyResult);
const msgList = historyResult.msgList;
await Promise.all(msgList.map(async msg => {
msg.id = await dbUtil.addMsg(msg);
}));
const ob11MsgList = await Promise.all(msgList.map(msg => OB11Constructor.message(msg)));
return { 'messages': ob11MsgList };
}
}

8
src/onebot11/action/msg/MarkMsgAsRead.ts
View File

@@ -13,18 +13,18 @@ class MarkMsgAsRead extends BaseAction<Payload, null> {
protected async _handle(payload: Payload): Promise<null> {
let uid: string | undefined = payload.uin;
if (this.ReqChatType != ChatType.group) {
uid = getUidByUin(payload.uin.toString())
uid = getUidByUin(payload.uin.toString());
if (!uid) {
throw `记录${payload.uin}不存在`;
}
let friend = await getFriend(uid);
const friend = await getFriend(uid);
this.ReqChatType = friend ? ChatType.friend : ChatType.temp;//重写
}
// 获取UID 组装Peer
// GuildId: string 留空
let ReqPeer: Peer = { chatType: this.ReqChatType, peerUid: uid, guildId: "" };
const ReqPeer: Peer = { chatType: this.ReqChatType, peerUid: uid, guildId: '' };
// 调用API
let ret = await NTQQMsgApi.setMsgRead(ReqPeer);
const ret = await NTQQMsgApi.setMsgRead(ReqPeer);
if (ret.result != 0) {
throw ('设置已读失败');
}