This commit is contained in:
邹宗楠
2022-05-16 14:49:25 +08:00
parent b5bad1cdd7
commit 6c57a0d389
2 changed files with 6 additions and 4 deletions

View File

@@ -94,8 +94,9 @@ func (c *DeliveryHandler) onWaybillMsg(msg *dadaapi.CallbackMsg) (retVal *dadaap
default:
order.Status = model.WaybillStatusUnknown
}
delivery.GetOrderRiderInfoToPlatform(order.VendorOrderID)// 骑手位置更新
return dadaapi.Err2CallbackResponse(partner.CurOrderManager.OnWaybillStatusChanged(order), utils.Int2Str(order.Status))
err := dadaapi.Err2CallbackResponse(partner.CurOrderManager.OnWaybillStatusChanged(order), utils.Int2Str(order.Status))
delivery.GetOrderRiderInfoToPlatform(order.VendorOrderID) // 骑手位置更新
return err
}
func (c *DeliveryHandler) callbackMsg2Waybill(msg *dadaapi.CallbackMsg) (retVal *model.Waybill) {

View File

@@ -119,9 +119,10 @@ func (c *DeliveryHandler) onWaybillMsg(msg *mtpsapi.CallbackOrderMsg) (retVal *m
c.pushToGy(msg)
return mtpsapi.SuccessResponse
}
delivery.GetOrderRiderInfoToPlatform(order.VendorOrderID)// 骑手位置更新
err := mtpsapi.Err2CallbackResponse(partner.CurOrderManager.OnWaybillStatusChanged(order), order.VendorStatus)
delivery.GetOrderRiderInfoToPlatform(order.VendorOrderID) // 骑手位置更新
// 加入调度器
return mtpsapi.Err2CallbackResponse(partner.CurOrderManager.OnWaybillStatusChanged(order), order.VendorStatus)
return err
}
func (c *DeliveryHandler) pushToGy(msg *mtpsapi.CallbackOrderMsg) {