轻易云数据集成平台实现KIS私有云API数据写入全流程

  • 轻易云集成顾问-姚缘

聚水潭·奇门数据集成到KIS私有云的案例分享

在本文中，我们将重点探讨如何通过轻易云数据集成平台，将聚水潭·奇门退货单信息准确、快速地集成到KIS私有云，并生成相应的红字销售出库单。具体实施过程中，主要涉及到从聚水潭·奇门接口抓取退货单数据、处理分页和限流问题，以及最终向KIS私有云写入规范化的数据。

首先，为确保不漏单，系统会定时可靠地调用聚水潭·奇门提供的API——jushuitan.refund.list.query。这个过程要求我们设计一个可靠的调度机制，以固定间隔抓取新产生的数据。同时需要注意的是，聚水潭·奇门API存在访问频率限制，因此必须妥善处理分页和限流问题，以避免对服务造成过大压力或导致请求失败。

其次，大量数据快速、安全写入是关键环节之一。在收到并处理了来自聚水潭·奇门的数据后，这些信息需要迅速、高效地导入到KIS私有云。为此，我们使用了其提供的API——/koas/app007104/api/salesdelivery/create进行批量操作，同时保证每个步骤都记录详细日志以便于实时监控与追溯。

此外，由于两个系统的数据格式可能存在差异，所以在对接前要先进行必要的数据映射与转换。这一步骤不仅需考虑字段名称的不一致，还需兼顾业务逻辑上的差异性。例如，在转换过程中，需要将聚水潭中的某些字段匹配至KIS系统中的相应字段，并根据实际情况添加或修改部分内容，例如日期格式、金额单位等。

最后，在整个集成流程中，不可避免会遇上异常情况，如网络故障或者接口响应错误。因此，建立健全的错误重试机制尤为重要。一旦捕捉到了任何异常，通过自动重试以及通知相关运维人员，可以最大程度减少因为各种故障带来的影响和损失。

本次案例展示了如何高效利用轻易云平台实现复杂场景下的数据对接，从而确保各业务环节顺畅衔接，提高整体运营效率。在下一部分，我们将详细阐述每个技术步骤及其实现细节。 金蝶与SCM系统接口开发配置

使用轻易云数据集成平台调用聚水潭·奇门接口获取退货单数据

在数据集成的生命周期中，第一步是从源系统获取数据。本文将深入探讨如何使用轻易云数据集成平台调用聚水潭·奇门接口jushuitan.refund.list.query来获取并加工退货单数据。

接口概述

jushuitan.refund.list.query接口用于查询聚水潭系统中的退货单列表。该接口采用POST请求方式，支持分页查询，并允许根据时间范围和货物状态等条件进行过滤。以下是该接口的元数据配置：

{
  "api": "jushuitan.refund.list.query",
  "effect": "QUERY",
  "method": "POST",
  "number": "{as_id}{modified}",
  "id": "{as_id}{modified}",
  "name": "as_id",
  "idCheck": true,
  "request": [
    {"field": "page_index", "label": "第几页", "type": "int", "describe": "从第一页开始，默认1", "value": "1"},
    {"field": "page_size", "label": "每页多少条", "type": "int", "describe": "默认30，最大50", "value": "50"},
    {"field": "start_time", "label": "修改起始时间", "type": "string", 
        "describe": 
        "起始时间，和结束时间必须同时存在，时间间隔不能超过七天，与线上单号不能同时为空",
        "value":"{{DAYS_AGO_1|date}} 00:00:00"},
    {"field":"end_time","label":"修改结束时间","type":"string","describe":"结束时间，和起始时间必须同时存在，时间间隔不能超过七天，与线上单号不能同时为空","value":"{{CURRENT_TIME|datetime}}"},
    {"field":"date_type","label":"时间类型","type":"int","describe":"修改时间:0 ; 创建时间:1; 确认时间: 2;非必填,默认0"},
    {"field":"good_status","label":"货物状态","type":"string","describe":"（BUYER_NOT_RECEIVED:买家未收到货,BUYER_RECEIVED:买家已收到货,BUYER_RETURNED_GOODS:买家已退货,SELLER_RECEIVED:卖家已收到退货","value":"SELLER_RECEIVED"}
  ],
  ...
}

请求参数详解

  • page_index: 查询的页码，从第一页开始，默认为1。
  • page_size: 每页返回的数据条数，默认为30条，最大不超过50条。
  • start_time: 修改起始时间，与结束时间必须同时存在且间隔不超过七天。
  • end_time: 修改结束时间，与起始时间必须同时存在且间隔不超过七天。
  • date_type: 时间类型，可选值为0（修改时间）、1（创建时间）、2（确认时间），默认为0。
  • good_status: 货物状态，此处设置为SELLER_RECEIVED表示卖家已收到退货。

数据请求与清洗

在轻易云数据集成平台上，我们首先需要配置上述请求参数，以确保能够正确地从聚水潭系统中获取所需的退货单数据。以下是一个示例请求配置：

{
  ...
  {
    ...
    {
      field: 'start_time',
      value: '{{DAYS_AGO_1|date}} 00:00:00'
    },
    {
      field: 'end_time',
      value: '{{CURRENT_TIME|datetime}}'
    },
    ...
  }
}

通过这种方式，我们可以动态地设置查询的起止日期，以确保每次调用都能获取到最新的数据。

数据转换与写入

在成功获取到退货单数据后，需要对数据进行清洗和转换，以便后续写入目标系统。在此过程中，可以利用轻易云平台提供的数据处理工具，对原始数据进行格式化、字段映射以及必要的数据校验。例如：

{
  ...
  {
    field: 'refund_id',
    transform: 'toUpperCase'
  },
  {
    field: 'refund_amount',
    transform: 'toFixed(2)'
  }
}

通过上述配置，可以将退款ID转换为大写，并将退款金额保留两位小数。

实际案例应用

假设我们需要将聚水潭系统中的退货单数据同步到KIS系统中的红字销售出库模块。首先，通过调用jushuitan.refund.list.query接口获取符合条件的退货单列表，然后对返回的数据进行清洗和转换，最后将处理后的数据写入KIS系统。

{
  apiCallConfig:{
    ...
    api:"jushuitan.refund.list.query",
    method:"POST",
    params:{
        page_index:"1",
        page_size:"50",
        start_time:"{{DAYS_AGO_1|date}} 00:00:00",
        end_time:"{{CURRENT_TIME|datetime}}",
        date_type:"0",
        good_status:"SELLER_RECEIVED"
    },
    transform:[
        {field:'refund_id',transform:'toUpperCase'},
        {field:'refund_amount',transform:'toFixed(2)'}
    ]
    ...
   }
}

通过这种方式，我们可以实现不同系统之间的数据无缝对接，并确保每个环节的数据处理过程透明可控。 用友与CRM系统接口开发配置

利用轻易云数据集成平台实现KIS私有云API接口的数据写入

在数据集成过程中，将源平台的数据转换为目标平台所能接受的格式是关键的一步。本文将详细介绍如何使用轻易云数据集成平台，将聚水潭退货单的数据转换并写入到KIS私有云API接口。

1. 配置API接口元数据

首先，我们需要了解目标平台KIS私有云API接口的元数据配置。根据提供的元数据配置，我们可以看到以下关键信息：

  • API路径：/koas/app007104/api/salesdelivery/create
  • 请求方法：POST
  • 数据结构：包含AccountDB、Object（其中包括Head和Entry）等字段。

2. 数据请求与清洗

在进行ETL转换之前，需要确保已经从源平台（聚水潭）获取了正确的数据，并进行了必要的清洗操作。假设我们已经完成了这一步，接下来将重点放在数据转换与写入上。

3. 数据转换与写入

3.1 配置请求头部信息

请求头部信息主要包括单据编号、红蓝字标识、制单人、业务类型、销售方式、摘要等字段。以下是具体配置：

{
    "AccountDB": "001",
    "Object": {
        "Head": {
            "FBillNo": "{order_id}",
            "FROB": "-1",
            "FBillerID": "16439",
            "FMarketingStyle": 12530,
            "FSaleStyle": "101",
            "FExplanation": "_function CONCAT( CASE '{wms_co_id}' WHEN '10736306' THEN '陈梓波' WHEN '13090941' THEN '廉速供应链'  WHEN '14132797' THEN 'JZ中山成品仓' when '14133381' then 'JZ廉江成品仓' when '14165050' then '一厂电商仓' when '14165051' then '二厂电商仓'  ELSE '新仓库' END,'-{shop_name}-{items_date_short}')",
            "FSupplyID": "{customer_id}",
            "Fdate": "_function REPLACE ('{{items_date_short|datetime}}',' ','T')",
            "FDCStockID": "_function CASE '{items_is_need}' WHEN '0' THEN '错的别穿' ELSE '{wms_co_id}-{wh_id}' END",
            "FFManagerID": "16043",
            "FSManagerID": "16043",
            "shop_name": "_function CASE '{shop_id}' WHEN '-1' THEN '未明确客户退货'  ELSE '{shop_name}' END",
            "drp_co_name_from": "{drp_co_name_form}"
        }
    }
}
3.2 配置请求体信息

请求体信息主要包括产品代码、实发数量、销售单价、仓库等字段。以下是具体配置：

{
    "Entry": [
        {
            "FItemID": "_mongoQuery 30fa1b2b-6cfc-31c2-90a3-5a497b7812bd findField=content.FItemID where={\"content.F_103\":{\"$eq\":\"{items_sku_id}\"}}",
            "Fauxqty": "{items_r_qty}",
            "FConsignPrice": "{item_price}",
            "FDCStockID": "{wms_co_id}-{wh_id}",
            "FUnitID": "_mongoQuery 30fa1b2b-6cfc-31c2-90a3-5a497b7812bd findField=content.FProductUnitID where={\"content.F_103\":{\"$eq\":\"{items_sku_id}\"}}"
        }
    ]
}
3.3 数据映射与计算

为了确保数据准确性，需要进行一些数据映射和计算。例如：

  • FExplanation字段通过函数拼接不同仓库名称和日期。
  • FDCStockID字段根据条件选择不同的仓库编码。
  • shop_name字段根据条件选择不同的客户名称。

这些映射和计算可以通过轻易云平台提供的函数和查询功能来实现，例如 _function CONCAT, _mongoQuery, _findCollection find name from ... where ... _endfind.

4. 提交请求

配置完成后，通过POST方法将处理后的JSON数据提交到KIS私有云API接口：

POST /koas/app007104/api/salesdelivery/create HTTP/1.1
Host: kis.example.com
Content-Type: application/json
Authorization: Bearer {token}

{
    // 上述配置好的JSON数据
}

总结

通过以上步骤，我们成功地将聚水潭退货单的数据转换为KIS私有云API接口所能接受的格式，并提交至目标平台。这一过程充分利用了轻易云数据集成平台的元数据配置功能，实现了不同系统间的数据无缝对接。 用友与外部系统接口集成开发

版权声明

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

数据集成平台架构
更多系统对接方案