转载 金蝶付款申请单与钉钉供应商月结付款无缝集成

金蝶付款申请单到钉钉供应商月结付款的数据集成方案

在企业的财务管理和供应链运营中，数据的高效流转和准确对接至关重要。本文将分享一个具体的系统对接集成案例：如何通过轻易云数据集成平台，将金蝶云星空中的付款申请单数据无缝集成到钉钉的供应商月结付款流程中。

本次集成方案名为“金蝶付款申请单->钉钉供应商月结付款①”，旨在实现从金蝶云星空获取付款申请单数据，并将其批量写入到钉钉的审批流程中。为了确保整个过程的高效性和可靠性，我们利用了轻易云平台的一系列特性，包括高吞吐量的数据写入能力、实时监控与告警系统、自定义数据转换逻辑等。

首先，通过调用金蝶云星空的executeBillQuery接口，我们能够定时可靠地抓取所需的付款申请单数据。这一步骤不仅需要处理分页和限流问题，还要确保数据不漏单，以保证所有应付账款都能及时进入后续处理环节。

接下来，针对从金蝶云星空获取的数据，我们使用轻易云平台提供的数据质量监控和异常检测功能，及时发现并处理潜在的数据问题。同时，通过自定义的数据转换逻辑，我们能够适配特定业务需求，将原始数据格式转换为符合钉钉API要求的格式。

最后，在将处理后的数据批量写入到钉钉时，调用topapi/processinstance/create接口，实现供应商月结付款流程的自动化启动。此过程中，轻易云平台提供了强大的集中监控和告警系统，实时跟踪每个任务状态，并在出现异常时触发错误重试机制，以确保整个集成过程顺利进行。

通过这一系列技术手段，我们不仅提升了业务透明度和效率，还实现了跨平台的数据无缝对接，为企业财务管理带来了显著优化。在后续章节中，我们将详细探讨每个步骤中的具体实现方法及注意事项。

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

在轻易云数据集成平台的生命周期中，调用源系统接口是关键的第一步。本文将详细探讨如何通过调用金蝶云星空的executeBillQuery接口来获取付款申请单的数据，并进行初步加工处理。

接口调用配置

首先，我们需要配置元数据以便正确地调用金蝶云星空的executeBillQuery接口。以下是主要的配置参数：

• API: executeBillQuery
• Method: POST
• Number: FBillNo
• ID: FBillNo
• Pagination: 每页500条记录
• Condition: 过滤条件，例如只查询付款组织ID为9.01的数据

这些配置确保了我们能够高效地分页获取所需的数据，同时也能根据特定条件进行筛选。

请求字段定义

为了确保我们获取到所有必要的信息，需要定义请求字段。这些字段包括但不限于：

• 实体主键（FID）
• 单据编号（FBillNo）
• 单据状态（FDOCUMENTSTATUS）
• 创建人（FCREATORID）
• 审核人（FAPPROVERID）
• 创建日期（FCREATEDATE）

例如，以下是部分请求字段的定义：

[
    {"field":"FID","label":"实体主键","type":"string","value":"FID"},
    {"field":"FBillNo","label":"单据编号","type":"string","value":"FBillNo"},
    {"field":"FDOCUMENTSTATUS","label":"单据状态","type":"string","value":"FDOCUMENTSTATUS"}
]

数据抓取与分页处理

由于金蝶云星空接口对每次返回的数据量有限制，我们需要实现分页抓取。通过设置分页参数如Limit和StartRow，可以逐页获取数据。例如，每页500条记录，从第0行开始：

{"Limit": "500", "StartRow": "0"}

在实际操作中，可以使用循环或递归方式逐页请求数据，直到没有更多记录为止。

数据清洗与转换

获取到原始数据后，需要进行初步清洗和转换，以便后续处理。例如，将日期格式统一、去除无效字符等。轻易云平台提供了自定义数据转换逻辑功能，可以根据业务需求编写相应的脚本或规则。

例如，将创建日期从字符串格式转换为标准日期格式：

def convert_date(date_str):
    return datetime.strptime(date_str, '%Y-%m-%d')

异常处理与重试机制

在调用过程中可能会遇到网络波动、接口限流等问题。为了保证数据抓取的可靠性，需要实现异常处理和重试机制。例如，当遇到网络错误时，可以等待一段时间后重新尝试请求。

import time
import requests

def fetch_data_with_retry(url, params, retries=3):
    for i in range(retries):
        try:
            response = requests.post(url, data=params)
            if response.status_code == 200:
                return response.json()
        except requests.exceptions.RequestException as e:
            print(f"Error occurred: {e}, retrying...")
            time.sleep(2 ** i)  # 指数退避策略
    raise Exception("Failed to fetch data after multiple retries")

实时监控与日志记录

为了确保整个过程透明可控，需要实时监控数据抓取任务的状态，并记录日志。轻易云平台提供了集中的监控和告警系统，可以帮助及时发现并解决问题。

例如，通过日志记录每次请求的状态和返回结果：

import logging

logging.basicConfig(level=logging.INFO)

def log_request_status(status, message):
    logging.info(f"Request status: {status}, Message: {message}")

log_request_status("Success", "Fetched 500 records from page 1")

通过上述步骤，我们可以高效地从金蝶云星空系统中获取付款申请单的数据，并进行初步加工，为后续的数据集成奠定基础。在整个过程中，合理利用轻易云平台提供的各种功能，如自定义转换逻辑、异常处理机制和实时监控系统，可以极大提升数据集成效率和可靠性。

金蝶付款申请单到钉钉供应商月结付款的ETL转换与写入

在数据集成生命周期的第二步，我们需要将已经集成的源平台数据进行ETL转换，确保其符合目标平台钉钉API接口的格式要求，并最终写入目标平台。本文将详细探讨如何利用轻易云数据集成平台，将金蝶付款申请单的数据转换并写入钉钉供应商月结付款流程。

数据请求与清洗

首先，从金蝶系统中提取所需数据。假设我们已经通过适当的API调用获取了付款申请单的数据，包括单据编号、货款所属项目、供应商名称、付款时间等字段。这些数据需要进行清洗和预处理，以确保其质量和一致性。

数据转换与映射

接下来，我们进入ETL过程中的关键步骤：数据转换。根据提供的元数据配置，我们需要将金蝶系统中的字段映射到钉钉API接口所需的字段格式。以下是几个关键字段的映射和转换逻辑：

1. 审批流的唯一码（process_code）：

   • 直接使用固定值 PROC-BB90A28C-0800-4F37-A972-E23EA258CA09。

2. 发起人（originator_user_id）：

   • 通过查询 _findCollection 函数，从用户ID集合中找到对应的发起人ID。

     _findCollection find user_id from ac26166e-93e7-382b-80ad-25a9eba3166e where name={F_VAOJ_FQR}

3. 发起人所在部门（dept_id）：

   • 同样使用 _findCollection 函数，从领导部门信息中获取发起人的部门ID。

     _findCollection find leader_in_dept.0.dept_id from ac26166e-93e7-382b-80ad-25a9eba3166e where name={F_VAOJ_FQR}

4. 审批流表单参数（form_component_values）：

   • 这是最为复杂的一部分，需要对多个字段进行映射和转换。例如：
     • 单据编号：直接映射 {FBillNo}。
     • 货款所属项目：反向映射 6295fa8ab3945438dd215d24。
     • 供应商名称：直接映射 {FCONTACTUNIT}。
     • 付款时间：使用日期格式化函数 {{FCREATEDATE|date}}。
     • 货款属性：使用条件判断逻辑 _function case '{F_VAOJ_HKSX}' when 'CP' then '成品' else '辅料' end。

数据写入

完成所有必要的转换后，生成最终的JSON请求体，并通过POST方法调用钉钉API接口 topapi/processinstance/create 将数据写入钉钉系统。

{
    "process_code": "PROC-BB90A28C-0800-4F37-A972-E23EA258CA09",
    "originator_user_id": "_findCollection find user_id from ac26166e-93e7-382b-80ad-25a9eba3166e where name={F_VAOJ_FQR}",
    "dept_id": "_findCollection find leader_in_dept.0.dept_id from ac26166e-93e7-382b-80ad-25a9eba3166e where name={F_VAOJ_FQR}",
    "form_component_values": [
        {"name": "单据编号", "value": "{FBillNo}"},
        {"name": "货款所属项目", "value": "{FSETTLEORGID}"},
        {"name": "供应商名称", "value": "{FCONTACTUNIT}"},
        {"name": "付款时间", "value": "{{FCREATEDATE|date}}"},
        {"name": "货款属性", "value": "_function case '{F_VAOJ_HKSX}' when 'CP' then '成品' else '辅料' end"},
        {"name": "备注", "value": "备注为：{F_VAOJ_Remarks}"},
        {"name": "付款金额（元）", "value": "{FAPPLYAMOUNTFOR_H}"},
        {"name": "收款人（公司名称）", "value": "{FEACHCCOUNTNAME}"},
        {"name": "收款人帐号", "value": "{FEACHBANKACCOUNT}"}
    ]
}

注意事项

1. 分页和限流问题： 在处理大量数据时，需要注意分页处理以及API调用频率限制。可以通过设置适当的分页参数和重试机制，确保数据完整性和稳定性。

2. 异常处理与错误重试机制： 实现可靠的数据传输，需要对可能出现的异常情况进行捕获和处理，设计合理的错误重试机制，以应对网络波动或接口调用失败等问题。

3. 实时监控与日志记录： 对整个ETL过程进行实时监控，并记录详细日志，以便在发生问题时能够快速定位和解决。

通过以上步骤，可以高效地实现从金蝶付款申请单到钉钉供应商月结付款的数据集成，确保数据准确无误地传输到目标平台，提高业务流程自动化水平。