欢迎来到知嘟嘟! 联系电话:13336804447 卖家免费入驻,海量在线求购! 卖家免费入驻,海量在线求购!
知嘟嘟
我要发布
联系电话:13336804447
知嘟嘟经纪人
收藏
专利号: 2018110102014
申请人: 平安科技(深圳)有限公司
专利类型:发明专利
专利状态:已下证
专利领域: 计算;推算;计数
更新日期:2026-07-21
缴费截止日期: 暂无
价格&联系人
年费信息
委托购买

摘要:

权利要求书:

1.一种基于数据分片的对账方法,其特征在于,所述基于数据分片的对账方法包括中心服务器执行的如下步骤:获取承保系统中的承保变更数据,并获取财务系统中的财务变更数据;

按照预设维度分别对所述承保变更数据和所述财务变更数据进行分片处理,得到N个承保分片数据块和N个财务分片数据块,并建立每个所述承保分片数据块与每个所述财务分片数据块之间的映射关系,其中,N为正整数;

根据所述映射关系,将每个所述承保分片数据块和该承保分片数据块对应的所述财务分片数据块作为一个目标任务信息,得到N个所述目标任务信息;

按照预设的负载均衡分配方式,从节点服务器集合中选取目标节点服务器,并将N个所述目标任务信息分配给所述目标节点服务器,以使所述目标节点服务器执行一致性对账检查,其中,所述节点服务器集合包含预设数量的节点服务器;

接收所述目标节点服务器发送的执行结果,并对所述执行结果进行汇总,得到目标结果;

每条所述承保变更数据和每条所述财务变更数据均包括保单号,所述预设维度为所述保单号,所述按照预设维度分别对所述承保变更数据和所述财务变更数据进行分片处理,得到N个承保分片数据块和N个财务分片数据块,并建立每个所述承保分片数据块与每个所述财务分片数据块之间的映射关系包括:从所述承保变更数据中获取最小的保单号,作为起始保单号,并根据所述起始保单号和预设的分片区间间隔,确定每个分片区间的保单范围;

根据每个所述分片区间的保单范围和每条所述承保变更数据的保单号,确定每条所述承保变更数据所属的分片区间,将属于同一个分片区间的承保变更数据作为一个承保分片数据块,得到N个承保分片数据块;

根据每个所述分片区间的保单范围和每条所述财务变更数据的保单号,确定每条所述财务变更数据所属的分片区间,将属于同一个分片区间的财务变更数据作为一个财务分片数据块,得到N个财务分片数据块;

对具有相同分片区间的承保分片数据块和财务分片数据块之间建立映射关系。

2.如权利要求1所述的基于数据分片的对账方法,其特征在于,所述按照预设的负载均衡分配方式,从节点服务器集合中选取目标节点服务器,并将N个所述目标任务信息分配给所述目标节点服务器包括:采用预设的探测机制对节点服务器集合中的每个节点服务器进行探测,获取节点服务器的状态,并将所述状态为激活的节点服务器确定为目标节点服务器;

针对每个所述目标节点服务器,获取该目标节点服务器的中央处理器型号按照如下公式计算每个所述目标节点服务器对应的状态分值S:

其中,

根据所述状态分值计算每个所述目标节点服务器的任务分配比例;

按照所述任务分配比例,将N个所述目标任务信息发送给所述目标节点服务器。

3.如权利要求1所述的基于数据分片的对账方法,其特征在于,在所述接收所述目标节点服务器发送的执行结果,并对所述执行结果进行汇总,得到目标结果之后,所述基于数据分片的对账方法还包括:若所述目标结果为存在不一致的变更数据,则将所述不一致的变更数据推送给监控端。

4.一种基于数据分片的对账方法,其特征在于,所述基于数据分片的对账方法包括节点服务器执行的如下步骤:若接收到中心服务器发送的目标任务信息,则将所述目标任务信息保存到数据池,其中,所述目标任务信息包括承保分片数据块和所述承保分片数据块对应的财务分片数据块;

采用预设的定时任务脚本,定时对所述数据池中的所述目标任务信息执行一致性对账检查,得到执行结果;

将所述执行结果发送给所述中心服务器;

所述对所述数据池中的所述目标任务信息执行一致性对账检查,得到执行结果包括:对所述承保分片数据块中的每条承保变更数据添加待处理的状态标识;

从所述状态标识为待处理的承保变更数据中,随机选取一条承保变更数据,作为基础数据,并获取所述基础数据的保单号,作为目标保单号;

从所述财务分片数据块中获取与所述目标保单号具有相同保单号的财务变更数据,作为比较数据;

对所述基础数据和所述比较数据进行对比,得到对比结果,并将所述基础数据的所述状态标识更新为已处理;

对所述承保变更数据的状态标识进行遍历,得到遍历结果;

若所述遍历结果为存在状态标识为待处理的所述承保变更数据,则返回执行所述从所述状态标识为待处理的承保变更数据中,随机选取一条承保变更数据,作为基础数据,并获取所述基础数据的保单号,作为目标保单号的步骤;

若所述遍历结果为不存在状态标识为待处理的承保变更数据,则将每个所述对比结果进行汇总,得到所述执行结果。

5.一种基于数据分片的对账装置,其特征在于,所述基于数据分片的对账装置包括中心服务器,所述中心服务器包括:数据获取模块,用于获取承保系统中的承保变更数据,并获取财务系统中的财务变更数据;

数据分片模块,用于按照预设维度分别对所述承保变更数据和所述财务变更数据进行分片处理,得到N个承保分片数据块和N个财务分片数据块,并建立每个所述承保分片数据块与每个所述财务分片数据块之间的映射关系,其中N为正整数;

任务生成模块,用于根据所述映射关系,将每个所述承保分片数据块和该承保分片数据块对应的所述财务分片数据块作为一个目标任务信息,得到N个所述目标任务信息;

任务分片模块,用于按照预设的负载均衡分配方式,从节点服务器集合中选取目标节点服务器,并将N个所述目标任务信息分配给所述目标节点服务器,以使所述目标节点服务器执行一致性对账检查,其中,所述节点服务器集合包含预设数量的节点服务器;

结果接收模块,用于接收所述目标节点服务器发送的执行结果,并对所述执行结果进行汇总,得到目标结果;

每条所述承保变更数据和每条所述财务变更数据均包括保单号,所述预设维度为所述保单号,所述数据分片模块包括:范围确定单元,用于从承保变更数据中获取最小的保单号,作为起始保单号,并根据起始保单号和预设的分片区间间隔,确定每个分片区间的保单范围;

第一分片单元,用于根据每个分片区间的保单范围和每条承保变更数据的保单号,确定每条承保变更数据所属的分片区间,将属于同一个分片区间的承保变更数据作为一个承保分片数据块,得到N个承保分片数据块;

第二分片单元,用于根据每个分片区间的保单范围和每条财务数据的保单号,确定每条财务变更数据所属的分片区间,将属于同一个分片区间的财务变更数据作为一个财务分片数据块,得到N个财务分片数据块;

数据映射单元,用于对具有相同分片区间的承保分片数据块和财务分片数据块之间建立映射关系。

6.一种基于数据分片的对账装置,其特征在于,所述基于数据分片的对账装置包括节点服务器,所述节点服务器包括:数据存储模块,用于若接收到中心服务器发送的目标任务信息,则将所述目标任务信息保存到数据池,其中,所述目标任务信息包括承保分片数据块和所述承保分片数据块对应的财务分片数据块;

对账检查模块,用于采用预设的定时任务脚本,定时对所述数据池中的所述目标任务信息执行一致性对账检查,得到执行结果;

结果发送模块,用于将所述执行结果发送给所述中心服务器;

所述对账检查模块包括:

状态标识单元,用于对承保分片数据块中的每条承保变更数据添加待处理的状态标识;

第一选取单元,用于从状态标识为待处理的承保变更数据中,随机选取一条承保变更数据,作为基础数据,并获取基础数据的保单号,作为目标保单号;

第二选取单元,用于从财务分片数据块中获取与目标保单号具有相同保单号的财务变更数据,作为比较数据;

数据比较单元,用于对基础数据和比较数据进行对比,得到对比结果,并将基础数据的状态标识更新为已处理;

状态遍历单元,用于对承保变更数据的状态标识进行遍历,得到遍历结果;

循环执行单元,用于若遍历结果为存在状态标识为待处理的承保变更数据,则返回执行从状态标识为待处理的承保变更数据中,随机选取一条承保变更数据,作为基础数据,并获取基础数据的保单号,作为目标保单号的步骤;

结果汇总单元,用于若遍历结果为不存在状态标识为待处理的承保变更数据,则将每个对比结果进行汇总,得到执行结果。

7.一种计算机设备,包括存储器、处理器以及存储在所述存储器中并可在所述处理器上运行的计算机程序,其特征在于,所述处理器执行所述计算机程序时实现如权利要求1至3任一项所述的基于数据分片的对账方法的步骤,或者所述处理器执行所述计算机程序时实现如权利要求4所述的基于数据分片的对账方法的步骤。

8.一种计算机可读存储介质,所述计算机可读存储介质存储有计算机程序,其特征在于,所述计算机程序被处理器执行时实现如权利要求1至3任一项所述的基于数据分片的对账方法的步骤,或者,所述计算机程序被处理器执行时实现如权利要求4任一项所述的基于数据分片的对账方法的步骤。