This commit is contained in:
邹宗楠
2023-11-30 16:22:33 +08:00
parent d23ba08091
commit 9cf6125a03
4 changed files with 14 additions and 7 deletions

View File

@@ -132,7 +132,7 @@ func (c *DeliveryHandler) onWaybillMsg(msg *dadaapi.CallbackMsg) (retVal *dadaap
func tiktokStatusPush(order *model.Waybill, status int, lng, lat string) { func tiktokStatusPush(order *model.Waybill, status int, lng, lat string) {
result := &utils.RiderInfo{ result := &utils.RiderInfo{
OrderId: order.VendorOrderID, OrderId: order.VendorOrderID,
ThirdCarrierOrderId: order.VendorWaybillID, ThirdCarrierOrderId: order.VendorOrderID,
CourierName: order.CourierName, CourierName: order.CourierName,
CourierPhone: order.CourierMobile, CourierPhone: order.CourierMobile,
LogisticsStatus: order.Status, LogisticsStatus: order.Status,

View File

@@ -325,7 +325,7 @@ func OnWaybillMsg(msg *fnpsapi.OrderStatusNottify, resultParam *fnpsapi.ShortSta
func tiktokStatusPush(order *model.Waybill, orderStatus int64, lng, lat string) { func tiktokStatusPush(order *model.Waybill, orderStatus int64, lng, lat string) {
result := &utils.RiderInfo{ result := &utils.RiderInfo{
OrderId: order.VendorOrderID, OrderId: order.VendorOrderID,
ThirdCarrierOrderId: order.VendorWaybillID, ThirdCarrierOrderId: order.VendorOrderID,
CourierName: order.CourierName, CourierName: order.CourierName,
CourierPhone: order.CourierMobile, CourierPhone: order.CourierMobile,
LogisticsStatus: order.Status, LogisticsStatus: order.Status,

View File

@@ -199,6 +199,7 @@ func GetOrderRiderInfoToPlatform(orderId string, wayBillStatus int) {
if riderInfo.OrderId == "" { if riderInfo.OrderId == "" {
riderInfo.OrderId = v.VendorOrderID riderInfo.OrderId = v.VendorOrderID
// 10001-顺丰, 10002-达达, 10003-闪送, 10004-蜂鸟, 10005 UU跑腿,10006 快跑者, 10007 极客快送,10008-点我达,10009 同达, 10010-生活半径,10011 邻趣,10012 趣送, 10013 快服务 10014 菜鸟新配盟 10015 商家自建配送 10016 风先生,10017-其他,10032-美团跑腿。
riderInfo.LogisticsProviderCode = "10017" riderInfo.LogisticsProviderCode = "10017"
} }
@@ -229,6 +230,8 @@ func GetOrderRiderInfoToPlatform(orderId string, wayBillStatus int) {
case model.VendorIDWSC: // 微盟微商城 case model.VendorIDWSC: // 微盟微商城
continue continue
case model.VendorIDDD: // 抖店小时达 case model.VendorIDDD: // 抖店小时达
riderInfo.LogisticsProviderCode = utils.JxVendorId2TiktokCode(v.WaybillVendorID)
riderInfo.ThirdCarrierOrderId = v.VendorOrderID
if handler := partner.GetPurchaseOrderHandlerFromVendorID(v.VendorID); handler != nil { if handler := partner.GetPurchaseOrderHandlerFromVendorID(v.VendorID); handler != nil {
if err := handler.GetOrderRider(v.VendorOrgCode, v.VendorStoreID, utils.Struct2Map(riderInfo, "", true)); err != nil { if err := handler.GetOrderRider(v.VendorOrgCode, v.VendorStoreID, utils.Struct2Map(riderInfo, "", true)); err != nil {
globals.SugarLogger.Debugf("Error pushing meituan rider information :%s--%s--%v", v.VendorOrderID, utils.Format4Output(riderInfo, false), err) globals.SugarLogger.Debugf("Error pushing meituan rider information :%s--%s--%v", v.VendorOrderID, utils.Format4Output(riderInfo, false), err)
@@ -436,6 +439,7 @@ func UpdateFakeWayBillToTiktok() {
if riderInfo.LogisticsContext != model.RiderGetOrderDeliverFailed && riderInfo.LogisticsContext != model.RiderGetOrderDeliverOther && riderInfo.LogisticsContext != model.RiderWaitRider { if riderInfo.LogisticsContext != model.RiderGetOrderDeliverFailed && riderInfo.LogisticsContext != model.RiderGetOrderDeliverOther && riderInfo.LogisticsContext != model.RiderWaitRider {
riderInfo.LogisticsContext = fmt.Sprintf(riderInfo.LogisticsContext, riderInfo.CourierName, riderInfo.CourierPhone) riderInfo.LogisticsContext = fmt.Sprintf(riderInfo.LogisticsContext, riderInfo.CourierName, riderInfo.CourierPhone)
} }
riderInfo.LogisticsProviderCode = utils.JxVendorId2TiktokCode(fakeWayBill[i].WaybillVendorID)
// 推送骑手信息 // 推送骑手信息
paramsMap := utils.Struct2Map(riderInfo, "", true) paramsMap := utils.Struct2Map(riderInfo, "", true)

View File

@@ -633,7 +633,7 @@ func (c *PurchaseHandler) SelfDeliverDelivering(order *model.GoodsOrder, userNam
param := &order_logisticsAdd_request.OrderLogisticsAddParam{ param := &order_logisticsAdd_request.OrderLogisticsAddParam{
OrderId: order.VendorOrderID, OrderId: order.VendorOrderID,
Company: "", Company: "",
CompanyCode: "chengdouruoxi", CompanyCode: "",
LogisticsCode: order.VendorOrderID, LogisticsCode: order.VendorOrderID,
IsRefundReject: false, IsRefundReject: false,
IsRejectRefund: false, IsRejectRefund: false,
@@ -641,6 +641,7 @@ func (c *PurchaseHandler) SelfDeliverDelivering(order *model.GoodsOrder, userNam
AddressId: 0, AddressId: 0,
StoreId: utils.Str2Int64(order.VendorStoreID), StoreId: utils.Str2Int64(order.VendorStoreID),
} }
param.CompanyCode = utils.JxVendorId2TiktokCode(order.WaybillVendorID)
err = getAPI(order.VendorOrgCode, jxutils.GetSaleStoreIDFromOrder(order), "").OrderDelivering(param) err = getAPI(order.VendorOrgCode, jxutils.GetSaleStoreIDFromOrder(order), "").OrderDelivering(param)
if err != nil { if err != nil {
return err return err
@@ -651,7 +652,7 @@ func (c *PurchaseHandler) SelfDeliverDelivering(order *model.GoodsOrder, userNam
ThirdCarrierOrderId: order.VendorOrderID, ThirdCarrierOrderId: order.VendorOrderID,
CourierName: "", CourierName: "",
CourierPhone: "", CourierPhone: "",
LogisticsProviderCode: "10002", LogisticsProviderCode: param.CompanyCode,
LogisticsStatus: 0, LogisticsStatus: 0,
LogisticsContext: "呼叫骑手,新建运单", LogisticsContext: "呼叫骑手,新建运单",
Latitude: "", Latitude: "",
@@ -669,13 +670,14 @@ func (c *PurchaseHandler) SelfDeliverDelivered(order *model.GoodsOrder, userName
ThirdCarrierOrderId: order.VendorOrderID, ThirdCarrierOrderId: order.VendorOrderID,
CourierName: "", CourierName: "",
CourierPhone: "", CourierPhone: "",
LogisticsProviderCode: utils.MyselfPsCode, LogisticsProviderCode: "",
LogisticsStatus: 0, LogisticsStatus: 0,
LogisticsContext: "商家自配送,已送达", LogisticsContext: "商家自配送,已送达",
Latitude: "", Latitude: utils.Float64ToStr(jxutils.IntCoordinate2Standard(order.ConsigneeLat)),
Longitude: "", Longitude: utils.Float64ToStr(jxutils.IntCoordinate2Standard(order.ConsigneeLng)),
OpCode: tiktokShop.TiktokLogisticsDELIVERED, OpCode: tiktokShop.TiktokLogisticsDELIVERED,
} }
riderInfo.LogisticsProviderCode = utils.JxVendorId2TiktokCode(order.WaybillVendorID)
bills, _ := dao.GetWaybills(dao.GetDB(), order.VendorOrderID, nil) bills, _ := dao.GetWaybills(dao.GetDB(), order.VendorOrderID, nil)
for _, v := range bills { for _, v := range bills {
if v.Status == model.OrderStatusCanceled { if v.Status == model.OrderStatusCanceled {
@@ -684,6 +686,7 @@ func (c *PurchaseHandler) SelfDeliverDelivered(order *model.GoodsOrder, userName
riderInfo.CourierName = v.CourierName riderInfo.CourierName = v.CourierName
riderInfo.CourierPhone = v.CourierMobile riderInfo.CourierPhone = v.CourierMobile
} }
riderInfo.LogisticsProviderCode = utils.JxVendorId2TiktokCode(order.WaybillVendorID)
return c.GetOrderRider("", "", utils.Struct2MapByJson(riderInfo)) return c.GetOrderRider("", "", utils.Struct2MapByJson(riderInfo))
} }