eta_api/cache/data_collect_handler.go

package cache

import (
	"eta_gn/eta_api/models/data_manage"
	"eta_gn/eta_api/utils"
	"fmt"
)

// AddDataCollectHandler
// @Description: 将需要重新处理收藏的资产的指标加入缓存
// @author: Roc
// @datetime 2024-12-27 16:55:09
// @param dataId int 资产（指标、图表）ID
// @param dataType int 资产类型：1-指标；2-图表
// @return bool
func AddDataCollectHandler(dataId, dataType int) bool {
	record := data_manage.DataCollectHandleItem{
		DataId:   dataId,
		DataType: dataType,
	}
	if utils.Re == nil {
		err := utils.Rc.LPush(utils.CACHE_KEY_DATA_COLLECT_HANDLER, record)

		utils.FileLog.Info(fmt.Sprintf("将需要重新处理收藏的资产的指标加入缓存 AddDataCollectHandler LPush: 资产（指标、图表）ID：%d，资产类型：%d", dataId, dataType))
		if err != nil {
			fmt.Println("AddDataCollectHandler LPush Err:" + err.Error())
		}
		return true
	}
	return false
}