(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202211044072.7 (22)申请日 2022.08.29 (71)申请人 中国建设银行股份有限公司 地址 100033 北京市西城区金融大街25号 申请人 建信金融科技有限责任公司 (72)发明人 冯振彪　刘文勇　马明岩　楚孔闯　 (74)专利代理 机构 中科专利商标代理有限责任 公司 11021 专利代理师 张博 (51)Int.Cl. G06F 16/23(2019.01) G06F 16/248(2019.01) G06F 9/54(2006.01) (54)发明名称 基于领域驱动设计的数据处理方法、 装置、 设备及介质 (57)摘要 本公开提供了一种基于领域驱动设计的数 据处理方法， 应用于大数据领域和数据库领域。 该方法包括： 响应于检测到针对目标数据的更新 操作， 根据目标数据构建数据变更事件； 对数据 变更事件进行领域边界分析， 确定目标数据具有 的N个领域标识； 基于数据变更事件和N个领域标 识， 构建与每个领域标识对应的领域数据更新任 务， 得到N个领域数据更新任务； 根据N个领域数 据更新任务， 分别更新N个领域标识各自对应的 第一领域数据， 得到N个领域标识各自更新后的 第一目标领域数据， 其中， 与领域标识对应的领 域边界由领域驱动设计方法确定； 根据第一目标 领域数据， 生 成N个目标领域报表。 本公开还提供 了一种数据处理装置、 设备、 存储介质和程序产 品。 权利要求书2页 说明书14页 附图9页 CN 115269625 A 2022.11.01 CN 115269625 A 1.一种基于领域驱动设计的数据处 理方法， 包括： 响应于检测到针对目标 数据的更新操作， 根据所述目标 数据构建数据变更事 件； 对所述数据变更事件进行领域边界分析， 确定所述目标数据具有的N个领域标识， N为 大于1的正整数； 基于所述数据变更事件和N个所述领域标识， 构建与每个所述领域标识对应的领域数 据更新任务， 得到N个所述领域数据更新任务； 根据N个所述领域数据 更新任务， 分别更新第 一数据库中N个所述领域标识各自对应的 第一领域数据， 得到N个所述领域标识各自更新后的第一目标领域数据， 其中， 与所述领域 标识对应的领域 边界由领域驱动设计方法确定； 以及 根据所述第一目标 领域数据， 生成N个所述领域标识各自对应的目标 领域报表。 2.根据权利要求1所述的数据处理方法， 其中， 所述数据变更事件包括M个， M为大于1的 正整数； 基于所述数据变更事件和N个所述领域标识， 构建与每个所述领域标识对应的N个领域 数据更新任务包括： 基于异步消息队列， 将M个所述数据变更事 件异步发送至变更事 件注册表； 以及 在监听到所述变更事件注册表中的M个所述数据变更事件中的目标数据变更事件的情 况下， 基于监听到的目标数据变更事件， 以及与所述 目标数据变更事件对应的目标领域标 识， 生成与所述目标领域标识对应的数据更新任务， 直至生成其他N ‑1个所述领域标识各自 对应的其 他N‑1个领域数据更新任务。 3.根据权利要求1所述的数据处理方法， 其中， 根据N个所述领域数据 更新任务， 分别更 新第一数据库中N个所述领域标识各自对应的第一领域数据， 得到N个所述领域标识各自更 新后的第一目标 领域数据包括： 根据N个所述领域数据更新任务， 确定N个所述领域标识中， 每个所述领域标识对应的 目标数据和数据更新操作； 基于N个所述领域标识各自对应的目标数据和数据 更新操作， 生成N个所述领域标识各 自对应的数据更新语句； 以及 在所述第一数据库中， 分别在每个所述领域标识各自对应的目标领域中， 执行与所述 领域标识对应的数据更新语句， 生成N个所述领域标识各自的更新后的第一目标 领域数据。 4.根据权利要求1所述的数据处理方法， 其中， 根据N个所述领域数据 更新任务， 分别更 新第一数据库中N个所述领域标识各自的第一领域数据， 得到N个所述领域标识各自更新后 的第一目标 领域数据包括： 根据N个所述领域数据 更新任务， 分别更新第 二数据库中N个领域标识各自对应的第二 领域数据， 得到第二数据库中N个所述领域标识各自的更新后的第二目标 领域数据； 利用所述第 二数据库中的N个所述第 二目标领域数据， 分别更新所述第 一数据库中N个 所述领域标识各自的第一领域数据， 得到N个所述领域标识各自更新后的第一目标领域数 据。 5.根据权利要求4所述的数据处理方法， 其中， 利用第二数据库中的N个所述第二目标 领域数据， 分别更新所述第一数据库中N个所述领域标识各自的第一领域数据， 得到N个所 述领域标识各自更新后的第一目标 领域数据包括：权　利　要　求　书 1/2 页 2 CN 115269625 A 2根据所述第二数据库中的N个所述第 二目标领域数据， 生成N个所述第 二目标领域数据 各自的第二变更查询语句； 将N个所述第二变更查询语句写入第二变更日志， 得到目标第二变更日志； 在监听到目标第二变更日志生成的情况下， 将N个所述第二变更查询语句同步至第一 数据库中， 得到N个第一变更查询语句； 以及 在所述第 一数据库中执行N个所述第 一变更查询语句， 得到N个所述领域标识各自更新 后的第一目标 领域数据。 6.根据权利要求1所述的数据处 理方法， 还 包括： 响应于针对目标查询项的查询请求， 根据所述查询请求， 确定与所述查询请求中的目 标查询项对应的L个目标查询领域标识； 根据所述目标查询项生成L个所述目标查询领域标识各自对应的目标查询指令； 根据L个所述目标查询 指令， 从所述第一数据库中的L个目标查询领域标识各自的存储 区域中， 分别调取与所述目标查询项相关联的目标查询领域报表， 得到L个所述目标查询领 域报表； 以及 在交互页面中生成L个所述目标查询领域报表。 7.一种基于领域驱动设计的数据处 理装置， 包括： 第一构建模块， 用于响应于检测到针对目标数据的更新操作， 根据所述目标数据构建 数据变更事 件； 第一确定模块， 用于对所述数据变更事件进行领域边界分析， 确定所述目标数据具有 的N个领域标识， N 为大于1的正整数； 第二构建模块， 用于基于所述数据变更事件和N个所述领域标识， 构建与每个所述领域 标识对应的领域数据更新任务， 得到N个所述领域数据更新任务； 第一更新模块， 用于根据N个所述领域数据更新任务， 分别更新第一数据库中N个所述 领域标识各自对应的第一领域数据， 得到N个所述领域标识各自更新后的第一目标领域数 据， 其中， 与所述领域标识对应的 的领域边界由领域驱动设计方法确定； 以及 目标领域报表生成模块， 用于根据所述第一目标领域数据， 生成N个所述领域标识各自 对应的目标 领域报表。 8.一种电子设备， 包括： 一个或多个处 理器； 存储装置， 用于存 储一个或多个程序， 其中， 当所述一个或多个程序被所述一个或多个处理器执行时， 使得所述一个或多个 处理器执行根据权利要求1～6中任一项所述的方法。 9.一种计算机可读存储介质， 其上存储有可执行指令， 该指令被处理器执行时使处理 器执行根据权利要求1～6中任一项所述的方法。 10.一种计算机程序产品， 包括计算机程序， 所述计算机程序被处理器执行时实现根据 权利要求1～6中任一项所述的方法。权　利　要　求　书 2/2 页 3 CN 115269625 A 3