[發明專利]一種基于Redis的對賬方法及系統

在審

• 申請號: 202210921245.2
• 申請日: 2022-08-02
• 公開（公告）號: CN115145939A
• 公開（公告）日: 2022-10-04
• 發明（設計）人: 楊瀚;李家菁;汪日清;劉湘璇;杜曉雪
• 申請（專利權）人: 深圳市雁聯計算系統有限公司
• 主分類號: G06F16/23
• 分類號: G06F16/23;G06F16/215;G06F16/25;G06F16/28;G06F9/54;G06Q40/04
• 代理公司: 廣州市華學知識產權代理有限公司 44245
• 代理人: 于波

1.一種基于Redis的對賬方法，其特征在于，包括以下步驟：

依托調度框架，定時觸發對賬任務初始化流程，根據各支付渠道對賬文件配置模板生成對賬任務；

將對賬任務寫入延遲隊列，在符合拉取規則時觸發延遲隊列發送對應支付渠道對賬文件拉取消息，拉取對賬文件；

配置各渠道所拉取的對賬文件類型、報文格式后，將各渠道對賬數據轉換為統一格式；

拉取與各渠道對賬數據對應的系統交易數據，并對系統交易數據進行清洗過濾；

將相應的渠道對賬數據與系統交易數據按照Redis對比指定格式分別推送至Redis集群兩個集合中，然后對集合進行對比并生成對賬結果。

2.根據權利要求1所述的基于Redis的對賬方法，其特征在于，所述拉取對賬文件后，還包括將拉取的對賬文件存入MinIO，具體包括：

計算所拉取對賬文件MD5值，并用MD5值作為MinIO對象名；

通過對象名調用MinIO封裝方法對對賬文件進行查重；

如果已存在則直接返回對賬文件拉取成功；如果不存在則通過MinIO上傳封裝方法將對賬文件上傳至MinIO指定對象桶存儲，對賬文件上傳成功后MinIO返回對象名，然后返回對賬文件拉取成功；

更新相關數據與MinIO對象名進行關聯。

3.根據權利要求2所述的基于Redis的對賬方法，其特征在于，所述將各渠道對賬數據轉換為統一格式是通過文件解析引擎，根據對賬文件渠道類型、MinIO對象桶名、MinIO對象名進行對賬數據的解析及轉換處理。

4.根據權利要求3所述的基于Redis的對賬方法，其特征在于，所述將各渠道對賬數據轉換為統一格式具體包括：

文件解析引擎通過MinIO對象桶名、MinIO對象名下載對應對賬文件，然后轉換為文件流推入文件解析引擎；

文件解析引擎判斷文件是否為Txt文件，如果不是則將其轉為Txt；

文件統一為Txt后，文件解析引擎獲取對應渠道的對賬文件字段與統一格式字段的映射關系；

引擎內部的解析工廠通過動態代理框架，按照配置信息與解析模版動態創建對應渠道的解析實現類；

調用動態實現類對文件進行逐行解析轉換為統一格式。

5.根據權利要求4所述的基于Redis的對賬方法，其特征在于，所述方法還包括：

如果當前解析模版不適用于當前渠道，則編寫具體解析代碼、打包成Jar文件并上傳；

文件解析引擎在解析時判斷當前渠道是否存在自定義實現方法，若存在，則通過自封裝類加載器將Jar文件中對應的Class文件加載進入系統；

通過動態代理框架為解析接口代理自定義實現方法完成文件解析操作。

6.根據權利要求1所述的基于Redis的對賬方法，其特征在于，所述對集合進行對比并生成對賬結果包括：

對兩個集合進行對比，得出交集，并存入Redis交集集合中；

對兩個集合進行對比，得出差集，并存入Redis差集集合中；

獲取Redis交集中的數據，將對應數據的對賬數據更新為對賬完成；

獲取Redis差集中的數據，判斷對應數據屬于何種差異，若是系統能自行糾錯的差異，則系統自行糾錯并將對應數據的對賬數據更新為對賬完成；

若不能進行自行糾錯則將對應數據的對賬數據更新為對賬錯誤，并寫入對賬差錯表中。

7.根據權利要求1所述的基于Redis的對賬方法，其特征在于，所述拉取對賬文件若拉取失敗，則拉取消息回滾至延遲隊列消息隊列中，延遲后再次觸發。

8.根據權利要求1所述的基于Redis的對賬方法，其特征在于，所述對集合進行對比并生成對賬結果后，還包括出具對賬結果報表：統計各渠道對賬數據、差錯數據，處理數據并生成報表。

9.根據權利要求1至8任一項所述的基于Redis的對賬方法，其特征在于，所述方法每個步驟均設有相應的監控及事件報警。

10.一種基于Redis的對賬系統，其特征在于，包括以下模塊：

任務初始化模塊：用于定時觸發對賬任務初始化流程，根據各支付渠道對賬文件配置模板生成對賬任務；

第一獲取模塊：用于根據延遲隊列發送對應支付渠道對賬文件拉取消息，拉取對賬文件；

文件解析模塊：用于配置各渠道所拉取的對賬文件類型、報文格式，將各渠道對賬數據轉換為統一格式；

第二獲取模塊：用于拉取與第一獲取模塊所拉取對賬文件對應的系統交易數據，并將其清洗過濾；

對賬模塊：用于將第一獲取模塊和第二獲取模塊所獲取的數據按照Redis對比指定格式分別推送至Redis集群兩個集合中，對集合進行對比，完成對賬。