<?php
/**
* Класс работы с рассылками
*
* @package AVE.cms
* @subpackage module_mailer
* @filesource
*/
class mailer
{
/**
* Данные
*/
// Путь к директории с шаблонами модуля
var $tpl_dir;
/**
* Внутренние методы класса
*/
/**
* Метод проверки на синтаксис и уникальность email-а внутри списка рассылки
*
* @param string $email e-mail
* @param int $list_id id списка рассылки
*
* @return int
* 0: неверный синтаксис или пустой запрос
* 1: всё отлично
* 2: email уже есть в базе
*/
function _mailerCheckEmail($email='',$list_id=null)
{
if (!$email || !preg_match('/^[^ <>@,\\\\\/]+@[^ <>@,\\\\\/]+\.[^ <>@,\\\\\/]+$/i',$email))
{
return 0;
}
$list_id = (int)trim($list_id);
if ($list_id)
{
global $AVE_DB;
$check = (int)$AVE_DB->Query("
SELECT *
FROM " . PREFIX . "_module_mailer_receivers
WHERE email = '" . $email . "' AND list_id=" . $list_id
)->NumRows();
return (($check==0) ? 1 : 2);
}
else return 1;
}
/**
* Метод сохранения вложений из $_FILES['attach']
*
* @return array $attach массив путей к файлам
*/
function _mailerAttach()
{
// проверяем наличие файлов в форме
if ($_FILES['attach']) $files = $_FILES['attach'];
else return false;
//$maxsize = 5000 * 1024; // 5mb
$attach = array();
$attach_dir = BASE_DIR . '/' . ATTACH_DIR . '/';
foreach ($files['tmp_name'] as $i => $file)
{
if ($file)
{
// проверяем ограничение на размер
if ($maxsize && filesize($file) > $maxsize) continue;
// преобразуем имя файла
$file_name = str_replace(' ','',mb_strtolower(trim($files['name'][$i])));
// проверяем на наличие файла с таким же именем в папке назначения
if (file_exists($attach_dir . $file_name))
{
$file_name = rand(1000, 9999) . '_' . $file_name;
}
// перекидываем файл из врем. дир. в папку назначения
$file_path = $attach_dir . $file_name;
@move_uploaded_file($file, $file_path);
$attach[] = $file_path;
}
}
return $attach;
}
/**
* Метод получения прикреплённого файла
*
* @param string $file имя файла
*/
function _mailerGetFile($file)
{
@ob_start();
header('Pragma: public');
header('Expires: 0');
header('Cache-Control: must-revalidate, post-check=0, pre-check=0');
header('Cache-Control: private',false);
header('Content-Type: application/octet-stream');
header('Content-Disposition: attachment; filename=' . basename($file));
header('Content-Transfer-Encoding: binary');
header('Content-Length: ' . @filesize($file));
@set_time_limit(0);
@readfile($file);
}
/**
* Метод удаления получателя
*
* @param string $id id получателя
*/
function _mailerDelReceiver($id=null,$public=false)
{
global $AVE_DB;
if ($public)
{
$email = $AVE_DB->Query("
SELECT email
FROM " . PREFIX . "_module_mailer_receivers
WHERE id = ". $id
)->FetchRow()->email;
}
$AVE_DB->Query("
DELETE
FROM " . PREFIX . "_module_mailer_receivers
WHERE id = ". $id
);
if ($public) return $email;
else exit;
}
/**
* Метод добавления получателя в список
*/
function _mailerAddReceiver($list_id,$status,$email,$lname=null,$fname=null,$mname=null,$com=null,$update=false)
{
global $AVE_DB;
$check = $this->_mailerCheckEmail(trim($email),$list_id);
if($check == 1)
{
$AVE_DB->Query("
INSERT
INTO " . PREFIX . "_module_mailer_receivers
SET
list_id = '" . (int)$list_id . "',
status = '" . (int)$status . "',
email = '" . trim($email) . "',
lastname = '" . trim($lname) . "',
firstname = '" . trim($fname) . "',
middlename = '" . trim($mname) . "',
comments = '" . trim($com) . "',
date = '" . time() . "'
");
}
elseif($check == 2 && $update)
{
$AVE_DB->Query("
UPDATE " . PREFIX . "_module_mailer_receivers
SET
status = '" . (int)$status . "',
lastname = '" . trim($lname) . "',
firstname = '" . trim($fname) . "',
middlename = '" . trim($mname) . "',
comments = '" . trim($com) . "',
date = '" . time() . "'
WHERE list_id=" . $list_id . " AND email='" . trim($email) . "'
");
}
return $check;
}
/**
* Внешние методы класса
*/
/**
* Вывод списка рассылок
*/
function mailerShowMails()
{
global $AVE_DB, $AVE_Template;
// Постраничная навигация
$limit = 20;
$num = $AVE_DB->Query("
SELECT COUNT(*)
FROM " . PREFIX . "_module_mailer_mails
WHERE sent='1'
ORDER BY date DESC
")->GetCell();
$pages = @ceil($num / $limit);
$start = get_current_page() * $limit - $limit;
// Поиск
if ($_POST['search'])
{
$AVE_Template->assign('search', $_POST['search']);
$AVE_Template->assign('search_words', $_POST['search_words']);
foreach ($_POST['search'] as $field => $true)
{
if ($true) $where[] = $field . " LIKE '%" . $_POST['search_words'] . "%'";
}
$where = implode(' OR ',$where);
$mails_var = array('tpl','sent','find');
}
else $mails_var = array('tpl','sent');
// Создаём три переменные с письмами
foreach ($mails_var as $mail_var)
{
// Запросы к бд
switch ($mail_var)
{
// Черновики
case 'tpl':
$sql = $AVE_DB->Query("
SELECT *
FROM " . PREFIX . "_module_mailer_mails
WHERE sent='0'
ORDER BY id DESC
");
break;
// Отправленные
case 'sent':
$sql = $AVE_DB->Query("
SELECT *
FROM " . PREFIX . "_module_mailer_mails
WHERE sent='1'
ORDER BY date DESC
LIMIT " . $start . "," . $limit
);
break;
// Поиск
case 'find':
$sql = $AVE_DB->Query("
SELECT *
FROM " . PREFIX . "_module_mailer_mails
WHERE sent='1' AND (" . $where . ")
");
break;
}
while ($row = $sql->FetchRow())
{
// получатели из групп
$s = $AVE_DB->Query("
SELECT user_group_name
FROM " . PREFIX . "_user_groups
WHERE user_group = '" . implode(' OR user_group = ', explode(';', $row->to_groups)) . "'
");
$e = array();
while ($r = $s->FetchRow())
{
array_push($e, $r);
}
$row->to_groups = $e;
// получатели из списков
$s = $AVE_DB->Query("
SELECT id, title
FROM " . PREFIX . "_module_mailer_lists
WHERE id = '" . implode(' OR id = ', explode(';', $row->to_lists)) . "'
");
$e = array();
while ($r = $s->FetchRow())
{
array_push($e, $r);
}
$row->to_lists = $e;
// доп. получатели
if ($row->to_add) $row->to_add = explode(';',$row->to_add);
// вложения
$attach = explode(';',$row->attach);
$row->attach = array();
foreach ($attach as $attachment)
{
array_push($row->attach,array('name' => basename($attachment),'path'=>$attachment));
}
// имя автора рассылки
$row->author_name = get_username_by_id($row->author_id);
$mails[$mail_var][] = $row;
}
}
if ($num > $limit)
{
$page_nav = '<a class="pnav" href="index.php?do=modules&action=modedit&mod=mailer&moduleaction=1&page={s}&cp=' . SESSION . '">{t}</a>';
$page_nav = get_pagination($pages, 'page', $page_nav);
$AVE_Template->assign('page_nav', $page_nav);
}
$AVE_Template->assign('mails', $mails);
$AVE_Template->assign('content', $AVE_Template->fetch($this->tpl_dir . 'admin_show_mails.tpl'));
}
/**
* Метод создания новой рассылки
*/
function mailerEditMail()
{
global $AVE_DB, $AVE_Template, $AVE_User;
if (!$_REQUEST['id'] && !$_REQUEST['copy_id'])
{
$mail -> from_name = get_settings('mail_from_name');
$mail -> from_email = get_settings('mail_from');
$mail -> type = 'html';
$mail -> body = $AVE_Template->get_config_vars('MAILER_MAILS_TEXT_D') . "\r\n\r\n\r\n\r\n" . get_settings('mail_signature');
$mail -> appeal = $AVE_Template->get_config_vars('MAILER_MAILS_APPEAL_D');
$mail -> saveattach = 1;
}
else
{
$mail = $AVE_DB->Query("
SELECT *
FROM " . PREFIX . "_module_mailer_mails
WHERE id=" . (($_REQUEST['id']) ? $_REQUEST['id'] : $_REQUEST['copy_id'])
) -> FetchRow();
if ($_REQUEST['copy_id'])
{
$mail->id = null;
$mail->sent = 0;
}
$mail -> to_groups = explode(';',$mail -> to_groups);
$mail -> to_lists = explode(';',$mail -> to_lists);
}
$mail -> site_name = get_settings('site_name');
$mail -> usergroups = $AVE_User->userGroupListGet(2);
$sql = $AVE_DB->Query("
SELECT *
FROM " . PREFIX . "_module_mailer_lists
ORDER BY id DESC
");
$lists = array();
while ($row = $sql -> FetchRow())
{
$lists[$row->id] = $row->title;
}
$mail -> lists = $lists;
$_SESSION['use_editor'] = get_settings('use_editor');
$AVE_Template->assign('mail', $mail);
$AVE_Template->assign('test_email', get_user_rec_by_id($_SESSION['user_id'])->email);
$AVE_Template->assign('content', $AVE_Template->fetch($this->tpl_dir . 'admin_edit_mail.tpl'));
}
/**
* Метод сохранения/удаления/подготовки к отправке рассылки
*/
function mailerSaveMail($mail_id=null, $act='')
{
global $AVE_DB, $AVE_Template, $AVE_User;
// удаление
if ($act=='delete' && $mail_id)
{
$AVE_DB->Query("
DELETE
FROM " . PREFIX . "_module_mailer_mails
WHERE id=" . $mail_id
);
header('Location:index.php?do=modules&action=modedit&mod=mailer&moduleaction=1&cp=' . SESSION . ($_REQUEST['page']?'&page='.$_REQUEST['page']:''));
exit;
}
// сохранение, отправка
// записываем вложения, если оправка
if ($act == 'send') $attach = $this->_mailerAttach();
if (!$mail_id)
{
$AVE_DB->Query("
INSERT
INTO " . PREFIX . "_module_mailer_mails
SET
id = '',
author_id = '" . $_SESSION['user_id'] . "',
date = '" . time() . "',
from_name = '" . trim($_POST['from_name']) . "',
from_email = '" . trim($_POST['from_email']) . "',
from_copy = '" . $_POST['from_copy'] . "',
to_groups = '" . implode(';',$_POST['to_groups']) . "',
to_lists = '" . implode(';',$_POST['to_lists']) . "',
to_add = '" . $_POST['to_add'] . "',
subject = '" . trim($_POST['subject']) . "',
type = '" . $_POST['type'] . "',
appeal = '" . trim($_POST['appeal']) . "',
body = '" . trim($_POST['body']) . "',
saveattach = '" . $_POST['saveattach'] . "',
timing = '" . $_POST['timing'] . "',
attach = '" . @implode(';',$attach) . "',
sent = '0'
");
$mail_id = $AVE_DB->Query("
SELECT LAST_INSERT_ID(id)
FROM " . PREFIX . "_module_mailer_mails
ORDER BY id DESC LIMIT 1
")->GetCell();
reportLog($_SESSION['user_name'] . ' - создал(а) рассылку "' . trim($_POST['subject']) . '" (' . $mail_id . ')', 2, 2);
}
else
{
$AVE_DB->Query("
UPDATE " . PREFIX . "_module_mailer_mails
SET
from_name = '" . trim($_POST['from_name']) . "',
from_email = '" . trim($_POST['from_email']) . "',
from_copy = '" . $_POST['from_copy'] . "',
to_groups = '" . implode(';',$_POST['to_groups']) . "',
to_lists = '" . implode(';',$_POST['to_lists']) . "',
to_add = '" . $_POST['to_add'] . "',
subject = '" . trim($_POST['subject']) . "',
type = '" . $_POST['type'] . "',
appeal = '" . trim($_POST['appeal']) . "',
body = '" . trim($_POST['body']) . "',
saveattach = '" . $_POST['saveattach'] . "',
timing = '" . $_POST['timing'] . "',
attach = '" . @implode(';',$attach) . "',
sent = '0'
WHERE id=" . $mail_id
);
reportLog($_SESSION['user_name'] . ' - отредактировал(а) рассылку "' . trim($_POST['subject']) . '" (' . $mail_id . ')', 2, 2);
}
// отправка
if ($act == 'send') {
// Сохраняем все данные в одну переменную
unset($_SESSION['mailer'][$mail_id]);
$mailer = $_POST;
// номер рассылки
$mailer['id'] = $mail_id;
// сохраняем вложения
$mailer['attach'] = $attach;
// создаём массив получателей
$mailer['receivers'] = array();
$receivers = array();
// получатели из списков
if($mailer['to_lists'])
{
$rec_lists = $AVE_DB->Query("
SELECT *
FROM " . PREFIX . "_module_mailer_receivers
WHERE list_id = " . implode(' OR list_id = ',$mailer['to_lists'])
);
while ($rec = $rec_lists->FetchRow())
{
if(!in_array($rec->email,$receivers) && (int)$rec->status == 1)
{
$rec -> id = 'L' . $rec -> id;
array_push($mailer['receivers'], $rec);
array_push($receivers, $rec->email);
}
}
unset($rec);
}
// получатели из групп
if($mailer['to_groups'])
{
$rec_groups = $AVE_DB->Query("
SELECT id,email,lastname,firstname,user_group
FROM " . PREFIX . "_users
WHERE user_group = " . implode(' OR user_group = ',$mailer['to_groups'])
);
while ($rec = $rec_groups->FetchRow())
{
if(!in_array($rec->email,$receivers))
{
$rec -> id = 'G' . $rec -> id;
array_push($mailer['receivers'], $rec);
array_push($receivers, $rec->email);
}
}
unset($rec);
}
// дополнительные получатели
$rec_add = explode(';',$mailer['to_add']);
foreach ($rec_add as $rec_add_num => $rec_add_1)
{
$rec_add_1 = trim($rec_add_1);
if($rec_add_1 && !in_array($rec_add_1,$receivers) && $this->_mailerCheckEmail($rec_add_1) == 1)
{
$rec = array();
$rec['id'] = 'A' . $rec_add_num;
$rec['email'] = $rec_add_1;
$rec = array2object($rec);
array_push($mailer['receivers'], $rec);
array_push($receivers, $rec->email);
}
}
unset($rec);
// отправитель в копию, если просили
if ($mailer['from_copy'] && !in_array($mailer['from_email'],$receivers))
{
$rec = array();
$rec['id'] = 'C' . $mailer['author_id'];
$rec['email'] = trim($mailer['from_email']);
$rec = array2object($rec);
array_push($mailer['receivers'], $rec);
}
// считаем получателей
$mailer['number'] = count($mailer['receivers']);
$mailer['count'] = 1;
// записываем все данные в сессию
$_SESSION['mailer'][$mail_id] = $mailer;
reportLog($_SESSION['user_name'] . ' - запустил(а) процесс отправки рассылки "' . trim($mailer['subject']) . '" (' . $mail_id . ')', 2, 2);
}
// если сохранение через ajax, выходим
if ($act == 'ajaxsave' || $act == 'send')
{
echo $mail_id;
exit;
}
elseif ($act == 'go' || $act == 'delete')
{
header('Location:index.php?do=modules&action=modedit&mod=mailer&moduleaction=1&cp='.SESSION);
}
}
/**
* Метод отправки рассылки
*/
function mailerSendMail() {
global $AVE_DB;
// получаем id рассылки
$mail_id = $_REQUEST['mail_id'];
// шлём письмо, используя данные сессии
if ($_SESSION['mailer'][$mail_id]['count'] <= $_SESSION['mailer'][$mail_id]['number'])
{
//берём следующего получателя
$rec = array_shift($_SESSION['mailer'][$mail_id]['receivers']);
// Уникальный id письма: %номер рассылки%-%id получателя%
$id = $_SESSION['mailer'][$mail_id]['id'] . '-' . $rec -> id;
// Обращение к получателю
$name = trim($rec->lastname . ' ' . $rec->firstname . ' ' . $rec->middlename);
if (!$name)
{
$name = $_SESSION['mailer'][$mail_id]['appeal'];
}
$body = str_replace(
array('%NAME%' ,'%ID%' ,'%SHOW%'),
array($name ,$id ,'http://'.$_SERVER['SERVER_NAME'].'/index.php?module=mailer&action=show&id='.$mail_id.'&onlycontent=1'),
$_SESSION['mailer'][$mail_id]['body']);
// Посылаем письмо
send_mail(
$rec->email,
$body,
trim($_SESSION['mailer'][$mail_id]['subject']),
trim($_SESSION['mailer'][$mail_id]['from_email']),
trim($_SESSION['mailer'][$mail_id]['from_name']),
trim($_SESSION['mailer'][$mail_id]['type']),
$_SESSION['mailer'][$mail_id]['attach'],
false,false
);
// записываем отправленных в базу, чтобы если что знать, кому уже отправились письма
$_SESSION['mailer'][$mail_id]['done'][] = $rec->email;
$AVE_DB->Query("
UPDATE " . PREFIX . "_module_mailer_mails
SET
date = '" . time() . "',
done = '" . implode(';',$_SESSION['mailer'][$mail_id]['done']) . "',
sent = '1'
WHERE id=" . $mail_id
);
$count = (int)$_SESSION['mailer'][$mail_id]['count'];
$timing = (int)$_SESSION['mailer'][$mail_id]['timing'];
$number = (int)$_SESSION['mailer'][$mail_id]['number'];
// округлённый процент выполнения
$result = floor($count / $number * 100);
// если просили отсылать по частям и осталось много писем, ставим процесс на паузу)
if($timing != 0 && $count % $timing == 0 && $number - $count > 10) $result = 'pause';
// считаем
$_SESSION['mailer'][$mail_id]['count']++;
// возвращаем в AJAX число
echo $result;
}
else
{
// Удаляем вложения, если просили
if ($_SESSION['mailer'][$mail_id]['attach'] && !(int)$_SESSION['mailer'][$mail_id]['saveattach'])
{
foreach ($_SESSION['mailer'][$mail_id]['attach'] as $file)
{
@unlink($file);
}
}
reportLog($_SESSION['user_name'] . ' - процесс отправки рассылки "' . trim($_SESSION['mailer']['subject']) . '" (' . $mail_id . ') завершён', 2, 2);
unset ($_SESSION['mailer'][$mail_id]);
echo 'finish';
}
exit;
}
/**
* Вывод списков рассылок
*/
function mailerShowLists()
{
global $AVE_DB, $AVE_Template;
if ($_POST['del'])
{
foreach ($_POST['del'] as $id => $del)
{
$AVE_DB->Query("
DELETE
FROM " . PREFIX . "_module_mailer_lists
WHERE id = '". $id ."'
");
}
}
$limit = 20;
$num = $AVE_DB->Query("
SELECT COUNT(*)
FROM " . PREFIX . "_module_mailer_lists
ORDER BY id DESC
")->GetCell();
$pages = @ceil($num / $limit);
$start = get_current_page() * $limit - $limit;
$sql = $AVE_DB->Query("
SELECT *
FROM " . PREFIX . "_module_mailer_lists
ORDER BY id DESC
LIMIT " . $start . "," . $limit . "
");
$lists = array();
while ($row = $sql->FetchRow())
{
$count = $AVE_DB->Query("
SELECT COUNT(*)
FROM " . PREFIX . "_module_mailer_receivers
WHERE list_id=" . $row->id
)->GetCell();
$row -> number = (($count) ? $count : 0);
$row -> author_name = get_username_by_id($row->author_id);
array_push($lists, $row);
}
if ($num > $limit)
{
$page_nav = '<a class="pnav" href="index.php?do=modules&action=modedit&mod=mailer&moduleaction=showlists&page={s}&cp=' . SESSION . '">{t}</a>';
$page_nav = get_pagination($pages, 'page', $page_nav);
$AVE_Template->assign('page_nav', $page_nav);
}
$AVE_Template->assign('lists',$lists);
$AVE_Template->assign('content', $AVE_Template->fetch($this->tpl_dir . 'admin_show_lists.tpl'));
}
/**
* Метод загрузки/удаления/создания/редактирования списка рассылки
*/
function mailerEditList()
{
global $AVE_DB, $AVE_Template;
if ($_REQUEST['wipe'] && $_REQUEST['id'])
{
$AVE_DB->Query("
DELETE
FROM " . PREFIX . "_module_mailer_receivers
WHERE list_id=" . $_REQUEST['id']
);
header('Location:index.php?do=modules&action=modedit&mod=mailer&moduleaction=showlists&cp=' . SESSION . ($_REQUEST['page']?'&page='.$_REQUEST['page']:''));
exit;
}
elseif ($_REQUEST['download'] && $_REQUEST['id'])
{
$listname = $AVE_DB->Query("
SELECT title
FROM " . PREFIX . "_module_mailer_lists
WHERE id=" . $_REQUEST['id']
)->GetCell();
$file = '';
$receivers = $AVE_DB->Query("
SELECT *
FROM " . PREFIX . "_module_mailer_receivers
WHERE list_id=" . $_REQUEST['id']
);
while ($rec = $receivers->FetchRow())
{
$file .= $rec->email . ';' . $rec->lastname . ';' . $rec->firstname . ';' . $rec->middlename . ';' . $rec->comments . "\r\n";
}
header('Content-Type: text/plain');
header('Expires: ' . gmdate('D, d M Y H:i:s') . ' GMT');
header('Content-Disposition: attachment; filename=' . $listname . '.csv');
header('Content-Length: ' . strlen($file));
header('Cache-Control: must-revalidate, post-check=0, pre-check=0');
header('Pragma: public');
echo $file;
exit;
}
elseif ($_REQUEST['delete'] && $_REQUEST['id'])
{
$AVE_DB->Query("
DELETE
FROM " . PREFIX . "_module_mailer_lists
WHERE id=" . $_REQUEST['id']
);
header('Location:index.php?do=modules&action=modedit&mod=mailer&moduleaction=showlists&cp=' . SESSION . ($_REQUEST['page']?'&page='.$_REQUEST['page']:''));
exit;
}
if ($_REQUEST['id'])
{
$list = $AVE_DB->Query("
SELECT *
FROM " . PREFIX . "_module_mailer_lists
WHERE id=" . $_REQUEST['id']
)->FetchRow();
$limit = 20;
$num = $AVE_DB->Query("
SELECT COUNT(*)
FROM " . PREFIX . "_module_mailer_receivers
WHERE list_id=" . $_REQUEST['id'] . "
ORDER BY id DESC
")->GetCell();
$pages = @ceil($num / $limit);
$start = get_current_page() * $limit - $limit;
$sql = $AVE_DB->Query("
SELECT *
FROM " . PREFIX . "_module_mailer_receivers
WHERE list_id=" . $_REQUEST['id'] . "
ORDER BY id DESC
LIMIT " . $start . ',' . $limit . "
");
$receivers = array();
while ($row = $sql->FetchRow())
{
array_push($receivers,$row);
}
if ($num > $limit)
{
$page_nav = '<a class="pnav" href="index.php?do=modules&action=modedit&mod=mailer&moduleaction=editlist&id=' . $_REQUEST['id'] . '&page={s}&cp=' . SESSION . '">{t}</a>';
$page_nav = get_pagination($pages, 'page', $page_nav);
$AVE_Template->assign('page_nav', $page_nav);
}
$AVE_Template->assign('list',$list);
$AVE_Template->assign('receivers',$receivers);
}
$AVE_Template->assign('content', $AVE_Template->fetch($this->tpl_dir . 'admin_edit_list.tpl'));
}
/**
* Метод сохранения списка рассылки
*/
function mailerSaveList()
{
global $AVE_DB,$AVE_Template;
if (!$_REQUEST['id'])
{
$AVE_DB->Query("
INSERT
INTO " . PREFIX . "_module_mailer_lists
SET
id = '',
title = '" . trim($_POST['title']) . "',
descr = '" . $_POST['descr'] . "',
author_id = '" . (int)$_SESSION['user_id'] . "',
date = '" . time() . "'
");
$list_id = $AVE_DB->Query("
SELECT LAST_INSERT_ID(id)
FROM " . PREFIX . "_module_mailer_lists
ORDER BY id DESC LIMIT 1
")->GetCell();
reportLog($_SESSION['user_name'] . ' - создал(а) список рассылки "' . trim($_POST['title']) . '" (' . $list_id . ')', 2, 2);
}
else
{
$list_id = $_REQUEST['id'];
$AVE_DB->Query("
UPDATE " . PREFIX . "_module_mailer_lists
SET
title = '" . trim($_POST['title']) . "',
descr = '" . $_POST['descr'] . "'
WHERE id=" . $list_id
);
reportLog($_SESSION['user_name'] . ' - отредактировал(а) список рассылки "' . trim($_POST['title']) . '" (' . $list_id . ')', 2, 2);
}
if ($_POST['status'])
{
foreach ($_POST['status'] as $rec_id => $status)
{
$AVE_DB->Query("
UPDATE " . PREFIX . "_module_mailer_receivers
SET
status = '" . $status . "'
WHERE id=" . $rec_id
);
}
}
if ($_POST['new'])
{
foreach ($_POST['new'] as $rec_id => $rec_row)
{
$rec_row['email'] = trim($rec_row['email']);
$this -> _mailerAddReceiver($list_id,$rec_row['status'],$rec_row['email'],$rec_row['lastn'],$rec_row['firstn'],$rec_row['midn'],$rec_row['comments']);
}
}
if ($_POST['edit'])
{
foreach ($_POST['edit'] as $rec_id => $rec_row)
{
$AVE_DB->Query("
UPDATE " . PREFIX . "_module_mailer_receivers
SET
lastname = '" . $rec_row['lastn'] . "',
firstname = '" . $rec_row['firstn'] . "',
middlename = '" . $rec_row['midn'] . "',
comments = '" . $rec_row['comments'] . "'
WHERE id=" . $rec_id
);
}
}
if ($_POST['import'] && $_POST['import_delim_1'] && $_POST['import_delim_2'] && $_POST['import_delim_1'] != $_POST['import_delim_2'])
{
$delim_1 = stripslashes($_POST['import_delim_1']);
$delim_2 = stripslashes($_POST['import_delim_2']);
if ($delim_1 == "\\r\\n") $delim_1 = "\r\n";
if ($delim_2 == "\\r\\n") $delim_2 = "\r\n";
$import = explode($delim_1,$_POST['import']);
foreach ($import as $receiver)
{
$receiver = explode($delim_2,$receiver);
$this->_mailerAddReceiver($list_id,1,$receiver[0],$receiver[1],$receiver[2],$receiver[3],$receiver[4]);
}
}
if ($_FILES['import_file'])
{
$file_type = end(explode('.',$_FILES['import_file']['name']));
if ($file_type == 'csv')
{
$import = file_get_contents($_FILES['import_file']['tmp_name']);
$file_ok = true;
if (mb_check_encoding($import,'UTF-8') || mb_check_encoding($import,'cp1251'))
{
if (mb_check_encoding($import,'cp1251'))
{
$import = @iconv('cp1251','UTF-8',$import);
}
else $file_ok = false;
}
if ($file_ok)
{
$import = explode("\r\n",$import);
foreach ($import as $receiver)
{
$receiver = explode(($_POST['import_file_delim']) ? $_POST['import_file_delim'] : ';',$receiver);
$this->_mailerAddReceiver($list_id,1,$receiver[0],$receiver[1],$receiver[2],$receiver[3],$receiver[4]);
}
}
}
}
$_SESSION['mailer']['list_import_delim_1'] = $_POST['import_delim_1'];
$_SESSION['mailer']['list_import_delim_2'] = $_POST['import_delim_2'];
$_SESSION['mailer']['list_import_delim_csv'] = $_POST['import_file_delim'];
header('Location:index.php?do=modules&action=modedit&mod=mailer&moduleaction=' . (($_REQUEST['return'] == 1) ? 'editlist&id=' . $list_id : 'showlists') . ($_POST['page']?'&page='.$_POST['page']:'') . '&cp=' . SESSION);
exit;
}
/**
* Метод подписки
*/
function mailerSubscribe()
{
global $AVE_DB,$AVE_Template;
$result = $this->_mailerAddReceiver($_POST['list_id'],1,$_POST['email'],$_POST['lname'],$_POST['fname'],$_POST['mname']);
if ($result == 2)
{
$rec = $AVE_DB->Query("
SELECT id, status
FROM " . PREFIX . "_module_mailer_receivers
WHERE list_id=" . $_POST['list_id'] . " AND email = '" . trim($_POST['email']) . "'
")->FetchRow();
if ((int)$rec->status == 2) $result = 1;
$this->_mailerAddReceiver($_POST['list_id'],1,$_POST['email'],$_POST['lname'],$_POST['fname'],$_POST['mname'],'',true);
}
return $result;
}
/**
* Метод "отписки"
*/
function mailerUnsubscribe()
{
global $AVE_DB,$AVE_Template;
$list_id = trim($_POST['list_id']);
$email = trim($_POST['email']);
$sql = $AVE_DB->Query("
SELECT id, status
FROM " . PREFIX . "_module_mailer_receivers
WHERE list_id = ". $list_id . " AND email = '" . $email . "'
")->FetchRow();
if (!$sql || (int)$sql->status == 2)
{
return 0;
}
else
{
$AVE_DB->Query("
UPDATE ". PREFIX . "_module_mailer_receivers
SET
status = '2'
WHERE id = ". $sql->id
);
return 1;
}
}
/**
* Метод тестовой отправки
*/
function mailerTestSend($id,$emails)
{
global $AVE_DB,$AVE_Template;
// Сохраняем письмо перед отправкой
$this->mailerSaveMail($id);
// Отправляем каждому адресату, если правильный email
foreach (explode(';',$emails) as $email)
{
$email = trim($email);
if ($this->_mailerCheckEmail($email) == 1)
{
// Формируем тело
$body = str_replace(
array('%NAME%' ,'%SHOW%'),
array($_POST['appeal'] ,'http://'.$_SERVER['SERVER_NAME'].'/index.php?module=mailer&action=show&id='.$id.'&onlycontent=1'),
$_POST['body']);
// Отправляем с вложениями
send_mail(
$email,
$body,
trim($_POST['subject']),
trim($_POST['from_email']),
trim($_POST['from_name']),
trim($_POST['type']),
$this->_mailerAttach(),
false,false
);
$emails_new[] = $email;
}
}
reportLog($_SESSION['user_name'] . ' - разослал(а) тестовую рассылку "' . trim($_POST['subject']) . '" (' . $id . ') по адресам: ' . implode(', ',$emails_new), 2, 2);
return $emails_new;
}
/**
* Метод мульти-добавления получателей
*/
function mailerMultiAdd()
{
global $AVE_DB, $AVE_Template;
$sql = $AVE_DB->Query("
SELECT *
FROM " . PREFIX . "_module_mailer_lists
ORDER BY id DESC
");
while ($row = $sql->FetchRow())
{
$lists[] = $row;
}
$AVE_Template->assign('lists', $lists);
$AVE_Template->assign('content', $AVE_Template->fetch($this->tpl_dir . 'admin_multi_add.tpl'));
}
/**
* Метод сохранения получателей из мульти-добавления
*/
function mailerMultiSave()
{
global $AVE_DB;
foreach ($_POST['lists'] as $list_id)
{
foreach ($_POST['new'] as $rec)
{
$this->_mailerAddReceiver($list_id,$rec['status'],$rec['email'],$rec['lastn'],$rec['firstn'],$rec['midn'],$rec['comments'],false);
}
}
$_SESSION['mailer']['multi_add'] = $_POST['lists'];
reportLog($_SESSION['user_name'] . ' - выполнил(а) мульти-добавление получателей в списки: ' . implode(', ',$_POST['lists']), 2, 2);
header('Location:index.php?do=modules&action=modedit&mod=mailer&moduleaction=' . ($_REQUEST['return'] ? 'multiadd' : 'showlists') . '&cp=' . SESSION);
}
/**
* Метод подсчёта получателей при создании рассылки
*/
function mailerCountMail($mail_id)
{
global $AVE_DB, $AVE_Template;
$mailer = $AVE_DB->Query("
SELECT subject, to_lists, to_groups, to_add, from_email, from_copy
FROM " . PREFIX . "_module_mailer_mails
WHERE id=" . $mail_id
)->FetchRow();
$mailer->to_lists = explode(';',$mailer->to_lists);
$mailer->to_groups = explode(';',$mailer->to_groups);
$mailer->to_add = explode(';',$mailer->to_add);
// получатели из списков
foreach ($mailer->to_lists as $list_id)
{
$list_name = $AVE_DB->Query("
SELECT title
FROM " . PREFIX . "_module_mailer_lists
WHERE id = " . $list_id
)->GetCell();
$rec_lists = $AVE_DB->Query("
SELECT *
FROM " . PREFIX . "_module_mailer_receivers
WHERE list_id = " . $list_id
);
while ($rec = $rec_lists->FetchRow())
{
if(!in_array($rec->email,$rec_clean) && (int)$rec->status == 1)
{
$rec_clean[] = $rec->email;
}
else
{
$rec->s = true;
}
$rec_all['lists'][$list_name][] = $rec;
}
}
unset($rec);
// получатели из групп
foreach ($mailer->to_groups as $group_id)
{
$group_name = $AVE_DB->Query("
SELECT user_group_name
FROM " . PREFIX . "_user_groups
WHERE user_group = " . $group_id
)->GetCell();
$rec_groups = $AVE_DB->Query("
SELECT id,email,lastname,firstname,user_group,user_name
FROM " . PREFIX . "_users
WHERE user_group = " . $group_id
);
while ($rec = $rec_groups->FetchRow())
{
if(!in_array($rec->email,$rec_clean))
{
$rec_clean[] = $rec->email;
}
else
{
$rec->s = true;
}
$rec_all['groups'][$group_name][] = $rec;
}
}
unset($rec);
// дополнительные получатели
foreach ($mailer->to_add as $email)
{
$rec = array();
$email = trim($email);
if ($email)
{
if(!in_array($email,$rec_clean) && $this->_mailerCheckEmail($email) == 1)
{
$rec_clean[] = $email;
}
elseif($this->_mailerCheckEmail($email) != 1)
{
$rec['s'] = 2;
}
else
{
$rec['s'] = 1;
}
$rec['email'] = $email;
$rec_all['add'][] = $rec;
}
}
unset($rec);
// отправитель
if ($mailer->from_copy)
{
$rec = array();
$rec['email'] = trim($mailer->from_email);
if(in_array($rec['email'],$rec_clean)) $rec['s'] = 1;
if($this->_mailerCheckEmail($rec['email']) != 1) $rec['s'] = 2;
$rec['from'] = true;
$rec_all['add'][] = $rec;
}
$count_mail = $rec_all;
$count_mail['title'] = $mailer->subject;
$count_mail['number'] = count($rec_clean);
$AVE_Template->assign('count_mail', $count_mail);
$AVE_Template->assign('content', $AVE_Template->fetch($this->tpl_dir . 'admin_count_mail.tpl'));
}
}
?>