轻易云助力零售业务数据无缝集成：从吉客云·奇门到金蝶云星空

  • 轻易云集成顾问-潘裕

礼顿销售单对接（92-零售业务）：吉客云·奇门数据集成到金蝶云星空

在复杂的企业系统环境中，实现不同平台之间的数据无缝集成是一项具有挑战性的任务。本案例将分享如何利用轻易云数据集成平台，将吉客云·奇门的销售单数据高效、安全地同步到金蝶云星空，确保零售业务逻辑的一致性和准确性。

首先，我们需要从吉客云·奇门获取非敏感交易信息。通过调用API jackyun.tradenotsensitiveinfos.list.get接口，可以实现定时可靠的数据抓取。这个过程中，为了避免漏单以及处理限流问题，我们设计了一套分页处理机制，并结合日志记录实现实时监控。

一旦成功获取所需的数据，接下来便涉及大量数据快速写入到金蝶云星空。在这一步，通过调用金蝶云星空提供的batchSave API接口，我们能够批量将整理后的数据上传至目标系统。值得注意的是，在此过程中，要特别关注两端系统间的数据格式差异。因此，需要编写自定义映射规则，以匹配二者间字段和类型上的不一致。

最后，为确保集成过程中的每一个环节都精确无误，还必须考虑异常情况的处理与重试机制。例如，当遇到网络延迟或服务不可用等突发状况时，通过配置错误重试策略可以最大程度上保障数据传输的成功率。此外，根据实际业务需求，对金蝶云星空进行特定定制化操作，也是提升整体工作效率的重要手段之一。

总体而言，本次礼顿销售单对接方案不仅展示了如何调度多个API接口以实现跨平台高效、可靠的数据同步，更为今后类似项目提供了可参考、可复用的方法论。 金蝶与外部系统打通接口

调用吉客云·奇门接口获取并加工数据

在数据集成的生命周期中，第一步是从源系统调用API接口获取数据。本文将详细探讨如何通过轻易云数据集成平台调用吉客云·奇门接口jackyun.tradenotsensitiveinfos.list.get来获取销售单数据，并进行初步的数据加工。

接口调用配置

首先，我们需要配置API接口的基本信息和请求参数。根据提供的元数据配置，以下是具体的配置细节：

  • API名称: jackyun.tradenotsensitiveinfos.list.get
  • 请求方法: POST
  • 分页设置: 每页记录数为20
  • 请求参数:
    • modified_begin 和 modified_end: 修改时间区间，必须同时存在且时间间隔不超过七天。
    • startConsignTime 和 endConsignTime: 发货时间区间，默认值分别为上次同步时间和当前时间。
    • 其他参数如 tradeNo, pageSize, pageIndex, hasTotal 等。

以下是一个示例请求体：

{
  "modified_begin": "2023-09-01T00:00:00",
  "modified_end": "2023-09-07T23:59:59",
  "startConsignTime": "{{LAST_SYNC_TIME|datetime}}",
  "endConsignTime": "{{CURRENT_TIME|datetime}}",
  "tradeNo": "",
  "pageSize": 20,
  "pageIndex": 0,
  "hasTotal": 1,
  "tradeType": "92",
  "shopIds": "1615936578929590912,1589750679905665664,1569612293650678144,1534037989995479680,1534037681284908288,1534037362433589760,1534036113940612352,1534035371021730432,1533987457103036928,1627628717304480256,1647713099654399104,1650630444457984640,1686189043839762816,1682486220094539008,1717339163268907904,1717342984653341952,1819552357780390400,1819553481654075776",
  "fields": "checkTotal,tradeNo,..."
}

数据加工与格式化

在获取到原始数据后，需要对部分字段进行格式化和重命名，以便后续处理。根据元数据配置，我们需要对返回结果中的consignTime字段进行日期格式化，并重命名为consignTime_new。

假设我们收到的原始响应如下：

{
  "data": [
    {
      "tradeId": "12345",
      "tradeNo": "T123456789",
      "consignTime": "2023-09-05T14:30:00"
    },
    ...
  ]
}

我们可以使用以下代码对其进行处理：

import datetime

def format_response(data):
    for item in data:
        if 'consignTime' in item:
            item['consignTime_new'] = datetime.datetime.strptime(item['consignTime'], "%Y-%m-%dT%H:%M:%S").strftime("%Y-%m-%d %H:%M:%S")
            del item['consignTime']
    return data

# 示例调用
response_data = format_response(response_data)

数据过滤与校验

为了确保数据的准确性和完整性，我们还需要对某些字段进行校验。例如，根据元数据配置中的条件，我们只需要订单状态大于等于6000的记录。因此，可以在处理过程中添加相应的过滤逻辑：

def filter_data(data):
    return [item for item in data if int(item.get('tradeStatus', '0')) >= 6000]

# 示例调用
filtered_data = filter_data(response_data)

异常处理与重试机制

在实际操作中，可能会遇到网络波动或接口超时等异常情况。因此，需要设计合理的异常处理和重试机制，以确保数据获取过程的稳定性。可以使用如下伪代码实现：

import requests
from time import sleep

def fetch_data_with_retry(url, payload, max_retries=3):
    retries = 0
    while retries < max_retries:
        try:
            response = requests.post(url, json=payload)
            response.raise_for_status()
            return response.json()
        except requests.exceptions.RequestException as e:
            retries += 1
            sleep(2 ** retries) # 指数退避策略
            if retries == max_retries:
                raise e

# 示例调用
api_url = 'https://api.jackyun.com/tradenotsensitiveinfos/list/get'
response_data = fetch_data_with_retry(api_url, request_payload)

通过上述步骤，我们可以顺利地从吉客云·奇门接口获取并加工销售单数据，为后续的数据转换与写入奠定基础。 用友与外部系统接口集成开发

使用轻易云数据集成平台实现金蝶云星空API接口的数据转换与写入

在数据集成的生命周期中，ETL（Extract, Transform, Load）过程是将源平台的数据转换为目标平台可接受格式的关键步骤。本文将详细探讨如何利用轻易云数据集成平台，将礼顿销售单的数据转换并写入到金蝶云星空API接口中。

数据请求与清洗

在开始数据转换之前，首先需要确保已经从源系统成功获取并清洗了所需的数据。这些数据通常包含订单信息、客户信息、商品详情等。接下来，我们将重点放在如何将这些数据通过ETL过程转换为金蝶云星空API所需的格式。

元数据配置解析

元数据配置是ETL过程中的核心部分，它定义了如何将源数据映射到目标平台的字段中。以下是我们使用的元数据配置：

{
  "api": "batchSave",
  "method": "POST",
  "idCheck": true,
  "operation": {
    "rowsKey": "array",
    "rows": 1,
    "method": "batchArraySave"
  },
  ...
}

该配置文件中的各个字段定义了如何将源数据映射到金蝶云星空API的字段中。以下是一些关键字段的解析：

  • FBillNo: 出库单号，类型为字符串。
  • FBillTypeID: 单据类型，固定值为XSCKD07_SYS。
  • FDate: 日期，使用源数据中的consignTime_new字段。
  • FCustomerID: 客户，使用自定义函数从shopCodenew字段中提取客户编号。

数据转换与写入

  1. 基础信息映射

    首先，我们需要将订单的基础信息映射到金蝶云星空API所需的格式。例如：

    {
 "FBillNo": "{orderNumber}",
 "FBillTypeID": {"FNumber": "XSCKD07_SYS"},
 "FDate": "{consignTime_new}",
 ...
}

  2. 明细信息处理

    对于订单中的商品明细，需要逐条处理并映射到目标平台。例如：

    {
 "FEntity": [
   {
     "FMaterialID": {"FNumber": "{details.goodsDetail_goodsNo}"},
     "FRealQty": "{details.goodsDetail_sellCount}",
     ...
   }
 ]
}

  3. 计算与聚合

    在处理明细信息时，有时需要进行计算和聚合操作，例如计算总金额或数量。在元数据配置中，可以通过如下方式实现：

    {
 "goodsDetail_sellCount": "$sum",
 ...
}

  4. 调用API接口

    完成所有字段的映射和计算后，通过HTTP POST请求将转换后的数据发送到金蝶云星空API接口：

    {
 "FormId": "SAL_OUTSTOCK",
 "Operation": "Save",
 ...
 "Model": {
   ...
   // 映射后的完整订单数据
 }
}

示例代码

以下是一个完整的示例代码片段，用于将礼顿销售单的数据转换并写入到金蝶云星空API接口中：

import requests
import json

# 定义元数据配置
metadata = {
    # 配置内容...
}

# 准备请求体
request_body = {
    # 根据元数据配置生成请求体...
}

# 调用金蝶云星空API接口
response = requests.post(
    url="https://api.kingdee.com/k3cloud/Kingdee.BOS.WebApi.ServicesStub.DynamicFormService.BatchSave",
    headers={"Content-Type": "application/json"},
    data=json.dumps(request_body)
)

# 检查响应状态
if response.status_code == 200:
    print("Data successfully written to Kingdee Cloud")
else:
    print(f"Failed to write data: {response.text}")

总结

通过轻易云数据集成平台，我们可以高效地实现从礼顿销售单到金蝶云星空API接口的数据转换与写入。关键在于正确配置元数据，并根据业务需求进行必要的计算和聚合操作。最终，通过调用目标平台的API接口，实现无缝的数据对接。 如何对接钉钉API接口

版权声明

该文章《数据集成：如何高效同步吉客云·奇门到金蝶云星空》为原创内容，版权归 广东轻亿云软件科技有限公司 所有。 未经本公司书面授权，严禁转载、引用、复制或建立镜像等行为。 若需转载或引用本文内容，请联系本公司获取授权，并在显著位置注明作者姓名、文章出处（包括原文链接）等信息。

金蝶云星辰与聚水潭对接
更多系统对接方案