轻易云平台助力企业数据集成：案例分享与技术细节

  • 轻易云集成顾问-蔡威

基于轻易云平台的聚水潭·奇门与KIS私有云数据集成案例分享

在现代企业的信息化管理中，实现不同系统间的数据无缝对接是提升业务效率和透明度的重要手段。本文将详细介绍一个实际运行的系统对接集成方案，即如何通过轻易云数据集成平台，将聚水潭·奇门发货单的数据高效、准确地同步到KIS私有云销售出库单中。

该方案名为“聚水潭-发货单——>KIS-销售出库单”，它不仅保证了数据在流转过程中的不漏单问题，还能够处理大量数据的快速写入，确保两大系统之间的数据一致性。同时，我们将重点探讨以下几个技术环节：

  1. 如何调用聚水潭·奇门接口jushuitan.saleout.list.query：这一API用于定时可靠地抓取发货单信息，是整个对接流程中的关键起点。我们会深入解析其分页和限流机制，以确保每次抓取操作都能获得最新且完整的数据。

  2. 批量集成数据到KIS私有云：为了提高效率，我们采用批量处理方式，通过调用KIS私有云提供的API /koas/app007104/api/salesdelivery/create，实现大量数据快速写入。这一部分还包含了如何定制化映射两边系统的数据格式差异。

  3. 异常处理与错误重试机制：任何复杂的系统对接都不可避免会遇到网络波动或接口响应异常等问题。本方案设计了一套完善的异常处理与错误重试机制，确保即便发生故障也能自动恢复，并及时完成未成功的数据传输。

  4. 实时监控与日志记录：为了让业务方随时了解数据传输状态，我们实施了实时监控及详细日志记录功能，从而使得整个流程更加透明可追溯。

综上所述，该解决方案不仅在技术层面上充分考虑到了各种细节，如接口调用、分页限流、格式转换等，也通过一些先进特性的应用，大幅提升了总体效率和稳定性。在后续内容中，我们将具体展示这些特性的实现方法及相关代码示例，以供参考。 用友与MES系统接口开发配置

调用聚水潭·奇门接口获取并加工数据

在轻易云数据集成平台的生命周期中，调用源系统接口是至关重要的一步。本文将详细探讨如何通过调用聚水潭·奇门接口jushuitan.saleout.list.query来获取发货单数据，并进行初步加工。

接口配置与请求参数

首先，我们需要配置接口元数据，以便正确调用聚水潭·奇门的API。以下是该接口的元数据配置：

{
  "api": "jushuitan.saleout.list.query",
  "effect": "QUERY",
  "method": "POST",
  "number": "io_id",
  "id": "io_id",
  "name": "io_id",
  "idCheck": true,
  "request": [
    {
      "field": "page_index",
      "label": "页数",
      "type": "string",
      "describe": "第几页，从第一页开始，默认1",
      "value": "1"
    },
    {
      "field": "page_size",
      "label": "每页行数",
      "type": "string",
      "describe": "每页多少条，默认25，最大25",
      "value": "100"
    },
    {
      "field": "start_time",
      "label": "修改开始时间",
      "type": "string",
      "describe": "修改起始时间，和结束时间必须同时存在，时间间隔不能超过七天，与线上单号不能同时为空",
      "value": "{{DAYS_AGO_1|date}} 00:00:00"
    },
    {
      "field": "end_time",
      "label": "修改结束时间",
      "type": "string",
      "describe": "修改结束时间，和起始时间必须同时存在，时间间隔不能超过七天，与线上单号不能同时为空",
      "value": "{{DAYS_AGO_1|date}} 23:59:59"
    },
    {
      "field": "status",
      "label": “单据状态”,
      “type”: “string”,
      “describe”: “单据状态: WaitConfirm=待出库; Confirmed=已出库; Cancelled=作废”,
       “value”: “Confirmed”
    },
    {
       “field”: “date_type”,
       “label”: “时间类型”,
       “type”: “int”,
       “describe”: “时间类型 默认0 0=修改时间 ; 1=制单日期; 2=出库时间”,
       “value”: “2”
     }
   ],
   “buildModel”: true,
   “autoFillResponse”: true,
   “beatFlat”: [“items”]
}

请求参数详解

  • page_index: 页数，从第一页开始，默认值为1。
  • page_size: 每页行数，默认25条记录，最大值为25。
  • start_time 和 end_time: 修改起始和结束时间，这两个参数必须同时存在且间隔不超过七天。
  • status: 单据状态，此处我们选择“Confirmed”，即已出库的单据。
  • date_type: 时间类型，我们选择2，即按出库时间筛选。

数据请求与清洗

在轻易云数据集成平台中，我们通过POST方法发送上述请求参数至聚水潭·奇门接口。返回的数据会自动填充到预定义的响应模型中，并进行初步清洗。

例如，对于返回的数据结构：

{
  “code”: 0,
  “message”: "",
  ”data“: [
     {
        ”io_id“: ”12345“，
        ”warehouse_code“: ”WH001“，
        ”order_code“: ”ORD12345“，
        ...
     }
     ...
   ]
}

我们可以利用beatFlat属性将嵌套的items数组平铺展开，使得后续的数据处理更加简洁高效。

数据转换与写入

在完成数据请求与清洗后，我们需要将这些数据转换为目标系统所需的格式，并写入到KIS系统中的销售出库单。此过程涉及字段映射、格式转换等操作。例如，将io_id映射为KIS系统中的唯一标识符，将warehouse_code映射为仓库编码等。

通过轻易云数据集成平台的可视化界面，我们可以直观地完成这些映射和转换操作，并实时监控数据流动和处理状态，以确保整个过程透明高效。

以上就是调用聚水潭·奇门接口获取并加工发货单数据的详细技术案例。希望这些技术细节能为您的系统集成工作提供有价值的参考。 用友BIP接口开发配置

使用轻易云数据集成平台进行ETL转换并写入KIS私有云API接口的技术案例

在数据集成过程中，将源平台的数据转换为目标平台可接受的格式是关键的一步。本文将详细探讨如何使用轻易云数据集成平台，将聚水潭的发货单数据转换为KIS私有云API接口所能接收的销售出库单格式，并最终写入目标平台。

API接口配置

我们需要向KIS私有云发送POST请求，API路径为/koas/app007104/api/salesdelivery/create。以下是元数据配置中的关键字段和对应的处理逻辑：

  • AccountDB: 固定值001，表示账套数据库。
  • Object: 包含两个子对象Head和Entry，分别对应表头和表体信息。

表头（Head）字段解析

  1. FBillNo（单据编号）:

    • 类型：string
    • 来源：聚水潭发货单的唯一标识符。

  2. FMarketingStyle（业务类型）:

    • 类型：int
    • 固定值：12530

  3. FSaleStyle（销售方式）:

    • 类型：string
    • 固定值：101

  4. FSupplyID（购货单位）:

    • 类型：int
    • 来源：聚水潭客户ID。

  5. Fdate（日期）:

    • 类型：string
    • 处理逻辑：使用函数将日期格式化为ISO 8601标准，例如 _function REPLACE ('{{date_short|datetime}}',' ','T')

  6. FDCStockID（仓库）:

    • 类型：int
    • 映射逻辑：根据仓库ID映射到目标系统的仓库ID，例如 {wms_co_id}-1

  7. FExplanation（摘要）:

    • 类型：string
    • 处理逻辑：根据不同仓库ID生成相应描述，例如 _function CONCAT( CASE '{wms_co_id}' WHEN '10736306' THEN '陈梓波' ELSE '新仓库' END,'-{shop_name}-{date_short}')

  8. FBillerID（制单人）、FFManagerID（销售负责人）、FSManagerID（保管人）:

    • 类型：string
    • 固定值分别为 16439, 16043, 16043

表体（Entry）字段解析

  1. FItemID（产品代码）:

    • 类型：int
    • 处理逻辑：通过MongoDB查询获取产品代码，例如 _mongoQuery 30fa1b2b-6cfc-31c2-90a3-5a497b7812bd findField=content.FItemID where={"content.F_103":{"$eq":"{items_sku_id}"}}

  2. FUnitID（物料单位）:

    • 类型：string
    • 处理逻辑：通过MongoDB查询获取物料单位，例如 _mongoQuery 30fa1b2b-6cfc-31c2-90a3-5a497b7812bd findField=content.FProductUnitID where={"content.F_103":{"$eq":"{items_sku_id}"}}

  3. Fauxqty（实发数量）:

    • 类型：int
    • 来源：聚水潭发货单中的实际发货数量。

  4. FDCStockID（仓库表体）:

    • 类型：int
    • 映射逻辑与表头一致，例如 {wms_co_id}-1

  5. FConsignPrice（销售单价）:

    • 类型：float
    • 来源于聚水潭发货单中的销售价格。

数据转换与写入

在完成上述字段的映射和转换后，我们可以构建最终的请求体，并通过POST方法将其发送至KIS私有云API接口。以下是一个示例请求体：

{
    "AccountDB": "001",
    "Object": {
        "Head": {
            "FBillNo": "20231001",
            "FMarketingStyle": 12530,
            "FSaleStyle": "101",
            "FSupplyID": 12345,
            "Fdate": "2023-10-01T00:00:00",
            "FDCStockID": 6696536,
            "FExplanation": "陈梓波-shopA-20231001",
            "FBillerID": "16439",
            "FFManagerID": "16043",
            "FSManagerID": "16043"
        },
        "Entry": [
            {
                "FItemID": 98765,
                "FUnitID": "pcs",
                "Fauxqty": 100,
                "FDCStockID": 6696536,
                "FConsignPrice": 50.0
            }
        ]
    }
}

通过这种方式，我们能够实现从聚水潭到KIS私有云的数据无缝对接，有效提升业务流程的自动化程度和效率。 如何对接金蝶云星空API接口

版权声明

该文章《轻易云平台助力企业数据集成：案例分享与技术细节》为原创内容，版权归 广东轻亿云软件科技有限公司 所有。 未经本公司书面授权，严禁转载、引用、复制或建立镜像等行为。 若需转载或引用本文内容，请联系本公司获取授权，并在显著位置注明作者姓名、文章出处（包括原文链接）等信息。

数据集成平台集成生命周期
更多系统对接方案