林奕希

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

1 背景及思路

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

2 實(shí)施目標(biāo)

通過引入賬務(wù)贈(zèng)送能力方案，實(shí)現(xiàn)如下目標(biāo)：

（1）實(shí)時(shí)通過下沉kafka數(shù)據(jù)，推送到贈(zèng)送能力平臺(tái)觸發(fā)活動(dòng)；

（2）實(shí)時(shí)查詢用戶三戶資料、實(shí)時(shí)繳費(fèi)記錄進(jìn)行業(yè)務(wù)處理；

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

3 技術(shù)方案

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

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

項(xiàng)目實(shí)施技術(shù)方案如下：

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

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

實(shí)時(shí)消息處理流程：

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

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

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

圖2 實(shí)時(shí)消息處理流程

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

圖3 文件處理流程

3.2 CBSS總部接口對(duì)接

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

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

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

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

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

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

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

3.3 CBSS贈(zèng)送業(yè)務(wù)實(shí)現(xiàn)

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

圖6 外部接入流程

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

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