1
This commit is contained in:
@@ -160,7 +160,7 @@ func IsImportantTaskRunning(taskName string) bool {
|
|||||||
}
|
}
|
||||||
|
|
||||||
func Init() {
|
func Init() {
|
||||||
globals.SugarLogger.Debug("-----------------30s跑一次", time.Now(),globals.IsProductEnv())
|
globals.SugarLogger.Debug("-----------------30s跑一次", time.Now(), globals.IsProductEnv())
|
||||||
if globals.IsProductEnv() {
|
if globals.IsProductEnv() {
|
||||||
//ScheduleTimerFunc("doDailyWork2", doDailyWork2, dailyWorkTimeList2)
|
//ScheduleTimerFunc("doDailyWork2", doDailyWork2, dailyWorkTimeList2)
|
||||||
|
|
||||||
@@ -178,8 +178,7 @@ func Init() {
|
|||||||
ScheduleTimerFuncByInterval(func() {
|
ScheduleTimerFuncByInterval(func() {
|
||||||
delivery.GetOrderRiderInfoToPlatform("")
|
delivery.GetOrderRiderInfoToPlatform("")
|
||||||
globals.SugarLogger.Debug("五分钟跑一次", time.Now())
|
globals.SugarLogger.Debug("五分钟跑一次", time.Now())
|
||||||
}, 10*time.Second, 5*time.Minute)
|
}, 10*time.Second, 30*time.Second)
|
||||||
|
|
||||||
|
|
||||||
ScheduleTimerFuncByInterval(func() {
|
ScheduleTimerFuncByInterval(func() {
|
||||||
defsch.FixedScheduler.ConfirmSelfTakeOrders(jxcontext.AdminCtx, []int{model.VendorIDJD}, time.Now().Add(-48*time.Hour), time.Now().Add(-30*time.Minute), true, true)
|
defsch.FixedScheduler.ConfirmSelfTakeOrders(jxcontext.AdminCtx, []int{model.VendorIDJD}, time.Now().Add(-48*time.Hour), time.Now().Add(-30*time.Minute), true, true)
|
||||||
|
|||||||
Reference in New Issue
Block a user