Делаем свои триггерные рассылки

include_once($_SERVER['DOCUMENT_ROOT'] . "/bitrix/php_interface/sender/handlers.php");

<?

class SenderTriggerBlogComment extends \Bitrix\Sender\Trigger
{
   public function getName()
   {
      return 'Добавлен комментарий';
   }

   public function getCode()
   {
      return "my_blog_comment";
   }

   public function getEventModuleId()
   {
      return 'blog';
   }

   public function getEventType()
   {
      return "OnCommentAdd";
   }
   
   public function getRecipient()
   {
      return array(
         'NAME' => 'Иван',
         'EMAIL' => 'ivan@example.com',
         'USER_ID' => '3'
      );
   }

   public function filter()
   {
      // безусловно разрешаем запустить рассылку
      return true;
   }

   public function getForm()
   {
      return '';
   }
}
   

   AddEventHandler("sender", "OnTriggerList", array("MySenderEventHandler","onTriggerList"));
   class MySenderEventHandler
   {
       public static function onTriggerList($data)
       {
      require_once($_SERVER['DOCUMENT_ROOT'] . '/bitrix/php_interface/trigger_blog_comment.php');
      $data['TRIGGER'] = 'SenderTriggerBlogComment';
      return $data;
       }
   }
   

$event = $this->getParam('EVENT');

   $event = $this->getParam('EVENT');
   $ID = $event[0];
   $arFields = $event[1];
   

   $event = $this->getParam('EVENT');
   $authorId = $event[1]['AUTHOR_ID'];
   

   public function getRecipient()
   {
      // получим данные из события
      $event = $this->getParam('EVENT');
      // Во втором параметре события есть код пользователя AUTHOR_ID
      $authorId = $event[1]['AUTHOR_ID'];

      if($authorId)
      {
         // получим email и имя пользователя, оставившего комментарий
         $user = \Bitrix\Main\UserTable::getRowById($authorId);
         if($user)
         {
            // возвращаем данные адресата в виде массива
            return array(
               'EMAIL' => $user['EMAIL'],
               'NAME' => $user['NAME'],
               'USER_ID' => $user['ID'],
            );
         }
      }

      // если не нашли данные адресата, то некому и рассылать
      return false;
   }
   

   public function getForm()
   {
      $blogId = $this->getFieldValue('BLOG_ID');
      
      $blogList = array();
      $blogDb = CBlog::GetList(
         array('ID' => 'DESC'),
         array('ACTIVE' => 'Y'),
         false,
         false,
         array('NAME', 'ID')
      );
      while($blog = $blogDb->Fetch())
      {
         $blog['SEL ECTED'] = ($blog['ID'] == $blogId ? true : false);
         $blogList[] = $blog;
      }

      ob_start();
      ?>
      <table>
         <tr>
            <td>Блог:</td>
            <td>
               <sel ect name="<?=$this->getFieldName('BLOG_ID');?>">
                  <option value="">(любой)</option>
                  <?foreach($blogList as $blog):?>
                     <option value="<?=htmlspecialcharsbx($blog['ID'])?>" <?=($blog['SEL ECTED'] ? 'sel ected' : '')?>>
                        <?=htmlspecialcharsbx($blog['NAME'])?>
                     </option>
                  <?endforeach?>
               </select>
            </td>
         </tr>
      </table>
      <?
      $resultForm = ob_get_clean();

      return $resultForm;
   }
   

   public function filter()
   {
      // получим код блога, в который добавлен комментарий
      $event = $this->getParam('EVENT');
      $eventBlogId = $event[1]['BLOG_ID'];
      
      // Сравним, что комментарий добавлен в блоге,
      // который указан в настройках формы. Если они одинаковы, запускаем рассылку.
      // Если в настройках не указан блог, то запускаем рассылку.
      $blogId = $this->getFieldValue('BLOG_ID');
      if($blogId && $blogId != $eventBlogId)
      {
         // запрещаем запускать рассылку
         return false;
      }
      
      // разрешаем запустить рассылку
      return true;
   }
   

   public function getPersonalizeFields()
   {
      $eventData = $this->getParam('EVENT');
      return array(
         'BLOG_COMMENT_ID' => $eventData[0],
         'BLOG_POST_ID' => $eventData[1]['POST_ID'],
         'BLOG_ID' => $eventData[1]['BLOG_ID'],
      );
   }
   

   public static function getPersonalizeList()
   {
      return array(
         array(
            'CODE' => 'BLOG_ID', // код тега, доступен как #BLOG_ID#
            'NAME' => 'Код блога', // выводимое название тега
            'DESC' => 'Это код блога, с которым связано событие' // описание
         ),
         array(
            'CODE' => 'BLOG_POST_ID',
            'NAME' => 'Код поста блога',
            'DESC' => 'Это код поста блога, с которым связано событие'
         ),
         array(
            'CODE' => 'BLOG_COMMENT_ID',
            'NAME' => 'Код комментария',
            'DESC' => 'Это код комментария, с которым связано событие'
         ),
      );
   }
   

$siteId = $this->getSiteId();

<?

class SenderTriggerViewedProduct extends \Bitrix\Sender\TriggerConnectorClosed
{
   /*
    * @return string
    *
    * Название триггера
    */
   public function getName()
   {
      return 'Просмотрел товары и ушел';
   }

   /*
    * @return string
    *
    * Уникальный код триггера
    */
   public function getCode()
   {
      return "my_viewed_product";
   }

   /*
    * @return bool
    *
    * Может ли триггер использоваться как цель,
    * а не только для запуска
    */
   public static function canBeTarget()
   {
      return false;
   }

   /*
    * @return bool
    *
    * Функция, которая сообщает, запускать ли рассылку для данного события.
    *
    */
   public function filter()
   {
      \Bitrix\Main\Loader::includeModule('sale');
      \Bitrix\Main\Loader::includeModule('catalog');


      $days = $this->getFieldValue('DAYS_VIEW');
      if(!is_numeric($days))
      {
         $days = 1;
      }

      $dateFr om = new \Bitrix\Main\Type\DateTime;
      $dateTo = new \Bitrix\Main\Type\DateTime;

      $dateFr om->setTime(0, 0, 0)->add('-' . $days.' days');
      $dateTo->setTime(0, 0, 0)->add('-' . ($days - 1) . ' days');

      $userListDb = \Bitrix\Catalog\CatalogViewedProductTable::getList(array(
         'select' => array('USER_ID' => 'FUSER.USER.ID', 'EMAIL' => 'FUSER.USER.EMAIL', 'NAME' => 'FUSER.USER.NAME'),
         'filter' => array(
            '=SITE_ID' => $this->getSiteId(),
            '>DATE_VISIT' => $dateFr om,
            '<DATE_VISIT' => $dateTo,
         ),
         'group' => array('USER_ID', 'EMAIL', 'NAME'),
         'order' => array('FUSER.USER.ID' => 'ASC')
      ));

      if($userListDb->getSelectedRowsCount() > 0)
      {
         // есть просмотренные товары
         // сохраняем список адресатов
         $this->recipient = $userListDb;

         // запускаем рассылку
         return true;
      }
      else
      {
         // нет просмотренных товаров, не запускаем рассылку
         return false;
      }
   }


   /*
    * @return string
    *
    * Форма настройки триггера
    */
   public function getForm()
   {
      return '
         <table>
            <tr>
               <td>Сколько дней назад:</td>
               <td>
                  <input size=3 type="text" name="'.$this->getFieldName('DAYS_VIEW').'" value="'.htmlspecialcharsbx($this->getFieldValue('DAYS_VIEW', 90)).'">
               </td>
            </tr>
         </table>
      ';
   }


   /*
    * @return array|\Bitrix\Main\DB\Result|\CDBResult
    *
    * Функция, которая из данных события
    * вернет данные о получателе рассылки
    */
   public function getRecipient()
   {
      // возвращаем сохраненные адресаты
      return $this->recipient;
   }
}

   public static function canRunForOldData()
   {
      return true;
   }
   

      if($this->isRunForOldData())
      {
         $filter = array(
            '!DATE_VISIT' => null,
            '<DATE_VISIT' => $dateTo,
         );
      }
      else
      {
         $filter = array(
            '>DATE_VISIT' => $dateFr om,
            '<DATE_VISIT' => $dateTo,
         );
      }
      $filter['=SITE_ID'] = $this->getSiteId();
      
      $userListDb = \Bitrix\Catalog\CatalogViewedProductTable::getList(array(
         'select' => array('USER_ID' => 'FUSER.USER.ID', 'EMAIL' => 'FUSER.USER.EMAIL', 'NAME' => 'FUSER.USER.NAME'),
         'filter' => $filter,
         'group' => array('USER_ID', 'EMAIL', 'NAME'),
         'order' => array('FUSER.USER.ID' => 'ASC')
      ));

AddEventHandler("sender", "OnPresetMailingList", array("MySenderEventHandler", "onPresetMailingList"));

class MySenderEventHandler
{
    public static function onPresetMailingList()
    {
        $result = array();

        $result[] = array(
            'TYPE' => 'Мои рассылки',
            'CODE' => 'my_sale_view_prod',
            'NAME' => 'Пример',
            'DESC_USER' => 'Это автоматическая рассылка, предлагающая скидки, если вы просмотрели товар, но не решились купить его.',
            'DESC' => 'Рассылка, запускаемая через день для тех, кто просмотрел на сайте товары.',
            'TRIGGER' => array(
                'START' => array(
                    'ENDPOINT' => array(
                        'MODULE_ID' => '',
                        'CODE' => 'my_viewed_product',
                        'FIELDS' => array('DAYS_VIEW' => 1)
                    )
                ),
                'END' => array(
                    'ENDPOINT' => array(
                        'MODULE_ID' => 'sale',
                        'CODE' => 'order_paid',
                        'FIELDS' => array()
                    )
                ),
            ),
            'CHAIN' => array(
                array(
                    'TIME_SHIFT' => 0,
                    'SUBJECT' => 'Письмо #1',
                    'MESSAGE' => 'Здравствуйте, #NAME#<br><br>Это письмо #1.',
                ),
                array(
                    'TIME_SHIFT' => 1440,
                    'SUBJECT' => 'Письмо #2',
                    'MESSAGE' => 'Здравствуйте, #NAME#<br><br>Это письмо #2.',
                ),
                array(
                    'TIME_SHIFT' => 1440,
                    'SUBJECT' => 'Письмо #3',
                    'MESSAGE' => 'Здравствуйте, #NAME#<br><br>Это письмо #3.',
                ),
            )
        );


        return $result;
    }
}