eta_api/controllers/ai/ai.go

package ai

import (
	"encoding/json"
	"eta_gn/eta_api/controllers"
	"eta_gn/eta_api/models"
	"eta_gn/eta_api/models/aimod"
	"eta_gn/eta_api/services/aiser"
	"eta_gn/eta_api/utils"
	"fmt"
	"strconv"
	"time"
)

type AiController struct {
	controllers.BaseAuthController
}

// @router /chat [post]
func (this *AiController) List() {
	br := new(models.BaseResponse).Init()
	defer func() {
		this.Data["json"] = br
		this.ServeJSON()
	}()

	var req aimod.ChatReq
	err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
	if err != nil {
		br.Msg = "参数解析异常！"
		br.ErrMsg = "参数解析失败，Err:" + err.Error()
		return
	}

	if req.Ask == "" {
		br.Msg = "请输入提问内容！"
		br.ErrMsg = "请输入提问内容"
		return
	}

	if utils.Re == nil {
		key := "CACHE_CHAT_" + strconv.Itoa(this.SysUser.AdminId)
		cacheVal, err := utils.Rc.RedisInt(key)
		fmt.Println("RedisString:", cacheVal, "err:", err)
		if err != nil && (err.Error() != "redigo: nil returned" && err.Error() != "redis: nil") {
			br.Msg = "获取数据失败！"
			br.ErrMsg = "获取数据失败，Err:" + err.Error()
			return
		}
		putVal := 0
		if cacheVal <= 0 {
			putVal = utils.AiChatLimit
		} else {
			putVal = cacheVal - 1
		}

		if putVal <= 0 {
			br.Msg = "您今日" + strconv.Itoa(utils.AiChatLimit) + "次问答已达上限，请明天再来！"
			br.ErrMsg = "您今日" + strconv.Itoa(utils.AiChatLimit) + "次问答已达上限，请明天再来！"
			return
		}
		lastSecond := utils.GetTodayLastSecond()
		utils.Rc.Put(key, putVal, lastSecond)
	}

	askUuid := utils.MD5(req.Ask)
	chatMode, err := aimod.GetAiChatByAsk(askUuid)
	if err != nil && !utils.IsErrNoRow(err) {
		br.Msg = "获取数据失败！"
		br.ErrMsg = "获取数据失败,GetAiChatByAsk，Err:" + err.Error()
		return
	}
	resp := new(aimod.ChatResp)
	var answer string

	if chatMode != nil && chatMode.Answer != "" {
		answer = chatMode.Answer
	} else {
		historyList, err := aimod.GetAiChatList(req.AiChatTopicId)
		if err != nil && !utils.IsErrNoRow(err) {
			br.Msg = "获取主题历史数据失败！"
			br.ErrMsg = "获取主题历史数据失败，Err:" + err.Error()
			return
		}

		historyChatList := make([]aimod.HistoryChat, 0)
		for _, v := range historyList {
			historyChat := new(aimod.HistoryChat)
			historyChat.Ask = v.Ask
			historyChat.Answer = v.Answer
			historyChatList = append(historyChatList, *historyChat)
		}

		answer, err = aiser.ChatAutoMsg(req.Ask, historyChatList, req.Model)
		if err != nil {
			br.Msg = "获取数据失败！"
			br.ErrMsg = "获取数据失败,ChatAutoMsg，Err:" + err.Error()
			return
		}
	}
	resp.Ask = req.Ask
	resp.Answer = answer
	resp.Model = req.Model

	if req.AiChatTopicId <= 0 { //新增
		name, err := aiser.QueryAskContent(req.Ask)
		if err != nil {
			br.Msg = "获取数据失败！"
			br.ErrMsg = "获取数据失败,QueryAskContent，Err:" + err.Error()
			return
		}
		topic := new(aimod.AiChatTopic)
		topic.TopicName = name
		topic.SysUserId = this.SysUser.AdminId
		topic.SysUserRealName = this.SysUser.RealName
		topic.CreateTime = time.Now()
		topic.ModifyTime = time.Now()
		topicId, err := aimod.AddAiChatTopic(topic)
		if err != nil {
			br.Msg = "获取数据失败！"
			br.ErrMsg = "生成话题失败，Err:" + err.Error()
			return
		}
		resp.AiChatTopicId = int(topicId)
		chatItem := new(aimod.AiChat)
		chatItem.AiChatTopicId = resp.AiChatTopicId
		chatItem.Ask = req.Ask
		chatItem.AskUuid = utils.MD5(req.Ask)
		chatItem.Answer = answer
		chatItem.Model = EnabledModelsForMap[req.Model]
		chatItem.SysUserId = this.SysUser.AdminId
		chatItem.SysUserRealName = this.SysUser.RealName
		chatItem.CreateTime = time.Now()
		chatItem.ModifyTime = time.Now()
		_, err = aimod.AddAiChat(chatItem)
		if err != nil {
			br.Msg = "获取数据失败！"
			br.ErrMsg = "生成话题记录失败，Err:" + err.Error()
			return
		}
	} else {
		resp.AiChatTopicId = req.AiChatTopicId
		chatItem := new(aimod.AiChat)
		chatItem.AiChatTopicId = resp.AiChatTopicId
		chatItem.Ask = req.Ask
		chatItem.AskUuid = utils.MD5(req.Ask)
		chatItem.Answer = answer
		chatItem.Model = EnabledModelsForMap[req.Model]
		chatItem.SysUserId = this.SysUser.AdminId
		chatItem.SysUserRealName = this.SysUser.RealName
		chatItem.CreateTime = time.Now()
		chatItem.ModifyTime = time.Now()
		_, err = aimod.AddAiChat(chatItem)
		if err != nil {
			br.Msg = "获取数据失败！"
			br.ErrMsg = "生成话题记录失败，Err:" + err.Error()
			return
		}
	}
	br.Ret = 200
	br.Success = true
	br.Msg = "获取成功"
	br.Data = resp
}

// @router /topic/list [get]
func (this *AiController) TopicList() {
	br := new(models.BaseResponse).Init()
	defer func() {
		this.Data["json"] = br
		this.ServeJSON()
	}()

	sysUser := this.SysUser
	if sysUser == nil {
		br.Msg = "请登录"
		br.ErrMsg = "请登录，SysUser Is Empty"
		br.Ret = 408
		return
	}
	list, err := aimod.GetAiChatTopicList(sysUser.AdminId)
	if err != nil {
		br.Msg = "获取数据失败！"
		br.ErrMsg = "获取主题记录信息失败，Err:" + err.Error()
		return
	}
	resp := new(aimod.AiChatTopicListResp)
	resp.List = list
	br.Ret = 200
	br.Success = true
	br.Msg = "获取成功"
	br.Data = resp
}

// @router /topic/detail [get]
func (this *AiController) TopicDetail() {
	br := new(models.BaseResponse).Init()
	defer func() {
		this.Data["json"] = br
		this.ServeJSON()
	}()

	sysUser := this.SysUser
	if sysUser == nil {
		br.Msg = "请登录"
		br.ErrMsg = "请登录，SysUser Is Empty"
		br.Ret = 408
		return
	}

	aiChatTopicId, _ := this.GetInt("AiChatTopicId")
	list, err := aimod.GetAiChatList(aiChatTopicId)
	if err != nil {
		br.Msg = "获取数据失败！"
		br.ErrMsg = "获取主题记录信息失败，Err:" + err.Error()
		return
	}
	for index := range list {
		list[index].Model = aimod.ModelViewMap[list[index].Model]
	}
	resp := new(aimod.AiChatDetailResp)
	resp.List = list
	br.Ret = 200
	br.Success = true
	br.Msg = "获取成功"
	br.Data = resp
}

// @router /topic/delete [post]
func (this *AiController) TopicDelete() {
	br := new(models.BaseResponse).Init()
	defer func() {
		this.Data["json"] = br
		this.ServeJSON()
	}()

	sysUser := this.SysUser
	if sysUser == nil {
		br.Msg = "请登录"
		br.ErrMsg = "请登录，SysUser Is Empty"
		br.Ret = 408
		return
	}

	var req aimod.TopicDeleteReq
	err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
	if err != nil {
		br.Msg = "参数解析异常！"
		br.ErrMsg = "参数解析失败，Err:" + err.Error()
		return
	}

	if req.AiChatTopicId <= 0 {
		br.Msg = "参数错误！"
		br.ErrMsg = "参数错误！AiChatTopicId:" + strconv.Itoa(req.AiChatTopicId)
		return
	}
	err = aimod.DeleteTopic(req.AiChatTopicId)
	if err != nil {
		br.Msg = "删除失败！"
		br.ErrMsg = "删除失败，Err:" + err.Error()
		return
	}
	br.Ret = 200
	br.Success = true
	br.Msg = "删除成功"
	br.IsAddLog = true
}

// @router /topic/edit [post]
func (this *AiController) TopicEdit() {
	br := new(models.BaseResponse).Init()
	defer func() {
		this.Data["json"] = br
		this.ServeJSON()
	}()

	sysUser := this.SysUser
	if sysUser == nil {
		br.Msg = "请登录"
		br.ErrMsg = "请登录，SysUser Is Empty"
		br.Ret = 408
		return
	}

	var req aimod.TopicEditReq
	err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
	if err != nil {
		br.Msg = "参数解析异常！"
		br.ErrMsg = "参数解析失败，Err:" + err.Error()
		return
	}

	if req.AiChatTopicId <= 0 {
		br.Msg = "参数错误！"
		br.ErrMsg = "参数错误！AiChatTopicId:" + strconv.Itoa(req.AiChatTopicId)
		return
	}
	topic, err := aimod.GetAiChatTopicByTopicName(req.TopicName)
	if err != nil && !utils.IsErrNoRow(err) {
		br.Msg = "编辑失败！"
		br.ErrMsg = "获取数据失败！Err:" + err.Error()
		return
	}
	if topic != nil && topic.AiChatTopicId > 0 && topic.AiChatTopicId != req.AiChatTopicId {
		br.Msg = "话题名称已存在，请重新修改！"
		return
	}

	err = aimod.EditTopic(req.AiChatTopicId, req.TopicName)
	if err != nil {
		br.Msg = "编辑失败！"
		br.ErrMsg = "编辑失败，Err:" + err.Error()
		return
	}
	br.Ret = 200
	br.Success = true
	br.Msg = "编辑成功"
	br.IsAddLog = true
}