基于旺店通与金蝶云星辰的系统数据对接案例

轻易云平台实现ETL转换与数据写入至金蝶云星辰V2

2021-05-06 05:47:57
轻易云集成顾问-谢楷斌

旺店通仓库同步至金蝶云星辰：高效的系统对接集成案例分享

在当前业务环境中，数据的流动性和实时性成为企业提升运营效率的重要保障。本文将分享一个具体的系统对接案例，即如何通过旺店通·企业奇门接口（wdt.warehouse.query）将仓库数据高效、准确地集成到金蝶云星辰V2平台，并实现全程透明监控。

确保不漏单的数据抓取机制

针对旺店通·企业奇门提供的数据，我们采用了定时调度任务来可靠地抓取接口数据。这不仅保证了对最新库存信息的及时获取，还避免了遗漏订单情况。我们利用轻易云平台内置的定时调度功能，以固定频率调用wdt.warehouse.query接口，实现自动化与精细化的数据拉取操作。

处理大规模数据写入问题

面对大量仓储数据需要快速写入金蝶云星辰V2的问题，我们采用批量处理技术，将多条记录打包后调用其API /jdy/v2/bd/store 实现一次传输。这样做既能有效减少网络请求次数，又提高了整体运行效率。同时，通过并行执行多个批次，提高大规模数据导入过程中的速度和稳定性。

数据格式差异及映射解决方案

由于旺店通与金蝶云两者在结构设计上的差异，对不同字段进行精准映射是关键一步。在实际项目实施过程中，开发团队构建了一套自动化映射规则以适应双方平台间字段的不一致。例如，把旺店通返回JSON格式中的“warehouse_id”对应到金蝶API中的“storeId”。此类转换借助轻易云平台自定义脚本模块得以实现，并成功完成跨系统间复杂数据表结构匹配工作。

尽管这只是开始的一部分，但希望这些实践经验能够为您搭建类似系统集成场景提供参考。如果想了解更详细的方法及代码示例，请继续关注后续章节内容。如何开发企业微信API接口

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

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

接口概述

wdt.warehouse.query是一个用于查询仓库信息的API接口，支持POST请求。该接口主要用于获取指定仓库的详细信息，包括仓库编号、类型、分页大小、页号和是否停用等参数。

元数据配置

根据提供的元数据配置，我们可以看到该接口的请求参数和响应结构。以下是元数据配置的详细内容：

{
  "api": "wdt.warehouse.query",
  "effect": "QUERY",
  "method": "POST",
  "number": "warehouse_no",
  "id": "warehouse_no",
  "name": "warehouse_no",
  "idCheck": true,
  "request": [
    {
      "field": "warehouse_no",
      "label": "仓库编号",
      "type": "string",
      "describe": "代表仓库所有属性的唯一编码，用于仓库区分，ERP内支持自定义（ERP仓库界面设置），用于获取指定仓库数据信息(不支持一次推送多个仓库编码)"
    },
    {
      "field": "type",
      "label": "仓库类型",
      "type": "string",
      "describe": "(0不限 1普通仓库 2自动流传外部 3京东仓储 4科捷 5百世物流 6SKU360 7通天晓 8中联网仓 9顺丰仓储 10网仓2号 11奇门仓储 12旺店通仓储 13心怡仓储 14力威仓储 15京东沧海 16云集仓储 17POS 18虎符 20外部链路型 22抖店云仓 126分销委外仓 127其它)"
    },
    {
      "field": "page_size",
      "label": "分页大小",
      "type": "string",
      "describe": "每页返回的数据条数，输入值范围1~100，不传本参数，输入值默认为40"
    },
    {
      "field": "page_no",
      "label": "页号",
      "type": "string",
      "describe": "不传值默认从0页开始"
    },
    {
      "field": "is_disabled",
      "label": "是否停用",
      "type": "string",
      "describe": "(0未停用,1停用,默认为0,返回未停用仓库)"
    }
  ],
  “autoFillResponse”: true
}

请求参数解析

warehouse_no（必填）: 仓库编号，是唯一标识一个仓库的编码。
type（可选）: 仓库类型，可以根据业务需求选择不同类型的仓库。
page_size（可选）: 分页大小，每页返回的数据条数，默认值为40。
page_no（可选）: 页号，不传值默认从第0页开始。
is_disabled（可选）: 是否停用，默认为0，即返回未停用的仓库。

数据请求与清洗

在实际操作中，我们需要通过轻易云平台配置上述请求参数，并发起POST请求以获取原始数据。以下是一个示例请求：

{
    "warehouse_no":"WH001", 
    "type":"1", 
    "page_size":"50", 
    "page_no":"0", 
    "is_disabled":"0"
}

该请求将返回编号为WH001的普通类型未停用的50条记录，从第0页开始。

数据转换与写入

获取到原始数据后，需要对其进行清洗和转换，以便后续写入目标系统。在清洗过程中，可以根据业务需求过滤掉无效或冗余的数据。例如，只保留活跃状态下的普通类型仓库信息。

转换后的数据可以直接写入目标系统，如金蝶云星辰。此过程可以通过轻易云平台提供的数据转换工具实现，将原始JSON格式的数据转换为目标系统所需的数据格式。

实际案例应用

假设我们需要将旺店通中的所有普通类型且未停用的仓库信息同步到金蝶云星辰系统。我们可以按照以下步骤进行操作：

配置API请求参数：
- warehouse_no: 可动态生成或从数据库读取
- type: 固定为“1”表示普通类型
- page_size: 设置为“100”以减少分页次数
- page_no: 从“0”开始逐页递增
- is_disabled: 固定为“0”表示未停用
发起API请求并获取响应数据。
对响应数据进行清洗和转换，确保符合目标系统的数据格式要求。
将清洗后的数据通过轻易云平台写入金蝶云星辰系统，实现数据同步。

通过上述步骤，我们可以高效地完成旺店通到金蝶云星辰的数据集成任务。这不仅提高了业务透明度和效率，还确保了不同系统间的数据一致性和准确性。系统集成平台API接口配置

轻易云数据集成平台ETL转换至金蝶云星辰V2API接口

在数据集成生命周期的第二步中，重点是将已经从源平台（如旺店通）获取的数据进行ETL（Extract, Transform, Load）转换，并将其转为目标平台（金蝶云星辰V2 API接口）所能够接收的格式，最终写入目标平台。本文将详细探讨如何通过轻易云数据集成平台实现这一过程。

数据请求与清洗

在数据请求阶段，我们已经从旺店通仓库系统中获取了相关数据。这些数据通常包括仓库名称、仓库编码等信息。在清洗阶段，需要确保这些数据符合目标系统的要求，例如去除无效字符、标准化格式等。

数据转换与写入

接下来是数据转换与写入阶段，这也是ETL过程的核心部分。我们需要将清洗后的数据转换为金蝶云星辰V2 API接口能够接受的格式，并通过API接口将数据写入目标平台。

根据提供的元数据配置，我们需要调用金蝶云星辰的/jdy/v2/bd/store API接口。以下是具体的元数据配置示例：

{
    "api": "/jdy/v2/bd/store",
    "effect": "EXECUTE",
    "method": "POST",
    "number": "1",
    "id": "1",
    "name": "1",
    "idCheck": true,
    "request": [
        {
            "field": "name",
            "label": "仓库名称",
            "type": "string",
            "describe": "仓库名称",
            "value": "{name}"
        },
        {
            "field": "number",
            "label": "仓库编码",
            "type": "string",
            "describe": "仓库编码",
            "value": "{warehouse_no}"
        },
        {
            "field": "groupid",
            "label": "仓库分类",
            "type": "string",
            "describe": "仓库分类",
            "value":"CKFL00001"
        }
    ]
}

配置解析

API路径：/jdy/v2/bd/store
- 这是金蝶云星辰V2用于接收仓库信息的API路径。
请求方法：POST
- 使用HTTP POST方法提交数据。
字段映射：
- name（仓库名称）：映射到源数据中的{name}。
- number（仓库编码）：映射到源数据中的{warehouse_no}。
- groupid（仓库分类）：固定值CKFL00001，表示特定的仓库分类。

实现步骤

提取源数据：从旺店通系统中提取所需的原始数据，例如：
```
{
   "name": ["A仓", ...],
   "warehouse_no": ["WH001", ...]
}
```

构建请求体：根据元数据配置，将提取的数据构建为符合金蝶云星辰V2 API要求的请求体。例如：

{
   {
       field: 'name',
       value: 'A仓'
   },
   {
       field: 'number',
       value: 'WH001'
   },
   {
       field: 'groupid',
       value: 'CKFL00001'
   }
}

发送请求：使用HTTP客户端（如curl、Postman或编程语言中的HTTP库）发送POST请求至金蝶云星辰V2 API。
处理响应：处理API响应，检查是否成功写入目标平台，并记录日志以便后续审计和错误排查。

以下是一个Python示例代码片段，展示如何实现上述步骤：

import requests
import json

# 源数据
source_data = {
    'name': 'A仓',
    'warehouse_no': 'WH001'
}

# 构建请求体
payload = {
    'name': source_data['name'],
    'number': source_data['warehouse_no'],
    'groupid': 'CKFL00001'
}

# 发送POST请求
response = requests.post(
    url='https://api.kingdee.com/jdy/v2/bd/store',
    headers={'Content-Type': 'application/json'},
    data=json.dumps(payload)
)

# 处理响应
if response.status_code == 200:
    print('Data successfully written to Kingdee Cloud.')
else:
    print(f'Failed to write data: {response.text}')

通过上述步骤，我们可以高效地将源平台的数据转换并写入到金蝶云星辰V2 API接口，实现不同系统间的数据无缝对接。金蝶与CRM系统接口开发配置

版权声明

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

轻易云平台实现ETL转换与数据写入至金蝶云星辰V2

旺店通仓库同步至金蝶云星辰：高效的系统对接集成案例分享

确保不漏单的数据抓取机制

处理大规模数据写入问题

数据格式差异及映射解决方案

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

接口概述

元数据配置

请求参数解析

数据请求与清洗

数据转换与写入

实际案例应用

轻易云数据集成平台ETL转换至金蝶云星辰V2API接口

数据请求与清洗

数据转换与写入

配置解析

实现步骤

版权声明

百威BEES系统与经销商ERP对接

更多系统对接方案