From 8a308ce9375d65b4bde24505a141716651580674 Mon Sep 17 00:00:00 2001
From: TsMask <340112800@qq.com>
Date: Wed, 6 Mar 2024 15:13:55 +0800
Subject: [PATCH] =?UTF-8?q?style:=20UPF=E6=80=BB=E6=B5=81=E9=87=8F?=
 =?UTF-8?q?=E7=BC=93=E5=AD=98=E6=95=B0=E6=8D=AE=20=E5=B0=8F=E4=BA=8E2?=
 =?UTF-8?q?=E5=88=86=E9=92=9F=E9=87=8D=E6=96=B0=E7=BC=93=E5=AD=98?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 src/modules/network_data/service/perf_kpi.impl.go | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

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