- Добавлено действие срабатывающее ПОСЛЕ подписки пользователя

common/modules/users/models/User.php

@@ -6,6 +6,7 @@ use common\modules\messageTemplate\controllers\TemplateAdminController;
 use common\modules\messageTemplate\models\MessageTemplate;
 use common\modules\triggers\components\conditions\Conditions;
 use common\modules\triggers\components\conditions\conditions\CheckUserToRegistration;
+use common\modules\triggers\components\conditions\conditions\CheckUserToSubscribe;
 use common\modules\triggers\models\AuthHashes;
 use common\modules\triggers\models\TriggerCondition;
 use common\modules\triggers\models\TriggerLogs;
@@ -630,55 +631,34 @@ class User extends \common\components\ActiveRecordModel implements IdentityInter
 		return true;
     }
 
-    /**
-     * @param $template_id
-     */
-    public function afterSubscribe($template_id, $params=array()){
-        /** @var \DateTime $time_now */
-        $time_now=new \DateTime();
-        /** @var MessageTemplate $templateModel */
-        $templateModel = MessageTemplate::findOne($template_id);
-        /** @var Templates $template */
-        $template = new Templates($template_id, $params);
-        $email = $this->email;
-        $sender = new UnisenderAPI();
-        // Create the send list
-        $newList = $sender->createList();
-        $newListObject=Json::decode($newList);
-        if (array_key_exists('result', $newListObject) && 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($this->name, $email, $templateModel->subject, $template->getTemplate(), $newListId);
-            // Decode result
-            $newMessageObject=Json::decode($newMessage);
-            if (array_key_exists('result', $newMessageObject) && 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) && array_key_exists('campaign_id', $newCampaignObject['result'])) {
-                    $newCampaignId = $newCampaignObject['result']['campaign_id'];
-
-                    $schedule = new TriggerSchedule();
-                    $schedule->sended=1;
-                    $schedule->checked=0;
-                    $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;
-                    if (!$schedule->save()) {
-                        echo 'Письмо не было отправлено';
-                    }
-                }
-            }
-        }
+	/**
+	 * @param array $params
+	 * @return bool
+	 */
+    public function afterSubscribe($params=array()){
+		/** @var TriggerTrigger[] $actualTriggers */
+		$actualTriggers = TriggerTrigger::getActualTriggers();
+		foreach($actualTriggers as $trigger) {
+			$exists = TriggerCondition::find()->where(['trigger_id'=>$trigger->id, 'condition_id'=>CheckUserToSubscribe::CONDITION_ID])->exists();
+			$count = TriggerCondition::find()->where(['trigger_id'=>$trigger->id])->count();
+			// Добавляем в расписание срабатывание триггера регистрации только при условии что у триггера условие регистрации есть и оно там одно
+			if ($exists===true && $count==1) {
+				$init = $trigger->initAction($params);
+				if ($init===true) {
+					$curl = curl_init();
+					curl_setopt($curl, CURLOPT_URL, Yii::$app->urlManager->createAbsoluteUrl('/triggers/default/rechecktriggers'));
+					curl_setopt($curl, CURLOPT_RETURNTRANSFER, true);
+					if (!curl_exec($curl)) {
+						$this->addError('email', curl_error($curl));
+						return false;
+					}
+					return true;
+				} else {
+					$this->addError('email', $init);
+					return false;
+				}
+			}
+		}
     }
 
 	/**