1.一种基于数据分片的对账方法,其特征在于,所述基于数据分片的对账方法包括中心服务器执行的如下步骤:获取承保系统中的承保变更数据,并获取财务系统中的财务变更数据;
按照预设维度分别对所述承保变更数据和所述财务变更数据进行分片处理,得到N个承保分片数据块和N个财务分片数据块,并建立每个所述承保分片数据块与每个所述财务分片数据块之间的映射关系,其中,N为正整数;
根据所述映射关系,将每个所述承保分片数据块和该承保分片数据块对应的所述财务分片数据块作为一个目标任务信息,得到N个所述目标任务信息;
按照预设的负载均衡分配方式,从节点服务器集合中选取目标节点服务器,并将N个所述目标任务信息分配给所述目标节点服务器,以使所述目标节点服务器执行一致性对账检查,其中,所述节点服务器集合包含预设数量的节点服务器;
接收所述目标节点服务器发送的执行结果,并对所述执行结果进行汇总,得到目标结果。
2.如权利要求1所述的基于数据分片的对账方法,其特征在于,每条所述承保变更数据和每条所述财务变更数据均包括保单号,预设维度为所述保单号,所述按照预设维度对所述承保变更数据和所述财务变更数据进行分片,得到N个承保分片数据块和N个财务分片数据块,并建立每个所述承保分片数据块与所述财务分片数据块的映射关系包括:从所述承保变更数据中获取最小的保单号,作为起始保单号,并根据所述起始保单号和预设的分片区间间隔,确定每个分片区间的保单范围;
根据每个所述分片区间的保单范围和每条所述承保变更数据的保单号,确定每条所述承保变更数据所属的分片区间,将属于同一个分片区间的承保变更数据作为一个承保分片数据块,得到N个承保分片数据块;
根据每个所述分片区间的保单范围和每条所述财务变更数据的保单号,确定每条所述财务变更数据所属的分片区间,将属于同一个分片区间的财务变更数据作为一个财务分片数据块,得到N个财务分片数据块;
对具有相同分片区间的承保分片数据块和财务分片数据块之间建立映射关系。
3.如权利要求1所述的基于数据分片的对账方法,其特征在于,所述按照预设的负载均衡分配方式,从节点服务器集合中选取目标节点服务器,并将N个所述目标任务信息分配给所述目标节点服务器包括:采用预设的探测机制对节点服务器集合中的每个节点服务器进行探测,获取节点服务器的状态,并将所述状态为激活的节点服务器确定为目标节点服务器;
针对每个所述目标节点服务器,获取该目标节点服务器的中央处理器型号Q1、磁盘空间参数Q2和内存型号Q3;
按照如下公式计算每个所述目标节点服务器对应的状态分值S:
S=J1+Q2×J2+J3
其中,J1为所述中央处理器型号Q1对应的预设权值,J2为所述磁盘空间参数Q2对应的预设权值,J3为所述内存型号Q3对应的预设权值;
根据所述状态分值计算每个所述目标节点服务器的任务分配比例;
按照所述任务分配比例,将N个所述目标任务信息发送给所述目标节点服务器。
4.如权利要求1所述的基于数据分片的对账方法,其特征在于,在所述接收所述目标节点服务器发送的执行结果,并对所述执行结果进行汇总,得到目标结果之后,所述基于数据分片的对账方法还包括:若所述目标结果为存在不一致的变更数据,则将所述不一致的变更数据推送给监控端。
5.一种基于数据分片的对账方法,其特征在于,所述基于数据分片的对账方法包括节点服务器执行的如下步骤:若接收到中心服务器发送的目标任务信息,则将所述目标任务信息保存到数据池,其中,所述目标任务信息包括承保分片数据块和所述承保分片数据块对应的财务分片数据块;
采用预设的定时任务脚本,定时对所述数据池中的所述目标任务信息执行一致性对账检查,得到执行结果;
将所述执行结果发送给所述中心服务器。
6.如权利要求5所述的基于数据分片的对账方法,其特征在于,所述对所述数据池中的所述目标任务信息执行一致性对账检查,得到执行结果包括:对所述承保分片数据块中的每条承保变更数据添加待处理的状态标识;
从所述状态标识为待处理的承保变更数据中,随机选取一条承保变更数据,作为基础数据,并获取所述基础数据的保单号,作为目标保单号;
从所述财务分片数据块中获取与所述目标保单号具有相同保单号的财务变更数据,作为比较数据;
对所述基础数据和所述比较数据进行对比,得到对比结果,并将所述基础数据的所述状态标识更新为已处理;
对所述承保变更数据的状态标识进行遍历,得到遍历结果;
若所述遍历结果为存在状态标识为待处理的所述承保变更数据,则返回执行所述从所述状态标识为待处理的承保变更数据中,随机选取一条承保变更数据,作为基础数据,并获取所述基础数据的保单号,作为目标保单号的步骤;
若所述遍历结果为不存在状态标识为待处理的承保变更数据,则将每个所述对比结果进行汇总,得到所述执行结果。
7.一种基于数据分片的对账装置,其特征在于,所述基于数据分片的对账装置包括中心服务器,所述中心服务器包括:数据获取模块,用于获取承保系统中的承保变更数据,并获取财务系统中的财务变更数据;
数据分片模块,用于按照预设维度分别对所述承保变更数据和所述财务变更数据进行分片处理,得到N个承保分片数据块和N个财务分片数据块,并建立每个所述承保分片数据块与每个所述财务分片数据块之间的映射关系,其中N为正整数;
任务生成模块,用于根据所述映射关系,将每个所述承保分片数据块和该承保分片数据块对应的所述财务分片数据块作为一个目标任务信息,得到N个所述目标任务信息;
任务分片模块,用于按照预设的负载均衡分配方式,从节点服务器集合中选取目标节点服务器,并将N个所述目标任务信息分配给所述目标节点服务器,以使所述目标节点服务器执行一致性对账检查,其中,所述节点服务器集合包含预设数量的节点服务器;
结果接收模块,用于接收所述目标节点服务器发送的执行结果,并对所述执行结果进行汇总,得到目标结果。
8.一种基于数据分片的对账装置,其特征在于,所述基于数据分片的对账装置包括节点服务器,所述节点服务器包括:数据存储模块,用于若接收到中心服务器发送的目标任务信息,则将所述目标任务信息保存到数据池,其中,所述目标任务信息包括承保分片数据块和所述承保分片数据块对应的财务分片数据块;
对账检查模块,用于采用预设的定时任务脚本,定时对所述数据池中的所述目标任务信息执行一致性对账检查,得到执行结果;
结果发送模块,用于将所述执行结果发送给所述中心服务器。
9.一种计算机设备,包括存储器、处理器以及存储在所述存储器中并可在所述处理器上运行的计算机程序,其特征在于,所述处理器执行所述计算机程序时实现如权利要求1至
4任一项所述的基于数据分片的对账方法的步骤,或者所述处理器执行所述计算机程序时实现如权利要求5或6所述的基于数据分片的对账方法的步骤。
10.一种计算机可读存储介质,所述计算机可读存储介质存储有计算机程序,其特征在于,所述计算机程序被处理器执行时实现如权利要求1至4任一项所述的基于数据分片的对账方法的步骤,或者,所述计算机程序被处理器执行时实现如权利要求5或6任一项所述的基于数据分片的对账方法的步骤。