diff --git a/server/light_backtask/task/vester.go b/server/light_backtask/task/vester.go index 76f4d913..bcc7d1e5 100644 --- a/server/light_backtask/task/vester.go +++ b/server/light_backtask/task/vester.go @@ -34,11 +34,11 @@ func (this *vester) unInit() { } 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 { f5.GetGoStyleDb().IncrementLoad( constant.BCEVENT_DB, - "vester." + q5.ToString(netId) + "." + contractAddress, + "vester.depositAndWithdraw." + q5.ToString(netId) + "." + contractAddress, "t_blockchain_event", q5.ToInt64(dbLastIdxStr), func (lastIdx int64, maxIdx int64) (string, []string) { @@ -62,7 +62,7 @@ ORDER BY idx LIMIT 1000 }, this.saveToDb) } else { - panic(fmt.Sprintf("vester getDBParam error %s", err)) + panic(fmt.Sprintf("vester.depositAndWithdraw getDBParam error %s", err)) } }