利用轻易云平台实现聚水潭与金蝶云星空的数据同步

轻易云数据集成平台：深度解析聚水潭与金蝶云星空的数据写入

2022-03-02 16:02:37
轻易云集成顾问-曾平安

聚水潭其他出库数据集成到金蝶云星空案例分享

在进行企业信息化系统的对接与整合时，确保不同平台之间的数据无缝流转是至关重要的一环。本文将聚焦一个实际案例——如何通过轻易云数据集成平台，实现聚水潭系统的其他出库单数据高效、准确地写入到金蝶云星空中，以期为读者提供有针对性的技术思路和解决方案。

任务概述： 本次任务主要涉及两个关键API接口的使用，即从聚水潭获取其他出库单数据 /open/other/inout/query 和向金蝶云星空批量写入数据 batchSave。挑战在于应对大容量、分页处理及两系统间的数据格式差异等问题。

高吞吐量的数据写入能力： 为了满足大量订单快速、高效地传输需求，我们必须设计一个具有高吞吐量的数据写入能力的解决方案。在此过程中，通过轻易云集成平台强大的并行处理和批量操作功能，将大量聚水潭订单数据打包后批量提交至金蝶云星空，有效提升了处理时效性。同时，通过实时监控机制，确保每一次操作都具备可追溯性，有问题能第一时间响应和修复。

分页与限流策略： 由于聚水潭接口对于单一请求返回记录数量有限制，需要特别关注分页机制以及限流管理。从而避免因请求频率过快引发限流封禁，在设计实现中需考虑定时调度策略和缓存控制，并尽可能优化API调用次数，提高资源利用效率。

异常检测与重试机制： 面对网络波动或突发异常情况，建立健全完善的错误捕捉及重试机制尤为必要。当任何阶段出现失败，例如某次数据推送因网络问题未成功，则通过内置告警系统立刻生成日志并触发自动重试逻辑，从而保障整个流程不中断运行，使得最终几乎零漏单发生。

接下来，将详细介绍每一步具体实施过程中的关键技术要点，包括自定义转换逻辑如何应用、两种不同格式间映射规则设置以及如何完成更加智能化实时监控，从而打造一套完美适配企业业务需求的数据集成互通体系。用友与MES系统接口开发配置

调用聚水潭接口获取并加工数据的技术实现

在轻易云数据集成平台的生命周期中，调用源系统接口获取数据是至关重要的一步。本文将深入探讨如何通过调用聚水潭的接口/open/other/inout/query来获取并加工数据。

接口配置与请求参数

首先，我们需要了解如何配置和调用聚水潭的API接口。根据提供的元数据配置，我们可以看到该接口使用POST方法进行数据请求，主要参数如下：

modified_begin: 开始修改时间，使用{{LAST_SYNC_TIME|datetime}}动态填充。
modified_end: 结束修改时间，使用{{CURRENT_TIME|datetime}}动态填充。
so_ids: 线上订单号，可选参数。
status: 单据状态，默认值为"Confirmed"。
page_index: 页码，默认值为1。
page_size: 每页记录数，使用{PAGINATION_PAGE_SIZE}动态填充。
types: 单据类型，默认值为"其它出库"，并通过解析器将字符串转换为数组。

这些参数确保了我们能够灵活地控制查询范围和结果分页。

请求示例

以下是一个具体的请求示例：

{
    "modified_begin": "2023-10-01T00:00:00",
    "modified_end": "2023-10-31T23:59:59",
    "status": "Confirmed",
    "page_index": "1",
    "page_size": "100",
    "types": ["其它出库"]
}

在这个请求中，我们指定了查询时间范围、单据状态、分页信息以及单据类型。

数据过滤与清洗

在获取到原始数据后，我们需要对其进行过滤和清洗。根据元数据配置中的条件部分，我们需要排除掉某些特定条件的数据。例如：

"condition":[
    [{"field":"so_id","logic":"notlike","value":"FBDR"}],
    [{"field":"labels","logic":"notlike","value":"星空单据"}]
]

这些条件表示我们需要排除掉so_id包含"FBDR"以及labels包含"星空单据"的数据。这一步骤可以通过编写相应的过滤逻辑来实现。

数据转换与写入

在完成数据清洗后，我们需要将数据转换为目标系统所需的格式，并写入目标系统。在本案例中，我们将处理后的数据写入金蝶其他出库单。这个过程通常包括字段映射、格式转换等操作。

例如，将聚水潭返回的数据字段映射到金蝶系统所需的字段：

{
    "io_id": "order_id",
    "modified_time": "update_time",
    // 其他字段映射
}

实时监控与错误处理

为了确保整个流程的稳定性和可靠性，我们需要对数据处理过程进行实时监控，并设置相应的错误处理机制。例如，可以通过轻易云平台提供的监控工具实时查看数据流动和处理状态，并在发生错误时及时报警或重试。

总结

通过以上步骤，我们实现了从聚水潭接口获取并加工数据的全过程。这不仅提高了数据集成的效率，也确保了数据的一致性和准确性。在实际应用中，根据业务需求灵活调整参数和处理逻辑，可以进一步优化集成效果。企业微信与ERP系统接口开发配置

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

在数据集成的生命周期中，数据转换与写入是关键的一步。本文将详细探讨如何利用轻易云数据集成平台，将已经集成的源平台数据进行ETL转换，并转为金蝶云星空API接口所能够接收的格式，最终写入目标平台。

配置元数据

首先，我们需要配置元数据，以确保数据能够正确地映射到金蝶云星空的API接口。以下是一个典型的元数据配置示例：

{
  "api": "batchSave",
  "effect": "EXECUTE",
  "method": "POST",
  "idCheck": true,
  "request": [
    {"field":"FBillNo","label":"单据编号","type":"string","describe":"单据编号","value":"{io_id}"},
    {"field":"FBillTypeID","label":"单据类型","type":"string","describe":"标准其他出库单：QTCKD01_SYS\n资产出库：QTCKD02_SYS\nVMI出库：QTCKD03_SYS\n费用物料出库：QTCKD04_SYS\n库存调整：QTCKD05_SYS","parser":{"name":"ConvertObjectParser","params":"FNumber"},"value":"QTCKD01_SYS"},
    {"field":"FStockOrgId","label":"库存组织","type":"string","describe":"组织","parser":{"name":"ConvertObjectParser","params":"FNumber"},"value":"_function CASE '{lock_wh_id}' WHEN '' THEN '115' ELSE '{lock_wh_id}' END"},
    {"field":"FPickOrgId","label":"领用组织","type":"string","describe":"领用组织","parser":{"name":"ConvertObjectParser","params":"FNumber"},"value":"_function CASE '{lock_wh_id}' WHEN '' THEN '115' ELSE '{lock_wh_id}' END"},
    {"field":"FStockDirect","label":"库存方向","type":"string","describe":"库存方向","value":"GENERAL"},
    {"field":"FDate","label":"日期","type":"string","describe":"日期","value":"{io_date}"},
    {"field":"FDeptId","label":"领料部门","type":"string","describe":"基础资料","parser":{"name":"ConvertObjectParser","params":"FNumber"},"value":"BM000008"},
    {"field":"FOwnerTypeIdHead","label":"货主类型","type": "string", "describe": "多类别基础资料列表", "value": "BD_OwnerOrg"},
    {"field": "FOwnerIdHead", "label": "货主", "type": "string", "describe": "多类别基础资料", "parser": { "name": "ConvertObjectParser", "params": "FNumber" }, "value": "_function CASE '{lock_wh_id}' WHEN '' THEN '115' ELSE '{lock_wh_id}' END"},
    {"field": "FNote", "label": "备注", "type": "string", "describe": "", value: "{remark}"},
    {"field": "F_kd_Base", label: “领料人”, type: “string”, value: “000”, parser: { name: “ConvertObjectParser”, params: “FSTAFFNUMBER” }},
    {
      field: “FEntity”,
      label: “明细信息”,
      type: “array”,
      describe: “明细信息”,
      value: “items”,
      children: [
        { field: “FMaterialId”, label: “物料编码”, type: “string”, describe: “基础资料”, parser:{ name:“ConvertObjectParser”, params:“FNumber” }, value:“{{items.sku_id}}”},
        { field:“FQty”, label:“实发数量”, type:“string”, describe:“数量”, value:“{{items.qty}}”},
        { field:“FStockId”, label:“发货仓库”, type:“string”, describe:“基础资料”， parser:{ name:"ConvertObjectParser", params:"FNumber" }, value:"{wms_co_id}" },
        { field:"FSTOCKSTATUSID", label:"库存状态", type:"string", describe:"库存状态"， parser:{ name:"ConvertObjectParser"， params:"FNumber" }, value:"KCZT01_SYS" },
        { field:"FOwnerTypeId"， label:"货主类型"， type:"string"， describe:"多类别基础资料列表"， value："BD_OwnerOrg" },
        { field:"FOwnerid"， label:"货主"， type："string"， describe："多类别基础资料"， parser:{ name："ConvertObjectParser"， params："FNumber" }， value：“_function CASE '{lock_wh_id}' WHEN '' THEN '115' ELSE '{lock_wh_id}' END” },
        { field：“FKeeperTypeId”， label：“保管者类型”， type：“string”， describe：“保管者类型”， value：“BD_KeeperOrg” },
        { field：“FKeeperId”， label：“保管者”， type：“string”， describe：“保管者”， parser：{ name：“ConvertObjectParser”， params：“FNumber” }， value：“_function CASE '{lock_wh_id}' WHEN '' THEN '115' ELSE '{lock_wh_id}' END” }
      ]
    }
  ],
  otherRequest:[
     { field:”FormId”， label:”业务对象表单Id”， type:”string”， describe:”必须填写金蝶的表单ID如:PUR_PurchaseOrder“， value:”STK_MisDelivery“},
     { field:”IsAutoSubmitAndAudit“， label:”提交并审核“， type:”bool“， describe:”提交并审核“， value:true},
     { field:”IsVerifyBaseDataField“， label:”验证基础资料“， type:”bool“， describe:”是否验证所有的基础资料有效性，布尔类，默认false（非必录）“， value:true},
     { field:”Operation“， label:”执行的操作“， type:”string“， describe:”执行的操作“， value:”Save“},
     { field：”InterationFlags“, label：”可以负库存“, type：”string“, describe：”可以负库存“, value：”STK_InvCheckResult“
  ],
  operation:{
     rowsKey:"array",
     rows:1,
     method:"batchArraySave"
   }
}

数据字段解析与映射

在上述配置中，每个字段都对应于金蝶云星空API接口中的具体参数。例如：

FBillNo 对应于源系统中的 {io_id}。
FBillTypeID 固定为 QTCKD01_SYS 表示标准其他出库单。
FPickOrgId 和 FOwnerIdHead 等字段通过 _function 函数进行条件判断和转换。

特别需要注意的是，通过 parser 属性，我们可以使用 ConvertObjectParser 来解析和转换复杂的数据类型，例如将源系统中的字符串值转换为目标系统所需的编码格式。

明细信息处理

对于数组类型的数据，如明细信息 FEntity 字段，我们需要逐项处理每个子字段：

items.sku_id 映射到 FMaterialId。
items.qty 映射到 FQty。
wms_co_id 映射到 FStockId。

这些字段通过模板字符串和解析器进行动态赋值和转换。

提交与审核

在配置中，我们设置了 IsAutoSubmitAndAudit 为 true 表示自动提交并审核。同时，通过设置 Operation 为 "Save" 来指定执行保存操作。

API调用

最后，通过配置中的 "method" 和 "operation" 字段，我们指定了使用 POST 方法进行批量保存操作。轻易云平台会根据这些配置生成相应的请求，并调用金蝶云星空的 API 接口，实现数据写入。

这种全异步、可视化的数据处理方式，不仅提高了开发效率，还确保了数据处理过程的透明度和可追溯性。通过合理配置元数据，可以轻松实现不同系统间的数据无缝对接，为企业提供高效、可靠的数据集成解决方案。打通企业微信数据接口

版权声明

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