mirror of
https://gitee.com/ShopeX/OMS
synced 2026-08-07 04:15:46 +08:00
673 lines
24 KiB
PHP
673 lines
24 KiB
PHP
<?php
|
||
|
||
/**
|
||
* 淘宝加急发货订单状态构建类
|
||
*/
|
||
class ome_order_urgent
|
||
{
|
||
/**
|
||
* 构建加急订单状态信息
|
||
*
|
||
* 根据订单当前的流转状态和发货单信息，映射为平台要求的加急发货状态码，
|
||
* 并附带物流单号、异常原因、订单明细等扩展信息返回给上游调用方。
|
||
*
|
||
* @param int|string $orderId 订单ID
|
||
* @return array 加急状态信息，包含 orderStatus、status_update_time 等字段；订单不存在时返回空数组
|
||
*/
|
||
public function buildUrgentOrderStatus($orderId)
|
||
{
|
||
// 查询订单主表信息
|
||
$order = app::get('ome')->model('orders')->dump($orderId, 'pay_status,order_id,order_bn,process_status,status,ship_status,sync,sync_fail_type,abnormal,pause,logi_no,source,createway,shop_id,shop_type,last_modified,createtime');
|
||
if (!$order) {
|
||
return [];
|
||
}
|
||
|
||
// 获取订单关联发货单列表，并使用最早创建的主发货单作为订单级状态时间参考
|
||
$deliveryRows = app::get('ome')->model('delivery')->getDeliversByOrderId($orderId);
|
||
$delivery = $this->getPrimaryUrgentDelivery($deliveryRows);
|
||
|
||
$details = $this->buildUrgentOrderDetails($orderId, $deliveryRows, $order);
|
||
$mainStatusData = $this->buildUrgentMainStatus($order, $details, $delivery);
|
||
|
||
return [
|
||
'orderStatus' => $mainStatusData['orderStatus'],
|
||
'status_update_time' => $mainStatusData['status_update_time'],
|
||
'tracking_number' => $mainStatusData['tracking_number'],
|
||
'exception_reason' => $mainStatusData['exception_reason'],
|
||
'order_details' => $details,
|
||
'is_split' => $this->isSplitOrder($order),
|
||
];
|
||
}
|
||
|
||
/**
|
||
* 构建加急发货回告 DTO。
|
||
*
|
||
* @param int|string $orderId
|
||
* @param string $orderBn
|
||
* @return array
|
||
*/
|
||
public function buildUrgentOrderReportDto($orderId, $orderBn = '')
|
||
{
|
||
$statusPayload = $this->buildUrgentOrderStatus($orderId);
|
||
if (empty($statusPayload['orderStatus'])) {
|
||
return [];
|
||
}
|
||
|
||
if (!$orderBn) {
|
||
$order = app::get('ome')->model('orders')->dump($orderId, 'order_bn');
|
||
$orderBn = $order['order_bn'] ?: '';
|
||
}
|
||
|
||
return $this->formatUrgentOrderReportDto($statusPayload, $orderBn);
|
||
}
|
||
|
||
/**
|
||
* 构建矩阵出站参数 erp_synergy_callback_req_dto。
|
||
*
|
||
* @param int|string $orderId
|
||
* @param string $orderBn
|
||
* @return array
|
||
*/
|
||
public function buildUrgentOrderReportParams($orderId, $orderBn = '')
|
||
{
|
||
return $this->wrapUrgentOrderDtoPayload(
|
||
$this->buildUrgentOrderReportDto($orderId, $orderBn),
|
||
'erp_synergy_callback_req_dto'
|
||
);
|
||
}
|
||
|
||
/**
|
||
* 构建加急发货入站响应参数 urgent_delivery_notify_response。
|
||
*
|
||
* @param int|string $orderId
|
||
* @param string $orderBn
|
||
* @return array
|
||
*/
|
||
public function buildUrgentNotifyResponseParams($orderId, $orderBn = '')
|
||
{
|
||
return $this->wrapUrgentOrderDtoPayload(
|
||
$this->buildUrgentOrderReportDto($orderId, $orderBn),
|
||
'urgent_delivery_notify_response'
|
||
);
|
||
}
|
||
|
||
/**
|
||
* 将 DTO 内容包装为指定字段名的 JSON 字符串参数。
|
||
*
|
||
* @param array $payload
|
||
* @param string $fieldName
|
||
* @return array
|
||
*/
|
||
protected function wrapUrgentOrderDtoPayload($payload, $fieldName)
|
||
{
|
||
if (!$payload) {
|
||
return [];
|
||
}
|
||
|
||
$dtoJson = $this->encodeUrgentOrderDtoJson($payload);
|
||
if ($dtoJson === '') {
|
||
return [];
|
||
}
|
||
|
||
return [
|
||
$fieldName => $dtoJson,
|
||
];
|
||
}
|
||
|
||
/**
|
||
* 编码加急回告 DTO，入站响应与主动回告共用。
|
||
*
|
||
* @param array $payload
|
||
* @return string
|
||
*/
|
||
public function encodeUrgentOrderDtoJson($payload)
|
||
{
|
||
$dtoJson = json_encode($payload, JSON_UNESCAPED_UNICODE);
|
||
if ($dtoJson !== false) {
|
||
return $dtoJson;
|
||
}
|
||
|
||
array_walk_recursive($payload, function (&$value) {
|
||
if (is_string($value)) {
|
||
$value = iconv('UTF-8', 'UTF-8//IGNORE', $value);
|
||
}
|
||
});
|
||
|
||
$dtoJson = json_encode($payload, JSON_UNESCAPED_UNICODE);
|
||
return $dtoJson === false ? '' : $dtoJson;
|
||
}
|
||
|
||
/**
|
||
* 将状态聚合结果格式化为 erp_synergy_callback_req_dto 内容。
|
||
*
|
||
* @param array $statusPayload
|
||
* @param string $orderBn
|
||
* @return array
|
||
*/
|
||
public function formatUrgentOrderReportDto($statusPayload, $orderBn)
|
||
{
|
||
$payload = [
|
||
'trade_order_code' => (string)$orderBn,
|
||
'order_status' => (string)$statusPayload['orderStatus'],
|
||
'status_update_time' => $statusPayload['status_update_time'] ?: date('Y-m-d H:i:s'),
|
||
'tracking_number' => '',
|
||
'exception_reason' => '',
|
||
'extend_fields' => '{}',
|
||
'order_details' => array_values((array)($statusPayload['order_details'] ?: [])),
|
||
'is_split' => (bool)($statusPayload['is_split'] ?? false),
|
||
];
|
||
|
||
if (!empty($statusPayload['tracking_number'])) {
|
||
$payload['tracking_number'] = (string)$statusPayload['tracking_number'];
|
||
}
|
||
if (!empty($statusPayload['exception_reason'])) {
|
||
$payload['exception_reason'] = (string)$statusPayload['exception_reason'];
|
||
}
|
||
|
||
return $payload;
|
||
}
|
||
|
||
/**
|
||
* 判断订单是否拆单，逻辑与发货同步 _is_split_order 保持一致。
|
||
*
|
||
* @param array $order
|
||
* @return bool
|
||
*/
|
||
public function isSplitOrder($order)
|
||
{
|
||
if ($order['ship_status'] == '2'
|
||
|| $order['process_status'] == 'remain_cancel'
|
||
|| $order['process_status'] == 'splitting') {
|
||
return true;
|
||
}
|
||
|
||
return count($this->getOrderDeliveryIds($order['order_id'])) > 1;
|
||
}
|
||
|
||
/**
|
||
* 获取订单有效主发货单列表。
|
||
*
|
||
* @param int|string $orderId
|
||
* @return array
|
||
*/
|
||
protected function getOrderDeliveryIds($orderId)
|
||
{
|
||
$sql = "SELECT d.delivery_id,d.status,d.delivery_time
|
||
FROM sdb_ome_delivery_order AS dord
|
||
LEFT JOIN sdb_ome_delivery AS d
|
||
ON(dord.delivery_id=d.delivery_id)
|
||
WHERE dord.order_id='" . intval($orderId) . "'
|
||
AND d.parent_id='0'
|
||
AND d.disabled='false'
|
||
AND d.status IN('succ','progress','ready')";
|
||
$rows = kernel::database()->select($sql);
|
||
|
||
$deliveryIds = [];
|
||
foreach ((array)$rows as $row) {
|
||
$deliveryIds[$row['delivery_id']] = $row;
|
||
}
|
||
|
||
return $deliveryIds;
|
||
}
|
||
|
||
/**
|
||
* 解析加急状态的更新时间
|
||
*
|
||
* 按优先级从发货单和订单中取最合适的时间戳，格式化为 Y-m-d H:i:s 返回。
|
||
* 优先级：发货时间 > 发货单修改时间 > 订单修改时间 > 订单创建时间
|
||
*
|
||
* @param array $order 订单信息
|
||
* @param array $delivery 发货单信息
|
||
* @return string 格式化后的时间字符串
|
||
*/
|
||
protected function resolveUrgentStatusUpdateTime($order, $delivery)
|
||
{
|
||
// 按优先级取时间戳
|
||
$timestamp = 0;
|
||
if (!empty($delivery['delivery_time'])) {
|
||
$timestamp = $delivery['delivery_time'];
|
||
} elseif (!empty($delivery['last_modified'])) {
|
||
$timestamp = $delivery['last_modified'];
|
||
} elseif (!empty($order['last_modified'])) {
|
||
$timestamp = $order['last_modified'];
|
||
} elseif (!empty($order['createtime'])) {
|
||
$timestamp = $order['createtime'];
|
||
}
|
||
|
||
// 无有效时间戳时返回当前时间
|
||
if (!$timestamp) {
|
||
return date('Y-m-d H:i:s');
|
||
}
|
||
// 数字型时间戳转格式化字符串
|
||
if (is_numeric($timestamp)) {
|
||
return date('Y-m-d H:i:s', intval($timestamp));
|
||
}
|
||
|
||
return (string)$timestamp;
|
||
}
|
||
|
||
/**
|
||
* 构建加急订单的商品明细列表
|
||
*
|
||
* 优先使用 order_items 表（含 SKU 信息）拼装明细；
|
||
* 若 order_items 无有效数据则降级使用 order_objects 表。
|
||
*
|
||
* @param int|string $orderId 订单ID
|
||
* @return array 订单明细数组，每项包含 sub_trade_order_code、item_id、sku_id、quantity
|
||
*/
|
||
protected function buildUrgentOrderDetails($orderId, $deliveryRows = [], $order = [])
|
||
{
|
||
$details = [];
|
||
$deliveryRows = (array)$deliveryRows;
|
||
// 查询订单货品和订单商品行
|
||
$objectRows = app::get('ome')->model('order_objects')->getList('obj_id,oid,shop_goods_id,quantity', ['order_id' => $orderId, 'delete' => 'false']);
|
||
$orderItemRows = app::get('ome')->model('order_items')->getList('item_id,obj_id,shop_goods_id,shop_product_id,nums,item_type', ['order_id' => $orderId, 'delete' => 'false']);
|
||
$deliveryDetailRows = app::get('ome')->model('delivery_items_detail')->getList(
|
||
'delivery_id,order_obj_id,order_item_id,oid,number',
|
||
['order_id' => $orderId]
|
||
);
|
||
|
||
// 构建 obj_id => object 映射，便于关联查找
|
||
$objectMap = [];
|
||
foreach ((array)$objectRows as $objectRow) {
|
||
$objectMap[$objectRow['obj_id']] = $objectRow;
|
||
}
|
||
|
||
// 统计每个 obj_id 下的 order_items 数量，用于判断 obj 级映射是否会歧义。
|
||
$objectItemCountMap = [];
|
||
foreach ((array)$orderItemRows as $itemRow) {
|
||
if (empty($itemRow['obj_id'])) {
|
||
continue;
|
||
}
|
||
if (!isset($objectItemCountMap[$itemRow['obj_id']])) {
|
||
$objectItemCountMap[$itemRow['obj_id']] = 0;
|
||
}
|
||
$objectItemCountMap[$itemRow['obj_id']]++;
|
||
}
|
||
|
||
// 构建发货单映射与订单货品 -> 发货单映射，便于按真实发货单状态生成明细状态
|
||
$deliveryMap = [];
|
||
foreach ($deliveryRows as $deliveryRow) {
|
||
$deliveryMap[$deliveryRow['delivery_id']] = $deliveryRow;
|
||
}
|
||
|
||
$detailDeliveryMap = [];
|
||
foreach ((array)$deliveryDetailRows as $deliveryDetailRow) {
|
||
if (!empty($deliveryDetailRow['order_item_id'])) {
|
||
$detailDeliveryMap['item_' . $deliveryDetailRow['order_item_id']] = $deliveryMap[$deliveryDetailRow['delivery_id']];
|
||
}
|
||
if (!empty($deliveryDetailRow['order_obj_id'])) {
|
||
$detailDeliveryMap['obj_' . $deliveryDetailRow['order_obj_id']] = $deliveryMap[$deliveryDetailRow['delivery_id']];
|
||
}
|
||
if (!empty($deliveryDetailRow['oid'])) {
|
||
$detailDeliveryMap['oid_' . $deliveryDetailRow['oid']] = $deliveryMap[$deliveryDetailRow['delivery_id']];
|
||
}
|
||
}
|
||
|
||
// 优先从 order_items 构建明细（包含 SKU 维度信息）
|
||
foreach ((array)$orderItemRows as $itemRow) {
|
||
$objectRow = $objectMap[$itemRow['obj_id']] ?: [];
|
||
if (!$objectRow) {
|
||
continue;
|
||
}
|
||
// 过滤非商品类型且无商品编码的行
|
||
if ($itemRow['item_type'] !== 'product' && !$itemRow['shop_product_id'] && !$itemRow['shop_goods_id']) {
|
||
continue;
|
||
}
|
||
|
||
if (empty($objectRow['oid'])){
|
||
continue;
|
||
}
|
||
|
||
$deliveryRow = [];
|
||
if (!empty($detailDeliveryMap['item_' . $itemRow['item_id']])) {
|
||
$deliveryRow = $detailDeliveryMap['item_' . $itemRow['item_id']];
|
||
} elseif (!empty($objectRow['oid']) && !empty($detailDeliveryMap['oid_' . $objectRow['oid']])) {
|
||
$deliveryRow = $detailDeliveryMap['oid_' . $objectRow['oid']];
|
||
} elseif (($objectItemCountMap[$itemRow['obj_id']] ?: 0) === 1 && !empty($detailDeliveryMap['obj_' . $itemRow['obj_id']])) {
|
||
// 仅当该 obj_id 下只有一个明细时，才允许退化到 obj 级发货单映射，避免把别的明细发货单借给当前明细。
|
||
$deliveryRow = $detailDeliveryMap['obj_' . $itemRow['obj_id']];
|
||
}
|
||
$detailStatus = $this->buildUrgentDetailStatus($deliveryRow, $order);
|
||
$trackingNumber = $this->resolveDetailTrackingNumber($deliveryRow, $detailStatus['order_status']);
|
||
|
||
$details[] = [
|
||
'sub_trade_order_code' => (string)$objectRow['oid'],
|
||
'item_id' => (string)($itemRow['shop_goods_id'] ?: $objectRow['shop_goods_id']),
|
||
'sku_id' => (string)$itemRow['shop_product_id'],
|
||
'quantity' => intval($itemRow['nums']),
|
||
'sub_trade_order_status' => $detailStatus['order_status'],
|
||
'status_update_time' => $detailStatus['status_update_time'],
|
||
'tracking_number' => $trackingNumber,
|
||
];
|
||
}
|
||
|
||
if ($details) {
|
||
return $details;
|
||
}
|
||
|
||
// 降级方案：直接使用 order_objects 构建明细（无 SKU 信息）
|
||
foreach ((array)$objectRows as $objectRow) {
|
||
$deliveryRow = [];
|
||
if (!empty($objectRow['oid']) && !empty($detailDeliveryMap['oid_' . $objectRow['oid']])) {
|
||
$deliveryRow = $detailDeliveryMap['oid_' . $objectRow['oid']];
|
||
} elseif (!empty($detailDeliveryMap['obj_' . $objectRow['obj_id']])) {
|
||
$deliveryRow = $detailDeliveryMap['obj_' . $objectRow['obj_id']];
|
||
}
|
||
$detailStatus = $this->buildUrgentDetailStatus($deliveryRow, $order);
|
||
$trackingNumber = $this->resolveDetailTrackingNumber($deliveryRow, $detailStatus['order_status']);
|
||
$details[] = [
|
||
'sub_trade_order_code' => (string)$objectRow['oid'],
|
||
'item_id' => (string)$objectRow['shop_goods_id'],
|
||
'sku_id' => '',
|
||
'quantity' => intval($objectRow['quantity']),
|
||
'sub_trade_order_status' => $detailStatus['order_status'],
|
||
'status_update_time' => $detailStatus['status_update_time'],
|
||
'tracking_number' => $trackingNumber,
|
||
];
|
||
}
|
||
|
||
return $details;
|
||
}
|
||
|
||
/**
|
||
* 选取订单关联的主发货单，优先取最早创建的有效发货单。
|
||
*
|
||
* @param array $deliveryRows
|
||
* @return array
|
||
*/
|
||
protected function getPrimaryUrgentDelivery($deliveryRows)
|
||
{
|
||
$primaryDelivery = [];
|
||
foreach ((array)$deliveryRows as $deliveryRow) {
|
||
if (!$primaryDelivery) {
|
||
$primaryDelivery = $deliveryRow;
|
||
continue;
|
||
}
|
||
|
||
$primaryCreateTime = intval($primaryDelivery['create_time']);
|
||
$currentCreateTime = intval($deliveryRow['create_time']);
|
||
if ($currentCreateTime && (!$primaryCreateTime || $currentCreateTime < $primaryCreateTime)) {
|
||
$primaryDelivery = $deliveryRow;
|
||
}
|
||
}
|
||
|
||
return $primaryDelivery;
|
||
}
|
||
|
||
/**
|
||
* 按发货单和发货回写日志构建订单明细状态。
|
||
*
|
||
* 规则：
|
||
* - 订单取消 → CANCELLED
|
||
* - 无发货单 → ORDER_CREATED
|
||
* - 明细状态只认当前明细自身映射到的发货单，不借用同订单其它明细的发货单
|
||
* - 有发货单且未发货完成 → WAREHOUSE_PROCESSING
|
||
* - 有发货单且已发货完成时，再用 shipment_log 区分：
|
||
* - shipment_log 失败 → WAREHOUSE_CONSIGN_FAIL
|
||
* - shipment_log 成功 → SHIPPED
|
||
* - 无明确回写结果 → WAREHOUSE_PROCESSING
|
||
*
|
||
* @param array $delivery
|
||
* @param array $order
|
||
* @return array
|
||
*/
|
||
protected function buildUrgentDetailStatus($delivery, $order)
|
||
{
|
||
$detailStatus = 'ORDER_CREATED';
|
||
$detailTime = $this->resolveUrgentDetailStatusUpdateTime($delivery, $order);
|
||
|
||
if ($order['status'] == 'dead' || $order['process_status'] == 'cancel' || $order['pay_status'] == '5') {
|
||
$detailStatus = 'CANCELLED';
|
||
} elseif ($delivery) {
|
||
if ($delivery['status'] != 'succ' && $delivery['process'] != 'true') {
|
||
$detailStatus = 'WAREHOUSE_PROCESSING';
|
||
} else {
|
||
$shipmentLog = $this->getLatestShipmentLog($order['order_bn'], $delivery['logi_no']);
|
||
if ($shipmentLog['status'] == 'fail') {
|
||
$detailStatus = 'WAREHOUSE_CONSIGN_FAIL';
|
||
$detailTime = $this->formatUrgentTimestamp($shipmentLog['updateTime']) ?: $detailTime;
|
||
} elseif ($shipmentLog['status'] == 'succ') {
|
||
$detailStatus = 'SHIPPED';
|
||
$detailTime = $this->formatUrgentTimestamp($shipmentLog['updateTime']) ?: $detailTime;
|
||
} else {
|
||
$detailStatus = 'WAREHOUSE_PROCESSING';
|
||
}
|
||
}
|
||
}
|
||
|
||
return [
|
||
'order_status' => $detailStatus,
|
||
'status_update_time' => $detailTime,
|
||
];
|
||
}
|
||
|
||
/**
|
||
* 解析订单明细状态更新时间。
|
||
*
|
||
* 若存在发货单则取发货单创建时间，否则取订单创建时间。
|
||
*
|
||
* @param array $delivery
|
||
* @param array $order
|
||
* @return string
|
||
*/
|
||
protected function resolveUrgentDetailStatusUpdateTime($delivery, $order)
|
||
{
|
||
$timestamp = $delivery['create_time'] ?: $order['createtime'];
|
||
return $this->formatUrgentTimestamp($timestamp);
|
||
}
|
||
|
||
/**
|
||
* 按子交易单号聚合明细，同一子单取优先级最高的状态。
|
||
*
|
||
* @param array $details
|
||
* @return array
|
||
*/
|
||
protected function aggregateDetailsBySubTradeOrder($details)
|
||
{
|
||
$priorityMap = [
|
||
'WAREHOUSE_CONSIGN_FAIL' => 5,
|
||
'SHIPPED' => 4,
|
||
'CANCELLED' => 3,
|
||
'WAREHOUSE_PROCESSING' => 2,
|
||
'ORDER_CREATED' => 1,
|
||
];
|
||
|
||
$grouped = [];
|
||
foreach ((array)$details as $detail) {
|
||
$oid = (string)$detail['sub_trade_order_code'];
|
||
if ($oid === '') {
|
||
continue;
|
||
}
|
||
if (!isset($grouped[$oid])) {
|
||
$grouped[$oid] = $detail;
|
||
continue;
|
||
}
|
||
|
||
$currentPriority = $priorityMap[$grouped[$oid]['sub_trade_order_status']] ?? 0;
|
||
$newPriority = $priorityMap[$detail['sub_trade_order_status']] ?? 0;
|
||
if ($newPriority > $currentPriority) {
|
||
$grouped[$oid] = $detail;
|
||
}
|
||
}
|
||
|
||
return array_values($grouped);
|
||
}
|
||
|
||
/**
|
||
* 解析子单运单号：SHIPPED 时取映射发货单 delivery.logi_no，主推与入站响应共用。
|
||
*
|
||
* @param array $deliveryRow
|
||
* @param string $detailStatus
|
||
* @return string
|
||
*/
|
||
protected function resolveDetailTrackingNumber($deliveryRow, $detailStatus)
|
||
{
|
||
if ($detailStatus !== 'SHIPPED' || empty($deliveryRow['logi_no'])) {
|
||
return '';
|
||
}
|
||
|
||
return (string)$deliveryRow['logi_no'];
|
||
}
|
||
|
||
/**
|
||
* 从已发货子单中选取主单运单号：优先最早 status_update_time，时间相同按子单号升序。
|
||
* 主单 tracking_number 与 order_details[].tracking_number 均来自 delivery.logi_no。
|
||
*
|
||
* @param array $subOrders
|
||
* @return string
|
||
*/
|
||
protected function resolveMainTrackingFromShippedSubOrders($subOrders)
|
||
{
|
||
$shippedSubs = [];
|
||
foreach ((array)$subOrders as $subOrder) {
|
||
if ($subOrder['sub_trade_order_status'] !== 'SHIPPED') {
|
||
continue;
|
||
}
|
||
if (empty($subOrder['tracking_number'])) {
|
||
continue;
|
||
}
|
||
$shippedSubs[] = $subOrder;
|
||
}
|
||
|
||
if (!$shippedSubs) {
|
||
return '';
|
||
}
|
||
|
||
usort($shippedSubs, function ($left, $right) {
|
||
$timeCompare = strcmp((string)$left['status_update_time'], (string)$right['status_update_time']);
|
||
if ($timeCompare !== 0) {
|
||
return $timeCompare;
|
||
}
|
||
|
||
return strcmp((string)$left['sub_trade_order_code'], (string)$right['sub_trade_order_code']);
|
||
});
|
||
|
||
return (string)$shippedSubs[0]['tracking_number'];
|
||
}
|
||
|
||
/**
|
||
* 根据子单状态聚合主结构状态与时间。
|
||
*
|
||
* 规则：
|
||
* - 任一子单 WAREHOUSE_CONSIGN_FAIL → 主单异常态，不返回运单号
|
||
* - 否则按优先级 SHIPPED > CANCELLED > WAREHOUSE_PROCESSING > ORDER_CREATED
|
||
* - 主单 SHIPPED 时，运单号取已发货子单对应发货单 logi_no；多个 SHIPPED 时取最早时间，时间相同按子单号升序
|
||
* - 主结构 status_update_time 取命中状态对应子单时间
|
||
*
|
||
* @param array $order
|
||
* @param array $details
|
||
* @param array $delivery
|
||
* @return array
|
||
*/
|
||
protected function buildUrgentMainStatus($order, $details, $delivery = [])
|
||
{
|
||
$defaultStatus = 'ORDER_CREATED';
|
||
$defaultTime = $this->resolveUrgentStatusUpdateTime($order, $delivery);
|
||
|
||
if (!$details) {
|
||
return [
|
||
'orderStatus' => $defaultStatus,
|
||
'status_update_time' => $defaultTime,
|
||
'tracking_number' => '',
|
||
'exception_reason' => '',
|
||
];
|
||
}
|
||
|
||
$subOrders = $this->aggregateDetailsBySubTradeOrder($details);
|
||
|
||
$failSubOrder = null;
|
||
foreach ($subOrders as $subOrder) {
|
||
if ($subOrder['sub_trade_order_status'] !== 'WAREHOUSE_CONSIGN_FAIL') {
|
||
continue;
|
||
}
|
||
if (!$failSubOrder || strcmp((string)$subOrder['status_update_time'], (string)$failSubOrder['status_update_time']) < 0) {
|
||
$failSubOrder = $subOrder;
|
||
}
|
||
}
|
||
if ($failSubOrder) {
|
||
return [
|
||
'orderStatus' => 'WAREHOUSE_CONSIGN_FAIL',
|
||
'status_update_time' => $failSubOrder['status_update_time'],
|
||
'tracking_number' => '',
|
||
'exception_reason' => '发货状态回写平台失败',
|
||
];
|
||
}
|
||
|
||
$priorityMap = [
|
||
'SHIPPED' => 4,
|
||
'CANCELLED' => 3,
|
||
'WAREHOUSE_PROCESSING' => 2,
|
||
'ORDER_CREATED' => 1,
|
||
];
|
||
|
||
$bestDetail = [
|
||
'sub_trade_order_status' => $defaultStatus,
|
||
'status_update_time' => $defaultTime,
|
||
];
|
||
|
||
foreach ($subOrders as $subOrder) {
|
||
$detailStatus = $subOrder['sub_trade_order_status'];
|
||
$detailPriority = $priorityMap[$detailStatus] ?? 0;
|
||
$bestPriority = $priorityMap[$bestDetail['sub_trade_order_status']] ?? 0;
|
||
if ($detailPriority > $bestPriority) {
|
||
$bestDetail = $subOrder;
|
||
}
|
||
}
|
||
|
||
$trackingNo = '';
|
||
if ($bestDetail['sub_trade_order_status'] === 'SHIPPED') {
|
||
$trackingNo = $this->resolveMainTrackingFromShippedSubOrders($subOrders);
|
||
}
|
||
|
||
return [
|
||
'orderStatus' => $bestDetail['sub_trade_order_status'],
|
||
'status_update_time' => $bestDetail['status_update_time'],
|
||
'tracking_number' => $trackingNo,
|
||
'exception_reason' => '',
|
||
];
|
||
}
|
||
|
||
/**
|
||
* 读取当前订单+运单号对应的最新发货回写日志。
|
||
*
|
||
* @param string $orderBn
|
||
* @param string $logiNo
|
||
* @return array
|
||
*/
|
||
protected function getLatestShipmentLog($orderBn, $logiNo)
|
||
{
|
||
if (!$orderBn || !$logiNo) {
|
||
return [];
|
||
}
|
||
|
||
$rows = app::get('ome')->model('shipment_log')->getList(
|
||
'status,updateTime,deliveryCode',
|
||
['orderBn' => $orderBn, 'deliveryCode' => $logiNo],
|
||
0,
|
||
1,
|
||
'updateTime DESC, log_id DESC'
|
||
);
|
||
|
||
return $rows ? $rows[0] : [];
|
||
}
|
||
|
||
/**
|
||
* 统一格式化时间戳。
|
||
*
|
||
* @param mixed $timestamp
|
||
* @return string
|
||
*/
|
||
protected function formatUrgentTimestamp($timestamp)
|
||
{
|
||
if (!$timestamp) {
|
||
return date('Y-m-d H:i:s');
|
||
}
|
||
if (is_numeric($timestamp)) {
|
||
return date('Y-m-d H:i:s', intval($timestamp));
|
||
}
|
||
|
||
return (string)$timestamp;
|
||
}
|
||
}
|