From: fomichev <vladimir.fomichev@erp-flowers.ru>
Date: Thu, 23 Jan 2025 10:50:33 +0000 (+0300)
Subject: Отправка в базу без рэббит по отправке сообщения в ТГ
X-Git-Tag: 1.7~44^2
X-Git-Url: https://gitweb.erp-flowers.ru/?a=commitdiff_plain;h=240dfbd3998ce5a2b793bb70aa7173717cd47256;p=erp24_rep%2Fyii-erp24%2F.git

Отправка в базу без рэббит по отправке сообщения в ТГ
---

diff --git a/erp24/commands/CronController.php b/erp24/commands/CronController.php
index be672657..7d81f14c 100644
--- a/erp24/commands/CronController.php
+++ b/erp24/commands/CronController.php
@@ -377,12 +377,8 @@ class CronController extends Controller
                         $messageData['type'] = 1;
                         $messageData['message'] = $messageText;
 
-                        Yii::$app->queue->push(new SendTelegramMessageDBJob([
-                            'messageData' =>  $messageData,
-                        ]));
                         Yii::$app->queue->push(new SendTelegramMessageJob([
-                            'chatId' =>  $telegramUser['chat_id'],
-                            'message' =>  $messageData['message'],
+                            'messageData' => $messageData,
                         ]));
                     }
                 }
@@ -635,12 +631,8 @@ class CronController extends Controller
                         $messageData['type'] = 2;
                         $messageData['message'] = $messageText;
 
-                        Yii::$app->queue->push(new SendTelegramMessageDBJob([
-                            'messageData' => $messageData,
-                        ]));
                         Yii::$app->queue->push(new SendTelegramMessageJob([
-                            'chatId' => $telegramUser['chat_id'],
-                            'message' => $messageData['message'],
+                            'messageData' => $messageData,
                         ]));
                     }
                 }
diff --git a/erp24/jobs/SendTelegramMessageJob.php b/erp24/jobs/SendTelegramMessageJob.php
index 9bab6ac5..74da300a 100644
--- a/erp24/jobs/SendTelegramMessageJob.php
+++ b/erp24/jobs/SendTelegramMessageJob.php
@@ -9,8 +9,7 @@ use yii_app\services\TelegramService;
 
 class SendTelegramMessageJob extends \yii\base\BaseObject implements JobInterface
 {
-    public $chatId;
-    public $message;
+    public $messageData;
 
     public static $messagesSent = 0;
     public static $lastResetTime;
@@ -31,18 +30,37 @@ class SendTelegramMessageJob extends \yii\base\BaseObject implements JobInterfac
             self::$messagesSent = 0;
         }
 
+        $chatId = ($this->messageData)['chat_id'];
+        $phone = ($this->messageData)['phone'];
+        $message = ($this->messageData)['message'];
+
         try {
-            $result = TelegramService::sendMessageToTelegramClient($this->chatId, $this->message);
+            $result = TelegramService::sendMessageToTelegramClient($chatId, $message);
 
             if ($result == "OK") {
-                Yii::warning("Сообщение успешно отправлено пользователю с ID {$this->chatId} {$result}", 'telegram');
+                try {
+                    $result = TelegramService::saveSentMessageToDB($this->messageData);
+
+                    if ($result) {
+                        Yii::warning("Сообщение успешно сохранено для пользователя с ID {$chatId} телефон {$phone}", 'telegram');
+                    } else {
+                        Yii::warning("Сообщение не удалось сохранить для пользователя с ID {$chatId} телефон {$phone}", 'telegram');
+                    }
+
+                } catch (\Exception $e) {
+                    Yii::error(
+                        "Сообщение не удалось сохранить для пользователя ID {$chatId} телефон {$phone}: " . $e->getMessage(),
+                        'telegram'
+                    );
+                }
+                Yii::warning("Сообщение успешно отправлено пользователю с ID {$chatId} {$result}", 'telegram');
             } else {
-                Yii::warning("Сообщение не удалось отправить пользователю ID {$this->chatId} {$result}", 'telegram');
+                Yii::warning("Сообщение не удалось отправить пользователю ID {$chatId} {$result}", 'telegram');
             }
 
         } catch (\Exception $e) {
             Yii::error(
-                "Сообщение не удалось отправить пользователю ID {$this->chatId}: " . $e->getMessage(),
+                "Сообщение не удалось отправить пользователю ID {$chatId}: " . $e->getMessage(),
                 'telegram'
             );
         }