聚水潭数据集成到金蝶云星空：采购订单回传单号可行性调研报告

聚水潭系统（源）
    ↓ 调用 /open/purchase/query API（POST方法，支持分页）
轻易云数据集成平台（集成枢纽）
    ├─ 数据抽取层：定时触发/事件驱动，处理限流与分页
    ├─ 数据转换层：ETL处理，字段映射与格式转换
    ├─ 数据质量层：异常检测、数据清洗、校验规则
    └─ 数据加载层：调用金蝶 batchSave API（批量写入）
金蝶云星空系统（目标）
    ↓ 返回执行结果，触发轻易云监控告警

{
  "api": "/open/purchase/query",
  "effect": "QUERY",
  "method": "POST",
  "idCheck": true,
  "request": [
    {
      "field": "modified_begin",
      "label": "修改起始时间",
      "type": "datetime",
      "describe": "修改起始时间，和结束时间必须同时存在，时间间隔不能超过七天，与线上单号不能同时为空",
      "value": "{{LAST_SYNC_TIME|datetime}}"
    },
    {
      "field": "modified_end",
      "label": "修改结束时间",
      "type": "datetime",
      "describe": "修改结束时间，和起始时间必须同时存在，时间间隔不能超过七天，与线上单号不能同时为空",
      "value": "{{CURRENT_TIME|datetime}}"
    },
    {
      "field": "page_index",
      "label": "第几页",
      "type": "string",
      "describe": "第几页，从1开始",
      "value": "1"
    },
    {
      "field": "page_size",
      "label": "每页条数",
      "type": "string",
      "describe": "每页多少条，最大50条",
      "value": "{PAGINATION_PAGE_SIZE}"
    }
  ]
}

{
  "api": "batchSave",
  "method": "POST",
  "request": [
    {
      "field": "FID",
      "label": "单据内码",
      "type": "string",
      "describe": "通过查询语句获取金蝶系统中的唯一标识符",
      "value": "_findCollection find FID from 7389e0ad-45f1-37e3-8887-5770febb696a where FBillNo={so_id}"
    },
    {
      "field": "F_JSTPO",
      "label": "聚水潭单号",
      "type": "string",
      "value": "{po_id}"
    },
    {
      "field": "FUPLOAD",
      "label": "上传标志",
      "type": "string",
      "value": "true"
    }
  ],
  "otherRequest": [
    {
      "field": "FormId",
      "label": "业务对象表单Id",
      "type": "string",
      "describe": "必须填写金蝶的表单ID如:PUR_PurchaseOrder",
      "value": "PUR_PurchaseOrder"
    },
    {
      "field": "Operation",
      "label": "执行的操作",
      "type": "string",
      "value": "BatchSave"
    },
    {
      "field": "IsAutoSubmitAndAudit",
      "label": "提交并审核",
      "type": "bool",
      "describe": "是否自动提交并审核",
      "value": "false"
    },
    {
      "field": "IsVerifyBaseDataField",
      "label": "验证基础资料",
      "type": "bool",
      "describe": "是否验证所有的基础资料有效性，布尔类，默认false（非必录）",
      "value": "false"
    },
    {
      "field": "IsUserModelInit",
      "label": "忽略网控",
      "type": "bool",
      "value": "true"
    }
  ]
}

// 条件映射示例：根据wms_co_id映射库存组织
function mapStockOrg(wmsCoId) {
  const mapping = {
    '13328244': '101',
    '13328245': '102'
  };
  return mapping[wmsCoId] || '100'; // 默认值100
}

{
  "incremental": true,
  "incrementalField": "modified_time",
  "incrementalFormat": "yyyy-MM-dd HH:mm:ss",
  "schedule": "*/5 * * * *"  // 每5分钟执行一次
}

{
  "retryPolicy": {
    "maxRetries": 5,
    "intervalSeconds": 10,
    "backoffMultiplier": 2,  // 指数退避策略
    "retryableStatusCodes": [500, 502, 503, 504, 429]
  }
}