林奕希

（中國聯(lián)合網(wǎng)絡通信有限公司廣東省分公司，廣東 廣州 510320）

1 背景及思路

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

2 實施目標

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

（1）實時通過下沉kafka數(shù)據(jù)，推送到贈送能力平臺觸發(fā)活動；

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

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

3 技術(shù)方案

基于hadoop 大數(shù)據(jù)架構(gòu)的實時營銷能力，支撐總部CBSS系統(tǒng)架構(gòu)如圖1所示。

圖1 支撐總部CBSS系統(tǒng)架構(gòu)

項目實施技術(shù)方案如下：

3.1 總部數(shù)據(jù)下沉

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

實時消息處理流程：

（1）總部將數(shù)據(jù)庫變化的消息轉(zhuǎn)化為OGG 消息存入總部的kafka。

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

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

圖2 實時消息處理流程

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

圖3 文件處理流程

3.2 CBSS總部接口對接

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

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

圖4 產(chǎn)品訂購接口流程

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

贈款接口：省分對能力平臺統(tǒng)一接口訪問省分能力平臺封裝的贈款接口→省分能力平臺再將調(diào)用請求解析并重新封裝轉(zhuǎn)發(fā)給總部能力平臺→總部能力平臺再將調(diào)用請求解析并重新封裝調(diào)用CBSS→CBSS上完成贈款到賬的邏輯，并將結(jié)果逐層返回給省分贈送模塊。

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

三戶查詢接口：省分對能力平臺統(tǒng)一接口訪問省分能力平臺封裝的三戶查詢接口→省分能力平臺再將調(diào)用請求解析并重新封裝轉(zhuǎn)發(fā)給總部能力平臺→總部能力平臺再將調(diào)用請求解析并重新封裝調(diào)用CBSS→CBSS 上完成三戶查詢的邏輯，并將結(jié)果逐層返回給省分贈送模塊。

3.3 CBSS贈送業(yè)務實現(xiàn)

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

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

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

圖5 充值活動觸發(fā)流程

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

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

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

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

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

3.4 外網(wǎng)異業(yè)模塊對接

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

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

內(nèi)部調(diào)用異業(yè)流程：內(nèi)部系統(tǒng)訪問外網(wǎng)的服務需要通過API網(wǎng)關(guān)再到聯(lián)通的防火墻，由防火墻進行IP映射到外網(wǎng)→API網(wǎng)關(guān)同樣需要進行token鑒權(quán)等方式判斷是否能訪問外部應用。如果能訪問則將請求路由到指定的后端應用服務器。

刷單模式業(yè)務流程：訂單系統(tǒng)確認訂單后，調(diào)用能力平臺的物流配送信息接口→能力平臺鑒權(quán)通過后，再調(diào)用API網(wǎng)關(guān)的物流配送信息接口→API網(wǎng)關(guān)鑒權(quán)通過后，再調(diào)用廣杰的物流配送信息接口。

4 方案成果和經(jīng)濟效益

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

圖6 外部接入流程

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

5G 時代來臨以后，聯(lián)通廣東分公司立足于當前的業(yè)務變化，基于hadoop大數(shù)據(jù)架構(gòu)對CBSS系統(tǒng)進行了調(diào)整和優(yōu)化，經(jīng)過技術(shù)升級與改造以后，公司的賬務贈送能力較為完美地融入到了CBSS系統(tǒng)當中，滿足了5G時代公司業(yè)務鞏固及拓展的需要。