如何利用轻易云平台整合金蝶云星空和旺店通数据

2021-04-08 10:22:44
轻易云集成顾问-彭亮

金蝶云星空与旺店通·企业奇门的高效数据集成实战案例

实现金蝶云星空的数据无缝对接到旺店通·企业奇门，是许多电商企业提高运营效率的重要举措。本技术案例将分享如何通过有效配置和使用API接口，确保物料信息从金蝶云星空（Kingdee Cloud）精确传输至旺店通·企业奇门（Wdt Qimen），最大限度地减少错误和遗漏。

集成挑战与解决方案

在本次系统集成中，我们主要面临以下几个技术挑战：

确保数据不漏单：需要设计可靠的机制来定时抓取金蝶云星空的数据，并处理分页和限流问题。
大量数据快速写入：借助批量操作，提高数据写入到旺店通·企业奇门的效率，同时保证准确性。
接口兼容性问题：由于两个系统之间的数据格式差异，需要对每个字段进行定制化映射，确保匹配正确。

关键步骤解析

1. 数据抓取与实时监控

我们采用金蝶云星空提供的executeBillQuery API接口，通过定时任务轮询获取最新物料信息。为了避免漏单，在每次调用接口后记录上一次成功拉取的位置，下次查询时继续从该位置开始。生命周期管理使得这个过程透明易追踪，并且可以及时发现并处理异常。

2. 批量数据推送

在完成初步的数据清洗和格式转换后，通过旺店通·企业奇门的wdt.goods.push API进行批量推送。在此过程中，为了保障大规模数据环境下稳定运行，我们设计了分段提交机制，即把所有待写入的数据拆分为多个小批次，以应对系统负载压力及网络波动影响。

3. 异常处理与重试机制

考虑到实际环境中可能出现的一些暂时性故障，例如网络超时或服务端响应延迟等情况，我们引入了一套健全的异常捕获及重试策略。一旦检测到推送失败，会自动进行多次尝试，如果依旧失败，则触发告警流程以便人工干预。此外，对每一步骤均进行了详细日志记录，实现全程可视化管理，方便后续监控分析。

通过上述方法，不仅显著提升了两套系统间的信息交互效率，还增加了任务执行过程中的鲁棒性，让业务部门能够更加专注于核心事务而非琐碎技术细节。接下来我们将逐一详解具体实施步骤以及相应代码示例。如何开发钉钉API接口

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

在数据集成的生命周期中，第一步是从源系统获取数据，并对其进行初步加工。本文将详细探讨如何通过轻易云数据集成平台调用金蝶云星空的executeBillQuery接口来实现这一过程。

接口配置与请求参数

首先，我们需要配置接口和请求参数。根据提供的元数据配置，executeBillQuery接口使用POST方法进行调用。以下是关键的请求参数及其含义：

FormId: 业务对象表单Id，必须填写金蝶的表单ID，如：BD_MATERIAL。
FieldKeys: 需查询的字段key集合，通过解析器将数组转换为字符串。
FilterString: 过滤条件，用于筛选特定的数据。
Limit, StartRow, TopRowCount: 分页参数，用于控制返回的数据量。

以下是一个示例请求体：

{
  "FormId": "BD_MATERIAL",
  "FieldKeys": "FMasterId,FNumber,FName,FSpecification,FMnemonicCode,FOldNumber,FBARCODE,FDescription,FMaterialGroup.FNumber,FMaterialGroup.FName,FErpClsID,FDocumentStatus,FForbidStatus,FBaseUnitId.FNumber,FBaseUnitId.FName,FCreateOrgId.FNumber,FUseOrgId.FNumber,FIsInventory,FIsSale,FIsAsset,FIsSubContract,FIsProduce,FIsPurchase,FStockId.FNumber,FPurchaseOrgId.FNumber,FPurchaseOrgId.FName,FIsBatchManage,FIsKFPeriod,FIsSNManage,FSafeStock,FCategoryID,FExpPeriod,FOrderQty,FMinQty,FMaxQty,FDefaultVendor.FNumber",
  "FilterString": "FUseOrgId.FNumber='100' and FApproveDate>='{{LAST_SYNC_TIME|datetime}}'",
  "Limit": 200,
  "StartRow": 0,
  "TopRowCount": true
}

数据清洗与转换

在获取到原始数据后，需要对其进行清洗和转换，以便后续处理和写入目标系统。以下是一些常见的数据清洗和转换操作：

字段映射：将源系统中的字段映射到目标系统中的相应字段。例如，将金蝶中的FMasterId映射到目标系统中的id。
数据类型转换：确保数据类型的一致性。例如，将字符串类型的数字转换为整数类型。
数据过滤：根据业务需求过滤掉不必要的数据。例如，只保留状态为“已审核”的物料信息。
数据格式化：对日期、时间等特殊格式的数据进行标准化处理。

以下是一个示例代码片段，展示了如何进行字段映射和数据类型转换：

def clean_and_transform(data):
    transformed_data = []
    for item in data:
        transformed_item = {
            "id": int(item["FMasterId"]),
            "编码": item["FNumber"],
            "名称": item["FName"],
            "规格型号": item["FSpecification"],
            # 更多字段映射...
        }
        transformed_data.append(transformed_item)
    return transformed_data

数据写入目标系统

在完成数据清洗和转换后，下一步是将处理后的数据写入目标系统。在轻易云平台上，可以通过配置相应的API接口来实现这一过程。具体操作步骤包括：

配置目标系统的API接口信息，如URL、请求方法、认证方式等。
将清洗和转换后的数据按照目标系统要求的格式组织起来。
调用目标系统的API接口，将数据批量写入。

以下是一个示例代码片段，展示了如何调用目标系统的API接口：

import requests

def write_to_target_system(data):
    url = "https://target-system-api.com/write"
    headers = {"Content-Type": "application/json"}
    response = requests.post(url, json=data, headers=headers)
    if response.status_code == 200:
        print("Data written successfully")
    else:
        print("Failed to write data", response.text)

# 示例调用
data_to_write = clean_and_transform(raw_data)
write_to_target_system(data_to_write)

通过以上步骤，我们可以实现从金蝶云星空获取并加工数据，并将其无缝对接到目标系统中。这一过程不仅提高了数据处理效率，还确保了数据的一致性和准确性。金蝶与MES系统接口开发配置

使用轻易云数据集成平台将物料云星空数据转换并写入旺店通·企业奇门API接口

在数据集成的生命周期中，数据转换与写入是至关重要的一环。本文将详细探讨如何利用轻易云数据集成平台，将来自物料云星空的数据进行ETL转换，并最终写入到旺店通·企业奇门API接口中。

元数据配置解析

首先，我们需要理解元数据配置，这些配置定义了如何将源平台的数据映射到目标平台所需的格式。以下是我们需要遵循的元数据配置：

{
  "api": "wdt.goods.push",
  "effect": "EXECUTE",
  "method": "POST",
  "idCheck": true,
  "request": [
    {
      "field": "goods_list",
      "label": "货品节点",
      "type": "array",
      "value": "skus",
      "children": [
        {"field": "goods_no", "label": "商品编码", "type": "string", "value": "{FNumber}"},
        {"field": "goods_name", "label": "货品名称", "type": "string", "value": "{FName}"},
        {"field": "short_name", "label": "货品简称", "type":"string",   "value":"{FName}"},
        {"field":"alias","label":"别名","type":"string","value":"{FName}"},
        {"field":"unit_name","label":"基本单位","type":"string","value":"{FBaseUnitId_FName}"},
        {"field":"class_name","label":"分类名称","type":"string","value":"{FMaterialGroup_FName}"},
        {"field":"aux_unit_name","label":"辅助单位","type":"string","value":"{F_kda_Base_Name}"},
        {"field":"spec_code","label":"规格编码","type":"string","value":"{FSpecification}"},
        {"field":"spec_name","label":"规格名称","type":"string","value":"{FSpecification}"},
        {"field":"goods_type","label":"货品类别","type":"string","value":"1"},
        {"field":"brand_name","label":"品牌","type":"string","value":"{F_USQR_Text}"},
        {
          "field": "spec_list",
          "label": "单品节点",
          "type":   "array",
            "value" :"{FSpecification}",
            "children":[
            {"field" :"spec_no" ,"label" :"商家编码" ,"type" :"string" ,"value" :"{FNumber}" },
            {"field" :"spec_name" ,"label" :"规格名称" ,"type" :"string" ,"value" :"{FSpecification}" },
            {"field" :"tax_rate" ,"label" :"税率" ,"type" :"string" ,"value" :"{FTaxRateId}" }
          ]
        }
      ]
    }
  ]
}

数据转换过程

提取源数据：首先，从物料云星空提取原始数据。这一步通常涉及调用物料云星空的API接口，获取包含所有必要字段的数据。
字段映射：根据元数据配置，将提取到的源数据字段映射到目标格式。例如：
- goods_no 对应 {FNumber}
- goods_name 对应 {FName}
- unit_name 对应 {FBaseUnitId_FName}
- class_name 对应 {FMaterialGroup_FName}
嵌套结构处理：处理嵌套结构，如 spec_list 节点，它包含多个子字段。确保每个子字段都正确映射：
- spec_no 对应 {FNumber}
- tax_rate 对应 {FTaxRateId}
默认值设置：某些字段可能需要设置默认值，如 goods_type 设置为 "1"。

数据写入过程

构建请求体：根据映射后的数据，构建符合旺店通·企业奇门API接口要求的请求体。例如：

{
    "goods_list":[
    {
        "goods_no": "{FNumber}",
        "goods_name": "{FName}",
        ...
        "class_name": "{FMaterialGroup_FName}",
        ...
        "spec_list":[
        {
            "spec_no": "{FNumber}",
            ...
            "tax_rate": "{FTaxRateId}"
        }
      ]
    }
  ]
}

发送请求：使用HTTP POST方法，将构建好的请求体发送到旺店通·企业奇门API接口。确保请求头和认证信息正确无误。
响应处理：接收并处理API响应，记录成功或失败的信息，以便后续追踪和调试。

实际案例分析

假设我们有以下源数据：

{
    "skus":[
    {
        "FNumber": "12345",
        "FName": "商品A",
        ...
        "FBaseUnitId_FName":  "Pcs",
      ...
    }
  ]
}

通过上述步骤，我们将其转换为目标格式并发送至旺店通·企业奇门API接口：

{
  "goos_list":[
    {
      "goos_no ":    “12345”,
      "goos_name ":   “商品A”,
       ...
       “unit_name”:   “Pcs”,
       ...
   }
  ]
}

通过这种方式，我们实现了从物料云星空到旺店通·企业奇门的数据无缝对接，有效提升了系统间的数据一致性和业务效率。钉钉与MES系统接口开发配置

版权声明

该文章《如何利用轻易云平台整合金蝶云星空和旺店通数据》为原创内容，版权归 广东轻亿云软件科技有限公司 所有。未经本公司书面授权，严禁转载、引用、复制或建立镜像等行为。若需转载或引用本文内容，请联系本公司获取授权，并在显著位置注明作者姓名、文章出处（包括原文链接）等信息。