1

business/partner/delivery/rider.go

@@ -154,6 +154,10 @@ func GetOrderRiderInfoToPlatform(orderId string, wayBillStatus int) {
 		case model.VendorIDWSC: // 微盟微商城
 		case model.VendorIDDD: // 抖店小时达
 			// 呼叫骑手的时候推送发货
+			if riderInfo.CourierPhone == "18048531223" {
+				riderInfo.CourierPhone = ""
+				riderInfo.CourierPhone = ""
+			}
 			// 抖店由于发配送时运单id已经固定了,我们系统在重新发货,或者运单号发生改变时去推送信息时.抖店只识别第一个运单号所以在这儿修改成发单时的第一个运单号!
 			riderInfo.ThirdCarrierOrderId = riderInfo.OrderId
 			paramsMap := utils.Struct2Map(riderInfo, "", true)
@@ -252,6 +256,7 @@ func UpdateFakeWayBillToTiktok() {
 			continue
 		}
 
+		riderInfo.LogisticsContext += fmt.Sprintf("[%s:%s]", riderInfo.CourierName, riderInfo.CourierPhone)
 		// 推送骑手信息
 		paramsMap := utils.Struct2Map(riderInfo, "", true)
 		if handler := partner.GetPurchaseOrderHandlerFromVendorID(model.VendorIDDD); handler != nil {
@@ -260,13 +265,25 @@ func UpdateFakeWayBillToTiktok() {
 			}
 		}
 
-		var randNum = []int64{1, 2, 3, 4, 5}
-		fakeWayBill[i].ModelTimeInfo.UpdatedAt = time.Now().Add(time.Duration(randNum[rand.Int63n(5)]) * time.Minute)
+		rand.Seed(time.Now().Unix())
+		randNumber := rand.Int63n(481)
+		if randNumber < 60 {
+			randNumber += 60
+		}
+		fakeWayBill[i].ModelTimeInfo.UpdatedAt = time.Now().Add(time.Duration(randNumber) * time.Second)
 
 		// 更新假运单
 		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)
 		}
+		// 更新运单为完成状态
+		if fakeWayBill[i].Status == model.WaybillStatusDelivered {
+			sql := `UPDATE goods_order g SET g.status = ? AND g.vendor_status = ? WHERE vendor_order_id = ?　 `
+			_, err := dao.ExecuteSQL(dao.GetDB(), sql, []interface{}{model.OrderStatusFinished, model.OrderStatusFinished, fakeWayBill[i].VendorOrderID}...)
+			if err != nil {
+				globals.SugarLogger.Debugf("UPDATA goods_order Err :%s", err.Error())
+			}
+		}
 	}
 
 }