订单->销货单-平凉倍健：汤臣倍健营销云数据集成到畅捷通T+

在企业信息化系统中，数据的高效流转和准确对接是业务顺利运行的关键。本文将分享一个实际案例——如何通过轻易云数据集成平台，将汤臣倍健营销云的数据无缝集成到畅捷通T+系统中，实现订单到销货单的自动转换。

背景与挑战

在本次项目中，我们需要将汤臣倍健营销云中的订单数据，通过API接口 /openapi-basesubject/order/queryOrderHead 获取，并批量写入到畅捷通T+系统的销货单模块，使用其API接口 /tplus/api/v2/saleDelivery/Create 完成数据写入。这一过程中，我们面临以下几个技术挑战：

1. 高吞吐量的数据写入能力：由于订单数据量大，需要确保大量数据能够快速且准确地被集成到畅捷通T+系统中。
2. 实时监控与告警：需要提供集中监控和告警系统，以实时跟踪数据集成任务的状态和性能，确保及时发现并处理异常情况。
3. 分页和限流问题：处理汤臣倍健营销云接口的分页和限流问题，以保证数据抓取过程稳定可靠。
4. 数据格式差异：解决汤臣倍健营销云与畅捷通T+之间的数据格式差异，实现无缝对接。
5. 错误重试机制：在对接过程中，必须实现异常处理与错误重试机制，以提高系统的鲁棒性。

解决方案概述

为了解决上述挑战，我们设计了一个名为“订单->销货单-平凉倍健”的集成方案。该方案利用轻易云平台提供的一系列特性，包括高吞吐量的数据写入能力、集中监控和告警系统、自定义数据转换逻辑以及可视化的数据流设计工具。

1. 高效的数据抓取与写入：

   • 定时可靠地调用汤臣倍健营销云接口 /openapi-basesubject/order/queryOrderHead 抓取订单数据。
   • 批量将抓取的数据快速写入到畅捷通T+系统，通过其API接口 /tplus/api/v2/saleDelivery/Create 实现销货单创建。

2. 实时监控与日志记录：

   • 集中的监控和告警系统实时跟踪每个任务的执行状态，并记录详细日志，确保任何异常情况都能第一时间被发现并处理。

3. 自定义转换逻辑与映射对接：

   • 支持自定义的数据转换逻辑，以适应不同平台间的数据结构差异。
   • 针对畅捷通T+进行定制化的数据映射，对接过程中确保每条记录都能准确匹配目标字段。

通过这一方案，不仅实现了汤臣倍健营销云到畅捷通T+之间的大规模、高效率的数据集成，还提升了整体业务流程的透明度和可靠性。在后续章节中，我们将详细介绍具体实施步骤及技术细节。

调用汤臣倍健营销云接口获取并加工数据

在轻易云数据集成平台中，生命周期的第一步是调用源系统接口获取数据。本文将详细探讨如何通过调用汤臣倍健营销云接口/openapi-basesubject/order/queryOrderHead来获取订单数据，并进行初步加工处理。

接口调用配置

首先，我们需要配置API调用的元数据。根据提供的metadata，可以看到该接口使用POST方法，支持分页查询，每页返回30条记录。请求参数包括组织ID、页码、订单ID等多个字段。

{
  "api": "/openapi-basesubject/order/queryOrderHead",
  "method": "POST",
  "pagination": {"pageSize": 30},
  "condition": [
    [{"field":"orderStatus","logic":"egt","value":4},{"field":"orderStatus","logic":"elt","value":5}]
  ],
  "request":[
    {"field":"orgId","label":"组织ID","type":"string","value":"7d0b5f87aee34604937b565507bff326,c50fd9a2f5be43e6b04e3f2e77970327,ca727e451b2440c98e494b491f996e26"},
    {"field":"page","label":"页码","type":"string"},
    {"field":"lastStartDt","label":"最后修改时间（开始）","type":"string", "value": "{{LAST_SYNC_TIME|datetime}}"},
    {"field":"lastEndDt","label":"最后修改时间（结束）", "type": "string", "value": "2024-09-07 12:59:00"}
  ]
}

数据请求与清洗

在实际操作中，首先需要构建请求体，根据业务需求设置相应的过滤条件。例如，我们可以根据订单状态和最后修改时间来筛选订单：

{
  "orgId": ["7d0b5f87aee34604937b565507bff326", "c50fd9a2f5be43e6b04e3f2e77970327", "ca727e451b2440c98e494b491f996e26"],
  "page": 1,
  "lastStartDt": "{{LAST_SYNC_TIME|datetime}}",
  "lastEndDt": "2024-09-07T12:59:00"
}

这些参数确保我们能够准确地获取到符合条件的订单数据。在接收到响应后，需要对数据进行初步清洗，例如去除无效字段、标准化日期格式等。

分页处理与限流

由于接口返回的数据量可能较大，因此需要处理分页问题。每次请求时，通过调整page参数来逐页获取数据，直到没有更多记录为止。同时，为了避免触发API限流机制，可以在每次请求之间加入适当的延迟。

def fetch_orders():
    page = 1
    while True:
        response = call_api(page)
        if not response['data']:
            break
        process_data(response['data'])
        page += 1
        time.sleep(1) # 延迟以避免限流

数据转换与写入

在完成数据清洗后，需要将其转换为目标系统所需的格式。例如，将订单信息转换为销货单格式，并批量写入畅捷通T+系统。这一步通常涉及复杂的数据映射和逻辑处理，以确保所有字段都能正确匹配。

def transform_and_write(data):
    transformed_data = []
    for order in data:
        transformed_order = {
            '销售单号': order['no'],
            '客户名称': get_customer_name(order['applyerId']),
            '商品明细': transform_items(order['items']),
            # 更多字段映射...
        }
        transformed_data.append(transformed_order)

    write_to_tplus(transformed_data)

实时监控与异常处理

为了确保整个流程的稳定性和可靠性，需要实现实时监控和异常处理机制。一旦发现异常情况，如网络超时或API返回错误，应及时记录日志并重试操作。此外，还可以设置告警系统，在出现严重问题时通知相关人员进行干预。

try:
    fetch_orders()
except Exception as e:
    log_error(e)
    send_alert("订单抓取失败")

通过以上步骤，我们能够高效地从汤臣倍健营销云接口获取并加工订单数据，为后续的数据集成打下坚实基础。这不仅提高了业务透明度，也显著提升了整体效率。

将订单数据转换为销货单并写入畅捷通T+的实现

在轻易云数据集成平台中，数据处理的第二步是将已经集成的源平台数据进行ETL转换，转为目标平台畅捷通T+API接口所能够接收的格式，并最终写入目标平台。本文将深入探讨如何实现这一过程，特别是如何通过元数据配置来完成订单到销货单的转换和写入。

数据请求与清洗

首先，通过调用汤臣倍健营销云接口获取订单数据。这个阶段主要包括数据抓取、解析和初步清洗，以确保源数据的完整性和准确性。比如，可以定时可靠地抓取汤臣倍健营销云接口数据，处理分页和限流问题，以确保不漏单。

数据转换与写入

接下来，重点在于将清洗后的订单数据转换为畅捷通T+系统所需的销货单格式，并通过API接口写入到畅捷通T+中。以下是如何利用元数据配置来实现这一过程的详细步骤：

1. 配置API接口信息

   {
    "api": "/tplus/api/v2/saleDelivery/Create",
    "method": "POST",
    "idCheck": true,
    ...
   }

   这里定义了目标API接口的路径和请求方法，以及是否需要ID检查。

2. 字段映射与转换 利用元数据配置中的字段映射，将源平台的数据字段转换为目标平台所需的格式。例如：

   {
    "field": "VoucherDate",
    "label": "单据日期",
    "type": "string",
    "describe": "默认系统时间",
    "value": "{orderDt}"
   }

   这里，将订单日期{orderDt}映射为畅捷通T+中的VoucherDate字段。

3. 复杂对象解析 对于复杂对象，如客户信息，需要利用解析器进行转换：

   {
    "field": "Customer",
    "label": "客户",
    "type": "string",
    "describe": "...",
    "parser": {"name":"ConvertObjectParser","params":"Code"},
    "value": "{clientAppNo}"
   }

   使用ConvertObjectParser解析器，将客户编码{clientAppNo}转换为T+系统所需格式。

4. 数组与子对象处理 对于包含多个子对象的字段，如销货单明细，需要逐一映射每个子字段：

   {
    "field": "SaleDeliveryDetails",
    "label": "明细",
    ...
    "children":[
      {"field":"Inventory","label":"存货","type":"string","parser":{"name":"ConvertObjectParser","params":"Code"},"value":"{{details.extNo}}"},
      {"field":"Quantity","label":"数量","type":"string","value":"{{details.actQuantity}}"},
      ...
    ],
    ...
   }

   在这里，每个明细项都需要分别映射库存、数量、批号等字段，并使用相应的解析器进行格式转换。

5. 自定义逻辑与条件判断 有时需要根据特定条件进行逻辑判断，例如是否赠品：

   {
    "parent":"SaleDeliveryDetails",
    ...
    "field":"IsPresent",
    ...
    "_function  case '{isFree}' when '是' then 'true' else  'false' end"
   }

   通过自定义逻辑，将{isFree}字段值为“是”时映射为布尔值true，否则映射为false。

6. 备注信息拼接 最后，可以在备注中添加额外的信息以便追踪：

   {
     "label":"备注",
     ...
     "value":"{saleDistribution}(from汤臣营销云){orgId}"
   }

实现高效写入

为了确保大量数据能够快速写入到畅捷通T+系统中，需要注意以下几点：

• 高吞吐量：利用轻易云的数据高吞吐量能力，实现大批量数据快速写入。
• 异常处理与重试机制：设置可靠的异常处理和错误重试机制，确保在网络波动或其他异常情况下，不会丢失任何数据。
• 实时监控：通过实时监控和日志记录，及时发现并解决潜在问题，提高整体效率和可靠性。

通过上述步骤，我们可以高效地将源平台的订单数据转换为畅捷通T+系统所需的销货单格式，并成功写入到目标平台。这不仅提升了数据处理效率，还确保了业务流程的连续性和准确性。