- Написан метод выполняющий рассылку всех непросмотренных кейсов

common/modules/triggers/controllers/DefaultController.php

@@ -3,13 +3,18 @@
 namespace common\modules\triggers\controllers;
 
 use common\components\BaseController;
+use common\modules\content\models\CoContent;
+use common\modules\messageTemplate\models\MessageTemplate;
 use common\modules\triggers\components\conditions\Conditions;
 use common\modules\triggers\models\TriggerLogs;
 use common\modules\triggers\models\TriggerSchedule;
 use common\modules\triggers\models\TriggerTrigger;
 use common\modules\users\models\User;
 use \DateTime;
+use yii\helpers\ArrayHelper;
 use yii\helpers\Json;
+use common\modules\messageTemplate\components\Templates;
+use common\components\UnisenderAPI;
 
 /**
  * Default controller for the `triggers` module
@@ -20,6 +25,7 @@ class DefaultController extends BaseController
         return [
             'Index' => 'Главная страница модуля',
             'Rechecktriggers' => 'Запуск проверки срабатывания триггеров',
+            'Recheckcases' => 'Запуск рассылки кейсов',
             'Settimeoflogs' => 'Фиксация времени логов',
             'Inittrigger' => 'Initiate trigger By id'
         ];
@@ -107,4 +113,65 @@ class DefaultController extends BaseController
             }
         }
     }
+
+    public function actionRecheckcases($category_id = 4, $template_id=1) {
+        /** @var User[] $users */
+        $users = User::find()->all();
+
+        $urls = ArrayHelper::map(CoContent::find()->all(), 'id', 'url');
+
+        foreach($users as $user) {
+            foreach($urls as $url) {
+                if (!TriggerLogs::find()->where(['url' => $url, 'user_id' => $user->id])->exists()) {
+                    $templateData = [];
+                    $email = $user->email;
+                    /** @var \DateTime $time_now */
+                    $time_now=new \DateTime();
+                    /** @var MessageTemplate $templateModel */
+                    $templateModel = MessageTemplate::findOne($template_id);
+                    /** @var Templates $template */
+
+                    $template = new Templates($this->message_template_id, $templateData);
+                    $sender = new UnisenderAPI();
+                    // Create the send list
+                    $newList = $sender->createList();
+                    $newListObject=Json::decode($newList);
+                    if (array_key_exists('result', $newListObject) && is_array($newListObject['result']) && array_key_exists('id', $newListObject['result'])) {
+                        $newListId=$newListObject['result']['id'];
+                        // Subscribe user to new List
+                        $sender->subscribe(['list_ids' => $newListId, 'fields[email]' => $email, 'double_optin' => 1]);
+                        // Create new message
+                        $newMessage=$sender->createEmailMessage('Школа аналитики "Арт Проект"', 'subscribe@task-on.com', $templateModel->subject, $template->getTemplate(), $newListId);
+                        // Decode result
+                        $newMessageObject=Json::decode($newMessage);
+                        if (array_key_exists('result', $newMessageObject) && is_array($newMessageObject['result']) && array_key_exists('message_id', $newMessageObject['result'])) {
+                            // Get the message ID
+                            $newMessageId=$newMessageObject['result']['message_id'];
+                            // Create new campaign
+                            $newCampaign = $sender->createCampaign($newMessageId);
+                            // Parse the result
+                            $newCampaignObject = Json::decode($newCampaign);
+                            if (array_key_exists('result', $newCampaignObject) && is_array($newCampaignObject['result']) && array_key_exists('campaign_id', $newCampaignObject['result'])) {
+                                $newCampaignId = $newCampaignObject['result']['campaign_id'];
+
+                                $schedule = new TriggerSchedule();
+                                $schedule->sended=1;
+                                $schedule->template_id=$this->message_template_id;
+                                $schedule->trigger_id=null;
+                                $schedule->message_id=$newMessageId;
+                                $schedule->message=$template->getTemplate();
+                                $schedule->email=$email;
+                                $schedule->time=$time_now->format('Y-m-d H:i:s');
+                                $schedule->date_create=$time_now->format('Y-m-d H:i:s');
+                                $schedule->list_id=$newListId;
+                                $schedule->campaign_id=$newCampaignId;
+                                $schedule->save(false);
+                            }
+                        }
+                    }
+                }
+            }
+        }
+
+    }
 }