### 金蝶云星空数据集成到旺店通·企业奇门：供应商对接案例分享
在推动企业数字化转型过程中，系统与平台之间的数据集成是实现业务高效运作的关键。本文将详细介绍如何通过轻易云数据集成平台，将金蝶云星空的数据无缝对接到旺店通·企业奇门，实现两者间的高度协同。
**一、如何确保集成金蝶云星空数据不漏单**
为了保证每一笔订单都能准确地从金蝶云星空传输到旺店通，我们首先需要调用金蝶云星空接口`executeBillQuery`进行定时可靠的数据抓取。该接口支持分页和限流处理，因此我们需要设计合理的轮询机制，以避免遗漏任何订单。在具体实现中，通过设置适当的时间间隔和批量查询条件，可以有效减少漏单风险。
**二、大量数据快速写入到旺店通·企业奇门**
在获取到来自金蝶云星空的大量订单后，需要将这些数据快速而精准地写入到旺店通·企业奇门。为此，我们利用了其提供的API接口`wdt.purchase.provider.create`进行批量数据插入操作。同时，为了应对海量数据场景，必须优化网络通信及数据库写入速度，例如通过分区并行处理大幅提高整体效率。
**三、处理分页和限流问题**
由于金蝶云星空API存在请求次数限制与返回结果分页的问题，我们建立了一个智能调度管理机制。当一次请求无法获取所有所需的数据时，该机制会自动调整下一次请求参数，并动态评估当前调用频率，以确保不会因超出速率限制导致服务中断或被封禁。
**四、异常处理与错误重试机制**
在实际运行过程中，不可避免地会遇到各种异常情况，如网络抖动或API响应超时等。因此，为了保障系统稳定性，设计了一套完善的异常捕获与重试逻辑。在首次失败后，会根据预设策略重新尝试多次，如果仍未成功则记录日志并发送告警通知，以便及时人工介入修复问题。此外，还使用轻易云实时监控功能，对整个过程中的各类事件进行全方位追踪，提高诊断问题和优化性能的能力。
本篇文章仅展示了项目开头部分，在随后的章节里我们将逐步展开更深入细节，包括具体实施步骤、技术难点以及解决方案等内容，帮助读者全面了解这一典型案例的实践经验与心得体会。
### 调用金蝶云星空接口executeBillQuery获取并加工数据
在数据集成过程中，调用源系统的API接口是关键的一步。本文将详细介绍如何使用轻易云数据集成平台调用金蝶云星空的`executeBillQuery`接口来获取供应商数据，并进行初步加工处理。
#### API接口配置
首先，我们需要配置API接口的元数据。以下是调用`executeBillQuery`接口所需的元数据配置：
```json
{
"api": "executeBillQuery",
"method": "POST",
"number": "FNumber",
"id": "FSupplierId",
"pagination": {
"pageSize": 100
},
"request": [
{"field":"FSupplierId","label":"FSupplierId","type":"string","value":"FSupplierId"},
{"field":"FNumber","label":"编码","type":"string","value":"FNumber"},
{"field":"FName","label":"名称","type":"string","value":"FName"},
{"field":"FCreateOrgId_FNumber","label":"创建组织","type":"string","value":"FCreateOrgId.FNumber"},
{"field":"FUseOrgId_FNumber","label":"使用组织","type":"string","value":"FUseOrgId.FNumber"},
{"field":"FDescription","label":"描述","type":"string","value":"FDescription"},
{"field":"FShortName","label":"简称","type":"string","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": "最大行数", "type": "string", "describe": "金蝶的查询分页参数", "value": "{PAGINATION_PAGE_SIZE}"},
{"field": "StartRow", "label": "开始行索引", "type": "string", "describe": "金蝶的查询分页参数", "value": "{PAGINATION_START_ROW}"},
{"field":...}
]
}
```
#### 请求参数解析
在请求参数中，我们需要特别注意以下几个字段：
- `FormId`: 必须填写金蝶的表单ID，例如：`BD_Supplier`。
- `FieldKeys`: 指定需要查询的字段集合，格式为数组，例如：`["FSupplierId", "FNumber", ...]`。
- `FilterString`: 用于过滤条件，例如：`FAuditDate>='{{LAST_SYNC_TIME|datetime}}' and FUseOrgId.FNumber = '999'`。
#### 数据请求与清洗
1. **构建请求体**：
根据元数据配置，构建请求体。示例如下：
```json
{
"FormId": "BD_Supplier",
"FieldKeys": ["FSupplierId", "FNumber", ...],
...
}
```
2. **发送请求**：
使用HTTP POST方法发送请求到金蝶云星空的API端点。
3. **接收响应**：
接收并解析响应数据，通常是JSON格式的数据。
4. **数据清洗**：
对接收到的数据进行初步清洗，包括但不限于：
- 去除无效或重复的数据。
- 转换数据类型，例如将字符串转换为日期或数字类型。
- 根据业务需求进行字段映射和重命名。
#### 数据转换与写入
在完成数据清洗后，下一步是将数据转换为目标系统所需的格式，并写入目标系统。这一步通常包括：
1. **字段映射**：
将源系统的数据字段映射到目标系统的数据字段。例如，将金蝶云星空中的`FSupplierId`映射到目标系统中的供应商ID字段。
2. **格式转换**：
根据目标系统的要求，对数据进行格式转换。例如，将日期格式从YYYY-MM-DD转换为MM/DD/YYYY。
3. **批量写入**：
将处理后的数据批量写入目标系统，以提高效率和性能。
#### 示例代码
以下是一个简单的示例代码，用于调用金蝶云星空的API并处理响应数据：
```python
import requests
import json
# 配置API端点和请求头
url = 'https://api.kingdee.com/executeBillQuery'
headers = {'Content-Type': 'application/json'}
# 构建请求体
payload = {
'FormId': 'BD_Supplier',
'FieldKeys': ['FSupplierId', 'FNumber', ...],
...
}
# 发送请求
response = requests.post(url, headers=headers, data=json.dumps(payload))
# 检查响应状态码
if response.status_code == 200:
data = response.json()
# 数据清洗与转换
cleaned_data = []
for item in data['Result']:
cleaned_item = {
'SupplierID': item['FSupplierId'],
'Code': item['FNumber'],
...
}
cleaned_data.append(cleaned_item)
# 写入目标系统（示例）
write_to_target_system(cleaned_data)
else:
print(f"Error: {response.status_code}")
```
通过上述步骤，我们可以高效地调用金蝶云星空接口获取供应商数据，并进行初步加工处理，为后续的数据集成奠定基础。
### 轻易云数据集成平台生命周期第二步：ETL转换与写入目标平台
在数据集成的过程中，ETL（Extract, Transform, Load）转换是至关重要的一步。本文将详细探讨如何将已经集成的源平台数据通过轻易云数据集成平台进行ETL转换，并最终写入到目标平台——旺店通·企业奇门API接口。
#### 数据请求与清洗
在数据请求与清洗阶段，我们已经从源系统中获取了原始数据，并进行了必要的清洗操作，使得数据符合初步的质量要求。接下来，我们需要将这些清洗后的数据进行转换，以便能够被目标平台所接受。
#### 数据转换
在轻易云数据集成平台中，数据转换主要包括字段映射和格式调整。为了将供应商信息写入到旺店通·企业奇门API接口，我们需要按照其元数据配置要求进行相应的字段映射和格式调整。
以下是旺店通·企业奇门API接口`wdt.purchase.provider.create`的元数据配置：
```json
{
"api": "wdt.purchase.provider.create",
"method": "POST",
"idCheck": true,
"request": [
{"field": "provider_no", "label": "供应商编号", "type": "string", "describe": "代表供应商所有属性的唯一编码，用于供应商区分，ERP内支持自定义（ERP供应商界面设置），用于创建供应商数据信息", "value": "{FNumber}"},
{"field": "provider_name", "label": "供应商名称", "type": "string", "describe": "供应商名称", "value": "{FName}"},
{"field": "min_purchase_num", "label": "最小采购量", "type": "string", "describe": "最小采购量"},
{"field": "purchase_cycle_days", "label": "采购周期", "type": "string", "describe": "采购周期"},
{"field": "arrive_cycle_days", "label": "到货周期", "type": "string", "describe": ":到货周期"},
{"field": ":contact", ":label:":"联系人","type":"string","describe":"联系人"},
{"field":"telno","label":"座机","type":"string","describe":"座机"},
{"field":"mobile","label":"移动电话","type":"string","describe":"手机号"},
{"field":"fax","label":"传真","type":"string","describe":"传真"},
{"field":"zip","label":"邮编","type":"string","describe":"邮政编码"},
{"field":"email","label":"邮箱","type":"string","describe":"电子邮箱"},
{"field":"qq","label":"qq","type":"string","describe":"腾讯QQ号码"},
{"field":"wangwang","label":"旺旺","type":"string","describe":"淘宝旺旺号"},
{"field:"address,""label:地址,""type:""string,""describe:省、市、区（县）、地址详情},
{"field:"website,""label:网址,""type:""string,""describe:供应商官网地址},
{"field:"last_purchase_time,""label:最后采购日期,""type:""string,""describe:对供应商最后一次采购日期，不传默认接口创建供应商的年月日，格式：yyyy-MM-dd HH:mm:ss},
{"field:"is_disabled,""label:停用,""type:""string,""describe:是否停用},
{"field:"charge_cycle_days,""label:结算周期,""type:""string,""describe:对供应商的账款结算周期，单位(天)，不传默认0}
]
}
```
根据上述元数据配置，我们需要将源系统中的字段映射到目标系统所要求的字段。例如：
- `FNumber` 映射到 `provider_no`
- `FName` 映射到 `provider_name`
其他字段如`min_purchase_num`, `purchase_cycle_days`, `arrive_cycle_days`等也需要根据业务需求进行相应的数据填充或转换。
#### 数据写入
完成了字段映射和格式调整之后，我们就可以将转换后的数据通过API接口写入到目标平台。这里以HTTP POST请求为例：
```http
POST /router/rest?method=wdt.purchase.provider.create HTTP/1.1
Host: api.wangdian.cn
Content-Type: application/json
{
"provider_no": "{FNumber}",
...
}
```
在实际操作中，可以使用轻易云提供的可视化工具来配置这些请求，从而简化开发过程并减少出错几率。
#### 实际案例
假设我们有以下源系统中的供应商信息：
```json
{
“FNumber”: “S12345”,
“FName”: “ABC供应商”,
“FTelNo”: “010-12345678”,
...
}
```
通过ETL转换后，将生成如下符合旺店通·企业奇门API接口要求的数据格式：
```json
{
“provider_no”: “S12345”,
“provider_name”: “ABC供应商”,
“telno”: “010-12345678”,
...
}
```
然后，通过HTTP POST请求将其发送至目标平台，实现最终的数据写入。
#### 总结
通过以上步骤，我们成功地将源系统中的数据经过ETL转换后写入到了目标平台。整个过程充分利用了轻易云提供的元数据配置和可视化工具，大大简化了复杂的数据集成任务，提高了效率和准确性。
