fix: UPF流量统计数据同时获取刷新

This commit is contained in:
TsMask
2025-08-28 09:52:25 +08:00
parent b525b92163
commit a7024df325
2 changed files with 23 additions and 22 deletions

View File

@@ -229,15 +229,15 @@ function loadData() {
interval10s.value = setInterval(() => { interval10s.value = setInterval(() => {
if (!interval10s.value || !initFlag) return; if (!interval10s.value || !initFlag) return;
if (upfTFActive.value === '0') { if (upfTFActive.value === '0') {
upfTFSend('7');
upfTFActive.value = '7'; upfTFActive.value = '7';
} else if (upfTFActive.value === '7') { } else if (upfTFActive.value === '7') {
upfTFSend('30');
upfTFActive.value = '30'; upfTFActive.value = '30';
} else if (upfTFActive.value === '30') { } else if (upfTFActive.value === '30') {
upfTFSend('0');
upfTFActive.value = '0'; upfTFActive.value = '0';
} }
upfTFSend('0');
upfTFSend('7');
upfTFSend('30');
}, 10_000); }, 10_000);
clearInterval(interval5s.value); clearInterval(interval5s.value);

View File

@@ -176,15 +176,15 @@ async function fnGetSkim() {
{ {
request: (neId: string) => listAMFNblist({ neId }), request: (neId: string) => listAMFNblist({ neId }),
process: async (res: any, neId: any) => { process: async (res: any, neId: any) => {
console.log(neId) console.log(neId);
if (res.code === RESULT_CODE_SUCCESS&& Array.isArray(res.data)) { if (res.code === RESULT_CODE_SUCCESS && Array.isArray(res.data)) {
skimState.gnbNum += res.data.length; skimState.gnbNum += res.data.length;
skimState.gnbUeNum += res.data.reduce( skimState.gnbUeNum += res.data.reduce(
(sum: number, item: any) => sum + item.ueNum, (sum: number, item: any) => sum + item.ueNum,
0 0
); );
const amfNbRes = await listAMFNbStatelist({ neId }); const amfNbRes = await listAMFNbStatelist({ neId });
console.log(amfNbRes) console.log(amfNbRes);
if ( if (
amfNbRes.code === RESULT_CODE_SUCCESS && amfNbRes.code === RESULT_CODE_SUCCESS &&
Array.isArray(amfNbRes.data) Array.isArray(amfNbRes.data)
@@ -224,13 +224,13 @@ async function fnGetSkim() {
); );
const mmeNbRes = await listMMENbStatelist({ neId }); const mmeNbRes = await listMMENbStatelist({ neId });
console.log(mmeNbRes) console.log(mmeNbRes);
if ( if (
mmeNbRes.code === RESULT_CODE_SUCCESS && mmeNbRes.code === RESULT_CODE_SUCCESS &&
Array.isArray(mmeNbRes.data) Array.isArray(mmeNbRes.data)
) { ) {
// skimState.eNbSumNum += mmeNbRes.data.length; // skimState.eNbSumNum += mmeNbRes.data.length;
console.log(mmeNbRes) console.log(mmeNbRes);
tempEnbSumNum += mmeNbRes.data.length; tempEnbSumNum += mmeNbRes.data.length;
} }
} }
@@ -238,20 +238,19 @@ async function fnGetSkim() {
}, },
], ],
]); ]);
console.log(neCascaderOptions) console.log(neCascaderOptions);
const requests = neCascaderOptions.value.flatMap( const requests = neCascaderOptions.value.flatMap(
(ne: any) => (ne: any) =>
ne.children ne.children
?.map((child: any) => { ?.map((child: any) => {
console.log(child.neId) console.log(child.neId);
const handler = neHandlers.get(child.neType); const handler = neHandlers.get(child.neType);
return handler return handler
? { ? {
promise: handler.request(child.neId), promise: handler.request(child.neId),
process: handler.process, process: handler.process,
neId: child.neId, // 这里加上neId neId: child.neId, // 这里加上neId
} }
: null; : null;
}) })
@@ -311,15 +310,15 @@ function loadData() {
interval10s.value = setInterval(() => { interval10s.value = setInterval(() => {
if (!interval10s.value || !initFlag) return; if (!interval10s.value || !initFlag) return;
if (upfTFActive.value === '0') { if (upfTFActive.value === '0') {
upfTFSend('7');
upfTFActive.value = '7'; upfTFActive.value = '7';
} else if (upfTFActive.value === '7') { } else if (upfTFActive.value === '7') {
upfTFSend('30');
upfTFActive.value = '30'; upfTFActive.value = '30';
} else if (upfTFActive.value === '30') { } else if (upfTFActive.value === '30') {
upfTFSend('0');
upfTFActive.value = '0'; upfTFActive.value = '0';
} }
upfTFSend('0');
upfTFSend('7');
upfTFSend('30');
}, 10_000); }, 10_000);
clearInterval(interval5s.value); clearInterval(interval5s.value);
@@ -375,12 +374,14 @@ async function fnSelectUDM(e: any) {
pageNum: 1, pageNum: 1,
pageSize: 1, pageSize: 1,
}); });
console.log(res) console.log(res);
// listUDMSub({ neId: udmNeId.value, pageNum: 1, pageSize: 1 }).then(res => { // listUDMSub({ neId: udmNeId.value, pageNum: 1, pageSize: 1 }).then(res => {
if (res.code === RESULT_CODE_SUCCESS && typeof res.data.total === 'number') { if (
res.code === RESULT_CODE_SUCCESS &&
typeof res.data.total === 'number'
) {
skimState.udmSubNum = res.data.total; skimState.udmSubNum = res.data.total;
console.log(res) console.log(res);
} else { } else {
skimState.udmSubNum = 0; skimState.udmSubNum = 0;
} }
@@ -393,7 +394,7 @@ async function fnSelectUDM(e: any) {
} }
/**资源控制-选择NE */ /**资源控制-选择NE */
function fnSelectNeRe(e: any) { function fnSelectNeRe(e: any) {
console.log(e) console.log(e);
graphNodeClickID.value = e.key; graphNodeClickID.value = e.key;
} }
// //
@@ -408,7 +409,7 @@ const getPopupContainer = () => {
onMounted(() => { onMounted(() => {
// 获取网元网元列表 // 获取网元网元列表
neListStore.neCascaderOptions.forEach(item => { neListStore.neCascaderOptions.forEach(item => {
console.log(item) console.log(item);
if (item.value === 'UPF') { if (item.value === 'UPF') {
neOtions.value = JSON.parse(JSON.stringify(item.children)); neOtions.value = JSON.parse(JSON.stringify(item.children));
} }