(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 20221084825 6.2 (22)申请日 2022.07.19 (71)申请人 深圳市享多 多网络技 术有限公司 地址 518000 广东省深圳市前海深港合作 区南山街道兴海 大道3044号信利康大 厦19B (72)发明人 曾昭志　王杰　陈福　 (74)专利代理 机构 华进联合专利商标代理有限 公司 44224 专利代理师 黄晓庆 (51)Int.Cl. G06Q 30/06(2012.01) G06Q 30/02(2012.01) (54)发明名称 订单数据处理方法、 装置、 计算机设备和存 储介质 (57)摘要 本申请涉及一种订单数据处理方法、 装置、 计算机设备、 存储介质和计算机程序产品。 所述 方法包括： 从交易库中实时获取待同步数据类型 对应的订单变化数据流； 根据订单变化数据流中 各订单变化数据的数据标识， 对 各订单变化数据 流进行分组操作， 得到各数据标识对应的子订单 变化数据流； 使用预设连接算子对 各数据标识对 应的子订单变化数据流进行合并操作， 得到各数 据标识对应的订单变化宽表数据流； 将订单变化 宽表数据流写入历史库的订单表中。 采用本方法 能够在降低了系统复杂 度的同时， 有效提高了数 据同步的实时性。 权利要求书2页 说明书14页 附图4页 CN 115115433 A 2022.09.27 CN 115115433 A 1.一种订单 数据处理方法， 其特 征在于， 所述方法包括： 从交易库中实时获取待同步数据类型对应的订单变化数据流； 根据所述订单变化数据流中各订单变化数据的数据标识， 对各所述订单变化数据流进 行分组操作， 得到各 所述数据标识对应的子订单变化数据流； 使用预设连接算子对各所述数据标识对应的子订单变化数据流进行合并操作， 得到各 所述数据标识对应的订单变化宽表数据流； 将所述订单变化宽表数据流写入历史库的订单表中。 2.根据权利要求1所述的方法， 其特征在于， 所述使用预设连接算子对各所述数据 标识 对应的子订单变化数据流进行合并操作， 得到各所述数据标识对应的订单变化宽表数据 流， 包括： 在预设时间段内通过状态管理机制对各所述数据标识对应的子订单变化数据流进行 状态保存； 若在所述预设时间段内， 所述数据标识对应有新增子订单变化数据流， 则将所述新增 子订单变化数据流与所述数据标识对应的子订单变化数据流进行合并操作， 得到各所述数 据标识对应的订单变化宽表数据流。 3.根据权利要求1所述的方法， 其特征在于， 所述将所述订单变化宽表数据流写入历史 库的订单表中之前， 还 包括： 对所述订单变化宽表数据流进行完整性检测， 若所述订单变化宽表数据流满足所述完 整性检测， 则使用预设数据分片写入算子， 按照预设规则将所述订单变化宽表数据流写入 历史库的订单表中。 4.根据权利要求3所述的方法， 其特征在于， 所述对所述订单变化宽表数据流进行完整 性检测， 包括： 将所述订单变化宽表数据流中各所述子订单变化数据流的数据类型与所述待同步数 据类型进行对比， 若所述数据类型与所述待同步数据类型一致， 则确定所述订单变化宽表 数据流满足所述完整性检测； 若数据类型与 所述待同步数据类型不一致， 则确定所述订单变化宽表数据流不满足所 述完整性检测。 5.根据权利要求 4所述的方法， 其特 征在于， 所述方法还 包括： 若所述订单变化宽表数据流不满足所述完整性检测， 则根据所述数据类型与 所述待同 步数据类型的比较结果， 确定所述 订单变化宽表数据流的待补充数据类型； 基于所述待补充数据类型， 查找所述交易库的订单表， 确定所述待补充数据类型的子 订单数据流； 根据所述子订单 数据流对所述 订单变化宽表数据流进行补充； 使用所述预设数据分片写入算子， 将补充后的订单变化宽表数据流按照所述预设规则 写入所述历史库的订单表中。 6.根据权利要求1所述的方法， 其特征在于， 所述从交易库中获取待同步数据类型对应 的订单变化数据流， 包括： 从所述交易库中获取日志文件， 对所述日志文件解码得到订单变化数据信息； 根据所述订单变化数据信 息中各所述订单变化数据 所属的数据类型， 对所述订单变化权　利　要　求　书 1/2 页 2 CN 115115433 A 2数据信息进行拆分， 得到待同步数据类型对应的订单变化数据流。 7.根据权利要求1至6任意一项所述的方法， 其特征在于， 所述预设规则包括预设分库 分表规则和时序优先规则； 所述使用预设数据分片写入算子， 按照预设规则将所述订单变化宽表数据流写入历史 库的订单表中， 包括： 按照预设分库分表规则以及时序优先规则， 将所述订单变化宽表数据流分批次的写入 所述历史库的订单表中。 8.一种订单 数据处理装置， 其特 征在于， 所述装置包括： 变化数据流获取模块， 用于从交易库中实时获取待同步数据类型对应的订单变化数据 流； 分组模块， 用于根据所述订单变化数据流中各订单变化数据的数据标识， 对各所述订 单变化数据流进行分组操作， 得到各 所述数据标识对应的子订单变化数据流； 合并模块， 用于使用预设连接算子对各所述数据标识对应的子订单变化数据流进行合 并操作， 得到各 所述数据标识对应的订单变化宽表数据流； 数据同步模块， 用于将所述 订单变化宽表数据流写入历史库的订单表中。 9.一种计算机设备， 包括存储器和处理器， 所述存储器存储有计算机程序， 其特征在 于， 所述处 理器执行所述计算机程序时实现权利要求1至7中任一项所述的方法的步骤。 10.一种计算机可读存储介质， 其上存储有计算机程序， 其特征在于， 所述计算机程序 被处理器执行时实现权利要求1至7中任一项所述的方法的步骤。权　利　要　求　书 2/2 页 3 CN 115115433 A 3