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:52:04 +08:00
parent b031b3fda2
commit bcd5f914eb
1 changed files with 13 additions and 22 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -185,23 +185,24 @@ func RepiarHeroQuality() error {
var resultErr error
nftDatas := []*jccommon.NftIdentityAndExtData{}
{
cb := func (err error, ds *f5.DataSet) {
resultErr = err
if err != nil {
return
}
for ds.Next() {
p := new(jccommon.NftIdentityAndExtData)
p.LoadFromDb(ds)
q5.AppendSlice(&nftDatas, p);
}
}
f5.GetGoStyleDb().OrmSelect(
constant.BCNFT_DB,
"t_nft",
[][]string{
{"token_type", q5.ToString(jccommon.NFT_TYPE_CFHERO)},
},
func (err error, ds *f5.DataSet) {
resultErr = err
if err != nil {
return
}
for ds.Next() {
p := new(jccommon.NftIdentityAndExtData)
p.LoadFromDb(ds)
q5.AppendSlice(&nftDatas, p);
}
})
cb)
if resultErr == nil {
f5.GetGoStyleDb().OrmSelect(
constant.BCNFT_DB,
@ -209,17 +210,7 @@ func RepiarHeroQuality() error {
[][]string{
{"token_type", q5.ToString(jccommon.NFT_TYPE_CFHERO_NORMAL)},
},
func (err error, ds *f5.DataSet) {
resultErr = err
if err != nil {
return
}
for ds.Next() {
p := new(jccommon.NftIdentityAndExtData)
p.LoadFromDb(ds)
q5.AppendSlice(&nftDatas, p);
}
})
cb)
}
}
procBatchFunc := func(batch []*jccommon.NftIdentityAndExtData) {