|
|
@@ -533,13 +533,22 @@ class ShopController extends BaseController {
|
|
|
foreach ($orderList as $order) {
|
|
|
// 发送wst仓库系统
|
|
|
$response = $logistics->createOrder($order);
|
|
|
- LoggerTool::warning($response);
|
|
|
+ LoggerTool::info($response);
|
|
|
if ($response['success'] == 1) {
|
|
|
// 写入mongo
|
|
|
Tool::wstOrderCall($response['data']);
|
|
|
$orderSnSuccess[] = $order['SN'];
|
|
|
} else {
|
|
|
+ // 记录推送结果
|
|
|
$orderSnFailed[] = $order['SN'];
|
|
|
+ LoggerTool::error(sprintf('自动推送wst失败. 订单号[%s], error[%s]', $order['SN'], $response));
|
|
|
+ // 发送预警通知
|
|
|
+ $alarm = [
|
|
|
+ 'trace-id' => Tool::generateId(),
|
|
|
+ 'message' => sprintf('自动推送wst失败. 订单号[%s], error[%s]', $order['SN'], $response),
|
|
|
+ ];
|
|
|
+ Alarm::reportAlarm($alarm);
|
|
|
+
|
|
|
}
|
|
|
}
|
|
|
|
|
|
@@ -549,17 +558,6 @@ class ShopController extends BaseController {
|
|
|
Order::updateAll(['SEND_AT' => time()], "SN IN ('" . $orderSnSuccessIds . "')");
|
|
|
}
|
|
|
|
|
|
- if (count($orderSnFailed) > 0) {
|
|
|
- // 发送预警通知
|
|
|
- LoggerTool::error(['自动推送wst失败', $orderSnFailed]);
|
|
|
-
|
|
|
- $alarm = [
|
|
|
- 'trace-id' => Tool::generateId(),
|
|
|
- 'message' => '跨境订单自动推送wst失败. 订单编号:' . implode(', ', $orderSnFailed),
|
|
|
- ];
|
|
|
- Alarm::reportAlarm($alarm);
|
|
|
- }
|
|
|
-
|
|
|
return static::notice(sprintf('wstLogisticsAutoSend success order count{%d}, orderSN[%s]; failed count{%d}, orderSN[%s]', count($orderSnSuccess), implode(', ', $orderSnSuccess), count($orderSnFailed), implode(', ', $orderSnFailed)));
|
|
|
}
|
|
|
}
|