From 29906ec057869489e39d1d6a11a3fd5dc72848ce Mon Sep 17 00:00:00 2001
From: xiaojunnuo <xiaojunnuo@qq.com>
Date: Wed, 25 Jun 2025 18:18:57 +0800
Subject: [PATCH] =?UTF-8?q?chore:=20=E6=A8=A1=E7=89=88=E5=88=9B=E5=BB=BA?=
 =?UTF-8?q?=E6=B5=81=E6=B0=B4=E7=BA=BF?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../views/certd/pipeline/certd-form/use.tsx   | 46 +++++++++----------
 .../src/views/certd/pipeline/template/api.ts  |  8 ++++
 .../views/certd/pipeline/template/crud.tsx    |  8 +++-
 .../views/certd/pipeline/template/form.vue    |  9 +++-
 .../src/views/certd/pipeline/template/use.tsx | 41 ++++++++++++++++-
 .../db/migration/v10026__template.sql         |  4 +-
 .../user/pipeline/template-controller.ts      |  6 +++
 .../src/modules/pipeline/entity/pipeline.ts   |  5 +-
 .../src/modules/pipeline/entity/template.ts   |  2 +
 .../pipeline/service/pipeline-service.ts      |  2 +-
 .../pipeline/service/template-service.ts      | 34 +++++++++++---
 11 files changed, 127 insertions(+), 38 deletions(-)

diff --git a/packages/ui/certd-client/src/views/certd/pipeline/certd-form/use.tsx b/packages/ui/certd-client/src/views/certd/pipeline/certd-form/use.tsx
index 508175d6..9238e2fd 100644
--- a/packages/ui/certd-client/src/views/certd/pipeline/certd-form/use.tsx
+++ b/packages/ui/certd-client/src/views/certd/pipeline/certd-form/use.tsx
@@ -12,6 +12,25 @@ import { PluginGroup, usePluginStore } from "/@/store/plugin";
 import { createNotificationApi } from "/@/views/certd/notification/api";
 import GroupSelector from "../group/group-selector.vue";
 
+export function fillPipelineByDefaultForm(pipeline: any, form: any) {
+  const triggers = [];
+  if (form.triggerCron) {
+    triggers.push({ title: "定时触发", type: "timer", props: { cron: form.triggerCron } });
+  }
+  const notifications = [];
+  if (form.notification != null) {
+    notifications.push({
+      type: "custom",
+      when: ["error", "turnToSuccess", "success"],
+      notificationId: form.notification,
+      title: form.notificationTarget?.name || "自定义通知",
+    });
+  }
+  pipeline.triggers = triggers;
+  pipeline.notifications = notifications;
+  return pipeline;
+}
+
 export function setRunnableIds(pipeline: any) {
   const idMap: any = {};
   function createId(oldId: any) {
@@ -244,21 +263,8 @@ export function useCertPipelineCreator() {
     async function doSubmit({ form }: any) {
       // const certDetail = readCertDetail(form.cert.crt);
       // 添加certd pipeline
-      const triggers = [];
-      if (form.triggerCron) {
-        triggers.push({ title: "定时触发", type: "timer", props: { cron: form.triggerCron } });
-      }
-      const notifications = [];
-      if (form.notification != null) {
-        notifications.push({
-          type: "custom",
-          when: ["error", "turnToSuccess", "success"],
-          notificationId: form.notification,
-          title: form.notificationTarget?.name || "自定义通知",
-        });
-      }
       const pluginInput = omit(form, ["triggerCron", "notification", "notificationTarget", "certApplyPlugin", "groupId"]);
-      let pipeline = {
+      let pipeline: any = {
         title: form.domains[0] + "证书自动化",
         runnableType: "pipeline",
         stages: [
@@ -288,17 +294,11 @@ export function useCertPipelineCreator() {
             ],
           },
         ],
-        triggers,
-        notifications,
       };
-      pipeline = setRunnableIds(pipeline);
 
-      /**
-       *  // cert: 证书; backup: 备份; custom:自定义;
-       *   type: string;
-       *   // custom: 自定义; monitor: 监控;
-       *   from: string;
-       */
+      pipeline = fillPipelineByDefaultForm(pipeline, form);
+
+      pipeline = setRunnableIds(pipeline);
       const groupId = form.groupId;
       const id = await api.Save({
         title: pipeline.title,
diff --git a/packages/ui/certd-client/src/views/certd/pipeline/template/api.ts b/packages/ui/certd-client/src/views/certd/pipeline/template/api.ts
index 121351f3..7912310d 100644
--- a/packages/ui/certd-client/src/views/certd/pipeline/template/api.ts
+++ b/packages/ui/certd-client/src/views/certd/pipeline/template/api.ts
@@ -56,4 +56,12 @@ export const templateApi = {
       method: "post",
     });
   },
+
+  async CreatePipelineByTemplate(data: any) {
+    return await request({
+      url: apiPrefix + "/createPipelineByTemplate",
+      method: "post",
+      data,
+    });
+  },
 };
diff --git a/packages/ui/certd-client/src/views/certd/pipeline/template/crud.tsx b/packages/ui/certd-client/src/views/certd/pipeline/template/crud.tsx
index 7153b138..96a4990f 100644
--- a/packages/ui/certd-client/src/views/certd/pipeline/template/crud.tsx
+++ b/packages/ui/certd-client/src/views/certd/pipeline/template/crud.tsx
@@ -146,8 +146,12 @@ export default function ({ crudExpose, context }: CreateCrudOptionsProps): Creat
                 toolbar: {
                   show: false,
                 },
-                tabs: {
-                  name: "type",
+                columns: {
+                  title: {
+                    column: {
+                      cellRender: null,
+                    },
+                  },
                 },
               },
             },
diff --git a/packages/ui/certd-client/src/views/certd/pipeline/template/form.vue b/packages/ui/certd-client/src/views/certd/pipeline/template/form.vue
index 46ea4934..31e0686c 100644
--- a/packages/ui/certd-client/src/views/certd/pipeline/template/form.vue
+++ b/packages/ui/certd-client/src/views/certd/pipeline/template/form.vue
@@ -1,5 +1,5 @@
 <template>
-  <a-form ref="templateFormRef" class="template-form w-full" :model="templateForm" :label-col="labelCol" :wrapper-col="wrapperCol">
+  <a-form ref="formRef" class="template-form w-full" :model="templateForm" :label-col="labelCol" :wrapper-col="wrapperCol">
     <template v-for="(item, key) in templateFormColumns" :key="key">
       <fs-form-item v-if="item.show !== false" :model-value="get(templateForm, key)" :item="item" :get-context-fn="getScopeFunc(key)" @update:model-value="set(templateForm, key, $event)" />
     </template>
@@ -14,7 +14,7 @@ import { usePluginStore } from "/@/store/plugin";
 defineOptions({
   name: "TemplateForm",
 });
-
+const formRef = ref();
 const props = defineProps<{
   input: any;
   pipeline: any;
@@ -61,9 +61,14 @@ function getScopeFunc(inputKey: string) {
   };
 }
 
+async function validate() {
+  return await formRef.value.validate();
+}
+
 defineExpose({
   getForm() {
     return templateForm;
   },
+  validate,
 });
 </script>
diff --git a/packages/ui/certd-client/src/views/certd/pipeline/template/use.tsx b/packages/ui/certd-client/src/views/certd/pipeline/template/use.tsx
index 38eb2b3f..3271c6d4 100644
--- a/packages/ui/certd-client/src/views/certd/pipeline/template/use.tsx
+++ b/packages/ui/certd-client/src/views/certd/pipeline/template/use.tsx
@@ -1,10 +1,12 @@
 import { dict, useFormWrapper } from "@fast-crud/fast-crud";
-import { checkPipelineLimit } from "/@/views/certd/pipeline/utils";
+import { checkPipelineLimit, eachSteps } from "/@/views/certd/pipeline/utils";
 import { templateApi } from "/@/views/certd/pipeline/template/api";
 import TemplateForm from "./form.vue";
 import NotificationSelector from "/@/views/certd/notification/notification-selector/index.vue";
 import GroupSelector from "/@/views/certd/pipeline/group/group-selector.vue";
 import { ref } from "vue";
+import { fillPipelineByDefaultForm } from "/@/views/certd/pipeline/certd-form/use";
+import { cloneDeep } from "lodash-es";
 
 export function useTemplate() {
   const { openCrudFormDialog } = useFormWrapper();
@@ -38,8 +40,43 @@ export function useTemplate() {
 
     const randomHour = Math.floor(Math.random() * 6);
     const randomMin = Math.floor(Math.random() * 60);
+    const templateFormRef = ref();
+
+    async function onSubmit(opts: { form: any }) {
+      const form = opts.form;
+      await templateFormRef.value.validate();
+
+      const tempInputs = templateFormRef.value.getFormData();
+
+      let newPipeline = cloneDeep(pipeline);
+      newPipeline = fillPipelineByDefaultForm(newPipeline, form);
+      //填充模版参数
+      const steps: any = {};
+      eachSteps(newPipeline, (step: any) => {
+        steps[step.id] = step;
+      });
+
+      for (const inputKey in tempInputs) {
+        const [stepId, key] = inputKey.split(".");
+        const step = steps[stepId];
+        if (step) {
+          step.input[key] = tempInputs[inputKey];
+        }
+      }
+
+      const groupId = form.groupId;
+      const { id } = await templateApi.CreatePipelineByTemplate({
+        title: form.title,
+        content: JSON.stringify(newPipeline),
+        keepHistoryCount: 30,
+        groupId,
+        templateId: detail.template.id,
+      });
+    }
+
     const crudOptions = {
       form: {
+        onSubmit,
         wrapper: {
           title: `从模版<${detail.template.title}>创建流水线`,
           width: 1100,
@@ -47,7 +84,7 @@ export function useTemplate() {
             "form-body-top": () => {
               return (
                 <div class={"w-full flex"}>
-                  <TemplateForm input={templateProps.input} pipeline={pipeline} />
+                  <TemplateForm ref={templateFormRef} input={templateProps.input} pipeline={pipeline} />
                 </div>
               );
             },
diff --git a/packages/ui/certd-server/db/migration/v10026__template.sql b/packages/ui/certd-server/db/migration/v10026__template.sql
index 793f704d..254c2d25 100644
--- a/packages/ui/certd-server/db/migration/v10026__template.sql
+++ b/packages/ui/certd-server/db/migration/v10026__template.sql
@@ -6,6 +6,7 @@ CREATE TABLE "pi_template"
   "title"       varchar(1024),
   "content"     text,
   "order"       integer,
+  "desc"        varchar(1024),
   "disabled"    boolean  NOT NULL DEFAULT (false),
   "create_time" datetime NOT NULL DEFAULT (CURRENT_TIMESTAMP),
   "update_time" datetime NOT NULL DEFAULT (CURRENT_TIMESTAMP)
@@ -14,5 +15,6 @@ CREATE TABLE "pi_template"
 CREATE INDEX "index_template_user_id" ON "pi_template" ("user_id");
 CREATE INDEX "index_template_pipeline_id" ON "pi_template" ("pipeline_id");
 
-ALTER TABLE pi_pipeline ADD COLUMN "template_id" integer DEFAULT 0;
+ALTER TABLE pi_pipeline ADD COLUMN "template_id" integer DEFAULT (0);
+ALTER TABLE pi_pipeline ADD COLUMN "is_template" boolean DEFAULT (0);
 CREATE INDEX "index_pipeline_template_id" ON "pi_pipeline" ("template_id");
diff --git a/packages/ui/certd-server/src/controller/user/pipeline/template-controller.ts b/packages/ui/certd-server/src/controller/user/pipeline/template-controller.ts
index 9abee545..cd665bb9 100644
--- a/packages/ui/certd-server/src/controller/user/pipeline/template-controller.ts
+++ b/packages/ui/certd-server/src/controller/user/pipeline/template-controller.ts
@@ -74,4 +74,10 @@ export class TemplateController extends CrudController<TemplateService> {
     const detail = await this.service.detail(id, this.getUserId());
     return this.ok(detail);
   }
+  @Post('/createPipelineByTemplate', { summary: Constants.per.authOnly })
+  async createPipelineByTemplate(@Body(ALL) body: any) {
+    body.userId = this.getUserId();
+    const res = await this.service.createPipelineByTemplate(body);
+    return this.ok(res);
+  }
 }
diff --git a/packages/ui/certd-server/src/modules/pipeline/entity/pipeline.ts b/packages/ui/certd-server/src/modules/pipeline/entity/pipeline.ts
index bea1b45d..6387ef94 100644
--- a/packages/ui/certd-server/src/modules/pipeline/entity/pipeline.ts
+++ b/packages/ui/certd-server/src/modules/pipeline/entity/pipeline.ts
@@ -37,9 +37,12 @@ export class PipelineEntity {
   @Column({ comment: '来源', nullable: true, default: '' })
   from: string;
 
-  @Column({ name:"template_id", comment: '是否模版', nullable: true, default: '' })
+  @Column({ name:"template_id", comment: '关联模版id', nullable: true, default: 0 })
   templateId: number;
 
+  @Column({ name:"is_template", comment: '是否模版', nullable: true, default: false })
+  isTemplate: boolean;
+
   @Column({
     name: 'last_history_time',
     comment: '最后一次执行时间',
diff --git a/packages/ui/certd-server/src/modules/pipeline/entity/template.ts b/packages/ui/certd-server/src/modules/pipeline/entity/template.ts
index caf83ec5..418d0910 100644
--- a/packages/ui/certd-server/src/modules/pipeline/entity/template.ts
+++ b/packages/ui/certd-server/src/modules/pipeline/entity/template.ts
@@ -23,6 +23,8 @@ export class TemplateEntity {
 
   @Column({ name: 'title', comment: '标题' })
   title: string;
+  @Column({ name: 'desc', comment: '说明' })
+  desc: string;
 
   @Column({ comment: '配置', length: 40960 })
   content: string;
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 7fa879a6..1c3b0e91 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
@@ -119,7 +119,7 @@ export class PipelineService extends BaseService<PipelineEntity> {
 
   async page(pageReq: PageReq<PipelineEntity>) {
     //模版流水线不要被查询出来
-    set(pageReq,"query.templateId",0)
+    set(pageReq,"query.isTemplate",false)
     const result = await super.page(pageReq);
     await this.fillLastVars(result.records);
 
diff --git a/packages/ui/certd-server/src/modules/pipeline/service/template-service.ts b/packages/ui/certd-server/src/modules/pipeline/service/template-service.ts
index 441967ad..2e80e016 100644
--- a/packages/ui/certd-server/src/modules/pipeline/service/template-service.ts
+++ b/packages/ui/certd-server/src/modules/pipeline/service/template-service.ts
@@ -45,10 +45,11 @@ export class TemplateService extends BaseService<TemplateEntity> {
       let newPipeline = cloneDeep(pipelineEntity)
       //创建pipeline模版
       newPipeline.id = undefined;
-      newPipeline.title = template.title+"模版流水线"
+      newPipeline.title = template.title + "模版流水线"
       newPipeline.templateId = template.id
+      newPipeline.isTemplate = true
 
-      const pipelineJson:Pipeline = JSON.parse(newPipeline.content)
+      const pipelineJson: Pipeline = JSON.parse(newPipeline.content)
       delete pipelineJson.triggers
       pipelineJson.id = template.id
       pipelineJson.userId = template.userId
@@ -56,7 +57,7 @@ export class TemplateService extends BaseService<TemplateEntity> {
       newPipeline.content = JSON.stringify(pipelineJson)
       newPipeline = await tx.getRepository(PipelineEntity).save(newPipeline)
 
-      const update :any= {}
+      const update: any = {}
       update.id = template.id
       update.pipelineId = newPipeline.id
       await tx.getRepository(TemplateEntity).save(update)
@@ -86,19 +87,40 @@ export class TemplateService extends BaseService<TemplateEntity> {
       pipeline,
     }
   }
+
   async batchDelete(ids: number[], userId: number) {
 
-    const where :any= {
+    const where: any = {
       id: In(ids),
     }
     if (userId > 0) {
       where.userId = userId
     }
-    const list = await this.getRepository().find({where })
+    const list = await this.getRepository().find({where})
     ids = list.map(item => item.id)
     const pipelineIds = list.map(item => item.pipelineId)
     await this.delete(ids);
-    await this.pipelineService.batchDelete(pipelineIds,userId)
+    await this.pipelineService.batchDelete(pipelineIds, userId)
+  }
+
+  async createPipelineByTemplate(body: PipelineEntity) {
+    const templateId = body.templateId;
+    const template = await this.info(templateId);
+
+    if (!template && template.userId !== body.userId) {
+      throw new Error('模板不存在');
+    }
+
+    const tempPipeline = await this.pipelineService.info(template.pipelineId)
+
+    const newPipeline = {
+      type: tempPipeline.type,
+      from : "template",
+      keepHistoryCount: tempPipeline.keepHistoryCount,
+      ... body,
+    }
+
+    await this.pipelineService.save(newPipeline)
   }
 }