From d8af40730575ce9f29e70301bcc9686c9d8bd6b2 Mon Sep 17 00:00:00 2001
From: fomichev <vladimir.fomichev@erp-flowers.ru>
Date: Mon, 20 Jan 2025 19:50:55 +0300
Subject: [PATCH] =?utf8?q?=D0=97=D0=B0=D0=BF=D1=83=D1=81=D0=BA=20=D1=82?=
 =?utf8?q?=D0=B5=D0=BB=D0=B5=D0=B3=D1=80=D0=B0=D0=BC?=
MIME-Version: 1.0
Content-Type: text/plain; charset=utf8
Content-Transfer-Encoding: 8bit

---
 erp24/commands/CronController.php | 12 ++++++++++--
 1 file changed, 10 insertions(+), 2 deletions(-)

diff --git a/erp24/commands/CronController.php b/erp24/commands/CronController.php
index feadf7d9..8ab3a0bb 100644
--- a/erp24/commands/CronController.php
+++ b/erp24/commands/CronController.php
@@ -296,6 +296,10 @@ class CronController extends Controller
                         Yii::$app->queue->push(new SendTelegramMessageDBJob([
                             'messageData' =>  $messageData,
                         ]));
+                        Yii::$app->queue->push(new SendTelegramMessageJob([
+                        'chatId' =>  $telegramUser['chat_id'],
+                        'message' =>  $messageData['message'],
+                        ]));
                 }
 
                 $updatedCount = SentKogort::updateAll(
@@ -448,7 +452,7 @@ class CronController extends Controller
                     BaseConsole::FG_GREEN
                 );
 
-               /* if ($i == 0) {
+               if ($i == 0) {
                     // Выбираем номера для отправки через бота
                    $telegramUsers = UsersTelegram::find()
                         ->where(['is_blocked' => 0, 'is_registered' => 1])
@@ -476,6 +480,10 @@ class CronController extends Controller
                             Yii::$app->queue->push(new SendTelegramMessageDBJob([
                                 'messageData' =>  $messageData,
                             ]));
+                            Yii::$app->queue->push(new SendTelegramMessageJob([
+                            'chatId' =>  $telegramUser['chat_id'],
+                            'message' =>  $messageData['message'],
+                            ]));
                         }
                         $updatedCount = SentKogort::updateAll(
                             ['status' => SentKogort::STATUSES['second']], // Устанавливаем статус "вторая рассылка"
@@ -498,7 +506,7 @@ class CronController extends Controller
                             );
                         }
                     }
-                }*/
+                }
             } else {
                 $this->stdout(
                     "Нет данных для формирования когорты для Ватсапа на {$kogortDate} для целевой даты {$targetDate}.\n",
-- 
2.39.5