### 钉钉报销【月结贷款】集成到金蝶云星空
在数据集成的实际应用中，如何高效稳定地实现系统对接是一个备受关注的问题。本文将分享一个具体的技术案例：通过轻易云数据集成平台，实现钉钉报销模块的数据无缝对接金蝶云星空的付款单模块。
#### 集成背景及需求分析
本次项目的核心目标是从钉钉获取每月报销【月结贷款】的数据，并将其准确且及时地写入到金蝶云星空系统中的付款单模块。为了保证数据处理过程的完整性和实时性，需要解决以下几个关键问题：
1. **确保数据不漏单**：必须保证每一笔在钉钉上生成的报销记录都能够无遗漏地传递到金蝶云星空。
2. **快速批量写入**：面对大规模的数据量，需实现高效的数据迁移与批量操作，从而避免性能瓶颈和用户体验问题。
3. **定时可靠抓取接口数据**：需要周期性（如每日或每小时）从钉钉端抓取最新产生或更新过的数据，以保持同步。
4. **处理分页和限流问题**：由于API调用限制，需要合理规划并控制API请求，确保不会因超出频率限制导致失败。
#### 技术方案概述
针对此次任务，我们设计了一套自动化处理流程，包括以下主要环节：
1. **调用TopAPI获取数据**：
- 利用`topapi/processinstance/get`接口，根据设定条件查询近期所有待支付报销记录。考虑到分页返回以及速率限制，将采用分段查询并合并结果的方法。
2. **格式转换与映射**：
- 在完成原始数据提取后，对其进行预处理、清洗及必要字段映射，以符合金蝶云星空接受标准。这其中涵盖了不同字段类型及结构差异，以及某些业务特有信息的额外转换。
3. **批量保存至金蝶云星空**：
- 通过`batchSave`接口，将整理完毕后的报销单据一次性快速推送至付款单模块。在此过程中还需注意事务一致性管理，即部分成功或失败时应该具备重试机制以保证整体操作成功完成。
4. **异常处理与日志跟踪**：
- 全程实施细粒度监控，对各个阶段、各类可能出现的问题进行捕捉与详细日志记录。特别是在网络波动、服务器响应延迟等情况下，可以即时触发报警机制或者自动重试策略来减少人工介入，提高工作效率和准确度。
####
### 调用钉钉接口topapi/processinstance/get获取并加工数据
在数据集成过程中，调用源系统的API接口是至关重要的一步。本文将详细探讨如何使用轻易云数据集成平台调用钉钉接口`topapi/processinstance/get`，并对获取的数据进行加工处理。
#### 接口调用与元数据配置
我们首先需要了解如何配置和调用钉钉的API接口。在本案例中，我们使用的是`topapi/processinstance/get`接口，通过POST方法来请求数据。以下是具体的元数据配置：
```json
{
"api": "topapi/processinstance/get",
"method": "POST",
"number": "number",
"id": "id",
"idCheck": true,
"condition": [
[
{
"field": "报销类别",
"logic": "eq",
"value": "月结货款"
}
]
],
"formatResponse": [
{
"old": "付款方式",
"new": "付款方式_new",
"format": "string"
}
]
}
```
#### 数据请求与条件过滤
在调用API时，我们需要传递必要的参数和条件过滤。在本例中，条件过滤部分如下：
```json
"condition": [
[
{
"field": "报销类别",
"logic": "eq",
"value": "月结货款"
}
]
]
```
这段配置表示我们只获取报销类别为“月结货款”的数据。通过这种方式，可以有效地筛选出我们需要的数据，避免不必要的数据传输和处理。
#### 数据格式化与字段映射
获取到原始数据后，需要对其进行格式化和字段映射。元数据配置中的`formatResponse`部分定义了这一过程：
```json
"formatResponse": [
{
"old": "付款方式",
"new": "付款方式_new",
"format": "string"
}
]
```
这表示将原始字段“付款方式”重命名为“付款方式_new”，并将其格式化为字符串类型。这一步骤确保了数据在后续处理环节中的一致性和可读性。
#### 实际操作步骤
1. **配置API请求**：在轻易云平台上，进入API配置界面，选择POST方法，并输入API路径`topapi/processinstance/get`。
2. **设置请求参数**：根据元数据配置，设置请求参数，包括必要的ID检查（`idCheck: true`）和条件过滤。
3. **执行请求**：发送请求并获取响应数据。
4. **处理响应数据**：根据`formatResponse`部分，对响应数据进行字段映射和格式化处理。
#### 示例代码
以下是一个示例代码片段，用于展示如何在实际操作中实现上述步骤：
```python
import requests
import json
# 配置API路径和请求头
url = 'https://oapi.dingtalk.com/topapi/processinstance/get'
headers = {'Content-Type': 'application/json'}
# 设置请求参数
payload = {
'process_instance_id': 'your_process_instance_id',
'userid': 'your_user_id'
}
# 执行POST请求
response = requests.post(url, headers=headers, data=json.dumps(payload))
# 检查响应状态
if response.status_code == 200:
data = response.json()
# 条件过滤
if data['报销类别'] == '月结货款':
# 字段映射与格式化
formatted_data = {
'付款方式_new': str(data['付款方式'])
}
print(formatted_data)
else:
print(f"Error: {response.status_code}")
```
通过上述步骤，我们成功地从钉钉系统中获取了指定条件的数据，并进行了必要的字段映射和格式化处理。这一过程不仅提高了数据处理的效率，也确保了后续集成环节的顺利进行。
### 使用轻易云数据集成平台将钉钉报销数据转换并写入金蝶云星空API接口
在数据集成过程中，将源平台的数据转换为目标平台可接受的格式是至关重要的一步。本文将详细探讨如何使用轻易云数据集成平台，将钉钉报销【月结贷款】的数据转换为金蝶付款单【衣酷】所需的格式，并通过金蝶云星空API接口进行写入。
#### 配置元数据
首先，我们需要配置元数据，以确保数据能够正确映射到目标平台的字段。以下是元数据配置的详细说明：
```json
{
"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`
- 描述：使用固定值表示特定的单据类型，通过`ConvertObjectParser`解析为目标系统可识别的格式。
3. **业务日期 (FDATE)**:
- 来源字段：`{{extend.finish_time}}`
- 类型：`string`
- 描述：业务完成时间直接映射为付款单的业务日期。
4. **结算组织 (FSETTLEORGID)** 和 **付款组织 (FPAYORGID)**:
- 来源字段：`{{费用归属项目}}`
- 类型：`string`
- 描述：通过查询集合获取对应的组织编码，并使用`ConvertObjectParser`进行解析。
5. **币别 (FCURRENCYID)** 和 **结算币别 (FSETTLECUR)**:
- 固定值：`PRE001`
- 类型：`string`
- 描述：使用固定值表示币种，通过解析器进行转换。
6. **往来单位类型 (FCONTACTUNITTYPE)** 和 **收款单位类型 (FRECTUNITTYPE)**:
- 固定值：`BD_Supplier`
- 类型：`string`
- 描述：统一设置为供应商类型。
7. **往来单位 (FCONTACTUNIT)** 和 **收款单位 (FRECTUNIT)**:
- 来源字段：`{{客户TextField_A5PMZAFT4BC0}}`
- 类型：`string`
- 描述：从源系统中获取客户信息并进行解析。
8. **备注 (FREMARK)**:
- 来源字段组合： `{title}-{{客户TextField-K2U5DHAA}}-{{备注}}`
- 类型：`string`
- 描述：组合多个字段形成备注信息。
9. **付款单明细 (FPAYBILLENTRY)**:
在付款单明细中，需要处理多个子字段：
```json
{
...
{
field: 'FPAYBILLENTRY',
label: '付款单明细',
type: 'array',
children: [
{
field: 'FSETTLETYPEID',
label: '结算方式',
type: 'string',
parser: { name: 'ConvertObjectParser', params: ['FNumber'] },
value: '_findCollection find Number from 04463531-c6b1-3e53-b5d7-9d456a92d4cf where Name={{付款方式_new}}'
},
...
]
}
}
```
10. **部门 (FDepartment)**:
- 来源字段： `{{费用归属部门}}`
- 类型： `string`
- 描述：通过查询集合获取对应部门编码，并进行解析。
#### API请求配置
为了实现批量保存操作，API请求配置如下：
```json
{
...
{
field: 'FormId',
label: '业务对象表单Id',
type: 'string',
describe: '必须填写金蝶的表单ID如:PUR_PurchaseOrder',
value: 'AP_PAYBILL'
},
{
field: 'Operation',
label: '执行的操作',
type: 'string',
value: 'BatchSave'
},
{
field: 'IsAutoSubmitAndAudit',
label: '提交并审核',
type: 'bool',
value: false
},
{
field: 'IsVerifyBaseDataField',
label: '验证基础资料',
type: 'bool',
describe:'是否验证所有的基础资料有效性，布尔类，默认false（非必录）',
value:false
}
}
```
上述配置确保了在提交数据时，能够正确匹配和验证基础资料，并且支持批量保存操作。
#### 实际案例应用
通过以上配置，我们可以实现将钉钉报销【月结贷款】的数据无缝转化为金蝶付款单【衣酷】所需格式，并通过金蝶云星空API接口进行写入。整个过程包括了数据提取、清洗、转换和写入，确保了数据的一致性和准确性。
