盘亏单同步技术详解：从调用到数据写入

  • 轻易云集成顾问-叶威宏

案例分享：盘亏单同步——旺店通·企业奇门数据集成到金蝶云星空

在本技术案例中，我们将聚焦于如何通过轻易云数据集成平台实现旺店通·企业奇门的盘亏单数据与金蝶云星空的高效对接。具体来说，我们将探讨“盘亏单同步”方案，包括通过接口调用、分页限流处理以及异常处理机制等关键性技术细节，以确保万无一失的数据对接和快速写入。

首先，针对旺店通·企业奇门系统提供的API接口wdt.stockout.order.query，我们需要定时可靠地抓取其最新的数据。这一步的重要性在于保证源端不断更新的信息能够及时被捕捉而不漏单。

然后，需要应对的是大批量数据快速写入到目标系统，即金蝶云星空的挑战。这里使用的是其提供的batchSave API，通过批量提交有效提升写入效率。此外，为了适配两者之间的数据格式差异，我们还需进行定制化的数据映射转换，从而保证数据的一致性和准确性。

在涉及大量分页及限流问题上，因为API返回结果会有分页限制且存在并发请求数限制，因此必须构建一个高效稳健的分页抓取逻辑。同时，对接时也不可避免会出现一些网络波动或服务器临时响应失败，这时候重试机制便显得尤为重要，以保障最终一致性的要求。

本篇将进一步展示如何通过实时监控与日志记录来跟踪整个数据处理过程，并详细解说每个环节中的注意事项和最佳实践，从而实现稳定可靠、高效透明的数据集成解决方案。 如何对接钉钉API接口

调用旺店通·企业奇门接口wdt.stockout.order.query获取并加工数据

在数据集成的生命周期中，调用源系统接口是至关重要的一步。本文将详细探讨如何通过轻易云数据集成平台调用旺店通·企业奇门接口wdt.stockout.order.query来获取并加工数据。

接口调用配置

首先，我们需要配置元数据以便正确调用wdt.stockout.order.query接口。以下是该接口的元数据配置：

{
  "api": "wdt.stockout.order.query",
  "method": "POST",
  "number": "order_no",
  "id": "stockout_id",
  "pagination": {
    "pageSize": 30
  },
  "idCheck": true,
  "condition_bk": [[]],
  "request": [
    {"field":"start_time","label":"开始时间","type":"string","value":"{{LAST_SYNC_TIME|datetime}}"},
    {"field":"end_time","label":"结束时间","type":"string","value":"{{CURRENT_TIME|datetime}}"},
    {"field":"order_type","label":"出库单类型","type":"string","value":"4"},
    {"field":"status","label":"出库单状态","type":"string"},
    {"field":"warehouse_no","label":"仓库编号","type":"string"},
    {"field":"src_order_no","label":"源单号","type":"string"},
    {"field":"stockout_no","label":"出库单号","type":"string"}
  ],
  "otherRequest": [
    {"field":"page_size","label":"分页大小","type":"string","value":"{PAGINATION_PAGE_SIZE}"},
    {"field":"page_no","label":"页号","type":"string","value":"{PAGINATION_START_PAGE}"}
  ]
}

请求参数解析

  1. 时间参数：

    • start_time 和 end_time 分别表示查询的起始和结束时间，使用动态变量 {{LAST_SYNC_TIME|datetime}} 和 {{CURRENT_TIME|datetime}} 来获取。

  2. 订单类型：

    • order_type 固定为 "4"，表示特定类型的出库单。

  3. 其他可选参数：

    • 包括 status（出库单状态）、warehouse_no（仓库编号）、src_order_no（源单号）和 stockout_no（出库单号），这些字段可以根据实际需求进行填充。

  4. 分页参数：

    • page_size 和 page_no 用于控制分页查询，确保能够处理大批量数据。

数据请求与清洗

在配置好元数据后，通过轻易云平台发起POST请求，调用接口获取原始数据。假设我们已经成功获取了JSON格式的响应数据，接下来需要对其进行清洗和转换。

{
  "code":0,
  "message":"",
  "data":{
    "total_count":100,
    "orders":[
      {
        "stockout_id":12345,
        "order_no":"SO20231001",
        ...
      },
      ...
    ]
  }
}

  1. 提取有效信息：

    • 从响应中提取 orders 数组，这是我们需要处理的数据主体。

  2. 字段映射与转换：

    • 将原始字段映射到目标系统所需的字段。例如，将 stockout_id 转换为目标系统中的唯一标识符。

  3. 异常处理：

    • 检查返回的状态码 (code) 是否为0，以确保请求成功。如果失败，需要记录错误信息并采取相应措施。

数据转换与写入

完成数据清洗后，将其转换为目标系统所需的格式，并通过轻易云平台写入到目标数据库或另一个系统中。这一步通常包括以下操作：

  1. 格式转换：

    • 将JSON格式的数据转换为目标系统支持的格式，如CSV、XML等。

  2. 批量写入：

    • 利用轻易云平台提供的批量写入功能，提高数据写入效率。

  3. 日志记录与监控：

    • 实时监控数据流动和处理状态，确保每个环节都透明可见，并记录日志以备审计和问题排查。

通过以上步骤，我们实现了从旺店通·企业奇门接口获取并加工盘亏单同步所需的数据。这不仅提高了业务透明度，还显著提升了数据处理效率。 如何开发用友BIP接口

轻易云数据集成平台：ETL转换与金蝶云星空API接口集成技术案例

在数据集成生命周期的第二步中，我们需要将已经从源平台获取并清洗的数据进行ETL（Extract, Transform, Load）转换，使其符合目标平台金蝶云星空API接口的要求，并最终将数据写入目标平台。本文将详细探讨这一过程中的关键技术点和具体实现方法。

元数据配置解析

首先，我们需要理解元数据配置中的各个字段及其对应的含义。以下是一个典型的元数据配置示例：

{
  "api": "batchSave",
  "method": "POST",
  "idCheck": true,
  "operation": {
    "rowsKey": "array",
    "rows": 10,
    "method": "batchArraySave"
  },
  "request": [
    {"field": "FBillNo", "label": "单据编号", "type": "string", "value": "{order_no}"},
    {"field": "FBillTypeID", "label": "单据类型", "type": "string", 
     "parser": {"name": "ConvertObjectParser", "params":"FNumber"}, 
     "value":"QTCKD01_SYS"},
    {"field": "FStockOrgId", "label": "库存组织", 
     "type": "string", 
     "parser":{"name":"ConvertObjectParser","params":"FNumber"}, 
     "value":"100"},
    {"field": "FPickOrgId", 
     ...

数据请求与清洗

在这一阶段，我们已经完成了从源平台的数据请求与清洗工作。接下来，需要对这些数据进行转换，以满足金蝶云星空API接口的要求。

数据转换与写入

  1. 定义API接口和请求方法：

    • api字段指定了目标API接口为batchSave。
    • method字段指定了HTTP请求方法为POST。

  2. ID检查和批量操作：

    • idCheck字段设置为true，表示需要进行ID检查。
    • operation字段定义了批量操作的参数，包括数组键名rowsKey、每批次行数rows以及批量保存的方法名method。

  3. 请求体结构： 请求体由多个字段组成，每个字段对应金蝶云星空API所需的数据格式。以下是几个关键字段的解析：

    • 单据编号（FBillNo）：

      {"field":"FBillNo","label":"单据编号","type":"string","value":"{order_no}"}

      将源数据中的订单编号映射到目标平台的单据编号。

    • 单据类型（FBillTypeID）：

      {"field":"FBillTypeID","label":"单据类型","type":"string","parser":{"name":"ConvertObjectParser","params":"FNumber"},"value":"QTCKD01_SYS"}

      使用解析器将固定值"QTCKD01_SYS"转换为目标平台所需格式。

    • 库存组织（FStockOrgId）：

      {"field":"FStockOrgId","label":"库存组织","type":"string","parser":{"name":"ConvertObjectParser","params":"FNumber"},"value":"100"}

      同样使用解析器，将库存组织ID从源数据转换为目标格式。

  4. 明细信息（FEntity）： 明细信息是一个嵌套数组，包含多个子字段，如物料编码、实发数量、发货仓库等。每个子字段也需要进行相应的转换。例如：

    • 物料编码（FMaterialId）：

      {"field":"FMaterialId","label":"物料编码","type":"string","parser":{"name":"ConvertObjectParser","params":"FNumber"},"value":"{{details_list.goods_no}}","parent":"FEntity"}

    • 实发数量（FQty）：

      {"field":"FQty","label":"实发数量","type":"string","value":"{{details_list.goods_count}}","parent":"FEntity"}

  5. 其他请求参数： 除了主要的数据字段，还需要一些其他参数来控制API行为，例如：

    • 业务对象表单Id（FormId）：

      {"field":"FormId","label":"业务对象表单Id","type":"string","value":"STK_MisDelivery"}

    • 提交并审核（IsAutoSubmitAndAudit）：

      {"field":"IsAutoSubmitAndAudit","label":"提交并审核","type":"bool","value":"true"}

通过上述配置，我们能够将源平台的数据经过ETL转换后，按照金蝶云星空API接口的要求进行格式化，并最终通过HTTP POST请求将数据写入目标平台。这一过程不仅确保了数据的一致性和准确性，也极大提升了系统间的数据交互效率。 钉钉与ERP系统接口开发配置

版权声明

该文章《盘亏单同步技术详解：从调用到数据写入》为原创内容，版权归 广东轻亿云软件科技有限公司 所有。 未经本公司书面授权，严禁转载、引用、复制或建立镜像等行为。 若需转载或引用本文内容，请联系本公司获取授权，并在显著位置注明作者姓名、文章出处（包括原文链接）等信息。

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