From: Alexander Smirnov <fredeom@mail.ru>
Date: Wed, 5 Mar 2025 10:40:44 +0000 (+0300)
Subject: [ERP-326] mq added
X-Git-Url: https://gitweb.erp-flowers.ru/?a=commitdiff_plain;h=f3472b682d33a65a20e247fa4d03e024b6a0aaf5;p=erp24_rep%2Fyii-erp24%2F.git

[ERP-326] mq added
---

diff --git a/erp24/jobs/SendTelegramTestMessageJob.php b/erp24/jobs/SendTelegramTestMessageJob.php
new file mode 100644
index 00000000..ec44129e
--- /dev/null
+++ b/erp24/jobs/SendTelegramTestMessageJob.php
@@ -0,0 +1,38 @@
+<?php
+
+namespace app\jobs;
+
+
+use GuzzleHttp\Client;
+use Yii;
+use yii\queue\JobInterface;
+use yii_app\services\TelegramService;
+
+class SendTelegramTestMessageJob extends \yii\base\BaseObject implements JobInterface
+{
+    public $messageData;
+
+    public function execute($queue)
+    {
+        $message = ($this->messageData)['message'];
+
+        $botToken = TelegramService::TELEGRAM_BOT_DEV;
+        $apiURL = "https://api.telegram.org/bot{$botToken}/sendMessage";
+        $chats = ['337084327', '5489795686']; //Алексей
+        $message = TelegramService::escapeMarkdown($message);
+        $client = new Client();
+        foreach ($chats as $chatId) {
+            try {
+                $client->post($apiURL, [
+                    'json' => [
+                        'chat_id' => $chatId,
+                        'text' => $message,
+                        'parse_mode' => 'MarkdownV2',
+                    ],
+                ]);
+            } catch (\Exception $e) {
+                Yii::error("Ошибка отправки сообщения в Telegram: " . $e->getMessage(), 'telegram');
+            }
+        }
+    }
+}
diff --git a/erp24/scripts/tasks/task_35_new_order_to_telegram.php b/erp24/scripts/tasks/task_35_new_order_to_telegram.php
index 0ea25e00..359a11d5 100644
--- a/erp24/scripts/tasks/task_35_new_order_to_telegram.php
+++ b/erp24/scripts/tasks/task_35_new_order_to_telegram.php
@@ -68,24 +68,9 @@ try {
             MarketplaceOrders::updateAll(['status_telegram' => MarketplaceOrders::STATUS_TELEGRAM_SENT],
                                          ['status_telegram' => MarketplaceOrders::STATUS_TELEGRAM_PREPARED_TO_SEND]);
 
-            $botToken = TelegramService::TELEGRAM_BOT_DEV;
-            $apiURL = "https://api.telegram.org/bot{$botToken}/sendMessage";
-            $chats = ['337084327', '5489795686']; //Алексей
-            $message = TelegramService::escapeMarkdown("Тестовое сообщение для https://tracker.yandex.ru/ERP-326 из шедулера");
-            $client = new Client();
-            foreach ($chats as $chatId) {
-                try {
-                    $client->post($apiURL, [
-                        'json' => [
-                            'chat_id' => $chatId,
-                            'text' => $message,
-                            'parse_mode' => 'MarkdownV2',
-                        ],
-                    ]);
-                } catch (\Exception $e) {
-                    Yii::error("Ошибка отправки сообщения в Telegram: " . $e->getMessage(), 'telegram');
-                }
-            }
+            Yii::$app->queue->push(new \app\jobs\SendTelegramTestMessageJob([
+                'message' => "Тестовое сообщение для https://tracker.yandex.ru/ERP-326 из шедулера"
+            ]));
         }
         ////////////////////////////////////////////////////////////////////////
         $info = ' ================ test Task ' . $taskNum . ' stop ================';