From 9fdfad369f291035476cb6e9c6bdc5331a1788fa Mon Sep 17 00:00:00 2001 From: break Date: Thu, 30 Jul 2026 15:37:16 +0800 Subject: [PATCH] =?UTF-8?q?=E7=A1=AE=E4=BF=9D=E6=89=B9=E9=87=8F=E8=B4=AD?= =?UTF-8?q?=E5=8C=85=E8=83=BD=E5=A4=9F=E5=86=99=E5=85=A5=E8=A7=82=E6=B5=8B?= =?UTF-8?q?=E4=BA=8B=E4=BB=B6?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Constraint: 批量订购复用 Worker 内独立构造的订单服务\nRejected: 跳过购包观测 | 会破坏业务事务与观测事件的一致性\nConfidence: high\nScope-risk: narrow\nDirective: 新增订单服务构造入口时同步注入购包观测 Writer\nTested: 未运行测试，按用户要求仅检查目标文件差异\nNot-tested: 未执行自动化测试 --- internal/bootstrap/worker_services.go | 1 + 1 file changed, 1 insertion(+) diff --git a/internal/bootstrap/worker_services.go b/internal/bootstrap/worker_services.go index bfc69b1..60a0a93 100644 --- a/internal/bootstrap/worker_services.go +++ b/internal/bootstrap/worker_services.go @@ -135,6 +135,7 @@ func initWorkerServices(stores *queue.WorkerStores, deps *WorkerDependencies) *q walletDebitEvents := walletinfra.NewDebitEventWriter(walletOutbox) orderService.SetAgentWalletReservationService(walletapp.NewReservationService(walletinfra.NewReservationEventWriter(walletOutbox), walletDebitEvents, nil)) orderService.SetAgentWalletDebitService(walletapp.NewDebitService(walletDebitEvents, nil)) + orderService.SetObservationSeriesEventWriter(observationSeriesEvents) // 创建停复机服务并注入回调：流量耗尽自动停机、套餐激活/重置/支付后自动复机 stopResumeService := iotCardSvc.NewStopResumeService(