|
@@ -80,14 +80,19 @@ func (m *cChatHistroy) Save(ctx context.Context, msgs ...*ChatRecord) (id int64)
|
|
|
|
|
|
// GetMessage 查询聊天信息
|
|
|
func (m *cChatHistroy) GetMessage(userId int64, pageNum, pageSize int, prevId string) (h []ResHistory, err error) {
|
|
|
+ var hTmp []ResHistory
|
|
|
if prevId != "" {
|
|
|
- err = g.Model("ai_message_history").Where("person_id = ? and id > ? ", userId, prevId).OrderDesc("id").Limit(0, pageSize).Scan(&h)
|
|
|
+ err = g.Model("ai_message_history").Where("person_id = ? and id < ? ", userId, prevId).OrderDesc("id").Limit(pageNum*pageSize, (pageNum+1)*pageSize).Scan(&hTmp)
|
|
|
} else {
|
|
|
- err = g.Model("ai_message_history").Where("person_id = ?", userId).OrderDesc("create_time").OrderDesc("id").Limit(pageNum*pageSize, (pageNum+1)*pageSize).Scan(&h)
|
|
|
+ err = g.Model("ai_message_history").Where("person_id = ?", userId).OrderDesc("id").Limit(pageNum*pageSize, (pageNum+1)*pageSize).Scan(&hTmp)
|
|
|
}
|
|
|
if err != nil {
|
|
|
return
|
|
|
}
|
|
|
+ //翻转查询结果
|
|
|
+ for i := len(hTmp) - 1; i > 0; i-- {
|
|
|
+ h = append(h, hTmp[i])
|
|
|
+ }
|
|
|
return
|
|
|
}
|
|
|
|