1

business/partner/delivery/dada/waybill.go

@@ -96,7 +96,7 @@ func (c *DeliveryHandler) onWaybillMsg(msg *dadaapi.CallbackMsg) (retVal *dadaap
 		order.Status = model.WaybillStatusUnknown
 	}
 	err := dadaapi.Err2CallbackResponse(partner.CurOrderManager.OnWaybillStatusChanged(order), utils.Int2Str(order.Status))
-	defer delivery.GetOrderRiderInfoToPlatform(order.VendorOrderID) // 骑手位置更新
+	defer delivery.GetOrderRiderInfoToPlatform(order.VendorOrderID, order.Status) // 骑手位置更新
 	return err
 }
 
@@ -456,8 +456,8 @@ func (c *DeliveryHandler) GetRiderInfo(orderId string, deliveryId int64, mtPeiso
 	}
 
 	switch order.StatusCode {
-	case dadaapi.OrderStatusWaitingForAccept: // 待接单
-		result.LogisticsStatus = model.WaybillStatusAccepted
+	case dadaapi.OrderStatusWaitingForAccept: // 待接单,召唤骑手
+		result.LogisticsStatus = model.WaybillStatusAcceptCanceled
 		result.LogisticsContext = model.RiderWaitRider
 	case dadaapi.OrderStatusAccepted: // 待取货
 		result.LogisticsStatus = model.WaybillStatusCourierAssigned // 分配骑手

business/partner/delivery/fn/waybill.go

@@ -255,7 +255,7 @@ func OnWaybillMsg(msg *fnpsapi.OrderStatusNottify) (resp *fnpsapi.CallbackRespon
 	if err := partner.CurOrderManager.OnWaybillStatusChanged(order); err != nil {
 		return fnpsapi.Err2CallbackResponse(err, "")
 	}
-	defer delivery.GetOrderRiderInfoToPlatform(order.VendorOrderID) // 骑手位置更新
+	defer delivery.GetOrderRiderInfoToPlatform(order.VendorOrderID, order.Status) // 骑手位置更新
 	return fnpsapi.Err2CallbackResponse(nil, "")
 }
 
@@ -316,6 +316,9 @@ func (c *DeliveryHandler) GetRiderInfo(orderId string, deliveryId int64, mtPeiso
 	}
 
 	switch order.OrderStatus {
+	case 0: // 新订单
+		result.LogisticsStatus = model.WaybillStatusNew
+		result.LogisticsContext = model.RiderWaitRider
 	case 20: // 骑手接单
 		result.LogisticsStatus = model.WaybillStatusCourierAssigned
 		result.LogisticsContext = model.RiderGetOrder

business/partner/delivery/mtps/waybill.go

@@ -88,7 +88,7 @@ func (c *DeliveryHandler) onWaybillMsg(msg *mtpsapi.CallbackOrderMsg) (retVal *m
 	if msg.Status == mtpsapi.OrderStatusPickedUp {
 		order.Status = model.WaybillStatusCourierArrived
 		mtpsapi.Err2CallbackResponse(partner.CurOrderManager.OnWaybillStatusChanged(order), order.VendorStatus)
-		delivery.GetOrderRiderInfoToPlatform(order.VendorOrderID) // 推送假的到店
+		defer delivery.GetOrderRiderInfoToPlatform(order.VendorOrderID, order.Status) // 骑手位置更新
 		msg.Status = mtpsapi.OrderStatusPickedUp
 	}
 	switch msg.Status {
@@ -125,7 +125,7 @@ func (c *DeliveryHandler) onWaybillMsg(msg *mtpsapi.CallbackOrderMsg) (retVal *m
 	}
 	// 加入调度器
 	err := mtpsapi.Err2CallbackResponse(partner.CurOrderManager.OnWaybillStatusChanged(order), order.VendorStatus)
-	defer delivery.GetOrderRiderInfoToPlatform(order.VendorOrderID) // 骑手位置更新
+	defer delivery.GetOrderRiderInfoToPlatform(order.VendorOrderID, order.Status) // 骑手位置更新
 	return err
 }
 
@@ -415,6 +415,9 @@ func (c *DeliveryHandler) GetRiderInfo(orderId string, deliveryId int64, mtPeiso
 		Longitude:             utils.Float64ToStr(jxutils.IntCoordinate2Standard(lng)),
 	}
 	switch int(utils.MustInterface2Int64(order["status"])) {
+	case 0:
+		result.LogisticsStatus = model.WaybillStatusNew
+		result.LogisticsContext = model.RiderWaitRider
 	case 20: //已接单
 		result.LogisticsStatus = model.WaybillStatusCourierAssigned
 		result.LogisticsContext = model.RiderGetOrder

business/partner/delivery/rider.go

@@ -26,7 +26,7 @@ import (
 //40-骑手已送达（C端：商品已送达；B端：骑手已送达）
 //100-配送单已取消（C端：商家已接单；B端：配送已取消）
 //注：若同步配送状态为“配送单已取消”，接口仍支持继续同步配送状态。 说明：商家如未上传此信息，则平台默认值为20（现已要求必传）。
-func GetOrderRiderInfoToPlatform(orderId string) {
+func GetOrderRiderInfoToPlatform(orderId string, wayBillStatus int) {
 	params := make(map[string]interface{}, 0)
 	params["isDateFinish"] = false
 	params["isIncludeFake"] = true
@@ -85,6 +85,11 @@ func GetOrderRiderInfoToPlatform(orderId string) {
 
 		riderInfo.ThirdCarrierOrderId = v.VendorWaybillID
 		switch riderInfo.LogisticsStatus {
+		case 5: // 呼叫骑手
+			riderInfo.LogisticsStatus = 0
+			riderInfo.CourierName = ""
+			riderInfo.CourierPhone = ""
+			riderInfo.OpCode = tiktok_api.TiktokLogisticsStatusCALLRIDER
 		case 12: // 骑手接单
 			riderInfo.LogisticsStatus = 12
 			riderInfo.OpCode = tiktok_api.TiktokLogisticsORDERRECEIVED

business/partner/delivery/rider_test.go

@@ -3,5 +3,5 @@ package delivery
 import "testing"
 
 func TestRider(t *testing.T) {
-	GetOrderRiderInfoToPlatform("144228632526740576")
+	GetOrderRiderInfoToPlatform("144228632526740576", 0)
 }