### 03-旺店通销售出库单对接金蝶销售出库单（线上）_合并
在复杂多变的电商环境中，实现高效、准确的数据流转至关重要。本案例聚焦于将旺店通·企业奇门的销售出库数据无缝集成到金蝶云星空系统，以实现订单数据的实时同步和处理。以下是具体实施过程中用到的一些关键技术点及注意事项。
首先，确保集成过程中的数据完整性与可靠性，我们通过定时抓取机制从旺店通·企业奇门获取数据接口`wdt.stockout.order.query.trade`，确保每一处理批次的数据都能被及时捕获，有效避免漏单现象。同时，为高效处理海量订单，我们采用批量写入方式，并调用金蝶云星空提供的API `batchSave` 接口，这样不仅提升了数据写入效率，也减少了频繁API调用带来的性能开销。
其次，在进行系统对接时，不可忽视的是两大平台间的数据格式差异。我们在整个生命周期管理中，通过自定义映射与转换规则，将旺店通·企业奇门的数据格式调整为符合金蝶云星空要求的格式，从而避免了因格式不匹配引发的问题。此外，还实现了分页和限流控制，保障在请求大量数据时不会超载或丢失信息。
同时，加固系统稳定性的另一关键措施就是异常处理与错误重试机制。在实际运行过程中，如果由于网络波动或其他原因导致接口调用失败，通过日志记录功能实时监控并触发自动重试，使得最终结果依然可靠可信。这种策略不仅保证了一致性，而且提升了整体业务流程透明度。
本次集成方案还特别关注如何通过对接细节来优化流程效率，包括细粒度权限管理、适配双方不同认证机制，以及利用轻易云平台的全生命周期管理工具提供各环节需求支持。以上这些设计考虑让我们的解决方案更加稳健、高效，也为后续扩展打下坚实基础。
### 调用旺店通·企业奇门接口wdt.stockout.order.query.trade获取并加工数据
在数据集成的生命周期中，调用源系统接口获取数据是至关重要的一步。本文将详细探讨如何使用轻易云数据集成平台调用旺店通·企业奇门接口`wdt.stockout.order.query.trade`，并对获取的数据进行初步加工。
#### 接口调用配置
首先，我们需要配置接口调用的元数据。以下是针对`wdt.stockout.order.query.trade`接口的详细配置：
```json
{
"api": "wdt.stockout.order.query.trade",
"method": "POST",
"number": "order_no",
"id": "stockout_id",
"formatResponse": [
{
"old": "consign_time",
"new": "consign_date",
"format": "date"
}
],
"beatFlat": ["details_list"],
"pagination": {
"pageSize": 100
},
"idCheck": true,
"request": [
{
"field": "start_time",
"label": "开始时间",
"type": "datetime",
"describe": "增量获取数据，start_time作为开始时间，格式：yyyy-MM-dd HH:mm:ss",
"value": "{{LAST_SYNC_TIME|datetime}}"
},
{
"field": "end_time",
"label": "结束时间",
"type": "datetime",
"describe": "增量获取数据，end_time作为结束时间，格式：yyyy-MM-dd HH:mm:ss",
"value": "{{CURRENT_TIME|datetime}}"
},
{
...
}
],
...
}
```
#### 请求参数设置
在请求参数中，我们需要特别关注以下几个字段：
- `start_time` 和 `end_time`: 用于指定增量数据的时间范围。
- `status`: 用于过滤不同状态的订单，例如已取消、已审核、已发货等。
- `shop_no` 和 `warehouse_no`: 用于指定店铺和仓库的编号，从而获取特定范围内的数据。
这些参数确保我们能够灵活地获取所需的数据，并且可以根据业务需求进行调整。
#### 数据格式化与处理
在获取到原始数据后，我们需要对其进行初步加工。例如，将字段`consign_time`转换为`consign_date`，并将其格式化为日期类型。这一步骤可以通过以下配置实现：
```json
{
...
"formatResponse": [
{
"old": "consign_time",
"new": "consign_date",
"format": "date"
}
],
...
}
```
此外，对于嵌套结构的数据（如`details_list`），我们可以使用`beatFlat`配置将其展平，以便后续处理更加方便。
#### 分页处理
由于接口返回的数据量可能较大，我们需要进行分页处理。通过设置分页参数，可以确保每次请求只返回一定数量的数据，从而避免超时或内存溢出的问题。以下是分页配置示例：
```json
{
...
"pagination": {
"pageSize": 100
},
...
}
```
在实际调用过程中，我们需要动态调整分页参数，如当前页码等，以确保能够遍历所有数据。
#### 异常处理与补偿机制
在实际操作中，不可避免会遇到各种异常情况，如网络故障、接口超时等。为了保证数据完整性，我们需要设计相应的补偿机制。例如，通过定时任务（crontab）定期重新拉取前几天的数据，以弥补可能遗漏的数据：
```json
{
...
“omissionRemedy”: {
“crontab”: “2 0 * * *”,
“takeOverRequest”: [
{
“field”: “start_time”,
“label”: “开始时间”,
“type”: “datetime”,
“is_required”: true,
“describe”: “增量获取数据，start_time作为开始时间，格式：yyyy-MM-dd HH:mm:ss”,
“value”: “{{DAYS_AGO_3|datetime}}”
}
]
}
}
```
通过以上配置，可以确保即使在出现异常情况下，也能尽可能保证数据的完整性和准确性。
#### 总结
通过上述步骤，我们可以高效地调用旺店通·企业奇门接口获取销售出库单数据，并对其进行初步加工和处理。这不仅提高了数据集成的效率，还为后续的数据转换和写入奠定了坚实基础。在实际应用中，根据具体业务需求灵活调整各项参数和配置，是确保系统稳定运行的重要保障。
### 使用轻易云数据集成平台进行ETL转换并写入金蝶云星空API接口的技术案例
在数据集成生命周期中，第二步是将已经集成的源平台数据进行ETL转换，并转为目标平台所能够接收的格式。本文将详细探讨如何使用轻易云数据集成平台，将旺店通销售出库单的数据转换并写入金蝶云星空API接口。
#### 配置元数据解析
在本案例中，我们需要将旺店通销售出库单的数据转换为金蝶云星空API接口所能接受的格式。以下是关键的元数据配置：
```json
{
"api": "batchSave",
"method": "POST",
"idCheck": true,
"operation": {
"rowsKey": "array",
"rows": 1,
"method": "batchArraySave"
},
"groupCalculate": {
"headerGroup": ["shop_no", "warehouse_no", "consign_date"],
"bodyGroup": ["details_list_goods_no"],
"bodyName": "details",
"targetBodyName": "FEntity",
"bodyMaxLine": 100,
"calculate": {
"details_list_goods_count": "$sum",
"details_list_paid": "$sum"
}
},
...
}
```
#### 数据请求与清洗
首先，我们需要从旺店通获取销售出库单的数据，并进行清洗和预处理。这一阶段主要是确保数据的准确性和一致性，为后续的转换做好准备。
#### 数据转换与写入
在数据清洗完成后，我们进入数据转换与写入阶段。这里我们使用ETL（Extract, Transform, Load）过程，将清洗后的数据转换为金蝶云星空API所需的格式，并通过API接口将其写入目标平台。
以下是关键字段及其配置：
- **FBillTypeID**: 单据类型，固定值为"WDTXSCKD"。
- **FBillNo**: 单据编号，对应于`{order_no}`。
- **FDate**: 日期，对应于`{consign_date}`。
- **FSaleOrgId**: 销售组织，通过店铺编号查询。
- **FCustomerID**: 客户，对应于`{shop_no}`。
- **FSaleDeptID**: 销售部门，通过解析器获取。
- **FStockOrgId**: 发货组织，通过店铺编号查询。
- **FNOTE**: 备注信息。
明细信息（FEntity）部分：
- **FMaterialID**: 物料编码，使用`TRIM`函数去除空格后，通过解析器获取。
- **FRealQty**: 实发数量，计算字段`{{details.details_list_goods_count}}`。
- **FEntryTaxRate**: 税率，对应于`{tax_rate}`。
- **FTaxPrice**: 含税单价，使用`round`函数计算单价。
- **FStockID**: 仓库，通过解析器获取。
- **FStockStatusID**: 库存状态，固定值为"KCZT01_SYS"。
财务信息（SubHeadEntity）部分：
- **FSettleOrgID**: 结算组织，通过店铺编号查询。
- **FSETTLECURRID**: 结算币别，固定值为"PRE001"。
其他配置项包括业务对象表单Id、执行操作、是否自动提交并审核等。
#### API请求示例
以下是一个完整的API请求示例，用于将处理后的销售出库单数据写入金蝶云星空：
```json
{
"FormId": "SAL_OUTSTOCK",
"Operation": "Save",
...
"Model": {
...
"FBillTypeID": {"FNumber":"WDTXSCKD"},
...
"SubHeadEntity":{
...
{"field":"FSettleOrgID","value":"..."},
{"field":"FSETTLECURRID","value":"PRE001"}
...
},
...
{"field":"FEntity","children":[
{"field":"FMaterialID","value":"..."},
{"field":"FRealQty","value":"..."},
...
]}
}
}
```
通过上述配置和请求示例，我们可以实现从旺店通到金蝶云星空的数据无缝对接。利用轻易云数据集成平台，我们不仅可以高效地完成ETL过程，还能确保每个环节的数据准确性和一致性，从而提升整体业务效率。
