From ab8fbaf21dc144d63e399e7d235a56cddc29ee5e Mon Sep 17 00:00:00 2001
From: xiaojunnuo <xiaojunnuo@qq.com>
Date: Tue, 16 Dec 2025 00:34:32 +0800
Subject: [PATCH] =?UTF-8?q?chore:=20=E4=BF=AE=E5=A4=8D=E6=B8=85=E9=99=A4?=
 =?UTF-8?q?=E5=AE=9A=E6=97=B6=E4=BB=BB=E5=8A=A1=E6=9C=AA=E7=94=9F=E6=95=88?=
 =?UTF-8?q?=E7=9A=84bug?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 packages/ui/certd-server/src/modules/cron/cron.ts             | 4 ++--
 .../src/modules/pipeline/service/pipeline-service.ts          | 2 ++
 2 files changed, 4 insertions(+), 2 deletions(-)

diff --git a/packages/ui/certd-server/src/modules/cron/cron.ts b/packages/ui/certd-server/src/modules/cron/cron.ts
index fc2373271..303a02644 100644
--- a/packages/ui/certd-server/src/modules/cron/cron.ts
+++ b/packages/ui/certd-server/src/modules/cron/cron.ts
@@ -1,5 +1,5 @@
 import parser from 'cron-parser';
-import { ILogger } from '@certd/basic';
+import { ILogger, logger } from '@certd/basic';
 
 export type CronTaskReq = {
   /**
@@ -52,7 +52,7 @@ export class Cron {
 
   queue: CronTask[] = [];
   constructor(opts: any) {
-    this.logger = opts.logger;
+    this.logger = opts.logger || logger;
     this.immediateTriggerOnce = opts.immediateTriggerOnce;
   }
 
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 ce56a832f..85b959305 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
@@ -441,6 +441,7 @@ export class PipelineService extends BaseService<PipelineEntity> {
       pipeline = await this.info(id);
     } else {
       pipeline = id;
+      id = pipeline.id;
     }
     if (!pipeline) {
       return;
@@ -456,6 +457,7 @@ export class PipelineService extends BaseService<PipelineEntity> {
   removeCron(pipelineId, trigger) {
     const name = this.buildCronKey(pipelineId, trigger.id);
     this.cron.remove(name);
+    logger.info("当前定时器数量：", this.cron.getTaskSize());
   }
 
   registerCron(pipelineId, trigger) {