From 7b451bbf6e6337507f4627b5a845f5bd96ab4f7b Mon Sep 17 00:00:00 2001
From: xiaojunnuo <xiaojunnuo@qq.com>
Date: Tue, 13 Aug 2024 20:30:42 +0800
Subject: [PATCH] =?UTF-8?q?perf:=20=E4=BC=98=E5=8C=96=E6=88=90=E5=8A=9F?=
 =?UTF-8?q?=E5=90=8E=E8=B7=B3=E8=BF=87=E7=9A=84=E6=8F=90=E7=A4=BA?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 packages/core/pipeline/src/plugin/api.ts      |  7 ++-
 .../src/plugin/cert-plugin/base.ts            |  7 +--
 .../component/output-selector/index.vue       |  4 +-
 .../pipeline/component/step-form/index.vue    | 47 +++++++++++--------
 packages/ui/certd-server/.env.pgdev.yaml      |  3 --
 packages/ui/certd-server/.env.preview.yaml    |  4 +-
 packages/ui/certd-server/.env.production.yaml | 10 +++-
 .../certd-server/src/config/config.default.ts |  3 ++
 .../certd-server/src/config/config.preview.ts | 21 ---------
 .../src/config/config.production.ts           | 21 ---------
 .../certd-server/src/config/config.syncdb.ts  | 11 -----
 .../src/config/config.unittest.ts             |  7 ---
 packages/ui/certd-server/src/configuration.ts | 10 +---
 .../authority/controller/user-controller.ts   | 10 +---
 .../modules/authority/service/user-service.ts | 13 +++++
 .../src/modules/auto/auto-register-cron.ts    |  6 +--
 .../pipeline/service/history-service.ts       |  9 ++--
 .../pipeline/service/pipeline-service.ts      |  4 +-
 .../plugin-aliyun/access/aliyun-access.ts     |  3 +-
 .../plugin/deploy-to-ack-ingress/index.ts     | 12 ++---
 .../plugin/deploy-to-cdn/index.ts             | 30 ++----------
 .../plugin/upload-to-aliyun/index.ts          | 14 ++----
 .../plugins/plugin-deploy-to-cdn.ts           | 14 ++----
 .../plugin-demo/plugins/plugin-test.ts        | 41 ++++++++--------
 .../plugin/host-shell-execute/index.ts        |  9 +---
 .../plugin/upload-to-host/index.ts            | 10 +---
 .../src/plugins/plugin-other/access/index.ts  |  1 +
 .../plugins/plugin-other/access/k8s-access.ts | 19 ++++++++
 .../plugin-tencent/access/dnspod-access.ts    |  3 +-
 .../plugin/deploy-to-cdn/index.ts             | 11 +----
 .../plugin/deploy-to-clb/index.ts             | 15 ++----
 .../plugin/deploy-to-tke-ingress/index.ts     | 14 ++----
 .../plugin/upload-to-tencent/index.ts         | 10 +---
 33 files changed, 151 insertions(+), 252 deletions(-)
 delete mode 100644 packages/ui/certd-server/src/config/config.preview.ts
 delete mode 100644 packages/ui/certd-server/src/config/config.production.ts
 delete mode 100644 packages/ui/certd-server/src/config/config.syncdb.ts
 delete mode 100644 packages/ui/certd-server/src/config/config.unittest.ts
 create mode 100644 packages/ui/certd-server/src/plugins/plugin-other/access/index.ts
 create mode 100644 packages/ui/certd-server/src/plugins/plugin-other/access/k8s-access.ts

diff --git a/packages/core/pipeline/src/plugin/api.ts b/packages/core/pipeline/src/plugin/api.ts
index 4f18a9685..4da1c0d4f 100644
--- a/packages/core/pipeline/src/plugin/api.ts
+++ b/packages/core/pipeline/src/plugin/api.ts
@@ -6,7 +6,7 @@ import { IAccessService } from "../access/index.js";
 import { IEmailService } from "../service/index.js";
 import { IContext } from "../core/index.js";
 import { AxiosInstance } from "axios";
-import { logger } from "../utils/index.js";
+import { ILogger, logger } from "../utils/index.js";
 
 export enum ContextScope {
   global,
@@ -69,6 +69,9 @@ export type TaskInstanceContext = {
 export abstract class AbstractTaskPlugin implements ITaskPlugin {
   _result: TaskResult = { clearLastStatus: false, files: [], pipelineVars: {} };
   ctx!: TaskInstanceContext;
+  logger!: ILogger;
+  accessService!: IAccessService;
+
   clearLastStatus() {
     this._result.clearLastStatus = true;
   }
@@ -79,6 +82,8 @@ export abstract class AbstractTaskPlugin implements ITaskPlugin {
 
   setCtx(ctx: TaskInstanceContext) {
     this.ctx = ctx;
+    this.logger = ctx.logger;
+    this.accessService = ctx.accessService;
   }
 
   randomFileId() {
diff --git a/packages/plugins/plugin-cert/src/plugin/cert-plugin/base.ts b/packages/plugins/plugin-cert/src/plugin/cert-plugin/base.ts
index 527b01888..984cf437c 100644
--- a/packages/plugins/plugin-cert/src/plugin/cert-plugin/base.ts
+++ b/packages/plugins/plugin-cert/src/plugin/cert-plugin/base.ts
@@ -1,7 +1,6 @@
-import { AbstractTaskPlugin, HttpClient, IAccessService, IContext, Step, TaskInput, TaskOutput } from "@certd/pipeline";
+import { AbstractTaskPlugin, HttpClient, IContext, Step, TaskInput, TaskOutput } from "@certd/pipeline";
 import dayjs from "dayjs";
 import type { CertInfo } from "./acme.js";
-import { Logger } from "log4js";
 import { CertReader } from "./cert-reader.js";
 import JSZip from "jszip";
 
@@ -91,9 +90,7 @@ export abstract class CertApplyBasePlugin extends AbstractTaskPlugin {
   // })
   csrInfo!: string;
 
-  logger!: Logger;
   userContext!: IContext;
-  accessService!: IAccessService;
   http!: HttpClient;
   lastStatus!: Step;
 
@@ -103,8 +100,6 @@ export abstract class CertApplyBasePlugin extends AbstractTaskPlugin {
   cert?: CertInfo;
 
   async onInstance() {
-    this.accessService = this.ctx.accessService;
-    this.logger = this.ctx.logger;
     this.userContext = this.ctx.userContext;
     this.http = this.ctx.http;
     this.lastStatus = this.ctx.lastStatus as Step;
diff --git a/packages/ui/certd-client/src/views/certd/pipeline/pipeline/component/output-selector/index.vue b/packages/ui/certd-client/src/views/certd/pipeline/pipeline/component/output-selector/index.vue
index 0e21fa1c7..d4230fdfd 100644
--- a/packages/ui/certd-client/src/views/certd/pipeline/pipeline/component/output-selector/index.vue
+++ b/packages/ui/certd-client/src/views/certd/pipeline/pipeline/component/output-selector/index.vue
@@ -23,7 +23,7 @@ export default {
     const currentStepIndex = inject("currentStepIndex") as Ref<number>;
     const currentTask = inject("currentTask") as Ref<any>;
 
-    const getPluginGroups = inject("getPluginGroups") as Ref<any>;
+    const getPluginGroups = inject("getPluginGroups") as any;
     const pluginGroups = getPluginGroups();
     function onCreate() {
       options.value = pluginGroups.getPreStepOutputOptions({
@@ -42,7 +42,7 @@ export default {
 
     watch(
       () => {
-        return pluginGroups.value.map;
+        return pluginGroups.value?.map;
       },
       () => {
         onCreate();
diff --git a/packages/ui/certd-client/src/views/certd/pipeline/pipeline/component/step-form/index.vue b/packages/ui/certd-client/src/views/certd/pipeline/pipeline/component/step-form/index.vue
index b4c82a9b9..8d0b45e7b 100644
--- a/packages/ui/certd-client/src/views/certd/pipeline/pipeline/component/step-form/index.vue
+++ b/packages/ui/certd-client/src/views/certd/pipeline/pipeline/component/step-form/index.vue
@@ -61,24 +61,7 @@
             <fs-form-item v-model="currentStep.input[key]" :item="item" :get-context-fn="blankFn" />
           </template>
 
-          <fs-form-item
-            v-model="currentStep.strategy.runStrategy"
-            :item="{
-              title: '运行策略',
-              key: 'strategy.runStrategy',
-              component: {
-                name: 'a-select',
-                vModel: 'value',
-                options: [
-                  { value: 0, label: '正常运行（证书申请任务请选择它）' },
-                  { value: 1, label: '成功后跳过（非证书任务请选择它）' }
-                ]
-              },
-              helper: '该任务运行成功一次之后下次运行是否跳过，保持默认即可',
-              rules: [{ required: true, message: '此项必填' }]
-            }"
-            :get-context-fn="blankFn"
-          />
+          <fs-form-item v-model="currentStep.strategy.runStrategy" :item="runStrategyProps" :get-context-fn="blankFn" />
         </a-form>
 
         <template #footer>
@@ -289,10 +272,36 @@ export default {
       };
     }
 
+    const runStrategyProps = ref({
+      title: "运行策略",
+      key: "strategy.runStrategy",
+      component: {
+        name: "a-select",
+        vModel: "value",
+        options: [
+          { value: 0, label: "正常运行（证书申请任务请选择它）" },
+          { value: 1, label: "成功后跳过（非证书任务请选择它）" }
+        ]
+      },
+      helper: {
+        render: () => {
+          return (
+            <div>
+              <div>正常运行：每次都运行，证书任务需要每次都运行</div>
+              <div>成功后跳过：在证书没变化时，该任务成功一次之后跳过，不重复部署</div>
+              <div>保持默认即可，如果你想要再次测试部署，可以临时设置为正常运行</div>
+            </div>
+          );
+        }
+      },
+      rules: [{ required: true, message: "此项必填" }]
+    });
+
     return {
       ...useStepForm(),
       labelCol: { span: 6 },
-      wrapperCol: { span: 16 }
+      wrapperCol: { span: 16 },
+      runStrategyProps
     };
   }
 };
diff --git a/packages/ui/certd-server/.env.pgdev.yaml b/packages/ui/certd-server/.env.pgdev.yaml
index 220ac326f..ba30ee9fe 100644
--- a/packages/ui/certd-server/.env.pgdev.yaml
+++ b/packages/ui/certd-server/.env.pgdev.yaml
@@ -1,6 +1,3 @@
-koa:
-  port: 7001
-
 flyway:
   scriptDir: './db/migration-pg'
 
diff --git a/packages/ui/certd-server/.env.preview.yaml b/packages/ui/certd-server/.env.preview.yaml
index 10b4b96dd..a03a3e162 100644
--- a/packages/ui/certd-server/.env.preview.yaml
+++ b/packages/ui/certd-server/.env.preview.yaml
@@ -1,2 +1,2 @@
-koa:
-  port: 7001
+preview:
+  enabled: true
diff --git a/packages/ui/certd-server/.env.production.yaml b/packages/ui/certd-server/.env.production.yaml
index 10b4b96dd..b6c1623c2 100644
--- a/packages/ui/certd-server/.env.production.yaml
+++ b/packages/ui/certd-server/.env.production.yaml
@@ -1,2 +1,8 @@
-koa:
-  port: 7001
+preview:
+  enabled: false
+
+typeorm:
+  dataSource:
+    default:
+      logging: false
+
diff --git a/packages/ui/certd-server/src/config/config.default.ts b/packages/ui/certd-server/src/config/config.default.ts
index 1a843c67f..7929535d8 100644
--- a/packages/ui/certd-server/src/config/config.default.ts
+++ b/packages/ui/certd-server/src/config/config.default.ts
@@ -38,7 +38,10 @@ const development = {
     },
   },
   cron: {
+    //启动时立即触发一次
     immediateTriggerOnce: false,
+    //启动时仅注册admin（id=1）用户的
+    onlyAdminUser: false,
   },
   /**
    * 演示环境
diff --git a/packages/ui/certd-server/src/config/config.preview.ts b/packages/ui/certd-server/src/config/config.preview.ts
deleted file mode 100644
index ebe309655..000000000
--- a/packages/ui/certd-server/src/config/config.preview.ts
+++ /dev/null
@@ -1,21 +0,0 @@
-import { MidwayConfig } from '@midwayjs/core';
-import { mergeConfig } from './loader.js';
-
-const preview = {
-  /**
-   * 演示环境
-   */
-  preview: {
-    enabled: true,
-  },
-  typeorm: {
-    dataSource: {
-      default: {
-        logging: false,
-      },
-    },
-  },
-} as MidwayConfig;
-
-mergeConfig(preview, 'preview');
-export default preview;
diff --git a/packages/ui/certd-server/src/config/config.production.ts b/packages/ui/certd-server/src/config/config.production.ts
deleted file mode 100644
index 41a3442a0..000000000
--- a/packages/ui/certd-server/src/config/config.production.ts
+++ /dev/null
@@ -1,21 +0,0 @@
-import { MidwayConfig } from '@midwayjs/core';
-import { mergeConfig } from './loader.js';
-
-const production = {
-  /**
-   * 演示环境
-   */
-  preview: {
-    enabled: false,
-  },
-  typeorm: {
-    dataSource: {
-      default: {
-        logging: false,
-      },
-    },
-  },
-} as MidwayConfig;
-
-mergeConfig(production, 'production');
-export default production;
diff --git a/packages/ui/certd-server/src/config/config.syncdb.ts b/packages/ui/certd-server/src/config/config.syncdb.ts
deleted file mode 100644
index 478af50b6..000000000
--- a/packages/ui/certd-server/src/config/config.syncdb.ts
+++ /dev/null
@@ -1,11 +0,0 @@
-import { MidwayConfig } from '@midwayjs/core';
-
-export default {
-  typeorm: {
-    dataSource: {
-      default: {
-        synchronize: true, // 如果第一次使用，不存在表，有同步的需求可以写 true
-      },
-    },
-  },
-} as MidwayConfig;
diff --git a/packages/ui/certd-server/src/config/config.unittest.ts b/packages/ui/certd-server/src/config/config.unittest.ts
deleted file mode 100644
index 423dfcd30..000000000
--- a/packages/ui/certd-server/src/config/config.unittest.ts
+++ /dev/null
@@ -1,7 +0,0 @@
-import { MidwayConfig } from '@midwayjs/core';
-
-export default {
-  koa: {
-    port: null,
-  },
-} as MidwayConfig;
diff --git a/packages/ui/certd-server/src/configuration.ts b/packages/ui/certd-server/src/configuration.ts
index 2e85a1d1e..f46d51635 100644
--- a/packages/ui/certd-server/src/configuration.ts
+++ b/packages/ui/certd-server/src/configuration.ts
@@ -1,4 +1,4 @@
-import { Configuration, App } from '@midwayjs/core';
+import { App, Configuration } from '@midwayjs/core';
 import * as koa from '@midwayjs/koa';
 import * as orm from '@midwayjs/typeorm';
 import * as cache from '@midwayjs/cache';
@@ -14,12 +14,7 @@ import { PreviewMiddleware } from './middleware/preview.js';
 import { AuthorityMiddleware } from './middleware/authority.js';
 import { logger } from './utils/logger.js';
 import { ResetPasswdMiddleware } from './middleware/reset-passwd/middleware.js';
-// import { DefaultErrorFilter } from './filter/default.filter.js';
-// import { NotFoundFilter } from './filter/notfound.filter.js';
 import DefaultConfig from './config/config.default.js';
-import ProductionConfig from './config/config.production.js';
-import PreviewConfig from './config/config.preview.js';
-import UnittestConfig from './config/config.unittest.js';
 
 process.on('uncaughtException', error => {
   console.error('未捕获的异常：', error);
@@ -43,9 +38,6 @@ process.on('uncaughtException', error => {
   importConfigs: [
     {
       default: DefaultConfig,
-      preview: PreviewConfig,
-      production: ProductionConfig,
-      unittest: UnittestConfig,
     },
   ],
 })
diff --git a/packages/ui/certd-server/src/modules/authority/controller/user-controller.ts b/packages/ui/certd-server/src/modules/authority/controller/user-controller.ts
index 4503ce9c2..8e535d541 100644
--- a/packages/ui/certd-server/src/modules/authority/controller/user-controller.ts
+++ b/packages/ui/certd-server/src/modules/authority/controller/user-controller.ts
@@ -1,12 +1,4 @@
-import {
-  Provide,
-  Controller,
-  Post,
-  Inject,
-  Body,
-  Query,
-  ALL,
-} from '@midwayjs/core';
+import { Provide, Controller, Post, Inject, Body, Query, ALL } from '@midwayjs/core';
 import { UserService } from '../service/user-service.js';
 import { CrudController } from '../../../basic/crud-controller.js';
 import { RoleService } from '../service/role-service.js';
diff --git a/packages/ui/certd-server/src/modules/authority/service/user-service.ts b/packages/ui/certd-server/src/modules/authority/service/user-service.ts
index c124800a7..5e883c7ae 100644
--- a/packages/ui/certd-server/src/modules/authority/service/user-service.ts
+++ b/packages/ui/certd-server/src/modules/authority/service/user-service.ts
@@ -191,4 +191,17 @@ export class UserService extends BaseService<UserEntity> {
     };
     await this.update(param);
   }
+
+  async delete(ids: any) {
+    if (typeof ids === 'string') {
+      ids = ids.split(',');
+      ids = ids.map(id => parseInt(id));
+    }
+    if (ids instanceof Array) {
+      if (ids.includes(1)) {
+        throw new CommonException('不能删除管理员');
+      }
+    }
+    await super.delete(ids);
+  }
 }
diff --git a/packages/ui/certd-server/src/modules/auto/auto-register-cron.ts b/packages/ui/certd-server/src/modules/auto/auto-register-cron.ts
index 8cfbacba5..da50e3a6c 100644
--- a/packages/ui/certd-server/src/modules/auto/auto-register-cron.ts
+++ b/packages/ui/certd-server/src/modules/auto/auto-register-cron.ts
@@ -8,8 +8,8 @@ export class AutoRegisterCron {
   @Inject()
   pipelineService: PipelineService;
 
-  @Config('preview.enabled')
-  private preview: boolean;
+  @Config('cron.onlyAdminUser')
+  private onlyAdminUser: boolean;
 
   // @Inject()
   // echoPlugin: EchoPlugin;
@@ -19,7 +19,7 @@ export class AutoRegisterCron {
   @Init()
   async init() {
     logger.info('加载定时trigger开始');
-    await this.pipelineService.onStartup(this.immediateTriggerOnce, this.preview);
+    await this.pipelineService.onStartup(this.immediateTriggerOnce, this.onlyAdminUser);
     // logger.info(this.echoPlugin, this.echoPlugin.test);
     // logger.info('加载定时trigger完成');
     //
diff --git a/packages/ui/certd-server/src/modules/pipeline/service/history-service.ts b/packages/ui/certd-server/src/modules/pipeline/service/history-service.ts
index af34254e2..cb8d97a38 100644
--- a/packages/ui/certd-server/src/modules/pipeline/service/history-service.ts
+++ b/packages/ui/certd-server/src/modules/pipeline/service/history-service.ts
@@ -136,10 +136,13 @@ export class HistoryService extends BaseService<HistoryEntity> {
   }
 
   async deleteByIds(ids: number[], userId: number) {
-    await this.repository.delete({
+    const condition: any = {
       id: In(ids),
-      userId,
-    });
+    };
+    if (userId != null) {
+      condition.userId = userId;
+    }
+    await this.repository.delete(condition);
     await this.logService.deleteByHistoryIds(ids);
   }
 
diff --git a/packages/ui/certd-server/src/modules/pipeline/service/pipeline-service.ts b/packages/ui/certd-server/src/modules/pipeline/service/pipeline-service.ts
index 568436c0f..1940e7d00 100644
--- a/packages/ui/certd-server/src/modules/pipeline/service/pipeline-service.ts
+++ b/packages/ui/certd-server/src/modules/pipeline/service/pipeline-service.ts
@@ -149,10 +149,10 @@ export class PipelineService extends BaseService<PipelineEntity> {
   /**
    * 应用启动后初始加载记录
    */
-  async onStartup(immediateTriggerOnce: boolean, preview: boolean) {
+  async onStartup(immediateTriggerOnce: boolean, onlyAdminUser: boolean) {
     logger.info('加载定时trigger开始');
     await this.foreachPipeline(async entity => {
-      if (preview && entity.userId !== 1) {
+      if (onlyAdminUser && entity.userId !== 1) {
         return;
       }
       const pipeline = JSON.parse(entity.content ?? '{}');
diff --git a/packages/ui/certd-server/src/plugins/plugin-aliyun/access/aliyun-access.ts b/packages/ui/certd-server/src/plugins/plugin-aliyun/access/aliyun-access.ts
index dba037ff9..d7ec28ce0 100644
--- a/packages/ui/certd-server/src/plugins/plugin-aliyun/access/aliyun-access.ts
+++ b/packages/ui/certd-server/src/plugins/plugin-aliyun/access/aliyun-access.ts
@@ -11,8 +11,7 @@ export class AliyunAccess {
     component: {
       placeholder: 'accessKeyId',
     },
-    helper:
-      '注意：证书申请，需要dns解析权限；其他阿里云插件，也需要对应的权限，比如证书上传需要证书管理权限',
+    helper: '注意：证书申请，需要dns解析权限；其他阿里云插件，也需要对应的权限，比如证书上传需要证书管理权限',
     required: true,
   })
   accessKeyId = '';
diff --git a/packages/ui/certd-server/src/plugins/plugin-aliyun/plugin/deploy-to-ack-ingress/index.ts b/packages/ui/certd-server/src/plugins/plugin-aliyun/plugin/deploy-to-ack-ingress/index.ts
index bfcbf2bf8..87fbd61ef 100644
--- a/packages/ui/certd-server/src/plugins/plugin-aliyun/plugin/deploy-to-ack-ingress/index.ts
+++ b/packages/ui/certd-server/src/plugins/plugin-aliyun/plugin/deploy-to-ack-ingress/index.ts
@@ -1,4 +1,4 @@
-import { AbstractTaskPlugin, IAccessService, ILogger, IsTaskPlugin, pluginGroups, RunStrategy, TaskInput, utils } from '@certd/pipeline';
+import { AbstractTaskPlugin, IsTaskPlugin, pluginGroups, RunStrategy, TaskInput, utils } from '@certd/pipeline';
 // @ts-ignore
 import { ROAClient } from '@alicloud/pop-core';
 import { AliyunAccess } from '../../access/index.js';
@@ -106,13 +106,7 @@ export class DeployCertToAliyunAckIngressPlugin extends AbstractTaskPlugin {
   })
   accessId!: string;
 
-  accessService!: IAccessService;
-  logger!: ILogger;
-
-  async onInstance(): Promise<void> {
-    this.accessService = this.ctx.accessService;
-    this.logger = this.ctx.logger;
-  }
+  async onInstance(): Promise<void> {}
   async execute(): Promise<void> {
     console.log('开始部署证书到阿里云cdn');
     const { regionId, ingressClass, clusterId, isPrivateIpAddress, cert } = this;
@@ -121,7 +115,7 @@ export class DeployCertToAliyunAckIngressPlugin extends AbstractTaskPlugin {
     const kubeConfigStr = await this.getKubeConfig(client, clusterId, isPrivateIpAddress);
 
     this.logger.info('kubeconfig已成功获取');
-    const k8sClient = new K8sClient(kubeConfigStr,this.logger);
+    const k8sClient = new K8sClient(kubeConfigStr, this.logger);
     const ingressType = ingressClass || 'qcloud';
     if (ingressType === 'qcloud') {
       throw new Error('暂未实现');
diff --git a/packages/ui/certd-server/src/plugins/plugin-aliyun/plugin/deploy-to-cdn/index.ts b/packages/ui/certd-server/src/plugins/plugin-aliyun/plugin/deploy-to-cdn/index.ts
index 05f57a3ce..1ecf4d626 100644
--- a/packages/ui/certd-server/src/plugins/plugin-aliyun/plugin/deploy-to-cdn/index.ts
+++ b/packages/ui/certd-server/src/plugins/plugin-aliyun/plugin/deploy-to-cdn/index.ts
@@ -1,11 +1,4 @@
-import {
-  AbstractTaskPlugin,
-  IAccessService,
-  ILogger,
-  IsTaskPlugin, pluginGroups,
-  RunStrategy,
-  TaskInput,
-} from '@certd/pipeline';
+import { AbstractTaskPlugin, IsTaskPlugin, pluginGroups, RunStrategy, TaskInput } from '@certd/pipeline';
 import dayjs from 'dayjs';
 import Core from '@alicloud/pop-core';
 import RPCClient from '@alicloud/pop-core';
@@ -57,18 +50,10 @@ export class DeployCertToAliyunCDN extends AbstractTaskPlugin {
   })
   accessId!: string;
 
-  accessService!: IAccessService;
-  logger!: ILogger;
-
-  async onInstance() {
-    this.accessService = this.ctx.accessService;
-    this.logger = this.ctx.logger;
-  }
+  async onInstance() {}
   async execute(): Promise<void> {
     console.log('开始部署证书到阿里云cdn');
-    const access = (await this.accessService.getById(
-      this.accessId
-    )) as AliyunAccess;
+    const access = (await this.accessService.getById(this.accessId)) as AliyunAccess;
     const client = this.getClient(access);
     const params = await this.buildParams();
     await this.doRequest(client, params);
@@ -85,8 +70,7 @@ export class DeployCertToAliyunCDN extends AbstractTaskPlugin {
   }
 
   async buildParams() {
-    const CertName =
-      (this.certName ?? 'certd') + '-' + dayjs().format('YYYYMMDDHHmmss');
+    const CertName = (this.certName ?? 'certd') + '-' + dayjs().format('YYYYMMDDHHmmss');
     const cert: any = this.cert;
     return {
       RegionId: 'cn-hangzhou',
@@ -103,11 +87,7 @@ export class DeployCertToAliyunCDN extends AbstractTaskPlugin {
     const requestOption = {
       method: 'POST',
     };
-    const ret: any = await client.request(
-      'SetDomainServerCertificate',
-      params,
-      requestOption
-    );
+    const ret: any = await client.request('SetDomainServerCertificate', params, requestOption);
     this.checkRet(ret);
     this.logger.info('设置cdn证书成功:', ret.RequestId);
   }
diff --git a/packages/ui/certd-server/src/plugins/plugin-aliyun/plugin/upload-to-aliyun/index.ts b/packages/ui/certd-server/src/plugins/plugin-aliyun/plugin/upload-to-aliyun/index.ts
index c8940eaa8..0430aab99 100644
--- a/packages/ui/certd-server/src/plugins/plugin-aliyun/plugin/upload-to-aliyun/index.ts
+++ b/packages/ui/certd-server/src/plugins/plugin-aliyun/plugin/upload-to-aliyun/index.ts
@@ -1,8 +1,7 @@
-import { AbstractTaskPlugin, IAccessService, IsTaskPlugin, pluginGroups, RunStrategy, TaskInput, TaskOutput } from '@certd/pipeline';
+import { AbstractTaskPlugin, IsTaskPlugin, pluginGroups, RunStrategy, TaskInput, TaskOutput } from '@certd/pipeline';
 import Core from '@alicloud/pop-core';
 import { AliyunAccess } from '../../access/index.js';
 import { appendTimeSuffix, checkRet, ZoneOptions } from '../../utils/index.js';
-import { Logger } from 'log4js';
 
 @IsTaskPlugin({
   name: 'uploadCertToAliyun',
@@ -26,8 +25,7 @@ export class UploadCertToAliyun extends AbstractTaskPlugin {
     title: '大区',
     value: 'cn-hangzhou',
     component: {
-      name: 'a-select',
-      mode: 'tags',
+      name: 'a-auto-complete',
       vModel: 'value',
       options: ZoneOptions,
     },
@@ -61,13 +59,7 @@ export class UploadCertToAliyun extends AbstractTaskPlugin {
   })
   aliyunCertId!: string;
 
-  accessService!: IAccessService;
-  logger!: Logger;
-
-  async onInstance() {
-    this.accessService = this.ctx.accessService;
-    this.logger = this.ctx.logger;
-  }
+  async onInstance() {}
 
   async execute(): Promise<void> {
     console.log('开始部署证书到阿里云cdn');
diff --git a/packages/ui/certd-server/src/plugins/plugin-cloudflare/plugins/plugin-deploy-to-cdn.ts b/packages/ui/certd-server/src/plugins/plugin-cloudflare/plugins/plugin-deploy-to-cdn.ts
index cd1dd610e..9b82e665b 100644
--- a/packages/ui/certd-server/src/plugins/plugin-cloudflare/plugins/plugin-deploy-to-cdn.ts
+++ b/packages/ui/certd-server/src/plugins/plugin-cloudflare/plugins/plugin-deploy-to-cdn.ts
@@ -1,4 +1,4 @@
-import { AbstractTaskPlugin, IAccessService, ILogger, IsTaskPlugin, pluginGroups, RunStrategy, TaskInput } from '@certd/pipeline';
+import { AbstractTaskPlugin, IsTaskPlugin, pluginGroups, RunStrategy, TaskInput } from '@certd/pipeline';
 import { CertInfo, CertReader } from '@certd/plugin-cert';
 
 @IsTaskPlugin({
@@ -28,8 +28,8 @@ export class CloudflareDeployToCDNPlugin extends AbstractTaskPlugin {
     title: '选择框',
     component: {
       //前端组件配置，具体配置见组件文档 https://www.antdv.com/components/select-cn
-      name: 'a-select',
-      mode: 'tags',
+      name: 'a-auto-complete',
+      vModel: 'value',
       options: [
         { value: '1', label: '选项1' },
         { value: '2', label: '选项2' },
@@ -71,13 +71,7 @@ export class CloudflareDeployToCDNPlugin extends AbstractTaskPlugin {
   })
   accessId!: string;
 
-  accessService!: IAccessService;
-  logger!: ILogger;
-
-  async onInstance() {
-    this.accessService = this.ctx.accessService;
-    this.logger = this.ctx.logger;
-  }
+  async onInstance() {}
   async execute(): Promise<void> {
     const { select, text, cert, accessId } = this;
     const certReader = new CertReader(cert);
diff --git a/packages/ui/certd-server/src/plugins/plugin-demo/plugins/plugin-test.ts b/packages/ui/certd-server/src/plugins/plugin-demo/plugins/plugin-test.ts
index 719daad8b..48fffd543 100644
--- a/packages/ui/certd-server/src/plugins/plugin-demo/plugins/plugin-test.ts
+++ b/packages/ui/certd-server/src/plugins/plugin-demo/plugins/plugin-test.ts
@@ -1,6 +1,5 @@
-import { AbstractTaskPlugin, IAccessService, ILogger, IsTaskPlugin, pluginGroups, RunStrategy, TaskInput } from '@certd/pipeline';
+import { AbstractTaskPlugin, IsTaskPlugin, pluginGroups, RunStrategy, TaskInput } from '@certd/pipeline';
 import { CertInfo, CertReader } from '@certd/plugin-cert';
-import { K8sClient } from '@certd/lib-k8s';
 
 @IsTaskPlugin({
   name: 'demoTest',
@@ -28,8 +27,8 @@ export class DemoTestPlugin extends AbstractTaskPlugin {
     title: '选择框',
     component: {
       //前端组件配置，具体配置见组件文档 https://www.antdv.com/components/select-cn
-      name: 'a-select',
-      mode: 'tags',
+      name: 'a-auto-complete',
+      vModel: 'value',
       options: [
         { value: '1', label: '选项1' },
         { value: '2', label: '选项2' },
@@ -55,7 +54,7 @@ export class DemoTestPlugin extends AbstractTaskPlugin {
     component: {
       name: 'pi-output-selector',
     },
-    required: true,
+    // required: true,
   })
   cert!: CertInfo;
 
@@ -67,31 +66,33 @@ export class DemoTestPlugin extends AbstractTaskPlugin {
       name: 'pi-access-selector',
       type: 'demo', //固定授权类型
     },
-    rules: [{ required: true, message: '此项必填' }],
+    // rules: [{ required: true, message: '此项必填' }],
   })
   accessId!: string;
 
-  accessService!: IAccessService;
-  logger!: ILogger;
-
-  async onInstance() {
-    this.accessService = this.ctx.accessService;
-    this.logger = this.ctx.logger;
-  }
+  async onInstance() {}
   async execute(): Promise<void> {
     const { select, text, cert, accessId } = this;
-    const certReader = new CertReader(cert);
-    const access = await this.accessService.getById(accessId);
-    this.logger.debug('access', access);
-    this.logger.debug('certReader', certReader);
+
+    try {
+      const access = await this.accessService.getById(accessId);
+      this.logger.debug('access', access);
+    } catch (e) {
+      this.logger.error('获取授权失败', e);
+    }
+
+    try {
+      const certReader = new CertReader(cert);
+      this.logger.debug('certReader', certReader);
+    } catch (e) {
+      this.logger.error('读取crt失败', e);
+    }
+
     this.logger.info('DemoTestPlugin execute');
     this.logger.info('text:', text);
     this.logger.info('select:', select);
     this.logger.info('switch:', this.switch);
     this.logger.info('授权id:', accessId);
-    //TODO 这里实现你要部署的执行方法
-
-    new K8sClient('111', null);
   }
 }
 //TODO 这里实例化插件，进行注册
diff --git a/packages/ui/certd-server/src/plugins/plugin-host/plugin/host-shell-execute/index.ts b/packages/ui/certd-server/src/plugins/plugin-host/plugin/host-shell-execute/index.ts
index 1b9b7361e..5194c1dda 100644
--- a/packages/ui/certd-server/src/plugins/plugin-host/plugin/host-shell-execute/index.ts
+++ b/packages/ui/certd-server/src/plugins/plugin-host/plugin/host-shell-execute/index.ts
@@ -1,4 +1,4 @@
-import { AbstractTaskPlugin, IAccessService, ILogger, IsTaskPlugin, pluginGroups, RunStrategy, TaskInput } from '@certd/pipeline';
+import { AbstractTaskPlugin, IsTaskPlugin, pluginGroups, RunStrategy, TaskInput } from '@certd/pipeline';
 import { SshClient } from '../../lib/ssh.js';
 
 @IsTaskPlugin({
@@ -34,12 +34,7 @@ export class HostShellExecutePlugin extends AbstractTaskPlugin {
   })
   script!: string;
 
-  accessService!: IAccessService;
-  logger!: ILogger;
-  async onInstance() {
-    this.accessService = this.ctx.accessService;
-    this.logger = this.ctx.logger;
-  }
+  async onInstance() {}
   async execute(): Promise<void> {
     const { script, accessId } = this;
     const connectConf = await this.accessService.getById(accessId);
diff --git a/packages/ui/certd-server/src/plugins/plugin-host/plugin/upload-to-host/index.ts b/packages/ui/certd-server/src/plugins/plugin-host/plugin/upload-to-host/index.ts
index 4a9d1cdb6..4397205ae 100644
--- a/packages/ui/certd-server/src/plugins/plugin-host/plugin/upload-to-host/index.ts
+++ b/packages/ui/certd-server/src/plugins/plugin-host/plugin/upload-to-host/index.ts
@@ -1,4 +1,4 @@
-import { AbstractTaskPlugin, IAccessService, ILogger, IsTaskPlugin, pluginGroups, RunStrategy, TaskInput, TaskOutput } from '@certd/pipeline';
+import { AbstractTaskPlugin, IsTaskPlugin, pluginGroups, RunStrategy, TaskInput, TaskOutput } from '@certd/pipeline';
 import { SshClient } from '../../lib/ssh.js';
 import { CertInfo, CertReader } from '@certd/plugin-cert';
 import * as fs from 'fs';
@@ -86,13 +86,7 @@ export class UploadCertToHostPlugin extends AbstractTaskPlugin {
   })
   hostKeyPath!: string;
 
-  accessService!: IAccessService;
-  logger!: ILogger;
-
-  async onInstance() {
-    this.accessService = this.ctx.accessService;
-    this.logger = this.ctx.logger;
-  }
+  async onInstance() {}
 
   copyFile(srcFile: string, destFile: string) {
     const dir = destFile.substring(0, destFile.lastIndexOf('/'));
diff --git a/packages/ui/certd-server/src/plugins/plugin-other/access/index.ts b/packages/ui/certd-server/src/plugins/plugin-other/access/index.ts
new file mode 100644
index 000000000..e4a8d690c
--- /dev/null
+++ b/packages/ui/certd-server/src/plugins/plugin-other/access/index.ts
@@ -0,0 +1 @@
+export * from './k8s-access.js';
diff --git a/packages/ui/certd-server/src/plugins/plugin-other/access/k8s-access.ts b/packages/ui/certd-server/src/plugins/plugin-other/access/k8s-access.ts
new file mode 100644
index 000000000..355fc8a9a
--- /dev/null
+++ b/packages/ui/certd-server/src/plugins/plugin-other/access/k8s-access.ts
@@ -0,0 +1,19 @@
+import { IsAccess, AccessInput } from '@certd/pipeline';
+
+@IsAccess({
+  name: 'k8s',
+  title: 'k8s授权',
+  desc: '',
+})
+export class K8sAccess {
+  @AccessInput({
+    title: 'kubeconfig',
+    component: {
+      placeholder: 'kubeconfig',
+    },
+    required: true,
+  })
+  kubeconfig = '';
+}
+
+new K8sAccess();
diff --git a/packages/ui/certd-server/src/plugins/plugin-tencent/access/dnspod-access.ts b/packages/ui/certd-server/src/plugins/plugin-tencent/access/dnspod-access.ts
index 59eb81f40..198871286 100644
--- a/packages/ui/certd-server/src/plugins/plugin-tencent/access/dnspod-access.ts
+++ b/packages/ui/certd-server/src/plugins/plugin-tencent/access/dnspod-access.ts
@@ -10,8 +10,7 @@ export class DnspodAccess {
     title: '端点',
     component: {
       placeholder: 'endpoint',
-      name: 'a-select',
-      mode: 'tags',
+      name: 'a-auto-complete',
       vModel: 'value',
       options: [
         { value: 'https://dnsapi.cn', label: '中国站' },
diff --git a/packages/ui/certd-server/src/plugins/plugin-tencent/plugin/deploy-to-cdn/index.ts b/packages/ui/certd-server/src/plugins/plugin-tencent/plugin/deploy-to-cdn/index.ts
index ad148ed09..851d493e3 100644
--- a/packages/ui/certd-server/src/plugins/plugin-tencent/plugin/deploy-to-cdn/index.ts
+++ b/packages/ui/certd-server/src/plugins/plugin-tencent/plugin/deploy-to-cdn/index.ts
@@ -1,4 +1,4 @@
-import { AbstractTaskPlugin, IAccessService, ILogger, IsTaskPlugin, pluginGroups, RunStrategy, TaskInput } from '@certd/pipeline';
+import { AbstractTaskPlugin, IsTaskPlugin, pluginGroups, RunStrategy, TaskInput } from '@certd/pipeline';
 import tencentcloud from 'tencentcloud-sdk-nodejs';
 import { TencentAccess } from '../../access/index.js';
 import { CertInfo } from '@certd/plugin-cert';
@@ -59,14 +59,7 @@ export class DeployToCdnPlugin extends AbstractTaskPlugin {
   // })
   // endpoint!: string;
 
-  accessService!: IAccessService;
-
-  logger!: ILogger;
-
-  async onInstance() {
-    this.accessService = this.ctx.accessService;
-    this.logger = this.ctx.logger;
-  }
+  async onInstance() {}
 
   async execute(): Promise<void> {
     const accessProvider: TencentAccess = (await this.accessService.getById(this.accessId)) as TencentAccess;
diff --git a/packages/ui/certd-server/src/plugins/plugin-tencent/plugin/deploy-to-clb/index.ts b/packages/ui/certd-server/src/plugins/plugin-tencent/plugin/deploy-to-clb/index.ts
index 6bbfcdea2..0f9a09f69 100644
--- a/packages/ui/certd-server/src/plugins/plugin-tencent/plugin/deploy-to-clb/index.ts
+++ b/packages/ui/certd-server/src/plugins/plugin-tencent/plugin/deploy-to-clb/index.ts
@@ -1,4 +1,4 @@
-import { AbstractTaskPlugin, IAccessService, ILogger, IsTaskPlugin, pluginGroups, RunStrategy, TaskInput, utils } from '@certd/pipeline';
+import { AbstractTaskPlugin, IsTaskPlugin, pluginGroups, RunStrategy, TaskInput, utils } from '@certd/pipeline';
 import tencentcloud from 'tencentcloud-sdk-nodejs';
 import { TencentAccess } from '../../access/index.js';
 import dayjs from 'dayjs';
@@ -17,10 +17,9 @@ import dayjs from 'dayjs';
 export class DeployToClbPlugin extends AbstractTaskPlugin {
   @TaskInput({
     title: '大区',
-    value: 'ap-guangzhou',
     component: {
-      name: 'a-select',
-      mode: 'tags',
+      name: 'a-auto-complete',
+      vModel: 'value',
       options: [
         { value: 'ap-guangzhou' },
         { value: 'ap-beijing' },
@@ -93,13 +92,7 @@ export class DeployToClbPlugin extends AbstractTaskPlugin {
   })
   accessId!: string;
 
-  accessService!: IAccessService;
-  logger!: ILogger;
-
-  async onInstance() {
-    this.accessService = this.ctx.accessService;
-    this.logger = this.ctx.logger;
-  }
+  async onInstance() {}
   async execute(): Promise<void> {
     const accessProvider = (await this.accessService.getById(this.accessId)) as TencentAccess;
     const client = this.getClient(accessProvider, this.region);
diff --git a/packages/ui/certd-server/src/plugins/plugin-tencent/plugin/deploy-to-tke-ingress/index.ts b/packages/ui/certd-server/src/plugins/plugin-tencent/plugin/deploy-to-tke-ingress/index.ts
index 34aa5b7c6..5382a8c27 100644
--- a/packages/ui/certd-server/src/plugins/plugin-tencent/plugin/deploy-to-tke-ingress/index.ts
+++ b/packages/ui/certd-server/src/plugins/plugin-tencent/plugin/deploy-to-tke-ingress/index.ts
@@ -1,8 +1,7 @@
-import { AbstractTaskPlugin, IAccessService, IsTaskPlugin, pluginGroups, RunStrategy, TaskInput, utils } from '@certd/pipeline';
+import { AbstractTaskPlugin, IsTaskPlugin, pluginGroups, RunStrategy, TaskInput, utils } from '@certd/pipeline';
 import tencentcloud from 'tencentcloud-sdk-nodejs';
 import { K8sClient } from '@certd/lib-k8s';
 import dayjs from 'dayjs';
-import { Logger } from 'log4js';
 
 @IsTaskPlugin({
   name: 'DeployCertToTencentTKEIngress',
@@ -38,8 +37,10 @@ export class DeployCertToTencentTKEIngressPlugin extends AbstractTaskPlugin {
 
   @TaskInput({
     title: 'ingress类型',
+    value: 'qcloud',
     component: {
-      name: 'a-select',
+      name: 'a-auto-complete',
+      vModel: 'value',
       options: [{ value: 'qcloud' }, { value: 'nginx' }],
     },
     helper: '可选 qcloud / nginx',
@@ -89,12 +90,7 @@ export class DeployCertToTencentTKEIngressPlugin extends AbstractTaskPlugin {
   })
   cert!: any;
 
-  logger!: Logger;
-  accessService!: IAccessService;
-  async onInstance() {
-    this.accessService = this.ctx.accessService;
-    this.logger = this.ctx.logger;
-  }
+  async onInstance() {}
   async execute(): Promise<void> {
     const accessProvider = await this.accessService.getById(this.accessId);
     const tkeClient = this.getTkeClient(accessProvider, this.region);
diff --git a/packages/ui/certd-server/src/plugins/plugin-tencent/plugin/upload-to-tencent/index.ts b/packages/ui/certd-server/src/plugins/plugin-tencent/plugin/upload-to-tencent/index.ts
index ad9d90bbd..f409074be 100644
--- a/packages/ui/certd-server/src/plugins/plugin-tencent/plugin/upload-to-tencent/index.ts
+++ b/packages/ui/certd-server/src/plugins/plugin-tencent/plugin/upload-to-tencent/index.ts
@@ -1,4 +1,4 @@
-import { AbstractTaskPlugin, IAccessService, ILogger, IsTaskPlugin, pluginGroups, RunStrategy, TaskInput, TaskOutput } from '@certd/pipeline';
+import { AbstractTaskPlugin, IsTaskPlugin, pluginGroups, RunStrategy, TaskInput, TaskOutput } from '@certd/pipeline';
 import tencentcloud from 'tencentcloud-sdk-nodejs';
 import dayjs from 'dayjs';
 
@@ -43,13 +43,7 @@ export class UploadToTencentPlugin extends AbstractTaskPlugin {
   })
   tencentCertId?: string;
 
-  accessService!: IAccessService;
-  logger!: ILogger;
-
-  async onInstance() {
-    this.accessService = this.ctx.accessService;
-    this.logger = this.ctx.logger;
-  }
+  async onInstance() {}
 
   async execute(): Promise<void> {
     const { accessId, name, cert } = this;