From 4f3148eaa26476802bd130bd807f6bb8d282e1d4 Mon Sep 17 00:00:00 2001 From: huang <1724659546@qq.com> Date: Mon, 10 Nov 2025 21:17:28 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E5=A4=8D=E6=8A=A5=E9=94=99?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- internal/core/component_initializers.go | 18 ++++++++++-------- 1 file changed, 10 insertions(+), 8 deletions(-) diff --git a/internal/core/component_initializers.go b/internal/core/component_initializers.go index 6be7dc5..73a9c05 100644 --- a/internal/core/component_initializers.go +++ b/internal/core/component_initializers.go @@ -161,13 +161,22 @@ func initDomainServices(ctx context.Context, cfg *config.Config, infra *Infrastr infra.lora.comm, ) + // 告警服务 + alarmService := alarm.NewAlarmService( + logs.AddCompName(baseCtx, "AlarmService"), + infra.repos.alarmRepo, + infra.repos.unitOfWork, + ) + // 任务工厂 taskFactory := task.NewTaskFactory(logs.AddCompName(baseCtx, "TaskFactory"), infra.repos.sensorDataRepo, infra.repos.deviceRepo, infra.repos.alarmRepo, generalDeviceService, - notifyService) + notifyService, + alarmService, + ) // 计划任务管理器 analysisPlanTaskManager := plan.NewAnalysisPlanTaskManager(logs.AddCompName(baseCtx, "AnalysisPlanTaskManager"), infra.repos.planRepo, infra.repos.pendingTaskRepo, infra.repos.executionLogRepo) @@ -198,13 +207,6 @@ func initDomainServices(ctx context.Context, cfg *config.Config, infra *Infrastr taskFactory, ) - // 告警服务 - alarmService := alarm.NewAlarmService( - logs.AddCompName(baseCtx, "AlarmService"), - infra.repos.alarmRepo, - infra.repos.unitOfWork, - ) - return &DomainServices{ pigPenTransferManager: pigPenTransferManager, pigTradeManager: pigTradeManager,