高效集成金蝶云星空与旺店通

金蝶云星空与旺店通·旗舰奇门数据集成案例分享

在企业信息化管理中，数据的高效流转和准确对接是实现业务流程自动化的关键。本文将聚焦于一个具体的系统对接集成案例：如何通过轻易云数据集成平台，将金蝶云星空中的收料通知单数据无缝集成到旺店通·旗舰奇门的采购订单模块【中转仓】。

本次集成方案旨在解决以下几个核心问题：

1. 确保数据不漏单：通过调用金蝶云星空的executeBillQuery接口，定时可靠地抓取收料通知单的数据，并处理分页和限流问题，确保所有数据都能被完整获取。
2. 高吞吐量的数据写入能力：利用轻易云平台支持的大量数据快速写入功能，将获取的数据批量、高效地写入到旺店通·旗舰奇门系统中，调用其wdt.purchase.purchaseorder.createorder接口创建采购订单。
3. 实时监控与告警：通过集中监控和告警系统，实时跟踪每个数据集成任务的状态和性能，及时发现并处理异常情况。
4. 自定义数据转换逻辑：针对金蝶云星空与旺店通·旗舰奇门之间的数据格式差异，通过自定义转换逻辑进行适配，以满足特定业务需求。
5. 异常处理与错误重试机制：在对接过程中，如果出现异常情况，通过完善的错误重试机制确保数据传输的可靠性。

此次集成不仅提升了两大系统间的数据交互效率，还通过可视化的数据流设计工具，使得整个过程更加直观和易于管理。接下来，我们将详细解析这一方案的具体实施步骤及技术要点。

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

在轻易云数据集成平台的生命周期中，调用源系统接口是至关重要的一步。本文将详细探讨如何通过调用金蝶云星空的executeBillQuery接口来获取收料通知单的数据，并进行必要的加工处理，以便后续集成到旺店通·旗舰奇门系统。

接口配置与调用

首先，我们需要配置和调用金蝶云星空的executeBillQuery接口。该接口主要用于查询业务单据，返回符合条件的数据记录。在本案例中，我们关注的是收料通知单的数据。

元数据配置解析

元数据配置是实现数据请求和清洗的重要基础。以下是关键字段及其描述：

• FormId: 业务对象表单Id，必须填写。例如：PUR_ReceiveBill。
• FieldKeys: 需查询的字段key集合，通过逗号分隔。
• FilterString: 过滤条件，用于筛选特定时间段、仓库编码、采购组织等条件下的数据。
• Limit: 最大行数，用于分页查询。
• StartRow: 开始行索引，用于分页查询。

这些字段在实际请求中会被动态填充，以确保查询结果准确且高效。

{
    "FormId": "PUR_ReceiveBill",
    "FieldKeys": "FID,FBillNo,FDocumentStatus,FMaterialId.fnumber,FStockOrgId.FNumber,...",
    "FilterString": "FApproveDate>='{{LAST_SYNC_TIME|dateTime}}' and (FStockID.fnumber='W005' or FStockID.fnumber='W009' or FStockID.fnumber='W019') and FPurOrgId.FNumber = '100.01'",
    "Limit": "{PAGINATION_PAGE_SIZE}",
    "StartRow": "{PAGINATION_START_ROW}"
}

数据请求与清洗

在完成元数据配置后，我们可以发起HTTP POST请求来调用executeBillQuery接口。响应的数据通常为JSON格式，需要对其进行解析和清洗，以便后续处理。

请求示例

POST /k3cloud/Kingdee.BOS.WebApi.ServicesStub.DynamicFormService.ExecuteBillQuery.common.kdsvc HTTP/1.1
Host: {K3CLOUD_HOST}
Content-Type: application/json
Authorization: Bearer {ACCESS_TOKEN}

{
    "FormId": "PUR_ReceiveBill",
    "FieldKeys": "...",
    ...
}

响应处理

收到响应后，需要对返回的数据进行解析和清洗。例如，将日期格式转换为标准格式，过滤掉不必要的字段，以及处理分页结果等。这一步骤确保了数据的一致性和完整性，为后续的数据转换与写入奠定基础。

数据转换与写入准备

在完成数据请求与清洗之后，需要根据目标系统（旺店通·旗舰奇门）的要求，对数据进行适当的转换。例如，将金蝶云星空中的物料编码映射到旺店通中的相应字段，确保两者之间的数据格式一致。

自定义转换逻辑

轻易云平台支持自定义数据转换逻辑，可以根据具体业务需求编写脚本或规则，实现复杂的数据映射和转换。例如：

def transform_data(data):
    transformed_data = []
    for record in data:
        transformed_record = {
            "purchaseOrderNo": record["FBillNo"],
            ...
        }
        transformed_data.append(transformed_record)
    return transformed_data

实时监控与异常处理

为了确保整个集成过程的可靠性，轻易云平台提供了实时监控和告警功能。通过集中监控，可以及时发现并处理异常情况，如网络故障、API限流等问题。此外，还可以设置重试机制，在遇到临时错误时自动重试，提高任务成功率。

总结

通过上述步骤，我们实现了从金蝶云星空获取收料通知单数据，并进行了必要的加工处理。这不仅保证了数据的一致性和完整性，也为后续集成到旺店通·旗舰奇门打下了坚实基础。在实际操作中，应根据具体业务需求灵活调整元数据配置和自定义转换逻辑，以达到最佳效果。

数据集成生命周期中的ETL转换：从金蝶到旺店通·旗舰奇门

在数据集成过程中，ETL（Extract, Transform, Load）转换是一个关键环节。本文将深入探讨如何将从金蝶云星空系统中提取的收料通知单数据，经过ETL转换后写入到旺店通·旗舰奇门API接口所能接收的格式，并最终成功写入目标平台。

数据提取与清洗

首先，从金蝶云星空系统中提取收料通知单的数据。这一步通常包括调用金蝶云星空的executeBillQuery接口，以获取所需的数据。为了确保数据的完整性和准确性，需要处理分页和限流问题。通过批量抓取和定时任务，确保数据不漏单。

数据转换

接下来，进入ETL流程中的“Transform”阶段。此阶段需要将提取的数据进行格式转换，以适应旺店通·旗舰奇门API接口的要求。以下是主要的字段映射和转换逻辑：

1. 采购单编号：从金蝶云星空中的FBillNo映射为旺店通中的purchase_no。
2. 供应商编号：从FSupplierId映射为provider_no。
3. 收货仓编号：从FStockID映射为receive_warehouse_nos和expect_warehouse_no。
4. 采购员：固定值“旺店通”，映射为purchaser_name。
5. 是否审核：固定值“true”，映射为is_check。

示例：

{
  "purchase_no": "{FBillNo}",
  "provider_no": "{FSupplierId}",
  "receive_warehouse_nos": "{FStockID}",
  "expect_warehouse_no": "{FStockID}",
  "purchaser_name": "旺店通",
  "is_check": "true"
}

采购单详情转换

对于采购单详情部分，需特别注意字段的嵌套结构及自定义属性。例如：

• 商家编码：从金蝶中的物料条码字段 FMaterialId_FBARCODE 映射为 spec_no
• 采购数量：从 FActReceiveQty 映射为 num
• 税前单价：从 FPrice 映射为 price
• 税后单价：从 FTaxPrice 映射为 tax_price
• 自定义属性1：从 FDetailEntity_FEntryID 映射为 prop4

示例：

{
  "purchase_details": [
    {
      "spec_no": "{{details.FMaterialId_FBARCODE}}",
      "num": "{{details.FActReceiveQty}}",
      "price": "{{details.FPrice}}",
      "tax_price": "{{details.FTaxPrice}}",
      "prop4": "{{details.FDetailEntity_FEntryID}}"
    }
  ]
}

数据加载与写入

完成数据转换后，将其通过POST请求写入到旺店通·旗舰奇门API接口中。使用的API接口为 wdt.purchase.purchaseorder.createorder, 并且确保所有必需字段都已正确填充。

{
  "api": "wdt.purchase.purchaseorder.createorder",
  "method": "POST",
  ...
}

异常处理与监控

在实际操作过程中，可能会遇到各种异常情况，如网络故障、数据格式错误等。因此，需要实现完善的异常处理与重试机制，以及实时监控系统状态。通过集中监控和告警系统，可以及时发现并解决问题，确保数据集成过程顺利进行。

总结

通过上述步骤，我们可以将金蝶云星空系统中的收料通知单数据经过ETL转换后，成功写入到旺店通·旗舰奇门API接口中。这不仅提升了数据处理的效率，还确保了数据的一致性和准确性。在整个过程中，自定义数据转换逻辑、异常处理机制以及实时监控都是关键要素。