轻易云数据集成：从金蝶云星空到旺店通的完整实践

  • 轻易云集成顾问-吕修远

金蝶云星空与旺店通·旗舰版的数据集成：从分步式调入到委外仓入

在本案例中，我们探讨了如何通过轻易云数据集成平台，成功实现金蝶云星空系统向旺店通·旗舰版的无缝数据对接。该方案名为“标准-金蝶-分步式调入——>旺店通-委外仓入(入库业务)”。本文将详细解析整个集成过程中使用的一系列技术要点和解决方案。

API接口的应用及其优化

首先，从金蝶云星空获取原始数据是整个流程的起点。我们使用了executeBillQuery API接口来实时抓取所需的业务单据信息。在实际操作中，对分页和限流问题进行了深入处理，以确保大量数据能够高效、稳定地获取并传输至平台。

对于数据写入端，我们采用了旺店通·旗舰版提供的wms.stockother.In.push API接口。这一过程不仅需要考量高吞吐量的数据写入能力，还需特别注意两大系统之间存在的数据格式差异。因此，自定义数据转换逻辑成为不可或缺的一环，使得来自金蝶云星空的数据经过适配后无缝导入到旺店通·旗舰版。

监控与告警机制

为了保障整个集成任务的平稳运行，配置并启用了集中监控和告警系统。这些工具可以实时跟踪每个数据流转环节，一旦出现异常情况，如API调用失败或网络延迟等，可迅速触发预设的告警策略，并进行自动化处理。例如，在发生错误时，重试机制会自动重新发送请求以确保最终顺利完成任务。

优化资源利用与性能管理

借助于统一视图和控制台，不仅能全面掌握API资产使用情况，还能有效配置资源，实现最佳性能管理。同时，通过定时可靠抓取金蝶云星空接口数据，并结合批量操作方式，将大量订单快速、高效地推送到目标系统，为企业运营带来了极大的便捷性和经济效益。

以上这些步骤，共同构筑了一个功能完善且灵活可靠的数据集成环境。从源头抓取、动态转换，到目标落地，每一步都充分体现出先进技术在业务中的实际应用价值。在后续内容中，我们将进一步深入剖析具体技术细节及应对挑战的方法。 用友与外部系统接口集成开发

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

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

接口配置与请求参数

首先，我们需要配置接口的元数据。根据提供的元数据配置，executeBillQuery接口采用POST方法进行调用，主要参数包括单据编号（FBillNo）、实体主键（FID）等。以下是具体的请求参数配置：

{
  "api": "executeBillQuery",
  "method": "POST",
  "number": "FBillNo",
  "id": "FSTKTRSINENTRY_FEntryID",
  "pagination": {
    "pageSize": 500
  },
  "idCheck": true,
  "request": [
    {"field":"FSTKTRSINENTRY_FEntryID","label":"FEntryID","type":"string","value":"FSTKTRSINENTRY_FEntryID"},
    {"field":"FID","label":"实体主键","type":"string","value":"FID"},
    {"field":"FBillNo","label":"单据编号","type":"string","value":"FBillNo"},
    {"field":"FDocumentStatus","label":"单据状态","type":"string","value":"FDocumentStatus"},
    {"field":"FStockOrgID_FNumber","label":"调入库存组织","type":"string","value":"FStockOrgID.FNumber"},
    {"field":"FDate","label":"日期","type":"string","value":"FDate"},
    {"field":"FBillTypeID","label":"单据类型","type":"string","value":"FBillTypeID.FNAME"},
    {"field":"FTransferDirect","label":"调拨方向","type":"string","value":"FTransferDirect"},
    {"field":"FNOTE","label":"备注","type":"string","value":"FNOTE"},
    {"field":"FCreateDate","label":"创建日期","type":"string","value":"FCreateDate"},
    {"field":"FApproveDate","label":"审核日期","type":"string","value":"FApproveDate"},
    {"field":"FTransferMode","label":"调拨方式","type":"string","value":"FTransferMode"},
    {"field\":\"...\"}
  ],
  "otherRequest": [
    {"field": "Limit", "label": "最大行数", "type": "string", "describe": "金蝶的查询分页参数", "value": "{PAGINATION_PAGE_SIZE}"},
    {"field": "StartRow", "label": "开始行索引", "type": "string", "describe": "金蝶的查询分页参数", "value": "{PAGINATION_START_ROW}"},
    {"field": "TopRowCount", "label": "返回总行数", "type": "int", "describe": ""},
    {"field\": \"FilterString\", \"label\": \"过滤条件\", \"type\": \"string\", \"describe\": \"示例写法 FSupplierId.FNumber = 'VEN00010' and FApproveDate>=\",\"value\":\"...\"},
    {\"...\"}
  ]
}

数据请求与清洗

在实际操作中，我们需要通过API请求获取原始数据，并对其进行清洗和转换。以下是一个典型的数据请求示例：

import requests
import json

url = 'https://api.kingdee.com/executeBillQuery'
headers = {'Content-Type': 'application/json'}
payload = {
  'FormId': 'STK_TRANSFERIN',
  'FieldKeys': 'FID,FBillNo,FDocumentStatus,FStockOrgID.FNumber,FDate,FBillTypeID.FNAME,FTransferDirect,FNOTE,FCreateDate,FApproveDate,FTransferMode',
  'FilterString':"FSupplierId.FNumber = 'VEN00010' and FApproveDate>='2024-08-05'",
  'Limit': 500,
  'StartRow': 0
}

response = requests.post(url, headers=headers, data=json.dumps(payload))
data = response.json()

上述代码通过POST方法向金蝶云星空接口发送请求，并获取返回的数据。接下来，我们需要对这些数据进行清洗和转换，以便后续处理。

数据转换与写入

获取到的数据通常需要进行一定的转换操作，例如字段重命名、格式调整等。以下是一个简单的数据转换示例：

def transform_data(data):
    transformed_data = []

    for entry in data:
        transformed_entry = {
            'entry_id': entry['FID'],
            'bill_no': entry['FBillNo'],
            'status': entry['FDocumentStatus'],
            'stock_org': entry['FStockOrgID.FNumber'],
            'date': entry['FDate'],
            # ...其他字段转换...
        }
        transformed_data.append(transformed_entry)

    return transformed_data

cleaned_data = transform_data(data)

在完成数据转换后，我们可以将其写入目标系统或数据库，以供后续使用。

实践中的注意事项

  1. 分页处理：由于每次请求的数据量有限，需要通过分页参数（如Limit和StartRow）来分批次获取完整的数据集。
  2. 错误处理：在实际操作中，可能会遇到网络问题或API错误，需要做好异常捕获和重试机制。
  3. 性能优化：对于大规模数据集成任务，可以考虑使用多线程或异步编程来提升性能。

通过以上步骤，我们实现了从金蝶云星空接口获取并加工数据，为后续的数据处理和分析奠定了基础。在实际项目中，根据具体需求进行相应调整，以确保数据集成过程高效、可靠。 金蝶与SCM系统接口开发配置

轻易云数据集成平台：ETL转换及写入旺店通·旗舰版API接口

在数据集成的生命周期中，ETL（提取、转换、加载）过程是关键的一环。本文将深入探讨如何使用轻易云数据集成平台，将已经集成的源平台数据进行ETL转换，转为目标平台旺店通·旗舰版API接口所能够接收的格式，并最终写入目标平台。

API接口配置解析

根据提供的元数据配置，我们需要将数据转换为符合旺店通·旗舰版API接口wms.stockother.In.push要求的格式。以下是该API接口的详细配置：

{
  "api": "wms.stockother.In.push",
  "effect": "EXECUTE",
  "method": "POST",
  "idCheck": true,
  "request": [
    {
      "field": "order",
      "label": "单据头",
      "type": "object",
      "children": [
        {"field": "outer_no", "label": "外部单号", "type": "string", "value": "{FBillNo}"},
        {"field": "warehouse_no", "label": "仓库编号", "type": "string", "value": "{FDestStockID_FNumber}"},
        {"field": "reason", "label": "入库原因", "type": "string", "value": "调拨入库"},
        {"field": "is_check", "label": "是否审核", "type": "string", "value":"true"},
        {"field":"remark","label":"备注","type":"string","value":"调出仓:{FSrcStockID_FNumber} {FNOTE}"}
      ]
    },
    {
      "field":"order_details",
      "label":"单据明细",
      "type":"array",
      "value":"list",
      ...
    }
  ],
  ...
}

数据转换步骤

  1. 提取源数据： 首先，从源系统（金蝶）中提取需要的数据。假设我们已经通过轻易云平台完成了这一阶段的数据请求与清洗工作。

  2. 构建请求头（Order）： 根据元数据配置，我们需要构建一个包含订单头信息的对象。具体字段映射如下：

    • outer_no: 对应金蝶中的FBillNo
    • warehouse_no: 对应金蝶中的FDestStockID_FNumber
    • reason: 固定值“调拨入库”
    • is_check: 固定值“true”
    • remark: 拼接字段“调出仓:{FSrcStockID_FNumber} {FNOTE}”

  3. 构建订单明细（Order Details）： 接下来，我们需要处理订单明细部分。这一部分是一个数组，每个元素代表一条明细记录。字段映射如下：

    • spec_no: 对应金蝶中的FMaterialID_FNumber
    • num: 对应金蝶中的FQty
    • price: 对应金蝶中的FMaterialID_FRefCost
    • remark: 对应金蝶中的FEntryNote

  4. 计算聚合字段： 在构建订单明细时，我们还需要对数量字段进行求和操作。这可以通过轻易云平台提供的计算功能实现。

实际操作示例

以下是一个简化的代码示例，展示如何将上述逻辑实现为实际操作：

# 假设我们已经从金蝶系统获取了原始数据
source_data = {
    'FBillNo': '12345',
    'FDestStockID_FNumber': 'WH001',
    'FSrcStockID_FNumber': 'WH002',
    'FNOTE': '备注信息',
    'details': [
        {'FMaterialID_FNumber': 'P001', 'FQty': 10, 'FMaterialID_FRefCost': 100, 'FEntryNote': '明细备注1'},
        {'FMaterialID_FNumber': 'P002', 'FQty': 20, 'FMaterialID_FRefCost': 200, 'FEntryNote': '明细备注2'}
    ]
}

# 构建请求头
order = {
    'outer_no': source_data['FBillNo'],
    'warehouse_no': source_data['FDestStockID_FNumber'],
    'reason': '调拨入库',
    'is_check': True,
    'remark': f"调出仓:{source_data['FSrcStockID_FNumber']} {source_data['FNOTE']}"
}

# 构建订单明细并计算数量总和
order_details = []
total_qty = 0
for detail in source_data['details']:
    order_details.append({
        'spec_no': detail['FMaterialID_FNumber'],
        'num': detail['FQty'],
        'price': detail['FMaterialID_FRefCost'],
        'remark': detail['FEntryNote']
    })
    total_qty += detail['FQty']

# 最终请求体
request_payload = {
    'order': order,
    'order_details': order_details
}

# 使用HTTP POST方法将数据发送到旺店通·旗舰版API接口
import requests

response = requests.post(
    url='https://api.wangdian.cn/openapi2/wms.stockother.In.push',
    json=request_payload
)

if response.status_code == 200:
    print("Data successfully written to 旺店通·旗舰版")
else:
    print("Failed to write data:", response.text)

总结

通过以上步骤，我们成功地将源平台（金蝶）的数据进行了ETL转换，并写入到了目标平台（旺店通·旗舰版）。这一过程充分利用了轻易云数据集成平台提供的元数据配置和计算功能，实现了高效的数据处理和无缝对接。 用友与MES系统接口开发配置

版权声明

该文章《如何通过轻易云平台实现金蝶云星空数据集成》为原创内容，版权归 广东轻亿云软件科技有限公司 所有。 未经本公司书面授权，严禁转载、引用、复制或建立镜像等行为。 若需转载或引用本文内容，请联系本公司获取授权，并在显著位置注明作者姓名、文章出处（包括原文链接）等信息。

数据集成平台架构
更多系统对接方案