(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202211154785.9 (22)申请日 2022.09.21 (71)申请人 深圳瑞泰信资讯有限公司 地址 518000 广东省深圳市南 山区南头街 道南海大道3 025号创意大厦10楼1010 (72)发明人 魏温远　张钧　 (74)专利代理 机构 深圳市海顺达知识产权代理 有限公司 4 4831 专利代理师 蔡星 (51)Int.Cl. G06F 16/25(2019.01) G06F 16/248(2019.01) G06F 16/2458(2019.01) G06Q 10/10(2012.01) (54)发明名称 一种数据收集分发处理方法及其数据处理 平台 (57)摘要 本发明提供一种数据收集分发处理方法， 包 括： 数据处理平台在自身数据库中定义与数据源 系统交互的数据结构类型、 数据装载方式、 数据 传输协议、 对同一对象属性数据的属性翻译规 则、 数据传递方式； 获取或接收数据源系统的数 据， 按数据处理平台的数据结构类型进行存储； 数据处理平台在自身数据库中定义与数据目标 系统交互的数据结构类型、 数据装载方式、 数据 传输协议、 对同一对象属性数据的属性翻译规 则、 数据传递方式； 把数据拼接成数据目标系统 可以识别的数据结构类型， 向数据目标系统推送 数据； 数据处理平台写下数据获取、 接收、 转换、 存储、 推送的执行日志。 本发明的有益效果为： 能 够实现数据的有序收集和快速准确分发。 权利要求书2页 说明书7页 附图1页 CN 115455102 A 2022.12.09 CN 115455102 A 1.一种数据收集分发处 理方法， 其特 征在于， 包括如下步骤， 步骤1： 数据处 理平台在自身数据库中定义与数据源系统 交互的数据结构类型； 步骤2： 数据处 理平台在自身数据库中定义与数据源系统 交互的数据装载 方式； 步骤3： 数据处 理平台在自身数据库中定义与数据源系统 交互的数据传输协议； 步骤4： 数据处理平台在 自身数据库中定义与数据源系统对 同一对象属性数据的属性 翻译规则； 步骤5： 数据处理平台在自身数据库中定义与数据源系统之间的数据传递方式， 并获取 或接收数据源系统的数据； 步骤6： 数据处理平台根据与 数据源系统之间的属性翻译规则和数据传输协议， 对不同 对象属性的数据进行匹配和组合， 按数据处 理平台的数据结构类型进行存 储； 步骤7： 数据处 理平台在自身数据库中定义与数据目标系统 交互的数据结构类型； 步骤8： 数据处 理平台在自身数据库中定义与数据目标系统 交互的数据装载 方式； 步骤9： 数据处 理平台在自身数据库中定义与数据目标系统 交互的数据传输协议； 步骤10： 数据处理平台在自身数据库中定义与数据目标系统对同一对象属性数据的属 性翻译规则； 步骤11： 数据处理平台在自身数据库中定义与数据目标系统之间的数据传递方式， 并 根据与数据目标系统之 间的属性翻译规则和数据传输协 议， 把数据拼接成数据目标系统可 以识别的数据结构类型， 调用数据目标系统的API接口， 向数据目标系统推送数据； 步骤12： 数据处理平台在自身数据库中写下数据获取、 接收、 转换、 存储、 推送的执行日 志， 并在出现错 误信息时将含有错 误信息的执 行日志反馈给 数据处理平台的管理人员。 2.如权利要求1所述的数据收集分发处理方法， 其特征在于： 在所述步骤1和步骤7中， 所述数据处理平台与所述数据源系统、 所述数据目标系统交互的数据结构 类型为对象的属 性结构。 3.如权利要求2所述的数据收集分发处理方法， 其特征在于： 在所述步骤2和步骤8中， 所述数据处理平台与所述数据源系统、 所述数据目标系统交互的数据装载方式包括JSON、 XML。 4.如权利要求3所述的数据收集分发处理方法， 其特征在于： 在所述步骤3和步骤9中， 所述数据处理平台与所述数据源系统、 所述数据目标系统交互的数据传输协议包括http、 WebService和中间表。 5.如权利要求4所述的数据收集分发处理方法， 其特征在于： 在所述步骤5 中， 所述数据 处理平台与所述数据源系统之间的数据传递方式包括被动接 收式和主动读取式， 其中， 所 述被动接收式为所述数据处理平台向所述数据源系统发布自身数据库的API接口， 被动接 收所述数据源系统推送的数据， 所述主动读取式为所述数据 处理平台配置调度任务， 根据 所述数据源系统提供的API接口定时获取 所述数据源系统的数据。 6.如权利要求5所述的数据收集分发处理方法， 其特征在于： 在所述步骤11中， 所述数 据处理平台与所述数据目标系统之 间的数据传递方式为主动推送式， 即所述数据处理平台 配置调度任务， 根据所述数据目标系统提供的API接口， 定时调用所述数据目标系统的API 接口向所述数据目标系统推送数据。 7.如权利要求6所述的数据收集分发处理方法， 其特征在于： 在所述步骤5和所述步骤6权　利　要　求　书 1/2 页 2 CN 115455102 A 2中， 所述数据处理平台设有数据查阅接口、 数据修改接口、 数据获取或推送手动操作接口， 其中， 所述数据查阅接口用于查阅数据 处理平台存储的数据， 所述数据修改接口用于修改 数据处理平台存储的数据， 所述数据获取或推送手动 操作接口用于手动操作数据获取和手 动操作数据推送到数据目标系统中。 8.如权利要求7所述的数据收集分发处理方法， 其特征在于： 在所述步骤12中， 所述数 据处理平台设有邮件提醒模块， 在数据获取、 接收、 推送不成功 时， 根据所述数据处理平台 内配置的邮箱列表， 主动向交 互目标发送邮件提醒。 9.如权利要求8所述的数据收集分发处理方法， 其特征在于： 所述数据处理平台设有数 据清理模块， 根据所述数据 处理平台内配置的数据清理条件， 所述数据 处理平台定期自动 清理符合清理条件的数据。 10.一种实现权利要求1 ‑9任一项所述的数据收集分发处理方法的数据处理平台,其特 征在于， 包括： 设置模块， 用于在 自身数据库中定义与数据源系统交互的数据结构类型、 数据装载方 式、 数据传输协议、 对同一对象属 性数据的属 性翻译规则、 数据传递方式； 用于在自身数据 库中定义与数据目标系统交互的数据结构 类型、 数据装载方式、 数据传输协 议、 对同一对象 属性数据的属性翻译规则、 数据传递方式； 数据接收模块， 用于 接收数据源系统推送的数据； 数据获取模块， 用于根据所述数据源系统提供的API接口定时主动获取所述数据源系 统的数据； 数据推送模块， 根据所述数据目标系统提供的API接口， 定时调用所述数据目标系统 的 API接口向所述数据目标系统推送数据； 邮件提醒模块， 用于在数据获取、 接收、 推送不成功时， 根据所述数据处理平台内配置 的邮箱列表， 主动向交 互目标发送邮件提醒； 数据处理和存储模块， 用于根据与数据源系统之间的属性翻译规则和数据传输协议， 对不同对 象属性的数据进行匹配和组合， 按数据 处理平台的数据结构类型进行存储； 用于 根据与数据目标系统之 间的属性翻译规则和数据传输协 议， 把数据拼接成数据目标系统可 以识别的数据结构类型； 用于提供数据查阅接口、 数据修改接口、 数据获取或推送手动 操作 接口； 数据清理模块， 用于根据所述数据处理平台内配置的数据清理条件， 所述数据处理平 台定期自动清理符合清理条件的数据； 日志模块， 用于在自身数据库中写下数据获取、 接收、 转换、 存储、 推送的执行日志； 用 于将含有错 误信息的执 行日志反馈给 数据处理平台的管理人员。权　利　要　求　书 2/2 页 3 CN 115455102 A 3