### 新版接口-管易退货单同步金蝶销售出库单（红字）案例分享
在企业的日常运营中，数据对接和集成是实现系统高效协作的关键。此次，我们将重点探讨如何通过轻易云数据集成平台，将管易云中的退货订单与金蝶K3-WISE中的销售出库单（红字）进行无缝集成。
这个案例涉及两个主要API：管易云的数据获取API `gy.erp.kingdeecloud.tradereturn.orders.querybydate` 和 金蝶K3-WISE 的数据写入API `Sales_Delivery/Save`。具体的方法和过程展示了如何解决各类技术挑战，包括定时抓取、批量处理、数据格式差异处理以及异常检测等。
#### 高吞吐量与实时监控
首先，面对大量的退货订单信息，高吞吐量的数据写入能力显得尤为重要。我们利用轻易云的平台优势，使得这些大规模数据能够迅速并精准地被传输到金蝶K3-WISE系统中。同时，通过集中式监控和告警系统，确保每个集成任务在执行过程中，都能被实时跟踪，从而及时发现潜在问题并进行预警。
#### 数据转换及质量监控
另一个重要环节是自定义数据转换逻辑。由于管易云和金蝶K3-WISE 系统之间可能存在不同的数据结构，对于某些字段需要特殊映射或转化。这一步骤不仅保证了最终入库的数据具有正确性，还增强了业务流程的一致性。此外，通过提供完善的数据质量监控机制，开创了一种新的模式来识别并处理异常情况，以防止错误传播到下游系统。
#### 接口调用及分页限流技巧
为了更好地管理请求频率，我们采用了一系列优化策略。例如，在调用`gy.erp.kingdeecloud.tradereturn.orders.querybydate` API时，实现分页功能以分段获取海量数据，并结合限流措施避免因请求过多造成服务压力。同时，在操作完成之后，通过自动重试机制确保每笔订单都能够成功同步到目标系统中，无一遗漏。
通过此整体方案，不仅提高了工作效率，还极大的提升了业务透明度，为后续操作提供强有力的支持基础。在本文后续部分，将进一步详细介绍具体实现步骤及相关代码示例，有助于快速复制这一成功经验至类似环境中去。
### 调用管易云接口gy.erp.kingdeecloud.tradereturn.orders.querybydate获取并加工数据
在数据集成生命周期的第一步中，调用源系统接口获取数据是至关重要的一环。本文将详细介绍如何通过轻易云数据集成平台调用管易云接口`gy.erp.kingdeecloud.tradereturn.orders.querybydate`，并对获取的数据进行初步加工。
#### 接口配置与请求参数
首先，我们需要配置接口元数据，以便正确调用管易云的API。根据提供的元数据配置，我们可以看到该接口使用POST方法，并且需要传递多个请求参数。
```json
{
"api": "gy.erp.kingdeecloud.tradereturn.orders.querybydate",
"method": "POST",
"number": "code",
"id": "code",
"idCheck": true,
"beatFlat": ["details", "batchs"],
"request": [
{"field": "start_date", "label": "创建时间开始段", "type": "string", "value": "{{LAST_SYNC_TIME|datetime}}"},
{"field": "end_date", "label": "创建时间结束段", "type": "string", "value": "{{CURRENT_TIME|datetime}}"}
],
"otherRequest": [
{"field": "page_size", "label": "分页大小", "type": "string", "describe":"默认为10", "value":"{PAGINATION_PAGE_SIZE}"},
{"field": "page_no", "label":"页号", "type":"string","describe":"默认1","value":"{PAGINATION_START_PAGE}"},
{"field":"detailApi","label":"详情查询api","type":"object","children":[{"field":"api","label":"api","type":"string","value":"gy.erp.kingdeecloud.tradereturn.details.querybycode","parent":"detailApi"}]}
]
}
```
#### 请求参数解析
1. **时间范围参数**：
- `start_date` 和 `end_date` 分别表示查询的起始和结束时间。这两个参数通过模板变量`{{LAST_SYNC_TIME|datetime}}`和`{{CURRENT_TIME|datetime}}`动态生成，确保每次请求都能获取到最新的数据。
2. **分页参数**：
- `page_size`：定义每页返回的数据条数，默认为10。
- `page_no`：定义当前请求的页码，默认为1。
3. **详情查询API**：
- `detailApi`：嵌套对象，用于指定详情查询的API，即`gy.erp.kingdeecloud.tradereturn.details.querybycode`。
#### 数据请求与清洗
在配置好请求参数后，我们通过轻易云平台发起API调用。假设我们已经成功获取了返回的数据，接下来需要对这些数据进行初步清洗和处理。
```python
import requests
import json
from datetime import datetime
# 定义API URL和Headers
url = 'https://api.guanyiyun.com/erp/kingdeecloud/tradereturn/orders/querybydate'
headers = {
'Content-Type': 'application/json',
'Authorization': 'Bearer YOUR_ACCESS_TOKEN'
}
# 定义请求Payload
payload = {
'start_date': datetime.now().strftime('%Y-%m-%dT%H:%M:%S'),
'end_date': datetime.now().strftime('%Y-%m-%dT%H:%M:%S'),
'page_size': 10,
'page_no': 1
}
# 发起POST请求
response = requests.post(url, headers=headers, data=json.dumps(payload))
# 检查响应状态码
if response.status_code == 200:
data = response.json()
# 数据清洗示例：提取订单编号和详情信息
orders = []
for order in data.get('orders', []):
cleaned_order = {
'order_code': order.get('code'),
'details': order.get('details', [])
}
orders.append(cleaned_order)
# 打印清洗后的数据
print(json.dumps(orders, indent=2))
else:
print(f"Error: {response.status_code}")
```
#### 数据转换与写入
在完成初步清洗后，可以根据业务需求对数据进行进一步转换，并将其写入目标系统。例如，将退货单同步到金蝶销售出库单（红字）。这一过程通常包括字段映射、格式转换等操作。
```python
def transform_and_write_to_kingdee(orders):
for order in orders:
transformed_order = {
# 转换后的字段映射示例
'销售出库单号': order['order_code'],
'商品明细': order['details']
}
# 调用金蝶API写入数据（伪代码）
kingdee_api_url = 'https://api.kingdee.com/sales/outbound'
response = requests.post(kingdee_api_url, headers=headers, data=json.dumps(transformed_order))
if response.status_code == 200:
print(f"Order {order['order_code']} successfully written to Kingdee.")
else:
print(f"Failed to write order {order['order_code']} to Kingdee.")
# 执行转换与写入操作
transform_and_write_to_kingdee(orders)
```
通过以上步骤，我们实现了从管易云接口获取退货单数据，并将其清洗、转换后写入金蝶系统的全过程。这一流程展示了轻易云平台在异构系统间无缝对接和高效数据处理方面的强大能力。
### 新版接口-管易退货单同步金蝶销售出库单（红字）
在数据集成生命周期的第二步，我们需要将已经集成的源平台数据进行ETL转换，并转为目标平台金蝶K3-WISE API接口所能够接收的格式，最终写入目标平台。本文将详细解析如何通过轻易云数据集成平台配置元数据，实现这一过程。
#### 1. 配置API接口
首先，我们需要配置目标平台的API接口。在本案例中，使用的是金蝶K3-WISE的`Sales_Delivery/Save`接口，方法为`POST`。以下是元数据配置中的关键部分：
```json
{
"api": "Sales_Delivery/Save",
"method": "POST",
"idCheck": true,
...
}
```
#### 2. 表头数据映射
表头部分的数据映射定义了从源数据到目标API请求字段的转换规则。以下是表头部分的具体配置：
```json
{
"field": "Page1",
"label": "表头",
"type": "array",
"children": [
{"field": "Fdate", "label": "日期", "type": "string", "value": "{enter_time1}", "parent": "Page1"},
{"field": "FMarketingStyle", "label": "销售业务类型", "type": "string", "value": "XSLX01", ...},
{"field": "FSupplyID", "label": "购货单位", "type": "string", ...},
...
{"field": "FROB", "label": "红蓝单标志", "type": "string", "value":"-1", ...}
]
}
```
在上述配置中，每个字段都通过`value`属性指定了对应的源数据字段，例如`{enter_time1}`。此外，还使用了`ConvertObjectParser`来处理一些复杂的字段映射，如购货单位、部门等。
#### 3. 表体数据映射
表体部分的数据映射定义了每个商品明细项的数据转换规则。以下是表体部分的具体配置：
```json
{
"field": "Page2",
...
{
{"field":"FConsignPrice","label":"销售单价","type":"string","value":"{details_price}","parent":"Page2"},
{"field":"FDCStockID1","label":"发货仓库","type":"string","value":"{warehouse_code}","parent":"Page2"},
{"field":"Fauxqty","label":"实发数量","type":"string","value":"_function {details_qty}*-1","parent":"Page2"},
...
{"field":"FEntrySelfB0178","label":"业绩金额","type":"string","value":"_function {details_amount}*-1","parent":"Page2"}
}
}
```
这里特别注意的是，针对退货单，需要将数量和金额取负值，因此使用了`_function {details_qty}*-1`和`_function {details_amount}*-1`来实现。
#### 4. 自动审核参数
为了确保数据写入后能够自动审核，还需要配置审核参数。这部分配置如下：
```json
{
...
{
{"field":"autoCheck","label":"审核参数","type":"object","children":[
{"field":"api","label":"api","type":"string","value":"Sales_Delivery/CheckBill"},
{"field":"FBillNo","label":"FBillNo","type":"string","value":"{{Data.BillNo}}"},
{"field":"FChecker","label":"FChecker","type":"string","value":"administrator"},
...
]}
}
}
```
该配置确保在数据写入后，系统会自动调用审核API进行单据审核。
#### 总结
通过以上步骤，我们成功地将管易退货单的数据转换为金蝶K3-WISE销售出库单（红字）的格式，并写入目标平台。在此过程中，利用轻易云数据集成平台提供的可视化界面和丰富的元数据配置能力，大大简化了复杂的数据转换和集成任务。
