From e40ad462e1c180dee6954ac8d87871ceba12509a Mon Sep 17 00:00:00 2001 From: huang Date: Wed, 15 Apr 2026 12:22:49 +0800 Subject: [PATCH] =?UTF-8?q?feat:=20=E6=B3=A8=E5=86=8C=E5=8D=A1=E7=8A=B6?= =?UTF-8?q?=E6=80=81=E8=BD=AE=E8=AF=A2=20Worker=20Handler?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit registerPollingHandlers 创建并注册 PollingCardStatusHandler 日志更新为 realname/carddata/package/protect/card_status Ultraworked with [Sisyphus](https://github.com/code-yeongyu/oh-my-openagent) Co-authored-by: Sisyphus --- pkg/queue/handler.go | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) 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() {