From b031b3fda2019f2e3210a19edf76e56d96284503 Mon Sep 17 00:00:00 2001
From: aozhiwei <aozhiwei@kingsome.cn>
Date: Mon, 29 Jul 2024 11:48:58 +0800
Subject: [PATCH] 1

---
 server/light_backtask/service/nftutils.go | 22 ++++++++++++++--------
 1 file changed, 14 insertions(+), 8 deletions(-)

diff --git a/server/light_backtask/service/nftutils.go b/server/light_backtask/service/nftutils.go
index f9a89303..668e9b16 100644
--- a/server/light_backtask/service/nftutils.go
+++ b/server/light_backtask/service/nftutils.go
@@ -228,13 +228,19 @@ func RepiarHeroQuality() error {
 		}
 		sql := "SELECT token_id, hero_id, quality FROM t_hero WHERE token_id IN ("
 		params := []string{}
-		tokenIdQualityHash := map[string]int32{}
-		/*
-		for _, val := range batch {
-			sql += "?"
-			q5.AppendSlice(&params, val[0])
-			tokenIdQualityHash[val[0]] = q5.ToInt32(val[1])
-		}*/
+		tokenIdQualityHash := map[string]*jccommon.NftIdentityAndExtData{}
+		{
+			inited := false
+			for _, val := range batch {
+				if !inited {
+					sql += "?"
+				} else {
+					sql += ", ?"
+				}
+				q5.AppendSlice(&params, val.TokenId)
+				tokenIdQualityHash[val.TokenId] = val
+			}
+		}
 		f5.GetGoStyleDb().RawQuery(
 			constant.GAME_DB,
 			sql,
@@ -246,7 +252,7 @@ func RepiarHeroQuality() error {
 				for ds.Next() {
 					tokenId := ds.GetByName("token_id")
 					quality := q5.ToInt32(ds.GetByName("quality"))
-					if val, ok := tokenIdQualityHash[tokenId]; ok  && val != quality {
+					if val, ok := tokenIdQualityHash[tokenId]; ok  && val.Quality != quality {
 					}
 				}
 			})