perf: 流水线支持有效期设置

packages/ui/certd-server/src/modules/pipeline/entity/pipeline.ts

@@ -43,28 +43,19 @@ export class PipelineEntity {
   @Column({ name:"is_template", comment: '是否模版', nullable: true, default: false })
   isTemplate: boolean;
 
-  @Column({
-    name: 'last_history_time',
-    comment: '最后一次执行时间',
-    nullable: true,
-  })
+  @Column({name: 'last_history_time',comment: '最后一次执行时间',nullable: true,})
   lastHistoryTime: number;
 
+  @Column({name: 'valid_time',comment: '到期时间',nullable: true,default: 0})
+  validTime: number;
+
   // 变量
   lastVars: any;
 
-  @Column({
-    name: 'order',
-    comment: '排序',
-    nullable: true,
-  })
+  @Column({name: 'order', comment: '排序', nullable: true,})
   order: number;
 
-  @Column({
-    name: 'create_time',
-    comment: '创建时间',
-    default: () => 'CURRENT_TIMESTAMP',
-  })
+  @Column({name: 'create_time',comment: '创建时间', default: () => 'CURRENT_TIMESTAMP',})
   createTime: Date;
   @Column({
     name: 'update_time',

packages/ui/certd-server/src/modules/pipeline/service/pipeline-service.ts

@@ -457,11 +457,11 @@ export class PipelineService extends BaseService<PipelineEntity> {
       return;
     }
     cron = cron.trim();
-    if (cron.startsWith("* *")) {
-      cron = cron.replace("\* \*", "0 0");
+    if (cron.startsWith("* * ")) {
+      cron = "0 0 " + cron.substring(5);
     }
-    if (cron.startsWith("*")) {
-      cron = cron.replace("\*", "0");
+    if (cron.startsWith("* ")) {
+      cron = "0 " + cron.substring(2);
     }
     const triggerId = trigger.id;
     const name = this.buildCronKey(pipelineId, triggerId);
@@ -493,6 +493,9 @@ export class PipelineService extends BaseService<PipelineEntity> {
    */
   async run(id: number, triggerId: string, stepId?: string) {
     const entity: PipelineEntity = await this.info(id);
+    if (entity.validTime > 0 && entity.validTime < Date.now()) {
+      return;
+    }
     await this.doRun(entity, triggerId, stepId);
   }