feat(sj_1.1.0-beta3): 日志组件新增状态监测功能
This commit is contained in:
parent
5dba7fa14b
commit
c10fc513cb
@ -67,6 +67,7 @@ const stopLog = () => {
|
|||||||
};
|
};
|
||||||
|
|
||||||
async function getLogList() {
|
async function getLogList() {
|
||||||
|
clearTimeout(interval.value);
|
||||||
let logData = null;
|
let logData = null;
|
||||||
let logError;
|
let logError;
|
||||||
|
|
||||||
@ -114,14 +115,44 @@ async function getLogList() {
|
|||||||
if (isAutoScroll.value) virtualListInst.value?.scrollTo({ position: 'bottom', debounce: true });
|
if (isAutoScroll.value) virtualListInst.value?.scrollTo({ position: 'bottom', debounce: true });
|
||||||
});
|
});
|
||||||
if (!finished.value && syncTime.value !== 0) {
|
if (!finished.value && syncTime.value !== 0) {
|
||||||
clearTimeout(interval.value);
|
|
||||||
interval.value = setTimeout(getLogList, syncTime.value * 1000);
|
interval.value = setTimeout(getLogList, syncTime.value * 1000);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
if (finished.value && syncTime.value !== 0) {
|
||||||
|
setTimeout(() => {
|
||||||
|
watchFinished();
|
||||||
|
}, 5 * 1000);
|
||||||
|
}
|
||||||
} else if (logError?.code !== 'ERR_CANCELED') {
|
} else if (logError?.code !== 'ERR_CANCELED') {
|
||||||
stopLog();
|
stopLog();
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
async function watchFinished() {
|
||||||
|
clearTimeout(interval.value);
|
||||||
|
if (props.type === 'job' && syncTime.value !== 0) {
|
||||||
|
const taskData = props.taskData! as Api.Job.JobTask;
|
||||||
|
const { data, error } = await fetchJobLogList(
|
||||||
|
{
|
||||||
|
taskBatchId: taskData.taskBatchId,
|
||||||
|
jobId: taskData.jobId,
|
||||||
|
taskId: taskData.id,
|
||||||
|
startId,
|
||||||
|
fromIndex,
|
||||||
|
size: 50
|
||||||
|
},
|
||||||
|
controller
|
||||||
|
);
|
||||||
|
if (!error && data) {
|
||||||
|
if (data.finished) {
|
||||||
|
interval.value = setTimeout(watchFinished, 5 * 1000);
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
await getLogList();
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
onBeforeUnmount(() => {
|
onBeforeUnmount(() => {
|
||||||
stopLog();
|
stopLog();
|
||||||
});
|
});
|
||||||
|
Loading…
Reference in New Issue
Block a user