修复报错
This commit is contained in:
@@ -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,
|
||||
|
||||
Reference in New Issue
Block a user