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-23 14:42:40 +08:00
parent ecf9029b97
commit cadc8224b4
1 changed files with 7 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -39,15 +39,15 @@ func (this* chainActivity) unInit() {
func (this* chainActivity) processLockAndUnLockEvent(netId int32, lockContractAddress string) { func (this* chainActivity) processLockAndUnLockEvent(netId int32, lockContractAddress string) {
f5.GetGoStyleDb().IncrementLoad( f5.GetGoStyleDb().IncrementLoad(
constant.BCNFT_DB, constant.BCEVENT_DB,
"chainActivity", "chainActivity",
"t_blockchain_event", "t_blockchain_event",
0, 0,
func (lastIdx int64, maxIdx int64) (string, []string) { func (lastIdx int64, maxIdx int64) (string, []string) {
sql := fmt.Sprintf(` sql := fmt.Sprintf(`
SELECT * FROM t_blockchain_event SELECT * FROM t_blockchain_event
WHERE idx > %d AND idx <= %d AND netId = %d AND contract_address = ? AND event_name IN (?, ?) WHERE idx > %d AND idx <= %d AND net_id = %d AND contract_address = ? AND event_name IN (?, ?)
ORDER BY idx LIMIT 1000 ORDER BY idx LIMIT 10
`, `,
lastIdx, lastIdx,
maxIdx, maxIdx,
@ -66,5 +66,9 @@ ORDER BY idx LIMIT 1000
} }
func (this* chainActivity) repairNft(ds *f5.DataSet) bool { func (this* chainActivity) repairNft(ds *f5.DataSet) bool {
f5.GetSysLog().Info("load lock/unlock idx:%s contract_name:%s event_name:%s",
ds.GetByName("idx"),
ds.GetByName("contract_name"),
ds.GetByName("event_name"))
return true return true
} }