[發明專利]一種實時計算的忠誠度實現方法

在審

• 申請號: 201810723652.6
• 申請日: 2018-07-04
• 公開（公告）號: CN109214851A
• 公開（公告）日: 2019-01-15
• 發明（設計）人: 王偉;丁浩;韓錚
• 申請（專利權）人: 杭州數云信息技術有限公司
• 主分類號: G06Q30/02
• 分類號: G06Q30/02;G06F9/48
• 代理公司: 杭州天昊專利代理事務所(特殊普通合伙) 33283
• 代理人: 程皓

本發明公開了一種實時計算的忠誠度實現方法。它具體包括如下步驟：服務啟動會自動初始化數據庫結構及默認元數據配置；根據客戶方需求實施初始化卡計劃、積分賬戶、等級體系，并調整會員元數據及指標元數據，并根據客戶數據資源轉換為事件并將事件推送到系統消息隊列中；初始化存量會員信息，或根據用戶操作，調用忠誠度注冊或綁定會員信息；待用戶設置好積分和等級自定義DSL規則，并接入事件后，計算其積分和等級；在發生等級或積分變更后，將及時變更會員信息，并將變更記錄以事件方式推送到消息隊列。本發明的有益效果是：可動態接入各類數據主題，配置靈活的DSL規則，做到實時計算消費者積分及等級的功能。

技術領域

本發明涉及數據處理相關技術領域，尤其是指一種實時計算的忠誠度實現方法。

背景技術

忠誠度，又可稱作客戶粘度。目前隨著市場中人又紅利的減少，市場競爭越來越激烈的情況下，作為一個企業現在越來越迫切的，需要以消費者的數據為核心，利用信息科學技術，實現與消費者在服務及消費方面的互動，在企業與客戶之間建立起一種互相信任和相互依賴的“質量價值鏈”。其中-套建全的消費者忠誠度管理系統，越來越引起企業的重視，其中消費者等級、積分體系的建立也越來越受到企業的青睞。但目前市面上缺少類似可動態接入各類數據主題，配置靈活的DSL規則，做到實時計算消費者積分及等級的功能。

發明內容

本發明是為了克服現有技術中存在上述的不足，提供了一種能夠實時計算消費者積分及等級的實時計算的忠誠度實現方法。

為了實現上述目的，本發明采用以下技術方案：

一種實時計算的忠誠度實現方法，具體包括如下步驟：

(1)系統基于jvm環境部署，依賴于mysql數據庫，kafka消息件及redis緩存服務，服務啟動會自動初始化數據庫結構及默認元數據配置；

(2)系統部署完成后，根據客戶方需求實施初始化卡計劃、積分賬戶、等級體系，并調整會員元數據及指標元數據，并根據客戶數據資源轉換為事件并將事件推送到系統消息隊列中；

(3)系統初始化存量會員信息，或根據用戶操作，調用忠誠度注冊或綁定會員信息；

(4)待用戶設置好積分和等級自定義DSL規則，并接入事件后，便會根據系統已經注冊或綁定的有效會員計算其積分和等級；

(5)在發生等級或積分變更后，將及時變更會員信息，并將變更記錄以事件方式推送到消息隊列，通知外部系統。

這種基于event processing的忠誠度引擎是根據客戶主提供的不同數據主題，實時推送到忠誠度系統，系統根據用戶管理端定義的DSL規則，與事件數據計算消費者積分及等級，并通過消息隊列方式將變更推送出去，其它系統可根據變更記錄向消費者以微信、短信、郵件等渠道通知客戶。系統運行中，根據事件類型不同以不同的隊列進行劃分，相應的隊列都對應專有的任務調度執行組，去消費處理的任務，將不同優先級的任務進行資源隔離，然后通過控制任務調度執行組的可用資源，來達到計算任務優先級的控制目的。通過對任務調度執行組熱啟動，控制服務任務可人為干預其執行和暫停且不影響其它任務處理；通過對任務調度執行組的上限資源限制，限制任務流量；通過設計系統特定異常任務重試的方式，盡可能保證，在網絡波動或未知情況下的容錯處理。在服務因斷電或其它不可預期情況下中止的情況下，在重啟服務后，能恢復正在執行的任務，并處理積壓的事件；系統可以通過scala多個實例的方式，并行消費處理事件，可水平擴展系統處理能力并能保證服務的高可用。本方法可動態接入各類數據主題，配置靈活的DSL規則，做到實時計算消費者積分及等級的功能。

作為優選，在步驟(4)中，接收到事件后，先根據事件發生的時間點，到歷史用戶DSL規則時間軸找到事件發生所在的規則作用區間，然后使用該規則進行后續計算任務。