案例分享：金蝶云星空数据集成到旺店通·企业奇门

在现代化的企业管理中，数据流动的高效性和准确性对于业务流程的优化至关重要。面对复杂多变的数据环境，如何实现不同系统之间的数据无缝对接成为了许多企业关注的焦点。在本篇技术案例中，我们将详细探讨如何通过轻易云数据集成平台，将金蝶云星空中的直接调拨单（direct transfer orders）高效、可靠地集成到旺店通·企业奇门（WDT Qimen），实现从采购订单创建到业务处理全链条自动化的一体化解决方案。

为了确保金蝶云星空与旺店通·企业奇门之间的数据交换过程不丢单且准确，我们首先需要调用金蝶云星空提供的executeBillQuery接口进行定时可靠地抓取数据。这一过程中，我们采用了一些关键技术手段，如：

1. 分页和限流处理：executeBillQuery接口返回的大量数据需分批次获取，以避免超出API请求限制和网络带宽瓶颈。
2. 实时监控与日志记录：对每一次API调用及返回结果进行详细记录，并在后台实时监控，以便及时发现并解决潜在问题。
3. 格式转换：针对金蝶云星空和旺店通·企业奇门两者间的数据格式差异，应用自定义映射规则进行一致性的转换。

随后，通过轻易云强大的批量写入功能，将已处理好的采购订单信息提交给旺店通·企业奇门，此过程中主要利用了wdt.purchase.order.push API。为了保证该环节操作顺利完成，我们特别设计了以下机制：

• 异常处理与错误重试：设置重试机制，应对网络故障或暂时性的API不可用情况，确保最终所有有效数据都成功推送并确认接收。
• 快速写入大规模数据：优化队列管理和并发控制，加速大量订单同时写入，提高整体效率。

最后，通过灵活配置相关参数，实现高度定制化的数据映射和适配。本文将逐步解析上述步骤，每个关键节点均会附上代码示例及实践建议，为您呈现一个完整、高效、安全的数据集成实例。

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

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

接口配置与调用

首先，我们需要配置和调用金蝶云星空的executeBillQuery接口。根据提供的元数据配置，以下是该接口的详细参数：

• API: executeBillQuery
• Method: POST
• Effect: QUERY
• 主要字段:
  • FBillEntry_FEntryID: 分录内码
  • FID: 实体主键
  • FBillNo: 单据编号
  • FDocumentStatus: 单据状态
  • FStockOrgId_FNumber: 调入库存组织
  • FDate: 日期
  • FBillTypeID_FNumber: 单据类型
  • FTransferBizType: 调拨类型
  • FStockOutOrgId_FNumber: 调出库存组织
  • FTransferDirect: 调拨方向
  • 更多字段详见元数据配置...

请求参数构建

为了实现对金蝶云星空系统的有效查询，我们需要构建一个请求参数对象。以下是一个示例请求参数：

{
    "FormId": "STK_TransferDirect",
    "FieldKeys": "FBillEntry_FEntryID,FID,FBillNo,FDocumentStatus,FStockOrgId.FNumber,FDate,FBillTypeID.FNumber,FTransferBizType,FStockOutOrgId.FNumber,FTransferDirect",
    "FilterString": "FApproveDate>='2023-01-01' and F_PAEZ_CheckBox='1' and FStockOutOrgId.FNumber in ('100','203','207','200')",
    "Limit": "500",
    "StartRow": "0"
}

上述请求参数中，FormId指定了业务对象表单ID为STK_TransferDirect，FieldKeys列出了需要查询的字段集合，FilterString定义了过滤条件，确保只获取符合条件的数据。

数据清洗与转换

在获取到原始数据后，需要对其进行清洗和转换，以便后续处理。以下是一个简单的数据清洗与转换示例：

import pandas as pd

# 假设response_data是从API获取到的原始数据列表
response_data = [
    {"FBillEntry_FEntryID": "1001", "FID": "2001", "FBillNo": "BILL001", ...},
    {"FBillEntry_FEntryID": "1002", "FID": "2002", "FBillNo": "BILL002", ...},
    # 更多数据...
]

# 将原始数据转换为DataFrame便于处理
df = pd.DataFrame(response_data)

# 清洗和转换数据，例如去除无效值、格式化日期等
df['FDate'] = pd.to_datetime(df['FDate'])
df = df.dropna(subset=['FBillNo', 'FID'])

# 转换后的DataFrame可以进一步处理或写入目标系统

写入目标系统

经过清洗和转换的数据可以通过轻易云平台写入到目标系统（如旺店通）。此过程通常包括将DataFrame中的数据转换为目标系统所需的格式，并通过相应的API进行写入。

# 假设target_system_api是目标系统的API地址
target_system_api = 'https://api.targetsystem.com/write'

# 将DataFrame转换为JSON格式并发送POST请求写入目标系统
import requests

data_to_write = df.to_json(orient='records')
response = requests.post(target_system_api, data=data_to_write, headers={'Content-Type': 'application/json'})

if response.status_code == 200:
    print("Data written successfully")
else:
    print(f"Failed to write data: {response.text}")

通过以上步骤，我们实现了从金蝶云星空获取、清洗、转换并写入目标系统的数据集成过程。这不仅提高了业务流程的自动化程度，还确保了数据的一致性和准确性。

使用轻易云数据集成平台将金蝶直接调拨单转换并写入旺店通·企业奇门API接口

在数据集成的生命周期中，ETL（提取、转换、加载）是关键步骤之一。本文将深入探讨如何使用轻易云数据集成平台，将金蝶直接调拨单的数据进行ETL转换，转为旺店通·企业奇门API接口所能够接收的格式，并最终写入目标平台。

1. 数据请求与清洗

在进行ETL之前，首先需要从源系统（金蝶）中提取数据。假设我们已经完成了这一阶段的数据请求与清洗工作，接下来我们重点关注数据的转换与写入。

2. 数据转换与写入

为了将金蝶直接调拨单的数据转换为旺店通·企业奇门API接口所能接收的格式，我们需要配置相应的元数据。以下是详细的元数据配置及其应用：

{
  "api": "wdt.purchase.order.push",
  "effect": "EXECUTE",
  "method": "POST",
  "idCheck": true,
  "operation": {
    "method": "merge",
    "field": "FBillNo,FSrcStockID_FNumber,FDestStockID_FNumber",
    "bodyName": "details_list",
    "bodySum": ["FQty"],
    "header": ["FBillNo", "FStockID", "FSupplierId", "FNOTE", "FSUPPLIERID_FNumber", "FMaterialId_FNumber", "FDestStockId_FNumber", "FStockOrgId_FNumber"],
    "body": ["FMaterialId_FNumber", "FQty", "FTaxPrice", "FEntryNote"]
  },
  "request": [
    {"field":"provider_no","label":"供应商编号","type":"string","describe":"供应商编号","value":"{FStockOrgId_FNumber}"},
    {"field":"warehouse_no","label":"仓库编号","type":"string","describe":"仓库编号","value":"{FDestStockId_FNumber}"},
    {"field":"outer_no","label":"API单号","type":"string","describe":"API单号","value":"{FBillNo}"},
    {"field":"is_use_outer_no","label":"传入ERP采购单号","type":"string","describe":"传入ERP采购单号","value":"1"},
    {"field":"is_check","label":"自动审核","type":"string","describe":"自动审核","value":"1"},
    {"field":"expect_arrive_time","label":"预计到货时间","type":"string","describe":"预计到货时间","value":"{FDeliveryDate}"},
    {
      "field": "details_list",
      "label": "采购明细节点",
      "type": "array",
      "describe": "采购明细节点",
      "value": "details_list",
      "children": [
        {"field":"remark","label":"备注","type":"string","describe":"备注","value":"{FNote}"},
        {"field":"spec_no","label":"商家编码","type":"string","describe":"商家编码","value":"'findCollection find spec_list.0.spec_no from 4ac96860-8efb-3671-a3b7-c45414cc7ddf where goods_no={FMaterialId_FNumber}'"},
        {"field":"num","label":"采购量","type":"string","describe":"采购量","value":"{FQty}"},
        {"field":"price","label":"采购价格","type":"","describe":"","value":{"FTaxPrice"}}
      ]
    }
  ],
  'otherRequest':[
     {'field':'purchase_info','label':'采购列表节点','type':'string','describe':'采购列表节点'}
   ]
}

元数据配置详解

1. API接口定义：

   • api: 定义目标API接口为wdt.purchase.order.push。
   • method: 使用POST方法提交数据。
   • idCheck: 启用ID检查，确保唯一性。

2. 操作配置：

   • method: 使用merge方法合并数据。
   • field: 指定合并字段为FBillNo, FSrcStockID_FNumber, FDestStockID_FNumber。
   • bodyName: 指定明细列表名称为details_list。
   • bodySum: 对明细中的数量字段进行汇总。
   • header, body: 定义头部和明细字段。

3. 请求参数映射：

   • 将金蝶系统中的字段映射到旺店通·企业奇门API所需的字段。例如：
     • provider_no: 映射为供应商编号，对应金蝶中的{FStockOrgId_FNumber}。
     • warehouse_no: 映射为仓库编号，对应金蝶中的{FDestStockId_FNumber}。
     • outer_no: 映射为API单号，对应金蝶中的{FBillNo}。

4. 明细节点配置：

   • 明细节点包含多个子字段，如备注、商家编码、采购量和采购价格等，这些字段分别映射到金蝶系统中的相应字段。

数据写入目标平台

通过上述配置，我们可以将处理后的数据通过POST请求提交到旺店通·企业奇门的API接口，实现从金蝶直接调拨单到旺店通采购订单的无缝对接。此过程不仅保证了数据的一致性和完整性，还极大提升了业务处理效率。

在实际操作中，我们还需要注意异常处理和日志记录，以便及时发现和解决问题，确保整个ETL过程顺利进行。