eta_api/cache/index_task.go

package cache

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

type IndexTaskRecordOp struct {
	IndexTaskRecordId int
	TaskType          string
}

// AddIndexTaskRecordOpToCache
// @Description: AI任务操作调度入队列
// @author: Roc
// @datetime 2025-04-24 09:41:11
// @param aiTaskRecordId int
// @return bool
func AddIndexTaskRecordOpToCache(aiTaskRecordId int, taskType string) bool {
	record := new(IndexTaskRecordOp)
	record.IndexTaskRecordId = aiTaskRecordId
	record.TaskType = taskType

	if utils.Re == nil {
		err := utils.Rc.LPush(utils.CACHE_INDEX_TASK, record)

		utils.FileLog.Info(fmt.Sprintf("将指标库任务操作调度入队列 加入缓存 AddIndexTaskRecordOpToCache LPush: 记录id：%d", aiTaskRecordId))
		if err != nil {
			fmt.Println("AddIndexTaskRecordOpToCache LPush Err:" + err.Error())
		}
		return true
	}
	return false
}