(19)国家知识产权局 (12)发明 专利 (10)授权公告 号 (45)授权公告日 (21)申请 号 202210477601.6 (22)申请日 2022.04.28 (65)同一申请的已公布的文献号 申请公布号 CN 114579555 A (43)申请公布日 2022.06.03 (73)专利权人 梅州客商银行股份有限公司 地址 514799 广东省梅州市梅县区华侨 城 客商银行 大厦一、 二层 (72)发明人 陈帆　陈景荣　何良玉　林锋　 罗烨敏　曾乔乔　詹军　张嘉辉　 (74)专利代理 机构 北京动力号知识产权代理有 限公司 1 1775 专利代理师 董钢 (51)Int.Cl. G06F 16/215(2019.01)G06F 16/2455(2019.01) G06F 9/455(2006.01) G06Q 40/02(2012.01) (56)对比文件 CN 114240611 A,2022.03.25 CN 110070440 A,2019.07.3 0 CN 110276614 A,2019.09.24 CN 114298835 A,2022.04.08 审查员 邓丽婉 (54)发明名称 一种基于7 ×24小时的实时数据校准方法及 系统 (57)摘要 本发明公开一种基于7 ×24小时的实时数据 校准方法， 包括： 基于核心业务系统T ‑1日总账批 量确定实时数据校准的时间段； 基于时间段确定 日终批量空隙， 日终批量空隙为时间段的间隔； 在大数据平台上部署7 ×24小时校准程序以及实 时预警平台， 并且在日终批量空隙内进行数据校 准的两次基准更新获得两个基准值， 两个基准值 分别是时间段的起点的 “T‑1日流数据余额 ”和时 间段的结束时间的 “T‑1日总账余额 ”； 异步比对 两个基准值， 计算出两个基准值的差值， 并根据 差值由大数据平台进行进一步的处理获得实时 数据校准结果。 还公开了对应的系统、 电子设备， 用于银行提高流数据的自动化校准能力， 降低运 营成本。 权利要求书3页 说明书7页 附图3页 CN 114579555 B 2022.07.15 CN 114579555 B 1.一种基于7 ×24小时的实时数据 校准方法， 在实时数据 校准系统内实现， 所述实时数 据校准系统包括大 数据平台， 其特 征在于， 实时数据校准方法包括： S1， 基于核心业务系统T ‑1日总账批量确定所述实时数据 校准的时间段， 所述时间段的 起点为每天0:0 0， 所述时间段的结束时间为核心业 务系统T‑1日总账批量结束时间； S2， 基于所述时间段确定日终批量空隙， 所述日终批量空隙为时间段的间隔； S3， 在所述大数据平台上部署7 ×24小时校准程序以及实时预警平台， 并且在所述日终 批量空隙内进 行所述数据校准的两次基准更新获得两个基准值， 所述两个基准值分别是所 述时间段的起 点的“T‑1日流数据余 额”和所述时间段的结束时间的 “T‑1日总账余 额”； S4， 异步比对两个基准值， 计算出两个基准值的差值， 并根据所述差值由所述大数据平 台进行进一 步的处理获得实时数据校准结果； 所述S3包括： S31， 所述7 ×24小时校准程序的运行时间根据所述实时数据校准的时间段确定； 所述 实时预警平台为大数据平 台独立的预警模块， 通过接收HTTPS协议的JSON报文接口展示预 警信息并发送短信， 所述实时预警平台的前端设置页面， 支持差错处理以回传大数据平台 指令重跑调度任务； S32， 0:00自然日切换后， 启动所述7 ×24小时校准程序， 取 “T‑1日流数据余额 ”作为新 的T日基准， 并实时合并计算T日新增存贷款 业务流水数据； S33， 校准程序实时监控核心业务系统T ‑1日总账批量完成状态， 0:40获得 “T‑1日总账 余额”， 替换为新的T日基准后， 实时合并计算T日新增存贷款 业务流水数据； 所述S32包括： S321， 校准程序0:00准时启动， 大数据平台回流实时计算 “T‑1日流数据 余额”， 插入“实 时校准表 ”， 作为第一次基准 值； S322， 实时计算平台从所述 “实时校准表 ”中获取交易时间最大的一笔 “预计时点余额 ” 作为新的T日基准， 合并T日新增存贷款 业务流数据， 将结果展示在数据应用平台。 2.根据权利要求1所述的一种基于7 ×24小时的实时数据校准方法， 其特征在于， 所述 S33包括： S331， 基于所述大数据平台的调度监控机制， 通过大数据平台的调度系 统配置循环执 行的数据库扫描脚本， 所述数据库扫描脚本每隔30 s查询一次核心系统的日终翻牌表， 等待 所述日终翻牌表生成一条新的数据， 所述新的数据包括字段， 分别为数据日期和状态， 当所 述数据日期为T日且所述状态为已完成， 即可认为核心系统完成日终批量； S332， 当核心系统完成日终批量后， 基于所述大数据平台的数据集成机制抽取数据， 将 “T‑1日总账余 额”插入所述“实时校准表 ”， 作为第二次基准 值； S333， 实时计算平台从所述 “实时校准表 ”获取交易时间最大的一笔 “预计时点余额 ”作 为新的T日基准， 合并T日新增存贷款业务流数据， 将最终结果在报表平台的 “大额变动表 ” 进行展示。 3.根据权利要求2所述的一种基于7 ×24小时的实时数据校准方法， 其特征在于， 所述 S4所述异步比对两个 基准值由7×24小时校准 程序执行， 所述S4的所述进一 步的处理包括： S41， 如果所述差值超过阈值， 则将超过阈值的信息推送实时预警平台， 并发送短信通 知大数据平台负责人、 开发人员和应用运维值班人员；权　利　要　求　书 1/3 页 2 CN 114579555 B 2S42， 所述实时预警平台提供差错处理入口， 并通过所述差错处理入口将差错处理指令 发送到所述大 数据平台； S43， 大数据平台接收到实时预警平台差错请求， 根据所述差错请求内的差错处理类型 完成差错处 理， 并将所述差错处 理的处理结果反馈给 所述实时预警平台； S44， 所述实时预警平台接收所述差错处理的处理结果并将所述处理结果进行统一展 示。 4.根据权利要求3所述的一种基于7 ×24小时的实时数据校准方法， 其特征在于， 所述 S41包括： S411， 基于所述大数据平台的调度监控机制， 在所述S332完成后触发异步差异比对脚 本以进行所述异步比对， 以0:00时间节点的 “T‑1日流数据余额 ”减去0:40时间节点的 “T‑1 日总账余 额”， 作为所述差值的绝对值插 入“实时预警表 ”； S412， 基于所述大数据平台的调度监控机制， 监控所述 “实时预警表 ”中的“是否预警 ” 字段， 如果所述 “是否预警 ”字段为“是”， 则以报文接口的形式为实时预警平台提供差错查 询接口服务， 并展示所有的当日需要处理的差错信息， 所述差错信息包含要素有： 对账系 统、 付款账户、 付款账户名称、 收款账户、 差错处理状态、 差错处理信息， 同步通过报文接口 的形式调用短信平台发送短信通知干系人。 5.根据权利要求3所述的一种基于7 ×24小时的实时数据校准方法， 其特征在于， 所述 S43包括： 若指令为“重跑”， 大数据平台对所述T日新增存贷款业务流水数据产生的账务进行重 跑处理， 同时更新 “实时校准表 ”所述差错信息的基准值、 比对值、 差异值， 差错处理状态为 “已重跑”状态； 若指令为“忽略”， 大数据平台对更新 “实时校准表 ”中所述T日新增存贷款业务流水数 据的差错信息 置为“忽略”。 6.一种基于7 ×24小时的实时数据校准系 统， 用于执行权利要求1 ‑5任一所述的基于7 ×24小时的实时数据校准方法， 其特征在于， 包括硬件系统以及软件模块， 其中所述硬件系 统包括大 数据平台， 所述软件 模块包括： 时间段确定模块， 用于基于核心业务系统T ‑1日总账批量确定所述实时数据校准的时 间段， 所述时间段的起点为每天0:00， 所述时间段的结束时间为核心 业务系统T ‑1日总账批 量结束时间； 间隔确定模块， 用于基于所述时间段确定日终批量空隙， 所述日终批量空隙为时间段 的间隔； 双基准值确定模块， 用于在所述大数据平台上部署7 ×24小时校准程序以及实时预警 平台， 并且在所述日终批量空隙内进行所述数据校准的两次基准更新获得两个基准值， 所 述两个基准值分别是所述时间段的起点的 “T‑1日流数据余额 ”和所述时间段的结束时间的 “T‑1日总账余 额”； 实时数据 校准模块， 异步比对两个基准值， 计算出两个基准值的差值， 并根据所述差值 由所述大 数据平台进行进一 步的处理获得实时数据校准结果。 7.一种电子设备， 其特征在于， 包括处理器和存储器， 所述存储器存储有多条指令， 所 述处理器用于读取 所述指令并执 行如权利要求1 ‑5任一所述的方法。权　利　要　求　书 2/3 页 3 CN 114579555 B 3