ETL转换实践：使用轻易云数据集成平台写入金蝶云星空API

  • 轻易云集成顾问-李国敏

SD001-生产订单审批泛微=>金蝶采购订单--488：数据集成技术解析

在企业内部系统间进行高效的数据对接和集成，是提升业务自动化水平的重要手段。本文将聚焦于SD001方案，通过轻易云数据集成平台，展示如何将泛微OA的生产订单审批数据无缝对接到金蝶云星空的采购订单中。

1. 泛微OA-Http API 数据获取

首先，在这一案例中，我们使用泛微OA提供的API接口/api/workflow/paService/getWorkflowRequest来抓取生产订单审批的数据。由于该API支持分页查询，因此我们需要考虑分页处理及其限流问题，以确保大量数据能够稳定、高效地被拉取。

为了确保这些关键业务数据不漏单，我们设计了定时任务来周期性调用此接口，同时结合异常处理和错误重试机制，最大程度保证了数据抓取的准确性与完整性。此外，通过实时监控日志记录，每一次请求详情均被详细记录，便于后续追踪与问题排查。

2. 数据转换逻辑及质量监控

从泛微OA获取到原始数据信息后，需要根据业务需求定义自定义的数据转换逻辑。这一步骤主要解决两者之间的数据格式差异，使得最终能够适配金蝶云星空所要求的数据结构。在这个过程中，利用轻易云提供的数据质量监控功能，对每一批次转化后的数据进行核验，并及时发现并处理潜在的质量问题，如重复、遗漏或异常值等。

3. 金蝶云星空快速写入

完成上述工作之后，我们将处理好的批量数据通过金蝶云星空的batchSave API实现快速写入。这一过程须特别关注大吞吐量下的性能表现，以及集成过程中出现异常情况时的应急响应措施。当发生网络抖动或其他不可预见的问题时，高效可靠的错误重试机制也是必不可少的一环，以确保整体流程平稳运行且一致性得以维护。同时，为了进一步优化资源配置，可借助集中式监控平台来跟踪所有活跃任务，并针对性能瓶颈做出相应调整。

常见的一些挑战还包括：如何识别并正确映射两个系统各自特有字段？如何有效管理与调度执行顺序？面对这些具体细节所引发的问题，本例中的实施方案都给出了合理可行的方法论。一切优化努力旨在达成一个目标——让整个跨系统、跨部门流程更紧密、更智能，同时减少人工干预，提高整体运作效率和准确度。 如何对接用友BIP接口

调用泛微OA-Http接口获取并加工数据

在数据集成的生命周期中，调用源系统API是至关重要的一步。本文将详细探讨如何通过轻易云数据集成平台调用泛微OA-Http接口/api/workflow/paService/getWorkflowRequest来获取和加工数据。

接口配置与调用

首先，我们需要配置元数据以便正确调用API。以下是元数据配置的关键部分：

{
  "api": "/api/workflow/paService/getWorkflowRequest",
  "effect": "QUERY",
  "method": "GET",
  "number": "requestId",
  "id": "requestId",
  "name": "id",
  "idCheck": true,
  "request": [
    {"field": "workflowId", "label": "e9流程id", "type": "string", "value": "488"},
    {"field": "workflowIdList", "label": "workflowIdList中间方案ID", "type": "string", "value": "8183a586-bdfb-3e93-8573-d5e81803c5ff"}
  ],
  "autoFillResponse": true,
  "condition_bk": [
    [{"field": "currentNodeName", "logic": "like", "value":"归档"}, {"field":"detail_0.xm","logic":"like","value":"1.wafer"}]
  ],
  "condition":[
    [{"field":"detail_0.xm","logic":"like","value":"wafer"}]
  ]
}

数据请求与清洗

在这个阶段，我们使用GET方法请求泛微OA系统的工作流数据。请求参数包括workflowId和workflowIdList，这两个字段分别指定了流程ID和中间方案ID。

GET /api/workflow/paService/getWorkflowRequest?workflowId=488&workflowIdList=8183a586-bdfb-3e93-8573-d5e81803c5ff

为了确保返回的数据符合预期，我们设置了自动填充响应（autoFillResponse: true），这意味着平台会自动处理并解析API返回的数据。

数据过滤与条件设置

为了进一步精炼数据，我们设置了两组条件：

  1. 备用条件（condition_bk）：用于在主要条件不满足时进行过滤。

    • currentNodeName包含"归档"
    • detail_0.xm包含"1.wafer"

  2. 主要条件（condition）：用于初步筛选数据。

    • detail_0.xm包含"wafer"

这些条件确保我们只获取到符合特定业务逻辑的数据，从而提高了数据的准确性和相关性。

数据转换与写入

虽然本文重点不在于数据转换与写入，但值得一提的是，轻易云平台提供了强大的转换功能，可以将获取的数据转换为目标系统所需的格式，并写入金蝶采购订单系统。这一步通常涉及复杂的映射和业务逻辑处理，但在轻易云平台上，这些操作都可以通过可视化界面轻松完成。

实践案例

假设我们需要从泛微OA系统中获取生产订单审批相关的数据，并将其导入到金蝶采购订单系统。以下是具体步骤：

  1. 配置元数据：如上所述，配置API路径、请求参数和过滤条件。
  2. 调用API：通过GET请求获取工作流数据。
  3. 清洗与过滤：根据设定的条件筛选出有效数据。
  4. 转换与写入：将筛选后的数据转换为金蝶系统所需格式，并写入目标数据库。

通过这种方式，我们能够高效地实现不同系统间的数据无缝对接，确保业务流程的顺畅运行。

总结来说，通过轻易云平台调用泛微OA-Http接口获取并加工数据，是一个高度自动化且灵活的过程。借助其强大的元数据配置能力，我们可以轻松实现复杂的数据集成需求，为企业提供可靠的数据支持。 金蝶与WMS系统接口开发配置

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

在数据集成的生命周期中，ETL（提取、转换、加载）是关键步骤之一。本文将详细探讨如何使用轻易云数据集成平台将源平台的数据转换为金蝶云星空API接口所能接收的格式，并最终写入目标平台。

配置元数据

首先，我们需要配置元数据以确保数据能够正确地映射到金蝶云星空API接口。以下是一个典型的元数据配置示例：

{
  "api": "batchSave",
  "effect": "EXECUTE",
  "method": "POST",
  "idCheck": true,
  "request": [
    {
      "field": "FBillTypeID",
      "label": "单据类型",
      "type": "string",
      "describe": "单据类型\n标准采购订单:CGDD01 SYS\n标准委外订单:CGDD02 SYS\n直运采购订单:CGDD03 SYS\n资产采购订单:CGDD04 SYS\n费用采购订单:CGDD05 SYS\n补料采购订单:CGDD06 SYS\nVMI采购订单:CGDD07 SYS\n现购订单:CGDD08 SYS\n分销购销采购订单:CGDD09 SYS",
      "parser": {
        "name": "ConvertObjectParser",
        "params": "FNumber"
      },
      "value": "CGDD01_SYS"
    },
    {
      "field": "FBillNo",
      "label": "单据编号",
      "type": "string",
      "describe": "单据编号",
      "value": "{{workflowMainTableInfo.lcbh}}"
    },
    {
      ...
    }
  ],
  ...
}

数据请求与清洗

在进行ETL转换之前，首先需要从源平台获取原始数据，并对其进行必要的清洗和预处理。这一步骤确保了数据的准确性和一致性。

数据转换

接下来是关键的转换步骤。通过配置元数据中的字段映射和解析器，可以将源平台的数据格式转换为金蝶云星空API接口所需的格式。

例如，FBillTypeID字段需要从源平台的数据中提取并转换为金蝶系统识别的编码：

{
  "field": "FBillTypeID",
  "label": "单据类型",
  ...
  "parser": {
    "name": "ConvertObjectParser",
    ...
  },
  ...
}

类似地，对于复杂的数据结构，如数组和对象，可以通过嵌套配置实现。例如，FPOOrderEntry字段表示明细信息，其子字段包括物料编码、采购数量等：

{
  ...
  {
    "field": "FPOOrderEntry",
    ...
    {
      ...
      {
        ...
        {
          ...
          {
            ...
            {
              ...
              {
                ...
                {
                  ...
                  {
                    ...
                    {
                      ...
                      {
                        ...
                        {
                          ...
                          {
                            ...
                            {
                              ...
                              {
                                ...
                                {
                                  ...
                                  }
                                }
                              }
                            }
                          }
                        }
                      }
                    }
                  }
                }
              }
            }
          }
        }
      }
    }
}

数据写入

最后，将转换后的数据通过API接口写入金蝶云星空系统。根据元数据配置，使用POST方法调用batchSave API，并传递所有必要的参数和字段。

{
  ...,
  {"method":"POST","idCheck":true,"request":[{"field":"FBillTypeID","label":"单据类型","type":"string","describe":"单据类型...","parser":{"name":"ConvertObjectParser","params":"FNumber"},"value":"CGDD01_SYS"},{"field":"FBillNo","label":"单据编号","type":"string","describe":"单据编号","value":"{{workflowMainTableInfo.lcbh}}"},{"field":"FDate","label":"采购日期","type":"string","describe":"采购日期","value":"{{workflowMainTableInfo.sqrq}}"},{"field":"FPurchaseOrgId","label":"采购组织","type":"string","describe":"采购组织..."}]}
}

通过以上步骤，可以实现从源平台到目标平台的数据无缝对接，确保业务流程顺畅运行。 如何对接钉钉API接口

版权声明

该文章《从泛微OA到金蝶云：生产订单审批数据的跨系统对接》为原创内容，版权归 广东轻亿云软件科技有限公司 所有。 未经本公司书面授权，严禁转载、引用、复制或建立镜像等行为。 若需转载或引用本文内容，请联系本公司获取授权，并在显著位置注明作者姓名、文章出处（包括原文链接）等信息。

金蝶云星辰与吉客云对接
更多系统对接方案