From 0ec16d4afa60e1742987bf54e17d5acaefecbb5f Mon Sep 17 00:00:00 2001 From: huang Date: Thu, 16 Apr 2026 16:48:14 +0800 Subject: [PATCH] =?UTF-8?q?fix:=20=E5=AE=9E=E5=90=8D=E8=BD=AE=E8=AF=A2?= =?UTF-8?q?=E9=98=B2=E6=AD=A2=E4=B8=8A=E6=B8=B8=E6=8E=A5=E5=8F=A3=E6=95=85?= =?UTF-8?q?=E9=9A=9C=E6=97=B6=E8=AF=AF=E9=99=8D=E7=BA=A7=E5=B7=B2=E5=AE=9E?= =?UTF-8?q?=E5=90=8D=E7=8A=B6=E6=80=81?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Gateway 返回 data=null 时 sonic 解析为零值结构体（ICCID="" RealStatus=false）， 导致已实名卡被误判为未实名并触发停机。 通过检查响应中 ICCID 是否回填来判断数据有效性： - ICCID 为空：视为上游接口故障，重新入队，不更新实名状态 - ICCID 有值：响应有效，正常处理（含合法的未实名降级） --- internal/task/polling_realname_handler.go | 12 ++++++++++++ 1 file changed, 12 insertions(+) diff --git a/internal/task/polling_realname_handler.go b/internal/task/polling_realname_handler.go index 2c20246..36bd49f 100644 --- a/internal/task/polling_realname_handler.go +++ b/internal/task/polling_realname_handler.go @@ -81,12 +81,24 @@ func (h *PollingRealnameHandler) Handle(ctx context.Context, t *asynq.Task) erro h.base.updateStats(ctx, constants.TaskTypePollingRealname, false, time.Since(startTime)) return h.base.requeueCard(ctx, cardID, constants.TaskTypePollingRealname) } + // 上游接口故障时 Gateway 可能返回 data=null， + // sonic 将其解析为零值结构体（ICCID="" RealStatus=false）， + // 需通过 ICCID 是否回填来判断响应是否有效。 + if result.ICCID == "" { + h.base.logger.Warn("实名查询响应异常：ICCID 为空，疑似上游接口故障，跳过本次同步", + zap.Uint("card_id", cardID), + zap.String("iccid", card.ICCID)) + h.base.updateStats(ctx, constants.TaskTypePollingRealname, false, time.Since(startTime)) + return h.base.requeueCard(ctx, cardID, constants.TaskTypePollingRealname) + } + realStatusBool = result.RealStatus if result.RealStatus { newStatus = constants.RealNameStatusVerified } else { newStatus = constants.RealNameStatusNotVerified } + if h.base.verboseLog { h.base.logger.Info("实名状态轮询详情", zap.Uint("card_id", cardID),