diff --git a/server/light_backtask/task/chain_activity.go b/server/light_backtask/task/chain_activity.go index 395f4d08..8954b758 100644 --- a/server/light_backtask/task/chain_activity.go +++ b/server/light_backtask/task/chain_activity.go @@ -32,28 +32,21 @@ func (this* chainActivity) unInit() { } func (this* chainActivity) process() { - f5.GetGoStyleDb().LoopLoad( + f5.GetGoStyleDb().IncrementLoad( constant.BCNFT_DB, "chainActivity", "t_blockchain_event", - func () int64 { - return 60 * 1 - }, - func (lastIdx int64) string { + func (lastIdx int64, maxIdx int64) (string, []string) { sql := fmt.Sprintf(` -SELECT * FROM t_blockchain_event WHERE idx > %d AND item_id = 0 AND token_type <> %d ORDER BY idx LIMIT 1000`, +SELECT * FROM t_blockchain_event +WHERE idx > %d AND idx <= %d AND item_id = 0 AND token_type <> %d ORDER BY idx LIMIT 1000 +`, lastIdx, + maxIdx, jccommon.NFT_TYPE_FOUNDER_TAG, ) - return sql - }, - []string{ - }, - func () int64 { - return 10 - }, - func () int64 { - return 60 * 5 + params := []string{} + return sql, params }, this.repairNft) } diff --git a/third_party/f5 b/third_party/f5 index c80bf38d..c842ce5e 160000 --- a/third_party/f5 +++ b/third_party/f5 @@ -1 +1 @@ -Subproject commit c80bf38df943c14b9019f08773f3a42db7f8f6cf +Subproject commit c842ce5e34e6b8a9e145913bcc87ea99219d45b5