基础数据同步：仓库/员工/往来单位同步实现

POST https://openapi.chanjet.com/tplus/api/v2/warehouse/Query
Headers:
  appKey: {appKey}
  appSecret: {appSecret}
  openToken: {accessToken}
Content-Type: application/json

{
    "param": {
        "SelectFields": "ID,Code,Name,WarehouseType.Code,WarehouseType.Name,Memo,Address,Admin.Code,Admin.Name,TS"
    }
}
​

function syncWarehouse() {
    $config    = loadConfig();
    $openToken = getValidToken($config);
    $pdo       = getDB($config['db']);

    $url  = 'https://openapi.chanjet.com/tplus/api/v2/warehouse/Query';
    $body = [
        'param' => [
            'SelectFields' => implode(',', [
                'ID', 'Code', 'Name',
                'WarehouseType.Code', 'WarehouseType.Name',
                'Memo', 'Address',
                'Admin.Code', 'Admin.Name', 'TS'
            ])
        ]
    ];

    $res  = callTplusApi($config['appKey'], $config['appSecret'], $openToken, $url, $body);
    $rows = extractRows($res);

    $stmt = $pdo->prepare("
        INSERT INTO tplus_warehouse (...) VALUES (...)
        ON DUPLICATE KEY UPDATE ...
    ");

    foreach ($rows as $r) {
        $stmt->execute([...]);
    }
}
​

POST https://openapi.chanjet.com/tplus/api/v2/person/Query
Content-Type: application/json

{
    "dto": {
        "SelectFields": "ID,Code,Name,Department.Code,Department.Name,
                         MobilePhoneNo,IsSalesMan,Position,Disabled,
                         Gender,EmailAddr,IdentityNo,TS"
    }
}
​

// 员工 API 使用 dto
$body = ['dto' => ['SelectFields' => $selectFields]];

// 仓库 API 使用 param
$body = ['param' => ['SelectFields' => $selectFields]];
​

POST https://openapi.chanjet.com/tplus/api/v2/partner/Query
Content-Type: application/json

{
    "dto": {
        "SelectFields": "ID,Code,Name,Shorthand,PartnerAbbName,
                         PartnerType.Code,PartnerType.Name,
                         PartnerClass.Code,PartnerClass.Name,
                         Contact,MobilePhone,Address,Disabled,TS"
    }
}
​

INSERT INTO tplus_warehouse (code, name, type_code, ...)
VALUES (:code, :name, :type_code, ...)
ON DUPLICATE KEY UPDATE
    name = VALUES(name),
    type_code = VALUES(type_code),
    sync_time = NOW()
​