GuanM/NapCatQQ
1
0
Fork 0
mirror of https://github.com/NapNeko/NapCatQQ.git synced 2024-11-21 09:36:35 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

fix

Browse Source
This commit is contained in:
手瓜一十雪 2024-04-16 18:32:02 +08:00
parent f6bc8f0a1f
commit 7449ce9c3b
1 changed files with 7 additions and 17 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -1,6 +1,6 @@
import BaseAction from '../BaseAction'; import BaseAction from '../BaseAction';
import { OB11Message, OB11User } from '../../types'; import { OB11Message, OB11User } from '../../types';
import { getFriend, friends, uid2UinMap } from '@/common/data'; import { getFriend, friends, uid2UinMap, getUidByUin } from '@/common/data';
import { ActionName } from '../types'; import { ActionName } from '../types';
import { ChatType } from '@/core/qqnt/entities'; import { ChatType } from '@/core/qqnt/entities';
import { dbUtil } from '@/common/utils/db'; import { dbUtil } from '@/common/utils/db';
@ -21,26 +21,16 @@ interface Response {
export default class GetFriendMsgHistory extends BaseAction<Payload, Response> { export default class GetFriendMsgHistory extends BaseAction<Payload, Response> {
actionName = ActionName.GoCQHTTP_GetGroupMsgHistory; actionName = ActionName.GoCQHTTP_GetGroupMsgHistory;
protected async _handle(payload: Payload): Promise<Response> { protected async _handle(payload: Payload): Promise<Response> {
if (!uid2UinMap?.[payload.user_id]) { let uin = getUidByUin(payload.user_id.toString())
if (!uin) {
throw `记录${payload.user_id}不存在`; throw `记录${payload.user_id}不存在`;
} }
const startMsgId = (await dbUtil.getMsgByShortId(payload.message_seq))?.msgId || '0'; const startMsgId = (await dbUtil.getMsgByShortId(payload.message_seq))?.msgId || '0';
// log("startMsgId", startMsgId)
let friend = await getFriend(uid2UinMap?.[payload.user_id].toString()) let friend = await getFriend(uid2UinMap?.[payload.user_id].toString())
let historyResult = undefined; let historyResult = (await NTQQMsgApi.getMsgHistory({
if (friend) { chatType: friend ? ChatType.friend : ChatType.temp,
historyResult = (await NTQQMsgApi.getMsgHistory({ peerUid: uin
chatType: ChatType.friend,
peerUid: uid2UinMap?.[payload.user_id]
}, startMsgId, parseInt(payload.count?.toString()) || 20)); }, startMsgId, parseInt(payload.count?.toString()) || 20));
} else {
historyResult = (await NTQQMsgApi.getMsgHistory({
chatType: ChatType.temp,
peerUid: uid2UinMap?.[payload.user_id]
}, startMsgId, parseInt(payload.count?.toString()) || 20));
}
console.log(historyResult); console.log(historyResult);
const msgList = historyResult.msgList; const msgList = historyResult.msgList;
await Promise.all(msgList.map(async msg => { await Promise.all(msgList.map(async msg => {