金蝶云星空API数据转换与写入的实现方法

2022-04-19 18:27:26
轻易云集成顾问-谢楷斌

每刻费用类型数据集成到金蝶云星空案例分享

在本次技术案例中，我们将探讨如何使用轻易云数据集成平台实现每刻（My Expense）的费用类型数据与金蝶云星空的无缝对接。具体方案名称为“每刻费用类型->金蝶费用项目”。我们将深入讨论API接口调用、分页处理、限流机制以及异常处理等关键技术细节。

首先，我们需要从每刻平台定时可靠地抓取相关费用类别的数据。通过调用其提供的公开API: /api/openapi/expense/type/search，可以确保获取完整且最新的数据。在这过程中，需要特别注意接口所设定的分页和速率限制，为此我们设计了适应性强的批量抓取策略，以避免因超过限流阈值导致请求失败。

为了保证大量数据能够快速、安全地写入到金蝶云星空系统，我们使用其相应的数据写入API batchSave进行操作。这一过程不仅要求高效的数据传输，还涉及两端数据格式不一致的问题。因此，在实际应用中需要进行精确的数据映射和转换，以便满足目标系统的需求。

针对可能出现的异常情况，例如网络故障或接口响应超时，本方案还引入了健全的错误重试机制，并采用实时监控日志记录以确保问题能迅速定位及解决。此外，通过可视化界面实时查看数据流动状态，可以有效提升业务透明度和效率。

整体来看，该方案通过全面考虑多种因素，实现了稳定、高效且精准的数据对接流程，使得两个异构系统间的信息交换变得更加顺畅。本篇文章将在后续部分详细讲解各个具体步骤及实现细节，包括代码示例及运行结果分析。用友与CRM系统接口开发配置

调用每刻接口获取并加工数据的技术案例

在数据集成过程中，调用源系统接口是至关重要的一步。本文将深入探讨如何通过轻易云数据集成平台调用每刻接口/api/openapi/expense/type/search，并对获取的数据进行加工处理。

接口调用配置

首先，我们需要配置元数据，以便正确调用每刻的API接口。以下是元数据配置的具体内容：

{
  "api": "/api/openapi/expense/type/search",
  "method": "POST",
  "number": "name",
  "id": "bizCode",
  "idCheck": true,
  "request": [
    {"field": "bizCodes", "label": "完整费用类型编码", "type": "array"},
    {"field": "keyword", "label": "按名称或编码模糊搜索", "type": "string", "value":"%"}
  ]
}

请求参数详解

API路径：/api/openapi/expense/type/search
- 此路径用于访问每刻系统中的费用类型数据。
请求方法：POST
- 使用POST方法发送请求，确保能够传递复杂的查询条件。
字段映射：
- number: 对应费用类型的名称字段。
- id: 对应费用类型的业务编码字段。
- idCheck: 设置为true，表示需要对ID进行校验。
请求参数：
- bizCodes: 完整费用类型编码，类型为数组，用于指定特定的费用类型。
- keyword: 按名称或编码模糊搜索，默认值为%，表示匹配所有记录。

数据请求与清洗

在实际操作中，我们需要构建一个POST请求体，并根据需求传递适当的参数。例如，如果我们希望获取所有费用类型，可以使用如下请求体：

{
  "bizCodes": [],
  "keyword": "%"
}

发送该请求后，每刻系统会返回符合条件的费用类型列表。接下来，我们需要对返回的数据进行清洗和转换，以便后续处理。

数据转换与写入

假设我们从每刻系统获取到如下数据：

[
  {
    "bizCode": "EXP001",
    "name": "差旅费"
  },
  {
    "bizCode": "EXP002",
    "name": "办公费"
  }
]

我们需要将这些数据转换为金蝶系统所需的格式。假设金蝶系统要求的数据格式如下：

[
  {
    "expenseCode": "",
    "expenseName": ""
  }
]

我们可以通过轻易云平台提供的数据转换功能，将每刻返回的数据映射到金蝶所需格式。例如：

[
  {
    "expenseCode": "{{bizCode}}",
    "expenseName": "{{name}}"
  }
]

这样，通过简单的映射规则，我们就能实现从每刻到金蝶的数据无缝对接。

实时监控与调试

在整个过程中，轻易云平台提供了全透明可视化的操作界面，使得每个环节都清晰可见。通过实时监控功能，我们可以随时查看数据流动和处理状态，确保集成过程顺利进行。如果出现问题，可以利用平台提供的调试工具快速定位并解决问题。

通过上述步骤，我们成功实现了从每刻系统获取费用类型数据，并将其转换为金蝶系统所需格式。这一过程不仅展示了轻易云平台强大的数据集成功能，也体现了其在异构系统间无缝对接方面的优势。用友与MES系统接口开发配置

数据转换与写入金蝶云星空API接口的技术实现

在数据集成生命周期的第二步，我们需要将已经集成的源平台数据进行ETL转换，并转为目标平台金蝶云星空API接口所能够接收的格式，最终写入目标平台。本文将详细探讨如何利用元数据配置，实现这一过程。

1. 元数据配置解析

元数据配置是实现数据转换和写入的关键。以下是我们需要关注的元数据配置内容：

{
  "api": "batchSave",
  "method": "POST",
  "idCheck": true,
  "operation": {
    "rowsKey": "array",
    "rows": 1,
    "method": "batchArraySave"
  },
  "request": [
    {
      "field": "FName",
      "label": "名称",
      "type": "string",
      "value": "{name}"
    },
    {
      "field": "FNumber",
      "label": "编码",
      "type": "string",
      "value": "{bizCode}"
    },
    {
      "field": "FGroup",
      "label": "分组",
      "type": "string",
      "parser": {
        "name": "ConvertObjectParser",
        "params": "FNumber"
      },
      "value": "{categoryName}",
      "mapping": "62b30a9059fe844c7d2bc704",
      "mappingDirection": "positive"
    },
    {
      "field": "FRATE",
      ...

2. 数据请求与清洗

在这个阶段，我们需要从源系统（如每刻费用类型）中提取相关数据，并进行必要的数据清洗和预处理。假设我们提取到的数据如下：

{
  "_id":"1234567890abcdefg",
  "_name":"差旅费",
  "_bizCode":"EXP001",
  "_categoryName":"业务费用"
}

3. 数据转换

根据元数据配置，我们需要将上述提取到的数据转换为金蝶云星空API接口能够接收的格式。具体步骤如下：

字段映射：
- FName 对应 {name}，即 _name 字段。
- FNumber 对应 {bizCode}，即 _bizCode 字段。
- FGroup 对应 {categoryName}，即 _categoryName 字段。
字段解析：
- FGroup 字段使用 ConvertObjectParser 转换器，将 _categoryName 转换为相应的 FNumber。
固定值设置：
- FRATE 设置为固定值 "SL04_SYS"。
其他请求参数：
- FormId 设置为 "BD_Expense"。
- Operation 设置为 "BatchSave"。
- IsAutoSubmitAndAudit 设置为 true。
- IsVerifyBaseDataField 设置为 false。

4. 构建请求体

根据上述步骤，我们构建出符合金蝶云星空API接口要求的请求体：

{
  ...
}

5. API调用

通过HTTP POST方法，将构建好的请求体发送到金蝶云星空API接口。示例如下：

import requests
import json

url = 'https://api.kingdee.com/k3cloud/BatchSave'
headers = {'Content-Type': 'application/json'}
data = {
  ...
}

response = requests.post(url, headers=headers, data=json.dumps(data))
if response.status_code == 200:
    print("Data successfully written to Kingdee Cloud.")
else:
    print("Failed to write data:", response.text)

通过上述步骤，我们实现了从源平台到目标平台的数据ETL转换与写入。在实际操作中，需要根据具体业务需求对元数据配置进行调整，以确保数据准确无误地传输和存储。用友与SCM系统接口开发配置