ensure_cap();
$this->render_header(__('发货及物流', 'aksrt'));
if (!class_exists('AKSRT_Shipping')) {
echo '
' . esc_html__('物流模块未初始化。', 'aksrt') . '
';
$this->render_footer();
return;
}
$view = isset($_GET['view']) ? sanitize_key((string) wp_unslash($_GET['view'])) : 'records';
if (!in_array($view, ['records', 'pending'], true)) {
$view = 'records';
}
$status = isset($_GET['status']) ? sanitize_key((string) wp_unslash($_GET['status'])) : '';
$search = isset($_GET['s']) ? sanitize_text_field((string) wp_unslash($_GET['s'])) : '';
$page_num = max(1, (int) ($_GET['paged'] ?? 1));
$per_page = 20;
$svc = AKSRT_Shipping::get_instance();
$stats = $svc->get_stats();
$status_options = $this->shipping_status_options(true);
$pending_total = 0;
if (class_exists('AKSRT_Order_Repository')) {
$pending_total = (int) (AKSRT_Order_Repository::get_instance()->get_pending_shipment_orders(['limit' => 1, 'search' => ''])['total'] ?? 0);
}
echo '' . esc_html(sprintf(
/* translators: 1: shipping records 2: pending shipment orders */
__('物流记录 %1$d 条 · 待发货订单 %2$d', 'aksrt'),
(int) ($stats['total'] ?? 0),
$pending_total
)) . '
';
echo '';
printf(
'%s ',
esc_url($this->page_url('aksrt_shipping', ['view' => 'pending'])),
$view === 'pending' ? ' nav-tab-active' : '',
esc_html(sprintf(__('待发货 (%d)', 'aksrt'), $pending_total))
);
printf(
'%s ',
esc_url($this->page_url('aksrt_shipping', ['view' => 'records'])),
$view === 'records' ? ' nav-tab-active' : '',
esc_html__('物流记录', 'aksrt')
);
echo ' ';
if ($view === 'pending') {
$this->render_pending_shipment_board($search, $page_num, $per_page);
$this->render_footer();
return;
}
echo '' . esc_html__('新建发货', 'aksrt') . ' ';
echo '';
echo '';
$args = [
'status' => $status,
'limit' => $per_page,
'offset' => ($page_num - 1) * $per_page,
];
if ($search !== '') {
if (preg_match('/^[A-Za-z0-9_-]+$/', $search)) {
$args['order_number'] = $search;
} else {
$args['tracking_no'] = $search;
}
}
$result = $svc->get_list($args);
$items = $result['items'] ?? [];
$total = (int) ($result['total'] ?? 0);
$pages = max(1, (int) ceil(max(1, $total) / $per_page));
$row_status_options = $this->shipping_status_options(false);
$show_express_id = isset($_GET['express_id']) ? (int) $_GET['express_id'] : 0;
echo '';
echo 'ID ' . esc_html__('订单号', 'aksrt') . ' ' . esc_html__('承运商', 'aksrt') . ' ' . esc_html__('运单号', 'aksrt') . ' ' . esc_html__('状态', 'aksrt') . ' ' . esc_html__('时间', 'aksrt') . ' ' . esc_html__('操作', 'aksrt') . ' ';
echo ' ';
if (!$items) {
echo '' . esc_html__('暂无物流记录', 'aksrt') . ' ';
}
foreach ($items as $row) {
$id = (int) ($row['id'] ?? 0);
$st = (string) ($row['status'] ?? '');
$order_number = (string) ($row['order_number'] ?? '');
echo '';
echo '' . esc_html((string) $id) . ' ';
echo '' . esc_html($order_number) . ' ';
echo '' . esc_html((string) ($row['carrier'] ?? '')) . ' ';
echo '' . esc_html((string) ($row['tracking_no'] ?? '')) . ' ';
echo '' . esc_html($row_status_options[$st] ?? $st) . ' ';
echo '' . esc_html((string) ($row['created_at'] ?? '')) . ' ';
echo '';
echo '';
echo '';
echo '' . esc_html__('轨迹', 'aksrt') . ' ';
echo ' ';
if ($show_express_id === $id) {
echo '';
$this->render_express_timeline_panel($id);
echo ' ';
}
}
echo '
';
$this->render_pagination($pages, $page_num);
$this->render_footer();
}
private function render_pending_shipment_board(string $search, int $page_num, int $per_page): void {
if (!class_exists('AKSRT_Order_Repository')) {
echo '' . esc_html__('订单服务不可用。', 'aksrt') . '
';
return;
}
echo '';
$result = AKSRT_Order_Repository::get_instance()->get_pending_shipment_orders([
'search' => $search,
'limit' => $per_page,
'offset' => ($page_num - 1) * $per_page,
]);
$items = $result['items'] ?? [];
$total = (int) ($result['total'] ?? 0);
$pages = max(1, (int) ($result['max_pages'] ?? 1));
$labels = class_exists('AKSRT_Domain_Model')
? AKSRT_Domain_Model::order_status_labels()
: [];
echo '';
echo '' . esc_html__('订单号', 'aksrt') . ' ';
echo '' . esc_html__('用户', 'aksrt') . ' ';
echo '' . esc_html__('类型', 'aksrt') . ' ';
echo '' . esc_html__('金额', 'aksrt') . ' ';
echo '' . esc_html__('状态', 'aksrt') . ' ';
echo '' . esc_html__('支付时间', 'aksrt') . ' ';
echo '' . esc_html__('立即发货', 'aksrt') . ' ';
echo ' ';
if (!$items) {
echo '' . esc_html__('暂无待发货订单', 'aksrt') . ' ';
}
foreach ($items as $row) {
$order_number = (string) ($row['order_number'] ?? '');
$user_id = (int) ($row['user_id'] ?? 0);
$user = $user_id > 0 ? get_userdata($user_id) : null;
$status_key = (string) ($row['status'] ?? '');
echo '';
echo '' . esc_html($order_number) . ' ';
echo '' . ($user ? esc_html($user->display_name . ' (#' . $user_id . ')') : esc_html((string) $user_id)) . ' ';
echo '' . esc_html((string) ($row['product_type'] ?? '')) . ' ';
echo '' . esc_html(number_format((float) ($row['amount'] ?? 0), 2)) . ' ' . esc_html((string) ($row['currency'] ?? '')) . ' ';
echo '' . esc_html($labels[$status_key] ?? $status_key) . ' ';
echo '' . esc_html((string) ($row['paid_at'] ?? $row['created_at'] ?? '')) . ' ';
echo '';
echo '';
echo ' ';
echo ' ';
}
echo '
';
$this->render_pagination($pages, $page_num);
}
public function handle_update_shipping(): void {
if (!current_user_can(self::CAPABILITY)) {
wp_die(esc_html__('权限不足', 'aksrt'));
}
$id = isset($_POST['shipping_id']) ? (int) $_POST['shipping_id'] : 0;
$new_status = isset($_POST['new_status']) ? sanitize_key((string) wp_unslash($_POST['new_status'])) : '';
$note = isset($_POST['note']) ? sanitize_textarea_field((string) wp_unslash($_POST['note'])) : '';
check_admin_referer('aksrt_pay_update_shipping_' . $id);
$ok = false;
if ($id > 0 && $new_status !== '' && class_exists('AKSRT_Shipping')) {
$ok = AKSRT_Shipping::get_instance()->update_status($id, $new_status, $note, get_current_user_id());
}
$redirect_order = isset($_POST['redirect_order']) ? sanitize_text_field((string) wp_unslash($_POST['redirect_order'])) : '';
if ($redirect_order !== '') {
wp_safe_redirect($this->page_url('aksrt_orders', [
'order' => $redirect_order,
'aksrt_pay_msg' => $ok ? 'shipping_updated' : 'shipping_failed',
]));
exit;
}
wp_safe_redirect($this->page_url('aksrt_shipping', [
'view' => 'records',
'aksrt_pay_msg' => $ok ? 'shipping_updated' : 'shipping_failed',
]));
exit;
}
public function handle_query_express(): void {
if (!current_user_can(self::CAPABILITY)) {
wp_die(esc_html__('权限不足', 'aksrt'));
}
$id = isset($_POST['shipping_id']) ? (int) $_POST['shipping_id'] : 0;
$force = !empty($_POST['force']);
check_admin_referer('aksrt_pay_query_express_' . $id);
$ok = false;
$order_number = '';
if ($id > 0 && class_exists('AKSRT_Shipping')) {
$svc = AKSRT_Shipping::get_instance();
$record = $svc->get($id);
$order_number = is_array($record) ? (string) ($record['order_number'] ?? '') : '';
$result = $svc->query_express($id, $force);
$ok = !empty($result['success']);
}
wp_safe_redirect($this->page_url('aksrt_shipping', [
'view' => 'records',
'express_id' => $id,
's' => $order_number,
'aksrt_pay_msg' => $ok ? 'express_ok' : 'express_failed',
]));
exit;
}
public function handle_create_shipping(): void {
if (!current_user_can(self::CAPABILITY)) {
wp_die(esc_html__('权限不足', 'aksrt'));
}
$order_number = isset($_POST['order_number']) ? sanitize_text_field((string) wp_unslash($_POST['order_number'])) : '';
$redirect_page = isset($_POST['redirect_page']) ? sanitize_key((string) wp_unslash($_POST['redirect_page'])) : 'order';
$nonce_action = $redirect_page === 'shipping' ? 'aksrt_pay_create_shipping' : ('aksrt_pay_create_shipping_' . $order_number);
check_admin_referer($nonce_action);
$ok = false;
if ($order_number !== '' && class_exists('AKSRT_Shipping')) {
if (class_exists('AKSRT_Order_Repository')) {
$order = AKSRT_Order_Repository::get_instance()->get($order_number);
if (!$order) {
$this->redirect_shipping_create_result(false, $order_number, $redirect_page);
}
}
$id = AKSRT_Shipping::get_instance()->create([
'order_number' => $order_number,
'carrier' => sanitize_text_field((string) wp_unslash($_POST['carrier'] ?? '')),
'tracking_no' => sanitize_text_field((string) wp_unslash($_POST['tracking_no'] ?? '')),
'note' => sanitize_textarea_field((string) wp_unslash($_POST['note'] ?? '')),
'operator_id' => get_current_user_id(),
]);
$ok = $id > 0;
}
$this->redirect_shipping_create_result($ok, $order_number, $redirect_page);
}
private function redirect_shipping_create_result(bool $ok, string $order_number, string $redirect_page): void {
$msg = $ok ? 'shipping_created' : 'shipping_create_failed';
if ($redirect_page === 'shipping') {
wp_safe_redirect($this->page_url('aksrt_shipping', [
'view' => 'records',
'aksrt_pay_msg' => $msg,
's' => $order_number,
]));
exit;
}
if ($redirect_page === 'pending') {
wp_safe_redirect($this->page_url('aksrt_shipping', [
'view' => 'pending',
'aksrt_pay_msg' => $msg,
]));
exit;
}
wp_safe_redirect($this->page_url('aksrt_orders', [
'order' => $order_number,
'aksrt_pay_msg' => $msg,
]));
exit;
}
public function shipping_status_options_public(bool $include_all = false): array {
return $this->shipping_status_options($include_all);
}
private function shipping_status_options(bool $include_all = false): array {
$options = [];
if ($include_all) {
$options[''] = __('全部状态', 'aksrt');
}
if (class_exists('AKSRT_Shipping')) {
foreach (AKSRT_Shipping::get_status_options() as $item) {
$value = (string) ($item['value'] ?? '');
if ($value === '') {
continue;
}
$options[$value] = (string) ($item['label'] ?? $value);
}
}
if (count($options) === (int) $include_all) {
$options = array_merge($options, [
'shipped' => __('已发货', 'aksrt'),
'in_transit' => __('运输中', 'aksrt'),
'delivered' => __('已签收', 'aksrt'),
'returned' => __('已退回', 'aksrt'),
]);
}
return $options;
}
public function render_carrier_field_public(string $selected = ''): void {
$this->render_carrier_field($selected);
}
private function render_carrier_field(string $selected = ''): void {
$options = [];
if (class_exists('AKSRT_Shipping')) {
foreach (AKSRT_Shipping::get_carrier_options() as $item) {
$value = (string) ($item['value'] ?? '');
$label = (string) ($item['label'] ?? $value);
if ($value !== '') {
$options[$value] = $label;
}
}
}
if ($options) {
echo '';
foreach ($options as $value => $label) {
printf(
'%s ',
esc_attr($value),
selected($selected, $value, false),
esc_html($label)
);
}
echo ' ';
return;
}
echo ' ';
}
private function render_express_timeline_panel(int $shipping_id): void {
if ($shipping_id <= 0 || !class_exists('AKSRT_Shipping')) {
echo '' . esc_html__('无法加载物流轨迹。', 'aksrt') . '
';
return;
}
$svc = AKSRT_Shipping::get_instance();
// Prefer cached data; do not force remote query on pure view.
$timeline = $svc->build_express_timeline($shipping_id);
$record = $svc->get($shipping_id);
echo '';
echo '
' . esc_html__('物流轨迹', 'aksrt') . ' · ';
echo esc_html((string) ($record['carrier'] ?? '')) . ' / ' . esc_html((string) ($record['tracking_no'] ?? ''));
echo '
';
if (!$timeline) {
echo '
' . esc_html__('暂无轨迹,可点击「查物流」拉取快递 API。', 'aksrt') . '
';
echo '
';
return;
}
echo '';
// newest first for operators
$timeline = array_reverse($timeline);
foreach ($timeline as $item) {
$time = (string) ($item['time'] ?? '');
$label = (string) ($item['label'] ?? '');
echo '' . esc_html($time) . ' ' . esc_html($label) . ' ';
}
echo ' ';
}
private function ensure_cap(): void {
if (!current_user_can(self::CAPABILITY)) {
wp_die(esc_html__('您没有权限访问此页面。', 'aksrt'));
}
}
private function render_header(string $title): void {
echo '';
echo '
' . esc_html($title) . ' ';
$this->render_flash();
}
private function render_footer(): void {
echo '';
}
private function render_flash(): void {
if (empty($_GET['aksrt_pay_msg'])) {
return;
}
$code = sanitize_key((string) wp_unslash($_GET['aksrt_pay_msg']));
$map = [
'shipping_updated' => __('物流状态已更新。', 'aksrt'),
'shipping_failed' => __('物流状态更新失败。', 'aksrt'),
'shipping_created' => __('发货记录已创建。', 'aksrt'),
'shipping_create_failed' => __('发货记录创建失败。', 'aksrt'),
'express_ok' => __('物流轨迹已更新。', 'aksrt'),
'express_failed' => __('物流轨迹查询失败。', 'aksrt'),
];
if (!isset($map[$code])) {
return;
}
$class = str_contains($code, 'failed') ? 'notice-error' : 'notice-success';
echo '' . esc_html($map[$code]) . '
';
}
private function page_url(string $slug, array $args = []): string {
return add_query_arg(array_merge(['page' => $slug], $args), admin_url('admin.php'));
}
private function render_pagination(int $pages, int $page_num): void {
if ($pages <= 1) {
return;
}
echo '';
echo paginate_links([
'base' => add_query_arg('paged', '%#%'),
'format' => '',
'prev_text' => '«',
'next_text' => '»',
'total' => $pages,
'current' => $page_num,
]);
echo '
';
}
}