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

- 变更updateBillsInfo的实现，每次将最新的bill存入cache

Browse Source
This commit is contained in:
gazebo
2019-06-16 21:08:00 +08:00
parent d65b49002e
commit 6732a64123
1 changed files with 7 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
business/jxcallback/scheduler/defsch/defsch.go
View File

@@ -546,7 +546,7 @@ func (s *DefScheduler) OnWaybillStatusChanged(bill *model.Waybill, isPending boo
default: default:
s.resetTimer(savedOrderInfo, bill, isPending) s.resetTimer(savedOrderInfo, bill, isPending)
} }
s.updateBillsInfo(savedOrderInfo, bill) // 更新可能的运单状态变化 // s.updateBillsInfo(savedOrderInfo, bill) // 更新可能的运单状态变化
} }
// } // }
} }
@@ -927,12 +927,13 @@ func (s *DefScheduler) updateBillsInfo(savedOrderInfo *WatchOrderInfo, bill *mod
if savedOrderInfo != nil { if savedOrderInfo != nil {
if savedBill := savedOrderInfo.waybills[bill.WaybillVendorID]; savedBill != nil { if savedBill := savedOrderInfo.waybills[bill.WaybillVendorID]; savedBill != nil {
isBillExist = true isBillExist = true
if savedBill.Status > bill.Status { // if savedBill.Status > bill.Status {
bill.Status = savedBill.Status // bill.Status = savedBill.Status
} else if bill.Status > savedBill.Status { // } else if bill.Status > savedBill.Status {
savedBill.Status = bill.Status // savedBill.Status = bill.Status
} // }
} }
savedOrderInfo.waybills[bill.WaybillVendorID] = bill
} }
return isBillExist return isBillExist
} }