### 旺店通·企业奇门数据集成到金蝶云星辰V1：一个成功的系统对接案例
在本技术案例中，我们将聚焦于如何成功实现旺店通·企业奇门的数据无缝集成到金蝶云星辰V1。此次集成的具体场景为采购退货单的数据同步，实际运行方案名称为wk_采购退货单同(New)。
#### 系统对接背景与挑战
为了解决在处理大规模数据时可能出现的漏单问题，同时确保数据快速而准确地写入金蝶云星辰V1系统，本次对接面临以下几个关键技术挑战：
1. **确保集成旺店通·企业奇门数据不漏单**：
- 通过调用wdt.stockout.order.query.return接口，我们获取了精准和实时更新的采购退货数据信息。
2. **大量数据快速写入到金蝶云星辰V1**：
- 使用jdy/pur/pur_rtn_save接口，实现批量、高效的数据写入，以及多个并发请求优化。
#### 数据抓取与分页处理
我们首先考虑的是定时抓取并可靠更新旺店通·企业奇门中的采购退货数据信息。为了防止遗漏，采用定时任务轮询机制，并针对分页和限流情况进行了特别优化。例如，在每次API调用过程中，通过监控返回结果中的页码信息，以确定剩余未抓取的数据。
```python
# 示例代码片段: 通过API分页获取旺店通·企业奇门的采购退货订单
def fetch_wdt_stockout_orders(api_key, start_time, end_time):
page_number = 0
while True:
response = call_api(endpoint='wdt.stockout.order.query.return',
params={'api_key': api_key, 'start_time': start_time, 'end_time': end_time,
'page_no': page_number})
if not response['orders']:
break
process_orders(response['orders']) # 批量处理逻辑
page_number += 1
```
#### 格式转换与异常处理
由于两个系统间存在显著的数据格式差异，每次获取到原始数据后，必须进行一系列格式化转换。这包括字段名重映射、日期格式调整等，并依据业务规则进行相应校验。此外，为提高系统稳定性，对所有API交互增加了错误捕获和重试机制。在调用金蝶云星辰V1 API接口时，如果遇到网络或服务端故障，将记录日志且自动触发重试逻辑。
```python
# 示例代码片段: 调用金蝶云星辰V1 API并实现错误重试机制
def save_to_jd_cloud_purchase_return
### 使用轻易云数据集成平台调用旺店通·企业奇门接口获取采购退货单数据
在数据集成的生命周期中，第一步是从源系统获取数据。本文将深入探讨如何使用轻易云数据集成平台调用旺店通·企业奇门接口`wdt.stockout.order.query.return`来获取并加工采购退货单数据。
#### 接口配置与请求参数
首先，我们需要配置接口的元数据。根据提供的元数据配置，接口采用POST方法进行调用，主要参数如下：
- **api**: `wdt.stockout.order.query.return`
- **method**: `POST`
- **number**: `order_no`
- **id**: `stockout_id`
- **pagination**: 每页返回的数据条数为100
- **idCheck**: true
请求参数包括以下字段：
1. **start_time**（开始时间）：
- 类型：datetime
- 值：`{{LAST_SYNC_TIME|datetime}}`
- 说明：用于增量获取数据的起始时间。
2. **end_time**（结束时间）：
- 类型：datetime
- 值：`{{CURRENT_TIME|datetime}}`
- 说明：按最后修改时间增量获取数据，格式为`yyyy-MM-dd HH:mm:ss`。
3. **warehouse_no**（仓库编号）：
- 类型：string
4. **status**（出库单状态）：
- 类型：string
- 说明：出库单状态可选值包括5（已取消）、50（待审核）、55（已审核）、95（已发货）、110（已完成）。默认查询已发货和已完成的单据。
5. **page_no**（页号）：
- 类型：string
- 值：`{PAGINATION_START_ROW}`
6. **page_size**（分页大小）：
- 类型：string
- 值：`{PAGINATION_PAGE_SIZE}`
- 说明：每页返回的数据条数，范围为1~30，不传本参数时默认为30。
7. **src_order_no**（上层单据编号）：
- 类型：string
#### 数据请求与清洗
在实际操作中，我们需要确保请求参数的正确性和完整性。以下是一个示例请求体：
```json
{
"start_time": "2023-01-01 00:00:00",
"end_time": "2023-01-31 23:59:59",
"warehouse_no": "WH001",
"status": "95,110",
"page_no": "1",
"page_size": "100"
}
```
通过上述请求体，我们可以从旺店通系统中获取指定时间段内、特定仓库和状态的采购退货单数据。轻易云平台会自动处理分页逻辑，确保所有符合条件的数据都能被完整提取。
#### 数据转换与写入
在获取到原始数据后，需要对其进行清洗和转换，以便写入目标系统。在这个过程中，可以利用轻易云平台提供的可视化工具，对字段进行映射、格式转换等操作。例如，将原始字段名转换为目标系统所需的字段名，或者将日期格式从字符串转换为日期对象。
以下是一个简单的数据转换示例：
```json
{
"order_no": "{{stockout_id}}",
"order_date": "{{created_at|datetime}}",
"warehouse_code": "{{warehouse_no}}",
"status": "{{status}}"
}
```
通过上述映射规则，可以将源系统中的字段名和格式转换为目标系统所需的形式。
#### 实时监控与异常处理
在整个数据集成过程中，实时监控和异常处理至关重要。轻易云平台提供了详细的日志记录和告警机制，当出现异常情况时，可以及时发现并处理。例如，如果某次请求失败或返回错误信息，可以通过日志快速定位问题，并采取相应措施进行修复。
综上所述，通过合理配置元数据和利用轻易云平台强大的功能，我们可以高效地调用旺店通·企业奇门接口`wdt.stockout.order.query.return`，实现采购退货单数据的自动化获取与加工。这不仅提升了业务透明度和效率，也为后续的数据分析和决策提供了可靠的数据基础。
### 使用轻易云数据集成平台实现金蝶云星辰V1 API接口的数据转换与写入
在数据集成的生命周期中，数据转换与写入是关键的一步。本文将深入探讨如何通过轻易云数据集成平台将源平台的数据进行ETL转换，并最终写入金蝶云星辰V1 API接口。
#### 配置元数据
首先，我们需要配置元数据，以便正确地将源平台的数据映射到目标平台的API接口格式。以下是针对金蝶云星辰V1 API接口`jdy/pur/pur_rtn_save`的元数据配置：
```json
{
"api": "jdy/pur/pur_rtn_save",
"method": "POST",
"idCheck": true,
"request": [
{
"field": "billno",
"label": "单据编码",
"type": "string",
"describe": "单据编码",
"value": "{order_no}"
},
{
"field": "billdate",
"label": "单据日期",
"type": "datetime",
"describe": "单据日期",
"value": "{{consign_time|date}}"
},
{
"field": "supplierid_id",
"label": "供应商",
"type": "string",
"describe": "供应商",
"value": "_findCollection find id from 9278fe4a-f123-3198-94b2-69703d296326 where number={provider_no}"
},
{
"field": "remark",
"label": "备注",
"type": "string",
"describe": ""
},
{
"field": "totalunsettleamount",
"label": "",
"type": "",
""
},
{
...
// 省略部分字段
...
}
]
}
```
#### 数据请求与清洗
在进行ETL转换之前，首先需要从源系统请求并清洗数据。假设我们已经完成了这一阶段，现在我们有了一个清洗后的数据集，接下来我们将其转换为目标平台所需的格式。
#### 数据转换
根据元数据配置，我们需要将源平台的数据字段映射到金蝶云星辰V1 API接口所需的字段。例如：
- `order_no` 映射到 `billno`
- `consign_time` 映射到 `billdate`
- `provider_no` 映射到 `supplierid_id`
对于复杂的数据结构，如商品分录（`material_entity`），我们需要逐一处理每个子字段：
```json
{
...
{
field: 'material_entity',
label: '商品分录',
type: 'array',
describe: '商品分录',
children: [
{
field: 'materialid_id',
label: '商品',
type: 'string',
describe: '商品',
value: '_findCollection find id from b36e2f56-3e1b-3d60-9748-c59ec4c9d95f where number={{detail_list.spec_no}}'
},
{
field: 'stockid_id',
label: '仓库',
type: 'string',
describe: '仓库',
value: '_findCollection find id from dfb624bb-d6b8-33fc-a971-c3df53cf9288 where number={warehouse_no}'
},
...
// 省略部分字段
...
],
value: 'details_list'
}
}
```
#### 数据写入
完成数据转换后，我们将其通过POST请求写入目标平台。以下是一个示例代码片段，展示如何使用轻易云平台进行API调用：
```python
import requests
import json
url = 'https://api.kingdee.com/jdy/pur/pur_rtn_save'
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(f"Failed to write data. Status code: {response.status_code}, Response: {response.text}")
```
通过上述步骤，我们可以确保源平台的数据经过清洗、转换后，成功写入金蝶云星辰V1 API接口。这不仅提高了系统间的数据一致性，还简化了跨平台的数据管理流程。
