markdown

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

### 销售出库单对接销售订单(线下)-p：旺店通·企业奇门数据集成到用友BIP

在现代企业的运营过程中，数据的高效流动和准确处理至关重要。本文将聚焦于一个具体的系统对接集成案例，即如何通过轻易云数据集成平台，将旺店通·企业奇门的数据无缝集成到用友BIP中，实现销售出库单对接销售订单(线下)-p。

为了确保数据在不同系统之间的顺畅传输，我们采用了旺店通·企业奇门提供的API接口`wdt.stockout.order.query.trade`来获取销售出库单数据，并利用用友BIP的API接口`/yonbip/sd/voucherorder/singleSave`进行数据写入。在这个过程中，轻易云平台发挥了其强大的高吞吐量数据写入能力，使得大量数据能够快速被处理和传输，大大提升了业务时效性。

此外，通过集中监控和告警系统，我们可以实时跟踪每个数据集成任务的状态和性能，确保任何异常情况都能及时发现并处理。这种实时监控机制不仅提高了系统运行的透明度，还为后续问题排查提供了有力支持。

为了适应特定业务需求，我们还自定义了数据转换逻辑，以解决旺店通·企业奇门与用友BIP之间的数据格式差异问题。同时，针对分页和限流等技术难点，我们设计了一套可靠的数据抓取策略，确保每一笔交易都能准确无误地被捕捉和处理。

最后，为了进一步优化资源利用率，我们通过统一视图和控制台全面掌握API资产使用情况，实现资源的高效配置。这不仅简化了管理流程，还显著提升了整体运营效率。

以上是本次技术案例分享的开篇部分，接下来我们将详细探讨具体实施方案及技术细节。
![钉钉与WMS系统接口开发配置](https://pic.qeasy.cloud/D25.png)

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

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

在数据集成的生命周期中，调用源系统接口是至关重要的一步。本文将详细探讨如何通过轻易云数据集成平台调用旺店通·企业奇门接口`wdt.stockout.order.query.trade`，并对获取的数据进行初步加工处理。

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

首先，我们需要配置接口的元数据。根据提供的元数据配置，可以看到该接口采用POST方法，并且支持分页查询。以下是关键的请求参数：

- `start_time` 和 `end_time`: 用于增量获取数据，分别表示开始时间和结束时间。
- `status`: 表示订单状态，如已取消、已审核、已发货等。
- `shop_no`: 店铺编号，用于区分不同店铺的数据。
- `warehouse_no`: 仓库编号，用于区分不同仓库的数据。

此外，还包括分页参数`page_size`和`page_no`，用于控制每次请求返回的数据条数和页号。

#### 数据请求与清洗

在实际操作中，我们需要按照以下步骤进行数据请求与清洗：

1. **构建请求报文**：根据元数据配置，构建包含必要字段的请求报文。例如：
   ```json
   {
       "start_time": "{{LAST_SYNC_TIME|datetime}}",
       "end_time": "{{CURRENT_TIME|datetime}}",
       "status": "95",
       "shop_no": "SJ002",
       "warehouse_no": "WH001",
       "page_size": 100,
       "page_no": 0
   }
   ```

2. **发送请求**：使用轻易云平台提供的HTTP客户端功能发送POST请求到旺店通·企业奇门API端点。

3. **处理响应**：接收到响应后，需要对返回的数据进行初步清洗。例如，将日期字段格式化为新的字段名：
   ```json
   {
       "consign_time_new": formatDate(response.consign_time)
   }
   ```

4. **分页处理**：由于API支持分页查询，需要循环发送多个请求以获取全部数据。在每次请求中更新`page_no`参数，直到所有页面的数据都被获取完毕。

#### 数据转换与写入

在完成初步清洗后，需要将数据转换为目标系统所需的格式，并写入目标数据库或系统。这一步通常涉及复杂的数据映射和转换逻辑，例如：

- 将源系统中的字段名映射到目标系统中的字段名。
- 根据业务需求对某些字段进行计算或重新编码。

例如，将出库单号从源系统映射到目标系统时可能需要进行格式转换或添加前缀，以符合目标系统的要求。

#### 异常处理与监控

为了确保整个过程的可靠性和稳定性，需要实现异常处理机制和实时监控。例如：

- **异常重试机制**：当网络故障或API限流导致请求失败时，可以设置重试策略，以确保最终成功获取数据。
- **实时监控与告警**：通过轻易云平台提供的监控工具，实时跟踪每个任务的执行状态。一旦发现异常情况（如长时间无响应、错误率过高），立即触发告警通知相关人员进行处理。

#### 自定义转换逻辑

针对特定业务需求，可以在轻易云平台上编写自定义脚本，实现复杂的数据转换逻辑。例如，对于某些特殊订单状态，需要根据业务规则重新计算订单总金额或调整库存数量。这些自定义逻辑可以灵活地嵌入到数据集成流程中，提高整体解决方案的适应性和灵活性。

综上所述，通过合理配置元数据、精确构建请求报文、有效处理响应以及完善的异常处理机制，可以高效地调用旺店通·企业奇门接口并对获取的数据进行加工，为后续的数据转换与写入奠定坚实基础。
![数据集成平台API接口配置](https://pic.qeasy.cloud/S12.png)

![企业微信与OA系统接口开发配置](https://pic.qeasy.cloud/QEASY/A12.png)

### 将源平台数据转换为用友BIPAPI接口格式并写入目标平台

在数据集成的生命周期中，ETL（Extract, Transform, Load）转换是关键的一步。将已经集成的源平台数据转化为目标平台所能接收的格式，并最终写入目标平台，是数据集成的核心环节。本文将详细探讨如何通过轻易云数据集成平台，将销售出库单数据转换为用友BIPAPI接口能够接收的格式，并写入用友BIP系统。

#### 数据请求与清洗

在数据请求阶段，我们通过调用旺店通·企业奇门接口`wdt.stockout.order.query.trade`获取销售出库单数据。为了确保数据完整性和一致性，需要处理分页和限流问题，保证所有订单都能被准确抓取。

#### 数据转换与映射

获取到源平台的数据后，下一步是将这些数据转换为用友BIPAPI接口所能接收的格式。这一步骤涉及到对字段的映射、数据类型的转换以及特定业务逻辑的处理。

##### 字段映射与转换

以下是一些关键字段及其转换逻辑：

- **resubmitCheckKey**：保证请求的幂等性，通过组合`src_order_no`和固定字符串生成唯一值。
  ```plaintext
  {src_order_no}-2
  ```

- **salesOrgId**：销售组织，通过映射表根据`shop_no`查找对应的销售组织ID或代码。
  ```plaintext
  _findCollection find mapping_sale_org from ... where shop_no={shop_no}
  ```

- **transactionTypeId**：交易类型，直接指定固定值。
  ```plaintext
  SO021
  ```

- **vouchdate**：单据日期，直接从源数据中提取并保持格式一致。
  ```plaintext
  {consign_time_new}
  ```

- **orderDetails**：销售订单子表，这部分包含多个字段，需要逐一进行映射和转换。例如：
  - `stockId`：仓库，通过映射表根据`warehouse_no`查找对应仓库ID或代码。
    ```plaintext
    {{details_list.warehouse_no}}
    ```
  
  - `productId`：商品，通过映射表根据`spec_no`查找对应商品ID或代码。
    ```plaintext
    {{details_list.spec_no}}
    ```

##### 自定义逻辑处理

有些字段需要自定义逻辑进行处理，例如：

- **orderDetailPrices!natSum**：本币含税金额，需要通过函数计算得到。
  ```plaintext
  _function round({{details_list.total_amount}},2)
  ```

- **orderDetailPrices!oriTax**：税额，通过计算无税金额和含税金额的差值得到。
  ```plaintext
  _function abs(round({{details_list.total_amount}}/(1+{{details_list.tax_rate}}),2)-round({{details_list.total_amount}},2))
  ```

#### 数据写入目标平台

完成数据转换后，使用POST方法将处理后的数据写入用友BIP系统。调用API接口`/yonbip/sd/voucherorder/singleSave`进行单据保存操作，并在必要时调用批量审核接口进行审核。

```plaintext
POST /yonbip/sd/voucherorder/singleSave
```

为了确保高效的数据写入，可以利用轻易云提供的大量数据快速写入功能，同时设置合适的重试机制以应对可能出现的异常情况。

##### 异常处理与监控

在整个过程中，通过轻易云提供的数据质量监控和异常检测功能，可以实时跟踪每个步骤的数据状态。一旦发现异常，可以及时进行处理和重试，确保数据准确无误地写入目标系统。

#### 总结

通过上述步骤，我们实现了从旺店通·企业奇门系统获取销售出库单数据，并通过ETL过程将其转化为用友BIPAPI接口能够接收的格式，最终成功写入用友BIP系统。在这个过程中，灵活运用了轻易云的数据转换、字段映射、自定义逻辑处理以及异常监控等功能，实现了高效稳定的数据集成。
![如何对接金蝶云星空API接口](https://pic.qeasy.cloud/T15.png)

![用友BIP接口开发配置](https://pic.qeasy.cloud/QEASY/A1.png)

用友BIP与旺店通数据集成实现销售出库单对接销售订单

销售出库单对接销售订单(线下)-p：旺店通·企业奇门数据集成到用友BIP

为了确保数据在不同系统之间的顺畅传输，我们采用了旺店通·企业奇门提供的API接口wdt.stockout.order.query.trade来获取销售出库单数据，并利用用友BIP的API接口/yonbip/sd/voucherorder/singleSave进行数据写入。在这个过程中，轻易云平台发挥了其强大的高吞吐量数据写入能力，使得大量数据能够快速被处理和传输，大大提升了业务时效性。

以上是本次技术案例分享的开篇部分，接下来我们将详细探讨具体实施方案及技术细节。钉钉与WMS系统接口开发配置

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

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

在数据集成的生命周期中，调用源系统接口是至关重要的一步。本文将详细探讨如何通过轻易云数据集成平台调用旺店通·企业奇门接口wdt.stockout.order.query.trade，并对获取的数据进行初步加工处理。

接口配置与请求参数

首先，我们需要配置接口的元数据。根据提供的元数据配置，可以看到该接口采用POST方法，并且支持分页查询。以下是关键的请求参数：

start_time 和 end_time: 用于增量获取数据，分别表示开始时间和结束时间。
status: 表示订单状态，如已取消、已审核、已发货等。
shop_no: 店铺编号，用于区分不同店铺的数据。
warehouse_no: 仓库编号，用于区分不同仓库的数据。

此外，还包括分页参数page_size和page_no，用于控制每次请求返回的数据条数和页号。

数据请求与清洗

在实际操作中，我们需要按照以下步骤进行数据请求与清洗：

构建请求报文：根据元数据配置，构建包含必要字段的请求报文。例如：

{
   "start_time": "{{LAST_SYNC_TIME|datetime}}",
   "end_time": "{{CURRENT_TIME|datetime}}",
   "status": "95",
   "shop_no": "SJ002",
   "warehouse_no": "WH001",
   "page_size": 100,
   "page_no": 0
}

发送请求：使用轻易云平台提供的HTTP客户端功能发送POST请求到旺店通·企业奇门API端点。
处理响应：接收到响应后，需要对返回的数据进行初步清洗。例如，将日期字段格式化为新的字段名：
```
{
   "consign_time_new": formatDate(response.consign_time)
}
```
分页处理：由于API支持分页查询，需要循环发送多个请求以获取全部数据。在每次请求中更新page_no参数，直到所有页面的数据都被获取完毕。

数据转换与写入

在完成初步清洗后，需要将数据转换为目标系统所需的格式，并写入目标数据库或系统。这一步通常涉及复杂的数据映射和转换逻辑，例如：

将源系统中的字段名映射到目标系统中的字段名。
根据业务需求对某些字段进行计算或重新编码。

例如，将出库单号从源系统映射到目标系统时可能需要进行格式转换或添加前缀，以符合目标系统的要求。

异常处理与监控

为了确保整个过程的可靠性和稳定性，需要实现异常处理机制和实时监控。例如：

异常重试机制：当网络故障或API限流导致请求失败时，可以设置重试策略，以确保最终成功获取数据。
实时监控与告警：通过轻易云平台提供的监控工具，实时跟踪每个任务的执行状态。一旦发现异常情况（如长时间无响应、错误率过高），立即触发告警通知相关人员进行处理。

自定义转换逻辑

综上所述，通过合理配置元数据、精确构建请求报文、有效处理响应以及完善的异常处理机制，可以高效地调用旺店通·企业奇门接口并对获取的数据进行加工，为后续的数据转换与写入奠定坚实基础。数据集成平台API接口配置

企业微信与OA系统接口开发配置

将源平台数据转换为用友BIPAPI接口格式并写入目标平台

数据请求与清洗

在数据请求阶段，我们通过调用旺店通·企业奇门接口wdt.stockout.order.query.trade获取销售出库单数据。为了确保数据完整性和一致性，需要处理分页和限流问题，保证所有订单都能被准确抓取。

数据转换与映射

字段映射与转换

以下是一些关键字段及其转换逻辑：

resubmitCheckKey：保证请求的幂等性，通过组合src_order_no和固定字符串生成唯一值。
```
{src_order_no}-2
```
salesOrgId：销售组织，通过映射表根据shop_no查找对应的销售组织ID或代码。
```
_findCollection find mapping_sale_org from ... where shop_no={shop_no}
```
transactionTypeId：交易类型，直接指定固定值。
```
SO021
```
vouchdate：单据日期，直接从源数据中提取并保持格式一致。
```
{consign_time_new}
```
orderDetails：销售订单子表，这部分包含多个字段，需要逐一进行映射和转换。例如：
- stockId：仓库，通过映射表根据warehouse_no查找对应仓库ID或代码。
```
{{details_list.warehouse_no}}
```
- productId：商品，通过映射表根据spec_no查找对应商品ID或代码。
```
{{details_list.spec_no}}
```

自定义逻辑处理

有些字段需要自定义逻辑进行处理，例如：

orderDetailPrices!natSum：本币含税金额，需要通过函数计算得到。
```
_function round({{details_list.total_amount}},2)
```

orderDetailPrices!oriTax：税额，通过计算无税金额和含税金额的差值得到。

_function abs(round({{details_list.total_amount}}/(1+{{details_list.tax_rate}}),2)-round({{details_list.total_amount}},2))

数据写入目标平台

完成数据转换后，使用POST方法将处理后的数据写入用友BIP系统。调用API接口/yonbip/sd/voucherorder/singleSave进行单据保存操作，并在必要时调用批量审核接口进行审核。

POST /yonbip/sd/voucherorder/singleSave

为了确保高效的数据写入，可以利用轻易云提供的大量数据快速写入功能，同时设置合适的重试机制以应对可能出现的异常情况。

异常处理与监控

总结

通过上述步骤，我们实现了从旺店通·企业奇门系统获取销售出库单数据，并通过ETL过程将其转化为用友BIPAPI接口能够接收的格式，最终成功写入用友BIP系统。在这个过程中，灵活运用了轻易云的数据转换、字段映射、自定义逻辑处理以及异常监控等功能，实现了高效稳定的数据集成。如何对接金蝶云星空API接口

用友BIP接口开发配置