[發明專利]物流軌跡推送方法、裝置、設備及存儲介質

在審

• 申請號: 202210003453.4
• 申請日: 2022-01-04
• 公開（公告）號: CN114528458A
• 公開（公告）日: 2022-05-24
• 發明（設計）人: 王飛翔;楊周龍;牛飛燕;鄒景春
• 申請（專利權）人: 上海東普信息科技有限公司
• 主分類號: G06F16/951
• 分類號: G06F16/951;G06F16/9537;G06F16/2455;H04L67/12;H04L67/55;G06Q10/08
• 代理公司: 暫無信息
• 代理人: 暫無信息

本發明涉及物流技術技術領域，公開了一種物流軌跡推送方法、裝置、設備及存儲介質，所述方法包括：調用預置訂閱接口獲取物流訂單信息，并將所述物流訂單信息傳輸至預置的訂單數據庫；采用Redis分布式緩存從所述訂單數據庫中的抓取所述物流訂單信息獲取掃描終端實時傳輸的物流掃描信息；將所述物流訂單信息和所述物流掃描信息進行數據碰撞比對，得到碰撞結果和物流運輸軌跡；當所述碰撞結果為碰撞成功時，將所述物流運輸軌跡推送至對應的目標終端；本發明避免物流時間跨度長導致物流數據漏推，保證物流訂單信息生產完成后，高速處理，提高大數據處理效率和對接響應速度快，保障實時推送成功率，并及時記錄全鏈路異常推送日志，降低維護成本。

技術領域

本發明涉及物流技術領域，尤其涉及一種物流軌跡推送方法、裝置、設備及存儲介質。

背景技術

目前，物流行業已經處于高速發展期，各個物流公司之間的競爭也日益加劇，因此時效性日漸成為評判物流公司信譽的一個主要制約因素，而快遞包裹在收攬件和運輸途徑的物流軌跡可以時刻被目標用戶所關注，也可以間接反映物流的時效性。

通常的物流推送接口只能存儲15天內訂單數據，不滿足物流軌跡跨15天外的業務場景；服務器每日處理數億軌跡數據，效率低，容易出錯，難排查；通常每條業務線對接物流軌跡需要每對接一條業務線開發一次代碼，成本巨大，維護成本劇增。

發明內容

有鑒于此，有必要針對效率低、容易出錯等的問題，提供一種物流軌跡推送方法、裝置、設備及存儲介質。

一種物流軌跡推送方法，所述物流軌跡推送方法包括以下步驟：

調用預置訂閱接口獲取物流訂單信息，并將所述物流訂單信息傳輸至預置的訂單數據庫；

采用Redis分布式緩存從所述訂單數據庫中的抓取所述物流訂單信息；

獲取掃描終端實時傳輸的物流掃描信息；

將所述物流訂單信息和所述物流掃描信息進行數據碰撞比對，得到碰撞結果和物流運輸軌跡；

當所述碰撞結果為碰撞成功時，將所述物流運輸軌跡推送至對應的目標終端。

在其中一個實施例中，所述物流訂單信息至少包括第一訂單號、第一運單號、收件人信息、發件人信息，所述物流掃描信息至少包括掃描時間、第二訂單號、第二運單號、掃描類型、備注編碼。

在其中一個實施例中，獲取所述物流訂單信息，并將所述物流訂單信息存儲至Redis隊列和歷史軌跡處理隊列中；

啟動多個消費進程，通過所述消費進程對所述Redis隊列中的所述物流訂單信息進行消費處理，并對消費處理過程進行監控；

若消費處理過程中監控到異常數據，則記錄到異常日志，重新將所述異常日志中的所述物流訂單信息存儲至Redis隊列中并進行消費處理；

將消費完成的所述物流訂單信息批量傳輸至預置的訂單數據庫中。

在其中一個實施例中，實時接收掃描終端發送的物流掃描信息，并將所述物流掃描信息傳輸至Kafka平臺；

實時消費所述Kafka平臺中的所述物流掃描信息，并基于歷史軌跡處理隊列查詢是否存在歷史軌跡；

若不存在，則對所述物流掃描信息進行過濾。

在其中一個實施例中，分別對所述物流訂單信息和所述物流掃描信息解析得到第一運單號和第二運單號；

對所述第一運單號和所述第二運單號進行碰撞，得到碰撞結果；

若所述碰撞結果為第一運單號和所述第二運單號相同，則將所述物流訂單信息和所述物流掃描信息進行數據合并，以得到對應的物流運輸軌跡；

將所述物流運輸軌跡存儲至待推送隊列。