fix: KPI推送ws订阅缺失_x下划线标识
This commit is contained in:
@@ -197,7 +197,7 @@ func saveKPIData(kpiReport KpiReport, index int64) int64 {
|
|||||||
neInfo := neService.NewNeInfo.FindByRmuid(kpiData.RmUid)
|
neInfo := neService.NewNeInfo.FindByRmuid(kpiData.RmUid)
|
||||||
if neInfo.RmUID == kpiData.RmUid {
|
if neInfo.RmUID == kpiData.RmUid {
|
||||||
// 推送到ws订阅组
|
// 推送到ws订阅组
|
||||||
wsService.NewWSSend.ByGroupID(fmt.Sprintf("%s%s_%s", wsService.GROUP_KPI, neInfo.NeType, neInfo.NeId), kpiEvent)
|
wsService.NewWSSend.ByGroupID(fmt.Sprintf("%s_%s_%s", wsService.GROUP_KPI, neInfo.NeType, neInfo.NeId), kpiEvent)
|
||||||
if neInfo.NeType == "UPF" {
|
if neInfo.NeType == "UPF" {
|
||||||
// 更新UPF总流量
|
// 更新UPF总流量
|
||||||
upValue := parse.Number(kpiEvent["UPF.03"])
|
upValue := parse.Number(kpiEvent["UPF.03"])
|
||||||
|
|||||||
Reference in New Issue
Block a user