diff --git a/server/backtask/task/repair_nft.go b/server/backtask/task/repair_nft.go
index df0d6561..14c33fc0 100644
--- a/server/backtask/task/repair_nft.go
+++ b/server/backtask/task/repair_nft.go
@@ -23,102 +23,72 @@ func (this* repairNft) unInit() {
 }
 
 func (this* repairNft) processNft() {
-	var lastIdx int64
-	for true {
-		hasNextData := false
-		sql := fmt.Sprintf(`
+	f5.GetGoStyleDb().LoopLoad(
+		constant.BCNFT_DB,
+		func (lastIdx int64) string {
+			sql := fmt.Sprintf(`
 SELECT * FROM nft WHERE idx > %d AND item_id = 0 LIMIT 1000`,
-			lastIdx,
-		)
-		f5.GetGoStyleDb().RawQuery(
-			constant.BCNFT_DB,
-			sql,
-			[]string{
-			},
-			func (err error, ds *f5.DataSet) {
-				if err == nil {
-					for ds.Next() {
-						idx := q5.ToInt64(ds.GetByName("idx"))
-						if idx > lastIdx {
-							lastIdx = idx
-						}
-						hasNextData = true
-					}
-				}
-			})
-		if hasNextData {
-			time.Sleep(time.Second * 10)
-		} else {
-			lastIdx = 0
-			time.Sleep(time.Second * 60 * 5)
-		}
-	}
+				lastIdx,
+			)
+			return sql
+		},
+		[]string{
+		},
+		func () time.Duration {
+			return time.Second * 10
+		},
+		func () time.Duration {
+			return time.Second * 60 * 5
+		},
+		func (ds *f5.DataSet) bool {
+			return true
+		})
 }
 
 func (this* repairNft) processOrder() {
-	var lastIdx int64
-	for true {
-		hasNextData := false
-		sql := fmt.Sprintf(`
+	f5.GetGoStyleDb().LoopLoad(
+		constant.BCNFT_DB,
+		func (lastIdx int64) string {
+			sql := fmt.Sprintf(`
 SELECT * FROM nft WHERE idx > %d AND item_id = 0 LIMIT 1000`,
-			lastIdx,
-		)
-		f5.GetGoStyleDb().RawQuery(
-			constant.BCNFT_DB,
-			sql,
-			[]string{
-			},
-			func (err error, ds *f5.DataSet) {
-				if err == nil {
-					for ds.Next() {
-						idx := q5.ToInt64(ds.GetByName("idx"))
-						if idx > lastIdx {
-							lastIdx = idx
-						}
-						hasNextData = true
-					}
-				}
-			})
-		if hasNextData {
-			time.Sleep(time.Second * 10)
-		} else {
-			lastIdx = 0
-			time.Sleep(time.Second * 60 * 5)
-		}
-	}
+				lastIdx,
+			)
+			return sql
+		},
+		[]string{
+		},
+		func () time.Duration {
+			return time.Second * 10
+		},
+		func () time.Duration {
+			return time.Second * 60 * 5
+		},
+		func (ds *f5.DataSet) bool {
+			return true
+		})
 }
 
 func (this* repairNft) processSale() {
-	var lastIdx int64
-	for true {
-		hasNextData := false
-		sql := fmt.Sprintf(`
+	f5.GetGoStyleDb().LoopLoad(
+		constant.BCNFT_DB,
+		func (lastIdx int64) string {
+			sql := fmt.Sprintf(`
 SELECT * FROM nft WHERE idx > %d AND item_id = 0 LIMIT 1000`,
-			lastIdx,
-		)
-		f5.GetGoStyleDb().RawQuery(
-			constant.BCNFT_DB,
-			sql,
-			[]string{
-			},
-			func (err error, ds *f5.DataSet) {
-				if err == nil {
-					for ds.Next() {
-						idx := q5.ToInt64(ds.GetByName("idx"))
-						if idx > lastIdx {
-							lastIdx = idx
-						}
-						hasNextData = true
-					}
-				}
-			})
-		if hasNextData {
-			time.Sleep(time.Second * 10)
-		} else {
-			lastIdx = 0
-			time.Sleep(time.Second * 60 * 5)
-		}
-	}
+				lastIdx,
+			)
+			return sql
+		},
+		[]string{
+		},
+		func () time.Duration {
+			return time.Second * 10
+		},
+		func () time.Duration {
+			return time.Second * 60 * 5
+		},
+		func (ds *f5.DataSet) bool {
+			return true
+		})
 }
 
 func (this* repairNft) getItemIdHeroQuality(netId int32, contractAddress string, tokenId string,
diff --git a/third_party/f5 b/third_party/f5
index 330f53df..04c7b77b 160000
--- a/third_party/f5
+++ b/third_party/f5
@@ -1 +1 @@
-Subproject commit 330f53df3d6143867c0d78d97cdfb8bbd6c42ebb
+Subproject commit 04c7b77bd79f7ce2dd706bc0ee3deb18d7bc7fd9