利用轻易云平台实现金蝶云与钉钉的数据集成

  • 轻易云集成顾问-曹润

金蝶云星空数据集成到钉钉的系统对接案例

在本文中，我们将深入探讨一个实际运行的系统对接方案，即如何通过轻易云数据集成平台，将金蝶云星空中的供应商数据集成到钉钉，以实现高效的数据管理和业务流程优化。

方案概述

本次案例命名为【资料】金蝶&钉钉—【往来单位】供应商，主要目标是通过executeBillQuery接口从金蝶云星空获取供应商信息，并使用topapi/processinstance/create接口将这些信息批量写入至钉钉。整个过程注重确保数据完整性、实时性以及可靠的异常处理机制。

数据获取与转换逻辑

为了成功抓取并传输金蝶云星空的数据，首先需要调用executeBillQuery接口。该接口能够按指定条件查询并返回所需的详细供应商信息。然而，在应对大规模数据时，需要考虑分页和限流问题，以确保抓取任务稳定进行。这部分工作通常包括以下步骤：

  1. 定时任务调度：利用轻易云的平台设置定时任务，保证周期性地访问金蝶API。
  2. 分页处理：构建分页逻辑，通过逐页抓取方式避免因大量请求导致服务器压力过大或超时。
  3. 数据格式转换：因两者API要求的数据结构不同，需自定义映射规则以匹配目的端需求。此处涉及字段名称、类型及多级嵌套等方面调整。

数据写入与监控

另一方面，当顺利获得符合要求的数据后，要高效、安全地将其写入至钉钉。这一步最关键的是保证高吞吐量，同时建立一个健全的监控和告警体系来及时发现潜在问题：

  1. 批量操作：尽可能采用批量提交形式（如topapi/processinstance/create），减少单笔操作次数，提高整体效率。
  2. 错误重试机制：
    • 在网络波动或服务暂不可达情况下，引入重试策略。
    • 登记失败记录并触发告警通知，有助于快速定位和修复。

集中控制台与透明化管理

借助轻易云提供的集中式控制台，可以直观查看每个阶段任务执行状况。例如，实时监控各类指标（如成功率、延迟等）、跟踪日志输出，这些都为故障排查和性能优化提供了有力支持。此外，通过统一视图掌握所有API资产，使得资源分配更加合理，高效利用成为可能。

以上章节介绍了该技术方案的一些核心思路，而具体实施细节将在随后的内容中进一步 如何对接钉钉API接口

调用金蝶云星空接口executeBillQuery获取并加工数据

在数据集成的生命周期中，调用源系统接口获取数据是至关重要的一步。本文将深入探讨如何通过轻易云数据集成平台调用金蝶云星空的executeBillQuery接口，获取供应商信息并进行初步加工。

接口配置与调用

首先，我们需要了解executeBillQuery接口的基本配置。根据提供的元数据配置，以下是我们需要关注的主要字段：

  • api: executeBillQuery
  • method: POST
  • idCheck: true
  • request: 包含了请求所需的字段及其描述
  • otherRequest: 包含分页参数、过滤条件等其他请求参数

请求字段解析

在请求字段中，每个字段都有明确的标签、类型和描述。以下是一些关键字段及其作用：

  • FSupplierId: 供应商ID
  • FNumber: 编码
  • FName: 名称
  • FCreateOrgId_FNumber: 创建组织
  • FUseOrgId_FNumber: 使用组织
  • FDescription: 描述
  • FShortName: 简称
  • FCountry_FNumber: 国家
  • FBusinessStatus: 业务状态

这些字段将帮助我们准确地从金蝶云星空中提取所需的供应商信息。

其他请求参数

除了基本的请求字段外，还有一些其他参数需要特别注意：

  • Limit 和 StartRow 用于分页控制。
  • FilterString 用于设置过滤条件，例如：FAuditDate>='{{LAST_SYNC_TIME|dateTime}}'。
  • FieldKeys 用于指定需要查询的字段集合。
  • FormId 固定为 BD_Supplier，表示业务对象表单ID。

实际调用示例

以下是一个实际调用executeBillQuery接口的示例代码片段：

{
    "api": "executeBillQuery",
    "method": "POST",
    "idCheck": true,
    "request": [
        {"field":"FSupplierId","value":"FSupplierId"},
        {"field":"FNumber","value":"FNumber"},
        {"field":"FName","value":"FName"},
        {"field":"FCreateOrgId_FNumber","value":"FCreateOrgId.FNumber"},
        {"field":"FUseOrgId_FNumber","value":"FUseOrgId.FNumber"},
        {"field":"FDescription","value":"FDescription"},
        {"field":"FShortName","value":"FShortName"},
        {"field":"FCountry_FNumber","value":"FCountry.FNumber"},
        {"field":"FBusinessStatus","value":"FBusinessStatus"}
    ],
    "otherRequest": [
        {"field": "Limit", "value": "{PAGINATION_PAGE_SIZE}"},
        {"field": "StartRow", "value": "{PAGINATION_START_ROW}"},
        {"field": "FilterString", "value": "FAuditDate>='{{LAST_SYNC_TIME|dateTime}}'"},
        {"field": "FieldKeys", "value": ["FSupplierId", "FNumber", "FName"]},
        {"field": "FormId", "value": "BD_Supplier"}
    ]
}

数据加工与清洗

在成功获取到数据后，我们需要对数据进行初步加工和清洗，以确保其符合后续处理和存储的要求。例如，可以对供应商名称进行去重处理，对编码进行格式化等。

以下是一个简单的数据清洗示例：

def clean_supplier_data(data):
    cleaned_data = []
    for record in data:
        # 去除重复供应商名称
        if record['FName'] not in [r['name'] for r in cleaned_data]:
            cleaned_data.append({
                'id': record['FSupplierId'],
                'number': record['FNumber'],
                'name': record['FName'],
                'description': record['FDescription']
            })
    return cleaned_data

通过上述步骤，我们可以确保从金蝶云星空获取的数据经过初步清洗后，可以无缝对接到下游系统，实现高效的数据集成。

总结

通过轻易云数据集成平台调用金蝶云星空接口executeBillQuery，我们能够高效地获取并加工供应商信息。这一步骤不仅确保了数据的准确性和完整性，还为后续的数据转换与写入奠定了坚实基础。在实际操作中，灵活运用元数据配置和请求参数，将极大提升我们的工作效率和数据质量。 打通企业微信数据接口

利用轻易云数据集成平台进行ETL转换并写入钉钉API接口

在数据集成生命周期的第二步，我们将重点探讨如何利用轻易云数据集成平台，将已经从源平台（如金蝶）获取的数据进行ETL转换，并最终写入目标平台（钉钉）的API接口。以下是具体的技术实现过程。

1. 配置元数据

首先，我们需要配置元数据，以便将源平台的数据映射到目标平台所需的格式。根据提供的元数据配置，钉钉API接口需要以下字段：

  • process_code：钉钉表单ID
  • originator_user_id：发起人userid
  • dept_id：发起人所属部门ID
  • form_component_values：表单控件，其中包含供应商名称和供应商编码

以下是元数据配置的JSON结构：

{
  "api": "topapi/processinstance/create",
  "effect": "EXECUTE",
  "method": "POST",
  "idCheck": true,
  "request": [
    {
      "field": "process_code",
      "label": "钉钉表单id",
      "type": "string",
      "describe": "process_code在审批流程编辑页面的URL网址中获取。",
      "value": "PROC-BFC58CBE-6884-4C1A-94B9-336BB6C118A0"
    },
    {
      "field": "originator_user_id",
      "label": "发起人userid",
      "type": "string",
      "describe": "审批实例发起人的userid。",
      "value": "0911101641848981"
    },
    {
      "field": "dept_id",
      "label": "发起人所属部门id",
      "type": "string",
      "describe": "发起人所在的部门，如果发起人属于根部门，传-1。",
      "value": "-1"
    },
    {
      "field": "form_component_values",
      "label": "表单控件",
      "type": "object",
      ...
    }
  ]
}

2. 数据清洗与转换

在ETL过程中，首先需要对从金蝶获取的数据进行清洗和转换。假设我们从金蝶获取了以下供应商信息：

{
  "_metadata_":{
    ...
  },
  "_data_":[
    {
      "_FName_":"供应商A公司",
      "_FNumber_":"SUP001"
    },
    ...
  ]
}

我们需要将这些信息映射到钉钉API所需的格式。通过轻易云数据集成平台，我们可以使用内置的映射工具来完成这个过程。

例如，可以使用如下代码片段进行映射：

const sourceData = getSourceData(); // 获取源数据
const transformedData = sourceData.map(item => ({
  process_code: 'PROC-BFC58CBE-6884-4C1A-94B9-336BB6C118A0',
  originator_user_id: '0911101641848981',
  dept_id: '-1',
  form_component_values: [
    {
      name: '供应商名称',
      value: item._FName_
    },
    {
      name: '供应商编码',
      value: item._FNumber_
    }
  ]
}));

3. 数据写入目标平台

完成数据清洗和转换后，接下来就是将处理后的数据写入到目标平台——钉钉。根据元数据配置，我们需要调用topapi/processinstance/create API接口，并使用POST方法提交请求。

以下是一个示例请求代码：

const axios = require('axios');

async function writeToDingTalk(transformedData) {
  const apiUrl = 'https://oapi.dingtalk.com/topapi/processinstance/create';

  for (const data of transformedData) {
    try {
      const response = await axios.post(apiUrl, data, {
        headers: {
          'Content-Type': 'application/json',
          'Authorization': `Bearer ${accessToken}` // 替换为实际的access token
        }
      });

      if (response.data.errcode === 0) {
        console.log('Data written successfully:', response.data);
      } else {
        console.error('Error writing data:', response.data);
      }

    } catch (error) {
      console.error('HTTP request failed:', error);
    }
  }
}

writeToDingTalk(transformedData);

以上代码展示了如何利用axios库发送HTTP POST请求，将处理后的供应商信息写入到钉钉API接口中。在实际应用中，需要确保正确处理错误和异常情况，以保证数据写入的可靠性。

通过上述步骤，我们成功地实现了从金蝶到钉钉的数据集成，包括数据清洗、转换和最终写入目标平台。这一过程充分体现了轻易云数据集成平台在异构系统间无缝对接和高效管理方面的优势。 如何开发钉钉API接口

版权声明

该文章《金蝶云星空与钉钉API集成的详细指南》为原创内容，版权归 广东轻亿云软件科技有限公司 所有。 未经本公司书面授权，严禁转载、引用、复制或建立镜像等行为。 若需转载或引用本文内容，请联系本公司获取授权，并在显著位置注明作者姓名、文章出处（包括原文链接）等信息。

百威BEES系统与经销商ERP对接
更多系统对接方案