From 1c291ce6c0f04aa06185231470825aaa2e4f47be Mon Sep 17 00:00:00 2001 From: hailin Date: Mon, 23 Feb 2026 05:03:04 -0800 Subject: [PATCH] =?UTF-8?q?fix:=20Scheduler=20=E7=94=A8=20slug=20=E6=9E=84?= =?UTF-8?q?=E5=BB=BA=20tenant=20schema=20=E5=90=8D?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit tenant schema 是 it0_t_{slug}（如 it0_t_default），不是 it0_t_{uuid}。 Co-Authored-By: Claude Opus 4.6 --- .../src/domain/services/standing-order-executor.service.ts | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/packages/services/ops-service/src/domain/services/standing-order-executor.service.ts b/packages/services/ops-service/src/domain/services/standing-order-executor.service.ts index 59b800b..2c10fb5 100644 --- a/packages/services/ops-service/src/domain/services/standing-order-executor.service.ts +++ b/packages/services/ops-service/src/domain/services/standing-order-executor.service.ts @@ -60,10 +60,10 @@ export class StandingOrderExecutorService implements OnModuleInit { */ @Cron('*/1 * * * *') async scanCronOrders(): Promise { - let tenants: { id: string; name: string }[]; + let tenants: { id: string; name: string; slug: string }[]; try { const result = await this.dataSource.query( - `SELECT id, name FROM public.tenants WHERE status = 'active'`, + `SELECT id, name, slug FROM public.tenants WHERE status = 'active'`, ); tenants = result; } catch (err) { @@ -81,7 +81,7 @@ export class StandingOrderExecutorService implements OnModuleInit { tenantId: tenant.id, tenantName: tenant.name, plan: 'pro', - schemaName: `it0_t_${tenant.id}`, + schemaName: `it0_t_${tenant.slug}`, }, async () => { const activeOrders =