markdown

![](https://pic.qeasy.cloud/QEASY/A7.png)

### 旺店通·企业奇门数据集成到用友BIP的技术案例分享

在本次技术案例中，我们将探讨如何通过轻易云数据集成平台，实现旺店通·企业奇门系统中的采购退货单数据高效、准确地集成到用友BIP系统中，并生成相应的采购入库单。该方案命名为“采购退货单=>采购入库单(下推)-p”，旨在优化企业的供应链管理流程。

首先，针对旺店通·企业奇门的数据获取，我们使用了其提供的API接口`wdt.stockout.order.query.return`，确保能够定时可靠地抓取所需的采购退货单数据。为了保证数据不漏单，我们设计了一套完善的数据质量监控和异常检测机制，及时发现并处理任何潜在的问题。

接下来，在数据写入用友BIP系统时，我们利用其API接口`/yonbip/scm/purinrecord/mergeSourceData/save`进行批量数据写入操作。得益于轻易云平台支持高吞吐量的数据写入能力，大量数据能够快速被集成到用友BIP系统中，从而大幅提升了整体处理效率。

此外，为了应对两大系统之间的数据格式差异，我们自定义了一系列的数据转换逻辑，使得每条记录都能无缝对接。同时，通过可视化的数据流设计工具，整个数据集成过程变得更加直观和易于管理。

实时监控与日志记录功能也是本次方案的一大亮点。我们通过集中监控和告警系统，实时跟踪每个数据集成任务的状态和性能，确保所有操作都在预期范围内进行。一旦出现异常情况，还可以通过错误重试机制进行自动修复，进一步提高了系统的稳定性和可靠性。

总之，本次技术案例展示了如何利用轻易云平台强大的功能特性，高效实现旺店通·企业奇门与用友BIP之间的数据对接，为企业提供了一种可靠且高效的数据集成解决方案。在后续章节中，我们将详细介绍具体的实施步骤及技术细节。
![金蝶云星空API接口配置](https://pic.qeasy.cloud/D28.png)

![如何对接金蝶云星空API接口](https://pic.qeasy.cloud/QEASY/A24.png)

### 调用旺店通·企业奇门接口wdt.stockout.order.query.return获取并加工数据

在集成方案中，第一步是调用源系统旺店通·企业奇门接口`wdt.stockout.order.query.return`以获取采购退货单的数据，并进行初步的加工处理。以下将详细探讨这一过程中涉及的技术细节和实现方法。

#### 接口调用与请求参数配置

为了从旺店通·企业奇门系统中获取采购退货单数据，我们需要配置相应的API请求参数。根据提供的元数据配置，可以看到该接口采用POST方法，主要参数包括开始时间、结束时间、仓库编号、出库单状态等。

```json
{
  "api": "wdt.stockout.order.query.return",
  "method": "POST",
  "number": "order_no",
  "id": "stockout_id",
  "pagination": {
    "pageSize": 50
  },
  "idCheck": true,
  ...
}
```

这些参数确保了我们能够按需查询到所需的数据。例如，通过设置`start_time`和`end_time`来实现增量数据抓取，避免重复处理已同步的数据。同时，通过分页参数（如`page_no`和`page_size`）来控制每次请求返回的数据量，从而有效管理大批量数据的处理。

#### 数据清洗与预处理

在成功调用API并获取到原始数据后，需要对数据进行清洗和预处理。这一步骤至关重要，因为它直接影响后续的数据转换与写入过程。常见的清洗操作包括：

1. **去重**：通过检查唯一标识符（如订单号或出库单ID），确保没有重复记录。
2. **格式化**：将日期、数值等字段转换为统一格式，以便于后续处理。
3. **过滤**：根据业务需求过滤掉不必要的数据，例如只保留状态为“已发货”或“已完成”的记录。

#### 分页与限流处理

由于接口返回的数据量可能较大，因此需要特别注意分页和限流问题。通过设置合理的分页大小（如每页50条记录），可以有效降低单次请求的负载。此外，还需要考虑API调用频率限制，避免因过于频繁的请求导致被封禁或限流。

```json
{
  "field": "page_no",
  "label": "页号",
  ...
},
{
  "field": "page_size",
  ...
}
```

在实际操作中，可以使用循环或递归方式逐页抓取数据，并结合轻易云平台提供的异步任务调度功能，实现定时可靠的数据抓取。

#### 数据质量监控与异常检测

为了确保集成过程中的数据质量，需要实时监控和检测异常情况。例如，在每次API调用后检查返回结果是否包含错误信息，如果有则记录日志并触发告警机制。同时，可以设置重试策略，对于临时性错误进行自动重试，以提高整体稳定性。

轻易云平台提供了集中监控和告警系统，使得我们能够实时跟踪每个数据集成任务的状态和性能。一旦发现异常情况，可以及时采取措施，确保整个流程顺利进行。

#### 自定义转换逻辑与映射规则

在完成初步清洗后，根据业务需求可能还需要对数据进行进一步转换。例如，将旺店通·企业奇门系统中的字段映射到用友BIP系统对应字段，这就需要自定义转换逻辑。在轻易云平台上，可以通过可视化工具设计这些转换规则，使得整个过程更加直观且易于管理。

综上所述，通过合理配置API请求参数、实施有效的数据清洗与预处理、妥善解决分页与限流问题，以及加强数据质量监控，我们可以高效地从旺店通·企业奇门系统中获取并加工采购退货单数据，为后续的数据转换与写入奠定坚实基础。
![企业微信与OA系统接口开发配置](https://pic.qeasy.cloud/S6.png)

![用友与WMS系统接口开发配置](https://pic.qeasy.cloud/QEASY/A78.png)

### 将采购退货单数据转换为用友BIP采购入库单数据并写入目标平台

在数据集成过程中，ETL（Extract, Transform, Load）是至关重要的一环。本文将重点探讨如何将已经集成的采购退货单数据进行ETL转换，使其符合用友BIP API接口的要求，并最终写入目标平台。

#### 数据请求与清洗

首先，从源系统获取采购退货单的数据。这一步通常涉及调用源系统API接口，并对返回的数据进行初步清洗和过滤，以确保数据的完整性和准确性。例如，通过分页和限流技术，确保在高并发情况下也能稳定地获取数据。

#### 数据转换

接下来，我们进入数据生命周期的第二步：将清洗后的数据进行转换，以符合用友BIP API接口的格式要求。以下是具体的转换步骤和技术细节：

1. **幂等性保证**：
   为了确保请求的幂等性，客户端需要生成一个全局唯一且长度不超过32位的`resubmitCheckKey`。该值通常由订单编号加上特定后缀生成，如`{order_no}_1`。

2. **合并上游数据**：
   固定传入值`true`，以确保上游数据能够被正确合并。

3. **表体行计算标识**：
   固定传入值`true`，以启用表体行的计算功能，并指定计算依据为含税单价，即字段`oriTaxUnitPrice`。

4. **单据编号和日期**：
   单据编号根据系统配置决定是否必输，而单据日期需要按照YYYYMMDD格式传入，例如使用模板变量`{{consign_time|date}}`。

5. **交易类型、仓库和备注**：
   交易类型ID或代码、仓库ID或代码以及备注信息分别通过对应字段传入，如交易类型ID为固定值A20003，仓库ID为`{warehouse_no}`，备注为`{remark}`。

6. **子表信息**：
   子表包含多个字段，其中较为关键的是生单规则编码、上游单据主表ID、子表ID、数量、无税单价、含税单价及备注等。
   
   - 生单规则编码固定传入值为`st_purchaseorder_return`。
   - 上游主表ID和子表ID通过MongoDB查询获取，例如：
     ```plaintext
     _mongoQuery 39bc45c8-c417-37df-8f20-d136f76b1a7a findField=content.new_id where={"content.code":{"$eq":"{pr_api_outer_no}"},"content.product_cCode":{"$eq":"{{details_list.goods_no}}"}}
     ```
   - 数量取负值以表示退货数量，如通过函数计算：`_function {{details_list.goods_count}}*(-1)`。
   - 无税单价直接从详情列表中提取：`{{details_list.sell_price}}`。
   - 含税单价同样通过MongoDB查询获取： 
     ```plaintext
     _mongoQuery 39bc45c8-c417-37df-8f20-d136f76b1a7a findField=content.oriTaxUnitPrice where={"content.code":{"$eq":"{pr_api_outer_no}"},"content.product_cCode":{"$eq":"{{details_list.goods_no}}"}}
     ```
   - 备注信息直接从详情列表中提取：`{{details_list.remark}}`。

#### 数据写入

完成数据转换后，通过用友BIP API接口将处理后的数据写入目标平台。具体API调用如下：

```plaintext
POST /yonbip/scm/purinrecord/mergeSourceData/save
```

在发送请求时，需确保所有必填字段均已正确填充，同时设置操作标识为“Insert”以表示新增记录。此外，还需注意以下几点：

- **批量处理**：为了提高效率，可以采用批量处理方式，将多个记录一次性写入目标平台。
- **异常处理与重试机制**：在实际操作中，可能会遇到网络问题或接口异常，这时需要实现异常捕获与重试机制，以确保数据写入的可靠性。
- **实时监控与日志记录**：通过集中的监控和告警系统，实时跟踪数据集成任务的状态和性能，并记录日志以便日后审计和问题排查。

#### 总结

通过上述步骤，我们实现了从源系统采购退货单到用友BIP采购入库单的数据ETL转换，并成功将处理后的数据写入目标平台。这一过程不仅保证了数据的一致性和完整性，还提高了业务流程的自动化程度。
![用友与SCM系统接口开发配置](https://pic.qeasy.cloud/T16.png)

![金蝶与CRM系统接口开发配置](https://pic.qeasy.cloud/QEASY/A66.png)

高效集成：旺店通·企业奇门到用友BIP的数据对接方案

旺店通·企业奇门数据集成到用友BIP的技术案例分享

首先，针对旺店通·企业奇门的数据获取，我们使用了其提供的API接口wdt.stockout.order.query.return，确保能够定时可靠地抓取所需的采购退货单数据。为了保证数据不漏单，我们设计了一套完善的数据质量监控和异常检测机制，及时发现并处理任何潜在的问题。

接下来，在数据写入用友BIP系统时，我们利用其API接口/yonbip/scm/purinrecord/mergeSourceData/save进行批量数据写入操作。得益于轻易云平台支持高吞吐量的数据写入能力，大量数据能够快速被集成到用友BIP系统中，从而大幅提升了整体处理效率。

总之，本次技术案例展示了如何利用轻易云平台强大的功能特性，高效实现旺店通·企业奇门与用友BIP之间的数据对接，为企业提供了一种可靠且高效的数据集成解决方案。在后续章节中，我们将详细介绍具体的实施步骤及技术细节。金蝶云星空API接口配置

如何对接金蝶云星空API接口

调用旺店通·企业奇门接口wdt.stockout.order.query.return获取并加工数据

在集成方案中，第一步是调用源系统旺店通·企业奇门接口wdt.stockout.order.query.return以获取采购退货单的数据，并进行初步的加工处理。以下将详细探讨这一过程中涉及的技术细节和实现方法。

接口调用与请求参数配置

{
  "api": "wdt.stockout.order.query.return",
  "method": "POST",
  "number": "order_no",
  "id": "stockout_id",
  "pagination": {
    "pageSize": 50
  },
  "idCheck": true,
  ...
}

这些参数确保了我们能够按需查询到所需的数据。例如，通过设置start_time和end_time来实现增量数据抓取，避免重复处理已同步的数据。同时，通过分页参数（如page_no和page_size）来控制每次请求返回的数据量，从而有效管理大批量数据的处理。

数据清洗与预处理

去重：通过检查唯一标识符（如订单号或出库单ID），确保没有重复记录。
格式化：将日期、数值等字段转换为统一格式，以便于后续处理。
过滤：根据业务需求过滤掉不必要的数据，例如只保留状态为“已发货”或“已完成”的记录。

分页与限流处理

{
  "field": "page_no",
  "label": "页号",
  ...
},
{
  "field": "page_size",
  ...
}

在实际操作中，可以使用循环或递归方式逐页抓取数据，并结合轻易云平台提供的异步任务调度功能，实现定时可靠的数据抓取。

数据质量监控与异常检测

自定义转换逻辑与映射规则

综上所述，通过合理配置API请求参数、实施有效的数据清洗与预处理、妥善解决分页与限流问题，以及加强数据质量监控，我们可以高效地从旺店通·企业奇门系统中获取并加工采购退货单数据，为后续的数据转换与写入奠定坚实基础。企业微信与OA系统接口开发配置

用友与WMS系统接口开发配置

将采购退货单数据转换为用友BIP采购入库单数据并写入目标平台

数据请求与清洗

数据转换

接下来，我们进入数据生命周期的第二步：将清洗后的数据进行转换，以符合用友BIP API接口的格式要求。以下是具体的转换步骤和技术细节：

幂等性保证：为了确保请求的幂等性，客户端需要生成一个全局唯一且长度不超过32位的resubmitCheckKey。该值通常由订单编号加上特定后缀生成，如{order_no}_1。
合并上游数据：固定传入值true，以确保上游数据能够被正确合并。
表体行计算标识：固定传入值true，以启用表体行的计算功能，并指定计算依据为含税单价，即字段oriTaxUnitPrice。
单据编号和日期：单据编号根据系统配置决定是否必输，而单据日期需要按照YYYYMMDD格式传入，例如使用模板变量{{consign_time|date}}。
交易类型、仓库和备注：交易类型ID或代码、仓库ID或代码以及备注信息分别通过对应字段传入，如交易类型ID为固定值A20003，仓库ID为{warehouse_no}，备注为{remark}。
子表信息：子表包含多个字段，其中较为关键的是生单规则编码、上游单据主表ID、子表ID、数量、无税单价、含税单价及备注等。
- 生单规则编码固定传入值为st_purchaseorder_return。
- 上游主表ID和子表ID通过MongoDB查询获取，例如：
```
_mongoQuery 39bc45c8-c417-37df-8f20-d136f76b1a7a findField=content.new_id where={"content.code":{"$eq":"{pr_api_outer_no}"},"content.product_cCode":{"$eq":"{{details_list.goods_no}}"}}
```
- 数量取负值以表示退货数量，如通过函数计算：_function {{details_list.goods_count}}*(-1)。
- 无税单价直接从详情列表中提取：{{details_list.sell_price}}。
- 含税单价同样通过MongoDB查询获取：
```
_mongoQuery 39bc45c8-c417-37df-8f20-d136f76b1a7a findField=content.oriTaxUnitPrice where={"content.code":{"$eq":"{pr_api_outer_no}"},"content.product_cCode":{"$eq":"{{details_list.goods_no}}"}}
```
- 备注信息直接从详情列表中提取：{{details_list.remark}}。

数据写入

完成数据转换后，通过用友BIP API接口将处理后的数据写入目标平台。具体API调用如下：

POST /yonbip/scm/purinrecord/mergeSourceData/save

在发送请求时，需确保所有必填字段均已正确填充，同时设置操作标识为“Insert”以表示新增记录。此外，还需注意以下几点：

批量处理：为了提高效率，可以采用批量处理方式，将多个记录一次性写入目标平台。
异常处理与重试机制：在实际操作中，可能会遇到网络问题或接口异常，这时需要实现异常捕获与重试机制，以确保数据写入的可靠性。
实时监控与日志记录：通过集中的监控和告警系统，实时跟踪数据集成任务的状态和性能，并记录日志以便日后审计和问题排查。

总结

通过上述步骤，我们实现了从源系统采购退货单到用友BIP采购入库单的数据ETL转换，并成功将处理后的数据写入目标平台。这一过程不仅保证了数据的一致性和完整性，还提高了业务流程的自动化程度。用友与SCM系统接口开发配置

金蝶与CRM系统接口开发配置