金蝶云星空API接口的ETL转换与数据写入方案：基于轻易云数据集成平台的经销商异构系统集成可行性深度调研报告

{
  "api": "executeBillQuery",
  "method": "POST",
  "number": "FNumber",
  "id": "FSupplierId",
  "request": [
    {"field": "FSupplierId", "label": "FSupplierId", "type": "string", "value": "FSupplierId"},
    {"field": "FNumber", "label": "编码", "type": "string", "value": "FNumber"},
    {"field": "FName", "label": "名称", "type": "string", "value": "FName"},
    {"field": "FCreateOrgId_FNumber", "label": "创建组织", "type": "string", "value":"FCreateOrgId.FNumber"}
  ]
}

{
  "api": "batchSave",
  "method": "POST",
  "idCheck": true,
  "operation": {
    "rowsKey": "array",
    "rows": 20,
    "method": "batchArraySave"
  },
  "request": [
    {"field":"FNumber","label":"编码","type":"string","value":"{FNumber}"},
    {"field":"FName","label":"名称","type":"string","value":"{FName}"},
    {"field":"FUseOrgId","label":"使用组织","type":"string","parser":{"name":"ConvertObjectParser","params":"FNumber"},"value":"{FUseOrgId_FNumber}"},
    {"field":"FCreateOrgId","label":"创建组织","type":"string","parser":{"name":"ConvertObjectParser","params":"FNumber"},"value":"{FCreateOrgId_FNumber}"}
  ],
  "otherRequest": [
    {"field":"FormId","label":"业务对象表单Id","type":"string","describe":"必须填写金蝶的表单ID如:PUR_PurchaseOrder","value":"BD_Supplier"},
    {"field":"Operation","label":"执行的操作","type":"string","value":"batchSave"},
    {"field":"IsVerifyBaseDataField","label":"验证基础资料","type":"bool","value":"false"},
    {"field":"IsAutoSubmitAndAudit","label":"提交并审核","type":"bool","value":"true"}
  ]
}

{
  "api": "Audit",
  "method": "POST",
  "idCheck": true,
  "request": [
    {"field": "FormId", "type": "string", "value": "PUR_PurchaseOrder"},
    {"field": "Numbers", "type": "string", "value": "{{单据编号}}"},
    {"field": "Ids", "type": "string", "value": "_findCollection find FID from fa3d5790-5d54-3e7b-b25e-91e571c3ded4 where FBillNo={{单据编号}}"},
    {"field": "IgnoreInterationFlag", "type": "string", "value":"true"},
    {"field": "NetworkCtrl", "type": "string", "value": "false"},
    {"field": "IsVerifyProcInst", "type": "string", "value": "false"}
  ]
}

# 步骤1：提取表单组件值
form_values = response['process_instance']['form_component_values']
data = {item['name']: item['value'] for item in form_values}

# 步骤2：校验和过滤数据
if data.get('采购类型') == '生产材料':
    processed_data = {
        'title': response['process_instance']['title'],
        'create_time': response['process_instance']['create_time'],
        'finish_time': response['process_instance']['finish_time'],
        'originator_userid': response['process_instance']['originator_userid'],
        'status': response['process_instance']['status'],
        'purchase_type': data.get('采购类型'),
        'purchase_amount': data.get('采购金额')
    }

# 步骤3：通过ConvertObjectParser转换基础资料编码
# 如：FUseOrgId_FNumber -> 金蝶内部组织ID