Merge branch 'jdshop' of e.coding.net:rosydev/jx-callback into jdshop

This commit is contained in:
邹宗楠
2022-12-28 11:18:21 +08:00

View File

@@ -1086,7 +1086,6 @@ func (s *DefScheduler) swtich2SelfDeliverWithRetry(savedOrderInfo *WatchOrderInf
// 这个函数这样写的原因是适应一些消息错序
func (s *DefScheduler) loadSavedOrderFromMap(status *model.OrderStatus, isForceLoad bool) *WatchOrderInfo {
universalOrderID := jxutils.ComposeUniversalOrderID(status.RefVendorOrderID, status.RefVendorID) // 等于RefVendorOrderID
globals.SugarLogger.Debugf("status====%s,universalOrderID=========%s", utils.Format4Output(status, false), universalOrderID)
var realSavedInfo *WatchOrderInfo
if savedInfo, ok := s.orderMap.Load(universalOrderID); ok {
realSavedInfo = savedInfo.(*WatchOrderInfo)
@@ -1095,10 +1094,8 @@ func (s *DefScheduler) loadSavedOrderFromMap(status *model.OrderStatus, isForceL
realSavedInfo = NewWatchOrderInfo(nil)
s.orderMap.StoreWithTimeout(universalOrderID, realSavedInfo, orderMapStoreMaxTime)
}
globals.SugarLogger.Debugf("pre loadSavedOrderFromMap realSavedInfo===========%s", utils.Format4Output(realSavedInfo, false))
if isForceLoad {
if order, err := partner.CurOrderManager.LoadOrder(status.RefVendorOrderID, status.RefVendorID); err == nil {
globals.SugarLogger.Debugf("isForceLoad order======%s", utils.Format4Output(order, false))
realSavedInfo.SetOrder(order)
} else {
realSavedInfo.SetOrder(&model.GoodsOrder{
@@ -1109,7 +1106,6 @@ func (s *DefScheduler) loadSavedOrderFromMap(status *model.OrderStatus, isForceL
OrderCreatedAt: status.StatusTime,
WaybillVendorID: model.VendorIDUnknown,
})
globals.SugarLogger.Debugf("after loadSavedOrderFromMap realSavedInfo=========%s", utils.Format4Output(realSavedInfo, false))
}
}
return realSavedInfo