(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202210699217.0 (22)申请日 2022.06.20 (71)申请人 上海纽酷信息科技有限公司 地址 200000 上海市徐汇区钦州路10 0号1 号楼1104-6室 (72)发明人 陈适文　顾倩文　李春迎　崔军华　 张智宇　曹传嵩　 (74)专利代理 机构 杭州山泰专利代理事务所 (普通合伙) 33438 专利代理师 张飞 (51)Int.Cl. G06F 16/248(2019.01) G06F 16/2455(2019.01) G06F 16/2458(2019.01) G06F 16/27(2019.01) (54)发明名称 一种基于BI平台的低代码平台数据传输方 法 (57)摘要 本发明公开了一种基于BI平台的低代码平 台数据传输方法， 包括以下步骤： S1、 在低代码平 台建立表单结构A并同步到BI平台， BI平台同步 创建表单结构B， 表单结构A映射为clickHouse数 据库中的物理表结构， 若表单结构A从属于表单 结构B， 则会在clickHouse数据库的表单结构B中 维护和表单结构A的关系； S2、 在步骤S1的前提 下， 在低代码平台的表单结构A中建立数据C并同 步到BI平台， BI平台同步的表单结构B中同步有 数据D。 本发明中， 将现有低代码平台上的结构和 数据全部实时同步到BI 分析系统上， 这样就能够 直接使用BI分析系统搭建低代码平台所缺乏的 报表服务， 即便是非专业人员也能轻易内搭建出 一套复杂分析报表， 提高便捷性， 降低时间和人 力成本。 权利要求书2页 说明书17页 附图3页 CN 115098567 A 2022.09.23 CN 115098567 A 1.一种基于BI平台的低代码平台数据传输方法， 其特征在于， 所述低代码平台和BI平 台之间通过消息中间件kafka进行数据传输， 低代码平 台投送数据至消息中间件kafka， BI 平台消费消息中间件kafka 中的消息， 具体的， 包括以下步骤： S1、 在低代码平台搭建出自定义的表单、 流程和服务规则， 包括表单的字段、 字段类型 和配置属性， 流程包括工作流和审核流， 工作流负责将多个表单关联起来， 可以做到表单联 动， 审核流是在单个表单中， 实现表单审核状态变化； S2、 将低代码平台的表单 结构传给BI平台， 并落到 clickHouse 数据库中； S21、 在低代码平台建立表单结构A， 根据表单信息创建kafka消息， 并将表单结构A通过 kafka消息中间件将数据传输到flink系统， flink系统按照既定的协议要求对kafka消息进 行解码， 并通过数据驱动将对应数据表创建到clickHouse数据库， 即在BI平台同步创建表 单结构B； S211、 在低代码平台修改表单结构A后， 根据 修改后的表单结构A1构建新的k afka消息， 并发送到消息中间件Kafka； S212、 flink系统收到新的k afka消息， 按照既定的协议要求进行解码， 并判断对应表单 结构B是否存在， 若存在则执 行步骤S213， 若不存在则执 行步骤S214； S213、 去除修改后的表单结构A1中已经存在的组件字段， 并判断修改后的表单结构A1 中是否有表单结构B中不存在的组件， 若 是， 则通过数据驱动为表单结构B中新增组件字段， 获得修改后的表单结构B11并持久化到clickHouse数据库， 若不是则直接输出表单结构B并 持久化到 clickHouse 数据库； S214、 根据 修改后的表单结构A1通过数据驱动在clickHouse数据库中新建对应的表单 结构B12： S22、 在步骤S1的前提下， 在低代码平台的表单结构A中建立数据C并同步到BI平台， BI 平台同步的表单 结构B中同步有数据D； S221、 在低代码平台编辑数据C， 低代码平台取其修改的数据C1增量性的发送到消息中 间件kafka； S222、 BI平台收到数据C变更的消息， 从缓存中读取数据C已同步的全量消息D， 与本次 增量数据C1通过 单据id取交集得到新的全量数据D1， 并放入缓存中； S23、 解析全量数据D1中所有的数据列信息， 通过与表单结构B中的所有列信息进行对 比从而得到一个完整的执行s ql， 通过数据驱动插入到clickHouse数据库， 并通过表的合并 引擎MergeTre e， 对单据主键相同的数据进行合并； S3、 BI平台将最新的表单之间关联关系， 以及流程与表单的关联关系， 按照低代码平台 侧的呈现规则进行展示， 保证低代码平台配置的关联逻辑与BI平台的展示逻辑保持一 致。 2.根据权利要求1所述的一种基于BI平台的低代码平台数据传输方法， 其特征在于， 所 述低代码平台包括表单、 工作流、 审核流设计器， 通过表单设计器搭建表单结构， 通过工作 流和审核流设计器定义流程， 所述BI平台基于flink系统实现数据处理， 即从消息中间件 kafka中消费数据， 并通过逻辑计算将明细数据存入缓存中， 当缓存刷新成功后， 继续将数 据保存至 clickHouse 数据库； 所述逻辑计算包括将kafka消息进行解码并解析成对应数据表结构， 并将数据结构通 过数据驱动在clickHouse数据库创建出对应的数据表， 还包括将kafka消息进行解码并解权　利　要　求　书 1/2 页 2 CN 115098567 A 2析成对应的数据 表的数据内容， 并根据元数据信息通过数据驱动去和数据 表结构进行对比 和持久化数据。 3.根据权利要求1所述的一种基于BI平台的低代码平台数据传输方法， 其特征在于， 在 步骤S21中， 表单结构A下的组件包括ID、 编码、 单行文本、 多行文本、 单选、 多选、 日期、 开关、 关联表单、 多选关联对象， 其中， ID、 编码、 单行文本、 多行文本、 单选、 关联表单映射为 clickHouse数据库的字符串String类型， 日期映射为clickHouse数据库的字符串Date   Time64类型， 开关映射为clickHouse数据库的字符串Int类型， 多选、 多选关联对象映射为 clickHouse 数据库的字符串A rray类型。 4.根据权利要求1所述的一种基于BI平台的低代码平台数据传输方法， 其特征在于， 在 步骤S222中， 使用非关系型 数据库Mo ngoDB进行 数据缓存。 5.根据权利要求1所述的一种基于BI平台的低代码平台数据传输方法， 其特征在于， 在 步骤S1中， 表单与表单关联关系： 按关联表单的字段展开， 按关联表单的字段值展开； 表单 与流程关联关系： 按表单展开流程中不同节点的操作 记录展开； 表单与服务规则关联关系： 按表单上绑定的服 务， 展开服务中关联的表单信息 。权　利　要　求　书 2/2 页 3 CN 115098567 A 3