金蝶云星空销售出库单自动化审核方案

如何利用金蝶云星空提升销售出库单处理效率

2024-12-09 11:27:12
轻易云集成顾问-李奇微

金蝶云星空数据集成案例分享：销售出库单自动提交审核

在企业的日常运营中，销售出库单的处理效率和准确性至关重要。为了提升这一环节的自动化程度，我们采用了金蝶云星空平台，实现了销售出库单从生成到审核的全流程自动化。本次集成方案主要聚焦于如何通过轻易云数据集成平台，将金蝶云星空中的销售出库单数据高效、可靠地提交并审核。

首先，我们利用金蝶云星空提供的数据获取API executeBillQuery，定时抓取最新生成的销售出库单数据。为了确保数据不漏单，我们设计了一套可靠的数据抓取机制，通过批量处理和分页技术，有效应对接口限流问题。同时，轻易云的数据质量监控功能帮助我们及时发现并处理任何异常情况，保证了数据的一致性和完整性。

接下来，通过自定义的数据转换逻辑，我们将抓取到的销售出库单数据进行必要的格式调整，以适应目标系统的要求。这一步骤对于确保数据能够顺利写入目标平台至关重要。随后，我们调用金蝶云星空的数据写入API Audit，实现销售出库单的自动提交审核。得益于轻易云高吞吐量的数据写入能力，即使面对大量订单，也能快速完成集成任务，大幅提升了业务处理时效性。

整个集成过程由集中监控和告警系统实时跟踪，不仅可以随时查看任务状态，还能在出现异常时迅速响应。这种全透明可视化操作界面，使得每个环节都清晰可见，为企业提供了极大的便利和保障。

通过这次集成方案实施，我们不仅实现了销售出库单自动提交审核，还为后续更多业务场景的数据集成奠定了坚实基础。在接下来的章节中，将详细介绍具体实现步骤及技术细节。用友与SCM系统接口开发配置

企业微信与ERP系统接口开发配置

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

在数据集成过程中，调用源系统接口是至关重要的一步。本文将详细探讨如何通过轻易云数据集成平台调用金蝶云星空的executeBillQuery接口，获取销售出库单数据并进行初步加工处理。

配置API请求参数

首先，我们需要配置API请求的元数据，以确保能够正确调用金蝶云星空的executeBillQuery接口。以下是关键的元数据配置：

API名称：executeBillQuery
请求方法：POST
分页设置：
- 每页大小：100
- 开始行索引：根据实际情况动态计算
过滤条件：
- 创建日期大于上次同步时间
- 单据状态不等于已关闭
- 单据类型为销售出库单（XSCKD07_SYS）

{
    "api": "executeBillQuery",
    "method": "POST",
    "pagination": {
        "pageSize": 100
    },
    "request": [
        {"field":"FBillTypeID_FNumber","label":"单据类型","type":"string","value":"FBillTypeID.FNumber"},
        {"field":"FID","label":"FID","type":"string","value":"FID"},
        {"field":"FBillNo","label":"单据编号","type":"string","value":"FBillNo"},
        {"field":"FDate","label":"日期","type":"string","value":"FDate"},
        {"field":"FSaleOrgId_FNumber","label":"销售组织","type":"string","value":"FSaleOrgId.FNumber"},
        {"field":"FCustomerID_FNumber","label":"客户","type":"string","value":"FCustomerID.FNumber"},
        {"field":"FStockOrgId_FNumber","label":"发货组织","type":"string","value":"FStockOrgId.FNumber"},
        {"field": "FApproveDate", "label": "审核时间", "type": "string", "value": "FApproveDate"}
    ],
    "otherRequest":[
        {"field": "Limit", "label": "最大行数", "type": "string", "value": "{PAGINATION_PAGE_SIZE}"},
        {"field": "StartRow", "label": "开始行索引", "type": "string", 
"value":
"{PAGINATION_START_ROW}"},
        {"field":
"FilterString",
"label":
"过滤条件",
"type":
"string",
"value":
"FCreateDate>='{{LAST_SYNC_TIME|dateTime}}' and FDOCUMENTSTATUS<>'C' and FBillTypeID.fnumber='XSCKD07_SYS'"},
{"field":
"FieldKeys",
"label":
"需查询的字段key集合",
"type":
"array",
"value":["FBillTypeID.FNumber, FID, FBillNo, FDate, FSaleOrgId.FNumber, FCustomerID.F.Number, FStockOrgId.F.Number, FApproveDate"]},
{"field":
"FormId",
"label":
"业务对象表单Id",
"type":
"string",
"value":
"SAL_OUTSTOCK"}
]
}

调用API并处理响应

在配置好元数据后，通过轻易云平台发起对金蝶云星空接口的调用。需要特别注意的是，分页和限流问题。在每次请求中，需要根据返回的数据量和总记录数来动态调整分页参数，以确保能够完整获取所有符合条件的数据。

def fetch_data(page_index):
    request_payload = {
        # 填充其他必要参数...
        'StartRow': page_index * PAGE_SIZE,
        'Limit': PAGE_SIZE,
    }

    response = requests.post(API_URL, json=request_payload)

    if response.status_code == 200:
        data = response.json()

        # 数据处理逻辑...

fetch_data(0)

数据清洗与转换

获取到原始数据后，需要对其进行清洗和转换，以便后续写入目标系统。常见的数据清洗操作包括：

字段映射：将源系统中的字段名映射为目标系统中的字段名。
格式转换：例如，将日期字符串转换为标准日期格式。
异常处理：检测并处理缺失值、重复值等异常情况。

def clean_data(raw_data):
    cleaned_data = []

    for record in raw_data:
        cleaned_record = {
            'bill_type': record['FBillTypeID_FNumber'],
            'id': record['FID'],
            'bill_no': record['FBillNo'],
            'date': parse_date(record['FDate']),
            'sale_org': record['FSaleOrgId_FNumber'],
            'customer_id': record['FCustomerID_F_Number'],
            'stock_org': record['FStockOrgId_F_Number'],
            'approve_date': parse_date(record['FApproveDate'])
         }
         cleaned_data.append(cleaned_record)

     return cleaned_data

cleaned_records = clean_data(raw_records)

确保高效与可靠性

为了确保集成过程的高效与可靠性，可以采取以下措施：

批量处理：尽可能使用批量操作来减少网络开销和提高吞吐量。
错误重试机制：对于失败的请求，设置重试机制以提高成功率。
实时监控与告警：通过平台提供的监控功能，实时跟踪任务状态，并在出现异常时及时告警。

def process_batch(batch):
   try:
       # 批量写入目标系统...
   except Exception as e:
       log_error(e)
       retry_batch(batch)

for batch in split_into_batches(cleaned_records):
   process_batch(batch)

通过上述步骤，我们可以高效地完成从金蝶云星空获取销售出库单数据，并进行初步加工，为后续的数据写入和进一步处理打下坚实基础。金蝶与外部系统打通接口

用友与MES系统接口开发配置

销售出库单自动提交审核

在数据集成过程中，将源平台的数据转换为金蝶云星空API接口可接收的格式，并最终写入目标平台，是关键的一步。本文将详细解析如何通过配置元数据，完成销售出库单的自动提交审核。

数据转换与写入

首先，需要明确金蝶云星空API接口的调用方法和参数配置。根据提供的元数据配置，调用金蝶云星空的Audit接口，实现销售出库单的自动提交审核。以下是主要参数：

FormId: 业务对象表单ID，必须填写金蝶的表单ID，如：SAL_OUTSTOCK
Numbers: 编码集合，对应销售出库单的编号
Ids: ID集合
InterationFlags: 交互标志集合，用于处理特定业务逻辑
IgnoreInterationFlag: 是否允许忽略交互，默认值为true
NetworkCtrl: 是否启用网控，默认值为false
IsVerifyProcInst: 是否检验单据关联运行中的工作流实例，默认值为false

元数据配置解析

在ETL（抽取、转换、加载）过程中，需要将源平台的数据进行清洗和转换，使其符合目标平台的要求。以下是具体步骤：

抽取数据：从源平台提取销售出库单相关数据。
数据清洗：对提取的数据进行清洗，去除冗余信息，确保数据准确无误。
数据转换：根据金蝶云星空API接口要求，对数据进行格式转换。以下是一个示例配置：

{
  "api": "Audit",
  "method": "POST",
  "idCheck": true,
  "request": [
    {
      "field": "FormId",
      "label": "业务对象表单Id",
      "type": "string",
      "describe": "必须填写金蝶的表单ID如:PUR_PurchaseOrder",
      "value": "SAL_OUTSTOCK"
    },
    {
      "field": "Numbers",
      "label": "编码集合",
      "type": "string",
      "value": "{FBillNo}"
    },
    {
      "field": "Ids",
      "label": "id集合",
      "type": "string"
    },
    {
      "field": "InterationFlags",
      ...

加载数据：将转换后的数据通过API接口写入金蝶云星空系统。

实现高效的数据写入

为了确保高效的数据写入，需要关注以下几点：

高吞吐量支持：轻易云平台支持高吞吐量的数据写入能力，使得大量销售出库单能够快速被集成到金蝶云星空系统中。
实时监控与告警：利用平台提供的集中监控和告警系统，实时跟踪数据集成任务的状态和性能，及时发现并处理问题。
自定义数据转换逻辑：根据业务需求，自定义数据转换逻辑，以适应特定的数据结构和格式。

异常处理与重试机制

在对接过程中，不可避免地会遇到各种异常情况。为了提高系统的稳定性，需要实现异常处理与错误重试机制：

异常检测：通过平台内置的数据质量监控功能，及时发现并记录异常情况。
错误重试：对于失败的请求，可以设置自动重试机制，确保重要数据不丢失。

调用示例

调用金蝶云星空API接口executeBillQuery时，需要特别注意分页和限流问题。例如：

{
  ...
  {
    "field": "IsVerifyProcInst",
    ...

通过合理设置分页参数和限流策略，可以有效避免因请求过多导致的性能问题。

总之，通过以上步骤，可以顺利完成销售出库单的自动提交审核，实现源平台与金蝶云星空系统之间的数据无缝对接，提高业务处理效率。企业微信与OA系统接口开发配置