1

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() {

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)