### 04-ToB销售出库单集成方案-P-T：旺店通·旗舰奇门数据对接金蝶云星空实战分享
在本案例中，我们将探讨如何通过`04-ToB销售出库单集成方案-P-T`，实现旺店通·旗舰奇门的数据高效、可靠地集成到金蝶云星空系统。整个方案的关键在于确保数据不漏单，大量数据能够快速写入，并处理好接口分页与限流，以及两种系统之间的数据格式差异。
首先，通过调用旺店通·旗舰奇门的API `wdt.wms.stockout.sales.querywithdetail`，我们能够定时可靠地抓取销售出库单及其详细信息。这一步骤至关重要，因为准确全面地获取源数据是后续所有操作的基础。
然后，在我们进行读取之后，需要解决大量数据快速写入到金蝶云星空的问题。这里使用的是金蝶云提供的批量保存接口 `batchSave`，该接口支持大规模、高频次的数据写入，但需要注意API调用次数和有限制流的问题。为了优化性能和避免超时，我们设计了分页处理策略，同时配置了必要的异常处理机制，包括重试逻辑，以保障系统稳定性。
除了性能层面的考量，还需处理两个平台之间的数据格式差异。例如，旺店通·旗舰奇门返回的数据可能包含诸如字符串类型，而金蝶云星空所需的是特定数值或日期格式。在这一过程中，自定义映射规则变得尤为重要，将原始数据转换为符合目标需求的结构，这样才能确保最终写入操作顺利完成，不会出现字段缺失或错误类型等问题。
最后，通过设置实时监控和日志记录，实现对整个集成过程中的每一个步骤进行追踪。一旦发生任何错误或者异常状况，可以迅速定位并采取相应措施，从而保证系统整体运行的可靠性与透明度。
以上只是该技术方案的一部分核心内容，在具体实施过程中还涵盖更多细节，例如权限管理、网络安全措施等，它们同样不可忽视。下一步将详细分解每个步骤并介绍实际代码实现。
### 调用旺店通·旗舰奇门接口获取并加工数据
在数据集成过程中，调用源系统接口是至关重要的一步。本文将详细探讨如何通过轻易云数据集成平台调用旺店通·旗舰奇门接口`wdt.wms.stockout.sales.querywithdetail`获取销售出库单数据，并进行初步加工。
#### 接口调用配置
首先，我们需要配置接口的元数据。根据提供的元数据配置，我们可以看到该接口使用POST方法，主要参数包括分页参数和业务参数。
```json
{
"api": "wdt.wms.stockout.sales.querywithdetail",
"method": "POST",
"number": "order_no",
"id": "stockout_id",
"idCheck": true,
"request": [
{
"field": "pager",
"label": "分页参数",
"type": "object",
"children": [
{
"field": "page_size",
"label": "分页大小",
"type": "int",
"value": "50",
"parent": "pager"
},
{
"field": "page_no",
"label": "页号",
"type": "int",
"value": 1,
"parent": "pager"
}
]
},
{
"field": "params",
...
}
],
...
}
```
#### 分页参数设置
分页参数用于控制每次请求返回的数据量和页码。默认情况下，`page_size`设置为50，`page_no`设置为1。这意味着每次请求将返回最多50条记录，从第一页开始。
```json
{
...
{
"field": "pager",
...
{
"field": "page_size",
...
},
{
...
}
]
},
...
}
```
#### 业务参数设置
业务参数包括时间范围、出库单状态、仓库编码等。以下是一些关键字段的配置：
- `start_time` 和 `end_time`: 用于指定查询的时间范围。
- `status_type` 和 `status`: 用于过滤特定状态的出库单。
- `warehouse_no`: 指定仓库编码。
- `shop_nos`: 可以指定多个店铺编号，用英文逗号分隔。
```json
{
...
{
...
{
...
},
{
...
}
]
},
{
...
{
...
},
{
...
}
]
}
}
```
#### 条件过滤
为了确保获取的数据符合业务需求，我们还需要设置条件过滤。例如，我们可以通过`platform_id`、`src_trade_no`和`shop_no`等字段进行过滤。
```json
{
...
],
condition: [
[
{"field":"platform_id","logic":"eqv2","value":"127"},
{"field":"src_trade_no","logic":"notlike","value":"BCKSQD"},
{"field":"src_trade_no","logic":"notlike","value":"B_CKSQD"},
{"field":"src_trade_no","logic":"notlike","value":"CKSQ"},
{"field":"shop_no","logic":"neqv2","value":"B0887"},
{"field":"src_trade_no","logic":"notlike","value":"ZPD"}
],
[
{"field":"platform_id","logic":"eqv2","value":"127"},
{"field":"src_trade_no","logic":"like","value":"BFH"},
{"field":"shop_no","logic":"neqv2","value":"B0887"},
{"field":"shop_no","logic":"neqv2","value":"B0002"},
{"field":"src_trade_no","logic":"notlike","value":"ZPD"}
]
]
}
```
#### 数据请求与清洗
在完成上述配置后，我们可以通过轻易云平台发起API请求，获取原始数据。接下来，需要对这些数据进行清洗和初步加工。例如，可以去除无效字段、标准化时间格式、处理缺失值等。
```python
def clean_data(raw_data):
# 示例代码：清洗原始数据
cleaned_data = []
for record in raw_data:
if record['status'] == '110': # 根据具体业务逻辑过滤
cleaned_record = {
'order_no': record['order_no'],
'stockout_id': record['stockout_id'],
'warehouse_no': record['warehouse_no'],
'shop_nos': record['shop_nos'].split(','),
# 更多字段处理...
}
cleaned_data.append(cleaned_record)
return cleaned_data
```
通过上述步骤，我们成功调用了旺店通·旗舰奇门接口并对返回的数据进行了初步清洗和加工。这为后续的数据转换与写入奠定了基础。
### 使用轻易云数据集成平台将销售出库单数据转换并写入金蝶云星空API接口
在数据集成生命周期的第二步中，主要任务是将已经集成的源平台数据进行ETL（Extract, Transform, Load）转换，并将其转为目标平台金蝶云星空API接口所能够接收的格式，最终写入目标平台。本文将详细探讨这一过程中的技术细节和实现方法。
#### 数据请求与清洗
首先，通过轻易云数据集成平台，我们已经从源系统获取了原始数据。这些数据可能包括订单编号、发货时间、客户信息、商品明细等。接下来，我们需要对这些数据进行清洗和转换，以符合金蝶云星空API的要求。
#### 数据转换与写入
为了将清洗后的数据写入金蝶云星空，我们需要遵循其API接口规范。以下是一个典型的元数据配置示例，该配置定义了如何将源系统的数据字段映射到金蝶云星空API所需的字段格式。
```json
{
"api": "batchSave",
"method": "POST",
"idCheck": true,
"operation": {
"rowsKey": "array",
"rows": 1,
"method": "batchArraySave"
},
"request": [
{
"field": "FBillTypeID",
"label": "单据类型",
"type": "string",
"describe": "单据类型",
"value": "XSCKD01_SYS",
"parser": {
"name": "ConvertObjectParser",
"params": "FNumber"
}
},
{
...
}
],
...
}
```
#### 核心字段解析
1. **单据类型（FBillTypeID）**：
- 配置中指定了固定值`XSCKD01_SYS`，并使用`ConvertObjectParser`进行对象转换。
2. **单据编号（FBillNo）**：
- 映射到源系统中的订单编号`{order_no}`。
3. **日期（FDate）**：
- 映射到源系统中的发货时间`{consign_time}`。
4. **发货组织（FStockOrgId）**：
- 使用查询语句从源系统中获取发货组织编码，并通过`ConvertObjectParser`进行转换。
```sql
_findCollection find FDeliveryOrgID_FNumber from ... where FBillNo={src_trade_no}
```
5. **客户（FCustomerID）**：
- 映射到客户编号`{shop_no}`，并通过`ConvertObjectParser`进行转换。
6. **明细信息（FEntity）**：
- 明细信息是一个数组，其中包含多个子字段，如物料编码、实发数量、含税单价等。
```json
{
...
{
"field": "FMaterialID",
...
"value": "{{details_list.goods_no}}"
},
...
{
...
"field": "FTaxPrice",
...
"_findCollection find FTAXPRICE from ... where FBillNo={src_trade_no} FMaterialID_Fnumber={{details_list.goods_no}}"
}
...
}
```
7. **财务信息（SubHeadEntity）**：
- 包含结算组织、结算币别等信息，同样使用查询语句从源系统中获取相应的数据。
8. **其他必要字段**：
- 如物流单号、订单状态等，都根据具体业务需求映射到相应的源系统字段。
#### API调用与验证
配置完成后，通过HTTP POST请求将处理后的数据发送到金蝶云星空的API接口。以下是一个简化的请求示例：
```json
{
"FormId": "SAL_OUTSTOCK",
...
"Model": {
...
// 包含所有映射后的字段
},
...
}
```
为了确保数据准确性，可以启用基础资料验证选项：
```json
{
...
{"field":"IsVerifyBaseDataField","label":"验证基础资料","type":"bool","value":"true"}
}
```
#### 实时监控与错误处理
在整个过程中，轻易云数据集成平台提供了实时监控功能，可以随时查看数据流动和处理状态。如果出现错误，可以通过日志和错误报告快速定位问题并进行修正。
以上就是使用轻易云数据集成平台将销售出库单数据转换并写入金蝶云星空API接口的详细技术实现方法。通过这种方式，可以实现不同系统间的数据无缝对接，提高业务效率和透明度。
