|
@@ -26,10 +26,6 @@ export function useWs() {
|
|
|
}
|
|
|
});
|
|
|
|
|
|
- function delay(ms: number): Promise<void> {
|
|
|
- return new Promise(resolve => setTimeout(resolve, ms));
|
|
|
- }
|
|
|
-
|
|
|
async function initWs(data: any, callback: any) {
|
|
|
examStateList = []; //当前状态码
|
|
|
testList = []; //区列表
|
|
@@ -66,25 +62,23 @@ export function useWs() {
|
|
|
//单WS多区直接执行
|
|
|
|
|
|
for (const item of testList) {
|
|
|
- await delay(100); // 延时 1 秒
|
|
|
- let examId = `${parameter.project}_${item}`;
|
|
|
- if (parameter.taskId) {
|
|
|
- getTaskStarts(examId);
|
|
|
- } else {
|
|
|
- getExamStarts(examId);
|
|
|
- }
|
|
|
- getNetWork(examId, (e: any) => {
|
|
|
- if (!e.status) {
|
|
|
- callback({cmd: 'disconnect_request', exam_id: examId, data: {message: '工作站未响应'}});
|
|
|
- }
|
|
|
- });
|
|
|
+ await delay(100); // 延时
|
|
|
+ let examId = `${parameter.project}_${item}`;
|
|
|
+ if (parameter.taskId) {
|
|
|
+ getTaskStarts(examId);
|
|
|
+ } else {
|
|
|
+ getExamStarts(examId);
|
|
|
}
|
|
|
-
|
|
|
-
|
|
|
+ getNetWork(examId, (e: any) => {
|
|
|
+ if (!e.status) {
|
|
|
+ callback({ cmd: 'disconnect_request', exam_id: examId, data: { message: '工作站未响应' } });
|
|
|
+ }
|
|
|
+ });
|
|
|
+ }
|
|
|
|
|
|
//分组延迟执行
|
|
|
- // let num = 10; //每次执行10个
|
|
|
- // let time = 200; //间隔时间
|
|
|
+ // let num = 10; //每次执行N个
|
|
|
+ // let time = 200; //间隔时间毫秒
|
|
|
// let group = Math.ceil(testList.length / num);
|
|
|
// for (let i = 0; i < group; i++) {
|
|
|
// for (let j = i * group; j < (i + 1) * num; j++) {
|
|
@@ -635,6 +629,13 @@ export function useWs() {
|
|
|
}
|
|
|
}
|
|
|
|
|
|
+ /**
|
|
|
+ * 控制延时
|
|
|
+ */
|
|
|
+ function delay(ms: number): Promise<void> {
|
|
|
+ return new Promise((resolve) => setTimeout(resolve, ms));
|
|
|
+ }
|
|
|
+
|
|
|
onUnmounted(() => {
|
|
|
getClearTimer();
|
|
|
if (socket) {
|