mirror of
https://github.com/woodchen-ink/czlexpress-for-woocommerce.git
synced 2025-07-18 14:01:58 +08:00
wood chen
64e952903a
- Updated system requirements in the README to reflect compatibility with WordPress 6.0+ and PHP 7.4+. - Revised usage steps for better clarity on plugin installation and configuration. - Improved order management features, including AJAX handling for shipment creation and tracking updates. - Added new custom order statuses (In Transit, Delivered) for better order tracking. - Enhanced error handling and logging during shipment creation and tracking updates. - Introduced chargeable weight calculation for shipping rates based on product dimensions and weight. These changes enhance the overall performance and usability of the CZL Express plugin.
763 lines
27 KiB
PHP
763 lines
27 KiB
PHP
<?php
|
||
class CZL_API {
|
||
private $api_url;
|
||
private $username;
|
||
private $password;
|
||
private $token;
|
||
private $token_expires;
|
||
private $country_mapping;
|
||
private $customer_id;
|
||
private $customer_userid;
|
||
|
||
public function __construct() {
|
||
$this->api_url = get_option('czl_api_url', '');
|
||
$this->username = get_option('czl_username', '');
|
||
$this->password = get_option('czl_password', '');
|
||
$this->token = get_transient('czl_api_token');
|
||
$this->token_expires = get_transient('czl_api_token_expires');
|
||
$this->init_country_mapping();
|
||
}
|
||
|
||
/**
|
||
* 初始化国家代码映射
|
||
*/
|
||
private function init_country_mapping() {
|
||
// 从API获取国家列表并缓存
|
||
$cached_mapping = get_transient('czl_country_mapping');
|
||
if ($cached_mapping !== false) {
|
||
$this->country_mapping = $cached_mapping;
|
||
return;
|
||
}
|
||
|
||
try {
|
||
$response = wp_remote_get('https://tms-api-go.czl.net/api/countries', array(
|
||
'timeout' => 30
|
||
));
|
||
|
||
if (is_wp_error($response)) {
|
||
throw new Exception($response->get_error_message());
|
||
}
|
||
|
||
$data = json_decode(wp_remote_retrieve_body($response), true);
|
||
if (!empty($data['data'])) {
|
||
$mapping = array();
|
||
foreach ($data['data'] as $country) {
|
||
$mapping[$country['ename']] = $country['code'];
|
||
}
|
||
$this->country_mapping = $mapping;
|
||
set_transient('czl_country_mapping', $mapping, DAY_IN_SECONDS);
|
||
error_log('CZL Express: Country mapping updated');
|
||
}
|
||
} catch (Exception $e) {
|
||
error_log('CZL Express Error: Failed to get country mapping - ' . $e->getMessage());
|
||
$this->country_mapping = array();
|
||
}
|
||
}
|
||
|
||
/**
|
||
* 转换国家代码
|
||
*/
|
||
private function convert_country_code($wc_country) {
|
||
error_log('CZL Express: Converting country code ' . $wc_country);
|
||
|
||
// 获取WooCommerce国家名称
|
||
$countries = WC()->countries->get_countries();
|
||
$country_name = isset($countries[$wc_country]) ? $countries[$wc_country] : '';
|
||
|
||
// 在映射中查找
|
||
foreach ($this->country_mapping as $name => $code) {
|
||
if (stripos($name, $country_name) !== false || stripos($country_name, $name) !== false) {
|
||
error_log('CZL Express: Found country mapping ' . $wc_country . ' => ' . $code);
|
||
return $code;
|
||
}
|
||
}
|
||
|
||
// 如果没找到映射，返回原始代码
|
||
error_log('CZL Express: No mapping found for ' . $wc_country . ', using original code');
|
||
return $wc_country;
|
||
}
|
||
|
||
/**
|
||
* 获取API认证Token
|
||
*/
|
||
private function get_token() {
|
||
if ($this->token && time() < $this->token_expires) {
|
||
return $this->token;
|
||
}
|
||
|
||
$response = wp_remote_post($this->api_url . '/auth/login', array(
|
||
'body' => array(
|
||
'username' => $this->username,
|
||
'password' => md5($this->password) // CZL API需要MD5加密的密码
|
||
),
|
||
'timeout' => 30
|
||
));
|
||
|
||
if (is_wp_error($response)) {
|
||
throw new Exception($response->get_error_message());
|
||
}
|
||
|
||
$body = json_decode(wp_remote_retrieve_body($response), true);
|
||
|
||
if (empty($body['success'])) {
|
||
throw new Exception(!empty($body['message']) ? $body['message'] : '认证失败');
|
||
}
|
||
|
||
$this->token = $body['data']['token'];
|
||
$this->token_expires = time() + 7200; // CZL token有效期通常是2小时
|
||
|
||
set_transient('czl_api_token', $this->token, 7200);
|
||
set_transient('czl_api_token_expires', $this->token_expires, 7200);
|
||
|
||
return $this->token;
|
||
}
|
||
|
||
/**
|
||
* 发送API请求
|
||
*/
|
||
private function request($endpoint, $method = 'GET', $data = null) {
|
||
$args = array(
|
||
'method' => $method,
|
||
'headers' => array(
|
||
'Authorization' => $this->get_token(),
|
||
'Content-Type' => 'application/json'
|
||
),
|
||
'timeout' => 30
|
||
);
|
||
|
||
if ($data !== null) {
|
||
$args['body'] = json_encode($data);
|
||
}
|
||
|
||
$response = wp_remote_request($this->api_url . $endpoint, $args);
|
||
|
||
if (is_wp_error($response)) {
|
||
throw new Exception($response->get_error_message());
|
||
}
|
||
|
||
$body = json_decode(wp_remote_retrieve_body($response), true);
|
||
|
||
if (empty($body['success'])) {
|
||
throw new Exception(!empty($body['message']) ? $body['message'] : '请求失败');
|
||
}
|
||
|
||
return $body['data'];
|
||
}
|
||
|
||
/**
|
||
* 获取运费报价
|
||
*/
|
||
public function get_shipping_rate($params) {
|
||
try {
|
||
$api_url = 'https://tms.czl.net/defaultPriceSearchJson.htm';
|
||
|
||
// 转换国家代码
|
||
$country_code = $this->convert_country_code($params['country']);
|
||
|
||
// 构建请求参数
|
||
$query = array(
|
||
'weight' => $params['weight'],
|
||
'country' => $country_code,
|
||
'cargoType' => $params['cargoType'],
|
||
'length' => $params['length'],
|
||
'width' => $params['width'],
|
||
'height' => $params['height'],
|
||
'postcode' => $params['postcode']
|
||
);
|
||
|
||
error_log('CZL Express: Shipping rate request - ' . print_r($query, true));
|
||
|
||
// 发送请求
|
||
$response = wp_remote_post($api_url . '?' . http_build_query($query), array(
|
||
'headers' => array(
|
||
'Authorization' => 'Basic ' . base64_encode($this->username . ':' . $this->password)
|
||
),
|
||
'timeout' => 30
|
||
));
|
||
|
||
if (is_wp_error($response)) {
|
||
throw new Exception($response->get_error_message());
|
||
}
|
||
|
||
$body = wp_remote_retrieve_body($response);
|
||
error_log('CZL Express: API raw response - ' . $body);
|
||
|
||
$data = json_decode($body, true);
|
||
if (empty($data)) {
|
||
throw new Exception('Empty API response');
|
||
}
|
||
|
||
// 检查响应格式
|
||
if (!is_array($data)) {
|
||
throw new Exception('Invalid API response format');
|
||
}
|
||
|
||
return $data;
|
||
|
||
} catch (Exception $e) {
|
||
error_log('CZL Express API Error: ' . $e->getMessage());
|
||
throw $e;
|
||
}
|
||
}
|
||
|
||
/**
|
||
* 格式化运费报价结果
|
||
*/
|
||
private function format_shipping_rates($rates) {
|
||
$formatted_rates = array();
|
||
foreach ($rates as $rate) {
|
||
$formatted_rates[] = array(
|
||
'method_id' => 'czl_express_' . sanitize_title($rate['product_id']),
|
||
'method_title' => $rate['product_name'],
|
||
'method_name' => $rate['product_name'],
|
||
'cost' => floatval($rate['total_amount']),
|
||
'delivery_time' => $rate['product_aging'],
|
||
'product_id' => $rate['product_id'],
|
||
'product_note' => $rate['product_note']
|
||
);
|
||
}
|
||
return $formatted_rates;
|
||
}
|
||
|
||
/**
|
||
* 创建运单
|
||
*/
|
||
public function create_order($order_data) {
|
||
try {
|
||
// 添加请求前的日志
|
||
error_log('CZL Express: Creating order with data - ' . print_r($order_data, true));
|
||
|
||
$response = wp_remote_post('https://tms.czl.net/createOrderApi.htm', array(
|
||
'body' => array(
|
||
'Param' => json_encode($order_data)
|
||
),
|
||
'timeout' => 30
|
||
));
|
||
|
||
// 添加响应日志
|
||
error_log('CZL Express: Raw API response - ' . print_r($response, true));
|
||
|
||
if (is_wp_error($response)) {
|
||
throw new Exception('API请求失败: ' . $response->get_error_message());
|
||
}
|
||
|
||
$result = json_decode(wp_remote_retrieve_body($response), true);
|
||
if (json_last_error() !== JSON_ERROR_NONE) {
|
||
throw new Exception('JSON解析失败: ' . json_last_error_msg());
|
||
}
|
||
|
||
if (empty($result['ack']) || $result['ack'] !== 'true') {
|
||
throw new Exception(!empty($result['message']) ? urldecode($result['message']) : '未知错误');
|
||
}
|
||
|
||
return $result;
|
||
|
||
} catch (Exception $e) {
|
||
error_log('CZL Express Error: Create order failed - ' . $e->getMessage());
|
||
error_log('CZL Express Error Stack Trace: ' . $e->getTraceAsString());
|
||
throw $e;
|
||
}
|
||
}
|
||
|
||
/**
|
||
* 获取运单跟踪信息
|
||
*/
|
||
public function get_tracking($tracking_number) {
|
||
try {
|
||
$response = wp_remote_post('https://tms.czl.net/selectTrack.htm', array(
|
||
'body' => array(
|
||
'documentCode' => $tracking_number
|
||
),
|
||
'timeout' => 30
|
||
));
|
||
|
||
if (is_wp_error($response)) {
|
||
throw new Exception($response->get_error_message());
|
||
}
|
||
|
||
$result = json_decode(wp_remote_retrieve_body($response), true);
|
||
|
||
if (empty($result[0]['ack']) || $result[0]['ack'] !== 'true') {
|
||
throw new Exception('获取跟踪信息失败');
|
||
}
|
||
|
||
return $result[0]['data'][0];
|
||
|
||
} catch (Exception $e) {
|
||
error_log('CZL Express API Error: ' . $e->getMessage());
|
||
throw $e;
|
||
}
|
||
}
|
||
|
||
/**
|
||
* 获取运单标签
|
||
*/
|
||
public function get_label($order_id) {
|
||
$url = sprintf(
|
||
'https://tms-label.czl.net/order/FastRpt/PDF_NEW.aspx?Format=lbl_sub一票多件161810499441.frx&PrintType=1&order_id=%s',
|
||
$order_id
|
||
);
|
||
return $url;
|
||
}
|
||
|
||
/**
|
||
* 取消运单
|
||
*/
|
||
public function cancel_order($order_number) {
|
||
return $this->request('/shipping/cancel', 'POST', array(
|
||
'order_number' => $order_number
|
||
));
|
||
}
|
||
|
||
/**
|
||
* 测试认证
|
||
*/
|
||
public function test_auth() {
|
||
try {
|
||
$response = wp_remote_post('https://tms.czl.net/selectAuth.htm', array(
|
||
'body' => array(
|
||
'username' => $this->username,
|
||
'password' => $this->password
|
||
),
|
||
'timeout' => 30
|
||
));
|
||
|
||
if (is_wp_error($response)) {
|
||
throw new Exception($response->get_error_message());
|
||
}
|
||
|
||
$result = json_decode(wp_remote_retrieve_body($response), true);
|
||
|
||
if (empty($result['success'])) {
|
||
throw new Exception('认证失败');
|
||
}
|
||
|
||
return array(
|
||
'customer_id' => $result['customer_id'],
|
||
'customer_userid' => $result['customer_userid']
|
||
);
|
||
|
||
} catch (Exception $e) {
|
||
error_log('CZL Express API Error: ' . $e->getMessage());
|
||
throw $e;
|
||
}
|
||
}
|
||
|
||
/**
|
||
* 获取支持的国家列表
|
||
*/
|
||
public function get_countries() {
|
||
try {
|
||
$response = wp_remote_get('https://tms-api-go.czl.net/api/countries', array(
|
||
'timeout' => 30
|
||
));
|
||
|
||
if (is_wp_error($response)) {
|
||
throw new Exception($response->get_error_message());
|
||
}
|
||
|
||
$result = json_decode(wp_remote_retrieve_body($response), true);
|
||
|
||
if ($result['code'] !== 200) {
|
||
throw new Exception('获取国家列表失败');
|
||
}
|
||
|
||
return $result['data'];
|
||
|
||
} catch (Exception $e) {
|
||
error_log('CZL Express API Error: ' . $e->getMessage());
|
||
throw $e;
|
||
}
|
||
}
|
||
|
||
private function ensure_logged_in() {
|
||
try {
|
||
error_log('CZL Express: Starting authentication');
|
||
|
||
$auth_url = 'https://tms.czl.net/selectAuth.htm';
|
||
$auth_data = array(
|
||
'username' => $this->username,
|
||
'password' => $this->password
|
||
);
|
||
|
||
error_log('CZL Express: Auth request data - ' . print_r($auth_data, true));
|
||
|
||
$ch = curl_init($auth_url);
|
||
curl_setopt($ch, CURLOPT_POST, 1);
|
||
curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
|
||
curl_setopt($ch, CURLOPT_POSTFIELDS, http_build_query($auth_data));
|
||
curl_setopt($ch, CURLOPT_HTTPHEADER, array(
|
||
'Accept-Language: zh-cn',
|
||
'Connection: Keep-Alive',
|
||
'Cache-Control: no-cache'
|
||
));
|
||
curl_setopt($ch, CURLOPT_TIMEOUT, 30);
|
||
|
||
$response = curl_exec($ch);
|
||
error_log('CZL Express: Auth raw response - ' . $response);
|
||
|
||
if (curl_errno($ch)) {
|
||
throw new Exception('认证请求失败');
|
||
}
|
||
|
||
curl_close($ch);
|
||
|
||
// 解析响应
|
||
$result = json_decode(str_replace("'", '"', $response), true);
|
||
error_log('CZL Express: Auth decoded response - ' . print_r($result, true));
|
||
|
||
if (empty($result) || !isset($result['customer_id'])) {
|
||
throw new Exception('认证失败');
|
||
}
|
||
|
||
// 保存认证信息
|
||
$this->customer_id = $result['customer_id'];
|
||
$this->customer_userid = $result['customer_userid'];
|
||
|
||
} catch (Exception $e) {
|
||
error_log('CZL Express Error: Authentication failed - ' . $e->getMessage());
|
||
throw new Exception('认证失败，请联系CZL Express');
|
||
}
|
||
}
|
||
|
||
private function make_request($url, $data = array(), $method = 'POST') {
|
||
try {
|
||
$ch = curl_init();
|
||
|
||
$curl_options = array(
|
||
CURLOPT_URL => $url,
|
||
CURLOPT_RETURNTRANSFER => true,
|
||
CURLOPT_HEADER => false,
|
||
CURLOPT_SSL_VERIFYPEER => true,
|
||
CURLOPT_SSL_VERIFYHOST => 2,
|
||
CURLOPT_TIMEOUT => 60, // 增加超时时间到60秒
|
||
CURLOPT_CONNECTTIMEOUT => 30, // 连接超时时间30秒
|
||
CURLOPT_VERBOSE => true, // 启用详细日志
|
||
CURLOPT_HTTPHEADER => array(
|
||
'Accept: */*',
|
||
'Accept-Language: zh-cn',
|
||
'Cache-Control: no-cache',
|
||
'Content-Type: application/x-www-form-urlencoded;charset=UTF-8'
|
||
)
|
||
);
|
||
|
||
if ($method === 'POST') {
|
||
$curl_options[CURLOPT_POST] = true;
|
||
if (!empty($data)) {
|
||
// 确保数据正确编码
|
||
$post_data = is_array($data) ? http_build_query($data) : $data;
|
||
$curl_options[CURLOPT_POSTFIELDS] = $post_data;
|
||
}
|
||
}
|
||
|
||
curl_setopt_array($ch, $curl_options);
|
||
|
||
// 捕获详细日志
|
||
$verbose = fopen('php://temp', 'w+');
|
||
curl_setopt($ch, CURLOPT_STDERR, $verbose);
|
||
|
||
$response = curl_exec($ch);
|
||
$error = curl_error($ch);
|
||
$errno = curl_errno($ch);
|
||
|
||
// 记录详细日志
|
||
rewind($verbose);
|
||
$verbose_log = stream_get_contents($verbose);
|
||
error_log('CZL Express: Curl verbose log - ' . $verbose_log);
|
||
fclose($verbose);
|
||
|
||
if ($errno) {
|
||
error_log('CZL Express: Curl error - ' . $error);
|
||
throw new Exception('请求失败: ' . $error);
|
||
}
|
||
|
||
if ($response === false) {
|
||
throw new Exception('请求失败');
|
||
}
|
||
|
||
error_log('CZL Express: Raw response - ' . $response);
|
||
|
||
$result = json_decode($response, true);
|
||
if (json_last_error() !== JSON_ERROR_NONE) {
|
||
error_log('CZL Express: JSON decode error - ' . json_last_error_msg());
|
||
throw new Exception('响应数据格式错误');
|
||
}
|
||
|
||
return $result;
|
||
|
||
} catch (Exception $e) {
|
||
error_log('CZL Express Error: Request failed - ' . $e->getMessage());
|
||
throw $e;
|
||
} finally {
|
||
if (isset($ch)) {
|
||
curl_close($ch);
|
||
}
|
||
}
|
||
}
|
||
|
||
/**
|
||
* 认证方法
|
||
*/
|
||
public function authenticate() {
|
||
try {
|
||
error_log('CZL Express: Starting authentication');
|
||
|
||
$auth_url = 'https://tms.czl.net/selectAuth.htm';
|
||
$auth_data = array(
|
||
'username' => $this->username,
|
||
'password' => $this->password
|
||
);
|
||
|
||
error_log('CZL Express: Auth request data - ' . print_r($auth_data, true));
|
||
|
||
$ch = curl_init($auth_url);
|
||
curl_setopt($ch, CURLOPT_POST, 1);
|
||
curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
|
||
curl_setopt($ch, CURLOPT_POSTFIELDS, http_build_query($auth_data));
|
||
curl_setopt($ch, CURLOPT_HTTPHEADER, array(
|
||
'Accept-Language: zh-cn',
|
||
'Connection: Keep-Alive',
|
||
'Cache-Control: no-cache'
|
||
));
|
||
curl_setopt($ch, CURLOPT_TIMEOUT, 30);
|
||
|
||
$response = curl_exec($ch);
|
||
error_log('CZL Express: Auth raw response - ' . $response);
|
||
|
||
if (curl_errno($ch)) {
|
||
throw new Exception('认证请求失败: ' . curl_error($ch));
|
||
}
|
||
|
||
curl_close($ch);
|
||
|
||
// 解析响应
|
||
$result = json_decode(str_replace("'", '"', $response), true);
|
||
error_log('CZL Express: Auth decoded response - ' . print_r($result, true));
|
||
|
||
if (empty($result) || !isset($result['customer_id'])) {
|
||
throw new Exception('认证失败: 无效的响应数据');
|
||
}
|
||
|
||
// 返回认证结果
|
||
return array(
|
||
'ack' => true,
|
||
'customer_id' => $result['customer_id'],
|
||
'customer_userid' => $result['customer_userid'],
|
||
'message' => ''
|
||
);
|
||
|
||
} catch (Exception $e) {
|
||
error_log('CZL Express Error: Authentication failed - ' . $e->getMessage());
|
||
return array(
|
||
'ack' => false,
|
||
'message' => $e->getMessage()
|
||
);
|
||
}
|
||
}
|
||
|
||
public function create_shipment($params) {
|
||
try {
|
||
error_log('CZL Express: Starting create shipment');
|
||
|
||
// 先进行认证
|
||
$auth_result = $this->authenticate();
|
||
if (!$auth_result['ack']) {
|
||
throw new Exception('认证失败: ' . $auth_result['message']);
|
||
}
|
||
|
||
// 添加认证信息到参数
|
||
$params['customer_id'] = $auth_result['customer_id'];
|
||
$params['customer_userid'] = $auth_result['customer_userid'];
|
||
|
||
// 准备请求数据
|
||
$request_data = array(
|
||
'param' => json_encode($params)
|
||
);
|
||
|
||
error_log('CZL Express: Create shipment request data - ' . print_r($request_data, true));
|
||
|
||
// 发送请求
|
||
$curl = curl_init();
|
||
curl_setopt_array($curl, array(
|
||
CURLOPT_URL => 'https://tms.czl.net/createOrderApi.htm',
|
||
CURLOPT_RETURNTRANSFER => true,
|
||
CURLOPT_ENCODING => '',
|
||
CURLOPT_MAXREDIRS => 10,
|
||
CURLOPT_TIMEOUT => 30,
|
||
CURLOPT_HTTP_VERSION => CURL_HTTP_VERSION_2_0,
|
||
CURLOPT_CUSTOMREQUEST => 'POST',
|
||
CURLOPT_POSTFIELDS => http_build_query($request_data),
|
||
CURLOPT_HTTPHEADER => array(
|
||
'Accept: */*',
|
||
'Accept-Language: zh-cn',
|
||
'Cache-Control: no-cache',
|
||
'Content-Type: application/x-www-form-urlencoded;charset=UTF-8'
|
||
),
|
||
CURLOPT_VERBOSE => true,
|
||
CURLOPT_STDERR => fopen('php://temp', 'w+')
|
||
));
|
||
|
||
// 获取详细的CURL日志
|
||
$verbose = fopen('php://temp', 'w+');
|
||
curl_setopt($curl, CURLOPT_STDERR, $verbose);
|
||
|
||
$response = curl_exec($curl);
|
||
$err = curl_error($curl);
|
||
|
||
// 记录CURL详细日志
|
||
rewind($verbose);
|
||
$verboseLog = stream_get_contents($verbose);
|
||
error_log('CZL Express: Curl verbose log - ' . $verboseLog);
|
||
|
||
if ($err) {
|
||
throw new Exception('CURL错误: ' . $err);
|
||
}
|
||
|
||
error_log('CZL Express: Raw response - ' . $response);
|
||
|
||
$result = json_decode($response, true);
|
||
if (json_last_error() !== JSON_ERROR_NONE) {
|
||
throw new Exception('JSON解析错误: ' . json_last_error_msg());
|
||
}
|
||
|
||
error_log('CZL Express: Create shipment response - ' . print_r($result, true));
|
||
|
||
// 检查API错误信息
|
||
if (isset($result['message']) && !empty($result['message'])) {
|
||
error_log('CZL Express: API error message - ' . $result['message']);
|
||
}
|
||
|
||
return $result;
|
||
|
||
} catch (Exception $e) {
|
||
error_log('CZL Express API Error: ' . $e->getMessage());
|
||
throw $e;
|
||
} finally {
|
||
if (isset($curl)) {
|
||
curl_close($curl);
|
||
}
|
||
}
|
||
}
|
||
|
||
/**
|
||
* 获取跟踪单号
|
||
*
|
||
* @param string $czl_order_id CZL订单号
|
||
* @return array 包含跟踪单号的响应数据
|
||
* @throws Exception 如果请求失败
|
||
*/
|
||
public function get_tracking_number($czl_order_id) {
|
||
$endpoint = '/api/tracking/number';
|
||
|
||
$params = array(
|
||
'order_id' => $czl_order_id
|
||
);
|
||
|
||
try {
|
||
$response = $this->send_request('GET', $endpoint, $params);
|
||
|
||
if (empty($response['tracking_number'])) {
|
||
throw new Exception('未找到跟踪单号');
|
||
}
|
||
|
||
return array(
|
||
'tracking_number' => $response['tracking_number'],
|
||
'status' => isset($response['status']) ? $response['status'] : null
|
||
);
|
||
|
||
} catch (Exception $e) {
|
||
throw new Exception('获取跟踪单号失败: ' . $e->getMessage());
|
||
}
|
||
}
|
||
|
||
/**
|
||
* 获取运单跟踪信息
|
||
*/
|
||
public function get_tracking_info($tracking_number) {
|
||
try {
|
||
$response = wp_remote_post('https://tms.czl.net/selectTrack.htm', array(
|
||
'body' => array(
|
||
'documentCode' => $tracking_number
|
||
),
|
||
'timeout' => 30,
|
||
'headers' => array(
|
||
'Accept-Encoding' => '',
|
||
'Accept-Language' => 'zh-CN,zh;q=0.9'
|
||
)
|
||
));
|
||
|
||
if (is_wp_error($response)) {
|
||
throw new Exception($response->get_error_message());
|
||
}
|
||
|
||
$body = wp_remote_retrieve_body($response);
|
||
error_log('CZL Express: Track raw response - ' . $body);
|
||
|
||
// 处理中文编码问题
|
||
$body = preg_replace('/[\x00-\x1F\x80-\xFF]/', '', $body);
|
||
$result = json_decode($body, true);
|
||
|
||
if (json_last_error() !== JSON_ERROR_NONE) {
|
||
error_log('CZL Express: JSON decode error - ' . json_last_error_msg());
|
||
throw new Exception('JSON解析失败: ' . json_last_error_msg());
|
||
}
|
||
|
||
error_log('CZL Express: Track decoded response - ' . print_r($result, true));
|
||
|
||
if (empty($result) || !isset($result[0])) {
|
||
throw new Exception('无效的API响应');
|
||
}
|
||
|
||
if (empty($result[0]['ack']) || $result[0]['ack'] !== 'true') {
|
||
throw new Exception('获取跟踪信息失败: ' . ($result[0]['message'] ?? '未知错误'));
|
||
}
|
||
|
||
if (empty($result[0]['data']) || !is_array($result[0]['data'])) {
|
||
return array(
|
||
'success' => true,
|
||
'data' => array(
|
||
'status' => 'pending',
|
||
'track_content' => '暂无轨迹信息',
|
||
'track_time' => current_time('mysql'),
|
||
'track_location' => ''
|
||
),
|
||
'message' => ''
|
||
);
|
||
}
|
||
|
||
// 获取最新的轨迹状态
|
||
$latest_track = $result[0]['data'][0];
|
||
$track_details = $latest_track['trackDetails'] ?? array();
|
||
$latest_detail = !empty($track_details) ? $track_details[0] : array();
|
||
|
||
// 根据轨迹内容判断状态
|
||
$status = 'in_transit'; // 默认状态
|
||
$track_content = strtolower($latest_detail['track_content'] ?? '');
|
||
|
||
if (strpos($track_content, 'delivered') !== false || strpos($track_content, 'signed') !== false) {
|
||
$status = 'delivered';
|
||
} elseif (strpos($track_content, 'pickup') !== false || strpos($track_content, 'picked up') !== false) {
|
||
$status = 'picked_up';
|
||
}
|
||
|
||
return array(
|
||
'success' => true,
|
||
'data' => array(
|
||
'status' => $status,
|
||
'track_content' => $latest_detail['track_content'] ?? '',
|
||
'track_time' => $latest_detail['track_date'] ?? current_time('mysql'),
|
||
'track_location' => $latest_detail['track_location'] ?? ''
|
||
),
|
||
'message' => ''
|
||
);
|
||
|
||
} catch (Exception $e) {
|
||
error_log('CZL Express API Error: ' . $e->getMessage());
|
||
return array(
|
||
'success' => false,
|
||
'data' => null,
|
||
'message' => $e->getMessage()
|
||
);
|
||
}
|
||
}
|
||
}
|