新增 计划任务上限数

Author: yumao233

src/routers/schedule_router.ts

@@ -25,8 +25,12 @@ import InstanceControlSubsystem from "../service/system_instance_control";
 
 // 创建计划任务
 routerApp.on("schedule/register", (ctx, data) => {
-  InstanceControlSubsystem.registerScheduleJob(data);
-  protocol.response(ctx, true);
+  try {
+    InstanceControlSubsystem.registerScheduleJob(data);
+    protocol.response(ctx, true);
+  } catch (error) {
+    protocol.responseError(ctx, error);
+  }
 });
 
 // 获取任务列表

src/service/system_instance_control.ts

@@ -91,10 +91,12 @@ class InstanceControlSubsystem {
     if (!this.taskMap.has(key)) {
       this.taskMap.set(key, []);
     }
+    if (this.taskMap.get(key)?.length > 8) throw new Error("无法继续创建计划任务，以达到上限");
     if (!this.checkTask(key, task.name)) throw new Error("已存在重复的任务");
-    let job: IScheduleJob;
     if (needStore) logger.info(`创建计划任务 ${task.name}:\n${JSON.stringify(task)}`);
 
+    let job: IScheduleJob;
+
     // 最小间隔时间检查
     if (task.type === 1) {
       let internalTime = Number(task.time);
@@ -232,6 +234,11 @@ class InstanceControlSubsystem {
       }
     }
   }
+
+  private checkScheduledTaskLimit(instanceUuid: string) {
+    for (const iterator of this.taskMap) {
+    }
+  }
 }
 
 export default new InstanceControlSubsystem();