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-24 11:47:26 +08:00
parent b2f1cf3ca1
commit 6901ba76c3
1 changed files with 17 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
server/light_backtask/task/repair_nft.go
View File

@ -263,13 +263,27 @@ func (this* repairNft) updateSale(netId int32, contractAddress string, tokenId s
func (this* repairNft) repairChainActivity(ds *f5.DataSet) bool { func (this* repairNft) repairChainActivity(ds *f5.DataSet) bool {
netId := q5.ToInt32(ds.GetByName("net_id")) netId := q5.ToInt32(ds.GetByName("net_id"))
contractAddress := ds.GetByName("contract_address") nftContractAddress := ds.GetByName("nft_contract_address")
tokenId := ds.GetByName("token_id") tokenId := ds.GetByName("token_id")
var itemId int32 var itemId int32
var quality int32 var quality int32
if service.GetHeroByTokenId(tokenId, &itemId, &quality) { service.GetNftItemIdQuality(netId, nftContractAddress, tokenId, &itemId, &quality)
this.updateSale(netId, contractAddress, tokenId, itemId, quality) if itemId > 0 || quality > 0 {
f5.GetGoStyleDb().Update(
constant.BCEVENT_DB,
"t_chain_activity",
[][]string {
{"net_id", q5.ToString(netId)},
{"nft_contract_address", nftContractAddress},
{"token_id", tokenId},
},
[][]string {
{"item_id", q5.ToString(itemId)},
{"quality", q5.ToString(quality)},
},
func (err error, lastInsertId int64, rowsAffected int64) {
})
} }
return true return true
} }