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

fix: 看板切换upf的流量统计显示

Browse Source
This commit is contained in:
TsMask
2025-08-07 15:49:47 +08:00
parent 48a4497c14
commit c020598678
2 changed files with 16 additions and 21 deletions
Download Patch File Download Diff File Expand all files Collapse all files

17
src/views/dashboard/overview/hooks/useWS.ts
View File

@@ -19,9 +19,6 @@ import PQueue from 'p-queue';
/**UPF-的Id */
export const upfWhoId = ref<any>('');
/**UPF-的RmUid */
export const upfWhoRmUid = ref<any>('');
/**websocket连接 */
export default function useWS() {
const ws = new WS();
@@ -71,13 +68,13 @@ export default function useWS() {
}
break;
//UPF-总流量数
case 'upf_001_0':
case `upf_${upfWhoId.value}_0`:
upfTFParse('0', data);
break;
case 'upf_001_7':
case `upf_${upfWhoId.value}_7`:
upfTFParse('7', data);
break;
case 'upf_001_30':
case `upf_${upfWhoId.value}_30`:
upfTFParse('30', data);
break;
}
@@ -87,7 +84,7 @@ export default function useWS() {
}
switch (data.groupId) {
// kpiEvent 指标UPF
case '10_UPF_' + upfWhoId.value:
case `10_UPF_${upfWhoId.value}`:
if (data.data) {
upfFlowParse(data.data);
}
@@ -122,11 +119,11 @@ export default function useWS() {
upfTotalFlow.value[day].requestFlag = true;
ws.send({
requestId: `upf_001_${day}`,
requestId: `upf_${upfWhoId.value}_${day}`,
type: 'upf_tf',
data: {
neType: 'UPF',
neId: '001',
neId: upfWhoId.value,
day: Number(day),
},
});
@@ -197,7 +194,7 @@ export default function useWS() {
* MME_UE会话事件(GroupID:1011_neId)
* IMS_CDR会话事件(GroupID:1005_neId)
*/
subGroupID: '10_UPF_' + neId + ',1010_001,1011_001,1005_001',
subGroupID: `10_UPF_${neId},1010_001,1011_001,1005_001`,
},
onmessage: wsMessage,
onerror: (ev: any) => {

20
src/views/dashboard/overview2/hooks/useWS.ts
View File

@@ -19,9 +19,6 @@ import PQueue from 'p-queue';
/**UPF-的Id */
export const upfWhoId = ref<any>('');
/**UPF-的RmUid */
export const upfWhoRmUid = ref<any>('');
/**websocket连接 */
export default function useWS() {
const ws = new WS();
@@ -34,6 +31,7 @@ export default function useWS() {
/**接收数据后回调 */
function wsMessage(res: Record<string, any>) {
//console.log(res);
const { code, requestId, data } = res;
if (code === RESULT_CODE_ERROR) {
console.warn(res.msg);
@@ -71,13 +69,13 @@ export default function useWS() {
}
break;
//UPF-总流量数
case 'upf_001_0':
case `upf_${upfWhoId.value}_0`:
upfTFParse('0', data);
break;
case 'upf_001_7':
case `upf_${upfWhoId.value}_7`:
upfTFParse('7', data);
break;
case 'upf_001_30':
case `upf_${upfWhoId.value}_30`:
upfTFParse('30', data);
break;
}
@@ -87,7 +85,7 @@ export default function useWS() {
}
switch (data.groupId) {
// kpiEvent 指标UPF
case '10_UPF_' + upfWhoId.value:
case `10_UPF_${upfWhoId.value}`:
if (data.data) {
upfFlowParse(data.data);
}
@@ -122,11 +120,11 @@ export default function useWS() {
upfTotalFlow.value[day].requestFlag = true;
ws.send({
requestId: `upf_001_${day}`,
requestId: `upf_${upfWhoId.value}_${day}`,
type: 'upf_tf',
data: {
neType: 'UPF',
neId: '001',
neId: upfWhoId.value,
day: Number(day),
},
});
@@ -197,7 +195,7 @@ export default function useWS() {
* MME_UE会话事件(GroupID:1011_neId)
* IMS_CDR会话事件(GroupID:1005_neId)
*/
subGroupID: '10_UPF_' + neId + ',1010_001,1011_001,1005_001',
subGroupID: `10_UPF_${neId},1010_001,1011_001,1005_001`,
},
onmessage: wsMessage,
onerror: (ev: any) => {
@@ -212,7 +210,7 @@ export default function useWS() {
userActivityReset();
upfTotalFlowReset();
topologyReset();
upfWhoRmUid.value = '';
upfWhoId.value = '';
});
return {