From cadc8224b4f2c0ac906408927f44357936624a9f Mon Sep 17 00:00:00 2001 From: aozhiwei Date: Tue, 23 Jul 2024 14:42:40 +0800 Subject: [PATCH] 1 --- server/light_backtask/task/chain_activity.go | 10 +++++++--- 1 file changed, 7 insertions(+), 3 deletions(-) diff --git a/server/light_backtask/task/chain_activity.go b/server/light_backtask/task/chain_activity.go index 412bf115..c98517ec 100644 --- a/server/light_backtask/task/chain_activity.go +++ b/server/light_backtask/task/chain_activity.go @@ -39,15 +39,15 @@ func (this* chainActivity) unInit() { func (this* chainActivity) processLockAndUnLockEvent(netId int32, lockContractAddress string) { f5.GetGoStyleDb().IncrementLoad( - constant.BCNFT_DB, + constant.BCEVENT_DB, "chainActivity", "t_blockchain_event", 0, func (lastIdx int64, maxIdx int64) (string, []string) { sql := fmt.Sprintf(` SELECT * FROM t_blockchain_event -WHERE idx > %d AND idx <= %d AND netId = %d AND contract_address = ? AND event_name IN (?, ?) -ORDER BY idx LIMIT 1000 +WHERE idx > %d AND idx <= %d AND net_id = %d AND contract_address = ? AND event_name IN (?, ?) +ORDER BY idx LIMIT 10 `, lastIdx, maxIdx, @@ -66,5 +66,9 @@ ORDER BY idx LIMIT 1000 } 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 }