ETL流程：将旺店通出库单数据转换并写入金蝶云星空

  • 轻易云集成顾问-吴伟

旺店通销售出库单同步至金蝶销售出库单【店铺】：API对接实现案例

在复杂多变的电商生态中，企业的数据处理需求与日俱增，实现数据流的高效传递和集成成为必然。本文将分享一个实际技术案例，详细解析如何通过轻易云数据集成平台，实现旺店通·企业奇门系统中的销售出库单数据同步至金蝶云星空的解决方案。

首先，我们需要明确两个关键操作点：一是从旺店通·企业奇门中获取销售出库订单数据(API: wdt.stockout.order.query.trade)，二是将这些数据批量写入到金蝶云星空系统(API: batchSave)。这一过程不仅要确保高吞吐量的数据写入能力，还要充分利用平台提供的集中监控和告警功能，实时跟踪任务状态和性能。

为了应对分页和限流问题，我们制定了合理的数据抓取策略，通过定时调度可靠地获取接口数据。同时，为了确保不漏单，在每次分页请求完成后，都进行严密的数据质量监控与异常检测。一旦发现问题，可以借助错误重试机制重新处理，保障整个流程无缝运行。

另一个挑战则来自于不同系统之间的数据格式差异。对此，我们利用自定义数据转换逻辑，将旺店通·企业奇门获取到的原始订单信息转化为符合金蝶云星空标准结构的数据格式。此外，通过可视化的数据流设计工具，使得每一步流程都直观、易管控，并且能够适应特定业务需求。

在具体实施上，调用旺店通·企业奇门接口(wdt.stockout.order.query.trade)提取目标时间段内所有待处理订单，将其组织为标准化JSON对象，然后通过批量保存方式(batchSave)上传至金蝶云星空。这一过程中，不仅需要注意网络请求的稳定性，还需考虑到两者API资产管理功能及资源配置优化的问题。

通过上述方法，不仅有效提升了整体传输效率，也保证了业务环节间数据的一致性和准确性。在这套方案中，每个细节都经过精心设计，以满足不同场景下多种业务需求，使跨系统互联互通变得更加简便、高效。 如何对接钉钉API接口

调用源系统旺店通·企业奇门接口wdt.stockout.order.query.trade获取并加工数据

在数据集成的生命周期中，调用源系统接口是关键的第一步。本文将详细探讨如何通过轻易云数据集成平台调用旺店通·企业奇门接口wdt.stockout.order.query.trade来获取并加工销售出库单数据。

接口配置与请求参数

首先，我们需要配置API接口及其请求参数。根据元数据配置，接口的基本信息如下：

  • API: wdt.stockout.order.query.trade
  • 方法: POST
  • 分页大小: 100
  • ID检查: 开启

请求参数包括时间范围、状态、订单编号、仓库编号等。以下是一些关键字段及其描述：

  • start_time: 增量获取数据的开始时间，格式为yyyy-MM-dd HH:mm:ss。
  • end_time: 增量获取数据的结束时间，格式为yyyy-MM-dd HH:mm:ss。
  • status: 订单状态，如已取消、已审核、已发货等。
  • warehouse_no: 仓库编号，用于区分不同仓库的数据。

这些参数确保我们能够精确地获取所需的数据，并且支持增量更新。

条件过滤与分页处理

为了提高查询效率和准确性，我们可以使用条件过滤和分页处理。元数据配置中定义了多个条件组，每个组包含以下条件：

  1. 仓库名称包含特定关键词（如“七遇”、“百媚”等）。
  2. 店铺名称不包含“OEM”。
  3. 分销订单号为空。

例如，一个条件组可以表示为：

[
  {"field": "warehouse_name", "logic": "like", "value": "七遇"},
  {"field": "shop_name", "logic": "notlike", "value": "OEM"},
  {"field": "fenxiao_tid", "logic": "isnull"}
]

分页处理方面，通过设置page_size和page_no参数，我们可以控制每次请求返回的数据条数和页码。例如：

{"page_size": 100, "page_no": 0}

数据请求与清洗

在发送请求后，我们会收到原始的销售出库单数据。这些数据通常需要进行清洗和转换，以便后续处理。常见的数据清洗步骤包括：

  1. 去除无效字段：删除不必要的字段，保留核心信息。
  2. 格式转换：将日期、金额等字段转换为标准格式。
  3. 数据校验：检查关键字段是否为空或格式是否正确。

例如，对于一个返回的出库单记录，我们可能需要提取并转换以下字段：

{
  "order_no": "123456",
  "warehouse_name": "七遇",
  "shop_name": "某店铺",
  ...
}

数据转换与写入

清洗后的数据需要进行进一步的转换，以符合目标系统（如金蝶）的要求。这可能涉及字段映射、单位转换等操作。例如，将旺店通中的“order_no”映射到金蝶中的“订单编号”。

最终，经过清洗和转换的数据将被写入目标系统。这一步通常通过API调用或数据库操作实现。在轻易云平台上，可以使用内置的连接器和脚本功能来完成这一过程。

实时监控与错误处理

在整个过程中，实时监控和错误处理至关重要。轻易云平台提供了丰富的监控工具，可以实时跟踪数据流动和处理状态。一旦发生错误（如网络故障、接口异常），系统会自动记录日志并发送告警通知，以便及时排查问题。

通过以上步骤，我们可以高效地调用旺店通·企业奇门接口获取销售出库单数据，并进行必要的清洗和转换，为后续的数据集成打下坚实基础。 如何对接钉钉API接口

轻易云数据集成平台生命周期的第二步：ETL转换与写入金蝶云星空API接口

在数据集成过程中，ETL（Extract, Transform, Load）是一个关键步骤，尤其是在将数据从源系统转换为目标系统所能接受的格式时。本文将重点探讨如何使用轻易云数据集成平台，将旺店通销售出库单的数据转换并写入到金蝶云星空API接口。

元数据配置解析

元数据配置是ETL过程中的核心部分，它定义了如何将源数据映射到目标系统所需的字段和格式。以下是一个典型的元数据配置示例：

{
    "api": "batchSave",
    "method": "POST",
    "idCheck": true,
    "operation": {
        "rowsKey": "array",
        "rows": 1,
        "method": "batchArraySave"
    },
    "request": [
        {
            "field": "FBillTypeID",
            "label": "单据类型",
            "type": "string",
            "describe": "单据类型",
            "parser": {
                "name": "ConvertObjectParser",
                "params": "FNumber"
            },
            "value": "XSCKD01_SYS"
        },
        {
            ...
        }
    ],
    ...
}

数据字段解析与转换

在这个配置中，每个字段都有特定的属性和解析规则。例如：

  • FBillTypeID：单据类型，通过ConvertObjectParser解析器将其值转换为目标系统所需的格式。
  • FBillNo：单据编号，直接从源系统中获取并传递。
  • FDate：日期，通过模板字符串和日期格式化函数进行转换。

这些字段通过不同的解析器和转换规则，确保数据能够正确地映射到金蝶云星空API接口。

明细信息处理

明细信息是销售出库单的重要组成部分，需要特别处理。以下是明细信息的配置示例：

{
    ...
    {
        "field": "FEntity",
        "label": "明细信息",
        "type": "array",
        ...
        "children": [
            {
                ...
                {
                    "field": "FMaterialID",
                    ...
                    ...
                },
                {
                    ...
                    ...
                }
            }
        ]
    }
}

每个明细项都包含多个子字段，如物料编码、实发数量、含税单价等。这些子字段同样需要通过解析器进行转换，以符合目标系统的要求。

特殊处理逻辑

在某些情况下，需要根据特定条件对数据进行特殊处理。例如，在含税单价（FTaxPrice）字段中，我们使用了条件判断逻辑：

{
    ...
    {
        ...
        {
            ...
            {
                ...
                "_function case when '{warehouse_name}' like '%七遇手机扣(广州仓)%' then '0.00' when '{cs_remark}' like '%重要客户%' then '0.00' else '{{details_list.sell_price}}' end"
            }
        }
    }
}

这种逻辑确保在特定条件下，含税单价被设置为0.00，而在其他情况下，则使用原始销售价格。

财务信息处理

财务信息也是不可忽视的一部分。以下是财务信息的配置示例：

{
    ...
    {
        ...
        {
            ...
            {
                ...
                "_findCollection find FCOUNTRY from 1c7e5053-1f36-35c8-844e-ceed3ac87bb9 where FName={shop_name}"
            }
        }
    }
}

通过使用_findCollection函数，我们可以根据店铺名称查找相应的结算组织，并将其映射到目标系统中。

最终写入操作

所有字段都完成映射和转换后，通过POST请求将数据批量保存到金蝶云星空API接口中：

{
    ...
    {
        ...
        {
            "_function batchArraySave"
        }
    }
}

该操作确保所有数据以批量方式高效地写入目标系统，并且可以选择自动提交和审核（通过设置IsAutoSubmitAndAudit为true）。

通过以上步骤，我们实现了从旺店通销售出库单到金蝶云星空销售出库单的数据无缝转换和写入。这一过程不仅保证了数据的一致性和准确性，还极大提升了业务流程的自动化程度。 用友与CRM系统接口开发配置

版权声明

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

数据集成平台架构
更多系统对接方案