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),