1.1 应用场景

用户想要同步钉钉通信录中的用户信息。

API取数-获取部门通讯录数据 中获取钉钉用户信息的方案，只适用于部门下用户数量不超过 100 的场景；若某部门中用户数超过 100，可参考本文方案获取用户信息。

1.2 实现思路

1.2.1 接口说明

本文方案主要使用的是 获取部门用户详情 接口，要使用该接口，需要获取：Query参数（access_token）、Body 参数（dept_id、cursor）。

• dept_id 通过 循环获取所有部门ID 获得，得到 dept_id 字段。

• cursor 为分页查询的游标，最开始传 0 ，后续传返回参数中的 next_cursor 值。

1.2.2 方案说明

实现过程如下图所示：

2.1 准备工作

• 参考 循环获取所有部门ID 方案，得到 dd_dep 表，本文方案需要用到 dd_dep 表的 dept_id 字段。

• 需要确定应用是否有 通讯录部门成员读权限，本文示例使用的应用是企业内部应用。

2.2 调用接口前准备

本文方案主要使用的是 获取部门用户详情 接口，要使用该接口，需要获取：Query参数（access_token）、Body 参数（dept_id、cursor）。

2.2.1 添加任务参数

cursor 参数为分页查询的游标，最开始传 0 ，后续传返回参数中的 next_cursor 值。本节为 cursor 赋予初始值 0 。

新建定时任务，点击右上角「参数列表」，添加参数 nextCursor ，类型为数值，值为 0 。如下图所示：

2.2.2 获取 access_token

新建定时任务，拖入「参数赋值」节点，使用 获取企业内部应用的access_token 接口获取 access_token。如下图所示：

将 access_token 作为参数输出。如下图所示：

2.2.3 将 dept_id 输出为参数

将 dd_dep 的 dept_id 字段写入到 dd_dep_temp 表中。

若某部门下用户数小于 100 ，调用 获取部门用户详情 接口一次性将数据取完，应该将本次循环所用的 dept_id 删除，下次循环用下一个 dept_id 取数，dd_dep 表为部门表，后续可与用户表关联，不能随意删除数据，所以新建临时表 dd_dep_temp。

1）拖入「数据同步」节点，将 dd_dep 表中的 dept_id 字段写入到 dd_dep_temp 中，写入方式选择清空目标表，再写入数据。如下图所示：

2）右键点击「参数赋值」节点，选择「运行节点及下游」，在数据库中新增 dd_dep_temp 表，便于后续步骤中将 dd_dep_temp 表中的 dept_id 输出为参数。如下图所示：

3）拖入「参数赋值」节点，将 dd_dep_temp 表中的第一个 dept_id 字段输出为参数 nextDepId 。如下图所示：

2.3 调用接口取出用户数据

循环容器中，调用 获取部门用户详情 接口，获取用户数据，用户数据如下图所示：

若has_more非空：将 has_more、next_cursor 输出为参数，为下次循环准备

• 若 has_more 非空：将 has_more、next_cursor 输出为参数，为下次循环准备。

• 若 has_more 为空、userid 非空，输出用户信息到 userid_test （用户信息表中）。

2.3.1 调用接口

1）拖入「循环容器」节点，「循环容器」内拖入「数据转换」节点，进入「数据转换」节点。

2）拖入「API输入」算子，调用 获取部门用户详情 接口，获取用户数据，Body 内引用 nextDepId、nextcursor 参数。如下图所示：

点击「数据预览」，如下图所示：

用户信息在 result 字段中，需要进行解析。

2.3.2 解析数据

1）拖入「JSON解析」节点，解析 result 字段，选择节点：has_more、dept_id_list、mobile、name、userid、job_number、title、next_cursor。

需注意，当 has_more 字段为 false 时，是没有 next_cursor 字段的，因此，建议在 dd_dep 表中找到超过 100 用户数的部门ID，赋值给 2.2.3 节中参数 nextDepId 。

2）点击「数据预览」，如下图所示：

2.3.3 新增一列depids

用户信息表后续可能与部门表 dd_dep 关联，所以本节新增一列 depids，用于后续作为左右合并的依据，使用「Spark SQL」算子实现。如下图所示：

2.3.4 结果输出

1）拖入「参数输出」算子、「DB表输出」算子，将这两个算子分别与「Spark SQL」算子相连。

2）右键点击「Spark SQL」算子，选择数据分发，若has_more非空，将 has_more、next_cursor 输出为参数，为下次循环准备；若has_more为空、userid非空，输出用户信息到 userid_test （用户信息表中）。

3）使用「参数输出」算子，将has_more、next_cursor 输出为参数。如下图所示：

4）使用「DB表输出」算子，将用户信息输出到userid_test （用户信息表中），写入方式选择直接将数据写入目标表，userid 设为主键，主键冲突策略选择主键相同，覆盖目标表的数据。如下图所示：

5）点击右上角「保存」按钮。

2.4 用户数量超过100

若 has_more 为true，即该部门ID下数据未取完，依然使用本次循环的 dept_id 做下次循环。

1）拖入「条件分支」节点，拖入「SQL脚本」节点、「参数赋值」节点，「SQL脚本」节点、「参数赋值」节点分别与「条件分支」节点相连。

2）设置「条件分支」节点，若 has_more 为 true ，执行「参数赋值」节点；若 has_more 为 false，执行「SQL脚本」节点。如下图所示：

3）设置「参数赋值」节点，依然使用本次循环的 dept_id 做下次循环。如下图所示，输出参数 nextDepId 。

2.5 用户数量未超过100

若has_more为false，即该部门ID下数据已取完：

1）SQL脚本节点：删除本次循环所用的 dept_id。

2）数据转换2节点：参数 next_cursor 置0。

3）参数赋值3节点：将 dd_dep_temp 表的行数输出为参数。

• 参数赋值4节点：若行数小于等于0（dept_id 已取完） ，下次循环的 dept_id 置0 。

• 数据转换3节点：若行数大于0（dept_id 未取完），输出 dept_id ，供下次循环。

2.5.1 删除本次循环所用的 dept_id

本次循环所用的 dept_id 已将用户数据取完，下次循环需要用到下个 dept_id ，所以我们将本次循环所用的 dept_id 删除。如下图所示：

2.5.2 参数 next_cursor 置0

将参数 next_cursor 置0，为下次循环准备。

1）拖入「数据转换」节点，进入「数据转换」节点。

2）拖入「Spark SQL」算子，将参数 next_cursor 置0。如下图所示：

3）拖入「参数输出」算子，将 0 赋值给参数 nextCursor 。如下图所示：

4）点击右上角「保存」按钮。

2.5.3 根据部门ID临时表的行数作判断

将部门ID临时表（dd_dep_temp）的行数输出为参数：

• 若行数小于等于0（dept_id 已取完） ：若行数大于0（dept_id 未取完），输出 dept_id ，供下次循环。

• 数据转换3节点：下次循环的 dept_id 置0 。

1）拖入「参数赋值」节点，将部门ID临时表（dd_dep_temp）的行数输出为参数count。如下图所示：

2）拖入「条件分支」节点、「参数赋值」节点、「数据转换」节点，将「参数赋值」节点、「数据转换」节点分别与「条件分支」节点相连。

3）设置「条件分支」节点，若 count 小于等于0，执行「数据转换」节点；若 count 大于 0，执行「参数赋值」节点。如下图所示：

4）若 count 大于0（dept_id 未取完），输出 dept_id ，供下次循环。设置「参数赋值」节点，输出参数 nextDepId 。如下图所示：

5）若 count 小于等于0（dept_id 已取完），下次循环的 dept_id 置空 。

进入「数据转换」节点，拖入「Spark SQL」算子，筛选出空数据，如下图所示：

拖入「参数输出」算子，将空数据赋值给参数nextDepId，由于调试值不能为空，此处随意填一个值即可，调试值不参与实际运行。如下图所示：

6）点击右上角「保存」按钮。