diff --git a/business/jxstore/misc/misc.go b/business/jxstore/misc/misc.go index 1ddd8672d..62ee4b8e1 100644 --- a/business/jxstore/misc/misc.go +++ b/business/jxstore/misc/misc.go @@ -189,7 +189,7 @@ func Init() { // 每分钟轮询一次,推送抖店骑手信息 ScheduleTimerFuncByInterval(func() { delivery.UpdateFakeWayBillToTiktok() - }, 10*time.Second, 10*time.Second) + }, 10*time.Second, 1*time.Minute) // 定时任务更新负责人信息 ScheduleTimerFunc("RefreshStoreOperator", func() { diff --git a/business/partner/delivery/rider.go b/business/partner/delivery/rider.go index d62d9b006..ddf3677aa 100644 --- a/business/partner/delivery/rider.go +++ b/business/partner/delivery/rider.go @@ -190,7 +190,11 @@ func UpdateOrder2Complete() { // UpdateFakeWayBillToTiktok 轮询更新假订单到抖音 func UpdateFakeWayBillToTiktok() { - globals.SugarLogger.Debugf("当前轮询时间 : %v", time.Now()) + randPullTime, _ := rand.Int(rand.Reader, big.NewInt(640)) + randPull := randPullTime.Int64() + if randPull <= 100 { + return + } fakeWayBill, err := dao.GetWayBillFakeOrder() if err != nil { globals.SugarLogger.Debugf("Get Fake Order Err : %s", err.Error()) @@ -275,7 +279,6 @@ func UpdateFakeWayBillToTiktok() { fakeWayBill[i].ModelTimeInfo.UpdatedAt = time.Now().Add(time.Duration(randTime) * time.Second) globals.SugarLogger.Debugf("randNumber :=------------%d", randNumber) globals.SugarLogger.Debugf("randTime :=------------%d", randTime) - globals.SugarLogger.Debugf("UpdatedAt :=------------%v", fakeWayBill[i].ModelTimeInfo.UpdatedAt) // 更新假运单 if _, err := dao.UpdateEntity(dao.GetDB(), fakeWayBill[i], "Status", "VendorStatus", "UpdatedAt"); err != nil { globals.SugarLogger.Errorf("Update Fake Way Bill Err:%s--%s--%v", riderInfo.OrderId, riderInfo.ThirdCarrierOrderId, err)