diff --git a/internal/service/asset/service.go b/internal/service/asset/service.go index 97868db6..4ee02d73 100644 --- a/internal/service/asset/service.go +++ b/internal/service/asset/service.go @@ -1504,6 +1504,10 @@ func (s *Service) restorePollingAfterExpiryChange(ctx context.Context, assetType if s.pollingRestorer == nil || assetID == 0 { return } + // 资产解析返回的卡类型为 card,统一为 iot_card。 + if assetType == constants.AssetResolveTypeCard { + assetType = constants.AssetTypeIotCard + } column := "iot_card_id" if assetType == constants.AssetTypeDevice { column = "device_id" diff --git a/internal/service/polling/polling_pause_service.go b/internal/service/polling/polling_pause_service.go index 17c8a8a9..fcd0f2f9 100644 --- a/internal/service/polling/polling_pause_service.go +++ b/internal/service/polling/polling_pause_service.go @@ -264,6 +264,9 @@ func (s *AssetPollingService) RestoreAssetPolling(ctx context.Context, assetType ctx = auditcontext.With(ctx, auditcontext.Context{ActorKind: constants.AuditActorSystemTask, ActorID: "polling_auto_restore", ActorName: "套餐生效自动恢复轮询", Source: constants.AuditSourceWorker}) } + if assetType == constants.AssetResolveTypeCard { + assetType = constants.AssetTypeIotCard + } restored := false switch assetType { case constants.AssetTypeIotCard: