新宝送货单-金蝶销售出库单数据集成案例分享

在企业信息化建设中，系统间的数据对接与集成是提升业务效率和数据准确性的关键环节。本文将聚焦于新宝-产业链协同平台与金蝶云星空的系统对接，通过具体案例“新宝送货单-金蝶销售出库单”来展示如何高效实现数据集成。

背景介绍

新宝-产业链协同平台作为企业供应链管理的重要工具，负责处理大量的送货单数据。而金蝶云星空则是企业财务和业务管理的核心系统之一，需要实时获取这些送货单信息以生成相应的销售出库单。为了确保两大平台之间的数据无缝对接，我们采用了轻易云数据集成平台进行配置和管理。

集成方案概述

本次集成方案旨在通过调用新宝-产业链协同平台的API接口/wms/deliveryBill，定时抓取最新的送货单数据，并批量写入到金蝶云星空系统中。为此，我们利用了轻易云数据集成平台的一系列特性：

1. 高吞吐量的数据写入能力：确保大量送货单数据能够快速、稳定地传输到金蝶云星空，提高整体处理效率。
2. 集中监控和告警系统：实时跟踪每个数据集成任务的状态和性能，及时发现并解决潜在问题。
3. 自定义数据转换逻辑：针对新宝-产业链协同平台与金蝶云星空之间的数据格式差异，进行必要的数据转换，以满足目标系统的要求。
4. 可视化的数据流设计工具：使得整个数据集成过程更加直观、易于管理，从而减少配置错误，提高实施效率。

通过上述特性的综合应用，我们不仅实现了两个系统间的数据无缝对接，还确保了整个过程中的高效性和可靠性。在后续章节中，我们将详细探讨具体的技术实现细节，包括如何调用API接口、处理分页与限流问题，以及异常处理机制等内容。

调用新宝-产业链协同平台接口/wms/deliveryBill获取并加工数据

在轻易云数据集成平台生命周期的第一步，我们需要调用新宝-产业链协同平台接口/wms/deliveryBill来获取送货单数据，并进行相应的数据加工处理。以下将详细探讨这一过程中的技术细节和关键点。

接口调用配置

首先，配置调用新宝-产业链协同平台接口的元数据。根据提供的元数据配置，可以看到该接口使用POST方法进行请求，主要参数包括：

• api: /wms/deliveryBill
• method: POST
• number: billNo
• id: billNo
• idCheck: true
• sdk: \\Adapter\\Donlim\\SDK\\DonlimSDK
• errorMsgKey: msg
• dataListKey: data
• autoPaging22: page_no

请求参数中最重要的是queryTime，用于查询特定时间范围内的数据。这一参数通过模板变量{{LAST_SYNC_TIME|dateTime}}动态生成，以确保每次同步时都能获取最新的数据。

数据请求与清洗

在实际操作中，首先需要构建HTTP请求，通过轻易云平台提供的可视化工具，可以直观地设置API地址、请求方法和参数。发送请求后，需要对返回的数据进行初步清洗和验证。

1. 错误处理：检查返回结果中的错误信息字段（msg），如果存在错误信息，则记录日志并触发告警机制。
2. 分页处理：由于可能存在大量数据，接口支持分页查询，通过设置page_no参数实现自动分页抓取。
3. 数据提取：从返回结果中提取有效数据列表（字段为data），并逐条处理。

数据转换与写入

在完成初步清洗后，需要对数据进行进一步的转换，以适应目标系统金蝶云星空的需求。这一步通常涉及以下几个方面：

1. 格式转换：根据金蝶云星空的要求，对字段名称和格式进行转换。例如，将送货单号字段从billNo转换为目标系统所需的格式。
2. 自定义逻辑：根据业务需求，自定义一些特殊逻辑，如计算某些字段值或合并多条记录等。
3. 批量写入：利用轻易云平台高吞吐量的数据写入能力，将处理后的数据快速批量写入到金蝶云星空系统中。

监控与异常处理

为了确保整个集成过程顺利进行，需要实时监控任务状态，并及时处理异常情况。轻易云平台提供了集中监控和告警系统，可以实时跟踪每个任务的执行情况，并在出现问题时立即通知相关人员。

1. 日志记录：详细记录每次API调用、数据处理和写入过程中的日志信息，便于后续分析和排查问题。
2. 重试机制：对于失败的任务，设置自动重试机制，以提高整体成功率。
3. 质量监控：通过内置的数据质量监控功能，及时发现并修正可能存在的数据问题，如重复记录、缺失字段等。

实现效果

通过上述步骤，我们可以高效地从新宝-产业链协同平台获取送货单数据，并将其无缝集成到金蝶云星空系统中。这不仅提升了业务流程的自动化程度，还确保了数据的一致性和准确性，为企业决策提供了可靠的数据支持。

集成方案：新宝送货单-金蝶销售出库单的ETL转换与写入

在数据集成过程中，ETL（抽取、转换、加载）是至关重要的一步。本文将重点介绍如何将新宝-产业链协同平台的数据通过轻易云数据集成平台，转换为金蝶云星空API接口所能够接收的格式，并最终写入目标平台。

数据请求与清洗

首先，从新宝-产业链协同平台接口中提取送货单数据。通过定时任务可靠地抓取接口数据，确保不漏单，并处理分页和限流问题。这一步骤的关键是保证数据的完整性和准确性。

数据转换

在数据转换阶段，轻易云数据集成平台提供了强大的自定义数据转换逻辑和可视化的数据流设计工具。以下是一些关键字段的转换逻辑示例：

1. 单据类型 (FBillTypeID)：

   • 固定值 "XSCKD01_SYS"，通过 ConvertObjectParser 转换为金蝶识别的编码。

2. 日期 (FDate)：

   • 直接从源数据字段 applyTime 获取并映射到目标字段。

3. 客户 (FCustomerID)：

   • 通过 _findCollection 方法，根据 deliveryDetail.poNo 查询客户编码并进行映射。

4. 物料编码 (FMaterialID)：

   • 从 deliveryDetail.materialNo 获取物料编码，通过 ConvertObjectParser 转换为金蝶识别的编码。

5. 实发数量 (FRealQty)：

   • 直接从 deliveryDetail.materialNum 获取并映射到目标字段。

6. 仓库 (FStockID)：

   • 固定值 "CK003"，通过 ConvertObjectParser 转换为金蝶识别的编码。

7. 订单行号 (FSOEntryId)：

   • 通过 _findCollection 方法，根据 deliveryDetail.poNo 和 deliveryDetail.materialNo 查询订单行号并进行映射。

这些字段的转换逻辑确保了源平台的数据能够准确无误地转化为目标平台所需格式。下面是一个简化后的配置示例：

{
  "field": "FCustomerID",
  "label": "客户",
  "type": "string",
  "parser": {
    "name": "ConvertObjectParser",
    "params": "FNumber"
  },
  "value": "_findCollection find FCustId_FNumber from da44aec5-927f-36bb-af83-e3b54d377d4e where F_GZHQ_Text_KHDDH={{deliveryDetail.poNo}}"
}

数据写入

在完成数据转换后，下一步是将数据批量写入到金蝶云星空。使用金蝶云星空提供的API接口，我们可以实现高吞吐量的数据写入能力，确保大量数据能够快速被集成到系统中，提升数据处理的时效性。

以下是批量保存操作的部分配置：

{
  "api": "batchSave",
  "method": "POST",
  "operation": {
    "rowsKey": "array",
    "rows": 20,
    "method": "batchArraySave"
  }
}

在实际操作中，通过设置 IsAutoSubmitAndAudit 参数，可以控制是否自动提交并审核单据。此外，还可以通过 IsVerifyBaseDataField 参数来决定是否验证所有基础资料的有效性，从而保证数据质量。

异常处理与监控

为了确保整个流程顺利进行，实时监控和日志记录至关重要。轻易云数据集成平台提供了集中监控和告警系统，可以实时跟踪数据集成任务的状态和性能。一旦出现异常情况，可以及时处理，并支持错误重试机制，以最大程度减少因网络或系统故障导致的数据丢失或重复问题。

数据质量监控

最后，为了保证最终写入的数据质量，需要对整个过程中的每个环节进行严格监控和异常检测。一旦发现问题，可以立即进行处理，确保最终进入金蝶云星空的数据准确无误。

综上所述，通过合理配置元数据和利用轻易云数据集成平台强大的功能，我们可以高效地将新宝-产业链协同平台的数据转化为金蝶云星空API接口所能接收的格式，并成功写入目标平台。