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-09-23 13:48:40 +08:00
parent 6d531f822f
commit 26a3d3ee2c
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
server/light_backtask/task/vester.go
View File

@ -34,11 +34,11 @@ func (this *vester) unInit() {
} }
func (this *vester) process(netId int32, contractAddress string) { func (this *vester) process(netId int32, contractAddress string) {
key := fmt.Sprintf("vester.lastIdx.%d.%s", netId, contractAddress) key := fmt.Sprintf("vester.depositAndWithdraw.lastIdx.%d.%s", netId, contractAddress)
if dbLastIdxStr, err := jccommon.GetDbParam(constant.BCEVENT_DB, key); err == nil { if dbLastIdxStr, err := jccommon.GetDbParam(constant.BCEVENT_DB, key); err == nil {
f5.GetGoStyleDb().IncrementLoad( f5.GetGoStyleDb().IncrementLoad(
constant.BCEVENT_DB, constant.BCEVENT_DB,
"vester." + q5.ToString(netId) + "." + contractAddress, "vester.depositAndWithdraw." + q5.ToString(netId) + "." + contractAddress,
"t_blockchain_event", "t_blockchain_event",
q5.ToInt64(dbLastIdxStr), q5.ToInt64(dbLastIdxStr),
func (lastIdx int64, maxIdx int64) (string, []string) { func (lastIdx int64, maxIdx int64) (string, []string) {
@ -62,7 +62,7 @@ ORDER BY idx LIMIT 1000
}, },
this.saveToDb) this.saveToDb)
} else { } else {
panic(fmt.Sprintf("vester getDBParam error %s", err)) panic(fmt.Sprintf("vester.depositAndWithdraw getDBParam error %s", err))
} }
} }