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 10:00:29 +08:00
parent 35ba92e955
commit 7834d87d14
2 changed files with 18 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
server/light_backtask/task/chain_activity.go
View File

@ -88,10 +88,14 @@ func (this* chainActivity) saveToDb(ds *f5.DataSet) bool {
returnValues := ds.GetByName("return_values") returnValues := ds.GetByName("return_values")
createTime := ds.GetByName("createtime") createTime := ds.GetByName("createtime")
modifyTime := ds.GetByName("modifytime") modifyTime := ds.GetByName("modifytime")
itemId := 0
quality := 0
if eventName == "Lock" { if eventName == "Lock" {
p := new(lockReturnValues) p := new(lockReturnValues)
if q5.DecodeJson(returnValues, p) == nil { if q5.DecodeJson(returnValues, p) == nil {
for _, tokenId := range p.TokenIds { for _, tokenId := range p.TokenIds {
var dbErr error
f5.GetGoStyleDb().Upsert( f5.GetGoStyleDb().Upsert(
constant.BCEVENT_DB, constant.BCEVENT_DB,
"t_chain_activity", "t_chain_activity",
@ -116,12 +120,17 @@ func (this* chainActivity) saveToDb(ds *f5.DataSet) bool {
{"src_idx", idx}, {"src_idx", idx},
{"sender_address", strings.ToLower(p.Sender)}, {"sender_address", strings.ToLower(p.Sender)},
{"to_address", strings.ToLower(p.To)}, {"to_address", strings.ToLower(p.To)},
{"item_id", q5.ToString(itemId)},
{"quality", q5.ToString(quality)},
{"createtime", createTime}, {"createtime", createTime},
{"modifytime", modifyTime}, {"modifytime", modifyTime},
}, },
func (err error, lastInsertId int64, rowsAffected int64) { func (err error, lastInsertId int64, rowsAffected int64) {
dbErr = err
}) })
if dbErr != nil {
return false
}
} }
} }
} else if eventName == "UnLock" { } else if eventName == "UnLock" {
@ -135,6 +144,7 @@ func (this* chainActivity) saveToDb(ds *f5.DataSet) bool {
if nft[2].(bool) { if nft[2].(bool) {
isMint = 1 isMint = 1
} }
var dbErr error
f5.GetGoStyleDb().Upsert( f5.GetGoStyleDb().Upsert(
constant.BCEVENT_DB, constant.BCEVENT_DB,
"t_chain_activity", "t_chain_activity",
@ -159,13 +169,18 @@ func (this* chainActivity) saveToDb(ds *f5.DataSet) bool {
{"src_idx", idx}, {"src_idx", idx},
{"sender_address", strings.ToLower(sender)}, {"sender_address", strings.ToLower(sender)},
{"to_address", strings.ToLower(to)}, {"to_address", strings.ToLower(to)},
{"item_id", q5.ToString(itemId)},
{"quality", q5.ToString(quality)},
{"is_mint", q5.ToString(isMint)}, {"is_mint", q5.ToString(isMint)},
{"createtime", createTime}, {"createtime", createTime},
{"modifytime", modifyTime}, {"modifytime", modifyTime},
}, },
func (err error, lastInsertId int64, rowsAffected int64) { func (err error, lastInsertId int64, rowsAffected int64) {
dbErr = err
}) })
if dbErr != nil {
return false
}
} }
} }
} else { } else {

2
third_party/q5 vendored

@ -1 +1 @@
Subproject commit ad5656a00af63ca9da8e4dc20d75c9f9a3324786 Subproject commit d40b258a47c4fd8f74a2afe6b856827a3cd3253b