From f7bf5cf3ae7a45966ae9ea1f7515e4a833af2fd0 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E9=82=B9=E5=AE=97=E6=A5=A0?= Date: Fri, 4 Nov 2022 13:43:03 +0800 Subject: [PATCH] 1 --- business/jxstore/misc/misc.go | 2 +- business/partner/delivery/rider.go | 7 +++++-- 2 files changed, 6 insertions(+), 3 deletions(-) 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)