ETL转换：如何将金蝶云数据写入旺店通·企业奇门API

  • 轻易云集成顾问-黄宏棵

金蝶云星辰V2与旺店通·企业奇门的数据集成案例分享：采购入库单对接-新

在现代化的企业管理中，数据集成已经成为提升业务效率和透明度的关键环节。本文将通过具体案例“采购入库单对接-新”，探讨如何使用轻易云数据集成平台，实现金蝶云星辰V2的数据无缝迁移到旺店通·企业奇门系统。

背景

为了优化公司内部ERP系统与仓储管理系统之间的数据流转，需要将金蝶云星辰V2中的采购入库单数据高效而准确地传输到旺店通·企业奇门。这不仅确保了库存记录的实时更新，也提高了供应链的响应速度。

技术实现概述

此次集成项目主要包括以下几个技术要点：

  1. 保证数据不漏单：在从金蝶云星辰V2抓取数据时，通过定时任务可靠地调用其接口/jdy/v2/scm/pur_inbound，并处理接口分页及限流问题，以确保所有数据均被成功提取。

  2. 快速批量写入：大量采集到的数据需要快速且高效地写入到旺店通·企业奇门，其API为wdt.stockin.order.push。这要求我们设计出高性能、低延迟的数据传输方案。

  3. 实时监控与日志记录：整个过程中，对每个操作步骤实施全程监控，并记录详细日志，以便于出现异常情况时进行排查和修复。

  4. 格式差异处理：解决两个系统间的数据格式差异，通过定制化映射规则进行精准对接，从而避免因格式冲突导致的数据丢失或错误。

  5. 异常处理机制：特别关注对接过程中的异常捕获及错误重试机制，确保即使发生网络波动等不可预见的问题，也能保障最终数据的一致性和完整性。

通过本次实例，我们期望读者能够掌握如何利用先进的平台工具，有效应对跨系统、跨平台的大规模数据集成挑战，为公司的信息化建设提供坚实支持。 如何开发用友BIP接口

调用金蝶云星辰V2接口获取采购入库单数据

在数据集成的生命周期中，调用源系统接口是至关重要的一步。本文将深入探讨如何通过轻易云数据集成平台调用金蝶云星辰V2接口/jdy/v2/scm/pur_inbound获取采购入库单数据，并对其进行加工处理。

接口概述

金蝶云星辰V2提供了丰富的API接口供外部系统调用，其中/jdy/v2/scm/pur_inbound用于查询采购入库单数据。该接口支持GET请求，能够根据多种条件进行数据筛选和分页查询。

元数据配置解析

在轻易云数据集成平台中，元数据配置(metadata)是实现接口调用和数据处理的关键。以下是对元数据配置的详细解析：

  • api: /jdy/v2/scm/pur_inbound

    • 这是我们需要调用的接口地址。

  • effect: QUERY

    • 表示该操作为查询类型。

  • method: GET

    • 使用HTTP GET方法进行请求。

  • number: bill_no

    • 单据编号字段，用于唯一标识每条记录。

  • id: id

    • 数据记录的唯一ID。

  • name: number

    • 数据记录的名称字段。

  • idCheck: true

    • 启用ID校验，确保每条记录都有唯一ID。

请求参数详解

请求参数决定了我们从接口获取的数据范围和内容。以下是主要请求参数及其用途：

  1. enable: 可用状态

    • 类型：string
    • 描述：可用状态，1：可用，0：禁用,-1：全部
    • 默认值：1

  2. search: 模糊搜索

    • 类型：string
    • 描述：模糊搜索-名称、编码、规格、条形码

  3. parent_id: 商品类别

    • 类型：string
    • 描述：商品类别ID

  4. isdataperm: 数据权限

    • 类型：string
    • 描述：是否添加数据权限校验，默认false

  5. create_start_time: 创建开始时间戳

    • 类型：string
    • 描述：开始时间（格式：“时间戳”，-1表示不过滤），创建时间

  6. create_end_time: 创建结束时间戳

    • 类型：string
    • 描述：结束时间（格式：“时间戳”，-1表示不过滤），创建时间

  7. modify_start_time: 修改开始时间戳

    • 类型：string
    • 描述：开始时间（格式：“时间戳”，-1表示不过滤），修改时间
    • 默认值：{LAST_SYNC_TIME}000

  8. modify_end_time: 修改结束时间戳

    • 类型：string
    • 描述：结束时间（格式：“时间戳”，-1表示不过滤），修改时间
    • 默认值：{CURRENT_TIME}000

  9. page: 当前页

    • 类型：string
    • 描述：当前页（默认1）
    • 默认值：1

  10. page_size: 每页显示条数

    • 类型：string
    • 描述：每页显示条数（默认10，最大100）
    • 默认值：10

  11. bill_status: 单据状态

    • 类型：string
    • 默认值："C"

  12. start_bill_date: 开始单据日期

    • 类型：string
    • 描述：格式：“yyyy-MM-dd”，为空表示不过滤
    • 默认值："{{DAYS_AGO_s30|date}}"

  13. end_bill_date: 结束单据日期

    • 类型：string
    • 描述：格式：“yyyy-MM-dd”，为空表示不过滤
    • 默认值："{{CURRENT_TIME|date}}"

实际应用案例

在实际应用中，我们可以通过配置上述元数据来调用金蝶云星辰V2接口，并获取采购入库单的数据。例如，我们希望获取最近30天内所有状态为“C”的采购入库单，可以设置如下参数：

{
  "enable": "1",
  "search": "",
  "parent_id": "",
  "isdataperm": "false",
  "create_start_time": "-1",
  "create_end_time": "-1",
  "modify_start_time": "{LAST_SYNC_TIME}000",
  "modify_end_time": "{CURRENT_TIME}000",
  "page": "1",
  "page_size": "10",
  "bill_status": "C",
  "start_bill_date": "{{DAYS_AGO_s30|date}}",
  "end_bill_date": "{{CURRENT_TIME|date}}"
}

通过上述配置，我们可以精确地筛选出符合条件的采购入库单，并进一步进行数据清洗和转换，为后续的数据写入做好准备。

总结

通过轻易云数据集成平台，我们可以高效地调用金蝶云星辰V2接口获取所需的数据。合理配置元数据不仅能确保我们获取到准确的数据，还能极大提升数据处理的效率。在实际操作中，根据业务需求灵活调整请求参数，是实现高效数据集成的关键。 打通钉钉数据接口

轻易云数据集成平台ETL转换与写入旺店通·企业奇门API接口

在轻易云数据集成平台的生命周期中，ETL（Extract, Transform, Load）转换是关键的一步。本文将详细探讨如何将已经集成的源平台数据进行ETL转换，转为目标平台——旺店通·企业奇门API接口所能够接收的格式，并最终写入目标平台。

元数据配置解析

首先，我们需要理解元数据配置的结构和内容。以下是用于将采购入库单对接到旺店通·企业奇门API接口的元数据配置：

{
  "api": "wdt.stockin.order.push",
  "effect": "EXECUTE",
  "method": "POST",
  "idCheck": true,
  "operation": {
    "method": "merge",
    "field": "bill_no",
    "bodyName": "items",
    "bodySum": ["material_entity_qty", "material_entity_all_amount"],
    "header": ["material_entity_stock_number", "bill_no"],
    "body": ["material_entity_material_number", "material_entity_qty", "material_entity_all_amount"]
  },
  "request": [
    {
      "field": "outer_no",
      "label": "外部单号",
      "type": "string",
      "describe": "外部单号",
      "value": "{bill_no}-{material_entity_stock_number}"
    },
    {
      "field": "warehouse_no",
      "label": "仓库编码",
      "type": "string",
      "describe": "仓库编码",
      "value": "{material_entity_stock_number}"
    },
    {
      ...

数据请求与清洗

在ETL过程中，首先需要从源系统请求并清洗数据。假设我们已经完成了这一阶段，接下来进入数据转换与写入阶段。

数据转换

根据元数据配置，我们需要将源系统的数据字段映射到目标系统所需的字段格式。例如：

  • outer_no 映射为 {bill_no}-{material_entity_stock_number}
  • warehouse_no 映射为 {material_entity_stock_number}
  • remark 映射为 金蝶采购入库单对接-{bill_no}

这些映射规则确保了源系统的数据能够准确地转换为目标系统所需的格式。

数据写入

在完成数据转换后，我们使用POST方法将数据写入到旺店通·企业奇门API接口。具体操作如下：

  1. 设置请求头：确保请求头包含必要的认证信息和Content-Type。
  2. 构建请求体：根据元数据配置构建请求体，包括外部单号、仓库编码、备注等字段。
  3. 发送请求：使用HTTP POST方法发送请求，将转换后的数据推送到目标API接口。

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

import requests
import json

# 设置请求头
headers = {
    'Content-Type': 'application/json',
    'Authorization': 'Bearer YOUR_ACCESS_TOKEN'
}

# 构建请求体
payload = {
    'outer_no': f"{bill_no}-{material_entity_stock_number}",
    'warehouse_no': material_entity_stock_number,
    'remark': f"金蝶采购入库单对接-{bill_no}",
    'is_check': '1',
    'goods_list': [
        {
            'spec_no': item['material_entity_material_number'],
            'stockin_num': item['material_entity_qty'],
            'src_price': item['material_entity_all_amount'] / item['material_entity_qty'],
            'stockin_price': item['material_entity_all_amount'] / item['material_entity_qty']
        } for item in items
    ]
}

# 发送POST请求
response = requests.post('https://api.wangdian.cn/stockin/order/push', headers=headers, data=json.dumps(payload))

# 检查响应状态
if response.status_code == 200:
    print("Data successfully pushed to Wangdian API")
else:
    print(f"Failed to push data: {response.text}")

实践中的注意事项

  1. 字段校验：确保所有必填字段都已正确映射和赋值，避免因缺少字段导致API调用失败。
  2. 错误处理：在实际应用中，需要处理可能出现的各种错误，如网络异常、认证失败等。
  3. 性能优化：对于大批量的数据推送，可以考虑批量处理或异步操作，以提高效率。

通过上述步骤，我们实现了从源系统到旺店通·企业奇门API接口的数据ETL转换与写入。这一过程不仅确保了数据的准确性和一致性，也极大提升了业务流程的自动化程度。 如何开发用友BIP接口

版权声明

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

金蝶云星辰与旺店通无缝集成
更多系统对接方案