### 金蝶云星空数据集成到泛微OA-Http的技术实现
在企业信息化系统环境中，实现不同业务系统之间的数据无缝对接是提升工作效率和优化资源配置的关键一步。本文将分享一个具体的技术案例，详细介绍如何借助轻易云数据集成平台，将金蝶云星空的数据高效、稳定地集成到泛微OA-Http任务中的实施过程。
#### 项目概述
本项目主要目标是通过调用金蝶云星空接口`executeBillQuery`, 定时可靠地抓取费用项目信息，并利用泛微OA-Http提供的API `/api/cube/new/card/doSubmit` 将数据批量写入对应模块。在这个过程中，我们面对高吞吐量需求，以及需要处理接口分页、限流等技术挑战。
#### 技术细节与实现要点
1. **定时任务调度与获取数据**
首先，通过轻易云平台的定时抓取功能，配置参数以固定周期执行对金蝶云星空API `executeBillQuery` 的调用，从而获取最新的费用项目信息。该步骤确保了我们能够及时且持续地同步最新业务数据。
2. **分页处理与限流策略**
由于金蝶云星空返回的大量纪录可能导致单次请求超载，因此我们必须精心设计分页处理方案。在每次API调用中，使用适当大小的页面参数，使得每批返回的数据都能安全传输。同时，为防止频繁访问造成服务器压力，在各页间必须配置合理时间间隔，以符合限流要求。
3. **自定义转换逻辑与格式差异适配**
两个系统的数据结构存在显著差异，需要针对性编写转换脚本来调整字段映射关系，并进行必要的数据清洗和格式调整。这部分工作可以在可视化设计工具上完成，有效降低了出错率并提高了开发便捷性。
4. **实时监控及异常检测**
在整个流程中，通过集中监控平台实时追踪各任务状态。当检测到异常情况，例如网络故障或接口错误时，触发告警机制并记录问题日志。此外，还考虑到了错误重试机制，对于偶发性异常则自动重新尝试执行相应操作以保障整体流程顺利进行。
5. **高吞吐量写入能力**
最后，在将整理好的费用项目信息批量提交至泛微OA-Http之前，根据实际负载情况合理分配资源，使得大量数据能够快速、高效地被成功写入指定模块之中。同时采用一些性能调优手段，如减少冗余字段传输等，以进一步提升速度和稳定性。
以上即为项目开头部分的重要技术点
### 调用金蝶云星空接口executeBillQuery获取并加工数据
在轻易云数据集成平台的生命周期中，调用源系统接口是至关重要的一步。本文将深入探讨如何通过调用金蝶云星空的`executeBillQuery`接口来获取并加工数据，以实现费用项目的集成。
#### API接口配置
首先，我们需要了解`executeBillQuery`接口的基本配置。根据元数据配置，以下是该接口的详细信息：
- **API名称**: executeBillQuery
- **请求方法**: POST
- **主要字段**:
- `FNumber`: 编码
- `FName`: 名称
- `FEXPID`: id
- `F_WMMX_OAId`: OA回传内码
此外，还有一些其他请求参数，用于控制查询结果的分页和过滤条件：
- **Limit**: 最大行数
- **StartRow**: 开始行索引
- **TopRowCount**: 返回总行数
- **FilterString**: 过滤条件（例如：`FAuditDate>='{{LAST_SYNC_TIME|datetime}}' and FForbidStatus='A'`）
- **FieldKeys**: 需查询的字段key集合
- **FormId**: 业务对象表单Id（例如：`BD_Expense`）
#### 请求参数构建
在实际操作中，我们需要根据业务需求构建请求参数。以下是一个示例请求体：
```json
{
"FormId": "BD_Expense",
"FieldKeys": ["FNumber", "FName", "FEXPID", "F_WMMX_OAId"],
"FilterString": "FAuditDate>='2023-01-01' and FForbidStatus='A'",
"Limit": 100,
"StartRow": 0,
"TopRowCount": true
}
```
该请求体指定了要查询的业务对象表单、字段集合、过滤条件以及分页参数。
#### 数据处理与转换
在获取到原始数据后，需要对其进行清洗和转换，以便后续写入目标系统。以下是一个示例代码片段，用于处理从金蝶云星空获取的数据：
```python
import requests
def fetch_data():
url = 'https://api.kingdee.com/executeBillQuery'
headers = {'Content-Type': 'application/json'}
payload = {
"FormId": "BD_Expense",
"FieldKeys": ["FNumber", "FName", "FEXPID", "F_WMMX_OAId"],
"FilterString": "FAuditDate>='2023-01-01' and FForbidStatus='A'",
"Limit": 100,
"StartRow": 0,
"TopRowCount": True
}
response = requests.post(url, json=payload, headers=headers)
data = response.json()
# 数据清洗与转换
cleaned_data = []
for item in data['Result']:
cleaned_item = {
'编码': item['FNumber'],
'名称': item['FName'],
'id': item['FEXPID'],
'OA回传内码': item['F_WMMX_OAId']
}
cleaned_data.append(cleaned_item)
return cleaned_data
# 调用函数获取并处理数据
processed_data = fetch_data()
print(processed_data)
```
上述代码展示了如何调用`executeBillQuery`接口，并对返回的数据进行清洗和转换。通过这种方式，可以确保数据符合目标系统的要求。
#### 自动填充响应
根据元数据配置中的`autoFillResponse`属性，轻易云平台可以自动填充响应数据。这意味着在大多数情况下，我们不需要手动解析和映射字段，平台会自动完成这一过程，从而简化了开发工作。
#### 总结
通过调用金蝶云星空的`executeBillQuery`接口，并结合轻易云平台提供的自动化工具，可以高效地实现费用项目的数据集成。在实际操作中，灵活运用请求参数和数据处理技术，可以极大提升数据集成的效率和准确性。
### 轻易云数据集成平台：将源平台数据转换并写入泛微OA-HttpAPI接口
在数据集成过程中，ETL（提取、转换、加载）是关键步骤之一。本文将详细探讨如何利用轻易云数据集成平台，将金蝶的费用项目数据转换为泛微OA-HttpAPI接口所能接收的格式，并最终写入目标平台。
#### 元数据配置解析
首先，我们来看一下元数据配置：
```json
{
"api": "/api/cube/new/card/doSubmit",
"effect": "EXECUTE",
"method": "POST",
"idCheck": true,
"request": [
{"field":"billid","label":"参数ID","type":"string","describe":"打开泛微表单后可以在URL中获取该参数","value":"{F_WMMX_OAId}"},
{"field":"type","label":"类型","type":"string","describe":"类型","value":"_function case '{F_WMMX_OAId}' when '' then 1 else 2 end"},
{"field":"modeId","label":"modeId","type":"string","describe":"//0 正常，1重要，2紧急","value":"38"},
{"field":"formId","label":"formId","type":"string","describe":"formId","value":"-187"},
{
"field": "JSONStr",
"label": "JSONStr",
"type": "object",
"children": [
{"field": "field11654", "label": "费用项目编码", "type": "string", "value": "{FNumber}"},
{"field": "field11655", "label": "费用类型名称", "type": "string", "value": "{FName}"},
{"field": "field11856", "label": "费用项目英文名称",
"type": "string",
"value": "_findCollection find fyxmywmc from 4f7d7071-9c5d-3c4d-8d9b-084741badbdf where id={F_WMMX_OAId}"
},
{"field": "field11656",
"label": "费用类别",
"type": "string",
"value": "_findCollection find fylb from 4f7d7071-9c5d-3c4d-8d9b-084741badbdf where id={F_WMMX_OAId}"
},
{"field":
field11657,
label: 是否对个可用,
type: string,
value: _findCollection find sfdgky from 4f7d7071-9c5d-3c4d-8d9b-084741badbdf where id={F_WMMX_OAId}
}
]
},
{"field":"guid","label":"guid","type":"string","value":"card"},
{"field":"layoutid","label":"layoutid","type":"string","value":"242"},
{"field":"iscreate","label":"iscreate","type":"string","value":"_function case '{F_WMMX_OAId}' when '' then 1 else 0 end"},
{"field":"token","label":"token","type":"string"},
{"field":"user_id","label":"user_id","type":"string","value":"22"}
]
}
```
#### 数据请求与清洗
在ETL过程的第一步，我们已经从金蝶系统中提取了原始数据。接下来，我们需要对这些数据进行清洗和转换，以符合泛微OA系统的要求。
#### 数据转换与写入
根据元数据配置，我们需要将金蝶系统中的字段映射到泛微OA系统所需的字段格式。以下是具体步骤：
1. **设置API端点**：
- API路径为`/api/cube/new/card/doSubmit`
- 请求方法为`POST`
2. **构建请求参数**：
- `billid`: 从URL中获取，使用占位符`{F_WMMX_OAId}`
- `type`: 使用条件表达式判断`{F_WMMX_OAId}`是否为空，为空则设置为1，否则设置为2
- `modeId`: 固定值38
- `formId`: 固定值-187
- `JSONStr`: 包含多个子字段，用于传递具体的费用项目信息
- `field11654`: 对应金蝶中的`{FNumber}`
- `field11655`: 对应金蝶中的`{FName}`
- `field11856`, `field11656`, `field11657`: 分别通过查询集合获取相应字段值
- `guid`, `layoutid`, `iscreate`, `token`, `user_id`: 分别设置为固定值或通过条件表达式计算
3. **实现API调用**：
将上述构建好的请求参数通过HTTP POST方法发送至泛微OA系统的指定API端点。
#### 技术细节与注意事项
1. **条件表达式与函数使用**：
在元数据配置中，使用了多种条件表达式和函数，例如：
```json
"_function case '{F_WMMX_OAId}' when '' then 1 else 2 end"
```
用于根据特定条件动态生成参数值。
2. **集合查询**：
对于某些字段值，通过集合查询来获取。例如：
```json
"_findCollection find fyxmywmc from ... where id={F_WMMX_OAId}"
```
确保这些查询能够正确执行，并返回预期结果。
3. **安全性与认证**：
确保在实际操作中，所有敏感信息（如`token`）都经过适当保护，并且API调用符合安全规范。
通过以上步骤，我们成功地将金蝶系统中的费用项目数据转换并写入到泛微OA系统，实现了不同系统间的数据无缝对接。这不仅提升了业务流程的自动化程度，也确保了数据的一致性和准确性。
