将易快报订单写入金蝶云星空的ETL过程

  • 轻易云集成顾问-钟家寿

易快报采购订单对接金蝶应付单(月结)技术案例分享

在企业信息化过程中，常常需要集成不同系统的数据，以确保业务流程的顺畅运作。本篇将详细介绍一个具体的技术解决方案——如何将易快报中的采购订单数据高效、可靠地集成到金蝶云星空应付单。

首先，从获取易快报接口数据开始。通过调用 /api/openapi/v1.1/docs/getApplyList 接口，我们可以定时抓取最新的采购订单数据。为了避免漏单和处理分页及限流问题，需要实现一套合适的调度机制。另外，可以通过实时监控与日志记录，确保每次数据抓取操作透明可见。

对于大量的数据批量写入金蝶云星空，应充分考虑其API接受能力以及数据格式差异的问题。在这个案例中，通过调用 batchSave API，一次性高效写入批量应付单，并保证了大规模数据传输的稳定性。同时，在进行这一步骤时，我们使用了一些字段映射规则，以便在两种系统之间实现准确无误的数据转换。

期间可能会遇到如网络波动等异常情况，为此设置了完善的错误重试机制。此外，为提高整体处理效率，将所有步骤自动化并整合至一个流畅工作流之中，使得整个集成过程快速且稳健运行。

本文开头提及的重要步骤和特性能够为理解后续复杂细节提供良好的基础，这是实施成功集成项目不可或缺的一部分。接下来，将逐步探讨各个环节具体实施的方法与技巧，包括接口调用方式、调度策略、日志管理等方面内容。 系统集成平台API接口配置

调用易快报接口获取并加工数据的技术案例

在数据集成过程中，调用源系统的API接口是至关重要的一步。本文将详细探讨如何通过轻易云数据集成平台调用易快报的/api/openapi/v1.1/docs/getApplyList接口获取采购订单数据，并进行初步的数据加工。

接口调用配置

首先，我们需要配置元数据，以便正确调用易快报的API接口。以下是元数据配置的详细说明：

{
  "api": "/api/openapi/v1.1/docs/getApplyList",
  "effect": "QUERY",
  "method": "GET",
  "number": "form.code",
  "id": "id",
  "idCheck": true,
  "otherRequest": [
    {
      "field": "type",
      "label": "type",
      "type": "string",
      "describe": "expense : 报销单\nloan : 借款单\nrepayment : 还款记录\npayment : 付款单\nrequisition : 申请单\ncustom : 通用审批单\nreceipt : 收款单",
      "value": "expense"
    },
    {
      "field": "start",
      "label": "分页查询起始值",
      "type": "string"
    },
    {
      "field": "count",
      "label": "count",
      "type": "string",
      "describe": "最大不能超过 100",
      "value": "100"
    },
    {
      "field": "orderBy",
      ...

配置参数详解

  • API路径：/api/openapi/v1.1/docs/getApplyList
  • 请求方法：GET
  • 主要字段：
    • type: 数据类型，这里我们选择 expense 表示报销单。
    • start: 分页查询起始值。
    • count: 每次请求返回的数据条数，最大不能超过100。
    • orderBy: 排序字段，这里选择 updateTime 表示按更新时间排序。
    • startDate 和 endDate: 查询时间范围，分别表示起始时间和结束时间。
    • specificationId: 单据模板ID，不带小版本号。
    • active: 是否已删除，设置为 true 表示未删除的数据。
    • state: 单据状态，这里选择多个状态如 paying,PROCESSING,paid,archived。

数据请求与清洗

在完成元数据配置后，我们可以发起API请求并获取数据。以下是一个简化的Python代码示例，用于演示如何使用上述配置进行API调用：

import requests
import datetime

# 设置请求参数
params = {
    'type': 'expense',
    'start': '0',
    'count': '100',
    'orderBy': 'updateTime',
    'startDate': (datetime.datetime.now() - datetime.timedelta(days=30)).strftime('%Y-%m-%d %H:%M:%S'),
    'endDate': datetime.datetime.now().strftime('%Y-%m-%d %H:%M:%S'),
    'specificationId': 'ID01oOrFbyCyGb',
    'active': 'true',
    'state': 'paying,PROCESSING,paid,archived'
}

# 发起GET请求
response = requests.get('https://example.com/api/openapi/v1.1/docs/getApplyList', params=params)

# 检查响应状态码
if response.status_code == 200:
    data = response.json()
else:
    print(f"Error: {response.status_code}")

# 数据清洗
cleaned_data = []
for item in data['data']:
    if item['details']['_amount_standard'] > 0:
        cleaned_data.append(item)

print(cleaned_data)

数据转换与写入

在获取并清洗数据后，下一步是将这些数据转换为目标系统所需的格式，并写入目标系统。由于本文重点在于第一步，因此不详细展开此部分。

通过上述步骤，我们成功地调用了易快报的API接口，获取了所需的数据，并进行了初步的数据清洗。这一过程展示了轻易云数据集成平台在处理异构系统间数据对接时的高效性和灵活性。 打通钉钉数据接口

数据集成：将易快报采购订单转换并写入金蝶云星空

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

API接口配置与调用

首先，我们需要理解目标平台——金蝶云星空的API接口配置。根据提供的元数据配置，我们使用batchSave API，通过POST方法进行数据写入。以下是主要配置参数：

  • api: "batchSave"
  • method: "POST"
  • pagination: {"pageSize":100}
  • operation: {"rowsKey":"array","rows":1,"method":"batchArraySave"}
  • idCheck: true

这些参数确保了我们能够批量处理数据，并且在每次请求中最多处理100条记录。

数据字段映射与转换

为了使源平台的数据能够被目标平台正确识别和处理，我们需要对数据字段进行映射和转换。以下是主要字段的配置和解析方式：

  1. 单据类型 (FBillTypeID)

    • 类型: string
    • 解析器: ConvertObjectParser, 参数: FNumber
    • 固定值: "YFD02_SYS"

  2. 结算组织 (FSETTLEORGID)

    • 类型: string
    • 解析器: ConvertObjectParser, 参数: FNumber
    • 固定值: "102"

  3. 单据编号 (FBillNo)

    • 类型: string
    • 动态值: {code}

  4. 业务类型 (FBUSINESSTYPE)

    • 类型: string
    • 固定值: "FY"

  5. 业务日期 (FDATE)

    • 类型: string
    • 动态值: {{expenseDate|datetime}}

  6. 供应商 (FSUPPLIERID)

    • 类型: string
    • 解析器: ConvertObjectParser, 参数: FNumber
    • 动态值: {{u_供应商编码}}

  7. 币别 (FCURRENCYID)

    • 类型: string
    • 解析器: ConvertObjectParser, 参数: FNumber
    • 动态值与映射关系: 
      {
"target": "64ca4880a6fc7b0a9b6cc8b2",
"direction": "positive"
}

  8. 付款条件说明 (FAP_Remark)

    • 类型: string
    • 动态值: {{u_付款条件说明}}

明细字段处理

对于明细部分，我们需要特别注意数组类型的数据处理。例如，FEntityDetail字段包含多个子字段，每个子字段都有其特定的解析和映射规则：

  1. 费用项目 (FCOSTID)

    • 类型: string
    • 解析器: ConvertObjectParser, 参数: FNumber
    • 固定值: "FYXM14_SYS"

  2. 含税单价 (FTaxPrice)

    • 类型: string
    • 动态计算: 
      case when '{FCURRENCYID}'='CNY' then '{{details._amount_standard}}'/'{{details.quantity}}' else '{{details._amount_foreign}}'/'{{details.quantity}}' end

  3. 计价数量 (FPriceQty)

    • 类型: string
    • 动态值: {{details.quantity}}

  4. 费用承担部门 (FCOSTDEPARTMENTID)

    • 类型: string
    • 动态查询: 
      {
"query": "_mongoQuery",
"params": {
 "collectionId": "12ec22fb-d3b3-3be1-b41e-447a338ffb92",
 "findField": "content.code",
 "where": "{\"id\":{\"$eq\":\"{{details.u_申请部门}}\"}}"
}
}

  5. 备注 (FComment)

    • 类型: string
    • 动态值: {{details.u_产品名称}}

提交与审核

最后，我们需要设置一些额外的请求参数，以确保数据提交后的自动化处理：

  • 表单Id (FormId): 固定值 "AP_Payable"
  • 执行操作 (Operation): 固定值 "BatchSave"
  • 提交并审核 (IsAutoSubmitAndAudit): 布尔类型，固定值 false
  • 验证基础资料有效性 (IsVerifyBaseDataField): 布尔类型，固定值 true

通过以上配置和详细的字段映射，我们可以确保易快报采购订单的数据能够准确无误地转换并写入金蝶云星空系统，实现跨平台的数据集成。 系统集成平台API接口配置

版权声明

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

旺店通金蝶对接业财一体化数据集成方案包全业务流程图下载
更多系统对接方案