变更记录

1 业务背景

通用场景：对比两个单据A和B，补偿B单据中缺失的A单据数据。

本案例以集成服务云基础资料demo1和demo2单据两个单据对比为例，简要介绍通过数据流实现数据对比和补偿的方法。

2 解决方案

2.1 概述

查询基础资料demo1，比较相同编码的基础资料demo2的数据，如果数据不一致则进行补偿。

主要思路如下：

1. 通过定时查询最近修改的demo1的基本信息数据，转换成demo2基本信息数据（需要进行比较的字段）

2. 然后将转换后的demo2基本信息数据与demo2数据库数据进行比较

3. 若存在则忽略，不存在则通过这条数据线上的demo1对应id去读取demo1详细信息

4. 然后将demo1详细信息数据转换成demo2详细信息数据

5. 最后保存到demo2单据实体上。

2.2 数据流资源准备

前提条件：对数据流已经有基本认识，学习过数据流入门案例。

本小节各步骤非必须，若系统中已存在对应资源，可忽略该步骤。

步骤1：创建数据模型-基础资料demo1实体

在数据流资源列表选择对应保存资源路径，定位到末级后，点击”集成对象导入“按钮进行【实体】数据模型的导入，作为源数据模型。

本例中的基础资料demo1已预置，对于其他未导入的实体、数据表、视图类的集成对象，导入后将在数据流中创建实体数据模型。

建立数据模型 - 通过实体导入

数据模型 - 基础资料demo1实体

步骤2：数据查询-查询DEMO1最近修改的基本数据

创建一个获取demo1单据基本信息的【数据查询】资源，取数字段仅包含demo1数据模型“id/number/modifytime”等基本信息字段，减小数据体量。

在数据流资源列表选择对应保存资源路径，定位到末级后，点击”新增“按钮，选择”数据查询“资源类型。

创建数据查询资源 - 选择资源类型

数据模型中“查询对象”选择步骤1创建的“基础资料demo1”，“查询条件参数”选择“数据查询-时间范围参数”（系统预置），“时间戳”字段选择“modifytime”。

数据查询资源-查询DEMO1最近修改数据基本信息

步骤3：建立数据模型 - 基础资料demo2实体

参考步骤1，建立基础资料demo2【实体】，作为目标数据模型。

步骤4：数据映射 - demo1基本信息转demo2基本信息

创建一个【字段映射】资源，将demo1的基本信息转换成对应的demo2基本信息，用于作为比较的数据来源。

数据映射-将demo1基本信息字段映射为demo2基本信息

步骤5: 数据比较资源 - DEMO2基本信息比较

创建一个对demo2单据的【数据比较】资源，将上一步转换后的基本信息与数据库中实际存在的数据进行比较，并忽略已同步数据。

在数据流资源列表选择对应保存资源路径，定位到末级后，点击”新增“按钮，选择”数据比较“资源类型。

创建数据编织资源 - 选择资源类型

“数据模型”中“目标数据”选择“基础资料demo2”，“比较结论”选择“数据比较-结果”（系统预置），“数据流中止执行并更新忽略计数”选择“数据一致”。

数据比较资源-DEMO2基本信息比较，忽略已同步数据

步骤6：数据读取资源 - 获取DEMO1详细信息

创建一个获取demo1单据详细的【数据读取】资源，按单据id进行取数，取数字段包含demo1数据模型全部字段。

数据读取资源-获取DEMO1详细信息

步骤7：字段映射资源 - DEMO1详细信息转DEMO2

创建一个【字段映射】资源，将demo1的详细信息转换成对应的demo2详细信息，作为加载的内容。

字段映射资源-DEMO1详细信息转DEMO2

步骤8：实体操作资源 - 保存DEMO2详细信息

创建一个【实体操作】资源，将demo2的详细信息保存到对应单据实体。

实体操作资源-保存DEMO2详细信息

2.3 数据流图设计

步骤1：配置流程属性

依次填写“名称”、“编码”、“数据流方案”等基本信息，在“外部系统声明”中分别选择两个对比单据的来源系统连接（此案例中demo1和demo2都是当前账套连接，因此只需声明一个）。

数据流图 - 流程属性

步骤2：节点配置与编排

将各节点资源依次按处理逻辑编排起来，并关联连接器

数据流节点

数据流图概览 - 数据对比和补偿

2.4 启动方案设计

步骤1：创建启动事件

创建一个【定时启动】的事件模型，“数据提供者”为2.2章节步骤2中创建的数据查询资源“定时查询最近修改的DEMO1基本信息”，“执行计划”自行定义即可。

创建启动事件 - 资源类型选择

创建启动事件 - 启动事件

步骤2：创建启动方案

创建一个【启动方案】，选择对应数据流和步骤1创建的启动事件，依次配置其他字段即可。“参数绑定”中给对应“最早/最晚时间”参数赋值（本案例为最近一小时内）。

创建启动方案 - 启动方案