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,