零售行业解决方案：旺店通与用友BIP集成接入步骤操作指南

{
  "start_time": "{{LAST_SYNC_TIME}}",
  "end_time": "{{CURRENT_TIME}}",
  "page_size": 100,
  "page_no": 1,
  "status": "80"
}

// 根据仓库编码获取组织编码
findCollection(
  target: "youyou_bip_warehouse_mapping",
  query: {wdt_code: "{{warehouse_no}}"},
  field: "bip_org_code"
)

import requests
import json
from datetime import datetime, timedelta

def query_wdt_stockout():
    url = "https://wdt.wangdian.cn/openapi2/wdt.stockout.order.query.trade"
    
    # 计算同步时间窗口
    last_sync = (datetime.now() - timedelta(minutes=5)).strftime('%Y-%m-%d %H:%M:%S')
    current_time = datetime.now().strftime('%Y-%m-%d %H:%M:%S')
    
    payload = {
        "start_time": last_sync,
        "end_time": current_time,
        "page_size": 100,
        "page_no": 1,
        "status": "80"  # 已发货状态
    }
    
    headers = {
        'Content-Type': 'application/json',
        'Authorization': 'Bearer YOUR_ACCESS_TOKEN'
    }
    
    response = requests.post(url, json=payload, headers=headers)
    return response.json()

def push_to_bip(wdt_data):
    url = "https://api.yonyoucloud.com/yonbip/sd/voucherorder/singleSave"
    
    bip_payload = {
        "data": {
            "code": wdt_data['stockout_no'],
            "vouchdate": wdt_data['consign_time'][:10],
            "org": map_warehouse_to_org(wdt_data['warehouse_no']),
            "resubmitCheckKey": wdt_data['stockout_no'],  # 幂等性控制
            "orderDetails": [
                {
                    "productId": detail['goods_no'],
                    "qty": detail['goods_count'],
                    "oriSum": calculate_amount(detail['total_amount'])
                }
                for detail in wdt_data['details_list']
            ]
        }
    }
    
    headers = {
        'Content-Type': 'application/json',
        'appKey': 'YOUR_APP_KEY',
        'appSecret': 'YOUR_APP_SECRET'
    }
    
    response = requests.post(url, json=bip_payload, headers=headers)
    return response.json()

{
  "integration": {
    "name": "旺店通-用友BIP销售订单同步",
    "source": {
      "platform": "wdt_qimen",
      "api": "wdt.stockout.order.query.trade",
      "method": "POST",
      "params": {
        "start_time": "{{LAST_SYNC_TIME}}",
        "end_time": "{{CURRENT_TIME}}",
        "page_size": 100
      }
    },
    "target": {
      "platform": "youyou_bip",
      "api": "/yonbip/sd/voucherorder/singleSave",
      "method": "POST"
    },
    "mapping": {
      "code": "{{stockout_no}}",
      "vouchdate": "{{consign_time|dateFormat:'yyyy-MM-dd'}}",
      "org": "{{warehouse_no|findCollection:'warehouse_mapping'}}",
      "orderDetails": "{{details_list|arrayMap}}"
    },
    "schedule": {
      "type": "cron",
      "expression": "0 */5 * * * *"
    }
  }
}