解析钉钉到金蝶云数据集成的技术细节和实践

  • 轻易云集成顾问-贺强

案例分享：钉钉数据集成到金蝶云星空

在本案例中，我们探讨了如何通过轻易云数据集成平台实现钉钉与金蝶云星空系统的无缝对接，具体解决方案为“其他业务付款单钉钉=>付款单金蝶”。这里将重点介绍API接口的调用及相应技术细节。

首先，为确保从钉钉获取的数据准确无误且不漏单，我们利用了topapi/processinstance/get API进行定时、可靠的数据抓取。此API允许我们获取特定业务流程实例的信息，从而可以精确地提取所需的付款单数据。在实际应用中，通过设置适当的时间间隔和重试机制，可以有效处理接口分页和限流问题，提升数据抓取效率。

接收到来自钉钉的数据后，下一个关键步骤是将其快速且高效地写入到金蝶云星空系统。这一步骤依赖于使用BatchSave API，该接口支持批量保存操作，使得大量数据能够迅速写入到金蝶云星空，极大提高了整体处理速度。此外，自定义的数据转换逻辑也被灵活运用，以适配不同系统之间的数据结构差异，实现平滑过渡和完美集成。

为确保整个数据处理过程透明并可监控，我们利用集中化监控与告警系统实时跟踪各个任务状态，并及时发现与解决潜在异常情况。这种全面监控不仅保证了集成过程中的高质量和稳定性，还有效增强了企业对API资产使用情况的掌握能力，有助于优化资源配置。

在以下章节中，将进一步详解相关代码实现、详细步骤以及各种边界条件下的问题处理方法，包括但不限于：错误重试机制、分页策略等。 钉钉与CRM系统接口开发配置

调用钉钉接口topapi/processinstance/get获取并加工数据

在数据集成的生命周期中，调用源系统接口获取数据是至关重要的一步。本文将详细探讨如何通过轻易云数据集成平台调用钉钉接口topapi/processinstance/get来获取并加工数据，以实现其他业务付款单到付款单金蝶的集成。

接口调用配置

首先，我们需要配置元数据以便正确调用钉钉的API接口。以下是配置元数据的详细说明：

{
  "api": "topapi/processinstance/get",
  "effect": "QUERY",
  "method": "POST",
  "number": "name",
  "id": "id",
  "idCheck": true,
  "autoFillResponse": true,
  "condition": [
    [
      {
        "field": "付款类型",
        "logic": "in",
        "value": "报关货物税金,店铺充值"
      }
    ]
  ]
}
  • api: 指定要调用的API接口为topapi/processinstance/get。
  • effect: 设置为QUERY，表示这是一个查询操作。
  • method: 使用HTTP POST方法进行请求。
  • number: 指定字段name作为唯一标识符。
  • id: 指定字段id用于唯一标识记录。
  • idCheck: 设置为true，表示在处理过程中需要检查ID的唯一性。
  • autoFillResponse: 设置为true，自动填充响应结果。
  • condition: 定义了查询条件，这里指定了“付款类型”字段的值必须是“报关货物税金”或“店铺充值”。

数据请求与清洗

在配置好元数据后，我们可以开始进行数据请求和清洗。通过轻易云平台，我们可以发送POST请求到钉钉API，并根据条件过滤出所需的数据。

import requests

url = 'https://oapi.dingtalk.com/topapi/processinstance/get'
headers = {
    'Content-Type': 'application/json',
    'Authorization': 'Bearer YOUR_ACCESS_TOKEN'
}
payload = {
    'process_instance_id': 'YOUR_PROCESS_INSTANCE_ID'
}

response = requests.post(url, headers=headers, json=payload)
data = response.json()

# 清洗数据
filtered_data = []
for item in data['result']['form_component_values']:
    if item['name'] == '付款类型' and item['value'] in ['报关货物税金', '店铺充值']:
        filtered_data.append(item)

上述代码展示了如何发送POST请求到钉钉API，并根据“付款类型”字段过滤出符合条件的数据。

数据转换与写入

获取并清洗完数据后，我们需要将其转换为目标系统所需的格式，并写入到金蝶系统中。这一步通常涉及到字段映射和格式转换。

# 转换数据格式
transformed_data = []
for item in filtered_data:
    transformed_item = {
        'payment_type': item['value'],
        'amount': item.get('amount', 0),
        # 添加其他必要的字段映射
    }
    transformed_data.append(transformed_item)

# 写入金蝶系统
kingdee_url = 'https://your.kingdee.api/endpoint'
kingdee_headers = {
    'Content-Type': 'application/json',
    'Authorization': 'Bearer YOUR_KINGDEE_ACCESS_TOKEN'
}

for record in transformed_data:
    kingdee_response = requests.post(kingdee_url, headers=kingdee_headers, json=record)
    if kingdee_response.status_code != 200:
        print(f"Failed to write record: {record}")

以上代码展示了如何将清洗后的数据转换为目标系统所需的格式，并通过POST请求写入到金蝶系统中。

总结

通过轻易云数据集成平台，我们能够高效地调用钉钉接口获取所需的数据，并经过清洗、转换后无缝对接到金蝶系统。这一过程不仅提高了业务透明度和效率，还确保了数据处理的准确性和一致性。 泛微OA与ERP系统接口开发配置

使用轻易云数据集成平台实现金蝶云星空API接口的数据ETL转换与写入

在数据集成过程中，将源平台的数据转换为目标平台能够接收的格式是至关重要的一步。本文将详细介绍如何使用轻易云数据集成平台将钉钉的其他业务付款单数据转换为金蝶云星空API接口所需的格式，并最终写入目标平台。

API接口配置与元数据解析

我们使用的API接口为BatchSave，通过POST方法进行数据提交。以下是具体的元数据配置：

{
  "api": "BatchSave",
  "effect": "EXECUTE",
  "method": "POST",
  "idCheck": true,
  "request": [
    {
      "field": "FBillTypeID",
      "label": "单据类型",
      "type": "string",
      "describe": "111",
      "value": "FKDLX02_SYS",
      "parser": {
        "name": "ConvertObjectParser",
        "params": "FNumber"
      }
    },
    {
      ...
    }
  ],
  ...
}

数据字段解析与转换

  1. 单据类型（FBillTypeID）：

    • 类型：字符串
    • 描述：单据类型
    • 固定值：FKDLX02_SYS
    • 转换器：ConvertObjectParser，参数为FNumber

  2. 单据编号（FBillNo）：

    • 类型：字符串
    • 描述：单据编号
    • 动态值：{business_id}

  3. 结算组织、采购组织、付款组织（FSETTLEORGID, FPURCHASEORGID, FPAYORGID）：

    • 类型：字符串
    • 动态值：{{付款组织}}
    • 转换器：ConvertObjectParser，参数为FNumber
    • 映射目标：657989a425298e29af25fb19

  4. 创建人（FCreatorId）：

    • 类型：字符串
    • 动态值：通过SQL查询获取，如 _findCollection find FUserID from 5b6d7573-c41f-30aa-9aa1-466182356a9f where FName={{办理人}}
    • 转换器：ConvertObjectParser，参数为FUserID

  5. 币别、结算币别（FCURRENCYID, FSETTLECUR）：

    • 类型：字符串
    • 动态值：{{币别}}
    • 转换器：ConvertObjectParser，参数为 FNumber
    • 映射目标： 657ae40425298e29af25fdc3

  6. 采购部门、往来单位、收款单位、部门（FPURCHASEDEPTID, FCONTACTUNIT, FRECTUNIT, FDepartment）：

    • 类型：字符串
    • 动态值分别为 {{K3部门编码}}, {{K3供应商编码}}, {{K3供应商编码}}, {{K3部门编码}}
    • 转换器均为 ConvertObjectParser, 参数为 FNumber

  7. 其他字段配置： 包括事业部、付款类型、钉钉审批编号等字段，均根据实际业务需求进行动态赋值和转换。

表体数据处理

表体数据包含多个子字段，如结算方式、应付金额等：

{
  "field": "FPAYBILLENTRY",
  ...
  "children": [
    {
      ...
    },
    {
      ...
    }
  ]
}

其中每个子字段都需要进行相应的解析和转换。例如：

  • 结算方式（FSETTLETYPEID）： 固定值为 JSFS04_SYS

  • 表体-应付金额（FPAYTOTALAMOUNTFOR）： 动态值为 {{表格.金额}}

  • 付款用途（FPURPOSEID）： 根据用途字段的不同值进行条件判断和赋值。

操作配置

操作配置部分包括批量保存方法及相关参数：

{
  ...
  "operation": {
    "method": "batchArraySave",
    ...
  }
}

该部分定义了如何批量保存数组数据，并指定了关键字段。

数据提交与验证

在完成所有字段的解析与转换后，通过POST方法将处理后的数据提交至金蝶云星空API接口。为了确保数据的有效性，可以设置是否验证基础资料有效性等参数。

{
  ...
  "IsVerifyBaseDataField": false,
  ...
}

通过以上步骤，我们实现了从钉钉到金蝶云星空的数据ETL转换与写入。每个环节都需要精确配置和验证，以确保最终的数据准确无误地写入目标系统。 电商OMS与WMS系统接口开发配置

版权声明

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

金蝶云星辰与旺店通无缝集成
更多系统对接方案