diff --git a/server/light_backtask/task/chain_activity.go b/server/light_backtask/task/chain_activity.go index 2b19a68b..111a2d66 100644 --- a/server/light_backtask/task/chain_activity.go +++ b/server/light_backtask/task/chain_activity.go @@ -52,7 +52,7 @@ func (this* chainActivity) processLockAndUnLockEvent(netId int32, lockContractAd sql := fmt.Sprintf(` SELECT * FROM t_blockchain_event WHERE idx > %d AND idx <= %d AND net_id = %d AND contract_address = ? AND event_name IN (?, ?) -ORDER BY idx LIMIT 10 +ORDER BY idx LIMIT 1000 `, lastIdx, maxIdx, @@ -143,8 +143,8 @@ func (this* chainActivity) saveToDb(ds *f5.DataSet) bool { } } else if eventName == "UnLock" { p := new(unLockReturnValues) - sender := q5.SafeToString(p.User) if q5.DecodeJson(returnValues, p) == nil { + sender := q5.SafeToString(p.User) decodeJsonOk = true for _, nft := range p.NftList { if len(nft) != 3 { diff --git a/server/light_backtask/task/taskmgr.go b/server/light_backtask/task/taskmgr.go index ec15dcea..d359400c 100644 --- a/server/light_backtask/task/taskmgr.go +++ b/server/light_backtask/task/taskmgr.go @@ -19,13 +19,13 @@ func (this *taskMgr) Init() { this.sysMail.init() this.repairOrder.init() //this.refreshMeta.init() - this.contribution.init() + //this.contribution.init() this.chainActivity.init() } func (this *taskMgr) UnInit() { this.chainActivity.unInit() - this.contribution.unInit() + //this.contribution.unInit() //this.refreshMeta.unInit() this.repairOrder.unInit() this.sysMail.unInit()