aiChat/internal/controller/chatHistory.go

package controller

import (
	v1 "aiChat/api/v1"
	"aiChat/internal/model"
	"app.yhyue.com/moapp/jybase/encrypt"
	"context"
	"fmt"
	"github.com/gogf/gf/v2/os/glog"
)

var (
	ChatHistory = cChatHistory{}
)

type cChatHistory struct{}

// Method 获取聊天记录
func (c *cChatHistory) Method(ctx context.Context, req *v1.ChatHistoryReq) (res *v1.ChatHistoryRes, err error) {
	session := model.SessionCtx.Get(ctx).JSession
	if session.AccountId <= 0 {
		return nil, fmt.Errorf("无用户身份")
	}
	res = &v1.ChatHistoryRes{}
	if req.PrevId != "" {
		req.PrevId = encrypt.SE.Decode4Hex(req.PrevId) //id解密
	}
	history, err := model.ChatHistroy.GetMessage(model.SessionCtx.Get(ctx).JSession.AccountId, req.PageNum, req.PageSize, req.PrevId)
	if err != nil {
		glog.Error(ctx, "%d查询聊天记录异常,error:%s", model.SessionCtx.Get(ctx).JSession.AccountId, err)
		res.ErrorCode = -1
		res.ErrorMsg = "数据查询异常"
		return
	}
	for _, v := range history {
		res.Data = append(res.Data, v1.History{
			Id:         encrypt.SE.Encode2Hex(v.Id),
			Content:    v.Content,
			Type:       v.Type,
			Useful:     v.Useful,
			CreateTime: v.CreateTime.Unix(),
		})
	}
	return
}