旗舰-金蝶-供应商——>旺店通-供应商系统对接集成案例

在本技术案例中，我们将分享如何通过轻易云数据集成平台，实现从金蝶云星空到旺店通·旗舰奇门的高效数据集成。项目期间，我们面对一系列技术挑战，包括确保数据不漏单、处理接口分页和限流问题，以及在不同系统之间实现定制化的数据映射与格式转换。

为了获取金蝶云星空中的订单数据，我们使用了其提供的executeBillQuery API。在此过程中，特别关注了接口调用频率和分页机制，以确保大批量数据能够被稳定、高效地抓取。为了解决大量数据写入旺店通·旗舰奇门的问题，我们利用其wdt.setting.purchaseprovider.push API执行大规模并发写入，并且针对可能出现的异常情况设计了重试机制及告警系统，实时监控任务状态。

高效的数据写入与实时监控

1. 支持高吞吐量的数据写入能力：得益于平台的架构优势，使得大量订单信息能够快速、安全地传输至目标系统。
2. 集中式监控与告警通知：通过提供可视化工具和自动化告警功能，实现对所有集成任务进行全方位实时跟踪。一旦发生任何异常，如连接超时或接口响应错误，即刻触发预设动作，将影响降到最低。

自定义转换逻辑与API资产管理

在具体实现过程中，还涉及到了复杂的数据转换要求。由于金蝶云星空和旺店通·旗舰奇门之间存在显著差异，需要自定义数据转换逻辑以适应两者不同的数据结构。此外，通过统一视图掌握API资产使用状况，有助于企业精细化管理资源、优化配置，提高整体利用效率。

这些先进特性不仅提高了我们处理同步任务的可靠性，也确保每一个环节都具备高度透明度。从而使整个解决方案既灵活又高效，满足业务需求，为后续操作铺平道路。

这一切无疑展示了现代数据集成方案的重要作用和优越能力。在后续部分，我将进一步详细介绍具体实施步骤及各阶段遇到的问题以及解决方法，希望能为读者提供有价值参考。

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

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

接口配置与请求参数

首先，我们需要配置元数据，以便正确调用金蝶云星空的executeBillQuery接口。以下是关键的元数据配置：

{
  "api": "executeBillQuery",
  "effect": "QUERY",
  "method": "POST",
  "number": "FNumber",
  "id": "FSupplierId",
  "name": "FNumber",
  "idCheck": true,
  "request": [
    {"field":"FSupplierId","label":"FSupplierId","type":"string","describe":"FSupplierId","value":"FSupplierId"},
    {"field":"FNumber","label":"编码","type":"string","describe":"编码","value":"FNumber"},
    {"field":"FName","label":"名称","type":"string","describe":"名称","value":"FName"},
    {"field":"FCreateOrgId_FNumber","label":"创建组织","type":"string","describe":"创建组织","value":"FCreateOrgId.FNumber"},
    {"field":"FUseOrgId_FNumber","label":"使用组织","type":"string","describe":"使用组织","value":"FUseOrgId.FNumber"},
    {"field":"FDescription","label":"描述","type":"string","describe":"描述","value":"FDescription"},
    {"field":"FShortName","label":"简称","type":"string","describe":"简称","value":"FShortName"},
    {"field":"FMinPOValue","label":"最小订单量","type":"string","describe":"最小订单量","value":"FMinPOValue"},
    {"field":"FCountry_FNumber","label":"国家","type":"string","describe":"国家","value":"FCountry.FNumber"},
    {"field":...},
    ...
  ],
  "otherRequest": [
    {"field": "Limit", "label": "{PAGINATION_PAGE_SIZE}", "type": "string", "describe": "金蝶的查询分页参数", "value": "{PAGINATION_PAGE_SIZE}"},
    {"field": "StartRow", "label": "开始行索引", "type": "string", "describe": "金蝶的查询分页参数", "value": "{PAGINATION_START_ROW}"},
    {"field": ...},
    ...
  ],
  "autoFillResponse": true
}

请求示例

根据上述元数据配置，我们可以构建一个具体的请求示例：

{
  "FormId": "BD_Supplier",
  "FieldKeys": ["FSupplierId", "FNumber", ...],
  "FilterString": "(FAuditDate >= '2023-01-01') AND (FUseOrgId.FNumber = '101')",
  ...
}

该请求将会返回符合条件的供应商信息，包括供应商ID、编码、名称等字段。

数据清洗与加工

获取到原始数据后，需要对其进行清洗和初步加工，以便后续的数据转换和写入。以下是一些常见的数据清洗操作：

1. 字段映射：将原始字段名映射为目标系统所需的字段名。例如，将FSupplierId映射为目标系统中的SupplierID。
2. 数据格式转换：将日期格式从YYYY-MM-DD转换为目标系统所需的格式。
3. 过滤无效数据：移除不符合业务逻辑的数据，例如供应商状态为“停用”的记录。

实际案例

假设我们需要将金蝶云星空中的供应商信息同步到旺店通系统，首先通过上述接口获取原始数据，然后进行如下处理：

1. 字段映射：

   {
    "SupplierID": "{{FSupplierId}}",
    ...
   }

2. 格式转换：

   {
    ...
    "EffectiveDate": "{{FStartDate|date('YYYY-MM-DD')}}"
   }

3. 过滤无效数据：

   {
    ...
    if (data.FBusinessStatus !== 'Active') {
      return null;
    }
   }

通过这些步骤，我们可以确保从金蝶云星空获取的数据能够顺利地集成到旺店通系统中，实现不同系统间的数据无缝对接。

以上内容详细介绍了如何利用轻易云数据集成平台调用金蝶云星空接口获取并加工数据，为后续的数据转换和写入打下坚实基础。

轻易云数据集成平台生命周期第二步：ETL转换与数据写入

在数据集成过程中，ETL（Extract, Transform, Load）转换是一个至关重要的环节。本文将深入探讨如何使用轻易云数据集成平台将已经集成的源平台数据进行ETL转换，最终写入目标平台——旺店通·旗舰奇门API接口。

数据请求与清洗

在数据请求与清洗阶段，我们从源系统（如金蝶、供应商系统）获取原始数据。这些原始数据通常是未经处理的，需要进行清洗和标准化，以确保其质量和一致性。这一步虽然重要，但本文重点将放在第二阶段，即数据转换与写入。

数据转换与写入

在这一阶段，我们需要将清洗后的数据进行格式转换，使其符合目标平台旺店通·旗舰奇门API接口的要求。以下是具体的技术细节和实现步骤。

API接口配置

根据提供的元数据配置，我们需要调用wdt.setting.purchaseprovider.push API接口，使用POST方法将供应商信息推送到旺店通。以下是具体的元数据配置：

{
  "api": "wdt.setting.purchaseprovider.push",
  "effect": "EXECUTE",
  "method": "POST",
  "idCheck": true,
  "request": [
    {
      "field": "provider_no",
      "label": "provider_no",
      "type": "string",
      "describe": "111",
      "value": "{FNumber}"
    },
    {
      "field": "provider_name",
      "label": "provider_name",
      "type": "string",
      "describe": "111",
      "value": "{FName}"
    }
  ],
  "otherRequest": [
    {
      "field": "objectKey",
      "label": "objectKey",
      "type": "string",
      "describe": "111",
      "value": "provider"
    }
  ]
}

数据映射

在进行ETL转换时，我们需要将源系统的数据字段映射到目标API接口所需的字段。例如：

• FNumber 映射到 provider_no
• FName 映射到 provider_name

这些映射关系在元数据配置中已经明确指出，因此我们只需按照配置进行相应的数据转换。

数据转换示例

假设我们从源系统获取了如下供应商信息：

{
  "FNumber": "SUP12345",
  "FName": "供应商A"
}

根据元数据配置，我们需要将其转换为符合旺店通API接口要求的格式：

{
  "provider_no": "{FNumber}",
  "provider_name": "{FName}",
  objectKey: 'provider'
}

经过替换后的实际请求体应为：

{
  'provider_no': 'SUP12345',
  'provider_name': '供应商A',
   objectKey: 'provider'
}

API调用

完成数据转换后，我们可以通过HTTP POST方法调用wdt.setting.purchaseprovider.push API接口，将处理后的数据推送到旺店通。以下是一个简单的Python代码示例，展示如何实现这一过程：

import requests
import json

# 定义API URL和请求头
url = 'https://api.wangdian.cn/openapi2/wdt.setting.purchaseprovider.push'
headers = {'Content-Type': 'application/json'}

# 构建请求体
payload = {
    'provider_no': 'SUP12345',
    'provider_name': '供应商A',
    objectKey: 'provider'
}

# 发起POST请求
response = requests.post(url, headers=headers, data=json.dumps(payload))

# 检查响应状态
if response.status_code == 200:
    print('Data pushed successfully:', response.json())
else:
    print('Failed to push data:', response.status_code, response.text)

通过上述步骤，我们实现了从源系统到目标平台的数据ETL转换和写入。在实际应用中，可以根据业务需求对代码进行进一步优化和扩展。

实时监控与反馈

轻易云数据集成平台提供了全透明可视化的操作界面，可以实时监控整个ETL过程中的每个环节，包括数据流动和处理状态。这极大地提升了业务透明度和效率，使得问题能够被及时发现并解决。

通过以上技术案例，我们详细介绍了如何利用轻易云数据集成平台完成ETL转换，并成功将处理后的数据写入目标平台旺店通·旗舰奇门API接口。这一过程不仅提高了数据集成效率，还确保了各系统间的数据一致性和可靠性。