1
This commit is contained in:
@@ -164,9 +164,7 @@ func IsImportantTaskRunning(taskName string) bool {
|
|||||||
}
|
}
|
||||||
|
|
||||||
func Init() {
|
func Init() {
|
||||||
globals.SugarLogger.Debugf("========================ScheduleTimerFuncByInterval=")
|
|
||||||
if globals.IsProductEnv() {
|
if globals.IsProductEnv() {
|
||||||
globals.SugarLogger.Debugf("========================ScheduleTimerFuncByInterval=2222")
|
|
||||||
//ScheduleTimerFunc("doDailyWork2", doDailyWork2, dailyWorkTimeList2)
|
//ScheduleTimerFunc("doDailyWork2", doDailyWork2, dailyWorkTimeList2)
|
||||||
|
|
||||||
//京东的订单信息解密密钥获取
|
//京东的订单信息解密密钥获取
|
||||||
@@ -210,7 +208,6 @@ func Init() {
|
|||||||
|
|
||||||
// 每分钟轮询一次,推送骑手信息(假的订单)
|
// 每分钟轮询一次,推送骑手信息(假的订单)
|
||||||
ScheduleTimerFuncByInterval(func() {
|
ScheduleTimerFuncByInterval(func() {
|
||||||
globals.SugarLogger.Debugf("定时任务推送UpdateFakeWayBillToTiktok := ")
|
|
||||||
delivery.UpdateFakeWayBillToTiktok()
|
delivery.UpdateFakeWayBillToTiktok()
|
||||||
}, 10*time.Second, 2*time.Minute)
|
}, 10*time.Second, 2*time.Minute)
|
||||||
|
|
||||||
|
|||||||
@@ -402,7 +402,6 @@ func UpdateFakeWayBillToTiktok() {
|
|||||||
//}
|
//}
|
||||||
|
|
||||||
fakeWayBill, err := dao.GetWayBillFakeOrder()
|
fakeWayBill, err := dao.GetWayBillFakeOrder()
|
||||||
globals.SugarLogger.Debugf("定时任务推送UpdateFakeWayBillToTiktok := %d", len(fakeWayBill))
|
|
||||||
if err != nil {
|
if err != nil {
|
||||||
globals.SugarLogger.Debugf("Get Fake Order Err : %s", err.Error())
|
globals.SugarLogger.Debugf("Get Fake Order Err : %s", err.Error())
|
||||||
return
|
return
|
||||||
@@ -412,7 +411,6 @@ func UpdateFakeWayBillToTiktok() {
|
|||||||
}
|
}
|
||||||
|
|
||||||
for i := 0; i < len(fakeWayBill); i++ {
|
for i := 0; i < len(fakeWayBill); i++ {
|
||||||
globals.SugarLogger.Debugf("定时任务推送UpdateFakeWayBillToTiktok := %s", fakeWayBill[i].VendorOrderID)
|
|
||||||
// 判断当前订单是否可以推送,UpdatedAt > 当前时间 就跳过
|
// 判断当前订单是否可以推送,UpdatedAt > 当前时间 就跳过
|
||||||
if fakeWayBill[i].StatusTime.After(time.Now()) {
|
if fakeWayBill[i].StatusTime.After(time.Now()) {
|
||||||
continue
|
continue
|
||||||
|
|||||||
Reference in New Issue
Block a user