diff --git a/server/light_backtask/service/nftutils.go b/server/light_backtask/service/nftutils.go index 918c24c7..562ad620 100644 --- a/server/light_backtask/service/nftutils.go +++ b/server/light_backtask/service/nftutils.go @@ -222,7 +222,7 @@ func RepiarHeroQuality() error { if len(batch) <= 0 { return } - sql := "SELECT * FROM t_hero WHERE token_id IN (" + sql := "SELECT token_id, quality FROM t_hero WHERE token_id IN (" params := []string{} tokenIdQualityHash := map[string]int32{} for _, val := range batch { @@ -235,7 +235,15 @@ func RepiarHeroQuality() error { sql, params, func (err error, ds *f5.DataSet) { - + if err != nil { + return + } + for ds.Next() { + tokenId := ds.GetByName("token_id") + quality := q5.ToInt32(ds.GetByName("quality")) + if val, ok := tokenIdQualityHash[tokenId]; ok && val != quality { + } + } }) } if resultErr == nil && len(nftQuality) > 0 {