高效调用旺店通接口获取采购退货单数据

  • 轻易云集成顾问-胡秀丛

旺店通·企业奇门数据集成到金蝶云星辰V1：一个成功的系统对接案例

在本技术案例中，我们将聚焦于如何成功实现旺店通·企业奇门的数据无缝集成到金蝶云星辰V1。此次集成的具体场景为采购退货单的数据同步，实际运行方案名称为wk_采购退货单同(New)。

系统对接背景与挑战

为了解决在处理大规模数据时可能出现的漏单问题，同时确保数据快速而准确地写入金蝶云星辰V1系统，本次对接面临以下几个关键技术挑战：

  1. 确保集成旺店通·企业奇门数据不漏单：

    • 通过调用wdt.stockout.order.query.return接口，我们获取了精准和实时更新的采购退货数据信息。

  2. 大量数据快速写入到金蝶云星辰V1：

    • 使用jdy/pur/pur_rtn_save接口，实现批量、高效的数据写入，以及多个并发请求优化。

数据抓取与分页处理

我们首先考虑的是定时抓取并可靠更新旺店通·企业奇门中的采购退货数据信息。为了防止遗漏，采用定时任务轮询机制，并针对分页和限流情况进行了特别优化。例如，在每次API调用过程中，通过监控返回结果中的页码信息，以确定剩余未抓取的数据。

# 示例代码片段: 通过API分页获取旺店通·企业奇门的采购退货订单
def fetch_wdt_stockout_orders(api_key, start_time, end_time):
    page_number = 0
    while True:
        response = call_api(endpoint='wdt.stockout.order.query.return', 
                            params={'api_key': api_key, 'start_time': start_time, 'end_time': end_time,
                                    'page_no': page_number})
        if not response['orders']:
            break

        process_orders(response['orders'])  # 批量处理逻辑
        page_number += 1

格式转换与异常处理

由于两个系统间存在显著的数据格式差异，每次获取到原始数据后，必须进行一系列格式化转换。这包括字段名重映射、日期格式调整等，并依据业务规则进行相应校验。此外，为提高系统稳定性，对所有API交互增加了错误捕获和重试机制。在调用金蝶云星辰V1 API接口时，如果遇到网络或服务端故障，将记录日志且自动触发重试逻辑。

# 示例代码片段: 调用金蝶云星辰V1 API并实现错误重试机制
def save_to_jd_cloud_purchase_return
![泛微OA与ERP系统接口开发配置](https://pic.qeasy.cloud/D2.png~tplv-syqr462i7n-qeasy.image)
### 使用轻易云数据集成平台调用旺店通·企业奇门接口获取采购退货单数据

在数据集成的生命周期中，第一步是从源系统获取数据。本文将深入探讨如何使用轻易云数据集成平台调用旺店通·企业奇门接口`wdt.stockout.order.query.return`来获取并加工采购退货单数据。

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

首先，我们需要配置接口的元数据。根据提供的元数据配置，接口采用POST方法进行调用，主要参数如下：

- **api**: `wdt.stockout.order.query.return`
- **method**: `POST`
- **number**: `order_no`
- **id**: `stockout_id`
- **pagination**: 每页返回的数据条数为100
- **idCheck**: true

请求参数包括以下字段：

1. **start_time**（开始时间）：
   - 类型：datetime
   - 值：`{{LAST_SYNC_TIME|datetime}}`
   - 说明：用于增量获取数据的起始时间。

2. **end_time**（结束时间）：
   - 类型：datetime
   - 值：`{{CURRENT_TIME|datetime}}`
   - 说明：按最后修改时间增量获取数据，格式为`yyyy-MM-dd HH:mm:ss`。

3. **warehouse_no**（仓库编号）：
   - 类型：string

4. **status**（出库单状态）：
   - 类型：string
   - 说明：出库单状态可选值包括5（已取消）、50（待审核）、55（已审核）、95（已发货）、110（已完成）。默认查询已发货和已完成的单据。

5. **page_no**（页号）：
   - 类型：string
   - 值：`{PAGINATION_START_ROW}`

6. **page_size**（分页大小）：
   - 类型：string
   - 值：`{PAGINATION_PAGE_SIZE}`
   - 说明：每页返回的数据条数，范围为1~30，不传本参数时默认为30。

7. **src_order_no**（上层单据编号）：
   - 类型：string

#### 数据请求与清洗

在实际操作中，我们需要确保请求参数的正确性和完整性。以下是一个示例请求体：

```json
{
    "start_time": "2023-01-01 00:00:00",
    "end_time": "2023-01-31 23:59:59",
    "warehouse_no": "WH001",
    "status": "95,110",
    "page_no": "1",
    "page_size": "100"
}

通过上述请求体，我们可以从旺店通系统中获取指定时间段内、特定仓库和状态的采购退货单数据。轻易云平台会自动处理分页逻辑，确保所有符合条件的数据都能被完整提取。

数据转换与写入

在获取到原始数据后，需要对其进行清洗和转换，以便写入目标系统。在这个过程中，可以利用轻易云平台提供的可视化工具，对字段进行映射、格式转换等操作。例如，将原始字段名转换为目标系统所需的字段名，或者将日期格式从字符串转换为日期对象。

以下是一个简单的数据转换示例：

{
    "order_no": "{{stockout_id}}",
    "order_date": "{{created_at|datetime}}",
    "warehouse_code": "{{warehouse_no}}",
    "status": "{{status}}"
}

通过上述映射规则，可以将源系统中的字段名和格式转换为目标系统所需的形式。

实时监控与异常处理

在整个数据集成过程中，实时监控和异常处理至关重要。轻易云平台提供了详细的日志记录和告警机制，当出现异常情况时，可以及时发现并处理。例如，如果某次请求失败或返回错误信息，可以通过日志快速定位问题，并采取相应措施进行修复。

综上所述，通过合理配置元数据和利用轻易云平台强大的功能，我们可以高效地调用旺店通·企业奇门接口wdt.stockout.order.query.return，实现采购退货单数据的自动化获取与加工。这不仅提升了业务透明度和效率，也为后续的数据分析和决策提供了可靠的数据基础。 如何对接用友BIP接口

使用轻易云数据集成平台实现金蝶云星辰V1 API接口的数据转换与写入

在数据集成的生命周期中，数据转换与写入是关键的一步。本文将深入探讨如何通过轻易云数据集成平台将源平台的数据进行ETL转换，并最终写入金蝶云星辰V1 API接口。

配置元数据

首先，我们需要配置元数据，以便正确地将源平台的数据映射到目标平台的API接口格式。以下是针对金蝶云星辰V1 API接口jdy/pur/pur_rtn_save的元数据配置：

{
  "api": "jdy/pur/pur_rtn_save",
  "method": "POST",
  "idCheck": true,
  "request": [
    {
      "field": "billno",
      "label": "单据编码",
      "type": "string",
      "describe": "单据编码",
      "value": "{order_no}"
    },
    {
      "field": "billdate",
      "label": "单据日期",
      "type": "datetime",
      "describe": "单据日期",
      "value": "{{consign_time|date}}"
    },
    {
      "field": "supplierid_id",
      "label": "供应商",
      "type": "string",
      "describe": "供应商",
      "value": "_findCollection find id from 9278fe4a-f123-3198-94b2-69703d296326 where number={provider_no}"
    },
    {
      "field": "remark",
      "label": "备注",
      "type": "string",
      "describe": ""
    },
    {
      "field": "totalunsettleamount",
      "label": "",
      "type": "",
      ""
    },
    {
        ...
        // 省略部分字段
        ...
    }
  ]
}

数据请求与清洗

在进行ETL转换之前，首先需要从源系统请求并清洗数据。假设我们已经完成了这一阶段，现在我们有了一个清洗后的数据集，接下来我们将其转换为目标平台所需的格式。

数据转换

根据元数据配置，我们需要将源平台的数据字段映射到金蝶云星辰V1 API接口所需的字段。例如：

  • order_no 映射到 billno
  • consign_time 映射到 billdate
  • provider_no 映射到 supplierid_id

对于复杂的数据结构，如商品分录（material_entity），我们需要逐一处理每个子字段：

{
  ...
  {
    field: 'material_entity',
    label: '商品分录',
    type: 'array',
    describe: '商品分录',
    children: [
        {
            field: 'materialid_id',
            label: '商品',
            type: 'string',
            describe: '商品',
            value: '_findCollection find id from b36e2f56-3e1b-3d60-9748-c59ec4c9d95f where number={{detail_list.spec_no}}'
        },
        {
            field: 'stockid_id',
            label: '仓库',
            type: 'string',
            describe: '仓库',
            value: '_findCollection find id from dfb624bb-d6b8-33fc-a971-c3df53cf9288 where number={warehouse_no}'
        },
        ...
        // 省略部分字段
        ...
    ],
    value: 'details_list'
  }
}

数据写入

完成数据转换后，我们将其通过POST请求写入目标平台。以下是一个示例代码片段，展示如何使用轻易云平台进行API调用：

import requests
import json

url = 'https://api.kingdee.com/jdy/pur/pur_rtn_save'
headers = {'Content-Type': 'application/json'}
data = {
  # 已经转换后的数据结构
}

response = requests.post(url, headers=headers, data=json.dumps(data))
if response.status_code == 200:
    print("Data successfully written to Kingdee Cloud")
else:
    print(f"Failed to write data. Status code: {response.status_code}, Response: {response.text}")

通过上述步骤，我们可以确保源平台的数据经过清洗、转换后，成功写入金蝶云星辰V1 API接口。这不仅提高了系统间的数据一致性，还简化了跨平台的数据管理流程。 打通企业微信数据接口

版权声明

该文章《轻易云平台实现旺店通到金蝶云星辰V1数据转换》为原创内容，版权归 广东轻亿云软件科技有限公司 所有。 未经本公司书面授权，严禁转载、引用、复制或建立镜像等行为。 若需转载或引用本文内容，请联系本公司获取授权，并在显著位置注明作者姓名、文章出处（包括原文链接）等信息。

金蝶云星辰与吉客云对接
更多系统对接方案