}
}
+ public static function sendMessageToTelegram($guid, $message)
+ {
+ Yii::$app->queue->push(new \yii_app\jobs\SendTelegramTestMessageJob([
+ 'message' => $message,
+ 'guid' => $guid,
+ ]));
+ }
+
public static function processOrders(array $allOrders)
{
$statuses = MarketplaceOrderStatusTypes::find()
$marketplaceOrder->raw_data = $newRawData;
if ($marketplaceOrder->save()) {
-
- Yii::$app->queue->push(new \yii_app\jobs\SendTelegramTestMessageJob([
- 'message' => "Тестовое сообщение для https://tracker.yandex.ru/ERP-326 из afterSave",
- 'guid' => $marketplaceOrder->guid,
- ]));
+ self::sendMessageToTelegram($marketplaceOrder->guid, "Тестовое сообщение для https://tracker.yandex.ru/ERP-326 из [1]");
$newOrdersCount += 1;
// Создаем запись истории статусов
$marketplaceOrder->status_id = (int)$statusId;
$marketplaceOrder->substatus_id = (int)$substatusId;
$marketplaceOrder->updated_at = date('Y-m-d H:i:s', strtotime($order->getUpdatedAt()));
- $marketplaceOrder->save();
+ if (!$marketplaceOrder->save()) {
+ Yii::error(
+ 'Ошибка сохранения: ' . json_encode(
+ $marketplaceOrder->getErrors(),
+ JSON_UNESCAPED_UNICODE
+ )
+ );
+ }
$updatedOrdersCount += 1;
// Обновление истории статусов, если изменился статус
$statusHistoryRecord = MarketplaceOrderStatusHistory::find()
if ($index == self::SUBJECT_INDEX[self::SUBJECT_NEW]) {
$marketplaceOrder = self::createOrder($orderDetails, $campaignId, $statusId, $substatusId);
if ($marketplaceOrder->save()) {
+ self::sendMessageToTelegram($marketplaceOrder->guid, "Тестовое сообщение для https://tracker.yandex.ru/ERP-326 из [2]");
$newOrdersCount += 1;
self::createOrUpdateStatusHistory($marketplaceOrder->id, $statusId, $substatusId, $orderDetails);
self::saveOrderItems($orderDetails, $marketplaceOrder->id, $marketplaceOrder->warehouse_guid);