diff --git a/pkg/queue/handler.go b/pkg/queue/handler.go index 591ed3c..021fd07 100644 --- a/pkg/queue/handler.go +++ b/pkg/queue/handler.go @@ -167,12 +167,15 @@ func (h *Handler) registerPollingHandlers() { protectHandler := task.NewPollingProtectHandler( h.pollingBase, h.gatewayClient, h.workerResult.Stores.IotCard, h.workerResult.Stores.DeviceSimBinding, h.pollingStopResumeSvc) + cardStatusHandler := task.NewPollingCardStatusHandler( + h.pollingBase, h.gatewayClient, h.workerResult.Stores.IotCard, h.pollingStopResumeSvc) h.mux.HandleFunc(constants.TaskTypePollingRealname, realnameHandler.Handle) h.mux.HandleFunc(constants.TaskTypePollingCarddata, carddataHandler.Handle) h.mux.HandleFunc(constants.TaskTypePollingPackage, packageHandler.Handle) h.mux.HandleFunc(constants.TaskTypePollingProtect, protectHandler.Handle) - h.logger.Info("已注册轮询任务处理器(realname/carddata/package/protect)") + h.mux.HandleFunc(constants.TaskTypePollingCardStatus, cardStatusHandler.Handle) + h.logger.Info("已注册轮询任务处理器(realname/carddata/package/protect/card_status)") } func (h *Handler) registerPackageActivationHandlers() {