使用轻易云平台进行数据转化并写入畅捷通T+接口的实例

  • 轻易云集成顾问-曹润

聚水潭·奇门数据集成到畅捷通T+：技术案例分享

在现代企业的系统对接需求中，保障不同平台之间的数据无缝流动和高效处理是核心问题。本文将聚焦于一个具体的应用场景——如何将聚水潭售后单数据通过API接口集成到畅捷通T+其他入库单，并且合并写入以提升操作效率。

首先，我们需要从聚水潭·奇门获取售后单数据，这里使用了jushuitan.refund.list.query API接口来抓取待处理数据。这一步骤中的关键挑战包括处理分页和限流问题，以确保大规模数据的可靠、快速抓取。在实际操作中，通过轻易云平台提供的定时任务功能，我们实现了对该接口的定期调用，保证任何时间段都能准确获取最新的数据，而不会漏单。

接下来就是解析和转换从聚水潭获得的数据，使其符合畅捷通T+所需的数据格式。简要地说，这是为了应对两者间可能存在的数据结构差异。在这一过程中，还涉及到一些字段映射及转换逻辑，需要确保每一个字段在最终写入前都被正确解析。

然后，将这些经过清洗和转换后的数据批量写入到畅捷通T+。这里我们用到了/tplus/api/v2/otherReceive/Create API，该API允许批量创建其他入库记录，从而极大提高了数据写入效率。此外，在整个传输过程中，设置了一整套异常处理与错误重试机制，以防止因网络或系统故障导致的数据丢失或重复提交现象。

最后，为了更好地监控整个集成过程以及排查潜在的问题，我们启用了实时监控与日志记录功能。例如，当某条记录未成功写入时，可以即时生成报警并自动尝试重新发送，这样确保整个过程透明、可追溯，不会因为偶发错误影响整体系统运行。同时，也为日常维护提供有力支持。 泛微OA与ERP系统接口开发配置

调用聚水潭·奇门接口jushuitan.refund.list.query获取并加工数据

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

接口调用配置

首先，我们需要配置接口调用的元数据。以下是jushuitan.refund.list.query接口的详细配置：

{
  "api": "jushuitan.refund.list.query",
  "effect": "QUERY",
  "method": "POST",
  "number": "as_id",
  "id": "as_id",
  "name": "as_id",
  "idCheck": true,
  "formatResponse": [
    {"format": "string", "old": "as_id", "new": "as_id_new"},
    {"format": "string", "old": "type", "new": "type_new"},
    {"format": "date", "old": "confirm_date", "new": "confirm_date_new"}
  ],
  ...
}

该配置文件定义了接口的基本信息，包括API名称、请求方法、主键字段等。同时，还定义了返回数据的格式化规则，将原始字段名转换为新的字段名，并指定了字段类型。

请求参数设置

请求参数是接口调用的重要组成部分。以下是该接口的请求参数配置：

{
  ...
  "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":"{{LAST_SYNC_TIME|datetime}}"},
    {"field":"end_time","label":"修改结束时间","type":"string","describe":"结束时间，和起始时间必须同时存在，时间间隔不能超过七天，与线上单号不能同时为空","value":"{{CURRENT_TIME|datetime}}"},
    {"field":"date_type","label":"时间类型","type":"int","describe":"修改时间:0 ; 创建时间:1; 确认时间: 2;非必填,默认0","value":"2"},
    {"field":"type","label":"售后类型","type":"string","describe":"普通退货，其它，拒收退货，仅退款，投诉，补发，换货，维修"},
    {"field":"status","label":"售后单状态","type":"string","describe":"（WaitConfirm:待确认,Confirmed:已确认,Cancelled:作废,Merged:被合并）"},
    {"field":"good_status","label":"货物状态","type":"string","describe":"（BUYER_NOT_RECEIVED:买家未收到货,BUYER_RECEIVED:买家已收到货,BUYER_RETURNED_GOODS:买家已退货,SELLER_RECEIVED:卖家已收到退货）", 
"value": 
"SELLER_RECEIVED"}
  ],
  ...
}

这些参数包括分页信息、时间范围、售后类型、状态等。特别注意的是start_time和end_time字段，它们使用了动态变量来获取上次同步时间和当前时间，以确保数据的实时性。

数据过滤条件

为了确保只获取到我们需要的数据，可以设置过滤条件：

{
  ...
  "condition":[
    [{"field": 
"items.type",
"logic":
"in",
"value":
"退货,换货"
},
{"field":
"items.r_qty",
"logic":
"gt",
"value":
"0"
},
{"field":
"status",
"logic":
"in",
"value":
"Confirmed,WaitConfirm"
}]
],
...
}

这些条件确保只获取到符合特定条件的售后单，例如类型为“退货”或“换货”，数量大于0，并且状态为“已确认”或“待确认”的记录。

数据格式化与加工

在获取到数据后，需要对其进行格式化和加工处理。根据元数据配置中的formatResponse部分，我们可以将原始字段名转换为新的字段名，并调整字段类型。例如：

{
  ...
  "formatResponse":[
    {"format":
"string",
"old":
"as_id",
"new":
"as_id_new"
},
{"format":
"string",
"old":
"type",
"new":
"type_new"
},
{"format":
"date",
"old":
"confirm_date",
"new":
"confirm_date_new"
}
],
...
}

这种格式化处理可以简化后续的数据处理步骤，使得数据更加规范和易于使用。

自动填充响应

最后，我们可以启用自动填充响应功能，以便在处理过程中自动补全某些字段：

{
  ...
  "autoFillResponse": true,
  ...
}

这有助于减少手动干预，提高数据处理效率。

通过以上步骤，我们成功地调用了聚水潭·奇门接口jushuitan.refund.list.query并对返回的数据进行了有效的加工处理。这一过程展示了如何利用轻易云数据集成平台实现高效的数据集成和管理。 数据集成平台可视化配置API接口

使用轻易云数据集成平台将源数据转换并写入畅捷通T+API接口的技术案例

在数据集成过程中，ETL（Extract, Transform, Load）是关键步骤之一。本文将详细探讨如何使用轻易云数据集成平台，将聚水潭售后单的数据转换为畅捷通T+其他入库单所需的格式，并通过API接口写入目标平台。

配置元数据

首先，我们需要配置元数据，以便将源数据正确映射到目标系统的字段。以下是元数据配置示例：

{
  "api": "/tplus/api/v2/otherReceive/Create",
  "effect": "EXECUTE",
  "method": "POST",
  "idCheck": true,
  "operation": {
    "method": "merge",
    "field": "confirm_date_new",
    "bodyName": "list",
    "bodySum": ["items_r_qty"],
    "header": ["as_id", "confirm_date_new", "wh_id", "remark"],
    "body": ["items_sku_id", "items_r_qty", "items_price"]
  },
  "request": [
    {"field":"ExternalCode","label":"外部单据号","type":"string","describe":"外部单据号,后台做唯一性检查。用于防止重复提交，和外系统数据对应。","value":"{as_id}+{wh_id}"},
    {"field":"VoucherType","label":"单据类型","type":"string","describe":"单据类型。默认值{Code:\"ST1024\"}","value":"ST1004","parser":{"name":"ConvertObjectParser","params":"Code"}},
    {"field":"VoucherDate","label":"单据日期","type":"string","describe":"111","value":"{confirm_date_new}"},
    {"field":"BusiType","label":"业务类型","type":"string","describe":"业务类型编码。取值范围： 13--其他  14--其他退库","value":"66","parser":{"name":"ConvertObjectParser","params":"Code"}},
    {"field":"Warehouse","label":"仓库信息","type":"string","describe":"111","value":"{wh_id}","parser":{"name":"ConvertObjectParser","params":"Code"}},
    {"field":"Memo","label":"表头备注","type":"string","describe":"111","value":"{remark}"},
    {"field":"RDRecordDetails","label":"单据明细信息","type":"array","describe":"111","value":"list",
      "children":[
        {"field":"Inventory","label":"存货信息","type":"string","value":"{{list.items_sku_id}}", 
          "parser":{"name": "ConvertObjectParser", 
          "params": { 
            // 参数配置
          }}},
        {"field": "BaseQuantity", 
          "label": "主计量单位数量", 
          "type": "string", 
          "value": "{{list.items_r_qty}}"},
        {"field": 
          // 成本金额计算
          // 使用_function函数进行计算
          // 将数量和价格相乘得到金额
          // 示例：_function ({{list.items_r_qty}}*{{list.items_price}})
        },
        {"field":
          // 成本单价
          // 直接映射价格字段
        }
      ]
    }
  ],
  // otherRequest部分省略
}

数据请求与清洗

在ETL过程的第一步，我们需要从源系统（如聚水潭）获取原始数据，并对其进行必要的清洗和预处理。这一步骤包括去除无效数据、修正错误记录以及标准化字段格式等。

{
  // 示例请求体，获取聚水潭售后单数据
}

数据转换与写入

接下来，我们将已清洗的数据进行转换，使其符合畅捷通T+API接口所需的格式。这一步骤主要涉及字段映射和数据计算。

  1. 字段映射：

    • 将as_id和wh_id组合生成ExternalCode。
    • 将confirm_date_new映射为VoucherDate。
    • 将wh_id映射为Warehouse。
    • 将备注字段映射为Memo。

  2. 数组处理：

    • 对于明细信息（如商品SKU、数量、价格等），需要将其转换为符合目标系统要求的数组结构。
    • 使用函数计算成本金额：例如，将数量乘以单价得到总金额。

  3. API调用：

    • 配置好所有字段后，通过HTTP POST方法调用畅捷通T+API接口，将转换后的数据发送到目标系统。
{
  // 示例请求体，发送到畅捷通T+API接口的数据结构
}

实际应用案例

假设我们有以下源数据：

{
  // 示例源数据结构
}

经过上述步骤处理后，生成的目标数据如下：

{
  // 示例目标数据结构，符合畅捷通T+API接口要求
}

通过轻易云平台，我们能够高效地完成从源系统到目标系统的数据集成任务，实现不同系统间的数据无缝对接，提高业务透明度和效率。在实际应用中，根据具体业务需求，可以灵活调整元数据配置和处理逻辑，以满足各种复杂场景下的数据集成需求。 打通企业微信数据接口

版权声明

该文章《使用轻易云平台进行数据转化并写入畅捷通T+接口的实例》为原创内容，版权归 广东轻亿云软件科技有限公司 所有。 未经本公司书面授权，严禁转载、引用、复制或建立镜像等行为。 若需转载或引用本文内容，请联系本公司获取授权，并在显著位置注明作者姓名、文章出处（包括原文链接）等信息。

轻易云企业AIGC应用
更多系统对接方案