[發明專利]一種基于異步消息的編排營銷方法及系統

在審

• 申請號: 202310458233.5
• 申請日: 2023-04-26
• 公開（公告）號: CN116485423A
• 公開（公告）日: 2023-07-25
• 發明（設計）人: 余曉剛
• 申請（專利權）人: 江蘇蘇寧銀行股份有限公司
• 主分類號: G06Q30/02
• 分類號: G06Q30/02;G06Q40/02;G06F16/215;G06F16/25
• 代理公司: 南京瑞華騰知識產權代理事務所(普通合伙) 32368
• 代理人: 徐沖沖

1.一種基于異步消息的編排營銷方法，其特征在于，包括：

接收各業務系統異步拋送的原始數據，并對所述原始數據進行數據清洗，然后轉化為標準數據；

對所述標準數據進行報文解析，并對報文的內容進行字段級拆分，處理形成標準報文結構的模型數據；

對標準報文結構的模型數據進行數據規則驗證匹配過濾；

對規則驗證通過的標準報文結構的模型數據進行計次、處理；

按照配置要求對客戶予以觸達。

2.根據權利要求1所述的一種基于異步消息的編排營銷方法，其特征在于，利用Flink對原始數據進行實時處理，將不同的來源數據處理為報文Message為json數據。

3.根據權利要求1所述的一種基于異步消息的編排營銷方法，其特征在于，采用SimHash算法對標準數據的來源及標準模型字段進行匹配；

若字段匹配度為100％，則直接進行標準模型轉換；

若閾值S1≤字段匹配度＜100％，則使用最高匹配度字段進行轉換；

若閾值S2≤字段匹配度＜閾值S1，則不予轉換，直接進行透傳；

若字段匹配度＜閾值S2，則視為無效字段舍棄。

4.根據權利要求3所述的一種基于異步消息的編排營銷方法，其特征在于，若同一字段匹配結果達到設定次數，則視為常規數據，字段轉換匹配結果入庫記錄，同時形成消息事件配置。

5.根據權利要求3所述的一種基于異步消息的編排營銷方法，其特征在于，所述閾值S1為80％，所述閾值S2為60％。

6.根據權利要求4所述的一種基于異步消息的編排營銷方法，其特征在于，所述設定次數為100次。

7.根據權利要求1所述的一種基于異步消息的編排營銷方法，其特征在于，通過單一參數字段處理內容進行匹配，形成處理原子，再由處理原子加以組合，形成處理單元，對于一個個單元予以整合加工，形成規則引擎腳本，并生產規則文件，通過Drools規則引擎加載規則文件進行數據規則驗證匹配過濾。

8.一種基于異步消息的編排營銷系統，其特征在于，包括：

消息處理模塊，用以接收各業務系統異步拋送的原始數據，并對所述原始數據進行數據清洗，然后轉化為標準數據，并對所述標準數據進行報文解析，并對報文的內容進行字段級拆分，處理形成標準報文結構的模型數據；

標準處理模塊，用以對標準報文結構的模型數據進行數據規則驗證匹配過濾；

編排處理模塊，用以對規則驗證通過的標準報文結構的模型數據進行計次、處理；

營銷觸達模塊，用以按照配置要求對客戶予以觸達。

9.根據權利要求8所述的一種基于異步消息的編排營銷系統，其特征在于，所述標準化模塊采用SimHash算法對標準數據的來源及標準模型字段進行匹配；

若字段匹配度為100％，則直接進行標準模型轉換；

若閾值S1≤字段匹配度＜100％，則使用最高匹配度字段進行轉換；

若閾值S2≤字段匹配度＜閾值S1，則不予轉換，直接進行透傳；

若字段匹配度＜閾值S2，則視為無效字段舍棄。

10.根據權利要求8所述的一種基于異步消息的編排營銷系統，其特征在于，所述標準處理模塊通過單一參數字段處理內容進行匹配，形成處理原子，再由處理原子加以組合，形成處理單元，對于一個個單元予以整合加工，形成規則引擎腳本，并生產規則文件，通過Drools規則引擎加載規則文件進行數據規則驗證匹配過濾。