1
This commit is contained in:
parent
fc42c31084
commit
af852fa33b
@ -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
|
||||
|
@ -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`,
|
||||
|
@ -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
|
||||
|
Loading…
x
Reference in New Issue
Block a user