markdown

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

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

在本案例中，我们将详细探讨如何通过轻易云数据集成平台，将旺店通·企业奇门的数据无缝对接到用友BIP系统，具体方案为“采购入库单=>采购入库单(下推)-v”。这一过程不仅需要高效的数据传输能力，还要确保数据的准确性和完整性。

首先，我们利用旺店通·企业奇门提供的API接口`wdt.stockin.order.query.purchase`来获取采购入库单数据。为了保证数据不漏单，我们设置了定时任务，可靠地抓取接口数据，并处理分页和限流问题，以应对大规模数据的传输需求。

在数据传输过程中，轻易云平台提供了强大的高吞吐量写入能力，使得大量数据能够快速被集成到用友BIP系统中。这一特性极大提升了数据处理的时效性，确保业务流程顺畅进行。同时，通过集中监控和告警系统，我们可以实时跟踪每个集成任务的状态和性能，及时发现并解决潜在问题。

为了适应不同系统之间的数据结构差异，我们自定义了数据转换逻辑，并使用可视化的数据流设计工具，使得整个集成过程更加直观和易于管理。在将转换后的数据写入用友BIP时，我们调用了其API接口`/yonbip/scm/purinrecord/mergeSourceData/save`，实现批量集成。

此外，为了确保整个集成过程中的数据质量，我们还配置了异常检测机制。一旦发现异常情况，可以自动触发错误重试机制，从而保证最终写入的数据准确无误。通过这些技术手段，实现了旺店通·企业奇门与用友BIP之间高效、稳定的数据对接。
![用友与MES系统接口开发配置](https://pic.qeasy.cloud/D1.png)

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

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

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

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

首先，我们需要配置接口的元数据，以确保能够正确地从旺店通·企业奇门系统中获取所需的数据。以下是关键的元数据配置：

- **API名称**: `wdt.stockin.order.query.purchase`
- **请求方法**: `POST`
- **分页大小**: 50
- **增量时间范围**: 使用`start_time`和`end_time`字段来指定时间范围，分别对应上次同步时间和当前时间。
- **状态过滤**: 默认值为80，即只获取已完成的入库单。
- **仓库编号**: 用于区分不同仓库的数据。

具体的请求参数如下：
```json
{
  "start_time": "{{LAST_SYNC_TIME|datetime}}",
  "end_time": "{{CURRENT_TIME|datetime}}",
  "status": "80",
  "warehouse_no": "{WAREHOUSE_NO}",
  "page_size": "{PAGINATION_PAGE_SIZE}",
  "page_no": "{PAGINATION_START_PAGE}"
}
```

#### 数据抓取与分页处理

由于接口返回的数据量可能较大，我们需要处理分页问题。每次请求时，通过调整`page_no`参数来逐页抓取数据，直到没有更多数据为止。

1. **初始化分页参数**:
   - 设置初始页号为0。
   - 设置每页返回的数据条数为50。

2. **循环抓取数据**:
   - 每次请求后检查返回的数据条数，如果等于分页大小，则继续下一页；否则终止循环。
   - 更新当前页号，继续下一轮请求。

这种方式确保了我们可以高效、可靠地抓取所有符合条件的数据，而不会遗漏任何一条记录。

#### 数据清洗与转换

在成功获取到原始数据后，需要对其进行清洗和转换，以便后续写入目标系统。在这一过程中，可以利用轻易云平台提供的自定义转换逻辑功能，对特定字段进行格式化或映射。例如：

- 将日期格式统一转换为目标系统所需的格式。
- 对状态码进行重新映射，使其符合目标系统的业务逻辑要求。
- 清理无效或冗余字段，只保留必要的信息。

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

为了确保整个过程顺利进行，实时监控和异常处理机制必不可少。轻易云平台提供了强大的监控和告警功能，可以实时跟踪每个任务的执行状态。一旦出现异常，如网络故障或接口限流问题，可以及时触发告警，并自动重试或采取其他补救措施。

例如，当遇到接口限流问题时，可以通过以下策略进行处理：
1. 增加重试机制，在一定时间间隔后重新发起请求。
2. 动态调整分页大小，以减少单次请求的数据量，从而降低被限流的风险。

#### 总结

通过以上步骤，我们可以高效地调用旺店通·企业奇门接口`wdt.stockin.order.query.purchase`获取采购入库单数据，并对其进行初步加工处理。这不仅提高了数据集成过程中的透明度和效率，也为后续的数据写入和业务应用打下了坚实基础。在实际操作中，还可以根据具体需求进一步优化和定制这些流程，以满足不同场景下的数据集成需求。
![用友与CRM系统接口开发配置](https://pic.qeasy.cloud/S28.png)

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

### 用友BIP采购入库单数据集成方案

在数据集成生命周期的第二步中，我们需要将已经集成的源平台数据进行ETL转换，转为目标平台用友BIPAPI接口所能够接收的格式，并最终写入目标平台。本文将详细探讨如何通过轻易云数据集成平台实现这一过程。

#### 数据转换与写入

在将数据写入用友BIP之前，我们需要确保数据格式符合其API接口要求。以下是几个关键字段的配置和处理方式：

1. **保证请求的幂等性**
   ```json
   {"field":"resubmitCheckKey","value":"{order_no}"}
   ```
   该字段用于确保每个请求都是唯一的，避免重复提交。我们使用订单编号`{order_no}`作为唯一标识。

2. **合并上游数据**
   ```json
   {"field":"mergeSourceData","value":"true"}
   ```
   固定值传入`true`，表示将上游数据进行合并处理。

3. **表体行计算标识及依据**
   ```json
   {"field":"needCalcLines","value":"true"}
   {"field":"calcLinesKey","value":"oriTaxUnitPrice"}
   ```
   这两个字段用于指示系统是否需要对表体行进行计算，以及计算依据字段。这里我们设置为`true`和`oriTaxUnitPrice`。

4. **单据编号和日期**
   ```json
   {"field":"code","value":"{order_no}"}
   {"field":"vouchdate","value":"{{check_time|date}}"}
   ```
   单据编号使用订单编号，单据日期则采用格式化后的检查时间。

5. **交易类型和仓库ID**
   ```json
   {"field":"bustype","value":"A15001"}
   {"field":"warehouse","value":"_findCollection find purchaseOrders_warehouse_code from aaafe9d3-cba3-367f-8b42-1dbd870e0564 where code={src_order_no} product_cCode={{details_list.goods_no}}"}
   ```
   交易类型和仓库ID根据业务规则进行配置，从源系统中提取相应信息。

6. **采购入库单子表配置**
    - **生单规则编码**
      ```json
      {"field":"makeRuleCode","value":"st_purchaseorder"}
      ```
      固定值传入`st_purchaseorder`，表示订单入库。
      
    - **上游单据主表和子表ID**
      ```json
      {"field":"sourceid","value":"_findCollection find new_id from aaafe9d3-cba3-367f-8b42-1dbd870e0564 where code={src_order_no} product_cCode={{details_list.goods_no}}"}
      {"field":"sourceautoid","value":"_findCollection find new_purchaseOrders_id from aaafe9d3-cba3-367f-8b42-1dbd870e0564 where code={src_order_no} product_cCode={{details_list.goods_no}}"}
      ```
      这些字段用于关联上游系统的主表和子表ID。
      
    - **数量和含税单价**
      ```json
      {"field":"qty","value":"{{details_list.right_num}}"}
      {"field":"oriTaxUnitPrice","value":"_findCollection find oriTaxUnitPrice from aaafe9d3-cba3-367f-8b42-1dbd870e0564 where code={src_order_no} product_cCode={{details_list.goods_no}}"}
      ```
      数量直接从详情列表中获取，而含税单价则从源系统中提取。

7. **备注和操作标识**
    ```json
    {"field":"memo","value":"{remark}"}
    {"field":"_status","value":"Insert"}
    ```

#### 调用API接口

完成以上配置后，我们通过POST方法调用用友BIP的API接口，将转换后的数据写入目标平台：
```http
POST /yonbip/scm/purinrecord/mergeSourceData/save
```

#### 数据质量监控与异常处理

为了确保数据集成过程中的质量，我们必须实时监控数据流动，并及时处理异常情况。轻易云平台提供了强大的监控和告警功能，可以帮助我们实时跟踪任务状态。一旦发生错误，可以通过重试机制来确保数据成功写入目标系统。

#### 批量处理与高吞吐量支持

针对大规模的数据集成需求，轻易云平台支持高吞吐量的数据写入能力，使得大量数据能够快速被集成到用友BIP系统中。同时，通过批量处理机制，可以有效提升数据处理效率，减少系统负载。

综上所述，通过合理配置元数据及调用API接口，我们能够高效地将源平台的数据转换并写入到用友BIP，实现跨系统的数据无缝对接。这不仅提升了业务流程的自动化程度，也确保了数据的一致性和准确性。
![企业微信与OA系统接口开发配置](https://pic.qeasy.cloud/T15.png)

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

使用轻易云平台实现旺店通与用友BIP的无缝数据集成

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

首先，我们利用旺店通·企业奇门提供的API接口wdt.stockin.order.query.purchase来获取采购入库单数据。为了保证数据不漏单，我们设置了定时任务，可靠地抓取接口数据，并处理分页和限流问题，以应对大规模数据的传输需求。

为了适应不同系统之间的数据结构差异，我们自定义了数据转换逻辑，并使用可视化的数据流设计工具，使得整个集成过程更加直观和易于管理。在将转换后的数据写入用友BIP时，我们调用了其API接口/yonbip/scm/purinrecord/mergeSourceData/save，实现批量集成。

此外，为了确保整个集成过程中的数据质量，我们还配置了异常检测机制。一旦发现异常情况，可以自动触发错误重试机制，从而保证最终写入的数据准确无误。通过这些技术手段，实现了旺店通·企业奇门与用友BIP之间高效、稳定的数据对接。用友与MES系统接口开发配置

钉钉与WMS系统接口开发配置

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

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

接口配置与请求参数

首先，我们需要配置接口的元数据，以确保能够正确地从旺店通·企业奇门系统中获取所需的数据。以下是关键的元数据配置：

API名称: wdt.stockin.order.query.purchase
请求方法: POST
分页大小: 50
增量时间范围: 使用start_time和end_time字段来指定时间范围，分别对应上次同步时间和当前时间。
状态过滤: 默认值为80，即只获取已完成的入库单。
仓库编号: 用于区分不同仓库的数据。

具体的请求参数如下：

{
  "start_time": "{{LAST_SYNC_TIME|datetime}}",
  "end_time": "{{CURRENT_TIME|datetime}}",
  "status": "80",
  "warehouse_no": "{WAREHOUSE_NO}",
  "page_size": "{PAGINATION_PAGE_SIZE}",
  "page_no": "{PAGINATION_START_PAGE}"
}

数据抓取与分页处理

由于接口返回的数据量可能较大，我们需要处理分页问题。每次请求时，通过调整page_no参数来逐页抓取数据，直到没有更多数据为止。

初始化分页参数:
- 设置初始页号为0。
- 设置每页返回的数据条数为50。
循环抓取数据:
- 每次请求后检查返回的数据条数，如果等于分页大小，则继续下一页；否则终止循环。
- 更新当前页号，继续下一轮请求。

这种方式确保了我们可以高效、可靠地抓取所有符合条件的数据，而不会遗漏任何一条记录。

数据清洗与转换

将日期格式统一转换为目标系统所需的格式。
对状态码进行重新映射，使其符合目标系统的业务逻辑要求。
清理无效或冗余字段，只保留必要的信息。

实时监控与异常处理

例如，当遇到接口限流问题时，可以通过以下策略进行处理：

增加重试机制，在一定时间间隔后重新发起请求。
动态调整分页大小，以减少单次请求的数据量，从而降低被限流的风险。

总结

通过以上步骤，我们可以高效地调用旺店通·企业奇门接口wdt.stockin.order.query.purchase获取采购入库单数据，并对其进行初步加工处理。这不仅提高了数据集成过程中的透明度和效率，也为后续的数据写入和业务应用打下了坚实基础。在实际操作中，还可以根据具体需求进一步优化和定制这些流程，以满足不同场景下的数据集成需求。用友与CRM系统接口开发配置

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

用友BIP采购入库单数据集成方案

数据转换与写入

在将数据写入用友BIP之前，我们需要确保数据格式符合其API接口要求。以下是几个关键字段的配置和处理方式：

保证请求的幂等性
```
{"field":"resubmitCheckKey","value":"{order_no}"}
```
该字段用于确保每个请求都是唯一的，避免重复提交。我们使用订单编号{order_no}作为唯一标识。
合并上游数据
```
{"field":"mergeSourceData","value":"true"}
```
固定值传入true，表示将上游数据进行合并处理。
表体行计算标识及依据
```
{"field":"needCalcLines","value":"true"}
{"field":"calcLinesKey","value":"oriTaxUnitPrice"}
```
这两个字段用于指示系统是否需要对表体行进行计算，以及计算依据字段。这里我们设置为true和oriTaxUnitPrice。
单据编号和日期
```
{"field":"code","value":"{order_no}"}
{"field":"vouchdate","value":"{{check_time|date}}"}
```
单据编号使用订单编号，单据日期则采用格式化后的检查时间。

交易类型和仓库ID

{"field":"bustype","value":"A15001"}
{"field":"warehouse","value":"_findCollection find purchaseOrders_warehouse_code from aaafe9d3-cba3-367f-8b42-1dbd870e0564 where code={src_order_no} product_cCode={{details_list.goods_no}}"}

交易类型和仓库ID根据业务规则进行配置，从源系统中提取相应信息。

采购入库单子表配置

生单规则编码
```
{"field":"makeRuleCode","value":"st_purchaseorder"}
```
固定值传入st_purchaseorder，表示订单入库。

上游单据主表和子表ID

{"field":"sourceid","value":"_findCollection find new_id from aaafe9d3-cba3-367f-8b42-1dbd870e0564 where code={src_order_no} product_cCode={{details_list.goods_no}}"}
{"field":"sourceautoid","value":"_findCollection find new_purchaseOrders_id from aaafe9d3-cba3-367f-8b42-1dbd870e0564 where code={src_order_no} product_cCode={{details_list.goods_no}}"}

这些字段用于关联上游系统的主表和子表ID。

数量和含税单价

{"field":"qty","value":"{{details_list.right_num}}"}
{"field":"oriTaxUnitPrice","value":"_findCollection find oriTaxUnitPrice from aaafe9d3-cba3-367f-8b42-1dbd870e0564 where code={src_order_no} product_cCode={{details_list.goods_no}}"}

数量直接从详情列表中获取，而含税单价则从源系统中提取。

备注和操作标识

{"field":"memo","value":"{remark}"}
{"field":"_status","value":"Insert"}

调用API接口

完成以上配置后，我们通过POST方法调用用友BIP的API接口，将转换后的数据写入目标平台：

POST /yonbip/scm/purinrecord/mergeSourceData/save

数据质量监控与异常处理

批量处理与高吞吐量支持

综上所述，通过合理配置元数据及调用API接口，我们能够高效地将源平台的数据转换并写入到用友BIP，实现跨系统的数据无缝对接。这不仅提升了业务流程的自动化程度，也确保了数据的一致性和准确性。企业微信与OA系统接口开发配置

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