From af852fa33b898e4a4117c3ca7dedcd8f1564fc49 Mon Sep 17 00:00:00 2001
From: aozhiwei <aozhiwei@kingsome.cn>
Date: Wed, 26 Jun 2024 11:51:07 +0800
Subject: [PATCH] 1

---
 server/backtask/task/gold_bullion_return.go         |  4 ++++
 server/backtask/task/repair_nft.go                  | 13 +++++++++++++
 .../task/spec_transfer721/spec_transfer721.go       |  5 +++++
 3 files changed, 22 insertions(+)

diff --git a/server/backtask/task/gold_bullion_return.go b/server/backtask/task/gold_bullion_return.go
index 05b8903c..b2b7dc5d 100644
--- a/server/backtask/task/gold_bullion_return.go
+++ b/server/backtask/task/gold_bullion_return.go
@@ -24,6 +24,10 @@ func (this* goldBullionReturn) unInit() {
 func (this* goldBullionReturn) loadExpiredGoldBullion() {
 	f5.GetGoStyleDb().LoopLoad(
 		constant.GAME_DB,
+		"t_gold_bullion",
+		func () int64 {
+			return 60 * 5
+		},
 		func (lastIdx int64) string {
 			nowTime := f5.GetApp().GetRealSeconds()
 			expiredTime := nowTime - 3600 * 24 - 60 * 5
diff --git a/server/backtask/task/repair_nft.go b/server/backtask/task/repair_nft.go
index 8a8b0921..4f3a136d 100644
--- a/server/backtask/task/repair_nft.go
+++ b/server/backtask/task/repair_nft.go
@@ -8,6 +8,7 @@ import (
 	"jccommon"
 	"main/constant"
 	"main/service"
+	"math/rand"
 )
 
 type repairNft struct {
@@ -26,6 +27,10 @@ func (this* repairNft) unInit() {
 func (this* repairNft) processNft() {
 	f5.GetGoStyleDb().LoopLoad(
 		constant.BCNFT_DB,
+		"t_nft",
+		func () int64 {
+			return 60 * 1
+		},
 		func (lastIdx int64) string {
 			sql := fmt.Sprintf(`
 SELECT * FROM t_nft WHERE idx > %d AND item_id = 0 LIMIT 1000`,
@@ -47,6 +52,10 @@ SELECT * FROM t_nft WHERE idx > %d AND item_id = 0 LIMIT 1000`,
 func (this* repairNft) processOrder() {
 	f5.GetGoStyleDb().LoopLoad(
 		constant.BCNFT_DB,
+		"t_order",
+		func () int64 {
+			return 60 + q5.ToInt64(rand.Intn(2))
+		},
 		func (lastIdx int64) string {
 			sql := fmt.Sprintf(`
 SELECT * FROM t_order WHERE idx > %d AND item_id = 0 LIMIT 1000`,
@@ -68,6 +77,10 @@ SELECT * FROM t_order WHERE idx > %d AND item_id = 0 LIMIT 1000`,
 func (this* repairNft) processSale() {
 	f5.GetGoStyleDb().LoopLoad(
 		constant.BCNFT_DB,
+		"t_sale",
+		func () int64 {
+			return 60 + q5.ToInt64(rand.Intn(2))
+		},
 		func (lastIdx int64) string {
 			sql := fmt.Sprintf(`
 SELECT * FROM t_sale WHERE idx > %d AND item_id = 0 LIMIT 1000`,
diff --git a/server/backtask/task/spec_transfer721/spec_transfer721.go b/server/backtask/task/spec_transfer721/spec_transfer721.go
index 2b834a79..46b0a771 100644
--- a/server/backtask/task/spec_transfer721/spec_transfer721.go
+++ b/server/backtask/task/spec_transfer721/spec_transfer721.go
@@ -8,6 +8,7 @@ import (
 	"mt"
 	"jccommon"
 	"main/constant"
+	"math/rand"
 )
 
 type SpecTransfer721 struct {
@@ -27,6 +28,10 @@ func (this* SpecTransfer721) UnInit() {
 func (this* SpecTransfer721) process() {
 	f5.GetGoStyleDb().LoopLoad(
 		constant.BCEVENT_DB,
+		"t_721nft_spec_transfer",
+		func () int64 {
+			return 3 + q5.ToInt64(rand.Intn(2))
+		},
 		func (lastIdx int64) string {
 			nowTime := f5.GetApp().GetRealSeconds()
 			expiredTime := nowTime - 3600 * 24 * 7