From bcd5f914eb3b1a4d47f19c2b9dd66e6c48badebe Mon Sep 17 00:00:00 2001
From: aozhiwei <aozhiwei@kingsome.cn>
Date: Mon, 29 Jul 2024 11:52:04 +0800
Subject: [PATCH] 1

---
 server/light_backtask/service/nftutils.go | 35 +++++++++--------------
 1 file changed, 13 insertions(+), 22 deletions(-)

diff --git a/server/light_backtask/service/nftutils.go b/server/light_backtask/service/nftutils.go
index 668e9b16..3d5302e2 100644
--- a/server/light_backtask/service/nftutils.go
+++ b/server/light_backtask/service/nftutils.go
@@ -185,23 +185,24 @@ func RepiarHeroQuality() error {
 	var resultErr error
 	nftDatas := []*jccommon.NftIdentityAndExtData{}
 	{
+		cb := func (err error, ds *f5.DataSet) {
+			resultErr = err
+			if err != nil {
+				return
+			}
+			for ds.Next() {
+				p := new(jccommon.NftIdentityAndExtData)
+				p.LoadFromDb(ds)
+				q5.AppendSlice(&nftDatas, p);
+			}
+		}
 		f5.GetGoStyleDb().OrmSelect(
 			constant.BCNFT_DB,
 			"t_nft",
 			[][]string{
 				{"token_type", q5.ToString(jccommon.NFT_TYPE_CFHERO)},
 			},
-			func (err error, ds *f5.DataSet) {
-				resultErr = err
-				if err != nil {
-					return
-				}
-				for ds.Next() {
-					p := new(jccommon.NftIdentityAndExtData)
-					p.LoadFromDb(ds)
-					q5.AppendSlice(&nftDatas, p);
-				}
-			})
+			cb)
 		if resultErr == nil {
 			f5.GetGoStyleDb().OrmSelect(
 				constant.BCNFT_DB,
@@ -209,17 +210,7 @@ func RepiarHeroQuality() error {
 				[][]string{
 					{"token_type", q5.ToString(jccommon.NFT_TYPE_CFHERO_NORMAL)},
 				},
-				func (err error, ds *f5.DataSet) {
-					resultErr = err
-					if err != nil {
-						return
-					}
-					for ds.Next() {
-						p := new(jccommon.NftIdentityAndExtData)
-						p.LoadFromDb(ds)
-						q5.AppendSlice(&nftDatas, p);
-					}
-				})
+				cb)
 		}
 	}
 	procBatchFunc := func(batch []*jccommon.NftIdentityAndExtData) {