金蝶云星空与旺店通WMS的采购订单集成案例分享

在企业的供应链管理中，数据的高效流转和准确处理至关重要。本文将分享一个实际运行的系统对接集成案例：如何将金蝶云星空中的采购订单数据集成到旺店通WMS系统中，并生成相应的CGRK入库单。

在本次集成方案“采购订单=>CGRK入库单新增OK”中，我们利用了轻易云数据集成平台强大的数据处理能力和可视化操作界面，实现了从金蝶云星空到旺店通WMS的数据无缝对接。通过调用金蝶云星空的executeBillQuery API接口获取采购订单数据，并使用WDT_WMS_ENTRYORDER_CREATE API接口将这些数据写入到旺店通WMS系统中。

为了确保整个数据集成过程的高效性和可靠性，我们采用了一系列技术手段：

• 高吞吐量的数据写入能力：支持大量采购订单数据快速写入到旺店通WMS，极大提升了业务处理效率。
• 实时监控与告警系统：提供集中监控和告警功能，实时跟踪每个数据集成任务的状态和性能，确保问题能够被及时发现并解决。
• 自定义数据转换逻辑：针对金蝶云星空与旺店通WMS之间的数据格式差异，我们设计了灵活的数据转换规则，以适应特定业务需求。
• 分页与限流处理机制：在调用金蝶云星空API时，通过合理设置分页参数和限流策略，有效避免了因请求过多导致的接口性能问题。
• 异常处理与错误重试机制：在对接过程中，如果出现任何异常情况，系统会自动进行错误重试，确保所有有效数据都能成功传输，不漏单。

通过上述技术手段，本次集成方案不仅实现了采购订单到CGRK入库单新增的自动化流程，还显著提高了整个供应链管理过程中的透明度和效率。在后续章节中，我们将详细介绍具体实施步骤及关键技术细节。

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

在轻易云数据集成平台中，调用源系统金蝶云星空接口executeBillQuery是数据集成生命周期的第一步。此步骤主要涉及从金蝶云星空系统中获取采购订单数据，并对其进行必要的加工处理，以便后续的数据转换与写入操作。

接口配置与调用

首先，通过配置元数据来定义API请求参数。以下是关键字段及其配置：

• API名称：executeBillQuery
• 请求方法：POST
• 分页设置：每页100条记录
• 表单ID：PUR_PurchaseOrder

这些配置确保了我们能够高效地分页获取采购订单数据。

{
  "api": "executeBillQuery",
  "method": "POST",
  "pagination": {
    "pageSize": 100
  },
  "request": [
    {"field":"FPOOrderEntry_FEntryId","label":"id","type":"string","value":"FPOOrderEntry_FEntryId"},
    {"field":"FBillNo","label":"单据编号","type":"string","describe":"单据编号","value":"FBillNo"},
    ...
    {"field":"FormId","label":"业务对象表单Id","type":"string","describe":"必须填写金蝶的表单ID如:PUR_PurchaseOrder","value":"PUR_PurchaseOrder"}
  ],
  "otherRequest": [
    {"field":"Limit","label":"最大行数","type":"string","describe":"金蝶的查询分页参数"},
    {"field":"StartRow","label":"开始行索引","type":"string","describe":"金蝶的查询分页参数"},
    ...
  ]
}

数据请求与清洗

在实际调用过程中，需要特别注意以下几个方面：

1. 分页处理：

   • 设置分页参数，如每页记录数（pageSize）和起始行索引（StartRow），确保能够逐页获取所有符合条件的数据。
   • 使用循环或递归方式处理多页数据，直到所有数据被完全提取。

2. 过滤条件：

   • 根据业务需求设置过滤条件（FilterString），例如按供应商编号、审批日期等字段进行筛选。
   • 示例过滤条件： FSupplierId.FNumber = 'VEN00010' and FApproveDate >= '{{LAST_SYNC_TIME|dateTime}}' And F_JZJ_WMSSTOCK.F_JZJ_CheckBox=1

3. 字段选择：

   • 指定需要查询的字段集合（FieldKeys），以减少不必要的数据传输，提高效率。
   • 示例字段集合： FPOOrderEntry_FEntryId, FPurchaseOrgId.FNumber, ...

数据加工与处理

在获取到原始数据后，需要对其进行必要的清洗和转换，以满足后续业务需求。这包括但不限于：

• 格式转换： 将日期、金额等字段按照目标系统要求进行格式转换。例如，将日期格式从YYYY-MM-DD转换为DD/MM/YYYY。

• 数据校验： 检查关键字段是否存在缺失或错误，并根据业务规则进行修正。例如，确保采购数量和金额为正值。

• 异常处理： 实现对异常情况的捕获和处理机制，例如网络超时、接口限流等问题。可以通过重试机制或告警通知来保证数据抓取过程的稳定性。

实例解析

假设我们需要从金蝶云星空系统中抓取最近一周内所有已审批且指定仓库标记为1的采购订单，可以通过如下方式实现：

{
  "FilterString": "FApproveDate >= '{{LAST_SYNC_TIME|dateTime}}' And F_JZJ_WMSSTOCK.F_JZJ_CheckBox=1"
}

通过上述配置，我们可以精准地筛选出所需的数据，并结合分页参数逐步提取全部结果。在此过程中，实时监控和日志记录功能将帮助我们跟踪每一步操作，及时发现并解决潜在问题。

综上所述，通过合理配置元数据并调用金蝶云星空接口，我们能够高效地完成采购订单数据的抓取与初步加工，为后续的数据转换与写入奠定坚实基础。

轻易云数据集成平台生命周期的第二步：ETL转换与数据写入

在数据集成的生命周期中，ETL（Extract, Transform, Load）转换是一个关键步骤。我们将已经集成的源平台数据转换为目标平台旺店通WMSAPI接口所能够接收的格式，并最终写入目标平台。以下将详细描述这一过程。

数据请求与清洗

在进行ETL转换之前，我们首先需要从源系统获取数据，并进行必要的清洗和预处理。这一阶段确保了数据的完整性和准确性，为后续的数据转换奠定基础。

数据转换与写入

1. 元数据配置

   我们使用如下元数据配置来定义目标平台API接口的请求结构和字段映射关系：

   {
    "api": "WDT_WMS_ENTRYORDER_CREATE",
    "method": "POST",
    "idCheck": true,
    "operation": {
      "method": "merge",
      "field": "FBillNo,F_JZJ_WMSSTOCK",
      "bodyName": "details",
      "bodySum": ["FQty"],
      "header": ["FBillNo", "FDate", "FSupplierId_FNumber", "FSupplierId_FName", "F_JZJ_WMSSTOCK"],
      "body": ["FMaterialId_FNumber", "FQty", "FPOOrderEntry_FEntryId"]
    },
    ...
   }

2. 定义请求结构

   在这一阶段，我们将源平台的数据按照目标平台API接口的要求进行转换。以采购订单到CGRK入库单新增为例，具体字段映射如下：

   • 入库单号：entryOrderCode 映射自 FBillNo
   • 仓库编码：warehouseCode 映射自 F_JZJ_WMSSTOCK
   • 业务类型：固定值 CGRK
   • 供应商编码：supplierCode 映射自 FSupplierId_FNumber
   • 供应商名称：supplierName 映射自 FSupplierId_FName

3. 构建请求体

   根据上述映射关系，构建请求体：

   {
    "entryOrder": {
      "entryOrderCode": "{FBillNo}",
      "warehouseCode": "{F_JZJ_WMSSTOCK}",
      ...
    },
    ...
   }

4. 处理细节信息

   对于订单行信息，我们将每一行数据按照目标平台要求进行转换：

   • 商家编码：itemCode 映射自 details.FMaterialId_FNumber
   • 应收商品数量：planQty 映射自 details.FQty
   • 入库单的行号：orderLineNo 映射自 details.FPOOrderEntry_FEntryId

5. 批量处理与高吞吐量支持

   为了确保大量数据能够快速被集成到旺店通WMS，我们利用轻易云提供的高吞吐量的数据写入能力。通过批量处理机制，将多个订单行信息一次性发送至目标平台，大大提升了数据处理效率。

6. 监控与异常处理

   在数据写入过程中，实时监控和告警系统会跟踪任务状态和性能，及时发现并处理异常情况。例如，在对接旺店通WMS时，如果发生错误，可以通过重试机制确保数据最终一致性。

7. 自定义数据转换逻辑

   根据特定业务需求，我们可以灵活调整数据转换逻辑。例如，对于特殊类型的库存，可以在映射过程中添加额外字段或调整现有字段值，以满足业务需求。

8. 日志记录与审计

   每次数据转换和写入操作都会记录详细日志，便于后续审计和问题排查。这些日志包括请求参数、响应结果、错误信息等，确保整个过程透明可追溯。

通过以上步骤，我们实现了将源平台的数据成功转换并写入到目标平台旺店通WMS。此过程不仅保证了数据的一致性和准确性，还极大提升了整体业务效率。