(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202211123490.5 (22)申请日 2022.09.15 (71)申请人 中国人民财产保险股份有限公司 地址 100022 北京市朝阳区建国门外大街2 号院2号楼 (72)发明人 潘曦　赵刚　陈想　马培科　 陈文利　潘蕊　 (74)专利代理 机构 北京国昊天诚知识产权代理 有限公司 1 1315 专利代理师 李潇 (51)Int.Cl. G06F 16/23(2019.01) G06F 16/27(2019.01) (54)发明名称 一种数据一 致性方法及业 务系统 (57)摘要 本申请公开了一种数据一致性方法及业务 系统， 业务系统包括第一业务系统和第二业务系 统。 第一业务系统在向第二业务系统发送数据失 败后， 基于数据发送失败的情况对 数据进行相应 处理后重新尝试发送至第二业务系统， 且可进行 多次重复尝试， 目的是通过多次重复尝试将数据 成功发送至第二业务系统， 从而实现第一业务系 统和第二 业务系统的数据一 致性。 权利要求书2页 说明书10页 附图2页 CN 115544034 A 2022.12.30 CN 115544034 A 1.一种数据一 致性方法， 其特 征在于， 应用于第一 业务系统， 包括： 对每个业务进行处理， 得到每个所述业务的业务数据， 并基于预设的业务概要中每个 字段的含义， 得到每个已处理完成的所述业务的业务概要数据； 其中， 所述字段包括业务信 息字段、 错误信息字段、 发送失败次数字段、 发送标志字段； 定期扫描每个已处理完成的所述业务的业务概要数据， 基于目标业务的目标业务概要 数据中的目标发送标志， 确认所述目标业务对应的发送状态； 其中， 所述目标业务为任一已 处理完成的所述 业务； 若所述发送状态为未处理状态， 且所述目标业务的目标业务数据为本周期待发送数 据， 则将所述目标业务数据发送至第二业务系统； 若 所述发送状态为 发送失败状态、 所述目 标业务概要数据中的目标发送失败次数小于预设次数， 且所述目标业务数据为本周期待发 送数据， 则基于所述目标业务概要数据中的目标错误信息对所述目标业务数据进 行相应处 理后发送至所述第二 业务系统； 在向所述第 二业务系统发送所述目标业务数据后， 若在预设时间内未接收到所述第 二 业务系统针对所述目标业务数据返回的接收成功消息， 则基于所述目标业务数据的发送失 败情况更新所述目标错误信息， 将所述目标发送失败次数加1， 将所述目标发送标志的标志 值更新为表征所述发送失败状态的标志值， 并等待下一周期的扫描操作， 以使所述 目标业 务数据成功发送至所述第二 业务系统。 2.如权利要求1所述的数据一致性方法， 其特征在于， 所述第 一业务系统包括包含多个 并发线程的线程池； 多个所述并发线程用于向所述第二业务系统并行发送本周期待发送的 多个所述 业务的业务数据； 所述目标业 务的目标业 务数据是否为本周期待发送数据的判定过程， 包括： 从本周期扫描的第一业务和第 二业务中选择出M个第 三业务； 其中； 所述第 一业务对应 的发送状态为所述未处理状态； 所述第二业务对应的发送状态为所述发送失败状态， 且所 述第二业务的业务概要 数据中的发送失败次数小于所述预设次数； M≤N ×所述线程池中并 发线程的总数量； N表示每 个所述并发线程在每 个周期最多发送N个所述 业务的业务数据； 判断所述目标业 务是否属于 本周期所选择 出的所述第三 业务； 若是， 则判定所述目标业 务的目标业 务数据是本周期待发送数据； 若否， 则判定所述目标业 务的目标业 务数据不是本周期待发送数据。 3.如权利要求2所述的数据一致性方法， 其特征在于， 所述字段还包括占号值字段； 所 述数据一 致性方法还 包括： 在所述目标业务分配至某一所述并发线程 时， 基于预设占号值生成规则为所述目标业 务生成新占号值， 并基于生成的所述新占号值更新所述目标业务概要数据中的目标占号 值； 其中， 对应所述 新占号值的所述目标业 务不能再被分配至其它所述并发线程； 若在所述预设时间内未接收到所述第二业务系统针对所述目标业务数据返回的接收 成功消息， 则将所述目标占号 值恢复至初始占号 值。 4.如权利要求1所述的数据一致性方法， 其特征在于， 所述基于所述目标业务数据的发 送失败情况 更新所述目标错 误信息， 包括： 若在所述预设时间内未接收到所述第 二业务系统针对所述目标业务数据返回的消息， 则将所述目标错误信息更新为表征系统超时的错误信息； 若在所述预设时间内接收到所述权　利　要　求　书 1/2 页 2 CN 115544034 A 2第二业务系统针对所述目标业务数据返回的校验失败消息， 则将所述目标错误信息更新为 表征所述第二 业务系统对所述目标业 务数据校验不 通过的错 误信息； 所述基于所述目标业务概要数据中的目标错误信息对所述目标业务数据进行相应处 理后发送至所述第二 业务系统， 包括： 若所述目标错误信 息为表征系统超时的错误信 息， 则将所述目标业务数据重新组织成 第一报文， 并将所述第一报文发送至所述第二 业务系统； 若所述目标错误信息为表征所述第二业务系统对所述目标业务数据校验不通过的错 误信息， 则修改所述目标业务数据， 并将修改后的所述目标业务数据组织成第二报文， 以将 所述第二报文发送至所述第二 业务系统。 5.如权利要求1所述的数据一 致性方法， 其特 征在于， 所述数据一 致性方法还 包括： 将每个所述业务的业务数据存入数据库的业务表中， 以从所述业务表中获取每个所述 业务的业务数据； 将每个已处理完成的所述业务的业务概要数据存入所述数据库的接口表中， 以从所述 接口表中定期扫描每 个已处理完成的所述 业务的业务概要数据。 6.如权利要求1所述的数据一 致性方法， 其特 征在于， 所述数据一 致性方法还 包括： 在向所述第 二业务系统发送所述目标业务数据后， 若在所述预设时间内接收到所述第 二业务系统针对所述目标业务数据返回的接收成功消息， 则将所述目标发送 标志的标志 值 更新为表征所述目标业 务数据成功发送至所述第二 业务系统的标志值。 7.如权利要求1所述的数据一致性方法， 其特征在于， 所述第 一业务系统上设有消息回 查接口， 所述第二 业务系统通过调用所述消息回查接口查询所述第一 业务系统上的数据。 8.如权利要求1所述的数据一致性方法， 其特征在于， 所述第 二业务系统具备接口幂等 性； 所述数据一 致性方法还 包括： 若接收到所述第二业务系统针对所述目标业务数据返回的重复接收消息， 则将所述目 标错误信息更新为表征所述第二业务系统重复接收所述目标业务数据的错误信息， 并停止 向所述第二 业务系统发送所述目标业 务数据。 9.如权利要求1 ‑8任一项所述的数据一致性方法， 其特征在于， 所述数据一致性方法还 包括： 向第三方系统发送待对账数据， 以使所述第 三方系统将所述第 一业务系统发送的待对 账数据与所述第二 业务系统发送的待对账 数据进行 数据比对； 若接收到所述第三方系统返回的表征所述第 二业务系统数据缺失的消息， 则向所述第 二业务系统补 传其缺失的数据； 若接收到所述第三方系统返回的表征所述第一业务系统与所述第二业务系统的数据 不一致的消息， 则向所述第二 业务系统重传比对结果 不一致的数据。 10.一种业务系统， 其特征在于， 包括第 一业务系统和第 二业务系统； 其中， 所述第 一业 务系统在执行自身存储的计算机程序时实现如权利要求 1‑9任一项所述的数据一致性方法 的步骤。权　利　要　求　书 2/2 页 3 CN 115544034 A 3