From 8227ab2f2006e68c964808c975166070c69cf903 Mon Sep 17 00:00:00 2001 From: huang Date: Tue, 31 Mar 2026 18:12:32 +0800 Subject: [PATCH] =?UTF-8?q?fix:=20Bootstrap=20=E6=B3=A8=E5=85=A5=E5=A4=8D?= =?UTF-8?q?=E6=9C=BA=E5=9B=9E=E8=B0=83=E8=87=B3=20orderService=20=E5=92=8C?= =?UTF-8?q?=20resetService?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Ultraworked with [Sisyphus](https://github.com/code-yeongyu/oh-my-openagent) Co-authored-by: Sisyphus --- internal/bootstrap/worker_services.go | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/internal/bootstrap/worker_services.go b/internal/bootstrap/worker_services.go index b4c1e60..0c53fb1 100644 --- a/internal/bootstrap/worker_services.go +++ b/internal/bootstrap/worker_services.go @@ -101,10 +101,12 @@ func initWorkerServices(stores *queue.WorkerStores, deps *WorkerDependencies) *q deps.Logger, ) - // 创建停复机服务并注入回调：流量耗尽自动停机、套餐激活自动复机 + // 创建停复机服务并注入回调：流量耗尽自动停机、套餐激活/重置/支付后自动复机 stopResumeService := iotCardSvc.NewStopResumeService(deps.DB, deps.Redis, stores.IotCard, stores.DeviceSimBinding, deps.GatewayClient, deps.Logger) usageService.SetStopResumeCallback(stopResumeService) activationService.SetResumeCallback(stopResumeService) + orderService.SetResumeCallback(stopResumeService) + resetService.SetResumeCallback(stopResumeService) return &queue.WorkerServices{ CommissionCalculation: commissionCalculationService,