### 【类型:盘盈入库】旺店通-入库单管理==>金蝶-其他入库单集成案例
在本篇技术分享中，我们将深入探讨如何使用轻易云数据集成平台，实现旺店通·企业奇门的数据与金蝶云星空的无缝对接。特定任务场景为【类型:盘盈入库】，即通过解锁接口`wdt.stockin.order.query`获取旺店通·企业奇门中的入库单信息，并高效写入到金蝶云星空系统的其它入库单模块。
这一过程中，面临着处理大量数据、确保不漏单以及实现高时效性的挑战。解决方案需要充分利用该平台支持批量数据集成、高吞吐量写入能力及其智能监控和告警系统等强大功能，这些都将帮助我们实时跟踪总体流程并尽早发现异常。
首先，我们调用旺店通·企业奇门接口`wdt.stockin.order.query`来抓取所需的库存订单数据。在这一步骤，需要特别注意接口分页和限流问题，以避免API请求超载。此外，通过自定义的数据转换逻辑，可以有效处理两系统间的数据结构差异，为顺利落地打好基础。
然后，这部分经过清洗和转换后的数据，将被快速且准确地传输至金蝶云星空。这其中涉及API `batchSave` 的调用，重点在于确保高效批量写入，同时规避潜在错误，并配置相应的重试机制以提高整体稳定性。
随之而来的，是详细介绍如何设置实时监控与可靠日志记录。这不仅有助于即时捕捉并修正可能出现的问题，还能为未来类似项目提供宝贵参考，使得整个业务交互链条更加透明、高效。
### 调用旺店通·企业奇门接口获取并加工数据
在数据集成的生命周期中，第一步是从源系统获取数据。本文将深入探讨如何通过调用旺店通·企业奇门接口`wdt.stockin.order.query`来实现这一过程，并对获取的数据进行必要的加工处理。
#### 接口概述
接口`wdt.stockin.order.query`用于查询旺店通系统中的入库单信息。该接口采用POST请求方式，支持按时间增量、单据类别、状态等多种条件进行查询。以下是该接口的主要参数配置：
- **start_time**: 开始时间，按最后修改时间增量获取数据，格式为`yyyy-MM-dd HH:mm:ss`。
- **end_time**: 结束时间，按最后修改时间增量获取数据，格式为`yyyy-MM-dd HH:mm:ss`。
- **order_type**: 单据类别，此处设置为盘盈入库（值为4）。
- **status**: 入库单状态，此处设置为已完成（值为80）。
- **warehouse_no**: 仓库编号，用于区分不同仓库的单据信息。
- **src_order_no**: 上层单据编号，可选参数。
- **stockin_no**: 入库单号，可选参数。
- **outer_no**: 外部API单号，可选参数。
- **page_size**: 分页大小，默认值为40。
- **page_no**: 页号，默认从0页开始。
#### 请求参数配置
在实际应用中，我们需要根据业务需求配置请求参数。以下是一个典型的请求参数配置示例：
```json
{
"start_time": "{{DAYS_AGO_1|datetime}}",
"end_time": "{{CURRENT_TIME|datetime}}",
"order_type": "4",
"status": "80",
"warehouse_no": "WH001",
"page_size": "40",
"page_no": "0"
}
```
上述配置表示查询过去一天内所有已完成的盘盈入库单，并限定在仓库编号为`WH001`的范围内。
#### 数据清洗与转换
获取到原始数据后，需要对其进行清洗和转换，以便后续写入目标系统。在轻易云数据集成平台中，可以通过可视化界面定义数据清洗和转换规则。例如：
1. **字段映射**：将源系统中的字段映射到目标系统所需的字段。例如，将`stockin_id`映射到目标系统中的`id`字段，将`order_no`映射到目标系统中的`number`字段。
2. **数据过滤**：根据业务规则过滤不需要的数据。例如，仅保留状态为已完成的记录。
3. **格式转换**：将日期格式从源系统的格式转换为目标系统所需的格式。
以下是一个简单的数据清洗和转换规则示例：
```json
{
"mappings": [
{"sourceField": "stockin_id", "targetField": "id"},
{"sourceField": "order_no", "targetField": "number"},
{"sourceField": "warehouse_no", "targetField": "warehouseCode"},
{"sourceField": "create_time", "targetField": "createdDate", "format": {"sourceFormat":"yyyy-MM-dd HH:mm:ss", "targetFormat":"yyyyMMdd"}}
],
"filters": [
{"field": "status", "operator": "equals", "value": "80"}
]
}
```
#### 实时监控与异常处理
在数据集成过程中，实时监控和异常处理至关重要。轻易云平台提供了全面的监控功能，可以实时跟踪每个环节的数据流动和处理状态。一旦出现异常，如网络故障或数据格式错误，可以及时报警并采取相应措施。
例如，通过设置告警规则，当某个API调用失败次数超过阈值时，自动发送告警邮件或短信通知相关人员。
```json
{
"alertRules": [
{
"condition": {
"field": "@errorCount",
"operator": ">=",
"value": 5
},
"actions": [
{
"type": "email",
"recipients": ["admin@example.com"],
"subject": "[告警] 数据集成异常",
"bodyTemplateId": "<template_id>"
}
]
}
]
}
```
通过上述技术手段，可以确保从源系统获取的数据准确无误，并顺利完成后续的数据清洗、转换和写入操作。
### 轻易云数据集成平台生命周期第二步：将源平台数据转换并写入金蝶云星空API接口
在数据集成过程中，ETL（Extract, Transform, Load）是关键步骤之一。本文将详细探讨如何利用轻易云数据集成平台，将已经集成的源平台数据进行转换，并通过金蝶云星空API接口写入目标平台。
#### 元数据配置解析
首先，我们需要理解元数据配置中的各个字段及其作用。以下是关键字段的解析：
- **api**: `batchSave` 表示批量保存操作。
- **method**: `POST` 表示使用HTTP POST方法。
- **idCheck**: `true` 表示需要进行ID检查。
- **request**: 包含具体的数据字段配置，每个字段都有其特定的属性和解析方式。
#### 主要字段及其解析
1. **FBillNo (单据编号)**:
- 类型: `string`
- 描述: 单据编号
- 值: `{order_no}`
2. **FBillTypeID (单据类型)**:
- 类型: `string`
- 描述: 单据类型
- 解析器: `ConvertObjectParser`，参数为 `FNumber`
- 固定值: `QTRKD02_SYS`
3. **FStockOrgId (库存组织)**:
- 类型: `string`
- 描述: 组织
- 解析器: `ConvertObjectParser`，参数为 `FNumber`
- 固定值: `100`
4. **FDate (日期)**:
- 类型: `string`
- 描述: 日期
- 值: `{stockin_time}`
5. **FDEPTID (部门)**:
- 类型: `string`
- 描述: 基础资料
- 解析器: `ConvertObjectParser`，参数为 `FNumber`
- 固定值: `BM000003`
6. **FOwnerTypeIdHead (货主类型)**:
- 类型: `string`
- 描述: 多类别基础资料列表
- 固定值: `BD_OwnerOrg`
7. **FOwnerIdHead (货主)**:
- 类型: `string`
- 描述: 多类别基础资料
- 解析器: `ConvertObjectParser`，参数为 `FNumber`
- 固定值: `100`
8. **FNOTE (备注)**:
- 类型: `string`
- 描述: 多行文本
- 值: `{remark}`
9. **FSUPPLIERID (供应商)**:
- 类型：`string`
- 值：`SP001`
- 解析器：`ConvertObjectParser`，参数为`FNumber`
10. **FEntity (明细信息)**:
明细信息是一个数组，每个元素包含以下子字段：
1. **FMATERIALID (物料编码)**:
- 类型：`string`
- 描述：基础资料
- 解析器：`ConvertObjectParser`，参数为`FNumber`
- 值：`{{details_list.spec_no}}`
2. **FSTOCKID (收货仓库)**:
- 类型：`string`
- 描述：基础资料
- 解析器：`ConvertObjectParser`，参数为`FNumber`
- 值：`{warehouse_no}`
3. **FQty (实收数量)**:
- 类型：`string`
- 描述：数量
- 值：`{{details_list.goods_count}}`
4. **FPrice (成本价)**:
- 类型：`string`
- 描述：单价
- 值：`{{details_list.cost_price}}`
5. **FEntryNote (备注)**:
‑ 类型:`string`
‑ 描述:`多行文本`
‑ 值:`{{details_list.remark}}`
6. **FSRCBILLNO (源单编号)**:
‑ 类型:`string`
‑ 描述:`源单编号`
‑ 值:`{trade_no}`
7. **FSRCBILLTYPEID (源单类型)**:
8. **FOWNERTYPEID(货主类型)**
‑ 类型:`string`
‑ 描述:`货主类型`
‑ 值:`BD_OwnerOrg`
9.**FOWNERID(货主)**
‑ 类型:`string`
‑ 描述:`货主`,
解析器:`ConvertObjectParser`,参数为:FNumber,
固定值:`100`
#### API接口调用与数据写入
在完成上述元数据配置后，我们可以使用轻易云的数据集成平台进行实际的数据转换与写入操作。以下是具体步骤：
1. 将源平台的数据按照元数据配置进行映射和转换。
2. 使用HTTP POST方法调用金蝶云星空的API接口，将转换后的数据发送到目标平台。
3. 确保所有必要的字段都已正确填充，并且符合目标平台的要求。
#### 操作细节与注意事项
- 在调用API接口时，需要确保所有基础资料（如组织、部门、物料编码等）都已经在目标系统中存在并有效。
- 使用批量保存操作时，需要特别注意数组中的每个元素是否符合要求，以避免部分数据写入失败。
- 在实际操作中，可以启用日志记录功能，以便在出现问题时能够快速定位和解决。
通过以上步骤，我们可以高效地将源平台的数据转换并写入金蝶云星空，实现不同系统间的数据无缝对接。这不仅提升了业务透明度和效率，也确保了数据处理过程的准确性和可靠性。
