### 旺店通销售出库单传金蝶直接调拨寄售发出的集成案例
在实际业务操作中，旺店通·企业奇门与金蝶云星空的系统对接需求日益增长。本文将介绍如何通过轻易云数据集成平台实现这一复杂过程的数据集成。特别是针对“旺店通销售出库单传金蝶直接调拨寄售发出”的具体案例，我们将详细探讨API调用、数据处理和异常处理等关键技术环节。
为了确保整个数据流动过程的高效和完整性，我们首先需要解决几个重要问题：
1. **如何调用旺店通·企业奇门接口 wdt.stockout.order.query.trade**
旺店通·企业奇门提供了强大而灵活的API接口，但在使用过程中必须考虑其分页和限流机制。通过合理设置查询参数，可以高效获取所需的数据，同时避免触发接口限流阈值。
2. **大量数据快速写入到金蝶云星空**
金蝶云星空支持批量写入，通过batchSave API可以一次性插入大量销售出库单信息。在此过程中，需要提前设计好对应字段的映射规则，以便准确、高效地处理不同系统间的数据格式差异。
3. **定时可靠抓取和实时监控**
为保证数据不漏单、不重叠，采用定时任务来周期性地抓取旺店通·企业奇门的数据，并搭配实时监控功能，及时发现并解决潜在问题。同时，将所有操作日志记录下来，以备查阅和分析。
4. **异常处理与错误重试机制**
在实际运行过程中，不可避免会遇到网络波动或请求失败等情况。因此，在构建整体方案时，需要引入异常处理及错误重试机制。一旦检测到某次操作失败，系统应自动尝试重新执行相关步骤，以最大程度上减少人工干预，提高运行稳定性。
通过掌握上述关键点，可以有效提升从旺店通向金蝶云星空的数据转换效率，并确保每个环节都能够顺利完成。在后续内容中，将进一步展开这些技术细节，包括具体配置方法与实例代码，实现完整且高效的跨系统数据集成流程。
### 调用旺店通·企业奇门接口wdt.stockout.order.query.trade获取并加工数据
在数据集成的生命周期中，调用源系统接口获取数据是至关重要的第一步。本文将详细探讨如何通过轻易云数据集成平台调用旺店通·企业奇门接口`wdt.stockout.order.query.trade`，并对获取的数据进行初步加工。
#### 接口概述
接口`wdt.stockout.order.query.trade`用于查询销售出库单的相关信息。该接口支持POST请求，并能够根据多种条件进行查询，如时间范围、订单状态、店铺编号等。以下是元数据配置中的关键字段：
- `start_time` 和 `end_time`: 用于定义数据增量获取的时间范围。
- `status`: 用于过滤订单状态，例如95表示已发货。
- `shop_no`: 店铺编号，用于区分不同店铺的数据。
- `warehouse_no`: 仓库编号，用于区分不同仓库的数据。
#### 请求参数配置
在实际操作中，我们需要根据业务需求配置请求参数。以下是一个典型的请求参数配置示例：
```json
{
"start_time": "{{LAST_SYNC_TIME|datetime}}",
"end_time": "{{CURRENT_TIME|datetime}}",
"status": "95",
"shop_no": "JS001",
"warehouse_no": "WH001",
"is_by_modified": "0",
"page_size": "{PAGINATION_PAGE_SIZE}",
"page_no": "0"
}
```
- `start_time` 和 `end_time` 使用动态变量分别表示上次同步时间和当前时间，以实现增量数据获取。
- `status` 设置为95，表示只获取已发货的订单。
- `shop_no` 和 `warehouse_no` 分别指定店铺和仓库编号，以确保查询到特定范围内的数据。
- `page_size` 和 `page_no` 用于分页控制，确保一次请求不会返回过多数据。
#### 数据清洗与转换
在获取到原始数据后，需要对其进行清洗和转换，以便后续处理和写入目标系统。以下是一些常见的数据清洗与转换操作：
1. **字段映射**: 将原始数据中的字段映射到目标系统所需的字段。例如，将原始数据中的`order_no`映射到目标系统中的订单编号字段。
2. **数据格式转换**: 将日期、金额等字段转换为目标系统所需的格式。例如，将日期格式从`yyyy-MM-dd HH:mm:ss`转换为目标系统所需的格式。
3. **过滤无效数据**: 根据业务规则过滤掉无效或不需要的数据。例如，过滤掉状态为已取消的订单。
以下是一个简单的数据清洗示例：
```python
def clean_data(raw_data):
cleaned_data = []
for record in raw_data:
if record['status'] == '95': # 只保留已发货订单
cleaned_record = {
'order_id': record['order_no'],
'warehouse': record['warehouse_no'],
'shop': record['shop_no'],
'date': convert_date_format(record['created']),
'amount': float(record['total_amount'])
}
cleaned_data.append(cleaned_record)
return cleaned_data
```
#### 自动填充响应
轻易云平台提供了自动填充响应功能，可以根据预定义的规则自动将响应结果填充到相应的字段中。这极大地简化了开发工作，提高了效率。在元数据配置中，通过设置`autoFillResponse: true`来启用该功能。
#### 条件筛选
为了确保查询结果符合业务需求，可以在请求参数中添加条件筛选。例如，通过设置多个条件来筛选特定店铺的数据：
```json
"condition":[
[{"field":"shop_no","logic":"like","value":"JS"}],
[{"field":"shop_no","logic":"like","value":"js"}],
[{"field":"shop_no","logic":"like","value":"jS"}],
[{"field":"shop_no","logic":"like","value":"js"}]
]
```
这种条件筛选可以灵活地适应各种复杂业务场景，确保获取到精确的数据。
通过上述步骤，我们可以高效地调用旺店通·企业奇门接口获取销售出库单数据，并对其进行初步加工，为后续的数据处理和写入奠定基础。
### 使用轻易云数据集成平台实现旺店通销售出库单传金蝶直接调拨寄售发出
在数据集成过程中，ETL（Extract, Transform, Load）转换是关键步骤之一。本文将详细探讨如何通过轻易云数据集成平台将旺店通销售出库单的数据转换为金蝶云星空API接口所能接收的格式，并最终写入目标平台。
#### 1. 数据请求与清洗
在开始数据转换之前，首先需要从源系统（旺店通）获取销售出库单的数据，并进行必要的清洗和预处理。这一步骤确保了数据的准确性和一致性，为后续的转换奠定基础。
#### 2. 数据转换与写入
本节将重点介绍如何将清洗后的数据通过ETL过程转换为金蝶云星空API接口所需的格式，并写入目标平台。以下是具体的元数据配置和操作步骤。
##### 2.1 配置元数据
根据提供的元数据配置，我们需要对每个字段进行映射和转换。以下是关键字段及其配置说明：
- **单据编号 (FBillNo)**: 对应于旺店通中的订单编号 `{order_no}`。
- **单据类型 (FBillTypeID)**: 固定值 `ZJDB07_SYS`。
- **业务类型 (FBizType)**: 下拉列表选择。
- **调拨方向 (FTransferDirect)**: 固定值 `GENERAL` 或 `RETURN`。
- **调拨类型 (FTransferBizType)**: 固定值 `InnerOrgTransfer`。
- **销售组织 (FSaleOrgId)**、**结算组织 (FSettleOrgId)**、**调出库存组织 (FStockOutOrgId)**、**调入库存组织 (FStockOrgId)**: 固定值 `100`。
- **调出货主类型 (FOwnerTypeOutIdHead)**: 固定值 `BD_OwnerOrg`。
- **调出货主 (FOwnerOutIdHead)**、**结算币别 (FSETTLECURRID)**: 分别对应固定值 `100` 和 `PRE001`。
- **日期 (FDate)**: 对应于旺店通中的发货时间 `{consign_time}`。
- **备注 (FNote)**: 可选多行文本字段。
##### 2.2 明细信息配置
对于明细信息，我们需要处理多个子字段，每个子字段都需要进行相应的映射和转换：
- **物料编码 (FMaterialId)**: 对应于旺店通中的规格编号 `{details_list.spec_no}`。
- **零售条形码 (FCMKBarCode)**: 文本字段，无需特殊处理。
- **调拨数量 (FQty)**: 对应于旺店通中的商品数量 `{details_list.goods_count}`。
- **调出仓库 (FSrcStockId)**、**调入仓库 (FDestStockId)**: 分别对应于旺店通中的仓库编号 `{warehouse_no}` 和商店编号 `{shop_no}`。
##### 2.3 API请求构建
基于上述元数据配置，我们构建API请求体如下：
```json
{
"FormId": "STK_TransferDirect",
"IsAutoSubmitAndAudit": true,
"IsVerifyBaseDataField": true,
"Operation": "Save",
"InterationFlags": "STK_InvCheckResult",
"Model": {
"FBillNo": "{order_no}",
"FBillTypeID": {"FNumber": "ZJDB07_SYS"},
"FBizType": "...",
"FTransferDirect": "...",
"FTransferBizType": {"FNumber": "InnerOrgTransfer"},
...
"FBillEntry": [
{
"FMaterialId": {"FNumber": "{details_list.spec_no}"},
...
}
]
}
}
```
##### 2.4 数据写入
最后，通过POST方法将构建好的请求体发送到金蝶云星空API接口，实现数据写入操作。以下是示例代码：
```python
import requests
url = 'https://api.kingdee.com/batchSave'
headers = {'Content-Type': 'application/json'}
data = {
# 构建好的请求体
}
response = requests.post(url, headers=headers, json=data)
if response.status_code == 200:
print("Data successfully written to Kingdee Cloud")
else:
print("Failed to write data:", response.text)
```
#### 总结
通过以上步骤，我们成功地将旺店通销售出库单的数据转换为金蝶云星空API接口所能接收的格式，并完成了数据写入操作。这一过程展示了轻易云数据集成平台在异构系统间无缝对接方面的强大能力。
