markdown

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

### 14-采购退料单集成方案：旺店通·旗舰奇门数据集成到金蝶云星空

在企业的供应链管理中，采购退料单的高效处理至关重要。为了实现这一目标，我们采用了轻易云数据集成平台，将旺店通·旗舰奇门的数据无缝对接到金蝶云星空。本次分享的案例是“14-采购退料单集成方案”，重点介绍如何通过API接口实现两大系统间的数据流转与同步。

首先，通过调用旺店通·旗舰奇门提供的`wdt.wms.stockout.purchasereturn.querywithdetail` API接口，我们能够定时可靠地抓取采购退料单的详细数据。这些数据包括商品信息、数量、退货原因等关键字段。为了确保数据不漏单，我们设计了一套高吞吐量的数据写入机制，使得大量数据能够快速且准确地被集成到金蝶云星空。

在数据传输过程中，轻易云平台提供了强大的集中监控和告警系统，实时跟踪每个数据集成任务的状态和性能。一旦发现异常情况，如网络延迟或接口限流问题，系统会立即发出告警并启动错误重试机制，以保证数据传输的稳定性和连续性。

此外，为了适应不同业务需求和数据结构，我们利用自定义的数据转换逻辑，对从旺店通·旗舰奇门获取的数据进行格式调整，使其符合金蝶云星空的要求。在完成转换后，通过调用金蝶云星空的`batchSave` API接口，实现批量数据写入，从而确保所有采购退料单信息都能及时更新到目标系统中。

整个集成过程不仅透明可视，还具备实时监控与日志记录功能，帮助我们全面掌握每一步操作细节，并及时处理可能出现的问题。通过这种方式，不仅提升了业务效率，也为企业资源优化配置提供了有力支持。

接下来，我们将深入探讨具体实施步骤及技术细节，包括如何处理分页与限流问题、异常处理机制以及定制化的数据映射对接等内容。
![用友与WMS系统接口开发配置](https://pic.qeasy.cloud/D29.png)

![数据集成平台可视化配置API接口](https://pic.qeasy.cloud/QEASY/A9.png)

### 调用旺店通·旗舰奇门接口获取并加工数据

在轻易云数据集成平台中，调用源系统接口是数据处理生命周期的第一步。本文将详细探讨如何通过调用旺店通·旗舰奇门接口`wdt.wms.stockout.purchasereturn.querywithdetail`来获取采购退料单数据，并进行必要的数据加工处理。

#### 接口调用配置

首先，我们需要配置接口请求参数。根据元数据配置，接口采用POST方法，主要参数包括出库单状态、出库单号、时间范围、仓库编号等。以下是关键参数的说明：

- **status**: 出库单状态，例如110表示已完成。
- **stockout_no**: 出库单号，用于精确查询特定出库单。
- **out_start_time**和**out_end_time**: 出库时间范围，确保查询结果在指定时间段内。
- **warehouse_no**: 仓库编号，仅限普通仓库。
- **src_order_no**: 采购退货单号，用于精确查询特定退货单。
- **create_start_time**和**create_end_time**: 出库单创建时间范围。

分页参数也非常重要，以确保能够处理大量数据：
- **page_size**: 每页记录数，默认设置为50。
- **page_no**: 页码，从0开始。

#### 数据请求与清洗

在发起请求后，我们会收到一个包含多个字段的响应。为了适应下游系统的数据结构，需要对部分字段进行重命名或格式转换。例如，将响应中的`remark`字段重命名为`remark_new`。

此外，还需注意以下几点：

1. **分页处理与限流问题**
   - 旺店通·旗舰奇门接口支持分页，通过设置`page_size`和`page_no`可以有效管理大批量数据的抓取过程。在实际操作中，可以通过循环递增页码来逐页获取所有数据，直到返回结果为空。
   - 限流问题则需要结合平台提供的监控和告警系统，在检测到频率过高时自动调整请求频率或暂停一段时间再继续。

2. **异常处理与错误重试机制**
   - 在调用过程中可能遇到网络波动或服务端错误，这时需要实现可靠的错误重试机制。例如，当接收到非200状态码时，可以记录错误日志并在一定间隔后重新尝试请求。

3. **自定义数据转换逻辑**
   - 根据业务需求，对某些字段进行自定义转换。例如，将日期格式从字符串转换为标准日期对象，以便后续处理更加方便。

#### 实现步骤示例

1. 配置API请求参数：
    ```json
    {
        "params": {
            "status": "110",
            "out_start_time": "{{LAST_SYNC_TIME|datetime}}",
            "out_end_time": "{{CURRENT_TIME|datetime}}"
        },
        "pager": {
            "page_size": "50",
            "page_no": "1"
        }
    }
    ```

2. 发起API请求并解析响应：
    ```python
    response = requests.post(api_url, json=request_payload)
    data = response.json()
    
    for record in data['records']:
        record['remark_new'] = record.pop('remark')
        # 其他必要的数据清洗操作
    ```

3. 分页抓取：
    ```python
    while True:
        response = requests.post(api_url, json=request_payload)
        data = response.json()
        
        if not data['records']:
            break
        
        for record in data['records']:
            process_record(record)  # 自定义处理函数
        
        request_payload['pager']['page_no'] += 1
    ```

4. 错误重试机制：
    ```python
    try:
        response = requests.post(api_url, json=request_payload)
        response.raise_for_status()
    except requests.exceptions.RequestException as e:
        log_error(e)
        time.sleep(retry_interval)
        continue
    ```

通过上述步骤，我们可以高效地从旺店通·旗舰奇门接口获取所需的采购退料单数据，并进行必要的数据清洗和转换，为后续的数据写入和进一步分析奠定基础。这种全透明可视化操作不仅提升了业务透明度，也极大提高了效率。
![用友与CRM系统接口开发配置](https://pic.qeasy.cloud/S15.png)

![打通企业微信数据接口](https://pic.qeasy.cloud/QEASY/A32.png)

### 采购退料单集成方案的ETL转换与写入

在数据集成过程中，将源平台的数据转化为目标平台所能接受的格式是至关重要的一步。本文将深入探讨如何通过轻易云数据集成平台，将已经集成的源数据进行ETL转换，并将其写入金蝶云星空系统。

#### 数据请求与清洗

在数据请求阶段，我们从旺店通·旗舰奇门系统中抓取原始的采购退料单数据。为了确保数据的完整性和准确性，平台提供了高效的数据质量监控和异常检测机制。通过调用旺店通·旗舰奇门接口`wdt.wms.stockout.purchasereturn.querywithdetail`，我们可以获取详细的退料单信息，包括订单编号、退料日期、供应商信息以及物料明细等。

#### 数据转换逻辑

接下来，我们需要对这些原始数据进行ETL转换，使其符合金蝶云星空API接口的格式要求。以下是关键字段的转换逻辑：

1. **单据类型（FBillTypeID）**：
   - 转换为固定值`TLD01_SYS`，并通过`ConvertObjectParser`解析为金蝶云星空所需的格式。
   
2. **业务类型（FBusinessType）**：
   - 固定值为`CG`，代表采购业务类型。

3. **单据编号（FBillNo）**：
   - 从源数据中的订单编号字段映射过来，确保唯一性和准确性。

4. **退料日期（FDate）**：
   - 使用模板语法将源数据中的时间戳转换为符合目标系统要求的日期格式。

5. **组织信息（FStockOrgId, FPurchaseOrgId）**：
   - 统一设置为固定值`106`，并通过解析器进行格式转换。

6. **供应商信息（FSupplierID）**：
   - 从源数据中提取供应商编号，通过解析器转换为目标系统所需格式。

7. **明细信息（FPURMRBENTRY）**：
   - 物料编码、实退数量、仓库等字段需要逐一映射，并通过相应的解析器进行转换。例如，物料编码使用`ConvertObjectParser`解析，以确保与金蝶云星空系统中的物料编码一致。
   
8. **关联关系表（FPURMRBENTRY_Link）**：
   - 包含源单内码、源单分录内码等字段，这些字段需要根据具体业务逻辑从源数据中提取并映射到目标系统对应字段。

#### 数据写入

完成上述ETL转换后，我们将处理好的数据通过金蝶云星空API接口写入目标系统。使用批量保存接口`batchSave`，可以一次性提交多条记录，提高数据写入效率。以下是部分关键配置：

- `FormId`: 设置为业务对象表单ID，例如采购退料单对应的ID为`PUR_MRB`。
- `Operation`: 执行操作类型设定为批量保存，即`batchSave`。
- `IsAutoSubmitAndAudit`: 设置为`true`，表示提交后自动审核，提高业务处理效率。
- `IsVerifyBaseDataField`: 设置为`false`，默认不验证基础资料有效性，可根据需求调整。
- `SubSystemId`: 系统模块ID设置为仓库模块，即`21`。

#### 异常处理与重试机制

在实际操作中，不可避免会遇到各种异常情况，如网络波动或接口限流问题。轻易云平台提供了完善的异常处理与错误重试机制。当发生错误时，系统会自动记录日志，并根据预设规则进行重试操作，确保数据最终能够成功写入目标系统。此外，通过实时监控功能，可以随时查看任务状态和性能指标，及时发现并处理问题。

#### 总结

通过以上步骤，我们成功地将旺店通·旗舰奇门系统中的采购退料单数据进行了ETL转换，并顺利写入金蝶云星空系统。在此过程中，充分利用了轻易云平台提供的数据质量监控、异常检测、自定义转换逻辑等特性，实现了高效可靠的数据集成。这不仅提高了业务处理效率，也确保了数据的一致性和准确性。
![钉钉与CRM系统接口开发配置](https://pic.qeasy.cloud/T11.png)

![如何对接钉钉API接口](https://pic.qeasy.cloud/QEASY/A38.png)

采购退料单集成方案：从旺店通到金蝶云的API实现

14-采购退料单集成方案：旺店通·旗舰奇门数据集成到金蝶云星空

首先，通过调用旺店通·旗舰奇门提供的wdt.wms.stockout.purchasereturn.querywithdetail API接口，我们能够定时可靠地抓取采购退料单的详细数据。这些数据包括商品信息、数量、退货原因等关键字段。为了确保数据不漏单，我们设计了一套高吞吐量的数据写入机制，使得大量数据能够快速且准确地被集成到金蝶云星空。

此外，为了适应不同业务需求和数据结构，我们利用自定义的数据转换逻辑，对从旺店通·旗舰奇门获取的数据进行格式调整，使其符合金蝶云星空的要求。在完成转换后，通过调用金蝶云星空的batchSave API接口，实现批量数据写入，从而确保所有采购退料单信息都能及时更新到目标系统中。

接下来，我们将深入探讨具体实施步骤及技术细节，包括如何处理分页与限流问题、异常处理机制以及定制化的数据映射对接等内容。用友与WMS系统接口开发配置

数据集成平台可视化配置API接口

调用旺店通·旗舰奇门接口获取并加工数据

在轻易云数据集成平台中，调用源系统接口是数据处理生命周期的第一步。本文将详细探讨如何通过调用旺店通·旗舰奇门接口wdt.wms.stockout.purchasereturn.querywithdetail来获取采购退料单数据，并进行必要的数据加工处理。

接口调用配置

status: 出库单状态，例如110表示已完成。
stockout_no: 出库单号，用于精确查询特定出库单。
out_start_time和out_end_time: 出库时间范围，确保查询结果在指定时间段内。
warehouse_no: 仓库编号，仅限普通仓库。
src_order_no: 采购退货单号，用于精确查询特定退货单。
create_start_time和create_end_time: 出库单创建时间范围。

分页参数也非常重要，以确保能够处理大量数据：

page_size: 每页记录数，默认设置为50。
page_no: 页码，从0开始。

数据请求与清洗

在发起请求后，我们会收到一个包含多个字段的响应。为了适应下游系统的数据结构，需要对部分字段进行重命名或格式转换。例如，将响应中的remark字段重命名为remark_new。

此外，还需注意以下几点：

分页处理与限流问题
- 旺店通·旗舰奇门接口支持分页，通过设置page_size和page_no可以有效管理大批量数据的抓取过程。在实际操作中，可以通过循环递增页码来逐页获取所有数据，直到返回结果为空。
- 限流问题则需要结合平台提供的监控和告警系统，在检测到频率过高时自动调整请求频率或暂停一段时间再继续。
异常处理与错误重试机制
- 在调用过程中可能遇到网络波动或服务端错误，这时需要实现可靠的错误重试机制。例如，当接收到非200状态码时，可以记录错误日志并在一定间隔后重新尝试请求。
自定义数据转换逻辑
- 根据业务需求，对某些字段进行自定义转换。例如，将日期格式从字符串转换为标准日期对象，以便后续处理更加方便。

实现步骤示例

配置API请求参数：

{
    "params": {
        "status": "110",
        "out_start_time": "{{LAST_SYNC_TIME|datetime}}",
        "out_end_time": "{{CURRENT_TIME|datetime}}"
    },
    "pager": {
        "page_size": "50",
        "page_no": "1"
    }
}

发起API请求并解析响应：

response = requests.post(api_url, json=request_payload)
data = response.json()

for record in data['records']:
    record['remark_new'] = record.pop('remark')
    # 其他必要的数据清洗操作

分页抓取：

while True:
    response = requests.post(api_url, json=request_payload)
    data = response.json()

    if not data['records']:
        break

    for record in data['records']:
        process_record(record)  # 自定义处理函数

    request_payload['pager']['page_no'] += 1

错误重试机制：

try:
    response = requests.post(api_url, json=request_payload)
    response.raise_for_status()
except requests.exceptions.RequestException as e:
    log_error(e)
    time.sleep(retry_interval)
    continue

通过上述步骤，我们可以高效地从旺店通·旗舰奇门接口获取所需的采购退料单数据，并进行必要的数据清洗和转换，为后续的数据写入和进一步分析奠定基础。这种全透明可视化操作不仅提升了业务透明度，也极大提高了效率。用友与CRM系统接口开发配置

打通企业微信数据接口

采购退料单集成方案的ETL转换与写入

数据请求与清洗

在数据请求阶段，我们从旺店通·旗舰奇门系统中抓取原始的采购退料单数据。为了确保数据的完整性和准确性，平台提供了高效的数据质量监控和异常检测机制。通过调用旺店通·旗舰奇门接口wdt.wms.stockout.purchasereturn.querywithdetail，我们可以获取详细的退料单信息，包括订单编号、退料日期、供应商信息以及物料明细等。

数据转换逻辑

接下来，我们需要对这些原始数据进行ETL转换，使其符合金蝶云星空API接口的格式要求。以下是关键字段的转换逻辑：

单据类型（FBillTypeID）：
- 转换为固定值TLD01_SYS，并通过ConvertObjectParser解析为金蝶云星空所需的格式。
业务类型（FBusinessType）：
- 固定值为CG，代表采购业务类型。
单据编号（FBillNo）：
- 从源数据中的订单编号字段映射过来，确保唯一性和准确性。
退料日期（FDate）：
- 使用模板语法将源数据中的时间戳转换为符合目标系统要求的日期格式。
组织信息（FStockOrgId, FPurchaseOrgId）：
- 统一设置为固定值106，并通过解析器进行格式转换。
供应商信息（FSupplierID）：
- 从源数据中提取供应商编号，通过解析器转换为目标系统所需格式。
明细信息（FPURMRBENTRY）：
- 物料编码、实退数量、仓库等字段需要逐一映射，并通过相应的解析器进行转换。例如，物料编码使用ConvertObjectParser解析，以确保与金蝶云星空系统中的物料编码一致。
关联关系表（FPURMRBENTRY_Link）：
- 包含源单内码、源单分录内码等字段，这些字段需要根据具体业务逻辑从源数据中提取并映射到目标系统对应字段。

数据写入

完成上述ETL转换后，我们将处理好的数据通过金蝶云星空API接口写入目标系统。使用批量保存接口batchSave，可以一次性提交多条记录，提高数据写入效率。以下是部分关键配置：

FormId: 设置为业务对象表单ID，例如采购退料单对应的ID为PUR_MRB。
Operation: 执行操作类型设定为批量保存，即batchSave。
IsAutoSubmitAndAudit: 设置为true，表示提交后自动审核，提高业务处理效率。
IsVerifyBaseDataField: 设置为false，默认不验证基础资料有效性，可根据需求调整。
SubSystemId: 系统模块ID设置为仓库模块，即21。

异常处理与重试机制

总结

通过以上步骤，我们成功地将旺店通·旗舰奇门系统中的采购退料单数据进行了ETL转换，并顺利写入金蝶云星空系统。在此过程中，充分利用了轻易云平台提供的数据质量监控、异常检测、自定义转换逻辑等特性，实现了高效可靠的数据集成。这不仅提高了业务处理效率，也确保了数据的一致性和准确性。钉钉与CRM系统接口开发配置

如何对接钉钉API接口