使用轻易云集成平台高效对接旺店通和金蝶系统

  • 轻易云集成顾问-孙传友

【纯采购业务】旺店通-采购退货单==>金蝶-采购退料单：一次高效的数据集成实践

在企业数据管理的实际应用中，将各类业务系统有效地连通并实现数据的无缝流动是一项技术挑战。本文将详细分享如何通过轻易云平台，实现“旺店通·企业奇门”与“金蝶云星空”的对接，具体方案为【纯采购业务】旺店通-采购退货单同步到金蝶-采购退料单。

为了确保从“旺店通·企业奇门”获取的数据能够精准、可靠地传输至“金蝶云星空”，我们需要解决以下几个关键问题：

  1. 定时可靠的抓取和批量处理：利用wdt.purchase.return.query接口，以定时任务方式抓取采集到所有待处理的退货数据，并进行实时监控和日志记录。
  2. 处理分页和限流问题：由于API调用次数和查询结果存在分页限制，需设计合理的调用策略以确保数据不遗漏且高效读取。
  3. 应对格式差异的数据转换：考虑两端系统间的数据格式可能存在差异，需在数据映射操作中进行必要转换。例如，将购进商品信息字段从JSON格式转化为金蝶所要求的结构化形式。
  4. 高效写入及异常重试机制：使用batchSave API进行批量写入操作，同时设置完善的异常处理流程，当发生错误时自动触发重试机制，以保证整体流程不中断。

首先，通过调用接口wdt.purchase.return.query, 我们可以充分利用其支持多条件过滤查询特性，对需要同步的数据做到准确获取，并结合轻易云提供的一系列工具来完成初步清洗与整理。在编排这段ETL（Extract, Transform, Load）过程中的每步，都可视化界面帮助我们随时验证每个环节运行状态，从而保证最终输出结果符合预期。

紧接着，为了确保向目标系统——即“金蝶云星空”上的顺利导入，我们必须认真设计好对应字段映射规则，以及适配相应表结构。同时，通过合理调度控制，我们能让大量历史及增量数据快速、高效地导入目标数据库，而不会产生性能瓶颈或资源浪费现象。

综上所述，本次集成项目不仅依托于两个强大API能力，还融合了轻易云全生命周期管理优势，使得整个过程达到了高度自动化、透明化以及极致效率。后续内容中我们将进一步细致讲解具体实施步骤及编码示例。 金蝶与MES系统接口开发配置

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

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

接口配置与请求参数

首先，我们需要配置元数据以便正确调用接口。以下是接口的基本配置：

  • API: wdt.purchase.return.query
  • 请求方法: POST
  • 主要标识字段: return_no（退货单编号）和 return_id（退货单ID）

为了实现增量数据获取，我们需要设置以下请求参数：

  1. 开始时间 (start_time): 用于指定增量数据的开始时间，格式为yyyy-MM-dd HH:mm:ss。该值通常取自上次同步时间（{{LAST_SYNC_TIME|datetime}}）。
  2. 结束时间 (end_time): 用于指定增量数据的结束时间，格式为yyyy-MM-dd HH:mm:ss。该值通常为当前时间（{{CURRENT_TIME|datetime}}）。
  3. 状态 (status): 指定要查询的采购退货单状态。在本例中，我们查询已审核状态的退货单（状态码：40）。

此外，为了分页获取数据，我们还需要设置以下参数：

  • 每页返回的数据条数 (page_size): 默认值为40。
  • 页码 (page_no): 默认从第0页开始。

请求示例

根据上述配置，一个典型的请求体可能如下所示：

{
  "start_time": "2023-10-01 00:00:00",
  "end_time": "2023-10-01 23:59:59",
  "status": "40",
  "page_size": "40",
  "page_no": "0"
}

数据清洗与转换

在获取到原始数据后，需要对其进行清洗和转换，以便后续处理和写入目标系统。在轻易云平台上，这一步骤可以通过可视化界面进行操作，确保每个环节都清晰透明。

  1. 字段映射：将源系统中的字段映射到目标系统。例如，将return_no映射到金蝶系统中的采购退料单编号。
  2. 数据格式转换：确保日期、数值等字段符合目标系统要求。例如，将日期格式从yyyy-MM-dd HH:mm:ss转换为目标系统所需的格式。
  3. 过滤无效数据：根据业务规则过滤掉不符合条件的数据。例如，剔除状态不为已审核（40）的记录。

自动填充响应

轻易云平台支持自动填充响应功能，这意味着在成功调用接口并获取数据后，平台会自动解析响应并填充到预定义的数据结构中。这极大简化了开发工作，提高了效率。

实时监控与日志记录

为了确保数据集成过程的可靠性和可追溯性，轻易云平台提供了实时监控和日志记录功能。通过这些功能，可以随时查看每个步骤的执行情况，并在出现问题时快速定位和解决。

总结来说，通过合理配置元数据并利用轻易云平台的强大功能，我们可以高效地调用旺店通·企业奇门接口获取采购退货单数据，并进行必要的清洗和转换，为后续的数据处理打下坚实基础。 金蝶云星空API接口配置

使用轻易云数据集成平台将源数据转换并写入金蝶云星空API接口

在数据集成的过程中，ETL（提取、转换、加载）是一个至关重要的步骤。本文将重点探讨如何使用轻易云数据集成平台，将已经集成的源平台数据转换为金蝶云星空API接口所能够接收的格式，并最终写入目标平台。

数据请求与清洗

在进行ETL转换之前，我们需要确保从源系统（如旺店通）获取的数据已经经过清洗和初步处理。这包括去除无效数据、修正错误信息等。假设这些步骤已经完成，我们直接进入数据转换与写入阶段。

数据转换与写入

我们使用轻易云提供的元数据配置来实现这一过程。以下是关键配置项及其解释：

  1. API调用配置

    • api: "batchSave"
    • method: "POST"
    • effect: "EXECUTE"

  2. 基础字段映射

    • FBILLTYPEID (单据类型): 固定值 "TLD01_SYS"
    • FStockOrgId (退料组织): 固定值 "100"
    • FBillNo (单据编号): 从源数据 {return_no} 提取
    • FDate (退料日期): 从源数据 {check_time} 提取
    • FSupplierID (供应商): 从源数据 {provider_no} 提取
    • FMRTYPE (退料类型): 固定值 "库存退料"
    • FMRDeptId (退料部门): 可选配置
    • FDESCRIPTION (备注): 从源数据 {remark} 提取
    • FSettleOrgId (结算组织): 固定值 "100"
    • FSettleCurrId (结算币别): 固定值 "PRE001"
    • FPayOrgId (付款组织): 固定值 "100"
    • FOwnerTypeIdHead (货主类型): 固定值 "BD_OwnerOrg"
    • FOwnerIdHead (货主): 固定值 "100"

  3. 明细信息映射 明细信息是整个配置中最复杂的一部分，需要逐条处理。

    {
  "FPURMRBENTRY": [
    {
      "FMATERIALID": "{{detail_list.spec_no}}",
      "FRMREALQTY": "{{detail_list.num}}",
      "FSTOCKID": "{warehouse_no}",
      "FNOTE": "{{detail_list.remark}}",
      "FPrice": "{{detail_list.price}}",
      "FGiveAway": "",
      "FOWNERTYPEID": "BD_OwnerOrg",
      "FOWNERID": "100",
      "FENTRYTAXRATE": "",
      "FTAXPRICE": "",
      "FPURMRBENTRY_Link": [
        {
          "FPURMRBENTRY_Link_FRuleId": "PUR_PurchaseOrder-PUR_MRB",
          "FPURMRBENTRY_Link_FSTableName": "t_PUR_POOrderEntry",
          "FPURMRBENTRY_Link_FSBillId": "_findCollection find FID from 417f6d4a-ca92-3035-a0a8-41486c6e9cdf where FBillNo={purchase_no}",
          "FPURMRBENTRY_Link_FSId": "_findCollection find FPOOrderEntry_FEntryId from 417f6d4a-ca92-3035-a0a8-41486c6e9cdf where FBillNo={purchase_no} and FMaterialId_FNumber={{details_list.spec_no}}"
        }
      ]
    }
  ]
}

  4. 其他请求参数

    • FormId: 金蝶表单ID，固定值为"PUR_MRB"
    • Operation: 执行操作，固定值为"batchSave"
    • IsAutoSubmitAndAudit: 是否自动提交和审核，布尔值"false"
    • IsVerifyBaseDataField: 是否验证基础资料有效性，布尔值"true"
    • SubSystemId: 系统模块，固定值为"21"

具体实现步骤

  1. 解析器设置

    配置中的解析器（如ConvertObjectParser）用于将原始字段转换为目标系统所需的格式。例如，将供应商编码从源系统格式转换为金蝶格式。

  2. 字段映射

    将每个字段从源系统映射到目标系统。通过元数据配置中的value属性，可以直接引用源系统的数据字段。

  3. 明细信息处理

    明细信息通常包含多个子项，需要逐条处理并映射到目标系统相应的字段。

  4. API调用

    最后，通过HTTP POST请求将处理后的数据发送到金蝶云星空API接口，实现批量保存操作。

{
  ...
  // 请求体示例
  {
    ...
    // 基础字段
    ...
    // 明细信息
    ...
  }
}

通过以上步骤，我们可以高效地将清洗后的源平台数据转换并写入金蝶云星空，实现不同系统间的数据无缝对接。 金蝶与CRM系统接口开发配置

版权声明

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

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