From 240dfbd3998ce5a2b793bb70aa7173717cd47256 Mon Sep 17 00:00:00 2001
From: fomichev <vladimir.fomichev@erp-flowers.ru>
Date: Thu, 23 Jan 2025 13:50:33 +0300
Subject: [PATCH] =?utf8?q?=D0=9E=D1=82=D0=BF=D1=80=D0=B0=D0=B2=D0=BA=D0=B0?=
 =?utf8?q?=20=D0=B2=20=D0=B1=D0=B0=D0=B7=D1=83=20=D0=B1=D0=B5=D0=B7=20?=
 =?utf8?q?=D1=80=D1=8D=D0=B1=D0=B1=D0=B8=D1=82=20=D0=BF=D0=BE=20=D0=BE?=
 =?utf8?q?=D1=82=D0=BF=D1=80=D0=B0=D0=B2=D0=BA=D0=B5=20=D1=81=D0=BE=D0=BE?=
 =?utf8?q?=D0=B1=D1=89=D0=B5=D0=BD=D0=B8=D1=8F=20=D0=B2=20=D0=A2=D0=93?=
MIME-Version: 1.0
Content-Type: text/plain; charset=utf8
Content-Transfer-Encoding: 8bit

---
 erp24/commands/CronController.php     | 12 ++---------
 erp24/jobs/SendTelegramMessageJob.php | 30 +++++++++++++++++++++------
 2 files changed, 26 insertions(+), 16 deletions(-)

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'
             );
         }
-- 
2.39.5