账务赠送能力在中国联通CBSS系统中的应用实现研究

2021-02-26林奕希

电脑与电信 2021年11期

林奕希

（中国联合网络通信有限公司广东省分公司，广东广州 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万笔。