perf: 支持设置用户有效期

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

@@ -329,6 +329,7 @@ export class PipelineService extends BaseService<PipelineEntity> {
     if (isComm()) {
       await this.checkHasDeployCount(id, entity.userId);
     }
+    await this.checkUserStatus(entity.userId)
     this.cron.register({
       name: `pipeline.${id}.trigger.once`,
       cron: null,
@@ -446,6 +447,13 @@ export class PipelineService extends BaseService<PipelineEntity> {
     if (isComm()) {
       suite = await this.checkHasDeployCount(id, entity.userId);
     }
+    try{
+      await this.checkUserStatus(entity.userId)
+    }catch (e) {
+      logger.info(e.message)
+      return
+    }
+
 
     const pipeline = JSON.parse(entity.content);
     if (!pipeline.id) {
@@ -745,5 +753,25 @@ export class PipelineService extends BaseService<PipelineEntity> {
   }
 
 
-
+  private async checkUserStatus(userId: number) {
+    const userEntity = await this.userService.info(userId);
+    if(userEntity == null){
+      throw new Error('用户不存在');
+    }
+    if(userEntity.status === 0){
+      const message = `账户${userId}已被禁用，禁止运行流水线`
+      throw new Error(message)
+    }
+    const sysPublic = await this.sysSettingsService.getPublicSettings()
+    if(isPlus() && sysPublic.userValidTimeEnabled === true){
+      //校验用户有效期是否设置
+      if(userEntity.validTime!= null && userEntity.validTime > 0){
+        if(userEntity.validTime < new Date().getTime()){
+          //用户已过期
+          const message = `账户${userId}已过有效期，禁止运行流水线`
+          throw new Error(message)
+        }
+      }
+    }
+  }
 }