数据流典型场景-数据对比和补偿

变更记录

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单据的【数据比较】资源，将上一步转换后的基本信息与数据库中实际存在的数据进行比较，并忽略已同步数据。

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

创建