12345678910111213141516171819202122232425262728293031 |
- package cache
- import (
- "eta_gn/eta_api/models/data_manage"
- "eta_gn/eta_api/utils"
- "fmt"
- )
- 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
- }
|