如何使用服务流程进行数据一致性补偿同步

服务流程是集成云推出的面向复杂集成场景的低代码服务编排工具，能够把已有的集成对象、集成方案、消息服务、API接口等集成资源，通过流程化设计编排成全新的应用服务，以支持更加复杂的业务场景。

例如基础数据分发到多个系统、数据消费需要从多源取数、基于某个数据参数处理不同的集成过程等等。

为了帮助大家快速掌握服务流程的使用方法，我们推出了系列文章，通过11个典型案例向大家介绍服务流程的高级技巧。

在上期集成服务流程典型案例系列文章中，我们为大家介绍了服务流程的第5个典型案例：如何使用服务流程进行基础资料初始化。

本期，小编继续为大家介绍第6个案例：以定时同步第三方系统凭证为例，演示如何进行数据一致性补偿同步，包括以下3个要点：

1 案例思路拆解

1.1 整体思路

业务人员在使用系统时，数据库直连或数据库代理等异构系统需要通过苍穹系统进行凭证同步。对此，服务流程提供了一种解决方案。

该解决方案的整体思路为：通过定时检查源系统和目标系统数据是否一致，对差异部分进行补偿同步，以保证两个系统间数据的一致性。

针对本文提出的定时同步第三方系统凭证案例，具体原理为：使用苍穹二开的凭证模版作为中间表，当源系统数据更新时，使用服务流程中数据对比节点对比源系统与中间表差异，检测出源系统新增、修改、删除的数据，从而调用不同的目标系统接口生成凭证、修改凭证或删除凭证。

实现原理

使用服务流程进行数据一致性补偿同步的业务逻辑如下：

1、设置凭证启动方式为定时启动；

2、通过两个数据对比节点分别检测新增/修改和删除的凭证数据；

3、若数据对比结果为map类型数据，需要转成list后作为后续处理的筛选条件值；

4、更新源系统凭证数据需要先同步到中间表，再通过中间表数据模版调用目标系统的微服务生成凭证；

5、删除源系统凭证需要先调用目标系统微服务删除凭证，成功后再删除中间表数据。

具体的流程如下图所示：

流程图概览

利用服务流程，可定时检测源系统新增、修改的数据，从而调用目标系统接口生成凭证、修改凭证。具体实现流程如下：

为了检测源系统数据是否有新增或修改，首先需要建立一个基于源系统和中间表的数据集成方案的数据对比方案，以对比源系统中数据是否在中间表中存在或需要更新。

新增数据集成方案

新增数据对比方案

将服务流程开始节点设置为每天定时启动，数据对比节点将过滤出最近两天的源系统更新数据，并将对比差异结果保存到流程变量中用于后续处理。

检查新增、修改的凭证

通过脚本节点获取上一步对比结果的流程变量（map）中所有ID值，并保存在另一个变量（list）中。如果该变量为空，则无需同步，结束这条分支流程。

获取