eta_task/cache/llm.go

package cache

import (
	"eta/eta_task/utils"
	"fmt"
)

type RagEtaReportOpOp struct {
	Source          string
	ReportId        int
	ReportChapterId int
}

// RagEtaReportOpToCache
// @Description: 将eta报告入知识库操作加入缓存
// @author: Roc
// @datetime 2025-04-07 15:05:22
// @param reportId int
// @param reportChapterId int
// @param source string
// @return bool
func RagEtaReportOpToCache(reportId, reportChapterId int, source string) bool {
	record := new(RagEtaReportOpOp)
	record.Source = source
	record.ReportId = reportId
	record.ReportChapterId = reportChapterId
	if utils.Re == nil {
		err := utils.Rc.LPush(utils.CACHE_ETA_REPORT_KNOWLEDGE, record)

		utils.FileLog.Info(fmt.Sprintf("将eta报告入知识库操作加入缓存 加入缓存 RagEtaReportOpToCache LPush: 操作类型：%s，报告id：%d，章节id：%d", source, reportId, reportChapterId))
		if err != nil {
			fmt.Println("RagEtaReportOpToCache LPush Err:" + err.Error())
		}
		return true
	}
	return false
}