賬務贈送能力在中國聯通CBSS系統中的應用實現研究

林奕希

（中國聯合網絡通信有限公司廣東省分公司，廣東 廣州 510320）

1 背景及思路

5G時代的來臨，讓通信企業之間的競爭愈發激烈，尤其是在攜號轉網政策實行以后，是否能夠留住老用戶，已經成為每一個通信企業在經營發展過程中需要解決的一個重要問題。為了留住老用戶，各個通信企業一般通過贈送業務的方式，給用戶帶來更多的優惠和便利，賬務贈送能力的增強，對通信企業的信息化管理提出了更高的標準和要求[1]。其中，聯通廣東分公司賬務任務能力管理也存在歷史的問題，在賬務贈送能力不斷增強的情況，如何在CBSS 系統當中應用并實現，解決管理實踐當中的這一重要問題，是該公司在經營發展過程中，尤其是在系統優化當中的一個重要任務[2]。在這種情況下廣東贈送平臺開發各種CB賬務、營業接口，利用各種源數據，快捷、迭代實現校園、市場、存量、政企等業務口的需求，確保業務快速上線，保障前端市場部業務的支撐到位，做到觸點運營效力達到省內領先的水平。同時，為了將賬務存儲能力完美融入到CBSS系統當中，公司基于hadoop大數據架構，對現有的CBSS系統當中的賬務贈送業務流程進行了進一步的調整和優化，提出了具體的改革方案和思路[3]。

2 實施目標

通過引入賬務贈送能力方案，實現如下目標：

（1）實時通過下沉kafka數據，推送到贈送能力平臺觸發活動；

（2）實時查詢用戶三戶資料、實時繳費記錄進行業務處理；

（3）由贈送能力平臺將消息推送給AOP系統，再由AOP推送到CBSS入賬。

3 技術方案

基于hadoop 大數據架構的實時營銷能力，支撐總部CBSS系統架構如圖1所示。

圖1 支撐總部CBSS系統架構

項目實施技術方案如下：

3.1 總部數據下沉

核心思想：將總部的kafka數據，用來做數據的下沉和實時業務的觸發來源。將每月全量文件和每天增量文件作為稽核手段來保證數據的準確性和觸發消息的查漏補缺。下沉的主要表包含客戶表，賬戶表，用戶表，產品訂購表，付費關系表，資費訂購表，sp 產品訂購表，服務表，用戶余額信息表，充值記錄表等。

實時消息處理流程：

（1）總部將數據庫變化的消息轉化為OGG 消息存入總部的kafka。

（2）省分程序讀取總部的kafka 實時OGG 消息，將非省分的數據進行過濾，并過濾出省分需要的表的數據，再將OGG消息轉換為JSON格式的數據緩存到省分的kafka中。

（3）省分應用程序讀取省分的kafka，并且將消息中的表進行入庫到省分本地的數據庫，并且觸發出需要處理業務的消息。

圖2 實時消息處理流程

文件處理流程：總部每月將主要表的全量文件提供給省分→省分應用根據總部提供的全量文件和省分數據庫進行全量比對→比對出差異，以總部數據為準，修正省分數據庫中的數據→根據特定表的變化，觸發出對應的業務消息→特定的業務表每天增量導出變化的數據文件和省分數據庫進行全量比對→根據特定表的變化，觸發出對應的業務消息。

圖3 文件處理流程

3.2 CBSS總部接口對接

核心思想：通過省分能力平臺、總部能力平臺、全業務平臺等實現和總部打通贈送業務的關鍵接口，如產品包訂購/退訂、贈款等接口來實現給CBSS 上省分的用戶進行資源和贈款的贈送和退訂。通過三戶查詢接口來完善和補充本地三戶資料的缺失。通過充值查詢接口來校驗充值記錄等[4]。

產品訂購接口：省分對能力平臺統一接口訪問省分能力平臺封裝的產品訂購接口→省分能力平臺再將調用請求解析并重新封裝轉發給總部能力平臺→總部能力平臺再將調用請求解析并重新封裝調用CBSS→CBSS上完成產品訂購的邏輯，并將結果逐層返回給省分贈送模塊→如果返回成功，則記錄結果。如果返回失敗，省分通過定時或者失敗重發機制再次發送給CBSS。

圖4 產品訂購接口流程

產品退訂接口：省分對能力平臺統一接口訪問省分能力平臺封裝的產品退訂接口→省分能力平臺再將調用請求解析并重新封裝轉發給總部能力平臺→總部能力平臺再將調用請求解析并重新封裝調用CBSS→CBSS 上完成產品退訂的邏輯，并將結果逐層返回給省分贈送模塊→如果返回成功，則記錄結果。如果返回失敗，省分通過定時或者失敗重發機制再次發送給CBSS。

贈款接口：省分對能力平臺統一接口訪問省分能力平臺封裝的贈款接口→省分能力平臺再將調用請求解析并重新封裝轉發給總部能力平臺→總部能力平臺再將調用請求解析并重新封裝調用CBSS→CBSS上完成贈款到賬的邏輯，并將結果逐層返回給省分贈送模塊。

充值記錄查詢接口：省分對能力平臺統一接口訪問省分能力平臺封裝的充值記錄查詢接口→省分能力平臺再將調用請求解析并重新封裝轉發給總部能力平臺→總部能力平臺再將調用請求解析并重新封裝調用CBSS→CBSS 上查詢用戶的充值記錄，并將結果逐層返回給省分贈送模塊→如果返回成功，則記錄結果。如果返回失敗，省分通過定時或者失敗重發機制再次發送給CBSS。

三戶查詢接口：省分對能力平臺統一接口訪問省分能力平臺封裝的三戶查詢接口→省分能力平臺再將調用請求解析并重新封裝轉發給總部能力平臺→總部能力平臺再將調用請求解析并重新封裝調用CBSS→CBSS 上完成三戶查詢的邏輯，并將結果逐層返回給省分贈送模塊。

3.3 CBSS贈送業務實現

核心思想：在省分原有贈送系統的基礎上完善對總部CBSS用戶的贈送業務。實現原有的激活贈送、充值贈送、訂購贈送、定向贈送、消費累積贈送等。

激活活動觸發流程：Kafka 下沉用戶新開戶。觸發一條贈送激活消息到贈送系統→贈送系統通過活動條件、活動關系等一系列條件判斷，觸發對應的活動→活動觸發后，通過統一對外接口（CBSS_BF）將活動對應的贈款或者資源在CBSS上進行產品訂購或者贈款贈送。

充值活動觸發流程：Kafka 下沉CBSS 用戶的充值記錄。觸發一條贈送充值消息到贈送系統→贈送系統通過活動條件、活動關系等一系列條件判斷，觸發對應的活動→活動觸發后，通過統一對外接口（CBSS_BF）將活動對應的贈款或者資源在CBSS上進行產品訂購或者贈款贈送。

圖5 充值活動觸發流程

訂購活動觸發流程：Kafka下沉CBSS用戶的訂購變化記錄，判斷為新訂購，則觸發一條贈送充值消息到贈送系統→贈送系統通過活動條件、活動關系等一系列條件判斷，觸發對應的活動→活動觸發后，通過統一對外接口（CBSS_BF）將活動對應的贈款或者資源在CBSS上進行產品訂購或者贈款贈送。

定向活動觸發流程：通過OAM 前臺批量導入指定的用戶，批量觸發定向用戶贈送消息到贈送系統→贈送系統通過活動條件、活動關系等一系列條件判斷，觸發對應的活動→活動觸發后，通過統一對外接口（CBSS_BF）將活動對應的贈款或者資源在CBSS上進行產品訂購或者贈款贈送。

定時贈送活動觸發流程：到達定時活動任務配置的時間，由定時掃描程序掃描用戶記錄，批量寫入定時贈送消息到贈送系統→贈送系統通過活動條件、活動關系等一系列條件判斷，觸發對應的活動→活動觸發后，通過統一對外接口（CBSS_BF）將活動對應的贈款或者資源在CBSS上進行產品訂購或者贈款贈送。

大數據定時贈送活動觸發流程：到達大數據定時活動任務配置的時間，由定時掃描程序掃描用戶記錄，批量寫入定時贈送消息到贈送系統→贈送系統通過活動條件、活動關系等一系列條件判斷，觸發對應的活動→活動觸發后，通過統一對外接口（CBSS_BF）將活動對應的贈款或者資源在CBSS上進行產品訂購或者贈款贈送。

消費累積贈送活動觸發流程：到達大數據定時活動任務配置的時間，由定時掃描程序掃描用戶記錄，批量寫入消費累積贈送消息到贈送系統→贈送系統通過活動條件、活動關系等一系列條件判斷，觸發對應的活動→活動觸發后，通過統一對外接口（CBSS_BF）將活動對應的贈款或者資源在CBSS上進行產品訂購或者贈款贈送。

3.4 外網異業模塊對接

核心思想：通過打通外網接口和異業進行合作，豐富贈送平臺的功能，以及和外部能力互通。

外部接入流程：外部系統訪問聯通內部服務通過公網IP，到聯通的防火墻映射到內網IP 的承載主體array 硬件負載均衡器→Array將訪問請求負載到API網關上面，API網關進行token鑒權等方式判斷是否能訪問后端應用。如果能訪問則將請求路由到指定的后端應用服務器，并給后端做負載均衡。

內部調用異業流程：內部系統訪問外網的服務需要通過API網關再到聯通的防火墻，由防火墻進行IP映射到外網→API網關同樣需要進行token鑒權等方式判斷是否能訪問外部應用。如果能訪問則將請求路由到指定的后端應用服務器。

刷單模式業務流程：訂單系統確認訂單后，調用能力平臺的物流配送信息接口→能力平臺鑒權通過后，再調用API網關的物流配送信息接口→API網關鑒權通過后，再調用廣杰的物流配送信息接口。

4 方案成果和經濟效益

為了維系老用戶，保證用戶的在網率，業務部門不斷推出多種創新業務[5]。但由于CBSS 業務開發周期長，業務部門要求業務上線周期短，廣東贈送平臺開發各種CB賬務、營業接口，利用各種源數據，快捷、迭代實現校園、市場、存量、政企等業務口的需求，確保業務快速上線，保障前端市場部業務的支撐到位，做到觸點運營效力達到省內領先的水平。支撐的觸點能力有：激活觸點、訂購觸點、充值觸點、累計消費觸點、定時任務觸點、定向觸點、組合贈送、個性化贈送等觸點能力。支撐的業務有：花一得三業務、移網用戶捆綁寬固業務折上折、2G用戶升網業務、2G、3G、4G轉5G攜帶原折扣、預存合約送會員權益、“沃廳/沃云購辦理泛終端”業務、加速包業務、上網卡半年包（資源購買）、網齡計劃業務等。CB用戶各類活動累計總觸發量約2030萬筆。

圖6 外部接入流程

5G項目作為公司重點專項，在2020年營銷攻堅戰中，達到了需求上線零延誤、系統運行零故障的成效，為公司開門紅戰役的勝利提供了堅強有力的后盾。5G套餐累計遷轉超過30萬戶。

5G 時代來臨以后，聯通廣東分公司立足于當前的業務變化，基于hadoop大數據架構對CBSS系統進行了調整和優化，經過技術升級與改造以后，公司的賬務贈送能力較為完美地融入到了CBSS系統當中，滿足了5G時代公司業務鞏固及拓展的需要。