(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202211152127.6 (22)申请日 2022.09.21 (71)申请人 平安国际融资 租赁有限公司 地址 200120 上海市浦东 新区中国 （上海） 自由贸易试验区世纪大道8号上海国 金中心办公楼二期37层 (72)发明人 马超军　 (74)专利代理 机构 北京辰权知识产权代理有限 公司 11619 专利代理师 刘广达 (51)Int.Cl. G06Q 30/02(2012.01) G06Q 30/06(2012.01) G06F 16/27(2019.01) G06F 9/54(2006.01) (54)发明名称 基于高并发分布式的返利数据采集方法及 装置 (57)摘要 本发明涉及数据处理技术领域， 公开了一种 基于高并发分布式的返利数据采集方法及装置， 包括： 拉取报单数据至返利服务组件； 通过分发 器组件将所述返利服务组件中的所述报单数据 多线程分发至PG数据库落库； 在所述报单数据落 库成功之后， 再次通过所述分发器组件将所述返 利服务组件中的所述报单数据多线程分发至计 算引擎组件； 所述计算引擎组件对 所述报单数据 进行分布式计算， 并将计算出的返利结果发送至 所述PG数据库落库。 本申请能够解决在月初计算 订单较多时， 产生计算超时所造成的风险较大的 技术问题。 权利要求书2页 说明书10页 附图4页 CN 115392984 A 2022.11.25 CN 115392984 A 1.一种基于高并发分布式的返利数据采集方法， 其特 征在于， 包括以下步骤： 拉取报单 数据至返利服 务组件； 通过分发器组件将所述返利服 务组件中的所述报单 数据多线程分发至PG数据库落库； 在所述报单数据落库成功之后， 再次通过所述分发器组件将所述返利服务组件中的所 述报单数据多线程分发至计算引擎组件； 所述计算引擎组件对所述报单数据进行分布式计算， 并将计算出的返利结果发送至所 述PG数据库落库。 2.根据权利要求1所述的返利数据采集方法， 其特征在于， 还包括： 所述PG数据库将所 述返利结果发送至前端设备。 3.根据权利要求2所述的返利数据采集方法， 其特征在于， 在所述拉取报单数据至返利 服务组件之前， 还 包括： 通过所述前端设备将所述报单 数据输入核心数据库。 4.根据权利要求3所述的返利数据采集方法， 其特征在于， 所述拉取报单数据至返利服 务组件， 包括： 在所述报单数据符合预设的规则启用条件时， 通过kafka组件从所述核心数据库中拉 取所述报单 数据至所述返利服 务组件。 5.根据权利要求1所述的返利数据采集方法， 其特征在于， 所述通过分发器组件将所述 返利服务组件中的所述报单 数据多线程分发至PG数据库落库， 包括： 通过所述分发器组件将所述返利服 务组件中的所述报单 数据多线程分发至PG数据库； 在所述PG数据库中， 查询所述报单 数据是否命中规则订单； 在所述报单数据命中所述规则订单时， 返回数据至所述返利服务组件， 所述报单数据 落库成功。 6.根据权利要求1所述的返利数据采集方法， 其特征在于， 所述计算引擎组件对所述报 单数据进行分布式计算， 包括： 所述计算引擎组件根据业务类型、 产品类型、 代理商类型和逾期情况对所述报单数据 进行分布式计算。 7.根据权利要求1所述的返利数据采集方法， 其特征在于， 在所述将计算出的返利结果 发送至所述PG数据库落库之后， 还 包括： 在所述PG数据库内， 修改所述报单 数据的状态为已计算状态。 8.一种基于高并发分布式的返利数据采集装置， 其特 征在于， 包括： 数据拉取模块， 用于拉取报单 数据至返利服 务组件； 首次分发模块， 用于通过分发器组件将所述返利服务组件中的所述报单数据多线程分 发至PG数据库落库； 再次分发模块， 用于在所述报单数据落库成功之后， 再次通过所述分发器组件将所述 返利服务组件中的所述报单 数据多线程分发至计算引擎组件； 计算模块， 用于通过所述计算引擎组件对所述报单数据进行分布式计算， 并将计算出 的返利结果发送至所述PG数据库落库。 9.一种计算机设备， 包括存储器、 处理器以及存储在所述存储器中并可在所述处理器 上运行的计算机程序， 其特征在于， 所述处理器执行所述计算机程序时实现如权利要求 1至权　利　要　求　书 1/2 页 2 CN 115392984 A 27任一项所述基于高并发分布式的返利数据采集方法的步骤。 10.一种计算机可读存储介质， 所述计算机可读存储介质存储有计算机程序， 其特征在 于， 所述计算机程序被处理器执行时实现如权利要求 1至7任一项 所述基于高并发分布式的 返利数据采集方法的步骤。权　利　要　求　书 2/2 页 3 CN 115392984 A 3