技术摘要：
本发明提供了一种基于集群的分润系统，其包括数据存储模块、分润程序、容器集群和调度模块，所述数据存储模块，用于存储分润规则和分润得到的明细数据；所述分润程序，用于根据所述数据存储模块中的分润规则计算分润金额；所述容器集群，用于为所述分润程序提供运行环  全部
背景技术：
随着手机等电子终端使用的普及和互联网金融的发展，利用互联网的金融收单机 构的大量出现，如微信支付、支付宝支付、二维码支付或是扫码支付(包括条形码、二维码、 声波码)、网上支付及银联刷卡支付、NFC拍卡支付、手机号码支付、光子支付等，给人们的消 费支付代来极大的方便，并被消费者广泛的应用。为适应多种收单机构的收费系统现有技 术中已被大量使用，如超市、铁路客服、机票预售、网上购物的收银系统，这种系统被称为分 润系统。分润系统参与市场运行的各方均需要在产品销售或服务完成后的最短时间内，实 现资金回收，降低运行成本。 然而，传统的分润运算采用单一的程序，基于单一的服务器，只能按部就班的进 行，无法扩容，也无法加速，无法知道今天需要处理多长时间，发生错误时必须从头再来。
技术实现要素：
本发明的目的在于提供了本发明提供了一种基于集群的分润系统，从而使得分润 系统可以进行扩容和加速。 本发明实施例中，提供了一种基于集群的分润系统，其包括数据存储模块、分润程 序、容器集群和调度模块， 所述数据存储模块，用于存储分润规则和分润得到的明细数据； 所述分润程序，用于根据所述数据存储模块中的分润规则计算分润金额； 所述容器集群，用于为所述分润程序提供运行环境； 所述调度模块，用于对所述分润程序进行调度、维护和跟踪。 本发明实施例中，所述数据存储模块包括Hive数据库和Oracle数据库。 本发明实施例中，所述Hive数据库用于存储分润规则和分润明细数据，所述 Oracle数据库用于存储分润金额汇总数据和入账数据。 本发明实施例中，所述分润程序使用java语言开发。 本发明实施例中，所述分润程序的运行过程包括： 首先，查询交易流水，按照流水的机身号，查找需要进行分润的账号； 然后，按照流水的交易类型，交易卡类型查找相关账号的分润规则； 最后，按照交易金额、交易成本及分润规则进行分润计算。 本发明实施例中，所述的基于集群的分润系统,还包括： 交易校验模块，用于将当日的交易数据与前一日的交易数据进行比较，根据两日 交易数据的差异来判断当日的交易是否正常。 本发明实施例中，所述的基于集群的分润系统,还包括： 分润校验模块，用于将当日的分润数据与前一日的分润数据进行比较，根据两日 3 CN 111598699 A 说　明　书 2/4 页 分润数据的差异来判断当日所述分润程序是否运行正常。 本发明实施例中，所述的基于集群的分润系统,还包括： 通知报警模块，用于在所述分润程序运行发生错误时通过邮件或短信的方式通知 管理员。 本发明实施例中，所述通知报警模块还用于在当交易金额或分润金额超出阀值时 以邮件或短信的方式通知管理员。 本发明实施例中，所述调度模块采用由Linkedin公司推出的批量工作流任务调度 器Azkaban。 与现有技术相比较，本发明的基于集群的分润系统中，采用了容器集群来运行所 述分润程序，解决了系统无法扩容的问题，可以使所述分润程序稳定、快速的运行；还可通 过所述调度模块对分润程序的运行过程进行可视化跟踪，使管理员便于查看历史记录及当 前任务情况；另外，系统发生错误时可通过邮件或短信的方式通知管理员，以便于管理及时 查看及修复；当交易金额或分润金额超出阀值时暂停任务以邮件或短信的方式通知管理员 确认，管理员可继续或中止任务，为无人值守创造了便利。 附图说明 图1是本发明实施例的基于集群的分润系统的结构示意图。 图2是本发明实施例的基于集群的分润系统的运行流程示意图。