{
$count = 0;
if ($message) {
- $store = MarketplaceStore::getWarehouseGuidByAccountEmail($message['to']) ?? 206008;
+ $store = MarketplaceStore::getWarehouseGuidByAccountEmail($message['to']) ?? 206008;
- $order = self::getOrdersDataFromMessage($message);
+ $order = self::getOrdersDataFromMessage($message);
- if ($message['subject_index'] == self::SUBJECT_INDEX[self::SUBJECT_NEW]) {
- $statusCode = 'PROCESSING';
- $substatusCode = 'STARTED';
- } elseif ($message['subject_index'] == self::SUBJECT_INDEX[self::SUBJECT_APPROVED]) {
- $statusCode = 'PROCESSING';
- $substatusCode = 'APPROVED';
- } elseif ($message['subject_index'] == self::SUBJECT_INDEX[self::SUBJECT_CANCELLED]) {
- $statusCode = 'CANCELLED';
- $substatusCode = 'USER_CHANGED_MIND';
- } elseif ($message['subject_index'] == self::SUBJECT_INDEX[self::SUBJECT_CHANGED]) {
- $statusCode = 'PROCESSING';
- $substatusCode = 'CHANGED';
- } elseif ($message['subject_index'] == self::SUBJECT_INDEX[self::SUBJECT_DELIVERED]) {
- $statusCode = 'DELIVERED';
- $substatusCode = 'DELIVERY_SERVICE_DELIVERED';
- }
- $count = self::processFlowwowOrders($order, $store, $statusCode, $substatusCode, $message['subject_index']);
-
+ if ($message['subject_index'] == self::SUBJECT_INDEX[self::SUBJECT_NEW]) {
+ $statusCode = 'PROCESSING';
+ $substatusCode = 'STARTED';
+ } elseif ($message['subject_index'] == self::SUBJECT_INDEX[self::SUBJECT_APPROVED]) {
+ $statusCode = 'PROCESSING';
+ $substatusCode = 'APPROVED';
+ } elseif ($message['subject_index'] == self::SUBJECT_INDEX[self::SUBJECT_CANCELLED]) {
+ $statusCode = 'CANCELLED';
+ $substatusCode = 'USER_CHANGED_MIND';
+ } elseif ($message['subject_index'] == self::SUBJECT_INDEX[self::SUBJECT_CHANGED]) {
+ $statusCode = 'PROCESSING';
+ $substatusCode = 'CHANGED';
+ } elseif ($message['subject_index'] == self::SUBJECT_INDEX[self::SUBJECT_DELIVERED]) {
+ $statusCode = 'DELIVERED';
+ $substatusCode = 'DELIVERY_SERVICE_DELIVERED';
+ }
+ $count = self::processFlowwowOrders($order, $store, $statusCode, $substatusCode, $message['subject_index']);
+ $marketplaceOrder = MarketplaceOrders::find()
+ ->where(['marketplace_order_id' => (string)key($order)])
+ ->one();
+ if ($statusCode == 'DELIVERED' && $substatusCode == 'DELIVERY_SERVICE_DELIVERED' && $marketplaceOrder) {
+ Yii::error('Заказ ' . $marketplaceOrder->marketplace_order_id);
+ /* @var $marketplaceOrder MarketplaceOrders */
+ $isCheckCreated = self::createCheckForMarketplaceOrder($marketplaceOrder);
+ }
}
return $count;
}
if ($index == self::SUBJECT_INDEX[self::SUBJECT_NEW]) {
$marketplaceOrder = self::createOrder($orderDetails, $campaignId, $statusId, $substatusId);
if ($marketplaceOrder->save()) {
- self::sendMessageToTelegram($marketplaceOrder->guid, "ТеÑ\81Ñ\82овое Ñ\81ообÑ\89ение длÑ\8f https://tracker.yandex.ru/ERP-326 из [2]");
- $newOrdersCount += 1;
- self::createOrUpdateStatusHistory($marketplaceOrder->id, $statusId, $substatusId, $orderDetails);
- self::saveOrderItems($orderDetails, $marketplaceOrder->id, $marketplaceOrder->warehouse_guid);
+ self::sendMessageToTelegram($marketplaceOrder->guid, "Ð\9dовÑ\8bй заказ ФлаÑ\83ваÑ\83");
+ $newOrdersCount += 1;
+ self::createOrUpdateStatusHistory($marketplaceOrder->id, $statusId, $substatusId, $orderDetails);
+ self::saveOrderItems($orderDetails, $marketplaceOrder->id, $marketplaceOrder->warehouse_guid);
} else {
- Yii::error(
- 'Ошибка сохранения заказа: ' . json_encode(
- $marketplaceOrder->getErrors(),
- JSON_UNESCAPED_UNICODE
- )
- );
+ Yii::error(
+ 'Ошибка сохранения заказа: ' . json_encode(
+ $marketplaceOrder->getErrors(),
+ JSON_UNESCAPED_UNICODE
+ )
+ );
}
self::setReadyMarketplaceOrders($marketplaceOrder);
}