From 6a4fd62fd9975af5ab758aad9945c002e7b02b1d Mon Sep 17 00:00:00 2001 From: aozhiwei Date: Thu, 27 Jun 2024 16:57:36 +0800 Subject: [PATCH] 1 --- server/backtask/task/repair_order.go | 9 ++++++--- 1 file changed, 6 insertions(+), 3 deletions(-) diff --git a/server/backtask/task/repair_order.go b/server/backtask/task/repair_order.go index a3cb31cd..844e5dba 100644 --- a/server/backtask/task/repair_order.go +++ b/server/backtask/task/repair_order.go @@ -7,7 +7,7 @@ import ( "fmt" "jccommon" "main/constant" - //"main/service" + "main/service" "math/rand" ) @@ -31,7 +31,7 @@ func (this* repairOrder) process() { }, func (lastIdx int64) string { sql := fmt.Sprintf(` -SELECT * FROM t_order WHERE idx > %d AND status = ? LIMIT 200`, +SELECT * FROM t_order WHERE idx > %d AND status = ? LIMIT 100`, lastIdx, ) return sql @@ -40,7 +40,7 @@ SELECT * FROM t_order WHERE idx > %d AND status = ? LIMIT 200`, jccommon.ORDER_STATUS_ACTIVE, }, func () time.Duration { - return time.Second * 10 + return time.Second * 3 }, func () time.Duration { return time.Second * 30 @@ -49,5 +49,8 @@ SELECT * FROM t_order WHERE idx > %d AND status = ? LIMIT 200`, } func (this* repairOrder) repairPrice(ds *f5.DataSet) bool { + if service.BcCurrency.GetLastRefreshOkTime() + 3600 * 2 < f5.GetApp().GetRealSeconds() { + return false + } return true }