供应商系统对接集成案例：旺店通·企业奇门数据集成到金蝶云星空

在面对复杂多变的业务环境时，如何通过优化数据处理来提升整体效率是每个企业所关心的问题。本次技术分享将聚焦于一个实际运行的解决方案：将旺店通·企业奇门中的采购供应商数据无缝高效地集成至金蝶云星空，通过调用API接口实现自动化、实时的数据传输和处理。

首先，我们选用了wdt.purchase.provider.query API作为获取旺店通·企业奇门数据的入口，该接口支持分页查询，确保海量数据能逐批稳妥获取。为了应对可能出现的限流问题，我们设置了智能重试机制，这样即使碰到瞬间高并发情况，也可从容应对。

接下来，在写入端，我们利用金蝶云星空提供的batchSave API进行操作，实现了大规模数据的快速存储。为确保写入过程中的稳定性和准确率，特别设计了一套异常处理与错误重试机制。一旦在批量写入过程中发生错误，可及时捕捉并进行精确定位，同时启动相应重试策略以继续完成未竟事务，而无需人工干预。

在具体实施过程中，不同平台的数据格式差异也是一大挑战。因此，对于从旺店通·企业奇门抓取到的数据，在进入金蝶云星空前必须经过定制化映射转换。这一步骤不仅涉及字段名称及类型匹配，还包含必要的数据清洗操作，以保证最终录入系统的数据始终维持一致性、高质量标准。

值得一提的是，为进一步保障全过程透明度与易追溯性，全程开启了实时监控及日志记录功能。从初步抓取、处理中间状态，到最终写入确认，每一步都具备详细日志记录，这不仅有利于后续排查问题，更为连续改进提供了宝贵依据。

调用旺店通·企业奇门接口wdt.purchase.provider.query获取并加工数据

在数据集成的生命周期中，调用源系统接口是至关重要的一步。本文将深入探讨如何通过轻易云数据集成平台调用旺店通·企业奇门接口wdt.purchase.provider.query，以获取并加工供应商数据。

接口概述

接口wdt.purchase.provider.query用于查询供应商信息，支持POST请求。该接口允许用户通过供应商编号或名称来获取相关数据，并提供了丰富的返回字段选项。

元数据配置解析

根据提供的元数据配置，我们可以看到以下关键参数：

• api: wdt.purchase.provider.query
• effect: QUERY
• method: POST
• number: provider_no
• id: provider_id
• name: provider_no
• idCheck: true

请求参数包括：

• column: 返回字段，多个字段用逗号隔开。
• provider_no: 供应商编号，用于唯一标识供应商。
• provider_name: 供应商名称。

分页参数：

• page_size: 每页返回的数据条数，默认40。
• page_no: 页号，默认从0页开始。

实际应用案例

假设我们需要获取某个特定供应商的详细信息，并且只需要返回部分字段，例如供应商编号、名称、联系方式等。以下是具体的实现步骤：

1. 配置请求参数

   首先，我们需要配置请求参数。假设我们要查询编号为SUP12345的供应商，并且只需要返回其编号、名称和联系电话，可以设置如下参数：

   {
    "column": "provider_no,provider_name,telno",
    "provider_no": "SUP12345",
    "page_size": "10",
    "page_no": "0"
   }

2. 发送请求

   使用轻易云数据集成平台发送POST请求到wdt.purchase.provider.query接口。平台会自动处理分页逻辑，并确保所有数据都能被完整获取。

3. 处理响应

   响应结果将包含我们指定的字段。由于元数据配置中启用了autoFillResponse，平台会自动填充响应内容，无需额外处理。例如：

   {
    "data": [
      {
        "provider_no": "SUP12345",
        "provider_name": "ABC Supplies",
        "telno": "1234567890"
      }
    ],
    "total_count": 1,
    "page_size": 10,
    "page_no": 0
   }

4. 数据清洗与转换

   获取到原始数据后，我们可以根据业务需求进行清洗和转换。例如，将电话号码格式化或将供应商名称统一大小写等操作。这些操作可以通过轻易云平台内置的数据处理工具完成。

5. 写入目标系统

   最后，将处理后的数据写入目标系统，如ERP或数据库。这一步通常涉及到调用目标系统的API或使用数据库连接器进行批量写入。

注意事项

在实际操作中，需要注意以下几点：

• 确保请求参数正确无误，特别是分页参数，以避免遗漏数据。
• 根据业务需求选择合适的返回字段，减少不必要的数据传输，提高效率。
• 在进行大批量数据处理时，注意接口的限流策略，以防止触发API限制。

通过上述步骤，我们可以高效地调用旺店通·企业奇门接口获取并加工供应商数据，为后续的数据集成和分析打下坚实基础。

使用轻易云数据集成平台将数据转换并写入金蝶云星空API接口

在轻易云数据集成平台的生命周期中，第二步是将已经集成的源平台数据进行ETL（Extract, Transform, Load）转换，并转为目标平台能够接收的格式，最终写入目标平台。本文将详细探讨如何通过轻易云数据集成平台，将供应商数据转换并写入金蝶云星空API接口。

API接口配置与元数据解析

在本案例中，我们需要将供应商信息写入金蝶云星空系统。根据提供的元数据配置，使用batchSave接口进行批量保存操作。

API接口元数据配置解析：

{
  "api": "batchSave",
  "effect": "EXECUTE",
  "method": "POST",
  "idCheck": true,
  "request": [
    {"field": "FNumber", "label": "编码", "type": "string", "describe": "编码", "value": "{provider_no}"},
    {"field": "FName", "label": "名称", "type": "string", "describe": "名称", "value": "{provider_name}"},
    {"field": "FUseOrgId", "label": "使用组织", "type": "string", "describe": "使用组织", 
        "parser":{"name":"ConvertObjectParser","params":"FNumber"}, 
        "value":"100"},
    {"field": "FCreateOrgId", 
        "label": "创建组织", 
        "type": "string", 
        "describe":"创建组织",
        "parser":{"name":"ConvertObjectParser","params":"FNumber"}, 
        "value":"100"}
  ],
  ...
}

1. API基本信息：

   • api: 接口名称，batchSave。
   • effect: 执行效果，EXECUTE。
   • method: 请求方法，POST。
   • idCheck: 是否检查ID，设置为true。

2. 请求字段：

   • FNumber: 编码，对应供应商编号 {provider_no}。
   • FName: 名称，对应供应商名称 {provider_name}。
   • FUseOrgId: 使用组织，固定值 100，通过 ConvertObjectParser 转换为目标格式。
   • FCreateOrgId: 创建组织，同样固定值 100，通过相同的解析器转换。

3. 其他请求参数：

   • FormId: 业务对象表单ID，如 BD_Supplier。
   • Operation: 执行的操作，如 batchSave。
   • IsVerifyBaseDataField: 验证基础资料有效性，可选参数，默认为 false。
   • IsAutoSubmitAndAudit: 提交并审核，设置为 true。

数据转换与写入过程

1. 提取（Extract）： 从源系统提取供应商数据。假设我们从一个数据库或另一个系统中获取以下结构的数据：

   [
    {
      "provider_no": "SUP001",
      "provider_name": "供应商A"
    },
    {
      "provider_no": "SUP002",
      "provider_name": "供应商B"
    }
   ]

2. 转换（Transform）： 根据元数据配置，将提取的数据转换为符合金蝶云星空API要求的格式：

   {
    ...
    // API基本信息和其他请求参数略
    ...
    request: [
      {
        FNumber: 'SUP001',
        FName: '供应商A',
        FUseOrgId: '100',
        FCreateOrgId: '100'
      },
      {
        FNumber: 'SUP002',
        FName: '供应商B',
        FUseOrgId: '100',
        FCreateOrgId: '100'
      }
    ]
   }

3. 加载（Load）： 将转换后的数据通过HTTP POST请求发送到金蝶云星空的批量保存接口：

const axios = require('axios');

const data = {
  FormId: 'BD_Supplier',
  Operation: 'batchSave',
  IsVerifyBaseDataField: false,
  IsAutoSubmitAndAudit: true,
  request: [
    {
      FNumber: 'SUP001',
      FName: '供应商A',
      FUseOrgId: '100',
      FCreateOrgId: '100'
    },
    {
      FNumber: 'SUP002',
      FName: '供应商B',
      FUseOrgId: '100',
      FCreateOrgId: '100'
    }
  ]
};

axios.post('https://api.kingdee.com/batchSave', data)
  .then(response => {
    console.log('Data saved successfully:', response.data);
  })
  .catch(error => {
    console.error('Error saving data:', error);
  });

注意事项

• 字段映射与验证： 确保所有字段正确映射，并且在实际应用中可能需要进行更多的数据验证和清洗工作，以确保数据质量。
• 错误处理： 在生产环境中，应当增加错误处理逻辑，以应对可能出现的网络问题或API调用失败等情况。

通过以上步骤，我们实现了从源系统提取、转换并加载到金蝶云星空API接口的完整过程。这种方法不仅提高了数据集成效率，还确保了各系统间的数据一致性和准确性。