为 MessageBean 添加 chat_id 字段?
* 不知道有没有用, 有可能会被移除 * 有可能是史山
This commit is contained in:
@@ -62,17 +62,22 @@ export default class ChatApi extends BaseApi {
|
|||||||
const userInst = User.findById(id)
|
const userInst = User.findById(id)
|
||||||
userInst?.updateRecentChat(chat.bean.id, args.text as string)
|
userInst?.updateRecentChat(chat.bean.id, args.text as string)
|
||||||
})
|
})
|
||||||
|
const m = {
|
||||||
|
...msg,
|
||||||
|
id,
|
||||||
|
chat_id: chat.bean.id,
|
||||||
|
}
|
||||||
this.boardcastToUsers(users, 'Client.onMessage', {
|
this.boardcastToUsers(users, 'Client.onMessage', {
|
||||||
chat: chat.bean.id,
|
chat: chat.bean.id,
|
||||||
msg: {
|
msg: m
|
||||||
...msg,
|
|
||||||
id
|
|
||||||
}
|
|
||||||
})
|
})
|
||||||
|
|
||||||
return {
|
return {
|
||||||
code: 200,
|
code: 200,
|
||||||
msg: "成功",
|
msg: "成功",
|
||||||
|
data: {
|
||||||
|
msg: m,
|
||||||
|
}
|
||||||
}
|
}
|
||||||
})
|
})
|
||||||
/**
|
/**
|
||||||
|
|||||||
@@ -2,6 +2,7 @@ export default class MessageBean {
|
|||||||
declare id: number
|
declare id: number
|
||||||
declare text: string
|
declare text: string
|
||||||
declare user_id?: string
|
declare user_id?: string
|
||||||
|
declare chat_id?: string
|
||||||
declare time: string
|
declare time: string
|
||||||
|
|
||||||
[key: string]: unknown
|
[key: string]: unknown
|
||||||
|
|||||||
@@ -60,7 +60,11 @@ export default class MessagesManager {
|
|||||||
})
|
})
|
||||||
}
|
}
|
||||||
getMessages(limit: number = 15, offset: number = 0) {
|
getMessages(limit: number = 15, offset: number = 0) {
|
||||||
return MessagesManager.database.prepare(`SELECT * FROM ${this.getTableName()} ORDER BY id DESC LIMIT ? OFFSET ?;`).all(limit, offset) as unknown as MessageBean[]
|
const ls = MessagesManager.database.prepare(`SELECT * FROM ${this.getTableName()} ORDER BY id DESC LIMIT ? OFFSET ?;`).all(limit, offset) as unknown as MessageBean[]
|
||||||
|
return ls.map((v) => ({
|
||||||
|
...v,
|
||||||
|
chat_id: this.chat.bean.id,
|
||||||
|
}))
|
||||||
}
|
}
|
||||||
getMessagesWithPage(limit: number = 15, page: number = 0) {
|
getMessagesWithPage(limit: number = 15, page: number = 0) {
|
||||||
return this.getMessages(limit, limit * page)
|
return this.getMessages(limit, limit * page)
|
||||||
|
|||||||
Reference in New Issue
Block a user