Browse Source

日常开发

林旭祥 5 months ago
parent
commit
85034ab1c5
1 changed files with 24 additions and 16 deletions
  1. 24 16
      src/utils/trainWs.ts

+ 24 - 16
src/utils/trainWs.ts

@@ -59,20 +59,28 @@ export function useWs() {
     socket.on('connect', (e: any) => {
     socket.on('connect', (e: any) => {
       callback({ cmd: 'mySid', data: { sid: socket.id.replace('/midexam#', '') } });
       callback({ cmd: 'mySid', data: { sid: socket.id.replace('/midexam#', '') } });
       if (testList.length > 1) {
       if (testList.length > 1) {
-        //单WS多区
-        testList.forEach((item: any) => {
-          let examId = `${parameter.project}_${item}`;
-          if (parameter.taskId) {
-            getTaskStarts(examId);
-          } else {
-            getExamStarts(examId);
+        //分组延迟执行
+        let num = 10; //每次执行10个
+        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++) {
+            setTimeout(() => {
+              let item = testList[j];
+              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: '工作站未响应' } });
+                }
+              });
+            }, time * i);
           }
           }
-          getNetWork(examId, (e: any) => {
-            if (!e.status) {
-              callback({ cmd: 'disconnect_request', exam_id: examId, data: { message: '工作站未响应' } });
-            }
-          });
-        });
+        }
       } else {
       } else {
         //单WS单区
         //单WS单区
         let examId = parameter.examId;
         let examId = parameter.examId;
@@ -215,7 +223,7 @@ export function useWs() {
    */
    */
   function sendMessage(type: string, data: any, callback?: () => void) {
   function sendMessage(type: string, data: any, callback?: () => void) {
     if (socket?.connected) {
     if (socket?.connected) {
-      callback = callback || function () { };
+      callback = callback || function () {};
       //版本2就拼接进去
       //版本2就拼接进去
       if (version == 'v2') {
       if (version == 'v2') {
         type = type + '_' + version;
         type = type + '_' + version;
@@ -240,7 +248,7 @@ export function useWs() {
         demo: parameter.demo,
         demo: parameter.demo,
         test_time: testTime
         test_time: testTime
       },
       },
-      () => { }
+      () => {}
     );
     );
   }
   }
 
 
@@ -259,7 +267,7 @@ export function useWs() {
         demo: parameter.demo,
         demo: parameter.demo,
         test_time: testTime
         test_time: testTime
       },
       },
-      () => { }
+      () => {}
     );
     );
   }
   }