server/game2006go
5
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

1

Browse Source
This commit is contained in:
aozhiwei 2024-07-29 11:55:17 +08:00
parent bcd5f914eb
commit b03cd8a4ac
1 changed files with 16 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

25
server/light_backtask/service/nftutils.go
View File

@ -242,30 +242,37 @@ func RepiarHeroQuality() error {
} }
for ds.Next() { for ds.Next() {
tokenId := ds.GetByName("token_id") tokenId := ds.GetByName("token_id")
itemId := q5.ToInt32(ds.GetByName("hero_id"))
quality := q5.ToInt32(ds.GetByName("quality")) quality := q5.ToInt32(ds.GetByName("quality"))
if val, ok := tokenIdQualityHash[tokenId]; ok && val.Quality != quality { if val, ok := tokenIdQualityHash[tokenId]; ok && quality > val.Quality && itemId > 0 {
UpdateNftItemIdQuality(
val.NetId,
val.ContractAddress,
val.TokenId,
itemId,
quality)
} }
} }
}) })
} }
if resultErr == nil && len(nftDatas) > 0 { if resultErr == nil && len(nftDatas) > 0 {
batchNftQuality := []*jccommon.NftIdentityAndExtData{} batch := []*jccommon.NftIdentityAndExtData{}
for _, val := range nftDatas { for _, val := range nftDatas {
if len(batchNftQuality) < 100 { if len(batch) < 100 {
q5.AppendSlice(&batchNftQuality, val) q5.AppendSlice(&batch, val)
} else { } else {
procBatchFunc(batchNftQuality) procBatchFunc(batch)
batchNftQuality = []*jccommon.NftIdentityAndExtData{} batch = []*jccommon.NftIdentityAndExtData{}
} }
} }
if len(batchNftQuality) > 0 { if len(batch) > 0 {
procBatchFunc(batchNftQuality) procBatchFunc(batch)
} }
} }
return resultErr return resultErr
} }
func updateNftItemIdQuality(netId int32, contractAddress string, tokenId string, func UpdateNftItemIdQuality(netId int32, contractAddress string, tokenId string,
itemId int32, quality int32) error { itemId int32, quality int32) error {
var resultErr error var resultErr error
f5.GetGoStyleDb().Update( f5.GetGoStyleDb().Update(