|
|
@ -208,6 +208,10 @@ func (the *ConfigHelper) SetChainedCacheObjWithExpiration(k string, obj any, dur |
|
|
|
err := the.chainedCache.LoadableChinCache.Set(the.ctx, k, value, store.WithExpiration(duration)) |
|
|
|
return err |
|
|
|
} |
|
|
|
func (the *ConfigHelper) DeleteChainedCacheObj(k string) error { |
|
|
|
err := the.chainedCache.LoadableChinCache.Delete(the.ctx, k) |
|
|
|
return err |
|
|
|
} |
|
|
|
func (the *ConfigHelper) GetCacheWindowObj(key_cacheWindow string) (common_models.CacheWindow, error) { |
|
|
|
var redisCacheWin common_models.CacheWinSave |
|
|
|
value, err := the.chainedCache.LoadableChinCache.Get(the.ctx, key_cacheWindow) |
|
|
@ -575,6 +579,22 @@ func (the *ConfigHelper) GetFilter(stationId int) (common_models.Filter, error) |
|
|
|
|
|
|
|
return result, err |
|
|
|
} |
|
|
|
func (the *ConfigHelper) GetFilterItem(stationId int, item string) (common_models.FilterItem, error) { |
|
|
|
|
|
|
|
result, err := the.GetFilter(stationId) |
|
|
|
|
|
|
|
if err == nil { |
|
|
|
for _, filterItem := range result.Items { |
|
|
|
if filterItem.FieldName == item { |
|
|
|
return filterItem, err |
|
|
|
} |
|
|
|
} |
|
|
|
} else { |
|
|
|
log.Printf("获取GetFilterItem err=%s", err.Error()) |
|
|
|
} |
|
|
|
|
|
|
|
return common_models.FilterItem{}, err |
|
|
|
} |
|
|
|
func (the *ConfigHelper) GetAlarmCode(alarmCode string) (common_models.AlarmCode, error) { |
|
|
|
var err error |
|
|
|
result, ok := AlarmCodeCache[alarmCode] |
|
|
|