From e73a4675f3ea24f4450cd1ddd9a483dec2052332 Mon Sep 17 00:00:00 2001 From: huang <1724659546@qq.com> Date: Thu, 6 Nov 2025 16:34:50 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AEbug?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- design/health-check-routing/index.md | 6 +++- internal/core/data_initializer.go | 45 +++++++++++++++------------- 2 files changed, 29 insertions(+), 22 deletions(-) diff --git a/design/health-check-routing/index.md b/design/health-check-routing/index.md index e149e02..3eabffd 100644 --- a/design/health-check-routing/index.md +++ b/design/health-check-routing/index.md @@ -8,4 +8,8 @@ http://git.huangwc.com/pig/pig-farm-controller/issues/48 # 方案 -增加三个对应路由 \ No newline at end of file +增加两个对应路由 + +# 其他修复 + +修复系统启动时系统计划更新和触发器刷新冲突的问题 \ No newline at end of file diff --git a/internal/core/data_initializer.go b/internal/core/data_initializer.go index 25d2f8d..5a4e93d 100644 --- a/internal/core/data_initializer.go +++ b/internal/core/data_initializer.go @@ -15,24 +15,35 @@ const ( ) // initializeState 在应用启动时准备其初始数据状态。 -// 这包括清理任何因上次异常关闭而留下的悬空任务或请求。 +// 它遵循一个严格的顺序：清理 -> 更新 -> 刷新，以确保数据的一致性和正确性。 func (app *Application) initializeState(ctx context.Context) error { appCtx, logger := logs.Trace(ctx, app.Ctx, "InitializeState") - // 初始化预定义系统计划 (致命错误) - if err := app.initializeSystemPlans(ctx); err != nil { - return fmt.Errorf("初始化预定义系统计划失败: %w", err) + + // 1. 清理所有上次运行时遗留的待执行任务和相关日志。 + // 这一步必须在任何可能修改计划结构的操作之前执行，以避免外键约束冲突。 + if err := app.cleanupStaleTasksAndLogs(appCtx); err != nil { + return fmt.Errorf("清理过期的任务及日志失败: %w", err) } - // 清理待采集任务 (非致命错误) + // 2. 清理待采集任务 (非致命错误)。 if err := app.initializePendingCollections(appCtx); err != nil { logger.Errorw("清理待采集任务时发生非致命错误", "error", err) } - // 初始化待执行任务列表 (致命错误) - if err := app.initializePendingTasks(appCtx); err != nil { - return fmt.Errorf("初始化待执行任务列表失败: %w", err) + // 3. 初始化并更新系统计划。 + // 此时，所有旧的待执行任务已被清除，可以安全地更新计划结构。 + if err := app.initializeSystemPlans(ctx); err != nil { + return fmt.Errorf("初始化预定义系统计划失败: %w", err) } + // 4. 最后，根据最新的计划状态，统一刷新所有计划的触发器。 + // 这一步确保了新创建或更新的系统计划能够被正确地调度。 + logger.Info("正在刷新所有计划的触发器...") + if err := app.Domain.planService.RefreshPlanTriggers(appCtx); err != nil { + return fmt.Errorf("刷新计划触发器失败: %w", err) + } + logger.Info("计划触发器刷新完成。") + return nil } @@ -149,15 +160,14 @@ func (app *Application) initializePendingCollections(ctx context.Context) error return nil } -// initializePendingTasks 在应用启动时清理并刷新待执行任务列表。 -func (app *Application) initializePendingTasks(ctx context.Context) error { - appCtx, logger := logs.Trace(ctx, app.Ctx, "InitializePendingTasks") +// cleanupStaleTasksAndLogs 在应用启动时清理所有因上次异常关闭而遗留的待执行任务和相关日志。 +func (app *Application) cleanupStaleTasksAndLogs(ctx context.Context) error { + appCtx, logger := logs.Trace(ctx, app.Ctx, "CleanupStaleTasksAndLogs") planRepo := app.Infra.repos.planRepo pendingTaskRepo := app.Infra.repos.pendingTaskRepo executionLogRepo := app.Infra.repos.executionLogRepo - planService := app.Domain.planService - logger.Info("开始初始化待执行任务列表...") + logger.Info("开始清理过期的任务及日志...") // 阶段一：修正因崩溃导致状态不一致的固定次数计划 logger.Info("阶段一：开始修正因崩溃导致状态不一致的固定次数计划...") @@ -247,13 +257,6 @@ func (app *Application) initializePendingTasks(ctx context.Context) error { } logger.Info("阶段二：待执行任务和相关日志清理完成。") - // 阶段三：初始刷新 - logger.Info("阶段三：开始刷新待执行列表...") - if err := planService.RefreshPlanTriggers(appCtx); err != nil { - return fmt.Errorf("刷新待执行任务列表失败: %w", err) - } - logger.Info("阶段三：待执行任务列表初始化完成。") - - logger.Info("待执行任务列表初始化完成。") + logger.Info("过期的任务及日志清理完成。") return nil }