1

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)
 }

third_party/f5

@@ -1 +1 @@
-Subproject commit c80bf38df943c14b9019f08773f3a42db7f8f6cf
+Subproject commit c842ce5e34e6b8a9e145913bcc87ea99219d45b5