This commit is contained in:
aozhiwei 2024-06-27 16:57:36 +08:00
parent e7561fe559
commit 6a4fd62fd9

View File

@ -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
}