(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202210581972.9 (22)申请日 2022.05.26 (71)申请人 中国平安人寿保险股份有限公司 地址 518000 广东省深圳市福田区福田街 道益田路5033号平安金融中心14、 15、 16、 37、 41、 4 4、 45、 46、 54、 58、 59层 (72)发明人 张莹　 (74)专利代理 机构 广州嘉权专利商标事务所有 限公司 4 4205 专利代理师 廖慧贤 (51)Int.Cl. G06F 9/50(2006.01) G06Q 40/08(2012.01) (54)发明名称 保单处理方法和装置、 设备、 介质 (57)摘要 本申请实施例提供一种保单处理方法和装 置、 设备、 介质， 属于数据库技术领域。 该方法包 括： 通过目标任务实例为多个结算数据库分配任 务实例， 并通过任务实例并发执行对应的结算数 据库中的待结算保单； 对于待结算保单已被执行 完毕的第一结算数据库， 将第一结算数据库对应 的任务实例记 为空闲任务实例， 通过预设的选举 算法找到待结算保单尚未被执行完毕的第二结 算数据库， 并为第二结算数据库分配空闲任务实 例， 并通过空闲任务实例并发执行第二结算数据 库的待结算保单， 直至所有结算数据库的待结算 保单均被执行完毕。 本实施例能够保证任务实例 分配的一致性， 还通过对任务实例的动态分配， 实现了任务实例的多次利用， 提高了结算数据库 的整体结算效率。 权利要求书2页 说明书13页 附图4页 CN 114968577 A 2022.08.30 CN 114968577 A 1.一种保单处 理方法， 其特 征在于， 所述方法包括： 创建任务 集群， 所述任务 集群包括若干任务实例； 通过若干所述任务实例抢占分布式锁， 并将抢占到所述分布式锁的任务实例作为目标 任务实例； 通过所述目标任务实例为多个结算数据库分配所述任务实例， 其中， 每个所述结算数 据库分配到 至少一个所述任务实例； 通过所述任务实例并发执 行对应的结算数据库中的待结算保单； 对于所述待结算保单已被执行完毕的第 一结算数据库， 将所述第 一结算数据库对应的 任务实例记为空闲任务实例， 通过预设的选举算法找到所述待结算保单尚未被执行完 毕的 第二结算数据库， 并为所述第二结算数据库分配所述空闲任务实例， 并通过所述空闲任务 实例并发执行所述第二结算数据库的待结算保单， 直至所有 结算数据库的待 结算保单均被 执行完毕。 2.根据权利要求1所述的方法， 其特 征在于， 所述创建任务 集群， 包括： 获取多个结算数据库的单量， 所述单量 为每个所述结算数据库的待结算保单的数量； 根据所述单量确定任务实例的数量， 并由所述任务实例创建任务 集群。 3.根据权利要求1所述的方法， 其特征在于， 在所述目标任务实例为多个结算数据库分 配所述任务实例之后， 创建 分配完成标识， 所述方法还 包括： 查询所述分配完成标识， 若所述分配完成标识不存在， 获取所述目标任务实例抢占分 布式锁的持续时长； 若所述持续时长大于预设的时长阈值， 则释放所述目标任务实例对应的所述分布式 锁， 以触发未抢占到的分布式锁的任务实例抢占被释放的分布式锁。 4.根据权利要求1所述的方法， 其特征在于， 所述通过所述目标任务实例为多个结算数 据库分配所述任务实例， 包括： 通过注册中心发现所述任务 集群中的若干存活任务实例； 获取多个结算数据库的单量， 所述单量为每个所述结算数据库的待结算保单的数量， 其中， 所述单量用于确定对应的结算数据库的所述存活任务实例的数量， 以使得所述 目标 任务实例根据所述单量 为所述结算数据库分配对应数量的所述存活任务实例。 5.根据权利要求1所述的方法， 其特征在于， 所述通过所述任务实例并发执行对应的结 算数据库中的待结算保单， 包括： 根据所述任务实例的IP地址查询分配的结算数据库， 以及获取所述结算数据库中的待 结算保单； 根据所述结算数据库创建线程池， 根据所述任务实例创建若干执行线程， 并将若干所 述执行线程装 入所述线程池； 将所述待结算保单进行分页处理， 得到多个分页， 每一所述分页包括多条所述待结算 保单； 根据若干所述执 行线程并发执 行多个所述分页上的待结算保单。 6.根据权利要求5任意一项所述的方法， 其特征在于， 所述根据若干所述执行线程并发 执行多个所述分页上的待结算保单， 包括： 获取所述分页， 将所述分页上的所述待结算保单都添加到总表中， 同时设置了每条所权　利　要　求　书 1/2 页 2 CN 114968577 A 2述待结算保单对应的执 行状态字段； 通过每个所述执行线程执行所述待结算保单， 并更新对应的执行状态字段的状态记 录； 当每个所述结算数据库的所有分页 上的待结算保单被执行完毕， 通过所述状态记录判 断漏单并记录漏单； 将所有漏单抓进错单表， 并通过 所述任务实例重新执 行所述错单表上的待结算保单。 7.根据权利要求1至6任意一项所述的方法， 其特征在于， 所述通过预设的选举算法找 到所述待结算保单尚未被执 行完毕的第二结算数据库， 包括： 从多个结算数据库中筛 选出所述待结算保单尚未被执 行完毕的第一结算数据库集 合； 获取所述第 一结算数据库集合的各个结算数据库的当前任务实例数， 根据所述当前任 务实例数和预设的最大执行任务实例数从所述第一结算数据库集合筛选出第二结算数据 库集合； 获取所述第 二结算数据库集合中的各个结算数据库的未处理的待结算保单的数量， 并 根据所述未处 理的待结算保单的数量从所述第二结算数据库集 合筛选出第二结算数据库。 8.一种保单处 理装置， 其特 征在于， 包括： 创建模块， 用于创建任务 集群， 所述任务 集群包括若干任务实例； 抢占模块， 用于通过若干所述任务实例抢占分布式锁， 并将抢占到所述分布式锁的任 务实例作为目标任务实例； 分配模块， 用于通过所述目标任务实例为多个结算数据库分配所述任务实例， 其中， 每 个所述结算数据库分配到 至少一个所述任务实例； 第一执行模块， 用于通过 所述任务实例并发执 行对应的结算数据库中的待结算保单； 第二执行模块， 用于对于所述待结算保单已被执行完毕的第一结算数据库， 将所述第 一结算数据库对应的任务 实例记为空闲任务 实例， 通过预设的选举算法找到所述待结算保 单尚未被执行完毕的第二结算数据库， 并为所述第二结算数据库分配所述空闲任务实例， 并通过所述空闲任务 实例并发执行所述第二结算数据库的待 结算保单， 直至所有 结算数据 库的待结算保单均被执 行完毕。 9.一种计算机设备， 其特征在于， 所述计算机设备包括存储器、 处理器、 存储在所述存 储器上并可在所述处理器上运行的程序以及用于实现所述处理器和所述存储器之间的连 接通信的数据总线， 所述程序被所述处理器执行时实现如权利要求 1至7任一项 所述的方法 的步骤。 10.一种存储介质， 所述存储介质为计算机可读存储介质， 用于计算机可读存储， 其特 征在于， 所述存储介质存储有一个或者多个程序， 所述一个或者多个程序可被一个或者多 个处理器执行， 以实现权利要求1至7中任一项所述的方法的步骤。权　利　要　求　书 2/2 页 3 CN 114968577 A 3