调用金蝶云星空API获取供应链数据的最佳实践

轻易云平台：从源平台到目标系统的ETL转换详解

2021-03-11 09:11:41
轻易云集成顾问-曾平安

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

在企业的供应链管理过程中，数据集成的效率和准确性至关重要。本文将聚焦于“柏为金蝶退料申请退料开单08.03”这一实际运行方案，详细探讨如何通过轻易云数据集成平台，实现金蝶云星空与旺店通·旗舰奇门之间的数据对接。

确保金蝶云星空数据不漏单

首先，我们利用轻易云强大的API调度能力，调用金蝶云星空的executeBillQuery接口，从源头上确保数据获取无遗漏。在配置初期，通过设置高频率抓取策略与实时监控机制，每隔固定时间段定时抓取最新的退料申请单。同时，为防止接口限流问题导致的数据丢失，我们采用分页拉取方式，即每次只请求一定数量的数据，并使用断点续传技术保证不会跳过任何一笔记录。

大量数据快速写入到旺店通·旗舰奇门

处理完从金蝶系统获取的数据后，需要将其迅速、批量地写入到目标系统——旺店通·旗舰奇门。我们选用 wdt.purchase.purchasereturn.createorder 接口进行操作。在此过程中，重点是优化并发写入策略，将大量订单按并行任务分配给多个线程执行，以提高整体效能。此外，通过建立临时缓存队列来存储待同步的数据，可以有效减少主程序阻塞，提高吞吐量。

处理两系统间的数据格式差异

不同系统对于同一类业务对象有着不同的数据结构定义。这就要求在进行跨系统对接时，对源端和目的端之间的字段及值类型做一个详细映射。我们在设计这个案例中的映射规则时，引入了自定义转换函数库，能够根据具体业务需求灵活调整各字段间的对应关系，从而实现无缝衔接。例如，对于日期格式、货币单位等常见不同点，都逐一进行了细化处理。

异常处理与错误重试机制

现实中不可避免会出现网络波动或者服务器响应超时等异常情况。因此，在整个流程中引入自动错误检测及重试机制显得尤为必要。当某条记录由于短暂性网络或者服务故障未能成功推送至旺店通，我们会先记录相关日志信息，并将在适当时间周期后再次尝试发送。这样不仅可以最大程度保证业务连续性，也极大增强了整体流程的鲁棒性。

综上所述，本案例展示了如何高效、可靠地完成从金蝶云星空到旺店通·旗舰奇门钉钉与ERP系统接口开发配置

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

在数据集成的生命周期中，调用源系统接口获取数据是至关重要的一步。本文将深入探讨如何通过轻易云数据集成平台调用金蝶云星空的executeBillQuery接口来获取退料申请单据的数据，并进行初步加工。

接口配置与请求参数

首先，我们需要配置executeBillQuery接口的元数据。以下是具体的配置细节：

API: executeBillQuery
Method: POST
Pagination: 支持分页，每页100条记录
ID Check: 启用ID检查，确保唯一性

请求参数包括多个字段，这些字段涵盖了退料申请单据的各个方面，如单据编号、申请日期、供应商等。以下是部分关键字段及其配置：

[
  {"field":"FEntity_FEntryID","label":"FEntity_FEntryID","type":"string","value":"FEntity_FEntryID"},
  {"field":"FBillNo","label":"单据编号","type":"string","value":"FBillNo"},
  {"field":"FID","label":"FID","type":"string","value":"FID"},
  {"field":"FDocumentStatus","label":"单据状态","type":"string","value":"FDocumentStatus"},
  {"field":"FBillTypeID_Fnumber","label":"单据类型","type":"string","value":"FBillTypeID.Fnumber"},
  {"field":"FDate","label":"申请日期","type":"string","value":"FDate"},
  {"field":"FPURCHASEORGID_Fnumber","label":"采购组织","type":"string","value":"FPURCHASEORGID.Fnumber"},
  {"field":"FRMTYPE","label":"退料类型","type":"string","value":"FRMTYPE"}
]

此外，还需要配置分页参数和过滤条件：

[
  {"field": "Limit", "label": "最大行数", "type": "string", "describe": "金蝶的查询分页参数", "value": "{PAGINATION_PAGE_SIZE}"},
  {"field": "StartRow", "label": "开始行索引", "type": "string", "describe": "金蝶的查询分页参数", "value": "{PAGINATION_START_ROW}"},
  {"field": "FilterString", "label": "过滤条件", "type": "string", "describe": "示例写法 FSupplierId.FNumber = 'VEN00010' and FApproveDate>=", "value": "FApproveDate>='{{LAST_SYNC_TIME|dateTime}}'"}
]

数据请求与清洗

在完成元数据配置后，我们可以通过轻易云平台发起对金蝶云星空的API请求。以下是一个示例请求体：

{
  "FormId": "PUR_MRAPP",
  "FieldKeys": [
    "FEntity_FEntryID",
    "FBillNo",
    ...
  ],
  "FilterString": "FApproveDate>='2023-01-01'",
  ...
}

请求成功后，返回的数据可能包含多个记录，每个记录对应一个退料申请单据。我们需要对这些数据进行清洗和初步加工，以便后续处理。

数据转换与写入

在清洗过程中，我们可以根据业务需求对数据进行转换。例如，将日期格式标准化，将金额字段转换为统一单位等。以下是一个简单的数据转换示例：

def transform_data(record):
    # 将日期格式标准化为YYYY-MM-DD
    record['FDate'] = record['FDate'].split('T')[0]
    # 将金额字段转换为统一单位（如元）
    record['FAMOUNT_F'] = float(record['FAMOUNT_F']) / 100
    return record

经过清洗和转换后的数据可以写入目标系统或数据库，以供进一步分析和使用。

实时监控与异常处理

在整个数据集成过程中，实时监控和异常处理也是不可忽视的环节。轻易云平台提供了实时监控功能，可以随时查看数据流动和处理状态。一旦发现异常，如网络故障或数据格式错误，可以及时采取措施进行修复。

通过以上步骤，我们实现了从金蝶云星空获取退料申请单据数据并进行初步加工，为后续的数据处理打下了坚实基础。这不仅提高了业务透明度和效率，也为企业决策提供了可靠的数据支持。如何对接钉钉API接口

使用轻易云数据集成平台进行ETL转换并写入旺店通·旗舰奇门API接口

在数据集成的生命周期中，ETL（提取、转换、加载）是至关重要的一环。本文将重点探讨如何使用轻易云数据集成平台，将已经集成的源平台数据进行ETL转换，并最终写入目标平台——旺店通·旗舰奇门API接口。

数据请求与清洗

在开始ETL过程之前，首先需要对源平台的数据进行请求和清洗。这一步骤包括从源系统中提取所需的数据，并进行必要的清洗和预处理，以确保数据质量和一致性。

数据转换与写入

接下来，我们进入本文的核心部分：数据转换与写入。我们将详细介绍如何配置元数据，将源平台的数据转化为旺店通·旗舰奇门API接口所能接收的格式，并最终写入目标平台。

配置元数据

根据提供的元数据配置，我们需要将采购退货单单据信息和明细信息转换为旺店通·旗舰奇门API接口所需的格式。以下是具体的配置步骤：

定义API接口和请求方法

{
   "api": "wdt.purchase.purchasereturn.createorder",
   "method": "POST",
   "idCheck": true
}

设置操作方法

{
   "operation": {
       "method": "merge",
       "field": "FBillNo,FStockId_Fnumber,FSUPPLIERID_Fnumber",
       "bodyName": "details",
       "header": ["FBillNo", "FStockId_Fnumber", "FSUPPLIERID_Fnumber"],
       "body": ["FMATERIALID_Fnumber", "FMRAPPQTY", "FALLAMOUNT_F"]
   }
}

构建请求体

订单信息（orderInfo）

{
 "field": "orderInfo",
 "label": "采购退货单单据信息",
 "type": "object",
 "describe": "采购退货单单据信息",
 "children": [
     {"field": "outer_no", "label": "外部单号", "type": "string", 
        "describe": "外部单号", 
        "value":"{FBillNo}", 
        "parent":"orderInfo"},
     {"field": "warehouse_no", 
        "label":"仓库编码", 
        "type":"string", 
        "describe":"仓库编码", 
        "value":"{FStockId_Fnumber}", 
        "parent":"orderInfo"},
     {"field":"provider_no","label":"供应商编号","type":"string","describe":"供应商编号","value":"{FSUPPLIERID_Fnumber}","parent":"orderInfo"},
     {"field":"post_fee","label":"邮费","type":"string","describe":"邮费","parent":"orderInfo"},
     {"field":"other_fee","label":"其他费用","type":"string","describe":"其他费用","parent":"orderInfo"},
     {"field":"contact","label":"联系人","type":"string","describe":"联系人（若未传该参数，使用供应商默认的联系人）","value":"1","parent":"orderInfo"},
     {"field":"telno","label":"联系电话","type":"string","describe":"联系电话（若未传该参数，使用供应商默认的电话）","value":"1","parent":"orderInfo"},
     {"field":
        "receive_address",
        "label":
        "收件地址",
        "type":
        "string",
        "describe":
        "收件地址（当省份、城市、区域、地址字段皆为空时，默认使用供应商的省市区及地址信息）",
        "value":
        "1",
        "parent":
        "orderInfo"
     },
     {"field":
        "receive_province",
        "label":
        "省",
        "type":
        "string",
        "describe":
        "省编码，可以查看城市代码表",
        "parent":
        "orderInfo"
     },
     {"field":
          receive_city,
          label:
          市,
          type:
          string,
          describe:
          市编码，可以查看城市代码表,
          parent:
          orderInfo
     },
     {"field":
         receive_district,
         label:
         区,
         type:
         string,
         describe:
         区编码，可以查看城市代码表,
         parent:
         orderInfo
     },
     {"field":
        remark,
        label:
        备注,
        type:
        string,
        describe:
        备注,
        value:
        {FNOTE_M},
        parent:
        orderInfo
    }
 ],
 value: orderInfo
}

明细信息（detailList）

{
 field: detailList,
 label: 采购退货单明细信息,
 type: array,
 describe: 采购退货单明细信息,
 children: [
    { field: spec_no, label: 单品信息, type: string, describe: 单品信息, value: {FMATERIALID_Fnumber}, parent: detailList },
    { field: num, label: 退货数量, type: string, describe: 退货数量, value: {FMRAPPQTY}, parent: detailList },
    { field: discount, label: 折扣, type: string, describe: 折扣，不传为默认值1, parent: detailList },
    { field: tax_rate, label: 税率, type: string, describe: 税率，不传默认值0, parent: detailList },
    { field: price, label: 金额, type:string, describe:"金额，不传为默认值0", value:"{FALLAMOUNT_F}", parent:"detailList"},
    { field:"unit_name", label:"基本单位", type:"string", describe:"基本单位", parent:"detailList"},
    { field:"defect", label:"是否残次品", type:"string", describe:"是否残次品true：残次品false：正品"，value："false"，parent："detailList"},
    { field:"remark"，label："备注"，type："string"，describe："备注"，parent："detailList"}
],
value：details
}

审核状态

{
    field：is_check，
    label：是否审核，
    type：string，
    describe：是否审核，
    value：false
}

通过上述配置，我们可以将源平台的数据成功转换为旺店通·旗舰奇门API接口所需的格式，并通过POST方法将其写入目标平台。

实际案例应用

在实际应用中，我们可以利用轻易云数据集成平台提供的全透明可视化操作界面，实时监控和调整数据流动及处理状态。通过配置上述元数据，我们能够实现不同系统间的数据无缝对接，大幅提升业务效率和透明度。

综上所述，通过精确配置元数据并利用轻易云数据集成平台强大的ETL功能，我们可以高效地将源平台的数据转化并写入目标平台，实现系统间的数据无缝集成。如何开发金蝶云星空API接口

版权声明

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

轻易云平台：从源平台到目标系统的ETL转换详解

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

确保金蝶云星空数据不漏单

大量数据快速写入到旺店通·旗舰奇门

处理两系统间的数据格式差异

异常处理与错误重试机制

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

接口配置与请求参数

数据请求与清洗

数据转换与写入

实时监控与异常处理

使用轻易云数据集成平台进行ETL转换并写入旺店通·旗舰奇门API接口

数据请求与清洗

数据转换与写入

配置元数据

实际案例应用

版权声明

数据集成平台运行原理

更多系统对接方案