fix: UPF流量累计无效问题

features/pm/performance.go

@@ -19,6 +19,8 @@ import (
 	"be.ems/lib/log"
 	"be.ems/lib/services"
 
+	"be.ems/src/framework/utils/parse"
+	neDataService "be.ems/src/modules/network_data/service"
 	neService "be.ems/src/modules/network_element/service"
 	wsService "be.ems/src/modules/ws/service"
 	"github.com/go-resty/resty/v2"
@@ -337,6 +339,10 @@ func PostKPIReportFromNF(w http.ResponseWriter, r *http.Request) {
 			wsService.NewWSSend.ByGroupID(wsService.GROUP_KPI_UPF+neInfo.NeId, kpiEvent)
 			// 推送标识为：12_RMUID, exp: 12_4400HXUPF001, for multi-tenancy
 			wsService.NewWSSend.ByGroupID(wsService.GROUP_KPI_UPF+kpiReport.Task.NE.RmUID, kpiEvent)
+			// 更新UPF总流量
+			upValue := parse.Number(kpiEvent["UPF.03"])
+			downValue := parse.Number(kpiEvent["UPF.06"])
+			neDataService.NewPerfKPI.UPFTodayFlowUpdate(neInfo.RmUID, upValue, downValue, false)
 		}
 	}
 

src/framework/redis/redis.go

@@ -71,6 +71,10 @@ func DefaultRDB() *redis.Client {
 
 // 获取实例
 func RDB(source string) *redis.Client {
+	// 不指定时获取默认实例
+	if source == "" {
+		source = config.Get("redis.defaultDataSourceName").(string)
+	}
 	return rdbMap[source]
 }
 

src/modules/network_data/service/all_perf_kpi.go

@@ -92,6 +92,7 @@ func (r PerfKPI) UPFTodayFlowUpdate(rmUID string, upValue, downValue int64, rest
 		if err != nil {
 			return err
 		}
+		return nil
 	}
 
 	// 使用HIncrBy实时累加统计值