OMC/be.ems
1
0
Fork 0
Code Issues Releases 3 Activity

style: UPF总流量缓存数据 小于2分钟重新缓存

Browse Source
This commit is contained in:
TsMask
2024-03-06 15:13:55 +08:00
parent f375959e91
commit 8a308ce937
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
src/modules/network_data/service/perf_kpi.impl.go
View File

@@ -54,14 +54,14 @@ func (r *PerfKPIImpl) SelectUPFTotalFlow(neType, rmUID string, day int) map[stri
var info map[string]any var info map[string]any
// 读取缓存数据 // 读取缓存数据 小于2分钟重新缓存
key := fmt.Sprintf("%sUPFTotalFlow_%s_%d", cachekey.NE_DATA_KEY, rmUID, day) key := fmt.Sprintf("%sUPF:totalFlow:%s_%d", cachekey.NE_DATA_KEY, rmUID, day)
infoStr, _ := redis.Get("", key) infoStr, _ := redis.Get("", key)
if infoStr != "" { if infoStr != "" {
json.Unmarshal([]byte(infoStr), &info) json.Unmarshal([]byte(infoStr), &info)
expireSecond, _ := redis.GetExpire("", key) expireSecond, _ := redis.GetExpire("", key)
expireMinute := (time.Duration(int64(expireSecond)) * time.Second) expireMinute := (time.Duration(int64(expireSecond)) * time.Second)
if expireMinute > 1*time.Minute { if expireMinute > 2*time.Minute {
return info return info
} }
} }