从金蝶到旺店通：销售订单的数据获取及清洗策略

  • 轻易云集成顾问-陈洁琳

案例分享：金蝶云星空数据集成到旺店通·旗舰版

在本案例中，我们将详细介绍如何通过高效的数据集成技术，将金蝶云星空系统中的销售订单同步到旺店通·旗舰版的原始订单。我们采用了一套名为"金蝶-销售订单-->旺店通-原始订单【2B】"的解决方案，重点展示了API接口调用、数据转换及异常处理等关键环节。

为了获取金蝶云星空系统中的销售订单数据，我们使用了其提供的executeBillQuery API接口，这一接口能够实现定时可靠的数据抓取，并支持分页和限流功能，以确保大量数据可以稳定、高效地提取。此外，为应对双方系统间的数据格式差异问题，我们设置了自定义的数据转换逻辑，使得从金蝶云星空提取出的行信息能顺利匹配至旺店通·旗舰版的数据库结构。

在数据写入方面，借助于旺店通·旗舰版提供的sales.RawTrade.pushSelf2 API接口，大量订单可以快速批量写入，从而大幅提高整个业务流程的响应速度和准确性。通过平台内置的可视化设计工具，技术人员能够直观地管理和监控每个步骤的数据流动情况，实时掌握各节点任务的运行状态。同时，通过实时监控与日志记录机制，可以迅速识别并处理任何潜在的问题和异常情况，实现对接过程全生命周期管理。

更重要的是，本次集成还运用了集中监控与告警系统，对整个任务状态进行全面跟踪，有效减少因网络波动或系统故障引起的数据丢失风险。对于出现的偶发错误，则依赖于完善错误重试机制进行自动修复，以保障最终一致性。这些先进特性共同协作，不仅确保了高频繁、大吞吐量场景下业务数据不漏单，还极大提升了整体操作透明度与效率。

接下来，我们将深入探讨具体实现过程中涉及到的一些核心技术细节，包括API调用参数配置、分页策略、限流控制及定制化映射规则等内容。 打通用友BIP数据接口

调用金蝶云星空接口executeBillQuery获取并加工数据

在数据集成的生命周期中，第一步是从源系统获取数据。本文将详细探讨如何通过轻易云数据集成平台调用金蝶云星空的executeBillQuery接口来获取销售订单数据，并进行初步加工。

接口配置与请求参数

首先，我们需要配置调用金蝶云星空接口的元数据。以下是元数据配置中的关键部分：

{
  "api": "executeBillQuery",
  "effect": "QUERY",
  "method": "POST",
  "number": "FBillNo",
  "id": "FSaleOrderEntry_FEntryID",
  ...
}

该配置指定了API名称、请求方法以及一些关键字段，如单据编号（FBillNo）和分录ID（FSaleOrderEntry_FEntryID）。这些字段在后续的数据处理和转换中至关重要。

请求参数详解

为了成功调用接口，我们需要构建一个包含所有必要请求参数的JSON对象。以下是主要请求参数及其描述：

  • FormId: 必须填写金蝶的表单ID，例如销售订单为SAL_SaleOrder。
  • FieldKeys: 需查询的字段集合，格式为数组。
  • FilterString: 用于过滤查询结果的条件字符串。
  • Limit: 最大行数，用于分页查询。
  • StartRow: 开始行索引，用于分页查询。

示例请求参数如下：

{
  "FormId": "SAL_SaleOrder",
  "FieldKeys": [
    "FSaleOrderEntry_FEntryID", 
    "FID", 
    "FBillNo", 
    ...
  ],
  "FilterString": "FApproveDate>='2023-01-01' and (FSaleOrgId.FNumber = '100.01' or FSaleOrgId.FNumber = '100.02') and F_PAUF_WDTTBBJ<>1",
  "Limit": 100,
  "StartRow": 0
}

数据请求与清洗

在发送请求并接收到响应后，我们需要对数据进行清洗和初步加工。以下是一个简单的数据清洗示例：

  1. 过滤无效数据：移除那些不符合业务需求的数据行。例如，删除所有状态为“已取消”的订单。
  2. 字段映射：将原始字段名映射到目标系统所需的字段名。例如，将FBillNo映射为order_number。
  3. 数据格式转换：将日期字符串转换为标准日期格式，将数值字符串转换为浮点数等。

示例代码如下：

import json
import requests

# 配置请求参数
payload = {
    "FormId": "SAL_SaleOrder",
    ...
}

# 发起POST请求
response = requests.post("https://api.kingdee.com/executeBillQuery", json=payload)
data = response.json()

# 数据清洗与加工
cleaned_data = []
for entry in data['Result']['ResponseStatus']['SuccessEntitys']:
    if entry['FNote'] != '已取消':
        cleaned_entry = {
            'order_number': entry['FBillNo'],
            'customer': entry['FCustId_FNumber'],
            ...
        }
        cleaned_data.append(cleaned_entry)

# 输出清洗后的数据
print(json.dumps(cleaned_data, indent=4, ensure_ascii=False))

数据转换与写入

在完成初步的数据清洗后，下一步是将这些数据转换并写入目标系统。在此过程中，需要确保目标系统能够正确解析和存储这些数据。

例如，如果目标系统是旺店通，我们可能需要将清洗后的销售订单数据转换为旺店通原始订单格式，并通过相应的API接口写入旺店通系统。

# 转换为旺店通原始订单格式
wdt_orders = []
for entry in cleaned_data:
    wdt_order = {
        'order_no': entry['order_number'],
        'customer_code': entry['customer'],
        ...
    }
    wdt_orders.append(wdt_order)

# 写入旺店通系统（假设有一个write_to_wdt函数）
write_to_wdt(wdt_orders)

通过上述步骤，我们实现了从金蝶云星空获取销售订单数据，并进行初步加工和转换，为后续的数据写入奠定了基础。这一过程展示了轻易云数据集成平台在处理异构系统间的数据集成时的强大能力。 钉钉与WMS系统接口开发配置

使用轻易云数据集成平台将金蝶销售订单转换并写入旺店通·旗舰版API接口

在数据集成过程中，ETL（Extract, Transform, Load）转换是至关重要的一环。本文将详细探讨如何利用轻易云数据集成平台，将金蝶的销售订单数据转换为旺店通·旗舰版API接口所能接收的格式，并最终写入目标平台。

元数据配置解析

首先，我们需要理解元数据配置中的各个字段和参数。这些配置定义了如何将源数据映射到目标API接口中。以下是元数据配置的主要部分：

{
  "api": "sales.RawTrade.pushSelf2",
  "effect": "EXECUTE",
  "method": "POST",
  "idCheck": true,
  "operation": {
    "method": "merge",
    "field": "FBillNo",
    "bodyName": "rawTradeOrderList",
    "bodySum": ["FQty"],
    "header": ["FCustId_FNumber", "FBillNo", "FDate", ...],
    ...
  },
  ...
}

  1. API接口定义：

    • api: 定义了目标API接口为sales.RawTrade.pushSelf2。
    • method: 使用HTTP POST方法进行请求。
    • idCheck: 启用ID检查，确保唯一性。

  2. 操作定义：

    • operation.method: 使用merge方法合并数据。
    • operation.field: 合并操作基于字段FBillNo。
    • operation.bodyName: 定义订单明细节点名称为rawTradeOrderList。
    • operation.bodySum: 对字段FQty进行汇总。

  3. 请求字段映射： 请求部分定义了如何将源系统的字段映射到目标系统的字段。例如：

    {
 "field": "shop_no",
 "label": "店铺编号",
 "type": "string",
 "value": "{FCustId_FNumber}"
}

    上述配置表示将源系统中的FCustId_FNumber字段值映射到目标系统的shop_no字段。

数据转换过程

在了解元数据配置后，我们可以开始实际的数据转换过程。以下是具体步骤：

  1. 提取源数据： 从金蝶系统中提取销售订单数据，这一步通常已经在生命周期的第一步完成。

  2. 转换数据格式： 根据元数据配置，将提取的数据进行格式转换。以一个示例订单为例：

    {
 "FBillNo": "SO12345",
 ...
 "rawTradeOrderList": [
   {
     ...
     "FSaleOrderEntry_FEntryID": 1,
     ...
   }
 ]
}

  3. 构建请求体： 根据元数据配置，构建符合旺店通·旗舰版API要求的请求体。例如：

    {
 "shop_no": "{FCustId_FNumber}",
 ...
 "rawTradeList": [
   {
     ...
     "tid": "{FBillNo}",
     ...
   }
 ],
 ...
 "rawTradeOrderList": [
   {
     ...
     "oid": "{FBillNo}-{{rawTradeOrderList.FSaleOrderEntry_FEntryID}}",
     ...
   }
 ]
}

  4. 发送请求： 使用HTTP POST方法，将构建好的请求体发送到旺店通·旗舰版API接口。

实际案例分析

假设我们有一个具体的销售订单，其主要字段如下：

  • FBillNo: SO12345
  • FCustId_FNumber: CUST001
  • FDate: 2023-10-01
  • F_PAUF_Recipient: 张三
  • F_PAUF_Text_province: 北京市
  • ...

根据上述信息，我们可以构建出如下的请求体：

{
  "shop_no": "CUST001",
  ...
  "rawTradeList": [
    {
      ...
      "tid": "SO12345",
      ...
      "buyer_nick": "张三",
      ...
      "receiver_area": "北京市 海淀区 中关村街道"
      ...
    }
  ],
  ...
}

通过上述步骤，我们实现了从金蝶系统到旺店通·旗舰版API接口的数据转换和写入。在实际操作中，可能还需要处理更多细节和异常情况，但本文提供了一个清晰的框架和思路，帮助您高效地完成ETL过程。 如何开发钉钉API接口

版权声明

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

轻易云AI数据分析
更多系统对接方案