Merge branch 'jdshop' of https://e.coding.net/rosydev/jx-callback into jdshop

business/jxstore/misc/misc.go

@@ -195,7 +195,7 @@ func Init() {
 		// 每分钟轮询一次,推送抖店骑手信息
 		ScheduleTimerFuncByInterval(func() {
 			delivery.UpdateFakeWayBillToTiktok()
-		}, 10*time.Second, 1*time.Minute)
+		}, 10*time.Second, 30*time.Second)
 
 		// 定时任务更新负责人信息
 		ScheduleTimerFunc("RefreshStoreOperator", func() {

business/model/dao/dao_order.go

@@ -1411,7 +1411,7 @@ func GetWayBillFakeOrder() (waybills []*model.Waybill, err error) {
 			WHERE waybill_vendor_id = ? AND status < ? AND waybill_created_at>= ? AND waybill_created_at< ? 
 	`
 
-	sqlParams := []interface{}{model.VendorJXFakeWL, model.WaybillStatusFailed, time.Now().Add(-7 * 24 * time.Hour), time.Now()}
+	sqlParams := []interface{}{model.VendorJXFakeWL, model.WaybillStatusFailed, time.Now().Add(-2 * 24 * time.Hour), time.Now()}
 	err = GetRows(GetDB(), &waybills, sql, sqlParams)
 	return waybills, err
 }

business/partner/delivery/rider.go

@@ -53,6 +53,9 @@ func GetOrderRiderInfoToPlatform(orderId string, wayBillStatus int) {
 	//3.当同一个订单已经上传了一次配送信息，如再次同步会更新配送信息，以最新的一次为准。
 	//4.如订单已完成、已取消等状态发货将失败。
 	for _, v := range orders {
+		if orderId == "" && v.VendorID == model.VendorIDDD { // 抖音门店订单除了三方配送回调时推送,不在主动推送配送消息
+			continue
+		}
 		if orderId == "" { // 订单id为空是,是定时轮询操作,不做此状态
 			waybillList, _ := dao.GetWaybills(dao.GetDB(), v.VendorOrderID)
 			if len(waybillList) > 0 && waybillList[0].Status > model.WaybillStatusEndBegin {
@@ -190,11 +193,7 @@ func UpdateOrder2Complete() {
 
 // UpdateFakeWayBillToTiktok 轮询更新假订单到抖音
 func UpdateFakeWayBillToTiktok() {
-	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())
@@ -206,6 +205,7 @@ func UpdateFakeWayBillToTiktok() {
 
 	for i := 0; i < len(fakeWayBill); i++ {
 		// 判断当前订单是否可以推送,UpdatedAt > 当前时间 就跳过
+		globals.SugarLogger.Debugf("updateTiem ==== %s,i=[%d],timeNow[%s]", fakeWayBill[i].ModelTimeInfo.UpdatedAt, i, time.Now())
 		if fakeWayBill[i].ModelTimeInfo.UpdatedAt.After(time.Now()) {
 			continue
 		}