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 }