[發(fā)明專利]物流軌跡推送方法、裝置、設(shè)備及存儲介質(zhì)

在審

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

1.一種物流軌跡推送方法，其特征在于，所述物流軌跡推送方法包括以下步驟：

調(diào)用預(yù)置訂閱接口獲取物流訂單信息，并將所述物流訂單信息傳輸至預(yù)置的訂單數(shù)據(jù)庫；

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

獲取掃描終端實時傳輸?shù)奈锪鲯呙栊畔ⅲ?/p>

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

當(dāng)所述碰撞結(jié)果為碰撞成功時，將所述物流運輸軌跡推送至對應(yīng)的目標(biāo)終端。

2.根據(jù)權(quán)利要求1所述的物流軌跡推送方法，其特征在于，所述物流訂單信息至少包括第一訂單號、第一運單號、收件人信息、發(fā)件人信息，所述物流掃描信息至少包括掃描時間、第二訂單號、第二運單號、掃描類型、備注編碼。

3.根據(jù)權(quán)利要求1所述的物流軌跡推送方法，其特征在于，所述將所述物流訂單信息傳輸至預(yù)置的訂單數(shù)據(jù)庫，包括：

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

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

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

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

4.根據(jù)權(quán)利要求1所述的物流軌跡推送方法，其特征在于，所述獲取掃描終端實時傳輸?shù)奈锪鲯呙栊畔ⅲǎ?/p>

實時接收掃描終端發(fā)送的物流掃描信息，并將所述物流掃描信息傳輸至Kafka平臺；

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

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

5.根據(jù)權(quán)利要求1所述的物流軌跡推送方法，其特征在于，所述將所述物流訂單信息和所述物流掃描信息進行數(shù)據(jù)碰撞比對，得到碰撞結(jié)果和物流運輸軌跡，包括：

分別對所述物流訂單信息和所述物流掃描信息解析得到第一運單號和第二運單號；

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

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

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

6.根據(jù)權(quán)利要求1所述的物流軌跡推送方法，其特征在于，所述當(dāng)所述碰撞結(jié)果為碰撞成功時，將所述物流運輸軌跡推送至對應(yīng)的目標(biāo)終端，包括：

獲取所述物流運輸軌跡對應(yīng)的所屬業(yè)務(wù)線；

根據(jù)所述所屬業(yè)務(wù)線對所述物流運輸軌跡進行分流處理，并將所述物流運輸軌跡推送至對應(yīng)的目標(biāo)終端，得到推送結(jié)果；

當(dāng)所述推送結(jié)果為推送失敗時，獲取預(yù)構(gòu)建的重推機制，利用所述重推機制將所述物流運輸軌跡重推至對應(yīng)的目標(biāo)終端；

獲取所述重推機制執(zhí)行的重推次數(shù)，并判斷所述重推次數(shù)是否超過預(yù)設(shè)的次數(shù)閾值；

若是，則標(biāo)記對應(yīng)的所述物流運輸軌跡為異常記錄，并將所述異常記錄推送至ELK日志中保存。

7.一種物流軌跡推送裝置，其特征在于，所述物流軌跡推送裝置包括：

調(diào)用模塊，用于調(diào)用預(yù)置訂閱接口獲取物流訂單信息，并將所述物流訂單信息傳輸至預(yù)置的訂單數(shù)據(jù)庫；

抓取模塊，用于采用Redis分布式緩存從所述訂單數(shù)據(jù)庫中的抓取所述物流訂單信息；

傳輸模塊，用于獲取掃描終端實時傳輸?shù)奈锪鲯呙栊畔ⅲ?/p>

碰撞模塊，用于將所述物流訂單信息和所述物流掃描信息進行數(shù)據(jù)碰撞比對，得到碰撞結(jié)果和物流運輸軌跡；

推送模塊，用于當(dāng)所述碰撞結(jié)果為碰撞成功時，將所述物流運輸軌跡推送至對應(yīng)的目標(biāo)終端。