### 案例分享：金蝶分布式调入单集成到旺店通采购订单
在现代企业的运营中，高效的数据集成和系统对接已成为业务成功的关键。本文将详细解析如何通过轻易云数据集成平台，将金蝶云星空中的分布式调入单数据无缝集成到旺店通·企业奇门中的采购订单。
#### 关键技术实现与方案概述
1. **确保数据不漏单**：
首先，我们需要调用金蝶云星空的接口 `executeBillQuery` 来抓取分布式调入单的数据。为了确保不会遗漏任何一条重要数据，需实现定时任务，通过轻易云的平台周期性地执行API调用，并且使用日志记录每次获取的数据量和状态。
2. **数据快速写入到旺店通·企业奇门**：
金蝶云星空的数据获取后，需要迅速写入到旺店通·企业奇门中，对此我们采用的是 `wdt.purchase.order.push` 接口。在大量请求情况下，考虑API限流问题，可以通过批量处理来提高写入效率。
3. **分页处理与限流策略**：
由于金蝶云星空可能返回大量数据，因此需要对接口进行分页处理，每次仅提取特定数量以防止超时或失败。此外，为应对接口调用次数限制（限流），需设置重试机制及熔断保护策略，在遇到API响应频次过高时自动调整请求频率。
4. **解决格式差异问题**:
金蝶云星空与旺店通·企业奇门之间存在数据格式上的不同，这就要求先行对从金蝶拿回来的原始数据做适当转换，以满足目标系统的字段及结构需求。具体实现过程中可利用内置映射配置功能，实现复杂字段间的一一对应。
5. **异常处理与错误重试机制的设计**:
对于每一次网络请求，我们都需要做好充分准备。包括捕捉各种意外情况：如网络抖动、服务器故障等，并实施相应的重试机制，保证在出现短暂故障时能自动恢复，从而提高整个流程稳定性。这些操作过程均可被精确监控，并输出详尽日志便于后续排查。
综上所述，通过合理运用上述技术手段，不仅能够顺利完成由金蝶至旺店通的数据传输，还可以为整个业务流程提供强有力保障，进一步提升整体工作效率与可靠性。在下文中，将细化介绍具体操作步骤及代码示例，以助您更深入理解并应用这些方法论。
### 调用金蝶云星空接口executeBillQuery获取并加工数据
在数据集成的生命周期中，调用源系统接口获取数据是至关重要的一步。本文将深入探讨如何通过轻易云数据集成平台，调用金蝶云星空的`executeBillQuery`接口来获取和加工数据。
#### 接口配置与请求参数
首先，我们需要配置调用金蝶云星空接口的元数据。在本案例中，元数据配置如下：
```json
{
"api": "executeBillQuery",
"method": "POST",
"number": "FBillNo",
"id": "FSTKTRSINENTRY_FEntryID",
"pagination": {
"pageSize": 500
},
"idCheck": true,
"request": [
{"field":"FSTKTRSINENTRY_FEntryID","label":"FEntryID","type":"string","value":"FSTKTRSINENTRY_FEntryID"},
{"field":"FID","label":"实体主键","type":"string","value":"FID"},
{"field":"FBillNo","label":"单据编号","type":"string","value":"FBillNo"},
{"field":"FDocumentStatus","label":"单据状态","type":"string","value":"FDocumentStatus"},
{"field":"FStockOrgID_FNumber","label":"调入库存组织","type":"string","value":"FStockOrgID.FNumber"},
{"field":"FDate","label":"日期","type":"string","value":"FDate"},
{"field":"FBillTypeID","label":"单据类型","type":"string","value":"FBillTypeID"},
{"field":"FTransferDirect","label":"调拨方向","type":"string","value":"FTransferDirect"},
{"field":"FNOTE","label":"备注","type":"string","value":"FNOTE"},
{"field":"FCreateDate","label":"创建日期","type":"string","value":"FCreateDate"},
{"field":"FApproveDate","label":"审核日期","type":"string","value":"FApproveDate"},
{"field":...}
],
"otherRequest": [
{"field": "Limit", "label": "最大行数", "type": "string", "describe": "金蝶的查询分页参数", "value": "{PAGINATION_PAGE_SIZE}"},
{"field": "StartRow", "label": "开始行索引", "type": "string", "describe": "金蝶的查询分页参数", "value": "{PAGINATION_START_ROW}"},
{"field":...}
]
}
```
#### 请求示例
在实际操作中，我们需要构建一个HTTP POST请求来调用`executeBillQuery`接口。以下是一个示例请求体：
```json
{
"FormId": "STK_TRANSFERIN",
"FieldKeys": ["FID", "FBillNo", ...],
"FilterString": "( FApproveDate>='2023-01-01' and FStockOrgID.fnumber in ( '7000','3000') and FStockOutOrgID.fnumber = '8000')",
...
}
```
#### 数据处理与清洗
获取到原始数据后，需要对其进行清洗和转换，以便后续的数据写入和使用。以下是一些常见的数据清洗步骤：
1. **字段映射**：将原始字段映射到目标系统所需的字段。例如，将`FBillNo`映射为目标系统中的订单编号。
2. **数据格式转换**：将日期、金额等字段转换为目标系统所需的格式。例如，将日期从字符串格式转换为标准日期格式。
3. **过滤无效数据**：移除不符合业务规则或无效的数据记录。例如，过滤掉单据状态为“草稿”的记录。
#### 示例代码
以下是一个示例代码片段，用于调用接口并处理返回的数据：
```python
import requests
import json
# 配置请求URL和头信息
url = 'https://api.kingdee.com/executeBillQuery'
headers = {'Content-Type': 'application/json'}
# 构建请求体
payload = {
'FormId': 'STK_TRANSFERIN',
'FieldKeys': ['FID', 'FBillNo', ...],
'FilterString': "( FApproveDate>='2023-01-01' and FStockOrgID.fnumber in ( '7000','3000') and FStockOutOrgID.fnumber = '8000')",
}
# 发起POST请求
response = requests.post(url, headers=headers, data=json.dumps(payload))
# 检查响应状态码
if response.status_code == 200:
data = response.json()
# 数据清洗与转换
cleaned_data = []
for record in data:
cleaned_record = {
'OrderNumber': record['FBillNo'],
'ApprovalDate': record['FApproveDate'],
...
}
cleaned_data.append(cleaned_record)
# 后续处理逻辑...
else:
print(f"Error: {response.status_code}")
```
通过上述步骤，我们可以有效地调用金蝶云星空的`executeBillQuery`接口，并对返回的数据进行清洗和加工，为后续的数据写入和使用做好准备。这一过程不仅确保了数据的一致性和准确性，也极大提升了业务流程的效率。
### 使用轻易云数据集成平台将金蝶分布式调入单转换为旺店通采购订单
在数据集成过程中，将源平台的数据转换为目标平台可接收的格式是关键步骤。本文将详细探讨如何使用轻易云数据集成平台将金蝶分布式调入单的数据通过ETL转换，最终写入旺店通·企业奇门API接口。
#### 元数据配置解析
我们需要将金蝶分布式调入单的数据转换为旺店通采购订单。以下是相关的元数据配置：
```json
{
"api": "wdt.purchase.order.push",
"method": "POST",
"idCheck": true,
"operation": {
"method": "merge",
"field": "FBillNo,FSrcStockID_FNumber,FDestStockID_FNumber",
"bodyName": "details_list",
"bodySum": ["F_UHZG_JJQty"],
"header": ["FBillNo", "FStockID", "FSupplierId", "FDestStockID_FNumber", "FNOTE", "FSUPPLIERID_FNumber"],
"body": ["FMaterialId", "FQty", "FPrice", "FMaterialID_FNumber", "FEntryNote", "F_UHZG_JJQty"]
},
...
}
```
#### 数据请求与清洗
在进行ETL转换之前，首先需要从源平台获取数据，并对其进行必要的清洗和预处理。假设我们已经完成了这一阶段，接下来进入数据转换与写入阶段。
#### 数据转换与写入
根据元数据配置，我们需要将源平台的数据字段映射到目标平台的字段，并按照目标平台API要求的格式进行组织。
1. **API接口和请求方法**：
- API接口：`wdt.purchase.order.push`
- 请求方法：`POST`
2. **请求参数映射**：
- `provider_no` 映射到 `FSUPPLIERID_FNumber`
- `warehouse_no` 映射到 `FDestStockID_FNumber`
- `outer_no` 映射到 `FBillNo`
- `is_use_outer_no` 固定值 `1`
- `is_check` 固定值 `1`
3. **采购明细节点**：
- 每个采购明细需要包含以下字段：
- `remark`: 映射到 `details_list.FEntryNote`
- `spec_no`: 映射到 `details_list.FMaterialID_FNumber`
- `num`: 映射到 `details_list.F_UHZG_JJQty`
- 其他字段如价格、折扣、税率等可以根据实际需求进行填充。
以下是一个具体的JSON请求示例：
```json
{
"provider_no": "{FSUPPLIERID_FNumber}",
"warehouse_no": "{FDestStockID_FNumber}",
"outer_no": "{FBillNo}",
"is_use_outer_no": "1",
"is_check": "1",
...
"details_list": [
{
"remark": "{{details_list.FEntryNote}}",
"spec_no": "{{details_list.FMaterialID_FNumber}}",
...
// 根据需求添加其他字段
}
]
}
```
#### 实际操作步骤
1. **定义ETL规则**：
在轻易云数据集成平台中，定义ETL规则以实现上述字段的映射和转换。确保每个字段都正确映射，并且符合目标API的格式要求。
2. **测试和验证**：
在正式运行之前，通过测试环境对ETL规则进行验证，确保所有数据能够正确转换并成功写入目标平台。
3. **监控和优化**：
实时监控数据流动和处理状态，及时发现并解决潜在问题，以确保数据集成过程的稳定性和高效性。
通过以上步骤，我们能够顺利地将金蝶分布式调入单的数据转换为旺店通采购订单，并通过旺店通·企业奇门API接口成功写入目标平台。这不仅提高了业务透明度和效率，也确保了不同系统间的数据无缝对接。
