数据对账方法、装置、设备及存储介质.pdf

(19)中华人民共和国国家知识产权局(12)发明专利申请(10)申请公布号CN114138802A(43)申请公布日2022.03.04(21)申请号202111436731.7(22)申请日2021.11.29(71)申请人中国平安财产保险股份有限公司地址518000广东省深圳市福田区福田街道益田路5033号平安金融中心12、13、38、39、40、62层(72)发明人冯强(74)专利代理机构深圳市明日今典知识产权代理事务所(普通合伙)44343代理人王杰辉曹勇(51)Int.Cl.G06F16/23(2019.01)G06F16/27(2019.01)G06F16/28(2019.01)权利要求书3页说明书13页附图3页(54)发明名称数据对账方法、装置、设备及存储介质(57)摘要本申请涉及数据处理技术领域，揭示了一种数据对账方法、装置、设备及存储介质，其中方法包括：响应对账开始信号，从对账记录表中抓取处理状态为待处理的每条对账记录作为第一对账记录，将第一对账记录和目标数据源之间进行数据对账对账差异性处理；重复执行确定第一对账记录的步骤，直至获取到对账记录表的遍历完成信号；响应遍历完成信号，从对账记录表中抓取处理状态为失败的每条对账记录作为第二对账记录，将第二对账记录和目标数据源之间进行数据对账对账差异性处理。从而提高了对账的准确性，提高了目标数据源的数据准确性，有利于对丢失的数据准确的进行补充同步。CN114138802ACN114138802A权利要求书1/3页1.一种数据对账方法，其特征在于，所述方法包括：获取对账开始信号；响应所述对账开始信号，从预设的对账记录表中抓取处理状态为待处理的每条对账记录作为第一对账记录，其中，所述对账记录表中的对账记录是根据消息中间件发送的数据更新消息生成的数据；将所述第一对账记录和目标数据源之间分别进行数据对账及对账差异性处理，其中，所述目标数据源中的数据是根据所述消息中间件发送的所述数据更新消息得到的数据；重复执行所述从预设的对账记录表中抓取处理状态为待处理的每条对账记录作为第一对账记录的步骤，直至获取到所述对账记录表的遍历完成信号；响应所述遍历完成信号，从所述对账记录表中抓取所述处理状态为失败的每条所述对账记录作为第二对账记录；将所述第二对账记录和所述目标数据源之间进行数据对账及对账差异性处理。2.根据权利要求1所述的数据对账方法，其特征在于，所述将所述第一对账记录和目标数据源之间分别进行数据对账及对账差异性处理的步骤，包括：判断所述第一对账记录的数据标识是否存在所述目标数据源中；若不存在所述目标数据源中，则根据所述第一对账记录向所述消息中间件发送第一重新同步信号，将所述第一对账记录对应的所述处理状态更新为失败；若存在所述目标数据源中，判断所述目标数据源中的与所述第一对账记录的数据标识对应的最晚更新时间是否大于所述第一对账记录中的更新时间，若大于，则将所述第一对账记录对应的所述处理状态更新为成功，若不大于，根据所述第一对账记录向所述消息中间件发送所述第一重新同步信号，将所述第一对账记录对应的所述处理状态更新为失败。3.根据权利要求1所述的数据对账方法，其特征在于，所述将所述第二对账记录和所述目标数据源之间进行数据对账及对账差异性处理的步骤，包括：判断所述第二对账记录的数据标识是否存在所述目标数据源中；若不存在所述目标数据源中，则根据所述第二对账记录向所述消息中间件发送第二重新同步信号，将所述第二对账记录对应的重试次数加1；若存在所述目标数据源中，判断所述目标数据源中的与所述第二对账记录的数据标识对应的最晚更新时间是否大于所述第二对账记录中的更新时间，若大于，则将所述第二对账记录对应的所述处理状态更新为成功，若不大于，根据所述第二对账记录向所述消息中间件发出所述第二重新同步信号，将所述第二对账记录对应的所述重试次数加1。4.根据权利要求3所述的数据对账方法，其特征在于，所述判断所述第二对账记录数据标识是否存在所述目标数据源中的步骤，包括：判断所述第二对账记录的所述重试次数是否大于预设的重试次数阈值；若大于所述重试次数阈值，则将所述第二对账记录对应的所述处理状态更新为异常记录；若不大于所述重试次数阈值，则判断所述第二对账记录的数据标识是否存在所述目标数据源中。5.根据权利要求1所述的数据对账方法，其特征在于，所述将所述第二对账记录和所述目标数据源之间进行数据对账及对账差异性处理的步骤之后，还包括：2CN114138802A权利要求书2/3页将所述对账记录表中的所述处理状态为异常记录的各个对账记录作为异常对账记录集；将所述异常对账记录集发送给异常处理端；获取所述异常处理端根据所述异常对账记录集发送的异常记录结果；根据所述异常记录结果，对所述对账记录表中的所述处理状态进行更新。6.根据权利