钉钉报销【现货采购】->金蝶付款单【画纤骨】数据集成案例分享

在企业的财务管理体系中，实现不同系统间的数据无缝对接，能够显著提升业务处理效率。本篇技术文章将详细解析如何通过轻易云数据集成平台，将钉钉的报销数据高效、安全地转入金蝶云星空中的付款单模块，确保数据流动过程中零遗漏和信息的一致性。

1. 集成需求分析

本次集成项目主要涉及以下两个核心业务系统：

• 钉钉： 用于处理员工报销申请，通过API接口topapi/processinstance/get获取所需的数据。
• 金蝶云星空： 用于记录最终的财务凭证，通过API接口batchSave进行批量写入操作。

首先，需要从钉钉内部取得报销相关的数据。由于实际应用场景可能会产生大量、分页及限流限制，必要时需要实现可靠抓取机制，以确保不漏单。并且，在向金蝶云星空写入之前，要完成两者之间的数据格式映射转换，这是为了保证程序能正确理解和存储所有目标字段。此外，还要考虑错误重试机制，以应对传输过程中可能出现的不确定性问题。

2. 数据抓取与实时监控

借助轻易云平台完善的接口支持和日志记录功能，我们能够定时可靠地调用滴滴API topapi/processinstance/get去抓取数据，并设置合理的分页策略来处理大规模数据。同时，为了以防止意外情况导致某些条目未被成功捕获或发送，可以设立定时任务和重试机制，每获取一批数据都进行详细日志记录，这样可以在异常发生时快速定位并修复问题。

示例代码片段：

def fetch_ding_data():
    try:
        response = requests.post("https://oapi.dingtalk.com/topapi/processinstance/get", data=params)
        if response.status_code == 200:
            process_data(response.json())
        else:
            log_error("Failed to fetch data from DingTalk API", response.text)
    except Exception as e:
        log_error(f"Error occurred: {str(e)}")

3. 数据格式转换与写入

另一项重要工作是将从滴滴拿到的数据按需求映射、清洗后再插入到金蝶端。这不仅仅是字段名或者位置上的简单调整，很多时候还需要结合具体业务规则做一些自定义化处理，比如金额、小数点精度等。因此，我们利用轻易云提供的灵活配置工具进行了相关配置，使得各种复杂情况得到充分应对。在完成预

调用钉钉接口topapi/processinstance/get获取并加工数据

在数据集成的生命周期中，调用源系统接口是至关重要的一步。本文将深入探讨如何通过轻易云数据集成平台调用钉钉接口topapi/processinstance/get，获取并加工报销类别为“现货采购”的数据，并最终实现与金蝶付款单的无缝对接。

接口调用配置

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

{
  "api": "topapi/processinstance/get",
  "method": "POST",
  "number": "number",
  "id": "id",
  "idCheck": true,
  "condition": [
    [
      {
        "field": "报销类别",
        "logic": "eq",
        "value": "现货采购"
      }
    ]
  ]
}

此配置指定了我们将使用POST方法调用topapi/processinstance/get接口，并根据条件筛选出报销类别为“现货采购”的数据。

数据请求与清洗

在进行数据请求时，轻易云平台会根据上述元数据配置自动生成请求参数，并向钉钉API发送请求。以下是一个示例请求体：

{
  "process_instance_id": "<实例ID>"
}

其中，process_instance_id是我们需要提供的具体实例ID。响应结果通常包含多个字段，如下所示：

{
  "dingtalk_smartwork_bpms_processinstance_get_response": {
    "result": {
      "process_instance_id": "<实例ID>",
      "title": "<标题>",
      "create_time": "<创建时间>",
      ...
      "form_component_values": [
        {
          "name": "<字段名>",
          "value": "<字段值>"
        },
        ...
      ]
    }
  }
}

在获取到原始数据后，我们需要对其进行清洗和过滤。根据元数据中的条件配置，我们只保留报销类别为“现货采购”的记录。这一步骤可以通过轻易云平台内置的数据清洗功能实现。

数据转换与写入

清洗后的数据需要进行格式转换，以符合目标系统（如金蝶付款单）的要求。假设金蝶付款单需要的数据格式如下：

{
  "付款单号": "<付款单号>",
  "申请人": "<申请人>",
  ...
}

我们可以利用轻易云平台的转换工具，将钉钉返回的数据映射到金蝶所需的字段。例如：

• process_instance_id -> 付款单号
• title -> 申请人

具体的映射规则可以在轻易云平台中通过拖拽操作完成，非常直观和高效。

实际案例应用

假设我们有一个实际案例，需要将某个报销流程实例的数据从钉钉导入到金蝶系统中。首先，通过API接口获取该实例的数据：

{
  "process_instance_id": "1234567890"
}

响应结果可能包含如下信息：

{
  "dingtalk_smartwork_bpms_processinstance_get_response": {
    ...
    "result": {
      ...
      "form_component_values": [
        {
          "name": "报销类别",
          "value": "现货采购"
        },
        {
          "name": "<其他字段名>",
          ...
        }
      ]
    }
  }
}

根据元数据配置，我们只保留“报销类别”为“现货采购”的记录，并将其转换为金蝶系统所需的格式：

{
  "付款单号": "<1234567890>",
  ...
}

最后，通过轻易云平台将转换后的数据写入到金蝶系统中，完成整个集成过程。

总结

本文详细介绍了如何通过轻易云数据集成平台调用钉钉接口topapi/processinstance/get，获取并加工特定条件下的数据。在实际操作中，通过合理配置元数据，可以大大简化复杂的数据处理流程，实现不同系统间的数据无缝对接，提高业务效率和透明度。

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

在数据集成的生命周期中，将源平台的数据转换为目标平台可接受的格式是关键步骤之一。本文将详细探讨如何使用轻易云数据集成平台，将钉钉报销【现货采购】的数据转换为金蝶付款单【画纤骨】格式，并通过金蝶云星空API接口写入目标平台。

配置元数据

首先，我们需要配置元数据，以便定义从源平台到目标平台的数据映射关系。以下是配置元数据的具体内容：

{
  "api": "batchSave",
  "method": "POST",
  "idCheck": true,
  "operation": {
    "method": "batchArraySave",
    "rows": 1,
    "rowsKey": "array"
  },
  "request": [
    {
      "field": "FBillNo",
      "label": "单据编号",
      "type": "string",
      "describe": "单据编号",
      "value": "{{extend.business_id}}"
    },
    {
      "field": "FBillTypeID",
      "label": "单据类型",
      "type": "string",
      "describe": "单据类型",
      "parser": {
        "name": "ConvertObjectParser",
        "params": "FNUMBER"
      },
      "value": "FKDLX01_SYS"
    },
    {
      ...
    }
  ],
  ...
}

数据字段解析与映射

在上述元数据配置中，每个字段都对应于金蝶付款单的一个属性。我们需要确保这些字段能够正确解析和映射到目标系统所需的格式。

1. 单据编号 (FBillNo)：

   • 来源：{{extend.business_id}}
   • 类型：string
   • 描述：钉钉报销系统中的业务ID。

2. 单据类型 (FBillTypeID)：

   • 固定值：FKDLX01_SYS
   • 类型：string
   • 描述：固定为付款单类型。

3. 业务日期 (FDATE)：

   • 来源：{{extend.finish_time}}
   • 类型：string
   • 描述：报销完成时间。

4. 结算组织 (FSETTLEORGID) 和 付款组织 (FPAYORGID)：

   • 来源：根据费用归属项目从集合中查找。
   • 类型：string
   • 描述：结算和付款组织。

5. 币别 (FCURRENCYID) 和 结算币别 (FSETTLECUR)：

   • 固定值：PRE001
   • 类型：string
   • 描述：固定为预设币别。

6. 往来单位类型 (FCONTACTUNITTYPE) 和 收款单位类型 (FRECTUNITTYPE)：

   • 固定值：BD_Supplier
   • 类型：string
   • 描述：固定为供应商类型。

7. 往来单位 (FCONTACTUNIT) 和 收款单位 (FRECTUNIT)：

   • 来源：根据客户字段解析。
   • 类型：string
   • 描述：客户信息。

8. 备注 (FREMARK)：

   • 来源：组合多个字段生成备注信息。
   • 类型：string

9. 付款单明细 (FPAYBILLENTRY)： 包含多个子字段，如结算方式、付款用途、我方银行账号、应付金额、物料编码、含税单价、数量、费用项目和备注等。这些子字段均需要根据相应的源数据进行解析和映射。

API请求配置

为了将转换后的数据写入金蝶云星空，我们需要配置API请求参数：

{
  ...
  "otherRequest":[
    {
      ...
    },
    {
      ...
    }
  ]
}

• FormId: AP_PAYBILL, 表示业务对象表单Id。
• Operation: BatchSave, 表示执行批量保存操作。
• IsAutoSubmitAndAudit: false, 表示不自动提交和审核。
• IsVerifyBaseDataField: false, 表示不验证所有基础资料有效性。

实际应用案例

假设我们有一条钉钉报销记录，需要将其转换并写入金蝶云星空。以下是一个具体案例：

{
  ...
}

在实际操作中，首先通过轻易云数据集成平台读取钉钉报销记录，然后根据上述元数据配置进行ETL转换，最后通过配置好的API接口将转换后的数据写入金蝶云星空系统。

通过这种方式，我们可以实现不同系统间的数据无缝对接，确保数据的一致性和准确性，大大提升了业务处理效率。