liulei/jx-callback
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

回滚

Browse Source
This commit is contained in:
邹宗楠
2022-03-07 10:44:17 +08:00
parent d6697d18fe
commit 18d8c23d98
1 changed files with 32 additions and 36 deletions
Download Patch File Download Diff File Expand all files Collapse all files

50
business/jxcallback/scheduler/defsch/defsch_ext.go
View File

@@ -370,50 +370,46 @@ func (s *DefScheduler) QueryOrderWaybillFeeInfoEx(ctx *jxcontext.Context, vendor
} }
for _, storeCourier := range storeCourierList { for _, storeCourier := range storeCourierList {
var feeInfo *partner.WaybillFeeInfo var feeInfo *partner.WaybillFeeInfo
// 无订单
if waybillMap[storeCourier.VendorID] != nil { if waybillMap[storeCourier.VendorID] != nil {
feeInfo = &partner.WaybillFeeInfo{ feeInfo = &partner.WaybillFeeInfo{
Waybill: waybillMap[storeCourier.VendorID], Waybill: waybillMap[storeCourier.VendorID],
} }
continue } else {
}
// 未开通运营联系
if storeCourier.Status != model.StoreStatusOpened { if storeCourier.Status != model.StoreStatusOpened {
feeInfo = &partner.WaybillFeeInfo{ feeInfo = &partner.WaybillFeeInfo{
ErrCode: partner.WaybillFeeErrCodeCourierNotOpen, ErrCode: partner.WaybillFeeErrCodeCourierNotOpen,
ErrStr: fmt.Sprintf("暂未开通，联系运营"), ErrStr: fmt.Sprintf("暂未开通，联系运营"),
} }
continue } else {
} if handler := partner.GetDeliveryPlatformFromVendorID(storeCourier.VendorID); handler != nil {
// 获取订单处理对线 if handler.Use4CreateWaybill {
handler := partner.GetDeliveryPlatformFromVendorID(storeCourier.VendorID)
if handler == nil {
feeInfo = &partner.WaybillFeeInfo{
ErrCode: partner.WaybillFeeErrCodeCourierNotSupported,
ErrStr: fmt.Sprintf("内部错误，%d不被支持", storeCourier.VendorID),
}
continue
}
if !handler.Use4CreateWaybill {
feeInfo = &partner.WaybillFeeInfo{
ErrCode: partner.WaybillFeeErrCodeCourierForbidden,
ErrStr: fmt.Sprintf("内部错误，%d不能用于创建运单", storeCourier.VendorID),
}
continue
}
// 获取订单配送费用
globals.SugarLogger.Info("获取美团运单开始", handler.Handler.GetVendorID()) globals.SugarLogger.Info("获取美团运单开始", handler.Handler.GetVendorID())
feeInfo, err = handler.Handler.GetWaybillFee(order) // 获取订单配送费用
if err != nil { if feeInfo, err = handler.Handler.GetWaybillFee(order); err != nil {
feeInfo = &partner.WaybillFeeInfo{ feeInfo = &partner.WaybillFeeInfo{
ErrCode: partner.WaybillFeeErrCodeCourierOthers, ErrCode: partner.WaybillFeeErrCodeCourierOthers,
ErrStr: err.Error(), ErrStr: err.Error(),
} }
continue } else {
}
feeInfo.TimeoutSecond = timeoutSecond feeInfo.TimeoutSecond = timeoutSecond
}
} else {
feeInfo = &partner.WaybillFeeInfo{
ErrCode: partner.WaybillFeeErrCodeCourierForbidden,
ErrStr: fmt.Sprintf("内部错误，%d不能用于创建运单", storeCourier.VendorID),
}
}
} else {
feeInfo = &partner.WaybillFeeInfo{
ErrCode: partner.WaybillFeeErrCodeCourierNotSupported,
ErrStr: fmt.Sprintf("内部错误，%d不被支持", storeCourier.VendorID),
}
}
}
}
deliveryFeeMap[storeCourier.VendorID] = feeInfo deliveryFeeMap[storeCourier.VendorID] = feeInfo
} }
err = nil
return deliveryFeeMap, err return deliveryFeeMap, err
}() }()
}, jxutils.ComposeUniversalOrderID(vendorOrderID, vendorID)) }, jxutils.ComposeUniversalOrderID(vendorOrderID, vendorID))