轻松掌握金蝶云星空与美国人资产系统的ETL数据转换

  • 轻易云集成顾问-陈洁琳

金蝶云星空数据集成到美国人资产系统：折旧调整单对接案例分享

为了提升企业财务数据处理的效率和可靠性，我们实施了一项关键性的系统对接任务：将金蝶云星空中的折旧调整单精确、安全地集成到美国人资产系统。本文聚焦于如何通过高效的数据集成方案，确保两大平台之间的数据流畅、无缝地传递，并提供相关技术规范。

为实现这一目标，我们利用了轻易云数据集成平台的强大功能，其中包括调用金蝶云星空接口ExecuteBillQuery抓取最新的折旧调整单数据，以及使用美国人资产系统API /assetCard/AssetFepreciationFromKingdee?fepreciationList=快速写入整理后的信息。

在整个过程中，我们面临多个技术挑战：

  1. 确保金蝶云星空数据不漏单： 通过实时监控与日志记录机制，每次调用接口时均严格检查返回结果，捕捉所有可能遗漏的数据。
  2. 分页和限流问题： 针对ExecuteBillQuery API，在请求大量数据时合理处理分页，并采用限流策略以避免过多请求导致的服务器负载问题。
  3. 解决不同平台间的数据格式差异： 在写入美国人资产系統前，对获取到的数据进行必要的格式转换与映射，以符合目的系统的格式要求。
  4. 异常处理与错误重试机制： 在对接过程中，如果发生网络异常或其他错误，通过内置重试机制保证流程不中断，提高整体操作可靠性。

此外，为了进一步提高效率，定制化批量处理机制被引入，使得大量折旧调整单能够一次性顺利迁移到目的库中。同时，通过设立定时任务，实现从金蝶云星空接口周期性、稳定的数据抓取，从而保持资产管理更新同步，这对于我们的自动化运营至关重要。

在实际操作中，这个案例不仅成功验证了我们方案设计思想，还显著降低了人工干预所需时间，大幅度提升业务部门响应速度。下面，将详细阐述每一步具体实施流程及相关代码示例，让您更直观了解整个过程。 打通钉钉数据接口

调用金蝶云星空接口ExecuteBillQuery获取并加工数据

在数据集成的生命周期中，调用源系统接口是关键的第一步。本文将深入探讨如何通过轻易云数据集成平台调用金蝶云星空的ExecuteBillQuery接口，以获取并加工折旧调整单的数据。

接口配置与调用

首先，我们需要了解ExecuteBillQuery接口的基本配置。根据提供的元数据配置，以下是该接口的详细参数：

  • API名称: ExecuteBillQuery
  • 请求方法: POST
  • 主要字段:
    • Limit: 查询分页参数，默认值为1000。
    • StartRow: 查询分页参数，用于指定查询起始行。
    • TopRowCount: 查询分页参数，用于限制返回记录数。
    • FilterString: 过滤条件，例如FSupplierId.FNumber = 'VEN00010' and FApproveDate>=。
    • FieldKeys: 返回字段列表，例如FPOOrderEntry_FEntryId, FPurchaseOrgId.FNumber。
    • FormId: 表单ID，例如FA_ADJUST。

请求示例

为了获取折旧调整单的数据，我们需要构建一个符合上述配置的请求体。以下是一个示例请求体：

{
  "Limit": "1000",
  "StartRow": "0",
  "TopRowCount": 1000,
  "FilterString": "FApproveDate>='{{LAST_SYNC_TIME|dateTime}}'",
  "FieldKeys": ["FBillNo", "FId", "FAdjustAmount"],
  "FormId": "FA_ADJUST"
}

在这个请求体中：

  • Limit和TopRowCount都设置为1000，确保每次查询最多返回1000条记录。
  • StartRow设置为0，表示从第一条记录开始查询。
  • FilterString使用动态变量{{LAST_SYNC_TIME|dateTime}}来过滤最近同步时间之后的数据。
  • FieldKeys指定了需要返回的字段，包括单据编号（FBillNo）、主键ID（FId）和调整金额（FAdjustAmount）。
  • FormId设置为折旧调整单的表单ID，即FA_ADJUST。

数据清洗与转换

在获取到原始数据后，需要对数据进行清洗和转换，以便后续处理和写入目标系统。以下是一些常见的数据清洗和转换操作：

  1. 数据格式化: 将日期、金额等字段格式化为标准格式。例如，将日期字段统一格式化为ISO8601标准。
  2. 字段映射: 将源系统中的字段名映射到目标系统中的字段名。例如，将金蝶中的FBillNo映射到资产系统中的DocumentNumber。
  3. 数据过滤: 根据业务需求过滤掉不必要的数据。例如，只保留已审核通过的折旧调整单。

以下是一个简单的数据清洗示例代码：

def clean_data(raw_data):
    cleaned_data = []
    for record in raw_data:
        cleaned_record = {
            "DocumentNumber": record["FBillNo"],
            "AdjustmentID": record["FId"],
            "AdjustmentAmount": float(record["FAdjustAmount"]),
            "ApprovalDate": format_date(record["FApproveDate"])
        }
        cleaned_data.append(cleaned_record)
    return cleaned_data

def format_date(date_str):
    # 假设输入日期格式为 'YYYY-MM-DD'
    return date_str + 'T00:00:00Z'

数据写入目标系统

在完成数据清洗和转换后，下一步就是将处理后的数据写入目标系统。这通常涉及调用目标系统的API接口，并确保数据格式和结构符合目标系统的要求。

例如，如果目标系统支持批量写入，可以构建一个批量写入请求体，将所有清洗后的记录一次性写入：

{
  "records": [
    {
      "DocumentNumber": "ADJ20230001",
      "AdjustmentID": "12345",
      "AdjustmentAmount": 1500.00,
      "ApprovalDate": "2023-10-01T00:00:00Z"
    },
    {
      // 更多记录...
    }
  ]
}

通过以上步骤，我们可以高效地调用金蝶云星空接口获取折旧调整单的数据，并进行必要的数据清洗和转换，最终将处理后的数据无缝对接到资产系统中。这一过程充分利用了轻易云数据集成平台的强大功能，实现了不同系统间的数据无缝对接。 如何对接金蝶云星空API接口

利用轻易云数据集成平台实现资产系统API接口的ETL转换

在数据集成生命周期的第二步，我们需要将已经集成的源平台数据进行ETL（Extract, Transform, Load）转换，使其符合目标平台美国人资产系统API接口所能接收的格式，并最终写入目标平台。本文将详细探讨这一过程中的技术细节，特别是如何配置和使用元数据来完成这一任务。

API接口配置与元数据解析

首先，我们需要理解目标平台美国人资产系统API接口的具体要求。根据提供的元数据配置，目标API接口为/assetCard/AssetFepreciationFromKingdee?fepreciationList=，请求方法为POST。以下是该接口所需的数据结构：

{
  "list": [
    {
      "device_code": "资产条码",
      "ori_value": "原值(元)",
      "dep_value": "累计折旧(元)",
      "net_value": "净值(元)",
      "use_year": "使用年限(月)",
      "less_value": "预计净残值",
      "dprn_date": "折旧到期日期"
    }
  ]
}

数据转换逻辑

为了将源平台的数据转换为上述格式，我们需要对每个字段进行相应的处理。以下是具体的字段映射和转换逻辑：

  1. device_code (资产条码):

    • 来源：{{FA_DEPRADJUSTENTRY.FA_DEPRADJUSTDETAIL.0.AssetNO}}
    • 类型：字符串
    • 说明：直接从源数据中提取资产条码。

  2. ori_value (原值(元)):

    • 来源：_function {{FA_DEPRADJUSTENTRY.OrgVal}}*1
    • 类型：字符串
    • 说明：将源数据中的原值乘以1，确保其为数值类型。

  3. dep_value (累计折旧(元)):

    • 来源：_function round({{FA_DEPRADJUSTENTRY.AccumDepr}}+{{FA_DEPRADJUSTENTRY.Depr}},2)
    • 类型：字符串
    • 说明：计算累计折旧，取源数据中的累积折旧和当前折旧之和，并四舍五入到小数点后两位。

  4. net_value (净值(元)):

    • 来源：_function round({{FA_DEPRADJUSTENTRY.OrgVal}}-{{FA_DEPRADJUSTENTRY.AccumDepr}}-{{FA_DEPRADJUSTENTRY.Depr}},2)
    • 类型：字符串
    • 说明：计算净值，即原值减去累积折旧和当前折旧后的结果，并四舍五入到小数点后两位。

  5. use_year (使用年限(月)):

    • 来源：_function {{FA_DEPRADJUSTENTRY.LifePeriods}}*1
    • 类型：字符串
    • 说明：将使用年限乘以1，确保其为数值类型。

  6. less_value (预计净残值):

    • 来源：_function {{FA_DEPRADJUSTENTRY.Residualvalue}}*1
    • 类型：字符串
    • 说明：将预计净残值乘以1，确保其为数值类型。

  7. dprn_date (折旧到期日期):

    • 固定值："2024-05-16"
    • 类型：字符串
    • 说明：直接设置为固定日期。

实现步骤

  1. 配置请求字段：
{
  "field": "list",
  "label": "list",
  "type": "array",
  "value": "FA_DEPRADJUSTENTRY",
  "children": [
    {
      "field": "device_code",
      "label": "资产条码",
      "type": "string",
      "value": "{{FA_DEPRADJUSTENTRY.FA_DEPRADJUSTDETAIL.0.AssetNO}}"
    },
    {
      "field": "ori_value",
      "label": "原值(元)",
      "type": "string",
      "value": "_function {{FA_DEPRADJUSTENTRY.OrgVal}}*1"
    },
    {
      ...
    }
  ]
}
  1. 定义转换函数：

在轻易云数据集成平台中，可以通过自定义函数实现复杂的数据转换逻辑。例如：

function calculateDepValue(accumDepr, depr) {
  return round(accumDepr + depr, 2);
}

function calculateNetValue(orgVal, accumDepr, depr) {
  return round(orgVal - accumDepr - depr, 2);
}
  1. 执行数据写入：

通过POST请求，将转换后的数据发送到目标API接口：

const requestData = {
  list: transformedData // 转换后的数据数组
};

fetch('/assetCard/AssetFepreciationFromKingdee?fepreciationList=', {
  method: 'POST',
  headers: {
    'Content-Type': 'application/json'
  },
  body: JSON.stringify(requestData)
})
.then(response => response.json())
.then(data => console.log('Success:', data))
.catch(error => console.error('Error:', error));

总结

通过以上步骤，我们成功地将源平台的数据进行ETL转换，使其符合目标平台美国人资产系统API接口的要求，并最终写入目标平台。这一过程充分利用了轻易云数据集成平台提供的全生命周期管理功能，实现了高效、透明的数据处理流程。 企业微信与ERP系统接口开发配置

版权声明

该文章《高效跨平台数据集成：实现折旧调整单从金蝶云到美国人资产系统的流转》为原创内容，版权归 广东轻亿云软件科技有限公司 所有。 未经本公司书面授权，严禁转载、引用、复制或建立镜像等行为。 若需转载或引用本文内容，请联系本公司获取授权，并在显著位置注明作者姓名、文章出处（包括原文链接）等信息。

数据集成平台运行原理
更多系统对接方案